reader

Documentation

Index

• Variables
• func RegisterReaderServer(s grpc.ServiceRegistrar, srv ReaderServer)
• type ReadRequest
  • func (*ReadRequest) Descriptor() ([]byte, []int)
  • func (x *ReadRequest) GetLength() int32
  • func (*ReadRequest) ProtoMessage()
  • func (x *ReadRequest) ProtoReflect() protoreflect.Message
  • func (x *ReadRequest) Reset()
  • func (x *ReadRequest) String() string
• type ReadResponse
  • func (*ReadResponse) Descriptor() ([]byte, []int)
  • func (x *ReadResponse) GetError() string
  • func (x *ReadResponse) GetRead() []byte
  • func (*ReadResponse) ProtoMessage()
  • func (x *ReadResponse) ProtoReflect() protoreflect.Message
  • func (x *ReadResponse) Reset()
  • func (x *ReadResponse) String() string
• type ReaderClient
  • func NewReaderClient(cc grpc.ClientConnInterface) ReaderClient
• type ReaderServer
• type UnimplementedReaderServer
  • func (UnimplementedReaderServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
• type UnsafeReaderServer

Variables

var File_io_reader_reader_proto protoreflect.FileDescriptor

var Reader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.reader.Reader",
	HandlerType: (*ReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Read",
			Handler:    _Reader_Read_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "io/reader/reader.proto",
}

Reader_ServiceDesc is the grpc.ServiceDesc for Reader service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterReaderServer

func RegisterReaderServer(s grpc.ServiceRegistrar, srv ReaderServer)

Types

type ReadRequest

type ReadRequest struct {

	// length is the request in bytes
	Length int32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor

func (*ReadRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetLength

func (x *ReadRequest) GetLength() int32

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect

func (x *ReadRequest) ProtoReflect() protoreflect.Message

func (*ReadRequest) Reset

func (x *ReadRequest) Reset()

func (*ReadRequest) String

func (x *ReadRequest) String() string

type ReadResponse

type ReadResponse struct {

	// read is the payload in bytes
	Read []byte `protobuf:"bytes,1,opt,name=read,proto3" json:"read,omitempty"`
	// error is an error message
	Error *string `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor

func (*ReadResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetError

func (x *ReadResponse) GetError() string

func (*ReadResponse) GetRead

func (x *ReadResponse) GetRead() []byte

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect

func (x *ReadResponse) ProtoReflect() protoreflect.Message

func (*ReadResponse) Reset

func (x *ReadResponse) Reset()

func (*ReadResponse) String

func (x *ReadResponse) String() string

type ReaderClient

type ReaderClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
}

ReaderClient is the client API for Reader service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewReaderClient

func NewReaderClient(cc grpc.ClientConnInterface) ReaderClient

type ReaderServer

type ReaderServer interface {
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	// contains filtered or unexported methods
}

ReaderServer is the server API for Reader service. All implementations must embed UnimplementedReaderServer for forward compatibility

type UnimplementedReaderServer

type UnimplementedReaderServer struct {
}

UnimplementedReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedReaderServer) Read

func (UnimplementedReaderServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

type UnsafeReaderServer

type UnsafeReaderServer interface {
	// contains filtered or unexported methods
}

UnsafeReaderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReaderServer will result in compilation errors.