compat

Documentation

Index

• Variables
• func RegisterProfileTaskServer(s grpc.ServiceRegistrar, srv ProfileTaskServer)
• type ProfileTaskClient
  • func NewProfileTaskClient(cc grpc.ClientConnInterface) ProfileTaskClient
• type ProfileTaskServer
• type ProfileTask_CollectSnapshotClient
• type ProfileTask_CollectSnapshotServer
• type UnimplementedProfileTaskServer
  • func (UnimplementedProfileTaskServer) CollectSnapshot(ProfileTask_CollectSnapshotServer) error
  • func (UnimplementedProfileTaskServer) GetProfileTaskCommands(context.Context, *v3.ProfileTaskCommandQuery) (*v31.Commands, error)
  • func (UnimplementedProfileTaskServer) ReportTaskFinish(context.Context, *v3.ProfileTaskFinishReport) (*v31.Commands, error)
• type UnsafeProfileTaskServer

Variables

var File_profile_ProfileCompat_proto protoreflect.FileDescriptor

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.

func NewProfileTaskClient

func NewProfileTaskClient(cc grpc.ClientConnInterface) ProfileTaskClient

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

ProfileTaskServer is the server API for ProfileTask service. All implementations must 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 must be embedded to have forward compatible implementations.

func (UnimplementedProfileTaskServer) CollectSnapshot

func (UnimplementedProfileTaskServer) CollectSnapshot(ProfileTask_CollectSnapshotServer) error

func (UnimplementedProfileTaskServer) GetProfileTaskCommands

func (UnimplementedProfileTaskServer) GetProfileTaskCommands(context.Context, *v3.ProfileTaskCommandQuery) (*v31.Commands, error)

func (UnimplementedProfileTaskServer) ReportTaskFinish

func (UnimplementedProfileTaskServer) ReportTaskFinish(context.Context, *v3.ProfileTaskFinishReport) (*v31.Commands, error)

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.