config

Documentation

Index

• Variables
• type Config
  • func NewConfig() Config
• type ConfigUpdate
• type Override
  • func (o Override) MarshalBinary() ([]byte, error)
  • func (o Override) ObjectID() string
  • func (o *Override) UnmarshalBinary(data []byte) error
• type OverrideDAO
• type Service
  • func NewService(c Config, config interface{}, l *log.Logger, updates chan<- ConfigUpdate) *Service
  • func (s *Service) Close() error
  • func (s *Service) Config() (map[string][]interface{}, error)
  • func (s *Service) Open() error

Variables

var (
	ErrNoOverrideExists = errors.New("no override exists")
)

Types

type Config

type Config struct {
	Enabled bool `toml:"enabled"`
}

func NewConfig

func NewConfig() Config

type ConfigUpdate

type ConfigUpdate struct {
	Name      string
	NewConfig []interface{}
	ErrC      chan<- error
}

type Override

type Override struct {
	// Unique identifier for the override
	ID string `json:"id"`

	// Map of key value pairs of option overrides.
	Options map[string]interface{} `json:"options"`

	Create bool `json:"create"`
}

func (Override) MarshalBinary

func (o Override) MarshalBinary() ([]byte, error)

func (Override) ObjectID

func (o Override) ObjectID() string

func (*Override) UnmarshalBinary

func (o *Override) UnmarshalBinary(data []byte) error

type OverrideDAO

type OverrideDAO interface {
	// Retrieve a override
	Get(id string) (Override, error)

	// Set an override.
	// If it does not already exist it will be created,
	// otherwise it will be replaced.
	Set(o Override) error

	// Delete a override.
	// It is not an error to delete an non-existent override.
	Delete(id string) error

	// List all overrides whose ID starts with the given prefix
	List(prefix string) ([]Override, error)

	Rebuild() error
}

Data access object for Override data.

type Service

type Service struct {
	StorageService interface {
		Store(namespace string) storage.Interface
		Register(name string, store storage.StoreActioner)
	}
	HTTPDService interface {
		AddRoutes([]httpd.Route) error
		DelRoutes([]httpd.Route)
	}
	// contains filtered or unexported fields
}

func NewService

func NewService(c Config, config interface{}, l *log.Logger, updates chan<- ConfigUpdate) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) Config

func (s *Service) Config() (map[string][]interface{}, error)

func (*Service) Open

func (s *Service) Open() error