queues

Documentation

Index

• type ApplicationFetchInput
• type ApplicationFetchQueue
  • func NewApplicationFetch() ApplicationFetchQueue
  • func (q *ApplicationFetchQueue) Enqueue(app *models.Application, watchObjects bool) error
• type ApplicationInitQueue
  • func NewApplicationInit() ApplicationInitQueue
  • func (q *ApplicationInitQueue) Enqueue(input *models.Application) error
• type SessionBuildInput
• type SessionBuildQueue
  • func NewSessionBuild() SessionBuildQueue
  • func (q *SessionBuildQueue) Enqueue(checkout string, app *models.Application, prevSession *models.Session, ...) *SessionBuildResult
• type SessionBuildResult
• type SessionBuildResultType
• type SessionCleanupInput
• type SessionCleanupQueue
  • func NewSessionCleanup() SessionCleanupQueue
  • func (q *SessionCleanupQueue) Enqueue(session *models.Session, status models.SessionStatus)
• type SessionDestroyInput
• type SessionDestroyQueue
  • func NewSessionDestroy() SessionDestroyQueue
  • func (q *SessionDestroyQueue) Enqueue(session *models.Session, callback func(*models.Session))
• type SessionFilesystemQueue
  • func NewSessionFilesystem() SessionFilesystemQueue
  • func (q *SessionFilesystemQueue) Enqueue(session *models.Session) *SessionFilesystemResult
• type SessionFilesystemResult
• type SessionHealthcheckInput
• type SessionHealthcheckQueue
  • func NewSessionHealthCheck() SessionHealthcheckQueue
  • func (q *SessionHealthcheckQueue) Enqueue(input SessionHealthcheckInput) struct{}
• type SessionStartInput
• type SessionStartQueue
  • func NewSessionStart() SessionStartQueue
  • func (q *SessionStartQueue) Enqueue(input SessionStartInput)

Types

type ApplicationFetchInput

type ApplicationFetchInput struct {
	Application  *models.Application
	WatchObjects bool
}

type ApplicationFetchQueue

type ApplicationFetchQueue struct {
	RequestChan  chan ApplicationFetchInput
	ResponseChan chan error
}

func NewApplicationFetch

func NewApplicationFetch() ApplicationFetchQueue

func (*ApplicationFetchQueue) Enqueue

func (q *ApplicationFetchQueue) Enqueue(app *models.Application, watchObjects bool) error

type ApplicationInitQueue

type ApplicationInitQueue struct {
	RequestChan  chan *models.Application
	ResponseChan chan error
}

func NewApplicationInit

func NewApplicationInit() ApplicationInitQueue

func (*ApplicationInitQueue) Enqueue

func (q *ApplicationInitQueue) Enqueue(input *models.Application) error

type SessionBuildInput

type SessionBuildInput struct {
	Checkout             string
	Application          *models.Application
	PreviousSession      *models.Session
	SessionsToBeReplaced []*models.Session
	DetectBranchOrTag    bool
}

type SessionBuildQueue

type SessionBuildQueue struct {
	RequestChan  chan *SessionBuildInput
	ResponseChan chan *SessionBuildResult
}

func NewSessionBuild

func NewSessionBuild() SessionBuildQueue

func (*SessionBuildQueue) Enqueue

func (q *SessionBuildQueue) Enqueue(checkout string, app *models.Application, prevSession *models.Session, sessionsToBeReplaced []*models.Session, detectBranchOrTag bool) *SessionBuildResult

type SessionBuildResult

type SessionBuildResult struct {
	Result        SessionBuildResultType
	Session       *models.Session
	FailingReason string
	EventBus      *models.SessionLifetimeEventBus
}

type SessionBuildResultType

type SessionBuildResultType string

const (
	SessionBuildResultSucceeded    SessionBuildResultType = "succeeded"
	SessionBuildResultAlreadyBuilt SessionBuildResultType = "already_built"
	SessionBuildResultFailed       SessionBuildResultType = "failed"
)

type SessionCleanupInput

type SessionCleanupInput struct {
	Session *models.Session
	Status  models.SessionStatus
}

type SessionCleanupQueue

type SessionCleanupQueue struct {
	Chan chan *SessionCleanupInput
}

func NewSessionCleanup

func NewSessionCleanup() SessionCleanupQueue

func (*SessionCleanupQueue) Enqueue

func (q *SessionCleanupQueue) Enqueue(session *models.Session, status models.SessionStatus)

type SessionDestroyInput

type SessionDestroyInput struct {
	Session  *models.Session
	Callback func(*models.Session)
}

type SessionDestroyQueue

type SessionDestroyQueue struct {
	Chan chan SessionDestroyInput
}

func NewSessionDestroy

func NewSessionDestroy() SessionDestroyQueue

func (*SessionDestroyQueue) Enqueue

func (q *SessionDestroyQueue) Enqueue(session *models.Session, callback func(*models.Session))

type SessionFilesystemQueue

type SessionFilesystemQueue struct {
	RequestChan  chan *models.Session
	ResponseChan chan *SessionFilesystemResult
}

func NewSessionFilesystem

func NewSessionFilesystem() SessionFilesystemQueue

func (*SessionFilesystemQueue) Enqueue

func (q *SessionFilesystemQueue) Enqueue(session *models.Session) *SessionFilesystemResult

type SessionFilesystemResult

type SessionFilesystemResult struct {
	CommitFolder string
	Err          error
}

type SessionHealthcheckInput

type SessionHealthcheckInput struct {
	Session *models.Session
}

type SessionHealthcheckQueue

type SessionHealthcheckQueue struct {
	RequestChan  chan SessionHealthcheckInput
	ResponseChan chan struct{}
}

func NewSessionHealthCheck

func NewSessionHealthCheck() SessionHealthcheckQueue

func (*SessionHealthcheckQueue) Enqueue

func (q *SessionHealthcheckQueue) Enqueue(input SessionHealthcheckInput) struct{}

type SessionStartInput

type SessionStartInput struct {
	Session *models.Session
}

type SessionStartQueue

type SessionStartQueue struct {
	Chan chan SessionStartInput
}

func NewSessionStart

func NewSessionStart() SessionStartQueue

func (*SessionStartQueue) Enqueue

func (q *SessionStartQueue) Enqueue(input SessionStartInput)