workerruntime

package

Go to main page

Versions in this module

v0

v0.56.0

Sep 4, 2025

v0.55.2

May 7, 2025

v0.55.1

Feb 17, 2025

v0.55.0

Jan 6, 2025

Changes in this version

+ func V2_cacheLinkHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_cacheSignatureHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_projectKeyHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_runResultsSynchronizeHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_workerConfig(ctx context.Context, wk Runtime) http.HandlerFunc

+ type CDNSignature struct

+ CDNAddress string

+ Signature string

type Runtime

+ V2GetCacheLink func(ctx context.Context, cacheKey string) (*sdk.CDNItemLinks, error)

+ V2GetCacheSignature func(ctx context.Context, cacheKey string) (*CDNSignature, error)

+ V2GetProjectKey func(ctx context.Context, keyName string, clear bool) (*sdk.ProjectKey, error)

+ V2RunResultsSynchronize func(ctx context.Context) error

+ type V2WorkerConfig struct

+ CDNEndpoint string

v0.54.1

Mar 29, 2024

v0.54.0

Mar 28, 2024

v0.53.1

Mar 26, 2024

Changes in this version

+ func IsReadinessServices(ctx context.Context) (bool, error)

+ func SetIsReadinessServices(ctx context.Context, i bool) context.Context

+ func V2_contextHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_integrationsHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_jobRunHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_outputHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ func V2_runResultHandler(ctx context.Context, wk Runtime) http.HandlerFunc

+ type OutputRequest struct

+ Name string

+ StepOnly bool

+ Value string

+ WorkflowRunID string

+ WorkflowRunJobID string

type Runtime

+ AddStepOutput func(ctx context.Context, outputName string, outputValue string)

+ V2AddRunResult func(ctx context.Context, req V2RunResultRequest) (*V2AddResultResponse, error)

+ V2GetIntegrationByName func(ctx context.Context, name string) (*sdk.ProjectIntegration, error)

+ V2GetJobContext func(ctx context.Context) *sdk.WorkflowRunJobsContext

+ V2GetJobRun func(ctx context.Context) *sdk.V2WorkflowRunJob

+ V2GetRunResult func(ctx context.Context, filter V2FilterRunResult) (*V2GetResultResponse, error)

+ V2UpdateRunResult func(ctx context.Context, req V2RunResultRequest) (*V2UpdateResultResponse, error)

+ type V2AddResultResponse struct

+ CDNAddress string

+ CDNSignature string

+ RunResult *sdk.V2WorkflowRunResult

+ type V2FilterRunResult struct

+ Pattern string

+ Type []sdk.V2WorkflowRunResultType

+ type V2GetResultResponse struct

+ CDNSignature string

+ RunResults []sdk.V2WorkflowRunResult

+ type V2RunResultRequest struct

+ CDNItemLink sdk.CDNItemLink

+ RunResult *sdk.V2WorkflowRunResult

+ type V2UpdateResultResponse struct

+ RunResult *sdk.V2WorkflowRunResult

v0.53.0

Sep 4, 2023

Changes in this version

+ func RunJobID(ctx context.Context) string

+ func SetRunJobID(ctx context.Context, i string) context.Context

type Runtime

+ ClientV2 func() cdsclient.V2WorkerInterface

+ GetActionPlugin func(pluginName string) *sdk.GRPCPlugin

+ GetIntegrationPlugin func(pluginType string) *sdk.GRPCPlugin

+ PluginGet func(pluginName string) (*sdk.GRPCPlugin, error)

+ PluginGetBinary func(name, os, arch string, w io.Writer) error

+ SetActionPlugin func(p *sdk.GRPCPlugin)

type WorkerConfig

+ RunJobID string

v0.52.0

Sep 26, 2022

Changes in this version

type WorkerConfig

+ CDNEndpoint string

+ GelfServiceAddr string

+ GelfServiceAddrEnableTLS bool

v0.50.0

Dec 14, 2021

Changes in this version

+ func JobID(ctx context.Context) (int64, error)

+ func KeysDirectory(ctx context.Context) (afero.File, error)

+ func SetJobID(ctx context.Context, i int64) context.Context

+ func SetKeysDirectory(ctx context.Context, s afero.File) context.Context

+ func SetStepName(ctx context.Context, name string) context.Context

+ func SetStepOrder(ctx context.Context, i int) context.Context

+ func SetTmpDirectory(ctx context.Context, s afero.File) context.Context

+ func SetWorkingDirectory(ctx context.Context, s afero.File) context.Context

+ func StepName(ctx context.Context) (string, error)

+ func StepOrder(ctx context.Context) (int, error)

+ func TmpDirectory(ctx context.Context) (afero.File, error)

+ func WorkingDirectory(ctx context.Context) (afero.File, error)

+ type CDSVersionSet struct

+ Value string

+ type DownloadArtifact struct

+ Destination string

+ Number int64

+ Pattern string

+ Tag string

+ Workflow string

+ type FilePath struct

+ Path string

+ type KeyResponse struct

+ Content []byte

+ PKey string

+ Type sdk.KeyType

+ type Level string

+ const LevelDebug

+ const LevelError

+ const LevelInfo

+ const LevelWarn

+ type Runtime interface

+ BaseDir func() afero.Fs

+ Blur func(interface{}) error

+ CDNHttpURL func() string

+ Client func() cdsclient.WorkerInterface

+ Environ func() []string

+ FeatureEnabled func(featureName sdk.FeatureName) bool

+ GetJobIdentifiers func() (int64, int64, int64)

+ GetPlugin func(pluginType string) *sdk.GRPCPlugin

+ HTTPPort func() int32

+ InstallKey func(key sdk.Variable) (*KeyResponse, error)

+ InstallKeyTo func(key sdk.Variable, destinationPath string) (*KeyResponse, error)

+ Name func() string

+ Parameters func() []sdk.Parameter

+ ProcessJob func(job sdk.WorkflowNodeJobRunData) sdk.Result

+ Register func(ctx context.Context) error

+ RunResultSignature func(fileName string, perm uint32, t sdk.WorkflowRunResultType) (string, error)

+ SendLog func(ctx context.Context, level Level, format string)

+ Take func(ctx context.Context, job sdk.WorkflowNodeJobRun) error

+ Unregister func(ctx context.Context) error

+ WorkerCacheSignature func(tag string) (string, error)

+ type TmplPath struct

+ Destination string

+ Path string

+ type UploadArtifact struct

+ Name string

+ Tag string

+ WorkingDirectory string

+ type WorkerConfig struct

+ APIEndpoint string

+ APIEndpointInsecure bool

+ APIToken string

+ Basedir string

+ BookedJobID int64

+ HatcheryName string

+ InjectEnvVars map[string]string

+ Log cdslog.Conf

+ Model string

+ Name string

+ Region string

+ func (cfg WorkerConfig) EncodeBase64() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL