ipc

package
v1.8.3 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EgressService_HandlerReady_FullMethodName        = "/ipc.EgressService/HandlerReady"
	EgressService_HandlerShuttingDown_FullMethodName = "/ipc.EgressService/HandlerShuttingDown"
)
View Source
const (
	EgressHandler_GetPipelineDot_FullMethodName = "/ipc.EgressHandler/GetPipelineDot"
	EgressHandler_GetPProf_FullMethodName       = "/ipc.EgressHandler/GetPProf"
	EgressHandler_GetMetrics_FullMethodName     = "/ipc.EgressHandler/GetMetrics"
)

Variables

View Source
var EgressHandler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ipc.EgressHandler",
	HandlerType: (*EgressHandlerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPipelineDot",
			Handler:    _EgressHandler_GetPipelineDot_Handler,
		},
		{
			MethodName: "GetPProf",
			Handler:    _EgressHandler_GetPProf_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _EgressHandler_GetMetrics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ipc.proto",
}

EgressHandler_ServiceDesc is the grpc.ServiceDesc for EgressHandler 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 EgressService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ipc.EgressService",
	HandlerType: (*EgressServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandlerReady",
			Handler:    _EgressService_HandlerReady_Handler,
		},
		{
			MethodName: "HandlerShuttingDown",
			Handler:    _EgressService_HandlerShuttingDown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ipc.proto",
}

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

Functions

func RegisterEgressHandlerServer

func RegisterEgressHandlerServer(s grpc.ServiceRegistrar, srv EgressHandlerServer)

func RegisterEgressServiceServer added in v1.8.1

func RegisterEgressServiceServer(s grpc.ServiceRegistrar, srv EgressServiceServer)

func StartHandlerListener added in v1.8.1

func StartHandlerListener(ipcServer *grpc.Server, handlerTmpDir string) error

func StartServiceListener added in v1.8.1

func StartServiceListener(ipcServer *grpc.Server, serviceTmpDir string) error

Types

type EgressHandlerClient

type EgressHandlerClient interface {
	GetPipelineDot(ctx context.Context, in *GstPipelineDebugDotRequest, opts ...grpc.CallOption) (*GstPipelineDebugDotResponse, error)
	GetPProf(ctx context.Context, in *PProfRequest, opts ...grpc.CallOption) (*PProfResponse, error)
	GetMetrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
}

EgressHandlerClient is the client API for EgressHandler 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 NewHandlerClient added in v1.8.1

func NewHandlerClient(handlerTmpDir string) (EgressHandlerClient, error)

type EgressHandlerServer

type EgressHandlerServer interface {
	GetPipelineDot(context.Context, *GstPipelineDebugDotRequest) (*GstPipelineDebugDotResponse, error)
	GetPProf(context.Context, *PProfRequest) (*PProfResponse, error)
	GetMetrics(context.Context, *MetricsRequest) (*MetricsResponse, error)
	// contains filtered or unexported methods
}

EgressHandlerServer is the server API for EgressHandler service. All implementations must embed UnimplementedEgressHandlerServer for forward compatibility

type EgressServiceClient added in v1.8.1

type EgressServiceClient interface {
	HandlerReady(ctx context.Context, in *HandlerReadyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	HandlerShuttingDown(ctx context.Context, in *HandlerShuttingDownRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

EgressServiceClient is the client API for EgressService 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 NewEgressServiceClient added in v1.8.1

func NewEgressServiceClient(cc grpc.ClientConnInterface) EgressServiceClient

func NewServiceClient added in v1.8.1

func NewServiceClient(serviceTmpDir string) (EgressServiceClient, error)

type EgressServiceServer added in v1.8.1

type EgressServiceServer interface {
	HandlerReady(context.Context, *HandlerReadyRequest) (*emptypb.Empty, error)
	HandlerShuttingDown(context.Context, *HandlerShuttingDownRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

EgressServiceServer is the server API for EgressService service. All implementations must embed UnimplementedEgressServiceServer for forward compatibility

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 HandlerReadyRequest added in v1.8.1

type HandlerReadyRequest struct {
	EgressId string `protobuf:"bytes,1,opt,name=egress_id,json=egressId,proto3" json:"egress_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerReadyRequest) Descriptor deprecated added in v1.8.1

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

Deprecated: Use HandlerReadyRequest.ProtoReflect.Descriptor instead.

func (*HandlerReadyRequest) GetEgressId added in v1.8.1

func (x *HandlerReadyRequest) GetEgressId() string

func (*HandlerReadyRequest) ProtoMessage added in v1.8.1

func (*HandlerReadyRequest) ProtoMessage()

func (*HandlerReadyRequest) ProtoReflect added in v1.8.1

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

func (*HandlerReadyRequest) Reset added in v1.8.1

func (x *HandlerReadyRequest) Reset()

func (*HandlerReadyRequest) String added in v1.8.1

func (x *HandlerReadyRequest) String() string

type HandlerShuttingDownRequest added in v1.8.1

type HandlerShuttingDownRequest struct {
	EgressId string `protobuf:"bytes,1,opt,name=egress_id,json=egressId,proto3" json:"egress_id,omitempty"`
	Metrics  string `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerShuttingDownRequest) Descriptor deprecated added in v1.8.1

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

Deprecated: Use HandlerShuttingDownRequest.ProtoReflect.Descriptor instead.

func (*HandlerShuttingDownRequest) GetEgressId added in v1.8.1

func (x *HandlerShuttingDownRequest) GetEgressId() string

func (*HandlerShuttingDownRequest) GetMetrics added in v1.8.1

func (x *HandlerShuttingDownRequest) GetMetrics() string

func (*HandlerShuttingDownRequest) ProtoMessage added in v1.8.1

func (*HandlerShuttingDownRequest) ProtoMessage()

func (*HandlerShuttingDownRequest) ProtoReflect added in v1.8.1

func (*HandlerShuttingDownRequest) Reset added in v1.8.1

func (x *HandlerShuttingDownRequest) Reset()

func (*HandlerShuttingDownRequest) String added in v1.8.1

func (x *HandlerShuttingDownRequest) String() string

type MetricsRequest added in v1.8.1

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

func (*MetricsRequest) Descriptor deprecated added in v1.8.1

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

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) ProtoMessage added in v1.8.1

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect added in v1.8.1

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

func (*MetricsRequest) Reset added in v1.8.1

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String added in v1.8.1

func (x *MetricsRequest) String() string

type MetricsResponse added in v1.8.1

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

func (*MetricsResponse) Descriptor deprecated added in v1.8.1

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetMetrics added in v1.8.1

func (x *MetricsResponse) GetMetrics() string

func (*MetricsResponse) ProtoMessage added in v1.8.1

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect added in v1.8.1

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

func (*MetricsResponse) Reset added in v1.8.1

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String added in v1.8.1

func (x *MetricsResponse) String() string

type PProfRequest added in v1.5.5

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 added in v1.5.5

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

Deprecated: Use PProfRequest.ProtoReflect.Descriptor instead.

func (*PProfRequest) GetDebug added in v1.5.5

func (x *PProfRequest) GetDebug() int32

func (*PProfRequest) GetProfileName added in v1.5.5

func (x *PProfRequest) GetProfileName() string

func (*PProfRequest) GetTimeout added in v1.5.5

func (x *PProfRequest) GetTimeout() int32

func (*PProfRequest) ProtoMessage added in v1.5.5

func (*PProfRequest) ProtoMessage()

func (*PProfRequest) ProtoReflect added in v1.5.5

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

func (*PProfRequest) Reset added in v1.5.5

func (x *PProfRequest) Reset()

func (*PProfRequest) String added in v1.5.5

func (x *PProfRequest) String() string

type PProfResponse added in v1.5.5

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 added in v1.5.5

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

Deprecated: Use PProfResponse.ProtoReflect.Descriptor instead.

func (*PProfResponse) GetPprofFile added in v1.5.5

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

func (*PProfResponse) ProtoMessage added in v1.5.5

func (*PProfResponse) ProtoMessage()

func (*PProfResponse) ProtoReflect added in v1.5.5

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

func (*PProfResponse) Reset added in v1.5.5

func (x *PProfResponse) Reset()

func (*PProfResponse) String added in v1.5.5

func (x *PProfResponse) String() string

type UnimplementedEgressHandlerServer

type UnimplementedEgressHandlerServer struct {
}

UnimplementedEgressHandlerServer must be embedded to have forward compatible implementations.

func (UnimplementedEgressHandlerServer) GetMetrics added in v1.8.1

func (UnimplementedEgressHandlerServer) GetPProf added in v1.5.5

func (UnimplementedEgressHandlerServer) GetPipelineDot added in v1.5.5

type UnimplementedEgressServiceServer added in v1.8.1

type UnimplementedEgressServiceServer struct {
}

UnimplementedEgressServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEgressServiceServer) HandlerReady added in v1.8.1

func (UnimplementedEgressServiceServer) HandlerShuttingDown added in v1.8.1

type UnsafeEgressHandlerServer

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

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

type UnsafeEgressServiceServer added in v1.8.1

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

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

Jump to

Keyboard shortcuts

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