Versions in this module Expand all Collapse all v1 v1.1.1 Oct 7, 2020 v1.1.0 Oct 7, 2020 Changes in this version + func CallHandler(reflection TaskReflection, ctx context.Context, input []byte) (ret interface{}, err error) + func CallHandlerFunction(handlerSymbol interface{}, ctx context.Context, input interface{}) (interface{}, error) + func CreateHandler(tm *TaskHandlers) (func(context context.Context, input *RawMessage) (interface{}, error), error) + func ValidateHandler(handlerSymbol interface{}) error + type RawMessage struct + Input json.RawMessage + Task *string + func (message *RawMessage) UnmarshalJSON(data []byte) error + type TaskError struct + ErrorString string + Task *string + Tasks []string + func (t *TaskError) Error() string + type TaskHandlers map[string]interface + func (t *TaskHandlers) Reflect() map[string]TaskReflection + func (t *TaskHandlers) Tasks() []string + func (t *TaskHandlers) Validate() error + type TaskReflection struct + EventType reflect.Type + Handler reflect.Value + Type reflect.Type + func CreateTaskReflection(handlerSymbol interface{}) TaskReflection