metrics

package

v4.91.0 Latest Latest Go to latest Published: Oct 31, 2025 License: MPL-2.0 Imports: 8 Imported by: 0

Details

View Source

const (
	ResourceName = "io.cloudquery"
)

This section is empty.

This section is empty.

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

func NewMetrics() *Metrics

func (m *Metrics) AddErrors(ctx context.Context, count int64, selector Selector)

func (m *Metrics) AddPanics(ctx context.Context, count int64, selector Selector)

func (m *Metrics) AddResources(ctx context.Context, count int64, selector Selector)

func (m *Metrics) EndTime(ctx context.Context, end time.Time, selector Selector)

func (m *Metrics) GetDuration(selector Selector) time.Duration

func (m *Metrics) GetErrors(selector Selector) uint64

func (m *Metrics) GetPanics(selector Selector) uint64

func (m *Metrics) GetResources(selector Selector) uint64

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

func (*Metrics) NewSelector(clientID, tableName string) Selector

func (m *Metrics) StartTime(start time.Time, selector Selector)

func (m *Metrics) TableDuration(tableName string) time.Duration

func (m *Metrics) TotalErrors() uint64

func (m *Metrics) TotalErrorsAtomic() uint64

Deprecated: Use TotalErrors instead, it provides the same functionality but is more consistent with the naming of other metrics methods.

func (m *Metrics) TotalPanics() uint64

func (m *Metrics) TotalPanicsAtomic() uint64

Deprecated: Use TotalPanics instead, it provides the same functionality but is more consistent with the naming of other metrics methods.

func (m *Metrics) TotalResources() uint64

func (m *Metrics) TotalResourcesAtomic() uint64

Deprecated: Use TotalResources instead, it provides the same functionality but is more consistent with the naming of other metrics methods.

type Selector struct {
	attribute.Set
	// contains filtered or unexported fields
}