84
}
85
87
>
numBufferedEvents := 20
88
>
89
>
shardID := rand.Int31()
90
>
namespaceID := primitives.NewUUID()
91
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
92
>
runID := primitives.NewUUID()
93
>
94
>
var buffers []sqlplugin.BufferedEventsRow
95
>
for range numBufferedEvents {
96
>
buffer := s.newRandomExecutionBufferRow(shardID, namespaceID, workflowID, runID)
97
>
buffers = append(buffers, buffer)
98
>
}
99
>
result, err := s.store.InsertIntoBufferedEvents(newExecutionContext(), buffers)
100
>
s.NoError(err)
101
>
rowsAffected, err := result.RowsAffected()
102
>
s.NoError(err)
103
>
s.Equal(numBufferedEvents, int(rowsAffected))
104
>
105
>
filter := sqlplugin.BufferedEventsFilter{
106
>
ShardID: shardID,
107
>
NamespaceID: namespaceID,
108
>
WorkflowID: workflowID,
109
>
RunID: runID,
110
>
}
111
>
rows, err := s.store.SelectFromBufferedEvents(newExecutionContext(), filter)
112
>
s.NoError(err)
113
>
s.Equal(buffers, rows)
114
}
115