ppnd

Nov 25, 2024

Changes in this version

+ func IsRequestingPause(pauseRequester PauseRequester, rollout client.Object) bool

Nov 18, 2024

Changes in this version

+ func ProcessChildObjectWithPPND(ctx context.Context, k8sclient client.Client, rollout client.Object, ...) (bool, error)

+ type PauseModule struct

+ PauseRequests map[string]*bool

+ func GetPauseModule() *PauseModule

+ func (pm *PauseModule) DeletePauseRequest(requester string)

+ func (pm *PauseModule) GetISBServiceKey(namespace string, name string) string

+ func (pm *PauseModule) GetNumaflowControllerKey(namespace string) string

+ func (pm *PauseModule) GetPauseRequest(requester string) (*bool, bool)

+ func (pm *PauseModule) NewPauseRequest(requester string)

+ func (pm *PauseModule) PausePipeline(ctx context.Context, c client.Client, pipeline *unstructured.Unstructured) error

+ func (pm *PauseModule) RunPipelineIfSafe(ctx context.Context, c client.Client, pipeline *unstructured.Unstructured) (bool, error)

+ func (pm *PauseModule) UpdatePauseRequest(requester string, pause bool) bool

+ func (pm *PauseModule) UpdatePipelineLifecycle(ctx context.Context, c client.Client, pipeline *unstructured.Unstructured, ...) error

+ type PauseRequester interface

+ GetChildTypeString func() string

+ GetPipelineList func(ctx context.Context, rolloutNamespace string, rolloutName string) (*unstructured.UnstructuredList, error)

+ GetRolloutKey func(rolloutNamespace string, rolloutName string) string

+ MarkRolloutPaused func(ctx context.Context, rollout client.Object, paused bool) error