Documentation
¶
Index ¶
- func ConvertDefaults(jobDefaults []protocol.TemplateToken) (model.Defaults, error)
- func ConvertEnvironment(environmentVariables []protocol.TemplateToken) (map[string]string, error)
- func ConvertMatrixInstance(contextData map[string]protocol.PipelineContextData) (map[string]interface{}, error)
- func ConvertServiceContainer(jobServiceContainers *protocol.TemplateToken) (map[string]*model.ContainerSpec, error)
- func ConvertSteps(jobSteps []protocol.ActionStep) ([]*model.Step, error)
- func ExecWorker(rqt *protocol.AgentJobRequestMessage, wc actionsrunner.WorkerContext)
- type ActRunner
- type ActionCacheBase
- type JobLoggerFactory
- type LaunchActionCache
- type VssActionCache
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertDefaults ¶
func ConvertDefaults(jobDefaults []protocol.TemplateToken) (model.Defaults, error)
func ConvertEnvironment ¶
func ConvertEnvironment(environmentVariables []protocol.TemplateToken) (map[string]string, error)
func ConvertMatrixInstance ¶
func ConvertMatrixInstance(contextData map[string]protocol.PipelineContextData) (map[string]interface{}, error)
func ConvertServiceContainer ¶
func ConvertServiceContainer(jobServiceContainers *protocol.TemplateToken) (map[string]*model.ContainerSpec, error)
func ConvertSteps ¶
func ConvertSteps(jobSteps []protocol.ActionStep) ([]*model.Step, error)
func ExecWorker ¶
func ExecWorker(rqt *protocol.AgentJobRequestMessage, wc actionsrunner.WorkerContext)
Types ¶
type ActRunner ¶
type ActRunner struct {
actionsrunner.WorkerRunnerEnvironment
}
func (*ActRunner) ExecWorker ¶
func (arunner *ActRunner) ExecWorker(run *actionsrunner.RunRunner, wc actionsrunner.WorkerContext, jobreq *protocol.AgentJobRequestMessage, src []byte, ) error
type ActionCacheBase ¶ added in v0.11.0
type ActionCacheBase struct {
VssConnection *protocol.VssConnection
Plan *protocol.TaskOrchestrationPlanReference
GHToken string
HttpClient *http.Client
CacheDir string
// contains filtered or unexported fields
}
func (*ActionCacheBase) GetTarArchive ¶ added in v0.11.0
func (cache *ActionCacheBase) GetTarArchive(ctx context.Context, cacheDir, sha, includePrefix string) (io.ReadCloser, error)
GetTarArchive implements runner.ActionCache.
type JobLoggerFactory ¶ added in v0.6.0
func (*JobLoggerFactory) WithJobLogger ¶ added in v0.6.0
func (factory *JobLoggerFactory) WithJobLogger() *logrus.Logger
type LaunchActionCache ¶ added in v0.11.0
type LaunchActionCache struct {
ActionCacheBase
LaunchEndpoint string
JobID string
}
type VssActionCache ¶ added in v0.11.0
type VssActionCache struct {
ActionCacheBase
}
Click to show internal directories.
Click to hide internal directories.