Interface FlowObjectiveService
-
@Beta public interface FlowObjectiveService
Service for programming data plane flow rules in manner independent of specific device table pipeline configuration.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description int
allocateNextId()
Obtains a globally unique next objective.default void
apply(DeviceId deviceId, Objective objective)
Installs the objective onto the specified device.default void
clearQueue()
void
filter(DeviceId deviceId, FilteringObjective filteringObjective)
Installs the filtering rules onto the specified device.void
forward(DeviceId deviceId, ForwardingObjective forwardingObjective)
Installs the forwarding rules onto the specified device.default com.google.common.collect.ListMultimap<FilteringObjQueueKey,Objective>
getFilteringObjQueue()
Returns all filtering objective that are waiting for the completion of previous objective with the same FilteringObjQueueKey.default Map<FilteringObjQueueKey,Objective>
getFilteringObjQueueHead()
default com.google.common.collect.ListMultimap<ForwardingObjQueueKey,Objective>
getForwardingObjQueue()
Returns all forwarding objective that are waiting for the completion of previous objective with the same ForwardingObjQueueKey.default Map<ForwardingObjQueueKey,Objective>
getForwardingObjQueueHead()
List<String>
getNextMappings()
Retrieve all nextObjective to group mappings known to this onos instance, in a format meant for display on the CLI, to help with debugging.Map<org.apache.commons.lang3.tuple.Pair<Integer,DeviceId>,List<String>>
getNextMappingsChain()
Retrieve all nextObjective to group mappings known to this onos instance, in a format meant for display via REST API, to help with debugging.default com.google.common.collect.ListMultimap<NextObjQueueKey,Objective>
getNextObjQueue()
Returns all next objective that are waiting for the completion of previous objective with the same NextObjQueueKey.default Map<NextObjQueueKey,Objective>
getNextObjQueueHead()
List<String>
getPendingFlowObjectives()
Retrieve all nextObjectives that are waiting to hear back from device drivers, and the forwarding-objectives or next-objectives that are waiting on the successful completion of the original next-objectives.void
initPolicy(String policy)
Provides a composition policy expression.void
next(DeviceId deviceId, NextObjective nextObjective)
Installs the next hop elements into the specified device.
-
-
-
Method Detail
-
filter
void filter(DeviceId deviceId, FilteringObjective filteringObjective)
Installs the filtering rules onto the specified device.- Parameters:
deviceId
- device identifierfilteringObjective
- the filtering objective
-
forward
void forward(DeviceId deviceId, ForwardingObjective forwardingObjective)
Installs the forwarding rules onto the specified device.- Parameters:
deviceId
- device identifierforwardingObjective
- the forwarding objective
-
next
void next(DeviceId deviceId, NextObjective nextObjective)
Installs the next hop elements into the specified device.- Parameters:
deviceId
- device identifiernextObjective
- a next objective
-
allocateNextId
int allocateNextId()
Obtains a globally unique next objective.- Returns:
- an integer
-
initPolicy
void initPolicy(String policy)
Provides a composition policy expression.WARNING: This method is a no-op in the default implementation.
- Parameters:
policy
- policy expression
-
apply
default void apply(DeviceId deviceId, Objective objective)
Installs the objective onto the specified device.- Parameters:
deviceId
- device identifierobjective
- the objective
-
getNextMappingsChain
Map<org.apache.commons.lang3.tuple.Pair<Integer,DeviceId>,List<String>> getNextMappingsChain()
Retrieve all nextObjective to group mappings known to this onos instance, in a format meant for display via REST API, to help with debugging. Applications are only aware of next-Ids, while the group sub-system is only aware of group-ids. This method fills in the gap by providing information on the mapping between next-ids and group-ids done by device-drivers.- Returns:
- a map of key as a pair of next-id and Device id to group-id mapping. Consumed by the REST API.
-
getNextMappings
List<String> getNextMappings()
Retrieve all nextObjective to group mappings known to this onos instance, in a format meant for display on the CLI, to help with debugging. Applications are only aware of next-Ids, while the group sub-system is only aware of group-ids. This method fills in the gap by providing information on the mapping between next-ids and group-ids done by device-drivers.- Returns:
- a list of strings preformatted by the device-drivers to provide information on next-id to group-id mapping. Consumed by the "obj-next-ids" command on the CLI.
-
getPendingFlowObjectives
List<String> getPendingFlowObjectives()
Retrieve all nextObjectives that are waiting to hear back from device drivers, and the forwarding-objectives or next-objectives that are waiting on the successful completion of the original next-objectives. Consumed by the "obj-pending-nexts" command on the CLI.- Returns:
- a list of strings preformatted to provide information on the next-ids awaiting confirmation from the device-drivers.
-
getFilteringObjQueue
default com.google.common.collect.ListMultimap<FilteringObjQueueKey,Objective> getFilteringObjQueue()
Returns all filtering objective that are waiting for the completion of previous objective with the same FilteringObjQueueKey.- Returns:
- Filtering objective queue as map
-
getForwardingObjQueue
default com.google.common.collect.ListMultimap<ForwardingObjQueueKey,Objective> getForwardingObjQueue()
Returns all forwarding objective that are waiting for the completion of previous objective with the same ForwardingObjQueueKey.- Returns:
- Forwarding objective queue as map
-
getNextObjQueue
default com.google.common.collect.ListMultimap<NextObjQueueKey,Objective> getNextObjQueue()
Returns all next objective that are waiting for the completion of previous objective with the same NextObjQueueKey.- Returns:
- Next objective queue as map
-
getFilteringObjQueueHead
default Map<FilteringObjQueueKey,Objective> getFilteringObjQueueHead()
-
getForwardingObjQueueHead
default Map<ForwardingObjQueueKey,Objective> getForwardingObjQueueHead()
-
getNextObjQueueHead
default Map<NextObjQueueKey,Objective> getNextObjQueueHead()
-
clearQueue
default void clearQueue()
-
-