compat

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: May 2, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_profile_ProfileCompat_proto protoreflect.FileDescriptor
View Source
var ProfileTask_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ProfileTask",
	HandlerType: (*ProfileTaskServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "getProfileTaskCommands",
			Handler:    _ProfileTask_GetProfileTaskCommands_Handler,
		},
		{
			MethodName: "reportTaskFinish",
			Handler:    _ProfileTask_ReportTaskFinish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "collectSnapshot",
			Handler:       _ProfileTask_CollectSnapshot_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "profile/ProfileCompat.proto",
}

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

Functions

func RegisterProfileTaskServer

func RegisterProfileTaskServer(s grpc.ServiceRegistrar, srv ProfileTaskServer)

Types

type ProfileTaskClient

type ProfileTaskClient interface {
	// query all sniffer need to execute profile task commands
	GetProfileTaskCommands(ctx context.Context, in *v3.ProfileTaskCommandQuery, opts ...grpc.CallOption) (*v31.Commands, error)
	// collect dumped thread snapshot
	CollectSnapshot(ctx context.Context, opts ...grpc.CallOption) (ProfileTask_CollectSnapshotClient, error)
	// report profiling task finished
	ReportTaskFinish(ctx context.Context, in *v3.ProfileTaskFinishReport, opts ...grpc.CallOption) (*v31.Commands, error)
}

ProfileTaskClient is the client API for ProfileTask 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 ProfileTaskServer

type ProfileTaskServer interface {
	// query all sniffer need to execute profile task commands
	GetProfileTaskCommands(context.Context, *v3.ProfileTaskCommandQuery) (*v31.Commands, error)
	// collect dumped thread snapshot
	CollectSnapshot(ProfileTask_CollectSnapshotServer) error
	// report profiling task finished
	ReportTaskFinish(context.Context, *v3.ProfileTaskFinishReport) (*v31.Commands, error)
}

ProfileTaskServer is the server API for ProfileTask service. All implementations should embed UnimplementedProfileTaskServer for forward compatibility

type ProfileTask_CollectSnapshotClient

type ProfileTask_CollectSnapshotClient interface {
	Send(*v3.ThreadSnapshot) error
	CloseAndRecv() (*v31.Commands, error)
	grpc.ClientStream
}

type ProfileTask_CollectSnapshotServer

type ProfileTask_CollectSnapshotServer interface {
	SendAndClose(*v31.Commands) error
	Recv() (*v3.ThreadSnapshot, error)
	grpc.ServerStream
}

type UnimplementedProfileTaskServer

type UnimplementedProfileTaskServer struct {
}

UnimplementedProfileTaskServer should be embedded to have forward compatible implementations.

func (UnimplementedProfileTaskServer) CollectSnapshot

func (UnimplementedProfileTaskServer) GetProfileTaskCommands

func (UnimplementedProfileTaskServer) ReportTaskFinish

type UnsafeProfileTaskServer

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

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

Jump to

Keyboard shortcuts

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