sources

Documentation

Index

• type CachedSources
  • func NewCachedSources(defaultExpration, cleanupInterval time.Duration) *CachedSources
  • func (cs *CachedSources) GetSource(reference string) (evalexpr.Source, error)
  • func (cs *CachedSources) SetSource(reference string, source evalexpr.Source, expirationPeriod time.Duration) error
  • func (cs *CachedSources) SetValue(reference string, value interface{}) error
• type MemorySource
  • func NewMemorySource(value interface{}) *MemorySource
  • func (ms *MemorySource) GetValue() (interface{}, error)
• type MemorySources
  • func NewMemorySources() *MemorySources
  • func (ms *MemorySources) GetSource(reference string) (evalexpr.Source, error)
  • func (ms *MemorySources) SetSource(reference string, source evalexpr.Source) error
  • func (ms *MemorySources) SetValue(reference string, value interface{}) error
• type PrometheusSource
  • func NewPrometheusSource(address, query string) *PrometheusSource
  • func (ps *PrometheusSource) GetValue() (interface{}, error)

Types

type CachedSources

type CachedSources struct {
	Cache *cache.Cache
}

func NewCachedSources

func NewCachedSources(defaultExpration, cleanupInterval time.Duration) *CachedSources

func (*CachedSources) GetSource

func (cs *CachedSources) GetSource(reference string) (evalexpr.Source, error)

func (*CachedSources) SetSource

func (cs *CachedSources) SetSource(reference string, source evalexpr.Source, expirationPeriod time.Duration) error

func (*CachedSources) SetValue

func (cs *CachedSources) SetValue(reference string, value interface{}) error

type MemorySource

type MemorySource struct {
	Value interface{}
}

func NewMemorySource

func NewMemorySource(value interface{}) *MemorySource

func (*MemorySource) GetValue

func (ms *MemorySource) GetValue() (interface{}, error)

type MemorySources

type MemorySources struct {
	SourceMap map[string]evalexpr.Source
}

func NewMemorySources

func NewMemorySources() *MemorySources

func (*MemorySources) GetSource

func (ms *MemorySources) GetSource(reference string) (evalexpr.Source, error)

func (*MemorySources) SetSource

func (ms *MemorySources) SetSource(reference string, source evalexpr.Source) error

func (*MemorySources) SetValue

func (ms *MemorySources) SetValue(reference string, value interface{}) error

type PrometheusSource

type PrometheusSource struct {
	Address string
	Query   string
}

func NewPrometheusSource

func NewPrometheusSource(address, query string) *PrometheusSource

func (*PrometheusSource) GetValue

func (ps *PrometheusSource) GetValue() (interface{}, error)