utils

package

v0.14.6 Latest Latest Go to latest Published: Jan 24, 2024 License: Apache-2.0 Imports: 10 Imported by: 4

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jcmoraisjr/haproxy-ingress

Links

Open Source Insights

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
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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func LineToSlice ¶ added in v0.8.1

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 ¶ added in v0.8.1

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 ¶ added in v0.9.1

type Queue interface {
	Add(item interface{})
	Clear()
	Notify()
	Remove(item interface{})
	Run()
	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 NewQueue ¶ added in v0.9.1

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

NewQueue ...

func NewRateLimitingQueue ¶ added in v0.9.1

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

NewRateLimitingQueue ...

type Tick ¶ added in v0.8.1

type Tick struct {
	Event string
	When  time.Time
}

Tick ...

type Timer ¶ added in v0.8.1

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

Timer ...

func NewTimer ¶ added in v0.8.1

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

NewTimer ...

func (*Timer) AsString ¶ added in v0.8.1

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

AsString ...

func (*Timer) Tick ¶ added in v0.8.1

func (t *Timer) Tick(eventLabel string)

Tick ...

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL