objectstatus

Documentation

Index

• type Service
  • func NewService(cfg *v1alpha1.OperatorConfig, pipeline svc_pipeline.Service, ...) Service

Types

type Service

type Service interface {
	// TODO: Adopt iterators.
	Watch(ctx context.Context, namespace string, c chan<- *apipipeline.ObjectStatusChange) error

	CapsulesInitialized()
	RegisterCapsule(namespace string, capsule string)
	UnregisterCapsule(namespace string, capsule string)

	UpdateStatus(namespace string, capsule string, pluginID uuid.UUID, change *apiplugin.ObjectStatusChange)
}

func NewService

func NewService(
	cfg *v1alpha1.OperatorConfig,
	pipeline svc_pipeline.Service,
	logger logr.Logger,
) Service