event

type AddDestinationFailedEvent ¶

type AddDestinationFailedEvent struct {
	URL string
	Err error
}

AddDestinationFailedEvent is emitted when a destination fails to be added.

func (e AddDestinationFailedEvent) EventName() Name

type AppStateChangedEvent ¶

type AppStateChangedEvent struct {
	State domain.AppState
}

AppStateChangedEvent is emitted when the application state changes.

func (e AppStateChangedEvent) EventName() Name

type Bus ¶

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

Bus is an event bus.

func NewBus(logger *slog.Logger) *Bus

func (b *Bus) Deregister(clientID ClientID)

func (b *Bus) Register() (ClientID, <-chan Event)

func (b *Bus) Send(evt Event)

func (b *Bus) SendTo(clientID ClientID, evt Event)

type ClientID ¶ added in v0.0.12

type ClientID string

ClientID is a unique identifier for a client.

func NewClientID() ClientID

type Command ¶

type Command interface {
	Name() string
}

Command is an interface for commands that can be triggered by the terminal user interface.

type CommandAddDestination ¶

type CommandAddDestination struct {
	DestinationName string
	URL             string
}

CommandAddDestination adds a destination.

func (c CommandAddDestination) Name() string

type CommandCloseOtherInstance ¶

type CommandCloseOtherInstance struct{}

CommandCloseOtherInstance closes the other instance of the application.

func (c CommandCloseOtherInstance) Name() string

type CommandKillServer ¶ added in v0.0.10

type CommandKillServer struct{}

CommandKillServer kills the server.

func (c CommandKillServer) Name() string

type CommandListDestinations ¶ added in v0.0.12

type CommandListDestinations struct{}

CommandListDestinations lists all destinations.

func (c CommandListDestinations) Name() string

type CommandRemoveDestination ¶

type CommandRemoveDestination struct {
	ID    uuid.UUID
	Force bool // Remove the destination even if it is running.
}

CommandRemoveDestination removes a destination.

func (c CommandRemoveDestination) Name() string

type CommandStartDestination ¶

type CommandStartDestination struct {
	ID uuid.UUID
}

CommandStartDestination starts a destination.

func (c CommandStartDestination) Name() string

type CommandStopDestination ¶

type CommandStopDestination struct {
	ID uuid.UUID
}

CommandStopDestination stops a destination.

func (c CommandStopDestination) Name() string

type CommandUpdateDestination ¶ added in v0.0.12

type CommandUpdateDestination struct {
	ID              uuid.UUID
	DestinationName optional.V[string]
	URL             optional.V[string]
}

CommandUpdateDestination updates a destination.

func (c CommandUpdateDestination) Name() string

type DestinationAddedEvent ¶

type DestinationAddedEvent struct {
	ID uuid.UUID
}

DestinationAddedEvent is emitted when a destination is successfully added.

func (e DestinationAddedEvent) EventName() Name

type DestinationRemovedEvent ¶

type DestinationRemovedEvent struct {
	ID uuid.UUID
}

DestinationRemovedEvent is emitted when a destination is successfully removed.

func (e DestinationRemovedEvent) EventName() Name

type DestinationStartedEvent ¶ added in v0.0.12

type DestinationStartedEvent struct {
	ID uuid.UUID
}

DestinationStartedEvent is emitted when a destination starts successfully.

func (e DestinationStartedEvent) EventName() Name

type DestinationStoppedEvent ¶ added in v0.0.12

type DestinationStoppedEvent struct {
	ID uuid.UUID
}

DestinationStoppedEvent is emitted when a destination stops successfully.

func (e DestinationStoppedEvent) EventName() Name

type DestinationStreamExitedEvent ¶

type DestinationStreamExitedEvent struct {
	ID   uuid.UUID
	Name string
	Err  error
}

DestinationStreamExitedEvent is emitted when a destination goes off-air unexpectedly.

func (e DestinationStreamExitedEvent) EventName() Name

type DestinationUpdatedEvent ¶ added in v0.0.12

type DestinationUpdatedEvent struct {
	ID uuid.UUID
}

DestinationUpdatedEvent is emitted when a destination is successfully updated.

func (e DestinationUpdatedEvent) EventName() Name

type DestinationsListedEvent ¶ added in v0.0.12

type DestinationsListedEvent struct {
	Destinations []domain.Destination
}

DestinationsListedEvent is emitted when the list of destinations is successfully retrieved.

func (e DestinationsListedEvent) EventName() Name

type Event ¶

type Event interface {
	EventName() Name
}

Event represents something which happened in the appllication.

type FatalErrorOccurredEvent ¶

type FatalErrorOccurredEvent struct {
	Message string
}

FatalErrorOccurredEvent is emitted when a fatal application error occurs.

func (e FatalErrorOccurredEvent) EventName() Name

type ListDestinationsFailedEvent ¶ added in v0.0.12

type ListDestinationsFailedEvent struct {
	Err error
}

ListDestinationsFailedEvent is emitted when the list of destinations fails to be retrieved.

func (e ListDestinationsFailedEvent) EventName() Name

type MediaServerStartedEvent ¶

type MediaServerStartedEvent struct{}

MediaServerStartedEvent is emitted when the mediaserver component starts successfully.

func (e MediaServerStartedEvent) EventName() Name

type Name ¶

type Name string

const (
	EventNameAppStateChanged         Name = "app_state_changed"
	EventNameDestinationsListed      Name = "destinations_listed"
	EventNameListDestinationsFailed  Name = "list_destinations_failed"
	EventNameDestinationAdded        Name = "destination_added"
	EventNameAddDestinationFailed    Name = "add_destination_failed"
	EventNameDestinationUpdated      Name = "destination_updated"
	EventNameUpdateDestinationFailed Name = "update_destination_failed"
	EventNameDestinationStreamExited Name = "destination_stream_exited"
	EventNameDestinationStarted      Name = "destination_started"
	EventNameStartDestinationFailed  Name = "start_destination_failed"
	EventNameDestinationStopped      Name = "destination_stopped"
	EventNameStopDestinationFailed   Name = "stop_destination_failed"
	EventNameDestinationRemoved      Name = "destination_removed"
	EventNameRemoveDestinationFailed Name = "remove_destination_failed"
	EventNameFatalErrorOccurred      Name = "fatal_error_occurred"
	EventNameOtherInstanceDetected   Name = "other_instance_detected"
	EventNameMediaServerStarted      Name = "media_server_started"
)

type OtherInstanceDetectedEvent ¶

type OtherInstanceDetectedEvent struct{}

OtherInstanceDetectedEvent is emitted when the app launches and detects another instance.

func (e OtherInstanceDetectedEvent) EventName() Name

type RemoveDestinationFailedEvent ¶

type RemoveDestinationFailedEvent struct {
	ID  uuid.UUID
	Err error
}

RemoveDestinationFailedEvent is emitted when a destination fails to be removed.

func (e RemoveDestinationFailedEvent) EventName() Name

type StartDestinationFailedEvent ¶

type StartDestinationFailedEvent struct {
	ID  uuid.UUID
	Err error
}

StartDestinationFailedEvent is emitted when a destination fails to start.

func (e StartDestinationFailedEvent) EventName() Name

type StopDestinationFailedEvent ¶ added in v0.0.12

type StopDestinationFailedEvent struct {
	ID  uuid.UUID
	Err error
}

StopDestinationFailedEvent is emitted when a destination fails to stop.

func (e StopDestinationFailedEvent) EventName() Name

type UpdateDestinationFailedEvent ¶ added in v0.0.12

type UpdateDestinationFailedEvent struct {
	ID  uuid.UUID
	Err error
}

UpdateDestinationFailedEvent is emitted when a destination fails to be updated.

func (e UpdateDestinationFailedEvent) EventName() Name