taskqtest

Documentation

Index

• func TestBatchConsumer(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig, messageSize int)
• func TestCallOnce(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestConsumer(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestDelay(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestErrorDelay(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestFallback(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestInvalidCredentials(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestLen(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestNamedJob(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestRateLimit(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestRetry(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• func TestUnknownTask(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)
• type RateLimitError
  • func (RateLimitError) Delay() time.Duration
  • func (e RateLimitError) Error() string

Functions

func TestBatchConsumer

func TestBatchConsumer(
	t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig, messageSize int,
)

func TestCallOnce

func TestCallOnce(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestConsumer

func TestConsumer(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestDelay

func TestDelay(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestErrorDelay

func TestErrorDelay(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestFallback

func TestFallback(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestInvalidCredentials

func TestInvalidCredentials(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestLen

func TestLen(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestNamedJob

func TestNamedJob(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestRateLimit

func TestRateLimit(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestRetry

func TestRetry(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

func TestUnknownTask

func TestUnknownTask(t *testing.T, factory taskq.Factory, opt *taskq.QueueConfig)

Types

type RateLimitError

type RateLimitError string

func (RateLimitError) Delay

func (RateLimitError) Delay() time.Duration

func (RateLimitError) Error

func (e RateLimitError) Error() string