statservice

Documentation

Index

• type Collector
• type CollectorService
  • func NewCollectorService(ctx context.Context, logger logservice.Logger, httpClient httpclient.Pooled, ...) *CollectorService
  • func (c *CollectorService) AddFailedRequest()
  • func (c *CollectorService) AddFailedRequestsDuration(d time.Duration)
  • func (c *CollectorService) AddSuccessRequest()
  • func (c *CollectorService) AddSuccessRequestsDuration(d time.Duration)
  • func (c *CollectorService) AddTotalRequest()
  • func (c *CollectorService) AddTotalRequestsDuration(d time.Duration)
  • func (c *CollectorService) AddWorker()
  • func (c *CollectorService) AvgFailedRequestsDuration() time.Duration
  • func (c *CollectorService) AvgSuccessRequestsDuration() time.Duration
  • func (c *CollectorService) AvgTotalRequestsDuration() time.Duration
  • func (c *CollectorService) FailedRequests() int64
  • func (c *CollectorService) FailedRequestsDuration() (ms int64)
  • func (c *CollectorService) HttpClientOutOfPool() int64
  • func (c *CollectorService) HttpClientPoolBusy() int64
  • func (c *CollectorService) HttpClientPoolTotal() int64
  • func (c *CollectorService) Metric(stage int64) (metric *statmodel.Metrics, found bool)
  • func (c *CollectorService) RPS() int64
  • func (c *CollectorService) RemoveWorker()
  • func (c *CollectorService) Run(wg *sync.WaitGroup)
  • func (c *CollectorService) SetHttpClientOutOfPool()
  • func (c *CollectorService) SetHttpClientPoolBusy()
  • func (c *CollectorService) SetHttpClientPoolTotal()
  • func (c *CollectorService) Stages() int64
  • func (c *CollectorService) StartedAt() time.Time
  • func (c *CollectorService) SuccessRequests() int64
  • func (c *CollectorService) SuccessRequestsDuration() (ms int64)
  • func (c *CollectorService) SummaryAvgFailedRequestsDuration() time.Duration
  • func (c *CollectorService) SummaryAvgSuccessRequestsDuration() time.Duration
  • func (c *CollectorService) SummaryAvgTotalRequestsDuration() time.Duration
  • func (c *CollectorService) SummaryDuration() time.Duration
  • func (c *CollectorService) SummaryFailedRequests() int64
  • func (c *CollectorService) SummaryRPS() int64
  • func (c *CollectorService) SummarySuccessRequests() int64
  • func (c *CollectorService) SummaryTotalRequests() int64
  • func (c *CollectorService) TotalRequests() int64
  • func (c *CollectorService) TotalRequestsDuration() (ms int64)
  • func (c *CollectorService) Workers() int64

Types

type Collector

type Collector interface {
	Run(wg *sync.WaitGroup)

	Metric(stage int64) (metric *statmodel.Metrics, found bool)
	Stages() int64

	StartedAt() time.Time
	SummaryDuration() time.Duration

	RPS() int64
	SummaryRPS() int64

	AddWorker()
	Workers() int64
	RemoveWorker()

	AddTotalRequest()
	TotalRequests() int64
	SummaryTotalRequests() int64

	AddSuccessRequest()
	SuccessRequests() int64
	SummarySuccessRequests() int64

	AddFailedRequest()
	FailedRequests() int64
	SummaryFailedRequests() int64

	AddTotalRequestsDuration(d time.Duration)
	TotalRequestsDuration() (ms int64)
	AvgTotalRequestsDuration() time.Duration
	SummaryAvgTotalRequestsDuration() time.Duration

	AddSuccessRequestsDuration(d time.Duration)
	SuccessRequestsDuration() (ms int64)
	AvgSuccessRequestsDuration() time.Duration
	SummaryAvgSuccessRequestsDuration() time.Duration

	AddFailedRequestsDuration(d time.Duration)
	FailedRequestsDuration() (ms int64)
	AvgFailedRequestsDuration() time.Duration
	SummaryAvgFailedRequestsDuration() time.Duration

	HttpClientPoolBusy() int64
	SetHttpClientPoolBusy()
	HttpClientPoolTotal() int64
	SetHttpClientPoolTotal()
	HttpClientOutOfPool() int64
	SetHttpClientOutOfPool()
}

type CollectorService

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

func NewCollectorService

func NewCollectorService(
	ctx context.Context,
	logger logservice.Logger,
	httpClient httpclient.Pooled,
	duration time.Duration,
	stages int64,
) *CollectorService

func (*CollectorService) AddFailedRequest

func (c *CollectorService) AddFailedRequest()

func (*CollectorService) AddFailedRequestsDuration

func (c *CollectorService) AddFailedRequestsDuration(d time.Duration)

AddFailedRequestsDuration for current percentile.

func (*CollectorService) AddSuccessRequest

func (c *CollectorService) AddSuccessRequest()

func (*CollectorService) AddSuccessRequestsDuration

func (c *CollectorService) AddSuccessRequestsDuration(d time.Duration)

AddSuccessRequestsDuration for current percentile.

func (*CollectorService) AddTotalRequest

func (c *CollectorService) AddTotalRequest()

func (*CollectorService) AddTotalRequestsDuration

func (c *CollectorService) AddTotalRequestsDuration(d time.Duration)

AddTotalRequestsDuration for current percentile.

func (*CollectorService) AddWorker

func (c *CollectorService) AddWorker()

func (*CollectorService) AvgFailedRequestsDuration

func (c *CollectorService) AvgFailedRequestsDuration() time.Duration

AvgFailedRequestsDuration of current percentile.

func (*CollectorService) AvgSuccessRequestsDuration

func (c *CollectorService) AvgSuccessRequestsDuration() time.Duration

AvgSuccessRequestsDuration of current percentile.

func (*CollectorService) AvgTotalRequestsDuration

func (c *CollectorService) AvgTotalRequestsDuration() time.Duration

AvgTotalRequestsDuration of current percentile.

func (*CollectorService) FailedRequests

func (c *CollectorService) FailedRequests() int64

func (*CollectorService) FailedRequestsDuration

func (c *CollectorService) FailedRequestsDuration() (ms int64)

FailedRequestsDuration of current percentile.

func (*CollectorService) HttpClientOutOfPool

func (c *CollectorService) HttpClientOutOfPool() int64

func (*CollectorService) HttpClientPoolBusy

func (c *CollectorService) HttpClientPoolBusy() int64

func (*CollectorService) HttpClientPoolTotal

func (c *CollectorService) HttpClientPoolTotal() int64

func (*CollectorService) Metric

func (c *CollectorService) Metric(stage int64) (metric *statmodel.Metrics, found bool)

func (*CollectorService) RPS

func (c *CollectorService) RPS() int64

func (*CollectorService) RemoveWorker

func (c *CollectorService) RemoveWorker()

func (*CollectorService) Run

func (c *CollectorService) Run(wg *sync.WaitGroup)

func (*CollectorService) SetHttpClientOutOfPool

func (c *CollectorService) SetHttpClientOutOfPool()

func (*CollectorService) SetHttpClientPoolBusy

func (c *CollectorService) SetHttpClientPoolBusy()

func (*CollectorService) SetHttpClientPoolTotal

func (c *CollectorService) SetHttpClientPoolTotal()

func (*CollectorService) Stages

func (c *CollectorService) Stages() int64

Stages number. This value is not mutable.

func (*CollectorService) StartedAt

func (c *CollectorService) StartedAt() time.Time

func (*CollectorService) SuccessRequests

func (c *CollectorService) SuccessRequests() int64

func (*CollectorService) SuccessRequestsDuration

func (c *CollectorService) SuccessRequestsDuration() (ms int64)

SuccessRequestsDuration of current percentile.

func (*CollectorService) SummaryAvgFailedRequestsDuration

func (c *CollectorService) SummaryAvgFailedRequestsDuration() time.Duration

SummaryAvgFailedRequestsDuration of all percentiles.

func (*CollectorService) SummaryAvgSuccessRequestsDuration

func (c *CollectorService) SummaryAvgSuccessRequestsDuration() time.Duration

SummaryAvgSuccessRequestsDuration of all percentiles.

func (*CollectorService) SummaryAvgTotalRequestsDuration

func (c *CollectorService) SummaryAvgTotalRequestsDuration() time.Duration

SummaryAvgTotalRequestsDuration of all percentiles.

func (*CollectorService) SummaryDuration

func (c *CollectorService) SummaryDuration() time.Duration

func (*CollectorService) SummaryFailedRequests

func (c *CollectorService) SummaryFailedRequests() int64

func (*CollectorService) SummaryRPS

func (c *CollectorService) SummaryRPS() int64

func (*CollectorService) SummarySuccessRequests

func (c *CollectorService) SummarySuccessRequests() int64

func (*CollectorService) SummaryTotalRequests

func (c *CollectorService) SummaryTotalRequests() int64

func (*CollectorService) TotalRequests

func (c *CollectorService) TotalRequests() int64

func (*CollectorService) TotalRequestsDuration

func (c *CollectorService) TotalRequestsDuration() (ms int64)

func (*CollectorService) Workers

func (c *CollectorService) Workers() int64