orchestration

package
v0.7.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 21, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConstructContext

func ConstructContext(ctx context.Context, construct model.URN) context.Context

Types

type DownOrchestrator

type DownOrchestrator struct {
	*Orchestrator
	FS afero.Fs
}

func NewDownOrchestrator

func NewDownOrchestrator(sm *model.StateManager, fs afero.Fs, outputPath string) *DownOrchestrator

func (*DownOrchestrator) RunDownCommand

func (do *DownOrchestrator) RunDownCommand(ctx context.Context, request DownRequest, maxConcurrency int) error

type DownRequest

type DownRequest struct {
	StackReferences []stack.Reference
	DryRun          model.DryRun
}

type InfraGenerator

type InfraGenerator struct {
	Engine *engine.Engine
	FS     afero.Fs
}

func NewInfraGenerator

func NewInfraGenerator(fs afero.Fs) (*InfraGenerator, error)

func (*InfraGenerator) Run

type InfraRequest

type InfraRequest struct {
	engine.SolveRequest
	OutputDir string
}

type Orchestrator

type Orchestrator struct {
	StateManager    *model.StateManager
	FS              afero.Fs
	OutputDirectory string
	// contains filtered or unexported fields
}

Orchestrator is the base orchestrator for the K2 platform

func NewOrchestrator

func NewOrchestrator(sm *model.StateManager, fs afero.Fs, outputPath string) *Orchestrator

func (*Orchestrator) FinalizeState

func (o *Orchestrator) FinalizeState(ctx context.Context)

func (*Orchestrator) InfraGenerator

func (o *Orchestrator) InfraGenerator() (*InfraGenerator, error)

type UpOrchestrator

type UpOrchestrator struct {
	*Orchestrator
	LanguageHostClient pb.KlothoServiceClient
	StackStateManager  *stack.StateManager
	ConstructEvaluator *constructs.ConstructEvaluator
}

func NewUpOrchestrator

func NewUpOrchestrator(
	sm *model.StateManager, languageHostClient pb.KlothoServiceClient, fs afero.Fs, outputPath string,
) (*UpOrchestrator, error)

func (*UpOrchestrator) EvaluateConstruct

func (uo *UpOrchestrator) EvaluateConstruct(ctx context.Context, state model.State, constructUrn model.URN) (stack.Reference, error)

func (*UpOrchestrator) RunUpCommand

func (uo *UpOrchestrator) RunUpCommand(
	ctx context.Context, ir *model.ApplicationEnvironment, dryRun model.DryRun, sem *semaphore.Weighted,
) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL