Cadence Worker service to host replicator (#563)

* Cadence Worker service to host replicator New cadence-worker service and bootstrap code to bring up the new service. This service currently only host the replicator which consumes replication tasks from kafka topic and applies to current Cadence cluster. MessagingClient interface abstract out interaction with Kafka. KafkaClient provides implementation for the interface using kafka-client library which consumes messages from Kafka broker. Created separate Kafka configuration used for bootstrapping the KafkaClient created during service startup and passed down to replicator. Created replicator.thrift which defines the payload which is sent over to other clusters through KafkaClient.
cadence-workflow · Feb 20, 2018 · 2740e6b · 2740e6b
1 parent ce52993
commit 2740e6b
Show file tree

Hide file tree

Showing 84 changed files with 1,547 additions and 93 deletions.
diff --git a/.gen/go/cadence/idl.go b/.gen/go/cadence/idl.go
diff --git a/.gen/go/cadence/workflowservice_deprecatedomain.go b/.gen/go/cadence/workflowservice_deprecatedomain.go
diff --git a/.gen/go/cadence/workflowservice_describedomain.go b/.gen/go/cadence/workflowservice_describedomain.go
diff --git a/.gen/go/cadence/workflowservice_describetasklist.go b/.gen/go/cadence/workflowservice_describetasklist.go
diff --git a/.gen/go/cadence/workflowservice_describeworkflowexecution.go b/.gen/go/cadence/workflowservice_describeworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_getworkflowexecutionhistory.go b/.gen/go/cadence/workflowservice_getworkflowexecutionhistory.go
diff --git a/.gen/go/cadence/workflowservice_listclosedworkflowexecutions.go b/.gen/go/cadence/workflowservice_listclosedworkflowexecutions.go
diff --git a/.gen/go/cadence/workflowservice_listopenworkflowexecutions.go b/.gen/go/cadence/workflowservice_listopenworkflowexecutions.go
diff --git a/.gen/go/cadence/workflowservice_pollforactivitytask.go b/.gen/go/cadence/workflowservice_pollforactivitytask.go
diff --git a/.gen/go/cadence/workflowservice_pollfordecisiontask.go b/.gen/go/cadence/workflowservice_pollfordecisiontask.go
diff --git a/.gen/go/cadence/workflowservice_queryworkflow.go b/.gen/go/cadence/workflowservice_queryworkflow.go
diff --git a/.gen/go/cadence/workflowservice_recordactivitytaskheartbeat.go b/.gen/go/cadence/workflowservice_recordactivitytaskheartbeat.go
diff --git a/.gen/go/cadence/workflowservice_registerdomain.go b/.gen/go/cadence/workflowservice_registerdomain.go
diff --git a/.gen/go/cadence/workflowservice_requestcancelworkflowexecution.go b/.gen/go/cadence/workflowservice_requestcancelworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskcanceled.go b/.gen/go/cadence/workflowservice_respondactivitytaskcanceled.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskcanceledbyid.go b/.gen/go/cadence/workflowservice_respondactivitytaskcanceledbyid.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskcompleted.go b/.gen/go/cadence/workflowservice_respondactivitytaskcompleted.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskcompletedbyid.go b/.gen/go/cadence/workflowservice_respondactivitytaskcompletedbyid.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskfailed.go b/.gen/go/cadence/workflowservice_respondactivitytaskfailed.go
diff --git a/.gen/go/cadence/workflowservice_respondactivitytaskfailedbyid.go b/.gen/go/cadence/workflowservice_respondactivitytaskfailedbyid.go
diff --git a/.gen/go/cadence/workflowservice_responddecisiontaskcompleted.go b/.gen/go/cadence/workflowservice_responddecisiontaskcompleted.go
diff --git a/.gen/go/cadence/workflowservice_responddecisiontaskfailed.go b/.gen/go/cadence/workflowservice_responddecisiontaskfailed.go
diff --git a/.gen/go/cadence/workflowservice_respondquerytaskcompleted.go b/.gen/go/cadence/workflowservice_respondquerytaskcompleted.go
diff --git a/.gen/go/cadence/workflowservice_signalworkflowexecution.go b/.gen/go/cadence/workflowservice_signalworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_startworkflowexecution.go b/.gen/go/cadence/workflowservice_startworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_terminateworkflowexecution.go b/.gen/go/cadence/workflowservice_terminateworkflowexecution.go
diff --git a/.gen/go/cadence/workflowservice_updatedomain.go b/.gen/go/cadence/workflowservice_updatedomain.go
diff --git a/.gen/go/health/idl.go b/.gen/go/health/idl.go
diff --git a/.gen/go/health/meta_health.go b/.gen/go/health/meta_health.go
diff --git a/.gen/go/health/types.go b/.gen/go/health/types.go
diff --git a/.gen/go/history/historyservice_describeworkflowexecution.go b/.gen/go/history/historyservice_describeworkflowexecution.go
diff --git a/.gen/go/history/historyservice_getmutablestate.go b/.gen/go/history/historyservice_getmutablestate.go
diff --git a/.gen/go/history/historyservice_recordactivitytaskheartbeat.go b/.gen/go/history/historyservice_recordactivitytaskheartbeat.go
diff --git a/.gen/go/history/historyservice_recordactivitytaskstarted.go b/.gen/go/history/historyservice_recordactivitytaskstarted.go
diff --git a/.gen/go/history/historyservice_recordchildexecutioncompleted.go b/.gen/go/history/historyservice_recordchildexecutioncompleted.go
diff --git a/.gen/go/history/historyservice_recorddecisiontaskstarted.go b/.gen/go/history/historyservice_recorddecisiontaskstarted.go
diff --git a/.gen/go/history/historyservice_removesignalmutablestate.go b/.gen/go/history/historyservice_removesignalmutablestate.go
diff --git a/.gen/go/history/historyservice_requestcancelworkflowexecution.go b/.gen/go/history/historyservice_requestcancelworkflowexecution.go
diff --git a/.gen/go/history/historyservice_respondactivitytaskcanceled.go b/.gen/go/history/historyservice_respondactivitytaskcanceled.go
diff --git a/.gen/go/history/historyservice_respondactivitytaskcompleted.go b/.gen/go/history/historyservice_respondactivitytaskcompleted.go
diff --git a/.gen/go/history/historyservice_respondactivitytaskfailed.go b/.gen/go/history/historyservice_respondactivitytaskfailed.go
diff --git a/.gen/go/history/historyservice_responddecisiontaskcompleted.go b/.gen/go/history/historyservice_responddecisiontaskcompleted.go
diff --git a/.gen/go/history/historyservice_responddecisiontaskfailed.go b/.gen/go/history/historyservice_responddecisiontaskfailed.go
diff --git a/.gen/go/history/historyservice_scheduledecisiontask.go b/.gen/go/history/historyservice_scheduledecisiontask.go