Add invoking workflow directly using cadence client samples (#79)

Author: chopincode

new_samples/client_samples/helloworld/hello_world_sample.go

@@ -0,0 +1,50 @@
+package main
+
+import (
+	"context"
+	"github.com/google/uuid"
+	"github.com/uber-common/cadence-samples/new_samples/worker"
+	"go.uber.org/cadence/.gen/go/shared"
+	"go.uber.org/zap"
+	"time"
+)
+
+func main() {
+	cadenceClient := worker.BuildCadenceClient()
+	logger := worker.BuildLogger()
+
+	domain := "cadence-samples"
+	tasklist := "cadence-samples-worker"
+	workflowID := uuid.New().String()
+	requestID := uuid.New().String()
+	executionTimeout := int32(60)
+	closeTimeout := int32(60)
+
+	workflowType := "cadence_samples.HelloWorldWorkflow"
+	input := []byte(`{"message": "Uber"}`)
+
+	req := shared.StartWorkflowExecutionRequest{
+		Domain:     &domain,
+		WorkflowId: &workflowID,
+		WorkflowType: &shared.WorkflowType{
+			Name: &workflowType,
+		},
+		TaskList: &shared.TaskList{
+			Name: &tasklist,
+		},
+		Input:                               input,
+		ExecutionStartToCloseTimeoutSeconds: &executionTimeout,
+		TaskStartToCloseTimeoutSeconds:      &closeTimeout,
+		RequestId:                           &requestID,
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
+	defer cancel()
+	resp, err := cadenceClient.StartWorkflowExecution(ctx, &req)
+	if err != nil {
+		logger.Error("Failed to create workflow", zap.Error(err))
+		panic("Failed to create workflow.")
+	}
+
+	logger.Info("successfully started HelloWorld workflow", zap.String("runID", resp.GetRunId()))
+}

new_samples/worker/worker.go

@@ -28,7 +28,7 @@ const (
 
 // StartWorker creates and starts a basic Cadence worker.
 func StartWorker() {
-	logger, cadenceClient := buildLogger(), buildCadenceClient()
+	logger, cadenceClient := BuildLogger(), BuildCadenceClient()
 	workerOptions := worker.Options{
 		Logger:       logger,
 		MetricsScope: tally.NewTestScope(TaskListName, nil),
@@ -59,7 +59,7 @@ func StartWorker() {
 
 }
 
-func buildCadenceClient() workflowserviceclient.Interface {
+func BuildCadenceClient() workflowserviceclient.Interface {
 	dispatcher := yarpc.NewDispatcher(yarpc.Config{
 		Name: ClientName,
 		Outbounds: yarpc.Outbounds{
@@ -80,7 +80,7 @@ func buildCadenceClient() workflowserviceclient.Interface {
 	)
 }
 
-func buildLogger() *zap.Logger {
+func BuildLogger() *zap.Logger {
 	config := zap.NewDevelopmentConfig()
 	config.Level.SetLevel(zapcore.InfoLevel)