Versions in this module Expand all Collapse all v0 v0.1.1 Oct 23, 2013 v0.1.0 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