remote

Documentation

Index

• type StorageClient
• type StorageQueueManager
  • func NewStorageQueueManager(tsdb StorageClient, queueCapacity int) *StorageQueueManager
  • func (t *StorageQueueManager) Append(s *clientmodel.Sample)
  • func (t *StorageQueueManager) Collect(ch chan<- prometheus.Metric)
  • func (t *StorageQueueManager) Describe(ch chan<- *prometheus.Desc)
  • func (t *StorageQueueManager) Run()
  • func (t *StorageQueueManager) Stop()

Types

type StorageClient

type StorageClient interface {
	// Store stores the given samples in the remote storage.
	Store(clientmodel.Samples) error
	// Name identifies the remote storage implementation.
	Name() string
}

StorageClient defines an interface for sending a batch of samples to an external timeseries database.

type StorageQueueManager

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

StorageQueueManager manages a queue of samples to be sent to the Storage indicated by the provided StorageClient.

func NewStorageQueueManager

func NewStorageQueueManager(tsdb StorageClient, queueCapacity int) *StorageQueueManager

NewStorageQueueManager builds a new StorageQueueManager.

func (*StorageQueueManager) Append

func (t *StorageQueueManager) Append(s *clientmodel.Sample)

Append queues a sample to be sent to the remote storage. It drops the sample on the floor if the queue is full. It implements storage.SampleAppender.

func (*StorageQueueManager) Collect

func (t *StorageQueueManager) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*StorageQueueManager) Describe

func (t *StorageQueueManager) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector.

func (*StorageQueueManager) Run

func (t *StorageQueueManager) Run()

Run continuously sends samples to the remote storage.

func (*StorageQueueManager) Stop

func (t *StorageQueueManager) Stop()

Stop stops sending samples to the remote storage and waits for pending sends to complete.