neo4j_tracing

README

RAITO - DynamoDB utils

Introduction

neo4jtracing is a go library that enables otel distribute tracing for neo4j driver v5.

Getting Started

Add this library as a dependency via go get github.com/raito-io/neo4j-tracing

Enable tracing

TOTO

Documentation

Index

• type BookmarkManagerTracer
  • func (b *BookmarkManagerTracer) GetBookmarks(ctx context.Context) (_ neo4j.Bookmarks, err error)
  • func (b *BookmarkManagerTracer) UpdateBookmarks(ctx context.Context, previousBookmarks, newBookmarks neo4j.Bookmarks) (err error)
• type DriverWithContextTracer
  • func (n *DriverWithContextTracer) ExecuteQueryBookmarkManager() neo4j.BookmarkManager
  • func (n *DriverWithContextTracer) GetServerInfo(ctx context.Context) (_ neo4j.ServerInfo, err error)
  • func (n *DriverWithContextTracer) NewSession(ctx context.Context, config neo4j.SessionConfig) neo4j.SessionWithContext
  • func (n *DriverWithContextTracer) VerifyAuthentication(ctx context.Context, auth *neo4j.AuthToken) (err error)
  • func (n *DriverWithContextTracer) VerifyConnectivity(ctx context.Context) (err error)
• type ExplicitTransactionTracer
  • func NewExplicitTransactionTracer(ctx context.Context, tx neo4j.ExplicitTransaction, txSpan trace.Span, ...) *ExplicitTransactionTracer
  • func (t *ExplicitTransactionTracer) Close(ctx context.Context) (err error)
  • func (t *ExplicitTransactionTracer) Commit(ctx context.Context) (err error)
  • func (t *ExplicitTransactionTracer) Rollback(ctx context.Context) (err error)
  • func (t *ExplicitTransactionTracer) Run(ctx context.Context, cypher string, params map[string]any) (_ neo4j.ResultWithContext, err error)
• type ManagedTransactionTracer
  • func NewManagedTransactionTracer(ctx context.Context, tx neo4j.ManagedTransaction, tracer trace.Tracer) *ManagedTransactionTracer
  • func (t *ManagedTransactionTracer) Run(ctx context.Context, cypher string, params map[string]any) (_ neo4j.ResultWithContext, err error)
• type Neo4jTracer
  • func NewNeo4jTracer(opts ...Option) *Neo4jTracer
  • func (t *Neo4jTracer) NewDriverWithContext(target string, auth auth.TokenManager, ...) (_ neo4j.DriverWithContext, err error)
• type Option
  • func WithTracerProvider(tp trace.TracerProvider) Option
• type SessionWithContextTracer
  • func (s *SessionWithContextTracer) BeginTransaction(ctx context.Context, configurers ...func(config *neo4j.TransactionConfig)) (neo4j.ExplicitTransaction, error)
  • func (s *SessionWithContextTracer) ExecuteRead(ctx context.Context, work neo4j.ManagedTransactionWork, ...) (_ any, err error)
  • func (s *SessionWithContextTracer) ExecuteWrite(ctx context.Context, work neo4j.ManagedTransactionWork, ...) (_ any, err error)
  • func (s *SessionWithContextTracer) Run(ctx context.Context, cypher string, params map[string]any, ...) (_ neo4j.ResultWithContext, err error)

Types

type BookmarkManagerTracer

type BookmarkManagerTracer struct {
	neo4j.BookmarkManager
	// contains filtered or unexported fields
}

func (*BookmarkManagerTracer) GetBookmarks

func (b *BookmarkManagerTracer) GetBookmarks(ctx context.Context) (_ neo4j.Bookmarks, err error)

func (*BookmarkManagerTracer) UpdateBookmarks

func (b *BookmarkManagerTracer) UpdateBookmarks(ctx context.Context, previousBookmarks, newBookmarks neo4j.Bookmarks) (err error)

type DriverWithContextTracer

type DriverWithContextTracer struct {
	neo4j.DriverWithContext
	// contains filtered or unexported fields
}

func (*DriverWithContextTracer) ExecuteQueryBookmarkManager

func (n *DriverWithContextTracer) ExecuteQueryBookmarkManager() neo4j.BookmarkManager

func (*DriverWithContextTracer) GetServerInfo

func (n *DriverWithContextTracer) GetServerInfo(ctx context.Context) (_ neo4j.ServerInfo, err error)

func (*DriverWithContextTracer) NewSession

func (n *DriverWithContextTracer) NewSession(ctx context.Context, config neo4j.SessionConfig) neo4j.SessionWithContext

func (*DriverWithContextTracer) VerifyAuthentication

func (n *DriverWithContextTracer) VerifyAuthentication(ctx context.Context, auth *neo4j.AuthToken) (err error)

func (*DriverWithContextTracer) VerifyConnectivity

func (n *DriverWithContextTracer) VerifyConnectivity(ctx context.Context) (err error)

type ExplicitTransactionTracer

type ExplicitTransactionTracer struct {
	neo4j.ExplicitTransaction
	// contains filtered or unexported fields
}

func NewExplicitTransactionTracer

func NewExplicitTransactionTracer(ctx context.Context, tx neo4j.ExplicitTransaction, txSpan trace.Span, tracer trace.Tracer) *ExplicitTransactionTracer

func (*ExplicitTransactionTracer) Close

func (t *ExplicitTransactionTracer) Close(ctx context.Context) (err error)

func (*ExplicitTransactionTracer) Commit

func (t *ExplicitTransactionTracer) Commit(ctx context.Context) (err error)

func (*ExplicitTransactionTracer) Rollback

func (t *ExplicitTransactionTracer) Rollback(ctx context.Context) (err error)

func (*ExplicitTransactionTracer) Run

func (t *ExplicitTransactionTracer) Run(ctx context.Context, cypher string, params map[string]any) (_ neo4j.ResultWithContext, err error)

type ManagedTransactionTracer

type ManagedTransactionTracer struct {
	neo4j.ManagedTransaction
	// contains filtered or unexported fields
}

func NewManagedTransactionTracer

func NewManagedTransactionTracer(ctx context.Context, tx neo4j.ManagedTransaction, tracer trace.Tracer) *ManagedTransactionTracer

func (*ManagedTransactionTracer) Run

func (t *ManagedTransactionTracer) Run(ctx context.Context, cypher string, params map[string]any) (_ neo4j.ResultWithContext, err error)

type Neo4jTracer

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

func NewNeo4jTracer

func NewNeo4jTracer(opts ...Option) *Neo4jTracer

func (*Neo4jTracer) NewDriverWithContext

func (t *Neo4jTracer) NewDriverWithContext(target string, auth auth.TokenManager, configurers ...func(config2 *neo4j.Config)) (_ neo4j.DriverWithContext, err error)

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithTracerProvider

func WithTracerProvider(tp trace.TracerProvider) Option

type SessionWithContextTracer

type SessionWithContextTracer struct {
	neo4j.SessionWithContext
	// contains filtered or unexported fields
}

func (*SessionWithContextTracer) BeginTransaction

func (s *SessionWithContextTracer) BeginTransaction(ctx context.Context, configurers ...func(config *neo4j.TransactionConfig)) (neo4j.ExplicitTransaction, error)

func (*SessionWithContextTracer) ExecuteRead

func (s *SessionWithContextTracer) ExecuteRead(ctx context.Context, work neo4j.ManagedTransactionWork, configurers ...func(config *neo4j.TransactionConfig)) (_ any, err error)

func (*SessionWithContextTracer) ExecuteWrite

func (s *SessionWithContextTracer) ExecuteWrite(ctx context.Context, work neo4j.ManagedTransactionWork, configurers ...func(config *neo4j.TransactionConfig)) (_ any, err error)

func (*SessionWithContextTracer) Run

func (s *SessionWithContextTracer) Run(ctx context.Context, cypher string, params map[string]any, configurers ...func(config *neo4j.TransactionConfig)) (_ neo4j.ResultWithContext, err error)