store

Documentation

Index

• type Pg
  • func (pg *Pg) Close()
  • func (pg *Pg) InsertFaucetGive(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertOwnershipChange(ctx context.Context, eventPayload event.Event) error
  • func (pg *Pg) InsertPool(ctx context.Context, contractAddress string, name string, symbol string) 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) InsertToken(ctx context.Context, contractAddress string, name string, symbol string, ...) 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
  • func (pg *Pg) RemoveContractAddress(ctx context.Context, eventPayload event.Event) error
• 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) InsertOwnershipChange

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

func (*Pg) InsertPool

func (pg *Pg) InsertPool(ctx context.Context, contractAddress string, name string, symbol string) 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) InsertToken

func (pg *Pg) InsertToken(ctx context.Context, contractAddress string, name string, symbol string, decimals uint8, sinkAddress string) 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

func (*Pg) RemoveContractAddress

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

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
	InsertOwnershipChange(context.Context, event.Event) error
	InsertToken(context.Context, string, string, string, uint8, string) error
	InsertPool(context.Context, string, string, string) error
	RemoveContractAddress(context.Context, event.Event) error
	Pool() *pgxpool.Pool
	Close()
}

func NewPgStore

func NewPgStore(o PgOpts) (Store, error)