55
store p.ExecutionStore,
56
logger log.Logger,
58
>
serializer := serialization.NewSerializer()
59
>
return &HistoryEventsSuite{
60
>
Assertions: require.New(t),
61
>
ProtoAssertions: protorequire.New(t),
62
>
store: p.NewExecutionManager(
63
>
store,
64
>
serializer,
65
>
nil,
66
>
logger,
67
>
dynamicconfig.GetIntPropertyFn(4*1024*1024),
68
>
dynamicconfig.GetBoolPropertyFn(false),
69
>
),
70
>
serializer: serializer,
71
>
logger: logger,
72
>
}
73
>
}
74
76
>
77
>
}
78
80
>
81
>
}
82
84
>
s.Assertions = require.New(s.T())
85
>
s.ProtoAssertions = protorequire.New(s.T())
86
>
s.Ctx, s.Cancel = context.WithTimeout(context.Background(), 30*time.Second*debug.TimeoutMultiplier)
87
>
88
>
s.ShardID++
89
>
}
90
92
>
s.Cancel()
93
>
}
94
95
func (s *HistoryEventsSuite) TestAppendSelect_First() {