Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func HeartbeatUntilDone ¶
Types ¶
type Client ¶
type Client interface {
GetJob(ctx context.Context, jobID string) (*models.AppRunnerJob, error)
GetJobPlanJSON(ctx context.Context, jobID string) (string, error)
GetJobCompositePlan(ctx context.Context, jobID string) (*models.PlantypesCompositePlan, error)
UpdateJobExecution(ctx context.Context, jobID, executionID string, req *models.ServiceUpdateRunnerJobExecutionRequest) (*models.AppRunnerJobExecution, error)
CreateJobExecutionResult(ctx context.Context, jobID, executionID string, req *models.ServiceCreateRunnerJobExecutionResultRequest) (*models.AppRunnerJobExecutionResult, error)
CreateJobExecutionOutputs(ctx context.Context, jobID, executionID string, req *models.ServiceCreateRunnerJobExecutionOutputsRequest) (*models.AppRunnerJobExecutionOutputs, error)
WriteControlPlaneLogs(ctx context.Context, logStreamID string, records []OTELLogRecord) error
WriteControlPlaneTraces(ctx context.Context, runnerID string, records []OTELTraceRecord) error
}
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func (*Executor) Execute ¶
func (e *Executor) Execute(ctx context.Context, job *models.AppRunnerJob, execution *models.AppRunnerJobExecution) error
type OTELLogRecord ¶
type OTELLogRecord struct {
RunnerID string
RunnerGroupID string
RunnerJobID string
RunnerJobExecutionID string
RunnerJobExecutionStep string
ResourceAttributes map[string]string
ResourceSchemaURL string
ScopeSchemaURL string
ScopeName string
ScopeVersion string
ScopeAttributes map[string]string
Timestamp time.Time
ServiceName string
SeverityNumber int
SeverityText string
Body string
TraceID string
SpanID string
TraceFlags int
LogAttributes map[string]string
}
type OTELTraceRecord ¶
type OTELTraceRecord struct {
RunnerID string
RunnerGroupID string
RunnerJobID string
RunnerJobExecutionID string
RunnerJobExecutionStep string
Timestamp time.Time
ResourceAttributes map[string]string
ResourceSchemaURL string
ScopeSchemaURL string
ScopeName string
ScopeVersion string
ScopeAttributes map[string]string
TraceID string
SpanID string
ParentSpanID string
TraceState string
SpanName string
SpanKind string
ServiceName string
SpanAttributes map[string]string
Duration int64
StatusCode string
StatusMessage string
EventsTimestamp []time.Time
EventsName []string
EventsAttributes []map[string]string
LinksTraceID []string
LinksSpanID []string
LinksState []string
LinksAttributes []map[string]string
}
Click to show internal directories.
Click to hide internal directories.