pb

package
v1.5.5 Latest Latest
Warning

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

Go to latest
Published: Apr 25, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	OpType_name = map[int32]string{
		0:  "None",
		1:  "Clear",
		2:  "Del",
		3:  "Expire",
		4:  "ExpireAt",
		5:  "HClear",
		6:  "HDel",
		7:  "HIncrBy",
		8:  "HIncrByFloat",
		9:  "HMSet",
		10: "HSet",
		12: "LInsert",
		13: "LPop",
		14: "LPopRPush",
		15: "LPush",
		16: "LPushX",
		17: "LRem",
		18: "LSet",
		19: "LTrim",
		20: "RPop",
		21: "RPopLPush",
		22: "RPush",
		23: "RPushX",
		24: "SAdd",
		25: "SRem",
		26: "Set",
		27: "ZAdd",
		28: "ZClear",
		29: "ZIncrBy",
		30: "ZRem",
		31: "ZRemRangeByRank",
		32: "ZRemRangeByScore",
		33: "Rename",
	}
	OpType_value = map[string]int32{
		"None":             0,
		"Clear":            1,
		"Del":              2,
		"Expire":           3,
		"ExpireAt":         4,
		"HClear":           5,
		"HDel":             6,
		"HIncrBy":          7,
		"HIncrByFloat":     8,
		"HMSet":            9,
		"HSet":             10,
		"LInsert":          12,
		"LPop":             13,
		"LPopRPush":        14,
		"LPush":            15,
		"LPushX":           16,
		"LRem":             17,
		"LSet":             18,
		"LTrim":            19,
		"RPop":             20,
		"RPopLPush":        21,
		"RPush":            22,
		"RPushX":           23,
		"SAdd":             24,
		"SRem":             25,
		"Set":              26,
		"ZAdd":             27,
		"ZClear":           28,
		"ZIncrBy":          29,
		"ZRem":             30,
		"ZRemRangeByRank":  31,
		"ZRemRangeByScore": 32,
		"Rename":           33,
	}
)

Enum value maps for OpType.

View Source
var File_nodis_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Entry

type Entry struct {
	Type uint32 `protobuf:"varint,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
	// Types that are assignable to Value:
	//
	//	*Entry_StringValue
	//	*Entry_ListValue
	//	*Entry_SetValue
	//	*Entry_HashValue
	//	*Entry_ZSetValue
	Value      isEntry_Value `protobuf_oneof:"Value"`
	Expiration int64         `protobuf:"varint,8,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	// contains filtered or unexported fields
}

func (*Entry) Descriptor deprecated

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetExpiration

func (x *Entry) GetExpiration() int64

func (*Entry) GetHashValue

func (x *Entry) GetHashValue() *HashValue

func (*Entry) GetKey

func (x *Entry) GetKey() string

func (*Entry) GetListValue

func (x *Entry) GetListValue() *ListValue

func (*Entry) GetSetValue

func (x *Entry) GetSetValue() *SetValue

func (*Entry) GetStringValue

func (x *Entry) GetStringValue() *StringValue

func (*Entry) GetType

func (x *Entry) GetType() uint32

func (*Entry) GetValue

func (m *Entry) GetValue() isEntry_Value

func (*Entry) GetZSetValue

func (x *Entry) GetZSetValue() *ZSetValue

func (*Entry) Marshal

func (e *Entry) Marshal() ([]byte, error)

func (*Entry) ProtoMessage

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect

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

func (*Entry) Reset

func (x *Entry) Reset()

func (*Entry) String

func (x *Entry) String() string

type Entry_HashValue

type Entry_HashValue struct {
	HashValue *HashValue `protobuf:"bytes,6,opt,name=HashValue,proto3,oneof"`
}

type Entry_ListValue

type Entry_ListValue struct {
	ListValue *ListValue `protobuf:"bytes,4,opt,name=ListValue,proto3,oneof"`
}

type Entry_SetValue

type Entry_SetValue struct {
	SetValue *SetValue `protobuf:"bytes,5,opt,name=SetValue,proto3,oneof"`
}

type Entry_StringValue

type Entry_StringValue struct {
	StringValue *StringValue `protobuf:"bytes,3,opt,name=StringValue,proto3,oneof"`
}

type Entry_ZSetValue

type Entry_ZSetValue struct {
	ZSetValue *ZSetValue `protobuf:"bytes,7,opt,name=ZSetValue,proto3,oneof"`
}

type HashValue

type HashValue struct {
	Values []*MemberBytes `protobuf:"bytes,2,rep,name=Values,proto3" json:"Values,omitempty"`
	// contains filtered or unexported fields
}

func (*HashValue) Descriptor deprecated

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

Deprecated: Use HashValue.ProtoReflect.Descriptor instead.

func (*HashValue) GetValues

func (x *HashValue) GetValues() []*MemberBytes

func (*HashValue) ProtoMessage

func (*HashValue) ProtoMessage()

func (*HashValue) ProtoReflect

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

func (*HashValue) Reset

func (x *HashValue) Reset()

func (*HashValue) String

func (x *HashValue) String() string

type Index

type Index struct {
	Items []*Index_Item `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
	// contains filtered or unexported fields
}

func (*Index) Descriptor deprecated

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

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetItems

func (x *Index) GetItems() []*Index_Item

func (*Index) ProtoMessage

func (*Index) ProtoMessage()

func (*Index) ProtoReflect

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

func (*Index) Reset

func (x *Index) Reset()

func (*Index) String

func (x *Index) String() string

type Index_Item

type Index_Item struct {
	Key  string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*Index_Item) Descriptor deprecated

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

Deprecated: Use Index_Item.ProtoReflect.Descriptor instead.

func (*Index_Item) GetData

func (x *Index_Item) GetData() []byte

func (*Index_Item) GetKey

func (x *Index_Item) GetKey() string

func (*Index_Item) ProtoMessage

func (*Index_Item) ProtoMessage()

func (*Index_Item) ProtoReflect

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

func (*Index_Item) Reset

func (x *Index_Item) Reset()

func (*Index_Item) String

func (x *Index_Item) String() string

type KeyScore

type KeyScore struct {
	Member string  `protobuf:"bytes,1,opt,name=Member,proto3" json:"Member,omitempty"`
	Score  float64 `protobuf:"fixed64,2,opt,name=Score,proto3" json:"Score,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyScore) Descriptor deprecated

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

Deprecated: Use KeyScore.ProtoReflect.Descriptor instead.

func (*KeyScore) GetMember

func (x *KeyScore) GetMember() string

func (*KeyScore) GetScore

func (x *KeyScore) GetScore() float64

func (*KeyScore) ProtoMessage

func (*KeyScore) ProtoMessage()

func (*KeyScore) ProtoReflect

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

func (*KeyScore) Reset

func (x *KeyScore) Reset()

func (*KeyScore) String

func (x *KeyScore) String() string

type ListValue

type ListValue struct {
	Values [][]byte `protobuf:"bytes,2,rep,name=Values,proto3" json:"Values,omitempty"`
	// contains filtered or unexported fields
}

func (*ListValue) Descriptor deprecated

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

Deprecated: Use ListValue.ProtoReflect.Descriptor instead.

func (*ListValue) GetValues

func (x *ListValue) GetValues() [][]byte

func (*ListValue) ProtoMessage

func (*ListValue) ProtoMessage()

func (*ListValue) ProtoReflect

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

func (*ListValue) Reset

func (x *ListValue) Reset()

func (*ListValue) String

func (x *ListValue) String() string

type MemberBytes

type MemberBytes struct {
	Member string `protobuf:"bytes,1,opt,name=Member,proto3" json:"Member,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberBytes) Descriptor deprecated

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

Deprecated: Use MemberBytes.ProtoReflect.Descriptor instead.

func (*MemberBytes) GetMember

func (x *MemberBytes) GetMember() string

func (*MemberBytes) GetValue

func (x *MemberBytes) GetValue() []byte

func (*MemberBytes) ProtoMessage

func (*MemberBytes) ProtoMessage()

func (*MemberBytes) ProtoReflect

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

func (*MemberBytes) Reset

func (x *MemberBytes) Reset()

func (*MemberBytes) String

func (x *MemberBytes) String() string

type Op

type Op struct {
	*Operation
}

func NewOp

func NewOp(typ OpType, key string) *Op

func (*Op) Before

func (o *Op) Before(before bool) *Op

Before set the before

func (*Op) Count

func (o *Op) Count(count int64) *Op

Count set the count

func (*Op) DstKey

func (o *Op) DstKey(key string) *Op

DstKey set the destination key

func (*Op) Expiration

func (o *Op) Expiration(seconds int64) *Op

Expiration set the expiration

func (*Op) Field

func (o *Op) Field(field string) *Op

Field set the field

func (*Op) Fields added in v1.5.0

func (o *Op) Fields(fields ...string) *Op

Fields set the field

func (*Op) IncrFloat

func (o *Op) IncrFloat(i float64) *Op

IncrFloat set the increment

func (*Op) IncrInt

func (o *Op) IncrInt(i int64) *Op

IncrInt set the increment

func (*Op) Index

func (o *Op) Index(index int64) *Op

Index set the index

func (*Op) Max

func (o *Op) Max(max float64) *Op

Max set the max

func (*Op) Member

func (o *Op) Member(member string) *Op

Member set the member

func (*Op) Members

func (o *Op) Members(members []string) *Op

Members set the members

func (*Op) Min

func (o *Op) Min(min float64) *Op

Min set the min

func (*Op) Pivot

func (o *Op) Pivot(pivot []byte) *Op

Pivot set the pivot

func (*Op) Reset added in v1.5.0

func (o *Op) Reset()

func (*Op) Score

func (o *Op) Score(score float64) *Op

Score set the score

func (*Op) Start

func (o *Op) Start(start int64) *Op

Start set the start

func (*Op) Stop

func (o *Op) Stop(stop int64) *Op

Stop set the stop

func (*Op) Value

func (o *Op) Value(v []byte) *Op

func (*Op) Values

func (o *Op) Values(v [][]byte) *Op

Values set the values

type OpType

type OpType int32
const (
	OpType_None             OpType = 0
	OpType_Clear            OpType = 1
	OpType_Del              OpType = 2
	OpType_Expire           OpType = 3
	OpType_ExpireAt         OpType = 4
	OpType_HClear           OpType = 5
	OpType_HDel             OpType = 6
	OpType_HIncrBy          OpType = 7
	OpType_HIncrByFloat     OpType = 8
	OpType_HMSet            OpType = 9
	OpType_HSet             OpType = 10
	OpType_LInsert          OpType = 12
	OpType_LPop             OpType = 13
	OpType_LPopRPush        OpType = 14
	OpType_LPush            OpType = 15
	OpType_LPushX           OpType = 16
	OpType_LRem             OpType = 17
	OpType_LSet             OpType = 18
	OpType_LTrim            OpType = 19
	OpType_RPop             OpType = 20
	OpType_RPopLPush        OpType = 21
	OpType_RPush            OpType = 22
	OpType_RPushX           OpType = 23
	OpType_SAdd             OpType = 24
	OpType_SRem             OpType = 25
	OpType_Set              OpType = 26
	OpType_ZAdd             OpType = 27
	OpType_ZClear           OpType = 28
	OpType_ZIncrBy          OpType = 29
	OpType_ZRem             OpType = 30
	OpType_ZRemRangeByRank  OpType = 31
	OpType_ZRemRangeByScore OpType = 32
	OpType_Rename           OpType = 33
)

func (OpType) Descriptor

func (OpType) Descriptor() protoreflect.EnumDescriptor

func (OpType) Enum

func (x OpType) Enum() *OpType

func (OpType) EnumDescriptor deprecated

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

Deprecated: Use OpType.Descriptor instead.

func (OpType) Number

func (x OpType) Number() protoreflect.EnumNumber

func (OpType) String

func (x OpType) String() string

func (OpType) Type

func (OpType) Type() protoreflect.EnumType

type Operation

type Operation struct {
	Type       OpType   `protobuf:"varint,1,opt,name=Type,proto3,enum=pb.OpType" json:"Type,omitempty"`
	Key        string   `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
	Member     string   `protobuf:"bytes,3,opt,name=Member,proto3" json:"Member,omitempty"`
	Value      []byte   `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Expiration int64    `protobuf:"varint,5,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	Score      float64  `protobuf:"fixed64,6,opt,name=Score,proto3" json:"Score,omitempty"`
	Values     [][]byte `protobuf:"bytes,7,rep,name=Values,proto3" json:"Values,omitempty"`
	DstKey     string   `protobuf:"bytes,8,opt,name=DstKey,proto3" json:"DstKey,omitempty"`
	Pivot      []byte   `protobuf:"bytes,9,opt,name=Pivot,proto3" json:"Pivot,omitempty"`
	Count      int64    `protobuf:"varint,10,opt,name=Count,proto3" json:"Count,omitempty"`
	Index      int64    `protobuf:"varint,11,opt,name=Index,proto3" json:"Index,omitempty"`
	Members    []string `protobuf:"bytes,12,rep,name=Members,proto3" json:"Members,omitempty"`
	Start      int64    `protobuf:"varint,13,opt,name=Start,proto3" json:"Start,omitempty"`
	Stop       int64    `protobuf:"varint,14,opt,name=Stop,proto3" json:"Stop,omitempty"`
	Min        float64  `protobuf:"fixed64,15,opt,name=Min,proto3" json:"Min,omitempty"`
	Max        float64  `protobuf:"fixed64,16,opt,name=Max,proto3" json:"Max,omitempty"`
	Field      string   `protobuf:"bytes,17,opt,name=Field,proto3" json:"Field,omitempty"`
	IncrFloat  float64  `protobuf:"fixed64,18,opt,name=IncrFloat,proto3" json:"IncrFloat,omitempty"`
	IncrInt    int64    `protobuf:"varint,19,opt,name=IncrInt,proto3" json:"IncrInt,omitempty"`
	Before     bool     `protobuf:"varint,20,opt,name=Before,proto3" json:"Before,omitempty"`
	Fields     []string `protobuf:"bytes,21,rep,name=Fields,proto3" json:"Fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated

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

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetBefore

func (x *Operation) GetBefore() bool

func (*Operation) GetCount

func (x *Operation) GetCount() int64

func (*Operation) GetDstKey

func (x *Operation) GetDstKey() string

func (*Operation) GetExpiration

func (x *Operation) GetExpiration() int64

func (*Operation) GetField

func (x *Operation) GetField() string

func (*Operation) GetFields added in v1.5.0

func (x *Operation) GetFields() []string

func (*Operation) GetIncrFloat

func (x *Operation) GetIncrFloat() float64

func (*Operation) GetIncrInt

func (x *Operation) GetIncrInt() int64

func (*Operation) GetIndex

func (x *Operation) GetIndex() int64

func (*Operation) GetKey

func (x *Operation) GetKey() string

func (*Operation) GetMax

func (x *Operation) GetMax() float64

func (*Operation) GetMember

func (x *Operation) GetMember() string

func (*Operation) GetMembers

func (x *Operation) GetMembers() []string

func (*Operation) GetMin

func (x *Operation) GetMin() float64

func (*Operation) GetPivot

func (x *Operation) GetPivot() []byte

func (*Operation) GetScore

func (x *Operation) GetScore() float64

func (*Operation) GetStart

func (x *Operation) GetStart() int64

func (*Operation) GetStop

func (x *Operation) GetStop() int64

func (*Operation) GetType

func (x *Operation) GetType() OpType

func (*Operation) GetValue

func (x *Operation) GetValue() []byte

func (*Operation) GetValues

func (x *Operation) GetValues() [][]byte

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect

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

func (*Operation) Reset

func (x *Operation) Reset()

func (*Operation) String

func (x *Operation) String() string

type SetValue

type SetValue struct {
	Values []string `protobuf:"bytes,2,rep,name=Values,proto3" json:"Values,omitempty"`
	// contains filtered or unexported fields
}

func (*SetValue) Descriptor deprecated

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

Deprecated: Use SetValue.ProtoReflect.Descriptor instead.

func (*SetValue) GetValues

func (x *SetValue) GetValues() []string

func (*SetValue) ProtoMessage

func (*SetValue) ProtoMessage()

func (*SetValue) ProtoReflect

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

func (*SetValue) Reset

func (x *SetValue) Reset()

func (*SetValue) String

func (x *SetValue) String() string

type StringValue

type StringValue struct {
	Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValue) Descriptor deprecated

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

Deprecated: Use StringValue.ProtoReflect.Descriptor instead.

func (*StringValue) GetValue

func (x *StringValue) GetValue() []byte

func (*StringValue) ProtoMessage

func (*StringValue) ProtoMessage()

func (*StringValue) ProtoReflect

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

func (*StringValue) Reset

func (x *StringValue) Reset()

func (*StringValue) String

func (x *StringValue) String() string

type ZSetValue

type ZSetValue struct {
	Values []*KeyScore `protobuf:"bytes,2,rep,name=Values,proto3" json:"Values,omitempty"`
	// contains filtered or unexported fields
}

func (*ZSetValue) Descriptor deprecated

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

Deprecated: Use ZSetValue.ProtoReflect.Descriptor instead.

func (*ZSetValue) GetValues

func (x *ZSetValue) GetValues() []*KeyScore

func (*ZSetValue) ProtoMessage

func (*ZSetValue) ProtoMessage()

func (*ZSetValue) ProtoReflect

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

func (*ZSetValue) Reset

func (x *ZSetValue) Reset()

func (*ZSetValue) String

func (x *ZSetValue) String() string

Jump to

Keyboard shortcuts

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