Versions in this module Expand all Collapse all v1 v1.0.1 May 10, 2021 v1.0.0 May 9, 2021 Changes in this version + func RegisterStoreHandler(s server.Server, hdlr StoreHandler, opts ...server.HandlerOption) error + type DeleteOptions struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteOptions) Descriptor() ([]byte, []int) + func (*DeleteOptions) ProtoMessage() + func (m *DeleteOptions) Reset() + func (m *DeleteOptions) String() string + func (m *DeleteOptions) XXX_DiscardUnknown() + func (m *DeleteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteOptions) XXX_Merge(src proto.Message) + func (m *DeleteOptions) XXX_Size() int + func (m *DeleteOptions) XXX_Unmarshal(b []byte) error + type DeleteRequest struct + Key string + Options *DeleteOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) GetKey() string + func (m *DeleteRequest) GetOptions() *DeleteOptions + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) String() string + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type DeleteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) String() string + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + type ListOptions struct + Limit uint64 + Offset uint64 + Prefix string + Suffix string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListOptions) Descriptor() ([]byte, []int) + func (*ListOptions) ProtoMessage() + func (m *ListOptions) GetLimit() uint64 + func (m *ListOptions) GetOffset() uint64 + func (m *ListOptions) GetPrefix() string + func (m *ListOptions) GetSuffix() string + func (m *ListOptions) Reset() + func (m *ListOptions) String() string + func (m *ListOptions) XXX_DiscardUnknown() + func (m *ListOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListOptions) XXX_Merge(src proto.Message) + func (m *ListOptions) XXX_Size() int + func (m *ListOptions) XXX_Unmarshal(b []byte) error + type ListRequest struct + Options *ListOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) GetOptions() *ListOptions + func (m *ListRequest) Reset() + func (m *ListRequest) String() string + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type ListResponse struct + Keys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (m *ListResponse) GetKeys() []string + func (m *ListResponse) Reset() + func (m *ListResponse) String() string + func (m *ListResponse) XXX_DiscardUnknown() + func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResponse) XXX_Merge(src proto.Message) + func (m *ListResponse) XXX_Size() int + func (m *ListResponse) XXX_Unmarshal(b []byte) error + type ReadOptions struct + Limit uint64 + Offset uint64 + Prefix bool + Suffix bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadOptions) Descriptor() ([]byte, []int) + func (*ReadOptions) ProtoMessage() + func (m *ReadOptions) GetLimit() uint64 + func (m *ReadOptions) GetOffset() uint64 + func (m *ReadOptions) GetPrefix() bool + func (m *ReadOptions) GetSuffix() bool + func (m *ReadOptions) Reset() + func (m *ReadOptions) String() string + func (m *ReadOptions) XXX_DiscardUnknown() + func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadOptions) XXX_Merge(src proto.Message) + func (m *ReadOptions) XXX_Size() int + func (m *ReadOptions) XXX_Unmarshal(b []byte) error + type ReadRequest struct + Key string + Options *ReadOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetKey() string + func (m *ReadRequest) GetOptions() *ReadOptions + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + func (m *ReadRequest) XXX_DiscardUnknown() + func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRequest) XXX_Merge(src proto.Message) + func (m *ReadRequest) XXX_Size() int + func (m *ReadRequest) XXX_Unmarshal(b []byte) error + type ReadResponse struct + Records []*Record + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetRecords() []*Record + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + func (m *ReadResponse) XXX_DiscardUnknown() + func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadResponse) XXX_Merge(src proto.Message) + func (m *ReadResponse) XXX_Size() int + func (m *ReadResponse) XXX_Unmarshal(b []byte) error + type Record struct + Expiry int64 + Key string + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Record) Descriptor() ([]byte, []int) + func (*Record) ProtoMessage() + func (m *Record) GetExpiry() int64 + func (m *Record) GetKey() string + func (m *Record) GetValue() []byte + func (m *Record) Reset() + func (m *Record) String() string + func (m *Record) XXX_DiscardUnknown() + func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Record) XXX_Merge(src proto.Message) + func (m *Record) XXX_Size() int + func (m *Record) XXX_Unmarshal(b []byte) error + type StoreHandler interface + Delete func(context.Context, *DeleteRequest, *DeleteResponse) error + List func(context.Context, *ListRequest, Store_ListStream) error + Read func(context.Context, *ReadRequest, *ReadResponse) error + Write func(context.Context, *WriteRequest, *WriteResponse) error + type StoreService interface + 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) + 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 WriteOptions struct + Expiry int64 + Ttl int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteOptions) Descriptor() ([]byte, []int) + func (*WriteOptions) ProtoMessage() + func (m *WriteOptions) GetExpiry() int64 + func (m *WriteOptions) GetTtl() int64 + func (m *WriteOptions) Reset() + func (m *WriteOptions) String() string + func (m *WriteOptions) XXX_DiscardUnknown() + func (m *WriteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteOptions) XXX_Merge(src proto.Message) + func (m *WriteOptions) XXX_Size() int + func (m *WriteOptions) XXX_Unmarshal(b []byte) error + type WriteRequest struct + Options *WriteOptions + Record *Record + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetOptions() *WriteOptions + func (m *WriteRequest) GetRecord() *Record + func (m *WriteRequest) Reset() + func (m *WriteRequest) String() string + func (m *WriteRequest) XXX_DiscardUnknown() + func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteRequest) XXX_Merge(src proto.Message) + func (m *WriteRequest) XXX_Size() int + func (m *WriteRequest) XXX_Unmarshal(b []byte) error + type WriteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) Reset() + func (m *WriteResponse) String() string + func (m *WriteResponse) XXX_DiscardUnknown() + func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteResponse) XXX_Merge(src proto.Message) + func (m *WriteResponse) XXX_Size() int + func (m *WriteResponse) XXX_Unmarshal(b []byte) error Incompatible versions in this module v2.3.0+incompatible May 9, 2021
Go to main page