Versions in this module Expand all Collapse all v1 v1.16.4 Nov 29, 2024 v0 v0.16.4 Nov 29, 2024 Changes in this version + const ACLAuthMethodDeleteRequestType + const ACLAuthMethodSetRequestType + const ACLBindingRuleDeleteRequestType + const ACLBindingRuleSetRequestType + const ACLBootstrapRequestType + const ACLPolicyDeleteRequestType + const ACLPolicyGlobalManagementDesc + const ACLPolicyGlobalManagementID + const ACLPolicyGlobalManagementName + const ACLPolicyGlobalReadOnlyDesc + const ACLPolicyGlobalReadOnlyID + const ACLPolicyGlobalReadOnlyName + const ACLPolicySetRequestType + const ACLReservedIDPrefix + const ACLRoleDeleteRequestType + const ACLRoleSetRequestType + const ACLTokenDeleteRequestType + const ACLTokenSetRequestType + const APIGateway + const AWSCAProvider + const AreaRequestType + const AutopilotRequestType + const BindingRuleBindTypeNode + const BindingRuleBindTypeRole + const BindingRuleBindTypeService + const BoundAPIGateway + const ChunkingStateType + const ConfigEntryRequestType + const ConnectCAConfigType + const ConnectCALeafRequestType + const ConnectCAProviderStateType + const ConnectCARequestType + const ConnectionExactBalance + const ConsulCAProvider + const ConsulServiceID + const ConsulServiceName + const CoordinateBatchUpdateType + const DefaultIntermediateCertTTL + const DefaultLeafCertTTL + const DefaultPeerKeyword + const DefaultRootCertTTL + const DefaultServiceProtocol + const DeprecatedACLRequestType + const DeregisterRequestType + const DiscoveryGraphNodeTypeResolver + const DiscoveryGraphNodeTypeRouter + const DiscoveryGraphNodeTypeSplitter + const EnterpriseACLPolicyGlobalManagement + const EnterpriseACLPolicyGlobalReadOnly + const ExportedServices + const FederationStateRequestType + const FreeVirtualIPRequestType + const HTTPRoute + const HashPolicyCookie + const HashPolicyHeader + const HashPolicyQueryParam + const IgnoreUnknownTypeFlag + const IndexRequestType + const IngressGateway + const InlineCertificate + const IntentionDataOriginConfigEntries + const IntentionDataOriginLegacy + const IntentionDefaultNamespace + const IntentionRequestType + const JWTProvider + const JitterFraction + const KVSRequestType + const KeyringInstall + const KeyringList + const KeyringRemove + const KeyringUse + const KindServiceNamesType + const LBPolicyLeastRequest + const LBPolicyMaglev + const LBPolicyRandom + const LBPolicyRingHash + const LBPolicyRoundRobin + const LocalPeerKeyword + const MaxLockDelay + const MeshConfig + const MeshConfigMesh + const MetaConsulVersion + const MetaExternalSource + const MetaKeyReservedPrefix + const MetaSegmentKey + const MetaWANFederationKey + const MinKeyLength + const NodeMaint + const PeeringDeleteType + const PeeringSecretsWriteType + const PeeringTerminateByIDType + const PeeringTrustBundleDeleteType + const PeeringTrustBundleWriteType + const PeeringWriteType + const PreparedQueryRequestType + const ProxyConfigGlobal + const ProxyDefaults + const QueryTemplateTypeNamePrefixMatch + const RaftLogVerifierCheckpoint + const RateLimitIPConfig + const RegisterRequestType + const ResourceOperationType + const SamenessGroup + const SerfCheckAliveOutput + const SerfCheckFailedOutput + const SerfCheckID + const SerfCheckName + const ServerManagementTokenAccessorID + const ServiceDefaults + const ServiceIntentions + const ServiceMaintPrefix + const ServiceResolver + const ServiceRouter + const ServiceSplitter + const ServiceVirtualIPRequestType + const SessionRequestType + const SessionTTLMax + const SessionTTLMultiplier + const SidecarProxySuffix + const SystemMetadataIntentionFormatConfigValue + const SystemMetadataIntentionFormatKey + const SystemMetadataIntentionFormatLegacyValue + const SystemMetadataRequestType + const SystemMetadataTermGatewayVirtualIPsEnabled + const SystemMetadataVirtualIPsEnabled + const TCPRoute + const TODOPeerKeyword + const TaggedAddressLAN + const TaggedAddressLANIPv4 + const TaggedAddressLANIPv6 + const TaggedAddressVirtualIP + const TaggedAddressWAN + const TaggedAddressWANIPv4 + const TaggedAddressWANIPv6 + const TerminatingGateway + const TombstoneRequestType + const TopologySourceDefaultAllow + const TopologySourceRegistration + const TopologySourceRoutingConfig + const TopologySourceSpecificIntention + const TopologySourceWildcardIntention + const TxnRequestType + const UpdateVirtualIPRequestType + const UpstreamDestTypePreparedQuery + const UpstreamDestTypeService + const VaultCAProvider + const WildcardSpecifier + var ACLBootstrapInvalidResetIndexErr = errors.New("Invalid ACL bootstrap reset index") + var ACLBootstrapNotAllowedErr = errors.New("ACL bootstrap no longer allowed") + var ACLBuiltinPolicies = map[string]ACLPolicy + var ACLPolicyGlobalManagementRules = fmt.Sprintf(aclPolicyGlobalRulesTemplate, "write") + EnterpriseACLPolicyGlobalManagement + var ACLPolicyGlobalReadOnlyRules = fmt.Sprintf(aclPolicyGlobalRulesTemplate, "read") + EnterpriseACLPolicyGlobalReadOnly + var AllConfigEntryKinds = []string + var ErrDCNotAvailable = errors.New(errDCNotAvailable) + var ErrLeaderNotTracked = errors.New(errLeaderNotTracked) + var ErrNoDCPath = errors.New(errNoDCPath) + var ErrNoLeader = errors.New(errNoLeader) + var ErrNoServers = errors.New(errNoServers) + var ErrNotReadyForConsistentReads = errors.New(errNotReadyForConsistentReads) + var ErrQueryNotFound = errors.New(errQueryNotFound) + var ErrRPCRateExceeded = errors.New(errRPCRateExceeded) + var ErrSegmentsNotSupported = errors.New(errSegmentsNotSupported) + var IntermediateCertRenewInterval = time.Hour + var MaxLeafCertTTL = 365 * 24 * time.Hour + var MinLeafCertTTL = time.Hour + var MsgpackHandle = &codec.MsgpackHandle + var NodeMaintCheckID = NewCheckID(NodeMaint, nil) + var TestingOldPre1dot7MsgpackHandle = &codec.MsgpackHandle + func ACLIDReserved(id string) bool + func ChainID(opts DiscoveryTargetOpts) string + func Decode(buf []byte, out interface{}) error + func DecodeProto(buf []byte, pb proto.Message) error + func DefaultEnterpriseMetaInDefaultPartition() *acl.EnterpriseMeta + func DefaultEnterpriseMetaInPartition(_ string) *acl.EnterpriseMeta + func DurationFromProto(d *durationpb.Duration) time.Duration + func DurationPointer(d time.Duration) *time.Duration + func DurationPointerFromProto(d *durationpb.Duration) *time.Duration + func DurationPointerToProto(d *time.Duration) *durationpb.Duration + func DurationToProto(d time.Duration) *durationpb.Duration + func Encode(t MessageType, msg interface{}) ([]byte, error) + func EncodeProto(t MessageType, pb proto.Message) ([]byte, error) + func EncodeProtoInterface(t MessageType, message interface{}) ([]byte, error) + func HashConfigEntry(conf ConfigEntry) (uint64, error) + func IsConsulServiceID(id ServiceID) bool + func IsErrNoDCPath(err error) bool + func IsErrNoLeader(err error) bool + func IsErrQueryNotFound(err error) bool + func IsErrRPCRateExceeded(err error) bool + func IsErrServiceNotFound(err error) bool + func IsHostname(address string) bool + func IsIP(address string) bool + func IsProtocolHTTPLike(protocol string) bool + func IsSerfCheckID(id CheckID) bool + func IsValidPartitionAndDatacenter(meta acl.EnterpriseMeta, datacenters []string, primaryDatacenter string) bool + func IsZeroProtoTime(t *timestamppb.Timestamp) bool + func NewEnterpriseMetaInDefaultPartition(_ string) acl.EnterpriseMeta + func NewEnterpriseMetaWithPartition(_, _ string) acl.EnterpriseMeta + func NodeEnterpriseMetaInDefaultPartition() *acl.EnterpriseMeta + func NodeEnterpriseMetaInPartition(_ string) *acl.EnterpriseMeta + func NodeNameString(node string, _ *acl.EnterpriseMeta) string + func NormalizeServiceSplitWeight(weight float32) float32 + func ParseDurationFunc() mapstructure.DecodeHookFunc + func ParseServiceIDString(input string) (string, *acl.EnterpriseMeta) + func ParseServiceNameString(input string) (string, *acl.EnterpriseMeta) + func ReplicationEnterpriseMeta() *acl.EnterpriseMeta + func SatisfiesMetaFilters(meta map[string]string, filters map[string]string) bool + func ServiceGatewayVirtualIPTag(sn ServiceName) string + func ServiceIDString(id string, _ *acl.EnterpriseMeta) string + func TestMsgpackEncodeDecode(t *testing.T, in interface{}, requireEncoderEquality bool) + func TimeFromProto(s *timestamppb.Timestamp) time.Time + func TimeToProto(s time.Time) *timestamppb.Timestamp + func Uint8ToString(bs []uint8) string + func UniqueID(node string, compoundID string) string + func ValidStatus(s string) bool + func ValidateMetaTags(metaTags map[string]string) error + func ValidateNodeMetadata(meta map[string]string, allowConsulPrefix bool) error + func ValidateServiceMetadata(kind ServiceKind, meta map[string]string, allowConsulPrefix bool) error + func ValidateWeights(weights *Weights) error + func WildcardEnterpriseMetaInDefaultPartition() *acl.EnterpriseMeta + func WildcardEnterpriseMetaInPartition(_ string) *acl.EnterpriseMeta + type ACLAuthMethod struct + Config map[string]interface{} + Description string + DisplayName string + MaxTokenTTL time.Duration + Name string + TokenLocality string + Type string + func (m *ACLAuthMethod) MarshalJSON() ([]byte, error) + func (m *ACLAuthMethod) UnmarshalJSON(data []byte) (err error) + func (p *ACLAuthMethod) Stub() *ACLAuthMethodListStub + type ACLAuthMethodBatchDeleteRequest struct + AuthMethodNames []string + type ACLAuthMethodBatchSetRequest struct + AuthMethods ACLAuthMethods + type ACLAuthMethodDeleteRequest struct + AuthMethodName string + Datacenter string + func (r *ACLAuthMethodDeleteRequest) RequestDatacenter() string + type ACLAuthMethodEnterpriseFields struct + type ACLAuthMethodEnterpriseMeta struct + func (_ *ACLAuthMethodEnterpriseMeta) FillWithEnterpriseMeta(_ *acl.EnterpriseMeta) + func (_ *ACLAuthMethodEnterpriseMeta) ToEnterpriseMeta() *acl.EnterpriseMeta + type ACLAuthMethodGetRequest struct + AuthMethodName string + Datacenter string + func (r *ACLAuthMethodGetRequest) RequestDatacenter() string + type ACLAuthMethodListRequest struct + Datacenter string + func (r *ACLAuthMethodListRequest) RequestDatacenter() string + type ACLAuthMethodListResponse struct + AuthMethods ACLAuthMethodListStubs + type ACLAuthMethodListStub struct + CreateIndex uint64 + Description string + DisplayName string + MaxTokenTTL time.Duration + ModifyIndex uint64 + Name string + TokenLocality string + Type string + func (m *ACLAuthMethodListStub) MarshalJSON() ([]byte, error) + type ACLAuthMethodListStubs []*ACLAuthMethodListStub + func (methods ACLAuthMethodListStubs) Sort() + type ACLAuthMethodResponse struct + AuthMethod *ACLAuthMethod + type ACLAuthMethodSetRequest struct + AuthMethod ACLAuthMethod + Datacenter string + func (r *ACLAuthMethodSetRequest) RequestDatacenter() string + type ACLAuthMethods []*ACLAuthMethod + func (methods ACLAuthMethods) Sort() + type ACLAuthorizationRequest struct + Access string + Resource acl.Resource + Segment string + type ACLAuthorizationResponse struct + Allow bool + func CreateACLAuthorizationResponses(authz acl.Authorizer, requests []ACLAuthorizationRequest) ([]ACLAuthorizationResponse, error) + type ACLBindingRule struct + AuthMethod string + BindName string + BindType string + Description string + ID string + Selector string + func (r *ACLBindingRule) Clone() *ACLBindingRule + type ACLBindingRuleBatchDeleteRequest struct + BindingRuleIDs []string + type ACLBindingRuleBatchSetRequest struct + BindingRules ACLBindingRules + type ACLBindingRuleDeleteRequest struct + BindingRuleID string + Datacenter string + func (r *ACLBindingRuleDeleteRequest) RequestDatacenter() string + type ACLBindingRuleGetRequest struct + BindingRuleID string + Datacenter string + func (r *ACLBindingRuleGetRequest) RequestDatacenter() string + type ACLBindingRuleListRequest struct + AuthMethod string + Datacenter string + func (r *ACLBindingRuleListRequest) RequestDatacenter() string + type ACLBindingRuleListResponse struct + BindingRules ACLBindingRules + type ACLBindingRuleResponse struct + BindingRule *ACLBindingRule + type ACLBindingRuleSetRequest struct + BindingRule ACLBindingRule + Datacenter string + func (r *ACLBindingRuleSetRequest) RequestDatacenter() string + type ACLBindingRules []*ACLBindingRule + func (rules ACLBindingRules) Sort() + type ACLCaches struct + func NewACLCaches(config *ACLCachesConfig) (*ACLCaches, error) + func (c *ACLCaches) GetAuthorizer(id string) *AuthorizerCacheEntry + func (c *ACLCaches) GetIdentity(id string) *IdentityCacheEntry + func (c *ACLCaches) GetIdentityWithSecretToken(secretToken string) *IdentityCacheEntry + func (c *ACLCaches) GetParsedPolicy(id string) *ParsedPolicyCacheEntry + func (c *ACLCaches) GetPolicy(policyID string) *PolicyCacheEntry + func (c *ACLCaches) GetRole(roleID string) *RoleCacheEntry + func (c *ACLCaches) Purge() + func (c *ACLCaches) PutAuthorizer(id string, authorizer acl.Authorizer) + func (c *ACLCaches) PutIdentity(id string, ident ACLIdentity) + func (c *ACLCaches) PutIdentityWithSecretToken(secretToken string, identity ACLIdentity) + func (c *ACLCaches) PutParsedPolicy(id string, policy *acl.Policy) + func (c *ACLCaches) PutPolicy(policyId string, policy *ACLPolicy) + func (c *ACLCaches) PutRole(roleID string, role *ACLRole) + func (c *ACLCaches) RemoveIdentity(id string) + func (c *ACLCaches) RemoveIdentityWithSecretToken(secretToken string) + func (c *ACLCaches) RemovePolicy(policyID string) + func (c *ACLCaches) RemoveRole(roleID string) + type ACLCachesConfig struct + Authorizers int + Identities int + ParsedPolicies int + Policies int + Roles int + type ACLIdentity interface + EnterpriseMetadata func() *acl.EnterpriseMeta + ID func() string + IsExpired func(asOf time.Time) bool + IsLocal func() bool + NodeIdentityList func() []*ACLNodeIdentity + PolicyIDs func() []string + RoleIDs func() []string + SecretToken func() string + ServiceIdentityList func() []*ACLServiceIdentity + type ACLInitialTokenBootstrapRequest struct + BootstrapSecret string + Datacenter string + func (r *ACLInitialTokenBootstrapRequest) RequestDatacenter() string + type ACLLoginParams struct + AuthMethod string + BearerToken string + Meta map[string]string + type ACLLoginRequest struct + Auth *ACLLoginParams + Datacenter string + func (r *ACLLoginRequest) RequestDatacenter() string + type ACLLogoutRequest struct + Datacenter string + func (r *ACLLogoutRequest) RequestDatacenter() string + type ACLMode string + const ACLModeDisabled + const ACLModeEnabled + type ACLNodeIdentities []*ACLNodeIdentity + func (ids ACLNodeIdentities) Deduplicate() ACLNodeIdentities + type ACLNodeIdentity struct + Datacenter string + NodeName string + func (s *ACLNodeIdentity) AddToHash(h hash.Hash) + func (s *ACLNodeIdentity) Clone() *ACLNodeIdentity + func (s *ACLNodeIdentity) EstimateSize() int + func (s *ACLNodeIdentity) SyntheticPolicy(entMeta *acl.EnterpriseMeta) *ACLPolicy + type ACLPolicies []*ACLPolicy + func (policies ACLPolicies) Compile(cache *ACLCaches, entConf *acl.Config) (acl.Authorizer, error) + func (policies ACLPolicies) HashKey() string + func (policies ACLPolicies) Sort() + type ACLPolicy struct + Datacenters []string + Description string + Hash []byte + ID string + Name string + Rules string + func (p *ACLPolicy) Clone() *ACLPolicy + func (p *ACLPolicy) EnterprisePolicyMeta() *acl.EnterprisePolicyMeta + func (p *ACLPolicy) EstimateSize() int + func (p *ACLPolicy) SetHash(force bool) []byte + func (p *ACLPolicy) Stub() *ACLPolicyListStub + func (t *ACLPolicy) UnmarshalJSON(data []byte) error + type ACLPolicyBatchDeleteRequest struct + PolicyIDs []string + type ACLPolicyBatchGetRequest struct + Datacenter string + PolicyIDs []string + func (r *ACLPolicyBatchGetRequest) RequestDatacenter() string + type ACLPolicyBatchResponse struct + Policies []*ACLPolicy + type ACLPolicyBatchSetRequest struct + Policies ACLPolicies + type ACLPolicyDeleteRequest struct + Datacenter string + PolicyID string + func (r *ACLPolicyDeleteRequest) RequestDatacenter() string + type ACLPolicyGetRequest struct + Datacenter string + PolicyID string + PolicyName string + func (r *ACLPolicyGetRequest) RequestDatacenter() string + type ACLPolicyListRequest struct + Datacenter string + func (r *ACLPolicyListRequest) RequestDatacenter() string + type ACLPolicyListResponse struct + Policies ACLPolicyListStubs + type ACLPolicyListStub struct + CreateIndex uint64 + Datacenters []string + Description string + Hash []byte + ID string + ModifyIndex uint64 + Name string + type ACLPolicyListStubs []*ACLPolicyListStub + func (policies ACLPolicyListStubs) Sort() + type ACLPolicyResponse struct + Policy *ACLPolicy + type ACLPolicySetRequest struct + Datacenter string + Policy ACLPolicy + func (r *ACLPolicySetRequest) RequestDatacenter() string + type ACLReplicationStatus struct + Enabled bool + LastError time.Time + LastErrorMessage string + LastSuccess time.Time + ReplicatedIndex uint64 + ReplicatedRoleIndex uint64 + ReplicatedTokenIndex uint64 + ReplicationType ACLReplicationType + Running bool + SourceDatacenter string + type ACLReplicationType string + const ACLReplicatePolicies + const ACLReplicateRoles + const ACLReplicateTokens + func (t ACLReplicationType) SingularNoun() string + type ACLRole struct + Description string + Hash []byte + ID string + Name string + NodeIdentities ACLNodeIdentities + Policies []ACLRolePolicyLink + ServiceIdentities ACLServiceIdentities + func (r *ACLRole) Clone() *ACLRole + func (r *ACLRole) EstimateSize() int + func (r *ACLRole) NodeIdentityList() []*ACLNodeIdentity + func (r *ACLRole) SetHash(force bool) []byte + func (t *ACLRole) UnmarshalJSON(data []byte) error + type ACLRoleBatchDeleteRequest struct + RoleIDs []string + type ACLRoleBatchGetRequest struct + Datacenter string + RoleIDs []string + func (r *ACLRoleBatchGetRequest) RequestDatacenter() string + type ACLRoleBatchResponse struct + Roles []*ACLRole + type ACLRoleBatchSetRequest struct + AllowMissingLinks bool + Roles ACLRoles + type ACLRoleDeleteRequest struct + Datacenter string + RoleID string + func (r *ACLRoleDeleteRequest) RequestDatacenter() string + type ACLRoleGetRequest struct + Datacenter string + RoleID string + RoleName string + func (r *ACLRoleGetRequest) RequestDatacenter() string + type ACLRoleListRequest struct + Datacenter string + Policy string + func (r *ACLRoleListRequest) RequestDatacenter() string + type ACLRoleListResponse struct + Roles ACLRoles + type ACLRolePolicyLink struct + ID string + Name string + type ACLRoleResponse struct + Role *ACLRole + type ACLRoleSetRequest struct + Datacenter string + Role ACLRole + func (r *ACLRoleSetRequest) RequestDatacenter() string + type ACLRoles []*ACLRole + func (roles ACLRoles) HashKey() string + func (roles ACLRoles) Sort() + type ACLServerIdentity struct + func NewACLServerIdentity(secretID string) *ACLServerIdentity + func (i *ACLServerIdentity) EnterpriseMetadata() *acl.EnterpriseMeta + func (i *ACLServerIdentity) ID() string + func (i *ACLServerIdentity) IsExpired(asOf time.Time) bool + func (i *ACLServerIdentity) IsLocal() bool + func (i *ACLServerIdentity) NodeIdentityList() []*ACLNodeIdentity + func (i *ACLServerIdentity) PolicyIDs() []string + func (i *ACLServerIdentity) RoleIDs() []string + func (i *ACLServerIdentity) SecretToken() string + func (i *ACLServerIdentity) ServiceIdentityList() []*ACLServiceIdentity + type ACLServiceIdentities []*ACLServiceIdentity + func (ids ACLServiceIdentities) Deduplicate() ACLServiceIdentities + type ACLServiceIdentity struct + Datacenters []string + ServiceName string + func (s *ACLServiceIdentity) AddToHash(h hash.Hash) + func (s *ACLServiceIdentity) Clone() *ACLServiceIdentity + func (s *ACLServiceIdentity) EstimateSize() int + func (s *ACLServiceIdentity) SyntheticPolicy(entMeta *acl.EnterpriseMeta) *ACLPolicy + type ACLToken struct + AccessorID string + AuthMethod string + CreateTime time.Time + Description string + ExpirationTTL time.Duration + ExpirationTime *time.Time + Hash []byte + Local bool + NodeIdentities ACLNodeIdentities + Policies []ACLTokenPolicyLink + Roles []ACLTokenRoleLink + SecretID string + ServiceIdentities ACLServiceIdentities + func (t *ACLToken) Clone() *ACLToken + func (t *ACLToken) EnterpriseMetadata() *acl.EnterpriseMeta + func (t *ACLToken) EstimateSize() int + func (t *ACLToken) HasExpirationTime() bool + func (t *ACLToken) ID() string + func (t *ACLToken) IsExpired(asOf time.Time) bool + func (t *ACLToken) IsLocal() bool + func (t *ACLToken) NodeIdentityList() []*ACLNodeIdentity + func (t *ACLToken) PolicyIDs() []string + func (t *ACLToken) RoleIDs() []string + func (t *ACLToken) SecretToken() string + func (t *ACLToken) ServiceIdentityList() []*ACLServiceIdentity + func (t *ACLToken) SetHash(force bool) []byte + func (t *ACLToken) UnmarshalJSON(data []byte) (err error) + func (token *ACLToken) Stub() *ACLTokenListStub + type ACLTokenBatchDeleteRequest struct + TokenIDs []string + type ACLTokenBatchGetRequest struct + AccessorIDs []string + Datacenter string + func (r *ACLTokenBatchGetRequest) RequestDatacenter() string + type ACLTokenBatchResponse struct + Redacted bool + Removed bool + Tokens []*ACLToken + type ACLTokenBatchSetRequest struct + AllowMissingLinks bool + CAS bool + FromReplication bool + ProhibitUnprivileged bool + Tokens ACLTokens + type ACLTokenBootstrapRequest struct + ResetIndex uint64 + Token ACLToken + type ACLTokenDeleteRequest struct + Datacenter string + TokenID string + func (r *ACLTokenDeleteRequest) RequestDatacenter() string + type ACLTokenExpanded struct + type ACLTokenGetRequest struct + Datacenter string + Expanded bool + TokenID string + TokenIDType ACLTokenIDType + func (r *ACLTokenGetRequest) RequestDatacenter() string + type ACLTokenIDType string + const ACLTokenAccessor + const ACLTokenSecret + type ACLTokenListRequest struct + AuthMethod string + Datacenter string + IncludeGlobal bool + IncludeLocal bool + Policy string + Role string + ServiceName string + func (r *ACLTokenListRequest) RequestDatacenter() string + type ACLTokenListResponse struct + Tokens ACLTokenListStubs + type ACLTokenListStub struct + AccessorID string + AuthMethod string + CreateIndex uint64 + CreateTime time.Time + Description string + ExpirationTime *time.Time + Hash []byte + Local bool + ModifyIndex uint64 + NodeIdentities ACLNodeIdentities + Policies []ACLTokenPolicyLink + Roles []ACLTokenRoleLink + SecretID string + ServiceIdentities ACLServiceIdentities + type ACLTokenListStubs []*ACLTokenListStub + func (tokens ACLTokenListStubs) Sort() + type ACLTokenPolicyLink struct + ID string + Name string + type ACLTokenResponse struct + Redacted bool + SourceDatacenter string + Token *ACLToken + type ACLTokenRoleLink struct + ID string + Name string + type ACLTokenSetRequest struct + ACLToken ACLToken + Create bool + Datacenter string + func (r *ACLTokenSetRequest) RequestDatacenter() string + type ACLTokens []*ACLToken + func (tokens ACLTokens) Sort() + type APIGatewayConfigEntry struct + Hash uint64 + Kind string + Listeners []APIGatewayListener + Meta map[string]string + Name string + Status Status + func (e *APIGatewayConfigEntry) CanRead(authz acl.Authorizer) error + func (e *APIGatewayConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *APIGatewayConfigEntry) DefaultStatus() Status + func (e *APIGatewayConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *APIGatewayConfigEntry) GetHash() uint64 + func (e *APIGatewayConfigEntry) GetKind() string + func (e *APIGatewayConfigEntry) GetMeta() map[string]string + func (e *APIGatewayConfigEntry) GetName() string + func (e *APIGatewayConfigEntry) GetRaftIndex() *RaftIndex + func (e *APIGatewayConfigEntry) GetStatus() Status + func (e *APIGatewayConfigEntry) ListenerIsReady(name string) bool + func (e *APIGatewayConfigEntry) Normalize() error + func (e *APIGatewayConfigEntry) SetHash(h uint64) + func (e *APIGatewayConfigEntry) SetStatus(status Status) + func (e *APIGatewayConfigEntry) Validate() error + type APIGatewayListener struct + Hostname string + Name string + Port int + Protocol APIGatewayListenerProtocol + TLS APIGatewayTLSConfiguration + func (l APIGatewayListener) GetHostname() string + func (o *APIGatewayListener) DeepCopy() *APIGatewayListener + type APIGatewayListenerProtocol string + const ListenerProtocolHTTP + const ListenerProtocolTCP + type APIGatewayTLSConfiguration struct + Certificates []ResourceReference + CipherSuites []types.TLSCipherSuite + MaxVersion types.TLSVersion + MinVersion types.TLSVersion + func (a *APIGatewayTLSConfiguration) IsEmpty() bool + type AWSCAProviderConfig struct + DeleteOnExit bool + ExistingARN string + type AccessLogsConfig struct + DisableListenerLogs bool + Enabled bool + JSONFormat string + Path string + TextFormat string + Type LogSinkType + func (c *AccessLogsConfig) IsZero() bool + func (c *AccessLogsConfig) ToAPI() *api.AccessLogsConfig + func (c *AccessLogsConfig) Validate() error + type AgentRecoveryTokenIdentity struct + func NewAgentRecoveryTokenIdentity(agent string, secretID string) *AgentRecoveryTokenIdentity + func (id *AgentRecoveryTokenIdentity) EnterpriseMetadata() *acl.EnterpriseMeta + func (id *AgentRecoveryTokenIdentity) ID() string + func (id *AgentRecoveryTokenIdentity) IsExpired(asOf time.Time) bool + func (id *AgentRecoveryTokenIdentity) IsLocal() bool + func (id *AgentRecoveryTokenIdentity) NodeIdentityList() []*ACLNodeIdentity + func (id *AgentRecoveryTokenIdentity) PolicyIDs() []string + func (id *AgentRecoveryTokenIdentity) RoleIDs() []string + func (id *AgentRecoveryTokenIdentity) SecretToken() string + func (id *AgentRecoveryTokenIdentity) ServiceIdentityList() []*ACLServiceIdentity + type AssignServiceManualVIPsRequest struct + ManualVIPs []string + Service string + type AssignServiceManualVIPsResponse struct + Found bool + UnassignedFrom []PeeredServiceName + type AuthorizerCacheEntry struct + Authorizer acl.Authorizer + CacheTime time.Time + TTL time.Duration + func (e *AuthorizerCacheEntry) Age() time.Duration + type AutopilotConfig struct + CleanupDeadServers bool + CreateIndex uint64 + DisableUpgradeMigration bool + LastContactThreshold time.Duration + MaxTrailingLogs uint64 + MinQuorum uint + ModifyIndex uint64 + RedundancyZoneTag string + ServerStabilizationTime time.Duration + UpgradeVersionTag string + func (c *AutopilotConfig) ToAutopilotLibraryConfig() *autopilot.Config + type AutopilotHealthReply struct + FailureTolerance int + Healthy bool + Servers []AutopilotServerHealth + type AutopilotServerHealth struct + Address string + Healthy bool + ID string + LastContact time.Duration + LastIndex uint64 + LastTerm uint64 + Leader bool + Name string + SerfStatus serf.MemberStatus + StableSince time.Time + Version string + Voter bool + type AutopilotSetConfigRequest struct + CAS bool + Config AutopilotConfig + Datacenter string + func (op *AutopilotSetConfigRequest) RequestDatacenter() string + type BoundAPIGatewayConfigEntry struct + Hash uint64 + Kind string + Listeners []BoundAPIGatewayListener + Meta map[string]string + Name string + Services ServiceRouteReferences + func (e *BoundAPIGatewayConfigEntry) CanRead(authz acl.Authorizer) error + func (e *BoundAPIGatewayConfigEntry) CanWrite(_ acl.Authorizer) error + func (e *BoundAPIGatewayConfigEntry) DefaultStatus() Status + func (e *BoundAPIGatewayConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *BoundAPIGatewayConfigEntry) GetHash() uint64 + func (e *BoundAPIGatewayConfigEntry) GetKind() string + func (e *BoundAPIGatewayConfigEntry) GetMeta() map[string]string + func (e *BoundAPIGatewayConfigEntry) GetName() string + func (e *BoundAPIGatewayConfigEntry) GetRaftIndex() *RaftIndex + func (e *BoundAPIGatewayConfigEntry) GetStatus() Status + func (e *BoundAPIGatewayConfigEntry) IsInitializedForGateway(gateway *APIGatewayConfigEntry) bool + func (e *BoundAPIGatewayConfigEntry) IsSame(other *BoundAPIGatewayConfigEntry) bool + func (e *BoundAPIGatewayConfigEntry) ListRelatedServices() []ServiceID + func (e *BoundAPIGatewayConfigEntry) Normalize() error + func (e *BoundAPIGatewayConfigEntry) SetHash(h uint64) + func (e *BoundAPIGatewayConfigEntry) SetStatus(status Status) + func (e *BoundAPIGatewayConfigEntry) Validate() error + func (o *BoundAPIGatewayConfigEntry) DeepCopy() *BoundAPIGatewayConfigEntry + type BoundAPIGatewayListener struct + Certificates []ResourceReference + Name string + Routes []ResourceReference + func (l *BoundAPIGatewayListener) BindRoute(routeRef ResourceReference) bool + func (l *BoundAPIGatewayListener) UnbindRoute(route ResourceReference) bool + func (l BoundAPIGatewayListener) IsSame(other BoundAPIGatewayListener) bool + func (o *BoundAPIGatewayListener) DeepCopy() *BoundAPIGatewayListener + type BoundRoute interface + GetParents func() []ResourceReference + GetProtocol func() APIGatewayListenerProtocol + GetServiceNames func() []ServiceName + type CAConfiguration struct + ClusterID string + Config map[string]interface{} + ForceWithoutCrossSigning bool + Provider string + State map[string]string + func (c *CAConfiguration) GetCommonConfig() (*CommonCAProviderConfig, error) + func (c *CAConfiguration) UnmarshalJSON(data []byte) (err error) + type CAConsulProviderState struct + ID string + IntermediateCert string + PrivateKey string + RootCert string + type CALeafOp string + const CALeafOpIncrementIndex + type CALeafRequest struct + Datacenter string + Op CALeafOp + func (q *CALeafRequest) RequestDatacenter() string + type CAOp string + const CAOpDeleteProviderState + const CAOpIncrementProviderSerialNumber + const CAOpSetConfig + const CAOpSetProviderState + const CAOpSetRoots + const CAOpSetRootsAndConfig + type CARequest struct + Config *CAConfiguration + Datacenter string + Index uint64 + Op CAOp + ProviderState *CAConsulProviderState + Roots []*CARoot + func (q *CARequest) RequestDatacenter() string + type CARoot struct + Active bool + ExternalTrustDomain string + ID string + IntermediateCerts []string + Name string + NotAfter time.Time + NotBefore time.Time + PrivateKeyBits int + PrivateKeyType string + RootCert string + RotatedOutAt time.Time + SerialNumber uint64 + SigningCert string + SigningKey string + SigningKeyID string + func (c *CARoot) Clone() *CARoot + func (o *CARoot) DeepCopy() *CARoot + type CARoots []*CARoot + func (c CARoots) Active() *CARoot + type CASignRequest struct + CSR string + Datacenter string + func (q *CASignRequest) RequestDatacenter() string + type CatalogContents struct + Checks []*HealthCheck + Nodes []*Node + Services []*ServiceNode + type CatalogSummary struct + Checks []HealthSummary + Nodes []HealthSummary + Services []HealthSummary + type CheckDefinition struct + AliasNode string + AliasService string + Body string + DeregisterCriticalServiceAfter time.Duration + DisableRedirects bool + DockerContainerID string + FailuresBeforeCritical int + FailuresBeforeWarning int + GRPC string + GRPCUseTLS bool + H2PING string + H2PingUseTLS bool + HTTP string + Header map[string][]string + ID types.CheckID + Interval time.Duration + Method string + Name string + Notes string + OSService string + OutputMaxSize int + ScriptArgs []string + ServiceID string + Shell string + Status string + SuccessBeforePassing int + TCP string + TCPUseTLS bool + TLSServerName string + TLSSkipVerify bool + TTL time.Duration + Timeout time.Duration + Token string + UDP string + func (c *CheckDefinition) CheckType() *CheckType + func (c *CheckDefinition) HealthCheck(node string) *HealthCheck + func (t *CheckDefinition) UnmarshalJSON(data []byte) (err error) + type CheckID struct + ID types.CheckID + func NewCheckID(id types.CheckID, entMeta *acl.EnterpriseMeta) CheckID + func (c CheckID) NamespaceOrDefault() string + func (c CheckID) PartitionOrDefault() string + func (cid CheckID) String() string + func (cid CheckID) StringHashMD5() string + func (cid CheckID) StringHashSHA256() string + type CheckServiceNode struct + Checks HealthChecks + Node *Node + Service *NodeService + func TestCheckNodeServiceWithNameInPeer(t testing.T, name, dc, peer, ip string, useHostname bool, ...) CheckServiceNode + func (csn *CheckServiceNode) BestAddress(wan bool) (uint64, string, int) + func (csn *CheckServiceNode) CanRead(authz acl.Authorizer) acl.EnforcementDecision + func (o *CheckServiceNode) DeepCopy() *CheckServiceNode + type CheckServiceNodes []CheckServiceNode + func (csns CheckServiceNodes) DeepCopy() CheckServiceNodes + func (nodes CheckServiceNodes) Filter(onlyPassing bool) CheckServiceNodes + func (nodes CheckServiceNodes) FilterIgnore(onlyPassing bool, ignoreCheckIDs []types.CheckID) CheckServiceNodes + func (nodes CheckServiceNodes) ShallowClone() CheckServiceNodes + func (nodes CheckServiceNodes) Shuffle() + func (nodes CheckServiceNodes) ToServiceDump() ServiceDump + type CheckType struct + AliasNode string + AliasService string + Body string + CheckID types.CheckID + DeregisterCriticalServiceAfter time.Duration + DisableRedirects bool + DockerContainerID string + FailuresBeforeCritical int + FailuresBeforeWarning int + GRPC string + GRPCUseTLS bool + H2PING string + H2PingUseTLS bool + HTTP string + Header map[string][]string + Interval time.Duration + Method string + Name string + Notes string + OSService string + OutputMaxSize int + ProxyGRPC string + ProxyHTTP string + ScriptArgs []string + Shell string + Status string + SuccessBeforePassing int + TCP string + TCPUseTLS bool + TLSServerName string + TLSSkipVerify bool + TTL time.Duration + Timeout time.Duration + UDP string + func (c *CheckType) Empty() bool + func (c *CheckType) IsAlias() bool + func (c *CheckType) IsDocker() bool + func (c *CheckType) IsGRPC() bool + func (c *CheckType) IsH2PING() bool + func (c *CheckType) IsHTTP() bool + func (c *CheckType) IsMonitor() bool + func (c *CheckType) IsOSService() bool + func (c *CheckType) IsScript() bool + func (c *CheckType) IsTCP() bool + func (c *CheckType) IsTTL() bool + func (c *CheckType) IsUDP() bool + func (c *CheckType) Type() string + func (c *CheckType) Validate() error + func (o *CheckType) DeepCopy() *CheckType + func (t *CheckType) UnmarshalJSON(data []byte) (err error) + type CheckTypes []*CheckType + type ChecksInStateRequest struct + Datacenter string + NodeMetaFilters map[string]string + PeerName string + Source QuerySource + State string + func (r *ChecksInStateRequest) RequestDatacenter() string + type ClusterDiscoveryType string + const DefaultClockSkewSeconds + const DiscoveryTypeEDS + const DiscoveryTypeLogicalDNS + const DiscoveryTypeOriginalDST + const DiscoveryTypeStatic + const DiscoveryTypeStrictDNS + func (d ClusterDiscoveryType) Validate() error + type CommonCAProviderConfig struct + CSRMaxConcurrent int + CSRMaxPerSecond float32 + IntermediateCertTTL time.Duration + LeafCertTTL time.Duration + PrivateKeyBits int + PrivateKeyType string + RootCertTTL time.Duration + SkipValidate bool + func (c CommonCAProviderConfig) Validate() error + type CompiledDiscoveryChain struct + AutoVirtualIPs []string + CustomizationHash string + Datacenter string + Default bool + EnvoyExtensions []EnvoyExtension + ManualVirtualIPs []string + Namespace string + Nodes map[string]*DiscoveryGraphNode + Partition string + Protocol string + ServiceMeta map[string]string + ServiceName string + StartNode string + Targets map[string]*DiscoveryTarget + func (c *CompiledDiscoveryChain) CompoundServiceName() ServiceName + func (c *CompiledDiscoveryChain) ID() string + func (o *CompiledDiscoveryChain) DeepCopy() *CompiledDiscoveryChain + type CompoundResponse interface + Add func(interface{}) + New func() interface{} + type Condition struct + LastTransitionTime *time.Time + Message string + Reason string + Resource *ResourceReference + Status string + Type string + func NewGatewayCondition(name api.GatewayConditionType, status api.ConditionStatus, ...) Condition + func NewRouteCondition(name api.RouteConditionType, status api.ConditionStatus, ...) Condition + func (c *Condition) IsCondition(other *Condition) bool + func (c *Condition) IsSame(other *Condition) bool + type ConfigEntry interface + CanRead func(acl.Authorizer) error + CanWrite func(acl.Authorizer) error + GetEnterpriseMeta func() *acl.EnterpriseMeta + GetHash func() uint64 + GetKind func() string + GetMeta func() map[string]string + GetName func() string + GetRaftIndex func() *RaftIndex + Normalize func() error + SetHash func(h uint64) + Validate func() error + func DecodeConfigEntry(raw map[string]interface{}) (ConfigEntry, error) + func MakeConfigEntry(kind, name string) (ConfigEntry, error) + type ConfigEntryDeleteResponse struct + Deleted bool + type ConfigEntryGraphError struct + Err error + Message string + func (e *ConfigEntryGraphError) Error() string + type ConfigEntryListAllRequest struct + Datacenter string + Kinds []string + func (r *ConfigEntryListAllRequest) RequestDatacenter() string + type ConfigEntryOp string + const ConfigEntryDelete + const ConfigEntryDeleteCAS + const ConfigEntryUpsert + const ConfigEntryUpsertCAS + const ConfigEntryUpsertWithStatusCAS + type ConfigEntryQuery struct + Datacenter string + Kind string + Name string + func (c *ConfigEntryQuery) RequestDatacenter() string + func (r *ConfigEntryQuery) CacheInfo() cache.RequestInfo + type ConfigEntryRequest struct + Datacenter string + Entry ConfigEntry + Op ConfigEntryOp + func (c *ConfigEntryRequest) MarshalBinary() (data []byte, err error) + func (c *ConfigEntryRequest) RequestDatacenter() string + func (c *ConfigEntryRequest) UnmarshalBinary(data []byte) error + type ConfigEntryResponse struct + Entry ConfigEntry + func (c *ConfigEntryResponse) MarshalBinary() (data []byte, err error) + func (c *ConfigEntryResponse) UnmarshalBinary(data []byte) error + type ConnectAuthorizeRequest struct + ClientCertSerial string + ClientCertURI string + Target string + func (req *ConnectAuthorizeRequest) TargetNamespace() string + func (req *ConnectAuthorizeRequest) TargetPartition() string + type ConnectProxyConfig 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 + MutualTLSMode MutualTLSMode + TransparentProxy TransparentProxyConfig + Upstreams Upstreams + func TestConnectProxyConfig(t testing.T) ConnectProxyConfig + func (c *ConnectProxyConfig) MarshalJSON() ([]byte, error) + func (c *ConnectProxyConfig) ToAPI() *api.AgentServiceConnectProxyConfig + func (o *ConnectProxyConfig) DeepCopy() *ConnectProxyConfig + func (t *ConnectProxyConfig) UnmarshalJSON(data []byte) (err error) + type ConsulCAProviderConfig struct + DisableCrossSigning bool + PrivateKey string + RootCert string + func (c *ConsulCAProviderConfig) Validate() error + type ControlledConfigEntry interface + DefaultStatus func() Status + GetStatus func() Status + SetStatus func(status Status) + type CookieConfig struct + Path string + Session bool + TTL time.Duration + type Coordinate struct + Coord *coordinate.Coordinate + Node string + Partition string + Segment string + func (_ *Coordinate) FillAuthzContext(_ *acl.AuthorizerContext) + func (c *Coordinate) GetEnterpriseMeta() *acl.EnterpriseMeta + func (c *Coordinate) PartitionOrDefault() string + type CoordinateUpdateRequest struct + Coord *coordinate.Coordinate + Datacenter string + Node string + Segment string + func (c *CoordinateUpdateRequest) RequestDatacenter() string + type Coordinates []*Coordinate + type DCSpecificRequest struct + Datacenter string + NodeMetaFilters map[string]string + PeerName string + Source QuerySource + func (r *DCSpecificRequest) CacheInfo() cache.RequestInfo + func (r *DCSpecificRequest) CacheMinIndex() uint64 + func (r *DCSpecificRequest) RequestDatacenter() string + type DatacenterIndexedCheckServiceNodes struct + DatacenterNodes map[string]CheckServiceNodes + type DatacenterMap struct + AreaID types.AreaID + Coordinates Coordinates + Datacenter string + type DatacentersRequest struct + func (r *DatacentersRequest) CacheInfo() cache.RequestInfo + type DeregisterRequest struct + CheckID types.CheckID + Datacenter string + Node string + PeerName string + ServiceID string + func (r *DeregisterRequest) RequestDatacenter() string + func (r *DeregisterRequest) UnmarshalJSON(data []byte) error + type DestinationConfig struct + Addresses []string + Port int + type DirEntries []*DirEntry + type DirEntry struct + Flags uint64 + Key string + LockIndex uint64 + Session string + Value []byte + func (_ *DirEntry) FillAuthzContext(_ *acl.AuthorizerContext) + func (d *DirEntry) Clone() *DirEntry + func (d *DirEntry) Equal(o *DirEntry) bool + func (d *DirEntry) IDValue() string + type DiscoveryChainRequest struct + Datacenter string + EvaluateInDatacenter string + EvaluateInNamespace string + EvaluateInPartition string + Name string + OverrideConnectTimeout time.Duration + OverrideMeshGateway MeshGatewayConfig + OverrideProtocol string + func (r *DiscoveryChainRequest) CacheInfo() cache.RequestInfo + func (r *DiscoveryChainRequest) RequestDatacenter() string + func (req *DiscoveryChainRequest) GetEnterpriseMeta() *acl.EnterpriseMeta + func (req *DiscoveryChainRequest) WithEnterpriseMeta(_ *acl.EnterpriseMeta) + type DiscoveryChainResponse struct + Chain *CompiledDiscoveryChain + type DiscoveryFailover struct + Policy *ServiceResolverFailoverPolicy + Regions []string + Targets []string + func (o *DiscoveryFailover) DeepCopy() *DiscoveryFailover + type DiscoveryGraphNode struct + LoadBalancer *LoadBalancer + Name string + Resolver *DiscoveryResolver + Routes []*DiscoveryRoute + Splits []*DiscoverySplit + Type string + func (o *DiscoveryGraphNode) DeepCopy() *DiscoveryGraphNode + func (s *DiscoveryGraphNode) IsResolver() bool + func (s *DiscoveryGraphNode) IsRouter() bool + func (s *DiscoveryGraphNode) IsSplitter() bool + func (s *DiscoveryGraphNode) MapKey() string + type DiscoveryPrioritizeByLocality struct + Mode string + type DiscoveryResolver struct + ConnectTimeout time.Duration + Default bool + Failover *DiscoveryFailover + RequestTimeout time.Duration + Target string + func (o *DiscoveryResolver) DeepCopy() *DiscoveryResolver + func (r *DiscoveryResolver) MarshalJSON() ([]byte, error) + func (r *DiscoveryResolver) UnmarshalJSON(data []byte) error + type DiscoveryRoute struct + Definition *ServiceRoute + NextNode string + func (o *DiscoveryRoute) DeepCopy() *DiscoveryRoute + type DiscoverySplit struct + Definition *ServiceSplit + NextNode string + Weight float32 + func (o *DiscoverySplit) DeepCopy() *DiscoverySplit + type DiscoveryTarget struct + ConnectTimeout time.Duration + Datacenter string + External bool + ID string + Locality *Locality + MeshGateway MeshGatewayConfig + Name string + Namespace string + Partition string + Peer string + PrioritizeByLocality *DiscoveryPrioritizeByLocality + SNI string + Service string + ServiceSubset string + Subset ServiceResolverSubset + TransparentProxy TransparentProxyConfig + func NewDiscoveryTarget(opts DiscoveryTargetOpts) *DiscoveryTarget + func (t *DiscoveryTarget) GetEnterpriseMetadata() *acl.EnterpriseMeta + func (t *DiscoveryTarget) MarshalJSON() ([]byte, error) + func (t *DiscoveryTarget) ServiceID() ServiceID + func (t *DiscoveryTarget) ServiceName() ServiceName + func (t *DiscoveryTarget) String() string + func (t *DiscoveryTarget) ToDiscoveryTargetOpts() DiscoveryTargetOpts + func (t *DiscoveryTarget) UnmarshalJSON(data []byte) error + type DiscoveryTargetOpts struct + Datacenter string + Namespace string + Partition string + Peer string + PrioritizeByLocality *DiscoveryPrioritizeByLocality + Service string + ServiceSubset string + func MergeDiscoveryTargetOpts(opts ...DiscoveryTargetOpts) DiscoveryTargetOpts + type EnterpriseServiceUsage struct + type EnvoyExtension struct + Arguments map[string]interface{} + ConsulVersion string + EnvoyVersion string + Name string + Required bool + type EnvoyExtensions []EnvoyExtension + func (es EnvoyExtensions) ToAPI() []api.EnvoyExtension + type EventFireRequest struct + Datacenter string + Name string + Payload []byte + func (r *EventFireRequest) RequestDatacenter() string + type EventFireResponse struct + type ExpandedTokenInfo struct + AgentACLDefaultPolicy string + AgentACLDownPolicy string + ExpandedPolicies []*ACLPolicy + ExpandedRoles []*ACLRole + NamespaceDefaultPolicyIDs []string + NamespaceDefaultRoleIDs []string + ResolvedByAgent string + type ExportedDiscoveryChainInfo struct + Protocol string + TCPTargets []*DiscoveryTarget + func (i ExportedDiscoveryChainInfo) Equal(o ExportedDiscoveryChainInfo) bool + type ExportedService struct + Consumers []ServiceConsumer + Name string + Namespace string + type ExportedServiceList struct + DiscoChains map[ServiceName]ExportedDiscoveryChainInfo + Services []ServiceName + func (list *ExportedServiceList) ListAllDiscoveryChains() map[ServiceName]ExportedDiscoveryChainInfo + type ExportedServicesConfigEntry struct + Hash uint64 + Meta map[string]string + Name string + Services []ExportedService + func (e *ExportedServicesConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ExportedServicesConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ExportedServicesConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ExportedServicesConfigEntry) GetHash() uint64 + func (e *ExportedServicesConfigEntry) GetKind() string + func (e *ExportedServicesConfigEntry) GetMeta() map[string]string + func (e *ExportedServicesConfigEntry) GetName() string + func (e *ExportedServicesConfigEntry) GetRaftIndex() *RaftIndex + func (e *ExportedServicesConfigEntry) MarshalJSON() ([]byte, error) + func (e *ExportedServicesConfigEntry) Normalize() error + func (e *ExportedServicesConfigEntry) SetHash(h uint64) + func (e *ExportedServicesConfigEntry) Validate() error + func (o *ExportedServicesConfigEntry) DeepCopy() *ExportedServicesConfigEntry + type ExposeConfig struct + Checks bool + Paths []ExposePath + func (e *ExposeConfig) Finalize() + func (e *ExposeConfig) ToAPI() api.ExposeConfig + func (e ExposeConfig) Clone() ExposeConfig + func (o *ExposeConfig) DeepCopy() *ExposeConfig + type ExposePath struct + ListenerPort int + LocalPathPort int + ParsedFromCheck bool + Path string + Protocol string + func (p *ExposePath) ToAPI() api.ExposePath + func (t *ExposePath) UnmarshalJSON(data []byte) (err error) + type FederationState struct + Datacenter string + MeshGateways CheckServiceNodes + PrimaryModifyIndex uint64 + UpdatedAt time.Time + func (c *FederationState) IsSame(other *FederationState) bool + type FederationStateOp string + const FederationStateDelete + const FederationStateUpsert + type FederationStateQuery struct + Datacenter string + TargetDatacenter string + func (c *FederationStateQuery) RequestDatacenter() string + type FederationStateRequest struct + Datacenter string + Op FederationStateOp + State *FederationState + func (c *FederationStateRequest) RequestDatacenter() string + type FederationStateResponse struct + State *FederationState + type FederationStates []*FederationState + func (listings FederationStates) Sort() + type GatewayService struct + CAFile string + CertFile string + FromWildcard bool + Gateway ServiceName + GatewayKind ServiceKind + Hosts []string + KeyFile string + Port int + Protocol string + SNI string + Service ServiceName + ServiceKind GatewayServiceKind + func (g *GatewayService) Addresses(defaultHosts []string) []string + func (g *GatewayService) Clone() *GatewayService + func (g *GatewayService) IsSame(o *GatewayService) bool + func (o *GatewayService) DeepCopy() *GatewayService + type GatewayServiceKind string + const GatewayServiceKindDestination + const GatewayServiceKindService + const GatewayServiceKindUnknown + type GatewayServiceTLSConfig struct + SDS *GatewayTLSSDSConfig + func (o *GatewayServiceTLSConfig) DeepCopy() *GatewayServiceTLSConfig + type GatewayServices []*GatewayService + type GatewayTLSConfig struct + CipherSuites []types.TLSCipherSuite + Enabled bool + SDS *GatewayTLSSDSConfig + TLSMaxVersion types.TLSVersion + TLSMinVersion types.TLSVersion + type GatewayTLSSDSConfig struct + CertResource string + ClusterName string + 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 + func MergeHTTPHeaderModifiers(base, overrides *HTTPHeaderModifiers) (*HTTPHeaderModifiers, error) + func (m *HTTPHeaderModifiers) Clone() (*HTTPHeaderModifiers, error) + func (m *HTTPHeaderModifiers) IsZero() bool + func (m *HTTPHeaderModifiers) Validate(protocol string) error + func (o *HTTPHeaderModifiers) DeepCopy() *HTTPHeaderModifiers + 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 + Hash uint64 + Hostnames []string + Kind string + Meta map[string]string + Name string + Parents []ResourceReference + Rules []HTTPRouteRule + Status Status + func (e *HTTPRouteConfigEntry) CanRead(authz acl.Authorizer) error + func (e *HTTPRouteConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *HTTPRouteConfigEntry) DefaultStatus() Status + func (e *HTTPRouteConfigEntry) FilteredHostnames(listenerHostname string) []string + func (e *HTTPRouteConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *HTTPRouteConfigEntry) GetHash() uint64 + func (e *HTTPRouteConfigEntry) GetKind() string + func (e *HTTPRouteConfigEntry) GetMeta() map[string]string + func (e *HTTPRouteConfigEntry) GetName() string + func (e *HTTPRouteConfigEntry) GetParents() []ResourceReference + func (e *HTTPRouteConfigEntry) GetProtocol() APIGatewayListenerProtocol + func (e *HTTPRouteConfigEntry) GetRaftIndex() *RaftIndex + func (e *HTTPRouteConfigEntry) GetServiceNames() []ServiceName + func (e *HTTPRouteConfigEntry) GetServices() []HTTPService + func (e *HTTPRouteConfigEntry) GetStatus() Status + func (e *HTTPRouteConfigEntry) Normalize() error + func (e *HTTPRouteConfigEntry) SetHash(h uint64) + func (e *HTTPRouteConfigEntry) SetStatus(status Status) + func (e *HTTPRouteConfigEntry) Validate() error + func (o *HTTPRouteConfigEntry) DeepCopy() *HTTPRouteConfigEntry + type HTTPRouteRule struct + Filters HTTPFilters + Matches []HTTPMatch + Services []HTTPService + type HTTPService struct + Filters HTTPFilters + Name string + Weight int + func (s HTTPService) ServiceName() ServiceName + type HashPolicy struct + CookieConfig *CookieConfig + Field string + FieldValue string + SourceIP bool + Terminal bool + func (o *HashPolicy) DeepCopy() *HashPolicy + type HealthCheck struct + CheckID types.CheckID + Definition HealthCheckDefinition + ExposedPort int + Interval string + Name string + Node string + Notes string + Output string + PeerName string + ServiceID string + ServiceName string + ServiceTags []string + Status string + Timeout string + Type string + func (_ *HealthCheck) Validate() error + func (c *HealthCheck) CheckType() *CheckType + func (c *HealthCheck) Clone() *HealthCheck + func (c *HealthCheck) IsSame(other *HealthCheck) bool + func (hc *HealthCheck) CompoundCheckID() CheckID + func (hc *HealthCheck) CompoundServiceID() ServiceID + func (hc *HealthCheck) FillAuthzContext(ctx *acl.AuthorizerContext) + func (hc *HealthCheck) NodeIdentity() Identity + func (hc *HealthCheck) PeerOrEmpty() string + func (o *HealthCheck) DeepCopy() *HealthCheck + type HealthCheckDefinition struct + AliasNode string + AliasService string + Body string + DeregisterCriticalServiceAfter time.Duration + DisableRedirects bool + DockerContainerID string + GRPC string + GRPCUseTLS bool + H2PING string + H2PingUseTLS bool + HTTP string + Header map[string][]string + Interval time.Duration + Method string + OSService string + OutputMaxSize uint + ScriptArgs []string + Shell string + TCP string + TCPUseTLS bool + TLSServerName string + TLSSkipVerify bool + TTL time.Duration + Timeout time.Duration + UDP string + func (d *HealthCheckDefinition) MarshalJSON() ([]byte, error) + func (t *HealthCheckDefinition) UnmarshalJSON(data []byte) (err error) + type HealthChecks []*HealthCheck + type HealthSummary struct + Critical int + Name string + Passing int + Total int + Warning int + func (h *HealthSummary) Add(status string) + type Identity struct + ID string + type IdentityCacheEntry struct + CacheTime time.Time + Identity ACLIdentity + func (e *IdentityCacheEntry) Age() time.Duration + type IndexedCARoots struct + ActiveRootID string + Roots []*CARoot + TrustDomain string + func (o *IndexedCARoots) DeepCopy() *IndexedCARoots + func (r IndexedCARoots) Active() *CARoot + type IndexedCheckServiceNodes struct + Nodes CheckServiceNodes + type IndexedConfigEntries struct + Entries []ConfigEntry + Kind string + func (c *IndexedConfigEntries) MarshalBinary() (data []byte, err error) + func (c *IndexedConfigEntries) UnmarshalBinary(data []byte) error + type IndexedCoordinate struct + Coord *coordinate.Coordinate + type IndexedCoordinates struct + Coordinates Coordinates + type IndexedDirEntries struct + Entries DirEntries + type IndexedExportedServiceList struct + Services map[string]ServiceList + type IndexedFederationStates struct + States FederationStates + type IndexedGatewayServices struct + Services GatewayServices + type IndexedGenericConfigEntries struct + Entries []ConfigEntry + func (c *IndexedGenericConfigEntries) MarshalBinary() (data []byte, err error) + func (c *IndexedGenericConfigEntries) UnmarshalBinary(data []byte) error + type IndexedHealthChecks struct + HealthChecks HealthChecks + type IndexedIntentionMatches struct + Matches []Intentions + type IndexedIntentions struct + DataOrigin string + Intentions Intentions + type IndexedKeyList struct + Keys []string + type IndexedNodeDump struct + Dump NodeDump + ImportedDump NodeDump + type IndexedNodeServiceList struct + NodeServices NodeServiceList + type IndexedNodeServices struct + NodeServices *NodeServices + type IndexedNodes struct + Nodes Nodes + type IndexedNodesWithGateways struct + Gateways GatewayServices + ImportedNodes CheckServiceNodes + Nodes CheckServiceNodes + type IndexedPeeredServiceList struct + Services []PeeredServiceName + type IndexedPreparedQueries struct + Queries PreparedQueries + type IndexedServiceDump struct + Dump ServiceDump + type IndexedServiceList struct + Services ServiceList + type IndexedServiceNodes struct + ServiceNodes ServiceNodes + type IndexedServiceTopology struct + FilteredByACLs bool + ServiceTopology *ServiceTopology + type IndexedServices struct + Services Services + type IndexedSessions struct + Sessions Sessions + type IngressGatewayConfigEntry struct + Defaults *IngressServiceConfig + Hash uint64 + Kind string + Listeners []IngressListener + Meta map[string]string + Name string + TLS GatewayTLSConfig + func (e *IngressGatewayConfigEntry) CanRead(authz acl.Authorizer) error + func (e *IngressGatewayConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *IngressGatewayConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *IngressGatewayConfigEntry) GetHash() uint64 + func (e *IngressGatewayConfigEntry) GetKind() string + func (e *IngressGatewayConfigEntry) GetMeta() map[string]string + func (e *IngressGatewayConfigEntry) GetName() string + func (e *IngressGatewayConfigEntry) GetRaftIndex() *RaftIndex + func (e *IngressGatewayConfigEntry) ListRelatedServices() []ServiceID + func (e *IngressGatewayConfigEntry) Normalize() error + func (e *IngressGatewayConfigEntry) SetHash(h uint64) + func (e *IngressGatewayConfigEntry) Validate() error + type IngressListener struct + Port int + Protocol string + Services []IngressService + TLS *GatewayTLSConfig + func (o *IngressListener) DeepCopy() *IngressListener + type IngressService struct + Hosts []string + MaxConcurrentRequests uint32 + MaxConnections uint32 + MaxPendingRequests uint32 + Meta map[string]string + Name string + PassiveHealthCheck *PassiveHealthCheck + RequestHeaders *HTTPHeaderModifiers + ResponseHeaders *HTTPHeaderModifiers + TLS *GatewayServiceTLSConfig + func (s *IngressService) ToServiceName() ServiceName + type IngressServiceConfig struct + MaxConcurrentRequests uint32 + MaxConnections uint32 + MaxPendingRequests uint32 + PassiveHealthCheck *PassiveHealthCheck + type InlineCertificateConfigEntry struct + Certificate string + Hash uint64 + Kind string + Meta map[string]string + Name string + PrivateKey string + func (e *InlineCertificateConfigEntry) CanRead(authz acl.Authorizer) error + func (e *InlineCertificateConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *InlineCertificateConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *InlineCertificateConfigEntry) GetHash() uint64 + func (e *InlineCertificateConfigEntry) GetKind() string + func (e *InlineCertificateConfigEntry) GetMeta() map[string]string + func (e *InlineCertificateConfigEntry) GetName() string + func (e *InlineCertificateConfigEntry) GetRaftIndex() *RaftIndex + func (e *InlineCertificateConfigEntry) Hosts() ([]string, error) + func (e *InlineCertificateConfigEntry) Normalize() error + func (e *InlineCertificateConfigEntry) SetHash(h uint64) + func (e *InlineCertificateConfigEntry) Validate() error + func (o *InlineCertificateConfigEntry) DeepCopy() *InlineCertificateConfigEntry + type Intention struct + Action IntentionAction + CreatedAt time.Time + DefaultAddr string + DefaultPort int + Description string + DestinationNS string + DestinationName string + DestinationPartition string + Hash []byte + ID string + JWT *IntentionJWTRequirement + Meta map[string]string + Permissions []*IntentionPermission + Precedence int + SourceNS string + SourceName string + SourcePartition string + SourcePeer string + SourceSamenessGroup string + SourceType IntentionSourceType + UpdatedAt time.Time + func TestIntention(t testing.T) *Intention + func (_ *Intention) FillAuthzContext(_ *acl.AuthorizerContext, _ bool) + func (ixn *Intention) CanRead(authz acl.Authorizer) bool + func (ixn *Intention) CanWrite(authz acl.Authorizer) bool + func (ixn *Intention) DestinationEnterpriseMeta() *acl.EnterpriseMeta + func (ixn *Intention) FillPartitionAndNamespace(entMeta *acl.EnterpriseMeta, fillDefault bool) + func (ixn *Intention) SourceEnterpriseMeta() *acl.EnterpriseMeta + func (ixn *Intention) SourcePartitionOrDefault() string + func (o *Intention) DeepCopy() *Intention + func (t *Intention) Clone() *Intention + func (t *Intention) HasWildcardDestination() bool + func (t *Intention) HasWildcardSource() bool + func (t *Intention) MarshalJSON() ([]byte, error) + func (t *Intention) ToExact() *IntentionQueryExact + func (t *Intention) UnmarshalJSON(data []byte) (err error) + func (x *Intention) DestinationServiceName() ServiceName + func (x *Intention) LegacyEstimateSize() int + func (x *Intention) SetHash() + func (x *Intention) SourceServiceName() ServiceName + func (x *Intention) String() string + func (x *Intention) ToConfigEntry(legacy bool) *ServiceIntentionsConfigEntry + func (x *Intention) ToSourceIntention(legacy bool) *SourceIntention + func (x *Intention) UpdatePrecedence() + func (x *Intention) Validate() error + type IntentionAction string + const IntentionActionAllow + const IntentionActionDeny + type IntentionDecisionSummary struct + Allowed bool + DefaultAllow bool + ExternalSource string + HasExact bool + HasPermissions bool + 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 + func (p *IntentionHTTPPermission) Clone() *IntentionHTTPPermission + type IntentionJWTClaimVerification struct + Path []string + Value string + func (e *IntentionJWTClaimVerification) Clone() *IntentionJWTClaimVerification + type IntentionJWTProvider struct + Name string + VerifyClaims []*IntentionJWTClaimVerification + func (e *IntentionJWTProvider) Clone() *IntentionJWTProvider + func (p *IntentionJWTProvider) Validate() error + type IntentionJWTRequirement struct + Providers []*IntentionJWTProvider + func (e *IntentionJWTRequirement) Clone() *IntentionJWTRequirement + func (e *IntentionJWTRequirement) Validate() error + type IntentionListRequest struct + Datacenter string + Legacy bool + func (r *IntentionListRequest) RequestDatacenter() string + type IntentionMatchEntry struct + Name string + Namespace string + Partition string + func (_ *IntentionMatchEntry) FillAuthzContext(_ *acl.AuthorizerContext) + func (e *IntentionMatchEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + type IntentionMatchType string + const IntentionMatchDestination + const IntentionMatchSource + type IntentionMutation struct + Destination ServiceName + ID string + Source ServiceName + Value *SourceIntention + type IntentionOp string + const IntentionOpCreate + const IntentionOpDelete + const IntentionOpDeleteAll + const IntentionOpUpdate + const IntentionOpUpsert + type IntentionPermission struct + Action IntentionAction + HTTP *IntentionHTTPPermission + JWT *IntentionJWTRequirement + func (o *IntentionPermission) DeepCopy() *IntentionPermission + func (p *IntentionPermission) Clone() *IntentionPermission + func (p *IntentionPermission) Validate() error + type IntentionPrecedenceSorter Intentions + func (s IntentionPrecedenceSorter) Len() int + func (s IntentionPrecedenceSorter) Less(i, j int) bool + func (s IntentionPrecedenceSorter) Swap(i, j int) + type IntentionQueryCheck struct + DestinationNS string + DestinationName string + DestinationPartition string + SourceNS string + SourceName string + SourcePartition string + SourceType IntentionSourceType + func (_ *IntentionQueryCheck) FillAuthzContext(_ *acl.AuthorizerContext) + func (q *IntentionQueryCheck) GetACLPrefix() (string, bool) + type IntentionQueryCheckResponse struct + Allowed bool + type IntentionQueryExact struct + DestinationNS string + DestinationName string + DestinationPartition string + SourceNS string + SourceName string + SourcePartition string + SourcePeer string + SourceSamenessGroup string + func (e *IntentionQueryExact) DestinationEnterpriseMeta() *acl.EnterpriseMeta + func (e *IntentionQueryExact) SourceEnterpriseMeta() *acl.EnterpriseMeta + func (q *IntentionQueryExact) Validate() error + type IntentionQueryMatch struct + Entries []IntentionMatchEntry + Type IntentionMatchType + WithSamenessGroups bool + type IntentionQueryRequest struct + Check *IntentionQueryCheck + Datacenter string + Exact *IntentionQueryExact + IntentionID string + Match *IntentionQueryMatch + func (q *IntentionQueryRequest) CacheInfo() cache.RequestInfo + func (q *IntentionQueryRequest) RequestDatacenter() string + type IntentionRequest struct + Datacenter string + Intention *Intention + Mutation *IntentionMutation + Op IntentionOp + func (q *IntentionRequest) RequestDatacenter() string + type IntentionSourceType string + const IntentionSourceConsul + type IntentionTargetType string + const IntentionTargetDestination + const IntentionTargetService + type Intentions []*Intention + type IssuedCert struct + Agent string + AgentURI string + CertPEM string + Kind ServiceKind + KindURI string + PrivateKeyPEM string + SerialNumber string + ServerURI string + Service string + ServiceURI string + ValidAfter time.Time + ValidBefore time.Time + type JSONWebKeySet struct + Local *LocalJWKS + Remote *RemoteJWKS + func (jwks *JSONWebKeySet) Validate() error + type JWKSCluster struct + ConnectTimeout time.Duration + DiscoveryType ClusterDiscoveryType + TLSCertificates *JWKSTLSCertificate + func (c *JWKSCluster) Validate() error + 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 + func (c *JWKSTLSCertTrustedCA) Validate() error + type JWKSTLSCertificate struct + CaCertificateProviderInstance *JWKSTLSCertProviderInstance + TrustedCA *JWKSTLSCertTrustedCA + func (c *JWKSTLSCertificate) Validate() error + type JWTCacheConfig struct + Size int + type JWTForwardingConfig struct + HeaderName string + PadForwardPayloadHeader bool + func (fc *JWTForwardingConfig) Validate() error + type JWTLocation struct + Cookie *JWTLocationCookie + Header *JWTLocationHeader + QueryParam *JWTLocationQueryParam + func (location *JWTLocation) Validate() error + type JWTLocationCookie struct + Name string + func (lc *JWTLocationCookie) Validate() error + type JWTLocationHeader struct + Forward bool + Name string + ValuePrefix string + func (lh *JWTLocationHeader) Validate() error + type JWTLocationQueryParam struct + Name string + func (qp *JWTLocationQueryParam) Validate() error + type JWTProviderConfigEntry struct + Audiences []string + CacheConfig *JWTCacheConfig + ClockSkewSeconds int + Forwarding *JWTForwardingConfig + Hash uint64 + Issuer string + JSONWebKeySet *JSONWebKeySet + Kind string + Locations []*JWTLocation + Meta map[string]string + Name string + func (e *JWTProviderConfigEntry) CanRead(authz acl.Authorizer) error + func (e *JWTProviderConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *JWTProviderConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *JWTProviderConfigEntry) GetHash() uint64 + func (e *JWTProviderConfigEntry) GetKind() string + func (e *JWTProviderConfigEntry) GetMeta() map[string]string + func (e *JWTProviderConfigEntry) GetName() string + func (e *JWTProviderConfigEntry) GetRaftIndex() *RaftIndex + func (e *JWTProviderConfigEntry) Normalize() error + func (e *JWTProviderConfigEntry) SetHash(h uint64) + func (e *JWTProviderConfigEntry) Validate() error + type KVSRequest struct + Datacenter string + DirEnt DirEntry + Op api.KVOp + func (r *KVSRequest) RequestDatacenter() string + type KeyListRequest struct + Datacenter string + Prefix string + Seperator string + func (r *KeyListRequest) RequestDatacenter() string + type KeyRequest struct + Datacenter string + Key string + func (r *KeyRequest) RequestDatacenter() string + type KeyringOp string + type KeyringRequest struct + Datacenter string + Forwarded bool + Key string + LocalOnly bool + Operation KeyringOp + RelayFactor uint8 + func (r *KeyringRequest) RequestDatacenter() string + type KeyringResponse struct + Datacenter string + Error string + Keys map[string]int + Messages map[string]string + NumNodes int + Partition string + PrimaryKeys map[string]int + Segment string + WAN bool + func (r *KeyringResponse) PartitionOrDefault() string + type KeyringResponses struct + Responses []*KeyringResponse + func (r *KeyringResponses) Add(v interface{}) + func (r *KeyringResponses) New() interface{} + type LeastRequestConfig struct + ChoiceCount uint32 + type LinkedService struct + CAFile string + CertFile string + KeyFile string + Name string + SNI string + type LoadBalancer struct + HashPolicies []HashPolicy + LeastRequestConfig *LeastRequestConfig + Policy string + RingHashConfig *RingHashConfig + func (lb *LoadBalancer) IsHashBased() bool + func (o *LoadBalancer) DeepCopy() *LoadBalancer + type LocalJWKS struct + Filename string + JWKS string + func (ks *LocalJWKS) Validate() error + type Locality struct + Region string + Zone string + func (l *Locality) GetRegion() string + func (l *Locality) ToAPI() *api.Locality + type LogSinkType string + const DefaultLogSinkType + const FileLogSinkType + const StdErrLogSinkType + const StdOutLogSinkType + type MeshConfigEntry struct + AllowEnablingPermissiveMutualTLS bool + HTTP *MeshHTTPConfig + Hash uint64 + Meta map[string]string + Peering *PeeringMeshConfig + TLS *MeshTLSConfig + TransparentProxy TransparentProxyMeshConfig + func (e *MeshConfigEntry) CanRead(authz acl.Authorizer) error + func (e *MeshConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *MeshConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *MeshConfigEntry) GetHash() uint64 + func (e *MeshConfigEntry) GetKind() string + func (e *MeshConfigEntry) GetMeta() map[string]string + func (e *MeshConfigEntry) GetName() string + func (e *MeshConfigEntry) GetRaftIndex() *RaftIndex + func (e *MeshConfigEntry) MarshalJSON() ([]byte, error) + func (e *MeshConfigEntry) Normalize() error + func (e *MeshConfigEntry) PeerThroughMeshGateways() bool + func (e *MeshConfigEntry) SetHash(h uint64) + func (e *MeshConfigEntry) Validate() error + func (o *MeshConfigEntry) DeepCopy() *MeshConfigEntry + type MeshDirectionalTLSConfig struct + CipherSuites []types.TLSCipherSuite + TLSMaxVersion types.TLSVersion + TLSMinVersion types.TLSVersion + func (o *MeshDirectionalTLSConfig) DeepCopy() *MeshDirectionalTLSConfig + type MeshGatewayConfig struct + Mode MeshGatewayMode + func (c *MeshGatewayConfig) IsZero() bool + func (c *MeshGatewayConfig) ToAPI() api.MeshGatewayConfig + type MeshGatewayMode string + const MeshGatewayModeDefault + const MeshGatewayModeLocal + const MeshGatewayModeNone + const MeshGatewayModeRemote + func ValidateMeshGatewayMode(mode string) (MeshGatewayMode, error) + type MeshHTTPConfig struct + SanitizeXForwardedClientCert bool + type MeshTLSConfig struct + Incoming *MeshDirectionalTLSConfig + Outgoing *MeshDirectionalTLSConfig + func (o *MeshTLSConfig) DeepCopy() *MeshTLSConfig + type MessageType uint8 + func (m MessageType) String() string + type MutualTLSMode string + const MutualTLSModeDefault + const MutualTLSModePermissive + const MutualTLSModeStrict + type NetworkSegment struct + Advertise *net.TCPAddr + Bind *net.TCPAddr + Name string + RPCListener bool + type Node struct + Address string + Datacenter string + ID types.NodeID + Locality *Locality + Meta map[string]string + Node string + Partition string + PeerName string + TaggedAddresses map[string]string + func (n *Node) BestAddress(wan bool) string + func (n *Node) FillAuthzContext(ctx *acl.AuthorizerContext) + func (n *Node) GetEnterpriseMeta() *acl.EnterpriseMeta + func (n *Node) IsSame(other *Node) bool + func (n *Node) OverridePartition(_ string) + func (n *Node) PartitionOrDefault() string + func (n *Node) PeerOrEmpty() string + func (n *Node) ToRegisterRequest() RegisterRequest + func (o *Node) DeepCopy() *Node + type NodeDump []*NodeInfo + type NodeInfo struct + Address string + Checks HealthChecks + ID types.NodeID + Meta map[string]string + Node string + Partition string + PeerName string + Services []*NodeService + TaggedAddresses map[string]string + func (n *NodeInfo) FillAuthzContext(ctx *acl.AuthorizerContext) + func (n *NodeInfo) GetEnterpriseMeta() *acl.EnterpriseMeta + func (n *NodeInfo) PartitionOrDefault() string + type NodeService struct + Address string + Connect ServiceConnect + EnableTagOverride bool + ID string + Kind ServiceKind + Locality *Locality + LocallyRegisteredAsSidecar bool + Meta map[string]string + PeerName string + Port int + Proxy ConnectProxyConfig + Service string + SocketPath string + TaggedAddresses map[string]ServiceAddress + Tags []string + Weights *Weights + func TestNodeService(t testing.T) *NodeService + func TestNodeServiceAPIGateway(t testing.T) *NodeService + func TestNodeServiceExpose(t testing.T) *NodeService + func TestNodeServiceIngressGateway(t testing.T, address string) *NodeService + func TestNodeServiceMeshGateway(t testing.T) *NodeService + func TestNodeServiceMeshGatewayWithAddrs(t testing.T, address string, port int, lanAddr, wanAddr ServiceAddress) *NodeService + func TestNodeServiceProxy(t testing.T) *NodeService + func TestNodeServiceProxyInPartition(t testing.T, partition string) *NodeService + func TestNodeServiceSidecar(t testing.T) *NodeService + func TestNodeServiceTerminatingGateway(t testing.T, address string) *NodeService + func TestNodeServiceWithName(t testing.T, name string) *NodeService + func (ns *NodeService) BestAddress(wan bool) (string, int) + func (ns *NodeService) CompoundServiceID() ServiceID + func (ns *NodeService) CompoundServiceName() ServiceName + func (ns *NodeService) FillAuthzContext(ctx *acl.AuthorizerContext) + func (o *NodeService) DeepCopy() *NodeService + func (s *NodeService) IsGateway() bool + func (s *NodeService) IsSame(other *NodeService) bool + func (s *NodeService) IsSidecarProxy() bool + func (s *NodeService) ToServiceNode(node string) *ServiceNode + func (s *NodeService) Validate() error + func (s *NodeService) ValidateForAgent() error + type NodeServiceList struct + Node *Node + Services []*NodeService + type NodeServices struct + Node *Node + Services map[string]*NodeService + type NodeSpecificRequest struct + Datacenter string + MergeCentralConfig bool + Node string + PeerName string + func (r *NodeSpecificRequest) CacheInfo() cache.RequestInfo + func (r *NodeSpecificRequest) RequestDatacenter() string + type Nodes []*Node + type OpaqueUpstreamConfig struct + Config map[string]interface{} + Upstream PeeredServiceName + type OpaqueUpstreamConfigs []OpaqueUpstreamConfig + type OperatorUsageRequest struct + Global bool + type ParsedPolicyCacheEntry struct + CacheTime time.Time + Policy *acl.Policy + func (e *ParsedPolicyCacheEntry) Age() time.Duration + type PartitionSpecificRequest struct + Datacenter string + func (r *PartitionSpecificRequest) CacheInfo() cache.RequestInfo + func (r *PartitionSpecificRequest) RequestDatacenter() string + type PassiveHealthCheck struct + BaseEjectionTime *time.Duration + EnforcingConsecutive5xx *uint32 + Interval time.Duration + MaxEjectionPercent *uint32 + MaxFailures uint32 + func (chk *PassiveHealthCheck) Clone() *PassiveHealthCheck + func (chk *PassiveHealthCheck) IsZero() bool + func (chk PassiveHealthCheck) Validate() error + type PeeredServiceName struct + Peer string + ServiceName ServiceName + func (psn PeeredServiceName) String() string + type PeeringMeshConfig struct + PeerThroughMeshGateways bool + type PeeringServiceMeta struct + Protocol string + SNI []string + SpiffeID []string + func (m *PeeringServiceMeta) PrimarySNI() string + func (o *PeeringServiceMeta) DeepCopy() *PeeringServiceMeta + type PeeringToken struct + CA []string + EstablishmentSecret string + ManualServerAddresses []string + PeerID string + Remote PeeringTokenRemote + ServerAddresses []string + ServerName string + type PeeringTokenRemote struct + Datacenter string + Locality *Locality + Partition string + type PolicyCacheEntry struct + CacheTime time.Time + Policy *ACLPolicy + func (e *PolicyCacheEntry) Age() time.Duration + type PreparedQueries []*PreparedQuery + type PreparedQuery struct + DNS QueryDNSOptions + ID string + Name string + Service ServiceQuery + Session string + Template QueryTemplateOptions + Token string + func (pq *PreparedQuery) GetACLPrefix() (string, bool) + type PreparedQueryExecuteRemoteRequest struct + Connect bool + Datacenter string + Limit int + Query PreparedQuery + func (q *PreparedQueryExecuteRemoteRequest) RequestDatacenter() string + type PreparedQueryExecuteRequest struct + Agent QuerySource + Connect bool + Datacenter string + Limit int + QueryIDOrName string + Source QuerySource + func (q *PreparedQueryExecuteRequest) CacheInfo() cache.RequestInfo + func (q *PreparedQueryExecuteRequest) RequestDatacenter() string + type PreparedQueryExecuteResponse struct + DNS QueryDNSOptions + Datacenter string + Failovers int + Nodes CheckServiceNodes + PeerName string + Service string + type PreparedQueryExplainResponse struct + Query PreparedQuery + type PreparedQueryOp string + const PreparedQueryCreate + const PreparedQueryDelete + const PreparedQueryUpdate + type PreparedQueryRequest struct + Datacenter string + Op PreparedQueryOp + Query *PreparedQuery + func (q *PreparedQueryRequest) RequestDatacenter() string + type PreparedQuerySpecificRequest struct + Datacenter string + QueryID string + func (q *PreparedQuerySpecificRequest) RequestDatacenter() string + type ProxyConfigEntry struct + AccessLogs AccessLogsConfig + Config map[string]interface{} + EnvoyExtensions EnvoyExtensions + Expose ExposeConfig + FailoverPolicy *ServiceResolverFailoverPolicy + Hash uint64 + Kind string + MeshGateway MeshGatewayConfig + Meta map[string]string + Mode ProxyMode + MutualTLSMode MutualTLSMode + Name string + PrioritizeByLocality *ServiceResolverPrioritizeByLocality + Protocol string + TransparentProxy TransparentProxyConfig + func (e *ProxyConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ProxyConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ProxyConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ProxyConfigEntry) GetHash() uint64 + func (e *ProxyConfigEntry) GetKind() string + func (e *ProxyConfigEntry) GetMeta() map[string]string + func (e *ProxyConfigEntry) GetName() string + func (e *ProxyConfigEntry) GetRaftIndex() *RaftIndex + func (e *ProxyConfigEntry) MarshalBinary() (data []byte, err error) + func (e *ProxyConfigEntry) Normalize() error + func (e *ProxyConfigEntry) SetHash(h uint64) + func (e *ProxyConfigEntry) UnmarshalBinary(data []byte) error + func (e *ProxyConfigEntry) Validate() error + type ProxyMode string + const ProxyModeDefault + const ProxyModeDirect + const ProxyModeTransparent + func ValidateProxyMode(mode string) (ProxyMode, error) + type QueryBackend int + const QueryBackendBlocking + const QueryBackendStreaming + func QueryBackendFromString(s string) QueryBackend + func (q QueryBackend) GoString() string + func (q QueryBackend) String() string + type QueryDNSOptions struct + TTL string + type QueryFailoverOptions struct + Datacenters []string + NearestN int + Targets []QueryFailoverTarget + func (f *QueryFailoverOptions) AsTargets() []QueryFailoverTarget + func (f *QueryFailoverOptions) IsEmpty() bool + type QueryFailoverTarget struct + Datacenter string + Peer string + type QueryMeta struct + Backend QueryBackend + ConsistencyLevel string + Index uint64 + KnownLeader bool + LastContact time.Duration + NotModified bool + ResultsFilteredByACLs bool + func (m *QueryMeta) GetConsistencyLevel() string + func (m *QueryMeta) GetIndex() uint64 + func (m *QueryMeta) GetKnownLeader() bool + func (m *QueryMeta) GetLastContact() (time.Duration, error) + func (q *QueryMeta) GetBackend() QueryBackend + func (q *QueryMeta) GetResultsFilteredByACLs() bool + func (q *QueryMeta) SetConsistencyLevel(consistencyLevel string) + func (q *QueryMeta) SetIndex(index uint64) + func (q *QueryMeta) SetKnownLeader(knownLeader bool) + func (q *QueryMeta) SetLastContact(lastContact time.Duration) + func (q *QueryMeta) SetResultsFilteredByACLs(v bool) + type QueryOptions struct + AllowNotModifiedResponse bool + AllowStale bool + Filter string + MaxAge time.Duration + MaxQueryTime time.Duration + MaxStaleDuration time.Duration + MinQueryIndex uint64 + MustRevalidate bool + RequireConsistent bool + StaleIfError time.Duration + Token string + UseCache bool + func (m *QueryOptions) GetAllowStale() bool + func (m *QueryOptions) GetFilter() string + func (m *QueryOptions) GetMaxAge() (time.Duration, error) + func (m *QueryOptions) GetMaxQueryTime() (time.Duration, error) + func (m *QueryOptions) GetMaxStaleDuration() (time.Duration, error) + func (m *QueryOptions) GetMinQueryIndex() uint64 + func (m *QueryOptions) GetMustRevalidate() bool + func (m *QueryOptions) GetRequireConsistent() bool + func (m *QueryOptions) GetStaleIfError() (time.Duration, error) + func (m *QueryOptions) GetToken() string + func (m *QueryOptions) GetUseCache() bool + func (q *QueryOptions) SetAllowStale(allowStale bool) + func (q *QueryOptions) SetFilter(filter string) + func (q *QueryOptions) SetMaxAge(maxAge time.Duration) + func (q *QueryOptions) SetMaxQueryTime(maxQueryTime time.Duration) + func (q *QueryOptions) SetMaxStaleDuration(maxStaleDuration time.Duration) + func (q *QueryOptions) SetMinQueryIndex(minQueryIndex uint64) + func (q *QueryOptions) SetMustRevalidate(mustRevalidate bool) + func (q *QueryOptions) SetRequireConsistent(requireConsistent bool) + func (q *QueryOptions) SetStaleIfError(staleIfError time.Duration) + func (q *QueryOptions) SetToken(token string) + func (q *QueryOptions) SetTokenSecret(s string) + func (q *QueryOptions) SetUseCache(useCache bool) + func (q QueryOptions) AllowStaleRead() bool + func (q QueryOptions) BlockingTimeout(maxQueryTime, defaultQueryTime time.Duration) time.Duration + func (q QueryOptions) ConsistencyLevel() string + func (q QueryOptions) HasTimedOut(start time.Time, rpcHoldTimeout, maxQueryTime, defaultQueryTime time.Duration) (bool, error) + func (q QueryOptions) IsRead() bool + func (q QueryOptions) TokenSecret() string + type QuerySource struct + Datacenter string + Ip string + Node string + NodePartition string + Segment string + func (s QuerySource) NodeEnterpriseMeta() *acl.EnterpriseMeta + func (s QuerySource) NodePartitionOrDefault() string + type QueryTemplateOptions struct + Regexp string + RemoveEmptyTags bool + Type string + type RPCInfo interface + AllowStaleRead func() bool + HasTimedOut func(since time.Time, rpcHoldTimeout, maxQueryTime, defaultQueryTime time.Duration) (bool, error) + IsRead func() bool + RequestDatacenter func() string + SetTokenSecret func(string) + TokenSecret func() string + type RaftConfigurationResponse struct + Index uint64 + Servers []*RaftServer + type RaftIndex struct + CreateIndex uint64 + ModifyIndex uint64 + type RaftRemovePeerRequest struct + Address raft.ServerAddress + Datacenter string + ID raft.ServerID + func (op *RaftRemovePeerRequest) RequestDatacenter() string + type RaftServer struct + Address raft.ServerAddress + ID raft.ServerID + LastIndex uint64 + Leader bool + Node string + ProtocolVersion string + Voter bool + type RaftStats struct + LastContact string + LastIndex uint64 + LastTerm uint64 + func (s *RaftStats) ToAutopilotServerStats() *autopilot.ServerStats + type RegisterRequest struct + Address string + Check *HealthCheck + Checks HealthChecks + Datacenter string + ID types.NodeID + Locality *Locality + Node string + NodeMeta map[string]string + PeerName string + Service *NodeService + SkipNodeUpdate bool + TaggedAddresses map[string]string + func TestRegisterIngressGateway(t testing.T) *RegisterRequest + func TestRegisterRequest(t testing.T) *RegisterRequest + func TestRegisterRequestProxy(t testing.T) *RegisterRequest + func (_ *RegisterRequest) FillAuthzContext(_ *acl.AuthorizerContext) + func (_ *RegisterRequest) GetEnterpriseMeta() *acl.EnterpriseMeta + func (r *RegisterRequest) ChangesNode(node *Node) bool + func (r *RegisterRequest) RequestDatacenter() string + type RemoteACLAuthorizationRequest struct + Datacenter string + Requests []ACLAuthorizationRequest + func (r *RemoteACLAuthorizationRequest) RequestDatacenter() string + type RemoteJWKS struct + CacheDuration time.Duration + FetchAsynchronously bool + JWKSCluster *JWKSCluster + RequestTimeoutMs int + RetryPolicy *JWKSRetryPolicy + URI string + func (ks *RemoteJWKS) Validate() error + type ResourceReference struct + Kind string + Name string + SectionName string + func (r *ResourceReference) IsSame(other *ResourceReference) bool + func (r *ResourceReference) String() string + type RetryPolicyBackOff struct + BaseInterval time.Duration + MaxInterval time.Duration + func (r *RetryPolicyBackOff) Validate() error + type RingHashConfig struct + MaximumRingSize uint64 + MinimumRingSize uint64 + type RoleCacheEntry struct + CacheTime time.Time + Role *ACLRole + func (e *RoleCacheEntry) Age() time.Duration + type SamenessGroupConfigEntry struct + DefaultForFailover bool + Hash uint64 + IncludeLocal bool + Members []SamenessGroupMember + Meta map[string]string + Name string + func (s *SamenessGroupConfigEntry) AllMembers() []SamenessGroupMember + func (s *SamenessGroupConfigEntry) CanRead(authz acl.Authorizer) error + func (s *SamenessGroupConfigEntry) CanWrite(authz acl.Authorizer) error + func (s *SamenessGroupConfigEntry) GetCreateIndex() uint64 + func (s *SamenessGroupConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (s *SamenessGroupConfigEntry) GetHash() 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) GetRaftIndex() *RaftIndex + func (s *SamenessGroupConfigEntry) MarshalJSON() ([]byte, error) + func (s *SamenessGroupConfigEntry) Normalize() error + func (s *SamenessGroupConfigEntry) RelatedPeers() []string + func (s *SamenessGroupConfigEntry) SetHash(h uint64) + func (s *SamenessGroupConfigEntry) ToQueryFailoverTargets(namespace string) []QueryFailoverTarget + func (s *SamenessGroupConfigEntry) ToServiceResolverFailoverTargets() []ServiceResolverFailoverTarget + func (s *SamenessGroupConfigEntry) Validate() error + type SamenessGroupMember struct + Partition string + Peer string + type ServiceAddress struct + Address string + Port int + func (a ServiceAddress) ToAPIServiceAddress() api.ServiceAddress + type ServiceCheck struct + ID string + Namespace string + type ServiceConfigEntry struct + BalanceInboundConnections string + Destination *DestinationConfig + EnvoyExtensions EnvoyExtensions + Expose ExposeConfig + ExternalSNI string + Hash uint64 + Kind string + LocalConnectTimeoutMs int + LocalRequestTimeoutMs int + MaxInboundConnections int + MeshGateway MeshGatewayConfig + Meta map[string]string + Mode ProxyMode + MutualTLSMode MutualTLSMode + Name string + Protocol string + TransparentProxy TransparentProxyConfig + UpstreamConfig *UpstreamConfiguration + func (e *ServiceConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ServiceConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ServiceConfigEntry) Clone() *ServiceConfigEntry + func (e *ServiceConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ServiceConfigEntry) GetHash() uint64 + func (e *ServiceConfigEntry) GetKind() string + func (e *ServiceConfigEntry) GetMeta() map[string]string + func (e *ServiceConfigEntry) GetName() string + func (e *ServiceConfigEntry) GetRaftIndex() *RaftIndex + func (e *ServiceConfigEntry) Normalize() error + func (e *ServiceConfigEntry) SetHash(h uint64) + func (e *ServiceConfigEntry) Validate() error + func (o *ServiceConfigEntry) DeepCopy() *ServiceConfigEntry + type ServiceConfigRequest struct + Datacenter string + MeshGateway MeshGatewayConfig + Mode ProxyMode + Name string + UpstreamServiceNames []PeeredServiceName + func (r *ServiceConfigRequest) CacheInfo() cache.RequestInfo + func (s *ServiceConfigRequest) GetLocalUpstreamIDs() []ServiceID + func (s *ServiceConfigRequest) RequestDatacenter() string + type ServiceConfigResponse struct + AccessLogs AccessLogsConfig + Destination DestinationConfig + EnvoyExtensions []EnvoyExtension + Expose ExposeConfig + MeshGateway MeshGatewayConfig + Meta map[string]string + Mode ProxyMode + MutualTLSMode MutualTLSMode + ProxyConfig map[string]interface{} + TransparentProxy TransparentProxyConfig + UpstreamConfigs OpaqueUpstreamConfigs + func (o *ServiceConfigResponse) DeepCopy() *ServiceConfigResponse + func (r *ServiceConfigResponse) MarshalBinary() (data []byte, err error) + func (r *ServiceConfigResponse) UnmarshalBinary(data []byte) error + type ServiceConnect struct + Native bool + PeerMeta *PeeringServiceMeta + SidecarService *ServiceDefinition + func (o *ServiceConnect) DeepCopy() *ServiceConnect + func (t *ServiceConnect) UnmarshalJSON(data []byte) (err error) + type ServiceConsumer struct + Partition string + Peer string + SamenessGroup string + type ServiceDefinition struct + Address string + Check CheckType + Checks CheckTypes + Connect *ServiceConnect + EnableTagOverride bool + ID string + Kind ServiceKind + Locality *Locality + Meta map[string]string + Name string + Port int + Proxy *ConnectProxyConfig + SocketPath string + TaggedAddresses map[string]ServiceAddress + Tags []string + Token string + Weights *Weights + func TestServiceDefinition(t testing.T) *ServiceDefinition + func TestServiceDefinitionProxy(t testing.T) *ServiceDefinition + func (o *ServiceDefinition) DeepCopy() *ServiceDefinition + func (s *ServiceDefinition) CheckTypes() (checks CheckTypes, err error) + func (s *ServiceDefinition) NodeService() *NodeService + func (s *ServiceDefinition) Validate() error + func (t *ServiceDefinition) UnmarshalJSON(data []byte) (err error) + type ServiceDump []*ServiceInfo + type ServiceDumpRequest struct + Datacenter string + PeerName string + ServiceKind ServiceKind + Source QuerySource + UseServiceKind bool + func (r *ServiceDumpRequest) CacheInfo() cache.RequestInfo + func (r *ServiceDumpRequest) CacheMinIndex() uint64 + func (r *ServiceDumpRequest) RequestDatacenter() string + type ServiceID struct + ID string + func NewServiceID(id string, entMeta *acl.EnterpriseMeta) ServiceID + func ServiceIDFromString(input string) ServiceID + func (sid ServiceID) Matches(other ServiceID) bool + func (sid ServiceID) String() string + func (sid ServiceID) StringHashSHA256() string + type ServiceInfo struct + Checks HealthChecks + GatewayService *GatewayService + Node *Node + Service *NodeService + type ServiceIntentionsConfigEntry struct + Hash uint64 + JWT *IntentionJWTRequirement + Kind string + Meta map[string]string + Name string + Sources []*SourceIntention + func MigrateIntentions(ixns Intentions) []*ServiceIntentionsConfigEntry + func (e *ServiceIntentionsConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ServiceIntentionsConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ServiceIntentionsConfigEntry) Clone() *ServiceIntentionsConfigEntry + func (e *ServiceIntentionsConfigEntry) DeleteSourceByLegacyID(legacyID string) bool + func (e *ServiceIntentionsConfigEntry) DeleteSourceByName(sn ServiceName) bool + func (e *ServiceIntentionsConfigEntry) DestinationServiceName() ServiceName + func (e *ServiceIntentionsConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ServiceIntentionsConfigEntry) GetHash() uint64 + func (e *ServiceIntentionsConfigEntry) GetKind() string + func (e *ServiceIntentionsConfigEntry) GetMeta() map[string]string + func (e *ServiceIntentionsConfigEntry) GetName() string + func (e *ServiceIntentionsConfigEntry) GetRaftIndex() *RaftIndex + func (e *ServiceIntentionsConfigEntry) HasAnyPermissions() bool + func (e *ServiceIntentionsConfigEntry) HasWildcardDestination() bool + func (e *ServiceIntentionsConfigEntry) LegacyIDFieldsAreAllEmpty() bool + func (e *ServiceIntentionsConfigEntry) LegacyIDFieldsAreAllSet() bool + func (e *ServiceIntentionsConfigEntry) LegacyNormalize() error + func (e *ServiceIntentionsConfigEntry) LegacyValidate() error + func (e *ServiceIntentionsConfigEntry) Normalize() error + func (e *ServiceIntentionsConfigEntry) SetHash(h uint64) + func (e *ServiceIntentionsConfigEntry) ToIntention(src *SourceIntention) *Intention + func (e *ServiceIntentionsConfigEntry) ToIntentions() Intentions + func (e *ServiceIntentionsConfigEntry) UpdateOver(rawPrev ConfigEntry) error + func (e *ServiceIntentionsConfigEntry) UpdateSourceByLegacyID(legacyID string, update *SourceIntention) bool + func (e *ServiceIntentionsConfigEntry) UpsertSourceByName(sn ServiceName, upsert *SourceIntention) + func (e *ServiceIntentionsConfigEntry) Validate() error + type ServiceKind string + const ServiceKindAPIGateway + const ServiceKindConnectEnabled + const ServiceKindConnectProxy + const ServiceKindDestination + const ServiceKindIngressGateway + const ServiceKindMeshGateway + const ServiceKindTerminatingGateway + const ServiceKindTypical + func (k ServiceKind) IsProxy() bool + func (k ServiceKind) Normalized() string + type ServiceList []ServiceName + func (s ServiceList) Len() int + func (s ServiceList) Less(i, j int) bool + func (s ServiceList) Sort() + func (s ServiceList) Swap(i, j int) + type ServiceName struct + Name string + func NewServiceName(name string, entMeta *acl.EnterpriseMeta) ServiceName + func ServiceNameFromString(input string) ServiceName + func (n ServiceName) Matches(o ServiceName) bool + func (n ServiceName) String() string + func (n ServiceName) ToServiceID() ServiceID + type ServiceNameWithSamenessGroup struct + SamenessGroup string + type ServiceNode struct + Address string + Datacenter string + ID types.NodeID + Node string + NodeMeta map[string]string + PeerName string + ServiceAddress string + ServiceConnect ServiceConnect + ServiceEnableTagOverride bool + ServiceID string + ServiceKind ServiceKind + ServiceLocality *Locality + ServiceMeta map[string]string + ServiceName string + ServicePort int + ServiceProxy ConnectProxyConfig + ServiceSocketPath string + ServiceTaggedAddresses map[string]ServiceAddress + ServiceTags []string + ServiceWeights Weights + TaggedAddresses map[string]string + func (s *ServiceNode) FillAuthzContext(ctx *acl.AuthorizerContext) + func (s *ServiceNode) IsSameService(other *ServiceNode) bool + func (s *ServiceNode) NodeIdentity() Identity + func (s *ServiceNode) PartialClone() *ServiceNode + func (s *ServiceNode) PeerOrEmpty() string + func (s *ServiceNode) ToNodeService() *NodeService + func (sn *ServiceNode) CompoundServiceID() ServiceID + func (sn *ServiceNode) CompoundServiceName() PeeredServiceName + type ServiceNodes []*ServiceNode + type ServiceQuery struct + Connect bool + Failover QueryFailoverOptions + IgnoreCheckIDs []types.CheckID + Near string + NodeMeta map[string]string + OnlyPassing bool + Peer string + SamenessGroup string + Service string + ServiceMeta map[string]string + Tags []string + type ServiceResolverConfigEntry struct + ConnectTimeout time.Duration + DefaultSubset string + Failover map[string]ServiceResolverFailover + Hash uint64 + Kind string + LoadBalancer *LoadBalancer + Meta map[string]string + Name string + PrioritizeByLocality *ServiceResolverPrioritizeByLocality + Redirect *ServiceResolverRedirect + RequestTimeout time.Duration + Subsets map[string]ServiceResolverSubset + func (e *ServiceResolverConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ServiceResolverConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ServiceResolverConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ServiceResolverConfigEntry) GetHash() uint64 + func (e *ServiceResolverConfigEntry) GetKind() string + func (e *ServiceResolverConfigEntry) GetMeta() map[string]string + func (e *ServiceResolverConfigEntry) GetName() string + func (e *ServiceResolverConfigEntry) GetRaftIndex() *RaftIndex + func (e *ServiceResolverConfigEntry) IsDefault() bool + func (e *ServiceResolverConfigEntry) ListRelatedServices() []ServiceID + func (e *ServiceResolverConfigEntry) MarshalJSON() ([]byte, error) + func (e *ServiceResolverConfigEntry) Normalize() error + func (e *ServiceResolverConfigEntry) RelatedPeers() []string + func (e *ServiceResolverConfigEntry) RelatedSamenessGroups() []string + func (e *ServiceResolverConfigEntry) SetHash(h uint64) + func (e *ServiceResolverConfigEntry) SubsetExists(name string) bool + func (e *ServiceResolverConfigEntry) UnmarshalJSON(data []byte) error + func (e *ServiceResolverConfigEntry) Validate() error + func (o *ServiceResolverConfigEntry) DeepCopy() *ServiceResolverConfigEntry + func (r *ServiceResolverConfigEntry) ToSamenessDiscoveryTargetOpts() DiscoveryTargetOpts + type ServiceResolverFailover struct + Datacenters []string + Namespace string + Policy *ServiceResolverFailoverPolicy + SamenessGroup string + Service string + ServiceSubset string + Targets []ServiceResolverFailoverTarget + func (f *ServiceResolverFailover) ToDiscoveryTargetOpts() DiscoveryTargetOpts + func (failover *ServiceResolverFailover) GetEnterpriseMeta(_ *acl.EnterpriseMeta) *acl.EnterpriseMeta + func (failover *ServiceResolverFailover) ValidateEnterprise() error + func (o *ServiceResolverFailover) DeepCopy() *ServiceResolverFailover + type ServiceResolverFailoverPolicy struct + Mode string + Regions []string + func (f *ServiceResolverFailoverPolicy) ValidateEnterprise() error + type ServiceResolverFailoverTarget struct + Datacenter string + Namespace string + Partition string + Peer string + Service string + ServiceSubset string + func (redir *ServiceResolverFailoverTarget) ValidateEnterprise() error + func (t *ServiceResolverFailoverTarget) ToDiscoveryTargetOpts() DiscoveryTargetOpts + func (target *ServiceResolverFailoverTarget) GetEnterpriseMeta(_ *acl.EnterpriseMeta) *acl.EnterpriseMeta + type ServiceResolverPrioritizeByLocality struct + Mode string + func (pbl *ServiceResolverPrioritizeByLocality) ToDiscovery() *DiscoveryPrioritizeByLocality + type ServiceResolverRedirect struct + Datacenter string + Namespace string + Partition string + Peer string + SamenessGroup string + Service string + ServiceSubset string + func (r *ServiceResolverRedirect) ToDiscoveryTargetOpts() DiscoveryTargetOpts + func (redir *ServiceResolverRedirect) GetEnterpriseMeta(_ *acl.EnterpriseMeta) *acl.EnterpriseMeta + func (redir *ServiceResolverRedirect) ValidateEnterprise() error + type ServiceResolverSubset struct + Filter string + OnlyPassing bool + type ServiceRoute struct + Destination *ServiceRouteDestination + Match *ServiceRouteMatch + func (o *ServiceRoute) DeepCopy() *ServiceRoute + 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 (d *ServiceRouteDestination) HasRetryFeatures() bool + func (dest *ServiceRouteDestination) GetEnterpriseMeta(_ *acl.EnterpriseMeta) *acl.EnterpriseMeta + func (e *ServiceRouteDestination) MarshalJSON() ([]byte, error) + func (e *ServiceRouteDestination) UnmarshalJSON(data []byte) error + func (o *ServiceRouteDestination) DeepCopy() *ServiceRouteDestination + type ServiceRouteHTTPMatch struct + Header []ServiceRouteHTTPMatchHeader + Methods []string + PathExact string + PathPrefix string + PathRegex string + QueryParam []ServiceRouteHTTPMatchQueryParam + func (m *ServiceRouteHTTPMatch) IsEmpty() bool + 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 + func (m *ServiceRouteMatch) IsEmpty() bool + func (o *ServiceRouteMatch) DeepCopy() *ServiceRouteMatch + type ServiceRouteReferences map[ServiceName][]ResourceReference + func (s ServiceRouteReferences) AddService(key ServiceName, routeRef ResourceReference) + func (s ServiceRouteReferences) MarshalJSON() ([]byte, error) + func (s ServiceRouteReferences) RemoveRouteRef(routeRef ResourceReference) + type ServiceRouterConfigEntry struct + Hash uint64 + Kind string + Meta map[string]string + Name string + Routes []ServiceRoute + func (e *ServiceRouterConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ServiceRouterConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ServiceRouterConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ServiceRouterConfigEntry) GetHash() uint64 + func (e *ServiceRouterConfigEntry) GetKind() string + func (e *ServiceRouterConfigEntry) GetMeta() map[string]string + func (e *ServiceRouterConfigEntry) GetName() string + func (e *ServiceRouterConfigEntry) GetRaftIndex() *RaftIndex + func (e *ServiceRouterConfigEntry) ListRelatedServices() []ServiceID + func (e *ServiceRouterConfigEntry) Normalize() error + func (e *ServiceRouterConfigEntry) SetHash(h uint64) + func (e *ServiceRouterConfigEntry) Validate() error + type ServiceSpecificRequest struct + Connect bool + Datacenter string + Ingress bool + MergeCentralConfig bool + NodeMetaFilters map[string]string + PeerName string + ServiceAddress string + ServiceKind ServiceKind + ServiceName string + ServiceTag string + ServiceTags []string + Source QuerySource + TagFilter bool + func (r *ServiceSpecificRequest) CacheInfo() cache.RequestInfo + func (r *ServiceSpecificRequest) CacheMinIndex() uint64 + func (r *ServiceSpecificRequest) RequestDatacenter() string + type ServiceSplit struct + Namespace string + Partition string + RequestHeaders *HTTPHeaderModifiers + ResponseHeaders *HTTPHeaderModifiers + Service string + ServiceSubset string + Weight float32 + func (s *ServiceSplit) MergeParent(parent *ServiceSplit) (*ServiceSplit, error) + func (split *ServiceSplit) GetEnterpriseMeta(_ *acl.EnterpriseMeta) *acl.EnterpriseMeta + type ServiceSplitterConfigEntry struct + Hash uint64 + Kind string + Meta map[string]string + Name string + Splits []ServiceSplit + func (e *ServiceSplitterConfigEntry) CanRead(authz acl.Authorizer) error + func (e *ServiceSplitterConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *ServiceSplitterConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *ServiceSplitterConfigEntry) GetHash() uint64 + func (e *ServiceSplitterConfigEntry) GetKind() string + func (e *ServiceSplitterConfigEntry) GetMeta() map[string]string + func (e *ServiceSplitterConfigEntry) GetName() string + func (e *ServiceSplitterConfigEntry) GetRaftIndex() *RaftIndex + func (e *ServiceSplitterConfigEntry) ListRelatedServices() []ServiceID + func (e *ServiceSplitterConfigEntry) Normalize() error + func (e *ServiceSplitterConfigEntry) SetHash(h uint64) + func (e *ServiceSplitterConfigEntry) Validate() error + type ServiceTopology struct + DownstreamDecisions map[string]IntentionDecisionSummary + DownstreamSources map[string]string + Downstreams CheckServiceNodes + MetricsProtocol string + TransparentProxy bool + UpstreamDecisions map[string]IntentionDecisionSummary + UpstreamSources map[string]string + Upstreams CheckServiceNodes + type ServiceUsage struct + BillableServiceInstances int + ConnectServiceInstances map[string]int + Nodes int + ServiceInstances int + Services int + type Services map[string][]string + type Session struct + Behavior SessionBehavior + Checks []types.CheckID + ID string + LockDelay time.Duration + Name string + Node string + NodeChecks []string + ServiceChecks []ServiceCheck + TTL string + func (s *Session) CheckIDs() []types.CheckID + func (s *Session) IDValue() string + func (s *Session) UnmarshalJSON(data []byte) (err error) + type SessionBehavior string + const SessionKeysDelete + const SessionKeysRelease + type SessionOp string + const SessionCreate + const SessionDestroy + type SessionRequest struct + Datacenter string + Op SessionOp + Session Session + func (r *SessionRequest) RequestDatacenter() string + type SessionSpecificRequest struct + Datacenter string + Session string + SessionID string + func (r *SessionSpecificRequest) RequestDatacenter() string + type Sessions []*Session + type SignedResponse struct + ConnectCARoots IndexedCARoots + GossipKey string + IssuedCert IssuedCert + ManualCARoots []string + VerifyServerHostname bool + type SimplifiedIntentions Intentions + type SnapshotOp int + const SnapshotRestore + const SnapshotSave + type SnapshotReplyFn func(reply *SnapshotResponse) error + type SnapshotRequest struct + AllowStale bool + Datacenter string + Op SnapshotOp + Token string + type SnapshotResponse struct + Error string + type SourceIntention struct + Action IntentionAction + Description string + LegacyCreateTime *time.Time + LegacyID string + LegacyMeta map[string]string + LegacyUpdateTime *time.Time + Name string + Peer string + Permissions []*IntentionPermission + Precedence int + SamenessGroup string + Type IntentionSourceType + func (x *SourceIntention) Clone() *SourceIntention + func (x *SourceIntention) SourceServiceName() ServiceName + type Status struct + Conditions []Condition + func (o *Status) DeepCopy() *Status + func (s *Status) MatchesConditionStatus(condition Condition) bool + func (s Status) SameConditions(other Status) bool + type StatusUpdater struct + func NewStatusUpdater(entry ControlledConfigEntry) *StatusUpdater + func (u *StatusUpdater) ClearConditions() + func (u *StatusUpdater) RemoveCondition(condition Condition) + func (u *StatusUpdater) SetCondition(condition Condition) + func (u *StatusUpdater) UpdateEntry() (ControlledConfigEntry, bool) + type SystemMetadataEntry struct + Key string + Value string + type SystemMetadataOp string + const SystemMetadataDelete + const SystemMetadataUpsert + type SystemMetadataRequest struct + Datacenter string + Entry *SystemMetadataEntry + Op SystemMetadataOp + func (c *SystemMetadataRequest) RequestDatacenter() string + type TCPRouteConfigEntry struct + Hash uint64 + Kind string + Meta map[string]string + Name string + Parents []ResourceReference + Services []TCPService + Status Status + func (e *TCPRouteConfigEntry) CanRead(authz acl.Authorizer) error + func (e *TCPRouteConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *TCPRouteConfigEntry) DefaultStatus() Status + func (e *TCPRouteConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *TCPRouteConfigEntry) GetHash() uint64 + func (e *TCPRouteConfigEntry) GetKind() string + func (e *TCPRouteConfigEntry) GetMeta() map[string]string + func (e *TCPRouteConfigEntry) GetName() string + func (e *TCPRouteConfigEntry) GetParents() []ResourceReference + func (e *TCPRouteConfigEntry) GetProtocol() APIGatewayListenerProtocol + func (e *TCPRouteConfigEntry) GetRaftIndex() *RaftIndex + func (e *TCPRouteConfigEntry) GetServiceNames() []ServiceName + func (e *TCPRouteConfigEntry) GetServices() []TCPService + func (e *TCPRouteConfigEntry) GetStatus() Status + func (e *TCPRouteConfigEntry) Normalize() error + func (e *TCPRouteConfigEntry) SetHash(h uint64) + func (e *TCPRouteConfigEntry) SetStatus(status Status) + func (e *TCPRouteConfigEntry) Validate() error + func (o *TCPRouteConfigEntry) DeepCopy() *TCPRouteConfigEntry + type TCPService struct + Name string + func (s TCPService) ServiceName() ServiceName + type TerminatingGatewayConfigEntry struct + Hash uint64 + Kind string + Meta map[string]string + Name string + Services []LinkedService + func (e *TerminatingGatewayConfigEntry) CanRead(authz acl.Authorizer) error + func (e *TerminatingGatewayConfigEntry) CanWrite(authz acl.Authorizer) error + func (e *TerminatingGatewayConfigEntry) GetEnterpriseMeta() *acl.EnterpriseMeta + func (e *TerminatingGatewayConfigEntry) GetHash() uint64 + func (e *TerminatingGatewayConfigEntry) GetKind() string + func (e *TerminatingGatewayConfigEntry) GetMeta() map[string]string + func (e *TerminatingGatewayConfigEntry) GetName() string + func (e *TerminatingGatewayConfigEntry) GetRaftIndex() *RaftIndex + func (e *TerminatingGatewayConfigEntry) Normalize() error + func (e *TerminatingGatewayConfigEntry) SetHash(h uint64) + func (e *TerminatingGatewayConfigEntry) Validate() error + func (e *TerminatingGatewayConfigEntry) Warnings() []string + type TombstoneOp string + const TombstoneReap + type TombstoneRequest struct + Datacenter string + Op TombstoneOp + ReapIndex uint64 + func (r *TombstoneRequest) RequestDatacenter() string + type TransparentProxyConfig struct + DialedDirectly bool + OutboundListenerPort int + func (c *TransparentProxyConfig) IsZero() bool + func (c TransparentProxyConfig) ToAPI() *api.TransparentProxyConfig + type TransparentProxyMeshConfig struct + MeshDestinationsOnly bool + type TxnCheckOp struct + Check HealthCheck + Verb api.CheckOp + func (_ *TxnCheckOp) FillAuthzContext(_ *acl.AuthorizerContext) + type TxnCheckResult *HealthCheck + type TxnError struct + OpIndex int + What string + func (e TxnError) Error() string + type TxnErrors []*TxnError + type TxnIntentionOp IntentionRequest + type TxnKVOp struct + DirEnt DirEntry + Verb api.KVOp + type TxnKVResult *DirEntry + type TxnNodeOp struct + Node Node + Verb api.NodeOp + func (op *TxnNodeOp) FillAuthzContext(ctx *acl.AuthorizerContext) + type TxnNodeResult *Node + type TxnOp struct + Check *TxnCheckOp + Intention *TxnIntentionOp + KV *TxnKVOp + Node *TxnNodeOp + Service *TxnServiceOp + Session *TxnSessionOp + type TxnOps []*TxnOp + type TxnReadRequest struct + Datacenter string + Ops TxnOps + func (r *TxnReadRequest) RequestDatacenter() string + type TxnReadResponse struct + type TxnRequest struct + Datacenter string + Ops TxnOps + func (r *TxnRequest) RequestDatacenter() string + type TxnResponse struct + Errors TxnErrors + Results TxnResults + func (r TxnResponse) Error() error + type TxnResult struct + Check TxnCheckResult + KV TxnKVResult + Node TxnNodeResult + Service TxnServiceResult + type TxnResults []*TxnResult + type TxnServiceOp struct + Node string + Service NodeService + Verb api.ServiceOp + func (_ *TxnServiceOp) FillAuthzContext(_ *acl.AuthorizerContext) + type TxnServiceResult *NodeService + type TxnSessionOp struct + Session Session + Verb api.SessionOp + type URLRewrite struct + Path string + type UpdatableConfigEntry interface + UpdateOver func(prev ConfigEntry) error + type Upstream struct + CentrallyConfigured bool + Config map[string]interface{} + Datacenter string + DestinationName string + DestinationNamespace string + DestinationPartition string + DestinationPeer string + DestinationType string + IngressHosts []string + LocalBindAddress string + LocalBindPort int + LocalBindSocketMode string + LocalBindSocketPath string + MeshGateway MeshGatewayConfig + func UpstreamFromAPI(u api.Upstream) Upstream + func (o *Upstream) DeepCopy() *Upstream + func (t *Upstream) UnmarshalJSON(data []byte) (err error) + func (u *Upstream) HasLocalPortOrSocket() bool + func (u *Upstream) ToAPI() api.Upstream + func (u *Upstream) ToKey() UpstreamKey + func (u *Upstream) UpstreamAddressToString() string + func (u *Upstream) UpstreamIsUnixSocket() bool + func (u *Upstream) Validate() error + func (us *Upstream) DestinationID() PeeredServiceName + func (us *Upstream) GetEnterpriseMeta() *acl.EnterpriseMeta + func (us *Upstream) String() string + type UpstreamConfig struct + BalanceOutboundConnections string + ConnectTimeoutMs int + EnvoyClusterJSON string + EnvoyListenerJSON string + Limits *UpstreamLimits + MeshGateway MeshGatewayConfig + Name string + PassiveHealthCheck *PassiveHealthCheck + Peer string + Protocol string + func ParseUpstreamConfig(m map[string]interface{}) (UpstreamConfig, error) + func ParseUpstreamConfigNoDefaults(m map[string]interface{}) (UpstreamConfig, error) + func (cfg *UpstreamConfig) NormalizeWithName(entMeta *acl.EnterpriseMeta) error + func (cfg *UpstreamConfig) NormalizeWithoutName() error + func (cfg *UpstreamConfig) PeeredServiceName() PeeredServiceName + func (cfg UpstreamConfig) Clone() UpstreamConfig + func (cfg UpstreamConfig) MergeInto(dst map[string]interface{}) + func (cfg UpstreamConfig) ValidateWithName() error + func (cfg UpstreamConfig) ValidateWithoutName() error + type UpstreamConfiguration struct + Defaults *UpstreamConfig + Overrides []*UpstreamConfig + func (c *UpstreamConfiguration) Clone() *UpstreamConfiguration + func (o *UpstreamConfiguration) DeepCopy() *UpstreamConfiguration + type UpstreamKey struct + Datacenter string + DestinationName string + DestinationNamespace string + DestinationPartition string + DestinationPeer string + DestinationType string + func (k UpstreamKey) String() string + type UpstreamLimits struct + MaxConcurrentRequests *int + MaxConnections *int + MaxPendingRequests *int + func (ul *UpstreamLimits) Clone() *UpstreamLimits + func (ul *UpstreamLimits) IsZero() bool + func (ul UpstreamLimits) Validate() error + type Upstreams []Upstream + func TestAddDefaultsToUpstreams(t testing.T, upstreams []Upstream, entMeta acl.EnterpriseMeta) Upstreams + func TestUpstreams(t testing.T, enterprise bool) Upstreams + func UpstreamsFromAPI(us []api.Upstream) Upstreams + func (us Upstreams) ToAPI() []api.Upstream + type Usage struct + Usage map[string]ServiceUsage + type VaultAuthMethod struct + MountPath string + Params map[string]interface{} + Type string + type VaultCAProviderConfig struct + Address string + AuthMethod *VaultAuthMethod + CAFile string + CAPath string + CertFile string + IntermediatePKINamespace string + IntermediatePKIPath string + KeyFile string + Namespace string + RootPKINamespace string + RootPKIPath string + TLSServerName string + TLSSkipVerify bool + Token string + type WarningConfigEntry interface + Warnings func() []string + type Weights struct + Passing int + Warning int + type WriteRequest struct + Token string + func (w *WriteRequest) SetTokenSecret(s string) + func (w WriteRequest) AllowStaleRead() bool + func (w WriteRequest) HasTimedOut(start time.Time, rpcHoldTimeout, _, _ time.Duration) (bool, error) + func (w WriteRequest) IsRead() bool + func (w WriteRequest) TokenSecret() string
Go to main page