Documentation
¶
Index ¶
- type Message
- func (m *Message) Create(ctx context.Context, req *proto.CreateRequest, rsp *proto.CreateResponse) error
- func (m *Message) Delete(ctx context.Context, req *proto.DeleteRequest, rsp *proto.DeleteResponse) error
- func (m *Message) Read(ctx context.Context, req *proto.ReadRequest, rsp *proto.ReadResponse) error
- func (m *Message) Search(ctx context.Context, req *proto.SearchRequest, rsp *proto.SearchResponse) error
- func (m *Message) Stream(ctx context.Context, req *proto.StreamRequest, ...) error
- func (m *Message) Update(ctx context.Context, req *proto.UpdateRequest, rsp *proto.UpdateResponse) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct{}
func (*Message) Create ¶
func (m *Message) Create(ctx context.Context, req *proto.CreateRequest, rsp *proto.CreateResponse) error
func (*Message) Delete ¶
func (m *Message) Delete(ctx context.Context, req *proto.DeleteRequest, rsp *proto.DeleteResponse) error
func (*Message) Read ¶
func (m *Message) Read(ctx context.Context, req *proto.ReadRequest, rsp *proto.ReadResponse) error
func (*Message) Search ¶
func (m *Message) Search(ctx context.Context, req *proto.SearchRequest, rsp *proto.SearchResponse) error
func (*Message) Stream ¶
func (m *Message) Stream(ctx context.Context, req *proto.StreamRequest, stream proto.Message_StreamStream) error
func (*Message) Update ¶
func (m *Message) Update(ctx context.Context, req *proto.UpdateRequest, rsp *proto.UpdateResponse) error
Click to show internal directories.
Click to hide internal directories.