Documentation
¶
Index ¶
- type DBStore
- func (s *DBStore) GetLatestOffset(ctx context.Context, eventAccountAddress, eventHandle, eventFieldName string) (uint64, error)
- func (s *DBStore) GetTransmitterSequenceNum(ctx context.Context, transmitterAddress string) (uint64, error)
- func (s *DBStore) GetTxVersionByID(ctx context.Context, id uint64) (uint64, error)
- func (s *DBStore) InsertEvents(ctx context.Context, records []EventRecord) error
- func (s *DBStore) QueryEvents(ctx context.Context, eventAccountAddress, eventHandle, eventFieldName string, ...) ([]EventRecord, error)
- func (s *DBStore) UpdateTransmitterSequence(ctx context.Context, transmitterAddress string, sequenceNumber uint64) error
- type EventRecord
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBStore ¶
type DBStore struct {
// contains filtered or unexported fields
}
func NewDBStore ¶
func NewDBStore(ds sqlutil.DataSource, logger logger.Logger) *DBStore
func (*DBStore) GetLatestOffset ¶
func (*DBStore) GetTransmitterSequenceNum ¶
func (*DBStore) GetTxVersionByID ¶
func (*DBStore) InsertEvents ¶
func (s *DBStore) InsertEvents(ctx context.Context, records []EventRecord) error
func (*DBStore) QueryEvents ¶
func (s *DBStore) QueryEvents(ctx context.Context, eventAccountAddress, eventHandle, eventFieldName string, expressions []query.Expression, limitAndSort query.LimitAndSort) ([]EventRecord, error)
Click to show internal directories.
Click to hide internal directories.