From 78d12f69c444089272c9c579d92cf97199c3c1e7 Mon Sep 17 00:00:00 2001 From: taylan isikdemir Date: Wed, 28 Feb 2024 14:22:11 -0800 Subject: [PATCH] Support AsyncWorkflowConfiguration decoding in admin cli --- tools/cli/admin_db_decode_thrift.go | 49 +++++++++++++++-------------- 1 file changed, 25 insertions(+), 24 deletions(-) diff --git a/tools/cli/admin_db_decode_thrift.go b/tools/cli/admin_db_decode_thrift.go index a0a7b56e6e6..825ec9aa31f 100644 --- a/tools/cli/admin_db_decode_thrift.go +++ b/tools/cli/admin_db_decode_thrift.go @@ -42,30 +42,31 @@ import ( ) var decodingTypes = map[string]func() codec.ThriftObject{ - "shared.History": func() codec.ThriftObject { return &shared.History{} }, - "shared.HistoryEvent": func() codec.ThriftObject { return &shared.HistoryEvent{} }, - "shared.HistoryBranch": func() codec.ThriftObject { return &shared.HistoryBranch{} }, - "shared.Memo": func() codec.ThriftObject { return &shared.Memo{} }, - "shared.ResetPoints": func() codec.ThriftObject { return &shared.ResetPoints{} }, - "shared.BadBinaries": func() codec.ThriftObject { return &shared.BadBinaries{} }, - "shared.VersionHistories": func() codec.ThriftObject { return &shared.VersionHistories{} }, - "replicator.FailoverMarkers": func() codec.ThriftObject { return &replicator.FailoverMarkers{} }, - "history.ProcessingQueueStates": func() codec.ThriftObject { return &history.ProcessingQueueStates{} }, - "config.DynamicConfigBlob": func() codec.ThriftObject { return &config.DynamicConfigBlob{} }, - "sqlblobs.ShardInfo": func() codec.ThriftObject { return &sqlblobs.ShardInfo{} }, - "sqlblobs.DomainInfo": func() codec.ThriftObject { return &sqlblobs.DomainInfo{} }, - "sqlblobs.HistoryTreeInfo": func() codec.ThriftObject { return &sqlblobs.HistoryTreeInfo{} }, - "sqlblobs.WorkflowExecutionInfo": func() codec.ThriftObject { return &sqlblobs.WorkflowExecutionInfo{} }, - "sqlblobs.ActivityInfo": func() codec.ThriftObject { return &sqlblobs.ActivityInfo{} }, - "sqlblobs.ChildExecutionInfo": func() codec.ThriftObject { return &sqlblobs.ChildExecutionInfo{} }, - "sqlblobs.SignalInfo": func() codec.ThriftObject { return &sqlblobs.SignalInfo{} }, - "sqlblobs.RequestCancelInfo": func() codec.ThriftObject { return &sqlblobs.RequestCancelInfo{} }, - "sqlblobs.TimerInfo": func() codec.ThriftObject { return &sqlblobs.TimerInfo{} }, - "sqlblobs.TaskInfo": func() codec.ThriftObject { return &sqlblobs.TaskInfo{} }, - "sqlblobs.TaskListInfo": func() codec.ThriftObject { return &sqlblobs.TaskListInfo{} }, - "sqlblobs.TransferTaskInfo": func() codec.ThriftObject { return &sqlblobs.TransferTaskInfo{} }, - "sqlblobs.TimerTaskInfo": func() codec.ThriftObject { return &sqlblobs.TimerTaskInfo{} }, - "sqlblobs.ReplicationTaskInfo": func() codec.ThriftObject { return &sqlblobs.ReplicationTaskInfo{} }, + "shared.History": func() codec.ThriftObject { return &shared.History{} }, + "shared.HistoryEvent": func() codec.ThriftObject { return &shared.HistoryEvent{} }, + "shared.HistoryBranch": func() codec.ThriftObject { return &shared.HistoryBranch{} }, + "shared.Memo": func() codec.ThriftObject { return &shared.Memo{} }, + "shared.ResetPoints": func() codec.ThriftObject { return &shared.ResetPoints{} }, + "shared.BadBinaries": func() codec.ThriftObject { return &shared.BadBinaries{} }, + "shared.VersionHistories": func() codec.ThriftObject { return &shared.VersionHistories{} }, + "replicator.FailoverMarkers": func() codec.ThriftObject { return &replicator.FailoverMarkers{} }, + "history.ProcessingQueueStates": func() codec.ThriftObject { return &history.ProcessingQueueStates{} }, + "config.DynamicConfigBlob": func() codec.ThriftObject { return &config.DynamicConfigBlob{} }, + "sqlblobs.ShardInfo": func() codec.ThriftObject { return &sqlblobs.ShardInfo{} }, + "sqlblobs.DomainInfo": func() codec.ThriftObject { return &sqlblobs.DomainInfo{} }, + "sqlblobs.HistoryTreeInfo": func() codec.ThriftObject { return &sqlblobs.HistoryTreeInfo{} }, + "sqlblobs.WorkflowExecutionInfo": func() codec.ThriftObject { return &sqlblobs.WorkflowExecutionInfo{} }, + "sqlblobs.ActivityInfo": func() codec.ThriftObject { return &sqlblobs.ActivityInfo{} }, + "sqlblobs.ChildExecutionInfo": func() codec.ThriftObject { return &sqlblobs.ChildExecutionInfo{} }, + "sqlblobs.SignalInfo": func() codec.ThriftObject { return &sqlblobs.SignalInfo{} }, + "sqlblobs.RequestCancelInfo": func() codec.ThriftObject { return &sqlblobs.RequestCancelInfo{} }, + "sqlblobs.TimerInfo": func() codec.ThriftObject { return &sqlblobs.TimerInfo{} }, + "sqlblobs.TaskInfo": func() codec.ThriftObject { return &sqlblobs.TaskInfo{} }, + "sqlblobs.TaskListInfo": func() codec.ThriftObject { return &sqlblobs.TaskListInfo{} }, + "sqlblobs.TransferTaskInfo": func() codec.ThriftObject { return &sqlblobs.TransferTaskInfo{} }, + "sqlblobs.TimerTaskInfo": func() codec.ThriftObject { return &sqlblobs.TimerTaskInfo{} }, + "sqlblobs.ReplicationTaskInfo": func() codec.ThriftObject { return &sqlblobs.ReplicationTaskInfo{} }, + "shared.AsyncWorkflowConfiguration": func() codec.ThriftObject { return &shared.AsyncWorkflowConfiguration{} }, } type decodeError struct {