v1alpha1

package
v0.0.0-...-2c1c132 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMetaprotocolApplicationProtocol        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetaprotocolApplicationProtocol          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetaprotocolApplicationProtocol = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	MetaprotocolApplicationProtocolMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	MetaprotocolApplicationProtocolUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source 
var (
	ErrInvalidLengthMetaprotocolMetarouter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetaprotocolMetarouter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetaprotocolMetarouter = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	MetaprotocolMetarouterMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	MetaprotocolMetarouterUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{AllowUnknownFields: true}
)

Functions

This section is empty.

Types

type ApplicationProtocol 

type ApplicationProtocol struct {
	Protocol             string   `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Codec                string   `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ApplicationProtocol defines an application protocol built on top of MetaProtocol.

<!-- crd generation tags +cue-gen:ApplicationProtocol:groupName:metaprotocol.aeraki.io +cue-gen:ApplicationProtocol:version:v1alpha1 +cue-gen:ApplicationProtocol:storageVersion +cue-gen:ApplicationProtocol:annotations:helm.sh/resource-policy=keep +cue-gen:ApplicationProtocol:labels:app=aeraki,chart=aeraki,heritage=Tiller,release=aeraki +cue-gen:ApplicationProtocol:subresource:status +cue-gen:ApplicationProtocol:scope:Cluster +cue-gen:ApplicationProtocol:resource:categories=aeraki-io,metaprotocol-aeraki-io +cue-gen:ApplicationProtocol:preserveUnknownFields:false -->

<!-- go code generation tags +kubetype-gen +kubetype-gen:groupVersion=metaprotocol.aeraki.io/v1alpha1 +genclient +k8s:deepcopy-gen=true -->

func (*ApplicationProtocol) DeepCopy 

func (in *ApplicationProtocol) DeepCopy() *ApplicationProtocol

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationProtocol. Required by controller-gen.

func (*ApplicationProtocol) DeepCopyInterface 

func (in *ApplicationProtocol) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ApplicationProtocol. Required by controller-gen.

func (*ApplicationProtocol) DeepCopyInto 

func (in *ApplicationProtocol) DeepCopyInto(out *ApplicationProtocol)

DeepCopyInto supports using ApplicationProtocol within kubernetes types, where deepcopy-gen is used.

func (*ApplicationProtocol) Descriptor 

func (*ApplicationProtocol) Descriptor() ([]byte, []int)

func (*ApplicationProtocol) GetCodec 

func (m *ApplicationProtocol) GetCodec() string

func (*ApplicationProtocol) GetProtocol 

func (m *ApplicationProtocol) GetProtocol() string

func (*ApplicationProtocol) Marshal 

func (m *ApplicationProtocol) Marshal() (dAtA []byte, err error)

func (*ApplicationProtocol) MarshalJSON 

func (this *ApplicationProtocol) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ApplicationProtocol

func (*ApplicationProtocol) MarshalTo 

func (m *ApplicationProtocol) MarshalTo(dAtA []byte) (int, error)

func (*ApplicationProtocol) MarshalToSizedBuffer 

func (m *ApplicationProtocol) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ApplicationProtocol) ProtoMessage 

func (*ApplicationProtocol) ProtoMessage()

func (*ApplicationProtocol) Reset 

func (m *ApplicationProtocol) Reset()

func (*ApplicationProtocol) Size 

func (m *ApplicationProtocol) Size() (n int)

func (*ApplicationProtocol) String 

func (m *ApplicationProtocol) String() string

func (*ApplicationProtocol) Unmarshal 

func (m *ApplicationProtocol) Unmarshal(dAtA []byte) error

func (*ApplicationProtocol) UnmarshalJSON 

func (this *ApplicationProtocol) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ApplicationProtocol

func (*ApplicationProtocol) XXX_DiscardUnknown 

func (m *ApplicationProtocol) XXX_DiscardUnknown()

func (*ApplicationProtocol) XXX_Marshal 

func (m *ApplicationProtocol) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationProtocol) XXX_Merge 

func (m *ApplicationProtocol) XXX_Merge(src proto.Message)

func (*ApplicationProtocol) XXX_Size 

func (m *ApplicationProtocol) XXX_Size() int

func (*ApplicationProtocol) XXX_Unmarshal 

func (m *ApplicationProtocol) XXX_Unmarshal(b []byte) error

type Destination 

type Destination struct {
	// The name of a service from the service registry. Service
	// names are looked up from the platform's service registry (e.g.,
	// Kubernetes services, Consul services, etc.) and from the hosts
	// declared by [ServiceEntry](https://istio.io/docs/reference/config/networking/service-entry/#ServiceEntry). Traffic
	// forwarded to destinations that are not found in either of the two, will be dropped.
	//
	// *Note for Kubernetes users*: When short names are used (e.g. "reviews"
	// instead of "reviews.default.svc.cluster.local"), Istio will interpret
	// the short name based on the namespace of the rule, not the service. A
	// rule in the "default" namespace containing a host "reviews will be
	// interpreted as "reviews.default.svc.cluster.local", irrespective of
	// the actual namespace associated with the reviews service. To avoid
	// potential misconfiguration, it is recommended to always use fully
	// qualified domain names over short names.
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The name of a subset within the service. Applicable only to services
	// within the mesh. The subset must be defined in a corresponding
	// DestinationRule.
	Subset string `protobuf:"bytes,2,opt,name=subset,proto3" json:"subset,omitempty"`
	// Specifies the port on the host that is being addressed. If a service
	// exposes only a single port it is not required to explicitly select the
	// port.
	Port                 *PortSelector `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Destination) DeepCopy 

func (in *Destination) DeepCopy() *Destination

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Destination. Required by controller-gen.

func (*Destination) DeepCopyInterface 

func (in *Destination) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Destination. Required by controller-gen.

func (*Destination) DeepCopyInto 

func (in *Destination) DeepCopyInto(out *Destination)

DeepCopyInto supports using Destination within kubernetes types, where deepcopy-gen is used.

func (*Destination) Descriptor 

func (*Destination) Descriptor() ([]byte, []int)

func (*Destination) GetHost 

func (m *Destination) GetHost() string

func (*Destination) GetPort 

func (m *Destination) GetPort() *PortSelector

func (*Destination) GetSubset 

func (m *Destination) GetSubset() string

func (*Destination) Marshal 

func (m *Destination) Marshal() (dAtA []byte, err error)

func (*Destination) MarshalJSON 

func (this *Destination) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Destination

func (*Destination) MarshalTo 

func (m *Destination) MarshalTo(dAtA []byte) (int, error)

func (*Destination) MarshalToSizedBuffer 

func (m *Destination) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) Reset 

func (m *Destination) Reset()

func (*Destination) Size 

func (m *Destination) Size() (n int)

func (*Destination) String 

func (m *Destination) String() string

func (*Destination) Unmarshal 

func (m *Destination) Unmarshal(dAtA []byte) error

func (*Destination) UnmarshalJSON 

func (this *Destination) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Destination

func (*Destination) XXX_DiscardUnknown 

func (m *Destination) XXX_DiscardUnknown()

func (*Destination) XXX_Marshal 

func (m *Destination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Destination) XXX_Merge 

func (m *Destination) XXX_Merge(src proto.Message)

func (*Destination) XXX_Size 

func (m *Destination) XXX_Size() int

func (*Destination) XXX_Unmarshal 

func (m *Destination) XXX_Unmarshal(b []byte) error

type GlobalRateLimit 

type GlobalRateLimit struct {
	// Match conditions to be satisfied for the rate limit rule to be activated.
	// All conditions inside a single match block have AND semantic.
	// If the match is not specified, then all the incoming requests will be considered matched.
	Match *MetaRouteMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// The rate limit domain to use when calling the rate limit service.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// The timeout in milliseconds for the rate limit service RPC. If not
	// set, this defaults to 20ms.
	RequestTimeout *types.Duration `protobuf:"bytes,3,opt,name=request_timeout,json=requestTimeout,proto3" json:"request_timeout,omitempty"`
	// The filter's behavior in case the rate limiting service does
	// not respond back. When it is set to true, Envoy will not allow traffic in case of
	// communication failure between rate limiting service and the proxy.
	DenyOnFail bool `protobuf:"varint,4,opt,name=deny_on_fail,json=denyOnFail,proto3" json:"deny_on_fail,omitempty"`
	// The cluster name of the external rate limit service provider.
	RateLimitService string `protobuf:"bytes,5,opt,name=rate_limit_service,json=rateLimitService,proto3" json:"rate_limit_service,omitempty"`
	// Defines what properties in the requests should be sent to the rate limit service
	Descriptors          []*GlobalRateLimit_Descriptor `protobuf:"bytes,6,rep,name=descriptors,proto3" json:"descriptors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

GlobalRateLimit configures global rate limit service for MetaProtocol proxy

func (*GlobalRateLimit) DeepCopy 

func (in *GlobalRateLimit) DeepCopy() *GlobalRateLimit

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalRateLimit. Required by controller-gen.

func (*GlobalRateLimit) DeepCopyInterface 

func (in *GlobalRateLimit) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GlobalRateLimit. Required by controller-gen.

func (*GlobalRateLimit) DeepCopyInto 

func (in *GlobalRateLimit) DeepCopyInto(out *GlobalRateLimit)

DeepCopyInto supports using GlobalRateLimit within kubernetes types, where deepcopy-gen is used.

func (*GlobalRateLimit) Descriptor 

func (*GlobalRateLimit) Descriptor() ([]byte, []int)

func (*GlobalRateLimit) GetDenyOnFail 

func (m *GlobalRateLimit) GetDenyOnFail() bool

func (*GlobalRateLimit) GetDescriptors 

func (m *GlobalRateLimit) GetDescriptors() []*GlobalRateLimit_Descriptor

func (*GlobalRateLimit) GetDomain 

func (m *GlobalRateLimit) GetDomain() string

func (*GlobalRateLimit) GetMatch 

func (m *GlobalRateLimit) GetMatch() *MetaRouteMatch

func (*GlobalRateLimit) GetRateLimitService 

func (m *GlobalRateLimit) GetRateLimitService() string

func (*GlobalRateLimit) GetRequestTimeout 

func (m *GlobalRateLimit) GetRequestTimeout() *types.Duration

func (*GlobalRateLimit) Marshal 

func (m *GlobalRateLimit) Marshal() (dAtA []byte, err error)

func (*GlobalRateLimit) MarshalJSON 

func (this *GlobalRateLimit) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for GlobalRateLimit

func (*GlobalRateLimit) MarshalTo 

func (m *GlobalRateLimit) MarshalTo(dAtA []byte) (int, error)

func (*GlobalRateLimit) MarshalToSizedBuffer 

func (m *GlobalRateLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalRateLimit) ProtoMessage 

func (*GlobalRateLimit) ProtoMessage()

func (*GlobalRateLimit) Reset 

func (m *GlobalRateLimit) Reset()

func (*GlobalRateLimit) Size 

func (m *GlobalRateLimit) Size() (n int)

func (*GlobalRateLimit) String 

func (m *GlobalRateLimit) String() string

func (*GlobalRateLimit) Unmarshal 

func (m *GlobalRateLimit) Unmarshal(dAtA []byte) error

func (*GlobalRateLimit) UnmarshalJSON 

func (this *GlobalRateLimit) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for GlobalRateLimit

func (*GlobalRateLimit) XXX_DiscardUnknown 

func (m *GlobalRateLimit) XXX_DiscardUnknown()

func (*GlobalRateLimit) XXX_Marshal 

func (m *GlobalRateLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalRateLimit) XXX_Merge 

func (m *GlobalRateLimit) XXX_Merge(src proto.Message)

func (*GlobalRateLimit) XXX_Size 

func (m *GlobalRateLimit) XXX_Size() int

func (*GlobalRateLimit) XXX_Unmarshal 

func (m *GlobalRateLimit) XXX_Unmarshal(b []byte) error

type GlobalRateLimit_Descriptor 

type GlobalRateLimit_Descriptor struct {
	// The property extracted from the requests
	Property string `protobuf:"bytes,1,opt,name=property,proto3" json:"property,omitempty"`
	// The corresponding descriptor key in the rate limit server configuration
	DescriptorKey        string   `protobuf:"bytes,2,opt,name=descriptor_key,json=descriptorKey,proto3" json:"descriptor_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Descriptor defines the mapping between the property in the request and the descriptor key in the rate limit server configuration Normally the property is the same as the descriptor key, but adding a mapping layer allows more flexibility

func (*GlobalRateLimit_Descriptor) DeepCopy 

func (in *GlobalRateLimit_Descriptor) DeepCopy() *GlobalRateLimit_Descriptor

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalRateLimit_Descriptor. Required by controller-gen.

func (*GlobalRateLimit_Descriptor) DeepCopyInterface 

func (in *GlobalRateLimit_Descriptor) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GlobalRateLimit_Descriptor. Required by controller-gen.

func (*GlobalRateLimit_Descriptor) DeepCopyInto 

func (in *GlobalRateLimit_Descriptor) DeepCopyInto(out *GlobalRateLimit_Descriptor)

DeepCopyInto supports using GlobalRateLimit_Descriptor within kubernetes types, where deepcopy-gen is used.

func (*GlobalRateLimit_Descriptor) Descriptor 

func (*GlobalRateLimit_Descriptor) Descriptor() ([]byte, []int)

func (*GlobalRateLimit_Descriptor) GetDescriptorKey 

func (m *GlobalRateLimit_Descriptor) GetDescriptorKey() string

func (*GlobalRateLimit_Descriptor) GetProperty 

func (m *GlobalRateLimit_Descriptor) GetProperty() string

func (*GlobalRateLimit_Descriptor) Marshal 

func (m *GlobalRateLimit_Descriptor) Marshal() (dAtA []byte, err error)

func (*GlobalRateLimit_Descriptor) MarshalJSON 

func (this *GlobalRateLimit_Descriptor) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for GlobalRateLimit_Descriptor

func (*GlobalRateLimit_Descriptor) MarshalTo 

func (m *GlobalRateLimit_Descriptor) MarshalTo(dAtA []byte) (int, error)

func (*GlobalRateLimit_Descriptor) MarshalToSizedBuffer 

func (m *GlobalRateLimit_Descriptor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GlobalRateLimit_Descriptor) ProtoMessage 

func (*GlobalRateLimit_Descriptor) ProtoMessage()

func (*GlobalRateLimit_Descriptor) Reset 

func (m *GlobalRateLimit_Descriptor) Reset()

func (*GlobalRateLimit_Descriptor) Size 

func (m *GlobalRateLimit_Descriptor) Size() (n int)

func (*GlobalRateLimit_Descriptor) String 

func (m *GlobalRateLimit_Descriptor) String() string

func (*GlobalRateLimit_Descriptor) Unmarshal 

func (m *GlobalRateLimit_Descriptor) Unmarshal(dAtA []byte) error

func (*GlobalRateLimit_Descriptor) UnmarshalJSON 

func (this *GlobalRateLimit_Descriptor) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for GlobalRateLimit_Descriptor

func (*GlobalRateLimit_Descriptor) XXX_DiscardUnknown 

func (m *GlobalRateLimit_Descriptor) XXX_DiscardUnknown()

func (*GlobalRateLimit_Descriptor) XXX_Marshal 

func (m *GlobalRateLimit_Descriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GlobalRateLimit_Descriptor) XXX_Merge 

func (m *GlobalRateLimit_Descriptor) XXX_Merge(src proto.Message)

func (*GlobalRateLimit_Descriptor) XXX_Size 

func (m *GlobalRateLimit_Descriptor) XXX_Size() int

func (*GlobalRateLimit_Descriptor) XXX_Unmarshal 

func (m *GlobalRateLimit_Descriptor) XXX_Unmarshal(b []byte) error

type KeyValue 

type KeyValue struct {
	// Key name.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// alue.
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KeyValue defines a Key /value pair.

func (*KeyValue) DeepCopy 

func (in *KeyValue) DeepCopy() *KeyValue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KeyValue. Required by controller-gen.

func (*KeyValue) DeepCopyInterface 

func (in *KeyValue) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new KeyValue. Required by controller-gen.

func (*KeyValue) DeepCopyInto 

func (in *KeyValue) DeepCopyInto(out *KeyValue)

DeepCopyInto supports using KeyValue within kubernetes types, where deepcopy-gen is used.

func (*KeyValue) Descriptor 

func (*KeyValue) Descriptor() ([]byte, []int)

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (m *KeyValue) GetValue() string

func (*KeyValue) Marshal 

func (m *KeyValue) Marshal() (dAtA []byte, err error)

func (*KeyValue) MarshalJSON 

func (this *KeyValue) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for KeyValue

func (*KeyValue) MarshalTo 

func (m *KeyValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue) MarshalToSizedBuffer 

func (m *KeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

func (m *KeyValue) Size() (n int)

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

func (m *KeyValue) Unmarshal(dAtA []byte) error

func (*KeyValue) UnmarshalJSON 

func (this *KeyValue) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for KeyValue

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValue) XXX_Merge 

func (m *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

func (m *KeyValue) XXX_Unmarshal(b []byte) error

type LocalRateLimit 

type LocalRateLimit struct {
	// The default token bucket configuration to use for rate limiting requests that are processed by
	// this filter.
	// Local rate limiter will first check the conditions, if a specific condition matches, then the token
	// bucket within that condition will be applied to the incoming request. All the other requests
	// that don't match the conditions will be rate limited by the default token bucket.
	// If the default token bucket is not specified, then the requests that don't match the conditions
	// will not be rate limited.
	// At least one of token_bucket or conditions should have value.
	TokenBucket *LocalRateLimit_TokenBucket `protobuf:"bytes,1,opt,name=token_bucket,json=tokenBucket,proto3" json:"token_bucket,omitempty"`
	// The more specific rate limit conditions, the first match will be used.
	Conditions           []*LocalRateLimit_Condition `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

LocalRateLimit defines local rate limit policies for MetaProtocol proxy

func (*LocalRateLimit) DeepCopy 

func (in *LocalRateLimit) DeepCopy() *LocalRateLimit

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocalRateLimit. Required by controller-gen.

func (*LocalRateLimit) DeepCopyInterface 

func (in *LocalRateLimit) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new LocalRateLimit. Required by controller-gen.

func (*LocalRateLimit) DeepCopyInto 

func (in *LocalRateLimit) DeepCopyInto(out *LocalRateLimit)

DeepCopyInto supports using LocalRateLimit within kubernetes types, where deepcopy-gen is used.

func (*LocalRateLimit) Descriptor 

func (*LocalRateLimit) Descriptor() ([]byte, []int)

func (*LocalRateLimit) GetConditions 

func (m *LocalRateLimit) GetConditions() []*LocalRateLimit_Condition

func (*LocalRateLimit) GetTokenBucket 

func (m *LocalRateLimit) GetTokenBucket() *LocalRateLimit_TokenBucket

func (*LocalRateLimit) Marshal 

func (m *LocalRateLimit) Marshal() (dAtA []byte, err error)

func (*LocalRateLimit) MarshalJSON 

func (this *LocalRateLimit) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for LocalRateLimit

func (*LocalRateLimit) MarshalTo 

func (m *LocalRateLimit) MarshalTo(dAtA []byte) (int, error)

func (*LocalRateLimit) MarshalToSizedBuffer 

func (m *LocalRateLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LocalRateLimit) ProtoMessage 

func (*LocalRateLimit) ProtoMessage()

func (*LocalRateLimit) Reset 

func (m *LocalRateLimit) Reset()

func (*LocalRateLimit) Size 

func (m *LocalRateLimit) Size() (n int)

func (*LocalRateLimit) String 

func (m *LocalRateLimit) String() string

func (*LocalRateLimit) Unmarshal 

func (m *LocalRateLimit) Unmarshal(dAtA []byte) error

func (*LocalRateLimit) UnmarshalJSON 

func (this *LocalRateLimit) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for LocalRateLimit

func (*LocalRateLimit) XXX_DiscardUnknown 

func (m *LocalRateLimit) XXX_DiscardUnknown()

func (*LocalRateLimit) XXX_Marshal 

func (m *LocalRateLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocalRateLimit) XXX_Merge 

func (m *LocalRateLimit) XXX_Merge(src proto.Message)

func (*LocalRateLimit) XXX_Size 

func (m *LocalRateLimit) XXX_Size() int

func (*LocalRateLimit) XXX_Unmarshal 

func (m *LocalRateLimit) XXX_Unmarshal(b []byte) error

type LocalRateLimit_Condition 

type LocalRateLimit_Condition struct {
	// Match conditions to be satisfied for the rate limit rule to be activated.
	// All conditions inside a single match block have AND semantic.
	// If the match is not specified, then all the incoming requests will be considered matched.
	Match *MetaRouteMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// The token bucket for this particular condition
	TokenBucket          *LocalRateLimit_TokenBucket `protobuf:"bytes,2,opt,name=token_bucket,json=tokenBucket,proto3" json:"token_bucket,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Condition defines a rate limit policy for a more specific condition

func (*LocalRateLimit_Condition) DeepCopy 

func (in *LocalRateLimit_Condition) DeepCopy() *LocalRateLimit_Condition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocalRateLimit_Condition. Required by controller-gen.

func (*LocalRateLimit_Condition) DeepCopyInterface 

func (in *LocalRateLimit_Condition) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new LocalRateLimit_Condition. Required by controller-gen.

func (*LocalRateLimit_Condition) DeepCopyInto 

func (in *LocalRateLimit_Condition) DeepCopyInto(out *LocalRateLimit_Condition)

DeepCopyInto supports using LocalRateLimit_Condition within kubernetes types, where deepcopy-gen is used.

func (*LocalRateLimit_Condition) Descriptor 

func (*LocalRateLimit_Condition) Descriptor() ([]byte, []int)

func (*LocalRateLimit_Condition) GetMatch 

func (m *LocalRateLimit_Condition) GetMatch() *MetaRouteMatch

func (*LocalRateLimit_Condition) GetTokenBucket 

func (m *LocalRateLimit_Condition) GetTokenBucket() *LocalRateLimit_TokenBucket

func (*LocalRateLimit_Condition) Marshal 

func (m *LocalRateLimit_Condition) Marshal() (dAtA []byte, err error)

func (*LocalRateLimit_Condition) MarshalJSON 

func (this *LocalRateLimit_Condition) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for LocalRateLimit_Condition

func (*LocalRateLimit_Condition) MarshalTo 

func (m *LocalRateLimit_Condition) MarshalTo(dAtA []byte) (int, error)

func (*LocalRateLimit_Condition) MarshalToSizedBuffer 

func (m *LocalRateLimit_Condition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LocalRateLimit_Condition) ProtoMessage 

func (*LocalRateLimit_Condition) ProtoMessage()

func (*LocalRateLimit_Condition) Reset 

func (m *LocalRateLimit_Condition) Reset()

func (*LocalRateLimit_Condition) Size 

func (m *LocalRateLimit_Condition) Size() (n int)

func (*LocalRateLimit_Condition) String 

func (m *LocalRateLimit_Condition) String() string

func (*LocalRateLimit_Condition) Unmarshal 

func (m *LocalRateLimit_Condition) Unmarshal(dAtA []byte) error

func (*LocalRateLimit_Condition) UnmarshalJSON 

func (this *LocalRateLimit_Condition) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for LocalRateLimit_Condition

func (*LocalRateLimit_Condition) XXX_DiscardUnknown 

func (m *LocalRateLimit_Condition) XXX_DiscardUnknown()

func (*LocalRateLimit_Condition) XXX_Marshal 

func (m *LocalRateLimit_Condition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocalRateLimit_Condition) XXX_Merge 

func (m *LocalRateLimit_Condition) XXX_Merge(src proto.Message)

func (*LocalRateLimit_Condition) XXX_Size 

func (m *LocalRateLimit_Condition) XXX_Size() int

func (*LocalRateLimit_Condition) XXX_Unmarshal 

func (m *LocalRateLimit_Condition) XXX_Unmarshal(b []byte) error

type LocalRateLimit_TokenBucket 

type LocalRateLimit_TokenBucket struct {
	// The maximum tokens that the bucket can hold. This is also the number of tokens that the bucket
	// initially contains. The value must be greater than 0.
	MaxTokens uint32 `protobuf:"varint,1,opt,name=max_tokens,json=maxTokens,proto3" json:"max_tokens,omitempty"`
	// The number of tokens added to the bucket during each fill interval. The value must be greater than 0.
	//If not specified, defaults to a single token.
	TokensPerFill *types.UInt32Value `protobuf:"bytes,2,opt,name=tokens_per_fill,json=tokensPerFill,proto3" json:"tokens_per_fill,omitempty"`
	// The fill interval that tokens are added to the bucket. During each fill interval
	// `tokens_per_fill` are added to the bucket. The bucket will never contain more than
	// `max_tokens` tokens.
	FillInterval         *types.Duration `protobuf:"bytes,3,opt,name=fill_interval,json=fillInterval,proto3" json:"fill_interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Configures a token bucket which is used for rate limiting.

func (*LocalRateLimit_TokenBucket) DeepCopy 

func (in *LocalRateLimit_TokenBucket) DeepCopy() *LocalRateLimit_TokenBucket

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LocalRateLimit_TokenBucket. Required by controller-gen.

func (*LocalRateLimit_TokenBucket) DeepCopyInterface 

func (in *LocalRateLimit_TokenBucket) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new LocalRateLimit_TokenBucket. Required by controller-gen.

func (*LocalRateLimit_TokenBucket) DeepCopyInto 

func (in *LocalRateLimit_TokenBucket) DeepCopyInto(out *LocalRateLimit_TokenBucket)

DeepCopyInto supports using LocalRateLimit_TokenBucket within kubernetes types, where deepcopy-gen is used.

func (*LocalRateLimit_TokenBucket) Descriptor 

func (*LocalRateLimit_TokenBucket) Descriptor() ([]byte, []int)

func (*LocalRateLimit_TokenBucket) GetFillInterval 

func (m *LocalRateLimit_TokenBucket) GetFillInterval() *types.Duration

func (*LocalRateLimit_TokenBucket) GetMaxTokens 

func (m *LocalRateLimit_TokenBucket) GetMaxTokens() uint32

func (*LocalRateLimit_TokenBucket) GetTokensPerFill 

func (m *LocalRateLimit_TokenBucket) GetTokensPerFill() *types.UInt32Value

func (*LocalRateLimit_TokenBucket) Marshal 

func (m *LocalRateLimit_TokenBucket) Marshal() (dAtA []byte, err error)

func (*LocalRateLimit_TokenBucket) MarshalJSON 

func (this *LocalRateLimit_TokenBucket) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for LocalRateLimit_TokenBucket

func (*LocalRateLimit_TokenBucket) MarshalTo 

func (m *LocalRateLimit_TokenBucket) MarshalTo(dAtA []byte) (int, error)

func (*LocalRateLimit_TokenBucket) MarshalToSizedBuffer 

func (m *LocalRateLimit_TokenBucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LocalRateLimit_TokenBucket) ProtoMessage 

func (*LocalRateLimit_TokenBucket) ProtoMessage()

func (*LocalRateLimit_TokenBucket) Reset 

func (m *LocalRateLimit_TokenBucket) Reset()

func (*LocalRateLimit_TokenBucket) Size 

func (m *LocalRateLimit_TokenBucket) Size() (n int)

func (*LocalRateLimit_TokenBucket) String 

func (m *LocalRateLimit_TokenBucket) String() string

func (*LocalRateLimit_TokenBucket) Unmarshal 

func (m *LocalRateLimit_TokenBucket) Unmarshal(dAtA []byte) error

func (*LocalRateLimit_TokenBucket) UnmarshalJSON 

func (this *LocalRateLimit_TokenBucket) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for LocalRateLimit_TokenBucket

func (*LocalRateLimit_TokenBucket) XXX_DiscardUnknown 

func (m *LocalRateLimit_TokenBucket) XXX_DiscardUnknown()

func (*LocalRateLimit_TokenBucket) XXX_Marshal 

func (m *LocalRateLimit_TokenBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LocalRateLimit_TokenBucket) XXX_Merge 

func (m *LocalRateLimit_TokenBucket) XXX_Merge(src proto.Message)

func (*LocalRateLimit_TokenBucket) XXX_Size 

func (m *LocalRateLimit_TokenBucket) XXX_Size() int

func (*LocalRateLimit_TokenBucket) XXX_Unmarshal 

func (m *LocalRateLimit_TokenBucket) XXX_Unmarshal(b []byte) error

type MetaRoute 

type MetaRoute struct {
	// The name assigned to the route for debugging purposes.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Match conditions to be satisfied for the rule to be activated.
	// All conditions inside a single match block have AND semantic.
	Match *MetaRouteMatch `protobuf:"bytes,2,opt,name=match,proto3" json:"match,omitempty"`
	// A Route rule can forward (default) traffic. The forwarding target
	// can be one of several versions of a service (see glossary in
	// beginning of document). Weights associated with the service version
	// determine the proportion of traffic it receives.
	Route  []*MetaRouteDestination `protobuf:"bytes,3,rep,name=route,proto3" json:"route,omitempty"`
	Mirror *Destination            `protobuf:"bytes,5,opt,name=mirror,proto3" json:"mirror,omitempty"`
	// Percentage of the traffic to be mirrored by the `mirror` field.
	// If this field is absent, all the traffic (100%) will be mirrored.
	// Max value is 100.
	MirrorPercentage *Percent `protobuf:"bytes,6,opt,name=mirror_percentage,json=mirrorPercentage,proto3" json:"mirror_percentage,omitempty"`
	// Specifies a list of key-value pairs that should be mutated for each request. How to interpret the key-value pairs
	// depends on the codec implementation
	RequestMutation []*KeyValue `protobuf:"bytes,19,rep,name=request_mutation,json=requestMutation,proto3" json:"request_mutation,omitempty"`
	// Specifies a list of key-value pairs that should be mutated for each response. How to interpret the key-value pairs
	// depends on the codec implementation
	ResponseMutation     []*KeyValue `protobuf:"bytes,20,rep,name=response_mutation,json=responseMutation,proto3" json:"response_mutation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Describes match conditions and actions for routing MetaProtocol.

func (*MetaRoute) DeepCopy 

func (in *MetaRoute) DeepCopy() *MetaRoute

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetaRoute. Required by controller-gen.

func (*MetaRoute) DeepCopyInterface 

func (in *MetaRoute) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new MetaRoute. Required by controller-gen.

func (*MetaRoute) DeepCopyInto 

func (in *MetaRoute) DeepCopyInto(out *MetaRoute)

DeepCopyInto supports using MetaRoute within kubernetes types, where deepcopy-gen is used.

func (*MetaRoute) Descriptor 

func (*MetaRoute) Descriptor() ([]byte, []int)

func (*MetaRoute) GetMatch 

func (m *MetaRoute) GetMatch() *MetaRouteMatch

func (*MetaRoute) GetMirror 

func (m *MetaRoute) GetMirror() *Destination

func (*MetaRoute) GetMirrorPercentage 

func (m *MetaRoute) GetMirrorPercentage() *Percent

func (*MetaRoute) GetName 

func (m *MetaRoute) GetName() string

func (*MetaRoute) GetRequestMutation 

func (m *MetaRoute) GetRequestMutation() []*KeyValue

func (*MetaRoute) GetResponseMutation 

func (m *MetaRoute) GetResponseMutation() []*KeyValue

func (*MetaRoute) GetRoute 

func (m *MetaRoute) GetRoute() []*MetaRouteDestination

func (*MetaRoute) Marshal 

func (m *MetaRoute) Marshal() (dAtA []byte, err error)

func (*MetaRoute) MarshalJSON 

func (this *MetaRoute) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MetaRoute

func (*MetaRoute) MarshalTo 

func (m *MetaRoute) MarshalTo(dAtA []byte) (int, error)

func (*MetaRoute) MarshalToSizedBuffer 

func (m *MetaRoute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetaRoute) ProtoMessage 

func (*MetaRoute) ProtoMessage()

func (*MetaRoute) Reset 

func (m *MetaRoute) Reset()

func (*MetaRoute) Size 

func (m *MetaRoute) Size() (n int)

func (*MetaRoute) String 

func (m *MetaRoute) String() string

func (*MetaRoute) Unmarshal 

func (m *MetaRoute) Unmarshal(dAtA []byte) error

func (*MetaRoute) UnmarshalJSON 

func (this *MetaRoute) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MetaRoute

func (*MetaRoute) XXX_DiscardUnknown 

func (m *MetaRoute) XXX_DiscardUnknown()

func (*MetaRoute) XXX_Marshal 

func (m *MetaRoute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaRoute) XXX_Merge 

func (m *MetaRoute) XXX_Merge(src proto.Message)

func (*MetaRoute) XXX_Size 

func (m *MetaRoute) XXX_Size() int

func (*MetaRoute) XXX_Unmarshal 

func (m *MetaRoute) XXX_Unmarshal(b []byte) error

type MetaRouteDestination 

type MetaRouteDestination struct {
	// Destination uniquely identifies the instances of a service
	// to which the request/connection should be forwarded to.
	Destination *Destination `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	// The proportion of traffic to be forwarded to the service
	// version. (0-100). Sum of weights across destinations SHOULD BE == 100.
	// If there is only one destination in a rule, the weight value is assumed to
	// be 100.
	Weight               uint32   `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetaRouteDestination) DeepCopy 

func (in *MetaRouteDestination) DeepCopy() *MetaRouteDestination

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetaRouteDestination. Required by controller-gen.

func (*MetaRouteDestination) DeepCopyInterface 

func (in *MetaRouteDestination) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new MetaRouteDestination. Required by controller-gen.

func (*MetaRouteDestination) DeepCopyInto 

func (in *MetaRouteDestination) DeepCopyInto(out *MetaRouteDestination)

DeepCopyInto supports using MetaRouteDestination within kubernetes types, where deepcopy-gen is used.

func (*MetaRouteDestination) Descriptor 

func (*MetaRouteDestination) Descriptor() ([]byte, []int)

func (*MetaRouteDestination) GetDestination 

func (m *MetaRouteDestination) GetDestination() *Destination

func (*MetaRouteDestination) GetWeight 

func (m *MetaRouteDestination) GetWeight() uint32

func (*MetaRouteDestination) Marshal 

func (m *MetaRouteDestination) Marshal() (dAtA []byte, err error)

func (*MetaRouteDestination) MarshalJSON 

func (this *MetaRouteDestination) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MetaRouteDestination

func (*MetaRouteDestination) MarshalTo 

func (m *MetaRouteDestination) MarshalTo(dAtA []byte) (int, error)

func (*MetaRouteDestination) MarshalToSizedBuffer 

func (m *MetaRouteDestination) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetaRouteDestination) ProtoMessage 

func (*MetaRouteDestination) ProtoMessage()

func (*MetaRouteDestination) Reset 

func (m *MetaRouteDestination) Reset()

func (*MetaRouteDestination) Size 

func (m *MetaRouteDestination) Size() (n int)

func (*MetaRouteDestination) String 

func (m *MetaRouteDestination) String() string

func (*MetaRouteDestination) Unmarshal 

func (m *MetaRouteDestination) Unmarshal(dAtA []byte) error

func (*MetaRouteDestination) UnmarshalJSON 

func (this *MetaRouteDestination) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MetaRouteDestination

func (*MetaRouteDestination) XXX_DiscardUnknown 

func (m *MetaRouteDestination) XXX_DiscardUnknown()

func (*MetaRouteDestination) XXX_Marshal 

func (m *MetaRouteDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaRouteDestination) XXX_Merge 

func (m *MetaRouteDestination) XXX_Merge(src proto.Message)

func (*MetaRouteDestination) XXX_Size 

func (m *MetaRouteDestination) XXX_Size() int

func (*MetaRouteDestination) XXX_Unmarshal 

func (m *MetaRouteDestination) XXX_Unmarshal(b []byte) error

type MetaRouteMatch 

type MetaRouteMatch struct {
	// If the value is empty and only the name of attribute is specified, presence of the attribute is checked.
	Attributes           map[string]*StringMatch `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*MetaRouteMatch) DeepCopy 

func (in *MetaRouteMatch) DeepCopy() *MetaRouteMatch

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetaRouteMatch. Required by controller-gen.

func (*MetaRouteMatch) DeepCopyInterface 

func (in *MetaRouteMatch) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new MetaRouteMatch. Required by controller-gen.

func (*MetaRouteMatch) DeepCopyInto 

func (in *MetaRouteMatch) DeepCopyInto(out *MetaRouteMatch)

DeepCopyInto supports using MetaRouteMatch within kubernetes types, where deepcopy-gen is used.

func (*MetaRouteMatch) Descriptor 

func (*MetaRouteMatch) Descriptor() ([]byte, []int)

func (*MetaRouteMatch) GetAttributes 

func (m *MetaRouteMatch) GetAttributes() map[string]*StringMatch

func (*MetaRouteMatch) Marshal 

func (m *MetaRouteMatch) Marshal() (dAtA []byte, err error)

func (*MetaRouteMatch) MarshalJSON 

func (this *MetaRouteMatch) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MetaRouteMatch

func (*MetaRouteMatch) MarshalTo 

func (m *MetaRouteMatch) MarshalTo(dAtA []byte) (int, error)

func (*MetaRouteMatch) MarshalToSizedBuffer 

func (m *MetaRouteMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetaRouteMatch) ProtoMessage 

func (*MetaRouteMatch) ProtoMessage()

func (*MetaRouteMatch) Reset 

func (m *MetaRouteMatch) Reset()

func (*MetaRouteMatch) Size 

func (m *MetaRouteMatch) Size() (n int)

func (*MetaRouteMatch) String 

func (m *MetaRouteMatch) String() string

func (*MetaRouteMatch) Unmarshal 

func (m *MetaRouteMatch) Unmarshal(dAtA []byte) error

func (*MetaRouteMatch) UnmarshalJSON 

func (this *MetaRouteMatch) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MetaRouteMatch

func (*MetaRouteMatch) XXX_DiscardUnknown 

func (m *MetaRouteMatch) XXX_DiscardUnknown()

func (*MetaRouteMatch) XXX_Marshal 

func (m *MetaRouteMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaRouteMatch) XXX_Merge 

func (m *MetaRouteMatch) XXX_Merge(src proto.Message)

func (*MetaRouteMatch) XXX_Size 

func (m *MetaRouteMatch) XXX_Size() int

func (*MetaRouteMatch) XXX_Unmarshal 

func (m *MetaRouteMatch) XXX_Unmarshal(b []byte) error

type MetaRouter 

type MetaRouter struct {
	// The destination service to which traffic is being sent.
	// *Note for Kubernetes users*: It must be a fully qualified domain name
	// (FQDN), (e.g. "thrift-sample-server.meta-thrift.svc.cluster.local" )
	// instead of a short name (e.g. "thrift-sample-server").
	// *Note*: Only one host is supported now. If multiple hosts are specified,
	// Only the first one takes effect.
	Hosts []string `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// The names of gateways and sidecars that should apply these routes. The usage of
	//  this field is the same as istio.io/VirtualService
	Gateways []string `protobuf:"bytes,2,rep,name=gateways,proto3" json:"gateways,omitempty"`
	// An ordered list of route rules for MetaProtocol traffic. The route rules
	// will be applied to service ports named "tcp-metaprotocol-${applicationProtocol}-*",
	// (e.g. "tcp-metaprotocol-thrift-hello-server"). Order maters in the routes,
	// The first rule matching an incoming request is used.
	Routes []*MetaRoute `protobuf:"bytes,3,rep,name=routes,proto3" json:"routes,omitempty"`
	// Loacal rate limit policy.
	LocalRateLimit *LocalRateLimit `protobuf:"bytes,4,opt,name=local_rate_limit,json=localRateLimit,proto3" json:"local_rate_limit,omitempty"`
	// Global rate limit policy.
	GlobalRateLimit *GlobalRateLimit `protobuf:"bytes,5,opt,name=global_rate_limit,json=globalRateLimit,proto3" json:"global_rate_limit,omitempty"`
	// A list of namespaces to which this MetaRouter is exported. Exporting a
	// MetaRouter allows it to be used by sidecars defined in other namespaces.
	// This feature provides a mechanism for service owners and mesh administrators
	// to control the visibility of MetaRouter across namespace boundaries.
	//
	// If no namespaces are specified then the MetaRouter is exported to all namespaces
	// by default.
	//
	// The value "." is reserved and defines an export to the same namespace that
	// the MetaRouter is declared in. Similarly the value "*" is reserved and
	// defines an export to all namespaces.
	ExportTo             []string `protobuf:"bytes,20,rep,name=export_to,json=exportTo,proto3" json:"export_to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MetaRouter defines route policies for MetaProtocol proxy.

<!-- crd generation tags +cue-gen:MetaRouter:groupName:metaprotocol.aeraki.io +cue-gen:MetaRouter:version:v1alpha1 +cue-gen:MetaRouter:storageVersion +cue-gen:MetaRouter:annotations:helm.sh/resource-policy=keep +cue-gen:MetaRouter:labels:app=aeraki,chart=aeraki,heritage=Tiller,release=aeraki +cue-gen:MetaRouter:subresource:status +cue-gen:MetaRouter:scope:Namespaced +cue-gen:MetaRouter:resource:categories=aeraki-io,metaprotocol-aeraki-io +cue-gen:MetaRouter:preserveUnknownFields:false -->

<!-- go code generation tags +kubetype-gen +kubetype-gen:groupVersion=metaprotocol.aeraki.io/v1alpha1 +genclient +k8s:deepcopy-gen=true -->

func (*MetaRouter) DeepCopy 

func (in *MetaRouter) DeepCopy() *MetaRouter

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MetaRouter. Required by controller-gen.

func (*MetaRouter) DeepCopyInterface 

func (in *MetaRouter) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new MetaRouter. Required by controller-gen.

func (*MetaRouter) DeepCopyInto 

func (in *MetaRouter) DeepCopyInto(out *MetaRouter)

DeepCopyInto supports using MetaRouter within kubernetes types, where deepcopy-gen is used.

func (*MetaRouter) Descriptor 

func (*MetaRouter) Descriptor() ([]byte, []int)

func (*MetaRouter) GetExportTo 

func (m *MetaRouter) GetExportTo() []string

func (*MetaRouter) GetGateways 

func (m *MetaRouter) GetGateways() []string

func (*MetaRouter) GetGlobalRateLimit 

func (m *MetaRouter) GetGlobalRateLimit() *GlobalRateLimit

func (*MetaRouter) GetHosts 

func (m *MetaRouter) GetHosts() []string

func (*MetaRouter) GetLocalRateLimit 

func (m *MetaRouter) GetLocalRateLimit() *LocalRateLimit

func (*MetaRouter) GetRoutes 

func (m *MetaRouter) GetRoutes() []*MetaRoute

func (*MetaRouter) Marshal 

func (m *MetaRouter) Marshal() (dAtA []byte, err error)

func (*MetaRouter) MarshalJSON 

func (this *MetaRouter) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for MetaRouter

func (*MetaRouter) MarshalTo 

func (m *MetaRouter) MarshalTo(dAtA []byte) (int, error)

func (*MetaRouter) MarshalToSizedBuffer 

func (m *MetaRouter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetaRouter) ProtoMessage 

func (*MetaRouter) ProtoMessage()

func (*MetaRouter) Reset 

func (m *MetaRouter) Reset()

func (*MetaRouter) Size 

func (m *MetaRouter) Size() (n int)

func (*MetaRouter) String 

func (m *MetaRouter) String() string

func (*MetaRouter) Unmarshal 

func (m *MetaRouter) Unmarshal(dAtA []byte) error

func (*MetaRouter) UnmarshalJSON 

func (this *MetaRouter) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for MetaRouter

func (*MetaRouter) XXX_DiscardUnknown 

func (m *MetaRouter) XXX_DiscardUnknown()

func (*MetaRouter) XXX_Marshal 

func (m *MetaRouter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaRouter) XXX_Merge 

func (m *MetaRouter) XXX_Merge(src proto.Message)

func (*MetaRouter) XXX_Size 

func (m *MetaRouter) XXX_Size() int

func (*MetaRouter) XXX_Unmarshal 

func (m *MetaRouter) XXX_Unmarshal(b []byte) error

type Percent 

type Percent struct {
	Value                float64  `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Percent specifies a percentage in the range of [0.0, 100.0].

func (*Percent) DeepCopy 

func (in *Percent) DeepCopy() *Percent

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Percent. Required by controller-gen.

func (*Percent) DeepCopyInterface 

func (in *Percent) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Percent. Required by controller-gen.

func (*Percent) DeepCopyInto 

func (in *Percent) DeepCopyInto(out *Percent)

DeepCopyInto supports using Percent within kubernetes types, where deepcopy-gen is used.

func (*Percent) Descriptor 

func (*Percent) Descriptor() ([]byte, []int)

func (*Percent) GetValue 

func (m *Percent) GetValue() float64

func (*Percent) Marshal 

func (m *Percent) Marshal() (dAtA []byte, err error)

func (*Percent) MarshalJSON 

func (this *Percent) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for Percent

func (*Percent) MarshalTo 

func (m *Percent) MarshalTo(dAtA []byte) (int, error)

func (*Percent) MarshalToSizedBuffer 

func (m *Percent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Percent) ProtoMessage 

func (*Percent) ProtoMessage()

func (*Percent) Reset 

func (m *Percent) Reset()

func (*Percent) Size 

func (m *Percent) Size() (n int)

func (*Percent) String 

func (m *Percent) String() string

func (*Percent) Unmarshal 

func (m *Percent) Unmarshal(dAtA []byte) error

func (*Percent) UnmarshalJSON 

func (this *Percent) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for Percent

func (*Percent) XXX_DiscardUnknown 

func (m *Percent) XXX_DiscardUnknown()

func (*Percent) XXX_Marshal 

func (m *Percent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Percent) XXX_Merge 

func (m *Percent) XXX_Merge(src proto.Message)

func (*Percent) XXX_Size 

func (m *Percent) XXX_Size() int

func (*Percent) XXX_Unmarshal 

func (m *Percent) XXX_Unmarshal(b []byte) error

type PortSelector 

type PortSelector struct {
	// Valid port number
	Number               uint32   `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PortSelector specifies the number of a port to be used for matching or selection for final routing.

func (*PortSelector) DeepCopy 

func (in *PortSelector) DeepCopy() *PortSelector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PortSelector. Required by controller-gen.

func (*PortSelector) DeepCopyInterface 

func (in *PortSelector) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new PortSelector. Required by controller-gen.

func (*PortSelector) DeepCopyInto 

func (in *PortSelector) DeepCopyInto(out *PortSelector)

DeepCopyInto supports using PortSelector within kubernetes types, where deepcopy-gen is used.

func (*PortSelector) Descriptor 

func (*PortSelector) Descriptor() ([]byte, []int)

func (*PortSelector) GetNumber 

func (m *PortSelector) GetNumber() uint32

func (*PortSelector) Marshal 

func (m *PortSelector) Marshal() (dAtA []byte, err error)

func (*PortSelector) MarshalJSON 

func (this *PortSelector) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for PortSelector

func (*PortSelector) MarshalTo 

func (m *PortSelector) MarshalTo(dAtA []byte) (int, error)

func (*PortSelector) MarshalToSizedBuffer 

func (m *PortSelector) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PortSelector) ProtoMessage 

func (*PortSelector) ProtoMessage()

func (*PortSelector) Reset 

func (m *PortSelector) Reset()

func (*PortSelector) Size 

func (m *PortSelector) Size() (n int)

func (*PortSelector) String 

func (m *PortSelector) String() string

func (*PortSelector) Unmarshal 

func (m *PortSelector) Unmarshal(dAtA []byte) error

func (*PortSelector) UnmarshalJSON 

func (this *PortSelector) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for PortSelector

func (*PortSelector) XXX_DiscardUnknown 

func (m *PortSelector) XXX_DiscardUnknown()

func (*PortSelector) XXX_Marshal 

func (m *PortSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PortSelector) XXX_Merge 

func (m *PortSelector) XXX_Merge(src proto.Message)

func (*PortSelector) XXX_Size 

func (m *PortSelector) XXX_Size() int

func (*PortSelector) XXX_Unmarshal 

func (m *PortSelector) XXX_Unmarshal(b []byte) error

type StringMatch 

type StringMatch struct {
	// Types that are valid to be assigned to MatchType:
	//	*StringMatch_Exact
	//	*StringMatch_Prefix
	//	*StringMatch_Regex
	MatchType            isStringMatch_MatchType `protobuf_oneof:"match_type"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Describes how to match a given string in HTTP headers. Match is case-sensitive.

func (*StringMatch) DeepCopy 

func (in *StringMatch) DeepCopy() *StringMatch

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StringMatch. Required by controller-gen.

func (*StringMatch) DeepCopyInterface 

func (in *StringMatch) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new StringMatch. Required by controller-gen.

func (*StringMatch) DeepCopyInto 

func (in *StringMatch) DeepCopyInto(out *StringMatch)

DeepCopyInto supports using StringMatch within kubernetes types, where deepcopy-gen is used.

func (*StringMatch) Descriptor 

func (*StringMatch) Descriptor() ([]byte, []int)

func (*StringMatch) GetExact 

func (m *StringMatch) GetExact() string

func (*StringMatch) GetMatchType 

func (m *StringMatch) GetMatchType() isStringMatch_MatchType

func (*StringMatch) GetPrefix 

func (m *StringMatch) GetPrefix() string

func (*StringMatch) GetRegex 

func (m *StringMatch) GetRegex() string

func (*StringMatch) Marshal 

func (m *StringMatch) Marshal() (dAtA []byte, err error)

func (*StringMatch) MarshalJSON 

func (this *StringMatch) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for StringMatch

func (*StringMatch) MarshalTo 

func (m *StringMatch) MarshalTo(dAtA []byte) (int, error)

func (*StringMatch) MarshalToSizedBuffer 

func (m *StringMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StringMatch) ProtoMessage 

func (*StringMatch) ProtoMessage()

func (*StringMatch) Reset 

func (m *StringMatch) Reset()

func (*StringMatch) Size 

func (m *StringMatch) Size() (n int)

func (*StringMatch) String 

func (m *StringMatch) String() string

func (*StringMatch) Unmarshal 

func (m *StringMatch) Unmarshal(dAtA []byte) error

func (*StringMatch) UnmarshalJSON 

func (this *StringMatch) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for StringMatch

func (*StringMatch) XXX_DiscardUnknown 

func (m *StringMatch) XXX_DiscardUnknown()

func (*StringMatch) XXX_Marshal 

func (m *StringMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringMatch) XXX_Merge 

func (m *StringMatch) XXX_Merge(src proto.Message)

func (*StringMatch) XXX_OneofWrappers 

func (*StringMatch) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StringMatch) XXX_Size 

func (m *StringMatch) XXX_Size() int

func (*StringMatch) XXX_Unmarshal 

func (m *StringMatch) XXX_Unmarshal(b []byte) error

type StringMatch_Exact 

type StringMatch_Exact struct {
	Exact string `protobuf:"bytes,1,opt,name=exact,proto3,oneof" json:"exact,omitempty"`
}

func (*StringMatch_Exact) MarshalTo 

func (m *StringMatch_Exact) MarshalTo(dAtA []byte) (int, error)

func (*StringMatch_Exact) MarshalToSizedBuffer 

func (m *StringMatch_Exact) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StringMatch_Exact) Size 

func (m *StringMatch_Exact) Size() (n int)

type StringMatch_Prefix 

type StringMatch_Prefix struct {
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof" json:"prefix,omitempty"`
}

func (*StringMatch_Prefix) MarshalTo 

func (m *StringMatch_Prefix) MarshalTo(dAtA []byte) (int, error)

func (*StringMatch_Prefix) MarshalToSizedBuffer 

func (m *StringMatch_Prefix) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StringMatch_Prefix) Size 

func (m *StringMatch_Prefix) Size() (n int)

type StringMatch_Regex 

type StringMatch_Regex struct {
	Regex string `protobuf:"bytes,3,opt,name=regex,proto3,oneof" json:"regex,omitempty"`
}

func (*StringMatch_Regex) MarshalTo 

func (m *StringMatch_Regex) MarshalTo(dAtA []byte) (int, error)

func (*StringMatch_Regex) MarshalToSizedBuffer 

func (m *StringMatch_Regex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StringMatch_Regex) Size 

func (m *StringMatch_Regex) Size() (n int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.