graph

Documentation

Index

• Variables
• func Test(backend, query, content bool) *mock.Mock
• type DB
  • func New(ctx context.Context, choice Subsets) (*DB, error)
  • func NewCodeListStore(ctx context.Context) (*DB, error)
  • func NewDimensionStore(ctx context.Context) (*DB, error)
  • func NewHierarchyStore(ctx context.Context) (*DB, error)
  • func NewInstanceStore(ctx context.Context) (*DB, error)
  • func NewObservationStore(ctx context.Context) (*DB, error)
  • func (db DB) ErrorChan() chan error
• type ErrorConsumer
  • func NewErrorConsumer(errors chan error, consume func(error)) *ErrorConsumer
  • func NewLoggingErrorConsumer(ctx context.Context, errors chan error) *ErrorConsumer
  • func (c *ErrorConsumer) Close(ctx context.Context) error
• type Subsets

Variables

var ErrContextDone = errors.New("context done while closing error consumer")

Functions

func Test

func Test(backend, query, content bool) *mock.Mock

Test sets flags for managing responses from the Mock driver

Types

type DB

type DB struct {
	driver.Driver

	driver.CodeList
	driver.Hierarchy
	driver.Instance
	driver.Observation
	driver.Dimension

	Errors chan error
}

DB contains the widest possible selection of functionality provided by any implementation of this abstraction

func New

func New(ctx context.Context, choice Subsets) (*DB, error)

New DB returned according to provided subsets and the environment config satisfying the interfaces requested by the choice of subsets

func NewCodeListStore

func NewCodeListStore(ctx context.Context) (*DB, error)

NewCodeListStore returns a configured DB containing the CodeList functionality

func NewDimensionStore

func NewDimensionStore(ctx context.Context) (*DB, error)

NewDimensionStore returns a configured DB containing the Dimension functionality

func NewHierarchyStore

func NewHierarchyStore(ctx context.Context) (*DB, error)

NewHierarchyStore returns a configured DB containing the Hierarchy functionality

func NewInstanceStore

func NewInstanceStore(ctx context.Context) (*DB, error)

NewInstanceStore returns a configured DB containing the Instance functionality

func NewObservationStore

func NewObservationStore(ctx context.Context) (*DB, error)

NewObservationStore returns a configured DB containing the Observation functionality

func (DB) ErrorChan

func (db DB) ErrorChan() chan error

ErrorChan returns the error channel associated with this DB

type ErrorConsumer

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

ErrorConsumer maintains a go routine to consume an error channel

func NewErrorConsumer

func NewErrorConsumer(errors chan error, consume func(error)) *ErrorConsumer

NewErrorConsumer starts a new go routine to consume errors

func NewLoggingErrorConsumer

func NewLoggingErrorConsumer(ctx context.Context, errors chan error) *ErrorConsumer

func (*ErrorConsumer) Close

func (c *ErrorConsumer) Close(ctx context.Context) error

Close blocks until the go routine has finished

type Subsets

type Subsets struct {
	CodeList    bool
	Hierarchy   bool
	Instance    bool
	Observation bool
	Dimension   bool
}

Subsets allows a clear and concise way of requesting any combination of functionality by groups of node types