clusterplatform

Documentation

Index

• Constants
• func GetActiveClusterPlatform(ctx context.Context, c ctrl.Client) (*operatorapi.SonataFlowClusterPlatform, error)
• func IsActive(p *operatorapi.SonataFlowClusterPlatform) bool
• func IsSecondary(p *operatorapi.SonataFlowClusterPlatform) bool
• type Action
  • func NewInitializeAction() Action

Constants

const (
	PlatformServices operatorapi.WorkFlowCapability = "services"
)

Functions

func GetActiveClusterPlatform

func GetActiveClusterPlatform(ctx context.Context, c ctrl.Client) (*operatorapi.SonataFlowClusterPlatform, error)

GetActiveClusterPlatform returns the currently installed active cluster platform.

func IsActive

func IsActive(p *operatorapi.SonataFlowClusterPlatform) bool

IsActive determines if the given cluster platform is being used.

func IsSecondary

func IsSecondary(p *operatorapi.SonataFlowClusterPlatform) bool

IsSecondary determines if the given cluster platform is marked as secondary.

Types

type Action

type Action interface {
	client.Injectable

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

	// returns true if the action can handle the cluster platform
	CanHandle(ctx context.Context, cPlatform *v08.SonataFlowClusterPlatform) bool

	// executes the handling function
	Handle(ctx context.Context, cPlatform *v08.SonataFlowClusterPlatform) error
}

Action --.

func NewInitializeAction

func NewInitializeAction() Action

NewInitializeAction returns an action that initializes the platform configuration when not provided by the user.