redis

Documentation

Index

• Variables
• type Compression
  • func (*Compression) Descriptor() ([]byte, []int)
  • func (this *Compression) Equal(that interface{}) bool
  • func (m *Compression) GetAlgorithm() Compression_Algorithm
  • func (m *Compression) GetEnable() bool
  • func (m *Compression) GetThreshold() uint32
  • func (this *Compression) GoString() string
  • func (m *Compression) Marshal() (dAtA []byte, err error)
  • func (m *Compression) MarshalJSON() ([]byte, error)
  • func (m *Compression) MarshalTo(dAtA []byte) (int, error)
  • func (m *Compression) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Compression) ProtoMessage()
  • func (m *Compression) Reset()
  • func (m *Compression) Size() (n int)
  • func (m *Compression) String() string
  • func (m *Compression) Unmarshal(dAtA []byte) error
  • func (m *Compression) UnmarshalJSON(b []byte) error
  • func (m *Compression) Validate() error
  • func (this *Compression) VerboseEqual(that interface{}) error
  • func (m *Compression) XXX_DiscardUnknown()
  • func (m *Compression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Compression) XXX_Merge(src proto.Message)
  • func (m *Compression) XXX_Size() int
  • func (m *Compression) XXX_Unmarshal(b []byte) error
• type CompressionValidationError
  • func (e CompressionValidationError) Cause() error
  • func (e CompressionValidationError) Error() string
  • func (e CompressionValidationError) ErrorName() string
  • func (e CompressionValidationError) Field() string
  • func (e CompressionValidationError) Key() bool
  • func (e CompressionValidationError) Reason() string
• type Compression_Algorithm
  • func (Compression_Algorithm) EnumDescriptor() ([]byte, []int)
  • func (x Compression_Algorithm) String() string
• type ReadStrategy
  • func (ReadStrategy) EnumDescriptor() ([]byte, []int)
  • func (x ReadStrategy) String() string

Variables

var (
	ErrInvalidLengthRedis = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRedis   = fmt.Errorf("proto: integer overflow")
)

var CompressionJSONMarshaler = new(jsonpb.Marshaler)

CompressionJSONMarshaler describes the default jsonpb.Marshaler used by all instances of Compression. This struct is safe to replace or modify but should not be done so concurrently.

var CompressionJSONUnmarshaler = new(jsonpb.Unmarshaler)

CompressionJSONUnmarshaler describes the default jsonpb.Unmarshaler used by all instances of Compression. This struct is safe to replace or modify but should not be done so concurrently.

var Compression_Algorithm_name = map[int32]string{
	0: "SNAPPY",
}

var Compression_Algorithm_value = map[string]int32{
	"SNAPPY": 0,
}

var ReadStrategy_name = map[int32]string{
	0: "MASTER",
	1: "REPLICA",
	2: "BOTH",
}

var ReadStrategy_value = map[string]int32{
	"MASTER":  0,
	"REPLICA": 1,
	"BOTH":    2,
}

Types

type Compression

type Compression struct {
	// Switch of compress, default is off.
	// NOTE: Uncompress will always work.
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// Compression algorithm used in compression filter.
	Algorithm Compression_Algorithm `protobuf:"varint,2,opt,name=algorithm,proto3,enum=redis.Compression_Algorithm" json:"algorithm,omitempty"`
	// Value will be ignored when byte length of value is less than the
	// threshold, must be greater than 0.
	Threshold            uint32   `protobuf:"varint,3,opt,name=threshold,proto3" json:"threshold,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Configuration of compression.

func (*Compression) Descriptor

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

func (*Compression) Equal

func (this *Compression) Equal(that interface{}) bool

func (*Compression) GetAlgorithm

func (m *Compression) GetAlgorithm() Compression_Algorithm

func (*Compression) GetEnable

func (m *Compression) GetEnable() bool

func (*Compression) GetThreshold

func (m *Compression) GetThreshold() uint32

func (*Compression) GoString

func (this *Compression) GoString() string

func (*Compression) Marshal

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

func (*Compression) MarshalJSON

func (m *Compression) MarshalJSON() ([]byte, error)

MarshalJSON satisfies the encoding/json Marshaler interface. This method uses the more correct jsonpb package to correctly marshal the message.

func (*Compression) MarshalTo

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

func (*Compression) MarshalToSizedBuffer

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

func (*Compression) ProtoMessage

func (*Compression) ProtoMessage()

func (*Compression) Reset

func (m *Compression) Reset()

func (*Compression) Size

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

func (*Compression) String

func (m *Compression) String() string

func (*Compression) Unmarshal

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

func (*Compression) UnmarshalJSON

func (m *Compression) UnmarshalJSON(b []byte) error

UnmarshalJSON satisfies the encoding/json Unmarshaler interface. This method uses the more correct jsonpb package to correctly unmarshal the message.

func (*Compression) Validate

func (m *Compression) Validate() error

Validate checks the field values on Compression with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Compression) VerboseEqual

func (this *Compression) VerboseEqual(that interface{}) error

func (*Compression) XXX_DiscardUnknown

func (m *Compression) XXX_DiscardUnknown()

func (*Compression) XXX_Marshal

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

func (*Compression) XXX_Merge

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

func (*Compression) XXX_Size

func (m *Compression) XXX_Size() int

func (*Compression) XXX_Unmarshal

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

type CompressionValidationError

type CompressionValidationError struct {
	// contains filtered or unexported fields
}

CompressionValidationError is the validation error returned by Compression.Validate if the designated constraints aren't met.

func (CompressionValidationError) Cause

func (e CompressionValidationError) Cause() error

Cause function returns cause value.

func (CompressionValidationError) Error

func (e CompressionValidationError) Error() string

Error satisfies the builtin error interface

func (CompressionValidationError) ErrorName

func (e CompressionValidationError) ErrorName() string

ErrorName returns error name.

func (CompressionValidationError) Field

func (e CompressionValidationError) Field() string

Field function returns field value.

func (CompressionValidationError) Key

func (e CompressionValidationError) Key() bool

Key function returns key value.

func (CompressionValidationError) Reason

func (e CompressionValidationError) Reason() string

Reason function returns reason value.

type Compression_Algorithm

type Compression_Algorithm int32

const (
	Compression_SNAPPY Compression_Algorithm = 0
)

func (Compression_Algorithm) EnumDescriptor

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

func (Compression_Algorithm) String

func (x Compression_Algorithm) String() string

type ReadStrategy

type ReadStrategy int32

Strategy of a read only command.

const (
	// Read from master nodes.
	ReadStrategy_MASTER ReadStrategy = 0
	// Read from replica nodes.
	ReadStrategy_REPLICA ReadStrategy = 1
	// Read from all nodes.
	ReadStrategy_BOTH ReadStrategy = 2
)

func (ReadStrategy) EnumDescriptor

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

func (ReadStrategy) String

func (x ReadStrategy) String() string