Versions in this module Expand all Collapse all v0 v0.0.3 Jan 28, 2024 v0.0.2 Jan 28, 2024 v0.0.1 Jan 28, 2024 Changes in this version + func HttpGet(url string, queryBody string) string + func HttpPost(url string, queryBody string) (string, error) + func HttpPostFormDataWithHeader(url string, queryBody string, headers map[string]string) (string, error) + func HttpPostWithHeader(url string, queryBody string, headers map[string]string) (string, error) + func NewTlsConfig(sslPath string) *tls.Config + func UploadFile(url string, headers map[string]string, bodyParams map[string]string, ...) ([]byte, error) + type FileMonitorHelper struct + Directory string + FilenameExtension string + func FileMonitorInitial(Directory string, FilenameExtension string, cron string) *FileMonitorHelper + func (the *FileMonitorHelper) Initial() + func (the *FileMonitorHelper) Subscribe(task func()) + type HttpHelper struct + Token string + Url string + func (the *HttpHelper) HttpGet(queryBody string) string + func (the *HttpHelper) Initial() + func (the *HttpHelper) Publish(messageBytes []byte) (string, error) + type InfluxDBHelper struct + Bucket string + Org string + Token string + Url string + func (the *InfluxDBHelper) Close() + func (the *InfluxDBHelper) GetClient() influxdb2.Client + func (the *InfluxDBHelper) Initial() + func (the *InfluxDBHelper) Query() map[string]time.Time + func (the *InfluxDBHelper) QueryByOfflineGap(measurement string, offlineGap string) map[string]time.Time + func (the *InfluxDBHelper) Write() + type MqttHelper struct + ClientId string + Host string + Password string + Port int + UserName string + func MqttInitial(host string, port int, clientId string, userName string, password string, ...) *MqttHelper + func (the *MqttHelper) Initial() + func (the *MqttHelper) InitialWithSSL(caPath string) + func (the *MqttHelper) Publish(topic string, messageBytes []byte) + func (the *MqttHelper) Subscribe(topic string, myCallback func(topic string, callMsg string)) + type UdpHelper struct + Host string + Port int + func (the *UdpHelper) Close() + func (the *UdpHelper) Initial() + func (the *UdpHelper) Publish(messageBytes []byte)