434
}
435
436
>
func (s *visibilitySuite) TestSelect_MinStartTime_MaxStartTime_WorkflowID_StatusOpen_Single() {
visibility.go
437
>
pageSize := 1
438
>
439
>
namespaceID := primitives.NewUUID()
440
>
runID := primitives.NewUUID()
441
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
442
>
workflowID := shuffle.String(testVisibilityWorkflowID)
443
>
startTime := s.now()
444
>
executionTime := startTime.Add(time.Second)
445
>
status := int32(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING)
446
>
closeTime := (*time.Time)(nil)
447
>
historyLength := (*int64)(nil)
448
>
449
>
visibility := s.newRandomVisibilityRow(
450
>
namespaceID,
451
>
runID,
452
>
workflowTypeName,
453
>
workflowID,
454
>
startTime,
455
>
executionTime,
456
>
status,
457
>
closeTime,
458
>
historyLength,
459
>
)
460
>
result, err := s.store.InsertIntoVisibility(newVisibilityContext(), &visibility)
461
>
s.NoError(err)
462
>
rowsAffected, err := result.RowsAffected()
463
>
s.NoError(err)
464
>
s.Equal(1, int(rowsAffected))
465
>
466
>
minStartTime := startTime
467
>
maxStartTime := startTime
468
>
selectFilter := sqlplugin.VisibilitySelectFilter{
469
>
NamespaceID: namespaceID.String(),
470
>
WorkflowID: new(workflowID),
471
>
RunID: new(""),
472
>
WorkflowTypeName: nil,
473
>
MinTime: new(minStartTime),
474
>
MaxTime: new(maxStartTime),
475
>
Status: int32(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING),
476
>
PageSize: new(pageSize),
477
>
}
478
>
rows, err := s.store.SelectFromVisibility(newVisibilityContext(), selectFilter)
479
>
s.NoError(err)
480
>
for index := range rows {
481
>
rows[index].NamespaceID = namespaceID.String()
482
>
}
483
>
s.Equal([]sqlplugin.VisibilityRow{visibility}, rows)
484
}
485