observe

package

v1.5.2 Latest Latest Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/openshift/origin

Links

Documentation ¶

Index ¶

func ObserveResource(ctx context.Context, log logr.Logger, client *dynamic.DynamicClient, ...)
type ObservationSink
type ObservationSource
- func Source(log logr.Logger) (ObservationSource, error)
type ObservationType
type ResourceObservation

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ObserveResource ¶

func ObserveResource(ctx context.Context, log logr.Logger, client *dynamic.DynamicClient, gvr schema.GroupVersionResource, resourceC chan<- *ResourceObservation)

ObserveResource monitors a Kubernetes resource for changes

Types ¶

type ObservationSink ¶

type ObservationSink func(ctx context.Context, log logr.Logger, resourceC <-chan *ResourceObservation) chan struct{}

type ObservationSource ¶

type ObservationSource func(ctx context.Context, log logr.Logger, resourceC chan<- *ResourceObservation) chan struct{}

func Source ¶

func Source(log logr.Logger) (ObservationSource, error)

type ObservationType ¶

type ObservationType string

const (
	ObservationTypeAdd    ObservationType = "add"
	ObservationTypeUpdate ObservationType = "update"
	ObservationTypeDelete ObservationType = "delete"
)

type ResourceObservation ¶

type ResourceObservation struct {
	Group    string `json:"group"`
	Version  string `json:"version"`
	Resource string `json:"resource"`

	UID types.UID `json:"uid"`

	Object    *unstructured.Unstructured `json:"object,omitempty"`
	OldObject *unstructured.Unstructured `json:"oldObject,omitempty"`

	ObservationType ObservationType `json:"observationType"`
	ObservationTime time.Time       `json:"observationTime"`
}

Source Files ¶

View all Source files

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