Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add Sticky Query to Cadence Server #464

Merged
merged 6 commits into from
Dec 16, 2017
Merged

Add Sticky Query to Cadence Server #464

Show file tree
Hide file tree
Changes from 3 commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
353a2f4
Revert "Revert "add support for sticky query (#452)" (#459)"
Dec 13, 2017
ec85132
add field in QueryWorkflowRequest, specifying whether to use sticky t…
Dec 13, 2017
b4a14e9
use information from worker / client header to determine whether to u…
Dec 14, 2017
c43a59d
rename GetWorkflowNextEventID to GetMutableState, add missing persist…
Dec 15, 2017
05ca9c5
Merge branch 'master' into revert
wxing1292 Dec 15, 2017
cdf0a36
address comments
Dec 15, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions .gen/go/shared/idl.go
View file
Open in desktop

Large diffs are not rendered by default.

172 changes: 170 additions & 2 deletions .gen/go/shared/types.go
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions Makefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -91,15 +91,15 @@ test: vendor/glide.updated bins
@rm -f test
@rm -f test.log
@for dir in $(TEST_DIRS); do \
go test -coverprofile=$@ "$$dir" | tee -a test.log; \
go test -race -coverprofile=$@ "$$dir" | tee -a test.log; \
done;

cover_profile: clean bins_nothrift
@mkdir -p $(BUILD)
@echo "mode: atomic" > $(BUILD)/cover.out

@echo Running integration test
@mkdir -p $(BUILD)/$(INTEG_TEST_DIR)
@mkdir -p $(BUILD)/$(INTEG_TEST_DIR)
@time go test $(INTEG_TEST_ROOT) $(TEST_ARG) $(GOCOVERPKG_ARG) -coverprofile=$(BUILD)/$(INTEG_TEST_DIR)/coverage.out || exit 1;
@cat $(BUILD)/$(INTEG_TEST_DIR)/coverage.out | grep -v "mode: atomic" >> $(BUILD)/cover.out

Expand Down
32 changes: 16 additions & 16 deletions client/history/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ func (c *clientImpl) StartWorkflowExecution(
var err error
ctx, cancel := c.createContext(ctx)
defer cancel()
response, err = client.StartWorkflowExecution(ctx, request)
response, err = client.StartWorkflowExecution(ctx, request, opts...)
return err
}
err = c.executeWithRedirect(ctx, client, op)
Expand All @@ -98,7 +98,7 @@ func (c *clientImpl) GetWorkflowExecutionNextEventID(
var err error
ctx, cancel := c.createContext(ctx)
defer cancel()
response, err = client.GetWorkflowExecutionNextEventID(ctx, request)
response, err = client.GetWorkflowExecutionNextEventID(ctx, request, opts...)
return err
}
err = c.executeWithRedirect(ctx, client, op)
Expand All @@ -121,7 +121,7 @@ func (c *clientImpl) DescribeWorkflowExecution(
var err error
ctx, cancel := c.createContext(ctx)
defer cancel()
response, err = client.DescribeWorkflowExecution(ctx, request)
response, err = client.DescribeWorkflowExecution(ctx, request, opts...)
return err
}
err = c.executeWithRedirect(ctx, client, op)
Expand All @@ -144,7 +144,7 @@ func (c *clientImpl) RecordDecisionTaskStarted(
var err error
ctx, cancel := c.createContext(ctx)
defer cancel()
response, err = client.RecordDecisionTaskStarted(ctx, request)
response, err = client.RecordDecisionTaskStarted(ctx, request, opts...)
return err
}
err = c.executeWithRedirect(ctx, client, op)
Expand All @@ -167,7 +167,7 @@ func (c *clientImpl) RecordActivityTaskStarted(
var err error
ctx, cancel := c.createContext(ctx)
defer cancel()
response, err = client.RecordActivityTaskStarted(ctx, request)
response, err = client.RecordActivityTaskStarted(ctx, request, opts...)
return err
}
err = c.executeWithRedirect(ctx, client, op)
Expand All @@ -192,7 +192,7 @@ func (c *clientImpl) RespondDecisionTaskCompleted(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RespondDecisionTaskCompleted(ctx, request)
return client.RespondDecisionTaskCompleted(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -213,7 +213,7 @@ func (c *clientImpl) RespondDecisionTaskFailed(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RespondDecisionTaskFailed(ctx, request)
return client.RespondDecisionTaskFailed(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -234,7 +234,7 @@ func (c *clientImpl) RespondActivityTaskCompleted(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RespondActivityTaskCompleted(ctx, request)
return client.RespondActivityTaskCompleted(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -255,7 +255,7 @@ func (c *clientImpl) RespondActivityTaskFailed(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RespondActivityTaskFailed(ctx, request)
return client.RespondActivityTaskFailed(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -276,7 +276,7 @@ func (c *clientImpl) RespondActivityTaskCanceled(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RespondActivityTaskCanceled(ctx, request)
return client.RespondActivityTaskCanceled(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -299,7 +299,7 @@ func (c *clientImpl) RecordActivityTaskHeartbeat(
var err error
ctx, cancel := c.createContext(ctx)
defer cancel()
response, err = client.RecordActivityTaskHeartbeat(ctx, request)
response, err = client.RecordActivityTaskHeartbeat(ctx, request, opts...)
return err
}
err = c.executeWithRedirect(ctx, client, op)
Expand All @@ -320,7 +320,7 @@ func (c *clientImpl) RequestCancelWorkflowExecution(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RequestCancelWorkflowExecution(ctx, request)
return client.RequestCancelWorkflowExecution(ctx, request, opts...)
}
return c.executeWithRedirect(ctx, client, op)
}
Expand All @@ -336,7 +336,7 @@ func (c *clientImpl) SignalWorkflowExecution(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.SignalWorkflowExecution(ctx, request)
return client.SignalWorkflowExecution(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)

Expand All @@ -354,7 +354,7 @@ func (c *clientImpl) TerminateWorkflowExecution(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.TerminateWorkflowExecution(ctx, request)
return client.TerminateWorkflowExecution(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -371,7 +371,7 @@ func (c *clientImpl) ScheduleDecisionTask(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.ScheduleDecisionTask(ctx, request)
return client.ScheduleDecisionTask(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand All @@ -388,7 +388,7 @@ func (c *clientImpl) RecordChildExecutionCompleted(
op := func(ctx context.Context, client historyserviceclient.Interface) error {
ctx, cancel := c.createContext(ctx)
defer cancel()
return client.RecordChildExecutionCompleted(ctx, request)
return client.RecordChildExecutionCompleted(ctx, request, opts...)
}
err = c.executeWithRedirect(ctx, client, op)
return err
Expand Down
Loading