blob: 5dc0bcd079b319e56633a8b3863cc37b67eca4c3 [file] [log] [blame]
def addBucket( main, egressPort="" ):
"""
Description:
Create a single bucket which can be added to a Group.
Optional:
* egressPort: port of egress device
Returns:
* Returns a Bucket
* Returns None in case of error
Note:
The ip and port option are for the requests input's ip and port
of the ONOS node.
"""
try:
bucket = {
"treatment": { "instructions": [] }
}
if egressPort:
bucket[ 'treatment' ][ 'instructions' ].append( {
"type": "OUTPUT",
"port": egressPort } )
return bucket
except ( AttributeError, TypeError ):
main.log.exception( self.name + ": Object not as expected" )
return None
except Exception:
main.log.exception( self.name + ": Uncaught exception!" )
main.cleanup()
main.exit()