services

Documentation

Index

• Variables
• type AliasingService
  • func NewAliasingService(sessionStorage *storage.Session) *AliasingService
  • func (a *AliasingService) Next() string
• type QueryService
  • func NewQueryService(environment utils.Environment, storage *storage.Session, ...) *QueryService
  • func (s *QueryService) GetAliveSession(uuid string) *models.Session
  • func (s *QueryService) GetAllAliveSessions() []*models.Session
  • func (s *QueryService) GetAllApplications() []*models.Application
  • func (s *QueryService) GetFailedSession(uuid string) (*models.Session, error)
  • func (s *QueryService) GetFailedSessionLogs(uuid string) ([]models.Log, error)
  • func (s *QueryService) GetFailedSessions() []*models.Session
  • func (s *QueryService) GetMatchingCheckoutByForwardLink(rawInput string) (checkout string, application string, path string, found bool)
  • func (s *QueryService) GetMatchingCheckoutByPermalink(rawInput string) (checkout string, application string, path string, found bool)
  • func (s *QueryService) GetMatchingCheckoutBySmartUrl(rawInput string) (checkout string, application string, path string, found bool, ...)
  • func (s *QueryService) GetSeenFailedSessions() []*models.Session
  • func (s *QueryService) GetSession(uuid string) *models.Session
  • func (s *QueryService) GetSessionIntegrationsStatus(uuid string) (*integrations_output_models.Session, error)
  • func (s *QueryService) GetSessionLogsAndStatus(uuid string, lastLogUUID string) ([]models.Log, models.SessionStatus, error)
  • func (s *QueryService) GetSessionMetrics(uuid string) ([]models.Metric, error)
  • func (s *QueryService) GetSessionStatus(uuid string) (output.SessionStatus, error)
  • func (s *QueryService) GetSessionTTY(uuid string) (utils.TTY, models.SessionStatus, error)
  • func (s *QueryService) MarkFailedSessionAsSeen(uuid string)
• type RequestService
  • func NewRequestService(environment utils.Environment, sessionStorage *storage.Session, ...) *RequestService
  • func (s *RequestService) NewSession(checkout string, app string, detectBranchOrTag bool) (*queues.SessionBuildResult, error)
  • func (s *RequestService) SessionDeletion(uuid string) error
• type StaticService
  • func NewStaticService(environment utils.Environment, logger logging.Logger, ...) *StaticService
  • func (s *StaticService) GetManager() []byte
  • func (s *StaticService) GetSessionHelperContent() string
  • func (s *StaticService) LoadSessionHelper()
  • func (s *StaticService) SetSessionHelperContent(helper string)

Variables

var (
	ErrApplicationNotFound error = errors.New("Application not found")
	ErrSessionNotFound     error = errors.New("Session not found")
	ErrSessionIsNotAlive   error = errors.New("Session is not alive")
)

Types

type AliasingService

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

func NewAliasingService

func NewAliasingService(
	sessionStorage *storage.Session,
) *AliasingService

func (*AliasingService) Next

func (a *AliasingService) Next() string

type QueryService

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

func NewQueryService

func NewQueryService(environment utils.Environment, storage *storage.Session, applicationStorage *storage.Application, log logging.Logger) *QueryService

func (*QueryService) GetAliveSession

func (s *QueryService) GetAliveSession(uuid string) *models.Session

func (*QueryService) GetAllAliveSessions

func (s *QueryService) GetAllAliveSessions() []*models.Session

func (*QueryService) GetAllApplications

func (s *QueryService) GetAllApplications() []*models.Application

func (*QueryService) GetFailedSession

func (s *QueryService) GetFailedSession(uuid string) (*models.Session, error)

Retrieve a failed session, search through seen and unseen

func (*QueryService) GetFailedSessionLogs

func (s *QueryService) GetFailedSessionLogs(uuid string) ([]models.Log, error)

func (*QueryService) GetFailedSessions

func (s *QueryService) GetFailedSessions() []*models.Session

func (*QueryService) GetMatchingCheckoutByForwardLink

func (s *QueryService) GetMatchingCheckoutByForwardLink(rawInput string) (checkout string, application string, path string, found bool)

func (*QueryService) GetMatchingCheckoutByPermalink

func (s *QueryService) GetMatchingCheckoutByPermalink(rawInput string) (checkout string, application string, path string, found bool)

func (*QueryService) GetMatchingCheckoutBySmartUrl

func (s *QueryService) GetMatchingCheckoutBySmartUrl(rawInput string) (checkout string, application string, path string, found bool, foundSession *models.Session)

GetMatchingCheckoutBySmartUrl The rawInput parameter is without prefix "/s/"

func (*QueryService) GetSeenFailedSessions

func (s *QueryService) GetSeenFailedSessions() []*models.Session

func (*QueryService) GetSession

func (s *QueryService) GetSession(uuid string) *models.Session

GetSession returns a session by its UUID, undependently from its status

func (*QueryService) GetSessionIntegrationsStatus

func (s *QueryService) GetSessionIntegrationsStatus(uuid string) (*integrations_output_models.Session, error)

func (*QueryService) GetSessionLogsAndStatus

func (s *QueryService) GetSessionLogsAndStatus(uuid string, lastLogUUID string) ([]models.Log, models.SessionStatus, error)

func (*QueryService) GetSessionMetrics

func (s *QueryService) GetSessionMetrics(uuid string) ([]models.Metric, error)

func (*QueryService) GetSessionStatus

func (s *QueryService) GetSessionStatus(uuid string) (output.SessionStatus, error)

func (*QueryService) GetSessionTTY

func (s *QueryService) GetSessionTTY(uuid string) (utils.TTY, models.SessionStatus, error)

func (*QueryService) MarkFailedSessionAsSeen

func (s *QueryService) MarkFailedSessionAsSeen(uuid string)

type RequestService

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

func NewRequestService

func NewRequestService(
	environment utils.Environment,
	sessionStorage *storage.Session,
	applicationStorage *storage.Application,
	mediator *background.Mediator) *RequestService

func (*RequestService) NewSession

func (s *RequestService) NewSession(checkout string, app string, detectBranchOrTag bool) (*queues.SessionBuildResult, error)

NewSession requests for a new session to be built at a specific checkout (can be a commit ID, a branch name or a tag) for a specific app If detectBranchOrTag is set to true, if the checkout is a commit ID, the builder will try to detect if the commit belongs to a branch or a tag

func (*RequestService) SessionDeletion

func (s *RequestService) SessionDeletion(uuid string) error

type StaticService

type StaticService struct {
	utils.RWLocker

	FileSystem fs.FS
	// contains filtered or unexported fields
}

func NewStaticService

func NewStaticService(
	environment utils.Environment,
	logger logging.Logger,
	configuration *models.RootConfiguration,
) *StaticService

func (*StaticService) GetManager

func (s *StaticService) GetManager() []byte

func (*StaticService) GetSessionHelperContent

func (s *StaticService) GetSessionHelperContent() string

func (*StaticService) LoadSessionHelper

func (s *StaticService) LoadSessionHelper()

func (*StaticService) SetSessionHelperContent

func (s *StaticService) SetSessionHelperContent(helper string)