Skip to content

Commit

Permalink
Support AsyncWorkflowConfiguration decoding in admin cli (cadence-wor…
Browse files Browse the repository at this point in the history
  • Loading branch information
taylanisikdemir authored Feb 29, 2024
1 parent 6a39682 commit bc08024
Showing 1 changed file with 25 additions and 24 deletions.
49 changes: 25 additions & 24 deletions tools/cli/admin_db_decode_thrift.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit bc08024

Please sign in to comment.