twineservices

Documentation

Index

• type AppGetterService
  • func (s *AppGetterService) HandleMessage(m twine.ReceivedMessageI)
  • func (s *AppGetterService) Start(authUser domain.UserID, t *twine.Twine)
• type AppspaceLogService
  • func (s *AppspaceLogService) Start(authUser domain.UserID, t *twine.Twine) domain.TwineServiceI
• type AppspaceStatusService
  • func (s *AppspaceStatusService) HandleMessage(m twine.ReceivedMessageI)
  • func (s *AppspaceStatusService) Start(authUser domain.UserID, t *twine.Twine)
• type IncomingAppspaceID
• type IncomingSubscribeApp
• type IncomingSubscribeAppspace
• type MigrationJobService
  • func (s *MigrationJobService) Start(authUser domain.UserID, t *twine.Twine) domain.TwineServiceI

Types

type AppGetterService

type AppGetterService struct {
	AppGetter interface {
		GetUser(key domain.AppGetKey) (domain.UserID, bool)
		SubscribeKey(key domain.AppGetKey) (domain.AppGetEvent, <-chan domain.AppGetEvent)
		Unsubscribe(ch <-chan domain.AppGetEvent)
	} `checkinject:"required"`
	// contains filtered or unexported fields
}

func (*AppGetterService) HandleMessage

func (s *AppGetterService) HandleMessage(m twine.ReceivedMessageI)

HandleMessage handles incoming twine message

func (*AppGetterService) Start

func (s *AppGetterService) Start(authUser domain.UserID, t *twine.Twine)

Start

type AppspaceLogService

type AppspaceLogService struct {
	AppspaceModel interface {
		GetFromID(domain.AppspaceID) (*domain.Appspace, error)
	} `checkinject:"required"`
	AppModel interface {
		GetFromID(appID domain.AppID) (*domain.App, error)
		GetVersion(appID domain.AppID, version domain.Version) (*domain.AppVersion, error)
	} `checkinject:"required"`
	AppspaceLogger interface {
		Get(appspaceID domain.AppspaceID) domain.LoggerI
	} `checkinject:"required"`
	AppLogger interface {
		Get(string) domain.LoggerI
	} `checkinject:"required"`
}

MigrationJobService offers subscription to app or appspace logs

func (*AppspaceLogService) Start

func (s *AppspaceLogService) Start(authUser domain.UserID, t *twine.Twine) domain.TwineServiceI

Start creates listeners and then shuts everything down when twine exits

type AppspaceStatusService

type AppspaceStatusService struct {
	AppspaceModel interface {
		GetFromID(domain.AppspaceID) (*domain.Appspace, error)
	} `checkinject:"required"`
	AppspaceStatus interface {
		Track(domain.AppspaceID) domain.AppspaceStatusEvent
	} `checkinject:"required"`
	AppspaceStatusEvents interface {
		Subscribe(domain.AppspaceID, chan<- domain.AppspaceStatusEvent)
		Unsubscribe(domain.AppspaceID, chan<- domain.AppspaceStatusEvent)
	} `checkinject:"required"`
	// contains filtered or unexported fields
}

AppspaceStatusService offers subscription to appspace status by appspace id

func (*AppspaceStatusService) HandleMessage

func (s *AppspaceStatusService) HandleMessage(m twine.ReceivedMessageI)

HandleMessage handles incoming twine message

func (*AppspaceStatusService) Start

func (s *AppspaceStatusService) Start(authUser domain.UserID, t *twine.Twine)

Start creates listeners and then shuts everything down when twine exits

type IncomingAppspaceID

type IncomingAppspaceID struct {
	AppspaceID domain.AppspaceID `json:"appspace_id"`
}

IncomingAppspaceID is json encoded payload to subscribe to appspace status

type IncomingSubscribeApp

type IncomingSubscribeApp struct {
	AppID   domain.AppID   `json:"app_id"`
	Version domain.Version `json:"version"`
}

type IncomingSubscribeAppspace

type IncomingSubscribeAppspace struct {
	AppspaceID domain.AppspaceID `json:"appspace_id"`
}

IncomingSubscribeAppspace is json encoded payload to subscribe to appspace status

type MigrationJobService

type MigrationJobService struct {
	AppspaceModel interface {
		GetFromID(domain.AppspaceID) (*domain.Appspace, error)
	} `checkinject:"required"`
	MigrationJobModel interface {
		GetRunning() ([]domain.MigrationJob, error)
	} `checkinject:"required"`
	MigrationJobEvents interface {
		SubscribeAppspace(domain.AppspaceID) <-chan domain.MigrationJob
		Unsubscribe(<-chan domain.MigrationJob)
	} `checkinject:"required"`
}

MigrationJobService offers subscription to appspace status by appspace id

func (*MigrationJobService) Start

func (s *MigrationJobService) Start(authUser domain.UserID, t *twine.Twine) domain.TwineServiceI

Start creates listeners and then shuts everything down when twine exits