transport

Documentation

Index

• type CollectorTransport
  • func NewCollectorTransport(logger *zap.Logger, ep *routing.Endpoint) *CollectorTransport
  • func (t *CollectorTransport) PostSpans(ctx context.Context, req *jaeger.PostSpansRequest) (*jaeger.PostSpansResponse, error)
• type StrategyManagerTransport
  • func NewStrategyManagerTransport(logger *zap.Logger, ep *routing.Endpoint) *StrategyManagerTransport
  • func (t *StrategyManagerTransport) GetStrategies(ctx context.Context, req *api_v1.StrategyRequest) (*api_v1.StrategiesResponse, error)

Types

type CollectorTransport

type CollectorTransport struct {
	// contains filtered or unexported fields
}

CollectorTransport reuses gRPC connection from agent to collector.

func NewCollectorTransport

func NewCollectorTransport(logger *zap.Logger, ep *routing.Endpoint) *CollectorTransport

func (*CollectorTransport) PostSpans

func (t *CollectorTransport) PostSpans(ctx context.Context, req *jaeger.PostSpansRequest) (*jaeger.PostSpansResponse, error)

type StrategyManagerTransport

type StrategyManagerTransport struct {
	// contains filtered or unexported fields
}

CollectorTransport reuses gRPC connection from agent to strategy manager.

func NewStrategyManagerTransport

func NewStrategyManagerTransport(logger *zap.Logger, ep *routing.Endpoint) *StrategyManagerTransport

func (*StrategyManagerTransport) GetStrategies

func (t *StrategyManagerTransport) GetStrategies(ctx context.Context, req *api_v1.StrategyRequest) (*api_v1.StrategiesResponse, error)