Versions in this module Expand all Collapse all v1 v1.4.1 Aug 17, 2023 v1.3.0 Jul 28, 2023 Changes in this version + var Fault_Type_name = map[int32]string + var Fault_Type_value = map[string]int32 + var File_redis_v1alpha1_redisdestination_proto protoreflect.FileDescriptor + var File_redis_v1alpha1_redisservice_proto protoreflect.FileDescriptor + var RedisService_ReadPolicy_name = map[int32]string + var RedisService_ReadPolicy_value = map[string]int32 + var RedisSettings_Mode_name = map[int32]string + var RedisSettings_Mode_value = map[string]int32 + var RedisdestinationMarshaler = &jsonpb.Marshaler + var RedisdestinationUnmarshaler = &jsonpb.Unmarshaler + var RedisserviceMarshaler = &jsonpb.Marshaler + var RedisserviceUnmarshaler = &jsonpb.Unmarshaler + type Auth struct + Auth isAuth_Auth + func (*Auth) Descriptor() ([]byte, []int) + func (*Auth) ProtoMessage() + func (in *Auth) DeepCopy() *Auth + func (in *Auth) DeepCopyInterface() interface{} + func (in *Auth) DeepCopyInto(out *Auth) + func (m *Auth) GetAuth() isAuth_Auth + func (this *Auth) MarshalJSON() ([]byte, error) + func (this *Auth) UnmarshalJSON(b []byte) error + func (x *Auth) GetPlain() *PlainAuth + func (x *Auth) GetSecret() *SecretReference + func (x *Auth) ProtoReflect() protoreflect.Message + func (x *Auth) Reset() + func (x *Auth) String() string + type Auth_Plain struct + Plain *PlainAuth + type Auth_Secret struct + Secret *SecretReference + type ConnectionPoolSettings struct + Redis *RedisSettings + Tcp *v1alpha3.ConnectionPoolSettings_TCPSettings + func (*ConnectionPoolSettings) Descriptor() ([]byte, []int) + func (*ConnectionPoolSettings) ProtoMessage() + func (in *ConnectionPoolSettings) DeepCopy() *ConnectionPoolSettings + func (in *ConnectionPoolSettings) DeepCopyInterface() interface{} + func (in *ConnectionPoolSettings) DeepCopyInto(out *ConnectionPoolSettings) + func (this *ConnectionPoolSettings) MarshalJSON() ([]byte, error) + func (this *ConnectionPoolSettings) UnmarshalJSON(b []byte) error + func (x *ConnectionPoolSettings) GetRedis() *RedisSettings + func (x *ConnectionPoolSettings) GetTcp() *v1alpha3.ConnectionPoolSettings_TCPSettings + func (x *ConnectionPoolSettings) ProtoReflect() protoreflect.Message + func (x *ConnectionPoolSettings) Reset() + func (x *ConnectionPoolSettings) String() string + type Fault struct + Commands []string + Delay *duration.Duration + Percentage *Percent + Type Fault_Type + func (*Fault) Descriptor() ([]byte, []int) + func (*Fault) ProtoMessage() + func (in *Fault) DeepCopy() *Fault + func (in *Fault) DeepCopyInterface() interface{} + func (in *Fault) DeepCopyInto(out *Fault) + func (this *Fault) MarshalJSON() ([]byte, error) + func (this *Fault) UnmarshalJSON(b []byte) error + func (x *Fault) GetCommands() []string + func (x *Fault) GetDelay() *duration.Duration + func (x *Fault) GetPercentage() *Percent + func (x *Fault) GetType() Fault_Type + func (x *Fault) ProtoReflect() protoreflect.Message + func (x *Fault) Reset() + func (x *Fault) String() string + type Fault_Type int32 + const Fault_DELAY + const Fault_ERROR + func (Fault_Type) Descriptor() protoreflect.EnumDescriptor + func (Fault_Type) EnumDescriptor() ([]byte, []int) + func (Fault_Type) Type() protoreflect.EnumType + func (x Fault_Type) Enum() *Fault_Type + func (x Fault_Type) Number() protoreflect.EnumNumber + func (x Fault_Type) String() string + type Percent struct + Value float64 + func (*Percent) Descriptor() ([]byte, []int) + func (*Percent) ProtoMessage() + func (in *Percent) DeepCopy() *Percent + func (in *Percent) DeepCopyInterface() interface{} + func (in *Percent) DeepCopyInto(out *Percent) + func (this *Percent) MarshalJSON() ([]byte, error) + func (this *Percent) UnmarshalJSON(b []byte) error + func (x *Percent) GetValue() float64 + func (x *Percent) ProtoReflect() protoreflect.Message + func (x *Percent) Reset() + func (x *Percent) String() string + type PlainAuth struct + Password string + Username string + func (*PlainAuth) Descriptor() ([]byte, []int) + func (*PlainAuth) ProtoMessage() + func (in *PlainAuth) DeepCopy() *PlainAuth + func (in *PlainAuth) DeepCopyInterface() interface{} + func (in *PlainAuth) DeepCopyInto(out *PlainAuth) + func (this *PlainAuth) MarshalJSON() ([]byte, error) + func (this *PlainAuth) UnmarshalJSON(b []byte) error + func (x *PlainAuth) GetPassword() string + func (x *PlainAuth) GetUsername() string + func (x *PlainAuth) ProtoReflect() protoreflect.Message + func (x *PlainAuth) Reset() + func (x *PlainAuth) String() string + type RedisDestination struct + Host string + TrafficPolicy *TrafficPolicy + func (*RedisDestination) Descriptor() ([]byte, []int) + func (*RedisDestination) ProtoMessage() + func (in *RedisDestination) DeepCopy() *RedisDestination + func (in *RedisDestination) DeepCopyInterface() interface{} + func (in *RedisDestination) DeepCopyInto(out *RedisDestination) + func (this *RedisDestination) MarshalJSON() ([]byte, error) + func (this *RedisDestination) UnmarshalJSON(b []byte) error + func (x *RedisDestination) GetHost() string + func (x *RedisDestination) GetTrafficPolicy() *TrafficPolicy + func (x *RedisDestination) ProtoReflect() protoreflect.Message + func (x *RedisDestination) Reset() + func (x *RedisDestination) String() string + type RedisService struct + Faults []*Fault + Host []string + Redis []*RedisService_Route + Settings *RedisService_Settings + func (*RedisService) Descriptor() ([]byte, []int) + func (*RedisService) ProtoMessage() + func (in *RedisService) DeepCopy() *RedisService + func (in *RedisService) DeepCopyInterface() interface{} + func (in *RedisService) DeepCopyInto(out *RedisService) + func (this *RedisService) MarshalJSON() ([]byte, error) + func (this *RedisService) UnmarshalJSON(b []byte) error + func (x *RedisService) GetFaults() []*Fault + func (x *RedisService) GetHost() []string + func (x *RedisService) GetRedis() []*RedisService_Route + func (x *RedisService) GetSettings() *RedisService_Settings + func (x *RedisService) ProtoReflect() protoreflect.Message + func (x *RedisService) Reset() + func (x *RedisService) String() string + type RedisService_Destination struct + Host string + Port uint32 + func (*RedisService_Destination) Descriptor() ([]byte, []int) + func (*RedisService_Destination) ProtoMessage() + func (in *RedisService_Destination) DeepCopy() *RedisService_Destination + func (in *RedisService_Destination) DeepCopyInterface() interface{} + func (in *RedisService_Destination) DeepCopyInto(out *RedisService_Destination) + func (this *RedisService_Destination) MarshalJSON() ([]byte, error) + func (this *RedisService_Destination) UnmarshalJSON(b []byte) error + func (x *RedisService_Destination) GetHost() string + func (x *RedisService_Destination) GetPort() uint32 + func (x *RedisService_Destination) ProtoReflect() protoreflect.Message + func (x *RedisService_Destination) Reset() + func (x *RedisService_Destination) String() string + type RedisService_KeyMatch struct + Prefix string + RemovePrefix bool + func (*RedisService_KeyMatch) Descriptor() ([]byte, []int) + func (*RedisService_KeyMatch) ProtoMessage() + func (in *RedisService_KeyMatch) DeepCopy() *RedisService_KeyMatch + func (in *RedisService_KeyMatch) DeepCopyInterface() interface{} + func (in *RedisService_KeyMatch) DeepCopyInto(out *RedisService_KeyMatch) + func (this *RedisService_KeyMatch) MarshalJSON() ([]byte, error) + func (this *RedisService_KeyMatch) UnmarshalJSON(b []byte) error + func (x *RedisService_KeyMatch) GetPrefix() string + func (x *RedisService_KeyMatch) GetRemovePrefix() bool + func (x *RedisService_KeyMatch) ProtoReflect() protoreflect.Message + func (x *RedisService_KeyMatch) Reset() + func (x *RedisService_KeyMatch) String() string + type RedisService_Mirror struct + ExcludeReadCommands bool + Percentage *Percent + Route *RedisService_Destination + func (*RedisService_Mirror) Descriptor() ([]byte, []int) + func (*RedisService_Mirror) ProtoMessage() + func (in *RedisService_Mirror) DeepCopy() *RedisService_Mirror + func (in *RedisService_Mirror) DeepCopyInterface() interface{} + func (in *RedisService_Mirror) DeepCopyInto(out *RedisService_Mirror) + func (this *RedisService_Mirror) MarshalJSON() ([]byte, error) + func (this *RedisService_Mirror) UnmarshalJSON(b []byte) error + func (x *RedisService_Mirror) GetExcludeReadCommands() bool + func (x *RedisService_Mirror) GetPercentage() *Percent + func (x *RedisService_Mirror) GetRoute() *RedisService_Destination + func (x *RedisService_Mirror) ProtoReflect() protoreflect.Message + func (x *RedisService_Mirror) Reset() + func (x *RedisService_Mirror) String() string + type RedisService_ReadPolicy int32 + const RedisService_ANY + const RedisService_MASTER + const RedisService_PREFER_MASTER + const RedisService_PREFER_REPLICA + const RedisService_REPLICA + func (RedisService_ReadPolicy) Descriptor() protoreflect.EnumDescriptor + func (RedisService_ReadPolicy) EnumDescriptor() ([]byte, []int) + func (RedisService_ReadPolicy) Type() protoreflect.EnumType + func (x RedisService_ReadPolicy) Enum() *RedisService_ReadPolicy + func (x RedisService_ReadPolicy) Number() protoreflect.EnumNumber + func (x RedisService_ReadPolicy) String() string + type RedisService_Route struct + Match *RedisService_RouteMatch + Mirror []*RedisService_Mirror + Route *RedisService_Destination + func (*RedisService_Route) Descriptor() ([]byte, []int) + func (*RedisService_Route) ProtoMessage() + func (in *RedisService_Route) DeepCopy() *RedisService_Route + func (in *RedisService_Route) DeepCopyInterface() interface{} + func (in *RedisService_Route) DeepCopyInto(out *RedisService_Route) + func (this *RedisService_Route) MarshalJSON() ([]byte, error) + func (this *RedisService_Route) UnmarshalJSON(b []byte) error + func (x *RedisService_Route) GetMatch() *RedisService_RouteMatch + func (x *RedisService_Route) GetMirror() []*RedisService_Mirror + func (x *RedisService_Route) GetRoute() *RedisService_Destination + func (x *RedisService_Route) ProtoReflect() protoreflect.Message + func (x *RedisService_Route) Reset() + func (x *RedisService_Route) String() string + type RedisService_RouteMatch struct + Match isRedisService_RouteMatch_Match + func (*RedisService_RouteMatch) Descriptor() ([]byte, []int) + func (*RedisService_RouteMatch) ProtoMessage() + func (in *RedisService_RouteMatch) DeepCopy() *RedisService_RouteMatch + func (in *RedisService_RouteMatch) DeepCopyInterface() interface{} + func (in *RedisService_RouteMatch) DeepCopyInto(out *RedisService_RouteMatch) + func (m *RedisService_RouteMatch) GetMatch() isRedisService_RouteMatch_Match + func (this *RedisService_RouteMatch) MarshalJSON() ([]byte, error) + func (this *RedisService_RouteMatch) UnmarshalJSON(b []byte) error + func (x *RedisService_RouteMatch) GetKey() *RedisService_KeyMatch + func (x *RedisService_RouteMatch) ProtoReflect() protoreflect.Message + func (x *RedisService_RouteMatch) Reset() + func (x *RedisService_RouteMatch) String() string + type RedisService_RouteMatch_Key struct + Key *RedisService_KeyMatch + type RedisService_Settings struct + Auth *Auth + BufferFlushTimeout *duration.Duration + CaseInsensitive bool + EnableCommandStats bool + EnableHashtagging bool + EnableRedirection bool + MaxBufferSizeBeforeFlush uint32 + MaxUpstreamUnknownConnections *wrappers.UInt32Value + OpTimeout *duration.Duration + ReadPolicy RedisService_ReadPolicy + func (*RedisService_Settings) Descriptor() ([]byte, []int) + func (*RedisService_Settings) ProtoMessage() + func (in *RedisService_Settings) DeepCopy() *RedisService_Settings + func (in *RedisService_Settings) DeepCopyInterface() interface{} + func (in *RedisService_Settings) DeepCopyInto(out *RedisService_Settings) + func (this *RedisService_Settings) MarshalJSON() ([]byte, error) + func (this *RedisService_Settings) UnmarshalJSON(b []byte) error + 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 (x *RedisService_Settings) ProtoReflect() protoreflect.Message + func (x *RedisService_Settings) Reset() + func (x *RedisService_Settings) String() string + type RedisSettings struct + Auth *Auth + DiscoveryEndpoints []string + Mode RedisSettings_Mode + func (*RedisSettings) Descriptor() ([]byte, []int) + func (*RedisSettings) ProtoMessage() + func (in *RedisSettings) DeepCopy() *RedisSettings + func (in *RedisSettings) DeepCopyInterface() interface{} + func (in *RedisSettings) DeepCopyInto(out *RedisSettings) + func (this *RedisSettings) MarshalJSON() ([]byte, error) + func (this *RedisSettings) UnmarshalJSON(b []byte) error + func (x *RedisSettings) GetAuth() *Auth + func (x *RedisSettings) GetDiscoveryEndpoints() []string + func (x *RedisSettings) GetMode() RedisSettings_Mode + func (x *RedisSettings) ProtoReflect() protoreflect.Message + func (x *RedisSettings) Reset() + func (x *RedisSettings) String() string + type RedisSettings_Mode int32 + const RedisSettings_CLUSTER + const RedisSettings_PROXY + func (RedisSettings_Mode) Descriptor() protoreflect.EnumDescriptor + func (RedisSettings_Mode) EnumDescriptor() ([]byte, []int) + func (RedisSettings_Mode) Type() protoreflect.EnumType + func (x RedisSettings_Mode) Enum() *RedisSettings_Mode + func (x RedisSettings_Mode) Number() protoreflect.EnumNumber + func (x RedisSettings_Mode) String() string + type SecretReference struct + Name string + PasswordField string + UsernameField string + func (*SecretReference) Descriptor() ([]byte, []int) + func (*SecretReference) ProtoMessage() + func (in *SecretReference) DeepCopy() *SecretReference + func (in *SecretReference) DeepCopyInterface() interface{} + func (in *SecretReference) DeepCopyInto(out *SecretReference) + func (this *SecretReference) MarshalJSON() ([]byte, error) + func (this *SecretReference) UnmarshalJSON(b []byte) error + func (x *SecretReference) GetName() string + func (x *SecretReference) GetPasswordField() string + func (x *SecretReference) GetUsernameField() string + func (x *SecretReference) ProtoReflect() protoreflect.Message + func (x *SecretReference) Reset() + func (x *SecretReference) String() string + type TrafficPolicy struct + ConnectionPool *ConnectionPoolSettings + func (*TrafficPolicy) Descriptor() ([]byte, []int) + func (*TrafficPolicy) ProtoMessage() + func (in *TrafficPolicy) DeepCopy() *TrafficPolicy + func (in *TrafficPolicy) DeepCopyInterface() interface{} + func (in *TrafficPolicy) DeepCopyInto(out *TrafficPolicy) + func (this *TrafficPolicy) MarshalJSON() ([]byte, error) + func (this *TrafficPolicy) UnmarshalJSON(b []byte) error + func (x *TrafficPolicy) GetConnectionPool() *ConnectionPoolSettings + func (x *TrafficPolicy) ProtoReflect() protoreflect.Message + func (x *TrafficPolicy) Reset() + func (x *TrafficPolicy) String() string