common

Documentation

Index

• Constants
• Variables
• func AskToChooseOneNamespace(c client.Client, envMeta *types.EnvMeta) error
• func FillParameterDefinitionFieldIfNotExist(val cue.Value) cue.Value
• func GenOpenAPI(val cue.Value) (b []byte, err error)
• func GenOpenAPIWithCueX(val cue.Value) (b []byte, err error)
• func GenerateUnstructuredObj(name, ns string, gvk schema.GroupVersionKind) *unstructured.Unstructured
• func GetCUEParameterValue(cueStr string) (cue.Value, error)
• func HTTPGetKubernetesObjects(ctx context.Context, url string) ([]*unstructured.Unstructured, error)
• func HTTPGetResponse(ctx context.Context, url string, opts *HTTPOption) (*http.Response, error)
• func HTTPGetWithOption(ctx context.Context, url string, opts *HTTPOption) ([]byte, error)
• func NewK8sClient() (client.Client, error)
• func ParseTerraformVariables(configuration string) (map[string]*tfconfig.Variable, map[string]*tfconfig.Output, error)
• func ReadYamlToObject(path string, object k8sruntime.Object) error
• func RealtimePrintCommandOutput(cmd *exec.Cmd, logFile string) error
• func RefineParameterValue(val cue.Value) (cue.Value, error)
• func SetSpecObjIntoUnstructuredObj(spec interface{}, u *unstructured.Unstructured) error
• type Args
  • func InitBaseRestConfig() (Args, error)
  • func (a *Args) GetClient() (client.Client, error)
  • func (a *Args) GetConfig() (*rest.Config, error)
  • func (a *Args) GetDiscoveryClient() (*discovery.DiscoveryClient, error)
  • func (a *Args) GetDynamicClient() (dynamic.Interface, error)
  • func (a *Args) GetFakeClient(defs []*unstructured.Unstructured) (client.Client, error)
  • func (a *Args) GetNamespaceFromConfig() string
  • func (a *Args) GetRawConfig() (*api.Config, error)
  • func (a *Args) SetClient(c client.Client)
  • func (a *Args) SetConfig(c *rest.Config) error
• type HTTPOption

Constants

const CreateCustomNamespace = "create new namespace"

CreateCustomNamespace display the create namespace message

Variables

var (
	// Scheme defines the default KubeVela schema
	Scheme = k8sruntime.NewScheme()
)

Functions

func AskToChooseOneNamespace

func AskToChooseOneNamespace(c client.Client, envMeta *types.EnvMeta) error

AskToChooseOneNamespace ask for choose one namespace as env

func FillParameterDefinitionFieldIfNotExist

func FillParameterDefinitionFieldIfNotExist(val cue.Value) cue.Value

FillParameterDefinitionFieldIfNotExist refines cue value to merely include `parameter` identifier

func GenOpenAPI

func GenOpenAPI(val cue.Value) (b []byte, err error)

GenOpenAPI generates OpenAPI json schema from cue.Instance

func GenOpenAPIWithCueX

func GenOpenAPIWithCueX(val cue.Value) (b []byte, err error)

GenOpenAPIWithCueX generates OpenAPI json schema from cue.Instance

func GenerateUnstructuredObj

func GenerateUnstructuredObj(name, ns string, gvk schema.GroupVersionKind) *unstructured.Unstructured

GenerateUnstructuredObj generate UnstructuredObj

func GetCUEParameterValue

func GetCUEParameterValue(cueStr string) (cue.Value, error)

GetCUEParameterValue converts definitions to cue format

func HTTPGetKubernetesObjects

func HTTPGetKubernetesObjects(ctx context.Context, url string) ([]*unstructured.Unstructured, error)

HTTPGetKubernetesObjects use HTTP requests to load resources from remote url

func HTTPGetResponse

func HTTPGetResponse(ctx context.Context, url string, opts *HTTPOption) (*http.Response, error)

HTTPGetResponse use HTTP option and default client to send request and get raw response

func HTTPGetWithOption

func HTTPGetWithOption(ctx context.Context, url string, opts *HTTPOption) ([]byte, error)

HTTPGetWithOption use HTTP option and default client to send get request

func NewK8sClient

func NewK8sClient() (client.Client, error)

NewK8sClient init a local k8s client which add oamcore scheme

func ParseTerraformVariables

func ParseTerraformVariables(configuration string) (map[string]*tfconfig.Variable, map[string]*tfconfig.Output, error)

ParseTerraformVariables get variables from Terraform Configuration

func ReadYamlToObject

func ReadYamlToObject(path string, object k8sruntime.Object) error

ReadYamlToObject will read a yaml K8s object to runtime.Object

func RealtimePrintCommandOutput

func RealtimePrintCommandOutput(cmd *exec.Cmd, logFile string) error

RealtimePrintCommandOutput prints command output in real time If logFile is "", it will prints the stdout, or it will write to local file

func RefineParameterValue

func RefineParameterValue(val cue.Value) (cue.Value, error)

RefineParameterValue refines cue value to merely include `parameter` identifier

func SetSpecObjIntoUnstructuredObj

func SetSpecObjIntoUnstructuredObj(spec interface{}, u *unstructured.Unstructured) error

SetSpecObjIntoUnstructuredObj set UnstructuredObj spec field

Types

type Args

type Args struct {
	Schema *runtime.Scheme
	// contains filtered or unexported fields
}

Args is args for controller-runtime client

func InitBaseRestConfig

func InitBaseRestConfig() (Args, error)

InitBaseRestConfig will return reset config for create controller runtime client

func (*Args) GetClient

func (a *Args) GetClient() (client.Client, error)

GetClient get client if exist

func (*Args) GetConfig

func (a *Args) GetConfig() (*rest.Config, error)

GetConfig get config, if not exist, will create

func (*Args) GetDiscoveryClient

func (a *Args) GetDiscoveryClient() (*discovery.DiscoveryClient, error)

GetDiscoveryClient return a discovery client from cli args

func (*Args) GetDynamicClient

func (a *Args) GetDynamicClient() (dynamic.Interface, error)

GetDynamicClient return a dynamic client from cli args

func (*Args) GetFakeClient

func (a *Args) GetFakeClient(defs []*unstructured.Unstructured) (client.Client, error)

GetFakeClient returns a fake client with the definition objects preloaded

func (*Args) GetNamespaceFromConfig

func (a *Args) GetNamespaceFromConfig() string

GetNamespaceFromConfig will get namespace from kube config

func (*Args) GetRawConfig

func (a *Args) GetRawConfig() (*api.Config, error)

GetRawConfig get raw kubeconfig, if not exist, will create

func (*Args) SetClient

func (a *Args) SetClient(c client.Client)

SetClient set custom client

func (*Args) SetConfig

func (a *Args) SetConfig(c *rest.Config) error

SetConfig insert kubeconfig into Args

type HTTPOption

type HTTPOption struct {
	Username        string `json:"username,omitempty"`
	Password        string `json:"password,omitempty"`
	CaFile          string `json:"caFile,omitempty"`
	CertFile        string `json:"certFile,omitempty"`
	KeyFile         string `json:"keyFile,omitempty"`
	InsecureSkipTLS bool   `json:"insecureSkipTLS,omitempty"`
}

HTTPOption define the https options