Documentation
¶
Overview ¶
Package v1 contains API Schema definitions for the networking.mesh.gloo.solo.io v1 API group +k8s:deepcopy-gen=package,register +groupName=networking.mesh.gloo.solo.io
NOTE: Boilerplate only. Ignore this file. Used to register the Go types with the Kubernetes internal scheme
Definitions for the Kubernetes types ¶
Definitions for the Kubernetes types
Index ¶
- Variables
- func AddToScheme(s *runtime.Scheme) error
- func NewAccessPolicyClient(client client.Client) *accessPolicyClient
- func NewTrafficPolicyClient(client client.Client) *trafficPolicyClient
- func NewVirtualMeshClient(client client.Client) *virtualMeshClient
- func Resource(resource string) schema.GroupResource
- type AccessPolicy
- type AccessPolicyClient
- type AccessPolicyList
- type AccessPolicyReader
- type AccessPolicySlice
- type AccessPolicySpec
- func (in *AccessPolicySpec) DeepCopyInto(out *AccessPolicySpec)
- func (*AccessPolicySpec) Descriptor() ([]byte, []int)deprecated
- func (m *AccessPolicySpec) Equal(that interface{}) bool
- func (x *AccessPolicySpec) GetAllowedMethods() []string
- func (x *AccessPolicySpec) GetAllowedPaths() []string
- func (x *AccessPolicySpec) GetAllowedPorts() []uint32
- func (x *AccessPolicySpec) GetDestinationSelector() []*v1.DestinationSelector
- func (x *AccessPolicySpec) GetSourceSelector() []*v1.IdentitySelector
- func (this *AccessPolicySpec) MarshalJSON() ([]byte, error)
- func (*AccessPolicySpec) ProtoMessage()
- func (x *AccessPolicySpec) ProtoReflect() protoreflect.Message
- func (x *AccessPolicySpec) Reset()
- func (x *AccessPolicySpec) String() string
- func (this *AccessPolicySpec) UnmarshalJSON(b []byte) error
- type AccessPolicyStatus
- func (in *AccessPolicyStatus) DeepCopyInto(out *AccessPolicyStatus)
- func (*AccessPolicyStatus) Descriptor() ([]byte, []int)deprecated
- func (m *AccessPolicyStatus) Equal(that interface{}) bool
- func (x *AccessPolicyStatus) GetDestinations() map[string]*ApprovalStatus
- func (x *AccessPolicyStatus) GetErrors() []string
- func (x *AccessPolicyStatus) GetObservedGeneration() int64
- func (x *AccessPolicyStatus) GetState() v1.ApprovalState
- func (x *AccessPolicyStatus) GetWorkloads() []string
- func (this *AccessPolicyStatus) MarshalJSON() ([]byte, error)
- func (*AccessPolicyStatus) ProtoMessage()
- func (x *AccessPolicyStatus) ProtoReflect() protoreflect.Message
- func (x *AccessPolicyStatus) Reset()
- func (x *AccessPolicyStatus) String() string
- func (this *AccessPolicyStatus) UnmarshalJSON(b []byte) error
- type AccessPolicyStatusWriter
- type AccessPolicyTransitionFunction
- type AccessPolicyWriter
- type Action
- func (*Action) Descriptor() ([]byte, []int)deprecated
- func (m *Action) Equal(that interface{}) bool
- func (m *Action) GetActionSpecifier() isAction_ActionSpecifier
- func (x *Action) GetDestinationCluster() *Action_DestinationCluster
- func (x *Action) GetGenericKey() *Action_GenericKey
- func (x *Action) GetHeaderValueMatch() *Action_HeaderValueMatch
- func (x *Action) GetMetadata() *MetaData
- func (x *Action) GetRemoteAddress() *Action_RemoteAddress
- func (x *Action) GetRequestHeaders() *Action_RequestHeaders
- func (x *Action) GetSourceCluster() *Action_SourceCluster
- func (*Action) ProtoMessage()
- func (x *Action) ProtoReflect() protoreflect.Message
- func (x *Action) Reset()
- func (x *Action) String() string
- type Action_DestinationCluster
- func (*Action_DestinationCluster) Descriptor() ([]byte, []int)deprecated
- func (m *Action_DestinationCluster) Equal(that interface{}) bool
- func (*Action_DestinationCluster) ProtoMessage()
- func (x *Action_DestinationCluster) ProtoReflect() protoreflect.Message
- func (x *Action_DestinationCluster) Reset()
- func (x *Action_DestinationCluster) String() string
- type Action_DestinationCluster_
- type Action_GenericKey
- func (*Action_GenericKey) Descriptor() ([]byte, []int)deprecated
- func (m *Action_GenericKey) Equal(that interface{}) bool
- func (x *Action_GenericKey) GetDescriptorValue() string
- func (*Action_GenericKey) ProtoMessage()
- func (x *Action_GenericKey) ProtoReflect() protoreflect.Message
- func (x *Action_GenericKey) Reset()
- func (x *Action_GenericKey) String() string
- type Action_GenericKey_
- type Action_HeaderValueMatch
- func (*Action_HeaderValueMatch) Descriptor() ([]byte, []int)deprecated
- func (m *Action_HeaderValueMatch) Equal(that interface{}) bool
- func (x *Action_HeaderValueMatch) GetDescriptorValue() string
- func (x *Action_HeaderValueMatch) GetExpectMatch() *wrappers.BoolValue
- func (x *Action_HeaderValueMatch) GetHeaders() []*Action_HeaderValueMatch_HeaderMatcher
- func (*Action_HeaderValueMatch) ProtoMessage()
- func (x *Action_HeaderValueMatch) ProtoReflect() protoreflect.Message
- func (x *Action_HeaderValueMatch) Reset()
- func (x *Action_HeaderValueMatch) String() string
- type Action_HeaderValueMatch_
- type Action_HeaderValueMatch_HeaderMatcher
- func (*Action_HeaderValueMatch_HeaderMatcher) Descriptor() ([]byte, []int)deprecated
- func (m *Action_HeaderValueMatch_HeaderMatcher) Equal(that interface{}) bool
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetExactMatch() string
- func (m *Action_HeaderValueMatch_HeaderMatcher) GetHeaderMatchSpecifier() isAction_HeaderValueMatch_HeaderMatcher_HeaderMatchSpecifier
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetInvertMatch() bool
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetName() string
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetPrefixMatch() string
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetPresentMatch() bool
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetRangeMatch() *Action_HeaderValueMatch_HeaderMatcher_Int64Range
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetRegexMatch() string
- func (x *Action_HeaderValueMatch_HeaderMatcher) GetSuffixMatch() string
- func (*Action_HeaderValueMatch_HeaderMatcher) ProtoMessage()
- func (x *Action_HeaderValueMatch_HeaderMatcher) ProtoReflect() protoreflect.Message
- func (x *Action_HeaderValueMatch_HeaderMatcher) Reset()
- func (x *Action_HeaderValueMatch_HeaderMatcher) String() string
- type Action_HeaderValueMatch_HeaderMatcher_ExactMatch
- type Action_HeaderValueMatch_HeaderMatcher_Int64Range
- func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) Descriptor() ([]byte, []int)deprecated
- func (m *Action_HeaderValueMatch_HeaderMatcher_Int64Range) Equal(that interface{}) bool
- func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) GetEnd() int64
- func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) GetStart() int64
- func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) ProtoMessage()
- func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) ProtoReflect() protoreflect.Message
- func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) Reset()
- func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) String() string
- type Action_HeaderValueMatch_HeaderMatcher_PrefixMatch
- type Action_HeaderValueMatch_HeaderMatcher_PresentMatch
- type Action_HeaderValueMatch_HeaderMatcher_RangeMatch
- type Action_HeaderValueMatch_HeaderMatcher_RegexMatch
- type Action_HeaderValueMatch_HeaderMatcher_SuffixMatch
- type Action_Metadata
- type Action_RemoteAddress
- func (*Action_RemoteAddress) Descriptor() ([]byte, []int)deprecated
- func (m *Action_RemoteAddress) Equal(that interface{}) bool
- func (*Action_RemoteAddress) ProtoMessage()
- func (x *Action_RemoteAddress) ProtoReflect() protoreflect.Message
- func (x *Action_RemoteAddress) Reset()
- func (x *Action_RemoteAddress) String() string
- type Action_RemoteAddress_
- type Action_RequestHeaders
- func (*Action_RequestHeaders) Descriptor() ([]byte, []int)deprecated
- func (m *Action_RequestHeaders) Equal(that interface{}) bool
- func (x *Action_RequestHeaders) GetDescriptorKey() string
- func (x *Action_RequestHeaders) GetHeaderName() string
- func (*Action_RequestHeaders) ProtoMessage()
- func (x *Action_RequestHeaders) ProtoReflect() protoreflect.Message
- func (x *Action_RequestHeaders) Reset()
- func (x *Action_RequestHeaders) String() string
- type Action_RequestHeaders_
- type Action_SourceCluster
- func (*Action_SourceCluster) Descriptor() ([]byte, []int)deprecated
- func (m *Action_SourceCluster) Equal(that interface{}) bool
- func (*Action_SourceCluster) ProtoMessage()
- func (x *Action_SourceCluster) ProtoReflect() protoreflect.Message
- func (x *Action_SourceCluster) Reset()
- func (x *Action_SourceCluster) String() string
- type Action_SourceCluster_
- type AppliedTrafficPolicy
- func (*AppliedTrafficPolicy) Descriptor() ([]byte, []int)deprecated
- func (m *AppliedTrafficPolicy) Equal(that interface{}) bool
- func (x *AppliedTrafficPolicy) GetObservedGeneration() int64
- func (x *AppliedTrafficPolicy) GetRef() *v1.ObjectRef
- func (x *AppliedTrafficPolicy) GetRoutes() []string
- func (x *AppliedTrafficPolicy) GetSpec() *TrafficPolicySpec
- func (*AppliedTrafficPolicy) ProtoMessage()
- func (x *AppliedTrafficPolicy) ProtoReflect() protoreflect.Message
- func (x *AppliedTrafficPolicy) Reset()
- func (x *AppliedTrafficPolicy) String() string
- type ApprovalStatus
- func (*ApprovalStatus) Descriptor() ([]byte, []int)deprecated
- func (m *ApprovalStatus) Equal(that interface{}) bool
- func (x *ApprovalStatus) GetAcceptanceOrder() uint32
- func (x *ApprovalStatus) GetErrors() []string
- func (x *ApprovalStatus) GetState() v1.ApprovalState
- func (x *ApprovalStatus) GetWarnings() []string
- func (*ApprovalStatus) ProtoMessage()
- func (x *ApprovalStatus) ProtoReflect() protoreflect.Message
- func (x *ApprovalStatus) Reset()
- func (x *ApprovalStatus) String() string
- type Clientset
- type DestinationPolicySpec
- func (*DestinationPolicySpec) Descriptor() ([]byte, []int)deprecated
- func (m *DestinationPolicySpec) Equal(that interface{}) bool
- func (x *DestinationPolicySpec) GetDestinationSelector() []*v1.DestinationSelector
- func (x *DestinationPolicySpec) GetPolicy() *DestinationPolicySpec_Policy
- func (*DestinationPolicySpec) ProtoMessage()
- func (x *DestinationPolicySpec) ProtoReflect() protoreflect.Message
- func (x *DestinationPolicySpec) Reset()
- func (x *DestinationPolicySpec) String() string
- type DestinationPolicySpec_Policy
- func (*DestinationPolicySpec_Policy) Descriptor() ([]byte, []int)deprecated
- func (m *DestinationPolicySpec_Policy) Equal(that interface{}) bool
- func (x *DestinationPolicySpec_Policy) GetMtls() *DestinationPolicySpec_Policy_MTLS
- func (x *DestinationPolicySpec_Policy) GetOutlierDetection() *DestinationPolicySpec_Policy_OutlierDetection
- func (*DestinationPolicySpec_Policy) ProtoMessage()
- func (x *DestinationPolicySpec_Policy) ProtoReflect() protoreflect.Message
- func (x *DestinationPolicySpec_Policy) Reset()
- func (x *DestinationPolicySpec_Policy) String() string
- type DestinationPolicySpec_Policy_MTLS
- func (*DestinationPolicySpec_Policy_MTLS) Descriptor() ([]byte, []int)deprecated
- func (m *DestinationPolicySpec_Policy_MTLS) Equal(that interface{}) bool
- func (x *DestinationPolicySpec_Policy_MTLS) GetIstio() *DestinationPolicySpec_Policy_MTLS_Istio
- func (*DestinationPolicySpec_Policy_MTLS) ProtoMessage()
- func (x *DestinationPolicySpec_Policy_MTLS) ProtoReflect() protoreflect.Message
- func (x *DestinationPolicySpec_Policy_MTLS) Reset()
- func (x *DestinationPolicySpec_Policy_MTLS) String() string
- type DestinationPolicySpec_Policy_MTLS_Istio
- func (*DestinationPolicySpec_Policy_MTLS_Istio) Descriptor() ([]byte, []int)deprecated
- func (m *DestinationPolicySpec_Policy_MTLS_Istio) Equal(that interface{}) bool
- func (x *DestinationPolicySpec_Policy_MTLS_Istio) GetTlsMode() DestinationPolicySpec_Policy_MTLS_Istio_TLSmode
- func (*DestinationPolicySpec_Policy_MTLS_Istio) ProtoMessage()
- func (x *DestinationPolicySpec_Policy_MTLS_Istio) ProtoReflect() protoreflect.Message
- func (x *DestinationPolicySpec_Policy_MTLS_Istio) Reset()
- func (x *DestinationPolicySpec_Policy_MTLS_Istio) String() string
- type DestinationPolicySpec_Policy_MTLS_Istio_TLSmode
- func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Descriptor() protoreflect.EnumDescriptor
- func (x DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Enum() *DestinationPolicySpec_Policy_MTLS_Istio_TLSmode
- func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) EnumDescriptor() ([]byte, []int)deprecated
- func (x DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Number() protoreflect.EnumNumber
- func (x DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) String() string
- func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Type() protoreflect.EnumType
- type DestinationPolicySpec_Policy_OutlierDetection
- func (*DestinationPolicySpec_Policy_OutlierDetection) Descriptor() ([]byte, []int)deprecated
- func (m *DestinationPolicySpec_Policy_OutlierDetection) Equal(that interface{}) bool
- func (x *DestinationPolicySpec_Policy_OutlierDetection) GetBaseEjectionTime() *duration.Duration
- func (x *DestinationPolicySpec_Policy_OutlierDetection) GetConsecutiveErrors() uint32
- func (x *DestinationPolicySpec_Policy_OutlierDetection) GetInterval() *duration.Duration
- func (x *DestinationPolicySpec_Policy_OutlierDetection) GetMaxEjectionPercent() uint32
- func (*DestinationPolicySpec_Policy_OutlierDetection) ProtoMessage()
- func (x *DestinationPolicySpec_Policy_OutlierDetection) ProtoReflect() protoreflect.Message
- func (x *DestinationPolicySpec_Policy_OutlierDetection) Reset()
- func (x *DestinationPolicySpec_Policy_OutlierDetection) String() string
- type DestinationPolicyStatus
- func (*DestinationPolicyStatus) Descriptor() ([]byte, []int)deprecated
- func (m *DestinationPolicyStatus) Equal(that interface{}) bool
- func (x *DestinationPolicyStatus) GetErrors() []string
- func (x *DestinationPolicyStatus) GetObservedGeneration() int64
- func (x *DestinationPolicyStatus) GetState() v1.ApprovalState
- func (*DestinationPolicyStatus) ProtoMessage()
- func (x *DestinationPolicyStatus) ProtoReflect() protoreflect.Message
- func (x *DestinationPolicyStatus) Reset()
- func (x *DestinationPolicyStatus) String() string
- type GatewayRoutes
- func (*GatewayRoutes) Descriptor() ([]byte, []int)deprecated
- func (m *GatewayRoutes) Equal(that interface{}) bool
- func (x *GatewayRoutes) GetRoutes() []string
- func (*GatewayRoutes) ProtoMessage()
- func (x *GatewayRoutes) ProtoReflect() protoreflect.Message
- func (x *GatewayRoutes) Reset()
- func (x *GatewayRoutes) String() string
- type HeaderManipulation
- func (*HeaderManipulation) Descriptor() ([]byte, []int)deprecated
- func (m *HeaderManipulation) Equal(that interface{}) bool
- func (x *HeaderManipulation) GetAppendRequestHeaders() map[string]string
- func (x *HeaderManipulation) GetAppendResponseHeaders() map[string]string
- func (x *HeaderManipulation) GetRemoveRequestHeaders() []string
- func (x *HeaderManipulation) GetRemoveResponseHeaders() []string
- func (*HeaderManipulation) ProtoMessage()
- func (x *HeaderManipulation) ProtoReflect() protoreflect.Message
- func (x *HeaderManipulation) Reset()
- func (x *HeaderManipulation) String() string
- type HeaderMatcher
- func (*HeaderMatcher) Descriptor() ([]byte, []int)deprecated
- func (x *HeaderMatcher) GetInvertMatch() bool
- func (x *HeaderMatcher) GetName() string
- func (x *HeaderMatcher) GetRegex() bool
- func (x *HeaderMatcher) GetValue() string
- func (*HeaderMatcher) ProtoMessage()
- func (x *HeaderMatcher) ProtoReflect() protoreflect.Message
- func (x *HeaderMatcher) Reset()
- func (x *HeaderMatcher) String() string
- type HttpMatcher
- func (*HttpMatcher) Descriptor() ([]byte, []int)deprecated
- func (x *HttpMatcher) GetHeaders() []*HeaderMatcher
- func (x *HttpMatcher) GetMethod() string
- func (x *HttpMatcher) GetName() string
- func (x *HttpMatcher) GetQueryParameters() []*HttpMatcher_QueryParameterMatcher
- func (x *HttpMatcher) GetUri() *v1.StringMatch
- func (*HttpMatcher) ProtoMessage()
- func (x *HttpMatcher) ProtoReflect() protoreflect.Message
- func (x *HttpMatcher) Reset()
- func (x *HttpMatcher) String() string
- type HttpMatcher_QueryParameterMatcher
- func (*HttpMatcher_QueryParameterMatcher) Descriptor() ([]byte, []int)deprecated
- func (x *HttpMatcher_QueryParameterMatcher) GetName() string
- func (x *HttpMatcher_QueryParameterMatcher) GetRegex() bool
- func (x *HttpMatcher_QueryParameterMatcher) GetValue() string
- func (*HttpMatcher_QueryParameterMatcher) ProtoMessage()
- func (x *HttpMatcher_QueryParameterMatcher) ProtoReflect() protoreflect.Message
- func (x *HttpMatcher_QueryParameterMatcher) Reset()
- func (x *HttpMatcher_QueryParameterMatcher) String() string
- type MetaData
- func (*MetaData) Descriptor() ([]byte, []int)deprecated
- func (m *MetaData) Equal(that interface{}) bool
- func (x *MetaData) GetDefaultValue() string
- func (x *MetaData) GetDescriptorKey() string
- func (x *MetaData) GetMetadataKey() *MetaData_MetadataKey
- func (x *MetaData) GetSource() MetaData_Source
- func (*MetaData) ProtoMessage()
- func (x *MetaData) ProtoReflect() protoreflect.Message
- func (x *MetaData) Reset()
- func (x *MetaData) String() string
- type MetaData_MetadataKey
- func (*MetaData_MetadataKey) Descriptor() ([]byte, []int)deprecated
- func (m *MetaData_MetadataKey) Equal(that interface{}) bool
- func (x *MetaData_MetadataKey) GetKey() string
- func (x *MetaData_MetadataKey) GetPath() []*MetaData_MetadataKey_PathSegment
- func (*MetaData_MetadataKey) ProtoMessage()
- func (x *MetaData_MetadataKey) ProtoReflect() protoreflect.Message
- func (x *MetaData_MetadataKey) Reset()
- func (x *MetaData_MetadataKey) String() string
- type MetaData_MetadataKey_PathSegment
- func (*MetaData_MetadataKey_PathSegment) Descriptor() ([]byte, []int)deprecated
- func (m *MetaData_MetadataKey_PathSegment) Equal(that interface{}) bool
- func (x *MetaData_MetadataKey_PathSegment) GetKey() string
- func (m *MetaData_MetadataKey_PathSegment) GetSegment() isMetaData_MetadataKey_PathSegment_Segment
- func (*MetaData_MetadataKey_PathSegment) ProtoMessage()
- func (x *MetaData_MetadataKey_PathSegment) ProtoReflect() protoreflect.Message
- func (x *MetaData_MetadataKey_PathSegment) Reset()
- func (x *MetaData_MetadataKey_PathSegment) String() string
- type MetaData_MetadataKey_PathSegment_Key
- type MetaData_Source
- func (MetaData_Source) Descriptor() protoreflect.EnumDescriptor
- func (x MetaData_Source) Enum() *MetaData_Source
- func (MetaData_Source) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetaData_Source) Number() protoreflect.EnumNumber
- func (x MetaData_Source) String() string
- func (MetaData_Source) Type() protoreflect.EnumType
- type MulticlusterAccessPolicyClient
- type MulticlusterClientset
- type MulticlusterTrafficPolicyClient
- type MulticlusterVirtualMeshClient
- type RateLimitActions
- func (*RateLimitActions) Descriptor() ([]byte, []int)deprecated
- func (m *RateLimitActions) Equal(that interface{}) bool
- func (x *RateLimitActions) GetActions() []*Action
- func (x *RateLimitActions) GetSetActions() []*Action
- func (*RateLimitActions) ProtoMessage()
- func (x *RateLimitActions) ProtoReflect() protoreflect.Message
- func (x *RateLimitActions) Reset()
- func (x *RateLimitActions) String() string
- type RateLimitRouteExtension
- func (*RateLimitRouteExtension) Descriptor() ([]byte, []int)deprecated
- func (m *RateLimitRouteExtension) Equal(that interface{}) bool
- func (x *RateLimitRouteExtension) GetIncludeVhRateLimits() bool
- func (x *RateLimitRouteExtension) GetRateLimits() []*RateLimitActions
- func (*RateLimitRouteExtension) ProtoMessage()
- func (x *RateLimitRouteExtension) ProtoReflect() protoreflect.Message
- func (x *RateLimitRouteExtension) Reset()
- func (x *RateLimitRouteExtension) String() string
- type RequestLimit
- func (*RequestLimit) Descriptor() ([]byte, []int)deprecated
- func (m *RequestLimit) Equal(that interface{}) bool
- func (x *RequestLimit) GetRequestsPerUnit() uint32
- func (x *RequestLimit) GetUnit() RequestLimit_Unit
- func (*RequestLimit) ProtoMessage()
- func (x *RequestLimit) ProtoReflect() protoreflect.Message
- func (x *RequestLimit) Reset()
- func (x *RequestLimit) String() string
- type RequestLimit_Unit
- func (RequestLimit_Unit) Descriptor() protoreflect.EnumDescriptor
- func (x RequestLimit_Unit) Enum() *RequestLimit_Unit
- func (RequestLimit_Unit) EnumDescriptor() ([]byte, []int)deprecated
- func (x RequestLimit_Unit) Number() protoreflect.EnumNumber
- func (x RequestLimit_Unit) String() string
- func (RequestLimit_Unit) Type() protoreflect.EnumType
- type RootCertificateAuthority
- func (*RootCertificateAuthority) Descriptor() ([]byte, []int)deprecated
- func (m *RootCertificateAuthority) Equal(that interface{}) bool
- func (m *RootCertificateAuthority) GetCaSource() isRootCertificateAuthority_CaSource
- func (x *RootCertificateAuthority) GetGenerated() *v11.CommonCertOptions
- func (x *RootCertificateAuthority) GetSecret() *v1.ObjectRef
- func (*RootCertificateAuthority) ProtoMessage()
- func (x *RootCertificateAuthority) ProtoReflect() protoreflect.Message
- func (x *RootCertificateAuthority) Reset()
- func (x *RootCertificateAuthority) String() string
- type RootCertificateAuthority_Generated
- type RootCertificateAuthority_Secret
- type RouteRateLimit
- func (*RouteRateLimit) Descriptor() ([]byte, []int)deprecated
- func (m *RouteRateLimit) Equal(that interface{}) bool
- func (x *RouteRateLimit) GetAdvanced() *RouteRateLimit_AdvancedRateLimit
- func (x *RouteRateLimit) GetBasic() *RouteRateLimit_BasicRateLimit
- func (x *RouteRateLimit) GetConfigRefs() *v1.ObjectRefList
- func (m *RouteRateLimit) GetRateLimitConfigType() isRouteRateLimit_RateLimitConfigType
- func (*RouteRateLimit) ProtoMessage()
- func (x *RouteRateLimit) ProtoReflect() protoreflect.Message
- func (x *RouteRateLimit) Reset()
- func (x *RouteRateLimit) String() string
- type RouteRateLimit_Advanced
- type RouteRateLimit_AdvancedRateLimit
- func (*RouteRateLimit_AdvancedRateLimit) Descriptor() ([]byte, []int)deprecated
- func (m *RouteRateLimit_AdvancedRateLimit) Equal(that interface{}) bool
- func (x *RouteRateLimit_AdvancedRateLimit) GetActions() []*RateLimitActions
- func (*RouteRateLimit_AdvancedRateLimit) ProtoMessage()
- func (x *RouteRateLimit_AdvancedRateLimit) ProtoReflect() protoreflect.Message
- func (x *RouteRateLimit_AdvancedRateLimit) Reset()
- func (x *RouteRateLimit_AdvancedRateLimit) String() string
- type RouteRateLimit_Basic
- type RouteRateLimit_BasicRateLimit
- func (*RouteRateLimit_BasicRateLimit) Descriptor() ([]byte, []int)deprecated
- func (m *RouteRateLimit_BasicRateLimit) Equal(that interface{}) bool
- func (x *RouteRateLimit_BasicRateLimit) GetAnonymousLimits() *RequestLimit
- func (x *RouteRateLimit_BasicRateLimit) GetAuthorizedLimits() *RequestLimit
- func (*RouteRateLimit_BasicRateLimit) ProtoMessage()
- func (x *RouteRateLimit_BasicRateLimit) ProtoReflect() protoreflect.Message
- func (x *RouteRateLimit_BasicRateLimit) Reset()
- func (x *RouteRateLimit_BasicRateLimit) String() string
- type RouteRateLimit_ConfigRefs
- type SetDescriptor
- func (*SetDescriptor) Descriptor() ([]byte, []int)deprecated
- func (m *SetDescriptor) Equal(that interface{}) bool
- func (x *SetDescriptor) GetAlwaysApply() bool
- func (x *SetDescriptor) GetRateLimit() *RequestLimit
- func (x *SetDescriptor) GetSimpleDescriptors() []*SimpleDescriptor
- func (*SetDescriptor) ProtoMessage()
- func (x *SetDescriptor) ProtoReflect() protoreflect.Message
- func (x *SetDescriptor) Reset()
- func (x *SetDescriptor) String() string
- type SharedTrust
- func (*SharedTrust) Descriptor() ([]byte, []int)deprecated
- func (m *SharedTrust) Equal(that interface{}) bool
- func (m *SharedTrust) GetCertificateAuthority() isSharedTrust_CertificateAuthority
- func (x *SharedTrust) GetIntermediateCertOptions() *v11.CommonCertOptions
- func (x *SharedTrust) GetIntermediateCertificateAuthority() *v11.IntermediateCertificateAuthority
- func (x *SharedTrust) GetRootCertificateAuthority() *RootCertificateAuthority
- func (*SharedTrust) ProtoMessage()
- func (x *SharedTrust) ProtoReflect() protoreflect.Message
- func (x *SharedTrust) Reset()
- func (x *SharedTrust) String() string
- type SharedTrust_IntermediateCertificateAuthority
- type SharedTrust_RootCertificateAuthority
- type SimpleDescriptor
- func (*SimpleDescriptor) Descriptor() ([]byte, []int)deprecated
- func (m *SimpleDescriptor) Equal(that interface{}) bool
- func (x *SimpleDescriptor) GetKey() string
- func (x *SimpleDescriptor) GetValue() string
- func (*SimpleDescriptor) ProtoMessage()
- func (x *SimpleDescriptor) ProtoReflect() protoreflect.Message
- func (x *SimpleDescriptor) Reset()
- func (x *SimpleDescriptor) String() string
- type StatusCodeMatcher
- func (*StatusCodeMatcher) Descriptor() ([]byte, []int)deprecated
- func (x *StatusCodeMatcher) GetComparator() StatusCodeMatcher_Comparator
- func (x *StatusCodeMatcher) GetValue() uint32
- func (*StatusCodeMatcher) ProtoMessage()
- func (x *StatusCodeMatcher) ProtoReflect() protoreflect.Message
- func (x *StatusCodeMatcher) Reset()
- func (x *StatusCodeMatcher) String() string
- type StatusCodeMatcher_Comparator
- func (StatusCodeMatcher_Comparator) Descriptor() protoreflect.EnumDescriptor
- func (x StatusCodeMatcher_Comparator) Enum() *StatusCodeMatcher_Comparator
- func (StatusCodeMatcher_Comparator) EnumDescriptor() ([]byte, []int)deprecated
- func (x StatusCodeMatcher_Comparator) Number() protoreflect.EnumNumber
- func (x StatusCodeMatcher_Comparator) String() string
- func (StatusCodeMatcher_Comparator) Type() protoreflect.EnumType
- type TrafficPolicy
- type TrafficPolicyClient
- type TrafficPolicyList
- type TrafficPolicyReader
- type TrafficPolicySlice
- type TrafficPolicySpec
- func (in *TrafficPolicySpec) DeepCopyInto(out *TrafficPolicySpec)
- func (*TrafficPolicySpec) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec) Equal(that interface{}) bool
- func (x *TrafficPolicySpec) GetDestinationSelector() []*v1.DestinationSelector
- func (x *TrafficPolicySpec) GetHttpRequestMatchers() []*HttpMatcher
- func (x *TrafficPolicySpec) GetPolicy() *TrafficPolicySpec_Policy
- func (x *TrafficPolicySpec) GetRouteSelector() []*TrafficPolicySpec_RouteSelector
- func (x *TrafficPolicySpec) GetSourceSelector() []*v1.WorkloadSelector
- func (this *TrafficPolicySpec) MarshalJSON() ([]byte, error)
- func (*TrafficPolicySpec) ProtoMessage()
- func (x *TrafficPolicySpec) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec) Reset()
- func (x *TrafficPolicySpec) String() string
- func (this *TrafficPolicySpec) UnmarshalJSON(b []byte) error
- type TrafficPolicySpec_Policy
- func (*TrafficPolicySpec_Policy) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy) GetCorsPolicy() *TrafficPolicySpec_Policy_CorsPolicy
- func (x *TrafficPolicySpec_Policy) GetCsrf() *csrf.CsrfPolicy
- func (x *TrafficPolicySpec_Policy) GetExtauth() *extauth.RouteExtauth
- func (x *TrafficPolicySpec_Policy) GetFaultInjection() *TrafficPolicySpec_Policy_FaultInjection
- func (x *TrafficPolicySpec_Policy) GetHeaderManipulation() *HeaderManipulation
- func (x *TrafficPolicySpec_Policy) GetMirror() *TrafficPolicySpec_Policy_Mirror
- func (x *TrafficPolicySpec_Policy) GetMtls() *TrafficPolicySpec_Policy_MTLS
- func (x *TrafficPolicySpec_Policy) GetOutlierDetection() *TrafficPolicySpec_Policy_OutlierDetection
- func (x *TrafficPolicySpec_Policy) GetRateLimit() *ratelimit.RouteRateLimit
- func (x *TrafficPolicySpec_Policy) GetRequestTimeout() *duration.Duration
- func (x *TrafficPolicySpec_Policy) GetRetries() *TrafficPolicySpec_Policy_RetryPolicy
- func (x *TrafficPolicySpec_Policy) GetTrafficShift() *TrafficPolicySpec_Policy_MultiDestination
- func (*TrafficPolicySpec_Policy) ProtoMessage()
- func (x *TrafficPolicySpec_Policy) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy) Reset()
- func (x *TrafficPolicySpec_Policy) String() string
- type TrafficPolicySpec_Policy_CorsPolicy
- func (*TrafficPolicySpec_Policy_CorsPolicy) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_CorsPolicy) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowCredentials() *wrappers.BoolValue
- func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowHeaders() []string
- func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowMethods() []string
- func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowOrigins() []*v1.StringMatch
- func (x *TrafficPolicySpec_Policy_CorsPolicy) GetExposeHeaders() []string
- func (x *TrafficPolicySpec_Policy_CorsPolicy) GetMaxAge() *duration.Duration
- func (*TrafficPolicySpec_Policy_CorsPolicy) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_CorsPolicy) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_CorsPolicy) Reset()
- func (x *TrafficPolicySpec_Policy_CorsPolicy) String() string
- type TrafficPolicySpec_Policy_DLPPolicy
- func (*TrafficPolicySpec_Policy_DLPPolicy) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_DLPPolicy) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_DLPPolicy) GetTodo() string
- func (*TrafficPolicySpec_Policy_DLPPolicy) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_DLPPolicy) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_DLPPolicy) Reset()
- func (x *TrafficPolicySpec_Policy_DLPPolicy) String() string
- type TrafficPolicySpec_Policy_ExtAuth
- func (*TrafficPolicySpec_Policy_ExtAuth) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_ExtAuth) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_ExtAuth) GetTodo() string
- func (*TrafficPolicySpec_Policy_ExtAuth) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_ExtAuth) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_ExtAuth) Reset()
- func (x *TrafficPolicySpec_Policy_ExtAuth) String() string
- type TrafficPolicySpec_Policy_FaultInjection
- func (*TrafficPolicySpec_Policy_FaultInjection) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_FaultInjection) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_FaultInjection) GetAbort() *TrafficPolicySpec_Policy_FaultInjection_Abort
- func (m *TrafficPolicySpec_Policy_FaultInjection) GetFaultInjectionType() isTrafficPolicySpec_Policy_FaultInjection_FaultInjectionType
- func (x *TrafficPolicySpec_Policy_FaultInjection) GetFixedDelay() *duration.Duration
- func (x *TrafficPolicySpec_Policy_FaultInjection) GetPercentage() float64
- func (*TrafficPolicySpec_Policy_FaultInjection) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_FaultInjection) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_FaultInjection) Reset()
- func (x *TrafficPolicySpec_Policy_FaultInjection) String() string
- type TrafficPolicySpec_Policy_FaultInjection_Abort
- func (*TrafficPolicySpec_Policy_FaultInjection_Abort) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_FaultInjection_Abort) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) GetHttpStatus() int32
- func (*TrafficPolicySpec_Policy_FaultInjection_Abort) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) Reset()
- func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) String() string
- type TrafficPolicySpec_Policy_FaultInjection_Abort_
- type TrafficPolicySpec_Policy_FaultInjection_FixedDelay
- type TrafficPolicySpec_Policy_MTLS
- func (*TrafficPolicySpec_Policy_MTLS) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_MTLS) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_MTLS) GetIstio() *TrafficPolicySpec_Policy_MTLS_Istio
- func (*TrafficPolicySpec_Policy_MTLS) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_MTLS) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_MTLS) Reset()
- func (x *TrafficPolicySpec_Policy_MTLS) String() string
- type TrafficPolicySpec_Policy_MTLS_Istio
- func (*TrafficPolicySpec_Policy_MTLS_Istio) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_MTLS_Istio) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_MTLS_Istio) GetTlsMode() TrafficPolicySpec_Policy_MTLS_Istio_TLSmode
- func (*TrafficPolicySpec_Policy_MTLS_Istio) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_MTLS_Istio) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_MTLS_Istio) Reset()
- func (x *TrafficPolicySpec_Policy_MTLS_Istio) String() string
- type TrafficPolicySpec_Policy_MTLS_Istio_TLSmode
- func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Descriptor() protoreflect.EnumDescriptor
- func (x TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Enum() *TrafficPolicySpec_Policy_MTLS_Istio_TLSmode
- func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) EnumDescriptor() ([]byte, []int)deprecated
- func (x TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Number() protoreflect.EnumNumber
- func (x TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) String() string
- func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Type() protoreflect.EnumType
- type TrafficPolicySpec_Policy_Mirror
- func (*TrafficPolicySpec_Policy_Mirror) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_Mirror) Equal(that interface{}) bool
- func (m *TrafficPolicySpec_Policy_Mirror) GetDestinationType() isTrafficPolicySpec_Policy_Mirror_DestinationType
- func (x *TrafficPolicySpec_Policy_Mirror) GetKubeService() *v11.ClusterObjectRef
- func (x *TrafficPolicySpec_Policy_Mirror) GetPercentage() float64
- func (x *TrafficPolicySpec_Policy_Mirror) GetPort() uint32
- func (*TrafficPolicySpec_Policy_Mirror) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_Mirror) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_Mirror) Reset()
- func (x *TrafficPolicySpec_Policy_Mirror) String() string
- type TrafficPolicySpec_Policy_Mirror_KubeService
- type TrafficPolicySpec_Policy_MultiDestination
- func (*TrafficPolicySpec_Policy_MultiDestination) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_MultiDestination) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_MultiDestination) GetDestinations() []*WeightedDestination
- func (*TrafficPolicySpec_Policy_MultiDestination) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_MultiDestination) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_MultiDestination) Reset()
- func (x *TrafficPolicySpec_Policy_MultiDestination) String() string
- type TrafficPolicySpec_Policy_OutlierDetection
- func (*TrafficPolicySpec_Policy_OutlierDetection) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_OutlierDetection) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_OutlierDetection) GetBaseEjectionTime() *duration.Duration
- func (x *TrafficPolicySpec_Policy_OutlierDetection) GetConsecutiveErrors() uint32
- func (x *TrafficPolicySpec_Policy_OutlierDetection) GetInterval() *duration.Duration
- func (x *TrafficPolicySpec_Policy_OutlierDetection) GetMaxEjectionPercent() uint32
- func (*TrafficPolicySpec_Policy_OutlierDetection) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_OutlierDetection) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_OutlierDetection) Reset()
- func (x *TrafficPolicySpec_Policy_OutlierDetection) String() string
- type TrafficPolicySpec_Policy_RetryPolicy
- func (*TrafficPolicySpec_Policy_RetryPolicy) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_RetryPolicy) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_RetryPolicy) GetAttempts() int32
- func (x *TrafficPolicySpec_Policy_RetryPolicy) GetPerTryTimeout() *duration.Duration
- func (*TrafficPolicySpec_Policy_RetryPolicy) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_RetryPolicy) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_RetryPolicy) Reset()
- func (x *TrafficPolicySpec_Policy_RetryPolicy) String() string
- type TrafficPolicySpec_Policy_Transform
- func (*TrafficPolicySpec_Policy_Transform) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_Policy_Transform) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_Policy_Transform) GetTodo() string
- func (*TrafficPolicySpec_Policy_Transform) ProtoMessage()
- func (x *TrafficPolicySpec_Policy_Transform) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_Policy_Transform) Reset()
- func (x *TrafficPolicySpec_Policy_Transform) String() string
- type TrafficPolicySpec_RouteSelector
- func (*TrafficPolicySpec_RouteSelector) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicySpec_RouteSelector) Equal(that interface{}) bool
- func (x *TrafficPolicySpec_RouteSelector) GetRouteLabelMatcher() map[string]string
- func (x *TrafficPolicySpec_RouteSelector) GetRouteTableRefs() []*v11.ObjectRef
- func (x *TrafficPolicySpec_RouteSelector) GetRouteTableSelector() *v11.ObjectSelector
- func (x *TrafficPolicySpec_RouteSelector) GetVirtualHostRefs() []*v11.ObjectRef
- func (x *TrafficPolicySpec_RouteSelector) GetVirtualHostSelector() *v11.ObjectSelector
- func (*TrafficPolicySpec_RouteSelector) ProtoMessage()
- func (x *TrafficPolicySpec_RouteSelector) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicySpec_RouteSelector) Reset()
- func (x *TrafficPolicySpec_RouteSelector) String() string
- type TrafficPolicyStatus
- func (in *TrafficPolicyStatus) DeepCopyInto(out *TrafficPolicyStatus)
- func (*TrafficPolicyStatus) Descriptor() ([]byte, []int)deprecated
- func (m *TrafficPolicyStatus) Equal(that interface{}) bool
- func (x *TrafficPolicyStatus) GetDestinations() map[string]*ApprovalStatus
- func (x *TrafficPolicyStatus) GetErrors() []string
- func (x *TrafficPolicyStatus) GetGatewayRoutes() map[string]*GatewayRoutes
- func (x *TrafficPolicyStatus) GetObservedGeneration() int64
- func (x *TrafficPolicyStatus) GetState() v1.ApprovalState
- func (x *TrafficPolicyStatus) GetWorkloads() []string
- func (this *TrafficPolicyStatus) MarshalJSON() ([]byte, error)
- func (*TrafficPolicyStatus) ProtoMessage()
- func (x *TrafficPolicyStatus) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicyStatus) Reset()
- func (x *TrafficPolicyStatus) String() string
- func (this *TrafficPolicyStatus) UnmarshalJSON(b []byte) error
- type TrafficPolicyStatusWriter
- type TrafficPolicyTransitionFunction
- type TrafficPolicyWriter
- type VirtualMesh
- type VirtualMeshClient
- type VirtualMeshList
- type VirtualMeshReader
- type VirtualMeshSlice
- type VirtualMeshSpec
- func (in *VirtualMeshSpec) DeepCopyInto(out *VirtualMeshSpec)
- func (*VirtualMeshSpec) Descriptor() ([]byte, []int)deprecated
- func (m *VirtualMeshSpec) Equal(that interface{}) bool
- func (x *VirtualMeshSpec) GetFederation() *VirtualMeshSpec_Federation
- func (x *VirtualMeshSpec) GetGlobalAccessPolicy() VirtualMeshSpec_GlobalAccessPolicy
- func (x *VirtualMeshSpec) GetMeshes() []*v1.ObjectRef
- func (x *VirtualMeshSpec) GetMtlsConfig() *VirtualMeshSpec_MTLSConfig
- func (this *VirtualMeshSpec) MarshalJSON() ([]byte, error)
- func (*VirtualMeshSpec) ProtoMessage()
- func (x *VirtualMeshSpec) ProtoReflect() protoreflect.Message
- func (x *VirtualMeshSpec) Reset()
- func (x *VirtualMeshSpec) String() string
- func (this *VirtualMeshSpec) UnmarshalJSON(b []byte) error
- type VirtualMeshSpec_Federation
- func (*VirtualMeshSpec_Federation) Descriptor() ([]byte, []int)deprecated
- func (m *VirtualMeshSpec_Federation) Equal(that interface{}) bool
- func (x *VirtualMeshSpec_Federation) GetFlatNetwork() bool
- func (x *VirtualMeshSpec_Federation) GetHostnameSuffix() string
- func (x *VirtualMeshSpec_Federation) GetIngressGatewaySelectors() []*v12.IngressGatewaySelector
- func (m *VirtualMeshSpec_Federation) GetMode() isVirtualMeshSpec_Federation_Mode
- func (x *VirtualMeshSpec_Federation) GetPermissive() *empty.Empty
- func (x *VirtualMeshSpec_Federation) GetSelectors() []*VirtualMeshSpec_Federation_FederationSelector
- func (x *VirtualMeshSpec_Federation) GetTcpKeepalive() *v12.TCPKeepalive
- func (*VirtualMeshSpec_Federation) ProtoMessage()
- func (x *VirtualMeshSpec_Federation) ProtoReflect() protoreflect.Message
- func (x *VirtualMeshSpec_Federation) Reset()
- func (x *VirtualMeshSpec_Federation) String() string
- type VirtualMeshSpec_Federation_FederationSelector
- func (*VirtualMeshSpec_Federation_FederationSelector) Descriptor() ([]byte, []int)deprecated
- func (m *VirtualMeshSpec_Federation_FederationSelector) Equal(that interface{}) bool
- func (x *VirtualMeshSpec_Federation_FederationSelector) GetDestinationSelectors() []*v12.DestinationSelector
- func (x *VirtualMeshSpec_Federation_FederationSelector) GetMeshes() []*v1.ObjectRef
- func (*VirtualMeshSpec_Federation_FederationSelector) ProtoMessage()
- func (x *VirtualMeshSpec_Federation_FederationSelector) ProtoReflect() protoreflect.Message
- func (x *VirtualMeshSpec_Federation_FederationSelector) Reset()
- func (x *VirtualMeshSpec_Federation_FederationSelector) String() string
- type VirtualMeshSpec_Federation_Permissive
- type VirtualMeshSpec_GlobalAccessPolicy
- func (VirtualMeshSpec_GlobalAccessPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x VirtualMeshSpec_GlobalAccessPolicy) Enum() *VirtualMeshSpec_GlobalAccessPolicy
- func (VirtualMeshSpec_GlobalAccessPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x VirtualMeshSpec_GlobalAccessPolicy) Number() protoreflect.EnumNumber
- func (x VirtualMeshSpec_GlobalAccessPolicy) String() string
- func (VirtualMeshSpec_GlobalAccessPolicy) Type() protoreflect.EnumType
- type VirtualMeshSpec_MTLSConfig
- func (*VirtualMeshSpec_MTLSConfig) Descriptor() ([]byte, []int)deprecated
- func (m *VirtualMeshSpec_MTLSConfig) Equal(that interface{}) bool
- func (x *VirtualMeshSpec_MTLSConfig) GetAutoRestartPods() bool
- func (x *VirtualMeshSpec_MTLSConfig) GetLimited() *VirtualMeshSpec_MTLSConfig_LimitedTrust
- func (x *VirtualMeshSpec_MTLSConfig) GetRotationStrategy() v11.CertificateRotationStrategy
- func (x *VirtualMeshSpec_MTLSConfig) GetRotationVerificationMethod() *v11.CertificateRotationVerificationMethod
- func (x *VirtualMeshSpec_MTLSConfig) GetShared() *SharedTrust
- func (m *VirtualMeshSpec_MTLSConfig) GetTrustModel() isVirtualMeshSpec_MTLSConfig_TrustModel
- func (*VirtualMeshSpec_MTLSConfig) ProtoMessage()
- func (x *VirtualMeshSpec_MTLSConfig) ProtoReflect() protoreflect.Message
- func (x *VirtualMeshSpec_MTLSConfig) Reset()
- func (x *VirtualMeshSpec_MTLSConfig) String() string
- type VirtualMeshSpec_MTLSConfig_Limited
- type VirtualMeshSpec_MTLSConfig_LimitedTrust
- func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) Descriptor() ([]byte, []int)deprecated
- func (m *VirtualMeshSpec_MTLSConfig_LimitedTrust) Equal(that interface{}) bool
- func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) ProtoMessage()
- func (x *VirtualMeshSpec_MTLSConfig_LimitedTrust) ProtoReflect() protoreflect.Message
- func (x *VirtualMeshSpec_MTLSConfig_LimitedTrust) Reset()
- func (x *VirtualMeshSpec_MTLSConfig_LimitedTrust) String() string
- type VirtualMeshSpec_MTLSConfig_Shared
- type VirtualMeshStatus
- func (in *VirtualMeshStatus) DeepCopyInto(out *VirtualMeshStatus)
- func (*VirtualMeshStatus) Descriptor() ([]byte, []int)deprecated
- func (m *VirtualMeshStatus) Equal(that interface{}) bool
- func (x *VirtualMeshStatus) GetConditions() []*v11.CertificateRotationCondition
- func (x *VirtualMeshStatus) GetDeployedSharedTrust() *SharedTrust
- func (x *VirtualMeshStatus) GetDestinations() map[string]*ApprovalStatus
- func (x *VirtualMeshStatus) GetErrors() []string
- func (x *VirtualMeshStatus) GetMeshes() map[string]*ApprovalStatus
- func (x *VirtualMeshStatus) GetObservedGeneration() int64
- func (x *VirtualMeshStatus) GetState() v12.ApprovalState
- func (this *VirtualMeshStatus) MarshalJSON() ([]byte, error)
- func (*VirtualMeshStatus) ProtoMessage()
- func (x *VirtualMeshStatus) ProtoReflect() protoreflect.Message
- func (x *VirtualMeshStatus) Reset()
- func (x *VirtualMeshStatus) String() string
- func (this *VirtualMeshStatus) UnmarshalJSON(b []byte) error
- type VirtualMeshStatusWriter
- type VirtualMeshTransitionFunction
- type VirtualMeshWriter
- type WeightedDestination
- func (*WeightedDestination) Descriptor() ([]byte, []int)deprecated
- func (m *WeightedDestination) Equal(that interface{}) bool
- func (x *WeightedDestination) GetClusterHeader() string
- func (m *WeightedDestination) GetDestinationType() isWeightedDestination_DestinationType
- func (x *WeightedDestination) GetKubeService() *WeightedDestination_KubeDestination
- func (x *WeightedDestination) GetOptions() *WeightedDestination_DestinationOptions
- func (x *WeightedDestination) GetStaticDestination() *v1.ObjectRef
- func (x *WeightedDestination) GetVirtualDestination() *WeightedDestination_VirtualDestination
- func (x *WeightedDestination) GetWeight() uint32
- func (*WeightedDestination) ProtoMessage()
- func (x *WeightedDestination) ProtoReflect() protoreflect.Message
- func (x *WeightedDestination) Reset()
- func (x *WeightedDestination) String() string
- type WeightedDestination_ClusterHeader
- type WeightedDestination_DestinationOptions
- func (*WeightedDestination_DestinationOptions) Descriptor() ([]byte, []int)deprecated
- func (m *WeightedDestination_DestinationOptions) Equal(that interface{}) bool
- func (x *WeightedDestination_DestinationOptions) GetHeaderManipulation() *HeaderManipulation
- func (*WeightedDestination_DestinationOptions) ProtoMessage()
- func (x *WeightedDestination_DestinationOptions) ProtoReflect() protoreflect.Message
- func (x *WeightedDestination_DestinationOptions) Reset()
- func (x *WeightedDestination_DestinationOptions) String() string
- type WeightedDestination_KubeDestination
- func (*WeightedDestination_KubeDestination) Descriptor() ([]byte, []int)deprecated
- func (m *WeightedDestination_KubeDestination) Equal(that interface{}) bool
- func (x *WeightedDestination_KubeDestination) GetClusterName() string
- func (x *WeightedDestination_KubeDestination) GetName() string
- func (x *WeightedDestination_KubeDestination) GetNamespace() string
- func (x *WeightedDestination_KubeDestination) GetPort() uint32
- func (x *WeightedDestination_KubeDestination) GetSubset() map[string]string
- func (*WeightedDestination_KubeDestination) ProtoMessage()
- func (x *WeightedDestination_KubeDestination) ProtoReflect() protoreflect.Message
- func (x *WeightedDestination_KubeDestination) Reset()
- func (x *WeightedDestination_KubeDestination) String() string
- type WeightedDestination_KubeService
- type WeightedDestination_StaticDestination
- type WeightedDestination_VirtualDestination
- func (*WeightedDestination_VirtualDestination) Descriptor() ([]byte, []int)deprecated
- func (m *WeightedDestination_VirtualDestination) Equal(that interface{}) bool
- func (x *WeightedDestination_VirtualDestination) GetName() string
- func (x *WeightedDestination_VirtualDestination) GetNamespace() string
- func (x *WeightedDestination_VirtualDestination) GetSubset() map[string]string
- func (*WeightedDestination_VirtualDestination) ProtoMessage()
- func (x *WeightedDestination_VirtualDestination) ProtoReflect() protoreflect.Message
- func (x *WeightedDestination_VirtualDestination) Reset()
- func (x *WeightedDestination_VirtualDestination) String() string
- type WeightedDestination_VirtualDestination_
Constants ¶
This section is empty.
Variables ¶
var ( DestinationPolicySpec_Policy_MTLS_Istio_TLSmode_name = map[int32]string{ 0: "DISABLE", 1: "SIMPLE", 2: "ISTIO_MUTUAL", } DestinationPolicySpec_Policy_MTLS_Istio_TLSmode_value = map[string]int32{ "DISABLE": 0, "SIMPLE": 1, "ISTIO_MUTUAL": 2, } )
Enum value maps for DestinationPolicySpec_Policy_MTLS_Istio_TLSmode.
var ( RequestLimit_Unit_name = map[int32]string{ 0: "UNKNOWN", 1: "SECOND", 2: "MINUTE", 3: "HOUR", 4: "DAY", } RequestLimit_Unit_value = map[string]int32{ "UNKNOWN": 0, "SECOND": 1, "MINUTE": 2, "HOUR": 3, "DAY": 4, } )
Enum value maps for RequestLimit_Unit.
var ( MetaData_Source_name = map[int32]string{ 0: "DYNAMIC", 1: "ROUTE_ENTRY", } MetaData_Source_value = map[string]int32{ "DYNAMIC": 0, "ROUTE_ENTRY": 1, } )
Enum value maps for MetaData_Source.
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: "networking.mesh.gloo.solo.io", Version: "v1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} )
var ( StatusCodeMatcher_Comparator_name = map[int32]string{ 0: "EQ", 1: "GE", 2: "LE", } StatusCodeMatcher_Comparator_value = map[string]int32{ "EQ": 0, "GE": 1, "LE": 2, } )
Enum value maps for StatusCodeMatcher_Comparator.
var ( TrafficPolicySpec_Policy_MTLS_Istio_TLSmode_name = map[int32]string{ 0: "DISABLE", 1: "SIMPLE", 2: "ISTIO_MUTUAL", } TrafficPolicySpec_Policy_MTLS_Istio_TLSmode_value = map[string]int32{ "DISABLE": 0, "SIMPLE": 1, "ISTIO_MUTUAL": 2, } )
Enum value maps for TrafficPolicySpec_Policy_MTLS_Istio_TLSmode.
var ( VirtualMeshSpec_GlobalAccessPolicy_name = map[int32]string{ 0: "MESH_DEFAULT", 1: "ENABLED", 2: "DISABLED", } VirtualMeshSpec_GlobalAccessPolicy_value = map[string]int32{ "MESH_DEFAULT": 0, "ENABLED": 1, "DISABLED": 2, } )
Enum value maps for VirtualMeshSpec_GlobalAccessPolicy.
var AccessPolicyGVK = schema.GroupVersionKind{
Group: "networking.mesh.gloo.solo.io",
Version: "v1",
Kind: "AccessPolicy",
}
GroupVersionKind for AccessPolicy
var File_github_com_solo_io_gloo_mesh_api_networking_v1_access_policy_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_applied_policies_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_destination_policy_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_rate_limit_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_request_matchers_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_status_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_traffic_policy_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_virtual_mesh_proto protoreflect.FileDescriptor
var File_github_com_solo_io_gloo_mesh_api_networking_v1_weighed_destination_proto protoreflect.FileDescriptor
var TrafficPolicyGVK = schema.GroupVersionKind{
Group: "networking.mesh.gloo.solo.io",
Version: "v1",
Kind: "TrafficPolicy",
}
GroupVersionKind for TrafficPolicy
var VirtualMeshGVK = schema.GroupVersionKind{
Group: "networking.mesh.gloo.solo.io",
Version: "v1",
Kind: "VirtualMesh",
}
GroupVersionKind for VirtualMesh
Functions ¶
func AddToScheme ¶
func NewAccessPolicyClient ¶
func NewTrafficPolicyClient ¶
func NewVirtualMeshClient ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource
Types ¶
type AccessPolicy ¶
type AccessPolicy struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec AccessPolicySpec `json:"spec,omitempty"` Status AccessPolicyStatus `json:"status,omitempty"` }
AccessPolicy is the Schema for the accessPolicy API
func (*AccessPolicy) DeepCopy ¶
func (in *AccessPolicy) DeepCopy() *AccessPolicy
func (*AccessPolicy) DeepCopyInto ¶
func (in *AccessPolicy) DeepCopyInto(out *AccessPolicy)
func (*AccessPolicy) DeepCopyObject ¶
func (in *AccessPolicy) DeepCopyObject() runtime.Object
func (AccessPolicy) GVK ¶
func (AccessPolicy) GVK() schema.GroupVersionKind
GVK returns the GroupVersionKind associated with the resource type.
type AccessPolicyClient ¶
type AccessPolicyClient interface { AccessPolicyReader AccessPolicyWriter AccessPolicyStatusWriter }
Client knows how to perform CRUD operations on AccessPolicys.
type AccessPolicyList ¶
type AccessPolicyList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []AccessPolicy `json:"items"` }
AccessPolicyList contains a list of AccessPolicy
func (*AccessPolicyList) DeepCopy ¶
func (in *AccessPolicyList) DeepCopy() *AccessPolicyList
func (*AccessPolicyList) DeepCopyInto ¶
func (in *AccessPolicyList) DeepCopyInto(out *AccessPolicyList)
func (*AccessPolicyList) DeepCopyObject ¶
func (in *AccessPolicyList) DeepCopyObject() runtime.Object
type AccessPolicyReader ¶
type AccessPolicyReader interface { // Get retrieves a AccessPolicy for the given object key GetAccessPolicy(ctx context.Context, key client.ObjectKey) (*AccessPolicy, error) // List retrieves list of AccessPolicys for a given namespace and list options. ListAccessPolicy(ctx context.Context, opts ...client.ListOption) (*AccessPolicyList, error) }
Reader knows how to read and list AccessPolicys.
type AccessPolicySlice ¶
type AccessPolicySlice []*AccessPolicy
AccessPolicySlice represents a slice of *AccessPolicy
type AccessPolicySpec ¶
type AccessPolicySpec struct { // Specify the identities of Workloads (i.e. traffic sources) for which to apply this AccessPolicy. // Leave empty to apply the AccessPolicy to all Workloads colocated in the destination's Mesh. SourceSelector []*v1.IdentitySelector `protobuf:"bytes,1,rep,name=source_selector,json=sourceSelector,proto3" json:"source_selector,omitempty"` // Specify the Destinations for which to apply this AccessPolicy. // Leave empty to apply the AccessPolicy to all Destinations. DestinationSelector []*v1.DestinationSelector `protobuf:"bytes,2,rep,name=destination_selector,json=destinationSelector,proto3" json:"destination_selector,omitempty"` // //Optional. A list of HTTP paths or gRPC methods to allow. //gRPC methods must be presented as fully-qualified name in the form of //"/packageName.serviceName/methodName" and are case sensitive. //Exact match, prefix match, and suffix match are supported for paths. //For example, the path "/books/review" matches //"/books/review" (exact match), "*books/" (suffix match), or "/books*" (prefix match). // //If not specified, allow any path. AllowedPaths []string `protobuf:"bytes,3,rep,name=allowed_paths,json=allowedPaths,proto3" json:"allowed_paths,omitempty"` // //Optional. A list of HTTP methods to allow (e.g., "GET", "POST"). //It is ignored in gRPC case because the value is always "POST". //If not specified, allows any method. AllowedMethods []string `protobuf:"bytes,4,rep,name=allowed_methods,json=allowedMethods,proto3" json:"allowed_methods,omitempty"` // //Optional. A list of ports which to allow. //If not set any port is allowed. AllowedPorts []uint32 `protobuf:"varint,5,rep,packed,name=allowed_ports,json=allowedPorts,proto3" json:"allowed_ports,omitempty"` // contains filtered or unexported fields }
Grants communication permission between selected identities (i.e. traffic sources) and Destinations (i.e. destinations). Explicitly granted access permission is required if a [VirtualMesh's GlobalAccessPolicy]({{% versioned_link_path fromRoot="/reference/api/virtual_mesh/#networking.mesh.gloo.solo.io.VirtualMeshSpec.GlobalAccessPolicy" %}}) is set to `ENABLED`.
func (*AccessPolicySpec) DeepCopyInto ¶
func (in *AccessPolicySpec) DeepCopyInto(out *AccessPolicySpec)
DeepCopyInto for the AccessPolicy.Spec
func (*AccessPolicySpec) Descriptor
deprecated
func (*AccessPolicySpec) Descriptor() ([]byte, []int)
Deprecated: Use AccessPolicySpec.ProtoReflect.Descriptor instead.
func (*AccessPolicySpec) Equal ¶
func (m *AccessPolicySpec) Equal(that interface{}) bool
Equal function
func (*AccessPolicySpec) GetAllowedMethods ¶
func (x *AccessPolicySpec) GetAllowedMethods() []string
func (*AccessPolicySpec) GetAllowedPaths ¶
func (x *AccessPolicySpec) GetAllowedPaths() []string
func (*AccessPolicySpec) GetAllowedPorts ¶
func (x *AccessPolicySpec) GetAllowedPorts() []uint32
func (*AccessPolicySpec) GetDestinationSelector ¶
func (x *AccessPolicySpec) GetDestinationSelector() []*v1.DestinationSelector
func (*AccessPolicySpec) GetSourceSelector ¶
func (x *AccessPolicySpec) GetSourceSelector() []*v1.IdentitySelector
func (*AccessPolicySpec) MarshalJSON ¶
func (this *AccessPolicySpec) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for AccessPolicySpec
func (*AccessPolicySpec) ProtoMessage ¶
func (*AccessPolicySpec) ProtoMessage()
func (*AccessPolicySpec) ProtoReflect ¶
func (x *AccessPolicySpec) ProtoReflect() protoreflect.Message
func (*AccessPolicySpec) Reset ¶
func (x *AccessPolicySpec) Reset()
func (*AccessPolicySpec) String ¶
func (x *AccessPolicySpec) String() string
func (*AccessPolicySpec) UnmarshalJSON ¶
func (this *AccessPolicySpec) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for AccessPolicySpec
type AccessPolicyStatus ¶
type AccessPolicyStatus struct { // The most recent generation observed in the the AccessPolicy metadata. // If the `observedGeneration` does not match `metadata.generation`, Gloo Mesh has not processed the most // recent version of this resource. ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"` // The state of the overall resource. // It will only show accepted if it has been successfully applied to selected Destinations. State v1.ApprovalState `protobuf:"varint,2,opt,name=state,proto3,enum=common.mesh.gloo.solo.io.ApprovalState" json:"state,omitempty"` // The status of the AccessPolicy for each Destination to which it has been applied. // An AccessPolicy may be accepted for some Destinations and rejected for others. Destinations map[string]*ApprovalStatus `` /* 165-byte string literal not displayed */ // The list of Workloads to which this policy has been applied. Workloads []string `protobuf:"bytes,4,rep,name=workloads,proto3" json:"workloads,omitempty"` // Any errors found while processing this generation of the resource. Errors []string `protobuf:"bytes,5,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*AccessPolicyStatus) DeepCopyInto ¶
func (in *AccessPolicyStatus) DeepCopyInto(out *AccessPolicyStatus)
DeepCopyInto for the AccessPolicy.Status
func (*AccessPolicyStatus) Descriptor
deprecated
func (*AccessPolicyStatus) Descriptor() ([]byte, []int)
Deprecated: Use AccessPolicyStatus.ProtoReflect.Descriptor instead.
func (*AccessPolicyStatus) Equal ¶
func (m *AccessPolicyStatus) Equal(that interface{}) bool
Equal function
func (*AccessPolicyStatus) GetDestinations ¶
func (x *AccessPolicyStatus) GetDestinations() map[string]*ApprovalStatus
func (*AccessPolicyStatus) GetErrors ¶
func (x *AccessPolicyStatus) GetErrors() []string
func (*AccessPolicyStatus) GetObservedGeneration ¶
func (x *AccessPolicyStatus) GetObservedGeneration() int64
func (*AccessPolicyStatus) GetState ¶
func (x *AccessPolicyStatus) GetState() v1.ApprovalState
func (*AccessPolicyStatus) GetWorkloads ¶
func (x *AccessPolicyStatus) GetWorkloads() []string
func (*AccessPolicyStatus) MarshalJSON ¶
func (this *AccessPolicyStatus) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for AccessPolicyStatus
func (*AccessPolicyStatus) ProtoMessage ¶
func (*AccessPolicyStatus) ProtoMessage()
func (*AccessPolicyStatus) ProtoReflect ¶
func (x *AccessPolicyStatus) ProtoReflect() protoreflect.Message
func (*AccessPolicyStatus) Reset ¶
func (x *AccessPolicyStatus) Reset()
func (*AccessPolicyStatus) String ¶
func (x *AccessPolicyStatus) String() string
func (*AccessPolicyStatus) UnmarshalJSON ¶
func (this *AccessPolicyStatus) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for AccessPolicyStatus
type AccessPolicyStatusWriter ¶
type AccessPolicyStatusWriter interface { // Update updates the fields corresponding to the status subresource for the // given AccessPolicy object. UpdateAccessPolicyStatus(ctx context.Context, obj *AccessPolicy, opts ...client.UpdateOption) error // Patch patches the given AccessPolicy object's subresource. PatchAccessPolicyStatus(ctx context.Context, obj *AccessPolicy, patch client.Patch, opts ...client.PatchOption) error }
StatusWriter knows how to update status subresource of a AccessPolicy object.
type AccessPolicyTransitionFunction ¶
type AccessPolicyTransitionFunction func(existing, desired *AccessPolicy) error
AccessPolicyTransitionFunction instructs the AccessPolicyWriter how to transition between an existing AccessPolicy object and a desired on an Upsert
type AccessPolicyWriter ¶
type AccessPolicyWriter interface { // Create saves the AccessPolicy object. CreateAccessPolicy(ctx context.Context, obj *AccessPolicy, opts ...client.CreateOption) error // Delete deletes the AccessPolicy object. DeleteAccessPolicy(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error // Update updates the given AccessPolicy object. UpdateAccessPolicy(ctx context.Context, obj *AccessPolicy, opts ...client.UpdateOption) error // Patch patches the given AccessPolicy object. PatchAccessPolicy(ctx context.Context, obj *AccessPolicy, patch client.Patch, opts ...client.PatchOption) error // DeleteAllOf deletes all AccessPolicy objects matching the given options. DeleteAllOfAccessPolicy(ctx context.Context, opts ...client.DeleteAllOfOption) error // Create or Update the AccessPolicy object. UpsertAccessPolicy(ctx context.Context, obj *AccessPolicy, transitionFuncs ...AccessPolicyTransitionFunction) error }
Writer knows how to create, delete, and update AccessPolicys.
type Action ¶ added in v1.1.0
type Action struct { // Types that are assignable to ActionSpecifier: // *Action_SourceCluster_ // *Action_DestinationCluster_ // *Action_RequestHeaders_ // *Action_RemoteAddress_ // *Action_GenericKey_ // *Action_HeaderValueMatch_ // *Action_Metadata ActionSpecifier isAction_ActionSpecifier `protobuf_oneof:"action_specifier"` // contains filtered or unexported fields }
Copied directly from envoy https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/route/v3/route_components.proto#envoy-v3-api-msg-config-route-v3-ratelimit-action
func (*Action) Descriptor
deprecated
added in
v1.1.0
func (*Action) GetActionSpecifier ¶ added in v1.1.0
func (m *Action) GetActionSpecifier() isAction_ActionSpecifier
func (*Action) GetDestinationCluster ¶ added in v1.1.0
func (x *Action) GetDestinationCluster() *Action_DestinationCluster
func (*Action) GetGenericKey ¶ added in v1.1.0
func (x *Action) GetGenericKey() *Action_GenericKey
func (*Action) GetHeaderValueMatch ¶ added in v1.1.0
func (x *Action) GetHeaderValueMatch() *Action_HeaderValueMatch
func (*Action) GetMetadata ¶ added in v1.1.0
func (*Action) GetRemoteAddress ¶ added in v1.1.0
func (x *Action) GetRemoteAddress() *Action_RemoteAddress
func (*Action) GetRequestHeaders ¶ added in v1.1.0
func (x *Action) GetRequestHeaders() *Action_RequestHeaders
func (*Action) GetSourceCluster ¶ added in v1.1.0
func (x *Action) GetSourceCluster() *Action_SourceCluster
func (*Action) ProtoMessage ¶ added in v1.1.0
func (*Action) ProtoMessage()
func (*Action) ProtoReflect ¶ added in v1.1.0
func (x *Action) ProtoReflect() protoreflect.Message
type Action_DestinationCluster ¶ added in v1.1.0
type Action_DestinationCluster struct {
// contains filtered or unexported fields
}
The following descriptor entry is appended to the descriptor:
```
("destination_cluster", "<routed target cluster>")
```
Once a request matches against a route table rule, a routed cluster is determined by one of the following `route table configuration (envoy_api_msg_RouteConfiguration)` settings:
- `cluster (envoy_api_field_route.RouteAction.cluster)` indicates the upstream cluster to route to.
- `weighted_clusters (envoy_api_field_route.RouteAction.weighted_clusters)` chooses a cluster randomly from a set of clusters with attributed weight.
- `cluster_header (envoy_api_field_route.RouteAction.cluster_header)` indicates which header in the request contains the target cluster.
func (*Action_DestinationCluster) Descriptor
deprecated
added in
v1.1.0
func (*Action_DestinationCluster) Descriptor() ([]byte, []int)
Deprecated: Use Action_DestinationCluster.ProtoReflect.Descriptor instead.
func (*Action_DestinationCluster) Equal ¶ added in v1.1.0
func (m *Action_DestinationCluster) Equal(that interface{}) bool
Equal function
func (*Action_DestinationCluster) ProtoMessage ¶ added in v1.1.0
func (*Action_DestinationCluster) ProtoMessage()
func (*Action_DestinationCluster) ProtoReflect ¶ added in v1.1.0
func (x *Action_DestinationCluster) ProtoReflect() protoreflect.Message
func (*Action_DestinationCluster) Reset ¶ added in v1.1.0
func (x *Action_DestinationCluster) Reset()
func (*Action_DestinationCluster) String ¶ added in v1.1.0
func (x *Action_DestinationCluster) String() string
type Action_DestinationCluster_ ¶ added in v1.1.0
type Action_DestinationCluster_ struct { // Rate limit on destination cluster. DestinationCluster *Action_DestinationCluster `protobuf:"bytes,2,opt,name=destination_cluster,json=destinationCluster,proto3,oneof"` }
type Action_GenericKey ¶ added in v1.1.0
type Action_GenericKey struct { // The value to use in the descriptor entry. DescriptorValue string `protobuf:"bytes,1,opt,name=descriptor_value,json=descriptorValue,proto3" json:"descriptor_value,omitempty"` // [(validate.rules).string.min_bytes = 1]; // contains filtered or unexported fields }
The following descriptor entry is appended to the descriptor:
```
("generic_key", "<descriptor_value>")
```
func (*Action_GenericKey) Descriptor
deprecated
added in
v1.1.0
func (*Action_GenericKey) Descriptor() ([]byte, []int)
Deprecated: Use Action_GenericKey.ProtoReflect.Descriptor instead.
func (*Action_GenericKey) Equal ¶ added in v1.1.0
func (m *Action_GenericKey) Equal(that interface{}) bool
Equal function
func (*Action_GenericKey) GetDescriptorValue ¶ added in v1.1.0
func (x *Action_GenericKey) GetDescriptorValue() string
func (*Action_GenericKey) ProtoMessage ¶ added in v1.1.0
func (*Action_GenericKey) ProtoMessage()
func (*Action_GenericKey) ProtoReflect ¶ added in v1.1.0
func (x *Action_GenericKey) ProtoReflect() protoreflect.Message
func (*Action_GenericKey) Reset ¶ added in v1.1.0
func (x *Action_GenericKey) Reset()
func (*Action_GenericKey) String ¶ added in v1.1.0
func (x *Action_GenericKey) String() string
type Action_GenericKey_ ¶ added in v1.1.0
type Action_GenericKey_ struct { // Rate limit on a generic key. GenericKey *Action_GenericKey `protobuf:"bytes,5,opt,name=generic_key,json=genericKey,proto3,oneof"` }
type Action_HeaderValueMatch ¶ added in v1.1.0
type Action_HeaderValueMatch struct { // The value to use in the descriptor entry. DescriptorValue string `protobuf:"bytes,1,opt,name=descriptor_value,json=descriptorValue,proto3" json:"descriptor_value,omitempty"` // [(validate.rules).string.min_bytes = 1]; // If set to true, the action will append a descriptor entry when the // request matches the headers. If set to false, the action will append a // descriptor entry when the request does not match the headers. The // default value is true. ExpectMatch *wrappers.BoolValue `protobuf:"bytes,2,opt,name=expect_match,json=expectMatch,proto3" json:"expect_match,omitempty"` // Specifies a set of headers that the rate limit action should match // on. The action will check the request’s headers against all the // specified headers in the config. A match will happen if all the // headers in the config are present in the request with the same values // (or based on presence if the value field is not in the config). Headers []*Action_HeaderValueMatch_HeaderMatcher `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"` // [(validate.rules).repeated .min_items = 1]; // contains filtered or unexported fields }
The following descriptor entry is appended to the descriptor:
```
("header_match", "<descriptor_value>")
```
func (*Action_HeaderValueMatch) Descriptor
deprecated
added in
v1.1.0
func (*Action_HeaderValueMatch) Descriptor() ([]byte, []int)
Deprecated: Use Action_HeaderValueMatch.ProtoReflect.Descriptor instead.
func (*Action_HeaderValueMatch) Equal ¶ added in v1.1.0
func (m *Action_HeaderValueMatch) Equal(that interface{}) bool
Equal function
func (*Action_HeaderValueMatch) GetDescriptorValue ¶ added in v1.1.0
func (x *Action_HeaderValueMatch) GetDescriptorValue() string
func (*Action_HeaderValueMatch) GetExpectMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch) GetExpectMatch() *wrappers.BoolValue
func (*Action_HeaderValueMatch) GetHeaders ¶ added in v1.1.0
func (x *Action_HeaderValueMatch) GetHeaders() []*Action_HeaderValueMatch_HeaderMatcher
func (*Action_HeaderValueMatch) ProtoMessage ¶ added in v1.1.0
func (*Action_HeaderValueMatch) ProtoMessage()
func (*Action_HeaderValueMatch) ProtoReflect ¶ added in v1.1.0
func (x *Action_HeaderValueMatch) ProtoReflect() protoreflect.Message
func (*Action_HeaderValueMatch) Reset ¶ added in v1.1.0
func (x *Action_HeaderValueMatch) Reset()
func (*Action_HeaderValueMatch) String ¶ added in v1.1.0
func (x *Action_HeaderValueMatch) String() string
type Action_HeaderValueMatch_ ¶ added in v1.1.0
type Action_HeaderValueMatch_ struct { // Rate limit on the existence of request headers. HeaderValueMatch *Action_HeaderValueMatch `protobuf:"bytes,6,opt,name=header_value_match,json=headerValueMatch,proto3,oneof"` }
type Action_HeaderValueMatch_HeaderMatcher ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher struct { // Specifies the name of the header in the request. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // [(validate.rules).string.min_bytes = 1]; // Specifies how the header match will be performed to route the request. // // Types that are assignable to HeaderMatchSpecifier: // *Action_HeaderValueMatch_HeaderMatcher_ExactMatch // *Action_HeaderValueMatch_HeaderMatcher_RegexMatch // *Action_HeaderValueMatch_HeaderMatcher_RangeMatch // *Action_HeaderValueMatch_HeaderMatcher_PresentMatch // *Action_HeaderValueMatch_HeaderMatcher_PrefixMatch // *Action_HeaderValueMatch_HeaderMatcher_SuffixMatch HeaderMatchSpecifier isAction_HeaderValueMatch_HeaderMatcher_HeaderMatchSpecifier `protobuf_oneof:"header_match_specifier"` // If specified, the match result will be inverted before checking. Defaults to false. // // Examples: // // * The regex *\d{3}* does not match the value *1234*, so it will match when inverted. // * The range [-10,0) will match the value -1, so it will not match when inverted. InvertMatch bool `protobuf:"varint,8,opt,name=invert_match,json=invertMatch,proto3" json:"invert_match,omitempty"` // contains filtered or unexported fields }
func (*Action_HeaderValueMatch_HeaderMatcher) Descriptor
deprecated
added in
v1.1.0
func (*Action_HeaderValueMatch_HeaderMatcher) Descriptor() ([]byte, []int)
Deprecated: Use Action_HeaderValueMatch_HeaderMatcher.ProtoReflect.Descriptor instead.
func (*Action_HeaderValueMatch_HeaderMatcher) Equal ¶ added in v1.1.0
func (m *Action_HeaderValueMatch_HeaderMatcher) Equal(that interface{}) bool
Equal function
func (*Action_HeaderValueMatch_HeaderMatcher) GetExactMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetExactMatch() string
func (*Action_HeaderValueMatch_HeaderMatcher) GetHeaderMatchSpecifier ¶ added in v1.1.0
func (m *Action_HeaderValueMatch_HeaderMatcher) GetHeaderMatchSpecifier() isAction_HeaderValueMatch_HeaderMatcher_HeaderMatchSpecifier
func (*Action_HeaderValueMatch_HeaderMatcher) GetInvertMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetInvertMatch() bool
func (*Action_HeaderValueMatch_HeaderMatcher) GetName ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetName() string
func (*Action_HeaderValueMatch_HeaderMatcher) GetPrefixMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetPrefixMatch() string
func (*Action_HeaderValueMatch_HeaderMatcher) GetPresentMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetPresentMatch() bool
func (*Action_HeaderValueMatch_HeaderMatcher) GetRangeMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetRangeMatch() *Action_HeaderValueMatch_HeaderMatcher_Int64Range
func (*Action_HeaderValueMatch_HeaderMatcher) GetRegexMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetRegexMatch() string
func (*Action_HeaderValueMatch_HeaderMatcher) GetSuffixMatch ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) GetSuffixMatch() string
func (*Action_HeaderValueMatch_HeaderMatcher) ProtoMessage ¶ added in v1.1.0
func (*Action_HeaderValueMatch_HeaderMatcher) ProtoMessage()
func (*Action_HeaderValueMatch_HeaderMatcher) ProtoReflect ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) ProtoReflect() protoreflect.Message
func (*Action_HeaderValueMatch_HeaderMatcher) Reset ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) Reset()
func (*Action_HeaderValueMatch_HeaderMatcher) String ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher) String() string
type Action_HeaderValueMatch_HeaderMatcher_ExactMatch ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_ExactMatch struct { // If specified, header match will be performed based on the value of the header. ExactMatch string `protobuf:"bytes,4,opt,name=exact_match,json=exactMatch,proto3,oneof"` }
type Action_HeaderValueMatch_HeaderMatcher_Int64Range ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_Int64Range struct { // start of the range (inclusive) Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // end of the range (exclusive) End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
Specifies the int64 start and end of the range using half-open interval semantics [start, end).
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) Descriptor
deprecated
added in
v1.1.0
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) Descriptor() ([]byte, []int)
Deprecated: Use Action_HeaderValueMatch_HeaderMatcher_Int64Range.ProtoReflect.Descriptor instead.
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) Equal ¶ added in v1.1.0
func (m *Action_HeaderValueMatch_HeaderMatcher_Int64Range) Equal(that interface{}) bool
Equal function
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) GetEnd ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) GetEnd() int64
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) GetStart ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) GetStart() int64
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) ProtoMessage ¶ added in v1.1.0
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) ProtoMessage()
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) ProtoReflect ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) ProtoReflect() protoreflect.Message
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) Reset ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) Reset()
func (*Action_HeaderValueMatch_HeaderMatcher_Int64Range) String ¶ added in v1.1.0
func (x *Action_HeaderValueMatch_HeaderMatcher_Int64Range) String() string
type Action_HeaderValueMatch_HeaderMatcher_PrefixMatch ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_PrefixMatch struct { // If specified, header match will be performed based on the prefix of the header value. // Note: empty prefix is not allowed, please use present_match instead. // // Examples: // // * The prefix *abcd* matches the value *abcdxyz*, but not for *abcxyz*. PrefixMatch string `protobuf:"bytes,9,opt,name=prefix_match,json=prefixMatch,proto3,oneof"` // [(validate.rules).string.min_bytes = 1]; }
type Action_HeaderValueMatch_HeaderMatcher_PresentMatch ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_PresentMatch struct { // If specified, header match will be performed based on whether the header is in the // request. PresentMatch bool `protobuf:"varint,7,opt,name=present_match,json=presentMatch,proto3,oneof"` }
type Action_HeaderValueMatch_HeaderMatcher_RangeMatch ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_RangeMatch struct { // If specified, header match will be performed based on range. // The rule will match if the request header value is within this range. // The entire request header value must represent an integer in base 10 notation: consisting of // an optional plus or minus sign followed by a sequence of digits. The rule will not match if // the header value does not represent an integer. Match will fail for empty values, floating // point numbers or if only a subsequence of the header value is an integer. // // Examples: // // * For range [-10,0), route will match for header value -1, but not for 0, "somestring", 10.9, // "-1somestring" RangeMatch *Action_HeaderValueMatch_HeaderMatcher_Int64Range `protobuf:"bytes,6,opt,name=range_match,json=rangeMatch,proto3,oneof"` }
type Action_HeaderValueMatch_HeaderMatcher_RegexMatch ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_RegexMatch struct { // If specified, this regex string is a regular expression rule which implies the entire request // header value must match the regex. The rule will not match if only a subsequence of the // request header value matches the regex. The regex grammar used in the value field is defined // `(here)[https://en.cppreference.com/w/cpp/regex/ecmascript]`. // // Examples: // // * The regex *\d{3}* matches the value *123* // * The regex *\d{3}* does not match the value *1234* // * The regex *\d{3}* does not match the value *123.456* RegexMatch string `protobuf:"bytes,5,opt,name=regex_match,json=regexMatch,proto3,oneof"` // [(validate.rules).string.max_bytes = 1024]; }
type Action_HeaderValueMatch_HeaderMatcher_SuffixMatch ¶ added in v1.1.0
type Action_HeaderValueMatch_HeaderMatcher_SuffixMatch struct { // If specified, header match will be performed based on the suffix of the header value. // Note: empty suffix is not allowed, please use present_match instead. // // Examples: // // * The suffix *abcd* matches the value *xyzabcd*, but not for *xyzbcd*. SuffixMatch string `protobuf:"bytes,10,opt,name=suffix_match,json=suffixMatch,proto3,oneof"` // [(validate.rules).string.min_bytes = 1]; }
type Action_Metadata ¶ added in v1.1.0
type Action_Metadata struct { // Rate limit on metadata. Metadata *MetaData `protobuf:"bytes,8,opt,name=metadata,proto3,oneof"` }
type Action_RemoteAddress ¶ added in v1.1.0
type Action_RemoteAddress struct {
// contains filtered or unexported fields
}
The following descriptor entry is appended to the descriptor and is populated using the trusted address from `x-forwarded-for (config_http_conn_man_headers_x-forwarded-for)`:
```
("remote_address", "<trusted address from x-forwarded-for>")
```
func (*Action_RemoteAddress) Descriptor
deprecated
added in
v1.1.0
func (*Action_RemoteAddress) Descriptor() ([]byte, []int)
Deprecated: Use Action_RemoteAddress.ProtoReflect.Descriptor instead.
func (*Action_RemoteAddress) Equal ¶ added in v1.1.0
func (m *Action_RemoteAddress) Equal(that interface{}) bool
Equal function
func (*Action_RemoteAddress) ProtoMessage ¶ added in v1.1.0
func (*Action_RemoteAddress) ProtoMessage()
func (*Action_RemoteAddress) ProtoReflect ¶ added in v1.1.0
func (x *Action_RemoteAddress) ProtoReflect() protoreflect.Message
func (*Action_RemoteAddress) Reset ¶ added in v1.1.0
func (x *Action_RemoteAddress) Reset()
func (*Action_RemoteAddress) String ¶ added in v1.1.0
func (x *Action_RemoteAddress) String() string
type Action_RemoteAddress_ ¶ added in v1.1.0
type Action_RemoteAddress_ struct { // Rate limit on remote address. RemoteAddress *Action_RemoteAddress `protobuf:"bytes,4,opt,name=remote_address,json=remoteAddress,proto3,oneof"` }
type Action_RequestHeaders ¶ added in v1.1.0
type Action_RequestHeaders struct { // The header name to be queried from the request headers. The header’s // value is used to populate the value of the descriptor entry for the // descriptor_key. HeaderName string `protobuf:"bytes,1,opt,name=header_name,json=headerName,proto3" json:"header_name,omitempty"` // [(validate.rules).string.min_bytes = 1]; // The key to use in the descriptor entry. DescriptorKey string `protobuf:"bytes,2,opt,name=descriptor_key,json=descriptorKey,proto3" json:"descriptor_key,omitempty"` // [(validate.rules).string.min_bytes = 1]; // contains filtered or unexported fields }
The following descriptor entry is appended when a header contains a key that matches the *header_name*:
```
("<descriptor_key>", "<header_value_queried_from_header>")
```
func (*Action_RequestHeaders) Descriptor
deprecated
added in
v1.1.0
func (*Action_RequestHeaders) Descriptor() ([]byte, []int)
Deprecated: Use Action_RequestHeaders.ProtoReflect.Descriptor instead.
func (*Action_RequestHeaders) Equal ¶ added in v1.1.0
func (m *Action_RequestHeaders) Equal(that interface{}) bool
Equal function
func (*Action_RequestHeaders) GetDescriptorKey ¶ added in v1.1.0
func (x *Action_RequestHeaders) GetDescriptorKey() string
func (*Action_RequestHeaders) GetHeaderName ¶ added in v1.1.0
func (x *Action_RequestHeaders) GetHeaderName() string
func (*Action_RequestHeaders) ProtoMessage ¶ added in v1.1.0
func (*Action_RequestHeaders) ProtoMessage()
func (*Action_RequestHeaders) ProtoReflect ¶ added in v1.1.0
func (x *Action_RequestHeaders) ProtoReflect() protoreflect.Message
func (*Action_RequestHeaders) Reset ¶ added in v1.1.0
func (x *Action_RequestHeaders) Reset()
func (*Action_RequestHeaders) String ¶ added in v1.1.0
func (x *Action_RequestHeaders) String() string
type Action_RequestHeaders_ ¶ added in v1.1.0
type Action_RequestHeaders_ struct { // Rate limit on request headers. RequestHeaders *Action_RequestHeaders `protobuf:"bytes,3,opt,name=request_headers,json=requestHeaders,proto3,oneof"` }
type Action_SourceCluster ¶ added in v1.1.0
type Action_SourceCluster struct {
// contains filtered or unexported fields
}
The following descriptor entry is appended to the descriptor:
```
("source_cluster", "<local service cluster>")
```
<local service cluster> is derived from the :option:`--service-cluster` option.
func (*Action_SourceCluster) Descriptor
deprecated
added in
v1.1.0
func (*Action_SourceCluster) Descriptor() ([]byte, []int)
Deprecated: Use Action_SourceCluster.ProtoReflect.Descriptor instead.
func (*Action_SourceCluster) Equal ¶ added in v1.1.0
func (m *Action_SourceCluster) Equal(that interface{}) bool
Equal function
func (*Action_SourceCluster) ProtoMessage ¶ added in v1.1.0
func (*Action_SourceCluster) ProtoMessage()
func (*Action_SourceCluster) ProtoReflect ¶ added in v1.1.0
func (x *Action_SourceCluster) ProtoReflect() protoreflect.Message
func (*Action_SourceCluster) Reset ¶ added in v1.1.0
func (x *Action_SourceCluster) Reset()
func (*Action_SourceCluster) String ¶ added in v1.1.0
func (x *Action_SourceCluster) String() string
type Action_SourceCluster_ ¶ added in v1.1.0
type Action_SourceCluster_ struct { // Rate limit on source cluster. SourceCluster *Action_SourceCluster `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3,oneof"` }
type AppliedTrafficPolicy ¶ added in v1.1.0
type AppliedTrafficPolicy struct { // Reference to the TrafficPolicy object. Ref *v1.ObjectRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"` // The observed generation of the accepted TrafficPolicy. ObservedGeneration int64 `protobuf:"varint,2,opt,name=observedGeneration,proto3" json:"observedGeneration,omitempty"` // The spec of the last known valid TrafficPolicy. Spec *TrafficPolicySpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"` // The list of routes, to which the TrafficPolicy applies, as selected by their labels, // represented by their configured Route Name. // If no route name is specified on a route, the route's URI matcher value is used instead. // Value is "*" if the TrafficPolicy applies to all routes. Routes []string `protobuf:"bytes,4,rep,name=routes,proto3" json:"routes,omitempty"` // contains filtered or unexported fields }
Describes a TrafficPolicy({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.traffic_policy" >}}) that applies to the resource. If an existing TrafficPolicy becomes invalid, the last valid applied TrafficPolicy will be used.
func (*AppliedTrafficPolicy) Descriptor
deprecated
added in
v1.1.0
func (*AppliedTrafficPolicy) Descriptor() ([]byte, []int)
Deprecated: Use AppliedTrafficPolicy.ProtoReflect.Descriptor instead.
func (*AppliedTrafficPolicy) Equal ¶ added in v1.1.0
func (m *AppliedTrafficPolicy) Equal(that interface{}) bool
Equal function
func (*AppliedTrafficPolicy) GetObservedGeneration ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) GetObservedGeneration() int64
func (*AppliedTrafficPolicy) GetRef ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) GetRef() *v1.ObjectRef
func (*AppliedTrafficPolicy) GetRoutes ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) GetRoutes() []string
func (*AppliedTrafficPolicy) GetSpec ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) GetSpec() *TrafficPolicySpec
func (*AppliedTrafficPolicy) ProtoMessage ¶ added in v1.1.0
func (*AppliedTrafficPolicy) ProtoMessage()
func (*AppliedTrafficPolicy) ProtoReflect ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) ProtoReflect() protoreflect.Message
func (*AppliedTrafficPolicy) Reset ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) Reset()
func (*AppliedTrafficPolicy) String ¶ added in v1.1.0
func (x *AppliedTrafficPolicy) String() string
type ApprovalStatus ¶
type ApprovalStatus struct { // Represents the order in which the policy // was accepted and applied to a discovery resource. The first accepted policy // will have an acceptance_order of 0, the second 1, etc. // When conflicts are detected in the system, // the Policy with the lowest acceptance_order // will be chosen and all other conflicting policies will be rejected. AcceptanceOrder uint32 `protobuf:"varint,1,opt,name=acceptance_order,json=acceptanceOrder,proto3" json:"acceptance_order,omitempty"` // The result of attempting to apply the policy to the discovery resource. State v1.ApprovalState `protobuf:"varint,2,opt,name=state,proto3,enum=common.mesh.gloo.solo.io.ApprovalState" json:"state,omitempty"` // Any errors observed which prevented the resource from being Accepted. Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"` // Any warnings observed while processing the resource. Warnings []string `protobuf:"bytes,4,rep,name=warnings,proto3" json:"warnings,omitempty"` // contains filtered or unexported fields }
The approval status of a policy that has been applied to a discovery resource.
func (*ApprovalStatus) Descriptor
deprecated
func (*ApprovalStatus) Descriptor() ([]byte, []int)
Deprecated: Use ApprovalStatus.ProtoReflect.Descriptor instead.
func (*ApprovalStatus) GetAcceptanceOrder ¶
func (x *ApprovalStatus) GetAcceptanceOrder() uint32
func (*ApprovalStatus) GetErrors ¶
func (x *ApprovalStatus) GetErrors() []string
func (*ApprovalStatus) GetState ¶
func (x *ApprovalStatus) GetState() v1.ApprovalState
func (*ApprovalStatus) GetWarnings ¶ added in v1.1.0
func (x *ApprovalStatus) GetWarnings() []string
func (*ApprovalStatus) ProtoMessage ¶
func (*ApprovalStatus) ProtoMessage()
func (*ApprovalStatus) ProtoReflect ¶
func (x *ApprovalStatus) ProtoReflect() protoreflect.Message
func (*ApprovalStatus) Reset ¶
func (x *ApprovalStatus) Reset()
func (*ApprovalStatus) String ¶
func (x *ApprovalStatus) String() string
type Clientset ¶
type Clientset interface { // clienset for the networking.mesh.gloo.solo.io/v1/v1 APIs TrafficPolicies() TrafficPolicyClient // clienset for the networking.mesh.gloo.solo.io/v1/v1 APIs AccessPolicies() AccessPolicyClient // clienset for the networking.mesh.gloo.solo.io/v1/v1 APIs VirtualMeshes() VirtualMeshClient }
clienset for the networking.mesh.gloo.solo.io/v1 APIs
func NewClientset ¶
type DestinationPolicySpec ¶ added in v1.1.0
type DestinationPolicySpec struct { // Specify the Destinations (destinations) this DestinationPolicy applies to. // Omit to apply to all Destinations. DestinationSelector []*v1.DestinationSelector `protobuf:"bytes,2,rep,name=destination_selector,json=destinationSelector,proto3" json:"destination_selector,omitempty"` // Specify L7 routing and post-routing configuration. Policy *DestinationPolicySpec_Policy `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"` // contains filtered or unexported fields }
Applies L7 routing and post-routing configuration on selected network edges.
func (*DestinationPolicySpec) Descriptor
deprecated
added in
v1.1.0
func (*DestinationPolicySpec) Descriptor() ([]byte, []int)
Deprecated: Use DestinationPolicySpec.ProtoReflect.Descriptor instead.
func (*DestinationPolicySpec) Equal ¶ added in v1.1.0
func (m *DestinationPolicySpec) Equal(that interface{}) bool
Equal function
func (*DestinationPolicySpec) GetDestinationSelector ¶ added in v1.1.0
func (x *DestinationPolicySpec) GetDestinationSelector() []*v1.DestinationSelector
func (*DestinationPolicySpec) GetPolicy ¶ added in v1.1.0
func (x *DestinationPolicySpec) GetPolicy() *DestinationPolicySpec_Policy
func (*DestinationPolicySpec) ProtoMessage ¶ added in v1.1.0
func (*DestinationPolicySpec) ProtoMessage()
func (*DestinationPolicySpec) ProtoReflect ¶ added in v1.1.0
func (x *DestinationPolicySpec) ProtoReflect() protoreflect.Message
func (*DestinationPolicySpec) Reset ¶ added in v1.1.0
func (x *DestinationPolicySpec) Reset()
func (*DestinationPolicySpec) String ¶ added in v1.1.0
func (x *DestinationPolicySpec) String() string
type DestinationPolicySpec_Policy ¶ added in v1.1.0
type DestinationPolicySpec_Policy struct { // Configure [outlier detection](https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/upstream/outlier) on the selected destinations. OutlierDetection *DestinationPolicySpec_Policy_OutlierDetection `protobuf:"bytes,11,opt,name=outlier_detection,json=outlierDetection,proto3" json:"outlier_detection,omitempty"` // Configure mTLS settings. If specified will override global default defined in Settings. Mtls *DestinationPolicySpec_Policy_MTLS `protobuf:"bytes,12,opt,name=mtls,proto3" json:"mtls,omitempty"` // contains filtered or unexported fields }
Specify L7 routing and post-routing configuration.
func (*DestinationPolicySpec_Policy) Descriptor
deprecated
added in
v1.1.0
func (*DestinationPolicySpec_Policy) Descriptor() ([]byte, []int)
Deprecated: Use DestinationPolicySpec_Policy.ProtoReflect.Descriptor instead.
func (*DestinationPolicySpec_Policy) Equal ¶ added in v1.1.0
func (m *DestinationPolicySpec_Policy) Equal(that interface{}) bool
Equal function
func (*DestinationPolicySpec_Policy) GetMtls ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy) GetMtls() *DestinationPolicySpec_Policy_MTLS
func (*DestinationPolicySpec_Policy) GetOutlierDetection ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy) GetOutlierDetection() *DestinationPolicySpec_Policy_OutlierDetection
func (*DestinationPolicySpec_Policy) ProtoMessage ¶ added in v1.1.0
func (*DestinationPolicySpec_Policy) ProtoMessage()
func (*DestinationPolicySpec_Policy) ProtoReflect ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy) ProtoReflect() protoreflect.Message
func (*DestinationPolicySpec_Policy) Reset ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy) Reset()
func (*DestinationPolicySpec_Policy) String ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy) String() string
type DestinationPolicySpec_Policy_MTLS ¶ added in v1.1.0
type DestinationPolicySpec_Policy_MTLS struct { // Istio TLS settings. Istio *DestinationPolicySpec_Policy_MTLS_Istio `protobuf:"bytes,1,opt,name=istio,proto3" json:"istio,omitempty"` // contains filtered or unexported fields }
Configure mTLS settings on destinations. If specified this overrides the global default defined in Settings.
func (*DestinationPolicySpec_Policy_MTLS) Descriptor
deprecated
added in
v1.1.0
func (*DestinationPolicySpec_Policy_MTLS) Descriptor() ([]byte, []int)
Deprecated: Use DestinationPolicySpec_Policy_MTLS.ProtoReflect.Descriptor instead.
func (*DestinationPolicySpec_Policy_MTLS) Equal ¶ added in v1.1.0
func (m *DestinationPolicySpec_Policy_MTLS) Equal(that interface{}) bool
Equal function
func (*DestinationPolicySpec_Policy_MTLS) GetIstio ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS) GetIstio() *DestinationPolicySpec_Policy_MTLS_Istio
func (*DestinationPolicySpec_Policy_MTLS) ProtoMessage ¶ added in v1.1.0
func (*DestinationPolicySpec_Policy_MTLS) ProtoMessage()
func (*DestinationPolicySpec_Policy_MTLS) ProtoReflect ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS) ProtoReflect() protoreflect.Message
func (*DestinationPolicySpec_Policy_MTLS) Reset ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS) Reset()
func (*DestinationPolicySpec_Policy_MTLS) String ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS) String() string
type DestinationPolicySpec_Policy_MTLS_Istio ¶ added in v1.1.0
type DestinationPolicySpec_Policy_MTLS_Istio struct { // TLS connection mode TlsMode DestinationPolicySpec_Policy_MTLS_Istio_TLSmode `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
Istio TLS settings.
func (*DestinationPolicySpec_Policy_MTLS_Istio) Descriptor
deprecated
added in
v1.1.0
func (*DestinationPolicySpec_Policy_MTLS_Istio) Descriptor() ([]byte, []int)
Deprecated: Use DestinationPolicySpec_Policy_MTLS_Istio.ProtoReflect.Descriptor instead.
func (*DestinationPolicySpec_Policy_MTLS_Istio) Equal ¶ added in v1.1.0
func (m *DestinationPolicySpec_Policy_MTLS_Istio) Equal(that interface{}) bool
Equal function
func (*DestinationPolicySpec_Policy_MTLS_Istio) GetTlsMode ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS_Istio) GetTlsMode() DestinationPolicySpec_Policy_MTLS_Istio_TLSmode
func (*DestinationPolicySpec_Policy_MTLS_Istio) ProtoMessage ¶ added in v1.1.0
func (*DestinationPolicySpec_Policy_MTLS_Istio) ProtoMessage()
func (*DestinationPolicySpec_Policy_MTLS_Istio) ProtoReflect ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS_Istio) ProtoReflect() protoreflect.Message
func (*DestinationPolicySpec_Policy_MTLS_Istio) Reset ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS_Istio) Reset()
func (*DestinationPolicySpec_Policy_MTLS_Istio) String ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_MTLS_Istio) String() string
type DestinationPolicySpec_Policy_MTLS_Istio_TLSmode ¶ added in v1.1.0
type DestinationPolicySpec_Policy_MTLS_Istio_TLSmode int32
TLS connection mode. Enums correspond to those [defined here](https://github.com/istio/api/blob/00636152b9d9254b614828a65723840282a177d3/networking/v1beta1/destination_rule.proto#L886)
const ( // Do not originate a TLS connection to the upstream endpoint. DestinationPolicySpec_Policy_MTLS_Istio_DISABLE DestinationPolicySpec_Policy_MTLS_Istio_TLSmode = 0 // Originate a TLS connection to the upstream endpoint. DestinationPolicySpec_Policy_MTLS_Istio_SIMPLE DestinationPolicySpec_Policy_MTLS_Istio_TLSmode = 1 // Secure connections to the upstream using mutual TLS by presenting // client certificates for authentication. // This mode uses certificates generated // automatically by Istio for mTLS authentication. When this mode is // used, all other fields in `ClientTLSSettings` should be empty. DestinationPolicySpec_Policy_MTLS_Istio_ISTIO_MUTUAL DestinationPolicySpec_Policy_MTLS_Istio_TLSmode = 2 )
func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Descriptor ¶ added in v1.1.0
func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Descriptor() protoreflect.EnumDescriptor
func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) EnumDescriptor
deprecated
added in
v1.1.0
func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) EnumDescriptor() ([]byte, []int)
Deprecated: Use DestinationPolicySpec_Policy_MTLS_Istio_TLSmode.Descriptor instead.
func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Number ¶ added in v1.1.0
func (x DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) Number() protoreflect.EnumNumber
func (DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) String ¶ added in v1.1.0
func (x DestinationPolicySpec_Policy_MTLS_Istio_TLSmode) String() string
type DestinationPolicySpec_Policy_OutlierDetection ¶ added in v1.1.0
type DestinationPolicySpec_Policy_OutlierDetection struct { // The number of errors before a host is ejected from the connection pool. A default will be used if not set. ConsecutiveErrors uint32 `protobuf:"varint,1,opt,name=consecutive_errors,json=consecutiveErrors,proto3" json:"consecutive_errors,omitempty"` // The time interval between ejection sweep analysis. Format: `1h`/`1m`/`1s`/`1ms`. Must be >= `1ms`. A default will be used if not set. Interval *duration.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"` // The minimum ejection duration. Format: `1h`/`1m`/`1s`/`1ms`. Must be >= `1ms`. A default will be used if not set. BaseEjectionTime *duration.Duration `protobuf:"bytes,3,opt,name=base_ejection_time,json=baseEjectionTime,proto3" json:"base_ejection_time,omitempty"` // The maximum percentage of hosts that can be ejected from the load balancing pool. // At least one host will be ejected regardless of the value. Must be between 0 and 100. A default will be used if not set. MaxEjectionPercent uint32 `protobuf:"varint,4,opt,name=max_ejection_percent,json=maxEjectionPercent,proto3" json:"max_ejection_percent,omitempty"` // contains filtered or unexported fields }
Configure [outlier detection](https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/upstream/outlier) on the selected destinations.
func (*DestinationPolicySpec_Policy_OutlierDetection) Descriptor
deprecated
added in
v1.1.0
func (*DestinationPolicySpec_Policy_OutlierDetection) Descriptor() ([]byte, []int)
Deprecated: Use DestinationPolicySpec_Policy_OutlierDetection.ProtoReflect.Descriptor instead.
func (*DestinationPolicySpec_Policy_OutlierDetection) Equal ¶ added in v1.1.0
func (m *DestinationPolicySpec_Policy_OutlierDetection) Equal(that interface{}) bool
Equal function
func (*DestinationPolicySpec_Policy_OutlierDetection) GetBaseEjectionTime ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) GetBaseEjectionTime() *duration.Duration
func (*DestinationPolicySpec_Policy_OutlierDetection) GetConsecutiveErrors ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) GetConsecutiveErrors() uint32
func (*DestinationPolicySpec_Policy_OutlierDetection) GetInterval ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) GetInterval() *duration.Duration
func (*DestinationPolicySpec_Policy_OutlierDetection) GetMaxEjectionPercent ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) GetMaxEjectionPercent() uint32
func (*DestinationPolicySpec_Policy_OutlierDetection) ProtoMessage ¶ added in v1.1.0
func (*DestinationPolicySpec_Policy_OutlierDetection) ProtoMessage()
func (*DestinationPolicySpec_Policy_OutlierDetection) ProtoReflect ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) ProtoReflect() protoreflect.Message
func (*DestinationPolicySpec_Policy_OutlierDetection) Reset ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) Reset()
func (*DestinationPolicySpec_Policy_OutlierDetection) String ¶ added in v1.1.0
func (x *DestinationPolicySpec_Policy_OutlierDetection) String() string
type DestinationPolicyStatus ¶ added in v1.1.0
type DestinationPolicyStatus struct { // The most recent generation observed in the the DestinationPolicy metadata. // If the `observedGeneration` does not match `metadata.generation`, Gloo Mesh has not processed the most // recent version of this resource. ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"` // The state of the overall resource. // It will only show accepted if it has been successfully applied to all selected Destinations. State v1.ApprovalState `protobuf:"varint,2,opt,name=state,proto3,enum=common.mesh.gloo.solo.io.ApprovalState" json:"state,omitempty"` // Any errors found while processing this generation of the resource. Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*DestinationPolicyStatus) Descriptor
deprecated
added in
v1.1.0
func (*DestinationPolicyStatus) Descriptor() ([]byte, []int)
Deprecated: Use DestinationPolicyStatus.ProtoReflect.Descriptor instead.
func (*DestinationPolicyStatus) Equal ¶ added in v1.1.0
func (m *DestinationPolicyStatus) Equal(that interface{}) bool
Equal function
func (*DestinationPolicyStatus) GetErrors ¶ added in v1.1.0
func (x *DestinationPolicyStatus) GetErrors() []string
func (*DestinationPolicyStatus) GetObservedGeneration ¶ added in v1.1.0
func (x *DestinationPolicyStatus) GetObservedGeneration() int64
func (*DestinationPolicyStatus) GetState ¶ added in v1.1.0
func (x *DestinationPolicyStatus) GetState() v1.ApprovalState
func (*DestinationPolicyStatus) ProtoMessage ¶ added in v1.1.0
func (*DestinationPolicyStatus) ProtoMessage()
func (*DestinationPolicyStatus) ProtoReflect ¶ added in v1.1.0
func (x *DestinationPolicyStatus) ProtoReflect() protoreflect.Message
func (*DestinationPolicyStatus) Reset ¶ added in v1.1.0
func (x *DestinationPolicyStatus) Reset()
func (*DestinationPolicyStatus) String ¶ added in v1.1.0
func (x *DestinationPolicyStatus) String() string
type GatewayRoutes ¶ added in v1.1.0
type GatewayRoutes struct { // The list of routes selected. If no routeLabelMatcher was provided, // the value "*" will be used to indicate all routes were selected. Routes []string `protobuf:"bytes,4,rep,name=routes,proto3" json:"routes,omitempty"` // contains filtered or unexported fields }
Represents a specific gateway resource and which routes on that resource have been selected
func (*GatewayRoutes) Descriptor
deprecated
added in
v1.1.0
func (*GatewayRoutes) Descriptor() ([]byte, []int)
Deprecated: Use GatewayRoutes.ProtoReflect.Descriptor instead.
func (*GatewayRoutes) Equal ¶ added in v1.1.0
func (m *GatewayRoutes) Equal(that interface{}) bool
Equal function
func (*GatewayRoutes) GetRoutes ¶ added in v1.1.0
func (x *GatewayRoutes) GetRoutes() []string
func (*GatewayRoutes) ProtoMessage ¶ added in v1.1.0
func (*GatewayRoutes) ProtoMessage()
func (*GatewayRoutes) ProtoReflect ¶ added in v1.1.0
func (x *GatewayRoutes) ProtoReflect() protoreflect.Message
func (*GatewayRoutes) Reset ¶ added in v1.1.0
func (x *GatewayRoutes) Reset()
func (*GatewayRoutes) String ¶ added in v1.1.0
func (x *GatewayRoutes) String() string
type HeaderManipulation ¶ added in v1.1.0
type HeaderManipulation struct { // HTTP headers to remove before returning a response to the caller. RemoveResponseHeaders []string `` /* 126-byte string literal not displayed */ // Additional HTTP headers to add before returning a response to the caller. AppendResponseHeaders map[string]string `` /* 214-byte string literal not displayed */ // HTTP headers to remove before forwarding a request to the destination service. RemoveRequestHeaders []string `protobuf:"bytes,3,rep,name=remove_request_headers,json=removeRequestHeaders,proto3" json:"remove_request_headers,omitempty"` // Additional HTTP headers to add before forwarding a request to the destination service. AppendRequestHeaders map[string]string `` /* 211-byte string literal not displayed */ // contains filtered or unexported fields }
Specify modifications to request and response headers.
func (*HeaderManipulation) Descriptor
deprecated
added in
v1.1.0
func (*HeaderManipulation) Descriptor() ([]byte, []int)
Deprecated: Use HeaderManipulation.ProtoReflect.Descriptor instead.
func (*HeaderManipulation) Equal ¶ added in v1.1.0
func (m *HeaderManipulation) Equal(that interface{}) bool
Equal function
func (*HeaderManipulation) GetAppendRequestHeaders ¶ added in v1.1.0
func (x *HeaderManipulation) GetAppendRequestHeaders() map[string]string
func (*HeaderManipulation) GetAppendResponseHeaders ¶ added in v1.1.0
func (x *HeaderManipulation) GetAppendResponseHeaders() map[string]string
func (*HeaderManipulation) GetRemoveRequestHeaders ¶ added in v1.1.0
func (x *HeaderManipulation) GetRemoveRequestHeaders() []string
func (*HeaderManipulation) GetRemoveResponseHeaders ¶ added in v1.1.0
func (x *HeaderManipulation) GetRemoveResponseHeaders() []string
func (*HeaderManipulation) ProtoMessage ¶ added in v1.1.0
func (*HeaderManipulation) ProtoMessage()
func (*HeaderManipulation) ProtoReflect ¶ added in v1.1.0
func (x *HeaderManipulation) ProtoReflect() protoreflect.Message
func (*HeaderManipulation) Reset ¶ added in v1.1.0
func (x *HeaderManipulation) Reset()
func (*HeaderManipulation) String ¶ added in v1.1.0
func (x *HeaderManipulation) String() string
type HeaderMatcher ¶ added in v1.1.0
type HeaderMatcher struct { // Specify the name of the header in the request. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Specify the value of the header. If the value is absent a request that // has the name header will match, regardless of the header’s value. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Specify whether the header value should be treated as regex. Regex bool `protobuf:"varint,3,opt,name=regex,proto3" json:"regex,omitempty"` // //If set to true, the result of the match will be inverted. Defaults to false. // //Examples: // //- name=foo, invert_match=true: matches if no header named `foo` is present //- name=foo, value=bar, invert_match=true: matches if no header named `foo` with value `bar` is present //- name=foo, value=“\d{3}“, regex=true, invert_match=true: matches if no header named `foo` with a value consisting of three integers is present. InvertMatch bool `protobuf:"varint,4,opt,name=invert_match,json=invertMatch,proto3" json:"invert_match,omitempty"` // contains filtered or unexported fields }
Describes a matcher against HTTP request headers.
func (*HeaderMatcher) Descriptor
deprecated
added in
v1.1.0
func (*HeaderMatcher) Descriptor() ([]byte, []int)
Deprecated: Use HeaderMatcher.ProtoReflect.Descriptor instead.
func (*HeaderMatcher) GetInvertMatch ¶ added in v1.1.0
func (x *HeaderMatcher) GetInvertMatch() bool
func (*HeaderMatcher) GetName ¶ added in v1.1.0
func (x *HeaderMatcher) GetName() string
func (*HeaderMatcher) GetRegex ¶ added in v1.1.0
func (x *HeaderMatcher) GetRegex() bool
func (*HeaderMatcher) GetValue ¶ added in v1.1.0
func (x *HeaderMatcher) GetValue() string
func (*HeaderMatcher) ProtoMessage ¶ added in v1.1.0
func (*HeaderMatcher) ProtoMessage()
func (*HeaderMatcher) ProtoReflect ¶ added in v1.1.0
func (x *HeaderMatcher) ProtoReflect() protoreflect.Message
func (*HeaderMatcher) Reset ¶ added in v1.1.0
func (x *HeaderMatcher) Reset()
func (*HeaderMatcher) String ¶ added in v1.1.0
func (x *HeaderMatcher) String() string
type HttpMatcher ¶ added in v1.1.0
type HttpMatcher struct { // The name assigned to a match. The match's name will be // concatenated with the parent route's name and will be logged in // the access logs for requests matching this route. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Specify match criteria against the targeted path. Uri *v1.StringMatch `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"` // Specify a set of headers which requests must match in entirety (all headers must match). Headers []*HeaderMatcher `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"` // Specify a set of URL query parameters which requests must match in entirety (all query params must match). QueryParameters []*HttpMatcher_QueryParameterMatcher `protobuf:"bytes,6,rep,name=query_parameters,json=queryParameters,proto3" json:"query_parameters,omitempty"` // Specify an HTTP method to match against. Method string `protobuf:"bytes,7,opt,name=method,proto3" json:"method,omitempty"` // contains filtered or unexported fields }
Specify HTTP request level match criteria. All specified conditions must be satisfied for a match to occur.
func (*HttpMatcher) Descriptor
deprecated
added in
v1.1.0
func (*HttpMatcher) Descriptor() ([]byte, []int)
Deprecated: Use HttpMatcher.ProtoReflect.Descriptor instead.
func (*HttpMatcher) GetHeaders ¶ added in v1.1.0
func (x *HttpMatcher) GetHeaders() []*HeaderMatcher
func (*HttpMatcher) GetMethod ¶ added in v1.1.0
func (x *HttpMatcher) GetMethod() string
func (*HttpMatcher) GetName ¶ added in v1.1.0
func (x *HttpMatcher) GetName() string
func (*HttpMatcher) GetQueryParameters ¶ added in v1.1.0
func (x *HttpMatcher) GetQueryParameters() []*HttpMatcher_QueryParameterMatcher
func (*HttpMatcher) GetUri ¶ added in v1.1.0
func (x *HttpMatcher) GetUri() *v1.StringMatch
func (*HttpMatcher) ProtoMessage ¶ added in v1.1.0
func (*HttpMatcher) ProtoMessage()
func (*HttpMatcher) ProtoReflect ¶ added in v1.1.0
func (x *HttpMatcher) ProtoReflect() protoreflect.Message
func (*HttpMatcher) Reset ¶ added in v1.1.0
func (x *HttpMatcher) Reset()
func (*HttpMatcher) String ¶ added in v1.1.0
func (x *HttpMatcher) String() string
type HttpMatcher_QueryParameterMatcher ¶ added in v1.1.0
type HttpMatcher_QueryParameterMatcher struct { // Specify the name of a key that must be present in the requested path's query string. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Specify the value of the query parameter keyed on `name`. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // If true, treat `value` as a regular expression. Regex bool `protobuf:"varint,3,opt,name=regex,proto3" json:"regex,omitempty"` // contains filtered or unexported fields }
Specify match criteria against the target URL's query parameters.
func (*HttpMatcher_QueryParameterMatcher) Descriptor
deprecated
added in
v1.1.0
func (*HttpMatcher_QueryParameterMatcher) Descriptor() ([]byte, []int)
Deprecated: Use HttpMatcher_QueryParameterMatcher.ProtoReflect.Descriptor instead.
func (*HttpMatcher_QueryParameterMatcher) GetName ¶ added in v1.1.0
func (x *HttpMatcher_QueryParameterMatcher) GetName() string
func (*HttpMatcher_QueryParameterMatcher) GetRegex ¶ added in v1.1.0
func (x *HttpMatcher_QueryParameterMatcher) GetRegex() bool
func (*HttpMatcher_QueryParameterMatcher) GetValue ¶ added in v1.1.0
func (x *HttpMatcher_QueryParameterMatcher) GetValue() string
func (*HttpMatcher_QueryParameterMatcher) ProtoMessage ¶ added in v1.1.0
func (*HttpMatcher_QueryParameterMatcher) ProtoMessage()
func (*HttpMatcher_QueryParameterMatcher) ProtoReflect ¶ added in v1.1.0
func (x *HttpMatcher_QueryParameterMatcher) ProtoReflect() protoreflect.Message
func (*HttpMatcher_QueryParameterMatcher) Reset ¶ added in v1.1.0
func (x *HttpMatcher_QueryParameterMatcher) Reset()
func (*HttpMatcher_QueryParameterMatcher) String ¶ added in v1.1.0
func (x *HttpMatcher_QueryParameterMatcher) String() string
type MetaData ¶ added in v1.1.0
type MetaData struct { // Required. The key to use in the descriptor entry. DescriptorKey string `protobuf:"bytes,1,opt,name=descriptor_key,json=descriptorKey,proto3" json:"descriptor_key,omitempty"` // [(validate.rules).string = {min_len: 1}]; // Required. Metadata struct that defines the key and path to retrieve the string value. A match will // only happen if the value in the metadata is of type string. MetadataKey *MetaData_MetadataKey `protobuf:"bytes,2,opt,name=metadata_key,json=metadataKey,proto3" json:"metadata_key,omitempty"` // [(validate.rules).message = {required: true}]; // An optional value to use if *metadata_key* is empty. If not set and // no value is present under the metadata_key then no descriptor is generated. DefaultValue string `protobuf:"bytes,3,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"` // Source of metadata Source MetaData_Source `protobuf:"varint,4,opt,name=source,proto3,enum=networking.mesh.gloo.solo.io.MetaData_Source" json:"source,omitempty"` // [(validate.rules).enum = {defined_only: true}]; // contains filtered or unexported fields }
The following descriptor entry is appended when the metadata contains a key value:
("<descriptor_key>", "<value_queried_from_metadata>")
func (*MetaData) Descriptor
deprecated
added in
v1.1.0
func (*MetaData) GetDefaultValue ¶ added in v1.1.0
func (*MetaData) GetDescriptorKey ¶ added in v1.1.0
func (*MetaData) GetMetadataKey ¶ added in v1.1.0
func (x *MetaData) GetMetadataKey() *MetaData_MetadataKey
func (*MetaData) GetSource ¶ added in v1.1.0
func (x *MetaData) GetSource() MetaData_Source
func (*MetaData) ProtoMessage ¶ added in v1.1.0
func (*MetaData) ProtoMessage()
func (*MetaData) ProtoReflect ¶ added in v1.1.0
func (x *MetaData) ProtoReflect() protoreflect.Message
type MetaData_MetadataKey ¶ added in v1.1.0
type MetaData_MetadataKey struct { // Required. The key name of Metadata to retrieve the Struct from the metadata. // Typically, it represents a builtin subsystem or custom extension. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // [(validate.rules).string = {min_len: 1}]; // Must have at least one element. The path to retrieve the Value from the Struct. It can be a prefix or a full path, // e.g. “[prop, xyz]“ for a struct or “[prop, foo]“ for a string in the example, // which depends on the particular scenario. // // Note: Due to that only the key type segment is supported, the path can not specify a list // unless the list is the last segment. Path []*MetaData_MetadataKey_PathSegment `protobuf:"bytes,2,rep,name=path,proto3" json:"path,omitempty"` // [(validate.rules).repeated = {min_items: 1}]; // contains filtered or unexported fields }
MetadataKey provides a general interface using `key` and `path` to retrieve value from [`Metadata`](https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/core/v3/base.proto#envoy-v3-api-msg-config-core-v3-metadata).
For example, for the following Metadata:
```yaml filter_metadata:
envoy.xxx: prop: foo: bar xyz: hello: envoy
```
The following MetadataKey will retrieve a string value "bar" from the Metadata.
```yaml key: envoy.xxx path: - key: prop - key: foo ```
func (*MetaData_MetadataKey) Descriptor
deprecated
added in
v1.1.0
func (*MetaData_MetadataKey) Descriptor() ([]byte, []int)
Deprecated: Use MetaData_MetadataKey.ProtoReflect.Descriptor instead.
func (*MetaData_MetadataKey) Equal ¶ added in v1.1.0
func (m *MetaData_MetadataKey) Equal(that interface{}) bool
Equal function
func (*MetaData_MetadataKey) GetKey ¶ added in v1.1.0
func (x *MetaData_MetadataKey) GetKey() string
func (*MetaData_MetadataKey) GetPath ¶ added in v1.1.0
func (x *MetaData_MetadataKey) GetPath() []*MetaData_MetadataKey_PathSegment
func (*MetaData_MetadataKey) ProtoMessage ¶ added in v1.1.0
func (*MetaData_MetadataKey) ProtoMessage()
func (*MetaData_MetadataKey) ProtoReflect ¶ added in v1.1.0
func (x *MetaData_MetadataKey) ProtoReflect() protoreflect.Message
func (*MetaData_MetadataKey) Reset ¶ added in v1.1.0
func (x *MetaData_MetadataKey) Reset()
func (*MetaData_MetadataKey) String ¶ added in v1.1.0
func (x *MetaData_MetadataKey) String() string
type MetaData_MetadataKey_PathSegment ¶ added in v1.1.0
type MetaData_MetadataKey_PathSegment struct { // Types that are assignable to Segment: // *MetaData_MetadataKey_PathSegment_Key Segment isMetaData_MetadataKey_PathSegment_Segment `protobuf_oneof:"segment"` // contains filtered or unexported fields }
Specifies the segment in a path to retrieve value from Metadata. Currently it is only supported to specify the key, i.e. field name, as one segment of a path.
func (*MetaData_MetadataKey_PathSegment) Descriptor
deprecated
added in
v1.1.0
func (*MetaData_MetadataKey_PathSegment) Descriptor() ([]byte, []int)
Deprecated: Use MetaData_MetadataKey_PathSegment.ProtoReflect.Descriptor instead.
func (*MetaData_MetadataKey_PathSegment) Equal ¶ added in v1.1.0
func (m *MetaData_MetadataKey_PathSegment) Equal(that interface{}) bool
Equal function
func (*MetaData_MetadataKey_PathSegment) GetKey ¶ added in v1.1.0
func (x *MetaData_MetadataKey_PathSegment) GetKey() string
func (*MetaData_MetadataKey_PathSegment) GetSegment ¶ added in v1.1.0
func (m *MetaData_MetadataKey_PathSegment) GetSegment() isMetaData_MetadataKey_PathSegment_Segment
func (*MetaData_MetadataKey_PathSegment) ProtoMessage ¶ added in v1.1.0
func (*MetaData_MetadataKey_PathSegment) ProtoMessage()
func (*MetaData_MetadataKey_PathSegment) ProtoReflect ¶ added in v1.1.0
func (x *MetaData_MetadataKey_PathSegment) ProtoReflect() protoreflect.Message
func (*MetaData_MetadataKey_PathSegment) Reset ¶ added in v1.1.0
func (x *MetaData_MetadataKey_PathSegment) Reset()
func (*MetaData_MetadataKey_PathSegment) String ¶ added in v1.1.0
func (x *MetaData_MetadataKey_PathSegment) String() string
type MetaData_MetadataKey_PathSegment_Key ¶ added in v1.1.0
type MetaData_MetadataKey_PathSegment_Key struct { // Required. If specified, use the key to retrieve the value in a Struct. Key string `protobuf:"bytes,1,opt,name=key,proto3,oneof"` // [(validate.rules).string = {min_len: 1}]; }
type MetaData_Source ¶ added in v1.1.0
type MetaData_Source int32
const ( // Query [dynamic metadata](https://www.envoyproxy.io/docs/envoy/latest/configuration/advanced/well_known_dynamic_metadata#well-known-dynamic-metadata). MetaData_DYNAMIC MetaData_Source = 0 // Query [route entry metadata](https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/route/v3/route_components.proto#envoy-v3-api-field-config-route-v3-route-metadata). MetaData_ROUTE_ENTRY MetaData_Source = 1 )
func (MetaData_Source) Descriptor ¶ added in v1.1.0
func (MetaData_Source) Descriptor() protoreflect.EnumDescriptor
func (MetaData_Source) Enum ¶ added in v1.1.0
func (x MetaData_Source) Enum() *MetaData_Source
func (MetaData_Source) EnumDescriptor
deprecated
added in
v1.1.0
func (MetaData_Source) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetaData_Source.Descriptor instead.
func (MetaData_Source) Number ¶ added in v1.1.0
func (x MetaData_Source) Number() protoreflect.EnumNumber
func (MetaData_Source) String ¶ added in v1.1.0
func (x MetaData_Source) String() string
func (MetaData_Source) Type ¶ added in v1.1.0
func (MetaData_Source) Type() protoreflect.EnumType
type MulticlusterAccessPolicyClient ¶
type MulticlusterAccessPolicyClient interface { // Cluster returns a AccessPolicyClient for the given cluster Cluster(cluster string) (AccessPolicyClient, error) }
Provides AccessPolicyClients for multiple clusters.
func NewMulticlusterAccessPolicyClient ¶
func NewMulticlusterAccessPolicyClient(client multicluster.Client) MulticlusterAccessPolicyClient
type MulticlusterClientset ¶
type MulticlusterClientset interface { // Cluster returns a Clientset for the given cluster Cluster(cluster string) (Clientset, error) }
MulticlusterClientset for the networking.mesh.gloo.solo.io/v1 APIs
func NewMulticlusterClientset ¶
func NewMulticlusterClientset(client multicluster.Client) MulticlusterClientset
type MulticlusterTrafficPolicyClient ¶
type MulticlusterTrafficPolicyClient interface { // Cluster returns a TrafficPolicyClient for the given cluster Cluster(cluster string) (TrafficPolicyClient, error) }
Provides TrafficPolicyClients for multiple clusters.
func NewMulticlusterTrafficPolicyClient ¶
func NewMulticlusterTrafficPolicyClient(client multicluster.Client) MulticlusterTrafficPolicyClient
type MulticlusterVirtualMeshClient ¶
type MulticlusterVirtualMeshClient interface { // Cluster returns a VirtualMeshClient for the given cluster Cluster(cluster string) (VirtualMeshClient, error) }
Provides VirtualMeshClients for multiple clusters.
func NewMulticlusterVirtualMeshClient ¶
func NewMulticlusterVirtualMeshClient(client multicluster.Client) MulticlusterVirtualMeshClient
type RateLimitActions ¶ added in v1.1.0
type RateLimitActions struct { // TODO: come up with descriptive names and comments for these fields Actions []*Action `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"` SetActions []*Action `protobuf:"bytes,2,rep,name=set_actions,json=setActions,proto3" json:"set_actions,omitempty"` // contains filtered or unexported fields }
Each action and setAction in the lists maps part of the request (or its context) to a descriptor. The tuple or set of descriptors generated by the provided actions is sent to the rate limit server and matched against rate limit rules. Order matters on provided actions but not on setActions, e.g. the following actions: - actions:
- requestHeaders: descriptorKey: account_id headerName: x-account-id
- requestHeaders: descriptorKey: plan headerName: x-plan
define an ordered descriptor tuple like so: ('account_id', '<x-account-id value>'), ('plan', '<x-plan value>')
While the current form matches, the same tuple in reverse order would not match the following descriptor:
descriptors:
- key: account_id descriptors:
- key: plan value: BASIC rateLimit: requestsPerUnit: 1 unit: MINUTE
- key: plan value: PLUS rateLimit: requestsPerUnit: 20 unit: MINUTE
Similarly, the following setActions: - setActions:
- requestHeaders: descriptorKey: account_id headerName: x-account-id
- requestHeaders: descriptorKey: plan headerName: x-plan
define an unordered descriptor set like so: {('account_id', '<x-account-id value>'), ('plan', '<x-plan value>')}
This set would match the following setDescriptor:
setDescriptors: - simpleDescriptors:
- key: plan value: BASIC
- key: account_id rateLimit: requestsPerUnit: 20 unit: MINUTE
It would also match the following setDescriptor which includes only a subset of the setActions enumerated:
setDescriptors: - simpleDescriptors:
- key: account_id rateLimit: requestsPerUnit: 20 unit: MINUTE
It would even match the following setDescriptor. Any setActions list would match this setDescriptor which has simpleDescriptors omitted entirely:
setDescriptors:
- rateLimit: requestsPerUnit: 20 unit: MINUTE
func (*RateLimitActions) Descriptor
deprecated
added in
v1.1.0
func (*RateLimitActions) Descriptor() ([]byte, []int)
Deprecated: Use RateLimitActions.ProtoReflect.Descriptor instead.
func (*RateLimitActions) Equal ¶ added in v1.1.0
func (m *RateLimitActions) Equal(that interface{}) bool
Equal function
func (*RateLimitActions) GetActions ¶ added in v1.1.0
func (x *RateLimitActions) GetActions() []*Action
func (*RateLimitActions) GetSetActions ¶ added in v1.1.0
func (x *RateLimitActions) GetSetActions() []*Action
func (*RateLimitActions) ProtoMessage ¶ added in v1.1.0
func (*RateLimitActions) ProtoMessage()
func (*RateLimitActions) ProtoReflect ¶ added in v1.1.0
func (x *RateLimitActions) ProtoReflect() protoreflect.Message
func (*RateLimitActions) Reset ¶ added in v1.1.0
func (x *RateLimitActions) Reset()
func (*RateLimitActions) String ¶ added in v1.1.0
func (x *RateLimitActions) String() string
type RateLimitRouteExtension ¶ added in v1.1.0
type RateLimitRouteExtension struct { // Whether or not to include rate limits as defined on the VirtualHost in addition to rate limits on the Route. IncludeVhRateLimits bool `protobuf:"varint,1,opt,name=include_vh_rate_limits,json=includeVhRateLimits,proto3" json:"include_vh_rate_limits,omitempty"` // Define individual rate limits here. Each rate limit will be evaluated, if any rate limit // would be throttled, the entire request returns a 429 (gets throttled) RateLimits []*RateLimitActions `protobuf:"bytes,2,rep,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"` // contains filtered or unexported fields }
Use this field if you want to inline the Envoy rate limits for this Route. Note that this does not configure the rate limit server. If you are running Gloo Enterprise, you need to specify the server configuration via the appropriate field in the Gloo `Settings` resource. If you are running a custom rate limit server you need to configure it yourself.
func (*RateLimitRouteExtension) Descriptor
deprecated
added in
v1.1.0
func (*RateLimitRouteExtension) Descriptor() ([]byte, []int)
Deprecated: Use RateLimitRouteExtension.ProtoReflect.Descriptor instead.
func (*RateLimitRouteExtension) Equal ¶ added in v1.1.0
func (m *RateLimitRouteExtension) Equal(that interface{}) bool
Equal function
func (*RateLimitRouteExtension) GetIncludeVhRateLimits ¶ added in v1.1.0
func (x *RateLimitRouteExtension) GetIncludeVhRateLimits() bool
func (*RateLimitRouteExtension) GetRateLimits ¶ added in v1.1.0
func (x *RateLimitRouteExtension) GetRateLimits() []*RateLimitActions
func (*RateLimitRouteExtension) ProtoMessage ¶ added in v1.1.0
func (*RateLimitRouteExtension) ProtoMessage()
func (*RateLimitRouteExtension) ProtoReflect ¶ added in v1.1.0
func (x *RateLimitRouteExtension) ProtoReflect() protoreflect.Message
func (*RateLimitRouteExtension) Reset ¶ added in v1.1.0
func (x *RateLimitRouteExtension) Reset()
func (*RateLimitRouteExtension) String ¶ added in v1.1.0
func (x *RateLimitRouteExtension) String() string
type RequestLimit ¶ added in v1.1.0
type RequestLimit struct { Unit RequestLimit_Unit `protobuf:"varint,1,opt,name=unit,proto3,enum=networking.mesh.gloo.solo.io.RequestLimit_Unit" json:"unit,omitempty"` RequestsPerUnit uint32 `protobuf:"varint,2,opt,name=requests_per_unit,json=requestsPerUnit,proto3" json:"requests_per_unit,omitempty"` // contains filtered or unexported fields }
A `RateLimit` specifies the actual rate limit that will be used when there is a match.
func (*RequestLimit) Descriptor
deprecated
added in
v1.1.0
func (*RequestLimit) Descriptor() ([]byte, []int)
Deprecated: Use RequestLimit.ProtoReflect.Descriptor instead.
func (*RequestLimit) Equal ¶ added in v1.1.0
func (m *RequestLimit) Equal(that interface{}) bool
Equal function
func (*RequestLimit) GetRequestsPerUnit ¶ added in v1.1.0
func (x *RequestLimit) GetRequestsPerUnit() uint32
func (*RequestLimit) GetUnit ¶ added in v1.1.0
func (x *RequestLimit) GetUnit() RequestLimit_Unit
func (*RequestLimit) ProtoMessage ¶ added in v1.1.0
func (*RequestLimit) ProtoMessage()
func (*RequestLimit) ProtoReflect ¶ added in v1.1.0
func (x *RequestLimit) ProtoReflect() protoreflect.Message
func (*RequestLimit) Reset ¶ added in v1.1.0
func (x *RequestLimit) Reset()
func (*RequestLimit) String ¶ added in v1.1.0
func (x *RequestLimit) String() string
type RequestLimit_Unit ¶ added in v1.1.0
type RequestLimit_Unit int32
const ( RequestLimit_UNKNOWN RequestLimit_Unit = 0 RequestLimit_SECOND RequestLimit_Unit = 1 RequestLimit_MINUTE RequestLimit_Unit = 2 RequestLimit_HOUR RequestLimit_Unit = 3 RequestLimit_DAY RequestLimit_Unit = 4 )
func (RequestLimit_Unit) Descriptor ¶ added in v1.1.0
func (RequestLimit_Unit) Descriptor() protoreflect.EnumDescriptor
func (RequestLimit_Unit) Enum ¶ added in v1.1.0
func (x RequestLimit_Unit) Enum() *RequestLimit_Unit
func (RequestLimit_Unit) EnumDescriptor
deprecated
added in
v1.1.0
func (RequestLimit_Unit) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestLimit_Unit.Descriptor instead.
func (RequestLimit_Unit) Number ¶ added in v1.1.0
func (x RequestLimit_Unit) Number() protoreflect.EnumNumber
func (RequestLimit_Unit) String ¶ added in v1.1.0
func (x RequestLimit_Unit) String() string
func (RequestLimit_Unit) Type ¶ added in v1.1.0
func (RequestLimit_Unit) Type() protoreflect.EnumType
type RootCertificateAuthority ¶ added in v1.1.0
type RootCertificateAuthority struct { // Specify the source of the Root CA data which Gloo Mesh will use for the VirtualMesh. // // Types that are assignable to CaSource: // *RootCertificateAuthority_Generated // *RootCertificateAuthority_Secret CaSource isRootCertificateAuthority_CaSource `protobuf_oneof:"ca_source"` // contains filtered or unexported fields }
Specify parameters for configuring the root certificate authority for a VirtualMesh.
func (*RootCertificateAuthority) Descriptor
deprecated
added in
v1.1.0
func (*RootCertificateAuthority) Descriptor() ([]byte, []int)
Deprecated: Use RootCertificateAuthority.ProtoReflect.Descriptor instead.
func (*RootCertificateAuthority) Equal ¶ added in v1.1.0
func (m *RootCertificateAuthority) Equal(that interface{}) bool
Equal function
func (*RootCertificateAuthority) GetCaSource ¶ added in v1.1.0
func (m *RootCertificateAuthority) GetCaSource() isRootCertificateAuthority_CaSource
func (*RootCertificateAuthority) GetGenerated ¶ added in v1.1.0
func (x *RootCertificateAuthority) GetGenerated() *v11.CommonCertOptions
func (*RootCertificateAuthority) GetSecret ¶ added in v1.1.0
func (x *RootCertificateAuthority) GetSecret() *v1.ObjectRef
func (*RootCertificateAuthority) ProtoMessage ¶ added in v1.1.0
func (*RootCertificateAuthority) ProtoMessage()
func (*RootCertificateAuthority) ProtoReflect ¶ added in v1.1.0
func (x *RootCertificateAuthority) ProtoReflect() protoreflect.Message
func (*RootCertificateAuthority) Reset ¶ added in v1.1.0
func (x *RootCertificateAuthority) Reset()
func (*RootCertificateAuthority) String ¶ added in v1.1.0
func (x *RootCertificateAuthority) String() string
type RootCertificateAuthority_Generated ¶ added in v1.1.0
type RootCertificateAuthority_Generated struct { // Generate a self-signed root certificate with the given options. Generated *v11.CommonCertOptions `protobuf:"bytes,1,opt,name=generated,proto3,oneof"` }
type RootCertificateAuthority_Secret ¶ added in v1.1.0
type RootCertificateAuthority_Secret struct { // Reference to a Kubernetes Secret containing the root certificate authority. // Provided secrets must conform to a specified format, [documented here]({{< versioned_link_path fromRoot="/guides/federate_identity/" >}}). Secret *v1.ObjectRef `protobuf:"bytes,2,opt,name=secret,proto3,oneof"` }
type RouteRateLimit ¶ added in v1.1.0
type RouteRateLimit struct { // Types that are assignable to RateLimitConfigType: // *RouteRateLimit_Basic // *RouteRateLimit_Advanced // *RouteRateLimit_ConfigRefs RateLimitConfigType isRouteRateLimit_RateLimitConfigType `protobuf_oneof:"rate_limit_config_type"` // contains filtered or unexported fields }
func (*RouteRateLimit) Descriptor
deprecated
added in
v1.1.0
func (*RouteRateLimit) Descriptor() ([]byte, []int)
Deprecated: Use RouteRateLimit.ProtoReflect.Descriptor instead.
func (*RouteRateLimit) Equal ¶ added in v1.1.0
func (m *RouteRateLimit) Equal(that interface{}) bool
Equal function
func (*RouteRateLimit) GetAdvanced ¶ added in v1.1.0
func (x *RouteRateLimit) GetAdvanced() *RouteRateLimit_AdvancedRateLimit
func (*RouteRateLimit) GetBasic ¶ added in v1.1.0
func (x *RouteRateLimit) GetBasic() *RouteRateLimit_BasicRateLimit
func (*RouteRateLimit) GetConfigRefs ¶ added in v1.1.0
func (x *RouteRateLimit) GetConfigRefs() *v1.ObjectRefList
func (*RouteRateLimit) GetRateLimitConfigType ¶ added in v1.1.0
func (m *RouteRateLimit) GetRateLimitConfigType() isRouteRateLimit_RateLimitConfigType
func (*RouteRateLimit) ProtoMessage ¶ added in v1.1.0
func (*RouteRateLimit) ProtoMessage()
func (*RouteRateLimit) ProtoReflect ¶ added in v1.1.0
func (x *RouteRateLimit) ProtoReflect() protoreflect.Message
func (*RouteRateLimit) Reset ¶ added in v1.1.0
func (x *RouteRateLimit) Reset()
func (*RouteRateLimit) String ¶ added in v1.1.0
func (x *RouteRateLimit) String() string
type RouteRateLimit_Advanced ¶ added in v1.1.0
type RouteRateLimit_Advanced struct { // Partial config for GlooE rate-limiting based on Envoy's rate-limit service; // supports Envoy's rate-limit service API. (reference here: https://github.com/lyft/ratelimit#configuration) // Configure rate-limit *actions* here, which define how request characteristics get translated into // descriptors used by the rate-limit service for rate-limiting. Configure rate-limit *descriptors* and // their associated limits on the Gloo settings. // Only one of `ratelimit` or `rate_limit_configs` can be set. Advanced *RouteRateLimit_AdvancedRateLimit `protobuf:"bytes,2,opt,name=advanced,proto3,oneof"` }
type RouteRateLimit_AdvancedRateLimit ¶ added in v1.1.0
type RouteRateLimit_AdvancedRateLimit struct { // Define individual rate limits here. Each rate limit will be evaluated, if any rate limit // would be throttled, the entire request returns a 429 (gets throttled) Actions []*RateLimitActions `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"` // contains filtered or unexported fields }
Use this field if you want to inline the Envoy rate limits for this VirtualHost. Note that this does not configure the rate limit server. If you are running Gloo Enterprise, you need to specify the server configuration via the appropriate field in the Gloo `Settings` resource. If you are running a custom rate limit server you need to configure it yourself.
func (*RouteRateLimit_AdvancedRateLimit) Descriptor
deprecated
added in
v1.1.0
func (*RouteRateLimit_AdvancedRateLimit) Descriptor() ([]byte, []int)
Deprecated: Use RouteRateLimit_AdvancedRateLimit.ProtoReflect.Descriptor instead.
func (*RouteRateLimit_AdvancedRateLimit) Equal ¶ added in v1.1.0
func (m *RouteRateLimit_AdvancedRateLimit) Equal(that interface{}) bool
Equal function
func (*RouteRateLimit_AdvancedRateLimit) GetActions ¶ added in v1.1.0
func (x *RouteRateLimit_AdvancedRateLimit) GetActions() []*RateLimitActions
func (*RouteRateLimit_AdvancedRateLimit) ProtoMessage ¶ added in v1.1.0
func (*RouteRateLimit_AdvancedRateLimit) ProtoMessage()
func (*RouteRateLimit_AdvancedRateLimit) ProtoReflect ¶ added in v1.1.0
func (x *RouteRateLimit_AdvancedRateLimit) ProtoReflect() protoreflect.Message
func (*RouteRateLimit_AdvancedRateLimit) Reset ¶ added in v1.1.0
func (x *RouteRateLimit_AdvancedRateLimit) Reset()
func (*RouteRateLimit_AdvancedRateLimit) String ¶ added in v1.1.0
func (x *RouteRateLimit_AdvancedRateLimit) String() string
type RouteRateLimit_Basic ¶ added in v1.1.0
type RouteRateLimit_Basic struct { // Config for rate-limiting using simplified (gloo-specific) API Basic *RouteRateLimit_BasicRateLimit `protobuf:"bytes,1,opt,name=basic,proto3,oneof"` }
type RouteRateLimit_BasicRateLimit ¶ added in v1.1.0
type RouteRateLimit_BasicRateLimit struct { // limits for authorized users AuthorizedLimits *RequestLimit `protobuf:"bytes,1,opt,name=authorized_limits,json=authorizedLimits,proto3" json:"authorized_limits,omitempty"` // limits for unauthorized users AnonymousLimits *RequestLimit `protobuf:"bytes,2,opt,name=anonymous_limits,json=anonymousLimits,proto3" json:"anonymous_limits,omitempty"` // contains filtered or unexported fields }
Basic rate-limiting API
func (*RouteRateLimit_BasicRateLimit) Descriptor
deprecated
added in
v1.1.0
func (*RouteRateLimit_BasicRateLimit) Descriptor() ([]byte, []int)
Deprecated: Use RouteRateLimit_BasicRateLimit.ProtoReflect.Descriptor instead.
func (*RouteRateLimit_BasicRateLimit) Equal ¶ added in v1.1.0
func (m *RouteRateLimit_BasicRateLimit) Equal(that interface{}) bool
Equal function
func (*RouteRateLimit_BasicRateLimit) GetAnonymousLimits ¶ added in v1.1.0
func (x *RouteRateLimit_BasicRateLimit) GetAnonymousLimits() *RequestLimit
func (*RouteRateLimit_BasicRateLimit) GetAuthorizedLimits ¶ added in v1.1.0
func (x *RouteRateLimit_BasicRateLimit) GetAuthorizedLimits() *RequestLimit
func (*RouteRateLimit_BasicRateLimit) ProtoMessage ¶ added in v1.1.0
func (*RouteRateLimit_BasicRateLimit) ProtoMessage()
func (*RouteRateLimit_BasicRateLimit) ProtoReflect ¶ added in v1.1.0
func (x *RouteRateLimit_BasicRateLimit) ProtoReflect() protoreflect.Message
func (*RouteRateLimit_BasicRateLimit) Reset ¶ added in v1.1.0
func (x *RouteRateLimit_BasicRateLimit) Reset()
func (*RouteRateLimit_BasicRateLimit) String ¶ added in v1.1.0
func (x *RouteRateLimit_BasicRateLimit) String() string
type RouteRateLimit_ConfigRefs ¶ added in v1.1.0
type RouteRateLimit_ConfigRefs struct { // References to RateLimitConfig resources. This is used to configure the GlooE rate limit server. // Only one of `ratelimit` or `rate_limit_configs` can be set. ConfigRefs *v1.ObjectRefList `protobuf:"bytes,3,opt,name=config_refs,json=configRefs,proto3,oneof"` }
type SetDescriptor ¶ added in v1.1.0
type SetDescriptor struct { // Simple descriptor key/value pairs. SimpleDescriptors []*SimpleDescriptor `protobuf:"bytes,1,rep,name=simple_descriptors,json=simpleDescriptors,proto3" json:"simple_descriptors,omitempty"` // Rate limit rule for the descriptor. RateLimit *RequestLimit `protobuf:"bytes,2,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"` // Typically, rule priority is signalled by rule ordering, as the first rule match for // the descriptor tuple generated by the rate limit actions is used. // // In some cases this is too restrictive; A boolean override can be specified. Any rule with `alwaysApply` set to `true` will // always be considered for rate limiting, regardless of the rule's place in the ordered list of rules. // The first rule to match will still be considered. (This can be a rule that also has `alwaysApply` set to `true`.) // // If any of these rules trigger rate limiting then the entire request will return a 429. // Rules that are not considered for rate limiting are ignored in the // rate limit server, and their request count is not incremented in the rate limit server cache. // // Defaults to false. AlwaysApply bool `protobuf:"varint,3,opt,name=always_apply,json=alwaysApply,proto3" json:"always_apply,omitempty"` // contains filtered or unexported fields }
A setDescriptor is a list of key/value pairs that the rate limit server uses to select the correct rate limit to use when limiting with the set style. Descriptors are case-sensitive.
Each configuration contains a simpleDescriptor list and a rateLimit. The format is:
``` set_descriptors:
- simple_descriptors: (optional block)
- key: <rule key: required> value: <rule value: optional>
- ... (repetition of above) rate_limit: requests_per_unit: <see below: required> unit: <see below: required> always_apply: <bool value: optional>
- ... (repetition of above)
```
Each SetDescriptor defines a new Rate Limit "rule". When a request comes in, rate limit actions are applied to the request to generate descriptor tuples that are sent to the rate limit server. If any rule is triggered then the entire request returns HTTP 429 Too Many Requests.
The `rate_limit` block sets up an actual rate limit rule.
func (*SetDescriptor) Descriptor
deprecated
added in
v1.1.0
func (*SetDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use SetDescriptor.ProtoReflect.Descriptor instead.
func (*SetDescriptor) Equal ¶ added in v1.1.0
func (m *SetDescriptor) Equal(that interface{}) bool
Equal function
func (*SetDescriptor) GetAlwaysApply ¶ added in v1.1.0
func (x *SetDescriptor) GetAlwaysApply() bool
func (*SetDescriptor) GetRateLimit ¶ added in v1.1.0
func (x *SetDescriptor) GetRateLimit() *RequestLimit
func (*SetDescriptor) GetSimpleDescriptors ¶ added in v1.1.0
func (x *SetDescriptor) GetSimpleDescriptors() []*SimpleDescriptor
func (*SetDescriptor) ProtoMessage ¶ added in v1.1.0
func (*SetDescriptor) ProtoMessage()
func (*SetDescriptor) ProtoReflect ¶ added in v1.1.0
func (x *SetDescriptor) ProtoReflect() protoreflect.Message
func (*SetDescriptor) Reset ¶ added in v1.1.0
func (x *SetDescriptor) Reset()
func (*SetDescriptor) String ¶ added in v1.1.0
func (x *SetDescriptor) String() string
type SharedTrust ¶ added in v1.1.0
type SharedTrust struct { // *SharedTrust_RootCertificateAuthority // *SharedTrust_IntermediateCertificateAuthority CertificateAuthority isSharedTrust_CertificateAuthority `protobuf_oneof:"certificate_authority"` IntermediateCertOptions *v11.CommonCertOptions `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
Shared trust is a trust model requiring a common root certificate shared between trusting Meshes, as well as shared identity between all Workloads and Destinations which wish to communicate within the VirtualMesh.
func (*SharedTrust) Descriptor
deprecated
added in
v1.1.0
func (*SharedTrust) Descriptor() ([]byte, []int)
Deprecated: Use SharedTrust.ProtoReflect.Descriptor instead.
func (*SharedTrust) Equal ¶ added in v1.1.0
func (m *SharedTrust) Equal(that interface{}) bool
Equal function
func (*SharedTrust) GetCertificateAuthority ¶ added in v1.1.0
func (m *SharedTrust) GetCertificateAuthority() isSharedTrust_CertificateAuthority
func (*SharedTrust) GetIntermediateCertOptions ¶ added in v1.1.0
func (x *SharedTrust) GetIntermediateCertOptions() *v11.CommonCertOptions
func (*SharedTrust) GetIntermediateCertificateAuthority ¶ added in v1.1.0
func (x *SharedTrust) GetIntermediateCertificateAuthority() *v11.IntermediateCertificateAuthority
func (*SharedTrust) GetRootCertificateAuthority ¶ added in v1.1.0
func (x *SharedTrust) GetRootCertificateAuthority() *RootCertificateAuthority
func (*SharedTrust) ProtoMessage ¶ added in v1.1.0
func (*SharedTrust) ProtoMessage()
func (*SharedTrust) ProtoReflect ¶ added in v1.1.0
func (x *SharedTrust) ProtoReflect() protoreflect.Message
func (*SharedTrust) Reset ¶ added in v1.1.0
func (x *SharedTrust) Reset()
func (*SharedTrust) String ¶ added in v1.1.0
func (x *SharedTrust) String() string
type SharedTrust_IntermediateCertificateAuthority ¶ added in v1.1.0
type SharedTrust_IntermediateCertificateAuthority struct { // certificates. In order for this to properly mesh all of the traffic across the different meshes, the CA // being used must be configured to generate the intermediate certificates. IntermediateCertificateAuthority *v11.IntermediateCertificateAuthority `protobuf:"bytes,2,opt,name=intermediate_certificate_authority,json=intermediateCertificateAuthority,proto3,oneof"` }
type SharedTrust_RootCertificateAuthority ¶ added in v1.1.0
type SharedTrust_RootCertificateAuthority struct { // If this is not provided, a self-signed certificate will be generated by Gloo Mesh. RootCertificateAuthority *RootCertificateAuthority `protobuf:"bytes,1,opt,name=root_certificate_authority,json=rootCertificateAuthority,proto3,oneof"` }
type SimpleDescriptor ¶ added in v1.1.0
type SimpleDescriptor struct { // The key of the descriptor. This field is required. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Optional value for the descriptor. If omitted, the server will create a rate limit for // each value that is provided for this descriptor in rate limit requests. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
A simpleDescriptor is a list of key/value pairs that the rate limit server uses to select the correct rate limit to use when limiting with the set style. Descriptors are case-sensitive.
The format is:
```
simple_descriptors: - key: <rule key: required> value: <rule value: optional> - ... (repetition of above)
```
Each simpleDescriptor in a simpleDescriptor list must have a key. It can also optionally have a value to enable a more specific match.
func (*SimpleDescriptor) Descriptor
deprecated
added in
v1.1.0
func (*SimpleDescriptor) Descriptor() ([]byte, []int)
Deprecated: Use SimpleDescriptor.ProtoReflect.Descriptor instead.
func (*SimpleDescriptor) Equal ¶ added in v1.1.0
func (m *SimpleDescriptor) Equal(that interface{}) bool
Equal function
func (*SimpleDescriptor) GetKey ¶ added in v1.1.0
func (x *SimpleDescriptor) GetKey() string
func (*SimpleDescriptor) GetValue ¶ added in v1.1.0
func (x *SimpleDescriptor) GetValue() string
func (*SimpleDescriptor) ProtoMessage ¶ added in v1.1.0
func (*SimpleDescriptor) ProtoMessage()
func (*SimpleDescriptor) ProtoReflect ¶ added in v1.1.0
func (x *SimpleDescriptor) ProtoReflect() protoreflect.Message
func (*SimpleDescriptor) Reset ¶ added in v1.1.0
func (x *SimpleDescriptor) Reset()
func (*SimpleDescriptor) String ¶ added in v1.1.0
func (x *SimpleDescriptor) String() string
type StatusCodeMatcher ¶ added in v1.1.0
type StatusCodeMatcher struct { // The status code value to match against. Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // The comparison type used for matching. Comparator StatusCodeMatcher_Comparator `` /* 137-byte string literal not displayed */ // contains filtered or unexported fields }
Describes a matcher against HTTP response status codes.
func (*StatusCodeMatcher) Descriptor
deprecated
added in
v1.1.0
func (*StatusCodeMatcher) Descriptor() ([]byte, []int)
Deprecated: Use StatusCodeMatcher.ProtoReflect.Descriptor instead.
func (*StatusCodeMatcher) GetComparator ¶ added in v1.1.0
func (x *StatusCodeMatcher) GetComparator() StatusCodeMatcher_Comparator
func (*StatusCodeMatcher) GetValue ¶ added in v1.1.0
func (x *StatusCodeMatcher) GetValue() uint32
func (*StatusCodeMatcher) ProtoMessage ¶ added in v1.1.0
func (*StatusCodeMatcher) ProtoMessage()
func (*StatusCodeMatcher) ProtoReflect ¶ added in v1.1.0
func (x *StatusCodeMatcher) ProtoReflect() protoreflect.Message
func (*StatusCodeMatcher) Reset ¶ added in v1.1.0
func (x *StatusCodeMatcher) Reset()
func (*StatusCodeMatcher) String ¶ added in v1.1.0
func (x *StatusCodeMatcher) String() string
type StatusCodeMatcher_Comparator ¶ added in v1.1.0
type StatusCodeMatcher_Comparator int32
const ( // Strict equality. StatusCodeMatcher_EQ StatusCodeMatcher_Comparator = 0 // Greater than or equal to. StatusCodeMatcher_GE StatusCodeMatcher_Comparator = 1 // Less than or equal to. StatusCodeMatcher_LE StatusCodeMatcher_Comparator = 2 )
func (StatusCodeMatcher_Comparator) Descriptor ¶ added in v1.1.0
func (StatusCodeMatcher_Comparator) Descriptor() protoreflect.EnumDescriptor
func (StatusCodeMatcher_Comparator) Enum ¶ added in v1.1.0
func (x StatusCodeMatcher_Comparator) Enum() *StatusCodeMatcher_Comparator
func (StatusCodeMatcher_Comparator) EnumDescriptor
deprecated
added in
v1.1.0
func (StatusCodeMatcher_Comparator) EnumDescriptor() ([]byte, []int)
Deprecated: Use StatusCodeMatcher_Comparator.Descriptor instead.
func (StatusCodeMatcher_Comparator) Number ¶ added in v1.1.0
func (x StatusCodeMatcher_Comparator) Number() protoreflect.EnumNumber
func (StatusCodeMatcher_Comparator) String ¶ added in v1.1.0
func (x StatusCodeMatcher_Comparator) String() string
func (StatusCodeMatcher_Comparator) Type ¶ added in v1.1.0
func (StatusCodeMatcher_Comparator) Type() protoreflect.EnumType
type TrafficPolicy ¶
type TrafficPolicy struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec TrafficPolicySpec `json:"spec,omitempty"` Status TrafficPolicyStatus `json:"status,omitempty"` }
TrafficPolicy is the Schema for the trafficPolicy API
func (*TrafficPolicy) DeepCopy ¶
func (in *TrafficPolicy) DeepCopy() *TrafficPolicy
func (*TrafficPolicy) DeepCopyInto ¶
func (in *TrafficPolicy) DeepCopyInto(out *TrafficPolicy)
func (*TrafficPolicy) DeepCopyObject ¶
func (in *TrafficPolicy) DeepCopyObject() runtime.Object
func (TrafficPolicy) GVK ¶
func (TrafficPolicy) GVK() schema.GroupVersionKind
GVK returns the GroupVersionKind associated with the resource type.
type TrafficPolicyClient ¶
type TrafficPolicyClient interface { TrafficPolicyReader TrafficPolicyWriter TrafficPolicyStatusWriter }
Client knows how to perform CRUD operations on TrafficPolicys.
type TrafficPolicyList ¶
type TrafficPolicyList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []TrafficPolicy `json:"items"` }
TrafficPolicyList contains a list of TrafficPolicy
func (*TrafficPolicyList) DeepCopy ¶
func (in *TrafficPolicyList) DeepCopy() *TrafficPolicyList
func (*TrafficPolicyList) DeepCopyInto ¶
func (in *TrafficPolicyList) DeepCopyInto(out *TrafficPolicyList)
func (*TrafficPolicyList) DeepCopyObject ¶
func (in *TrafficPolicyList) DeepCopyObject() runtime.Object
type TrafficPolicyReader ¶
type TrafficPolicyReader interface { // Get retrieves a TrafficPolicy for the given object key GetTrafficPolicy(ctx context.Context, key client.ObjectKey) (*TrafficPolicy, error) // List retrieves list of TrafficPolicys for a given namespace and list options. ListTrafficPolicy(ctx context.Context, opts ...client.ListOption) (*TrafficPolicyList, error) }
Reader knows how to read and list TrafficPolicys.
type TrafficPolicySlice ¶
type TrafficPolicySlice []*TrafficPolicy
TrafficPolicySlice represents a slice of *TrafficPolicy
type TrafficPolicySpec ¶
type TrafficPolicySpec struct { // Specify the Workloads (sources for east-west traffic) this TrafficPolicy applies to. // Omit to apply to all Workloads. SourceSelector []*v1.WorkloadSelector `protobuf:"bytes,1,rep,name=source_selector,json=sourceSelector,proto3" json:"source_selector,omitempty"` // Specify the Destinations (destinations) this TrafficPolicy applies to. // Omit to apply to all Destinations. DestinationSelector []*v1.DestinationSelector `protobuf:"bytes,2,rep,name=destination_selector,json=destinationSelector,proto3" json:"destination_selector,omitempty"` // Specify which ingress gateway traffic this trafficPolicy should // apply to. Multiple policies from different sources defining // different policies (eg retries, timeouts) will be merged. // If a conflicting policy value is defined in both a TrafficPolicy // resource (or multiple TrafficPolicy resources) and in-line on a VirtualHost, // or Route - then the in-line values will take precedence. If multiple // TrafficPolicies select the same VirtualHost, RouteTable, or Route, then the older // TrafficPolicy (by CreationTime) takes precedence over any newer Traffic policy. // Omit to apply to all VirtualHosts and all of their routes. RouteSelector []*TrafficPolicySpec_RouteSelector `protobuf:"bytes,5,rep,name=route_selector,json=routeSelector,proto3" json:"route_selector,omitempty"` // Specify criteria that HTTP requests must satisfy for the TrafficPolicy to apply. // Conditions defined within a single matcher are conjunctive, i.e. all conditions must be satisfied for a match to occur. // Conditions defined between different matchers are disjunctive, i.e. at least one matcher must be satisfied for the TrafficPolicy to apply. // Omit to apply to any HTTP request. HttpRequestMatchers []*HttpMatcher `protobuf:"bytes,3,rep,name=http_request_matchers,json=httpRequestMatchers,proto3" json:"http_request_matchers,omitempty"` // Specify L7 routing and post-routing configuration. Policy *TrafficPolicySpec_Policy `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"` // contains filtered or unexported fields }
Applies L7 routing and post-routing configuration on selected network edges.
func (*TrafficPolicySpec) DeepCopyInto ¶
func (in *TrafficPolicySpec) DeepCopyInto(out *TrafficPolicySpec)
DeepCopyInto for the TrafficPolicy.Spec
func (*TrafficPolicySpec) Descriptor
deprecated
func (*TrafficPolicySpec) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec) Equal ¶
func (m *TrafficPolicySpec) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec) GetDestinationSelector ¶
func (x *TrafficPolicySpec) GetDestinationSelector() []*v1.DestinationSelector
func (*TrafficPolicySpec) GetHttpRequestMatchers ¶
func (x *TrafficPolicySpec) GetHttpRequestMatchers() []*HttpMatcher
func (*TrafficPolicySpec) GetPolicy ¶
func (x *TrafficPolicySpec) GetPolicy() *TrafficPolicySpec_Policy
func (*TrafficPolicySpec) GetRouteSelector ¶ added in v1.1.0
func (x *TrafficPolicySpec) GetRouteSelector() []*TrafficPolicySpec_RouteSelector
func (*TrafficPolicySpec) GetSourceSelector ¶
func (x *TrafficPolicySpec) GetSourceSelector() []*v1.WorkloadSelector
func (*TrafficPolicySpec) MarshalJSON ¶
func (this *TrafficPolicySpec) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for TrafficPolicySpec
func (*TrafficPolicySpec) ProtoMessage ¶
func (*TrafficPolicySpec) ProtoMessage()
func (*TrafficPolicySpec) ProtoReflect ¶
func (x *TrafficPolicySpec) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec) Reset ¶
func (x *TrafficPolicySpec) Reset()
func (*TrafficPolicySpec) String ¶
func (x *TrafficPolicySpec) String() string
func (*TrafficPolicySpec) UnmarshalJSON ¶
func (this *TrafficPolicySpec) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for TrafficPolicySpec
type TrafficPolicySpec_Policy ¶
type TrafficPolicySpec_Policy struct { // Shift traffic to a different destination. TrafficShift *TrafficPolicySpec_Policy_MultiDestination `protobuf:"bytes,4,opt,name=traffic_shift,json=trafficShift,proto3" json:"traffic_shift,omitempty"` // Inject faulty responses. FaultInjection *TrafficPolicySpec_Policy_FaultInjection `protobuf:"bytes,5,opt,name=fault_injection,json=faultInjection,proto3" json:"fault_injection,omitempty"` // Set a timeout on requests. RequestTimeout *duration.Duration `protobuf:"bytes,6,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"` // Set a retry policy on requests. Retries *TrafficPolicySpec_Policy_RetryPolicy `protobuf:"bytes,7,opt,name=retries,proto3" json:"retries,omitempty"` // Set a Cross-Origin Resource Sharing policy (CORS) for requests. Refer to [this link](https://developer.mozilla.org/en-US/docs/Web/HTTP/Access_control_CORS) // for further details about cross origin resource sharing. CorsPolicy *TrafficPolicySpec_Policy_CorsPolicy `protobuf:"bytes,8,opt,name=cors_policy,json=corsPolicy,proto3" json:"cors_policy,omitempty"` // Mirror traffic to a another destination (traffic will be sent to its original destination in addition to the mirrored destinations). Mirror *TrafficPolicySpec_Policy_Mirror `protobuf:"bytes,9,opt,name=mirror,proto3" json:"mirror,omitempty"` // Manipulate request and response headers. HeaderManipulation *HeaderManipulation `protobuf:"bytes,10,opt,name=header_manipulation,json=headerManipulation,proto3" json:"header_manipulation,omitempty"` // Configure [outlier detection](https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/upstream/outlier) on the selected destinations. // Specifying this field requires an empty `source_selector` because it must apply to all traffic. OutlierDetection *TrafficPolicySpec_Policy_OutlierDetection `protobuf:"bytes,11,opt,name=outlier_detection,json=outlierDetection,proto3" json:"outlier_detection,omitempty"` // Configure mTLS settings. If specified will override global default defined in Settings. Mtls *TrafficPolicySpec_Policy_MTLS `protobuf:"bytes,12,opt,name=mtls,proto3" json:"mtls,omitempty"` // Configure the Envoy based CSRF filter Csrf *csrf.CsrfPolicy `protobuf:"bytes,13,opt,name=csrf,proto3" json:"csrf,omitempty"` // Configure the Envoy based Ratelimit filter RateLimit *ratelimit.RouteRateLimit `protobuf:"bytes,14,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"` // Configure the Envoy based Extauth filter Extauth *extauth.RouteExtauth `protobuf:"bytes,15,opt,name=extauth,proto3" json:"extauth,omitempty"` // contains filtered or unexported fields }
Specify L7 routing and post-routing configuration.
func (*TrafficPolicySpec_Policy) Descriptor
deprecated
func (*TrafficPolicySpec_Policy) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy) Equal ¶
func (m *TrafficPolicySpec_Policy) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy) GetCorsPolicy ¶
func (x *TrafficPolicySpec_Policy) GetCorsPolicy() *TrafficPolicySpec_Policy_CorsPolicy
func (*TrafficPolicySpec_Policy) GetCsrf ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy) GetCsrf() *csrf.CsrfPolicy
func (*TrafficPolicySpec_Policy) GetExtauth ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy) GetExtauth() *extauth.RouteExtauth
func (*TrafficPolicySpec_Policy) GetFaultInjection ¶
func (x *TrafficPolicySpec_Policy) GetFaultInjection() *TrafficPolicySpec_Policy_FaultInjection
func (*TrafficPolicySpec_Policy) GetHeaderManipulation ¶
func (x *TrafficPolicySpec_Policy) GetHeaderManipulation() *HeaderManipulation
func (*TrafficPolicySpec_Policy) GetMirror ¶
func (x *TrafficPolicySpec_Policy) GetMirror() *TrafficPolicySpec_Policy_Mirror
func (*TrafficPolicySpec_Policy) GetMtls ¶
func (x *TrafficPolicySpec_Policy) GetMtls() *TrafficPolicySpec_Policy_MTLS
func (*TrafficPolicySpec_Policy) GetOutlierDetection ¶
func (x *TrafficPolicySpec_Policy) GetOutlierDetection() *TrafficPolicySpec_Policy_OutlierDetection
func (*TrafficPolicySpec_Policy) GetRateLimit ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy) GetRateLimit() *ratelimit.RouteRateLimit
func (*TrafficPolicySpec_Policy) GetRequestTimeout ¶
func (x *TrafficPolicySpec_Policy) GetRequestTimeout() *duration.Duration
func (*TrafficPolicySpec_Policy) GetRetries ¶
func (x *TrafficPolicySpec_Policy) GetRetries() *TrafficPolicySpec_Policy_RetryPolicy
func (*TrafficPolicySpec_Policy) GetTrafficShift ¶
func (x *TrafficPolicySpec_Policy) GetTrafficShift() *TrafficPolicySpec_Policy_MultiDestination
func (*TrafficPolicySpec_Policy) ProtoMessage ¶
func (*TrafficPolicySpec_Policy) ProtoMessage()
func (*TrafficPolicySpec_Policy) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy) Reset ¶
func (x *TrafficPolicySpec_Policy) Reset()
func (*TrafficPolicySpec_Policy) String ¶
func (x *TrafficPolicySpec_Policy) String() string
type TrafficPolicySpec_Policy_CorsPolicy ¶
type TrafficPolicySpec_Policy_CorsPolicy struct { // String patterns that match allowed origins. An origin is allowed if any of the string matchers match. AllowOrigins []*v1.StringMatch `protobuf:"bytes,7,rep,name=allow_origins,json=allowOrigins,proto3" json:"allow_origins,omitempty"` // List of HTTP methods allowed to access the resource. The content will // be serialized to the `Access-Control-Allow-Methods` header. AllowMethods []string `protobuf:"bytes,2,rep,name=allow_methods,json=allowMethods,proto3" json:"allow_methods,omitempty"` // List of HTTP headers that can be used when requesting the // resource. Serialized to the `Access-Control-Allow-Headers` header. AllowHeaders []string `protobuf:"bytes,3,rep,name=allow_headers,json=allowHeaders,proto3" json:"allow_headers,omitempty"` // A list of HTTP headers that browsers are allowed to // access. Serialized to the `Access-Control-Expose-Headers` header. ExposeHeaders []string `protobuf:"bytes,4,rep,name=expose_headers,json=exposeHeaders,proto3" json:"expose_headers,omitempty"` // Specify how long the results of a preflight request can be // cached. Serialized to the `Access-Control-Max-Age` header. MaxAge *duration.Duration `protobuf:"bytes,5,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"` // Indicates whether the caller is allowed to send the actual request // (not the preflight) using credentials. Translates to the // `Access-Control-Allow-Credentials` header. AllowCredentials *wrappers.BoolValue `protobuf:"bytes,6,opt,name=allow_credentials,json=allowCredentials,proto3" json:"allow_credentials,omitempty"` // contains filtered or unexported fields }
Specify Cross-Origin Resource Sharing policy (CORS) for requests. Refer to [this link](https://developer.mozilla.org/en-US/docs/Web/HTTP/Access_control_CORS) for further details about cross origin resource sharing.
func (*TrafficPolicySpec_Policy_CorsPolicy) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_CorsPolicy) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_CorsPolicy.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_CorsPolicy) Equal ¶
func (m *TrafficPolicySpec_Policy_CorsPolicy) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_CorsPolicy) GetAllowCredentials ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowCredentials() *wrappers.BoolValue
func (*TrafficPolicySpec_Policy_CorsPolicy) GetAllowHeaders ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowHeaders() []string
func (*TrafficPolicySpec_Policy_CorsPolicy) GetAllowMethods ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowMethods() []string
func (*TrafficPolicySpec_Policy_CorsPolicy) GetAllowOrigins ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) GetAllowOrigins() []*v1.StringMatch
func (*TrafficPolicySpec_Policy_CorsPolicy) GetExposeHeaders ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) GetExposeHeaders() []string
func (*TrafficPolicySpec_Policy_CorsPolicy) GetMaxAge ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) GetMaxAge() *duration.Duration
func (*TrafficPolicySpec_Policy_CorsPolicy) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_CorsPolicy) ProtoMessage()
func (*TrafficPolicySpec_Policy_CorsPolicy) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_CorsPolicy) Reset ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) Reset()
func (*TrafficPolicySpec_Policy_CorsPolicy) String ¶
func (x *TrafficPolicySpec_Policy_CorsPolicy) String() string
type TrafficPolicySpec_Policy_DLPPolicy ¶ added in v1.1.0
type TrafficPolicySpec_Policy_DLPPolicy struct { // TODO: implement Todo string `protobuf:"bytes,1,opt,name=todo,proto3" json:"todo,omitempty"` // contains filtered or unexported fields }
DLP filter config.
func (*TrafficPolicySpec_Policy_DLPPolicy) Descriptor
deprecated
added in
v1.1.0
func (*TrafficPolicySpec_Policy_DLPPolicy) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_DLPPolicy.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_DLPPolicy) Equal ¶ added in v1.1.0
func (m *TrafficPolicySpec_Policy_DLPPolicy) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_DLPPolicy) GetTodo ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_DLPPolicy) GetTodo() string
func (*TrafficPolicySpec_Policy_DLPPolicy) ProtoMessage ¶ added in v1.1.0
func (*TrafficPolicySpec_Policy_DLPPolicy) ProtoMessage()
func (*TrafficPolicySpec_Policy_DLPPolicy) ProtoReflect ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_DLPPolicy) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_DLPPolicy) Reset ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_DLPPolicy) Reset()
func (*TrafficPolicySpec_Policy_DLPPolicy) String ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_DLPPolicy) String() string
type TrafficPolicySpec_Policy_ExtAuth ¶ added in v1.1.0
type TrafficPolicySpec_Policy_ExtAuth struct { // TODO: implement Todo string `protobuf:"bytes,1,opt,name=todo,proto3" json:"todo,omitempty"` // contains filtered or unexported fields }
ExtAuth filter config.
func (*TrafficPolicySpec_Policy_ExtAuth) Descriptor
deprecated
added in
v1.1.0
func (*TrafficPolicySpec_Policy_ExtAuth) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_ExtAuth.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_ExtAuth) Equal ¶ added in v1.1.0
func (m *TrafficPolicySpec_Policy_ExtAuth) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_ExtAuth) GetTodo ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_ExtAuth) GetTodo() string
func (*TrafficPolicySpec_Policy_ExtAuth) ProtoMessage ¶ added in v1.1.0
func (*TrafficPolicySpec_Policy_ExtAuth) ProtoMessage()
func (*TrafficPolicySpec_Policy_ExtAuth) ProtoReflect ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_ExtAuth) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_ExtAuth) Reset ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_ExtAuth) Reset()
func (*TrafficPolicySpec_Policy_ExtAuth) String ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_ExtAuth) String() string
type TrafficPolicySpec_Policy_FaultInjection ¶
type TrafficPolicySpec_Policy_FaultInjection struct { // Specify the type of fault to inject. // // Types that are assignable to FaultInjectionType: // *TrafficPolicySpec_Policy_FaultInjection_FixedDelay // *TrafficPolicySpec_Policy_FaultInjection_Abort_ FaultInjectionType isTrafficPolicySpec_Policy_FaultInjection_FaultInjectionType `protobuf_oneof:"fault_injection_type"` // Percentage of requests to be faulted. Values range between 0 and 100. If omitted all requests will be faulted. Percentage float64 `protobuf:"fixed64,4,opt,name=percentage,proto3" json:"percentage,omitempty"` // contains filtered or unexported fields }
Specify one or more faults to inject for the selected network edge.
func (*TrafficPolicySpec_Policy_FaultInjection) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_FaultInjection) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_FaultInjection.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_FaultInjection) Equal ¶
func (m *TrafficPolicySpec_Policy_FaultInjection) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_FaultInjection) GetAbort ¶
func (x *TrafficPolicySpec_Policy_FaultInjection) GetAbort() *TrafficPolicySpec_Policy_FaultInjection_Abort
func (*TrafficPolicySpec_Policy_FaultInjection) GetFaultInjectionType ¶
func (m *TrafficPolicySpec_Policy_FaultInjection) GetFaultInjectionType() isTrafficPolicySpec_Policy_FaultInjection_FaultInjectionType
func (*TrafficPolicySpec_Policy_FaultInjection) GetFixedDelay ¶
func (x *TrafficPolicySpec_Policy_FaultInjection) GetFixedDelay() *duration.Duration
func (*TrafficPolicySpec_Policy_FaultInjection) GetPercentage ¶
func (x *TrafficPolicySpec_Policy_FaultInjection) GetPercentage() float64
func (*TrafficPolicySpec_Policy_FaultInjection) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_FaultInjection) ProtoMessage()
func (*TrafficPolicySpec_Policy_FaultInjection) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_FaultInjection) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_FaultInjection) Reset ¶
func (x *TrafficPolicySpec_Policy_FaultInjection) Reset()
func (*TrafficPolicySpec_Policy_FaultInjection) String ¶
func (x *TrafficPolicySpec_Policy_FaultInjection) String() string
type TrafficPolicySpec_Policy_FaultInjection_Abort ¶
type TrafficPolicySpec_Policy_FaultInjection_Abort struct { // Required. HTTP status code to use to abort the request. HttpStatus int32 `protobuf:"varint,1,opt,name=http_status,json=httpStatus,proto3" json:"http_status,omitempty"` // contains filtered or unexported fields }
Abort the request and return the specified error code back to traffic source.
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_FaultInjection_Abort.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) Equal ¶
func (m *TrafficPolicySpec_Policy_FaultInjection_Abort) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) GetHttpStatus ¶
func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) GetHttpStatus() int32
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) ProtoMessage()
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) Reset ¶
func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) Reset()
func (*TrafficPolicySpec_Policy_FaultInjection_Abort) String ¶
func (x *TrafficPolicySpec_Policy_FaultInjection_Abort) String() string
type TrafficPolicySpec_Policy_FaultInjection_Abort_ ¶
type TrafficPolicySpec_Policy_FaultInjection_Abort_ struct { // Abort the request and return the specified error code back to traffic source. Abort *TrafficPolicySpec_Policy_FaultInjection_Abort `protobuf:"bytes,2,opt,name=abort,proto3,oneof"` }
type TrafficPolicySpec_Policy_MTLS ¶
type TrafficPolicySpec_Policy_MTLS struct { // Istio TLS settings. Istio *TrafficPolicySpec_Policy_MTLS_Istio `protobuf:"bytes,1,opt,name=istio,proto3" json:"istio,omitempty"` // contains filtered or unexported fields }
Configure mTLS settings on destinations. If specified this overrides the global default defined in Settings.
func (*TrafficPolicySpec_Policy_MTLS) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_MTLS) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_MTLS.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_MTLS) Equal ¶
func (m *TrafficPolicySpec_Policy_MTLS) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_MTLS) GetIstio ¶
func (x *TrafficPolicySpec_Policy_MTLS) GetIstio() *TrafficPolicySpec_Policy_MTLS_Istio
func (*TrafficPolicySpec_Policy_MTLS) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_MTLS) ProtoMessage()
func (*TrafficPolicySpec_Policy_MTLS) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_MTLS) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_MTLS) Reset ¶
func (x *TrafficPolicySpec_Policy_MTLS) Reset()
func (*TrafficPolicySpec_Policy_MTLS) String ¶
func (x *TrafficPolicySpec_Policy_MTLS) String() string
type TrafficPolicySpec_Policy_MTLS_Istio ¶
type TrafficPolicySpec_Policy_MTLS_Istio struct { // TLS connection mode TlsMode TrafficPolicySpec_Policy_MTLS_Istio_TLSmode `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
Istio TLS settings.
func (*TrafficPolicySpec_Policy_MTLS_Istio) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_MTLS_Istio) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_MTLS_Istio.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_MTLS_Istio) Equal ¶
func (m *TrafficPolicySpec_Policy_MTLS_Istio) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_MTLS_Istio) GetTlsMode ¶
func (x *TrafficPolicySpec_Policy_MTLS_Istio) GetTlsMode() TrafficPolicySpec_Policy_MTLS_Istio_TLSmode
func (*TrafficPolicySpec_Policy_MTLS_Istio) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_MTLS_Istio) ProtoMessage()
func (*TrafficPolicySpec_Policy_MTLS_Istio) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_MTLS_Istio) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_MTLS_Istio) Reset ¶
func (x *TrafficPolicySpec_Policy_MTLS_Istio) Reset()
func (*TrafficPolicySpec_Policy_MTLS_Istio) String ¶
func (x *TrafficPolicySpec_Policy_MTLS_Istio) String() string
type TrafficPolicySpec_Policy_MTLS_Istio_TLSmode ¶
type TrafficPolicySpec_Policy_MTLS_Istio_TLSmode int32
TLS connection mode. Enums correspond to those [defined here](https://github.com/istio/api/blob/00636152b9d9254b614828a65723840282a177d3/networking/v1beta1/destination_rule.proto#L886)
const ( // Do not originate a TLS connection to the upstream endpoint. TrafficPolicySpec_Policy_MTLS_Istio_DISABLE TrafficPolicySpec_Policy_MTLS_Istio_TLSmode = 0 // Originate a TLS connection to the upstream endpoint. TrafficPolicySpec_Policy_MTLS_Istio_SIMPLE TrafficPolicySpec_Policy_MTLS_Istio_TLSmode = 1 // Secure connections to the upstream using mutual TLS by presenting // client certificates for authentication. // This mode uses certificates generated // automatically by Istio for mTLS authentication. When this mode is // used, all other fields in `ClientTLSSettings` should be empty. TrafficPolicySpec_Policy_MTLS_Istio_ISTIO_MUTUAL TrafficPolicySpec_Policy_MTLS_Istio_TLSmode = 2 )
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Descriptor ¶
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Descriptor() protoreflect.EnumDescriptor
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) EnumDescriptor
deprecated
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_MTLS_Istio_TLSmode.Descriptor instead.
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Number ¶
func (x TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Number() protoreflect.EnumNumber
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) String ¶
func (x TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) String() string
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Type ¶
func (TrafficPolicySpec_Policy_MTLS_Istio_TLSmode) Type() protoreflect.EnumType
type TrafficPolicySpec_Policy_Mirror ¶
type TrafficPolicySpec_Policy_Mirror struct { // Platform specific mirror destinations. // // Types that are assignable to DestinationType: // *TrafficPolicySpec_Policy_Mirror_KubeService DestinationType isTrafficPolicySpec_Policy_Mirror_DestinationType `protobuf_oneof:"destination_type"` // Percentage of traffic to mirror. If omitted all traffic will be mirrored. Values must be between 0 and 100. Percentage float64 `protobuf:"fixed64,2,opt,name=percentage,proto3" json:"percentage,omitempty"` // Port on the destination to receive traffic. Required if the destination exposes multiple ports. Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
Mirror traffic to a another destination (traffic will be sent to its original destination in addition to the mirrored destinations).
func (*TrafficPolicySpec_Policy_Mirror) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_Mirror) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_Mirror.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_Mirror) Equal ¶
func (m *TrafficPolicySpec_Policy_Mirror) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_Mirror) GetDestinationType ¶
func (m *TrafficPolicySpec_Policy_Mirror) GetDestinationType() isTrafficPolicySpec_Policy_Mirror_DestinationType
func (*TrafficPolicySpec_Policy_Mirror) GetKubeService ¶
func (x *TrafficPolicySpec_Policy_Mirror) GetKubeService() *v11.ClusterObjectRef
func (*TrafficPolicySpec_Policy_Mirror) GetPercentage ¶
func (x *TrafficPolicySpec_Policy_Mirror) GetPercentage() float64
func (*TrafficPolicySpec_Policy_Mirror) GetPort ¶
func (x *TrafficPolicySpec_Policy_Mirror) GetPort() uint32
func (*TrafficPolicySpec_Policy_Mirror) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_Mirror) ProtoMessage()
func (*TrafficPolicySpec_Policy_Mirror) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_Mirror) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_Mirror) Reset ¶
func (x *TrafficPolicySpec_Policy_Mirror) Reset()
func (*TrafficPolicySpec_Policy_Mirror) String ¶
func (x *TrafficPolicySpec_Policy_Mirror) String() string
type TrafficPolicySpec_Policy_Mirror_KubeService ¶
type TrafficPolicySpec_Policy_Mirror_KubeService struct { // Reference (name, namespace, Gloo Mesh cluster) to a Kubernetes service. KubeService *v11.ClusterObjectRef `protobuf:"bytes,1,opt,name=kube_service,json=kubeService,proto3,oneof"` }
type TrafficPolicySpec_Policy_MultiDestination ¶
type TrafficPolicySpec_Policy_MultiDestination struct { // Specify weighted traffic shift destinations. Destinations []*WeightedDestination `protobuf:"bytes,1,rep,name=destinations,proto3" json:"destinations,omitempty"` // contains filtered or unexported fields }
Specify a traffic shift destination.
func (*TrafficPolicySpec_Policy_MultiDestination) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_MultiDestination) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_MultiDestination.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_MultiDestination) Equal ¶
func (m *TrafficPolicySpec_Policy_MultiDestination) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_MultiDestination) GetDestinations ¶
func (x *TrafficPolicySpec_Policy_MultiDestination) GetDestinations() []*WeightedDestination
func (*TrafficPolicySpec_Policy_MultiDestination) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_MultiDestination) ProtoMessage()
func (*TrafficPolicySpec_Policy_MultiDestination) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_MultiDestination) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_MultiDestination) Reset ¶
func (x *TrafficPolicySpec_Policy_MultiDestination) Reset()
func (*TrafficPolicySpec_Policy_MultiDestination) String ¶
func (x *TrafficPolicySpec_Policy_MultiDestination) String() string
type TrafficPolicySpec_Policy_OutlierDetection ¶
type TrafficPolicySpec_Policy_OutlierDetection struct { // The number of errors before a host is ejected from the connection pool. A default will be used if not set. ConsecutiveErrors uint32 `protobuf:"varint,1,opt,name=consecutive_errors,json=consecutiveErrors,proto3" json:"consecutive_errors,omitempty"` // The time interval between ejection sweep analysis. Format: `1h`/`1m`/`1s`/`1ms`. Must be >= `1ms`. A default will be used if not set. Interval *duration.Duration `protobuf:"bytes,2,opt,name=interval,proto3" json:"interval,omitempty"` // The minimum ejection duration. Format: `1h`/`1m`/`1s`/`1ms`. Must be >= `1ms`. A default will be used if not set. BaseEjectionTime *duration.Duration `protobuf:"bytes,3,opt,name=base_ejection_time,json=baseEjectionTime,proto3" json:"base_ejection_time,omitempty"` // The maximum percentage of hosts that can be ejected from the load balancing pool. // At least one host will be ejected regardless of the value. Must be between 0 and 100. A default will be used if not set. MaxEjectionPercent uint32 `protobuf:"varint,4,opt,name=max_ejection_percent,json=maxEjectionPercent,proto3" json:"max_ejection_percent,omitempty"` // contains filtered or unexported fields }
Configure [outlier detection](https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/upstream/outlier) on the selected destinations. Specifying this field requires an empty `source_selector` because it must apply to all traffic.
func (*TrafficPolicySpec_Policy_OutlierDetection) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_OutlierDetection) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_OutlierDetection.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_OutlierDetection) Equal ¶
func (m *TrafficPolicySpec_Policy_OutlierDetection) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_OutlierDetection) GetBaseEjectionTime ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) GetBaseEjectionTime() *duration.Duration
func (*TrafficPolicySpec_Policy_OutlierDetection) GetConsecutiveErrors ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) GetConsecutiveErrors() uint32
func (*TrafficPolicySpec_Policy_OutlierDetection) GetInterval ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) GetInterval() *duration.Duration
func (*TrafficPolicySpec_Policy_OutlierDetection) GetMaxEjectionPercent ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) GetMaxEjectionPercent() uint32
func (*TrafficPolicySpec_Policy_OutlierDetection) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_OutlierDetection) ProtoMessage()
func (*TrafficPolicySpec_Policy_OutlierDetection) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_OutlierDetection) Reset ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) Reset()
func (*TrafficPolicySpec_Policy_OutlierDetection) String ¶
func (x *TrafficPolicySpec_Policy_OutlierDetection) String() string
type TrafficPolicySpec_Policy_RetryPolicy ¶
type TrafficPolicySpec_Policy_RetryPolicy struct { // Number of retries for a given request Attempts int32 `protobuf:"varint,1,opt,name=attempts,proto3" json:"attempts,omitempty"` // Timeout per retry attempt for a given request. Format: `1h`/`1m`/`1s`/`1ms`. *Must be >= 1ms*. PerTryTimeout *duration.Duration `protobuf:"bytes,2,opt,name=per_try_timeout,json=perTryTimeout,proto3" json:"per_try_timeout,omitempty"` // contains filtered or unexported fields }
Specify retries for failed requests.
func (*TrafficPolicySpec_Policy_RetryPolicy) Descriptor
deprecated
func (*TrafficPolicySpec_Policy_RetryPolicy) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_RetryPolicy.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_RetryPolicy) Equal ¶
func (m *TrafficPolicySpec_Policy_RetryPolicy) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_RetryPolicy) GetAttempts ¶
func (x *TrafficPolicySpec_Policy_RetryPolicy) GetAttempts() int32
func (*TrafficPolicySpec_Policy_RetryPolicy) GetPerTryTimeout ¶
func (x *TrafficPolicySpec_Policy_RetryPolicy) GetPerTryTimeout() *duration.Duration
func (*TrafficPolicySpec_Policy_RetryPolicy) ProtoMessage ¶
func (*TrafficPolicySpec_Policy_RetryPolicy) ProtoMessage()
func (*TrafficPolicySpec_Policy_RetryPolicy) ProtoReflect ¶
func (x *TrafficPolicySpec_Policy_RetryPolicy) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_RetryPolicy) Reset ¶
func (x *TrafficPolicySpec_Policy_RetryPolicy) Reset()
func (*TrafficPolicySpec_Policy_RetryPolicy) String ¶
func (x *TrafficPolicySpec_Policy_RetryPolicy) String() string
type TrafficPolicySpec_Policy_Transform ¶ added in v1.1.0
type TrafficPolicySpec_Policy_Transform struct { // TODO: implement Todo string `protobuf:"bytes,1,opt,name=todo,proto3" json:"todo,omitempty"` // contains filtered or unexported fields }
Transform filter config.
func (*TrafficPolicySpec_Policy_Transform) Descriptor
deprecated
added in
v1.1.0
func (*TrafficPolicySpec_Policy_Transform) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_Policy_Transform.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_Policy_Transform) Equal ¶ added in v1.1.0
func (m *TrafficPolicySpec_Policy_Transform) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_Policy_Transform) GetTodo ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_Transform) GetTodo() string
func (*TrafficPolicySpec_Policy_Transform) ProtoMessage ¶ added in v1.1.0
func (*TrafficPolicySpec_Policy_Transform) ProtoMessage()
func (*TrafficPolicySpec_Policy_Transform) ProtoReflect ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_Transform) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_Policy_Transform) Reset ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_Transform) Reset()
func (*TrafficPolicySpec_Policy_Transform) String ¶ added in v1.1.0
func (x *TrafficPolicySpec_Policy_Transform) String() string
type TrafficPolicySpec_RouteSelector ¶ added in v1.1.0
type TrafficPolicySpec_RouteSelector struct { // Select VirtualHosts by reference. VirtualHostRefs []*v11.ObjectRef `protobuf:"bytes,1,rep,name=virtual_host_refs,json=virtualHostRefs,proto3" json:"virtual_host_refs,omitempty"` // Select VirtualHosts by label and/or namespace. VirtualHostSelector *v11.ObjectSelector `protobuf:"bytes,2,opt,name=virtual_host_selector,json=virtualHostSelector,proto3" json:"virtual_host_selector,omitempty"` // Select RouteTables by reference. RouteTableRefs []*v11.ObjectRef `protobuf:"bytes,3,rep,name=route_table_refs,json=routeTableRefs,proto3" json:"route_table_refs,omitempty"` // Select RouteTables by label and/or namespace. RouteTableSelector *v11.ObjectSelector `protobuf:"bytes,4,opt,name=route_table_selector,json=routeTableSelector,proto3" json:"route_table_selector,omitempty"` // Specify a set of labels for selecting Routes. All labels listed here must be // present on a route for that route to be considered matched. // If omitted, all routes on the selected VirtualHosts are selected. RouteLabelMatcher map[string]string `` /* 202-byte string literal not displayed */ // contains filtered or unexported fields }
Specify selected gateway traffic by specifying which gateway resources (virtualHosts or routeTables) to select. You can optionally further filter by using route labels to only select a subset of routes within those resources. If no virtualHost or routeTable selectors (or references) are explicitly set, all virtualHosts and routeTables will be selected by default. If no route label matcher is specified, all routes on the selected resources are matched.
func (*TrafficPolicySpec_RouteSelector) Descriptor
deprecated
added in
v1.1.0
func (*TrafficPolicySpec_RouteSelector) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicySpec_RouteSelector.ProtoReflect.Descriptor instead.
func (*TrafficPolicySpec_RouteSelector) Equal ¶ added in v1.1.0
func (m *TrafficPolicySpec_RouteSelector) Equal(that interface{}) bool
Equal function
func (*TrafficPolicySpec_RouteSelector) GetRouteLabelMatcher ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) GetRouteLabelMatcher() map[string]string
func (*TrafficPolicySpec_RouteSelector) GetRouteTableRefs ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) GetRouteTableRefs() []*v11.ObjectRef
func (*TrafficPolicySpec_RouteSelector) GetRouteTableSelector ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) GetRouteTableSelector() *v11.ObjectSelector
func (*TrafficPolicySpec_RouteSelector) GetVirtualHostRefs ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) GetVirtualHostRefs() []*v11.ObjectRef
func (*TrafficPolicySpec_RouteSelector) GetVirtualHostSelector ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) GetVirtualHostSelector() *v11.ObjectSelector
func (*TrafficPolicySpec_RouteSelector) ProtoMessage ¶ added in v1.1.0
func (*TrafficPolicySpec_RouteSelector) ProtoMessage()
func (*TrafficPolicySpec_RouteSelector) ProtoReflect ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) ProtoReflect() protoreflect.Message
func (*TrafficPolicySpec_RouteSelector) Reset ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) Reset()
func (*TrafficPolicySpec_RouteSelector) String ¶ added in v1.1.0
func (x *TrafficPolicySpec_RouteSelector) String() string
type TrafficPolicyStatus ¶
type TrafficPolicyStatus struct { // The most recent generation observed in the the TrafficPolicy metadata. // If the `observedGeneration` does not match `metadata.generation`, Gloo Mesh has not processed the most // recent version of this resource. ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"` // The state of the overall resource. // It will only show accepted if it has been successfully applied to all selected Destinations. State v1.ApprovalState `protobuf:"varint,2,opt,name=state,proto3,enum=common.mesh.gloo.solo.io.ApprovalState" json:"state,omitempty"` // The status of the TrafficPolicy for each selected Destination. // A TrafficPolicy may be Accepted for some Destinations and rejected for others. Destinations map[string]*ApprovalStatus `` /* 165-byte string literal not displayed */ // The list of selected Workloads for which this policy has been applied. Workloads []string `protobuf:"bytes,4,rep,name=workloads,proto3" json:"workloads,omitempty"` // Any errors found while processing this generation of the resource. Errors []string `protobuf:"bytes,5,rep,name=errors,proto3" json:"errors,omitempty"` // The Gateway resoures to which this traffic policy has been applied. // The resource names are in the format `name.namespace (resourceType)`, // which act as the keys in this map. GatewayRoutes map[string]*GatewayRoutes `` /* 188-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TrafficPolicyStatus) DeepCopyInto ¶
func (in *TrafficPolicyStatus) DeepCopyInto(out *TrafficPolicyStatus)
DeepCopyInto for the TrafficPolicy.Status
func (*TrafficPolicyStatus) Descriptor
deprecated
func (*TrafficPolicyStatus) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicyStatus.ProtoReflect.Descriptor instead.
func (*TrafficPolicyStatus) Equal ¶
func (m *TrafficPolicyStatus) Equal(that interface{}) bool
Equal function
func (*TrafficPolicyStatus) GetDestinations ¶
func (x *TrafficPolicyStatus) GetDestinations() map[string]*ApprovalStatus
func (*TrafficPolicyStatus) GetErrors ¶
func (x *TrafficPolicyStatus) GetErrors() []string
func (*TrafficPolicyStatus) GetGatewayRoutes ¶ added in v1.1.0
func (x *TrafficPolicyStatus) GetGatewayRoutes() map[string]*GatewayRoutes
func (*TrafficPolicyStatus) GetObservedGeneration ¶
func (x *TrafficPolicyStatus) GetObservedGeneration() int64
func (*TrafficPolicyStatus) GetState ¶
func (x *TrafficPolicyStatus) GetState() v1.ApprovalState
func (*TrafficPolicyStatus) GetWorkloads ¶
func (x *TrafficPolicyStatus) GetWorkloads() []string
func (*TrafficPolicyStatus) MarshalJSON ¶
func (this *TrafficPolicyStatus) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for TrafficPolicyStatus
func (*TrafficPolicyStatus) ProtoMessage ¶
func (*TrafficPolicyStatus) ProtoMessage()
func (*TrafficPolicyStatus) ProtoReflect ¶
func (x *TrafficPolicyStatus) ProtoReflect() protoreflect.Message
func (*TrafficPolicyStatus) Reset ¶
func (x *TrafficPolicyStatus) Reset()
func (*TrafficPolicyStatus) String ¶
func (x *TrafficPolicyStatus) String() string
func (*TrafficPolicyStatus) UnmarshalJSON ¶
func (this *TrafficPolicyStatus) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for TrafficPolicyStatus
type TrafficPolicyStatusWriter ¶
type TrafficPolicyStatusWriter interface { // Update updates the fields corresponding to the status subresource for the // given TrafficPolicy object. UpdateTrafficPolicyStatus(ctx context.Context, obj *TrafficPolicy, opts ...client.UpdateOption) error // Patch patches the given TrafficPolicy object's subresource. PatchTrafficPolicyStatus(ctx context.Context, obj *TrafficPolicy, patch client.Patch, opts ...client.PatchOption) error }
StatusWriter knows how to update status subresource of a TrafficPolicy object.
type TrafficPolicyTransitionFunction ¶
type TrafficPolicyTransitionFunction func(existing, desired *TrafficPolicy) error
TrafficPolicyTransitionFunction instructs the TrafficPolicyWriter how to transition between an existing TrafficPolicy object and a desired on an Upsert
type TrafficPolicyWriter ¶
type TrafficPolicyWriter interface { // Create saves the TrafficPolicy object. CreateTrafficPolicy(ctx context.Context, obj *TrafficPolicy, opts ...client.CreateOption) error // Delete deletes the TrafficPolicy object. DeleteTrafficPolicy(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error // Update updates the given TrafficPolicy object. UpdateTrafficPolicy(ctx context.Context, obj *TrafficPolicy, opts ...client.UpdateOption) error // Patch patches the given TrafficPolicy object. PatchTrafficPolicy(ctx context.Context, obj *TrafficPolicy, patch client.Patch, opts ...client.PatchOption) error // DeleteAllOf deletes all TrafficPolicy objects matching the given options. DeleteAllOfTrafficPolicy(ctx context.Context, opts ...client.DeleteAllOfOption) error // Create or Update the TrafficPolicy object. UpsertTrafficPolicy(ctx context.Context, obj *TrafficPolicy, transitionFuncs ...TrafficPolicyTransitionFunction) error }
Writer knows how to create, delete, and update TrafficPolicys.
type VirtualMesh ¶
type VirtualMesh struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec VirtualMeshSpec `json:"spec,omitempty"` Status VirtualMeshStatus `json:"status,omitempty"` }
VirtualMesh is the Schema for the virtualMesh API
func (*VirtualMesh) DeepCopy ¶
func (in *VirtualMesh) DeepCopy() *VirtualMesh
func (*VirtualMesh) DeepCopyInto ¶
func (in *VirtualMesh) DeepCopyInto(out *VirtualMesh)
func (*VirtualMesh) DeepCopyObject ¶
func (in *VirtualMesh) DeepCopyObject() runtime.Object
func (VirtualMesh) GVK ¶
func (VirtualMesh) GVK() schema.GroupVersionKind
GVK returns the GroupVersionKind associated with the resource type.
type VirtualMeshClient ¶
type VirtualMeshClient interface { VirtualMeshReader VirtualMeshWriter VirtualMeshStatusWriter }
Client knows how to perform CRUD operations on VirtualMeshs.
type VirtualMeshList ¶
type VirtualMeshList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []VirtualMesh `json:"items"` }
VirtualMeshList contains a list of VirtualMesh
func (*VirtualMeshList) DeepCopy ¶
func (in *VirtualMeshList) DeepCopy() *VirtualMeshList
func (*VirtualMeshList) DeepCopyInto ¶
func (in *VirtualMeshList) DeepCopyInto(out *VirtualMeshList)
func (*VirtualMeshList) DeepCopyObject ¶
func (in *VirtualMeshList) DeepCopyObject() runtime.Object
type VirtualMeshReader ¶
type VirtualMeshReader interface { // Get retrieves a VirtualMesh for the given object key GetVirtualMesh(ctx context.Context, key client.ObjectKey) (*VirtualMesh, error) // List retrieves list of VirtualMeshs for a given namespace and list options. ListVirtualMesh(ctx context.Context, opts ...client.ListOption) (*VirtualMeshList, error) }
Reader knows how to read and list VirtualMeshs.
type VirtualMeshSlice ¶
type VirtualMeshSlice []*VirtualMesh
VirtualMeshSlice represents a slice of *VirtualMesh
type VirtualMeshSpec ¶
type VirtualMeshSpec struct { // Specify the Meshes configured by this VirtualMesh. Meshes []*v1.ObjectRef `protobuf:"bytes,1,rep,name=meshes,proto3" json:"meshes,omitempty"` // Specify mTLS options. MtlsConfig *VirtualMeshSpec_MTLSConfig `protobuf:"bytes,2,opt,name=mtls_config,json=mtlsConfig,proto3" json:"mtls_config,omitempty"` // Specify how to federate Destinations across service mesh boundaries. Federation *VirtualMeshSpec_Federation `protobuf:"bytes,3,opt,name=federation,proto3" json:"federation,omitempty"` // Specify a global access policy for all Workloads and Destinations associated with this VirtualMesh. GlobalAccessPolicy VirtualMeshSpec_GlobalAccessPolicy `` /* 187-byte string literal not displayed */ // contains filtered or unexported fields }
Represents a logical grouping of Meshes for shared configuration and cross-mesh interoperability.
func (*VirtualMeshSpec) DeepCopyInto ¶
func (in *VirtualMeshSpec) DeepCopyInto(out *VirtualMeshSpec)
DeepCopyInto for the VirtualMesh.Spec
func (*VirtualMeshSpec) Descriptor
deprecated
func (*VirtualMeshSpec) Descriptor() ([]byte, []int)
Deprecated: Use VirtualMeshSpec.ProtoReflect.Descriptor instead.
func (*VirtualMeshSpec) Equal ¶
func (m *VirtualMeshSpec) Equal(that interface{}) bool
Equal function
func (*VirtualMeshSpec) GetFederation ¶
func (x *VirtualMeshSpec) GetFederation() *VirtualMeshSpec_Federation
func (*VirtualMeshSpec) GetGlobalAccessPolicy ¶
func (x *VirtualMeshSpec) GetGlobalAccessPolicy() VirtualMeshSpec_GlobalAccessPolicy
func (*VirtualMeshSpec) GetMeshes ¶
func (x *VirtualMeshSpec) GetMeshes() []*v1.ObjectRef
func (*VirtualMeshSpec) GetMtlsConfig ¶
func (x *VirtualMeshSpec) GetMtlsConfig() *VirtualMeshSpec_MTLSConfig
func (*VirtualMeshSpec) MarshalJSON ¶
func (this *VirtualMeshSpec) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for VirtualMeshSpec
func (*VirtualMeshSpec) ProtoMessage ¶
func (*VirtualMeshSpec) ProtoMessage()
func (*VirtualMeshSpec) ProtoReflect ¶
func (x *VirtualMeshSpec) ProtoReflect() protoreflect.Message
func (*VirtualMeshSpec) Reset ¶
func (x *VirtualMeshSpec) Reset()
func (*VirtualMeshSpec) String ¶
func (x *VirtualMeshSpec) String() string
func (*VirtualMeshSpec) UnmarshalJSON ¶
func (this *VirtualMeshSpec) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for VirtualMeshSpec
type VirtualMeshSpec_Federation ¶
type VirtualMeshSpec_Federation struct { // Selects the Destination(s) acting as ingress gateways for cross cluster traffic. // The supplied IngressGatewaySelectors will be used to select ingress gateways for all Meshes in this VirtualMesh. IngressGatewaySelectors []*v12.IngressGatewaySelector `` /* 132-byte string literal not displayed */ // Selectively federate Destinations to specific external meshes. // If omitted, no Destinations will be federated. Selectors []*VirtualMeshSpec_Federation_FederationSelector `protobuf:"bytes,4,rep,name=selectors,proto3" json:"selectors,omitempty"` // DEPRECATED: Use `selectors` instead. Omission of the `selectors` field has permissive semantics. // The "mode" in which to federate Destinations within this VirtualMesh. // // Types that are assignable to Mode: // *VirtualMeshSpec_Federation_Permissive Mode isVirtualMeshSpec_Federation_Mode `protobuf_oneof:"mode"` // If true, all multicluster traffic will be routed directly to the Kubernetes service endpoints of the Destinations, // rather than through an ingress gateway. This mode requires a flat network environment. // This feature is exclusive to Gloo Mesh Enterprise. FlatNetwork bool `protobuf:"varint,2,opt,name=flat_network,json=flatNetwork,proto3" json:"flat_network,omitempty"` // Configure the suffix for hostnames of Destinations federated within this VirtualMesh. // Currently this is only supported for Istio with [smart DNS proxying enabled](https://istio.io/latest/blog/2020/dns-proxy/), // otherwise setting this field results in an error. // If omitted, the hostname suffix defaults to "global". HostnameSuffix string `protobuf:"bytes,3,opt,name=hostname_suffix,json=hostnameSuffix,proto3" json:"hostname_suffix,omitempty"` // Specify a keepalive rule for all requests made within the VirtualMesh which cross clusters within that VirtualMesh, // as well as any requests to externalService type destinations. TcpKeepalive *v12.TCPKeepalive `protobuf:"bytes,5,opt,name=tcp_keepalive,json=tcpKeepalive,proto3" json:"tcp_keepalive,omitempty"` // contains filtered or unexported fields }
"Federation" refers to the ability to expose Destinations across service mesh boundaries, i.e. to traffic originating from Workloads external to the Destination's Mesh.
func (*VirtualMeshSpec_Federation) Descriptor
deprecated
func (*VirtualMeshSpec_Federation) Descriptor() ([]byte, []int)
Deprecated: Use VirtualMeshSpec_Federation.ProtoReflect.Descriptor instead.
func (*VirtualMeshSpec_Federation) Equal ¶
func (m *VirtualMeshSpec_Federation) Equal(that interface{}) bool
Equal function
func (*VirtualMeshSpec_Federation) GetFlatNetwork ¶
func (x *VirtualMeshSpec_Federation) GetFlatNetwork() bool
func (*VirtualMeshSpec_Federation) GetHostnameSuffix ¶
func (x *VirtualMeshSpec_Federation) GetHostnameSuffix() string
func (*VirtualMeshSpec_Federation) GetIngressGatewaySelectors ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation) GetIngressGatewaySelectors() []*v12.IngressGatewaySelector
func (*VirtualMeshSpec_Federation) GetMode ¶
func (m *VirtualMeshSpec_Federation) GetMode() isVirtualMeshSpec_Federation_Mode
func (*VirtualMeshSpec_Federation) GetPermissive ¶
func (x *VirtualMeshSpec_Federation) GetPermissive() *empty.Empty
func (*VirtualMeshSpec_Federation) GetSelectors ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation) GetSelectors() []*VirtualMeshSpec_Federation_FederationSelector
func (*VirtualMeshSpec_Federation) GetTcpKeepalive ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation) GetTcpKeepalive() *v12.TCPKeepalive
func (*VirtualMeshSpec_Federation) ProtoMessage ¶
func (*VirtualMeshSpec_Federation) ProtoMessage()
func (*VirtualMeshSpec_Federation) ProtoReflect ¶
func (x *VirtualMeshSpec_Federation) ProtoReflect() protoreflect.Message
func (*VirtualMeshSpec_Federation) Reset ¶
func (x *VirtualMeshSpec_Federation) Reset()
func (*VirtualMeshSpec_Federation) String ¶
func (x *VirtualMeshSpec_Federation) String() string
type VirtualMeshSpec_Federation_FederationSelector ¶ added in v1.1.0
type VirtualMeshSpec_Federation_FederationSelector struct { // The set of Destinations that will be federated to external Meshes. // If omitted, all Destinations will be selected. DestinationSelectors []*v12.DestinationSelector `protobuf:"bytes,1,rep,name=destination_selectors,json=destinationSelectors,proto3" json:"destination_selectors,omitempty"` // The Meshes to which the selected Destinations will be federated. All referenced Meshes must exist in this VirtualMesh. // If omitted, the selected Destinations will be federated to all Meshes in the VirtualMesh. Meshes []*v1.ObjectRef `protobuf:"bytes,2,rep,name=meshes,proto3" json:"meshes,omitempty"` // contains filtered or unexported fields }
Selects a set of Destinations to federate to the referenced Meshes.
func (*VirtualMeshSpec_Federation_FederationSelector) Descriptor
deprecated
added in
v1.1.0
func (*VirtualMeshSpec_Federation_FederationSelector) Descriptor() ([]byte, []int)
Deprecated: Use VirtualMeshSpec_Federation_FederationSelector.ProtoReflect.Descriptor instead.
func (*VirtualMeshSpec_Federation_FederationSelector) Equal ¶ added in v1.1.0
func (m *VirtualMeshSpec_Federation_FederationSelector) Equal(that interface{}) bool
Equal function
func (*VirtualMeshSpec_Federation_FederationSelector) GetDestinationSelectors ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation_FederationSelector) GetDestinationSelectors() []*v12.DestinationSelector
func (*VirtualMeshSpec_Federation_FederationSelector) GetMeshes ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation_FederationSelector) GetMeshes() []*v1.ObjectRef
func (*VirtualMeshSpec_Federation_FederationSelector) ProtoMessage ¶ added in v1.1.0
func (*VirtualMeshSpec_Federation_FederationSelector) ProtoMessage()
func (*VirtualMeshSpec_Federation_FederationSelector) ProtoReflect ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation_FederationSelector) ProtoReflect() protoreflect.Message
func (*VirtualMeshSpec_Federation_FederationSelector) Reset ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation_FederationSelector) Reset()
func (*VirtualMeshSpec_Federation_FederationSelector) String ¶ added in v1.1.0
func (x *VirtualMeshSpec_Federation_FederationSelector) String() string
type VirtualMeshSpec_GlobalAccessPolicy ¶
type VirtualMeshSpec_GlobalAccessPolicy int32
Specify a global access policy for all Workloads and Destinations associated with this VirtualMesh.
const ( // Assume the default for the service mesh type. Istio defaults to `false`, App Mesh defaults to `true`. VirtualMeshSpec_MESH_DEFAULT VirtualMeshSpec_GlobalAccessPolicy = 0 // Disallow traffic to all Destinations in the VirtualMesh unless explicitly allowed through [AccessPolicies]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.access_policy/" >}}). VirtualMeshSpec_ENABLED VirtualMeshSpec_GlobalAccessPolicy = 1 // Allow traffic to all Destinations in the VirtualMesh unless explicitly disallowed through [AccessPolicies]({{< versioned_link_path fromRoot="/reference/api/github.com.solo-io.gloo-mesh.api.networking.v1.access_policy/" >}}). VirtualMeshSpec_DISABLED VirtualMeshSpec_GlobalAccessPolicy = 2 )
func (VirtualMeshSpec_GlobalAccessPolicy) Descriptor ¶
func (VirtualMeshSpec_GlobalAccessPolicy) Descriptor() protoreflect.EnumDescriptor
func (VirtualMeshSpec_GlobalAccessPolicy) Enum ¶
func (x VirtualMeshSpec_GlobalAccessPolicy) Enum() *VirtualMeshSpec_GlobalAccessPolicy
func (VirtualMeshSpec_GlobalAccessPolicy) EnumDescriptor
deprecated
func (VirtualMeshSpec_GlobalAccessPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use VirtualMeshSpec_GlobalAccessPolicy.Descriptor instead.
func (VirtualMeshSpec_GlobalAccessPolicy) Number ¶
func (x VirtualMeshSpec_GlobalAccessPolicy) Number() protoreflect.EnumNumber
func (VirtualMeshSpec_GlobalAccessPolicy) String ¶
func (x VirtualMeshSpec_GlobalAccessPolicy) String() string
func (VirtualMeshSpec_GlobalAccessPolicy) Type ¶
func (VirtualMeshSpec_GlobalAccessPolicy) Type() protoreflect.EnumType
type VirtualMeshSpec_MTLSConfig ¶
type VirtualMeshSpec_MTLSConfig struct { // Specify the model for establishing mTLS trust between Meshes. // // Types that are assignable to TrustModel: // *VirtualMeshSpec_MTLSConfig_Shared // *VirtualMeshSpec_MTLSConfig_Limited TrustModel isVirtualMeshSpec_MTLSConfig_TrustModel `protobuf_oneof:"trust_model"` // NOTE: THIS IS NOT A RECOMMENDED SETTING FOR PRODUCTION! // Specify whether to allow Gloo Mesh to restart Kubernetes Pods when certificates are rotated when establishing shared trust. // This will auto-restart ALL of the workloads in your mesh. It is a convenience feature while testing Gloo Mesh. // If this option is not explicitly enabled, // users must restart Pods manually for the new certificates to be picked up. // `meshctl` provides the command `meshctl mesh restart` to simplify this process, see [here]({{< versioned_link_path fromRoot="reference/cli/meshctl_mesh_restart/" >}}) for more info. AutoRestartPods bool `protobuf:"varint,3,opt,name=auto_restart_pods,json=autoRestartPods,proto3" json:"auto_restart_pods,omitempty"` // Type of rotation verification to use when rotating root certificates. RotationVerificationMethod *v11.CertificateRotationVerificationMethod `` /* 141-byte string literal not displayed */ // Type of rotation to use. RotationStrategy v11.CertificateRotationStrategy `` /* 174-byte string literal not displayed */ // contains filtered or unexported fields }
Specify mTLS options. This includes options for configuring Mutual TLS within an individual Mesh, as well as enabling mTLS across Meshes by establishing cross-mesh trust.
func (*VirtualMeshSpec_MTLSConfig) Descriptor
deprecated
func (*VirtualMeshSpec_MTLSConfig) Descriptor() ([]byte, []int)
Deprecated: Use VirtualMeshSpec_MTLSConfig.ProtoReflect.Descriptor instead.
func (*VirtualMeshSpec_MTLSConfig) Equal ¶
func (m *VirtualMeshSpec_MTLSConfig) Equal(that interface{}) bool
Equal function
func (*VirtualMeshSpec_MTLSConfig) GetAutoRestartPods ¶
func (x *VirtualMeshSpec_MTLSConfig) GetAutoRestartPods() bool
func (*VirtualMeshSpec_MTLSConfig) GetLimited ¶
func (x *VirtualMeshSpec_MTLSConfig) GetLimited() *VirtualMeshSpec_MTLSConfig_LimitedTrust
func (*VirtualMeshSpec_MTLSConfig) GetRotationStrategy ¶ added in v1.1.0
func (x *VirtualMeshSpec_MTLSConfig) GetRotationStrategy() v11.CertificateRotationStrategy
func (*VirtualMeshSpec_MTLSConfig) GetRotationVerificationMethod ¶ added in v1.1.0
func (x *VirtualMeshSpec_MTLSConfig) GetRotationVerificationMethod() *v11.CertificateRotationVerificationMethod
func (*VirtualMeshSpec_MTLSConfig) GetShared ¶
func (x *VirtualMeshSpec_MTLSConfig) GetShared() *SharedTrust
func (*VirtualMeshSpec_MTLSConfig) GetTrustModel ¶
func (m *VirtualMeshSpec_MTLSConfig) GetTrustModel() isVirtualMeshSpec_MTLSConfig_TrustModel
func (*VirtualMeshSpec_MTLSConfig) ProtoMessage ¶
func (*VirtualMeshSpec_MTLSConfig) ProtoMessage()
func (*VirtualMeshSpec_MTLSConfig) ProtoReflect ¶
func (x *VirtualMeshSpec_MTLSConfig) ProtoReflect() protoreflect.Message
func (*VirtualMeshSpec_MTLSConfig) Reset ¶
func (x *VirtualMeshSpec_MTLSConfig) Reset()
func (*VirtualMeshSpec_MTLSConfig) String ¶
func (x *VirtualMeshSpec_MTLSConfig) String() string
type VirtualMeshSpec_MTLSConfig_Limited ¶
type VirtualMeshSpec_MTLSConfig_Limited struct { // Limited trust (selectively allow communication between Workloads and Destinations in the grouped Meshes). *Currently not available.* Limited *VirtualMeshSpec_MTLSConfig_LimitedTrust `protobuf:"bytes,2,opt,name=limited,proto3,oneof"` }
type VirtualMeshSpec_MTLSConfig_LimitedTrust ¶
type VirtualMeshSpec_MTLSConfig_LimitedTrust struct {
// contains filtered or unexported fields
}
Limited trust is a trust model which does not require trusting Meshes to share the same root certificate or identity. Instead, trust is established between different Meshes by connecting their ingress/egress gateways with a common certificate/identity. In this model all requests between different have the following request path when communicating between clusters ```
cluster 1 MTLS shared MTLS cluster 2 MTLS
client/workload <-----------> egress gateway <----------> ingress gateway <--------------> server ``` This approach has the downside of not maintaining identity from client to server, but allows for ad-hoc addition of additional Meshes into a VirtualMesh.
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) Descriptor
deprecated
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) Descriptor() ([]byte, []int)
Deprecated: Use VirtualMeshSpec_MTLSConfig_LimitedTrust.ProtoReflect.Descriptor instead.
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) Equal ¶
func (m *VirtualMeshSpec_MTLSConfig_LimitedTrust) Equal(that interface{}) bool
Equal function
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) ProtoMessage ¶
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) ProtoMessage()
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) ProtoReflect ¶
func (x *VirtualMeshSpec_MTLSConfig_LimitedTrust) ProtoReflect() protoreflect.Message
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) Reset ¶
func (x *VirtualMeshSpec_MTLSConfig_LimitedTrust) Reset()
func (*VirtualMeshSpec_MTLSConfig_LimitedTrust) String ¶
func (x *VirtualMeshSpec_MTLSConfig_LimitedTrust) String() string
type VirtualMeshSpec_MTLSConfig_Shared ¶
type VirtualMeshSpec_MTLSConfig_Shared struct { SharedTrust `protobuf:"bytes,1,opt,name=shared,proto3,oneof"` }Shared *
type VirtualMeshStatus ¶
type VirtualMeshStatus struct { // The most recent generation observed in the the VirtualMesh metadata. // If the `observedGeneration` does not match `metadata.generation`, Gloo Mesh has not processed the most // recent version of this resource. ObservedGeneration int64 `protobuf:"varint,1,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"` // The state of the overall resource. It will only show accepted if it has been successfully // applied to all selected Meshes. State v12.ApprovalState `protobuf:"varint,2,opt,name=state,proto3,enum=common.mesh.gloo.solo.io.ApprovalState" json:"state,omitempty"` // Any errors found while processing this generation of the resource. Errors []string `protobuf:"bytes,3,rep,name=errors,proto3" json:"errors,omitempty"` // The status of the VirtualMesh for each Mesh to which it has been applied. // A VirtualMesh may be Accepted for some Meshes and rejected for others. Meshes map[string]*ApprovalStatus `` /* 153-byte string literal not displayed */ // The status of the VirtualMesh for each Destination to which it has been applied. // A VirtualMesh may be Accepted for some Destinations and rejected for others. Destinations map[string]*ApprovalStatus `` /* 165-byte string literal not displayed */ // List of rotation conditions which have been completed/carried out for this Virtual Mesh Conditions []*v11.CertificateRotationCondition `protobuf:"bytes,6,rep,name=conditions,proto3" json:"conditions,omitempty"` // is different from this, we need to start a new rotation. DeployedSharedTrust *SharedTrust `protobuf:"bytes,7,opt,name=deployed_shared_trust,json=deployedSharedTrust,proto3" json:"deployed_shared_trust,omitempty"` // contains filtered or unexported fields }
func (*VirtualMeshStatus) DeepCopyInto ¶
func (in *VirtualMeshStatus) DeepCopyInto(out *VirtualMeshStatus)
DeepCopyInto for the VirtualMesh.Status
func (*VirtualMeshStatus) Descriptor
deprecated
func (*VirtualMeshStatus) Descriptor() ([]byte, []int)
Deprecated: Use VirtualMeshStatus.ProtoReflect.Descriptor instead.
func (*VirtualMeshStatus) Equal ¶
func (m *VirtualMeshStatus) Equal(that interface{}) bool
Equal function
func (*VirtualMeshStatus) GetConditions ¶ added in v1.1.0
func (x *VirtualMeshStatus) GetConditions() []*v11.CertificateRotationCondition
func (*VirtualMeshStatus) GetDeployedSharedTrust ¶ added in v1.1.0
func (x *VirtualMeshStatus) GetDeployedSharedTrust() *SharedTrust
func (*VirtualMeshStatus) GetDestinations ¶ added in v1.0.4
func (x *VirtualMeshStatus) GetDestinations() map[string]*ApprovalStatus
func (*VirtualMeshStatus) GetErrors ¶
func (x *VirtualMeshStatus) GetErrors() []string
func (*VirtualMeshStatus) GetMeshes ¶
func (x *VirtualMeshStatus) GetMeshes() map[string]*ApprovalStatus
func (*VirtualMeshStatus) GetObservedGeneration ¶
func (x *VirtualMeshStatus) GetObservedGeneration() int64
func (*VirtualMeshStatus) GetState ¶
func (x *VirtualMeshStatus) GetState() v12.ApprovalState
func (*VirtualMeshStatus) MarshalJSON ¶
func (this *VirtualMeshStatus) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for VirtualMeshStatus
func (*VirtualMeshStatus) ProtoMessage ¶
func (*VirtualMeshStatus) ProtoMessage()
func (*VirtualMeshStatus) ProtoReflect ¶
func (x *VirtualMeshStatus) ProtoReflect() protoreflect.Message
func (*VirtualMeshStatus) Reset ¶
func (x *VirtualMeshStatus) Reset()
func (*VirtualMeshStatus) String ¶
func (x *VirtualMeshStatus) String() string
func (*VirtualMeshStatus) UnmarshalJSON ¶
func (this *VirtualMeshStatus) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for VirtualMeshStatus
type VirtualMeshStatusWriter ¶
type VirtualMeshStatusWriter interface { // Update updates the fields corresponding to the status subresource for the // given VirtualMesh object. UpdateVirtualMeshStatus(ctx context.Context, obj *VirtualMesh, opts ...client.UpdateOption) error // Patch patches the given VirtualMesh object's subresource. PatchVirtualMeshStatus(ctx context.Context, obj *VirtualMesh, patch client.Patch, opts ...client.PatchOption) error }
StatusWriter knows how to update status subresource of a VirtualMesh object.
type VirtualMeshTransitionFunction ¶
type VirtualMeshTransitionFunction func(existing, desired *VirtualMesh) error
VirtualMeshTransitionFunction instructs the VirtualMeshWriter how to transition between an existing VirtualMesh object and a desired on an Upsert
type VirtualMeshWriter ¶
type VirtualMeshWriter interface { // Create saves the VirtualMesh object. CreateVirtualMesh(ctx context.Context, obj *VirtualMesh, opts ...client.CreateOption) error // Delete deletes the VirtualMesh object. DeleteVirtualMesh(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error // Update updates the given VirtualMesh object. UpdateVirtualMesh(ctx context.Context, obj *VirtualMesh, opts ...client.UpdateOption) error // Patch patches the given VirtualMesh object. PatchVirtualMesh(ctx context.Context, obj *VirtualMesh, patch client.Patch, opts ...client.PatchOption) error // DeleteAllOf deletes all VirtualMesh objects matching the given options. DeleteAllOfVirtualMesh(ctx context.Context, opts ...client.DeleteAllOfOption) error // Create or Update the VirtualMesh object. UpsertVirtualMesh(ctx context.Context, obj *VirtualMesh, transitionFuncs ...VirtualMeshTransitionFunction) error }
Writer knows how to create, delete, and update VirtualMeshs.
type WeightedDestination ¶ added in v1.1.0
type WeightedDestination struct { // Specify the proportion of traffic to be forwarded to this destination. // Weights across all of the `destinations` must sum to 100. Weight uint32 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"` // Platform specific destinations. // // Types that are assignable to DestinationType: // *WeightedDestination_KubeService // *WeightedDestination_VirtualDestination_ // *WeightedDestination_StaticDestination // *WeightedDestination_ClusterHeader DestinationType isWeightedDestination_DestinationType `protobuf_oneof:"destination_type"` // additional options / config for a route which will be applied // when this destination is selected. Options *WeightedDestination_DestinationOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
Specify a traffic shift or routing destination along with a weight. Weight is only relevant when supplying multiple destinations.
func (*WeightedDestination) Descriptor
deprecated
added in
v1.1.0
func (*WeightedDestination) Descriptor() ([]byte, []int)
Deprecated: Use WeightedDestination.ProtoReflect.Descriptor instead.
func (*WeightedDestination) Equal ¶ added in v1.1.0
func (m *WeightedDestination) Equal(that interface{}) bool
Equal function
func (*WeightedDestination) GetClusterHeader ¶ added in v1.1.0
func (x *WeightedDestination) GetClusterHeader() string
func (*WeightedDestination) GetDestinationType ¶ added in v1.1.0
func (m *WeightedDestination) GetDestinationType() isWeightedDestination_DestinationType
func (*WeightedDestination) GetKubeService ¶ added in v1.1.0
func (x *WeightedDestination) GetKubeService() *WeightedDestination_KubeDestination
func (*WeightedDestination) GetOptions ¶ added in v1.1.0
func (x *WeightedDestination) GetOptions() *WeightedDestination_DestinationOptions
func (*WeightedDestination) GetStaticDestination ¶ added in v1.1.0
func (x *WeightedDestination) GetStaticDestination() *v1.ObjectRef
func (*WeightedDestination) GetVirtualDestination ¶ added in v1.1.0
func (x *WeightedDestination) GetVirtualDestination() *WeightedDestination_VirtualDestination
func (*WeightedDestination) GetWeight ¶ added in v1.1.0
func (x *WeightedDestination) GetWeight() uint32
func (*WeightedDestination) ProtoMessage ¶ added in v1.1.0
func (*WeightedDestination) ProtoMessage()
func (*WeightedDestination) ProtoReflect ¶ added in v1.1.0
func (x *WeightedDestination) ProtoReflect() protoreflect.Message
func (*WeightedDestination) Reset ¶ added in v1.1.0
func (x *WeightedDestination) Reset()
func (*WeightedDestination) String ¶ added in v1.1.0
func (x *WeightedDestination) String() string
type WeightedDestination_ClusterHeader ¶ added in v1.1.0
type WeightedDestination_ClusterHeader struct { // Envoy will determine the cluster to route to by reading the value of the HTTP header named by cluster_header from the request headers. // If the header is not found or the referenced cluster does not exist, Envoy will return a 404 response. // Avoid using this whenever possible, it does not allow for custom filter configuration based on Virtual Host. // {{/* NOTE: unimplemented */}} ClusterHeader string `protobuf:"bytes,5,opt,name=cluster_header,json=clusterHeader,proto3,oneof"` }
type WeightedDestination_DestinationOptions ¶ added in v1.1.0
type WeightedDestination_DestinationOptions struct { // manipualte headers on traffic sent to this destination HeaderManipulation *HeaderManipulation `protobuf:"bytes,1,opt,name=header_manipulation,json=headerManipulation,proto3" json:"header_manipulation,omitempty"` // contains filtered or unexported fields }
Specify functionality which will be applied to traffic when this particular destination is selected for routing.
func (*WeightedDestination_DestinationOptions) Descriptor
deprecated
added in
v1.1.0
func (*WeightedDestination_DestinationOptions) Descriptor() ([]byte, []int)
Deprecated: Use WeightedDestination_DestinationOptions.ProtoReflect.Descriptor instead.
func (*WeightedDestination_DestinationOptions) Equal ¶ added in v1.1.0
func (m *WeightedDestination_DestinationOptions) Equal(that interface{}) bool
Equal function
func (*WeightedDestination_DestinationOptions) GetHeaderManipulation ¶ added in v1.1.0
func (x *WeightedDestination_DestinationOptions) GetHeaderManipulation() *HeaderManipulation
func (*WeightedDestination_DestinationOptions) ProtoMessage ¶ added in v1.1.0
func (*WeightedDestination_DestinationOptions) ProtoMessage()
func (*WeightedDestination_DestinationOptions) ProtoReflect ¶ added in v1.1.0
func (x *WeightedDestination_DestinationOptions) ProtoReflect() protoreflect.Message
func (*WeightedDestination_DestinationOptions) Reset ¶ added in v1.1.0
func (x *WeightedDestination_DestinationOptions) Reset()
func (*WeightedDestination_DestinationOptions) String ¶ added in v1.1.0
func (x *WeightedDestination_DestinationOptions) String() string
type WeightedDestination_KubeDestination ¶ added in v1.1.0
type WeightedDestination_KubeDestination struct { // The name of the service. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The namespace of the service. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // The Gloo Mesh cluster name (registration name) of the service. ClusterName string `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` // Specify, by labels, a subset of service instances to route to. Subset map[string]string `` /* 153-byte string literal not displayed */ // Port on the service to receive traffic. Required if the service exposes more than one port. Port uint32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
A Kubernetes destination.
func (*WeightedDestination_KubeDestination) Descriptor
deprecated
added in
v1.1.0
func (*WeightedDestination_KubeDestination) Descriptor() ([]byte, []int)
Deprecated: Use WeightedDestination_KubeDestination.ProtoReflect.Descriptor instead.
func (*WeightedDestination_KubeDestination) Equal ¶ added in v1.1.0
func (m *WeightedDestination_KubeDestination) Equal(that interface{}) bool
Equal function
func (*WeightedDestination_KubeDestination) GetClusterName ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) GetClusterName() string
func (*WeightedDestination_KubeDestination) GetName ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) GetName() string
func (*WeightedDestination_KubeDestination) GetNamespace ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) GetNamespace() string
func (*WeightedDestination_KubeDestination) GetPort ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) GetPort() uint32
func (*WeightedDestination_KubeDestination) GetSubset ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) GetSubset() map[string]string
func (*WeightedDestination_KubeDestination) ProtoMessage ¶ added in v1.1.0
func (*WeightedDestination_KubeDestination) ProtoMessage()
func (*WeightedDestination_KubeDestination) ProtoReflect ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) ProtoReflect() protoreflect.Message
func (*WeightedDestination_KubeDestination) Reset ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) Reset()
func (*WeightedDestination_KubeDestination) String ¶ added in v1.1.0
func (x *WeightedDestination_KubeDestination) String() string
type WeightedDestination_KubeService ¶ added in v1.1.0
type WeightedDestination_KubeService struct { // Specify a Kubernetes Service. KubeService *WeightedDestination_KubeDestination `protobuf:"bytes,2,opt,name=kube_service,json=kubeService,proto3,oneof"` }
type WeightedDestination_StaticDestination ¶ added in v1.1.0
type WeightedDestination_VirtualDestination ¶ added in v1.1.0
type WeightedDestination_VirtualDestination struct { // The name of the VirtualDestination object. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The namespace of the VirtualDestination object. Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // Specify, by labels, a subset of service instances backing the VirtualDestination to route to. Subset map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Specify a VirtualDestination traffic shift destination.
func (*WeightedDestination_VirtualDestination) Descriptor
deprecated
added in
v1.1.0
func (*WeightedDestination_VirtualDestination) Descriptor() ([]byte, []int)
Deprecated: Use WeightedDestination_VirtualDestination.ProtoReflect.Descriptor instead.
func (*WeightedDestination_VirtualDestination) Equal ¶ added in v1.1.0
func (m *WeightedDestination_VirtualDestination) Equal(that interface{}) bool
Equal function
func (*WeightedDestination_VirtualDestination) GetName ¶ added in v1.1.0
func (x *WeightedDestination_VirtualDestination) GetName() string
func (*WeightedDestination_VirtualDestination) GetNamespace ¶ added in v1.1.0
func (x *WeightedDestination_VirtualDestination) GetNamespace() string
func (*WeightedDestination_VirtualDestination) GetSubset ¶ added in v1.1.0
func (x *WeightedDestination_VirtualDestination) GetSubset() map[string]string
func (*WeightedDestination_VirtualDestination) ProtoMessage ¶ added in v1.1.0
func (*WeightedDestination_VirtualDestination) ProtoMessage()
func (*WeightedDestination_VirtualDestination) ProtoReflect ¶ added in v1.1.0
func (x *WeightedDestination_VirtualDestination) ProtoReflect() protoreflect.Message
func (*WeightedDestination_VirtualDestination) Reset ¶ added in v1.1.0
func (x *WeightedDestination_VirtualDestination) Reset()
func (*WeightedDestination_VirtualDestination) String ¶ added in v1.1.0
func (x *WeightedDestination_VirtualDestination) String() string
type WeightedDestination_VirtualDestination_ ¶ added in v1.1.0
type WeightedDestination_VirtualDestination_ struct { // Specify a VirtualDestination. // Virtual destinations get a new hostname that services reference and route to, // and then Gloo Mesh orchestrates locality-based load-balancing among the destinations. // This is helpful to setup, for example, cluster-agnostic routing and failover with // preference given to local services. VirtualDestination *WeightedDestination_VirtualDestination `protobuf:"bytes,3,opt,name=virtual_destination,json=virtualDestination,proto3,oneof"` }
Source Files
¶
- access_policy.pb.equal.go
- access_policy.pb.go
- applied_policies.pb.equal.go
- applied_policies.pb.go
- clients.go
- destination_policy.pb.equal.go
- destination_policy.pb.go
- doc.go
- json.gen.go
- proto_deepcopy.go
- rate_limit.pb.equal.go
- rate_limit.pb.go
- register.go
- request_matchers.pb.go
- status.pb.equal.go
- status.pb.go
- traffic_policy.pb.equal.go
- traffic_policy.pb.go
- type_helpers.go
- types.go
- virtual_mesh.pb.equal.go
- virtual_mesh.pb.go
- weighed_destination.pb.equal.go
- weighed_destination.pb.go
- zz_generated.deepcopy.go
Directories
¶
Path | Synopsis |
---|---|
Definitions for the Kubernetes Controllers Definitions for the multicluster Kubernetes Controllers Definitions for the Kubernetes Controllers
|
Definitions for the Kubernetes Controllers Definitions for the multicluster Kubernetes Controllers Definitions for the Kubernetes Controllers |
mocks
Package mock_controller is a generated GoMock package.
|
Package mock_controller is a generated GoMock package. |
Package mock_v1 is a generated GoMock package.
|
Package mock_v1 is a generated GoMock package. |
mocks
Package mock_v1sets is a generated GoMock package.
|
Package mock_v1sets is a generated GoMock package. |