Versions in this module Expand all Collapse all v1 v1.0.4 Apr 3, 2022 Changes in this version + const ELSSEN_SAFETY_HOOK + const ELSSEN_TOXIC_GAS + const ELSSEN_WEARABLE_DEVICE + const METHOD_ERROR + const METHOD_MQTT + const METHOD_SOCKET + const METHOD_UNKNOWN + var BB_APPROACH_OBJECT = []byte + var BB_EVENT_COLLISION = []byte + var BB_FRONT_APPROACH = []byte + var BB_FRONT_COLLISION = []byte + var BB_FRONT_VIDEO = []byte + var BB_RADAR_APPROACH = []byte + var BB_RAW_ACCELEROMETER = []byte + var BB_REAR_APPROACH = []byte + var BB_REAR_COLLISION = []byte + var BB_REAR_VIDEO = []byte + var BB_RELAY_DISTANCE = []byte + var BB_SMART_DISTANCE = []byte + var BB_UWB_LOCATION = []byte + var BB_WORKER_IDENTITY = []byte + var BB_WRAPPED = []byte + var BBx0000 = []byte + var BBx0001 = []byte + var BBx0002 = []byte + var BBx0003 = []byte + var BBx0004 = []byte + var BBx0005 = []byte + var BBx0006 = []byte + var BBx0007 = []byte + var BBx0008 = []byte + var BBx0009 = []byte + var BBx000A = []byte + var BBx000B = []byte + var BBx000C = []byte + var BBx000D = []byte + var BBx000E = []byte + var BBx000F = []byte + var CGW_COLLISION_RISK = []byte + var CODE_ABRAIN = []byte + var CODE_ELSSEN = []byte + var CODE_TELEFIELD = []byte + var CODE_WRAPPED = []byte + var CODE_YMTECH = []byte + var CONTROL_COMMAND = []byte + var CONTROL_DIAG = []byte + var GW_CENTER_STATUS_DANGERZONE = []byte + var GW_CENTER_STATUS_FACTORY = []byte + var GW_ELSSEN_SAFETY_HOOK = []byte + var GW_ELSSEN_TOXIC_GAS = []byte + var GW_ELSSEN_WEARABLE_DEVICE = []byte + var GW_NAME_API_SERVER string = "보안 IoT 시스템" + var GW_NAME_BLACKBOX_DANGERZONE string = "위험구역 블랙박스" + var GW_NAME_BLACKBOX_FACTORY string = "제조현장 블랙박스" + var GW_NAME_CENTER_DANGERZONE string = "위험구역 집중게이트웨이" + var GW_NAME_CENTER_FACTORY string = "제조현장 집중게이트웨이" + var GW_NAME_PORTABLE_CONSTRUCTION string = "건설현장 이동형게이트웨이" + var GW_NAME_RELAY_CONSTRUCTION string = "건설현장 중계게이트웨이" + var GW_NAME_RELAY_FACTORY string = "제조현장 중계게이트웨이" + var GW_NAME_RELAY_PLATFORM string = "지능플랫폼 데이터릴레이" + var GW_NAME_SERVER_PLATFORM string = "지능형프르랫폼 서버" + var GW_NAME_SMART_DANGERZONE string = "위험구역 스마트게이트웨이" + var GW_NAME_SMART_FACTORY string = "제조현장 스마트게이트웨이" + var GW_PORTABLE_STATUS_CONSTRUCTION = []byte + var GW_RELAY_STATUS_CONSTRUCTION = []byte + var GW_RELAY_STATUS_FACTORY = []byte + var GW_SMART_STATUS_DANGERZONE = []byte + var GW_SMART_STATUS_FACTORY = []byte + var GW_TYPE_API_SERVER byte = 0x05 + var GW_TYPE_BLACKBOX_DANGERZONE byte = 0x14 + var GW_TYPE_BLACKBOX_FACTORY byte = 0x04 + var GW_TYPE_CENTER_DANGERZONE byte = 0x11 + var GW_TYPE_CENTER_FACTORY byte = 0x01 + var GW_TYPE_PORTABLE_CONSTRUCTION byte = 0x21 + var GW_TYPE_RELAY_CONSTRUCTION byte = 0x22 + var GW_TYPE_RELAY_FACTORY byte = 0x02 + var GW_TYPE_RELAY_PLATFORM byte = 0x31 + var GW_TYPE_SERVER_PLATFORM byte = 0x32 + var GW_TYPE_SMART_DANGERZONE byte = 0x13 + var GW_TYPE_SMART_FACTORY byte = 0x03 + var NAME_BB_APPROACH_OBJECT = "event.approach" + var NAME_BB_EVENT_COLLISION = "event.collision" + var NAME_BB_FRONT_APPROACH = "front.approach" + var NAME_BB_FRONT_COLLISION = "front.collision" + var NAME_BB_FRONT_VIDEO = "front.video" + var NAME_BB_RADAR_APPROACH = "radar.approach" + var NAME_BB_RAW_ACCELEROMETER = "accelerometer.raw" + var NAME_BB_REAR_APPROACH = "rear.approach" + var NAME_BB_REAR_COLLISION = "rear.collision" + var NAME_BB_REAR_VIDEO = "rear.video" + var NAME_BB_UWB_LOCATION = "event.location" + var NAME_BB_WORKER_IDENTITY = "worker.identify" + var NAME_CGW_COLLISION_RISK = "event.collision.risk" + var NAME_CODE_ABRAIN = "ABRAIN" + var NAME_CODE_ELSSEN = "ELSSEN" + var NAME_CODE_TELEFIELD = "TELEFIELD" + var NAME_CODE_WRAPPED = "Wrapped" + var NAME_CODE_YMTECH = "YMTECH" + var NAME_GW_CENTER_STATUS_DANGERZONE = "center.gw.status" + var NAME_GW_CENTER_STATUS_FACTORY = "center.gw.status" + var NAME_GW_ELSSEN_SAFETY_HOOK = "safetyhook" + var NAME_GW_ELSSEN_TOXIC_GAS = "toxicgas" + var NAME_GW_ELSSEN_WEARABLE_DEVICE = "wearable" + var NAME_GW_PORTABLE_STATUS_CONSTRUCTION = "portable.gw.status" + var NAME_GW_RELAY_STATUS_CONSTRUCTION = "relay.gw.status" + var NAME_GW_RELAY_STATUS_FACTORY = "relay.gw.status" + var NAME_GW_SMART_STATUS_DANGERZONE = "smart.gw.status" + var NAME_GW_SMART_STATUS_FACTORY = "smart.gw.status" + var NAME_UNKNOWN = "unknown" + var TYPE_BB_APPROACH_OBJECT = "접근 감지 영상" + var TYPE_BB_EVENT_COLLISION = "가속도 충돌 이벤트" + var TYPE_BB_FRONT_APPROACH = "전방 접근감지 이력 파일" + var TYPE_BB_FRONT_COLLISION = "전방 충돌 이력 파일" + var TYPE_BB_FRONT_VIDEO = "전방 영상 파일" + var TYPE_BB_RADAR_APPROACH = "접근 감지 레이다" + var TYPE_BB_RAW_ACCELEROMETER = "RAW 6축 가속도 파일" + var TYPE_BB_REAR_APPROACH = "후방 접근감지 이력 파일" + var TYPE_BB_REAR_COLLISION = "후방 충돌 이력 파일" + var TYPE_BB_REAR_VIDEO = "후방 영상 파일" + var TYPE_BB_UWB_LOCATION = "UWB 위치/속도" + var TYPE_BB_WORKER_IDENTITY = "작업자 식별" + var TYPE_CGW_COLLISION_RISK = "충돌 위험" + var TYPE_CODE_ABRAIN = "ABRAIN" + var TYPE_CODE_ELSSEN = "ELSSEN" + var TYPE_CODE_TELEFIELD = "TELEFIELD" + var TYPE_CODE_WRAPPED = "Wrapped" + var TYPE_CODE_YMTECH = "YMTECH" + var TYPE_GW_CENTER_STATUS_DANGERZONE = "위험구역 집중게이트웨이 상태보고" + var TYPE_GW_CENTER_STATUS_FACTORY = "제조현장 집중게이트웨이 상태보고" + var TYPE_GW_ELSSEN_SAFETY_HOOK = "안전고리" + var TYPE_GW_ELSSEN_TOXIC_GAS = "유해가스" + var TYPE_GW_ELSSEN_WEARABLE_DEVICE = "생체정보" + var TYPE_GW_PORTABLE_STATUS_CONSTRUCTION = "건설현장 이동형게이트웨이 상태보고" + var TYPE_GW_RELAY_STATUS_CONSTRUCTION = "건설현장 중계게이트웨이 상태보고" + var TYPE_GW_RELAY_STATUS_FACTORY = "제조현장 중계게이트웨이 상태보고" + var TYPE_GW_SMART_STATUS_DANGERZONE = "위험구역 스마트게이트웨이 상태보고" + var TYPE_GW_SMART_STATUS_FACTORY = "제조현장 스마트게이트웨이 상태보고" + var TYPE_UNKNOWN = "알 수 없음" + func AppendSliceToList(dst *list.List, src []interface{}) *list.List + func AppendToList(dst *list.List, src ...interface{}) *list.List + func AsBool(value interface{}) (bool, error) + func AsByte(value interface{}) (byte, error) + func AsBytes(value interface{}) ([]byte, error) + func AsFloat32(value interface{}) (float32, error) + func AsFloat64(value interface{}) (float64, error) + func AsInt(value interface{}) (int, error) + func AsInt16(value interface{}) (int16, error) + func AsInt32(value interface{}) (int32, error) + func AsInt64(value interface{}) (int64, error) + func AsString(value interface{}) (string, error) + func AsUint(value interface{}) (uint, error) + func AsUint16(value interface{}) (uint16, error) + func AsUint32(value interface{}) (uint32, error) + func AsUint64(value interface{}) (uint64, error) + func Copy(src, dst string) (int64, error) + func CopyMap(dst Map, src Map) error + func Dial(remote *ServiceConfigurations) (net.Conn, error) + func EncBEString(tag uint16, data string) []byte + func EncBETL(tag uint16, length uint32) []byte + func EncBETLV(tag uint16, data []byte) []byte + func EncBEUint16(tag uint16, data uint16) []byte + func EncBEUint32(tag uint16, data uint32) []byte + func EncLEString(tag uint16, data string) []byte + func EncLETL(tag uint16, length uint32) []byte + func EncLETLV(tag uint16, data []byte) []byte + func EncLETLnV(tag uint16, size uint, data []byte) []byte + func EncLEUint16(tag uint16, data uint16) []byte + func EncLEUint32(tag uint16, data uint32) []byte + func EncTagLn(order binary.ByteOrder, tag []byte, size uint, length uint32) []byte + func EncTagLnString(order binary.ByteOrder, tag []byte, size uint, data string) []byte + func EncTagLnUInt16(order binary.ByteOrder, tag []byte, size uint, data uint16) []byte + func EncTagLnUInt32(order binary.ByteOrder, tag []byte, size uint, data uint32) []byte + func EncTagLnUInt64(order binary.ByteOrder, tag []byte, size uint, data uint64) []byte + func EncTagLnV(order binary.ByteOrder, tag []byte, size uint, data []byte) []byte + func EncodeMap(order binary.ByteOrder, params map[int][]byte) []byte + func GetEquipmentName(code byte) string + func GetFlagBoolean(option *bool, name string, param *bool, deffunc func() bool) + func GetFlagInt(option *int, name string, param *int, deffunc func() int) + func GetFlagInt32(option *int32, name string, param *int32, deffunc func() int32) + func GetFlagInt64(option *int64, name string, param *int64, deffunc func() int64) + func GetFlagString(option *string, name string, param *string, deffunc func() string) + func GetFlagUint(option *uint, name string, param *uint, deffunc func() uint) + func GetFlagUint32(option *uint32, name string, param *uint32, deffunc func() uint32) + func GetFlagUint64(option *uint64, name string, param *uint64, deffunc func() uint64) + func GetGID() uint64 + func GetMQTTClient(config *MQTTConfigurations) (MQTT.Client, error) + func GetMessageName(order binary.ByteOrder, data []byte) string + func GetMessageName4ELSSEN(order binary.ByteOrder, data []byte) string + func GetMessageName4Wrap(order binary.ByteOrder, data []byte) string + func GetMessageName4YMTECH(order binary.ByteOrder, data []byte) string + func GetMessageType(order binary.ByteOrder, data []byte) string + func GetMessageType4ELSSEN(order binary.ByteOrder, data []byte) string + func GetMessageType4Wrap(order binary.ByteOrder, data []byte) string + func GetMessageType4YMTECH(order binary.ByteOrder, data []byte) string + func GetSubID(order binary.ByteOrder, data []byte) []byte + func GetSubID4ELSSEN(order binary.ByteOrder, data []byte) int + func GetSubID4YMTECH(order binary.ByteOrder, data []byte) []byte + func GetTransmissionMethod(order binary.ByteOrder, data []byte) int + func GetTransmissionMethod4Wrap(order binary.ByteOrder, data []byte) int + func GetTransmissionMethod4YMTECH(order binary.ByteOrder, data []byte) int + func GetType(myvar interface{}) string + func HttpPost(rawurl string, headers map[string]string, data []byte, ...) (int, error) + func IsFlagPassed(name string) bool + func ListToSlice(src *list.List) []interface + func ListToStringArray(src *list.List) []string + func MakeRecvChannel(conn net.Conn, ud interface{}, ...) (chan []byte, chan error) + func Map2SMap(dst map[string]interface{}, src map[interface{}]interface{}) error + func MapKey(key []byte) interface + func NativeEndian() binary.ByteOrder + func NewTLSConfig() *tls.Config + func Pack(args ...interface{}) interface + func PackAsString(args ...interface{}) string + func ReadFile(filepath string) (*bytes.Buffer, error) + func ReadyServer(serviceConfig *ServiceConfigurations, ud interface{}, ...) int + func RecvTLV(conn net.Conn, order binary.ByteOrder) ([]byte, error) + func Relay(conn1 net.Conn, ud1 interface{}, ...) int + func ReportEvent(url string, log EventLog) error + func ReportLog(url string, sourceId string, evtGwType string, evtType string, status string, ...) error + func SMap2Struct(dst interface{}, src map[string]interface{}) error + func SendMessage(data []byte, conn net.Conn) (int, error) + func SetField(obj interface{}, name string, value interface{}) error + func SliceToList(src []interface{}) *list.List + func StartServer(serviceConfig *ServiceConfigurations, ud interface{}, ...) net.Listener + func StringJoin(elems []string, sep string, filter func(string) string) string + func SumHash(filepath string, hash hash.Hash) (string, error) + func SumMD5(filepath string) (string, error) + func SumSHA256(filepath string) (string, error) + func TimeYYmmddHHMMSS(t *time.Time) string + func TraceTLVMessage(order binary.ByteOrder, data []byte, handler func(tl32v *TL32V) int) (int, error) + type ClientConfigurations struct + DiagInterval int64 + EventLogUrl string + Remote ServiceConfigurations + SourceId string + func (v *ClientConfigurations) PrintConfigurations() + func (v ClientConfigurations) ToString() []string + type DataRelay interface + DoSend func(args ...interface{}) (interface{}, error) + type EventLog struct + Content string + EventTime string + EventType string + GatewayId string + GatewayType string + Message string + Status string + func (v *EventLog) EncodeLog() ([]byte, error) + type FirmwareConfigurations struct + ConfigFilepath string + DownlaodFilepath string + Enable bool + Http HttpConfigurations + type GatewayConfigurations struct + Date string + Manufacture string + Model string + Serial string + Type string + func (v *GatewayConfigurations) PrintConfigurations() + func (v GatewayConfigurations) ToString() []string + type HttpConfigurations struct + Address string + Authorization string + EnableTls bool + Path string + Port int64 + Timeout int64 + TlsCert string + TlsKey string + func (v HttpConfigurations) ToString() []string + func (v HttpConfigurations) Url(args ...string) (*url.URL, error) + type MQTTConfigurations struct + Broker string + Cleansess bool + ClientId string + Password string + Prefix string + Qos int + User string + func (v MQTTConfigurations) ToString() []string + type Map map[interface{}]interface + func (d Map) AsByte(key interface{}) (byte, error) + func (d Map) AsFloat32(key interface{}) (float32, error) + func (d Map) AsFloat64(key interface{}) (float64, error) + func (d Map) AsInt(key interface{}) (int, error) + func (d Map) AsInt32(key interface{}) (int32, error) + func (d Map) AsInt64(key interface{}) (int64, error) + func (d Map) AsString(key interface{}) (string, error) + func (d Map) AsUint(key interface{}) (uint, error) + func (d Map) AsUint32(key interface{}) (uint32, error) + func (d Map) AsUint64(key interface{}) (uint64, error) + func (d Map) Get(key interface{}) interface{} + func (d Map) Has(key interface{}) bool + func (d Map) Set(key interface{}, value interface{}) + func (d Map) SetPair(pair ...Pair) + func (m Map) GetKeys() []interface{} + func (m Map) GetValues() []interface{} + func (m Map) Len() int + func (m Map) Range(cb func(key interface{}, value interface{}) bool) + func (m Map) Remove(key interface{}) (interface{}, bool) + func (m Map) RemoveAll() + func (m Map) ToArray() []Pair + func NewMap() *Map + type Pair struct + Key interface{} + Value interface{} + type PublishConfigurations struct + DiagInterval int64 + EventLogUrl string + MQTT MQTTConfigurations + Remote ServiceConfigurations + Service ServiceConfigurations + SourceId string + func (v *PublishConfigurations) PrintConfigurations() + func (v PublishConfigurations) ToString() []string + type RelayConfigurations struct + DiagInterval int64 + EventLogUrl string + Remote ServiceConfigurations + Service ServiceConfigurations + SourceId string + func (v *RelayConfigurations) PrintConfigurations() + func (v RelayConfigurations) ToString() []string + type SMap map[string]interface + func (d SMap) AsByte(key string) (byte, error) + func (d SMap) AsFloat32(key string) (float32, error) + func (d SMap) AsFloat64(key string) (float64, error) + func (d SMap) AsInt(key string) (int, error) + func (d SMap) AsInt32(key string) (int32, error) + func (d SMap) AsInt64(key string) (int64, error) + func (d SMap) AsString(key string) (string, error) + func (d SMap) AsUint(key string) (uint, error) + func (d SMap) AsUint32(key string) (uint32, error) + func (d SMap) AsUint64(key string) (uint64, error) + func (d SMap) Get(key string) interface{} + func (d SMap) Has(key string) bool + func (d SMap) Set(key string, value interface{}) + func (d SMap) SetPair(pair ...SPair) + func (m SMap) GetKeys() []string + func (m SMap) GetValues() []interface{} + func (m SMap) Len() int + func (m SMap) Range(cb func(key interface{}, value interface{}) bool) + func (m SMap) Remove(key string) (interface{}, bool) + func (m SMap) RemoveAll() + func (m SMap) ToArray() []SPair + func NewSMap() SMap + type SPair struct + Key string + Value interface{} + type ServerConfigurations struct + DiagInterval int64 + EventLogUrl string + Service ServiceConfigurations + SourceId string + func (v *ServerConfigurations) PrintConfigurations() + func (v ServerConfigurations) ToString() []string + type ServiceConfigurations struct + Address string + EnableTls bool + Port int64 + Timeout int64 + TlsCert string + TlsKey string + func (v *ServiceConfigurations) PrintConfigurations() + func (v ServiceConfigurations) ToString() []string + func (v ServiceConfigurations) Url(args ...string) (*url.URL, error) + type SubscribeConfigurations struct + DiagInterval int64 + EventLogUrl string + MQTT MQTTConfigurations + Remote ServiceConfigurations + SourceId string + func (v *SubscribeConfigurations) PrintConfigurations() + func (v SubscribeConfigurations) ToString() []string + type TL16V struct + Length uint16 + Type []byte + Value []byte + func DecTL16V(order binary.ByteOrder, data []byte) (*TL16V, error) + type TL32V struct + Length uint32 + Type []byte + Value []byte + func DecTL32V(order binary.ByteOrder, data []byte) (*TL32V, error) + func RecvTL32V(conn net.Conn, order binary.ByteOrder) (*TL32V, error) + func (v TL32V) Bytes(order binary.ByteOrder) []byte + func (v TL32V) Size() int + type TL64V struct + Length uint64 + Type []byte + Value []byte + func DecTL64V(order binary.ByteOrder, data []byte) (*TL64V, error) + type TcpRelay struct + func (v TcpRelay) DoSend(args ...interface{}) (interface{}, error)