Documentation
¶
Index ¶
- func CacheMiss()
- func CacheRead(duration time.Duration)
- func DeviceMsgHandled(size float64, userId string, deviceId string, deviceTypeId string, ...)
- func DeviceMsgReceive(size float64, userId string, deviceId string, deviceTypeId string, ...)
- func Init()
- func IotRead(duration time.Duration)
- func KafkaWrite(duration time.Duration, userId string)
- func SourceReceive(size float64, userId string)
- func SourceReceiveHandled(size float64, userId string)
- func TimescaleWrite(duration time.Duration, userId string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeviceMsgHandled ¶
func DeviceMsgReceive ¶
func KafkaWrite ¶
func SourceReceive ¶
func SourceReceiveHandled ¶
func TimescaleWrite ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.