Documentation
¶
Overview ¶
Package runexec coordinates governed command operations without CLI policy.
Index ¶
- Constants
- func LoadHint(configPath string) string
- func Queue(request QueueRequest) runqueue.QueueListing
- type ChangedOperations
- type ChangedRequest
- type ChangedResult
- type ExecuteRequest
- type ExecuteResult
- type Executor
- type HistoryOperations
- type HistoryRequest
- type HistoryResult
- type QueueEvent
- type QueueEventKind
- type QueueRequest
- type RecipeBucket
- type RecipeEvent
- type RecipeFailure
- type RecipeOperations
- type RecipeRequest
- type RecipeResult
- type RecipeRow
- type Submission
- type SubmissionOperations
- type SubmitRequest
Constants ¶
View Source
const AdmissionGrace = 200 * time.Millisecond
View Source
const Heartbeat = 10 * time.Second
Variables ¶
This section is empty.
Functions ¶
func Queue ¶
func Queue(request QueueRequest) runqueue.QueueListing
Types ¶
type ChangedOperations ¶
type ChangedOperations struct {
Getwd func() (string, error)
DefaultBranch func(string) string
Packages func(context.Context, string, string) (quality.ChangedPackagesResult, error)
}
func (ChangedOperations) Run ¶
func (ops ChangedOperations) Run(ctx context.Context, request ChangedRequest) (ChangedResult, error)
type ChangedRequest ¶
type ChangedResult ¶
type ChangedResult struct {
Argv, Packages []string
Target, MergeBase string
MissingTarget, NoWork bool
}
func Changed ¶
func Changed(ctx context.Context, request ChangedRequest) (ChangedResult, error)
type ExecuteRequest ¶
type ExecuteResult ¶
func Execute ¶
func Execute(ctx context.Context, request ExecuteRequest) (ExecuteResult, error)
type Executor ¶
type Executor struct {
QueueHeartbeat, CourtesyHeartbeat time.Duration
// contains filtered or unexported fields
}
Executor's durations configure this invocation; zero uses production defaults. There are no process-global test overrides.
func (Executor) Run ¶
func (executor Executor) Run(ctx context.Context, request ExecuteRequest) (ExecuteResult, error)
type HistoryOperations ¶
type HistoryOperations struct {
Getwd func() (string, error)
Read func(string) ([]runlog.Event, string, error)
Now func() time.Time
}
func (HistoryOperations) Run ¶
func (ops HistoryOperations) Run(_ context.Context, request HistoryRequest) (HistoryResult, error)
type HistoryRequest ¶
type HistoryRequest struct{ Days int }
type HistoryResult ¶
func History ¶
func History(ctx context.Context, request HistoryRequest) (HistoryResult, error)
type QueueEvent ¶
type QueueEventKind ¶
type QueueEventKind uint8
const ( ImmediatelyAdmitted QueueEventKind = iota Queued WaitingHeartbeat AdmittedAfterWait Done CourtesyRunning )
type QueueRequest ¶
type QueueRequest struct{ ProjectsRoot string }
type RecipeBucket ¶
type RecipeBucket uint8
const ( Updated RecipeBucket = iota Skipped Archived Forked Failed )
type RecipeEvent ¶
type RecipeFailure ¶
RecipeFailure identifies the existing diagnostic prefix without CLI exit types.
func (*RecipeFailure) Error ¶
func (failure *RecipeFailure) Error() string
func (*RecipeFailure) Unwrap ¶
func (failure *RecipeFailure) Unwrap() error
type RecipeOperations ¶
type RecipeOperations struct {
LoadConfig func(string) (recipe.Config, error)
Discover func(string, string, []string) ([]discover.Repo, error)
DefaultBranch func(string) (string, error)
Fetch func(string) error
Land func(recipe.Recipe, string, string) (gitops.Outcome, error)
}
func NewRecipes ¶
func (RecipeOperations) Run ¶
func (ops RecipeOperations) Run(_ context.Context, request RecipeRequest) (RecipeResult, error)
type RecipeRequest ¶
type RecipeRequest struct {
ProjectsRoot, Filter, ConfigPath, Name string
ExtraOrgs []string
List, Apply bool
// Observe renders warnings and rows before further effects; required for named runs.
Observe func(RecipeEvent) error
}
type RecipeResult ¶
type RecipeRow ¶
type RecipeRow struct {
Bucket RecipeBucket
Text string
}
type Submission ¶
type SubmissionOperations ¶
type SubmissionOperations struct {
Getwd func() (string, error)
Send func(context.Context, SubmitRequest, Submission) (operationreceipt.Receipt, error)
}
SubmissionOperations binds the actual authenticated transport at composition.
func NewSubmission ¶
func NewSubmission(send func(context.Context, SubmitRequest, Submission) (operationreceipt.Receipt, error)) SubmissionOperations
func (SubmissionOperations) Run ¶
func (ops SubmissionOperations) Run(ctx context.Context, request SubmitRequest) (operationreceipt.Receipt, error)
Click to show internal directories.
Click to hide internal directories.