config

Documentation

Overview

Package config reads the configurations from a yaml file and produces necessary configuration for instantiating readers and recorders.

Index

• Constants
• Variables
• type ConfMap
  • func LoadYAML(log *internal.Logger, v *viper.Viper) (*ConfMap, error)
• type ErrNotSpecified
  • func NewErrNotSpecified(section, reason string, err error) *ErrNotSpecified
  • func (e *ErrNotSpecified) Error() string
• type ErrNotSupported
  • func (n ErrNotSupported) Error() string
• type ErrRouters
  • func NewErrRouters(section, reason string, err error) *ErrRouters
  • func (e *ErrRouters) Error() string
• type ReaderConf
• type RecorderConf
• type StructureErr
  • func (e *StructureErr) Error() string

Constants

const (
	// NilStr is the string used to print nil for an error
	NilStr = "<nil>"
)

Variables

var EmptyConfigErr = &StructureErr{"", "empty configuration file", nil}

EmptyConfigErr is an error when the config file is empty

Types

type ConfMap

type ConfMap struct {
	// Readers contains a map of reader names to their configuration.
	Readers map[string]ReaderConf

	// Recorders contains a map of recorder names to their configuration.
	Recorders map[string]RecorderConf

	// Routes contains a map of recorder names to a list of readers.
	// map["rec1"][]string{"red1", "red2"}: means whatever is read
	// from red1 and red2, will be shipped to rec1.
	Routes map[string][]string
}

ConfMap holds the relation between readers and recorders.

func LoadYAML

func LoadYAML(log *internal.Logger, v *viper.Viper) (*ConfMap, error)

LoadYAML loads the settings from the configuration file. It returns any errors returned from readers/recorders. Please refer to their documentations.

type ErrNotSpecified

type ErrNotSpecified StructureErr

ErrNotSpecified is returned when a section is not specified

func NewErrNotSpecified

func NewErrNotSpecified(section, reason string, err error) *ErrNotSpecified

NewErrNotSpecified instantiates an ErrNotSpecified with the given input

func (*ErrNotSpecified) Error

func (e *ErrNotSpecified) Error() string

type ErrNotSupported

type ErrNotSupported string

ErrNotSupported says something is still not supported

func (ErrNotSupported) Error

func (n ErrNotSupported) Error() string

type ErrRouters

type ErrRouters struct{ StructureErr }

ErrRouters represents an error when routes are not configured correctly. The section on this error is the subsection of the route.

func NewErrRouters

func NewErrRouters(section, reason string, err error) *ErrRouters

NewErrRouters instantiates an ErrRouters with the given input

func (*ErrRouters) Error

func (e *ErrRouters) Error() string

type ReaderConf

type ReaderConf interface {
	NewInstance() (reader.DataReader, error)
}

ReaderConf is for configure and returning a Reader instance.

type RecorderConf

type RecorderConf interface {
	NewInstance() (recorder.DataRecorder, error)
}

RecorderConf is for configure and returning a Recorder instance.

type StructureErr

type StructureErr struct {
	Section string // The section that error happened
	Reason  string // The reason behind the error
	Err     error  // Err is the error that occurred during the operation.
}

StructureErr is an error on reading the configuration file.

func (*StructureErr) Error

func (e *StructureErr) Error() string

Error returns "<nil>" if the error is nil.