v2

package
v0.0.0-...-5b17d3f Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterProfileTaskServer 

func RegisterProfileTaskServer(s *grpc.Server, 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) (*v21.CommandsV2, 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) (*v21.CommandsV2, error)
}

ProfileTaskClient is the client API for ProfileTask service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProfileTaskClient 

func NewProfileTaskClient(cc *grpc.ClientConn) ProfileTaskClient

type ProfileTaskCommandQuery 

type ProfileTaskCommandQuery struct {
	// current sniffer information
	ServiceId  int32 `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	InstanceId int32 `protobuf:"varint,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// last command timestamp
	LastCommandTime      int64    `protobuf:"varint,3,opt,name=lastCommandTime,proto3" json:"lastCommandTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProfileTaskCommandQuery) Descriptor 

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

func (*ProfileTaskCommandQuery) GetInstanceId 

func (m *ProfileTaskCommandQuery) GetInstanceId() int32

func (*ProfileTaskCommandQuery) GetLastCommandTime 

func (m *ProfileTaskCommandQuery) GetLastCommandTime() int64

func (*ProfileTaskCommandQuery) GetServiceId 

func (m *ProfileTaskCommandQuery) GetServiceId() int32

func (*ProfileTaskCommandQuery) ProtoMessage 

func (*ProfileTaskCommandQuery) ProtoMessage()

func (*ProfileTaskCommandQuery) Reset 

func (m *ProfileTaskCommandQuery) Reset()

func (*ProfileTaskCommandQuery) String 

func (m *ProfileTaskCommandQuery) String() string

func (*ProfileTaskCommandQuery) XXX_DiscardUnknown 

func (m *ProfileTaskCommandQuery) XXX_DiscardUnknown()

func (*ProfileTaskCommandQuery) XXX_Marshal 

func (m *ProfileTaskCommandQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfileTaskCommandQuery) XXX_Merge 

func (m *ProfileTaskCommandQuery) XXX_Merge(src proto.Message)

func (*ProfileTaskCommandQuery) XXX_Size 

func (m *ProfileTaskCommandQuery) XXX_Size() int

func (*ProfileTaskCommandQuery) XXX_Unmarshal 

func (m *ProfileTaskCommandQuery) XXX_Unmarshal(b []byte) error

type ProfileTaskFinishReport 

type ProfileTaskFinishReport struct {
	// current sniffer information
	ServiceId  int32 `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	InstanceId int32 `protobuf:"varint,2,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// profile task
	TaskId               string   `protobuf:"bytes,3,opt,name=taskId,proto3" json:"taskId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

profile task finished report

func (*ProfileTaskFinishReport) Descriptor 

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

func (*ProfileTaskFinishReport) GetInstanceId 

func (m *ProfileTaskFinishReport) GetInstanceId() int32

func (*ProfileTaskFinishReport) GetServiceId 

func (m *ProfileTaskFinishReport) GetServiceId() int32

func (*ProfileTaskFinishReport) GetTaskId 

func (m *ProfileTaskFinishReport) GetTaskId() string

func (*ProfileTaskFinishReport) ProtoMessage 

func (*ProfileTaskFinishReport) ProtoMessage()

func (*ProfileTaskFinishReport) Reset 

func (m *ProfileTaskFinishReport) Reset()

func (*ProfileTaskFinishReport) String 

func (m *ProfileTaskFinishReport) String() string

func (*ProfileTaskFinishReport) XXX_DiscardUnknown 

func (m *ProfileTaskFinishReport) XXX_DiscardUnknown()

func (*ProfileTaskFinishReport) XXX_Marshal 

func (m *ProfileTaskFinishReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProfileTaskFinishReport) XXX_Merge 

func (m *ProfileTaskFinishReport) XXX_Merge(src proto.Message)

func (*ProfileTaskFinishReport) XXX_Size 

func (m *ProfileTaskFinishReport) XXX_Size() int

func (*ProfileTaskFinishReport) XXX_Unmarshal 

func (m *ProfileTaskFinishReport) XXX_Unmarshal(b []byte) error

type ProfileTaskServer 

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

ProfileTaskServer is the server API for ProfileTask service.

type ProfileTask_CollectSnapshotClient 

type ProfileTask_CollectSnapshotClient interface {
	Send(*ThreadSnapshot) error
	CloseAndRecv() (*v21.CommandsV2, error)
	grpc.ClientStream
}

type ProfileTask_CollectSnapshotServer 

type ProfileTask_CollectSnapshotServer interface {
	SendAndClose(*v21.CommandsV2) 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 *v2.UniqueIdV2 `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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

dumped thread snapshot

func (*ThreadSnapshot) Descriptor 

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

func (*ThreadSnapshot) GetSequence 

func (m *ThreadSnapshot) GetSequence() int32

func (*ThreadSnapshot) GetStack 

func (m *ThreadSnapshot) GetStack() *ThreadStack

func (*ThreadSnapshot) GetTaskId 

func (m *ThreadSnapshot) GetTaskId() string

func (*ThreadSnapshot) GetTime 

func (m *ThreadSnapshot) GetTime() int64

func (*ThreadSnapshot) GetTraceSegmentId 

func (m *ThreadSnapshot) GetTraceSegmentId() *v2.UniqueIdV2

func (*ThreadSnapshot) ProtoMessage 

func (*ThreadSnapshot) ProtoMessage()

func (*ThreadSnapshot) Reset 

func (m *ThreadSnapshot) Reset()

func (*ThreadSnapshot) String 

func (m *ThreadSnapshot) String() string

func (*ThreadSnapshot) XXX_DiscardUnknown 

func (m *ThreadSnapshot) XXX_DiscardUnknown()

func (*ThreadSnapshot) XXX_Marshal 

func (m *ThreadSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ThreadSnapshot) XXX_Merge 

func (m *ThreadSnapshot) XXX_Merge(src proto.Message)

func (*ThreadSnapshot) XXX_Size 

func (m *ThreadSnapshot) XXX_Size() int

func (*ThreadSnapshot) XXX_Unmarshal 

func (m *ThreadSnapshot) XXX_Unmarshal(b []byte) error

type ThreadStack 

type ThreadStack struct {
	// stack code signature list
	CodeSignatures       []string `protobuf:"bytes,1,rep,name=codeSignatures,proto3" json:"codeSignatures,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ThreadStack) Descriptor 

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

func (*ThreadStack) GetCodeSignatures 

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

func (*ThreadStack) ProtoMessage 

func (*ThreadStack) ProtoMessage()

func (*ThreadStack) Reset 

func (m *ThreadStack) Reset()

func (*ThreadStack) String 

func (m *ThreadStack) String() string

func (*ThreadStack) XXX_DiscardUnknown 

func (m *ThreadStack) XXX_DiscardUnknown()

func (*ThreadStack) XXX_Marshal 

func (m *ThreadStack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ThreadStack) XXX_Merge 

func (m *ThreadStack) XXX_Merge(src proto.Message)

func (*ThreadStack) XXX_Size 

func (m *ThreadStack) XXX_Size() int

func (*ThreadStack) XXX_Unmarshal 

func (m *ThreadStack) XXX_Unmarshal(b []byte) error

type UnimplementedProfileTaskServer 

type UnimplementedProfileTaskServer struct {
}

UnimplementedProfileTaskServer can be embedded to have forward compatible implementations.

func (*UnimplementedProfileTaskServer) CollectSnapshot 

func (*UnimplementedProfileTaskServer) CollectSnapshot(srv ProfileTask_CollectSnapshotServer) error

func (*UnimplementedProfileTaskServer) GetProfileTaskCommands 

func (*UnimplementedProfileTaskServer) GetProfileTaskCommands(ctx context.Context, req *ProfileTaskCommandQuery) (*v21.CommandsV2, error)

func (*UnimplementedProfileTaskServer) ReportTaskFinish 

func (*UnimplementedProfileTaskServer) ReportTaskFinish(ctx context.Context, req *ProfileTaskFinishReport) (*v21.CommandsV2, error)

Source Files

View all Source files

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.