Documentation
¶
Overview ¶
Package taskpool is a generated GoMock package.
Package taskpool provides limited pool running task
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IoPool ¶
type IoPool interface {
Submit(IoPoolTaskArgs)
Close()
}
func NewReadPool ¶
func NewReadPool(threadCnt, queueDepth int, conf IoPoolMetricConf) IoPool
func NewWritePool ¶
func NewWritePool(threadCnt, queueDepth int, conf IoPoolMetricConf) IoPool
type IoPoolMetricConf ¶
type IoPoolTaskArgs ¶
type MockIoPool ¶
type MockIoPool struct {
// contains filtered or unexported fields
}
MockIoPool is a mock of IoPool interface.
func NewMockIoPool ¶
func NewMockIoPool(ctrl *gomock.Controller) *MockIoPool
NewMockIoPool creates a new mock instance.
func (*MockIoPool) EXPECT ¶
func (m *MockIoPool) EXPECT() *MockIoPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIoPool) Submit ¶
func (m *MockIoPool) Submit(arg0 IoPoolTaskArgs)
Submit mocks base method.
type MockIoPoolMockRecorder ¶
type MockIoPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockIoPoolMockRecorder is the mock recorder for MockIoPool.
func (*MockIoPoolMockRecorder) Close ¶
func (mr *MockIoPoolMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockIoPoolMockRecorder) Submit ¶
func (mr *MockIoPoolMockRecorder) Submit(arg0 interface{}) *gomock.Call
Submit indicates an expected call of Submit.
type TaskPool ¶
type TaskPool struct {
// contains filtered or unexported fields
}
TaskPool limited pool
func (TaskPool) Close ¶
func (tp TaskPool) Close()
Close the pool, the function is concurrent unsafe
Click to show internal directories.
Click to hide internal directories.