114
}
115
117
>
shardID := rand.Int31()
118
>
namespaceID := primitives.NewUUID()
119
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
120
>
runID := primitives.NewUUID()
121
>
122
>
filter := sqlplugin.BufferedEventsFilter{
123
>
ShardID: shardID,
124
>
NamespaceID: namespaceID,
125
>
WorkflowID: workflowID,
126
>
RunID: runID,
127
>
}
128
>
result, err := s.store.DeleteFromBufferedEvents(newExecutionContext(), filter)
129
>
s.NoError(err)
130
>
rowsAffected, err := result.RowsAffected()
131
>
s.NoError(err)
132
>
s.Equal(0, int(rowsAffected))
133
>
134
>
rows, err := s.store.SelectFromBufferedEvents(newExecutionContext(), filter)
135
>
s.NoError(err)
136
>
s.Equal([]sqlplugin.BufferedEventsRow(nil), rows)
137
>
}
138
139
func (s *historyExecutionBufferSuite) TestInsertDelete() {