Documentation
¶
Index ¶
- type AppGetterEvents
- type AppUrlDataEvents
- func (e *AppUrlDataEvents) Send(ownerID domain.UserID, data domain.AppURLData)
- func (e *AppUrlDataEvents) SubscribeApp(appID domain.AppID) <-chan domain.AppURLData
- func (e *AppUrlDataEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppURLData
- func (e *AppUrlDataEvents) Unsubscribe(ch <-chan domain.AppURLData)
- type AppspaceFilesEvents
- type AppspaceRouteHitEvents
- type AppspaceStatusEvents
- func (e *AppspaceStatusEvents) Send(data domain.AppspaceStatusEvent)
- func (e *AppspaceStatusEvents) Subscribe() <-chan domain.AppspaceStatusEvent
- func (e *AppspaceStatusEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppspaceStatusEvent
- func (e *AppspaceStatusEvents) Unsubscribe(ch <-chan domain.AppspaceStatusEvent)
- type DataTypes
- type MigrationJobEvents
- type SubscribeIDs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppGetterEvents ¶ added in v0.13.3
type AppGetterEvents struct {
// contains filtered or unexported fields
}
AppGetterEvents
func (*AppGetterEvents) Send ¶ added in v0.13.3
func (e *AppGetterEvents) Send(data domain.AppGetEvent)
func (*AppGetterEvents) SubscribeOwner ¶ added in v0.13.3
func (e *AppGetterEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppGetEvent
func (*AppGetterEvents) Unsubscribe ¶ added in v0.13.3
func (e *AppGetterEvents) Unsubscribe(ch <-chan domain.AppGetEvent)
type AppUrlDataEvents ¶ added in v0.13.0
type AppUrlDataEvents struct {
// contains filtered or unexported fields
}
AppUrlDataEvents sends AppURLData
func (*AppUrlDataEvents) Send ¶ added in v0.13.0
func (e *AppUrlDataEvents) Send(ownerID domain.UserID, data domain.AppURLData)
func (*AppUrlDataEvents) SubscribeApp ¶ added in v0.13.0
func (e *AppUrlDataEvents) SubscribeApp(appID domain.AppID) <-chan domain.AppURLData
func (*AppUrlDataEvents) SubscribeOwner ¶ added in v0.13.0
func (e *AppUrlDataEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppURLData
func (*AppUrlDataEvents) Unsubscribe ¶ added in v0.13.0
func (e *AppUrlDataEvents) Unsubscribe(ch <-chan domain.AppURLData)
type AppspaceFilesEvents ¶
type AppspaceFilesEvents struct {
// contains filtered or unexported fields
}
AppspaceFilesEvents notify subscribers that appsapce files have been written to outside of normal appspace use. Usually this means they were imported, or a backup restored
func (*AppspaceFilesEvents) Send ¶
func (e *AppspaceFilesEvents) Send(appspaceID domain.AppspaceID)
Send sends an appspace paused or unpaused event
func (*AppspaceFilesEvents) Subscribe ¶
func (e *AppspaceFilesEvents) Subscribe() <-chan domain.AppspaceID
Subscribe to an event for when an appspace is paused or unpaused
func (*AppspaceFilesEvents) Unsubscribe ¶
func (e *AppspaceFilesEvents) Unsubscribe(ch <-chan domain.AppspaceID)
Unsubscribe to an event for when an appspace is paused or unpaused
type AppspaceRouteHitEvents ¶
type AppspaceRouteHitEvents struct {
// contains filtered or unexported fields
}
AppspaceRouteHitEvents handles appspace pause and unpause events
func (*AppspaceRouteHitEvents) Send ¶
func (e *AppspaceRouteHitEvents) Send(routeEvent *domain.AppspaceRouteHitEvent)
Send sends an appspace paused or unpaused event Event's timestamp is set if needed
func (*AppspaceRouteHitEvents) Subscribe ¶
func (e *AppspaceRouteHitEvents) Subscribe(ch chan<- *domain.AppspaceRouteHitEvent)
Subscribe to an event for when an appspace is paused or unpaused
func (*AppspaceRouteHitEvents) Unsubscribe ¶
func (e *AppspaceRouteHitEvents) Unsubscribe(ch chan<- *domain.AppspaceRouteHitEvent)
Unsubscribe to an event for when an appspace is paused or unpaused
type AppspaceStatusEvents ¶
type AppspaceStatusEvents struct {
// contains filtered or unexported fields
}
func (*AppspaceStatusEvents) Send ¶
func (e *AppspaceStatusEvents) Send(data domain.AppspaceStatusEvent)
func (*AppspaceStatusEvents) Subscribe ¶
func (e *AppspaceStatusEvents) Subscribe() <-chan domain.AppspaceStatusEvent
func (*AppspaceStatusEvents) SubscribeOwner ¶ added in v0.13.3
func (e *AppspaceStatusEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppspaceStatusEvent
func (*AppspaceStatusEvents) Unsubscribe ¶
func (e *AppspaceStatusEvents) Unsubscribe(ch <-chan domain.AppspaceStatusEvent)
type DataTypes ¶ added in v0.13.0
type DataTypes interface {
domain.AppURLData |
domain.AppspaceID |
domain.AppspaceStatusEvent |
domain.MigrationJob |
domain.AppGetEvent
}
type MigrationJobEvents ¶
type MigrationJobEvents struct {
// contains filtered or unexported fields
}
MigrationJobEvents forwards events related to migration jobs
func (*MigrationJobEvents) Send ¶
func (e *MigrationJobEvents) Send(data domain.MigrationJob)
func (*MigrationJobEvents) Subscribe ¶
func (e *MigrationJobEvents) Subscribe() <-chan domain.MigrationJob
func (*MigrationJobEvents) SubscribeOwner ¶ added in v0.13.3
func (e *MigrationJobEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.MigrationJob
func (*MigrationJobEvents) Unsubscribe ¶
func (e *MigrationJobEvents) Unsubscribe(ch <-chan domain.MigrationJob)