temporal-sdk-core-0.1.0.0
Safe HaskellNone
LanguageHaskell2010

Temporal.Core.Worker

Synopsis

Documentation

data Worker (ty :: WorkerType) Source #

data WorkerType Source #

Constructors

Real 
Replay 

data SWorkerType (ty :: WorkerType) where Source #

A singleton type for WorkerType.

data SomeWorkerType where Source #

Constructors

SomeWorkerType :: forall (ty :: WorkerType). SWorkerType ty -> SomeWorkerType 

validateWorker :: Worker 'Real -> IO (Either WorkerValidationError ()) Source #

closeWorker :: forall (ty :: WorkerType). Worker ty -> IO () Source #

type family InactiveForReplay (ty :: WorkerType) a where ... Source #

Equations

InactiveForReplay 'Real a = a 
InactiveForReplay 'Replay _1 = () 

data WorkflowActivation #

Fields :

Instances

Instances details
NFData WorkflowActivation 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

rnf :: WorkflowActivation -> () #

Show WorkflowActivation 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Eq WorkflowActivation 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Ord WorkflowActivation 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Message WorkflowActivation 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

HasField WorkflowActivation "buildIdForCurrentTask" Text 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "buildIdForCurrentTask" -> (Text -> f Text) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "continueAsNewSuggested" Bool 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "continueAsNewSuggested" -> (Bool -> f Bool) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "historyLength" Word32 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "historyLength" -> (Word32 -> f Word32) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "historySizeBytes" Word64 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "historySizeBytes" -> (Word64 -> f Word64) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "isReplaying" Bool 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "isReplaying" -> (Bool -> f Bool) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "runId" Text 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "runId" -> (Text -> f Text) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "timestamp" Timestamp 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "timestamp" -> (Timestamp -> f Timestamp) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "availableInternalFlags" [Word32] 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "availableInternalFlags" -> ([Word32] -> f [Word32]) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "jobs" [WorkflowActivationJob] 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

HasField WorkflowActivation "maybe'timestamp" (Maybe Timestamp) 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "maybe'timestamp" -> (Maybe Timestamp -> f (Maybe Timestamp)) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "vec'availableInternalFlags" (Vector Word32) 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

Methods

fieldOf :: Functor f => Proxy# "vec'availableInternalFlags" -> (Vector Word32 -> f (Vector Word32)) -> WorkflowActivation -> f WorkflowActivation #

HasField WorkflowActivation "vec'jobs" (Vector WorkflowActivationJob) 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation

data ActivityTask #

Fields :

  • taskToken :: Lens' ActivityTask Data.ByteString.ByteString
  • maybe'variant :: Lens' ActivityTask (Prelude.Maybe ActivityTask'Variant)
  • maybe'start :: Lens' ActivityTask (Prelude.Maybe Start)
  • start :: Lens' ActivityTask Start
  • maybe'cancel :: Lens' ActivityTask (Prelude.Maybe Cancel)
  • cancel :: Lens' ActivityTask Cancel

Instances

Instances details
NFData ActivityTask 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Methods

rnf :: ActivityTask -> () #

Show ActivityTask 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Eq ActivityTask 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Ord ActivityTask 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Message ActivityTask 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

HasField ActivityTask "cancel" Cancel 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Methods

fieldOf :: Functor f => Proxy# "cancel" -> (Cancel -> f Cancel) -> ActivityTask -> f ActivityTask #

HasField ActivityTask "start" Start 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Methods

fieldOf :: Functor f => Proxy# "start" -> (Start -> f Start) -> ActivityTask -> f ActivityTask #

HasField ActivityTask "taskToken" ByteString 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Methods

fieldOf :: Functor f => Proxy# "taskToken" -> (ByteString -> f ByteString) -> ActivityTask -> f ActivityTask #

HasField ActivityTask "maybe'cancel" (Maybe Cancel) 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Methods

fieldOf :: Functor f => Proxy# "maybe'cancel" -> (Maybe Cancel -> f (Maybe Cancel)) -> ActivityTask -> f ActivityTask #

HasField ActivityTask "maybe'start" (Maybe Start) 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

Methods

fieldOf :: Functor f => Proxy# "maybe'start" -> (Maybe Start -> f (Maybe Start)) -> ActivityTask -> f ActivityTask #

HasField ActivityTask "maybe'variant" (Maybe ActivityTask'Variant) 
Instance details

Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask

data WorkflowActivationCompletion #

Fields :

  • runId :: Lens' WorkflowActivationCompletion Data.Text.Text
  • maybe'status :: Lens' WorkflowActivationCompletion (Prelude.Maybe WorkflowActivationCompletion'Status)
  • maybe'successful :: Lens' WorkflowActivationCompletion (Prelude.Maybe Success)
  • successful :: Lens' WorkflowActivationCompletion Success
  • maybe'failed :: Lens' WorkflowActivationCompletion (Prelude.Maybe Failure)
  • failed :: Lens' WorkflowActivationCompletion Failure

Instances

Instances details
NFData WorkflowActivationCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

Show WorkflowActivationCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

Eq WorkflowActivationCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

Ord WorkflowActivationCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

Message WorkflowActivationCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

HasField WorkflowActivationCompletion "failed" Failure 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

HasField WorkflowActivationCompletion "runId" Text 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

HasField WorkflowActivationCompletion "successful" Success 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

HasField WorkflowActivationCompletion "maybe'failed" (Maybe Failure) 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

HasField WorkflowActivationCompletion "maybe'status" (Maybe WorkflowActivationCompletion'Status) 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

HasField WorkflowActivationCompletion "maybe'successful" (Maybe Success) 
Instance details

Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion

data ActivityTaskCompletion #

Fields :

  • taskToken :: Lens' ActivityTaskCompletion Data.ByteString.ByteString
  • result :: Lens' ActivityTaskCompletion Proto.Temporal.Sdk.Core.ActivityResult.ActivityResult.ActivityExecutionResult
  • maybe'result :: Lens' ActivityTaskCompletion (Prelude.Maybe Proto.Temporal.Sdk.Core.ActivityResult.ActivityResult.ActivityExecutionResult)

Instances

Instances details
NFData ActivityTaskCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Methods

rnf :: ActivityTaskCompletion -> () #

Show ActivityTaskCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Eq ActivityTaskCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Ord ActivityTaskCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Message ActivityTaskCompletion 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

HasField ActivityTaskCompletion "result" ActivityExecutionResult 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

HasField ActivityTaskCompletion "taskToken" ByteString 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

HasField ActivityTaskCompletion "maybe'result" (Maybe ActivityExecutionResult) 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

data ActivityHeartbeat #

Fields :

  • taskToken :: Lens' ActivityHeartbeat Data.ByteString.ByteString
  • details :: Lens' ActivityHeartbeat [Proto.Temporal.Api.Common.V1.Message.Payload]
  • vec'details :: Lens' ActivityHeartbeat (Data.Vector.Vector Proto.Temporal.Api.Common.V1.Message.Payload)

Instances

Instances details
NFData ActivityHeartbeat 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Methods

rnf :: ActivityHeartbeat -> () #

Show ActivityHeartbeat 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Eq ActivityHeartbeat 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Ord ActivityHeartbeat 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Message ActivityHeartbeat 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

HasField ActivityHeartbeat "taskToken" ByteString 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Methods

fieldOf :: Functor f => Proxy# "taskToken" -> (ByteString -> f ByteString) -> ActivityHeartbeat -> f ActivityHeartbeat #

HasField ActivityHeartbeat "details" [Payload] 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Methods

fieldOf :: Functor f => Proxy# "details" -> ([Payload] -> f [Payload]) -> ActivityHeartbeat -> f ActivityHeartbeat #

HasField ActivityHeartbeat "vec'details" (Vector Payload) 
Instance details

Defined in Proto.Temporal.Sdk.Core.CoreInterface

Methods

fieldOf :: Functor f => Proxy# "vec'details" -> (Vector Payload -> f (Vector Payload)) -> ActivityHeartbeat -> f ActivityHeartbeat #

requestWorkflowEviction :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> RunId -> IO () Source #

initiateShutdown :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> IO () Source #

Initiate shutdown.

finalizeShutdown :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> IO (Either WorkerError ()) Source #

Completes shutdown and frees all resources. You should avoid simply dropping workers, as this does not allow async tasks to report any panics that may have occurred cleanly.

This should be called only after initiateShutdown has resolved and/or both polling functions have returned ShutDown errors.

data History #

Fields :

  • events :: Lens' History [HistoryEvent]
  • vec'events :: Lens' History (Data.Vector.Vector HistoryEvent)

Instances

Instances details
NFData History 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

Methods

rnf :: History -> () #

Show History 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

Eq History 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

Methods

(==) :: History -> History -> Bool #

(/=) :: History -> History -> Bool #

Ord History 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

Message History 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

HasField WorkflowExecution "history" History 
Instance details

Defined in Proto.Temporal.Api.Export.V1.Message

Methods

fieldOf :: Functor f => Proxy# "history" -> (History -> f History) -> WorkflowExecution -> f WorkflowExecution #

HasField GetWorkflowExecutionHistoryResponse "history" History 
Instance details

Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse

HasField GetWorkflowExecutionHistoryReverseResponse "history" History 
Instance details

Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse

HasField PollWorkflowTaskQueueResponse "history" History 
Instance details

Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse

HasField WorkflowExecution "maybe'history" (Maybe History) 
Instance details

Defined in Proto.Temporal.Api.Export.V1.Message

Methods

fieldOf :: Functor f => Proxy# "maybe'history" -> (Maybe History -> f (Maybe History)) -> WorkflowExecution -> f WorkflowExecution #

HasField History "events" [HistoryEvent] 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

Methods

fieldOf :: Functor f => Proxy# "events" -> ([HistoryEvent] -> f [HistoryEvent]) -> History -> f History #

HasField History "vec'events" (Vector HistoryEvent) 
Instance details

Defined in Proto.Temporal.Api.History.V1.Message

Methods

fieldOf :: Functor f => Proxy# "vec'events" -> (Vector HistoryEvent -> f (Vector HistoryEvent)) -> History -> f History #

HasField GetWorkflowExecutionHistoryResponse "maybe'history" (Maybe History) 
Instance details

Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse

HasField GetWorkflowExecutionHistoryReverseResponse "maybe'history" (Maybe History) 
Instance details

Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse

HasField PollWorkflowTaskQueueResponse "maybe'history" (Maybe History) 
Instance details

Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse

class KnownWorkerType (ty :: WorkerType) where Source #

Instances

Instances details
KnownWorkerType 'Real Source # 
Instance details

Defined in Temporal.Core.Worker

KnownWorkerType 'Replay Source # 
Instance details

Defined in Temporal.Core.Worker