agent

package

Go to main page

Versions in this module

v0

v0.4.0

Jun 28, 2016

Changes in this version

type Config

+ Consul *config.ConsulConfig

type HTTPServer

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

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

type Telemetry

+ CollectionInterval string

v0.4.0-rc2

Jun 22, 2016

v0.4.0-rc1

Jun 14, 2016

v0.3.2

Apr 22, 2016

Changes in this version

type HTTPServer

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

v0.3.2-rc2

Apr 20, 2016

v0.3.2-rc1

Apr 14, 2016

v0.3.1

Mar 16, 2016

Changes in this version

type ClientConfig

+ Reserved *Resources

type Config

+ func ParseConfig(r io.Reader) (*Config, error)

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

type HTTPServer

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

+ type Resources struct

+ CPU int

+ DiskMB int

+ IOPS int

+ MemoryMB int

+ ParsedReservedPorts []int

+ ReservedPorts string

+ func (r *Resources) Merge(b *Resources) *Resources

+ func (r *Resources) ParseReserved() error

type ServerConfig

+ HeartbeatGrace string

v0.3.0

Feb 25, 2016

Changes in this version

type AdvertiseAddrs

+ HTTP string

type ClientConfig

+ ClientMaxPort uint

+ ClientMinPort uint

+ MaxKillTimeout string

type Config

+ HTTPAPIResponseHeaders map[string]string

type HTTPServer

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

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

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

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

v0.3.0-rc2

Feb 23, 2016

v0.2.3

Dec 18, 2015

v0.2.3-rc1

Dec 16, 2015

v0.2.2

Dec 11, 2015

Changes in this version

type AtlasConfig

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

type Config

+ Files []string

type ServerConfig

+ RejoinAfterLeave bool

+ RetryInterval string

+ RetryJoin []string

+ RetryMaxAttempts int

+ StartJoin []string

v0.2.1

Nov 28, 2015

Changes in this version

type HTTPServer

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

v0.2.0

Nov 19, 2015

Changes in this version

type ServerConfig

+ NodeGCThreshold string

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

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