func()

in pkg/stream/s3/s3_streamer.go [35:55]

• 17 lines of code
• 5 McCabe index (conditional complexity)

func (s *streamer) CreateStream(url string) (io.ReadSeeker, int64, string, error) {
	region, bucket, key, err := parseS3Url(url)
	if err != nil {
		return nil, 0, "", err
	}

	// Create a client if one was not provided
	if s.client == nil {
		s.client, err = createClientFromEnv(region)
		if err != nil {
			return nil, 0, "", err
		}
	}

	s3Reader, err := newS3ReaderBucketAndKey(s.client, bucket, key)
	if err != nil {
		return nil, 0, "", err
	}

	return s3Reader, s3Reader.ContentLength, s3Reader.Etag, nil
}