watch

Documentation

Index

• func DiffModuleReleaseMetaChannels(oldModuleReleaseMeta, newModuleReleaseMeta *v1beta2.ModuleReleaseMeta) map[string]v1beta2.ChannelVersionAssignment
• func GetAffectedKymas(kymas *v1beta2.KymaList, moduleName string, ...) []*types.NamespacedName
• type ChangeHandlerClient
• type MandatoryTemplateChangeHandler
  • func NewMandatoryTemplateChangeHandler(handlerClient ChangeHandlerClient) *MandatoryTemplateChangeHandler
  • func (h *MandatoryTemplateChangeHandler) Watch() handler.MapFunc
• type ModuleReleaseMetaEventHandler
  • func NewModuleReleaseMetaEventHandler(handlerClient ChangeHandlerClient) *ModuleReleaseMetaEventHandler
• type TemplateChangeHandler
  • func NewTemplateChangeHandler(handlerClient ChangeHandlerClient) *TemplateChangeHandler
  • func (h *TemplateChangeHandler) Watch() handler.MapFunc
• type TypedModuleReleaseMetaEventHandler
  • func (m TypedModuleReleaseMetaEventHandler[object, request]) Create(ctx context.Context, event event.CreateEvent, ...)
  • func (m TypedModuleReleaseMetaEventHandler[object, request]) Delete(ctx context.Context, event event.DeleteEvent, ...)
  • func (m TypedModuleReleaseMetaEventHandler[object, request]) Generic(ctx context.Context, event event.GenericEvent, ...)
  • func (m TypedModuleReleaseMetaEventHandler[object, request]) Update(ctx context.Context, event event.UpdateEvent, ...)

Functions

func DiffModuleReleaseMetaChannels

func DiffModuleReleaseMetaChannels(oldModuleReleaseMeta, newModuleReleaseMeta *v1beta2.ModuleReleaseMeta) map[string]v1beta2.ChannelVersionAssignment

DiffModuleReleaseMetaChannels determines the difference between the old and new ModuleReleaseMeta channels. It returns a map of the channels that have been updated or added.

func GetAffectedKymas

func GetAffectedKymas(kymas *v1beta2.KymaList, moduleName string,
	newChannelAssignments map[string]v1beta2.ChannelVersionAssignment,
) []*types.NamespacedName

GetAffectedKymas determines which Kymas are affected by the update. It returns a list of Kymas that have modules assigned to the updated channels.

Types

type ChangeHandlerClient

type ChangeHandlerClient interface {
	client.Reader
}

type MandatoryTemplateChangeHandler

type MandatoryTemplateChangeHandler struct {
	client.Reader
}

func NewMandatoryTemplateChangeHandler

func NewMandatoryTemplateChangeHandler(handlerClient ChangeHandlerClient) *MandatoryTemplateChangeHandler

func (*MandatoryTemplateChangeHandler) Watch

func (h *MandatoryTemplateChangeHandler) Watch() handler.MapFunc

type ModuleReleaseMetaEventHandler

type ModuleReleaseMetaEventHandler = TypedModuleReleaseMetaEventHandler[client.Object, reconcile.Request]

func NewModuleReleaseMetaEventHandler

func NewModuleReleaseMetaEventHandler(handlerClient ChangeHandlerClient) *ModuleReleaseMetaEventHandler

type TemplateChangeHandler

type TemplateChangeHandler struct {
	client.Reader
}

func NewTemplateChangeHandler

func NewTemplateChangeHandler(handlerClient ChangeHandlerClient) *TemplateChangeHandler

func (*TemplateChangeHandler) Watch

func (h *TemplateChangeHandler) Watch() handler.MapFunc

type TypedModuleReleaseMetaEventHandler

type TypedModuleReleaseMetaEventHandler[object any, request comparable] struct {
	client.Reader

	CreateFunc func(context.Context, event.TypedCreateEvent[object], workqueue.TypedRateLimitingInterface[request])

	UpdateFunc func(context.Context, event.TypedUpdateEvent[object], workqueue.TypedRateLimitingInterface[request])

	DeleteFunc func(context.Context, event.TypedDeleteEvent[object], workqueue.TypedRateLimitingInterface[request])

	GenericFunc func(context.Context, event.TypedGenericEvent[object], workqueue.TypedRateLimitingInterface[request])
}

TypedModuleReleaseMetaEventHandler implements handler.EventHandler.

func (TypedModuleReleaseMetaEventHandler[object, request]) Create

func (m TypedModuleReleaseMetaEventHandler[object, request]) Create(ctx context.Context, event event.CreateEvent,
	rli workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Create handles Create events.

func (TypedModuleReleaseMetaEventHandler[object, request]) Delete

func (m TypedModuleReleaseMetaEventHandler[object, request]) Delete(ctx context.Context, event event.DeleteEvent,
	rli workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Delete handles Delete events.

func (TypedModuleReleaseMetaEventHandler[object, request]) Generic

func (m TypedModuleReleaseMetaEventHandler[object, request]) Generic(ctx context.Context, event event.GenericEvent,
	rli workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Generic handles generic events.

func (TypedModuleReleaseMetaEventHandler[object, request]) Update

func (m TypedModuleReleaseMetaEventHandler[object, request]) Update(ctx context.Context, event event.UpdateEvent,
	rli workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Update handles Update events.