postgresstore

package

v0.7.3 Latest Latest Go to latest Published: Jan 26, 2021 License: BSD-3-Clause Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/inklabs/rangedb

Links

Open Source Insights

Documentation ¶

Index ¶

func New(config *Config, options ...Option) (*postgresStore, error)
type Config
- func NewConfigFromEnvironment() (*Config, error)
- func (c Config) DataSourceName() string
type JsonSerializer
type Option
- func WithClock(clock clock.Clock) Option
- func WithPgNotify() Option
type PostgresJsonRecord

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(config *Config, options ...Option) (*postgresStore, error)

New constructs an postgresStore.

Types ¶

type Config ¶

type Config struct {
	Host     string
	Port     int
	User     string
	Password string
	DBName   string
}

Config holds the state for a PostgreSQL DB config.

func NewConfigFromEnvironment ¶ added in v0.6.0

func NewConfigFromEnvironment() (*Config, error)

NewConfigFromEnvironment loads a Postgres config from environment variables.

func (Config) DataSourceName ¶

func (c Config) DataSourceName() string

DataSourceName returns the DSN for a PostgreSQL DB.

type JsonSerializer ¶

type JsonSerializer interface {
	rangedb.EventBinder
	rangedb.EventTypeIdentifier
}

JsonSerializer defines the interface to bind events and identify event types.

type Option ¶

type Option func(*postgresStore)

Option defines functional option parameters for postgresStore.

func WithClock ¶

func WithClock(clock clock.Clock) Option

WithClock is a functional option to inject a clock.Clock.

func WithPgNotify ¶ added in v0.6.0

func WithPgNotify() Option

WithPgNotify enables pg_notify() for notifying subscribers.

type PostgresJsonRecord ¶ added in v0.6.0

type PostgresJsonRecord struct {
	AggregateType        string `json:"aggregatetype"`
	AggregateID          string `json:"aggregateid"`
	GlobalSequenceNumber uint64 `json:"globalsequencenumber"`
	StreamSequenceNumber uint64 `json:"streamsequencenumber"`
	InsertTimestamp      uint64 `json:"inserttimestamp"`
	EventID              string `json:"eventid"`
	EventType            string `json:"eventtype"`
	Data                 string `json:"data"`
	Metadata             string `json:"metadata"`
}

PostgresJsonRecord holds a JSON record sent via pg_notify.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL