agent

package

Go to main page

Versions in this module

v0

v0.3.0

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

v0.2.1

Nov 7, 2013

Changes in this version

type Command

+ Ui cli.Ui

v0.2.0

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL