background

Documentation

Index

• Variables
• type ApplicationFetchWorker
  • func NewApplicationFetchWorker(sessionStorage *storage.Session, mediator *Mediator) *ApplicationFetchWorker
  • func (w *ApplicationFetchWorker) FetchApplicationRemote(application *models.Application, watchObjects bool)
• type ApplicationInitWorker
  • func NewApplicationInitWorker(globalConfiguration *models.GlobalConfiguration, mediator *Mediator) *ApplicationInitWorker
  • func (w *ApplicationInitWorker) InitApplication(application *models.Application) error
• type Mediator
  • func NewMediator(build queues.SessionBuildQueue, destroy queues.SessionDestroyQueue, ...) *Mediator
• type SessionBuildWorker
  • func NewSessionBuildWorker(globalConfiguration *models.GlobalConfiguration, ...) *SessionBuildWorker
  • func (w *SessionBuildWorker) RequestNewSession(buildInput *queues.SessionBuildInput) *queues.SessionBuildResult
• type SessionCleanWorker
  • func NewSessionCleanWorker(sessionStorage *storage.Session, mediator *Mediator) *SessionCleanWorker
• type SessionDestroyWorker
  • func NewSessionDestroyWorker(mediator *Mediator) *SessionDestroyWorker
  • func (w *SessionDestroyWorker) DestroySession(session *models.Session, callback func(*models.Session))
• type SessionFilesystemWorker
  • func NewSessionFilesystemWorker(mediator *Mediator) *SessionFilesystemWorker
• type SessionHealthcheckWorker
  • func NewSessionHealthcheckWorker(mediator *Mediator) *SessionHealthcheckWorker
• type SessionStartWorker
  • func NewSessionStartWorker(sessionStorage *storage.Session, mediator *Mediator) *SessionStartWorker
  • func (w *SessionStartWorker) MarkSessionAsStarted(session *models.Session)

Variables

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

Types

type ApplicationFetchWorker

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

func NewApplicationFetchWorker

func NewApplicationFetchWorker(sessionStorage *storage.Session, mediator *Mediator) *ApplicationFetchWorker

func (*ApplicationFetchWorker) FetchApplicationRemote

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

type ApplicationInitWorker

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

func NewApplicationInitWorker

func NewApplicationInitWorker(globalConfiguration *models.GlobalConfiguration, mediator *Mediator) *ApplicationInitWorker

func (*ApplicationInitWorker) InitApplication

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

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,
	pubSubBuilder *communication.PubSubBuilder,
) *SessionBuildWorker

func (*SessionBuildWorker) RequestNewSession

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

type SessionCleanWorker

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

func NewSessionCleanWorker

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

type SessionDestroyWorker

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

func NewSessionDestroyWorker

func NewSessionDestroyWorker(mediator *Mediator) *SessionDestroyWorker

func (*SessionDestroyWorker) DestroySession

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

type SessionFilesystemWorker

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

func NewSessionFilesystemWorker

func NewSessionFilesystemWorker(mediator *Mediator) *SessionFilesystemWorker

type SessionHealthcheckWorker

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

func NewSessionHealthcheckWorker

func NewSessionHealthcheckWorker(
	mediator *Mediator,
) *SessionHealthcheckWorker

type SessionStartWorker

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

func NewSessionStartWorker

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

func (*SessionStartWorker) MarkSessionAsStarted

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