statistics

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)

Functions

func CacheMiss

func CacheMiss()

func CacheRead

func CacheRead(duration time.Duration)

func DeviceMsgHandled

func DeviceMsgHandled(size float64, userId string, deviceId string, deviceTypeId string, serviceIds []string)

func DeviceMsgReceive

func DeviceMsgReceive(size float64, userId string, deviceId string, deviceTypeId string, serviceIds []string)

func Init

func Init()

func IotRead

func IotRead(duration time.Duration)

func KafkaWrite

func KafkaWrite(duration time.Duration, userId string)

func SourceReceive

func SourceReceive(size float64, userId string)

func SourceReceiveHandled

func SourceReceiveHandled(size float64, userId string)

func TimescaleWrite

func TimescaleWrite(duration time.Duration, userId string)