utils

Documentation

Index

• func LineToSlice(s string) []string
• func MergeMap(data map[string]string, resultTo interface{}) error
• func SendToSocket(socket string, command string) error
• func SizeSuffixToInt64(size string) (int64, error)
• func Split(s, sep string) []string
• type Queue
  • func NewFailureRateLimitingQueue(failInitialWait, failMaxWait time.Duration, ...) Queue
  • func NewQueue(sync func(item interface{})) Queue
  • func NewRateLimitingQueue(rate float32, syncfn func(item interface{})) Queue
• type Tick
• type Timer
  • func NewTimer(observer func(task string, duration time.Duration)) *Timer
  • func (t *Timer) AsString(totalLabel string) string
  • func (t *Timer) Tick(eventLabel string)

Functions

func LineToSlice

func LineToSlice(s string) []string

LineToSlice converts POSIX line breaks to a string slice

func MergeMap

func MergeMap(data map[string]string, resultTo interface{}) error

MergeMap copy keys from a `data` map to a `resultTo` tagged object

func SendToSocket

func SendToSocket(socket string, command string) error

SendToSocket send strings to a unix socket specified

func SizeSuffixToInt64

func SizeSuffixToInt64(size string) (int64, error)

SizeSuffixToInt64 converts a size in string format with suffix into int64

func Split

func Split(s, sep string) []string

Split returns a slice of substrings from s, separated by sep. If s is empty, Split returns an empty slice. Split will also TrimSpace() all resulting substrings.

Types

type Queue

type Queue interface {
	Add(item interface{})
	Clear()
	Notify()
	Remove(item interface{})
	Run()
	ShuttingDown() bool
	ShutDown()
}

Queue ...

func NewFailureRateLimitingQueue

func NewFailureRateLimitingQueue(failInitialWait, failMaxWait time.Duration, syncfn func(item interface{}) error) Queue

NewFailureRateLimitingQueue ...

func NewQueue

func NewQueue(sync func(item interface{})) Queue

NewQueue ...

func NewRateLimitingQueue

func NewRateLimitingQueue(rate float32, syncfn func(item interface{})) Queue

NewRateLimitingQueue ...

type Tick

type Tick struct {
	Event string
	When  time.Time
}

Tick ...

type Timer

type Timer struct {
	Start time.Time
	Ticks []*Tick
	// contains filtered or unexported fields
}

Timer ...

func NewTimer

func NewTimer(observer func(task string, duration time.Duration)) *Timer

NewTimer ...

func (*Timer) AsString

func (t *Timer) AsString(totalLabel string) string

AsString ...

func (*Timer) Tick

func (t *Timer) Tick(eventLabel string)

Tick ...