utils

Feb 28, 2020

Changes in this version

type Observable

+ func (o *Observable) UnsubscribeAll()

Feb 20, 2020

Changes in this version

+ type ErrInjector struct

+ func (e *ErrInjector) CountInject(times int, err error)

+ func (e *ErrInjector) E(err error) error

+ func (e *ErrInjector) Inject(fn func(error) error)

Feb 9, 2020

Changes in this version

+ var ErrMaxSleepCount = errors.New("max sleep count")

+ func DefaultBackoff(interval time.Duration) time.Duration

+ func Retry(ctx context.Context, s Sleeper, fn func() (stop bool, err error)) error

+ type Sleeper func(ctx context.Context) error

+ func BackoffSleeper(init, maxInterval time.Duration, algorithm func(time.Duration) time.Duration) Sleeper

+ func CountSleeper(max int) Sleeper

+ func MergeSleepers(list ...Sleeper) Sleeper

Feb 7, 2020

Changes in this version

type Subscriber

+ func (s *Subscriber) Filter(filter func(Event) bool) chan Event

Feb 7, 2020

Changes in this version

type Observable

+ func (o *Observable) Count() int

type Subscriber

+ C chan Event

Feb 6, 2020

Changes in this version

+ func Pause()

Feb 6, 2020

Changes in this version

+ func Sleep(seconds float64)

Feb 2, 2020

Changes in this version

type Observable

+ func NewObservable() *Observable

Feb 2, 2020

Changes in this version

+ type Event interface

+ type Observable struct

+ func (o *Observable) Publish(e Event)

+ func (o *Observable) Subscribe() Subscriber

+ func (o *Observable) Unsubscribe(s *Subscriber)

+ func (o *Observable) Until(filter func(e Event) bool) (e Event)

+ type Subscriber chan Event

Dec 16, 2019

Changes in this version

+ type JSONResult = *gjson.Result

Dec 2, 2019

Changes in this version

+ func MustToJSON(data interface{}) string

+ func MustToJSONBytes(data interface{}) []byte

Aug 13, 2019

Changes in this version

+ const Version

+ var Stderr = ansi.NewAnsiStderr()

+ var Stdout = ansi.NewAnsiStdout()

+ func All(actions ...func())

+ func C(str interface{}, color string) string

+ func ClearScreen() error

+ func Dump(val interface{})

+ func E(args ...interface{}) []interface

+ func E1(arg interface{}, err error) interface

+ func Err(v ...interface{})

+ func ErrArg(args ...interface{}) error

+ func JSON(data interface{}) (res gjson.Result)

+ func Log(v ...interface{})

+ func Noop(_ ...interface{})

+ func RandBytes(len int) []byte

+ func RandString(len int) string

+ func S(tpl string, params ...interface{}) string

+ func Sdump(val interface{}) string

+ func Try(fn func()) (err interface{})

+ type Nil struct