Skip to content
Documentation
Reference
SDK
observer/otel

observer/otel

otel

import "github.com/danmestas/libfossil/observer/otel"

Package otel provides OpenTelemetry implementations of the libfossil SyncObserver and CheckoutObserver interfaces. Import this package only when you want OTel instrumentation — it pulls in the OTel SDK dependency.

Index

type CheckoutObserver

CheckoutObserver implements libfossil.CheckoutObserver using OpenTelemetry spans and metrics.

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

func NewCheckoutObserver 

func NewCheckoutObserver() *CheckoutObserver

NewCheckoutObserver returns a CheckoutObserver that records spans and metrics using the OTel global tracer and meter providers.

func (*CheckoutObserver) CommitCompleted 

func (o *CheckoutObserver) CommitCompleted(info libfossil.CommitEnd)

func (*CheckoutObserver) CommitStarted 

func (o *CheckoutObserver) CommitStarted(info libfossil.CommitStart)

func (*CheckoutObserver) Error 

func (o *CheckoutObserver) Error(err error)

func (*CheckoutObserver) ExtractCompleted 

func (o *CheckoutObserver) ExtractCompleted(info libfossil.ExtractEnd)

func (*CheckoutObserver) ExtractFileCompleted 

func (o *CheckoutObserver) ExtractFileCompleted(name string, change libfossil.UpdateChange)

func (*CheckoutObserver) ExtractStarted 

func (o *CheckoutObserver) ExtractStarted(info libfossil.ExtractStart)

func (*CheckoutObserver) ScanCompleted 

func (o *CheckoutObserver) ScanCompleted(info libfossil.ScanEnd)

func (*CheckoutObserver) ScanStarted 

func (o *CheckoutObserver) ScanStarted(dir string)

func (*CheckoutObserver) String 

func (o *CheckoutObserver) String() string

type SyncObserver

SyncObserver implements libfossil.SyncObserver using OpenTelemetry spans and metrics.

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

func NewSyncObserver 

func NewSyncObserver() *SyncObserver

NewSyncObserver returns a SyncObserver that records spans and metrics using the OTel global tracer and meter providers.

func (*SyncObserver) Completed 

func (o *SyncObserver) Completed(info libfossil.SessionEnd)

func (*SyncObserver) Error 

func (o *SyncObserver) Error(err error)

func (*SyncObserver) HandleCompleted 

func (o *SyncObserver) HandleCompleted(info libfossil.HandleEnd)

func (*SyncObserver) HandleStarted 

func (o *SyncObserver) HandleStarted(info libfossil.HandleStart)

func (*SyncObserver) RoundCompleted 

func (o *SyncObserver) RoundCompleted(round int, stats libfossil.RoundStats)

func (*SyncObserver) RoundStarted 

func (o *SyncObserver) RoundStarted(round int)

func (*SyncObserver) Started 

func (o *SyncObserver) Started(info libfossil.SessionStart)

func (*SyncObserver) String 

func (o *SyncObserver) String() string

String returns a human-readable description.

func (*SyncObserver) TableSyncCompleted 

func (o *SyncObserver) TableSyncCompleted(info libfossil.TableSyncEnd)

func (*SyncObserver) TableSyncStarted 

func (o *SyncObserver) TableSyncStarted(info libfossil.TableSyncStart)

Generated by gomarkdoc

libfossil