( ctx context.Context, sourceRef buffetch.SourceRef, functionOptions *functionOptions, )
| 1030 | } |
| 1031 | |
| 1032 | func (c *controller) getWorkspaceForSourceRef( |
| 1033 | ctx context.Context, |
| 1034 | sourceRef buffetch.SourceRef, |
| 1035 | functionOptions *functionOptions, |
| 1036 | ) (_ bufworkspace.Workspace, retErr error) { |
| 1037 | readBucketCloser, bucketTargeting, err := c.buffetchReader.GetSourceReadBucketCloser( |
| 1038 | ctx, |
| 1039 | c.container, |
| 1040 | sourceRef, |
| 1041 | functionOptions.getGetReadBucketCloserOptions()..., |
| 1042 | ) |
| 1043 | if err != nil { |
| 1044 | return nil, err |
| 1045 | } |
| 1046 | defer func() { |
| 1047 | retErr = errors.Join(retErr, readBucketCloser.Close()) |
| 1048 | }() |
| 1049 | options := []bufworkspace.WorkspaceBucketOption{ |
| 1050 | bufworkspace.WithConfigOverride( |
| 1051 | functionOptions.configOverride, |
| 1052 | ), |
| 1053 | } |
| 1054 | if functionOptions.ignoreAndDisallowV1BufWorkYAMLs { |
| 1055 | options = append( |
| 1056 | options, |
| 1057 | bufworkspace.WithIgnoreAndDisallowV1BufWorkYAMLs(), |
| 1058 | ) |
| 1059 | } |
| 1060 | return c.workspaceProvider.GetWorkspaceForBucket( |
| 1061 | ctx, |
| 1062 | readBucketCloser, |
| 1063 | bucketTargeting, |
| 1064 | options..., |
| 1065 | ) |
| 1066 | } |
| 1067 | |
| 1068 | func (c *controller) getWorkspaceDepManagerForDirRef( |
| 1069 | ctx context.Context, |
no test coverage detected