753
func (s *VisibilityStore) generateVisibilityRow(
754
request *store.InternalVisibilityRequestBase,
756
>
searchAttributes, err := s.prepareSearchAttributesForDb(request)
757
>
if err != nil {
758
return nil, err
759
}
760
762
>
NamespaceID: request.NamespaceID,
763
>
WorkflowID: request.WorkflowID,
764
>
RunID: request.RunID,
765
>
StartTime: request.StartTime,
766
>
ExecutionTime: request.ExecutionTime,
767
>
WorkflowTypeName: request.WorkflowTypeName,
768
>
Status: int32(request.Status),
769
>
Memo: request.Memo.Data,
770
>
Encoding: request.Memo.EncodingType.String(),
771
>
TaskQueue: request.TaskQueue,
772
>
SearchAttributes: searchAttributes,
773
>
ParentWorkflowID: request.ParentWorkflowID,
774
>
ParentRunID: request.ParentRunID,
775
>
RootWorkflowID: request.RootWorkflowID,
776
>
RootRunID: request.RootRunID,
777
>
Version: request.TaskID,
778
>
}, nil
779
}
780
781
func (s *VisibilityStore) prepareSearchAttributesForDb(
782
request *store.InternalVisibilityRequestBase,
784
>
if request.SearchAttributes == nil {
785
>
return nil, nil
786
>
}
787
788
saTypeMap, err := s.searchAttributesProvider.GetSearchAttributes(s.GetIndexName(), false)