Documentation ¶
Index ¶
- func CleanupRedisContainer(pool *dockertest.Pool, resource *dockertest.Resource) error
- func MustCreateQueue(backend iface.Backend, spec taskqueue.TaskQueueSpec) *taskqueue.TaskQueue
- func MustCreateQueueAndRegisterWorker(backend iface.Backend, queueSpec taskqueue.TaskQueueSpec, ...) (*taskqueue.TaskQueue, *worker.Worker)
- func MustQueueWithState(backend iface.Backend, spec taskqueue.TaskQueueSpec)
- func PrepareRedisContainer(clientConfig config.RedisClientConfig) (*redis.Client, *dockertest.Resource, *dockertest.Pool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CleanupRedisContainer ¶
func CleanupRedisContainer(pool *dockertest.Pool, resource *dockertest.Resource) error
func MustCreateQueue ¶
func MustCreateQueueAndRegisterWorker ¶
func MustCreateQueueAndRegisterWorker(backend iface.Backend, queueSpec taskqueue.TaskQueueSpec, workerSpec worker.WorkerSpec) (*taskqueue.TaskQueue, *worker.Worker)
func MustQueueWithState ¶
func MustQueueWithState(backend iface.Backend, spec taskqueue.TaskQueueSpec)
func PrepareRedisContainer ¶
func PrepareRedisContainer(clientConfig config.RedisClientConfig) (*redis.Client, *dockertest.Resource, *dockertest.Pool, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.