Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gotag

package module

Go to main page

Versions in this module

v0

v0.0.6

Dec 4, 2019

Changes in this version

+ const TAG_VALUE_TYPE_INT64

+ const TAG_VALUE_TYPE_UINT64

v0.0.5

Jul 29, 2019

v0.0.4

Jul 25, 2019

Changes in this version

type MQConfig

+ Debug string

type TpMqtt

+ func (self *TpMqtt) SetLogLevel(level string) error

v0.0.3

Jul 22, 2019

v0.0.2

Jul 1, 2019

Changes in this version

type MsgQueueBase

+ UnSubscribe func(topic string) error

type Tagf

+ func (self *Tagf) SetLogLevel(level string) error

type TpMqtt

+ func (self *TpMqtt) UnSubscribe(topic string) error

+ type WaitLock struct

+ func WaitSync(wg *sync.WaitGroup, timeout time.Duration) *WaitLock

+ func (w *WaitLock) PostDelay() bool

v0.0.1

Jan 11, 2019

Changes in this version

+ const ERR_FAILED

+ const ERR_INVALID_INPUT

+ const ERR_NULL_ACCESS

+ const ERR_SUCESS

+ const TAG_VALUE_TYPE_BOOLEAN

+ const TAG_VALUE_TYPE_BYTEARRAY

+ const TAG_VALUE_TYPE_DOUBLE

+ const TAG_VALUE_TYPE_FLOAT

+ const TAG_VALUE_TYPE_INT

+ const TAG_VALUE_TYPE_INT16

+ const TAG_VALUE_TYPE_INT32

+ const TAG_VALUE_TYPE_INT8

+ const TAG_VALUE_TYPE_STRING

+ const TAG_VALUE_TYPE_UINT

+ const TAG_VALUE_TYPE_UINT16

+ const TAG_VALUE_TYPE_UINT32

+ const TAG_VALUE_TYPE_UINT8

+ func DecodePayload(payload []byte, tag *Tag) error

+ func DecodeTopic(topic string) (string, string)

+ func EncodePayload(source string, tag string, value *Value, valtype int32, at uint64, unit string) []byte

+ func EncodeTopic(source, tag string) string

+ func Split(str string, symbol string) (string, string, error)

+ type MQConfig struct

+ Host string

+ Id string

+ Port string

+ Qos byte

+ Retained bool

+ type MessageHandler *func(string, string, Value, int32, uint64, string)

+ type MsgQueueBase interface

+ Close func() (int32, error)

+ Publish func(topic string, payload []byte) error

+ Subscribe func(topic string) (int32, error)

+ SubscribeCallback func(ontag OnTagCallback) (int32, error)

+ Unsubscribe func(topic string) (int32, error)

+ type OnTagCallback func(sourceName string, tagName string, value *Value, valueType int32, ...)

+ type Tag struct

+ type Tagf struct

+ func NewClient(host ...string) *Tagf

+ func (self *Tagf) Delete() (int32, error)

+ func (self *Tagf) Publish(sourceName string, tagName string, val *Value, valType int32, timestamp uint64, ...) error

+ func (self *Tagf) Subscribe(sourceName, tagName string) (int32, error)

+ func (self *Tagf) SubscribeCallback(ontag OnTagCallback) (int32, error)

+ func (self *Tagf) UnSubscribe(sourceName, tagName string) (int32, error)

+ type TpMqtt struct

+ func NewMqtt(cfg *MQConfig) (*TpMqtt, error)

+ func (self *TpMqtt) Close() (int32, 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) Subscribe(topic string) (int32, error)

+ func (self *TpMqtt) SubscribeCallback(hnd OnTagCallback) (int32, error)

+ func (self *TpMqtt) Unsubscribe(topic string) (int32, error)

+ type Value struct

+ func NewValue(value interface{}) *Value

+ func (m *Value) GetBytes() []byte

+ func (m *Value) GetDouble() float64

+ func (m *Value) GetFloat() float32

+ func (m *Value) GetInt() int64

+ func (m *Value) GetStr() string

+ func (m *Value) GetUint() uint64