--- /dev/null
+from types import StringTypes
+import time
+import re
+import datetime
+
+from PLC.Faults import *
+from PLC.Parameter import Parameter, Mixed
+from PLC.Filter import Filter
+from PLC.Debug import profile
+from PLC.Timestamp import Timestamp
+from PLC.Storage.AlchemyObject import AlchemyObj
+
+class SliceInstance(AlchemyObj):
+ """
+ Representation of a row in the slice_node table. To use, optionally
+ instantiate with a dict of values. Update as you would a
+ dict. Commit to the database with sync().To use, instantiate
+ with a dict of values.
+ """
+
+ tablename = 'slice_instance'
+
+ fields = {
+ 'slice_id': Parameter(int, "Slice identifier", primary_key=True),
+ 'instance_id': Parameter(str, "Instance identifier", indexed=True),
+ }
+
+ tags = {}
+
+ def sync(self, commit = True, validate=True):
+ """
+ Add the record
+ """
+ AlchemyObj.sync(self, commit, validate)
+ AlchemyObj.insert(self, dict(self))
+
+ def delete(self, commit = True):
+ """
+ Delete existing slice.
+ """
+ AlchemyObj.delete(self, dict(self))
+
+
+class SliceInstances(list):
+ """
+ Representation of row(s) from the slices table in the
+ database.
+ """
+
+ def __init__(self, api, filter = None, columns = None):
+
+ # the view that we're selecting upon: start with view_slices
+ if not filter:
+ slice_instances = SliceInstance().select()
+ elif isinstance(filter, dict):
+ slices_instances = SliceInstance().select(filter=filter)
+ else:
+ raise PLCInvalidArgument, "Wrong slice_instance filter %r"%filter
+
+ for slice_instance in slice_instances:
+ self.append(slice_instance)