util

Documentation

Index

• Constants
• func CanReadFile(path string) bool
• func FormatError(err error) (string, error)
• func GenerateCACert(certPath, keyPath string) error
• func GenerateSignedCert(certPath, keyPath string, ips []net.IP, alternateDNS []string, ...) error
• func GetAlternateDNS(domain string) []string
• func GetLocalkubeDownloadURL(versionOrURL string, filename string) (string, error)
• func IsDirectory(path string) (bool, error)
• func MarshallError(errMsg, service, version string) ([]byte, error)
• func MaybeReportErrorAndExit(err error)
• func Pad(str string) string
• func ReportError(err error, url string) error
• func Retry(attempts int, callback func() error) (err error)
• func RetryAfter(attempts int, callback func() error, d time.Duration) (err error)
• func Until(fn func() error, w io.Writer, name string, sleep time.Duration, ...)
• func UploadError(b []byte, url string) error
• type Message
• type MultiError
  • func (m *MultiError) Collect(err error)
  • func (m MultiError) ToError() error
• type ServiceContext

Constants

const (
	DefaultLocalkubeDirectory = "/var/lib/localkube"
	DefaultCertPath           = DefaultLocalkubeDirectory + "/certs/"
	DefaultServiceClusterIP   = "10.0.0.1"
	DefaultDNSDomain          = "cluster.local"
	DefaultDNSIP              = "10.0.0.10"
)

These constants are used by both minikube and localkube

Functions

func CanReadFile

func CanReadFile(path string) bool

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

func FormatError

func FormatError(err error) (string, error)

func GenerateCACert

func GenerateCACert(certPath, keyPath string) error

func GenerateSignedCert

func GenerateSignedCert(certPath, keyPath 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 GetLocalkubeDownloadURL

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

func IsDirectory

func IsDirectory(path string) (bool, error)

func MarshallError

func MarshallError(errMsg, service, version string) ([]byte, error)

func MaybeReportErrorAndExit

func MaybeReportErrorAndExit(err error)

func Pad

func Pad(str string) string

func ReportError

func ReportError(err error, url string) error

func Retry

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

func RetryAfter

func RetryAfter(attempts int, callback func() error, d time.Duration) (err 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 UploadError

func UploadError(b []byte, url string) error

Types

type Message

type Message struct {
	Message        string `json:"message"`
	ServiceContext `json:"serviceContext"`
}

type MultiError

type MultiError struct {
	Errors []error
}

func (*MultiError) Collect

func (m *MultiError) Collect(err error)

func (MultiError) ToError

func (m MultiError) ToError() error

type ServiceContext

type ServiceContext struct {
	Service string `json:"service"`
	Version string `json:"version"`
}