tracer

package
v0.1.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

type Handler struct {
	TraceName    string
	IsAutoFinish bool
}

func (*Handler) HandleMessage

func (h *Handler) HandleMessage(msg *nsq.Message) error

type Tracer

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

func NewDefaultTracer

func NewDefaultTracer(cfg *TracerConfig) *Tracer

func (*Tracer) AddHandler

func (t *Tracer) AddHandler(handler nsqio.Handler)

func (*Tracer) SetConcurrency

func (t *Tracer) SetConcurrency(v int)

func (*Tracer) SetMaxInFlight

func (t *Tracer) SetMaxInFlight(v int)

func (*Tracer) StartTrace

func (t *Tracer) StartTrace() error

func (*Tracer) StopTrace

func (t *Tracer) StopTrace()

type TracerConfig

type TracerConfig struct {
	Topic          string
	Channel        string
	NSQdAddrs      []string
	NSQLookupAddrs []string
	Concurrency    int
	MaxInFlighht   int
	EnableDebug    bool
	EnableInfo     bool
	EnableWarn     bool
	AutoFinish     bool
}

Jump to

Keyboard shortcuts

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