storage

package
v1.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2024 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BATCH_FLUSH_INTERVAL = 500 * time.Millisecond

	MAX_BATCH_SIZE_IN_BYTES             = 32 * 1024
	MAX_INTERNODE_PAYLOAD_SIZE_IN_BYTES = 2 * MAX_BATCH_SIZE_IN_BYTES
)

Variables

This section is empty.

Functions

func NewRemoteAppender 

func NewRemoteAppender(targetNodeIndex string, connection *leanstreams.Connection, done chan struct{}, opts ...RemoteAppenderOption) prom_storage.Appender

func NewRemoteQuerier 

func NewRemoteQuerier(
	ctx context.Context,
	index int,
	addr string,
	egressTLSConfig *config_util.TLSConfig,
	logger *logger.Logger,
) (prom_storage.Querier, error)

func NewReplicatedAppender 

func NewReplicatedAppender(appenders []storage.Appender, lookup routing.Lookup, opts ...ReplicatedAppenderOption) prom_storage.Appender

func NewReplicatedStorage 

func NewReplicatedStorage(
	localStore prom_storage.Storage,
	localIndex int,
	nodeAddrs []string,
	internodeAddrs []string,
	replicationFactor uint,
	internodeTLSConfig *tls.Config,
	egressTLSConfig *config_util.TLSConfig,
	queryTimeout time.Duration,
	opts ...ReplicatedOption,
) prom_storage.Storage

func NewScrapeStorage 

func NewScrapeStorage(store prom_storage.Storage) prom_storage.Appendable

Types

type QuerierFactory 

type QuerierFactory interface {
	Build(ctx context.Context, nodeIndexes ...int) []prom_storage.Querier
}

type RemoteAppender 

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

func (*RemoteAppender) Append added in v1.6.0 

func (a *RemoteAppender) Append(ref prom_storage.SeriesRef, l labels.Labels, timestamp int64, value float64) (prom_storage.SeriesRef, error)

func (*RemoteAppender) AppendExemplar added in v1.6.0 

func (a *RemoteAppender) AppendExemplar(ref prom_storage.SeriesRef, l labels.Labels, e exemplar.Exemplar) (prom_storage.SeriesRef, error)

func (*RemoteAppender) AppendHistogram added in v1.6.0 

func (a *RemoteAppender) AppendHistogram(ref prom_storage.SeriesRef, l labels.Labels, t int64, h *histogram.Histogram, fh *histogram.FloatHistogram) (prom_storage.SeriesRef, error)

func (*RemoteAppender) Commit 

func (a *RemoteAppender) Commit() error

func (*RemoteAppender) Rollback 

func (a *RemoteAppender) Rollback() error

func (*RemoteAppender) UpdateMetadata added in v1.6.0 

func (a *RemoteAppender) UpdateMetadata(ref prom_storage.SeriesRef, l labels.Labels, m metadata.Metadata) (prom_storage.SeriesRef, error)

type RemoteAppenderOption 

type RemoteAppenderOption func(*RemoteAppender)

func WithRemoteAppenderHandoffStoragePath 

func WithRemoteAppenderHandoffStoragePath(handoffStoragePath string) RemoteAppenderOption

func WithRemoteAppenderLogger 

func WithRemoteAppenderLogger(log *logger.Logger) RemoteAppenderOption

func WithRemoteAppenderMetrics 

func WithRemoteAppenderMetrics(metrics metrics.Registrar) RemoteAppenderOption

type RemoteQuerier 

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

func (*RemoteQuerier) Close 

func (r *RemoteQuerier) Close() error

func (*RemoteQuerier) LabelNames 

func (r *RemoteQuerier) LabelNames(matchers ...*labels.Matcher) ([]string, prom_storage.Warnings, error)

func (*RemoteQuerier) LabelValues 

func (r *RemoteQuerier) LabelValues(name string, matchers ...*labels.Matcher) ([]string,
	prom_storage.Warnings, error)

func (*RemoteQuerier) Select 

func (r *RemoteQuerier) Select(sortSeries bool, params *prom_storage.SelectHints, matchers ...*labels.Matcher) prom_storage.SeriesSet

type ReplicatedAppender 

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

func (*ReplicatedAppender) AddFast 

func (a *ReplicatedAppender) AddFast(_ uint64, _ int64, _ float64) error

func (*ReplicatedAppender) Append added in v1.6.0 

func (a *ReplicatedAppender) Append(ref prom_storage.SeriesRef, l labels.Labels, t int64, v float64) (prom_storage.SeriesRef, error)

func (*ReplicatedAppender) AppendExemplar added in v1.6.0 

func (a *ReplicatedAppender) AppendExemplar(ref prom_storage.SeriesRef, l labels.Labels, e exemplar.Exemplar) (prom_storage.SeriesRef, error)

func (*ReplicatedAppender) AppendHistogram added in v1.6.0 

func (a *ReplicatedAppender) AppendHistogram(ref prom_storage.SeriesRef, l labels.Labels, t int64, h *histogram.Histogram, fh *histogram.FloatHistogram) (prom_storage.SeriesRef, error)

func (*ReplicatedAppender) Commit 

func (a *ReplicatedAppender) Commit() error

func (*ReplicatedAppender) Rollback 

func (s *ReplicatedAppender) Rollback() error

func (*ReplicatedAppender) UpdateMetadata added in v1.6.0 

func (a *ReplicatedAppender) UpdateMetadata(ref prom_storage.SeriesRef, l labels.Labels, m metadata.Metadata) (prom_storage.SeriesRef, error)

type ReplicatedAppenderOption 

type ReplicatedAppenderOption func(*ReplicatedAppender)

func WithReplicatedAppenderLogger 

func WithReplicatedAppenderLogger(log *logger.Logger) ReplicatedAppenderOption

func WithReplicatedAppenderMetrics 

func WithReplicatedAppenderMetrics(metrics metrics.Registrar) ReplicatedAppenderOption

type ReplicatedOption 

type ReplicatedOption func(*ReplicatedStorage)

func WithReplicatedHandoffStoragePath 

func WithReplicatedHandoffStoragePath(handoffStoragePath string) ReplicatedOption

func WithReplicatedLogger 

func WithReplicatedLogger(log *logger.Logger) ReplicatedOption

func WithReplicatedMetrics 

func WithReplicatedMetrics(metrics metrics.Registrar) ReplicatedOption

type ReplicatedQuerier 

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

func NewReplicatedQuerier 

func NewReplicatedQuerier(ctx context.Context, localStore prom_storage.Storage, localIndex int, factory QuerierFactory,
	queryTimeout time.Duration, routingTable Routing, log *logger.Logger) *ReplicatedQuerier

func (*ReplicatedQuerier) Close 

func (r *ReplicatedQuerier) Close() error

func (*ReplicatedQuerier) LabelNames 

func (r *ReplicatedQuerier) LabelNames(matchers ...*labels.Matcher) ([]string,
	prom_storage.Warnings, error)

func (*ReplicatedQuerier) LabelValues 

func (r *ReplicatedQuerier) LabelValues(name string, matchers ...*labels.Matcher) ([]string,
	prom_storage.Warnings, error)

func (*ReplicatedQuerier) Select 

func (r *ReplicatedQuerier) Select(sortSeries bool, params *prom_storage.SelectHints, matchers ...*labels.Matcher) prom_storage.SeriesSet

type ReplicatedQuerierFactory 

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

func NewReplicatedQuerierFactory 

func NewReplicatedQuerierFactory(localStore prom_storage.Storage,
	localIndex int, nodeAddrs []string, egressTLSConfig *config_util.TLSConfig,
	log *logger.Logger) *ReplicatedQuerierFactory

func (*ReplicatedQuerierFactory) Build 

func (factory *ReplicatedQuerierFactory) Build(ctx context.Context, nodeIndexes ...int) []prom_storage.Querier

type ReplicatedStorage 

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

func (*ReplicatedStorage) Appender 

func (r *ReplicatedStorage) Appender(ctx context.Context) prom_storage.Appender

func (*ReplicatedStorage) ChunkQuerier added in v1.6.0 

func (r *ReplicatedStorage) ChunkQuerier(ctx context.Context, mint, maxt int64) (prom_storage.ChunkQuerier, error)

func (*ReplicatedStorage) Close 

func (r *ReplicatedStorage) Close() error

func (*ReplicatedStorage) Querier 

func (r *ReplicatedStorage) Querier(ctx context.Context, _, _ int64) (storage.Querier, error)

func (*ReplicatedStorage) StartTime 

func (r *ReplicatedStorage) StartTime() (int64, error)

type Routing 

type Routing interface {
	Lookup(item string) []int
	IsLocal(metricName string) bool
}

type ScrapeAppender 

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

func (*ScrapeAppender) Append added in v1.6.0 

func (s *ScrapeAppender) Append(ref prom_storage.SeriesRef, l labels.Labels, t int64, v float64) (prom_storage.SeriesRef, error)

func (*ScrapeAppender) AppendExemplar added in v1.6.0 

func (s *ScrapeAppender) AppendExemplar(ref prom_storage.SeriesRef, l labels.Labels, e exemplar.Exemplar) (prom_storage.SeriesRef, error)

func (*ScrapeAppender) AppendHistogram added in v1.6.0 

func (s *ScrapeAppender) AppendHistogram(ref prom_storage.SeriesRef, l labels.Labels, t int64, h *histogram.Histogram, fh *histogram.FloatHistogram) (prom_storage.SeriesRef, error)

func (*ScrapeAppender) Commit 

func (s *ScrapeAppender) Commit() error

func (*ScrapeAppender) Rollback 

func (s *ScrapeAppender) Rollback() error

func (*ScrapeAppender) UpdateMetadata added in v1.6.0 

func (s *ScrapeAppender) UpdateMetadata(ref prom_storage.SeriesRef, l labels.Labels, m metadata.Metadata) (prom_storage.SeriesRef, error)

type ScrapeStorage 

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

func (*ScrapeStorage) Appender 

func (s *ScrapeStorage) Appender(ctx context.Context) prom_storage.Appender

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.