Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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
type IncomingAppspaceID ¶
type IncomingAppspaceID struct {
AppspaceID domain.AppspaceID `json:"appspace_id"`
}
IncomingAppspaceID is json encoded payload to subscribe to appspace status
type IncomingSubscribeApp ¶
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
Click to show internal directories.
Click to hide internal directories.