There was an error while loading. Please reload this page.
2 parents 0d5866d + e2b3d7f commit 319fb5aCopy full SHA for 319fb5a
1 file changed
features/snippets/external_storage/gcs_setup/gcs_driver_create.go
@@ -0,0 +1,29 @@
1
+package gcssetup
2
+
3
+import (
4
+ "context"
5
+ "log"
6
7
+ "cloud.google.com/go/storage"
8
+ "go.temporal.io/sdk/contrib/gcp/gcsdriver"
9
+ "go.temporal.io/sdk/contrib/gcp/gcsdriver/gcssdk"
10
+ "go.temporal.io/sdk/converter"
11
+)
12
13
+func CreateGCSDriver() converter.StorageDriver {
14
+ // @@@SNIPSTART go-gcs-driver-create
15
+ gcsClient, err := storage.NewClient(context.Background())
16
+ if err != nil {
17
+ log.Fatalf("create GCS client: %v", err)
18
+ }
19
20
+ driver, err := gcsdriver.NewDriver(gcsdriver.Options{
21
+ Client: gcssdk.NewClient(gcsClient),
22
+ Bucket: gcsdriver.StaticBucket("my-temporal-payloads"),
23
+ })
24
25
+ log.Fatalf("create GCS driver: %v", err)
26
27
+ // @@@SNIPEND
28
+ return driver
29
+}
0 commit comments