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 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 assignable to CommandType:
	//
	//	*Command_AddDestination
	//	*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,1,opt,name=add_destination,json=addDestination,proto3,oneof"`
}

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

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

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

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

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

type Command_StopDestination struct {
	StopDestination *StopDestinationCommand `protobuf:"bytes,4,opt,name=stop_destination,json=stopDestination,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"`
	Name      string             `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Url       string             `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type Destination_Status int32

type Envelope struct {

	// Types that are assignable 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 assignable to EventType:
	//
	//	*Event_AppStateChanged
	//	*Event_DestinationStreamExited
	//	*Event_DestinationAdded
	//	*Event_AddDestinationFailed
	//	*Event_DestinationRemoved
	//	*Event_RemoveDestinationFailed
	//	*Event_StartDestinationFailed
	//	*Event_MediaServerStarted
	//	*Event_OtherInstanceDetected
	//	*Event_FatalError
	//	*Event_HandshakeCompleted
	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,5,opt,name=destination_removed,json=destinationRemoved,proto3,oneof"`
}

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

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

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

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

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

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

type Event_StartDestinationFailed struct {
	StartDestinationFailed *StartDestinationFailedEvent `protobuf:"bytes,7,opt,name=start_destination_failed,json=startDestinationFailed,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) (InternalAPI_CommunicateClient, error)
}

type InternalAPIServer interface {
	Communicate(InternalAPI_CommunicateServer) error
	// contains filtered or unexported methods
}

type InternalAPI_CommunicateClient interface {
	Send(*Envelope) error
	Recv() (*Envelope, error)
	grpc.ClientStream
}

type InternalAPI_CommunicateServer interface {
	Send(*Envelope) error
	Recv() (*Envelope, error)
	grpc.ServerStream
}

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

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

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

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

type RemoveDestinationFailedEvent 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 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 {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type UnimplementedInternalAPIServer struct {
}

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