Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.entity.basic
[Java] Class BrooklynTasks

java.lang.Object
  brooklyn.entity.basic.BrooklynTasks

public class BrooklynTasks

Provides utilities for making Tasks easier to work with in Brooklyn. Main thing at present is to supply (and find) wrapped entities for tasks to understand the relationship of the entity to the task. TODO Longer term it would be better to remove 'tags' on Tasks and use a strongly typed context object. (Tags there are used mainly for determining who called it (caller), what they called it on (target entity), and what type of task it is (effector, schedule/sensor, etc).)

Nested Class Summary
static class BrooklynTasks.WrappedEntity

static class BrooklynTasks.WrappedStream

 
Field Summary
static java.lang.String CALLER_ENTITY

static java.lang.String CONTEXT_ENTITY

static java.lang.String STREAM_STDERR

static java.lang.String STREAM_STDIN

static java.lang.String STREAM_STDOUT

static java.lang.String TARGET_ENTITY

 
Method Summary
static void addTagDynamically(TaskAdaptable task, java.lang.Object tag)

static void addTagsDynamically(TaskAdaptable task, java.lang.Object tag1, java.lang.Object... tags)

static Entity getContextEntity(Task task)

static Entity getTargetOrContextEntity(Task t)

static java.util.Set getTasksInEntityContext(ExecutionManager em, Entity e)

static Entity getWrappedEntityOfType(Task t, java.lang.String wrappingType)

static Entity getWrappedEntityOfType(java.util.Collection tags, java.lang.String wrappingType)

static void setTransient(Task task)

static BrooklynTasks.WrappedStream stream(Task task, java.lang.String streamType)

returns the tag for the indicated stream, or null
static java.util.Set streams(Task task)

returns the set of tags indicating the streams available on a task
static BrooklynTasks.WrappedEntity tagForCallerEntity(Entity entity)

static BrooklynTasks.WrappedEntity tagForContextEntity(Entity entity)

static BrooklynTasks.WrappedStream tagForStream(java.lang.String streamType, java.io.ByteArrayOutputStream stream)

static BrooklynTasks.WrappedStream tagForStream(java.lang.String streamType, Supplier contents, Supplier size)

creates a tag suitable for marking a stream available on a task
static BrooklynTasks.WrappedEntity tagForTargetEntity(Entity entity)

 
Methods inherited from class java.lang.Object
java.lang.Object#wait(), java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()
 

Field Detail

CALLER_ENTITY

public static final java.lang.String CALLER_ENTITY

CONTEXT_ENTITY

public static final java.lang.String CONTEXT_ENTITY

STREAM_STDERR

public static final java.lang.String STREAM_STDERR

STREAM_STDIN

public static final java.lang.String STREAM_STDIN

STREAM_STDOUT

public static final java.lang.String STREAM_STDOUT

TARGET_ENTITY

public static final java.lang.String TARGET_ENTITY

 
Method Detail

addTagDynamically

public static void addTagDynamically(TaskAdaptable task, java.lang.Object tag)

addTagsDynamically

public static void addTagsDynamically(TaskAdaptable task, java.lang.Object tag1, java.lang.Object... tags)

getContextEntity

public static Entity getContextEntity(Task task)

getTargetOrContextEntity

public static Entity getTargetOrContextEntity(Task t)

getTasksInEntityContext

public static java.util.Set getTasksInEntityContext(ExecutionManager em, Entity e)

getWrappedEntityOfType

public static Entity getWrappedEntityOfType(Task t, java.lang.String wrappingType)

getWrappedEntityOfType

public static Entity getWrappedEntityOfType(java.util.Collection tags, java.lang.String wrappingType)

setTransient

public static void setTransient(Task task)

stream

public static BrooklynTasks.WrappedStream stream(Task task, java.lang.String streamType)
returns the tag for the indicated stream, or null

streams

public static java.util.Set streams(Task task)
returns the set of tags indicating the streams available on a task

tagForCallerEntity

public static BrooklynTasks.WrappedEntity tagForCallerEntity(Entity entity)

tagForContextEntity

public static BrooklynTasks.WrappedEntity tagForContextEntity(Entity entity)

tagForStream

public static BrooklynTasks.WrappedStream tagForStream(java.lang.String streamType, java.io.ByteArrayOutputStream stream)

tagForStream

public static BrooklynTasks.WrappedStream tagForStream(java.lang.String streamType, Supplier contents, Supplier size)
creates a tag suitable for marking a stream available on a task

tagForTargetEntity

public static BrooklynTasks.WrappedEntity tagForTargetEntity(Entity entity)

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.