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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL