metrics

func (m *Metrics) HandleAggregatedEvent(ctx context.Context,
	timeToFirstIndexerResult time.Duration,
	timeToFirstByte time.Duration,
	success bool,
	storageProviderID string,
	startTime time.Time,
	endTime time.Time,
	bandwidth int64,
	bytesTransferred int64,
	indexerCandidates int64,
	indexerFiltered int64,
	attempts map[string]string)

func (m *Metrics) HandleCandidatesFilteredEvent(ctx context.Context, id types.RetrievalID, details interface{})

func (m *Metrics) HandleCandidatesFoundEvent(ctx context.Context, id types.RetrievalID, eventTime time.Time, details interface{})

func (m *Metrics) HandleFailureEvent(ctx context.Context, id types.RetrievalID, phase types.Phase, storageProviderID string, details interface{})

func (m *Metrics) HandleStartedEvent(ctx context.Context, id types.RetrievalID, phase types.Phase, eventTime time.Time, storageProviderID string)

func (m *Metrics) HandleSuccessEvent(ctx context.Context, id types.RetrievalID, eventTime time.Time, storageProviderId string, details interface{})

func (m *Metrics) HandleTimeToFirstByteEvent(ctx context.Context, id types.RetrievalID, storageProviderId string, eventTime time.Time)

func (m *Metrics) Start() error