integration

Documentation

Index

• Variables
• func Add(mgr manager.Manager) error
• func HasMatchingTraits(kit *v1.IntegrationKit, integration *v1.Integration) (bool, error)
• func LookupKitForIntegration(ctx context.Context, c k8sclient.Reader, integration *v1.Integration) (*v1.IntegrationKit, error)
• type Action
  • func NewBuildKitAction() Action
  • func NewDeployAction() Action
  • func NewErrorAction() Action
  • func NewInitializeAction() Action
  • func NewMonitorAction() Action
  • func NewNoopAction() Action
  • func NewPlatformSetupAction() Action
• type ReconcileIntegration
  • func (r *ReconcileIntegration) Reconcile(request reconcile.Request) (reconcile.Result, error)

Variables

var Log = log.Log.WithName("controller").WithName("integration")

Log --

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new Integration Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func HasMatchingTraits

func HasMatchingTraits(kit *v1.IntegrationKit, integration *v1.Integration) (bool, error)

HasMatchingTraits compare traits defined on kit against those defined on integration.

func LookupKitForIntegration

func LookupKitForIntegration(ctx context.Context, c k8sclient.Reader, integration *v1.Integration) (*v1.IntegrationKit, error)

LookupKitForIntegration --

Types

type Action

type Action interface {
	client.Injectable
	log.Injectable

	// a user friendly name for the action
	Name() string

	// returns true if the action can handle the integration
	CanHandle(integration *v1.Integration) bool

	// executes the handling function
	Handle(ctx context.Context, integration *v1.Integration) (*v1.Integration, error)
}

Action --

func NewBuildKitAction

func NewBuildKitAction() Action

NewBuildKitAction create an action that handles integration kit build

func NewDeployAction

func NewDeployAction() Action

NewDeployAction create an action that handles integration deploy

func NewErrorAction

func NewErrorAction() Action

NewErrorAction creates a new error action for an integration

func NewInitializeAction

func NewInitializeAction() Action

NewInitializeAction creates a new initialize action

func NewMonitorAction

func NewMonitorAction() Action

NewMonitorAction creates a new monitoring action for an integration

func NewNoopAction

func NewNoopAction() Action

NewNoopAction is used to put an integration resource out of the operator lifecycle.

The resource must be updated by an external entity (e.g. the kamel CLI) to a new state when ready to start a new workflow.

func NewPlatformSetupAction

func NewPlatformSetupAction() Action

NewPlatformSetupAction creates a new platform-setup action

type ReconcileIntegration

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

ReconcileIntegration reconciles a Integration object

func (*ReconcileIntegration) Reconcile

func (r *ReconcileIntegration) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Integration object and makes changes based on the state read and what is in the Integration.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.