packetio

package
v0.7.0 Latest Latest
Warning

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

Go to latest
Published: Aug 6, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	PortOperation_name = map[int32]string{
		0: "PORT_OPERATION_UNSPECIFIED",
		1: "PORT_OPERATION_CREATE",
		2: "PORT_OPERATION_DELETE",
		3: "PORT_OPERATION_SET_UP",
		4: "PORT_OPERATION_SET_DOWN",
	}
	PortOperation_value = map[string]int32{
		"PORT_OPERATION_UNSPECIFIED": 0,
		"PORT_OPERATION_CREATE":      1,
		"PORT_OPERATION_DELETE":      2,
		"PORT_OPERATION_SET_UP":      3,
		"PORT_OPERATION_SET_DOWN":    4,
	}
)

Enum value maps for PortOperation.

View Source
var (
	PortType_name = map[int32]string{
		0: "PORT_TYPE_UNSPECIFIED",
		1: "PORT_TYPE_NETDEV",
		2: "PORT_TYPE_GENETLINK",
	}
	PortType_value = map[string]int32{
		"PORT_TYPE_UNSPECIFIED": 0,
		"PORT_TYPE_NETDEV":      1,
		"PORT_TYPE_GENETLINK":   2,
	}
)

Enum value maps for PortType.

View Source
var File_dataplane_proto_packetio_packetio_proto protoreflect.FileDescriptor

Functions

func RegisterPacketIOServer

func RegisterPacketIOServer(s *grpc.Server, srv PacketIOServer)

Types

type GenetlinkPort

type GenetlinkPort struct {
	Family string `protobuf:"bytes,1,opt,name=family,proto3" json:"family,omitempty"`
	Group  string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*GenetlinkPort) Descriptor deprecated

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

Deprecated: Use GenetlinkPort.ProtoReflect.Descriptor instead.

func (*GenetlinkPort) GetFamily

func (x *GenetlinkPort) GetFamily() string

func (*GenetlinkPort) GetGroup

func (x *GenetlinkPort) GetGroup() string

func (*GenetlinkPort) ProtoMessage

func (*GenetlinkPort) ProtoMessage()

func (*GenetlinkPort) ProtoReflect

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

func (*GenetlinkPort) Reset

func (x *GenetlinkPort) Reset()

func (*GenetlinkPort) String

func (x *GenetlinkPort) String() string

type HostPortControlInit

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

func (*HostPortControlInit) Descriptor deprecated

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

Deprecated: Use HostPortControlInit.ProtoReflect.Descriptor instead.

func (*HostPortControlInit) ProtoMessage

func (*HostPortControlInit) ProtoMessage()

func (*HostPortControlInit) ProtoReflect

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

func (*HostPortControlInit) Reset

func (x *HostPortControlInit) Reset()

func (*HostPortControlInit) String

func (x *HostPortControlInit) String() string

type HostPortControlMessage

type HostPortControlMessage struct {
	PortId        uint64 `protobuf:"varint,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	DataplanePort uint64 `protobuf:"varint,2,opt,name=dataplane_port,json=dataplanePort,proto3" json:"dataplane_port,omitempty"`
	// Deprecated: Marked as deprecated in dataplane/proto/packetio/packetio.proto.
	Create bool `protobuf:"varint,3,opt,name=create,proto3" json:"create,omitempty"`
	// Types that are valid to be assigned to Port:
	//
	//	*HostPortControlMessage_Netdev
	//	*HostPortControlMessage_Genetlink
	Port isHostPortControlMessage_Port `protobuf_oneof:"port"`
	Op   PortOperation                 `protobuf:"varint,6,opt,name=op,proto3,enum=lucius.dataplane.packetio.PortOperation" json:"op,omitempty"`
	// contains filtered or unexported fields
}

func (*HostPortControlMessage) Descriptor deprecated

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

Deprecated: Use HostPortControlMessage.ProtoReflect.Descriptor instead.

func (*HostPortControlMessage) GetCreate deprecated

func (x *HostPortControlMessage) GetCreate() bool

Deprecated: Marked as deprecated in dataplane/proto/packetio/packetio.proto.

func (*HostPortControlMessage) GetDataplanePort

func (x *HostPortControlMessage) GetDataplanePort() uint64
func (x *HostPortControlMessage) GetGenetlink() *GenetlinkPort

func (*HostPortControlMessage) GetNetdev

func (x *HostPortControlMessage) GetNetdev() *NetdevPort

func (*HostPortControlMessage) GetOp added in v0.6.0

func (*HostPortControlMessage) GetPort

func (x *HostPortControlMessage) GetPort() isHostPortControlMessage_Port

func (*HostPortControlMessage) GetPortId

func (x *HostPortControlMessage) GetPortId() uint64

func (*HostPortControlMessage) ProtoMessage

func (*HostPortControlMessage) ProtoMessage()

func (*HostPortControlMessage) ProtoReflect

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

func (*HostPortControlMessage) Reset

func (x *HostPortControlMessage) Reset()

func (*HostPortControlMessage) String

func (x *HostPortControlMessage) String() string
type HostPortControlMessage_Genetlink struct {
	Genetlink *GenetlinkPort `protobuf:"bytes,5,opt,name=genetlink,proto3,oneof"`
}

type HostPortControlMessage_Netdev

type HostPortControlMessage_Netdev struct {
	Netdev *NetdevPort `protobuf:"bytes,4,opt,name=netdev,proto3,oneof"`
}

type HostPortControlRequest

type HostPortControlRequest struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*HostPortControlRequest_Init
	//	*HostPortControlRequest_Status
	Msg isHostPortControlRequest_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*HostPortControlRequest) Descriptor deprecated

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

Deprecated: Use HostPortControlRequest.ProtoReflect.Descriptor instead.

func (*HostPortControlRequest) GetInit

func (*HostPortControlRequest) GetMsg

func (x *HostPortControlRequest) GetMsg() isHostPortControlRequest_Msg

func (*HostPortControlRequest) GetStatus

func (x *HostPortControlRequest) GetStatus() *status.Status

func (*HostPortControlRequest) ProtoMessage

func (*HostPortControlRequest) ProtoMessage()

func (*HostPortControlRequest) ProtoReflect

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

func (*HostPortControlRequest) Reset

func (x *HostPortControlRequest) Reset()

func (*HostPortControlRequest) String

func (x *HostPortControlRequest) String() string

type HostPortControlRequest_Init

type HostPortControlRequest_Init struct {
	Init *HostPortControlInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type HostPortControlRequest_Status

type HostPortControlRequest_Status struct {
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type NetdevPort

type NetdevPort struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*NetdevPort) Descriptor deprecated

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

Deprecated: Use NetdevPort.ProtoReflect.Descriptor instead.

func (*NetdevPort) GetName

func (x *NetdevPort) GetName() string

func (*NetdevPort) ProtoMessage

func (*NetdevPort) ProtoMessage()

func (*NetdevPort) ProtoReflect

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

func (*NetdevPort) Reset

func (x *NetdevPort) Reset()

func (*NetdevPort) String

func (x *NetdevPort) String() string

type Packet

type Packet struct {
	HostPort   uint64 `protobuf:"varint,1,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`
	InputPort  uint64 `protobuf:"varint,2,opt,name=input_port,json=inputPort,proto3" json:"input_port,omitempty"`
	OutputPort uint64 `protobuf:"varint,3,opt,name=output_port,json=outputPort,proto3" json:"output_port,omitempty"`
	Frame      []byte `protobuf:"bytes,4,opt,name=frame,proto3" json:"frame,omitempty"`
	// contains filtered or unexported fields
}

func (*Packet) Descriptor deprecated

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetFrame

func (x *Packet) GetFrame() []byte

func (*Packet) GetHostPort

func (x *Packet) GetHostPort() uint64

func (*Packet) GetInputPort

func (x *Packet) GetInputPort() uint64

func (*Packet) GetOutputPort

func (x *Packet) GetOutputPort() uint64

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 PacketIOClient

type PacketIOClient interface {
	HostPortControl(ctx context.Context, opts ...grpc.CallOption) (PacketIO_HostPortControlClient, error)
	CPUPacketStream(ctx context.Context, opts ...grpc.CallOption) (PacketIO_CPUPacketStreamClient, error)
}

PacketIOClient is the client API for PacketIO service.

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

func NewPacketIOClient

func NewPacketIOClient(cc grpc.ClientConnInterface) PacketIOClient

type PacketIOServer

type PacketIOServer interface {
	HostPortControl(PacketIO_HostPortControlServer) error
	CPUPacketStream(PacketIO_CPUPacketStreamServer) error
}

PacketIOServer is the server API for PacketIO service.

type PacketIO_CPUPacketStreamClient

type PacketIO_CPUPacketStreamClient interface {
	Send(*PacketIn) error
	Recv() (*PacketOut, error)
	grpc.ClientStream
}

type PacketIO_CPUPacketStreamServer

type PacketIO_CPUPacketStreamServer interface {
	Send(*PacketOut) error
	Recv() (*PacketIn, error)
	grpc.ServerStream
}

type PacketIO_HostPortControlClient

type PacketIO_HostPortControlClient interface {
	Send(*HostPortControlRequest) error
	Recv() (*HostPortControlMessage, error)
	grpc.ClientStream
}

type PacketIO_HostPortControlServer

type PacketIO_HostPortControlServer interface {
	Send(*HostPortControlMessage) error
	Recv() (*HostPortControlRequest, error)
	grpc.ServerStream
}

type PacketIn

type PacketIn struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*PacketIn_Init
	//	*PacketIn_Packet
	Msg isPacketIn_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*PacketIn) Descriptor deprecated

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

Deprecated: Use PacketIn.ProtoReflect.Descriptor instead.

func (*PacketIn) GetInit

func (x *PacketIn) GetInit() *PacketStreamInit

func (*PacketIn) GetMsg

func (x *PacketIn) GetMsg() isPacketIn_Msg

func (*PacketIn) GetPacket

func (x *PacketIn) GetPacket() *Packet

func (*PacketIn) ProtoMessage

func (*PacketIn) ProtoMessage()

func (*PacketIn) ProtoReflect

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

func (*PacketIn) Reset

func (x *PacketIn) Reset()

func (*PacketIn) String

func (x *PacketIn) String() string

type PacketIn_Init

type PacketIn_Init struct {
	Init *PacketStreamInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type PacketIn_Packet

type PacketIn_Packet struct {
	Packet *Packet `protobuf:"bytes,2,opt,name=packet,proto3,oneof"`
}

type PacketOut

type PacketOut struct {
	Packet *Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketOut) Descriptor deprecated

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

Deprecated: Use PacketOut.ProtoReflect.Descriptor instead.

func (*PacketOut) GetPacket

func (x *PacketOut) GetPacket() *Packet

func (*PacketOut) ProtoMessage

func (*PacketOut) ProtoMessage()

func (*PacketOut) ProtoReflect

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

func (*PacketOut) Reset

func (x *PacketOut) Reset()

func (*PacketOut) String

func (x *PacketOut) String() string

type PacketStreamInit

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

func (*PacketStreamInit) Descriptor deprecated

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

Deprecated: Use PacketStreamInit.ProtoReflect.Descriptor instead.

func (*PacketStreamInit) ProtoMessage

func (*PacketStreamInit) ProtoMessage()

func (*PacketStreamInit) ProtoReflect

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

func (*PacketStreamInit) Reset

func (x *PacketStreamInit) Reset()

func (*PacketStreamInit) String

func (x *PacketStreamInit) String() string

type PortOperation added in v0.6.0

type PortOperation int32
const (
	PortOperation_PORT_OPERATION_UNSPECIFIED PortOperation = 0
	PortOperation_PORT_OPERATION_CREATE      PortOperation = 1
	PortOperation_PORT_OPERATION_DELETE      PortOperation = 2
	PortOperation_PORT_OPERATION_SET_UP      PortOperation = 3
	PortOperation_PORT_OPERATION_SET_DOWN    PortOperation = 4
)

func (PortOperation) Descriptor added in v0.6.0

func (PortOperation) Enum added in v0.6.0

func (x PortOperation) Enum() *PortOperation

func (PortOperation) EnumDescriptor deprecated added in v0.6.0

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

Deprecated: Use PortOperation.Descriptor instead.

func (PortOperation) Number added in v0.6.0

func (PortOperation) String added in v0.6.0

func (x PortOperation) String() string

func (PortOperation) Type added in v0.6.0

type PortType added in v0.5.1

type PortType int32
const (
	PortType_PORT_TYPE_UNSPECIFIED PortType = 0
	PortType_PORT_TYPE_NETDEV      PortType = 1
	PortType_PORT_TYPE_GENETLINK   PortType = 2
)

func (PortType) Descriptor added in v0.5.1

func (PortType) Descriptor() protoreflect.EnumDescriptor

func (PortType) Enum added in v0.5.1

func (x PortType) Enum() *PortType

func (PortType) EnumDescriptor deprecated added in v0.5.1

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

Deprecated: Use PortType.Descriptor instead.

func (PortType) Number added in v0.5.1

func (x PortType) Number() protoreflect.EnumNumber

func (PortType) String added in v0.5.1

func (x PortType) String() string

func (PortType) Type added in v0.5.1

type UnimplementedPacketIOServer

type UnimplementedPacketIOServer struct {
}

UnimplementedPacketIOServer can be embedded to have forward compatible implementations.

func (*UnimplementedPacketIOServer) CPUPacketStream

func (*UnimplementedPacketIOServer) HostPortControl

Jump to

Keyboard shortcuts

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