agent

Dec 15, 2017

Changes in this version

+ func New(ui cli.Ui, revision, version, versionPre, versionHuman string, ...) *cmd

Apr 17, 2017

Changes in this version

+ func Duration(d time.Duration) *time.Duration

+ func FixupConfigDurations(raw interface{}) error

+ func Uint64(i uint64) *uint64

+ type Autopilot struct

+ CleanupDeadServers *bool

+ DisableUpgradeMigration *bool

+ LastContactThreshold *time.Duration

+ LastContactThresholdRaw string

+ MaxTrailingLogs *uint64

+ RedundancyZoneTag string

+ ServerStabilizationTime *time.Duration

+ ServerStabilizationTimeRaw string

type Config

+ Autopilot Autopilot

+ DisableHostNodeID bool

+ NonVotingServer bool

+ RaftProtocol int

type HTTPServer

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

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

Feb 15, 2017

Changes in this version

+ func ParseRelayFactor(n int) (uint8, error)

type Config

+ TLSMinVersion string

Jan 26, 2017

Changes in this version

+ const RPCAddrEnvName

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

type Agent

+ func (a *Agent) SnapshotRPC(args *structs.SnapshotRequest, in io.Reader, out io.Writer, ...) error

type AgentSelf

+ Meta map[string]string

type CheckHTTP

+ TLSSkipVerify bool

type CheckType

+ TLSSkipVerify bool

type Config

+ ACLAgentMasterToken string

+ ACLAgentToken string

+ ACLDisabledTTL time.Duration

+ ACLEnforceVersion8 *bool

+ Meta map[string]string

+ NodeID types.NodeID

+ RetryJoinEC2 RetryJoinEC2

+ RetryJoinGCE RetryJoinGCE

+ SerfLanBindAddr string

+ SerfWanBindAddr string

+ func (c *Config) GetTokenForAgent() string

type HTTPServer

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

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

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

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

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

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

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

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

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

+ type RetryJoinEC2 struct

+ AccessKeyID string

+ Region string

+ SecretAccessKey string

+ TagKey string

+ TagValue string

+ type RetryJoinGCE struct

+ CredentialsFile string

+ ProjectName string

+ TagValue string

+ ZonePattern string

type Telemetry

+ CirconusCheckDisplayName string

+ CirconusCheckTags string

Sep 14, 2016

Changes in this version

+ const HttpUserAgent

+ const WatchBufSize

+ func Asset(name string) ([]byte, error)

+ func AssetDir(name string) ([]string, error)

+ func AssetInfo(name string) (os.FileInfo, error)

+ func AssetNames() []string

+ func Bool(b bool) *bool

+ func ExecScript(script string) (*exec.Cmd, error)

+ func MustAsset(name string) []byte

+ func RestoreAsset(dir, name string) error

+ func RestoreAssets(dir, name string) error

+ type AddressConfig struct

+ DNS string

+ HTTP string

+ HTTPS string

+ RPC string

+ type AdvertiseAddrsConfig struct

+ RPC *net.TCPAddr

+ RPCRaw string

+ SerfLan *net.TCPAddr

+ SerfLanRaw string

+ SerfWan *net.TCPAddr

+ SerfWanRaw string

type Agent

+ func (a *Agent) DisableNodeMaintenance()

+ func (a *Agent) DisableServiceMaintenance(serviceID string) error

+ func (a *Agent) EnableNodeMaintenance(reason, token string)

+ func (a *Agent) EnableServiceMaintenance(serviceID, reason, token string) error

+ func (a *Agent) GetCoordinate() (*coordinate.Coordinate, error)

+ func (a *Agent) InjectEndpoint(endpoint string, handler interface{}) error

+ func (a *Agent) InstallKey(key, token string) (*structs.KeyringResponses, error)

+ func (a *Agent) LastUserEvent() *UserEvent

+ func (a *Agent) ListKeys(token string) (*structs.KeyringResponses, error)

+ func (a *Agent) RemoveKey(key, token string) (*structs.KeyringResponses, error)

+ func (a *Agent) UseKey(key, token string) (*structs.KeyringResponses, error)

+ func (a *Agent) UserEvent(dc, token string, params *UserEvent) error

+ func (a *Agent) UserEvents() []*UserEvent

type AgentSelf

+ Coord *coordinate.Coordinate

+ Stats map[string]map[string]string

type CheckDefinition

+ ServiceID string

+ Status string

+ Token string

+ type CheckDocker struct

+ CheckID types.CheckID

+ DockerContainerID string

+ Interval time.Duration

+ Logger *log.Logger

+ Notify CheckNotifier

+ Script string

+ Shell string

+ func (c *CheckDocker) Init() error

+ func (c *CheckDocker) Start()

+ func (c *CheckDocker) Stop()

+ type CheckHTTP struct

+ CheckID types.CheckID

+ HTTP string

+ Interval time.Duration

+ Logger *log.Logger

+ Notify CheckNotifier

+ Timeout time.Duration

+ func (c *CheckHTTP) Start()

+ func (c *CheckHTTP) Stop()

type CheckMonitor

+ ReapLock *sync.RWMutex

+ Timeout time.Duration

+ type CheckTCP struct

+ CheckID types.CheckID

+ Interval time.Duration

+ Logger *log.Logger

+ Notify CheckNotifier

+ TCP string

+ Timeout time.Duration

+ func (c *CheckTCP) Start()

+ func (c *CheckTCP) Stop()

type CheckType

+ DeregisterCriticalServiceAfter time.Duration

+ DockerContainerID string

+ HTTP string

+ Notes string

+ Shell string

+ Status string

+ TCP string

+ Timeout time.Duration

+ func (c *CheckType) IsDocker() bool

+ func (c *CheckType) IsHTTP() bool

+ func (c *CheckType) IsTCP() bool

+ type CheckTypes []*CheckType

type Command

+ HumanVersion string

type Config

+ ACLDatacenter string

+ ACLDefaultPolicy string

+ ACLDownPolicy string

+ ACLMasterToken string

+ ACLReplicationToken string

+ ACLTTL time.Duration

+ ACLTTLRaw string

+ ACLToken string

+ Addresses AddressConfig

+ AdvertiseAddrWan string

+ AdvertiseAddrs AdvertiseAddrsConfig

+ AtlasACLToken string

+ AtlasEndpoint string

+ AtlasInfrastructure string

+ AtlasJoin bool

+ AtlasToken string

+ BootstrapExpect int

+ CheckDeregisterIntervalMin time.Duration

+ CheckReapInterval time.Duration

+ DNSRecursors []string

+ DevMode bool

+ DisableAnonymousSignature bool

+ DisableCoordinates bool

+ DisableRemoteExec bool

+ DisableUpdateCheck bool

+ EnableUi bool

+ HTTPAPIResponseHeaders map[string]string

+ Performance Performance

+ Reap *bool

+ ReconnectTimeoutLan time.Duration

+ ReconnectTimeoutLanRaw string

+ ReconnectTimeoutWan time.Duration

+ ReconnectTimeoutWanRaw string

+ RetryInterval time.Duration

+ RetryIntervalRaw string

+ RetryIntervalWan time.Duration

+ RetryIntervalWanRaw string

+ RetryJoin []string

+ RetryJoinWan []string

+ RetryMaxAttempts int

+ RetryMaxAttemptsWan int

+ SessionTTLMin time.Duration

+ SessionTTLMinRaw string

+ StartJoinWan []string

+ SyncCoordinateIntervalMin time.Duration

+ SyncCoordinateRateTarget float64

+ TaggedAddresses map[string]string

+ Telemetry Telemetry

+ TranslateWanAddrs bool

+ UnixSockets UnixSocketConfig

+ VerifyServerHostname bool

+ WatchPlans []*watch.WatchPlan

+ Watches []map[string]interface{}

+ func DevConfig() *Config

+ type CriticalCheck struct

+ Check *structs.HealthCheck

+ CriticalFor time.Duration

type DNSConfig

+ DisableCompression bool

+ EnableTruncate bool

+ OnlyPassing bool

+ RecursorTimeout time.Duration

+ RecursorTimeoutRaw string

+ UDPAnswerLimit int

type DNSServer

+ func (d *DNSServer) Shutdown()

+ type DockerClient interface

+ CreateExec func(docker.CreateExecOptions) (*docker.Exec, error)

+ InspectExec func(string) (*docker.ExecInspect, error)

+ StartExec func(string, docker.StartExecOptions) error

+ type FilePermissions interface

+ Group func() string

+ Mode func() string

+ User func() string

type HTTPServer

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (s *HTTPServer) IsUIEnabled() bool

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

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

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

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

+ type KeyringEntry struct

+ Count int

+ Datacenter string

+ Key string

+ Pool string

+ type KeyringInfo struct

+ Datacenter string

+ Error string

+ NumNodes int

+ Pool string

+ type KeyringMessage struct

+ Datacenter string

+ Message string

+ Node string

+ Pool string

+ type Performance struct

+ RaftMultiplier uint

type PortConfig

+ HTTPS int

type RPCClient

+ func (c *RPCClient) InstallKey(key, token string) (keyringResponse, error)

+ func (c *RPCClient) ListKeys(token string) (keyringResponse, error)

+ func (c *RPCClient) RemoveKey(key, token string) (keyringResponse, error)

+ func (c *RPCClient) UseKey(key, token string) (keyringResponse, error)

type ServiceDefinition

+ Address string

+ Checks CheckTypes

+ EnableTagOverride bool

+ Token string

+ func (s *ServiceDefinition) CheckTypes() (checks CheckTypes)

+ type Telemetry struct

+ CirconusAPIApp string

+ CirconusAPIToken string

+ CirconusAPIURL string

+ CirconusBrokerID string

+ CirconusBrokerSelectTag string

+ CirconusCheckForceMetricActivation string

+ CirconusCheckID string

+ CirconusCheckInstanceID string

+ CirconusCheckSearchTag string

+ CirconusCheckSubmissionURL string

+ CirconusSubmissionInterval string

+ DisableHostname bool

+ DogStatsdAddr string

+ DogStatsdTags []string

+ StatsdAddr string

+ StatsiteAddr string

+ StatsitePrefix string

+ func (s *Telemetry) GoString() string

+ type UnixSocketConfig struct

+ type UnixSocketPermissions struct

+ Grp string

+ Perms string

+ Usr string

+ func (u UnixSocketPermissions) Group() string

+ func (u UnixSocketPermissions) Mode() string

+ func (u UnixSocketPermissions) User() string

+ type UserEvent struct

+ ID string

+ LTime uint64

+ Name string

+ NodeFilter string

+ Payload []byte

+ ServiceFilter string

+ TagFilter string

+ Version int

Jun 13, 2014

Changes in this version

+ const CheckBufSize

+ const MaxRPCVersion

+ const MinInterval

+ const MinRPCVersion

+ func FixupCheckType(raw interface{}) error

+ func FixupLockDelay(raw interface{}) error

+ func LevelFilter() *logutils.LevelFilter

+ func NewLogWriter(buf int) *logWriter

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

+ type Agent struct

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

+ func (a *Agent) AddCheck(check *structs.HealthCheck, chkType *CheckType) error

+ func (a *Agent) AddService(service *structs.NodeService, chkType *CheckType) error

+ func (a *Agent) ForceLeave(node string) (err error)

+ func (a *Agent) JoinLAN(addrs []string) (n int, err error)

+ func (a *Agent) JoinWAN(addrs []string) (n int, err error)

+ func (a *Agent) LANMembers() []serf.Member

+ func (a *Agent) Leave() error

+ func (a *Agent) LocalMember() serf.Member

+ func (a *Agent) PauseSync()

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

+ func (a *Agent) RemoveCheck(checkID string) error

+ func (a *Agent) RemoveService(serviceID string) error

+ func (a *Agent) ResumeSync()

+ func (a *Agent) Shutdown() error

+ func (a *Agent) ShutdownCh() <-chan struct{}

+ func (a *Agent) StartSync()

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

+ func (a *Agent) UpdateCheck(checkID, status, output string) error

+ func (a *Agent) WANMembers() []serf.Member

+ type AgentRPC struct

+ func NewAgentRPC(agent *Agent, listener net.Listener, logOutput io.Writer, logWriter *logWriter) *AgentRPC

+ func (i *AgentRPC) ReloadCh() <-chan struct{}

+ func (i *AgentRPC) Shutdown()

+ type AgentSelf struct

+ Config *Config

+ Member serf.Member

+ type AppendSliceValue []string

+ func (s *AppendSliceValue) Set(value string) error

+ func (s *AppendSliceValue) String() string

+ type CheckDefinition struct

+ ID string

+ Name string

+ Notes string

+ func DecodeCheckDefinition(raw interface{}) (*CheckDefinition, error)

+ func (c *CheckDefinition) HealthCheck(node string) *structs.HealthCheck

+ type CheckMonitor struct

+ CheckID string

+ Interval time.Duration

+ Logger *log.Logger

+ Notify CheckNotifier

+ Script string

+ func (c *CheckMonitor) Start()

+ func (c *CheckMonitor) Stop()

+ type CheckNotifier interface

+ UpdateCheck func(checkID, status, output string)

+ type CheckTTL struct

+ CheckID string

+ Logger *log.Logger

+ Notify CheckNotifier

+ TTL time.Duration

+ func (c *CheckTTL) SetStatus(status, output string)

+ func (c *CheckTTL) Start()

+ func (c *CheckTTL) Stop()

+ type CheckType struct

+ Interval time.Duration

+ Script string

+ TTL time.Duration

+ func (c *CheckType) IsMonitor() bool

+ func (c *CheckType) IsTTL() bool

+ func (c *CheckType) Valid() bool

+ 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

+ AEInterval time.Duration

+ AdvertiseAddr string

+ BindAddr string

+ Bootstrap bool

+ CAFile string

+ CertFile string

+ CheckUpdateInterval time.Duration

+ CheckUpdateIntervalRaw string

+ Checks []*CheckDefinition

+ ClientAddr string

+ ConsulConfig *consul.Config

+ DNSConfig DNSConfig

+ DNSRecursor string

+ DataDir string

+ Datacenter string

+ Domain string

+ EnableDebug bool

+ EnableSyslog bool

+ EncryptKey string

+ KeyFile string

+ LeaveOnTerm bool

+ LogLevel string

+ NodeName string

+ PidFile string

+ Ports PortConfig

+ Protocol int

+ RejoinAfterLeave bool

+ Revision string

+ Server bool

+ ServerName string

+ Services []*ServiceDefinition

+ SkipLeaveOnInt bool

+ StartJoin []string

+ StatsiteAddr string

+ SyslogFacility string

+ UiDir string

+ VerifyIncoming bool

+ VerifyOutgoing bool

+ Version string

+ VersionPrerelease string

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

+ func DefaultConfig() *Config

+ func MergeConfig(a, b *Config) *Config

+ func ReadConfigPaths(paths []string) (*Config, error)

+ func (c *Config) ClientListener(port int) (*net.TCPAddr, error)

+ func (c *Config) EncryptBytes() ([]byte, error)

+ type DNSConfig struct

+ AllowStale bool

+ MaxStale time.Duration

+ MaxStaleRaw string

+ NodeTTL time.Duration

+ NodeTTLRaw string

+ ServiceTTL map[string]time.Duration

+ ServiceTTLRaw map[string]string

+ type DNSServer struct

+ func NewDNSServer(agent *Agent, config *DNSConfig, logOutput io.Writer, ...) (*DNSServer, error)

+ type GatedWriter struct

+ Writer io.Writer

+ func (w *GatedWriter) Flush()

+ func (w *GatedWriter) Write(p []byte) (n int, err error)

+ type HTTPServer struct

+ func NewHTTPServer(agent *Agent, uiDir string, enableDebug bool, logOutput io.Writer, bind string) (*HTTPServer, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (s *HTTPServer) Index(resp http.ResponseWriter, req *http.Request)

+ func (s *HTTPServer) KVSDelete(resp http.ResponseWriter, req *http.Request, args *structs.KeyRequest) (interface{}, error)

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

+ func (s *HTTPServer) KVSGet(resp http.ResponseWriter, req *http.Request, args *structs.KeyRequest) (interface{}, error)

+ func (s *HTTPServer) KVSGetKeys(resp http.ResponseWriter, req *http.Request, args *structs.KeyRequest) (interface{}, error)

+ func (s *HTTPServer) KVSPut(resp http.ResponseWriter, req *http.Request, args *structs.KeyRequest) (interface{}, error)

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

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

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

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

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

+ func (s *HTTPServer) Shutdown()

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

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

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

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

+ func (s *HTTPServer) UIServices(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 PortConfig struct

+ DNS int

+ HTTP int

+ RPC int

+ SerfLan int

+ SerfWan int

+ Server int

+ type RPCClient struct

+ func NewRPCClient(addr string) (*RPCClient, error)

+ func (c *RPCClient) Close() error

+ func (c *RPCClient) ForceLeave(node string) error

+ func (c *RPCClient) Join(addrs []string, wan bool) (int, error)

+ func (c *RPCClient) LANMembers() ([]Member, error)

+ func (c *RPCClient) Leave() error

+ func (c *RPCClient) Monitor(level logutils.LogLevel, ch chan<- string) (StreamHandle, error)

+ func (c *RPCClient) Reload() error

+ func (c *RPCClient) Stats() (map[string]map[string]string, error)

+ func (c *RPCClient) Stop(handle StreamHandle) error

+ func (c *RPCClient) WANMembers() ([]Member, error)

+ type ServiceDefinition struct

+ Check CheckType

+ ID string

+ Name string

+ Port int

+ Tags []string

+ func DecodeServiceDefinition(raw interface{}) (*ServiceDefinition, error)

+ func (s *ServiceDefinition) CheckType() *CheckType

+ func (s *ServiceDefinition) NodeService() *structs.NodeService

+ type ServiceSummary struct

+ ChecksCritical int

+ ChecksPassing int

+ ChecksWarning int

+ Name string

+ Nodes []string

+ type StreamHandle uint64

+ type SyslogWrapper struct

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