v3

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_profile_Profile_proto protoreflect.FileDescriptor
View Source 
var ProfileTask_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.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/Profile.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 *ProfileTaskCommandQuery, opts ...grpc.CallOption) (*v3.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 *ProfileTaskFinishReport, opts ...grpc.CallOption) (*v3.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 ProfileTaskCommandQuery 

type ProfileTaskCommandQuery struct {

	// current sniffer information
	Service         string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance string `protobuf:"bytes,2,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	// last command timestamp
	LastCommandTime int64 `protobuf:"varint,3,opt,name=lastCommandTime,proto3" json:"lastCommandTime,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileTaskCommandQuery) Descriptor deprecated 

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

Deprecated: Use ProfileTaskCommandQuery.ProtoReflect.Descriptor instead.

func (*ProfileTaskCommandQuery) GetLastCommandTime 

func (x *ProfileTaskCommandQuery) GetLastCommandTime() int64

func (*ProfileTaskCommandQuery) GetService 

func (x *ProfileTaskCommandQuery) GetService() string

func (*ProfileTaskCommandQuery) GetServiceInstance 

func (x *ProfileTaskCommandQuery) GetServiceInstance() string

func (*ProfileTaskCommandQuery) ProtoMessage 

func (*ProfileTaskCommandQuery) ProtoMessage()

func (*ProfileTaskCommandQuery) ProtoReflect 

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

func (*ProfileTaskCommandQuery) Reset 

func (x *ProfileTaskCommandQuery) Reset()

func (*ProfileTaskCommandQuery) String 

func (x *ProfileTaskCommandQuery) String() string

type ProfileTaskFinishReport 

type ProfileTaskFinishReport struct {

	// current sniffer information
	Service         string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance string `protobuf:"bytes,2,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	// profile task
	TaskId string `protobuf:"bytes,3,opt,name=taskId,proto3" json:"taskId,omitempty"`
	// contains filtered or unexported fields
}

profile task finished report

func (*ProfileTaskFinishReport) Descriptor deprecated 

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

Deprecated: Use ProfileTaskFinishReport.ProtoReflect.Descriptor instead.

func (*ProfileTaskFinishReport) GetService 

func (x *ProfileTaskFinishReport) GetService() string

func (*ProfileTaskFinishReport) GetServiceInstance 

func (x *ProfileTaskFinishReport) GetServiceInstance() string

func (*ProfileTaskFinishReport) GetTaskId 

func (x *ProfileTaskFinishReport) GetTaskId() string

func (*ProfileTaskFinishReport) ProtoMessage 

func (*ProfileTaskFinishReport) ProtoMessage()

func (*ProfileTaskFinishReport) ProtoReflect 

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

func (*ProfileTaskFinishReport) Reset 

func (x *ProfileTaskFinishReport) Reset()

func (*ProfileTaskFinishReport) String 

func (x *ProfileTaskFinishReport) String() string

type ProfileTaskServer 

type ProfileTaskServer interface {
	// query all sniffer need to execute profile task commands
	GetProfileTaskCommands(context.Context, *ProfileTaskCommandQuery) (*v3.Commands, error)
	// collect dumped thread snapshot
	CollectSnapshot(ProfileTask_CollectSnapshotServer) error
	// report profiling task finished
	ReportTaskFinish(context.Context, *ProfileTaskFinishReport) (*v3.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(*ThreadSnapshot) error
	CloseAndRecv() (*v3.Commands, error)
	grpc.ClientStream
}

type ProfileTask_CollectSnapshotServer 

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

type ThreadSnapshot 

type ThreadSnapshot struct {

	// profile task id
	TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	// dumped segment id
	TraceSegmentId string `protobuf:"bytes,2,opt,name=traceSegmentId,proto3" json:"traceSegmentId,omitempty"`
	// dump timestamp
	Time int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	// snapshot dump sequence, start with zero
	Sequence int32 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// snapshot stack
	Stack *ThreadStack `protobuf:"bytes,5,opt,name=stack,proto3" json:"stack,omitempty"`
	// contains filtered or unexported fields
}

dumped thread snapshot

func (*ThreadSnapshot) Descriptor deprecated 

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

Deprecated: Use ThreadSnapshot.ProtoReflect.Descriptor instead.

func (*ThreadSnapshot) GetSequence 

func (x *ThreadSnapshot) GetSequence() int32

func (*ThreadSnapshot) GetStack 

func (x *ThreadSnapshot) GetStack() *ThreadStack

func (*ThreadSnapshot) GetTaskId 

func (x *ThreadSnapshot) GetTaskId() string

func (*ThreadSnapshot) GetTime 

func (x *ThreadSnapshot) GetTime() int64

func (*ThreadSnapshot) GetTraceSegmentId 

func (x *ThreadSnapshot) GetTraceSegmentId() string

func (*ThreadSnapshot) ProtoMessage 

func (*ThreadSnapshot) ProtoMessage()

func (*ThreadSnapshot) ProtoReflect 

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

func (*ThreadSnapshot) Reset 

func (x *ThreadSnapshot) Reset()

func (*ThreadSnapshot) String 

func (x *ThreadSnapshot) String() string

type ThreadStack 

type ThreadStack struct {

	// stack code signature list
	CodeSignatures []string `protobuf:"bytes,1,rep,name=codeSignatures,proto3" json:"codeSignatures,omitempty"`
	// contains filtered or unexported fields
}

func (*ThreadStack) Descriptor deprecated 

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

Deprecated: Use ThreadStack.ProtoReflect.Descriptor instead.

func (*ThreadStack) GetCodeSignatures 

func (x *ThreadStack) GetCodeSignatures() []string

func (*ThreadStack) ProtoMessage 

func (*ThreadStack) ProtoMessage()

func (*ThreadStack) ProtoReflect 

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

func (*ThreadStack) Reset 

func (x *ThreadStack) Reset()

func (*ThreadStack) String 

func (x *ThreadStack) String() string

type UnimplementedProfileTaskServer 

type UnimplementedProfileTaskServer struct {
}

UnimplementedProfileTaskServer should be embedded to have forward compatible implementations.

func (UnimplementedProfileTaskServer) CollectSnapshot 

func (UnimplementedProfileTaskServer) CollectSnapshot(ProfileTask_CollectSnapshotServer) error

func (UnimplementedProfileTaskServer) GetProfileTaskCommands 

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

func (UnimplementedProfileTaskServer) ReportTaskFinish 

func (UnimplementedProfileTaskServer) ReportTaskFinish(context.Context, *ProfileTaskFinishReport) (*v3.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.

Source Files

View all Source files

Directories

Path Synopsis

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.