v3

Documentation

Index

• func NewRedisCache(client redis.Client) cache.MultiGetDeleteCountCache
• type AutoOpsRulesCache
  • func NewAutoOpsRulesCache(c cache.MultiGetCache) AutoOpsRulesCache
• type EnvironmentAPIKeyCache
  • func NewEnvironmentAPIKeyCache(c cache.Cache) EnvironmentAPIKeyCache
• type EventCounterCache
  • func NewEventCountCache(c cache.MultiGetDeleteCountCache) EventCounterCache
• type ExperimentsCache
  • func NewExperimentsCache(c cache.MultiGetCache) ExperimentsCache
• type FeaturesCache
  • func NewFeaturesCache(c cache.MultiGetCache) FeaturesCache
• type InMemoryCache
  • func NewInMemoryCache(opts ...InMemoryCacheOption) *InMemoryCache
  • func (c *InMemoryCache) Destroy()
  • func (c *InMemoryCache) Get(key interface{}) (interface{}, error)
  • func (c *InMemoryCache) Put(key, value interface{}, expiration time.Duration) error
• type InMemoryCacheOption
  • func WithEvictionInterval(evictionInterval time.Duration) InMemoryCacheOption
• type SegmentUsersCache
  • func NewSegmentUsersCache(c cache.MultiGetCache) SegmentUsersCache

Functions

func NewRedisCache

func NewRedisCache(client redis.Client) cache.MultiGetDeleteCountCache

Types

type AutoOpsRulesCache

type AutoOpsRulesCache interface {
	Get(environmentId string) (*aoproto.AutoOpsRules, error)
	Put(autoOps *aoproto.AutoOpsRules, environmentId string) error
}

func NewAutoOpsRulesCache

func NewAutoOpsRulesCache(c cache.MultiGetCache) AutoOpsRulesCache

type EnvironmentAPIKeyCache

type EnvironmentAPIKeyCache interface {
	Get(string) (*accountproto.EnvironmentAPIKey, error)
	Put(*accountproto.EnvironmentAPIKey) error
}

func NewEnvironmentAPIKeyCache

func NewEnvironmentAPIKeyCache(c cache.Cache) EnvironmentAPIKeyCache

type EventCounterCache

type EventCounterCache interface {
	GetEventCounts(keys []string) ([]float64, error)
	GetEventCountsV2(keys [][]string) ([]float64, error)
	GetUserCount(key string) (int64, error)
	GetUserCounts(keys []string) ([]float64, error)
	GetUserCountsV2(keys []string) ([]float64, error)
	MergeMultiKeys(dest string, keys []string, expiration time.Duration) error
	DeleteKey(key string) error
	UpdateUserCount(key, userID string) error
}

func NewEventCountCache

func NewEventCountCache(c cache.MultiGetDeleteCountCache) EventCounterCache

type ExperimentsCache

type ExperimentsCache interface {
	Get(environmentId string) (*exproto.Experiments, error)
	Put(experiments *exproto.Experiments, environmentId string) error
}

func NewExperimentsCache

func NewExperimentsCache(c cache.MultiGetCache) ExperimentsCache

type FeaturesCache

type FeaturesCache interface {
	Get(environmentId string) (*featureproto.Features, error)
	Put(features *featureproto.Features, environmentId string) error
}

func NewFeaturesCache

func NewFeaturesCache(c cache.MultiGetCache) FeaturesCache

type InMemoryCache

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

func NewInMemoryCache

func NewInMemoryCache(opts ...InMemoryCacheOption) *InMemoryCache

func (*InMemoryCache) Destroy

func (c *InMemoryCache) Destroy()

func (*InMemoryCache) Get

func (c *InMemoryCache) Get(key interface{}) (interface{}, error)

func (*InMemoryCache) Put

func (c *InMemoryCache) Put(key, value interface{}, expiration time.Duration) error

type InMemoryCacheOption

type InMemoryCacheOption func(*InMemoryCache)

func WithEvictionInterval

func WithEvictionInterval(evictionInterval time.Duration) InMemoryCacheOption

type SegmentUsersCache

type SegmentUsersCache interface {
	Get(segmentID, environmentId string) (*featureproto.SegmentUsers, error)
	GetAll(environmentId string) ([]*featureproto.SegmentUsers, error)
	Put(segmentUsers *featureproto.SegmentUsers, environmentId string) error
}

func NewSegmentUsersCache

func NewSegmentUsersCache(c cache.MultiGetCache) SegmentUsersCache