remotewrite

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

type Config struct {
	// UpstreamURL is the base URL to send remote write requests to.
	// May contain {tenant} placeholder for tenant-based URL routing.
	UpstreamURL string

	// Timeout, if > 0, is applied to http.Client.Timeout and (for the default
	// transport) ResponseHeaderTimeout. Default: 0 (no client-level timeout).
	// Prefer context deadlines on each call.
	Timeout time.Duration

	// TenantHeader is the header name for tenant injection.
	TenantHeader string

	// BearerToken is an optional bearer token for authentication.
	BearerToken string

	// Transport is an optional custom http.Transport.
	Transport *http.Transport

	// MaxConnsPerHost limits connections to the upstream host. Default: 100.
	MaxConnsPerHost int

	// MaxIdleConnsPerHost limits idle connections per host. Default: 10.
	MaxIdleConnsPerHost int

	// Retry configures retry behavior. If nil, retries are DISABLED (streaming mode).
	Retry *RetryConfig

	// RateLimitBytesPerSec limits send rate. 0 = disabled.
	RateLimitBytesPerSec int64

	// UserAgent is the User-Agent header value. Default: "remotewrite-client".
	UserAgent string

	// DefaultContentType is the default Content-Type if not specified per request.
	// Common value: "application/x-protobuf"
	DefaultContentType string

	// DefaultContentEncoding is the default Content-Encoding if not specified per request.
	// Common value: "snappy"
	DefaultContentEncoding string

	// DefaultRemoteWriteVersion is the default X-Prometheus-Remote-Write-Version.
	// Common value: "0.1.0"
	DefaultRemoteWriteVersion string
}

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

type DurableConfig struct {
	// Client configures the underlying HTTP transport.
	Client Config

	// QueueDir is the base directory containing durable queue state.
	QueueDir string
	// QueueName scopes queue files within QueueDir.
	QueueName string
	// MaxInMemoryBlocks limits how many record references remain in memory before the
	// internal scheduler spills them to files.
	MaxInMemoryBlocks int
	// MaxPendingBytes bounds the total size of accepted spool records on disk.
	// When this budget is exceeded, Enqueue returns ErrDurableQueueBlocked.
	MaxPendingBytes int64
	// DisablePersistence disables normal file spillover for the internal scheduling queue.
	// Accepted durable spool records are still written to disk, and their scheduler
	// references may still be written during recovery or after acceptance.
	DisablePersistence bool

	// SendConcurrency controls how many queued payloads may be sent in parallel.
	SendConcurrency int

	// Logger receives durable queue lifecycle and failure logs.
	Logger *slog.Logger
	// Registerer receives durable Prometheus metrics. If nil, metrics are created but not registered.
	Registerer prometheus.Registerer
}

type DurableRequest struct {
	// TenantID is used for tenant URL substitution or tenant header injection.
	TenantID string
	// BodyBytes contains the fully materialized request body to send or spool.
	BodyBytes []byte
	// ContentType is the Content-Type header for the upstream request.
	ContentType string
	// ContentEncoding is the Content-Encoding header for the upstream request.
	ContentEncoding string
	// RemoteWriteVersion is the X-Prometheus-Remote-Write-Version header value.
	RemoteWriteVersion string
	// ExtraHeaders are additional HTTP headers to forward upstream. It must not
	// contain protocol headers or headers managed by client configuration.
	ExtraHeaders http.Header
}

type ForwardRequest struct {
	// TenantID for URL substitution or header injection.
	TenantID string

	// Body is the request body. It will be closed by the transport.
	// Caller should not close it manually until the request is complete.
	Body io.ReadCloser

	// BodyBytes provides pre-buffered body bytes (best performance).
	BodyBytes []byte

	// GetBody returns a fresh body for retries.
	GetBody func() (io.ReadCloser, error)

	// ContentLength is the body size. Set to -1 (or leave 0 with a non-nil
	// Body) when the size is unknown — Forward treats 0 with a streaming Body
	// as "unknown" so net/http does not advertise an empty body.
	ContentLength int64

	// ContentType header value.
	ContentType string

	// ContentEncoding header value.
	ContentEncoding string

	// RemoteWriteVersion header value.
	RemoteWriteVersion string

	// ExtraHeaders are additional headers to forward. It must not contain
	// protocol headers or headers managed by client configuration.
	ExtraHeaders http.Header
}

type PushRequest struct {
	// TenantID is the tenant to push metrics for.
	TenantID string

	// Gatherer is the source of metrics.
	Gatherer prometheus.Gatherer

	// ExternalLabels are labels to add to every metric if not present.
	ExternalLabels map[string]string

	// WriteRelabelConfigs are relabeling rules applied before sending.
	// These can be used to filter, modify, or drop metrics.
	WriteRelabelConfigs []relabel.Config

	// Now returns the current time. If nil, time.Now() is used.
	Now func() time.Time

	// MaxBatchBytes is the target uncompressed batch size. Default: 3MB.
	// This is a soft target; a single metric family may push the batch over.
	MaxBatchBytes int

	// MaxSeriesPerBatch is a soft target for the number of series per batch.
	// Default: 10000. A batch may exceed this when the last appended metric
	// family pushes the count past the target — the series produced by a
	// single metric family are never split across batches.
	MaxSeriesPerBatch int

	// ExtraHeaders are additional headers to forward. It must not contain
	// protocol headers or headers managed by client configuration.
	ExtraHeaders http.Header
}

type PushTimeSeriesRequest struct {
	// TenantID is the tenant to push metrics for.
	TenantID string

	// TimeSeries are the series to send.
	TimeSeries []prompb.TimeSeries

	// MaxBatchBytes is the target uncompressed batch size. Default: 3MB.
	MaxBatchBytes int

	// MaxSeriesPerBatch is the maximum number of series per batch. Default: 10000.
	MaxSeriesPerBatch int

	// ExtraHeaders are additional headers to forward. It must not contain
	// protocol headers or headers managed by client configuration.
	ExtraHeaders http.Header
}

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

type RetryConfig struct {
	// MaxRetries is the maximum number of retries. Must be >= 1.
	MaxRetries int

	// MinWait is the minimum wait between retries. Default: 1s.
	MinWait time.Duration

	// MaxWait is the maximum wait between retries. Default: 30s.
	MaxWait time.Duration

	// MaxBodySize is the maximum body size to buffer for retries.
	// Bodies larger than this will fail with an error if retries are enabled
	// and content length is unknown. Default: 10MB.
	MaxBodySize int64
}