postgres

Documentation

Index

• Constants
• func Connect(ctx context.Context, conn string, maxTimeout time.Duration) (*pgxpool.Pool, error)
• func NewPostgresConfigurationStore(logger logger.Logger) configuration.Store
• type ConfigurationStore
  • func (p *ConfigurationStore) Get(ctx context.Context, req *configuration.GetRequest) (*configuration.GetResponse, error)
  • func (p *ConfigurationStore) Init(metadata configuration.Metadata) error
  • func (p *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, ...) (string, error)
  • func (p *ConfigurationStore) Unsubscribe(ctx context.Context, req *configuration.UnsubscribeRequest) error

Constants

const (
	ErrorMissingTableName        = "missing postgreSQL configuration table name"
	ErrorMissingTable            = "postgreSQL configuration table - '%s' does not exist"
	InfoStartInit                = "initializing postgreSQL configuration store"
	ErrorMissingConnectionString = "missing postgreSQL connection string"
	ErrorAlreadyInitialized      = "postgreSQL configuration store already initialized"
	ErrorMissingMaxTimeout       = "missing PostgreSQL maxTimeout setting in configuration"
	QueryTableExists             = "SELECT EXISTS (SELECT FROM pg_tables where tablename = $1)"
	ErrorTooLongFieldLength      = "field name is too long"
)

Functions

func Connect

func Connect(ctx context.Context, conn string, maxTimeout time.Duration) (*pgxpool.Pool, error)

func NewPostgresConfigurationStore

func NewPostgresConfigurationStore(logger logger.Logger) configuration.Store

Types

type ConfigurationStore

type ConfigurationStore struct {
	ActiveSubscriptions map[string]*subscription
	// contains filtered or unexported fields
}

func (*ConfigurationStore) Get

func (p *ConfigurationStore) Get(ctx context.Context, req *configuration.GetRequest) (*configuration.GetResponse, error)

func (*ConfigurationStore) Init

func (p *ConfigurationStore) Init(metadata configuration.Metadata) error

func (*ConfigurationStore) Subscribe

func (p *ConfigurationStore) Subscribe(ctx context.Context, req *configuration.SubscribeRequest, handler configuration.UpdateHandler) (string, error)

func (*ConfigurationStore) Unsubscribe

func (p *ConfigurationStore) Unsubscribe(ctx context.Context, req *configuration.UnsubscribeRequest) error