v1alpha1

package
v1.4.1 Latest Latest
Warning

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

Go to latest
Published: Aug 17, 2023 License: Apache-2.0 Imports: 12 Imported by: 2

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

Constants

This section is empty.

Variables

View Source
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.

View Source
var (
	RedisdestinationMarshaler   = &jsonpb.Marshaler{}
	RedisdestinationUnmarshaler = &jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source
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.

View Source
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.

View Source
var (
	RedisserviceMarshaler   = &jsonpb.Marshaler{}
	RedisserviceUnmarshaler = &jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source
var File_redis_v1alpha1_redisdestination_proto protoreflect.FileDescriptor
View Source
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

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 deprecated

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

Deprecated: Use Auth.ProtoReflect.Descriptor instead.

func (*Auth) GetAuth

func (m *Auth) GetAuth() isAuth_Auth

func (*Auth) GetPlain

func (x *Auth) GetPlain() *PlainAuth

func (*Auth) GetSecret

func (x *Auth) GetSecret() *SecretReference

func (*Auth) MarshalJSON

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

MarshalJSON is a custom marshaler for Auth

func (*Auth) ProtoMessage

func (*Auth) ProtoMessage()

func (*Auth) ProtoReflect

func (x *Auth) ProtoReflect() protoreflect.Message

func (*Auth) Reset

func (x *Auth) Reset()

func (*Auth) String

func (x *Auth) String() string

func (*Auth) UnmarshalJSON

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

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

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 (*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

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 deprecated

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

Deprecated: Use Fault.ProtoReflect.Descriptor instead.

func (*Fault) GetCommands

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

func (*Fault) GetDelay

func (x *Fault) GetDelay() *duration.Duration

func (*Fault) GetPercentage

func (x *Fault) GetPercentage() *Percent

func (*Fault) GetType

func (x *Fault) GetType() Fault_Type

func (*Fault) MarshalJSON

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

MarshalJSON is a custom marshaler for Fault

func (*Fault) ProtoMessage

func (*Fault) ProtoMessage()

func (*Fault) ProtoReflect

func (x *Fault) ProtoReflect() protoreflect.Message

func (*Fault) Reset

func (x *Fault) Reset()

func (*Fault) String

func (x *Fault) String() string

func (*Fault) UnmarshalJSON

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

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

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

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 deprecated

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

Deprecated: Use Percent.ProtoReflect.Descriptor instead.

func (*Percent) GetValue

func (x *Percent) GetValue() float64

func (*Percent) MarshalJSON

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

MarshalJSON is a custom marshaler for Percent

func (*Percent) ProtoMessage

func (*Percent) ProtoMessage()

func (*Percent) ProtoReflect

func (x *Percent) ProtoReflect() protoreflect.Message

func (*Percent) Reset

func (x *Percent) Reset()

func (*Percent) String

func (x *Percent) String() string

func (*Percent) UnmarshalJSON

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

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

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 deprecated

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

Deprecated: Use PlainAuth.ProtoReflect.Descriptor instead.

func (*PlainAuth) GetPassword

func (x *PlainAuth) GetPassword() string

func (*PlainAuth) GetUsername

func (x *PlainAuth) GetUsername() string

func (*PlainAuth) MarshalJSON

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

MarshalJSON is a custom marshaler for PlainAuth

func (*PlainAuth) ProtoMessage

func (*PlainAuth) ProtoMessage()

func (*PlainAuth) ProtoReflect

func (x *PlainAuth) ProtoReflect() protoreflect.Message

func (*PlainAuth) Reset

func (x *PlainAuth) Reset()

func (*PlainAuth) String

func (x *PlainAuth) String() string

func (*PlainAuth) UnmarshalJSON

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

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

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

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 (*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) Enum

func (RedisService_ReadPolicy) EnumDescriptor deprecated

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

Deprecated: Use RedisService_ReadPolicy.Descriptor instead.

func (RedisService_ReadPolicy) Number

func (RedisService_ReadPolicy) String

func (x RedisService_ReadPolicy) String() string

func (RedisService_ReadPolicy) Type

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 (*RedisService_Route) GetMirror

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

func (*RedisService_Route) GetRoute

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

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 (*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

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 (*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) Enum

func (RedisSettings_Mode) EnumDescriptor deprecated

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

Deprecated: Use RedisSettings_Mode.Descriptor instead.

func (RedisSettings_Mode) Number

func (RedisSettings_Mode) String

func (x RedisSettings_Mode) String() string

func (RedisSettings_Mode) Type

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL