api

Mar 4, 2019

Changes in this version

type Agent

+ func (a *Agent) UpdateAgentACLToken(token string, q *WriteOptions) (*WriteMeta, error)

+ func (a *Agent) UpdateAgentMasterACLToken(token string, q *WriteOptions) (*WriteMeta, error)

+ func (a *Agent) UpdateDefaultACLToken(token string, q *WriteOptions) (*WriteMeta, error)

+ func (a *Agent) UpdateReplicationACLToken(token string, q *WriteOptions) (*WriteMeta, error)

type ServiceQuery

+ ServiceMeta map[string]string

Jan 28, 2019

Changes in this version

type HealthCheckDefinition

+ DeregisterCriticalServiceAfterDuration time.Duration

+ IntervalDuration time.Duration

+ TimeoutDuration time.Duration

Jan 23, 2019

Changes in this version

type Agent

+ func (a *Agent) AgentHealthServiceByID(serviceID string) (string, *AgentServiceChecksInfo, error)

+ func (a *Agent) AgentHealthServiceByName(service string) (string, []AgentServiceChecksInfo, error)

+ type AgentServiceChecksInfo struct

+ AggregatedStatus string

+ Checks HealthChecks

+ Service *AgentService

+ type CheckOp string

+ const CheckCAS

+ const CheckDelete

+ const CheckDeleteCAS

+ const CheckGet

+ const CheckSet

+ type CheckTxnOp struct

+ Check HealthCheck

+ Verb CheckOp

type Client

+ func (c *Client) Txn() *Txn

type CommonCAProviderConfig

+ CSRMaxConcurrent int

+ CSRMaxPerSecond float32

+ SkipValidate bool

type HealthCheck

+ CreateIndex uint64

+ ModifyIndex uint64

type HealthCheckDefinition

+ func (d *HealthCheckDefinition) MarshalJSON() ([]byte, error)

+ func (d *HealthCheckDefinition) UnmarshalJSON(data []byte) error

type KeyringResponse

+ Messages map[string]string

+ type NodeOp string

+ const NodeCAS

+ const NodeDelete

+ const NodeDeleteCAS

+ const NodeGet

+ const NodeSet

+ type NodeTxnOp struct

+ Node Node

+ Verb NodeOp

+ type ServiceOp string

+ const ServiceCAS

+ const ServiceDelete

+ const ServiceDeleteCAS

+ const ServiceGet

+ const ServiceSet

+ type ServiceTxnOp struct

+ Node string

+ Service AgentService

+ Verb ServiceOp

+ type Txn struct

+ func (t *Txn) Txn(txn TxnOps, q *QueryOptions) (bool, *TxnResponse, *QueryMeta, error)

type TxnOp

+ Check *CheckTxnOp

+ Node *NodeTxnOp

+ Service *ServiceTxnOp

type TxnResult

+ Check *HealthCheck

+ Node *Node

+ Service *CatalogService

Nov 14, 2018

Changes in this version

type ACL

+ func (a *ACL) PolicyCreate(policy *ACLPolicy, q *WriteOptions) (*ACLPolicy, *WriteMeta, error)

+ func (a *ACL) PolicyDelete(policyID string, q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) PolicyList(q *QueryOptions) ([]*ACLPolicyListEntry, *QueryMeta, error)

+ func (a *ACL) PolicyRead(policyID string, q *QueryOptions) (*ACLPolicy, *QueryMeta, error)

+ func (a *ACL) PolicyUpdate(policy *ACLPolicy, q *WriteOptions) (*ACLPolicy, *WriteMeta, error)

+ func (a *ACL) RulesTranslate(rules io.Reader) (string, error)

+ func (a *ACL) RulesTranslateToken(tokenID string) (string, error)

+ func (a *ACL) TokenClone(tokenID string, description string, q *WriteOptions) (*ACLToken, *WriteMeta, error)

+ func (a *ACL) TokenCreate(token *ACLToken, q *WriteOptions) (*ACLToken, *WriteMeta, error)

+ func (a *ACL) TokenDelete(tokenID string, q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) TokenList(q *QueryOptions) ([]*ACLTokenListEntry, *QueryMeta, error)

+ func (a *ACL) TokenRead(tokenID string, q *QueryOptions) (*ACLToken, *QueryMeta, error)

+ func (a *ACL) TokenReadSelf(q *QueryOptions) (*ACLToken, *QueryMeta, error)

+ func (a *ACL) TokenUpdate(token *ACLToken, q *WriteOptions) (*ACLToken, *WriteMeta, error)

+ type ACLPolicy struct

+ CreateIndex uint64

+ Datacenters []string

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ Name string

+ Rules string

+ type ACLPolicyListEntry struct

+ CreateIndex uint64

+ Datacenters []string

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ Name string

type ACLReplicationStatus

+ ReplicatedTokenIndex uint64

+ ReplicationType string

+ type ACLToken struct

+ AccessorID string

+ CreateIndex uint64

+ CreateTime time.Time

+ Description string

+ Hash []byte

+ Local bool

+ ModifyIndex uint64

+ Policies []*ACLTokenPolicyLink

+ Rules string

+ SecretID string

+ type ACLTokenListEntry struct

+ AccessorID string

+ CreateIndex uint64

+ CreateTime time.Time

+ Description string

+ Hash []byte

+ Legacy bool

+ Local bool

+ ModifyIndex uint64

+ Policies []*ACLTokenPolicyLink

+ type ACLTokenPolicyLink struct

+ ID string

+ Name string

type Agent

+ func (a *Agent) Host() (map[string]interface{}, error)

type CatalogRegistration

+ Checks HealthChecks

type CatalogService

+ Checks HealthChecks

type Client

+ func (c *Client) Debug() *Debug

+ type Debug struct

+ func (d *Debug) Goroutine() ([]byte, error)

+ func (d *Debug) Heap() ([]byte, error)

+ func (d *Debug) Profile(seconds int) ([]byte, error)

+ func (d *Debug) Trace(seconds int) ([]byte, error)

Oct 11, 2018

Changes in this version

+ const GRPCAddrEnvName

type Agent

+ func (a *Agent) Service(serviceID string, q *QueryOptions) (*AgentService, *QueryMeta, error)

type AgentService

+ ContentHash string

+ Proxy *AgentServiceConnectProxyConfig

type AgentServiceCheck

+ AliasNode string

+ AliasService string

type AgentServiceConnect

+ SidecarService *AgentServiceRegistration

type AgentServiceConnectProxy

+ Upstreams []Upstream

+ type AgentServiceConnectProxyConfig struct

+ Config map[string]interface{}

+ DestinationServiceID string

+ DestinationServiceName string

+ LocalServiceAddress string

+ LocalServicePort int

+ Upstreams []Upstream

type AgentServiceRegistration

+ Proxy *AgentServiceConnectProxyConfig

type Catalog

+ func (c *Catalog) ConnectMultipleTags(service string, tags []string, q *QueryOptions) ([]*CatalogService, *QueryMeta, error)

+ func (c *Catalog) ServiceMultipleTags(service string, tags []string, q *QueryOptions) ([]*CatalogService, *QueryMeta, error)

type CatalogService

+ ServiceProxy *AgentServiceConnectProxyConfig

type ConnectProxyConfig

+ Upstreams []Upstream

type Health

+ func (h *Health) ConnectMultipleTags(service string, tags []string, passingOnly bool, q *QueryOptions) ([]*ServiceEntry, *QueryMeta, error)

+ func (h *Health) ServiceMultipleTags(service string, tags []string, passingOnly bool, q *QueryOptions) ([]*ServiceEntry, *QueryMeta, error)

type QueryMeta

+ CacheAge time.Duration

+ CacheHit bool

type QueryOptions

+ MaxAge time.Duration

+ StaleIfError time.Duration

+ UseCache bool

+ type Upstream struct

+ Config map[string]interface{}

+ Datacenter string

+ DestinationName string

+ DestinationNamespace string

+ DestinationType UpstreamDestType

+ LocalBindAddress string

+ LocalBindPort int

+ type UpstreamDestType string

+ const UpstreamDestTypePreparedQuery

+ const UpstreamDestTypeService

Sep 13, 2018

Changes in this version

type AgentService

+ Weights AgentWeights

type AgentServiceRegistration

+ Weights *AgentWeights

+ type AgentWeights struct

+ Passing int

+ Warning int

type CatalogService

+ ServiceWeights Weights

+ type Weights struct

+ Passing int

+ Warning int

Jul 30, 2018

Changes in this version

+ type CommonCAProviderConfig struct

+ LeafCertTTL time.Duration

Jul 12, 2018

Changes in this version

type Config

+ func (c *Config) GenerateEnv() []string

Jun 25, 2018

Changes in this version

+ const IntentionDefaultNamespace

type Agent

+ func (a *Agent) ConnectAuthorize(auth *AgentAuthorizeParams) (*AgentAuthorize, error)

+ func (a *Agent) ConnectCALeaf(serviceID string, q *QueryOptions) (*LeafCert, *QueryMeta, error)

+ func (a *Agent) ConnectCARoots(q *QueryOptions) (*CARootList, *QueryMeta, error)

+ func (a *Agent) ConnectProxyConfig(proxyServiceID string, q *QueryOptions) (*ConnectProxyConfig, *QueryMeta, error)

+ type AgentAuthorize struct

+ Authorized bool

+ Reason string

+ type AgentAuthorizeParams struct

+ ClientCertSerial string

+ ClientCertURI string

+ Target string

type AgentService

+ Connect *AgentServiceConnect

+ Kind ServiceKind

+ ProxyDestination string

+ type AgentServiceConnect struct

+ Native bool

+ Proxy *AgentServiceConnectProxy

+ type AgentServiceConnectProxy struct

+ Command []string

+ Config map[string]interface{}

+ ExecMode ProxyExecMode

type AgentServiceRegistration

+ Connect *AgentServiceConnect

+ Kind ServiceKind

+ ProxyDestination string

+ type CAConfig struct

+ Config map[string]interface{}

+ CreateIndex uint64

+ ModifyIndex uint64

+ Provider string

+ type CARoot struct

+ Active bool

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ Name string

+ RootCertPEM string

+ type CARootList struct

+ ActiveRootID string

+ Roots []*CARoot

+ TrustDomain string

type Catalog

+ func (c *Catalog) Connect(service, tag string, q *QueryOptions) ([]*CatalogService, *QueryMeta, error)

type Client

+ func (c *Client) Connect() *Connect

+ type Connect struct

+ func (c *Connect) IntentionCreate(ixn *Intention, q *WriteOptions) (string, *WriteMeta, error)

+ func (c *Connect) IntentionUpdate(ixn *Intention, q *WriteOptions) (*WriteMeta, error)

+ func (h *Connect) CAGetConfig(q *QueryOptions) (*CAConfig, *QueryMeta, error)

+ func (h *Connect) CARoots(q *QueryOptions) (*CARootList, *QueryMeta, error)

+ func (h *Connect) CASetConfig(conf *CAConfig, q *WriteOptions) (*WriteMeta, error)

+ func (h *Connect) IntentionCheck(args *IntentionCheck, q *QueryOptions) (bool, *QueryMeta, error)

+ func (h *Connect) IntentionDelete(id string, q *WriteOptions) (*WriteMeta, error)

+ func (h *Connect) IntentionGet(id string, q *QueryOptions) (*Intention, *QueryMeta, error)

+ func (h *Connect) IntentionMatch(args *IntentionMatch, q *QueryOptions) (map[string][]*Intention, *QueryMeta, error)

+ func (h *Connect) Intentions(q *QueryOptions) ([]*Intention, *QueryMeta, error)

+ type ConnectProxyConfig struct

+ Command []string

+ Config map[string]interface{}

+ ContentHash string

+ ExecMode ProxyExecMode

+ ProxyServiceID string

+ TargetServiceID string

+ TargetServiceName string

+ type ConsulCAProviderConfig struct

+ PrivateKey string

+ RootCert string

+ RotationPeriod time.Duration

+ func ParseConsulCAConfig(raw map[string]interface{}) (*ConsulCAProviderConfig, error)

type Health

+ func (h *Health) Connect(service, tag string, passingOnly bool, q *QueryOptions) ([]*ServiceEntry, *QueryMeta, error)

+ type Intention struct

+ Action IntentionAction

+ CreateIndex uint64

+ CreatedAt time.Time

+ DefaultAddr string

+ DefaultPort int

+ Description string

+ DestinationNS string

+ DestinationName string

+ ID string

+ Meta map[string]string

+ ModifyIndex uint64

+ Precedence int

+ SourceNS string

+ SourceName string

+ SourceType IntentionSourceType

+ UpdatedAt time.Time

+ func (i *Intention) DestinationString() string

+ func (i *Intention) SourceString() string

+ func (i *Intention) String() string

+ type IntentionAction string

+ const IntentionActionAllow

+ const IntentionActionDeny

+ type IntentionCheck struct

+ Destination string

+ Source string

+ SourceType IntentionSourceType

+ type IntentionMatch struct

+ By IntentionMatchType

+ Names []string

+ type IntentionMatchType string

+ const IntentionMatchDestination

+ const IntentionMatchSource

+ type IntentionSourceType string

+ const IntentionSourceConsul

+ type LeafCert struct

+ CertPEM string

+ CreateIndex uint64

+ ModifyIndex uint64

+ PrivateKeyPEM string

+ SerialNumber string

+ Service string

+ ServiceURI string

+ ValidAfter time.Time

+ ValidBefore time.Time

+ type ProxyExecMode string

+ const ProxyExecModeDaemon

+ const ProxyExecModeScript

type QueryMeta

+ LastContentHash string

type QueryOptions

+ Connect bool

+ WaitHash string

+ type ServiceKind string

+ const ServiceKindConnectProxy

+ const ServiceKindTypical

type ServiceQuery

+ Connect bool

May 11, 2018

Changes in this version

type AgentService

+ Meta map[string]string

Apr 13, 2018

Changes in this version

type AgentServiceCheck

+ GRPC string

+ GRPCUseTLS bool

type AgentServiceRegistration

+ Meta map[string]string

type CatalogService

+ ServiceMeta map[string]string

type ServiceQuery

+ IgnoreCheckIDs []string

Jan 24, 2018

Changes in this version

type AgentServiceCheck

+ CheckID string

+ Name string

Nov 20, 2017

Changes in this version

type AgentCheck

+ Definition HealthCheckDefinition

type AgentServiceCheck

+ Args []string

type CatalogRegistration

+ SkipNodeUpdate bool

type Coordinate

+ func (c *Coordinate) Node(node string, q *QueryOptions) ([]*CoordinateEntry, *QueryMeta, error)

+ func (c *Coordinate) Update(coord *CoordinateEntry, q *WriteOptions) (*WriteMeta, error)

type HealthCheck

+ Definition HealthCheckDefinition

+ type HealthCheckDefinition struct

+ DeregisterCriticalServiceAfter ReadableDuration

+ HTTP string

+ Header map[string][]string

+ Interval ReadableDuration

+ Method string

+ TCP string

+ TLSSkipVerify bool

+ Timeout ReadableDuration

Oct 16, 2017

Changes in this version

+ func IsRetryableError(err error) bool

type Area

+ UseTLS bool

type Operator

+ func (op *Operator) AreaUpdate(areaID string, area *Area, q *WriteOptions) (string, *WriteMeta, error)

type RaftServer

+ ProtocolVersion string

Sep 8, 2017

Changes in this version

+ const AllSegments

type Agent

+ func (a *Agent) MembersOpts(opts MembersOpts) ([]*AgentMember, error)

type CoordinateEntry

+ Segment string

type KeyringResponse

+ Segment string

+ type MembersOpts struct

+ Segment string

+ WAN bool

type Operator

+ func (op *Operator) SegmentList(q *QueryOptions) ([]string, *QueryMeta, error)

Aug 9, 2017

Changes in this version

type ACL

+ func (a *ACL) Bootstrap() (string, *WriteMeta, error)

type Agent

+ func (a *Agent) Metrics() (*MetricsInfo, error)

+ func (c *Agent) UpdateACLAgentMasterToken(token string, q *WriteOptions) (*WriteMeta, error)

+ func (c *Agent) UpdateACLAgentToken(token string, q *WriteOptions) (*WriteMeta, error)

+ func (c *Agent) UpdateACLReplicationToken(token string, q *WriteOptions) (*WriteMeta, error)

+ func (c *Agent) UpdateACLToken(token string, q *WriteOptions) (*WriteMeta, error)

+ type AgentToken struct

+ Token string

+ type GaugeValue struct

+ Labels map[string]string

+ Name string

+ Value float32

+ type MetricsInfo struct

+ Counters []SampledValue

+ Gauges []GaugeValue

+ Points []PointValue

+ Samples []SampledValue

+ Timestamp string

+ type PointValue struct

+ Name string

+ Points []float32

+ type SampledValue struct

+ Count int

+ Labels map[string]string

+ Max float64

+ Mean float64

+ Min float64

+ Name string

+ Stddev float64

+ Sum float64

Jul 20, 2017

Changes in this version

type AutopilotConfiguration

+ UpgradeVersionTag string

type QueryOptions

+ func (o *QueryOptions) Context() context.Context

+ func (o *QueryOptions) WithContext(ctx context.Context) *QueryOptions

type WriteOptions

+ func (o *WriteOptions) Context() context.Context

+ func (o *WriteOptions) WithContext(ctx context.Context) *WriteOptions

Jun 9, 2017

Changes in this version

type AgentServiceCheck

+ Header map[string][]string

+ Method string

May 9, 2017

Changes in this version

+ func NewHttpClient(transport *http.Transport, tlsConf TLSConfig) (*http.Client, error)

type ACL

+ func (a *ACL) Replication(q *QueryOptions) (*ACLReplicationStatus, *QueryMeta, error)

+ type ACLReplicationStatus struct

+ Enabled bool

+ LastError time.Time

+ LastSuccess time.Time

+ ReplicatedIndex uint64

+ Running bool

+ SourceDatacenter string

type CatalogService

+ Datacenter string

type Config

+ Transport *http.Transport

type HealthCheck

+ ServiceTags []string

type KVOp

+ const KVCheckNotExists

type Node

+ Datacenter string

Apr 17, 2017

Changes in this version

+ const HTTPCAFile

+ const HTTPCAPath

+ const HTTPClientCert

+ const HTTPClientKey

+ const HTTPTLSServerName

type AgentService

+ CreateIndex uint64

+ ModifyIndex uint64

type Config

+ TLSConfig TLSConfig

type Node

+ CreateIndex uint64

+ ModifyIndex uint64

type TLSConfig

+ CAPath string

Apr 5, 2017

Changes in this version

+ type Area struct

+ ID string

+ PeerDatacenter string

+ RetryJoin []string

+ type AreaJoinResponse struct

+ Address string

+ Error string

+ Joined bool

+ type AutopilotConfiguration struct

+ CleanupDeadServers bool

+ CreateIndex uint64

+ DisableUpgradeMigration bool

+ LastContactThreshold *ReadableDuration

+ MaxTrailingLogs uint64

+ ModifyIndex uint64

+ RedundancyZoneTag string

+ ServerStabilizationTime *ReadableDuration

type CoordinateDatacenterMap

+ AreaID string

type Operator

+ func (op *Operator) AreaCreate(area *Area, q *WriteOptions) (string, *WriteMeta, error)

+ func (op *Operator) AreaDelete(areaID string, q *WriteOptions) (*WriteMeta, error)

+ func (op *Operator) AreaGet(areaID string, q *QueryOptions) ([]*Area, *QueryMeta, error)

+ func (op *Operator) AreaJoin(areaID string, addresses []string, q *WriteOptions) ([]*AreaJoinResponse, *WriteMeta, error)

+ func (op *Operator) AreaList(q *QueryOptions) ([]*Area, *QueryMeta, error)

+ func (op *Operator) AreaMembers(areaID string, q *QueryOptions) ([]*SerfMember, *QueryMeta, error)

+ func (op *Operator) AutopilotCASConfiguration(conf *AutopilotConfiguration, q *WriteOptions) (bool, error)

+ func (op *Operator) AutopilotGetConfiguration(q *QueryOptions) (*AutopilotConfiguration, error)

+ func (op *Operator) AutopilotServerHealth(q *QueryOptions) (*OperatorHealthReply, error)

+ func (op *Operator) AutopilotSetConfiguration(conf *AutopilotConfiguration, q *WriteOptions) error

+ func (op *Operator) RaftRemovePeerByID(id string, q *WriteOptions) error

+ type OperatorHealthReply struct

+ FailureTolerance int

+ Healthy bool

+ Servers []ServerHealth

type QueryOptions

+ RelayFactor uint8

+ type ReadableDuration time.Duration

+ func NewReadableDuration(dur time.Duration) *ReadableDuration

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

+ func (d *ReadableDuration) MarshalJSON() ([]byte, error)

+ func (d *ReadableDuration) String() string

+ func (d *ReadableDuration) UnmarshalJSON(raw []byte) error

+ type SerfMember struct

+ Addr net.IP

+ Build string

+ Datacenter string

+ ID string

+ Name string

+ Port uint16

+ Protocol int

+ RTT time.Duration

+ Role string

+ Status string

+ type ServerHealth struct

+ Address string

+ Healthy bool

+ ID string

+ LastContact *ReadableDuration

+ LastIndex uint64

+ LastTerm uint64

+ Leader bool

+ Name string

+ SerfStatus string

+ StableSince time.Time

+ Version string

+ Voter bool

type WriteOptions

+ RelayFactor uint8

Jan 26, 2017

Changes in this version

type CatalogRegistration

+ ID string

+ NodeMeta map[string]string

type CatalogService

+ ID string

+ NodeMeta map[string]string

type Node

+ ID string

+ Meta map[string]string

type QueryOptions

+ NodeMeta map[string]string

type ServiceQuery

+ NodeMeta map[string]string

Dec 19, 2016

Changes in this version

+ const HTTPAddrEnvName

+ const HTTPAuthEnvName

+ const HTTPSSLEnvName

+ const HTTPSSLVerifyEnvName

+ const HTTPTokenEnvName

+ const HealthMaint

+ const NodeMaint

+ const ServiceMaintPrefix

type Agent

+ func (a *Agent) Leave() error

+ func (a *Agent) Monitor(loglevel string, stopCh chan struct{}, q *QueryOptions) (chan string, error)

+ func (a *Agent) Reload() error

type AgentServiceCheck

+ Notes string

type CatalogService

+ CreateIndex uint64

+ ModifyIndex uint64

+ type HealthChecks []*HealthCheck

+ func (c HealthChecks) AggregatedStatus() string

+ type KeyringResponse struct

+ Datacenter string

+ Keys map[string]int

+ NumNodes int

+ WAN bool

type Operator

+ func (op *Operator) KeyringInstall(key string, q *WriteOptions) error

+ func (op *Operator) KeyringList(q *QueryOptions) ([]*KeyringResponse, error)

+ func (op *Operator) KeyringRemove(key string, q *WriteOptions) error

+ func (op *Operator) KeyringUse(key string, q *WriteOptions) error

Nov 10, 2016

Changes in this version

type AgentServiceCheck

+ TLSSkipVerify string

type Client

+ func (c *Client) Snapshot() *Snapshot

type LockOptions

+ SessionOpts *SessionEntry

+ type Snapshot struct

+ func (s *Snapshot) Restore(q *WriteOptions, in io.Reader) error

+ func (s *Snapshot) Save(q *QueryOptions) (io.ReadCloser, *QueryMeta, error)

Sep 14, 2016

Changes in this version

+ const HealthAny

+ const HealthCritical

+ const HealthPassing

+ const HealthWarning

+ const KVCAS

+ const KVCheckIndex

+ const KVCheckSession

+ const KVDelete

+ const KVDeleteCAS

+ const KVDeleteTree

+ const KVGet

+ const KVGetTree

+ const KVLock

+ const KVSet

+ const KVUnlock

+ func SetupTLSConfig(tlsConfig *TLSConfig) (*tls.Config, error)

type AgentServiceCheck

+ DeregisterCriticalServiceAfter string

type CatalogRegistration

+ TaggedAddresses map[string]string

type CatalogService

+ TaggedAddresses map[string]string

type Client

+ func (c *Client) Operator() *Operator

type KV

+ func (k *KV) Txn(txn KVTxnOps, q *QueryOptions) (bool, *KVTxnResponse, *QueryMeta, error)

+ type KVOp string

+ type KVTxnOp struct

+ Flags uint64

+ Index uint64

+ Key string

+ Session string

+ Value []byte

+ Verb string

+ type KVTxnOps []*KVTxnOp

+ type KVTxnResponse struct

+ Errors TxnErrors

+ Results []*KVPair

type Node

+ TaggedAddresses map[string]string

+ type Operator struct

+ func (op *Operator) RaftGetConfiguration(q *QueryOptions) (*RaftConfiguration, error)

+ func (op *Operator) RaftRemovePeerByAddress(address string, q *WriteOptions) error

type PreparedQueryDefinition

+ Template QueryTemplate

type QueryMeta

+ AddressTranslationEnabled bool

+ type QueryTemplate struct

+ Regexp string

+ Type string

+ type RaftConfiguration struct

+ Index uint64

+ Servers []*RaftServer

+ type RaftServer struct

+ Address string

+ ID string

+ Leader bool

+ Node string

+ Voter bool

type ServiceQuery

+ Near string

+ type TLSConfig struct

+ Address string

+ CAFile string

+ CertFile string

+ InsecureSkipVerify bool

+ KeyFile string

+ type TxnError struct

+ OpIndex int

+ What string

+ type TxnErrors []*TxnError

+ type TxnOp struct

+ KV *KVTxnOp

+ type TxnOps []*TxnOp

+ type TxnResponse struct

+ Errors TxnErrors

+ Results TxnResults

+ type TxnResult struct

+ KV *KVPair

+ type TxnResults []*TxnResult

Mar 16, 2016

Changes in this version

type AgentService

+ EnableTagOverride bool

type AgentServiceRegistration

+ EnableTagOverride bool

type CatalogService

+ ServiceEnableTagOverride bool

type Config

+ func DefaultNonPooledConfig() *Config

Jan 6, 2016

Changes in this version

+ func IsServerError(err error) bool

type LockOptions

+ LockTryOnce bool

+ LockWaitTime time.Duration

type SemaphoreOptions

+ MonitorRetries int

+ MonitorRetryTime time.Duration

+ SemaphoreTryOnce bool

+ SemaphoreWaitTime time.Duration

Dec 3, 2015

Changes in this version

+ const DefaultMonitorRetryTime

+ var ErrSessionExpired = errors.New("session expired")

type AgentServiceCheck

+ DockerContainerID string

+ Shell string

+ TCP string

type Client

+ func (c *Client) Coordinate() *Coordinate

+ func (c *Client) PreparedQuery() *PreparedQuery

+ type Coordinate struct

+ func (c *Coordinate) Datacenters() ([]*CoordinateDatacenterMap, error)

+ func (c *Coordinate) Nodes(q *QueryOptions) ([]*CoordinateEntry, *QueryMeta, error)

+ type CoordinateDatacenterMap struct

+ Coordinates []CoordinateEntry

+ Datacenter string

+ type CoordinateEntry struct

+ Coord *coordinate.Coordinate

+ Node string

type LockOptions

+ MonitorRetries int

+ MonitorRetryTime time.Duration

+ type PreparedQuery struct

+ func (c *PreparedQuery) Create(query *PreparedQueryDefinition, q *WriteOptions) (string, *WriteMeta, error)

+ func (c *PreparedQuery) Delete(queryID string, q *QueryOptions) (*QueryMeta, error)

+ func (c *PreparedQuery) Execute(queryIDOrName string, q *QueryOptions) (*PreparedQueryExecuteResponse, *QueryMeta, error)

+ func (c *PreparedQuery) Get(queryID string, q *QueryOptions) ([]*PreparedQueryDefinition, *QueryMeta, error)

+ func (c *PreparedQuery) List(q *QueryOptions) ([]*PreparedQueryDefinition, *QueryMeta, error)

+ func (c *PreparedQuery) Update(query *PreparedQueryDefinition, q *WriteOptions) (*WriteMeta, error)

+ type PreparedQueryDefinition struct

+ DNS QueryDNSOptions

+ ID string

+ Name string

+ Service ServiceQuery

+ Session string

+ Token string

+ type PreparedQueryExecuteResponse struct

+ DNS QueryDNSOptions

+ Datacenter string

+ Failovers int

+ Nodes []ServiceEntry

+ Service string

+ type QueryDNSOptions struct

+ TTL string

+ type QueryDatacenterOptions struct

+ Datacenters []string

+ NearestN int

type QueryOptions

+ Near string

+ type ServiceQuery struct

+ Failover QueryDatacenterOptions

+ OnlyPassing bool

+ Service string

+ Tags []string

May 13, 2015

Changes in this version

type AgentServiceCheck

+ Status string

type CatalogService

+ ServiceAddress string

Feb 19, 2015

Changes in this version

+ const ACLClientType

+ const ACLManagementType

+ const DefaultLockRetryTime

+ const DefaultLockSessionName

+ const DefaultLockSessionTTL

+ const DefaultLockWaitTime

+ const DefaultSemaphoreKey

+ const DefaultSemaphoreRetryTime

+ const DefaultSemaphoreSessionName

+ const DefaultSemaphoreSessionTTL

+ const DefaultSemaphoreWaitTime

+ const LockFlagValue

+ const SemaphoreFlagValue

+ const SessionBehaviorDelete

+ const SessionBehaviorRelease

+ var ErrLockConflict = fmt.Errorf("Existing key does not match lock use")

+ var ErrLockHeld = fmt.Errorf("Lock already held")

+ var ErrLockInUse = fmt.Errorf("Lock in use")

+ var ErrLockNotHeld = fmt.Errorf("Lock not held")

+ var ErrSemaphoreConflict = fmt.Errorf("Existing key does not match semaphore use")

+ var ErrSemaphoreHeld = fmt.Errorf("Semaphore already held")

+ var ErrSemaphoreInUse = fmt.Errorf("Semaphore in use")

+ var ErrSemaphoreNotHeld = fmt.Errorf("Semaphore not held")

+ type ACL struct

+ func (a *ACL) Clone(id string, q *WriteOptions) (string, *WriteMeta, error)

+ func (a *ACL) Create(acl *ACLEntry, q *WriteOptions) (string, *WriteMeta, error)

+ func (a *ACL) Destroy(id string, q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) Info(id string, q *QueryOptions) (*ACLEntry, *QueryMeta, error)

+ func (a *ACL) List(q *QueryOptions) ([]*ACLEntry, *QueryMeta, error)

+ func (a *ACL) Update(acl *ACLEntry, q *WriteOptions) (*WriteMeta, error)

+ type ACLEntry struct

+ CreateIndex uint64

+ ID string

+ ModifyIndex uint64

+ Name string

+ Rules string

+ Type string

+ type Agent struct

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

+ func (a *Agent) CheckRegister(check *AgentCheckRegistration) error

+ func (a *Agent) Checks() (map[string]*AgentCheck, error)

+ func (a *Agent) DisableNodeMaintenance() error

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

+ func (a *Agent) EnableNodeMaintenance(reason string) error

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

+ func (a *Agent) FailTTL(checkID, note string) error

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

+ func (a *Agent) Join(addr string, wan bool) error

+ func (a *Agent) Members(wan bool) ([]*AgentMember, error)

+ func (a *Agent) NodeName() (string, error)

+ func (a *Agent) PassTTL(checkID, note string) error

+ func (a *Agent) Self() (map[string]map[string]interface{}, error)

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

+ func (a *Agent) ServiceRegister(service *AgentServiceRegistration) error

+ func (a *Agent) Services() (map[string]*AgentService, error)

+ func (a *Agent) UpdateTTL(checkID, note, status string) error

+ func (a *Agent) WarnTTL(checkID, note string) error

+ type AgentCheck struct

+ CheckID string

+ Name string

+ Node string

+ Notes string

+ Output string

+ ServiceID string

+ ServiceName string

+ Status string

+ type AgentCheckRegistration struct

+ ID string

+ Name string

+ Notes string

+ ServiceID string

+ type AgentMember struct

+ Addr string

+ DelegateCur uint8

+ DelegateMax uint8

+ DelegateMin uint8

+ Name string

+ Port uint16

+ ProtocolCur uint8

+ ProtocolMax uint8

+ ProtocolMin uint8

+ Status int

+ Tags map[string]string

+ type AgentService struct

+ Address string

+ ID string

+ Port int

+ Service string

+ Tags []string

+ type AgentServiceCheck struct

+ HTTP string

+ Interval string

+ Script string

+ TTL string

+ Timeout string

+ type AgentServiceChecks []*AgentServiceCheck

+ type AgentServiceRegistration struct

+ Address string

+ Check *AgentServiceCheck

+ Checks AgentServiceChecks

+ ID string

+ Name string

+ Port int

+ Tags []string

+ type Catalog struct

+ func (c *Catalog) Datacenters() ([]string, error)

+ func (c *Catalog) Deregister(dereg *CatalogDeregistration, q *WriteOptions) (*WriteMeta, error)

+ func (c *Catalog) Node(node string, q *QueryOptions) (*CatalogNode, *QueryMeta, error)

+ func (c *Catalog) Nodes(q *QueryOptions) ([]*Node, *QueryMeta, error)

+ func (c *Catalog) Register(reg *CatalogRegistration, q *WriteOptions) (*WriteMeta, error)

+ func (c *Catalog) Service(service, tag string, q *QueryOptions) ([]*CatalogService, *QueryMeta, error)

+ func (c *Catalog) Services(q *QueryOptions) (map[string][]string, *QueryMeta, error)

+ type CatalogDeregistration struct

+ Address string

+ CheckID string

+ Datacenter string

+ Node string

+ ServiceID string

+ type CatalogNode struct

+ Node *Node

+ Services map[string]*AgentService

+ type CatalogRegistration struct

+ Address string

+ Check *AgentCheck

+ Datacenter string

+ Node string

+ Service *AgentService

+ type CatalogService struct

+ Address string

+ Node string

+ ServiceID string

+ ServiceName string

+ ServicePort int

+ ServiceTags []string

+ type Client struct

+ func NewClient(config *Config) (*Client, error)

+ func (c *Client) ACL() *ACL

+ func (c *Client) Agent() *Agent

+ func (c *Client) Catalog() *Catalog

+ func (c *Client) Event() *Event

+ func (c *Client) Health() *Health

+ func (c *Client) KV() *KV

+ func (c *Client) LockKey(key string) (*Lock, error)

+ func (c *Client) LockOpts(opts *LockOptions) (*Lock, error)

+ func (c *Client) Raw() *Raw

+ func (c *Client) SemaphoreOpts(opts *SemaphoreOptions) (*Semaphore, error)

+ func (c *Client) SemaphorePrefix(prefix string, limit int) (*Semaphore, error)

+ func (c *Client) Session() *Session

+ func (c *Client) Status() *Status

+ type Config struct

+ Address string

+ Datacenter string

+ HttpAuth *HttpBasicAuth

+ HttpClient *http.Client

+ Scheme string

+ Token string

+ WaitTime time.Duration

+ func DefaultConfig() *Config

+ type Event struct

+ func (e *Event) Fire(params *UserEvent, q *WriteOptions) (string, *WriteMeta, error)

+ func (e *Event) IDToIndex(uuid string) uint64

+ func (e *Event) List(name string, q *QueryOptions) ([]*UserEvent, *QueryMeta, error)

+ type Health struct

+ func (h *Health) Checks(service string, q *QueryOptions) ([]*HealthCheck, *QueryMeta, error)

+ func (h *Health) Node(node string, q *QueryOptions) ([]*HealthCheck, *QueryMeta, error)

+ func (h *Health) Service(service, tag string, passingOnly bool, q *QueryOptions) ([]*ServiceEntry, *QueryMeta, error)

+ func (h *Health) State(state string, q *QueryOptions) ([]*HealthCheck, *QueryMeta, error)

+ type HealthCheck struct

+ CheckID string

+ Name string

+ Node string

+ Notes string

+ Output string

+ ServiceID string

+ ServiceName string

+ Status string

+ type HttpBasicAuth struct

+ Password string

+ Username string

+ type KV struct

+ func (k *KV) Acquire(p *KVPair, q *WriteOptions) (bool, *WriteMeta, error)

+ func (k *KV) CAS(p *KVPair, q *WriteOptions) (bool, *WriteMeta, error)

+ func (k *KV) Delete(key string, w *WriteOptions) (*WriteMeta, error)

+ func (k *KV) DeleteCAS(p *KVPair, q *WriteOptions) (bool, *WriteMeta, error)

+ func (k *KV) DeleteTree(prefix string, w *WriteOptions) (*WriteMeta, error)

+ func (k *KV) Get(key string, q *QueryOptions) (*KVPair, *QueryMeta, error)

+ func (k *KV) Keys(prefix, separator string, q *QueryOptions) ([]string, *QueryMeta, error)

+ func (k *KV) List(prefix string, q *QueryOptions) (KVPairs, *QueryMeta, error)

+ func (k *KV) Put(p *KVPair, q *WriteOptions) (*WriteMeta, error)

+ func (k *KV) Release(p *KVPair, q *WriteOptions) (bool, *WriteMeta, error)

+ type KVPair struct

+ CreateIndex uint64

+ Flags uint64

+ Key string

+ LockIndex uint64

+ ModifyIndex uint64

+ Session string

+ Value []byte

+ type KVPairs []*KVPair

+ type Lock struct

+ func (l *Lock) Destroy() error

+ func (l *Lock) Lock(stopCh <-chan struct{}) (<-chan struct{}, error)

+ func (l *Lock) Unlock() error

+ type LockOptions struct

+ Key string

+ Session string

+ SessionName string

+ SessionTTL string

+ Value []byte

+ type Node struct

+ Address string

+ Node string

+ type QueryMeta struct

+ KnownLeader bool

+ LastContact time.Duration

+ LastIndex uint64

+ RequestTime time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ Datacenter string

+ RequireConsistent bool

+ Token string

+ WaitIndex uint64

+ WaitTime time.Duration

+ type Raw struct

+ func (raw *Raw) Query(endpoint string, out interface{}, q *QueryOptions) (*QueryMeta, error)

+ func (raw *Raw) Write(endpoint string, in, out interface{}, q *WriteOptions) (*WriteMeta, error)

+ type Semaphore struct

+ func (s *Semaphore) Acquire(stopCh <-chan struct{}) (<-chan struct{}, error)

+ func (s *Semaphore) Destroy() error

+ func (s *Semaphore) Release() error

+ type SemaphoreOptions struct

+ Limit int

+ Prefix string

+ Session string

+ SessionName string

+ SessionTTL string

+ Value []byte

+ type ServiceEntry struct

+ Checks []*HealthCheck

+ Node *Node

+ Service *AgentService

+ type Session struct

+ func (s *Session) Create(se *SessionEntry, q *WriteOptions) (string, *WriteMeta, error)

+ func (s *Session) CreateNoChecks(se *SessionEntry, q *WriteOptions) (string, *WriteMeta, error)

+ func (s *Session) Destroy(id string, q *WriteOptions) (*WriteMeta, error)

+ func (s *Session) Info(id string, q *QueryOptions) (*SessionEntry, *QueryMeta, error)

+ func (s *Session) List(q *QueryOptions) ([]*SessionEntry, *QueryMeta, error)

+ func (s *Session) Node(node string, q *QueryOptions) ([]*SessionEntry, *QueryMeta, error)

+ func (s *Session) Renew(id string, q *WriteOptions) (*SessionEntry, *WriteMeta, error)

+ func (s *Session) RenewPeriodic(initialTTL string, id string, q *WriteOptions, doneCh chan struct{}) error

+ type SessionEntry struct

+ Behavior string

+ Checks []string

+ CreateIndex uint64

+ ID string

+ LockDelay time.Duration

+ Name string

+ Node string

+ TTL string

+ type Status struct

+ func (s *Status) Leader() (string, error)

+ func (s *Status) Peers() ([]string, error)

+ type UserEvent struct

+ ID string

+ LTime uint64

+ Name string

+ NodeFilter string

+ Payload []byte

+ ServiceFilter string

+ TagFilter string

+ Version int

+ type WriteMeta struct

+ RequestTime time.Duration

+ type WriteOptions struct

+ Datacenter string

+ Token string