Safe Haskell	None
Language	Haskell2010

Temporal.Core.Worker

Synopsis

data Worker (ty :: WorkerType)
getWorkerClient :: Worker 'Real -> Client
data WorkerConfig = WorkerConfig {
- namespace :: Text
- taskQueue :: Text
- buildId :: Text
- identityOverride :: Maybe Text
- maxCachedWorkflows :: Word64
- maxOutstandingWorkflowTasks :: Word64
- maxOutstandingActivities :: Word64
- maxOutstandingLocalActivities :: Word64
- maxConcurrentWorkflowTaskPolls :: Word64
- nonstickyToStickyPollRatio :: Float
- maxConcurrentActivityTaskPolls :: Word64
- noRemoteActivities :: Bool
- stickyQueueScheduleToStartTimeoutMillis :: Word64
- maxHeartbeatThrottleIntervalMillis :: Word64
- defaultHeartbeatThrottleIntervalMillis :: Word64
- maxActivitiesPerSecond :: Maybe Double
- maxTaskQueueActivitiesPerSecond :: Maybe Double
- gracefulShutdownPeriodMillis :: Word64
- nondeterminismAsWorkflowFail :: Bool
- nondeterminismAsWorkflowFailForTypes :: [Text]
}
getWorkerConfig :: forall (ty :: WorkerType). Worker ty -> WorkerConfig
defaultWorkerConfig :: WorkerConfig
data WorkerError = WorkerError {
- code :: WorkerErrorCode
- message :: Text
}
data WorkerErrorCode
- = SDKError
- | InitWorkerFailed
- | InitReplayWorkerFailed
- | InvalidProto
- | ReplayWorkerClosed
- | PollShutdown
- | PollFailure
- | CompletionFailure
- | InvalidWorkerConfig
- | UnknownError Word8
data WorkerType
- = Real
- | Replay
data SWorkerType (ty :: WorkerType) where
- SReal :: SWorkerType 'Real
- SReplay :: SWorkerType 'Replay
data SomeWorkerType where
- SomeWorkerType :: forall (ty :: WorkerType). SWorkerType ty -> SomeWorkerType
newWorker :: Client -> WorkerConfig -> IO (Either WorkerError (Worker 'Real))
validateWorker :: Worker 'Real -> IO (Either WorkerValidationError ())
newReplayWorker :: Runtime -> WorkerConfig -> IO (Either WorkerError (Worker 'Replay, HistoryPusher))
closeWorker :: forall (ty :: WorkerType). Worker ty -> IO ()
type family InactiveForReplay (ty :: WorkerType) a where ...
data WorkflowActivation
pollWorkflowActivation :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> IO (Either WorkerError WorkflowActivation)
data ActivityTask
pollActivityTask :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> IO (Either WorkerError ActivityTask)
data WorkflowActivationCompletion
completeWorkflowActivation :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> WorkflowActivationCompletion -> IO (Either WorkerError ())
data ActivityTaskCompletion
completeActivityTask :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> ActivityTaskCompletion -> IO (Either WorkerError ())
data ActivityHeartbeat
recordActivityHeartbeat :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> ActivityHeartbeat -> IO (Either WorkerError ())
requestWorkflowEviction :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> RunId -> IO ()
initiateShutdown :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> IO ()
finalizeShutdown :: forall (ty :: WorkerType). KnownWorkerType ty => Worker ty -> IO (Either WorkerError ())
data HistoryPusher
data History
pushHistory :: HistoryPusher -> WorkflowId -> Either ByteString History -> IO (Either WorkerError ())
closeHistory :: HistoryPusher -> IO ()
class KnownWorkerType (ty :: WorkerType) where
- knownWorkerType :: SWorkerType ty

Documentation

data Worker (ty :: WorkerType) Source #

getWorkerClient :: Worker 'Real -> Client Source #

data WorkerConfig Source #

Instances

Instances details

FromJSON WorkerConfig Source #
Instance details Defined in Temporal.Core.Worker Methods parseJSON :: Value -> Parser WorkerConfig # parseJSONList :: Value -> Parser [WorkerConfig] # omittedField :: Maybe WorkerConfig #
ToJSON WorkerConfig Source #
Instance details Defined in Temporal.Core.Worker Methods toJSON :: WorkerConfig -> Value # toEncoding :: WorkerConfig -> Encoding # toJSONList :: [WorkerConfig] -> Value # toEncodingList :: [WorkerConfig] -> Encoding # omitField :: WorkerConfig -> Bool #

getWorkerConfig :: forall (ty :: WorkerType). Worker ty -> WorkerConfig Source #

defaultWorkerConfig :: WorkerConfig Source #

data WorkerError Source #

Constructors

WorkerError
Fields code :: WorkerErrorCode message :: Text

Instances

Instances details

Exception WorkerError Source #
Instance details Defined in Temporal.Core.CTypes Methods toException :: WorkerError -> SomeException # fromException :: SomeException -> Maybe WorkerError # displayException :: WorkerError -> String # backtraceDesired :: WorkerError -> Bool #
Show WorkerError Source #
Instance details Defined in Temporal.Core.CTypes Methods showsPrec :: Int -> WorkerError -> ShowS # show :: WorkerError -> String # showList :: [WorkerError] -> ShowS #
Eq WorkerError Source #
Instance details Defined in Temporal.Core.CTypes Methods (==) :: WorkerError -> WorkerError -> Bool # (/=) :: WorkerError -> WorkerError -> Bool #

data WorkerErrorCode Source #

Constructors

SDKError
InitWorkerFailed
InitReplayWorkerFailed
InvalidProto
ReplayWorkerClosed
PollShutdown
PollFailure
CompletionFailure
InvalidWorkerConfig
UnknownError Word8

Instances

Instances details

Storable WorkerErrorCode Source #
Instance details Defined in Temporal.Core.CTypes Methods sizeOf :: WorkerErrorCode -> Int # alignment :: WorkerErrorCode -> Int # peekElemOff :: Ptr WorkerErrorCode -> Int -> IO WorkerErrorCode # pokeElemOff :: Ptr WorkerErrorCode -> Int -> WorkerErrorCode -> IO () # peekByteOff :: Ptr b -> Int -> IO WorkerErrorCode # pokeByteOff :: Ptr b -> Int -> WorkerErrorCode -> IO () # peek :: Ptr WorkerErrorCode -> IO WorkerErrorCode # poke :: Ptr WorkerErrorCode -> WorkerErrorCode -> IO () #
Show WorkerErrorCode Source #
Instance details Defined in Temporal.Core.CTypes Methods showsPrec :: Int -> WorkerErrorCode -> ShowS # show :: WorkerErrorCode -> String # showList :: [WorkerErrorCode] -> ShowS #
Eq WorkerErrorCode Source #
Instance details Defined in Temporal.Core.CTypes Methods (==) :: WorkerErrorCode -> WorkerErrorCode -> Bool # (/=) :: WorkerErrorCode -> WorkerErrorCode -> Bool #

data WorkerType Source #

Constructors

Real
Replay

data SWorkerType (ty :: WorkerType) where Source #

A singleton type for WorkerType.

Constructors

SReal :: SWorkerType 'Real
SReplay :: SWorkerType 'Replay

data SomeWorkerType where Source #

Constructors

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

newWorker :: Client -> WorkerConfig -> IO (Either WorkerError (Worker 'Real)) Source #

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

newReplayWorker :: Runtime -> WorkerConfig -> IO (Either WorkerError (Worker 'Replay, HistoryPusher)) 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 :

runId :: Lens' WorkflowActivation Data.Text.Text
timestamp :: Lens' WorkflowActivation Proto.Google.Protobuf.Timestamp.Timestamp
maybe'timestamp :: Lens' WorkflowActivation (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp)
isReplaying :: Lens' WorkflowActivation Prelude.Bool
historyLength :: Lens' WorkflowActivation Data.Word.Word32
jobs :: Lens' WorkflowActivation [WorkflowActivationJob]
vec'jobs :: Lens' WorkflowActivation (Data.Vector.Vector WorkflowActivationJob)
availableInternalFlags :: Lens' WorkflowActivation [Data.Word.Word32]
vec'availableInternalFlags :: Lens' WorkflowActivation (Data.Vector.Unboxed.Vector Data.Word.Word32)
historySizeBytes :: Lens' WorkflowActivation Data.Word.Word64
continueAsNewSuggested :: Lens' WorkflowActivation Prelude.Bool
buildIdForCurrentTask :: Lens' WorkflowActivation Data.Text.Text

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 Methods showsPrec :: Int -> WorkflowActivation -> ShowS # show :: WorkflowActivation -> String # showList :: [WorkflowActivation] -> ShowS #
Eq WorkflowActivation
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation Methods (==) :: WorkflowActivation -> WorkflowActivation -> Bool # (/=) :: WorkflowActivation -> WorkflowActivation -> Bool #
Ord WorkflowActivation
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation Methods compare :: WorkflowActivation -> WorkflowActivation -> Ordering # (<) :: WorkflowActivation -> WorkflowActivation -> Bool # (<=) :: WorkflowActivation -> WorkflowActivation -> Bool # (>) :: WorkflowActivation -> WorkflowActivation -> Bool # (>=) :: WorkflowActivation -> WorkflowActivation -> Bool # max :: WorkflowActivation -> WorkflowActivation -> WorkflowActivation # min :: WorkflowActivation -> WorkflowActivation -> WorkflowActivation #
Message WorkflowActivation
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowActivation.WorkflowActivation Methods messageName :: Proxy WorkflowActivation -> Text # packedMessageDescriptor :: Proxy WorkflowActivation -> ByteString # packedFileDescriptor :: Proxy WorkflowActivation -> ByteString # defMessage :: WorkflowActivation # fieldsByTag :: Map Tag (FieldDescriptor WorkflowActivation) # fieldsByTextFormatName :: Map String (FieldDescriptor WorkflowActivation) # unknownFields :: Lens' WorkflowActivation FieldSet # parseMessage :: Parser WorkflowActivation # buildMessage :: WorkflowActivation -> Builder #
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 Methods fieldOf :: Functor f => Proxy# "jobs" -> ([WorkflowActivationJob] -> f [WorkflowActivationJob]) -> WorkflowActivation -> f 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 Methods fieldOf :: Functor f => Proxy# "vec'jobs" -> (Vector WorkflowActivationJob -> f (Vector WorkflowActivationJob)) -> WorkflowActivation -> f WorkflowActivation #

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

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 Methods showsPrec :: Int -> ActivityTask -> ShowS # show :: ActivityTask -> String # showList :: [ActivityTask] -> ShowS #
Eq ActivityTask
Instance details Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask Methods (==) :: ActivityTask -> ActivityTask -> Bool # (/=) :: ActivityTask -> ActivityTask -> Bool #
Ord ActivityTask
Instance details Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask Methods compare :: ActivityTask -> ActivityTask -> Ordering # (<) :: ActivityTask -> ActivityTask -> Bool # (<=) :: ActivityTask -> ActivityTask -> Bool # (>) :: ActivityTask -> ActivityTask -> Bool # (>=) :: ActivityTask -> ActivityTask -> Bool # max :: ActivityTask -> ActivityTask -> ActivityTask # min :: ActivityTask -> ActivityTask -> ActivityTask #
Message ActivityTask
Instance details Defined in Proto.Temporal.Sdk.Core.ActivityTask.ActivityTask Methods messageName :: Proxy ActivityTask -> Text # packedMessageDescriptor :: Proxy ActivityTask -> ByteString # packedFileDescriptor :: Proxy ActivityTask -> ByteString # defMessage :: ActivityTask # fieldsByTag :: Map Tag (FieldDescriptor ActivityTask) # fieldsByTextFormatName :: Map String (FieldDescriptor ActivityTask) # unknownFields :: Lens' ActivityTask FieldSet # parseMessage :: Parser ActivityTask # buildMessage :: ActivityTask -> Builder #
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 Methods fieldOf :: Functor f => Proxy# "maybe'variant" -> (Maybe ActivityTask'Variant -> f (Maybe ActivityTask'Variant)) -> ActivityTask -> f ActivityTask #

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

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 Methods rnf :: WorkflowActivationCompletion -> () #
Show WorkflowActivationCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods showsPrec :: Int -> WorkflowActivationCompletion -> ShowS # show :: WorkflowActivationCompletion -> String # showList :: [WorkflowActivationCompletion] -> ShowS #
Eq WorkflowActivationCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods (==) :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Bool # (/=) :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Bool #
Ord WorkflowActivationCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods compare :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Ordering # (<) :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Bool # (<=) :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Bool # (>) :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Bool # (>=) :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> Bool # max :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> WorkflowActivationCompletion # min :: WorkflowActivationCompletion -> WorkflowActivationCompletion -> WorkflowActivationCompletion #
Message WorkflowActivationCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods messageName :: Proxy WorkflowActivationCompletion -> Text # packedMessageDescriptor :: Proxy WorkflowActivationCompletion -> ByteString # packedFileDescriptor :: Proxy WorkflowActivationCompletion -> ByteString # defMessage :: WorkflowActivationCompletion # fieldsByTag :: Map Tag (FieldDescriptor WorkflowActivationCompletion) # fieldsByTextFormatName :: Map String (FieldDescriptor WorkflowActivationCompletion) # unknownFields :: Lens' WorkflowActivationCompletion FieldSet # parseMessage :: Parser WorkflowActivationCompletion # buildMessage :: WorkflowActivationCompletion -> Builder #
HasField WorkflowActivationCompletion "failed" Failure
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods fieldOf :: Functor f => Proxy# "failed" -> (Failure -> f Failure) -> WorkflowActivationCompletion -> f WorkflowActivationCompletion #
HasField WorkflowActivationCompletion "runId" Text
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods fieldOf :: Functor f => Proxy# "runId" -> (Text -> f Text) -> WorkflowActivationCompletion -> f WorkflowActivationCompletion #
HasField WorkflowActivationCompletion "successful" Success
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods fieldOf :: Functor f => Proxy# "successful" -> (Success -> f Success) -> WorkflowActivationCompletion -> f WorkflowActivationCompletion #
HasField WorkflowActivationCompletion "maybe'failed" (Maybe Failure)
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods fieldOf :: Functor f => Proxy# "maybe'failed" -> (Maybe Failure -> f (Maybe Failure)) -> WorkflowActivationCompletion -> f WorkflowActivationCompletion #
HasField WorkflowActivationCompletion "maybe'status" (Maybe WorkflowActivationCompletion'Status)
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods fieldOf :: Functor f => Proxy# "maybe'status" -> (Maybe WorkflowActivationCompletion'Status -> f (Maybe WorkflowActivationCompletion'Status)) -> WorkflowActivationCompletion -> f WorkflowActivationCompletion #
HasField WorkflowActivationCompletion "maybe'successful" (Maybe Success)
Instance details Defined in Proto.Temporal.Sdk.Core.WorkflowCompletion.WorkflowCompletion Methods fieldOf :: Functor f => Proxy# "maybe'successful" -> (Maybe Success -> f (Maybe Success)) -> WorkflowActivationCompletion -> f WorkflowActivationCompletion #

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

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 Methods showsPrec :: Int -> ActivityTaskCompletion -> ShowS # show :: ActivityTaskCompletion -> String # showList :: [ActivityTaskCompletion] -> ShowS #
Eq ActivityTaskCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods (==) :: ActivityTaskCompletion -> ActivityTaskCompletion -> Bool # (/=) :: ActivityTaskCompletion -> ActivityTaskCompletion -> Bool #
Ord ActivityTaskCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods compare :: ActivityTaskCompletion -> ActivityTaskCompletion -> Ordering # (<) :: ActivityTaskCompletion -> ActivityTaskCompletion -> Bool # (<=) :: ActivityTaskCompletion -> ActivityTaskCompletion -> Bool # (>) :: ActivityTaskCompletion -> ActivityTaskCompletion -> Bool # (>=) :: ActivityTaskCompletion -> ActivityTaskCompletion -> Bool # max :: ActivityTaskCompletion -> ActivityTaskCompletion -> ActivityTaskCompletion # min :: ActivityTaskCompletion -> ActivityTaskCompletion -> ActivityTaskCompletion #
Message ActivityTaskCompletion
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods messageName :: Proxy ActivityTaskCompletion -> Text # packedMessageDescriptor :: Proxy ActivityTaskCompletion -> ByteString # packedFileDescriptor :: Proxy ActivityTaskCompletion -> ByteString # defMessage :: ActivityTaskCompletion # fieldsByTag :: Map Tag (FieldDescriptor ActivityTaskCompletion) # fieldsByTextFormatName :: Map String (FieldDescriptor ActivityTaskCompletion) # unknownFields :: Lens' ActivityTaskCompletion FieldSet # parseMessage :: Parser ActivityTaskCompletion # buildMessage :: ActivityTaskCompletion -> Builder #
HasField ActivityTaskCompletion "result" ActivityExecutionResult
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods fieldOf :: Functor f => Proxy# "result" -> (ActivityExecutionResult -> f ActivityExecutionResult) -> ActivityTaskCompletion -> f ActivityTaskCompletion #
HasField ActivityTaskCompletion "taskToken" ByteString
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods fieldOf :: Functor f => Proxy# "taskToken" -> (ByteString -> f ByteString) -> ActivityTaskCompletion -> f ActivityTaskCompletion #
HasField ActivityTaskCompletion "maybe'result" (Maybe ActivityExecutionResult)
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods fieldOf :: Functor f => Proxy# "maybe'result" -> (Maybe ActivityExecutionResult -> f (Maybe ActivityExecutionResult)) -> ActivityTaskCompletion -> f ActivityTaskCompletion #

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

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 Methods showsPrec :: Int -> ActivityHeartbeat -> ShowS # show :: ActivityHeartbeat -> String # showList :: [ActivityHeartbeat] -> ShowS #
Eq ActivityHeartbeat
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods (==) :: ActivityHeartbeat -> ActivityHeartbeat -> Bool # (/=) :: ActivityHeartbeat -> ActivityHeartbeat -> Bool #
Ord ActivityHeartbeat
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods compare :: ActivityHeartbeat -> ActivityHeartbeat -> Ordering # (<) :: ActivityHeartbeat -> ActivityHeartbeat -> Bool # (<=) :: ActivityHeartbeat -> ActivityHeartbeat -> Bool # (>) :: ActivityHeartbeat -> ActivityHeartbeat -> Bool # (>=) :: ActivityHeartbeat -> ActivityHeartbeat -> Bool # max :: ActivityHeartbeat -> ActivityHeartbeat -> ActivityHeartbeat # min :: ActivityHeartbeat -> ActivityHeartbeat -> ActivityHeartbeat #
Message ActivityHeartbeat
Instance details Defined in Proto.Temporal.Sdk.Core.CoreInterface Methods messageName :: Proxy ActivityHeartbeat -> Text # packedMessageDescriptor :: Proxy ActivityHeartbeat -> ByteString # packedFileDescriptor :: Proxy ActivityHeartbeat -> ByteString # defMessage :: ActivityHeartbeat # fieldsByTag :: Map Tag (FieldDescriptor ActivityHeartbeat) # fieldsByTextFormatName :: Map String (FieldDescriptor ActivityHeartbeat) # unknownFields :: Lens' ActivityHeartbeat FieldSet # parseMessage :: Parser ActivityHeartbeat # buildMessage :: ActivityHeartbeat -> Builder #
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 #

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

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 HistoryPusher Source #

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 Methods showsPrec :: Int -> History -> ShowS # show :: History -> String # showList :: [History] -> ShowS #
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 Methods compare :: History -> History -> Ordering # (<) :: History -> History -> Bool # (<=) :: History -> History -> Bool # (>) :: History -> History -> Bool # (>=) :: History -> History -> Bool # max :: History -> History -> History # min :: History -> History -> History #
Message History
Instance details Defined in Proto.Temporal.Api.History.V1.Message Methods messageName :: Proxy History -> Text # packedMessageDescriptor :: Proxy History -> ByteString # packedFileDescriptor :: Proxy History -> ByteString # defMessage :: History # fieldsByTag :: Map Tag (FieldDescriptor History) # fieldsByTextFormatName :: Map String (FieldDescriptor History) # unknownFields :: Lens' History FieldSet # parseMessage :: Parser History # buildMessage :: History -> Builder #
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 Methods fieldOf :: Functor f => Proxy# "history" -> (History -> f History) -> GetWorkflowExecutionHistoryResponse -> f GetWorkflowExecutionHistoryResponse #
HasField GetWorkflowExecutionHistoryReverseResponse "history" History
Instance details Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse Methods fieldOf :: Functor f => Proxy# "history" -> (History -> f History) -> GetWorkflowExecutionHistoryReverseResponse -> f GetWorkflowExecutionHistoryReverseResponse #
HasField PollWorkflowTaskQueueResponse "history" History
Instance details Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse Methods fieldOf :: Functor f => Proxy# "history" -> (History -> f History) -> PollWorkflowTaskQueueResponse -> f PollWorkflowTaskQueueResponse #
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 Methods fieldOf :: Functor f => Proxy# "maybe'history" -> (Maybe History -> f (Maybe History)) -> GetWorkflowExecutionHistoryResponse -> f GetWorkflowExecutionHistoryResponse #
HasField GetWorkflowExecutionHistoryReverseResponse "maybe'history" (Maybe History)
Instance details Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse Methods fieldOf :: Functor f => Proxy# "maybe'history" -> (Maybe History -> f (Maybe History)) -> GetWorkflowExecutionHistoryReverseResponse -> f GetWorkflowExecutionHistoryReverseResponse #
HasField PollWorkflowTaskQueueResponse "maybe'history" (Maybe History)
Instance details Defined in Proto.Temporal.Api.Workflowservice.V1.RequestResponse Methods fieldOf :: Functor f => Proxy# "maybe'history" -> (Maybe History -> f (Maybe History)) -> PollWorkflowTaskQueueResponse -> f PollWorkflowTaskQueueResponse #

pushHistory :: HistoryPusher -> WorkflowId -> Either ByteString History -> IO (Either WorkerError ()) Source #

closeHistory :: HistoryPusher -> IO () Source #

class KnownWorkerType (ty :: WorkerType) where Source #

Methods

knownWorkerType :: SWorkerType ty Source #

Instances

Instances details

KnownWorkerType 'Real Source #
Instance details Defined in Temporal.Core.Worker Methods knownWorkerType :: SWorkerType 'Real Source #
KnownWorkerType 'Replay Source #
Instance details Defined in Temporal.Core.Worker Methods knownWorkerType :: SWorkerType 'Replay Source #