session

package
v0.11.1 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthH2C        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowH2C          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupH2C = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterTunnelListenerServer 

func RegisterTunnelListenerServer(s *grpc.Server, srv TunnelListenerServer)

Types

type ListenRequest 

type ListenRequest struct {
	Addr     string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"`
	ConnId   string `protobuf:"bytes,3,opt,name=connId,proto3" json:"connId,omitempty"`
	Data     []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Close    bool   `protobuf:"varint,5,opt,name=close,proto3" json:"close,omitempty"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) Equal 

func (this *ListenRequest) Equal(that interface{}) bool

func (*ListenRequest) GetAddr 

func (m *ListenRequest) GetAddr() string

func (*ListenRequest) GetClose 

func (m *ListenRequest) GetClose() bool

func (*ListenRequest) GetConnId 

func (m *ListenRequest) GetConnId() string

func (*ListenRequest) GetData 

func (m *ListenRequest) GetData() []byte

func (*ListenRequest) GetProtocol 

func (m *ListenRequest) GetProtocol() string

func (*ListenRequest) GoString 

func (this *ListenRequest) GoString() string

func (*ListenRequest) Marshal 

func (m *ListenRequest) Marshal() (dAtA []byte, err error)

func (*ListenRequest) MarshalTo 

func (m *ListenRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListenRequest) MarshalToSizedBuffer 

func (m *ListenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) Size 

func (m *ListenRequest) Size() (n int)

func (*ListenRequest) String 

func (this *ListenRequest) String() string

func (*ListenRequest) Unmarshal 

func (m *ListenRequest) Unmarshal(dAtA []byte) error

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

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

func (*ListenRequest) XXX_Merge 

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

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

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

type ListenResponse 

type ListenResponse struct {
	Addr   string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	ConnId string `protobuf:"bytes,2,opt,name=connId,proto3" json:"connId,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Close  bool   `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"`
}

func (*ListenResponse) Descriptor 

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

func (*ListenResponse) Equal 

func (this *ListenResponse) Equal(that interface{}) bool

func (*ListenResponse) GetAddr 

func (m *ListenResponse) GetAddr() string

func (*ListenResponse) GetClose 

func (m *ListenResponse) GetClose() bool

func (*ListenResponse) GetConnId 

func (m *ListenResponse) GetConnId() string

func (*ListenResponse) GetData 

func (m *ListenResponse) GetData() []byte

func (*ListenResponse) GoString 

func (this *ListenResponse) GoString() string

func (*ListenResponse) Marshal 

func (m *ListenResponse) Marshal() (dAtA []byte, err error)

func (*ListenResponse) MarshalTo 

func (m *ListenResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListenResponse) MarshalToSizedBuffer 

func (m *ListenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset 

func (m *ListenResponse) Reset()

func (*ListenResponse) Size 

func (m *ListenResponse) Size() (n int)

func (*ListenResponse) String 

func (this *ListenResponse) String() string

func (*ListenResponse) Unmarshal 

func (m *ListenResponse) Unmarshal(dAtA []byte) error

func (*ListenResponse) XXX_DiscardUnknown 

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal 

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

func (*ListenResponse) XXX_Merge 

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

func (*ListenResponse) XXX_Size 

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal 

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

type TunnelListenerAttachable 

type TunnelListenerAttachable struct {
	UnimplementedTunnelListenerServer
	// contains filtered or unexported fields
}

func NewTunnelListenerAttachable 

func NewTunnelListenerAttachable(rootCtx context.Context) TunnelListenerAttachable

func (TunnelListenerAttachable) Listen 

func (s TunnelListenerAttachable) Listen(srv TunnelListener_ListenServer) error

func (TunnelListenerAttachable) Register 

func (s TunnelListenerAttachable) Register(srv *grpc.Server)

type TunnelListenerClient 

type TunnelListenerClient interface {
	Listen(ctx context.Context, opts ...grpc.CallOption) (TunnelListener_ListenClient, error)
}

TunnelListenerClient is the client API for TunnelListener service.

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

func NewTunnelListenerClient 

func NewTunnelListenerClient(cc *grpc.ClientConn) TunnelListenerClient

type TunnelListenerServer 

type TunnelListenerServer interface {
	Listen(TunnelListener_ListenServer) error
}

TunnelListenerServer is the server API for TunnelListener service.

type TunnelListener_ListenClient 

type TunnelListener_ListenClient interface {
	Send(*ListenRequest) error
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type TunnelListener_ListenServer 

type TunnelListener_ListenServer interface {
	Send(*ListenResponse) error
	Recv() (*ListenRequest, error)
	grpc.ServerStream
}

type UnimplementedTunnelListenerServer 

type UnimplementedTunnelListenerServer struct {
}

UnimplementedTunnelListenerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTunnelListenerServer) Listen 

func (*UnimplementedTunnelListenerServer) Listen(srv TunnelListener_ListenServer) 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.