messaging

type Consumer interface {
	// Consume consumes an event from the queue.
	Consume(ctx context.Context, envelope *Envelope) error
}

type Envelope struct {
	// ResourceID the GUID of a resource.
	ResourceID string
	// DeletionTimestamp describes whether the resource is being deleted
	// or not, and is used for routing.  If not set this is a creation or
	// update event.
	DeletionTimestamp *time.Time
}

type Queue interface {
	// Run starts the event queue consumption.  This is a blocking call.
	Run(ctx context.Context, consumers ...Consumer) error
}