action

Documentation

Index

• type Func
• type Handler
  • func New(maxConcurrentActions int) (handler *Handler)
  • func (handler *Handler) Execute(id string, doAction Func) (channel <-chan error)
  • func (handler *Handler) Wait()

Types

type Func

type Func func(id string) (err error)

Func action function type.

type Handler

type Handler struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Handler action handler.

func New

func New(maxConcurrentActions int) (handler *Handler)

New creates new action handler.

func (*Handler) Execute

func (handler *Handler) Execute(id string, doAction Func) (channel <-chan error)

Execute executes action.

func (*Handler) Wait

func (handler *Handler) Wait()

Wait waits all actions are executed.