Versions in this module Expand all Collapse all v0 v0.1.0 Apr 19, 2020 Changes in this version + func RegisterConnServer(s *grpc.Server, srv ConnServer) + 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 ConnClient 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) + SetDeadline func(ctx context.Context, in *SetDeadlineRequest, opts ...grpc.CallOption) (*SetDeadlineResponse, error) + SetReadDeadline func(ctx context.Context, in *SetReadDeadlineRequest, opts ...grpc.CallOption) (*SetReadDeadlineResponse, error) + SetWriteDeadline func(ctx context.Context, in *SetWriteDeadlineRequest, opts ...grpc.CallOption) (*SetWriteDeadlineResponse, error) + Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) + func NewConnClient(cc grpc.ClientConnInterface) ConnClient + type ConnServer interface + Close func(context.Context, *CloseRequest) (*CloseResponse, error) + Read func(context.Context, *ReadRequest) (*ReadResponse, error) + SetDeadline func(context.Context, *SetDeadlineRequest) (*SetDeadlineResponse, error) + SetReadDeadline func(context.Context, *SetReadDeadlineRequest) (*SetReadDeadlineResponse, error) + SetWriteDeadline func(context.Context, *SetWriteDeadlineRequest) (*SetWriteDeadlineResponse, error) + Write func(context.Context, *WriteRequest) (*WriteResponse, 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 SetDeadlineRequest struct + Time []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetDeadlineRequest) Descriptor() ([]byte, []int) + func (*SetDeadlineRequest) ProtoMessage() + func (m *SetDeadlineRequest) GetTime() []byte + func (m *SetDeadlineRequest) Reset() + func (m *SetDeadlineRequest) String() string + func (m *SetDeadlineRequest) XXX_DiscardUnknown() + func (m *SetDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetDeadlineRequest) XXX_Merge(src proto.Message) + func (m *SetDeadlineRequest) XXX_Size() int + func (m *SetDeadlineRequest) XXX_Unmarshal(b []byte) error + type SetDeadlineResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetDeadlineResponse) Descriptor() ([]byte, []int) + func (*SetDeadlineResponse) ProtoMessage() + func (m *SetDeadlineResponse) Reset() + func (m *SetDeadlineResponse) String() string + func (m *SetDeadlineResponse) XXX_DiscardUnknown() + func (m *SetDeadlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetDeadlineResponse) XXX_Merge(src proto.Message) + func (m *SetDeadlineResponse) XXX_Size() int + func (m *SetDeadlineResponse) XXX_Unmarshal(b []byte) error + type SetReadDeadlineRequest struct + Time []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetReadDeadlineRequest) Descriptor() ([]byte, []int) + func (*SetReadDeadlineRequest) ProtoMessage() + func (m *SetReadDeadlineRequest) GetTime() []byte + func (m *SetReadDeadlineRequest) Reset() + func (m *SetReadDeadlineRequest) String() string + func (m *SetReadDeadlineRequest) XXX_DiscardUnknown() + func (m *SetReadDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetReadDeadlineRequest) XXX_Merge(src proto.Message) + func (m *SetReadDeadlineRequest) XXX_Size() int + func (m *SetReadDeadlineRequest) XXX_Unmarshal(b []byte) error + type SetReadDeadlineResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetReadDeadlineResponse) Descriptor() ([]byte, []int) + func (*SetReadDeadlineResponse) ProtoMessage() + func (m *SetReadDeadlineResponse) Reset() + func (m *SetReadDeadlineResponse) String() string + func (m *SetReadDeadlineResponse) XXX_DiscardUnknown() + func (m *SetReadDeadlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetReadDeadlineResponse) XXX_Merge(src proto.Message) + func (m *SetReadDeadlineResponse) XXX_Size() int + func (m *SetReadDeadlineResponse) XXX_Unmarshal(b []byte) error + type SetWriteDeadlineRequest struct + Time []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetWriteDeadlineRequest) Descriptor() ([]byte, []int) + func (*SetWriteDeadlineRequest) ProtoMessage() + func (m *SetWriteDeadlineRequest) GetTime() []byte + func (m *SetWriteDeadlineRequest) Reset() + func (m *SetWriteDeadlineRequest) String() string + func (m *SetWriteDeadlineRequest) XXX_DiscardUnknown() + func (m *SetWriteDeadlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetWriteDeadlineRequest) XXX_Merge(src proto.Message) + func (m *SetWriteDeadlineRequest) XXX_Size() int + func (m *SetWriteDeadlineRequest) XXX_Unmarshal(b []byte) error + type SetWriteDeadlineResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetWriteDeadlineResponse) Descriptor() ([]byte, []int) + func (*SetWriteDeadlineResponse) ProtoMessage() + func (m *SetWriteDeadlineResponse) Reset() + func (m *SetWriteDeadlineResponse) String() string + func (m *SetWriteDeadlineResponse) XXX_DiscardUnknown() + func (m *SetWriteDeadlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetWriteDeadlineResponse) XXX_Merge(src proto.Message) + func (m *SetWriteDeadlineResponse) XXX_Size() int + func (m *SetWriteDeadlineResponse) XXX_Unmarshal(b []byte) error + type UnimplementedConnServer struct + func (*UnimplementedConnServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error) + func (*UnimplementedConnServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error) + func (*UnimplementedConnServer) SetDeadline(ctx context.Context, req *SetDeadlineRequest) (*SetDeadlineResponse, error) + func (*UnimplementedConnServer) SetReadDeadline(ctx context.Context, req *SetReadDeadlineRequest) (*SetReadDeadlineResponse, error) + func (*UnimplementedConnServer) SetWriteDeadline(ctx context.Context, req *SetWriteDeadlineRequest) (*SetWriteDeadlineResponse, error) + func (*UnimplementedConnServer) 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 + Length 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) GetLength() 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
Go to main page