datastore

Documentation

Overview

Code generated from meta collections. DO NOT EDIT.

Index

• func WaitPostgresAvailable(lookup environment.Environmenter) error
• type FlowPostgres
  • func NewFlowPostgres(lookup environment.Environmenter) (*FlowPostgres, error)
  • func (p *FlowPostgres) Close()
  • func (p *FlowPostgres) Get(ctx context.Context, keys ...dskey.Key) (map[dskey.Key][]byte, error)
  • func (p *FlowPostgres) Update(ctx context.Context, updateFn func(map[dskey.Key][]byte, error))
• type FlowVoteCount
  • func NewFlowVoteCount(lookup environment.Environmenter) *FlowVoteCount
  • func (s *FlowVoteCount) Connect(ctx context.Context, eventProvider func() (<-chan time.Time, func() bool), ...)
  • func (s *FlowVoteCount) Get(ctx context.Context, keys ...dskey.Key) (map[dskey.Key][]byte, error)
  • func (s *FlowVoteCount) Update(ctx context.Context, updateFn func(map[dskey.Key][]byte, error))
• type InvalidDataError
  • func (err InvalidDataError) Error() string

Functions

func WaitPostgresAvailable

func WaitPostgresAvailable(lookup environment.Environmenter) error

WaitPostgresAvailable blocks until postgres db is availabe

Types

type FlowPostgres

type FlowPostgres struct {
	Pool *pgxpool.Pool
}

FlowPostgres uses postgres to get the connections.

func NewFlowPostgres

func NewFlowPostgres(lookup environment.Environmenter) (*FlowPostgres, error)

NewFlowPostgres initializes a SourcePostgres.

func (*FlowPostgres) Close

func (p *FlowPostgres) Close()

Close closes the connection pool.

func (*FlowPostgres) Get

func (p *FlowPostgres) Get(ctx context.Context, keys ...dskey.Key) (map[dskey.Key][]byte, error)

Get fetches the keys from postgres.

func (*FlowPostgres) Update

func (p *FlowPostgres) Update(ctx context.Context, updateFn func(map[dskey.Key][]byte, error))

Update listens on pg notify to fetch updates.

type FlowVoteCount

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

FlowVoteCount is a datastore flow for the poll/vote_count value.

func NewFlowVoteCount

func NewFlowVoteCount(lookup environment.Environmenter) *FlowVoteCount

NewFlowVoteCount initializes the object.

func (*FlowVoteCount) Connect

func (s *FlowVoteCount) Connect(ctx context.Context, eventProvider func() (<-chan time.Time, func() bool), errHandler func(error))

Connect creates a connection to the vote service and makes sure, it stays open.

eventProvider is a function that returns a channel. If the connection fails, this function fetches such a channel and waits for a signal before it tries to open a new connection.

func (*FlowVoteCount) Get

func (s *FlowVoteCount) Get(ctx context.Context, keys ...dskey.Key) (map[dskey.Key][]byte, error)

Get is called when a key is not in the cache.

func (*FlowVoteCount) Update

func (s *FlowVoteCount) Update(ctx context.Context, updateFn func(map[dskey.Key][]byte, error))

Update has to be called frequently. It blocks, until there is new data.

type InvalidDataError

type InvalidDataError struct {
	Key   dskey.Key
	Value []byte
}

InvalidDataError is returned, when a key has an invalid value in the database.

func (InvalidDataError) Error

func (err InvalidDataError) Error() string