proto

package module
v0.0.0-...-789def6 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2022 License: Apache-2.0 Imports: 4 Imported by: 1

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 (
	Error_name = map[int32]string{
		0: "EOF",
	}
	Error_value = map[string]int32{
		"EOF": 0,
	}
)

Enum value maps for Error.

View Source 
var File_konectivity_proto protoreflect.FileDescriptor

Functions

This section is empty.

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 deprecated 

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

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 

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 

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 

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 

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

func (*DialResponse) Reset 

func (x *DialResponse) Reset()

func (*DialResponse) String 

func (x *DialResponse) String() string

type Error 

type Error int32
const (
	Error_EOF Error = 0 // ...
)

func (Error) Descriptor 

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum 

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated 

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

Deprecated: Use Error.Descriptor instead.

func (Error) Number 

func (x Error) Number() protoreflect.EnumNumber

func (Error) String 

func (x Error) String() string

func (Error) Type 

func (Error) Type() protoreflect.EnumType

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 

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 

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 

func (PacketType) Descriptor() protoreflect.EnumDescriptor

func (PacketType) Enum 

func (x PacketType) Enum() *PacketType

func (PacketType) EnumDescriptor deprecated 

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"`
}

Source Files

View all Source files

Directories

Path Synopsis
envoy
service/discovery/v3
go module
google
api
cloud/security/privateca/v1
longrunning
security/meshca/v1
type
grpc
binlog/v1
channelz/v1
core
gcp
health/v1
lookup/v1
reflection/v1
service_config
testing
istio
v1/auth
networking
v1beta1
type
v1beta1

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.