Documentation ¶
Index ¶
Constants ¶
View Source
const ( NotifyProductAdded = "ProductAdded" NotifyProductDelete = "ProductDelete" NotifyAddDevice = "AddDevice" NotifyDeleteDevice = "DeleteDevice" NotifyAction = "Action" NotifySerialNet = "SerialNet" NotifyCheckStatus = "CheckStatus" NotifySimulatorSend = "SimulatorSend" NotifyUpgrade = "Upgrade" )
Variables ¶
View Source
var ProviderSet = wire.NewSet(NewIotHubMessage)
Functions ¶
This section is empty.
Types ¶
type CheckStatusHandler ¶
type CheckStatusHandler struct {
// contains filtered or unexported fields
}
func (*CheckStatusHandler) Handle ¶
func (csh *CheckStatusHandler) Handle(downstream *Downstream) error
func (*CheckStatusHandler) NotifyType ¶
func (csh *CheckStatusHandler) NotifyType() string
type Downstream ¶
type DsDeviceActionData ¶
type DsDeviceAddData ¶
type DsSerialNetData ¶
type DsSimulatorSendData ¶
type DsUpgradeData ¶
type DsUpgradeData struct { UpgradeID string Firmsoft *FirmsoftInfo File *os.File SnList []string }
type DsUpgradeInData ¶
type DsUpgradeInData struct { UpgradeID string Firmsoft *FirmsoftInfo SnList []interface{} }
type FirmsoftInfo ¶
type IotHubMessage ¶
type IotHubMessage interface { http.Handler RegisterMessageHandler(handler IotHubMessageHandler) UnregisterMessageHandler(notifyType string) }
func NewIotHubMessage ¶
func NewIotHubMessage(cfg config.Config, log *zap.Logger, request req.Request, dalInfoService service.DalInfoService) IotHubMessage
type IotHubMessageHandler ¶
type IotHubMessageHandler interface { NotifyType() string Handle(downstream *Downstream) error }
func NewCheckStatusHandler ¶
func NewCheckStatusHandler(dalInfoService service.DalInfoService) IotHubMessageHandler
Click to show internal directories.
Click to hide internal directories.