client

package
v0.30.3 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PacketType_name = map[int32]string{
		0: "DIAL_REQ",
		1: "DIAL_RSP",
		2: "CLOSE_REQ",
		3: "CLOSE_RSP",
		4: "DATA",
		5: "DIAL_CLS",
	}
	PacketType_value = map[string]int32{
		"DIAL_REQ":  0,
		"DIAL_RSP":  1,
		"CLOSE_REQ": 2,
		"CLOSE_RSP": 3,
		"DATA":      4,
		"DIAL_CLS":  5,
	}
)

Enum value maps for PacketType.

View Source 
var File_konnectivity_client_proto_client_client_proto protoreflect.FileDescriptor
View Source 
var ProxyService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ProxyService",
	HandlerType: (*ProxyServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Proxy",
			Handler:       _ProxyService_Proxy_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "konnectivity-client/proto/client/client.proto",
}

ProxyService_ServiceDesc is the grpc.ServiceDesc for ProxyService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterProxyServiceServer 

func RegisterProxyServiceServer(s grpc.ServiceRegistrar, srv ProxyServiceServer)

Types

type CloseDial added in v0.0.23 

type CloseDial struct {

	// random id of the DialRequest
	Random int64 `protobuf:"varint,1,opt,name=random,proto3" json:"random,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseDial) Descriptor deprecated added in v0.0.23 

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

Deprecated: Use CloseDial.ProtoReflect.Descriptor instead.

func (*CloseDial) GetRandom added in v0.0.23 

func (x *CloseDial) GetRandom() int64

func (*CloseDial) ProtoMessage added in v0.0.23 

func (*CloseDial) ProtoMessage()

func (*CloseDial) ProtoReflect added in v0.1.0 

func (x *CloseDial) ProtoReflect() protoreflect.Message

func (*CloseDial) Reset added in v0.0.23 

func (x *CloseDial) Reset()

func (*CloseDial) String added in v0.0.23 

func (x *CloseDial) String() string

type CloseRequest 

type CloseRequest struct {

	// connectID of the stream to close
	ConnectID int64 `protobuf:"varint,1,opt,name=connectID,proto3" json:"connectID,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetConnectID 

func (x *CloseRequest) GetConnectID() int64

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect added in v0.1.0 

func (x *CloseRequest) ProtoReflect() protoreflect.Message

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CloseResponse 

type CloseResponse struct {

	// error message
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// connectID indicates the identifier of the connection
	ConnectID int64 `protobuf:"varint,2,opt,name=connectID,proto3" json:"connectID,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponse) Descriptor deprecated 

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) GetConnectID 

func (x *CloseResponse) GetConnectID() int64

func (*CloseResponse) GetError 

func (x *CloseResponse) GetError() string

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect added in v0.1.0 

func (x *CloseResponse) ProtoReflect() protoreflect.Message

func (*CloseResponse) Reset 

func (x *CloseResponse) Reset()

func (*CloseResponse) String 

func (x *CloseResponse) String() string

type Data 

type Data struct {

	// connectID to connect to
	ConnectID int64 `protobuf:"varint,1,opt,name=connectID,proto3" json:"connectID,omitempty"`
	// error message if error happens
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// stream data
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetConnectID 

func (x *Data) GetConnectID() int64

func (*Data) GetData 

func (x *Data) GetData() []byte

func (*Data) GetError 

func (x *Data) GetError() string

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect added in v0.1.0 

func (x *Data) ProtoReflect() protoreflect.Message

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type DialRequest 

type DialRequest struct {

	// tcp or udp?
	Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// node:port
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// random id for client, maybe should be longer
	Random int64 `protobuf:"varint,3,opt,name=random,proto3" json:"random,omitempty"`
	// contains filtered or unexported fields
}

func (*DialRequest) Descriptor deprecated 

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

Deprecated: Use DialRequest.ProtoReflect.Descriptor instead.

func (*DialRequest) GetAddress 

func (x *DialRequest) GetAddress() string

func (*DialRequest) GetProtocol 

func (x *DialRequest) GetProtocol() string

func (*DialRequest) GetRandom 

func (x *DialRequest) GetRandom() int64

func (*DialRequest) ProtoMessage 

func (*DialRequest) ProtoMessage()

func (*DialRequest) ProtoReflect added in v0.1.0 

func (x *DialRequest) ProtoReflect() protoreflect.Message

func (*DialRequest) Reset 

func (x *DialRequest) Reset()

func (*DialRequest) String 

func (x *DialRequest) String() string

type DialResponse 

type DialResponse struct {

	// error failed reason; enum?
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// connectID indicates the identifier of the connection
	ConnectID int64 `protobuf:"varint,2,opt,name=connectID,proto3" json:"connectID,omitempty"`
	// random copied from DialRequest
	Random int64 `protobuf:"varint,3,opt,name=random,proto3" json:"random,omitempty"`
	// contains filtered or unexported fields
}

func (*DialResponse) Descriptor deprecated 

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

Deprecated: Use DialResponse.ProtoReflect.Descriptor instead.

func (*DialResponse) GetConnectID 

func (x *DialResponse) GetConnectID() int64

func (*DialResponse) GetError 

func (x *DialResponse) GetError() string

func (*DialResponse) GetRandom 

func (x *DialResponse) GetRandom() int64

func (*DialResponse) ProtoMessage 

func (*DialResponse) ProtoMessage()

func (*DialResponse) ProtoReflect added in v0.1.0 

func (x *DialResponse) ProtoReflect() protoreflect.Message

func (*DialResponse) Reset 

func (x *DialResponse) Reset()

func (*DialResponse) String 

func (x *DialResponse) String() string

type Packet 

type Packet struct {
	Type PacketType `protobuf:"varint,1,opt,name=type,proto3,enum=PacketType" json:"type,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*Packet_DialRequest
	//	*Packet_DialResponse
	//	*Packet_Data
	//	*Packet_CloseRequest
	//	*Packet_CloseResponse
	//	*Packet_CloseDial
	Payload isPacket_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Packet) Descriptor deprecated 

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetCloseDial added in v0.0.23 

func (x *Packet) GetCloseDial() *CloseDial

func (*Packet) GetCloseRequest 

func (x *Packet) GetCloseRequest() *CloseRequest

func (*Packet) GetCloseResponse 

func (x *Packet) GetCloseResponse() *CloseResponse

func (*Packet) GetData 

func (x *Packet) GetData() *Data

func (*Packet) GetDialRequest 

func (x *Packet) GetDialRequest() *DialRequest

func (*Packet) GetDialResponse 

func (x *Packet) GetDialResponse() *DialResponse

func (*Packet) GetPayload 

func (m *Packet) GetPayload() isPacket_Payload

func (*Packet) GetType 

func (x *Packet) GetType() PacketType

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect added in v0.1.0 

func (x *Packet) ProtoReflect() protoreflect.Message

func (*Packet) Reset 

func (x *Packet) Reset()

func (*Packet) String 

func (x *Packet) String() string

type PacketType 

type PacketType int32
const (
	PacketType_DIAL_REQ  PacketType = 0
	PacketType_DIAL_RSP  PacketType = 1
	PacketType_CLOSE_REQ PacketType = 2
	PacketType_CLOSE_RSP PacketType = 3
	PacketType_DATA      PacketType = 4
	PacketType_DIAL_CLS  PacketType = 5
)

func (PacketType) Descriptor added in v0.1.0 

func (PacketType) Descriptor() protoreflect.EnumDescriptor

func (PacketType) Enum added in v0.1.0 

func (x PacketType) Enum() *PacketType

func (PacketType) EnumDescriptor deprecated 

func (PacketType) EnumDescriptor() ([]byte, []int)

Deprecated: Use PacketType.Descriptor instead.

func (PacketType) Number added in v0.1.0 

func (x PacketType) Number() protoreflect.EnumNumber

func (PacketType) String 

func (x PacketType) String() string

func (PacketType) Type added in v0.1.0 

func (PacketType) Type() protoreflect.EnumType

type Packet_CloseDial added in v0.0.23 

type Packet_CloseDial struct {
	CloseDial *CloseDial `protobuf:"bytes,7,opt,name=closeDial,proto3,oneof"`
}

type Packet_CloseRequest 

type Packet_CloseRequest struct {
	CloseRequest *CloseRequest `protobuf:"bytes,5,opt,name=closeRequest,proto3,oneof"`
}

type Packet_CloseResponse 

type Packet_CloseResponse struct {
	CloseResponse *CloseResponse `protobuf:"bytes,6,opt,name=closeResponse,proto3,oneof"`
}

type Packet_Data 

type Packet_Data struct {
	Data *Data `protobuf:"bytes,4,opt,name=data,proto3,oneof"`
}

type Packet_DialRequest 

type Packet_DialRequest struct {
	DialRequest *DialRequest `protobuf:"bytes,2,opt,name=dialRequest,proto3,oneof"`
}

type Packet_DialResponse 

type Packet_DialResponse struct {
	DialResponse *DialResponse `protobuf:"bytes,3,opt,name=dialResponse,proto3,oneof"`
}

type ProxyServiceClient 

type ProxyServiceClient interface {
	Proxy(ctx context.Context, opts ...grpc.CallOption) (ProxyService_ProxyClient, error)
}

ProxyServiceClient is the client API for ProxyService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProxyServiceClient 

func NewProxyServiceClient(cc grpc.ClientConnInterface) ProxyServiceClient

type ProxyServiceServer 

type ProxyServiceServer interface {
	Proxy(ProxyService_ProxyServer) error
}

ProxyServiceServer is the server API for ProxyService service. All implementations should embed UnimplementedProxyServiceServer for forward compatibility

type ProxyService_ProxyClient 

type ProxyService_ProxyClient interface {
	Send(*Packet) error
	Recv() (*Packet, error)
	grpc.ClientStream
}

type ProxyService_ProxyServer 

type ProxyService_ProxyServer interface {
	Send(*Packet) error
	Recv() (*Packet, error)
	grpc.ServerStream
}

type UnimplementedProxyServiceServer 

type UnimplementedProxyServiceServer struct {
}

UnimplementedProxyServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedProxyServiceServer) Proxy 

func (UnimplementedProxyServiceServer) Proxy(ProxyService_ProxyServer) error

type UnsafeProxyServiceServer added in v0.1.0 

type UnsafeProxyServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeProxyServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProxyServiceServer will result in compilation errors.

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.