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, data *collection.CollectionData) error
- func KafkaTopicDeviceReportUnmarshal(data []byte) (*collection.CollectionData, error)
- func KafkaTopicDeviceReportUnmarshalTo(data []byte, v *collection.CollectionData) 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 UnmarshalCollectionData(data []byte) (*collection.CollectionData, error)
- func UnmarshalCollectionDataTo(data []byte, v *collection.CollectionData) error
Constants ¶
View Source
const (
KafkaTopicDeviceLog = "device-log"
)
View Source
const (
KafkaTopicDeviceReport = "device-report"
)
View Source
const (
KafkaTopicEmail = "email"
)
Variables ¶
This section is empty.
Functions ¶
func KafkaTopicDeviceLogUnmarshal ¶
func KafkaTopicDeviceLogUnmarshal(data []byte) (*log.DeviceLogData, error)
func KafkaTopicDeviceLogUnmarshalTo ¶
func KafkaTopicDeviceLogUnmarshalTo(data []byte, v *log.DeviceLogData) error
func KafkaTopicDeviceReportSend ¶ added in v0.3.0
func KafkaTopicDeviceReportSend(kc sarama.AsyncProducer, deviceID uint64, data *collection.CollectionData) error
func KafkaTopicDeviceReportUnmarshal ¶
func KafkaTopicDeviceReportUnmarshal(data []byte) (*collection.CollectionData, error)
func KafkaTopicDeviceReportUnmarshalTo ¶
func KafkaTopicDeviceReportUnmarshalTo(data []byte, v *collection.CollectionData) error
func KafkaTopicEmailSend ¶ added in v0.3.0
func KafkaTopicEmailSend(kc sarama.AsyncProducer, data *email.SendEmailReq) error
func KafkaTopicEmailUnmarshal ¶ added in v0.3.0
func KafkaTopicEmailUnmarshal(data []byte) (*email.SendEmailReq, error)
func KafkaTopicEmailUnmarshalTo ¶ added in v0.3.0
func KafkaTopicEmailUnmarshalTo(data []byte, v *email.SendEmailReq) error
func UnmarshalCollectionData ¶ added in v0.3.1
func UnmarshalCollectionData(data []byte) (*collection.CollectionData, error)
func UnmarshalCollectionDataTo ¶ added in v0.3.1
func UnmarshalCollectionDataTo(data []byte, v *collection.CollectionData) error
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.