v3

package
v0.0.0-...-6cb6b35 Latest Latest
Warning

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

Go to latest
Published: Jun 19, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_profile_Profile_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 *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.

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)
	// 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(*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 must 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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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