mocks

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broadcaster 

type Broadcaster struct {
	mock.Mock
}

Broadcaster is an autogenerated mock type for the Broadcaster type

func NewBroadcaster 

func NewBroadcaster(t interface {
	mock.TestingT
	Cleanup(func())
}) *Broadcaster

NewBroadcaster creates a new instance of Broadcaster. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Broadcaster) Broadcast 

func (_mock *Broadcaster) Broadcast(ctxt context.Context, message interface{}) error

Broadcast provides a mock function for the type Broadcaster

func (*Broadcaster) EXPECT 

func (_m *Broadcaster) EXPECT() *Broadcaster_Expecter

type Broadcaster_Broadcast_Call 

type Broadcaster_Broadcast_Call struct {
	*mock.Call
}

Broadcaster_Broadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Broadcast'

func (*Broadcaster_Broadcast_Call) Return 

func (_c *Broadcaster_Broadcast_Call) Return(err error) *Broadcaster_Broadcast_Call

func (*Broadcaster_Broadcast_Call) Run 

func (_c *Broadcaster_Broadcast_Call) Run(run func(ctxt context.Context, message interface{})) *Broadcaster_Broadcast_Call

func (*Broadcaster_Broadcast_Call) RunAndReturn 

func (_c *Broadcaster_Broadcast_Call) RunAndReturn(run func(ctxt context.Context, message interface{}) error) *Broadcaster_Broadcast_Call

type Broadcaster_Expecter 

type Broadcaster_Expecter struct {
	// contains filtered or unexported fields
}

func (*Broadcaster_Expecter) Broadcast 

func (_e *Broadcaster_Expecter) Broadcast(ctxt interface{}, message interface{}) *Broadcaster_Broadcast_Call

Broadcast is a helper method to define mock.On call

  • ctxt context.Context
  • message interface{}

type ConnectionManager 

type ConnectionManager struct {
	mock.Mock
}

ConnectionManager is an autogenerated mock type for the ConnectionManager type

func NewConnectionManager 

func NewConnectionManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectionManager

NewConnectionManager creates a new instance of ConnectionManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectionManager) ApplySQLitePragmas added in v0.3.2 

func (_mock *ConnectionManager) ApplySQLitePragmas(config common.SqliteConfig) error

ApplySQLitePragmas provides a mock function for the type ConnectionManager

func (*ConnectionManager) Commit 

func (_mock *ConnectionManager) Commit(session *gorm.DB)

Commit provides a mock function for the type ConnectionManager

func (*ConnectionManager) EXPECT 

func (_m *ConnectionManager) EXPECT() *ConnectionManager_Expecter

func (*ConnectionManager) NewPersistanceManager 

func (_mock *ConnectionManager) NewPersistanceManager() db.PersistenceManager

NewPersistanceManager provides a mock function for the type ConnectionManager

func (*ConnectionManager) NewTransaction 

func (_mock *ConnectionManager) NewTransaction() *gorm.DB

NewTransaction provides a mock function for the type ConnectionManager

func (*ConnectionManager) Rollback 

func (_mock *ConnectionManager) Rollback(session *gorm.DB)

Rollback provides a mock function for the type ConnectionManager

type ConnectionManager_ApplySQLitePragmas_Call added in v0.3.2 

type ConnectionManager_ApplySQLitePragmas_Call struct {
	*mock.Call
}

ConnectionManager_ApplySQLitePragmas_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ApplySQLitePragmas'

func (*ConnectionManager_ApplySQLitePragmas_Call) Return added in v0.3.2 

func (_c *ConnectionManager_ApplySQLitePragmas_Call) Return(err error) *ConnectionManager_ApplySQLitePragmas_Call

func (*ConnectionManager_ApplySQLitePragmas_Call) Run added in v0.3.2 

func (_c *ConnectionManager_ApplySQLitePragmas_Call) Run(run func(config common.SqliteConfig)) *ConnectionManager_ApplySQLitePragmas_Call

func (*ConnectionManager_ApplySQLitePragmas_Call) RunAndReturn added in v0.3.2 

func (_c *ConnectionManager_ApplySQLitePragmas_Call) RunAndReturn(run func(config common.SqliteConfig) error) *ConnectionManager_ApplySQLitePragmas_Call

type ConnectionManager_Commit_Call 

type ConnectionManager_Commit_Call struct {
	*mock.Call
}

ConnectionManager_Commit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Commit'

func (*ConnectionManager_Commit_Call) Return 

func (_c *ConnectionManager_Commit_Call) Return() *ConnectionManager_Commit_Call

func (*ConnectionManager_Commit_Call) Run 

func (_c *ConnectionManager_Commit_Call) Run(run func(session *gorm.DB)) *ConnectionManager_Commit_Call

func (*ConnectionManager_Commit_Call) RunAndReturn 

func (_c *ConnectionManager_Commit_Call) RunAndReturn(run func(session *gorm.DB)) *ConnectionManager_Commit_Call

type ConnectionManager_Expecter 

type ConnectionManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*ConnectionManager_Expecter) ApplySQLitePragmas added in v0.3.2 

func (_e *ConnectionManager_Expecter) ApplySQLitePragmas(config interface{}) *ConnectionManager_ApplySQLitePragmas_Call

ApplySQLitePragmas is a helper method to define mock.On call

  • config common.SqliteConfig

func (*ConnectionManager_Expecter) Commit 

func (_e *ConnectionManager_Expecter) Commit(session interface{}) *ConnectionManager_Commit_Call

Commit is a helper method to define mock.On call

  • session *gorm.DB

func (*ConnectionManager_Expecter) NewPersistanceManager 

func (_e *ConnectionManager_Expecter) NewPersistanceManager() *ConnectionManager_NewPersistanceManager_Call

NewPersistanceManager is a helper method to define mock.On call

func (*ConnectionManager_Expecter) NewTransaction 

func (_e *ConnectionManager_Expecter) NewTransaction() *ConnectionManager_NewTransaction_Call

NewTransaction is a helper method to define mock.On call

func (*ConnectionManager_Expecter) Rollback 

func (_e *ConnectionManager_Expecter) Rollback(session interface{}) *ConnectionManager_Rollback_Call

Rollback is a helper method to define mock.On call

  • session *gorm.DB

type ConnectionManager_NewPersistanceManager_Call 

type ConnectionManager_NewPersistanceManager_Call struct {
	*mock.Call
}

ConnectionManager_NewPersistanceManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewPersistanceManager'

func (*ConnectionManager_NewPersistanceManager_Call) Return 

func (_c *ConnectionManager_NewPersistanceManager_Call) Return(persistenceManager db.PersistenceManager) *ConnectionManager_NewPersistanceManager_Call

func (*ConnectionManager_NewPersistanceManager_Call) Run 

func (_c *ConnectionManager_NewPersistanceManager_Call) Run(run func()) *ConnectionManager_NewPersistanceManager_Call

func (*ConnectionManager_NewPersistanceManager_Call) RunAndReturn 

func (_c *ConnectionManager_NewPersistanceManager_Call) RunAndReturn(run func() db.PersistenceManager) *ConnectionManager_NewPersistanceManager_Call

type ConnectionManager_NewTransaction_Call 

type ConnectionManager_NewTransaction_Call struct {
	*mock.Call
}

ConnectionManager_NewTransaction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewTransaction'

func (*ConnectionManager_NewTransaction_Call) Return 

func (_c *ConnectionManager_NewTransaction_Call) Return(dB *gorm.DB) *ConnectionManager_NewTransaction_Call

func (*ConnectionManager_NewTransaction_Call) Run 

func (_c *ConnectionManager_NewTransaction_Call) Run(run func()) *ConnectionManager_NewTransaction_Call

func (*ConnectionManager_NewTransaction_Call) RunAndReturn 

func (_c *ConnectionManager_NewTransaction_Call) RunAndReturn(run func() *gorm.DB) *ConnectionManager_NewTransaction_Call

type ConnectionManager_Rollback_Call 

type ConnectionManager_Rollback_Call struct {
	*mock.Call
}

ConnectionManager_Rollback_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Rollback'

func (*ConnectionManager_Rollback_Call) Return 

func (_c *ConnectionManager_Rollback_Call) Return() *ConnectionManager_Rollback_Call

func (*ConnectionManager_Rollback_Call) Run 

func (_c *ConnectionManager_Rollback_Call) Run(run func(session *gorm.DB)) *ConnectionManager_Rollback_Call

func (*ConnectionManager_Rollback_Call) RunAndReturn 

func (_c *ConnectionManager_Rollback_Call) RunAndReturn(run func(session *gorm.DB)) *ConnectionManager_Rollback_Call

type ControlRequestClient 

type ControlRequestClient struct {
	mock.Mock
}

ControlRequestClient is an autogenerated mock type for the ControlRequestClient type

func NewControlRequestClient 

func NewControlRequestClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *ControlRequestClient

NewControlRequestClient creates a new instance of ControlRequestClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ControlRequestClient) EXPECT 

func (_m *ControlRequestClient) EXPECT() *ControlRequestClient_Expecter

func (*ControlRequestClient) ExchangeVideoSourceStatus added in v0.4.0 

func (_mock *ControlRequestClient) ExchangeVideoSourceStatus(ctxt context.Context, sourceID string, reqRespTargetID string, localTime time.Time) (common.VideoSource, []common.Recording, error)

ExchangeVideoSourceStatus provides a mock function for the type ControlRequestClient

func (*ControlRequestClient) GetVideoSourceInfo 

func (_mock *ControlRequestClient) GetVideoSourceInfo(ctxt context.Context, sourceName string) (common.VideoSource, error)

GetVideoSourceInfo provides a mock function for the type ControlRequestClient

func (*ControlRequestClient) InstallReferenceToManager 

func (_mock *ControlRequestClient) InstallReferenceToManager(newManager edge.VideoSourceOperator)

InstallReferenceToManager provides a mock function for the type ControlRequestClient

func (*ControlRequestClient) ListActiveRecordingsOfSource 

func (_mock *ControlRequestClient) ListActiveRecordingsOfSource(ctxt context.Context, sourceID string) ([]common.Recording, error)

ListActiveRecordingsOfSource provides a mock function for the type ControlRequestClient

func (*ControlRequestClient) StopAllAssociatedRecordings 

func (_mock *ControlRequestClient) StopAllAssociatedRecordings(ctxt context.Context, sourceID string) error

StopAllAssociatedRecordings provides a mock function for the type ControlRequestClient

type ControlRequestClient_ExchangeVideoSourceStatus_Call added in v0.4.0 

type ControlRequestClient_ExchangeVideoSourceStatus_Call struct {
	*mock.Call
}

ControlRequestClient_ExchangeVideoSourceStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ExchangeVideoSourceStatus'

func (*ControlRequestClient_ExchangeVideoSourceStatus_Call) Return added in v0.4.0 

func (_c *ControlRequestClient_ExchangeVideoSourceStatus_Call) Return(videoSource common.VideoSource, recordings []common.Recording, err error) *ControlRequestClient_ExchangeVideoSourceStatus_Call

func (*ControlRequestClient_ExchangeVideoSourceStatus_Call) Run added in v0.4.0 

func (_c *ControlRequestClient_ExchangeVideoSourceStatus_Call) Run(run func(ctxt context.Context, sourceID string, reqRespTargetID string, localTime time.Time)) *ControlRequestClient_ExchangeVideoSourceStatus_Call

func (*ControlRequestClient_ExchangeVideoSourceStatus_Call) RunAndReturn added in v0.4.0 

func (_c *ControlRequestClient_ExchangeVideoSourceStatus_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, reqRespTargetID string, localTime time.Time) (common.VideoSource, []common.Recording, error)) *ControlRequestClient_ExchangeVideoSourceStatus_Call

type ControlRequestClient_Expecter 

type ControlRequestClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*ControlRequestClient_Expecter) ExchangeVideoSourceStatus added in v0.4.0 

func (_e *ControlRequestClient_Expecter) ExchangeVideoSourceStatus(ctxt interface{}, sourceID interface{}, reqRespTargetID interface{}, localTime interface{}) *ControlRequestClient_ExchangeVideoSourceStatus_Call

ExchangeVideoSourceStatus is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • reqRespTargetID string
  • localTime time.Time

func (*ControlRequestClient_Expecter) GetVideoSourceInfo 

func (_e *ControlRequestClient_Expecter) GetVideoSourceInfo(ctxt interface{}, sourceName interface{}) *ControlRequestClient_GetVideoSourceInfo_Call

GetVideoSourceInfo is a helper method to define mock.On call

  • ctxt context.Context
  • sourceName string

func (*ControlRequestClient_Expecter) InstallReferenceToManager 

func (_e *ControlRequestClient_Expecter) InstallReferenceToManager(newManager interface{}) *ControlRequestClient_InstallReferenceToManager_Call

InstallReferenceToManager is a helper method to define mock.On call

  • newManager edge.VideoSourceOperator

func (*ControlRequestClient_Expecter) ListActiveRecordingsOfSource 

func (_e *ControlRequestClient_Expecter) ListActiveRecordingsOfSource(ctxt interface{}, sourceID interface{}) *ControlRequestClient_ListActiveRecordingsOfSource_Call

ListActiveRecordingsOfSource is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string

func (*ControlRequestClient_Expecter) StopAllAssociatedRecordings 

func (_e *ControlRequestClient_Expecter) StopAllAssociatedRecordings(ctxt interface{}, sourceID interface{}) *ControlRequestClient_StopAllAssociatedRecordings_Call

StopAllAssociatedRecordings is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string

type ControlRequestClient_GetVideoSourceInfo_Call 

type ControlRequestClient_GetVideoSourceInfo_Call struct {
	*mock.Call
}

ControlRequestClient_GetVideoSourceInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVideoSourceInfo'

func (*ControlRequestClient_GetVideoSourceInfo_Call) Return 

func (_c *ControlRequestClient_GetVideoSourceInfo_Call) Return(videoSource common.VideoSource, err error) *ControlRequestClient_GetVideoSourceInfo_Call

func (*ControlRequestClient_GetVideoSourceInfo_Call) Run 

func (_c *ControlRequestClient_GetVideoSourceInfo_Call) Run(run func(ctxt context.Context, sourceName string)) *ControlRequestClient_GetVideoSourceInfo_Call

func (*ControlRequestClient_GetVideoSourceInfo_Call) RunAndReturn 

func (_c *ControlRequestClient_GetVideoSourceInfo_Call) RunAndReturn(run func(ctxt context.Context, sourceName string) (common.VideoSource, error)) *ControlRequestClient_GetVideoSourceInfo_Call

type ControlRequestClient_InstallReferenceToManager_Call 

type ControlRequestClient_InstallReferenceToManager_Call struct {
	*mock.Call
}

ControlRequestClient_InstallReferenceToManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InstallReferenceToManager'

func (*ControlRequestClient_InstallReferenceToManager_Call) Return 

func (_c *ControlRequestClient_InstallReferenceToManager_Call) Return() *ControlRequestClient_InstallReferenceToManager_Call

func (*ControlRequestClient_InstallReferenceToManager_Call) Run 

func (_c *ControlRequestClient_InstallReferenceToManager_Call) Run(run func(newManager edge.VideoSourceOperator)) *ControlRequestClient_InstallReferenceToManager_Call

func (*ControlRequestClient_InstallReferenceToManager_Call) RunAndReturn 

func (_c *ControlRequestClient_InstallReferenceToManager_Call) RunAndReturn(run func(newManager edge.VideoSourceOperator)) *ControlRequestClient_InstallReferenceToManager_Call

type ControlRequestClient_ListActiveRecordingsOfSource_Call 

type ControlRequestClient_ListActiveRecordingsOfSource_Call struct {
	*mock.Call
}

ControlRequestClient_ListActiveRecordingsOfSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListActiveRecordingsOfSource'

func (*ControlRequestClient_ListActiveRecordingsOfSource_Call) Return 

func (_c *ControlRequestClient_ListActiveRecordingsOfSource_Call) Return(recordings []common.Recording, err error) *ControlRequestClient_ListActiveRecordingsOfSource_Call

func (*ControlRequestClient_ListActiveRecordingsOfSource_Call) Run 

func (_c *ControlRequestClient_ListActiveRecordingsOfSource_Call) Run(run func(ctxt context.Context, sourceID string)) *ControlRequestClient_ListActiveRecordingsOfSource_Call

func (*ControlRequestClient_ListActiveRecordingsOfSource_Call) RunAndReturn 

func (_c *ControlRequestClient_ListActiveRecordingsOfSource_Call) RunAndReturn(run func(ctxt context.Context, sourceID string) ([]common.Recording, error)) *ControlRequestClient_ListActiveRecordingsOfSource_Call

type ControlRequestClient_StopAllAssociatedRecordings_Call 

type ControlRequestClient_StopAllAssociatedRecordings_Call struct {
	*mock.Call
}

ControlRequestClient_StopAllAssociatedRecordings_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopAllAssociatedRecordings'

func (*ControlRequestClient_StopAllAssociatedRecordings_Call) Return 

func (_c *ControlRequestClient_StopAllAssociatedRecordings_Call) Return(err error) *ControlRequestClient_StopAllAssociatedRecordings_Call

func (*ControlRequestClient_StopAllAssociatedRecordings_Call) Run 

func (_c *ControlRequestClient_StopAllAssociatedRecordings_Call) Run(run func(ctxt context.Context, sourceID string)) *ControlRequestClient_StopAllAssociatedRecordings_Call

func (*ControlRequestClient_StopAllAssociatedRecordings_Call) RunAndReturn 

func (_c *ControlRequestClient_StopAllAssociatedRecordings_Call) RunAndReturn(run func(ctxt context.Context, sourceID string) error) *ControlRequestClient_StopAllAssociatedRecordings_Call

type EdgeRequestClient 

type EdgeRequestClient struct {
	mock.Mock
}

EdgeRequestClient is an autogenerated mock type for the EdgeRequestClient type

func NewEdgeRequestClient 

func NewEdgeRequestClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *EdgeRequestClient

NewEdgeRequestClient creates a new instance of EdgeRequestClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*EdgeRequestClient) ChangeVideoStreamingState 

func (_mock *EdgeRequestClient) ChangeVideoStreamingState(ctxt context.Context, source common.VideoSource, newState int) error

ChangeVideoStreamingState provides a mock function for the type EdgeRequestClient

func (*EdgeRequestClient) EXPECT 

func (_m *EdgeRequestClient) EXPECT() *EdgeRequestClient_Expecter

func (*EdgeRequestClient) InstallReferenceToManager 

func (_mock *EdgeRequestClient) InstallReferenceToManager(newManager control.SystemManager)

InstallReferenceToManager provides a mock function for the type EdgeRequestClient

func (*EdgeRequestClient) StartRecordingSession 

func (_mock *EdgeRequestClient) StartRecordingSession(ctxt context.Context, source common.VideoSource, recording common.Recording) error

StartRecordingSession provides a mock function for the type EdgeRequestClient

func (*EdgeRequestClient) StopRecordingSession 

func (_mock *EdgeRequestClient) StopRecordingSession(ctxt context.Context, source common.VideoSource, recordingID string, endTime time.Time) error

StopRecordingSession provides a mock function for the type EdgeRequestClient

type EdgeRequestClient_ChangeVideoStreamingState_Call 

type EdgeRequestClient_ChangeVideoStreamingState_Call struct {
	*mock.Call
}

EdgeRequestClient_ChangeVideoStreamingState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeVideoStreamingState'

func (*EdgeRequestClient_ChangeVideoStreamingState_Call) Return 

func (_c *EdgeRequestClient_ChangeVideoStreamingState_Call) Return(err error) *EdgeRequestClient_ChangeVideoStreamingState_Call

func (*EdgeRequestClient_ChangeVideoStreamingState_Call) Run 

func (_c *EdgeRequestClient_ChangeVideoStreamingState_Call) Run(run func(ctxt context.Context, source common.VideoSource, newState int)) *EdgeRequestClient_ChangeVideoStreamingState_Call

func (*EdgeRequestClient_ChangeVideoStreamingState_Call) RunAndReturn 

func (_c *EdgeRequestClient_ChangeVideoStreamingState_Call) RunAndReturn(run func(ctxt context.Context, source common.VideoSource, newState int) error) *EdgeRequestClient_ChangeVideoStreamingState_Call

type EdgeRequestClient_Expecter 

type EdgeRequestClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*EdgeRequestClient_Expecter) ChangeVideoStreamingState 

func (_e *EdgeRequestClient_Expecter) ChangeVideoStreamingState(ctxt interface{}, source interface{}, newState interface{}) *EdgeRequestClient_ChangeVideoStreamingState_Call

ChangeVideoStreamingState is a helper method to define mock.On call

  • ctxt context.Context
  • source common.VideoSource
  • newState int

func (*EdgeRequestClient_Expecter) InstallReferenceToManager 

func (_e *EdgeRequestClient_Expecter) InstallReferenceToManager(newManager interface{}) *EdgeRequestClient_InstallReferenceToManager_Call

InstallReferenceToManager is a helper method to define mock.On call

  • newManager control.SystemManager

func (*EdgeRequestClient_Expecter) StartRecordingSession 

func (_e *EdgeRequestClient_Expecter) StartRecordingSession(ctxt interface{}, source interface{}, recording interface{}) *EdgeRequestClient_StartRecordingSession_Call

StartRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • source common.VideoSource
  • recording common.Recording

func (*EdgeRequestClient_Expecter) StopRecordingSession 

func (_e *EdgeRequestClient_Expecter) StopRecordingSession(ctxt interface{}, source interface{}, recordingID interface{}, endTime interface{}) *EdgeRequestClient_StopRecordingSession_Call

StopRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • source common.VideoSource
  • recordingID string
  • endTime time.Time

type EdgeRequestClient_InstallReferenceToManager_Call 

type EdgeRequestClient_InstallReferenceToManager_Call struct {
	*mock.Call
}

EdgeRequestClient_InstallReferenceToManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InstallReferenceToManager'

func (*EdgeRequestClient_InstallReferenceToManager_Call) Return 

func (_c *EdgeRequestClient_InstallReferenceToManager_Call) Return() *EdgeRequestClient_InstallReferenceToManager_Call

func (*EdgeRequestClient_InstallReferenceToManager_Call) Run 

func (_c *EdgeRequestClient_InstallReferenceToManager_Call) Run(run func(newManager control.SystemManager)) *EdgeRequestClient_InstallReferenceToManager_Call

func (*EdgeRequestClient_InstallReferenceToManager_Call) RunAndReturn 

func (_c *EdgeRequestClient_InstallReferenceToManager_Call) RunAndReturn(run func(newManager control.SystemManager)) *EdgeRequestClient_InstallReferenceToManager_Call

type EdgeRequestClient_StartRecordingSession_Call 

type EdgeRequestClient_StartRecordingSession_Call struct {
	*mock.Call
}

EdgeRequestClient_StartRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartRecordingSession'

func (*EdgeRequestClient_StartRecordingSession_Call) Return 

func (_c *EdgeRequestClient_StartRecordingSession_Call) Return(err error) *EdgeRequestClient_StartRecordingSession_Call

func (*EdgeRequestClient_StartRecordingSession_Call) Run 

func (_c *EdgeRequestClient_StartRecordingSession_Call) Run(run func(ctxt context.Context, source common.VideoSource, recording common.Recording)) *EdgeRequestClient_StartRecordingSession_Call

func (*EdgeRequestClient_StartRecordingSession_Call) RunAndReturn 

func (_c *EdgeRequestClient_StartRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, source common.VideoSource, recording common.Recording) error) *EdgeRequestClient_StartRecordingSession_Call

type EdgeRequestClient_StopRecordingSession_Call 

type EdgeRequestClient_StopRecordingSession_Call struct {
	*mock.Call
}

EdgeRequestClient_StopRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopRecordingSession'

func (*EdgeRequestClient_StopRecordingSession_Call) Return 

func (_c *EdgeRequestClient_StopRecordingSession_Call) Return(err error) *EdgeRequestClient_StopRecordingSession_Call

func (*EdgeRequestClient_StopRecordingSession_Call) Run 

func (_c *EdgeRequestClient_StopRecordingSession_Call) Run(run func(ctxt context.Context, source common.VideoSource, recordingID string, endTime time.Time)) *EdgeRequestClient_StopRecordingSession_Call

func (*EdgeRequestClient_StopRecordingSession_Call) RunAndReturn 

func (_c *EdgeRequestClient_StopRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, source common.VideoSource, recordingID string, endTime time.Time) error) *EdgeRequestClient_StopRecordingSession_Call

type FileSystemWatcher 

type FileSystemWatcher struct {
	mock.Mock
}

FileSystemWatcher is an autogenerated mock type for the FileSystemWatcher type

func NewFileSystemWatcher 

func NewFileSystemWatcher(t interface {
	mock.TestingT
	Cleanup(func())
}) *FileSystemWatcher

NewFileSystemWatcher creates a new instance of FileSystemWatcher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*FileSystemWatcher) AddPath 

func (_mock *FileSystemWatcher) AddPath(ctxt context.Context, newPath string) error

AddPath provides a mock function for the type FileSystemWatcher

func (*FileSystemWatcher) EXPECT 

func (_m *FileSystemWatcher) EXPECT() *FileSystemWatcher_Expecter

func (*FileSystemWatcher) RemovePath 

func (_mock *FileSystemWatcher) RemovePath(ctxt context.Context, path string) error

RemovePath provides a mock function for the type FileSystemWatcher

func (*FileSystemWatcher) Start 

func (_mock *FileSystemWatcher) Start(ctxt context.Context, runtimeCtxt context.Context) error

Start provides a mock function for the type FileSystemWatcher

func (*FileSystemWatcher) Stop 

func (_mock *FileSystemWatcher) Stop(ctxt context.Context) error

Stop provides a mock function for the type FileSystemWatcher

type FileSystemWatcher_AddPath_Call 

type FileSystemWatcher_AddPath_Call struct {
	*mock.Call
}

FileSystemWatcher_AddPath_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddPath'

func (*FileSystemWatcher_AddPath_Call) Return 

func (_c *FileSystemWatcher_AddPath_Call) Return(err error) *FileSystemWatcher_AddPath_Call

func (*FileSystemWatcher_AddPath_Call) Run 

func (_c *FileSystemWatcher_AddPath_Call) Run(run func(ctxt context.Context, newPath string)) *FileSystemWatcher_AddPath_Call

func (*FileSystemWatcher_AddPath_Call) RunAndReturn 

func (_c *FileSystemWatcher_AddPath_Call) RunAndReturn(run func(ctxt context.Context, newPath string) error) *FileSystemWatcher_AddPath_Call

type FileSystemWatcher_Expecter 

type FileSystemWatcher_Expecter struct {
	// contains filtered or unexported fields
}

func (*FileSystemWatcher_Expecter) AddPath 

func (_e *FileSystemWatcher_Expecter) AddPath(ctxt interface{}, newPath interface{}) *FileSystemWatcher_AddPath_Call

AddPath is a helper method to define mock.On call

  • ctxt context.Context
  • newPath string

func (*FileSystemWatcher_Expecter) RemovePath 

func (_e *FileSystemWatcher_Expecter) RemovePath(ctxt interface{}, path interface{}) *FileSystemWatcher_RemovePath_Call

RemovePath is a helper method to define mock.On call

  • ctxt context.Context
  • path string

func (*FileSystemWatcher_Expecter) Start 

func (_e *FileSystemWatcher_Expecter) Start(ctxt interface{}, runtimeCtxt interface{}) *FileSystemWatcher_Start_Call

Start is a helper method to define mock.On call

  • ctxt context.Context
  • runtimeCtxt context.Context

func (*FileSystemWatcher_Expecter) Stop 

func (_e *FileSystemWatcher_Expecter) Stop(ctxt interface{}) *FileSystemWatcher_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type FileSystemWatcher_RemovePath_Call 

type FileSystemWatcher_RemovePath_Call struct {
	*mock.Call
}

FileSystemWatcher_RemovePath_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePath'

func (*FileSystemWatcher_RemovePath_Call) Return 

func (_c *FileSystemWatcher_RemovePath_Call) Return(err error) *FileSystemWatcher_RemovePath_Call

func (*FileSystemWatcher_RemovePath_Call) Run 

func (_c *FileSystemWatcher_RemovePath_Call) Run(run func(ctxt context.Context, path string)) *FileSystemWatcher_RemovePath_Call

func (*FileSystemWatcher_RemovePath_Call) RunAndReturn 

func (_c *FileSystemWatcher_RemovePath_Call) RunAndReturn(run func(ctxt context.Context, path string) error) *FileSystemWatcher_RemovePath_Call

type FileSystemWatcher_Start_Call 

type FileSystemWatcher_Start_Call struct {
	*mock.Call
}

FileSystemWatcher_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*FileSystemWatcher_Start_Call) Return 

func (_c *FileSystemWatcher_Start_Call) Return(err error) *FileSystemWatcher_Start_Call

func (*FileSystemWatcher_Start_Call) Run 

func (_c *FileSystemWatcher_Start_Call) Run(run func(ctxt context.Context, runtimeCtxt context.Context)) *FileSystemWatcher_Start_Call

func (*FileSystemWatcher_Start_Call) RunAndReturn 

func (_c *FileSystemWatcher_Start_Call) RunAndReturn(run func(ctxt context.Context, runtimeCtxt context.Context) error) *FileSystemWatcher_Start_Call

type FileSystemWatcher_Stop_Call 

type FileSystemWatcher_Stop_Call struct {
	*mock.Call
}

FileSystemWatcher_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*FileSystemWatcher_Stop_Call) Return 

func (_c *FileSystemWatcher_Stop_Call) Return(err error) *FileSystemWatcher_Stop_Call

func (*FileSystemWatcher_Stop_Call) Run 

func (_c *FileSystemWatcher_Stop_Call) Run(run func(ctxt context.Context)) *FileSystemWatcher_Stop_Call

func (*FileSystemWatcher_Stop_Call) RunAndReturn 

func (_c *FileSystemWatcher_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *FileSystemWatcher_Stop_Call

type LiveStreamSegmentForwarder 

type LiveStreamSegmentForwarder struct {
	mock.Mock
}

LiveStreamSegmentForwarder is an autogenerated mock type for the LiveStreamSegmentForwarder type

func NewLiveStreamSegmentForwarder 

func NewLiveStreamSegmentForwarder(t interface {
	mock.TestingT
	Cleanup(func())
}) *LiveStreamSegmentForwarder

NewLiveStreamSegmentForwarder creates a new instance of LiveStreamSegmentForwarder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*LiveStreamSegmentForwarder) EXPECT 

func (_m *LiveStreamSegmentForwarder) EXPECT() *LiveStreamSegmentForwarder_Expecter

func (*LiveStreamSegmentForwarder) ForwardSegment 

func (_mock *LiveStreamSegmentForwarder) ForwardSegment(ctxt context.Context, segment common.VideoSegmentWithData, blocking bool) error

ForwardSegment provides a mock function for the type LiveStreamSegmentForwarder

func (*LiveStreamSegmentForwarder) Stop 

func (_mock *LiveStreamSegmentForwarder) Stop(ctxt context.Context) error

Stop provides a mock function for the type LiveStreamSegmentForwarder

type LiveStreamSegmentForwarder_Expecter 

type LiveStreamSegmentForwarder_Expecter struct {
	// contains filtered or unexported fields
}

func (*LiveStreamSegmentForwarder_Expecter) ForwardSegment 

func (_e *LiveStreamSegmentForwarder_Expecter) ForwardSegment(ctxt interface{}, segment interface{}, blocking interface{}) *LiveStreamSegmentForwarder_ForwardSegment_Call

ForwardSegment is a helper method to define mock.On call

  • ctxt context.Context
  • segment common.VideoSegmentWithData
  • blocking bool

func (*LiveStreamSegmentForwarder_Expecter) Stop 

func (_e *LiveStreamSegmentForwarder_Expecter) Stop(ctxt interface{}) *LiveStreamSegmentForwarder_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type LiveStreamSegmentForwarder_ForwardSegment_Call 

type LiveStreamSegmentForwarder_ForwardSegment_Call struct {
	*mock.Call
}

LiveStreamSegmentForwarder_ForwardSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForwardSegment'

func (*LiveStreamSegmentForwarder_ForwardSegment_Call) Return 

func (_c *LiveStreamSegmentForwarder_ForwardSegment_Call) Return(err error) *LiveStreamSegmentForwarder_ForwardSegment_Call

func (*LiveStreamSegmentForwarder_ForwardSegment_Call) Run 

func (_c *LiveStreamSegmentForwarder_ForwardSegment_Call) Run(run func(ctxt context.Context, segment common.VideoSegmentWithData, blocking bool)) *LiveStreamSegmentForwarder_ForwardSegment_Call

func (*LiveStreamSegmentForwarder_ForwardSegment_Call) RunAndReturn 

func (_c *LiveStreamSegmentForwarder_ForwardSegment_Call) RunAndReturn(run func(ctxt context.Context, segment common.VideoSegmentWithData, blocking bool) error) *LiveStreamSegmentForwarder_ForwardSegment_Call

type LiveStreamSegmentForwarder_Stop_Call 

type LiveStreamSegmentForwarder_Stop_Call struct {
	*mock.Call
}

LiveStreamSegmentForwarder_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*LiveStreamSegmentForwarder_Stop_Call) Return 

func (_c *LiveStreamSegmentForwarder_Stop_Call) Return(err error) *LiveStreamSegmentForwarder_Stop_Call

func (*LiveStreamSegmentForwarder_Stop_Call) Run 

func (_c *LiveStreamSegmentForwarder_Stop_Call) Run(run func(ctxt context.Context)) *LiveStreamSegmentForwarder_Stop_Call

func (*LiveStreamSegmentForwarder_Stop_Call) RunAndReturn 

func (_c *LiveStreamSegmentForwarder_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *LiveStreamSegmentForwarder_Stop_Call

type LiveStreamSegmentManager 

type LiveStreamSegmentManager struct {
	mock.Mock
}

LiveStreamSegmentManager is an autogenerated mock type for the LiveStreamSegmentManager type

func NewLiveStreamSegmentManager 

func NewLiveStreamSegmentManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *LiveStreamSegmentManager

NewLiveStreamSegmentManager creates a new instance of LiveStreamSegmentManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*LiveStreamSegmentManager) EXPECT 

func (_m *LiveStreamSegmentManager) EXPECT() *LiveStreamSegmentManager_Expecter

func (*LiveStreamSegmentManager) Ready 

func (_mock *LiveStreamSegmentManager) Ready(ctxt context.Context) error

Ready provides a mock function for the type LiveStreamSegmentManager

func (*LiveStreamSegmentManager) RegisterLiveStreamSegment 

func (_mock *LiveStreamSegmentManager) RegisterLiveStreamSegment(ctxt context.Context, sourceID string, segment hls.Segment, content []byte) error

RegisterLiveStreamSegment provides a mock function for the type LiveStreamSegmentManager

func (*LiveStreamSegmentManager) Stop 

func (_mock *LiveStreamSegmentManager) Stop(ctxt context.Context) error

Stop provides a mock function for the type LiveStreamSegmentManager

type LiveStreamSegmentManager_Expecter 

type LiveStreamSegmentManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*LiveStreamSegmentManager_Expecter) Ready 

func (_e *LiveStreamSegmentManager_Expecter) Ready(ctxt interface{}) *LiveStreamSegmentManager_Ready_Call

Ready is a helper method to define mock.On call

  • ctxt context.Context

func (*LiveStreamSegmentManager_Expecter) RegisterLiveStreamSegment 

func (_e *LiveStreamSegmentManager_Expecter) RegisterLiveStreamSegment(ctxt interface{}, sourceID interface{}, segment interface{}, content interface{}) *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call

RegisterLiveStreamSegment is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • segment hls.Segment
  • content []byte

func (*LiveStreamSegmentManager_Expecter) Stop 

func (_e *LiveStreamSegmentManager_Expecter) Stop(ctxt interface{}) *LiveStreamSegmentManager_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type LiveStreamSegmentManager_Ready_Call 

type LiveStreamSegmentManager_Ready_Call struct {
	*mock.Call
}

LiveStreamSegmentManager_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*LiveStreamSegmentManager_Ready_Call) Return 

func (_c *LiveStreamSegmentManager_Ready_Call) Return(err error) *LiveStreamSegmentManager_Ready_Call

func (*LiveStreamSegmentManager_Ready_Call) Run 

func (_c *LiveStreamSegmentManager_Ready_Call) Run(run func(ctxt context.Context)) *LiveStreamSegmentManager_Ready_Call

func (*LiveStreamSegmentManager_Ready_Call) RunAndReturn 

func (_c *LiveStreamSegmentManager_Ready_Call) RunAndReturn(run func(ctxt context.Context) error) *LiveStreamSegmentManager_Ready_Call

type LiveStreamSegmentManager_RegisterLiveStreamSegment_Call 

type LiveStreamSegmentManager_RegisterLiveStreamSegment_Call struct {
	*mock.Call
}

LiveStreamSegmentManager_RegisterLiveStreamSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterLiveStreamSegment'

func (*LiveStreamSegmentManager_RegisterLiveStreamSegment_Call) Return 

func (_c *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call) Return(err error) *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call

func (*LiveStreamSegmentManager_RegisterLiveStreamSegment_Call) Run 

func (_c *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call) Run(run func(ctxt context.Context, sourceID string, segment hls.Segment, content []byte)) *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call

func (*LiveStreamSegmentManager_RegisterLiveStreamSegment_Call) RunAndReturn 

func (_c *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, segment hls.Segment, content []byte) error) *LiveStreamSegmentManager_RegisterLiveStreamSegment_Call

type LiveStreamSegmentManager_Stop_Call 

type LiveStreamSegmentManager_Stop_Call struct {
	*mock.Call
}

LiveStreamSegmentManager_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*LiveStreamSegmentManager_Stop_Call) Return 

func (_c *LiveStreamSegmentManager_Stop_Call) Return(err error) *LiveStreamSegmentManager_Stop_Call

func (*LiveStreamSegmentManager_Stop_Call) Run 

func (_c *LiveStreamSegmentManager_Stop_Call) Run(run func(ctxt context.Context)) *LiveStreamSegmentManager_Stop_Call

func (*LiveStreamSegmentManager_Stop_Call) RunAndReturn 

func (_c *LiveStreamSegmentManager_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *LiveStreamSegmentManager_Stop_Call

type PersistenceManager 

type PersistenceManager struct {
	mock.Mock
}

PersistenceManager is an autogenerated mock type for the PersistenceManager type

func NewPersistenceManager 

func NewPersistenceManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *PersistenceManager

NewPersistenceManager creates a new instance of PersistenceManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PersistenceManager) BulkDeleteLiveStreamSegment 

func (_mock *PersistenceManager) BulkDeleteLiveStreamSegment(ctxt context.Context, ids []string) error

BulkDeleteLiveStreamSegment provides a mock function for the type PersistenceManager

func (*PersistenceManager) BulkRegisterLiveStreamSegments 

func (_mock *PersistenceManager) BulkRegisterLiveStreamSegments(ctxt context.Context, sourceID string, segments []hls.Segment) (map[string]string, error)

BulkRegisterLiveStreamSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) ChangeVideoSourceStreamState 

func (_mock *PersistenceManager) ChangeVideoSourceStreamState(ctxt context.Context, id string, streaming int) error

ChangeVideoSourceStreamState provides a mock function for the type PersistenceManager

func (*PersistenceManager) Close 

func (_mock *PersistenceManager) Close()

Close provides a mock function for the type PersistenceManager

func (*PersistenceManager) DefineRecordingSession 

func (_mock *PersistenceManager) DefineRecordingSession(ctxt context.Context, sourceID string, alias *string, description *string, startTime time.Time) (string, error)

DefineRecordingSession provides a mock function for the type PersistenceManager

func (*PersistenceManager) DefineVideoSource 

func (_mock *PersistenceManager) DefineVideoSource(ctxt context.Context, name string, segmentLen int, playlistURI *string, description *string) (string, error)

DefineVideoSource provides a mock function for the type PersistenceManager

func (*PersistenceManager) DeleteLiveStreamSegment 

func (_mock *PersistenceManager) DeleteLiveStreamSegment(ctxt context.Context, id string) error

DeleteLiveStreamSegment provides a mock function for the type PersistenceManager

func (*PersistenceManager) DeleteOldLiveStreamSegments 

func (_mock *PersistenceManager) DeleteOldLiveStreamSegments(ctxt context.Context, timeLimit time.Time) error

DeleteOldLiveStreamSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) DeleteRecordingSession 

func (_mock *PersistenceManager) DeleteRecordingSession(ctxt context.Context, id string) error

DeleteRecordingSession provides a mock function for the type PersistenceManager

func (*PersistenceManager) DeleteUnassociatedRecordingSegments 

func (_mock *PersistenceManager) DeleteUnassociatedRecordingSegments(ctxt context.Context) ([]common.VideoSegment, error)

DeleteUnassociatedRecordingSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) DeleteVideoSource 

func (_mock *PersistenceManager) DeleteVideoSource(ctxt context.Context, id string) error

DeleteVideoSource provides a mock function for the type PersistenceManager

func (*PersistenceManager) EXPECT 

func (_m *PersistenceManager) EXPECT() *PersistenceManager_Expecter

func (*PersistenceManager) Error 

func (_mock *PersistenceManager) Error() error

Error provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetLatestLiveStreamSegments 

func (_mock *PersistenceManager) GetLatestLiveStreamSegments(ctxt context.Context, sourceID string, count int) ([]common.VideoSegment, error)

GetLatestLiveStreamSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetLiveStreamSegment 

func (_mock *PersistenceManager) GetLiveStreamSegment(ctxt context.Context, id string) (common.VideoSegment, error)

GetLiveStreamSegment provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetLiveStreamSegmentByName 

func (_mock *PersistenceManager) GetLiveStreamSegmentByName(ctxt context.Context, name string) (common.VideoSegment, error)

GetLiveStreamSegmentByName provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetRecordingSegment 

func (_mock *PersistenceManager) GetRecordingSegment(ctxt context.Context, id string) (common.VideoSegment, error)

GetRecordingSegment provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetRecordingSegmentByName 

func (_mock *PersistenceManager) GetRecordingSegmentByName(ctxt context.Context, name string) (common.VideoSegment, error)

GetRecordingSegmentByName provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetRecordingSession 

func (_mock *PersistenceManager) GetRecordingSession(ctxt context.Context, id string) (common.Recording, error)

GetRecordingSession provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetRecordingSessionByAlias 

func (_mock *PersistenceManager) GetRecordingSessionByAlias(ctxt context.Context, alias string) (common.Recording, error)

GetRecordingSessionByAlias provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetVideoSource 

func (_mock *PersistenceManager) GetVideoSource(ctxt context.Context, id string) (common.VideoSource, error)

GetVideoSource provides a mock function for the type PersistenceManager

func (*PersistenceManager) GetVideoSourceByName 

func (_mock *PersistenceManager) GetVideoSourceByName(ctxt context.Context, name string) (common.VideoSource, error)

GetVideoSourceByName provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListAllLiveStreamSegments 

func (_mock *PersistenceManager) ListAllLiveStreamSegments(ctxt context.Context, sourceID string) ([]common.VideoSegment, error)

ListAllLiveStreamSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListAllLiveStreamSegmentsAfterTime 

func (_mock *PersistenceManager) ListAllLiveStreamSegmentsAfterTime(ctxt context.Context, sourceID string, timestamp time.Time) ([]common.VideoSegment, error)

ListAllLiveStreamSegmentsAfterTime provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListAllRecordingSegments 

func (_mock *PersistenceManager) ListAllRecordingSegments(ctxt context.Context) ([]common.VideoSegment, error)

ListAllRecordingSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListAllSegmentsOfRecording 

func (_mock *PersistenceManager) ListAllSegmentsOfRecording(ctxt context.Context, recordingID string) ([]common.VideoSegment, error)

ListAllSegmentsOfRecording provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListRecordingSessions 

func (_mock *PersistenceManager) ListRecordingSessions(ctxt context.Context) ([]common.Recording, error)

ListRecordingSessions provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListRecordingSessionsOfSource 

func (_mock *PersistenceManager) ListRecordingSessionsOfSource(ctxt context.Context, sourceID string, active bool) ([]common.Recording, error)

ListRecordingSessionsOfSource provides a mock function for the type PersistenceManager

func (*PersistenceManager) ListVideoSources 

func (_mock *PersistenceManager) ListVideoSources(ctxt context.Context) ([]common.VideoSource, error)

ListVideoSources provides a mock function for the type PersistenceManager

func (*PersistenceManager) MarkEndOfRecordingSession 

func (_mock *PersistenceManager) MarkEndOfRecordingSession(ctxt context.Context, id string, endTime time.Time) error

MarkEndOfRecordingSession provides a mock function for the type PersistenceManager

func (*PersistenceManager) MarkExternalError 

func (_mock *PersistenceManager) MarkExternalError(err error)

MarkExternalError provides a mock function for the type PersistenceManager

func (*PersistenceManager) MarkLiveStreamSegmentsUploaded 

func (_mock *PersistenceManager) MarkLiveStreamSegmentsUploaded(ctxt context.Context, ids []string) error

MarkLiveStreamSegmentsUploaded provides a mock function for the type PersistenceManager

func (*PersistenceManager) Ready 

func (_mock *PersistenceManager) Ready(ctxt context.Context) error

Ready provides a mock function for the type PersistenceManager

func (*PersistenceManager) RecordKnownRecordingSession 

func (_mock *PersistenceManager) RecordKnownRecordingSession(ctxt context.Context, entry common.Recording) error

RecordKnownRecordingSession provides a mock function for the type PersistenceManager

func (*PersistenceManager) RecordKnownVideoSource 

func (_mock *PersistenceManager) RecordKnownVideoSource(ctxt context.Context, id string, name string, segmentLen int, playlistURI *string, description *string, streaming int) error

RecordKnownVideoSource provides a mock function for the type PersistenceManager

func (*PersistenceManager) RegisterLiveStreamSegment 

func (_mock *PersistenceManager) RegisterLiveStreamSegment(ctxt context.Context, sourceID string, segment hls.Segment) (string, error)

RegisterLiveStreamSegment provides a mock function for the type PersistenceManager

func (*PersistenceManager) RegisterRecordingSegments 

func (_mock *PersistenceManager) RegisterRecordingSegments(ctxt context.Context, recordingIDs []string, segments []common.VideoSegment) error

RegisterRecordingSegments provides a mock function for the type PersistenceManager

func (*PersistenceManager) UpdateRecordingSession 

func (_mock *PersistenceManager) UpdateRecordingSession(ctxt context.Context, newSetting common.Recording) error

UpdateRecordingSession provides a mock function for the type PersistenceManager

func (*PersistenceManager) UpdateVideoSource 

func (_mock *PersistenceManager) UpdateVideoSource(ctxt context.Context, newSetting common.VideoSource) error

UpdateVideoSource provides a mock function for the type PersistenceManager

func (*PersistenceManager) UpdateVideoSourceStats 

func (_mock *PersistenceManager) UpdateVideoSourceStats(ctxt context.Context, id string, reqRespTargetID string, sourceLocalTime time.Time) error

UpdateVideoSourceStats provides a mock function for the type PersistenceManager

type PersistenceManager_BulkDeleteLiveStreamSegment_Call 

type PersistenceManager_BulkDeleteLiveStreamSegment_Call struct {
	*mock.Call
}

PersistenceManager_BulkDeleteLiveStreamSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BulkDeleteLiveStreamSegment'

func (*PersistenceManager_BulkDeleteLiveStreamSegment_Call) Return 

func (_c *PersistenceManager_BulkDeleteLiveStreamSegment_Call) Return(err error) *PersistenceManager_BulkDeleteLiveStreamSegment_Call

func (*PersistenceManager_BulkDeleteLiveStreamSegment_Call) Run 

func (_c *PersistenceManager_BulkDeleteLiveStreamSegment_Call) Run(run func(ctxt context.Context, ids []string)) *PersistenceManager_BulkDeleteLiveStreamSegment_Call

func (*PersistenceManager_BulkDeleteLiveStreamSegment_Call) RunAndReturn 

func (_c *PersistenceManager_BulkDeleteLiveStreamSegment_Call) RunAndReturn(run func(ctxt context.Context, ids []string) error) *PersistenceManager_BulkDeleteLiveStreamSegment_Call

type PersistenceManager_BulkRegisterLiveStreamSegments_Call 

type PersistenceManager_BulkRegisterLiveStreamSegments_Call struct {
	*mock.Call
}

PersistenceManager_BulkRegisterLiveStreamSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BulkRegisterLiveStreamSegments'

func (*PersistenceManager_BulkRegisterLiveStreamSegments_Call) Return 

func (_c *PersistenceManager_BulkRegisterLiveStreamSegments_Call) Return(stringToString map[string]string, err error) *PersistenceManager_BulkRegisterLiveStreamSegments_Call

func (*PersistenceManager_BulkRegisterLiveStreamSegments_Call) Run 

func (_c *PersistenceManager_BulkRegisterLiveStreamSegments_Call) Run(run func(ctxt context.Context, sourceID string, segments []hls.Segment)) *PersistenceManager_BulkRegisterLiveStreamSegments_Call

func (*PersistenceManager_BulkRegisterLiveStreamSegments_Call) RunAndReturn 

func (_c *PersistenceManager_BulkRegisterLiveStreamSegments_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, segments []hls.Segment) (map[string]string, error)) *PersistenceManager_BulkRegisterLiveStreamSegments_Call

type PersistenceManager_ChangeVideoSourceStreamState_Call 

type PersistenceManager_ChangeVideoSourceStreamState_Call struct {
	*mock.Call
}

PersistenceManager_ChangeVideoSourceStreamState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeVideoSourceStreamState'

func (*PersistenceManager_ChangeVideoSourceStreamState_Call) Return 

func (_c *PersistenceManager_ChangeVideoSourceStreamState_Call) Return(err error) *PersistenceManager_ChangeVideoSourceStreamState_Call

func (*PersistenceManager_ChangeVideoSourceStreamState_Call) Run 

func (_c *PersistenceManager_ChangeVideoSourceStreamState_Call) Run(run func(ctxt context.Context, id string, streaming int)) *PersistenceManager_ChangeVideoSourceStreamState_Call

func (*PersistenceManager_ChangeVideoSourceStreamState_Call) RunAndReturn 

func (_c *PersistenceManager_ChangeVideoSourceStreamState_Call) RunAndReturn(run func(ctxt context.Context, id string, streaming int) error) *PersistenceManager_ChangeVideoSourceStreamState_Call

type PersistenceManager_Close_Call 

type PersistenceManager_Close_Call struct {
	*mock.Call
}

PersistenceManager_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*PersistenceManager_Close_Call) Return 

func (_c *PersistenceManager_Close_Call) Return() *PersistenceManager_Close_Call

func (*PersistenceManager_Close_Call) Run 

func (_c *PersistenceManager_Close_Call) Run(run func()) *PersistenceManager_Close_Call

func (*PersistenceManager_Close_Call) RunAndReturn 

func (_c *PersistenceManager_Close_Call) RunAndReturn(run func()) *PersistenceManager_Close_Call

type PersistenceManager_DefineRecordingSession_Call 

type PersistenceManager_DefineRecordingSession_Call struct {
	*mock.Call
}

PersistenceManager_DefineRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineRecordingSession'

func (*PersistenceManager_DefineRecordingSession_Call) Return 

func (_c *PersistenceManager_DefineRecordingSession_Call) Return(s string, err error) *PersistenceManager_DefineRecordingSession_Call

func (*PersistenceManager_DefineRecordingSession_Call) Run 

func (_c *PersistenceManager_DefineRecordingSession_Call) Run(run func(ctxt context.Context, sourceID string, alias *string, description *string, startTime time.Time)) *PersistenceManager_DefineRecordingSession_Call

func (*PersistenceManager_DefineRecordingSession_Call) RunAndReturn 

func (_c *PersistenceManager_DefineRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, alias *string, description *string, startTime time.Time) (string, error)) *PersistenceManager_DefineRecordingSession_Call

type PersistenceManager_DefineVideoSource_Call 

type PersistenceManager_DefineVideoSource_Call struct {
	*mock.Call
}

PersistenceManager_DefineVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineVideoSource'

func (*PersistenceManager_DefineVideoSource_Call) Return 

func (_c *PersistenceManager_DefineVideoSource_Call) Return(s string, err error) *PersistenceManager_DefineVideoSource_Call

func (*PersistenceManager_DefineVideoSource_Call) Run 

func (_c *PersistenceManager_DefineVideoSource_Call) Run(run func(ctxt context.Context, name string, segmentLen int, playlistURI *string, description *string)) *PersistenceManager_DefineVideoSource_Call

func (*PersistenceManager_DefineVideoSource_Call) RunAndReturn 

func (_c *PersistenceManager_DefineVideoSource_Call) RunAndReturn(run func(ctxt context.Context, name string, segmentLen int, playlistURI *string, description *string) (string, error)) *PersistenceManager_DefineVideoSource_Call

type PersistenceManager_DeleteLiveStreamSegment_Call 

type PersistenceManager_DeleteLiveStreamSegment_Call struct {
	*mock.Call
}

PersistenceManager_DeleteLiveStreamSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteLiveStreamSegment'

func (*PersistenceManager_DeleteLiveStreamSegment_Call) Return 

func (_c *PersistenceManager_DeleteLiveStreamSegment_Call) Return(err error) *PersistenceManager_DeleteLiveStreamSegment_Call

func (*PersistenceManager_DeleteLiveStreamSegment_Call) Run 

func (_c *PersistenceManager_DeleteLiveStreamSegment_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_DeleteLiveStreamSegment_Call

func (*PersistenceManager_DeleteLiveStreamSegment_Call) RunAndReturn 

func (_c *PersistenceManager_DeleteLiveStreamSegment_Call) RunAndReturn(run func(ctxt context.Context, id string) error) *PersistenceManager_DeleteLiveStreamSegment_Call

type PersistenceManager_DeleteOldLiveStreamSegments_Call 

type PersistenceManager_DeleteOldLiveStreamSegments_Call struct {
	*mock.Call
}

PersistenceManager_DeleteOldLiveStreamSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteOldLiveStreamSegments'

func (*PersistenceManager_DeleteOldLiveStreamSegments_Call) Return 

func (_c *PersistenceManager_DeleteOldLiveStreamSegments_Call) Return(err error) *PersistenceManager_DeleteOldLiveStreamSegments_Call

func (*PersistenceManager_DeleteOldLiveStreamSegments_Call) Run 

func (_c *PersistenceManager_DeleteOldLiveStreamSegments_Call) Run(run func(ctxt context.Context, timeLimit time.Time)) *PersistenceManager_DeleteOldLiveStreamSegments_Call

func (*PersistenceManager_DeleteOldLiveStreamSegments_Call) RunAndReturn 

func (_c *PersistenceManager_DeleteOldLiveStreamSegments_Call) RunAndReturn(run func(ctxt context.Context, timeLimit time.Time) error) *PersistenceManager_DeleteOldLiveStreamSegments_Call

type PersistenceManager_DeleteRecordingSession_Call 

type PersistenceManager_DeleteRecordingSession_Call struct {
	*mock.Call
}

PersistenceManager_DeleteRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteRecordingSession'

func (*PersistenceManager_DeleteRecordingSession_Call) Return 

func (_c *PersistenceManager_DeleteRecordingSession_Call) Return(err error) *PersistenceManager_DeleteRecordingSession_Call

func (*PersistenceManager_DeleteRecordingSession_Call) Run 

func (_c *PersistenceManager_DeleteRecordingSession_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_DeleteRecordingSession_Call

func (*PersistenceManager_DeleteRecordingSession_Call) RunAndReturn 

func (_c *PersistenceManager_DeleteRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, id string) error) *PersistenceManager_DeleteRecordingSession_Call

type PersistenceManager_DeleteUnassociatedRecordingSegments_Call 

type PersistenceManager_DeleteUnassociatedRecordingSegments_Call struct {
	*mock.Call
}

PersistenceManager_DeleteUnassociatedRecordingSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteUnassociatedRecordingSegments'

func (*PersistenceManager_DeleteUnassociatedRecordingSegments_Call) Return 

func (_c *PersistenceManager_DeleteUnassociatedRecordingSegments_Call) Return(videoSegments []common.VideoSegment, err error) *PersistenceManager_DeleteUnassociatedRecordingSegments_Call

func (*PersistenceManager_DeleteUnassociatedRecordingSegments_Call) Run 

func (_c *PersistenceManager_DeleteUnassociatedRecordingSegments_Call) Run(run func(ctxt context.Context)) *PersistenceManager_DeleteUnassociatedRecordingSegments_Call

func (*PersistenceManager_DeleteUnassociatedRecordingSegments_Call) RunAndReturn 

func (_c *PersistenceManager_DeleteUnassociatedRecordingSegments_Call) RunAndReturn(run func(ctxt context.Context) ([]common.VideoSegment, error)) *PersistenceManager_DeleteUnassociatedRecordingSegments_Call

type PersistenceManager_DeleteVideoSource_Call 

type PersistenceManager_DeleteVideoSource_Call struct {
	*mock.Call
}

PersistenceManager_DeleteVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteVideoSource'

func (*PersistenceManager_DeleteVideoSource_Call) Return 

func (_c *PersistenceManager_DeleteVideoSource_Call) Return(err error) *PersistenceManager_DeleteVideoSource_Call

func (*PersistenceManager_DeleteVideoSource_Call) Run 

func (_c *PersistenceManager_DeleteVideoSource_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_DeleteVideoSource_Call

func (*PersistenceManager_DeleteVideoSource_Call) RunAndReturn 

func (_c *PersistenceManager_DeleteVideoSource_Call) RunAndReturn(run func(ctxt context.Context, id string) error) *PersistenceManager_DeleteVideoSource_Call

type PersistenceManager_Error_Call 

type PersistenceManager_Error_Call struct {
	*mock.Call
}

PersistenceManager_Error_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Error'

func (*PersistenceManager_Error_Call) Return 

func (_c *PersistenceManager_Error_Call) Return(err error) *PersistenceManager_Error_Call

func (*PersistenceManager_Error_Call) Run 

func (_c *PersistenceManager_Error_Call) Run(run func()) *PersistenceManager_Error_Call

func (*PersistenceManager_Error_Call) RunAndReturn 

func (_c *PersistenceManager_Error_Call) RunAndReturn(run func() error) *PersistenceManager_Error_Call

type PersistenceManager_Expecter 

type PersistenceManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*PersistenceManager_Expecter) BulkDeleteLiveStreamSegment 

func (_e *PersistenceManager_Expecter) BulkDeleteLiveStreamSegment(ctxt interface{}, ids interface{}) *PersistenceManager_BulkDeleteLiveStreamSegment_Call

BulkDeleteLiveStreamSegment is a helper method to define mock.On call

  • ctxt context.Context
  • ids []string

func (*PersistenceManager_Expecter) BulkRegisterLiveStreamSegments 

func (_e *PersistenceManager_Expecter) BulkRegisterLiveStreamSegments(ctxt interface{}, sourceID interface{}, segments interface{}) *PersistenceManager_BulkRegisterLiveStreamSegments_Call

BulkRegisterLiveStreamSegments is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • segments []hls.Segment

func (*PersistenceManager_Expecter) ChangeVideoSourceStreamState 

func (_e *PersistenceManager_Expecter) ChangeVideoSourceStreamState(ctxt interface{}, id interface{}, streaming interface{}) *PersistenceManager_ChangeVideoSourceStreamState_Call

ChangeVideoSourceStreamState is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • streaming int

func (*PersistenceManager_Expecter) Close 

func (_e *PersistenceManager_Expecter) Close() *PersistenceManager_Close_Call

Close is a helper method to define mock.On call

func (*PersistenceManager_Expecter) DefineRecordingSession 

func (_e *PersistenceManager_Expecter) DefineRecordingSession(ctxt interface{}, sourceID interface{}, alias interface{}, description interface{}, startTime interface{}) *PersistenceManager_DefineRecordingSession_Call

DefineRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • alias *string
  • description *string
  • startTime time.Time

func (*PersistenceManager_Expecter) DefineVideoSource 

func (_e *PersistenceManager_Expecter) DefineVideoSource(ctxt interface{}, name interface{}, segmentLen interface{}, playlistURI interface{}, description interface{}) *PersistenceManager_DefineVideoSource_Call

DefineVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • name string
  • segmentLen int
  • playlistURI *string
  • description *string

func (*PersistenceManager_Expecter) DeleteLiveStreamSegment 

func (_e *PersistenceManager_Expecter) DeleteLiveStreamSegment(ctxt interface{}, id interface{}) *PersistenceManager_DeleteLiveStreamSegment_Call

DeleteLiveStreamSegment is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) DeleteOldLiveStreamSegments 

func (_e *PersistenceManager_Expecter) DeleteOldLiveStreamSegments(ctxt interface{}, timeLimit interface{}) *PersistenceManager_DeleteOldLiveStreamSegments_Call

DeleteOldLiveStreamSegments is a helper method to define mock.On call

  • ctxt context.Context
  • timeLimit time.Time

func (*PersistenceManager_Expecter) DeleteRecordingSession 

func (_e *PersistenceManager_Expecter) DeleteRecordingSession(ctxt interface{}, id interface{}) *PersistenceManager_DeleteRecordingSession_Call

DeleteRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) DeleteUnassociatedRecordingSegments 

func (_e *PersistenceManager_Expecter) DeleteUnassociatedRecordingSegments(ctxt interface{}) *PersistenceManager_DeleteUnassociatedRecordingSegments_Call

DeleteUnassociatedRecordingSegments is a helper method to define mock.On call

  • ctxt context.Context

func (*PersistenceManager_Expecter) DeleteVideoSource 

func (_e *PersistenceManager_Expecter) DeleteVideoSource(ctxt interface{}, id interface{}) *PersistenceManager_DeleteVideoSource_Call

DeleteVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) Error 

func (_e *PersistenceManager_Expecter) Error() *PersistenceManager_Error_Call

Error is a helper method to define mock.On call

func (*PersistenceManager_Expecter) GetLatestLiveStreamSegments 

func (_e *PersistenceManager_Expecter) GetLatestLiveStreamSegments(ctxt interface{}, sourceID interface{}, count interface{}) *PersistenceManager_GetLatestLiveStreamSegments_Call

GetLatestLiveStreamSegments is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • count int

func (*PersistenceManager_Expecter) GetLiveStreamSegment 

func (_e *PersistenceManager_Expecter) GetLiveStreamSegment(ctxt interface{}, id interface{}) *PersistenceManager_GetLiveStreamSegment_Call

GetLiveStreamSegment is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) GetLiveStreamSegmentByName 

func (_e *PersistenceManager_Expecter) GetLiveStreamSegmentByName(ctxt interface{}, name interface{}) *PersistenceManager_GetLiveStreamSegmentByName_Call

GetLiveStreamSegmentByName is a helper method to define mock.On call

  • ctxt context.Context
  • name string

func (*PersistenceManager_Expecter) GetRecordingSegment 

func (_e *PersistenceManager_Expecter) GetRecordingSegment(ctxt interface{}, id interface{}) *PersistenceManager_GetRecordingSegment_Call

GetRecordingSegment is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) GetRecordingSegmentByName 

func (_e *PersistenceManager_Expecter) GetRecordingSegmentByName(ctxt interface{}, name interface{}) *PersistenceManager_GetRecordingSegmentByName_Call

GetRecordingSegmentByName is a helper method to define mock.On call

  • ctxt context.Context
  • name string

func (*PersistenceManager_Expecter) GetRecordingSession 

func (_e *PersistenceManager_Expecter) GetRecordingSession(ctxt interface{}, id interface{}) *PersistenceManager_GetRecordingSession_Call

GetRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) GetRecordingSessionByAlias 

func (_e *PersistenceManager_Expecter) GetRecordingSessionByAlias(ctxt interface{}, alias interface{}) *PersistenceManager_GetRecordingSessionByAlias_Call

GetRecordingSessionByAlias is a helper method to define mock.On call

  • ctxt context.Context
  • alias string

func (*PersistenceManager_Expecter) GetVideoSource 

func (_e *PersistenceManager_Expecter) GetVideoSource(ctxt interface{}, id interface{}) *PersistenceManager_GetVideoSource_Call

GetVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*PersistenceManager_Expecter) GetVideoSourceByName 

func (_e *PersistenceManager_Expecter) GetVideoSourceByName(ctxt interface{}, name interface{}) *PersistenceManager_GetVideoSourceByName_Call

GetVideoSourceByName is a helper method to define mock.On call

  • ctxt context.Context
  • name string

func (*PersistenceManager_Expecter) ListAllLiveStreamSegments 

func (_e *PersistenceManager_Expecter) ListAllLiveStreamSegments(ctxt interface{}, sourceID interface{}) *PersistenceManager_ListAllLiveStreamSegments_Call

ListAllLiveStreamSegments is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string

func (*PersistenceManager_Expecter) ListAllLiveStreamSegmentsAfterTime 

func (_e *PersistenceManager_Expecter) ListAllLiveStreamSegmentsAfterTime(ctxt interface{}, sourceID interface{}, timestamp interface{}) *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call

ListAllLiveStreamSegmentsAfterTime is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • timestamp time.Time

func (*PersistenceManager_Expecter) ListAllRecordingSegments 

func (_e *PersistenceManager_Expecter) ListAllRecordingSegments(ctxt interface{}) *PersistenceManager_ListAllRecordingSegments_Call

ListAllRecordingSegments is a helper method to define mock.On call

  • ctxt context.Context

func (*PersistenceManager_Expecter) ListAllSegmentsOfRecording 

func (_e *PersistenceManager_Expecter) ListAllSegmentsOfRecording(ctxt interface{}, recordingID interface{}) *PersistenceManager_ListAllSegmentsOfRecording_Call

ListAllSegmentsOfRecording is a helper method to define mock.On call

  • ctxt context.Context
  • recordingID string

func (*PersistenceManager_Expecter) ListRecordingSessions 

func (_e *PersistenceManager_Expecter) ListRecordingSessions(ctxt interface{}) *PersistenceManager_ListRecordingSessions_Call

ListRecordingSessions is a helper method to define mock.On call

  • ctxt context.Context

func (*PersistenceManager_Expecter) ListRecordingSessionsOfSource 

func (_e *PersistenceManager_Expecter) ListRecordingSessionsOfSource(ctxt interface{}, sourceID interface{}, active interface{}) *PersistenceManager_ListRecordingSessionsOfSource_Call

ListRecordingSessionsOfSource is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • active bool

func (*PersistenceManager_Expecter) ListVideoSources 

func (_e *PersistenceManager_Expecter) ListVideoSources(ctxt interface{}) *PersistenceManager_ListVideoSources_Call

ListVideoSources is a helper method to define mock.On call

  • ctxt context.Context

func (*PersistenceManager_Expecter) MarkEndOfRecordingSession 

func (_e *PersistenceManager_Expecter) MarkEndOfRecordingSession(ctxt interface{}, id interface{}, endTime interface{}) *PersistenceManager_MarkEndOfRecordingSession_Call

MarkEndOfRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • endTime time.Time

func (*PersistenceManager_Expecter) MarkExternalError 

func (_e *PersistenceManager_Expecter) MarkExternalError(err interface{}) *PersistenceManager_MarkExternalError_Call

MarkExternalError is a helper method to define mock.On call

  • err error

func (*PersistenceManager_Expecter) MarkLiveStreamSegmentsUploaded 

func (_e *PersistenceManager_Expecter) MarkLiveStreamSegmentsUploaded(ctxt interface{}, ids interface{}) *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call

MarkLiveStreamSegmentsUploaded is a helper method to define mock.On call

  • ctxt context.Context
  • ids []string

func (*PersistenceManager_Expecter) Ready 

func (_e *PersistenceManager_Expecter) Ready(ctxt interface{}) *PersistenceManager_Ready_Call

Ready is a helper method to define mock.On call

  • ctxt context.Context

func (*PersistenceManager_Expecter) RecordKnownRecordingSession 

func (_e *PersistenceManager_Expecter) RecordKnownRecordingSession(ctxt interface{}, entry interface{}) *PersistenceManager_RecordKnownRecordingSession_Call

RecordKnownRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • entry common.Recording

func (*PersistenceManager_Expecter) RecordKnownVideoSource 

func (_e *PersistenceManager_Expecter) RecordKnownVideoSource(ctxt interface{}, id interface{}, name interface{}, segmentLen interface{}, playlistURI interface{}, description interface{}, streaming interface{}) *PersistenceManager_RecordKnownVideoSource_Call

RecordKnownVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • name string
  • segmentLen int
  • playlistURI *string
  • description *string
  • streaming int

func (*PersistenceManager_Expecter) RegisterLiveStreamSegment 

func (_e *PersistenceManager_Expecter) RegisterLiveStreamSegment(ctxt interface{}, sourceID interface{}, segment interface{}) *PersistenceManager_RegisterLiveStreamSegment_Call

RegisterLiveStreamSegment is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • segment hls.Segment

func (*PersistenceManager_Expecter) RegisterRecordingSegments 

func (_e *PersistenceManager_Expecter) RegisterRecordingSegments(ctxt interface{}, recordingIDs interface{}, segments interface{}) *PersistenceManager_RegisterRecordingSegments_Call

RegisterRecordingSegments is a helper method to define mock.On call

  • ctxt context.Context
  • recordingIDs []string
  • segments []common.VideoSegment

func (*PersistenceManager_Expecter) UpdateRecordingSession 

func (_e *PersistenceManager_Expecter) UpdateRecordingSession(ctxt interface{}, newSetting interface{}) *PersistenceManager_UpdateRecordingSession_Call

UpdateRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • newSetting common.Recording

func (*PersistenceManager_Expecter) UpdateVideoSource 

func (_e *PersistenceManager_Expecter) UpdateVideoSource(ctxt interface{}, newSetting interface{}) *PersistenceManager_UpdateVideoSource_Call

UpdateVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • newSetting common.VideoSource

func (*PersistenceManager_Expecter) UpdateVideoSourceStats 

func (_e *PersistenceManager_Expecter) UpdateVideoSourceStats(ctxt interface{}, id interface{}, reqRespTargetID interface{}, sourceLocalTime interface{}) *PersistenceManager_UpdateVideoSourceStats_Call

UpdateVideoSourceStats is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • reqRespTargetID string
  • sourceLocalTime time.Time

type PersistenceManager_GetLatestLiveStreamSegments_Call 

type PersistenceManager_GetLatestLiveStreamSegments_Call struct {
	*mock.Call
}

PersistenceManager_GetLatestLiveStreamSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestLiveStreamSegments'

func (*PersistenceManager_GetLatestLiveStreamSegments_Call) Return 

func (_c *PersistenceManager_GetLatestLiveStreamSegments_Call) Return(videoSegments []common.VideoSegment, err error) *PersistenceManager_GetLatestLiveStreamSegments_Call

func (*PersistenceManager_GetLatestLiveStreamSegments_Call) Run 

func (_c *PersistenceManager_GetLatestLiveStreamSegments_Call) Run(run func(ctxt context.Context, sourceID string, count int)) *PersistenceManager_GetLatestLiveStreamSegments_Call

func (*PersistenceManager_GetLatestLiveStreamSegments_Call) RunAndReturn 

func (_c *PersistenceManager_GetLatestLiveStreamSegments_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, count int) ([]common.VideoSegment, error)) *PersistenceManager_GetLatestLiveStreamSegments_Call

type PersistenceManager_GetLiveStreamSegmentByName_Call 

type PersistenceManager_GetLiveStreamSegmentByName_Call struct {
	*mock.Call
}

PersistenceManager_GetLiveStreamSegmentByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLiveStreamSegmentByName'

func (*PersistenceManager_GetLiveStreamSegmentByName_Call) Return 

func (_c *PersistenceManager_GetLiveStreamSegmentByName_Call) Return(videoSegment common.VideoSegment, err error) *PersistenceManager_GetLiveStreamSegmentByName_Call

func (*PersistenceManager_GetLiveStreamSegmentByName_Call) Run 

func (_c *PersistenceManager_GetLiveStreamSegmentByName_Call) Run(run func(ctxt context.Context, name string)) *PersistenceManager_GetLiveStreamSegmentByName_Call

func (*PersistenceManager_GetLiveStreamSegmentByName_Call) RunAndReturn 

func (_c *PersistenceManager_GetLiveStreamSegmentByName_Call) RunAndReturn(run func(ctxt context.Context, name string) (common.VideoSegment, error)) *PersistenceManager_GetLiveStreamSegmentByName_Call

type PersistenceManager_GetLiveStreamSegment_Call 

type PersistenceManager_GetLiveStreamSegment_Call struct {
	*mock.Call
}

PersistenceManager_GetLiveStreamSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLiveStreamSegment'

func (*PersistenceManager_GetLiveStreamSegment_Call) Return 

func (_c *PersistenceManager_GetLiveStreamSegment_Call) Return(videoSegment common.VideoSegment, err error) *PersistenceManager_GetLiveStreamSegment_Call

func (*PersistenceManager_GetLiveStreamSegment_Call) Run 

func (_c *PersistenceManager_GetLiveStreamSegment_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_GetLiveStreamSegment_Call

func (*PersistenceManager_GetLiveStreamSegment_Call) RunAndReturn 

func (_c *PersistenceManager_GetLiveStreamSegment_Call) RunAndReturn(run func(ctxt context.Context, id string) (common.VideoSegment, error)) *PersistenceManager_GetLiveStreamSegment_Call

type PersistenceManager_GetRecordingSegmentByName_Call 

type PersistenceManager_GetRecordingSegmentByName_Call struct {
	*mock.Call
}

PersistenceManager_GetRecordingSegmentByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingSegmentByName'

func (*PersistenceManager_GetRecordingSegmentByName_Call) Return 

func (_c *PersistenceManager_GetRecordingSegmentByName_Call) Return(videoSegment common.VideoSegment, err error) *PersistenceManager_GetRecordingSegmentByName_Call

func (*PersistenceManager_GetRecordingSegmentByName_Call) Run 

func (_c *PersistenceManager_GetRecordingSegmentByName_Call) Run(run func(ctxt context.Context, name string)) *PersistenceManager_GetRecordingSegmentByName_Call

func (*PersistenceManager_GetRecordingSegmentByName_Call) RunAndReturn 

func (_c *PersistenceManager_GetRecordingSegmentByName_Call) RunAndReturn(run func(ctxt context.Context, name string) (common.VideoSegment, error)) *PersistenceManager_GetRecordingSegmentByName_Call

type PersistenceManager_GetRecordingSegment_Call 

type PersistenceManager_GetRecordingSegment_Call struct {
	*mock.Call
}

PersistenceManager_GetRecordingSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingSegment'

func (*PersistenceManager_GetRecordingSegment_Call) Return 

func (_c *PersistenceManager_GetRecordingSegment_Call) Return(videoSegment common.VideoSegment, err error) *PersistenceManager_GetRecordingSegment_Call

func (*PersistenceManager_GetRecordingSegment_Call) Run 

func (_c *PersistenceManager_GetRecordingSegment_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_GetRecordingSegment_Call

func (*PersistenceManager_GetRecordingSegment_Call) RunAndReturn 

func (_c *PersistenceManager_GetRecordingSegment_Call) RunAndReturn(run func(ctxt context.Context, id string) (common.VideoSegment, error)) *PersistenceManager_GetRecordingSegment_Call

type PersistenceManager_GetRecordingSessionByAlias_Call 

type PersistenceManager_GetRecordingSessionByAlias_Call struct {
	*mock.Call
}

PersistenceManager_GetRecordingSessionByAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingSessionByAlias'

func (*PersistenceManager_GetRecordingSessionByAlias_Call) Return 

func (_c *PersistenceManager_GetRecordingSessionByAlias_Call) Return(recording common.Recording, err error) *PersistenceManager_GetRecordingSessionByAlias_Call

func (*PersistenceManager_GetRecordingSessionByAlias_Call) Run 

func (_c *PersistenceManager_GetRecordingSessionByAlias_Call) Run(run func(ctxt context.Context, alias string)) *PersistenceManager_GetRecordingSessionByAlias_Call

func (*PersistenceManager_GetRecordingSessionByAlias_Call) RunAndReturn 

func (_c *PersistenceManager_GetRecordingSessionByAlias_Call) RunAndReturn(run func(ctxt context.Context, alias string) (common.Recording, error)) *PersistenceManager_GetRecordingSessionByAlias_Call

type PersistenceManager_GetRecordingSession_Call 

type PersistenceManager_GetRecordingSession_Call struct {
	*mock.Call
}

PersistenceManager_GetRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingSession'

func (*PersistenceManager_GetRecordingSession_Call) Return 

func (_c *PersistenceManager_GetRecordingSession_Call) Return(recording common.Recording, err error) *PersistenceManager_GetRecordingSession_Call

func (*PersistenceManager_GetRecordingSession_Call) Run 

func (_c *PersistenceManager_GetRecordingSession_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_GetRecordingSession_Call

func (*PersistenceManager_GetRecordingSession_Call) RunAndReturn 

func (_c *PersistenceManager_GetRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, id string) (common.Recording, error)) *PersistenceManager_GetRecordingSession_Call

type PersistenceManager_GetVideoSourceByName_Call 

type PersistenceManager_GetVideoSourceByName_Call struct {
	*mock.Call
}

PersistenceManager_GetVideoSourceByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVideoSourceByName'

func (*PersistenceManager_GetVideoSourceByName_Call) Return 

func (_c *PersistenceManager_GetVideoSourceByName_Call) Return(videoSource common.VideoSource, err error) *PersistenceManager_GetVideoSourceByName_Call

func (*PersistenceManager_GetVideoSourceByName_Call) Run 

func (_c *PersistenceManager_GetVideoSourceByName_Call) Run(run func(ctxt context.Context, name string)) *PersistenceManager_GetVideoSourceByName_Call

func (*PersistenceManager_GetVideoSourceByName_Call) RunAndReturn 

func (_c *PersistenceManager_GetVideoSourceByName_Call) RunAndReturn(run func(ctxt context.Context, name string) (common.VideoSource, error)) *PersistenceManager_GetVideoSourceByName_Call

type PersistenceManager_GetVideoSource_Call 

type PersistenceManager_GetVideoSource_Call struct {
	*mock.Call
}

PersistenceManager_GetVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVideoSource'

func (*PersistenceManager_GetVideoSource_Call) Return 

func (_c *PersistenceManager_GetVideoSource_Call) Return(videoSource common.VideoSource, err error) *PersistenceManager_GetVideoSource_Call

func (*PersistenceManager_GetVideoSource_Call) Run 

func (_c *PersistenceManager_GetVideoSource_Call) Run(run func(ctxt context.Context, id string)) *PersistenceManager_GetVideoSource_Call

func (*PersistenceManager_GetVideoSource_Call) RunAndReturn 

func (_c *PersistenceManager_GetVideoSource_Call) RunAndReturn(run func(ctxt context.Context, id string) (common.VideoSource, error)) *PersistenceManager_GetVideoSource_Call

type PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call 

type PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call struct {
	*mock.Call
}

PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllLiveStreamSegmentsAfterTime'

func (*PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call) Return 

func (_c *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call) Return(videoSegments []common.VideoSegment, err error) *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call

func (*PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call) Run 

func (_c *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call) Run(run func(ctxt context.Context, sourceID string, timestamp time.Time)) *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call

func (*PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call) RunAndReturn 

func (_c *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, timestamp time.Time) ([]common.VideoSegment, error)) *PersistenceManager_ListAllLiveStreamSegmentsAfterTime_Call

type PersistenceManager_ListAllLiveStreamSegments_Call 

type PersistenceManager_ListAllLiveStreamSegments_Call struct {
	*mock.Call
}

PersistenceManager_ListAllLiveStreamSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllLiveStreamSegments'

func (*PersistenceManager_ListAllLiveStreamSegments_Call) Return 

func (_c *PersistenceManager_ListAllLiveStreamSegments_Call) Return(videoSegments []common.VideoSegment, err error) *PersistenceManager_ListAllLiveStreamSegments_Call

func (*PersistenceManager_ListAllLiveStreamSegments_Call) Run 

func (_c *PersistenceManager_ListAllLiveStreamSegments_Call) Run(run func(ctxt context.Context, sourceID string)) *PersistenceManager_ListAllLiveStreamSegments_Call

func (*PersistenceManager_ListAllLiveStreamSegments_Call) RunAndReturn 

func (_c *PersistenceManager_ListAllLiveStreamSegments_Call) RunAndReturn(run func(ctxt context.Context, sourceID string) ([]common.VideoSegment, error)) *PersistenceManager_ListAllLiveStreamSegments_Call

type PersistenceManager_ListAllRecordingSegments_Call 

type PersistenceManager_ListAllRecordingSegments_Call struct {
	*mock.Call
}

PersistenceManager_ListAllRecordingSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllRecordingSegments'

func (*PersistenceManager_ListAllRecordingSegments_Call) Return 

func (_c *PersistenceManager_ListAllRecordingSegments_Call) Return(videoSegments []common.VideoSegment, err error) *PersistenceManager_ListAllRecordingSegments_Call

func (*PersistenceManager_ListAllRecordingSegments_Call) Run 

func (_c *PersistenceManager_ListAllRecordingSegments_Call) Run(run func(ctxt context.Context)) *PersistenceManager_ListAllRecordingSegments_Call

func (*PersistenceManager_ListAllRecordingSegments_Call) RunAndReturn 

func (_c *PersistenceManager_ListAllRecordingSegments_Call) RunAndReturn(run func(ctxt context.Context) ([]common.VideoSegment, error)) *PersistenceManager_ListAllRecordingSegments_Call

type PersistenceManager_ListAllSegmentsOfRecording_Call 

type PersistenceManager_ListAllSegmentsOfRecording_Call struct {
	*mock.Call
}

PersistenceManager_ListAllSegmentsOfRecording_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllSegmentsOfRecording'

func (*PersistenceManager_ListAllSegmentsOfRecording_Call) Return 

func (_c *PersistenceManager_ListAllSegmentsOfRecording_Call) Return(videoSegments []common.VideoSegment, err error) *PersistenceManager_ListAllSegmentsOfRecording_Call

func (*PersistenceManager_ListAllSegmentsOfRecording_Call) Run 

func (_c *PersistenceManager_ListAllSegmentsOfRecording_Call) Run(run func(ctxt context.Context, recordingID string)) *PersistenceManager_ListAllSegmentsOfRecording_Call

func (*PersistenceManager_ListAllSegmentsOfRecording_Call) RunAndReturn 

func (_c *PersistenceManager_ListAllSegmentsOfRecording_Call) RunAndReturn(run func(ctxt context.Context, recordingID string) ([]common.VideoSegment, error)) *PersistenceManager_ListAllSegmentsOfRecording_Call

type PersistenceManager_ListRecordingSessionsOfSource_Call 

type PersistenceManager_ListRecordingSessionsOfSource_Call struct {
	*mock.Call
}

PersistenceManager_ListRecordingSessionsOfSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListRecordingSessionsOfSource'

func (*PersistenceManager_ListRecordingSessionsOfSource_Call) Return 

func (_c *PersistenceManager_ListRecordingSessionsOfSource_Call) Return(recordings []common.Recording, err error) *PersistenceManager_ListRecordingSessionsOfSource_Call

func (*PersistenceManager_ListRecordingSessionsOfSource_Call) Run 

func (_c *PersistenceManager_ListRecordingSessionsOfSource_Call) Run(run func(ctxt context.Context, sourceID string, active bool)) *PersistenceManager_ListRecordingSessionsOfSource_Call

func (*PersistenceManager_ListRecordingSessionsOfSource_Call) RunAndReturn 

func (_c *PersistenceManager_ListRecordingSessionsOfSource_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, active bool) ([]common.Recording, error)) *PersistenceManager_ListRecordingSessionsOfSource_Call

type PersistenceManager_ListRecordingSessions_Call 

type PersistenceManager_ListRecordingSessions_Call struct {
	*mock.Call
}

PersistenceManager_ListRecordingSessions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListRecordingSessions'

func (*PersistenceManager_ListRecordingSessions_Call) Return 

func (_c *PersistenceManager_ListRecordingSessions_Call) Return(recordings []common.Recording, err error) *PersistenceManager_ListRecordingSessions_Call

func (*PersistenceManager_ListRecordingSessions_Call) Run 

func (_c *PersistenceManager_ListRecordingSessions_Call) Run(run func(ctxt context.Context)) *PersistenceManager_ListRecordingSessions_Call

func (*PersistenceManager_ListRecordingSessions_Call) RunAndReturn 

func (_c *PersistenceManager_ListRecordingSessions_Call) RunAndReturn(run func(ctxt context.Context) ([]common.Recording, error)) *PersistenceManager_ListRecordingSessions_Call

type PersistenceManager_ListVideoSources_Call 

type PersistenceManager_ListVideoSources_Call struct {
	*mock.Call
}

PersistenceManager_ListVideoSources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListVideoSources'

func (*PersistenceManager_ListVideoSources_Call) Return 

func (_c *PersistenceManager_ListVideoSources_Call) Return(videoSources []common.VideoSource, err error) *PersistenceManager_ListVideoSources_Call

func (*PersistenceManager_ListVideoSources_Call) Run 

func (_c *PersistenceManager_ListVideoSources_Call) Run(run func(ctxt context.Context)) *PersistenceManager_ListVideoSources_Call

func (*PersistenceManager_ListVideoSources_Call) RunAndReturn 

func (_c *PersistenceManager_ListVideoSources_Call) RunAndReturn(run func(ctxt context.Context) ([]common.VideoSource, error)) *PersistenceManager_ListVideoSources_Call

type PersistenceManager_MarkEndOfRecordingSession_Call 

type PersistenceManager_MarkEndOfRecordingSession_Call struct {
	*mock.Call
}

PersistenceManager_MarkEndOfRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkEndOfRecordingSession'

func (*PersistenceManager_MarkEndOfRecordingSession_Call) Return 

func (_c *PersistenceManager_MarkEndOfRecordingSession_Call) Return(err error) *PersistenceManager_MarkEndOfRecordingSession_Call

func (*PersistenceManager_MarkEndOfRecordingSession_Call) Run 

func (_c *PersistenceManager_MarkEndOfRecordingSession_Call) Run(run func(ctxt context.Context, id string, endTime time.Time)) *PersistenceManager_MarkEndOfRecordingSession_Call

func (*PersistenceManager_MarkEndOfRecordingSession_Call) RunAndReturn 

func (_c *PersistenceManager_MarkEndOfRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, id string, endTime time.Time) error) *PersistenceManager_MarkEndOfRecordingSession_Call

type PersistenceManager_MarkExternalError_Call 

type PersistenceManager_MarkExternalError_Call struct {
	*mock.Call
}

PersistenceManager_MarkExternalError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkExternalError'

func (*PersistenceManager_MarkExternalError_Call) Return 

func (_c *PersistenceManager_MarkExternalError_Call) Return() *PersistenceManager_MarkExternalError_Call

func (*PersistenceManager_MarkExternalError_Call) Run 

func (_c *PersistenceManager_MarkExternalError_Call) Run(run func(err error)) *PersistenceManager_MarkExternalError_Call

func (*PersistenceManager_MarkExternalError_Call) RunAndReturn 

func (_c *PersistenceManager_MarkExternalError_Call) RunAndReturn(run func(err error)) *PersistenceManager_MarkExternalError_Call

type PersistenceManager_MarkLiveStreamSegmentsUploaded_Call 

type PersistenceManager_MarkLiveStreamSegmentsUploaded_Call struct {
	*mock.Call
}

PersistenceManager_MarkLiveStreamSegmentsUploaded_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkLiveStreamSegmentsUploaded'

func (*PersistenceManager_MarkLiveStreamSegmentsUploaded_Call) Return 

func (_c *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call) Return(err error) *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call

func (*PersistenceManager_MarkLiveStreamSegmentsUploaded_Call) Run 

func (_c *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call) Run(run func(ctxt context.Context, ids []string)) *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call

func (*PersistenceManager_MarkLiveStreamSegmentsUploaded_Call) RunAndReturn 

func (_c *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call) RunAndReturn(run func(ctxt context.Context, ids []string) error) *PersistenceManager_MarkLiveStreamSegmentsUploaded_Call

type PersistenceManager_Ready_Call 

type PersistenceManager_Ready_Call struct {
	*mock.Call
}

PersistenceManager_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*PersistenceManager_Ready_Call) Return 

func (_c *PersistenceManager_Ready_Call) Return(err error) *PersistenceManager_Ready_Call

func (*PersistenceManager_Ready_Call) Run 

func (_c *PersistenceManager_Ready_Call) Run(run func(ctxt context.Context)) *PersistenceManager_Ready_Call

func (*PersistenceManager_Ready_Call) RunAndReturn 

func (_c *PersistenceManager_Ready_Call) RunAndReturn(run func(ctxt context.Context) error) *PersistenceManager_Ready_Call

type PersistenceManager_RecordKnownRecordingSession_Call 

type PersistenceManager_RecordKnownRecordingSession_Call struct {
	*mock.Call
}

PersistenceManager_RecordKnownRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordKnownRecordingSession'

func (*PersistenceManager_RecordKnownRecordingSession_Call) Return 

func (_c *PersistenceManager_RecordKnownRecordingSession_Call) Return(err error) *PersistenceManager_RecordKnownRecordingSession_Call

func (*PersistenceManager_RecordKnownRecordingSession_Call) Run 

func (_c *PersistenceManager_RecordKnownRecordingSession_Call) Run(run func(ctxt context.Context, entry common.Recording)) *PersistenceManager_RecordKnownRecordingSession_Call

func (*PersistenceManager_RecordKnownRecordingSession_Call) RunAndReturn 

func (_c *PersistenceManager_RecordKnownRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, entry common.Recording) error) *PersistenceManager_RecordKnownRecordingSession_Call

type PersistenceManager_RecordKnownVideoSource_Call 

type PersistenceManager_RecordKnownVideoSource_Call struct {
	*mock.Call
}

PersistenceManager_RecordKnownVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordKnownVideoSource'

func (*PersistenceManager_RecordKnownVideoSource_Call) Return 

func (_c *PersistenceManager_RecordKnownVideoSource_Call) Return(err error) *PersistenceManager_RecordKnownVideoSource_Call

func (*PersistenceManager_RecordKnownVideoSource_Call) Run 

func (_c *PersistenceManager_RecordKnownVideoSource_Call) Run(run func(ctxt context.Context, id string, name string, segmentLen int, playlistURI *string, description *string, streaming int)) *PersistenceManager_RecordKnownVideoSource_Call

func (*PersistenceManager_RecordKnownVideoSource_Call) RunAndReturn 

func (_c *PersistenceManager_RecordKnownVideoSource_Call) RunAndReturn(run func(ctxt context.Context, id string, name string, segmentLen int, playlistURI *string, description *string, streaming int) error) *PersistenceManager_RecordKnownVideoSource_Call

type PersistenceManager_RegisterLiveStreamSegment_Call 

type PersistenceManager_RegisterLiveStreamSegment_Call struct {
	*mock.Call
}

PersistenceManager_RegisterLiveStreamSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterLiveStreamSegment'

func (*PersistenceManager_RegisterLiveStreamSegment_Call) Return 

func (_c *PersistenceManager_RegisterLiveStreamSegment_Call) Return(s string, err error) *PersistenceManager_RegisterLiveStreamSegment_Call

func (*PersistenceManager_RegisterLiveStreamSegment_Call) Run 

func (_c *PersistenceManager_RegisterLiveStreamSegment_Call) Run(run func(ctxt context.Context, sourceID string, segment hls.Segment)) *PersistenceManager_RegisterLiveStreamSegment_Call

func (*PersistenceManager_RegisterLiveStreamSegment_Call) RunAndReturn 

func (_c *PersistenceManager_RegisterLiveStreamSegment_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, segment hls.Segment) (string, error)) *PersistenceManager_RegisterLiveStreamSegment_Call

type PersistenceManager_RegisterRecordingSegments_Call 

type PersistenceManager_RegisterRecordingSegments_Call struct {
	*mock.Call
}

PersistenceManager_RegisterRecordingSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterRecordingSegments'

func (*PersistenceManager_RegisterRecordingSegments_Call) Return 

func (_c *PersistenceManager_RegisterRecordingSegments_Call) Return(err error) *PersistenceManager_RegisterRecordingSegments_Call

func (*PersistenceManager_RegisterRecordingSegments_Call) Run 

func (_c *PersistenceManager_RegisterRecordingSegments_Call) Run(run func(ctxt context.Context, recordingIDs []string, segments []common.VideoSegment)) *PersistenceManager_RegisterRecordingSegments_Call

func (*PersistenceManager_RegisterRecordingSegments_Call) RunAndReturn 

func (_c *PersistenceManager_RegisterRecordingSegments_Call) RunAndReturn(run func(ctxt context.Context, recordingIDs []string, segments []common.VideoSegment) error) *PersistenceManager_RegisterRecordingSegments_Call

type PersistenceManager_UpdateRecordingSession_Call 

type PersistenceManager_UpdateRecordingSession_Call struct {
	*mock.Call
}

PersistenceManager_UpdateRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateRecordingSession'

func (*PersistenceManager_UpdateRecordingSession_Call) Return 

func (_c *PersistenceManager_UpdateRecordingSession_Call) Return(err error) *PersistenceManager_UpdateRecordingSession_Call

func (*PersistenceManager_UpdateRecordingSession_Call) Run 

func (_c *PersistenceManager_UpdateRecordingSession_Call) Run(run func(ctxt context.Context, newSetting common.Recording)) *PersistenceManager_UpdateRecordingSession_Call

func (*PersistenceManager_UpdateRecordingSession_Call) RunAndReturn 

func (_c *PersistenceManager_UpdateRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, newSetting common.Recording) error) *PersistenceManager_UpdateRecordingSession_Call

type PersistenceManager_UpdateVideoSourceStats_Call 

type PersistenceManager_UpdateVideoSourceStats_Call struct {
	*mock.Call
}

PersistenceManager_UpdateVideoSourceStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateVideoSourceStats'

func (*PersistenceManager_UpdateVideoSourceStats_Call) Return 

func (_c *PersistenceManager_UpdateVideoSourceStats_Call) Return(err error) *PersistenceManager_UpdateVideoSourceStats_Call

func (*PersistenceManager_UpdateVideoSourceStats_Call) Run 

func (_c *PersistenceManager_UpdateVideoSourceStats_Call) Run(run func(ctxt context.Context, id string, reqRespTargetID string, sourceLocalTime time.Time)) *PersistenceManager_UpdateVideoSourceStats_Call

func (*PersistenceManager_UpdateVideoSourceStats_Call) RunAndReturn 

func (_c *PersistenceManager_UpdateVideoSourceStats_Call) RunAndReturn(run func(ctxt context.Context, id string, reqRespTargetID string, sourceLocalTime time.Time) error) *PersistenceManager_UpdateVideoSourceStats_Call

type PersistenceManager_UpdateVideoSource_Call 

type PersistenceManager_UpdateVideoSource_Call struct {
	*mock.Call
}

PersistenceManager_UpdateVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateVideoSource'

func (*PersistenceManager_UpdateVideoSource_Call) Return 

func (_c *PersistenceManager_UpdateVideoSource_Call) Return(err error) *PersistenceManager_UpdateVideoSource_Call

func (*PersistenceManager_UpdateVideoSource_Call) Run 

func (_c *PersistenceManager_UpdateVideoSource_Call) Run(run func(ctxt context.Context, newSetting common.VideoSource)) *PersistenceManager_UpdateVideoSource_Call

func (*PersistenceManager_UpdateVideoSource_Call) RunAndReturn 

func (_c *PersistenceManager_UpdateVideoSource_Call) RunAndReturn(run func(ctxt context.Context, newSetting common.VideoSource) error) *PersistenceManager_UpdateVideoSource_Call

type PlaylistBuilder 

type PlaylistBuilder struct {
	mock.Mock
}

PlaylistBuilder is an autogenerated mock type for the PlaylistBuilder type

func NewPlaylistBuilder 

func NewPlaylistBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *PlaylistBuilder

NewPlaylistBuilder creates a new instance of PlaylistBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PlaylistBuilder) EXPECT 

func (_m *PlaylistBuilder) EXPECT() *PlaylistBuilder_Expecter

func (*PlaylistBuilder) GetLiveStreamPlaylist 

func (_mock *PlaylistBuilder) GetLiveStreamPlaylist(ctxt context.Context, target common.VideoSource, timestamp time.Time, addMediaSequence bool) (hls.Playlist, error)

GetLiveStreamPlaylist provides a mock function for the type PlaylistBuilder

func (*PlaylistBuilder) GetRecordingStreamPlaylist 

func (_mock *PlaylistBuilder) GetRecordingStreamPlaylist(ctxt context.Context, recording common.Recording) (hls.Playlist, error)

GetRecordingStreamPlaylist provides a mock function for the type PlaylistBuilder

type PlaylistBuilder_Expecter 

type PlaylistBuilder_Expecter struct {
	// contains filtered or unexported fields
}

func (*PlaylistBuilder_Expecter) GetLiveStreamPlaylist 

func (_e *PlaylistBuilder_Expecter) GetLiveStreamPlaylist(ctxt interface{}, target interface{}, timestamp interface{}, addMediaSequence interface{}) *PlaylistBuilder_GetLiveStreamPlaylist_Call

GetLiveStreamPlaylist is a helper method to define mock.On call

  • ctxt context.Context
  • target common.VideoSource
  • timestamp time.Time
  • addMediaSequence bool

func (*PlaylistBuilder_Expecter) GetRecordingStreamPlaylist 

func (_e *PlaylistBuilder_Expecter) GetRecordingStreamPlaylist(ctxt interface{}, recording interface{}) *PlaylistBuilder_GetRecordingStreamPlaylist_Call

GetRecordingStreamPlaylist is a helper method to define mock.On call

  • ctxt context.Context
  • recording common.Recording

type PlaylistBuilder_GetLiveStreamPlaylist_Call 

type PlaylistBuilder_GetLiveStreamPlaylist_Call struct {
	*mock.Call
}

PlaylistBuilder_GetLiveStreamPlaylist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLiveStreamPlaylist'

func (*PlaylistBuilder_GetLiveStreamPlaylist_Call) Return 

func (_c *PlaylistBuilder_GetLiveStreamPlaylist_Call) Return(playlist hls.Playlist, err error) *PlaylistBuilder_GetLiveStreamPlaylist_Call

func (*PlaylistBuilder_GetLiveStreamPlaylist_Call) Run 

func (_c *PlaylistBuilder_GetLiveStreamPlaylist_Call) Run(run func(ctxt context.Context, target common.VideoSource, timestamp time.Time, addMediaSequence bool)) *PlaylistBuilder_GetLiveStreamPlaylist_Call

func (*PlaylistBuilder_GetLiveStreamPlaylist_Call) RunAndReturn 

func (_c *PlaylistBuilder_GetLiveStreamPlaylist_Call) RunAndReturn(run func(ctxt context.Context, target common.VideoSource, timestamp time.Time, addMediaSequence bool) (hls.Playlist, error)) *PlaylistBuilder_GetLiveStreamPlaylist_Call

type PlaylistBuilder_GetRecordingStreamPlaylist_Call 

type PlaylistBuilder_GetRecordingStreamPlaylist_Call struct {
	*mock.Call
}

PlaylistBuilder_GetRecordingStreamPlaylist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingStreamPlaylist'

func (*PlaylistBuilder_GetRecordingStreamPlaylist_Call) Return 

func (_c *PlaylistBuilder_GetRecordingStreamPlaylist_Call) Return(playlist hls.Playlist, err error) *PlaylistBuilder_GetRecordingStreamPlaylist_Call

func (*PlaylistBuilder_GetRecordingStreamPlaylist_Call) Run 

func (_c *PlaylistBuilder_GetRecordingStreamPlaylist_Call) Run(run func(ctxt context.Context, recording common.Recording)) *PlaylistBuilder_GetRecordingStreamPlaylist_Call

func (*PlaylistBuilder_GetRecordingStreamPlaylist_Call) RunAndReturn 

func (_c *PlaylistBuilder_GetRecordingStreamPlaylist_Call) RunAndReturn(run func(ctxt context.Context, recording common.Recording) (hls.Playlist, error)) *PlaylistBuilder_GetRecordingStreamPlaylist_Call

type PlaylistManager 

type PlaylistManager struct {
	mock.Mock
}

PlaylistManager is an autogenerated mock type for the PlaylistManager type

func NewPlaylistManager 

func NewPlaylistManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *PlaylistManager

NewPlaylistManager creates a new instance of PlaylistManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PlaylistManager) EXPECT 

func (_m *PlaylistManager) EXPECT() *PlaylistManager_Expecter

func (*PlaylistManager) GetLiveStreamPlaylist 

func (_mock *PlaylistManager) GetLiveStreamPlaylist(ctxt context.Context, target common.VideoSource, timestamp time.Time, addMediaSequence bool) (hls.Playlist, error)

GetLiveStreamPlaylist provides a mock function for the type PlaylistManager

func (*PlaylistManager) GetRecordingStreamPlaylist 

func (_mock *PlaylistManager) GetRecordingStreamPlaylist(ctxt context.Context, recording common.Recording) (hls.Playlist, error)

GetRecordingStreamPlaylist provides a mock function for the type PlaylistManager

func (*PlaylistManager) GetSegment 

func (_mock *PlaylistManager) GetSegment(ctxt context.Context, target common.VideoSegment) ([]byte, error)

GetSegment provides a mock function for the type PlaylistManager

func (*PlaylistManager) Stop 

func (_mock *PlaylistManager) Stop(ctxt context.Context) error

Stop provides a mock function for the type PlaylistManager

type PlaylistManager_Expecter 

type PlaylistManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*PlaylistManager_Expecter) GetLiveStreamPlaylist 

func (_e *PlaylistManager_Expecter) GetLiveStreamPlaylist(ctxt interface{}, target interface{}, timestamp interface{}, addMediaSequence interface{}) *PlaylistManager_GetLiveStreamPlaylist_Call

GetLiveStreamPlaylist is a helper method to define mock.On call

  • ctxt context.Context
  • target common.VideoSource
  • timestamp time.Time
  • addMediaSequence bool

func (*PlaylistManager_Expecter) GetRecordingStreamPlaylist 

func (_e *PlaylistManager_Expecter) GetRecordingStreamPlaylist(ctxt interface{}, recording interface{}) *PlaylistManager_GetRecordingStreamPlaylist_Call

GetRecordingStreamPlaylist is a helper method to define mock.On call

  • ctxt context.Context
  • recording common.Recording

func (*PlaylistManager_Expecter) GetSegment 

func (_e *PlaylistManager_Expecter) GetSegment(ctxt interface{}, target interface{}) *PlaylistManager_GetSegment_Call

GetSegment is a helper method to define mock.On call

  • ctxt context.Context
  • target common.VideoSegment

func (*PlaylistManager_Expecter) Stop 

func (_e *PlaylistManager_Expecter) Stop(ctxt interface{}) *PlaylistManager_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type PlaylistManager_GetLiveStreamPlaylist_Call 

type PlaylistManager_GetLiveStreamPlaylist_Call struct {
	*mock.Call
}

PlaylistManager_GetLiveStreamPlaylist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLiveStreamPlaylist'

func (*PlaylistManager_GetLiveStreamPlaylist_Call) Return 

func (_c *PlaylistManager_GetLiveStreamPlaylist_Call) Return(playlist hls.Playlist, err error) *PlaylistManager_GetLiveStreamPlaylist_Call

func (*PlaylistManager_GetLiveStreamPlaylist_Call) Run 

func (_c *PlaylistManager_GetLiveStreamPlaylist_Call) Run(run func(ctxt context.Context, target common.VideoSource, timestamp time.Time, addMediaSequence bool)) *PlaylistManager_GetLiveStreamPlaylist_Call

func (*PlaylistManager_GetLiveStreamPlaylist_Call) RunAndReturn 

func (_c *PlaylistManager_GetLiveStreamPlaylist_Call) RunAndReturn(run func(ctxt context.Context, target common.VideoSource, timestamp time.Time, addMediaSequence bool) (hls.Playlist, error)) *PlaylistManager_GetLiveStreamPlaylist_Call

type PlaylistManager_GetRecordingStreamPlaylist_Call 

type PlaylistManager_GetRecordingStreamPlaylist_Call struct {
	*mock.Call
}

PlaylistManager_GetRecordingStreamPlaylist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingStreamPlaylist'

func (*PlaylistManager_GetRecordingStreamPlaylist_Call) Return 

func (_c *PlaylistManager_GetRecordingStreamPlaylist_Call) Return(playlist hls.Playlist, err error) *PlaylistManager_GetRecordingStreamPlaylist_Call

func (*PlaylistManager_GetRecordingStreamPlaylist_Call) Run 

func (_c *PlaylistManager_GetRecordingStreamPlaylist_Call) Run(run func(ctxt context.Context, recording common.Recording)) *PlaylistManager_GetRecordingStreamPlaylist_Call

func (*PlaylistManager_GetRecordingStreamPlaylist_Call) RunAndReturn 

func (_c *PlaylistManager_GetRecordingStreamPlaylist_Call) RunAndReturn(run func(ctxt context.Context, recording common.Recording) (hls.Playlist, error)) *PlaylistManager_GetRecordingStreamPlaylist_Call

type PlaylistManager_GetSegment_Call 

type PlaylistManager_GetSegment_Call struct {
	*mock.Call
}

PlaylistManager_GetSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSegment'

func (*PlaylistManager_GetSegment_Call) Return 

func (_c *PlaylistManager_GetSegment_Call) Return(bytes []byte, err error) *PlaylistManager_GetSegment_Call

func (*PlaylistManager_GetSegment_Call) Run 

func (_c *PlaylistManager_GetSegment_Call) Run(run func(ctxt context.Context, target common.VideoSegment)) *PlaylistManager_GetSegment_Call

func (*PlaylistManager_GetSegment_Call) RunAndReturn 

func (_c *PlaylistManager_GetSegment_Call) RunAndReturn(run func(ctxt context.Context, target common.VideoSegment) ([]byte, error)) *PlaylistManager_GetSegment_Call

type PlaylistManager_Stop_Call 

type PlaylistManager_Stop_Call struct {
	*mock.Call
}

PlaylistManager_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*PlaylistManager_Stop_Call) Return 

func (_c *PlaylistManager_Stop_Call) Return(err error) *PlaylistManager_Stop_Call

func (*PlaylistManager_Stop_Call) Run 

func (_c *PlaylistManager_Stop_Call) Run(run func(ctxt context.Context)) *PlaylistManager_Stop_Call

func (*PlaylistManager_Stop_Call) RunAndReturn 

func (_c *PlaylistManager_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *PlaylistManager_Stop_Call

type RecordingSegmentForwarder 

type RecordingSegmentForwarder struct {
	mock.Mock
}

RecordingSegmentForwarder is an autogenerated mock type for the RecordingSegmentForwarder type

func NewRecordingSegmentForwarder 

func NewRecordingSegmentForwarder(t interface {
	mock.TestingT
	Cleanup(func())
}) *RecordingSegmentForwarder

NewRecordingSegmentForwarder creates a new instance of RecordingSegmentForwarder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RecordingSegmentForwarder) EXPECT 

func (_m *RecordingSegmentForwarder) EXPECT() *RecordingSegmentForwarder_Expecter

func (*RecordingSegmentForwarder) ForwardSegment 

func (_mock *RecordingSegmentForwarder) ForwardSegment(ctxt context.Context, recordings []string, segments []common.VideoSegmentWithData) error

ForwardSegment provides a mock function for the type RecordingSegmentForwarder

func (*RecordingSegmentForwarder) Stop 

func (_mock *RecordingSegmentForwarder) Stop(ctxt context.Context) error

Stop provides a mock function for the type RecordingSegmentForwarder

type RecordingSegmentForwarder_Expecter 

type RecordingSegmentForwarder_Expecter struct {
	// contains filtered or unexported fields
}

func (*RecordingSegmentForwarder_Expecter) ForwardSegment 

func (_e *RecordingSegmentForwarder_Expecter) ForwardSegment(ctxt interface{}, recordings interface{}, segments interface{}) *RecordingSegmentForwarder_ForwardSegment_Call

ForwardSegment is a helper method to define mock.On call

  • ctxt context.Context
  • recordings []string
  • segments []common.VideoSegmentWithData

func (*RecordingSegmentForwarder_Expecter) Stop 

func (_e *RecordingSegmentForwarder_Expecter) Stop(ctxt interface{}) *RecordingSegmentForwarder_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type RecordingSegmentForwarder_ForwardSegment_Call 

type RecordingSegmentForwarder_ForwardSegment_Call struct {
	*mock.Call
}

RecordingSegmentForwarder_ForwardSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForwardSegment'

func (*RecordingSegmentForwarder_ForwardSegment_Call) Return 

func (_c *RecordingSegmentForwarder_ForwardSegment_Call) Return(err error) *RecordingSegmentForwarder_ForwardSegment_Call

func (*RecordingSegmentForwarder_ForwardSegment_Call) Run 

func (_c *RecordingSegmentForwarder_ForwardSegment_Call) Run(run func(ctxt context.Context, recordings []string, segments []common.VideoSegmentWithData)) *RecordingSegmentForwarder_ForwardSegment_Call

func (*RecordingSegmentForwarder_ForwardSegment_Call) RunAndReturn 

func (_c *RecordingSegmentForwarder_ForwardSegment_Call) RunAndReturn(run func(ctxt context.Context, recordings []string, segments []common.VideoSegmentWithData) error) *RecordingSegmentForwarder_ForwardSegment_Call

type RecordingSegmentForwarder_Stop_Call 

type RecordingSegmentForwarder_Stop_Call struct {
	*mock.Call
}

RecordingSegmentForwarder_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*RecordingSegmentForwarder_Stop_Call) Return 

func (_c *RecordingSegmentForwarder_Stop_Call) Return(err error) *RecordingSegmentForwarder_Stop_Call

func (*RecordingSegmentForwarder_Stop_Call) Run 

func (_c *RecordingSegmentForwarder_Stop_Call) Run(run func(ctxt context.Context)) *RecordingSegmentForwarder_Stop_Call

func (*RecordingSegmentForwarder_Stop_Call) RunAndReturn 

func (_c *RecordingSegmentForwarder_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *RecordingSegmentForwarder_Stop_Call

type RequestResponseClient 

type RequestResponseClient struct {
	mock.Mock
}

RequestResponseClient is an autogenerated mock type for the RequestResponseClient type

func NewRequestResponseClient 

func NewRequestResponseClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *RequestResponseClient

NewRequestResponseClient creates a new instance of RequestResponseClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RequestResponseClient) EXPECT 

func (_m *RequestResponseClient) EXPECT() *RequestResponseClient_Expecter

func (*RequestResponseClient) Request 

func (_mock *RequestResponseClient) Request(ctxt context.Context, targetID string, message []byte, metadata map[string]string, callParam goutils.RequestCallParam) (string, error)

Request provides a mock function for the type RequestResponseClient

func (*RequestResponseClient) Respond 

func (_mock *RequestResponseClient) Respond(ctxt context.Context, originalReq goutils.ReqRespMessage, message []byte, metadata map[string]string, blocking bool) error

Respond provides a mock function for the type RequestResponseClient

func (*RequestResponseClient) SetInboundRequestHandler 

func (_mock *RequestResponseClient) SetInboundRequestHandler(ctxt context.Context, handler goutils.ReqRespMessageHandler) error

SetInboundRequestHandler provides a mock function for the type RequestResponseClient

func (*RequestResponseClient) Stop 

func (_mock *RequestResponseClient) Stop(ctxt context.Context) error

Stop provides a mock function for the type RequestResponseClient

type RequestResponseClient_Expecter 

type RequestResponseClient_Expecter struct {
	// contains filtered or unexported fields
}

func (*RequestResponseClient_Expecter) Request 

func (_e *RequestResponseClient_Expecter) Request(ctxt interface{}, targetID interface{}, message interface{}, metadata interface{}, callParam interface{}) *RequestResponseClient_Request_Call

Request is a helper method to define mock.On call

  • ctxt context.Context
  • targetID string
  • message []byte
  • metadata map[string]string
  • callParam goutils.RequestCallParam

func (*RequestResponseClient_Expecter) Respond 

func (_e *RequestResponseClient_Expecter) Respond(ctxt interface{}, originalReq interface{}, message interface{}, metadata interface{}, blocking interface{}) *RequestResponseClient_Respond_Call

Respond is a helper method to define mock.On call

  • ctxt context.Context
  • originalReq goutils.ReqRespMessage
  • message []byte
  • metadata map[string]string
  • blocking bool

func (*RequestResponseClient_Expecter) SetInboundRequestHandler 

func (_e *RequestResponseClient_Expecter) SetInboundRequestHandler(ctxt interface{}, handler interface{}) *RequestResponseClient_SetInboundRequestHandler_Call

SetInboundRequestHandler is a helper method to define mock.On call

  • ctxt context.Context
  • handler goutils.ReqRespMessageHandler

func (*RequestResponseClient_Expecter) Stop 

func (_e *RequestResponseClient_Expecter) Stop(ctxt interface{}) *RequestResponseClient_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type RequestResponseClient_Request_Call 

type RequestResponseClient_Request_Call struct {
	*mock.Call
}

RequestResponseClient_Request_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Request'

func (*RequestResponseClient_Request_Call) Return 

func (_c *RequestResponseClient_Request_Call) Return(s string, err error) *RequestResponseClient_Request_Call

func (*RequestResponseClient_Request_Call) Run 

func (_c *RequestResponseClient_Request_Call) Run(run func(ctxt context.Context, targetID string, message []byte, metadata map[string]string, callParam goutils.RequestCallParam)) *RequestResponseClient_Request_Call

func (*RequestResponseClient_Request_Call) RunAndReturn 

func (_c *RequestResponseClient_Request_Call) RunAndReturn(run func(ctxt context.Context, targetID string, message []byte, metadata map[string]string, callParam goutils.RequestCallParam) (string, error)) *RequestResponseClient_Request_Call

type RequestResponseClient_Respond_Call 

type RequestResponseClient_Respond_Call struct {
	*mock.Call
}

RequestResponseClient_Respond_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Respond'

func (*RequestResponseClient_Respond_Call) Return 

func (_c *RequestResponseClient_Respond_Call) Return(err error) *RequestResponseClient_Respond_Call

func (*RequestResponseClient_Respond_Call) Run 

func (_c *RequestResponseClient_Respond_Call) Run(run func(ctxt context.Context, originalReq goutils.ReqRespMessage, message []byte, metadata map[string]string, blocking bool)) *RequestResponseClient_Respond_Call

func (*RequestResponseClient_Respond_Call) RunAndReturn 

func (_c *RequestResponseClient_Respond_Call) RunAndReturn(run func(ctxt context.Context, originalReq goutils.ReqRespMessage, message []byte, metadata map[string]string, blocking bool) error) *RequestResponseClient_Respond_Call

type RequestResponseClient_SetInboundRequestHandler_Call 

type RequestResponseClient_SetInboundRequestHandler_Call struct {
	*mock.Call
}

RequestResponseClient_SetInboundRequestHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetInboundRequestHandler'

func (*RequestResponseClient_SetInboundRequestHandler_Call) Return 

func (_c *RequestResponseClient_SetInboundRequestHandler_Call) Return(err error) *RequestResponseClient_SetInboundRequestHandler_Call

func (*RequestResponseClient_SetInboundRequestHandler_Call) Run 

func (_c *RequestResponseClient_SetInboundRequestHandler_Call) Run(run func(ctxt context.Context, handler goutils.ReqRespMessageHandler)) *RequestResponseClient_SetInboundRequestHandler_Call

func (*RequestResponseClient_SetInboundRequestHandler_Call) RunAndReturn 

func (_c *RequestResponseClient_SetInboundRequestHandler_Call) RunAndReturn(run func(ctxt context.Context, handler goutils.ReqRespMessageHandler) error) *RequestResponseClient_SetInboundRequestHandler_Call

type RequestResponseClient_Stop_Call 

type RequestResponseClient_Stop_Call struct {
	*mock.Call
}

RequestResponseClient_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*RequestResponseClient_Stop_Call) Return 

func (_c *RequestResponseClient_Stop_Call) Return(err error) *RequestResponseClient_Stop_Call

func (*RequestResponseClient_Stop_Call) Run 

func (_c *RequestResponseClient_Stop_Call) Run(run func(ctxt context.Context)) *RequestResponseClient_Stop_Call

func (*RequestResponseClient_Stop_Call) RunAndReturn 

func (_c *RequestResponseClient_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *RequestResponseClient_Stop_Call

type S3Client 

type S3Client struct {
	mock.Mock
}

S3Client is an autogenerated mock type for the S3Client type

func NewS3Client 

func NewS3Client(t interface {
	mock.TestingT
	Cleanup(func())
}) *S3Client

NewS3Client creates a new instance of S3Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*S3Client) CreateBucket 

func (_mock *S3Client) CreateBucket(ctxt context.Context, bucketName string) error

CreateBucket provides a mock function for the type S3Client

func (*S3Client) DeleteBucket 

func (_mock *S3Client) DeleteBucket(ctxt context.Context, bucketName string) error

DeleteBucket provides a mock function for the type S3Client

func (*S3Client) DeleteObject 

func (_mock *S3Client) DeleteObject(ctxt context.Context, bucketName string, objectKey string) error

DeleteObject provides a mock function for the type S3Client

func (*S3Client) DeleteObjects 

func (_mock *S3Client) DeleteObjects(ctxt context.Context, bucketName string, objectKeys []string) []utils.S3BulkDeleteError

DeleteObjects provides a mock function for the type S3Client

func (*S3Client) EXPECT 

func (_m *S3Client) EXPECT() *S3Client_Expecter

func (*S3Client) GetObject 

func (_mock *S3Client) GetObject(ctxt context.Context, bucketName string, objectKey string) ([]byte, error)

GetObject provides a mock function for the type S3Client

func (*S3Client) ListBuckets 

func (_mock *S3Client) ListBuckets(ctxt context.Context) ([]string, error)

ListBuckets provides a mock function for the type S3Client

func (*S3Client) ListObjects 

func (_mock *S3Client) ListObjects(ctxt context.Context, bucket string, prefix *string) ([]string, error)

ListObjects provides a mock function for the type S3Client

func (*S3Client) PutObject 

func (_mock *S3Client) PutObject(ctxt context.Context, bucketName string, objectKey string, content []byte) error

PutObject provides a mock function for the type S3Client

type S3Client_CreateBucket_Call 

type S3Client_CreateBucket_Call struct {
	*mock.Call
}

S3Client_CreateBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateBucket'

func (*S3Client_CreateBucket_Call) Return 

func (_c *S3Client_CreateBucket_Call) Return(err error) *S3Client_CreateBucket_Call

func (*S3Client_CreateBucket_Call) Run 

func (_c *S3Client_CreateBucket_Call) Run(run func(ctxt context.Context, bucketName string)) *S3Client_CreateBucket_Call

func (*S3Client_CreateBucket_Call) RunAndReturn 

func (_c *S3Client_CreateBucket_Call) RunAndReturn(run func(ctxt context.Context, bucketName string) error) *S3Client_CreateBucket_Call

type S3Client_DeleteBucket_Call 

type S3Client_DeleteBucket_Call struct {
	*mock.Call
}

S3Client_DeleteBucket_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteBucket'

func (*S3Client_DeleteBucket_Call) Return 

func (_c *S3Client_DeleteBucket_Call) Return(err error) *S3Client_DeleteBucket_Call

func (*S3Client_DeleteBucket_Call) Run 

func (_c *S3Client_DeleteBucket_Call) Run(run func(ctxt context.Context, bucketName string)) *S3Client_DeleteBucket_Call

func (*S3Client_DeleteBucket_Call) RunAndReturn 

func (_c *S3Client_DeleteBucket_Call) RunAndReturn(run func(ctxt context.Context, bucketName string) error) *S3Client_DeleteBucket_Call

type S3Client_DeleteObject_Call 

type S3Client_DeleteObject_Call struct {
	*mock.Call
}

S3Client_DeleteObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteObject'

func (*S3Client_DeleteObject_Call) Return 

func (_c *S3Client_DeleteObject_Call) Return(err error) *S3Client_DeleteObject_Call

func (*S3Client_DeleteObject_Call) Run 

func (_c *S3Client_DeleteObject_Call) Run(run func(ctxt context.Context, bucketName string, objectKey string)) *S3Client_DeleteObject_Call

func (*S3Client_DeleteObject_Call) RunAndReturn 

func (_c *S3Client_DeleteObject_Call) RunAndReturn(run func(ctxt context.Context, bucketName string, objectKey string) error) *S3Client_DeleteObject_Call

type S3Client_DeleteObjects_Call 

type S3Client_DeleteObjects_Call struct {
	*mock.Call
}

S3Client_DeleteObjects_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteObjects'

func (*S3Client_DeleteObjects_Call) Return 

func (_c *S3Client_DeleteObjects_Call) Return(s3BulkDeleteErrors []utils.S3BulkDeleteError) *S3Client_DeleteObjects_Call

func (*S3Client_DeleteObjects_Call) Run 

func (_c *S3Client_DeleteObjects_Call) Run(run func(ctxt context.Context, bucketName string, objectKeys []string)) *S3Client_DeleteObjects_Call

func (*S3Client_DeleteObjects_Call) RunAndReturn 

func (_c *S3Client_DeleteObjects_Call) RunAndReturn(run func(ctxt context.Context, bucketName string, objectKeys []string) []utils.S3BulkDeleteError) *S3Client_DeleteObjects_Call

type S3Client_Expecter 

type S3Client_Expecter struct {
	// contains filtered or unexported fields
}

func (*S3Client_Expecter) CreateBucket 

func (_e *S3Client_Expecter) CreateBucket(ctxt interface{}, bucketName interface{}) *S3Client_CreateBucket_Call

CreateBucket is a helper method to define mock.On call

  • ctxt context.Context
  • bucketName string

func (*S3Client_Expecter) DeleteBucket 

func (_e *S3Client_Expecter) DeleteBucket(ctxt interface{}, bucketName interface{}) *S3Client_DeleteBucket_Call

DeleteBucket is a helper method to define mock.On call

  • ctxt context.Context
  • bucketName string

func (*S3Client_Expecter) DeleteObject 

func (_e *S3Client_Expecter) DeleteObject(ctxt interface{}, bucketName interface{}, objectKey interface{}) *S3Client_DeleteObject_Call

DeleteObject is a helper method to define mock.On call

  • ctxt context.Context
  • bucketName string
  • objectKey string

func (*S3Client_Expecter) DeleteObjects 

func (_e *S3Client_Expecter) DeleteObjects(ctxt interface{}, bucketName interface{}, objectKeys interface{}) *S3Client_DeleteObjects_Call

DeleteObjects is a helper method to define mock.On call

  • ctxt context.Context
  • bucketName string
  • objectKeys []string

func (*S3Client_Expecter) GetObject 

func (_e *S3Client_Expecter) GetObject(ctxt interface{}, bucketName interface{}, objectKey interface{}) *S3Client_GetObject_Call

GetObject is a helper method to define mock.On call

  • ctxt context.Context
  • bucketName string
  • objectKey string

func (*S3Client_Expecter) ListBuckets 

func (_e *S3Client_Expecter) ListBuckets(ctxt interface{}) *S3Client_ListBuckets_Call

ListBuckets is a helper method to define mock.On call

  • ctxt context.Context

func (*S3Client_Expecter) ListObjects 

func (_e *S3Client_Expecter) ListObjects(ctxt interface{}, bucket interface{}, prefix interface{}) *S3Client_ListObjects_Call

ListObjects is a helper method to define mock.On call

  • ctxt context.Context
  • bucket string
  • prefix *string

func (*S3Client_Expecter) PutObject 

func (_e *S3Client_Expecter) PutObject(ctxt interface{}, bucketName interface{}, objectKey interface{}, content interface{}) *S3Client_PutObject_Call

PutObject is a helper method to define mock.On call

  • ctxt context.Context
  • bucketName string
  • objectKey string
  • content []byte

type S3Client_GetObject_Call 

type S3Client_GetObject_Call struct {
	*mock.Call
}

S3Client_GetObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetObject'

func (*S3Client_GetObject_Call) Return 

func (_c *S3Client_GetObject_Call) Return(bytes []byte, err error) *S3Client_GetObject_Call

func (*S3Client_GetObject_Call) Run 

func (_c *S3Client_GetObject_Call) Run(run func(ctxt context.Context, bucketName string, objectKey string)) *S3Client_GetObject_Call

func (*S3Client_GetObject_Call) RunAndReturn 

func (_c *S3Client_GetObject_Call) RunAndReturn(run func(ctxt context.Context, bucketName string, objectKey string) ([]byte, error)) *S3Client_GetObject_Call

type S3Client_ListBuckets_Call 

type S3Client_ListBuckets_Call struct {
	*mock.Call
}

S3Client_ListBuckets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListBuckets'

func (*S3Client_ListBuckets_Call) Return 

func (_c *S3Client_ListBuckets_Call) Return(strings []string, err error) *S3Client_ListBuckets_Call

func (*S3Client_ListBuckets_Call) Run 

func (_c *S3Client_ListBuckets_Call) Run(run func(ctxt context.Context)) *S3Client_ListBuckets_Call

func (*S3Client_ListBuckets_Call) RunAndReturn 

func (_c *S3Client_ListBuckets_Call) RunAndReturn(run func(ctxt context.Context) ([]string, error)) *S3Client_ListBuckets_Call

type S3Client_ListObjects_Call 

type S3Client_ListObjects_Call struct {
	*mock.Call
}

S3Client_ListObjects_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListObjects'

func (*S3Client_ListObjects_Call) Return 

func (_c *S3Client_ListObjects_Call) Return(strings []string, err error) *S3Client_ListObjects_Call

func (*S3Client_ListObjects_Call) Run 

func (_c *S3Client_ListObjects_Call) Run(run func(ctxt context.Context, bucket string, prefix *string)) *S3Client_ListObjects_Call

func (*S3Client_ListObjects_Call) RunAndReturn 

func (_c *S3Client_ListObjects_Call) RunAndReturn(run func(ctxt context.Context, bucket string, prefix *string) ([]string, error)) *S3Client_ListObjects_Call

type S3Client_PutObject_Call 

type S3Client_PutObject_Call struct {
	*mock.Call
}

S3Client_PutObject_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutObject'

func (*S3Client_PutObject_Call) Return 

func (_c *S3Client_PutObject_Call) Return(err error) *S3Client_PutObject_Call

func (*S3Client_PutObject_Call) Run 

func (_c *S3Client_PutObject_Call) Run(run func(ctxt context.Context, bucketName string, objectKey string, content []byte)) *S3Client_PutObject_Call

func (*S3Client_PutObject_Call) RunAndReturn 

func (_c *S3Client_PutObject_Call) RunAndReturn(run func(ctxt context.Context, bucketName string, objectKey string, content []byte) error) *S3Client_PutObject_Call

type SegmentManager 

type SegmentManager struct {
	mock.Mock
}

SegmentManager is an autogenerated mock type for the SegmentManager type

func NewSegmentManager 

func NewSegmentManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *SegmentManager

NewSegmentManager creates a new instance of SegmentManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SegmentManager) EXPECT 

func (_m *SegmentManager) EXPECT() *SegmentManager_Expecter

func (*SegmentManager) GetSegment 

func (_mock *SegmentManager) GetSegment(ctxt context.Context, target common.VideoSegment) ([]byte, error)

GetSegment provides a mock function for the type SegmentManager

type SegmentManager_Expecter 

type SegmentManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*SegmentManager_Expecter) GetSegment 

func (_e *SegmentManager_Expecter) GetSegment(ctxt interface{}, target interface{}) *SegmentManager_GetSegment_Call

GetSegment is a helper method to define mock.On call

  • ctxt context.Context
  • target common.VideoSegment

type SegmentManager_GetSegment_Call 

type SegmentManager_GetSegment_Call struct {
	*mock.Call
}

SegmentManager_GetSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSegment'

func (*SegmentManager_GetSegment_Call) Return 

func (_c *SegmentManager_GetSegment_Call) Return(bytes []byte, err error) *SegmentManager_GetSegment_Call

func (*SegmentManager_GetSegment_Call) Run 

func (_c *SegmentManager_GetSegment_Call) Run(run func(ctxt context.Context, target common.VideoSegment)) *SegmentManager_GetSegment_Call

func (*SegmentManager_GetSegment_Call) RunAndReturn 

func (_c *SegmentManager_GetSegment_Call) RunAndReturn(run func(ctxt context.Context, target common.VideoSegment) ([]byte, error)) *SegmentManager_GetSegment_Call

type SegmentMetricsAgent 

type SegmentMetricsAgent struct {
	mock.Mock
}

SegmentMetricsAgent is an autogenerated mock type for the SegmentMetricsAgent type

func NewSegmentMetricsAgent 

func NewSegmentMetricsAgent(t interface {
	mock.TestingT
	Cleanup(func())
}) *SegmentMetricsAgent

NewSegmentMetricsAgent creates a new instance of SegmentMetricsAgent. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SegmentMetricsAgent) EXPECT 

func (_m *SegmentMetricsAgent) EXPECT() *SegmentMetricsAgent_Expecter

func (*SegmentMetricsAgent) RecordSegment 

func (_mock *SegmentMetricsAgent) RecordSegment(segmentSize int, labels map[string]string)

RecordSegment provides a mock function for the type SegmentMetricsAgent

type SegmentMetricsAgent_Expecter 

type SegmentMetricsAgent_Expecter struct {
	// contains filtered or unexported fields
}

func (*SegmentMetricsAgent_Expecter) RecordSegment 

func (_e *SegmentMetricsAgent_Expecter) RecordSegment(segmentSize interface{}, labels interface{}) *SegmentMetricsAgent_RecordSegment_Call

RecordSegment is a helper method to define mock.On call

  • segmentSize int
  • labels map[string]string

type SegmentMetricsAgent_RecordSegment_Call 

type SegmentMetricsAgent_RecordSegment_Call struct {
	*mock.Call
}

SegmentMetricsAgent_RecordSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordSegment'

func (*SegmentMetricsAgent_RecordSegment_Call) Return 

func (_c *SegmentMetricsAgent_RecordSegment_Call) Return() *SegmentMetricsAgent_RecordSegment_Call

func (*SegmentMetricsAgent_RecordSegment_Call) Run 

func (_c *SegmentMetricsAgent_RecordSegment_Call) Run(run func(segmentSize int, labels map[string]string)) *SegmentMetricsAgent_RecordSegment_Call

func (*SegmentMetricsAgent_RecordSegment_Call) RunAndReturn 

func (_c *SegmentMetricsAgent_RecordSegment_Call) RunAndReturn(run func(segmentSize int, labels map[string]string)) *SegmentMetricsAgent_RecordSegment_Call

type SegmentReader 

type SegmentReader struct {
	mock.Mock
}

SegmentReader is an autogenerated mock type for the SegmentReader type

func NewSegmentReader 

func NewSegmentReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *SegmentReader

NewSegmentReader creates a new instance of SegmentReader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SegmentReader) EXPECT 

func (_m *SegmentReader) EXPECT() *SegmentReader_Expecter

func (*SegmentReader) ReadSegment 

func (_mock *SegmentReader) ReadSegment(ctxt context.Context, segment common.VideoSegment, returnCB utils.SegmentReturnCallback) error

ReadSegment provides a mock function for the type SegmentReader

func (*SegmentReader) Stop 

func (_mock *SegmentReader) Stop(ctxt context.Context) error

Stop provides a mock function for the type SegmentReader

type SegmentReader_Expecter 

type SegmentReader_Expecter struct {
	// contains filtered or unexported fields
}

func (*SegmentReader_Expecter) ReadSegment 

func (_e *SegmentReader_Expecter) ReadSegment(ctxt interface{}, segment interface{}, returnCB interface{}) *SegmentReader_ReadSegment_Call

ReadSegment is a helper method to define mock.On call

  • ctxt context.Context
  • segment common.VideoSegment
  • returnCB utils.SegmentReturnCallback

func (*SegmentReader_Expecter) Stop 

func (_e *SegmentReader_Expecter) Stop(ctxt interface{}) *SegmentReader_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

type SegmentReader_ReadSegment_Call 

type SegmentReader_ReadSegment_Call struct {
	*mock.Call
}

SegmentReader_ReadSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReadSegment'

func (*SegmentReader_ReadSegment_Call) Return 

func (_c *SegmentReader_ReadSegment_Call) Return(err error) *SegmentReader_ReadSegment_Call

func (*SegmentReader_ReadSegment_Call) Run 

func (_c *SegmentReader_ReadSegment_Call) Run(run func(ctxt context.Context, segment common.VideoSegment, returnCB utils.SegmentReturnCallback)) *SegmentReader_ReadSegment_Call

func (*SegmentReader_ReadSegment_Call) RunAndReturn 

func (_c *SegmentReader_ReadSegment_Call) RunAndReturn(run func(ctxt context.Context, segment common.VideoSegment, returnCB utils.SegmentReturnCallback) error) *SegmentReader_ReadSegment_Call

type SegmentReader_Stop_Call 

type SegmentReader_Stop_Call struct {
	*mock.Call
}

SegmentReader_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*SegmentReader_Stop_Call) Return 

func (_c *SegmentReader_Stop_Call) Return(err error) *SegmentReader_Stop_Call

func (*SegmentReader_Stop_Call) Run 

func (_c *SegmentReader_Stop_Call) Run(run func(ctxt context.Context)) *SegmentReader_Stop_Call

func (*SegmentReader_Stop_Call) RunAndReturn 

func (_c *SegmentReader_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *SegmentReader_Stop_Call

type SegmentSender 

type SegmentSender struct {
	mock.Mock
}

SegmentSender is an autogenerated mock type for the SegmentSender type

func NewSegmentSender 

func NewSegmentSender(t interface {
	mock.TestingT
	Cleanup(func())
}) *SegmentSender

NewSegmentSender creates a new instance of SegmentSender. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SegmentSender) EXPECT 

func (_m *SegmentSender) EXPECT() *SegmentSender_Expecter

func (*SegmentSender) ForwardSegment 

func (_mock *SegmentSender) ForwardSegment(ctxt context.Context, segment common.VideoSegmentWithData) error

ForwardSegment provides a mock function for the type SegmentSender

type SegmentSender_Expecter 

type SegmentSender_Expecter struct {
	// contains filtered or unexported fields
}

func (*SegmentSender_Expecter) ForwardSegment 

func (_e *SegmentSender_Expecter) ForwardSegment(ctxt interface{}, segment interface{}) *SegmentSender_ForwardSegment_Call

ForwardSegment is a helper method to define mock.On call

  • ctxt context.Context
  • segment common.VideoSegmentWithData

type SegmentSender_ForwardSegment_Call 

type SegmentSender_ForwardSegment_Call struct {
	*mock.Call
}

SegmentSender_ForwardSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForwardSegment'

func (*SegmentSender_ForwardSegment_Call) Return 

func (_c *SegmentSender_ForwardSegment_Call) Return(err error) *SegmentSender_ForwardSegment_Call

func (*SegmentSender_ForwardSegment_Call) Run 

func (_c *SegmentSender_ForwardSegment_Call) Run(run func(ctxt context.Context, segment common.VideoSegmentWithData)) *SegmentSender_ForwardSegment_Call

func (*SegmentSender_ForwardSegment_Call) RunAndReturn 

func (_c *SegmentSender_ForwardSegment_Call) RunAndReturn(run func(ctxt context.Context, segment common.VideoSegmentWithData) error) *SegmentSender_ForwardSegment_Call

type SystemManager 

type SystemManager struct {
	mock.Mock
}

SystemManager is an autogenerated mock type for the SystemManager type

func NewSystemManager 

func NewSystemManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *SystemManager

NewSystemManager creates a new instance of SystemManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SystemManager) ChangeVideoSourceStreamState 

func (_mock *SystemManager) ChangeVideoSourceStreamState(ctxt context.Context, id string, streaming int) error

ChangeVideoSourceStreamState provides a mock function for the type SystemManager

func (*SystemManager) DefineRecordingSession 

func (_mock *SystemManager) DefineRecordingSession(ctxt context.Context, sourceID string, alias *string, description *string, startTime time.Time) (string, error)

DefineRecordingSession provides a mock function for the type SystemManager

func (*SystemManager) DefineVideoSource 

func (_mock *SystemManager) DefineVideoSource(ctxt context.Context, name string, segmentLen int, playlistURI *string, description *string) (string, error)

DefineVideoSource provides a mock function for the type SystemManager

func (*SystemManager) DeleteRecordingSession 

func (_mock *SystemManager) DeleteRecordingSession(ctxt context.Context, id string, force bool) error

DeleteRecordingSession provides a mock function for the type SystemManager

func (*SystemManager) DeleteUnassociatedRecordingSegments 

func (_mock *SystemManager) DeleteUnassociatedRecordingSegments() error

DeleteUnassociatedRecordingSegments provides a mock function for the type SystemManager

func (*SystemManager) DeleteVideoSource 

func (_mock *SystemManager) DeleteVideoSource(ctxt context.Context, id string) error

DeleteVideoSource provides a mock function for the type SystemManager

func (*SystemManager) EXPECT 

func (_m *SystemManager) EXPECT() *SystemManager_Expecter

func (*SystemManager) GetRecordingSession 

func (_mock *SystemManager) GetRecordingSession(ctxt context.Context, id string) (common.Recording, error)

GetRecordingSession provides a mock function for the type SystemManager

func (*SystemManager) GetRecordingSessionByAlias 

func (_mock *SystemManager) GetRecordingSessionByAlias(ctxt context.Context, alias string) (common.Recording, error)

GetRecordingSessionByAlias provides a mock function for the type SystemManager

func (*SystemManager) GetVideoSource 

func (_mock *SystemManager) GetVideoSource(ctxt context.Context, id string) (common.VideoSource, error)

GetVideoSource provides a mock function for the type SystemManager

func (*SystemManager) GetVideoSourceByName 

func (_mock *SystemManager) GetVideoSourceByName(ctxt context.Context, name string) (common.VideoSource, error)

GetVideoSourceByName provides a mock function for the type SystemManager

func (*SystemManager) ListAllSegmentsOfRecording 

func (_mock *SystemManager) ListAllSegmentsOfRecording(ctxt context.Context, recordingID string) ([]common.VideoSegment, error)

ListAllSegmentsOfRecording provides a mock function for the type SystemManager

func (*SystemManager) ListRecordingSessions 

func (_mock *SystemManager) ListRecordingSessions(ctxt context.Context) ([]common.Recording, error)

ListRecordingSessions provides a mock function for the type SystemManager

func (*SystemManager) ListRecordingSessionsOfSource 

func (_mock *SystemManager) ListRecordingSessionsOfSource(ctxt context.Context, sourceID string, active bool) ([]common.Recording, error)

ListRecordingSessionsOfSource provides a mock function for the type SystemManager

func (*SystemManager) ListVideoSources 

func (_mock *SystemManager) ListVideoSources(ctxt context.Context) ([]common.VideoSource, error)

ListVideoSources provides a mock function for the type SystemManager

func (*SystemManager) MarkEndOfRecordingSession 

func (_mock *SystemManager) MarkEndOfRecordingSession(ctxt context.Context, id string, endTime time.Time, force bool) error

MarkEndOfRecordingSession provides a mock function for the type SystemManager

func (*SystemManager) ProcessBroadcastMsgs 

func (_mock *SystemManager) ProcessBroadcastMsgs(ctxt context.Context, pubTimestamp time.Time, msg []byte, metadata map[string]string) error

ProcessBroadcastMsgs provides a mock function for the type SystemManager

func (*SystemManager) Ready 

func (_mock *SystemManager) Ready(ctxt context.Context) error

Ready provides a mock function for the type SystemManager

func (*SystemManager) Stop 

func (_mock *SystemManager) Stop(ctxt context.Context) error

Stop provides a mock function for the type SystemManager

func (*SystemManager) StopAllActiveRecordingOfSource 

func (_mock *SystemManager) StopAllActiveRecordingOfSource(ctxt context.Context, id string, currentTime time.Time) error

StopAllActiveRecordingOfSource provides a mock function for the type SystemManager

func (*SystemManager) UpdateRecordingSession 

func (_mock *SystemManager) UpdateRecordingSession(ctxt context.Context, newSetting common.Recording) error

UpdateRecordingSession provides a mock function for the type SystemManager

func (*SystemManager) UpdateVideoSource 

func (_mock *SystemManager) UpdateVideoSource(ctxt context.Context, newSetting common.VideoSource) error

UpdateVideoSource provides a mock function for the type SystemManager

func (*SystemManager) UpdateVideoSourceStatus added in v0.4.0 

func (_mock *SystemManager) UpdateVideoSourceStatus(ctxt context.Context, id string, reqRespTargetID string, sourceLocalTime time.Time) error

UpdateVideoSourceStatus provides a mock function for the type SystemManager

type SystemManager_ChangeVideoSourceStreamState_Call 

type SystemManager_ChangeVideoSourceStreamState_Call struct {
	*mock.Call
}

SystemManager_ChangeVideoSourceStreamState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeVideoSourceStreamState'

func (*SystemManager_ChangeVideoSourceStreamState_Call) Return 

func (_c *SystemManager_ChangeVideoSourceStreamState_Call) Return(err error) *SystemManager_ChangeVideoSourceStreamState_Call

func (*SystemManager_ChangeVideoSourceStreamState_Call) Run 

func (_c *SystemManager_ChangeVideoSourceStreamState_Call) Run(run func(ctxt context.Context, id string, streaming int)) *SystemManager_ChangeVideoSourceStreamState_Call

func (*SystemManager_ChangeVideoSourceStreamState_Call) RunAndReturn 

func (_c *SystemManager_ChangeVideoSourceStreamState_Call) RunAndReturn(run func(ctxt context.Context, id string, streaming int) error) *SystemManager_ChangeVideoSourceStreamState_Call

type SystemManager_DefineRecordingSession_Call 

type SystemManager_DefineRecordingSession_Call struct {
	*mock.Call
}

SystemManager_DefineRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineRecordingSession'

func (*SystemManager_DefineRecordingSession_Call) Return 

func (_c *SystemManager_DefineRecordingSession_Call) Return(s string, err error) *SystemManager_DefineRecordingSession_Call

func (*SystemManager_DefineRecordingSession_Call) Run 

func (_c *SystemManager_DefineRecordingSession_Call) Run(run func(ctxt context.Context, sourceID string, alias *string, description *string, startTime time.Time)) *SystemManager_DefineRecordingSession_Call

func (*SystemManager_DefineRecordingSession_Call) RunAndReturn 

func (_c *SystemManager_DefineRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, alias *string, description *string, startTime time.Time) (string, error)) *SystemManager_DefineRecordingSession_Call

type SystemManager_DefineVideoSource_Call 

type SystemManager_DefineVideoSource_Call struct {
	*mock.Call
}

SystemManager_DefineVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DefineVideoSource'

func (*SystemManager_DefineVideoSource_Call) Return 

func (_c *SystemManager_DefineVideoSource_Call) Return(s string, err error) *SystemManager_DefineVideoSource_Call

func (*SystemManager_DefineVideoSource_Call) Run 

func (_c *SystemManager_DefineVideoSource_Call) Run(run func(ctxt context.Context, name string, segmentLen int, playlistURI *string, description *string)) *SystemManager_DefineVideoSource_Call

func (*SystemManager_DefineVideoSource_Call) RunAndReturn 

func (_c *SystemManager_DefineVideoSource_Call) RunAndReturn(run func(ctxt context.Context, name string, segmentLen int, playlistURI *string, description *string) (string, error)) *SystemManager_DefineVideoSource_Call

type SystemManager_DeleteRecordingSession_Call 

type SystemManager_DeleteRecordingSession_Call struct {
	*mock.Call
}

SystemManager_DeleteRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteRecordingSession'

func (*SystemManager_DeleteRecordingSession_Call) Return 

func (_c *SystemManager_DeleteRecordingSession_Call) Return(err error) *SystemManager_DeleteRecordingSession_Call

func (*SystemManager_DeleteRecordingSession_Call) Run 

func (_c *SystemManager_DeleteRecordingSession_Call) Run(run func(ctxt context.Context, id string, force bool)) *SystemManager_DeleteRecordingSession_Call

func (*SystemManager_DeleteRecordingSession_Call) RunAndReturn 

func (_c *SystemManager_DeleteRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, id string, force bool) error) *SystemManager_DeleteRecordingSession_Call

type SystemManager_DeleteUnassociatedRecordingSegments_Call 

type SystemManager_DeleteUnassociatedRecordingSegments_Call struct {
	*mock.Call
}

SystemManager_DeleteUnassociatedRecordingSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteUnassociatedRecordingSegments'

func (*SystemManager_DeleteUnassociatedRecordingSegments_Call) Return 

func (_c *SystemManager_DeleteUnassociatedRecordingSegments_Call) Return(err error) *SystemManager_DeleteUnassociatedRecordingSegments_Call

func (*SystemManager_DeleteUnassociatedRecordingSegments_Call) Run 

func (_c *SystemManager_DeleteUnassociatedRecordingSegments_Call) Run(run func()) *SystemManager_DeleteUnassociatedRecordingSegments_Call

func (*SystemManager_DeleteUnassociatedRecordingSegments_Call) RunAndReturn 

func (_c *SystemManager_DeleteUnassociatedRecordingSegments_Call) RunAndReturn(run func() error) *SystemManager_DeleteUnassociatedRecordingSegments_Call

type SystemManager_DeleteVideoSource_Call 

type SystemManager_DeleteVideoSource_Call struct {
	*mock.Call
}

SystemManager_DeleteVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteVideoSource'

func (*SystemManager_DeleteVideoSource_Call) Return 

func (_c *SystemManager_DeleteVideoSource_Call) Return(err error) *SystemManager_DeleteVideoSource_Call

func (*SystemManager_DeleteVideoSource_Call) Run 

func (_c *SystemManager_DeleteVideoSource_Call) Run(run func(ctxt context.Context, id string)) *SystemManager_DeleteVideoSource_Call

func (*SystemManager_DeleteVideoSource_Call) RunAndReturn 

func (_c *SystemManager_DeleteVideoSource_Call) RunAndReturn(run func(ctxt context.Context, id string) error) *SystemManager_DeleteVideoSource_Call

type SystemManager_Expecter 

type SystemManager_Expecter struct {
	// contains filtered or unexported fields
}

func (*SystemManager_Expecter) ChangeVideoSourceStreamState 

func (_e *SystemManager_Expecter) ChangeVideoSourceStreamState(ctxt interface{}, id interface{}, streaming interface{}) *SystemManager_ChangeVideoSourceStreamState_Call

ChangeVideoSourceStreamState is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • streaming int

func (*SystemManager_Expecter) DefineRecordingSession 

func (_e *SystemManager_Expecter) DefineRecordingSession(ctxt interface{}, sourceID interface{}, alias interface{}, description interface{}, startTime interface{}) *SystemManager_DefineRecordingSession_Call

DefineRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • alias *string
  • description *string
  • startTime time.Time

func (*SystemManager_Expecter) DefineVideoSource 

func (_e *SystemManager_Expecter) DefineVideoSource(ctxt interface{}, name interface{}, segmentLen interface{}, playlistURI interface{}, description interface{}) *SystemManager_DefineVideoSource_Call

DefineVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • name string
  • segmentLen int
  • playlistURI *string
  • description *string

func (*SystemManager_Expecter) DeleteRecordingSession 

func (_e *SystemManager_Expecter) DeleteRecordingSession(ctxt interface{}, id interface{}, force interface{}) *SystemManager_DeleteRecordingSession_Call

DeleteRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • force bool

func (*SystemManager_Expecter) DeleteUnassociatedRecordingSegments 

func (_e *SystemManager_Expecter) DeleteUnassociatedRecordingSegments() *SystemManager_DeleteUnassociatedRecordingSegments_Call

DeleteUnassociatedRecordingSegments is a helper method to define mock.On call

func (*SystemManager_Expecter) DeleteVideoSource 

func (_e *SystemManager_Expecter) DeleteVideoSource(ctxt interface{}, id interface{}) *SystemManager_DeleteVideoSource_Call

DeleteVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*SystemManager_Expecter) GetRecordingSession 

func (_e *SystemManager_Expecter) GetRecordingSession(ctxt interface{}, id interface{}) *SystemManager_GetRecordingSession_Call

GetRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*SystemManager_Expecter) GetRecordingSessionByAlias 

func (_e *SystemManager_Expecter) GetRecordingSessionByAlias(ctxt interface{}, alias interface{}) *SystemManager_GetRecordingSessionByAlias_Call

GetRecordingSessionByAlias is a helper method to define mock.On call

  • ctxt context.Context
  • alias string

func (*SystemManager_Expecter) GetVideoSource 

func (_e *SystemManager_Expecter) GetVideoSource(ctxt interface{}, id interface{}) *SystemManager_GetVideoSource_Call

GetVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string

func (*SystemManager_Expecter) GetVideoSourceByName 

func (_e *SystemManager_Expecter) GetVideoSourceByName(ctxt interface{}, name interface{}) *SystemManager_GetVideoSourceByName_Call

GetVideoSourceByName is a helper method to define mock.On call

  • ctxt context.Context
  • name string

func (*SystemManager_Expecter) ListAllSegmentsOfRecording 

func (_e *SystemManager_Expecter) ListAllSegmentsOfRecording(ctxt interface{}, recordingID interface{}) *SystemManager_ListAllSegmentsOfRecording_Call

ListAllSegmentsOfRecording is a helper method to define mock.On call

  • ctxt context.Context
  • recordingID string

func (*SystemManager_Expecter) ListRecordingSessions 

func (_e *SystemManager_Expecter) ListRecordingSessions(ctxt interface{}) *SystemManager_ListRecordingSessions_Call

ListRecordingSessions is a helper method to define mock.On call

  • ctxt context.Context

func (*SystemManager_Expecter) ListRecordingSessionsOfSource 

func (_e *SystemManager_Expecter) ListRecordingSessionsOfSource(ctxt interface{}, sourceID interface{}, active interface{}) *SystemManager_ListRecordingSessionsOfSource_Call

ListRecordingSessionsOfSource is a helper method to define mock.On call

  • ctxt context.Context
  • sourceID string
  • active bool

func (*SystemManager_Expecter) ListVideoSources 

func (_e *SystemManager_Expecter) ListVideoSources(ctxt interface{}) *SystemManager_ListVideoSources_Call

ListVideoSources is a helper method to define mock.On call

  • ctxt context.Context

func (*SystemManager_Expecter) MarkEndOfRecordingSession 

func (_e *SystemManager_Expecter) MarkEndOfRecordingSession(ctxt interface{}, id interface{}, endTime interface{}, force interface{}) *SystemManager_MarkEndOfRecordingSession_Call

MarkEndOfRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • endTime time.Time
  • force bool

func (*SystemManager_Expecter) ProcessBroadcastMsgs 

func (_e *SystemManager_Expecter) ProcessBroadcastMsgs(ctxt interface{}, pubTimestamp interface{}, msg interface{}, metadata interface{}) *SystemManager_ProcessBroadcastMsgs_Call

ProcessBroadcastMsgs is a helper method to define mock.On call

  • ctxt context.Context
  • pubTimestamp time.Time
  • msg []byte
  • metadata map[string]string

func (*SystemManager_Expecter) Ready 

func (_e *SystemManager_Expecter) Ready(ctxt interface{}) *SystemManager_Ready_Call

Ready is a helper method to define mock.On call

  • ctxt context.Context

func (*SystemManager_Expecter) Stop 

func (_e *SystemManager_Expecter) Stop(ctxt interface{}) *SystemManager_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

func (*SystemManager_Expecter) StopAllActiveRecordingOfSource 

func (_e *SystemManager_Expecter) StopAllActiveRecordingOfSource(ctxt interface{}, id interface{}, currentTime interface{}) *SystemManager_StopAllActiveRecordingOfSource_Call

StopAllActiveRecordingOfSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • currentTime time.Time

func (*SystemManager_Expecter) UpdateRecordingSession 

func (_e *SystemManager_Expecter) UpdateRecordingSession(ctxt interface{}, newSetting interface{}) *SystemManager_UpdateRecordingSession_Call

UpdateRecordingSession is a helper method to define mock.On call

  • ctxt context.Context
  • newSetting common.Recording

func (*SystemManager_Expecter) UpdateVideoSource 

func (_e *SystemManager_Expecter) UpdateVideoSource(ctxt interface{}, newSetting interface{}) *SystemManager_UpdateVideoSource_Call

UpdateVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • newSetting common.VideoSource

func (*SystemManager_Expecter) UpdateVideoSourceStatus added in v0.4.0 

func (_e *SystemManager_Expecter) UpdateVideoSourceStatus(ctxt interface{}, id interface{}, reqRespTargetID interface{}, sourceLocalTime interface{}) *SystemManager_UpdateVideoSourceStatus_Call

UpdateVideoSourceStatus is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • reqRespTargetID string
  • sourceLocalTime time.Time

type SystemManager_GetRecordingSessionByAlias_Call 

type SystemManager_GetRecordingSessionByAlias_Call struct {
	*mock.Call
}

SystemManager_GetRecordingSessionByAlias_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingSessionByAlias'

func (*SystemManager_GetRecordingSessionByAlias_Call) Return 

func (_c *SystemManager_GetRecordingSessionByAlias_Call) Return(recording common.Recording, err error) *SystemManager_GetRecordingSessionByAlias_Call

func (*SystemManager_GetRecordingSessionByAlias_Call) Run 

func (_c *SystemManager_GetRecordingSessionByAlias_Call) Run(run func(ctxt context.Context, alias string)) *SystemManager_GetRecordingSessionByAlias_Call

func (*SystemManager_GetRecordingSessionByAlias_Call) RunAndReturn 

func (_c *SystemManager_GetRecordingSessionByAlias_Call) RunAndReturn(run func(ctxt context.Context, alias string) (common.Recording, error)) *SystemManager_GetRecordingSessionByAlias_Call

type SystemManager_GetRecordingSession_Call 

type SystemManager_GetRecordingSession_Call struct {
	*mock.Call
}

SystemManager_GetRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordingSession'

func (*SystemManager_GetRecordingSession_Call) Return 

func (_c *SystemManager_GetRecordingSession_Call) Return(recording common.Recording, err error) *SystemManager_GetRecordingSession_Call

func (*SystemManager_GetRecordingSession_Call) Run 

func (_c *SystemManager_GetRecordingSession_Call) Run(run func(ctxt context.Context, id string)) *SystemManager_GetRecordingSession_Call

func (*SystemManager_GetRecordingSession_Call) RunAndReturn 

func (_c *SystemManager_GetRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, id string) (common.Recording, error)) *SystemManager_GetRecordingSession_Call

type SystemManager_GetVideoSourceByName_Call 

type SystemManager_GetVideoSourceByName_Call struct {
	*mock.Call
}

SystemManager_GetVideoSourceByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVideoSourceByName'

func (*SystemManager_GetVideoSourceByName_Call) Return 

func (_c *SystemManager_GetVideoSourceByName_Call) Return(videoSource common.VideoSource, err error) *SystemManager_GetVideoSourceByName_Call

func (*SystemManager_GetVideoSourceByName_Call) Run 

func (_c *SystemManager_GetVideoSourceByName_Call) Run(run func(ctxt context.Context, name string)) *SystemManager_GetVideoSourceByName_Call

func (*SystemManager_GetVideoSourceByName_Call) RunAndReturn 

func (_c *SystemManager_GetVideoSourceByName_Call) RunAndReturn(run func(ctxt context.Context, name string) (common.VideoSource, error)) *SystemManager_GetVideoSourceByName_Call

type SystemManager_GetVideoSource_Call 

type SystemManager_GetVideoSource_Call struct {
	*mock.Call
}

SystemManager_GetVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetVideoSource'

func (*SystemManager_GetVideoSource_Call) Return 

func (_c *SystemManager_GetVideoSource_Call) Return(videoSource common.VideoSource, err error) *SystemManager_GetVideoSource_Call

func (*SystemManager_GetVideoSource_Call) Run 

func (_c *SystemManager_GetVideoSource_Call) Run(run func(ctxt context.Context, id string)) *SystemManager_GetVideoSource_Call

func (*SystemManager_GetVideoSource_Call) RunAndReturn 

func (_c *SystemManager_GetVideoSource_Call) RunAndReturn(run func(ctxt context.Context, id string) (common.VideoSource, error)) *SystemManager_GetVideoSource_Call

type SystemManager_ListAllSegmentsOfRecording_Call 

type SystemManager_ListAllSegmentsOfRecording_Call struct {
	*mock.Call
}

SystemManager_ListAllSegmentsOfRecording_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListAllSegmentsOfRecording'

func (*SystemManager_ListAllSegmentsOfRecording_Call) Return 

func (_c *SystemManager_ListAllSegmentsOfRecording_Call) Return(videoSegments []common.VideoSegment, err error) *SystemManager_ListAllSegmentsOfRecording_Call

func (*SystemManager_ListAllSegmentsOfRecording_Call) Run 

func (_c *SystemManager_ListAllSegmentsOfRecording_Call) Run(run func(ctxt context.Context, recordingID string)) *SystemManager_ListAllSegmentsOfRecording_Call

func (*SystemManager_ListAllSegmentsOfRecording_Call) RunAndReturn 

func (_c *SystemManager_ListAllSegmentsOfRecording_Call) RunAndReturn(run func(ctxt context.Context, recordingID string) ([]common.VideoSegment, error)) *SystemManager_ListAllSegmentsOfRecording_Call

type SystemManager_ListRecordingSessionsOfSource_Call 

type SystemManager_ListRecordingSessionsOfSource_Call struct {
	*mock.Call
}

SystemManager_ListRecordingSessionsOfSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListRecordingSessionsOfSource'

func (*SystemManager_ListRecordingSessionsOfSource_Call) Return 

func (_c *SystemManager_ListRecordingSessionsOfSource_Call) Return(recordings []common.Recording, err error) *SystemManager_ListRecordingSessionsOfSource_Call

func (*SystemManager_ListRecordingSessionsOfSource_Call) Run 

func (_c *SystemManager_ListRecordingSessionsOfSource_Call) Run(run func(ctxt context.Context, sourceID string, active bool)) *SystemManager_ListRecordingSessionsOfSource_Call

func (*SystemManager_ListRecordingSessionsOfSource_Call) RunAndReturn 

func (_c *SystemManager_ListRecordingSessionsOfSource_Call) RunAndReturn(run func(ctxt context.Context, sourceID string, active bool) ([]common.Recording, error)) *SystemManager_ListRecordingSessionsOfSource_Call

type SystemManager_ListRecordingSessions_Call 

type SystemManager_ListRecordingSessions_Call struct {
	*mock.Call
}

SystemManager_ListRecordingSessions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListRecordingSessions'

func (*SystemManager_ListRecordingSessions_Call) Return 

func (_c *SystemManager_ListRecordingSessions_Call) Return(recordings []common.Recording, err error) *SystemManager_ListRecordingSessions_Call

func (*SystemManager_ListRecordingSessions_Call) Run 

func (_c *SystemManager_ListRecordingSessions_Call) Run(run func(ctxt context.Context)) *SystemManager_ListRecordingSessions_Call

func (*SystemManager_ListRecordingSessions_Call) RunAndReturn 

func (_c *SystemManager_ListRecordingSessions_Call) RunAndReturn(run func(ctxt context.Context) ([]common.Recording, error)) *SystemManager_ListRecordingSessions_Call

type SystemManager_ListVideoSources_Call 

type SystemManager_ListVideoSources_Call struct {
	*mock.Call
}

SystemManager_ListVideoSources_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListVideoSources'

func (*SystemManager_ListVideoSources_Call) Return 

func (_c *SystemManager_ListVideoSources_Call) Return(videoSources []common.VideoSource, err error) *SystemManager_ListVideoSources_Call

func (*SystemManager_ListVideoSources_Call) Run 

func (_c *SystemManager_ListVideoSources_Call) Run(run func(ctxt context.Context)) *SystemManager_ListVideoSources_Call

func (*SystemManager_ListVideoSources_Call) RunAndReturn 

func (_c *SystemManager_ListVideoSources_Call) RunAndReturn(run func(ctxt context.Context) ([]common.VideoSource, error)) *SystemManager_ListVideoSources_Call

type SystemManager_MarkEndOfRecordingSession_Call 

type SystemManager_MarkEndOfRecordingSession_Call struct {
	*mock.Call
}

SystemManager_MarkEndOfRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MarkEndOfRecordingSession'

func (*SystemManager_MarkEndOfRecordingSession_Call) Return 

func (_c *SystemManager_MarkEndOfRecordingSession_Call) Return(err error) *SystemManager_MarkEndOfRecordingSession_Call

func (*SystemManager_MarkEndOfRecordingSession_Call) Run 

func (_c *SystemManager_MarkEndOfRecordingSession_Call) Run(run func(ctxt context.Context, id string, endTime time.Time, force bool)) *SystemManager_MarkEndOfRecordingSession_Call

func (*SystemManager_MarkEndOfRecordingSession_Call) RunAndReturn 

func (_c *SystemManager_MarkEndOfRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, id string, endTime time.Time, force bool) error) *SystemManager_MarkEndOfRecordingSession_Call

type SystemManager_ProcessBroadcastMsgs_Call 

type SystemManager_ProcessBroadcastMsgs_Call struct {
	*mock.Call
}

SystemManager_ProcessBroadcastMsgs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ProcessBroadcastMsgs'

func (*SystemManager_ProcessBroadcastMsgs_Call) Return 

func (_c *SystemManager_ProcessBroadcastMsgs_Call) Return(err error) *SystemManager_ProcessBroadcastMsgs_Call

func (*SystemManager_ProcessBroadcastMsgs_Call) Run 

func (_c *SystemManager_ProcessBroadcastMsgs_Call) Run(run func(ctxt context.Context, pubTimestamp time.Time, msg []byte, metadata map[string]string)) *SystemManager_ProcessBroadcastMsgs_Call

func (*SystemManager_ProcessBroadcastMsgs_Call) RunAndReturn 

func (_c *SystemManager_ProcessBroadcastMsgs_Call) RunAndReturn(run func(ctxt context.Context, pubTimestamp time.Time, msg []byte, metadata map[string]string) error) *SystemManager_ProcessBroadcastMsgs_Call

type SystemManager_Ready_Call 

type SystemManager_Ready_Call struct {
	*mock.Call
}

SystemManager_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*SystemManager_Ready_Call) Return 

func (_c *SystemManager_Ready_Call) Return(err error) *SystemManager_Ready_Call

func (*SystemManager_Ready_Call) Run 

func (_c *SystemManager_Ready_Call) Run(run func(ctxt context.Context)) *SystemManager_Ready_Call

func (*SystemManager_Ready_Call) RunAndReturn 

func (_c *SystemManager_Ready_Call) RunAndReturn(run func(ctxt context.Context) error) *SystemManager_Ready_Call

type SystemManager_StopAllActiveRecordingOfSource_Call 

type SystemManager_StopAllActiveRecordingOfSource_Call struct {
	*mock.Call
}

SystemManager_StopAllActiveRecordingOfSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopAllActiveRecordingOfSource'

func (*SystemManager_StopAllActiveRecordingOfSource_Call) Return 

func (_c *SystemManager_StopAllActiveRecordingOfSource_Call) Return(err error) *SystemManager_StopAllActiveRecordingOfSource_Call

func (*SystemManager_StopAllActiveRecordingOfSource_Call) Run 

func (_c *SystemManager_StopAllActiveRecordingOfSource_Call) Run(run func(ctxt context.Context, id string, currentTime time.Time)) *SystemManager_StopAllActiveRecordingOfSource_Call

func (*SystemManager_StopAllActiveRecordingOfSource_Call) RunAndReturn 

func (_c *SystemManager_StopAllActiveRecordingOfSource_Call) RunAndReturn(run func(ctxt context.Context, id string, currentTime time.Time) error) *SystemManager_StopAllActiveRecordingOfSource_Call

type SystemManager_Stop_Call 

type SystemManager_Stop_Call struct {
	*mock.Call
}

SystemManager_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*SystemManager_Stop_Call) Return 

func (_c *SystemManager_Stop_Call) Return(err error) *SystemManager_Stop_Call

func (*SystemManager_Stop_Call) Run 

func (_c *SystemManager_Stop_Call) Run(run func(ctxt context.Context)) *SystemManager_Stop_Call

func (*SystemManager_Stop_Call) RunAndReturn 

func (_c *SystemManager_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *SystemManager_Stop_Call

type SystemManager_UpdateRecordingSession_Call 

type SystemManager_UpdateRecordingSession_Call struct {
	*mock.Call
}

SystemManager_UpdateRecordingSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateRecordingSession'

func (*SystemManager_UpdateRecordingSession_Call) Return 

func (_c *SystemManager_UpdateRecordingSession_Call) Return(err error) *SystemManager_UpdateRecordingSession_Call

func (*SystemManager_UpdateRecordingSession_Call) Run 

func (_c *SystemManager_UpdateRecordingSession_Call) Run(run func(ctxt context.Context, newSetting common.Recording)) *SystemManager_UpdateRecordingSession_Call

func (*SystemManager_UpdateRecordingSession_Call) RunAndReturn 

func (_c *SystemManager_UpdateRecordingSession_Call) RunAndReturn(run func(ctxt context.Context, newSetting common.Recording) error) *SystemManager_UpdateRecordingSession_Call

type SystemManager_UpdateVideoSourceStatus_Call added in v0.4.0 

type SystemManager_UpdateVideoSourceStatus_Call struct {
	*mock.Call
}

SystemManager_UpdateVideoSourceStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateVideoSourceStatus'

func (*SystemManager_UpdateVideoSourceStatus_Call) Return added in v0.4.0 

func (_c *SystemManager_UpdateVideoSourceStatus_Call) Return(err error) *SystemManager_UpdateVideoSourceStatus_Call

func (*SystemManager_UpdateVideoSourceStatus_Call) Run added in v0.4.0 

func (_c *SystemManager_UpdateVideoSourceStatus_Call) Run(run func(ctxt context.Context, id string, reqRespTargetID string, sourceLocalTime time.Time)) *SystemManager_UpdateVideoSourceStatus_Call

func (*SystemManager_UpdateVideoSourceStatus_Call) RunAndReturn added in v0.4.0 

func (_c *SystemManager_UpdateVideoSourceStatus_Call) RunAndReturn(run func(ctxt context.Context, id string, reqRespTargetID string, sourceLocalTime time.Time) error) *SystemManager_UpdateVideoSourceStatus_Call

type SystemManager_UpdateVideoSource_Call 

type SystemManager_UpdateVideoSource_Call struct {
	*mock.Call
}

SystemManager_UpdateVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateVideoSource'

func (*SystemManager_UpdateVideoSource_Call) Return 

func (_c *SystemManager_UpdateVideoSource_Call) Return(err error) *SystemManager_UpdateVideoSource_Call

func (*SystemManager_UpdateVideoSource_Call) Run 

func (_c *SystemManager_UpdateVideoSource_Call) Run(run func(ctxt context.Context, newSetting common.VideoSource)) *SystemManager_UpdateVideoSource_Call

func (*SystemManager_UpdateVideoSource_Call) RunAndReturn 

func (_c *SystemManager_UpdateVideoSource_Call) RunAndReturn(run func(ctxt context.Context, newSetting common.VideoSource) error) *SystemManager_UpdateVideoSource_Call

type VideoSegmentCache 

type VideoSegmentCache struct {
	mock.Mock
}

VideoSegmentCache is an autogenerated mock type for the VideoSegmentCache type

func NewVideoSegmentCache 

func NewVideoSegmentCache(t interface {
	mock.TestingT
	Cleanup(func())
}) *VideoSegmentCache

NewVideoSegmentCache creates a new instance of VideoSegmentCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*VideoSegmentCache) CacheEntryCount 

func (_mock *VideoSegmentCache) CacheEntryCount(ctxt context.Context) (int, error)

CacheEntryCount provides a mock function for the type VideoSegmentCache

func (*VideoSegmentCache) CacheSegment 

func (_mock *VideoSegmentCache) CacheSegment(ctxt context.Context, segment common.VideoSegmentWithData, ttl time.Duration) error

CacheSegment provides a mock function for the type VideoSegmentCache

func (*VideoSegmentCache) EXPECT 

func (_m *VideoSegmentCache) EXPECT() *VideoSegmentCache_Expecter

func (*VideoSegmentCache) GetSegment 

func (_mock *VideoSegmentCache) GetSegment(ctxt context.Context, segment common.VideoSegment) ([]byte, error)

GetSegment provides a mock function for the type VideoSegmentCache

func (*VideoSegmentCache) GetSegments 

func (_mock *VideoSegmentCache) GetSegments(ctxt context.Context, segments []common.VideoSegment) (map[string][]byte, error)

GetSegments provides a mock function for the type VideoSegmentCache

func (*VideoSegmentCache) PurgeSegments 

func (_mock *VideoSegmentCache) PurgeSegments(ctxt context.Context, segments []common.VideoSegment) error

PurgeSegments provides a mock function for the type VideoSegmentCache

type VideoSegmentCache_CacheEntryCount_Call 

type VideoSegmentCache_CacheEntryCount_Call struct {
	*mock.Call
}

VideoSegmentCache_CacheEntryCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CacheEntryCount'

func (*VideoSegmentCache_CacheEntryCount_Call) Return 

func (_c *VideoSegmentCache_CacheEntryCount_Call) Return(n int, err error) *VideoSegmentCache_CacheEntryCount_Call

func (*VideoSegmentCache_CacheEntryCount_Call) Run 

func (_c *VideoSegmentCache_CacheEntryCount_Call) Run(run func(ctxt context.Context)) *VideoSegmentCache_CacheEntryCount_Call

func (*VideoSegmentCache_CacheEntryCount_Call) RunAndReturn 

func (_c *VideoSegmentCache_CacheEntryCount_Call) RunAndReturn(run func(ctxt context.Context) (int, error)) *VideoSegmentCache_CacheEntryCount_Call

type VideoSegmentCache_CacheSegment_Call 

type VideoSegmentCache_CacheSegment_Call struct {
	*mock.Call
}

VideoSegmentCache_CacheSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CacheSegment'

func (*VideoSegmentCache_CacheSegment_Call) Return 

func (_c *VideoSegmentCache_CacheSegment_Call) Return(err error) *VideoSegmentCache_CacheSegment_Call

func (*VideoSegmentCache_CacheSegment_Call) Run 

func (_c *VideoSegmentCache_CacheSegment_Call) Run(run func(ctxt context.Context, segment common.VideoSegmentWithData, ttl time.Duration)) *VideoSegmentCache_CacheSegment_Call

func (*VideoSegmentCache_CacheSegment_Call) RunAndReturn 

func (_c *VideoSegmentCache_CacheSegment_Call) RunAndReturn(run func(ctxt context.Context, segment common.VideoSegmentWithData, ttl time.Duration) error) *VideoSegmentCache_CacheSegment_Call

type VideoSegmentCache_Expecter 

type VideoSegmentCache_Expecter struct {
	// contains filtered or unexported fields
}

func (*VideoSegmentCache_Expecter) CacheEntryCount 

func (_e *VideoSegmentCache_Expecter) CacheEntryCount(ctxt interface{}) *VideoSegmentCache_CacheEntryCount_Call

CacheEntryCount is a helper method to define mock.On call

  • ctxt context.Context

func (*VideoSegmentCache_Expecter) CacheSegment 

func (_e *VideoSegmentCache_Expecter) CacheSegment(ctxt interface{}, segment interface{}, ttl interface{}) *VideoSegmentCache_CacheSegment_Call

CacheSegment is a helper method to define mock.On call

  • ctxt context.Context
  • segment common.VideoSegmentWithData
  • ttl time.Duration

func (*VideoSegmentCache_Expecter) GetSegment 

func (_e *VideoSegmentCache_Expecter) GetSegment(ctxt interface{}, segment interface{}) *VideoSegmentCache_GetSegment_Call

GetSegment is a helper method to define mock.On call

  • ctxt context.Context
  • segment common.VideoSegment

func (*VideoSegmentCache_Expecter) GetSegments 

func (_e *VideoSegmentCache_Expecter) GetSegments(ctxt interface{}, segments interface{}) *VideoSegmentCache_GetSegments_Call

GetSegments is a helper method to define mock.On call

  • ctxt context.Context
  • segments []common.VideoSegment

func (*VideoSegmentCache_Expecter) PurgeSegments 

func (_e *VideoSegmentCache_Expecter) PurgeSegments(ctxt interface{}, segments interface{}) *VideoSegmentCache_PurgeSegments_Call

PurgeSegments is a helper method to define mock.On call

  • ctxt context.Context
  • segments []common.VideoSegment

type VideoSegmentCache_GetSegment_Call 

type VideoSegmentCache_GetSegment_Call struct {
	*mock.Call
}

VideoSegmentCache_GetSegment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSegment'

func (*VideoSegmentCache_GetSegment_Call) Return 

func (_c *VideoSegmentCache_GetSegment_Call) Return(bytes []byte, err error) *VideoSegmentCache_GetSegment_Call

func (*VideoSegmentCache_GetSegment_Call) Run 

func (_c *VideoSegmentCache_GetSegment_Call) Run(run func(ctxt context.Context, segment common.VideoSegment)) *VideoSegmentCache_GetSegment_Call

func (*VideoSegmentCache_GetSegment_Call) RunAndReturn 

func (_c *VideoSegmentCache_GetSegment_Call) RunAndReturn(run func(ctxt context.Context, segment common.VideoSegment) ([]byte, error)) *VideoSegmentCache_GetSegment_Call

type VideoSegmentCache_GetSegments_Call 

type VideoSegmentCache_GetSegments_Call struct {
	*mock.Call
}

VideoSegmentCache_GetSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSegments'

func (*VideoSegmentCache_GetSegments_Call) Return 

func (_c *VideoSegmentCache_GetSegments_Call) Return(stringToBytes map[string][]byte, err error) *VideoSegmentCache_GetSegments_Call

func (*VideoSegmentCache_GetSegments_Call) Run 

func (_c *VideoSegmentCache_GetSegments_Call) Run(run func(ctxt context.Context, segments []common.VideoSegment)) *VideoSegmentCache_GetSegments_Call

func (*VideoSegmentCache_GetSegments_Call) RunAndReturn 

func (_c *VideoSegmentCache_GetSegments_Call) RunAndReturn(run func(ctxt context.Context, segments []common.VideoSegment) (map[string][]byte, error)) *VideoSegmentCache_GetSegments_Call

type VideoSegmentCache_PurgeSegments_Call 

type VideoSegmentCache_PurgeSegments_Call struct {
	*mock.Call
}

VideoSegmentCache_PurgeSegments_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeSegments'

func (*VideoSegmentCache_PurgeSegments_Call) Return 

func (_c *VideoSegmentCache_PurgeSegments_Call) Return(err error) *VideoSegmentCache_PurgeSegments_Call

func (*VideoSegmentCache_PurgeSegments_Call) Run 

func (_c *VideoSegmentCache_PurgeSegments_Call) Run(run func(ctxt context.Context, segments []common.VideoSegment)) *VideoSegmentCache_PurgeSegments_Call

func (*VideoSegmentCache_PurgeSegments_Call) RunAndReturn 

func (_c *VideoSegmentCache_PurgeSegments_Call) RunAndReturn(run func(ctxt context.Context, segments []common.VideoSegment) error) *VideoSegmentCache_PurgeSegments_Call

type VideoSourceOperator 

type VideoSourceOperator struct {
	mock.Mock
}

VideoSourceOperator is an autogenerated mock type for the VideoSourceOperator type

func NewVideoSourceOperator 

func NewVideoSourceOperator(t interface {
	mock.TestingT
	Cleanup(func())
}) *VideoSourceOperator

NewVideoSourceOperator creates a new instance of VideoSourceOperator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*VideoSourceOperator) CacheEntryCount 

func (_mock *VideoSourceOperator) CacheEntryCount(ctxt context.Context) (int, error)

CacheEntryCount provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) ChangeVideoSourceStreamState 

func (_mock *VideoSourceOperator) ChangeVideoSourceStreamState(ctxt context.Context, id string, streaming int) error

ChangeVideoSourceStreamState provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) EXPECT 

func (_m *VideoSourceOperator) EXPECT() *VideoSourceOperator_Expecter

func (*VideoSourceOperator) NewSegmentFromSource 

func (_mock *VideoSourceOperator) NewSegmentFromSource(ctxt context.Context, segment common.VideoSegmentWithData) error

NewSegmentFromSource provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) Ready 

func (_mock *VideoSourceOperator) Ready(ctxt context.Context) error

Ready provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) RecordKnownVideoSource 

func (_mock *VideoSourceOperator) RecordKnownVideoSource(ctxt context.Context, id string, name string, segmentLen int, playlistURI *string, description *string, streaming int) error

RecordKnownVideoSource provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) StartRecording 

func (_mock *VideoSourceOperator) StartRecording(ctxt context.Context, newRecording common.Recording) error

StartRecording provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) Stop 

func (_mock *VideoSourceOperator) Stop(ctxt context.Context) error

Stop provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) StopRecording 

func (_mock *VideoSourceOperator) StopRecording(ctxt context.Context, recordingID string, endTime time.Time) error

StopRecording provides a mock function for the type VideoSourceOperator

func (*VideoSourceOperator) SyncActiveRecordingState 

func (_mock *VideoSourceOperator) SyncActiveRecordingState(timestamp time.Time) error

SyncActiveRecordingState provides a mock function for the type VideoSourceOperator

type VideoSourceOperator_CacheEntryCount_Call 

type VideoSourceOperator_CacheEntryCount_Call struct {
	*mock.Call
}

VideoSourceOperator_CacheEntryCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CacheEntryCount'

func (*VideoSourceOperator_CacheEntryCount_Call) Return 

func (_c *VideoSourceOperator_CacheEntryCount_Call) Return(n int, err error) *VideoSourceOperator_CacheEntryCount_Call

func (*VideoSourceOperator_CacheEntryCount_Call) Run 

func (_c *VideoSourceOperator_CacheEntryCount_Call) Run(run func(ctxt context.Context)) *VideoSourceOperator_CacheEntryCount_Call

func (*VideoSourceOperator_CacheEntryCount_Call) RunAndReturn 

func (_c *VideoSourceOperator_CacheEntryCount_Call) RunAndReturn(run func(ctxt context.Context) (int, error)) *VideoSourceOperator_CacheEntryCount_Call

type VideoSourceOperator_ChangeVideoSourceStreamState_Call 

type VideoSourceOperator_ChangeVideoSourceStreamState_Call struct {
	*mock.Call
}

VideoSourceOperator_ChangeVideoSourceStreamState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeVideoSourceStreamState'

func (*VideoSourceOperator_ChangeVideoSourceStreamState_Call) Return 

func (_c *VideoSourceOperator_ChangeVideoSourceStreamState_Call) Return(err error) *VideoSourceOperator_ChangeVideoSourceStreamState_Call

func (*VideoSourceOperator_ChangeVideoSourceStreamState_Call) Run 

func (_c *VideoSourceOperator_ChangeVideoSourceStreamState_Call) Run(run func(ctxt context.Context, id string, streaming int)) *VideoSourceOperator_ChangeVideoSourceStreamState_Call

func (*VideoSourceOperator_ChangeVideoSourceStreamState_Call) RunAndReturn 

func (_c *VideoSourceOperator_ChangeVideoSourceStreamState_Call) RunAndReturn(run func(ctxt context.Context, id string, streaming int) error) *VideoSourceOperator_ChangeVideoSourceStreamState_Call

type VideoSourceOperator_Expecter 

type VideoSourceOperator_Expecter struct {
	// contains filtered or unexported fields
}

func (*VideoSourceOperator_Expecter) CacheEntryCount 

func (_e *VideoSourceOperator_Expecter) CacheEntryCount(ctxt interface{}) *VideoSourceOperator_CacheEntryCount_Call

CacheEntryCount is a helper method to define mock.On call

  • ctxt context.Context

func (*VideoSourceOperator_Expecter) ChangeVideoSourceStreamState 

func (_e *VideoSourceOperator_Expecter) ChangeVideoSourceStreamState(ctxt interface{}, id interface{}, streaming interface{}) *VideoSourceOperator_ChangeVideoSourceStreamState_Call

ChangeVideoSourceStreamState is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • streaming int

func (*VideoSourceOperator_Expecter) NewSegmentFromSource 

func (_e *VideoSourceOperator_Expecter) NewSegmentFromSource(ctxt interface{}, segment interface{}) *VideoSourceOperator_NewSegmentFromSource_Call

NewSegmentFromSource is a helper method to define mock.On call

  • ctxt context.Context
  • segment common.VideoSegmentWithData

func (*VideoSourceOperator_Expecter) Ready 

func (_e *VideoSourceOperator_Expecter) Ready(ctxt interface{}) *VideoSourceOperator_Ready_Call

Ready is a helper method to define mock.On call

  • ctxt context.Context

func (*VideoSourceOperator_Expecter) RecordKnownVideoSource 

func (_e *VideoSourceOperator_Expecter) RecordKnownVideoSource(ctxt interface{}, id interface{}, name interface{}, segmentLen interface{}, playlistURI interface{}, description interface{}, streaming interface{}) *VideoSourceOperator_RecordKnownVideoSource_Call

RecordKnownVideoSource is a helper method to define mock.On call

  • ctxt context.Context
  • id string
  • name string
  • segmentLen int
  • playlistURI *string
  • description *string
  • streaming int

func (*VideoSourceOperator_Expecter) StartRecording 

func (_e *VideoSourceOperator_Expecter) StartRecording(ctxt interface{}, newRecording interface{}) *VideoSourceOperator_StartRecording_Call

StartRecording is a helper method to define mock.On call

  • ctxt context.Context
  • newRecording common.Recording

func (*VideoSourceOperator_Expecter) Stop 

func (_e *VideoSourceOperator_Expecter) Stop(ctxt interface{}) *VideoSourceOperator_Stop_Call

Stop is a helper method to define mock.On call

  • ctxt context.Context

func (*VideoSourceOperator_Expecter) StopRecording 

func (_e *VideoSourceOperator_Expecter) StopRecording(ctxt interface{}, recordingID interface{}, endTime interface{}) *VideoSourceOperator_StopRecording_Call

StopRecording is a helper method to define mock.On call

  • ctxt context.Context
  • recordingID string
  • endTime time.Time

func (*VideoSourceOperator_Expecter) SyncActiveRecordingState 

func (_e *VideoSourceOperator_Expecter) SyncActiveRecordingState(timestamp interface{}) *VideoSourceOperator_SyncActiveRecordingState_Call

SyncActiveRecordingState is a helper method to define mock.On call

  • timestamp time.Time

type VideoSourceOperator_NewSegmentFromSource_Call 

type VideoSourceOperator_NewSegmentFromSource_Call struct {
	*mock.Call
}

VideoSourceOperator_NewSegmentFromSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewSegmentFromSource'

func (*VideoSourceOperator_NewSegmentFromSource_Call) Return 

func (_c *VideoSourceOperator_NewSegmentFromSource_Call) Return(err error) *VideoSourceOperator_NewSegmentFromSource_Call

func (*VideoSourceOperator_NewSegmentFromSource_Call) Run 

func (_c *VideoSourceOperator_NewSegmentFromSource_Call) Run(run func(ctxt context.Context, segment common.VideoSegmentWithData)) *VideoSourceOperator_NewSegmentFromSource_Call

func (*VideoSourceOperator_NewSegmentFromSource_Call) RunAndReturn 

func (_c *VideoSourceOperator_NewSegmentFromSource_Call) RunAndReturn(run func(ctxt context.Context, segment common.VideoSegmentWithData) error) *VideoSourceOperator_NewSegmentFromSource_Call

type VideoSourceOperator_Ready_Call 

type VideoSourceOperator_Ready_Call struct {
	*mock.Call
}

VideoSourceOperator_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*VideoSourceOperator_Ready_Call) Return 

func (_c *VideoSourceOperator_Ready_Call) Return(err error) *VideoSourceOperator_Ready_Call

func (*VideoSourceOperator_Ready_Call) Run 

func (_c *VideoSourceOperator_Ready_Call) Run(run func(ctxt context.Context)) *VideoSourceOperator_Ready_Call

func (*VideoSourceOperator_Ready_Call) RunAndReturn 

func (_c *VideoSourceOperator_Ready_Call) RunAndReturn(run func(ctxt context.Context) error) *VideoSourceOperator_Ready_Call

type VideoSourceOperator_RecordKnownVideoSource_Call 

type VideoSourceOperator_RecordKnownVideoSource_Call struct {
	*mock.Call
}

VideoSourceOperator_RecordKnownVideoSource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecordKnownVideoSource'

func (*VideoSourceOperator_RecordKnownVideoSource_Call) Return 

func (_c *VideoSourceOperator_RecordKnownVideoSource_Call) Return(err error) *VideoSourceOperator_RecordKnownVideoSource_Call

func (*VideoSourceOperator_RecordKnownVideoSource_Call) Run 

func (_c *VideoSourceOperator_RecordKnownVideoSource_Call) Run(run func(ctxt context.Context, id string, name string, segmentLen int, playlistURI *string, description *string, streaming int)) *VideoSourceOperator_RecordKnownVideoSource_Call

func (*VideoSourceOperator_RecordKnownVideoSource_Call) RunAndReturn 

func (_c *VideoSourceOperator_RecordKnownVideoSource_Call) RunAndReturn(run func(ctxt context.Context, id string, name string, segmentLen int, playlistURI *string, description *string, streaming int) error) *VideoSourceOperator_RecordKnownVideoSource_Call

type VideoSourceOperator_StartRecording_Call 

type VideoSourceOperator_StartRecording_Call struct {
	*mock.Call
}

VideoSourceOperator_StartRecording_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartRecording'

func (*VideoSourceOperator_StartRecording_Call) Return 

func (_c *VideoSourceOperator_StartRecording_Call) Return(err error) *VideoSourceOperator_StartRecording_Call

func (*VideoSourceOperator_StartRecording_Call) Run 

func (_c *VideoSourceOperator_StartRecording_Call) Run(run func(ctxt context.Context, newRecording common.Recording)) *VideoSourceOperator_StartRecording_Call

func (*VideoSourceOperator_StartRecording_Call) RunAndReturn 

func (_c *VideoSourceOperator_StartRecording_Call) RunAndReturn(run func(ctxt context.Context, newRecording common.Recording) error) *VideoSourceOperator_StartRecording_Call

type VideoSourceOperator_StopRecording_Call 

type VideoSourceOperator_StopRecording_Call struct {
	*mock.Call
}

VideoSourceOperator_StopRecording_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopRecording'

func (*VideoSourceOperator_StopRecording_Call) Return 

func (_c *VideoSourceOperator_StopRecording_Call) Return(err error) *VideoSourceOperator_StopRecording_Call

func (*VideoSourceOperator_StopRecording_Call) Run 

func (_c *VideoSourceOperator_StopRecording_Call) Run(run func(ctxt context.Context, recordingID string, endTime time.Time)) *VideoSourceOperator_StopRecording_Call

func (*VideoSourceOperator_StopRecording_Call) RunAndReturn 

func (_c *VideoSourceOperator_StopRecording_Call) RunAndReturn(run func(ctxt context.Context, recordingID string, endTime time.Time) error) *VideoSourceOperator_StopRecording_Call

type VideoSourceOperator_Stop_Call 

type VideoSourceOperator_Stop_Call struct {
	*mock.Call
}

VideoSourceOperator_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*VideoSourceOperator_Stop_Call) Return 

func (_c *VideoSourceOperator_Stop_Call) Return(err error) *VideoSourceOperator_Stop_Call

func (*VideoSourceOperator_Stop_Call) Run 

func (_c *VideoSourceOperator_Stop_Call) Run(run func(ctxt context.Context)) *VideoSourceOperator_Stop_Call

func (*VideoSourceOperator_Stop_Call) RunAndReturn 

func (_c *VideoSourceOperator_Stop_Call) RunAndReturn(run func(ctxt context.Context) error) *VideoSourceOperator_Stop_Call

type VideoSourceOperator_SyncActiveRecordingState_Call 

type VideoSourceOperator_SyncActiveRecordingState_Call struct {
	*mock.Call
}

VideoSourceOperator_SyncActiveRecordingState_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SyncActiveRecordingState'

func (*VideoSourceOperator_SyncActiveRecordingState_Call) Return 

func (_c *VideoSourceOperator_SyncActiveRecordingState_Call) Return(err error) *VideoSourceOperator_SyncActiveRecordingState_Call

func (*VideoSourceOperator_SyncActiveRecordingState_Call) Run 

func (_c *VideoSourceOperator_SyncActiveRecordingState_Call) Run(run func(timestamp time.Time)) *VideoSourceOperator_SyncActiveRecordingState_Call

func (*VideoSourceOperator_SyncActiveRecordingState_Call) RunAndReturn 

func (_c *VideoSourceOperator_SyncActiveRecordingState_Call) RunAndReturn(run func(timestamp time.Time) error) *VideoSourceOperator_SyncActiveRecordingState_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
⌂ 换网址