agent

package

Go to main page

Versions in this module

v0

v0.10.9

Nov 19, 2020

Changes in this version

+ func ApiConsulConnectToStructs(in *api.ConsulConnect) *structs.ConsulConnect

+ func ApiNetworkResourceToStructs(in []*api.NetworkResource) []*structs.NetworkResource

+ func ApiServicesToStructs(in []*api.Service) []*structs.Service

type ClientConfig

+ BridgeNetworkName string

+ BridgeNetworkSubnet string

+ CNIPath string

+ HostVolumes []*structs.ClientHostVolumeConfig

+ TemplateConfig *ClientTemplateConfig

+ type ClientTemplateConfig struct

+ DisableSandbox bool

+ FunctionBlacklist []string

type Config

+ Limits config.Limits

+ LogFile string

+ LogRotateBytes int

+ LogRotateDuration string

+ LogRotateMaxFiles int

type HTTPServer

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

+ func (s *HTTPServer) AgentPprofRequest(resp http.ResponseWriter, req *http.Request) ([]byte, error)

type ServerConfig

+ DefaultSchedulerConfig *structs.SchedulerConfiguration

+ JobGCInterval string

v0.10.2-rc1

Nov 22, 2019

v0.9.3

Jun 12, 2019

Changes in this version

+ func ApiAffinitiesToStructs(in []*api.Affinity) []*structs.Affinity

+ func ApiAffinityToStructs(a1 *api.Affinity) *structs.Affinity

+ func ApiConstraintsToStructs(in []*api.Constraint) []*structs.Constraint

+ func ApiResourcesToStructs(in *api.Resources) *structs.Resources

+ func ApiSpreadToStructs(a1 *api.Spread) *structs.Spread

type ACLConfig

+ ExtraKeysHCL []string

+ PolicyTTLHCL string

+ TokenTTLHCL string

type Addresses

+ ExtraKeysHCL []string

type AdvertiseAddrs

+ ExtraKeysHCL []string

type Agent

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

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

+ func (a *Agent) ShouldReload(newConfig *Config) (agent, http bool)

type ClientConfig

+ DisableRemoteExec bool

+ ExtraKeysHCL []string

+ GCIntervalHCL string

+ MemoryMB int

+ ServerJoin *ServerJoin

type Config

+ Autopilot *config.AutopilotConfig

+ ExtraKeysHCL []string

+ LogJson bool

+ PluginDir string

+ Plugins []*config.PluginConfig

+ func DefaultEntConfig() *Config

+ type DiscoverInterface interface

+ Addrs func(string, *golog.Logger) ([]string, error)

+ Help func() string

+ Names func() []string

type HTTPServer

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

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

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

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

type Ports

+ ExtraKeysHCL []string

type Resources

+ ExtraKeysHCL []string

+ func (r *Resources) CanParseReserved() error

type ServerConfig

+ ExtraKeysHCL []string

+ HeartbeatGraceHCL string

+ MinHeartbeatTTLHCL string

+ NonVotingServer bool

+ RaftProtocol int

+ RedundancyZone string

+ RetryIntervalHCL string

+ ServerJoin *ServerJoin

+ UpgradeVersion string

+ type ServerJoin struct

+ ExtraKeysHCL []string

+ RetryInterval time.Duration

+ RetryIntervalHCL string

+ RetryJoin []string

+ RetryMaxAttempts int

+ StartJoin []string

+ func (s *ServerJoin) Merge(b *ServerJoin) *ServerJoin

type Telemetry

+ DataDogTags []string

+ DisableDispatchedJobSummaryMetrics bool

+ ExtraKeysHCL []string

+ FilterDefault *bool

+ PrefixFilter []string

+ func (t *Telemetry) PrefixFilters() (allowed, blocked []string, err error)

v0.8.4-rc1

Jun 1, 2018

v0.7.0

Nov 1, 2017

Changes in this version

+ const ErrEntOnly

+ var TempDir = os.TempDir()

+ 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 ClientConfig

+ GCMaxAllocs int

type Command

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

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

type Config

+ ACL *ACLConfig

+ Sentinel *config.SentinelConfig

type HTTPServer

+ Addr string

+ 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) DeploymentSpecificRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

+ func (s *HTTPServer) DeploymentsRequest(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)

+ 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 ServerConfig

+ AuthoritativeRegion string

+ DeploymentGCThreshold string

+ MaxHeartbeatsPerSecond float64

+ MinHeartbeatTTL time.Duration

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)

type Telemetry

+ BackwardsCompatibleMetrics bool

+ DisableTaggedMetrics bool

+ PrometheusMetrics bool

+ type TestAgent struct

+ Config *Config

+ ConfigCallback func(*Config)

+ DataDir string

+ Key string

+ LogOutput io.Writer

+ Name string

+ RootToken *structs.ACLToken

+ Server *HTTPServer

+ T testing.T

+ func NewTestAgent(t testing.T, 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

+ type UIAssetWrapper struct

+ FileSystem *assetfs.AssetFS

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

v0.7.0-rc1

Oct 19, 2017

v0.5.5

Mar 14, 2017

Changes in this version

+ const OriginEnd

+ const OriginStart

+ var HeartbeatStreamFrame = &StreamFrame

+ 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 AdvertiseAddrs

+ HTTP string

type ClientConfig

+ ChrootEnv map[string]string

+ ClientMaxPort int

+ ClientMinPort int

+ CpuCompute int

+ GCDiskUsageThreshold float64

+ GCInodeUsageThreshold float64

+ GCInterval time.Duration

+ GCParallelDestroys int

+ MaxKillTimeout string

+ NoHostUUID bool

+ Reserved *Resources

type Config

+ Consul *config.ConsulConfig

+ HTTPAPIResponseHeaders map[string]string

+ TLSConfig *config.TLSConfig

+ Vault *config.VaultConfig

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

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

type HTTPServer

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

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

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

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

+ func (s *HTTPServer) FileCatRequest(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) FsRequest(resp http.ResponseWriter, req *http.Request) (interface{}, error)

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

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

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

+ 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) ReconcileJobSummaries(resp http.ResponseWriter, req *http.Request) (interface{}, error)

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

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

+ type ReadCloserWrapper struct

+ 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

+ EncryptKey string

+ EvalGCThreshold string

+ HeartbeatGrace string

+ JobGCThreshold string

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

+ type StreamFrame struct

+ Data []byte

+ File string

+ FileEvent string

+ Offset int64

+ func (s *StreamFrame) Clear()

+ func (s *StreamFrame) IsCleared() bool

+ func (s *StreamFrame) IsHeartbeat() bool

+ type StreamFramer struct

+ Err error

+ func NewStreamFramer(out io.WriteCloser, plainTxt bool, heartbeatRate, batchWindow time.Duration, ...) *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

+ CirconusCheckDisplayName string

+ CirconusCheckForceMetricActivation string

+ CirconusCheckID string

+ CirconusCheckInstanceID string

+ CirconusCheckSearchTag string

+ CirconusCheckSubmissionURL string

+ CirconusCheckTags string

+ CirconusSubmissionInterval string

+ CollectionInterval string

+ DataDogAddr string

+ PublishAllocationMetrics bool

+ PublishNodeMetrics bool

+ UseNodeName bool

v0.5.1-rc1

Dec 6, 2016

v0.4.0-rc2

Jun 22, 2016

v0.2.2

Dec 11, 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

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

+ type ClientConfig struct

+ AllocDir string

+ Enabled bool

+ Meta map[string]string

+ NetworkInterface string

+ NetworkSpeed int

+ NodeClass string

+ NodeID string

+ Options map[string]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

+ Files []string

+ 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 (c *Config) Listener(proto, addr string, port int) (net.Listener, error)

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

+ 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) RegionListRequest(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

+ NodeGCThreshold string

+ NumSchedulers int

+ ProtocolVersion int

+ RejoinAfterLeave bool

+ RetryInterval string

+ RetryJoin []string

+ RetryMaxAttempts int

+ StartJoin []string

+ 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