Documentation ¶
Overview ¶
Code generated by protoc-gen-deepcopy. DO NOT EDIT.
Code generated by protoc-gen-jsonshim. DO NOT EDIT.
Code generated by protoc-gen-deepcopy. DO NOT EDIT.
Code generated by protoc-gen-jsonshim. DO NOT EDIT.
Index ¶
- Variables
- type Auth
- func (in *Auth) DeepCopy() *Auth
- func (in *Auth) DeepCopyInterface() interface{}
- func (in *Auth) DeepCopyInto(out *Auth)
- func (*Auth) Descriptor() ([]byte, []int)deprecated
- func (m *Auth) GetAuth() isAuth_Auth
- func (x *Auth) GetPlain() *PlainAuth
- func (x *Auth) GetSecret() *SecretReference
- func (this *Auth) MarshalJSON() ([]byte, error)
- func (*Auth) ProtoMessage()
- func (x *Auth) ProtoReflect() protoreflect.Message
- func (x *Auth) Reset()
- func (x *Auth) String() string
- func (this *Auth) UnmarshalJSON(b []byte) error
- type Auth_Plain
- type Auth_Secret
- type ConnectionPoolSettings
- func (in *ConnectionPoolSettings) DeepCopy() *ConnectionPoolSettings
- func (in *ConnectionPoolSettings) DeepCopyInterface() interface{}
- func (in *ConnectionPoolSettings) DeepCopyInto(out *ConnectionPoolSettings)
- func (*ConnectionPoolSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionPoolSettings) GetRedis() *RedisSettings
- func (x *ConnectionPoolSettings) GetTcp() *v1alpha3.ConnectionPoolSettings_TCPSettings
- func (this *ConnectionPoolSettings) MarshalJSON() ([]byte, error)
- func (*ConnectionPoolSettings) ProtoMessage()
- func (x *ConnectionPoolSettings) ProtoReflect() protoreflect.Message
- func (x *ConnectionPoolSettings) Reset()
- func (x *ConnectionPoolSettings) String() string
- func (this *ConnectionPoolSettings) UnmarshalJSON(b []byte) error
- type Fault
- func (in *Fault) DeepCopy() *Fault
- func (in *Fault) DeepCopyInterface() interface{}
- func (in *Fault) DeepCopyInto(out *Fault)
- func (*Fault) Descriptor() ([]byte, []int)deprecated
- func (x *Fault) GetCommands() []string
- func (x *Fault) GetDelay() *duration.Duration
- func (x *Fault) GetPercentage() *Percent
- func (x *Fault) GetType() Fault_Type
- func (this *Fault) MarshalJSON() ([]byte, error)
- func (*Fault) ProtoMessage()
- func (x *Fault) ProtoReflect() protoreflect.Message
- func (x *Fault) Reset()
- func (x *Fault) String() string
- func (this *Fault) UnmarshalJSON(b []byte) error
- type Fault_Type
- type Percent
- func (in *Percent) DeepCopy() *Percent
- func (in *Percent) DeepCopyInterface() interface{}
- func (in *Percent) DeepCopyInto(out *Percent)
- func (*Percent) Descriptor() ([]byte, []int)deprecated
- func (x *Percent) GetValue() float64
- func (this *Percent) MarshalJSON() ([]byte, error)
- func (*Percent) ProtoMessage()
- func (x *Percent) ProtoReflect() protoreflect.Message
- func (x *Percent) Reset()
- func (x *Percent) String() string
- func (this *Percent) UnmarshalJSON(b []byte) error
- type PlainAuth
- func (in *PlainAuth) DeepCopy() *PlainAuth
- func (in *PlainAuth) DeepCopyInterface() interface{}
- func (in *PlainAuth) DeepCopyInto(out *PlainAuth)
- func (*PlainAuth) Descriptor() ([]byte, []int)deprecated
- func (x *PlainAuth) GetPassword() string
- func (x *PlainAuth) GetUsername() string
- func (this *PlainAuth) MarshalJSON() ([]byte, error)
- func (*PlainAuth) ProtoMessage()
- func (x *PlainAuth) ProtoReflect() protoreflect.Message
- func (x *PlainAuth) Reset()
- func (x *PlainAuth) String() string
- func (this *PlainAuth) UnmarshalJSON(b []byte) error
- type RedisDestination
- func (in *RedisDestination) DeepCopy() *RedisDestination
- func (in *RedisDestination) DeepCopyInterface() interface{}
- func (in *RedisDestination) DeepCopyInto(out *RedisDestination)
- func (*RedisDestination) Descriptor() ([]byte, []int)deprecated
- func (x *RedisDestination) GetHost() string
- func (x *RedisDestination) GetTrafficPolicy() *TrafficPolicy
- func (this *RedisDestination) MarshalJSON() ([]byte, error)
- func (*RedisDestination) ProtoMessage()
- func (x *RedisDestination) ProtoReflect() protoreflect.Message
- func (x *RedisDestination) Reset()
- func (x *RedisDestination) String() string
- func (this *RedisDestination) UnmarshalJSON(b []byte) error
- type RedisService
- func (in *RedisService) DeepCopy() *RedisService
- func (in *RedisService) DeepCopyInterface() interface{}
- func (in *RedisService) DeepCopyInto(out *RedisService)
- func (*RedisService) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService) GetFaults() []*Fault
- func (x *RedisService) GetHost() []string
- func (x *RedisService) GetRedis() []*RedisService_Route
- func (x *RedisService) GetSettings() *RedisService_Settings
- func (this *RedisService) MarshalJSON() ([]byte, error)
- func (*RedisService) ProtoMessage()
- func (x *RedisService) ProtoReflect() protoreflect.Message
- func (x *RedisService) Reset()
- func (x *RedisService) String() string
- func (this *RedisService) UnmarshalJSON(b []byte) error
- type RedisService_Destination
- func (in *RedisService_Destination) DeepCopy() *RedisService_Destination
- func (in *RedisService_Destination) DeepCopyInterface() interface{}
- func (in *RedisService_Destination) DeepCopyInto(out *RedisService_Destination)
- func (*RedisService_Destination) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService_Destination) GetHost() string
- func (x *RedisService_Destination) GetPort() uint32
- func (this *RedisService_Destination) MarshalJSON() ([]byte, error)
- func (*RedisService_Destination) ProtoMessage()
- func (x *RedisService_Destination) ProtoReflect() protoreflect.Message
- func (x *RedisService_Destination) Reset()
- func (x *RedisService_Destination) String() string
- func (this *RedisService_Destination) UnmarshalJSON(b []byte) error
- type RedisService_KeyMatch
- func (in *RedisService_KeyMatch) DeepCopy() *RedisService_KeyMatch
- func (in *RedisService_KeyMatch) DeepCopyInterface() interface{}
- func (in *RedisService_KeyMatch) DeepCopyInto(out *RedisService_KeyMatch)
- func (*RedisService_KeyMatch) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService_KeyMatch) GetPrefix() string
- func (x *RedisService_KeyMatch) GetRemovePrefix() bool
- func (this *RedisService_KeyMatch) MarshalJSON() ([]byte, error)
- func (*RedisService_KeyMatch) ProtoMessage()
- func (x *RedisService_KeyMatch) ProtoReflect() protoreflect.Message
- func (x *RedisService_KeyMatch) Reset()
- func (x *RedisService_KeyMatch) String() string
- func (this *RedisService_KeyMatch) UnmarshalJSON(b []byte) error
- type RedisService_Mirror
- func (in *RedisService_Mirror) DeepCopy() *RedisService_Mirror
- func (in *RedisService_Mirror) DeepCopyInterface() interface{}
- func (in *RedisService_Mirror) DeepCopyInto(out *RedisService_Mirror)
- func (*RedisService_Mirror) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService_Mirror) GetExcludeReadCommands() bool
- func (x *RedisService_Mirror) GetPercentage() *Percent
- func (x *RedisService_Mirror) GetRoute() *RedisService_Destination
- func (this *RedisService_Mirror) MarshalJSON() ([]byte, error)
- func (*RedisService_Mirror) ProtoMessage()
- func (x *RedisService_Mirror) ProtoReflect() protoreflect.Message
- func (x *RedisService_Mirror) Reset()
- func (x *RedisService_Mirror) String() string
- func (this *RedisService_Mirror) UnmarshalJSON(b []byte) error
- type RedisService_ReadPolicy
- func (RedisService_ReadPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x RedisService_ReadPolicy) Enum() *RedisService_ReadPolicy
- func (RedisService_ReadPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x RedisService_ReadPolicy) Number() protoreflect.EnumNumber
- func (x RedisService_ReadPolicy) String() string
- func (RedisService_ReadPolicy) Type() protoreflect.EnumType
- type RedisService_Route
- func (in *RedisService_Route) DeepCopy() *RedisService_Route
- func (in *RedisService_Route) DeepCopyInterface() interface{}
- func (in *RedisService_Route) DeepCopyInto(out *RedisService_Route)
- func (*RedisService_Route) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService_Route) GetMatch() *RedisService_RouteMatch
- func (x *RedisService_Route) GetMirror() []*RedisService_Mirror
- func (x *RedisService_Route) GetRoute() *RedisService_Destination
- func (this *RedisService_Route) MarshalJSON() ([]byte, error)
- func (*RedisService_Route) ProtoMessage()
- func (x *RedisService_Route) ProtoReflect() protoreflect.Message
- func (x *RedisService_Route) Reset()
- func (x *RedisService_Route) String() string
- func (this *RedisService_Route) UnmarshalJSON(b []byte) error
- type RedisService_RouteMatch
- func (in *RedisService_RouteMatch) DeepCopy() *RedisService_RouteMatch
- func (in *RedisService_RouteMatch) DeepCopyInterface() interface{}
- func (in *RedisService_RouteMatch) DeepCopyInto(out *RedisService_RouteMatch)
- func (*RedisService_RouteMatch) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService_RouteMatch) GetKey() *RedisService_KeyMatch
- func (m *RedisService_RouteMatch) GetMatch() isRedisService_RouteMatch_Match
- func (this *RedisService_RouteMatch) MarshalJSON() ([]byte, error)
- func (*RedisService_RouteMatch) ProtoMessage()
- func (x *RedisService_RouteMatch) ProtoReflect() protoreflect.Message
- func (x *RedisService_RouteMatch) Reset()
- func (x *RedisService_RouteMatch) String() string
- func (this *RedisService_RouteMatch) UnmarshalJSON(b []byte) error
- type RedisService_RouteMatch_Key
- type RedisService_Settings
- func (in *RedisService_Settings) DeepCopy() *RedisService_Settings
- func (in *RedisService_Settings) DeepCopyInterface() interface{}
- func (in *RedisService_Settings) DeepCopyInto(out *RedisService_Settings)
- func (*RedisService_Settings) Descriptor() ([]byte, []int)deprecated
- func (x *RedisService_Settings) GetAuth() *Auth
- func (x *RedisService_Settings) GetBufferFlushTimeout() *duration.Duration
- func (x *RedisService_Settings) GetCaseInsensitive() bool
- func (x *RedisService_Settings) GetEnableCommandStats() bool
- func (x *RedisService_Settings) GetEnableHashtagging() bool
- func (x *RedisService_Settings) GetEnableRedirection() bool
- func (x *RedisService_Settings) GetMaxBufferSizeBeforeFlush() uint32
- func (x *RedisService_Settings) GetMaxUpstreamUnknownConnections() *wrappers.UInt32Value
- func (x *RedisService_Settings) GetOpTimeout() *duration.Duration
- func (x *RedisService_Settings) GetReadPolicy() RedisService_ReadPolicy
- func (this *RedisService_Settings) MarshalJSON() ([]byte, error)
- func (*RedisService_Settings) ProtoMessage()
- func (x *RedisService_Settings) ProtoReflect() protoreflect.Message
- func (x *RedisService_Settings) Reset()
- func (x *RedisService_Settings) String() string
- func (this *RedisService_Settings) UnmarshalJSON(b []byte) error
- type RedisSettings
- func (in *RedisSettings) DeepCopy() *RedisSettings
- func (in *RedisSettings) DeepCopyInterface() interface{}
- func (in *RedisSettings) DeepCopyInto(out *RedisSettings)
- func (*RedisSettings) Descriptor() ([]byte, []int)deprecated
- func (x *RedisSettings) GetAuth() *Auth
- func (x *RedisSettings) GetDiscoveryEndpoints() []string
- func (x *RedisSettings) GetMode() RedisSettings_Mode
- func (this *RedisSettings) MarshalJSON() ([]byte, error)
- func (*RedisSettings) ProtoMessage()
- func (x *RedisSettings) ProtoReflect() protoreflect.Message
- func (x *RedisSettings) Reset()
- func (x *RedisSettings) String() string
- func (this *RedisSettings) UnmarshalJSON(b []byte) error
- type RedisSettings_Mode
- func (RedisSettings_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x RedisSettings_Mode) Enum() *RedisSettings_Mode
- func (RedisSettings_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x RedisSettings_Mode) Number() protoreflect.EnumNumber
- func (x RedisSettings_Mode) String() string
- func (RedisSettings_Mode) Type() protoreflect.EnumType
- type SecretReference
- func (in *SecretReference) DeepCopy() *SecretReference
- func (in *SecretReference) DeepCopyInterface() interface{}
- func (in *SecretReference) DeepCopyInto(out *SecretReference)
- func (*SecretReference) Descriptor() ([]byte, []int)deprecated
- func (x *SecretReference) GetName() string
- func (x *SecretReference) GetPasswordField() string
- func (x *SecretReference) GetUsernameField() string
- func (this *SecretReference) MarshalJSON() ([]byte, error)
- func (*SecretReference) ProtoMessage()
- func (x *SecretReference) ProtoReflect() protoreflect.Message
- func (x *SecretReference) Reset()
- func (x *SecretReference) String() string
- func (this *SecretReference) UnmarshalJSON(b []byte) error
- type TrafficPolicy
- func (in *TrafficPolicy) DeepCopy() *TrafficPolicy
- func (in *TrafficPolicy) DeepCopyInterface() interface{}
- func (in *TrafficPolicy) DeepCopyInto(out *TrafficPolicy)
- func (*TrafficPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *TrafficPolicy) GetConnectionPool() *ConnectionPoolSettings
- func (this *TrafficPolicy) MarshalJSON() ([]byte, error)
- func (*TrafficPolicy) ProtoMessage()
- func (x *TrafficPolicy) ProtoReflect() protoreflect.Message
- func (x *TrafficPolicy) Reset()
- func (x *TrafficPolicy) String() string
- func (this *TrafficPolicy) UnmarshalJSON(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( RedisSettings_Mode_name = map[int32]string{ 0: "PROXY", 1: "CLUSTER", } RedisSettings_Mode_value = map[string]int32{ "PROXY": 0, "CLUSTER": 1, } )
Enum value maps for RedisSettings_Mode.
var ( RedisdestinationMarshaler = &jsonpb.Marshaler{} RedisdestinationUnmarshaler = &jsonpb.Unmarshaler{AllowUnknownFields: true} )
var ( RedisService_ReadPolicy_name = map[int32]string{ 0: "MASTER", 1: "PREFER_MASTER", 2: "REPLICA", 3: "PREFER_REPLICA", 4: "ANY", } RedisService_ReadPolicy_value = map[string]int32{ "MASTER": 0, "PREFER_MASTER": 1, "REPLICA": 2, "PREFER_REPLICA": 3, "ANY": 4, } )
Enum value maps for RedisService_ReadPolicy.
var ( Fault_Type_name = map[int32]string{ 0: "DELAY", 1: "ERROR", } Fault_Type_value = map[string]int32{ "DELAY": 0, "ERROR": 1, } )
Enum value maps for Fault_Type.
var ( RedisserviceMarshaler = &jsonpb.Marshaler{} RedisserviceUnmarshaler = &jsonpb.Unmarshaler{AllowUnknownFields: true} )
var File_redis_v1alpha1_redisdestination_proto protoreflect.FileDescriptor
var File_redis_v1alpha1_redisservice_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Auth ¶
type Auth struct { // Types that are assignable to Auth: // // *Auth_Secret // *Auth_Plain Auth isAuth_Auth `protobuf_oneof:"auth"` // contains filtered or unexported fields }
Auth provide a way to get redis auth token.
func (*Auth) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Auth. Required by controller-gen.
func (*Auth) DeepCopyInterface ¶
func (in *Auth) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Auth. Required by controller-gen.
func (*Auth) DeepCopyInto ¶
DeepCopyInto supports using Auth within kubernetes types, where deepcopy-gen is used.
func (*Auth) Descriptor
deprecated
func (*Auth) GetSecret ¶
func (x *Auth) GetSecret() *SecretReference
func (*Auth) MarshalJSON ¶
MarshalJSON is a custom marshaler for Auth
func (*Auth) ProtoMessage ¶
func (*Auth) ProtoMessage()
func (*Auth) ProtoReflect ¶
func (x *Auth) ProtoReflect() protoreflect.Message
func (*Auth) UnmarshalJSON ¶
UnmarshalJSON is a custom unmarshaler for Auth
type Auth_Plain ¶
type Auth_Plain struct { // redis password. Plain *PlainAuth `protobuf:"bytes,2,opt,name=plain,proto3,oneof"` }
type Auth_Secret ¶
type Auth_Secret struct { // Secret use the k8s secret in current namespace. Secret *SecretReference `protobuf:"bytes,1,opt,name=secret,proto3,oneof"` }
type ConnectionPoolSettings ¶
type ConnectionPoolSettings struct { Tcp *v1alpha3.ConnectionPoolSettings_TCPSettings `protobuf:"bytes,1,opt,name=tcp,proto3" json:"tcp,omitempty"` Redis *RedisSettings `protobuf:"bytes,2,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
Connection pool settings for an upstream host. The settings apply to each individual host in the upstream service.
func (*ConnectionPoolSettings) DeepCopy ¶
func (in *ConnectionPoolSettings) DeepCopy() *ConnectionPoolSettings
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionPoolSettings. Required by controller-gen.
func (*ConnectionPoolSettings) DeepCopyInterface ¶
func (in *ConnectionPoolSettings) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ConnectionPoolSettings. Required by controller-gen.
func (*ConnectionPoolSettings) DeepCopyInto ¶
func (in *ConnectionPoolSettings) DeepCopyInto(out *ConnectionPoolSettings)
DeepCopyInto supports using ConnectionPoolSettings within kubernetes types, where deepcopy-gen is used.
func (*ConnectionPoolSettings) Descriptor
deprecated
func (*ConnectionPoolSettings) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionPoolSettings.ProtoReflect.Descriptor instead.
func (*ConnectionPoolSettings) GetRedis ¶
func (x *ConnectionPoolSettings) GetRedis() *RedisSettings
func (*ConnectionPoolSettings) GetTcp ¶
func (x *ConnectionPoolSettings) GetTcp() *v1alpha3.ConnectionPoolSettings_TCPSettings
func (*ConnectionPoolSettings) MarshalJSON ¶
func (this *ConnectionPoolSettings) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for ConnectionPoolSettings
func (*ConnectionPoolSettings) ProtoMessage ¶
func (*ConnectionPoolSettings) ProtoMessage()
func (*ConnectionPoolSettings) ProtoReflect ¶
func (x *ConnectionPoolSettings) ProtoReflect() protoreflect.Message
func (*ConnectionPoolSettings) Reset ¶
func (x *ConnectionPoolSettings) Reset()
func (*ConnectionPoolSettings) String ¶
func (x *ConnectionPoolSettings) String() string
func (*ConnectionPoolSettings) UnmarshalJSON ¶
func (this *ConnectionPoolSettings) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for ConnectionPoolSettings
type Fault ¶
type Fault struct { // Fault type. Type Fault_Type `protobuf:"varint,1,opt,name=type,proto3,enum=redis.aeraki.io.v1alpha1.Fault_Type" json:"type,omitempty"` // Percentage of requests fault applies to. Percentage *Percent `protobuf:"bytes,2,opt,name=percentage,proto3" json:"percentage,omitempty"` // Delay for all faults. If not set, defaults to zero Delay *duration.Duration `protobuf:"bytes,3,opt,name=delay,proto3" json:"delay,omitempty"` // Commands fault is restricted to, if any. If not set, fault applies to all commands // other than auth and ping (due to special handling of those commands in Envoy). Commands []string `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"` // contains filtered or unexported fields }
Fault defines redis faults used for fault injection.
func (*Fault) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Fault. Required by controller-gen.
func (*Fault) DeepCopyInterface ¶
func (in *Fault) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Fault. Required by controller-gen.
func (*Fault) DeepCopyInto ¶
DeepCopyInto supports using Fault within kubernetes types, where deepcopy-gen is used.
func (*Fault) Descriptor
deprecated
func (*Fault) GetCommands ¶
func (*Fault) GetPercentage ¶
func (*Fault) GetType ¶
func (x *Fault) GetType() Fault_Type
func (*Fault) MarshalJSON ¶
MarshalJSON is a custom marshaler for Fault
func (*Fault) ProtoMessage ¶
func (*Fault) ProtoMessage()
func (*Fault) ProtoReflect ¶
func (x *Fault) ProtoReflect() protoreflect.Message
func (*Fault) UnmarshalJSON ¶
UnmarshalJSON is a custom unmarshaler for Fault
type Fault_Type ¶
type Fault_Type int32
const ( // Delays requests. This is the base fault; other faults can have delays added. Fault_DELAY Fault_Type = 0 // Returns errors on requests. Fault_ERROR Fault_Type = 1 )
func (Fault_Type) Descriptor ¶
func (Fault_Type) Descriptor() protoreflect.EnumDescriptor
func (Fault_Type) Enum ¶
func (x Fault_Type) Enum() *Fault_Type
func (Fault_Type) EnumDescriptor
deprecated
func (Fault_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Fault_Type.Descriptor instead.
func (Fault_Type) Number ¶
func (x Fault_Type) Number() protoreflect.EnumNumber
func (Fault_Type) String ¶
func (x Fault_Type) String() string
func (Fault_Type) Type ¶
func (Fault_Type) Type() protoreflect.EnumType
type Percent ¶
type Percent struct { Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Percent specifies a percentage in the range of [0.0, 100.0].
func (*Percent) DeepCopy ¶
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 ¶
DeepCopyInto supports using Percent within kubernetes types, where deepcopy-gen is used.
func (*Percent) Descriptor
deprecated
func (*Percent) MarshalJSON ¶
MarshalJSON is a custom marshaler for Percent
func (*Percent) ProtoMessage ¶
func (*Percent) ProtoMessage()
func (*Percent) ProtoReflect ¶
func (x *Percent) ProtoReflect() protoreflect.Message
func (*Percent) UnmarshalJSON ¶
UnmarshalJSON is a custom unmarshaler for Percent
type PlainAuth ¶
type PlainAuth struct { Password string `protobuf:"bytes,1,opt,name=password,proto3" json:"password,omitempty"` Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"` // contains filtered or unexported fields }
func (*PlainAuth) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PlainAuth. Required by controller-gen.
func (*PlainAuth) DeepCopyInterface ¶
func (in *PlainAuth) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new PlainAuth. Required by controller-gen.
func (*PlainAuth) DeepCopyInto ¶
DeepCopyInto supports using PlainAuth within kubernetes types, where deepcopy-gen is used.
func (*PlainAuth) Descriptor
deprecated
func (*PlainAuth) GetPassword ¶
func (*PlainAuth) GetUsername ¶
func (*PlainAuth) MarshalJSON ¶
MarshalJSON is a custom marshaler for PlainAuth
func (*PlainAuth) ProtoMessage ¶
func (*PlainAuth) ProtoMessage()
func (*PlainAuth) ProtoReflect ¶
func (x *PlainAuth) ProtoReflect() protoreflect.Message
func (*PlainAuth) UnmarshalJSON ¶
UnmarshalJSON is a custom unmarshaler for PlainAuth
type RedisDestination ¶
type RedisDestination struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` TrafficPolicy *TrafficPolicy `protobuf:"bytes,2,opt,name=traffic_policy,json=trafficPolicy,proto3" json:"traffic_policy,omitempty"` // contains filtered or unexported fields }
RedisDestination defines policies that apply to redis traffic intended for a redis service
<!-- crd generation tags +cue-gen:RedisDestination:groupName:redis.aeraki.io +cue-gen:RedisDestination:version:v1alpha1 +cue-gen:RedisDestination:storageVersion +cue-gen:RedisDestination:subresource:status +cue-gen:RedisDestination:scope:Namespaced +cue-gen:RedisDestination:resource:categories=redis-aeraki-io,shortNames=rd +cue-gen:RedisDestination:printerColumn:name=Host,type=string,JSONPath=.spec.host,description="The name of a service from the service registry" +cue-gen:RedisDestination:printerColumn:name=Age,type=date,JSONPath=.metadata.creationTimestamp,description="CreationTimestamp is a timestamp representing the server time when this object was created. It is not guaranteed to be set in happens-before order across separate operations. Clients may not set this value. It is represented in RFC3339 form and is in UTC. Populated by the system. Read-only. Null for lists. More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#metadata" +cue-gen:RedisDestination:preserveUnknownFields:false -->
<!-- go code generation tags +kubetype-gen +kubetype-gen:groupVersion=redis.aeraki.io/v1alpha1 +genclient +k8s:deepcopy-gen=true -->
func (*RedisDestination) DeepCopy ¶
func (in *RedisDestination) DeepCopy() *RedisDestination
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisDestination. Required by controller-gen.
func (*RedisDestination) DeepCopyInterface ¶
func (in *RedisDestination) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisDestination. Required by controller-gen.
func (*RedisDestination) DeepCopyInto ¶
func (in *RedisDestination) DeepCopyInto(out *RedisDestination)
DeepCopyInto supports using RedisDestination within kubernetes types, where deepcopy-gen is used.
func (*RedisDestination) Descriptor
deprecated
func (*RedisDestination) Descriptor() ([]byte, []int)
Deprecated: Use RedisDestination.ProtoReflect.Descriptor instead.
func (*RedisDestination) GetHost ¶
func (x *RedisDestination) GetHost() string
func (*RedisDestination) GetTrafficPolicy ¶
func (x *RedisDestination) GetTrafficPolicy() *TrafficPolicy
func (*RedisDestination) MarshalJSON ¶
func (this *RedisDestination) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisDestination
func (*RedisDestination) ProtoMessage ¶
func (*RedisDestination) ProtoMessage()
func (*RedisDestination) ProtoReflect ¶
func (x *RedisDestination) ProtoReflect() protoreflect.Message
func (*RedisDestination) Reset ¶
func (x *RedisDestination) Reset()
func (*RedisDestination) String ¶
func (x *RedisDestination) String() string
func (*RedisDestination) UnmarshalJSON ¶
func (this *RedisDestination) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisDestination
type RedisService ¶
type RedisService struct { Host []string `protobuf:"bytes,1,rep,name=host,proto3" json:"host,omitempty"` Settings *RedisService_Settings `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"` Redis []*RedisService_Route `protobuf:"bytes,3,rep,name=redis,proto3" json:"redis,omitempty"` // List of faults to inject. Faults currently come in two flavors: // - Delay, which delays a request. // - Error, which responds to a request with an error. Errors can also have delays attached. Faults []*Fault `protobuf:"bytes,4,rep,name=faults,proto3" json:"faults,omitempty"` // contains filtered or unexported fields }
RedisService provide a way to config redis service in service mesh.
<!-- crd generation tags +cue-gen:RedisService:groupName:redis.aeraki.io +cue-gen:RedisService:version:v1alpha1 +cue-gen:RedisService:storageVersion +cue-gen:RedisService:subresource:status +cue-gen:RedisService:scope:Namespaced +cue-gen:RedisService:resource:categories=redis-aeraki-io,shortNames=rsvc +cue-gen:RedisService:printerColumn:name=Hosts,type=string,JSONPath=.spec.hosts,description="The destination hosts to which traffic is being sent" +cue-gen:RedisService:printerColumn:name=Age,type=date,JSONPath=.metadata.creationTimestamp,description="CreationTimestamp is a timestamp representing the server time when this object was created. It is not guaranteed to be set in happens-before order across separate operations. Clients may not set this value. It is represented in RFC3339 form and is in UTC. Populated by the system. Read-only. Null for lists. More info: https://git.k8s.io/community/contributors/devel/api-conventions.md#metadata" +cue-gen:RedisService:preserveUnknownFields:true -->
<!-- go code generation tags +kubetype-gen +kubetype-gen:groupVersion=redis.aeraki.io/v1alpha1 +genclient +k8s:deepcopy-gen=true -->
func (*RedisService) DeepCopy ¶
func (in *RedisService) DeepCopy() *RedisService
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService. Required by controller-gen.
func (*RedisService) DeepCopyInterface ¶
func (in *RedisService) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService. Required by controller-gen.
func (*RedisService) DeepCopyInto ¶
func (in *RedisService) DeepCopyInto(out *RedisService)
DeepCopyInto supports using RedisService within kubernetes types, where deepcopy-gen is used.
func (*RedisService) Descriptor
deprecated
func (*RedisService) Descriptor() ([]byte, []int)
Deprecated: Use RedisService.ProtoReflect.Descriptor instead.
func (*RedisService) GetFaults ¶
func (x *RedisService) GetFaults() []*Fault
func (*RedisService) GetHost ¶
func (x *RedisService) GetHost() []string
func (*RedisService) GetRedis ¶
func (x *RedisService) GetRedis() []*RedisService_Route
func (*RedisService) GetSettings ¶
func (x *RedisService) GetSettings() *RedisService_Settings
func (*RedisService) MarshalJSON ¶
func (this *RedisService) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService
func (*RedisService) ProtoMessage ¶
func (*RedisService) ProtoMessage()
func (*RedisService) ProtoReflect ¶
func (x *RedisService) ProtoReflect() protoreflect.Message
func (*RedisService) Reset ¶
func (x *RedisService) Reset()
func (*RedisService) String ¶
func (x *RedisService) String() string
func (*RedisService) UnmarshalJSON ¶
func (this *RedisService) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService
type RedisService_Destination ¶
type RedisService_Destination struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*RedisService_Destination) DeepCopy ¶
func (in *RedisService_Destination) DeepCopy() *RedisService_Destination
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Destination. Required by controller-gen.
func (*RedisService_Destination) DeepCopyInterface ¶
func (in *RedisService_Destination) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Destination. Required by controller-gen.
func (*RedisService_Destination) DeepCopyInto ¶
func (in *RedisService_Destination) DeepCopyInto(out *RedisService_Destination)
DeepCopyInto supports using RedisService_Destination within kubernetes types, where deepcopy-gen is used.
func (*RedisService_Destination) Descriptor
deprecated
func (*RedisService_Destination) Descriptor() ([]byte, []int)
Deprecated: Use RedisService_Destination.ProtoReflect.Descriptor instead.
func (*RedisService_Destination) GetHost ¶
func (x *RedisService_Destination) GetHost() string
func (*RedisService_Destination) GetPort ¶
func (x *RedisService_Destination) GetPort() uint32
func (*RedisService_Destination) MarshalJSON ¶
func (this *RedisService_Destination) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService_Destination
func (*RedisService_Destination) ProtoMessage ¶
func (*RedisService_Destination) ProtoMessage()
func (*RedisService_Destination) ProtoReflect ¶
func (x *RedisService_Destination) ProtoReflect() protoreflect.Message
func (*RedisService_Destination) Reset ¶
func (x *RedisService_Destination) Reset()
func (*RedisService_Destination) String ¶
func (x *RedisService_Destination) String() string
func (*RedisService_Destination) UnmarshalJSON ¶
func (this *RedisService_Destination) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService_Destination
type RedisService_KeyMatch ¶
type RedisService_KeyMatch struct { // String prefix that must match the beginning of the keys. Envoy will always favor the // longest match. Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` // Indicates if the prefix needs to be removed from the key when forwarded. RemovePrefix bool `protobuf:"varint,2,opt,name=remove_prefix,json=removePrefix,proto3" json:"remove_prefix,omitempty"` // contains filtered or unexported fields }
KeyMatch match the redis key prefix;
func (*RedisService_KeyMatch) DeepCopy ¶
func (in *RedisService_KeyMatch) DeepCopy() *RedisService_KeyMatch
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_KeyMatch. Required by controller-gen.
func (*RedisService_KeyMatch) DeepCopyInterface ¶
func (in *RedisService_KeyMatch) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_KeyMatch. Required by controller-gen.
func (*RedisService_KeyMatch) DeepCopyInto ¶
func (in *RedisService_KeyMatch) DeepCopyInto(out *RedisService_KeyMatch)
DeepCopyInto supports using RedisService_KeyMatch within kubernetes types, where deepcopy-gen is used.
func (*RedisService_KeyMatch) Descriptor
deprecated
func (*RedisService_KeyMatch) Descriptor() ([]byte, []int)
Deprecated: Use RedisService_KeyMatch.ProtoReflect.Descriptor instead.
func (*RedisService_KeyMatch) GetPrefix ¶
func (x *RedisService_KeyMatch) GetPrefix() string
func (*RedisService_KeyMatch) GetRemovePrefix ¶
func (x *RedisService_KeyMatch) GetRemovePrefix() bool
func (*RedisService_KeyMatch) MarshalJSON ¶
func (this *RedisService_KeyMatch) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService_KeyMatch
func (*RedisService_KeyMatch) ProtoMessage ¶
func (*RedisService_KeyMatch) ProtoMessage()
func (*RedisService_KeyMatch) ProtoReflect ¶
func (x *RedisService_KeyMatch) ProtoReflect() protoreflect.Message
func (*RedisService_KeyMatch) Reset ¶
func (x *RedisService_KeyMatch) Reset()
func (*RedisService_KeyMatch) String ¶
func (x *RedisService_KeyMatch) String() string
func (*RedisService_KeyMatch) UnmarshalJSON ¶
func (this *RedisService_KeyMatch) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService_KeyMatch
type RedisService_Mirror ¶
type RedisService_Mirror struct { Route *RedisService_Destination `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"` Percentage *Percent `protobuf:"bytes,2,opt,name=percentage,proto3" json:"percentage,omitempty"` ExcludeReadCommands bool `protobuf:"varint,3,opt,name=exclude_read_commands,json=excludeReadCommands,proto3" json:"exclude_read_commands,omitempty"` // contains filtered or unexported fields }
func (*RedisService_Mirror) DeepCopy ¶
func (in *RedisService_Mirror) DeepCopy() *RedisService_Mirror
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Mirror. Required by controller-gen.
func (*RedisService_Mirror) DeepCopyInterface ¶
func (in *RedisService_Mirror) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Mirror. Required by controller-gen.
func (*RedisService_Mirror) DeepCopyInto ¶
func (in *RedisService_Mirror) DeepCopyInto(out *RedisService_Mirror)
DeepCopyInto supports using RedisService_Mirror within kubernetes types, where deepcopy-gen is used.
func (*RedisService_Mirror) Descriptor
deprecated
func (*RedisService_Mirror) Descriptor() ([]byte, []int)
Deprecated: Use RedisService_Mirror.ProtoReflect.Descriptor instead.
func (*RedisService_Mirror) GetExcludeReadCommands ¶
func (x *RedisService_Mirror) GetExcludeReadCommands() bool
func (*RedisService_Mirror) GetPercentage ¶
func (x *RedisService_Mirror) GetPercentage() *Percent
func (*RedisService_Mirror) GetRoute ¶
func (x *RedisService_Mirror) GetRoute() *RedisService_Destination
func (*RedisService_Mirror) MarshalJSON ¶
func (this *RedisService_Mirror) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService_Mirror
func (*RedisService_Mirror) ProtoMessage ¶
func (*RedisService_Mirror) ProtoMessage()
func (*RedisService_Mirror) ProtoReflect ¶
func (x *RedisService_Mirror) ProtoReflect() protoreflect.Message
func (*RedisService_Mirror) Reset ¶
func (x *RedisService_Mirror) Reset()
func (*RedisService_Mirror) String ¶
func (x *RedisService_Mirror) String() string
func (*RedisService_Mirror) UnmarshalJSON ¶
func (this *RedisService_Mirror) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService_Mirror
type RedisService_ReadPolicy ¶
type RedisService_ReadPolicy int32
const ( RedisService_MASTER RedisService_ReadPolicy = 0 RedisService_PREFER_MASTER RedisService_ReadPolicy = 1 RedisService_REPLICA RedisService_ReadPolicy = 2 RedisService_PREFER_REPLICA RedisService_ReadPolicy = 3 RedisService_ANY RedisService_ReadPolicy = 4 )
func (RedisService_ReadPolicy) Descriptor ¶
func (RedisService_ReadPolicy) Descriptor() protoreflect.EnumDescriptor
func (RedisService_ReadPolicy) Enum ¶
func (x RedisService_ReadPolicy) Enum() *RedisService_ReadPolicy
func (RedisService_ReadPolicy) EnumDescriptor
deprecated
func (RedisService_ReadPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use RedisService_ReadPolicy.Descriptor instead.
func (RedisService_ReadPolicy) Number ¶
func (x RedisService_ReadPolicy) Number() protoreflect.EnumNumber
func (RedisService_ReadPolicy) String ¶
func (x RedisService_ReadPolicy) String() string
func (RedisService_ReadPolicy) Type ¶
func (RedisService_ReadPolicy) Type() protoreflect.EnumType
type RedisService_Route ¶
type RedisService_Route struct { Match *RedisService_RouteMatch `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"` Route *RedisService_Destination `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"` Mirror []*RedisService_Mirror `protobuf:"bytes,3,rep,name=mirror,proto3" json:"mirror,omitempty"` // contains filtered or unexported fields }
func (*RedisService_Route) DeepCopy ¶
func (in *RedisService_Route) DeepCopy() *RedisService_Route
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Route. Required by controller-gen.
func (*RedisService_Route) DeepCopyInterface ¶
func (in *RedisService_Route) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Route. Required by controller-gen.
func (*RedisService_Route) DeepCopyInto ¶
func (in *RedisService_Route) DeepCopyInto(out *RedisService_Route)
DeepCopyInto supports using RedisService_Route within kubernetes types, where deepcopy-gen is used.
func (*RedisService_Route) Descriptor
deprecated
func (*RedisService_Route) Descriptor() ([]byte, []int)
Deprecated: Use RedisService_Route.ProtoReflect.Descriptor instead.
func (*RedisService_Route) GetMatch ¶
func (x *RedisService_Route) GetMatch() *RedisService_RouteMatch
func (*RedisService_Route) GetMirror ¶
func (x *RedisService_Route) GetMirror() []*RedisService_Mirror
func (*RedisService_Route) GetRoute ¶
func (x *RedisService_Route) GetRoute() *RedisService_Destination
func (*RedisService_Route) MarshalJSON ¶
func (this *RedisService_Route) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService_Route
func (*RedisService_Route) ProtoMessage ¶
func (*RedisService_Route) ProtoMessage()
func (*RedisService_Route) ProtoReflect ¶
func (x *RedisService_Route) ProtoReflect() protoreflect.Message
func (*RedisService_Route) Reset ¶
func (x *RedisService_Route) Reset()
func (*RedisService_Route) String ¶
func (x *RedisService_Route) String() string
func (*RedisService_Route) UnmarshalJSON ¶
func (this *RedisService_Route) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService_Route
type RedisService_RouteMatch ¶
type RedisService_RouteMatch struct { // Types that are assignable to Match: // // *RedisService_RouteMatch_Key Match isRedisService_RouteMatch_Match `protobuf_oneof:"match"` // contains filtered or unexported fields }
func (*RedisService_RouteMatch) DeepCopy ¶
func (in *RedisService_RouteMatch) DeepCopy() *RedisService_RouteMatch
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_RouteMatch. Required by controller-gen.
func (*RedisService_RouteMatch) DeepCopyInterface ¶
func (in *RedisService_RouteMatch) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_RouteMatch. Required by controller-gen.
func (*RedisService_RouteMatch) DeepCopyInto ¶
func (in *RedisService_RouteMatch) DeepCopyInto(out *RedisService_RouteMatch)
DeepCopyInto supports using RedisService_RouteMatch within kubernetes types, where deepcopy-gen is used.
func (*RedisService_RouteMatch) Descriptor
deprecated
func (*RedisService_RouteMatch) Descriptor() ([]byte, []int)
Deprecated: Use RedisService_RouteMatch.ProtoReflect.Descriptor instead.
func (*RedisService_RouteMatch) GetKey ¶
func (x *RedisService_RouteMatch) GetKey() *RedisService_KeyMatch
func (*RedisService_RouteMatch) GetMatch ¶
func (m *RedisService_RouteMatch) GetMatch() isRedisService_RouteMatch_Match
func (*RedisService_RouteMatch) MarshalJSON ¶
func (this *RedisService_RouteMatch) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService_RouteMatch
func (*RedisService_RouteMatch) ProtoMessage ¶
func (*RedisService_RouteMatch) ProtoMessage()
func (*RedisService_RouteMatch) ProtoReflect ¶
func (x *RedisService_RouteMatch) ProtoReflect() protoreflect.Message
func (*RedisService_RouteMatch) Reset ¶
func (x *RedisService_RouteMatch) Reset()
func (*RedisService_RouteMatch) String ¶
func (x *RedisService_RouteMatch) String() string
func (*RedisService_RouteMatch) UnmarshalJSON ¶
func (this *RedisService_RouteMatch) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService_RouteMatch
type RedisService_RouteMatch_Key ¶
type RedisService_RouteMatch_Key struct {
Key *RedisService_KeyMatch `protobuf:"bytes,1,opt,name=key,proto3,oneof"`
}
type RedisService_Settings ¶
type RedisService_Settings struct { // Indicates that prefix matching should be case insensitive. CaseInsensitive bool `protobuf:"varint,1,opt,name=case_insensitive,json=caseInsensitive,proto3" json:"case_insensitive,omitempty"` // Per-operation timeout in milliseconds. The timer starts when the first // command of a pipeline is written to the backend connection. Each response received from Redis // resets the timer since it signifies that the next command is being processed by the backend. // The only exception to this behavior is when a connection to a backend is not yet established. // In that case, the connect timeout on the cluster will govern the timeout until the connection // is ready. OpTimeout *duration.Duration `protobuf:"bytes,2,opt,name=op_timeout,json=opTimeout,proto3" json:"op_timeout,omitempty"` // Enable per-command statistics per upstream cluster, in addition to the filter level aggregate // count EnableCommandStats bool `protobuf:"varint,3,opt,name=enable_command_stats,json=enableCommandStats,proto3" json:"enable_command_stats,omitempty"` // Maximum size of encoded request buffer before flush is triggered and encoded requests // are sent upstream. If this is unset, the buffer flushes whenever it receives data // and performs no batching. // This feature makes it possible for multiple clients to send requests to Envoy and have // them batched- for example if one is running several worker processes, each with its own // Redis connection. There is no benefit to using this with a single downstream process. // Recommended size (if enabled) is 1024 bytes. MaxBufferSizeBeforeFlush uint32 `` /* 140-byte string literal not displayed */ // The encoded request buffer is flushed N milliseconds after the first request has been // encoded, unless the buffer size has already exceeded `max_buffer_size_before_flush`. // If `max_buffer_size_before_flush` is not set, this flush timer is not used. Otherwise, // the timer should be set according to the number of clients, overall request rate and // desired maximum latency for a single command. For example, if there are many requests // being batched together at a high rate, the buffer will likely be filled before the timer // fires. Alternatively, if the request rate is lower the buffer will not be filled as often // before the timer fires. // If `max_buffer_size_before_flush` is set, but `buffer_flush_timeout` is not, the latter // defaults to 3ms. BufferFlushTimeout *duration.Duration `protobuf:"bytes,5,opt,name=buffer_flush_timeout,json=bufferFlushTimeout,proto3" json:"buffer_flush_timeout,omitempty"` // `max_upstream_unknown_connections` controls how many upstream connections to unknown hosts // can be created at any given time by any given worker thread (see `enable_redirection` for // more details). If the host is unknown and a connection cannot be created due to enforcing // this limit, then redirection will fail and the original redirection error will be passed // downstream unchanged. This limit defaults to 100. MaxUpstreamUnknownConnections *wrappers.UInt32Value `` /* 152-byte string literal not displayed */ // Use hash tagging on every redis key to guarantee that keys with the same hash tag will be // forwarded to the same upstream. The hash key used for determining the upstream in a // consistent hash ring configuration will be computed from the hash tagged key instead of the // whole key. The algorithm used to compute the hash tag is identical to the `redis-cluster // implementation <https://redis.io/topics/cluster-spec#keys-hash-tags>`_. // // Examples: // // * '{user1000}.following' and '{user1000}.followers' **will** be sent to the same upstream // * '{user1000}.following' and '{user1001}.following' **might** be sent to the same upstream EnableHashtagging bool `protobuf:"varint,7,opt,name=enable_hashtagging,json=enableHashtagging,proto3" json:"enable_hashtagging,omitempty"` // Accept `moved and ask redirection // <https://redis.io/topics/cluster-spec#redirection-and-resharding>`_ errors from upstream // redis servers, and retry commands to the specified target server. The target server does not // need to be known to the cluster manager. If the command cannot be redirected, then the // original error is passed downstream unchanged. By default, this support is not enabled. EnableRedirection bool `protobuf:"varint,8,opt,name=enable_redirection,json=enableRedirection,proto3" json:"enable_redirection,omitempty"` // Read policy. The default is to read from the primary. ReadPolicy RedisService_ReadPolicy `` /* 146-byte string literal not displayed */ // Downstream auth. Auth *Auth `protobuf:"bytes,10,opt,name=auth,proto3" json:"auth,omitempty"` // contains filtered or unexported fields }
func (*RedisService_Settings) DeepCopy ¶
func (in *RedisService_Settings) DeepCopy() *RedisService_Settings
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Settings. Required by controller-gen.
func (*RedisService_Settings) DeepCopyInterface ¶
func (in *RedisService_Settings) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisService_Settings. Required by controller-gen.
func (*RedisService_Settings) DeepCopyInto ¶
func (in *RedisService_Settings) DeepCopyInto(out *RedisService_Settings)
DeepCopyInto supports using RedisService_Settings within kubernetes types, where deepcopy-gen is used.
func (*RedisService_Settings) Descriptor
deprecated
func (*RedisService_Settings) Descriptor() ([]byte, []int)
Deprecated: Use RedisService_Settings.ProtoReflect.Descriptor instead.
func (*RedisService_Settings) GetAuth ¶
func (x *RedisService_Settings) GetAuth() *Auth
func (*RedisService_Settings) GetBufferFlushTimeout ¶
func (x *RedisService_Settings) GetBufferFlushTimeout() *duration.Duration
func (*RedisService_Settings) GetCaseInsensitive ¶
func (x *RedisService_Settings) GetCaseInsensitive() bool
func (*RedisService_Settings) GetEnableCommandStats ¶
func (x *RedisService_Settings) GetEnableCommandStats() bool
func (*RedisService_Settings) GetEnableHashtagging ¶
func (x *RedisService_Settings) GetEnableHashtagging() bool
func (*RedisService_Settings) GetEnableRedirection ¶
func (x *RedisService_Settings) GetEnableRedirection() bool
func (*RedisService_Settings) GetMaxBufferSizeBeforeFlush ¶
func (x *RedisService_Settings) GetMaxBufferSizeBeforeFlush() uint32
func (*RedisService_Settings) GetMaxUpstreamUnknownConnections ¶
func (x *RedisService_Settings) GetMaxUpstreamUnknownConnections() *wrappers.UInt32Value
func (*RedisService_Settings) GetOpTimeout ¶
func (x *RedisService_Settings) GetOpTimeout() *duration.Duration
func (*RedisService_Settings) GetReadPolicy ¶
func (x *RedisService_Settings) GetReadPolicy() RedisService_ReadPolicy
func (*RedisService_Settings) MarshalJSON ¶
func (this *RedisService_Settings) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisService_Settings
func (*RedisService_Settings) ProtoMessage ¶
func (*RedisService_Settings) ProtoMessage()
func (*RedisService_Settings) ProtoReflect ¶
func (x *RedisService_Settings) ProtoReflect() protoreflect.Message
func (*RedisService_Settings) Reset ¶
func (x *RedisService_Settings) Reset()
func (*RedisService_Settings) String ¶
func (x *RedisService_Settings) String() string
func (*RedisService_Settings) UnmarshalJSON ¶
func (this *RedisService_Settings) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisService_Settings
type RedisSettings ¶
type RedisSettings struct { Mode RedisSettings_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=redis.aeraki.io.v1alpha1.RedisSettings_Mode" json:"mode,omitempty"` Auth *Auth `protobuf:"bytes,2,opt,name=auth,proto3" json:"auth,omitempty"` DiscoveryEndpoints []string `protobuf:"bytes,3,rep,name=discovery_endpoints,json=discoveryEndpoints,proto3" json:"discovery_endpoints,omitempty"` // contains filtered or unexported fields }
func (*RedisSettings) DeepCopy ¶
func (in *RedisSettings) DeepCopy() *RedisSettings
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisSettings. Required by controller-gen.
func (*RedisSettings) DeepCopyInterface ¶
func (in *RedisSettings) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RedisSettings. Required by controller-gen.
func (*RedisSettings) DeepCopyInto ¶
func (in *RedisSettings) DeepCopyInto(out *RedisSettings)
DeepCopyInto supports using RedisSettings within kubernetes types, where deepcopy-gen is used.
func (*RedisSettings) Descriptor
deprecated
func (*RedisSettings) Descriptor() ([]byte, []int)
Deprecated: Use RedisSettings.ProtoReflect.Descriptor instead.
func (*RedisSettings) GetAuth ¶
func (x *RedisSettings) GetAuth() *Auth
func (*RedisSettings) GetDiscoveryEndpoints ¶
func (x *RedisSettings) GetDiscoveryEndpoints() []string
func (*RedisSettings) GetMode ¶
func (x *RedisSettings) GetMode() RedisSettings_Mode
func (*RedisSettings) MarshalJSON ¶
func (this *RedisSettings) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for RedisSettings
func (*RedisSettings) ProtoMessage ¶
func (*RedisSettings) ProtoMessage()
func (*RedisSettings) ProtoReflect ¶
func (x *RedisSettings) ProtoReflect() protoreflect.Message
func (*RedisSettings) Reset ¶
func (x *RedisSettings) Reset()
func (*RedisSettings) String ¶
func (x *RedisSettings) String() string
func (*RedisSettings) UnmarshalJSON ¶
func (this *RedisSettings) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for RedisSettings
type RedisSettings_Mode ¶
type RedisSettings_Mode int32
const ( RedisSettings_PROXY RedisSettings_Mode = 0 RedisSettings_CLUSTER RedisSettings_Mode = 1 )
func (RedisSettings_Mode) Descriptor ¶
func (RedisSettings_Mode) Descriptor() protoreflect.EnumDescriptor
func (RedisSettings_Mode) Enum ¶
func (x RedisSettings_Mode) Enum() *RedisSettings_Mode
func (RedisSettings_Mode) EnumDescriptor
deprecated
func (RedisSettings_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use RedisSettings_Mode.Descriptor instead.
func (RedisSettings_Mode) Number ¶
func (x RedisSettings_Mode) Number() protoreflect.EnumNumber
func (RedisSettings_Mode) String ¶
func (x RedisSettings_Mode) String() string
func (RedisSettings_Mode) Type ¶
func (RedisSettings_Mode) Type() protoreflect.EnumType
type SecretReference ¶
type SecretReference struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` PasswordField string `protobuf:"bytes,2,opt,name=password_field,json=passwordField,proto3" json:"password_field,omitempty"` UsernameField string `protobuf:"bytes,3,opt,name=username_field,json=usernameField,proto3" json:"username_field,omitempty"` // contains filtered or unexported fields }
func (*SecretReference) DeepCopy ¶
func (in *SecretReference) DeepCopy() *SecretReference
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretReference. Required by controller-gen.
func (*SecretReference) DeepCopyInterface ¶
func (in *SecretReference) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new SecretReference. Required by controller-gen.
func (*SecretReference) DeepCopyInto ¶
func (in *SecretReference) DeepCopyInto(out *SecretReference)
DeepCopyInto supports using SecretReference within kubernetes types, where deepcopy-gen is used.
func (*SecretReference) Descriptor
deprecated
func (*SecretReference) Descriptor() ([]byte, []int)
Deprecated: Use SecretReference.ProtoReflect.Descriptor instead.
func (*SecretReference) GetName ¶
func (x *SecretReference) GetName() string
func (*SecretReference) GetPasswordField ¶
func (x *SecretReference) GetPasswordField() string
func (*SecretReference) GetUsernameField ¶
func (x *SecretReference) GetUsernameField() string
func (*SecretReference) MarshalJSON ¶
func (this *SecretReference) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for SecretReference
func (*SecretReference) ProtoMessage ¶
func (*SecretReference) ProtoMessage()
func (*SecretReference) ProtoReflect ¶
func (x *SecretReference) ProtoReflect() protoreflect.Message
func (*SecretReference) Reset ¶
func (x *SecretReference) Reset()
func (*SecretReference) String ¶
func (x *SecretReference) String() string
func (*SecretReference) UnmarshalJSON ¶
func (this *SecretReference) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for SecretReference
type TrafficPolicy ¶
type TrafficPolicy struct { ConnectionPool *ConnectionPoolSettings `protobuf:"bytes,1,opt,name=connection_pool,json=connectionPool,proto3" json:"connection_pool,omitempty"` // contains filtered or unexported fields }
func (*TrafficPolicy) DeepCopy ¶
func (in *TrafficPolicy) DeepCopy() *TrafficPolicy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TrafficPolicy. Required by controller-gen.
func (*TrafficPolicy) DeepCopyInterface ¶
func (in *TrafficPolicy) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new TrafficPolicy. Required by controller-gen.
func (*TrafficPolicy) DeepCopyInto ¶
func (in *TrafficPolicy) DeepCopyInto(out *TrafficPolicy)
DeepCopyInto supports using TrafficPolicy within kubernetes types, where deepcopy-gen is used.
func (*TrafficPolicy) Descriptor
deprecated
func (*TrafficPolicy) Descriptor() ([]byte, []int)
Deprecated: Use TrafficPolicy.ProtoReflect.Descriptor instead.
func (*TrafficPolicy) GetConnectionPool ¶
func (x *TrafficPolicy) GetConnectionPool() *ConnectionPoolSettings
func (*TrafficPolicy) MarshalJSON ¶
func (this *TrafficPolicy) MarshalJSON() ([]byte, error)
MarshalJSON is a custom marshaler for TrafficPolicy
func (*TrafficPolicy) ProtoMessage ¶
func (*TrafficPolicy) ProtoMessage()
func (*TrafficPolicy) ProtoReflect ¶
func (x *TrafficPolicy) ProtoReflect() protoreflect.Message
func (*TrafficPolicy) Reset ¶
func (x *TrafficPolicy) Reset()
func (*TrafficPolicy) String ¶
func (x *TrafficPolicy) String() string
func (*TrafficPolicy) UnmarshalJSON ¶
func (this *TrafficPolicy) UnmarshalJSON(b []byte) error
UnmarshalJSON is a custom unmarshaler for TrafficPolicy