Documentation
¶
Index ¶
- Variables
- func RegisterPacketIOServer(s *grpc.Server, srv PacketIOServer)
- type GenetlinkPort
- func (*GenetlinkPort) Descriptor() ([]byte, []int)deprecated
- func (x *GenetlinkPort) GetFamily() string
- func (x *GenetlinkPort) GetGroup() string
- func (*GenetlinkPort) ProtoMessage()
- func (x *GenetlinkPort) ProtoReflect() protoreflect.Message
- func (x *GenetlinkPort) Reset()
- func (x *GenetlinkPort) String() string
- type HostPortControlInit
- type HostPortControlMessage
- func (*HostPortControlMessage) Descriptor() ([]byte, []int)deprecated
- func (x *HostPortControlMessage) GetCreate() booldeprecated
- func (x *HostPortControlMessage) GetDataplanePort() uint64
- func (x *HostPortControlMessage) GetGenetlink() *GenetlinkPort
- func (x *HostPortControlMessage) GetNetdev() *NetdevPort
- func (x *HostPortControlMessage) GetOp() PortOperation
- func (x *HostPortControlMessage) GetPort() isHostPortControlMessage_Port
- func (x *HostPortControlMessage) GetPortId() uint64
- func (*HostPortControlMessage) ProtoMessage()
- func (x *HostPortControlMessage) ProtoReflect() protoreflect.Message
- func (x *HostPortControlMessage) Reset()
- func (x *HostPortControlMessage) String() string
- type HostPortControlMessage_Genetlink
- type HostPortControlMessage_Netdev
- type HostPortControlRequest
- func (*HostPortControlRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HostPortControlRequest) GetInit() *HostPortControlInit
- func (x *HostPortControlRequest) GetMsg() isHostPortControlRequest_Msg
- func (x *HostPortControlRequest) GetStatus() *status.Status
- func (*HostPortControlRequest) ProtoMessage()
- func (x *HostPortControlRequest) ProtoReflect() protoreflect.Message
- func (x *HostPortControlRequest) Reset()
- func (x *HostPortControlRequest) String() string
- type HostPortControlRequest_Init
- type HostPortControlRequest_Status
- type NetdevPort
- type Packet
- func (*Packet) Descriptor() ([]byte, []int)deprecated
- func (x *Packet) GetFrame() []byte
- func (x *Packet) GetHostPort() uint64
- func (x *Packet) GetInputPort() uint64
- func (x *Packet) GetOutputPort() uint64
- func (*Packet) ProtoMessage()
- func (x *Packet) ProtoReflect() protoreflect.Message
- func (x *Packet) Reset()
- func (x *Packet) String() string
- type PacketIOClient
- type PacketIOServer
- type PacketIO_CPUPacketStreamClient
- type PacketIO_CPUPacketStreamServer
- type PacketIO_HostPortControlClient
- type PacketIO_HostPortControlServer
- type PacketIn
- func (*PacketIn) Descriptor() ([]byte, []int)deprecated
- func (x *PacketIn) GetInit() *PacketStreamInit
- func (x *PacketIn) GetMsg() isPacketIn_Msg
- func (x *PacketIn) GetPacket() *Packet
- func (*PacketIn) ProtoMessage()
- func (x *PacketIn) ProtoReflect() protoreflect.Message
- func (x *PacketIn) Reset()
- func (x *PacketIn) String() string
- type PacketIn_Init
- type PacketIn_Packet
- type PacketOut
- type PacketStreamInit
- type PortOperation
- func (PortOperation) Descriptor() protoreflect.EnumDescriptor
- func (x PortOperation) Enum() *PortOperation
- func (PortOperation) EnumDescriptor() ([]byte, []int)deprecated
- func (x PortOperation) Number() protoreflect.EnumNumber
- func (x PortOperation) String() string
- func (PortOperation) Type() protoreflect.EnumType
- type PortType
- type UnimplementedPacketIOServer
Constants ¶
This section is empty.
Variables ¶
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.
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.
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 (*HostPortControlMessage) GetGenetlink ¶
func (x *HostPortControlMessage) GetGenetlink() *GenetlinkPort
func (*HostPortControlMessage) GetNetdev ¶
func (x *HostPortControlMessage) GetNetdev() *NetdevPort
func (*HostPortControlMessage) GetOp ¶ added in v0.6.0
func (x *HostPortControlMessage) GetOp() PortOperation
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 ¶
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 (x *HostPortControlRequest) GetInit() *HostPortControlInit
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 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) GetHostPort ¶
func (*Packet) GetInputPort ¶
func (*Packet) GetOutputPort ¶
func (*Packet) ProtoMessage ¶
func (*Packet) ProtoMessage()
func (*Packet) ProtoReflect ¶
func (x *Packet) ProtoReflect() protoreflect.Message
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_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) GetInit ¶
func (x *PacketIn) GetInit() *PacketStreamInit
func (*PacketIn) ProtoMessage ¶
func (*PacketIn) ProtoMessage()
func (*PacketIn) ProtoReflect ¶
func (x *PacketIn) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*PacketOut) ProtoMessage()
func (*PacketOut) ProtoReflect ¶
func (x *PacketOut) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
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 (x PortOperation) Number() protoreflect.EnumNumber
func (PortOperation) String ¶ added in v0.6.0
func (x PortOperation) String() string
func (PortOperation) Type ¶ added in v0.6.0
func (PortOperation) Type() protoreflect.EnumType
type PortType ¶ added in v0.5.1
type PortType int32
func (PortType) Descriptor ¶ added in v0.5.1
func (PortType) Descriptor() protoreflect.EnumDescriptor
func (PortType) EnumDescriptor
deprecated
added in
v0.5.1
func (PortType) Number ¶ added in v0.5.1
func (x PortType) Number() protoreflect.EnumNumber
func (PortType) Type ¶ added in v0.5.1
func (PortType) Type() protoreflect.EnumType
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