Write tests for cassandra/queue.go

cadence-workflow · Apr 2, 2024 · 7363688 · 7363688
1 parent bbb7772
commit 7363688
Show file tree

Hide file tree

Showing 3 changed files with 939 additions and 9 deletions.
diff --git a/common/persistence/nosql/nosqlplugin/cassandra/queue.go b/common/persistence/nosql/nosqlplugin/cassandra/queue.go
@@ -252,16 +252,10 @@ func (db *cdb) GetQueueSize(
 	return result["count"].(int64), nil
 }
 
-func getMessagePayload(
-	message map[string]interface{},
-) []byte {
-
+func getMessagePayload(message map[string]interface{}) []byte {
 	return message["message_payload"].([]byte)
 }
 
-func getMessageID(
-	message map[string]interface{},
-) int64 {
-
+func getMessageID(message map[string]interface{}) int64 {
 	return message["message_id"].(int64)
 }