Versions in this module Expand all Collapse all v0 v0.1.0 Dec 24, 2020 Changes in this version + func RegisterWriterServer(s *grpc.Server, srv WriterServer) + type UnimplementedWriterServer struct + func (*UnimplementedWriterServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error) + type WriteRequest struct + Payload []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetPayload() []byte + 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 + Error string + Errored bool + Written int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) GetError() string + func (m *WriteResponse) GetErrored() bool + func (m *WriteResponse) GetWritten() int32 + 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 + type WriterClient interface + Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) + func NewWriterClient(cc grpc.ClientConnInterface) WriterClient + type WriterServer interface + Write func(context.Context, *WriteRequest) (*WriteResponse, error)
Go to main page