numaflowcontroller

package

v0.26.2 Latest Latest Go to latest Published: Sep 23, 2025 License: Apache-2.0 Imports: 39 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 NumaflowControllerReconciler
- func NewNumaflowControllerReconciler(client client.Client, scheme *k8sRuntime.Scheme, rawConfig *rest.Config, ...) (*NumaflowControllerReconciler, error)

Constants ¶

View Source

const (
	ControllerNumaflowController       = "numaflowcontroller-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 NumaflowControllerReconciler ¶

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

NumaflowControllerReconciler reconciles a NumaflowController object

func NewNumaflowControllerReconciler ¶

func NewNumaflowControllerReconciler(
	client client.Client,
	scheme *k8sRuntime.Scheme,
	rawConfig *rest.Config,
	kubectl kubeUtil.Kubectl,
	customMetrics *metrics.CustomMetrics,
	recorder record.EventRecorder,
) (*NumaflowControllerReconciler, error)

func (*NumaflowControllerReconciler) ErrorHandler ¶

func (r *NumaflowControllerReconciler) ErrorHandler(ctx context.Context, numaflowController *apiv1.NumaflowController, err error, reason, msg string)

func (*NumaflowControllerReconciler) Reconcile ¶

func (r *NumaflowControllerReconciler) 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 (*NumaflowControllerReconciler) SetupWithManager ¶

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

SetupWithManager sets up the controller with the Manager.

Source Files ¶

View all Source files

numaflowcontroller_controller.go

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