37
serializer serialization.Serializer,
38
logger log.Logger,
40
>
return &ShardSuite{
41
>
Assertions: require.New(t),
42
>
ProtoAssertions: protorequire.New(t),
43
>
ShardManager: p.NewShardManager(
44
>
shardStore,
45
>
serializer,
46
>
),
47
>
Logger: logger,
48
>
}
49
>
}
50
52
>
}
53
55
>
}
56
58
>
s.Assertions = require.New(s.T())
59
>
s.ProtoAssertions = protorequire.New(s.T())
60
>
s.Ctx, s.Cancel = context.WithTimeout(context.Background(), 30*time.Second*debug.TimeoutMultiplier)
61
>
62
>
s.ShardID++
63
>
}
64
66
>
s.Cancel()
67
>
}
68
69
func (s *ShardSuite) TestGetOrCreateShard_Create() {