structs

package

Go to main page

Versions in this module

v1

v1.4.0

Nov 14, 2018

Changes in this version

+ const ACLPolicyDeleteRequestType

+ const ACLPolicyGlobalManagement

+ const ACLPolicyGlobalManagementID

+ const ACLPolicySetRequestType

+ const ACLTokenAnonymousID

+ const ACLTokenDeleteRequestType

+ const ACLTokenSetRequestType

+ const ACLTokenTypeClient

+ const ACLTokenTypeManagement

+ const ACLTokenTypeNone

+ const IndexRequestType

+ var ACLBootstrapInvalidResetIndexErr = errors.New("Invalid ACL bootstrap reset index")

+ func ACLIDReserved(id string) bool

+ func SanitizeLegacyACLToken(token *ACLToken)

+ func SanitizeLegacyACLTokenRules(rules string) string

type ACL

+ func (a *ACL) Convert() *ACLToken

+ type ACLCaches struct

+ func NewACLCaches(config *ACLCachesConfig) (*ACLCaches, error)

+ func (c *ACLCaches) GetAuthorizer(id string) *AuthorizerCacheEntry

+ func (c *ACLCaches) GetIdentity(id string) *IdentityCacheEntry

+ func (c *ACLCaches) GetParsedPolicy(id string) *ParsedPolicyCacheEntry

+ func (c *ACLCaches) GetPolicy(policyID string) *PolicyCacheEntry

+ func (c *ACLCaches) Purge()

+ func (c *ACLCaches) PutAuthorizer(id string, authorizer acl.Authorizer)

+ func (c *ACLCaches) PutAuthorizerWithTTL(id string, authorizer acl.Authorizer, ttl time.Duration)

+ func (c *ACLCaches) PutIdentity(id string, ident ACLIdentity)

+ func (c *ACLCaches) PutParsedPolicy(id string, policy *acl.Policy)

+ func (c *ACLCaches) PutPolicy(policyId string, policy *ACLPolicy)

+ func (c *ACLCaches) RemoveIdentity(id string)

+ func (c *ACLCaches) RemovePolicy(policyID string)

+ type ACLCachesConfig struct

+ Authorizers int

+ Identities int

+ ParsedPolicies int

+ Policies int

+ type ACLIdentity interface

+ EmbeddedPolicy func() *ACLPolicy

+ ID func() string

+ PolicyIDs func() []string

+ SecretToken func() string

+ type ACLMode string

+ const ACLModeDisabled

+ const ACLModeEnabled

+ const ACLModeLegacy

+ const ACLModeUnknown

+ type ACLPolicies []*ACLPolicy

+ func (policies ACLPolicies) Compile(parent acl.Authorizer, cache *ACLCaches, sentinel sentinel.Evaluator) (acl.Authorizer, error)

+ func (policies ACLPolicies) HashKey() string

+ func (policies ACLPolicies) Merge(cache *ACLCaches, sentinel sentinel.Evaluator) (*acl.Policy, error)

+ func (policies ACLPolicies) Sort()

type ACLPolicy

+ Datacenters []string

+ Description string

+ Hash []byte

+ ID string

+ Name string

+ Rules string

+ Syntax acl.SyntaxVersion

+ func (p *ACLPolicy) EstimateSize() int

+ func (p *ACLPolicy) SetHash(force bool) []byte

+ func (p *ACLPolicy) Stub() *ACLPolicyListStub

+ type ACLPolicyBatchDeleteRequest struct

+ PolicyIDs []string

+ type ACLPolicyBatchGetRequest struct

+ Datacenter string

+ PolicyIDs []string

+ func (r *ACLPolicyBatchGetRequest) RequestDatacenter() string

+ type ACLPolicyBatchResponse struct

+ Policies []*ACLPolicy

+ type ACLPolicyBatchSetRequest struct

+ Policies ACLPolicies

+ type ACLPolicyDeleteRequest struct

+ Datacenter string

+ PolicyID string

+ func (r *ACLPolicyDeleteRequest) RequestDatacenter() string

+ type ACLPolicyGetRequest struct

+ Datacenter string

+ PolicyID string

+ func (r *ACLPolicyGetRequest) RequestDatacenter() string

+ type ACLPolicyIDType string

+ const ACLPolicyID

+ const ACLPolicyName

+ type ACLPolicyListRequest struct

+ Datacenter string

+ func (r *ACLPolicyListRequest) RequestDatacenter() string

+ type ACLPolicyListResponse struct

+ Policies ACLPolicyListStubs

+ type ACLPolicyListStub struct

+ CreateIndex uint64

+ Datacenters []string

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ Name string

+ type ACLPolicyListStubs []*ACLPolicyListStub

+ func (policies ACLPolicyListStubs) Sort()

+ type ACLPolicyResolveLegacyRequest struct

+ ACL string

+ Datacenter string

+ ETag string

+ func (r *ACLPolicyResolveLegacyRequest) RequestDatacenter() string

+ type ACLPolicyResolveLegacyResponse struct

+ ETag string

+ Parent string

+ Policy *acl.Policy

+ TTL time.Duration

+ type ACLPolicyResponse struct

+ Policy *ACLPolicy

+ type ACLPolicySetRequest struct

+ Datacenter string

+ Policy ACLPolicy

+ func (r *ACLPolicySetRequest) RequestDatacenter() string

type ACLReplicationStatus

+ ReplicatedTokenIndex uint64

+ ReplicationType ACLReplicationType

+ type ACLReplicationType string

+ const ACLReplicateLegacy

+ const ACLReplicatePolicies

+ const ACLReplicateTokens

+ type ACLToken struct

+ AccessorID string

+ CreateTime time.Time

+ Description string

+ Hash []byte

+ Local bool

+ Policies []ACLTokenPolicyLink

+ Rules string

+ SecretID string

+ Type string

+ func (t *ACLToken) EmbeddedPolicy() *ACLPolicy

+ func (t *ACLToken) EstimateSize() int

+ func (t *ACLToken) ID() string

+ func (t *ACLToken) PolicyIDs() []string

+ func (t *ACLToken) SecretToken() string

+ func (t *ACLToken) SetHash(force bool) []byte

+ func (tok *ACLToken) Convert() (*ACL, error)

+ func (token *ACLToken) Stub() *ACLTokenListStub

+ type ACLTokenBatchDeleteRequest struct

+ TokenIDs []string

+ type ACLTokenBatchGetRequest struct

+ AccessorIDs []string

+ Datacenter string

+ func (r *ACLTokenBatchGetRequest) RequestDatacenter() string

+ type ACLTokenBatchResponse struct

+ Tokens []*ACLToken

+ type ACLTokenBatchSetRequest struct

+ CAS bool

+ Tokens ACLTokens

+ type ACLTokenBootstrapRequest struct

+ ResetIndex uint64

+ Token ACLToken

+ type ACLTokenDeleteRequest struct

+ Datacenter string

+ TokenID string

+ func (r *ACLTokenDeleteRequest) RequestDatacenter() string

+ type ACLTokenGetRequest struct

+ Datacenter string

+ TokenID string

+ TokenIDType ACLTokenIDType

+ func (r *ACLTokenGetRequest) RequestDatacenter() string

+ type ACLTokenIDType string

+ const ACLTokenAccessor

+ const ACLTokenSecret

+ type ACLTokenListRequest struct

+ Datacenter string

+ IncludeGlobal bool

+ IncludeLocal bool

+ Policy string

+ func (r *ACLTokenListRequest) RequestDatacenter() string

+ type ACLTokenListResponse struct

+ Tokens ACLTokenListStubs

+ type ACLTokenListStub struct

+ AccessorID string

+ CreateIndex uint64

+ CreateTime time.Time

+ Description string

+ Hash []byte

+ Legacy bool

+ Local bool

+ ModifyIndex uint64

+ Policies []ACLTokenPolicyLink

+ type ACLTokenListStubs []*ACLTokenListStub

+ func (tokens ACLTokenListStubs) Sort()

+ type ACLTokenPolicyLink struct

+ ID string

+ Name string

+ type ACLTokenResponse struct

+ Token *ACLToken

+ type ACLTokenSetRequest struct

+ ACLToken ACLToken

+ Datacenter string

+ func (r *ACLTokenSetRequest) RequestDatacenter() string

+ type ACLTokens []*ACLToken

+ func (tokens ACLTokens) Sort()

+ type AuthorizerCacheEntry struct

+ Authorizer acl.Authorizer

+ CacheTime time.Time

+ TTL time.Duration

+ func (e *AuthorizerCacheEntry) Age() time.Duration

type CARoot

+ ExternalTrustDomain string

+ type IdentityCacheEntry struct

+ CacheTime time.Time

+ Identity ACLIdentity

+ func (e *IdentityCacheEntry) Age() time.Duration

type Intention

+ func (x *Intention) EstimateSize() int

+ type ParsedPolicyCacheEntry struct

+ CacheTime time.Time

+ Policy *acl.Policy

+ func (e *ParsedPolicyCacheEntry) Age() time.Duration

+ type PolicyCacheEntry struct

+ CacheTime time.Time

+ Policy *ACLPolicy

+ func (e *PolicyCacheEntry) Age() time.Duration

type QueryOptions

+ func (q QueryOptions) TokenSecret() string

type RPCInfo

+ TokenSecret func() string

+ type TxnIntentionOp IntentionRequest

type TxnOp

+ Intention *TxnIntentionOp

type TxnResponse

+ func (r TxnResponse) Error() error

type WriteRequest

+ func (w WriteRequest) TokenSecret() string

v1.4.0-rc1

Oct 19, 2018

v1.3.1

Nov 13, 2018

v1.3.0

Oct 11, 2018

Changes in this version

+ const UpstreamDestTypePreparedQuery

+ const UpstreamDestTypeService

type CAConsulProviderState

+ IntermediateCert string

type ConnectManagedProxy

+ Upstreams Upstreams

type ConnectManagedProxyConfig

+ LocalServiceAddress string

+ LocalServicePort int

+ type ConnectProxyConfig struct

+ Config map[string]interface{}

+ DestinationServiceID string

+ DestinationServiceName string

+ LocalServiceAddress string

+ LocalServicePort int

+ Upstreams Upstreams

+ func TestConnectProxyConfig(t testing.T) ConnectProxyConfig

+ func (c *ConnectProxyConfig) ToAPI() *api.AgentServiceConnectProxyConfig

type Node

+ func (n *Node) IsSame(other *Node) bool

type NodeService

+ LocallyRegisteredAsSidecar bool

+ Proxy ConnectProxyConfig

+ func TestNodeServiceSidecar(t testing.T) *NodeService

type PreparedQueryExecuteRequest

+ func (q *PreparedQueryExecuteRequest) CacheInfo() cache.RequestInfo

type QueryOptions

+ MaxAge time.Duration

+ MustRevalidate bool

+ StaleIfError time.Duration

+ UseCache bool

type ServiceConnect

+ SidecarService *ServiceDefinition

type ServiceDefinition

+ Proxy *ConnectProxyConfig

type ServiceDefinitionConnectProxy

+ Upstreams []Upstream

type ServiceNode

+ ServiceProxy ConnectProxyConfig

+ func (s *ServiceNode) IsSameService(other *ServiceNode) bool

type ServiceSpecificRequest

+ ServiceTags []string

+ func (r *ServiceSpecificRequest) CacheInfo() cache.RequestInfo

+ func (r *ServiceSpecificRequest) CacheMinIndex() uint64

+ type Upstream struct

+ Config map[string]interface{}

+ Datacenter string

+ DestinationName string

+ DestinationNamespace string

+ DestinationType string

+ LocalBindAddress string

+ LocalBindPort int

+ func UpstreamFromAPI(u api.Upstream) Upstream

+ func (u *Upstream) Identifier() string

+ func (u *Upstream) String() string

+ func (u *Upstream) ToAPI() api.Upstream

+ func (u *Upstream) Validate() error

+ type Upstreams []Upstream

+ func TestAddDefaultsToUpstreams(t testing.T, upstreams []Upstream) Upstreams

+ func TestUpstreams(t testing.T) Upstreams

+ func UpstreamsFromAPI(us []api.Upstream) Upstreams

+ func (us Upstreams) ToAPI() []api.Upstream

v1.2.4

Nov 21, 2018

v1.2.3

Sep 13, 2018

Changes in this version

+ const ConnectCAConfigType

+ func ParseDurationFunc() mapstructure.DecodeHookFunc

+ func Uint8ToString(bs []uint8) string

+ func ValidateWeights(weights *Weights) error

type NodeService

+ Weights *Weights

type ServiceDefinition

+ Weights *Weights

type ServiceNode

+ ServiceWeights Weights

+ type Weights struct

+ Passing int

+ Warning int

v1.2.2

Jul 30, 2018

Changes in this version

type CAConfiguration

+ func (c *CAConfiguration) GetCommonConfig() (*CommonCAProviderConfig, error)

type CheckDefinition

+ AliasNode string

+ AliasService string

type CheckType

+ AliasNode string

+ AliasService string

+ func (c *CheckType) IsAlias() bool

+ type CommonCAProviderConfig struct

+ LeafCertTTL time.Duration

+ SkipValidate bool

+ func (c CommonCAProviderConfig) Validate() error

v1.2.1

Jul 12, 2018

Changes in this version

+ const ConnectCAProviderStateType

type CARoot

+ RotatedOutAt time.Time

v1.2.0

Jun 25, 2018

Changes in this version

+ const ConnectCARequestType

+ const ConsulCAProvider

+ const IntentionDefaultNamespace

+ const IntentionRequestType

+ const IntentionWildcard

+ const VaultCAProvider

+ type CAConfiguration struct

+ ClusterID string

+ Config map[string]interface{}

+ Provider string

+ type CAConsulProviderState struct

+ ID string

+ PrivateKey string

+ RootCert string

+ type CAOp string

+ const CAOpDeleteProviderState

+ const CAOpSetConfig

+ const CAOpSetProviderState

+ const CAOpSetRoots

+ const CAOpSetRootsAndConfig

+ type CARequest struct

+ Config *CAConfiguration

+ Datacenter string

+ Index uint64

+ Op CAOp

+ ProviderState *CAConsulProviderState

+ Roots []*CARoot

+ func (q *CARequest) RequestDatacenter() string

+ type CARoot struct

+ Active bool

+ ID string

+ IntermediateCerts []string

+ Name string

+ NotAfter time.Time

+ NotBefore time.Time

+ RootCert string

+ SerialNumber uint64

+ SigningCert string

+ SigningKey string

+ SigningKeyID string

+ type CARoots []*CARoot

+ type CASignRequest struct

+ CSR string

+ Datacenter string

+ func (q *CASignRequest) RequestDatacenter() string

+ type ConnectAuthorizeRequest struct

+ ClientCertSerial string

+ ClientCertURI string

+ Target string

+ type ConnectManagedProxy struct

+ Command []string

+ Config map[string]interface{}

+ ExecMode ProxyExecMode

+ ProxyService *NodeService

+ TargetServiceID string

+ func (p *ConnectManagedProxy) ParseConfig() (*ConnectManagedProxyConfig, error)

+ type ConnectManagedProxyConfig struct

+ BindAddress string

+ BindPort int

+ type ConsulCAProviderConfig struct

+ PrivateKey string

+ RootCert string

+ RotationPeriod time.Duration

type DCSpecificRequest

+ func (r *DCSpecificRequest) CacheInfo() cache.RequestInfo

+ func (r *DCSpecificRequest) CacheMinIndex() uint64

+ type IndexedCARoots struct

+ ActiveRootID string

+ Roots []*CARoot

+ TrustDomain string

+ type IndexedIntentionMatches struct

+ Matches []Intentions

+ type IndexedIntentions struct

+ Intentions Intentions

+ type Intention struct

+ Action IntentionAction

+ CreatedAt time.Time

+ DefaultAddr string

+ DefaultPort int

+ Description string

+ DestinationNS string

+ DestinationName string

+ ID string

+ Meta map[string]string

+ Precedence int

+ SourceNS string

+ SourceName string

+ SourceType IntentionSourceType

+ UpdatedAt time.Time

+ func TestIntention(t testing.T) *Intention

+ func (x *Intention) GetACLPrefix() (string, bool)

+ func (x *Intention) String() string

+ func (x *Intention) UpdatePrecedence()

+ func (x *Intention) Validate() error

+ type IntentionAction string

+ const IntentionActionAllow

+ const IntentionActionDeny

+ type IntentionMatchEntry struct

+ Name string

+ Namespace string

+ type IntentionMatchType string

+ const IntentionMatchDestination

+ const IntentionMatchSource

+ type IntentionOp string

+ const IntentionOpCreate

+ const IntentionOpDelete

+ const IntentionOpUpdate

+ type IntentionPrecedenceSorter Intentions

+ func (s IntentionPrecedenceSorter) Len() int

+ func (s IntentionPrecedenceSorter) Less(i, j int) bool

+ func (s IntentionPrecedenceSorter) Swap(i, j int)

+ type IntentionQueryCheck struct

+ DestinationNS string

+ DestinationName string

+ SourceNS string

+ SourceName string

+ SourceType IntentionSourceType

+ func (q *IntentionQueryCheck) GetACLPrefix() (string, bool)

+ type IntentionQueryCheckResponse struct

+ Allowed bool

+ type IntentionQueryMatch struct

+ Entries []IntentionMatchEntry

+ Type IntentionMatchType

+ type IntentionQueryRequest struct

+ Check *IntentionQueryCheck

+ Datacenter string

+ IntentionID string

+ Match *IntentionQueryMatch

+ func (q *IntentionQueryRequest) CacheInfo() cache.RequestInfo

+ func (q *IntentionQueryRequest) RequestDatacenter() string

+ type IntentionRequest struct

+ Datacenter string

+ Intention *Intention

+ Op IntentionOp

+ func (q *IntentionRequest) RequestDatacenter() string

+ type IntentionSourceType string

+ const IntentionSourceConsul

+ type Intentions []*Intention

+ type IssuedCert struct

+ CertPEM string

+ PrivateKeyPEM string

+ SerialNumber string

+ Service string

+ ServiceURI string

+ ValidAfter time.Time

+ ValidBefore time.Time

type NodeService

+ Connect ServiceConnect

+ Kind ServiceKind

+ ProxyDestination string

+ func TestNodeService(t testing.T) *NodeService

+ func TestNodeServiceProxy(t testing.T) *NodeService

+ func (s *NodeService) Validate() error

type PreparedQueryExecuteRemoteRequest

+ Connect bool

type PreparedQueryExecuteRequest

+ Connect bool

+ type ProxyExecMode int

+ const ProxyExecModeDaemon

+ const ProxyExecModeScript

+ const ProxyExecModeTest

+ const ProxyExecModeUnspecified

+ func NewProxyExecMode(raw string) (ProxyExecMode, error)

+ func (m ProxyExecMode) String() string

type RegisterRequest

+ func TestRegisterRequest(t testing.T) *RegisterRequest

+ func TestRegisterRequestProxy(t testing.T) *RegisterRequest

+ type ServiceConnect struct

+ Native bool

+ Proxy *ServiceDefinitionConnectProxy

type ServiceDefinition

+ Connect *ServiceConnect

+ Kind ServiceKind

+ ProxyDestination string

+ func TestServiceDefinition(t testing.T) *ServiceDefinition

+ func TestServiceDefinitionProxy(t testing.T) *ServiceDefinition

+ func (s *ServiceDefinition) ConnectManagedProxy() (*ConnectManagedProxy, error)

+ func (s *ServiceDefinition) Validate() error

+ type ServiceDefinitionConnectProxy struct

+ Command []string

+ Config map[string]interface{}

+ ExecMode string

+ func (p *ServiceDefinitionConnectProxy) MarshalJSON() ([]byte, error)

+ type ServiceKind string

+ const ServiceKindConnectProxy

+ const ServiceKindTypical

type ServiceNode

+ ServiceConnect ServiceConnect

+ ServiceKind ServiceKind

+ ServiceProxyDestination string

type ServiceQuery

+ Connect bool

type ServiceSpecificRequest

+ Connect bool

+ ServiceAddress string

+ type VaultCAProviderConfig struct

+ Address string

+ IntermediatePKIPath string

+ RootPKIPath string

+ Token string

v1.1.1

Nov 21, 2018

v1.1.0

May 11, 2018

v1.0.8

Nov 21, 2018

v1.0.7

Apr 13, 2018

Changes in this version

type CheckServiceNodes

+ func (nodes CheckServiceNodes) FilterIgnore(onlyPassing bool, ignoreCheckIDs []types.CheckID) CheckServiceNodes

type NodeService

+ Meta map[string]string

type QueryMeta

+ ConsistencyLevel string

type QueryOptions

+ MaxStaleDuration time.Duration

+ func (q QueryOptions) ConsistencyLevel() string

type QuerySource

+ Ip string

type ServiceDefinition

+ Meta map[string]string

type ServiceNode

+ ServiceMeta map[string]string

type ServiceQuery

+ IgnoreCheckIDs []types.CheckID

v1.0.6

Feb 9, 2018

v1.0.5

Feb 7, 2018

v1.0.4

Feb 6, 2018

Changes in this version

type CheckDefinition

+ GRPC string

+ GRPCUseTLS bool

type CheckType

+ GRPC string

+ GRPCUseTLS bool

+ func (c *CheckType) IsGRPC() bool

v1.0.3

Jan 24, 2018

v1.0.2

Dec 15, 2017

v1.0.1

Nov 20, 2017

Changes in this version

type HealthCheck

+ Definition HealthCheckDefinition

+ type HealthCheckDefinition struct

+ DeregisterCriticalServiceAfter api.ReadableDuration

+ HTTP string

+ Header map[string][]string

+ Interval api.ReadableDuration

+ Method string

+ TCP string

+ TLSSkipVerify bool

+ Timeout api.ReadableDuration

v1.0.1-rc1

Nov 11, 2017

v1.0.0

Oct 16, 2017

Changes in this version

+ func IsErrNoLeader(err error) bool

type CheckDefinition

+ ScriptArgs []string

type CheckType

+ ScriptArgs []string

+ func (c *CheckType) Empty() bool

+ func (c *CheckType) Validate() error

+ type NetworkSegment struct

+ Advertise *net.TCPAddr

+ Bind *net.TCPAddr

+ Name string

+ RPCListener bool

type RaftServer

+ ProtocolVersion string

v1.0.0-beta2

Oct 5, 2017

v1.0.0-beta1

Sep 28, 2017

v0

v0.9.4

Nov 20, 2018

v0.9.3

Sep 8, 2017

Changes in this version

+ const MetaSegmentKey

+ var ErrRPCRateExceeded = errors.New(errRPCRateExceeded)

+ var ErrSegmentsNotSupported = errors.New(errSegmentsNotSupported)

+ func IsErrRPCRateExceeded(err error) bool

type Coordinate

+ Segment string

type CoordinateUpdateRequest

+ Segment string

type KeyringResponse

+ Segment string

type QuerySource

+ Segment string

v0.9.3-rc2

Sep 6, 2017

v0.9.3-rc1

Sep 5, 2017

v0.9.2

Aug 10, 2017

Changes in this version

+ const ACLBootstrapInit

+ const ACLBootstrapNow

+ const ACLBootstrapRequestType

+ const ACLDelete

+ const ACLForceSet

+ const ACLRequestType

+ const ACLSet

+ const ACLTypeClient

+ const ACLTypeManagement

+ const AreaRequestType

+ const AutopilotRequestType

+ const ConsulServiceID

+ const ConsulServiceName

+ const CoordinateBatchUpdateType

+ const DeregisterRequestType

+ const IgnoreUnknownTypeFlag

+ const KVSRequestType

+ const KeyringInstall

+ const KeyringList

+ const KeyringRemove

+ const KeyringUse

+ const MaxLockDelay

+ const NodeMaint

+ const PreparedQueryRequestType

+ const QueryTemplateTypeNamePrefixMatch

+ const RegisterRequestType

+ const SerfCheckAliveOutput

+ const SerfCheckFailedOutput

+ const SerfCheckID

+ const SerfCheckName

+ const ServiceMaintPrefix

+ const SessionRequestType

+ const SessionTTLMax

+ const SessionTTLMultiplier

+ const TombstoneRequestType

+ const TxnRequestType

+ var ACLBootstrapNotAllowedErr = errors.New("ACL bootstrap no longer allowed")

+ var ACLBootstrapNotInitializedErr = errors.New(...)

+ var ErrNoDCPath = fmt.Errorf("No path to datacenter")

+ var ErrNoLeader = fmt.Errorf("No cluster leader")

+ var ErrNoServers = fmt.Errorf("No known Consul servers")

+ var ErrNotReadyForConsistentReads = fmt.Errorf("Not ready to serve consistent reads")

+ func Decode(buf []byte, out interface{}) error

+ func Encode(t MessageType, msg interface{}) ([]byte, error)

+ func SatisfiesMetaFilters(meta map[string]string, filters map[string]string) bool

+ func ValidStatus(s string) bool

+ func ValidateMetadata(meta map[string]string) error

+ type ACL struct

+ ID string

+ Name string

+ Rules string

+ Type string

+ func (a *ACL) IsSame(other *ACL) bool

+ type ACLBootstrap struct

+ AllowBootstrap bool

+ type ACLOp string

+ type ACLPolicy struct

+ ETag string

+ Parent string

+ Policy *acl.Policy

+ TTL time.Duration

+ type ACLPolicyRequest struct

+ ACL string

+ Datacenter string

+ ETag string

+ func (r *ACLPolicyRequest) RequestDatacenter() string

+ type ACLReplicationStatus struct

+ Enabled bool

+ LastError time.Time

+ LastSuccess time.Time

+ ReplicatedIndex uint64

+ Running bool

+ SourceDatacenter string

+ type ACLRequest struct

+ ACL ACL

+ Datacenter string

+ Op ACLOp

+ func (r *ACLRequest) RequestDatacenter() string

+ type ACLRequests []*ACLRequest

+ type ACLSpecificRequest struct

+ ACL string

+ Datacenter string

+ func (r *ACLSpecificRequest) RequestDatacenter() string

+ type ACLs []*ACL

+ type AutopilotConfig struct

+ CleanupDeadServers bool

+ DisableUpgradeMigration bool

+ LastContactThreshold time.Duration

+ MaxTrailingLogs uint64

+ RedundancyZoneTag string

+ ServerStabilizationTime time.Duration

+ UpgradeVersionTag string

+ type AutopilotSetConfigRequest struct

+ CAS bool

+ Config AutopilotConfig

+ Datacenter string

+ func (op *AutopilotSetConfigRequest) RequestDatacenter() string

+ type CheckDefinition struct

+ DeregisterCriticalServiceAfter time.Duration

+ DockerContainerID string

+ HTTP string

+ Header map[string][]string

+ ID types.CheckID

+ Interval time.Duration

+ Method string

+ Name string

+ Notes string

+ Script string

+ ServiceID string

+ Shell string

+ Status string

+ TCP string

+ TLSSkipVerify bool

+ TTL time.Duration

+ Timeout time.Duration

+ Token string

+ func (c *CheckDefinition) CheckType() *CheckType

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

+ type CheckServiceNode struct

+ Checks HealthChecks

+ Node *Node

+ Service *NodeService

+ type CheckServiceNodes []CheckServiceNode

+ func (nodes CheckServiceNodes) Filter(onlyPassing bool) CheckServiceNodes

+ func (nodes CheckServiceNodes) Shuffle()

+ type CheckType struct

+ CheckID types.CheckID

+ DeregisterCriticalServiceAfter time.Duration

+ DockerContainerID string

+ HTTP string

+ Header map[string][]string

+ Interval time.Duration

+ Method string

+ Name string

+ Notes string

+ Script string

+ Shell string

+ Status string

+ TCP string

+ TLSSkipVerify bool

+ TTL time.Duration

+ Timeout time.Duration

+ func (c *CheckType) IsDocker() bool

+ func (c *CheckType) IsHTTP() bool

+ func (c *CheckType) IsMonitor() bool

+ func (c *CheckType) IsScript() bool

+ func (c *CheckType) IsTCP() bool

+ func (c *CheckType) IsTTL() bool

+ func (c *CheckType) Valid() bool

+ type CheckTypes []*CheckType

+ type ChecksInStateRequest struct

+ Datacenter string

+ NodeMetaFilters map[string]string

+ Source QuerySource

+ State string

+ func (r *ChecksInStateRequest) RequestDatacenter() string

+ type CompoundResponse interface

+ Add func(interface{})

+ New func() interface{}

+ type Coordinate struct

+ Coord *coordinate.Coordinate

+ Node string

+ type CoordinateUpdateRequest struct

+ Coord *coordinate.Coordinate

+ Datacenter string

+ Node string

+ func (c *CoordinateUpdateRequest) RequestDatacenter() string

+ type Coordinates []*Coordinate

+ type DCSpecificRequest struct

+ Datacenter string

+ NodeMetaFilters map[string]string

+ Source QuerySource

+ func (r *DCSpecificRequest) RequestDatacenter() string

+ type DatacenterMap struct

+ AreaID types.AreaID

+ Coordinates Coordinates

+ Datacenter string

+ type DeregisterRequest struct

+ CheckID types.CheckID

+ Datacenter string

+ Node string

+ ServiceID string

+ func (r *DeregisterRequest) RequestDatacenter() string

+ type DirEntries []*DirEntry

+ type DirEntry struct

+ Flags uint64

+ Key string

+ LockIndex uint64

+ Session string

+ Value []byte

+ func (d *DirEntry) Clone() *DirEntry

+ type EventFireRequest struct

+ Datacenter string

+ Name string

+ Payload []byte

+ func (r *EventFireRequest) RequestDatacenter() string

+ type EventFireResponse struct

+ type HealthCheck struct

+ CheckID types.CheckID

+ Name string

+ Node string

+ Notes string

+ Output string

+ ServiceID string

+ ServiceName string

+ ServiceTags []string

+ Status string

+ func (c *HealthCheck) Clone() *HealthCheck

+ func (c *HealthCheck) IsSame(other *HealthCheck) bool

+ type HealthChecks []*HealthCheck

+ type IndexedACLs struct

+ ACLs ACLs

+ type IndexedCheckServiceNodes struct

+ Nodes CheckServiceNodes

+ type IndexedCoordinate struct

+ Coord *coordinate.Coordinate

+ type IndexedCoordinates struct

+ Coordinates Coordinates

+ type IndexedDirEntries struct

+ Entries DirEntries

+ type IndexedHealthChecks struct

+ HealthChecks HealthChecks

+ type IndexedKeyList struct

+ Keys []string

+ type IndexedNodeDump struct

+ Dump NodeDump

+ type IndexedNodeServices struct

+ NodeServices *NodeServices

+ type IndexedNodes struct

+ Nodes Nodes

+ type IndexedPreparedQueries struct

+ Queries PreparedQueries

+ type IndexedServiceNodes struct

+ ServiceNodes ServiceNodes

+ type IndexedServices struct

+ Services Services

+ type IndexedSessions struct

+ Sessions Sessions

+ type KVSRequest struct

+ Datacenter string

+ DirEnt DirEntry

+ Op api.KVOp

+ func (r *KVSRequest) RequestDatacenter() string

+ type KeyListRequest struct

+ Datacenter string

+ Prefix string

+ Seperator string

+ func (r *KeyListRequest) RequestDatacenter() string

+ type KeyRequest struct

+ Datacenter string

+ Key string

+ func (r *KeyRequest) RequestDatacenter() string

+ type KeyringOp string

+ type KeyringRequest struct

+ Datacenter string

+ Forwarded bool

+ Key string

+ Operation KeyringOp

+ RelayFactor uint8

+ func (r *KeyringRequest) RequestDatacenter() string

+ type KeyringResponse struct

+ Datacenter string

+ Error string

+ Keys map[string]int

+ Messages map[string]string

+ NumNodes int

+ WAN bool

+ type KeyringResponses struct

+ Responses []*KeyringResponse

+ func (r *KeyringResponses) Add(v interface{})

+ func (r *KeyringResponses) New() interface{}

+ type MessageType uint8

+ type Node struct

+ Address string

+ Datacenter string

+ ID types.NodeID

+ Meta map[string]string

+ Node string

+ TaggedAddresses map[string]string

+ type NodeDump []*NodeInfo

+ type NodeInfo struct

+ Address string

+ Checks HealthChecks

+ ID types.NodeID

+ Meta map[string]string

+ Node string

+ Services []*NodeService

+ TaggedAddresses map[string]string

+ type NodeService struct

+ Address string

+ EnableTagOverride bool

+ ID string

+ Port int

+ Service string

+ Tags []string

+ func (s *NodeService) IsSame(other *NodeService) bool

+ func (s *NodeService) ToServiceNode(node string) *ServiceNode

+ type NodeServices struct

+ Node *Node

+ Services map[string]*NodeService

+ type NodeSpecificRequest struct

+ Datacenter string

+ Node string

+ func (r *NodeSpecificRequest) RequestDatacenter() string

+ type Nodes []*Node

+ type OperatorHealthReply struct

+ FailureTolerance int

+ Healthy bool

+ Servers []ServerHealth

+ type PreparedQueries []*PreparedQuery

+ type PreparedQuery struct

+ DNS QueryDNSOptions

+ ID string

+ Name string

+ Service ServiceQuery

+ Session string

+ Template QueryTemplateOptions

+ Token string

+ func (pq *PreparedQuery) GetACLPrefix() (string, bool)

+ type PreparedQueryExecuteRemoteRequest struct

+ Datacenter string

+ Limit int

+ Query PreparedQuery

+ func (q *PreparedQueryExecuteRemoteRequest) RequestDatacenter() string

+ type PreparedQueryExecuteRequest struct

+ Agent QuerySource

+ Datacenter string

+ Limit int

+ QueryIDOrName string

+ Source QuerySource

+ func (q *PreparedQueryExecuteRequest) RequestDatacenter() string

+ type PreparedQueryExecuteResponse struct

+ DNS QueryDNSOptions

+ Datacenter string

+ Failovers int

+ Nodes CheckServiceNodes

+ Service string

+ type PreparedQueryExplainResponse struct

+ Query PreparedQuery

+ type PreparedQueryOp string

+ const PreparedQueryCreate

+ const PreparedQueryDelete

+ const PreparedQueryUpdate

+ type PreparedQueryRequest struct

+ Datacenter string

+ Op PreparedQueryOp

+ Query *PreparedQuery

+ func (q *PreparedQueryRequest) RequestDatacenter() string

+ type PreparedQuerySpecificRequest struct

+ Datacenter string

+ QueryID string

+ func (q *PreparedQuerySpecificRequest) RequestDatacenter() string

+ type QueryDNSOptions struct

+ TTL string

+ type QueryDatacenterOptions struct

+ Datacenters []string

+ NearestN int

+ type QueryMeta struct

+ Index uint64

+ KnownLeader bool

+ LastContact time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ MaxQueryTime time.Duration

+ MinQueryIndex uint64

+ RequireConsistent bool

+ Token string

+ func (q QueryOptions) ACLToken() string

+ func (q QueryOptions) AllowStaleRead() bool

+ func (q QueryOptions) IsRead() bool

+ type QuerySource struct

+ Datacenter string

+ Node string

+ type QueryTemplateOptions struct

+ Regexp string

+ RemoveEmptyTags bool

+ Type string

+ type RPCInfo interface

+ ACLToken func() string

+ AllowStaleRead func() bool

+ IsRead func() bool

+ RequestDatacenter func() string

+ type RaftConfigurationResponse struct

+ Index uint64

+ Servers []*RaftServer

+ type RaftIndex struct

+ CreateIndex uint64

+ ModifyIndex uint64

+ type RaftRemovePeerRequest struct

+ Address raft.ServerAddress

+ Datacenter string

+ ID raft.ServerID

+ func (op *RaftRemovePeerRequest) RequestDatacenter() string

+ type RaftServer struct

+ Address raft.ServerAddress

+ ID raft.ServerID

+ Leader bool

+ Node string

+ Voter bool

+ type RegisterRequest struct

+ Address string

+ Check *HealthCheck

+ Checks HealthChecks

+ Datacenter string

+ ID types.NodeID

+ Node string

+ NodeMeta map[string]string

+ Service *NodeService

+ SkipNodeUpdate bool

+ TaggedAddresses map[string]string

+ func (r *RegisterRequest) ChangesNode(node *Node) bool

+ func (r *RegisterRequest) RequestDatacenter() string

+ type ServerHealth struct

+ Address string

+ Healthy bool

+ ID string

+ LastContact time.Duration

+ LastIndex uint64

+ LastTerm uint64

+ Leader bool

+ Name string

+ SerfStatus serf.MemberStatus

+ StableSince time.Time

+ Version string

+ Voter bool

+ func (h *ServerHealth) IsHealthy(lastTerm uint64, leaderLastIndex uint64, autopilotConf *AutopilotConfig) bool

+ func (h *ServerHealth) IsStable(now time.Time, conf *AutopilotConfig) bool

+ type ServerStats struct

+ LastContact string

+ LastIndex uint64

+ LastTerm uint64

+ type ServiceDefinition struct

+ Address string

+ Check CheckType

+ Checks CheckTypes

+ EnableTagOverride bool

+ ID string

+ Name string

+ Port int

+ Tags []string

+ Token string

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

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

+ type ServiceNode struct

+ Address string

+ Datacenter string

+ ID types.NodeID

+ Node string

+ NodeMeta map[string]string

+ ServiceAddress string

+ ServiceEnableTagOverride bool

+ ServiceID string

+ ServiceName string

+ ServicePort int

+ ServiceTags []string

+ TaggedAddresses map[string]string

+ func (s *ServiceNode) PartialClone() *ServiceNode

+ func (s *ServiceNode) ToNodeService() *NodeService

+ type ServiceNodes []*ServiceNode

+ type ServiceQuery struct

+ Failover QueryDatacenterOptions

+ Near string

+ NodeMeta map[string]string

+ OnlyPassing bool

+ Service string

+ Tags []string

+ type ServiceSpecificRequest struct

+ Datacenter string

+ NodeMetaFilters map[string]string

+ ServiceName string

+ ServiceTag string

+ Source QuerySource

+ TagFilter bool

+ func (r *ServiceSpecificRequest) RequestDatacenter() string

+ type Services map[string][]string

+ type Session struct

+ Behavior SessionBehavior

+ Checks []types.CheckID

+ ID string

+ LockDelay time.Duration

+ Name string

+ Node string

+ TTL string

+ type SessionBehavior string

+ const SessionKeysDelete

+ const SessionKeysRelease

+ type SessionOp string

+ const SessionCreate

+ const SessionDestroy

+ type SessionRequest struct

+ Datacenter string

+ Op SessionOp

+ Session Session

+ func (r *SessionRequest) RequestDatacenter() string

+ type SessionSpecificRequest struct

+ Datacenter string

+ Session string

+ func (r *SessionSpecificRequest) RequestDatacenter() string

+ type Sessions []*Session

+ type SnapshotOp int

+ const SnapshotRestore

+ const SnapshotSave

+ type SnapshotReplyFn func(reply *SnapshotResponse) error

+ type SnapshotRequest struct

+ AllowStale bool

+ Datacenter string

+ Op SnapshotOp

+ Token string

+ type SnapshotResponse struct

+ Error string

+ type TombstoneOp string

+ const TombstoneReap

+ type TombstoneRequest struct

+ Datacenter string

+ Op TombstoneOp

+ ReapIndex uint64

+ func (r *TombstoneRequest) RequestDatacenter() string

+ type TxnError struct

+ OpIndex int

+ What string

+ func (e TxnError) Error() string

+ type TxnErrors []*TxnError

+ type TxnKVOp struct

+ DirEnt DirEntry

+ Verb api.KVOp

+ type TxnKVResult *DirEntry

+ type TxnOp struct

+ KV *TxnKVOp

+ type TxnOps []*TxnOp

+ type TxnReadRequest struct

+ Datacenter string

+ Ops TxnOps

+ func (r *TxnReadRequest) RequestDatacenter() string

+ type TxnReadResponse struct

+ type TxnRequest struct

+ Datacenter string

+ Ops TxnOps

+ func (r *TxnRequest) RequestDatacenter() string

+ type TxnResponse struct

+ Errors TxnErrors

+ Results TxnResults

+ type TxnResult struct

+ KV TxnKVResult

+ type TxnResults []*TxnResult

+ type WriteRequest struct

+ Token string

+ func (w WriteRequest) ACLToken() string

+ func (w WriteRequest) AllowStaleRead() bool

+ func (w WriteRequest) IsRead() bool

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