packetio

package
v0.5.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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"`
	Create        bool   `protobuf:"varint,3,opt,name=create,proto3" json:"create,omitempty"`
	// Types that are assignable to Port:
	//
	//	*HostPortControlMessage_Netdev
	//	*HostPortControlMessage_Genetlink
	Port isHostPortControlMessage_Port `protobuf_oneof:"port"`
	// contains filtered or unexported fields
}

func (*HostPortControlMessage) Descriptor deprecated 

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

Deprecated: Use HostPortControlMessage.ProtoReflect.Descriptor instead.

func (*HostPortControlMessage) GetCreate 

func (x *HostPortControlMessage) GetCreate() bool

func (*HostPortControlMessage) GetDataplanePort 

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

func (*HostPortControlMessage) GetNetdev 

func (x *HostPortControlMessage) GetNetdev() *NetdevPort

func (*HostPortControlMessage) GetPort 

func (m *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 assignable 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 (x *HostPortControlRequest) GetInit() *HostPortControlInit

func (*HostPortControlRequest) GetMsg 

func (m *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 assignable 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 (m *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 UnimplementedPacketIOServer 

type UnimplementedPacketIOServer struct {
}

UnimplementedPacketIOServer can be embedded to have forward compatible implementations.

func (*UnimplementedPacketIOServer) CPUPacketStream 

func (*UnimplementedPacketIOServer) CPUPacketStream(PacketIO_CPUPacketStreamServer) error

func (*UnimplementedPacketIOServer) HostPortControl 

func (*UnimplementedPacketIOServer) HostPortControl(PacketIO_HostPortControlServer) error

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.