Documentation ¶
Index ¶
- func Test_Assert(t *testing.T, condition bool, msg string, v ...interface{})
- func Test_Equals(t *testing.T, exp, act interface{})
- func Test_Nil(t *testing.T, val interface{})
- func Test_NotNil(t *testing.T, val interface{})
- type Parallel
- type Test_Struct
- type Worker
- type WorkerConfig
- type WorkerHelper
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Test_Assert ¶
assert fails the test if the condition is false.
func Test_Equals ¶
equals fails the test if exp is not equal to act.
func Test_NotNil ¶
Types ¶
type Parallel ¶
type Parallel struct {
// contains filtered or unexported fields
}
func (*Parallel) CloseDataChannel ¶
func (*Parallel) NewDataChannel ¶
type Test_Struct ¶
type Worker ¶
type Worker struct { Name string Config *WorkerConfig // contains filtered or unexported fields }
func (*Worker) SetExecution ¶
func (w *Worker) SetExecution(exec func(wh *WorkerHelper, args interface{}))
func (*Worker) SetParallelism ¶
type WorkerConfig ¶
type WorkerConfig struct {
Parallelism int
}
type WorkerHelper ¶
type WorkerHelper struct {
// contains filtered or unexported fields
}
func (*WorkerHelper) ConsumeData ¶
func (wh *WorkerHelper) ConsumeData(name string) (interface{}, error)
func (*WorkerHelper) ConsumeDataInBatches ¶
func (wh *WorkerHelper) ConsumeDataInBatches(name string, size int) ([]interface{}, error)
func (*WorkerHelper) Done ¶
func (wh *WorkerHelper) Done()
func (*WorkerHelper) PublishData ¶
func (wh *WorkerHelper) PublishData(name string, data interface{}) error
Click to show internal directories.
Click to hide internal directories.