Versions in this module Expand all Collapse all v2 v2.9.3 Mar 19, 2021 Changes in this version + var File_github_com_micro_go_micro_store_service_proto_store_proto protoreflect.FileDescriptor + func NewStoreEndpoints() []*api.Endpoint + func RegisterStoreHandler(s server.Server, hdlr StoreHandler, opts ...server.HandlerOption) error + type DatabasesRequest struct + func (*DatabasesRequest) Descriptor() ([]byte, []int) + func (*DatabasesRequest) ProtoMessage() + func (x *DatabasesRequest) ProtoReflect() protoreflect.Message + func (x *DatabasesRequest) Reset() + func (x *DatabasesRequest) String() string + type DatabasesResponse struct + Databases []string + func (*DatabasesResponse) Descriptor() ([]byte, []int) + func (*DatabasesResponse) ProtoMessage() + func (x *DatabasesResponse) GetDatabases() []string + func (x *DatabasesResponse) ProtoReflect() protoreflect.Message + func (x *DatabasesResponse) Reset() + func (x *DatabasesResponse) String() string + type DeleteOptions struct + Database string + Table string + func (*DeleteOptions) Descriptor() ([]byte, []int) + func (*DeleteOptions) ProtoMessage() + func (x *DeleteOptions) GetDatabase() string + func (x *DeleteOptions) GetTable() string + func (x *DeleteOptions) ProtoReflect() protoreflect.Message + func (x *DeleteOptions) Reset() + func (x *DeleteOptions) String() string + type DeleteRequest struct + Key string + Options *DeleteOptions + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (x *DeleteRequest) GetKey() string + func (x *DeleteRequest) GetOptions() *DeleteOptions + func (x *DeleteRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRequest) Reset() + func (x *DeleteRequest) String() string + type DeleteResponse struct + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (x *DeleteResponse) ProtoReflect() protoreflect.Message + func (x *DeleteResponse) Reset() + func (x *DeleteResponse) String() string + type Field struct + Type string + Value string + func (*Field) Descriptor() ([]byte, []int) + func (*Field) ProtoMessage() + func (x *Field) GetType() string + func (x *Field) GetValue() string + func (x *Field) ProtoReflect() protoreflect.Message + func (x *Field) Reset() + func (x *Field) String() string + type ListOptions struct + Database string + Limit uint64 + Offset uint64 + Prefix string + Suffix string + Table string + func (*ListOptions) Descriptor() ([]byte, []int) + func (*ListOptions) ProtoMessage() + func (x *ListOptions) GetDatabase() string + func (x *ListOptions) GetLimit() uint64 + func (x *ListOptions) GetOffset() uint64 + func (x *ListOptions) GetPrefix() string + func (x *ListOptions) GetSuffix() string + func (x *ListOptions) GetTable() string + func (x *ListOptions) ProtoReflect() protoreflect.Message + func (x *ListOptions) Reset() + func (x *ListOptions) String() string + type ListRequest struct + Options *ListOptions + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (x *ListRequest) GetOptions() *ListOptions + func (x *ListRequest) ProtoReflect() protoreflect.Message + func (x *ListRequest) Reset() + func (x *ListRequest) String() string + type ListResponse struct + Keys []string + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (x *ListResponse) GetKeys() []string + func (x *ListResponse) ProtoReflect() protoreflect.Message + func (x *ListResponse) Reset() + func (x *ListResponse) String() string + type ReadOptions struct + Database string + Limit uint64 + Offset uint64 + Prefix bool + Suffix bool + Table string + func (*ReadOptions) Descriptor() ([]byte, []int) + func (*ReadOptions) ProtoMessage() + func (x *ReadOptions) GetDatabase() string + func (x *ReadOptions) GetLimit() uint64 + func (x *ReadOptions) GetOffset() uint64 + func (x *ReadOptions) GetPrefix() bool + func (x *ReadOptions) GetSuffix() bool + func (x *ReadOptions) GetTable() string + func (x *ReadOptions) ProtoReflect() protoreflect.Message + func (x *ReadOptions) Reset() + func (x *ReadOptions) String() string + type ReadRequest struct + Key string + Options *ReadOptions + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (x *ReadRequest) GetKey() string + func (x *ReadRequest) GetOptions() *ReadOptions + func (x *ReadRequest) ProtoReflect() protoreflect.Message + func (x *ReadRequest) Reset() + func (x *ReadRequest) String() string + type ReadResponse struct + Records []*Record + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (x *ReadResponse) GetRecords() []*Record + func (x *ReadResponse) ProtoReflect() protoreflect.Message + func (x *ReadResponse) Reset() + func (x *ReadResponse) String() string + type Record struct + Expiry int64 + Key string + Metadata map[string]*Field + Value []byte + func (*Record) Descriptor() ([]byte, []int) + func (*Record) ProtoMessage() + func (x *Record) GetExpiry() int64 + func (x *Record) GetKey() string + func (x *Record) GetMetadata() map[string]*Field + func (x *Record) GetValue() []byte + func (x *Record) ProtoReflect() protoreflect.Message + func (x *Record) Reset() + func (x *Record) String() string + type StoreHandler interface + Databases func(context.Context, *DatabasesRequest, *DatabasesResponse) error + Delete func(context.Context, *DeleteRequest, *DeleteResponse) error + List func(context.Context, *ListRequest, Store_ListStream) error + Read func(context.Context, *ReadRequest, *ReadResponse) error + Tables func(context.Context, *TablesRequest, *TablesResponse) error + Write func(context.Context, *WriteRequest, *WriteResponse) error + type StoreService interface + Databases func(ctx context.Context, in *DatabasesRequest, opts ...client.CallOption) (*DatabasesResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error) + List func(ctx context.Context, in *ListRequest, opts ...client.CallOption) (Store_ListService, error) + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Tables func(ctx context.Context, in *TablesRequest, opts ...client.CallOption) (*TablesResponse, error) + Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error) + func NewStoreService(name string, c client.Client) StoreService + type Store_ListService interface + Close func() error + Context func() context.Context + Recv func() (*ListResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Store_ListStream interface + Close func() error + Context func() context.Context + RecvMsg func(interface{}) error + Send func(*ListResponse) error + SendMsg func(interface{}) error + type TablesRequest struct + Database string + func (*TablesRequest) Descriptor() ([]byte, []int) + func (*TablesRequest) ProtoMessage() + func (x *TablesRequest) GetDatabase() string + func (x *TablesRequest) ProtoReflect() protoreflect.Message + func (x *TablesRequest) Reset() + func (x *TablesRequest) String() string + type TablesResponse struct + Tables []string + func (*TablesResponse) Descriptor() ([]byte, []int) + func (*TablesResponse) ProtoMessage() + func (x *TablesResponse) GetTables() []string + func (x *TablesResponse) ProtoReflect() protoreflect.Message + func (x *TablesResponse) Reset() + func (x *TablesResponse) String() string + type WriteOptions struct + Database string + Expiry int64 + Table string + Ttl int64 + func (*WriteOptions) Descriptor() ([]byte, []int) + func (*WriteOptions) ProtoMessage() + func (x *WriteOptions) GetDatabase() string + func (x *WriteOptions) GetExpiry() int64 + func (x *WriteOptions) GetTable() string + func (x *WriteOptions) GetTtl() int64 + func (x *WriteOptions) ProtoReflect() protoreflect.Message + func (x *WriteOptions) Reset() + func (x *WriteOptions) String() string + type WriteRequest struct + Options *WriteOptions + Record *Record + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (x *WriteRequest) GetOptions() *WriteOptions + func (x *WriteRequest) GetRecord() *Record + func (x *WriteRequest) ProtoReflect() protoreflect.Message + func (x *WriteRequest) Reset() + func (x *WriteRequest) String() string + type WriteResponse struct + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (x *WriteResponse) ProtoReflect() protoreflect.Message + func (x *WriteResponse) Reset() + func (x *WriteResponse) String() string
Go to main page