Documentation
¶
Index ¶
- type LocalSyncMock
- func (l *LocalSyncMock) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
- func (l *LocalSyncMock) StartPeriodicDataRecording()
- func (l *LocalSyncMock) StartPeriodicFetching()
- func (l *LocalSyncMock) StopPeriodicDataRecording()
- func (l *LocalSyncMock) StopPeriodicFetching()
- func (l *LocalSyncMock) SyncAll() error
- func (l *LocalSyncMock) SynchronizeSegment(segmentName string, till *int64) error
- func (l *LocalSyncMock) SynchronizeSplits(till *int64) error
- type MockManager
- type NotificationParserMock
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LocalSyncMock ¶
type LocalSyncMock struct {
SyncAllCall func() error
SynchronizeSplitsCall func(till *int64) error
LocalKillCall func(splitName string, defaultTreatment string, changeNumber int64)
SynchronizeSegmentCall func(segmentName string, till *int64) error
StartPeriodicFetchingCall func()
StopPeriodicFetchingCall func()
StartPeriodicDataRecordingCall func()
StopPeriodicDataRecordingCall func()
}
func (*LocalSyncMock) LocalKill ¶
func (l *LocalSyncMock) LocalKill(splitName string, defaultTreatment string, changeNumber int64)
func (*LocalSyncMock) StartPeriodicDataRecording ¶
func (l *LocalSyncMock) StartPeriodicDataRecording()
func (*LocalSyncMock) StartPeriodicFetching ¶
func (l *LocalSyncMock) StartPeriodicFetching()
func (*LocalSyncMock) StopPeriodicDataRecording ¶
func (l *LocalSyncMock) StopPeriodicDataRecording()
func (*LocalSyncMock) StopPeriodicFetching ¶
func (l *LocalSyncMock) StopPeriodicFetching()
func (*LocalSyncMock) SyncAll ¶
func (l *LocalSyncMock) SyncAll() error
func (*LocalSyncMock) SynchronizeSegment ¶
func (l *LocalSyncMock) SynchronizeSegment(segmentName string, till *int64) error
func (*LocalSyncMock) SynchronizeSplits ¶
func (l *LocalSyncMock) SynchronizeSplits(till *int64) error
type MockManager ¶
type MockManager struct {
StartCall func() error
StopCall func() error
StartWorkersCall func()
StopWorkersCall func()
IsRunningCall func() bool
NextRefreshCall func() time.Time
}
MockManager mocking struct for push
func (MockManager) NextRefresh ¶ added in v4.0.2
func (m MockManager) NextRefresh() time.Time
NextRefresh call
type NotificationParserMock ¶
type NotificationParserMock struct {
ParseAndForwardCall func(m sse.IncomingMessage) (*int64, error)
}
func (*NotificationParserMock) ParseAndForward ¶
func (n *NotificationParserMock) ParseAndForward(m sse.IncomingMessage) (*int64, error)
Click to show internal directories.
Click to hide internal directories.