utils

Documentation

Index

• Constants
• func CreateNamespace(ctx context.Context, kubeClient client.Client, name string, ...) error
• func CreateOrUpdateNamespace(ctx context.Context, kubeClient client.Client, name string, ...) error
• func DumpJSON(o interface{}) string
• func ParseAPIServerEndpoint(server string) (string, error)
• func RandomString(n int) string
• func Sanitize(s string) string
• func StringsContain(items []string, source string) bool
• func UpdateNamespace(ctx context.Context, kubeClient client.Client, name string, ...) error
• type Content
  • func Parse(addr string) (string, *Content, error)
• type GithubContent
• type LocalContent
• type MutateOption
  • func MergeNoConflictLabels(labels map[string]string) MutateOption
  • func MergeOverrideAnnotations(annotations map[string]string) MutateOption
  • func MergeOverrideLabels(labels map[string]string) MutateOption
• type OssContent

Constants

const TypeGithub = "github"

TypeGithub represents github

const TypeLocal = "local"

TypeLocal represents github

const TypeOss = "oss"

TypeOss represent oss

const TypeUnknown = "unknown"

TypeUnknown represents parse failed

Functions

func CreateNamespace

func CreateNamespace(ctx context.Context, kubeClient client.Client, name string, options ...MutateOption) error

CreateNamespace will create a namespace with mutate option

func CreateOrUpdateNamespace

func CreateOrUpdateNamespace(ctx context.Context, kubeClient client.Client, name string, options ...MutateOption) error

CreateOrUpdateNamespace will create a namespace if not exist, it will also update a namespace if exists It will report an error if the labels conflict while it will override the annotations

func DumpJSON

func DumpJSON(o interface{}) string

DumpJSON returns the JSON encoding

func ParseAPIServerEndpoint

func ParseAPIServerEndpoint(server string) (string, error)

ParseAPIServerEndpoint automatically construct the full url of APIServer It will patch port and scheme if not exists

func RandomString

func RandomString(n int) string

RandomString generate random string.

func Sanitize

func Sanitize(s string) string

Sanitize the inputs by removing line endings

func StringsContain

func StringsContain(items []string, source string) bool

StringsContain strings contain

func UpdateNamespace

func UpdateNamespace(ctx context.Context, kubeClient client.Client, name string, options ...MutateOption) error

UpdateNamespace will update a namespace with mutate option

Types

type Content

type Content struct {
	OssContent
	GithubContent
	LocalContent
}

Content contains different type of content needed when building Registry

func Parse

func Parse(addr string) (string, *Content, error)

Parse will parse config from address

type GithubContent

type GithubContent struct {
	Owner string `json:"owner"`
	Repo  string `json:"repo"`
	Path  string `json:"path"`
	Ref   string `json:"ref"`
}

GithubContent for cap center

type LocalContent

type LocalContent struct {
	AbsDir string `json:"abs_dir"`
}

LocalContent for local registry

type MutateOption

type MutateOption func(object metav1.Object) error

MutateOption defines the function pattern for mutate

func MergeNoConflictLabels

func MergeNoConflictLabels(labels map[string]string) MutateOption

MergeNoConflictLabels will merge the existing labels with the labels passed in, it will report conflicts if exists

func MergeOverrideAnnotations

func MergeOverrideAnnotations(annotations map[string]string) MutateOption

MergeOverrideAnnotations will merge the existing annotations and override by the annotations passed in

func MergeOverrideLabels

func MergeOverrideLabels(labels map[string]string) MutateOption

MergeOverrideLabels will merge the existing labels and override by the labels passed in

type OssContent

type OssContent struct {
	EndPoint string `json:"bucket_url"`
	Bucket   string `json:"bucket"`
}

OssContent for oss registry