tracecacheextension

Documentation

Index

• func NewFactory() extension.Factory
• type Config
• type RWMap
  • func NewRWMap[K comparable, V any]() *RWMap[K, V]
  • func (m *RWMap[K, V]) Delete(key K)
  • func (m *RWMap[K, V]) Load(key K) (V, bool)
  • func (m *RWMap[K, V]) LoadOrStore(key K, value V) (V, bool)
• type TraceCacheExtension
  • func (tce *TraceCacheExtension) CacheTrace(traces ptrace.Traces) map[pcommon.TraceID]tracecache.SpanMapping
  • func (tce *TraceCacheExtension) HasConnector() bool
  • func (tce *TraceCacheExtension) IsEnable() bool
  • func (tce *TraceCacheExtension) SetConnector(connector tracecache.Connector)
  • func (tce *TraceCacheExtension) SetSampler(sampler tracecache.Sampler) error
  • func (tce *TraceCacheExtension) Shutdown(context.Context) error
  • func (tce *TraceCacheExtension) Start(context.Context, component.Host) error

Functions

func NewFactory

func NewFactory() extension.Factory

Types

type Config

type Config struct {
	Enable bool `mapstructure:"enable"`

	CleanTime time.Duration `mapstructure:"clean_time"`
}

type RWMap

type RWMap[K comparable, V any] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRWMap

func NewRWMap[K comparable, V any]() *RWMap[K, V]

func (*RWMap[K, V]) Delete

func (m *RWMap[K, V]) Delete(key K)

func (*RWMap[K, V]) Load

func (m *RWMap[K, V]) Load(key K) (V, bool)

func (*RWMap[K, V]) LoadOrStore

func (m *RWMap[K, V]) LoadOrStore(key K, value V) (V, bool)

type TraceCacheExtension

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

func (*TraceCacheExtension) CacheTrace

func (tce *TraceCacheExtension) CacheTrace(traces ptrace.Traces) map[pcommon.TraceID]tracecache.SpanMapping

func (*TraceCacheExtension) HasConnector

func (tce *TraceCacheExtension) HasConnector() bool

func (*TraceCacheExtension) IsEnable

func (tce *TraceCacheExtension) IsEnable() bool

func (*TraceCacheExtension) SetConnector

func (tce *TraceCacheExtension) SetConnector(connector tracecache.Connector)

func (*TraceCacheExtension) SetSampler

func (tce *TraceCacheExtension) SetSampler(sampler tracecache.Sampler) error

func (*TraceCacheExtension) Shutdown

func (tce *TraceCacheExtension) Shutdown(context.Context) error

func (*TraceCacheExtension) Start

func (tce *TraceCacheExtension) Start(context.Context, component.Host) error