persistence

Nov 14, 2023

Changes in this version

+ const PostgresDriver

+ const SQLiteDriver

+ const UndefinedDriver

+ func GetDriverType(db *sql.DB) int

Sep 17, 2023

Changes in this version

+ type Metrics interface

+ RecordError func(err metricsErrCategory)

+ RecordInsertDuration func(duration time.Duration)

+ RecordMessage func(num int)

+ RecordQueryDuration func(duration time.Duration)

+ type MigrationFn func(db *sql.DB) error

+ type Queries struct

+ func CreateQueries(tbl string, db *sql.DB) *Queries

+ func (q Queries) Delete() string

+ func (q Queries) Exists() string

+ func (q Queries) Get() string

+ func (q Queries) GetSize() string

+ func (q Queries) Limit() string

+ func (q Queries) Offset() string

+ func (q Queries) Prefix() string

+ func (q Queries) Put() string

+ func (q Queries) Query() string

May 12, 2023

Changes in this version

+ const MaxTimeVariance

+ var ErrFutureMessage = errors.New("message timestamp in the future")

+ var ErrMessageTooOld = errors.New("message too old")

type DBStore

+ func (d *DBStore) Validate(env *protocol.Envelope) error

type MessageProvider

+ Validate func(env *protocol.Envelope) error

Jan 23, 2023

Changes in this version

type DBOption

+ func WithMigrations(migrationFn func(db *sql.DB) error) DBOption

Dec 21, 2022

Changes in this version

+ const DBKeyLength

+ const DigestLength

+ const HashLength

+ const PubsubTopicLength

+ const TimestampLength

+ const WALMode

+ var ErrInvalidByteSize = errors.New("byte slice has invalid length")

+ var ErrInvalidCursor = errors.New("invalid cursor")

+ type ConnectionPoolOptions struct

+ ConnectionMaxIdleTime time.Duration

+ ConnectionMaxLifetime time.Duration

+ MaxIdleConnections int

+ MaxOpenConnections int

+ type DBKey struct

+ func NewDBKey(senderTimestamp uint64, receiverTimestamp uint64, pubsubTopic string, ...) *DBKey

+ func (k *DBKey) Bytes() []byte

+ type DBOption func(*DBStore) error

+ func DefaultOptions() []DBOption

+ func WithDB(db *sql.DB) DBOption

+ func WithDriver(driverName string, datasourceName string, ...) DBOption

+ func WithMigrationsEnabled(enabled bool) DBOption

+ func WithRetentionPolicy(maxMessages int, maxDuration time.Duration) DBOption

+ type DBStore struct

+ func NewDBStore(log *zap.Logger, options ...DBOption) (*DBStore, error)

+ func (d *DBStore) Count() (int, error)

+ func (d *DBStore) GetAll() ([]StoredMessage, error)

+ func (d *DBStore) GetStoredMessage(row *sql.Rows) (StoredMessage, error)

+ func (d *DBStore) MostRecentTimestamp() (int64, error)

+ func (d *DBStore) Put(env *protocol.Envelope) error

+ func (d *DBStore) Query(query *pb.HistoryQuery) (*pb.Index, []StoredMessage, error)

+ func (d *DBStore) Start(timesource timesource.Timesource) error

+ func (d *DBStore) Stop()

+ type Hash [HashLength]byte

+ type MessageProvider interface

+ GetAll func() ([]StoredMessage, error)

+ MostRecentTimestamp func() (int64, error)

+ Put func(env *protocol.Envelope) error

+ Query func(query *pb.HistoryQuery) ([]StoredMessage, error)

+ Start func(timesource timesource.Timesource) error

+ Stop func()

+ type StoredMessage struct

+ ID []byte

+ Message *pb.WakuMessage

+ PubsubTopic string

+ ReceiverTime int64