postgres

Documentation

Index

• Constants
• 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
• type Postgres
  • 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)

Constants

const (
	DefaultPort = 5432
)

Functions

func New

func New(opts Opts, queryTimeout time.Duration, logger *zap.Logger) (persistence.Persister, error)

func NewSQLClient

func NewSQLClient(opts Opts, logger *zap.Logger) (*sql.DB, error)

Types

type Opts

type Opts struct {
	DBName           string
	Hostname         string
	ReadOnlyHostname string
	Port             int
	User             string
	Password         string
	EnableTLS        bool
	CABundleFSPath   string
	SQLOpen          func(driver persistence.Driver, dataSourceName string) (*sql.DB, error)
}

type Postgres

type Postgres struct {
	// contains filtered or unexported fields
}

func (*Postgres) Close

func (s *Postgres) Close() error

func (*Postgres) Delete

func (s *Postgres) Delete(ctx context.Context, key string) error

func (*Postgres) Get

func (s *Postgres) Get(ctx context.Context, key string) ([]byte, error)

func (*Postgres) List

func (s *Postgres) List(ctx context.Context, prefix string, opts *persistence.ListOpts) (persistence.ListResult,
	error,
)

func (*Postgres) Put

func (s *Postgres) Put(ctx context.Context, key string, value []byte) error

func (*Postgres) Tx

func (s *Postgres) Tx(ctx context.Context) (persistence.Tx, error)