store

Documentation

Index

• type Pg
  • func (pg *Pg) Close()
  • func (pg *Pg) InsertFaucetGive(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertPoolDeposit(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertPoolSwap(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertPriceQuoteUpdate(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertTokenBurn(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertTokenMint(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertTokenTransfer(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) Pool() *pgxpool.Pool
• type PgOpts
• type Store
  • func NewPgStore(o PgOpts) (Store, error)

Types

type Pg

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

func (*Pg) Close

func (pg *Pg) Close()

func (*Pg) InsertFaucetGive

func (pg *Pg) InsertFaucetGive(ctx context.Context, eventPayload event.Event) error

func (*Pg) InsertPoolDeposit

func (pg *Pg) InsertPoolDeposit(ctx context.Context, eventPayload event.Event) error

func (*Pg) InsertPoolSwap

func (pg *Pg) InsertPoolSwap(ctx context.Context, eventPayload event.Event) error

func (*Pg) InsertPriceQuoteUpdate

func (pg *Pg) InsertPriceQuoteUpdate(ctx context.Context, eventPayload event.Event) error

func (*Pg) InsertTokenBurn

func (pg *Pg) InsertTokenBurn(ctx context.Context, eventPayload event.Event) error

func (*Pg) InsertTokenMint

func (pg *Pg) InsertTokenMint(ctx context.Context, eventPayload event.Event) error

func (*Pg) InsertTokenTransfer

func (pg *Pg) InsertTokenTransfer(ctx context.Context, eventPayload event.Event) error

func (*Pg) Pool

func (pg *Pg) Pool() *pgxpool.Pool

type PgOpts

type PgOpts struct {
	Logg                 *slog.Logger
	DSN                  string
	MigrationsFolderPath string
	QueriesFolderPath    string
}

type Store

type Store interface {
	InsertTokenTransfer(context.Context, event.Event) error
	InsertTokenMint(context.Context, event.Event) error
	InsertTokenBurn(context.Context, event.Event) error
	InsertFaucetGive(context.Context, event.Event) error
	InsertPoolSwap(context.Context, event.Event) error
	InsertPoolDeposit(context.Context, event.Event) error
	InsertPriceQuoteUpdate(context.Context, event.Event) error
	Pool() *pgxpool.Pool
	Close()
}

func NewPgStore

func NewPgStore(o PgOpts) (Store, error)