mocks

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
  • func (m MockManager) IsRunning() bool
  • func (m MockManager) Start() error
  • func (m MockManager) StartWorkers()
  • func (m MockManager) Stop() error
  • func (m MockManager) StopWorkers()
• type NotificationParserMock
  • func (n *NotificationParserMock) ParseAndForward(m sse.IncomingMessage) (*int64, error)

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

func (MockManager) IsRunning

func (m MockManager) IsRunning() bool

IsRunning mock

func (MockManager) Start

func (m MockManager) Start() error

Start mock

func (MockManager) StartWorkers

func (m MockManager) StartWorkers()

StartWorkers mock

func (MockManager) Stop

func (m MockManager) Stop() error

Stop mock

func (MockManager) StopWorkers

func (m MockManager) StopWorkers()

StopWorkers mock

type NotificationParserMock

type NotificationParserMock struct {
	ParseAndForwardCall func(m sse.IncomingMessage) (*int64, error)
}

func (*NotificationParserMock) ParseAndForward

func (n *NotificationParserMock) ParseAndForward(m sse.IncomingMessage) (*int64, error)