integration

Documentation

Index

• Variables
• func Add(mgr manager.Manager) error
• type Action
  • func NewInitializeAction() Action
  • func NewMonitorAction() Action
  • func NewPlatformSetupAction() Action
• type HealthCheck
  • func NewHealthCheck(body []byte) (*HealthCheck, error)
• type HealthCheckResponse
• type HealthCheckState
• type StatusChangedPredicate
  • func (StatusChangedPredicate) Update(e event.UpdateEvent) bool

Variables

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

Log --.

Functions

func Add

func Add(mgr manager.Manager) 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 HealthCheck

type HealthCheck struct {
	Status HealthCheckState      `json:"status,omitempty"`
	Checks []HealthCheckResponse `json:"checks,omitempty"`
}

func NewHealthCheck

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

type HealthCheckResponse

type HealthCheckResponse struct {
	Name   string                 `json:"name,omitempty"`
	Status HealthCheckState       `json:"status,omitempty"`
	Data   map[string]interface{} `json:"data,omitempty"`
}

type HealthCheckState

type HealthCheckState string

const (
	HealthCheckStateDown HealthCheckState = "DOWN"
	HealthCheckStateUp   HealthCheckState = "UP"
)

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.