Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var FinalizationTasks = tq.RegisterTaskClass(tq.TaskClass{ ID: "try-finalize-inv", Prototype: &taskspb.TryFinalizeInvocation{}, Kind: tq.Transactional, Queue: "finalizer", RoutingPrefix: "/internal/tasks/finalizer", })
FinalizationTasks describes how to route finalization tasks.
The handler is implemented in internal/services/finalizer.
Functions ¶
func StartInvocationFinalization ¶
func StartInvocationFinalization(ctx context.Context, id invocations.ID, updateInv bool)
StartInvocationFinalization changes invocation state to FINALIZING if updateInv is set, and enqueues a TryFinalizeInvocation task.
The caller is responsible for ensuring that the invocation is active.
TODO(nodir): this package is not a great place for this function, but there is no better package at the moment. Keep it here for now, but consider a new package as the code base grows.
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.