Documentation
¶
Index ¶
- type Throttler
- func (_mock *Throttler) Add(key sync.Key, priority int32, creationTime time.Time)
- func (_mock *Throttler) Admit(key sync.Key) bool
- func (_m *Throttler) EXPECT() *Throttler_Expecter
- func (_mock *Throttler) Init(wfs []v1alpha1.Workflow) error
- func (_mock *Throttler) Remove(key sync.Key)
- func (_mock *Throttler) ResetNamespaceParallelism(namespace string)
- func (_mock *Throttler) UpdateNamespaceParallelism(namespace string, limit int)
- func (_mock *Throttler) UpdateParallelism(limit int)
- type Throttler_Add_Call
- func (_c *Throttler_Add_Call) Return() *Throttler_Add_Call
- func (_c *Throttler_Add_Call) Run(run func(key sync.Key, priority int32, creationTime time.Time)) *Throttler_Add_Call
- func (_c *Throttler_Add_Call) RunAndReturn(run func(key sync.Key, priority int32, creationTime time.Time)) *Throttler_Add_Call
- type Throttler_Admit_Call
- type Throttler_Expecter
- func (_e *Throttler_Expecter) Add(key interface{}, priority interface{}, creationTime interface{}) *Throttler_Add_Call
- func (_e *Throttler_Expecter) Admit(key interface{}) *Throttler_Admit_Call
- func (_e *Throttler_Expecter) Init(wfs interface{}) *Throttler_Init_Call
- func (_e *Throttler_Expecter) Remove(key interface{}) *Throttler_Remove_Call
- func (_e *Throttler_Expecter) ResetNamespaceParallelism(namespace interface{}) *Throttler_ResetNamespaceParallelism_Call
- func (_e *Throttler_Expecter) UpdateNamespaceParallelism(namespace interface{}, limit interface{}) *Throttler_UpdateNamespaceParallelism_Call
- func (_e *Throttler_Expecter) UpdateParallelism(limit interface{}) *Throttler_UpdateParallelism_Call
- type Throttler_Init_Call
- type Throttler_Remove_Call
- type Throttler_ResetNamespaceParallelism_Call
- func (_c *Throttler_ResetNamespaceParallelism_Call) Return() *Throttler_ResetNamespaceParallelism_Call
- func (_c *Throttler_ResetNamespaceParallelism_Call) Run(run func(namespace string)) *Throttler_ResetNamespaceParallelism_Call
- func (_c *Throttler_ResetNamespaceParallelism_Call) RunAndReturn(run func(namespace string)) *Throttler_ResetNamespaceParallelism_Call
- type Throttler_UpdateNamespaceParallelism_Call
- func (_c *Throttler_UpdateNamespaceParallelism_Call) Return() *Throttler_UpdateNamespaceParallelism_Call
- func (_c *Throttler_UpdateNamespaceParallelism_Call) Run(run func(namespace string, limit int)) *Throttler_UpdateNamespaceParallelism_Call
- func (_c *Throttler_UpdateNamespaceParallelism_Call) RunAndReturn(run func(namespace string, limit int)) *Throttler_UpdateNamespaceParallelism_Call
- type Throttler_UpdateParallelism_Call
- func (_c *Throttler_UpdateParallelism_Call) Return() *Throttler_UpdateParallelism_Call
- func (_c *Throttler_UpdateParallelism_Call) Run(run func(limit int)) *Throttler_UpdateParallelism_Call
- func (_c *Throttler_UpdateParallelism_Call) RunAndReturn(run func(limit int)) *Throttler_UpdateParallelism_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Throttler ¶
Throttler is an autogenerated mock type for the Throttler type
func NewThrottler ¶
NewThrottler creates a new instance of Throttler. 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 (*Throttler) EXPECT ¶
func (_m *Throttler) EXPECT() *Throttler_Expecter
func (*Throttler) ResetNamespaceParallelism ¶
ResetNamespaceParallelism provides a mock function for the type Throttler
func (*Throttler) UpdateNamespaceParallelism ¶
UpdateNamespaceParallelism provides a mock function for the type Throttler
func (*Throttler) UpdateParallelism ¶
UpdateParallelism provides a mock function for the type Throttler
type Throttler_Add_Call ¶
Throttler_Add_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Add'
func (*Throttler_Add_Call) Return ¶
func (_c *Throttler_Add_Call) Return() *Throttler_Add_Call
func (*Throttler_Add_Call) Run ¶
func (_c *Throttler_Add_Call) Run(run func(key sync.Key, priority int32, creationTime time.Time)) *Throttler_Add_Call
func (*Throttler_Add_Call) RunAndReturn ¶
func (_c *Throttler_Add_Call) RunAndReturn(run func(key sync.Key, priority int32, creationTime time.Time)) *Throttler_Add_Call
type Throttler_Admit_Call ¶
Throttler_Admit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Admit'
func (*Throttler_Admit_Call) Return ¶
func (_c *Throttler_Admit_Call) Return(b bool) *Throttler_Admit_Call
func (*Throttler_Admit_Call) Run ¶
func (_c *Throttler_Admit_Call) Run(run func(key sync.Key)) *Throttler_Admit_Call
func (*Throttler_Admit_Call) RunAndReturn ¶
func (_c *Throttler_Admit_Call) RunAndReturn(run func(key sync.Key) bool) *Throttler_Admit_Call
type Throttler_Expecter ¶
type Throttler_Expecter struct {
// contains filtered or unexported fields
}
func (*Throttler_Expecter) Add ¶
func (_e *Throttler_Expecter) Add(key interface{}, priority interface{}, creationTime interface{}) *Throttler_Add_Call
Add is a helper method to define mock.On call
- key sync.Key
- priority int32
- creationTime time.Time
func (*Throttler_Expecter) Admit ¶
func (_e *Throttler_Expecter) Admit(key interface{}) *Throttler_Admit_Call
Admit is a helper method to define mock.On call
- key sync.Key
func (*Throttler_Expecter) Init ¶
func (_e *Throttler_Expecter) Init(wfs interface{}) *Throttler_Init_Call
Init is a helper method to define mock.On call
- wfs []v1alpha1.Workflow
func (*Throttler_Expecter) Remove ¶
func (_e *Throttler_Expecter) Remove(key interface{}) *Throttler_Remove_Call
Remove is a helper method to define mock.On call
- key sync.Key
func (*Throttler_Expecter) ResetNamespaceParallelism ¶
func (_e *Throttler_Expecter) ResetNamespaceParallelism(namespace interface{}) *Throttler_ResetNamespaceParallelism_Call
ResetNamespaceParallelism is a helper method to define mock.On call
- namespace string
func (*Throttler_Expecter) UpdateNamespaceParallelism ¶
func (_e *Throttler_Expecter) UpdateNamespaceParallelism(namespace interface{}, limit interface{}) *Throttler_UpdateNamespaceParallelism_Call
UpdateNamespaceParallelism is a helper method to define mock.On call
- namespace string
- limit int
func (*Throttler_Expecter) UpdateParallelism ¶
func (_e *Throttler_Expecter) UpdateParallelism(limit interface{}) *Throttler_UpdateParallelism_Call
UpdateParallelism is a helper method to define mock.On call
- limit int
type Throttler_Init_Call ¶
Throttler_Init_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Init'
func (*Throttler_Init_Call) Return ¶
func (_c *Throttler_Init_Call) Return(err error) *Throttler_Init_Call
func (*Throttler_Init_Call) Run ¶
func (_c *Throttler_Init_Call) Run(run func(wfs []v1alpha1.Workflow)) *Throttler_Init_Call
func (*Throttler_Init_Call) RunAndReturn ¶
func (_c *Throttler_Init_Call) RunAndReturn(run func(wfs []v1alpha1.Workflow) error) *Throttler_Init_Call
type Throttler_Remove_Call ¶
Throttler_Remove_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Remove'
func (*Throttler_Remove_Call) Return ¶
func (_c *Throttler_Remove_Call) Return() *Throttler_Remove_Call
func (*Throttler_Remove_Call) Run ¶
func (_c *Throttler_Remove_Call) Run(run func(key sync.Key)) *Throttler_Remove_Call
func (*Throttler_Remove_Call) RunAndReturn ¶
func (_c *Throttler_Remove_Call) RunAndReturn(run func(key sync.Key)) *Throttler_Remove_Call
type Throttler_ResetNamespaceParallelism_Call ¶
Throttler_ResetNamespaceParallelism_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResetNamespaceParallelism'
func (*Throttler_ResetNamespaceParallelism_Call) Return ¶
func (_c *Throttler_ResetNamespaceParallelism_Call) Return() *Throttler_ResetNamespaceParallelism_Call
func (*Throttler_ResetNamespaceParallelism_Call) Run ¶
func (_c *Throttler_ResetNamespaceParallelism_Call) Run(run func(namespace string)) *Throttler_ResetNamespaceParallelism_Call
func (*Throttler_ResetNamespaceParallelism_Call) RunAndReturn ¶
func (_c *Throttler_ResetNamespaceParallelism_Call) RunAndReturn(run func(namespace string)) *Throttler_ResetNamespaceParallelism_Call
type Throttler_UpdateNamespaceParallelism_Call ¶
Throttler_UpdateNamespaceParallelism_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateNamespaceParallelism'
func (*Throttler_UpdateNamespaceParallelism_Call) Return ¶
func (_c *Throttler_UpdateNamespaceParallelism_Call) Return() *Throttler_UpdateNamespaceParallelism_Call
func (*Throttler_UpdateNamespaceParallelism_Call) Run ¶
func (_c *Throttler_UpdateNamespaceParallelism_Call) Run(run func(namespace string, limit int)) *Throttler_UpdateNamespaceParallelism_Call
func (*Throttler_UpdateNamespaceParallelism_Call) RunAndReturn ¶
func (_c *Throttler_UpdateNamespaceParallelism_Call) RunAndReturn(run func(namespace string, limit int)) *Throttler_UpdateNamespaceParallelism_Call
type Throttler_UpdateParallelism_Call ¶
Throttler_UpdateParallelism_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateParallelism'
func (*Throttler_UpdateParallelism_Call) Return ¶
func (_c *Throttler_UpdateParallelism_Call) Return() *Throttler_UpdateParallelism_Call
func (*Throttler_UpdateParallelism_Call) Run ¶
func (_c *Throttler_UpdateParallelism_Call) Run(run func(limit int)) *Throttler_UpdateParallelism_Call
func (*Throttler_UpdateParallelism_Call) RunAndReturn ¶
func (_c *Throttler_UpdateParallelism_Call) RunAndReturn(run func(limit int)) *Throttler_UpdateParallelism_Call