helpers

Documentation

Index

• func Check(url string, status int) (string, error)
• func CheckProxy(url string, status int, header *proxyproto.Header) (string, error)
• func Concat(left error, right error) error
• func Fanout(funcs []func() error) func() error
• func PruneHome(pwd string) string
• func RandomString(n int) string
• func RandomStringRunes(n int, runes []rune) string
• func Retry(timer *time.Timer, interval time.Duration, callback func() (retry bool)) error
• func ToStringKeyedMap(m interface{}) (map[string]interface{}, error)
• type Synchronizer
  • func NewSynchronizer(wg *sync.WaitGroup) *Synchronizer
  • func (s *Synchronizer) Cause() error
  • func (s *Synchronizer) Done(err error)
  • func (s Synchronizer) Error() string
  • func (s *Synchronizer) IsError() bool

Functions

func Check

func Check(url string, status int) (string, error)

func CheckProxy

func CheckProxy(url string, status int, header *proxyproto.Header) (string, error)

func Concat

func Concat(left error, right error) error

func Fanout

func Fanout(funcs []func() error) func() error

func PruneHome

func PruneHome(pwd string) string

func RandomString

func RandomString(n int) string

RandomString generates an alphabetic string with uppercase and lowercase letters of size n with some chance of being unique

func RandomStringRunes

func RandomStringRunes(n int, runes []rune) string

RandomString generates an alphabetic string with uppercase and lowercase letters of size n with some chance of being unique

func Retry

func Retry(timer *time.Timer, interval time.Duration, callback func() (retry bool)) error

func ToStringKeyedMap

func ToStringKeyedMap(m interface{}) (map[string]interface{}, error)

Types

type Synchronizer

type Synchronizer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Synchronizer implements the error interface as well as the Causer interface from package github.com/pkg/errors It just returns the first error when Cause is called

It is well suited for scatter and gather synchronization

func NewSynchronizer

func NewSynchronizer(wg *sync.WaitGroup) *Synchronizer

func (*Synchronizer) Cause

func (s *Synchronizer) Cause() error

func (*Synchronizer) Done

func (s *Synchronizer) Done(err error)

func (Synchronizer) Error

func (s Synchronizer) Error() string

func (*Synchronizer) IsError

func (s *Synchronizer) IsError() bool