jobs

func DeleteProxy(name string, t *testing.T)

func DestroyPipelines(address string, pipes ...string) func(t *testing.T)

func DisableProxy(name string, t *testing.T)

func EnableProxy(name string, t *testing.T)

func PausePipelines(address string, pipes ...string) func(t *testing.T)

func PushToDisabledPipe(address, pipeline string) func(t *testing.T)

func PushToPipe(pipeline string, autoAck bool, address string) func(t *testing.T)

func PushToPipeBatch(address string, pipeline string, count int, autoAck bool) func(t *testing.T)

func PushToPipeDelayed(address string, pipeline string, delay int64) func(t *testing.T)

func PushToPipeErr(pipeline string) func(t *testing.T)

func ResumePipes(address string, pipes ...string) func(t *testing.T)

func Stats(address string, state *jobState.State) func(t *testing.T)