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(requestNoCache bool) error
- func (l *LocalSyncMock) SynchronizeSegment(segmentName string, till *int64, requestNoCache bool) error
- func (l *LocalSyncMock) SynchronizeSplits(till *int64, requestNoCache bool) 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(requestNoCache bool) error
SynchronizeSplitsCall func(till *int64, requestNoCache bool) error
LocalKillCall func(splitName string, defaultTreatment string, changeNumber int64)
SynchronizeSegmentCall func(segmentName string, till *int64, requestNoCache bool) 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(requestNoCache bool) error
func (*LocalSyncMock) SynchronizeSegment ¶
func (l *LocalSyncMock) SynchronizeSegment(segmentName string, till *int64, requestNoCache bool) error
func (*LocalSyncMock) SynchronizeSplits ¶
func (l *LocalSyncMock) SynchronizeSplits(till *int64, requestNoCache bool) error
type MockManager ¶
type MockManager struct {
StartCall func() error
StopCall func() error
StartWorkersCall func()
StopWorkersCall func()
IsRunningCall func() bool
}
MockManager mocking struct for push
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.