| Index: impl/memory/taskqueue.go
|
| diff --git a/impl/memory/taskqueue.go b/impl/memory/taskqueue.go
|
| index 2af0f5a7117f4345322c298b1d7ddad19003c98d..9ac3e5287d6b80ba66b140edee33f39d75a376ca 100644
|
| --- a/impl/memory/taskqueue.go
|
| +++ b/impl/memory/taskqueue.go
|
| @@ -145,6 +145,10 @@ func (t *taskqueueImpl) Stats(queueNames []string, cb tq.RawStatsCB) error {
|
| return nil
|
| }
|
|
|
| +func (t *taskqueueImpl) Testable() tq.Testable {
|
| + return t
|
| +}
|
| +
|
| /////////////////////////////// taskqueueTxnImpl ///////////////////////////////
|
|
|
| type taskqueueTxnImpl struct {
|
| @@ -222,6 +226,10 @@ func (t *taskqueueTxnImpl) Stats([]string, tq.RawStatsCB) error {
|
| return errors.New("taskqueue: cannot Stats from a transaction")
|
| }
|
|
|
| +func (t *taskqueueTxnImpl) Testable() tq.Testable {
|
| + return t
|
| +}
|
| +
|
| ////////////////////////////// private functions ///////////////////////////////
|
|
|
| var validTaskName = regexp.MustCompile("^[0-9a-zA-Z\\-\\_]{0,500}$")
|
|
|