Documentation
¶
Index ¶
Constants ¶
View Source
const (
PlatformServices operatorapi.WorkFlowCapability = "services"
)
Variables ¶
This section is empty.
Functions ¶
func GetActiveClusterPlatform ¶
func GetActiveClusterPlatform(ctx context.Context) (*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.
Source Files
Click to show internal directories.
Click to hide internal directories.