store

Nov 29, 2022

Changes in this version

+ type BatchConfig struct

+ QueryTTL time.Duration

+ type BatchOption func(conf *BatchConfig)

Sep 28, 2022

Changes in this version

type Store

+ func (s Store) Batch(ctx context.Context, batch provider.Batch, opts ...QueryOption) error

type Txn

+ func (tx Txn) Batch(batch provider.Batch, opts ...QueryOption) error

Jul 17, 2022

Changes in this version

+ type Config struct

+ DSN string

+ Migration fs.ReadDirFS

+ PgOptions []pg.Option

+ type Option func(conf *Config)

+ func WithDSN(dsn string) Option

+ func WithMigration(fs fs.ReadDirFS) Option

+ func WithPg(opts ...pg.Option) Option

+ type QueryConfig struct

+ QueryTTL time.Duration

+ type QueryOption func(conf *QueryConfig)

+ func QueryTTL(duration time.Duration) QueryOption

+ type Store struct

+ func New(opts ...Option) (*Store, error)

+ func NewStore(db provider.Provider) *Store

+ func (s Store) Add(ctx context.Context, collection string, v interface{}) error

+ func (s Store) All(ctx context.Context, spec provider.Spec, v interface{}, opts ...QueryOption) error

+ func (s Store) BatchQuery(ctx context.Context, query provider.BatchQuery, opts ...QueryOption) error

+ func (s Store) Begin(ctx context.Context, opts ...provider.TxOption) (Txn, error)

+ func (s Store) Do(ctx context.Context, fn func(tx Txn) error, opts ...provider.TxOption) error

+ func (s Store) Edit(ctx context.Context, collection string, spec provider.Spec, v interface{}) error

+ func (s Store) One(ctx context.Context, spec provider.Spec, v interface{}, opts ...QueryOption) error

+ func (s Store) Remove(ctx context.Context, collection string, spec provider.Spec) error

+ type Txn struct

+ func (tx Txn) Add(collection string, v interface{}) error

+ func (tx Txn) All(spec provider.Spec, v interface{}, opts ...QueryOption) error

+ func (tx Txn) BatchQuery(query provider.BatchQuery, opts ...QueryOption) error

+ func (tx Txn) Context() context.Context

+ func (tx Txn) Edit(collection string, spec provider.Spec, v interface{}) error

+ func (tx Txn) One(spec provider.Spec, v interface{}, opts ...QueryOption) error

+ func (tx Txn) Remove(collection string, spec provider.Spec) error