Versions in this module Expand all Collapse all v0 v0.1.0 Dec 24, 2020 Changes in this version + func RegisterReaderServer(s *grpc.Server, srv ReaderServer) + type CloseRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseRequest) Descriptor() ([]byte, []int) + func (*CloseRequest) ProtoMessage() + func (m *CloseRequest) Reset() + func (m *CloseRequest) String() string + func (m *CloseRequest) XXX_DiscardUnknown() + func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseRequest) XXX_Merge(src proto.Message) + func (m *CloseRequest) XXX_Size() int + func (m *CloseRequest) XXX_Unmarshal(b []byte) error + type CloseResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseResponse) Descriptor() ([]byte, []int) + func (*CloseResponse) ProtoMessage() + func (m *CloseResponse) Reset() + func (m *CloseResponse) String() string + func (m *CloseResponse) XXX_DiscardUnknown() + func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseResponse) XXX_Merge(src proto.Message) + func (m *CloseResponse) XXX_Size() int + func (m *CloseResponse) XXX_Unmarshal(b []byte) error + type ReadRequest struct + Length int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetLength() int32 + 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 + Error string + Errored bool + Read []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetError() string + func (m *ReadResponse) GetErrored() bool + func (m *ReadResponse) GetRead() []byte + 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 ReaderClient interface + Close func(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error) + Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) + func NewReaderClient(cc grpc.ClientConnInterface) ReaderClient + type ReaderServer interface + Close func(context.Context, *CloseRequest) (*CloseResponse, error) + Read func(context.Context, *ReadRequest) (*ReadResponse, error) + type UnimplementedReaderServer struct + func (*UnimplementedReaderServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error) + func (*UnimplementedReaderServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)