service

Documentation

Index

• Constants
• func KafkaTopicDeviceLogUnmarshal(data []byte) (*log.DeviceLogData, error)
• func KafkaTopicDeviceLogUnmarshalTo(data []byte, v *log.DeviceLogData) error
• func KafkaTopicDeviceReportSend(kc sarama.AsyncProducer, deviceID uint64, ...) error
• func KafkaTopicDeviceReportUnmarshal(data []byte) (*collection.CreateCollectionRecordReq, error)
• func KafkaTopicDeviceReportUnmarshalTo(data []byte, v *collection.CreateCollectionRecordReq) error
• func KafkaTopicEmailSend(kc sarama.AsyncProducer, data *email.SendEmailReq) error
• func KafkaTopicEmailUnmarshal(data []byte) (*email.SendEmailReq, error)
• func KafkaTopicEmailUnmarshalTo(data []byte, v *email.SendEmailReq) error
• func KafkaTopicMessageSend(kc sarama.AsyncProducer, data *message.SendMessageReq) error
• func KafkaTopicMessageUnmarshal(data []byte) (*message.SendMessageReq, error)
• func KafkaTopicMessageUnmarshalTo(data []byte, v *message.SendMessageReq) error

Constants

const (
	KafkaTopicDeviceLog = "device-log"
)

const (
	KafkaTopicDeviceReport = "device-report"
)

const (
	KafkaTopicEmail = "email"
)

const (
	KafkaTopicMessage = "message"
)

Functions

func KafkaTopicDeviceLogUnmarshal

func KafkaTopicDeviceLogUnmarshal(data []byte) (*log.DeviceLogData, error)

func KafkaTopicDeviceLogUnmarshalTo

func KafkaTopicDeviceLogUnmarshalTo(data []byte, v *log.DeviceLogData) error

func KafkaTopicDeviceReportSend

func KafkaTopicDeviceReportSend(kc sarama.AsyncProducer, deviceID uint64, data *collection.CreateCollectionRecordReq) error

func KafkaTopicDeviceReportUnmarshal

func KafkaTopicDeviceReportUnmarshal(data []byte) (*collection.CreateCollectionRecordReq, error)

func KafkaTopicDeviceReportUnmarshalTo

func KafkaTopicDeviceReportUnmarshalTo(data []byte, v *collection.CreateCollectionRecordReq) error

func KafkaTopicEmailSend

func KafkaTopicEmailSend(kc sarama.AsyncProducer, data *email.SendEmailReq) error

func KafkaTopicEmailUnmarshal

func KafkaTopicEmailUnmarshal(data []byte) (*email.SendEmailReq, error)

func KafkaTopicEmailUnmarshalTo

func KafkaTopicEmailUnmarshalTo(data []byte, v *email.SendEmailReq) error

func KafkaTopicMessageSend

func KafkaTopicMessageSend(kc sarama.AsyncProducer, data *message.SendMessageReq) error

func KafkaTopicMessageUnmarshal

func KafkaTopicMessageUnmarshal(data []byte) (*message.SendMessageReq, error)

func KafkaTopicMessageUnmarshalTo

func KafkaTopicMessageUnmarshalTo(data []byte, v *message.SendMessageReq) error