events

package
v0.14.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 22, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

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 AppspaceTSNetModelEvents added in v0.14.0 

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

////////////////////////////////////

func (*AppspaceTSNetModelEvents) Send added in v0.14.0 

func (e *AppspaceTSNetModelEvents) Send(data domain.AppspaceTSNetModelEvent)

func (*AppspaceTSNetModelEvents) Subscribe added in v0.14.0 

func (e *AppspaceTSNetModelEvents) Subscribe() <-chan domain.AppspaceTSNetModelEvent

func (*AppspaceTSNetModelEvents) Unsubscribe added in v0.14.0 

func (e *AppspaceTSNetModelEvents) Unsubscribe(ch <-chan domain.AppspaceTSNetModelEvent)

type AppspaceTSNetPeersEvents added in v0.14.0 

type AppspaceTSNetPeersEvents struct {
	Relations interface {
		GetAppspaceOwnerID(appspaceID domain.AppspaceID) (domain.UserID, bool)
	} `checkinject:"required"`
	// contains filtered or unexported fields
}

Appspace TSNet Users/peers changed notification It merely sends the appspace ID of the appspace whose peers changed.

func (*AppspaceTSNetPeersEvents) Send added in v0.14.0 

func (e *AppspaceTSNetPeersEvents) Send(appspaceID domain.AppspaceID)

func (*AppspaceTSNetPeersEvents) Subscribe added in v0.14.0 

func (e *AppspaceTSNetPeersEvents) Subscribe() <-chan domain.AppspaceID

func (*AppspaceTSNetPeersEvents) SubscribeOwner added in v0.14.0 

func (e *AppspaceTSNetPeersEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.AppspaceID

func (*AppspaceTSNetPeersEvents) Unsubscribe added in v0.14.0 

func (e *AppspaceTSNetPeersEvents) Unsubscribe(ch <-chan domain.AppspaceID)

type AppspaceTSNetStatusEvents added in v0.14.0 

type AppspaceTSNetStatusEvents struct {
	Relations interface {
		GetAppspaceOwnerID(appspaceID domain.AppspaceID) (domain.UserID, bool)
	} `checkinject:"required"`
	// contains filtered or unexported fields
}

/////////////////

func (*AppspaceTSNetStatusEvents) Send added in v0.14.0 

func (e *AppspaceTSNetStatusEvents) Send(data domain.TSNetAppspaceStatus)

func (*AppspaceTSNetStatusEvents) Subscribe added in v0.14.0 

func (e *AppspaceTSNetStatusEvents) Subscribe() <-chan domain.TSNetAppspaceStatus

func (*AppspaceTSNetStatusEvents) SubscribeOwner added in v0.14.0 

func (e *AppspaceTSNetStatusEvents) SubscribeOwner(ownerID domain.UserID) <-chan domain.TSNetAppspaceStatus

func (*AppspaceTSNetStatusEvents) Unsubscribe added in v0.14.0 

func (e *AppspaceTSNetStatusEvents) Unsubscribe(ch <-chan domain.TSNetAppspaceStatus)

type DataTypes added in v0.13.0 

type DataTypes interface {
	struct{} |
		domain.TSNetStatus |
		domain.AppURLData |
		domain.AppspaceID |
		domain.AppspaceStatusEvent |
		domain.AppspaceTSNetModelEvent |
		domain.TSNetAppspaceStatus |
		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)

type Relations added in v0.14.0 

type Relations struct {
	AppspaceModel interface {
		GetFromID(domain.AppspaceID) (*domain.Appspace, error)
	} `checkinject:"required"`
}

Relations returns related identifiers to the passed identifier.

func (*Relations) GetAppspaceOwnerID added in v0.14.0 

func (r *Relations) GetAppspaceOwnerID(appspaceID domain.AppspaceID) (domain.UserID, bool)

type SubscribeIDs added in v0.13.0 

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

type UserTSNetPeersEvents added in v0.14.0 

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

UserTSNetPeersEvents peers changed notification It sends an empty struct{}

func (*UserTSNetPeersEvents) Send added in v0.14.0 

func (e *UserTSNetPeersEvents) Send()

func (*UserTSNetPeersEvents) Subscribe added in v0.14.0 

func (e *UserTSNetPeersEvents) Subscribe() <-chan struct{}

func (*UserTSNetPeersEvents) Unsubscribe added in v0.14.0 

func (e *UserTSNetPeersEvents) Unsubscribe(ch <-chan struct{})

type UserTSNetStatusEvents added in v0.14.0 

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

func (*UserTSNetStatusEvents) Send added in v0.14.0 

func (e *UserTSNetStatusEvents) Send(data domain.TSNetStatus)

func (*UserTSNetStatusEvents) Subscribe added in v0.14.0 

func (e *UserTSNetStatusEvents) Subscribe() <-chan domain.TSNetStatus

func (*UserTSNetStatusEvents) Unsubscribe added in v0.14.0 

func (e *UserTSNetStatusEvents) Unsubscribe(ch <-chan domain.TSNetStatus)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.