Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Deregister = errors.New("callback deregistered")
Functions ¶
This section is empty.
Types ¶
type ReduceCallback ¶
type ReduceCallback func(in interface{}, params ...interface{}) (interface{}, error)
type ReduceCallbackManager ¶
type ReduceCallbackManager struct {
// contains filtered or unexported fields
}
func NewReduceCallbackManager ¶
func NewReduceCallbackManager() *ReduceCallbackManager
func (*ReduceCallbackManager) RegisterCallback ¶
func (m *ReduceCallbackManager) RegisterCallback(c ReduceCallback)
func (*ReduceCallbackManager) RunCallbacks ¶
func (m *ReduceCallbackManager) RunCallbacks(in interface{}, params ...interface{}) (res interface{}, errs []error)
RunCallbacks runs all callbacks on a variadic parameter list, and de-registers callbacks that throw an error.
func (*ReduceCallbackManager) UnsafelySetReverse ¶
func (m *ReduceCallbackManager) UnsafelySetReverse() *ReduceCallbackManager
type SequentialCallbackManager ¶
type SequentialCallbackManager struct {
// contains filtered or unexported fields
}
func NewSequentialCallbackManager ¶
func NewSequentialCallbackManager() *SequentialCallbackManager
func (*SequentialCallbackManager) RegisterCallback ¶
func (m *SequentialCallbackManager) RegisterCallback(callbacks ...Callback)
RegisterCallback atomically registers all callbacks passed in.
func (*SequentialCallbackManager) RunCallbacks ¶
func (m *SequentialCallbackManager) RunCallbacks(params ...interface{}) []error
RunCallbacks runs all callbacks on a variadic parameter list, and de-registers callbacks that throw an error.
func (*SequentialCallbackManager) Trim ¶
func (m *SequentialCallbackManager) Trim()
func (*SequentialCallbackManager) UnsafelySetReverse ¶
func (m *SequentialCallbackManager) UnsafelySetReverse() *SequentialCallbackManager
Source Files
Click to show internal directories.
Click to hide internal directories.