reader

type Error ¶ added in v1.13.3

type Error struct {
	ErrorCode ErrorCode `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=io.reader.ErrorCode" json:"error_code,omitempty"`
	Message   string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *Error) GetErrorCode() ErrorCode

func (x *Error) GetMessage() string

func (*Error) ProtoMessage()

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

func (x *Error) Reset()

func (x *Error) String() string

type ErrorCode ¶ added in v1.13.3

type ErrorCode int32

ErrorCode provides information for special sentinel error types

const (
	ErrorCode_ERROR_CODE_UNSPECIFIED ErrorCode = 0
	ErrorCode_ERROR_CODE_EOF         ErrorCode = 1
)

func (ErrorCode) Descriptor() protoreflect.EnumDescriptor

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) EnumDescriptor() ([]byte, []int)

func (x ErrorCode) Number() protoreflect.EnumNumber

func (x ErrorCode) String() string

func (ErrorCode) Type() protoreflect.EnumType

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() ([]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 ¶

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 *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ReadResponse) GetError() *Error

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 ¶

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.

Reader is an io.Reader see: https://pkg.go.dev/io#Reader

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.

Reader is an io.Reader see: https://pkg.go.dev/io#Reader

type UnimplementedReaderServer ¶

type UnimplementedReaderServer struct{}

UnimplementedReaderServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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.