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 ¶
View Source
const (
KafkaTopicDeviceLog = "device-log"
)
View Source
const (
KafkaTopicDeviceReport = "device-report"
)
View Source
const (
KafkaTopicEmail = "email"
)
View Source
const (
KafkaTopicMessage = "message"
)
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.CreateCollectionRecordReq) error
func KafkaTopicDeviceReportUnmarshal ¶
func KafkaTopicDeviceReportUnmarshal(data []byte) (*collection.CreateCollectionRecordReq, error)
func KafkaTopicDeviceReportUnmarshalTo ¶
func KafkaTopicDeviceReportUnmarshalTo(data []byte, v *collection.CreateCollectionRecordReq) 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 KafkaTopicMessageSend ¶ added in v0.3.3
func KafkaTopicMessageSend(kc sarama.AsyncProducer, data *message.SendMessageReq) error
func KafkaTopicMessageUnmarshal ¶ added in v0.3.3
func KafkaTopicMessageUnmarshal(data []byte) (*message.SendMessageReq, error)
func KafkaTopicMessageUnmarshalTo ¶ added in v0.3.3
func KafkaTopicMessageUnmarshalTo(data []byte, v *message.SendMessageReq) error
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.