stats

Documentation

Index

• type ConcurrencyStats
  • func NewConcurrencyStats() *ConcurrencyStats
  • func (s *ConcurrencyStats) AddTotalBytes(nBytes int64)
  • func (s *ConcurrencyStats) Failed(nBytes, nRecords int64)
  • func (s *ConcurrencyStats) Init()
  • func (s *ConcurrencyStats) RequestFailed(nRecords int64)
  • func (s *ConcurrencyStats) RequestSucceeded(nRecords int64, latency, respTime time.Duration)
  • func (s *ConcurrencyStats) Stats() *Stats
  • func (s *ConcurrencyStats) String() string
  • func (s *ConcurrencyStats) Succeeded(nBytes, nRecords int64)
• type Stats
  • func (s *Stats) IsFailed() bool
  • func (s *Stats) Percentage() float64
  • func (s *Stats) String() string

Types

type ConcurrencyStats

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

func NewConcurrencyStats

func NewConcurrencyStats() *ConcurrencyStats

func (*ConcurrencyStats) AddTotalBytes

func (s *ConcurrencyStats) AddTotalBytes(nBytes int64)

func (*ConcurrencyStats) Failed

func (s *ConcurrencyStats) Failed(nBytes, nRecords int64)

func (*ConcurrencyStats) Init

func (s *ConcurrencyStats) Init()

func (*ConcurrencyStats) RequestFailed

func (s *ConcurrencyStats) RequestFailed(nRecords int64)

func (*ConcurrencyStats) RequestSucceeded

func (s *ConcurrencyStats) RequestSucceeded(nRecords int64, latency, respTime time.Duration)

func (*ConcurrencyStats) Stats

func (s *ConcurrencyStats) Stats() *Stats

func (*ConcurrencyStats) String

func (s *ConcurrencyStats) String() string

func (*ConcurrencyStats) Succeeded

func (s *ConcurrencyStats) Succeeded(nBytes, nRecords int64)

type Stats

type Stats struct {
	StartTime       time.Time     // The time to start statistics.
	ProcessedBytes  int64         // The processed bytes.
	TotalBytes      int64         // The total bytes.
	FailedRecords   int64         // The number of records that have failed to be processed.
	TotalRecords    int64         // The number of records that have been processed.
	FailedRequest   int64         // The number of requests that have failed.
	TotalRequest    int64         // The number of requests that have been processed.
	TotalLatency    time.Duration // The cumulative latency.
	TotalRespTime   time.Duration // The cumulative response time.
	FailedProcessed int64         // The number of nodes and edges that have failed to be processed.
	TotalProcessed  int64         // The number of nodes and edges that have been processed.
}

func (*Stats) IsFailed

func (s *Stats) IsFailed() bool

func (*Stats) Percentage

func (s *Stats) Percentage() float64

func (*Stats) String

func (s *Stats) String() string