remotestorage

Documentation

Index

• Variables
• func New(writer types.MetricWriter, index types.Index, maxConcurrentRemoteWrite int, ...) storage.Appendable
• func NewReadOnly() storage.Appendable
• type MutableLabelDetector
• type RemoteStorage
  • func (r *RemoteStorage) Appender(ctx context.Context) storage.Appender

Variables

var (
	ErrMissingTenantHeader = errors.New("the tenant header is missing")
	ErrParseTTLHeader      = errors.New("can't parse time to live header ")
)

var (
	ErrInvalidMatcher = errors.New("invalid labels")
	ErrNotImplemented = errors.New("not implemented")
)

var ErrIsReadOnly = errors.New("trying to write but read-only mode is enabled")

Functions

func New

func New(
	writer types.MetricWriter,
	index types.Index,
	maxConcurrentRemoteWrite int,
	tenantLabelName string,
	mutableLabelDetector MutableLabelDetector,
	requireTenantHeader bool,
	reg prometheus.Registerer,
) storage.Appendable

New returns a new initialized appendable storage.

func NewReadOnly

func NewReadOnly() storage.Appendable

NewReadOnly return a appended in read-only mode. That is one that return ErrIsReadOnly on all writes.

Types

type MutableLabelDetector

type MutableLabelDetector interface {
	IsMutableLabel(ctx context.Context, tenant, name string) (bool, error)
}

type RemoteStorage

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

func (*RemoteStorage) Appender

func (r *RemoteStorage) Appender(ctx context.Context) storage.Appender