mq

type AppDlData struct {
	CorrelationID string
	DeviceID      string
	NetworkCode   string
	NetworkAddr   string
	Data          []byte
	Extension     map[string]interface{}
}

type AppDlDataResp struct {
	CorrelationID string `json:"correlationId"`
	DataID        string `json:"dataId"`
	Error         string `json:"error"`
	Message       string `json:"message"`
}

type AppDlDataResult struct {
	DataID  string `json:"dataId"`
	Status  int    `json:"status"`
	Message string `json:"message"`
}

type AppMgrEventHandler interface {
	// Fired when one of the manager's queues encounters a state change.
	OnStatusChange(mgr *ApplicationMgr, status MgrStatus)

	// Fired when a `UlData` data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnUlData(mgr *ApplicationMgr, data *AppUlData) error

	// Fired when a `DlDataResult` data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnDlDataResp(mgr *ApplicationMgr, data *AppDlDataResp) error

	// Fired when a `DlDataResp` data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnDlDataResult(mgr *ApplicationMgr, data *AppDlDataResult) error
}

type AppUlData struct {
	DataID      string
	Time        time.Time
	Pub         time.Time
	DeviceID    string
	NetworkID   string
	NetworkCode string
	NetworkAddr string
	IsPublic    bool
	Data        []byte
	Extension   map[string]interface{}
}

type ApplicationMgr struct {
	// contains filtered or unexported fields
}

type ConnectionPool struct {
	// contains filtered or unexported fields
}

type DataMqStatus struct {
	// For `uldata`.
	UlData gmq.Status
	// For `dldata`.
	DlData gmq.Status
	// For `dldata-resp`.
	DlDataResp gmq.Status
	// For `dldata-result`.
	DlDataResult gmq.Status
	// For `ctrl`.
	Ctrl gmq.Status
}

type MgrStatus int

type NetCtrlAddDevice struct {
	NetworkAddr string `json:"networkAddr"`
}

type NetCtrlAddDeviceBulk struct {
	NetworkAddrs []string `json:"networkAddrs"`
}

type NetCtrlAddDeviceRange struct {
	StartAddr string `json:"startAddr"`
	EndAddr   string `json:"endAddr"`
}

type NetCtrlDelDevice struct {
	NetworkAddr string `json:"networkAddr"`
}

type NetCtrlDelDeviceBulk struct {
	NetworkAddrs []string `json:"networkAddrs"`
}

type NetCtrlDelDeviceRange struct {
	StartAddr string `json:"startAddr"`
	EndAddr   string `json:"endAddr"`
}

type NetDlData struct {
	DataID      string
	Pub         time.Time
	ExpiresIn   int64
	NetworkAddr string
	Data        []byte
	Extension   map[string]interface{}
}

type NetDlDataResult struct {
	DataID  string `json:"dataId"`
	Status  int    `json:"status"`
	Message string `json:"message,omitempty"`
}

type NetMgrEventHandler interface {
	// Fired when one of the manager's queues encounters a state change.
	OnStatusChange(mgr *NetworkMgr, status MgrStatus)

	// Fired when a `DlData` data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnDlData(mgr *NetworkMgr, data *NetDlData) error

	// Fired when a `add-device` control data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnCtrlAddDevice(mgr *NetworkMgr, time time.Time, new *NetCtrlAddDevice) error

	// Fired when a `add-device-bulk` control data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnCtrlAddDeviceBulk(mgr *NetworkMgr, time time.Time, new *NetCtrlAddDeviceBulk) error

	// Fired when a `add-device-range` control data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnCtrlAddDeviceRange(mgr *NetworkMgr, time time.Time, new *NetCtrlAddDeviceRange) error

	// Fired when a `del-device` control data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnCtrlDelDevice(mgr *NetworkMgr, time time.Time, new *NetCtrlDelDevice) error

	// Fired when a `del-device-bulk` control data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnCtrlDelDeviceBulk(mgr *NetworkMgr, time time.Time, new *NetCtrlDelDeviceBulk) error

	// Fired when a `del-device-range` control data is received.
	//
	// Return error will NACK the data.
	// The data may will be received again depending on the protocol (such as AMQP).
	OnCtrlDelDeviceRange(mgr *NetworkMgr, time time.Time, new *NetCtrlDelDeviceRange) error
}

type NetUlData struct {
	Time        time.Time
	NetworkAddr string
	Data        []byte
	Extension   map[string]interface{}
}

type NetworkMgr struct {
	// contains filtered or unexported fields
}

type Options struct {
	// The associated unit ID of the application/network. Empty for public network.
	UnitID string `json:"unitId"`
	// The associated unit code of the application/network. Empty for public network.
	UnitCode string `json:"unitCode"`
	// The associated application/network ID.
	ID string `json:"id"`
	// The associated application/network code.
	Name string `json:"name"`
	// AMQP prefetch option.
	Prefetch uint16 `json:"prefetch"`
	// AMQP persistent option.
	Persistent bool `json:"persistent"`
	// MQTT shared queue prefix option.
	SharedPrefix string `json:"sharedPrefix"`
}