package client

import "sigs.k8s.io/apiserver-network-proxy/konnectivity-client/proto/client"

Index

Variables 

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

Enum value maps for PacketType. 

var File_konnectivity_client_proto_client_client_proto protoreflect.FileDescriptor
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 

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 

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

Deprecated: Use CloseDial.ProtoReflect.Descriptor instead.

func (*CloseDial) GetRandom 

func (x *CloseDial) GetRandom() int64

func (*CloseDial) ProtoMessage 

func (*CloseDial) ProtoMessage()

func (*CloseDial) ProtoReflect 

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

func (*CloseDial) Reset 

func (x *CloseDial) Reset()

func (*CloseDial) String 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

func (*DialResponse) Reset 

func (x *DialResponse) Reset()

func (*DialResponse) String 

func (x *DialResponse) String() string

type Drain 

type Drain struct {
	// contains filtered or unexported fields
}

func (*Drain) Descriptor 

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

Deprecated: Use Drain.ProtoReflect.Descriptor instead.

func (*Drain) ProtoMessage 

func (*Drain) ProtoMessage()

func (*Drain) ProtoReflect 

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

func (*Drain) Reset 

func (x *Drain) Reset()

func (*Drain) String 

func (x *Drain) 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
	//	*Packet_Drain
	Payload isPacket_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Packet) Descriptor 

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetCloseDial 

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

func (x *Packet) GetDrain() *Drain

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 

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
	PacketType_DRAIN     PacketType = 6
)

func (PacketType) Descriptor 

func (PacketType) Descriptor() protoreflect.EnumDescriptor

func (PacketType) Enum 

func (x PacketType) Enum() *PacketType

func (PacketType) EnumDescriptor 

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

Deprecated: Use PacketType.Descriptor instead.

func (PacketType) Number 

func (x PacketType) Number() protoreflect.EnumNumber

func (PacketType) String 

func (x PacketType) String() string

func (PacketType) Type 

func (PacketType) Type() protoreflect.EnumType

type Packet_CloseDial 

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 Packet_Drain 

type Packet_Drain struct {
	Drain *Drain `protobuf:"bytes,8,opt,name=drain,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 

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

client.pb.go client_grpc.pb.go

Version
v0.32.0 (latest)
Published
Mar 11, 2025
Platform
linux/amd64
Imports
8 packages
Last checked
13 hours ago –

Tools for package owners.