gconnproto

package
v0.99.99-test-ignore Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterConnServer

func RegisterConnServer(s *grpc.Server, srv ConnServer)

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 ConnClient

type ConnClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	SetDeadline(ctx context.Context, in *SetDeadlineRequest, opts ...grpc.CallOption) (*SetDeadlineResponse, error)
	SetReadDeadline(ctx context.Context, in *SetReadDeadlineRequest, opts ...grpc.CallOption) (*SetReadDeadlineResponse, error)
	SetWriteDeadline(ctx context.Context, in *SetWriteDeadlineRequest, opts ...grpc.CallOption) (*SetWriteDeadlineResponse, error)
}

ConnClient is the client API for Conn service.

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

func NewConnClient

func NewConnClient(cc grpc.ClientConnInterface) ConnClient

type ConnServer

ConnServer is the server API for Conn service.

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 SetDeadlineRequest

type SetDeadlineRequest struct {
	Time                 []byte   `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDeadlineRequest) Descriptor

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

func (*SetDeadlineRequest) GetTime

func (m *SetDeadlineRequest) GetTime() []byte

func (*SetDeadlineRequest) ProtoMessage

func (*SetDeadlineRequest) ProtoMessage()

func (*SetDeadlineRequest) Reset

func (m *SetDeadlineRequest) Reset()

func (*SetDeadlineRequest) String

func (m *SetDeadlineRequest) String() string

func (*SetDeadlineRequest) XXX_DiscardUnknown

func (m *SetDeadlineRequest) XXX_DiscardUnknown()

func (*SetDeadlineRequest) XXX_Marshal

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

func (*SetDeadlineRequest) XXX_Merge

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

func (*SetDeadlineRequest) XXX_Size

func (m *SetDeadlineRequest) XXX_Size() int

func (*SetDeadlineRequest) XXX_Unmarshal

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

type SetDeadlineResponse

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

func (*SetDeadlineResponse) Descriptor

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

func (*SetDeadlineResponse) ProtoMessage

func (*SetDeadlineResponse) ProtoMessage()

func (*SetDeadlineResponse) Reset

func (m *SetDeadlineResponse) Reset()

func (*SetDeadlineResponse) String

func (m *SetDeadlineResponse) String() string

func (*SetDeadlineResponse) XXX_DiscardUnknown

func (m *SetDeadlineResponse) XXX_DiscardUnknown()

func (*SetDeadlineResponse) XXX_Marshal

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

func (*SetDeadlineResponse) XXX_Merge

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

func (*SetDeadlineResponse) XXX_Size

func (m *SetDeadlineResponse) XXX_Size() int

func (*SetDeadlineResponse) XXX_Unmarshal

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

type SetReadDeadlineRequest

type SetReadDeadlineRequest struct {
	Time                 []byte   `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetReadDeadlineRequest) Descriptor

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

func (*SetReadDeadlineRequest) GetTime

func (m *SetReadDeadlineRequest) GetTime() []byte

func (*SetReadDeadlineRequest) ProtoMessage

func (*SetReadDeadlineRequest) ProtoMessage()

func (*SetReadDeadlineRequest) Reset

func (m *SetReadDeadlineRequest) Reset()

func (*SetReadDeadlineRequest) String

func (m *SetReadDeadlineRequest) String() string

func (*SetReadDeadlineRequest) XXX_DiscardUnknown

func (m *SetReadDeadlineRequest) XXX_DiscardUnknown()

func (*SetReadDeadlineRequest) XXX_Marshal

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

func (*SetReadDeadlineRequest) XXX_Merge

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

func (*SetReadDeadlineRequest) XXX_Size

func (m *SetReadDeadlineRequest) XXX_Size() int

func (*SetReadDeadlineRequest) XXX_Unmarshal

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

type SetReadDeadlineResponse

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

func (*SetReadDeadlineResponse) Descriptor

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

func (*SetReadDeadlineResponse) ProtoMessage

func (*SetReadDeadlineResponse) ProtoMessage()

func (*SetReadDeadlineResponse) Reset

func (m *SetReadDeadlineResponse) Reset()

func (*SetReadDeadlineResponse) String

func (m *SetReadDeadlineResponse) String() string

func (*SetReadDeadlineResponse) XXX_DiscardUnknown

func (m *SetReadDeadlineResponse) XXX_DiscardUnknown()

func (*SetReadDeadlineResponse) XXX_Marshal

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

func (*SetReadDeadlineResponse) XXX_Merge

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

func (*SetReadDeadlineResponse) XXX_Size

func (m *SetReadDeadlineResponse) XXX_Size() int

func (*SetReadDeadlineResponse) XXX_Unmarshal

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

type SetWriteDeadlineRequest

type SetWriteDeadlineRequest struct {
	Time                 []byte   `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetWriteDeadlineRequest) Descriptor

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

func (*SetWriteDeadlineRequest) GetTime

func (m *SetWriteDeadlineRequest) GetTime() []byte

func (*SetWriteDeadlineRequest) ProtoMessage

func (*SetWriteDeadlineRequest) ProtoMessage()

func (*SetWriteDeadlineRequest) Reset

func (m *SetWriteDeadlineRequest) Reset()

func (*SetWriteDeadlineRequest) String

func (m *SetWriteDeadlineRequest) String() string

func (*SetWriteDeadlineRequest) XXX_DiscardUnknown

func (m *SetWriteDeadlineRequest) XXX_DiscardUnknown()

func (*SetWriteDeadlineRequest) XXX_Marshal

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

func (*SetWriteDeadlineRequest) XXX_Merge

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

func (*SetWriteDeadlineRequest) XXX_Size

func (m *SetWriteDeadlineRequest) XXX_Size() int

func (*SetWriteDeadlineRequest) XXX_Unmarshal

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

type SetWriteDeadlineResponse

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

func (*SetWriteDeadlineResponse) Descriptor

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

func (*SetWriteDeadlineResponse) ProtoMessage

func (*SetWriteDeadlineResponse) ProtoMessage()

func (*SetWriteDeadlineResponse) Reset

func (m *SetWriteDeadlineResponse) Reset()

func (*SetWriteDeadlineResponse) String

func (m *SetWriteDeadlineResponse) String() string

func (*SetWriteDeadlineResponse) XXX_DiscardUnknown

func (m *SetWriteDeadlineResponse) XXX_DiscardUnknown()

func (*SetWriteDeadlineResponse) XXX_Marshal

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

func (*SetWriteDeadlineResponse) XXX_Merge

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

func (*SetWriteDeadlineResponse) XXX_Size

func (m *SetWriteDeadlineResponse) XXX_Size() int

func (*SetWriteDeadlineResponse) XXX_Unmarshal

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

type UnimplementedConnServer

type UnimplementedConnServer struct {
}

UnimplementedConnServer can be embedded to have forward compatible implementations.

func (*UnimplementedConnServer) Close

func (*UnimplementedConnServer) Read

func (*UnimplementedConnServer) SetDeadline

func (*UnimplementedConnServer) SetReadDeadline

func (*UnimplementedConnServer) SetWriteDeadline

func (*UnimplementedConnServer) Write

type WriteRequest

type WriteRequest struct {
	Payload              []byte   `protobuf:"bytes,1,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) 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 {
	Length               int32    `protobuf:"varint,1,opt,name=length,proto3" json:"length,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 (*WriteResponse) Descriptor

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

func (*WriteResponse) GetError

func (m *WriteResponse) GetError() string

func (*WriteResponse) GetErrored

func (m *WriteResponse) GetErrored() bool

func (*WriteResponse) GetLength

func (m *WriteResponse) GetLength() 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

Jump to

Keyboard shortcuts

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