69
}
70
72
>
shardID := rand.Int31()
73
>
namespaceID := primitives.NewUUID()
74
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
75
>
runID := primitives.NewUUID()
76
>
77
>
buffer1 := s.newRandomExecutionBufferRow(shardID, namespaceID, workflowID, runID)
78
>
buffer2 := s.newRandomExecutionBufferRow(shardID, namespaceID, workflowID, runID)
79
>
result, err := s.store.InsertIntoBufferedEvents(newExecutionContext(), []sqlplugin.BufferedEventsRow{buffer1, buffer2})
80
>
s.NoError(err)
81
>
rowsAffected, err := result.RowsAffected()
82
>
s.NoError(err)
83
>
s.Equal(2, int(rowsAffected))
84
>
}
85
86
func (s *historyExecutionBufferSuite) TestInsertSelect() {