numaflowcontrollerrollout

package

v0.8.0 Latest Latest Go to latest Published: Nov 18, 2024 License: Apache-2.0 Imports: 42 Imported by: 0

Details

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

Repository

github.com/numaproj/numaplane

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func SplitYAMLToString(yamlData []byte) ([]string, error)
type NumaflowControllerRolloutReconciler
- func NewNumaflowControllerRolloutReconciler(client client.Client, s *runtime.Scheme, rawConfig *rest.Config, ...) (*NumaflowControllerRolloutReconciler, error)

Constants ¶

View Source

const (
	ControllerNumaflowControllerRollout = "numaflow-controller-rollout-controller"
	NumaflowControllerDeploymentName    = "numaflow-controller"
	DefaultNumaflowControllerImageName  = "numaflow"
)

Variables ¶

This section is empty.

Functions ¶

func SplitYAMLToString ¶

func SplitYAMLToString(yamlData []byte) ([]string, error)

SplitYAMLToString splits a YAML file into strings. Returns list of yamls found in the yaml. If an error occurs, returns objects that have been parsed so far too.

Types ¶

type NumaflowControllerRolloutReconciler ¶

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

NumaflowControllerRolloutReconciler reconciles a NumaflowControllerRollout object

func NewNumaflowControllerRolloutReconciler ¶

func NewNumaflowControllerRolloutReconciler(
	client client.Client,
	s *runtime.Scheme,
	rawConfig *rest.Config,
	kubectl kubeUtil.Kubectl,
	customMetrics *metrics.CustomMetrics,
	recorder record.EventRecorder,
) (*NumaflowControllerRolloutReconciler, error)

func (*NumaflowControllerRolloutReconciler) ErrorHandler ¶

func (r *NumaflowControllerRolloutReconciler) ErrorHandler(numaflowControllerRollout *apiv1.NumaflowControllerRollout, err error, reason, msg string)

func (*NumaflowControllerRolloutReconciler) GetChildTypeString ¶

func (r *NumaflowControllerRolloutReconciler) GetChildTypeString() string

for the purpose of logging

func (*NumaflowControllerRolloutReconciler) GetPipelineList ¶

func (r *NumaflowControllerRolloutReconciler) GetPipelineList(ctx context.Context, rolloutNamespace string, _ string) (*unstructured.UnstructuredList, error)

func (*NumaflowControllerRolloutReconciler) GetRolloutKey ¶

func (r *NumaflowControllerRolloutReconciler) GetRolloutKey(rolloutNamespace string, rolloutName string) string

func (*NumaflowControllerRolloutReconciler) MarkRolloutPaused ¶

func (r *NumaflowControllerRolloutReconciler) MarkRolloutPaused(ctx context.Context, rollout client.Object, paused bool) error

func (*NumaflowControllerRolloutReconciler) Reconcile ¶

func (r *NumaflowControllerRolloutReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.3/pkg/reconcile

func (*NumaflowControllerRolloutReconciler) SetupWithManager ¶

func (r *NumaflowControllerRolloutReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files ¶

View all Source files

numaflowcontrollerrollout_controller.go

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