postgres

Documentation

Index

• Constants
• func InitConfig(conf config.Section)
• func NewPostgresPersistence(bgCtx context.Context, conf config.Section, nonceStateTimeout time.Duration, ...) (persistence.Persistence, error)
• type CodeUsageOptions
• type Postgres
  • func (psql *Postgres) ApplyInsertQueryCustomizations(insert sq.InsertBuilder, requestConflictEmptyResult bool) (sq.InsertBuilder, bool)
  • func (psql *Postgres) Features() dbsql.SQLFeatures
  • func (psql *Postgres) GetMigrationDriver(db *sql.DB) (migratedb.Driver, error)
  • func (psql *Postgres) MigrationsDir() string
  • func (psql *Postgres) Name() string
  • func (psql *Postgres) Open(url string) (*sql.DB, error)
  • func (psql *Postgres) SequenceColumn() string

Constants

const (
	ConfigTXWriterCacheSlots                = "txwriter.cacheSlots"
	ConfigTXWriterHistorySummaryLimit       = "txwriter.historySummaryLimit"
	ConfigTXWriterHistoryCompactionInterval = "txwriter.historyCompactionInterval"
	ConfigTXWriterCount                     = "txwriter.count"
	ConfigTXWriterBatchTimeout              = "txwriter.batchTimeout"
	ConfigTXWriterBatchSize                 = "txwriter.batchSize"
)

Functions

func InitConfig

func InitConfig(conf config.Section)

InitConfig gets called after config reset to initialize the config structure

func NewPostgresPersistence

func NewPostgresPersistence(bgCtx context.Context, conf config.Section, nonceStateTimeout time.Duration, codeOptions ...CodeUsageOptions) (persistence.Persistence, error)

Types

type CodeUsageOptions

type CodeUsageOptions int

const ForMigration CodeUsageOptions = iota

type Postgres

type Postgres struct {
	dbsql.Database
}

Postgres provider implementation

func (*Postgres) ApplyInsertQueryCustomizations

func (psql *Postgres) ApplyInsertQueryCustomizations(insert sq.InsertBuilder, requestConflictEmptyResult bool) (sq.InsertBuilder, bool)

func (*Postgres) Features

func (psql *Postgres) Features() dbsql.SQLFeatures

func (*Postgres) GetMigrationDriver

func (psql *Postgres) GetMigrationDriver(db *sql.DB) (migratedb.Driver, error)

func (*Postgres) MigrationsDir

func (psql *Postgres) MigrationsDir() string

func (*Postgres) Name

func (psql *Postgres) Name() string

func (*Postgres) Open

func (psql *Postgres) Open(url string) (*sql.DB, error)

func (*Postgres) SequenceColumn

func (psql *Postgres) SequenceColumn() string