common

Documentation

Index

• func NewNotifyResult(success bool, err error, data interface{}) basic.NotifyResult
• type Notify
  • func NewNotify() *Notify
  • func (notify *Notify) Done() <-chan struct{}
  • func (notify *Notify) Finish(result basic.NotifyResult) error
  • func (notify *Notify) Result() basic.NotifyResult

Functions

func NewNotifyResult

func NewNotifyResult(success bool, err error, data interface{}) basic.NotifyResult

Types

type Notify

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

Notify is an implementation of basic.Notify.

func NewNotify

func NewNotify() *Notify

NewNotify creates Notify which implements basic.Notify.

func (*Notify) Done

func (notify *Notify) Done() <-chan struct{}

func (*Notify) Finish

func (notify *Notify) Finish(result basic.NotifyResult) error

Finish sets result and close done channel to notify work done.

func (*Notify) Result

func (notify *Notify) Result() basic.NotifyResult

Result returns the NotifyResult and only valid after Done channel is closed.