network

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

type DataPublish struct {
	ID   string          `json:"id"`
	Data []entities.Data `json:"data"`
}

type DataRequest struct {
	ID        string `json:"id"`
	SensorIds []int  `json:"sensorIds"`
}

type DataUpdate struct {
	ID   string          `json:"id"`
	Data []entities.Data `json:"data"`
}

type DeviceAuthRequest struct {
	ID    string `json:"id"`
	Token string `json:"token"`
}

type DeviceAuthResponse struct {
	ID    string  `json:"id"`
	Error *string `json:"error"`
}

type DeviceListResponse struct {
	Things []*entities.Thing `json:"devices"`
	Error  *string           `json:"error"`
}

type DeviceRegisterRequest struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type DeviceRegisteredResponse struct {
	ID    string  `json:"id"`
	Token string  `json:"token"`
	Error *string `json:"error"`
}

type DeviceUnregisterRequest struct {
	ID string `json:"id"`
}

type DeviceUnregisteredResponse struct {
	ID    string  `json:"id"`
	Error *string `json:"error"`
}

type InMsg struct {
	Exchange   string
	RoutingKey string
	Headers    map[string]interface{}
	Body       []byte
}

type SchemaUpdateRequest struct {
	ID     string            `json:"id"`
	Schema []entities.Schema `json:"schema,omitempty"`
}

type SchemaUpdatedResponse struct {
	ID    string  `json:"id"`
	Error *string `json:"error"`
}