Documentation
¶
Index ¶
- type EventRecorderMock
- type ImpressionRecorderMock
- 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 MockSynchronizer
- func (m *MockSynchronizer) LocalKill(name string, treatment string, cn int64)
- func (m *MockSynchronizer) RefreshRates() (time.Duration, time.Duration)
- func (m *MockSynchronizer) StartPeriodicDataRecording()
- func (m *MockSynchronizer) StartPeriodicFetching()
- func (m *MockSynchronizer) StopPeriodicDataRecording()
- func (m *MockSynchronizer) StopPeriodicFetching()
- func (m *MockSynchronizer) SyncAll() error
- func (m *MockSynchronizer) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) error
- func (m *MockSynchronizer) SynchronizeLargeSegment(name string, till *int64) error
- func (m *MockSynchronizer) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error
- func (m *MockSynchronizer) SynchronizeSegment(segmentName string, till *int64) error
- type SegmentUpdaterMock
- func (u *SegmentUpdaterMock) IsSegmentCached(segmentName string) bool
- func (u *SegmentUpdaterMock) SegmentNames() []interface{}
- func (u *SegmentUpdaterMock) SynchronizeSegment(name string, till *int64) (*segment.UpdateResult, error)
- func (u *SegmentUpdaterMock) SynchronizeSegments() (map[string]segment.UpdateResult, error)
- type SplitUpdaterMock
- func (u *SplitUpdaterMock) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
- func (u *SplitUpdaterMock) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*split.UpdateResult, error)
- func (u *SplitUpdaterMock) SynchronizeSplits(till *int64) (*split.UpdateResult, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventRecorderMock ¶
func (*EventRecorderMock) FlushEvents ¶
func (e *EventRecorderMock) FlushEvents(bulkSize int64) error
func (*EventRecorderMock) SynchronizeEvents ¶
func (e *EventRecorderMock) SynchronizeEvents(bulkSize int64) error
type ImpressionRecorderMock ¶
func (*ImpressionRecorderMock) FlushImpressions ¶
func (r *ImpressionRecorderMock) FlushImpressions(bulkSize int64) error
func (*ImpressionRecorderMock) SynchronizeImpressions ¶
func (r *ImpressionRecorderMock) SynchronizeImpressions(bulkSize int64) error
type LargeSegmentUpdaterMock ¶
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 MockSynchronizer ¶
type MockSynchronizer struct {
SyncAllCall func() error
SynchronizeFeatureFlagsCall func(ffChange *dtos.SplitChangeUpdate) error
SynchronizeSegmentCall func(segmentName string, till *int64) error
StartPeriodicFetchingCall func()
StopPeriodicFetchingCall func()
StartPeriodicDataRecordingCall func()
StopPeriodicDataRecordingCall func()
LocalKillCall func(string, string, int64)
RefreshRatesCall func() (time.Duration, time.Duration)
SynchronizeLargeSegmentCall func(name string, till *int64) error
SynchronizeLargeSegmentUpdateCall func(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error
}
MockSynchronizer mock implementation
func (*MockSynchronizer) LocalKill ¶
func (m *MockSynchronizer) LocalKill(name string, treatment string, cn int64)
LocalKill mock
func (*MockSynchronizer) RefreshRates ¶
func (m *MockSynchronizer) RefreshRates() (time.Duration, time.Duration)
RefreshRates call
func (*MockSynchronizer) StartPeriodicDataRecording ¶
func (m *MockSynchronizer) StartPeriodicDataRecording()
StartPeriodicDataRecording mock
func (*MockSynchronizer) StartPeriodicFetching ¶
func (m *MockSynchronizer) StartPeriodicFetching()
StartPeriodicFetching mock
func (*MockSynchronizer) StopPeriodicDataRecording ¶
func (m *MockSynchronizer) StopPeriodicDataRecording()
StopPeriodicDataRecording mock
func (*MockSynchronizer) StopPeriodicFetching ¶
func (m *MockSynchronizer) StopPeriodicFetching()
StopPeriodicFetching mock
func (*MockSynchronizer) SynchronizeFeatureFlags ¶
func (m *MockSynchronizer) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) error
RefreshRates call
func (*MockSynchronizer) SynchronizeLargeSegment ¶
func (m *MockSynchronizer) SynchronizeLargeSegment(name string, till *int64) error
SynchronizeSegment mock
func (*MockSynchronizer) SynchronizeLargeSegmentUpdate ¶
func (m *MockSynchronizer) SynchronizeLargeSegmentUpdate(lsRFDResponseDTO *dtos.LargeSegmentRFDResponseDTO) error
SynchronizeLargeSegmentUpdate call
func (*MockSynchronizer) SynchronizeSegment ¶
func (m *MockSynchronizer) SynchronizeSegment(segmentName string, till *int64) error
SynchronizeSegment mock
type SegmentUpdaterMock ¶
Segment Updater
func (*SegmentUpdaterMock) IsSegmentCached ¶
func (u *SegmentUpdaterMock) IsSegmentCached(segmentName string) bool
func (*SegmentUpdaterMock) SegmentNames ¶
func (u *SegmentUpdaterMock) SegmentNames() []interface{}
func (*SegmentUpdaterMock) SynchronizeSegment ¶
func (u *SegmentUpdaterMock) SynchronizeSegment(name string, till *int64) (*segment.UpdateResult, error)
func (*SegmentUpdaterMock) SynchronizeSegments ¶
func (u *SegmentUpdaterMock) SynchronizeSegments() (map[string]segment.UpdateResult, error)
type SplitUpdaterMock ¶
SplitUpdaterMock
func (*SplitUpdaterMock) LocalKill ¶
func (u *SplitUpdaterMock) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
func (*SplitUpdaterMock) SynchronizeFeatureFlags ¶
func (u *SplitUpdaterMock) SynchronizeFeatureFlags(ffChange *dtos.SplitChangeUpdate) (*split.UpdateResult, error)
func (*SplitUpdaterMock) SynchronizeSplits ¶
func (u *SplitUpdaterMock) SynchronizeSplits(till *int64) (*split.UpdateResult, error)
Click to show internal directories.
Click to hide internal directories.