events

Documentation

Index

• 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
  • func (e *AppspaceFilesEvents) Send(appspaceID domain.AppspaceID)
  • func (e *AppspaceFilesEvents) Subscribe() <-chan domain.AppspaceID
  • func (e *AppspaceFilesEvents) Unsubscribe(ch <-chan domain.AppspaceID)
• type AppspaceRouteHitEvents
  • func (e *AppspaceRouteHitEvents) Send(routeEvent *domain.AppspaceRouteHitEvent)
  • func (e *AppspaceRouteHitEvents) Subscribe(ch chan<- *domain.AppspaceRouteHitEvent)
  • func (e *AppspaceRouteHitEvents) Unsubscribe(ch chan<- *domain.AppspaceRouteHitEvent)
• type AppspaceStatusEvents
  • func (e *AppspaceStatusEvents) Send(appspaceID domain.AppspaceID, event domain.AppspaceStatusEvent)
  • func (e *AppspaceStatusEvents) Subscribe(appspaceID domain.AppspaceID, ch chan<- domain.AppspaceStatusEvent)
  • func (e *AppspaceStatusEvents) Unsubscribe(appspaceID domain.AppspaceID, ch chan<- domain.AppspaceStatusEvent)
  • func (e *AppspaceStatusEvents) UnsubscribeChannel(ch chan<- domain.AppspaceStatusEvent)
• type DataTypes
• type MigrationJobEvents
  • func (e *MigrationJobEvents) Send(event domain.MigrationJob)
  • func (e *MigrationJobEvents) Subscribe() <-chan domain.MigrationJob
  • func (e *MigrationJobEvents) SubscribeAppspace(appspaceID domain.AppspaceID) <-chan domain.MigrationJob
  • func (e *MigrationJobEvents) Unsubscribe(ch <-chan domain.MigrationJob)
• type SubscribeIDs

Types

type AppUrlDataEvents

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

AppUrlDataEvents sends AppURLData

func (*AppUrlDataEvents) Send

func (e *AppUrlDataEvents) Send(ownerID domain.UserID, data domain.AppURLData)

func (*AppUrlDataEvents) SubscribeApp

func (e *AppUrlDataEvents) SubscribeApp(appID domain.AppID) <-chan domain.AppURLData

func (*AppUrlDataEvents) SubscribeOwner

func (e *AppUrlDataEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppURLData

func (*AppUrlDataEvents) Unsubscribe

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
}

AppspaceStatusEvents handles appspace pause and unpause events

func (*AppspaceStatusEvents) Send

func (e *AppspaceStatusEvents) Send(appspaceID domain.AppspaceID, event domain.AppspaceStatusEvent)

Send sends an appspace status event

func (*AppspaceStatusEvents) Subscribe

func (e *AppspaceStatusEvents) Subscribe(appspaceID domain.AppspaceID, ch chan<- domain.AppspaceStatusEvent)

Subscribe to an event to know when the status of an appspace has changed

func (*AppspaceStatusEvents) Unsubscribe

func (e *AppspaceStatusEvents) Unsubscribe(appspaceID domain.AppspaceID, ch chan<- domain.AppspaceStatusEvent)

Unsubscribe to the event

func (*AppspaceStatusEvents) UnsubscribeChannel

func (e *AppspaceStatusEvents) UnsubscribeChannel(ch chan<- domain.AppspaceStatusEvent)

UnsubscribeChannel removes the channel from all subscriptions

type DataTypes

type DataTypes interface {
	domain.AppURLData | domain.AppspaceID
}

type MigrationJobEvents

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

MigrationJobEvents forwards events related to migration jobs

func (*MigrationJobEvents) Send

func (e *MigrationJobEvents) Send(event domain.MigrationJob)

Send sends an appspace status event

func (*MigrationJobEvents) Subscribe

func (e *MigrationJobEvents) Subscribe() <-chan domain.MigrationJob

Subscribe to an event to know when the status of a migration has changed

func (*MigrationJobEvents) SubscribeAppspace

func (e *MigrationJobEvents) SubscribeAppspace(appspaceID domain.AppspaceID) <-chan domain.MigrationJob

SubscribeAppspace to an event to know when the status of a migration for an appspace has changed

func (*MigrationJobEvents) Unsubscribe

func (e *MigrationJobEvents) Unsubscribe(ch <-chan domain.MigrationJob)

Unsubscribe to the event

type SubscribeIDs

type SubscribeIDs interface {
	domain.UserID | domain.AppID | domain.AppspaceID
}