932
}
933
934
>
func (s *visibilitySuite) TestSelect_MinStartTime_MaxStartTime_StatusOpen_Single() {
visibility.go
935
>
pageSize := 1
936
>
937
>
namespaceID := primitives.NewUUID()
938
>
runID := primitives.NewUUID()
939
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
940
>
workflowID := shuffle.String(testVisibilityWorkflowID)
941
>
startTime := s.now()
942
>
executionTime := startTime.Add(time.Second)
943
>
status := int32(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING)
944
>
closeTime := (*time.Time)(nil)
945
>
historyLength := (*int64)(nil)
946
>
947
>
visibility := s.newRandomVisibilityRow(
948
>
namespaceID,
949
>
runID,
950
>
workflowTypeName,
951
>
workflowID,
952
>
startTime,
953
>
executionTime,
954
>
status,
955
>
closeTime,
956
>
historyLength,
957
>
)
958
>
result, err := s.store.InsertIntoVisibility(newVisibilityContext(), &visibility)
959
>
s.NoError(err)
960
>
rowsAffected, err := result.RowsAffected()
961
>
s.NoError(err)
962
>
s.Equal(1, int(rowsAffected))
963
>
964
>
minStartTime := startTime
965
>
maxStartTime := startTime
966
>
selectFilter := sqlplugin.VisibilitySelectFilter{
967
>
NamespaceID: namespaceID.String(),
968
>
WorkflowID: nil,
969
>
RunID: new(""),
970
>
WorkflowTypeName: nil,
971
>
MinTime: new(minStartTime),
972
>
MaxTime: new(maxStartTime),
973
>
Status: int32(enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING),
974
>
PageSize: new(pageSize),
975
>
}
976
>
rows, err := s.store.SelectFromVisibility(newVisibilityContext(), selectFilter)
977
>
s.NoError(err)
978
>
for index := range rows {
979
>
rows[index].NamespaceID = namespaceID.String()
980
>
}
981
>
s.Equal([]sqlplugin.VisibilityRow{visibility}, rows)
982
}
983