background

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2021 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrWrongSessionState error = errors.New("Wrong session state")
	ErrCommandFailed     error = errors.New("Command failed")
)

Functions

func ParseCommandContext added in v1.3.0 

func ParseCommandContext(context context.Context, command string) []*exec.Cmd

Types

type ApplicationFetchWorker 

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

func NewApplicationFetchWorker 

func NewApplicationFetchWorker(sessionStorage *storage.Session, repositoryFetcher versioning.RepositoryFetcher, mediator *Mediator, log logging.Logger) *ApplicationFetchWorker

func (*ApplicationFetchWorker) FetchApplicationRemote 

func (w *ApplicationFetchWorker) FetchApplicationRemote(application *models.Application, watchObjects bool)

func (*ApplicationFetchWorker) Start 

func (w *ApplicationFetchWorker) Start()

type ApplicationInitWorker 

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

func NewApplicationInitWorker 

func NewApplicationInitWorker(globalConfiguration *models.GlobalConfiguration, gitClient versioning.GitClient, mediator *Mediator, logger logging.Logger) *ApplicationInitWorker

func (*ApplicationInitWorker) InitApplication 

func (w *ApplicationInitWorker) InitApplication(application *models.Application) error

func (*ApplicationInitWorker) Start 

func (w *ApplicationInitWorker) Start()

type Mediator 

type Mediator struct {
	BuildSession       queues.SessionBuildQueue
	DestroySession     queues.SessionDestroyQueue
	SessionFileSystem  queues.SessionFilesystemQueue
	CleanSession       queues.SessionCleanupQueue
	StartSession       queues.SessionStartQueue
	HealthcheckSession queues.SessionHealthcheckQueue
	ApplicationInit    queues.ApplicationInitQueue
	ApplicationFetch   queues.ApplicationFetchQueue
}

func NewMediator 

func NewMediator(
	build queues.SessionBuildQueue,
	destroy queues.SessionDestroyQueue,
	fs queues.SessionFilesystemQueue,
	clean queues.SessionCleanupQueue,
	start queues.SessionStartQueue,
	healthcheck queues.SessionHealthcheckQueue,
	init queues.ApplicationInitQueue,
	fetch queues.ApplicationFetchQueue,
) *Mediator

type SessionBuildWorker 

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

func NewSessionBuildWorker 

func NewSessionBuildWorker(
	globalConfiguration *models.GlobalConfiguration,
	applicationStorage *storage.Application,
	sessionStorage *storage.Session,
	mediator *Mediator,
	sessionBuilder *models.SessionBuilder,
	log logging.Logger,
	sessionCommandExecution SessionCommandExecution,
	portRetriever net.PortRetriever,
) *SessionBuildWorker

func (*SessionBuildWorker) RequestNewSession 

func (w *SessionBuildWorker) RequestNewSession(buildInput *queues.SessionBuildInput) *queues.SessionBuildResult

func (*SessionBuildWorker) Start 

func (w *SessionBuildWorker) Start()

type SessionCleanWorker 

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

func NewSessionCleanWorker 

func NewSessionCleanWorker(sessionStorage *storage.Session, mediator *Mediator, sessionCommandExecution SessionCommandExecution) *SessionCleanWorker

func (*SessionCleanWorker) Start 

func (w *SessionCleanWorker) Start()

type SessionCommandExecution added in v1.3.0 

type SessionCommandExecution interface {
	ExecCommand(ctx context.Context, command *models.Command, session *models.Session) error
}

func NewSessionCommandExecution added in v1.3.0 

func NewSessionCommandExecution(portRetriever net.PortRetriever, commandRunner execution.CommandRunner) SessionCommandExecution

type SessionDestroyWorker 

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

func NewSessionDestroyWorker 

func NewSessionDestroyWorker(mediator *Mediator, sessionCommandExecution SessionCommandExecution) *SessionDestroyWorker

func (*SessionDestroyWorker) DestroySession 

func (w *SessionDestroyWorker) DestroySession(session *models.Session, callback func(*models.Session))

func (*SessionDestroyWorker) Start 

func (w *SessionDestroyWorker) Start()

type SessionFilesystemWorker 

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

func NewSessionFilesystemWorker 

func NewSessionFilesystemWorker(gitClient versioning.GitClient, mediator *Mediator) *SessionFilesystemWorker

func (*SessionFilesystemWorker) Start 

func (w *SessionFilesystemWorker) Start()

type SessionHealthcheckWorker 

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

func NewSessionHealthcheckWorker 

func NewSessionHealthcheckWorker(
	mediator *Mediator,
	logger logging.Logger,
) *SessionHealthcheckWorker

func (*SessionHealthcheckWorker) Start 

func (w *SessionHealthcheckWorker) Start()

type SessionStartWorker 

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

func NewSessionStartWorker 

func NewSessionStartWorker(
	sessionStorage *storage.Session,
	mediator *Mediator,
	logger logging.Logger,
) *SessionStartWorker

func (*SessionStartWorker) MarkSessionAsStarted 

func (w *SessionStartWorker) MarkSessionAsStarted(session *models.Session)

func (*SessionStartWorker) Start 

func (w *SessionStartWorker) Start()

Source Files

View all Source files

Directories

Path Synopsis

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.