Versions in this module Expand all Collapse all v0 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
Go to main page