index

package
v0.0.0-...-dfa5874 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	OpType_name = map[int32]string{
		0: "Upsert",
		1: "Update",
	}
	OpType_value = map[string]int32{
		"Upsert": 0,
		"Update": 1,
	}
)

Enum value maps for OpType.

View Source
var File_index_proto protoreflect.FileDescriptor

Functions

func RegisterIndexServiceServer

func RegisterIndexServiceServer(s *grpc.Server, srv IndexServiceServer)

Types

type AddItemReq

type AddItemReq struct {
	Item    []*Item `protobuf:"bytes,1,rep,name=Item,proto3" json:"Item,omitempty"`                  //items
	MainKey string  `protobuf:"bytes,2,opt,name=MainKey,proto3" json:"MainKey,omitempty"`            //主key
	OpType  OpType  `protobuf:"varint,3,opt,name=OpType,proto3,enum=OpType" json:"OpType,omitempty"` //操作类型
	Version string  `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`            //版本号
	// contains filtered or unexported fields
}

AddItem Request

func (*AddItemReq) Descriptor deprecated

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

Deprecated: Use AddItemReq.ProtoReflect.Descriptor instead.

func (*AddItemReq) GetItem

func (x *AddItemReq) GetItem() []*Item

func (*AddItemReq) GetMainKey

func (x *AddItemReq) GetMainKey() string

func (*AddItemReq) GetOpType

func (x *AddItemReq) GetOpType() OpType

func (*AddItemReq) GetVersion

func (x *AddItemReq) GetVersion() string

func (*AddItemReq) ProtoMessage

func (*AddItemReq) ProtoMessage()

func (*AddItemReq) ProtoReflect

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

func (*AddItemReq) Reset

func (x *AddItemReq) Reset()

func (*AddItemReq) String

func (x *AddItemReq) String() string

type AddItemRsp

type AddItemRsp struct {
	Id        string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`                //item id
	ItemCount int32  `protobuf:"varint,2,opt,name=ItemCount,proto3" json:"ItemCount,omitempty"` //item count in bucket
	Msg       string `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"`              //return msg
	Ret       int32  `protobuf:"varint,4,opt,name=Ret,proto3" json:"Ret,omitempty"`             //返回值return code
	// contains filtered or unexported fields
}

AddItem Response

func (*AddItemRsp) Descriptor deprecated

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

Deprecated: Use AddItemRsp.ProtoReflect.Descriptor instead.

func (*AddItemRsp) GetId

func (x *AddItemRsp) GetId() string

func (*AddItemRsp) GetItemCount

func (x *AddItemRsp) GetItemCount() int32

func (*AddItemRsp) GetMsg

func (x *AddItemRsp) GetMsg() string

func (*AddItemRsp) GetRet

func (x *AddItemRsp) GetRet() int32

func (*AddItemRsp) ProtoMessage

func (*AddItemRsp) ProtoMessage()

func (*AddItemRsp) ProtoReflect

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

func (*AddItemRsp) Reset

func (x *AddItemRsp) Reset()

func (*AddItemRsp) String

func (x *AddItemRsp) String() string

type BloomFilterValueData

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

布隆过滤器编解码存储value类型

func (*BloomFilterValueData) Descriptor deprecated

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

Deprecated: Use BloomFilterValueData.ProtoReflect.Descriptor instead.

func (*BloomFilterValueData) GetBloomFilters

func (x *BloomFilterValueData) GetBloomFilters() []byte

func (*BloomFilterValueData) ProtoMessage

func (*BloomFilterValueData) ProtoMessage()

func (*BloomFilterValueData) ProtoReflect

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

func (*BloomFilterValueData) Reset

func (x *BloomFilterValueData) Reset()

func (*BloomFilterValueData) String

func (x *BloomFilterValueData) String() string

type DeleteKeyReq

type DeleteKeyReq struct {
	MainKey string `protobuf:"bytes,1,opt,name=MainKey,proto3" json:"MainKey,omitempty"`
	// contains filtered or unexported fields
}

DeleteKey Request

func (*DeleteKeyReq) Descriptor deprecated

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

Deprecated: Use DeleteKeyReq.ProtoReflect.Descriptor instead.

func (*DeleteKeyReq) GetMainKey

func (x *DeleteKeyReq) GetMainKey() string

func (*DeleteKeyReq) ProtoMessage

func (*DeleteKeyReq) ProtoMessage()

func (*DeleteKeyReq) ProtoReflect

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

func (*DeleteKeyReq) Reset

func (x *DeleteKeyReq) Reset()

func (*DeleteKeyReq) String

func (x *DeleteKeyReq) String() string

type DeleteKeyRsp

type DeleteKeyRsp struct {
	Ret int32 `protobuf:"varint,1,opt,name=Ret,proto3" json:"Ret,omitempty"` //return code
	// contains filtered or unexported fields
}

DeleteKey Response

func (*DeleteKeyRsp) Descriptor deprecated

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

Deprecated: Use DeleteKeyRsp.ProtoReflect.Descriptor instead.

func (*DeleteKeyRsp) GetRet

func (x *DeleteKeyRsp) GetRet() int32

func (*DeleteKeyRsp) ProtoMessage

func (*DeleteKeyRsp) ProtoMessage()

func (*DeleteKeyRsp) ProtoReflect

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

func (*DeleteKeyRsp) Reset

func (x *DeleteKeyRsp) Reset()

func (*DeleteKeyRsp) String

func (x *DeleteKeyRsp) String() string

type IndexServiceClient

type IndexServiceClient interface {
	//add item 添加Item,同个主key可一次添加多个Item
	AddItem(ctx context.Context, in *AddItemReq, opts ...grpc.CallOption) (*AddItemRsp, error)
	//delete item 删除Item,同个主Key可一次删除多个Item
	RemoveItem(ctx context.Context, in *RemoveItemReq, opts ...grpc.CallOption) (*RemoveItemRsp, error)
	//read items 读取Item列表
	ReadItems(ctx context.Context, in *ReadItemsReq, opts ...grpc.CallOption) (*ReadItemsRsp, error)
	//delete MainKey 删除主Key
	DeleteKey(ctx context.Context, in *DeleteKeyReq, opts ...grpc.CallOption) (*DeleteKeyRsp, error)
	//布隆过滤器:写入
	WriteBloomFilter(ctx context.Context, in *WriteBloomFilterReq, opts ...grpc.CallOption) (*WriteBloomFilterRsp, error)
	//布隆过滤器:读出
	ReadBloomFilter(ctx context.Context, in *ReadBloomFilterReq, opts ...grpc.CallOption) (*ReadBloomFilterRsp, error)
}

IndexServiceClient is the client API for IndexService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type IndexServiceServer

type IndexServiceServer interface {
	//add item 添加Item,同个主key可一次添加多个Item
	AddItem(context.Context, *AddItemReq) (*AddItemRsp, error)
	//delete item 删除Item,同个主Key可一次删除多个Item
	RemoveItem(context.Context, *RemoveItemReq) (*RemoveItemRsp, error)
	//read items 读取Item列表
	ReadItems(context.Context, *ReadItemsReq) (*ReadItemsRsp, error)
	//delete MainKey 删除主Key
	DeleteKey(context.Context, *DeleteKeyReq) (*DeleteKeyRsp, error)
	//布隆过滤器:写入
	WriteBloomFilter(context.Context, *WriteBloomFilterReq) (*WriteBloomFilterRsp, error)
	//布隆过滤器:读出
	ReadBloomFilter(context.Context, *ReadBloomFilterReq) (*ReadBloomFilterRsp, error)
}

IndexServiceServer is the server API for IndexService service.

type IndexValueData

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

索引存储value类型

func (*IndexValueData) Descriptor deprecated

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

Deprecated: Use IndexValueData.ProtoReflect.Descriptor instead.

func (*IndexValueData) GetItems

func (x *IndexValueData) GetItems() []*Item

func (*IndexValueData) ProtoMessage

func (*IndexValueData) ProtoMessage()

func (*IndexValueData) ProtoReflect

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

func (*IndexValueData) Reset

func (x *IndexValueData) Reset()

func (*IndexValueData) String

func (x *IndexValueData) String() string

type Item

type Item struct {
	Id               string  `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`                              //唯一ID,一般对应ProductID
	SortValue        float64 `protobuf:"fixed64,2,opt,name=SortValue,proto3" json:"SortValue,omitempty"`              //打分值
	Time             int64   `protobuf:"varint,3,opt,name=Time,proto3" json:"Time,omitempty"`                         //时间戳
	InvalidSortValue bool    `protobuf:"varint,4,opt,name=InvalidSortValue,proto3" json:"InvalidSortValue,omitempty"` //打分值是否无效,默认false更新
	InvalidTime      bool    `protobuf:"varint,5,opt,name=InvalidTime,proto3" json:"InvalidTime,omitempty"`           //时间戳是否无效,默认false更新
	// contains filtered or unexported fields
}

Item

func (*Item) Descriptor deprecated

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetId

func (x *Item) GetId() string

func (*Item) GetInvalidSortValue

func (x *Item) GetInvalidSortValue() bool

func (*Item) GetInvalidTime

func (x *Item) GetInvalidTime() bool

func (*Item) GetSortValue

func (x *Item) GetSortValue() float64

func (*Item) GetTime

func (x *Item) GetTime() int64

func (*Item) ProtoMessage

func (*Item) ProtoMessage()

func (*Item) ProtoReflect

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

func (*Item) Reset

func (x *Item) Reset()

func (*Item) String

func (x *Item) String() string

type OpType

type OpType int32

操作类型

const (
	OpType_Upsert OpType = 0 //不存在则插入,存在则更新
	OpType_Update OpType = 1 //更新,但是key必须存在
)

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 ReadBloomFilterReq

type ReadBloomFilterReq struct {
	UserID string `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID,omitempty"`
	// contains filtered or unexported fields
}

Read BloomFilter Request

func (*ReadBloomFilterReq) Descriptor deprecated

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

Deprecated: Use ReadBloomFilterReq.ProtoReflect.Descriptor instead.

func (*ReadBloomFilterReq) GetUserID

func (x *ReadBloomFilterReq) GetUserID() string

func (*ReadBloomFilterReq) ProtoMessage

func (*ReadBloomFilterReq) ProtoMessage()

func (*ReadBloomFilterReq) ProtoReflect

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

func (*ReadBloomFilterReq) Reset

func (x *ReadBloomFilterReq) Reset()

func (*ReadBloomFilterReq) String

func (x *ReadBloomFilterReq) String() string

type ReadBloomFilterRsp

type ReadBloomFilterRsp struct {
	BloomFilters [][]byte `protobuf:"bytes,1,rep,name=BloomFilters,proto3" json:"BloomFilters,omitempty"` //布隆过滤器
	Ret          int32    `protobuf:"varint,2,opt,name=Ret,proto3" json:"Ret,omitempty"`
	Msg          string   `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

Read BloomFilter Response

func (*ReadBloomFilterRsp) Descriptor deprecated

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

Deprecated: Use ReadBloomFilterRsp.ProtoReflect.Descriptor instead.

func (*ReadBloomFilterRsp) GetBloomFilters

func (x *ReadBloomFilterRsp) GetBloomFilters() [][]byte

func (*ReadBloomFilterRsp) GetMsg

func (x *ReadBloomFilterRsp) GetMsg() string

func (*ReadBloomFilterRsp) GetRet

func (x *ReadBloomFilterRsp) GetRet() int32

func (*ReadBloomFilterRsp) ProtoMessage

func (*ReadBloomFilterRsp) ProtoMessage()

func (*ReadBloomFilterRsp) ProtoReflect

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

func (*ReadBloomFilterRsp) Reset

func (x *ReadBloomFilterRsp) Reset()

func (*ReadBloomFilterRsp) String

func (x *ReadBloomFilterRsp) String() string

type ReadItemsReq

type ReadItemsReq struct {
	MainKey     string   `protobuf:"bytes,1,opt,name=MainKey,proto3" json:"MainKey,omitempty"`         //主key
	ItemCount   int32    `protobuf:"varint,2,opt,name=ItemCount,proto3" json:"ItemCount,omitempty"`    //限制长度
	BloomFilter [][]byte `protobuf:"bytes,3,rep,name=BloomFilter,proto3" json:"BloomFilter,omitempty"` //布隆过滤器
	Version     string   `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`         //版本号
	// contains filtered or unexported fields
}

ReadItems Request

func (*ReadItemsReq) Descriptor deprecated

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

Deprecated: Use ReadItemsReq.ProtoReflect.Descriptor instead.

func (*ReadItemsReq) GetBloomFilter

func (x *ReadItemsReq) GetBloomFilter() [][]byte

func (*ReadItemsReq) GetItemCount

func (x *ReadItemsReq) GetItemCount() int32

func (*ReadItemsReq) GetMainKey

func (x *ReadItemsReq) GetMainKey() string

func (*ReadItemsReq) GetVersion

func (x *ReadItemsReq) GetVersion() string

func (*ReadItemsReq) ProtoMessage

func (*ReadItemsReq) ProtoMessage()

func (*ReadItemsReq) ProtoReflect

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

func (*ReadItemsReq) Reset

func (x *ReadItemsReq) Reset()

func (*ReadItemsReq) String

func (x *ReadItemsReq) String() string

type ReadItemsRsp

type ReadItemsRsp struct {
	Item []*Item `protobuf:"bytes,1,rep,name=item,proto3" json:"item,omitempty"` //items
	Msg  string  `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`   //return msg
	Ret  int32   `protobuf:"varint,3,opt,name=Ret,proto3" json:"Ret,omitempty"`  //return code
	// contains filtered or unexported fields
}

ReadItems Response

func (*ReadItemsRsp) Descriptor deprecated

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

Deprecated: Use ReadItemsRsp.ProtoReflect.Descriptor instead.

func (*ReadItemsRsp) GetItem

func (x *ReadItemsRsp) GetItem() []*Item

func (*ReadItemsRsp) GetMsg

func (x *ReadItemsRsp) GetMsg() string

func (*ReadItemsRsp) GetRet

func (x *ReadItemsRsp) GetRet() int32

func (*ReadItemsRsp) ProtoMessage

func (*ReadItemsRsp) ProtoMessage()

func (*ReadItemsRsp) ProtoReflect

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

func (*ReadItemsRsp) Reset

func (x *ReadItemsRsp) Reset()

func (*ReadItemsRsp) String

func (x *ReadItemsRsp) String() string

type RemoveItemReq

type RemoveItemReq struct {
	Id      []string `protobuf:"bytes,1,rep,name=Id,proto3" json:"Id,omitempty"`           //items id
	MainKey string   `protobuf:"bytes,2,opt,name=MainKey,proto3" json:"MainKey,omitempty"` //主key
	Version string   `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"` //版本号
	// contains filtered or unexported fields
}

RemoveItem Request

func (*RemoveItemReq) Descriptor deprecated

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

Deprecated: Use RemoveItemReq.ProtoReflect.Descriptor instead.

func (*RemoveItemReq) GetId

func (x *RemoveItemReq) GetId() []string

func (*RemoveItemReq) GetMainKey

func (x *RemoveItemReq) GetMainKey() string

func (*RemoveItemReq) GetVersion

func (x *RemoveItemReq) GetVersion() string

func (*RemoveItemReq) ProtoMessage

func (*RemoveItemReq) ProtoMessage()

func (*RemoveItemReq) ProtoReflect

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

func (*RemoveItemReq) Reset

func (x *RemoveItemReq) Reset()

func (*RemoveItemReq) String

func (x *RemoveItemReq) String() string

type RemoveItemRsp

type RemoveItemRsp struct {
	ChangeCount int32  `protobuf:"varint,1,opt,name=ChangeCount,proto3" json:"ChangeCount,omitempty"` //发生变更的个数
	ItemCount   int32  `protobuf:"varint,2,opt,name=ItemCount,proto3" json:"ItemCount,omitempty"`     //item count in bucket
	Msg         string `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"`                  //return msg
	Ret         int32  `protobuf:"varint,4,opt,name=Ret,proto3" json:"Ret,omitempty"`                 //return code
	// contains filtered or unexported fields
}

RemoveItem Response

func (*RemoveItemRsp) Descriptor deprecated

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

Deprecated: Use RemoveItemRsp.ProtoReflect.Descriptor instead.

func (*RemoveItemRsp) GetChangeCount

func (x *RemoveItemRsp) GetChangeCount() int32

func (*RemoveItemRsp) GetItemCount

func (x *RemoveItemRsp) GetItemCount() int32

func (*RemoveItemRsp) GetMsg

func (x *RemoveItemRsp) GetMsg() string

func (*RemoveItemRsp) GetRet

func (x *RemoveItemRsp) GetRet() int32

func (*RemoveItemRsp) ProtoMessage

func (*RemoveItemRsp) ProtoMessage()

func (*RemoveItemRsp) ProtoReflect

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

func (*RemoveItemRsp) Reset

func (x *RemoveItemRsp) Reset()

func (*RemoveItemRsp) String

func (x *RemoveItemRsp) String() string

type UnimplementedIndexServiceServer

type UnimplementedIndexServiceServer struct {
}

UnimplementedIndexServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexServiceServer) AddItem

func (*UnimplementedIndexServiceServer) DeleteKey

func (*UnimplementedIndexServiceServer) ReadBloomFilter

func (*UnimplementedIndexServiceServer) ReadItems

func (*UnimplementedIndexServiceServer) RemoveItem

func (*UnimplementedIndexServiceServer) WriteBloomFilter

type WriteBloomFilterReq

type WriteBloomFilterReq struct {
	UserID  string   `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID,omitempty"`   //user id
	ItemIds []string `protobuf:"bytes,2,rep,name=ItemIds,proto3" json:"ItemIds,omitempty"` //item id list
	// contains filtered or unexported fields
}

Write BloomFilter Request

func (*WriteBloomFilterReq) Descriptor deprecated

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

Deprecated: Use WriteBloomFilterReq.ProtoReflect.Descriptor instead.

func (*WriteBloomFilterReq) GetItemIds

func (x *WriteBloomFilterReq) GetItemIds() []string

func (*WriteBloomFilterReq) GetUserID

func (x *WriteBloomFilterReq) GetUserID() string

func (*WriteBloomFilterReq) ProtoMessage

func (*WriteBloomFilterReq) ProtoMessage()

func (*WriteBloomFilterReq) ProtoReflect

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

func (*WriteBloomFilterReq) Reset

func (x *WriteBloomFilterReq) Reset()

func (*WriteBloomFilterReq) String

func (x *WriteBloomFilterReq) String() string

type WriteBloomFilterRsp

type WriteBloomFilterRsp struct {
	Ret int32  `protobuf:"varint,1,opt,name=Ret,proto3" json:"Ret,omitempty"`
	Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

Write BloomFilter Response

func (*WriteBloomFilterRsp) Descriptor deprecated

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

Deprecated: Use WriteBloomFilterRsp.ProtoReflect.Descriptor instead.

func (*WriteBloomFilterRsp) GetMsg

func (x *WriteBloomFilterRsp) GetMsg() string

func (*WriteBloomFilterRsp) GetRet

func (x *WriteBloomFilterRsp) GetRet() int32

func (*WriteBloomFilterRsp) ProtoMessage

func (*WriteBloomFilterRsp) ProtoMessage()

func (*WriteBloomFilterRsp) ProtoReflect

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

func (*WriteBloomFilterRsp) Reset

func (x *WriteBloomFilterRsp) Reset()

func (*WriteBloomFilterRsp) String

func (x *WriteBloomFilterRsp) String() string

Jump to

Keyboard shortcuts

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