71
}
72
74
>
namespaceID := primitives.NewUUID()
75
>
runID := primitives.NewUUID()
76
>
workflowTypeName := shuffle.String(testVisibilityWorkflowTypeName)
77
>
workflowID := shuffle.String(testVisibilityWorkflowID)
78
>
startTime := s.now()
79
>
executionTime := startTime.Add(time.Second)
80
>
status := int32(0)
81
>
closeTime := (*time.Time)(nil)
82
>
historyLength := (*int64)(nil)
83
>
84
>
visibility := s.newRandomVisibilityRow(
85
>
namespaceID,
86
>
runID,
87
>
workflowTypeName,
88
>
workflowID,
89
>
startTime,
90
>
executionTime,
91
>
status,
92
>
closeTime,
93
>
historyLength,
94
>
)
95
>
result, err := s.store.InsertIntoVisibility(newVisibilityContext(), &visibility)
96
>
s.NoError(err)
97
>
rowsAffected, err := result.RowsAffected()
98
>
s.NoError(err)
99
>
s.Equal(1, int(rowsAffected))
100
>
101
>
selectFilter := sqlplugin.VisibilitySelectFilter{
102
>
NamespaceID: namespaceID.String(),
103
>
RunID: new(runID.String()),
104
>
}
105
>
rows, err := s.store.SelectFromVisibility(newVisibilityContext(), selectFilter)
106
>
s.NoError(err)
107
>
for index := range rows {
108
>
rows[index].NamespaceID = namespaceID.String()
109
>
}
110
>
s.Equal([]sqlplugin.VisibilityRow{visibility}, rows)
111
}
112