protocol

package
v0.0.15 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2025 License: AGPL-3.0-or-later Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddDestinationCommandToProto added in v0.0.12 

func AddDestinationCommandToProto(cmd event.CommandAddDestination) *pb.AddDestinationCommand

AddDestinationCommandToProto converts an AddDestinationCommand to a protobuf message.

func AddDestinationFailedEventToProto added in v0.0.12 

func AddDestinationFailedEventToProto(evt event.AddDestinationFailedEvent) *pb.AddDestinationFailedEvent

AddDestinationFailedEventToProto converts an AddDestinationFailedEvent to a protobuf message.

func AppStateChangedEventToProto added in v0.0.12 

func AppStateChangedEventToProto(evt event.AppStateChangedEvent) *pb.AppStateChangedEvent

AppStateChangedEventToProto converts an AppStateChangedEvent to a protobuf message.

func CloseOtherInstancesCommandToProto added in v0.0.12 

func CloseOtherInstancesCommandToProto(event.CommandCloseOtherInstance) *pb.CloseOtherInstancesCommand

CloseOtherInstancesCommandToProto converts a CloseOtherInstanceCommand to a protobuf message.

func CommandFromAddDestinationProto added in v0.0.12 

func CommandFromAddDestinationProto(cmd *pb.AddDestinationCommand) (event.Command, error)

CommandFromAddDestinationProto converts a protobuf AddDestinationCommand to a domain command.

func CommandFromCloseOtherInstancesProto added in v0.0.12 

func CommandFromCloseOtherInstancesProto(_ *pb.CloseOtherInstancesCommand) (event.Command, error)

CommandFromCloseOtherInstancesProto converts a protobuf CloseOtherInstancesCommand to a domain command.

func CommandFromKillServerProto added in v0.0.12 

func CommandFromKillServerProto(_ *pb.KillServerCommand) (event.Command, error)

CommandFromKillServerProto converts a protobuf KillServerCommand to a domain command.

func CommandFromListDestinationsProto added in v0.0.12 

func CommandFromListDestinationsProto(_ *pb.ListDestinationsCommand) (event.Command, error)

CommandFromListDestinationsProto converts a protobuf ListDestinationsCommand to a domain command.

func CommandFromRemoveDestinationProto added in v0.0.12 

func CommandFromRemoveDestinationProto(cmd *pb.RemoveDestinationCommand) (event.Command, error)

CommandFromRemoveDestinationProto converts a protobuf RemoveDestinationCommand to a domain command.

func CommandFromStartDestinationProto added in v0.0.12 

func CommandFromStartDestinationProto(cmd *pb.StartDestinationCommand) (event.Command, error)

CommandFromStartDestinationProto converts a protobuf StartDestinationCommand to a domain command.

func CommandFromStopDestinationProto added in v0.0.12 

func CommandFromStopDestinationProto(cmd *pb.StopDestinationCommand) (event.Command, error)

CommandFromStopDestinationProto converts a protobuf StopDestinationCommand to a domain command.

func CommandFromUpdateDestinationProto added in v0.0.12 

func CommandFromUpdateDestinationProto(cmd *pb.UpdateDestinationCommand) (event.Command, error)

CommandFromUpdateDestinationProto converts a protobuf UpdateDestinationCommand to a domain command.

func CommandFromWrappedProto added in v0.0.12 

func CommandFromWrappedProto(pbCmd *pb.Command) (event.Command, error)

CommandFromWrappedProto converts a wrapped protobuf message to a command. This is intended for processing commands from a streaming gRPC API where commands are represented in a oneof. For direct conversion from specific command types, use the CommandFrom*Proto functions.

func CommandToWrappedProto added in v0.0.12 

func CommandToWrappedProto(command event.Command) *pb.Command

CommandToWrappedProto converts a command to a wrapped protobuf message (inside pb.Command). For direct conversion to the specific command type, use the *CommandToProto functions.

func ContainerFromProto 

func ContainerFromProto(pbContainer *pb.Container) domain.Container

ContainerFromProto converts a protobuf Container to a domain.Container.

func ContainerToProto 

func ContainerToProto(c domain.Container) *pb.Container

ContainerToProto converts a domain.Container to a protobuf Container.

func DestinationAddedEventToProto added in v0.0.12 

func DestinationAddedEventToProto(evt event.DestinationAddedEvent) *pb.DestinationAddedEvent

DestinationAddedEventToProto converts a DestinationAddedEvent to a protobuf message.

func DestinationRemovedEventToProto added in v0.0.12 

func DestinationRemovedEventToProto(evt event.DestinationRemovedEvent) *pb.DestinationRemovedEvent

DestinationRemovedEventToProto converts a DestinationRemovedEvent to a protobuf message.

func DestinationStartedEventToProto added in v0.0.12 

func DestinationStartedEventToProto(evt event.DestinationStartedEvent) *pb.DestinationStartedEvent

DestinationStartedEventToProto converts a DestinationStartedEvent to a protobuf message.

func DestinationStatusToProto 

func DestinationStatusToProto(s domain.DestinationStatus) pb.Destination_Status

DestinationStatusToProto converts a domain.DestinationStatus to a pb.Destination_Status.

func DestinationStoppedEventToProto added in v0.0.12 

func DestinationStoppedEventToProto(evt event.DestinationStoppedEvent) *pb.DestinationStoppedEvent

DestinationStoppedEventToProto converts a DestinationStoppedEvent to a protobuf message.

func DestinationStreamExitedEventToProto added in v0.0.12 

func DestinationStreamExitedEventToProto(evt event.DestinationStreamExitedEvent) *pb.DestinationStreamExitedEvent

DestinationStreamExitedEventToProto converts a DestinationStreamExitedEvent to a protobuf message.

func DestinationToProto 

func DestinationToProto(d domain.Destination) *pb.Destination

DestinationToProto converts a domain.Destination to a protobuf Destination.

func DestinationUpdatedEventToProto added in v0.0.12 

func DestinationUpdatedEventToProto(evt event.DestinationUpdatedEvent) *pb.DestinationUpdatedEvent

DestinationUpdatedEventToProto converts a DestinationUpdatedEvent to a protobuf message.

func DestinationsListedEventToProto added in v0.0.12 

func DestinationsListedEventToProto(evt event.DestinationsListedEvent) *pb.DestinationsListedEvent

DestinationsListedEventToProto converts a DestinationsListedEvent to a protobuf message.

func DestinationsToProto 

func DestinationsToProto(inDests []domain.Destination) []*pb.Destination

DestinationsToProto converts a slice of domain.Destinations to a slice of protobuf Destinations.

func EventFromAddDestinationFailedProto added in v0.0.12 

func EventFromAddDestinationFailedProto(evt *pb.AddDestinationFailedEvent) (event.Event, error)

EventFromAddDestinationFailedProto converts a protobuf AddDestinationFailedEvent to a domain event.

func EventFromAppStateChangedProto added in v0.0.12 

func EventFromAppStateChangedProto(evt *pb.AppStateChangedEvent) (event.Event, error)

EventFromAppStateChangedProto converts a protobuf AppStateChangedEvent to a domain event.

func EventFromDestinationAddedProto added in v0.0.12 

func EventFromDestinationAddedProto(evt *pb.DestinationAddedEvent) (event.Event, error)

EventFromDestinationAddedProto converts a protobuf DestinationAddedEvent to a domain event.

func EventFromDestinationRemovedProto added in v0.0.12 

func EventFromDestinationRemovedProto(evt *pb.DestinationRemovedEvent) (event.Event, error)

EventFromDestinationRemovedProto converts a protobuf DestinationRemovedEvent to a domain event.

func EventFromDestinationStartedProto added in v0.0.12 

func EventFromDestinationStartedProto(evt *pb.DestinationStartedEvent) (event.Event, error)

EventFromDestinationStartedProto converts a protobuf DestinationStartedEvent to a domain event.

func EventFromDestinationStoppedProto added in v0.0.12 

func EventFromDestinationStoppedProto(evt *pb.DestinationStoppedEvent) (event.Event, error)

EventFromDestinationStoppedProto converts a protobuf DestinationStoppedEvent to a domain event.

func EventFromDestinationStreamExitedProto added in v0.0.12 

func EventFromDestinationStreamExitedProto(evt *pb.DestinationStreamExitedEvent) (event.Event, error)

EventFromDestinationStreamExitedProto converts a protobuf DestinationStreamExitedEvent to a domain event.

func EventFromDestinationUpdatedProto added in v0.0.12 

func EventFromDestinationUpdatedProto(evt *pb.DestinationUpdatedEvent) (event.Event, error)

EventFromDestinationUpdatedProto converts a protobuf DestinationUpdatedEvent to a domain event.

func EventFromDestinationsListedProto added in v0.0.12 

func EventFromDestinationsListedProto(evt *pb.DestinationsListedEvent) (event.Event, error)

EventFromDestinationsListedProto converts a protobuf DestinationsListedEvent to a domain event.

func EventFromFatalErrorProto added in v0.0.12 

func EventFromFatalErrorProto(evt *pb.FatalErrorEvent) (event.Event, error)

EventFromFatalErrorProto converts a protobuf FatalErrorEvent to a domain event.

func EventFromListDestinationsFailedProto added in v0.0.12 

func EventFromListDestinationsFailedProto(evt *pb.ListDestinationsFailedEvent) (event.Event, error)

EventFromListDestinationsFailedProto converts a protobuf ListDestinationsFailedEvent to a domain event.

func EventFromMediaServerStartedProto added in v0.0.12 

func EventFromMediaServerStartedProto(evt *pb.MediaServerStartedEvent) (event.Event, error)

EventFromMediaServerStartedProto converts a protobuf MediaServerStartedEvent to a domain event.

func EventFromOtherInstanceDetectedProto added in v0.0.12 

func EventFromOtherInstanceDetectedProto(_ *pb.OtherInstanceDetectedEvent) (event.Event, error)

EventFromOtherInstanceDetectedProto converts a protobuf OtherInstanceDetectedEvent to a domain event.

func EventFromRemoveDestinationFailedProto added in v0.0.12 

func EventFromRemoveDestinationFailedProto(evt *pb.RemoveDestinationFailedEvent) (event.Event, error)

EventFromRemoveDestinationFailedProto converts a protobuf RemoveDestinationFailedEvent to a domain event.

func EventFromStartDestinationFailedProto added in v0.0.12 

func EventFromStartDestinationFailedProto(evt *pb.StartDestinationFailedEvent) (event.Event, error)

EventFromStartDestinationFailedProto converts a protobuf StartDestinationFailedEvent to a domain event.

func EventFromStopDestinationFailedProto added in v0.0.12 

func EventFromStopDestinationFailedProto(evt *pb.StopDestinationFailedEvent) (event.Event, error)

EventFromStopDestinationFailedProto converts a protobuf StopDestinationFailedEvent to a domain event.

func EventFromUpdateDestinationFailedProto added in v0.0.12 

func EventFromUpdateDestinationFailedProto(evt *pb.UpdateDestinationFailedEvent) (event.Event, error)

EventFromUpdateDestinationFailedProto converts a protobuf UpdateDestinationFailedEvent to a domain event.

func EventFromWrappedProto added in v0.0.12 

func EventFromWrappedProto(pbEv *pb.Event) (event.Event, error)

EventFromWrappedProto converts a wrapped protobuf message to an event.

func EventToWrappedProto added in v0.0.12 

func EventToWrappedProto(ev event.Event) *pb.Event

EventToWrappedProto converts an event to a wrapped protobuf message (inside pb.Event). Used in the streaming gRPC API. Use specific event helper functions for direct conversion to protobuf messages.

func FatalErrorEventToProto added in v0.0.12 

func FatalErrorEventToProto(evt event.FatalErrorOccurredEvent) *pb.FatalErrorEvent

FatalErrorEventToProto converts a FatalErrorOccurredEvent to a protobuf message.

func KillServerCommandToProto added in v0.0.12 

func KillServerCommandToProto(event.CommandKillServer) *pb.KillServerCommand

KillServerCommandToProto converts a KillServerCommand to a protobuf message.

func ListDestinationsCommandToProto added in v0.0.12 

func ListDestinationsCommandToProto(event.CommandListDestinations) *pb.ListDestinationsCommand

ListDestinationsCommandToProto converts a ListDestinationsCommand to a protobuf message.

func ListDestinationsFailedEventToProto added in v0.0.12 

func ListDestinationsFailedEventToProto(evt event.ListDestinationsFailedEvent) *pb.ListDestinationsFailedEvent

ListDestinationsFailedEventToProto converts a ListDestinationsFailedEvent to a protobuf message.

func MediaServerStartedEventToProto added in v0.0.12 

func MediaServerStartedEventToProto(event.MediaServerStartedEvent) *pb.MediaServerStartedEvent

MediaServerStartedEventToProto converts a MediaServerStartedEvent to a protobuf message.

func OtherInstanceDetectedEventToProto added in v0.0.12 

func OtherInstanceDetectedEventToProto(_ event.OtherInstanceDetectedEvent) *pb.OtherInstanceDetectedEvent

OtherInstanceDetectedEventToProto converts an OtherInstanceDetectedEvent to a protobuf message.

func ProtoToDestinations 

func ProtoToDestinations(pbDests []*pb.Destination) ([]domain.Destination, error)

ProtoToDestinations converts a slice of protobuf Destinations to a slice of domain.Destinations.

func RemoveDestinationCommandToProto added in v0.0.12 

func RemoveDestinationCommandToProto(cmd event.CommandRemoveDestination) *pb.RemoveDestinationCommand

RemoveDestinationCommandToProto converts a RemoveDestinationCommand to a protobuf message.

func RemoveDestinationFailedEventToProto added in v0.0.12 

func RemoveDestinationFailedEventToProto(evt event.RemoveDestinationFailedEvent) *pb.RemoveDestinationFailedEvent

RemoveDestinationFailedEventToProto converts a RemoveDestinationFailedEvent to a protobuf message.

func StartDestinationCommandToProto added in v0.0.12 

func StartDestinationCommandToProto(cmd event.CommandStartDestination) *pb.StartDestinationCommand

StartDestinationCommandToProto converts a StartDestinationCommand to a protobuf message.

func StartDestinationFailedEventToProto added in v0.0.12 

func StartDestinationFailedEventToProto(evt event.StartDestinationFailedEvent) *pb.StartDestinationFailedEvent

StartDestinationFailedEventToProto converts a StartDestinationFailedEvent to a protobuf message.

func StopDestinationCommandToProto added in v0.0.12 

func StopDestinationCommandToProto(cmd event.CommandStopDestination) *pb.StopDestinationCommand

StopDestinationCommandToProto converts a StopDestinationCommand to a protobuf message.

func StopDestinationFailedEventToProto added in v0.0.12 

func StopDestinationFailedEventToProto(evt event.StopDestinationFailedEvent) *pb.StopDestinationFailedEvent

StopDestinationFailedEventToProto converts a StopDestinationFailedEvent to a protobuf message.

func UpdateDestinationCommandToProto added in v0.0.12 

func UpdateDestinationCommandToProto(cmd event.CommandUpdateDestination) *pb.UpdateDestinationCommand

UpdateDestinationCommandToProto converts an UpdateDestinationCommand to a protobuf message.

func UpdateDestinationFailedEventToProto added in v0.0.12 

func UpdateDestinationFailedEventToProto(evt event.UpdateDestinationFailedEvent) *pb.UpdateDestinationFailedEvent

UpdateDestinationFailedEventToProto converts an UpdateDestinationFailedEvent to a protobuf message.

Types

This section is empty.

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.