Documentation ¶
Index ¶
- type ProgressMessage
- type ScenarioOrchestrator
- func (c *ScenarioOrchestrator) Attach(containerId *string, signalChannel chan os.Signal, stdout io.Writer, ...) (bool, error)
- func (c *ScenarioOrchestrator) AttachWait(containerId *string, stdout io.Writer, stderr io.Writer, ctx context.Context) (*bool, error)
- func (c *ScenarioOrchestrator) CleanContainers(ctx context.Context) (*int, error)
- func (c *ScenarioOrchestrator) Connect(containerRuntimeUri string) (context.Context, error)
- func (c *ScenarioOrchestrator) GetConfig() config.Config
- func (c *ScenarioOrchestrator) GetContainerRuntime() orchestratormodels.ContainerRuntime
- func (c *ScenarioOrchestrator) GetContainerRuntimeSocket(userId *int) (*string, error)
- func (c *ScenarioOrchestrator) InspectScenario(container orchestratormodels.Container, ctx context.Context) (*orchestratormodels.ScenarioContainer, error)
- func (c *ScenarioOrchestrator) Kill(containerId *string, ctx context.Context) error
- func (c *ScenarioOrchestrator) ListRunningContainers(ctx context.Context) (*map[int64]orchestratormodels.Container, error)
- func (c *ScenarioOrchestrator) ListRunningScenarios(ctx context.Context) (*[]orchestratormodels.ScenarioContainer, error)
- func (c *ScenarioOrchestrator) PrintContainerRuntime()
- func (c *ScenarioOrchestrator) ResolveContainerName(containerName string, ctx context.Context) (*string, error)
- func (c *ScenarioOrchestrator) Run(image string, containerName string, env map[string]string, cache bool, ...) (*string, error)
- func (c *ScenarioOrchestrator) RunAttached(image string, containerName string, env map[string]string, cache bool, ...) (*string, error)
- func (c *ScenarioOrchestrator) RunGraph(scenarios orchestratormodels.ScenarioSet, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProgressMessage ¶
type ScenarioOrchestrator ¶
type ScenarioOrchestrator struct { Config config.Config ContainerRuntime orchestratormodels.ContainerRuntime }
func (*ScenarioOrchestrator) AttachWait ¶
func (*ScenarioOrchestrator) CleanContainers ¶
func (c *ScenarioOrchestrator) CleanContainers(ctx context.Context) (*int, error)
func (*ScenarioOrchestrator) Connect ¶
func (c *ScenarioOrchestrator) Connect(containerRuntimeUri string) (context.Context, error)
func (*ScenarioOrchestrator) GetConfig ¶
func (c *ScenarioOrchestrator) GetConfig() config.Config
func (*ScenarioOrchestrator) GetContainerRuntime ¶
func (c *ScenarioOrchestrator) GetContainerRuntime() orchestratormodels.ContainerRuntime
func (*ScenarioOrchestrator) GetContainerRuntimeSocket ¶
func (c *ScenarioOrchestrator) GetContainerRuntimeSocket(userId *int) (*string, error)
func (*ScenarioOrchestrator) InspectScenario ¶
func (c *ScenarioOrchestrator) InspectScenario(container orchestratormodels.Container, ctx context.Context) (*orchestratormodels.ScenarioContainer, error)
func (*ScenarioOrchestrator) Kill ¶
func (c *ScenarioOrchestrator) Kill(containerId *string, ctx context.Context) error
func (*ScenarioOrchestrator) ListRunningContainers ¶
func (c *ScenarioOrchestrator) ListRunningContainers(ctx context.Context) (*map[int64]orchestratormodels.Container, error)
func (*ScenarioOrchestrator) ListRunningScenarios ¶
func (c *ScenarioOrchestrator) ListRunningScenarios(ctx context.Context) (*[]orchestratormodels.ScenarioContainer, error)
func (*ScenarioOrchestrator) PrintContainerRuntime ¶
func (c *ScenarioOrchestrator) PrintContainerRuntime()
func (*ScenarioOrchestrator) ResolveContainerName ¶
func (*ScenarioOrchestrator) RunAttached ¶
func (*ScenarioOrchestrator) RunGraph ¶
func (c *ScenarioOrchestrator) RunGraph(scenarios orchestratormodels.ScenarioSet, resolvedGraph orchestratormodels.ResolvedGraph, extraEnv map[string]string, extraVolumeMounts map[string]string, cache bool, commChannel chan *orchestratormodels.GraphCommChannel, ctx context.Context)
Click to show internal directories.
Click to hide internal directories.