agent

Documentation

Index

• type Agent
  • func New(c Config) (a Agent, err error)
  • func (a Agent) Run() error
  • func (a Agent) Stop()
• type Config
• type NodeConfig
  • func Read(r io.Reader) (*NodeConfig, error)
  • func (nc NodeConfig) CacheConfig() cache.Config
  • func (nc NodeConfig) NATSServers() []string
  • func (nc *NodeConfig) SetCacheConfig(cc cache.Config)
  • func (nc *NodeConfig) SetNATSServers(uris []string)
  • func (nc *NodeConfig) SetVolumeConfig(vc vol.Config)
  • func (nc NodeConfig) VolumeConfig() vol.Config

Types

type Agent

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

Agent contains the state of the agent.

func New

func New(c Config) (a Agent, err error)

New returns a new Agent.

func (Agent) Run

func (a Agent) Run() error

Run is the main routine for the Agent.

func (Agent) Stop

func (a Agent) Stop()

Stop is used to gracefully stop the Agent.

type Config

type Config struct {
	NodeConfig *NodeConfig
}

Config describes agent configuration.

type NodeConfig

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

NodeConfig represents a configuration.

func Read

func Read(r io.Reader) (*NodeConfig, error)

Read reads a config from the specified reader.

func (NodeConfig) CacheConfig

func (nc NodeConfig) CacheConfig() cache.Config

func (NodeConfig) NATSServers

func (nc NodeConfig) NATSServers() []string

func (*NodeConfig) SetCacheConfig

func (nc *NodeConfig) SetCacheConfig(cc cache.Config)

func (*NodeConfig) SetNATSServers

func (nc *NodeConfig) SetNATSServers(uris []string)

func (*NodeConfig) SetVolumeConfig

func (nc *NodeConfig) SetVolumeConfig(vc vol.Config)

func (NodeConfig) VolumeConfig

func (nc NodeConfig) VolumeConfig() vol.Config