Change all samples to use envconfig to connect to client (#421)

yuandrew · web-flow · commit c0a074b5c828 · 2025-11-07T00:22:05.000-08:00
diff --git a/batch-sliding-window/starter/main.go b/batch-sliding-window/starter/main.go
@@ -6,10 +6,11 @@ import (
 
 	batch_sliding_window "github.com/temporalio/samples-go/batch-sliding-window"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		panic(err)
 	}
diff --git a/branch/starter/main.go b/branch/starter/main.go
@@ -5,14 +5,15 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 
 	"github.com/temporalio/samples-go/branch"
 )
 
 // @@@SNIPSTART samples-go-branch-workflow-execution-starter
 func main() {
 	// The client is a heavyweight object that should be created only once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		panic(err)
 	}
diff --git a/eager-workflow-start/main.go b/eager-workflow-start/main.go
@@ -6,6 +6,7 @@ import (
 
 	"github.com/pborman/uuid"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	"github.com/temporalio/samples-go/helloworld"
@@ -15,7 +16,7 @@ const taskQueueName = "eager_wf_start"
 
 func main() {
 	// 1. Create the shared client.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/early-return/starter/main.go b/early-return/starter/main.go
@@ -9,10 +9,11 @@ import (
 	"github.com/temporalio/samples-go/early-return"
 	enumspb "go.temporal.io/api/enums/v1"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/early-return/worker/main.go b/early-return/worker/main.go
@@ -5,12 +5,13 @@ import (
 
 	"github.com/temporalio/samples-go/early-return"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/logger-interceptor/starter/main.go b/logger-interceptor/starter/main.go
@@ -6,11 +6,12 @@ import (
 
 	"github.com/temporalio/samples-go/logger-interceptor"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/logger-interceptor/worker/main.go b/logger-interceptor/worker/main.go
@@ -8,14 +8,15 @@ import (
 	"github.com/temporalio/samples-go/logger-interceptor"
 	"go.temporal.io/sdk/activity"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	sdkinterceptor "go.temporal.io/sdk/interceptor"
 	"go.temporal.io/sdk/worker"
 	"go.temporal.io/sdk/workflow"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/metrics/starter/main.go b/metrics/starter/main.go
@@ -5,13 +5,14 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 
 	"github.com/temporalio/samples-go/metrics"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client.", err)
 	}
diff --git a/multi-history-replay/replayer/main.go b/multi-history-replay/replayer/main.go
@@ -8,6 +8,7 @@ import (
 	workflowpb "go.temporal.io/api/workflow/v1"
 	"go.temporal.io/api/workflowservice/v1"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 	"go.temporal.io/sdk/workflow"
 )
@@ -34,7 +35,7 @@ func GetWorkflows(ctx context.Context, c client.Client, query string) ([]*workfl
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/multi-history-replay/starter/main.go b/multi-history-replay/starter/main.go
@@ -6,11 +6,12 @@ import (
 
 	"github.com/temporalio/samples-go/helloworld"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/multi-history-replay/worker/main.go b/multi-history-replay/worker/main.go
@@ -4,14 +4,15 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	"github.com/temporalio/samples-go/helloworld"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/polling/frequent/starter/main.go b/polling/frequent/starter/main.go
@@ -8,11 +8,12 @@ import (
 
 	"github.com/pborman/uuid"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/safe_message_handler/starter/main.go b/safe_message_handler/starter/main.go
@@ -7,14 +7,15 @@ import (
 	"time"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 
 	"github.com/google/uuid"
 	"github.com/temporalio/samples-go/safe_message_handler"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/safe_message_handler/worker/main.go b/safe_message_handler/worker/main.go
@@ -4,14 +4,15 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	"github.com/temporalio/samples-go/safe_message_handler"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/saga/start/main.go b/saga/start/main.go
@@ -6,13 +6,14 @@ import (
 
 	"github.com/google/uuid"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 
 	"github.com/temporalio/samples-go/saga"
 )
 
 func main() {
 	// Create the client object just once per process
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("unable to create Temporal client", err)
 	}
diff --git a/saga/worker/main.go b/saga/worker/main.go
@@ -4,14 +4,15 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	"github.com/temporalio/samples-go/saga"
 )
 
 func main() {
 	// Create the client object just once per process
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("unable to create Temporal client", err)
 	}
diff --git a/sleep-for-days/starter/main.go b/sleep-for-days/starter/main.go
@@ -6,10 +6,11 @@ import (
 
 	sleepfordays "github.com/temporalio/samples-go/sleep-for-days"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/sleep-for-days/worker/main.go b/sleep-for-days/worker/main.go
@@ -4,14 +4,15 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	sleepfordays "github.com/temporalio/samples-go/sleep-for-days"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/slogadapter/starter/main.go b/slogadapter/starter/main.go
@@ -6,11 +6,12 @@ import (
 
 	"github.com/temporalio/samples-go/slogadapter"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/synchronous-proxy/ui/main.go b/synchronous-proxy/ui/main.go
@@ -10,10 +10,11 @@ import (
 
 	synchronousproxy "github.com/temporalio/samples-go/synchronous-proxy"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/synchronous-proxy/worker/main.go b/synchronous-proxy/worker/main.go
@@ -4,14 +4,15 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	synchronousproxy "github.com/temporalio/samples-go/synchronous-proxy"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/update/starter/main.go b/update/starter/main.go
@@ -6,10 +6,11 @@ import (
 
 	"github.com/temporalio/samples-go/update"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 )
 
 func main() {
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/update/worker/main.go b/update/worker/main.go
@@ -5,12 +5,13 @@ import (
 
 	"github.com/temporalio/samples-go/update"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 )
 
 func main() {
 	// The client and worker are heavyweight objects that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/worker-specific-task-queues/starter/main.go b/worker-specific-task-queues/starter/main.go
@@ -5,13 +5,14 @@ import (
 	"log"
 
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 
 	worker_specific_task_queues "github.com/temporalio/samples-go/worker-specific-task-queues"
 )
 
 func main() {
 	// The client is a heavyweight object that should be created once per process.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/worker-specific-task-queues/worker/main.go b/worker-specific-task-queues/worker/main.go
@@ -8,6 +8,7 @@ import (
 
 	"go.temporal.io/sdk/activity"
 	"go.temporal.io/sdk/client"
+	"go.temporal.io/sdk/contrib/envconfig"
 	"go.temporal.io/sdk/worker"
 
 	"github.com/google/uuid"
@@ -16,7 +17,7 @@ import (
 func main() {
 	// The client and worker are heavyweight objects that should generally be created once per process.
 	// In this case, we create a single client but two workers since we need to handle Activities on multiple task queues.
-	c, err := client.Dial(client.Options{})
+	c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())
 	if err != nil {
 		log.Fatalln("Unable to create client", err)
 	}
diff --git a/workflow-security-interceptor/starter/main.go b/workflow-security-interceptor/starter/main.go
diff --git a/workflow-security-interceptor/worker/main.go b/workflow-security-interceptor/worker/main.go
diff --git a/zapadapter/starter/main.go b/zapadapter/starter/main.go

Original file line number	Diff line number	Diff line change
`@@ -6,10 +6,11 @@ import (`
`6`	`6`
`7`	`7`	`batch_sliding_window "github.com/temporalio/samples-go/batch-sliding-window"`
`8`	`8`	`"go.temporal.io/sdk/client"`
	`9`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`9`	`10`	`)`
`10`	`11`
`11`	`12`	`func main() {`
`12`		`- c, err := client.Dial(client.Options{})`
	`13`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`13`	`14`	`if err != nil {`
`14`	`15`	`panic(err)`
`15`	`16`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,14 +5,15 @@ import (`
`5`	`5`	`"log"`
`6`	`6`
`7`	`7`	`"go.temporal.io/sdk/client"`
	`8`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`8`	`9`
`9`	`10`	`"github.com/temporalio/samples-go/branch"`
`10`	`11`	`)`
`11`	`12`
`12`	`13`	`// @@@SNIPSTART samples-go-branch-workflow-execution-starter`
`13`	`14`	`func main() {`
`14`	`15`	`// The client is a heavyweight object that should be created only once per process.`
`15`		`- c, err := client.Dial(client.Options{})`
	`16`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`16`	`17`	`if err != nil {`
`17`	`18`	`panic(err)`
`18`	`19`	`}`
Original file line number	Diff line number	Diff line change
`@@ -9,10 +9,11 @@ import (`
`9`	`9`	`"github.com/temporalio/samples-go/early-return"`
`10`	`10`	`enumspb "go.temporal.io/api/enums/v1"`
`11`	`11`	`"go.temporal.io/sdk/client"`
	`12`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`12`	`13`	`)`
`13`	`14`
`14`	`15`	`func main() {`
`15`		`- c, err := client.Dial(client.Options{})`
	`16`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`16`	`17`	`if err != nil {`
`17`	`18`	`log.Fatalln("Unable to create client", err)`
`18`	`19`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,12 +5,13 @@ import (`
`5`	`5`
`6`	`6`	`"github.com/temporalio/samples-go/early-return"`
`7`	`7`	`"go.temporal.io/sdk/client"`
	`8`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`8`	`9`	`"go.temporal.io/sdk/worker"`
`9`	`10`	`)`
`10`	`11`
`11`	`12`	`func main() {`
`12`	`13`	`// The client and worker are heavyweight objects that should be created once per process.`
`13`		`- c, err := client.Dial(client.Options{})`
	`14`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`14`	`15`	`if err != nil {`
`15`	`16`	`log.Fatalln("Unable to create client", err)`
`16`	`17`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,11 +6,12 @@ import (`
`6`	`6`
`7`	`7`	`"github.com/temporalio/samples-go/logger-interceptor"`
`8`	`8`	`"go.temporal.io/sdk/client"`
	`9`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`9`	`10`	`)`
`10`	`11`
`11`	`12`	`func main() {`
`12`	`13`	`// The client is a heavyweight object that should be created once per process.`
`13`		`- c, err := client.Dial(client.Options{})`
	`14`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`14`	`15`	`if err != nil {`
`15`	`16`	`log.Fatalln("Unable to create client", err)`
`16`	`17`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,13 +5,14 @@ import (`
`5`	`5`	`"log"`
`6`	`6`
`7`	`7`	`"go.temporal.io/sdk/client"`
	`8`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`8`	`9`
`9`	`10`	`"github.com/temporalio/samples-go/metrics"`
`10`	`11`	`)`
`11`	`12`
`12`	`13`	`func main() {`
`13`	`14`	`// The client is a heavyweight object that should be created once per process.`
`14`		`- c, err := client.Dial(client.Options{})`
	`15`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`15`	`16`	`if err != nil {`
`16`	`17`	`log.Fatalln("Unable to create client.", err)`
`17`	`18`	`}`
Original file line number	Diff line number	Diff line change
`@@ -6,11 +6,12 @@ import (`
`6`	`6`
`7`	`7`	`"github.com/temporalio/samples-go/helloworld"`
`8`	`8`	`"go.temporal.io/sdk/client"`
	`9`	`+ "go.temporal.io/sdk/contrib/envconfig"`
`9`	`10`	`)`
`10`	`11`
`11`	`12`	`func main() {`
`12`	`13`	`// The client is a heavyweight object that should be created once per process.`
`13`		`- c, err := client.Dial(client.Options{})`
	`14`	`+ c, err := client.Dial(envconfig.MustLoadDefaultClientOptions())`
`14`	`15`	`if err != nil {`
`15`	`16`	`log.Fatalln("Unable to create client", err)`
`16`	`17`	`}`