bess_pb

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
}

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
}

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

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
}

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
}

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)
}

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)
}

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
}

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
}

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

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

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}