ipc

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	IngressHandler_GetPipelineDot_FullMethodName   = "/ipc.IngressHandler/GetPipelineDot"
	IngressHandler_GetPProf_FullMethodName         = "/ipc.IngressHandler/GetPProf"
	IngressHandler_GatherMediaStats_FullMethodName = "/ipc.IngressHandler/GatherMediaStats"
	IngressHandler_UpdateMediaStats_FullMethodName = "/ipc.IngressHandler/UpdateMediaStats"
	IngressHandler_KillIngress_FullMethodName      = "/ipc.IngressHandler/KillIngress"
)
View Source
const (
	IngressService_UpdateIngressState_FullMethodName = "/ipc.IngressService/UpdateIngressState"
)

Variables

View Source
var IngressHandler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ipc.IngressHandler",
	HandlerType: (*IngressHandlerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPipelineDot",
			Handler:    _IngressHandler_GetPipelineDot_Handler,
		},
		{
			MethodName: "GetPProf",
			Handler:    _IngressHandler_GetPProf_Handler,
		},
		{
			MethodName: "GatherMediaStats",
			Handler:    _IngressHandler_GatherMediaStats_Handler,
		},
		{
			MethodName: "UpdateMediaStats",
			Handler:    _IngressHandler_UpdateMediaStats_Handler,
		},
		{
			MethodName: "KillIngress",
			Handler:    _IngressHandler_KillIngress_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ipc.proto",
}

IngressHandler_ServiceDesc is the grpc.ServiceDesc for IngressHandler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var IngressService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ipc.IngressService",
	HandlerType: (*IngressServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateIngressState",
			Handler:    _IngressService_UpdateIngressState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ipc.proto",
}

IngressService_ServiceDesc is the grpc.ServiceDesc for IngressService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIngressHandlerServer

func RegisterIngressHandlerServer(s grpc.ServiceRegistrar, srv IngressHandlerServer)

func RegisterIngressServiceServer added in v1.5.0

func RegisterIngressServiceServer(s grpc.ServiceRegistrar, srv IngressServiceServer)

func StartHandlerServer added in v1.5.0

func StartHandlerServer(tmpDir string, h IngressHandlerServer) error

func StartServiceServer added in v1.5.0

func StartServiceServer(tmpDir string, h IngressServiceServer) (*grpc.Server, error)

Types

type GatherMediaStatsRequest added in v1.3.0

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

func (*GatherMediaStatsRequest) Descriptor deprecated added in v1.3.0

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

Deprecated: Use GatherMediaStatsRequest.ProtoReflect.Descriptor instead.

func (*GatherMediaStatsRequest) ProtoMessage added in v1.3.0

func (*GatherMediaStatsRequest) ProtoMessage()

func (*GatherMediaStatsRequest) ProtoReflect added in v1.3.0

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

func (*GatherMediaStatsRequest) Reset added in v1.3.0

func (x *GatherMediaStatsRequest) Reset()

func (*GatherMediaStatsRequest) String added in v1.3.0

func (x *GatherMediaStatsRequest) String() string

type GatherMediaStatsResponse added in v1.3.0

type GatherMediaStatsResponse struct {
	Stats *MediaStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*GatherMediaStatsResponse) Descriptor deprecated added in v1.3.0

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

Deprecated: Use GatherMediaStatsResponse.ProtoReflect.Descriptor instead.

func (*GatherMediaStatsResponse) GetStats added in v1.3.0

func (x *GatherMediaStatsResponse) GetStats() *MediaStats

func (*GatherMediaStatsResponse) ProtoMessage added in v1.3.0

func (*GatherMediaStatsResponse) ProtoMessage()

func (*GatherMediaStatsResponse) ProtoReflect added in v1.3.0

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

func (*GatherMediaStatsResponse) Reset added in v1.3.0

func (x *GatherMediaStatsResponse) Reset()

func (*GatherMediaStatsResponse) String added in v1.3.0

func (x *GatherMediaStatsResponse) String() string

type GstPipelineDebugDotRequest

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

func (*GstPipelineDebugDotRequest) Descriptor deprecated

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

Deprecated: Use GstPipelineDebugDotRequest.ProtoReflect.Descriptor instead.

func (*GstPipelineDebugDotRequest) ProtoMessage

func (*GstPipelineDebugDotRequest) ProtoMessage()

func (*GstPipelineDebugDotRequest) ProtoReflect

func (*GstPipelineDebugDotRequest) Reset

func (x *GstPipelineDebugDotRequest) Reset()

func (*GstPipelineDebugDotRequest) String

func (x *GstPipelineDebugDotRequest) String() string

type GstPipelineDebugDotResponse

type GstPipelineDebugDotResponse struct {
	DotFile string `protobuf:"bytes,1,opt,name=dot_file,json=dotFile,proto3" json:"dot_file,omitempty"`
	// contains filtered or unexported fields
}

func (*GstPipelineDebugDotResponse) Descriptor deprecated

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

Deprecated: Use GstPipelineDebugDotResponse.ProtoReflect.Descriptor instead.

func (*GstPipelineDebugDotResponse) GetDotFile

func (x *GstPipelineDebugDotResponse) GetDotFile() string

func (*GstPipelineDebugDotResponse) ProtoMessage

func (*GstPipelineDebugDotResponse) ProtoMessage()

func (*GstPipelineDebugDotResponse) ProtoReflect

func (*GstPipelineDebugDotResponse) Reset

func (x *GstPipelineDebugDotResponse) Reset()

func (*GstPipelineDebugDotResponse) String

func (x *GstPipelineDebugDotResponse) String() string

type IngressHandlerClient

type IngressHandlerClient interface {
	GetPipelineDot(ctx context.Context, in *GstPipelineDebugDotRequest, opts ...grpc.CallOption) (*GstPipelineDebugDotResponse, error)
	GetPProf(ctx context.Context, in *PProfRequest, opts ...grpc.CallOption) (*PProfResponse, error)
	GatherMediaStats(ctx context.Context, in *GatherMediaStatsRequest, opts ...grpc.CallOption) (*GatherMediaStatsResponse, error)
	UpdateMediaStats(ctx context.Context, in *UpdateMediaStatsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	KillIngress(ctx context.Context, in *KillIngressRequest, opts ...grpc.CallOption) (*KillIngressResponse, error)
}

IngressHandlerClient is the client API for IngressHandler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type IngressHandlerClientWrapper added in v1.5.0

type IngressHandlerClientWrapper struct {
	IngressHandlerClient
	// contains filtered or unexported fields
}

func GetHandlerClient added in v1.5.0

func GetHandlerClient(tmpDir string) (*IngressHandlerClientWrapper, error)

func (*IngressHandlerClientWrapper) Close added in v1.5.0

func (ihc *IngressHandlerClientWrapper) Close() error

type IngressHandlerServer

type IngressHandlerServer interface {
	GetPipelineDot(context.Context, *GstPipelineDebugDotRequest) (*GstPipelineDebugDotResponse, error)
	GetPProf(context.Context, *PProfRequest) (*PProfResponse, error)
	GatherMediaStats(context.Context, *GatherMediaStatsRequest) (*GatherMediaStatsResponse, error)
	UpdateMediaStats(context.Context, *UpdateMediaStatsRequest) (*emptypb.Empty, error)
	KillIngress(context.Context, *KillIngressRequest) (*KillIngressResponse, error)
	// contains filtered or unexported methods
}

IngressHandlerServer is the server API for IngressHandler service. All implementations must embed UnimplementedIngressHandlerServer for forward compatibility.

type IngressServiceClient added in v1.5.0

type IngressServiceClient interface {
	UpdateIngressState(ctx context.Context, in *UpdateIngressStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

IngressServiceClient is the client API for IngressService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func GetServiceClient added in v1.5.0

func GetServiceClient(tmpDir string) (IngressServiceClient, error)

func NewIngressServiceClient added in v1.5.0

func NewIngressServiceClient(cc grpc.ClientConnInterface) IngressServiceClient

type IngressServiceServer added in v1.5.0

type IngressServiceServer interface {
	UpdateIngressState(context.Context, *UpdateIngressStateRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

IngressServiceServer is the server API for IngressService service. All implementations must embed UnimplementedIngressServiceServer for forward compatibility.

type JitterStats added in v1.3.0

type JitterStats struct {
	P50 float64 `protobuf:"fixed64,1,opt,name=p50,proto3" json:"p50,omitempty"` // in ms
	P90 float64 `protobuf:"fixed64,2,opt,name=p90,proto3" json:"p90,omitempty"`
	P99 float64 `protobuf:"fixed64,3,opt,name=p99,proto3" json:"p99,omitempty"`
	// contains filtered or unexported fields
}

func (*JitterStats) Descriptor deprecated added in v1.3.0

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

Deprecated: Use JitterStats.ProtoReflect.Descriptor instead.

func (*JitterStats) GetP50 added in v1.3.0

func (x *JitterStats) GetP50() float64

func (*JitterStats) GetP90 added in v1.3.0

func (x *JitterStats) GetP90() float64

func (*JitterStats) GetP99 added in v1.3.0

func (x *JitterStats) GetP99() float64

func (*JitterStats) ProtoMessage added in v1.3.0

func (*JitterStats) ProtoMessage()

func (*JitterStats) ProtoReflect added in v1.3.0

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

func (*JitterStats) Reset added in v1.3.0

func (x *JitterStats) Reset()

func (*JitterStats) String added in v1.3.0

func (x *JitterStats) String() string

type KillIngressRequest added in v1.5.0

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

func (*KillIngressRequest) Descriptor deprecated added in v1.5.0

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

Deprecated: Use KillIngressRequest.ProtoReflect.Descriptor instead.

func (*KillIngressRequest) ProtoMessage added in v1.5.0

func (*KillIngressRequest) ProtoMessage()

func (*KillIngressRequest) ProtoReflect added in v1.5.0

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

func (*KillIngressRequest) Reset added in v1.5.0

func (x *KillIngressRequest) Reset()

func (*KillIngressRequest) String added in v1.5.0

func (x *KillIngressRequest) String() string

type KillIngressResponse added in v1.5.0

type KillIngressResponse struct {
	State *livekit.IngressState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*KillIngressResponse) Descriptor deprecated added in v1.5.0

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

Deprecated: Use KillIngressResponse.ProtoReflect.Descriptor instead.

func (*KillIngressResponse) GetState added in v1.5.0

func (x *KillIngressResponse) GetState() *livekit.IngressState

func (*KillIngressResponse) ProtoMessage added in v1.5.0

func (*KillIngressResponse) ProtoMessage()

func (*KillIngressResponse) ProtoReflect added in v1.5.0

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

func (*KillIngressResponse) Reset added in v1.5.0

func (x *KillIngressResponse) Reset()

func (*KillIngressResponse) String added in v1.5.0

func (x *KillIngressResponse) String() string

type MediaStats added in v1.3.0

type MediaStats struct {
	TrackStats map[string]*TrackStats `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MediaStats) Descriptor deprecated added in v1.3.0

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

Deprecated: Use MediaStats.ProtoReflect.Descriptor instead.

func (*MediaStats) GetTrackStats added in v1.3.0

func (x *MediaStats) GetTrackStats() map[string]*TrackStats

func (*MediaStats) ProtoMessage added in v1.3.0

func (*MediaStats) ProtoMessage()

func (*MediaStats) ProtoReflect added in v1.3.0

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

func (*MediaStats) Reset added in v1.3.0

func (x *MediaStats) Reset()

func (*MediaStats) String added in v1.3.0

func (x *MediaStats) String() string

type PProfRequest

type PProfRequest struct {
	ProfileName string `protobuf:"bytes,1,opt,name=profile_name,json=profileName,proto3" json:"profile_name,omitempty"`
	Timeout     int32  `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Debug       int32  `protobuf:"varint,3,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

func (*PProfRequest) Descriptor deprecated

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

Deprecated: Use PProfRequest.ProtoReflect.Descriptor instead.

func (*PProfRequest) GetDebug

func (x *PProfRequest) GetDebug() int32

func (*PProfRequest) GetProfileName

func (x *PProfRequest) GetProfileName() string

func (*PProfRequest) GetTimeout

func (x *PProfRequest) GetTimeout() int32

func (*PProfRequest) ProtoMessage

func (*PProfRequest) ProtoMessage()

func (*PProfRequest) ProtoReflect

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

func (*PProfRequest) Reset

func (x *PProfRequest) Reset()

func (*PProfRequest) String

func (x *PProfRequest) String() string

type PProfResponse

type PProfResponse struct {
	PprofFile []byte `protobuf:"bytes,1,opt,name=pprof_file,json=pprofFile,proto3" json:"pprof_file,omitempty"`
	// contains filtered or unexported fields
}

func (*PProfResponse) Descriptor deprecated

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

Deprecated: Use PProfResponse.ProtoReflect.Descriptor instead.

func (*PProfResponse) GetPprofFile

func (x *PProfResponse) GetPprofFile() []byte

func (*PProfResponse) ProtoMessage

func (*PProfResponse) ProtoMessage()

func (*PProfResponse) ProtoReflect

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

func (*PProfResponse) Reset

func (x *PProfResponse) Reset()

func (*PProfResponse) String

func (x *PProfResponse) String() string

type TrackStats added in v1.3.0

type TrackStats struct {
	AverageBitrate       uint32       `protobuf:"varint,1,opt,name=average_bitrate,json=averageBitrate,proto3" json:"average_bitrate,omitempty"`
	CurrentBitrate       uint32       `protobuf:"varint,2,opt,name=current_bitrate,json=currentBitrate,proto3" json:"current_bitrate,omitempty"`
	TotalPackets         uint64       `protobuf:"varint,4,opt,name=total_packets,json=totalPackets,proto3" json:"total_packets,omitempty"`
	CurrentPackets       uint64       `protobuf:"varint,5,opt,name=current_packets,json=currentPackets,proto3" json:"current_packets,omitempty"`
	TotalLossRate        float64      `protobuf:"fixed64,6,opt,name=total_loss_rate,json=totalLossRate,proto3" json:"total_loss_rate,omitempty"`
	CurrentLossRate      float64      `protobuf:"fixed64,7,opt,name=current_loss_rate,json=currentLossRate,proto3" json:"current_loss_rate,omitempty"`
	TotalPli             uint64       `protobuf:"varint,8,opt,name=total_pli,json=totalPli,proto3" json:"total_pli,omitempty"`
	CurrentPli           uint64       `protobuf:"varint,9,opt,name=current_pli,json=currentPli,proto3" json:"current_pli,omitempty"`
	Jitter               *JitterStats `protobuf:"bytes,10,opt,name=jitter,proto3" json:"jitter,omitempty"`
	PacketLatencySeconds []float64    `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TrackStats) Descriptor deprecated added in v1.3.0

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

Deprecated: Use TrackStats.ProtoReflect.Descriptor instead.

func (*TrackStats) GetAverageBitrate added in v1.3.0

func (x *TrackStats) GetAverageBitrate() uint32

func (*TrackStats) GetCurrentBitrate added in v1.3.0

func (x *TrackStats) GetCurrentBitrate() uint32

func (*TrackStats) GetCurrentLossRate added in v1.3.0

func (x *TrackStats) GetCurrentLossRate() float64

func (*TrackStats) GetCurrentPackets added in v1.3.0

func (x *TrackStats) GetCurrentPackets() uint64

func (*TrackStats) GetCurrentPli added in v1.4.0

func (x *TrackStats) GetCurrentPli() uint64

func (*TrackStats) GetJitter added in v1.3.0

func (x *TrackStats) GetJitter() *JitterStats

func (*TrackStats) GetPacketLatencySeconds added in v1.5.0

func (x *TrackStats) GetPacketLatencySeconds() []float64

func (*TrackStats) GetTotalLossRate added in v1.3.0

func (x *TrackStats) GetTotalLossRate() float64

func (*TrackStats) GetTotalPackets added in v1.3.0

func (x *TrackStats) GetTotalPackets() uint64

func (*TrackStats) GetTotalPli added in v1.4.0

func (x *TrackStats) GetTotalPli() uint64

func (*TrackStats) ProtoMessage added in v1.3.0

func (*TrackStats) ProtoMessage()

func (*TrackStats) ProtoReflect added in v1.3.0

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

func (*TrackStats) Reset added in v1.3.0

func (x *TrackStats) Reset()

func (*TrackStats) String added in v1.3.0

func (x *TrackStats) String() string

type UnimplementedIngressHandlerServer

type UnimplementedIngressHandlerServer struct{}

UnimplementedIngressHandlerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedIngressHandlerServer) GatherMediaStats added in v1.3.0

func (UnimplementedIngressHandlerServer) GetPProf

func (UnimplementedIngressHandlerServer) KillIngress added in v1.5.0

func (UnimplementedIngressHandlerServer) UpdateMediaStats

type UnimplementedIngressServiceServer added in v1.5.0

type UnimplementedIngressServiceServer struct{}

UnimplementedIngressServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedIngressServiceServer) UpdateIngressState added in v1.5.0

type UnsafeIngressHandlerServer

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

UnsafeIngressHandlerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngressHandlerServer will result in compilation errors.

type UnsafeIngressServiceServer added in v1.5.0

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

UnsafeIngressServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngressServiceServer will result in compilation errors.

type UpdateIngressStateRequest added in v1.5.0

type UpdateIngressStateRequest struct {
	ProjectId string               `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Info      *livekit.IngressInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateIngressStateRequest) Descriptor deprecated added in v1.5.0

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

Deprecated: Use UpdateIngressStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateIngressStateRequest) GetInfo added in v1.5.0

func (*UpdateIngressStateRequest) GetProjectId added in v1.5.0

func (x *UpdateIngressStateRequest) GetProjectId() string

func (*UpdateIngressStateRequest) ProtoMessage added in v1.5.0

func (*UpdateIngressStateRequest) ProtoMessage()

func (*UpdateIngressStateRequest) ProtoReflect added in v1.5.0

func (*UpdateIngressStateRequest) Reset added in v1.5.0

func (x *UpdateIngressStateRequest) Reset()

func (*UpdateIngressStateRequest) String added in v1.5.0

func (x *UpdateIngressStateRequest) String() string

type UpdateMediaStatsRequest

type UpdateMediaStatsRequest struct {
	Stats *MediaStats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMediaStatsRequest) Descriptor deprecated

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

Deprecated: Use UpdateMediaStatsRequest.ProtoReflect.Descriptor instead.

func (*UpdateMediaStatsRequest) GetStats added in v1.3.0

func (x *UpdateMediaStatsRequest) GetStats() *MediaStats

func (*UpdateMediaStatsRequest) ProtoMessage

func (*UpdateMediaStatsRequest) ProtoMessage()

func (*UpdateMediaStatsRequest) ProtoReflect

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

func (*UpdateMediaStatsRequest) Reset

func (x *UpdateMediaStatsRequest) Reset()

func (*UpdateMediaStatsRequest) String

func (x *UpdateMediaStatsRequest) String() string

Jump to

Keyboard shortcuts

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