grpc

package

Go to main page

Versions in this module

v0

v0.0.15

Jul 27, 2025

v0.0.13

Jun 22, 2025

Changes in this version

+ const InternalAPI_AddDestination_FullMethodName

+ const InternalAPI_Communicate_FullMethodName

+ const InternalAPI_ListDestinations_FullMethodName

+ const InternalAPI_RemoveDestination_FullMethodName

+ const InternalAPI_StartDestination_FullMethodName

+ const InternalAPI_StopDestination_FullMethodName

+ const InternalAPI_UpdateDestination_FullMethodName

type DestinationStreamExitedEvent

+ Id []byte

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

v0.0.12

Jun 5, 2025

Changes in this version

+ type AddDestinationRequest struct

+ Command *AddDestinationCommand

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

+ func (*AddDestinationRequest) ProtoMessage()

+ func (x *AddDestinationRequest) GetCommand() *AddDestinationCommand

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

+ func (x *AddDestinationRequest) Reset()

+ func (x *AddDestinationRequest) String() string

+ type AddDestinationResponse struct

+ Result isAddDestinationResponse_Result

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

+ func (*AddDestinationResponse) ProtoMessage()

+ func (m *AddDestinationResponse) GetResult() isAddDestinationResponse_Result

+ func (x *AddDestinationResponse) GetError() *AddDestinationFailedEvent

+ func (x *AddDestinationResponse) GetOk() *DestinationAddedEvent

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

+ func (x *AddDestinationResponse) Reset()

+ func (x *AddDestinationResponse) String() string

+ type AddDestinationResponse_Error struct

+ Error *AddDestinationFailedEvent

+ type AddDestinationResponse_Ok struct

+ Ok *DestinationAddedEvent

type Command

+ func (x *Command) GetListDestinations() *ListDestinationsCommand

+ func (x *Command) GetUpdateDestination() *UpdateDestinationCommand

+ type Command_ListDestinations struct

+ ListDestinations *ListDestinationsCommand

+ type Command_UpdateDestination struct

+ UpdateDestination *UpdateDestinationCommand

type Destination

+ Id []byte

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

type DestinationAddedEvent

+ Id []byte

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

type DestinationRemovedEvent

+ Id []byte

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

+ type DestinationStartedEvent struct

+ Id []byte

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

+ func (*DestinationStartedEvent) ProtoMessage()

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

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

+ func (x *DestinationStartedEvent) Reset()

+ func (x *DestinationStartedEvent) String() string

+ type DestinationStoppedEvent struct

+ Id []byte

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

+ func (*DestinationStoppedEvent) ProtoMessage()

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

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

+ func (x *DestinationStoppedEvent) Reset()

+ func (x *DestinationStoppedEvent) String() string

+ type DestinationUpdatedEvent struct

+ Id []byte

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

+ func (*DestinationUpdatedEvent) ProtoMessage()

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

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

+ func (x *DestinationUpdatedEvent) Reset()

+ func (x *DestinationUpdatedEvent) String() string

+ type DestinationsListedEvent struct

+ Destinations []*Destination

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

+ func (*DestinationsListedEvent) ProtoMessage()

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

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

+ func (x *DestinationsListedEvent) Reset()

+ func (x *DestinationsListedEvent) String() string

type Event

+ func (x *Event) GetDestinationStarted() *DestinationStartedEvent

+ func (x *Event) GetDestinationStopped() *DestinationStoppedEvent

+ func (x *Event) GetDestinationUpdated() *DestinationUpdatedEvent

+ func (x *Event) GetDestinationsListed() *DestinationsListedEvent

+ func (x *Event) GetListDestinationsFailed() *ListDestinationsFailedEvent

+ func (x *Event) GetStopDestinationFailed() *StopDestinationFailedEvent

+ func (x *Event) GetUpdateDestinationFailed() *UpdateDestinationFailedEvent

+ type Event_DestinationStarted struct

+ DestinationStarted *DestinationStartedEvent

+ type Event_DestinationStopped struct

+ DestinationStopped *DestinationStoppedEvent

+ type Event_DestinationUpdated struct

+ DestinationUpdated *DestinationUpdatedEvent

+ type Event_DestinationsListed struct

+ DestinationsListed *DestinationsListedEvent

+ type Event_ListDestinationsFailed struct

+ ListDestinationsFailed *ListDestinationsFailedEvent

+ type Event_StopDestinationFailed struct

+ StopDestinationFailed *StopDestinationFailedEvent

+ type Event_UpdateDestinationFailed struct

+ UpdateDestinationFailed *UpdateDestinationFailedEvent

type InternalAPIClient

+ AddDestination func(ctx context.Context, in *AddDestinationRequest, opts ...grpc.CallOption) (*AddDestinationResponse, error)

+ ListDestinations func(ctx context.Context, in *ListDestinationsRequest, opts ...grpc.CallOption) (*ListDestinationsResponse, error)

+ RemoveDestination func(ctx context.Context, in *RemoveDestinationRequest, opts ...grpc.CallOption) (*RemoveDestinationResponse, error)

+ StartDestination func(ctx context.Context, in *StartDestinationRequest, opts ...grpc.CallOption) (*StartDestinationResponse, error)

+ StopDestination func(ctx context.Context, in *StopDestinationRequest, opts ...grpc.CallOption) (*StopDestinationResponse, error)

+ UpdateDestination func(ctx context.Context, in *UpdateDestinationRequest, opts ...grpc.CallOption) (*UpdateDestinationResponse, error)

type InternalAPIServer

+ AddDestination func(context.Context, *AddDestinationRequest) (*AddDestinationResponse, error)

+ ListDestinations func(context.Context, *ListDestinationsRequest) (*ListDestinationsResponse, error)

+ RemoveDestination func(context.Context, *RemoveDestinationRequest) (*RemoveDestinationResponse, error)

+ StartDestination func(context.Context, *StartDestinationRequest) (*StartDestinationResponse, error)

+ StopDestination func(context.Context, *StopDestinationRequest) (*StopDestinationResponse, error)

+ UpdateDestination func(context.Context, *UpdateDestinationRequest) (*UpdateDestinationResponse, error)

+ type ListDestinationsCommand struct

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

+ func (*ListDestinationsCommand) ProtoMessage()

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

+ func (x *ListDestinationsCommand) Reset()

+ func (x *ListDestinationsCommand) String() string

+ type ListDestinationsFailedEvent struct

+ Error string

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

+ func (*ListDestinationsFailedEvent) ProtoMessage()

+ func (x *ListDestinationsFailedEvent) GetError() string

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

+ func (x *ListDestinationsFailedEvent) Reset()

+ func (x *ListDestinationsFailedEvent) String() string

+ type ListDestinationsRequest struct

+ Command *ListDestinationsCommand

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

+ func (*ListDestinationsRequest) ProtoMessage()

+ func (x *ListDestinationsRequest) GetCommand() *ListDestinationsCommand

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

+ func (x *ListDestinationsRequest) Reset()

+ func (x *ListDestinationsRequest) String() string

+ type ListDestinationsResponse struct

+ Result isListDestinationsResponse_Result

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

+ func (*ListDestinationsResponse) ProtoMessage()

+ func (m *ListDestinationsResponse) GetResult() isListDestinationsResponse_Result

+ func (x *ListDestinationsResponse) GetError() *ListDestinationsFailedEvent

+ func (x *ListDestinationsResponse) GetOk() *DestinationsListedEvent

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

+ func (x *ListDestinationsResponse) Reset()

+ func (x *ListDestinationsResponse) String() string

+ type ListDestinationsResponse_Error struct

+ Error *ListDestinationsFailedEvent

+ type ListDestinationsResponse_Ok struct

+ Ok *DestinationsListedEvent

type RemoveDestinationCommand

+ Force bool

+ Id []byte

+ func (x *RemoveDestinationCommand) GetForce() bool

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

type RemoveDestinationFailedEvent

+ Id []byte

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

+ type RemoveDestinationRequest struct

+ Command *RemoveDestinationCommand

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

+ func (*RemoveDestinationRequest) ProtoMessage()

+ func (x *RemoveDestinationRequest) GetCommand() *RemoveDestinationCommand

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

+ func (x *RemoveDestinationRequest) Reset()

+ func (x *RemoveDestinationRequest) String() string

+ type RemoveDestinationResponse struct

+ Result isRemoveDestinationResponse_Result

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

+ func (*RemoveDestinationResponse) ProtoMessage()

+ func (m *RemoveDestinationResponse) GetResult() isRemoveDestinationResponse_Result

+ func (x *RemoveDestinationResponse) GetError() *RemoveDestinationFailedEvent

+ func (x *RemoveDestinationResponse) GetOk() *DestinationRemovedEvent

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

+ func (x *RemoveDestinationResponse) Reset()

+ func (x *RemoveDestinationResponse) String() string

+ type RemoveDestinationResponse_Error struct

+ Error *RemoveDestinationFailedEvent

+ type RemoveDestinationResponse_Ok struct

+ Ok *DestinationRemovedEvent

type StartDestinationCommand

+ Id []byte

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

type StartDestinationFailedEvent

+ Error string

+ Id []byte

+ func (x *StartDestinationFailedEvent) GetError() string

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

+ type StartDestinationRequest struct

+ Command *StartDestinationCommand

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

+ func (*StartDestinationRequest) ProtoMessage()

+ func (x *StartDestinationRequest) GetCommand() *StartDestinationCommand

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

+ func (x *StartDestinationRequest) Reset()

+ func (x *StartDestinationRequest) String() string

+ type StartDestinationResponse struct

+ Result isStartDestinationResponse_Result

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

+ func (*StartDestinationResponse) ProtoMessage()

+ func (m *StartDestinationResponse) GetResult() isStartDestinationResponse_Result

+ func (x *StartDestinationResponse) GetError() *StartDestinationFailedEvent

+ func (x *StartDestinationResponse) GetOk() *DestinationStartedEvent

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

+ func (x *StartDestinationResponse) Reset()

+ func (x *StartDestinationResponse) String() string

+ type StartDestinationResponse_Error struct

+ Error *StartDestinationFailedEvent

+ type StartDestinationResponse_Ok struct

+ Ok *DestinationStartedEvent

type StopDestinationCommand

+ Id []byte

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

+ type StopDestinationFailedEvent struct

+ Error string

+ Id []byte

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

+ func (*StopDestinationFailedEvent) ProtoMessage()

+ func (x *StopDestinationFailedEvent) GetError() string

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

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

+ func (x *StopDestinationFailedEvent) Reset()

+ func (x *StopDestinationFailedEvent) String() string

+ type StopDestinationRequest struct

+ Command *StopDestinationCommand

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

+ func (*StopDestinationRequest) ProtoMessage()

+ func (x *StopDestinationRequest) GetCommand() *StopDestinationCommand

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

+ func (x *StopDestinationRequest) Reset()

+ func (x *StopDestinationRequest) String() string

+ type StopDestinationResponse struct

+ Result isStopDestinationResponse_Result

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

+ func (*StopDestinationResponse) ProtoMessage()

+ func (m *StopDestinationResponse) GetResult() isStopDestinationResponse_Result

+ func (x *StopDestinationResponse) GetError() *StopDestinationFailedEvent

+ func (x *StopDestinationResponse) GetOk() *DestinationStoppedEvent

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

+ func (x *StopDestinationResponse) Reset()

+ func (x *StopDestinationResponse) String() string

+ type StopDestinationResponse_Error struct

+ Error *StopDestinationFailedEvent

+ type StopDestinationResponse_Ok struct

+ Ok *DestinationStoppedEvent

type UnimplementedInternalAPIServer

+ func (UnimplementedInternalAPIServer) AddDestination(context.Context, *AddDestinationRequest) (*AddDestinationResponse, error)

+ func (UnimplementedInternalAPIServer) ListDestinations(context.Context, *ListDestinationsRequest) (*ListDestinationsResponse, error)

+ func (UnimplementedInternalAPIServer) RemoveDestination(context.Context, *RemoveDestinationRequest) (*RemoveDestinationResponse, error)

+ func (UnimplementedInternalAPIServer) StartDestination(context.Context, *StartDestinationRequest) (*StartDestinationResponse, error)

+ func (UnimplementedInternalAPIServer) StopDestination(context.Context, *StopDestinationRequest) (*StopDestinationResponse, error)

+ func (UnimplementedInternalAPIServer) UpdateDestination(context.Context, *UpdateDestinationRequest) (*UpdateDestinationResponse, error)

+ type UpdateDestinationCommand struct

+ Id []byte

+ Name *string

+ Url *string

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

+ func (*UpdateDestinationCommand) ProtoMessage()

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

+ func (x *UpdateDestinationCommand) GetName() string

+ func (x *UpdateDestinationCommand) GetUrl() string

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

+ func (x *UpdateDestinationCommand) Reset()

+ func (x *UpdateDestinationCommand) String() string

+ type UpdateDestinationFailedEvent struct

+ Error string

+ Id []byte

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

+ func (*UpdateDestinationFailedEvent) ProtoMessage()

+ func (x *UpdateDestinationFailedEvent) GetError() string

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

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

+ func (x *UpdateDestinationFailedEvent) Reset()

+ func (x *UpdateDestinationFailedEvent) String() string

+ type UpdateDestinationRequest struct

+ Command *UpdateDestinationCommand

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

+ func (*UpdateDestinationRequest) ProtoMessage()

+ func (x *UpdateDestinationRequest) GetCommand() *UpdateDestinationCommand

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

+ func (x *UpdateDestinationRequest) Reset()

+ func (x *UpdateDestinationRequest) String() string

+ type UpdateDestinationResponse struct

+ Result isUpdateDestinationResponse_Result

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

+ func (*UpdateDestinationResponse) ProtoMessage()

+ func (m *UpdateDestinationResponse) GetResult() isUpdateDestinationResponse_Result

+ func (x *UpdateDestinationResponse) GetError() *UpdateDestinationFailedEvent

+ func (x *UpdateDestinationResponse) GetOk() *DestinationUpdatedEvent

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

+ func (x *UpdateDestinationResponse) Reset()

+ func (x *UpdateDestinationResponse) String() string

+ type UpdateDestinationResponse_Error struct

+ Error *UpdateDestinationFailedEvent

+ type UpdateDestinationResponse_Ok struct

+ Ok *DestinationUpdatedEvent

v0.0.11

May 23, 2025

v0.0.10

May 18, 2025

Changes in this version

+ var Destination_Status_name = map[int32]string

+ var Destination_Status_value = map[string]int32

+ var File_api_proto protoreflect.FileDescriptor

+ var File_command_proto protoreflect.FileDescriptor

+ var File_domain_proto protoreflect.FileDescriptor

+ var File_event_proto protoreflect.FileDescriptor

+ var InternalAPI_ServiceDesc = grpc.ServiceDesc

+ func RegisterInternalAPIServer(s grpc.ServiceRegistrar, srv InternalAPIServer)

+ type AddDestinationCommand struct

+ Name string

+ Url string

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

+ func (*AddDestinationCommand) ProtoMessage()

+ func (x *AddDestinationCommand) GetName() string

+ func (x *AddDestinationCommand) GetUrl() string

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

+ func (x *AddDestinationCommand) Reset()

+ func (x *AddDestinationCommand) String() string

+ type AddDestinationFailedEvent struct

+ Error string

+ Url string

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

+ func (*AddDestinationFailedEvent) ProtoMessage()

+ func (x *AddDestinationFailedEvent) GetError() string

+ func (x *AddDestinationFailedEvent) GetUrl() string

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

+ func (x *AddDestinationFailedEvent) Reset()

+ func (x *AddDestinationFailedEvent) String() string

+ type AppState struct

+ BuildInfo *BuildInfo

+ Destinations []*Destination

+ Source *Source

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

+ func (*AppState) ProtoMessage()

+ func (x *AppState) GetBuildInfo() *BuildInfo

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

+ func (x *AppState) GetSource() *Source

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

+ func (x *AppState) Reset()

+ func (x *AppState) String() string

+ type AppStateChangedEvent struct

+ AppState *AppState

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

+ func (*AppStateChangedEvent) ProtoMessage()

+ func (x *AppStateChangedEvent) GetAppState() *AppState

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

+ func (x *AppStateChangedEvent) Reset()

+ func (x *AppStateChangedEvent) String() string

+ type BuildInfo struct

+ Commit string

+ Date string

+ GoVersion string

+ Version string

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

+ func (*BuildInfo) ProtoMessage()

+ func (x *BuildInfo) GetCommit() string

+ func (x *BuildInfo) GetDate() string

+ func (x *BuildInfo) GetGoVersion() string

+ func (x *BuildInfo) GetVersion() string

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

+ func (x *BuildInfo) Reset()

+ func (x *BuildInfo) String() string

+ type CloseOtherInstancesCommand struct

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

+ func (*CloseOtherInstancesCommand) ProtoMessage()

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

+ func (x *CloseOtherInstancesCommand) Reset()

+ func (x *CloseOtherInstancesCommand) String() string

+ type Command struct

+ CommandType isCommand_CommandType

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

+ func (*Command) ProtoMessage()

+ func (m *Command) GetCommandType() isCommand_CommandType

+ func (x *Command) GetAddDestination() *AddDestinationCommand

+ func (x *Command) GetCloseOtherInstances() *CloseOtherInstancesCommand

+ func (x *Command) GetKillServer() *KillServerCommand

+ func (x *Command) GetRemoveDestination() *RemoveDestinationCommand

+ func (x *Command) GetStartDestination() *StartDestinationCommand

+ func (x *Command) GetStartHandshake() *StartHandshakeCommand

+ func (x *Command) GetStopDestination() *StopDestinationCommand

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

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type Command_AddDestination struct

+ AddDestination *AddDestinationCommand

+ type Command_CloseOtherInstances struct

+ CloseOtherInstances *CloseOtherInstancesCommand

+ type Command_KillServer struct

+ KillServer *KillServerCommand

+ type Command_RemoveDestination struct

+ RemoveDestination *RemoveDestinationCommand

+ type Command_StartDestination struct

+ StartDestination *StartDestinationCommand

+ type Command_StartHandshake struct

+ StartHandshake *StartHandshakeCommand

+ type Command_StopDestination struct

+ StopDestination *StopDestinationCommand

+ type Container struct

+ CpuPercent float64

+ Err string

+ ExitCode *int32

+ HealthState string

+ Id string

+ ImageName string

+ MemoryUsageBytes uint64

+ PullPercent int32

+ PullProgress string

+ PullStatus string

+ RestartCount int32

+ RxRate int32

+ RxSince *timestamppb.Timestamp

+ Status string

+ TxRate int32

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

+ func (*Container) ProtoMessage()

+ func (x *Container) GetCpuPercent() float64

+ func (x *Container) GetErr() string

+ func (x *Container) GetExitCode() int32

+ func (x *Container) GetHealthState() string

+ func (x *Container) GetId() string

+ func (x *Container) GetImageName() string

+ func (x *Container) GetMemoryUsageBytes() uint64

+ func (x *Container) GetPullPercent() int32

+ func (x *Container) GetPullProgress() string

+ func (x *Container) GetPullStatus() string

+ func (x *Container) GetRestartCount() int32

+ func (x *Container) GetRxRate() int32

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

+ func (x *Container) GetStatus() string

+ func (x *Container) GetTxRate() int32

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

+ func (x *Container) Reset()

+ func (x *Container) String() string

+ type Destination struct

+ Container *Container

+ Name string

+ Status Destination_Status

+ Url string

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

+ func (*Destination) ProtoMessage()

+ func (x *Destination) GetContainer() *Container

+ func (x *Destination) GetName() string

+ func (x *Destination) GetStatus() Destination_Status

+ func (x *Destination) GetUrl() string

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

+ func (x *Destination) Reset()

+ func (x *Destination) String() string

+ type DestinationAddedEvent struct

+ Url string

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

+ func (*DestinationAddedEvent) ProtoMessage()

+ func (x *DestinationAddedEvent) GetUrl() string

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

+ func (x *DestinationAddedEvent) Reset()

+ func (x *DestinationAddedEvent) String() string

+ type DestinationRemovedEvent struct

+ Url string

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

+ func (*DestinationRemovedEvent) ProtoMessage()

+ func (x *DestinationRemovedEvent) GetUrl() string

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

+ func (x *DestinationRemovedEvent) Reset()

+ func (x *DestinationRemovedEvent) String() string

+ type DestinationStreamExitedEvent struct

+ Error string

+ Name string

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

+ func (*DestinationStreamExitedEvent) ProtoMessage()

+ func (x *DestinationStreamExitedEvent) GetError() string

+ func (x *DestinationStreamExitedEvent) GetName() string

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

+ func (x *DestinationStreamExitedEvent) Reset()

+ func (x *DestinationStreamExitedEvent) String() string

+ type Destination_Status int32

+ const Destination_STATUS_LIVE

+ const Destination_STATUS_OFF_AIR

+ const Destination_STATUS_STARTING

+ func (Destination_Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (Destination_Status) Type() protoreflect.EnumType

+ func (x Destination_Status) Enum() *Destination_Status

+ func (x Destination_Status) Number() protoreflect.EnumNumber

+ func (x Destination_Status) String() string

+ type Envelope struct

+ Payload isEnvelope_Payload

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

+ func (*Envelope) ProtoMessage()

+ func (m *Envelope) GetPayload() isEnvelope_Payload

+ func (x *Envelope) GetCommand() *Command

+ func (x *Envelope) GetEvent() *Event

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

+ func (x *Envelope) Reset()

+ func (x *Envelope) String() string

+ type Envelope_Command struct

+ Command *Command

+ type Envelope_Event struct

+ Event *Event

+ type Event struct

+ EventType isEvent_EventType

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetEventType() isEvent_EventType

+ func (x *Event) GetAddDestinationFailed() *AddDestinationFailedEvent

+ func (x *Event) GetAppStateChanged() *AppStateChangedEvent

+ func (x *Event) GetDestinationAdded() *DestinationAddedEvent

+ func (x *Event) GetDestinationRemoved() *DestinationRemovedEvent

+ func (x *Event) GetDestinationStreamExited() *DestinationStreamExitedEvent

+ func (x *Event) GetFatalError() *FatalErrorEvent

+ func (x *Event) GetHandshakeCompleted() *HandshakeCompletedEvent

+ func (x *Event) GetMediaServerStarted() *MediaServerStartedEvent

+ func (x *Event) GetOtherInstanceDetected() *OtherInstanceDetectedEvent

+ func (x *Event) GetRemoveDestinationFailed() *RemoveDestinationFailedEvent

+ func (x *Event) GetStartDestinationFailed() *StartDestinationFailedEvent

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

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ type Event_AddDestinationFailed struct

+ AddDestinationFailed *AddDestinationFailedEvent

+ type Event_AppStateChanged struct

+ AppStateChanged *AppStateChangedEvent

+ type Event_DestinationAdded struct

+ DestinationAdded *DestinationAddedEvent

+ type Event_DestinationRemoved struct

+ DestinationRemoved *DestinationRemovedEvent

+ type Event_DestinationStreamExited struct

+ DestinationStreamExited *DestinationStreamExitedEvent

+ type Event_FatalError struct

+ FatalError *FatalErrorEvent

+ type Event_HandshakeCompleted struct

+ HandshakeCompleted *HandshakeCompletedEvent

+ type Event_MediaServerStarted struct

+ MediaServerStarted *MediaServerStartedEvent

+ type Event_OtherInstanceDetected struct

+ OtherInstanceDetected *OtherInstanceDetectedEvent

+ type Event_RemoveDestinationFailed struct

+ RemoveDestinationFailed *RemoveDestinationFailedEvent

+ type Event_StartDestinationFailed struct

+ StartDestinationFailed *StartDestinationFailedEvent

+ type FatalErrorEvent struct

+ Message string

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

+ func (*FatalErrorEvent) ProtoMessage()

+ func (x *FatalErrorEvent) GetMessage() string

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

+ func (x *FatalErrorEvent) Reset()

+ func (x *FatalErrorEvent) String() string

+ type HandshakeCompletedEvent struct

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

+ func (*HandshakeCompletedEvent) ProtoMessage()

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

+ func (x *HandshakeCompletedEvent) Reset()

+ func (x *HandshakeCompletedEvent) String() string

+ type InternalAPIClient interface

+ Communicate func(ctx context.Context, opts ...grpc.CallOption) (InternalAPI_CommunicateClient, error)

+ func NewInternalAPIClient(cc grpc.ClientConnInterface) InternalAPIClient

+ type InternalAPIServer interface

+ Communicate func(InternalAPI_CommunicateServer) error

+ type InternalAPI_CommunicateClient interface

+ Recv func() (*Envelope, error)

+ Send func(*Envelope) error

+ type InternalAPI_CommunicateServer interface

+ Recv func() (*Envelope, error)

+ Send func(*Envelope) error

+ type KillServerCommand struct

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

+ func (*KillServerCommand) ProtoMessage()

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

+ func (x *KillServerCommand) Reset()

+ func (x *KillServerCommand) String() string

+ type MediaServerStartedEvent struct

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

+ func (*MediaServerStartedEvent) ProtoMessage()

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

+ func (x *MediaServerStartedEvent) Reset()

+ func (x *MediaServerStartedEvent) String() string

+ type OtherInstanceDetectedEvent struct

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

+ func (*OtherInstanceDetectedEvent) ProtoMessage()

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

+ func (x *OtherInstanceDetectedEvent) Reset()

+ func (x *OtherInstanceDetectedEvent) String() string

+ type RemoveDestinationCommand struct

+ Url string

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

+ func (*RemoveDestinationCommand) ProtoMessage()

+ func (x *RemoveDestinationCommand) GetUrl() string

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

+ func (x *RemoveDestinationCommand) Reset()

+ func (x *RemoveDestinationCommand) String() string

+ type RemoveDestinationFailedEvent struct

+ Error string

+ Url string

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

+ func (*RemoveDestinationFailedEvent) ProtoMessage()

+ func (x *RemoveDestinationFailedEvent) GetError() string

+ func (x *RemoveDestinationFailedEvent) GetUrl() string

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

+ func (x *RemoveDestinationFailedEvent) Reset()

+ func (x *RemoveDestinationFailedEvent) String() string

+ type Source struct

+ Container *Container

+ ExitReason string

+ Live bool

+ LiveChangedAt *timestamppb.Timestamp

+ RtmpUrl string

+ RtmpsUrl string

+ Tracks []string

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

+ func (*Source) ProtoMessage()

+ func (x *Source) GetContainer() *Container

+ func (x *Source) GetExitReason() string

+ func (x *Source) GetLive() bool

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

+ func (x *Source) GetRtmpUrl() string

+ func (x *Source) GetRtmpsUrl() string

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

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

+ func (x *Source) Reset()

+ func (x *Source) String() string

+ type StartDestinationCommand struct

+ Url string

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

+ func (*StartDestinationCommand) ProtoMessage()

+ func (x *StartDestinationCommand) GetUrl() string

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

+ func (x *StartDestinationCommand) Reset()

+ func (x *StartDestinationCommand) String() string

+ type StartDestinationFailedEvent struct

+ Message string

+ Url string

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

+ func (*StartDestinationFailedEvent) ProtoMessage()

+ func (x *StartDestinationFailedEvent) GetMessage() string

+ func (x *StartDestinationFailedEvent) GetUrl() string

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

+ func (x *StartDestinationFailedEvent) Reset()

+ func (x *StartDestinationFailedEvent) String() string

+ type StartHandshakeCommand struct

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

+ func (*StartHandshakeCommand) ProtoMessage()

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

+ func (x *StartHandshakeCommand) Reset()

+ func (x *StartHandshakeCommand) String() string

+ type StopDestinationCommand struct

+ Url string

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

+ func (*StopDestinationCommand) ProtoMessage()

+ func (x *StopDestinationCommand) GetUrl() string

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

+ func (x *StopDestinationCommand) Reset()

+ func (x *StopDestinationCommand) String() string

+ type UnimplementedInternalAPIServer struct

+ func (UnimplementedInternalAPIServer) Communicate(InternalAPI_CommunicateServer) error

+ type UnsafeInternalAPIServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL