Documentation ¶
Index ¶
- func ExpBackoff(last time.Duration, max time.Duration) (next time.Duration)
- func NewThreadsafeSet(values ...string) *tsafeSet
- func NewUnsafeSet(values ...string) *unsafeSet
- func ParseFilepath(path string) string
- func TrimToDashes(args []string) []string
- type Event
- type EventStream
- type LoggingHTTPTransport
- type PeriodicReconciler
- type Set
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewThreadsafeSet ¶
func NewThreadsafeSet(values ...string) *tsafeSet
func NewUnsafeSet ¶
func NewUnsafeSet(values ...string) *unsafeSet
func ParseFilepath ¶
ParseFilepath expands ~ and ~user constructions. If user or $HOME is unknown, do nothing.
func TrimToDashes ¶
TrimToDashes takes a slice of strings (e.g. a command line) and returns everything after the first double dash (--), if any are present
Types ¶
type EventStream ¶
type EventStream interface {
Next(stop chan struct{}) chan Event
}
EventStream generates a channel which will emit an event as soon as one of interest occurs. Any background operation associated with the channel should be terminated when stop is closed.
type LoggingHTTPTransport ¶
type PeriodicReconciler ¶
type PeriodicReconciler interface {
Run(stop chan bool)
}
func NewPeriodicReconciler ¶
func NewPeriodicReconciler(interval time.Duration, recFunc func(), eStream EventStream) PeriodicReconciler
NewPeriodicReconciler creates a PeriodicReconciler that will run recFunc at least every ival, or in response to anything emitted from the channel returned by trigFunc
Click to show internal directories.
Click to hide internal directories.