tensor¶
tensor.interfaces¶
tensor.objects¶
- class tensor.objects.Event(state, service, description, metric, ttl, tags=, []hostname=None, aggregation=None, evtime=None)[source]¶
Bases: object
Tensor Event object
All sources pass these to the queue, which form a proxy object to create protobuf Event objects
Parameters: - state – Some sort of string < 255 chars describing the state
- service – The service name for this event
- description – A description for the event, ie. “My house is on fire!”
- metric – int or float metric for this event
- tags – List of tag strings
- hostname – Hostname for the event (defaults to system fqdn)
- aggregation – Aggregation function
- evtime – Event timestamp override
- class tensor.objects.Output(config, tensor)[source]¶
Bases: object
Output parent class
Outputs can inherit this object which provides a construct for a working output
Parameters: - config – Dictionary config for this queue (usually read from the yaml configuration)
- tensor – A TensorService object for interacting with the queue manager
- class tensor.objects.Source(config, queueBack, tensor)[source]¶
Bases: object
Source parent class
Sources can inherit this object which provides a number of utility methods.
Parameters: - config – Dictionary config for this queue (usually read from the yaml configuration)
- queueBack – A callback method to recieve a list of Event objects
- tensor – A TensorService object for interacting with the queue manager
tensor.service¶
tensor.utils¶
- class tensor.utils.BodyReceiver(finished)[source]¶
Bases: twisted.internet.protocol.Protocol
Simple buffering consumer for body objects
- class tensor.utils.ProcessProtocol(deferred, timeout)[source]¶
Bases: twisted.internet.protocol.ProcessProtocol
ProcessProtocol which supports timeouts
- tensor.utils.fork(executable, args=(), env={}, path=None, timeout=3600)[source]¶
Provides a deferred wrapper function with a timeout function
Parameters: - executable (str.) – Executable
- args (tupple.) – Tupple of arguments
- env (dict.) – Environment dictionary
- timeout (int.) – Kill the child process if timeout is exceeded