gotag

package module

Go to main page

Versions in this module

v1

v1.1.1

Aug 23, 2022

Changes in this version

type Value

+ func (m *Value) GetBool() bool

v1.1.0

Jun 17, 2020

Changes in this version

+ func GetTimestamp() int64

v1.0.3

Mar 19, 2020

v1.0.2

Feb 25, 2020

v1.0.1

Jan 21, 2020

Changes in this version

type Value

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

v1.0.0

Jan 7, 2020

Changes in this version

+ const TAG_VALUE_TYPE_INT64

+ const TAG_VALUE_TYPE_RAW

+ const TAG_VALUE_TYPE_UINT64

+ func DecodeDxValue(val *Value, v *C.DX_TAG_VALUE, valType uint16)

+ func EncodeDxValue(val *Value, v *C.DX_TAG_VALUE, valType uint16)

+ func FreeAlloc(val *C.DX_TAG_VALUE, valType uint16)

+ type DataExchange struct

+ func NewDataExchange() *DataExchange

+ func (d *DataExchange) Close() error

+ func (d *DataExchange) Publish(topic string, valType uint16, val *Value, ts uint64) error

+ func (d *DataExchange) Subscribe(topic string) error

+ func (d *DataExchange) SubscribeCallback(hnd OnTagCallback) error

+ func (d *DataExchange) UnSubscribe(topic string) error

type Tagf

+ func (self *Tagf) Get(module, source, tag string) *Tag

+ func (self *Tagf) TagList() []Tag

v0

v0.0.7

Dec 10, 2019

Changes in this version

+ func Round(x, unit float64) float64

v0.0.6

Aug 19, 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, error)

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

+ func EncodeTopic(source, tag string) string

+ type MQConfig struct

+ Debug string

+ Host string

+ Id string

+ Port string

+ Qos byte

+ Retained bool

+ type MsgQueueBase interface

+ Close func() error

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

+ Subscribe func(topic string) error

+ SubscribeCallback func(ontag OnTagCallback) error

+ UnSubscribe func(topic string) error

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

+ type Tag struct

+ type Tagf struct

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

+ 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 struct

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

+ 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 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

+ type WaitLock struct

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

+ func (w *WaitLock) PostDelay() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL