agent

Dec 20, 2017

Changes in this version

type Agent

+ func (a *Agent) GetConfig() *Config

+ func (a *Agent) Reload(newConfig *Config) error

Nov 1, 2017

Changes in this version

+ const ErrEntOnly

+ type ACLConfig struct

+ Enabled bool

+ PolicyTTL time.Duration

+ ReplicationToken string

+ TokenTTL time.Duration

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

type Agent

+ InmemSink *metrics.InmemSink

type Config

+ ACL *ACLConfig

+ Sentinel *config.SentinelConfig

type HTTPServer

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

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

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

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

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

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

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

type ServerConfig

+ AuthoritativeRegion string

type Telemetry

+ BackwardsCompatibleMetrics bool

+ DisableTaggedMetrics bool

+ PrometheusMetrics bool

type TestAgent

+ RootToken *structs.ACLToken

+ T testing.T

+ type UIAssetWrapper struct

+ FileSystem *assetfs.AssetFS

+ func (fs *UIAssetWrapper) Open(name string) (http.File, error)

Aug 28, 2017

Changes in this version

type HTTPServer

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

type ReadCloserWrapper

+ func (x *ReadCloserWrapper) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ReadCloserWrapper) CodecEncodeSelf(e *codec1978.Encoder)

type StreamFrame

+ func (x *StreamFrame) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *StreamFrame) CodecEncodeSelf(e *codec1978.Encoder)

type StreamFramer

+ func (x *StreamFramer) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *StreamFramer) CodecEncodeSelf(e *codec1978.Encoder)

Jul 26, 2017

Changes in this version

+ var TempDir = os.TempDir()

+ func FivePorts() int

type ClientConfig

+ GCMaxAllocs int

type Command

+ func (c *Command) AutocompleteArgs() complete.Predictor

+ func (c *Command) AutocompleteFlags() complete.Flags

type HTTPServer

+ Addr string

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

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

type ServerConfig

+ DeploymentGCThreshold string

+ MaxHeartbeatsPerSecond float64

+ MinHeartbeatTTL time.Duration

+ type TestAgent struct

+ Config *Config

+ ConfigCallback func(*Config)

+ DataDir string

+ Key string

+ LogOutput io.Writer

+ Name string

+ Server *HTTPServer

+ func NewTestAgent(name string, configCallback func(*Config)) *TestAgent

+ func (a *TestAgent) Client() *api.Client

+ func (a *TestAgent) HTTPAddr() string

+ func (a *TestAgent) Shutdown() error

+ func (a *TestAgent) Start() *TestAgent

Mar 14, 2017

Changes in this version

+ func ApiConstraintToStructs(c1 *api.Constraint, c2 *structs.Constraint)

+ func ApiJobToStructJob(job *api.Job) *structs.Job

+ func ApiTaskToStructsTask(apiTask *api.Task, structsTask *structs.Task)

+ func ApiTgToStructsTG(taskGroup *api.TaskGroup, tg *structs.TaskGroup)

type ClientConfig

+ CpuCompute int

+ GCParallelDestroys int

+ NoHostUUID bool

type HTTPServer

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

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

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

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

type ServerConfig

+ EvalGCThreshold string

+ JobGCThreshold string

Feb 1, 2017

Changes in this version

type ClientConfig

+ GCDiskUsageThreshold float64

+ GCInodeUsageThreshold float64

+ GCInterval time.Duration

Jan 30, 2017

Changes in this version

type Telemetry

+ UseNodeName bool

Dec 21, 2016

Changes in this version

type HTTPServer

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

Dec 12, 2016

Changes in this version

+ var HeartbeatStreamFrame = &StreamFrame

type StreamFrame

+ func (s *StreamFrame) Clear()

+ func (s *StreamFrame) IsCleared() bool

Nov 16, 2016

Changes in this version

type Config

+ TLSConfig *config.TLSConfig

+ Vault *config.VaultConfig

type HTTPServer

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

type ServerConfig

+ EncryptKey string

+ func (s *ServerConfig) EncryptBytes() ([]byte, error)

type Telemetry

+ CirconusCheckDisplayName string

+ CirconusCheckTags string

+ DataDogAddr string

Aug 17, 2016

Changes in this version

+ const OriginEnd

+ const OriginStart

type ClientConfig

+ ChrootEnv map[string]string

type HTTPServer

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

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

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

+ type ReadCloserWrapper struct

+ type StreamFrame struct

+ Data []byte

+ File string

+ FileEvent string

+ Offset int64

+ func (s *StreamFrame) IsHeartbeat() bool

+ type StreamFramer struct

+ Err error

+ func NewStreamFramer(out io.WriteCloser, heartbeatRate, batchWindow time.Duration, frameSize int) *StreamFramer

+ func (s *StreamFramer) Destroy()

+ func (s *StreamFramer) ExitCh() <-chan struct{}

+ func (s *StreamFramer) Run()

+ func (s *StreamFramer) Send(file, fileEvent string, data []byte, offset int64) error

type Telemetry

+ CirconusAPIApp string

+ CirconusAPIToken string

+ CirconusAPIURL string

+ CirconusBrokerID string

+ CirconusBrokerSelectTag string

+ CirconusCheckForceMetricActivation string

+ CirconusCheckID string

+ CirconusCheckInstanceID string

+ CirconusCheckSearchTag string

+ CirconusCheckSubmissionURL string

+ CirconusSubmissionInterval string

+ PublishAllocationMetrics bool

+ PublishNodeMetrics bool

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

Apr 22, 2016

Changes in this version

type HTTPServer

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

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

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)

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

Nov 28, 2015

Changes in this version

type HTTPServer

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

Nov 19, 2015

Changes in this version

type ServerConfig

+ NodeGCThreshold string

Oct 5, 2015

Changes in this version

type ClientConfig

+ NetworkInterface string

+ NetworkSpeed int

+ Options map[string]string

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