nativeebpfprofiling

Documentation

Index

• Constants
• type ContinuousProfilingReportService
  • func (c *ContinuousProfilingReportService) QueryPolicies(ctx context.Context, query *v3.ContinuousProfilingPolicyQuery) (*common_v3.Commands, error)
  • func (c *ContinuousProfilingReportService) ReportProfilingTask(ctx context.Context, report *v3.ContinuousProfilingReport) (*common_v3.Commands, error)
• type ProfilingReportService
  • func (p *ProfilingReportService) CollectProfilingData(stream v3.EBPFProfilingService_CollectProfilingDataServer) error
  • func (p *ProfilingReportService) QueryTasks(ctx context.Context, d *v3.EBPFProfilingTaskQuery) (*common.Commands, error)
• type Receiver
  • func (r *Receiver) Channel() <-chan *v1.SniffData
  • func (r *Receiver) DefaultConfig() string
  • func (r *Receiver) Description() string
  • func (r *Receiver) Name() string
  • func (r *Receiver) RegisterHandler(server interface{})
  • func (r *Receiver) RegisterSyncInvoker(invoker module.SyncInvoker)
  • func (r *Receiver) ShowName() string
  • func (r *Receiver) SupportForwarders() []forwarder.Forwarder

Constants

const (
	Name     = "grpc-native-ebpf-profiling-receiver"
	ShowName = "GRPC Native EBFP Profiling Receiver"
)

Types

type ContinuousProfilingReportService

type ContinuousProfilingReportService struct {
	module.SyncInvoker

	v3.UnimplementedContinuousProfilingServiceServer
}

func (*ContinuousProfilingReportService) QueryPolicies

func (c *ContinuousProfilingReportService) QueryPolicies(ctx context.Context, query *v3.ContinuousProfilingPolicyQuery) (*common_v3.Commands, error)

func (*ContinuousProfilingReportService) ReportProfilingTask

func (c *ContinuousProfilingReportService) ReportProfilingTask(ctx context.Context,
	report *v3.ContinuousProfilingReport) (*common_v3.Commands, error)

type ProfilingReportService

type ProfilingReportService struct {
	module.SyncInvoker
	v3.UnimplementedEBPFProfilingServiceServer
	// contains filtered or unexported fields
}

func (*ProfilingReportService) CollectProfilingData

func (p *ProfilingReportService) CollectProfilingData(stream v3.EBPFProfilingService_CollectProfilingDataServer) error

func (*ProfilingReportService) QueryTasks

func (p *ProfilingReportService) QueryTasks(ctx context.Context, d *v3.EBPFProfilingTaskQuery) (*common.Commands, error)

type Receiver

type Receiver struct {
	config.CommonFields
	grpcreceiver.CommonGRPCReceiverFields
	// contains filtered or unexported fields
}

func (*Receiver) Channel

func (r *Receiver) Channel() <-chan *v1.SniffData

func (*Receiver) DefaultConfig

func (r *Receiver) DefaultConfig() string

func (*Receiver) Description

func (r *Receiver) Description() string

func (*Receiver) Name

func (r *Receiver) Name() string

func (*Receiver) RegisterHandler

func (r *Receiver) RegisterHandler(server interface{})

func (*Receiver) RegisterSyncInvoker

func (r *Receiver) RegisterSyncInvoker(invoker module.SyncInvoker)

func (*Receiver) ShowName

func (r *Receiver) ShowName() string

func (*Receiver) SupportForwarders

func (r *Receiver) SupportForwarders() []forwarder.Forwarder