mqtt_binding

Dec 12, 2023

Changes in this version

+ var ErrIgnoreBusinessResult = errors.New("忽略业务结果")

Dec 4, 2023

Changes in this version

type BindItem

+ ResponseIdentifier string

Nov 21, 2023

Changes in this version

+ func Bind[I any, O any](b *Binding, item *BindItem[I, O], handlers ...router.Handler)

+ func Destroy()

+ func Init(prefix string, opts *mqtt_client.MqttClientOptions) error

+ type BindItem struct

+ BusinessFunc BusinessFunc[I, O]

+ OptionalBindingFunc BindingFunc[O]

+ ResponseFunc response.SendFunc[O]

+ Topic string

+ type Binding struct

+ func NewBinding(apiVersion string, handlers ...router.Handler) *Binding

+ func (binding *Binding) AddHandler(topic string, handlers ...router.Handler) error

+ type BindingFunc func(c *mqtt_client.MqttClient, item *router.Item, request any, ...) bool

+ type BusinessFunc func(c *mqtt_client.MqttClient, inputModel I) (O, error)