How to use UploadFile method of gcs Package

Best Syzkaller code snippet using gcs.UploadFile

bucket_test.go

Source:bucket_test.go

...156		})157		Context("when the bucket contains multiple files and some match the prefix", func() {158			BeforeEach(func() {159				bucketName = CreateBucketWithTimestampedName("list_blobs")160				UploadFileWithDir(bucketName, "my/prefix", "file1", "file-content")161				UploadFileWithDir(bucketName, "not/my/prefix", "file2", "file-content")162				UploadFile(bucketName, "file3", "file-content")163			})164			It("lists all files that have the prefix", func() {165				blobs, err := bucket.ListBlobs("my/prefix")166				Expect(err).NotTo(HaveOccurred())167				Expect(blobs).To(ConsistOf(168					gcs.NewBlob("my/prefix/file1"),169				))170			})171			AfterEach(func() {172				DeleteBucket(bucketName)173			})174		})175		Context("when providing a non-existing bucket", func() {176			It("returns an error", func() {177				config := map[string]gcs.Config{178					"droplets": {179						BucketName:       "I-am-not-a-bucket",180						BackupBucketName: "definitely-not-a-bucket",181					},182				}183				backupsToComplete, err := gcs.BuildBackupsToComplete(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), config)184				Expect(err).NotTo(HaveOccurred())185				_, err = backupsToComplete["droplets"].BucketPair.LiveBucket.ListBlobs("")186				Expect(err).To(MatchError("storage: bucket doesn't exist"))187			})188		})189	})190	Describe("CopyBlobToBucket", func() {191		var srcBucketName string192		var dstBucketName string193		var srcBucket gcs.Bucket194		var dstBucket gcs.Bucket195		var err error196		Context("copying an existing file", func() {197			BeforeEach(func() {198				srcBucketName = CreateBucketWithTimestampedName("src")199				dstBucketName = CreateBucketWithTimestampedName("dst")200				UploadFile(srcBucketName, "file1", "file-content")201				srcBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), srcBucketName)202				Expect(err).NotTo(HaveOccurred())203				dstBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), dstBucketName)204				Expect(err).NotTo(HaveOccurred())205			})206			AfterEach(func() {207				DeleteBucket(srcBucketName)208				DeleteBucket(dstBucketName)209			})210			It("copies the blob to the specified location", func() {211				blob := gcs.NewBlob("file1")212				err := srcBucket.CopyBlobToBucket(dstBucket, blob.Name(), "copydir/file1")213				Expect(err).NotTo(HaveOccurred())214				blobs, err := dstBucket.ListBlobs("")215				Expect(err).NotTo(HaveOccurred())216				Expect(blobs).To(ConsistOf(217					gcs.NewBlob("copydir/file1"),218				))219			})220		})221		Context("copying a file that doesn't exist", func() {222			BeforeEach(func() {223				srcBucketName = CreateBucketWithTimestampedName("src")224				dstBucketName = CreateBucketWithTimestampedName("dst")225				srcBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), srcBucketName)226				Expect(err).NotTo(HaveOccurred())227				dstBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), dstBucketName)228				Expect(err).NotTo(HaveOccurred())229			})230			AfterEach(func() {231				DeleteBucket(srcBucketName)232				DeleteBucket(dstBucketName)233			})234			It("errors with a useful message", func() {235				err := srcBucket.CopyBlobToBucket(dstBucket, "foobar", "copydir/file1")236				Expect(err).To(HaveOccurred())237				Expect(err).To(MatchError(And(ContainSubstring("failed to copy object:"), ContainSubstring("foobar"))))238			})239		})240		Context("copying to a bucket that doesn't exist", func() {241			BeforeEach(func() {242				srcBucketName = CreateBucketWithTimestampedName("src")243				UploadFile(srcBucketName, "file1", "file-content")244				srcBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), srcBucketName)245				Expect(err).NotTo(HaveOccurred())246			})247			AfterEach(func() {248				DeleteBucket(srcBucketName)249			})250			It("errors", func() {251				err := srcBucket.CopyBlobToBucket(nil, "file1", "copydir/file1")252				Expect(err).To(HaveOccurred())253				Expect(err).To(MatchError("destination bucket does not exist"))254			})255		})256	})257	Describe("CopyBlobsToBucket", func() {258		var (259			srcBucketName string260			dstBucketName string261			srcBucket     gcs.Bucket262			dstBucket     gcs.Bucket263			badBucket     gcs.Bucket264			err           error265		)266		BeforeEach(func() {267			srcBucketName = CreateBucketWithTimestampedName("src")268			dstBucketName = CreateBucketWithTimestampedName("dst")269			UploadFile(srcBucketName, "notInSourcePath", "file-content")270			UploadFile(dstBucketName, "alreadyInDstBucket", "file-content")271			UploadFileWithDir(srcBucketName, "sourcePath", "file1", "file-content1")272			UploadFileWithDir(srcBucketName, "sourcePath", "file2", "file-content2")273			srcBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), srcBucketName)274			Expect(err).NotTo(HaveOccurred())275			dstBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), dstBucketName)276			Expect(err).NotTo(HaveOccurred())277			badBucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), "badBucket")278			Expect(err).NotTo(HaveOccurred())279		})280		AfterEach(func() {281			DeleteBucket(srcBucketName)282			DeleteBucket(dstBucketName)283		})284		It("copies only the blobs from source/sourcePath to destination/destinationPath", func() {285			err := srcBucket.CopyBlobsToBucket(dstBucket, "sourcePath")286			Expect(err).NotTo(HaveOccurred())287			blobs, err := dstBucket.ListBlobs("")288			Expect(err).NotTo(HaveOccurred())289			Expect(blobs).To(ConsistOf(290				gcs.NewBlob("file1"),291				gcs.NewBlob("file2"),292				gcs.NewBlob("alreadyInDstBucket"),293			))294		})295		It("returns an error if the destination bucket does not exist", func() {296			err := srcBucket.CopyBlobsToBucket(nil, "sourcePath")297			Expect(err).To(MatchError("destination bucket does not exist"))298		})299		It("returns an error when the source bucket does not exist", func() {300			err := badBucket.CopyBlobsToBucket(dstBucket, "path")301			Expect(err).To(HaveOccurred())302		})303		It("returns an error when the destination bucket does not exist", func() {304			err := srcBucket.CopyBlobsToBucket(badBucket, "sourcePath")305			Expect(err).To(HaveOccurred())306		})307	})308	Describe("DeleteBlob", func() {309		var (310			bucketName string311			bucket     gcs.Bucket312			err        error313			dirName    = "mydir"314			fileName1  = "file1"315			fileName2  = "file2"316		)317		AfterEach(func() {318			DeleteBucket(bucketName)319		})320		Context("when deleting a file that doesn't exist", func() {321			BeforeEach(func() {322				bucketName = CreateBucketWithTimestampedName("src")323				UploadFile(bucketName, fileName1, "file-content")324				bucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), bucketName)325				Expect(err).NotTo(HaveOccurred())326			})327			It("errors", func() {328				err := bucket.DeleteBlob(fileName1 + "idontexist")329				Expect(err).To(HaveOccurred())330			})331		})332		Context("when deleting existing files", func() {333			BeforeEach(func() {334				bucketName = CreateBucketWithTimestampedName("src")335				UploadFileWithDir(bucketName, dirName, fileName1, "file-content")336				UploadFileWithDir(bucketName, dirName, fileName2, "file-content")337				bucket, err = gcs.NewSDKBucket(MustHaveEnv("GCP_SERVICE_ACCOUNT_KEY"), bucketName)338				Expect(err).NotTo(HaveOccurred())339			})340			It("deletes all files and the folder", func() {341				err := bucket.DeleteBlob(fmt.Sprintf("%s/%s", dirName, fileName1))342				Expect(err).NotTo(HaveOccurred())343				err = bucket.DeleteBlob(fmt.Sprintf("%s/%s", dirName, fileName2))344				Expect(err).NotTo(HaveOccurred())345				blobs, err := bucket.ListBlobs("")346				Expect(err).NotTo(HaveOccurred())347				Expect(blobs).To(BeNil())348			})349		})350	})...

gcsclient_test.go

Source:gcsclient_test.go

...40			err = gcsClient.DeleteObject(bucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"), 0)41			Expect(err).ToNot(HaveOccurred())42		})43		It("can interact with buckets", func() {44			_, err := gcsClient.UploadFile(bucketName, filepath.Join(directoryPrefix, "file-to-upload-1"), "", tempFile.Name(), "", "")45			Expect(err).ToNot(HaveOccurred())46			_, err = gcsClient.UploadFile(bucketName, filepath.Join(directoryPrefix, "file-to-upload-2"), "", tempFile.Name(), "", "")47			Expect(err).ToNot(HaveOccurred())48			_, err = gcsClient.UploadFile(bucketName, filepath.Join(directoryPrefix, "file-to-upload-2"), "", tempFile.Name(), "", "")49			Expect(err).ToNot(HaveOccurred())50			_, err = gcsClient.UploadFile(bucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"), "application/zip", tempFile.Name(), "", "")51			Expect(err).ToNot(HaveOccurred())52			fakeZipFileObject, err := gcsClient.GetBucketObjectInfo(bucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"))53			Expect(err).ToNot(HaveOccurred())54			Expect(fakeZipFileObject.ContentType).To(Equal("application/zip"))55			files, err := gcsClient.BucketObjects(bucketName, directoryPrefix)56			Expect(err).ToNot(HaveOccurred())57			Expect(files).To(ConsistOf([]string{filepath.Join(directoryPrefix, "file-to-upload-1"), filepath.Join(directoryPrefix, "file-to-upload-2"), filepath.Join(directoryPrefix, "zip-to-upload.zip")}))58			_, err = gcsClient.ObjectGenerations(bucketName, filepath.Join(directoryPrefix, "file-to-upload-1"))59			Expect(err).To(HaveOccurred())60			Expect(err.Error()).To(ContainSubstring("bucket is not versioned"))61			fileOneURL, err := gcsClient.URL(bucketName, filepath.Join(directoryPrefix, "file-to-upload-1"), 0)62			Expect(err).ToNot(HaveOccurred())63			Expect(fileOneURL).To(Equal(fmt.Sprintf("gs://%s/%s", bucketName, filepath.Join(directoryPrefix, "file-to-upload-1"))))64			_, err = gcsClient.ObjectGenerations(bucketName, filepath.Join(directoryPrefix, "file-to-upload-2"))65			Expect(err).To(HaveOccurred())66			Expect(err.Error()).To(ContainSubstring("bucket is not versioned"))67			fileTwoURL, err := gcsClient.URL(bucketName, filepath.Join(directoryPrefix, "file-to-upload-2"), 0)68			Expect(err).ToNot(HaveOccurred())69			Expect(fileTwoURL).To(Equal(fmt.Sprintf("gs://%s/%s", bucketName, filepath.Join(directoryPrefix, "file-to-upload-2"))))70			err = gcsClient.DownloadFile(bucketName, filepath.Join(directoryPrefix, "file-to-upload-1"), 0, filepath.Join(tempDir, "downloaded-file"))71			Expect(err).ToNot(HaveOccurred())72			read, err := ioutil.ReadFile(filepath.Join(tempDir, "downloaded-file"))73			Expect(err).ToNot(HaveOccurred())74			Expect(read).To(Equal([]byte("hello-" + runtime)))75		})76	})77	Describe("with a versioned bucket", func() {78		BeforeEach(func() {79			tempVerDir, err = ioutil.TempDir("", "gcs-versioned-upload-dir")80			Expect(err).ToNot(HaveOccurred())81			tempVerFile, err = ioutil.TempFile(tempVerDir, "file-to-upload")82			Expect(err).ToNot(HaveOccurred())83			tempVerFile.Write([]byte("hello-" + runtime))84		})85		AfterEach(func() {86			err := os.RemoveAll(tempVerDir)87			Expect(err).ToNot(HaveOccurred())88			fileOneGenerations, err := gcsClient.ObjectGenerations(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-1"))89			Expect(err).ToNot(HaveOccurred())90			for _, fileOneGeneration := range fileOneGenerations {91				err := gcsClient.DeleteObject(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-1"), fileOneGeneration)92				Expect(err).ToNot(HaveOccurred())93			}94			fileTwoGenerations, err := gcsClient.ObjectGenerations(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-2"))95			Expect(err).ToNot(HaveOccurred())96			for _, fileTwoGeneration := range fileTwoGenerations {97				err := gcsClient.DeleteObject(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-2"), fileTwoGeneration)98				Expect(err).ToNot(HaveOccurred())99			}100			fakeZipFileGenerations, err := gcsClient.ObjectGenerations(versionedBucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"))101			Expect(err).ToNot(HaveOccurred())102			for _, fakeZipFileGeneration := range fakeZipFileGenerations {103				err := gcsClient.DeleteObject(versionedBucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"), fakeZipFileGeneration)104				Expect(err).ToNot(HaveOccurred())105			}106		})107		It("can interact with buckets", func() {108			fileOneGeneration, err := gcsClient.UploadFile(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-1"), "", tempVerFile.Name(), "", "")109			Expect(err).ToNot(HaveOccurred())110			fileTwoGeneration1, err := gcsClient.UploadFile(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-2"), "", tempVerFile.Name(), "", "")111			Expect(err).ToNot(HaveOccurred())112			fileTwoGeneration2, err := gcsClient.UploadFile(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-2"), "", tempVerFile.Name(), "", "")113			Expect(err).ToNot(HaveOccurred())114			fakeZipFileGeneration, err := gcsClient.UploadFile(versionedBucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"), "application/zip", tempVerFile.Name(), "", "")115			Expect(err).ToNot(HaveOccurred())116			fakeZipFileObject, err := gcsClient.GetBucketObjectInfo(versionedBucketName, filepath.Join(directoryPrefix, "zip-to-upload.zip"))117			Expect(err).ToNot(HaveOccurred())118			Expect(fakeZipFileObject.ContentType).To(Equal("application/zip"))119			Expect(fakeZipFileGeneration).To(Equal(fakeZipFileObject.Generation))120			files, err := gcsClient.BucketObjects(versionedBucketName, directoryPrefix)121			Expect(err).ToNot(HaveOccurred())122			Expect(files).To(ConsistOf([]string{filepath.Join(directoryPrefix, "file-to-upload-1"), filepath.Join(directoryPrefix, "file-to-upload-2"), filepath.Join(directoryPrefix, "zip-to-upload.zip")}))123			fileOneGenerations, err := gcsClient.ObjectGenerations(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-1"))124			Expect(err).ToNot(HaveOccurred())125			Expect(fileOneGenerations).To(ConsistOf([]int64{fileOneGeneration}))126			fileOneGenerationsObject, err := gcsClient.GetBucketObjectInfo(versionedBucketName, filepath.Join(directoryPrefix, "file-to-upload-1"))127			Expect(err).ToNot(HaveOccurred())128			Expect(fileOneGenerations).To(ConsistOf([]int64{fileOneGenerationsObject.Generation}))...

utils.go

Source:utils.go

...33	// Download returns an io.ReadCloser for GCS object at given gcsPath.34	Download(ctx context.Context, gcsPath string) (io.ReadCloser, error)35	// Delete deletes all objects under given gcsPath36	Delete(ctx context.Context, gcsPath string) error37	// UploadFile uploads contents of a file at filepath to gcsPath location in38	// GCS and sets object's contentType.39	// If gcsPath ends with .gz it also compresses the uploaded contents40	// and sets object's content type to application/gzip.41	UploadFile(ctx context.Context, gcsPath, filepath, contentType string) error42	// SplitURI takes a GCS URI and splits it into bucket and object names. If the URI does not have43	// the gs:// scheme, or the URI doesn't specify both a bucket and an object name, returns an error.44	SplitURI(url string) (bucket, name string, err error)45}46type GCSUtilImpl struct{}47func (g *GCSUtilImpl) Download(ctx context.Context, gcsPath string) (io.ReadCloser, error) {48	bucket, name, err := g.SplitURI(gcsPath)49	if err != nil {50		return nil, err51	}52	client, err := storage.NewClient(ctx)53	if err != nil {54		return nil, fmt.Errorf("failed to init GCS client: %v", err)55	}56	defer client.Close()57	reader, err := client.Bucket(bucket).Object(name).NewReader(ctx)58	if err != nil {59		return nil, fmt.Errorf("failed to read URL %s: %v", gcsPath, err)60	}61	return reader, nil62}63func (g *GCSUtilImpl) UploadFile(ctx context.Context, gcsPath, filePath, contentType string) error {64	return retry.OnError(retry.DefaultBackoff, func(err error) bool {65		klog.ErrorS(err, "failed to upload a file")66		// tried to cast err to *googleapi.Error with errors.As and wrap the error67		// in uploadFile. returned err is not a *googleapi.Error.68		return err != nil && strings.Contains(err.Error(), "compute: Received 500 ")69	}, func() error {70		return g.uploadFile(ctx, gcsPath, filePath, contentType)71	})72}73func (g *GCSUtilImpl) uploadFile(ctx context.Context, gcsPath, filePath, contentType string) error {74	bucket, name, err := g.SplitURI(gcsPath)75	if err != nil {76		return err77	}...

UploadFile

Using AI Code Generation

1import (2func main() {3	r := mux.NewRouter()4	r.HandleFunc("/upload", uploadFile).Methods("POST")5	r.HandleFunc("/download", downloadFile).Methods("GET")6	r.HandleFunc("/delete", deleteFile).Methods("DELETE")7	r.HandleFunc("/list", listFiles).Methods("GET")8	r.HandleFunc("/createBucket", createBucket).Methods("POST")9	r.HandleFunc("/deleteBucket", deleteBucket).Methods("DELETE")10	r.HandleFunc("/listBuckets", listBuckets).Methods("GET")11	r.HandleFunc("/bucketExists", bucketExists).Methods("GET")12	r.HandleFunc("/createFolder", createFolder).Methods("POST")13	r.HandleFunc("/deleteFolder", deleteFolder).Methods("DELETE")14	r.HandleFunc("/folderExists", folderExists).Methods("GET")15	r.HandleFunc("/listFolders", listFolders).Methods("GET")16	r.HandleFunc("/createFile", createFile).Methods("POST")17	r.HandleFunc("/deleteFile", deleteFile).Methods("DELETE")18	r.HandleFunc("/fileExists", fileExists).Methods("GET")19	r.HandleFunc("/listFiles", listFiles).Methods("GET")20	r.HandleFunc("/copyFile", copyFile).Methods("POST")21	r.HandleFunc("/moveFile", moveFile).Methods("POST")22	r.HandleFunc("/getFileInfo", getFileInfo).Methods("GET")23	r.HandleFunc("/getBucketInfo", getBucketInfo).Methods("GET")24	r.HandleFunc("/getFolderInfo", getFolderInfo).Methods("GET")25	r.HandleFunc("/getFileInfo", getFileInfo).Methods("GET")26	r.HandleFunc("/getSignedURL", getSignedURL).Methods("GET")27	r.HandleFunc("/getSignedURLWithExpiry", getSignedURLWithExpiry).Methods("GET")28	r.HandleFunc("/getSignedURLWithExpiry", getSignedURLWithExpiry).Methods("GET")29	r.HandleFunc("/getSignedURLWithExpiry", getSignedURLWithExpiry).Methods("GET")30	r.HandleFunc("/getSignedURLWithExpiry", getSignedURLWithExpiry).Methods("GET")31	r.HandleFunc("/getSignedURLWithExpiry", getSignedURLWithExpiry).Methods("GET")32	r.HandleFunc("/getSignedURLWithExpiry", getSignedURLWithExpiry).Methods("GET")33	log.Fatal(http.ListenAndServe

UploadFile

Using AI Code Generation

1import (2func main() {3	ctx := context.Background()4	client, err := storage.NewClient(ctx, option.WithCredentialsFile("key.json"))5	if err != nil {6		log.Fatal(err)7	}8	err = uploadFile(client, bucketName, objectName, filePath)9	if err != nil {10		log.Fatal(err)11	}12	fmt.Printf("File %v uploaded to bucket %v.\n", objectName, bucketName)13}14func uploadFile(client *storage.Client, bucketName, objectName, filePath string) error {15	ctx := context.Background()16	bucket := client.Bucket(bucketName)17	object := bucket.Object(objectName)18	wc := object.NewWriter(ctx)19	defer wc.Close()20	f, err := os.Open(filePath)21	if err != nil {22	}23	defer f.Close()24	if _, err = io.Copy(wc, f); err != nil {25	}26}

UploadFile

Using AI Code Generation

1import (2func main() {3	gcs := NewGCS()4	fileName = filepath.Base(filePath)5	err := gcs.UploadFile(fileName, filePath, bucketName)6	if err != nil {7		log.Fatalf("Error: %v", err)8	}9	fmt.Println("File uploaded successfully")10}11import (12func main() {13	gcs := NewGCS()14	fileName = filepath.Base(filePath)15	err := gcs.UploadFile(fileName, filePath, bucketName)16	if err != nil {17		log.Fatalf("Error: %v", err)18	}19	fmt.Println("File uploaded successfully")20}21import (22func main() {23	gcs := NewGCS()24	fileName = filepath.Base(filePath)

UploadFile

Using AI Code Generation

1import (2func main() {3	gcs.UploadFile("bucket_name", "file_path")4}5import (6func main() {7	gcs.DownloadFile("bucket_name", "file_path")8}9import (10func main() {11	gcs.DeleteFile("bucket_name", "file_path")12}13import (14func main() {15	gcs.ListFiles("bucket_name")16}17import (18func main() {19	gcs.CreateBucket("bucket_name")20}21import (22func main() {23	gcs.DeleteBucket("bucket_name")24}25import (26func main() {27	gcs.ListBuckets()28}29import (30func main() {31	fmt.Println("Starting...")32	start := time.Now()33	gcs.UploadFile("bucket_name", "file_path")34	gcs.DownloadFile("bucket_name", "file_path")35	gcs.DeleteFile("bucket_name", "file_path")36	gcs.ListFiles("bucket_name")37	gcs.CreateBucket("bucket_name")38	gcs.DeleteBucket("bucket_name")39	gcs.ListBuckets()

UploadFile

Using AI Code Generation

1func main() {2  gcs := gcs.NewGCS()3  err := gcs.UploadFile("bucket-name", "file-name", "file-path")4  if err != nil {5    log.Fatal(err)6  }7}8func main() {9  gcs := gcs.NewGCS()10  err := gcs.DownloadFile("bucket-name", "file-name", "file-path")11  if err != nil {12    log.Fatal(err)13  }14}15func main() {16  gcs := gcs.NewGCS()17  err := gcs.DeleteFile("bucket-name", "file-name")18  if err != nil {19    log.Fatal(err)20  }21}22func main() {23  gcs := gcs.NewGCS()24  files, err := gcs.ListFiles("bucket-name")25  if err != nil {26    log.Fatal(err)27  }28  for _, file := range files {29    fmt.Println(file.Name)30  }31}32func main() {33  gcs := gcs.NewGCS()34  err := gcs.UploadDir("bucket-name", "dir-path", "dir-name")35  if err != nil {36    log.Fatal(err)37  }38}39func main() {40  gcs := gcs.NewGCS()41  err := gcs.DownloadDir("bucket-name", "dir-path", "dir-name")42  if err != nil {43    log.Fatal(err)44  }45}

UploadFile

Using AI Code Generation

1import (2func main() {3	gcs := gcs.NewGcs()4	err := gcs.Initialize("bucket-name", "path/to/credentials.json", "project-id")5	if err != nil {6		fmt.Println(err)7		os.Exit(1)8	}9	err = gcs.UploadFile("path/to/file", "path/on/server")10	if err != nil {11		fmt.Println(err)12		os.Exit(1)13	}14}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.