DelayStart param cadence client changes (#1079)

Author: demirkayaender

idls

@@ -392,6 +392,11 @@ type (
 		// supported when Cadence server is using ElasticSearch). The key and value type must be registered on Cadence server side.
 		// Use GetSearchAttributes API to get valid key and corresponding value type.
 		SearchAttributes map[string]interface{}
+
+		// DelayStartSeconds - Seconds to delay the workflow start
+		// The resolution is seconds.
+		// Optional: defaulted to 0 seconds
+		DelayStart time.Duration
 	}
 
 	// RetryPolicy defines the retry policy.

internal/client.go

@@ -26,10 +26,11 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"go.uber.org/cadence/internal/common/serializer"
 	"reflect"
 	"time"
 
+	"go.uber.org/cadence/internal/common/serializer"
+
 	"github.com/opentracing/opentracing-go"
 	"github.com/pborman/uuid"
 	"github.com/uber-go/tally"
@@ -188,6 +189,11 @@ func (wc *workflowClient) StartWorkflow(
 		return nil, err
 	}
 
+	delayStartSeconds := common.Int32Ceil(options.DelayStart.Seconds())
+	if delayStartSeconds < 0 {
+		return nil, errors.New("Invalid DelayStart option")
+	}
+
 	// create a workflow start span and attach it to the context object.
 	// N.B. we need to finish this immediately as jaeger does not give us a way
 	// to recreate a span given a span context - which means we will run into
@@ -218,6 +224,7 @@ func (wc *workflowClient) StartWorkflow(
 		Memo:                                memo,
 		SearchAttributes:                    searchAttr,
 		Header:                              header,
+		DelayStartSeconds:                   common.Int32Ptr(delayStartSeconds),
 	}
 
 	var response *s.StartWorkflowExecutionResponse
@@ -386,6 +393,11 @@ func (wc *workflowClient) SignalWithStartWorkflow(ctx context.Context, workflowI
 		return nil, err
 	}
 
+	delayStartSeconds := common.Int32Ceil(options.DelayStart.Seconds())
+	if delayStartSeconds < 0 {
+		return nil, errors.New("Invalid DelayStart option")
+	}
+
 	// create a workflow start span and attach it to the context object. finish it immediately
 	ctx, span := createOpenTracingWorkflowSpan(ctx, wc.tracer, time.Now(), fmt.Sprintf("SignalWithStartWorkflow-%s", workflowType.Name), workflowID)
 	span.Finish()
@@ -411,6 +423,7 @@ func (wc *workflowClient) SignalWithStartWorkflow(ctx context.Context, workflowI
 		SearchAttributes:                    searchAttr,
 		WorkflowIdReusePolicy:               options.WorkflowIDReusePolicy.toThriftPtr(),
 		Header:                              header,
+		DelayStartSeconds:                   common.Int32Ptr(delayStartSeconds),
 	}
 
 	var response *s.StartWorkflowExecutionResponse