exector

type AppSnapshot struct {
	Services            []*RegionServiceSnapshot
	Plugins             []*dbmodel.TenantEnvPlugin
	PluginBuildVersions []*dbmodel.TenantEnvPluginBuildVersion
}

type BackupAPPNew struct {
	WithImageData bool     `json:"with_image_data"`
	GroupID       string   `json:"group_id" `
	ServiceIDs    []string `json:"service_ids" `
	Version       string   `json:"version"`
	EventID       string
	SourceDir     string `json:"source_dir"`
	SourceType    string `json:"source_type"`
	BackupID      string `json:"backup_id"`
	BackupSize    int64
	Logger        event.Logger
	ImageClient   sources.ImageClient

	//full-online,full-offline
	Mode     string `json:"mode"`
	S3Config struct {
		Provider   string `json:"provider"`
		Endpoint   string `json:"endpoint"`
		AccessKey  string `json:"access_key"`
		SecretKey  string `json:"secret_key"`
		BucketName string `json:"bucket_name"`
	} `json:"s3_config"`
}

type BackupAPPRestore struct {
	//full-online,full-offline
	EventID     string
	BackupID    string `json:"backup_id"`
	TenantEnvID string `json:"tenant_env_id"`
	Logger      event.Logger
	//RestoreMode(cdct) current datacenter and current tenantEnv
	//RestoreMode(cdot) current datacenter and other tenantEnv
	//RestoreMode(od)     other datacenter
	RestoreMode string `json:"restore_mode"`
	RestoreID   string `json:"restore_id"`
	ImageClient sources.ImageClient

	S3Config struct {
		Provider   string `json:"provider"`
		Endpoint   string `json:"endpoint"`
		AccessKey  string `json:"access_key"`
		SecretKey  string `json:"secret_key"`
		BucketName string `json:"bucket_name"`
	} `json:"s3_config"`
	// contains filtered or unexported fields
}

type Commit struct {
	Hash    string
	Author  string
	Message string
}

type Error struct {
	Code    uint   `json:"code"`
	Msg     string `json:"msg"`
	Details string `json:"details,omitempty"`
}

type ExportApp struct {
	EventID       string `json:"event_id"`
	Format        string `json:"format"`
	SourceDir     string `json:"source_dir"`
	WithImageData bool   `json:"with_image_data"`
	Logger        event.Logger
	ImageClient   sources.ImageClient
}

type GarbageCollectionItem struct {
	TenantEnvID string        `json:"tenant_env_id"`
	ServiceID   string        `json:"service_id"`
	EventIDs    []string      `json:"event_ids"`
	Cfg         option.Config `json:"-"`
}

type ImageBuildItem struct {
	Namespace     string       `json:"namespace"`
	TenantEnvName string       `json:"tenant_env_name"`
	ServiceAlias  string       `json:"service_alias"`
	Image         string       `json:"image"`
	DestImage     string       `json:"dest_image"`
	Logger        event.Logger `json:"logger"`
	EventID       string       `json:"event_id"`
	ImageClient   sources.ImageClient
	TenantEnvID   string
	ServiceID     string
	DeployVersion string
	HubUser       string
	HubPassword   string
	Action        string
	Configs       map[string]gjson.Result `json:"configs"`
	Operator      string                  `json:"operator"`
}

type ImageShareItem struct {
	Namespace          string `json:"namespace"`
	TenantEnvName      string `json:"tenant_env_name"`
	ServiceID          string `json:"service_id"`
	ServiceAlias       string `json:"service_alias"`
	ImageName          string `json:"image_name"`
	LocalImageName     string `json:"local_image_name"`
	LocalImageUsername string `json:"-"`
	LocalImagePassword string `json:"-"`
	ShareID            string `json:"share_id"`
	Logger             event.Logger
	ShareInfo          struct {
		ServiceKey string `json:"service_key" `
		AppVersion string `json:"app_version" `
		EventID    string `json:"event_id"`
		ShareUser  string `json:"share_user"`
		ShareScope string `json:"share_scope"`
		ImageInfo  struct {
			HubURL      string `json:"hub_url"`
			HubUser     string `json:"hub_user"`
			HubPassword string `json:"hub_password"`
			Namespace   string `json:"namespace"`
			IsTrust     bool   `json:"is_trust,omitempty"`
		} `json:"image_info,omitempty"`
	} `json:"share_info"`
	ImageClient sources.ImageClient
	EtcdCli     *clientv3.Client
}

type ImportApp struct {
	EventID      string             `json:"event_id"`
	Format       string             `json:"format"`
	SourceDir    string             `json:"source_dir"`
	Apps         []string           `json:"apps"`
	ServiceImage model.ServiceImage `json:"service_image"`
	Logger       event.Logger

	// ContainerdCli export.ContainerdAPI
	ImageClient sources.ImageClient
	// contains filtered or unexported fields
}

type Info struct {
	ServiceID    string
	ServiceAlias string
	Status       string
	LBPorts      map[int]int
}

type Manager interface {
	GetMaxConcurrentTask() float64
	GetCurrentConcurrentTask() float64
	AddTask(*pb.TaskMessage) error
	SetReturnTaskChan(func(*pb.TaskMessage))
	Start() error
	Stop() error
	GetImageClient() sources.ImageClient
}

type MarketSlugItem struct {
	TenantEnvName string       `json:"tenant_env_name"`
	ServiceAlias  string       `json:"service_alias"`
	Logger        event.Logger `json:"logger"`
	EventID       string       `json:"event_id"`
	Operator      string       `json:"operator"`
	DeployVersion string       `json:"deploy_version"`
	TenantEnvID   string       `json:"tenant_env_id"`
	ServiceID     string       `json:"service_id"`
	Action        string       `json:"action"`
	TGZPath       string
	Configs       map[string]string `json:"configs"`
	SlugInfo      struct {
		SlugPath    string `json:"slug_path"`
		FTPHost     string `json:"ftp_host"`
		FTPPort     string `json:"ftp_port"`
		FTPUser     string `json:"ftp_username"`
		FTPPassword string `json:"ftp_password"`
	} `json:"slug_info"`
}

type PluginShareItem struct {
	EventID        string `json:"event_id"`
	ImageName      string `json:"image_name"`
	LocalImageName string `json:"local_image_name"`
	ShareID        string `json:"share_id"`
	Logger         event.Logger
	ImageInfo      struct {
		HubURL      string `json:"hub_url"`
		HubUser     string `json:"hub_user"`
		HubPassword string `json:"hub_password"`
		Namespace   string `json:"namespace"`
		IsTrust     bool   `json:"is_trust,omitempty"`
	} `json:"image_info,omitempty"`
	ImageClient sources.ImageClient
	EtcdCli     *clientv3.Client
}

type RegionServiceSnapshot struct {
	ServiceID                    string
	Service                      *dbmodel.TenantEnvServices
	ServiceProbe                 []*dbmodel.TenantEnvServiceProbe
	LBMappingPort                []*dbmodel.TenantEnvServiceLBMappingPort
	ServiceEnv                   []*dbmodel.TenantEnvServiceEnvVar
	ServiceLabel                 []*dbmodel.TenantEnvServiceLabel
	ServiceSchedulingLabels      []*dbmodel.TenantEnvServiceSchedulingLabel
	ServiceSchedulingTolerations []*dbmodel.TenantEnvServiceSchedulingToleration
	ServiceMntRelation           []*dbmodel.TenantEnvServiceMountRelation
	ServiceRelation              []*dbmodel.TenantEnvServiceRelation
	ServiceStatus                string
	ServiceVolume                []*dbmodel.TenantEnvServiceVolume
	ServiceConfigFile            []*dbmodel.TenantEnvServiceConfigFile
	ServicePort                  []*dbmodel.TenantEnvServicesPort
	Versions                     []*dbmodel.VersionInfo

	PluginRelation    []*dbmodel.TenantEnvServicePluginRelation
	PluginConfigs     []*dbmodel.TenantEnvPluginVersionDiscoverConfig
	PluginEnvs        []*dbmodel.TenantEnvPluginVersionEnv
	PluginStreamPorts []*dbmodel.TenantEnvServicesStreamPluginPort
}

type RestoreResult struct {
	Status        string           `json:"status"`
	Message       string           `json:"message"`
	CreateTime    time.Time        `json:"create_time"`
	ServiceChange map[string]*Info `json:"service_change"`
	BackupID      string           `json:"backup_id"`
	RestoreMode   string           `json:"restore_mode"`
	EventID       string           `json:"event_id"`
	RestoreID     string           `json:"restore_id"`
	CacheDir      string           `json:"cache_dir"`
}

type ServiceCheckInput struct {
	CheckUUID string `json:"uuid"`
	//检测来源类型
	SourceType string `json:"source_type"`

	// 检测来源定义，
	// 代码： https://github.com/shurcooL/githubql.git master
	// docker-run: docker run --name xxx nginx:latest nginx
	// docker-compose: compose全文
	SourceBody  string `json:"source_body"`
	Username    string `json:"username"`
	Password    string `json:"password"`
	TenantEnvID string
	EventID     string `json:"event_id"`
}

type ServiceCheckResult struct {
	//检测状态 Success Failure
	CheckStatus string                `json:"check_status"`
	ErrorInfos  parser.ParseErrorList `json:"error_infos"`
	ServiceInfo []parser.ServiceInfo  `json:"service_info"`
}

type ShareStatus struct {
	ShareID string `json:"share_id,omitempty"`
	Status  string `json:"status,omitempty"`
}

type SlugShareItem struct {
	Namespace     string `json:"namespace"`
	TenantEnvName string `json:"tenant_env_name"`
	ServiceID     string `json:"service_id"`
	ServiceAlias  string `json:"service_alias"`
	SlugPath      string `json:"slug_path"`
	LocalSlugPath string `json:"local_slug_path"`
	ShareID       string `json:"share_id"`
	Logger        event.Logger
	ShareInfo     struct {
		ServiceKey string `json:"service_key" `
		AppVersion string `json:"app_version" `
		EventID    string `json:"event_id"`
		ShareUser  string `json:"share_user"`
		ShareScope string `json:"share_scope"`
		SlugInfo   struct {
			Namespace   string `json:"namespace"`
			FTPHost     string `json:"ftp_host"`
			FTPPort     string `json:"ftp_port"`
			FTPUser     string `json:"ftp_username"`
			FTPPassword string `json:"ftp_password"`
		} `json:"slug_info,omitempty"`
	} `json:"share_info"`
	EtcdCli     *clientv3.Client
	PackageName string
}

type SourceCodeBuildItem struct {
	Namespace     string       `json:"namespace"`
	TenantEnvName string       `json:"tenant_env_name"`
	WTDataPVCName string       `json:"gr_data_pvc_name"`
	CachePVCName  string       `json:"cache_pvc_name"`
	CacheMode     string       `json:"cache_mode"`
	CachePath     string       `json:"cache_path"`
	ServiceAlias  string       `json:"service_alias"`
	Action        string       `json:"action"`
	DestImage     string       `json:"dest_image"`
	Logger        event.Logger `json:"logger"`
	EventID       string       `json:"event_id"`
	CacheDir      string       `json:"cache_dir"`
	TGZDir        string       `json:"tgz_dir"`
	ImageClient   sources.ImageClient
	KanikoImage   string
	KubeClient    kubernetes.Interface
	WtNamespace   string
	WtRepoName    string
	TenantEnvID   string
	ServiceID     string
	DeployVersion string
	Lang          string
	Runtime       string
	BuildEnvs     map[string]string
	CodeSouceInfo sources.CodeSourceInfo
	RepoInfo      *sources.RepostoryBuildInfo

	Configs  map[string]gjson.Result `json:"configs"`
	Ctx      context.Context
	Operator string `json:"operator"`
	// contains filtered or unexported fields
}

type TaskWorker interface {
	Run(timeout time.Duration) error
	GetLogger() event.Logger
	Name() string
	Stop() error
	//ErrorCallBack if run error will callback
	ErrorCallBack(err error)
}

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