683
}
684
685
>
func (s *visibilitySuite) TestSelect_MinStartTime_MaxStartTime_WorkflowTypeName_StatusOpen_Single() {
visibility.go
686
>
pageSize := 1
687
>
688
>
namespaceID := primitives.NewUUID()
689
>
runID := primitives.NewUUID()
690
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
691
>
workflowID := shuffle.String(testVisibilityWorkflowID)
692
>
startTime := s.now()
693
>
executionTime := startTime.Add(time.Second)
694
>
status := int32(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING)
695
>
closeTime := (*time.Time)(nil)
696
>
historyLength := (*int64)(nil)
697
>
698
>
visibility := s.newRandomVisibilityRow(
699
>
namespaceID,
700
>
runID,
701
>
workflowTypeName,
702
>
workflowID,
703
>
startTime,
704
>
executionTime,
705
>
status,
706
>
closeTime,
707
>
historyLength,
708
>
)
709
>
result, err := s.store.InsertIntoVisibility(newVisibilityContext(), &visibility)
710
>
s.NoError(err)
711
>
rowsAffected, err := result.RowsAffected()
712
>
s.NoError(err)
713
>
s.Equal(1, int(rowsAffected))
714
>
715
>
minStartTime := startTime
716
>
maxStartTime := startTime
717
>
selectFilter := sqlplugin.VisibilitySelectFilter{
718
>
NamespaceID: namespaceID.String(),
719
>
WorkflowID: nil,
720
>
RunID: new(""),
721
>
WorkflowTypeName: new(workflowTypeName),
722
>
MinTime: new(minStartTime),
723
>
MaxTime: new(maxStartTime),
724
>
Status: int32(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING),
725
>
PageSize: new(pageSize),
726
>
}
727
>
rows, err := s.store.SelectFromVisibility(newVisibilityContext(), selectFilter)
728
>
s.NoError(err)
729
>
for index := range rows {
730
>
rows[index].NamespaceID = namespaceID.String()
731
>
}
732
>
s.Equal([]sqlplugin.VisibilityRow{visibility}, rows)
733
}
734