config

Documentation

Index

• Variables
• type Instance
• type InstanceConfig
  • func NewInstanceConfig(fname string) (*InstanceConfig, error)
• type QuorumConfig
  • func NewQuorumConfig(fname string) (*QuorumConfig, error)

Variables

var (
	// ErrInvalidTimeout is returned when the timeout is not valid, e.g. zero or negative
	ErrInvalidTimeout = errors.New("invalid timeout")

	// ErrInvalidIncrement is returned when the increment is not valid, e.g. zero or negative
	ErrInvalidIncrement = errors.New("invalid increment")

	// ErrNoInstance is returned when an instance definition is expected but missing
	ErrNoInstance = errors.New("missing instance definition")

	// ErrInvalidInstanceDefinition is returned when an invalid instance definition is discovered, e.g. an empty name or
	// address
	ErrInvalidInstanceDefinition = errors.New("invalid instance definition")

	// ErrDuplicateInstance is returned when there are multiple definitions for the same instance
	ErrDuplicateInstance = errors.New("duplicate instance")
)

Types

type Instance

type Instance struct {
	Name    string `yaml:"name"`
	Address string `yaml:"address"`
}

Instance describes a single Skinny instance connection information

type InstanceConfig

type InstanceConfig struct {
	Name      string        `yaml:"name"`
	Increment uint64        `yaml:"increment"`
	Timeout   time.Duration `yaml:"timeout"`
	Listen    string        `yaml:"listen"`
	Peers     []Instance    `yaml:"peers"`
}

InstanceConfig describes a Skinny instance configuration

func NewInstanceConfig

func NewInstanceConfig(fname string) (*InstanceConfig, error)

NewInstanceConfig loads a Skinny instance configuration from given file

type QuorumConfig

type QuorumConfig struct {
	Timeout   time.Duration `yaml:"timeout"`
	Instances []Instance    `yaml:"instances"`
}

QuorumConfig describes a Skinny quorum configuration file

func NewQuorumConfig

func NewQuorumConfig(fname string) (*QuorumConfig, error)

NewQuorumConfig loads a Skinny quorum configuration from given file