hooks

type SyncMatchOutcome int

type TaskAddHookDetails struct {
	DeploymentVersion *deploymentpb.WorkerDeploymentVersion
	IsSyncMatch       bool // Deprecated: use SyncMatchOutcome instead.
	SyncMatchOutcome  SyncMatchOutcome
}

type TaskHook interface {
	// Start is called when the task queue partition manager for the hooks partition is started
	Start()
	// Stop is called when the task queue partition manager for the hooks partition is stopped
	Stop()
	// ProcessTaskAdd is called for each Task addition (whether sync or async matching)
	ProcessTaskAdd(ctx context.Context, event *TaskAddHookDetails)
}

type TaskHookFactory interface {
	// Create returns a TaskHook instance that will be leveraged as part
	// of the specific task queue partition (as specified in the details).
	// This might also return nil, if no hooking into that task queue
	// partition is desired.
	Create(details *TaskHookFactoryCreateDetails) TaskHook
}

type TaskHookFactoryCreateDetails struct {
	Namespace *namespace.Namespace
	Partition TaskQueuePartition
}

type TaskQueuePartition interface {
	NamespaceId() string
	TaskQueue() *tqid.TaskQueue
	TaskType() enumspb.TaskQueueType
	Kind() enumspb.TaskQueueKind
}