go_micro_store

package

Go to main page

Versions in this module

v1

v1.18.0

Dec 8, 2019

v1.17.1

Nov 27, 2019

v1.17.0

Nov 27, 2019

v1.16.0

Nov 9, 2019

v1.15.1

Nov 3, 2019

v1.15.0

Nov 3, 2019

v1.14.0

Oct 25, 2019

Changes in this version

+ type ListRequest struct

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

+ func (m *ListRequest) GetKey() string

+ 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

+ Records []*Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListResponse) Descriptor() ([]byte, []int)

+ func (*ListResponse) ProtoMessage()

+ func (m *ListResponse) GetRecords() []*Record

+ 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 StoreClient

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Store_ListClient, error)

type StoreHandler

+ List func(context.Context, *ListRequest, Store_ListStream) error

type StoreServer

+ List func(*ListRequest, Store_ListServer) error

type StoreService

+ List func(ctx context.Context, in *ListRequest, opts ...client.CallOption) (Store_ListService, error)

+ type Store_ListClient interface

+ Recv func() (*ListResponse, error)

+ type Store_ListServer interface

+ Send func(*ListResponse) error

+ type Store_ListService interface

+ Close func() error

+ Recv func() (*ListResponse, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type Store_ListStream interface

+ Close func() error

+ RecvMsg func(interface{}) error

+ Send func(*ListResponse) error

+ SendMsg func(interface{}) error

v1.13.2

Oct 22, 2019

v1.13.1

Oct 19, 2019

v1.13.0

Oct 18, 2019

v1.12.0

Oct 16, 2019

Changes in this version

+ func RegisterStoreHandler(s server.Server, hdlr StoreHandler, opts ...server.HandlerOption) error

+ func RegisterStoreServer(s *grpc.Server, srv StoreServer)

+ type DeleteRequest struct

+ Keys []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRequest) ProtoMessage()

+ func (m *DeleteRequest) GetKeys() []string

+ 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 ReadRequest struct

+ Keys []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadRequest) Descriptor() ([]byte, []int)

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) GetKeys() []string

+ 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 StoreClient interface

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)

+ Sync func(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Store_SyncClient, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)

+ func NewStoreClient(cc *grpc.ClientConn) StoreClient

+ type StoreHandler interface

+ Delete func(context.Context, *DeleteRequest, *DeleteResponse) error

+ Read func(context.Context, *ReadRequest, *ReadResponse) error

+ Sync func(context.Context, *SyncRequest, Store_SyncStream) error

+ Write func(context.Context, *WriteRequest, *WriteResponse) error

+ type StoreServer interface

+ Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error)

+ Read func(context.Context, *ReadRequest) (*ReadResponse, error)

+ Sync func(*SyncRequest, Store_SyncServer) error

+ Write func(context.Context, *WriteRequest) (*WriteResponse, error)

+ type StoreService interface

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)

+ Sync func(ctx context.Context, in *SyncRequest, opts ...client.CallOption) (Store_SyncService, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error)

+ func NewStoreService(name string, c client.Client) StoreService

+ type Store_SyncClient interface

+ Recv func() (*SyncResponse, error)

+ type Store_SyncServer interface

+ Send func(*SyncResponse) error

+ type Store_SyncService interface

+ Close func() error

+ Recv func() (*SyncResponse, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type Store_SyncStream interface

+ Close func() error

+ RecvMsg func(interface{}) error

+ Send func(*SyncResponse) error

+ SendMsg func(interface{}) error

+ type SyncRequest struct

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SyncRequest) Descriptor() ([]byte, []int)

+ func (*SyncRequest) ProtoMessage()

+ func (m *SyncRequest) GetKey() string

+ func (m *SyncRequest) Reset()

+ func (m *SyncRequest) String() string

+ func (m *SyncRequest) XXX_DiscardUnknown()

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

+ func (m *SyncRequest) XXX_Merge(src proto.Message)

+ func (m *SyncRequest) XXX_Size() int

+ func (m *SyncRequest) XXX_Unmarshal(b []byte) error

+ type SyncResponse struct

+ Records []*Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SyncResponse) Descriptor() ([]byte, []int)

+ func (*SyncResponse) ProtoMessage()

+ func (m *SyncResponse) GetRecords() []*Record

+ func (m *SyncResponse) Reset()

+ func (m *SyncResponse) String() string

+ func (m *SyncResponse) XXX_DiscardUnknown()

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

+ func (m *SyncResponse) XXX_Merge(src proto.Message)

+ func (m *SyncResponse) XXX_Size() int

+ func (m *SyncResponse) XXX_Unmarshal(b []byte) error

+ type WriteRequest struct

+ Records []*Record

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteRequest) Descriptor() ([]byte, []int)

+ func (*WriteRequest) ProtoMessage()

+ func (m *WriteRequest) GetRecords() []*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

Other modules containing this package

github.com/micro/go-micro/v2

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