processdeployment

type Config struct {
	ProcessDeploymentUrl         string `json:"process_deployment_url"`
	FogProcessDeploymentUrl      string `json:"fog_process_deployment_url"`
	FogProcessSyncUrl            string `json:"fog_process_sync_url"`
	DeviceRepositoryUrl          string `json:"device_repository_url"`
	AllowMsgEventsInFogProcesses bool   `json:"allow_msg_events_in_fog_processes"`
	AllowImportsInFogProcesses   bool   `json:"allow_imports_in_fog_processes"`
	ProcessDeploymentSource      string `json:"process_deployment_source"`
	WorkerParamPrefix            string `json:"worker_param_prefix"`
	KafkaUrl                     string `json:"kafka_url"`
	KafkaConsumerGroup           string `json:"kafka_consumer_group"`
	ProcessDeploymentDoneTopic   string `json:"process_deployment_done_topic"`
	InitTopics                   bool   `json:"init_topics"`
}

type DeviceGroup struct {
	Id        string   `json:"id"`
	Name      string   `json:"name"`
	DeviceIds []string `json:"device_ids"`
}

type DoneNotification struct {
	Command string `json:"command"`
	Id      string `json:"id"`
	Handler string `json:"handler"`
}

type Hub struct {
	Id             string   `json:"id"`
	Name           string   `json:"name"`
	DeviceLocalIds []string `json:"device_local_ids"`
	DeviceIds      []string `json:"device_ids"`
}

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

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
	UseModuleDeleteInfo(info model.ModuleDeleteInfo) error
}