mirror of
https://github.com/mentos1386/zdravko.git
synced 2024-11-26 09:17:55 +00:00
33 lines
843 B
Go
33 lines
843 B
Go
|
package main
|
||
|
|
||
|
import (
|
||
|
"log"
|
||
|
|
||
|
"go.temporal.io/sdk/client"
|
||
|
"go.temporal.io/sdk/worker"
|
||
|
)
|
||
|
|
||
|
func main() {
|
||
|
// Initialize a Temporal Client
|
||
|
// Specify the Namespace in the Client options
|
||
|
clientOptions := client.Options{
|
||
|
Namespace: "default",
|
||
|
}
|
||
|
temporalClient, err := client.Dial(clientOptions)
|
||
|
if err != nil {
|
||
|
log.Fatalln("Unable to create a Temporal Client", err)
|
||
|
}
|
||
|
defer temporalClient.Close()
|
||
|
// Create a new Worker
|
||
|
yourWorker := worker.New(temporalClient, "default-boilerplate-task-queue-local", worker.Options{})
|
||
|
// Register Workflows
|
||
|
//yourWorker.RegisterWorkflow(workflows.default)
|
||
|
// Register Activities
|
||
|
//yourWorker.RegisterActivity(activities.SSNTraceActivity)
|
||
|
// Start the the Worker Process
|
||
|
err = yourWorker.Run(worker.InterruptCh())
|
||
|
if err != nil {
|
||
|
log.Fatalln("Unable to start the Worker Process", err)
|
||
|
}
|
||
|
}
|