common

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 18, 2021 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultChosenAllSvc = "ALL SERVICES"
	FlagNotSet          = "FlagNotSet"
	FlagIsInvalid       = "FlagIsInvalid"
	FlagIsValid         = "FlagIsValid"
)

nolint:golint

Variables

This section is empty.

Functions

func AddCapabilityCenter 

func AddCapabilityCenter(capName, capURL, capToken string) error

AddCapabilityCenter will add a cap center

func AddCapabilityIntoCluster 

func AddCapabilityIntoCluster(c client.Client, mapper discoverymapper.DiscoveryMapper, capability string) (string, error)

AddCapabilityIntoCluster will add a capability into K8s cluster, it is equal to apply a definition yaml and run `vela workloads/traits`

func BaseComplete 

func BaseComplete(env *types.EnvMeta, c common.Args, workloadName string, appName string, flagSet *pflag.FlagSet, workloadType string) (*api.Application, error)

BaseComplete will construct an Application from cli parameters.

func BuildRun 

func BuildRun(ctx context.Context, app *api.Application, client client.Client, env *types.EnvMeta, io util.IOStreams) error

BuildRun will build application and deploy from Appfile

func ConvertApplyTo 

func ConvertApplyTo(applyTo []string, workloads []types.Capability) []string

ConvertApplyTo will convert applyTo slice to workload capability name if CRD matches

func GetCapabilityConfigMap 

func GetCapabilityConfigMap(kubeClient client.Client, capabilityName string) (corev1.ConfigMap, error)

GetCapabilityConfigMap gets the ConfigMap which stores the information of a capability

func GetCapabilityFromCenter 

func GetCapabilityFromCenter(mapper discoverymapper.DiscoveryMapper, repoName, addonName string) (types.Capability, error)

GetCapabilityFromCenter will list all synced capabilities from cap center and return the specified one

func GetServicesWhenDescribingApplication 

func GetServicesWhenDescribingApplication(cmd *cobra.Command, app *api.Application) ([]string, error)

GetServicesWhenDescribingApplication gets the target services list either from cli `--svc` flag or from survey

func GetTraitDefinition 

func GetTraitDefinition(userNamespace string, c common.Args, workloadName *string, traitType string) (types.Capability, error)

GetTraitDefinition will get trait capability with applyTo converted

func HackForStandardTrait 

func HackForStandardTrait(tp types.Capability, client client.Client) error

HackForStandardTrait will do some hack install for standard capability

func InitApplication 

func InitApplication(env *types.EnvMeta, c common.Args, workloadName string, appGroup string) (*api.Application, error)

InitApplication will load Application from cluster

func InstallCapability 

func InstallCapability(client client.Client, mapper discoverymapper.DiscoveryMapper, centerName, capabilityName string, ioStreams cmdutil.IOStreams) error

InstallCapability will add a cap into K8s cluster and install it's controller(helm charts)

func InstallPrometheusInstance 

func InstallPrometheusInstance(kubecli client.Client) error

InstallPrometheusInstance will install prometheus instance when the Capability is 'metrics'

func ListApplicationConfigurations 

func ListApplicationConfigurations(ctx context.Context, c client.Reader, opt Option) (corev1alpha2.ApplicationConfigurationList, error)

ListApplicationConfigurations lists all OAM ApplicationConfiguration

func ListApplications 

func ListApplications(ctx context.Context, c client.Reader, opt Option) ([]apis.ApplicationMeta, error)

ListApplications lists all applications

func ListCapabilities 

func ListCapabilities(userNamespace string, c common.Args, capabilityCenterName string) ([]types.Capability, error)

ListCapabilities will list all caps from specified center

func ListCapabilityCenters 

func ListCapabilityCenters() ([]apis.CapabilityCenterMeta, error)

ListCapabilityCenters will list all capabilities from center

func ListComponents 

func ListComponents(ctx context.Context, c client.Reader, opt Option) ([]apis.ComponentMeta, error)

ListComponents will list all components for dashboard

func ListRawComponentDefinitions 

func ListRawComponentDefinitions(userNamespace string, c common.Args) ([]v1beta1.ComponentDefinition, error)

ListRawComponentDefinitions will list raw component definition

func ListRawTraitDefinitions 

func ListRawTraitDefinitions(userNamespace string, c common.Args) ([]v1beta1.TraitDefinition, error)

ListRawTraitDefinitions will list raw definition

func ListRawWorkloadDefinitions 

func ListRawWorkloadDefinitions(userNamespace string, c common.Args) ([]v1beta1.WorkloadDefinition, error)

ListRawWorkloadDefinitions will list raw definition

func ListTraitDefinitions 

func ListTraitDefinitions(userNamespace string, c common.Args, workloadName *string) ([]types.Capability, error)

ListTraitDefinitions will list all definition include traits and workloads

func Parse 

func Parse(applyTo string) string

Parse will parse applyTo(with format Group/Version.Kind) to crd name by just calculate the plural of kind word. TODO we should use discoverymapper instead of calculate plural

func RemoveCapability 

func RemoveCapability(userNamespace string, c common.Args, client client.Client, capabilityName string, ioStreams cmdutil.IOStreams) error

RemoveCapability will remove a capability from cluster. 1. remove definition 2. uninstall chart 3. remove local files

func RemoveCapabilityCenter 

func RemoveCapabilityCenter(centerName string) (string, error)

RemoveCapabilityCenter will remove a cap center from local

func RemoveCapabilityFromCluster 

func RemoveCapabilityFromCluster(userNamespace string, c common.Args, client client.Client, capabilityName string) (string, error)

RemoveCapabilityFromCluster will remove a capability from cluster. 1. remove definition 2. uninstall chart 3. remove local files

func RetrieveApplicationStatusByName 

func RetrieveApplicationStatusByName(ctx context.Context, c client.Reader, applicationName string,
	namespace string) (apis.ApplicationMeta, error)

RetrieveApplicationStatusByName will get app status

func RetrieveComponent 

func RetrieveComponent(ctx context.Context, c client.Reader, applicationName, componentName,
	namespace string) (apis.ComponentMeta, error)

RetrieveComponent will get component status

func SyncCapabilityCenter 

func SyncCapabilityCenter(capabilityCenterName string) error

SyncCapabilityCenter will sync capabilities from center to local

func SyncCapabilityFromCenter 

func SyncCapabilityFromCenter(capName, capURL, capToken string) error

SyncCapabilityFromCenter will sync all capabilities from center

Types

type AppfileOptions 

type AppfileOptions struct {
	Kubecli client.Client
	IO      cmdutil.IOStreams
	Env     *types.EnvMeta
}

AppfileOptions is some configuration that modify options for an Appfile

func (*AppfileOptions) ApplyApp 

func (o *AppfileOptions) ApplyApp(app *corev1beta1.Application, scopes []oam.Object) error

ApplyApp applys config resources for the app. It differs by create and update:

  • for create, it displays app status along with information of url, metrics, ssh, logging.
  • for update, it rolls out a canary deployment and prints its information. User can verify the canary deployment. This will wait for user approval. If approved, it continues upgrading the whole; otherwise, it would rollback.

func (*AppfileOptions) BaseAppFileRun 

func (o *AppfileOptions) BaseAppFileRun(result *BuildResult, data []byte, args common.Args) error

BaseAppFileRun starts an application according to Appfile

func (*AppfileOptions) Export 

func (o *AppfileOptions) Export(filePath, namespace string, quiet bool, c common.Args) (*BuildResult, []byte, error)

Export export Application object from the path of Appfile

func (*AppfileOptions) ExportFromAppFile 

func (o *AppfileOptions) ExportFromAppFile(app *api.AppFile, namespace string, quiet bool, c common.Args) (*BuildResult, []byte, error)

ExportFromAppFile exports Application from appfile object

func (*AppfileOptions) Info 

func (o *AppfileOptions) Info(app *corev1beta1.Application) string

Info shows the status of each service in the Appfile

func (*AppfileOptions) Run 

func (o *AppfileOptions) Run(filePath, namespace string, c common.Args) error

Run starts an application according to Appfile

type BuildResult 

type BuildResult struct {
	// contains filtered or unexported fields
}

BuildResult is the export struct from AppFile yaml or AppFile object

type DeleteOptions 

type DeleteOptions struct {
	AppName  string
	CompName string
	Client   client.Client
	Env      *types.EnvMeta
	C        common.Args
}

DeleteOptions is options for delete

func (*DeleteOptions) DeleteApp 

func (o *DeleteOptions) DeleteApp() (string, error)

DeleteApp will delete app including server side

func (*DeleteOptions) DeleteComponent 

func (o *DeleteOptions) DeleteComponent(io cmdutil.IOStreams) (string, error)

DeleteComponent will delete one component including server side.

type Option 

type Option struct {
	// Optional filter, if specified, only components in such app will be listed
	AppName string

	Namespace string
}

Option is option work with dashboard api server

type RunOptions 

type RunOptions struct {
	Env          *types.EnvMeta
	WorkloadName string
	KubeClient   client.Client
	App          *api.Application
	AppName      string
	Staging      bool
	util.IOStreams
}

RunOptions include all options for run

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.