_type

type AddTaskRequest struct {
	Name   string   `json:"mission_name" binding:"required"`
	ParStr TaskData `json:"params" binding:"required"`
	Cron   string   `json:"cron" binding:"required"`
}

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

type DeleteDataSourceRequest struct {
	Id string `json:"id" binding:"required"`
}

type DeleteFileRequest struct {
	ID string `json:"id" binding:"required"`
}

type DeleteTaskRequest struct {
	Id string `json:"id" binding:"required"`
}

type DeleteVariableRequest struct {
	Id string `json:"id" binding:"required"`
}

type GetDataSourceTypeListResponse struct {
	Type   string           `json:"type"`
	Params []params2.Params `json:"params"`
}

type GetDatasourceParamsByTypeRequest struct {
	Type string `json:"type" binding:"required"`
}

type GetFileListRequest struct {
	PageSize int `json:"page_size"`
	PageNo   int `json:"page_no"`
}

type GetTaskByIdRequest struct {
	Id string `json:"id" binding:"required"`
}

type GetTaskRecordListRequest struct {
	PageNo      int    `json:"page_no"`
	PageSize    int    `json:"page_size"`
	MissionName string `json:"mission_name"`
	Status      int    `json:"status"`
	ID          string `json:"id"`
}

type GetTypeByComponentResponse struct {
	Executor  []TypeDataSource   `json:"executor"`
	Source    []TypeDataSource   `json:"source"`
	Processor []TypeNoDataSource `json:"processor"`
	Sink      []TypeDataSource   `json:"sink"`
}

type GetVariableTypeListResponse struct {
	Type           string           `json:"type"`
	Params         []params2.Params `json:"params"`
	DatasourceList *[]struct {
		Name string
		ID   string
	} `json:"datasource_list"`
}

type KeyValue struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type KeyValues []KeyValue

type LoginRequest struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

type LoginResponse struct {
	Token string `json:"token"`
}

type LoginWithCodeRequest struct {
	Username string `json:"username"`
	Password string `json:"password"`
	Code     string `json:"code"`
}

type Mission struct {
	Spec string
	Func func() error
}

type MissionLog struct {
	Name string
	Spec string
}

type NewDataSourceRequest struct {
	ID   string    `json:"id"`
	Name string    `json:"name" binding:"required"`
	Type string    `json:"type" binding:"required"`
	Data KeyValues `json:"data" binding:"required"`
	Edit string    `json:"edit" binding:"required"`
}

type NewVariableRequest struct {
	ID           string    `json:"id"`
	Type         string    `json:"type"`
	DataSourceID *string   `json:"datasource_id" binding:"required"`
	Name         string    `json:"name" binding:"required"`
	Description  string    `json:"description" binding:"required"`
	Value        KeyValues `json:"value" binding:"required"`
	Edit         string    `json:"edit" binding:"required"`
}

type RequestLog struct {
	Method   string            `json:"method"`
	Ip       string            `json:"ip"`
	Path     string            `json:"path"`
	Body     string            `json:"body"`
	Headers  map[string]string `json:"headers"`
	Response *ResponseModel    `json:"response"`
}

type ResponseModel struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type ResponseWithData struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data"`
}

type RunTaskOnceRequest struct {
	Id string `json:"id" binding:"required"`
}

type RunTaskRequest struct {
	Id string `json:"id" binding:"required"`
}

type StopTaskRequest struct {
	Id string `json:"id" binding:"required"`
}

type TaskData struct {
	BeforeExecute *struct {
		Type       string  `json:"type"`
		DataSource *string `json:"data_source"`
		Params     []struct {
			Key   string `json:"key"`
			Value string `json:"value"`
		} `json:"params"`
	} `json:"before_execute"`
	Source struct {
		Type       string  `json:"type"`
		DataSource *string `json:"data_source"`
		Params     []struct {
			Key   string `json:"key"`
			Value string `json:"value"`
		} `json:"params"`
	} `json:"source"`
	Processors []struct {
		Type   string `json:"type"`
		Params []struct {
			Key   string `json:"key"`
			Value string `json:"value"`
		} `json:"params"`
	} `json:"processors"`
	Sinks struct {
		Type       string  `json:"type"`
		DataSource *string `json:"data_source"`
		Params     []struct {
			Key   string `json:"key"`
			Value string `json:"value"`
		} `json:"params"`
	} `json:"sink"`
	AfterExecute *struct {
		Type       string  `json:"type"`
		DataSource *string `json:"data_source"`
		Params     []struct {
			Key   string `json:"key"`
			Value string `json:"value"`
		} `json:"params"`
	} `json:"after_execute"`
}

type TestVariableRequest struct {
	Id string `json:"id" binding:"required"`
}

type TypeDataSource struct {
	Type       string `json:"type"`
	DataSource *[]struct {
		Name string `json:"name"`
		ID   string `json:"id"`
	} `json:"data_source"`
	Params []params.Params `json:"params"`
}

type TypeNoDataSource struct {
	Type   string          `json:"type"`
	Params []params.Params `json:"params"`
}

type UpdateTaskRequest struct {
	Id     string   `json:"id" binding:"required"`
	Name   string   `json:"mission_name" binding:"required"`
	ParStr TaskData `json:"params" binding:"required"`
	Cron   string   `json:"cron" binding:"required"`
}

type UploadFileRequest struct {
	File multipart.FileHeader `form:"file"`
}