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

      Path Synopsis