Versions in this module Expand all Collapse all v0 v0.1.0 Sep 27, 2022 Changes in this version + const DefaultPort + func New(opts Opts, queryTimeout time.Duration, logger *zap.Logger) (persistence.Persister, error) + func NewSQLClient(opts Opts, logger *zap.Logger) (*sql.DB, error) + type Opts struct + CABundleFSPath string + DBName string + EnableTLS bool + Hostname string + Password string + Port int + ReadOnlyHostname string + SQLOpen func(driver persistence.Driver, dataSourceName string) (*sql.DB, error) + User string + type Postgres struct + func (s *Postgres) Close() error + func (s *Postgres) Delete(ctx context.Context, key string) error + func (s *Postgres) Get(ctx context.Context, key string) ([]byte, error) + func (s *Postgres) List(ctx context.Context, prefix string, opts *persistence.ListOpts) (persistence.ListResult, error) + func (s *Postgres) Put(ctx context.Context, key string, value []byte) error + func (s *Postgres) Tx(ctx context.Context) (persistence.Tx, error)
Go to main page