44
taskStore p.TaskStore,
45
logger log.Logger,
47
>
return &TaskQueueSuite{
48
>
Assertions: require.New(t),
49
>
ProtoAssertions: protorequire.New(t),
50
>
taskManager: p.NewTaskManager(
51
>
taskStore,
52
>
serialization.NewSerializer(),
53
>
),
54
>
logger: logger,
55
>
}
56
>
}
57
59
>
}
60
62
>
}
63
65
>
s.Assertions = require.New(s.T())
66
>
s.ctx, s.cancel = context.WithTimeout(context.Background(), 30*time.Second*debug.TimeoutMultiplier)
67
>
68
>
s.stickyTTL = time.Second * 10
69
>
s.namespaceID = uuid.New().String()
70
>
s.taskQueueName = uuid.New().String()
71
>
s.taskQueueType = enumspb.TaskQueueType(rand.Int31n(
72
>
int32(len(enumspb.TaskQueueType_value)) + 1),
73
>
)
74
>
}
75
77
>
s.cancel()
78
>
}
79
80
func (s *TaskQueueSuite) TestCreate_Normal() {