trace

Documentation

Index

• type TraceManager
  • func New(sender types.MessageSender, opts ...TraceManagerOption) *TraceManager
  • func (t *TraceManager) Done() <-chan struct{}
  • func (t *TraceManager) GetNodes() []types.Node
  • func (t *TraceManager) Start(ctx context.Context)
• type TraceManagerOption
  • func WithIPProvider(provider ipinfo.Provider) TraceManagerOption
  • func WithOutputWriter(writer interfaces.OutputWriter) TraceManagerOption

Types

type TraceManager

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

TraceManager manages trace information

func New

func New(sender types.MessageSender, opts ...TraceManagerOption) *TraceManager

New creates a new TraceManager with options

func (*TraceManager) Done

func (t *TraceManager) Done() <-chan struct{}

Done returns a channel that's closed when tracing is done

func (*TraceManager) GetNodes

func (t *TraceManager) GetNodes() []types.Node

GetNodes returns a copy of the current nodes for testing

func (*TraceManager) Start

func (t *TraceManager) Start(ctx context.Context)

Start starts the trace manager

type TraceManagerOption

type TraceManagerOption func(*TraceManager)

TraceManagerOption defines a function type for configuring TraceManager

func WithIPProvider

func WithIPProvider(provider ipinfo.Provider) TraceManagerOption

WithIPProvider sets the IP info provider

func WithOutputWriter

func WithOutputWriter(writer interfaces.OutputWriter) TraceManagerOption

WithOutputWriter sets the output writer