temporal 一些关键概念
所属分类 temporal
浏览量 640
https://docs.temporal.io/docs/concepts
Namespace
Temporal guarantees a unique Workflow Id within a Namespace
An Activity Definition is the code that defines the constraints of an Activity Task Execution.
Activity Id
A unique Id that identifies an Activity Execution
A Task Token is a unique Id that correlates to an Activity Execution.
Activity Execution completion calls take either a single Task Token, or the Namespace, Workflow Id, and Activity Id as a set of arguments
Task
A Task is the context that a Worker needs to progress with a specific Workflow Execution or Activity Execution.
two types of Tasks
Activity Task
Workflow Task
Task Queue
Workers poll for Tasks in Task Queues via synchronous RPC.
Task Queues enable load balancing across a large number of Worker Processes
Task Routing
routing of specific Tasks to specific Worker Processes or even a specific process.
Task Token
Workflow Execution
A Workflow Execution is either Running or Closed
closed ( Completed , Continued As New, Failed, TimedOut, Cancelled, Terminated )
A Workflow Execution is uniquely identified by its Namespace, Workflow Id, and Run Id.
A Run Id is a globally unique, platform-level identifier for a Workflow Execution.
A Workflow Id is a customizable, application-level identifier for a Workflow Execution that is unique to an Open Workflow Execution within a Namespace.
Event
https://github.com/temporalio/api/blob/master/temporal/api/enums/v1/event_type.proto
Event History
A Temporal Cluster is the Temporal Server paired with persistence.
The Temporal Server consists of four independently scalable services:
Frontend gateway: for rate limiting, routing, authorizing
History subsystem: maintains data (mutable state, queues, and timers)
Matching subsystem: hosts Task Queues for dispatching
Worker service: for internal background workflows
Worker
Worker Entity
A Worker Entity is the individual Worker within a Worker Process that listens to a specific Task Queue.
A Worker Process is responsible for polling a Task Queue, dequeueing a Task,
executing your code in response to a Task, and responding to the Temporal Cluster with the results.
A Worker Program is the static code that defines the constraints of the Worker Process
上一篇
下一篇
temporal 监控指标
使用arthas 观察 temporal worker grpc 方法调用
temporal local activity vs activity
CompletableFuture 实例
scala 泛型 上下界 非变 协变 逆变
temporal Workers 为何使用轮询拉取任务