v1alpha1

package
v0.0.0-...-52063fc Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRedisdestination        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRedisdestination          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRedisdestination = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	RedisdestinationMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	RedisdestinationUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source 
var (
	ErrInvalidLengthRedisservice        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRedisservice          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRedisservice = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	RedisserviceMarshaler   = &github_com_gogo_protobuf_jsonpb.Marshaler{}
	RedisserviceUnmarshaler = &github_com_gogo_protobuf_jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source 
var Fault_Type_name = map[int32]string{
	0: "DELAY",
	1: "ERROR",
}
View Source 
var Fault_Type_value = map[string]int32{
	"DELAY": 0,
	"ERROR": 1,
}
View Source 
var RedisService_ReadPolicy_name = map[int32]string{
	0: "MASTER",
	1: "PREFER_MASTER",
	2: "REPLICA",
	3: "PREFER_REPLICA",
	4: "ANY",
}
View Source 
var RedisService_ReadPolicy_value = map[string]int32{
	"MASTER":         0,
	"PREFER_MASTER":  1,
	"REPLICA":        2,
	"PREFER_REPLICA": 3,
	"ANY":            4,
}
View Source 
var RedisSettings_Mode_name = map[int32]string{
	0: "PROXY",
	1: "CLUSTER",
}
View Source 
var RedisSettings_Mode_value = map[string]int32{
	"PROXY":   0,
	"CLUSTER": 1,
}

Functions

This section is empty.

Types

type Auth 

type Auth struct {
	// Types that are valid to be assigned to Auth:
	//	*Auth_Secret
	//	*Auth_Plain
	Auth                 isAuth_Auth `protobuf_oneof:"auth"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Auth provide a way to get redis auth token.

func (*Auth) DeepCopy 

func (in *Auth) DeepCopy() *Auth

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 

func (in *Auth) DeepCopyInto(out *Auth)

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

func (*Auth) Descriptor 

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

func (*Auth) GetAuth 

func (m *Auth) GetAuth() isAuth_Auth

func (*Auth) GetPlain 

func (m *Auth) GetPlain() *PlainAuth

func (*Auth) GetSecret 

func (m *Auth) GetSecret() *SecretReference

func (*Auth) Marshal 

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

func (*Auth) MarshalJSON 

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

MarshalJSON is a custom marshaler for Auth

func (*Auth) MarshalTo 

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

func (*Auth) MarshalToSizedBuffer 

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

func (*Auth) ProtoMessage 

func (*Auth) ProtoMessage()

func (*Auth) Reset 

func (m *Auth) Reset()

func (*Auth) Size 

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

func (*Auth) String 

func (m *Auth) String() string

func (*Auth) Unmarshal 

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

func (*Auth) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for Auth

func (*Auth) XXX_DiscardUnknown 

func (m *Auth) XXX_DiscardUnknown()

func (*Auth) XXX_Marshal 

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

func (*Auth) XXX_Merge 

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

func (*Auth) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Auth) XXX_Size 

func (m *Auth) XXX_Size() int

func (*Auth) XXX_Unmarshal 

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

type Auth_Plain 

type Auth_Plain struct {
	Plain *PlainAuth `protobuf:"bytes,2,opt,name=plain,proto3,oneof" json:"plain,omitempty"`
}

func (*Auth_Plain) MarshalTo 

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

func (*Auth_Plain) MarshalToSizedBuffer 

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

func (*Auth_Plain) Size 

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

type Auth_Secret 

type Auth_Secret struct {
	Secret *SecretReference `protobuf:"bytes,1,opt,name=secret,proto3,oneof" json:"secret,omitempty"`
}

func (*Auth_Secret) MarshalTo 

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

func (*Auth_Secret) MarshalToSizedBuffer 

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

func (*Auth_Secret) Size 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

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 

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

func (*ConnectionPoolSettings) GetRedis 

func (m *ConnectionPoolSettings) GetRedis() *RedisSettings

func (*ConnectionPoolSettings) GetTcp 

func (m *ConnectionPoolSettings) GetTcp() *v1alpha3.ConnectionPoolSettings_TCPSettings

func (*ConnectionPoolSettings) Marshal 

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

func (*ConnectionPoolSettings) MarshalJSON 

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

MarshalJSON is a custom marshaler for ConnectionPoolSettings

func (*ConnectionPoolSettings) MarshalTo 

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

func (*ConnectionPoolSettings) MarshalToSizedBuffer 

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

func (*ConnectionPoolSettings) ProtoMessage 

func (*ConnectionPoolSettings) ProtoMessage()

func (*ConnectionPoolSettings) Reset 

func (m *ConnectionPoolSettings) Reset()

func (*ConnectionPoolSettings) Size 

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

func (*ConnectionPoolSettings) String 

func (m *ConnectionPoolSettings) String() string

func (*ConnectionPoolSettings) Unmarshal 

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

func (*ConnectionPoolSettings) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for ConnectionPoolSettings

func (*ConnectionPoolSettings) XXX_DiscardUnknown 

func (m *ConnectionPoolSettings) XXX_DiscardUnknown()

func (*ConnectionPoolSettings) XXX_Marshal 

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

func (*ConnectionPoolSettings) XXX_Merge 

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

func (*ConnectionPoolSettings) XXX_Size 

func (m *ConnectionPoolSettings) XXX_Size() int

func (*ConnectionPoolSettings) XXX_Unmarshal 

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

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 *types.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Fault defines redis faults used for fault injection.

func (*Fault) DeepCopy 

func (in *Fault) DeepCopy() *Fault

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 

func (in *Fault) DeepCopyInto(out *Fault)

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

func (*Fault) Descriptor 

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

func (*Fault) GetCommands 

func (m *Fault) GetCommands() []string

func (*Fault) GetDelay 

func (m *Fault) GetDelay() *types.Duration

func (*Fault) GetPercentage 

func (m *Fault) GetPercentage() *Percent

func (*Fault) GetType 

func (m *Fault) GetType() Fault_Type

func (*Fault) Marshal 

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

func (*Fault) MarshalJSON 

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

MarshalJSON is a custom marshaler for Fault

func (*Fault) MarshalTo 

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

func (*Fault) MarshalToSizedBuffer 

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

func (*Fault) ProtoMessage 

func (*Fault) ProtoMessage()

func (*Fault) Reset 

func (m *Fault) Reset()

func (*Fault) Size 

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

func (*Fault) String 

func (m *Fault) String() string

func (*Fault) Unmarshal 

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

func (*Fault) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for Fault

func (*Fault) XXX_DiscardUnknown 

func (m *Fault) XXX_DiscardUnknown()

func (*Fault) XXX_Marshal 

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

func (*Fault) XXX_Merge 

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

func (*Fault) XXX_Size 

func (m *Fault) XXX_Size() int

func (*Fault) XXX_Unmarshal 

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

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) EnumDescriptor 

func (Fault_Type) EnumDescriptor() ([]byte, []int)

func (Fault_Type) String 

func (x Fault_Type) String() string

type Percent 

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

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

func (*Percent) DeepCopy 

func (in *Percent) DeepCopy() *Percent

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

func (*Percent) DeepCopyInterface 

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

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

func (*Percent) DeepCopyInto 

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

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

func (*Percent) Descriptor 

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

func (*Percent) GetValue 

func (m *Percent) GetValue() float64

func (*Percent) Marshal 

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

func (*Percent) MarshalJSON 

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

MarshalJSON is a custom marshaler for Percent

func (*Percent) MarshalTo 

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

func (*Percent) MarshalToSizedBuffer 

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

func (*Percent) ProtoMessage 

func (*Percent) ProtoMessage()

func (*Percent) Reset 

func (m *Percent) Reset()

func (*Percent) Size 

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

func (*Percent) String 

func (m *Percent) String() string

func (*Percent) Unmarshal 

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

func (*Percent) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for Percent

func (*Percent) XXX_DiscardUnknown 

func (m *Percent) XXX_DiscardUnknown()

func (*Percent) XXX_Marshal 

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

func (*Percent) XXX_Merge 

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

func (*Percent) XXX_Size 

func (m *Percent) XXX_Size() int

func (*Percent) XXX_Unmarshal 

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

type 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PlainAuth) DeepCopy 

func (in *PlainAuth) DeepCopy() *PlainAuth

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 

func (in *PlainAuth) DeepCopyInto(out *PlainAuth)

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

func (*PlainAuth) Descriptor 

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

func (*PlainAuth) GetPassword 

func (m *PlainAuth) GetPassword() string

func (*PlainAuth) GetUsername 

func (m *PlainAuth) GetUsername() string

func (*PlainAuth) Marshal 

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

func (*PlainAuth) MarshalJSON 

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

MarshalJSON is a custom marshaler for PlainAuth

func (*PlainAuth) MarshalTo 

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

func (*PlainAuth) MarshalToSizedBuffer 

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

func (*PlainAuth) ProtoMessage 

func (*PlainAuth) ProtoMessage()

func (*PlainAuth) Reset 

func (m *PlainAuth) Reset()

func (*PlainAuth) Size 

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

func (*PlainAuth) String 

func (m *PlainAuth) String() string

func (*PlainAuth) Unmarshal 

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

func (*PlainAuth) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for PlainAuth

func (*PlainAuth) XXX_DiscardUnknown 

func (m *PlainAuth) XXX_DiscardUnknown()

func (*PlainAuth) XXX_Marshal 

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

func (*PlainAuth) XXX_Merge 

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

func (*PlainAuth) XXX_Size 

func (m *PlainAuth) XXX_Size() int

func (*PlainAuth) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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 

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

func (*RedisDestination) GetHost 

func (m *RedisDestination) GetHost() string

func (*RedisDestination) GetTrafficPolicy 

func (m *RedisDestination) GetTrafficPolicy() *TrafficPolicy

func (*RedisDestination) Marshal 

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

func (*RedisDestination) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisDestination

func (*RedisDestination) MarshalTo 

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

func (*RedisDestination) MarshalToSizedBuffer 

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

func (*RedisDestination) ProtoMessage 

func (*RedisDestination) ProtoMessage()

func (*RedisDestination) Reset 

func (m *RedisDestination) Reset()

func (*RedisDestination) Size 

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

func (*RedisDestination) String 

func (m *RedisDestination) String() string

func (*RedisDestination) Unmarshal 

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

func (*RedisDestination) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisDestination

func (*RedisDestination) XXX_DiscardUnknown 

func (m *RedisDestination) XXX_DiscardUnknown()

func (*RedisDestination) XXX_Marshal 

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

func (*RedisDestination) XXX_Merge 

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

func (*RedisDestination) XXX_Size 

func (m *RedisDestination) XXX_Size() int

func (*RedisDestination) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*RedisService) GetFaults 

func (m *RedisService) GetFaults() []*Fault

func (*RedisService) GetHost 

func (m *RedisService) GetHost() []string

func (*RedisService) GetRedis 

func (m *RedisService) GetRedis() []*RedisService_Route

func (*RedisService) GetSettings 

func (m *RedisService) GetSettings() *RedisService_Settings

func (*RedisService) Marshal 

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

func (*RedisService) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService

func (*RedisService) MarshalTo 

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

func (*RedisService) MarshalToSizedBuffer 

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

func (*RedisService) ProtoMessage 

func (*RedisService) ProtoMessage()

func (*RedisService) Reset 

func (m *RedisService) Reset()

func (*RedisService) Size 

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

func (*RedisService) String 

func (m *RedisService) String() string

func (*RedisService) Unmarshal 

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

func (*RedisService) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService

func (*RedisService) XXX_DiscardUnknown 

func (m *RedisService) XXX_DiscardUnknown()

func (*RedisService) XXX_Marshal 

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

func (*RedisService) XXX_Merge 

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

func (*RedisService) XXX_Size 

func (m *RedisService) XXX_Size() int

func (*RedisService) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*RedisService_Destination) GetHost 

func (m *RedisService_Destination) GetHost() string

func (*RedisService_Destination) GetPort 

func (m *RedisService_Destination) GetPort() uint32

func (*RedisService_Destination) Marshal 

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

func (*RedisService_Destination) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService_Destination

func (*RedisService_Destination) MarshalTo 

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

func (*RedisService_Destination) MarshalToSizedBuffer 

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

func (*RedisService_Destination) ProtoMessage 

func (*RedisService_Destination) ProtoMessage()

func (*RedisService_Destination) Reset 

func (m *RedisService_Destination) Reset()

func (*RedisService_Destination) Size 

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

func (*RedisService_Destination) String 

func (m *RedisService_Destination) String() string

func (*RedisService_Destination) Unmarshal 

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

func (*RedisService_Destination) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService_Destination

func (*RedisService_Destination) XXX_DiscardUnknown 

func (m *RedisService_Destination) XXX_DiscardUnknown()

func (*RedisService_Destination) XXX_Marshal 

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

func (*RedisService_Destination) XXX_Merge 

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

func (*RedisService_Destination) XXX_Size 

func (m *RedisService_Destination) XXX_Size() int

func (*RedisService_Destination) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*RedisService_KeyMatch) GetPrefix 

func (m *RedisService_KeyMatch) GetPrefix() string

func (*RedisService_KeyMatch) GetRemovePrefix 

func (m *RedisService_KeyMatch) GetRemovePrefix() bool

func (*RedisService_KeyMatch) Marshal 

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

func (*RedisService_KeyMatch) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService_KeyMatch

func (*RedisService_KeyMatch) MarshalTo 

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

func (*RedisService_KeyMatch) MarshalToSizedBuffer 

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

func (*RedisService_KeyMatch) ProtoMessage 

func (*RedisService_KeyMatch) ProtoMessage()

func (*RedisService_KeyMatch) Reset 

func (m *RedisService_KeyMatch) Reset()

func (*RedisService_KeyMatch) Size 

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

func (*RedisService_KeyMatch) String 

func (m *RedisService_KeyMatch) String() string

func (*RedisService_KeyMatch) Unmarshal 

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

func (*RedisService_KeyMatch) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService_KeyMatch

func (*RedisService_KeyMatch) XXX_DiscardUnknown 

func (m *RedisService_KeyMatch) XXX_DiscardUnknown()

func (*RedisService_KeyMatch) XXX_Marshal 

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

func (*RedisService_KeyMatch) XXX_Merge 

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

func (*RedisService_KeyMatch) XXX_Size 

func (m *RedisService_KeyMatch) XXX_Size() int

func (*RedisService_KeyMatch) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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 

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

func (*RedisService_Mirror) GetExcludeReadCommands 

func (m *RedisService_Mirror) GetExcludeReadCommands() bool

func (*RedisService_Mirror) GetPercentage 

func (m *RedisService_Mirror) GetPercentage() *Percent

func (*RedisService_Mirror) GetRoute 

func (m *RedisService_Mirror) GetRoute() *RedisService_Destination

func (*RedisService_Mirror) Marshal 

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

func (*RedisService_Mirror) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService_Mirror

func (*RedisService_Mirror) MarshalTo 

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

func (*RedisService_Mirror) MarshalToSizedBuffer 

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

func (*RedisService_Mirror) ProtoMessage 

func (*RedisService_Mirror) ProtoMessage()

func (*RedisService_Mirror) Reset 

func (m *RedisService_Mirror) Reset()

func (*RedisService_Mirror) Size 

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

func (*RedisService_Mirror) String 

func (m *RedisService_Mirror) String() string

func (*RedisService_Mirror) Unmarshal 

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

func (*RedisService_Mirror) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService_Mirror

func (*RedisService_Mirror) XXX_DiscardUnknown 

func (m *RedisService_Mirror) XXX_DiscardUnknown()

func (*RedisService_Mirror) XXX_Marshal 

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

func (*RedisService_Mirror) XXX_Merge 

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

func (*RedisService_Mirror) XXX_Size 

func (m *RedisService_Mirror) XXX_Size() int

func (*RedisService_Mirror) XXX_Unmarshal 

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

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) EnumDescriptor 

func (RedisService_ReadPolicy) EnumDescriptor() ([]byte, []int)

func (RedisService_ReadPolicy) String 

func (x RedisService_ReadPolicy) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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 

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

func (*RedisService_Route) GetMatch 

func (m *RedisService_Route) GetMatch() *RedisService_RouteMatch

func (*RedisService_Route) GetMirror 

func (m *RedisService_Route) GetMirror() []*RedisService_Mirror

func (*RedisService_Route) GetRoute 

func (m *RedisService_Route) GetRoute() *RedisService_Destination

func (*RedisService_Route) Marshal 

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

func (*RedisService_Route) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService_Route

func (*RedisService_Route) MarshalTo 

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

func (*RedisService_Route) MarshalToSizedBuffer 

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

func (*RedisService_Route) ProtoMessage 

func (*RedisService_Route) ProtoMessage()

func (*RedisService_Route) Reset 

func (m *RedisService_Route) Reset()

func (*RedisService_Route) Size 

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

func (*RedisService_Route) String 

func (m *RedisService_Route) String() string

func (*RedisService_Route) Unmarshal 

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

func (*RedisService_Route) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService_Route

func (*RedisService_Route) XXX_DiscardUnknown 

func (m *RedisService_Route) XXX_DiscardUnknown()

func (*RedisService_Route) XXX_Marshal 

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

func (*RedisService_Route) XXX_Merge 

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

func (*RedisService_Route) XXX_Size 

func (m *RedisService_Route) XXX_Size() int

func (*RedisService_Route) XXX_Unmarshal 

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

type RedisService_RouteMatch 

type RedisService_RouteMatch struct {
	// Types that are valid to be assigned to Match:
	//	*RedisService_RouteMatch_Key
	Match                isRedisService_RouteMatch_Match `protobuf_oneof:"match"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

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 

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

func (*RedisService_RouteMatch) GetKey 

func (m *RedisService_RouteMatch) GetKey() *RedisService_KeyMatch

func (*RedisService_RouteMatch) GetMatch 

func (m *RedisService_RouteMatch) GetMatch() isRedisService_RouteMatch_Match

func (*RedisService_RouteMatch) Marshal 

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

func (*RedisService_RouteMatch) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService_RouteMatch

func (*RedisService_RouteMatch) MarshalTo 

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

func (*RedisService_RouteMatch) MarshalToSizedBuffer 

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

func (*RedisService_RouteMatch) ProtoMessage 

func (*RedisService_RouteMatch) ProtoMessage()

func (*RedisService_RouteMatch) Reset 

func (m *RedisService_RouteMatch) Reset()

func (*RedisService_RouteMatch) Size 

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

func (*RedisService_RouteMatch) String 

func (m *RedisService_RouteMatch) String() string

func (*RedisService_RouteMatch) Unmarshal 

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

func (*RedisService_RouteMatch) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService_RouteMatch

func (*RedisService_RouteMatch) XXX_DiscardUnknown 

func (m *RedisService_RouteMatch) XXX_DiscardUnknown()

func (*RedisService_RouteMatch) XXX_Marshal 

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

func (*RedisService_RouteMatch) XXX_Merge 

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

func (*RedisService_RouteMatch) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*RedisService_RouteMatch) XXX_Size 

func (m *RedisService_RouteMatch) XXX_Size() int

func (*RedisService_RouteMatch) XXX_Unmarshal 

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

type RedisService_RouteMatch_Key 

type RedisService_RouteMatch_Key struct {
	Key *RedisService_KeyMatch `protobuf:"bytes,1,opt,name=key,proto3,oneof" json:"key,omitempty"`
}

func (*RedisService_RouteMatch_Key) MarshalTo 

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

func (*RedisService_RouteMatch_Key) MarshalToSizedBuffer 

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

func (*RedisService_RouteMatch_Key) Size 

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

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 *types.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 *types.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 *types.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*RedisService_Settings) GetAuth 

func (m *RedisService_Settings) GetAuth() *Auth

func (*RedisService_Settings) GetBufferFlushTimeout 

func (m *RedisService_Settings) GetBufferFlushTimeout() *types.Duration

func (*RedisService_Settings) GetCaseInsensitive 

func (m *RedisService_Settings) GetCaseInsensitive() bool

func (*RedisService_Settings) GetEnableCommandStats 

func (m *RedisService_Settings) GetEnableCommandStats() bool

func (*RedisService_Settings) GetEnableHashtagging 

func (m *RedisService_Settings) GetEnableHashtagging() bool

func (*RedisService_Settings) GetEnableRedirection 

func (m *RedisService_Settings) GetEnableRedirection() bool

func (*RedisService_Settings) GetMaxBufferSizeBeforeFlush 

func (m *RedisService_Settings) GetMaxBufferSizeBeforeFlush() uint32

func (*RedisService_Settings) GetMaxUpstreamUnknownConnections 

func (m *RedisService_Settings) GetMaxUpstreamUnknownConnections() *types.UInt32Value

func (*RedisService_Settings) GetOpTimeout 

func (m *RedisService_Settings) GetOpTimeout() *types.Duration

func (*RedisService_Settings) GetReadPolicy 

func (m *RedisService_Settings) GetReadPolicy() RedisService_ReadPolicy

func (*RedisService_Settings) Marshal 

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

func (*RedisService_Settings) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisService_Settings

func (*RedisService_Settings) MarshalTo 

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

func (*RedisService_Settings) MarshalToSizedBuffer 

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

func (*RedisService_Settings) ProtoMessage 

func (*RedisService_Settings) ProtoMessage()

func (*RedisService_Settings) Reset 

func (m *RedisService_Settings) Reset()

func (*RedisService_Settings) Size 

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

func (*RedisService_Settings) String 

func (m *RedisService_Settings) String() string

func (*RedisService_Settings) Unmarshal 

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

func (*RedisService_Settings) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisService_Settings

func (*RedisService_Settings) XXX_DiscardUnknown 

func (m *RedisService_Settings) XXX_DiscardUnknown()

func (*RedisService_Settings) XXX_Marshal 

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

func (*RedisService_Settings) XXX_Merge 

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

func (*RedisService_Settings) XXX_Size 

func (m *RedisService_Settings) XXX_Size() int

func (*RedisService_Settings) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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 

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

func (*RedisSettings) GetAuth 

func (m *RedisSettings) GetAuth() *Auth

func (*RedisSettings) GetDiscoveryEndpoints 

func (m *RedisSettings) GetDiscoveryEndpoints() []string

func (*RedisSettings) GetMode 

func (m *RedisSettings) GetMode() RedisSettings_Mode

func (*RedisSettings) Marshal 

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

func (*RedisSettings) MarshalJSON 

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

MarshalJSON is a custom marshaler for RedisSettings

func (*RedisSettings) MarshalTo 

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

func (*RedisSettings) MarshalToSizedBuffer 

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

func (*RedisSettings) ProtoMessage 

func (*RedisSettings) ProtoMessage()

func (*RedisSettings) Reset 

func (m *RedisSettings) Reset()

func (*RedisSettings) Size 

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

func (*RedisSettings) String 

func (m *RedisSettings) String() string

func (*RedisSettings) Unmarshal 

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

func (*RedisSettings) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for RedisSettings

func (*RedisSettings) XXX_DiscardUnknown 

func (m *RedisSettings) XXX_DiscardUnknown()

func (*RedisSettings) XXX_Marshal 

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

func (*RedisSettings) XXX_Merge 

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

func (*RedisSettings) XXX_Size 

func (m *RedisSettings) XXX_Size() int

func (*RedisSettings) XXX_Unmarshal 

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

type RedisSettings_Mode 

type RedisSettings_Mode int32
const (
	RedisSettings_PROXY   RedisSettings_Mode = 0
	RedisSettings_CLUSTER RedisSettings_Mode = 1
)

func (RedisSettings_Mode) EnumDescriptor 

func (RedisSettings_Mode) EnumDescriptor() ([]byte, []int)

func (RedisSettings_Mode) String 

func (x RedisSettings_Mode) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*SecretReference) GetName 

func (m *SecretReference) GetName() string

func (*SecretReference) GetPasswordField 

func (m *SecretReference) GetPasswordField() string

func (*SecretReference) GetUsernameField 

func (m *SecretReference) GetUsernameField() string

func (*SecretReference) Marshal 

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

func (*SecretReference) MarshalJSON 

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

MarshalJSON is a custom marshaler for SecretReference

func (*SecretReference) MarshalTo 

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

func (*SecretReference) MarshalToSizedBuffer 

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

func (*SecretReference) ProtoMessage 

func (*SecretReference) ProtoMessage()

func (*SecretReference) Reset 

func (m *SecretReference) Reset()

func (*SecretReference) Size 

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

func (*SecretReference) String 

func (m *SecretReference) String() string

func (*SecretReference) Unmarshal 

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

func (*SecretReference) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for SecretReference

func (*SecretReference) XXX_DiscardUnknown 

func (m *SecretReference) XXX_DiscardUnknown()

func (*SecretReference) XXX_Marshal 

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

func (*SecretReference) XXX_Merge 

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

func (*SecretReference) XXX_Size 

func (m *SecretReference) XXX_Size() int

func (*SecretReference) XXX_Unmarshal 

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

type TrafficPolicy 

type TrafficPolicy struct {
	ConnectionPool       *ConnectionPoolSettings `protobuf:"bytes,1,opt,name=connection_pool,json=connectionPool,proto3" json:"connection_pool,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

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 

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

func (*TrafficPolicy) GetConnectionPool 

func (m *TrafficPolicy) GetConnectionPool() *ConnectionPoolSettings

func (*TrafficPolicy) Marshal 

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

func (*TrafficPolicy) MarshalJSON 

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

MarshalJSON is a custom marshaler for TrafficPolicy

func (*TrafficPolicy) MarshalTo 

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

func (*TrafficPolicy) MarshalToSizedBuffer 

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

func (*TrafficPolicy) ProtoMessage 

func (*TrafficPolicy) ProtoMessage()

func (*TrafficPolicy) Reset 

func (m *TrafficPolicy) Reset()

func (*TrafficPolicy) Size 

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

func (*TrafficPolicy) String 

func (m *TrafficPolicy) String() string

func (*TrafficPolicy) Unmarshal 

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

func (*TrafficPolicy) UnmarshalJSON 

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

UnmarshalJSON is a custom unmarshaler for TrafficPolicy

func (*TrafficPolicy) XXX_DiscardUnknown 

func (m *TrafficPolicy) XXX_DiscardUnknown()

func (*TrafficPolicy) XXX_Marshal 

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

func (*TrafficPolicy) XXX_Merge 

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

func (*TrafficPolicy) XXX_Size 

func (m *TrafficPolicy) XXX_Size() int

func (*TrafficPolicy) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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