Versions in this module Expand all Collapse all v0 v0.0.15 Jul 27, 2025 Changes in this version + var Destination_Status_name = map[int32]string + var Destination_Status_value = map[string]int32 + var File_internalapi_v1_api_proto protoreflect.FileDescriptor + var File_internalapi_v1_command_proto protoreflect.FileDescriptor + var File_internalapi_v1_domain_proto protoreflect.FileDescriptor + var File_internalapi_v1_event_proto protoreflect.FileDescriptor + type AddDestinationCommand struct + Name string + Url string + func (*AddDestinationCommand) Descriptor() ([]byte, []int) + func (*AddDestinationCommand) ProtoMessage() + func (x *AddDestinationCommand) GetName() string + func (x *AddDestinationCommand) GetUrl() string + func (x *AddDestinationCommand) ProtoReflect() protoreflect.Message + func (x *AddDestinationCommand) Reset() + func (x *AddDestinationCommand) String() string + type AddDestinationFailedEvent struct + Error string + Url string + func (*AddDestinationFailedEvent) Descriptor() ([]byte, []int) + func (*AddDestinationFailedEvent) ProtoMessage() + func (x *AddDestinationFailedEvent) GetError() string + func (x *AddDestinationFailedEvent) GetUrl() string + func (x *AddDestinationFailedEvent) ProtoReflect() protoreflect.Message + func (x *AddDestinationFailedEvent) Reset() + func (x *AddDestinationFailedEvent) String() string + type AddDestinationRequest struct + Command *AddDestinationCommand + func (*AddDestinationRequest) Descriptor() ([]byte, []int) + func (*AddDestinationRequest) ProtoMessage() + func (x *AddDestinationRequest) GetCommand() *AddDestinationCommand + func (x *AddDestinationRequest) ProtoReflect() protoreflect.Message + func (x *AddDestinationRequest) Reset() + func (x *AddDestinationRequest) String() string + type AddDestinationResponse struct + Result isAddDestinationResponse_Result + func (*AddDestinationResponse) Descriptor() ([]byte, []int) + func (*AddDestinationResponse) ProtoMessage() + func (x *AddDestinationResponse) GetError() *AddDestinationFailedEvent + func (x *AddDestinationResponse) GetOk() *DestinationAddedEvent + func (x *AddDestinationResponse) GetResult() isAddDestinationResponse_Result + func (x *AddDestinationResponse) ProtoReflect() protoreflect.Message + func (x *AddDestinationResponse) Reset() + func (x *AddDestinationResponse) String() string + type AddDestinationResponse_Error struct + Error *AddDestinationFailedEvent + type AddDestinationResponse_Ok struct + Ok *DestinationAddedEvent + type AppState struct + BuildInfo *BuildInfo + Destinations []*Destination + Source *Source + func (*AppState) Descriptor() ([]byte, []int) + func (*AppState) ProtoMessage() + func (x *AppState) GetBuildInfo() *BuildInfo + func (x *AppState) GetDestinations() []*Destination + func (x *AppState) GetSource() *Source + func (x *AppState) ProtoReflect() protoreflect.Message + func (x *AppState) Reset() + func (x *AppState) String() string + type AppStateChangedEvent struct + AppState *AppState + func (*AppStateChangedEvent) Descriptor() ([]byte, []int) + func (*AppStateChangedEvent) ProtoMessage() + func (x *AppStateChangedEvent) GetAppState() *AppState + func (x *AppStateChangedEvent) ProtoReflect() protoreflect.Message + func (x *AppStateChangedEvent) Reset() + func (x *AppStateChangedEvent) String() string + type AuthenticateRequest struct + func (*AuthenticateRequest) Descriptor() ([]byte, []int) + func (*AuthenticateRequest) ProtoMessage() + func (x *AuthenticateRequest) ProtoReflect() protoreflect.Message + func (x *AuthenticateRequest) Reset() + func (x *AuthenticateRequest) String() string + type AuthenticateResponse struct + func (*AuthenticateResponse) Descriptor() ([]byte, []int) + func (*AuthenticateResponse) ProtoMessage() + func (x *AuthenticateResponse) ProtoReflect() protoreflect.Message + func (x *AuthenticateResponse) Reset() + func (x *AuthenticateResponse) String() string + type BuildInfo struct + Commit string + Date string + GoVersion string + Version string + func (*BuildInfo) Descriptor() ([]byte, []int) + func (*BuildInfo) ProtoMessage() + func (x *BuildInfo) GetCommit() string + func (x *BuildInfo) GetDate() string + func (x *BuildInfo) GetGoVersion() string + func (x *BuildInfo) GetVersion() string + func (x *BuildInfo) ProtoReflect() protoreflect.Message + func (x *BuildInfo) Reset() + func (x *BuildInfo) String() string + type CloseOtherInstancesCommand struct + func (*CloseOtherInstancesCommand) Descriptor() ([]byte, []int) + func (*CloseOtherInstancesCommand) ProtoMessage() + func (x *CloseOtherInstancesCommand) ProtoReflect() protoreflect.Message + func (x *CloseOtherInstancesCommand) Reset() + func (x *CloseOtherInstancesCommand) String() string + type Command struct + CommandType isCommand_CommandType + func (*Command) Descriptor() ([]byte, []int) + func (*Command) ProtoMessage() + func (x *Command) GetAddDestination() *AddDestinationCommand + func (x *Command) GetCloseOtherInstances() *CloseOtherInstancesCommand + func (x *Command) GetCommandType() isCommand_CommandType + func (x *Command) GetKillServer() *KillServerCommand + func (x *Command) GetListDestinations() *ListDestinationsCommand + func (x *Command) GetRemoveDestination() *RemoveDestinationCommand + func (x *Command) GetStartDestination() *StartDestinationCommand + func (x *Command) GetStartHandshake() *StartHandshakeCommand + func (x *Command) GetStopDestination() *StopDestinationCommand + func (x *Command) GetUpdateDestination() *UpdateDestinationCommand + func (x *Command) ProtoReflect() protoreflect.Message + func (x *Command) Reset() + func (x *Command) String() string + type Command_AddDestination struct + AddDestination *AddDestinationCommand + type Command_CloseOtherInstances struct + CloseOtherInstances *CloseOtherInstancesCommand + type Command_KillServer struct + KillServer *KillServerCommand + type Command_ListDestinations struct + ListDestinations *ListDestinationsCommand + type Command_RemoveDestination struct + RemoveDestination *RemoveDestinationCommand + type Command_StartDestination struct + StartDestination *StartDestinationCommand + type Command_StartHandshake struct + StartHandshake *StartHandshakeCommand + type Command_StopDestination struct + StopDestination *StopDestinationCommand + type Command_UpdateDestination struct + UpdateDestination *UpdateDestinationCommand + type Container struct + CpuPercent float64 + Err string + ExitCode *int32 + HealthState string + Id string + ImageName string + MemoryUsageBytes uint64 + PullPercent int32 + PullProgress string + PullStatus string + RestartCount int32 + RxRate int32 + RxSince *timestamppb.Timestamp + Status string + TxRate int32 + func (*Container) Descriptor() ([]byte, []int) + func (*Container) ProtoMessage() + func (x *Container) GetCpuPercent() float64 + func (x *Container) GetErr() string + func (x *Container) GetExitCode() int32 + func (x *Container) GetHealthState() string + func (x *Container) GetId() string + func (x *Container) GetImageName() string + func (x *Container) GetMemoryUsageBytes() uint64 + func (x *Container) GetPullPercent() int32 + func (x *Container) GetPullProgress() string + func (x *Container) GetPullStatus() string + func (x *Container) GetRestartCount() int32 + func (x *Container) GetRxRate() int32 + func (x *Container) GetRxSince() *timestamppb.Timestamp + func (x *Container) GetStatus() string + func (x *Container) GetTxRate() int32 + func (x *Container) ProtoReflect() protoreflect.Message + func (x *Container) Reset() + func (x *Container) String() string + type Destination struct + Container *Container + Id []byte + Name string + Status Destination_Status + Url string + func (*Destination) Descriptor() ([]byte, []int) + func (*Destination) ProtoMessage() + func (x *Destination) GetContainer() *Container + func (x *Destination) GetId() []byte + func (x *Destination) GetName() string + func (x *Destination) GetStatus() Destination_Status + func (x *Destination) GetUrl() string + func (x *Destination) ProtoReflect() protoreflect.Message + func (x *Destination) Reset() + func (x *Destination) String() string + type DestinationAddedEvent struct + Id []byte + func (*DestinationAddedEvent) Descriptor() ([]byte, []int) + func (*DestinationAddedEvent) ProtoMessage() + func (x *DestinationAddedEvent) GetId() []byte + func (x *DestinationAddedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationAddedEvent) Reset() + func (x *DestinationAddedEvent) String() string + type DestinationRemovedEvent struct + Id []byte + func (*DestinationRemovedEvent) Descriptor() ([]byte, []int) + func (*DestinationRemovedEvent) ProtoMessage() + func (x *DestinationRemovedEvent) GetId() []byte + func (x *DestinationRemovedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationRemovedEvent) Reset() + func (x *DestinationRemovedEvent) String() string + type DestinationStartedEvent struct + Id []byte + func (*DestinationStartedEvent) Descriptor() ([]byte, []int) + func (*DestinationStartedEvent) ProtoMessage() + func (x *DestinationStartedEvent) GetId() []byte + func (x *DestinationStartedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationStartedEvent) Reset() + func (x *DestinationStartedEvent) String() string + type DestinationStoppedEvent struct + Id []byte + func (*DestinationStoppedEvent) Descriptor() ([]byte, []int) + func (*DestinationStoppedEvent) ProtoMessage() + func (x *DestinationStoppedEvent) GetId() []byte + func (x *DestinationStoppedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationStoppedEvent) Reset() + func (x *DestinationStoppedEvent) String() string + type DestinationStreamExitedEvent struct + Error string + Id []byte + Name string + func (*DestinationStreamExitedEvent) Descriptor() ([]byte, []int) + func (*DestinationStreamExitedEvent) ProtoMessage() + func (x *DestinationStreamExitedEvent) GetError() string + func (x *DestinationStreamExitedEvent) GetId() []byte + func (x *DestinationStreamExitedEvent) GetName() string + func (x *DestinationStreamExitedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationStreamExitedEvent) Reset() + func (x *DestinationStreamExitedEvent) String() string + type DestinationUpdatedEvent struct + Id []byte + func (*DestinationUpdatedEvent) Descriptor() ([]byte, []int) + func (*DestinationUpdatedEvent) ProtoMessage() + func (x *DestinationUpdatedEvent) GetId() []byte + func (x *DestinationUpdatedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationUpdatedEvent) Reset() + func (x *DestinationUpdatedEvent) String() string + type Destination_Status int32 + const Destination_STATUS_LIVE + const Destination_STATUS_OFF_AIR + const Destination_STATUS_STARTING + func (Destination_Status) Descriptor() protoreflect.EnumDescriptor + func (Destination_Status) EnumDescriptor() ([]byte, []int) + func (Destination_Status) Type() protoreflect.EnumType + func (x Destination_Status) Enum() *Destination_Status + func (x Destination_Status) Number() protoreflect.EnumNumber + func (x Destination_Status) String() string + type DestinationsListedEvent struct + Destinations []*Destination + func (*DestinationsListedEvent) Descriptor() ([]byte, []int) + func (*DestinationsListedEvent) ProtoMessage() + func (x *DestinationsListedEvent) GetDestinations() []*Destination + func (x *DestinationsListedEvent) ProtoReflect() protoreflect.Message + func (x *DestinationsListedEvent) Reset() + func (x *DestinationsListedEvent) String() string + type Envelope struct + Payload isEnvelope_Payload + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (x *Envelope) GetCommand() *Command + func (x *Envelope) GetEvent() *Event + func (x *Envelope) GetPayload() isEnvelope_Payload + func (x *Envelope) ProtoReflect() protoreflect.Message + func (x *Envelope) Reset() + func (x *Envelope) String() string + type Envelope_Command struct + Command *Command + type Envelope_Event struct + Event *Event + type Event struct + EventType isEvent_EventType + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (x *Event) GetAddDestinationFailed() *AddDestinationFailedEvent + func (x *Event) GetAppStateChanged() *AppStateChangedEvent + func (x *Event) GetDestinationAdded() *DestinationAddedEvent + func (x *Event) GetDestinationRemoved() *DestinationRemovedEvent + func (x *Event) GetDestinationStarted() *DestinationStartedEvent + func (x *Event) GetDestinationStopped() *DestinationStoppedEvent + func (x *Event) GetDestinationStreamExited() *DestinationStreamExitedEvent + func (x *Event) GetDestinationUpdated() *DestinationUpdatedEvent + func (x *Event) GetDestinationsListed() *DestinationsListedEvent + func (x *Event) GetEventType() isEvent_EventType + func (x *Event) GetFatalError() *FatalErrorEvent + func (x *Event) GetHandshakeCompleted() *HandshakeCompletedEvent + func (x *Event) GetListDestinationsFailed() *ListDestinationsFailedEvent + func (x *Event) GetMediaServerStarted() *MediaServerStartedEvent + func (x *Event) GetOtherInstanceDetected() *OtherInstanceDetectedEvent + func (x *Event) GetRemoveDestinationFailed() *RemoveDestinationFailedEvent + func (x *Event) GetStartDestinationFailed() *StartDestinationFailedEvent + func (x *Event) GetStopDestinationFailed() *StopDestinationFailedEvent + func (x *Event) GetUpdateDestinationFailed() *UpdateDestinationFailedEvent + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type Event_AddDestinationFailed struct + AddDestinationFailed *AddDestinationFailedEvent + type Event_AppStateChanged struct + AppStateChanged *AppStateChangedEvent + type Event_DestinationAdded struct + DestinationAdded *DestinationAddedEvent + type Event_DestinationRemoved struct + DestinationRemoved *DestinationRemovedEvent + type Event_DestinationStarted struct + DestinationStarted *DestinationStartedEvent + type Event_DestinationStopped struct + DestinationStopped *DestinationStoppedEvent + type Event_DestinationStreamExited struct + DestinationStreamExited *DestinationStreamExitedEvent + type Event_DestinationUpdated struct + DestinationUpdated *DestinationUpdatedEvent + type Event_DestinationsListed struct + DestinationsListed *DestinationsListedEvent + type Event_FatalError struct + FatalError *FatalErrorEvent + type Event_HandshakeCompleted struct + HandshakeCompleted *HandshakeCompletedEvent + type Event_ListDestinationsFailed struct + ListDestinationsFailed *ListDestinationsFailedEvent + type Event_MediaServerStarted struct + MediaServerStarted *MediaServerStartedEvent + type Event_OtherInstanceDetected struct + OtherInstanceDetected *OtherInstanceDetectedEvent + type Event_RemoveDestinationFailed struct + RemoveDestinationFailed *RemoveDestinationFailedEvent + type Event_StartDestinationFailed struct + StartDestinationFailed *StartDestinationFailedEvent + type Event_StopDestinationFailed struct + StopDestinationFailed *StopDestinationFailedEvent + type Event_UpdateDestinationFailed struct + UpdateDestinationFailed *UpdateDestinationFailedEvent + type FatalErrorEvent struct + Message string + func (*FatalErrorEvent) Descriptor() ([]byte, []int) + func (*FatalErrorEvent) ProtoMessage() + func (x *FatalErrorEvent) GetMessage() string + func (x *FatalErrorEvent) ProtoReflect() protoreflect.Message + func (x *FatalErrorEvent) Reset() + func (x *FatalErrorEvent) String() string + type HandshakeCompletedEvent struct + func (*HandshakeCompletedEvent) Descriptor() ([]byte, []int) + func (*HandshakeCompletedEvent) ProtoMessage() + func (x *HandshakeCompletedEvent) ProtoReflect() protoreflect.Message + func (x *HandshakeCompletedEvent) Reset() + func (x *HandshakeCompletedEvent) String() string + type KillServerCommand struct + func (*KillServerCommand) Descriptor() ([]byte, []int) + func (*KillServerCommand) ProtoMessage() + func (x *KillServerCommand) ProtoReflect() protoreflect.Message + func (x *KillServerCommand) Reset() + func (x *KillServerCommand) String() string + type ListDestinationsCommand struct + func (*ListDestinationsCommand) Descriptor() ([]byte, []int) + func (*ListDestinationsCommand) ProtoMessage() + func (x *ListDestinationsCommand) ProtoReflect() protoreflect.Message + func (x *ListDestinationsCommand) Reset() + func (x *ListDestinationsCommand) String() string + type ListDestinationsFailedEvent struct + Error string + func (*ListDestinationsFailedEvent) Descriptor() ([]byte, []int) + func (*ListDestinationsFailedEvent) ProtoMessage() + func (x *ListDestinationsFailedEvent) GetError() string + func (x *ListDestinationsFailedEvent) ProtoReflect() protoreflect.Message + func (x *ListDestinationsFailedEvent) Reset() + func (x *ListDestinationsFailedEvent) String() string + type ListDestinationsRequest struct + Command *ListDestinationsCommand + func (*ListDestinationsRequest) Descriptor() ([]byte, []int) + func (*ListDestinationsRequest) ProtoMessage() + func (x *ListDestinationsRequest) GetCommand() *ListDestinationsCommand + func (x *ListDestinationsRequest) ProtoReflect() protoreflect.Message + func (x *ListDestinationsRequest) Reset() + func (x *ListDestinationsRequest) String() string + type ListDestinationsResponse struct + Result isListDestinationsResponse_Result + func (*ListDestinationsResponse) Descriptor() ([]byte, []int) + func (*ListDestinationsResponse) ProtoMessage() + func (x *ListDestinationsResponse) GetError() *ListDestinationsFailedEvent + func (x *ListDestinationsResponse) GetOk() *DestinationsListedEvent + func (x *ListDestinationsResponse) GetResult() isListDestinationsResponse_Result + func (x *ListDestinationsResponse) ProtoReflect() protoreflect.Message + func (x *ListDestinationsResponse) Reset() + func (x *ListDestinationsResponse) String() string + type ListDestinationsResponse_Error struct + Error *ListDestinationsFailedEvent + type ListDestinationsResponse_Ok struct + Ok *DestinationsListedEvent + type MediaServerStartedEvent struct + func (*MediaServerStartedEvent) Descriptor() ([]byte, []int) + func (*MediaServerStartedEvent) ProtoMessage() + func (x *MediaServerStartedEvent) ProtoReflect() protoreflect.Message + func (x *MediaServerStartedEvent) Reset() + func (x *MediaServerStartedEvent) String() string + type OtherInstanceDetectedEvent struct + func (*OtherInstanceDetectedEvent) Descriptor() ([]byte, []int) + func (*OtherInstanceDetectedEvent) ProtoMessage() + func (x *OtherInstanceDetectedEvent) ProtoReflect() protoreflect.Message + func (x *OtherInstanceDetectedEvent) Reset() + func (x *OtherInstanceDetectedEvent) String() string + type RemoveDestinationCommand struct + Force bool + Id []byte + func (*RemoveDestinationCommand) Descriptor() ([]byte, []int) + func (*RemoveDestinationCommand) ProtoMessage() + func (x *RemoveDestinationCommand) GetForce() bool + func (x *RemoveDestinationCommand) GetId() []byte + func (x *RemoveDestinationCommand) ProtoReflect() protoreflect.Message + func (x *RemoveDestinationCommand) Reset() + func (x *RemoveDestinationCommand) String() string + type RemoveDestinationFailedEvent struct + Error string + Id []byte + func (*RemoveDestinationFailedEvent) Descriptor() ([]byte, []int) + func (*RemoveDestinationFailedEvent) ProtoMessage() + func (x *RemoveDestinationFailedEvent) GetError() string + func (x *RemoveDestinationFailedEvent) GetId() []byte + func (x *RemoveDestinationFailedEvent) ProtoReflect() protoreflect.Message + func (x *RemoveDestinationFailedEvent) Reset() + func (x *RemoveDestinationFailedEvent) String() string + type RemoveDestinationRequest struct + Command *RemoveDestinationCommand + func (*RemoveDestinationRequest) Descriptor() ([]byte, []int) + func (*RemoveDestinationRequest) ProtoMessage() + func (x *RemoveDestinationRequest) GetCommand() *RemoveDestinationCommand + func (x *RemoveDestinationRequest) ProtoReflect() protoreflect.Message + func (x *RemoveDestinationRequest) Reset() + func (x *RemoveDestinationRequest) String() string + type RemoveDestinationResponse struct + Result isRemoveDestinationResponse_Result + func (*RemoveDestinationResponse) Descriptor() ([]byte, []int) + func (*RemoveDestinationResponse) ProtoMessage() + func (x *RemoveDestinationResponse) GetError() *RemoveDestinationFailedEvent + func (x *RemoveDestinationResponse) GetOk() *DestinationRemovedEvent + func (x *RemoveDestinationResponse) GetResult() isRemoveDestinationResponse_Result + func (x *RemoveDestinationResponse) ProtoReflect() protoreflect.Message + func (x *RemoveDestinationResponse) Reset() + func (x *RemoveDestinationResponse) String() string + type RemoveDestinationResponse_Error struct + Error *RemoveDestinationFailedEvent + type RemoveDestinationResponse_Ok struct + Ok *DestinationRemovedEvent + type Source struct + Container *Container + ExitReason string + Live bool + LiveChangedAt *timestamppb.Timestamp + RtmpUrl string + RtmpsUrl string + Tracks []string + func (*Source) Descriptor() ([]byte, []int) + func (*Source) ProtoMessage() + func (x *Source) GetContainer() *Container + func (x *Source) GetExitReason() string + func (x *Source) GetLive() bool + func (x *Source) GetLiveChangedAt() *timestamppb.Timestamp + func (x *Source) GetRtmpUrl() string + func (x *Source) GetRtmpsUrl() string + func (x *Source) GetTracks() []string + func (x *Source) ProtoReflect() protoreflect.Message + func (x *Source) Reset() + func (x *Source) String() string + type StartDestinationCommand struct + Id []byte + func (*StartDestinationCommand) Descriptor() ([]byte, []int) + func (*StartDestinationCommand) ProtoMessage() + func (x *StartDestinationCommand) GetId() []byte + func (x *StartDestinationCommand) ProtoReflect() protoreflect.Message + func (x *StartDestinationCommand) Reset() + func (x *StartDestinationCommand) String() string + type StartDestinationFailedEvent struct + Error string + Id []byte + func (*StartDestinationFailedEvent) Descriptor() ([]byte, []int) + func (*StartDestinationFailedEvent) ProtoMessage() + func (x *StartDestinationFailedEvent) GetError() string + func (x *StartDestinationFailedEvent) GetId() []byte + func (x *StartDestinationFailedEvent) ProtoReflect() protoreflect.Message + func (x *StartDestinationFailedEvent) Reset() + func (x *StartDestinationFailedEvent) String() string + type StartDestinationRequest struct + Command *StartDestinationCommand + func (*StartDestinationRequest) Descriptor() ([]byte, []int) + func (*StartDestinationRequest) ProtoMessage() + func (x *StartDestinationRequest) GetCommand() *StartDestinationCommand + func (x *StartDestinationRequest) ProtoReflect() protoreflect.Message + func (x *StartDestinationRequest) Reset() + func (x *StartDestinationRequest) String() string + type StartDestinationResponse struct + Result isStartDestinationResponse_Result + func (*StartDestinationResponse) Descriptor() ([]byte, []int) + func (*StartDestinationResponse) ProtoMessage() + func (x *StartDestinationResponse) GetError() *StartDestinationFailedEvent + func (x *StartDestinationResponse) GetOk() *DestinationStartedEvent + func (x *StartDestinationResponse) GetResult() isStartDestinationResponse_Result + func (x *StartDestinationResponse) ProtoReflect() protoreflect.Message + func (x *StartDestinationResponse) Reset() + func (x *StartDestinationResponse) String() string + type StartDestinationResponse_Error struct + Error *StartDestinationFailedEvent + type StartDestinationResponse_Ok struct + Ok *DestinationStartedEvent + type StartHandshakeCommand struct + func (*StartHandshakeCommand) Descriptor() ([]byte, []int) + func (*StartHandshakeCommand) ProtoMessage() + func (x *StartHandshakeCommand) ProtoReflect() protoreflect.Message + func (x *StartHandshakeCommand) Reset() + func (x *StartHandshakeCommand) String() string + type StopDestinationCommand struct + Id []byte + func (*StopDestinationCommand) Descriptor() ([]byte, []int) + func (*StopDestinationCommand) ProtoMessage() + func (x *StopDestinationCommand) GetId() []byte + func (x *StopDestinationCommand) ProtoReflect() protoreflect.Message + func (x *StopDestinationCommand) Reset() + func (x *StopDestinationCommand) String() string + type StopDestinationFailedEvent struct + Error string + Id []byte + func (*StopDestinationFailedEvent) Descriptor() ([]byte, []int) + func (*StopDestinationFailedEvent) ProtoMessage() + func (x *StopDestinationFailedEvent) GetError() string + func (x *StopDestinationFailedEvent) GetId() []byte + func (x *StopDestinationFailedEvent) ProtoReflect() protoreflect.Message + func (x *StopDestinationFailedEvent) Reset() + func (x *StopDestinationFailedEvent) String() string + type StopDestinationRequest struct + Command *StopDestinationCommand + func (*StopDestinationRequest) Descriptor() ([]byte, []int) + func (*StopDestinationRequest) ProtoMessage() + func (x *StopDestinationRequest) GetCommand() *StopDestinationCommand + func (x *StopDestinationRequest) ProtoReflect() protoreflect.Message + func (x *StopDestinationRequest) Reset() + func (x *StopDestinationRequest) String() string + type StopDestinationResponse struct + Result isStopDestinationResponse_Result + func (*StopDestinationResponse) Descriptor() ([]byte, []int) + func (*StopDestinationResponse) ProtoMessage() + func (x *StopDestinationResponse) GetError() *StopDestinationFailedEvent + func (x *StopDestinationResponse) GetOk() *DestinationStoppedEvent + func (x *StopDestinationResponse) GetResult() isStopDestinationResponse_Result + func (x *StopDestinationResponse) ProtoReflect() protoreflect.Message + func (x *StopDestinationResponse) Reset() + func (x *StopDestinationResponse) String() string + type StopDestinationResponse_Error struct + Error *StopDestinationFailedEvent + type StopDestinationResponse_Ok struct + Ok *DestinationStoppedEvent + type UpdateDestinationCommand struct + Id []byte + Name *string + Url *string + func (*UpdateDestinationCommand) Descriptor() ([]byte, []int) + func (*UpdateDestinationCommand) ProtoMessage() + func (x *UpdateDestinationCommand) GetId() []byte + func (x *UpdateDestinationCommand) GetName() string + func (x *UpdateDestinationCommand) GetUrl() string + func (x *UpdateDestinationCommand) ProtoReflect() protoreflect.Message + func (x *UpdateDestinationCommand) Reset() + func (x *UpdateDestinationCommand) String() string + type UpdateDestinationFailedEvent struct + Error string + Id []byte + func (*UpdateDestinationFailedEvent) Descriptor() ([]byte, []int) + func (*UpdateDestinationFailedEvent) ProtoMessage() + func (x *UpdateDestinationFailedEvent) GetError() string + func (x *UpdateDestinationFailedEvent) GetId() []byte + func (x *UpdateDestinationFailedEvent) ProtoReflect() protoreflect.Message + func (x *UpdateDestinationFailedEvent) Reset() + func (x *UpdateDestinationFailedEvent) String() string + type UpdateDestinationRequest struct + Command *UpdateDestinationCommand + func (*UpdateDestinationRequest) Descriptor() ([]byte, []int) + func (*UpdateDestinationRequest) ProtoMessage() + func (x *UpdateDestinationRequest) GetCommand() *UpdateDestinationCommand + func (x *UpdateDestinationRequest) ProtoReflect() protoreflect.Message + func (x *UpdateDestinationRequest) Reset() + func (x *UpdateDestinationRequest) String() string + type UpdateDestinationResponse struct + Result isUpdateDestinationResponse_Result + func (*UpdateDestinationResponse) Descriptor() ([]byte, []int) + func (*UpdateDestinationResponse) ProtoMessage() + func (x *UpdateDestinationResponse) GetError() *UpdateDestinationFailedEvent + func (x *UpdateDestinationResponse) GetOk() *DestinationUpdatedEvent + func (x *UpdateDestinationResponse) GetResult() isUpdateDestinationResponse_Result + func (x *UpdateDestinationResponse) ProtoReflect() protoreflect.Message + func (x *UpdateDestinationResponse) Reset() + func (x *UpdateDestinationResponse) String() string + type UpdateDestinationResponse_Error struct + Error *UpdateDestinationFailedEvent + type UpdateDestinationResponse_Ok struct + Ok *DestinationUpdatedEvent
Go to main page