utils

Documentation

Index

• func NewRemoteWriteServer(receivedChan chan RemoteWriteRequest, status int) *httptest.Server
• func ToLabelSet(in map[string]string) model.LabelSet
• type RemoteWriteRequest
• type SyncSlice
  • func NewSyncSlice[T any]() *SyncSlice[T]
  • func (ss *SyncSlice[T]) Append(el T)
  • func (ss *SyncSlice[T]) DoneIterate()
  • func (ss *SyncSlice[T]) Length() int
  • func (ss *SyncSlice[T]) StartIterate() []T

Functions

func NewRemoteWriteServer

func NewRemoteWriteServer(receivedChan chan RemoteWriteRequest, status int) *httptest.Server

NewRemoteWriteServer creates and starts a new httpserver.Server that can handle remote write request. When a request is handled, the received entries are written to receivedChan, and status is responded.

func ToLabelSet

func ToLabelSet(in map[string]string) model.LabelSet

ToLabelSet converts a map of strings to a prometheus LabelSet.

Types

type RemoteWriteRequest

type RemoteWriteRequest struct {
	TenantID string
	Request  logproto.PushRequest
}

RemoteWriteRequest wraps the received logs remote write request that is received.

type SyncSlice

type SyncSlice[T any] struct {
	// contains filtered or unexported fields
}

SyncSlice is a concurrent slice implementation.

func NewSyncSlice

func NewSyncSlice[T any]() *SyncSlice[T]

func (*SyncSlice[T]) Append

func (ss *SyncSlice[T]) Append(el T)

func (*SyncSlice[T]) DoneIterate

func (ss *SyncSlice[T]) DoneIterate()

DoneIterate releases the internal read-lock.

func (*SyncSlice[T]) Length

func (ss *SyncSlice[T]) Length() int

func (*SyncSlice[T]) StartIterate

func (ss *SyncSlice[T]) StartIterate() []T

StartIterate returns the internal slice, after read-locking the internal lock. Once the iteration is finished, DoneIterate should be called to release the lock.