gresponsewriterproto

package
v1.4.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 25, 2021 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterWriterServer 

func RegisterWriterServer(s *grpc.Server, srv WriterServer)

Types

type FlushRequest 

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

func (*FlushRequest) Descriptor 

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

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) Reset 

func (m *FlushRequest) Reset()

func (*FlushRequest) String 

func (m *FlushRequest) String() string

func (*FlushRequest) XXX_DiscardUnknown 

func (m *FlushRequest) XXX_DiscardUnknown()

func (*FlushRequest) XXX_Marshal 

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

func (*FlushRequest) XXX_Merge 

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

func (*FlushRequest) XXX_Size 

func (m *FlushRequest) XXX_Size() int

func (*FlushRequest) XXX_Unmarshal 

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

type FlushResponse 

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

func (*FlushResponse) Descriptor 

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

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) Reset 

func (m *FlushResponse) Reset()

func (*FlushResponse) String 

func (m *FlushResponse) String() string

func (*FlushResponse) XXX_DiscardUnknown 

func (m *FlushResponse) XXX_DiscardUnknown()

func (*FlushResponse) XXX_Marshal 

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

func (*FlushResponse) XXX_Merge 

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

func (*FlushResponse) XXX_Size 

func (m *FlushResponse) XXX_Size() int

func (*FlushResponse) XXX_Unmarshal 

func (m *FlushResponse) XXX_Unmarshal(b []byte) error
type Header struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values               []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Header) Descriptor 

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

func (*Header) GetKey 

func (m *Header) GetKey() string

func (*Header) GetValues 

func (m *Header) GetValues() []string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) String 

func (m *Header) String() string

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

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

func (*Header) XXX_Merge 

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

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

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

type HijackRequest 

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

func (*HijackRequest) Descriptor 

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

func (*HijackRequest) ProtoMessage 

func (*HijackRequest) ProtoMessage()

func (*HijackRequest) Reset 

func (m *HijackRequest) Reset()

func (*HijackRequest) String 

func (m *HijackRequest) String() string

func (*HijackRequest) XXX_DiscardUnknown 

func (m *HijackRequest) XXX_DiscardUnknown()

func (*HijackRequest) XXX_Marshal 

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

func (*HijackRequest) XXX_Merge 

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

func (*HijackRequest) XXX_Size 

func (m *HijackRequest) XXX_Size() int

func (*HijackRequest) XXX_Unmarshal 

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

type HijackResponse 

type HijackResponse struct {
	ConnServer           uint32   `protobuf:"varint,1,opt,name=connServer,proto3" json:"connServer,omitempty"`
	LocalNetwork         string   `protobuf:"bytes,2,opt,name=localNetwork,proto3" json:"localNetwork,omitempty"`
	LocalString          string   `protobuf:"bytes,3,opt,name=localString,proto3" json:"localString,omitempty"`
	RemoteNetwork        string   `protobuf:"bytes,4,opt,name=remoteNetwork,proto3" json:"remoteNetwork,omitempty"`
	RemoteString         string   `protobuf:"bytes,5,opt,name=remoteString,proto3" json:"remoteString,omitempty"`
	ReaderServer         uint32   `protobuf:"varint,6,opt,name=readerServer,proto3" json:"readerServer,omitempty"`
	WriterServer         uint32   `protobuf:"varint,7,opt,name=writerServer,proto3" json:"writerServer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HijackResponse) Descriptor 

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

func (*HijackResponse) GetConnServer 

func (m *HijackResponse) GetConnServer() uint32

func (*HijackResponse) GetLocalNetwork 

func (m *HijackResponse) GetLocalNetwork() string

func (*HijackResponse) GetLocalString 

func (m *HijackResponse) GetLocalString() string

func (*HijackResponse) GetReaderServer 

func (m *HijackResponse) GetReaderServer() uint32

func (*HijackResponse) GetRemoteNetwork 

func (m *HijackResponse) GetRemoteNetwork() string

func (*HijackResponse) GetRemoteString 

func (m *HijackResponse) GetRemoteString() string

func (*HijackResponse) GetWriterServer 

func (m *HijackResponse) GetWriterServer() uint32

func (*HijackResponse) ProtoMessage 

func (*HijackResponse) ProtoMessage()

func (*HijackResponse) Reset 

func (m *HijackResponse) Reset()

func (*HijackResponse) String 

func (m *HijackResponse) String() string

func (*HijackResponse) XXX_DiscardUnknown 

func (m *HijackResponse) XXX_DiscardUnknown()

func (*HijackResponse) XXX_Marshal 

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

func (*HijackResponse) XXX_Merge 

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

func (*HijackResponse) XXX_Size 

func (m *HijackResponse) XXX_Size() int

func (*HijackResponse) XXX_Unmarshal 

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

type UnimplementedWriterServer 

type UnimplementedWriterServer struct {
}

UnimplementedWriterServer can be embedded to have forward compatible implementations.

func (*UnimplementedWriterServer) Flush 

func (*UnimplementedWriterServer) Flush(ctx context.Context, req *FlushRequest) (*FlushResponse, error)

func (*UnimplementedWriterServer) Hijack 

func (*UnimplementedWriterServer) Hijack(ctx context.Context, req *HijackRequest) (*HijackResponse, error)

func (*UnimplementedWriterServer) Write 

func (*UnimplementedWriterServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

func (*UnimplementedWriterServer) WriteHeader 

func (*UnimplementedWriterServer) WriteHeader(ctx context.Context, req *WriteHeaderRequest) (*WriteHeaderResponse, error)

type WriteHeaderRequest 

type WriteHeaderRequest struct {
	Headers              []*Header `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	StatusCode           int32     `protobuf:"varint,2,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WriteHeaderRequest) Descriptor 

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

func (*WriteHeaderRequest) GetHeaders 

func (m *WriteHeaderRequest) GetHeaders() []*Header

func (*WriteHeaderRequest) GetStatusCode 

func (m *WriteHeaderRequest) GetStatusCode() int32

func (*WriteHeaderRequest) ProtoMessage 

func (*WriteHeaderRequest) ProtoMessage()

func (*WriteHeaderRequest) Reset 

func (m *WriteHeaderRequest) Reset()

func (*WriteHeaderRequest) String 

func (m *WriteHeaderRequest) String() string

func (*WriteHeaderRequest) XXX_DiscardUnknown 

func (m *WriteHeaderRequest) XXX_DiscardUnknown()

func (*WriteHeaderRequest) XXX_Marshal 

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

func (*WriteHeaderRequest) XXX_Merge 

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

func (*WriteHeaderRequest) XXX_Size 

func (m *WriteHeaderRequest) XXX_Size() int

func (*WriteHeaderRequest) XXX_Unmarshal 

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

type WriteHeaderResponse 

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

func (*WriteHeaderResponse) Descriptor 

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

func (*WriteHeaderResponse) ProtoMessage 

func (*WriteHeaderResponse) ProtoMessage()

func (*WriteHeaderResponse) Reset 

func (m *WriteHeaderResponse) Reset()

func (*WriteHeaderResponse) String 

func (m *WriteHeaderResponse) String() string

func (*WriteHeaderResponse) XXX_DiscardUnknown 

func (m *WriteHeaderResponse) XXX_DiscardUnknown()

func (*WriteHeaderResponse) XXX_Marshal 

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

func (*WriteHeaderResponse) XXX_Merge 

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

func (*WriteHeaderResponse) XXX_Size 

func (m *WriteHeaderResponse) XXX_Size() int

func (*WriteHeaderResponse) XXX_Unmarshal 

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

type WriteRequest 

type WriteRequest struct {
	Headers              []*Header `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	Payload              []byte    `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetHeaders 

func (m *WriteRequest) GetHeaders() []*Header

func (*WriteRequest) GetPayload 

func (m *WriteRequest) GetPayload() []byte

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteResponse 

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

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetWritten 

func (m *WriteResponse) GetWritten() int32

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

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

type WriterClient 

type WriterClient interface {
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	WriteHeader(ctx context.Context, in *WriteHeaderRequest, opts ...grpc.CallOption) (*WriteHeaderResponse, error)
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	Hijack(ctx context.Context, in *HijackRequest, opts ...grpc.CallOption) (*HijackResponse, error)
}

WriterClient is the client API for Writer service.

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

func NewWriterClient 

func NewWriterClient(cc grpc.ClientConnInterface) WriterClient

type WriterServer 

type WriterServer interface {
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	WriteHeader(context.Context, *WriteHeaderRequest) (*WriteHeaderResponse, error)
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	Hijack(context.Context, *HijackRequest) (*HijackResponse, error)
}

WriterServer is the server API for Writer service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.