transform

Documentation

Index

• type ExtensionProcessor
• type FetchExtensionsAndStoreCache
  • func (x *FetchExtensionsAndStoreCache) ProcessExtensions(ctx context.Context, transformer *Transformer, extensions []extension.Provider, ...) ([]*model.Span, error)
• type LoadExtensionCache
  • func (x *LoadExtensionCache) ProcessExtensions(ctx context.Context, transformer *Transformer, extensions []extension.Provider, ...) ([]*model.Span, error)
• type Transformer
  • func (transformer *Transformer) Close(ctx context.Context) error
  • func (transformer *Transformer) Init() error
  • func (transformer *Transformer) Options() manager.Options
  • func (transformer *Transformer) Start(ctx context.Context) error
  • func (transformer *Transformer) Transform(ctx context.Context, trace *model.Trace, rootObject *utilobject.Key, ...) error
• type TransformerOptions
  • func (options *TransformerOptions) EnableFlag() *bool
  • func (options *TransformerOptions) Setup(fs *pflag.FlagSet)

Types

type ExtensionProcessor

type ExtensionProcessor interface {
	ProcessExtensions(
		ctx context.Context,
		transformer *Transformer,
		extensions []extension.Provider,
		spans []*model.Span,
		start, end time.Time,
	) ([]*model.Span, error)
}

type FetchExtensionsAndStoreCache

type FetchExtensionsAndStoreCache struct {
	Cache []tracecache.ExtensionCache
}

func (*FetchExtensionsAndStoreCache) ProcessExtensions

func (x *FetchExtensionsAndStoreCache) ProcessExtensions(
	ctx context.Context,
	transformer *Transformer,
	extensions []extension.Provider,
	spans []*model.Span,
	start, end time.Time,
) ([]*model.Span, error)

type LoadExtensionCache

type LoadExtensionCache struct {
	Cache []tracecache.ExtensionCache
}

func (*LoadExtensionCache) ProcessExtensions

func (x *LoadExtensionCache) ProcessExtensions(
	ctx context.Context,
	transformer *Transformer,
	extensions []extension.Provider,
	spans []*model.Span,
	start, end time.Time,
) ([]*model.Span, error)

type Transformer

type Transformer struct {
	Logger           logrus.FieldLogger
	Configs          tfconfig.Provider
	ExtensionFactory *manager.List[extension.ProviderFactory]
	// contains filtered or unexported fields
}

func (*Transformer) Close

func (transformer *Transformer) Close(ctx context.Context) error

func (*Transformer) Init

func (transformer *Transformer) Init() error

func (*Transformer) Options

func (transformer *Transformer) Options() manager.Options

func (*Transformer) Start

func (transformer *Transformer) Start(ctx context.Context) error

func (*Transformer) Transform

func (transformer *Transformer) Transform(
	ctx context.Context,
	trace *model.Trace,
	rootObject *utilobject.Key,
	configId tfconfig.Id,
	extensionProcessor ExtensionProcessor,
	start, end time.Time,
) error

type TransformerOptions

type TransformerOptions struct{}

func (*TransformerOptions) EnableFlag

func (options *TransformerOptions) EnableFlag() *bool

func (*TransformerOptions) Setup

func (options *TransformerOptions) Setup(fs *pflag.FlagSet)