342
}
343
344
>
func (s *visibilitySuite) TestInsertDeleteGet() {
visibility.go
345
>
namespaceID := primitives.NewUUID()
346
>
runID := primitives.NewUUID()
347
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
348
>
workflowID := shuffle.String(testVisibilityWorkflowID)
349
>
startTime := s.now()
350
>
executionTime := startTime.Add(time.Second)
351
>
status := int32(0)
352
>
closeTime := (*time.Time)(nil)
353
>
historyLength := (*int64)(nil)
354
>
355
>
visibility := s.newRandomVisibilityRow(
356
>
namespaceID,
357
>
runID,
358
>
workflowTypeName,
359
>
workflowID,
360
>
startTime,
361
>
executionTime,
362
>
status,
363
>
closeTime,
364
>
historyLength,
365
>
)
366
>
result, err := s.store.InsertIntoVisibility(newVisibilityContext(), &visibility)
367
>
s.NoError(err)
368
>
rowsAffected, err := result.RowsAffected()
369
>
s.NoError(err)
370
>
s.Equal(1, int(rowsAffected))
371
>
372
>
deleteFilter := sqlplugin.VisibilityDeleteFilter{
373
>
NamespaceID: namespaceID.String(),
374
>
RunID: runID.String(),
375
>
}
376
>
result, err = s.store.DeleteFromVisibility(newVisibilityContext(), deleteFilter)
377
>
s.NoError(err)
378
>
rowsAffected, err = result.RowsAffected()
379
>
s.NoError(err)
380
>
s.Equal(1, int(rowsAffected))
381
>
382
>
getFilter := sqlplugin.VisibilityGetFilter{
383
>
NamespaceID: namespaceID.String(),
384
>
RunID: runID.String(),
385
>
}
386
>
_, err = s.store.GetFromVisibility(newVisibilityContext(), getFilter)
387
>
s.Error(err) // TODO persistence layer should do proper error translation
388
>
}
389
390
func (s *visibilitySuite) TestReplaceDeleteGet() {