graphmodel

Documentation

Overview

Package graphmodel provides methods that encode opentelemetry pipeline data into a property graph through cypher queries.

Index

• type Encoder
  • func NewEncoder(labelFromAttr map[attribute.Key]ResourceEncoder, ...) *Encoder
  • func (e *Encoder) MergeResource(ctx context.Context, tx neo4j.ManagedTransaction, r *pcommon.Resource) error
• type ResourceEncoder

Types

type Encoder

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

Encoder defines the configuration required to encode traces in a hierarchical property graph

func NewEncoder

func NewEncoder(labelFromAttr map[attribute.Key]ResourceEncoder, containmentOrder map[string][]string, logger *zap.Logger) *Encoder

NewEncoder creates a graph encoder with the provided parameters

func (*Encoder) MergeResource

func (e *Encoder) MergeResource(ctx context.Context, tx neo4j.ManagedTransaction, r *pcommon.Resource) error

type ResourceEncoder

type ResourceEncoder struct {
	ResourceType       string
	AdditionalPropKeys []attribute.Key
}

ResourceEncoder is a struct that identifies a type of resource and all the attributes found in telemetry data that will be used to create a vertex in graph encoding procedure.