Versions in this module Expand all Collapse all v1 v1.0.0 Aug 6, 2026 Changes in this version + type DocIndexConfigRow struct + Collection string + CreatedAt time.Time + DB int + Field string + Kind string + func (DocIndexConfigRow) TableName() string + type DocIndexRow struct + Collection string + CreatedAt time.Time + DB int + DisplayText string + Field string + ID string + ValueHash string + func (DocIndexRow) TableName() string + type DocRow struct + Collection string + CreatedAt time.Time + DB int + ExpiresAt *time.Time + ID string + SearchText string + UpdatedAt time.Time + Value []byte + Version int64 + func (DocRow) TableName() string + type KeyRow struct + CreatedAt time.Time + DB int + ExpiresAt *time.Time + Key string + StringValue []byte + Type string + UpdatedAt time.Time + Version int64 + func (KeyRow) TableName() string + type Store struct + func New(conn *database.Connection, log *zap.Logger) (*Store, error) + func (s *Store) CleanupExpired(ctx context.Context, limit int) (int64, error) + func (s *Store) Close() error + func (s *Store) ConfigureIndexes(ctx context.Context, db int, collection string, cfg docstore.IndexConfig) (docstore.IndexConfig, error) + func (s *Store) Delete(ctx context.Context, db int, keys ...string) (int64, error) + func (s *Store) DeleteDoc(ctx context.Context, db int, collection, id string) (bool, error) + func (s *Store) Exists(ctx context.Context, db int, keys ...string) (int64, error) + func (s *Store) Expire(ctx context.Context, db int, key string, ttl time.Duration) (bool, error) + func (s *Store) Get(ctx context.Context, db int, key string) (*store.Value, error) + func (s *Store) GetDel(ctx context.Context, db int, key string) (*store.Value, bool, error) + func (s *Store) GetDoc(ctx context.Context, db int, collection, id string) (docstore.Document, error) + func (s *Store) GetIndexConfig(ctx context.Context, db int, collection string) (docstore.IndexConfig, error) + func (s *Store) IncrBy(ctx context.Context, db int, key string, delta int64) (int64, error) + func (s *Store) MGet(ctx context.Context, db int, keys ...string) ([]*store.Value, error) + func (s *Store) MSet(ctx context.Context, db int, pairs []store.KeyValue, opts store.SetOptions) error + func (s *Store) Migrate(ctx context.Context) error + func (s *Store) MigrateDocs(ctx context.Context) error + func (s *Store) Persist(ctx context.Context, db int, key string) (bool, error) + func (s *Store) Ping(ctx context.Context) error + func (s *Store) PutDoc(ctx context.Context, db int, collection, id string, value []byte, ...) (docstore.Document, bool, error) + func (s *Store) QueryDocs(ctx context.Context, db int, collection string, opts docstore.QueryOptions) (docstore.QueryResult, error) + func (s *Store) Scan(ctx context.Context, db int, cursor string, pattern string, count int) (store.ScanResult, error) + func (s *Store) Set(ctx context.Context, db int, key string, value []byte, opts store.SetOptions) (*store.Value, bool, error) + func (s *Store) Stats(ctx context.Context, db int) (store.Stats, error) + func (s *Store) TTL(ctx context.Context, db int, key string) (time.Duration, bool, bool, error) + func (s *Store) Type(ctx context.Context, db int, key string) (string, error) + func (s *Store) ZAdd(ctx context.Context, db int, key string, score float64, member []byte) (int64, error) + func (s *Store) ZCard(ctx context.Context, db int, key string) (int64, error) + func (s *Store) ZCount(ctx context.Context, db int, key string, min, max store.ScoreBound) (int64, error) + func (s *Store) ZRange(ctx context.Context, db int, key string, start, stop int64) ([]store.ZMember, error) + func (s *Store) ZRangeByScore(ctx context.Context, db int, key string, min, max store.ScoreBound, ...) ([]store.ZMember, error) + func (s *Store) ZRem(ctx context.Context, db int, key string, members ...[]byte) (int64, error) + func (s *Store) ZRemRangeByScore(ctx context.Context, db int, key string, min, max store.ScoreBound) (int64, error) + func (s *Store) ZScore(ctx context.Context, db int, key string, member []byte) (float64, bool, error) + type ZSetMemberRow struct + CreatedAt time.Time + DB int + Key string + Member []byte + MemberHash string + Score float64 + UpdatedAt time.Time + func (ZSetMemberRow) TableName() string
Go to main page