v3

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: 8 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) (*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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProfileTaskClient

func NewProfileTaskClient(cc *grpc.ClientConn) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProfileTaskCommandQuery) Descriptor

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

func (*ProfileTaskCommandQuery) GetLastCommandTime

func (m *ProfileTaskCommandQuery) GetLastCommandTime() int64

func (*ProfileTaskCommandQuery) GetService

func (m *ProfileTaskCommandQuery) GetService() string

func (*ProfileTaskCommandQuery) GetServiceInstance

func (m *ProfileTaskCommandQuery) GetServiceInstance() string

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
	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"`
	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) GetService

func (m *ProfileTaskFinishReport) GetService() string

func (*ProfileTaskFinishReport) GetServiceInstance

func (m *ProfileTaskFinishReport) GetServiceInstance() string

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

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"`
	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() string

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) GetProfileTaskCommands

func (*UnimplementedProfileTaskServer) ReportTaskFinish

Jump to

Keyboard shortcuts

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