mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
60 lines
1.4 KiB
Go
60 lines
1.4 KiB
Go
package tasktoken
|
|
|
|
import (
|
|
clockspb "github.com/hanzoai/tasks/api/clock/v1"
|
|
tokenspb "github.com/hanzoai/tasks/api/token/v1"
|
|
"google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
func NewWorkflowTaskToken(
|
|
namespaceID string,
|
|
workflowID string,
|
|
runID string,
|
|
scheduledEventID int64,
|
|
startedEventId int64,
|
|
startedTime *timestamppb.Timestamp,
|
|
attempt int32,
|
|
clock *clockspb.VectorClock,
|
|
version int64,
|
|
) *tokenspb.Task {
|
|
return &tokenspb.Task{
|
|
NamespaceId: namespaceID,
|
|
WorkflowId: workflowID,
|
|
RunId: runID,
|
|
ScheduledEventId: scheduledEventID,
|
|
StartedEventId: startedEventId,
|
|
StartedTime: startedTime,
|
|
Attempt: attempt,
|
|
Clock: clock,
|
|
Version: version,
|
|
}
|
|
}
|
|
|
|
func NewActivityTaskToken(
|
|
namespaceID string,
|
|
workflowID string,
|
|
runID string,
|
|
scheduledEventID int64,
|
|
activityId string,
|
|
activityType string,
|
|
attempt int32,
|
|
clock *clockspb.VectorClock,
|
|
version int64,
|
|
startVersion int64,
|
|
componentRef []byte,
|
|
) *tokenspb.Task {
|
|
return &tokenspb.Task{
|
|
NamespaceId: namespaceID,
|
|
WorkflowId: workflowID,
|
|
RunId: runID,
|
|
ScheduledEventId: scheduledEventID,
|
|
ActivityType: activityType,
|
|
Attempt: attempt,
|
|
ActivityId: activityId,
|
|
Clock: clock,
|
|
Version: version,
|
|
StartVersion: startVersion,
|
|
ComponentRef: componentRef,
|
|
}
|
|
}
|