config

Documentation

Index

• Constants
• type Config
  • func New(memberID, listenAddress, etcdPrefix, etcdUserPass string, ...) *Config
  • func (c *Config) Load() error
  • func (c *Config) ValidateDirs() []string
• type Health
  • func (h *Health) Read() (bool, string)
  • func (h *Health) Write(ok bool, message string)

Constants

const (
	DEFAULT_CONFIG = `{"HeartbeatInterval":"3s","HeartbeatTimeout":"6s","StateDumpInterval":"10s"}`
)

Types

type Config

type Config struct {
	MemberID      string
	ListenAddress string
	EtcdPrefix    string
	EtcdMembers   []string
	EtcdUserPass  string
	Tags          []string
	DalClient     dal.IDal
	EQClient      event.IClient
	Health        *Health

	Version string
	SemVer  string
	// contains filtered or unexported fields
}

func New

func New(memberID, listenAddress, etcdPrefix, etcdUserPass string, etcdMembers, tags []string,
	dalClient dal.IDal, eqClient *event.Client, version, semver string) *Config

Pass in the dal client in order to facilitate better/easier testing story

func (*Config) Load

func (c *Config) Load() error

func (*Config) ValidateDirs

func (c *Config) ValidateDirs() []string

type Health

type Health struct {
	Ok      bool
	Message string
	Lock    *sync.Mutex
}

func (*Health) Read

func (h *Health) Read() (bool, string)

func (*Health) Write

func (h *Health) Write(ok bool, message string)