agent

Jun 16, 2014

Changes in this version

type Config

+ SyslogFacility string

May 8, 2014

Changes in this version

+ func MarshalTags(tags map[string]string) []string

+ func UnmarshalTags(tags []string) (map[string]string, error)

type Agent

+ func (a *Agent) InstallKey(key string) (*serf.KeyResponse, error)

+ func (a *Agent) ListKeys() (*serf.KeyResponse, error)

+ func (a *Agent) RemoveKey(key string) (*serf.KeyResponse, error)

+ func (a *Agent) SetTags(tags map[string]string) error

+ func (a *Agent) Stats() map[string]map[string]string

+ func (a *Agent) UseKey(key string) (*serf.KeyResponse, error)

type Config

+ EnableSyslog bool

+ KeyringFile string

+ RejoinAfterLeave bool

+ RetryInterval time.Duration

+ RetryIntervalRaw string

+ RetryJoin []string

+ RetryMaxAttempts int

+ TagsFile string

+ type SyslogWrapper struct

+ func (s *SyslogWrapper) Write(p []byte) (int, error)

Mar 12, 2014

Changes in this version

type Agent

+ func (a *Agent) Query(name string, payload []byte, params *serf.QueryParam) (*serf.QueryResponse, error)

type Config

+ DisableNameResolution bool

+ RPCAuthKey string

+ ReconnectInterval time.Duration

+ ReconnectIntervalRaw string

+ ReconnectTimeout time.Duration

+ ReconnectTimeoutRaw string

+ TombstoneTimeout time.Duration

+ TombstoneTimeoutRaw string

type EventFilter

+ Name string

type IPCClient

+ func (c *IPCClient) RegisterQuery(q *serf.Query) uint64

+ type MockQueryHandler struct

+ Queries []*serf.Query

+ Response []byte

+ func (h *MockQueryHandler) HandleEvent(e serf.Event)

type ScriptEventHandler

+ SelfFunc func() serf.Member

Feb 25, 2014

Changes in this version

type Config

+ Interface string

+ func (c *Config) NetworkInterface() (*net.Interface, error)

Jan 31, 2014

Changes in this version

+ type AgentMDNS struct

+ func NewAgentMDNS(agent *Agent, logOutput io.Writer, replay bool, node, discover string, ...) (*AgentMDNS, error)

type Config

+ AdvertiseAddr string

+ Discover string

+ SkipLeaveOnInt bool

+ Tags map[string]string

+ func (c *Config) AddrParts(address string) (string, int, error)

type Member

+ Tags map[string]string

Dec 5, 2013

Changes in this version

+ const MaxIPCVersion

+ const MinIPCVersion

+ func NewLogWriter(buf int) *logWriter

type Agent

+ func Create(conf *serf.Config, logOutput io.Writer) (*Agent, error)

+ func (a *Agent) DeregisterEventHandler(eh EventHandler)

+ func (a *Agent) ForceLeave(node string) error

+ func (a *Agent) Leave() error

+ func (a *Agent) RegisterEventHandler(eh EventHandler)

+ func (a *Agent) ShutdownCh() <-chan struct{}

+ type AgentIPC struct

+ func NewAgentIPC(agent *Agent, listener net.Listener, logOutput io.Writer, logWriter *logWriter) *AgentIPC

+ func (i *AgentIPC) Shutdown()

type Config

+ LeaveOnInt bool

+ LeaveOnTerm bool

+ Profile string

+ ReplayOnJoin bool

+ SnapshotPath string

+ type EventFilter struct

+ Event string

+ UserEvent string

+ func ParseEventFilter(v string) []EventFilter

+ func (s *EventFilter) Invoke(e serf.Event) bool

+ func (s *EventFilter) Valid() bool

+ type IPCClient struct

+ func (c *IPCClient) Send(header *responseHeader, obj interface{}) error

+ func (c *IPCClient) String() string

+ type LogHandler interface

+ HandleLog func(string)

+ type Member struct

+ Addr net.IP

+ DelegateCur uint8

+ DelegateMax uint8

+ DelegateMin uint8

+ Name string

+ Port uint16

+ ProtocolCur uint8

+ ProtocolMax uint8

+ ProtocolMin uint8

+ Role string

+ Status string

type RPCClient

+ func NewRPCClient(addr string) (*RPCClient, error)

+ func (c *RPCClient) Leave() error

+ func (c *RPCClient) Stop(handle StreamHandle) error

+ func (c *RPCClient) Stream(filter string, ch chan<- map[string]interface{}) (StreamHandle, error)

type ScriptEventHandler

+ Logger *log.Logger

+ func (h *ScriptEventHandler) UpdateScripts(scripts []EventScript)

+ type StreamHandle uint64

Nov 7, 2013

Changes in this version

type Command

+ Ui cli.Ui

Nov 1, 2013

Changes in this version

+ var DefaultConfig = &Config

type Config

+ EncryptKey string

+ LogLevel string

+ Protocol int

+ StartJoin []string

+ func DecodeConfig(r io.Reader) (*Config, error)

+ func MergeConfig(a, b *Config) *Config

+ func ReadConfigPaths(paths []string) (*Config, error)

+ func (c *Config) EncryptBytes() ([]byte, error)

type RPCClient

+ func (c *RPCClient) ForceLeave(node string) error

+ type RPCJoinArgs struct

+ Addrs []string

+ IgnoreOld bool

type RPCUserEventArgs

+ Coalesce bool

Oct 23, 2013

Changes in this version

+ const DefaultBindPort

+ func LevelFilter() *logutils.LevelFilter

+ func ValidateLevelFilter(filter *logutils.LevelFilter) bool

+ type Agent struct

+ EventHandler EventHandler

+ LogOutput io.Writer

+ RPCAddr string

+ SerfConfig *serf.Config

+ func (a *Agent) Join(addrs []string) (n int, err error)

+ func (a *Agent) NotifyLogs(ch chan<- string) []string

+ func (a *Agent) Serf() *serf.Serf

+ func (a *Agent) Shutdown() error

+ func (a *Agent) Start() error

+ func (a *Agent) StopLogs(ch chan<- string)

+ func (a *Agent) UserEvent(name string, payload []byte) error

+ type AgentState int

+ const AgentIdle

+ const AgentRunning

+ type AppendSliceValue []string

+ func (s *AppendSliceValue) Set(value string) error

+ func (s *AppendSliceValue) String() string

+ type Command struct

+ ShutdownCh <-chan struct{}

+ func (c *Command) Help() string

+ func (c *Command) Run(args []string, rawUi cli.Ui) int

+ func (c *Command) Synopsis() string

+ type Config struct

+ BindAddr string

+ EventHandlers []string

+ NodeName string

+ RPCAddr string

+ Role string

+ func (c *Config) BindAddrParts() (string, int, error)

+ func (c *Config) EventScripts() ([]EventScript, error)

+ type EventHandler interface

+ HandleEvent func(*log.Logger, serf.Event) error

+ type EventScript struct

+ Event string

+ Script string

+ UserEvent string

+ func ParseEventScript(v string) ([]EventScript, error)

+ func (s *EventScript) Invoke(e serf.Event) bool

+ func (s *EventScript) String() string

+ func (s *EventScript) Valid() bool

+ type EventWriter struct

+ Agent *Agent

+ func (w *EventWriter) Write(p []byte) (n int, err error)

+ type GatedWriter struct

+ Writer io.Writer

+ func (w *GatedWriter) Flush()

+ func (w *GatedWriter) Write(p []byte) (n int, err error)

+ type MockEventHandler struct

+ Events []serf.Event

+ func (h *MockEventHandler) HandleEvent(l *log.Logger, e serf.Event) error

+ type RPCClient struct

+ Client *rpc.Client

+ func (c *RPCClient) Close() error

+ func (c *RPCClient) Join(addrs []string) (n int, err error)

+ func (c *RPCClient) Members() ([]serf.Member, error)

+ func (c *RPCClient) Monitor(level logutils.LogLevel, ch chan<- string, done <-chan struct{}) error

+ func (c *RPCClient) UserEvent(name string, payload []byte) error

+ type RPCMonitorArgs struct

+ CallbackAddr string

+ LogLevel string

+ type RPCUserEventArgs struct

+ Name string

+ Payload []byte

+ type ScriptEventHandler struct

+ Scripts []EventScript

+ Self serf.Member

+ func (h *ScriptEventHandler) HandleEvent(logger *log.Logger, e serf.Event) error