util

Documentation

Index

• Constants
• Variables
• func AppNamespace() string
• func Base64DecodeInterface(d interface{}) ([]byte, error)
• func CommonSlicePrefix(first []string, second []string) []string
• func CompareStringArrays(arr1, arr2 []string) bool
• func ConvertToSingleDocs(doc []byte) [][]byte
• func DecryptConfigValue(input string) (string, error)
• func ExtractTGZArchive(tgzFile string, destDir string) error
• func FilesToTGZ(files map[string]string) ([]byte, error)
• func GenPassword(length int) string
• func GetFileFromTGZArchive(archive *bytes.Buffer, fileName string) (*bytes.Buffer, error)
• func GetFilesMap(dir string) (map[string][]byte, error)
• func GetReplicatedAPIEndpoint() string
• func GetValueFromMapPath(m interface{}, path []string) interface{}
• func HomeDir() string
• func IntPointer(x int) *int64
• func IsHelmManaged() bool
• func IsURL(str string) bool
• func MarshalIndent(indent int, in interface{}) ([]byte, error)
• func NewRequest(method string, url string, body io.Reader) (*http.Request, error)
• func NewThrottle(after time.Duration) func(f func())
• func PromptForNewPassword() (string, error)
• func SplitStringOnLen(str string, maxLength int) ([]string, error)
• func SplitYAML(input []byte) (map[string][]byte, error)
• func StrPointer(s string) *string
• func TGZArchive(dir string) ([]byte, error)
• func TGZToFiles(tgzBytes []byte) (map[string]string, error)
• func TestGetenv(key string) string
• func ThisImage(ctx context.Context, client kubernetes.Interface) (string, error)
• type ActionableError
  • func (e ActionableError) Error() string
• type OverlySimpleGVK
• type OverlySimpleMetadata

Constants

const (
	PasswordSecretName = "kotsadm-password"
	SessionsSecretName = "kotsadm-sessions"
)

Variables

var (
	PodNamespace           string = os.Getenv("POD_NAMESPACE")
	KotsadmTargetNamespace string = os.Getenv("KOTSADM_TARGET_NAMESPACE")
)

Functions

func AppNamespace

func AppNamespace() string

func Base64DecodeInterface

func Base64DecodeInterface(d interface{}) ([]byte, error)

func CommonSlicePrefix

func CommonSlicePrefix(first []string, second []string) []string

func CompareStringArrays

func CompareStringArrays(arr1, arr2 []string) bool

CompareStringArrays returns true if all elements in arr1 are present in arr2 and the other way around. it does not check for equal counts of duplicates, or for ordering.

func ConvertToSingleDocs

func ConvertToSingleDocs(doc []byte) [][]byte

func DecryptConfigValue

func DecryptConfigValue(input string) (string, error)

func ExtractTGZArchive

func ExtractTGZArchive(tgzFile string, destDir string) error

func FilesToTGZ

func FilesToTGZ(files map[string]string) ([]byte, error)

func GenPassword

func GenPassword(length int) string

generates a [0-9a-zA-Z] password of the specified length

func GetFileFromTGZArchive

func GetFileFromTGZArchive(archive *bytes.Buffer, fileName string) (*bytes.Buffer, error)

func GetFilesMap

func GetFilesMap(dir string) (map[string][]byte, error)

func GetReplicatedAPIEndpoint

func GetReplicatedAPIEndpoint() string

func GetValueFromMapPath

func GetValueFromMapPath(m interface{}, path []string) interface{}

func HomeDir

func HomeDir() string

func IntPointer

func IntPointer(x int) *int64

func IsHelmManaged

func IsHelmManaged() bool

func IsURL

func IsURL(str string) bool

func MarshalIndent

func MarshalIndent(indent int, in interface{}) ([]byte, error)

func NewRequest

func NewRequest(method string, url string, body io.Reader) (*http.Request, error)

NewRequest returns a http.Request object with kots defaults set, including a User-Agent header.

func NewThrottle

func NewThrottle(after time.Duration) func(f func())

func PromptForNewPassword

func PromptForNewPassword() (string, error)

func SplitStringOnLen

func SplitStringOnLen(str string, maxLength int) ([]string, error)

func SplitYAML

func SplitYAML(input []byte) (map[string][]byte, error)

func StrPointer

func StrPointer(s string) *string

func TGZArchive

func TGZArchive(dir string) ([]byte, error)

func TGZToFiles

func TGZToFiles(tgzBytes []byte) (map[string]string, error)

func TestGetenv

func TestGetenv(key string) string

func ThisImage

func ThisImage(ctx context.Context, client kubernetes.Interface) (string, error)

ThisImage looks for either a deployment 'kotsadm' or a statefulset 'kotsadm' in the current namespace it returns the image of the first container in the pod template

Types

type ActionableError

type ActionableError struct {
	NoRetry bool
	Message string
}

func (ActionableError) Error

func (e ActionableError) Error() string

type OverlySimpleGVK

type OverlySimpleGVK struct {
	APIVersion string               `yaml:"apiVersion"`
	Kind       string               `yaml:"kind"`
	Metadata   OverlySimpleMetadata `yaml:"metadata"`
}

type OverlySimpleMetadata

type OverlySimpleMetadata struct {
	Name      string `yaml:"name"`
	Namespace string `yaml:"namespace"`
}