workerruntime

type CDSVersionSet struct {
	Value string `json:"value"`
}

type DownloadArtifact struct {
	Workflow    string `json:"workflow"`
	Number      int64  `json:"number"`
	Pattern     string `json:"pattern" cli:"pattern"`
	Tag         string `json:"tag" cli:"tag"`
	Destination string `json:"destination"`
}

type FilePath struct {
	Path string `json:"path"`
}

type KeyResponse struct {
	PKey    string      `json:"pkey"`
	Type    sdk.KeyType `json:"type"`
	Content []byte      `json:"-"`
}

type Level string

type OutputRequest struct {
	Name             string `json:"name"`
	Value            string `json:"value"`
	StepOnly         bool   `json:"step_only"`
	WorkflowRunID    string `json:"workflow_run_id"`
	WorkflowRunJobID string `json:"workflow_run_job_id"`
}

type Runtime interface {
	Name() string
	Register(ctx context.Context) error
	Take(ctx context.Context, job sdk.WorkflowNodeJobRun) error
	ProcessJob(job sdk.WorkflowNodeJobRunData) sdk.Result
	SendLog(ctx context.Context, level Level, format string)
	RunResultSignature(fileName string, perm uint32, t sdk.WorkflowRunResultType) (string, error)
	WorkerCacheSignature(tag string) (string, error)
	FeatureEnabled(featureName sdk.FeatureName) bool
	GetIntegrationPlugin(pluginType string) *sdk.GRPCPlugin
	GetActionPlugin(pluginName string) *sdk.GRPCPlugin
	SetActionPlugin(p *sdk.GRPCPlugin)
	GetJobIdentifiers() (int64, int64, int64)
	CDNHttpURL() string
	InstallKey(key sdk.Variable) (*KeyResponse, error)
	InstallKeyTo(key sdk.Variable, destinationPath string) (*KeyResponse, error)
	Unregister(ctx context.Context) error
	Client() cdsclient.WorkerInterface
	ClientV2() cdsclient.V2WorkerInterface
	BaseDir() afero.Fs
	Environ() []string
	Blur(interface{}) error
	HTTPPort() int32
	Parameters() []sdk.Parameter
	PluginGet(pluginName string) (*sdk.GRPCPlugin, error)
	PluginGetBinary(name, os, arch string, w io.Writer) error

	V2AddRunResult(ctx context.Context, req V2RunResultRequest) (*V2AddResultResponse, error)
	V2UpdateRunResult(ctx context.Context, req V2RunResultRequest) (*V2UpdateResultResponse, error)
	AddStepOutput(ctx context.Context, outputName string, outputValue string)
	V2GetRunResult(ctx context.Context, filter V2FilterRunResult) (*V2GetResultResponse, error)
	V2GetIntegrationByName(ctx context.Context, name string) (*sdk.ProjectIntegration, error)
	V2GetJobRun(ctx context.Context) *sdk.V2WorkflowRunJob
	V2GetJobContext(ctx context.Context) *sdk.WorkflowRunJobsContext
}

type TmplPath struct {
	Path        string `json:"path"`
	Destination string `json:"destination"`
}

type UploadArtifact struct {
	Name             string `json:"name"`
	Tag              string `json:"tag"`
	WorkingDirectory string `json:"working_directory"`
}

type V2AddResultResponse struct {
	RunResult    *sdk.V2WorkflowRunResult
	CDNSignature string
	CDNAddress   string
}

type V2FilterRunResult struct {
	Pattern string
	Type    []sdk.V2WorkflowRunResultType
}

type V2GetResultResponse struct {
	RunResults   []sdk.V2WorkflowRunResult
	CDNSignature string
}

type V2RunResultRequest struct {
	RunResult   *sdk.V2WorkflowRunResult
	CDNItemLink sdk.CDNItemLink // TODO
}

type V2UpdateResultResponse struct {
	RunResult *sdk.V2WorkflowRunResult
}

type WorkerConfig struct {
	Name                     string            `json:"name"`
	Basedir                  string            `json:"basedir"`
	Log                      cdslog.Conf       `json:"log"`
	HatcheryName             string            `json:"hatchery_name"`
	APIEndpoint              string            `json:"api_endpoint"`
	APIEndpointInsecure      bool              `json:"api_endpoint_insecure,omitempty"`
	APIToken                 string            `json:"api_token"`
	CDNEndpoint              string            `json:"cdn_endpoint"`
	GelfServiceAddr          string            `json:"gelf_service_addr"`
	GelfServiceAddrEnableTLS bool              `json:"gelf_service_addr_enable_tls,omitempty"`
	Model                    string            `json:"model"`
	BookedJobID              int64             `json:"booked_job_id,omitempty"`
	RunJobID                 string            `json:"run_job_id,omitempty"`
	Region                   string            `json:"region,omitempty"`
	InjectEnvVars            map[string]string `json:"inject_env_vars,omitempty"`
}