execution

package
v0.19.0 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2021 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RecipeStatusTypes = struct {
	AVAILABLE   RecipeStatusType
	INSTALLING  RecipeStatusType
	FAILED      RecipeStatusType
	INSTALLED   RecipeStatusType
	SKIPPED     RecipeStatusType
	RECOMMENDED RecipeStatusType
}{
	AVAILABLE:   "AVAILABLE",
	INSTALLING:  "INSTALLING",
	FAILED:      "FAILED",
	INSTALLED:   "INSTALLED",
	SKIPPED:     "SKIPPED",
	RECOMMENDED: "RECOMMENDED",
}

Functions

This section is empty.

Types

type GoTaskRecipeExecutor 

type GoTaskRecipeExecutor struct{}

GoTaskRecipeExecutor is an implementation of the recipeExecutor interface that uses the go-task module to execute the steps defined in each recipe.

func NewGoTaskRecipeExecutor 

func NewGoTaskRecipeExecutor() *GoTaskRecipeExecutor

NewGoTaskRecipeExecutor returns a new instance of GoTaskRecipeExecutor.

func (*GoTaskRecipeExecutor) Execute 

func (re *GoTaskRecipeExecutor) Execute(ctx context.Context, m types.DiscoveryManifest, r types.Recipe, recipeVars types.RecipeVars) error

func (*GoTaskRecipeExecutor) Prepare 

func (re *GoTaskRecipeExecutor) Prepare(ctx context.Context, m types.DiscoveryManifest, r types.Recipe, assumeYes bool) (types.RecipeVars, error)

type InstallStatus added in v0.18.26 

type InstallStatus struct {
	Complete    bool `json:"complete"`
	DocumentID  string
	EntityGUIDs []string       `json:"entityGuids"`
	Statuses    []RecipeStatus `json:"recipes"`
	Timestamp   int64          `json:"timestamp"`
	LogFilePath string         `json:"logFilePath"`
	// contains filtered or unexported fields
}

func NewInstallStatus added in v0.18.26 

func NewInstallStatus(reporters []StatusSubscriber) *InstallStatus

func (*InstallStatus) InstallComplete added in v0.18.26 

func (s *InstallStatus) InstallComplete()

func (*InstallStatus) RecipeAvailable added in v0.18.26 

func (s *InstallStatus) RecipeAvailable(recipe types.Recipe)

func (*InstallStatus) RecipeFailed added in v0.18.26 

func (s *InstallStatus) RecipeFailed(event RecipeStatusEvent)

func (*InstallStatus) RecipeInstalled added in v0.18.26 

func (s *InstallStatus) RecipeInstalled(event RecipeStatusEvent)

func (*InstallStatus) RecipeInstalling added in v0.18.26 

func (s *InstallStatus) RecipeInstalling(event RecipeStatusEvent)

func (*InstallStatus) RecipeRecommended added in v0.18.26 

func (s *InstallStatus) RecipeRecommended(event RecipeStatusEvent)

RecipeRecommended is responsible for setting the nerstorage scopes when a recipe is recommended. This is used when a recipe is found, but not a "HOST" type, and is used to indicate to the user that it is something they should consider integrating, but not something that the recipe framework will currently assist with.

func (*InstallStatus) RecipeSkipped added in v0.18.26 

func (s *InstallStatus) RecipeSkipped(event RecipeStatusEvent)

func (*InstallStatus) RecipesAvailable added in v0.18.26 

func (s *InstallStatus) RecipesAvailable(recipes []types.Recipe)

func (*InstallStatus) RecipesSelected added in v0.18.26 

func (s *InstallStatus) RecipesSelected(recipes []types.Recipe)

type MockFailingRecipeExecutor added in v0.18.11 

type MockFailingRecipeExecutor struct {
	// contains filtered or unexported fields
}

func NewMockFailingRecipeExecutor added in v0.18.11 

func NewMockFailingRecipeExecutor() *MockFailingRecipeExecutor

func (*MockFailingRecipeExecutor) Execute added in v0.18.11 

func (m *MockFailingRecipeExecutor) Execute(ctx context.Context, dm types.DiscoveryManifest, r types.Recipe, v types.RecipeVars) error

func (*MockFailingRecipeExecutor) Prepare added in v0.18.11 

func (m *MockFailingRecipeExecutor) Prepare(ctx context.Context, dm types.DiscoveryManifest, r types.Recipe, y bool) (types.RecipeVars, error)

type MockNerdStorageClient 

type MockNerdStorageClient struct {
	WriteDocumentWithUserScopeVal   interface{}
	WriteDocumentWithEntityScopeVal interface{}
	WriteDocumentWithUserScopeErr   error
	WriteDocumentWithEntityScopeErr error
	// contains filtered or unexported fields
}

func NewMockNerdStorageClient 

func NewMockNerdStorageClient() *MockNerdStorageClient

func (*MockNerdStorageClient) WriteDocumentWithEntityScope 

func (c *MockNerdStorageClient) WriteDocumentWithEntityScope(string, nerdstorage.WriteDocumentInput) (interface{}, error)

func (*MockNerdStorageClient) WriteDocumentWithUserScope 

func (c *MockNerdStorageClient) WriteDocumentWithUserScope(nerdstorage.WriteDocumentInput) (interface{}, error)

type MockRecipeExecutor 

type MockRecipeExecutor struct {
	// contains filtered or unexported fields
}

func NewMockRecipeExecutor 

func NewMockRecipeExecutor() *MockRecipeExecutor

func (*MockRecipeExecutor) Execute 

func (m *MockRecipeExecutor) Execute(ctx context.Context, dm types.DiscoveryManifest, r types.Recipe, v types.RecipeVars) error

func (*MockRecipeExecutor) Prepare 

func (m *MockRecipeExecutor) Prepare(ctx context.Context, dm types.DiscoveryManifest, r types.Recipe, y bool) (types.RecipeVars, error)

type MockStatusReporter 

type MockStatusReporter struct {
	RecipeAvailableErr         error
	RecipesAvailableErr        error
	RecipesSelectedErr         error
	RecipeFailedErr            error
	RecipeInstalledErr         error
	RecipeInstallingErr        error
	RecipeRecommendedErr       error
	RecipeSkippedErr           error
	InstallCompleteErr         error
	RecipeAvailableCallCount   int
	RecipesAvailableCallCount  int
	RecipesSelectedCallCount   int
	RecipeFailedCallCount      int
	RecipeInstalledCallCount   int
	RecipeInstallingCallCount  int
	RecipeRecommendedCallCount int
	RecipeSkippedCallCount     int
	InstallCompleteCallCount   int

	ReportSkipped     map[string]int
	ReportInstalled   map[string]int
	ReportInstalling  map[string]int
	ReportRecommended map[string]int
	ReportFailed      map[string]int
	ReportAvailable   map[string]int
}

MockStatusReporter is a mock implementation of the ExecutionStatusReporter interface that provides method spies for testing scenarios.

func NewMockStatusReporter 

func NewMockStatusReporter() *MockStatusReporter

NewMockStatusReporter returns a new instance of MockExecutionStatusReporter.

func (*MockStatusReporter) InstallComplete added in v0.18.26 

func (r *MockStatusReporter) InstallComplete(status *InstallStatus) error

func (*MockStatusReporter) RecipeAvailable added in v0.18.26 

func (r *MockStatusReporter) RecipeAvailable(status *InstallStatus, recipe types.Recipe) error

func (*MockStatusReporter) RecipeFailed added in v0.18.26 

func (r *MockStatusReporter) RecipeFailed(status *InstallStatus, event RecipeStatusEvent) error

func (*MockStatusReporter) RecipeInstalled added in v0.18.26 

func (r *MockStatusReporter) RecipeInstalled(status *InstallStatus, event RecipeStatusEvent) error

func (*MockStatusReporter) RecipeInstalling added in v0.18.26 

func (r *MockStatusReporter) RecipeInstalling(status *InstallStatus, event RecipeStatusEvent) error

func (*MockStatusReporter) RecipeRecommended added in v0.18.26 

func (r *MockStatusReporter) RecipeRecommended(status *InstallStatus, event RecipeStatusEvent) error

func (*MockStatusReporter) RecipeSkipped added in v0.18.26 

func (r *MockStatusReporter) RecipeSkipped(status *InstallStatus, event RecipeStatusEvent) error

func (*MockStatusReporter) RecipesAvailable added in v0.18.26 

func (r *MockStatusReporter) RecipesAvailable(status *InstallStatus, recipes []types.Recipe) error

func (*MockStatusReporter) RecipesSelected added in v0.18.26 

func (r *MockStatusReporter) RecipesSelected(status *InstallStatus, recipes []types.Recipe) error

type NerdStorageClient 

type NerdStorageClient interface {
	WriteDocumentWithUserScope(nerdstorage.WriteDocumentInput) (interface{}, error)
	WriteDocumentWithEntityScope(string, nerdstorage.WriteDocumentInput) (interface{}, error)
}

type NerdstorageStatusReporter 

type NerdstorageStatusReporter struct {
	// contains filtered or unexported fields
}

NerdstorageStatusReporter is an implementation of the ExecutionStatusReporter interface that reports esecution status into NerdStorage.

func NewNerdStorageStatusReporter 

func NewNerdStorageStatusReporter(client NerdStorageClient) *NerdstorageStatusReporter

NewNerdStorageStatusReporter returns a new instance of NerdStorageExecutionStatusReporter.

func (NerdstorageStatusReporter) InstallComplete added in v0.18.26 

func (r NerdstorageStatusReporter) InstallComplete(status *InstallStatus) error

func (NerdstorageStatusReporter) RecipeAvailable added in v0.18.26 

func (r NerdstorageStatusReporter) RecipeAvailable(status *InstallStatus, recipe types.Recipe) error

RecipeAvailable reports that a recipe is available for installation on the underlying host.

func (NerdstorageStatusReporter) RecipeFailed added in v0.18.26 

func (r NerdstorageStatusReporter) RecipeFailed(status *InstallStatus, event RecipeStatusEvent) error

func (NerdstorageStatusReporter) RecipeInstalled added in v0.18.26 

func (r NerdstorageStatusReporter) RecipeInstalled(status *InstallStatus, event RecipeStatusEvent) error

func (NerdstorageStatusReporter) RecipeInstalling added in v0.18.26 

func (r NerdstorageStatusReporter) RecipeInstalling(status *InstallStatus, event RecipeStatusEvent) error

func (NerdstorageStatusReporter) RecipeRecommended added in v0.18.26 

func (r NerdstorageStatusReporter) RecipeRecommended(status *InstallStatus, event RecipeStatusEvent) error

func (NerdstorageStatusReporter) RecipeSkipped added in v0.18.26 

func (r NerdstorageStatusReporter) RecipeSkipped(status *InstallStatus, event RecipeStatusEvent) error

func (NerdstorageStatusReporter) RecipesAvailable added in v0.18.26 

func (r NerdstorageStatusReporter) RecipesAvailable(status *InstallStatus, recipes []types.Recipe) error

RecipesAvailable reports that recipes are available for installation on the underlying host.

func (NerdstorageStatusReporter) RecipesSelected added in v0.18.26 

func (r NerdstorageStatusReporter) RecipesSelected(status *InstallStatus, recipes []types.Recipe) error

type RecipeExecutor 

type RecipeExecutor interface {
	Prepare(context.Context, types.DiscoveryManifest, types.Recipe, bool) (types.RecipeVars, error)
	Execute(context.Context, types.DiscoveryManifest, types.Recipe, types.RecipeVars) error
}

RecipeExecutor is responsible for execution of the task steps defined in a recipe.

type RecipeStatus added in v0.18.26 

type RecipeStatus struct {
	Name        string              `json:"name"`
	DisplayName string              `json:"displayName"`
	Status      RecipeStatusType    `json:"status"`
	Errors      []StatusRecipeError `json:"errors"`
}

type RecipeStatusEvent 

type RecipeStatusEvent struct {
	Recipe     types.Recipe
	Msg        string
	EntityGUID string
}

RecipeStatusEvent represents an event in a recipe's execution.

type RecipeStatusType added in v0.18.26 

type RecipeStatusType string

type StatusRecipeError 

type StatusRecipeError struct {
	Message string `json:"message"`
	Details string `json:"details"`
}

type StatusSubscriber added in v0.18.26 

type StatusSubscriber interface {
	InstallComplete(status *InstallStatus) error
	RecipeAvailable(status *InstallStatus, recipe types.Recipe) error
	RecipeFailed(status *InstallStatus, event RecipeStatusEvent) error
	RecipeInstalled(status *InstallStatus, event RecipeStatusEvent) error
	RecipeInstalling(status *InstallStatus, event RecipeStatusEvent) error
	RecipeRecommended(status *InstallStatus, event RecipeStatusEvent) error
	RecipeSkipped(status *InstallStatus, event RecipeStatusEvent) error
	RecipesAvailable(status *InstallStatus, recipes []types.Recipe) error
	RecipesSelected(status *InstallStatus, recipes []types.Recipe) error
}

StatusSubscriber is notified during the lifecycle of the recipe execution status.

type TerminalStatusReporter added in v0.18.11 

type TerminalStatusReporter struct{}

func NewTerminalStatusReporter added in v0.18.11 

func NewTerminalStatusReporter() *TerminalStatusReporter

NewTerminalStatusReporter is an implementation of the ExecutionStatusReporter interface that reports execution status to STDOUT.

func (TerminalStatusReporter) InstallComplete added in v0.18.26 

func (r TerminalStatusReporter) InstallComplete(status *InstallStatus) error

func (TerminalStatusReporter) RecipeAvailable added in v0.18.26 

func (r TerminalStatusReporter) RecipeAvailable(status *InstallStatus, recipe types.Recipe) error

func (TerminalStatusReporter) RecipeFailed added in v0.18.26 

func (r TerminalStatusReporter) RecipeFailed(status *InstallStatus, event RecipeStatusEvent) error

func (TerminalStatusReporter) RecipeInstalled added in v0.18.26 

func (r TerminalStatusReporter) RecipeInstalled(status *InstallStatus, event RecipeStatusEvent) error

func (TerminalStatusReporter) RecipeInstalling added in v0.18.26 

func (r TerminalStatusReporter) RecipeInstalling(status *InstallStatus, event RecipeStatusEvent) error

func (TerminalStatusReporter) RecipeRecommended added in v0.18.26 

func (r TerminalStatusReporter) RecipeRecommended(status *InstallStatus, event RecipeStatusEvent) error

func (TerminalStatusReporter) RecipeSkipped added in v0.18.26 

func (r TerminalStatusReporter) RecipeSkipped(status *InstallStatus, event RecipeStatusEvent) error

func (TerminalStatusReporter) RecipesAvailable added in v0.18.26 

func (r TerminalStatusReporter) RecipesAvailable(status *InstallStatus, recipes []types.Recipe) error

func (TerminalStatusReporter) RecipesSelected added in v0.18.26 

func (r TerminalStatusReporter) RecipesSelected(status *InstallStatus, recipes []types.Recipe) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.