Versions in this module Expand all Collapse all v0 v0.0.0 Mar 19, 2025 Changes in this version + const ACLClientType + const ACLManagementType + const APIGateway + const AllSegments + const BuiltinAWSLambdaExtension + const BuiltinExtAuthzExtension + const BuiltinLuaExtension + const BuiltinPropertyOverrideExtension + const BuiltinValidateExtension + const BuiltinWasmExtension + const DefaultLockRetryTime + const DefaultLockSessionName + const DefaultLockSessionTTL + const DefaultLockWaitTime + const DefaultMonitorRetryTime + const DefaultSemaphoreKey + const DefaultSemaphoreSessionName + const DefaultSemaphoreSessionTTL + const DefaultSemaphoreWaitTime + const DiscoveryGraphNodeTypeResolver + const DiscoveryGraphNodeTypeRouter + const DiscoveryGraphNodeTypeSplitter + const ExportedServices + const GRPCAddrEnvName + const GRPCCAFileEnvName + const GRPCCAPathEnvName + const GatewayConditionAccepted + const GatewayConditionConflicted + const GatewayConditionResolvedRefs + const GatewayListenerReasonInvalidCertificateRef + const GatewayReasonAccepted + const GatewayReasonInvalidCertificates + const GatewayReasonNoConflict + const GatewayReasonResolvedRefs + const GatewayReasonRouteConflict + const HTTPAddrEnvName + const HTTPAuthEnvName + const HTTPCAFile + const HTTPCAPath + const HTTPClientCert + const HTTPClientKey + const HTTPNamespaceEnvName + const HTTPPartitionEnvName + const HTTPRoute + const HTTPSSLEnvName + const HTTPSSLVerifyEnvName + const HTTPTLSServerName + const HTTPTokenEnvName + const HTTPTokenFileEnvName + const HealthAny + const HealthCritical + const HealthMaint + const HealthPassing + const HealthWarning + const IngressGateway + const InlineCertificate + const IntentionDefaultNamespace + const JWTProvider + const LockFlagValue + const MemberTagKeyACLMode + const MemberTagKeyBootstrap + const MemberTagKeyBootstrapExpect + const MemberTagKeyDatacenter + const MemberTagKeyPartition + const MemberTagKeyReadReplica + const MemberTagKeyRole + const MemberTagKeySegment + const MemberTagKeyUseTLS + const MemberTagValueBootstrap + const MemberTagValueReadReplica + const MemberTagValueRoleClient + const MemberTagValueRoleServer + const MemberTagValueUseTLS + const MeshConfig + const MeshConfigMesh + const NodeMaint + const PartitionDefaultName + const ProxyConfigGlobal + const ProxyDefaults + const QueryBackendBlockingQuery + const QueryBackendStreaming + const RateLimitIPConfig + const RouteConditionAccepted + const RouteConditionBound + const RouteReasonAccepted + const RouteReasonBound + const RouteReasonFailedToBind + const RouteReasonGatewayNotFound + const RouteReasonInvalidDiscoveryChain + const RouteReasonNoUpstreamServicesTargeted + const SamenessGroup + const SemaphoreFlagValue + const ServiceDefaults + const ServiceIntentions + const ServiceMaintPrefix + const ServiceResolver + const ServiceRouter + const ServiceSplitter + const SessionBehaviorDelete + const SessionBehaviorRelease + const TCPRoute + const TelemetryCollectorName + const TerminatingGateway + 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) + func ValidateGatewayConditionReason(name GatewayConditionType, status ConditionStatus, ...) error + func ValidateRouteConditionReason(name RouteConditionType, status ConditionStatus, reason RouteConditionReason) error + type ACL struct + 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) Bootstrap() (*ACLToken, *WriteMeta, error) + func (a *ACL) BootstrapWithToken(btoken string) (*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) Login(auth *ACLLoginParams, q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACL) Logout(q *WriteOptions) (*WriteMeta, error) + 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) 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) PolicyReadByName(policyName 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) 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) + func (a *ACL) RulesTranslate(rules io.Reader) (string, error) + func (a *ACL) RulesTranslateToken(tokenID string) (string, error) + func (a *ACL) TokenClone(accessorID string, description string, q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACL) TokenCreate(token *ACLToken, q *WriteOptions) (*ACLToken, *WriteMeta, error) + func (a *ACL) TokenDelete(accessorID string, q *WriteOptions) (*WriteMeta, error) + func (a *ACL) TokenList(q *QueryOptions) ([]*ACLTokenListEntry, *QueryMeta, error) + func (a *ACL) TokenListFiltered(t ACLTokenFilterOptions, q *QueryOptions) ([]*ACLTokenListEntry, *QueryMeta, error) + func (a *ACL) TokenRead(accessorID string, q *QueryOptions) (*ACLToken, *QueryMeta, error) + func (a *ACL) TokenReadExpanded(accessorID string, q *QueryOptions) (*ACLTokenExpanded, *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 ACLAuthMethod struct + Config map[string]interface{} + CreateIndex uint64 + Description string + DisplayName string + MaxTokenTTL time.Duration + ModifyIndex uint64 + Name string + Namespace string + NamespaceRules []*ACLAuthMethodNamespaceRule + Partition string + TokenLocality string + Type string + func (m *ACLAuthMethod) MarshalJSON() ([]byte, error) + func (m *ACLAuthMethod) UnmarshalJSON(data []byte) error + type ACLAuthMethodListEntry struct + CreateIndex uint64 + Description string + DisplayName string + MaxTokenTTL time.Duration + ModifyIndex uint64 + Name string + Namespace string + Partition string + TokenLocality string + Type string + func (m *ACLAuthMethodListEntry) MarshalJSON() ([]byte, error) + func (m *ACLAuthMethodListEntry) UnmarshalJSON(data []byte) error + type ACLAuthMethodNamespaceRule struct + BindNamespace string + Selector string + type ACLBindingRule struct + AuthMethod string + BindName string + BindType BindingRuleBindType + CreateIndex uint64 + Description string + ID string + ModifyIndex uint64 + Namespace string + Partition string + Selector string + type ACLEntry struct + CreateIndex uint64 + ID string + ModifyIndex uint64 + Name string + Rules string + Type string + type ACLLink struct + ID string + Name string + type ACLLoginParams struct + AuthMethod string + BearerToken string + Meta map[string]string + type ACLNodeIdentity struct + Datacenter string + NodeName 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 ACLPolicy struct + CreateIndex uint64 + Datacenters []string + Description string + Hash []byte + ID string + ModifyIndex uint64 + Name string + Namespace string + Partition string + Rules string + type ACLPolicyListEntry struct + CreateIndex uint64 + Datacenters []string + Description string + Hash []byte + ID string + ModifyIndex uint64 + Name string + Namespace string + Partition string + type ACLReplicationStatus struct + Enabled bool + LastError time.Time + LastErrorMessage string + LastSuccess time.Time + ReplicatedIndex uint64 + ReplicatedRoleIndex uint64 + ReplicatedTokenIndex uint64 + ReplicationType string + Running bool + SourceDatacenter string + type ACLRole struct + CreateIndex uint64 + Description string + Hash []byte + ID string + ModifyIndex uint64 + Name string + Namespace string + NodeIdentities []*ACLNodeIdentity + Partition string + Policies []*ACLRolePolicyLink + ServiceIdentities []*ACLServiceIdentity + type ACLRolePolicyLink = ACLLink + type ACLServiceIdentity struct + Datacenters []string + ServiceName string + type ACLToken struct + AccessorID string + AuthMethod string + AuthMethodNamespace string + CreateIndex uint64 + CreateTime time.Time + Description string + ExpirationTTL time.Duration + ExpirationTime *time.Time + Hash []byte + Local bool + ModifyIndex uint64 + Namespace string + NodeIdentities []*ACLNodeIdentity + Partition string + Policies []*ACLTokenPolicyLink + Roles []*ACLTokenRoleLink + Rules string + SecretID string + ServiceIdentities []*ACLServiceIdentity + type ACLTokenExpanded struct + AgentACLDefaultPolicy string + AgentACLDownPolicy string + ExpandedPolicies []ACLPolicy + ExpandedRoles []ACLRole + NamespaceDefaultPolicyIDs []string + NamespaceDefaultRoleIDs []string + ResolvedByAgent string + type ACLTokenFilterOptions struct + AuthMethod string + Policy string + Role string + ServiceName string + type ACLTokenListEntry struct + AccessorID string + AuthMethod string + AuthMethodNamespace string + CreateIndex uint64 + CreateTime time.Time + Description string + ExpirationTime *time.Time + Hash []byte + Legacy bool + Local bool + ModifyIndex uint64 + Namespace string + NodeIdentities []*ACLNodeIdentity + Partition string + Policies []*ACLTokenPolicyLink + Roles []*ACLTokenRoleLink + SecretID string + ServiceIdentities []*ACLServiceIdentity + type ACLTokenPolicyLink = ACLLink + type ACLTokenRoleLink = ACLLink + 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 struct + func (a *Agent) AgentHealthServiceByID(serviceID string) (string, *AgentServiceChecksInfo, error) + func (a *Agent) AgentHealthServiceByIDOpts(serviceID string, q *QueryOptions) (string, *AgentServiceChecksInfo, error) + func (a *Agent) AgentHealthServiceByName(service string) (string, []AgentServiceChecksInfo, error) + func (a *Agent) AgentHealthServiceByNameOpts(service string, q *QueryOptions) (string, []AgentServiceChecksInfo, error) + func (a *Agent) CheckDeregister(checkID string) error + func (a *Agent) CheckDeregisterOpts(checkID string, q *QueryOptions) error + func (a *Agent) CheckRegister(check *AgentCheckRegistration) error + func (a *Agent) Checks() (map[string]*AgentCheck, error) + func (a *Agent) ChecksWithFilter(filter string) (map[string]*AgentCheck, error) + func (a *Agent) ChecksWithFilterOpts(filter string, q *QueryOptions) (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) DisableNodeMaintenance() error + func (a *Agent) DisableServiceMaintenance(serviceID string) error + func (a *Agent) DisableServiceMaintenanceOpts(serviceID string, q *QueryOptions) error + func (a *Agent) EnableNodeMaintenance(reason string) error + func (a *Agent) EnableServiceMaintenance(serviceID, reason string) error + func (a *Agent) EnableServiceMaintenanceOpts(serviceID, reason string, q *QueryOptions) error + func (a *Agent) FailTTL(checkID, note string) error + func (a *Agent) ForceLeave(node string) error + func (a *Agent) ForceLeaveOptions(node string, opts ForceLeaveOpts, q *QueryOptions) error + func (a *Agent) ForceLeaveOpts(node string, opts ForceLeaveOpts) error + func (a *Agent) ForceLeavePrune(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) MetricsStream(ctx context.Context) (io.ReadCloser, error) + func (a *Agent) Monitor(loglevel string, stopCh <-chan struct{}, q *QueryOptions) (chan string, error) + func (a *Agent) MonitorJSON(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) ServiceDeregisterOpts(serviceID string, q *QueryOptions) error + func (a *Agent) ServiceRegister(service *AgentServiceRegistration) error + func (a *Agent) ServiceRegisterOpts(service *AgentServiceRegistration, opts ServiceRegisterOpts) error + func (a *Agent) Services() (map[string]*AgentService, error) + func (a *Agent) ServicesWithFilter(filter string) (map[string]*AgentService, error) + func (a *Agent) ServicesWithFilterOpts(filter string, q *QueryOptions) (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) UpdateAgentRecoveryACLToken(token string, q *WriteOptions) (*WriteMeta, error) + func (a *Agent) UpdateConfigFileRegistrationToken(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) UpdateTTLOpts(checkID, output, status string, q *QueryOptions) error + func (a *Agent) Version() (map[string]interface{}, 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 + ExposedPort int + Name string + Namespace string + Node string + Notes string + Output string + Partition string + ServiceID string + ServiceName string + Status string + Type string + type AgentCheckRegistration struct + ID string + Name string + Namespace string + Notes string + Partition 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 + func (m *AgentMember) ACLMode() MemberACLMode + func (m *AgentMember) IsConsulServer() bool + type AgentService struct + Address string + Connect *AgentServiceConnect + ContentHash string + CreateIndex uint64 + Datacenter string + EnableTagOverride bool + ID string + Kind ServiceKind + Locality *Locality + Meta map[string]string + ModifyIndex uint64 + Namespace string + Partition string + PeerName string + Port int + Proxy *AgentServiceConnectProxyConfig + Service string + SocketPath string + TaggedAddresses map[string]ServiceAddress + Tags []string + Weights AgentWeights + type AgentServiceCheck struct + AliasNode string + AliasService string + Args []string + Body string + CheckID string + DeregisterCriticalServiceAfter string + DockerContainerID string + FailuresBeforeCritical int + FailuresBeforeWarning int + GRPC string + GRPCUseTLS bool + H2PING string + H2PingUseTLS bool + HTTP string + Header map[string][]string + Interval string + Method string + Name string + Notes string + Shell string + Status string + SuccessBeforePassing int + TCP string + TCPUseTLS bool + TLSServerName string + TLSSkipVerify bool + TTL string + Timeout string + UDP string + type AgentServiceChecks []*AgentServiceCheck + type AgentServiceChecksInfo struct + AggregatedStatus string + Checks HealthChecks + Service *AgentService + type AgentServiceConnect struct + Native bool + SidecarService *AgentServiceRegistration + type AgentServiceConnectProxyConfig struct + AccessLogs *AccessLogsConfig + Config map[string]interface{} + DestinationServiceID string + DestinationServiceName string + EnvoyExtensions []EnvoyExtension + Expose ExposeConfig + LocalServiceAddress string + LocalServicePort int + LocalServiceSocketPath string + MeshGateway MeshGatewayConfig + Mode ProxyMode + TransparentProxy *TransparentProxyConfig + Upstreams []Upstream + type AgentServiceRegistration struct + Address string + Check *AgentServiceCheck + Checks AgentServiceChecks + Connect *AgentServiceConnect + EnableTagOverride bool + ID string + Kind ServiceKind + Locality *Locality + Meta map[string]string + Name string + Namespace string + Partition string + Port int + Proxy *AgentServiceConnectProxyConfig + SocketPath string + TaggedAddresses map[string]ServiceAddress + 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 AssignServiceManualVIPsRequest struct + ManualVIPs []string + Service string + type AssignServiceManualVIPsResponse struct + ServiceFound bool + UnassignedFrom []PeeredServiceName + type AuditHashRequest struct + Input string + type AuditHashResponse struct + Hash string + type AutopilotConfiguration struct + CleanupDeadServers bool + CreateIndex uint64 + DisableUpgradeMigration bool + LastContactThreshold *ReadableDuration + MaxTrailingLogs uint64 + MinQuorum uint + ModifyIndex uint64 + RedundancyZoneTag string + ServerStabilizationTime *ReadableDuration + UpgradeVersionTag string + func NewAutopilotConfiguration() AutopilotConfiguration + 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 BindingRuleBindType string + const BindingRuleBindTypeRole + const BindingRuleBindTypeService + type BootstrapRequest struct + BootstrapSecret string + type CAConfig struct + Config map[string]interface{} + CreateIndex uint64 + ForceWithoutCrossSigning bool + ModifyIndex uint64 + Provider string + State map[string]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) GatewayServices(gateway string, q *QueryOptions) ([]*GatewayService, *QueryMeta, error) + func (c *Catalog) Node(node string, q *QueryOptions) (*CatalogNode, *QueryMeta, error) + func (c *Catalog) NodeServiceList(node string, q *QueryOptions) (*CatalogNodeServiceList, *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 + Namespace string + Node string + Partition string + ServiceID string + type CatalogNode struct + Node *Node + Services map[string]*AgentService + type CatalogNodeServiceList struct + Node *Node + Services []*AgentService + type CatalogRegistration struct + Address string + Check *AgentCheck + Checks HealthChecks + Datacenter string + ID string + Locality *Locality + Node string + NodeMeta map[string]string + Partition string + Service *AgentService + SkipNodeUpdate bool + TaggedAddresses map[string]string + type CatalogService struct + Address string + Checks HealthChecks + CreateIndex uint64 + Datacenter string + ID string + ModifyIndex uint64 + Namespace string + Node string + NodeMeta map[string]string + Partition string + ServiceAddress string + ServiceEnableTagOverride bool + ServiceID string + ServiceLocality *Locality + ServiceMeta map[string]string + ServiceName string + ServicePort int + ServiceProxy *AgentServiceConnectProxyConfig + ServiceTaggedAddresses map[string]ServiceAddress + 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) AddHeader(key, value string) + func (c *Client) Agent() *Agent + func (c *Client) Catalog() *Catalog + func (c *Client) ConfigEntries() *ConfigEntries + func (c *Client) Connect() *Connect + func (c *Client) Coordinate() *Coordinate + func (c *Client) Debug() *Debug + func (c *Client) DiscoveryChain() *DiscoveryChain + func (c *Client) Event() *Event + func (c *Client) Headers() http.Header + func (c *Client) Health() *Health + func (c *Client) Internal() *Internal + func (c *Client) KV() *KV + func (c *Client) LockKey(key string) (*Lock, error) + func (c *Client) LockOpts(opts *LockOptions) (*Lock, error) + func (c *Client) Namespaces() *Namespaces + func (c *Client) Operator() *Operator + func (c *Client) Partitions() *Partitions + func (c *Client) Peerings() *Peerings + 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) SetHeaders(headers http.Header) + func (c *Client) Snapshot() *Snapshot + func (c *Client) Status() *Status + func (c *Client) Txn() *Txn + type ClusterDiscoveryType string + const DiscoveryTypeEDS + const DiscoveryTypeLogicalDNS + const DiscoveryTypeOriginalDST + const DiscoveryTypeStatic + const DiscoveryTypeStrictDNS + type CommonCAProviderConfig struct + CSRMaxConcurrent int + CSRMaxPerSecond float32 + LeafCertTTL time.Duration + RootCertTTL time.Duration + SkipValidate bool + type CompiledDiscoveryChain struct + CustomizationHash string + Datacenter string + Default bool + Namespace string + Nodes map[string]*DiscoveryGraphNode + Protocol string + ServiceMeta map[string]string + ServiceName string + StartNode string + Targets map[string]*DiscoveryTarget + type CompoundServiceName struct + Name string + Namespace string + Partition string + type Condition struct + LastTransitionTime *time.Time + Message string + Reason string + Resource *ResourceReference + Status ConditionStatus + Type string + type ConditionStatus string + const ConditionStatusFalse + const ConditionStatusTrue + const ConditionStatusUnknown + type Config struct + Address string + Datacenter string + HttpAuth *HttpBasicAuth + HttpClient *http.Client + Namespace string + Partition string + PathPrefix string + Scheme string + TLSConfig TLSConfig + Token string + TokenFile string + Transport *http.Transport + WaitTime time.Duration + func DefaultConfig() *Config + func DefaultConfigWithLogger(logger hclog.Logger) *Config + func DefaultNonPooledConfig() *Config + func (c *Config) GenerateEnv() []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) DeleteCAS(kind, name string, index uint64, w *WriteOptions) (bool, *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 + GetMeta func() map[string]string + GetModifyIndex func() uint64 + GetName func() string + GetNamespace func() string + GetPartition func() string + func DecodeConfigEntry(raw map[string]interface{}) (ConfigEntry, error) + func DecodeConfigEntryFromJSON(data []byte) (ConfigEntry, error) + func MakeConfigEntry(kind, name string) (ConfigEntry, error) + type ConfigEntryStatus struct + Conditions []Condition + 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 (c *Connect) IntentionUpsert(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) IntentionDeleteExact(source, destination string, q *WriteOptions) (*WriteMeta, error) + func (h *Connect) IntentionGet(id string, q *QueryOptions) (*Intention, *QueryMeta, error) + func (h *Connect) IntentionGetExact(source, destination 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 + Config map[string]interface{} + ContentHash string + ProxyServiceID string + TargetServiceID string + TargetServiceName string + Upstreams []Upstream + type ConsulCAProviderConfig struct + IntermediateCertTTL time.Duration + PrivateKey string + RootCert string + func ParseConsulCAConfig(raw map[string]interface{}) (*ConsulCAProviderConfig, error) + type CookieConfig struct + Path string + Session bool + TTL time.Duration + 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 + Partition string + Segment string + type Debug struct + func (d *Debug) Goroutine() ([]byte, error) + func (d *Debug) Heap() ([]byte, error) + func (d *Debug) PProf(ctx context.Context, name string, seconds int) (io.ReadCloser, error) + func (d *Debug) Profile(seconds int) ([]byte, error) + func (d *Debug) Trace(seconds int) ([]byte, error) + type DestinationConfig struct + Addresses []string + Port int + 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 + Policy ServiceResolverFailoverPolicy + Targets []string + type DiscoveryGraphNode struct + LoadBalancer *LoadBalancer + 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 + ConnectTimeout time.Duration + Datacenter string + External bool + ID string + MeshGateway MeshGatewayConfig + Name string + Namespace string + SNI string + Service string + ServiceSubset string + Subset ServiceResolverSubset + func (t *DiscoveryTarget) MarshalJSON() ([]byte, error) + func (t *DiscoveryTarget) UnmarshalJSON(data []byte) error + type EnvoyExtension struct + Arguments map[string]interface{} + ConsulVersion string + EnvoyVersion string + Name string + Required bool + 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 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 ExposeConfig struct + Checks bool + Paths []ExposePath + type ExposePath struct + ListenerPort int + LocalPathPort int + ParsedFromCheck bool + Path string + Protocol string + type ForceLeaveOpts struct + Prune bool + WAN bool + type GatewayConditionReason string + type GatewayConditionType 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 + type GatewayServiceTLSConfig struct + SDS *GatewayTLSSDSConfig + type GatewayTLSConfig struct + CipherSuites []string + Enabled bool + SDS *GatewayTLSSDSConfig + TLSMaxVersion string + TLSMinVersion string + type GatewayTLSSDSConfig struct + CertResource string + ClusterName string + type GaugeValue struct + Labels map[string]string + Name string + Value float32 + 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 HTTPHeaderModifiers struct + Add map[string]string + Remove []string + Set map[string]string + 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 HashPolicy struct + CookieConfig *CookieConfig + Field string + FieldValue string + SourceIP bool + Terminal bool + 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) Ingress(service 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 + ExposedPort int + ModifyIndex uint64 + Name string + Namespace string + Node string + Notes string + Output string + Partition string + PeerName string + ServiceID string + ServiceName string + ServiceTags []string + Status string + Type string + type HealthCheckDefinition struct + Body string + DeregisterCriticalServiceAfter ReadableDuration + DeregisterCriticalServiceAfterDuration time.Duration + GRPC string + GRPCUseTLS bool + HTTP string + Header map[string][]string + Interval ReadableDuration + IntervalDuration time.Duration + Method string + OSService string + TCP string + TCPUseTLS bool + TLSServerName string + TLSSkipVerify bool + Timeout ReadableDuration + TimeoutDuration time.Duration + UDP string + func (d *HealthCheckDefinition) MarshalJSON() ([]byte, error) + func (t *HealthCheckDefinition) UnmarshalJSON(data []byte) (err error) + type HealthChecks []*HealthCheck + func (c HealthChecks) AggregatedStatus() string + type HttpBasicAuth struct + Password string + Username string + type IngressGatewayConfigEntry struct + CreateIndex uint64 + Defaults *IngressServiceConfig + Kind string + Listeners []IngressListener + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + Partition string + TLS GatewayTLSConfig + func (i *IngressGatewayConfigEntry) GetCreateIndex() uint64 + func (i *IngressGatewayConfigEntry) GetKind() string + func (i *IngressGatewayConfigEntry) GetMeta() map[string]string + func (i *IngressGatewayConfigEntry) GetModifyIndex() uint64 + func (i *IngressGatewayConfigEntry) GetName() string + func (i *IngressGatewayConfigEntry) GetNamespace() string + func (i *IngressGatewayConfigEntry) GetPartition() string + type IngressListener struct + Port int + Protocol string + Services []IngressService + TLS *GatewayTLSConfig + type IngressService struct + Hosts []string + MaxConcurrentRequests *uint32 + MaxConnections *uint32 + MaxPendingRequests *uint32 + Name string + Namespace string + Partition string + PassiveHealthCheck *PassiveHealthCheck + RequestHeaders *HTTPHeaderModifiers + ResponseHeaders *HTTPHeaderModifiers + TLS *GatewayServiceTLSConfig + type IngressServiceConfig struct + MaxConcurrentRequests *uint32 + MaxConnections *uint32 + MaxPendingRequests *uint32 + 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 Intention struct + Action IntentionAction + CreateIndex uint64 + CreatedAt time.Time + DefaultAddr string + DefaultPort int + Description string + DestinationNS string + DestinationName string + DestinationPartition string + Hash []byte + ID string + Meta map[string]string + ModifyIndex uint64 + Permissions []*IntentionPermission + Precedence int + SourceNS string + SourceName string + SourcePartition string + SourcePeer string + SourceSamenessGroup 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 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 IntentionJWTClaimVerification struct + Path []string + Value string + type IntentionJWTProvider struct + Name string + VerifyClaims []*IntentionJWTClaimVerification + type IntentionJWTRequirement struct + Providers []*IntentionJWTProvider + type IntentionMatch struct + By IntentionMatchType + Names []string + type IntentionMatchType string + const IntentionMatchDestination + const IntentionMatchSource + type IntentionPermission struct + Action IntentionAction + HTTP *IntentionHTTPPermission + JWT *IntentionJWTRequirement + type IntentionSourceType string + const IntentionSourceConsul + 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 JWKSCluster struct + ConnectTimeout time.Duration + DiscoveryType ClusterDiscoveryType + TLSCertificates *JWKSTLSCertificate + type JWKSRetryPolicy struct + NumRetries int + RetryPolicyBackOff *RetryPolicyBackOff + 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 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 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 KVGetOrEmpty + const KVGetTree + const KVLock + const KVSet + const KVUnlock + type KVPair struct + CreateIndex uint64 + Flags uint64 + Key string + LockIndex uint64 + ModifyIndex uint64 + Namespace string + Partition string + Session string + Value []byte + type KVPairs []*KVPair + type KVTxnOp struct + Flags uint64 + Index uint64 + Key string + Namespace string + Partition 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 + Partition string + PrimaryKeys map[string]int + Segment string + WAN bool + 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 LeafCert struct + CertPEM string + CreateIndex uint64 + ModifyIndex uint64 + PrivateKeyPEM string + SerialNumber string + Service string + ServiceURI string + ValidAfter time.Time + ValidBefore time.Time + type LeastRequestConfig struct + ChoiceCount uint32 + type License struct + CustomerID string + ExpirationTime time.Time + Features []string + Flags map[string]interface{} + IgnoreTermination bool + InstallationID string + IssueTime time.Time + LicenseID string + Modules []string + Product string + StartTime time.Time + TerminationTime time.Time + type LicenseReply struct + License *License + Valid bool + Warnings []string + type LinkedService struct + CAFile string + CertFile string + KeyFile string + Name string + Namespace string + SNI string + type LoadBalancer struct + HashPolicies []HashPolicy + LeastRequestConfig *LeastRequestConfig + Policy string + RingHashConfig *RingHashConfig + type LocalJWKS struct + Filename string + JWKS string + type Locality struct + Region string + Zone string + 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 + LockDelay time.Duration + LockTryOnce bool + LockWaitTime time.Duration + MonitorRetries int + MonitorRetryTime time.Duration + Namespace string + Session string + SessionName string + SessionOpts *SessionEntry + SessionTTL string + Value []byte + type LogSinkType string + const DefaultLogSinkType + const FileLogSinkType + const StdErrLogSinkType + const StdOutLogSinkType + type MemberACLMode string + const ACLModeDisabled + const ACLModeEnabled + const ACLModeLegacy + const ACLModeUnknown + type MembersOpts struct + Filter string + Segment string + WAN bool + type MeshConfigEntry struct + AllowEnablingPermissiveMutualTLS bool + CreateIndex uint64 + HTTP *MeshHTTPConfig + Meta map[string]string + ModifyIndex uint64 + Namespace string + Partition string + Peering *PeeringMeshConfig + TLS *MeshTLSConfig + 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) GetPartition() string + func (e *MeshConfigEntry) MarshalJSON() ([]byte, error) + type MeshDirectionalTLSConfig struct + CipherSuites []string + TLSMaxVersion string + TLSMinVersion string + type MeshGatewayConfig struct + Mode MeshGatewayMode + type MeshGatewayMode string + const MeshGatewayModeDefault + const MeshGatewayModeLocal + const MeshGatewayModeNone + const MeshGatewayModeRemote + type MeshHTTPConfig struct + SanitizeXForwardedClientCert bool + type MeshTLSConfig struct + Incoming *MeshDirectionalTLSConfig + Outgoing *MeshDirectionalTLSConfig + type MetricsInfo struct + Counters []SampledValue + Gauges []GaugeValue + Points []PointValue + Samples []SampledValue + Timestamp string + type MutualTLSMode string + const MutualTLSModeDefault + const MutualTLSModePermissive + const MutualTLSModeStrict + type Namespace struct + ACLs *NamespaceACLConfig + CreateIndex uint64 + DeletedAt *time.Time + Description string + Meta map[string]string + ModifyIndex uint64 + Name string + Partition string + func (n *Namespace) UnmarshalJSON(data []byte) error + type NamespaceACLConfig struct + PolicyDefaults []ACLLink + RoleDefaults []ACLLink + func (n *NamespaceACLConfig) UnmarshalJSON(data []byte) error + 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 Node struct + Address string + CreateIndex uint64 + Datacenter string + ID string + Locality *Locality + Meta map[string]string + ModifyIndex uint64 + Node string + Partition string + PeerName 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 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 + OIDCACRValues []string + OIDCClientID string + OIDCClientSecret string + OIDCDiscoveryCACert string + OIDCDiscoveryURL string + OIDCScopes []string + VerboseOIDCLogging bool + func (c *OIDCAuthMethodConfig) RenderToConfig() map[string]interface{} + 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) AuditHash(a *AuditHashRequest, q *QueryOptions) (*AuditHashResponse, 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) AutopilotState(q *QueryOptions) (*AutopilotState, 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) 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) + func (op *Operator) RaftGetConfiguration(q *QueryOptions) (*RaftConfiguration, error) + func (op *Operator) RaftLeaderTransfer(q *QueryOptions) (*TransferLeaderResponse, 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) + func (op *Operator) Usage(q *QueryOptions) (*Usage, *QueryMeta, error) + type OperatorHealthReply struct + FailureTolerance int + Healthy bool + Servers []ServerHealth + type Partition struct + CreateIndex uint64 + DeletedAt *time.Time + Description string + ModifyIndex uint64 + Name string + type Partitions struct + func (p *Partitions) Create(ctx context.Context, partition *Partition, q *WriteOptions) (*Partition, *WriteMeta, error) + func (p *Partitions) Delete(ctx context.Context, name string, q *WriteOptions) (*WriteMeta, error) + func (p *Partitions) List(ctx context.Context, q *QueryOptions) ([]*Partition, *QueryMeta, error) + func (p *Partitions) Read(ctx context.Context, name string, q *QueryOptions) (*Partition, *QueryMeta, error) + func (p *Partitions) Update(ctx context.Context, partition *Partition, q *WriteOptions) (*Partition, *WriteMeta, error) + type PassiveHealthCheck struct + BaseEjectionTime *time.Duration + EnforcingConsecutive5xx *uint32 + Interval time.Duration + MaxEjectionPercent *uint32 + MaxFailures uint32 + type PeeredServiceName struct + Peer string + ServiceName CompoundServiceName + type Peering struct + CreateIndex uint64 + DeletedAt *time.Time + ID string + Meta map[string]string + ModifyIndex uint64 + Name string + Partition string + PeerCAPems []string + PeerID string + PeerServerAddresses []string + PeerServerName string + Remote PeeringRemoteInfo + State PeeringState + StreamStatus PeeringStreamStatus + 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 PeeringMeshConfig struct + PeerThroughMeshGateways bool + type PeeringReadResponse struct + Peering *Peering + type PeeringRemoteInfo struct + Datacenter string + Locality *Locality + Partition string + type PeeringState string + const PeeringStateActive + const PeeringStateDeleting + const PeeringStateEstablishing + const PeeringStateFailing + const PeeringStatePending + const PeeringStateTerminated + const PeeringStateUndefined + type PeeringStreamStatus struct + ExportedServices []string + ImportedServices []string + LastHeartbeat *time.Time + LastReceive *time.Time + LastSend *time.Time + 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 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 + Namespace string + Nodes []ServiceEntry + Service string + type ProxyConfigEntry struct + AccessLogs *AccessLogsConfig + Config map[string]interface{} + CreateIndex uint64 + EnvoyExtensions []EnvoyExtension + Expose ExposeConfig + FailoverPolicy *ServiceResolverFailoverPolicy + Kind string + MeshGateway MeshGatewayConfig + Meta map[string]string + Mode ProxyMode + ModifyIndex uint64 + MutualTLSMode MutualTLSMode + Name string + Namespace string + Partition string + PrioritizeByLocality *ServiceResolverPrioritizeByLocality + TransparentProxy *TransparentProxyConfig + func (p *ProxyConfigEntry) GetCreateIndex() uint64 + func (p *ProxyConfigEntry) GetKind() string + func (p *ProxyConfigEntry) GetMeta() map[string]string + func (p *ProxyConfigEntry) GetModifyIndex() uint64 + func (p *ProxyConfigEntry) GetName() string + func (p *ProxyConfigEntry) GetNamespace() string + func (p *ProxyConfigEntry) GetPartition() string + type ProxyMode string + const ProxyModeDefault + const ProxyModeDirect + const ProxyModeTransparent + type QueryDNSOptions struct + TTL string + type QueryDatacenterOptions = QueryFailoverOptions + type QueryFailoverOptions struct + Datacenters []string + NearestN int + Targets []QueryFailoverTarget + type QueryFailoverTarget struct + Datacenter string + Namespace string + Partition string + Peer string + type QueryMeta struct + AddressTranslationEnabled bool + CacheAge time.Duration + CacheHit bool + DefaultACLPolicy string + KnownLeader bool + LastContact time.Duration + LastContentHash string + LastIndex uint64 + QueryBackend string + RequestTime time.Duration + ResultsFilteredByACLs bool + type QueryOptions struct + AllowStale bool + Connect bool + Datacenter string + Filter string + Global bool + LocalOnly bool + MaxAge time.Duration + MergeCentralConfig bool + Namespace string + Near string + NodeMeta map[string]string + Partition string + Peer 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 + RemoveEmptyTags bool + Type string + type RaftConfiguration struct + Index uint64 + Servers []*RaftServer + type RaftServer struct + Address string + ID string + LastIndex uint64 + Leader bool + Node string + ProtocolVersion string + Voter bool + 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 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 ReadWriteRatesConfig struct + ReadRate float64 + WriteRate float64 + 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) (err error) + type RemoteJWKS struct + CacheDuration time.Duration + FetchAsynchronously bool + JWKSCluster *JWKSCluster + RequestTimeoutMs int + RetryPolicy *JWKSRetryPolicy + URI string + type ResourceReference struct + Kind string + Name string + Namespace string + Partition string + SectionName string + type RetryPolicyBackOff struct + BaseInterval time.Duration + MaxInterval time.Duration + type RingHashConfig struct + MaximumRingSize uint64 + MinimumRingSize uint64 + type RouteConditionReason string + type RouteConditionType string + 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 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 + Namespace string + 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 ServiceAddress struct + Address string + Port int + func ParseServiceAddr(addrPort string) (ServiceAddress, error) + type ServiceCheck struct + ID string + Namespace string + type ServiceConfigEntry struct + BalanceInboundConnections string + CreateIndex uint64 + Destination *DestinationConfig + EnvoyExtensions []EnvoyExtension + Expose ExposeConfig + ExternalSNI string + Kind string + LocalConnectTimeoutMs int + LocalRequestTimeoutMs int + MaxInboundConnections int + MeshGateway MeshGatewayConfig + Meta map[string]string + Mode ProxyMode + ModifyIndex uint64 + MutualTLSMode MutualTLSMode + Name string + Namespace string + Partition string + Protocol string + TransparentProxy *TransparentProxyConfig + UpstreamConfig *UpstreamConfiguration + func (s *ServiceConfigEntry) GetCreateIndex() uint64 + func (s *ServiceConfigEntry) GetKind() string + func (s *ServiceConfigEntry) GetMeta() map[string]string + func (s *ServiceConfigEntry) GetModifyIndex() uint64 + func (s *ServiceConfigEntry) GetName() string + func (s *ServiceConfigEntry) GetNamespace() string + func (s *ServiceConfigEntry) GetPartition() string + type ServiceConsumer struct + Partition string + Peer string + SamenessGroup string + type ServiceEntry struct + Checks HealthChecks + Node *Node + Service *AgentService + type ServiceIntentionsConfigEntry struct + CreateIndex uint64 + JWT *IntentionJWTRequirement + Kind string + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + Partition 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 + func (e *ServiceIntentionsConfigEntry) GetPartition() string + type ServiceKind string + const ServiceKindAPIGateway + const ServiceKindConnectProxy + const ServiceKindIngressGateway + const ServiceKindMeshGateway + const ServiceKindTerminatingGateway + const ServiceKindTypical + type ServiceOp string + const ServiceCAS + const ServiceDelete + const ServiceDeleteCAS + const ServiceGet + const ServiceSet + type ServiceQuery struct + Connect bool + Failover QueryFailoverOptions + IgnoreCheckIDs []string + Namespace string + Near string + NodeMeta map[string]string + OnlyPassing bool + Partition string + SamenessGroup string + Service string + ServiceMeta map[string]string + Tags []string + type ServiceRegisterOpts struct + ReplaceExistingChecks bool + func (o ServiceRegisterOpts) WithContext(ctx context.Context) ServiceRegisterOpts + type ServiceResolverConfigEntry struct + ConnectTimeout time.Duration + CreateIndex uint64 + DefaultSubset string + Failover map[string]ServiceResolverFailover + Kind string + LoadBalancer *LoadBalancer + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + Partition string + PrioritizeByLocality *ServiceResolverPrioritizeByLocality + Redirect *ServiceResolverRedirect + RequestTimeout time.Duration + Subsets map[string]ServiceResolverSubset + func (e *ServiceResolverConfigEntry) GetCreateIndex() uint64 + func (e *ServiceResolverConfigEntry) GetKind() string + func (e *ServiceResolverConfigEntry) GetMeta() map[string]string + func (e *ServiceResolverConfigEntry) GetModifyIndex() uint64 + func (e *ServiceResolverConfigEntry) GetName() string + func (e *ServiceResolverConfigEntry) GetNamespace() string + func (e *ServiceResolverConfigEntry) GetPartition() string + func (e *ServiceResolverConfigEntry) MarshalJSON() ([]byte, error) + func (e *ServiceResolverConfigEntry) UnmarshalJSON(data []byte) error + type ServiceResolverFailover struct + Datacenters []string + Namespace string + Policy *ServiceResolverFailoverPolicy + SamenessGroup string + Service string + ServiceSubset string + Targets []ServiceResolverFailoverTarget + type ServiceResolverFailoverPolicy struct + Mode string + Regions []string + type ServiceResolverFailoverTarget struct + Datacenter string + Namespace string + Partition string + Peer string + Service string + ServiceSubset string + type ServiceResolverPrioritizeByLocality struct + Mode string + type ServiceResolverRedirect struct + Datacenter string + Namespace string + Partition string + Peer string + SamenessGroup string + Service string + ServiceSubset string + type ServiceResolverSubset struct + Filter string + OnlyPassing bool + type ServiceRoute struct + Destination *ServiceRouteDestination + Match *ServiceRouteMatch + type ServiceRouteDestination struct + IdleTimeout time.Duration + Namespace string + NumRetries uint32 + Partition string + PrefixRewrite string + RequestHeaders *HTTPHeaderModifiers + RequestTimeout time.Duration + ResponseHeaders *HTTPHeaderModifiers + RetryOn []string + 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 + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + Partition string + Routes []ServiceRoute + func (e *ServiceRouterConfigEntry) GetCreateIndex() uint64 + func (e *ServiceRouterConfigEntry) GetKind() string + func (e *ServiceRouterConfigEntry) GetMeta() map[string]string + func (e *ServiceRouterConfigEntry) GetModifyIndex() uint64 + func (e *ServiceRouterConfigEntry) GetName() string + func (e *ServiceRouterConfigEntry) GetNamespace() string + func (e *ServiceRouterConfigEntry) GetPartition() string + type ServiceSplit struct + Namespace string + Partition string + RequestHeaders *HTTPHeaderModifiers + ResponseHeaders *HTTPHeaderModifiers + Service string + ServiceSubset string + Weight float32 + type ServiceSplitterConfigEntry struct + CreateIndex uint64 + Kind string + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + Partition string + Splits []ServiceSplit + func (e *ServiceSplitterConfigEntry) GetCreateIndex() uint64 + func (e *ServiceSplitterConfigEntry) GetKind() string + func (e *ServiceSplitterConfigEntry) GetMeta() map[string]string + func (e *ServiceSplitterConfigEntry) GetModifyIndex() uint64 + func (e *ServiceSplitterConfigEntry) GetName() string + func (e *ServiceSplitterConfigEntry) GetNamespace() string + func (e *ServiceSplitterConfigEntry) GetPartition() string + type ServiceTxnOp struct + Node string + Service AgentService + Verb ServiceOp + type ServiceUsage struct + BillableServiceInstances int + ConnectServiceInstances map[string]int + Nodes 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 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 + Namespace string + Node string + NodeChecks []string + ServiceChecks []ServiceCheck + TTL string + type SessionOp string + const SessionDelete + type SessionTxnOp struct + Session Session + Verb SessionOp + type Snapshot struct + func (s *Snapshot) Restore(q *WriteOptions, in io.Reader) error + func (s *Snapshot) Save(q *QueryOptions) (io.ReadCloser, *QueryMeta, error) + type SourceIntention struct + Action IntentionAction + Description string + LegacyCreateTime *time.Time + LegacyID string + LegacyMeta map[string]string + LegacyUpdateTime *time.Time + Name string + Namespace string + Partition string + Peer string + Permissions []*IntentionPermission + Precedence int + SamenessGroup string + Type IntentionSourceType + type Status struct + func (s *Status) Leader() (string, error) + func (s *Status) LeaderWithQueryOptions(q *QueryOptions) (string, error) + func (s *Status) Peers() ([]string, error) + func (s *Status) PeersWithQueryOptions(q *QueryOptions) ([]string, error) + type StatusError struct + Body string + Code int + func (e StatusError) Error() string + 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 TLSConfig struct + Address string + CAFile string + CAPath string + CAPem []byte + CertFile string + CertPEM []byte + InsecureSkipVerify bool + KeyFile string + KeyPEM []byte + type TerminatingGatewayConfigEntry struct + CreateIndex uint64 + Kind string + Meta map[string]string + ModifyIndex uint64 + Name string + Namespace string + Partition string + Services []LinkedService + func (g *TerminatingGatewayConfigEntry) GetCreateIndex() uint64 + func (g *TerminatingGatewayConfigEntry) GetKind() string + func (g *TerminatingGatewayConfigEntry) GetMeta() map[string]string + func (g *TerminatingGatewayConfigEntry) GetModifyIndex() uint64 + func (g *TerminatingGatewayConfigEntry) GetName() string + func (g *TerminatingGatewayConfigEntry) GetNamespace() string + func (g *TerminatingGatewayConfigEntry) GetPartition() string + type TransferLeaderResponse struct + Success bool + type TransparentProxyConfig struct + DialedDirectly bool + OutboundListenerPort int + type TransparentProxyMeshConfig struct + MeshDestinationsOnly bool + 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 URLRewrite struct + Path string + type Upstream struct + CentrallyConfigured bool + Config map[string]interface{} + Datacenter string + DestinationName string + DestinationNamespace string + DestinationPartition string + DestinationPeer string + DestinationType UpstreamDestType + LocalBindAddress string + LocalBindPort int + LocalBindSocketMode string + LocalBindSocketPath string + MeshGateway MeshGatewayConfig + type UpstreamConfig struct + BalanceOutboundConnections string + ConnectTimeoutMs int + EnvoyClusterJSON string + EnvoyListenerJSON string + Limits *UpstreamLimits + MeshGateway MeshGatewayConfig + Name string + Namespace string + Partition string + PassiveHealthCheck *PassiveHealthCheck + Peer string + Protocol string + type UpstreamConfiguration struct + Defaults *UpstreamConfig + Overrides []*UpstreamConfig + type UpstreamDestType string + const UpstreamDestTypePreparedQuery + const UpstreamDestTypeService + type UpstreamLimits struct + MaxConcurrentRequests *int + MaxConnections *int + MaxPendingRequests *int + type Usage struct + Usage map[string]ServiceUsage + 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 + Namespace string + Partition string + RelayFactor uint8 + Token string + func (o *WriteOptions) Context() context.Context + func (o *WriteOptions) WithContext(ctx context.Context) *WriteOptions
Go to main page