Documentation ¶
Index ¶
- Constants
- func OriginalValue(data reflect.Value) (interface{}, error)
- func ReflectValue(valueType string, value interface{}) (reflect.Value, error)
- func RegisteHandler(h map[string]interface{})
- func TypeValue2ReflectValue(data []TypeValue) []reflect.Value
- type AsyncBase
- type Backend
- type Broker
- type BrokerMessage
- type Logger
- type Message
- type Result
- type ResultValue
- type TypeValue
Constants ¶
View Source
const NoResultFound string = "No errors found"
Variables ¶
This section is empty.
Functions ¶
func OriginalValue ¶
func RegisteHandler ¶
func RegisteHandler(h map[string]interface{})
func TypeValue2ReflectValue ¶
Types ¶
type AsyncBase ¶
type AsyncBase struct {
// contains filtered or unexported fields
}
func (*AsyncBase) GetProducer ¶
func (t *AsyncBase) GetProducer() *producer
type Backend ¶
type Backend interface { CheckHealth() bool SetResult(taskId string, result []byte) error GetResult(taskId string) ([]byte, error) Close() error }
Backend used to manage task's status and result
type Broker ¶
type Broker interface { CheckHealth() bool PopMessage(string) (*BrokerMessage, error) Ack(ackAll bool, message *BrokerMessage) error PushMessage(string, []byte) error Close() error }
Broker used to manage the task queue
type BrokerMessage ¶
type BrokerMessage struct { Body []byte Origin interface{} }
type Message ¶
func NewMessage ¶
type Result ¶
type Result struct { ReturnValues []*ResultValue HasError bool Error string }
type ResultValue ¶
type ResultValue struct { Type string Value interface{} }
Source Files ¶
Click to show internal directories.
Click to hide internal directories.