388
}
389
390
>
func (s *visibilitySuite) TestReplaceDeleteGet() {
visibility.go
391
>
namespaceID := primitives.NewUUID()
392
>
runID := primitives.NewUUID()
393
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
394
>
workflowID := shuffle.String(testVisibilityWorkflowID)
395
>
startTime := s.now()
396
>
executionTime := startTime.Add(time.Second)
397
>
status := int32(0)
398
>
closeTime := executionTime.Add(time.Second)
399
>
historyLength := rand.Int63()
400
>
401
>
visibility := s.newRandomVisibilityRow(
402
>
namespaceID,
403
>
runID,
404
>
workflowTypeName,
405
>
workflowID,
406
>
startTime,
407
>
executionTime,
408
>
status,
409
>
new(closeTime),
410
>
new(historyLength),
411
>
)
412
>
result, err := s.store.ReplaceIntoVisibility(newVisibilityContext(), &visibility)
413
>
s.NoError(err)
414
>
rowsAffected, err := result.RowsAffected()
415
>
s.NoError(err)
416
>
s.Equal(1, int(rowsAffected))
417
>
418
>
deleteFilter := sqlplugin.VisibilityDeleteFilter{
419
>
NamespaceID: namespaceID.String(),
420
>
RunID: runID.String(),
421
>
}
422
>
result, err = s.store.DeleteFromVisibility(newVisibilityContext(), deleteFilter)
423
>
s.NoError(err)
424
>
rowsAffected, err = result.RowsAffected()
425
>
s.NoError(err)
426
>
s.Equal(1, int(rowsAffected))
427
>
428
>
getFilter := sqlplugin.VisibilityGetFilter{
429
>
NamespaceID: namespaceID.String(),
430
>
RunID: runID.String(),
431
>
}
432
>
_, err = s.store.GetFromVisibility(newVisibilityContext(), getFilter)
433
>
s.Error(err) // TODO persistence layer should do proper error translation
434
>
}
435
436
func (s *visibilitySuite) TestSelect_MinStartTime_MaxStartTime_WorkflowID_StatusOpen_Single() {