Commit Graph
12 Commits
Author SHA1 Message Date
Shawn HathawayandGitHub 4698cf4291 Add ClusterMembership Persistence Capabilities (#117)
This change adds three new apis to the ClusterMetadataManager persistence client across Mysql, Postgresql and Cassandra implementations:

- GetActiveClusterMembers
- UpsertClusterMembership
- PruneClusterMembership

This paves the way for a subsequent change to persist and coordinate cluster membership through this layer.
2020-02-07 17:34:54 -08:00
Alex Shtin 0e4ca57040 Merge from uber/cadence on 01-23-20. 2020-01-23 15:37:35 -08:00
Shawn HathawayandGitHub d7f9a4853a Immutable ClusterMetadata Persistence (#71)
This builds upon https://github.com/temporalio/temporal/pull/65 and implements the logic on top of the provided schemas to make the number of history shards and the cluster name read-only configuration.

See PR commits for step by step vertical implementation of a configuration value to the persistence layer.
2020-01-21 18:15:32 -08:00
Yu XiaandGitHub 23a5d6713d Add Domain Replication DLQ (#2964)
* Add Domain Replication DLQ

* Adding query range, limit and order on the DB dlq query
2020-01-13 20:52:04 -08:00
Ben JacobsonandVenkat 9ee79dc723 Add support for custom mysql tls configuration (#2913) 2020-01-10 16:43:29 -08:00
Bowei XuandGitHub d53bd92c02 Fix bench of issues with new lint tool (#2962) 2020-01-06 16:10:32 -08:00
Alex Shtin b8169a84bf Merge remote-tracking branch 'cadence/master' into merge/cadence-12-19-19
Conflicts:
	.gen/go/history/history.go
	.gen/go/temporal/temporal.go
	cmd/server/cadence/cadence.go
	cmd/server/cadence/server.go
	cmd/tools/sql/main.go
	common/service/service.go
	docs/persistence.md
	go.mod
	go.sum
	service/frontend/dcRedirectionHandler.go
	service/frontend/service.go
	service/history/conflictResolver_test.go
	service/history/historyBuilder_test.go
	service/history/historyCache_test.go
	service/history/historyEngine.go
	service/history/historyEngine2_test.go
	service/history/historyEngine3_eventsv2_test.go
	service/history/historyEngine_test.go
	service/history/historyReplicator_test.go
	service/history/mutableStateBuilder_test.go
	service/history/nDCActivityReplicator_test.go
	service/history/nDCBranchMgr_test.go
	service/history/nDCConflictResolver_test.go
	service/history/nDCStateRebuilder_test.go
	service/history/nDCTransactionMgr_test.go
	service/history/nDCWorkflowResetter_test.go
	service/history/queueAckMgr_test.go
	service/history/replicatorQueueProcessor_test.go
	service/history/shardController_test.go
	service/history/stateBuilder_test.go
	service/history/taskProcessor_test.go
	service/history/timerQueueAckMgr_test.go
	service/history/timerQueueActiveProcessor_test.go
	service/history/timerQueueProcessorBase_test.go
	service/history/timerQueueStandbyProcessor_test.go
	service/history/transferQueueActiveProcessor_test.go
	service/history/transferQueueStandbyProcessor_test.go
	service/history/workflowResetor_test.go
	service/history/workflowResetter_test.go
	service/matching/handler.go
2019-12-19 16:07:20 -08:00
Quanzheng LongandGitHub d22e8104cf Enforce ordering in reading transfer tasks (#2916) 2019-12-17 17:11:22 -08:00
Yu XiaandGitHub 385dd85f24 [Kafka deprecation] Move ack level to source cluster (#2896)
* Add ack level to source cluster and source cluster can clean up replication task based on min ack level from all other clusters
* Add sync shard info from get replication messages API
2019-12-17 15:18:25 -08:00
Andrew DawsonandGitHub 1443829760 Sticky query support (#2899) 2019-12-12 12:57:10 -08:00
Samar Abbas 34bd0a03c2 resolve all merge conflicts and unit tests to work again 2019-12-10 12:20:56 -08:00
Quanzheng LongandGitHub eea1e2b8c7 Implement Postgres SQL Plugin (#2889) 2019-12-06 11:53:22 -08:00