jobs

Documentation

Index

• 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)

Functions

func DeleteProxy

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

func DestroyPipelines

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

func DisableProxy

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

func EnableProxy

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

func PausePipelines

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

func PushToDisabledPipe

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

func PushToPipe

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

func PushToPipeBatch

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

func PushToPipeDelayed

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

func PushToPipeErr

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

func ResumePipes

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

func Stats

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