quaistats

type AuthResponse ¶

type AuthResponse struct {
	Success bool   `json:"success"`
	Token   string `json:"token"`
}

type BatchObject ¶ added in v0.25.0

type BatchObject struct {
	TotalNoTransactions uint64
	OldestBlockTime     uint64
}

type Credentials ¶

type Credentials struct {
	Name     string `json:"name"`
	Password string `json:"password"`
}

type Service ¶

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

Service implements an Quai netstats reporting daemon that pushes local chain statistics up to a monitoring server.

func (s *Service) Start() error

func (s *Service) Stop() error

type StatsQueue ¶ added in v0.25.0

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

StatsQueue is a thread-safe queue designed for managing and processing stats data.

The primary objective of the StatsQueue is to provide a safe mechanism for enqueuing, dequeuing, and requeuing stats objects concurrently across multiple goroutines.

Key Features:

• Enqueue: Allows adding an item to the end of the queue.
• Dequeue: Removes and returns the item from the front of the queue.
• RequeueFront: Adds an item back to the front of the queue, useful for failed processing attempts.

Concurrent Access:

• The internal state of the queue is protected by a mutex to prevent data races and ensure that the operations are atomic. As a result, it's safe to use across multiple goroutines without external synchronization.

func NewStatsQueue() *StatsQueue

func (q *StatsQueue) Dequeue() interface{}

func (q *StatsQueue) Enqueue(item interface{})

func (q *StatsQueue) EnqueueFront(item interface{})

func (q *StatsQueue) EnqueueFrontBatch(items []interface{})

func (q *StatsQueue) Size() int