postgres

Documentation

Index

• Constants
• type Handler
• type PGSink
  • func NewSink(cfg SinkConfig) (*PGSink, error)
  • func (s *PGSink) LoadCursor(ctx context.Context, chainId string) (blockNum uint64, blockHash string, err error)
  • func (s *PGSink) Migrate(ctx context.Context, sqlString string) error
  • func (s *PGSink) MigrateWithFile(ctx context.Context, filePath string) error
  • func (s *PGSink) Rollback(ctx context.Context, chainId string, toBlock uint64, blockHash string) (err error)
  • func (s *PGSink) Store(ctx context.Context, events []types.Event) (err error)
  • func (s *PGSink) UpdateCursor(ctx context.Context, chainId string, newBlock uint64, blockHash string) error
• type SinkConfig

Constants

const (
	// threshold to switch to COPY for bulk inserting
	DefaultCopyThreshold = 32
)

Types

type Handler

type Handler interface {
	Handle(ctx context.Context, tx pgx.Tx, ev types.Event) error
}

type PGSink

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

func NewSink

func NewSink(cfg SinkConfig) (*PGSink, error)

func (*PGSink) LoadCursor

func (s *PGSink) LoadCursor(ctx context.Context, chainId string) (blockNum uint64, blockHash string, err error)

func (*PGSink) Migrate

func (s *PGSink) Migrate(ctx context.Context, sqlString string) error

func (*PGSink) MigrateWithFile

func (s *PGSink) MigrateWithFile(ctx context.Context, filePath string) error

func (*PGSink) Rollback

func (s *PGSink) Rollback(ctx context.Context, chainId string, toBlock uint64, blockHash string) (err error)

func (*PGSink) Store

func (s *PGSink) Store(ctx context.Context, events []types.Event) (err error)

func (*PGSink) UpdateCursor

func (s *PGSink) UpdateCursor(ctx context.Context, chainId string, newBlock uint64, blockHash string) error

type SinkConfig

type SinkConfig struct {
	Pool          *pgxpool.Pool
	Handler       Handler
	CopyThreshold int
	Metrics       metrics.Metrics
}