testvars

Documentation

Index

• type Any
  • func (a Any) EventID() int64
  • func (a Any) Int() int
  • func (a Any) Payload() *commonpb.Payload
  • func (a Any) Payloads() *commonpb.Payloads
  • func (a Any) String() string
• type Global
  • func (c Global) ClusterName() string
  • func (c Global) RemoteClusterName() string
• type TestVars
  • func New(testName string) *TestVars
  • func (tv *TestVars) ActivityID(key ...string) string
  • func (tv *TestVars) ActivityType(key ...string) *commonpb.ActivityType
  • func (tv *TestVars) Any() Any
  • func (tv *TestVars) Global() Global
  • func (tv *TestVars) HandlerName(key ...string) string
  • func (tv *TestVars) InfiniteTimeout() *durationpb.Duration
  • func (tv *TestVars) MessageID(key ...string) string
  • func (tv *TestVars) Namespace(key ...string) *namespace.Namespace
  • func (tv *TestVars) NamespaceID(key ...string) namespace.ID
  • func (tv *TestVars) NamespaceName(key ...string) namespace.Name
  • func (tv *TestVars) RunID(key ...string) string
  • func (tv *TestVars) StickyTaskQueue(key ...string) *taskqueuepb.TaskQueue
  • func (tv *TestVars) String(key ...string) string
  • func (tv *TestVars) TaskQueue(key ...string) *taskqueuepb.TaskQueue
  • func (tv *TestVars) TimerID(key ...string) string
  • func (tv *TestVars) UpdateID(key ...string) string
  • func (tv *TestVars) UpdateRef() *updatepb.UpdateRef
  • func (tv *TestVars) WithActivityID(activityID string, key ...string) *TestVars
  • func (tv *TestVars) WithActivityType(workflowType string, key ...string) *TestVars
  • func (tv *TestVars) WithHandlerName(handlerName string, key ...string) *TestVars
  • func (tv *TestVars) WithMessageID(messageID string, key ...string) *TestVars
  • func (tv *TestVars) WithNamespaceID(namespaceID namespace.ID, key ...string) *TestVars
  • func (tv *TestVars) WithNamespaceName(namespaceName namespace.Name, key ...string) *TestVars
  • func (tv *TestVars) WithRunID(runID string, key ...string) *TestVars
  • func (tv *TestVars) WithStickyTaskQueue(stickyTaskQueue string, key ...string) *TestVars
  • func (tv *TestVars) WithString(str string, key ...string) *TestVars
  • func (tv *TestVars) WithTaskQueue(taskQueue string, key ...string) *TestVars
  • func (tv *TestVars) WithTimerID(timerID string, key ...string) *TestVars
  • func (tv *TestVars) WithUpdateID(updateID string, key ...string) *TestVars
  • func (tv *TestVars) WithWorkerIdentity(identity string, key ...string) *TestVars
  • func (tv *TestVars) WithWorkflowID(workflowID string, key ...string) *TestVars
  • func (tv *TestVars) WithWorkflowType(workflowType string, key ...string) *TestVars
  • func (tv *TestVars) WorkerIdentity(key ...string) string
  • func (tv *TestVars) WorkflowExecution(key ...string) *commonpb.WorkflowExecution
  • func (tv *TestVars) WorkflowID(key ...string) string
  • func (tv *TestVars) WorkflowType(key ...string) *commonpb.WorkflowType

Types

type Any

type Any struct {
	// contains filtered or unexported fields
}

func (Any) EventID

func (a Any) EventID() int64

func (Any) Int

func (a Any) Int() int

func (Any) Payload

func (a Any) Payload() *commonpb.Payload

func (Any) Payloads

func (a Any) Payloads() *commonpb.Payloads

func (Any) String

func (a Any) String() string

type Global

type Global struct {
}

func (Global) ClusterName

func (c Global) ClusterName() string

func (Global) RemoteClusterName

func (c Global) RemoteClusterName() string

type TestVars

type TestVars struct {
	// contains filtered or unexported fields
}

func New

func New(testName string) *TestVars

func (*TestVars) ActivityID

func (tv *TestVars) ActivityID(key ...string) string

func (*TestVars) ActivityType

func (tv *TestVars) ActivityType(key ...string) *commonpb.ActivityType

func (*TestVars) Any

func (tv *TestVars) Any() Any

func (*TestVars) Global

func (tv *TestVars) Global() Global

func (*TestVars) HandlerName

func (tv *TestVars) HandlerName(key ...string) string

func (*TestVars) InfiniteTimeout

func (tv *TestVars) InfiniteTimeout() *durationpb.Duration

func (*TestVars) MessageID

func (tv *TestVars) MessageID(key ...string) string

func (*TestVars) Namespace

func (tv *TestVars) Namespace(key ...string) *namespace.Namespace

func (*TestVars) NamespaceID

func (tv *TestVars) NamespaceID(key ...string) namespace.ID

func (*TestVars) NamespaceName

func (tv *TestVars) NamespaceName(key ...string) namespace.Name

func (*TestVars) RunID

func (tv *TestVars) RunID(key ...string) string

func (*TestVars) StickyTaskQueue

func (tv *TestVars) StickyTaskQueue(key ...string) *taskqueuepb.TaskQueue

func (*TestVars) String

func (tv *TestVars) String(key ...string) string

func (*TestVars) TaskQueue

func (tv *TestVars) TaskQueue(key ...string) *taskqueuepb.TaskQueue

func (*TestVars) TimerID

func (tv *TestVars) TimerID(key ...string) string

func (*TestVars) UpdateID

func (tv *TestVars) UpdateID(key ...string) string

func (*TestVars) UpdateRef

func (tv *TestVars) UpdateRef() *updatepb.UpdateRef

func (*TestVars) WithActivityID

func (tv *TestVars) WithActivityID(activityID string, key ...string) *TestVars

func (*TestVars) WithActivityType

func (tv *TestVars) WithActivityType(workflowType string, key ...string) *TestVars

func (*TestVars) WithHandlerName

func (tv *TestVars) WithHandlerName(handlerName string, key ...string) *TestVars

func (*TestVars) WithMessageID

func (tv *TestVars) WithMessageID(messageID string, key ...string) *TestVars

func (*TestVars) WithNamespaceID

func (tv *TestVars) WithNamespaceID(namespaceID namespace.ID, key ...string) *TestVars

func (*TestVars) WithNamespaceName

func (tv *TestVars) WithNamespaceName(namespaceName namespace.Name, key ...string) *TestVars

func (*TestVars) WithRunID

func (tv *TestVars) WithRunID(runID string, key ...string) *TestVars

func (*TestVars) WithStickyTaskQueue

func (tv *TestVars) WithStickyTaskQueue(stickyTaskQueue string, key ...string) *TestVars

func (*TestVars) WithString

func (tv *TestVars) WithString(str string, key ...string) *TestVars

func (*TestVars) WithTaskQueue

func (tv *TestVars) WithTaskQueue(taskQueue string, key ...string) *TestVars

func (*TestVars) WithTimerID

func (tv *TestVars) WithTimerID(timerID string, key ...string) *TestVars

func (*TestVars) WithUpdateID

func (tv *TestVars) WithUpdateID(updateID string, key ...string) *TestVars

func (*TestVars) WithWorkerIdentity

func (tv *TestVars) WithWorkerIdentity(identity string, key ...string) *TestVars

func (*TestVars) WithWorkflowID

func (tv *TestVars) WithWorkflowID(workflowID string, key ...string) *TestVars

func (*TestVars) WithWorkflowType

func (tv *TestVars) WithWorkflowType(workflowType string, key ...string) *TestVars

func (*TestVars) WorkerIdentity

func (tv *TestVars) WorkerIdentity(key ...string) string

func (*TestVars) WorkflowExecution

func (tv *TestVars) WorkflowExecution(key ...string) *commonpb.WorkflowExecution

func (*TestVars) WorkflowID

func (tv *TestVars) WorkflowID(key ...string) string

func (*TestVars) WorkflowType

func (tv *TestVars) WorkflowType(key ...string) *commonpb.WorkflowType