optimized

Documentation

Index

• type FeatureView
  • func (f *FeatureView) FlagSetNames() []string
• type FlagSetView
• type HistoricChanges
• type HistoricChangesImpl
  • func NewHistoricSplitChanges(capacity int) *HistoricChangesImpl
  • func (h *HistoricChangesImpl) GetUpdatedSince(since int64, flagSets []string) []FeatureView
  • func (h *HistoricChangesImpl) Update(toAdd []dtos.SplitDTO, toRemove []dtos.SplitDTO, newCN int64)
• type MySegmentsCache
• type MySegmentsCacheImpl
  • func NewMySegmentsCache() *MySegmentsCacheImpl
  • func (m *MySegmentsCacheImpl) KeyCount() int
  • func (m *MySegmentsCacheImpl) SegmentsForUser(key string) []string
  • func (m *MySegmentsCacheImpl) Update(name string, toAdd *set.ThreadUnsafeSet, toRemove *set.ThreadUnsafeSet) error

Types

type FeatureView

type FeatureView struct {
	Name            string
	Active          bool
	LastUpdated     int64
	TrafficTypeName string
	FlagSets        []FlagSetView
}

func (*FeatureView) FlagSetNames

func (f *FeatureView) FlagSetNames() []string

type FlagSetView

type FlagSetView struct {
	Name        string
	Active      bool
	LastUpdated int64
}

type HistoricChanges

type HistoricChanges interface {
	GetUpdatedSince(since int64, flagSets []string) []FeatureView
	Update(toAdd []dtos.SplitDTO, toRemove []dtos.SplitDTO, newCN int64)
}

type HistoricChangesImpl

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

func NewHistoricSplitChanges

func NewHistoricSplitChanges(capacity int) *HistoricChangesImpl

func (*HistoricChangesImpl) GetUpdatedSince

func (h *HistoricChangesImpl) GetUpdatedSince(since int64, flagSets []string) []FeatureView

func (*HistoricChangesImpl) Update

func (h *HistoricChangesImpl) Update(toAdd []dtos.SplitDTO, toRemove []dtos.SplitDTO, newCN int64)

type MySegmentsCache

type MySegmentsCache interface {
	Update(name string, toAdd *set.ThreadUnsafeSet, toRemove *set.ThreadUnsafeSet) error
	SegmentsForUser(key string) []string
	KeyCount() int
}

MySegmentsCache defines the interface for a per-user optimized segment storage

type MySegmentsCacheImpl

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

MySegmentsCacheImpl implements the MySegmentsCache interface

func NewMySegmentsCache

func NewMySegmentsCache() *MySegmentsCacheImpl

NewMySegmentsCache constructs a new MySegments cache

func (*MySegmentsCacheImpl) KeyCount

func (m *MySegmentsCacheImpl) KeyCount() int

KeyCount retuns the amount of keys who belong to at least one segment

func (*MySegmentsCacheImpl) SegmentsForUser

func (m *MySegmentsCacheImpl) SegmentsForUser(key string) []string

SegmentsForUser returns the list of segments a certain user belongs to

func (*MySegmentsCacheImpl) Update

func (m *MySegmentsCacheImpl) Update(name string, toAdd *set.ThreadUnsafeSet, toRemove *set.ThreadUnsafeSet) error

Update adds and removes segments to keys