tdbg

Documentation

Index

• Variables
• func AdminDecodeBase64(c *cli.Context) error
• func AdminDecodeProto(c *cli.Context) error
• func AdminDeleteWorkflow(c *cli.Context) error
• func AdminDescribeHistoryHost(c *cli.Context) error
• func AdminDescribeShard(c *cli.Context) error
• func AdminDescribeWorkflow(c *cli.Context) error
• func AdminGetDLQMessages(c *cli.Context) (err error)
• func AdminGetShardID(c *cli.Context) error
• func AdminListClusterMembers(c *cli.Context) error
• func AdminListGossipMembers(c *cli.Context) error
• func AdminListShardTasks(c *cli.Context) error
• func AdminListTaskQueueTasks(c *cli.Context) error
• func AdminMergeDLQMessages(c *cli.Context) error
• func AdminPurgeDLQMessages(c *cli.Context) error
• func AdminRebuildMutableState(c *cli.Context) error
• func AdminRefreshWorkflowTasks(c *cli.Context) error
• func AdminRemoveTask(c *cli.Context) error
• func AdminShardManagement(c *cli.Context) error
• func AdminShowWorkflow(c *cli.Context) error
• func NewCliApp() *cli.App
• func SetFactory(factory ClientFactory)
• type ClientFactory
  • func NewClientFactory() ClientFactory
• type HttpGetter

Variables

var (
	FlagAddress                    = "address"
	FlagHistoryAddress             = "history-address"
	FlagNamespaceID                = "namespace-id"
	FlagNamespace                  = "namespace"
	FlagNamespaceAlias             = []string{"n"}
	FlagShardID                    = "shard-id"
	FlagWorkflowID                 = "workflow-id"
	FlagWorkflowIDAlias            = []string{"wid"}
	FlagRunID                      = "run-id"
	FlagRunIDAlias                 = []string{"rid"}
	FlagNumberOfShards             = "number-of-shards"
	FlagMinEventID                 = "min-event-id"
	FlagMaxEventID                 = "max-event-id"
	FlagTaskQueue                  = "task-queue"
	FlagTaskQueueType              = "task-queue-type"
	FlagContextTimeout             = "context-timeout"
	FlagContextTimeoutAlias        = []string{"ct"}
	FlagCluster                    = "cluster"
	FlagPageSize                   = "pagesize"
	FlagFrom                       = "from"
	FlagPrintFullyDetail           = "print-full"
	FlagPrintJSON                  = "print-json"
	FlagHeartbeatedWithin          = "heartbeated-within"
	FlagOutputFilename             = "output-filename"
	FlagClusterMembershipRole      = "role"
	FlagSkipErrorMode              = "skip-errors"
	FlagTaskID                     = "task-id"
	FlagTaskType                   = "task-type"
	FlagTaskVisibilityTimestamp    = "task-timestamp"
	FlagMinVisibilityTimestamp     = "min-visibility-ts"
	FlagMaxVisibilityTimestamp     = "max-visibility-ts"
	FlagEnableTLS                  = "tls"
	FlagTLSCertPath                = "tls-cert-path"
	FlagTLSKeyPath                 = "tls-key-path"
	FlagTLSCaPath                  = "tls-ca-path"
	FlagTLSDisableHostVerification = "tls-disable-host-verification"
	FlagTLSServerName              = "tls-server-name"
	FlagLastMessageID              = "last-message-id"
	FlagYes                        = "yes"
	FlagMore                       = "more"
	FlagMinEventVersion            = "min-event-version"
	FlagMaxEventVersion            = "max-event-version"
	FlagMinTaskID                  = "min-task-id"
	FlagMaxTaskID                  = "max-task-id"
	FlagDLQType                    = "dlq-type"
	FlagMaxMessageCount            = "max-message-count"
	FlagProtoType                  = "type"
	FlagHexData                    = "hex-data"
	FlagHexFile                    = "hex-file"
	FlagBinaryFile                 = "binary-file"
	FlagBase64Data                 = "base64-data"
	FlagBase64File                 = "base64-file"
)

Flags used to specify cli command line arguments

Functions

func AdminDecodeBase64

func AdminDecodeBase64(c *cli.Context) error

func AdminDecodeProto

func AdminDecodeProto(c *cli.Context) error

func AdminDeleteWorkflow

func AdminDeleteWorkflow(c *cli.Context) error

AdminDeleteWorkflow force deletes a workflow's mutable state (both concrete and current), history, and visibility records as long as it's possible. It should only be used as a troubleshooting tool since no additional check will be done before the deletion. (e.g. if a child workflow has recorded its result in the parent workflow) Please use normal workflow delete command to gracefully delete a workflow execution.

func AdminDescribeHistoryHost

func AdminDescribeHistoryHost(c *cli.Context) error

AdminDescribeHistoryHost describes history host

func AdminDescribeShard

func AdminDescribeShard(c *cli.Context) error

AdminDescribeShard describes shard by shard id

func AdminDescribeWorkflow

func AdminDescribeWorkflow(c *cli.Context) error

AdminDescribeWorkflow describe a new workflow execution for admin

func AdminGetDLQMessages

func AdminGetDLQMessages(c *cli.Context) (err error)

AdminGetDLQMessages gets DLQ metadata

func AdminGetShardID

func AdminGetShardID(c *cli.Context) error

AdminGetShardID get shardID

func AdminListClusterMembers

func AdminListClusterMembers(c *cli.Context) error

AdminListClusterMembers outputs a list of cluster members

func AdminListGossipMembers

func AdminListGossipMembers(c *cli.Context) error

AdminListGossipMembers outputs a list of gossip members

func AdminListShardTasks

func AdminListShardTasks(c *cli.Context) error

AdminListShardTasks outputs a list of a tasks for given Shard and Task Category

func AdminListTaskQueueTasks

func AdminListTaskQueueTasks(c *cli.Context) error

AdminListTaskQueueTasks displays task information

func AdminMergeDLQMessages

func AdminMergeDLQMessages(c *cli.Context) error

AdminMergeDLQMessages merges message from DLQ

func AdminPurgeDLQMessages

func AdminPurgeDLQMessages(c *cli.Context) error

AdminPurgeDLQMessages deletes messages from DLQ

func AdminRebuildMutableState

func AdminRebuildMutableState(c *cli.Context) error

AdminRebuildMutableState rebuild a workflow mutable state using persisted history events

func AdminRefreshWorkflowTasks

func AdminRefreshWorkflowTasks(c *cli.Context) error

AdminRefreshWorkflowTasks refreshes all the tasks of a workflow

func AdminRemoveTask

func AdminRemoveTask(c *cli.Context) error

AdminRemoveTask describes history host

func AdminShardManagement

func AdminShardManagement(c *cli.Context) error

AdminShardManagement describes history host

func AdminShowWorkflow

func AdminShowWorkflow(c *cli.Context) error

AdminShowWorkflow shows history

func NewCliApp

func NewCliApp() *cli.App

NewCliApp instantiates a new instance of the CLI application.

func SetFactory

func SetFactory(factory ClientFactory)

SetFactory is used to set the ClientFactory global

Types

type ClientFactory

type ClientFactory interface {
	AdminClient(c *cli.Context) adminservice.AdminServiceClient
	WorkflowClient(c *cli.Context) workflowservice.WorkflowServiceClient
}

ClientFactory is used to construct rpc clients

func NewClientFactory

func NewClientFactory() ClientFactory

NewClientFactory creates a new ClientFactory

type HttpGetter

type HttpGetter interface {
	Get(url string) (resp *http.Response, err error)
}

HttpGetter defines http.Client.Get(...) as an interface so we can mock it