util

package
v0.26.1 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2018 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	APIServerPort             = 8443
	DefaultLocalkubeDirectory = "/var/lib/localkube"
	DefaultCertPath           = DefaultLocalkubeDirectory + "/certs/"
	DefaultKubeConfigPath     = DefaultLocalkubeDirectory + "/kubeconfig"
	DefaultDNSDomain          = "cluster.local"
	DefaultServiceCIDR        = "10.96.0.0/12"
)

These constants are used by both minikube and localkube

Variables

View Source 
var DefaultAdmissionControllers = []string{
	"Initializers",
	"NamespaceLifecycle",
	"LimitRanger",
	"ServiceAccount",
	"DefaultStorageClass",
	"DefaultTolerationSeconds",
	"NodeRestriction",
	"MutatingAdmissionWebhook",
	"ValidatingAdmissionWebhook",
	"ResourceQuota",
}

Functions

func CalculateDiskSizeInMB added in v0.22.0 

func CalculateDiskSizeInMB(humanReadableDiskSize string) int

func CanReadFile 

func CanReadFile(path string) bool

If the file represented by path exists and readable, return true otherwise return false.

func ChownR added in v0.21.0 

func ChownR(path string, uid, gid int) error

func FindAndSet added in v0.11.0 

func FindAndSet(path string, c interface{}, value string) error

FindAndSet sets the nested value.

func GenerateCACert added in v0.6.0 

func GenerateCACert(certPath, keyPath string, name string) error

func GenerateSignedCert added in v0.6.0 

func GenerateSignedCert(certPath, keyPath, cn string, ips []net.IP, alternateDNS []string, signerCertPath, signerKeyPath string) error

You may also specify additional subject alt names (either ip or dns names) for the certificate The certificate will be created with file mode 0644. The key will be created with file mode 0600. If the certificate or key files already exist, they will be overwritten. Any parent directories of the certPath or keyPath will be created as needed with file mode 0755.

func GetAlternateDNS 

func GetAlternateDNS(domain string) []string

func GetBinaryDownloadURL added in v0.26.0 

func GetBinaryDownloadURL(version, platform string) string

func GetClient added in v0.22.2 

func GetClient() (kubernetes.Interface, error)

func GetDNSIP added in v0.24.0 

func GetDNSIP(serviceCIDR string) (net.IP, error)

GetDNSIP returns x.x.x.10 of the service CIDR

func GetLocalkubeDownloadURL added in v0.8.0 

func GetLocalkubeDownloadURL(versionOrURL string, filename string) (string, error)

func GetServiceClusterIP added in v0.24.0 

func GetServiceClusterIP(serviceCIDR string) (net.IP, error)

GetServiceClusterIP returns the first IP of the ServiceCIDR

func IsDirectory added in v0.9.0 

func IsDirectory(path string) (bool, error)

func IsRetryableAPIError added in v0.22.2 

func IsRetryableAPIError(err error) bool

func MaybeChownDirRecursiveToMinikubeUser added in v0.21.0 

func MaybeChownDirRecursiveToMinikubeUser(dir string) error

func Pad 

func Pad(str string) string

func ParseSHAFromURL added in v0.11.0 

func ParseSHAFromURL(url string) (string, error)

func Retry added in v0.2.0 

func Retry(attempts int, callback func() error) (err error)

func RetryAfter added in v0.2.0 

func RetryAfter(attempts int, callback func() error, d time.Duration) (err error)

func StartPods added in v0.22.2 

func StartPods(c kubernetes.Interface, namespace string, pod v1.Pod, waitForRunning bool) error

func Until 

func Until(fn func() error, w io.Writer, name string, sleep time.Duration, done <-chan struct{})

Until endlessly loops the provided function until a message is received on the done channel. The function will wait the duration provided in sleep between function calls. Errors will be sent on provider Writer.

func WaitForDeploymentToStabilize added in v0.25.0 

func WaitForDeploymentToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForDeploymentToStabilize waits till the Deployment has a matching generation/replica count between spec and status.

func WaitForPodsWithLabelRunning added in v0.22.2 

func WaitForPodsWithLabelRunning(c kubernetes.Interface, ns string, label labels.Selector) error

Wait up to 10 minutes for all matching pods to become Running and at least one matching pod exists.

func WaitForRCToStabilize added in v0.22.2 

func WaitForRCToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForRCToStabilize waits till the RC has a matching generation/replica count between spec and status.

func WaitForService added in v0.22.2 

func WaitForService(c kubernetes.Interface, namespace, name string, exist bool, interval, timeout time.Duration) error

WaitForService waits until the service appears (exist == true), or disappears (exist == false)

func WaitForServiceEndpointsNum added in v0.22.2 

func WaitForServiceEndpointsNum(c kubernetes.Interface, namespace, serviceName string, expectNum int, interval, timeout time.Duration) error

WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.

Types

type DefaultDownloader added in v0.16.0 

type DefaultDownloader struct{}

func (DefaultDownloader) CacheMinikubeISOFromURL added in v0.16.0 

func (f DefaultDownloader) CacheMinikubeISOFromURL(isoURL string) error

func (DefaultDownloader) GetISOCacheFilepath added in v0.17.0 

func (f DefaultDownloader) GetISOCacheFilepath(isoURL string) string

func (DefaultDownloader) GetISOFileURI added in v0.16.0 

func (f DefaultDownloader) GetISOFileURI(isoURL string) string

func (DefaultDownloader) IsMinikubeISOCached added in v0.17.0 

func (f DefaultDownloader) IsMinikubeISOCached(isoURL string) bool

func (DefaultDownloader) ShouldCacheMinikubeISO added in v0.17.0 

func (f DefaultDownloader) ShouldCacheMinikubeISO(isoURL string) bool

type ExtraOption added in v0.11.0 

type ExtraOption struct {
	Component string
	Key       string
	Value     string
}

func (*ExtraOption) String added in v0.11.0 

func (e *ExtraOption) String() string

type ExtraOptionSlice added in v0.11.0 

type ExtraOptionSlice []ExtraOption

func (*ExtraOptionSlice) Set added in v0.11.0 

func (es *ExtraOptionSlice) Set(value string) error

func (*ExtraOptionSlice) String added in v0.11.0 

func (es *ExtraOptionSlice) String() string

func (*ExtraOptionSlice) Type added in v0.11.0 

func (es *ExtraOptionSlice) Type() string

type ISODownloader added in v0.16.0 

type ISODownloader interface {
	GetISOFileURI(isoURL string) string
	CacheMinikubeISOFromURL(isoURL string) error
}

type MultiError added in v0.8.0 

type MultiError struct {
	Errors []error
}

func (*MultiError) Collect added in v0.8.0 

func (m *MultiError) Collect(err error)

func (MultiError) ToError added in v0.8.0 

func (m MultiError) ToError() error

type PodStore added in v0.22.2 

type PodStore struct {
	cache.Store

	Reflector *cache.Reflector
	// contains filtered or unexported fields
}

func NewPodStore added in v0.22.2 

func NewPodStore(c kubernetes.Interface, namespace string, label labels.Selector, field fields.Selector) *PodStore

func (*PodStore) List added in v0.22.2 

func (s *PodStore) List() []*v1.Pod

func (*PodStore) Stop added in v0.22.2 

func (s *PodStore) Stop()

type RetriableError added in v0.12.0 

type RetriableError struct {
	Err error
}

func (RetriableError) Error added in v0.12.0 

func (r RetriableError) Error() string

Source Files

View all Source files

Directories

Path Synopsis

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.