Versions in this module Expand all Collapse all v1 v1.0.0 Jul 21, 2022 Changes in this version + var Conn_ServiceDesc = grpc.ServiceDesc + var File_net_conn_conn_proto protoreflect.FileDescriptor + func RegisterConnServer(s grpc.ServiceRegistrar, srv ConnServer) + type ConnClient interface + Close func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) + Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) + SetDeadline func(ctx context.Context, in *SetDeadlineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + SetReadDeadline func(ctx context.Context, in *SetDeadlineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + SetWriteDeadline func(ctx context.Context, in *SetDeadlineRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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, *emptypb.Empty) (*emptypb.Empty, error) + Read func(context.Context, *ReadRequest) (*ReadResponse, error) + SetDeadline func(context.Context, *SetDeadlineRequest) (*emptypb.Empty, error) + SetReadDeadline func(context.Context, *SetDeadlineRequest) (*emptypb.Empty, error) + SetWriteDeadline func(context.Context, *SetDeadlineRequest) (*emptypb.Empty, error) + Write func(context.Context, *WriteRequest) (*WriteResponse, error) + type ReadRequest struct + Length int32 + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (x *ReadRequest) GetLength() int32 + func (x *ReadRequest) ProtoReflect() protoreflect.Message + func (x *ReadRequest) Reset() + func (x *ReadRequest) String() string + type ReadResponse struct + Error string + Errored bool + Read []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (x *ReadResponse) GetError() string + func (x *ReadResponse) GetErrored() bool + func (x *ReadResponse) GetRead() []byte + func (x *ReadResponse) ProtoReflect() protoreflect.Message + func (x *ReadResponse) Reset() + func (x *ReadResponse) String() string + type SetDeadlineRequest struct + Time []byte + func (*SetDeadlineRequest) Descriptor() ([]byte, []int) + func (*SetDeadlineRequest) ProtoMessage() + func (x *SetDeadlineRequest) GetTime() []byte + func (x *SetDeadlineRequest) ProtoReflect() protoreflect.Message + func (x *SetDeadlineRequest) Reset() + func (x *SetDeadlineRequest) String() string + type UnimplementedConnServer struct + func (UnimplementedConnServer) Close(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (UnimplementedConnServer) Read(context.Context, *ReadRequest) (*ReadResponse, error) + func (UnimplementedConnServer) SetDeadline(context.Context, *SetDeadlineRequest) (*emptypb.Empty, error) + func (UnimplementedConnServer) SetReadDeadline(context.Context, *SetDeadlineRequest) (*emptypb.Empty, error) + func (UnimplementedConnServer) SetWriteDeadline(context.Context, *SetDeadlineRequest) (*emptypb.Empty, error) + func (UnimplementedConnServer) Write(context.Context, *WriteRequest) (*WriteResponse, error) + type UnsafeConnServer interface + type WriteRequest struct + Payload []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (x *WriteRequest) GetPayload() []byte + func (x *WriteRequest) ProtoReflect() protoreflect.Message + func (x *WriteRequest) Reset() + func (x *WriteRequest) String() string + type WriteResponse struct + Error string + Errored bool + Length int32 + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (x *WriteResponse) GetError() string + func (x *WriteResponse) GetErrored() bool + func (x *WriteResponse) GetLength() int32 + func (x *WriteResponse) ProtoReflect() protoreflect.Message + func (x *WriteResponse) Reset() + func (x *WriteResponse) String() string v1.0.0-alpha Nov 22, 2022