stash

uber · Jun 17, 2021 · e5ce06e · e5ce06e
1 parent 1676eaa
commit e5ce06e
Show file tree

Hide file tree

Showing 5 changed files with 1,268 additions and 20 deletions.
diff --git a/common/persistence/dataStoreInterfaces.go b/common/persistence/dataStoreInterfaces.go
@@ -887,6 +887,16 @@ func FromDataBlob(blob *DataBlob) ([]byte, string) {
 	return blob.Data, string(blob.Encoding)
 }
 
+func (d *DataBlob) ToNilSafeDataBlob() *DataBlob {
+	if d != nil {
+		return d
+	}
+	return &DataBlob{}
+}
+func (d *DataBlob) GetEncodingString() string {
+	return string(d.Encoding)
+}
+
 // GetEncoding returns encoding type
 func (d *DataBlob) GetEncoding() common.EncodingType {
 	encodingStr := string(d.Encoding)

diff --git a/common/persistence/nosql/nosqlplugin/cassandra/constants.go b/common/persistence/nosql/nosqlplugin/cassandra/constants.go
@@ -53,6 +53,7 @@ const (
 	rowTypeTimerTask
 	rowTypeReplicationTask
 	rowTypeDLQ
+	rowTypeCrossClusterTask
 )
 
 // Guidelines for creating new special UUID constants
@@ -75,6 +76,9 @@ const (
 	rowTypeTransferDomainID   = "10000000-3000-f000-f000-000000000000"
 	rowTypeTransferWorkflowID = "20000000-3000-f000-f000-000000000000"
 	rowTypeTransferRunID      = "30000000-3000-f000-f000-000000000000"
+	// Row Constants for Cross Cluster Task Row
+	rowTypeCrossClusterDomainID = "10000000-7000-f000-f000-000000000000"
+	rowTypeCrossClusterRunID    = "30000000-7000-f000-f000-000000000000"
 	// Row Constants for Timer Task Row
 	rowTypeTimerDomainID   = "10000000-4000-f000-f000-000000000000"
 	rowTypeTimerWorkflowID = "20000000-4000-f000-f000-000000000000"