consumer

package
v1.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2026 License: Apache-2.0 Imports: 11 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CascadingDelete

type CascadingDelete struct {
	// contains filtered or unexported fields
}

CascadingDelete implements a message queue consumer that watches for resource deletion events and then fans them out to another local type. You almost certainly want a resource label to be defined corrsponding to the messages's resource ID, or you will just delete everything.

func NewCascadingDelete

func NewCascadingDelete(client client.Client, resources client.ObjectList, options ...Option) *CascadingDelete

NewCascadingDelete creates a new cascading deletion consumer.

func (*CascadingDelete) Consume

func (c *CascadingDelete) Consume(ctx context.Context, envelope *messaging.Envelope) error

Consume receives project events. If the resource is being deleted, we propagate that deletion request to all local resources that reference that resource.

type Option

type Option func(c *CascadingDelete)

Options defines a set of runtime composable options.

func WithNamespace

func WithNamespace(namespace string) Option

WithNamespace sets the namespace in which to each for resources.

func WithResourceLabel

func WithResourceLabel(label string) Option

WithResourceLabel creates a label selector that will match the value passed in the messages's resource ID.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL