util

Documentation

Index

• Variables
• func Contains(values []string, value string) bool
• func Convert(from, to interface{}) error
• func Copy(d interface{}) interface{}
• func Equal(l, r interface{}) interface{}
• func ExtractTar(archive string, dest string) error
• func GetFsType(device string) (string, error)
• func GetOSType() string
• func GetServices(urls []string) ([]string, error)
• func GetValue(kvPairs []string, key string) string
• func IsRunningInTty() bool
• func KVPairs2Map(kvs []string) map[string]string
• func LoadResource(location string, network bool, urls []string) ([]byte, error)
• func Map2KVPairs(m map[string]string) []string
• func MapCopy(data map[interface{}]interface{}) map[interface{}]interface{}
• func MapsIntersection(left, right map[interface{}]interface{}, ...) map[interface{}]interface{}
• func MapsUnion(left, right map[interface{}]interface{}, ...) map[interface{}]interface{}
• func MergeBytes(left, right []byte) ([]byte, error)
• func Mount(device, directory, fsType, options string) error
• func RandSeq(n int) string
• func Remount(directory, options string) error
• func Replace(l, r interface{}) interface{}
• func ResolveDevice(spec string) string
• func ShortCircuit(funcs ...ReturnsErr) error
• func TrimSplit(str, sep string) []string
• func TrimSplitN(str, sep string, count int) []string
• type Backoff
  • func (b *Backoff) Close() error
  • func (b *Backoff) Start() <-chan bool
• type ErrWriter
  • func NewErrorWriter(w io.Writer) *ErrWriter
  • func (e *ErrWriter) Write(buf []byte) *ErrWriter
• type ReturnsErr

Variables

var (
	ErrNoNetwork = errors.New("Networking not available to load resource")
	ErrNotFound  = errors.New("Failed to find resource")
)

Functions

func Contains

func Contains(values []string, value string) bool

func Convert

func Convert(from, to interface{}) error

func Copy

func Copy(d interface{}) interface{}

func Equal

func Equal(l, r interface{}) interface{}

func ExtractTar

func ExtractTar(archive string, dest string) error

func GetFsType

func GetFsType(device string) (string, error)

func GetOSType

func GetOSType() string

func GetServices

func GetServices(urls []string) ([]string, error)

func GetValue

func GetValue(kvPairs []string, key string) string

func IsRunningInTty

func IsRunningInTty() bool

func KVPairs2Map

func KVPairs2Map(kvs []string) map[string]string

func LoadResource

func LoadResource(location string, network bool, urls []string) ([]byte, error)

func Map2KVPairs

func Map2KVPairs(m map[string]string) []string

func MapCopy

func MapCopy(data map[interface{}]interface{}) map[interface{}]interface{}

func MapsIntersection

func MapsIntersection(left, right map[interface{}]interface{}, op func(interface{}, interface{}) interface{}) map[interface{}]interface{}

func MapsUnion

func MapsUnion(left, right map[interface{}]interface{}, op func(interface{}, interface{}) interface{}) map[interface{}]interface{}

func MergeBytes

func MergeBytes(left, right []byte) ([]byte, error)

func Mount

func Mount(device, directory, fsType, options string) error

func RandSeq

func RandSeq(n int) string

func Remount

func Remount(directory, options string) error

func Replace

func Replace(l, r interface{}) interface{}

func ResolveDevice

func ResolveDevice(spec string) string

func ShortCircuit

func ShortCircuit(funcs ...ReturnsErr) error

func TrimSplit

func TrimSplit(str, sep string) []string

func TrimSplitN

func TrimSplitN(str, sep string, count int) []string

Types

type Backoff

type Backoff struct {
	StartMillis, MaxIntervalMillis, MaxMillis int
	// contains filtered or unexported fields
}

func (*Backoff) Close

func (b *Backoff) Close() error

func (*Backoff) Start

func (b *Backoff) Start() <-chan bool

type ErrWriter

type ErrWriter struct {
	Err error
	// contains filtered or unexported fields
}

func NewErrorWriter

func NewErrorWriter(w io.Writer) *ErrWriter

func (*ErrWriter) Write

func (e *ErrWriter) Write(buf []byte) *ErrWriter

type ReturnsErr

type ReturnsErr func() error