Struct WorkGraphService 

pub struct WorkGraphService { /* private fields */ }

Implementations

impl WorkGraphService

pub fn new(store: Arc<dyn WorkGraphStore>) -> Self

pub fn with_scope( store: Arc<dyn WorkGraphStore>, default_realm_id: impl Into<String>, default_namespace: WorkNamespace, ) -> Self

pub fn store(&self) -> &Arc<dyn WorkGraphStore>

pub fn default_realm_id(&self) -> &str

pub fn default_namespace(&self) -> &WorkNamespace

pub async fn create( &self, request: CreateWorkItemRequest, ) -> Result<WorkItem, WorkGraphError>

pub async fn create_goal( &self, request: GoalCreateRequest, ) -> Result<GoalCreateResult, WorkGraphError>

pub async fn goal_status( &self, request: GoalStatusRequest, ) -> Result<GoalStatusResult, WorkGraphError>

pub async fn attention_binding( &self, request: AttentionBindingRequest, ) -> Result<AttentionBindingResult, WorkGraphError>

pub async fn list_attention( &self, request: AttentionListRequest, ) -> Result<AttentionListResult, WorkGraphError>

pub async fn pause_attention( &self, request: AttentionPauseRequest, ) -> Result<AttentionBindingResult, WorkGraphError>

pub async fn resume_attention( &self, request: AttentionResumeRequest, ) -> Result<AttentionBindingResult, WorkGraphError>

pub async fn attention_projection( &self, request: AttentionProjectionRequest, ) -> Result<AttentionProjectionResult, WorkGraphError>

pub async fn goal_confirm( &self, request: GoalConfirmRequest, ) -> Result<GoalConfirmResult, WorkGraphError>

pub async fn goal_confirm_public( &self, request: GoalConfirmRequest, ) -> Result<GoalConfirmResult, WorkGraphError>

pub async fn goal_request_close( &self, request: GoalRequestCloseRequest, ) -> Result<GoalRequestCloseResult, WorkGraphError>

pub async fn get( &self, realm_id: Option<String>, namespace: Option<WorkNamespace>, id: WorkItemId, ) -> Result<WorkItem, WorkGraphError>

pub async fn list( &self, filter: WorkItemFilter, ) -> Result<Vec<WorkItem>, WorkGraphError>

pub async fn ready( &self, filter: ReadyWorkFilter, ) -> Result<Vec<WorkItem>, WorkGraphError>

pub async fn snapshot( &self, filter: WorkGraphSnapshotFilter, ) -> Result<WorkGraphSnapshot, WorkGraphError>

pub async fn claim( &self, request: ClaimWorkItemRequest, ) -> Result<WorkItem, WorkGraphError>

pub async fn release( &self, request: ReleaseWorkItemRequest, ) -> Result<WorkItem, WorkGraphError>

pub async fn update( &self, request: UpdateWorkItemRequest, ) -> Result<WorkItem, WorkGraphError>

pub async fn block( &self, realm_id: Option<String>, namespace: Option<WorkNamespace>, id: WorkItemId, expected_revision: u64, ) -> Result<WorkItem, WorkGraphError>

pub async fn close( &self, request: CloseWorkItemRequest, ) -> Result<WorkItem, WorkGraphError>

pub async fn link( &self, request: LinkWorkItemsRequest, ) -> Result<WorkEdge, WorkGraphError>

pub async fn add_evidence( &self, request: AddEvidenceRequest, ) -> Result<WorkItem, WorkGraphError>

pub async fn events( &self, filter: WorkGraphEventFilter, ) -> Result<Vec<WorkGraphEvent>, WorkGraphError>

Trait Implementations

impl Clone for WorkGraphService

fn clone(&self) -> WorkGraphService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.