Documentation
¶
Overview ¶
Package tasks contains task class definitions for ResultDB.
Index ¶
Constants ¶
This section is empty.
Variables ¶
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.
var NotifyFinalizedPublisher = tq.RegisterTaskClass(tq.TaskClass{ ID: "notify-finalized", Topic: v1NotifyFinalizedTopic, Prototype: &taskspb.NotifyInvocationFinalized{}, Kind: tq.Transactional, Custom: func(ctx context.Context, m proto.Message) (*tq.CustomPayload, error) { t := m.(*taskspb.NotifyInvocationFinalized) notification := t.Message blob, err := (protojson.MarshalOptions{Indent: "\t"}).Marshal(notification) if err != nil { return nil, err } if err := realms.ValidateRealmName(notification.Realm, realms.GlobalScope); err != nil { return nil, err } project, _ := realms.Split(notification.Realm) attrs := map[string]string{ "luci_project": project, } return &tq.CustomPayload{ Meta: attrs, Body: blob, }, nil }, })
NotifyFinalizedPublisher describes how to publish to cloud pub/sub notifications that an invocation has been finalized.
Functions ¶
func NotifyInvocationFinalized ¶
func NotifyInvocationFinalized(ctx context.Context, message *pb.InvocationFinalizedNotification)
NotifyInvocationFinalized transactionally enqueues a task to publish that the given invocation has been finalized.
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