greadcloserproto

Documentation

Index

• func RegisterReaderServer(s *grpc.Server, srv ReaderServer)
• type CloseRequest
  • 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
  • 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
  • func (*ReadRequest) Descriptor() ([]byte, []int)
  • func (m *ReadRequest) GetLength() int32
  • func (*ReadRequest) ProtoMessage()
  • 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
  • func (*ReadResponse) Descriptor() ([]byte, []int)
  • func (m *ReadResponse) GetError() string
  • func (m *ReadResponse) GetErrored() bool
  • func (m *ReadResponse) GetRead() []byte
  • func (*ReadResponse) ProtoMessage()
  • 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
  • func NewReaderClient(cc grpc.ClientConnInterface) ReaderClient
• type ReaderServer
• type UnimplementedReaderServer
  • func (*UnimplementedReaderServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)
  • func (*UnimplementedReaderServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)

Functions

func RegisterReaderServer

func RegisterReaderServer(s *grpc.Server, srv ReaderServer)

Types

type CloseRequest

type CloseRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseRequest) Descriptor

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

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset

func (m *CloseRequest) Reset()

func (*CloseRequest) String

func (m *CloseRequest) String() string

func (*CloseRequest) XXX_DiscardUnknown

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal

func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseRequest) XXX_Merge

func (m *CloseRequest) XXX_Merge(src proto.Message)

func (*CloseRequest) XXX_Size

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal

func (m *CloseRequest) XXX_Unmarshal(b []byte) error

type CloseResponse

type CloseResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseResponse) Descriptor

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

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset

func (m *CloseResponse) Reset()

func (*CloseResponse) String

func (m *CloseResponse) String() string

func (*CloseResponse) XXX_DiscardUnknown

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal

func (m *CloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseResponse) XXX_Merge

func (m *CloseResponse) XXX_Merge(src proto.Message)

func (*CloseResponse) XXX_Size

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal

func (m *CloseResponse) XXX_Unmarshal(b []byte) error

type ReadRequest

type ReadRequest struct {
	Length               int32    `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadRequest) Descriptor

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

func (*ReadRequest) GetLength

func (m *ReadRequest) GetLength() int32

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset

func (m *ReadRequest) Reset()

func (*ReadRequest) String

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal

func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRequest) XXX_Merge

func (m *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal

func (m *ReadRequest) XXX_Unmarshal(b []byte) error

type ReadResponse

type ReadResponse struct {
	Read                 []byte   `protobuf:"bytes,1,opt,name=read,proto3" json:"read,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Errored              bool     `protobuf:"varint,3,opt,name=errored,proto3" json:"errored,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadResponse) Descriptor

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

func (*ReadResponse) GetError

func (m *ReadResponse) GetError() string

func (*ReadResponse) GetErrored

func (m *ReadResponse) GetErrored() bool

func (*ReadResponse) GetRead

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

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset

func (m *ReadResponse) Reset()

func (*ReadResponse) String

func (m *ReadResponse) String() string

func (*ReadResponse) XXX_DiscardUnknown

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal

func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadResponse) XXX_Merge

func (m *ReadResponse) XXX_Merge(src proto.Message)

func (*ReadResponse) XXX_Size

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal

func (m *ReadResponse) XXX_Unmarshal(b []byte) error

type ReaderClient

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

ReaderClient is the client API for Reader service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewReaderClient

func NewReaderClient(cc grpc.ClientConnInterface) ReaderClient

type ReaderServer

type ReaderServer interface {
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
}

ReaderServer is the server API for Reader service.

type UnimplementedReaderServer

type UnimplementedReaderServer struct {
}

UnimplementedReaderServer can be embedded to have forward compatible implementations.

func (*UnimplementedReaderServer) Close

func (*UnimplementedReaderServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedReaderServer) Read

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