Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommonRunner ¶
type CommonRunner struct {
// contains filtered or unexported fields
}
func NewCommonRunner ¶
func NewCommonRunner( configuration *config.Config, ) *CommonRunner
type Loop ¶
type Loop struct {
// contains filtered or unexported fields
}
func NewLoop ¶
func NewLoop(runner *WorkflowRunner) *Loop
type Runner ¶
type Runner interface {
// Start starts the runner with the given context
Start(ctx context.Context) error
// Stop gracefully stops the runner with the given context
Stop(ctx context.Context) error
}
Runner defines the standard interface for all runners
type WorkflowRunner ¶
type WorkflowRunner struct {
// contains filtered or unexported fields
}
func NewWorkflowRunner ¶
func NewWorkflowRunner( configuration *config.Config, keysManager taskverifier.KeysManager, verifier *taskverifier.TaskVerifier, opmsClient opms.Client, traceroute traceroute.Component, eventPlatform eventplatform.Component, ) (*WorkflowRunner, error)
func (*WorkflowRunner) RunTask ¶
func (n *WorkflowRunner) RunTask( ctx context.Context, task *types.Task, credential *privateconnection.PrivateCredentials, ) (interface{}, error)
Source Files
Click to show internal directories.
Click to hide internal directories.