v1beta1

Documentation

Index

• func RegisterClusterFlowGeneratingHandler(ctx context.Context, controller ClusterFlowController, apply apply.Apply, ...)
• func RegisterClusterFlowStatusHandler(ctx context.Context, controller ClusterFlowController, ...)
• func RegisterClusterOutputGeneratingHandler(ctx context.Context, controller ClusterOutputController, apply apply.Apply, ...)
• func RegisterClusterOutputStatusHandler(ctx context.Context, controller ClusterOutputController, ...)
• func RegisterLoggingGeneratingHandler(ctx context.Context, controller LoggingController, apply apply.Apply, ...)
• func RegisterLoggingStatusHandler(ctx context.Context, controller LoggingController, condition condition.Cond, ...)
• type ClusterFlowCache
• type ClusterFlowClient
• type ClusterFlowController
• type ClusterFlowGeneratingHandler
• type ClusterFlowStatusHandler
• type ClusterOutputCache
• type ClusterOutputClient
• type ClusterOutputController
• type ClusterOutputGeneratingHandler
• type ClusterOutputStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type LoggingCache
• type LoggingClient
• type LoggingController
• type LoggingGeneratingHandler
• type LoggingStatusHandler

Functions

func RegisterClusterFlowGeneratingHandler

func RegisterClusterFlowGeneratingHandler(ctx context.Context, controller ClusterFlowController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterFlowGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterClusterFlowGeneratingHandler configures a ClusterFlowController to execute a ClusterFlowGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterFlowStatusHandler

func RegisterClusterFlowStatusHandler(ctx context.Context, controller ClusterFlowController, condition condition.Cond, name string, handler ClusterFlowStatusHandler)

RegisterClusterFlowStatusHandler configures a ClusterFlowController to execute a ClusterFlowStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterOutputGeneratingHandler

func RegisterClusterOutputGeneratingHandler(ctx context.Context, controller ClusterOutputController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterOutputGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterClusterOutputGeneratingHandler configures a ClusterOutputController to execute a ClusterOutputGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterOutputStatusHandler

func RegisterClusterOutputStatusHandler(ctx context.Context, controller ClusterOutputController, condition condition.Cond, name string, handler ClusterOutputStatusHandler)

RegisterClusterOutputStatusHandler configures a ClusterOutputController to execute a ClusterOutputStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterLoggingGeneratingHandler

func RegisterLoggingGeneratingHandler(ctx context.Context, controller LoggingController, apply apply.Apply,
	condition condition.Cond, name string, handler LoggingGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterLoggingGeneratingHandler configures a LoggingController to execute a LoggingGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterLoggingStatusHandler

func RegisterLoggingStatusHandler(ctx context.Context, controller LoggingController, condition condition.Cond, name string, handler LoggingStatusHandler)

RegisterLoggingStatusHandler configures a LoggingController to execute a LoggingStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

Types

type ClusterFlowCache

type ClusterFlowCache interface {
	generic.CacheInterface[*v1beta1.ClusterFlow]
}

ClusterFlowCache interface for retrieving ClusterFlow resources in memory.

type ClusterFlowClient

type ClusterFlowClient interface {
	generic.ClientInterface[*v1beta1.ClusterFlow, *v1beta1.ClusterFlowList]
}

ClusterFlowClient interface for managing ClusterFlow resources in Kubernetes.

type ClusterFlowController

type ClusterFlowController interface {
	generic.ControllerInterface[*v1beta1.ClusterFlow, *v1beta1.ClusterFlowList]
}

ClusterFlowController interface for managing ClusterFlow resources.

type ClusterFlowGeneratingHandler

type ClusterFlowGeneratingHandler func(obj *v1beta1.ClusterFlow, status v1beta1.FlowStatus) ([]runtime.Object, v1beta1.FlowStatus, error)

ClusterFlowGeneratingHandler is the top-level handler that is executed for every ClusterFlow event. It extends ClusterFlowStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type ClusterFlowStatusHandler

type ClusterFlowStatusHandler func(obj *v1beta1.ClusterFlow, status v1beta1.FlowStatus) (v1beta1.FlowStatus, error)

ClusterFlowStatusHandler is executed for every added or modified ClusterFlow. Should return the new status to be updated

type ClusterOutputCache

type ClusterOutputCache interface {
	generic.CacheInterface[*v1beta1.ClusterOutput]
}

ClusterOutputCache interface for retrieving ClusterOutput resources in memory.

type ClusterOutputClient

type ClusterOutputClient interface {
	generic.ClientInterface[*v1beta1.ClusterOutput, *v1beta1.ClusterOutputList]
}

ClusterOutputClient interface for managing ClusterOutput resources in Kubernetes.

type ClusterOutputController

type ClusterOutputController interface {
	generic.ControllerInterface[*v1beta1.ClusterOutput, *v1beta1.ClusterOutputList]
}

ClusterOutputController interface for managing ClusterOutput resources.

type ClusterOutputGeneratingHandler

type ClusterOutputGeneratingHandler func(obj *v1beta1.ClusterOutput, status v1beta1.OutputStatus) ([]runtime.Object, v1beta1.OutputStatus, error)

ClusterOutputGeneratingHandler is the top-level handler that is executed for every ClusterOutput event. It extends ClusterOutputStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type ClusterOutputStatusHandler

type ClusterOutputStatusHandler func(obj *v1beta1.ClusterOutput, status v1beta1.OutputStatus) (v1beta1.OutputStatus, error)

ClusterOutputStatusHandler is executed for every added or modified ClusterOutput. Should return the new status to be updated

type Interface

type Interface interface {
	ClusterFlow() ClusterFlowController
	ClusterOutput() ClusterOutputController
	Logging() LoggingController
}

func New

func New(controllerFactory controller.SharedControllerFactory) Interface

type LoggingCache

type LoggingCache interface {
	generic.NonNamespacedCacheInterface[*v1beta1.Logging]
}

LoggingCache interface for retrieving Logging resources in memory.

type LoggingClient

type LoggingClient interface {
	generic.NonNamespacedClientInterface[*v1beta1.Logging, *v1beta1.LoggingList]
}

LoggingClient interface for managing Logging resources in Kubernetes.

type LoggingController

type LoggingController interface {
	generic.NonNamespacedControllerInterface[*v1beta1.Logging, *v1beta1.LoggingList]
}

LoggingController interface for managing Logging resources.

type LoggingGeneratingHandler

type LoggingGeneratingHandler func(obj *v1beta1.Logging, status v1beta1.LoggingStatus) ([]runtime.Object, v1beta1.LoggingStatus, error)

LoggingGeneratingHandler is the top-level handler that is executed for every Logging event. It extends LoggingStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type LoggingStatusHandler

type LoggingStatusHandler func(obj *v1beta1.Logging, status v1beta1.LoggingStatus) (v1beta1.LoggingStatus, error)

LoggingStatusHandler is executed for every added or modified Logging. Should return the new status to be updated