v1alpha1

package
v0.0.0-...-43b7830 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

+groupName=proxy.kubegateway.io +k8s:openapi-gen=true +k8s:deepcopy-gen=package +k8s:defaulter-gen=TypeMeta

Index

Constants

View Source 
const (
	ServiceAccountUsernamePrefix    = "system:serviceaccount:"
	ServiceAccountUsernameSeparator = ":"
)
View Source 
const GroupName = "proxy.kubegateway.io"

GroupName specifies the group name used to register the objects.

View Source 
const (
	MatchAll = "*"
)

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	// Depreciated: use Install instead
	AddToScheme = localSchemeBuilder.AddToScheme
	Install     = localSchemeBuilder.AddToScheme
)
View Source 
var GroupVersion = v1.GroupVersion{Group: GroupName, Version: "v1alpha1"}

GroupVersion specifies the group and the version used to register the objects.

View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"}

SchemeGroupVersion is group version used to register these objects Deprecated: use GroupVersion instead.

Functions

func APIGroupMatches 

func APIGroupMatches(apiGroups []string, request string) bool

func MakeServiceAccountUsername 

func MakeServiceAccountUsername(namespace, name string) string

MakeServiceAccountUsername generates a username from the given namespace and ServiceAccount name. The resulting username can be passed to SplitUsername to extract the original namespace and ServiceAccount name.

func NonResourceURLMatches 

func NonResourceURLMatches(nonResourceURLs []string, request string) bool

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

func ResourceMatches 

func ResourceMatches(resources []string, combinedRequestedResource, requestedSubresource string) bool

func ResourceNameMatches 

func ResourceNameMatches(resourceNames []string, request string) bool

func SetDefaults_UpstreamCluster 

func SetDefaults_UpstreamCluster(obj *UpstreamCluster)

SetDefaults_UpstreamCluster set additional defaults compared to its counterpart nolint

func SetObjectDefaults_UpstreamCluster 

func SetObjectDefaults_UpstreamCluster(in *UpstreamCluster)

func SetObjectDefaults_UpstreamClusterList 

func SetObjectDefaults_UpstreamClusterList(in *UpstreamClusterList)

func UserGroupMatches 

func UserGroupMatches(userGroups []string, requestGroups []string) bool

func UserOrServiceAccountMatches 

func UserOrServiceAccountMatches(users []string, serviceAccounts []ServiceAccountRef, requestUser string) bool

func VerbMatches 

func VerbMatches(verbs []string, request string) bool

Types

type ClientConfig 

type ClientConfig struct {
	// Server should be accessed without verifying the TLS certificate. For testing only.
	Insecure bool `json:"insecure,omitempty" protobuf:"varint,1,opt,name=insecure"`
	// BearerToken is the bearer token for authentication. It can be an service account token.
	BearerToken []byte `json:"bearerToken,omitempty" protobuf:"bytes,2,opt,name=bearerToken"`
	// KeyData contains PEM-encoded data from a client key file for TLS.
	// The serialized form of data is a base64 encoded string
	KeyData []byte `json:"keyData,omitempty" protobuf:"bytes,3,opt,name=keyData"`
	// CertData contains PEM-encoded data from a client cert file for TLS.
	// The serialized form of data is a base64 encoded string
	CertData []byte `json:"certData,omitempty" protobuf:"bytes,4,opt,name=certData"`
	// CAData contains PEM-encoded data from a ca file for TLS.
	// The serialized form of data is a base64 encoded string
	CAData []byte `json:"caData,omitempty" protobuf:"bytes,5,opt,name=caData"`
	// QPS indicates the maximum QPS to the master from this client.
	// Zero means no limit, it is different from qps defined in flowcontrol.RateLimiter
	// +optional
	QPS int32 `json:"qps,omitempty" protobuf:"varint,6,opt,name=qps"`
	// Maximum burst for throttle.
	// Zero means no limit
	// This value must be bigger than QPS if QPS is not 0
	// +optional
	Burst int32 `json:"burst,omitempty" protobuf:"varint,7,opt,name=burst"`
	// QPSDivisor divites QPS to a new float32 qps value because we can not use float32
	// type in API Struct according to API convention.
	// It allows you to set a more precise qps, like 0.01 (qps:1, qpsDivisor:100)
	// +optional
	QPSDivisor int32 `json:"qpsDivisor,omitempty" protobuf:"varint,8,opt,name=qpsDivisor"`
}

func (*ClientConfig) DeepCopy 

func (in *ClientConfig) DeepCopy() *ClientConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientConfig.

func (*ClientConfig) DeepCopyInto 

func (in *ClientConfig) DeepCopyInto(out *ClientConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ClientConfig) Descriptor 

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

func (*ClientConfig) Marshal 

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

func (*ClientConfig) MarshalTo 

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

func (*ClientConfig) MarshalToSizedBuffer 

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

func (*ClientConfig) ProtoMessage 

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset 

func (m *ClientConfig) Reset()

func (*ClientConfig) Size 

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

func (*ClientConfig) String 

func (this *ClientConfig) String() string

func (*ClientConfig) Unmarshal 

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

func (*ClientConfig) XXX_DiscardUnknown 

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal 

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

func (*ClientConfig) XXX_Merge 

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

func (*ClientConfig) XXX_Size 

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal 

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

type DispatchPolicy 

type DispatchPolicy struct {
	// Specifies a load balancing method for a server group
	Strategy Strategy `json:"strategy,omitempty" protobuf:"bytes,1,opt,name=strategy,casttype=Strategy"`

	// UpstreamSubset indacates to the list of upstream endpoints. An empty set
	// means use all upstreams
	// +optional
	UpstreamSubset []string `json:"upstreamSubset,omitempty" protobuf:"bytes,2,rep,name=upstreamSubset"`

	// Rules holds all the DispatchPolicyRules for this policy
	// Gateway matches rules according to the list order, the previous rules
	// take higher precedence
	// +optional
	Rules []DispatchPolicyRule `json:"rules,omitempty" protobuf:"bytes,3,rep,name=rules"`

	// FlowControlSchemaName indicates to which flow control schema in spec.FlowControl will
	// take effect on this prolicy
	// If not set, there is no limit
	// +optional
	FlowControlSchemaName string `json:"flowControlSchemaName,omitempty" protobuf:"bytes,4,opt,name=flowControlSchemaName"`

	// dispatch policy level access log mode
	// - if set to off, all access logs of requests matching this policy will be disabled.
	// - if set to on, access logs will be enabled when spec.Logging.Mode is "on" or ""
	// - if set to unset, the logging is controlled by spec.Logging.Mode
	// +optional
	LogMode LogMode `json:"logMode,omitempty" protobuf:"bytes,5,opt,name=logMode,casttype=LogMode"`
}

func (*DispatchPolicy) DeepCopy 

func (in *DispatchPolicy) DeepCopy() *DispatchPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DispatchPolicy.

func (*DispatchPolicy) DeepCopyInto 

func (in *DispatchPolicy) DeepCopyInto(out *DispatchPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DispatchPolicy) Descriptor 

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

func (*DispatchPolicy) Marshal 

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

func (*DispatchPolicy) MarshalTo 

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

func (*DispatchPolicy) MarshalToSizedBuffer 

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

func (*DispatchPolicy) ProtoMessage 

func (*DispatchPolicy) ProtoMessage()

func (*DispatchPolicy) Reset 

func (m *DispatchPolicy) Reset()

func (*DispatchPolicy) Size 

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

func (*DispatchPolicy) String 

func (this *DispatchPolicy) String() string

func (*DispatchPolicy) Unmarshal 

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

func (*DispatchPolicy) XXX_DiscardUnknown 

func (m *DispatchPolicy) XXX_DiscardUnknown()

func (*DispatchPolicy) XXX_Marshal 

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

func (*DispatchPolicy) XXX_Merge 

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

func (*DispatchPolicy) XXX_Size 

func (m *DispatchPolicy) XXX_Size() int

func (*DispatchPolicy) XXX_Unmarshal 

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

type DispatchPolicyRule 

type DispatchPolicyRule struct {
	// Verbs is a list of Verbs that apply to ALL the ResourceKinds and AttributeRestrictions contained in this rule.
	// - "*" represents all Verbs.
	// - An empty set mains that nothing is allowed.
	// - use '-' prefix to invert verbs matching, e.g. "-get" means match all verbs except "get"
	Verbs []string `json:"verbs,omitempty" protobuf:"bytes,1,rep,name=verbs"`

	// APIGroups is the name of the APIGroup that contains the resources.  If multiple API groups are specified, any action requested against one of
	// the enumerated resources in any API group will be allowed.
	// - "*" represents all APIGroups.
	// - An empty set mains that nothing is allowed.
	// - use '-' prefix to invert apiGroups matching, e.g. "-apps" means match all apiGroups except "apps"
	APIGroups []string `json:"apiGroups,omitempty" protobuf:"bytes,2,rep,name=apiGroups"`

	// Resources is a list of resources this rule applies to.
	// - "*" represents all Resources.
	// - An empty set mains that nothing is allowed.
	// - use "{resource}/{subresource}" to match one resource's subresource
	// - use "*/{subresource}" to match all resources' subresource, but "{resource}/*" is not allowed.
	// - use '-' prefix to invert resources matching, e.g. "-deployments" means match all resources except "deployments".
	Resources []string `json:"resources,omitempty" protobuf:"bytes,3,rep,name=resources"`

	// ResourceNames is an optional white list of names that the rule applies to.
	// - "*" represents all ResourceNames.
	// - An empty set means that everything is allowed.
	// - use '-' prefix to invert resourceNames matching, e.g. "-nginx" means match all resourceNames except "nginx"
	// +optional
	ResourceNames []string `json:"resourceNames,omitempty" protobuf:"bytes,4,rep,name=resourceNames"`

	// Users is a list of users this rule applies to.
	// - "*" represents all Users.
	// - if ServiceAccounts is empty, an empty set means that everything is allowed, otherwise it means nothing is allowed.
	// use '-' prefix to invert users matching, e.g. "-admin" means match all users except "admin"
	// +optional
	Users []string `json:"users,omitempty" protobuf:"bytes,5,rep,name=users"`

	// ServiceAccounts is a list of serviceAccont users this rule applies to. It can be covered if Users matches all.
	// - ServiceAccounts can not use invert matching
	// - if Users is empty, an empty set mains that nothing is allowed, otherwise it means nothing is allowed.
	// - serviceAccount name and namespace must be set
	// +optional
	ServiceAccounts []ServiceAccountRef `json:"serviceAccounts,omitempty" protobuf:"bytes,6,rep,name=serviceAccounts"`

	// UserGroups is a list of users groups this rule applies to. UserGroupAll represents all user groups.
	// - "*" represents all UserGroups.
	// - An empty set means that everything is allowed.
	// - use '-' prefix to invert userGroups matching, e.g. "-system:controllers" means match all userGroups except "system:controllers"
	// +optional
	UserGroups []string `json:"userGroups,omitempty" protobuf:"bytes,7,rep,name=userGroups"`

	// NonResourceURLs is a set of partial urls that a user should have access to.  *s are allowed, but only as the full, final step in the path
	// Since non-resource URLs are not namespaced, this field is only applicable for ClusterRoles referenced from a ClusterRoleBinding.
	// Rules can either apply to API resources (such as "pods"or "secrets") or non-resource URL paths (such as "/api"),  but not both.
	// - "*" represents all NonResourceURLs.
	// - An empty set mains that nothing is allowed.
	// - NonResourceURLs can not use invert matching
	NonResourceURLs []string `json:"nonResourceURLs,omitempty" protobuf:"bytes,8,rep,name=nonResourceURLs"`
}

DispatchPolicyRule holds information that describes a policy rule

func (*DispatchPolicyRule) DeepCopy 

func (in *DispatchPolicyRule) DeepCopy() *DispatchPolicyRule

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DispatchPolicyRule.

func (*DispatchPolicyRule) DeepCopyInto 

func (in *DispatchPolicyRule) DeepCopyInto(out *DispatchPolicyRule)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DispatchPolicyRule) Descriptor 

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

func (*DispatchPolicyRule) Marshal 

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

func (*DispatchPolicyRule) MarshalTo 

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

func (*DispatchPolicyRule) MarshalToSizedBuffer 

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

func (*DispatchPolicyRule) ProtoMessage 

func (*DispatchPolicyRule) ProtoMessage()

func (*DispatchPolicyRule) Reset 

func (m *DispatchPolicyRule) Reset()

func (*DispatchPolicyRule) Size 

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

func (*DispatchPolicyRule) String 

func (this *DispatchPolicyRule) String() string

func (*DispatchPolicyRule) Unmarshal 

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

func (*DispatchPolicyRule) XXX_DiscardUnknown 

func (m *DispatchPolicyRule) XXX_DiscardUnknown()

func (*DispatchPolicyRule) XXX_Marshal 

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

func (*DispatchPolicyRule) XXX_Merge 

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

func (*DispatchPolicyRule) XXX_Size 

func (m *DispatchPolicyRule) XXX_Size() int

func (*DispatchPolicyRule) XXX_Unmarshal 

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

type EndpointInfo 

type EndpointInfo struct {
	Leader     string      `json:"Leader,omitempty" protobuf:"bytes,1,opt,name=Leader"`
	ShardID    int32       `json:"shardID" protobuf:"varint,2,opt,name=shardID"`
	LastChange metav1.Time `json:"lastHeartbeat,omitempty" protobuf:"bytes,3,opt,name=lastHeartbeat"`
}

func (*EndpointInfo) DeepCopy 

func (in *EndpointInfo) DeepCopy() *EndpointInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointInfo.

func (*EndpointInfo) DeepCopyInto 

func (in *EndpointInfo) DeepCopyInto(out *EndpointInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EndpointInfo) Descriptor 

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

func (*EndpointInfo) Marshal 

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

func (*EndpointInfo) MarshalTo 

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

func (*EndpointInfo) MarshalToSizedBuffer 

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

func (*EndpointInfo) ProtoMessage 

func (*EndpointInfo) ProtoMessage()

func (*EndpointInfo) Reset 

func (m *EndpointInfo) Reset()

func (*EndpointInfo) Size 

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

func (*EndpointInfo) String 

func (this *EndpointInfo) String() string

func (*EndpointInfo) Unmarshal 

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

func (*EndpointInfo) XXX_DiscardUnknown 

func (m *EndpointInfo) XXX_DiscardUnknown()

func (*EndpointInfo) XXX_Marshal 

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

func (*EndpointInfo) XXX_Merge 

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

func (*EndpointInfo) XXX_Size 

func (m *EndpointInfo) XXX_Size() int

func (*EndpointInfo) XXX_Unmarshal 

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

type ExemptFlowControlSchema 

type ExemptFlowControlSchema struct {
}

Represents no limit flow control.

func (*ExemptFlowControlSchema) DeepCopy 

func (in *ExemptFlowControlSchema) DeepCopy() *ExemptFlowControlSchema

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExemptFlowControlSchema.

func (*ExemptFlowControlSchema) DeepCopyInto 

func (in *ExemptFlowControlSchema) DeepCopyInto(out *ExemptFlowControlSchema)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ExemptFlowControlSchema) Descriptor 

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

func (*ExemptFlowControlSchema) Marshal 

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

func (*ExemptFlowControlSchema) MarshalTo 

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

func (*ExemptFlowControlSchema) MarshalToSizedBuffer 

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

func (*ExemptFlowControlSchema) ProtoMessage 

func (*ExemptFlowControlSchema) ProtoMessage()

func (*ExemptFlowControlSchema) Reset 

func (m *ExemptFlowControlSchema) Reset()

func (*ExemptFlowControlSchema) Size 

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

func (*ExemptFlowControlSchema) String 

func (this *ExemptFlowControlSchema) String() string

func (*ExemptFlowControlSchema) Unmarshal 

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

func (*ExemptFlowControlSchema) XXX_DiscardUnknown 

func (m *ExemptFlowControlSchema) XXX_DiscardUnknown()

func (*ExemptFlowControlSchema) XXX_Marshal 

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

func (*ExemptFlowControlSchema) XXX_Merge 

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

func (*ExemptFlowControlSchema) XXX_Size 

func (m *ExemptFlowControlSchema) XXX_Size() int

func (*ExemptFlowControlSchema) XXX_Unmarshal 

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

type FlowControl 

type FlowControl struct {
	Schemas []FlowControlSchema `json:"flowControlSchemas,omitempty" protobuf:"bytes,1,rep,name=flowControlSchemas"`
}

func (*FlowControl) DeepCopy 

func (in *FlowControl) DeepCopy() *FlowControl

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlowControl.

func (*FlowControl) DeepCopyInto 

func (in *FlowControl) DeepCopyInto(out *FlowControl)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FlowControl) Descriptor 

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

func (*FlowControl) Marshal 

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

func (*FlowControl) MarshalTo 

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

func (*FlowControl) MarshalToSizedBuffer 

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

func (*FlowControl) ProtoMessage 

func (*FlowControl) ProtoMessage()

func (*FlowControl) Reset 

func (m *FlowControl) Reset()

func (*FlowControl) Size 

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

func (*FlowControl) String 

func (this *FlowControl) String() string

func (*FlowControl) Unmarshal 

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

func (*FlowControl) XXX_DiscardUnknown 

func (m *FlowControl) XXX_DiscardUnknown()

func (*FlowControl) XXX_Marshal 

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

func (*FlowControl) XXX_Merge 

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

func (*FlowControl) XXX_Size 

func (m *FlowControl) XXX_Size() int

func (*FlowControl) XXX_Unmarshal 

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

type FlowControlSchema 

type FlowControlSchema struct {
	// Schema name
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Schema config
	FlowControlSchemaConfiguration `json:",inline" protobuf:"bytes,2,opt,name=flowControlSchemaConfiguration"`

	Strategy LimitStrategy `json:"strategy,omitempty" protobuf:"varint,3,opt,name=strategy"`
}

func (*FlowControlSchema) DeepCopy 

func (in *FlowControlSchema) DeepCopy() *FlowControlSchema

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlowControlSchema.

func (*FlowControlSchema) DeepCopyInto 

func (in *FlowControlSchema) DeepCopyInto(out *FlowControlSchema)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FlowControlSchema) Descriptor 

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

func (*FlowControlSchema) Marshal 

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

func (*FlowControlSchema) MarshalTo 

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

func (*FlowControlSchema) MarshalToSizedBuffer 

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

func (*FlowControlSchema) ProtoMessage 

func (*FlowControlSchema) ProtoMessage()

func (*FlowControlSchema) Reset 

func (m *FlowControlSchema) Reset()

func (*FlowControlSchema) Size 

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

func (*FlowControlSchema) String 

func (this *FlowControlSchema) String() string

func (*FlowControlSchema) Unmarshal 

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

func (*FlowControlSchema) XXX_DiscardUnknown 

func (m *FlowControlSchema) XXX_DiscardUnknown()

func (*FlowControlSchema) XXX_Marshal 

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

func (*FlowControlSchema) XXX_Merge 

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

func (*FlowControlSchema) XXX_Size 

func (m *FlowControlSchema) XXX_Size() int

func (*FlowControlSchema) XXX_Unmarshal 

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

type FlowControlSchemaConfiguration 

type FlowControlSchemaConfiguration struct {
	// Exempt represents no limits on a flow.
	// +optianal
	Exempt *ExemptFlowControlSchema `json:"exempt,omitempty" protobuf:"bytes,1,opt,name=exempt"`
	// MaxRequestsInflight represents a maximum concurrent number of requests
	// in flight at a given time.
	// +optianal
	MaxRequestsInflight *MaxRequestsInflightFlowControlSchema `json:"maxRequestsInflight,omitempty" protobuf:"bytes,2,opt,name=maxRequestsInflight"`
	// TokenBucket represents a token bucket approach. The rate limiter allows bursts
	// of up to 'burst' to exceed the QPS, while still maintaining a smoothed qps
	// rate of 'qps'.
	// +optianal
	TokenBucket *TokenBucketFlowControlSchema `json:"tokenBucket,omitempty" protobuf:"bytes,3,opt,name=tokenBucket"`

	// GlobalMaxRequestsInflight represents a maximum global concurrent number of requests
	// in flight at a given time.
	// +optianal
	GlobalMaxRequestsInflight *MaxRequestsInflightFlowControlSchema `json:"globalMaxRequestsInflight,omitempty" protobuf:"bytes,4,opt,name=globalMaxRequestsInflight"`
	// GlobalTokenBucket represents a global token bucket approach. The rate limiter allows bursts
	// of up to 'burst' to exceed the QPS, while still maintaining a smoothed qps
	// rate of 'qps'.
	// +optianal
	GlobalTokenBucket *TokenBucketFlowControlSchema `json:"globalTokenBucket,omitempty" protobuf:"bytes,5,opt,name=globalTokenBucket"`
}

Represents the configuration of flow control schema Only one of its members may be specified

func (*FlowControlSchemaConfiguration) DeepCopy 

func (in *FlowControlSchemaConfiguration) DeepCopy() *FlowControlSchemaConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlowControlSchemaConfiguration.

func (*FlowControlSchemaConfiguration) DeepCopyInto 

func (in *FlowControlSchemaConfiguration) DeepCopyInto(out *FlowControlSchemaConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FlowControlSchemaConfiguration) Descriptor 

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

func (*FlowControlSchemaConfiguration) Marshal 

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

func (*FlowControlSchemaConfiguration) MarshalTo 

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

func (*FlowControlSchemaConfiguration) MarshalToSizedBuffer 

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

func (*FlowControlSchemaConfiguration) ProtoMessage 

func (*FlowControlSchemaConfiguration) ProtoMessage()

func (*FlowControlSchemaConfiguration) Reset 

func (m *FlowControlSchemaConfiguration) Reset()

func (*FlowControlSchemaConfiguration) Size 

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

func (*FlowControlSchemaConfiguration) String 

func (this *FlowControlSchemaConfiguration) String() string

func (*FlowControlSchemaConfiguration) Unmarshal 

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

func (*FlowControlSchemaConfiguration) XXX_DiscardUnknown 

func (m *FlowControlSchemaConfiguration) XXX_DiscardUnknown()

func (*FlowControlSchemaConfiguration) XXX_Marshal 

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

func (*FlowControlSchemaConfiguration) XXX_Merge 

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

func (*FlowControlSchemaConfiguration) XXX_Size 

func (m *FlowControlSchemaConfiguration) XXX_Size() int

func (*FlowControlSchemaConfiguration) XXX_Unmarshal 

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

type FlowControlSchemaType 

type FlowControlSchemaType string

Represents flow control schema type 

const (
	Unknown             FlowControlSchemaType = "Unknown"
	Exempt              FlowControlSchemaType = "Exempt"
	MaxRequestsInflight FlowControlSchemaType = "MaxRequestsInflight"
	TokenBucket         FlowControlSchemaType = "TokenBucket"
)

type LimitItemDetail 

type LimitItemDetail struct {
	// MaxRequestsInflight represents a maximum concurrent number of requests
	// in flight at a given time.
	// +optianal
	MaxRequestsInflight *MaxRequestsInflightFlowControlSchema `json:"maxRequestsInflight,omitempty" protobuf:"bytes,1,opt,name=maxRequestsInflight"`
	// TokenBucket represents a token bucket approach. The rate limiter allows bursts
	// of up to 'burst' to exceed the QPS, while still maintaining a smoothed qps
	// rate of 'qps'.
	// +optianal
	TokenBucket *TokenBucketFlowControlSchema `json:"tokenBucket,omitempty" protobuf:"bytes,2,opt,name=tokenBucket"`
}

Represents token bucket rate limit approach.

func (*LimitItemDetail) DeepCopy 

func (in *LimitItemDetail) DeepCopy() *LimitItemDetail

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LimitItemDetail.

func (*LimitItemDetail) DeepCopyInto 

func (in *LimitItemDetail) DeepCopyInto(out *LimitItemDetail)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LimitItemDetail) Descriptor 

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

func (*LimitItemDetail) Marshal 

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

func (*LimitItemDetail) MarshalTo 

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

func (*LimitItemDetail) MarshalToSizedBuffer 

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

func (*LimitItemDetail) ProtoMessage 

func (*LimitItemDetail) ProtoMessage()

func (*LimitItemDetail) Reset 

func (m *LimitItemDetail) Reset()

func (*LimitItemDetail) Size 

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

func (*LimitItemDetail) String 

func (this *LimitItemDetail) String() string

func (*LimitItemDetail) Unmarshal 

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

func (*LimitItemDetail) XXX_DiscardUnknown 

func (m *LimitItemDetail) XXX_DiscardUnknown()

func (*LimitItemDetail) XXX_Marshal 

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

func (*LimitItemDetail) XXX_Merge 

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

func (*LimitItemDetail) XXX_Size 

func (m *LimitItemDetail) XXX_Size() int

func (*LimitItemDetail) XXX_Unmarshal 

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

type LimitStrategy 

type LimitStrategy string
const (
	LocalLimit          LimitStrategy = "local"
	GlobalAllocateLimit LimitStrategy = "globalAllocate"
	GlobalCountLimit    LimitStrategy = "globalCount"
)

type LogMode 

type LogMode string
const (
	// LogOn enable access log
	LogOn LogMode = "on"
	// LogOff disable access log
	LogOff LogMode = "off"
)

type LoggingConfig 

type LoggingConfig struct {
	// upstream cluster level log mode
	// - if set to off, all access logs of requests to this cluster will be disabled.
	// - if set to on, access logs of requests to this cluster will be enabled. But it
	//   can be override by dispatchPolicy.LogMode
	// - if unset, the logging is controlled by dispatchPolicy.LogMode
	Mode LogMode `json:"mode,omitempty" protobuf:"bytes,1,opt,name=mode,casttype=LogMode"`
}

func (*LoggingConfig) DeepCopy 

func (in *LoggingConfig) DeepCopy() *LoggingConfig

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingConfig.

func (*LoggingConfig) DeepCopyInto 

func (in *LoggingConfig) DeepCopyInto(out *LoggingConfig)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*LoggingConfig) Descriptor 

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

func (*LoggingConfig) Marshal 

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

func (*LoggingConfig) MarshalTo 

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

func (*LoggingConfig) MarshalToSizedBuffer 

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

func (*LoggingConfig) ProtoMessage 

func (*LoggingConfig) ProtoMessage()

func (*LoggingConfig) Reset 

func (m *LoggingConfig) Reset()

func (*LoggingConfig) Size 

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

func (*LoggingConfig) String 

func (this *LoggingConfig) String() string

func (*LoggingConfig) Unmarshal 

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

func (*LoggingConfig) XXX_DiscardUnknown 

func (m *LoggingConfig) XXX_DiscardUnknown()

func (*LoggingConfig) XXX_Marshal 

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

func (*LoggingConfig) XXX_Merge 

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

func (*LoggingConfig) XXX_Size 

func (m *LoggingConfig) XXX_Size() int

func (*LoggingConfig) XXX_Unmarshal 

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

type MaxRequestsInflightFlowControlSchema 

type MaxRequestsInflightFlowControlSchema struct {
	// maximum concurrent number of requests
	Max int32 `json:"max,omitempty" protobuf:"varint,1,opt,name=max"`
}

Represents a maximum concurrent number of requests in flight at a given time.

func (*MaxRequestsInflightFlowControlSchema) DeepCopy 

func (in *MaxRequestsInflightFlowControlSchema) DeepCopy() *MaxRequestsInflightFlowControlSchema

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MaxRequestsInflightFlowControlSchema.

func (*MaxRequestsInflightFlowControlSchema) DeepCopyInto 

func (in *MaxRequestsInflightFlowControlSchema) DeepCopyInto(out *MaxRequestsInflightFlowControlSchema)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MaxRequestsInflightFlowControlSchema) Descriptor 

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

func (*MaxRequestsInflightFlowControlSchema) Marshal 

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

func (*MaxRequestsInflightFlowControlSchema) MarshalTo 

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

func (*MaxRequestsInflightFlowControlSchema) MarshalToSizedBuffer 

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

func (*MaxRequestsInflightFlowControlSchema) ProtoMessage 

func (*MaxRequestsInflightFlowControlSchema) ProtoMessage()

func (*MaxRequestsInflightFlowControlSchema) Reset 

func (m *MaxRequestsInflightFlowControlSchema) Reset()

func (*MaxRequestsInflightFlowControlSchema) Size 

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

func (*MaxRequestsInflightFlowControlSchema) String 

func (this *MaxRequestsInflightFlowControlSchema) String() string

func (*MaxRequestsInflightFlowControlSchema) Unmarshal 

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

func (*MaxRequestsInflightFlowControlSchema) XXX_DiscardUnknown 

func (m *MaxRequestsInflightFlowControlSchema) XXX_DiscardUnknown()

func (*MaxRequestsInflightFlowControlSchema) XXX_Marshal 

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

func (*MaxRequestsInflightFlowControlSchema) XXX_Merge 

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

func (*MaxRequestsInflightFlowControlSchema) XXX_Size 

func (m *MaxRequestsInflightFlowControlSchema) XXX_Size() int

func (*MaxRequestsInflightFlowControlSchema) XXX_Unmarshal 

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

type RateLimitAcquire 

type RateLimitAcquire struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   RateLimitAcquireSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status RateLimitAcquireStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

RateLimitAcquire represents a acquire request for a resource.

func (*RateLimitAcquire) DeepCopy 

func (in *RateLimitAcquire) DeepCopy() *RateLimitAcquire

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitAcquire.

func (*RateLimitAcquire) DeepCopyInto 

func (in *RateLimitAcquire) DeepCopyInto(out *RateLimitAcquire)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitAcquire) DeepCopyObject 

func (in *RateLimitAcquire) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*RateLimitAcquire) Descriptor 

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

func (*RateLimitAcquire) Marshal 

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

func (*RateLimitAcquire) MarshalTo 

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

func (*RateLimitAcquire) MarshalToSizedBuffer 

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

func (*RateLimitAcquire) ProtoMessage 

func (*RateLimitAcquire) ProtoMessage()

func (*RateLimitAcquire) Reset 

func (m *RateLimitAcquire) Reset()

func (*RateLimitAcquire) Size 

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

func (*RateLimitAcquire) String 

func (this *RateLimitAcquire) String() string

func (*RateLimitAcquire) Unmarshal 

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

func (*RateLimitAcquire) XXX_DiscardUnknown 

func (m *RateLimitAcquire) XXX_DiscardUnknown()

func (*RateLimitAcquire) XXX_Marshal 

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

func (*RateLimitAcquire) XXX_Merge 

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

func (*RateLimitAcquire) XXX_Size 

func (m *RateLimitAcquire) XXX_Size() int

func (*RateLimitAcquire) XXX_Unmarshal 

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

type RateLimitAcquireRequest 

type RateLimitAcquireRequest struct {
	FlowControl string `json:"flowControl,omitempty" protobuf:"bytes,1,opt,name=flowControl"`
	// Limit tokens required of this flowcontrol
	Tokens int32 `json:"tokens,omitempty" protobuf:"bytes,2,opt,name=tokens"`
}

func (*RateLimitAcquireRequest) DeepCopy 

func (in *RateLimitAcquireRequest) DeepCopy() *RateLimitAcquireRequest

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitAcquireRequest.

func (*RateLimitAcquireRequest) DeepCopyInto 

func (in *RateLimitAcquireRequest) DeepCopyInto(out *RateLimitAcquireRequest)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitAcquireRequest) Descriptor 

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

func (*RateLimitAcquireRequest) Marshal 

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

func (*RateLimitAcquireRequest) MarshalTo 

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

func (*RateLimitAcquireRequest) MarshalToSizedBuffer 

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

func (*RateLimitAcquireRequest) ProtoMessage 

func (*RateLimitAcquireRequest) ProtoMessage()

func (*RateLimitAcquireRequest) Reset 

func (m *RateLimitAcquireRequest) Reset()

func (*RateLimitAcquireRequest) Size 

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

func (*RateLimitAcquireRequest) String 

func (this *RateLimitAcquireRequest) String() string

func (*RateLimitAcquireRequest) Unmarshal 

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

func (*RateLimitAcquireRequest) XXX_DiscardUnknown 

func (m *RateLimitAcquireRequest) XXX_DiscardUnknown()

func (*RateLimitAcquireRequest) XXX_Marshal 

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

func (*RateLimitAcquireRequest) XXX_Merge 

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

func (*RateLimitAcquireRequest) XXX_Size 

func (m *RateLimitAcquireRequest) XXX_Size() int

func (*RateLimitAcquireRequest) XXX_Unmarshal 

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

type RateLimitAcquireResult 

type RateLimitAcquireResult struct {
	FlowControl string `json:"flowControl,omitempty" protobuf:"bytes,1,opt,name=flowControl"`
	Accept      bool   `json:"accept" protobuf:"bytes,2,opt,name=accept"`
	Limit       int32  `json:"limit" protobuf:"bytes,3,opt,name=limit"`
	Error       string `json:"error,omitempty" protobuf:"bytes,4,opt,name=error"`
}

func (*RateLimitAcquireResult) DeepCopy 

func (in *RateLimitAcquireResult) DeepCopy() *RateLimitAcquireResult

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitAcquireResult.

func (*RateLimitAcquireResult) DeepCopyInto 

func (in *RateLimitAcquireResult) DeepCopyInto(out *RateLimitAcquireResult)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitAcquireResult) Descriptor 

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

func (*RateLimitAcquireResult) Marshal 

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

func (*RateLimitAcquireResult) MarshalTo 

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

func (*RateLimitAcquireResult) MarshalToSizedBuffer 

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

func (*RateLimitAcquireResult) ProtoMessage 

func (*RateLimitAcquireResult) ProtoMessage()

func (*RateLimitAcquireResult) Reset 

func (m *RateLimitAcquireResult) Reset()

func (*RateLimitAcquireResult) Size 

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

func (*RateLimitAcquireResult) String 

func (this *RateLimitAcquireResult) String() string

func (*RateLimitAcquireResult) Unmarshal 

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

func (*RateLimitAcquireResult) XXX_DiscardUnknown 

func (m *RateLimitAcquireResult) XXX_DiscardUnknown()

func (*RateLimitAcquireResult) XXX_Marshal 

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

func (*RateLimitAcquireResult) XXX_Merge 

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

func (*RateLimitAcquireResult) XXX_Size 

func (m *RateLimitAcquireResult) XXX_Size() int

func (*RateLimitAcquireResult) XXX_Unmarshal 

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

type RateLimitAcquireSpec 

type RateLimitAcquireSpec struct {
	// Rate limit client instance identity
	Instance string `json:"instance,omitempty" protobuf:"bytes,1,opt,name=instance"`
	// Limit tokens requested
	Requests []RateLimitAcquireRequest `json:"requests,omitempty" protobuf:"bytes,2,opt,name=requests"`
	// Request id
	RequestID int64 `json:"requestID,omitempty" protobuf:"bytes,3,opt,name=requestID"`
}

RateLimitAcquireSpec defines the request body for acquire

func (*RateLimitAcquireSpec) DeepCopy 

func (in *RateLimitAcquireSpec) DeepCopy() *RateLimitAcquireSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitAcquireSpec.

func (*RateLimitAcquireSpec) DeepCopyInto 

func (in *RateLimitAcquireSpec) DeepCopyInto(out *RateLimitAcquireSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitAcquireSpec) Descriptor 

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

func (*RateLimitAcquireSpec) Marshal 

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

func (*RateLimitAcquireSpec) MarshalTo 

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

func (*RateLimitAcquireSpec) MarshalToSizedBuffer 

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

func (*RateLimitAcquireSpec) ProtoMessage 

func (*RateLimitAcquireSpec) ProtoMessage()

func (*RateLimitAcquireSpec) Reset 

func (m *RateLimitAcquireSpec) Reset()

func (*RateLimitAcquireSpec) Size 

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

func (*RateLimitAcquireSpec) String 

func (this *RateLimitAcquireSpec) String() string

func (*RateLimitAcquireSpec) Unmarshal 

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

func (*RateLimitAcquireSpec) XXX_DiscardUnknown 

func (m *RateLimitAcquireSpec) XXX_DiscardUnknown()

func (*RateLimitAcquireSpec) XXX_Marshal 

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

func (*RateLimitAcquireSpec) XXX_Merge 

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

func (*RateLimitAcquireSpec) XXX_Size 

func (m *RateLimitAcquireSpec) XXX_Size() int

func (*RateLimitAcquireSpec) XXX_Unmarshal 

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

type RateLimitAcquireStatus 

type RateLimitAcquireStatus struct {
	Results []RateLimitAcquireResult `json:"results,omitempty" protobuf:"bytes,1,opt,name=results"`
}

RateLimitAcquireStatus defines the response body for acquire

func (*RateLimitAcquireStatus) DeepCopy 

func (in *RateLimitAcquireStatus) DeepCopy() *RateLimitAcquireStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitAcquireStatus.

func (*RateLimitAcquireStatus) DeepCopyInto 

func (in *RateLimitAcquireStatus) DeepCopyInto(out *RateLimitAcquireStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitAcquireStatus) Descriptor 

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

func (*RateLimitAcquireStatus) Marshal 

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

func (*RateLimitAcquireStatus) MarshalTo 

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

func (*RateLimitAcquireStatus) MarshalToSizedBuffer 

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

func (*RateLimitAcquireStatus) ProtoMessage 

func (*RateLimitAcquireStatus) ProtoMessage()

func (*RateLimitAcquireStatus) Reset 

func (m *RateLimitAcquireStatus) Reset()

func (*RateLimitAcquireStatus) Size 

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

func (*RateLimitAcquireStatus) String 

func (this *RateLimitAcquireStatus) String() string

func (*RateLimitAcquireStatus) Unmarshal 

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

func (*RateLimitAcquireStatus) XXX_DiscardUnknown 

func (m *RateLimitAcquireStatus) XXX_DiscardUnknown()

func (*RateLimitAcquireStatus) XXX_Marshal 

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

func (*RateLimitAcquireStatus) XXX_Merge 

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

func (*RateLimitAcquireStatus) XXX_Size 

func (m *RateLimitAcquireStatus) XXX_Size() int

func (*RateLimitAcquireStatus) XXX_Unmarshal 

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

type RateLimitCondition 

type RateLimitCondition struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   RateLimitSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status RateLimitStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

RateLimitCondition is the Schema for the upstreamclusters API

func (*RateLimitCondition) DeepCopy 

func (in *RateLimitCondition) DeepCopy() *RateLimitCondition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitCondition.

func (*RateLimitCondition) DeepCopyInto 

func (in *RateLimitCondition) DeepCopyInto(out *RateLimitCondition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitCondition) DeepCopyObject 

func (in *RateLimitCondition) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*RateLimitCondition) Descriptor 

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

func (*RateLimitCondition) Marshal 

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

func (*RateLimitCondition) MarshalTo 

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

func (*RateLimitCondition) MarshalToSizedBuffer 

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

func (*RateLimitCondition) ProtoMessage 

func (*RateLimitCondition) ProtoMessage()

func (*RateLimitCondition) Reset 

func (m *RateLimitCondition) Reset()

func (*RateLimitCondition) Size 

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

func (*RateLimitCondition) String 

func (this *RateLimitCondition) String() string

func (*RateLimitCondition) Unmarshal 

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

func (*RateLimitCondition) XXX_DiscardUnknown 

func (m *RateLimitCondition) XXX_DiscardUnknown()

func (*RateLimitCondition) XXX_Marshal 

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

func (*RateLimitCondition) XXX_Merge 

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

func (*RateLimitCondition) XXX_Size 

func (m *RateLimitCondition) XXX_Size() int

func (*RateLimitCondition) XXX_Unmarshal 

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

type RateLimitConditionList 

type RateLimitConditionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []RateLimitCondition `json:"items" protobuf:"bytes,2,rep,name=items"`
}

RateLimitConditionList contains a list of RateLimitCondition

func (*RateLimitConditionList) DeepCopy 

func (in *RateLimitConditionList) DeepCopy() *RateLimitConditionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitConditionList.

func (*RateLimitConditionList) DeepCopyInto 

func (in *RateLimitConditionList) DeepCopyInto(out *RateLimitConditionList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitConditionList) DeepCopyObject 

func (in *RateLimitConditionList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*RateLimitConditionList) Descriptor 

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

func (*RateLimitConditionList) Marshal 

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

func (*RateLimitConditionList) MarshalTo 

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

func (*RateLimitConditionList) MarshalToSizedBuffer 

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

func (*RateLimitConditionList) ProtoMessage 

func (*RateLimitConditionList) ProtoMessage()

func (*RateLimitConditionList) Reset 

func (m *RateLimitConditionList) Reset()

func (*RateLimitConditionList) Size 

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

func (*RateLimitConditionList) String 

func (this *RateLimitConditionList) String() string

func (*RateLimitConditionList) Unmarshal 

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

func (*RateLimitConditionList) XXX_DiscardUnknown 

func (m *RateLimitConditionList) XXX_DiscardUnknown()

func (*RateLimitConditionList) XXX_Marshal 

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

func (*RateLimitConditionList) XXX_Merge 

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

func (*RateLimitConditionList) XXX_Size 

func (m *RateLimitConditionList) XXX_Size() int

func (*RateLimitConditionList) XXX_Unmarshal 

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

type RateLimitItemConfiguration 

type RateLimitItemConfiguration struct {
	// Schema name
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`

	// Expect limit config detail
	LimitItemDetail `json:",inline" protobuf:"bytes,2,opt,name=expect"`

	Strategy LimitStrategy `json:"strategy,omitempty" protobuf:"varint,3,opt,name=strategy"`
}

func (*RateLimitItemConfiguration) DeepCopy 

func (in *RateLimitItemConfiguration) DeepCopy() *RateLimitItemConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitItemConfiguration.

func (*RateLimitItemConfiguration) DeepCopyInto 

func (in *RateLimitItemConfiguration) DeepCopyInto(out *RateLimitItemConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitItemConfiguration) Descriptor 

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

func (*RateLimitItemConfiguration) Marshal 

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

func (*RateLimitItemConfiguration) MarshalTo 

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

func (*RateLimitItemConfiguration) MarshalToSizedBuffer 

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

func (*RateLimitItemConfiguration) ProtoMessage 

func (*RateLimitItemConfiguration) ProtoMessage()

func (*RateLimitItemConfiguration) Reset 

func (m *RateLimitItemConfiguration) Reset()

func (*RateLimitItemConfiguration) Size 

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

func (*RateLimitItemConfiguration) String 

func (this *RateLimitItemConfiguration) String() string

func (*RateLimitItemConfiguration) Unmarshal 

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

func (*RateLimitItemConfiguration) XXX_DiscardUnknown 

func (m *RateLimitItemConfiguration) XXX_DiscardUnknown()

func (*RateLimitItemConfiguration) XXX_Marshal 

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

func (*RateLimitItemConfiguration) XXX_Merge 

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

func (*RateLimitItemConfiguration) XXX_Size 

func (m *RateLimitItemConfiguration) XXX_Size() int

func (*RateLimitItemConfiguration) XXX_Unmarshal 

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

type RateLimitItemStatus 

type RateLimitItemStatus struct {
	// Schema name
	Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	// Current limit status detail
	LimitItemDetail `json:",inline" protobuf:"bytes,2,opt,name=current"`

	// percent of ( actual requests / limit threshold )
	RequestLevel int32 `json:"requestLevel,omitempty" protobuf:"bytes,3,opt,name=requestLevel"`
}

func (*RateLimitItemStatus) DeepCopy 

func (in *RateLimitItemStatus) DeepCopy() *RateLimitItemStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitItemStatus.

func (*RateLimitItemStatus) DeepCopyInto 

func (in *RateLimitItemStatus) DeepCopyInto(out *RateLimitItemStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitItemStatus) Descriptor 

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

func (*RateLimitItemStatus) Marshal 

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

func (*RateLimitItemStatus) MarshalTo 

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

func (*RateLimitItemStatus) MarshalToSizedBuffer 

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

func (*RateLimitItemStatus) ProtoMessage 

func (*RateLimitItemStatus) ProtoMessage()

func (*RateLimitItemStatus) Reset 

func (m *RateLimitItemStatus) Reset()

func (*RateLimitItemStatus) Size 

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

func (*RateLimitItemStatus) String 

func (this *RateLimitItemStatus) String() string

func (*RateLimitItemStatus) Unmarshal 

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

func (*RateLimitItemStatus) XXX_DiscardUnknown 

func (m *RateLimitItemStatus) XXX_DiscardUnknown()

func (*RateLimitItemStatus) XXX_Marshal 

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

func (*RateLimitItemStatus) XXX_Merge 

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

func (*RateLimitItemStatus) XXX_Size 

func (m *RateLimitItemStatus) XXX_Size() int

func (*RateLimitItemStatus) XXX_Unmarshal 

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

type RateLimitServerInfo 

type RateLimitServerInfo struct {
	Server        string         `json:"server,omitempty" protobuf:"bytes,1,opt,name=server"`
	ID            string         `json:"id,omitempty" protobuf:"bytes,2,opt,name=id"`
	Version       string         `json:"version,omitempty" protobuf:"bytes,3,opt,name=version"`
	ShardCount    int32          `json:"shardCount,omitempty" protobuf:"bytes,4,opt,name=shardCount"`
	ManagedShards []int32        `json:"managedShards,omitempty" protobuf:"bytes,5,opt,name=managedShards"`
	Endpoints     []EndpointInfo `json:"endpoints,omitempty" protobuf:"bytes,6,rep,name=endpoints"`
}

func (*RateLimitServerInfo) DeepCopy 

func (in *RateLimitServerInfo) DeepCopy() *RateLimitServerInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitServerInfo.

func (*RateLimitServerInfo) DeepCopyInto 

func (in *RateLimitServerInfo) DeepCopyInto(out *RateLimitServerInfo)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitServerInfo) Descriptor 

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

func (*RateLimitServerInfo) Marshal 

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

func (*RateLimitServerInfo) MarshalTo 

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

func (*RateLimitServerInfo) MarshalToSizedBuffer 

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

func (*RateLimitServerInfo) ProtoMessage 

func (*RateLimitServerInfo) ProtoMessage()

func (*RateLimitServerInfo) Reset 

func (m *RateLimitServerInfo) Reset()

func (*RateLimitServerInfo) Size 

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

func (*RateLimitServerInfo) String 

func (this *RateLimitServerInfo) String() string

func (*RateLimitServerInfo) Unmarshal 

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

func (*RateLimitServerInfo) XXX_DiscardUnknown 

func (m *RateLimitServerInfo) XXX_DiscardUnknown()

func (*RateLimitServerInfo) XXX_Marshal 

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

func (*RateLimitServerInfo) XXX_Merge 

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

func (*RateLimitServerInfo) XXX_Size 

func (m *RateLimitServerInfo) XXX_Size() int

func (*RateLimitServerInfo) XXX_Unmarshal 

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

type RateLimitSpec 

type RateLimitSpec struct {
	// All rate limit requests must specify a upstreamCluster.
	UpstreamCluster string `json:"upstreamCluster,omitempty" protobuf:"bytes,1,opt,name=upstreamCluster"`

	// Rate limit client instance identity
	Instance string `json:"instance,omitempty" protobuf:"bytes,2,opt,name=instance"`

	// Client flow control settings, e.g. qps and burst
	LimitItemConfigurations []RateLimitItemConfiguration `json:"limitItemConfigurations,omitempty" protobuf:"bytes,3,opt,name=limitItemConfigurations"`
}

RateLimitSpec defines the expect rate limit state of UpstreamCluster

func (*RateLimitSpec) DeepCopy 

func (in *RateLimitSpec) DeepCopy() *RateLimitSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitSpec.

func (*RateLimitSpec) DeepCopyInto 

func (in *RateLimitSpec) DeepCopyInto(out *RateLimitSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitSpec) Descriptor 

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

func (*RateLimitSpec) Marshal 

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

func (*RateLimitSpec) MarshalTo 

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

func (*RateLimitSpec) MarshalToSizedBuffer 

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

func (*RateLimitSpec) ProtoMessage 

func (*RateLimitSpec) ProtoMessage()

func (*RateLimitSpec) Reset 

func (m *RateLimitSpec) Reset()

func (*RateLimitSpec) Size 

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

func (*RateLimitSpec) String 

func (this *RateLimitSpec) String() string

func (*RateLimitSpec) Unmarshal 

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

func (*RateLimitSpec) XXX_DiscardUnknown 

func (m *RateLimitSpec) XXX_DiscardUnknown()

func (*RateLimitSpec) XXX_Marshal 

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

func (*RateLimitSpec) XXX_Merge 

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

func (*RateLimitSpec) XXX_Size 

func (m *RateLimitSpec) XXX_Size() int

func (*RateLimitSpec) XXX_Unmarshal 

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

type RateLimitStatus 

type RateLimitStatus struct {
	// Client flow control settings, e.g. qps and burst
	LimitItemStatuses []RateLimitItemStatus `json:"limitItemStatuses,omitempty" protobuf:"bytes,1,opt,name=limitItemStatuses"`
}

RateLimitStatus defines the rate limit state of UpstreamCluster

func (*RateLimitStatus) DeepCopy 

func (in *RateLimitStatus) DeepCopy() *RateLimitStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitStatus.

func (*RateLimitStatus) DeepCopyInto 

func (in *RateLimitStatus) DeepCopyInto(out *RateLimitStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*RateLimitStatus) Descriptor 

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

func (*RateLimitStatus) Marshal 

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

func (*RateLimitStatus) MarshalTo 

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

func (*RateLimitStatus) MarshalToSizedBuffer 

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

func (*RateLimitStatus) ProtoMessage 

func (*RateLimitStatus) ProtoMessage()

func (*RateLimitStatus) Reset 

func (m *RateLimitStatus) Reset()

func (*RateLimitStatus) Size 

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

func (*RateLimitStatus) String 

func (this *RateLimitStatus) String() string

func (*RateLimitStatus) Unmarshal 

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

func (*RateLimitStatus) XXX_DiscardUnknown 

func (m *RateLimitStatus) XXX_DiscardUnknown()

func (*RateLimitStatus) XXX_Marshal 

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

func (*RateLimitStatus) XXX_Merge 

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

func (*RateLimitStatus) XXX_Size 

func (m *RateLimitStatus) XXX_Size() int

func (*RateLimitStatus) XXX_Unmarshal 

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

type SecretReferecence 

type SecretReferecence struct {
	// `namespace` is the namespace of the secret.
	// Required
	Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"`
	// `name` is the name of the secret.
	// Required
	Name string `json:"name" protobuf:"bytes,2,opt,name=name"`
}

func (*SecretReferecence) DeepCopy 

func (in *SecretReferecence) DeepCopy() *SecretReferecence

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretReferecence.

func (*SecretReferecence) DeepCopyInto 

func (in *SecretReferecence) DeepCopyInto(out *SecretReferecence)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SecretReferecence) Descriptor 

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

func (*SecretReferecence) Marshal 

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

func (*SecretReferecence) MarshalTo 

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

func (*SecretReferecence) MarshalToSizedBuffer 

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

func (*SecretReferecence) ProtoMessage 

func (*SecretReferecence) ProtoMessage()

func (*SecretReferecence) Reset 

func (m *SecretReferecence) Reset()

func (*SecretReferecence) Size 

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

func (*SecretReferecence) String 

func (this *SecretReferecence) String() string

func (*SecretReferecence) Unmarshal 

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

func (*SecretReferecence) XXX_DiscardUnknown 

func (m *SecretReferecence) XXX_DiscardUnknown()

func (*SecretReferecence) XXX_Marshal 

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

func (*SecretReferecence) XXX_Merge 

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

func (*SecretReferecence) XXX_Size 

func (m *SecretReferecence) XXX_Size() int

func (*SecretReferecence) XXX_Unmarshal 

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

type SecureServing 

type SecureServing struct {
	// KeyData contains PEM-encoded data from a client key file for TLS.
	// The serialized form of data is a base64 encoded string
	KeyData []byte `json:"keyData,omitempty" protobuf:"bytes,1,opt,name=keyData"`
	// CertData contains PEM-encoded data from a client cert file for TLS.
	// The serialized form of data is a base64 encoded string
	CertData []byte `json:"certData,omitempty" protobuf:"bytes,2,opt,name=certData"`
	// ClientCAData contains PEM-encoded data from a ca file for TLS.
	// The serialized form of data is a base64 encoded string
	ClientCAData []byte `json:"clientCAData,omitempty" protobuf:"bytes,3,opt,name=clientCAData"`
}

func (*SecureServing) DeepCopy 

func (in *SecureServing) DeepCopy() *SecureServing

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecureServing.

func (*SecureServing) DeepCopyInto 

func (in *SecureServing) DeepCopyInto(out *SecureServing)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SecureServing) Descriptor 

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

func (*SecureServing) Marshal 

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

func (*SecureServing) MarshalTo 

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

func (*SecureServing) MarshalToSizedBuffer 

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

func (*SecureServing) ProtoMessage 

func (*SecureServing) ProtoMessage()

func (*SecureServing) Reset 

func (m *SecureServing) Reset()

func (*SecureServing) Size 

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

func (*SecureServing) String 

func (this *SecureServing) String() string

func (*SecureServing) Unmarshal 

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

func (*SecureServing) XXX_DiscardUnknown 

func (m *SecureServing) XXX_DiscardUnknown()

func (*SecureServing) XXX_Marshal 

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

func (*SecureServing) XXX_Merge 

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

func (*SecureServing) XXX_Size 

func (m *SecureServing) XXX_Size() int

func (*SecureServing) XXX_Unmarshal 

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

type ServiceAccountRef 

type ServiceAccountRef struct {
	Name      string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"`
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,2,opt,name=namespace"`
}

func (*ServiceAccountRef) DeepCopy 

func (in *ServiceAccountRef) DeepCopy() *ServiceAccountRef

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceAccountRef.

func (*ServiceAccountRef) DeepCopyInto 

func (in *ServiceAccountRef) DeepCopyInto(out *ServiceAccountRef)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ServiceAccountRef) Descriptor 

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

func (*ServiceAccountRef) Marshal 

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

func (*ServiceAccountRef) MarshalTo 

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

func (*ServiceAccountRef) MarshalToSizedBuffer 

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

func (*ServiceAccountRef) ProtoMessage 

func (*ServiceAccountRef) ProtoMessage()

func (*ServiceAccountRef) Reset 

func (m *ServiceAccountRef) Reset()

func (*ServiceAccountRef) Size 

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

func (*ServiceAccountRef) String 

func (this *ServiceAccountRef) String() string

func (*ServiceAccountRef) Unmarshal 

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

func (*ServiceAccountRef) XXX_DiscardUnknown 

func (m *ServiceAccountRef) XXX_DiscardUnknown()

func (*ServiceAccountRef) XXX_Marshal 

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

func (*ServiceAccountRef) XXX_Merge 

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

func (*ServiceAccountRef) XXX_Size 

func (m *ServiceAccountRef) XXX_Size() int

func (*ServiceAccountRef) XXX_Unmarshal 

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

type Strategy 

type Strategy string
const (
	RoundRobin Strategy = "RoundRobin"
)

type TokenBucketFlowControlSchema 

type TokenBucketFlowControlSchema struct {
	// QPS indicates the maximum QPS to the master from this client.
	// It can not be zero
	QPS int32 `json:"qps,omitempty" protobuf:"varint,1,opt,name=qps"`
	// Maximum burst for throttle.
	// This value must be bigger than QPS if QPS is not 0
	// +optional
	Burst int32 `json:"burst,omitempty" protobuf:"varint,2,opt,name=burst"`
}

Represents token bucket rate limit approach.

func (*TokenBucketFlowControlSchema) DeepCopy 

func (in *TokenBucketFlowControlSchema) DeepCopy() *TokenBucketFlowControlSchema

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TokenBucketFlowControlSchema.

func (*TokenBucketFlowControlSchema) DeepCopyInto 

func (in *TokenBucketFlowControlSchema) DeepCopyInto(out *TokenBucketFlowControlSchema)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TokenBucketFlowControlSchema) Descriptor 

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

func (*TokenBucketFlowControlSchema) Marshal 

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

func (*TokenBucketFlowControlSchema) MarshalTo 

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

func (*TokenBucketFlowControlSchema) MarshalToSizedBuffer 

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

func (*TokenBucketFlowControlSchema) ProtoMessage 

func (*TokenBucketFlowControlSchema) ProtoMessage()

func (*TokenBucketFlowControlSchema) Reset 

func (m *TokenBucketFlowControlSchema) Reset()

func (*TokenBucketFlowControlSchema) Size 

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

func (*TokenBucketFlowControlSchema) String 

func (this *TokenBucketFlowControlSchema) String() string

func (*TokenBucketFlowControlSchema) Unmarshal 

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

func (*TokenBucketFlowControlSchema) XXX_DiscardUnknown 

func (m *TokenBucketFlowControlSchema) XXX_DiscardUnknown()

func (*TokenBucketFlowControlSchema) XXX_Marshal 

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

func (*TokenBucketFlowControlSchema) XXX_Merge 

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

func (*TokenBucketFlowControlSchema) XXX_Size 

func (m *TokenBucketFlowControlSchema) XXX_Size() int

func (*TokenBucketFlowControlSchema) XXX_Unmarshal 

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

type UpstreamCluster 

type UpstreamCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`

	Spec   UpstreamClusterSpec   `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
	Status UpstreamClusterStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
}

UpstreamCluster is the Schema for the upstreamclusters API

func (*UpstreamCluster) DeepCopy 

func (in *UpstreamCluster) DeepCopy() *UpstreamCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpstreamCluster.

func (*UpstreamCluster) DeepCopyInto 

func (in *UpstreamCluster) DeepCopyInto(out *UpstreamCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UpstreamCluster) DeepCopyObject 

func (in *UpstreamCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*UpstreamCluster) Descriptor 

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

func (*UpstreamCluster) Hub 

func (*UpstreamCluster) Hub()

Hub marks this type as a conversion hub

func (*UpstreamCluster) Marshal 

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

func (*UpstreamCluster) MarshalTo 

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

func (*UpstreamCluster) MarshalToSizedBuffer 

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

func (*UpstreamCluster) ProtoMessage 

func (*UpstreamCluster) ProtoMessage()

func (*UpstreamCluster) Reset 

func (m *UpstreamCluster) Reset()

func (*UpstreamCluster) Size 

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

func (*UpstreamCluster) String 

func (this *UpstreamCluster) String() string

func (*UpstreamCluster) Unmarshal 

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

func (*UpstreamCluster) XXX_DiscardUnknown 

func (m *UpstreamCluster) XXX_DiscardUnknown()

func (*UpstreamCluster) XXX_Marshal 

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

func (*UpstreamCluster) XXX_Merge 

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

func (*UpstreamCluster) XXX_Size 

func (m *UpstreamCluster) XXX_Size() int

func (*UpstreamCluster) XXX_Unmarshal 

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

type UpstreamClusterList 

type UpstreamClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
	Items           []UpstreamCluster `json:"items" protobuf:"bytes,2,rep,name=items"`
}

UpstreamClusterList contains a list of UpstreamCluster

func (*UpstreamClusterList) DeepCopy 

func (in *UpstreamClusterList) DeepCopy() *UpstreamClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpstreamClusterList.

func (*UpstreamClusterList) DeepCopyInto 

func (in *UpstreamClusterList) DeepCopyInto(out *UpstreamClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UpstreamClusterList) DeepCopyObject 

func (in *UpstreamClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*UpstreamClusterList) Descriptor 

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

func (*UpstreamClusterList) Marshal 

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

func (*UpstreamClusterList) MarshalTo 

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

func (*UpstreamClusterList) MarshalToSizedBuffer 

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

func (*UpstreamClusterList) ProtoMessage 

func (*UpstreamClusterList) ProtoMessage()

func (*UpstreamClusterList) Reset 

func (m *UpstreamClusterList) Reset()

func (*UpstreamClusterList) Size 

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

func (*UpstreamClusterList) String 

func (this *UpstreamClusterList) String() string

func (*UpstreamClusterList) Unmarshal 

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

func (*UpstreamClusterList) XXX_DiscardUnknown 

func (m *UpstreamClusterList) XXX_DiscardUnknown()

func (*UpstreamClusterList) XXX_Marshal 

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

func (*UpstreamClusterList) XXX_Merge 

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

func (*UpstreamClusterList) XXX_Size 

func (m *UpstreamClusterList) XXX_Size() int

func (*UpstreamClusterList) XXX_Unmarshal 

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

type UpstreamClusterServer 

type UpstreamClusterServer struct {
	// Endpoint is the backend api server address, like https://apiserver.com:6443
	Endpoint string `json:"endpoint,omitempty" protobuf:"bytes,1,opt,name=endpoint"`
	// Disabled marks the server as permanently unavailable.
	// +optional
	Disabled *bool `json:"disabled,omitempty" protobuf:"varint,2,opt,name=disabled"`
}

func (*UpstreamClusterServer) DeepCopy 

func (in *UpstreamClusterServer) DeepCopy() *UpstreamClusterServer

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpstreamClusterServer.

func (*UpstreamClusterServer) DeepCopyInto 

func (in *UpstreamClusterServer) DeepCopyInto(out *UpstreamClusterServer)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UpstreamClusterServer) Descriptor 

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

func (*UpstreamClusterServer) Marshal 

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

func (*UpstreamClusterServer) MarshalTo 

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

func (*UpstreamClusterServer) MarshalToSizedBuffer 

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

func (*UpstreamClusterServer) ProtoMessage 

func (*UpstreamClusterServer) ProtoMessage()

func (*UpstreamClusterServer) Reset 

func (m *UpstreamClusterServer) Reset()

func (*UpstreamClusterServer) Size 

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

func (*UpstreamClusterServer) String 

func (this *UpstreamClusterServer) String() string

func (*UpstreamClusterServer) Unmarshal 

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

func (*UpstreamClusterServer) XXX_DiscardUnknown 

func (m *UpstreamClusterServer) XXX_DiscardUnknown()

func (*UpstreamClusterServer) XXX_Marshal 

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

func (*UpstreamClusterServer) XXX_Merge 

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

func (*UpstreamClusterServer) XXX_Size 

func (m *UpstreamClusterServer) XXX_Size() int

func (*UpstreamClusterServer) XXX_Unmarshal 

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

type UpstreamClusterSpec 

type UpstreamClusterSpec struct {
	// Servers contains a group of upstream api servers
	Servers []UpstreamClusterServer `json:"servers,omitempty" protobuf:"bytes,1,rep,name=servers"`

	// Client connection config for upstream api servers
	ClientConfig ClientConfig `json:"clientConfig,omitempty" protobuf:"bytes,2,opt,name=clientConfig"`

	// Secures serving config for upstream cluster
	SecureServing SecureServing `json:"secureServing,omitempty" protobuf:"bytes,3,opt,name=secureServing"`

	// Client flow control settings, e.g. qps and burst
	FlowControl FlowControl `json:"flowControl,omitempty" protobuf:"bytes,4,opt,name=flowControl"`

	// DispatchPolicies describes how to dispatch requests to upsteams.
	// Only one dispatch policy will be matched
	// The router will follow the order of DispatchPolicies, that means
	// the previous policy has higher priority
	DispatchPolicies []DispatchPolicy `json:"dispatchPolicies,omitempty" protobuf:"bytes,5,rep,name=dispatchPolicies"`

	// Logging config for upstream cluster
	//
	// There are three places to control the log switch
	// 1. flag --enable-proxy-access-log: If it is false, all proxy access log
	//    will be disabled.
	// 2. log mode in upstream, it allows you control cluster level log switch. If it
	//    is off, all access logs of requests to this cluster will be disabled.
	// 3. log mode in dispatchPolicy, it allows you control policy level log switch.
	//    If it is off, all access logs of requests matching this policy will be disabled.
	Logging LoggingConfig `json:"logging,omitempty" protobuf:"bytes,6,opt,name=logging"`
}

UpstreamClusterSpec defines the desired state of UpstreamCluster

func (*UpstreamClusterSpec) DeepCopy 

func (in *UpstreamClusterSpec) DeepCopy() *UpstreamClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpstreamClusterSpec.

func (*UpstreamClusterSpec) DeepCopyInto 

func (in *UpstreamClusterSpec) DeepCopyInto(out *UpstreamClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UpstreamClusterSpec) Descriptor 

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

func (*UpstreamClusterSpec) Marshal 

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

func (*UpstreamClusterSpec) MarshalTo 

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

func (*UpstreamClusterSpec) MarshalToSizedBuffer 

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

func (*UpstreamClusterSpec) ProtoMessage 

func (*UpstreamClusterSpec) ProtoMessage()

func (*UpstreamClusterSpec) Reset 

func (m *UpstreamClusterSpec) Reset()

func (*UpstreamClusterSpec) Size 

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

func (*UpstreamClusterSpec) String 

func (this *UpstreamClusterSpec) String() string

func (*UpstreamClusterSpec) Unmarshal 

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

func (*UpstreamClusterSpec) XXX_DiscardUnknown 

func (m *UpstreamClusterSpec) XXX_DiscardUnknown()

func (*UpstreamClusterSpec) XXX_Marshal 

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

func (*UpstreamClusterSpec) XXX_Merge 

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

func (*UpstreamClusterSpec) XXX_Size 

func (m *UpstreamClusterSpec) XXX_Size() int

func (*UpstreamClusterSpec) XXX_Unmarshal 

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

type UpstreamClusterStatus 

type UpstreamClusterStatus struct {
}

UpstreamClusterStatus defines the observed state of UpstreamCluster

func (*UpstreamClusterStatus) DeepCopy 

func (in *UpstreamClusterStatus) DeepCopy() *UpstreamClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpstreamClusterStatus.

func (*UpstreamClusterStatus) DeepCopyInto 

func (in *UpstreamClusterStatus) DeepCopyInto(out *UpstreamClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*UpstreamClusterStatus) Descriptor 

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

func (*UpstreamClusterStatus) Marshal 

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

func (*UpstreamClusterStatus) MarshalTo 

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

func (*UpstreamClusterStatus) MarshalToSizedBuffer 

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

func (*UpstreamClusterStatus) ProtoMessage 

func (*UpstreamClusterStatus) ProtoMessage()

func (*UpstreamClusterStatus) Reset 

func (m *UpstreamClusterStatus) Reset()

func (*UpstreamClusterStatus) Size 

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

func (*UpstreamClusterStatus) String 

func (this *UpstreamClusterStatus) String() string

func (*UpstreamClusterStatus) Unmarshal 

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

func (*UpstreamClusterStatus) XXX_DiscardUnknown 

func (m *UpstreamClusterStatus) XXX_DiscardUnknown()

func (*UpstreamClusterStatus) XXX_Marshal 

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

func (*UpstreamClusterStatus) XXX_Merge 

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

func (*UpstreamClusterStatus) XXX_Size 

func (m *UpstreamClusterStatus) XXX_Size() int

func (*UpstreamClusterStatus) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis

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.