nativetracing

Documentation

Index

• Constants
• 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(_ module.SyncInvoker)
  • func (r *Receiver) ShowName() string
  • func (r *Receiver) SupportForwarders() []forwarder.Forwarder
• type TraceSegmentReportService
  • func (s *TraceSegmentReportService) Collect(stream agent.TraceSegmentReportService_CollectServer) error
  • func (s *TraceSegmentReportService) CollectInSync(ctx context.Context, segments *agent.SegmentCollection) (*common.Commands, error)
• type TraceSegmentReportServiceCompat
  • func (s *TraceSegmentReportServiceCompat) Collect(stream agent_compat.TraceSegmentReportService_CollectServer) error
  • func (s *TraceSegmentReportServiceCompat) CollectInSync(ctx context.Context, segments *agent.SegmentCollection) (*common.Commands, error)

Constants

const (
	Name     = "grpc-native-tracing-receiver"
	ShowName = "GRPC Native Tracing Receiver"
)

Types

type Receiver

type Receiver struct {
	config.CommonFields
	grpc.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(_ module.SyncInvoker)

func (*Receiver) ShowName

func (r *Receiver) ShowName() string

func (*Receiver) SupportForwarders

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

type TraceSegmentReportService

type TraceSegmentReportService struct {
	agent.UnimplementedTraceSegmentReportServiceServer
	// contains filtered or unexported fields
}

func (*TraceSegmentReportService) Collect

func (s *TraceSegmentReportService) Collect(stream agent.TraceSegmentReportService_CollectServer) error

func (*TraceSegmentReportService) CollectInSync

func (s *TraceSegmentReportService) CollectInSync(ctx context.Context, segments *agent.SegmentCollection) (*common.Commands, error)

type TraceSegmentReportServiceCompat

type TraceSegmentReportServiceCompat struct {
	agent_compat.UnimplementedTraceSegmentReportServiceServer
	// contains filtered or unexported fields
}

func (*TraceSegmentReportServiceCompat) Collect

func (s *TraceSegmentReportServiceCompat) Collect(stream agent_compat.TraceSegmentReportService_CollectServer) error

func (*TraceSegmentReportServiceCompat) CollectInSync

func (s *TraceSegmentReportServiceCompat) CollectInSync(ctx context.Context, segments *agent.SegmentCollection) (*common.Commands, error)