util

Jul 1, 2016

Changes in this version

+ func Int32Ptr(i int32) *int32

+ func Int32PtrDerefOr(ptr *int32, def int32) int32

type Clock

+ Tick func(d time.Duration) <-chan time.Time

type FakeClock

+ func (f *FakeClock) Tick(d time.Duration) <-chan time.Time

type IntervalClock

+ func (*IntervalClock) Tick(d time.Duration) <-chan time.Time

type RealClock

+ func (RealClock) Tick(d time.Duration) <-chan time.Time

Apr 22, 2016

Changes in this version

+ func ApplyRLimitForSelf(maxOpenFiles uint64) — linux/amd64

+ func ApplyRLimitForSelf(maxOpenFiles uint64) error — darwin/amd64, js/wasm, windows/amd64

+ func DeadlockWatchdog(lock sync.Locker, name string, maxLockPeriod time.Duration)

+ func DeadlockWatchdogReadLock(lock *sync.RWMutex, name string, maxLockPeriod time.Duration)

+ func GetEnvAsFloat64OrFallback(key string, defaultValue float64) (float64, error)

+ func GetEnvAsIntOrFallback(key string, defaultValue int) (int, error)

+ func GetEnvAsStringOrFallback(key, defaultValue string) string

+ func IntPtr(i int) *int

+ func IntPtrDerefOr(ptr *int, def int) int

+ func NewCRLFWriter(w io.Writer) io.Writer

+ func ReadDirNoExit(dirname string) ([]os.FileInfo, []error, error)

+ func Umask(mask int) (old int, err error)

+ type Backoff struct

+ Clock Clock

+ func NewBackOff(initial, max time.Duration) *Backoff

+ func NewFakeBackOff(initial, max time.Duration, tc *FakeClock) *Backoff

+ func (p *Backoff) DeleteEntry(id string)

+ func (p *Backoff) GC()

+ func (p *Backoff) Get(id string) time.Duration

+ func (p *Backoff) IsInBackOffSince(id string, eventTime time.Time) bool

+ func (p *Backoff) IsInBackOffSinceUpdate(id string, eventTime time.Time) bool

+ func (p *Backoff) Next(id string, eventTime time.Time)

+ func (p *Backoff) Reset(id string)

type Clock

+ After func(d time.Duration) <-chan time.Time

+ Sleep func(d time.Duration)

type FakeClock

+ func NewFakeClock(t time.Time) *FakeClock

+ func (f *FakeClock) After(d time.Duration) <-chan time.Time

+ func (f *FakeClock) HasWaiters() bool

+ func (f *FakeClock) SetTime(t time.Time)

+ func (f *FakeClock) Sleep(d time.Duration)

+ func (f *FakeClock) Step(d time.Duration)

+ type IntervalClock struct

+ Duration time.Duration

+ Time time.Time

+ func (*IntervalClock) After(d time.Duration) <-chan time.Time

+ func (*IntervalClock) Sleep(d time.Duration)

+ func (i *IntervalClock) Now() time.Time

+ func (i *IntervalClock) Since(ts time.Time) time.Duration

type RateLimiter

+ func NewFakeAlwaysRateLimiter() RateLimiter

+ func NewFakeNeverRateLimiter() RateLimiter

+ Saturation func() float64

+ TryAccept func() bool

type RealClock

+ func (RealClock) After(d time.Duration) <-chan time.Time

+ func (RealClock) Sleep(d time.Duration)

Aug 1, 2015

Changes in this version

+ type LineDelimiter struct

+ func NewLineDelimiter(output io.Writer, delimiter string) *LineDelimiter

+ func (ld *LineDelimiter) Flush() (err error)

+ func (ld *LineDelimiter) Write(buf []byte) (n int, err error)

Jul 11, 2015

Changes in this version

+ const IdentifierNoHyphensBeginEndFmt

+ func CertsFromPEM(pemCerts []byte) ([]*x509.Certificate, error)

+ func EncodePrivateKey(private *rsa.PrivateKey) []byte

+ func EncodePublicKey(public *rsa.PublicKey) ([]byte, error)

+ func EncodeSSHKey(public *rsa.PublicKey) ([]byte, error)

+ func FileExists(filename string) (bool, error)

+ func GenerateKey(bits int) (*rsa.PrivateKey, *rsa.PublicKey, error)

+ func GetClient(req *http.Request) string

+ func IsProbableEOF(err error) bool

+ func IsValidPortName(port string) bool

+ func MakePrivateKeySignerFromBytes(buffer []byte) (ssh.Signer, error)

+ func MakePrivateKeySignerFromFile(key string) (ssh.Signer, error)

+ func ParsePublicKeyFromFile(keyFile string) (*rsa.PublicKey, error)

+ func RunInResourceContainer(containerName string) error

+ func RunSSHCommand(cmd, user, host string, signer ssh.Signer) (string, string, int, error)

+ func ShortenString(str string, n int) string

+ func SplitPort(id string) (name, port string, valid bool)

+ func UsingSystemdInitSystem() bool

+ func WarnWordSepNormalizeFunc(f *pflag.FlagSet, name string) pflag.NormalizedName

+ func WordSepNormalizeFunc(f *pflag.FlagSet, name string) pflag.NormalizedName

+ type AtomicValue struct

+ func (at *AtomicValue) Load() interface{}

+ func (at *AtomicValue) Store(val interface{})

+ type Cache []*cacheShard

+ func NewCache(maxSize int) Cache

+ func (c *Cache) Add(index uint64, obj interface{}) bool

+ func (c *Cache) Get(index uint64) (obj interface{}, found bool)

+ type Empty struct

+ type HighWaterMark int64

+ func (hwm *HighWaterMark) Check(current int64) bool

+ type PortRange struct

+ Base int

+ Size int

+ func ParsePortRange(value string) (*PortRange, error)

+ func (*PortRange) Type() string

+ func (pr *PortRange) Contains(p int) bool

+ func (pr *PortRange) Set(value string) error

+ func (pr PortRange) String() string

+ type SSHTunnel struct

+ Config *ssh.ClientConfig

+ Host string

+ SSHPort string

+ func NewSSHTunnel(user, keyfile, host string) (*SSHTunnel, error)

+ func NewSSHTunnelFromBytes(user string, privateKey []byte, host string) (*SSHTunnel, error)

+ func (s *SSHTunnel) Close() error

+ func (s *SSHTunnel) Dial(network, address string) (net.Conn, error)

+ func (s *SSHTunnel) Open() error

+ type SSHTunnelEntry struct

+ Address string

+ Tunnel *SSHTunnel

+ type SSHTunnelList struct

+ func MakeSSHTunnels(user, keyfile string, addresses []string) *SSHTunnelList

+ func (l *SSHTunnelList) Close()

+ func (l *SSHTunnelList) Has(addr string) bool

+ func (l *SSHTunnelList) Len() int

+ func (l *SSHTunnelList) Open() error

+ func (l *SSHTunnelList) PickRandomTunnel() (SSHTunnelEntry, error)

type StringFlag

+ func NewStringFlag(defaultVal string) StringFlag

type StringSet

+ func (s StringSet) HasAny(items ...string) bool

+ func (s StringSet) PopAny() (string, bool)

+ func (s1 StringSet) Union(s2 StringSet) StringSet

type Time

+ func (t Time) Equal(u Time) bool

+ type Trace struct

+ func NewTrace(name string) *Trace

+ func (t *Trace) Log()

+ func (t *Trace) LogIfLong(threshold time.Duration)

+ func (t *Trace) Step(msg string)

+ func (t *Trace) TotalTime() time.Duration

Apr 13, 2015

Changes in this version

+ const CIdentifierFmt

+ const DNS1123LabelFmt

+ const DNS1123LabelMaxLength

+ const DNS1123SubdomainFmt

+ const DNS1123SubdomainMaxLength

+ const DNS952LabelFmt

+ const DNS952LabelMaxLength

+ const LabelValueFmt

+ const LabelValueMaxLength

+ const QualifiedNameFmt

+ const QualifiedNameMaxLength

+ var ErrorHandlers = []func(error)

+ var NeverStop <-chan struct{} = make(chan struct{})

+ var PanicHandlers = []func(interface{})

+ func CertPoolFromFile(filename string) (*x509.CertPool, error)

+ func ChooseHostInterface() (net.IP, error)

+ func EscapeQualifiedNameForDisk(in string) string

+ func ExecuteTemplate(w io.Writer, templateText string, data interface{}) error

+ func ExecuteTemplateToString(templateText string, data interface{}) (string, error)

+ func HandleError(err error)

+ func IsValidIPv4(value string) bool

+ func IsValidLabelValue(value string) bool

+ func JoinQualifiedName(namespace, name string) string

+ func SplitQualifiedName(str string) (string, string)

+ func UnescapeQualifiedNameForDisk(in string) string

+ type BoolFlag struct

+ func (f *BoolFlag) Default(value bool)

+ func (f *BoolFlag) Set(value string) error

+ func (f *BoolFlag) Type() string

+ func (f BoolFlag) Provided() bool

+ func (f BoolFlag) String() string

+ func (f BoolFlag) Value() bool

type Clock

+ Since func(time.Time) time.Duration

type FakeClock

+ func (f *FakeClock) Since(ts time.Time) time.Duration

type IntOrString

+ func (intstr *IntOrString) Fuzz(c fuzz.Continue)

type RateLimiter

+ func NewFakeRateLimiter() RateLimiter

+ Accept func()

type RealClock

+ func (r RealClock) Since(ts time.Time) time.Duration

+ type Route struct

+ Destination net.IP

+ Gateway net.IP

+ Interface string

+ type StringFlag struct

+ func (f *StringFlag) Default(value string)

+ func (f *StringFlag) Set(value string) error

+ func (f *StringFlag) Type() string

+ func (f StringFlag) Provided() bool

+ func (f StringFlag) String() string

+ func (f StringFlag) Value() string

type StringSet

+ func KeySet(theMap reflect.Value) StringSet

+ func (s StringSet) Difference(s2 StringSet) StringSet

type Time

+ func (t *Time) Fuzz(c fuzz.Continue)

+ func (t *Time) IsZero() bool

+ func (t Time) Before(u Time) bool

Jan 30, 2015

Changes in this version

+ func AddAllFlagsToPFlagSet(fs *pflag.FlagSet)

+ func AddAllFlagsToPFlags()

+ func AddFlagSetToPFlagSet(fsIn *flag.FlagSet, fsOut *pflag.FlagSet)

+ func AddFlagToPFlagSet(f *flag.Flag, fs *pflag.FlagSet)

+ func AddPFlagSetToPFlagSet(fsFrom *pflag.FlagSet, fsTo *pflag.FlagSet)

+ func AllPtrFieldsNil(obj interface{}) bool

+ func ApplyOomScoreAdj(value int) error

+ func ConnectToDockerOrDie(dockerEndpoint string) *docker.Client

+ func DeepHashObject(hasher hash.Hash, objectToWrite interface{})

+ func GenerateSelfSignedCert(host, certPath, keyPath string) error

+ func GetDockerEndpoint(dockerEndpoint string) string

+ func GetHostname(hostnameOverride string) string

+ func InitFlags()

+ type Clock interface

+ Now func() time.Time

+ type ConfigurationMap map[string]string

+ func (*ConfigurationMap) Type() string

+ func (m *ConfigurationMap) Set(value string) error

+ func (m *ConfigurationMap) String() string

+ type FakeClock struct

+ Time time.Time

+ func (f *FakeClock) Now() time.Time

type IntOrString

+ func (intstr *IntOrString) String() string

+ type RealClock struct

+ func (r RealClock) Now() time.Time

+ type T interface

+ type TimeCache interface

+ Get func(key string) T

+ func NewTimeCache(clock Clock, ttl time.Duration, fill func(key string) T) TimeCache

Dec 16, 2014

Changes in this version

+ func IsDNS1123Label(value string) bool

+ func IsDNS1123Subdomain(value string) bool

+ func IsQualifiedName(value string) bool

+ func ObjectGoPrintSideBySide(a, b interface{}) string

+ func Until(f func(), period time.Duration, stopCh <-chan struct{})

type FakeHandler

+ func (f *FakeHandler) ValidateRequestCount(t TestInterface, count int)

type IP

+ func (*IP) Type() string

type IPNet

+ func (*IPNet) Type() string

type StringList

+ func (*StringList) Type() string

type StringSet

+ func (s StringSet) Len() int

type Time

+ func NewTime(time time.Time) Time

Dec 2, 2014

Changes in this version

+ var ReallyCrash bool

+ func CompileRegexps(regexpStrings []string) ([]*regexp.Regexp, error)

+ func FlushLogs()

+ func Forever(f func(), period time.Duration)

+ func HandleCrash()

+ func InitLogs()

+ func IsCIdentifier(value string) bool

+ func IsDNS952Label(value string) bool

+ func IsDNSLabel(value string) bool

+ func IsDNSSubdomain(value string) bool

+ func IsValidPortNum(port int) bool

+ func NewLogger(prefix string) *log.Logger

+ func ObjectDiff(a, b interface{}) string

+ func ObjectGoPrintDiff(a, b interface{}) string

+ func StringDiff(a, b string) string

+ type ErrorList []error

+ func (list ErrorList) ToError() error

+ type FakeHandler struct

+ RequestBody string

+ RequestReceived *http.Request

+ ResponseBody string

+ StatusCode int

+ T LogInterface

+ func (f *FakeHandler) ServeHTTP(response http.ResponseWriter, request *http.Request)

+ func (f *FakeHandler) ValidateRequest(t TestInterface, expectedPath, expectedMethod string, body *string)

+ type GlogWriter struct

+ func (writer GlogWriter) Write(data []byte) (n int, err error)

+ type IP net.IP

+ func (ip *IP) Set(value string) error

+ func (ip IP) String() string

+ type IPNet net.IPNet

+ func (ipnet *IPNet) Set(value string) error

+ func (ipnet IPNet) String() string

+ type IntOrString struct

+ IntVal int

+ Kind IntstrKind

+ StrVal string

+ func NewIntOrStringFromInt(val int) IntOrString

+ func NewIntOrStringFromString(val string) IntOrString

+ func (intstr *IntOrString) SetYAML(tag string, value interface{}) bool

+ func (intstr *IntOrString) UnmarshalJSON(value []byte) error

+ func (intstr IntOrString) GetYAML() (tag string, value interface{})

+ func (intstr IntOrString) MarshalJSON() ([]byte, error)

+ type IntstrKind int

+ const IntstrInt

+ const IntstrString

+ type LogInterface interface

+ Logf func(format string, args ...interface{})

+ type RateLimiter interface

+ CanAccept func() bool

+ Stop func()

+ func NewTokenBucketRateLimiter(qps float32, burst int) RateLimiter

+ type Runner struct

+ func NewRunner(f ...func(stop chan struct{})) *Runner

+ func (r *Runner) Start()

+ func (r *Runner) Stop()

+ type StringList []string

+ func (sl *StringList) Set(value string) error

+ func (sl *StringList) String() string

+ type StringSet map[string]empty

+ func NewStringSet(items ...string) StringSet

+ func (s StringSet) Delete(item string)

+ func (s StringSet) Has(item string) bool

+ func (s StringSet) HasAll(items ...string) bool

+ func (s StringSet) Insert(items ...string)

+ func (s StringSet) List() []string

+ func (s1 StringSet) IsSuperset(s2 StringSet) bool

+ type TestInterface interface

+ Errorf func(format string, args ...interface{})

+ Logf func(format string, args ...interface{})

+ type Time struct

+ func Date(year int, month time.Month, day, hour, min, sec, nsec int, loc *time.Location) Time

+ func Now() Time

+ func Unix(sec int64, nsec int64) Time

+ func (t *Time) SetYAML(tag string, value interface{}) bool

+ func (t *Time) UnmarshalJSON(b []byte) error

+ func (t Time) GetYAML() (tag string, value interface{})

+ func (t Time) MarshalJSON() ([]byte, error)

+ func (t Time) Rfc3339Copy() Time

+ type UUID interface

+ String func() string

+ func NewUUID() UUID