wrappers

Documentation

Index

• func TagSpan(span opentracing.Span, opts clients.CommonOpts, step pipeline.Step)
• type LogWrapper
  • func (l *LogWrapper) Fields(ctx context.Context, step pipeline.Step) logrus.Fields
  • func (l *LogWrapper) Wrap(wf pipeline.StepWalkFunc) pipeline.StepWalkFunc
  • func (l *LogWrapper) WrapStep(step pipeline.Step) pipeline.Step
• type TraceWrapper
  • func (l *TraceWrapper) Fields(ctx context.Context, step pipeline.Step) logrus.Fields
  • func (l *TraceWrapper) Wrap(wf pipeline.StepWalkFunc) pipeline.StepWalkFunc
  • func (l *TraceWrapper) WrapStep(step pipeline.Step) pipeline.Step

Functions

func TagSpan

func TagSpan(span opentracing.Span, opts clients.CommonOpts, step pipeline.Step)

Types

type LogWrapper

type LogWrapper struct {
	Opts clients.CommonOpts
	Log  logrus.FieldLogger
}

func (*LogWrapper) Fields

func (l *LogWrapper) Fields(ctx context.Context, step pipeline.Step) logrus.Fields

func (*LogWrapper) Wrap

func (l *LogWrapper) Wrap(wf pipeline.StepWalkFunc) pipeline.StepWalkFunc

func (*LogWrapper) WrapStep

func (l *LogWrapper) WrapStep(step pipeline.Step) pipeline.Step

type TraceWrapper

type TraceWrapper struct {
	Opts   clients.CommonOpts
	Tracer opentracing.Tracer
}

func (*TraceWrapper) Fields

func (l *TraceWrapper) Fields(ctx context.Context, step pipeline.Step) logrus.Fields

func (*TraceWrapper) Wrap

func (l *TraceWrapper) Wrap(wf pipeline.StepWalkFunc) pipeline.StepWalkFunc

func (*TraceWrapper) WrapStep

func (l *TraceWrapper) WrapStep(step pipeline.Step) pipeline.Step