addtasks

Documentation

Index

• func Invoke(ctx context.Context, shardContext shard.Context, deserializer TaskDeserializer, ...) (*historyservice.AddTasksResponse, error)
• type TaskDeserializer

Functions

func Invoke

func Invoke(
	ctx context.Context,
	shardContext shard.Context,
	deserializer TaskDeserializer,
	numShards int,
	req *historyservice.AddTasksRequest,
	taskRegistry tasks.TaskCategoryRegistry,
) (*historyservice.AddTasksResponse, error)

Invoke is the implementation of the history service's AddTasks API. This exposes the shard.Context.AddTasks API via the history service. This method works by batching tasks by workflow run, and then invoking the relevant shard's AddTasks API for each task batch. See historyservice.HistoryServiceClient.AddTasks for more details. We don't do any validation on the shard ID because that must have been done by whoever provided the shard.Context to this method.

Types

type TaskDeserializer

type TaskDeserializer interface {
	DeserializeTask(category tasks.Category, blob *commonpb.DataBlob) (tasks.Task, error)
}

TaskDeserializer is a trimmed version of go.temporal.io/server/common/persistence/serialization.Serializer that requires only the DeserializeTask method.