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.2

Oct 6, 2015

v0.1.1

Oct 5, 2015

Changes in this version

type ClientConfig

+ NetworkInterface string

+ NetworkSpeed int

+ Options map[string]string

v0.1.0

Sep 28, 2015

Changes in this version

+ const ErrInvalidMethod

+ func LevelFilter() *logutils.LevelFilter

+ func NewLogWriter(buf int) *logWriter

+ func NewProvider(c *Config, logOutput io.Writer) (*client.Provider, net.Listener, error)

+ func ProviderConfig(c *Config) *client.ProviderConfig

+ func ProviderService(c *Config) *client.ProviderService

+ func ValidateLevelFilter(minLevel logutils.LogLevel, filter *logutils.LevelFilter) bool

+ type Addresses struct

+ HTTP string

+ RPC string

+ Serf string

+ func (a *Addresses) Merge(b *Addresses) *Addresses

+ type AdvertiseAddrs struct

+ RPC string

+ Serf string

+ func (a *AdvertiseAddrs) Merge(b *AdvertiseAddrs) *AdvertiseAddrs

+ type Agent struct

+ func NewAgent(config *Config, logOutput io.Writer) (*Agent, error)

+ func (a *Agent) Client() *client.Client

+ func (a *Agent) Leave() error

+ func (a *Agent) RPC(method string, args interface{}, reply interface{}) error

+ func (a *Agent) Server() *nomad.Server

+ func (a *Agent) Shutdown() error

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

+ type AtlasConfig struct

+ Endpoint string

+ Infrastructure string

+ Join bool

+ Token string

+ type ClientConfig struct

+ AllocDir string

+ Enabled bool

+ Meta map[string]string

+ NodeClass string

+ NodeID string

+ Servers []string

+ StateDir string

+ func (a *ClientConfig) Merge(b *ClientConfig) *ClientConfig

+ type Command struct

+ Revision string

+ ShutdownCh <-chan struct{}

+ Ui cli.Ui

+ Version string

+ VersionPrerelease string

+ func (c *Command) Help() string

+ func (c *Command) Run(args []string) int

+ func (c *Command) Synopsis() string

+ type Config struct

+ Addresses *Addresses

+ AdvertiseAddrs *AdvertiseAddrs

+ Atlas *AtlasConfig

+ BindAddr string

+ Client *ClientConfig

+ ClientConfig *client.Config

+ DataDir string

+ Datacenter string

+ DevMode bool

+ DisableAnonymousSignature bool

+ DisableUpdateCheck bool

+ EnableDebug bool

+ EnableSyslog bool

+ LeaveOnInt bool

+ LeaveOnTerm bool

+ LogLevel string

+ NodeName string

+ NomadConfig *nomad.Config

+ Ports *Ports

+ Region string

+ Revision string

+ Server *ServerConfig

+ SyslogFacility string

+ Telemetry *Telemetry

+ Version string

+ VersionPrerelease string

+ func DefaultConfig() *Config

+ func DevConfig() *Config

+ func LoadConfig(path string) (*Config, error)

+ func LoadConfigDir(dir string) (*Config, error)

+ func LoadConfigFile(path string) (*Config, error)

+ func LoadConfigString(s string) (*Config, error)

+ func (a *Config) Merge(b *Config) *Config

+ func (c *Config) Listener(proto, addr string, port int) (net.Listener, error)

+ type HTTPCodedError interface

+ Code func() int

+ func CodedError(c int, s string) HTTPCodedError

+ type HTTPServer struct

+ func NewHTTPServer(agent *Agent, config *Config, logOutput io.Writer) (*HTTPServer, error)

+ func (s *HTTPServer) AgentForceLeaveRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) AgentJoinRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) AgentMembersRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) AgentSelfRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) AgentServersRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) AllocSpecificRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) AllocsRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) EvalSpecificRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) EvalsRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) JobSpecificRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) JobsRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) NodeSpecificRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) NodesRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) Shutdown()

+ func (s *HTTPServer) StatusLeaderRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) StatusPeersRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ 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

+ Status string

+ Tags map[string]string

+ type Ports struct

+ HTTP int

+ RPC int

+ Serf int

+ func (a *Ports) Merge(b *Ports) *Ports

+ type ServerConfig struct

+ BootstrapExpect int

+ DataDir string

+ Enabled bool

+ EnabledSchedulers []string

+ NumSchedulers int

+ ProtocolVersion int

+ func (a *ServerConfig) Merge(b *ServerConfig) *ServerConfig

+ type SyslogWrapper struct

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

+ type Telemetry struct

+ DisableHostname bool

+ StatsdAddr string

+ StatsiteAddr string

+ func (a *Telemetry) Merge(b *Telemetry) *Telemetry