bess_pb

package
v0.0.0-...-aef4648 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_bess_msg_proto protoreflect.FileDescriptor
View Source 
var File_error_proto protoreflect.FileDescriptor
View Source 
var File_module_msg_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var File_util_msg_proto protoreflect.FileDescriptor

Functions

func RegisterBESSControlServer 

func RegisterBESSControlServer(s *grpc.Server, srv BESSControlServer)

Types

type ACLArg 

type ACLArg struct {
	Rules []*ACLArg_Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` ///A list of ACL rules.
	// contains filtered or unexported fields
}

* The module ACL creates an access control module which by default blocks all traffic, unless it contains a rule which specifies otherwise. Examples of ACL can be found in [acl.bess](https://github.com/NetSys/bess/blob/master/bessctl/conf/samples/acl.bess)

__Input Gates__: 1 __Output Gates__: 1

func (*ACLArg) Descriptor deprecated 

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

Deprecated: Use ACLArg.ProtoReflect.Descriptor instead.

func (*ACLArg) GetRules 

func (x *ACLArg) GetRules() []*ACLArg_Rule

func (*ACLArg) ProtoMessage 

func (*ACLArg) ProtoMessage()

func (*ACLArg) ProtoReflect 

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

func (*ACLArg) Reset 

func (x *ACLArg) Reset()

func (*ACLArg) String 

func (x *ACLArg) String() string

type ACLArg_Rule 

type ACLArg_Rule struct {
	SrcIp       string `protobuf:"bytes,1,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`        /// Source IP block in CIDR. Wildcard if "".
	DstIp       string `protobuf:"bytes,2,opt,name=dst_ip,json=dstIp,proto3" json:"dst_ip,omitempty"`        /// Destination IP block in CIDR. Wildcard if "".
	SrcPort     uint32 `protobuf:"varint,3,opt,name=src_port,json=srcPort,proto3" json:"src_port,omitempty"` /// TCP/UDP source port. Wildcard if 0.
	DstPort     uint32 `protobuf:"varint,4,opt,name=dst_port,json=dstPort,proto3" json:"dst_port,omitempty"` /// TCP/UDP Destination port. Wildcard if 0.
	Established bool   `protobuf:"varint,5,opt,name=established,proto3" json:"established,omitempty"`        /// Not implemented
	Drop        bool   `protobuf:"varint,6,opt,name=drop,proto3" json:"drop,omitempty"`                      /// Drop matched packets if true, forward if false. By default ACL drops all traffic.
	// contains filtered or unexported fields
}

* One ACL rule is represented by the following 6-tuple.

func (*ACLArg_Rule) Descriptor deprecated 

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

Deprecated: Use ACLArg_Rule.ProtoReflect.Descriptor instead.

func (*ACLArg_Rule) GetDrop 

func (x *ACLArg_Rule) GetDrop() bool

func (*ACLArg_Rule) GetDstIp 

func (x *ACLArg_Rule) GetDstIp() string

func (*ACLArg_Rule) GetDstPort 

func (x *ACLArg_Rule) GetDstPort() uint32

func (*ACLArg_Rule) GetEstablished 

func (x *ACLArg_Rule) GetEstablished() bool

func (*ACLArg_Rule) GetSrcIp 

func (x *ACLArg_Rule) GetSrcIp() string

func (*ACLArg_Rule) GetSrcPort 

func (x *ACLArg_Rule) GetSrcPort() uint32

func (*ACLArg_Rule) ProtoMessage 

func (*ACLArg_Rule) ProtoMessage()

func (*ACLArg_Rule) ProtoReflect 

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

func (*ACLArg_Rule) Reset 

func (x *ACLArg_Rule) Reset()

func (*ACLArg_Rule) String 

func (x *ACLArg_Rule) String() string

type AddTcRequest 

type AddTcRequest struct {
	Class *TrafficClass `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTcRequest) Descriptor deprecated 

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

Deprecated: Use AddTcRequest.ProtoReflect.Descriptor instead.

func (*AddTcRequest) GetClass 

func (x *AddTcRequest) GetClass() *TrafficClass

func (*AddTcRequest) ProtoMessage 

func (*AddTcRequest) ProtoMessage()

func (*AddTcRequest) ProtoReflect 

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

func (*AddTcRequest) Reset 

func (x *AddTcRequest) Reset()

func (*AddTcRequest) String 

func (x *AddTcRequest) String() string

type AddWorkerRequest 

type AddWorkerRequest struct {
	Wid       int64  `protobuf:"varint,1,opt,name=wid,proto3" json:"wid,omitempty"`            /// Worker ID to be added
	Core      int64  `protobuf:"varint,2,opt,name=core,proto3" json:"core,omitempty"`          /// CPU core ID on which the worker would run
	Scheduler string `protobuf:"bytes,3,opt,name=scheduler,proto3" json:"scheduler,omitempty"` /// Empty string denotes default scheduler.
	// contains filtered or unexported fields
}

func (*AddWorkerRequest) Descriptor deprecated 

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

Deprecated: Use AddWorkerRequest.ProtoReflect.Descriptor instead.

func (*AddWorkerRequest) GetCore 

func (x *AddWorkerRequest) GetCore() int64

func (*AddWorkerRequest) GetScheduler 

func (x *AddWorkerRequest) GetScheduler() string

func (*AddWorkerRequest) GetWid 

func (x *AddWorkerRequest) GetWid() int64

func (*AddWorkerRequest) ProtoMessage 

func (*AddWorkerRequest) ProtoMessage()

func (*AddWorkerRequest) ProtoReflect 

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

func (*AddWorkerRequest) Reset 

func (x *AddWorkerRequest) Reset()

func (*AddWorkerRequest) String 

func (x *AddWorkerRequest) String() string

type ArpResponderArg 

type ArpResponderArg struct {
	Ip      string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`                          /// The IP
	MacAddr string `protobuf:"bytes,2,opt,name=mac_addr,json=macAddr,proto3" json:"mac_addr,omitempty"` /// The MAC address
	// contains filtered or unexported fields
}

* The ARP Responder module is responding to ARP requests. It has a function `add(...)` which adds one IP-MAC mapping.

TODO: Dynamic learn new MAC's-IP's mapping

__Input Gates__: 1 __Output Gates__: 1

func (*ArpResponderArg) Descriptor deprecated 

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

Deprecated: Use ArpResponderArg.ProtoReflect.Descriptor instead.

func (*ArpResponderArg) GetIp 

func (x *ArpResponderArg) GetIp() string

func (*ArpResponderArg) GetMacAddr 

func (x *ArpResponderArg) GetMacAddr() string

func (*ArpResponderArg) ProtoMessage 

func (*ArpResponderArg) ProtoMessage()

func (*ArpResponderArg) ProtoReflect 

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

func (*ArpResponderArg) Reset 

func (x *ArpResponderArg) Reset()

func (*ArpResponderArg) String 

func (x *ArpResponderArg) String() string

type BESSControlClient 

type BESSControlClient interface {
	/// Query version of bessd
	GetVersion(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	/// Reset the current packet processing datapath to the initial state.
	///
	/// This command is identical to the following sequence:
	///   ResetModules()
	///   ResetPorts()
	///   ResetTcs()
	///   ResetWorkers()
	/// As it clears everything, BESS should appear as if the daemon has freshly
	/// started (if not, it is a bug; please report).
	///
	/// NOTE: There should be no running worker to run this command.
	ResetAll(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Terminate the BESS daemon.
	///
	/// BESS daemon shuts off in a graceful manner. Note that this command is
	/// "asynchronous": this command doesn't block until the BESS daemon has
	/// shut off.
	///
	/// NOTE: There should be no running worker to run this command.
	/// FIXME: rename (e.g., Terminate)
	KillBess(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Import a plugin
	///
	/// At the moment plugins can only contain module types,
	/// but might also support drivers/hooks/schedulers in the future.
	ImportPlugin(ctx context.Context, in *ImportPluginRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Unload a plugin
	///
	/// At the moment plugins can only contain module types,
	/// but might also support drivers/hooks/schedulers in the future.
	UnloadPlugin(ctx context.Context, in *UnloadPluginRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// List imported plugins
	///
	/// At the moment plugins can only contain module types,
	/// but might also support drivers/hooks/schedulers in the future.
	ListPlugins(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListPluginsResponse, error)
	/// Pause all running workers temporarily
	///
	/// Some RPC commands to BESS or individual modules/ports require that
	/// threads must be inactive, to avoid race conditions.
	/// For such commands, use PauseALl at the beginning and ResumeAll at the end.
	///  PauseAll()
	///   SomeCommand1()
	///   SomeCommand2()
	///   ...
	///  ResumeAll()
	/// Keep the duration as short as possible, to avoid packet drops.
	PauseAll(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Pause the specified worker temporarily
	///
	/// Some RPC commands to BESS or individual modules/ports require that
	/// threads must be inactive, to avoid race conditions.
	/// For such commands, use PauseWorker at the beginning and ResumeWorker at the end.
	///  PauseWorker(0)
	///   SomeCommand1()
	///   SomeCommand2()
	///   ...
	///  ResumeWorker(0)
	/// Keep the duration as short as possible, to avoid packet drops.
	PauseWorker(ctx context.Context, in *PauseWorkerRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Resume the specified worker
	ResumeWorker(ctx context.Context, in *ResumeWorkerRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Resume all paused workers
	ResumeAll(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Remove all existing workers
	///
	/// NOTE: There should be no running worker to run this command.
	ResetWorkers(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Enumerate all existing workers
	ListWorkers(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	/// Create a new worker
	///
	/// NOTE: There should be no running worker to run this command.
	AddWorker(ctx context.Context, in *AddWorkerRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Remove a single worker
	///
	/// NOTE: There should be no running worker to run this command.
	DestroyWorker(ctx context.Context, in *DestroyWorkerRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Remove all existing traffic classes
	///
	/// NOTE: There should be no running worker to run this command.
	ResetTcs(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Enumerate all existing workers
	ListTcs(ctx context.Context, in *ListTcsRequest, opts ...grpc.CallOption) (*ListTcsResponse, error)
	/// Check scheduling contraints
	CheckSchedulingConstraints(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*CheckSchedulingConstraintsResponse, error)
	/// Create a new traffic class
	///
	/// NOTE: There should be no running worker to run this command.
	AddTc(ctx context.Context, in *AddTcRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Update parameters of an existing traffic class
	///
	/// NOTE: There should be no running worker to run this command.
	UpdateTcParams(ctx context.Context, in *UpdateTcParamsRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Change parent (and child arguments) of an existing traffic class
	///
	/// NOTE: There should be no running worker to run this command.
	UpdateTcParent(ctx context.Context, in *UpdateTcParentRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Collect statistics of a traffic class
	GetTcStats(ctx context.Context, in *GetTcStatsRequest, opts ...grpc.CallOption) (*GetTcStatsResponse, error)
	/// Enumerate all port drivers available
	ListDrivers(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListDriversResponse, error)
	/// Query detailed information of a port driver
	GetDriverInfo(ctx context.Context, in *GetDriverInfoRequest, opts ...grpc.CallOption) (*GetDriverInfoResponse, error)
	/// Remove all initialized ports
	///
	/// Will fail if there are modules that are still using ports.
	/// (e.g., PortInc, PortOut, QueueInc, QueueOut)
	///
	/// NOTE: There should be no running worker to run this command.
	ResetPorts(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Enumerate all initialized ports
	ListPorts(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListPortsResponse, error)
	/// Create a new port from the specified driver
	CreatePort(ctx context.Context, in *CreatePortRequest, opts ...grpc.CallOption) (*CreatePortResponse, error)
	/// Remove a port
	///
	/// The port should not be being used by a port-related module.
	/// (e.g., PortInc, PortOut, QueueInc, QueueOut)
	DestroyPort(ctx context.Context, in *DestroyPortRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Runtime-updatable configuration
	SetPortConf(ctx context.Context, in *SetPortConfRequest, opts ...grpc.CallOption) (*CommandResponse, error)
	GetPortConf(ctx context.Context, in *GetPortConfRequest, opts ...grpc.CallOption) (*GetPortConfResponse, error)
	/// Collect port statistics
	///
	/// At the moment, per-queue stats are not supported.
	GetPortStats(ctx context.Context, in *GetPortStatsRequest, opts ...grpc.CallOption) (*GetPortStatsResponse, error)
	/// Query link status
	GetLinkStatus(ctx context.Context, in *GetLinkStatusRequest, opts ...grpc.CallOption) (*GetLinkStatusResponse, error)
	/// Enumerate all module types available
	ListMclass(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListMclassResponse, error)
	/// Query detailed information of a module type
	GetMclassInfo(ctx context.Context, in *GetMclassInfoRequest, opts ...grpc.CallOption) (*GetMclassInfoResponse, error)
	/// Remove all modules.
	///
	/// This RPC will always succeed (unless there is a running worker)
	///
	/// NOTE: There should be no running worker to run this command.
	ResetModules(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Enumerate all initialized modules
	ListModules(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListModulesResponse, error)
	/// Create a new module instance from the given module type
	///
	/// NOTE: There should be no running worker to run this command.
	CreateModule(ctx context.Context, in *CreateModuleRequest, opts ...grpc.CallOption) (*CreateModuleResponse, error)
	/// Destroy an exsting module
	///
	/// If the module is connected to other modules' input/output gate, they are
	/// disconnected first. All tasks created by the module will also be destoyed.
	///
	/// NOTE: There should be no running worker to run this command.
	DestroyModule(ctx context.Context, in *DestroyModuleRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Fetch detailed information of an module instance
	GetModuleInfo(ctx context.Context, in *GetModuleInfoRequest, opts ...grpc.CallOption) (*GetModuleInfoResponse, error)
	/// Connect two modules.
	///
	/// Connect between m1's ogate and n2's igate (i.e., ackets sent to m1's ogate
	/// will be fed to m2's igate). The oate can be connected to only one igate,
	/// while the igate can be connected to multiple output gates.
	///
	/// NOTE: There should be no running worker to run this command.
	ConnectModules(ctx context.Context, in *ConnectModulesRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Disconnect two modules.
	///
	/// It removes a connection between two modules (you specify the previous one
	/// and its output gate). All packets coming out from the ogate will be
	/// dropped. Once disconnected, the ogate can be connected
	/// to any input gate.
	///
	/// NOTE: There should be no running worker to run this command.
	DisconnectModules(ctx context.Context, in *DisconnectModulesRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	/// Dump various stats about BESS's packet pools
	DumpMempool(ctx context.Context, in *DumpMempoolRequest, opts ...grpc.CallOption) (*DumpMempoolResponse, error)
	/// Send a command to the specified module instance.
	///
	/// Each module type defines a list of modyle-specific commands, which
	/// allow external programs to communicate with the module at runtime.
	/// See module_msg.proto for details.
	///
	/// NOTE: Some commands cannot be used if there are running workers.
	///       For those commands you must pause all workers first.
	ModuleCommand(ctx context.Context, in *CommandRequest, opts ...grpc.CallOption) (*CommandResponse, error)
	/// Enumerate all gatehook types available
	ListGateHookClass(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListGateHookClassResponse, error)
	/// Query detailed information of a gatehook type
	GetGateHookClassInfo(ctx context.Context, in *GetGateHookClassInfoRequest, opts ...grpc.CallOption) (*GetGateHookClassInfoResponse, error)
	/// Enable/Disable a gate hook.
	ConfigureGateHook(ctx context.Context, in *ConfigureGateHookRequest, opts ...grpc.CallOption) (*ConfigureGateHookResponse, error)
	/// Enumerate all gatehook installed
	ListGateHooks(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*ListGateHooksResponse, error)
	/// Send command to gate hook instance.
	GateHookCommand(ctx context.Context, in *GateHookCommandRequest, opts ...grpc.CallOption) (*CommandResponse, error)
	/// Enable/Disable a resume hook.
	ConfigureResumeHook(ctx context.Context, in *ConfigureResumeHookRequest, opts ...grpc.CallOption) (*CommandResponse, error)
}

BESSControlClient is the client API for BESSControl service.

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

func NewBESSControlClient 

func NewBESSControlClient(cc grpc.ClientConnInterface) BESSControlClient

type BESSControlServer 

type BESSControlServer interface {
	/// Query version of bessd
	GetVersion(context.Context, *EmptyRequest) (*VersionResponse, error)
	/// Reset the current packet processing datapath to the initial state.
	///
	/// This command is identical to the following sequence:
	///   ResetModules()
	///   ResetPorts()
	///   ResetTcs()
	///   ResetWorkers()
	/// As it clears everything, BESS should appear as if the daemon has freshly
	/// started (if not, it is a bug; please report).
	///
	/// NOTE: There should be no running worker to run this command.
	ResetAll(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Terminate the BESS daemon.
	///
	/// BESS daemon shuts off in a graceful manner. Note that this command is
	/// "asynchronous": this command doesn't block until the BESS daemon has
	/// shut off.
	///
	/// NOTE: There should be no running worker to run this command.
	/// FIXME: rename (e.g., Terminate)
	KillBess(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Import a plugin
	///
	/// At the moment plugins can only contain module types,
	/// but might also support drivers/hooks/schedulers in the future.
	ImportPlugin(context.Context, *ImportPluginRequest) (*EmptyResponse, error)
	/// Unload a plugin
	///
	/// At the moment plugins can only contain module types,
	/// but might also support drivers/hooks/schedulers in the future.
	UnloadPlugin(context.Context, *UnloadPluginRequest) (*EmptyResponse, error)
	/// List imported plugins
	///
	/// At the moment plugins can only contain module types,
	/// but might also support drivers/hooks/schedulers in the future.
	ListPlugins(context.Context, *EmptyRequest) (*ListPluginsResponse, error)
	/// Pause all running workers temporarily
	///
	/// Some RPC commands to BESS or individual modules/ports require that
	/// threads must be inactive, to avoid race conditions.
	/// For such commands, use PauseALl at the beginning and ResumeAll at the end.
	///  PauseAll()
	///   SomeCommand1()
	///   SomeCommand2()
	///   ...
	///  ResumeAll()
	/// Keep the duration as short as possible, to avoid packet drops.
	PauseAll(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Pause the specified worker temporarily
	///
	/// Some RPC commands to BESS or individual modules/ports require that
	/// threads must be inactive, to avoid race conditions.
	/// For such commands, use PauseWorker at the beginning and ResumeWorker at the end.
	///  PauseWorker(0)
	///   SomeCommand1()
	///   SomeCommand2()
	///   ...
	///  ResumeWorker(0)
	/// Keep the duration as short as possible, to avoid packet drops.
	PauseWorker(context.Context, *PauseWorkerRequest) (*EmptyResponse, error)
	/// Resume the specified worker
	ResumeWorker(context.Context, *ResumeWorkerRequest) (*EmptyResponse, error)
	/// Resume all paused workers
	ResumeAll(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Remove all existing workers
	///
	/// NOTE: There should be no running worker to run this command.
	ResetWorkers(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Enumerate all existing workers
	ListWorkers(context.Context, *EmptyRequest) (*ListWorkersResponse, error)
	/// Create a new worker
	///
	/// NOTE: There should be no running worker to run this command.
	AddWorker(context.Context, *AddWorkerRequest) (*EmptyResponse, error)
	/// Remove a single worker
	///
	/// NOTE: There should be no running worker to run this command.
	DestroyWorker(context.Context, *DestroyWorkerRequest) (*EmptyResponse, error)
	/// Remove all existing traffic classes
	///
	/// NOTE: There should be no running worker to run this command.
	ResetTcs(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Enumerate all existing workers
	ListTcs(context.Context, *ListTcsRequest) (*ListTcsResponse, error)
	/// Check scheduling contraints
	CheckSchedulingConstraints(context.Context, *EmptyRequest) (*CheckSchedulingConstraintsResponse, error)
	/// Create a new traffic class
	///
	/// NOTE: There should be no running worker to run this command.
	AddTc(context.Context, *AddTcRequest) (*EmptyResponse, error)
	/// Update parameters of an existing traffic class
	///
	/// NOTE: There should be no running worker to run this command.
	UpdateTcParams(context.Context, *UpdateTcParamsRequest) (*EmptyResponse, error)
	/// Change parent (and child arguments) of an existing traffic class
	///
	/// NOTE: There should be no running worker to run this command.
	UpdateTcParent(context.Context, *UpdateTcParentRequest) (*EmptyResponse, error)
	/// Collect statistics of a traffic class
	GetTcStats(context.Context, *GetTcStatsRequest) (*GetTcStatsResponse, error)
	/// Enumerate all port drivers available
	ListDrivers(context.Context, *EmptyRequest) (*ListDriversResponse, error)
	/// Query detailed information of a port driver
	GetDriverInfo(context.Context, *GetDriverInfoRequest) (*GetDriverInfoResponse, error)
	/// Remove all initialized ports
	///
	/// Will fail if there are modules that are still using ports.
	/// (e.g., PortInc, PortOut, QueueInc, QueueOut)
	///
	/// NOTE: There should be no running worker to run this command.
	ResetPorts(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Enumerate all initialized ports
	ListPorts(context.Context, *EmptyRequest) (*ListPortsResponse, error)
	/// Create a new port from the specified driver
	CreatePort(context.Context, *CreatePortRequest) (*CreatePortResponse, error)
	/// Remove a port
	///
	/// The port should not be being used by a port-related module.
	/// (e.g., PortInc, PortOut, QueueInc, QueueOut)
	DestroyPort(context.Context, *DestroyPortRequest) (*EmptyResponse, error)
	/// Runtime-updatable configuration
	SetPortConf(context.Context, *SetPortConfRequest) (*CommandResponse, error)
	GetPortConf(context.Context, *GetPortConfRequest) (*GetPortConfResponse, error)
	/// Collect port statistics
	///
	/// At the moment, per-queue stats are not supported.
	GetPortStats(context.Context, *GetPortStatsRequest) (*GetPortStatsResponse, error)
	/// Query link status
	GetLinkStatus(context.Context, *GetLinkStatusRequest) (*GetLinkStatusResponse, error)
	/// Enumerate all module types available
	ListMclass(context.Context, *EmptyRequest) (*ListMclassResponse, error)
	/// Query detailed information of a module type
	GetMclassInfo(context.Context, *GetMclassInfoRequest) (*GetMclassInfoResponse, error)
	/// Remove all modules.
	///
	/// This RPC will always succeed (unless there is a running worker)
	///
	/// NOTE: There should be no running worker to run this command.
	ResetModules(context.Context, *EmptyRequest) (*EmptyResponse, error)
	/// Enumerate all initialized modules
	ListModules(context.Context, *EmptyRequest) (*ListModulesResponse, error)
	/// Create a new module instance from the given module type
	///
	/// NOTE: There should be no running worker to run this command.
	CreateModule(context.Context, *CreateModuleRequest) (*CreateModuleResponse, error)
	/// Destroy an exsting module
	///
	/// If the module is connected to other modules' input/output gate, they are
	/// disconnected first. All tasks created by the module will also be destoyed.
	///
	/// NOTE: There should be no running worker to run this command.
	DestroyModule(context.Context, *DestroyModuleRequest) (*EmptyResponse, error)
	/// Fetch detailed information of an module instance
	GetModuleInfo(context.Context, *GetModuleInfoRequest) (*GetModuleInfoResponse, error)
	/// Connect two modules.
	///
	/// Connect between m1's ogate and n2's igate (i.e., ackets sent to m1's ogate
	/// will be fed to m2's igate). The oate can be connected to only one igate,
	/// while the igate can be connected to multiple output gates.
	///
	/// NOTE: There should be no running worker to run this command.
	ConnectModules(context.Context, *ConnectModulesRequest) (*EmptyResponse, error)
	/// Disconnect two modules.
	///
	/// It removes a connection between two modules (you specify the previous one
	/// and its output gate). All packets coming out from the ogate will be
	/// dropped. Once disconnected, the ogate can be connected
	/// to any input gate.
	///
	/// NOTE: There should be no running worker to run this command.
	DisconnectModules(context.Context, *DisconnectModulesRequest) (*EmptyResponse, error)
	/// Dump various stats about BESS's packet pools
	DumpMempool(context.Context, *DumpMempoolRequest) (*DumpMempoolResponse, error)
	/// Send a command to the specified module instance.
	///
	/// Each module type defines a list of modyle-specific commands, which
	/// allow external programs to communicate with the module at runtime.
	/// See module_msg.proto for details.
	///
	/// NOTE: Some commands cannot be used if there are running workers.
	///       For those commands you must pause all workers first.
	ModuleCommand(context.Context, *CommandRequest) (*CommandResponse, error)
	/// Enumerate all gatehook types available
	ListGateHookClass(context.Context, *EmptyRequest) (*ListGateHookClassResponse, error)
	/// Query detailed information of a gatehook type
	GetGateHookClassInfo(context.Context, *GetGateHookClassInfoRequest) (*GetGateHookClassInfoResponse, error)
	/// Enable/Disable a gate hook.
	ConfigureGateHook(context.Context, *ConfigureGateHookRequest) (*ConfigureGateHookResponse, error)
	/// Enumerate all gatehook installed
	ListGateHooks(context.Context, *EmptyRequest) (*ListGateHooksResponse, error)
	/// Send command to gate hook instance.
	GateHookCommand(context.Context, *GateHookCommandRequest) (*CommandResponse, error)
	/// Enable/Disable a resume hook.
	ConfigureResumeHook(context.Context, *ConfigureResumeHookRequest) (*CommandResponse, error)
}

BESSControlServer is the server API for BESSControl service.

type BPFArg 

type BPFArg struct {
	Filters []*BPFArg_Filter `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"` /// The BPF initialized function takes a list of BPF filters.
	// contains filtered or unexported fields
}

* The BPF module is an access control module that sends packets out on a particular gate based on whether they match a BPF filter.

__Input Gates__: 1 __Output Gates__: many (configurable)

func (*BPFArg) Descriptor deprecated 

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

Deprecated: Use BPFArg.ProtoReflect.Descriptor instead.

func (*BPFArg) GetFilters 

func (x *BPFArg) GetFilters() []*BPFArg_Filter

func (*BPFArg) ProtoMessage 

func (*BPFArg) ProtoMessage()

func (*BPFArg) ProtoReflect 

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

func (*BPFArg) Reset 

func (x *BPFArg) Reset()

func (*BPFArg) String 

func (x *BPFArg) String() string

type BPFArg_Filter 

type BPFArg_Filter struct {
	Priority int64  `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"` /// The priority level for this rule. If a packet matches multiple rules, it will be forwarded out the gate with the highest priority. If a packet matches multiple rules with the same priority, the behavior is undefined.
	Filter   string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`      /// The actual BPF string.
	Gate     int64  `protobuf:"varint,3,opt,name=gate,proto3" json:"gate,omitempty"`         ///What gate to forward packets that match this BPF to.
	// contains filtered or unexported fields
}

* One BPF filter is represented by the following 3-tuple.

func (*BPFArg_Filter) Descriptor deprecated 

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

Deprecated: Use BPFArg_Filter.ProtoReflect.Descriptor instead.

func (*BPFArg_Filter) GetFilter 

func (x *BPFArg_Filter) GetFilter() string

func (*BPFArg_Filter) GetGate 

func (x *BPFArg_Filter) GetGate() int64

func (*BPFArg_Filter) GetPriority 

func (x *BPFArg_Filter) GetPriority() int64

func (*BPFArg_Filter) ProtoMessage 

func (*BPFArg_Filter) ProtoMessage()

func (*BPFArg_Filter) ProtoReflect 

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

func (*BPFArg_Filter) Reset 

func (x *BPFArg_Filter) Reset()

func (*BPFArg_Filter) String 

func (x *BPFArg_Filter) String() string

type BPFCommandClearArg 

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

* The BPF module has a command `clear()` that takes no parameters. This command removes all filters from the module.

func (*BPFCommandClearArg) Descriptor deprecated 

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

Deprecated: Use BPFCommandClearArg.ProtoReflect.Descriptor instead.

func (*BPFCommandClearArg) ProtoMessage 

func (*BPFCommandClearArg) ProtoMessage()

func (*BPFCommandClearArg) ProtoReflect 

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

func (*BPFCommandClearArg) Reset 

func (x *BPFCommandClearArg) Reset()

func (*BPFCommandClearArg) String 

func (x *BPFCommandClearArg) String() string

type BufferArg 

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

* The Buffer module takes no parameters to initialize (ie, `Buffer()` is sufficient to create one). Buffer accepts packets and stores them; it may forward them to the next module only after it has received enough packets to fill an entire PacketBatch.

__Input Gates__: 1 __Output Gates__: 1

func (*BufferArg) Descriptor deprecated 

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

Deprecated: Use BufferArg.ProtoReflect.Descriptor instead.

func (*BufferArg) ProtoMessage 

func (*BufferArg) ProtoMessage()

func (*BufferArg) ProtoReflect 

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

func (*BufferArg) Reset 

func (x *BufferArg) Reset()

func (*BufferArg) String 

func (x *BufferArg) String() string

type BypassArg 

type BypassArg struct {
	CyclesPerBatch  uint32 `protobuf:"varint,1,opt,name=cycles_per_batch,json=cyclesPerBatch,proto3" json:"cycles_per_batch,omitempty"`
	CyclesPerPacket uint32 `protobuf:"varint,2,opt,name=cycles_per_packet,json=cyclesPerPacket,proto3" json:"cycles_per_packet,omitempty"`
	CyclesPerByte   uint32 `protobuf:"varint,3,opt,name=cycles_per_byte,json=cyclesPerByte,proto3" json:"cycles_per_byte,omitempty"`
	// contains filtered or unexported fields
}

* The Bypass module forwards packets by emulating pre-defined packet processing overhead. It burns cpu cycles per_batch, per_packet, and per-bytes. Bypass is useful primarily for testing and performance evaluation.

__Input Gates__: 1 __Output Gates__: 1

func (*BypassArg) Descriptor deprecated 

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

Deprecated: Use BypassArg.ProtoReflect.Descriptor instead.

func (*BypassArg) GetCyclesPerBatch 

func (x *BypassArg) GetCyclesPerBatch() uint32

func (*BypassArg) GetCyclesPerByte 

func (x *BypassArg) GetCyclesPerByte() uint32

func (*BypassArg) GetCyclesPerPacket 

func (x *BypassArg) GetCyclesPerPacket() uint32

func (*BypassArg) ProtoMessage 

func (*BypassArg) ProtoMessage()

func (*BypassArg) ProtoReflect 

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

func (*BypassArg) Reset 

func (x *BypassArg) Reset()

func (*BypassArg) String 

func (x *BypassArg) String() string

type CheckSchedulingConstraintsResponse 

type CheckSchedulingConstraintsResponse struct {
	Error      *Error                                                `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Fatal      bool                                                  `protobuf:"varint,2,opt,name=fatal,proto3" json:"fatal,omitempty"`
	Violations []*CheckSchedulingConstraintsResponse_ViolatingClass  `protobuf:"bytes,3,rep,name=violations,proto3" json:"violations,omitempty"`
	Modules    []*CheckSchedulingConstraintsResponse_ViolatingModule `protobuf:"bytes,4,rep,name=modules,proto3" json:"modules,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSchedulingConstraintsResponse) Descriptor deprecated 

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

Deprecated: Use CheckSchedulingConstraintsResponse.ProtoReflect.Descriptor instead.

func (*CheckSchedulingConstraintsResponse) GetError 

func (x *CheckSchedulingConstraintsResponse) GetError() *Error

func (*CheckSchedulingConstraintsResponse) GetFatal 

func (x *CheckSchedulingConstraintsResponse) GetFatal() bool

func (*CheckSchedulingConstraintsResponse) GetModules 

func (x *CheckSchedulingConstraintsResponse) GetModules() []*CheckSchedulingConstraintsResponse_ViolatingModule

func (*CheckSchedulingConstraintsResponse) GetViolations 

func (x *CheckSchedulingConstraintsResponse) GetViolations() []*CheckSchedulingConstraintsResponse_ViolatingClass

func (*CheckSchedulingConstraintsResponse) ProtoMessage 

func (*CheckSchedulingConstraintsResponse) ProtoMessage()

func (*CheckSchedulingConstraintsResponse) ProtoReflect 

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

func (*CheckSchedulingConstraintsResponse) Reset 

func (x *CheckSchedulingConstraintsResponse) Reset()

func (*CheckSchedulingConstraintsResponse) String 

func (x *CheckSchedulingConstraintsResponse) String() string

type CheckSchedulingConstraintsResponse_ViolatingClass 

type CheckSchedulingConstraintsResponse_ViolatingClass struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Constraint   int32  `protobuf:"varint,2,opt,name=constraint,proto3" json:"constraint,omitempty"`
	AssignedNode int32  `protobuf:"varint,3,opt,name=assigned_node,json=assignedNode,proto3" json:"assigned_node,omitempty"`
	AssignedCore int32  `protobuf:"varint,4,opt,name=assigned_core,json=assignedCore,proto3" json:"assigned_core,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckSchedulingConstraintsResponse_ViolatingClass) Descriptor deprecated 

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

Deprecated: Use CheckSchedulingConstraintsResponse_ViolatingClass.ProtoReflect.Descriptor instead.

func (*CheckSchedulingConstraintsResponse_ViolatingClass) GetAssignedCore 

func (x *CheckSchedulingConstraintsResponse_ViolatingClass) GetAssignedCore() int32

func (*CheckSchedulingConstraintsResponse_ViolatingClass) GetAssignedNode 

func (x *CheckSchedulingConstraintsResponse_ViolatingClass) GetAssignedNode() int32

func (*CheckSchedulingConstraintsResponse_ViolatingClass) GetConstraint 

func (x *CheckSchedulingConstraintsResponse_ViolatingClass) GetConstraint() int32

func (*CheckSchedulingConstraintsResponse_ViolatingClass) GetName 

func (x *CheckSchedulingConstraintsResponse_ViolatingClass) GetName() string

func (*CheckSchedulingConstraintsResponse_ViolatingClass) ProtoMessage 

func (*CheckSchedulingConstraintsResponse_ViolatingClass) ProtoMessage()

func (*CheckSchedulingConstraintsResponse_ViolatingClass) ProtoReflect 

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

func (*CheckSchedulingConstraintsResponse_ViolatingClass) Reset 

func (x *CheckSchedulingConstraintsResponse_ViolatingClass) Reset()

func (*CheckSchedulingConstraintsResponse_ViolatingClass) String 

func (x *CheckSchedulingConstraintsResponse_ViolatingClass) String() string

type CheckSchedulingConstraintsResponse_ViolatingModule 

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

func (*CheckSchedulingConstraintsResponse_ViolatingModule) Descriptor deprecated 

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

Deprecated: Use CheckSchedulingConstraintsResponse_ViolatingModule.ProtoReflect.Descriptor instead.

func (*CheckSchedulingConstraintsResponse_ViolatingModule) GetName 

func (x *CheckSchedulingConstraintsResponse_ViolatingModule) GetName() string

func (*CheckSchedulingConstraintsResponse_ViolatingModule) ProtoMessage 

func (*CheckSchedulingConstraintsResponse_ViolatingModule) ProtoMessage()

func (*CheckSchedulingConstraintsResponse_ViolatingModule) ProtoReflect 

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

func (*CheckSchedulingConstraintsResponse_ViolatingModule) Reset 

func (x *CheckSchedulingConstraintsResponse_ViolatingModule) Reset()

func (*CheckSchedulingConstraintsResponse_ViolatingModule) String 

func (x *CheckSchedulingConstraintsResponse_ViolatingModule) String() string

type CommandRequest 

type CommandRequest struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` /// Name of module/port/driver
	Cmd  string   `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`   /// Name of command
	Arg  *any.Any `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`   /// Command argument
	// contains filtered or unexported fields
}

func (*CommandRequest) Descriptor deprecated 

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

Deprecated: Use CommandRequest.ProtoReflect.Descriptor instead.

func (*CommandRequest) GetArg 

func (x *CommandRequest) GetArg() *any.Any

func (*CommandRequest) GetCmd 

func (x *CommandRequest) GetCmd() string

func (*CommandRequest) GetName 

func (x *CommandRequest) GetName() string

func (*CommandRequest) ProtoMessage 

func (*CommandRequest) ProtoMessage()

func (*CommandRequest) ProtoReflect 

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

func (*CommandRequest) Reset 

func (x *CommandRequest) Reset()

func (*CommandRequest) String 

func (x *CommandRequest) String() string

type CommandResponse 

type CommandResponse struct {
	Error *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Data  *any.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` /// Command response (see *_msg.proto)
	// contains filtered or unexported fields
}

func (*CommandResponse) Descriptor deprecated 

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

Deprecated: Use CommandResponse.ProtoReflect.Descriptor instead.

func (*CommandResponse) GetData 

func (x *CommandResponse) GetData() *any.Any

func (*CommandResponse) GetError 

func (x *CommandResponse) GetError() *Error

func (*CommandResponse) ProtoMessage 

func (*CommandResponse) ProtoMessage()

func (*CommandResponse) ProtoReflect 

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

func (*CommandResponse) Reset 

func (x *CommandResponse) Reset()

func (*CommandResponse) String 

func (x *CommandResponse) String() string

type ConfigureGateHookRequest 

type ConfigureGateHookRequest struct {
	Hook   *GateHookInfo `protobuf:"bytes,1,opt,name=hook,proto3" json:"hook,omitempty"`
	Enable bool          `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureGateHookRequest) Descriptor deprecated 

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

Deprecated: Use ConfigureGateHookRequest.ProtoReflect.Descriptor instead.

func (*ConfigureGateHookRequest) GetEnable 

func (x *ConfigureGateHookRequest) GetEnable() bool

func (*ConfigureGateHookRequest) GetHook 

func (x *ConfigureGateHookRequest) GetHook() *GateHookInfo

func (*ConfigureGateHookRequest) ProtoMessage 

func (*ConfigureGateHookRequest) ProtoMessage()

func (*ConfigureGateHookRequest) ProtoReflect 

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

func (*ConfigureGateHookRequest) Reset 

func (x *ConfigureGateHookRequest) Reset()

func (*ConfigureGateHookRequest) String 

func (x *ConfigureGateHookRequest) String() string

type ConfigureGateHookResponse 

type ConfigureGateHookResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` /// Name of the created gatehook (specified or default one)
	// contains filtered or unexported fields
}

func (*ConfigureGateHookResponse) Descriptor deprecated 

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

Deprecated: Use ConfigureGateHookResponse.ProtoReflect.Descriptor instead.

func (*ConfigureGateHookResponse) GetError 

func (x *ConfigureGateHookResponse) GetError() *Error

func (*ConfigureGateHookResponse) GetName 

func (x *ConfigureGateHookResponse) GetName() string

func (*ConfigureGateHookResponse) ProtoMessage 

func (*ConfigureGateHookResponse) ProtoMessage()

func (*ConfigureGateHookResponse) ProtoReflect 

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

func (*ConfigureGateHookResponse) Reset 

func (x *ConfigureGateHookResponse) Reset()

func (*ConfigureGateHookResponse) String 

func (x *ConfigureGateHookResponse) String() string

type ConfigureResumeHookRequest 

type ConfigureResumeHookRequest struct {
	HookName string   `protobuf:"bytes,1,opt,name=hook_name,json=hookName,proto3" json:"hook_name,omitempty"` /// Name of the hook
	Enable   bool     `protobuf:"varint,2,opt,name=enable,proto3" json:"enable,omitempty"`                    /// Installs the hook if True, else uninstalls
	Arg      *any.Any `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`                           /// Hook-specific arguments
	// contains filtered or unexported fields
}

Enable/Disable a global ResumeHook.

func (*ConfigureResumeHookRequest) Descriptor deprecated 

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

Deprecated: Use ConfigureResumeHookRequest.ProtoReflect.Descriptor instead.

func (*ConfigureResumeHookRequest) GetArg 

func (x *ConfigureResumeHookRequest) GetArg() *any.Any

func (*ConfigureResumeHookRequest) GetEnable 

func (x *ConfigureResumeHookRequest) GetEnable() bool

func (*ConfigureResumeHookRequest) GetHookName 

func (x *ConfigureResumeHookRequest) GetHookName() string

func (*ConfigureResumeHookRequest) ProtoMessage 

func (*ConfigureResumeHookRequest) ProtoMessage()

func (*ConfigureResumeHookRequest) ProtoReflect 

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

func (*ConfigureResumeHookRequest) Reset 

func (x *ConfigureResumeHookRequest) Reset()

func (*ConfigureResumeHookRequest) String 

func (x *ConfigureResumeHookRequest) String() string

type ConnectModulesRequest 

type ConnectModulesRequest struct {
	M1    string `protobuf:"bytes,1,opt,name=m1,proto3" json:"m1,omitempty"`        /// Name of "previous" module name
	M2    string `protobuf:"bytes,2,opt,name=m2,proto3" json:"m2,omitempty"`        /// name of "next" module name
	Ogate uint64 `protobuf:"varint,3,opt,name=ogate,proto3" json:"ogate,omitempty"` /// m1's output gate ID
	Igate uint64 `protobuf:"varint,4,opt,name=igate,proto3" json:"igate,omitempty"` /// m2's input gate ID
	/// If true do not attach default hooks at the input/output gate.
	/// (Currently, the only default hook is the "Track" hook at the ogate)
	SkipDefaultHooks bool `protobuf:"varint,5,opt,name=skip_default_hooks,json=skipDefaultHooks,proto3" json:"skip_default_hooks,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectModulesRequest) Descriptor deprecated 

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

Deprecated: Use ConnectModulesRequest.ProtoReflect.Descriptor instead.

func (*ConnectModulesRequest) GetIgate 

func (x *ConnectModulesRequest) GetIgate() uint64

func (*ConnectModulesRequest) GetM1 

func (x *ConnectModulesRequest) GetM1() string

func (*ConnectModulesRequest) GetM2 

func (x *ConnectModulesRequest) GetM2() string

func (*ConnectModulesRequest) GetOgate 

func (x *ConnectModulesRequest) GetOgate() uint64

func (*ConnectModulesRequest) GetSkipDefaultHooks 

func (x *ConnectModulesRequest) GetSkipDefaultHooks() bool

func (*ConnectModulesRequest) ProtoMessage 

func (*ConnectModulesRequest) ProtoMessage()

func (*ConnectModulesRequest) ProtoReflect 

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

func (*ConnectModulesRequest) Reset 

func (x *ConnectModulesRequest) Reset()

func (*ConnectModulesRequest) String 

func (x *ConnectModulesRequest) String() string

type CounterAddArg 

type CounterAddArg struct {
	CtrId uint32 `protobuf:"varint,1,opt,name=ctr_id,json=ctrId,proto3" json:"ctr_id,omitempty"` /// counter id
	// contains filtered or unexported fields
}

* The Counter module has a command `add(...)` which takes one parameters. This function accepts the counter id of a session record. Example use in bessctl: `counter.add(ctr_id=0x1)`

func (*CounterAddArg) Descriptor deprecated 

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

Deprecated: Use CounterAddArg.ProtoReflect.Descriptor instead.

func (*CounterAddArg) GetCtrId 

func (x *CounterAddArg) GetCtrId() uint32

func (*CounterAddArg) ProtoMessage 

func (*CounterAddArg) ProtoMessage()

func (*CounterAddArg) ProtoReflect 

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

func (*CounterAddArg) Reset 

func (x *CounterAddArg) Reset()

func (*CounterAddArg) String 

func (x *CounterAddArg) String() string

type CounterArg 

type CounterArg struct {
	NameId     string `protobuf:"bytes,1,opt,name=name_id,json=nameId,proto3" json:"name_id,omitempty"`              /// Name of the counter_id
	CheckExist bool   `protobuf:"varint,2,opt,name=check_exist,json=checkExist,proto3" json:"check_exist,omitempty"` /// verify each counter pre-exists before any operation (default = False)
	Total      uint32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`                             /// Total number of entries it can support
	// contains filtered or unexported fields
}

* The Counter module counts the number of packets and bytes it passes

__Input Gates__: 1 __Output Gates__: 1

func (*CounterArg) Descriptor deprecated 

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

Deprecated: Use CounterArg.ProtoReflect.Descriptor instead.

func (*CounterArg) GetCheckExist 

func (x *CounterArg) GetCheckExist() bool

func (*CounterArg) GetNameId 

func (x *CounterArg) GetNameId() string

func (*CounterArg) GetTotal 

func (x *CounterArg) GetTotal() uint32

func (*CounterArg) ProtoMessage 

func (*CounterArg) ProtoMessage()

func (*CounterArg) ProtoReflect 

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

func (*CounterArg) Reset 

func (x *CounterArg) Reset()

func (*CounterArg) String 

func (x *CounterArg) String() string

type CounterRemoveArg 

type CounterRemoveArg struct {
	CtrId uint32 `protobuf:"varint,1,opt,name=ctr_id,json=ctrId,proto3" json:"ctr_id,omitempty"` /// counter id
	// contains filtered or unexported fields
}

* The Counter module has a command `remove(...)` which takes one parameter. This function accepts ctr_id, and removes the respective counter. Example use in bessctl: `counter.remove(ctr_id=0x1)`

func (*CounterRemoveArg) Descriptor deprecated 

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

Deprecated: Use CounterRemoveArg.ProtoReflect.Descriptor instead.

func (*CounterRemoveArg) GetCtrId 

func (x *CounterRemoveArg) GetCtrId() uint32

func (*CounterRemoveArg) ProtoMessage 

func (*CounterRemoveArg) ProtoMessage()

func (*CounterRemoveArg) ProtoReflect 

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

func (*CounterRemoveArg) Reset 

func (x *CounterRemoveArg) Reset()

func (*CounterRemoveArg) String 

func (x *CounterRemoveArg) String() string

type CreateModuleRequest 

type CreateModuleRequest struct {

	/// Name of the module to create. Every module must have a unique name.
	/// If not specified, a default name will be assigned
	/// (returned via CreateModuleResponse for future reference).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	/// Name of module type. Must be specified.
	Mclass string `protobuf:"bytes,2,opt,name=mclass,proto3" json:"mclass,omitempty"`
	/// Protobuf message to be used for module initialization.
	/// See module_msg.proto for the argument message types.
	Arg *any.Any `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateModuleRequest) Descriptor deprecated 

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

Deprecated: Use CreateModuleRequest.ProtoReflect.Descriptor instead.

func (*CreateModuleRequest) GetArg 

func (x *CreateModuleRequest) GetArg() *any.Any

func (*CreateModuleRequest) GetMclass 

func (x *CreateModuleRequest) GetMclass() string

func (*CreateModuleRequest) GetName 

func (x *CreateModuleRequest) GetName() string

func (*CreateModuleRequest) ProtoMessage 

func (*CreateModuleRequest) ProtoMessage()

func (*CreateModuleRequest) ProtoReflect 

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

func (*CreateModuleRequest) Reset 

func (x *CreateModuleRequest) Reset()

func (*CreateModuleRequest) String 

func (x *CreateModuleRequest) String() string

type CreateModuleResponse 

type CreateModuleResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` /// Name of the created module (specified or default one)
	// contains filtered or unexported fields
}

func (*CreateModuleResponse) Descriptor deprecated 

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

Deprecated: Use CreateModuleResponse.ProtoReflect.Descriptor instead.

func (*CreateModuleResponse) GetError 

func (x *CreateModuleResponse) GetError() *Error

func (*CreateModuleResponse) GetName 

func (x *CreateModuleResponse) GetName() string

func (*CreateModuleResponse) ProtoMessage 

func (*CreateModuleResponse) ProtoMessage()

func (*CreateModuleResponse) ProtoReflect 

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

func (*CreateModuleResponse) Reset 

func (x *CreateModuleResponse) Reset()

func (*CreateModuleResponse) String 

func (x *CreateModuleResponse) String() string

type CreatePortRequest 

type CreatePortRequest struct {

	/// Name of the port to create. Every port must have a unique name.
	/// If not specified, a default name will be assigned
	/// (returned via CreatePortResponse for future reference).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	/// Name of port driver. Must be specified.
	Driver string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	/// Number of incoming/RX queues (Ext -> BESS). Default is 1
	NumIncQ uint64 `protobuf:"varint,3,opt,name=num_inc_q,json=numIncQ,proto3" json:"num_inc_q,omitempty"`
	/// Number of outgoind/TX queues (BESS -> Ext). Default is 1
	NumOutQ uint64 `protobuf:"varint,4,opt,name=num_out_q,json=numOutQ,proto3" json:"num_out_q,omitempty"`
	/// Size of each incoming queue (# of packets).
	/// If not set (0), a driver-specific default value will be used.
	SizeIncQ uint64 `protobuf:"varint,5,opt,name=size_inc_q,json=sizeIncQ,proto3" json:"size_inc_q,omitempty"`
	/// Size of each incoming queue (# of packets).
	/// If not set (0), a driver-specific default value will be used.
	SizeOutQ uint64 `protobuf:"varint,6,opt,name=size_out_q,json=sizeOutQ,proto3" json:"size_out_q,omitempty"`
	/// Driver specific argument for port initialization. See port_msg.proto
	Arg *any.Any `protobuf:"bytes,7,opt,name=arg,proto3" json:"arg,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePortRequest) Descriptor deprecated 

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

Deprecated: Use CreatePortRequest.ProtoReflect.Descriptor instead.

func (*CreatePortRequest) GetArg 

func (x *CreatePortRequest) GetArg() *any.Any

func (*CreatePortRequest) GetDriver 

func (x *CreatePortRequest) GetDriver() string

func (*CreatePortRequest) GetName 

func (x *CreatePortRequest) GetName() string

func (*CreatePortRequest) GetNumIncQ 

func (x *CreatePortRequest) GetNumIncQ() uint64

func (*CreatePortRequest) GetNumOutQ 

func (x *CreatePortRequest) GetNumOutQ() uint64

func (*CreatePortRequest) GetSizeIncQ 

func (x *CreatePortRequest) GetSizeIncQ() uint64

func (*CreatePortRequest) GetSizeOutQ 

func (x *CreatePortRequest) GetSizeOutQ() uint64

func (*CreatePortRequest) ProtoMessage 

func (*CreatePortRequest) ProtoMessage()

func (*CreatePortRequest) ProtoReflect 

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

func (*CreatePortRequest) Reset 

func (x *CreatePortRequest) Reset()

func (*CreatePortRequest) String 

func (x *CreatePortRequest) String() string

type CreatePortResponse 

type CreatePortResponse struct {
	Error   *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                      /// Name of the created port (specified or default one)
	MacAddr string `protobuf:"bytes,3,opt,name=mac_addr,json=macAddr,proto3" json:"mac_addr,omitempty"` /// Port MAC address (specified or default one)
	// contains filtered or unexported fields
}

func (*CreatePortResponse) Descriptor deprecated 

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

Deprecated: Use CreatePortResponse.ProtoReflect.Descriptor instead.

func (*CreatePortResponse) GetError 

func (x *CreatePortResponse) GetError() *Error

func (*CreatePortResponse) GetMacAddr 

func (x *CreatePortResponse) GetMacAddr() string

func (*CreatePortResponse) GetName 

func (x *CreatePortResponse) GetName() string

func (*CreatePortResponse) ProtoMessage 

func (*CreatePortResponse) ProtoMessage()

func (*CreatePortResponse) ProtoReflect 

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

func (*CreatePortResponse) Reset 

func (x *CreatePortResponse) Reset()

func (*CreatePortResponse) String 

func (x *CreatePortResponse) String() string

type DRRArg 

type DRRArg struct {
	NumFlows         uint32 `protobuf:"varint,1,opt,name=num_flows,json=numFlows,proto3" json:"num_flows,omitempty"`                             /// Number of flows to handle in module
	Quantum          uint64 `protobuf:"varint,2,opt,name=quantum,proto3" json:"quantum,omitempty"`                                               /// the number of bytes to allocate to each on every round
	MaxFlowQueueSize uint32 `protobuf:"varint,3,opt,name=max_flow_queue_size,json=maxFlowQueueSize,proto3" json:"max_flow_queue_size,omitempty"` /// the max size that any Flows queue can get
	// contains filtered or unexported fields
}

* The Module DRR provides fair scheduling of flows based on a quantum which is number of bytes allocated to each flow on each round of going through all flows. Examples can be found [./bessctl/conf/samples/drr.bess]

__Input_Gates__: 1 __Output_Gates__: 1

func (*DRRArg) Descriptor deprecated 

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

Deprecated: Use DRRArg.ProtoReflect.Descriptor instead.

func (*DRRArg) GetMaxFlowQueueSize 

func (x *DRRArg) GetMaxFlowQueueSize() uint32

func (*DRRArg) GetNumFlows 

func (x *DRRArg) GetNumFlows() uint32

func (*DRRArg) GetQuantum 

func (x *DRRArg) GetQuantum() uint64

func (*DRRArg) ProtoMessage 

func (*DRRArg) ProtoMessage()

func (*DRRArg) ProtoReflect 

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

func (*DRRArg) Reset 

func (x *DRRArg) Reset()

func (*DRRArg) String 

func (x *DRRArg) String() string

type DRRMaxFlowQueueSizeArg 

type DRRMaxFlowQueueSizeArg struct {
	MaxQueueSize uint32 `protobuf:"varint,1,opt,name=max_queue_size,json=maxQueueSize,proto3" json:"max_queue_size,omitempty"` /// the max size that any Flows queue can get
	// contains filtered or unexported fields
}

* The SetMaxQueueSize function sets a new maximum flow queue size for DRR module. If the flow's queue gets to this size, the module starts dropping packets to that flow until the queue is below this size.

func (*DRRMaxFlowQueueSizeArg) Descriptor deprecated 

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

Deprecated: Use DRRMaxFlowQueueSizeArg.ProtoReflect.Descriptor instead.

func (*DRRMaxFlowQueueSizeArg) GetMaxQueueSize 

func (x *DRRMaxFlowQueueSizeArg) GetMaxQueueSize() uint32

func (*DRRMaxFlowQueueSizeArg) ProtoMessage 

func (*DRRMaxFlowQueueSizeArg) ProtoMessage()

func (*DRRMaxFlowQueueSizeArg) ProtoReflect 

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

func (*DRRMaxFlowQueueSizeArg) Reset 

func (x *DRRMaxFlowQueueSizeArg) Reset()

func (*DRRMaxFlowQueueSizeArg) String 

func (x *DRRMaxFlowQueueSizeArg) String() string

type DRRQuantumArg 

type DRRQuantumArg struct {
	Quantum uint32 `protobuf:"varint,1,opt,name=quantum,proto3" json:"quantum,omitempty"` /// the number of bytes to allocate to each on every round
	// contains filtered or unexported fields
}

* the SetQuantumSize function sets a new quantum for DRR module to operate on.

func (*DRRQuantumArg) Descriptor deprecated 

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

Deprecated: Use DRRQuantumArg.ProtoReflect.Descriptor instead.

func (*DRRQuantumArg) GetQuantum 

func (x *DRRQuantumArg) GetQuantum() uint32

func (*DRRQuantumArg) ProtoMessage 

func (*DRRQuantumArg) ProtoMessage()

func (*DRRQuantumArg) ProtoReflect 

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

func (*DRRQuantumArg) Reset 

func (x *DRRQuantumArg) Reset()

func (*DRRQuantumArg) String 

func (x *DRRQuantumArg) String() string

type DestroyModuleRequest 

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

func (*DestroyModuleRequest) Descriptor deprecated 

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

Deprecated: Use DestroyModuleRequest.ProtoReflect.Descriptor instead.

func (*DestroyModuleRequest) GetName 

func (x *DestroyModuleRequest) GetName() string

func (*DestroyModuleRequest) ProtoMessage 

func (*DestroyModuleRequest) ProtoMessage()

func (*DestroyModuleRequest) ProtoReflect 

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

func (*DestroyModuleRequest) Reset 

func (x *DestroyModuleRequest) Reset()

func (*DestroyModuleRequest) String 

func (x *DestroyModuleRequest) String() string

type DestroyPortRequest 

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

func (*DestroyPortRequest) Descriptor deprecated 

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

Deprecated: Use DestroyPortRequest.ProtoReflect.Descriptor instead.

func (*DestroyPortRequest) GetName 

func (x *DestroyPortRequest) GetName() string

func (*DestroyPortRequest) ProtoMessage 

func (*DestroyPortRequest) ProtoMessage()

func (*DestroyPortRequest) ProtoReflect 

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

func (*DestroyPortRequest) Reset 

func (x *DestroyPortRequest) Reset()

func (*DestroyPortRequest) String 

func (x *DestroyPortRequest) String() string

type DestroyWorkerRequest 

type DestroyWorkerRequest struct {
	Wid int64 `protobuf:"varint,1,opt,name=wid,proto3" json:"wid,omitempty"` /// Worker ID
	// contains filtered or unexported fields
}

func (*DestroyWorkerRequest) Descriptor deprecated 

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

Deprecated: Use DestroyWorkerRequest.ProtoReflect.Descriptor instead.

func (*DestroyWorkerRequest) GetWid 

func (x *DestroyWorkerRequest) GetWid() int64

func (*DestroyWorkerRequest) ProtoMessage 

func (*DestroyWorkerRequest) ProtoMessage()

func (*DestroyWorkerRequest) ProtoReflect 

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

func (*DestroyWorkerRequest) Reset 

func (x *DestroyWorkerRequest) Reset()

func (*DestroyWorkerRequest) String 

func (x *DestroyWorkerRequest) String() string

type DisconnectModulesRequest 

type DisconnectModulesRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`    /// Name of previous module
	Ogate uint64 `protobuf:"varint,2,opt,name=ogate,proto3" json:"ogate,omitempty"` /// Output gate ID of previous module
	// contains filtered or unexported fields
}

func (*DisconnectModulesRequest) Descriptor deprecated 

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

Deprecated: Use DisconnectModulesRequest.ProtoReflect.Descriptor instead.

func (*DisconnectModulesRequest) GetName 

func (x *DisconnectModulesRequest) GetName() string

func (*DisconnectModulesRequest) GetOgate 

func (x *DisconnectModulesRequest) GetOgate() uint64

func (*DisconnectModulesRequest) ProtoMessage 

func (*DisconnectModulesRequest) ProtoMessage()

func (*DisconnectModulesRequest) ProtoReflect 

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

func (*DisconnectModulesRequest) Reset 

func (x *DisconnectModulesRequest) Reset()

func (*DisconnectModulesRequest) String 

func (x *DisconnectModulesRequest) String() string

type DumpArg 

type DumpArg struct {
	Interval float64 `protobuf:"fixed64,1,opt,name=interval,proto3" json:"interval,omitempty"` ///How frequently to sample and print a packet, in seconds.
	// contains filtered or unexported fields
}

* The Dump module blindly forwards packets without modifying them. It periodically samples a packet and prints out out to the BESS log (by default stored in `/tmp/bessd.INFO`).

__Input Gates__: 1 __Output Gates__: 1

func (*DumpArg) Descriptor deprecated 

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

Deprecated: Use DumpArg.ProtoReflect.Descriptor instead.

func (*DumpArg) GetInterval 

func (x *DumpArg) GetInterval() float64

func (*DumpArg) ProtoMessage 

func (*DumpArg) ProtoMessage()

func (*DumpArg) ProtoReflect 

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

func (*DumpArg) Reset 

func (x *DumpArg) Reset()

func (*DumpArg) String 

func (x *DumpArg) String() string

type DumpMempoolRequest 

type DumpMempoolRequest struct {
	Socket int32 `protobuf:"varint,1,opt,name=socket,proto3" json:"socket,omitempty"` // ID of the socket whose mempool should be dumped. -1 for all sockets
	// contains filtered or unexported fields
}

func (*DumpMempoolRequest) Descriptor deprecated 

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

Deprecated: Use DumpMempoolRequest.ProtoReflect.Descriptor instead.

func (*DumpMempoolRequest) GetSocket 

func (x *DumpMempoolRequest) GetSocket() int32

func (*DumpMempoolRequest) ProtoMessage 

func (*DumpMempoolRequest) ProtoMessage()

func (*DumpMempoolRequest) ProtoReflect 

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

func (*DumpMempoolRequest) Reset 

func (x *DumpMempoolRequest) Reset()

func (*DumpMempoolRequest) String 

func (x *DumpMempoolRequest) String() string

type DumpMempoolResponse 

type DumpMempoolResponse struct {
	Error *Error         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Dumps []*MempoolDump `protobuf:"bytes,2,rep,name=dumps,proto3" json:"dumps,omitempty"` /// The list of requested mempool dumps
	// contains filtered or unexported fields
}

func (*DumpMempoolResponse) Descriptor deprecated 

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

Deprecated: Use DumpMempoolResponse.ProtoReflect.Descriptor instead.

func (*DumpMempoolResponse) GetDumps 

func (x *DumpMempoolResponse) GetDumps() []*MempoolDump

func (*DumpMempoolResponse) GetError 

func (x *DumpMempoolResponse) GetError() *Error

func (*DumpMempoolResponse) ProtoMessage 

func (*DumpMempoolResponse) ProtoMessage()

func (*DumpMempoolResponse) ProtoReflect 

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

func (*DumpMempoolResponse) Reset 

func (x *DumpMempoolResponse) Reset()

func (*DumpMempoolResponse) String 

func (x *DumpMempoolResponse) String() string

type EmptyArg 

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

func (*EmptyArg) Descriptor deprecated 

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

Deprecated: Use EmptyArg.ProtoReflect.Descriptor instead.

func (*EmptyArg) ProtoMessage 

func (*EmptyArg) ProtoMessage()

func (*EmptyArg) ProtoReflect 

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

func (*EmptyArg) Reset 

func (x *EmptyArg) Reset()

func (*EmptyArg) String 

func (x *EmptyArg) String() string

type EmptyRequest 

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

func (*EmptyRequest) Descriptor deprecated 

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

Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead.

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect 

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

func (*EmptyRequest) Reset 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (x *EmptyRequest) String() string

type EmptyResponse 

type EmptyResponse struct {

	/// Contains a non-zero error code and a non-empty message if and only if
	/// there has been an error
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*EmptyResponse) Descriptor deprecated 

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

Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.

func (*EmptyResponse) GetError 

func (x *EmptyResponse) GetError() *Error

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect 

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

func (*EmptyResponse) Reset 

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String 

func (x *EmptyResponse) String() string

type Error 

type Error struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // 0 for success, errno (>0) for failure
	Errmsg string `protobuf:"bytes,2,opt,name=errmsg,proto3" json:"errmsg,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() int32

func (*Error) GetErrmsg 

func (x *Error) GetErrmsg() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type EtherEncapArg 

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

* The EtherEncap module wraps packets in an Ethernet header, but it takes no parameters. Instead, Ethernet source, destination, and type are pulled from a packet's metadata attributes. For example: `SetMetadata('dst_mac', 11:22:33:44:55) -> EtherEncap()` This is useful when upstream modules wish to assign a MAC address to a packet, e.g., due to an ARP request.

__Input Gates__: 1 __Output Gates__: 1

func (*EtherEncapArg) Descriptor deprecated 

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

Deprecated: Use EtherEncapArg.ProtoReflect.Descriptor instead.

func (*EtherEncapArg) ProtoMessage 

func (*EtherEncapArg) ProtoMessage()

func (*EtherEncapArg) ProtoReflect 

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

func (*EtherEncapArg) Reset 

func (x *EtherEncapArg) Reset()

func (*EtherEncapArg) String 

func (x *EtherEncapArg) String() string

type ExactMatchArg 

type ExactMatchArg struct {
	Fields  []*Field     `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` ///A list of ExactMatch Fields
	Masks   []*FieldData `protobuf:"bytes,2,rep,name=masks,proto3" json:"masks,omitempty"`   /// mask(i) corresponds to the mask for field(i)
	Values  []*Field     `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` /// A list of ExactMatch Values
	Masksv  []*FieldData `protobuf:"bytes,4,rep,name=masksv,proto3" json:"masksv,omitempty"` /// mask(i) corresponds to the mask for value(i)
	Entries uint64       `protobuf:"varint,5,opt,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

* The ExactMatch module splits packets along output gates according to exact match values in arbitrary packet fields. To instantiate an ExactMatch module, you must specify which fields in the packet to match over. You can add rules using the function `ExactMatch.add(...)` Fields may be stored either in the packet data or its metadata attributes. An example script using the ExactMatch code is found in [`bess/bessctl/conf/samples/exactmatch.bess`](https://github.com/NetSys/bess/blob/master/bessctl/conf/samples/exactmatch.bess).

__Input Gates__: 1 __Output Gates__: many (configurable)

func (*ExactMatchArg) Descriptor deprecated 

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

Deprecated: Use ExactMatchArg.ProtoReflect.Descriptor instead.

func (*ExactMatchArg) GetEntries 

func (x *ExactMatchArg) GetEntries() uint64

func (*ExactMatchArg) GetFields 

func (x *ExactMatchArg) GetFields() []*Field

func (*ExactMatchArg) GetMasks 

func (x *ExactMatchArg) GetMasks() []*FieldData

func (*ExactMatchArg) GetMasksv 

func (x *ExactMatchArg) GetMasksv() []*FieldData

func (*ExactMatchArg) GetValues 

func (x *ExactMatchArg) GetValues() []*Field

func (*ExactMatchArg) ProtoMessage 

func (*ExactMatchArg) ProtoMessage()

func (*ExactMatchArg) ProtoReflect 

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

func (*ExactMatchArg) Reset 

func (x *ExactMatchArg) Reset()

func (*ExactMatchArg) String 

func (x *ExactMatchArg) String() string

type ExactMatchCommandAddArg 

type ExactMatchCommandAddArg struct {
	Gate   uint64       `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"`    /// The gate to forward out packets that mach this rule.
	Fields []*FieldData `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` /// The exact match values to check for
	Values []*FieldData `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` /// The exact match values to check for
	// contains filtered or unexported fields
}

* The ExactMatch module has a command `add(...)` that takes two parameters. The ExactMatch initializer specifies what fields in a packet to inspect; add() specifies which values to check for over these fields. add() inserts a new rule into the ExactMatch module such that traffic matching that bytestring will be forwarded out a specified gate. Example use: `add(fields=[aton('12.3.4.5'), aton('5.4.3.2')], gate=2)`

func (*ExactMatchCommandAddArg) Descriptor deprecated 

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

Deprecated: Use ExactMatchCommandAddArg.ProtoReflect.Descriptor instead.

func (*ExactMatchCommandAddArg) GetFields 

func (x *ExactMatchCommandAddArg) GetFields() []*FieldData

func (*ExactMatchCommandAddArg) GetGate 

func (x *ExactMatchCommandAddArg) GetGate() uint64

func (*ExactMatchCommandAddArg) GetValues 

func (x *ExactMatchCommandAddArg) GetValues() []*FieldData

func (*ExactMatchCommandAddArg) ProtoMessage 

func (*ExactMatchCommandAddArg) ProtoMessage()

func (*ExactMatchCommandAddArg) ProtoReflect 

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

func (*ExactMatchCommandAddArg) Reset 

func (x *ExactMatchCommandAddArg) Reset()

func (*ExactMatchCommandAddArg) String 

func (x *ExactMatchCommandAddArg) String() string

type ExactMatchCommandClearArg 

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

* The ExactMatch module has a command `clear()` which takes no parameters. This command removes all rules from the ExactMatch module.

func (*ExactMatchCommandClearArg) Descriptor deprecated 

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

Deprecated: Use ExactMatchCommandClearArg.ProtoReflect.Descriptor instead.

func (*ExactMatchCommandClearArg) ProtoMessage 

func (*ExactMatchCommandClearArg) ProtoMessage()

func (*ExactMatchCommandClearArg) ProtoReflect 

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

func (*ExactMatchCommandClearArg) Reset 

func (x *ExactMatchCommandClearArg) Reset()

func (*ExactMatchCommandClearArg) String 

func (x *ExactMatchCommandClearArg) String() string

type ExactMatchCommandDeleteArg 

type ExactMatchCommandDeleteArg struct {
	Fields []*FieldData `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` /// The field values for the rule to be deleted.
	// contains filtered or unexported fields
}

* The ExactMatch module has a command `delete(...)` which deletes an existing rule. Example use: `delete(fields=[aton('12.3.4.5'), aton('5.4.3.2')])`

func (*ExactMatchCommandDeleteArg) Descriptor deprecated 

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

Deprecated: Use ExactMatchCommandDeleteArg.ProtoReflect.Descriptor instead.

func (*ExactMatchCommandDeleteArg) GetFields 

func (x *ExactMatchCommandDeleteArg) GetFields() []*FieldData

func (*ExactMatchCommandDeleteArg) ProtoMessage 

func (*ExactMatchCommandDeleteArg) ProtoMessage()

func (*ExactMatchCommandDeleteArg) ProtoReflect 

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

func (*ExactMatchCommandDeleteArg) Reset 

func (x *ExactMatchCommandDeleteArg) Reset()

func (*ExactMatchCommandDeleteArg) String 

func (x *ExactMatchCommandDeleteArg) String() string

type ExactMatchCommandSetDefaultGateArg 

type ExactMatchCommandSetDefaultGateArg struct {
	Gate uint64 `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"` /// The gate number to send the default traffic out.
	// contains filtered or unexported fields
}

* The ExactMatch module has a command `set_default_gate(...)` which takes one parameter. This command routes all traffic which does _not_ match a rule to a specified gate. Example use in bessctl: `setDefaultGate(gate=2)`

func (*ExactMatchCommandSetDefaultGateArg) Descriptor deprecated 

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

Deprecated: Use ExactMatchCommandSetDefaultGateArg.ProtoReflect.Descriptor instead.

func (*ExactMatchCommandSetDefaultGateArg) GetGate 

func (x *ExactMatchCommandSetDefaultGateArg) GetGate() uint64

func (*ExactMatchCommandSetDefaultGateArg) ProtoMessage 

func (*ExactMatchCommandSetDefaultGateArg) ProtoMessage()

func (*ExactMatchCommandSetDefaultGateArg) ProtoReflect 

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

func (*ExactMatchCommandSetDefaultGateArg) Reset 

func (x *ExactMatchCommandSetDefaultGateArg) Reset()

func (*ExactMatchCommandSetDefaultGateArg) String 

func (x *ExactMatchCommandSetDefaultGateArg) String() string

type ExactMatchConfig 

type ExactMatchConfig struct {
	DefaultGate uint64                     `protobuf:"varint,1,opt,name=default_gate,json=defaultGate,proto3" json:"default_gate,omitempty"`
	Rules       []*ExactMatchCommandAddArg `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

* ExactMatchConfig represents the current runtime configuration of an ExactMatch module, as returned by get_runtime_config and set by set_runtime_config.

func (*ExactMatchConfig) Descriptor deprecated 

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

Deprecated: Use ExactMatchConfig.ProtoReflect.Descriptor instead.

func (*ExactMatchConfig) GetDefaultGate 

func (x *ExactMatchConfig) GetDefaultGate() uint64

func (*ExactMatchConfig) GetRules 

func (x *ExactMatchConfig) GetRules() []*ExactMatchCommandAddArg

func (*ExactMatchConfig) ProtoMessage 

func (*ExactMatchConfig) ProtoMessage()

func (*ExactMatchConfig) ProtoReflect 

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

func (*ExactMatchConfig) Reset 

func (x *ExactMatchConfig) Reset()

func (*ExactMatchConfig) String 

func (x *ExactMatchConfig) String() string

type Field 

type Field struct {

	// Types that are assignable to Position:
	//	*Field_AttrName
	//	*Field_Offset
	Position isField_Position `protobuf_oneof:"position"`
	NumBytes uint32           `protobuf:"varint,3,opt,name=num_bytes,json=numBytes,proto3" json:"num_bytes,omitempty"` /// The size of the data in bytes
	// contains filtered or unexported fields
}

/ The Field message represents one field in a packet -- either stored in metadata or in the packet body.

func (*Field) Descriptor deprecated 

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetAttrName 

func (x *Field) GetAttrName() string

func (*Field) GetNumBytes 

func (x *Field) GetNumBytes() uint32

func (*Field) GetOffset 

func (x *Field) GetOffset() uint32

func (*Field) GetPosition 

func (m *Field) GetPosition() isField_Position

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

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

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) String() string

type FieldData 

type FieldData struct {

	// Types that are assignable to Encoding:
	//	*FieldData_ValueBin
	//	*FieldData_ValueInt
	Encoding isFieldData_Encoding `protobuf_oneof:"encoding"`
	// contains filtered or unexported fields
}

/ The FieldData message encodes a value to insert into a packet; the value can be supplied as either an int or a bytestring.

func (*FieldData) Descriptor deprecated 

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

Deprecated: Use FieldData.ProtoReflect.Descriptor instead.

func (*FieldData) GetEncoding 

func (m *FieldData) GetEncoding() isFieldData_Encoding

func (*FieldData) GetValueBin 

func (x *FieldData) GetValueBin() []byte

func (*FieldData) GetValueInt 

func (x *FieldData) GetValueInt() uint64

func (*FieldData) ProtoMessage 

func (*FieldData) ProtoMessage()

func (*FieldData) ProtoReflect 

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

func (*FieldData) Reset 

func (x *FieldData) Reset()

func (*FieldData) String 

func (x *FieldData) String() string

type FieldData_ValueBin 

type FieldData_ValueBin struct {
	ValueBin []byte `protobuf:"bytes,1,opt,name=value_bin,json=valueBin,proto3,oneof"` /// The value as a bytestring
}

type FieldData_ValueInt 

type FieldData_ValueInt struct {
	ValueInt uint64 `protobuf:"varint,2,opt,name=value_int,json=valueInt,proto3,oneof"` /// The value in integer format
}

type Field_AttrName 

type Field_AttrName struct {
	AttrName string `protobuf:"bytes,1,opt,name=attr_name,json=attrName,proto3,oneof"` /// The metadata attribute assigned to store the data
}

type Field_Offset 

type Field_Offset struct {
	Offset uint32 `protobuf:"varint,2,opt,name=offset,proto3,oneof"` /// The offset in bytes to store the data into
}

type FlowGenArg 

type FlowGenArg struct {
	Template     []byte  `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`                                 /// The packet "template". All data packets are derived from this template and contain the same payload.
	Pps          float64 `protobuf:"fixed64,2,opt,name=pps,proto3" json:"pps,omitempty"`                                         /// The total number of packets per second to generate.
	FlowRate     float64 `protobuf:"fixed64,3,opt,name=flow_rate,json=flowRate,proto3" json:"flow_rate,omitempty"`               /// The number of new flows to create every second. flow_rate must be <= pps.
	FlowDuration float64 `protobuf:"fixed64,4,opt,name=flow_duration,json=flowDuration,proto3" json:"flow_duration,omitempty"`   /// The lifetime of a flow in seconds.
	Arrival      string  `protobuf:"bytes,5,opt,name=arrival,proto3" json:"arrival,omitempty"`                                   /// The packet arrival distribution -- must be either "uniform" or "exponential"
	Duration     string  `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`                                 /// The flow duration distribution -- must be either "uniform" or "pareto"
	QuickRampup  bool    `protobuf:"varint,7,opt,name=quick_rampup,json=quickRampup,proto3" json:"quick_rampup,omitempty"`       /// Whether or not to populate the flowgenerator with initial flows (start generating full pps rate immediately) or to wait for new flows to be generated naturally (all flows have a SYN packet).
	IpSrcRange   uint32  `protobuf:"varint,8,opt,name=ip_src_range,json=ipSrcRange,proto3" json:"ip_src_range,omitempty"`        /// When generating new flows, FlowGen modifies the template packet by changing the IP src, incrementing it by at most ip_src_range (e.g., if the base packet is 10.0.0.1 and range is 5, it will generate packets with IPs 10.0.0.1-10.0.0.6).
	IpDstRange   uint32  `protobuf:"varint,9,opt,name=ip_dst_range,json=ipDstRange,proto3" json:"ip_dst_range,omitempty"`        /// When generating new flows, FlowGen modifies the template packet by changing the IP dst, incrementing it by at most ip_dst_range.
	PortSrcRange uint32  `protobuf:"varint,10,opt,name=port_src_range,json=portSrcRange,proto3" json:"port_src_range,omitempty"` /// When generating new flows, FlowGen modifies the template packet by changing the TCP port, incrementing it by at most port_src_range.
	PortDstRange uint32  `protobuf:"varint,11,opt,name=port_dst_range,json=portDstRange,proto3" json:"port_dst_range,omitempty"` /// When generating new flows, FlowGen modifies the template packet by changing the TCP dst port, incrementing it by at most port_dst_range.
	// contains filtered or unexported fields
}

* The FlowGen module generates simulated TCP flows of packets with correct SYN/FIN flags and sequence numbers. This module is useful for testing, e.g., a NAT module or other flow-aware code. Packets are generated off a base, "template" packet by modifying the IP src/dst and TCP src/dst. By default, only the ports are changed and will be modified by incrementing the template ports by up to 20000 more than the template values.

__Input Gates__: 0 __Output Gates__: 1

func (*FlowGenArg) Descriptor deprecated 

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

Deprecated: Use FlowGenArg.ProtoReflect.Descriptor instead.

func (*FlowGenArg) GetArrival 

func (x *FlowGenArg) GetArrival() string

func (*FlowGenArg) GetDuration 

func (x *FlowGenArg) GetDuration() string

func (*FlowGenArg) GetFlowDuration 

func (x *FlowGenArg) GetFlowDuration() float64

func (*FlowGenArg) GetFlowRate 

func (x *FlowGenArg) GetFlowRate() float64

func (*FlowGenArg) GetIpDstRange 

func (x *FlowGenArg) GetIpDstRange() uint32

func (*FlowGenArg) GetIpSrcRange 

func (x *FlowGenArg) GetIpSrcRange() uint32

func (*FlowGenArg) GetPortDstRange 

func (x *FlowGenArg) GetPortDstRange() uint32

func (*FlowGenArg) GetPortSrcRange 

func (x *FlowGenArg) GetPortSrcRange() uint32

func (*FlowGenArg) GetPps 

func (x *FlowGenArg) GetPps() float64

func (*FlowGenArg) GetQuickRampup 

func (x *FlowGenArg) GetQuickRampup() bool

func (*FlowGenArg) GetTemplate 

func (x *FlowGenArg) GetTemplate() []byte

func (*FlowGenArg) ProtoMessage 

func (*FlowGenArg) ProtoMessage()

func (*FlowGenArg) ProtoReflect 

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

func (*FlowGenArg) Reset 

func (x *FlowGenArg) Reset()

func (*FlowGenArg) String 

func (x *FlowGenArg) String() string

type FlowGenCommandSetBurstArg 

type FlowGenCommandSetBurstArg struct {
	Burst uint64 `protobuf:"varint,1,opt,name=burst,proto3" json:"burst,omitempty"`
	// contains filtered or unexported fields
}

* The FlowGen module has a command `set_burst(...)` that allows you to specify the maximum number of packets to be stored in a single PacketBatch released by the module.

func (*FlowGenCommandSetBurstArg) Descriptor deprecated 

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

Deprecated: Use FlowGenCommandSetBurstArg.ProtoReflect.Descriptor instead.

func (*FlowGenCommandSetBurstArg) GetBurst 

func (x *FlowGenCommandSetBurstArg) GetBurst() uint64

func (*FlowGenCommandSetBurstArg) ProtoMessage 

func (*FlowGenCommandSetBurstArg) ProtoMessage()

func (*FlowGenCommandSetBurstArg) ProtoReflect 

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

func (*FlowGenCommandSetBurstArg) Reset 

func (x *FlowGenCommandSetBurstArg) Reset()

func (*FlowGenCommandSetBurstArg) String 

func (x *FlowGenCommandSetBurstArg) String() string

type FlowMeasureArg 

type FlowMeasureArg struct {
	FlagAttrName string `protobuf:"bytes,1,opt,name=flag_attr_name,json=flagAttrName,proto3" json:"flag_attr_name,omitempty"`
	Entries      uint64 `protobuf:"varint,2,opt,name=entries,proto3" json:"entries,omitempty"`
	Leader       bool   `protobuf:"varint,3,opt,name=leader,proto3" json:"leader,omitempty"` // If true, this module will decide the buffer side
	// contains filtered or unexported fields
}

func (*FlowMeasureArg) Descriptor deprecated 

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

Deprecated: Use FlowMeasureArg.ProtoReflect.Descriptor instead.

func (*FlowMeasureArg) GetEntries 

func (x *FlowMeasureArg) GetEntries() uint64

func (*FlowMeasureArg) GetFlagAttrName 

func (x *FlowMeasureArg) GetFlagAttrName() string

func (*FlowMeasureArg) GetLeader 

func (x *FlowMeasureArg) GetLeader() bool

func (*FlowMeasureArg) ProtoMessage 

func (*FlowMeasureArg) ProtoMessage()

func (*FlowMeasureArg) ProtoReflect 

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

func (*FlowMeasureArg) Reset 

func (x *FlowMeasureArg) Reset()

func (*FlowMeasureArg) String 

func (x *FlowMeasureArg) String() string

type FlowMeasureCommandReadArg 

type FlowMeasureCommandReadArg struct {
	Clear              bool      `protobuf:"varint,1,opt,name=clear,proto3" json:"clear,omitempty"`                                                             // If true, the data will be all cleared after read
	LatencyPercentiles []float64 `protobuf:"fixed64,2,rep,packed,name=latency_percentiles,json=latencyPercentiles,proto3" json:"latency_percentiles,omitempty"` /// ascending list of real numbers in [0.0, 100.0]
	JitterPercentiles  []float64 `protobuf:"fixed64,3,rep,packed,name=jitter_percentiles,json=jitterPercentiles,proto3" json:"jitter_percentiles,omitempty"`    /// ascending list of real numbers in [0.0, 100.0]
	// contains filtered or unexported fields
}

func (*FlowMeasureCommandReadArg) Descriptor deprecated 

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

Deprecated: Use FlowMeasureCommandReadArg.ProtoReflect.Descriptor instead.

func (*FlowMeasureCommandReadArg) GetClear 

func (x *FlowMeasureCommandReadArg) GetClear() bool

func (*FlowMeasureCommandReadArg) GetJitterPercentiles 

func (x *FlowMeasureCommandReadArg) GetJitterPercentiles() []float64

func (*FlowMeasureCommandReadArg) GetLatencyPercentiles 

func (x *FlowMeasureCommandReadArg) GetLatencyPercentiles() []float64

func (*FlowMeasureCommandReadArg) ProtoMessage 

func (*FlowMeasureCommandReadArg) ProtoMessage()

func (*FlowMeasureCommandReadArg) ProtoReflect 

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

func (*FlowMeasureCommandReadArg) Reset 

func (x *FlowMeasureCommandReadArg) Reset()

func (*FlowMeasureCommandReadArg) String 

func (x *FlowMeasureCommandReadArg) String() string

type FlowMeasureReadResponse 

type FlowMeasureReadResponse struct {
	Statistics []*FlowMeasureReadResponse_Statistic `protobuf:"bytes,1,rep,name=statistics,proto3" json:"statistics,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowMeasureReadResponse) Descriptor deprecated 

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

Deprecated: Use FlowMeasureReadResponse.ProtoReflect.Descriptor instead.

func (*FlowMeasureReadResponse) GetStatistics 

func (x *FlowMeasureReadResponse) GetStatistics() []*FlowMeasureReadResponse_Statistic

func (*FlowMeasureReadResponse) ProtoMessage 

func (*FlowMeasureReadResponse) ProtoMessage()

func (*FlowMeasureReadResponse) ProtoReflect 

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

func (*FlowMeasureReadResponse) Reset 

func (x *FlowMeasureReadResponse) Reset()

func (*FlowMeasureReadResponse) String 

func (x *FlowMeasureReadResponse) String() string

type FlowMeasureReadResponse_Statistic 

type FlowMeasureReadResponse_Statistic struct {
	Fseid        uint64                                       `protobuf:"varint,1,opt,name=fseid,proto3" json:"fseid,omitempty"`
	Pdr          uint64                                       `protobuf:"varint,2,opt,name=pdr,proto3" json:"pdr,omitempty"`
	Latency      *FlowMeasureReadResponse_Statistic_Histogram `protobuf:"bytes,3,opt,name=latency,proto3" json:"latency,omitempty"`
	Jitter       *FlowMeasureReadResponse_Statistic_Histogram `protobuf:"bytes,4,opt,name=jitter,proto3" json:"jitter,omitempty"`
	TotalBytes   uint64                                       `protobuf:"varint,11,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	TotalPackets uint64                                       `protobuf:"varint,12,opt,name=total_packets,json=totalPackets,proto3" json:"total_packets,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowMeasureReadResponse_Statistic) Descriptor deprecated 

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

Deprecated: Use FlowMeasureReadResponse_Statistic.ProtoReflect.Descriptor instead.

func (*FlowMeasureReadResponse_Statistic) GetFseid 

func (x *FlowMeasureReadResponse_Statistic) GetFseid() uint64

func (*FlowMeasureReadResponse_Statistic) GetJitter 

func (x *FlowMeasureReadResponse_Statistic) GetJitter() *FlowMeasureReadResponse_Statistic_Histogram

func (*FlowMeasureReadResponse_Statistic) GetLatency 

func (x *FlowMeasureReadResponse_Statistic) GetLatency() *FlowMeasureReadResponse_Statistic_Histogram

func (*FlowMeasureReadResponse_Statistic) GetPdr 

func (x *FlowMeasureReadResponse_Statistic) GetPdr() uint64

func (*FlowMeasureReadResponse_Statistic) GetTotalBytes 

func (x *FlowMeasureReadResponse_Statistic) GetTotalBytes() uint64

func (*FlowMeasureReadResponse_Statistic) GetTotalPackets 

func (x *FlowMeasureReadResponse_Statistic) GetTotalPackets() uint64

func (*FlowMeasureReadResponse_Statistic) ProtoMessage 

func (*FlowMeasureReadResponse_Statistic) ProtoMessage()

func (*FlowMeasureReadResponse_Statistic) ProtoReflect 

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

func (*FlowMeasureReadResponse_Statistic) Reset 

func (x *FlowMeasureReadResponse_Statistic) Reset()

func (*FlowMeasureReadResponse_Statistic) String 

func (x *FlowMeasureReadResponse_Statistic) String() string

type FlowMeasureReadResponse_Statistic_Histogram 

type FlowMeasureReadResponse_Statistic_Histogram struct {
	Count              uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`                                   /// Total # of measured data points, including above_range
	AboveRange         uint64   `protobuf:"varint,2,opt,name=above_range,json=aboveRange,proto3" json:"above_range,omitempty"`       /// # of data points for the "too large value" bucket
	ResolutionNs       uint64   `protobuf:"varint,8,opt,name=resolution_ns,json=resolutionNs,proto3" json:"resolution_ns,omitempty"` /// resolution of measured data
	MinNs              uint64   `protobuf:"varint,3,opt,name=min_ns,json=minNs,proto3" json:"min_ns,omitempty"`
	AvgNs              uint64   `protobuf:"varint,4,opt,name=avg_ns,json=avgNs,proto3" json:"avg_ns,omitempty"`
	MaxNs              uint64   `protobuf:"varint,5,opt,name=max_ns,json=maxNs,proto3" json:"max_ns,omitempty"`
	TotalNs            uint64   `protobuf:"varint,6,opt,name=total_ns,json=totalNs,proto3" json:"total_ns,omitempty"`
	PercentileValuesNs []uint64 `protobuf:"varint,7,rep,packed,name=percentile_values_ns,json=percentileValuesNs,proto3" json:"percentile_values_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowMeasureReadResponse_Statistic_Histogram) Descriptor deprecated 

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

Deprecated: Use FlowMeasureReadResponse_Statistic_Histogram.ProtoReflect.Descriptor instead.

func (*FlowMeasureReadResponse_Statistic_Histogram) GetAboveRange 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetAboveRange() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetAvgNs 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetAvgNs() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetCount 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetCount() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetMaxNs 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetMaxNs() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetMinNs 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetMinNs() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetPercentileValuesNs 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetPercentileValuesNs() []uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetResolutionNs 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetResolutionNs() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) GetTotalNs 

func (x *FlowMeasureReadResponse_Statistic_Histogram) GetTotalNs() uint64

func (*FlowMeasureReadResponse_Statistic_Histogram) ProtoMessage 

func (*FlowMeasureReadResponse_Statistic_Histogram) ProtoMessage()

func (*FlowMeasureReadResponse_Statistic_Histogram) ProtoReflect 

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

func (*FlowMeasureReadResponse_Statistic_Histogram) Reset 

func (x *FlowMeasureReadResponse_Statistic_Histogram) Reset()

func (*FlowMeasureReadResponse_Statistic_Histogram) String 

func (x *FlowMeasureReadResponse_Statistic_Histogram) String() string

type GateHookCommandRequest 

type GateHookCommandRequest struct {
	Hook *GateHookInfo `protobuf:"bytes,1,opt,name=hook,proto3" json:"hook,omitempty"` // N.B.: this includes the command argument
	Cmd  string        `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*GateHookCommandRequest) Descriptor deprecated 

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

Deprecated: Use GateHookCommandRequest.ProtoReflect.Descriptor instead.

func (*GateHookCommandRequest) GetCmd 

func (x *GateHookCommandRequest) GetCmd() string

func (*GateHookCommandRequest) GetHook 

func (x *GateHookCommandRequest) GetHook() *GateHookInfo

func (*GateHookCommandRequest) ProtoMessage 

func (*GateHookCommandRequest) ProtoMessage()

func (*GateHookCommandRequest) ProtoReflect 

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

func (*GateHookCommandRequest) Reset 

func (x *GateHookCommandRequest) Reset()

func (*GateHookCommandRequest) String 

func (x *GateHookCommandRequest) String() string

type GateHookInfo 

type GateHookInfo struct {
	ClassName  string `protobuf:"bytes,1,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"`    /// Name of the hook class
	HookName   string `protobuf:"bytes,2,opt,name=hook_name,json=hookName,proto3" json:"hook_name,omitempty"`       /// Name of the hook
	ModuleName string `protobuf:"bytes,3,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"` /// Name of module
	// Types that are assignable to Gate:
	//	*GateHookInfo_Igate
	//	*GateHookInfo_Ogate
	Gate isGateHookInfo_Gate `protobuf_oneof:"gate"`
	Arg  *any.Any            `protobuf:"bytes,6,opt,name=arg,proto3" json:"arg,omitempty"` /// Hook-specific arguments
	// contains filtered or unexported fields
}

func (*GateHookInfo) Descriptor deprecated 

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

Deprecated: Use GateHookInfo.ProtoReflect.Descriptor instead.

func (*GateHookInfo) GetArg 

func (x *GateHookInfo) GetArg() *any.Any

func (*GateHookInfo) GetClassName 

func (x *GateHookInfo) GetClassName() string

func (*GateHookInfo) GetGate 

func (m *GateHookInfo) GetGate() isGateHookInfo_Gate

func (*GateHookInfo) GetHookName 

func (x *GateHookInfo) GetHookName() string

func (*GateHookInfo) GetIgate 

func (x *GateHookInfo) GetIgate() int64

func (*GateHookInfo) GetModuleName 

func (x *GateHookInfo) GetModuleName() string

func (*GateHookInfo) GetOgate 

func (x *GateHookInfo) GetOgate() int64

func (*GateHookInfo) ProtoMessage 

func (*GateHookInfo) ProtoMessage()

func (*GateHookInfo) ProtoReflect 

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

func (*GateHookInfo) Reset 

func (x *GateHookInfo) Reset()

func (*GateHookInfo) String 

func (x *GateHookInfo) String() string

type GateHookInfo_Igate 

type GateHookInfo_Igate struct {
	Igate int64 `protobuf:"varint,4,opt,name=igate,proto3,oneof"` /// Input gate index. All input gates if -1
}

type GateHookInfo_Ogate 

type GateHookInfo_Ogate struct {
	Ogate int64 `protobuf:"varint,5,opt,name=ogate,proto3,oneof"` /// Output gate index. All output gates if -1
}

type GenericDecapArg 

type GenericDecapArg struct {
	Bytes uint64 `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"` /// The number of bytes to strip off.
	// contains filtered or unexported fields
}

* The GenericDecap module strips off the first few bytes of data from a packet.

__Input Gates__: 1 __Ouptut Gates__: 1

func (*GenericDecapArg) Descriptor deprecated 

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

Deprecated: Use GenericDecapArg.ProtoReflect.Descriptor instead.

func (*GenericDecapArg) GetBytes 

func (x *GenericDecapArg) GetBytes() uint64

func (*GenericDecapArg) ProtoMessage 

func (*GenericDecapArg) ProtoMessage()

func (*GenericDecapArg) ProtoReflect 

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

func (*GenericDecapArg) Reset 

func (x *GenericDecapArg) Reset()

func (*GenericDecapArg) String 

func (x *GenericDecapArg) String() string

type GenericEncapArg 

type GenericEncapArg struct {
	Fields []*GenericEncapArg_EncapField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

* The GenericEncap module adds a header to packets passing through it. Takes a list of fields. Each field is either:

  1. {'size': X, 'value': Y} (for constant values)
  2. {'size': X, 'attribute': Y} (for metadata attributes)

e.g.: `GenericEncap([{'size': 4, 'value': 0xdeadbeef}, 

{'size': 2, 'attribute': 'foo'},
{'size': 2, 'value': 0x1234}])`

will prepend a 8-byte header: 

`de ad be ef <xx> <xx> 12 34`

where the 2-byte `<xx> <xx>` comes from the value of metadata attribute `'foo'` for each packet. An example script using GenericEncap is in [`bess/bessctl/conf/samples/generic_encap.bess`](https://github.com/NetSys/bess/blob/master/bessctl/conf/samples/generic_encap.bess).

__Input Gates__: 1 __Output Gates__: 1

func (*GenericEncapArg) Descriptor deprecated 

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

Deprecated: Use GenericEncapArg.ProtoReflect.Descriptor instead.

func (*GenericEncapArg) GetFields 

func (x *GenericEncapArg) GetFields() []*GenericEncapArg_EncapField

func (*GenericEncapArg) ProtoMessage 

func (*GenericEncapArg) ProtoMessage()

func (*GenericEncapArg) ProtoReflect 

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

func (*GenericEncapArg) Reset 

func (x *GenericEncapArg) Reset()

func (*GenericEncapArg) String 

func (x *GenericEncapArg) String() string

type GenericEncapArg_EncapField 

type GenericEncapArg_EncapField struct {
	Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` /// The length of the field.
	// Types that are assignable to Insertion:
	//	*GenericEncapArg_EncapField_Attribute
	//	*GenericEncapArg_EncapField_Value
	Insertion isGenericEncapArg_EncapField_Insertion `protobuf_oneof:"insertion"`
	// contains filtered or unexported fields
}

* An EncapField represents one field in the new packet header.

func (*GenericEncapArg_EncapField) Descriptor deprecated 

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

Deprecated: Use GenericEncapArg_EncapField.ProtoReflect.Descriptor instead.

func (*GenericEncapArg_EncapField) GetAttribute 

func (x *GenericEncapArg_EncapField) GetAttribute() string

func (*GenericEncapArg_EncapField) GetInsertion 

func (m *GenericEncapArg_EncapField) GetInsertion() isGenericEncapArg_EncapField_Insertion

func (*GenericEncapArg_EncapField) GetSize 

func (x *GenericEncapArg_EncapField) GetSize() uint64

func (*GenericEncapArg_EncapField) GetValue 

func (x *GenericEncapArg_EncapField) GetValue() *FieldData

func (*GenericEncapArg_EncapField) ProtoMessage 

func (*GenericEncapArg_EncapField) ProtoMessage()

func (*GenericEncapArg_EncapField) ProtoReflect 

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

func (*GenericEncapArg_EncapField) Reset 

func (x *GenericEncapArg_EncapField) Reset()

func (*GenericEncapArg_EncapField) String 

func (x *GenericEncapArg_EncapField) String() string

type GenericEncapArg_EncapField_Attribute 

type GenericEncapArg_EncapField_Attribute struct {
	Attribute string `protobuf:"bytes,2,opt,name=attribute,proto3,oneof"` /// The metadata attribute name to pull the field value from
}

type GenericEncapArg_EncapField_Value 

type GenericEncapArg_EncapField_Value struct {
	Value *FieldData `protobuf:"bytes,3,opt,name=value,proto3,oneof"` /// Or, the fixed value to insert into the packet.
}

type GetDriverInfoRequest 

type GetDriverInfoRequest struct {
	DriverName string `protobuf:"bytes,1,opt,name=driver_name,json=driverName,proto3" json:"driver_name,omitempty"` /// Name of port driver
	// contains filtered or unexported fields
}

func (*GetDriverInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetDriverInfoRequest.ProtoReflect.Descriptor instead.

func (*GetDriverInfoRequest) GetDriverName 

func (x *GetDriverInfoRequest) GetDriverName() string

func (*GetDriverInfoRequest) ProtoMessage 

func (*GetDriverInfoRequest) ProtoMessage()

func (*GetDriverInfoRequest) ProtoReflect 

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

func (*GetDriverInfoRequest) Reset 

func (x *GetDriverInfoRequest) Reset()

func (*GetDriverInfoRequest) String 

func (x *GetDriverInfoRequest) String() string

type GetDriverInfoResponse 

type GetDriverInfoResponse struct {
	Error    *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name     string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`         /// Name of port driver
	Help     string   `protobuf:"bytes,3,opt,name=help,proto3" json:"help,omitempty"`         /// 1-line description of the driver
	Commands []string `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"` /// List of supported commands (TODO)
	// contains filtered or unexported fields
}

func (*GetDriverInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetDriverInfoResponse.ProtoReflect.Descriptor instead.

func (*GetDriverInfoResponse) GetCommands 

func (x *GetDriverInfoResponse) GetCommands() []string

func (*GetDriverInfoResponse) GetError 

func (x *GetDriverInfoResponse) GetError() *Error

func (*GetDriverInfoResponse) GetHelp 

func (x *GetDriverInfoResponse) GetHelp() string

func (*GetDriverInfoResponse) GetName 

func (x *GetDriverInfoResponse) GetName() string

func (*GetDriverInfoResponse) ProtoMessage 

func (*GetDriverInfoResponse) ProtoMessage()

func (*GetDriverInfoResponse) ProtoReflect 

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

func (*GetDriverInfoResponse) Reset 

func (x *GetDriverInfoResponse) Reset()

func (*GetDriverInfoResponse) String 

func (x *GetDriverInfoResponse) String() string

type GetGateHookClassInfoRequest 

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

func (*GetGateHookClassInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetGateHookClassInfoRequest.ProtoReflect.Descriptor instead.

func (*GetGateHookClassInfoRequest) GetName 

func (x *GetGateHookClassInfoRequest) GetName() string

func (*GetGateHookClassInfoRequest) ProtoMessage 

func (*GetGateHookClassInfoRequest) ProtoMessage()

func (*GetGateHookClassInfoRequest) ProtoReflect 

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

func (*GetGateHookClassInfoRequest) Reset 

func (x *GetGateHookClassInfoRequest) Reset()

func (*GetGateHookClassInfoRequest) String 

func (x *GetGateHookClassInfoRequest) String() string

type GetGateHookClassInfoResponse 

type GetGateHookClassInfoResponse struct {
	Error   *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                      /// Name of gatehook type
	Help    string   `protobuf:"bytes,3,opt,name=help,proto3" json:"help,omitempty"`                      /// 1=line description of the gatehook type
	Cmds    []string `protobuf:"bytes,4,rep,name=cmds,proto3" json:"cmds,omitempty"`                      /// List of commands supported by the gatehook
	CmdArgs []string `protobuf:"bytes,5,rep,name=cmd_args,json=cmdArgs,proto3" json:"cmd_args,omitempty"` /// Corresponding Protobuf message types
	// contains filtered or unexported fields
}

func (*GetGateHookClassInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetGateHookClassInfoResponse.ProtoReflect.Descriptor instead.

func (*GetGateHookClassInfoResponse) GetCmdArgs 

func (x *GetGateHookClassInfoResponse) GetCmdArgs() []string

func (*GetGateHookClassInfoResponse) GetCmds 

func (x *GetGateHookClassInfoResponse) GetCmds() []string

func (*GetGateHookClassInfoResponse) GetError 

func (x *GetGateHookClassInfoResponse) GetError() *Error

func (*GetGateHookClassInfoResponse) GetHelp 

func (x *GetGateHookClassInfoResponse) GetHelp() string

func (*GetGateHookClassInfoResponse) GetName 

func (x *GetGateHookClassInfoResponse) GetName() string

func (*GetGateHookClassInfoResponse) ProtoMessage 

func (*GetGateHookClassInfoResponse) ProtoMessage()

func (*GetGateHookClassInfoResponse) ProtoReflect 

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

func (*GetGateHookClassInfoResponse) Reset 

func (x *GetGateHookClassInfoResponse) Reset()

func (*GetGateHookClassInfoResponse) String 

func (x *GetGateHookClassInfoResponse) String() string

type GetLinkStatusRequest 

type GetLinkStatusRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` /// name of the port to query
	// contains filtered or unexported fields
}

func (*GetLinkStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetLinkStatusRequest.ProtoReflect.Descriptor instead.

func (*GetLinkStatusRequest) GetName 

func (x *GetLinkStatusRequest) GetName() string

func (*GetLinkStatusRequest) ProtoMessage 

func (*GetLinkStatusRequest) ProtoMessage()

func (*GetLinkStatusRequest) ProtoReflect 

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

func (*GetLinkStatusRequest) Reset 

func (x *GetLinkStatusRequest) Reset()

func (*GetLinkStatusRequest) String 

func (x *GetLinkStatusRequest) String() string

type GetLinkStatusResponse 

type GetLinkStatusResponse struct {
	Error      *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Speed      uint32 `protobuf:"varint,2,opt,name=speed,proto3" json:"speed,omitempty"`                             /// speed in mbps: 1000, 40000, etc. 0 for vports
	FullDuplex bool   `protobuf:"varint,3,opt,name=full_duplex,json=fullDuplex,proto3" json:"full_duplex,omitempty"` /// full-duplex enabled?
	Autoneg    bool   `protobuf:"varint,4,opt,name=autoneg,proto3" json:"autoneg,omitempty"`                         /// auto-negotiated speed and duplex?
	LinkUp     bool   `protobuf:"varint,5,opt,name=link_up,json=linkUp,proto3" json:"link_up,omitempty"`             /// link up?
	// contains filtered or unexported fields
}

func (*GetLinkStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetLinkStatusResponse.ProtoReflect.Descriptor instead.

func (*GetLinkStatusResponse) GetAutoneg 

func (x *GetLinkStatusResponse) GetAutoneg() bool

func (*GetLinkStatusResponse) GetError 

func (x *GetLinkStatusResponse) GetError() *Error

func (*GetLinkStatusResponse) GetFullDuplex 

func (x *GetLinkStatusResponse) GetFullDuplex() bool

func (*GetLinkStatusResponse) GetLinkUp 

func (x *GetLinkStatusResponse) GetLinkUp() bool

func (*GetLinkStatusResponse) GetSpeed 

func (x *GetLinkStatusResponse) GetSpeed() uint32

func (*GetLinkStatusResponse) ProtoMessage 

func (*GetLinkStatusResponse) ProtoMessage()

func (*GetLinkStatusResponse) ProtoReflect 

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

func (*GetLinkStatusResponse) Reset 

func (x *GetLinkStatusResponse) Reset()

func (*GetLinkStatusResponse) String 

func (x *GetLinkStatusResponse) String() string

type GetMclassInfoRequest 

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

func (*GetMclassInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetMclassInfoRequest.ProtoReflect.Descriptor instead.

func (*GetMclassInfoRequest) GetName 

func (x *GetMclassInfoRequest) GetName() string

func (*GetMclassInfoRequest) ProtoMessage 

func (*GetMclassInfoRequest) ProtoMessage()

func (*GetMclassInfoRequest) ProtoReflect 

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

func (*GetMclassInfoRequest) Reset 

func (x *GetMclassInfoRequest) Reset()

func (*GetMclassInfoRequest) String 

func (x *GetMclassInfoRequest) String() string

type GetMclassInfoResponse 

type GetMclassInfoResponse struct {
	Error   *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name    string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                      /// Name of module type
	Help    string   `protobuf:"bytes,3,opt,name=help,proto3" json:"help,omitempty"`                      /// 1=line description of the module type
	Cmds    []string `protobuf:"bytes,4,rep,name=cmds,proto3" json:"cmds,omitempty"`                      /// List of commands supported by the module
	CmdArgs []string `protobuf:"bytes,5,rep,name=cmd_args,json=cmdArgs,proto3" json:"cmd_args,omitempty"` /// Corresponding Protobuf message types
	// contains filtered or unexported fields
}

func (*GetMclassInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetMclassInfoResponse.ProtoReflect.Descriptor instead.

func (*GetMclassInfoResponse) GetCmdArgs 

func (x *GetMclassInfoResponse) GetCmdArgs() []string

func (*GetMclassInfoResponse) GetCmds 

func (x *GetMclassInfoResponse) GetCmds() []string

func (*GetMclassInfoResponse) GetError 

func (x *GetMclassInfoResponse) GetError() *Error

func (*GetMclassInfoResponse) GetHelp 

func (x *GetMclassInfoResponse) GetHelp() string

func (*GetMclassInfoResponse) GetName 

func (x *GetMclassInfoResponse) GetName() string

func (*GetMclassInfoResponse) ProtoMessage 

func (*GetMclassInfoResponse) ProtoMessage()

func (*GetMclassInfoResponse) ProtoReflect 

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

func (*GetMclassInfoResponse) Reset 

func (x *GetMclassInfoResponse) Reset()

func (*GetMclassInfoResponse) String 

func (x *GetMclassInfoResponse) String() string

type GetModuleInfoRequest 

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

func (*GetModuleInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoRequest.ProtoReflect.Descriptor instead.

func (*GetModuleInfoRequest) GetName 

func (x *GetModuleInfoRequest) GetName() string

func (*GetModuleInfoRequest) ProtoMessage 

func (*GetModuleInfoRequest) ProtoMessage()

func (*GetModuleInfoRequest) ProtoReflect 

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

func (*GetModuleInfoRequest) Reset 

func (x *GetModuleInfoRequest) Reset()

func (*GetModuleInfoRequest) String 

func (x *GetModuleInfoRequest) String() string

type GetModuleInfoResponse 

type GetModuleInfoResponse struct {
	Error    *Error                             `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Name     string                             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`          /// Name of module
	Mclass   string                             `protobuf:"bytes,3,opt,name=mclass,proto3" json:"mclass,omitempty"`      /// Module type
	Desc     string                             `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`          /// Current status of module as a short, 1-line string
	Igates   []*GetModuleInfoResponse_IGate     `protobuf:"bytes,6,rep,name=igates,proto3" json:"igates,omitempty"`      /// List of connected input gates
	Ogates   []*GetModuleInfoResponse_OGate     `protobuf:"bytes,7,rep,name=ogates,proto3" json:"ogates,omitempty"`      /// List of connected output gates
	Metadata []*GetModuleInfoResponse_Attribute `protobuf:"bytes,8,rep,name=metadata,proto3" json:"metadata,omitempty"`  /// List of metadata used by the module
	Deadends uint64                             `protobuf:"varint,9,opt,name=deadends,proto3" json:"deadends,omitempty"` /// Number of packets deadended or explicitly dropped by this module
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse) GetDeadends 

func (x *GetModuleInfoResponse) GetDeadends() uint64

func (*GetModuleInfoResponse) GetDesc 

func (x *GetModuleInfoResponse) GetDesc() string

func (*GetModuleInfoResponse) GetError 

func (x *GetModuleInfoResponse) GetError() *Error

func (*GetModuleInfoResponse) GetIgates 

func (x *GetModuleInfoResponse) GetIgates() []*GetModuleInfoResponse_IGate

func (*GetModuleInfoResponse) GetMclass 

func (x *GetModuleInfoResponse) GetMclass() string

func (*GetModuleInfoResponse) GetMetadata 

func (x *GetModuleInfoResponse) GetMetadata() []*GetModuleInfoResponse_Attribute

func (*GetModuleInfoResponse) GetName 

func (x *GetModuleInfoResponse) GetName() string

func (*GetModuleInfoResponse) GetOgates 

func (x *GetModuleInfoResponse) GetOgates() []*GetModuleInfoResponse_OGate

func (*GetModuleInfoResponse) ProtoMessage 

func (*GetModuleInfoResponse) ProtoMessage()

func (*GetModuleInfoResponse) ProtoReflect 

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

func (*GetModuleInfoResponse) Reset 

func (x *GetModuleInfoResponse) Reset()

func (*GetModuleInfoResponse) String 

func (x *GetModuleInfoResponse) String() string

type GetModuleInfoResponse_Attribute 

type GetModuleInfoResponse_Attribute struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`      /// Name of per-packet metadata attribute
	Size   uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`     /// Size of attribute (in bytes)
	Mode   string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"`      /// "read", "write", or "update"
	Offset int64  `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` /// (internal debugging purpose only)
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse_Attribute) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse_Attribute.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse_Attribute) GetMode 

func (x *GetModuleInfoResponse_Attribute) GetMode() string

func (*GetModuleInfoResponse_Attribute) GetName 

func (x *GetModuleInfoResponse_Attribute) GetName() string

func (*GetModuleInfoResponse_Attribute) GetOffset 

func (x *GetModuleInfoResponse_Attribute) GetOffset() int64

func (*GetModuleInfoResponse_Attribute) GetSize 

func (x *GetModuleInfoResponse_Attribute) GetSize() uint64

func (*GetModuleInfoResponse_Attribute) ProtoMessage 

func (*GetModuleInfoResponse_Attribute) ProtoMessage()

func (*GetModuleInfoResponse_Attribute) ProtoReflect 

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

func (*GetModuleInfoResponse_Attribute) Reset 

func (x *GetModuleInfoResponse_Attribute) Reset()

func (*GetModuleInfoResponse_Attribute) String 

func (x *GetModuleInfoResponse_Attribute) String() string

type GetModuleInfoResponse_GateHook 

type GetModuleInfoResponse_GateHook struct {
	ClassName string `protobuf:"bytes,1,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"` /// gate hook class_name and
	HookName  string `protobuf:"bytes,2,opt,name=hook_name,json=hookName,proto3" json:"hook_name,omitempty"`    /// gate hook name
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse_GateHook) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse_GateHook.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse_GateHook) GetClassName 

func (x *GetModuleInfoResponse_GateHook) GetClassName() string

func (*GetModuleInfoResponse_GateHook) GetHookName 

func (x *GetModuleInfoResponse_GateHook) GetHookName() string

func (*GetModuleInfoResponse_GateHook) ProtoMessage 

func (*GetModuleInfoResponse_GateHook) ProtoMessage()

func (*GetModuleInfoResponse_GateHook) ProtoReflect 

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

func (*GetModuleInfoResponse_GateHook) Reset 

func (x *GetModuleInfoResponse_GateHook) Reset()

func (*GetModuleInfoResponse_GateHook) String 

func (x *GetModuleInfoResponse_GateHook) String() string

type GetModuleInfoResponse_IGate 

type GetModuleInfoResponse_IGate struct {
	Igate     uint64                               `protobuf:"varint,1,opt,name=igate,proto3" json:"igate,omitempty"`          /// Input gate ID
	Ogates    []*GetModuleInfoResponse_IGate_OGate `protobuf:"bytes,2,rep,name=ogates,proto3" json:"ogates,omitempty"`         /// The list of upstream output gates
	Cnt       uint64                               `protobuf:"varint,3,opt,name=cnt,proto3" json:"cnt,omitempty"`              /// # of packet batches seen
	Pkts      uint64                               `protobuf:"varint,4,opt,name=pkts,proto3" json:"pkts,omitempty"`            /// # of packets seen
	Bytes     uint64                               `protobuf:"varint,5,opt,name=bytes,proto3" json:"bytes,omitempty"`          /// # of bytes seen
	Timestamp float64                              `protobuf:"fixed64,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` /// The time that cnt/pkts counters were read
	Gatehooks []*GetModuleInfoResponse_GateHook    `protobuf:"bytes,8,rep,name=gatehooks,proto3" json:"gatehooks,omitempty"`   /// List of gate hook
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse_IGate) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse_IGate.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse_IGate) GetBytes 

func (x *GetModuleInfoResponse_IGate) GetBytes() uint64

func (*GetModuleInfoResponse_IGate) GetCnt 

func (x *GetModuleInfoResponse_IGate) GetCnt() uint64

func (*GetModuleInfoResponse_IGate) GetGatehooks 

func (x *GetModuleInfoResponse_IGate) GetGatehooks() []*GetModuleInfoResponse_GateHook

func (*GetModuleInfoResponse_IGate) GetIgate 

func (x *GetModuleInfoResponse_IGate) GetIgate() uint64

func (*GetModuleInfoResponse_IGate) GetOgates 

func (x *GetModuleInfoResponse_IGate) GetOgates() []*GetModuleInfoResponse_IGate_OGate

func (*GetModuleInfoResponse_IGate) GetPkts 

func (x *GetModuleInfoResponse_IGate) GetPkts() uint64

func (*GetModuleInfoResponse_IGate) GetTimestamp 

func (x *GetModuleInfoResponse_IGate) GetTimestamp() float64

func (*GetModuleInfoResponse_IGate) ProtoMessage 

func (*GetModuleInfoResponse_IGate) ProtoMessage()

func (*GetModuleInfoResponse_IGate) ProtoReflect 

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

func (*GetModuleInfoResponse_IGate) Reset 

func (x *GetModuleInfoResponse_IGate) Reset()

func (*GetModuleInfoResponse_IGate) String 

func (x *GetModuleInfoResponse_IGate) String() string

type GetModuleInfoResponse_IGate_OGate 

type GetModuleInfoResponse_IGate_OGate struct {
	Ogate uint64 `protobuf:"varint,1,opt,name=ogate,proto3" json:"ogate,omitempty"` /// Output gate of "previous" module
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`    /// Name of "previous" module
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse_IGate_OGate) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse_IGate_OGate.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse_IGate_OGate) GetName 

func (x *GetModuleInfoResponse_IGate_OGate) GetName() string

func (*GetModuleInfoResponse_IGate_OGate) GetOgate 

func (x *GetModuleInfoResponse_IGate_OGate) GetOgate() uint64

func (*GetModuleInfoResponse_IGate_OGate) ProtoMessage 

func (*GetModuleInfoResponse_IGate_OGate) ProtoMessage()

func (*GetModuleInfoResponse_IGate_OGate) ProtoReflect 

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

func (*GetModuleInfoResponse_IGate_OGate) Reset 

func (x *GetModuleInfoResponse_IGate_OGate) Reset()

func (*GetModuleInfoResponse_IGate_OGate) String 

func (x *GetModuleInfoResponse_IGate_OGate) String() string

type GetModuleInfoResponse_OGate 

type GetModuleInfoResponse_OGate struct {
	Ogate     uint64                            `protobuf:"varint,1,opt,name=ogate,proto3" json:"ogate,omitempty"`          /// Output gate ID
	Cnt       uint64                            `protobuf:"varint,2,opt,name=cnt,proto3" json:"cnt,omitempty"`              /// # of packet batches seen
	Pkts      uint64                            `protobuf:"varint,3,opt,name=pkts,proto3" json:"pkts,omitempty"`            /// # of packets seen
	Bytes     uint64                            `protobuf:"varint,4,opt,name=bytes,proto3" json:"bytes,omitempty"`          /// # of bytes seen
	Timestamp float64                           `protobuf:"fixed64,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` /// The time thatcnt/pkts counters were read
	Name      string                            `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`             /// Name of the "next" module it connects to
	Igate     uint64                            `protobuf:"varint,7,opt,name=igate,proto3" json:"igate,omitempty"`          /// Input gate ID of the "next" module
	Gatehooks []*GetModuleInfoResponse_GateHook `protobuf:"bytes,9,rep,name=gatehooks,proto3" json:"gatehooks,omitempty"`   /// List of gate hook
	// contains filtered or unexported fields
}

func (*GetModuleInfoResponse_OGate) Descriptor deprecated 

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

Deprecated: Use GetModuleInfoResponse_OGate.ProtoReflect.Descriptor instead.

func (*GetModuleInfoResponse_OGate) GetBytes 

func (x *GetModuleInfoResponse_OGate) GetBytes() uint64

func (*GetModuleInfoResponse_OGate) GetCnt 

func (x *GetModuleInfoResponse_OGate) GetCnt() uint64

func (*GetModuleInfoResponse_OGate) GetGatehooks 

func (x *GetModuleInfoResponse_OGate) GetGatehooks() []*GetModuleInfoResponse_GateHook

func (*GetModuleInfoResponse_OGate) GetIgate 

func (x *GetModuleInfoResponse_OGate) GetIgate() uint64

func (*GetModuleInfoResponse_OGate) GetName 

func (x *GetModuleInfoResponse_OGate) GetName() string

func (*GetModuleInfoResponse_OGate) GetOgate 

func (x *GetModuleInfoResponse_OGate) GetOgate() uint64

func (*GetModuleInfoResponse_OGate) GetPkts 

func (x *GetModuleInfoResponse_OGate) GetPkts() uint64

func (*GetModuleInfoResponse_OGate) GetTimestamp 

func (x *GetModuleInfoResponse_OGate) GetTimestamp() float64

func (*GetModuleInfoResponse_OGate) ProtoMessage 

func (*GetModuleInfoResponse_OGate) ProtoMessage()

func (*GetModuleInfoResponse_OGate) ProtoReflect 

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

func (*GetModuleInfoResponse_OGate) Reset 

func (x *GetModuleInfoResponse_OGate) Reset()

func (*GetModuleInfoResponse_OGate) String 

func (x *GetModuleInfoResponse_OGate) String() string

type GetPortConfRequest 

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

func (*GetPortConfRequest) Descriptor deprecated 

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

Deprecated: Use GetPortConfRequest.ProtoReflect.Descriptor instead.

func (*GetPortConfRequest) GetName 

func (x *GetPortConfRequest) GetName() string

func (*GetPortConfRequest) ProtoMessage 

func (*GetPortConfRequest) ProtoMessage()

func (*GetPortConfRequest) ProtoReflect 

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

func (*GetPortConfRequest) Reset 

func (x *GetPortConfRequest) Reset()

func (*GetPortConfRequest) String 

func (x *GetPortConfRequest) String() string

type GetPortConfResponse 

type GetPortConfResponse struct {
	Error *Error    `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Conf  *PortConf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPortConfResponse) Descriptor deprecated 

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

Deprecated: Use GetPortConfResponse.ProtoReflect.Descriptor instead.

func (*GetPortConfResponse) GetConf 

func (x *GetPortConfResponse) GetConf() *PortConf

func (*GetPortConfResponse) GetError 

func (x *GetPortConfResponse) GetError() *Error

func (*GetPortConfResponse) ProtoMessage 

func (*GetPortConfResponse) ProtoMessage()

func (*GetPortConfResponse) ProtoReflect 

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

func (*GetPortConfResponse) Reset 

func (x *GetPortConfResponse) Reset()

func (*GetPortConfResponse) String 

func (x *GetPortConfResponse) String() string

type GetPortStatsRequest 

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

func (*GetPortStatsRequest) Descriptor deprecated 

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

Deprecated: Use GetPortStatsRequest.ProtoReflect.Descriptor instead.

func (*GetPortStatsRequest) GetName 

func (x *GetPortStatsRequest) GetName() string

func (*GetPortStatsRequest) ProtoMessage 

func (*GetPortStatsRequest) ProtoMessage()

func (*GetPortStatsRequest) ProtoReflect 

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

func (*GetPortStatsRequest) Reset 

func (x *GetPortStatsRequest) Reset()

func (*GetPortStatsRequest) String 

func (x *GetPortStatsRequest) String() string

type GetPortStatsResponse 

type GetPortStatsResponse struct {
	Error     *Error                     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Inc       *GetPortStatsResponse_Stat `protobuf:"bytes,2,opt,name=inc,proto3" json:"inc,omitempty"`               /// Port stats for incoming (Ext -> BESS) direction.
	Out       *GetPortStatsResponse_Stat `protobuf:"bytes,3,opt,name=out,proto3" json:"out,omitempty"`               /// Port stats for outgoing (BESS -> Ext) direction.
	Timestamp float64                    `protobuf:"fixed64,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` /// Time that stat counters were read.
	// contains filtered or unexported fields
}

func (*GetPortStatsResponse) Descriptor deprecated 

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

Deprecated: Use GetPortStatsResponse.ProtoReflect.Descriptor instead.

func (*GetPortStatsResponse) GetError 

func (x *GetPortStatsResponse) GetError() *Error

func (*GetPortStatsResponse) GetInc 

func (x *GetPortStatsResponse) GetInc() *GetPortStatsResponse_Stat

func (*GetPortStatsResponse) GetOut 

func (x *GetPortStatsResponse) GetOut() *GetPortStatsResponse_Stat

func (*GetPortStatsResponse) GetTimestamp 

func (x *GetPortStatsResponse) GetTimestamp() float64

func (*GetPortStatsResponse) ProtoMessage 

func (*GetPortStatsResponse) ProtoMessage()

func (*GetPortStatsResponse) ProtoReflect 

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

func (*GetPortStatsResponse) Reset 

func (x *GetPortStatsResponse) Reset()

func (*GetPortStatsResponse) String 

func (x *GetPortStatsResponse) String() string

type GetPortStatsResponse_Stat 

type GetPortStatsResponse_Stat struct {

	/// Number of objects that have been successfully sent/received.
	/// All counters shows the accumulated value since port initialization.
	Packets uint64 `protobuf:"varint,1,opt,name=packets,proto3" json:"packets,omitempty"`
	/// Number of dropped packets.
	/// For incoming direction, it implies BESS is not picking up fast enough.
	/// For outgoing direction, non-zero drop counter indicates that the "peer"
	/// of this port is the performance bottleneck: namely, VMs/containers/apps
	/// for virtual ports, or PCIe/NIC/link for physical port.
	Dropped uint64 `protobuf:"varint,2,opt,name=dropped,proto3" json:"dropped,omitempty"`
	/// Total number of bytes, not including Frame CRC or Ethernet overheads
	Bytes uint64 `protobuf:"varint,3,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// Histogram of how many times a given number of packets in a batch was
	// requested.
	RequestedHist []uint64 `protobuf:"varint,4,rep,packed,name=requested_hist,json=requestedHist,proto3" json:"requested_hist,omitempty"`
	// Histogram of how many times a given number of packets in a batch were
	// actually processed.
	ActualHist []uint64 `protobuf:"varint,5,rep,packed,name=actual_hist,json=actualHist,proto3" json:"actual_hist,omitempty"`
	// Histogram of the difference between the requested batch size and the
	// actual number of packets processed in that batch.
	DiffHist []uint64 `protobuf:"varint,6,rep,packed,name=diff_hist,json=diffHist,proto3" json:"diff_hist,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPortStatsResponse_Stat) Descriptor deprecated 

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

Deprecated: Use GetPortStatsResponse_Stat.ProtoReflect.Descriptor instead.

func (*GetPortStatsResponse_Stat) GetActualHist 

func (x *GetPortStatsResponse_Stat) GetActualHist() []uint64

func (*GetPortStatsResponse_Stat) GetBytes 

func (x *GetPortStatsResponse_Stat) GetBytes() uint64

func (*GetPortStatsResponse_Stat) GetDiffHist 

func (x *GetPortStatsResponse_Stat) GetDiffHist() []uint64

func (*GetPortStatsResponse_Stat) GetDropped 

func (x *GetPortStatsResponse_Stat) GetDropped() uint64

func (*GetPortStatsResponse_Stat) GetPackets 

func (x *GetPortStatsResponse_Stat) GetPackets() uint64

func (*GetPortStatsResponse_Stat) GetRequestedHist 

func (x *GetPortStatsResponse_Stat) GetRequestedHist() []uint64

func (*GetPortStatsResponse_Stat) ProtoMessage 

func (*GetPortStatsResponse_Stat) ProtoMessage()

func (*GetPortStatsResponse_Stat) ProtoReflect 

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

func (*GetPortStatsResponse_Stat) Reset 

func (x *GetPortStatsResponse_Stat) Reset()

func (*GetPortStatsResponse_Stat) String 

func (x *GetPortStatsResponse_Stat) String() string

type GetTcStatsRequest 

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

func (*GetTcStatsRequest) Descriptor deprecated 

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

Deprecated: Use GetTcStatsRequest.ProtoReflect.Descriptor instead.

func (*GetTcStatsRequest) GetName 

func (x *GetTcStatsRequest) GetName() string

func (*GetTcStatsRequest) ProtoMessage 

func (*GetTcStatsRequest) ProtoMessage()

func (*GetTcStatsRequest) ProtoReflect 

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

func (*GetTcStatsRequest) Reset 

func (x *GetTcStatsRequest) Reset()

func (*GetTcStatsRequest) String 

func (x *GetTcStatsRequest) String() string

type GetTcStatsResponse 

type GetTcStatsResponse struct {
	Error     *Error  `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Timestamp float64 `protobuf:"fixed64,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` /// The time that stat counters were read
	/// THe following counters represent the total amount of accumulated resource
	/// usage of a module since its creation.
	Count   uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`     /// # of scheduled times
	Cycles  uint64 `protobuf:"varint,4,opt,name=cycles,proto3" json:"cycles,omitempty"`   /// CPU cycles
	Packets uint64 `protobuf:"varint,5,opt,name=packets,proto3" json:"packets,omitempty"` /// # of packets
	Bits    uint64 `protobuf:"varint,6,opt,name=bits,proto3" json:"bits,omitempty"`       /// # of bits
	// contains filtered or unexported fields
}

func (*GetTcStatsResponse) Descriptor deprecated 

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

Deprecated: Use GetTcStatsResponse.ProtoReflect.Descriptor instead.

func (*GetTcStatsResponse) GetBits 

func (x *GetTcStatsResponse) GetBits() uint64

func (*GetTcStatsResponse) GetCount 

func (x *GetTcStatsResponse) GetCount() uint64

func (*GetTcStatsResponse) GetCycles 

func (x *GetTcStatsResponse) GetCycles() uint64

func (*GetTcStatsResponse) GetError 

func (x *GetTcStatsResponse) GetError() *Error

func (*GetTcStatsResponse) GetPackets 

func (x *GetTcStatsResponse) GetPackets() uint64

func (*GetTcStatsResponse) GetTimestamp 

func (x *GetTcStatsResponse) GetTimestamp() float64

func (*GetTcStatsResponse) ProtoMessage 

func (*GetTcStatsResponse) ProtoMessage()

func (*GetTcStatsResponse) ProtoReflect 

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

func (*GetTcStatsResponse) Reset 

func (x *GetTcStatsResponse) Reset()

func (*GetTcStatsResponse) String 

func (x *GetTcStatsResponse) String() string

type GtpuEchoArg 

type GtpuEchoArg struct {
	S1USgwIp uint32 `protobuf:"varint,1,opt,name=s1u_sgw_ip,json=s1uSgwIp,proto3" json:"s1u_sgw_ip,omitempty"` /// IP address of S1U interface
	// contains filtered or unexported fields
}

* The GtpuEcho module processes the GTPv1 echo packet and prepares corresponding IP packet containing GTP echo response. It assumes Recovery IE is always zero.

__Input Gates__: 1 __Output Gates__: 1

func (*GtpuEchoArg) Descriptor deprecated 

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

Deprecated: Use GtpuEchoArg.ProtoReflect.Descriptor instead.

func (*GtpuEchoArg) GetS1USgwIp 

func (x *GtpuEchoArg) GetS1USgwIp() uint32

func (*GtpuEchoArg) ProtoMessage 

func (*GtpuEchoArg) ProtoMessage()

func (*GtpuEchoArg) ProtoReflect 

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

func (*GtpuEchoArg) Reset 

func (x *GtpuEchoArg) Reset()

func (*GtpuEchoArg) String 

func (x *GtpuEchoArg) String() string

type GtpuEncapArg 

type GtpuEncapArg struct {
	AddPsc bool `protobuf:"varint,1,opt,name=add_psc,json=addPsc,proto3" json:"add_psc,omitempty"` /// Add PDU session container in encap (default = False)
	// contains filtered or unexported fields
}

* The GtpuEncap module inserts GTP header in an ethernet frame

__Input Gates__: 1 __Output Gates__: 1

func (*GtpuEncapArg) Descriptor deprecated 

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

Deprecated: Use GtpuEncapArg.ProtoReflect.Descriptor instead.

func (*GtpuEncapArg) GetAddPsc 

func (x *GtpuEncapArg) GetAddPsc() bool

func (*GtpuEncapArg) ProtoMessage 

func (*GtpuEncapArg) ProtoMessage()

func (*GtpuEncapArg) ProtoReflect 

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

func (*GtpuEncapArg) Reset 

func (x *GtpuEncapArg) Reset()

func (*GtpuEncapArg) String 

func (x *GtpuEncapArg) String() string

type HashLBArg 

type HashLBArg struct {
	Gates  []int64  `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// A list of gate numbers over which to partition packets
	Mode   string   `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`           /// The mode (`'l2'`, `'l3'`, or `'l4'`) for the hash function.
	Fields []*Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`       /// A list of fields that define a custom tuple.
	// contains filtered or unexported fields
}

* The HashLB module partitions packets between output gates according to either a hash over their MAC src/dst (`mode='l2'`), their IP src/dst (`mode='l3'`), the full IP/TCP 5-tuple (`mode='l4'`), or the N-tuple defined by `fields`.

__Input Gates__: 1 __Output Gates__: many (configurable)

func (*HashLBArg) Descriptor deprecated 

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

Deprecated: Use HashLBArg.ProtoReflect.Descriptor instead.

func (*HashLBArg) GetFields 

func (x *HashLBArg) GetFields() []*Field

func (*HashLBArg) GetGates 

func (x *HashLBArg) GetGates() []int64

func (*HashLBArg) GetMode 

func (x *HashLBArg) GetMode() string

func (*HashLBArg) ProtoMessage 

func (*HashLBArg) ProtoMessage()

func (*HashLBArg) ProtoReflect 

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

func (*HashLBArg) Reset 

func (x *HashLBArg) Reset()

func (*HashLBArg) String 

func (x *HashLBArg) String() string

type HashLBCommandSetGatesArg 

type HashLBCommandSetGatesArg struct {
	Gates []int64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` ///A list of gate numbers to load balance traffic over
	// contains filtered or unexported fields
}

* The HashLB module has a command `set_gates(...)` which takes one parameter. This function takes in a list of gate numbers to send hashed traffic out over. Example use in bessctl: `lb.setGates(gates=[0,1,2,3])`

func (*HashLBCommandSetGatesArg) Descriptor deprecated 

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

Deprecated: Use HashLBCommandSetGatesArg.ProtoReflect.Descriptor instead.

func (*HashLBCommandSetGatesArg) GetGates 

func (x *HashLBCommandSetGatesArg) GetGates() []int64

func (*HashLBCommandSetGatesArg) ProtoMessage 

func (*HashLBCommandSetGatesArg) ProtoMessage()

func (*HashLBCommandSetGatesArg) ProtoReflect 

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

func (*HashLBCommandSetGatesArg) Reset 

func (x *HashLBCommandSetGatesArg) Reset()

func (*HashLBCommandSetGatesArg) String 

func (x *HashLBCommandSetGatesArg) String() string

type HashLBCommandSetModeArg 

type HashLBCommandSetModeArg struct {
	Mode   string   `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"`     /// What fields to hash over, `'l2'`, `'l3'`, and `'l4'` are only valid values.
	Fields []*Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` /// A list of fields that define a custom tuple.
	// contains filtered or unexported fields
}

* The HashLB module has a command `set_mode(...)` which takes two parameters. The `mode` parameter specifies whether the load balancer will hash over the src/dest ethernet header (`'l2'`), over the src/dest IP addresses (`'l3'`), or over the flow 5-tuple (`'l4'`). Alternatively, if the `fields` parameter is set, the load balancer will hash over the N-tuple with the specified offsets and sizes. Example use in bessctl: `lb.set_mode('l2')`

func (*HashLBCommandSetModeArg) Descriptor deprecated 

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

Deprecated: Use HashLBCommandSetModeArg.ProtoReflect.Descriptor instead.

func (*HashLBCommandSetModeArg) GetFields 

func (x *HashLBCommandSetModeArg) GetFields() []*Field

func (*HashLBCommandSetModeArg) GetMode 

func (x *HashLBCommandSetModeArg) GetMode() string

func (*HashLBCommandSetModeArg) ProtoMessage 

func (*HashLBCommandSetModeArg) ProtoMessage()

func (*HashLBCommandSetModeArg) ProtoReflect 

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

func (*HashLBCommandSetModeArg) Reset 

func (x *HashLBCommandSetModeArg) Reset()

func (*HashLBCommandSetModeArg) String 

func (x *HashLBCommandSetModeArg) String() string

type IPChecksumArg 

type IPChecksumArg struct {
	Verify bool `protobuf:"varint,1,opt,name=verify,proto3" json:"verify,omitempty"` /// check checksum
	Hw     bool `protobuf:"varint,2,opt,name=hw,proto3" json:"hw,omitempty"`         /// enable hardware offload
	// contains filtered or unexported fields
}

* The IPChecksum module calculates the IPv4 checksum of packets. If verify is set to true, the module can be used to validate the checksum of the IPv4 packet. All non-IPv4 packets are forwarded without modification. Output gates: (0) Default, (1) Drop.

__Input Gates__: 1 __Output Gates__: 2

func (*IPChecksumArg) Descriptor deprecated 

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

Deprecated: Use IPChecksumArg.ProtoReflect.Descriptor instead.

func (*IPChecksumArg) GetHw 

func (x *IPChecksumArg) GetHw() bool

func (*IPChecksumArg) GetVerify 

func (x *IPChecksumArg) GetVerify() bool

func (*IPChecksumArg) ProtoMessage 

func (*IPChecksumArg) ProtoMessage()

func (*IPChecksumArg) ProtoReflect 

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

func (*IPChecksumArg) Reset 

func (x *IPChecksumArg) Reset()

func (*IPChecksumArg) String 

func (x *IPChecksumArg) String() string

type IPDefragArg 

type IPDefragArg struct {
	NumFlows uint32 `protobuf:"varint,1,opt,name=num_flows,json=numFlows,proto3" json:"num_flows,omitempty"` /// max number of flows the module can handle
	Numa     int32  `protobuf:"varint,2,opt,name=numa,proto3" json:"numa,omitempty"`                         /// numa placement for ip frags memory management
	// contains filtered or unexported fields
}

* The IPDefrag module scans the IP datagram and checks whether it is fragmented. It returns a fully reassembled datagram or an unfragmented IP datagram

__Input Gates__: 1 __Output Gates__: 1

func (*IPDefragArg) Descriptor deprecated 

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

Deprecated: Use IPDefragArg.ProtoReflect.Descriptor instead.

func (*IPDefragArg) GetNumFlows 

func (x *IPDefragArg) GetNumFlows() uint32

func (*IPDefragArg) GetNuma 

func (x *IPDefragArg) GetNuma() int32

func (*IPDefragArg) ProtoMessage 

func (*IPDefragArg) ProtoMessage()

func (*IPDefragArg) ProtoReflect 

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

func (*IPDefragArg) Reset 

func (x *IPDefragArg) Reset()

func (*IPDefragArg) String 

func (x *IPDefragArg) String() string

type IPEncapArg 

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

* Encapsulates a packet with an IP header, where IP src, dst, and proto are filled in by metadata values carried with the packet. Metadata attributes must include: ip_src, ip_dst, ip_proto, ip_nexthop, and ether_type.

__Input Gates__: 1 __Output Gates__: 1

func (*IPEncapArg) Descriptor deprecated 

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

Deprecated: Use IPEncapArg.ProtoReflect.Descriptor instead.

func (*IPEncapArg) ProtoMessage 

func (*IPEncapArg) ProtoMessage()

func (*IPEncapArg) ProtoReflect 

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

func (*IPEncapArg) Reset 

func (x *IPEncapArg) Reset()

func (*IPEncapArg) String 

func (x *IPEncapArg) String() string

type IPFragArg 

type IPFragArg struct {
	Mtu int32 `protobuf:"varint,1,opt,name=mtu,proto3" json:"mtu,omitempty"` /// full Ethernet frame size (including CRC) for encapsulated ipv4 frag datagrams
	// contains filtered or unexported fields
}

* The IPDFrag module scans the IP datagram and checks whether it needs to be fragmented.

__Input Gates__: 1 __Output Gates__: 1

func (*IPFragArg) Descriptor deprecated 

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

Deprecated: Use IPFragArg.ProtoReflect.Descriptor instead.

func (*IPFragArg) GetMtu 

func (x *IPFragArg) GetMtu() int32

func (*IPFragArg) ProtoMessage 

func (*IPFragArg) ProtoMessage()

func (*IPFragArg) ProtoReflect 

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

func (*IPFragArg) Reset 

func (x *IPFragArg) Reset()

func (*IPFragArg) String 

func (x *IPFragArg) String() string

type IPLookupArg 

type IPLookupArg struct {
	MaxRules uint32 `protobuf:"varint,1,opt,name=max_rules,json=maxRules,proto3" json:"max_rules,omitempty"` /// Maximum number of rules (default: 1024)
	MaxTbl8S uint32 `protobuf:"varint,2,opt,name=max_tbl8s,json=maxTbl8s,proto3" json:"max_tbl8s,omitempty"` /// Maximum number of IP prefixes with smaller than /24 (default: 128)
	// contains filtered or unexported fields
}

* An IPLookup module perfroms LPM lookups over a packet destination. IPLookup takes no parameters to instantiate. To add rules to the IPLookup table, use `IPLookup.add()`

__Input Gates__: 1 __Output Gates__: many (configurable, depending on rule values)

func (*IPLookupArg) Descriptor deprecated 

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

Deprecated: Use IPLookupArg.ProtoReflect.Descriptor instead.

func (*IPLookupArg) GetMaxRules 

func (x *IPLookupArg) GetMaxRules() uint32

func (*IPLookupArg) GetMaxTbl8S 

func (x *IPLookupArg) GetMaxTbl8S() uint32

func (*IPLookupArg) ProtoMessage 

func (*IPLookupArg) ProtoMessage()

func (*IPLookupArg) ProtoReflect 

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

func (*IPLookupArg) Reset 

func (x *IPLookupArg) Reset()

func (*IPLookupArg) String 

func (x *IPLookupArg) String() string

type IPLookupCommandAddArg 

type IPLookupCommandAddArg struct {
	Prefix    string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`                         /// The CIDR IP part of the prefix to match
	PrefixLen uint64 `protobuf:"varint,2,opt,name=prefix_len,json=prefixLen,proto3" json:"prefix_len,omitempty"` /// The prefix length
	Gate      uint64 `protobuf:"varint,3,opt,name=gate,proto3" json:"gate,omitempty"`                            /// The number of the gate to forward matching traffic on.
	// contains filtered or unexported fields
}

* The IPLookup module has a command `add(...)` which takes three paramters. This function accepts the routing rules -- CIDR prefix, CIDR prefix length, and what gate to forward matching traffic out on. Example use in bessctl: `table.add(prefix='10.0.0.0', prefix_len=8, gate=2)`

func (*IPLookupCommandAddArg) Descriptor deprecated 

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

Deprecated: Use IPLookupCommandAddArg.ProtoReflect.Descriptor instead.

func (*IPLookupCommandAddArg) GetGate 

func (x *IPLookupCommandAddArg) GetGate() uint64

func (*IPLookupCommandAddArg) GetPrefix 

func (x *IPLookupCommandAddArg) GetPrefix() string

func (*IPLookupCommandAddArg) GetPrefixLen 

func (x *IPLookupCommandAddArg) GetPrefixLen() uint64

func (*IPLookupCommandAddArg) ProtoMessage 

func (*IPLookupCommandAddArg) ProtoMessage()

func (*IPLookupCommandAddArg) ProtoReflect 

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

func (*IPLookupCommandAddArg) Reset 

func (x *IPLookupCommandAddArg) Reset()

func (*IPLookupCommandAddArg) String 

func (x *IPLookupCommandAddArg) String() string

type IPLookupCommandClearArg 

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

* The IPLookup module has a command `clear()` which takes no parameters. This function removes all rules in the IPLookup table. Example use in bessctl: `myiplookuptable.clear()`

func (*IPLookupCommandClearArg) Descriptor deprecated 

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

Deprecated: Use IPLookupCommandClearArg.ProtoReflect.Descriptor instead.

func (*IPLookupCommandClearArg) ProtoMessage 

func (*IPLookupCommandClearArg) ProtoMessage()

func (*IPLookupCommandClearArg) ProtoReflect 

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

func (*IPLookupCommandClearArg) Reset 

func (x *IPLookupCommandClearArg) Reset()

func (*IPLookupCommandClearArg) String 

func (x *IPLookupCommandClearArg) String() string

type IPLookupCommandDeleteArg 

type IPLookupCommandDeleteArg struct {
	Prefix    string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`                         /// The CIDR IP part of the prefix to match
	PrefixLen uint64 `protobuf:"varint,2,opt,name=prefix_len,json=prefixLen,proto3" json:"prefix_len,omitempty"` /// The prefix length
	// contains filtered or unexported fields
}

* The IPLookup module has a command `delete(...)` which takes two paramters. This function accepts the routing rules -- CIDR prefix, CIDR prefix length, Example use in bessctl: `table.delete(prefix='10.0.0.0', prefix_len=8)`

func (*IPLookupCommandDeleteArg) Descriptor deprecated 

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

Deprecated: Use IPLookupCommandDeleteArg.ProtoReflect.Descriptor instead.

func (*IPLookupCommandDeleteArg) GetPrefix 

func (x *IPLookupCommandDeleteArg) GetPrefix() string

func (*IPLookupCommandDeleteArg) GetPrefixLen 

func (x *IPLookupCommandDeleteArg) GetPrefixLen() uint64

func (*IPLookupCommandDeleteArg) ProtoMessage 

func (*IPLookupCommandDeleteArg) ProtoMessage()

func (*IPLookupCommandDeleteArg) ProtoReflect 

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

func (*IPLookupCommandDeleteArg) Reset 

func (x *IPLookupCommandDeleteArg) Reset()

func (*IPLookupCommandDeleteArg) String 

func (x *IPLookupCommandDeleteArg) String() string

type ImportPluginRequest 

type ImportPluginRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` /// Path to the module library (*.so file)
	// contains filtered or unexported fields
}

func (*ImportPluginRequest) Descriptor deprecated 

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

Deprecated: Use ImportPluginRequest.ProtoReflect.Descriptor instead.

func (*ImportPluginRequest) GetPath 

func (x *ImportPluginRequest) GetPath() string

func (*ImportPluginRequest) ProtoMessage 

func (*ImportPluginRequest) ProtoMessage()

func (*ImportPluginRequest) ProtoReflect 

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

func (*ImportPluginRequest) Reset 

func (x *ImportPluginRequest) Reset()

func (*ImportPluginRequest) String 

func (x *ImportPluginRequest) String() string

type L2ForwardArg 

type L2ForwardArg struct {
	Size   int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`     /// Configures the forwarding hash table -- total number of hash table entries.
	Bucket int64 `protobuf:"varint,2,opt,name=bucket,proto3" json:"bucket,omitempty"` /// Configures the forwarding hash table -- total number of slots per hash value.
	// contains filtered or unexported fields
}

* An L2Forward module forwards packets to an output gate according to exact-match rules over an Ethernet destination. Note that this is _not_ a learning switch -- forwards according to fixed routes specified by `add(..)`.

__Input Gates__: 1 __Ouput Gates__: many (configurable, depending on rules)

func (*L2ForwardArg) Descriptor deprecated 

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

Deprecated: Use L2ForwardArg.ProtoReflect.Descriptor instead.

func (*L2ForwardArg) GetBucket 

func (x *L2ForwardArg) GetBucket() int64

func (*L2ForwardArg) GetSize 

func (x *L2ForwardArg) GetSize() int64

func (*L2ForwardArg) ProtoMessage 

func (*L2ForwardArg) ProtoMessage()

func (*L2ForwardArg) ProtoReflect 

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

func (*L2ForwardArg) Reset 

func (x *L2ForwardArg) Reset()

func (*L2ForwardArg) String 

func (x *L2ForwardArg) String() string

type L2ForwardCommandAddArg 

type L2ForwardCommandAddArg struct {
	Entries []*L2ForwardCommandAddArg_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` /// A list of L2Forward entries.
	// contains filtered or unexported fields
}

* The L2Forward module forwards traffic via exact match over the Ethernet destination address. The command `add(...)` allows you to specifiy a MAC address and which gate the L2Forward module should direct it out of.

func (*L2ForwardCommandAddArg) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandAddArg.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandAddArg) GetEntries 

func (x *L2ForwardCommandAddArg) GetEntries() []*L2ForwardCommandAddArg_Entry

func (*L2ForwardCommandAddArg) ProtoMessage 

func (*L2ForwardCommandAddArg) ProtoMessage()

func (*L2ForwardCommandAddArg) ProtoReflect 

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

func (*L2ForwardCommandAddArg) Reset 

func (x *L2ForwardCommandAddArg) Reset()

func (*L2ForwardCommandAddArg) String 

func (x *L2ForwardCommandAddArg) String() string

type L2ForwardCommandAddArg_Entry 

type L2ForwardCommandAddArg_Entry struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`  /// The MAC address to match
	Gate int64  `protobuf:"varint,2,opt,name=gate,proto3" json:"gate,omitempty"` /// Which gate to send out traffic matching this address.
	// contains filtered or unexported fields
}

func (*L2ForwardCommandAddArg_Entry) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandAddArg_Entry.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandAddArg_Entry) GetAddr 

func (x *L2ForwardCommandAddArg_Entry) GetAddr() string

func (*L2ForwardCommandAddArg_Entry) GetGate 

func (x *L2ForwardCommandAddArg_Entry) GetGate() int64

func (*L2ForwardCommandAddArg_Entry) ProtoMessage 

func (*L2ForwardCommandAddArg_Entry) ProtoMessage()

func (*L2ForwardCommandAddArg_Entry) ProtoReflect 

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

func (*L2ForwardCommandAddArg_Entry) Reset 

func (x *L2ForwardCommandAddArg_Entry) Reset()

func (*L2ForwardCommandAddArg_Entry) String 

func (x *L2ForwardCommandAddArg_Entry) String() string

type L2ForwardCommandDeleteArg 

type L2ForwardCommandDeleteArg struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"` /// The address to remove from the forwarding table
	// contains filtered or unexported fields
}

* The L2Forward module has a function `delete(...)` to remove a rule from the MAC forwarding table.

func (*L2ForwardCommandDeleteArg) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandDeleteArg.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandDeleteArg) GetAddrs 

func (x *L2ForwardCommandDeleteArg) GetAddrs() []string

func (*L2ForwardCommandDeleteArg) ProtoMessage 

func (*L2ForwardCommandDeleteArg) ProtoMessage()

func (*L2ForwardCommandDeleteArg) ProtoReflect 

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

func (*L2ForwardCommandDeleteArg) Reset 

func (x *L2ForwardCommandDeleteArg) Reset()

func (*L2ForwardCommandDeleteArg) String 

func (x *L2ForwardCommandDeleteArg) String() string

type L2ForwardCommandLookupArg 

type L2ForwardCommandLookupArg struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"` /// The MAC address to query for
	// contains filtered or unexported fields
}

* The L2Forward module has a function `lookup(...)` to query what output gate a given MAC address will be forwared to; it returns the gate ID number.

func (*L2ForwardCommandLookupArg) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandLookupArg.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandLookupArg) GetAddrs 

func (x *L2ForwardCommandLookupArg) GetAddrs() []string

func (*L2ForwardCommandLookupArg) ProtoMessage 

func (*L2ForwardCommandLookupArg) ProtoMessage()

func (*L2ForwardCommandLookupArg) ProtoReflect 

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

func (*L2ForwardCommandLookupArg) Reset 

func (x *L2ForwardCommandLookupArg) Reset()

func (*L2ForwardCommandLookupArg) String 

func (x *L2ForwardCommandLookupArg) String() string

type L2ForwardCommandLookupResponse 

type L2ForwardCommandLookupResponse struct {
	Gates []uint64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// The gate ID that the requested MAC address maps to
	// contains filtered or unexported fields
}

* This message type provides the reponse to the L2Forward function `lookup(..)`. It returns the gate that a requested MAC address is currently assigned to.

func (*L2ForwardCommandLookupResponse) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandLookupResponse.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandLookupResponse) GetGates 

func (x *L2ForwardCommandLookupResponse) GetGates() []uint64

func (*L2ForwardCommandLookupResponse) ProtoMessage 

func (*L2ForwardCommandLookupResponse) ProtoMessage()

func (*L2ForwardCommandLookupResponse) ProtoReflect 

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

func (*L2ForwardCommandLookupResponse) Reset 

func (x *L2ForwardCommandLookupResponse) Reset()

func (*L2ForwardCommandLookupResponse) String 

func (x *L2ForwardCommandLookupResponse) String() string

type L2ForwardCommandPopulateArg 

type L2ForwardCommandPopulateArg struct {
	Base      string `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`                             /// The base MAC address
	Count     int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`                          /// How many addresses beyond base to populate into the routing table
	GateCount int64  `protobuf:"varint,3,opt,name=gate_count,json=gateCount,proto3" json:"gate_count,omitempty"` /// How many gates to create in the L2Forward module.
	// contains filtered or unexported fields
}

* The L2Forward module has a command `populate(...)` which allows for fast creation of the forwarding table given a range of MAC addresses. The function takes in a 'base' MAC address, a count (number of MAC addresses), and a gate_id. The module will route all MAC addresses starting from the base address, up to base+count address round-robin over gate_count total gates. For example, `populate(base='11:22:33:44:00', count = 10, gate_count = 2)` would route addresses `11:22:33:44::(00, 02, 04, 06, 08)` out a gate 0 and the odd-suffixed addresses out gate 1.

func (*L2ForwardCommandPopulateArg) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandPopulateArg.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandPopulateArg) GetBase 

func (x *L2ForwardCommandPopulateArg) GetBase() string

func (*L2ForwardCommandPopulateArg) GetCount 

func (x *L2ForwardCommandPopulateArg) GetCount() int64

func (*L2ForwardCommandPopulateArg) GetGateCount 

func (x *L2ForwardCommandPopulateArg) GetGateCount() int64

func (*L2ForwardCommandPopulateArg) ProtoMessage 

func (*L2ForwardCommandPopulateArg) ProtoMessage()

func (*L2ForwardCommandPopulateArg) ProtoReflect 

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

func (*L2ForwardCommandPopulateArg) Reset 

func (x *L2ForwardCommandPopulateArg) Reset()

func (*L2ForwardCommandPopulateArg) String 

func (x *L2ForwardCommandPopulateArg) String() string

type L2ForwardCommandSetDefaultGateArg 

type L2ForwardCommandSetDefaultGateArg struct {
	Gate int64 `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"` /// The default gate to forward traffic which matches no entry to.
	// contains filtered or unexported fields
}

* For traffic reaching the L2Forward module which does not match a MAC rule, the function `set_default_gate(...)` allows you to specify a default gate to direct unmatched traffic to.

func (*L2ForwardCommandSetDefaultGateArg) Descriptor deprecated 

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

Deprecated: Use L2ForwardCommandSetDefaultGateArg.ProtoReflect.Descriptor instead.

func (*L2ForwardCommandSetDefaultGateArg) GetGate 

func (x *L2ForwardCommandSetDefaultGateArg) GetGate() int64

func (*L2ForwardCommandSetDefaultGateArg) ProtoMessage 

func (*L2ForwardCommandSetDefaultGateArg) ProtoMessage()

func (*L2ForwardCommandSetDefaultGateArg) ProtoReflect 

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

func (*L2ForwardCommandSetDefaultGateArg) Reset 

func (x *L2ForwardCommandSetDefaultGateArg) Reset()

func (*L2ForwardCommandSetDefaultGateArg) String 

func (x *L2ForwardCommandSetDefaultGateArg) String() string

type L4ChecksumArg 

type L4ChecksumArg struct {
	Verify bool `protobuf:"varint,1,opt,name=verify,proto3" json:"verify,omitempty"` /// check checksum
	Hw     bool `protobuf:"varint,2,opt,name=hw,proto3" json:"hw,omitempty"`         /// enable hardware offload
	// contains filtered or unexported fields
}

* The L4Checksum module calculates the UDP/IPv4 checksum of packets. If verify is set to true, the module can be used to validate the checksum of the UDP/IPv4 packet. All non-IPv4 packets are forwarded without modification. Output gates: (0) Default, (1) Drop.

__Input Gates__: MAX_GATES __Output Gates__: 2

func (*L4ChecksumArg) Descriptor deprecated 

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

Deprecated: Use L4ChecksumArg.ProtoReflect.Descriptor instead.

func (*L4ChecksumArg) GetHw 

func (x *L4ChecksumArg) GetHw() bool

func (*L4ChecksumArg) GetVerify 

func (x *L4ChecksumArg) GetVerify() bool

func (*L4ChecksumArg) ProtoMessage 

func (*L4ChecksumArg) ProtoMessage()

func (*L4ChecksumArg) ProtoReflect 

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

func (*L4ChecksumArg) Reset 

func (x *L4ChecksumArg) Reset()

func (*L4ChecksumArg) String 

func (x *L4ChecksumArg) String() string

type ListDriversResponse 

type ListDriversResponse struct {
	Error       *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	DriverNames []string `protobuf:"bytes,2,rep,name=driver_names,json=driverNames,proto3" json:"driver_names,omitempty"` /// List of availabe port drivers
	// contains filtered or unexported fields
}

func (*ListDriversResponse) Descriptor deprecated 

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

Deprecated: Use ListDriversResponse.ProtoReflect.Descriptor instead.

func (*ListDriversResponse) GetDriverNames 

func (x *ListDriversResponse) GetDriverNames() []string

func (*ListDriversResponse) GetError 

func (x *ListDriversResponse) GetError() *Error

func (*ListDriversResponse) ProtoMessage 

func (*ListDriversResponse) ProtoMessage()

func (*ListDriversResponse) ProtoReflect 

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

func (*ListDriversResponse) Reset 

func (x *ListDriversResponse) Reset()

func (*ListDriversResponse) String 

func (x *ListDriversResponse) String() string

type ListGateHookClassResponse 

type ListGateHookClassResponse struct {
	Error *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"` /// List of gatehook types
	// contains filtered or unexported fields
}

func (*ListGateHookClassResponse) Descriptor deprecated 

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

Deprecated: Use ListGateHookClassResponse.ProtoReflect.Descriptor instead.

func (*ListGateHookClassResponse) GetError 

func (x *ListGateHookClassResponse) GetError() *Error

func (*ListGateHookClassResponse) GetNames 

func (x *ListGateHookClassResponse) GetNames() []string

func (*ListGateHookClassResponse) ProtoMessage 

func (*ListGateHookClassResponse) ProtoMessage()

func (*ListGateHookClassResponse) ProtoReflect 

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

func (*ListGateHookClassResponse) Reset 

func (x *ListGateHookClassResponse) Reset()

func (*ListGateHookClassResponse) String 

func (x *ListGateHookClassResponse) String() string

type ListGateHooksResponse 

type ListGateHooksResponse struct {
	Error *Error          `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Hooks []*GateHookInfo `protobuf:"bytes,2,rep,name=hooks,proto3" json:"hooks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListGateHooksResponse) Descriptor deprecated 

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

Deprecated: Use ListGateHooksResponse.ProtoReflect.Descriptor instead.

func (*ListGateHooksResponse) GetError 

func (x *ListGateHooksResponse) GetError() *Error

func (*ListGateHooksResponse) GetHooks 

func (x *ListGateHooksResponse) GetHooks() []*GateHookInfo

func (*ListGateHooksResponse) ProtoMessage 

func (*ListGateHooksResponse) ProtoMessage()

func (*ListGateHooksResponse) ProtoReflect 

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

func (*ListGateHooksResponse) Reset 

func (x *ListGateHooksResponse) Reset()

func (*ListGateHooksResponse) String 

func (x *ListGateHooksResponse) String() string

type ListMclassResponse 

type ListMclassResponse struct {
	Error *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Names []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"` /// List of module types
	// contains filtered or unexported fields
}

func (*ListMclassResponse) Descriptor deprecated 

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

Deprecated: Use ListMclassResponse.ProtoReflect.Descriptor instead.

func (*ListMclassResponse) GetError 

func (x *ListMclassResponse) GetError() *Error

func (*ListMclassResponse) GetNames 

func (x *ListMclassResponse) GetNames() []string

func (*ListMclassResponse) ProtoMessage 

func (*ListMclassResponse) ProtoMessage()

func (*ListMclassResponse) ProtoReflect 

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

func (*ListMclassResponse) Reset 

func (x *ListMclassResponse) Reset()

func (*ListMclassResponse) String 

func (x *ListMclassResponse) String() string

type ListModulesResponse 

type ListModulesResponse struct {
	Error   *Error                        `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Modules []*ListModulesResponse_Module `protobuf:"bytes,2,rep,name=modules,proto3" json:"modules,omitempty"` /// List of all existing modules
	// contains filtered or unexported fields
}

func (*ListModulesResponse) Descriptor deprecated 

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

Deprecated: Use ListModulesResponse.ProtoReflect.Descriptor instead.

func (*ListModulesResponse) GetError 

func (x *ListModulesResponse) GetError() *Error

func (*ListModulesResponse) GetModules 

func (x *ListModulesResponse) GetModules() []*ListModulesResponse_Module

func (*ListModulesResponse) ProtoMessage 

func (*ListModulesResponse) ProtoMessage()

func (*ListModulesResponse) ProtoReflect 

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

func (*ListModulesResponse) Reset 

func (x *ListModulesResponse) Reset()

func (*ListModulesResponse) String 

func (x *ListModulesResponse) String() string

type ListModulesResponse_Module 

type ListModulesResponse_Module struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`     /// Name of module
	Mclass string `protobuf:"bytes,2,opt,name=mclass,proto3" json:"mclass,omitempty"` /// Module type
	Desc   string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`     /// Current status of module as a short, 1-line string
	// contains filtered or unexported fields
}

func (*ListModulesResponse_Module) Descriptor deprecated 

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

Deprecated: Use ListModulesResponse_Module.ProtoReflect.Descriptor instead.

func (*ListModulesResponse_Module) GetDesc 

func (x *ListModulesResponse_Module) GetDesc() string

func (*ListModulesResponse_Module) GetMclass 

func (x *ListModulesResponse_Module) GetMclass() string

func (*ListModulesResponse_Module) GetName 

func (x *ListModulesResponse_Module) GetName() string

func (*ListModulesResponse_Module) ProtoMessage 

func (*ListModulesResponse_Module) ProtoMessage()

func (*ListModulesResponse_Module) ProtoReflect 

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

func (*ListModulesResponse_Module) Reset 

func (x *ListModulesResponse_Module) Reset()

func (*ListModulesResponse_Module) String 

func (x *ListModulesResponse_Module) String() string

type ListPluginsResponse 

type ListPluginsResponse struct {
	Error *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Paths []string `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"` /// Paths to the module library (*.so file)
	// contains filtered or unexported fields
}

func (*ListPluginsResponse) Descriptor deprecated 

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

Deprecated: Use ListPluginsResponse.ProtoReflect.Descriptor instead.

func (*ListPluginsResponse) GetError 

func (x *ListPluginsResponse) GetError() *Error

func (*ListPluginsResponse) GetPaths 

func (x *ListPluginsResponse) GetPaths() []string

func (*ListPluginsResponse) ProtoMessage 

func (*ListPluginsResponse) ProtoMessage()

func (*ListPluginsResponse) ProtoReflect 

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

func (*ListPluginsResponse) Reset 

func (x *ListPluginsResponse) Reset()

func (*ListPluginsResponse) String 

func (x *ListPluginsResponse) String() string

type ListPortsResponse 

type ListPortsResponse struct {
	Error *Error                    `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Ports []*ListPortsResponse_Port `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"` /// List of all existing ports
	// contains filtered or unexported fields
}

func (*ListPortsResponse) Descriptor deprecated 

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

Deprecated: Use ListPortsResponse.ProtoReflect.Descriptor instead.

func (*ListPortsResponse) GetError 

func (x *ListPortsResponse) GetError() *Error

func (*ListPortsResponse) GetPorts 

func (x *ListPortsResponse) GetPorts() []*ListPortsResponse_Port

func (*ListPortsResponse) ProtoMessage 

func (*ListPortsResponse) ProtoMessage()

func (*ListPortsResponse) ProtoReflect 

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

func (*ListPortsResponse) Reset 

func (x *ListPortsResponse) Reset()

func (*ListPortsResponse) String 

func (x *ListPortsResponse) String() string

type ListPortsResponse_Port 

type ListPortsResponse_Port struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                      /// Name of port
	Driver  string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`                  /// Name of port driver.
	MacAddr string `protobuf:"bytes,3,opt,name=mac_addr,json=macAddr,proto3" json:"mac_addr,omitempty"` /// MAC address of the port
	/// Number of incoming/RX queues (Ext -> BESS).
	NumIncQ uint64 `protobuf:"varint,4,opt,name=num_inc_q,json=numIncQ,proto3" json:"num_inc_q,omitempty"`
	/// Number of outgoind/TX queues (BESS -> Ext).
	NumOutQ uint64 `protobuf:"varint,5,opt,name=num_out_q,json=numOutQ,proto3" json:"num_out_q,omitempty"`
	/// Size of each incoming queue (# of packets).
	SizeIncQ uint64 `protobuf:"varint,6,opt,name=size_inc_q,json=sizeIncQ,proto3" json:"size_inc_q,omitempty"`
	/// Size of each incoming queue (# of packets).
	SizeOutQ uint64 `protobuf:"varint,7,opt,name=size_out_q,json=sizeOutQ,proto3" json:"size_out_q,omitempty"`
	/// Driver specific argument that was used for port initialization. See port_msg.proto
	DriverArg *any.Any `protobuf:"bytes,8,opt,name=driver_arg,json=driverArg,proto3" json:"driver_arg,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPortsResponse_Port) Descriptor deprecated 

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

Deprecated: Use ListPortsResponse_Port.ProtoReflect.Descriptor instead.

func (*ListPortsResponse_Port) GetDriver 

func (x *ListPortsResponse_Port) GetDriver() string

func (*ListPortsResponse_Port) GetDriverArg 

func (x *ListPortsResponse_Port) GetDriverArg() *any.Any

func (*ListPortsResponse_Port) GetMacAddr 

func (x *ListPortsResponse_Port) GetMacAddr() string

func (*ListPortsResponse_Port) GetName 

func (x *ListPortsResponse_Port) GetName() string

func (*ListPortsResponse_Port) GetNumIncQ 

func (x *ListPortsResponse_Port) GetNumIncQ() uint64

func (*ListPortsResponse_Port) GetNumOutQ 

func (x *ListPortsResponse_Port) GetNumOutQ() uint64

func (*ListPortsResponse_Port) GetSizeIncQ 

func (x *ListPortsResponse_Port) GetSizeIncQ() uint64

func (*ListPortsResponse_Port) GetSizeOutQ 

func (x *ListPortsResponse_Port) GetSizeOutQ() uint64

func (*ListPortsResponse_Port) ProtoMessage 

func (*ListPortsResponse_Port) ProtoMessage()

func (*ListPortsResponse_Port) ProtoReflect 

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

func (*ListPortsResponse_Port) Reset 

func (x *ListPortsResponse_Port) Reset()

func (*ListPortsResponse_Port) String 

func (x *ListPortsResponse_Port) String() string

type ListTcsRequest 

type ListTcsRequest struct {

	/// Specify a worker thread to fetch traffic classes.
	/// To include all traffic classes on every worker, specify -1.
	Wid int64 `protobuf:"varint,1,opt,name=wid,proto3" json:"wid,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTcsRequest) Descriptor deprecated 

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

Deprecated: Use ListTcsRequest.ProtoReflect.Descriptor instead.

func (*ListTcsRequest) GetWid 

func (x *ListTcsRequest) GetWid() int64

func (*ListTcsRequest) ProtoMessage 

func (*ListTcsRequest) ProtoMessage()

func (*ListTcsRequest) ProtoReflect 

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

func (*ListTcsRequest) Reset 

func (x *ListTcsRequest) Reset()

func (*ListTcsRequest) String 

func (x *ListTcsRequest) String() string

type ListTcsResponse 

type ListTcsResponse struct {
	Error         *Error                                `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	ClassesStatus []*ListTcsResponse_TrafficClassStatus `protobuf:"bytes,2,rep,name=classes_status,json=classesStatus,proto3" json:"classes_status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTcsResponse) Descriptor deprecated 

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

Deprecated: Use ListTcsResponse.ProtoReflect.Descriptor instead.

func (*ListTcsResponse) GetClassesStatus 

func (x *ListTcsResponse) GetClassesStatus() []*ListTcsResponse_TrafficClassStatus

func (*ListTcsResponse) GetError 

func (x *ListTcsResponse) GetError() *Error

func (*ListTcsResponse) ProtoMessage 

func (*ListTcsResponse) ProtoMessage()

func (*ListTcsResponse) ProtoReflect 

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

func (*ListTcsResponse) Reset 

func (x *ListTcsResponse) Reset()

func (*ListTcsResponse) String 

func (x *ListTcsResponse) String() string

type ListTcsResponse_TrafficClassStatus 

type ListTcsResponse_TrafficClassStatus struct {
	Class  *TrafficClass `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	Parent string        `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"` /// Name of its parent TC
	// contains filtered or unexported fields
}

func (*ListTcsResponse_TrafficClassStatus) Descriptor deprecated 

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

Deprecated: Use ListTcsResponse_TrafficClassStatus.ProtoReflect.Descriptor instead.

func (*ListTcsResponse_TrafficClassStatus) GetClass 

func (x *ListTcsResponse_TrafficClassStatus) GetClass() *TrafficClass

func (*ListTcsResponse_TrafficClassStatus) GetParent 

func (x *ListTcsResponse_TrafficClassStatus) GetParent() string

func (*ListTcsResponse_TrafficClassStatus) ProtoMessage 

func (*ListTcsResponse_TrafficClassStatus) ProtoMessage()

func (*ListTcsResponse_TrafficClassStatus) ProtoReflect 

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

func (*ListTcsResponse_TrafficClassStatus) Reset 

func (x *ListTcsResponse_TrafficClassStatus) Reset()

func (*ListTcsResponse_TrafficClassStatus) String 

func (x *ListTcsResponse_TrafficClassStatus) String() string

type ListWorkersResponse 

type ListWorkersResponse struct {
	Error         *Error                              `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	WorkersStatus []*ListWorkersResponse_WorkerStatus `protobuf:"bytes,2,rep,name=workers_status,json=workersStatus,proto3" json:"workers_status,omitempty"` /// List of all existing workers
	// contains filtered or unexported fields
}

func (*ListWorkersResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.

func (*ListWorkersResponse) GetError 

func (x *ListWorkersResponse) GetError() *Error

func (*ListWorkersResponse) GetWorkersStatus 

func (x *ListWorkersResponse) GetWorkersStatus() []*ListWorkersResponse_WorkerStatus

func (*ListWorkersResponse) ProtoMessage 

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) ProtoReflect 

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

func (*ListWorkersResponse) Reset 

func (x *ListWorkersResponse) Reset()

func (*ListWorkersResponse) String 

func (x *ListWorkersResponse) String() string

type ListWorkersResponse_WorkerStatus 

type ListWorkersResponse_WorkerStatus struct {
	Wid     int64 `protobuf:"varint,1,opt,name=wid,proto3" json:"wid,omitempty"`         /// Worker ID, starting from 0
	Core    int64 `protobuf:"varint,2,opt,name=core,proto3" json:"core,omitempty"`       /// CPU core ID on which the worker is pinned
	Running bool  `protobuf:"varint,3,opt,name=running,proto3" json:"running,omitempty"` /// True if running, otherwise False.
	/// Number of traffic classes running on the worker
	NumTcs int64 `protobuf:"varint,4,opt,name=num_tcs,json=numTcs,proto3" json:"num_tcs,omitempty"`
	/// Total number of packets that have been silently dropped on the worker.
	/// Silent drops happen when a module transmit packets via disconnected
	/// output gates.
	SilentDrops int64 `protobuf:"varint,5,opt,name=silent_drops,json=silentDrops,proto3" json:"silent_drops,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersResponse_WorkerStatus) Descriptor deprecated 

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

Deprecated: Use ListWorkersResponse_WorkerStatus.ProtoReflect.Descriptor instead.

func (*ListWorkersResponse_WorkerStatus) GetCore 

func (x *ListWorkersResponse_WorkerStatus) GetCore() int64

func (*ListWorkersResponse_WorkerStatus) GetNumTcs 

func (x *ListWorkersResponse_WorkerStatus) GetNumTcs() int64

func (*ListWorkersResponse_WorkerStatus) GetRunning 

func (x *ListWorkersResponse_WorkerStatus) GetRunning() bool

func (*ListWorkersResponse_WorkerStatus) GetSilentDrops 

func (x *ListWorkersResponse_WorkerStatus) GetSilentDrops() int64

func (*ListWorkersResponse_WorkerStatus) GetWid 

func (x *ListWorkersResponse_WorkerStatus) GetWid() int64

func (*ListWorkersResponse_WorkerStatus) ProtoMessage 

func (*ListWorkersResponse_WorkerStatus) ProtoMessage()

func (*ListWorkersResponse_WorkerStatus) ProtoReflect 

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

func (*ListWorkersResponse_WorkerStatus) Reset 

func (x *ListWorkersResponse_WorkerStatus) Reset()

func (*ListWorkersResponse_WorkerStatus) String 

func (x *ListWorkersResponse_WorkerStatus) String() string

type MACSwapArg 

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

* The MACSwap module takes no arguments. It swaps the src/destination MAC addresses within a packet.

__Input Gates__: 1 __Output Gates__: 1

func (*MACSwapArg) Descriptor deprecated 

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

Deprecated: Use MACSwapArg.ProtoReflect.Descriptor instead.

func (*MACSwapArg) ProtoMessage 

func (*MACSwapArg) ProtoMessage()

func (*MACSwapArg) ProtoReflect 

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

func (*MACSwapArg) Reset 

func (x *MACSwapArg) Reset()

func (*MACSwapArg) String 

func (x *MACSwapArg) String() string

type MeasureArg 

type MeasureArg struct {

	// int64 warmup = 1; /// removed: instead of warmup delay, user should Clear()
	//
	// Types that are assignable to Type:
	//	*MeasureArg_Offset
	//	*MeasureArg_AttrName
	Type                isMeasureArg_Type `protobuf_oneof:"type"`
	JitterSampleProb    float64           `protobuf:"fixed64,3,opt,name=jitter_sample_prob,json=jitterSampleProb,proto3" json:"jitter_sample_prob,omitempty"`         /// How often the module should sample packets for inter-packet arrival measurements (to measure jitter).
	LatencyNsMax        uint64            `protobuf:"varint,4,opt,name=latency_ns_max,json=latencyNsMax,proto3" json:"latency_ns_max,omitempty"`                      /// maximum latency expected, in ns (default 0.1 s)
	LatencyNsResolution uint32            `protobuf:"varint,5,opt,name=latency_ns_resolution,json=latencyNsResolution,proto3" json:"latency_ns_resolution,omitempty"` /// resolution, in ns (default 100)
	// contains filtered or unexported fields
}

* The measure module tracks latencies, packets per second, and other statistics. It should be paired with a Timestamp module, which attaches a timestamp to packets. The measure module will log how long (in nanoseconds) it has been for each packet it received since it was timestamped. This module is somewhat experimental and undergoing various changes. There is a test for the the Measure module in [`bessctl/module_tests/timestamp.py`](https://github.com/NetSys/bess/blob/master/bessctl/module_tests/timestamp.py).

__Input Gates__: 1 __Output Gates__: 1

func (*MeasureArg) Descriptor deprecated 

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

Deprecated: Use MeasureArg.ProtoReflect.Descriptor instead.

func (*MeasureArg) GetAttrName 

func (x *MeasureArg) GetAttrName() string

func (*MeasureArg) GetJitterSampleProb 

func (x *MeasureArg) GetJitterSampleProb() float64

func (*MeasureArg) GetLatencyNsMax 

func (x *MeasureArg) GetLatencyNsMax() uint64

func (*MeasureArg) GetLatencyNsResolution 

func (x *MeasureArg) GetLatencyNsResolution() uint32

func (*MeasureArg) GetOffset 

func (x *MeasureArg) GetOffset() uint64

func (*MeasureArg) GetType 

func (m *MeasureArg) GetType() isMeasureArg_Type

func (*MeasureArg) ProtoMessage 

func (*MeasureArg) ProtoMessage()

func (*MeasureArg) ProtoReflect 

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

func (*MeasureArg) Reset 

func (x *MeasureArg) Reset()

func (*MeasureArg) String 

func (x *MeasureArg) String() string

type MeasureArg_AttrName 

type MeasureArg_AttrName struct {
	AttrName string `protobuf:"bytes,6,opt,name=attr_name,json=attrName,proto3,oneof"` /// Where to store the current time as attribute
}

type MeasureArg_Offset 

type MeasureArg_Offset struct {
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3,oneof"` /// Where to store the current time within the packet, offset in bytes.
}

type MeasureCommandGetSummaryArg 

type MeasureCommandGetSummaryArg struct {
	Clear              bool      `protobuf:"varint,1,opt,name=clear,proto3" json:"clear,omitempty"`                                                             /// if true, the data will be all cleared after read
	LatencyPercentiles []float64 `protobuf:"fixed64,2,rep,packed,name=latency_percentiles,json=latencyPercentiles,proto3" json:"latency_percentiles,omitempty"` /// ascending list of real numbers in [0.0, 100.0]
	JitterPercentiles  []float64 `protobuf:"fixed64,3,rep,packed,name=jitter_percentiles,json=jitterPercentiles,proto3" json:"jitter_percentiles,omitempty"`    /// ascending list of real numbers in [0.0, 100.0]
	// contains filtered or unexported fields
}

* The Measure module measures and collects latency/jitter data for packets annotated by a Timestamp module. Note that Timestamp and Measure module must reside on the server for accurate measurement (as a result, the most typical use case is measuring roundtrip time). Optionally, you can also retrieve percentile values by specifying points in "percentiles". For example, "percentiles" of [50.0, 99.0] will return [median, 99'th %-ile tail latency] in "percentile_values_ns" in the response.

func (*MeasureCommandGetSummaryArg) Descriptor deprecated 

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

Deprecated: Use MeasureCommandGetSummaryArg.ProtoReflect.Descriptor instead.

func (*MeasureCommandGetSummaryArg) GetClear 

func (x *MeasureCommandGetSummaryArg) GetClear() bool

func (*MeasureCommandGetSummaryArg) GetJitterPercentiles 

func (x *MeasureCommandGetSummaryArg) GetJitterPercentiles() []float64

func (*MeasureCommandGetSummaryArg) GetLatencyPercentiles 

func (x *MeasureCommandGetSummaryArg) GetLatencyPercentiles() []float64

func (*MeasureCommandGetSummaryArg) ProtoMessage 

func (*MeasureCommandGetSummaryArg) ProtoMessage()

func (*MeasureCommandGetSummaryArg) ProtoReflect 

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

func (*MeasureCommandGetSummaryArg) Reset 

func (x *MeasureCommandGetSummaryArg) Reset()

func (*MeasureCommandGetSummaryArg) String 

func (x *MeasureCommandGetSummaryArg) String() string

type MeasureCommandGetSummaryResponse 

type MeasureCommandGetSummaryResponse struct {
	Timestamp float64                                     `protobuf:"fixed64,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` /// Seconds since boot.
	Packets   uint64                                      `protobuf:"varint,2,opt,name=packets,proto3" json:"packets,omitempty"`      /// Total # of packets seen by this module.
	Bits      uint64                                      `protobuf:"varint,3,opt,name=bits,proto3" json:"bits,omitempty"`            /// Total # of bits seen by this module.
	Latency   *MeasureCommandGetSummaryResponse_Histogram `protobuf:"bytes,4,opt,name=latency,proto3" json:"latency,omitempty"`
	Jitter    *MeasureCommandGetSummaryResponse_Histogram `protobuf:"bytes,5,opt,name=jitter,proto3" json:"jitter,omitempty"`
	// contains filtered or unexported fields
}

* The Measure module function `get_summary()` returns the following values. Note that the resolution value tells you how grainy the samples are, e.g., 100 means that anything from 0-99 ns counts as "0", anything from 100-199 counts as "100", and so on. The average is of samples using this graininess, but (being a result of division) may not be a multiple of the resolution.

func (*MeasureCommandGetSummaryResponse) Descriptor deprecated 

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

Deprecated: Use MeasureCommandGetSummaryResponse.ProtoReflect.Descriptor instead.

func (*MeasureCommandGetSummaryResponse) GetBits 

func (x *MeasureCommandGetSummaryResponse) GetBits() uint64

func (*MeasureCommandGetSummaryResponse) GetJitter 

func (x *MeasureCommandGetSummaryResponse) GetJitter() *MeasureCommandGetSummaryResponse_Histogram

func (*MeasureCommandGetSummaryResponse) GetLatency 

func (x *MeasureCommandGetSummaryResponse) GetLatency() *MeasureCommandGetSummaryResponse_Histogram

func (*MeasureCommandGetSummaryResponse) GetPackets 

func (x *MeasureCommandGetSummaryResponse) GetPackets() uint64

func (*MeasureCommandGetSummaryResponse) GetTimestamp 

func (x *MeasureCommandGetSummaryResponse) GetTimestamp() float64

func (*MeasureCommandGetSummaryResponse) ProtoMessage 

func (*MeasureCommandGetSummaryResponse) ProtoMessage()

func (*MeasureCommandGetSummaryResponse) ProtoReflect 

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

func (*MeasureCommandGetSummaryResponse) Reset 

func (x *MeasureCommandGetSummaryResponse) Reset()

func (*MeasureCommandGetSummaryResponse) String 

func (x *MeasureCommandGetSummaryResponse) String() string

type MeasureCommandGetSummaryResponse_Histogram 

type MeasureCommandGetSummaryResponse_Histogram struct {
	Count              uint64   `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`                                   /// Total # of measured data points, including above_range
	AboveRange         uint64   `protobuf:"varint,2,opt,name=above_range,json=aboveRange,proto3" json:"above_range,omitempty"`       /// # of data points for the "too large value" bucket
	ResolutionNs       uint64   `protobuf:"varint,8,opt,name=resolution_ns,json=resolutionNs,proto3" json:"resolution_ns,omitempty"` /// resolution of measured data
	MinNs              uint64   `protobuf:"varint,3,opt,name=min_ns,json=minNs,proto3" json:"min_ns,omitempty"`
	AvgNs              uint64   `protobuf:"varint,4,opt,name=avg_ns,json=avgNs,proto3" json:"avg_ns,omitempty"`
	MaxNs              uint64   `protobuf:"varint,5,opt,name=max_ns,json=maxNs,proto3" json:"max_ns,omitempty"`
	TotalNs            uint64   `protobuf:"varint,6,opt,name=total_ns,json=totalNs,proto3" json:"total_ns,omitempty"`
	PercentileValuesNs []uint64 `protobuf:"varint,7,rep,packed,name=percentile_values_ns,json=percentileValuesNs,proto3" json:"percentile_values_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*MeasureCommandGetSummaryResponse_Histogram) Descriptor deprecated 

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

Deprecated: Use MeasureCommandGetSummaryResponse_Histogram.ProtoReflect.Descriptor instead.

func (*MeasureCommandGetSummaryResponse_Histogram) GetAboveRange 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetAboveRange() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetAvgNs 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetAvgNs() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetCount 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetCount() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetMaxNs 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetMaxNs() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetMinNs 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetMinNs() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetPercentileValuesNs 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetPercentileValuesNs() []uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetResolutionNs 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetResolutionNs() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) GetTotalNs 

func (x *MeasureCommandGetSummaryResponse_Histogram) GetTotalNs() uint64

func (*MeasureCommandGetSummaryResponse_Histogram) ProtoMessage 

func (*MeasureCommandGetSummaryResponse_Histogram) ProtoMessage()

func (*MeasureCommandGetSummaryResponse_Histogram) ProtoReflect 

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

func (*MeasureCommandGetSummaryResponse_Histogram) Reset 

func (x *MeasureCommandGetSummaryResponse_Histogram) Reset()

func (*MeasureCommandGetSummaryResponse_Histogram) String 

func (x *MeasureCommandGetSummaryResponse_Histogram) String() string

type MempoolDump 

type MempoolDump struct {
	Socket           int32  `protobuf:"varint,1,opt,name=socket,proto3" json:"socket,omitempty"`                                               /// The socket this mempool belongs to
	Initialized      bool   `protobuf:"varint,2,opt,name=initialized,proto3" json:"initialized,omitempty"`                                     /// True when this mempool has been initialized
	MpSize           uint32 `protobuf:"varint,3,opt,name=mp_size,json=mpSize,proto3" json:"mp_size,omitempty"`                                 /// The maximum size of this mempool
	MpCacheSize      uint32 `protobuf:"varint,4,opt,name=mp_cache_size,json=mpCacheSize,proto3" json:"mp_cache_size,omitempty"`                /// Size of per-lcore default local cache.
	MpElementSize    uint32 `protobuf:"varint,5,opt,name=mp_element_size,json=mpElementSize,proto3" json:"mp_element_size,omitempty"`          /// Size of one element
	MpPopulatedSize  uint32 `protobuf:"varint,6,opt,name=mp_populated_size,json=mpPopulatedSize,proto3" json:"mp_populated_size,omitempty"`    /// Number of populated objects
	MpAvailableCount uint32 `protobuf:"varint,7,opt,name=mp_available_count,json=mpAvailableCount,proto3" json:"mp_available_count,omitempty"` /// Number of entries in this mempool
	MpInUseCount     uint32 `protobuf:"varint,8,opt,name=mp_in_use_count,json=mpInUseCount,proto3" json:"mp_in_use_count,omitempty"`           /// Number of elements which have been allocated from this mempool
	RingCount        uint32 `protobuf:"varint,9,opt,name=ring_count,json=ringCount,proto3" json:"ring_count,omitempty"`                        /// Number of entries in the backing ring
	RingFreeCount    uint32 `protobuf:"varint,10,opt,name=ring_free_count,json=ringFreeCount,proto3" json:"ring_free_count,omitempty"`         /// Number of free entries in the backing ring
	RingBytes        uint64 `protobuf:"varint,11,opt,name=ring_bytes,json=ringBytes,proto3" json:"ring_bytes,omitempty"`                       /// Size of the backing ring in bytes
	// contains filtered or unexported fields
}

func (*MempoolDump) Descriptor deprecated 

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

Deprecated: Use MempoolDump.ProtoReflect.Descriptor instead.

func (*MempoolDump) GetInitialized 

func (x *MempoolDump) GetInitialized() bool

func (*MempoolDump) GetMpAvailableCount 

func (x *MempoolDump) GetMpAvailableCount() uint32

func (*MempoolDump) GetMpCacheSize 

func (x *MempoolDump) GetMpCacheSize() uint32

func (*MempoolDump) GetMpElementSize 

func (x *MempoolDump) GetMpElementSize() uint32

func (*MempoolDump) GetMpInUseCount 

func (x *MempoolDump) GetMpInUseCount() uint32

func (*MempoolDump) GetMpPopulatedSize 

func (x *MempoolDump) GetMpPopulatedSize() uint32

func (*MempoolDump) GetMpSize 

func (x *MempoolDump) GetMpSize() uint32

func (*MempoolDump) GetRingBytes 

func (x *MempoolDump) GetRingBytes() uint64

func (*MempoolDump) GetRingCount 

func (x *MempoolDump) GetRingCount() uint32

func (*MempoolDump) GetRingFreeCount 

func (x *MempoolDump) GetRingFreeCount() uint32

func (*MempoolDump) GetSocket 

func (x *MempoolDump) GetSocket() int32

func (*MempoolDump) ProtoMessage 

func (*MempoolDump) ProtoMessage()

func (*MempoolDump) ProtoReflect 

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

func (*MempoolDump) Reset 

func (x *MempoolDump) Reset()

func (*MempoolDump) String 

func (x *MempoolDump) String() string

type MergeArg 

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

* The merge module takes no parameters. It has multiple input gates, and passes out all packets from a single output gate.

__Input Gates__: many (configurable) __Output Gates__: 1

func (*MergeArg) Descriptor deprecated 

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

Deprecated: Use MergeArg.ProtoReflect.Descriptor instead.

func (*MergeArg) ProtoMessage 

func (*MergeArg) ProtoMessage()

func (*MergeArg) ProtoReflect 

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

func (*MergeArg) Reset 

func (x *MergeArg) Reset()

func (*MergeArg) String 

func (x *MergeArg) String() string

type MetadataTestArg 

type MetadataTestArg struct {
	Read   map[string]int64 `` /* 150-byte string literal not displayed */
	Write  map[string]int64 `` /* 152-byte string literal not displayed */
	Update map[string]int64 `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

* The MetadataTest module is used for internal testing purposes.

func (*MetadataTestArg) Descriptor deprecated 

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

Deprecated: Use MetadataTestArg.ProtoReflect.Descriptor instead.

func (*MetadataTestArg) GetRead 

func (x *MetadataTestArg) GetRead() map[string]int64

func (*MetadataTestArg) GetUpdate 

func (x *MetadataTestArg) GetUpdate() map[string]int64

func (*MetadataTestArg) GetWrite 

func (x *MetadataTestArg) GetWrite() map[string]int64

func (*MetadataTestArg) ProtoMessage 

func (*MetadataTestArg) ProtoMessage()

func (*MetadataTestArg) ProtoReflect 

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

func (*MetadataTestArg) Reset 

func (x *MetadataTestArg) Reset()

func (*MetadataTestArg) String 

func (x *MetadataTestArg) String() string

type MplsPopArg 

type MplsPopArg struct {
	RemoveEthHeader bool   `protobuf:"varint,1,opt,name=remove_eth_header,json=removeEthHeader,proto3" json:"remove_eth_header,omitempty"` /// Remove ETH header with the pop
	NextEthType     uint32 `protobuf:"varint,2,opt,name=next_eth_type,json=nextEthType,proto3" json:"next_eth_type,omitempty"`             /// The next ETH type to set
	// contains filtered or unexported fields
}

* The MPLS pop module removes MPLS labels

__Input Gates__: 1 __Output Gates__: 2

func (*MplsPopArg) Descriptor deprecated 

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

Deprecated: Use MplsPopArg.ProtoReflect.Descriptor instead.

func (*MplsPopArg) GetNextEthType 

func (x *MplsPopArg) GetNextEthType() uint32

func (*MplsPopArg) GetRemoveEthHeader 

func (x *MplsPopArg) GetRemoveEthHeader() bool

func (*MplsPopArg) ProtoMessage 

func (*MplsPopArg) ProtoMessage()

func (*MplsPopArg) ProtoReflect 

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

func (*MplsPopArg) Reset 

func (x *MplsPopArg) Reset()

func (*MplsPopArg) String 

func (x *MplsPopArg) String() string

type NATArg 

type NATArg struct {
	ExtAddrs []*NATArg_ExternalAddress `protobuf:"bytes,1,rep,name=ext_addrs,json=extAddrs,proto3" json:"ext_addrs,omitempty"` /// list of external IP addresses
	// contains filtered or unexported fields
}

* The NAT module implements Dynamic IPv4 address/port translation, rewriting packet source addresses with external addresses as specified, and destination addresses for packets on the reverse direction. L3/L4 checksums are updated correspondingly. To see an example of NAT in use, see: [`bess/bessctl/conf/samples/nat.bess`](https://github.com/NetSys/bess/blob/master/bessctl/conf/samples/nat.bess)

Currently only supports TCP/UDP/ICMP. Note that address/port in packet payload (e.g., FTP) are NOT translated.

__Input Gates__: 2 (0 for internal->external, and 1 for external->internal direction) __Output Gates__: 2 (same as the input gate)

func (*NATArg) Descriptor deprecated 

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

Deprecated: Use NATArg.ProtoReflect.Descriptor instead.

func (*NATArg) GetExtAddrs 

func (x *NATArg) GetExtAddrs() []*NATArg_ExternalAddress

func (*NATArg) ProtoMessage 

func (*NATArg) ProtoMessage()

func (*NATArg) ProtoReflect 

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

func (*NATArg) Reset 

func (x *NATArg) Reset()

func (*NATArg) String 

func (x *NATArg) String() string

type NATArg_ExternalAddress 

type NATArg_ExternalAddress struct {
	ExtAddr    string              `protobuf:"bytes,1,opt,name=ext_addr,json=extAddr,proto3" json:"ext_addr,omitempty"`
	PortRanges []*NATArg_PortRange `protobuf:"bytes,2,rep,name=port_ranges,json=portRanges,proto3" json:"port_ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*NATArg_ExternalAddress) Descriptor deprecated 

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

Deprecated: Use NATArg_ExternalAddress.ProtoReflect.Descriptor instead.

func (*NATArg_ExternalAddress) GetExtAddr 

func (x *NATArg_ExternalAddress) GetExtAddr() string

func (*NATArg_ExternalAddress) GetPortRanges 

func (x *NATArg_ExternalAddress) GetPortRanges() []*NATArg_PortRange

func (*NATArg_ExternalAddress) ProtoMessage 

func (*NATArg_ExternalAddress) ProtoMessage()

func (*NATArg_ExternalAddress) ProtoReflect 

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

func (*NATArg_ExternalAddress) Reset 

func (x *NATArg_ExternalAddress) Reset()

func (*NATArg_ExternalAddress) String 

func (x *NATArg_ExternalAddress) String() string

type NATArg_PortRange 

type NATArg_PortRange struct {
	Begin     uint32 `protobuf:"varint,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End       uint32 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	Suspended bool   `protobuf:"varint,3,opt,name=suspended,proto3" json:"suspended,omitempty"`
	// contains filtered or unexported fields
}

func (*NATArg_PortRange) Descriptor deprecated 

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

Deprecated: Use NATArg_PortRange.ProtoReflect.Descriptor instead.

func (*NATArg_PortRange) GetBegin 

func (x *NATArg_PortRange) GetBegin() uint32

func (*NATArg_PortRange) GetEnd 

func (x *NATArg_PortRange) GetEnd() uint32

func (*NATArg_PortRange) GetSuspended 

func (x *NATArg_PortRange) GetSuspended() bool

func (*NATArg_PortRange) ProtoMessage 

func (*NATArg_PortRange) ProtoMessage()

func (*NATArg_PortRange) ProtoReflect 

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

func (*NATArg_PortRange) Reset 

func (x *NATArg_PortRange) Reset()

func (*NATArg_PortRange) String 

func (x *NATArg_PortRange) String() string

type NoOpArg 

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

* This module is used for testing purposes.

func (*NoOpArg) Descriptor deprecated 

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

Deprecated: Use NoOpArg.ProtoReflect.Descriptor instead.

func (*NoOpArg) ProtoMessage 

func (*NoOpArg) ProtoMessage()

func (*NoOpArg) ProtoReflect 

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

func (*NoOpArg) Reset 

func (x *NoOpArg) Reset()

func (*NoOpArg) String 

func (x *NoOpArg) String() string

type PauseWorkerRequest 

type PauseWorkerRequest struct {
	Wid int64 `protobuf:"varint,1,opt,name=wid,proto3" json:"wid,omitempty"` /// ID of the worker to be paused
	// contains filtered or unexported fields
}

func (*PauseWorkerRequest) Descriptor deprecated 

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

Deprecated: Use PauseWorkerRequest.ProtoReflect.Descriptor instead.

func (*PauseWorkerRequest) GetWid 

func (x *PauseWorkerRequest) GetWid() int64

func (*PauseWorkerRequest) ProtoMessage 

func (*PauseWorkerRequest) ProtoMessage()

func (*PauseWorkerRequest) ProtoReflect 

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

func (*PauseWorkerRequest) Reset 

func (x *PauseWorkerRequest) Reset()

func (*PauseWorkerRequest) String 

func (x *PauseWorkerRequest) String() string

type PcapngArg 

type PcapngArg struct {
	Fifo      string `protobuf:"bytes,5,opt,name=fifo,proto3" json:"fifo,omitempty"`            /// Path to the FIFO file.
	Defer     bool   `protobuf:"varint,6,opt,name=defer,proto3" json:"defer,omitempty"`         /// If set, we'll defer opening the FIFO.
	Reconnect bool   `protobuf:"varint,7,opt,name=reconnect,proto3" json:"reconnect,omitempty"` /// If set, we'll reconnect after failure.
	// contains filtered or unexported fields
}

/ Enable/Disable pcapng tapping at an input/output gate. / / Once the tap is installed, all packets going through the gate will be / captured and sent in pcapng format to the specified named pipe (FIFO). / Unlike the Tcpdump hook, this also dumps a textual metadata representation, / in the form of a comment to the Enhanced Packet Block. Thus you can run / `tcpdump -r <path to FIFO>` or save the stream in a file. / This feature may affect performance. / / NOTE: There should be no running worker to run this command.

func (*PcapngArg) Descriptor deprecated 

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

Deprecated: Use PcapngArg.ProtoReflect.Descriptor instead.

func (*PcapngArg) GetDefer 

func (x *PcapngArg) GetDefer() bool

func (*PcapngArg) GetFifo 

func (x *PcapngArg) GetFifo() string

func (*PcapngArg) GetReconnect 

func (x *PcapngArg) GetReconnect() bool

func (*PcapngArg) ProtoMessage 

func (*PcapngArg) ProtoMessage()

func (*PcapngArg) ProtoReflect 

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

func (*PcapngArg) Reset 

func (x *PcapngArg) Reset()

func (*PcapngArg) String 

func (x *PcapngArg) String() string

type PortConf 

type PortConf struct {

	/// MAC address for the new port. Should be "xx:xx:xx:xx:xx:xx" format.
	/// Set to '00:00:00:00:00:00' to use the default/current MAC address
	MacAddr string `protobuf:"bytes,1,opt,name=mac_addr,json=macAddr,proto3" json:"mac_addr,omitempty"`
	/// Port MTU. Set to 0 to accept the default port MTU
	Mtu uint32 `protobuf:"varint,2,opt,name=mtu,proto3" json:"mtu,omitempty"`
	/// Enable or disable the port.
	/// Both admin and link (operational) states must be up to function
	AdminUp bool `protobuf:"varint,3,opt,name=admin_up,json=adminUp,proto3" json:"admin_up,omitempty"`
	// contains filtered or unexported fields
}

/ All configuration parameters updatable at runtime

func (*PortConf) Descriptor deprecated 

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

Deprecated: Use PortConf.ProtoReflect.Descriptor instead.

func (*PortConf) GetAdminUp 

func (x *PortConf) GetAdminUp() bool

func (*PortConf) GetMacAddr 

func (x *PortConf) GetMacAddr() string

func (*PortConf) GetMtu 

func (x *PortConf) GetMtu() uint32

func (*PortConf) ProtoMessage 

func (*PortConf) ProtoMessage()

func (*PortConf) ProtoReflect 

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

func (*PortConf) Reset 

func (x *PortConf) Reset()

func (*PortConf) String 

func (x *PortConf) String() string

type PortIncArg 

type PortIncArg struct {
	Port     string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"`          /// The portname to connect to.
	Prefetch bool   `protobuf:"varint,2,opt,name=prefetch,proto3" json:"prefetch,omitempty"` /// Whether or not to prefetch packets from the port.
	// contains filtered or unexported fields
}

* The PortInc module connects a physical or virtual port and releases packets from it. PortInc does not support multiqueueing. For details on how to configure PortInc using DPDK, virtual ports, or libpcap, see the sidebar in the wiki.

__Input Gates__: 0 __Output Gates__: 1

func (*PortIncArg) Descriptor deprecated 

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

Deprecated: Use PortIncArg.ProtoReflect.Descriptor instead.

func (*PortIncArg) GetPort 

func (x *PortIncArg) GetPort() string

func (*PortIncArg) GetPrefetch 

func (x *PortIncArg) GetPrefetch() bool

func (*PortIncArg) ProtoMessage 

func (*PortIncArg) ProtoMessage()

func (*PortIncArg) ProtoReflect 

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

func (*PortIncArg) Reset 

func (x *PortIncArg) Reset()

func (*PortIncArg) String 

func (x *PortIncArg) String() string

type PortIncCommandSetBurstArg 

type PortIncCommandSetBurstArg struct {
	Burst uint64 `protobuf:"varint,1,opt,name=burst,proto3" json:"burst,omitempty"` /// The maximum "burst" of packets (ie, the maximum batch size)
	// contains filtered or unexported fields
}

* The module PortInc has a function `set_burst(...)` that allows you to specify the maximum number of packets to be stored in a single PacketBatch released by the module.

func (*PortIncCommandSetBurstArg) Descriptor deprecated 

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

Deprecated: Use PortIncCommandSetBurstArg.ProtoReflect.Descriptor instead.

func (*PortIncCommandSetBurstArg) GetBurst 

func (x *PortIncCommandSetBurstArg) GetBurst() uint64

func (*PortIncCommandSetBurstArg) ProtoMessage 

func (*PortIncCommandSetBurstArg) ProtoMessage()

func (*PortIncCommandSetBurstArg) ProtoReflect 

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

func (*PortIncCommandSetBurstArg) Reset 

func (x *PortIncCommandSetBurstArg) Reset()

func (*PortIncCommandSetBurstArg) String 

func (x *PortIncCommandSetBurstArg) String() string

type PortOutArg 

type PortOutArg struct {
	Port string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"` /// The portname to connect to.
	// contains filtered or unexported fields
}

* The PortOut module connects to a physical or virtual port and pushes packets to it. For details on how to configure PortOut with DPDK, virtual ports, libpcap, etc, see the sidebar in the wiki.

__Input Gates__: 1 __Output Gates__: 0

func (*PortOutArg) Descriptor deprecated 

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

Deprecated: Use PortOutArg.ProtoReflect.Descriptor instead.

func (*PortOutArg) GetPort 

func (x *PortOutArg) GetPort() string

func (*PortOutArg) ProtoMessage 

func (*PortOutArg) ProtoMessage()

func (*PortOutArg) ProtoReflect 

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

func (*PortOutArg) Reset 

func (x *PortOutArg) Reset()

func (*PortOutArg) String 

func (x *PortOutArg) String() string

type QosArg 

type QosArg struct {
	Fields  []*Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	Values  []*Field `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	Entries uint64   `protobuf:"varint,3,opt,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*QosArg) Descriptor deprecated 

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

Deprecated: Use QosArg.ProtoReflect.Descriptor instead.

func (*QosArg) GetEntries 

func (x *QosArg) GetEntries() uint64

func (*QosArg) GetFields 

func (x *QosArg) GetFields() []*Field

func (*QosArg) GetValues 

func (x *QosArg) GetValues() []*Field

func (*QosArg) ProtoMessage 

func (*QosArg) ProtoMessage()

func (*QosArg) ProtoReflect 

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

func (*QosArg) Reset 

func (x *QosArg) Reset()

func (*QosArg) String 

func (x *QosArg) String() string

type QosCommandAddArg 

type QosCommandAddArg struct {
	Gate uint64 `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"`
	Cir  uint64 `protobuf:"varint,2,opt,name=cir,proto3" json:"cir,omitempty"`
	Pir  uint64 `protobuf:"varint,3,opt,name=pir,proto3" json:"pir,omitempty"`
	Cbs  uint64 `protobuf:"varint,4,opt,name=cbs,proto3" json:"cbs,omitempty"`
	Pbs  uint64 `protobuf:"varint,5,opt,name=pbs,proto3" json:"pbs,omitempty"`
	Ebs  uint64 `protobuf:"varint,6,opt,name=ebs,proto3" json:"ebs,omitempty"`
	// Types that are assignable to OptionalDeductLen:
	//	*QosCommandAddArg_DeductLen
	OptionalDeductLen isQosCommandAddArg_OptionalDeductLen `protobuf_oneof:"optional_deduct_len"`
	Fields            []*FieldData                         `protobuf:"bytes,7,rep,name=fields,proto3" json:"fields,omitempty"`
	Values            []*FieldData                         `protobuf:"bytes,8,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*QosCommandAddArg) Descriptor deprecated 

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

Deprecated: Use QosCommandAddArg.ProtoReflect.Descriptor instead.

func (*QosCommandAddArg) GetCbs 

func (x *QosCommandAddArg) GetCbs() uint64

func (*QosCommandAddArg) GetCir 

func (x *QosCommandAddArg) GetCir() uint64

func (*QosCommandAddArg) GetDeductLen 

func (x *QosCommandAddArg) GetDeductLen() int64

func (*QosCommandAddArg) GetEbs 

func (x *QosCommandAddArg) GetEbs() uint64

func (*QosCommandAddArg) GetFields 

func (x *QosCommandAddArg) GetFields() []*FieldData

func (*QosCommandAddArg) GetGate 

func (x *QosCommandAddArg) GetGate() uint64

func (*QosCommandAddArg) GetOptionalDeductLen 

func (m *QosCommandAddArg) GetOptionalDeductLen() isQosCommandAddArg_OptionalDeductLen

func (*QosCommandAddArg) GetPbs 

func (x *QosCommandAddArg) GetPbs() uint64

func (*QosCommandAddArg) GetPir 

func (x *QosCommandAddArg) GetPir() uint64

func (*QosCommandAddArg) GetValues 

func (x *QosCommandAddArg) GetValues() []*FieldData

func (*QosCommandAddArg) ProtoMessage 

func (*QosCommandAddArg) ProtoMessage()

func (*QosCommandAddArg) ProtoReflect 

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

func (*QosCommandAddArg) Reset 

func (x *QosCommandAddArg) Reset()

func (*QosCommandAddArg) String 

func (x *QosCommandAddArg) String() string

type QosCommandAddArg_DeductLen 

type QosCommandAddArg_DeductLen struct {
	DeductLen int64 `protobuf:"varint,9,opt,name=deduct_len,json=deductLen,proto3,oneof"`
}

type QosCommandClearArg 

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

* The function `clear()` for WildcardMatch takes no parameters, it clears all state in the WildcardMatch module (is equivalent to calling delete for all rules)

func (*QosCommandClearArg) Descriptor deprecated 

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

Deprecated: Use QosCommandClearArg.ProtoReflect.Descriptor instead.

func (*QosCommandClearArg) ProtoMessage 

func (*QosCommandClearArg) ProtoMessage()

func (*QosCommandClearArg) ProtoReflect 

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

func (*QosCommandClearArg) Reset 

func (x *QosCommandClearArg) Reset()

func (*QosCommandClearArg) String 

func (x *QosCommandClearArg) String() string

type QosCommandDeleteArg 

type QosCommandDeleteArg struct {
	Fields []*FieldData `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*QosCommandDeleteArg) Descriptor deprecated 

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

Deprecated: Use QosCommandDeleteArg.ProtoReflect.Descriptor instead.

func (*QosCommandDeleteArg) GetFields 

func (x *QosCommandDeleteArg) GetFields() []*FieldData

func (*QosCommandDeleteArg) ProtoMessage 

func (*QosCommandDeleteArg) ProtoMessage()

func (*QosCommandDeleteArg) ProtoReflect 

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

func (*QosCommandDeleteArg) Reset 

func (x *QosCommandDeleteArg) Reset()

func (*QosCommandDeleteArg) String 

func (x *QosCommandDeleteArg) String() string

type QosCommandSetDefaultGateArg 

type QosCommandSetDefaultGateArg struct {
	Gate uint64 `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"`
	// contains filtered or unexported fields
}

* For traffic which does not match any rule in the WildcardMatch module, the `set_default_gate(...)` function specifies which gate to send this extra traffic to.

func (*QosCommandSetDefaultGateArg) Descriptor deprecated 

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

Deprecated: Use QosCommandSetDefaultGateArg.ProtoReflect.Descriptor instead.

func (*QosCommandSetDefaultGateArg) GetGate 

func (x *QosCommandSetDefaultGateArg) GetGate() uint64

func (*QosCommandSetDefaultGateArg) ProtoMessage 

func (*QosCommandSetDefaultGateArg) ProtoMessage()

func (*QosCommandSetDefaultGateArg) ProtoReflect 

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

func (*QosCommandSetDefaultGateArg) Reset 

func (x *QosCommandSetDefaultGateArg) Reset()

func (*QosCommandSetDefaultGateArg) String 

func (x *QosCommandSetDefaultGateArg) String() string

type QueueArg 

type QueueArg struct {
	Size         uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`                 /// The maximum number of packets to store in the queue.
	Prefetch     bool   `protobuf:"varint,2,opt,name=prefetch,proto3" json:"prefetch,omitempty"`         /// When prefetch is enabled, the module will perform CPU prefetch on the first 64B of each packet onto CPU L1 cache. Default value is false.
	Backpressure bool   `protobuf:"varint,3,opt,name=backpressure,proto3" json:"backpressure,omitempty"` // When backpressure is enabled, the module will notify upstream if it is overloaded.
	// contains filtered or unexported fields
}

* The Queue module implements a simple packet queue.

__Input Gates__: 1 __Output Gates__: 1

func (*QueueArg) Descriptor deprecated 

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

Deprecated: Use QueueArg.ProtoReflect.Descriptor instead.

func (*QueueArg) GetBackpressure 

func (x *QueueArg) GetBackpressure() bool

func (*QueueArg) GetPrefetch 

func (x *QueueArg) GetPrefetch() bool

func (*QueueArg) GetSize 

func (x *QueueArg) GetSize() uint64

func (*QueueArg) ProtoMessage 

func (*QueueArg) ProtoMessage()

func (*QueueArg) ProtoReflect 

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

func (*QueueArg) Reset 

func (x *QueueArg) Reset()

func (*QueueArg) String 

func (x *QueueArg) String() string

type QueueCommandGetStatusArg 

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

* Modules that are queues or contain queues may contain functions `get_status()` that return QueueCommandGetStatusResponse.

func (*QueueCommandGetStatusArg) Descriptor deprecated 

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

Deprecated: Use QueueCommandGetStatusArg.ProtoReflect.Descriptor instead.

func (*QueueCommandGetStatusArg) ProtoMessage 

func (*QueueCommandGetStatusArg) ProtoMessage()

func (*QueueCommandGetStatusArg) ProtoReflect 

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

func (*QueueCommandGetStatusArg) Reset 

func (x *QueueCommandGetStatusArg) Reset()

func (*QueueCommandGetStatusArg) String 

func (x *QueueCommandGetStatusArg) String() string

type QueueCommandGetStatusResponse 

type QueueCommandGetStatusResponse struct {
	Count    uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`       /// The number of packets currently in the queue.
	Size     uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`         /// The maximum number of packets the queue can contain.
	Enqueued uint64 `protobuf:"varint,3,opt,name=enqueued,proto3" json:"enqueued,omitempty"` /// total enqueued
	Dequeued uint64 `protobuf:"varint,4,opt,name=dequeued,proto3" json:"dequeued,omitempty"` /// total dequeued
	Dropped  uint64 `protobuf:"varint,5,opt,name=dropped,proto3" json:"dropped,omitempty"`   /// total dropped
	// contains filtered or unexported fields
}

* Modules that are queues or contain queues may contain functions `get_status()` that take no parameters and returns the queue occupancy and size.

func (*QueueCommandGetStatusResponse) Descriptor deprecated 

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

Deprecated: Use QueueCommandGetStatusResponse.ProtoReflect.Descriptor instead.

func (*QueueCommandGetStatusResponse) GetCount 

func (x *QueueCommandGetStatusResponse) GetCount() uint64

func (*QueueCommandGetStatusResponse) GetDequeued 

func (x *QueueCommandGetStatusResponse) GetDequeued() uint64

func (*QueueCommandGetStatusResponse) GetDropped 

func (x *QueueCommandGetStatusResponse) GetDropped() uint64

func (*QueueCommandGetStatusResponse) GetEnqueued 

func (x *QueueCommandGetStatusResponse) GetEnqueued() uint64

func (*QueueCommandGetStatusResponse) GetSize 

func (x *QueueCommandGetStatusResponse) GetSize() uint64

func (*QueueCommandGetStatusResponse) ProtoMessage 

func (*QueueCommandGetStatusResponse) ProtoMessage()

func (*QueueCommandGetStatusResponse) ProtoReflect 

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

func (*QueueCommandGetStatusResponse) Reset 

func (x *QueueCommandGetStatusResponse) Reset()

func (*QueueCommandGetStatusResponse) String 

func (x *QueueCommandGetStatusResponse) String() string

type QueueCommandSetBurstArg 

type QueueCommandSetBurstArg struct {
	Burst uint64 `protobuf:"varint,1,opt,name=burst,proto3" json:"burst,omitempty"` /// The maximum "burst" of packets (ie, the maximum batch size)
	// contains filtered or unexported fields
}

* The module Queue has a function `set_burst(...)` that allows you to specify the maximum number of packets to be stored in a single PacketBatch released by the module.

func (*QueueCommandSetBurstArg) Descriptor deprecated 

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

Deprecated: Use QueueCommandSetBurstArg.ProtoReflect.Descriptor instead.

func (*QueueCommandSetBurstArg) GetBurst 

func (x *QueueCommandSetBurstArg) GetBurst() uint64

func (*QueueCommandSetBurstArg) ProtoMessage 

func (*QueueCommandSetBurstArg) ProtoMessage()

func (*QueueCommandSetBurstArg) ProtoReflect 

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

func (*QueueCommandSetBurstArg) Reset 

func (x *QueueCommandSetBurstArg) Reset()

func (*QueueCommandSetBurstArg) String 

func (x *QueueCommandSetBurstArg) String() string

type QueueCommandSetSizeArg 

type QueueCommandSetSizeArg struct {
	Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` /// The maximum number of packets to store in the queue.
	// contains filtered or unexported fields
}

* The module Queue has a function `set_size(...)` that allows specifying the size of the queue in total number of packets.

func (*QueueCommandSetSizeArg) Descriptor deprecated 

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

Deprecated: Use QueueCommandSetSizeArg.ProtoReflect.Descriptor instead.

func (*QueueCommandSetSizeArg) GetSize 

func (x *QueueCommandSetSizeArg) GetSize() uint64

func (*QueueCommandSetSizeArg) ProtoMessage 

func (*QueueCommandSetSizeArg) ProtoMessage()

func (*QueueCommandSetSizeArg) ProtoReflect 

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

func (*QueueCommandSetSizeArg) Reset 

func (x *QueueCommandSetSizeArg) Reset()

func (*QueueCommandSetSizeArg) String 

func (x *QueueCommandSetSizeArg) String() string

type QueueIncArg 

type QueueIncArg struct {
	Port     string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"`          /// The portname to connect to (read from).
	Qid      uint64 `protobuf:"varint,2,opt,name=qid,proto3" json:"qid,omitempty"`           /// The queue on that port to read from. qid starts from 0.
	Prefetch bool   `protobuf:"varint,3,opt,name=prefetch,proto3" json:"prefetch,omitempty"` /// When prefetch is enabled, the module will perform CPU prefetch on the first 64B of each packet onto CPU L1 cache. Default value is false.
	// contains filtered or unexported fields
}

* The module QueueInc produces input packets from a physical or virtual port. Unlike PortInc, it supports multiqueue ports. For details on how to configure QueueInc with DPDK, virtualports, libpcap, etc, see the sidebar in the wiki.

__Input Gates__: 0 __Output Gates__: 1

func (*QueueIncArg) Descriptor deprecated 

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

Deprecated: Use QueueIncArg.ProtoReflect.Descriptor instead.

func (*QueueIncArg) GetPort 

func (x *QueueIncArg) GetPort() string

func (*QueueIncArg) GetPrefetch 

func (x *QueueIncArg) GetPrefetch() bool

func (*QueueIncArg) GetQid 

func (x *QueueIncArg) GetQid() uint64

func (*QueueIncArg) ProtoMessage 

func (*QueueIncArg) ProtoMessage()

func (*QueueIncArg) ProtoReflect 

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

func (*QueueIncArg) Reset 

func (x *QueueIncArg) Reset()

func (*QueueIncArg) String 

func (x *QueueIncArg) String() string

type QueueIncCommandSetBurstArg 

type QueueIncCommandSetBurstArg struct {
	Burst uint64 `protobuf:"varint,1,opt,name=burst,proto3" json:"burst,omitempty"` /// The maximum "burst" of packets (ie, the maximum batch size)
	// contains filtered or unexported fields
}

* The module QueueInc has a function `set_burst(...)` that allows you to specify the maximum number of packets to be stored in a single PacketBatch released by the module.

func (*QueueIncCommandSetBurstArg) Descriptor deprecated 

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

Deprecated: Use QueueIncCommandSetBurstArg.ProtoReflect.Descriptor instead.

func (*QueueIncCommandSetBurstArg) GetBurst 

func (x *QueueIncCommandSetBurstArg) GetBurst() uint64

func (*QueueIncCommandSetBurstArg) ProtoMessage 

func (*QueueIncCommandSetBurstArg) ProtoMessage()

func (*QueueIncCommandSetBurstArg) ProtoReflect 

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

func (*QueueIncCommandSetBurstArg) Reset 

func (x *QueueIncCommandSetBurstArg) Reset()

func (*QueueIncCommandSetBurstArg) String 

func (x *QueueIncCommandSetBurstArg) String() string

type QueueOutArg 

type QueueOutArg struct {
	Port string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"` /// The portname to connect to.
	Qid  uint64 `protobuf:"varint,2,opt,name=qid,proto3" json:"qid,omitempty"`  /// The queue on that port to write out to.
	// contains filtered or unexported fields
}

* The QueueOut module releases packets to a physical or virtual port. Unlike PortOut, it supports multiqueue ports. For details on how to configure QueueOut with DPDK, virtualports, libpcap, etc, see the sidebar in the wiki.

__Input Gates__: 1 __Output Gates__: 0

func (*QueueOutArg) Descriptor deprecated 

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

Deprecated: Use QueueOutArg.ProtoReflect.Descriptor instead.

func (*QueueOutArg) GetPort 

func (x *QueueOutArg) GetPort() string

func (*QueueOutArg) GetQid 

func (x *QueueOutArg) GetQid() uint64

func (*QueueOutArg) ProtoMessage 

func (*QueueOutArg) ProtoMessage()

func (*QueueOutArg) ProtoReflect 

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

func (*QueueOutArg) Reset 

func (x *QueueOutArg) Reset()

func (*QueueOutArg) String 

func (x *QueueOutArg) String() string

type RandomSplitArg 

type RandomSplitArg struct {
	DropRate float64 `protobuf:"fixed64,1,opt,name=drop_rate,json=dropRate,proto3" json:"drop_rate,omitempty"` /// Probability of dropping packet.
	Gates    []int64 `protobuf:"varint,2,rep,packed,name=gates,proto3" json:"gates,omitempty"`                 /// A list of gate numbers to split the traffic.
	// contains filtered or unexported fields
}

* The RandomSplit module randomly split/drop packets

__InputGates__: 1 __Output Gates__: many (configurable)

func (*RandomSplitArg) Descriptor deprecated 

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

Deprecated: Use RandomSplitArg.ProtoReflect.Descriptor instead.

func (*RandomSplitArg) GetDropRate 

func (x *RandomSplitArg) GetDropRate() float64

func (*RandomSplitArg) GetGates 

func (x *RandomSplitArg) GetGates() []int64

func (*RandomSplitArg) ProtoMessage 

func (*RandomSplitArg) ProtoMessage()

func (*RandomSplitArg) ProtoReflect 

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

func (*RandomSplitArg) Reset 

func (x *RandomSplitArg) Reset()

func (*RandomSplitArg) String 

func (x *RandomSplitArg) String() string

type RandomSplitCommandSetDroprateArg 

type RandomSplitCommandSetDroprateArg struct {
	DropRate float64 `protobuf:"fixed64,1,opt,name=drop_rate,json=dropRate,proto3" json:"drop_rate,omitempty"` /// Probability of dropping packet.
	// contains filtered or unexported fields
}

* The RandomSplit module has a function `set_droprate(...)` which specifies the probability of dropping packets

func (*RandomSplitCommandSetDroprateArg) Descriptor deprecated 

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

Deprecated: Use RandomSplitCommandSetDroprateArg.ProtoReflect.Descriptor instead.

func (*RandomSplitCommandSetDroprateArg) GetDropRate 

func (x *RandomSplitCommandSetDroprateArg) GetDropRate() float64

func (*RandomSplitCommandSetDroprateArg) ProtoMessage 

func (*RandomSplitCommandSetDroprateArg) ProtoMessage()

func (*RandomSplitCommandSetDroprateArg) ProtoReflect 

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

func (*RandomSplitCommandSetDroprateArg) Reset 

func (x *RandomSplitCommandSetDroprateArg) Reset()

func (*RandomSplitCommandSetDroprateArg) String 

func (x *RandomSplitCommandSetDroprateArg) String() string

type RandomSplitCommandSetGatesArg 

type RandomSplitCommandSetGatesArg struct {
	Gates []int64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// A list of gate numbers to split the traffic.
	// contains filtered or unexported fields
}

* The RandomSplit module has a function `set_gates(...)` which changes the total number of output gates in the module.

func (*RandomSplitCommandSetGatesArg) Descriptor deprecated 

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

Deprecated: Use RandomSplitCommandSetGatesArg.ProtoReflect.Descriptor instead.

func (*RandomSplitCommandSetGatesArg) GetGates 

func (x *RandomSplitCommandSetGatesArg) GetGates() []int64

func (*RandomSplitCommandSetGatesArg) ProtoMessage 

func (*RandomSplitCommandSetGatesArg) ProtoMessage()

func (*RandomSplitCommandSetGatesArg) ProtoReflect 

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

func (*RandomSplitCommandSetGatesArg) Reset 

func (x *RandomSplitCommandSetGatesArg) Reset()

func (*RandomSplitCommandSetGatesArg) String 

func (x *RandomSplitCommandSetGatesArg) String() string

type RandomUpdateArg 

type RandomUpdateArg struct {
	Fields []*RandomUpdateArg_Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` /// A list of Random Update Fields.
	// contains filtered or unexported fields
}

* The RandomUpdate module rewrites a specified field (`offset` and `size`) in a packet with a random value between a specified min and max values.

__Input Gates__: 1 __Output Gates__: 1

func (*RandomUpdateArg) Descriptor deprecated 

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

Deprecated: Use RandomUpdateArg.ProtoReflect.Descriptor instead.

func (*RandomUpdateArg) GetFields 

func (x *RandomUpdateArg) GetFields() []*RandomUpdateArg_Field

func (*RandomUpdateArg) ProtoMessage 

func (*RandomUpdateArg) ProtoMessage()

func (*RandomUpdateArg) ProtoReflect 

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

func (*RandomUpdateArg) Reset 

func (x *RandomUpdateArg) Reset()

func (*RandomUpdateArg) String 

func (x *RandomUpdateArg) String() string

type RandomUpdateArg_Field 

type RandomUpdateArg_Field struct {
	Offset int64  `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` /// Offset in bytes of where to rewrite.
	Size   uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`     /// The number of bytes to write.
	Min    uint64 `protobuf:"varint,3,opt,name=min,proto3" json:"min,omitempty"`       /// The minimum value to insert into the packet.
	Max    uint64 `protobuf:"varint,4,opt,name=max,proto3" json:"max,omitempty"`       /// The maximum value to insert into the packet.
	// contains filtered or unexported fields
}

* RandomUpdate's Field specifies where to rewrite, and what values to rewrite in each packet processed.

func (*RandomUpdateArg_Field) Descriptor deprecated 

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

Deprecated: Use RandomUpdateArg_Field.ProtoReflect.Descriptor instead.

func (*RandomUpdateArg_Field) GetMax 

func (x *RandomUpdateArg_Field) GetMax() uint64

func (*RandomUpdateArg_Field) GetMin 

func (x *RandomUpdateArg_Field) GetMin() uint64

func (*RandomUpdateArg_Field) GetOffset 

func (x *RandomUpdateArg_Field) GetOffset() int64

func (*RandomUpdateArg_Field) GetSize 

func (x *RandomUpdateArg_Field) GetSize() uint64

func (*RandomUpdateArg_Field) ProtoMessage 

func (*RandomUpdateArg_Field) ProtoMessage()

func (*RandomUpdateArg_Field) ProtoReflect 

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

func (*RandomUpdateArg_Field) Reset 

func (x *RandomUpdateArg_Field) Reset()

func (*RandomUpdateArg_Field) String 

func (x *RandomUpdateArg_Field) String() string

type RandomUpdateCommandClearArg 

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

* The function `clear()` for RandomUpdate takes no parameters and clears all state in the module.

func (*RandomUpdateCommandClearArg) Descriptor deprecated 

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

Deprecated: Use RandomUpdateCommandClearArg.ProtoReflect.Descriptor instead.

func (*RandomUpdateCommandClearArg) ProtoMessage 

func (*RandomUpdateCommandClearArg) ProtoMessage()

func (*RandomUpdateCommandClearArg) ProtoReflect 

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

func (*RandomUpdateCommandClearArg) Reset 

func (x *RandomUpdateCommandClearArg) Reset()

func (*RandomUpdateCommandClearArg) String 

func (x *RandomUpdateCommandClearArg) String() string

type ReplicateArg 

type ReplicateArg struct {
	Gates []int64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// A list of gate numbers to send packet copies to.
	// contains filtered or unexported fields
}

* The Replicate module makes copies of a packet sending one copy out over each of n output gates.

__Input Gates__: 1 __Output Gates__: many (configurable)

func (*ReplicateArg) Descriptor deprecated 

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

Deprecated: Use ReplicateArg.ProtoReflect.Descriptor instead.

func (*ReplicateArg) GetGates 

func (x *ReplicateArg) GetGates() []int64

func (*ReplicateArg) ProtoMessage 

func (*ReplicateArg) ProtoMessage()

func (*ReplicateArg) ProtoReflect 

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

func (*ReplicateArg) Reset 

func (x *ReplicateArg) Reset()

func (*ReplicateArg) String 

func (x *ReplicateArg) String() string

type ReplicateCommandSetGatesArg 

type ReplicateCommandSetGatesArg struct {
	Gates []int64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// A list of gate numbers to replicate the traffic over.
	// contains filtered or unexported fields
}

* The Replicate module has a function `set_gates(...)` which changes the total number of output gates in the module.

func (*ReplicateCommandSetGatesArg) Descriptor deprecated 

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

Deprecated: Use ReplicateCommandSetGatesArg.ProtoReflect.Descriptor instead.

func (*ReplicateCommandSetGatesArg) GetGates 

func (x *ReplicateCommandSetGatesArg) GetGates() []int64

func (*ReplicateCommandSetGatesArg) ProtoMessage 

func (*ReplicateCommandSetGatesArg) ProtoMessage()

func (*ReplicateCommandSetGatesArg) ProtoReflect 

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

func (*ReplicateCommandSetGatesArg) Reset 

func (x *ReplicateCommandSetGatesArg) Reset()

func (*ReplicateCommandSetGatesArg) String 

func (x *ReplicateCommandSetGatesArg) String() string

type ResumeWorkerRequest 

type ResumeWorkerRequest struct {
	Wid int64 `protobuf:"varint,1,opt,name=wid,proto3" json:"wid,omitempty"` /// ID of the worker to be resumed
	// contains filtered or unexported fields
}

func (*ResumeWorkerRequest) Descriptor deprecated 

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

Deprecated: Use ResumeWorkerRequest.ProtoReflect.Descriptor instead.

func (*ResumeWorkerRequest) GetWid 

func (x *ResumeWorkerRequest) GetWid() int64

func (*ResumeWorkerRequest) ProtoMessage 

func (*ResumeWorkerRequest) ProtoMessage()

func (*ResumeWorkerRequest) ProtoReflect 

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

func (*ResumeWorkerRequest) Reset 

func (x *ResumeWorkerRequest) Reset()

func (*ResumeWorkerRequest) String 

func (x *ResumeWorkerRequest) String() string

type RewriteArg 

type RewriteArg struct {
	Templates [][]byte `protobuf:"bytes,1,rep,name=templates,proto3" json:"templates,omitempty"` /// A list of bytestrings representing packet templates.
	// contains filtered or unexported fields
}

* The Rewrite module replaces an entire packet body with a packet "template" converting all packets that pass through to copies of the of one of the templates.

__Input Gates__: 1 __Output Gates__: 1

func (*RewriteArg) Descriptor deprecated 

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

Deprecated: Use RewriteArg.ProtoReflect.Descriptor instead.

func (*RewriteArg) GetTemplates 

func (x *RewriteArg) GetTemplates() [][]byte

func (*RewriteArg) ProtoMessage 

func (*RewriteArg) ProtoMessage()

func (*RewriteArg) ProtoReflect 

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

func (*RewriteArg) Reset 

func (x *RewriteArg) Reset()

func (*RewriteArg) String 

func (x *RewriteArg) String() string

type RewriteCommandClearArg 

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

* The function `clear()` for Rewrite takes no parameters and clears all state in the module.

func (*RewriteCommandClearArg) Descriptor deprecated 

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

Deprecated: Use RewriteCommandClearArg.ProtoReflect.Descriptor instead.

func (*RewriteCommandClearArg) ProtoMessage 

func (*RewriteCommandClearArg) ProtoMessage()

func (*RewriteCommandClearArg) ProtoReflect 

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

func (*RewriteCommandClearArg) Reset 

func (x *RewriteCommandClearArg) Reset()

func (*RewriteCommandClearArg) String 

func (x *RewriteCommandClearArg) String() string

type RoundRobinArg 

type RoundRobinArg struct {
	Gates []int64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// A list of gate numbers to split packets across.
	Mode  string  `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`           /// Whether to split across gate with every `'packet'` or every `'batch'`.
	// contains filtered or unexported fields
}

* The RoundRobin module splits packets from one input gate across multiple output gates.

__Input Gates__: 1 __Output Gates__: many (configurable)

func (*RoundRobinArg) Descriptor deprecated 

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

Deprecated: Use RoundRobinArg.ProtoReflect.Descriptor instead.

func (*RoundRobinArg) GetGates 

func (x *RoundRobinArg) GetGates() []int64

func (*RoundRobinArg) GetMode 

func (x *RoundRobinArg) GetMode() string

func (*RoundRobinArg) ProtoMessage 

func (*RoundRobinArg) ProtoMessage()

func (*RoundRobinArg) ProtoReflect 

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

func (*RoundRobinArg) Reset 

func (x *RoundRobinArg) Reset()

func (*RoundRobinArg) String 

func (x *RoundRobinArg) String() string

type RoundRobinCommandSetGatesArg 

type RoundRobinCommandSetGatesArg struct {
	Gates []int64 `protobuf:"varint,1,rep,packed,name=gates,proto3" json:"gates,omitempty"` /// A list of gate numbers to round-robin the traffic over.
	// contains filtered or unexported fields
}

* The RoundRobin module has a function `set_gates(...)` which changes the total number of output gates in the module.

func (*RoundRobinCommandSetGatesArg) Descriptor deprecated 

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

Deprecated: Use RoundRobinCommandSetGatesArg.ProtoReflect.Descriptor instead.

func (*RoundRobinCommandSetGatesArg) GetGates 

func (x *RoundRobinCommandSetGatesArg) GetGates() []int64

func (*RoundRobinCommandSetGatesArg) ProtoMessage 

func (*RoundRobinCommandSetGatesArg) ProtoMessage()

func (*RoundRobinCommandSetGatesArg) ProtoReflect 

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

func (*RoundRobinCommandSetGatesArg) Reset 

func (x *RoundRobinCommandSetGatesArg) Reset()

func (*RoundRobinCommandSetGatesArg) String 

func (x *RoundRobinCommandSetGatesArg) String() string

type RoundRobinCommandSetModeArg 

type RoundRobinCommandSetModeArg struct {
	Mode string `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"` /// whether to perform `'packet'` or `'batch'` round robin partitioning.
	// contains filtered or unexported fields
}

* The RoundRobin module has a function `set_mode(...)` which specifies whether to balance traffic across gates per-packet or per-batch.

func (*RoundRobinCommandSetModeArg) Descriptor deprecated 

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

Deprecated: Use RoundRobinCommandSetModeArg.ProtoReflect.Descriptor instead.

func (*RoundRobinCommandSetModeArg) GetMode 

func (x *RoundRobinCommandSetModeArg) GetMode() string

func (*RoundRobinCommandSetModeArg) ProtoMessage 

func (*RoundRobinCommandSetModeArg) ProtoMessage()

func (*RoundRobinCommandSetModeArg) ProtoReflect 

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

func (*RoundRobinCommandSetModeArg) Reset 

func (x *RoundRobinCommandSetModeArg) Reset()

func (*RoundRobinCommandSetModeArg) String 

func (x *RoundRobinCommandSetModeArg) String() string

type SetMetadataArg 

type SetMetadataArg struct {
	Attrs []*SetMetadataArg_Attribute `protobuf:"bytes,1,rep,name=attrs,proto3" json:"attrs,omitempty"` /// A list of attributes to attach to the packet.
	// contains filtered or unexported fields
}

* The SetMetadata module adds metadata attributes to packets, which are not stored or sent out with packet data. For examples of SetMetadata use, see [`bess/bessctl/conf/attr_match.bess`](https://github.com/NetSys/bess/blob/master/bessctl/conf/metadata/attr_match.bess)

__Input Gates__: 1 __Output Gates__: 1

func (*SetMetadataArg) Descriptor deprecated 

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

Deprecated: Use SetMetadataArg.ProtoReflect.Descriptor instead.

func (*SetMetadataArg) GetAttrs 

func (x *SetMetadataArg) GetAttrs() []*SetMetadataArg_Attribute

func (*SetMetadataArg) ProtoMessage 

func (*SetMetadataArg) ProtoMessage()

func (*SetMetadataArg) ProtoReflect 

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

func (*SetMetadataArg) Reset 

func (x *SetMetadataArg) Reset()

func (*SetMetadataArg) String 

func (x *SetMetadataArg) String() string

type SetMetadataArg_Attribute 

type SetMetadataArg_Attribute struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`  /// The metadata attribute name.
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` /// The size of values stored in this attribute in bytes.
	// Types that are assignable to Value:
	//	*SetMetadataArg_Attribute_ValueInt
	//	*SetMetadataArg_Attribute_ValueBin
	Value      isSetMetadataArg_Attribute_Value `protobuf_oneof:"value"`
	Offset     int32                            `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`                           /// An index in the packet data to store copy into the metadata attribute.
	Mask       []byte                           `protobuf:"bytes,6,opt,name=mask,proto3" json:"mask,omitempty"`                                /// An array of bit masks to apply to each of the bytes copied starting from `offset`. If empty, the mask `[0xFF,....,0xFF]` will be used.
	RshiftBits int32                            `protobuf:"varint,7,opt,name=rshift_bits,json=rshiftBits,proto3" json:"rshift_bits,omitempty"` /// The number of bits to shift the value at `offset` by before masking. Must be a multiple of 8. Positive and negative values represent right and left shifts respectively.
	// contains filtered or unexported fields
}

* SetMetadata Attribute describes a metadata attribute and value to attach to every packet. If copying data from a packet buffer, SetMetadata can also logically shift then mask the value before storing it as metadata, i.e., metadata_value = (packet_value >> `rshift_bits`) & `mask`.

func (*SetMetadataArg_Attribute) Descriptor deprecated 

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

Deprecated: Use SetMetadataArg_Attribute.ProtoReflect.Descriptor instead.

func (*SetMetadataArg_Attribute) GetMask 

func (x *SetMetadataArg_Attribute) GetMask() []byte

func (*SetMetadataArg_Attribute) GetName 

func (x *SetMetadataArg_Attribute) GetName() string

func (*SetMetadataArg_Attribute) GetOffset 

func (x *SetMetadataArg_Attribute) GetOffset() int32

func (*SetMetadataArg_Attribute) GetRshiftBits 

func (x *SetMetadataArg_Attribute) GetRshiftBits() int32

func (*SetMetadataArg_Attribute) GetSize 

func (x *SetMetadataArg_Attribute) GetSize() uint64

func (*SetMetadataArg_Attribute) GetValue 

func (m *SetMetadataArg_Attribute) GetValue() isSetMetadataArg_Attribute_Value

func (*SetMetadataArg_Attribute) GetValueBin 

func (x *SetMetadataArg_Attribute) GetValueBin() []byte

func (*SetMetadataArg_Attribute) GetValueInt 

func (x *SetMetadataArg_Attribute) GetValueInt() uint64

func (*SetMetadataArg_Attribute) ProtoMessage 

func (*SetMetadataArg_Attribute) ProtoMessage()

func (*SetMetadataArg_Attribute) ProtoReflect 

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

func (*SetMetadataArg_Attribute) Reset 

func (x *SetMetadataArg_Attribute) Reset()

func (*SetMetadataArg_Attribute) String 

func (x *SetMetadataArg_Attribute) String() string

type SetMetadataArg_Attribute_ValueBin 

type SetMetadataArg_Attribute_ValueBin struct {
	ValueBin []byte `protobuf:"bytes,4,opt,name=value_bin,json=valueBin,proto3,oneof"` /// A binary value to store in the packet (host-order).
}

type SetMetadataArg_Attribute_ValueInt 

type SetMetadataArg_Attribute_ValueInt struct {
	ValueInt uint64 `protobuf:"varint,3,opt,name=value_int,json=valueInt,proto3,oneof"` /// An integer value to store in the packet (host-order).
}

type SetPortConfRequest 

type SetPortConfRequest struct {
	Name string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` /// Name of port
	Conf *PortConf `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*SetPortConfRequest) Descriptor deprecated 

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

Deprecated: Use SetPortConfRequest.ProtoReflect.Descriptor instead.

func (*SetPortConfRequest) GetConf 

func (x *SetPortConfRequest) GetConf() *PortConf

func (*SetPortConfRequest) GetName 

func (x *SetPortConfRequest) GetName() string

func (*SetPortConfRequest) ProtoMessage 

func (*SetPortConfRequest) ProtoMessage()

func (*SetPortConfRequest) ProtoReflect 

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

func (*SetPortConfRequest) Reset 

func (x *SetPortConfRequest) Reset()

func (*SetPortConfRequest) String 

func (x *SetPortConfRequest) String() string

type SinkArg 

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

* The sink module drops all packets that are sent to it.

__Input Gates__: 1 __Output Gates__: 0

func (*SinkArg) Descriptor deprecated 

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

Deprecated: Use SinkArg.ProtoReflect.Descriptor instead.

func (*SinkArg) ProtoMessage 

func (*SinkArg) ProtoMessage()

func (*SinkArg) ProtoReflect 

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

func (*SinkArg) Reset 

func (x *SinkArg) Reset()

func (*SinkArg) String 

func (x *SinkArg) String() string

type SourceArg 

type SourceArg struct {
	PktSize uint64 `protobuf:"varint,1,opt,name=pkt_size,json=pktSize,proto3" json:"pkt_size,omitempty"` /// The size (in bytes) of packet data to produce.
	// contains filtered or unexported fields
}

* The Source module generates packets with no payload contents.

__Input Gates__: 0 __Output Gates__: 1

func (*SourceArg) Descriptor deprecated 

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

Deprecated: Use SourceArg.ProtoReflect.Descriptor instead.

func (*SourceArg) GetPktSize 

func (x *SourceArg) GetPktSize() uint64

func (*SourceArg) ProtoMessage 

func (*SourceArg) ProtoMessage()

func (*SourceArg) ProtoReflect 

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

func (*SourceArg) Reset 

func (x *SourceArg) Reset()

func (*SourceArg) String 

func (x *SourceArg) String() string

type SourceCommandSetBurstArg 

type SourceCommandSetBurstArg struct {
	Burst uint64 `protobuf:"varint,1,opt,name=burst,proto3" json:"burst,omitempty"` /// The maximum number of packets to release in a packetbatch from the module.
	// contains filtered or unexported fields
}

* The Source module has a function `set_burst(...)` which specifies the maximum number of packets to release in a single packetbatch from the module.

func (*SourceCommandSetBurstArg) Descriptor deprecated 

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

Deprecated: Use SourceCommandSetBurstArg.ProtoReflect.Descriptor instead.

func (*SourceCommandSetBurstArg) GetBurst 

func (x *SourceCommandSetBurstArg) GetBurst() uint64

func (*SourceCommandSetBurstArg) ProtoMessage 

func (*SourceCommandSetBurstArg) ProtoMessage()

func (*SourceCommandSetBurstArg) ProtoReflect 

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

func (*SourceCommandSetBurstArg) Reset 

func (x *SourceCommandSetBurstArg) Reset()

func (*SourceCommandSetBurstArg) String 

func (x *SourceCommandSetBurstArg) String() string

type SourceCommandSetPktSizeArg 

type SourceCommandSetPktSizeArg struct {
	PktSize uint64 `protobuf:"varint,1,opt,name=pkt_size,json=pktSize,proto3" json:"pkt_size,omitempty"` /// The size (in bytes) of the packets for Source to create.
	// contains filtered or unexported fields
}

* The Source module has a function `set_pkt_size(...)` which specifies the size of packets to be produced by the Source module.

func (*SourceCommandSetPktSizeArg) Descriptor deprecated 

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

Deprecated: Use SourceCommandSetPktSizeArg.ProtoReflect.Descriptor instead.

func (*SourceCommandSetPktSizeArg) GetPktSize 

func (x *SourceCommandSetPktSizeArg) GetPktSize() uint64

func (*SourceCommandSetPktSizeArg) ProtoMessage 

func (*SourceCommandSetPktSizeArg) ProtoMessage()

func (*SourceCommandSetPktSizeArg) ProtoReflect 

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

func (*SourceCommandSetPktSizeArg) Reset 

func (x *SourceCommandSetPktSizeArg) Reset()

func (*SourceCommandSetPktSizeArg) String 

func (x *SourceCommandSetPktSizeArg) String() string

type SplitArg 

type SplitArg struct {
	Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` /// The size of the value to read in bytes
	// Types that are assignable to Type:
	//	*SplitArg_Attribute
	//	*SplitArg_Offset
	Type isSplitArg_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

* The Split module is a basic classifier which directs packets out a gate based on data in the packet (e.g., if the read in value is 3, the packet is directed out output gate 3).

__Input Gates__: 1 __Output Gates__: many (up to 2^(size * 8))

func (*SplitArg) Descriptor deprecated 

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

Deprecated: Use SplitArg.ProtoReflect.Descriptor instead.

func (*SplitArg) GetAttribute 

func (x *SplitArg) GetAttribute() string

func (*SplitArg) GetOffset 

func (x *SplitArg) GetOffset() int64

func (*SplitArg) GetSize 

func (x *SplitArg) GetSize() uint64

func (*SplitArg) GetType 

func (m *SplitArg) GetType() isSplitArg_Type

func (*SplitArg) ProtoMessage 

func (*SplitArg) ProtoMessage()

func (*SplitArg) ProtoReflect 

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

func (*SplitArg) Reset 

func (x *SplitArg) Reset()

func (*SplitArg) String 

func (x *SplitArg) String() string

type SplitArg_Attribute 

type SplitArg_Attribute struct {
	Attribute string `protobuf:"bytes,2,opt,name=attribute,proto3,oneof"` /// The name of the metadata field to read.
}

type SplitArg_Offset 

type SplitArg_Offset struct {
	Offset int64 `protobuf:"varint,3,opt,name=offset,proto3,oneof"` /// The offset (in bytes) of the data field to read.
}

type StaticNATArg 

type StaticNATArg struct {
	Pairs []*StaticNATArg_AddressRangePair `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

* Static NAT module implements one-to-one translation of source/destination IPv4 addresses. No port number is translated. L3/L4 checksums are updated correspondingly. To see an example of NAT in use, see: [`bess/bessctl/conf/samples/nat.bess`](https://github.com/NetSys/bess/blob/master/bessctl/conf/samples/nat.bess)

Forward direction (from input gate 0 to output gate 0):

  • Source IP address is updated, from internal to external address.

Reverse direction (from input gate 1 to output gate 1):

  • Destination IP address is updated, from external to internal address.

If the original address is outside any of the ranges, packets are forwarded without NAT.

Note that address in packet payload (e.g., FTP) are NOT translated.

__Input Gates__: 2 (0 for internal->external, and 1 for external->internal direction) __Output Gates__: 2 (same as the input gate)

func (*StaticNATArg) Descriptor deprecated 

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

Deprecated: Use StaticNATArg.ProtoReflect.Descriptor instead.

func (*StaticNATArg) GetPairs 

func (x *StaticNATArg) GetPairs() []*StaticNATArg_AddressRangePair

func (*StaticNATArg) ProtoMessage 

func (*StaticNATArg) ProtoMessage()

func (*StaticNATArg) ProtoReflect 

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

func (*StaticNATArg) Reset 

func (x *StaticNATArg) Reset()

func (*StaticNATArg) String 

func (x *StaticNATArg) String() string

type StaticNATArg_AddressRange 

type StaticNATArg_AddressRange struct {
	Start string `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` /// first IP address to use
	End   string `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`     /// last IP address to use
	// contains filtered or unexported fields
}

func (*StaticNATArg_AddressRange) Descriptor deprecated 

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

Deprecated: Use StaticNATArg_AddressRange.ProtoReflect.Descriptor instead.

func (*StaticNATArg_AddressRange) GetEnd 

func (x *StaticNATArg_AddressRange) GetEnd() string

func (*StaticNATArg_AddressRange) GetStart 

func (x *StaticNATArg_AddressRange) GetStart() string

func (*StaticNATArg_AddressRange) ProtoMessage 

func (*StaticNATArg_AddressRange) ProtoMessage()

func (*StaticNATArg_AddressRange) ProtoReflect 

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

func (*StaticNATArg_AddressRange) Reset 

func (x *StaticNATArg_AddressRange) Reset()

func (*StaticNATArg_AddressRange) String 

func (x *StaticNATArg_AddressRange) String() string

type StaticNATArg_AddressRangePair 

type StaticNATArg_AddressRangePair struct {
	IntRange *StaticNATArg_AddressRange `protobuf:"bytes,1,opt,name=int_range,json=intRange,proto3" json:"int_range,omitempty"`
	ExtRange *StaticNATArg_AddressRange `protobuf:"bytes,2,opt,name=ext_range,json=extRange,proto3" json:"ext_range,omitempty"` /// should be the same size as int_range
	// contains filtered or unexported fields
}

func (*StaticNATArg_AddressRangePair) Descriptor deprecated 

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

Deprecated: Use StaticNATArg_AddressRangePair.ProtoReflect.Descriptor instead.

func (*StaticNATArg_AddressRangePair) GetExtRange 

func (x *StaticNATArg_AddressRangePair) GetExtRange() *StaticNATArg_AddressRange

func (*StaticNATArg_AddressRangePair) GetIntRange 

func (x *StaticNATArg_AddressRangePair) GetIntRange() *StaticNATArg_AddressRange

func (*StaticNATArg_AddressRangePair) ProtoMessage 

func (*StaticNATArg_AddressRangePair) ProtoMessage()

func (*StaticNATArg_AddressRangePair) ProtoReflect 

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

func (*StaticNATArg_AddressRangePair) Reset 

func (x *StaticNATArg_AddressRangePair) Reset()

func (*StaticNATArg_AddressRangePair) String 

func (x *StaticNATArg_AddressRangePair) String() string

type TcpdumpArg 

type TcpdumpArg struct {
	Fifo      string `protobuf:"bytes,5,opt,name=fifo,proto3" json:"fifo,omitempty"`            /// Path to the FIFO file.
	Defer     bool   `protobuf:"varint,6,opt,name=defer,proto3" json:"defer,omitempty"`         /// If set, we'll defer opening the FIFO.
	Reconnect bool   `protobuf:"varint,7,opt,name=reconnect,proto3" json:"reconnect,omitempty"` /// If set, we'll reconnect after failure.
	// contains filtered or unexported fields
}

/ Enable/Disable tcpdump tapping at an input/output gate. / / Once the tap is installed, all packets going through the gate will be / captured and sent in PCAP format to the specified named pipe (FIFO). / Thus you can run `tcpdump -r <path to FIFO>` or save the stream in a file. / This feature may affect performance. / / NOTE: There should be no running worker to run this command.

func (*TcpdumpArg) Descriptor deprecated 

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

Deprecated: Use TcpdumpArg.ProtoReflect.Descriptor instead.

func (*TcpdumpArg) GetDefer 

func (x *TcpdumpArg) GetDefer() bool

func (*TcpdumpArg) GetFifo 

func (x *TcpdumpArg) GetFifo() string

func (*TcpdumpArg) GetReconnect 

func (x *TcpdumpArg) GetReconnect() bool

func (*TcpdumpArg) ProtoMessage 

func (*TcpdumpArg) ProtoMessage()

func (*TcpdumpArg) ProtoReflect 

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

func (*TcpdumpArg) Reset 

func (x *TcpdumpArg) Reset()

func (*TcpdumpArg) String 

func (x *TcpdumpArg) String() string

type TimestampArg 

type TimestampArg struct {

	// Types that are assignable to Type:
	//	*TimestampArg_Offset
	//	*TimestampArg_AttrName
	Type isTimestampArg_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

* The timestamp module takes an offset parameter. It inserts the current time in nanoseconds into the packet, to be used for latency measurements alongside the Measure module. The default offset is after an IPv4 UDP header.

__Input Gates__: 1 __Output Gates__: 1

func (*TimestampArg) Descriptor deprecated 

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

Deprecated: Use TimestampArg.ProtoReflect.Descriptor instead.

func (*TimestampArg) GetAttrName 

func (x *TimestampArg) GetAttrName() string

func (*TimestampArg) GetOffset 

func (x *TimestampArg) GetOffset() uint64

func (*TimestampArg) GetType 

func (m *TimestampArg) GetType() isTimestampArg_Type

func (*TimestampArg) ProtoMessage 

func (*TimestampArg) ProtoMessage()

func (*TimestampArg) ProtoReflect 

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

func (*TimestampArg) Reset 

func (x *TimestampArg) Reset()

func (*TimestampArg) String 

func (x *TimestampArg) String() string

type TimestampArg_AttrName 

type TimestampArg_AttrName struct {
	AttrName string `protobuf:"bytes,2,opt,name=attr_name,json=attrName,proto3,oneof"`
}

type TimestampArg_Offset 

type TimestampArg_Offset struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3,oneof"`
}

type TrackArg 

type TrackArg struct {
	Bits bool `protobuf:"varint,5,opt,name=bits,proto3" json:"bits,omitempty"` /// Tracks bits too if True, else only packets and batches
	// contains filtered or unexported fields
}

/ Enable/Disable the "Track" hook on a gate (or all gates) / / "Track" hook accumulates the number of total packets, batches and bits / passing through a gate. This incurs some amount of CPU overheads. While / the cost is very small, remember that the delay adds up at every gate. / / NOTE: There should be no running worker to run this command.

func (*TrackArg) Descriptor deprecated 

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

Deprecated: Use TrackArg.ProtoReflect.Descriptor instead.

func (*TrackArg) GetBits 

func (x *TrackArg) GetBits() bool

func (*TrackArg) ProtoMessage 

func (*TrackArg) ProtoMessage()

func (*TrackArg) ProtoReflect 

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

func (*TrackArg) Reset 

func (x *TrackArg) Reset()

func (*TrackArg) String 

func (x *TrackArg) String() string

type TrafficClass 

type TrafficClass struct {
	Parent  string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`    /// Name of parent TC
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`        /// Name of TC
	Blocked bool   `protobuf:"varint,3,opt,name=blocked,proto3" json:"blocked,omitempty"` /// Is it running or ready to run at the moment?
	/// One of "priority", "weighted_fair", "round_robin", "rate_limit", "leaf"
	Policy string `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
	/// Type of resource to regulate. Only used for traffic classes of
	/// weighted_fair and rate_limit types.
	/// Should be one of resource types: "count", "cycle", "packet", "bit"
	Resource string `protobuf:"bytes,5,opt,name=resource,proto3" json:"resource,omitempty"`
	// Types that are assignable to Arg:
	//	*TrafficClass_Priority
	//	*TrafficClass_Share
	Arg isTrafficClass_Arg `protobuf_oneof:"arg"`
	/// Worker ID that this TC belongs to. If -1, the TC will be assigned
	/// to an arbitrary worker.
	Wid int64 `protobuf:"varint,8,opt,name=wid,proto3" json:"wid,omitempty"`
	/// Long-term average of resource limit, in cycles/s, packets/s, ...
	Limit map[string]int64 `` /* 152-byte string literal not displayed */
	/// Burst allowance of resource limit, in cycles, packets, bits, ...
	/// If set to 0, no extra tokens will be saved.
	MaxBurst map[string]int64 `` /* 175-byte string literal not displayed */
	/// Only for "leaf": the task executed by this class.
	LeafModuleName   string `protobuf:"bytes,11,opt,name=leaf_module_name,json=leafModuleName,proto3" json:"leaf_module_name,omitempty"`
	LeafModuleTaskid uint64 `protobuf:"varint,12,opt,name=leaf_module_taskid,json=leafModuleTaskid,proto3" json:"leaf_module_taskid,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficClass) Descriptor deprecated 

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

Deprecated: Use TrafficClass.ProtoReflect.Descriptor instead.

func (*TrafficClass) GetArg 

func (m *TrafficClass) GetArg() isTrafficClass_Arg

func (*TrafficClass) GetBlocked 

func (x *TrafficClass) GetBlocked() bool

func (*TrafficClass) GetLeafModuleName 

func (x *TrafficClass) GetLeafModuleName() string

func (*TrafficClass) GetLeafModuleTaskid 

func (x *TrafficClass) GetLeafModuleTaskid() uint64

func (*TrafficClass) GetLimit 

func (x *TrafficClass) GetLimit() map[string]int64

func (*TrafficClass) GetMaxBurst 

func (x *TrafficClass) GetMaxBurst() map[string]int64

func (*TrafficClass) GetName 

func (x *TrafficClass) GetName() string

func (*TrafficClass) GetParent 

func (x *TrafficClass) GetParent() string

func (*TrafficClass) GetPolicy 

func (x *TrafficClass) GetPolicy() string

func (*TrafficClass) GetPriority 

func (x *TrafficClass) GetPriority() int64

func (*TrafficClass) GetResource 

func (x *TrafficClass) GetResource() string

func (*TrafficClass) GetShare 

func (x *TrafficClass) GetShare() int64

func (*TrafficClass) GetWid 

func (x *TrafficClass) GetWid() int64

func (*TrafficClass) ProtoMessage 

func (*TrafficClass) ProtoMessage()

func (*TrafficClass) ProtoReflect 

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

func (*TrafficClass) Reset 

func (x *TrafficClass) Reset()

func (*TrafficClass) String 

func (x *TrafficClass) String() string

type TrafficClass_Priority 

type TrafficClass_Priority struct {
	/// Used by "priority". Lower number == high priority.
	//  FIXME: should be higher number == higher priority, to be consistent
	//         other uses of "priority" in BESS
	Priority int64 `protobuf:"varint,6,opt,name=priority,proto3,oneof"`
}

type TrafficClass_Share 

type TrafficClass_Share struct {
	/// Relative weight (share), used by "weighted_fair".
	/// 1 <= share <= 1024 is recommended. Higher number will result in
	/// lower scheduling accuracy.
	Share int64 `protobuf:"varint,7,opt,name=share,proto3,oneof"`
}

type UnimplementedBESSControlServer 

type UnimplementedBESSControlServer struct {
}

UnimplementedBESSControlServer can be embedded to have forward compatible implementations.

func (*UnimplementedBESSControlServer) AddTc 

func (*UnimplementedBESSControlServer) AddTc(context.Context, *AddTcRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) AddWorker 

func (*UnimplementedBESSControlServer) AddWorker(context.Context, *AddWorkerRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) CheckSchedulingConstraints 

func (*UnimplementedBESSControlServer) CheckSchedulingConstraints(context.Context, *EmptyRequest) (*CheckSchedulingConstraintsResponse, error)

func (*UnimplementedBESSControlServer) ConfigureGateHook 

func (*UnimplementedBESSControlServer) ConfigureGateHook(context.Context, *ConfigureGateHookRequest) (*ConfigureGateHookResponse, error)

func (*UnimplementedBESSControlServer) ConfigureResumeHook 

func (*UnimplementedBESSControlServer) ConfigureResumeHook(context.Context, *ConfigureResumeHookRequest) (*CommandResponse, error)

func (*UnimplementedBESSControlServer) ConnectModules 

func (*UnimplementedBESSControlServer) ConnectModules(context.Context, *ConnectModulesRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) CreateModule 

func (*UnimplementedBESSControlServer) CreateModule(context.Context, *CreateModuleRequest) (*CreateModuleResponse, error)

func (*UnimplementedBESSControlServer) CreatePort 

func (*UnimplementedBESSControlServer) CreatePort(context.Context, *CreatePortRequest) (*CreatePortResponse, error)

func (*UnimplementedBESSControlServer) DestroyModule 

func (*UnimplementedBESSControlServer) DestroyModule(context.Context, *DestroyModuleRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) DestroyPort 

func (*UnimplementedBESSControlServer) DestroyPort(context.Context, *DestroyPortRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) DestroyWorker 

func (*UnimplementedBESSControlServer) DestroyWorker(context.Context, *DestroyWorkerRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) DisconnectModules 

func (*UnimplementedBESSControlServer) DisconnectModules(context.Context, *DisconnectModulesRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) DumpMempool 

func (*UnimplementedBESSControlServer) DumpMempool(context.Context, *DumpMempoolRequest) (*DumpMempoolResponse, error)

func (*UnimplementedBESSControlServer) GateHookCommand 

func (*UnimplementedBESSControlServer) GateHookCommand(context.Context, *GateHookCommandRequest) (*CommandResponse, error)

func (*UnimplementedBESSControlServer) GetDriverInfo 

func (*UnimplementedBESSControlServer) GetDriverInfo(context.Context, *GetDriverInfoRequest) (*GetDriverInfoResponse, error)

func (*UnimplementedBESSControlServer) GetGateHookClassInfo 

func (*UnimplementedBESSControlServer) GetGateHookClassInfo(context.Context, *GetGateHookClassInfoRequest) (*GetGateHookClassInfoResponse, error)

func (*UnimplementedBESSControlServer) GetLinkStatus 

func (*UnimplementedBESSControlServer) GetLinkStatus(context.Context, *GetLinkStatusRequest) (*GetLinkStatusResponse, error)

func (*UnimplementedBESSControlServer) GetMclassInfo 

func (*UnimplementedBESSControlServer) GetMclassInfo(context.Context, *GetMclassInfoRequest) (*GetMclassInfoResponse, error)

func (*UnimplementedBESSControlServer) GetModuleInfo 

func (*UnimplementedBESSControlServer) GetModuleInfo(context.Context, *GetModuleInfoRequest) (*GetModuleInfoResponse, error)

func (*UnimplementedBESSControlServer) GetPortConf 

func (*UnimplementedBESSControlServer) GetPortConf(context.Context, *GetPortConfRequest) (*GetPortConfResponse, error)

func (*UnimplementedBESSControlServer) GetPortStats 

func (*UnimplementedBESSControlServer) GetPortStats(context.Context, *GetPortStatsRequest) (*GetPortStatsResponse, error)

func (*UnimplementedBESSControlServer) GetTcStats 

func (*UnimplementedBESSControlServer) GetTcStats(context.Context, *GetTcStatsRequest) (*GetTcStatsResponse, error)

func (*UnimplementedBESSControlServer) GetVersion 

func (*UnimplementedBESSControlServer) GetVersion(context.Context, *EmptyRequest) (*VersionResponse, error)

func (*UnimplementedBESSControlServer) ImportPlugin 

func (*UnimplementedBESSControlServer) ImportPlugin(context.Context, *ImportPluginRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) KillBess 

func (*UnimplementedBESSControlServer) KillBess(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ListDrivers 

func (*UnimplementedBESSControlServer) ListDrivers(context.Context, *EmptyRequest) (*ListDriversResponse, error)

func (*UnimplementedBESSControlServer) ListGateHookClass 

func (*UnimplementedBESSControlServer) ListGateHookClass(context.Context, *EmptyRequest) (*ListGateHookClassResponse, error)

func (*UnimplementedBESSControlServer) ListGateHooks 

func (*UnimplementedBESSControlServer) ListGateHooks(context.Context, *EmptyRequest) (*ListGateHooksResponse, error)

func (*UnimplementedBESSControlServer) ListMclass 

func (*UnimplementedBESSControlServer) ListMclass(context.Context, *EmptyRequest) (*ListMclassResponse, error)

func (*UnimplementedBESSControlServer) ListModules 

func (*UnimplementedBESSControlServer) ListModules(context.Context, *EmptyRequest) (*ListModulesResponse, error)

func (*UnimplementedBESSControlServer) ListPlugins 

func (*UnimplementedBESSControlServer) ListPlugins(context.Context, *EmptyRequest) (*ListPluginsResponse, error)

func (*UnimplementedBESSControlServer) ListPorts 

func (*UnimplementedBESSControlServer) ListPorts(context.Context, *EmptyRequest) (*ListPortsResponse, error)

func (*UnimplementedBESSControlServer) ListTcs 

func (*UnimplementedBESSControlServer) ListTcs(context.Context, *ListTcsRequest) (*ListTcsResponse, error)

func (*UnimplementedBESSControlServer) ListWorkers 

func (*UnimplementedBESSControlServer) ListWorkers(context.Context, *EmptyRequest) (*ListWorkersResponse, error)

func (*UnimplementedBESSControlServer) ModuleCommand 

func (*UnimplementedBESSControlServer) ModuleCommand(context.Context, *CommandRequest) (*CommandResponse, error)

func (*UnimplementedBESSControlServer) PauseAll 

func (*UnimplementedBESSControlServer) PauseAll(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) PauseWorker 

func (*UnimplementedBESSControlServer) PauseWorker(context.Context, *PauseWorkerRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResetAll 

func (*UnimplementedBESSControlServer) ResetAll(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResetModules 

func (*UnimplementedBESSControlServer) ResetModules(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResetPorts 

func (*UnimplementedBESSControlServer) ResetPorts(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResetTcs 

func (*UnimplementedBESSControlServer) ResetTcs(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResetWorkers 

func (*UnimplementedBESSControlServer) ResetWorkers(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResumeAll 

func (*UnimplementedBESSControlServer) ResumeAll(context.Context, *EmptyRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) ResumeWorker 

func (*UnimplementedBESSControlServer) ResumeWorker(context.Context, *ResumeWorkerRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) SetPortConf 

func (*UnimplementedBESSControlServer) SetPortConf(context.Context, *SetPortConfRequest) (*CommandResponse, error)

func (*UnimplementedBESSControlServer) UnloadPlugin 

func (*UnimplementedBESSControlServer) UnloadPlugin(context.Context, *UnloadPluginRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) UpdateTcParams 

func (*UnimplementedBESSControlServer) UpdateTcParams(context.Context, *UpdateTcParamsRequest) (*EmptyResponse, error)

func (*UnimplementedBESSControlServer) UpdateTcParent 

func (*UnimplementedBESSControlServer) UpdateTcParent(context.Context, *UpdateTcParentRequest) (*EmptyResponse, error)

type UnloadPluginRequest 

type UnloadPluginRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` /// Path to the module library (*.so file)
	// contains filtered or unexported fields
}

func (*UnloadPluginRequest) Descriptor deprecated 

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

Deprecated: Use UnloadPluginRequest.ProtoReflect.Descriptor instead.

func (*UnloadPluginRequest) GetPath 

func (x *UnloadPluginRequest) GetPath() string

func (*UnloadPluginRequest) ProtoMessage 

func (*UnloadPluginRequest) ProtoMessage()

func (*UnloadPluginRequest) ProtoReflect 

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

func (*UnloadPluginRequest) Reset 

func (x *UnloadPluginRequest) Reset()

func (*UnloadPluginRequest) String 

func (x *UnloadPluginRequest) String() string

type UpdateArg 

type UpdateArg struct {
	Fields []*UpdateArg_Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` /// A list of Update Fields.
	// contains filtered or unexported fields
}

* The Update module rewrites a field in a packet's data with a specific value.

__Input Gates__: 1 __Output Gates__: 1

func (*UpdateArg) Descriptor deprecated 

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

Deprecated: Use UpdateArg.ProtoReflect.Descriptor instead.

func (*UpdateArg) GetFields 

func (x *UpdateArg) GetFields() []*UpdateArg_Field

func (*UpdateArg) ProtoMessage 

func (*UpdateArg) ProtoMessage()

func (*UpdateArg) ProtoReflect 

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

func (*UpdateArg) Reset 

func (x *UpdateArg) Reset()

func (*UpdateArg) String 

func (x *UpdateArg) String() string

type UpdateArg_Field 

type UpdateArg_Field struct {
	Offset int64  `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` /// The offset in the packet in bytes to rewrite at.
	Size   uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`     /// The number of bytes to rewrite (max 8 bytes).
	Value  uint64 `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`   /// The value to write into the packet, max 8 bytes.
	// contains filtered or unexported fields
}

* Update Field describes where in a packet's data to rewrite, and with what value.

func (*UpdateArg_Field) Descriptor deprecated 

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

Deprecated: Use UpdateArg_Field.ProtoReflect.Descriptor instead.

func (*UpdateArg_Field) GetOffset 

func (x *UpdateArg_Field) GetOffset() int64

func (*UpdateArg_Field) GetSize 

func (x *UpdateArg_Field) GetSize() uint64

func (*UpdateArg_Field) GetValue 

func (x *UpdateArg_Field) GetValue() uint64

func (*UpdateArg_Field) ProtoMessage 

func (*UpdateArg_Field) ProtoMessage()

func (*UpdateArg_Field) ProtoReflect 

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

func (*UpdateArg_Field) Reset 

func (x *UpdateArg_Field) Reset()

func (*UpdateArg_Field) String 

func (x *UpdateArg_Field) String() string

type UpdateCommandClearArg 

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

* The function `clear()` for Update takes no parameters and clears all state in the module.

func (*UpdateCommandClearArg) Descriptor deprecated 

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

Deprecated: Use UpdateCommandClearArg.ProtoReflect.Descriptor instead.

func (*UpdateCommandClearArg) ProtoMessage 

func (*UpdateCommandClearArg) ProtoMessage()

func (*UpdateCommandClearArg) ProtoReflect 

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

func (*UpdateCommandClearArg) Reset 

func (x *UpdateCommandClearArg) Reset()

func (*UpdateCommandClearArg) String 

func (x *UpdateCommandClearArg) String() string

type UpdateTcParamsRequest 

type UpdateTcParamsRequest struct {
	Class *TrafficClass `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTcParamsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTcParamsRequest.ProtoReflect.Descriptor instead.

func (*UpdateTcParamsRequest) GetClass 

func (x *UpdateTcParamsRequest) GetClass() *TrafficClass

func (*UpdateTcParamsRequest) ProtoMessage 

func (*UpdateTcParamsRequest) ProtoMessage()

func (*UpdateTcParamsRequest) ProtoReflect 

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

func (*UpdateTcParamsRequest) Reset 

func (x *UpdateTcParamsRequest) Reset()

func (*UpdateTcParamsRequest) String 

func (x *UpdateTcParamsRequest) String() string

type UpdateTcParentRequest 

type UpdateTcParentRequest struct {
	Class *TrafficClass `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTcParentRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTcParentRequest.ProtoReflect.Descriptor instead.

func (*UpdateTcParentRequest) GetClass 

func (x *UpdateTcParentRequest) GetClass() *TrafficClass

func (*UpdateTcParentRequest) ProtoMessage 

func (*UpdateTcParentRequest) ProtoMessage()

func (*UpdateTcParentRequest) ProtoReflect 

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

func (*UpdateTcParentRequest) Reset 

func (x *UpdateTcParentRequest) Reset()

func (*UpdateTcParentRequest) String 

func (x *UpdateTcParentRequest) String() string

type UrlFilterArg 

type UrlFilterArg struct {
	Blacklist []*UrlFilterArg_Url `protobuf:"bytes,1,rep,name=blacklist,proto3" json:"blacklist,omitempty"` /// A list of Urls to block.
	// contains filtered or unexported fields
}

* The URLFilter performs TCP reconstruction over a flow and blocks connections which mention a banned URL.

__Input Gates__: 2 __Output Gates__: 2

Note that the add() command takes this same argument, and the clear() command takes an empty argument.

func (*UrlFilterArg) Descriptor deprecated 

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

Deprecated: Use UrlFilterArg.ProtoReflect.Descriptor instead.

func (*UrlFilterArg) GetBlacklist 

func (x *UrlFilterArg) GetBlacklist() []*UrlFilterArg_Url

func (*UrlFilterArg) ProtoMessage 

func (*UrlFilterArg) ProtoMessage()

func (*UrlFilterArg) ProtoReflect 

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

func (*UrlFilterArg) Reset 

func (x *UrlFilterArg) Reset()

func (*UrlFilterArg) String 

func (x *UrlFilterArg) String() string

type UrlFilterArg_Url 

type UrlFilterArg_Url struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` /// Host field, e.g. "www.google.com"
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` /// Path prefix, e.g. "/"
	// contains filtered or unexported fields
}

* A URL consists of a host and a path.

func (*UrlFilterArg_Url) Descriptor deprecated 

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

Deprecated: Use UrlFilterArg_Url.ProtoReflect.Descriptor instead.

func (*UrlFilterArg_Url) GetHost 

func (x *UrlFilterArg_Url) GetHost() string

func (*UrlFilterArg_Url) GetPath 

func (x *UrlFilterArg_Url) GetPath() string

func (*UrlFilterArg_Url) ProtoMessage 

func (*UrlFilterArg_Url) ProtoMessage()

func (*UrlFilterArg_Url) ProtoReflect 

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

func (*UrlFilterArg_Url) Reset 

func (x *UrlFilterArg_Url) Reset()

func (*UrlFilterArg_Url) String 

func (x *UrlFilterArg_Url) String() string

type UrlFilterConfig 

type UrlFilterConfig struct {
	Blacklist []*UrlFilterArg_Url `protobuf:"bytes,1,rep,name=blacklist,proto3" json:"blacklist,omitempty"`
	// contains filtered or unexported fields
}

* The runtime configuration of a URLFilter is the current blacklist. This means that getting the Arg gets an *empty* list: we assume anyone using get_initial_arg is also using get_runtime_config.

func (*UrlFilterConfig) Descriptor deprecated 

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

Deprecated: Use UrlFilterConfig.ProtoReflect.Descriptor instead.

func (*UrlFilterConfig) GetBlacklist 

func (x *UrlFilterConfig) GetBlacklist() []*UrlFilterArg_Url

func (*UrlFilterConfig) ProtoMessage 

func (*UrlFilterConfig) ProtoMessage()

func (*UrlFilterConfig) ProtoReflect 

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

func (*UrlFilterConfig) Reset 

func (x *UrlFilterConfig) Reset()

func (*UrlFilterConfig) String 

func (x *UrlFilterConfig) String() string

type VLANPopArg 

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

* VLANPop removes the VLAN tag.

__Input Gates__: 1 __Output Gates__: 1

func (*VLANPopArg) Descriptor deprecated 

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

Deprecated: Use VLANPopArg.ProtoReflect.Descriptor instead.

func (*VLANPopArg) ProtoMessage 

func (*VLANPopArg) ProtoMessage()

func (*VLANPopArg) ProtoReflect 

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

func (*VLANPopArg) Reset 

func (x *VLANPopArg) Reset()

func (*VLANPopArg) String 

func (x *VLANPopArg) String() string

type VLANPushArg 

type VLANPushArg struct {
	Tci uint64 `protobuf:"varint,1,opt,name=tci,proto3" json:"tci,omitempty"` /// The TCI value to insert in the VLAN tag.
	// contains filtered or unexported fields
}

* VLANPush appends a VLAN tag with a specified TCI value.

__Input Gates__: 1 __Output Gates__: 1

func (*VLANPushArg) Descriptor deprecated 

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

Deprecated: Use VLANPushArg.ProtoReflect.Descriptor instead.

func (*VLANPushArg) GetTci 

func (x *VLANPushArg) GetTci() uint64

func (*VLANPushArg) ProtoMessage 

func (*VLANPushArg) ProtoMessage()

func (*VLANPushArg) ProtoReflect 

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

func (*VLANPushArg) Reset 

func (x *VLANPushArg) Reset()

func (*VLANPushArg) String 

func (x *VLANPushArg) String() string

type VLANSplitArg 

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

* Splits packets across output gates according to VLAN id (e.g., id 3 goes out gate 3).

__Input Gates__: 1 __Output Gates__: many

func (*VLANSplitArg) Descriptor deprecated 

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

Deprecated: Use VLANSplitArg.ProtoReflect.Descriptor instead.

func (*VLANSplitArg) ProtoMessage 

func (*VLANSplitArg) ProtoMessage()

func (*VLANSplitArg) ProtoReflect 

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

func (*VLANSplitArg) Reset 

func (x *VLANSplitArg) Reset()

func (*VLANSplitArg) String 

func (x *VLANSplitArg) String() string

type VXLANDecapArg 

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

* VXLANDecap module decapsulates a VXLAN header on a packet.

__Input Gates__: 1 __Output Gates__: 1

func (*VXLANDecapArg) Descriptor deprecated 

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

Deprecated: Use VXLANDecapArg.ProtoReflect.Descriptor instead.

func (*VXLANDecapArg) ProtoMessage 

func (*VXLANDecapArg) ProtoMessage()

func (*VXLANDecapArg) ProtoReflect 

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

func (*VXLANDecapArg) Reset 

func (x *VXLANDecapArg) Reset()

func (*VXLANDecapArg) String 

func (x *VXLANDecapArg) String() string

type VXLANEncapArg 

type VXLANEncapArg struct {
	Dstport uint64 `protobuf:"varint,1,opt,name=dstport,proto3" json:"dstport,omitempty"` /// The destination UDP port
	// contains filtered or unexported fields
}

* VXLANEncap module wraps a packet in a VXLAN header with a specified destination port.

__Input Gates__: 1 __Output Gates__: 1

func (*VXLANEncapArg) Descriptor deprecated 

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

Deprecated: Use VXLANEncapArg.ProtoReflect.Descriptor instead.

func (*VXLANEncapArg) GetDstport 

func (x *VXLANEncapArg) GetDstport() uint64

func (*VXLANEncapArg) ProtoMessage 

func (*VXLANEncapArg) ProtoMessage()

func (*VXLANEncapArg) ProtoReflect 

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

func (*VXLANEncapArg) Reset 

func (x *VXLANEncapArg) Reset()

func (*VXLANEncapArg) String 

func (x *VXLANEncapArg) String() string

type VersionResponse 

type VersionResponse struct {
	Error   *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` /// Version of bessd
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetError 

func (x *VersionResponse) GetError() *Error

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

type WildcardMatchArg 

type WildcardMatchArg struct {
	Fields  []*Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` /// A list of WildcardMatch fields.
	Values  []*Field `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` /// A list of WildcardMatch values.
	Entries uint64   `protobuf:"varint,3,opt,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

* The WildcardMatch module matches over multiple fields in a packet and pushes packets that do match out a specified gate, and those that don't out a default gate. WildcardMatch is initialized with the fields it should inspect over, rules are added via the `add(...)` function. An example of WildcardMatch is in [`bess/bessctl/conf/samples/wildcardmatch.bess`](https://github.com/NetSys/bess/blob/master/bessctl/conf/samples/wildcardmatch.bess)

__Input Gates__: 1 __Output Gates__: many (configurable)

func (*WildcardMatchArg) Descriptor deprecated 

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

Deprecated: Use WildcardMatchArg.ProtoReflect.Descriptor instead.

func (*WildcardMatchArg) GetEntries 

func (x *WildcardMatchArg) GetEntries() uint64

func (*WildcardMatchArg) GetFields 

func (x *WildcardMatchArg) GetFields() []*Field

func (*WildcardMatchArg) GetValues 

func (x *WildcardMatchArg) GetValues() []*Field

func (*WildcardMatchArg) ProtoMessage 

func (*WildcardMatchArg) ProtoMessage()

func (*WildcardMatchArg) ProtoReflect 

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

func (*WildcardMatchArg) Reset 

func (x *WildcardMatchArg) Reset()

func (*WildcardMatchArg) String 

func (x *WildcardMatchArg) String() string

type WildcardMatchCommandAddArg 

type WildcardMatchCommandAddArg struct {
	Gate     uint64       `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"`         /// Traffic matching this new rule will be sent to this gate.
	Priority int64        `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"` ///If a packet matches multiple rules, the rule with higher priority will be applied. If priorities are equal behavior is undefined.
	Values   []*FieldData `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`      /// The values to check for in each field.
	Masks    []*FieldData `protobuf:"bytes,4,rep,name=masks,proto3" json:"masks,omitempty"`        /// The bitmask for each field -- set `0x0` to ignore the field altogether.
	Valuesv  []*FieldData `protobuf:"bytes,5,rep,name=valuesv,proto3" json:"valuesv,omitempty"`    /// The values to check for in each fieldv.
	// contains filtered or unexported fields
}

* The module WildcardMatch has a command `add(...)` which inserts a new rule into the WildcardMatch module. For an example of code using WilcardMatch see `bess/bessctl/conf/samples/wildcardmatch.bess`.

func (*WildcardMatchCommandAddArg) Descriptor deprecated 

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

Deprecated: Use WildcardMatchCommandAddArg.ProtoReflect.Descriptor instead.

func (*WildcardMatchCommandAddArg) GetGate 

func (x *WildcardMatchCommandAddArg) GetGate() uint64

func (*WildcardMatchCommandAddArg) GetMasks 

func (x *WildcardMatchCommandAddArg) GetMasks() []*FieldData

func (*WildcardMatchCommandAddArg) GetPriority 

func (x *WildcardMatchCommandAddArg) GetPriority() int64

func (*WildcardMatchCommandAddArg) GetValues 

func (x *WildcardMatchCommandAddArg) GetValues() []*FieldData

func (*WildcardMatchCommandAddArg) GetValuesv 

func (x *WildcardMatchCommandAddArg) GetValuesv() []*FieldData

func (*WildcardMatchCommandAddArg) ProtoMessage 

func (*WildcardMatchCommandAddArg) ProtoMessage()

func (*WildcardMatchCommandAddArg) ProtoReflect 

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

func (*WildcardMatchCommandAddArg) Reset 

func (x *WildcardMatchCommandAddArg) Reset()

func (*WildcardMatchCommandAddArg) String 

func (x *WildcardMatchCommandAddArg) String() string

type WildcardMatchCommandClearArg 

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

* The function `clear()` for WildcardMatch takes no parameters, it clears all state in the WildcardMatch module (is equivalent to calling delete for all rules)

func (*WildcardMatchCommandClearArg) Descriptor deprecated 

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

Deprecated: Use WildcardMatchCommandClearArg.ProtoReflect.Descriptor instead.

func (*WildcardMatchCommandClearArg) ProtoMessage 

func (*WildcardMatchCommandClearArg) ProtoMessage()

func (*WildcardMatchCommandClearArg) ProtoReflect 

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

func (*WildcardMatchCommandClearArg) Reset 

func (x *WildcardMatchCommandClearArg) Reset()

func (*WildcardMatchCommandClearArg) String 

func (x *WildcardMatchCommandClearArg) String() string

type WildcardMatchCommandDeleteArg 

type WildcardMatchCommandDeleteArg struct {
	Values []*FieldData `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` /// The values being checked for in the rule
	Masks  []*FieldData `protobuf:"bytes,2,rep,name=masks,proto3" json:"masks,omitempty"`   /// The bitmask from the rule.
	// contains filtered or unexported fields
}

* The module WildcardMatch has a command `delete(...)` which removes a rule -- simply specify the values and masks from the previously inserted rule to remove them.

func (*WildcardMatchCommandDeleteArg) Descriptor deprecated 

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

Deprecated: Use WildcardMatchCommandDeleteArg.ProtoReflect.Descriptor instead.

func (*WildcardMatchCommandDeleteArg) GetMasks 

func (x *WildcardMatchCommandDeleteArg) GetMasks() []*FieldData

func (*WildcardMatchCommandDeleteArg) GetValues 

func (x *WildcardMatchCommandDeleteArg) GetValues() []*FieldData

func (*WildcardMatchCommandDeleteArg) ProtoMessage 

func (*WildcardMatchCommandDeleteArg) ProtoMessage()

func (*WildcardMatchCommandDeleteArg) ProtoReflect 

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

func (*WildcardMatchCommandDeleteArg) Reset 

func (x *WildcardMatchCommandDeleteArg) Reset()

func (*WildcardMatchCommandDeleteArg) String 

func (x *WildcardMatchCommandDeleteArg) String() string

type WildcardMatchCommandSetDefaultGateArg 

type WildcardMatchCommandSetDefaultGateArg struct {
	Gate uint64 `protobuf:"varint,1,opt,name=gate,proto3" json:"gate,omitempty"`
	// contains filtered or unexported fields
}

* For traffic which does not match any rule in the WildcardMatch module, the `set_default_gate(...)` function specifies which gate to send this extra traffic to.

func (*WildcardMatchCommandSetDefaultGateArg) Descriptor deprecated 

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

Deprecated: Use WildcardMatchCommandSetDefaultGateArg.ProtoReflect.Descriptor instead.

func (*WildcardMatchCommandSetDefaultGateArg) GetGate 

func (x *WildcardMatchCommandSetDefaultGateArg) GetGate() uint64

func (*WildcardMatchCommandSetDefaultGateArg) ProtoMessage 

func (*WildcardMatchCommandSetDefaultGateArg) ProtoMessage()

func (*WildcardMatchCommandSetDefaultGateArg) ProtoReflect 

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

func (*WildcardMatchCommandSetDefaultGateArg) Reset 

func (x *WildcardMatchCommandSetDefaultGateArg) Reset()

func (*WildcardMatchCommandSetDefaultGateArg) String 

func (x *WildcardMatchCommandSetDefaultGateArg) String() string

type WildcardMatchConfig 

type WildcardMatchConfig struct {
	DefaultGate uint64                        `protobuf:"varint,1,opt,name=default_gate,json=defaultGate,proto3" json:"default_gate,omitempty"`
	Rules       []*WildcardMatchCommandAddArg `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

* WildcardMatchConfig represents the current runtime configuration of a WildcardMatch module, as returned by get_runtime_config and set by set_runtime_config.

func (*WildcardMatchConfig) Descriptor deprecated 

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

Deprecated: Use WildcardMatchConfig.ProtoReflect.Descriptor instead.

func (*WildcardMatchConfig) GetDefaultGate 

func (x *WildcardMatchConfig) GetDefaultGate() uint64

func (*WildcardMatchConfig) GetRules 

func (x *WildcardMatchConfig) GetRules() []*WildcardMatchCommandAddArg

func (*WildcardMatchConfig) ProtoMessage 

func (*WildcardMatchConfig) ProtoMessage()

func (*WildcardMatchConfig) ProtoReflect 

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

func (*WildcardMatchConfig) Reset 

func (x *WildcardMatchConfig) Reset()

func (*WildcardMatchConfig) String 

func (x *WildcardMatchConfig) String() string

type WorkerSplitArg 

type WorkerSplitArg struct {
	WorkerGates map[uint32]uint32 `` // ogate -> worker mask
	/* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

* WorkerSplit splits packets based on the worker calling ProcessBatch(). It has two modes.

  1. Packets from worker `x` are mapped to output gate `x`. This is the default mode.
  2. When the `worker_gates` field is set, packets from a worker `x` are mapped to `worker_gates[x]`. In this mode, packet batches from workers not mapped to an output gate will be dropped.

Calling the `reset` command with an empty `worker_gates` field will revert WorkerSplit to the default mode.

__Input Gates__: 1 __Output Gates__: many

func (*WorkerSplitArg) Descriptor deprecated 

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

Deprecated: Use WorkerSplitArg.ProtoReflect.Descriptor instead.

func (*WorkerSplitArg) GetWorkerGates 

func (x *WorkerSplitArg) GetWorkerGates() map[uint32]uint32

func (*WorkerSplitArg) ProtoMessage 

func (*WorkerSplitArg) ProtoMessage()

func (*WorkerSplitArg) ProtoReflect 

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

func (*WorkerSplitArg) Reset 

func (x *WorkerSplitArg) Reset()

func (*WorkerSplitArg) String 

func (x *WorkerSplitArg) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.