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
- func SplitHeaderNameValue(header string) (name, value string, err error)
- type Queue
- type QueueFacade
- type Tick
- type Timer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LineToSlice ¶ added in v0.8.1
LineToSlice converts POSIX line breaks to a string slice
func SendToSocket ¶
SendToSocket send strings to a unix socket specified
func SizeSuffixToInt64 ¶
SizeSuffixToInt64 converts a size in string format with suffix into int64
func Split ¶ added in v0.8.1
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.
func SplitHeaderNameValue ¶ added in v0.15.0
SplitHeaderNameValue splits a header line declaration into header name and value. Note that name and value might be empty for an empty input.
Types ¶
type Queue ¶ added in v0.9.1
type Queue interface {
QueueFacade
Clear()
Notify()
Run()
RunWithContext(context.Context)
Len() int
ShuttingDown() bool
ShutDown()
}
Queue ...
func NewFailureRateLimitingQueue ¶ added in v0.9.1
func NewFailureRateLimitingQueue(failInitialWait, failMaxWait time.Duration, syncfn func(item interface{}) error) Queue
NewFailureRateLimitingQueue ...
func NewRateLimitingQueue ¶ added in v0.9.1
NewRateLimitingQueue ...
type QueueFacade ¶ added in v0.15.0
type QueueFacade interface {
Add(item interface{})
AddAfter(item interface{}, duration time.Duration)
Remove(item interface{})
Start(context.Context) error
}
QueueFacade ...
Click to show internal directories.
Click to hide internal directories.