ipc

package
v1.4.3 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: Apache-2.0 Imports: 9 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"
)

Variables

View Source 
var File_ipc_proto protoreflect.FileDescriptor
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,
		},
	},
	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)

Functions

func RegisterIngressHandlerServer 

func RegisterIngressHandlerServer(s grpc.ServiceRegistrar, srv IngressHandlerServer)

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 (x *GstPipelineDebugDotRequest) ProtoReflect() protoreflect.Message

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 (x *GstPipelineDebugDotResponse) ProtoReflect() protoreflect.Message

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)
}

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.

func NewIngressHandlerClient 

func NewIngressHandlerClient(cc grpc.ClientConnInterface) IngressHandlerClient

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)
	// contains filtered or unexported methods
}

IngressHandlerServer is the server API for IngressHandler service. All implementations must embed UnimplementedIngressHandlerServer 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 MediaStats added in v1.3.0 

type MediaStats struct {
	TrackStats map[string]*TrackStats `` /* 179-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"`
	// 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) 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.

func (UnimplementedIngressHandlerServer) GatherMediaStats added in v1.3.0 

func (UnimplementedIngressHandlerServer) GatherMediaStats(context.Context, *GatherMediaStatsRequest) (*GatherMediaStatsResponse, error)

func (UnimplementedIngressHandlerServer) GetPProf 

func (UnimplementedIngressHandlerServer) GetPProf(context.Context, *PProfRequest) (*PProfResponse, error)

func (UnimplementedIngressHandlerServer) GetPipelineDot 

func (UnimplementedIngressHandlerServer) GetPipelineDot(context.Context, *GstPipelineDebugDotRequest) (*GstPipelineDebugDotResponse, error)

func (UnimplementedIngressHandlerServer) UpdateMediaStats 

func (UnimplementedIngressHandlerServer) UpdateMediaStats(context.Context, *UpdateMediaStatsRequest) (*emptypb.Empty, error)

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 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

Source Files

View all Source files

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.