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) Hijack

func (*UnimplementedWriterServer) Write

func (*UnimplementedWriterServer) WriteHeader

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

WriterServer is the server API for Writer service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL