integration

Documentation

Index

• Constants
• Variables
• func Add(ctx context.Context, mgr manager.Manager, c client.Client) error
• func NewHealthCheck(body []byte) (*v1.HealthCheck, error)
• type Action
  • func NewInitializeAction() Action
  • func NewMonitorAction() Action
  • func NewPlatformSetupAction() Action
• type StatusChangedPredicate
  • func (StatusChangedPredicate) Update(e event.UpdateEvent) bool

Constants

const (
	// The key used for propagating error details from Camel health to MicroProfile Health
	// (See CAMEL-17138).
	HealthCheckErrorMessage = "error.message"
)

Variables

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

Log --.

Functions

func Add

func Add(ctx context.Context, mgr manager.Manager, c client.Client) error

func NewHealthCheck

func NewHealthCheck(body []byte) (*v1.HealthCheck, error)

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 NewInitializeAction

func NewInitializeAction() Action

NewInitializeAction creates a new initialize action.

func NewMonitorAction

func NewMonitorAction() Action

func NewPlatformSetupAction

func NewPlatformSetupAction() Action

NewPlatformSetupAction creates a new platform-setup action.

type StatusChangedPredicate

type StatusChangedPredicate struct {
	predicate.Funcs
}

StatusChangedPredicate implements a generic update predicate function on status change.

func (StatusChangedPredicate) Update

func (StatusChangedPredicate) Update(e event.UpdateEvent) bool

Update implements default UpdateEvent filter for validating status change.