metrics

Documentation

Index

• Constants
• type Metrics
  • func (s *Metrics) Equal(other *Metrics) bool
  • func (s *Metrics) InitWithClients(table *schema.Table, clients []schema.ClientMeta)
  • func (s *Metrics) TotalErrors() uint64
  • func (s *Metrics) TotalErrorsAtomic() uint64
  • func (s *Metrics) TotalPanics() uint64
  • func (s *Metrics) TotalPanicsAtomic() uint64
  • func (s *Metrics) TotalResources() uint64
  • func (s *Metrics) TotalResourcesAtomic() uint64
• type OtelMeters
• type TableClientMetrics
  • func (m *TableClientMetrics) Equal(other *TableClientMetrics) bool
  • func (m *TableClientMetrics) OtelEndTime(ctx context.Context, end time.Time)
  • func (m *TableClientMetrics) OtelErrorsAdd(ctx context.Context, count int64)
  • func (m *TableClientMetrics) OtelPanicsAdd(ctx context.Context, count int64)
  • func (m *TableClientMetrics) OtelResourcesAdd(ctx context.Context, count int64)
  • func (m *TableClientMetrics) OtelStartTime(ctx context.Context, start time.Time)

Constants

const (
	OtelName = "io.cloudquery"
)

Types

type Metrics

type Metrics struct {
	TableClient map[string]map[string]*TableClientMetrics
}

Metrics is deprecated as we move toward open telemetry for tracing and metrics

func (*Metrics) Equal

func (s *Metrics) Equal(other *Metrics) bool

Equal compares to stats. Mostly useful in testing

func (*Metrics) InitWithClients

func (s *Metrics) InitWithClients(table *schema.Table, clients []schema.ClientMeta)

func (*Metrics) TotalErrors

func (s *Metrics) TotalErrors() uint64

func (*Metrics) TotalErrorsAtomic

func (s *Metrics) TotalErrorsAtomic() uint64

func (*Metrics) TotalPanics

func (s *Metrics) TotalPanics() uint64

func (*Metrics) TotalPanicsAtomic

func (s *Metrics) TotalPanicsAtomic() uint64

func (*Metrics) TotalResources

func (s *Metrics) TotalResources() uint64

func (*Metrics) TotalResourcesAtomic

func (s *Metrics) TotalResourcesAtomic() uint64

type OtelMeters

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

type TableClientMetrics

type TableClientMetrics struct {
	Resources uint64
	Errors    uint64
	Panics    uint64
	Duration  atomic.Pointer[time.Duration]
	// contains filtered or unexported fields
}

func (*TableClientMetrics) Equal

func (m *TableClientMetrics) Equal(other *TableClientMetrics) bool

func (*TableClientMetrics) OtelEndTime

func (m *TableClientMetrics) OtelEndTime(ctx context.Context, end time.Time)

func (*TableClientMetrics) OtelErrorsAdd

func (m *TableClientMetrics) OtelErrorsAdd(ctx context.Context, count int64)

func (*TableClientMetrics) OtelPanicsAdd

func (m *TableClientMetrics) OtelPanicsAdd(ctx context.Context, count int64)

func (*TableClientMetrics) OtelResourcesAdd

func (m *TableClientMetrics) OtelResourcesAdd(ctx context.Context, count int64)

func (*TableClientMetrics) OtelStartTime

func (m *TableClientMetrics) OtelStartTime(ctx context.Context, start time.Time)