util

Documentation

Index

• Constants
• Variables
• func AskToChooseOneService(svcNames []string) (string, error)
• func CheckErr(err error)
• func DoesCRDExist(cxt context.Context, c client.Client, crdName string) (bool, error)
• func DoesNamespaceExist(c client.Client, namespace string) (bool, error)
• func GetAPIVersionKindFromTrait(td corev1alpha2.TraitDefinition) (string, string)
• func GetAPIVersionKindFromWorkload(td corev1alpha2.WorkloadDefinition) (string, string)
• func GetComponent(ctx context.Context, c client.Client, componentName string, namespace string) (corev1alpha2.Component, error)
• func GetTraitAPIVersionKind(ctx context.Context, c client.Client, namespace string, name string) (string, string, error)
• func GetTraitDefinitionByAlias(ctx context.Context, c client.Client, traitAlias string) (corev1alpha2.TraitDefinition, error)
• func GetTraitDefinitionByName(ctx context.Context, c client.Client, namespace string, traitName string) (corev1alpha2.TraitDefinition, error)
• func GetWorkloadDefinitionByAlias(ctx context.Context, c client.Client, traitAlias string) (corev1alpha2.WorkloadDefinition, error)
• func GetWorkloadDefinitionByName(ctx context.Context, c client.Client, namespace string, name string) (corev1alpha2.WorkloadDefinition, error)
• func GetWorkloadNameAliasKind(ctx context.Context, c client.Client, namespace string, workloadName string) (string, string, string)
• func ListTraitDefinitionsByApplicationConfiguration(app corev1alpha2.ApplicationConfiguration) []corev1alpha2.TraitDefinition
• func NewNamespace(c client.Client, namespace string) error
• func NewRestConfigGetter(namespace string) genericclioptions.RESTClientGetter
• func Print(msg string)
• func PrintErrorMessage(errorMessage string, exitCode int)
• func PrintFlags(cmd *cobra.Command, subcmds []*cobra.Command)
• type IOStreams
  • func NewTestIOStreams() (IOStreams, *bytes.Buffer, *bytes.Buffer, *bytes.Buffer)
  • func (i *IOStreams) Error(a ...interface{})
  • func (i *IOStreams) Errorf(format string, a ...interface{})
  • func (i *IOStreams) Info(a ...interface{})
  • func (i *IOStreams) Infof(format string, a ...interface{})
  • func (i *IOStreams) Infonln(a ...interface{})

Constants

const (
	DefaultErrorExitCode = 1
)

Variables

var OAMLabel = map[string]string{"app.kubernetes.io/part-of": "kubevela"}

Functions

func AskToChooseOneService

func AskToChooseOneService(svcNames []string) (string, error)

AskToChooseOneService will ask users to select one service of the application if more than one exidi

func CheckErr

func CheckErr(err error)

func DoesCRDExist

func DoesCRDExist(cxt context.Context, c client.Client, crdName string) (bool, error)

DoesCoreCRDExist check CRD exist

func DoesNamespaceExist

func DoesNamespaceExist(c client.Client, namespace string) (bool, error)

DoesNamespaceExist check namespace exist

func GetAPIVersionKindFromTrait

func GetAPIVersionKindFromTrait(td corev1alpha2.TraitDefinition) (string, string)

func GetAPIVersionKindFromWorkload

func GetAPIVersionKindFromWorkload(td corev1alpha2.WorkloadDefinition) (string, string)

func GetComponent

func GetComponent(ctx context.Context, c client.Client, componentName string, namespace string) (corev1alpha2.Component, error)

func GetTraitAPIVersionKind

func GetTraitAPIVersionKind(ctx context.Context, c client.Client, namespace string, name string) (string, string, error)

GetTraitNameAndAlias return the name and alias of a TraitDefinition by a string which might be the trait name, the trait alias, or invalid name

func GetTraitDefinitionByAlias

func GetTraitDefinitionByAlias(ctx context.Context, c client.Client, traitAlias string) (corev1alpha2.TraitDefinition, error)

func GetTraitDefinitionByName

func GetTraitDefinitionByName(ctx context.Context, c client.Client, namespace string, traitName string) (corev1alpha2.TraitDefinition, error)

func GetWorkloadDefinitionByAlias

func GetWorkloadDefinitionByAlias(ctx context.Context, c client.Client, traitAlias string) (corev1alpha2.WorkloadDefinition, error)

func GetWorkloadDefinitionByName

func GetWorkloadDefinitionByName(ctx context.Context, c client.Client, namespace string, name string) (corev1alpha2.WorkloadDefinition, error)

func GetWorkloadNameAliasKind

func GetWorkloadNameAliasKind(ctx context.Context, c client.Client, namespace string, workloadName string) (string, string, string)

func ListTraitDefinitionsByApplicationConfiguration

func ListTraitDefinitionsByApplicationConfiguration(app corev1alpha2.ApplicationConfiguration) []corev1alpha2.TraitDefinition

func NewNamespace

func NewNamespace(c client.Client, namespace string) error

func NewRestConfigGetter

func NewRestConfigGetter(namespace string) genericclioptions.RESTClientGetter

The helm client never thought it could be used inside a cluster so it took a dependency on the kube cli, we have to create a cli client getter from the rest.Config

func Print

func Print(msg string)

func PrintErrorMessage

func PrintErrorMessage(errorMessage string, exitCode int)

func PrintFlags

func PrintFlags(cmd *cobra.Command, subcmds []*cobra.Command)

Types

type IOStreams

type IOStreams struct {
	// In think, os.Stdin
	In io.Reader
	// Out think, os.Stdout
	Out io.Writer
	// ErrOut think, os.Stderr
	ErrOut io.Writer
}

IOStreams provides the standard names for iostreams. This is useful for embedding and for unit testing. Inconsistent and different names make it hard to read and review code

func NewTestIOStreams

func NewTestIOStreams() (IOStreams, *bytes.Buffer, *bytes.Buffer, *bytes.Buffer)

NewTestIOStreams returns a valid IOStreams and in, out, errout buffers for unit tests

func (*IOStreams) Error

func (i *IOStreams) Error(a ...interface{})

func (*IOStreams) Errorf

func (i *IOStreams) Errorf(format string, a ...interface{})

func (*IOStreams) Info

func (i *IOStreams) Info(a ...interface{})

func (*IOStreams) Infof

func (i *IOStreams) Infof(format string, a ...interface{})

func (*IOStreams) Infonln

func (i *IOStreams) Infonln(a ...interface{})

Infonln compared to Info(), won't print new line