plugins

Documentation

Index

• Variables
• func GetAvailablePlugins(availablePlugins []string) []string
• func IsVmbasedProviders(provider string) bool
• func RegisterProvider(provider string, providerInterface ProviderInterface)
• type ProviderInterface
  • func GetProviderPlugin(ctx context.Context, provider string) (ProviderInterface, error)

Variables

var SupportedProviders = make(map[string]interface{})

Functions

func GetAvailablePlugins

func GetAvailablePlugins(availablePlugins []string) []string

func IsVmbasedProviders

func IsVmbasedProviders(provider string) bool

func RegisterProvider

func RegisterProvider(provider string, providerInterface ProviderInterface)

Types

type ProviderInterface

type ProviderInterface interface {
	// Parse package and conf into cluster which clusterManager will register into db.
	ParseClusterConf(ctx context.Context, versionId, runtimeId, conf string, clusterWrapper *models.ClusterWrapper) error
	SplitJobIntoTasks(ctx context.Context, job *models.Job) (*models.TaskLayer, error)
	HandleSubtask(ctx context.Context, task *models.Task) error
	WaitSubtask(ctx context.Context, task *models.Task) error
	DescribeSubnets(ctx context.Context, req *pb.DescribeSubnetsRequest) (*pb.DescribeSubnetsResponse, error)
	CheckResource(ctx context.Context, clusterWrapper *models.ClusterWrapper) error
	DescribeVpc(ctx context.Context, runtimeId, vpcId string) (*models.Vpc, error)
	ValidateCredential(ctx context.Context, runtimeId, url, credential, zone string) error
	DescribeRuntimeProviderZones(ctx context.Context, url, credential string) ([]string, error)
	UpdateClusterStatus(ctx context.Context, job *models.Job) error
	DescribeClusterDetails(ctx context.Context, cluster *models.ClusterWrapper) error
}

func GetProviderPlugin

func GetProviderPlugin(ctx context.Context, provider string) (ProviderInterface, error)