Versions in this module Expand all Collapse all v0 v0.1.0 Apr 19, 2020 Changes in this version + func RegisterWriterServer(s *grpc.Server, srv WriterServer) + type FlushRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FlushRequest) Descriptor() ([]byte, []int) + func (*FlushRequest) ProtoMessage() + func (m *FlushRequest) Reset() + func (m *FlushRequest) String() string + func (m *FlushRequest) XXX_DiscardUnknown() + func (m *FlushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FlushRequest) XXX_Merge(src proto.Message) + func (m *FlushRequest) XXX_Size() int + func (m *FlushRequest) XXX_Unmarshal(b []byte) error + type FlushResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FlushResponse) Descriptor() ([]byte, []int) + func (*FlushResponse) ProtoMessage() + func (m *FlushResponse) Reset() + func (m *FlushResponse) String() string + func (m *FlushResponse) XXX_DiscardUnknown() + func (m *FlushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FlushResponse) XXX_Merge(src proto.Message) + func (m *FlushResponse) XXX_Size() int + func (m *FlushResponse) XXX_Unmarshal(b []byte) error + type Header struct + Key string + Values []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (m *Header) GetKey() string + func (m *Header) GetValues() []string + func (m *Header) Reset() + func (m *Header) String() string + func (m *Header) XXX_DiscardUnknown() + func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Header) XXX_Merge(src proto.Message) + func (m *Header) XXX_Size() int + func (m *Header) XXX_Unmarshal(b []byte) error + type HijackRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HijackRequest) Descriptor() ([]byte, []int) + func (*HijackRequest) ProtoMessage() + func (m *HijackRequest) Reset() + func (m *HijackRequest) String() string + func (m *HijackRequest) XXX_DiscardUnknown() + func (m *HijackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HijackRequest) XXX_Merge(src proto.Message) + func (m *HijackRequest) XXX_Size() int + func (m *HijackRequest) XXX_Unmarshal(b []byte) error + type HijackResponse struct + ConnServer uint32 + LocalNetwork string + LocalString string + ReaderServer uint32 + RemoteNetwork string + RemoteString string + WriterServer uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HijackResponse) Descriptor() ([]byte, []int) + func (*HijackResponse) ProtoMessage() + func (m *HijackResponse) GetConnServer() uint32 + func (m *HijackResponse) GetLocalNetwork() string + func (m *HijackResponse) GetLocalString() string + func (m *HijackResponse) GetReaderServer() uint32 + func (m *HijackResponse) GetRemoteNetwork() string + func (m *HijackResponse) GetRemoteString() string + func (m *HijackResponse) GetWriterServer() uint32 + func (m *HijackResponse) Reset() + func (m *HijackResponse) String() string + func (m *HijackResponse) XXX_DiscardUnknown() + func (m *HijackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HijackResponse) XXX_Merge(src proto.Message) + func (m *HijackResponse) XXX_Size() int + func (m *HijackResponse) XXX_Unmarshal(b []byte) error + type UnimplementedWriterServer struct + func (*UnimplementedWriterServer) Flush(ctx context.Context, req *FlushRequest) (*FlushResponse, error) + func (*UnimplementedWriterServer) Hijack(ctx context.Context, req *HijackRequest) (*HijackResponse, error) + func (*UnimplementedWriterServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error) + func (*UnimplementedWriterServer) WriteHeader(ctx context.Context, req *WriteHeaderRequest) (*WriteHeaderResponse, error) + type WriteHeaderRequest struct + Headers []*Header + StatusCode int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteHeaderRequest) Descriptor() ([]byte, []int) + func (*WriteHeaderRequest) ProtoMessage() + func (m *WriteHeaderRequest) GetHeaders() []*Header + func (m *WriteHeaderRequest) GetStatusCode() int32 + func (m *WriteHeaderRequest) Reset() + func (m *WriteHeaderRequest) String() string + func (m *WriteHeaderRequest) XXX_DiscardUnknown() + func (m *WriteHeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteHeaderRequest) XXX_Merge(src proto.Message) + func (m *WriteHeaderRequest) XXX_Size() int + func (m *WriteHeaderRequest) XXX_Unmarshal(b []byte) error + type WriteHeaderResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteHeaderResponse) Descriptor() ([]byte, []int) + func (*WriteHeaderResponse) ProtoMessage() + func (m *WriteHeaderResponse) Reset() + func (m *WriteHeaderResponse) String() string + func (m *WriteHeaderResponse) XXX_DiscardUnknown() + func (m *WriteHeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteHeaderResponse) XXX_Merge(src proto.Message) + func (m *WriteHeaderResponse) XXX_Size() int + func (m *WriteHeaderResponse) XXX_Unmarshal(b []byte) error + type WriteRequest struct + Headers []*Header + Payload []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetHeaders() []*Header + 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 + Written int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) GetWritten() 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 + type WriterClient interface + Flush func(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error) + Hijack func(ctx context.Context, in *HijackRequest, opts ...grpc.CallOption) (*HijackResponse, error) + Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error) + WriteHeader func(ctx context.Context, in *WriteHeaderRequest, opts ...grpc.CallOption) (*WriteHeaderResponse, error) + func NewWriterClient(cc grpc.ClientConnInterface) WriterClient + type WriterServer interface + Flush func(context.Context, *FlushRequest) (*FlushResponse, error) + Hijack func(context.Context, *HijackRequest) (*HijackResponse, error) + Write func(context.Context, *WriteRequest) (*WriteResponse, error) + WriteHeader func(context.Context, *WriteHeaderRequest) (*WriteHeaderResponse, error)
Go to main page