Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

agent

package

Go to main page

Versions in this module

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