events

Documentation

Index

• type AppspaceFilesEvents
  • func (e *AppspaceFilesEvents) Send(appspaceID domain.AppspaceID)
  • func (e *AppspaceFilesEvents) Subscribe(ch 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 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)

Types

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(ch 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 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