storage

Jun 7, 2024

Changes in this version

+ type Config struct

+ MaxConnecting uint64

+ MaxPoolSize uint64

+ MetricsEnabled bool

+ Password string

+ URI string

+ User string

+ type Storage struct

+ func New(cfg Config, l zerolog.Logger) *Storage

+ func (s *Storage) CountErrorMessages(ctx context.Context) (int64, error)

+ func (s *Storage) CountErrorTxs(ctx context.Context) (int64, error)

+ func (s *Storage) CreateBlock(ctx context.Context, block *model.Block) error

+ func (s *Storage) GetAllBlocks(ctx context.Context) (blocks []*model.Block, err error)

+ func (s *Storage) GetBlockByHeight(ctx context.Context, height int64) (*model.Block, error)

+ func (s *Storage) GetErrorBlockHeights(ctx context.Context) ([]int64, error)

+ func (s *Storage) GetLatestBlock(ctx context.Context) (*model.Block, error)

+ func (s *Storage) InsertErrorMessage(ctx context.Context, message model.Message) error

+ func (s *Storage) InsertErrorTx(ctx context.Context, tx model.Tx) error

+ func (s *Storage) Ping(ctx context.Context) error

+ func (s *Storage) SetErrorStatus(ctx context.Context, height int64, msg string) error

+ func (s *Storage) SetProcessedStatus(ctx context.Context, height int64) error

+ func (s *Storage) Start(ctx context.Context) error

+ func (s *Storage) Stop(ctx context.Context) error

+ func (s *Storage) UpdateStatus(ctx context.Context, height int64, status model.Status) error