common

type BuildError struct {
	Inner error
}

type Docker struct {
	DNS             []string       `toml:"dns,omitempty" json:"dns" long:"dns" env:"DOCKER_DNS" description:"A list of DNS servers for the container to use"`
	DockerWorkspace string         `toml:"workspace"`
	Privileged      bool           `` /* 138-byte string literal not displayed */
	Volumes         []DockerVolume `` /* 284-byte string literal not displayed */
}

type DockerVolume struct {
	Name     string `toml:"name"`
	Source   string `toml:"source"`
	Target   string `toml:"target"`
	ReadOnly bool   `toml:"read_only"`
}

type Execution struct {
	Language    string   `json:"language"`
	PackagePath string   `json:"package_path"`
	Demands     []string `json:"demands"`
	Artifacts   []string `json:"artifacts,omitempty"`
	Target      string   `json:"target"`
}

type Executor interface {
	Prepare(job Job) error
	Run() error
	Wait() error
	SendError(err error)
	Cleanup() error
}

type ExecutorProvider interface {
	CanCreate() bool
	Create() Executor
}

type FailuresCollector interface {
	RecordFailure(reason JobFailureReason, runnerDescription string)
}

type GitConfig struct {
	Name     string `toml:"name"`
	Password string `toml:"password"`
}

type Image struct {
	Name       string   `json:"name"`
	Alias      string   `json:"alias,omitempty"`
	Command    []string `json:"command,omitempty"`
	Entrypoint []string `json:"entrypoint,omitempty"`
}

type Job struct {
	Runner RunnerConfig
	JobResponse
	Trace   JobTrace
	JobName string
}

type JobCredentials struct {
	ID         string
	Token      string
	Pipeline   string
	StageIndex int
	JobIndex   int
}

type JobFailureReason string // job 失败的原因(系统级别简要分析)

type JobInfo struct {
	Pipeline       string       `json:"pipeline"`
	PipelineNumber int          `json:"pipeline_number"`
	ProjectID      int          `json:"project_id"`
	Stage          string       `json:"stage"`
	StageIndex     int          `json:"stage_index"`
	JobName        string       `json:"job_name"`
	JobNumber      int          `json:"job_number"`
	JobIndex       int          `json:"job_index"`
	Timestamp      int64        `json:"timestamp"`
	Image          Image        `json:"image"`
	Services       Services     `json:"services,omitempty"`
	Volumes        []Volume     `json:"volumes,omitempty"`
	Variables      JobVariables `json:"variables,omitempty"`
	Plugins        Plugins      `json:"plugins"`
	Timeout        int32        `json:"timeout,omitempty"`
}

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

type JobRequest struct {
	Info  VersionInfo `json:"info,omitempty"`
	Token string      `json:"token,omitempty"`
}

type JobResponse struct {
	ID      string  `json:"id"`
	Token   string  `json:"token"`
	JobInfo JobInfo `json:"job_info"`
}

type JobResultRequest struct {
	Info    VersionInfo `json:"info,omitempty"`
	Token   string      `json:"token,omitempty"`
	JobInfo JobInfo     `json:"job_info"`
	Data    ResultData  `json:"result_data"`
}

type JobState string // job 状态标识

type JobTrace interface {
	io.Writer
	Success()
	Fail(err error, failureReason JobFailureReason)
	SetCancelFunc(cancelFunc context.CancelFunc)
	SetFailuresCollector(fc FailuresCollector)
	SetMasked(values []string)
	IsStdout() bool
}

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

type JobVariables []JobVariable

type KafkaConfig struct {
	Read   Read   `toml:"read"`
	Writer Writer `toml:"writer"`
}

type Kubernetes struct {
	Config      string   `toml:"config,omitempty"`
	Namespace   string   `toml:"namespace,omitempty"`
	DNS         []string `toml:"dns,omitempty"`
	HelperImage string   `toml:"helper_image,omitempty"`
}

type MinioConfig struct {
	URL             string `toml:"url"`
	ArtifactsBucket string `toml:"artifacts_bucket"`
	PluginsBucket   string `toml:"plugins_bucket"`
	LogsBucket      string `toml:"logs_bucket"`
	AccessKey       string `toml:"access_key"`
	SecretKey       string `toml:"secret_key"`
}

type PluginInfo struct {
	PluginName    string       `json:"plugin_name"`
	PluginMd5     string       `json:"plugin_md5"`
	PluginVersion string       `json:"plugin_version"`
	PluginAuthor  string       `json:"plugin_author"`
	Execution     Execution    `json:"execution"`
	Variables     JobVariables `json:"variables,omitempty"`
}

type PluginRequest struct {
	Pipeline    string `json:"pipeline"`
	StageIndex  int    `json:"stage_index"`
	JobIndex    int    `json:"job_index"`
	PluginIndex int    `json:"plugin_index"` // 该job 的 plugin 下标
	Token       string `json:"job_token"`    // job 的 token

}

type PluginResponse struct {
	ID         int        `json:"id"`
	Token      string     `json:"token"`
	PluginInfo PluginInfo `json:"plugin_info"`
}

type Plugins struct {
	Count int `json:"count"`
}

type Read struct {
	BrokerList string `toml:"brokerList"`
	Topic      string `toml:"topic"`
	GroupID    string `toml:"groupID"`
}

type ResultData struct {
	Status      string `json:"status"`
	Code        string `json:"code"`
	Message     string `json:"message"`
	MinioLogURL string `json:"minio_log_url"`
}

type RunnerConfig struct {
	Name          string      `toml:"name"`
	Executor      string      `toml:"executor"`
	Concurrent    int         `toml:"concurrent"`
	OutputLimit   int         `` /* 126-byte string literal not displayed */
	LogLevel      string      `toml:"log_level"`
	Log           string      `toml:"log"`
	TempLogDir    string      `toml:"temp_log_dir"`
	ListenAddress string      `toml:"listen_address,omitempty" json:"listen_address"`
	KafkaConfig   KafkaConfig `toml:"kafka"`
	Kubernetes    Kubernetes  `toml:"kubernetes"`
	MinioConfig   MinioConfig `toml:"minio"`
	Docker        Docker      `toml:"docker"`
	GitConfig     GitConfig   `toml:"git"`
	RunnerCredentials
}

type RunnerCredentials struct {
	URL   string `toml:"url" json:"url" short:"u" long:"url" env:"CI_SERVER_URL" required:"true" description:"Runner URL"`
	Token string `toml:"token" json:"token" short:"t" long:"token" env:"CI_SERVER_TOKEN" required:"true" description:"Runner token"`
}

type Services []Image

type UpdateJobInfo struct {
	ID            string
	State         JobState
	FailureReason JobFailureReason
}

type UpdateJobRequest struct {
	Info          VersionInfo      `json:"info,omitempty"`
	Token         string           `json:"token,omitempty"`
	State         JobState         `json:"state,omitempty"`
	FailureReason JobFailureReason `json:"failure_reason,omitempty"`
}

type UpdateState int // 日志内容上传的状态标识

type VersionInfo struct {
	Name         string `json:"name,omitempty"`
	Version      string `json:"version,omitempty"`
	Revision     string `json:"revision,omitempty"`
	Platform     string `json:"platform,omitempty"`
	Architecture string `json:"architecture,omitempty"`
	Executor     string `json:"executor,omitempty"`
}

type Volume struct {
	Name      string `json:"name"`
	MountPath string `json:"mount_path"`
	ReadOnly  bool   `json:"read_only"`
	HostPath  string `json:"host_path"`
}

type Writer struct {
	BrokerList string `toml:"brokerList"`
	Topic      string `toml:"topic"`
}