internalapiv1

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: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Destination_Status_name = map[int32]string{
		0: "STATUS_OFF_AIR",
		1: "STATUS_STARTING",
		2: "STATUS_LIVE",
	}
	Destination_Status_value = map[string]int32{
		"STATUS_OFF_AIR":  0,
		"STATUS_STARTING": 1,
		"STATUS_LIVE":     2,
	}
)

Enum value maps for Destination_Status.

View Source 
var File_internalapi_v1_api_proto protoreflect.FileDescriptor
View Source 
var File_internalapi_v1_command_proto protoreflect.FileDescriptor
View Source 
var File_internalapi_v1_domain_proto protoreflect.FileDescriptor
View Source 
var File_internalapi_v1_event_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddDestinationCommand 

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
}

func (*AddDestinationCommand) Descriptor deprecated 

func (*AddDestinationCommand) Descriptor() ([]byte, []int)

Deprecated: Use AddDestinationCommand.ProtoReflect.Descriptor instead.

func (*AddDestinationCommand) GetName 

func (x *AddDestinationCommand) GetName() string

func (*AddDestinationCommand) GetUrl 

func (x *AddDestinationCommand) GetUrl() string

func (*AddDestinationCommand) ProtoMessage 

func (*AddDestinationCommand) ProtoMessage()

func (*AddDestinationCommand) ProtoReflect 

func (x *AddDestinationCommand) ProtoReflect() protoreflect.Message

func (*AddDestinationCommand) Reset 

func (x *AddDestinationCommand) Reset()

func (*AddDestinationCommand) String 

func (x *AddDestinationCommand) String() string

type AddDestinationFailedEvent 

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
}

func (*AddDestinationFailedEvent) Descriptor deprecated 

func (*AddDestinationFailedEvent) Descriptor() ([]byte, []int)

Deprecated: Use AddDestinationFailedEvent.ProtoReflect.Descriptor instead.

func (*AddDestinationFailedEvent) GetError 

func (x *AddDestinationFailedEvent) GetError() string

func (*AddDestinationFailedEvent) GetUrl 

func (x *AddDestinationFailedEvent) GetUrl() string

func (*AddDestinationFailedEvent) ProtoMessage 

func (*AddDestinationFailedEvent) ProtoMessage()

func (*AddDestinationFailedEvent) ProtoReflect 

func (x *AddDestinationFailedEvent) ProtoReflect() protoreflect.Message

func (*AddDestinationFailedEvent) Reset 

func (x *AddDestinationFailedEvent) Reset()

func (*AddDestinationFailedEvent) String 

func (x *AddDestinationFailedEvent) String() string

type AddDestinationRequest 

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

func (*AddDestinationRequest) Descriptor deprecated 

func (*AddDestinationRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddDestinationRequest.ProtoReflect.Descriptor instead.

func (*AddDestinationRequest) GetCommand 

func (x *AddDestinationRequest) GetCommand() *AddDestinationCommand

func (*AddDestinationRequest) ProtoMessage 

func (*AddDestinationRequest) ProtoMessage()

func (*AddDestinationRequest) ProtoReflect 

func (x *AddDestinationRequest) ProtoReflect() protoreflect.Message

func (*AddDestinationRequest) Reset 

func (x *AddDestinationRequest) Reset()

func (*AddDestinationRequest) String 

func (x *AddDestinationRequest) String() string

type AddDestinationResponse 

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
}

func (*AddDestinationResponse) Descriptor deprecated 

func (*AddDestinationResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddDestinationResponse.ProtoReflect.Descriptor instead.

func (*AddDestinationResponse) GetError 

func (x *AddDestinationResponse) GetError() *AddDestinationFailedEvent

func (*AddDestinationResponse) GetOk 

func (x *AddDestinationResponse) GetOk() *DestinationAddedEvent

func (*AddDestinationResponse) GetResult 

func (x *AddDestinationResponse) GetResult() isAddDestinationResponse_Result

func (*AddDestinationResponse) ProtoMessage 

func (*AddDestinationResponse) ProtoMessage()

func (*AddDestinationResponse) ProtoReflect 

func (x *AddDestinationResponse) ProtoReflect() protoreflect.Message

func (*AddDestinationResponse) Reset 

func (x *AddDestinationResponse) Reset()

func (*AddDestinationResponse) String 

func (x *AddDestinationResponse) String() string

type AddDestinationResponse_Error 

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

type AddDestinationResponse_Ok 

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

type AppState 

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
}

func (*AppState) Descriptor deprecated 

func (*AppState) Descriptor() ([]byte, []int)

Deprecated: Use AppState.ProtoReflect.Descriptor instead.

func (*AppState) GetBuildInfo 

func (x *AppState) GetBuildInfo() *BuildInfo

func (*AppState) GetDestinations 

func (x *AppState) GetDestinations() []*Destination

func (*AppState) GetSource 

func (x *AppState) GetSource() *Source

func (*AppState) ProtoMessage 

func (*AppState) ProtoMessage()

func (*AppState) ProtoReflect 

func (x *AppState) ProtoReflect() protoreflect.Message

func (*AppState) Reset 

func (x *AppState) Reset()

func (*AppState) String 

func (x *AppState) String() string

type AppStateChangedEvent 

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

func (*AppStateChangedEvent) Descriptor deprecated 

func (*AppStateChangedEvent) Descriptor() ([]byte, []int)

Deprecated: Use AppStateChangedEvent.ProtoReflect.Descriptor instead.

func (*AppStateChangedEvent) GetAppState 

func (x *AppStateChangedEvent) GetAppState() *AppState

func (*AppStateChangedEvent) ProtoMessage 

func (*AppStateChangedEvent) ProtoMessage()

func (*AppStateChangedEvent) ProtoReflect 

func (x *AppStateChangedEvent) ProtoReflect() protoreflect.Message

func (*AppStateChangedEvent) Reset 

func (x *AppStateChangedEvent) Reset()

func (*AppStateChangedEvent) String 

func (x *AppStateChangedEvent) String() string

type AuthenticateRequest 

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

func (*AuthenticateRequest) Descriptor deprecated 

func (*AuthenticateRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthenticateRequest.ProtoReflect.Descriptor instead.

func (*AuthenticateRequest) ProtoMessage 

func (*AuthenticateRequest) ProtoMessage()

func (*AuthenticateRequest) ProtoReflect 

func (x *AuthenticateRequest) ProtoReflect() protoreflect.Message

func (*AuthenticateRequest) Reset 

func (x *AuthenticateRequest) Reset()

func (*AuthenticateRequest) String 

func (x *AuthenticateRequest) String() string

type AuthenticateResponse 

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

func (*AuthenticateResponse) Descriptor deprecated 

func (*AuthenticateResponse) Descriptor() ([]byte, []int)

Deprecated: Use AuthenticateResponse.ProtoReflect.Descriptor instead.

func (*AuthenticateResponse) ProtoMessage 

func (*AuthenticateResponse) ProtoMessage()

func (*AuthenticateResponse) ProtoReflect 

func (x *AuthenticateResponse) ProtoReflect() protoreflect.Message

func (*AuthenticateResponse) Reset 

func (x *AuthenticateResponse) Reset()

func (*AuthenticateResponse) String 

func (x *AuthenticateResponse) String() string

type BuildInfo 

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
}

func (*BuildInfo) Descriptor deprecated 

func (*BuildInfo) Descriptor() ([]byte, []int)

Deprecated: Use BuildInfo.ProtoReflect.Descriptor instead.

func (*BuildInfo) GetCommit 

func (x *BuildInfo) GetCommit() string

func (*BuildInfo) GetDate 

func (x *BuildInfo) GetDate() string

func (*BuildInfo) GetGoVersion 

func (x *BuildInfo) GetGoVersion() string

func (*BuildInfo) GetVersion 

func (x *BuildInfo) GetVersion() string

func (*BuildInfo) ProtoMessage 

func (*BuildInfo) ProtoMessage()

func (*BuildInfo) ProtoReflect 

func (x *BuildInfo) ProtoReflect() protoreflect.Message

func (*BuildInfo) Reset 

func (x *BuildInfo) Reset()

func (*BuildInfo) String 

func (x *BuildInfo) String() string

type CloseOtherInstancesCommand 

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

func (*CloseOtherInstancesCommand) Descriptor deprecated 

func (*CloseOtherInstancesCommand) Descriptor() ([]byte, []int)

Deprecated: Use CloseOtherInstancesCommand.ProtoReflect.Descriptor instead.

func (*CloseOtherInstancesCommand) ProtoMessage 

func (*CloseOtherInstancesCommand) ProtoMessage()

func (*CloseOtherInstancesCommand) ProtoReflect 

func (x *CloseOtherInstancesCommand) ProtoReflect() protoreflect.Message

func (*CloseOtherInstancesCommand) Reset 

func (x *CloseOtherInstancesCommand) Reset()

func (*CloseOtherInstancesCommand) String 

func (x *CloseOtherInstancesCommand) String() string

type Command 

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
}

func (*Command) Descriptor deprecated 

func (*Command) Descriptor() ([]byte, []int)

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetAddDestination 

func (x *Command) GetAddDestination() *AddDestinationCommand

func (*Command) GetCloseOtherInstances 

func (x *Command) GetCloseOtherInstances() *CloseOtherInstancesCommand

func (*Command) GetCommandType 

func (x *Command) GetCommandType() isCommand_CommandType

func (*Command) GetKillServer 

func (x *Command) GetKillServer() *KillServerCommand

func (*Command) GetListDestinations 

func (x *Command) GetListDestinations() *ListDestinationsCommand

func (*Command) GetRemoveDestination 

func (x *Command) GetRemoveDestination() *RemoveDestinationCommand

func (*Command) GetStartDestination 

func (x *Command) GetStartDestination() *StartDestinationCommand

func (*Command) GetStartHandshake 

func (x *Command) GetStartHandshake() *StartHandshakeCommand

func (*Command) GetStopDestination 

func (x *Command) GetStopDestination() *StopDestinationCommand

func (*Command) GetUpdateDestination 

func (x *Command) GetUpdateDestination() *UpdateDestinationCommand

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

func (x *Command) ProtoReflect() protoreflect.Message

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type Command_AddDestination 

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

type Command_CloseOtherInstances 

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

type Command_KillServer 

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

type Command_ListDestinations 

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

type Command_RemoveDestination 

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

type Command_StartDestination 

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

type Command_StartHandshake 

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

type Command_StopDestination 

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

type Command_UpdateDestination 

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

type Container 

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
}

func (*Container) Descriptor deprecated 

func (*Container) Descriptor() ([]byte, []int)

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetCpuPercent 

func (x *Container) GetCpuPercent() float64

func (*Container) GetErr 

func (x *Container) GetErr() string

func (*Container) GetExitCode 

func (x *Container) GetExitCode() int32

func (*Container) GetHealthState 

func (x *Container) GetHealthState() string

func (*Container) GetId 

func (x *Container) GetId() string

func (*Container) GetImageName 

func (x *Container) GetImageName() string

func (*Container) GetMemoryUsageBytes 

func (x *Container) GetMemoryUsageBytes() uint64

func (*Container) GetPullPercent 

func (x *Container) GetPullPercent() int32

func (*Container) GetPullProgress 

func (x *Container) GetPullProgress() string

func (*Container) GetPullStatus 

func (x *Container) GetPullStatus() string

func (*Container) GetRestartCount 

func (x *Container) GetRestartCount() int32

func (*Container) GetRxRate 

func (x *Container) GetRxRate() int32

func (*Container) GetRxSince 

func (x *Container) GetRxSince() *timestamppb.Timestamp

func (*Container) GetStatus 

func (x *Container) GetStatus() string

func (*Container) GetTxRate 

func (x *Container) GetTxRate() int32

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect 

func (x *Container) ProtoReflect() protoreflect.Message

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) String 

func (x *Container) String() string

type Destination 

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=internalapi.v1.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
}

func (*Destination) Descriptor deprecated 

func (*Destination) Descriptor() ([]byte, []int)

Deprecated: Use Destination.ProtoReflect.Descriptor instead.

func (*Destination) GetContainer 

func (x *Destination) GetContainer() *Container

func (*Destination) GetId 

func (x *Destination) GetId() []byte

func (*Destination) GetName 

func (x *Destination) GetName() string

func (*Destination) GetStatus 

func (x *Destination) GetStatus() Destination_Status

func (*Destination) GetUrl 

func (x *Destination) GetUrl() string

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) ProtoReflect 

func (x *Destination) ProtoReflect() protoreflect.Message

func (*Destination) Reset 

func (x *Destination) Reset()

func (*Destination) String 

func (x *Destination) String() string

type DestinationAddedEvent 

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

func (*DestinationAddedEvent) Descriptor deprecated 

func (*DestinationAddedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationAddedEvent.ProtoReflect.Descriptor instead.

func (*DestinationAddedEvent) GetId 

func (x *DestinationAddedEvent) GetId() []byte

func (*DestinationAddedEvent) ProtoMessage 

func (*DestinationAddedEvent) ProtoMessage()

func (*DestinationAddedEvent) ProtoReflect 

func (x *DestinationAddedEvent) ProtoReflect() protoreflect.Message

func (*DestinationAddedEvent) Reset 

func (x *DestinationAddedEvent) Reset()

func (*DestinationAddedEvent) String 

func (x *DestinationAddedEvent) String() string

type DestinationRemovedEvent 

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

func (*DestinationRemovedEvent) Descriptor deprecated 

func (*DestinationRemovedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationRemovedEvent.ProtoReflect.Descriptor instead.

func (*DestinationRemovedEvent) GetId 

func (x *DestinationRemovedEvent) GetId() []byte

func (*DestinationRemovedEvent) ProtoMessage 

func (*DestinationRemovedEvent) ProtoMessage()

func (*DestinationRemovedEvent) ProtoReflect 

func (x *DestinationRemovedEvent) ProtoReflect() protoreflect.Message

func (*DestinationRemovedEvent) Reset 

func (x *DestinationRemovedEvent) Reset()

func (*DestinationRemovedEvent) String 

func (x *DestinationRemovedEvent) String() string

type DestinationStartedEvent 

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

func (*DestinationStartedEvent) Descriptor deprecated 

func (*DestinationStartedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationStartedEvent.ProtoReflect.Descriptor instead.

func (*DestinationStartedEvent) GetId 

func (x *DestinationStartedEvent) GetId() []byte

func (*DestinationStartedEvent) ProtoMessage 

func (*DestinationStartedEvent) ProtoMessage()

func (*DestinationStartedEvent) ProtoReflect 

func (x *DestinationStartedEvent) ProtoReflect() protoreflect.Message

func (*DestinationStartedEvent) Reset 

func (x *DestinationStartedEvent) Reset()

func (*DestinationStartedEvent) String 

func (x *DestinationStartedEvent) String() string

type DestinationStoppedEvent 

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

func (*DestinationStoppedEvent) Descriptor deprecated 

func (*DestinationStoppedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationStoppedEvent.ProtoReflect.Descriptor instead.

func (*DestinationStoppedEvent) GetId 

func (x *DestinationStoppedEvent) GetId() []byte

func (*DestinationStoppedEvent) ProtoMessage 

func (*DestinationStoppedEvent) ProtoMessage()

func (*DestinationStoppedEvent) ProtoReflect 

func (x *DestinationStoppedEvent) ProtoReflect() protoreflect.Message

func (*DestinationStoppedEvent) Reset 

func (x *DestinationStoppedEvent) Reset()

func (*DestinationStoppedEvent) String 

func (x *DestinationStoppedEvent) String() string

type DestinationStreamExitedEvent 

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
}

func (*DestinationStreamExitedEvent) Descriptor deprecated 

func (*DestinationStreamExitedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationStreamExitedEvent.ProtoReflect.Descriptor instead.

func (*DestinationStreamExitedEvent) GetError 

func (x *DestinationStreamExitedEvent) GetError() string

func (*DestinationStreamExitedEvent) GetId 

func (x *DestinationStreamExitedEvent) GetId() []byte

func (*DestinationStreamExitedEvent) GetName 

func (x *DestinationStreamExitedEvent) GetName() string

func (*DestinationStreamExitedEvent) ProtoMessage 

func (*DestinationStreamExitedEvent) ProtoMessage()

func (*DestinationStreamExitedEvent) ProtoReflect 

func (x *DestinationStreamExitedEvent) ProtoReflect() protoreflect.Message

func (*DestinationStreamExitedEvent) Reset 

func (x *DestinationStreamExitedEvent) Reset()

func (*DestinationStreamExitedEvent) String 

func (x *DestinationStreamExitedEvent) String() string

type DestinationUpdatedEvent 

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

func (*DestinationUpdatedEvent) Descriptor deprecated 

func (*DestinationUpdatedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationUpdatedEvent.ProtoReflect.Descriptor instead.

func (*DestinationUpdatedEvent) GetId 

func (x *DestinationUpdatedEvent) GetId() []byte

func (*DestinationUpdatedEvent) ProtoMessage 

func (*DestinationUpdatedEvent) ProtoMessage()

func (*DestinationUpdatedEvent) ProtoReflect 

func (x *DestinationUpdatedEvent) ProtoReflect() protoreflect.Message

func (*DestinationUpdatedEvent) Reset 

func (x *DestinationUpdatedEvent) Reset()

func (*DestinationUpdatedEvent) String 

func (x *DestinationUpdatedEvent) String() string

type Destination_Status 

type Destination_Status int32
const (
	Destination_STATUS_OFF_AIR  Destination_Status = 0
	Destination_STATUS_STARTING Destination_Status = 1
	Destination_STATUS_LIVE     Destination_Status = 2
)

func (Destination_Status) Descriptor 

func (Destination_Status) Descriptor() protoreflect.EnumDescriptor

func (Destination_Status) Enum 

func (x Destination_Status) Enum() *Destination_Status

func (Destination_Status) EnumDescriptor deprecated 

func (Destination_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Destination_Status.Descriptor instead.

func (Destination_Status) Number 

func (x Destination_Status) Number() protoreflect.EnumNumber

func (Destination_Status) String 

func (x Destination_Status) String() string

func (Destination_Status) Type 

func (Destination_Status) Type() protoreflect.EnumType

type DestinationsListedEvent 

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

func (*DestinationsListedEvent) Descriptor deprecated 

func (*DestinationsListedEvent) Descriptor() ([]byte, []int)

Deprecated: Use DestinationsListedEvent.ProtoReflect.Descriptor instead.

func (*DestinationsListedEvent) GetDestinations 

func (x *DestinationsListedEvent) GetDestinations() []*Destination

func (*DestinationsListedEvent) ProtoMessage 

func (*DestinationsListedEvent) ProtoMessage()

func (*DestinationsListedEvent) ProtoReflect 

func (x *DestinationsListedEvent) ProtoReflect() protoreflect.Message

func (*DestinationsListedEvent) Reset 

func (x *DestinationsListedEvent) Reset()

func (*DestinationsListedEvent) String 

func (x *DestinationsListedEvent) String() string

type Envelope 

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
}

func (*Envelope) Descriptor deprecated 

func (*Envelope) Descriptor() ([]byte, []int)

Deprecated: Use Envelope.ProtoReflect.Descriptor instead.

func (*Envelope) GetCommand 

func (x *Envelope) GetCommand() *Command

func (*Envelope) GetEvent 

func (x *Envelope) GetEvent() *Event

func (*Envelope) GetPayload 

func (x *Envelope) GetPayload() isEnvelope_Payload

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) ProtoReflect 

func (x *Envelope) ProtoReflect() protoreflect.Message

func (*Envelope) Reset 

func (x *Envelope) Reset()

func (*Envelope) String 

func (x *Envelope) String() string

type Envelope_Command 

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

type Envelope_Event 

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

type Event 

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
}

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAddDestinationFailed 

func (x *Event) GetAddDestinationFailed() *AddDestinationFailedEvent

func (*Event) GetAppStateChanged 

func (x *Event) GetAppStateChanged() *AppStateChangedEvent

func (*Event) GetDestinationAdded 

func (x *Event) GetDestinationAdded() *DestinationAddedEvent

func (*Event) GetDestinationRemoved 

func (x *Event) GetDestinationRemoved() *DestinationRemovedEvent

func (*Event) GetDestinationStarted 

func (x *Event) GetDestinationStarted() *DestinationStartedEvent

func (*Event) GetDestinationStopped 

func (x *Event) GetDestinationStopped() *DestinationStoppedEvent

func (*Event) GetDestinationStreamExited 

func (x *Event) GetDestinationStreamExited() *DestinationStreamExitedEvent

func (*Event) GetDestinationUpdated 

func (x *Event) GetDestinationUpdated() *DestinationUpdatedEvent

func (*Event) GetDestinationsListed 

func (x *Event) GetDestinationsListed() *DestinationsListedEvent

func (*Event) GetEventType 

func (x *Event) GetEventType() isEvent_EventType

func (*Event) GetFatalError 

func (x *Event) GetFatalError() *FatalErrorEvent

func (*Event) GetHandshakeCompleted 

func (x *Event) GetHandshakeCompleted() *HandshakeCompletedEvent

func (*Event) GetListDestinationsFailed 

func (x *Event) GetListDestinationsFailed() *ListDestinationsFailedEvent

func (*Event) GetMediaServerStarted 

func (x *Event) GetMediaServerStarted() *MediaServerStartedEvent

func (*Event) GetOtherInstanceDetected 

func (x *Event) GetOtherInstanceDetected() *OtherInstanceDetectedEvent

func (*Event) GetRemoveDestinationFailed 

func (x *Event) GetRemoveDestinationFailed() *RemoveDestinationFailedEvent

func (*Event) GetStartDestinationFailed 

func (x *Event) GetStartDestinationFailed() *StartDestinationFailedEvent

func (*Event) GetStopDestinationFailed 

func (x *Event) GetStopDestinationFailed() *StopDestinationFailedEvent

func (*Event) GetUpdateDestinationFailed 

func (x *Event) GetUpdateDestinationFailed() *UpdateDestinationFailedEvent

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_AddDestinationFailed 

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

type Event_AppStateChanged 

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

type Event_DestinationAdded 

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

type Event_DestinationRemoved 

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

type Event_DestinationStarted 

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

type Event_DestinationStopped 

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

type Event_DestinationStreamExited 

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

type Event_DestinationUpdated 

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

type Event_DestinationsListed 

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

type Event_FatalError 

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

type Event_HandshakeCompleted 

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

type Event_ListDestinationsFailed 

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

type Event_MediaServerStarted 

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

type Event_OtherInstanceDetected 

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

type Event_RemoveDestinationFailed 

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

type Event_StartDestinationFailed 

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

type Event_StopDestinationFailed 

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

type Event_UpdateDestinationFailed 

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

type FatalErrorEvent 

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

func (*FatalErrorEvent) Descriptor deprecated 

func (*FatalErrorEvent) Descriptor() ([]byte, []int)

Deprecated: Use FatalErrorEvent.ProtoReflect.Descriptor instead.

func (*FatalErrorEvent) GetMessage 

func (x *FatalErrorEvent) GetMessage() string

func (*FatalErrorEvent) ProtoMessage 

func (*FatalErrorEvent) ProtoMessage()

func (*FatalErrorEvent) ProtoReflect 

func (x *FatalErrorEvent) ProtoReflect() protoreflect.Message

func (*FatalErrorEvent) Reset 

func (x *FatalErrorEvent) Reset()

func (*FatalErrorEvent) String 

func (x *FatalErrorEvent) String() string

type HandshakeCompletedEvent 

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

func (*HandshakeCompletedEvent) Descriptor deprecated 

func (*HandshakeCompletedEvent) Descriptor() ([]byte, []int)

Deprecated: Use HandshakeCompletedEvent.ProtoReflect.Descriptor instead.

func (*HandshakeCompletedEvent) ProtoMessage 

func (*HandshakeCompletedEvent) ProtoMessage()

func (*HandshakeCompletedEvent) ProtoReflect 

func (x *HandshakeCompletedEvent) ProtoReflect() protoreflect.Message

func (*HandshakeCompletedEvent) Reset 

func (x *HandshakeCompletedEvent) Reset()

func (*HandshakeCompletedEvent) String 

func (x *HandshakeCompletedEvent) String() string

type KillServerCommand 

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

func (*KillServerCommand) Descriptor deprecated 

func (*KillServerCommand) Descriptor() ([]byte, []int)

Deprecated: Use KillServerCommand.ProtoReflect.Descriptor instead.

func (*KillServerCommand) ProtoMessage 

func (*KillServerCommand) ProtoMessage()

func (*KillServerCommand) ProtoReflect 

func (x *KillServerCommand) ProtoReflect() protoreflect.Message

func (*KillServerCommand) Reset 

func (x *KillServerCommand) Reset()

func (*KillServerCommand) String 

func (x *KillServerCommand) String() string

type ListDestinationsCommand 

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

func (*ListDestinationsCommand) Descriptor deprecated 

func (*ListDestinationsCommand) Descriptor() ([]byte, []int)

Deprecated: Use ListDestinationsCommand.ProtoReflect.Descriptor instead.

func (*ListDestinationsCommand) ProtoMessage 

func (*ListDestinationsCommand) ProtoMessage()

func (*ListDestinationsCommand) ProtoReflect 

func (x *ListDestinationsCommand) ProtoReflect() protoreflect.Message

func (*ListDestinationsCommand) Reset 

func (x *ListDestinationsCommand) Reset()

func (*ListDestinationsCommand) String 

func (x *ListDestinationsCommand) String() string

type ListDestinationsFailedEvent 

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

func (*ListDestinationsFailedEvent) Descriptor deprecated 

func (*ListDestinationsFailedEvent) Descriptor() ([]byte, []int)

Deprecated: Use ListDestinationsFailedEvent.ProtoReflect.Descriptor instead.

func (*ListDestinationsFailedEvent) GetError 

func (x *ListDestinationsFailedEvent) GetError() string

func (*ListDestinationsFailedEvent) ProtoMessage 

func (*ListDestinationsFailedEvent) ProtoMessage()

func (*ListDestinationsFailedEvent) ProtoReflect 

func (x *ListDestinationsFailedEvent) ProtoReflect() protoreflect.Message

func (*ListDestinationsFailedEvent) Reset 

func (x *ListDestinationsFailedEvent) Reset()

func (*ListDestinationsFailedEvent) String 

func (x *ListDestinationsFailedEvent) String() string

type ListDestinationsRequest 

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

func (*ListDestinationsRequest) Descriptor deprecated 

func (*ListDestinationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListDestinationsRequest.ProtoReflect.Descriptor instead.

func (*ListDestinationsRequest) GetCommand 

func (x *ListDestinationsRequest) GetCommand() *ListDestinationsCommand

func (*ListDestinationsRequest) ProtoMessage 

func (*ListDestinationsRequest) ProtoMessage()

func (*ListDestinationsRequest) ProtoReflect 

func (x *ListDestinationsRequest) ProtoReflect() protoreflect.Message

func (*ListDestinationsRequest) Reset 

func (x *ListDestinationsRequest) Reset()

func (*ListDestinationsRequest) String 

func (x *ListDestinationsRequest) String() string

type ListDestinationsResponse 

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
}

func (*ListDestinationsResponse) Descriptor deprecated 

func (*ListDestinationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListDestinationsResponse.ProtoReflect.Descriptor instead.

func (*ListDestinationsResponse) GetError 

func (x *ListDestinationsResponse) GetError() *ListDestinationsFailedEvent

func (*ListDestinationsResponse) GetOk 

func (x *ListDestinationsResponse) GetOk() *DestinationsListedEvent

func (*ListDestinationsResponse) GetResult 

func (x *ListDestinationsResponse) GetResult() isListDestinationsResponse_Result

func (*ListDestinationsResponse) ProtoMessage 

func (*ListDestinationsResponse) ProtoMessage()

func (*ListDestinationsResponse) ProtoReflect 

func (x *ListDestinationsResponse) ProtoReflect() protoreflect.Message

func (*ListDestinationsResponse) Reset 

func (x *ListDestinationsResponse) Reset()

func (*ListDestinationsResponse) String 

func (x *ListDestinationsResponse) String() string

type ListDestinationsResponse_Error 

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

type ListDestinationsResponse_Ok 

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

type MediaServerStartedEvent 

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

func (*MediaServerStartedEvent) Descriptor deprecated 

func (*MediaServerStartedEvent) Descriptor() ([]byte, []int)

Deprecated: Use MediaServerStartedEvent.ProtoReflect.Descriptor instead.

func (*MediaServerStartedEvent) ProtoMessage 

func (*MediaServerStartedEvent) ProtoMessage()

func (*MediaServerStartedEvent) ProtoReflect 

func (x *MediaServerStartedEvent) ProtoReflect() protoreflect.Message

func (*MediaServerStartedEvent) Reset 

func (x *MediaServerStartedEvent) Reset()

func (*MediaServerStartedEvent) String 

func (x *MediaServerStartedEvent) String() string

type OtherInstanceDetectedEvent 

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

func (*OtherInstanceDetectedEvent) Descriptor deprecated 

func (*OtherInstanceDetectedEvent) Descriptor() ([]byte, []int)

Deprecated: Use OtherInstanceDetectedEvent.ProtoReflect.Descriptor instead.

func (*OtherInstanceDetectedEvent) ProtoMessage 

func (*OtherInstanceDetectedEvent) ProtoMessage()

func (*OtherInstanceDetectedEvent) ProtoReflect 

func (x *OtherInstanceDetectedEvent) ProtoReflect() protoreflect.Message

func (*OtherInstanceDetectedEvent) Reset 

func (x *OtherInstanceDetectedEvent) Reset()

func (*OtherInstanceDetectedEvent) String 

func (x *OtherInstanceDetectedEvent) String() string

type RemoveDestinationCommand 

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
}

func (*RemoveDestinationCommand) Descriptor deprecated 

func (*RemoveDestinationCommand) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDestinationCommand.ProtoReflect.Descriptor instead.

func (*RemoveDestinationCommand) GetForce 

func (x *RemoveDestinationCommand) GetForce() bool

func (*RemoveDestinationCommand) GetId 

func (x *RemoveDestinationCommand) GetId() []byte

func (*RemoveDestinationCommand) ProtoMessage 

func (*RemoveDestinationCommand) ProtoMessage()

func (*RemoveDestinationCommand) ProtoReflect 

func (x *RemoveDestinationCommand) ProtoReflect() protoreflect.Message

func (*RemoveDestinationCommand) Reset 

func (x *RemoveDestinationCommand) Reset()

func (*RemoveDestinationCommand) String 

func (x *RemoveDestinationCommand) String() string

type RemoveDestinationFailedEvent 

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
}

func (*RemoveDestinationFailedEvent) Descriptor deprecated 

func (*RemoveDestinationFailedEvent) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDestinationFailedEvent.ProtoReflect.Descriptor instead.

func (*RemoveDestinationFailedEvent) GetError 

func (x *RemoveDestinationFailedEvent) GetError() string

func (*RemoveDestinationFailedEvent) GetId 

func (x *RemoveDestinationFailedEvent) GetId() []byte

func (*RemoveDestinationFailedEvent) ProtoMessage 

func (*RemoveDestinationFailedEvent) ProtoMessage()

func (*RemoveDestinationFailedEvent) ProtoReflect 

func (x *RemoveDestinationFailedEvent) ProtoReflect() protoreflect.Message

func (*RemoveDestinationFailedEvent) Reset 

func (x *RemoveDestinationFailedEvent) Reset()

func (*RemoveDestinationFailedEvent) String 

func (x *RemoveDestinationFailedEvent) String() string

type RemoveDestinationRequest 

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

func (*RemoveDestinationRequest) Descriptor deprecated 

func (*RemoveDestinationRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDestinationRequest.ProtoReflect.Descriptor instead.

func (*RemoveDestinationRequest) GetCommand 

func (x *RemoveDestinationRequest) GetCommand() *RemoveDestinationCommand

func (*RemoveDestinationRequest) ProtoMessage 

func (*RemoveDestinationRequest) ProtoMessage()

func (*RemoveDestinationRequest) ProtoReflect 

func (x *RemoveDestinationRequest) ProtoReflect() protoreflect.Message

func (*RemoveDestinationRequest) Reset 

func (x *RemoveDestinationRequest) Reset()

func (*RemoveDestinationRequest) String 

func (x *RemoveDestinationRequest) String() string

type RemoveDestinationResponse 

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
}

func (*RemoveDestinationResponse) Descriptor deprecated 

func (*RemoveDestinationResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveDestinationResponse.ProtoReflect.Descriptor instead.

func (*RemoveDestinationResponse) GetError 

func (x *RemoveDestinationResponse) GetError() *RemoveDestinationFailedEvent

func (*RemoveDestinationResponse) GetOk 

func (x *RemoveDestinationResponse) GetOk() *DestinationRemovedEvent

func (*RemoveDestinationResponse) GetResult 

func (x *RemoveDestinationResponse) GetResult() isRemoveDestinationResponse_Result

func (*RemoveDestinationResponse) ProtoMessage 

func (*RemoveDestinationResponse) ProtoMessage()

func (*RemoveDestinationResponse) ProtoReflect 

func (x *RemoveDestinationResponse) ProtoReflect() protoreflect.Message

func (*RemoveDestinationResponse) Reset 

func (x *RemoveDestinationResponse) Reset()

func (*RemoveDestinationResponse) String 

func (x *RemoveDestinationResponse) String() string

type RemoveDestinationResponse_Error 

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

type RemoveDestinationResponse_Ok 

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

type Source 

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
}

func (*Source) Descriptor deprecated 

func (*Source) Descriptor() ([]byte, []int)

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetContainer 

func (x *Source) GetContainer() *Container

func (*Source) GetExitReason 

func (x *Source) GetExitReason() string

func (*Source) GetLive 

func (x *Source) GetLive() bool

func (*Source) GetLiveChangedAt 

func (x *Source) GetLiveChangedAt() *timestamppb.Timestamp

func (*Source) GetRtmpUrl 

func (x *Source) GetRtmpUrl() string

func (*Source) GetRtmpsUrl 

func (x *Source) GetRtmpsUrl() string

func (*Source) GetTracks 

func (x *Source) GetTracks() []string

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

func (x *Source) ProtoReflect() protoreflect.Message

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type StartDestinationCommand 

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

func (*StartDestinationCommand) Descriptor deprecated 

func (*StartDestinationCommand) Descriptor() ([]byte, []int)

Deprecated: Use StartDestinationCommand.ProtoReflect.Descriptor instead.

func (*StartDestinationCommand) GetId 

func (x *StartDestinationCommand) GetId() []byte

func (*StartDestinationCommand) ProtoMessage 

func (*StartDestinationCommand) ProtoMessage()

func (*StartDestinationCommand) ProtoReflect 

func (x *StartDestinationCommand) ProtoReflect() protoreflect.Message

func (*StartDestinationCommand) Reset 

func (x *StartDestinationCommand) Reset()

func (*StartDestinationCommand) String 

func (x *StartDestinationCommand) String() string

type StartDestinationFailedEvent 

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
}

func (*StartDestinationFailedEvent) Descriptor deprecated 

func (*StartDestinationFailedEvent) Descriptor() ([]byte, []int)

Deprecated: Use StartDestinationFailedEvent.ProtoReflect.Descriptor instead.

func (*StartDestinationFailedEvent) GetError 

func (x *StartDestinationFailedEvent) GetError() string

func (*StartDestinationFailedEvent) GetId 

func (x *StartDestinationFailedEvent) GetId() []byte

func (*StartDestinationFailedEvent) ProtoMessage 

func (*StartDestinationFailedEvent) ProtoMessage()

func (*StartDestinationFailedEvent) ProtoReflect 

func (x *StartDestinationFailedEvent) ProtoReflect() protoreflect.Message

func (*StartDestinationFailedEvent) Reset 

func (x *StartDestinationFailedEvent) Reset()

func (*StartDestinationFailedEvent) String 

func (x *StartDestinationFailedEvent) String() string

type StartDestinationRequest 

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

func (*StartDestinationRequest) Descriptor deprecated 

func (*StartDestinationRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartDestinationRequest.ProtoReflect.Descriptor instead.

func (*StartDestinationRequest) GetCommand 

func (x *StartDestinationRequest) GetCommand() *StartDestinationCommand

func (*StartDestinationRequest) ProtoMessage 

func (*StartDestinationRequest) ProtoMessage()

func (*StartDestinationRequest) ProtoReflect 

func (x *StartDestinationRequest) ProtoReflect() protoreflect.Message

func (*StartDestinationRequest) Reset 

func (x *StartDestinationRequest) Reset()

func (*StartDestinationRequest) String 

func (x *StartDestinationRequest) String() string

type StartDestinationResponse 

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
}

func (*StartDestinationResponse) Descriptor deprecated 

func (*StartDestinationResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartDestinationResponse.ProtoReflect.Descriptor instead.

func (*StartDestinationResponse) GetError 

func (x *StartDestinationResponse) GetError() *StartDestinationFailedEvent

func (*StartDestinationResponse) GetOk 

func (x *StartDestinationResponse) GetOk() *DestinationStartedEvent

func (*StartDestinationResponse) GetResult 

func (x *StartDestinationResponse) GetResult() isStartDestinationResponse_Result

func (*StartDestinationResponse) ProtoMessage 

func (*StartDestinationResponse) ProtoMessage()

func (*StartDestinationResponse) ProtoReflect 

func (x *StartDestinationResponse) ProtoReflect() protoreflect.Message

func (*StartDestinationResponse) Reset 

func (x *StartDestinationResponse) Reset()

func (*StartDestinationResponse) String 

func (x *StartDestinationResponse) String() string

type StartDestinationResponse_Error 

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

type StartDestinationResponse_Ok 

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

type StartHandshakeCommand 

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

func (*StartHandshakeCommand) Descriptor deprecated 

func (*StartHandshakeCommand) Descriptor() ([]byte, []int)

Deprecated: Use StartHandshakeCommand.ProtoReflect.Descriptor instead.

func (*StartHandshakeCommand) ProtoMessage 

func (*StartHandshakeCommand) ProtoMessage()

func (*StartHandshakeCommand) ProtoReflect 

func (x *StartHandshakeCommand) ProtoReflect() protoreflect.Message

func (*StartHandshakeCommand) Reset 

func (x *StartHandshakeCommand) Reset()

func (*StartHandshakeCommand) String 

func (x *StartHandshakeCommand) String() string

type StopDestinationCommand 

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

func (*StopDestinationCommand) Descriptor deprecated 

func (*StopDestinationCommand) Descriptor() ([]byte, []int)

Deprecated: Use StopDestinationCommand.ProtoReflect.Descriptor instead.

func (*StopDestinationCommand) GetId 

func (x *StopDestinationCommand) GetId() []byte

func (*StopDestinationCommand) ProtoMessage 

func (*StopDestinationCommand) ProtoMessage()

func (*StopDestinationCommand) ProtoReflect 

func (x *StopDestinationCommand) ProtoReflect() protoreflect.Message

func (*StopDestinationCommand) Reset 

func (x *StopDestinationCommand) Reset()

func (*StopDestinationCommand) String 

func (x *StopDestinationCommand) String() string

type StopDestinationFailedEvent 

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
}

func (*StopDestinationFailedEvent) Descriptor deprecated 

func (*StopDestinationFailedEvent) Descriptor() ([]byte, []int)

Deprecated: Use StopDestinationFailedEvent.ProtoReflect.Descriptor instead.

func (*StopDestinationFailedEvent) GetError 

func (x *StopDestinationFailedEvent) GetError() string

func (*StopDestinationFailedEvent) GetId 

func (x *StopDestinationFailedEvent) GetId() []byte

func (*StopDestinationFailedEvent) ProtoMessage 

func (*StopDestinationFailedEvent) ProtoMessage()

func (*StopDestinationFailedEvent) ProtoReflect 

func (x *StopDestinationFailedEvent) ProtoReflect() protoreflect.Message

func (*StopDestinationFailedEvent) Reset 

func (x *StopDestinationFailedEvent) Reset()

func (*StopDestinationFailedEvent) String 

func (x *StopDestinationFailedEvent) String() string

type StopDestinationRequest 

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

func (*StopDestinationRequest) Descriptor deprecated 

func (*StopDestinationRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopDestinationRequest.ProtoReflect.Descriptor instead.

func (*StopDestinationRequest) GetCommand 

func (x *StopDestinationRequest) GetCommand() *StopDestinationCommand

func (*StopDestinationRequest) ProtoMessage 

func (*StopDestinationRequest) ProtoMessage()

func (*StopDestinationRequest) ProtoReflect 

func (x *StopDestinationRequest) ProtoReflect() protoreflect.Message

func (*StopDestinationRequest) Reset 

func (x *StopDestinationRequest) Reset()

func (*StopDestinationRequest) String 

func (x *StopDestinationRequest) String() string

type StopDestinationResponse 

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
}

func (*StopDestinationResponse) Descriptor deprecated 

func (*StopDestinationResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopDestinationResponse.ProtoReflect.Descriptor instead.

func (*StopDestinationResponse) GetError 

func (x *StopDestinationResponse) GetError() *StopDestinationFailedEvent

func (*StopDestinationResponse) GetOk 

func (x *StopDestinationResponse) GetOk() *DestinationStoppedEvent

func (*StopDestinationResponse) GetResult 

func (x *StopDestinationResponse) GetResult() isStopDestinationResponse_Result

func (*StopDestinationResponse) ProtoMessage 

func (*StopDestinationResponse) ProtoMessage()

func (*StopDestinationResponse) ProtoReflect 

func (x *StopDestinationResponse) ProtoReflect() protoreflect.Message

func (*StopDestinationResponse) Reset 

func (x *StopDestinationResponse) Reset()

func (*StopDestinationResponse) String 

func (x *StopDestinationResponse) String() string

type StopDestinationResponse_Error 

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

type StopDestinationResponse_Ok 

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

type UpdateDestinationCommand 

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
}

func (*UpdateDestinationCommand) Descriptor deprecated 

func (*UpdateDestinationCommand) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDestinationCommand.ProtoReflect.Descriptor instead.

func (*UpdateDestinationCommand) GetId 

func (x *UpdateDestinationCommand) GetId() []byte

func (*UpdateDestinationCommand) GetName 

func (x *UpdateDestinationCommand) GetName() string

func (*UpdateDestinationCommand) GetUrl 

func (x *UpdateDestinationCommand) GetUrl() string

func (*UpdateDestinationCommand) ProtoMessage 

func (*UpdateDestinationCommand) ProtoMessage()

func (*UpdateDestinationCommand) ProtoReflect 

func (x *UpdateDestinationCommand) ProtoReflect() protoreflect.Message

func (*UpdateDestinationCommand) Reset 

func (x *UpdateDestinationCommand) Reset()

func (*UpdateDestinationCommand) String 

func (x *UpdateDestinationCommand) String() string

type UpdateDestinationFailedEvent 

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
}

func (*UpdateDestinationFailedEvent) Descriptor deprecated 

func (*UpdateDestinationFailedEvent) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDestinationFailedEvent.ProtoReflect.Descriptor instead.

func (*UpdateDestinationFailedEvent) GetError 

func (x *UpdateDestinationFailedEvent) GetError() string

func (*UpdateDestinationFailedEvent) GetId 

func (x *UpdateDestinationFailedEvent) GetId() []byte

func (*UpdateDestinationFailedEvent) ProtoMessage 

func (*UpdateDestinationFailedEvent) ProtoMessage()

func (*UpdateDestinationFailedEvent) ProtoReflect 

func (x *UpdateDestinationFailedEvent) ProtoReflect() protoreflect.Message

func (*UpdateDestinationFailedEvent) Reset 

func (x *UpdateDestinationFailedEvent) Reset()

func (*UpdateDestinationFailedEvent) String 

func (x *UpdateDestinationFailedEvent) String() string

type UpdateDestinationRequest 

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

func (*UpdateDestinationRequest) Descriptor deprecated 

func (*UpdateDestinationRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDestinationRequest.ProtoReflect.Descriptor instead.

func (*UpdateDestinationRequest) GetCommand 

func (x *UpdateDestinationRequest) GetCommand() *UpdateDestinationCommand

func (*UpdateDestinationRequest) ProtoMessage 

func (*UpdateDestinationRequest) ProtoMessage()

func (*UpdateDestinationRequest) ProtoReflect 

func (x *UpdateDestinationRequest) ProtoReflect() protoreflect.Message

func (*UpdateDestinationRequest) Reset 

func (x *UpdateDestinationRequest) Reset()

func (*UpdateDestinationRequest) String 

func (x *UpdateDestinationRequest) String() string

type UpdateDestinationResponse 

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
}

func (*UpdateDestinationResponse) Descriptor deprecated 

func (*UpdateDestinationResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateDestinationResponse.ProtoReflect.Descriptor instead.

func (*UpdateDestinationResponse) GetError 

func (x *UpdateDestinationResponse) GetError() *UpdateDestinationFailedEvent

func (*UpdateDestinationResponse) GetOk 

func (x *UpdateDestinationResponse) GetOk() *DestinationUpdatedEvent

func (*UpdateDestinationResponse) GetResult 

func (x *UpdateDestinationResponse) GetResult() isUpdateDestinationResponse_Result

func (*UpdateDestinationResponse) ProtoMessage 

func (*UpdateDestinationResponse) ProtoMessage()

func (*UpdateDestinationResponse) ProtoReflect 

func (x *UpdateDestinationResponse) ProtoReflect() protoreflect.Message

func (*UpdateDestinationResponse) Reset 

func (x *UpdateDestinationResponse) Reset()

func (*UpdateDestinationResponse) String 

func (x *UpdateDestinationResponse) String() string

type UpdateDestinationResponse_Error 

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

type UpdateDestinationResponse_Ok 

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

Source Files

View all Source files

Directories

Path Synopsis

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.