gconnproto

package
v1.4.5 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 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 

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

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) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedConnServer) Read 

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

func (*UnimplementedConnServer) SetDeadline 

func (*UnimplementedConnServer) SetDeadline(ctx context.Context, req *SetDeadlineRequest) (*SetDeadlineResponse, error)

func (*UnimplementedConnServer) SetReadDeadline 

func (*UnimplementedConnServer) SetReadDeadline(ctx context.Context, req *SetReadDeadlineRequest) (*SetReadDeadlineResponse, error)

func (*UnimplementedConnServer) SetWriteDeadline 

func (*UnimplementedConnServer) SetWriteDeadline(ctx context.Context, req *SetWriteDeadlineRequest) (*SetWriteDeadlineResponse, error)

func (*UnimplementedConnServer) Write 

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

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

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.