tasktoken

package

v1.29.3 Latest Latest Go to latest Published: Feb 4, 2026 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/temporalio/temporal

Links

Open Source Insights

Documentation ¶

Index ¶

func NewActivityTaskToken(namespaceID string, workflowID string, runID string, scheduledEventID int64, ...) *tokenspb.Task
func NewWorkflowTaskToken(namespaceID string, workflowID string, runID string, scheduledEventID int64, ...) *tokenspb.Task
type Serializer
- func NewSerializer() *Serializer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewActivityTaskToken ¶

func NewActivityTaskToken(
	namespaceID string,
	workflowID string,
	runID string,
	scheduledEventID int64,
	activityId string,
	activityType string,
	attempt int32,
	clock *clockspb.VectorClock,
	version int64,
) *tokenspb.Task

func NewWorkflowTaskToken ¶

func NewWorkflowTaskToken(
	namespaceID string,
	workflowID string,
	runID string,
	scheduledEventID int64,
	startedEventId int64,
	startedTime *timestamppb.Timestamp,
	attempt int32,
	clock *clockspb.VectorClock,
	version int64,
) *tokenspb.Task

Types ¶

type Serializer ¶ added in v1.27.0

type Serializer struct{}

func NewSerializer ¶ added in v1.27.0

func NewSerializer() *Serializer

NewSerializer creates a new instance of Serializer

func (*Serializer) Deserialize ¶ added in v1.27.0

func (s *Serializer) Deserialize(data []byte) (*tokenspb.Task, error)

func (*Serializer) DeserializeNexusTaskToken ¶ added in v1.27.0

func (s *Serializer) DeserializeNexusTaskToken(data []byte) (*tokenspb.NexusTask, error)

func (*Serializer) DeserializeQueryTaskToken ¶ added in v1.27.0

func (s *Serializer) DeserializeQueryTaskToken(data []byte) (*tokenspb.QueryTask, error)

func (*Serializer) Serialize ¶ added in v1.27.0

func (s *Serializer) Serialize(taskToken *tokenspb.Task) ([]byte, error)

func (*Serializer) SerializeNexusTaskToken ¶ added in v1.27.0

func (s *Serializer) SerializeNexusTaskToken(taskToken *tokenspb.NexusTask) ([]byte, error)

func (*Serializer) SerializeQueryTaskToken ¶ added in v1.27.0

func (s *Serializer) SerializeQueryTaskToken(taskToken *tokenspb.QueryTask) ([]byte, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL