model Package

model Package

actions Module

class opennode.oms.model.model.actions.Action(context)

Bases: grokcore.component.components.Subscription

subject(args)

class opennode.oms.model.model.actions.ActionGrokker

Bases: martian.components.ClassGrokker

execute(class_, action, **kw)

class opennode.oms.model.model.actions.ActionsContainer(parent)

Bases: opennode.oms.model.model.base.ReadonlyContainer

Implements a dynamic view containing actions that can be performed on a given object.

content()

class opennode.oms.model.model.actions.ActionsContainerExtension(context)

Bases: grokcore.component.components.Subscription

extend()

class opennode.oms.model.model.actions.action(*args, **kw)

Bases: martian.directive.Directive

Use this directive on adapters used to define actions for specific model objects.

default = None

scope = <martian.directive.ClassScope object at 0x2821cd0>

store = <martian.directive.StoreOnce object at 0x2821910>

base Module

class opennode.oms.model.model.base.AddingContainer

Bases: opennode.oms.model.model.base.ReadonlyContainer

A container which can accept items to be added to it. Doesn’t actually store them, so it’s up to subclasses to implement _add and override listcontent and listnames.

add(item)

can_contain(item)

rename(old_name, new_name)

class opennode.oms.model.model.base.Container

Bases: opennode.oms.model.model.base.AddingContainer

A base class for containers whose items are named by their __name__. Adding unnamed objects will allocated using the overridable _new_id method.

Does not support __setitem__; use add(...) instead.

remove(item)

class opennode.oms.model.model.base.ContainerExtension(context)

Bases: grokcore.component.components.Subscription

extend()

class opennode.oms.model.model.base.ContainerInjector(context)

Bases: grokcore.component.components.Subscription

inject()

class opennode.oms.model.model.base.MarkerSourceBinder

Bases: object

class opennode.oms.model.model.base.Model

Bases: persistent.Persistent

classmethod class_implemented_interfaces()

features

classmethod get_class_features()

get_features()

implemented_interfaces()

set_features(values)

Features is a pseudo attribute which allows us to treat marker interfaces as if they were attributes. This special setter behaves like the tags setter, allowing addition and removal of individual marker interfaces from omsh.

class opennode.oms.model.model.base.ReadonlyContainer

Bases: opennode.oms.model.model.base.Model

A container whose items cannot be modified, i.e. are predefined.

can_contain(item)

A read only container cannot accept new children

content(*args, **kwargs)

listcontent()

listnames()

bin Module

class opennode.oms.model.model.bin.Bin

Bases: opennode.oms.model.model.base.ReadonlyContainer

content()

class opennode.oms.model.model.bin.Command(name, parent, cmd)

Bases: opennode.oms.model.model.base.Model

byname Module

class opennode.oms.model.model.byname.ByNameContainer(parent)

Bases: opennode.oms.model.model.base.ReadonlyContainer

Implements a dynamic view creating a symlink for each parent’s object which provides a display_name() value.

content()

class opennode.oms.model.model.byname.ByNameContainerExtension(context)

Bases: grokcore.component.components.Subscription

extend()

filtrable Module

class opennode.oms.model.model.filtrable.DefaultFiltrable(context)

Bases: grokcore.component.components.Adapter

match(query)

class opennode.oms.model.model.filtrable.ModelFiltrable(context)

Bases: grokcore.component.components.Adapter

match(query)

log Module

class opennode.oms.model.model.log.Log

Bases: opennode.oms.model.model.base.ReadonlyContainer

news

news Module

class opennode.oms.model.model.news.News

Bases: opennode.oms.model.model.base.Container

class opennode.oms.model.model.news.NewsItem(message)

Bases: opennode.oms.model.model.base.Model

nicknames

plugins Module

class opennode.oms.model.model.plugins.PluginInfo(parent, name)

Bases: opennode.oms.model.model.base.Model

initialize()

class opennode.oms.model.model.plugins.Plugins

Bases: opennode.oms.model.model.base.ReadonlyContainer

ENTRY_POINT_NAME = 'oms.plugins'

instance = None

load_eggs(search_path, auto_enable=None)

load_plugin(entry)

load_plugins()

opennode.oms.model.model.plugins.load_plugins(event)

proc Module

class opennode.oms.model.model.proc.CompletedProc(parent, tasks)

Bases: opennode.oms.model.model.base.ReadonlyContainer

content()

class opennode.oms.model.model.proc.ContinueTaskAction(context)

Bases: opennode.oms.model.model.proc.SignalAction

Send CONT signal

class opennode.oms.model.model.proc.DaemonProcess

Bases: object

signal_handler(name)

class opennode.oms.model.model.proc.DaemonStateRenderer(context)

Bases: grokcore.component.components.Adapter

class opennode.oms.model.model.proc.Proc

Bases: opennode.oms.model.model.base.ReadonlyContainer

content()

instance = None

classmethod register(deferred, subject, cmdline=None, ptid='1', principal=None, write_buffer=None)

spawn(process)

start_daemons()

classmethod unregister(id_)

class opennode.oms.model.model.proc.SignalAction(context)

Bases: opennode.oms.model.model.actions.Action

Send a given signal

execute(cmd, args)

class opennode.oms.model.model.proc.StopTaskAction(context)

Bases: opennode.oms.model.model.proc.SignalAction

Send STOP signal

class opennode.oms.model.model.proc.Task(name, parent, subject, deferred, cmdline, ptid, signal_handler=None, principal=None, write_buffer=None)

Bases: opennode.oms.model.model.base.ReadonlyContainer

nicknames

signal(name)

stdout

uptime

class opennode.oms.model.model.proc.TerminateTaskAction(context)

Bases: opennode.oms.model.model.proc.SignalAction

Send TERM signal

opennode.oms.model.model.proc.start_daemons(event)

root Module

class opennode.oms.model.model.root.OmsRoot

Bases: opennode.oms.model.model.base.ReadonlyContainer

The root of the OMS DB.

This model is the root of the object hierarchy.

Absolute object traversals start from this object.

class opennode.oms.model.model.root.RootContainerExtension(context)

Bases: grokcore.component.components.Subscription

extend()

class opennode.oms.model.model.root.RootContainerInjector(context)

Bases: grokcore.component.components.Subscription

inject()

search Module

class opennode.oms.model.model.search.ClearIndexAction(context)

Bases: opennode.oms.model.model.actions.Action

Clear index

execute(cmd, args)

class opennode.oms.model.model.search.ModelTags(context)

Bases: grokcore.component.components.Adapter

auto_tags()

get_tags()

set_tags(values)

If tag names begin with + or - this setter will add or remove tags from the tag set, otherwise the set will be replaced.

Tags are composed of a ‘prefix’ and a ‘name’. If not specified, the default prefix is ‘label:’. The user cannot add/remove tags in the one of the ‘reserved prefixes’.

tags

class opennode.oms.model.model.search.ModelTokenizer(context)

Bases: grokcore.component.components.Adapter

tokens()

Hackish way to quickly take all important tokens

class opennode.oms.model.model.search.ReindexAction(context)

Bases: opennode.oms.model.model.actions.Action

Force reindex

execute(cmd, args)

class opennode.oms.model.model.search.SearchByTagContainer(parent)

Bases: opennode.oms.model.model.base.AddingContainer

tags

class opennode.oms.model.model.search.SearchContainer

Bases: opennode.oms.model.model.base.ReadonlyContainer

clear()

index_object(obj)

search(**kwargs)

search_goog(query)

unindex_object(obj)

class opennode.oms.model.model.search.SearchResult(parent, query)

Bases: opennode.oms.model.model.base.ReadonlyContainer

search_goog(query)

class opennode.oms.model.model.search.Tag(name, searcher, parent, other_tags, tag_path)

Bases: opennode.oms.model.model.base.ReadonlyContainer

class opennode.oms.model.model.search.TagItems(parent, searcher)

Bases: opennode.oms.model.model.base.ReadonlyContainer

opennode.oms.model.model.search.enqueue_for_indexing(model, event)

stream Module

class opennode.oms.model.model.stream.Metrics(parent)

Bases: opennode.oms.model.model.base.ReadonlyContainer

class opennode.oms.model.model.stream.MetricsContainerExtension(context)

Bases: grokcore.component.components.Subscription

extend()

class opennode.oms.model.model.stream.ModelStream(context)

Bases: opennode.oms.model.model.stream.TransientStream

class opennode.oms.model.model.stream.StreamSubscriber

Bases: opennode.oms.model.model.base.ReadonlyContainer

class opennode.oms.model.model.stream.TransientStream(context)

Bases: grokcore.component.components.Adapter

A stream which stores the data in memory in a capped collection

MAX_LEN = 100

add(event)

data

events(after, limit=None)

transient_store = defaultdict(<type 'list'>, {})

class opennode.oms.model.model.stream.TransientStreamModel(parent, name)

Bases: opennode.oms.model.model.base.Model

A model which represents a a transient stream

opennode.oms.model.model.stream.model_created(model, event)

opennode.oms.model.model.stream.model_deleted(model, event)

opennode.oms.model.model.stream.model_modified(model, event)

symlink Module

class opennode.oms.model.model.symlink.Symlink(name, target)

Bases: opennode.oms.model.model.base.Model

Symbolic link.

opennode.oms.model.model.symlink.follow_symlinks(item)

Returns the object pointed to a symlink chain.