Documentation
¶
Index ¶
- type CacheFlusherMock
- type LargeSegmentStorageMock
- func (s *LargeSegmentStorageMock) ChangeNumber(name string) int64
- func (s *LargeSegmentStorageMock) Count() int
- func (s *LargeSegmentStorageMock) IsInLargeSegment(name string, key string) (bool, error)
- func (s *LargeSegmentStorageMock) LargeSegmentsForUser(userKey string) []string
- func (s *LargeSegmentStorageMock) SetChangeNumber(name string, till int64)
- func (s *LargeSegmentStorageMock) TotalKeys(name string) int
- func (s *LargeSegmentStorageMock) Update(name string, userKeys []string, till int64)
- type LargeSegmentUpdaterMock
- func (u *LargeSegmentUpdaterMock) IsCached(name string) bool
- func (u *LargeSegmentUpdaterMock) SynchronizeLargeSegment(name string, till *int64) (*int64, error)
- func (u *LargeSegmentUpdaterMock) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) (*int64, error)
- func (u *LargeSegmentUpdaterMock) SynchronizeLargeSegments() (map[string]*int64, error)
- type SegmentStorageMock
- func (s *SegmentStorageMock) ChangeNumber(segmentName string) (int64, error)
- func (*SegmentStorageMock) Keys(segmentName string) *set.ThreadUnsafeSet
- func (*SegmentStorageMock) SegmentContainsKey(segmentName string, key string) (bool, error)
- func (*SegmentStorageMock) SegmentKeysCount() int64
- func (*SegmentStorageMock) SetChangeNumber(segmentName string, till int64) error
- func (s *SegmentStorageMock) Update(name string, toAdd *set.ThreadUnsafeSet, toRemove *set.ThreadUnsafeSet, ...) error
- type SegmentUpdaterMock
- func (s *SegmentUpdaterMock) IsSegmentCached(segmentName string) bool
- func (s *SegmentUpdaterMock) SegmentNames() []interface{}
- func (s *SegmentUpdaterMock) SynchronizeSegment(name string, till *int64) (*segment.UpdateResult, error)
- func (s *SegmentUpdaterMock) SynchronizeSegments() (map[string]segment.UpdateResult, error)
- type SplitStorageMock
- func (s *SplitStorageMock) All() []dtos.SplitDTO
- func (s *SplitStorageMock) ChangeNumber() (int64, error)
- func (*SplitStorageMock) FetchMany(splitNames []string) map[string]*dtos.SplitDTO
- func (*SplitStorageMock) GetAllFlagSetNames() []string
- func (*SplitStorageMock) GetNamesByFlagSets(sets []string) map[string][]string
- func (*SplitStorageMock) KillLocally(splitName string, defaultTreatment string, changeNumber int64)
- func (s *SplitStorageMock) LargeSegmentNames() *set.ThreadUnsafeSet
- func (s *SplitStorageMock) SegmentNames() *set.ThreadUnsafeSet
- func (s *SplitStorageMock) SetChangeNumber(changeNumber int64) error
- func (*SplitStorageMock) Split(splitName string) *dtos.SplitDTO
- func (*SplitStorageMock) SplitNames() []string
- func (*SplitStorageMock) TrafficTypeExists(trafficType string) bool
- func (*SplitStorageMock) Update(toAdd []dtos.SplitDTO, toRemove []dtos.SplitDTO, changeNumber int64)
- type SplitUpdaterMock
- func (s *SplitUpdaterMock) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
- func (s *SplitUpdaterMock) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*split.UpdateResult, error)
- func (s *SplitUpdaterMock) SynchronizeSplits(till *int64) (*split.UpdateResult, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CacheFlusherMock ¶
func (*CacheFlusherMock) Evict ¶
func (c *CacheFlusherMock) Evict(key string)
func (*CacheFlusherMock) EvictAll ¶
func (c *CacheFlusherMock) EvictAll()
func (*CacheFlusherMock) EvictBySurrogate ¶
func (c *CacheFlusherMock) EvictBySurrogate(surrogate string)
type LargeSegmentStorageMock ¶
func (*LargeSegmentStorageMock) ChangeNumber ¶
func (s *LargeSegmentStorageMock) ChangeNumber(name string) int64
func (*LargeSegmentStorageMock) Count ¶
func (s *LargeSegmentStorageMock) Count() int
func (*LargeSegmentStorageMock) IsInLargeSegment ¶
func (s *LargeSegmentStorageMock) IsInLargeSegment(name string, key string) (bool, error)
func (*LargeSegmentStorageMock) LargeSegmentsForUser ¶
func (s *LargeSegmentStorageMock) LargeSegmentsForUser(userKey string) []string
func (*LargeSegmentStorageMock) SetChangeNumber ¶
func (s *LargeSegmentStorageMock) SetChangeNumber(name string, till int64)
func (*LargeSegmentStorageMock) TotalKeys ¶
func (s *LargeSegmentStorageMock) TotalKeys(name string) int
type LargeSegmentUpdaterMock ¶
func (*LargeSegmentUpdaterMock) IsCached ¶
func (u *LargeSegmentUpdaterMock) IsCached(name string) bool
func (*LargeSegmentUpdaterMock) SynchronizeLargeSegment ¶
func (u *LargeSegmentUpdaterMock) SynchronizeLargeSegment(name string, till *int64) (*int64, error)
func (*LargeSegmentUpdaterMock) SynchronizeLargeSegmentUpdate ¶
func (u *LargeSegmentUpdaterMock) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) (*int64, error)
func (*LargeSegmentUpdaterMock) SynchronizeLargeSegments ¶
func (u *LargeSegmentUpdaterMock) SynchronizeLargeSegments() (map[string]*int64, error)
type SegmentStorageMock ¶
func (*SegmentStorageMock) ChangeNumber ¶
func (s *SegmentStorageMock) ChangeNumber(segmentName string) (int64, error)
ChangeNumber implements storage.SegmentStorage
func (*SegmentStorageMock) Keys ¶
func (*SegmentStorageMock) Keys(segmentName string) *set.ThreadUnsafeSet
func (*SegmentStorageMock) SegmentContainsKey ¶
func (*SegmentStorageMock) SegmentContainsKey(segmentName string, key string) (bool, error)
func (*SegmentStorageMock) SegmentKeysCount ¶
func (*SegmentStorageMock) SegmentKeysCount() int64
func (*SegmentStorageMock) SetChangeNumber ¶
func (*SegmentStorageMock) SetChangeNumber(segmentName string, till int64) error
func (*SegmentStorageMock) Update ¶
func (s *SegmentStorageMock) Update(name string, toAdd *set.ThreadUnsafeSet, toRemove *set.ThreadUnsafeSet, changeNumber int64) error
type SegmentUpdaterMock ¶
func (*SegmentUpdaterMock) IsSegmentCached ¶
func (s *SegmentUpdaterMock) IsSegmentCached(segmentName string) bool
func (*SegmentUpdaterMock) SegmentNames ¶
func (s *SegmentUpdaterMock) SegmentNames() []interface{}
func (*SegmentUpdaterMock) SynchronizeSegment ¶
func (s *SegmentUpdaterMock) SynchronizeSegment(name string, till *int64) (*segment.UpdateResult, error)
func (*SegmentUpdaterMock) SynchronizeSegments ¶
func (s *SegmentUpdaterMock) SynchronizeSegments() (map[string]segment.UpdateResult, error)
type SplitStorageMock ¶
func (*SplitStorageMock) All ¶
func (s *SplitStorageMock) All() []dtos.SplitDTO
func (*SplitStorageMock) ChangeNumber ¶
func (s *SplitStorageMock) ChangeNumber() (int64, error)
func (*SplitStorageMock) FetchMany ¶
func (*SplitStorageMock) FetchMany(splitNames []string) map[string]*dtos.SplitDTO
func (*SplitStorageMock) GetAllFlagSetNames ¶
func (*SplitStorageMock) GetAllFlagSetNames() []string
func (*SplitStorageMock) GetNamesByFlagSets ¶
func (*SplitStorageMock) GetNamesByFlagSets(sets []string) map[string][]string
func (*SplitStorageMock) KillLocally ¶
func (*SplitStorageMock) KillLocally(splitName string, defaultTreatment string, changeNumber int64)
func (*SplitStorageMock) LargeSegmentNames ¶
func (s *SplitStorageMock) LargeSegmentNames() *set.ThreadUnsafeSet
func (*SplitStorageMock) SegmentNames ¶
func (s *SplitStorageMock) SegmentNames() *set.ThreadUnsafeSet
func (*SplitStorageMock) SetChangeNumber ¶
func (s *SplitStorageMock) SetChangeNumber(changeNumber int64) error
func (*SplitStorageMock) SplitNames ¶
func (*SplitStorageMock) SplitNames() []string
func (*SplitStorageMock) TrafficTypeExists ¶
func (*SplitStorageMock) TrafficTypeExists(trafficType string) bool
type SplitUpdaterMock ¶
func (*SplitUpdaterMock) LocalKill ¶
func (s *SplitUpdaterMock) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
LocalKill implements split.Updater
func (*SplitUpdaterMock) SynchronizeFeatureFlags ¶
func (s *SplitUpdaterMock) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*split.UpdateResult, error)
SynchronizeFeatureFlags implements split.Updater
func (*SplitUpdaterMock) SynchronizeSplits ¶
func (s *SplitUpdaterMock) SynchronizeSplits(till *int64) (*split.UpdateResult, error)
SynchronizeSplits implements split.Updater
Click to show internal directories.
Click to hide internal directories.