Documentation
¶
Index ¶
- Constants
- func DecodePayload(payload []byte, tag *Tag) error
- func DecodeTopic(topic string) (string, string, error)
- func EncodePayload(source string, tag string, value *Value, valtype int32, at uint64, unit string) []byte
- func EncodeTopic(source, tag string) string
- type MQConfig
- type MsgQueueBase
- type OnTagCallback
- type Tag
- type Tagf
- func (self *Tagf) Delete() error
- func (self *Tagf) Publish(sourceName string, tagName string, val *Value, valType int32, timestamp uint64, ...) error
- func (self *Tagf) Subscribe(sourceName, tagName string) error
- func (self *Tagf) SubscribeCallback(ontag OnTagCallback) error
- func (self *Tagf) UnSubscribe(sourceName, tagName string) error
- type TpMqtt
- func (self *TpMqtt) Close() error
- func (self *TpMqtt) OnConnectHandler(client mqtt.Client)
- func (self *TpMqtt) OnDisconnectHandler(client mqtt.Client, err error)
- func (self *TpMqtt) OnPublishHandler(client mqtt.Client, message mqtt.Message)
- func (self *TpMqtt) Publish(topic string, payload []byte) error
- func (self *TpMqtt) SetLogLevel(level string) error
- func (self *TpMqtt) Subscribe(topic string) error
- func (self *TpMqtt) SubscribeCallback(hnd OnTagCallback) error
- func (self *TpMqtt) UnSubscribe(topic string) error
- type Value
- type WaitLock
Constants ¶
View Source
const ( ERR_SUCESS = 0 ERR_FAILED = 1 ERR_INVALID_INPUT = 2 ERR_NULL_ACCESS = 3 )
View Source
const ( TAG_VALUE_TYPE_BOOLEAN = 0 TAG_VALUE_TYPE_INT8 = 1 TAG_VALUE_TYPE_INT16 = 2 TAG_VALUE_TYPE_INT32 = 3 TAG_VALUE_TYPE_INT64 = 4 TAG_VALUE_TYPE_INT = 5 TAG_VALUE_TYPE_UINT8 = 6 TAG_VALUE_TYPE_UINT16 = 7 TAG_VALUE_TYPE_UINT32 = 8 TAG_VALUE_TYPE_UINT64 = 9 TAG_VALUE_TYPE_UINT = 10 TAG_VALUE_TYPE_FLOAT = 11 TAG_VALUE_TYPE_DOUBLE = 12 TAG_VALUE_TYPE_STRING = 13 TAG_VALUE_TYPE_BYTEARRAY = 14 )
Variables ¶
This section is empty.
Functions ¶
func DecodePayload ¶
func EncodePayload ¶
func EncodeTopic ¶
Types ¶
type MsgQueueBase ¶
type OnTagCallback ¶
type Tagf ¶
type Tagf struct {
// contains filtered or unexported fields
}
func (*Tagf) SubscribeCallback ¶
func (self *Tagf) SubscribeCallback(ontag OnTagCallback) error
func (*Tagf) UnSubscribe ¶
type TpMqtt ¶
type TpMqtt struct { MsgQueueBase // contains filtered or unexported fields }
func (*TpMqtt) OnConnectHandler ¶
func (*TpMqtt) OnDisconnectHandler ¶
func (*TpMqtt) OnPublishHandler ¶
func (*TpMqtt) SetLogLevel ¶ added in v0.0.4
func (*TpMqtt) SubscribeCallback ¶
func (self *TpMqtt) SubscribeCallback(hnd OnTagCallback) error
func (*TpMqtt) UnSubscribe ¶ added in v0.0.2
Click to show internal directories.
Click to hide internal directories.