utils

Documentation

Index

• func GoWithRecover(handler func(), recoverHandler func(r interface{}))
• type Cycle
  • func NewCycle() *Cycle
  • func (c *Cycle) Close()
  • func (c *Cycle) Done() <-chan struct{}
  • func (c *Cycle) DoneAndClose()
  • func (c *Cycle) Run(fn func() error)
  • func (c *Cycle) Wait() <-chan error

Functions

func GoWithRecover

func GoWithRecover(handler func(), recoverHandler func(r interface{}))

Types

type Cycle

type Cycle struct {
	// contains filtered or unexported fields
}

Cycle ..

func NewCycle

func NewCycle() *Cycle

NewCycle new a cycle life

func (*Cycle) Close

func (c *Cycle) Close()

Close ..

func (*Cycle) Done

func (c *Cycle) Done() <-chan struct{}

Done block and return a chan error

func (*Cycle) DoneAndClose

func (c *Cycle) DoneAndClose()

DoneAndClose ..

func (*Cycle) Run

func (c *Cycle) Run(fn func() error)

Run a new goroutine

func (*Cycle) Wait

func (c *Cycle) Wait() <-chan error

Wait blocked for a life cycle