cache

Documentation

Index

• type CacheMeter
  • func (m *CacheMeter) GetValue(meterName string, startTime time.Time, endTime time.Time, ...) (float64, bool)
• type CacheMeterData
• type CacheMeterKey
  • func (c CacheMeterKey) String() string
• type CacheMeterProvider
  • func NewCacheMeterProvider(provider meters.MeterProvider, topic string, redisClient *redis.Client, ...) *CacheMeterProvider
  • func (m *CacheMeterProvider) GetValue(user meters.MeterUser, meterName string, startTime time.Time, ...) (float64, bool)
  • func (c *CacheMeterProvider) NewMeter(u meters.MeterUser) meters.ApiMeter

Types

type CacheMeter

type CacheMeter struct {
	meters.ApiMeter
	// contains filtered or unexported fields
}

func (*CacheMeter) GetValue

func (m *CacheMeter) GetValue(meterName string, startTime time.Time, endTime time.Time, dims meters.Dimensions) (float64, bool)

type CacheMeterData

type CacheMeterData struct {
	Value float64
}

A simple value

type CacheMeterKey

type CacheMeterKey struct {
	User      string
	MeterName string
	Start     int64
	End       int64
	Dims      string
}

CacheMeterKey should map to GetValue arguments

func (CacheMeterKey) String

func (c CacheMeterKey) String() string

type CacheMeterProvider

type CacheMeterProvider struct {
	meters.MeterProvider
	// contains filtered or unexported fields
}

Wraps a meter with caching

func NewCacheMeterProvider

func NewCacheMeterProvider(provider meters.MeterProvider, topic string, redisClient *redis.Client, recheck time.Duration, expires time.Duration, refresh time.Duration) *CacheMeterProvider

func (*CacheMeterProvider) GetValue

func (m *CacheMeterProvider) GetValue(user meters.MeterUser, meterName string, startTime time.Time, endTime time.Time, dims meters.Dimensions) (float64, bool)

func (*CacheMeterProvider) NewMeter

func (c *CacheMeterProvider) NewMeter(u meters.MeterUser) meters.ApiMeter