grpc

type AddDestinationCommand struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url  string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

type AddDestinationFailedEvent struct {
	Url   string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type AddDestinationRequest struct {
	Command *AddDestinationCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type AddDestinationResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*AddDestinationResponse_Ok
	//	*AddDestinationResponse_Error
	Result isAddDestinationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type AddDestinationResponse_Error struct {
	Error *AddDestinationFailedEvent `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type AddDestinationResponse_Ok struct {
	Ok *DestinationAddedEvent `protobuf:"bytes,1,opt,name=ok,proto3,oneof"`
}

type AppState struct {
	Source       *Source        `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destinations []*Destination `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	BuildInfo    *BuildInfo     `protobuf:"bytes,3,opt,name=build_info,json=buildInfo,proto3" json:"build_info,omitempty"`
	// contains filtered or unexported fields
}

type AppStateChangedEvent struct {
	AppState *AppState `protobuf:"bytes,1,opt,name=app_state,json=appState,proto3" json:"app_state,omitempty"`
	// contains filtered or unexported fields
}

type BuildInfo struct {
	GoVersion string `protobuf:"bytes,1,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Commit    string `protobuf:"bytes,3,opt,name=commit,proto3" json:"commit,omitempty"`
	Date      string `protobuf:"bytes,4,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

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

type Command struct {

	// Types that are valid to be assigned to CommandType:
	//
	//	*Command_ListDestinations
	//	*Command_AddDestination
	//	*Command_UpdateDestination
	//	*Command_RemoveDestination
	//	*Command_StartDestination
	//	*Command_StopDestination
	//	*Command_CloseOtherInstances
	//	*Command_KillServer
	//	*Command_StartHandshake
	CommandType isCommand_CommandType `protobuf_oneof:"command_type"`
	// contains filtered or unexported fields
}

type Command_AddDestination struct {
	AddDestination *AddDestinationCommand `protobuf:"bytes,2,opt,name=add_destination,json=addDestination,proto3,oneof"`
}

type Command_CloseOtherInstances struct {
	CloseOtherInstances *CloseOtherInstancesCommand `protobuf:"bytes,7,opt,name=close_other_instances,json=closeOtherInstances,proto3,oneof"`
}

type Command_KillServer struct {
	KillServer *KillServerCommand `protobuf:"bytes,8,opt,name=kill_server,json=killServer,proto3,oneof"`
}

type Command_ListDestinations struct {
	ListDestinations *ListDestinationsCommand `protobuf:"bytes,1,opt,name=list_destinations,json=listDestinations,proto3,oneof"`
}

type Command_RemoveDestination struct {
	RemoveDestination *RemoveDestinationCommand `protobuf:"bytes,4,opt,name=remove_destination,json=removeDestination,proto3,oneof"`
}

type Command_StartDestination struct {
	StartDestination *StartDestinationCommand `protobuf:"bytes,5,opt,name=start_destination,json=startDestination,proto3,oneof"`
}

type Command_StartHandshake struct {
	StartHandshake *StartHandshakeCommand `protobuf:"bytes,9,opt,name=start_handshake,json=startHandshake,proto3,oneof"`
}

type Command_StopDestination struct {
	StopDestination *StopDestinationCommand `protobuf:"bytes,6,opt,name=stop_destination,json=stopDestination,proto3,oneof"`
}

type Command_UpdateDestination struct {
	UpdateDestination *UpdateDestinationCommand `protobuf:"bytes,3,opt,name=update_destination,json=updateDestination,proto3,oneof"`
}

type Container struct {
	Id               string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status           string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	HealthState      string                 `protobuf:"bytes,3,opt,name=health_state,json=healthState,proto3" json:"health_state,omitempty"`
	CpuPercent       float64                `protobuf:"fixed64,4,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`
	MemoryUsageBytes uint64                 `protobuf:"varint,5,opt,name=memory_usage_bytes,json=memoryUsageBytes,proto3" json:"memory_usage_bytes,omitempty"`
	RxRate           int32                  `protobuf:"varint,6,opt,name=rx_rate,json=rxRate,proto3" json:"rx_rate,omitempty"`
	TxRate           int32                  `protobuf:"varint,7,opt,name=tx_rate,json=txRate,proto3" json:"tx_rate,omitempty"`
	RxSince          *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=rx_since,json=rxSince,proto3" json:"rx_since,omitempty"`
	ImageName        string                 `protobuf:"bytes,9,opt,name=image_name,json=imageName,proto3" json:"image_name,omitempty"`
	PullStatus       string                 `protobuf:"bytes,10,opt,name=pull_status,json=pullStatus,proto3" json:"pull_status,omitempty"`
	PullProgress     string                 `protobuf:"bytes,11,opt,name=pull_progress,json=pullProgress,proto3" json:"pull_progress,omitempty"`
	PullPercent      int32                  `protobuf:"varint,12,opt,name=pull_percent,json=pullPercent,proto3" json:"pull_percent,omitempty"`
	RestartCount     int32                  `protobuf:"varint,13,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	ExitCode         *int32                 `protobuf:"varint,14,opt,name=exit_code,json=exitCode,proto3,oneof" json:"exit_code,omitempty"`
	Err              string                 `protobuf:"bytes,15,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type Destination struct {
	Container *Container         `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
	Status    Destination_Status `protobuf:"varint,2,opt,name=status,proto3,enum=api.Destination_Status" json:"status,omitempty"`
	Id        []byte             `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Name      string             `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Url       string             `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

type DestinationAddedEvent struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DestinationRemovedEvent struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DestinationStartedEvent struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DestinationStoppedEvent struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DestinationStreamExitedEvent struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type DestinationUpdatedEvent struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type Destination_Status int32

type DestinationsListedEvent struct {
	Destinations []*Destination `protobuf:"bytes,1,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// contains filtered or unexported fields
}

type Envelope struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*Envelope_Command
	//	*Envelope_Event
	Payload isEnvelope_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type Envelope_Command struct {
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3,oneof"`
}

type Envelope_Event struct {
	Event *Event `protobuf:"bytes,2,opt,name=event,proto3,oneof"`
}

type Event struct {

	// Types that are valid to be assigned to EventType:
	//
	//	*Event_AppStateChanged
	//	*Event_DestinationStreamExited
	//	*Event_DestinationAdded
	//	*Event_AddDestinationFailed
	//	*Event_DestinationUpdated
	//	*Event_UpdateDestinationFailed
	//	*Event_DestinationRemoved
	//	*Event_RemoveDestinationFailed
	//	*Event_DestinationStarted
	//	*Event_StartDestinationFailed
	//	*Event_DestinationStopped
	//	*Event_StopDestinationFailed
	//	*Event_MediaServerStarted
	//	*Event_OtherInstanceDetected
	//	*Event_FatalError
	//	*Event_HandshakeCompleted
	//	*Event_DestinationsListed
	//	*Event_ListDestinationsFailed
	EventType isEvent_EventType `protobuf_oneof:"event_type"`
	// contains filtered or unexported fields
}

type Event_AddDestinationFailed struct {
	AddDestinationFailed *AddDestinationFailedEvent `protobuf:"bytes,4,opt,name=add_destination_failed,json=addDestinationFailed,proto3,oneof"`
}

type Event_AppStateChanged struct {
	AppStateChanged *AppStateChangedEvent `protobuf:"bytes,1,opt,name=app_state_changed,json=appStateChanged,proto3,oneof"`
}

type Event_DestinationAdded struct {
	DestinationAdded *DestinationAddedEvent `protobuf:"bytes,3,opt,name=destination_added,json=destinationAdded,proto3,oneof"`
}

type Event_DestinationRemoved struct {
	DestinationRemoved *DestinationRemovedEvent `protobuf:"bytes,7,opt,name=destination_removed,json=destinationRemoved,proto3,oneof"`
}

type Event_DestinationStarted struct {
	DestinationStarted *DestinationStartedEvent `protobuf:"bytes,9,opt,name=destination_started,json=destinationStarted,proto3,oneof"`
}

type Event_DestinationStopped struct {
	DestinationStopped *DestinationStoppedEvent `protobuf:"bytes,11,opt,name=destination_stopped,json=destinationStopped,proto3,oneof"`
}

type Event_DestinationStreamExited struct {
	DestinationStreamExited *DestinationStreamExitedEvent `protobuf:"bytes,2,opt,name=destination_stream_exited,json=destinationStreamExited,proto3,oneof"`
}

type Event_DestinationUpdated struct {
	DestinationUpdated *DestinationUpdatedEvent `protobuf:"bytes,5,opt,name=destination_updated,json=destinationUpdated,proto3,oneof"`
}

type Event_DestinationsListed struct {
	DestinationsListed *DestinationsListedEvent `protobuf:"bytes,17,opt,name=destinations_listed,json=destinationsListed,proto3,oneof"`
}

type Event_FatalError struct {
	FatalError *FatalErrorEvent `protobuf:"bytes,15,opt,name=fatal_error,json=fatalError,proto3,oneof"`
}

type Event_HandshakeCompleted struct {
	HandshakeCompleted *HandshakeCompletedEvent `protobuf:"bytes,16,opt,name=handshake_completed,json=handshakeCompleted,proto3,oneof"`
}

type Event_ListDestinationsFailed struct {
	ListDestinationsFailed *ListDestinationsFailedEvent `protobuf:"bytes,18,opt,name=list_destinations_failed,json=listDestinationsFailed,proto3,oneof"`
}

type Event_MediaServerStarted struct {
	MediaServerStarted *MediaServerStartedEvent `protobuf:"bytes,13,opt,name=media_server_started,json=mediaServerStarted,proto3,oneof"`
}

type Event_OtherInstanceDetected struct {
	OtherInstanceDetected *OtherInstanceDetectedEvent `protobuf:"bytes,14,opt,name=other_instance_detected,json=otherInstanceDetected,proto3,oneof"`
}

type Event_RemoveDestinationFailed struct {
	RemoveDestinationFailed *RemoveDestinationFailedEvent `protobuf:"bytes,8,opt,name=remove_destination_failed,json=removeDestinationFailed,proto3,oneof"`
}

type Event_StartDestinationFailed struct {
	StartDestinationFailed *StartDestinationFailedEvent `protobuf:"bytes,10,opt,name=start_destination_failed,json=startDestinationFailed,proto3,oneof"`
}

type Event_StopDestinationFailed struct {
	StopDestinationFailed *StopDestinationFailedEvent `protobuf:"bytes,12,opt,name=stop_destination_failed,json=stopDestinationFailed,proto3,oneof"`
}

type Event_UpdateDestinationFailed struct {
	UpdateDestinationFailed *UpdateDestinationFailedEvent `protobuf:"bytes,6,opt,name=update_destination_failed,json=updateDestinationFailed,proto3,oneof"`
}

type FatalErrorEvent struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

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

type InternalAPIClient interface {
	Communicate(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[Envelope, Envelope], error)
	ListDestinations(ctx context.Context, in *ListDestinationsRequest, opts ...grpc.CallOption) (*ListDestinationsResponse, error)
	AddDestination(ctx context.Context, in *AddDestinationRequest, opts ...grpc.CallOption) (*AddDestinationResponse, error)
	UpdateDestination(ctx context.Context, in *UpdateDestinationRequest, opts ...grpc.CallOption) (*UpdateDestinationResponse, error)
	RemoveDestination(ctx context.Context, in *RemoveDestinationRequest, opts ...grpc.CallOption) (*RemoveDestinationResponse, error)
	StartDestination(ctx context.Context, in *StartDestinationRequest, opts ...grpc.CallOption) (*StartDestinationResponse, error)
	StopDestination(ctx context.Context, in *StopDestinationRequest, opts ...grpc.CallOption) (*StopDestinationResponse, error)
}

type InternalAPIServer interface {
	Communicate(grpc.BidiStreamingServer[Envelope, Envelope]) error
	ListDestinations(context.Context, *ListDestinationsRequest) (*ListDestinationsResponse, error)
	AddDestination(context.Context, *AddDestinationRequest) (*AddDestinationResponse, error)
	UpdateDestination(context.Context, *UpdateDestinationRequest) (*UpdateDestinationResponse, error)
	RemoveDestination(context.Context, *RemoveDestinationRequest) (*RemoveDestinationResponse, error)
	StartDestination(context.Context, *StartDestinationRequest) (*StartDestinationResponse, error)
	StopDestination(context.Context, *StopDestinationRequest) (*StopDestinationResponse, error)
	// contains filtered or unexported methods
}

type InternalAPI_CommunicateClient = grpc.BidiStreamingClient[Envelope, Envelope]

type InternalAPI_CommunicateServer = grpc.BidiStreamingServer[Envelope, Envelope]

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

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

type ListDestinationsFailedEvent struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ListDestinationsRequest struct {
	Command *ListDestinationsCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type ListDestinationsResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*ListDestinationsResponse_Ok
	//	*ListDestinationsResponse_Error
	Result isListDestinationsResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type ListDestinationsResponse_Error struct {
	Error *ListDestinationsFailedEvent `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ListDestinationsResponse_Ok struct {
	Ok *DestinationsListedEvent `protobuf:"bytes,1,opt,name=ok,proto3,oneof"`
}

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

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

type RemoveDestinationCommand struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

type RemoveDestinationFailedEvent struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type RemoveDestinationRequest struct {
	Command *RemoveDestinationCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type RemoveDestinationResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*RemoveDestinationResponse_Ok
	//	*RemoveDestinationResponse_Error
	Result isRemoveDestinationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type RemoveDestinationResponse_Error struct {
	Error *RemoveDestinationFailedEvent `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type RemoveDestinationResponse_Ok struct {
	Ok *DestinationRemovedEvent `protobuf:"bytes,2,opt,name=ok,proto3,oneof"`
}

type Source struct {
	Container     *Container             `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"`
	Live          bool                   `protobuf:"varint,2,opt,name=live,proto3" json:"live,omitempty"`
	LiveChangedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=live_changed_at,json=liveChangedAt,proto3" json:"live_changed_at,omitempty"`
	Tracks        []string               `protobuf:"bytes,4,rep,name=tracks,proto3" json:"tracks,omitempty"`
	ExitReason    string                 `protobuf:"bytes,5,opt,name=exit_reason,json=exitReason,proto3" json:"exit_reason,omitempty"`
	RtmpUrl       string                 `protobuf:"bytes,6,opt,name=rtmp_url,json=rtmpUrl,proto3" json:"rtmp_url,omitempty"`
	RtmpsUrl      string                 `protobuf:"bytes,7,opt,name=rtmps_url,json=rtmpsUrl,proto3" json:"rtmps_url,omitempty"`
	// contains filtered or unexported fields
}

type StartDestinationCommand struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type StartDestinationFailedEvent struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type StartDestinationRequest struct {
	Command *StartDestinationCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type StartDestinationResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*StartDestinationResponse_Ok
	//	*StartDestinationResponse_Error
	Result isStartDestinationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type StartDestinationResponse_Error struct {
	Error *StartDestinationFailedEvent `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type StartDestinationResponse_Ok struct {
	Ok *DestinationStartedEvent `protobuf:"bytes,1,opt,name=ok,proto3,oneof"`
}

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

type StopDestinationCommand struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type StopDestinationFailedEvent struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type StopDestinationRequest struct {
	Command *StopDestinationCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type StopDestinationResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*StopDestinationResponse_Ok
	//	*StopDestinationResponse_Error
	Result isStopDestinationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type StopDestinationResponse_Error struct {
	Error *StopDestinationFailedEvent `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type StopDestinationResponse_Ok struct {
	Ok *DestinationStoppedEvent `protobuf:"bytes,1,opt,name=ok,proto3,oneof"`
}

type UnimplementedInternalAPIServer struct{}

type UnsafeInternalAPIServer interface {
	// contains filtered or unexported methods
}

type UpdateDestinationCommand struct {
	Id   []byte  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Url  *string `protobuf:"bytes,3,opt,name=url,proto3,oneof" json:"url,omitempty"`
	// contains filtered or unexported fields
}

type UpdateDestinationFailedEvent struct {
	Id    []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type UpdateDestinationRequest struct {
	Command *UpdateDestinationCommand `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type UpdateDestinationResponse struct {

	// Types that are valid to be assigned to Result:
	//
	//	*UpdateDestinationResponse_Ok
	//	*UpdateDestinationResponse_Error
	Result isUpdateDestinationResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type UpdateDestinationResponse_Error struct {
	Error *UpdateDestinationFailedEvent `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type UpdateDestinationResponse_Ok struct {
	Ok *DestinationUpdatedEvent `protobuf:"bytes,1,opt,name=ok,proto3,oneof"`
}