api

Feb 6, 2024

retracted

Changes in this version

type BindingRuleBindType

+ const BindingRuleBindTypePolicy

type Client

+ func (c *Client) ExportedServices(q *QueryOptions) ([]ResolvedExportedService, *QueryMeta, error)

+ type ResolvedConsumers struct

+ Partitions []string

+ Peers []string

+ type ResolvedExportedService struct

+ Consumers ResolvedConsumers

+ Namespace string

+ Partition string

+ Service string

type ServiceRouteHTTPMatch

+ CaseInsensitive bool

Jan 18, 2024

Changes in this version

+ const ACLTemplatedPolicyAPIGatewayName

+ const ACLTemplatedPolicyNomadClientName

type ACLTemplatedPolicyResponse

+ Description string

Oct 31, 2023

Changes in this version

+ const ACLTemplatedPolicyDNSName

+ const ACLTemplatedPolicyNodeName

+ const ACLTemplatedPolicyNomadServerName

+ const ACLTemplatedPolicyServiceName

+ const ACLTemplatedPolicyWorkloadIdentityName

+ const BuiltinOTELAccessLoggingExtension

+ const GatewayListenerReasonInvalidJWTProviderRef

+ const GatewayReasonInvalidJWTProviders

+ const RouteReasonJWTProvidersNotFound

type ACL

+ func (a *ACL) TemplatedPolicyList(q *QueryOptions) (map[string]ACLTemplatedPolicyResponse, *QueryMeta, error)

+ func (a *ACL) TemplatedPolicyPreview(tp *ACLTemplatedPolicy, q *WriteOptions) (*ACLPolicy, *WriteMeta, error)

+ func (a *ACL) TemplatedPolicyReadByName(templateName string, q *QueryOptions) (*ACLTemplatedPolicyResponse, *QueryMeta, error)

type ACLBindingRule

+ BindVars *ACLTemplatedPolicyVariables

type ACLRole

+ TemplatedPolicies []*ACLTemplatedPolicy

+ type ACLTemplatedPolicy struct

+ Datacenters []string

+ TemplateName string

+ TemplateVariables *ACLTemplatedPolicyVariables

+ type ACLTemplatedPolicyResponse struct

+ Schema string

+ Template string

+ TemplateName string

+ type ACLTemplatedPolicyVariables struct

+ Name string

type ACLToken

+ TemplatedPolicies []*ACLTemplatedPolicy

type ACLTokenListEntry

+ TemplatedPolicies []*ACLTemplatedPolicy

+ type APIGatewayJWTClaimVerification struct

+ Path []string

+ Value string

+ type APIGatewayJWTProvider struct

+ Name string

+ VerifyClaims []*APIGatewayJWTClaimVerification

+ type APIGatewayJWTRequirement struct

+ Providers []*APIGatewayJWTProvider

type APIGatewayListener

+ Default *APIGatewayPolicy

+ Override *APIGatewayPolicy

+ type APIGatewayPolicy struct

+ JWT *APIGatewayJWTRequirement

type Agent

+ func (a *Agent) CheckRegisterOpts(check *AgentCheckRegistration, q *QueryOptions) error

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

type BindingRuleBindType

+ const BindingRuleBindTypeNode

+ const BindingRuleBindTypeTemplatedPolicy

type HTTPFilters

+ JWT *JWTFilter

+ RetryFilter *RetryFilter

+ TimeoutFilter *TimeoutFilter

+ type HTTPResponseFilters struct

+ Headers []HTTPHeaderFilter

type HTTPRouteRule

+ ResponseFilters HTTPResponseFilters

type HTTPService

+ ResponseFilters HTTPResponseFilters

+ type InstanceLevelRateLimits struct

+ RequestsMaxBurst int

+ RequestsPerSecond int

+ Routes []InstanceLevelRouteRateLimits

+ type InstanceLevelRouteRateLimits struct

+ PathExact string

+ PathPrefix string

+ PathRegex string

+ RequestsMaxBurst int

+ RequestsPerSecond int

+ type JWTFilter struct

+ Providers []*APIGatewayJWTProvider

+ type RateLimits struct

+ InstanceLevel InstanceLevelRateLimits

+ type RetryFilter struct

+ NumRetries uint32

+ RetryOn []string

+ RetryOnConnectFailure bool

+ RetryOnStatusCodes []uint32

type ServiceConfigEntry

+ RateLimits *RateLimits

type ServiceRegisterOpts

+ Token string

+ type TimeoutFilter struct

+ IdleTimeout time.Duration

+ RequestTimeout time.Duration

Sep 19, 2023

Changes in this version

+ type AuditHashRequest struct

+ Input string

+ type AuditHashResponse struct

+ Hash string

type Operator

+ func (op *Operator) AuditHash(a *AuditHashRequest, q *QueryOptions) (*AuditHashResponse, error)

Sep 18, 2023

Changes in this version

type AgentServiceCheck

+ TCPUseTLS bool

type HealthCheckDefinition

+ TCPUseTLS bool

Jul 20, 2023

Changes in this version

+ type ClusterDiscoveryType string

+ const DiscoveryTypeEDS

+ const DiscoveryTypeLogicalDNS

+ const DiscoveryTypeOriginalDST

+ const DiscoveryTypeStatic

+ const DiscoveryTypeStrictDNS

+ type JWKSCluster struct

+ ConnectTimeout time.Duration

+ DiscoveryType ClusterDiscoveryType

+ TLSCertificates *JWKSTLSCertificate

+ type JWKSTLSCertProviderInstance struct

+ CertificateName string

+ InstanceName string

+ type JWKSTLSCertTrustedCA struct

+ EnvironmentVariable string

+ Filename string

+ InlineBytes []byte

+ InlineString string

+ type JWKSTLSCertificate struct

+ CaCertificateProviderInstance *JWKSTLSCertProviderInstance

+ TrustedCA *JWKSTLSCertTrustedCA

type RemoteJWKS

+ JWKSCluster *JWKSCluster

type ServiceUsage

+ Nodes int

Jun 26, 2023

Changes in this version

+ const BuiltinExtAuthzExtension

+ const BuiltinLocalRatelimitExtension

+ const BuiltinPropertyOverrideExtension

+ const BuiltinWasmExtension

+ const JWTProvider

+ const RateLimitIPConfig

+ const SamenessGroup

type Agent

+ func (a *Agent) ForceLeaveOptions(node string, opts ForceLeaveOpts, q *QueryOptions) error

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

type AgentService

+ Locality *Locality

type AgentServiceRegistration

+ Locality *Locality

+ type AssignServiceManualVIPsRequest struct

+ ManualVIPs []string

+ Service string

+ type AssignServiceManualVIPsResponse struct

+ ServiceFound bool

+ UnassignedFrom []PeeredServiceName

type CatalogRegistration

+ Locality *Locality

type CatalogService

+ ServiceLocality *Locality

type Client

+ func (c *Client) Internal() *Internal

type DiscoveryFailover

+ Policy ServiceResolverFailoverPolicy

type EnvoyExtension

+ ConsulVersion string

+ EnvoyVersion string

type Intention

+ SourceSamenessGroup string

+ type IntentionJWTClaimVerification struct

+ Path []string

+ Value string

+ type IntentionJWTProvider struct

+ Name string

+ VerifyClaims []*IntentionJWTClaimVerification

+ type IntentionJWTRequirement struct

+ Providers []*IntentionJWTProvider

type IntentionPermission

+ JWT *IntentionJWTRequirement

+ type Internal struct

+ func (i *Internal) AssignServiceVirtualIP(ctx context.Context, service string, manualVIPs []string, wo *WriteOptions) (*AssignServiceManualVIPsResponse, *QueryMeta, error)

+ type JSONWebKeySet struct

+ Local *LocalJWKS

+ Remote *RemoteJWKS

+ type JWKSRetryPolicy struct

+ NumRetries int

+ RetryPolicyBackOff *RetryPolicyBackOff

+ type JWTCacheConfig struct

+ Size int

+ type JWTForwardingConfig struct

+ HeaderName string

+ PadForwardPayloadHeader bool

+ type JWTLocation struct

+ Cookie *JWTLocationCookie

+ Header *JWTLocationHeader

+ QueryParam *JWTLocationQueryParam

+ type JWTLocationCookie struct

+ Name string

+ type JWTLocationHeader struct

+ Forward bool

+ Name string

+ ValuePrefix string

+ type JWTLocationQueryParam struct

+ Name string

+ type JWTProviderConfigEntry struct

+ Audiences []string

+ CacheConfig *JWTCacheConfig

+ ClockSkewSeconds int

+ CreateIndex uint64

+ Forwarding *JWTForwardingConfig

+ Issuer string

+ JSONWebKeySet *JSONWebKeySet

+ Kind string

+ Locations []*JWTLocation

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Partition string

+ func (e *JWTProviderConfigEntry) GetCreateIndex() uint64

+ func (e *JWTProviderConfigEntry) GetKind() string

+ func (e *JWTProviderConfigEntry) GetMeta() map[string]string

+ func (e *JWTProviderConfigEntry) GetModifyIndex() uint64

+ func (e *JWTProviderConfigEntry) GetName() string

+ func (e *JWTProviderConfigEntry) GetNamespace() string

+ func (e *JWTProviderConfigEntry) GetPartition() string

+ type LocalJWKS struct

+ Filename string

+ JWKS string

+ type Locality struct

+ Region string

+ Zone string

type MeshConfigEntry

+ AllowEnablingPermissiveMutualTLS bool

+ type MutualTLSMode string

+ const MutualTLSModeDefault

+ const MutualTLSModePermissive

+ const MutualTLSModeStrict

type Node

+ Locality *Locality

+ type PeeredServiceName struct

+ Peer string

+ ServiceName CompoundServiceName

type PeeringRemoteInfo

+ Locality *Locality

type ProxyConfigEntry

+ FailoverPolicy *ServiceResolverFailoverPolicy

+ MutualTLSMode MutualTLSMode

+ PrioritizeByLocality *ServiceResolverPrioritizeByLocality

type QueryFailoverTarget

+ Namespace string

+ Partition string

+ type RateLimitIPConfigEntry struct

+ ACL *ReadWriteRatesConfig

+ AutoConfig *ReadWriteRatesConfig

+ Catalog *ReadWriteRatesConfig

+ ConfigEntry *ReadWriteRatesConfig

+ ConnectCA *ReadWriteRatesConfig

+ Coordinate *ReadWriteRatesConfig

+ CreateIndex uint64

+ DNS *ReadWriteRatesConfig

+ DataPlane *ReadWriteRatesConfig

+ DiscoveryChain *ReadWriteRatesConfig

+ FederationState *ReadWriteRatesConfig

+ Health *ReadWriteRatesConfig

+ Intention *ReadWriteRatesConfig

+ Internal *ReadWriteRatesConfig

+ KV *ReadWriteRatesConfig

+ Kind string

+ Meta map[string]string

+ Mode string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Partition string

+ PeerStream *ReadWriteRatesConfig

+ Peering *ReadWriteRatesConfig

+ PreparedQuery *ReadWriteRatesConfig

+ ReadRate float64

+ Resource *ReadWriteRatesConfig

+ ServerDiscovery *ReadWriteRatesConfig

+ Session *ReadWriteRatesConfig

+ Subscribe *ReadWriteRatesConfig

+ Tenancy *ReadWriteRatesConfig

+ Txn *ReadWriteRatesConfig

+ WriteRate float64

+ func (r *RateLimitIPConfigEntry) GetCreateIndex() uint64

+ func (r *RateLimitIPConfigEntry) GetKind() string

+ func (r *RateLimitIPConfigEntry) GetMeta() map[string]string

+ func (r *RateLimitIPConfigEntry) GetModifyIndex() uint64

+ func (r *RateLimitIPConfigEntry) GetName() string

+ func (r *RateLimitIPConfigEntry) GetNamespace() string

+ func (r *RateLimitIPConfigEntry) GetPartition() string

+ type ReadWriteRatesConfig struct

+ ReadRate float64

+ WriteRate float64

+ type RemoteJWKS struct

+ CacheDuration time.Duration

+ FetchAsynchronously bool

+ RequestTimeoutMs int

+ RetryPolicy *JWKSRetryPolicy

+ URI string

+ type RetryPolicyBackOff struct

+ BaseInterval time.Duration

+ MaxInterval time.Duration

+ type SamenessGroupConfigEntry struct

+ CreateIndex uint64

+ DefaultForFailover bool

+ IncludeLocal bool

+ Kind string

+ Members []SamenessGroupMember

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Partition string

+ func (s *SamenessGroupConfigEntry) GetCreateIndex() uint64

+ func (s *SamenessGroupConfigEntry) GetKind() string

+ func (s *SamenessGroupConfigEntry) GetMeta() map[string]string

+ func (s *SamenessGroupConfigEntry) GetModifyIndex() uint64

+ func (s *SamenessGroupConfigEntry) GetName() string

+ func (s *SamenessGroupConfigEntry) GetNamespace() string

+ func (s *SamenessGroupConfigEntry) GetPartition() string

+ type SamenessGroupMember struct

+ Partition string

+ Peer string

type ServiceConfigEntry

+ MutualTLSMode MutualTLSMode

type ServiceConsumer

+ SamenessGroup string

type ServiceIntentionsConfigEntry

+ JWT *IntentionJWTRequirement

type ServiceQuery

+ Partition string

+ SamenessGroup string

type ServiceResolverConfigEntry

+ PrioritizeByLocality *ServiceResolverPrioritizeByLocality

type ServiceResolverFailover

+ Policy *ServiceResolverFailoverPolicy

+ SamenessGroup string

+ type ServiceResolverFailoverPolicy struct

+ Mode string

+ Regions []string

+ type ServiceResolverPrioritizeByLocality struct

+ Mode string

type ServiceResolverRedirect

+ SamenessGroup string

type SourceIntention

+ SamenessGroup string

Sep 18, 2023

Changes in this version

+ const GatewayConditionAccepted

+ const GatewayConditionConflicted

+ const GatewayConditionResolvedRefs

+ const GatewayListenerReasonInvalidCertificateRef

+ const GatewayReasonAccepted

+ const GatewayReasonInvalidCertificates

+ const GatewayReasonNoConflict

+ const GatewayReasonResolvedRefs

+ const GatewayReasonRouteConflict

+ const RouteConditionAccepted

+ const RouteConditionBound

+ const RouteReasonAccepted

+ const RouteReasonBound

+ const RouteReasonFailedToBind

+ const RouteReasonGatewayNotFound

+ const RouteReasonInvalidDiscoveryChain

+ const RouteReasonNoUpstreamServicesTargeted

+ func ValidateGatewayConditionReason(name GatewayConditionType, status ConditionStatus, ...) error

+ func ValidateRouteConditionReason(name RouteConditionType, status ConditionStatus, reason RouteConditionReason) error

+ type ConditionStatus string

+ const ConditionStatusFalse

+ const ConditionStatusTrue

+ const ConditionStatusUnknown

+ type GatewayConditionReason string

+ type GatewayConditionType string

+ type RouteConditionReason string

+ type RouteConditionType string

Jun 1, 2023

Changes in this version

+ const BuiltinValidateExtension

+ const TelemetryCollectorName

Feb 23, 2023

Changes in this version

type License

+ IgnoreTermination bool

Feb 23, 2023

Changes in this version

+ const APIGateway

+ const BuiltinAWSLambdaExtension

+ const BuiltinLuaExtension

+ const HTTPRoute

+ const InlineCertificate

+ const TCPRoute

type ACL

+ func (a *ACL) BootstrapWithToken(btoken string) (*ACLToken, *WriteMeta, error)

+ type APIGatewayConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ Listeners []APIGatewayListener

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Partition string

+ Status ConfigEntryStatus

+ func (g *APIGatewayConfigEntry) GetCreateIndex() uint64

+ func (g *APIGatewayConfigEntry) GetKind() string

+ func (g *APIGatewayConfigEntry) GetMeta() map[string]string

+ func (g *APIGatewayConfigEntry) GetModifyIndex() uint64

+ func (g *APIGatewayConfigEntry) GetName() string

+ func (g *APIGatewayConfigEntry) GetNamespace() string

+ func (g *APIGatewayConfigEntry) GetPartition() string

+ type APIGatewayListener struct

+ Hostname string

+ Name string

+ Port int

+ Protocol string

+ TLS APIGatewayTLSConfiguration

+ type APIGatewayTLSConfiguration struct

+ Certificates []ResourceReference

+ CipherSuites []string

+ MaxVersion string

+ MinVersion string

+ type AccessLogsConfig struct

+ DisableListenerLogs bool

+ Enabled bool

+ JSONFormat string

+ Path string

+ TextFormat string

+ Type LogSinkType

type Agent

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

type AgentServiceConnectProxyConfig

+ AccessLogs *AccessLogsConfig

+ EnvoyExtensions []EnvoyExtension

+ type BootstrapRequest struct

+ BootstrapSecret string

+ type Condition struct

+ LastTransitionTime *time.Time

+ Message string

+ Reason string

+ Resource *ResourceReference

+ Status string

+ Type string

+ type ConfigEntryStatus struct

+ Conditions []Condition

+ type EnvoyExtension struct

+ Arguments map[string]interface{}

+ Name string

+ Required bool

+ type HTTPFilters struct

+ Headers []HTTPHeaderFilter

+ URLRewrite *URLRewrite

+ type HTTPHeaderFilter struct

+ Add map[string]string

+ Remove []string

+ Set map[string]string

+ type HTTPHeaderMatch struct

+ Match HTTPHeaderMatchType

+ Name string

+ Value string

+ type HTTPHeaderMatchType string

+ const HTTPHeaderMatchExact

+ const HTTPHeaderMatchPrefix

+ const HTTPHeaderMatchPresent

+ const HTTPHeaderMatchRegularExpression

+ const HTTPHeaderMatchSuffix

+ type HTTPMatch struct

+ Headers []HTTPHeaderMatch

+ Method HTTPMatchMethod

+ Path HTTPPathMatch

+ Query []HTTPQueryMatch

+ type HTTPMatchMethod string

+ const HTTPMatchMethodAll

+ const HTTPMatchMethodConnect

+ const HTTPMatchMethodDelete

+ const HTTPMatchMethodGet

+ const HTTPMatchMethodHead

+ const HTTPMatchMethodOptions

+ const HTTPMatchMethodPatch

+ const HTTPMatchMethodPost

+ const HTTPMatchMethodPut

+ const HTTPMatchMethodTrace

+ type HTTPPathMatch struct

+ Match HTTPPathMatchType

+ Value string

+ type HTTPPathMatchType string

+ const HTTPPathMatchExact

+ const HTTPPathMatchPrefix

+ const HTTPPathMatchRegularExpression

+ type HTTPQueryMatch struct

+ Match HTTPQueryMatchType

+ Name string

+ Value string

+ type HTTPQueryMatchType string

+ const HTTPQueryMatchExact

+ const HTTPQueryMatchPresent

+ const HTTPQueryMatchRegularExpression

+ type HTTPRouteConfigEntry struct

+ CreateIndex uint64

+ Hostnames []string

+ Kind string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Parents []ResourceReference

+ Partition string

+ Rules []HTTPRouteRule

+ Status ConfigEntryStatus

+ func (r *HTTPRouteConfigEntry) GetCreateIndex() uint64

+ func (r *HTTPRouteConfigEntry) GetKind() string

+ func (r *HTTPRouteConfigEntry) GetMeta() map[string]string

+ func (r *HTTPRouteConfigEntry) GetModifyIndex() uint64

+ func (r *HTTPRouteConfigEntry) GetName() string

+ func (r *HTTPRouteConfigEntry) GetNamespace() string

+ func (r *HTTPRouteConfigEntry) GetPartition() string

+ type HTTPRouteRule struct

+ Filters HTTPFilters

+ Matches []HTTPMatch

+ Services []HTTPService

+ type HTTPService struct

+ Filters HTTPFilters

+ Name string

+ Namespace string

+ Partition string

+ Weight int

type IngressService

+ PassiveHealthCheck *PassiveHealthCheck

type IngressServiceConfig

+ PassiveHealthCheck *PassiveHealthCheck

+ type InlineCertificateConfigEntry struct

+ Certificate string

+ CreateIndex uint64

+ Kind string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Partition string

+ PrivateKey string

+ func (a *InlineCertificateConfigEntry) GetCreateIndex() uint64

+ func (a *InlineCertificateConfigEntry) GetKind() string

+ func (a *InlineCertificateConfigEntry) GetMeta() map[string]string

+ func (a *InlineCertificateConfigEntry) GetModifyIndex() uint64

+ func (a *InlineCertificateConfigEntry) GetName() string

+ func (a *InlineCertificateConfigEntry) GetNamespace() string

+ func (a *InlineCertificateConfigEntry) GetPartition() string

+ type LogSinkType string

+ const DefaultLogSinkType

+ const FileLogSinkType

+ const StdErrLogSinkType

+ const StdOutLogSinkType

type Operator

+ func (op *Operator) RaftLeaderTransfer(q *QueryOptions) (*TransferLeaderResponse, error)

+ func (op *Operator) Usage(q *QueryOptions) (*Usage, *QueryMeta, error)

type ProxyConfigEntry

+ AccessLogs *AccessLogsConfig

+ EnvoyExtensions []EnvoyExtension

type QueryOptions

+ Global bool

type QueryTemplate

+ RemoveEmptyTags bool

+ type ResourceReference struct

+ Kind string

+ Name string

+ Namespace string

+ Partition string

+ SectionName string

type ServiceConfigEntry

+ EnvoyExtensions []EnvoyExtension

type ServiceKind

+ const ServiceKindAPIGateway

+ type ServiceUsage struct

+ BillableServiceInstances int

+ ConnectServiceInstances map[string]int

+ PartitionNamespaceBillableServiceInstances map[string]map[string]int

+ PartitionNamespaceConnectServiceInstances map[string]map[string]map[string]int

+ PartitionNamespaceServiceInstances map[string]map[string]int

+ PartitionNamespaceServices map[string]map[string]int

+ ServiceInstances int

+ Services int

+ type TCPRouteConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Parents []ResourceReference

+ Partition string

+ Services []TCPService

+ Status ConfigEntryStatus

+ func (a *TCPRouteConfigEntry) GetCreateIndex() uint64

+ func (a *TCPRouteConfigEntry) GetKind() string

+ func (a *TCPRouteConfigEntry) GetMeta() map[string]string

+ func (a *TCPRouteConfigEntry) GetModifyIndex() uint64

+ func (a *TCPRouteConfigEntry) GetName() string

+ func (a *TCPRouteConfigEntry) GetNamespace() string

+ func (a *TCPRouteConfigEntry) GetPartition() string

+ type TCPService struct

+ Name string

+ Namespace string

+ Partition string

+ type TransferLeaderResponse struct

+ Success bool

+ type URLRewrite struct

+ Path string

type UpstreamConfig

+ Peer string

+ type Usage struct

+ Usage map[string]ServiceUsage

Sep 13, 2023

Changes in this version

type ACL

+ func (a *ACL) TokenListFiltered(t ACLTokenFilterOptions, q *QueryOptions) ([]*ACLTokenListEntry, *QueryMeta, error)

+ type ACLTokenFilterOptions struct

+ AuthMethod string

+ Policy string

+ Role string

+ ServiceName string

type MembersOpts

+ Filter string

type PassiveHealthCheck

+ BaseEjectionTime *time.Duration

+ MaxEjectionPercent *uint32

type RaftServer

+ LastIndex uint64

type ServiceResolverConfigEntry

+ RequestTimeout time.Duration

Nov 30, 2022

Changes in this version

type ServiceRouteDestination

+ IdleTimeout time.Duration

Nov 21, 2022

Changes in this version

+ const GRPCCAFileEnvName

+ const GRPCCAPathEnvName

Nov 15, 2022

Changes in this version

type HealthCheckDefinition

+ OSService string

type KVOp

+ const KVGetOrEmpty

type MeshConfigEntry

+ Peering *PeeringMeshConfig

type Peering

+ Remote PeeringRemoteInfo

+ StreamStatus PeeringStreamStatus

+ type PeeringMeshConfig struct

+ PeerThroughMeshGateways bool

+ type PeeringRemoteInfo struct

+ Datacenter string

+ Partition string

+ type PeeringStreamStatus struct

+ ExportedServices []string

+ ImportedServices []string

+ LastHeartbeat time.Time

+ LastReceive time.Time

+ LastSend time.Time

type QueryFailoverTarget

+ Peer string

type ServiceConfigEntry

+ BalanceInboundConnections string

type ServiceConsumer

+ Peer string

type ServiceResolverFailover

+ Targets []ServiceResolverFailoverTarget

+ type ServiceResolverFailoverTarget struct

+ Datacenter string

+ Namespace string

+ Partition string

+ Peer string

+ Service string

+ ServiceSubset string

type ServiceResolverRedirect

+ Peer string

type ServiceRouteDestination

+ RetryOn []string

type UpstreamConfig

+ BalanceOutboundConnections string

Oct 19, 2022

Changes in this version

type IngressGatewayConfigEntry

+ Defaults *IngressServiceConfig

type IngressService

+ MaxConcurrentRequests *uint32

+ MaxConnections *uint32

+ MaxPendingRequests *uint32

+ type IngressServiceConfig struct

+ MaxConcurrentRequests *uint32

+ MaxConnections *uint32

+ MaxPendingRequests *uint32

type QueryOptions

+ Peer string

Sep 19, 2022

Changes in this version

type HealthCheck

+ ExposedPort int

+ PeerName string

type Node

+ PeerName string

type PassiveHealthCheck

+ EnforcingConsecutive5xx *uint32

type ServiceConfigEntry

+ LocalConnectTimeoutMs int

+ LocalRequestTimeoutMs int

+ MaxInboundConnections int

Aug 9, 2022

Changes in this version

type AgentService

+ PeerName string

type AgentServiceCheck

+ UDP string

type Client

+ func (c *Client) Peerings() *Peerings

type Config

+ PathPrefix string

+ type DestinationConfig struct

+ Addresses []string

+ Port int

type HealthCheckDefinition

+ UDP string

type Intention

+ SourcePeer string

+ type Peering struct

+ CreateIndex uint64

+ DeletedAt *time.Time

+ ExportedServiceCount uint64

+ ID string

+ ImportedServiceCount uint64

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Partition string

+ PeerCAPems []string

+ PeerID string

+ PeerServerAddresses []string

+ PeerServerName string

+ State PeeringState

+ type PeeringEstablishRequest struct

+ Meta map[string]string

+ Partition string

+ PeerName string

+ PeeringToken string

+ type PeeringEstablishResponse struct

+ type PeeringGenerateTokenRequest struct

+ Meta map[string]string

+ Partition string

+ PeerName string

+ ServerExternalAddresses []string

+ type PeeringGenerateTokenResponse struct

+ PeeringToken string

+ type PeeringListRequest struct

+ type PeeringReadResponse struct

+ Peering *Peering

+ type PeeringState string

+ const PeeringStateActive

+ const PeeringStateDeleting

+ const PeeringStateEstablishing

+ const PeeringStateFailing

+ const PeeringStatePending

+ const PeeringStateTerminated

+ const PeeringStateUndefined

+ type Peerings struct

+ func (p *Peerings) Delete(ctx context.Context, name string, q *WriteOptions) (*WriteMeta, error)

+ func (p *Peerings) Establish(ctx context.Context, i PeeringEstablishRequest, wq *WriteOptions) (*PeeringEstablishResponse, *WriteMeta, error)

+ func (p *Peerings) GenerateToken(ctx context.Context, g PeeringGenerateTokenRequest, wq *WriteOptions) (*PeeringGenerateTokenResponse, *WriteMeta, error)

+ func (p *Peerings) List(ctx context.Context, q *QueryOptions) ([]*Peering, *QueryMeta, error)

+ func (p *Peerings) Read(ctx context.Context, name string, q *QueryOptions) (*Peering, *QueryMeta, error)

+ type QueryFailoverOptions struct

+ Datacenters []string

+ NearestN int

+ Targets []QueryFailoverTarget

+ type QueryFailoverTarget struct

+ Datacenter string

+ PeerName string

type QueryOptions

+ MergeCentralConfig bool

type ServiceConfigEntry

+ Destination *DestinationConfig

type ServiceConsumer

+ PeerName string

type SourceIntention

+ Peer string

type Upstream

+ DestinationPeer string

Jun 1, 2022

Changes in this version

+ const QueryBackendBlockingQuery

+ const QueryBackendStreaming

type ACL

+ func (a *ACL) TokenReadExpanded(tokenID string, q *QueryOptions) (*ACLTokenExpanded, *QueryMeta, error)

+ type ACLTokenExpanded struct

+ AgentACLDefaultPolicy string

+ AgentACLDownPolicy string

+ ExpandedPolicies []ACLPolicy

+ ExpandedRoles []ACLRole

+ NamespaceDefaultPolicyIDs []string

+ NamespaceDefaultRoleIDs []string

+ ResolvedByAgent string

type CompiledDiscoveryChain

+ Default bool

+ ServiceMeta map[string]string

type DiscoveryTarget

+ ConnectTimeout time.Duration

+ func (t *DiscoveryTarget) MarshalJSON() ([]byte, error)

+ func (t *DiscoveryTarget) UnmarshalJSON(data []byte) error

type GatewayTLSConfig

+ CipherSuites []string

+ TLSMaxVersion string

+ TLSMinVersion string

type HealthCheckDefinition

+ GRPC string

+ GRPCUseTLS bool

type MeshConfigEntry

+ HTTP *MeshHTTPConfig

+ TLS *MeshTLSConfig

+ type MeshDirectionalTLSConfig struct

+ CipherSuites []string

+ TLSMaxVersion string

+ TLSMinVersion string

+ type MeshHTTPConfig struct

+ SanitizeXForwardedClientCert bool

+ type MeshTLSConfig struct

+ Incoming *MeshDirectionalTLSConfig

+ Outgoing *MeshDirectionalTLSConfig

type Namespace

+ func (n *Namespace) UnmarshalJSON(data []byte) error

type NamespaceACLConfig

+ func (n *NamespaceACLConfig) UnmarshalJSON(data []byte) error

type QueryMeta

+ QueryBackend string

Dec 14, 2021

Changes in this version

+ const ExportedServices

+ const MemberTagKeyDatacenter

+ const MemberTagKeyPartition

+ const MemberTagValueRoleClient

+ const PartitionDefaultName

type ACLAuthMethod

+ Partition string

type ACLAuthMethodListEntry

+ Partition string

type ACLBindingRule

+ Partition string

type ACLPolicy

+ Partition string

type ACLPolicyListEntry

+ Partition string

type ACLRole

+ Partition string

type ACLToken

+ Partition string

type ACLTokenListEntry

+ Partition string

type Agent

+ func (a *Agent) ForceLeaveOpts(node string, opts ForceLeaveOpts) error

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

type AgentServiceCheck

+ FailuresBeforeWarning int

+ H2PING string

+ H2PingUseTLS bool

type CommonCAProviderConfig

+ RootCertTTL time.Duration

type ConfigEntries

+ func (conf *ConfigEntries) DeleteCAS(kind, name string, index uint64, w *WriteOptions) (bool, *WriteMeta, error)

type ConfigEntry

+ GetPartition func() string

+ type ExportedService struct

+ Consumers []ServiceConsumer

+ Name string

+ Namespace string

+ type ExportedServicesConfigEntry struct

+ CreateIndex uint64

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Partition string

+ Services []ExportedService

+ func (e *ExportedServicesConfigEntry) GetCreateIndex() uint64

+ func (e *ExportedServicesConfigEntry) GetKind() string

+ func (e *ExportedServicesConfigEntry) GetMeta() map[string]string

+ func (e *ExportedServicesConfigEntry) GetModifyIndex() uint64

+ func (e *ExportedServicesConfigEntry) GetName() string

+ func (e *ExportedServicesConfigEntry) GetNamespace() string

+ func (e *ExportedServicesConfigEntry) GetPartition() string

+ func (e *ExportedServicesConfigEntry) MarshalJSON() ([]byte, error)

+ type ForceLeaveOpts struct

+ Prune bool

+ WAN bool

+ type GatewayServiceTLSConfig struct

+ SDS *GatewayTLSSDSConfig

type GatewayTLSConfig

+ SDS *GatewayTLSSDSConfig

+ type GatewayTLSSDSConfig struct

+ CertResource string

+ ClusterName string

+ type HTTPHeaderModifiers struct

+ Add map[string]string

+ Remove []string

+ Set map[string]string

type IngressGatewayConfigEntry

+ Partition string

+ func (i *IngressGatewayConfigEntry) GetPartition() string

type IngressListener

+ TLS *GatewayTLSConfig

type IngressService

+ Partition string

+ RequestHeaders *HTTPHeaderModifiers

+ ResponseHeaders *HTTPHeaderModifiers

+ TLS *GatewayServiceTLSConfig

type Intention

+ DestinationPartition string

+ SourcePartition string

type KVPair

+ Partition string

type KeyringResponse

+ Partition string

type MeshConfigEntry

+ Partition string

+ func (e *MeshConfigEntry) GetPartition() string

type Namespace

+ Partition string

+ type Partition struct

+ CreateIndex uint64

+ DeletedAt *time.Time

+ Description string

+ ModifyIndex uint64

+ Name string

type ProxyConfigEntry

+ Partition string

+ func (p *ProxyConfigEntry) GetPartition() string

type QueryMeta

+ ResultsFilteredByACLs bool

type ServiceConfigEntry

+ Partition string

+ func (s *ServiceConfigEntry) GetPartition() string

+ type ServiceConsumer struct

+ Partition string

type ServiceIntentionsConfigEntry

+ Partition string

+ func (e *ServiceIntentionsConfigEntry) GetPartition() string

type ServiceResolverConfigEntry

+ Partition string

+ func (e *ServiceResolverConfigEntry) GetPartition() string

type ServiceResolverRedirect

+ Partition string

type ServiceRouteDestination

+ Partition string

+ RequestHeaders *HTTPHeaderModifiers

+ ResponseHeaders *HTTPHeaderModifiers

type ServiceRouterConfigEntry

+ Partition string

+ func (e *ServiceRouterConfigEntry) GetPartition() string

type ServiceSplit

+ Partition string

+ RequestHeaders *HTTPHeaderModifiers

+ ResponseHeaders *HTTPHeaderModifiers

type ServiceSplitterConfigEntry

+ Partition string

+ func (e *ServiceSplitterConfigEntry) GetPartition() string

type SourceIntention

+ Partition string

+ type StatusError struct

+ Body string

+ Code int

+ func (e StatusError) Error() string

type TerminatingGatewayConfigEntry

+ Partition string

+ func (g *TerminatingGatewayConfigEntry) GetPartition() string

type UpstreamConfig

+ Partition string

Sep 27, 2021

Changes in this version

type OIDCAuthMethodConfig

+ OIDCACRValues []string

Aug 27, 2021

Changes in this version

+ const HTTPPartitionEnvName

type ACLReplicationStatus

+ LastErrorMessage string

type ACLToken

+ AuthMethodNamespace string

type ACLTokenListEntry

+ AuthMethodNamespace string

+ SecretID string

+ type AdminPartition struct

+ CreateIndex uint64

+ DeletedAt *time.Time

+ Description string

+ ModifyIndex uint64

+ Name string

+ type AdminPartitions struct

+ Partitions []*AdminPartition

type Agent

+ func (a *Agent) AgentHealthServiceByIDOpts(serviceID string, q *QueryOptions) (string, *AgentServiceChecksInfo, error)

+ func (a *Agent) AgentHealthServiceByNameOpts(service string, q *QueryOptions) (string, []AgentServiceChecksInfo, error)

+ func (a *Agent) DisableServiceMaintenanceOpts(serviceID string, q *QueryOptions) error

+ func (a *Agent) EnableServiceMaintenanceOpts(serviceID, reason string, q *QueryOptions) error

+ func (a *Agent) MetricsStream(ctx context.Context) (io.ReadCloser, error)

type AgentCheck

+ Partition string

type AgentCheckRegistration

+ Partition string

type AgentService

+ Partition string

type AgentServiceRegistration

+ Partition string

+ SocketPath string

type AutopilotConfiguration

+ func NewAutopilotConfiguration() AutopilotConfiguration

type CatalogDeregistration

+ Partition string

type CatalogRegistration

+ Partition string

type CatalogService

+ Partition string

type Client

+ func (c *Client) Partitions() *Partitions

type CompoundServiceName

+ Partition string

type Config

+ Partition string

type CoordinateEntry

+ Partition string

type Debug

+ func (d *Debug) PProf(ctx context.Context, name string, seconds int) (io.ReadCloser, error)

type HealthCheck

+ Partition string

type KVTxnOp

+ Partition string

type Node

+ Partition string

+ type Partitions struct

+ func (p *Partitions) Create(ctx context.Context, partition *AdminPartition, q *WriteOptions) (*AdminPartition, *WriteMeta, error)

+ func (p *Partitions) Delete(ctx context.Context, name string, q *WriteOptions) (*WriteMeta, error)

+ func (p *Partitions) List(ctx context.Context, q *QueryOptions) (*AdminPartitions, *QueryMeta, error)

+ func (p *Partitions) Read(ctx context.Context, name string, q *QueryOptions) (*AdminPartition, *QueryMeta, error)

+ func (p *Partitions) Update(ctx context.Context, partition *AdminPartition, q *WriteOptions) (*AdminPartition, *WriteMeta, error)

type QueryOptions

+ Partition string

type Upstream

+ DestinationPartition string

type WriteOptions

+ Partition string

Jun 22, 2021

Changes in this version

+ const MeshConfig

+ const MeshConfigMesh

type ACLAuthMethodListEntry

+ MaxTokenTTL time.Duration

+ TokenLocality string

+ func (m *ACLAuthMethodListEntry) MarshalJSON() ([]byte, error)

+ func (m *ACLAuthMethodListEntry) UnmarshalJSON(data []byte) error

type Agent

+ func (a *Agent) CheckDeregisterOpts(checkID string, q *QueryOptions) error

+ func (a *Agent) ChecksWithFilterOpts(filter string, q *QueryOptions) (map[string]*AgentCheck, error)

+ func (a *Agent) ServiceDeregisterOpts(serviceID string, q *QueryOptions) error

+ func (a *Agent) ServicesWithFilterOpts(filter string, q *QueryOptions) (map[string]*AgentService, error)

+ func (a *Agent) UpdateTTLOpts(checkID, output, status string, q *QueryOptions) error

type AgentCheck

+ ExposedPort int

type AgentService

+ SocketPath string

type AgentServiceCheck

+ TLSServerName string

type AgentServiceConnectProxyConfig

+ LocalServiceSocketPath string

+ Mode ProxyMode

+ TransparentProxy *TransparentProxyConfig

type CAConfig

+ ForceWithoutCrossSigning bool

type Client

+ func (c *Client) AddHeader(key, value string)

+ func (c *Client) Headers() http.Header

+ func (c *Client) SetHeaders(headers http.Header)

type HealthCheckDefinition

+ TLSServerName string

+ type MeshConfigEntry struct

+ CreateIndex uint64

+ Meta map[string]string

+ ModifyIndex uint64

+ Namespace string

+ TransparentProxy TransparentProxyMeshConfig

+ func (e *MeshConfigEntry) GetCreateIndex() uint64

+ func (e *MeshConfigEntry) GetKind() string

+ func (e *MeshConfigEntry) GetMeta() map[string]string

+ func (e *MeshConfigEntry) GetModifyIndex() uint64

+ func (e *MeshConfigEntry) GetName() string

+ func (e *MeshConfigEntry) GetNamespace() string

+ func (e *MeshConfigEntry) MarshalJSON() ([]byte, error)

+ type PassiveHealthCheck struct

+ Interval time.Duration

+ MaxFailures uint32

type ProxyConfigEntry

+ Mode ProxyMode

+ TransparentProxy *TransparentProxyConfig

+ type ProxyMode string

+ const ProxyModeDefault

+ const ProxyModeDirect

+ const ProxyModeTransparent

type ServiceConfigEntry

+ Mode ProxyMode

+ TransparentProxy *TransparentProxyConfig

+ UpstreamConfig *UpstreamConfiguration

type ServiceRegisterOpts

+ func (o ServiceRegisterOpts) WithContext(ctx context.Context) ServiceRegisterOpts

+ type TransparentProxyConfig struct

+ DialedDirectly bool

+ OutboundListenerPort int

+ type TransparentProxyMeshConfig struct

+ MeshDestinationsOnly bool

type Upstream

+ CentrallyConfigured bool

+ LocalBindSocketMode string

+ LocalBindSocketPath string

+ type UpstreamConfig struct

+ ConnectTimeoutMs int

+ EnvoyClusterJSON string

+ EnvoyListenerJSON string

+ Limits *UpstreamLimits

+ MeshGateway MeshGatewayConfig

+ Name string

+ Namespace string

+ PassiveHealthCheck *PassiveHealthCheck

+ Protocol string

+ type UpstreamConfiguration struct

+ Defaults *UpstreamConfig

+ Overrides []*UpstreamConfig

+ type UpstreamLimits struct

+ MaxConcurrentRequests *int

+ MaxConnections *int

+ MaxPendingRequests *int

Nov 24, 2020

Changes in this version

+ const ServiceIntentions

type AgentService

+ Datacenter string

+ type AutopilotServer struct

+ Address string

+ Healthy bool

+ ID string

+ LastContact *ReadableDuration

+ LastIndex uint64

+ LastTerm uint64

+ Meta map[string]string

+ Name string

+ NodeStatus string

+ NodeType AutopilotServerType

+ ReadReplica bool

+ RedundancyZone string

+ StableSince time.Time

+ Status AutopilotServerStatus

+ UpgradeVersion string

+ Version string

+ type AutopilotServerStatus string

+ const AutopilotServerLeader

+ const AutopilotServerNonVoter

+ const AutopilotServerNone

+ const AutopilotServerStaging

+ const AutopilotServerVoter

+ type AutopilotServerType string

+ const AutopilotTypeReadReplica

+ const AutopilotTypeVoter

+ const AutopilotTypeZoneExtraVoter

+ const AutopilotTypeZoneStandby

+ const AutopilotTypeZoneVoter

+ type AutopilotState struct

+ FailureTolerance int

+ Healthy bool

+ Leader string

+ OptimisticFailureTolerance int

+ ReadReplicas []string

+ RedundancyZones map[string]AutopilotZone

+ Servers map[string]AutopilotServer

+ Upgrade *AutopilotUpgrade

+ Voters []string

+ type AutopilotUpgrade struct

+ OtherVersionNonVoters []string

+ OtherVersionReadReplicas []string

+ OtherVersionVoters []string

+ RedundancyZones map[string]AutopilotZoneUpgradeVersions

+ Status AutopilotUpgradeStatus

+ TargetVersion string

+ TargetVersionNonVoters []string

+ TargetVersionReadReplicas []string

+ TargetVersionVoters []string

+ type AutopilotUpgradeStatus string

+ const AutopilotUpgradeAwaitNewServers

+ const AutopilotUpgradeAwaitNewVoters

+ const AutopilotUpgradeAwaitServerRemoval

+ const AutopilotUpgradeDemoting

+ const AutopilotUpgradeDisabled

+ const AutopilotUpgradeIdle

+ const AutopilotUpgradeLeaderTransfer

+ const AutopilotUpgradePromoting

+ type AutopilotZone struct

+ FailureTolerance int

+ Servers []string

+ Voters []string

+ type AutopilotZoneUpgradeVersions struct

+ OtherVersionNonVoters []string

+ OtherVersionVoters []string

+ TargetVersionNonVoters []string

+ TargetVersionVoters []string

type ConfigEntry

+ GetMeta func() map[string]string

+ GetNamespace func() string

type Connect

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

+ func (h *Connect) IntentionDeleteExact(source, destination string, q *WriteOptions) (*WriteMeta, error)

+ func (h *Connect) IntentionGetExact(source, destination string, q *QueryOptions) (*Intention, *QueryMeta, error)

+ type CookieConfig struct

+ Path string

+ Session bool

+ TTL time.Duration

type DiscoveryGraphNode

+ LoadBalancer *LoadBalancer

+ type HashPolicy struct

+ CookieConfig *CookieConfig

+ Field string

+ FieldValue string

+ SourceIP bool

+ Terminal bool

type IngressGatewayConfigEntry

+ func (i *IngressGatewayConfigEntry) GetMeta() map[string]string

+ func (i *IngressGatewayConfigEntry) GetNamespace() string

type Intention

+ Permissions []*IntentionPermission

+ type IntentionHTTPHeaderPermission struct

+ Exact string

+ Invert bool

+ Name string

+ Prefix string

+ Present bool

+ Regex string

+ Suffix string

+ type IntentionHTTPPermission struct

+ Header []IntentionHTTPHeaderPermission

+ Methods []string

+ PathExact string

+ PathPrefix string

+ PathRegex string

+ type IntentionPermission struct

+ Action IntentionAction

+ HTTP *IntentionHTTPPermission

+ type LeastRequestConfig struct

+ ChoiceCount uint32

+ type LoadBalancer struct

+ HashPolicies []HashPolicy

+ LeastRequestConfig *LeastRequestConfig

+ Policy string

+ RingHashConfig *RingHashConfig

type LockOptions

+ LockDelay time.Duration

type Operator

+ func (op *Operator) AutopilotState(q *QueryOptions) (*AutopilotState, error)

type ProxyConfigEntry

+ func (p *ProxyConfigEntry) GetMeta() map[string]string

+ func (p *ProxyConfigEntry) GetNamespace() string

type QueryMeta

+ DefaultACLPolicy string

+ type RingHashConfig struct

+ MaximumRingSize uint64

+ MinimumRingSize uint64

type ServiceConfigEntry

+ func (s *ServiceConfigEntry) GetMeta() map[string]string

+ func (s *ServiceConfigEntry) GetNamespace() string

+ type ServiceIntentionsConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Sources []*SourceIntention

+ func (e *ServiceIntentionsConfigEntry) GetCreateIndex() uint64

+ func (e *ServiceIntentionsConfigEntry) GetKind() string

+ func (e *ServiceIntentionsConfigEntry) GetMeta() map[string]string

+ func (e *ServiceIntentionsConfigEntry) GetModifyIndex() uint64

+ func (e *ServiceIntentionsConfigEntry) GetName() string

+ func (e *ServiceIntentionsConfigEntry) GetNamespace() string

type ServiceResolverConfigEntry

+ LoadBalancer *LoadBalancer

+ func (e *ServiceResolverConfigEntry) GetMeta() map[string]string

+ func (e *ServiceResolverConfigEntry) GetNamespace() string

type ServiceRouterConfigEntry

+ func (e *ServiceRouterConfigEntry) GetMeta() map[string]string

+ func (e *ServiceRouterConfigEntry) GetNamespace() string

type ServiceSplitterConfigEntry

+ func (e *ServiceSplitterConfigEntry) GetMeta() map[string]string

+ func (e *ServiceSplitterConfigEntry) GetNamespace() string

+ type SourceIntention struct

+ Action IntentionAction

+ Description string

+ LegacyCreateTime *time.Time

+ LegacyID string

+ LegacyMeta map[string]string

+ LegacyUpdateTime *time.Time

+ Name string

+ Namespace string

+ Permissions []*IntentionPermission

+ Precedence int

+ Type IntentionSourceType

type Status

+ func (s *Status) LeaderWithQueryOptions(q *QueryOptions) (string, error)

+ func (s *Status) PeersWithQueryOptions(q *QueryOptions) ([]string, error)

type TerminatingGatewayConfigEntry

+ func (g *TerminatingGatewayConfigEntry) GetMeta() map[string]string

+ func (g *TerminatingGatewayConfigEntry) GetNamespace() string

Sep 10, 2020

Changes in this version

+ const MemberTagKeyACLMode

+ const MemberTagKeyBootstrap

+ const MemberTagKeyBootstrapExpect

+ const MemberTagKeyReadReplica

+ const MemberTagKeyRole

+ const MemberTagKeySegment

+ const MemberTagKeyUseTLS

+ const MemberTagValueBootstrap

+ const MemberTagValueReadReplica

+ const MemberTagValueRoleServer

+ const MemberTagValueUseTLS

type AgentMember

+ func (m *AgentMember) ACLMode() MemberACLMode

+ func (m *AgentMember) IsConsulServer() bool

type IngressGatewayConfigEntry

+ Meta map[string]string

type KeyringResponse

+ PrimaryKeys map[string]int

+ type MemberACLMode string

+ const ACLModeDisabled

+ const ACLModeEnabled

+ const ACLModeLegacy

+ const ACLModeUnknown

type ProxyConfigEntry

+ Meta map[string]string

type ServiceConfigEntry

+ Meta map[string]string

type ServiceResolverConfigEntry

+ Meta map[string]string

type ServiceRouterConfigEntry

+ Meta map[string]string

type ServiceSplitterConfigEntry

+ Meta map[string]string

type TerminatingGatewayConfigEntry

+ Meta map[string]string

Aug 7, 2020

Changes in this version

+ type ACLNodeIdentity struct

+ Datacenter string

+ NodeName string

type ACLRole

+ NodeIdentities []*ACLNodeIdentity

type ACLToken

+ NodeIdentities []*ACLNodeIdentity

type ACLTokenListEntry

+ NodeIdentities []*ACLNodeIdentity

type AgentServiceCheck

+ FailuresBeforeCritical int

+ SuccessBeforePassing int

type Catalog

+ func (c *Catalog) GatewayServices(gateway string, q *QueryOptions) ([]*GatewayService, *QueryMeta, error)

+ type CompoundServiceName struct

+ Name string

+ Namespace string

+ type GatewayService struct

+ CAFile string

+ CertFile string

+ FromWildcard bool

+ Gateway CompoundServiceName

+ GatewayKind ServiceKind

+ Hosts []string

+ KeyFile string

+ Port int

+ Protocol string

+ SNI string

+ Service CompoundServiceName

Jun 18, 2020

Changes in this version

+ const IngressGateway

+ const TerminatingGateway

type ACL

+ func (a *ACL) OIDCAuthURL(auth *ACLOIDCAuthURLParams, q *WriteOptions) (string, *WriteMeta, error)

+ func (a *ACL) OIDCCallback(auth *ACLOIDCCallbackParams, q *WriteOptions) (*ACLToken, *WriteMeta, error)

+ func (a *ACL) PolicyReadByName(policyName string, q *QueryOptions) (*ACLPolicy, *QueryMeta, error)

type ACLAuthMethod

+ DisplayName string

+ MaxTokenTTL time.Duration

+ NamespaceRules []*ACLAuthMethodNamespaceRule

+ TokenLocality string

+ func (m *ACLAuthMethod) MarshalJSON() ([]byte, error)

+ func (m *ACLAuthMethod) UnmarshalJSON(data []byte) error

type ACLAuthMethodListEntry

+ DisplayName string

+ type ACLAuthMethodNamespaceRule struct

+ BindNamespace string

+ Selector string

+ type ACLOIDCAuthURLParams struct

+ AuthMethod string

+ ClientNonce string

+ Meta map[string]string

+ RedirectURI string

+ type ACLOIDCCallbackParams struct

+ AuthMethod string

+ ClientNonce string

+ Code string

+ State string

type ACLToken

+ AuthMethod string

type ACLTokenListEntry

+ AuthMethod string

+ type GatewayTLSConfig struct

+ Enabled bool

type Health

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

+ type IngressGatewayConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ Listeners []IngressListener

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ TLS GatewayTLSConfig

+ func (i *IngressGatewayConfigEntry) GetCreateIndex() uint64

+ func (i *IngressGatewayConfigEntry) GetKind() string

+ func (i *IngressGatewayConfigEntry) GetModifyIndex() uint64

+ func (i *IngressGatewayConfigEntry) GetName() string

+ type IngressListener struct

+ Port int

+ Protocol string

+ Services []IngressService

+ type IngressService struct

+ Hosts []string

+ Name string

+ Namespace string

type License

+ Modules []string

+ type LinkedService struct

+ CAFile string

+ CertFile string

+ KeyFile string

+ Name string

+ Namespace string

+ SNI string

+ type OIDCAuthMethodConfig struct

+ AllowedRedirectURIs []string

+ BoundAudiences []string

+ BoundIssuer string

+ ClaimMappings map[string]string

+ ClockSkewLeeway time.Duration

+ ExpirationLeeway time.Duration

+ JWKSCACert string

+ JWKSURL string

+ JWTSupportedAlgs []string

+ JWTValidationPubKeys []string

+ ListClaimMappings map[string]string

+ NotBeforeLeeway time.Duration

+ OIDCClientID string

+ OIDCClientSecret string

+ OIDCDiscoveryCACert string

+ OIDCDiscoveryURL string

+ OIDCScopes []string

+ VerboseOIDCLogging bool

+ func (c *OIDCAuthMethodConfig) RenderToConfig() map[string]interface{}

type ServiceKind

+ const ServiceKindIngressGateway

+ const ServiceKindTerminatingGateway

+ type TerminatingGatewayConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ ModifyIndex uint64

+ Name string

+ Namespace string

+ Services []LinkedService

+ func (g *TerminatingGatewayConfigEntry) GetCreateIndex() uint64

+ func (g *TerminatingGatewayConfigEntry) GetKind() string

+ func (g *TerminatingGatewayConfigEntry) GetModifyIndex() uint64

+ func (g *TerminatingGatewayConfigEntry) GetName() string

Feb 11, 2020

Changes in this version

+ const HTTPNamespaceEnvName

type ACLAuthMethod

+ Namespace string

type ACLAuthMethodListEntry

+ Namespace string

type ACLBindingRule

+ Namespace string

+ type ACLLink struct

+ ID string

+ Name string

type ACLPolicy

+ Namespace string

type ACLPolicyListEntry

+ Namespace string

type ACLRole

+ Namespace string

type ACLToken

+ Namespace string

type ACLTokenListEntry

+ Namespace string

type Agent

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

+ func (a *Agent) ServiceRegisterOpts(service *AgentServiceRegistration, opts ServiceRegisterOpts) error

type AgentCheck

+ Namespace string

type AgentCheckRegistration

+ Namespace string

type AgentService

+ Namespace string

type AgentServiceCheck

+ Body string

type AgentServiceRegistration

+ Namespace string

type CAConfig

+ State map[string]string

type Catalog

+ func (c *Catalog) NodeServiceList(node string, q *QueryOptions) (*CatalogNodeServiceList, *QueryMeta, error)

type CatalogDeregistration

+ Namespace string

+ type CatalogNodeServiceList struct

+ Node *Node

+ Services []*AgentService

type CatalogService

+ Namespace string

type Client

+ func (c *Client) Namespaces() *Namespaces

type Config

+ Namespace string

+ func DefaultConfigWithLogger(logger hclog.Logger) *Config

type ConsulCAProviderConfig

+ IntermediateCertTTL time.Duration

type HealthCheck

+ Namespace string

type HealthCheckDefinition

+ Body string

type KVPair

+ Namespace string

type KVTxnOp

+ Namespace string

type LockOptions

+ Namespace string

+ type Namespace struct

+ ACLs *NamespaceACLConfig

+ CreateIndex uint64

+ DeletedAt *time.Time

+ Description string

+ Meta map[string]string

+ ModifyIndex uint64

+ Name string

+ type NamespaceACLConfig struct

+ PolicyDefaults []ACLLink

+ RoleDefaults []ACLLink

+ type Namespaces struct

+ func (n *Namespaces) Create(ns *Namespace, q *WriteOptions) (*Namespace, *WriteMeta, error)

+ func (n *Namespaces) Delete(name string, q *WriteOptions) (*WriteMeta, error)

+ func (n *Namespaces) List(q *QueryOptions) ([]*Namespace, *QueryMeta, error)

+ func (n *Namespaces) Read(name string, q *QueryOptions) (*Namespace, *QueryMeta, error)

+ func (n *Namespaces) Update(ns *Namespace, q *WriteOptions) (*Namespace, *WriteMeta, error)

type PreparedQueryExecuteResponse

+ Namespace string

type ProxyConfigEntry

+ Namespace string

type QueryOptions

+ Namespace string

type SemaphoreOptions

+ Namespace string

+ type ServiceCheck struct

+ ID string

+ Namespace string

type ServiceConfigEntry

+ Namespace string

type ServiceQuery

+ Namespace string

+ type ServiceRegisterOpts struct

+ ReplaceExistingChecks bool

type ServiceResolverConfigEntry

+ Namespace string

type ServiceRouterConfigEntry

+ Namespace string

type ServiceSplitterConfigEntry

+ Namespace string

type SessionEntry

+ Namespace string

+ NodeChecks []string

+ ServiceChecks []ServiceCheck

+ type SessionOp string

+ const SessionDelete

+ type SessionTxnOp struct

+ Session Session

+ Verb SessionOp

type TLSConfig

+ CAPem []byte

+ CertPEM []byte

+ KeyPEM []byte

type WriteOptions

+ Namespace string

Nov 12, 2019

Changes in this version

type Agent

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

type AgentCheck

+ Type string

type AgentServiceConnectProxyConfig

+ Expose ExposeConfig

type AutopilotConfiguration

+ MinQuorum uint

+ type ExposeConfig struct

+ Checks bool

+ Paths []ExposePath

+ type ExposePath struct

+ ListenerPort int

+ LocalPathPort int

+ ParsedFromCheck bool

+ Path string

+ Protocol string

type HealthCheck

+ Type string

type ProxyConfigEntry

+ Expose ExposeConfig

type ServiceConfigEntry

+ Expose ExposeConfig

Aug 23, 2019

Changes in this version

+ const DiscoveryGraphNodeTypeResolver

+ const DiscoveryGraphNodeTypeRouter

+ const DiscoveryGraphNodeTypeSplitter

+ const ServiceResolver

+ const ServiceRouter

+ const ServiceSplitter

type AgentService

+ TaggedAddresses map[string]ServiceAddress

type AgentServiceConnectProxyConfig

+ MeshGateway MeshGatewayConfig

type AgentServiceRegistration

+ TaggedAddresses map[string]ServiceAddress

type CatalogService

+ ServiceTaggedAddresses map[string]ServiceAddress

type Client

+ func (c *Client) DiscoveryChain() *DiscoveryChain

+ type CompiledDiscoveryChain struct

+ CustomizationHash string

+ Datacenter string

+ Namespace string

+ Nodes map[string]*DiscoveryGraphNode

+ Protocol string

+ ServiceName string

+ StartNode string

+ Targets map[string]*DiscoveryTarget

type ConfigEntry

+ func MakeConfigEntry(kind, name string) (ConfigEntry, error)

+ type DiscoveryChain struct

+ func (d *DiscoveryChain) Get(name string, opts *DiscoveryChainOptions, q *QueryOptions) (*DiscoveryChainResponse, *QueryMeta, error)

+ type DiscoveryChainOptions struct

+ EvaluateInDatacenter string

+ OverrideConnectTimeout time.Duration

+ OverrideMeshGateway MeshGatewayConfig

+ OverrideProtocol string

+ type DiscoveryChainResponse struct

+ Chain *CompiledDiscoveryChain

+ type DiscoveryFailover struct

+ Targets []string

+ type DiscoveryGraphNode struct

+ Name string

+ Resolver *DiscoveryResolver

+ Routes []*DiscoveryRoute

+ Splits []*DiscoverySplit

+ Type string

+ type DiscoveryResolver struct

+ ConnectTimeout time.Duration

+ Default bool

+ Failover *DiscoveryFailover

+ Target string

+ func (r *DiscoveryResolver) MarshalJSON() ([]byte, error)

+ func (r *DiscoveryResolver) UnmarshalJSON(data []byte) error

+ type DiscoveryRoute struct

+ Definition *ServiceRoute

+ NextNode string

+ type DiscoverySplit struct

+ NextNode string

+ Weight float32

+ type DiscoveryTarget struct

+ Datacenter string

+ External bool

+ ID string

+ MeshGateway MeshGatewayConfig

+ Name string

+ Namespace string

+ SNI string

+ Service string

+ ServiceSubset string

+ Subset ServiceResolverSubset

type Intention

+ Hash []byte

+ type License struct

+ CustomerID string

+ ExpirationTime time.Time

+ Features []string

+ Flags map[string]interface{}

+ InstallationID string

+ IssueTime time.Time

+ LicenseID string

+ Product string

+ StartTime time.Time

+ TerminationTime time.Time

+ type LicenseReply struct

+ License *License

+ Valid bool

+ Warnings []string

+ type MeshGatewayConfig struct

+ Mode MeshGatewayMode

+ type MeshGatewayMode string

+ const MeshGatewayModeDefault

+ const MeshGatewayModeLocal

+ const MeshGatewayModeNone

+ const MeshGatewayModeRemote

type Operator

+ func (op *Operator) LicenseGet(q *QueryOptions) (*LicenseReply, error)

+ func (op *Operator) LicenseGetSigned(q *QueryOptions) (string, error)

+ func (op *Operator) LicensePut(license string, opts *WriteOptions) (*LicenseReply, error)

+ func (op *Operator) LicenseReset(opts *WriteOptions) (*LicenseReply, error)

type ProxyConfigEntry

+ MeshGateway MeshGatewayConfig

type QueryOptions

+ LocalOnly bool

+ type ServiceAddress struct

+ Address string

+ Port int

+ func ParseServiceAddr(addrPort string) (ServiceAddress, error)

type ServiceConfigEntry

+ ExternalSNI string

+ MeshGateway MeshGatewayConfig

type ServiceKind

+ const ServiceKindMeshGateway

+ type ServiceResolverConfigEntry struct

+ ConnectTimeout time.Duration

+ CreateIndex uint64

+ DefaultSubset string

+ Failover map[string]ServiceResolverFailover

+ Kind string

+ ModifyIndex uint64

+ Name string

+ Redirect *ServiceResolverRedirect

+ Subsets map[string]ServiceResolverSubset

+ func (e *ServiceResolverConfigEntry) GetCreateIndex() uint64

+ func (e *ServiceResolverConfigEntry) GetKind() string

+ func (e *ServiceResolverConfigEntry) GetModifyIndex() uint64

+ func (e *ServiceResolverConfigEntry) GetName() string

+ func (e *ServiceResolverConfigEntry) MarshalJSON() ([]byte, error)

+ func (e *ServiceResolverConfigEntry) UnmarshalJSON(data []byte) error

+ type ServiceResolverFailover struct

+ Datacenters []string

+ Namespace string

+ Service string

+ ServiceSubset string

+ type ServiceResolverRedirect struct

+ Datacenter string

+ Namespace string

+ Service string

+ ServiceSubset string

+ type ServiceResolverSubset struct

+ Filter string

+ OnlyPassing bool

+ type ServiceRoute struct

+ Destination *ServiceRouteDestination

+ Match *ServiceRouteMatch

+ type ServiceRouteDestination struct

+ Namespace string

+ NumRetries uint32

+ PrefixRewrite string

+ RequestTimeout time.Duration

+ RetryOnConnectFailure bool

+ RetryOnStatusCodes []uint32

+ Service string

+ ServiceSubset string

+ func (e *ServiceRouteDestination) MarshalJSON() ([]byte, error)

+ func (e *ServiceRouteDestination) UnmarshalJSON(data []byte) error

+ type ServiceRouteHTTPMatch struct

+ Header []ServiceRouteHTTPMatchHeader

+ Methods []string

+ PathExact string

+ PathPrefix string

+ PathRegex string

+ QueryParam []ServiceRouteHTTPMatchQueryParam

+ type ServiceRouteHTTPMatchHeader struct

+ Exact string

+ Invert bool

+ Name string

+ Prefix string

+ Present bool

+ Regex string

+ Suffix string

+ type ServiceRouteHTTPMatchQueryParam struct

+ Exact string

+ Name string

+ Present bool

+ Regex string

+ type ServiceRouteMatch struct

+ HTTP *ServiceRouteHTTPMatch

+ type ServiceRouterConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ ModifyIndex uint64

+ Name string

+ Routes []ServiceRoute

+ func (e *ServiceRouterConfigEntry) GetCreateIndex() uint64

+ func (e *ServiceRouterConfigEntry) GetKind() string

+ func (e *ServiceRouterConfigEntry) GetModifyIndex() uint64

+ func (e *ServiceRouterConfigEntry) GetName() string

+ type ServiceSplit struct

+ Namespace string

+ Service string

+ ServiceSubset string

+ Weight float32

+ type ServiceSplitterConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ ModifyIndex uint64

+ Name string

+ Splits []ServiceSplit

+ func (e *ServiceSplitterConfigEntry) GetCreateIndex() uint64

+ func (e *ServiceSplitterConfigEntry) GetKind() string

+ func (e *ServiceSplitterConfigEntry) GetModifyIndex() uint64

+ func (e *ServiceSplitterConfigEntry) GetName() string

type Upstream

+ MeshGateway MeshGatewayConfig

May 8, 2019

Changes in this version

+ const HTTPTokenFileEnvName

+ const ProxyConfigGlobal

+ const ProxyDefaults

+ const ServiceDefaults

type ACL

+ func (a *ACL) AuthMethodCreate(method *ACLAuthMethod, q *WriteOptions) (*ACLAuthMethod, *WriteMeta, error)

+ func (a *ACL) AuthMethodDelete(methodName string, q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) AuthMethodList(q *QueryOptions) ([]*ACLAuthMethodListEntry, *QueryMeta, error)

+ func (a *ACL) AuthMethodRead(methodName string, q *QueryOptions) (*ACLAuthMethod, *QueryMeta, error)

+ func (a *ACL) AuthMethodUpdate(method *ACLAuthMethod, q *WriteOptions) (*ACLAuthMethod, *WriteMeta, error)

+ func (a *ACL) BindingRuleCreate(rule *ACLBindingRule, q *WriteOptions) (*ACLBindingRule, *WriteMeta, error)

+ func (a *ACL) BindingRuleDelete(bindingRuleID string, q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) BindingRuleList(methodName string, q *QueryOptions) ([]*ACLBindingRule, *QueryMeta, error)

+ func (a *ACL) BindingRuleRead(bindingRuleID string, q *QueryOptions) (*ACLBindingRule, *QueryMeta, error)

+ func (a *ACL) BindingRuleUpdate(rule *ACLBindingRule, q *WriteOptions) (*ACLBindingRule, *WriteMeta, error)

+ func (a *ACL) Login(auth *ACLLoginParams, q *WriteOptions) (*ACLToken, *WriteMeta, error)

+ func (a *ACL) Logout(q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) RoleCreate(role *ACLRole, q *WriteOptions) (*ACLRole, *WriteMeta, error)

+ func (a *ACL) RoleDelete(roleID string, q *WriteOptions) (*WriteMeta, error)

+ func (a *ACL) RoleList(q *QueryOptions) ([]*ACLRole, *QueryMeta, error)

+ func (a *ACL) RoleRead(roleID string, q *QueryOptions) (*ACLRole, *QueryMeta, error)

+ func (a *ACL) RoleReadByName(roleName string, q *QueryOptions) (*ACLRole, *QueryMeta, error)

+ func (a *ACL) RoleUpdate(role *ACLRole, q *WriteOptions) (*ACLRole, *WriteMeta, error)

+ type ACLAuthMethod struct

+ Config map[string]interface{}

+ CreateIndex uint64

+ Description string

+ ModifyIndex uint64

+ Name string

+ Type string

+ type ACLAuthMethodListEntry struct

+ CreateIndex uint64

+ Description string

+ ModifyIndex uint64

+ Name string

+ Type string

+ type ACLBindingRule struct

+ AuthMethod string

+ BindName string

+ BindType BindingRuleBindType

+ CreateIndex uint64

+ Description string

+ ID string

+ ModifyIndex uint64

+ Selector string

+ type ACLLoginParams struct

+ AuthMethod string

+ BearerToken string

+ Meta map[string]string

type ACLReplicationStatus

+ ReplicatedRoleIndex uint64

+ type ACLRole struct

+ CreateIndex uint64

+ Description string

+ Hash []byte

+ ID string

+ ModifyIndex uint64

+ Name string

+ Policies []*ACLRolePolicyLink

+ ServiceIdentities []*ACLServiceIdentity

+ type ACLRolePolicyLink struct

+ ID string

+ Name string

+ type ACLServiceIdentity struct

+ Datacenters []string

+ ServiceName string

type ACLToken

+ ExpirationTTL time.Duration

+ ExpirationTime *time.Time

+ Roles []*ACLTokenRoleLink

+ ServiceIdentities []*ACLServiceIdentity

type ACLTokenListEntry

+ ExpirationTime *time.Time

+ Roles []*ACLTokenRoleLink

+ ServiceIdentities []*ACLServiceIdentity

+ type ACLTokenRoleLink struct

+ ID string

+ Name string

type Agent

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

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

+ type BindingRuleBindType string

+ const BindingRuleBindTypeRole

+ const BindingRuleBindTypeService

type Client

+ func (c *Client) ConfigEntries() *ConfigEntries

type Config

+ TokenFile string

+ type ConfigEntries struct

+ func (conf *ConfigEntries) CAS(entry ConfigEntry, index uint64, w *WriteOptions) (bool, *WriteMeta, error)

+ func (conf *ConfigEntries) Delete(kind string, name string, w *WriteOptions) (*WriteMeta, error)

+ func (conf *ConfigEntries) Get(kind string, name string, q *QueryOptions) (ConfigEntry, *QueryMeta, error)

+ func (conf *ConfigEntries) List(kind string, q *QueryOptions) ([]ConfigEntry, *QueryMeta, error)

+ func (conf *ConfigEntries) Set(entry ConfigEntry, w *WriteOptions) (bool, *WriteMeta, error)

+ type ConfigEntry interface

+ GetCreateIndex func() uint64

+ GetKind func() string

+ GetModifyIndex func() uint64

+ GetName func() string

+ func DecodeConfigEntry(raw map[string]interface{}) (ConfigEntry, error)

+ func DecodeConfigEntryFromJSON(data []byte) (ConfigEntry, error)

+ type KubernetesAuthMethodConfig struct

+ CACert string

+ Host string

+ ServiceAccountJWT string

+ func ParseKubernetesAuthMethodConfig(raw map[string]interface{}) (*KubernetesAuthMethodConfig, error)

+ func (c *KubernetesAuthMethodConfig) RenderToConfig() map[string]interface{}

+ type ProxyConfigEntry struct

+ Config map[string]interface{}

+ CreateIndex uint64

+ Kind string

+ ModifyIndex uint64

+ Name string

+ func (p *ProxyConfigEntry) GetCreateIndex() uint64

+ func (p *ProxyConfigEntry) GetKind() string

+ func (p *ProxyConfigEntry) GetModifyIndex() uint64

+ func (p *ProxyConfigEntry) GetName() string

type QueryOptions

+ Filter string

+ type ServiceConfigEntry struct

+ CreateIndex uint64

+ Kind string

+ ModifyIndex uint64

+ Name string

+ Protocol string

+ func (s *ServiceConfigEntry) GetCreateIndex() uint64

+ func (s *ServiceConfigEntry) GetKind() string

+ func (s *ServiceConfigEntry) GetModifyIndex() uint64

+ func (s *ServiceConfigEntry) GetName() string

Mar 26, 2019

Changes in this version

+ const ACLClientType

+ const ACLManagementType

+ const AllSegments

+ const DefaultLockRetryTime

+ const DefaultLockSessionName

+ const DefaultLockSessionTTL

+ const DefaultLockWaitTime

+ const DefaultMonitorRetryTime

+ const DefaultSemaphoreKey

+ const DefaultSemaphoreSessionName

+ const DefaultSemaphoreSessionTTL

+ const DefaultSemaphoreWaitTime

+ const GRPCAddrEnvName

+ const HTTPAddrEnvName

+ const HTTPAuthEnvName

+ const HTTPCAFile

+ const HTTPCAPath

+ const HTTPClientCert

+ const HTTPClientKey

+ const HTTPSSLEnvName

+ const HTTPSSLVerifyEnvName

+ const HTTPTLSServerName

+ const HTTPTokenEnvName

+ const HealthAny

+ const HealthCritical

+ const HealthMaint

+ const HealthPassing

+ const HealthWarning

+ const IntentionDefaultNamespace

+ const LockFlagValue

+ const NodeMaint

+ const SemaphoreFlagValue

+ const ServiceMaintPrefix

+ 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")

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

+ func IsRetryableError(err error) bool

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

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

+ type ACL struct

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

+ 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) 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) Replication(q *QueryOptions) (*ACLReplicationStatus, *QueryMeta, 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)

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

+ Enabled bool

+ LastError time.Time

+ LastSuccess time.Time

+ ReplicatedIndex uint64

+ ReplicatedTokenIndex uint64

+ ReplicationType string

+ Running bool

+ SourceDatacenter 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 struct

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

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

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

+ 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) Host() (map[string]interface{}, error)

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

+ func (a *Agent) Leave() error

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

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

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

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

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

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

+ func (a *Agent) Reload() error

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

+ func (a *Agent) Service(serviceID string, q *QueryOptions) (*AgentService, *QueryMeta, 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) UpdateACLAgentMasterToken(token string, q *WriteOptions) (*WriteMeta, error)

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

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

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

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

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

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

+ type AgentAuthorize struct

+ Authorized bool

+ Reason string

+ type AgentAuthorizeParams struct

+ ClientCertSerial string

+ ClientCertURI string

+ Target string

+ type AgentCheck struct

+ CheckID string

+ Definition HealthCheckDefinition

+ 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

+ Connect *AgentServiceConnect

+ ContentHash string

+ CreateIndex uint64

+ EnableTagOverride bool

+ ID string

+ Kind ServiceKind

+ Meta map[string]string

+ ModifyIndex uint64

+ Port int

+ Proxy *AgentServiceConnectProxyConfig

+ ProxyDestination string

+ Service string

+ Tags []string

+ Weights AgentWeights

+ type AgentServiceCheck struct

+ AliasNode string

+ AliasService string

+ Args []string

+ CheckID string

+ DeregisterCriticalServiceAfter string

+ DockerContainerID string

+ GRPC string

+ GRPCUseTLS bool

+ HTTP string

+ Header map[string][]string

+ Interval string

+ Method string

+ Name string

+ Notes string

+ Shell string

+ Status string

+ TCP string

+ TLSSkipVerify bool

+ TTL string

+ Timeout string

+ type AgentServiceChecks []*AgentServiceCheck

+ type AgentServiceChecksInfo struct

+ AggregatedStatus string

+ Checks HealthChecks

+ Service *AgentService

+ type AgentServiceConnect struct

+ Native bool

+ Proxy *AgentServiceConnectProxy

+ SidecarService *AgentServiceRegistration

+ type AgentServiceConnectProxy struct

+ Command []string

+ Config map[string]interface{}

+ ExecMode ProxyExecMode

+ Upstreams []Upstream

+ type AgentServiceConnectProxyConfig struct

+ Config map[string]interface{}

+ DestinationServiceID string

+ DestinationServiceName string

+ LocalServiceAddress string

+ LocalServicePort int

+ Upstreams []Upstream

+ type AgentServiceRegistration struct

+ Address string

+ Check *AgentServiceCheck

+ Checks AgentServiceChecks

+ Connect *AgentServiceConnect

+ EnableTagOverride bool

+ ID string

+ Kind ServiceKind

+ Meta map[string]string

+ Name string

+ Port int

+ Proxy *AgentServiceConnectProxyConfig

+ ProxyDestination string

+ Tags []string

+ Weights *AgentWeights

+ type AgentToken struct

+ Token string

+ type AgentWeights struct

+ Passing int

+ Warning int

+ type Area struct

+ ID string

+ PeerDatacenter string

+ RetryJoin []string

+ UseTLS bool

+ 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

+ UpgradeVersionTag 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 struct

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

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

+ 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) ServiceMultipleTags(service string, tags []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

+ Checks HealthChecks

+ Datacenter string

+ ID string

+ Node string

+ NodeMeta map[string]string

+ Service *AgentService

+ SkipNodeUpdate bool

+ TaggedAddresses map[string]string

+ type CatalogService struct

+ Address string

+ Checks HealthChecks

+ CreateIndex uint64

+ Datacenter string

+ ID string

+ ModifyIndex uint64

+ Node string

+ NodeMeta map[string]string

+ ServiceAddress string

+ ServiceEnableTagOverride bool

+ ServiceID string

+ ServiceMeta map[string]string

+ ServiceName string

+ ServicePort int

+ ServiceProxy *AgentServiceConnectProxyConfig

+ ServiceTags []string

+ ServiceWeights Weights

+ TaggedAddresses map[string]string

+ type CheckOp string

+ const CheckCAS

+ const CheckDelete

+ const CheckDeleteCAS

+ const CheckGet

+ const CheckSet

+ type CheckTxnOp struct

+ Check HealthCheck

+ Verb CheckOp

+ 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) Connect() *Connect

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

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

+ 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) Operator() *Operator

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

+ 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) Snapshot() *Snapshot

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

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

+ type CommonCAProviderConfig struct

+ CSRMaxConcurrent int

+ CSRMaxPerSecond float32

+ LeafCertTTL time.Duration

+ SkipValidate bool

+ type Config struct

+ Address string

+ Datacenter string

+ HttpAuth *HttpBasicAuth

+ HttpClient *http.Client

+ Scheme string

+ TLSConfig TLSConfig

+ Token string

+ Transport *http.Transport

+ WaitTime time.Duration

+ func DefaultConfig() *Config

+ func DefaultNonPooledConfig() *Config

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

+ 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

+ Upstreams []Upstream

+ type ConsulCAProviderConfig struct

+ PrivateKey string

+ RootCert string

+ RotationPeriod time.Duration

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

+ type Coordinate struct

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

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

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

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

+ type CoordinateDatacenterMap struct

+ AreaID string

+ Coordinates []CoordinateEntry

+ Datacenter string

+ type CoordinateEntry struct

+ Coord *coordinate.Coordinate

+ Node string

+ Segment string

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

+ 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 GaugeValue struct

+ Labels map[string]string

+ Name string

+ Value float32

+ type Health struct

+ func (h *Health) Checks(service string, q *QueryOptions) (HealthChecks, *QueryMeta, error)

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

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

+ func (h *Health) Node(node string, q *QueryOptions) (HealthChecks, *QueryMeta, error)

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

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

+ func (h *Health) State(state string, q *QueryOptions) (HealthChecks, *QueryMeta, error)

+ type HealthCheck struct

+ CheckID string

+ CreateIndex uint64

+ Definition HealthCheckDefinition

+ ModifyIndex uint64

+ Name string

+ Node string

+ Notes string

+ Output string

+ ServiceID string

+ ServiceName string

+ ServiceTags []string

+ Status string

+ type HealthCheckDefinition struct

+ DeregisterCriticalServiceAfter ReadableDuration

+ DeregisterCriticalServiceAfterDuration time.Duration

+ HTTP string

+ Header map[string][]string

+ Interval ReadableDuration

+ IntervalDuration time.Duration

+ Method string

+ TCP string

+ TLSSkipVerify bool

+ Timeout ReadableDuration

+ TimeoutDuration time.Duration

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

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

+ type HealthChecks []*HealthCheck

+ func (c HealthChecks) AggregatedStatus() string

+ type HttpBasicAuth struct

+ Password string

+ Username string

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

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

+ type KVOp string

+ const KVCAS

+ const KVCheckIndex

+ const KVCheckNotExists

+ const KVCheckSession

+ const KVDelete

+ const KVDeleteCAS

+ const KVDeleteTree

+ const KVGet

+ const KVGetTree

+ const KVLock

+ const KVSet

+ const KVUnlock

+ type KVPair struct

+ CreateIndex uint64

+ Flags uint64

+ Key string

+ LockIndex uint64

+ ModifyIndex uint64

+ Session string

+ Value []byte

+ type KVPairs []*KVPair

+ type KVTxnOp struct

+ Flags uint64

+ Index uint64

+ Key string

+ Session string

+ Value []byte

+ Verb KVOp

+ type KVTxnOps []*KVTxnOp

+ type KVTxnResponse struct

+ Errors TxnErrors

+ Results []*KVPair

+ type KeyringResponse struct

+ Datacenter string

+ Keys map[string]int

+ Messages map[string]string

+ NumNodes int

+ Segment string

+ WAN bool

+ type LeafCert struct

+ CertPEM string

+ CreateIndex uint64

+ ModifyIndex uint64

+ PrivateKeyPEM string

+ SerialNumber string

+ Service string

+ ServiceURI string

+ ValidAfter time.Time

+ ValidBefore time.Time

+ 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

+ LockTryOnce bool

+ LockWaitTime time.Duration

+ MonitorRetries int

+ MonitorRetryTime time.Duration

+ Session string

+ SessionName string

+ SessionOpts *SessionEntry

+ SessionTTL string

+ Value []byte

+ type MembersOpts struct

+ Segment string

+ WAN bool

+ type MetricsInfo struct

+ Counters []SampledValue

+ Gauges []GaugeValue

+ Points []PointValue

+ Samples []SampledValue

+ Timestamp string

+ type Node struct

+ Address string

+ CreateIndex uint64

+ Datacenter string

+ ID string

+ Meta map[string]string

+ ModifyIndex uint64

+ Node string

+ TaggedAddresses map[string]string

+ type NodeOp string

+ const NodeCAS

+ const NodeDelete

+ const NodeDeleteCAS

+ const NodeGet

+ const NodeSet

+ type NodeTxnOp struct

+ Node Node

+ Verb NodeOp

+ type Operator struct

+ 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) AreaUpdate(areaID string, area *Area, q *WriteOptions) (string, *WriteMeta, 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) 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

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

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

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

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

+ type OperatorHealthReply struct

+ FailureTolerance int

+ Healthy bool

+ Servers []ServerHealth

+ type PointValue struct

+ Name string

+ Points []float32

+ type PreparedQuery struct

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

+ func (c *PreparedQuery) Delete(queryID string, q *WriteOptions) (*WriteMeta, 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

+ Template QueryTemplate

+ Token string

+ type PreparedQueryExecuteResponse struct

+ DNS QueryDNSOptions

+ Datacenter string

+ Failovers int

+ Nodes []ServiceEntry

+ Service string

+ type ProxyExecMode string

+ const ProxyExecModeDaemon

+ const ProxyExecModeScript

+ type QueryDNSOptions struct

+ TTL string

+ type QueryDatacenterOptions struct

+ Datacenters []string

+ NearestN int

+ type QueryMeta struct

+ AddressTranslationEnabled bool

+ CacheAge time.Duration

+ CacheHit bool

+ KnownLeader bool

+ LastContact time.Duration

+ LastContentHash string

+ LastIndex uint64

+ RequestTime time.Duration

+ type QueryOptions struct

+ AllowStale bool

+ Connect bool

+ Datacenter string

+ MaxAge time.Duration

+ Near string

+ NodeMeta map[string]string

+ RelayFactor uint8

+ RequireConsistent bool

+ StaleIfError time.Duration

+ Token string

+ UseCache bool

+ WaitHash string

+ WaitIndex uint64

+ WaitTime time.Duration

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

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

+ 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

+ ProtocolVersion string

+ Voter bool

+ 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 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 SampledValue struct

+ Count int

+ Labels map[string]string

+ Max float64

+ Mean float64

+ Min float64

+ Name string

+ Stddev float64

+ Sum float64

+ 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

+ MonitorRetries int

+ MonitorRetryTime time.Duration

+ Prefix string

+ SemaphoreTryOnce bool

+ SemaphoreWaitTime time.Duration

+ Session string

+ SessionName string

+ SessionTTL string

+ Value []byte

+ 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 ServiceEntry struct

+ Checks HealthChecks

+ Node *Node

+ Service *AgentService

+ type ServiceKind string

+ const ServiceKindConnectProxy

+ const ServiceKindTypical

+ type ServiceOp string

+ const ServiceCAS

+ const ServiceDelete

+ const ServiceDeleteCAS

+ const ServiceGet

+ const ServiceSet

+ type ServiceQuery struct

+ Connect bool

+ Failover QueryDatacenterOptions

+ IgnoreCheckIDs []string

+ Near string

+ NodeMeta map[string]string

+ OnlyPassing bool

+ Service string

+ ServiceMeta map[string]string

+ Tags []string

+ type ServiceTxnOp struct

+ Node string

+ Service AgentService

+ Verb ServiceOp

+ 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 Snapshot struct

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

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

+ type Status struct

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

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

+ type TLSConfig struct

+ Address string

+ CAFile string

+ CAPath string

+ CertFile string

+ InsecureSkipVerify bool

+ KeyFile string

+ type Txn struct

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

+ type TxnError struct

+ OpIndex int

+ What string

+ type TxnErrors []*TxnError

+ type TxnOp struct

+ Check *CheckTxnOp

+ KV *KVTxnOp

+ Node *NodeTxnOp

+ Service *ServiceTxnOp

+ type TxnOps []*TxnOp

+ type TxnResponse struct

+ Errors TxnErrors

+ Results TxnResults

+ type TxnResult struct

+ Check *HealthCheck

+ KV *KVPair

+ Node *Node

+ Service *CatalogService

+ type TxnResults []*TxnResult

+ 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

+ type UserEvent struct

+ ID string

+ LTime uint64

+ Name string

+ NodeFilter string

+ Payload []byte

+ ServiceFilter string

+ TagFilter string

+ Version int

+ type Weights struct

+ Passing int

+ Warning int

+ type WriteMeta struct

+ RequestTime time.Duration

+ type WriteOptions struct

+ Datacenter string

+ RelayFactor uint8

+ Token string

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

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