common

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: May 27, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DaprNamespace           = "dapr-system"
	KedaNamespace           = "keda"
	KnativeServingNamespace = "knative-serving"
	KourierNamespace        = "kourier-system"
	TektonPipelineNamespace = "tekton-pipelines"
	ShipwrightNamespace     = "shipwright-build"
	CertManagerNamespace    = "cert-manager"
	IngressNginxNamespace   = "ingress-nginx"
	OpenFunctionNamespace   = "openfunction"

	BaseVersion   = "v0.3.1"
	LatestVersion = "latest"
)

Variables

This section is empty.

Functions

func IsComponentExist 

func IsComponentExist(ctx context.Context, cl *k8s.Clientset, ns string, resourceName string) bool

func IsVersionValid 

func IsVersionValid(ofVersion *version.Version) (bool, error)

Types

type Operator 

type Operator struct {
	Inventory map[string]inventory.Interface
	Records   *inventory.Record
	// contains filtered or unexported fields
}

func NewOperator 

func NewOperator(os, arch, version string, timeout time.Duration, inRegionCN bool, verbose bool) *Operator

func (*Operator) CheckCertManagerIsReady 

func (o *Operator) CheckCertManagerIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckIngressNginxIsReady 

func (o *Operator) CheckIngressNginxIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckKedaIsReady 

func (o *Operator) CheckKedaIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckKnativeServingIsReady 

func (o *Operator) CheckKnativeServingIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckKourierIsReady 

func (o *Operator) CheckKourierIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckOpenFunctionIsReady 

func (o *Operator) CheckOpenFunctionIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckShipwrightIsReady 

func (o *Operator) CheckShipwrightIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) CheckTektonPipelinesIsReady 

func (o *Operator) CheckTektonPipelinesIsReady(ctx context.Context, cl *k8s.Clientset) error

func (*Operator) ConfigKnativeServingDefaultDomain 

func (o *Operator) ConfigKnativeServingDefaultDomain(ctx context.Context, yamlFile string) error

func (*Operator) CreateKindCluster 

func (o *Operator) CreateKindCluster(ctx context.Context) error

func (*Operator) CurlOpenFunction 

func (o *Operator) CurlOpenFunction(ctx context.Context, endPoint string) (string, error)

func (*Operator) DeleteKind 

func (o *Operator) DeleteKind(ctx context.Context) error

func (*Operator) DownloadDaprClient 

func (o *Operator) DownloadDaprClient(ctx context.Context, daprVersion string) error

func (*Operator) DownloadKind 

func (o *Operator) DownloadKind(ctx context.Context) error

func (*Operator) GetInventoryRecord 

func (o *Operator) GetInventoryRecord(ctx context.Context, humanize bool) (map[string]string, error)

func (*Operator) GetNodeIP 

func (o *Operator) GetNodeIP(ctx context.Context) (string, error)

func (*Operator) InitDapr 

func (o *Operator) InitDapr(ctx context.Context, daprVersion string) error

func (*Operator) InstallCertManager 

func (o *Operator) InstallCertManager(ctx context.Context, yamlFile string) error

func (*Operator) InstallIngressNginx 

func (o *Operator) InstallIngressNginx(ctx context.Context, yamlFile string) error

func (*Operator) InstallKeda 

func (o *Operator) InstallKeda(ctx context.Context, yamlFile string) error

func (*Operator) InstallKnativeServing 

func (o *Operator) InstallKnativeServing(ctx context.Context, crdYamlFile string, coreYamlFile string) error

func (*Operator) InstallKourier 

func (o *Operator) InstallKourier(ctx context.Context, cl *k8s.Clientset, yamlFile string) error

func (*Operator) InstallOpenFunction 

func (o *Operator) InstallOpenFunction(ctx context.Context, yamlFile string) error

func (*Operator) InstallShipwright 

func (o *Operator) InstallShipwright(ctx context.Context, yamlFile string) error

func (*Operator) InstallTektonPipelines 

func (o *Operator) InstallTektonPipelines(ctx context.Context, yamlFile string) error

func (*Operator) PatchExternalIP 

func (o *Operator) PatchExternalIP(ctx context.Context, cl *k8s.Clientset, ip string) error

func (*Operator) PatchMagicDNS 

func (o *Operator) PatchMagicDNS(ctx context.Context, cl *k8s.Clientset, ip string) error

func (*Operator) PrintEndpoint 

func (o *Operator) PrintEndpoint(ctx context.Context) (string, error)

func (*Operator) RecordInventory 

func (o *Operator) RecordInventory(ctx context.Context) error

func (*Operator) RunOpenFunction 

func (o *Operator) RunOpenFunction(ctx context.Context, demoYamlFile string) error

func (*Operator) Uninstall 

func (o *Operator) Uninstall(
	ctx context.Context,
	cl *k8s.Clientset,
	yamlFile string,
	namespace string,
	waitForDelete bool,
	waitForCleared bool,
) error

func (*Operator) UninstallDapr 

func (o *Operator) UninstallDapr(ctx context.Context, cl *k8s.Clientset, waitForCleared bool) error

func (*Operator) UninstallKnativeServing 

func (o *Operator) UninstallKnativeServing(
	ctx context.Context,
	cl *k8s.Clientset,
	crdYamlFile string,
	coreYamlFile string,
	waitForCleared bool,
) error

type PatchExternalIP 

type PatchExternalIP struct {
	Spec Spec `json:"spec"`
}

type Spec 

type Spec struct {
	MyType      string   `json:"type"`
	ExternalIPs []string `json:"externalIPs"`
}

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.