postgres

package

v0.0.7 Latest Latest Go to latest Published: Feb 18, 2025 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateIndex(ctx context.Context, tx bun.Tx) error

CreateIndex - creates all needed indices in postgres database

func CreateTypes(ctx context.Context, conn *database.Bun) error

type CelestialState struct {
	// contains filtered or unexported fields
}

func NewCelestialState(db *database.Bun) *CelestialState

func (cs *CelestialState) ByName(ctx context.Context, name string) (result storage.CelestialState, err error)

func (cs *CelestialState) Save(ctx context.Context, state *storage.CelestialState) error

type CelestialTransaction struct {
	sdk.Transaction
}

func BeginCelestialTransaction(ctx context.Context, tx sdk.Transactable) (CelestialTransaction, error)

func (tx CelestialTransaction) SaveCelestials(ctx context.Context, celestials iter.Seq[storage.Celestial]) error

func (tx CelestialTransaction) UpdateState(ctx context.Context, state *storage.CelestialState) error

func (tx CelestialTransaction) UpdateStatusForAddress(ctx context.Context, addressId iter.Seq[uint64]) error

type Celestials struct {
	*database.Bun
}

func NewCelestials(db *database.Bun) *Celestials

func (c *Celestials) ByAddressId(ctx context.Context, addressId uint64, limit, offset int) (result []storage.Celestial, err error)

func (c *Celestials) ById(ctx context.Context, id string) (result storage.Celestial, err error)

func (c *Celestials) Primary(ctx context.Context, addressId uint64) (result storage.Celestial, err error)