app

Documentation

Index

• func NewApp(c *AppConfig, l log.Logger) (*app, error)
• type AppConfig
• type SeriesSetState
• type SeriesState
• type StateManager
  • func NewStateManager(name string, saveInterval time.Duration, logger log.Logger) (*StateManager, error)
  • func (sm *StateManager) Close()
  • func (sm *StateManager) GetTimestamp(labels prom_labels.Labels) int64
  • func (sm *StateManager) Start()
  • func (sm *StateManager) Update(labels prom_labels.Labels, ts int64)

Functions

func NewApp

func NewApp(c *AppConfig, l log.Logger) (*app, error)

Types

type AppConfig

type AppConfig struct {
	TsdbDir                string
	RemoteURL              *url.URL
	RemoteTimeout          time.Duration
	Concurrency            int
	QueueCapacity          int
	QueueMaxSamplesPerSend int
	QueueMaxRetries        int
	Backward               bool
	MinTime                int64
	MaxTime                int64
}

type SeriesSetState

type SeriesSetState []SeriesState

type SeriesState

type SeriesState struct {
	Labels    prom_labels.Labels
	Timestamp int64
}

type StateManager

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

func NewStateManager

func NewStateManager(name string, saveInterval time.Duration, logger log.Logger) (*StateManager, error)

func (*StateManager) Close

func (sm *StateManager) Close()

func (*StateManager) GetTimestamp

func (sm *StateManager) GetTimestamp(labels prom_labels.Labels) int64

func (*StateManager) Start

func (sm *StateManager) Start()

func (*StateManager) Update

func (sm *StateManager) Update(labels prom_labels.Labels, ts int64)