mocks

package
v4.0.2 Latest Latest
Warning

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

 Go to latest Published: Mar 11, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SyncQueries 

type SyncQueries struct {
	mock.Mock
}

SyncQueries is an autogenerated mock type for the SyncQueries type

func NewSyncQueries 

func NewSyncQueries(t interface {
	mock.TestingT
	Cleanup(func())
}) *SyncQueries

NewSyncQueries creates a new instance of SyncQueries. 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 (*SyncQueries) AddToQueue 

func (_mock *SyncQueries) AddToQueue(ctx context.Context, record *db.StateRecord) error

AddToQueue provides a mock function for the type SyncQueries

func (*SyncQueries) CheckQueueExists 

func (_mock *SyncQueries) CheckQueueExists(ctx context.Context, semaphoreName string, holderKey string, controllerName string) ([]db.StateRecord, error)

CheckQueueExists provides a mock function for the type SyncQueries

func (*SyncQueries) CreateSemaphoreLimit 

func (_mock *SyncQueries) CreateSemaphoreLimit(ctx context.Context, name string, sizeLimit int) error

CreateSemaphoreLimit provides a mock function for the type SyncQueries

func (*SyncQueries) DeleteLock 

func (_mock *SyncQueries) DeleteLock(ctx context.Context, lockName string) error

DeleteLock provides a mock function for the type SyncQueries

func (*SyncQueries) DeleteSemaphoreLimit 

func (_mock *SyncQueries) DeleteSemaphoreLimit(ctx context.Context, name string) error

DeleteSemaphoreLimit provides a mock function for the type SyncQueries

func (*SyncQueries) EXPECT 

func (_m *SyncQueries) EXPECT() *SyncQueries_Expecter

func (*SyncQueries) ExpireInactiveLocks 

func (_mock *SyncQueries) ExpireInactiveLocks(ctx context.Context, inactiveTimeout time.Duration) (int64, error)

ExpireInactiveLocks provides a mock function for the type SyncQueries

func (*SyncQueries) GetCurrentHolders 

func (_mock *SyncQueries) GetCurrentHolders(ctx context.Context, session db0.Session, semaphoreName string) ([]db.StateRecord, error)

GetCurrentHolders provides a mock function for the type SyncQueries

func (*SyncQueries) GetCurrentPending 

func (_mock *SyncQueries) GetCurrentPending(ctx context.Context, semaphoreName string) ([]db.StateRecord, error)

GetCurrentPending provides a mock function for the type SyncQueries

func (*SyncQueries) GetCurrentState 

func (_mock *SyncQueries) GetCurrentState(ctx context.Context, session db0.Session, semaphoreName string, held bool) ([]db.StateRecord, error)

GetCurrentState provides a mock function for the type SyncQueries

func (*SyncQueries) GetExistingLocks 

func (_mock *SyncQueries) GetExistingLocks(ctx context.Context, lockName string, controllerName string) ([]db.LockRecord, error)

GetExistingLocks provides a mock function for the type SyncQueries

func (*SyncQueries) GetOrderedQueue 

func (_mock *SyncQueries) GetOrderedQueue(ctx context.Context, session db0.Session, semaphoreName string, inactiveTimeout time.Duration) ([]db.StateRecord, error)

GetOrderedQueue provides a mock function for the type SyncQueries

func (*SyncQueries) GetPendingInQueue 

func (_mock *SyncQueries) GetPendingInQueue(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) ([]db.StateRecord, error)

GetPendingInQueue provides a mock function for the type SyncQueries

func (*SyncQueries) GetPendingInQueueWithSession 

func (_mock *SyncQueries) GetPendingInQueueWithSession(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) ([]db.StateRecord, error)

GetPendingInQueueWithSession provides a mock function for the type SyncQueries

func (*SyncQueries) GetSemaphoreLimit 

func (_mock *SyncQueries) GetSemaphoreLimit(ctx context.Context, dbKey string) (*db.LimitRecord, error)

GetSemaphoreLimit provides a mock function for the type SyncQueries

func (*SyncQueries) InsertControllerHealth 

func (_mock *SyncQueries) InsertControllerHealth(ctx context.Context, record *db.ControllerHealthRecord) error

InsertControllerHealth provides a mock function for the type SyncQueries

func (*SyncQueries) InsertHeldState 

func (_mock *SyncQueries) InsertHeldState(ctx context.Context, session db0.Session, record *db.StateRecord) error

InsertHeldState provides a mock function for the type SyncQueries

func (*SyncQueries) InsertHeldStateWithSession 

func (_mock *SyncQueries) InsertHeldStateWithSession(ctx context.Context, session db0.Session, record *db.StateRecord) error

InsertHeldStateWithSession provides a mock function for the type SyncQueries

func (*SyncQueries) InsertLock 

func (_mock *SyncQueries) InsertLock(ctx context.Context, record *db.LockRecord) error

InsertLock provides a mock function for the type SyncQueries

func (*SyncQueries) ReleaseHeld 

func (_mock *SyncQueries) ReleaseHeld(ctx context.Context, semaphoreName string, key string, controllerName string) error

ReleaseHeld provides a mock function for the type SyncQueries

func (*SyncQueries) RemoveFromQueue 

func (_mock *SyncQueries) RemoveFromQueue(ctx context.Context, semaphoreName string, holderKey string) error

RemoveFromQueue provides a mock function for the type SyncQueries

func (*SyncQueries) UpdateControllerTimestamp 

func (_mock *SyncQueries) UpdateControllerTimestamp(ctx context.Context, controllerName string, timestamp time.Time) error

UpdateControllerTimestamp provides a mock function for the type SyncQueries

func (*SyncQueries) UpdateSemaphoreLimit 

func (_mock *SyncQueries) UpdateSemaphoreLimit(ctx context.Context, name string, sizeLimit int) error

UpdateSemaphoreLimit provides a mock function for the type SyncQueries

func (*SyncQueries) UpdateStateToHeld 

func (_mock *SyncQueries) UpdateStateToHeld(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) error

UpdateStateToHeld provides a mock function for the type SyncQueries

func (*SyncQueries) UpdateStateToHeldWithSession 

func (_mock *SyncQueries) UpdateStateToHeldWithSession(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) error

UpdateStateToHeldWithSession provides a mock function for the type SyncQueries

type SyncQueries_AddToQueue_Call 

type SyncQueries_AddToQueue_Call struct {
	*mock.Call
}

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

func (*SyncQueries_AddToQueue_Call) Return 

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

func (*SyncQueries_AddToQueue_Call) Run 

func (_c *SyncQueries_AddToQueue_Call) Run(run func(ctx context.Context, record *db.StateRecord)) *SyncQueries_AddToQueue_Call

func (*SyncQueries_AddToQueue_Call) RunAndReturn 

func (_c *SyncQueries_AddToQueue_Call) RunAndReturn(run func(ctx context.Context, record *db.StateRecord) error) *SyncQueries_AddToQueue_Call

type SyncQueries_CheckQueueExists_Call 

type SyncQueries_CheckQueueExists_Call struct {
	*mock.Call
}

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

func (*SyncQueries_CheckQueueExists_Call) Return 

func (_c *SyncQueries_CheckQueueExists_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_CheckQueueExists_Call

func (*SyncQueries_CheckQueueExists_Call) Run 

func (_c *SyncQueries_CheckQueueExists_Call) Run(run func(ctx context.Context, semaphoreName string, holderKey string, controllerName string)) *SyncQueries_CheckQueueExists_Call

func (*SyncQueries_CheckQueueExists_Call) RunAndReturn 

func (_c *SyncQueries_CheckQueueExists_Call) RunAndReturn(run func(ctx context.Context, semaphoreName string, holderKey string, controllerName string) ([]db.StateRecord, error)) *SyncQueries_CheckQueueExists_Call

type SyncQueries_CreateSemaphoreLimit_Call 

type SyncQueries_CreateSemaphoreLimit_Call struct {
	*mock.Call
}

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

func (*SyncQueries_CreateSemaphoreLimit_Call) Return 

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

func (*SyncQueries_CreateSemaphoreLimit_Call) Run 

func (_c *SyncQueries_CreateSemaphoreLimit_Call) Run(run func(ctx context.Context, name string, sizeLimit int)) *SyncQueries_CreateSemaphoreLimit_Call

func (*SyncQueries_CreateSemaphoreLimit_Call) RunAndReturn 

func (_c *SyncQueries_CreateSemaphoreLimit_Call) RunAndReturn(run func(ctx context.Context, name string, sizeLimit int) error) *SyncQueries_CreateSemaphoreLimit_Call

type SyncQueries_DeleteLock_Call 

type SyncQueries_DeleteLock_Call struct {
	*mock.Call
}

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

func (*SyncQueries_DeleteLock_Call) Return 

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

func (*SyncQueries_DeleteLock_Call) Run 

func (_c *SyncQueries_DeleteLock_Call) Run(run func(ctx context.Context, lockName string)) *SyncQueries_DeleteLock_Call

func (*SyncQueries_DeleteLock_Call) RunAndReturn 

func (_c *SyncQueries_DeleteLock_Call) RunAndReturn(run func(ctx context.Context, lockName string) error) *SyncQueries_DeleteLock_Call

type SyncQueries_DeleteSemaphoreLimit_Call 

type SyncQueries_DeleteSemaphoreLimit_Call struct {
	*mock.Call
}

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

func (*SyncQueries_DeleteSemaphoreLimit_Call) Return 

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

func (*SyncQueries_DeleteSemaphoreLimit_Call) Run 

func (_c *SyncQueries_DeleteSemaphoreLimit_Call) Run(run func(ctx context.Context, name string)) *SyncQueries_DeleteSemaphoreLimit_Call

func (*SyncQueries_DeleteSemaphoreLimit_Call) RunAndReturn 

func (_c *SyncQueries_DeleteSemaphoreLimit_Call) RunAndReturn(run func(ctx context.Context, name string) error) *SyncQueries_DeleteSemaphoreLimit_Call

type SyncQueries_Expecter 

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

func (*SyncQueries_Expecter) AddToQueue 

func (_e *SyncQueries_Expecter) AddToQueue(ctx interface{}, record interface{}) *SyncQueries_AddToQueue_Call

AddToQueue is a helper method to define mock.On call

  • ctx context.Context
  • record *db.StateRecord

func (*SyncQueries_Expecter) CheckQueueExists 

func (_e *SyncQueries_Expecter) CheckQueueExists(ctx interface{}, semaphoreName interface{}, holderKey interface{}, controllerName interface{}) *SyncQueries_CheckQueueExists_Call

CheckQueueExists is a helper method to define mock.On call

  • ctx context.Context
  • semaphoreName string
  • holderKey string
  • controllerName string

func (*SyncQueries_Expecter) CreateSemaphoreLimit 

func (_e *SyncQueries_Expecter) CreateSemaphoreLimit(ctx interface{}, name interface{}, sizeLimit interface{}) *SyncQueries_CreateSemaphoreLimit_Call

CreateSemaphoreLimit is a helper method to define mock.On call

  • ctx context.Context
  • name string
  • sizeLimit int

func (*SyncQueries_Expecter) DeleteLock 

func (_e *SyncQueries_Expecter) DeleteLock(ctx interface{}, lockName interface{}) *SyncQueries_DeleteLock_Call

DeleteLock is a helper method to define mock.On call

  • ctx context.Context
  • lockName string

func (*SyncQueries_Expecter) DeleteSemaphoreLimit 

func (_e *SyncQueries_Expecter) DeleteSemaphoreLimit(ctx interface{}, name interface{}) *SyncQueries_DeleteSemaphoreLimit_Call

DeleteSemaphoreLimit is a helper method to define mock.On call

  • ctx context.Context
  • name string

func (*SyncQueries_Expecter) ExpireInactiveLocks 

func (_e *SyncQueries_Expecter) ExpireInactiveLocks(ctx interface{}, inactiveTimeout interface{}) *SyncQueries_ExpireInactiveLocks_Call

ExpireInactiveLocks is a helper method to define mock.On call

  • ctx context.Context
  • inactiveTimeout time.Duration

func (*SyncQueries_Expecter) GetCurrentHolders 

func (_e *SyncQueries_Expecter) GetCurrentHolders(ctx interface{}, session interface{}, semaphoreName interface{}) *SyncQueries_GetCurrentHolders_Call

GetCurrentHolders is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string

func (*SyncQueries_Expecter) GetCurrentPending 

func (_e *SyncQueries_Expecter) GetCurrentPending(ctx interface{}, semaphoreName interface{}) *SyncQueries_GetCurrentPending_Call

GetCurrentPending is a helper method to define mock.On call

  • ctx context.Context
  • semaphoreName string

func (*SyncQueries_Expecter) GetCurrentState 

func (_e *SyncQueries_Expecter) GetCurrentState(ctx interface{}, session interface{}, semaphoreName interface{}, held interface{}) *SyncQueries_GetCurrentState_Call

GetCurrentState is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string
  • held bool

func (*SyncQueries_Expecter) GetExistingLocks 

func (_e *SyncQueries_Expecter) GetExistingLocks(ctx interface{}, lockName interface{}, controllerName interface{}) *SyncQueries_GetExistingLocks_Call

GetExistingLocks is a helper method to define mock.On call

  • ctx context.Context
  • lockName string
  • controllerName string

func (*SyncQueries_Expecter) GetOrderedQueue 

func (_e *SyncQueries_Expecter) GetOrderedQueue(ctx interface{}, session interface{}, semaphoreName interface{}, inactiveTimeout interface{}) *SyncQueries_GetOrderedQueue_Call

GetOrderedQueue is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string
  • inactiveTimeout time.Duration

func (*SyncQueries_Expecter) GetPendingInQueue 

func (_e *SyncQueries_Expecter) GetPendingInQueue(ctx interface{}, session interface{}, semaphoreName interface{}, holderKey interface{}, controllerName interface{}) *SyncQueries_GetPendingInQueue_Call

GetPendingInQueue is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string
  • holderKey string
  • controllerName string

func (*SyncQueries_Expecter) GetPendingInQueueWithSession 

func (_e *SyncQueries_Expecter) GetPendingInQueueWithSession(ctx interface{}, session interface{}, semaphoreName interface{}, holderKey interface{}, controllerName interface{}) *SyncQueries_GetPendingInQueueWithSession_Call

GetPendingInQueueWithSession is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string
  • holderKey string
  • controllerName string

func (*SyncQueries_Expecter) GetSemaphoreLimit 

func (_e *SyncQueries_Expecter) GetSemaphoreLimit(ctx interface{}, dbKey interface{}) *SyncQueries_GetSemaphoreLimit_Call

GetSemaphoreLimit is a helper method to define mock.On call

  • ctx context.Context
  • dbKey string

func (*SyncQueries_Expecter) InsertControllerHealth 

func (_e *SyncQueries_Expecter) InsertControllerHealth(ctx interface{}, record interface{}) *SyncQueries_InsertControllerHealth_Call

InsertControllerHealth is a helper method to define mock.On call

  • ctx context.Context
  • record *db.ControllerHealthRecord

func (*SyncQueries_Expecter) InsertHeldState 

func (_e *SyncQueries_Expecter) InsertHeldState(ctx interface{}, session interface{}, record interface{}) *SyncQueries_InsertHeldState_Call

InsertHeldState is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • record *db.StateRecord

func (*SyncQueries_Expecter) InsertHeldStateWithSession 

func (_e *SyncQueries_Expecter) InsertHeldStateWithSession(ctx interface{}, session interface{}, record interface{}) *SyncQueries_InsertHeldStateWithSession_Call

InsertHeldStateWithSession is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • record *db.StateRecord

func (*SyncQueries_Expecter) InsertLock 

func (_e *SyncQueries_Expecter) InsertLock(ctx interface{}, record interface{}) *SyncQueries_InsertLock_Call

InsertLock is a helper method to define mock.On call

  • ctx context.Context
  • record *db.LockRecord

func (*SyncQueries_Expecter) ReleaseHeld 

func (_e *SyncQueries_Expecter) ReleaseHeld(ctx interface{}, semaphoreName interface{}, key interface{}, controllerName interface{}) *SyncQueries_ReleaseHeld_Call

ReleaseHeld is a helper method to define mock.On call

  • ctx context.Context
  • semaphoreName string
  • key string
  • controllerName string

func (*SyncQueries_Expecter) RemoveFromQueue 

func (_e *SyncQueries_Expecter) RemoveFromQueue(ctx interface{}, semaphoreName interface{}, holderKey interface{}) *SyncQueries_RemoveFromQueue_Call

RemoveFromQueue is a helper method to define mock.On call

  • ctx context.Context
  • semaphoreName string
  • holderKey string

func (*SyncQueries_Expecter) UpdateControllerTimestamp 

func (_e *SyncQueries_Expecter) UpdateControllerTimestamp(ctx interface{}, controllerName interface{}, timestamp interface{}) *SyncQueries_UpdateControllerTimestamp_Call

UpdateControllerTimestamp is a helper method to define mock.On call

  • ctx context.Context
  • controllerName string
  • timestamp time.Time

func (*SyncQueries_Expecter) UpdateSemaphoreLimit 

func (_e *SyncQueries_Expecter) UpdateSemaphoreLimit(ctx interface{}, name interface{}, sizeLimit interface{}) *SyncQueries_UpdateSemaphoreLimit_Call

UpdateSemaphoreLimit is a helper method to define mock.On call

  • ctx context.Context
  • name string
  • sizeLimit int

func (*SyncQueries_Expecter) UpdateStateToHeld 

func (_e *SyncQueries_Expecter) UpdateStateToHeld(ctx interface{}, session interface{}, semaphoreName interface{}, holderKey interface{}, controllerName interface{}) *SyncQueries_UpdateStateToHeld_Call

UpdateStateToHeld is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string
  • holderKey string
  • controllerName string

func (*SyncQueries_Expecter) UpdateStateToHeldWithSession 

func (_e *SyncQueries_Expecter) UpdateStateToHeldWithSession(ctx interface{}, session interface{}, semaphoreName interface{}, holderKey interface{}, controllerName interface{}) *SyncQueries_UpdateStateToHeldWithSession_Call

UpdateStateToHeldWithSession is a helper method to define mock.On call

  • ctx context.Context
  • session db0.Session
  • semaphoreName string
  • holderKey string
  • controllerName string

type SyncQueries_ExpireInactiveLocks_Call 

type SyncQueries_ExpireInactiveLocks_Call struct {
	*mock.Call
}

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

func (*SyncQueries_ExpireInactiveLocks_Call) Return 

func (_c *SyncQueries_ExpireInactiveLocks_Call) Return(n int64, err error) *SyncQueries_ExpireInactiveLocks_Call

func (*SyncQueries_ExpireInactiveLocks_Call) Run 

func (_c *SyncQueries_ExpireInactiveLocks_Call) Run(run func(ctx context.Context, inactiveTimeout time.Duration)) *SyncQueries_ExpireInactiveLocks_Call

func (*SyncQueries_ExpireInactiveLocks_Call) RunAndReturn 

func (_c *SyncQueries_ExpireInactiveLocks_Call) RunAndReturn(run func(ctx context.Context, inactiveTimeout time.Duration) (int64, error)) *SyncQueries_ExpireInactiveLocks_Call

type SyncQueries_GetCurrentHolders_Call 

type SyncQueries_GetCurrentHolders_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetCurrentHolders_Call) Return 

func (_c *SyncQueries_GetCurrentHolders_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_GetCurrentHolders_Call

func (*SyncQueries_GetCurrentHolders_Call) Run 

func (_c *SyncQueries_GetCurrentHolders_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string)) *SyncQueries_GetCurrentHolders_Call

func (*SyncQueries_GetCurrentHolders_Call) RunAndReturn 

func (_c *SyncQueries_GetCurrentHolders_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string) ([]db.StateRecord, error)) *SyncQueries_GetCurrentHolders_Call

type SyncQueries_GetCurrentPending_Call 

type SyncQueries_GetCurrentPending_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetCurrentPending_Call) Return 

func (_c *SyncQueries_GetCurrentPending_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_GetCurrentPending_Call

func (*SyncQueries_GetCurrentPending_Call) Run 

func (_c *SyncQueries_GetCurrentPending_Call) Run(run func(ctx context.Context, semaphoreName string)) *SyncQueries_GetCurrentPending_Call

func (*SyncQueries_GetCurrentPending_Call) RunAndReturn 

func (_c *SyncQueries_GetCurrentPending_Call) RunAndReturn(run func(ctx context.Context, semaphoreName string) ([]db.StateRecord, error)) *SyncQueries_GetCurrentPending_Call

type SyncQueries_GetCurrentState_Call 

type SyncQueries_GetCurrentState_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetCurrentState_Call) Return 

func (_c *SyncQueries_GetCurrentState_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_GetCurrentState_Call

func (*SyncQueries_GetCurrentState_Call) Run 

func (_c *SyncQueries_GetCurrentState_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string, held bool)) *SyncQueries_GetCurrentState_Call

func (*SyncQueries_GetCurrentState_Call) RunAndReturn 

func (_c *SyncQueries_GetCurrentState_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string, held bool) ([]db.StateRecord, error)) *SyncQueries_GetCurrentState_Call

type SyncQueries_GetExistingLocks_Call 

type SyncQueries_GetExistingLocks_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetExistingLocks_Call) Return 

func (_c *SyncQueries_GetExistingLocks_Call) Return(lockRecords []db.LockRecord, err error) *SyncQueries_GetExistingLocks_Call

func (*SyncQueries_GetExistingLocks_Call) Run 

func (_c *SyncQueries_GetExistingLocks_Call) Run(run func(ctx context.Context, lockName string, controllerName string)) *SyncQueries_GetExistingLocks_Call

func (*SyncQueries_GetExistingLocks_Call) RunAndReturn 

func (_c *SyncQueries_GetExistingLocks_Call) RunAndReturn(run func(ctx context.Context, lockName string, controllerName string) ([]db.LockRecord, error)) *SyncQueries_GetExistingLocks_Call

type SyncQueries_GetOrderedQueue_Call 

type SyncQueries_GetOrderedQueue_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetOrderedQueue_Call) Return 

func (_c *SyncQueries_GetOrderedQueue_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_GetOrderedQueue_Call

func (*SyncQueries_GetOrderedQueue_Call) Run 

func (_c *SyncQueries_GetOrderedQueue_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string, inactiveTimeout time.Duration)) *SyncQueries_GetOrderedQueue_Call

func (*SyncQueries_GetOrderedQueue_Call) RunAndReturn 

func (_c *SyncQueries_GetOrderedQueue_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string, inactiveTimeout time.Duration) ([]db.StateRecord, error)) *SyncQueries_GetOrderedQueue_Call

type SyncQueries_GetPendingInQueueWithSession_Call 

type SyncQueries_GetPendingInQueueWithSession_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetPendingInQueueWithSession_Call) Return 

func (_c *SyncQueries_GetPendingInQueueWithSession_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_GetPendingInQueueWithSession_Call

func (*SyncQueries_GetPendingInQueueWithSession_Call) Run 

func (_c *SyncQueries_GetPendingInQueueWithSession_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string)) *SyncQueries_GetPendingInQueueWithSession_Call

func (*SyncQueries_GetPendingInQueueWithSession_Call) RunAndReturn 

func (_c *SyncQueries_GetPendingInQueueWithSession_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) ([]db.StateRecord, error)) *SyncQueries_GetPendingInQueueWithSession_Call

type SyncQueries_GetPendingInQueue_Call 

type SyncQueries_GetPendingInQueue_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetPendingInQueue_Call) Return 

func (_c *SyncQueries_GetPendingInQueue_Call) Return(stateRecords []db.StateRecord, err error) *SyncQueries_GetPendingInQueue_Call

func (*SyncQueries_GetPendingInQueue_Call) Run 

func (_c *SyncQueries_GetPendingInQueue_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string)) *SyncQueries_GetPendingInQueue_Call

func (*SyncQueries_GetPendingInQueue_Call) RunAndReturn 

func (_c *SyncQueries_GetPendingInQueue_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) ([]db.StateRecord, error)) *SyncQueries_GetPendingInQueue_Call

type SyncQueries_GetSemaphoreLimit_Call 

type SyncQueries_GetSemaphoreLimit_Call struct {
	*mock.Call
}

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

func (*SyncQueries_GetSemaphoreLimit_Call) Return 

func (_c *SyncQueries_GetSemaphoreLimit_Call) Return(limitRecord *db.LimitRecord, err error) *SyncQueries_GetSemaphoreLimit_Call

func (*SyncQueries_GetSemaphoreLimit_Call) Run 

func (_c *SyncQueries_GetSemaphoreLimit_Call) Run(run func(ctx context.Context, dbKey string)) *SyncQueries_GetSemaphoreLimit_Call

func (*SyncQueries_GetSemaphoreLimit_Call) RunAndReturn 

func (_c *SyncQueries_GetSemaphoreLimit_Call) RunAndReturn(run func(ctx context.Context, dbKey string) (*db.LimitRecord, error)) *SyncQueries_GetSemaphoreLimit_Call

type SyncQueries_InsertControllerHealth_Call 

type SyncQueries_InsertControllerHealth_Call struct {
	*mock.Call
}

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

func (*SyncQueries_InsertControllerHealth_Call) Return 

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

func (*SyncQueries_InsertControllerHealth_Call) Run 

func (_c *SyncQueries_InsertControllerHealth_Call) Run(run func(ctx context.Context, record *db.ControllerHealthRecord)) *SyncQueries_InsertControllerHealth_Call

func (*SyncQueries_InsertControllerHealth_Call) RunAndReturn 

func (_c *SyncQueries_InsertControllerHealth_Call) RunAndReturn(run func(ctx context.Context, record *db.ControllerHealthRecord) error) *SyncQueries_InsertControllerHealth_Call

type SyncQueries_InsertHeldStateWithSession_Call 

type SyncQueries_InsertHeldStateWithSession_Call struct {
	*mock.Call
}

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

func (*SyncQueries_InsertHeldStateWithSession_Call) Return 

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

func (*SyncQueries_InsertHeldStateWithSession_Call) Run 

func (_c *SyncQueries_InsertHeldStateWithSession_Call) Run(run func(ctx context.Context, session db0.Session, record *db.StateRecord)) *SyncQueries_InsertHeldStateWithSession_Call

func (*SyncQueries_InsertHeldStateWithSession_Call) RunAndReturn 

func (_c *SyncQueries_InsertHeldStateWithSession_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, record *db.StateRecord) error) *SyncQueries_InsertHeldStateWithSession_Call

type SyncQueries_InsertHeldState_Call 

type SyncQueries_InsertHeldState_Call struct {
	*mock.Call
}

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

func (*SyncQueries_InsertHeldState_Call) Return 

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

func (*SyncQueries_InsertHeldState_Call) Run 

func (_c *SyncQueries_InsertHeldState_Call) Run(run func(ctx context.Context, session db0.Session, record *db.StateRecord)) *SyncQueries_InsertHeldState_Call

func (*SyncQueries_InsertHeldState_Call) RunAndReturn 

func (_c *SyncQueries_InsertHeldState_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, record *db.StateRecord) error) *SyncQueries_InsertHeldState_Call

type SyncQueries_InsertLock_Call 

type SyncQueries_InsertLock_Call struct {
	*mock.Call
}

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

func (*SyncQueries_InsertLock_Call) Return 

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

func (*SyncQueries_InsertLock_Call) Run 

func (_c *SyncQueries_InsertLock_Call) Run(run func(ctx context.Context, record *db.LockRecord)) *SyncQueries_InsertLock_Call

func (*SyncQueries_InsertLock_Call) RunAndReturn 

func (_c *SyncQueries_InsertLock_Call) RunAndReturn(run func(ctx context.Context, record *db.LockRecord) error) *SyncQueries_InsertLock_Call

type SyncQueries_ReleaseHeld_Call 

type SyncQueries_ReleaseHeld_Call struct {
	*mock.Call
}

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

func (*SyncQueries_ReleaseHeld_Call) Return 

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

func (*SyncQueries_ReleaseHeld_Call) Run 

func (_c *SyncQueries_ReleaseHeld_Call) Run(run func(ctx context.Context, semaphoreName string, key string, controllerName string)) *SyncQueries_ReleaseHeld_Call

func (*SyncQueries_ReleaseHeld_Call) RunAndReturn 

func (_c *SyncQueries_ReleaseHeld_Call) RunAndReturn(run func(ctx context.Context, semaphoreName string, key string, controllerName string) error) *SyncQueries_ReleaseHeld_Call

type SyncQueries_RemoveFromQueue_Call 

type SyncQueries_RemoveFromQueue_Call struct {
	*mock.Call
}

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

func (*SyncQueries_RemoveFromQueue_Call) Return 

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

func (*SyncQueries_RemoveFromQueue_Call) Run 

func (_c *SyncQueries_RemoveFromQueue_Call) Run(run func(ctx context.Context, semaphoreName string, holderKey string)) *SyncQueries_RemoveFromQueue_Call

func (*SyncQueries_RemoveFromQueue_Call) RunAndReturn 

func (_c *SyncQueries_RemoveFromQueue_Call) RunAndReturn(run func(ctx context.Context, semaphoreName string, holderKey string) error) *SyncQueries_RemoveFromQueue_Call

type SyncQueries_UpdateControllerTimestamp_Call 

type SyncQueries_UpdateControllerTimestamp_Call struct {
	*mock.Call
}

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

func (*SyncQueries_UpdateControllerTimestamp_Call) Return 

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

func (*SyncQueries_UpdateControllerTimestamp_Call) Run 

func (_c *SyncQueries_UpdateControllerTimestamp_Call) Run(run func(ctx context.Context, controllerName string, timestamp time.Time)) *SyncQueries_UpdateControllerTimestamp_Call

func (*SyncQueries_UpdateControllerTimestamp_Call) RunAndReturn 

func (_c *SyncQueries_UpdateControllerTimestamp_Call) RunAndReturn(run func(ctx context.Context, controllerName string, timestamp time.Time) error) *SyncQueries_UpdateControllerTimestamp_Call

type SyncQueries_UpdateSemaphoreLimit_Call 

type SyncQueries_UpdateSemaphoreLimit_Call struct {
	*mock.Call
}

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

func (*SyncQueries_UpdateSemaphoreLimit_Call) Return 

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

func (*SyncQueries_UpdateSemaphoreLimit_Call) Run 

func (_c *SyncQueries_UpdateSemaphoreLimit_Call) Run(run func(ctx context.Context, name string, sizeLimit int)) *SyncQueries_UpdateSemaphoreLimit_Call

func (*SyncQueries_UpdateSemaphoreLimit_Call) RunAndReturn 

func (_c *SyncQueries_UpdateSemaphoreLimit_Call) RunAndReturn(run func(ctx context.Context, name string, sizeLimit int) error) *SyncQueries_UpdateSemaphoreLimit_Call

type SyncQueries_UpdateStateToHeldWithSession_Call 

type SyncQueries_UpdateStateToHeldWithSession_Call struct {
	*mock.Call
}

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

func (*SyncQueries_UpdateStateToHeldWithSession_Call) Return 

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

func (*SyncQueries_UpdateStateToHeldWithSession_Call) Run 

func (_c *SyncQueries_UpdateStateToHeldWithSession_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string)) *SyncQueries_UpdateStateToHeldWithSession_Call

func (*SyncQueries_UpdateStateToHeldWithSession_Call) RunAndReturn 

func (_c *SyncQueries_UpdateStateToHeldWithSession_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) error) *SyncQueries_UpdateStateToHeldWithSession_Call

type SyncQueries_UpdateStateToHeld_Call 

type SyncQueries_UpdateStateToHeld_Call struct {
	*mock.Call
}

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

func (*SyncQueries_UpdateStateToHeld_Call) Return 

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

func (*SyncQueries_UpdateStateToHeld_Call) Run 

func (_c *SyncQueries_UpdateStateToHeld_Call) Run(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string)) *SyncQueries_UpdateStateToHeld_Call

func (*SyncQueries_UpdateStateToHeld_Call) RunAndReturn 

func (_c *SyncQueries_UpdateStateToHeld_Call) RunAndReturn(run func(ctx context.Context, session db0.Session, semaphoreName string, holderKey string, controllerName string) error) *SyncQueries_UpdateStateToHeld_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.