workflowservice

package
v0.0.0-...-06c5b24 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 3, 2020 License: MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func BuildWorkflowServiceYARPCProcedures 

func BuildWorkflowServiceYARPCProcedures(server WorkflowServiceYARPCServer) []transport.Procedure

BuildWorkflowServiceYARPCProcedures prepares an implementation of the WorkflowService service for YARPC registration.

func NewFxWorkflowServiceYARPCClient 

func NewFxWorkflowServiceYARPCClient(name string, options ...protobuf.ClientOption) interface{}

NewFxWorkflowServiceYARPCClient provides a WorkflowServiceYARPCClient to an Fx application using the given name for routing. 

fx.Provide(
  workflowservice.NewFxWorkflowServiceYARPCClient("service-name"),
  ...
)

func NewFxWorkflowServiceYARPCProcedures 

func NewFxWorkflowServiceYARPCProcedures() interface{}

NewFxWorkflowServiceYARPCProcedures provides WorkflowServiceYARPCServer procedures to an Fx application. It expects a WorkflowServiceYARPCServer to be present in the container. 

fx.Provide(
  workflowservice.NewFxWorkflowServiceYARPCProcedures(),
  ...
)

func RegisterWorkflowServiceServer 

func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer)

Types

type CountWorkflowExecutionsRequest 

type CountWorkflowExecutionsRequest struct {
	Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Query  string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
}

func (*CountWorkflowExecutionsRequest) Descriptor 

func (*CountWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

func (*CountWorkflowExecutionsRequest) Equal 

func (this *CountWorkflowExecutionsRequest) Equal(that interface{}) bool

func (*CountWorkflowExecutionsRequest) GetDomain 

func (m *CountWorkflowExecutionsRequest) GetDomain() string

func (*CountWorkflowExecutionsRequest) GetQuery 

func (m *CountWorkflowExecutionsRequest) GetQuery() string

func (*CountWorkflowExecutionsRequest) GoString 

func (this *CountWorkflowExecutionsRequest) GoString() string

func (*CountWorkflowExecutionsRequest) Marshal 

func (m *CountWorkflowExecutionsRequest) Marshal() (dAtA []byte, err error)

func (*CountWorkflowExecutionsRequest) MarshalTo 

func (m *CountWorkflowExecutionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*CountWorkflowExecutionsRequest) MarshalToSizedBuffer 

func (m *CountWorkflowExecutionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CountWorkflowExecutionsRequest) ProtoMessage 

func (*CountWorkflowExecutionsRequest) ProtoMessage()

func (*CountWorkflowExecutionsRequest) Reset 

func (m *CountWorkflowExecutionsRequest) Reset()

func (*CountWorkflowExecutionsRequest) Size 

func (m *CountWorkflowExecutionsRequest) Size() (n int)

func (*CountWorkflowExecutionsRequest) String 

func (this *CountWorkflowExecutionsRequest) String() string

func (*CountWorkflowExecutionsRequest) Unmarshal 

func (m *CountWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

func (*CountWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *CountWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*CountWorkflowExecutionsRequest) XXX_Marshal 

func (m *CountWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountWorkflowExecutionsRequest) XXX_Merge 

func (m *CountWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

func (*CountWorkflowExecutionsRequest) XXX_Size 

func (m *CountWorkflowExecutionsRequest) XXX_Size() int

func (*CountWorkflowExecutionsRequest) XXX_Unmarshal 

func (m *CountWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

type CountWorkflowExecutionsResponse 

type CountWorkflowExecutionsResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

func (*CountWorkflowExecutionsResponse) Descriptor 

func (*CountWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

func (*CountWorkflowExecutionsResponse) Equal 

func (this *CountWorkflowExecutionsResponse) Equal(that interface{}) bool

func (*CountWorkflowExecutionsResponse) GetCount 

func (m *CountWorkflowExecutionsResponse) GetCount() int64

func (*CountWorkflowExecutionsResponse) GoString 

func (this *CountWorkflowExecutionsResponse) GoString() string

func (*CountWorkflowExecutionsResponse) Marshal 

func (m *CountWorkflowExecutionsResponse) Marshal() (dAtA []byte, err error)

func (*CountWorkflowExecutionsResponse) MarshalTo 

func (m *CountWorkflowExecutionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*CountWorkflowExecutionsResponse) MarshalToSizedBuffer 

func (m *CountWorkflowExecutionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CountWorkflowExecutionsResponse) ProtoMessage 

func (*CountWorkflowExecutionsResponse) ProtoMessage()

func (*CountWorkflowExecutionsResponse) Reset 

func (m *CountWorkflowExecutionsResponse) Reset()

func (*CountWorkflowExecutionsResponse) Size 

func (m *CountWorkflowExecutionsResponse) Size() (n int)

func (*CountWorkflowExecutionsResponse) String 

func (this *CountWorkflowExecutionsResponse) String() string

func (*CountWorkflowExecutionsResponse) Unmarshal 

func (m *CountWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

func (*CountWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *CountWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*CountWorkflowExecutionsResponse) XXX_Marshal 

func (m *CountWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountWorkflowExecutionsResponse) XXX_Merge 

func (m *CountWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

func (*CountWorkflowExecutionsResponse) XXX_Size 

func (m *CountWorkflowExecutionsResponse) XXX_Size() int

func (*CountWorkflowExecutionsResponse) XXX_Unmarshal 

func (m *CountWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

type DeprecateDomainRequest 

type DeprecateDomainRequest struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SecurityToken string `protobuf:"bytes,2,opt,name=securityToken,proto3" json:"securityToken,omitempty"`
}

func (*DeprecateDomainRequest) Descriptor 

func (*DeprecateDomainRequest) Descriptor() ([]byte, []int)

func (*DeprecateDomainRequest) Equal 

func (this *DeprecateDomainRequest) Equal(that interface{}) bool

func (*DeprecateDomainRequest) GetName 

func (m *DeprecateDomainRequest) GetName() string

func (*DeprecateDomainRequest) GetSecurityToken 

func (m *DeprecateDomainRequest) GetSecurityToken() string

func (*DeprecateDomainRequest) GoString 

func (this *DeprecateDomainRequest) GoString() string

func (*DeprecateDomainRequest) Marshal 

func (m *DeprecateDomainRequest) Marshal() (dAtA []byte, err error)

func (*DeprecateDomainRequest) MarshalTo 

func (m *DeprecateDomainRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeprecateDomainRequest) MarshalToSizedBuffer 

func (m *DeprecateDomainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeprecateDomainRequest) ProtoMessage 

func (*DeprecateDomainRequest) ProtoMessage()

func (*DeprecateDomainRequest) Reset 

func (m *DeprecateDomainRequest) Reset()

func (*DeprecateDomainRequest) Size 

func (m *DeprecateDomainRequest) Size() (n int)

func (*DeprecateDomainRequest) String 

func (this *DeprecateDomainRequest) String() string

func (*DeprecateDomainRequest) Unmarshal 

func (m *DeprecateDomainRequest) Unmarshal(dAtA []byte) error

func (*DeprecateDomainRequest) XXX_DiscardUnknown 

func (m *DeprecateDomainRequest) XXX_DiscardUnknown()

func (*DeprecateDomainRequest) XXX_Marshal 

func (m *DeprecateDomainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeprecateDomainRequest) XXX_Merge 

func (m *DeprecateDomainRequest) XXX_Merge(src proto.Message)

func (*DeprecateDomainRequest) XXX_Size 

func (m *DeprecateDomainRequest) XXX_Size() int

func (*DeprecateDomainRequest) XXX_Unmarshal 

func (m *DeprecateDomainRequest) XXX_Unmarshal(b []byte) error

type DeprecateDomainResponse 

type DeprecateDomainResponse struct {
}

func (*DeprecateDomainResponse) Descriptor 

func (*DeprecateDomainResponse) Descriptor() ([]byte, []int)

func (*DeprecateDomainResponse) Equal 

func (this *DeprecateDomainResponse) Equal(that interface{}) bool

func (*DeprecateDomainResponse) GoString 

func (this *DeprecateDomainResponse) GoString() string

func (*DeprecateDomainResponse) Marshal 

func (m *DeprecateDomainResponse) Marshal() (dAtA []byte, err error)

func (*DeprecateDomainResponse) MarshalTo 

func (m *DeprecateDomainResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeprecateDomainResponse) MarshalToSizedBuffer 

func (m *DeprecateDomainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeprecateDomainResponse) ProtoMessage 

func (*DeprecateDomainResponse) ProtoMessage()

func (*DeprecateDomainResponse) Reset 

func (m *DeprecateDomainResponse) Reset()

func (*DeprecateDomainResponse) Size 

func (m *DeprecateDomainResponse) Size() (n int)

func (*DeprecateDomainResponse) String 

func (this *DeprecateDomainResponse) String() string

func (*DeprecateDomainResponse) Unmarshal 

func (m *DeprecateDomainResponse) Unmarshal(dAtA []byte) error

func (*DeprecateDomainResponse) XXX_DiscardUnknown 

func (m *DeprecateDomainResponse) XXX_DiscardUnknown()

func (*DeprecateDomainResponse) XXX_Marshal 

func (m *DeprecateDomainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeprecateDomainResponse) XXX_Merge 

func (m *DeprecateDomainResponse) XXX_Merge(src proto.Message)

func (*DeprecateDomainResponse) XXX_Size 

func (m *DeprecateDomainResponse) XXX_Size() int

func (*DeprecateDomainResponse) XXX_Unmarshal 

func (m *DeprecateDomainResponse) XXX_Unmarshal(b []byte) error

type DescribeDomainRequest 

type DescribeDomainRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
}

func (*DescribeDomainRequest) Descriptor 

func (*DescribeDomainRequest) Descriptor() ([]byte, []int)

func (*DescribeDomainRequest) Equal 

func (this *DescribeDomainRequest) Equal(that interface{}) bool

func (*DescribeDomainRequest) GetName 

func (m *DescribeDomainRequest) GetName() string

func (*DescribeDomainRequest) GetUuid 

func (m *DescribeDomainRequest) GetUuid() string

func (*DescribeDomainRequest) GoString 

func (this *DescribeDomainRequest) GoString() string

func (*DescribeDomainRequest) Marshal 

func (m *DescribeDomainRequest) Marshal() (dAtA []byte, err error)

func (*DescribeDomainRequest) MarshalTo 

func (m *DescribeDomainRequest) MarshalTo(dAtA []byte) (int, error)

func (*DescribeDomainRequest) MarshalToSizedBuffer 

func (m *DescribeDomainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeDomainRequest) ProtoMessage 

func (*DescribeDomainRequest) ProtoMessage()

func (*DescribeDomainRequest) Reset 

func (m *DescribeDomainRequest) Reset()

func (*DescribeDomainRequest) Size 

func (m *DescribeDomainRequest) Size() (n int)

func (*DescribeDomainRequest) String 

func (this *DescribeDomainRequest) String() string

func (*DescribeDomainRequest) Unmarshal 

func (m *DescribeDomainRequest) Unmarshal(dAtA []byte) error

func (*DescribeDomainRequest) XXX_DiscardUnknown 

func (m *DescribeDomainRequest) XXX_DiscardUnknown()

func (*DescribeDomainRequest) XXX_Marshal 

func (m *DescribeDomainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeDomainRequest) XXX_Merge 

func (m *DescribeDomainRequest) XXX_Merge(src proto.Message)

func (*DescribeDomainRequest) XXX_Size 

func (m *DescribeDomainRequest) XXX_Size() int

func (*DescribeDomainRequest) XXX_Unmarshal 

func (m *DescribeDomainRequest) XXX_Unmarshal(b []byte) error

type DescribeDomainResponse 

type DescribeDomainResponse struct {
	DomainInfo               *common.DomainInfo                     `protobuf:"bytes,1,opt,name=domainInfo,proto3" json:"domainInfo,omitempty"`
	Configuration            *common.DomainConfiguration            `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"`
	ReplicationConfiguration *common.DomainReplicationConfiguration `protobuf:"bytes,3,opt,name=replicationConfiguration,proto3" json:"replicationConfiguration,omitempty"`
	FailoverVersion          int64                                  `protobuf:"varint,4,opt,name=failoverVersion,proto3" json:"failoverVersion,omitempty"`
	IsGlobalDomain           bool                                   `protobuf:"varint,5,opt,name=isGlobalDomain,proto3" json:"isGlobalDomain,omitempty"`
}

func (*DescribeDomainResponse) Descriptor 

func (*DescribeDomainResponse) Descriptor() ([]byte, []int)

func (*DescribeDomainResponse) Equal 

func (this *DescribeDomainResponse) Equal(that interface{}) bool

func (*DescribeDomainResponse) GetConfiguration 

func (m *DescribeDomainResponse) GetConfiguration() *common.DomainConfiguration

func (*DescribeDomainResponse) GetDomainInfo 

func (m *DescribeDomainResponse) GetDomainInfo() *common.DomainInfo

func (*DescribeDomainResponse) GetFailoverVersion 

func (m *DescribeDomainResponse) GetFailoverVersion() int64

func (*DescribeDomainResponse) GetIsGlobalDomain 

func (m *DescribeDomainResponse) GetIsGlobalDomain() bool

func (*DescribeDomainResponse) GetReplicationConfiguration 

func (m *DescribeDomainResponse) GetReplicationConfiguration() *common.DomainReplicationConfiguration

func (*DescribeDomainResponse) GoString 

func (this *DescribeDomainResponse) GoString() string

func (*DescribeDomainResponse) Marshal 

func (m *DescribeDomainResponse) Marshal() (dAtA []byte, err error)

func (*DescribeDomainResponse) MarshalTo 

func (m *DescribeDomainResponse) MarshalTo(dAtA []byte) (int, error)

func (*DescribeDomainResponse) MarshalToSizedBuffer 

func (m *DescribeDomainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeDomainResponse) ProtoMessage 

func (*DescribeDomainResponse) ProtoMessage()

func (*DescribeDomainResponse) Reset 

func (m *DescribeDomainResponse) Reset()

func (*DescribeDomainResponse) Size 

func (m *DescribeDomainResponse) Size() (n int)

func (*DescribeDomainResponse) String 

func (this *DescribeDomainResponse) String() string

func (*DescribeDomainResponse) Unmarshal 

func (m *DescribeDomainResponse) Unmarshal(dAtA []byte) error

func (*DescribeDomainResponse) XXX_DiscardUnknown 

func (m *DescribeDomainResponse) XXX_DiscardUnknown()

func (*DescribeDomainResponse) XXX_Marshal 

func (m *DescribeDomainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeDomainResponse) XXX_Merge 

func (m *DescribeDomainResponse) XXX_Merge(src proto.Message)

func (*DescribeDomainResponse) XXX_Size 

func (m *DescribeDomainResponse) XXX_Size() int

func (*DescribeDomainResponse) XXX_Unmarshal 

func (m *DescribeDomainResponse) XXX_Unmarshal(b []byte) error

type DescribeTaskListRequest 

type DescribeTaskListRequest struct {
	Domain                string             `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	TaskList              *common.TaskList   `protobuf:"bytes,2,opt,name=taskList,proto3" json:"taskList,omitempty"`
	TaskListType          enums.TaskListType `protobuf:"varint,3,opt,name=taskListType,proto3,enum=enums.TaskListType" json:"taskListType,omitempty"`
	IncludeTaskListStatus bool               `protobuf:"varint,4,opt,name=includeTaskListStatus,proto3" json:"includeTaskListStatus,omitempty"`
}

func (*DescribeTaskListRequest) Descriptor 

func (*DescribeTaskListRequest) Descriptor() ([]byte, []int)

func (*DescribeTaskListRequest) Equal 

func (this *DescribeTaskListRequest) Equal(that interface{}) bool

func (*DescribeTaskListRequest) GetDomain 

func (m *DescribeTaskListRequest) GetDomain() string

func (*DescribeTaskListRequest) GetIncludeTaskListStatus 

func (m *DescribeTaskListRequest) GetIncludeTaskListStatus() bool

func (*DescribeTaskListRequest) GetTaskList 

func (m *DescribeTaskListRequest) GetTaskList() *common.TaskList

func (*DescribeTaskListRequest) GetTaskListType 

func (m *DescribeTaskListRequest) GetTaskListType() enums.TaskListType

func (*DescribeTaskListRequest) GoString 

func (this *DescribeTaskListRequest) GoString() string

func (*DescribeTaskListRequest) Marshal 

func (m *DescribeTaskListRequest) Marshal() (dAtA []byte, err error)

func (*DescribeTaskListRequest) MarshalTo 

func (m *DescribeTaskListRequest) MarshalTo(dAtA []byte) (int, error)

func (*DescribeTaskListRequest) MarshalToSizedBuffer 

func (m *DescribeTaskListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeTaskListRequest) ProtoMessage 

func (*DescribeTaskListRequest) ProtoMessage()

func (*DescribeTaskListRequest) Reset 

func (m *DescribeTaskListRequest) Reset()

func (*DescribeTaskListRequest) Size 

func (m *DescribeTaskListRequest) Size() (n int)

func (*DescribeTaskListRequest) String 

func (this *DescribeTaskListRequest) String() string

func (*DescribeTaskListRequest) Unmarshal 

func (m *DescribeTaskListRequest) Unmarshal(dAtA []byte) error

func (*DescribeTaskListRequest) XXX_DiscardUnknown 

func (m *DescribeTaskListRequest) XXX_DiscardUnknown()

func (*DescribeTaskListRequest) XXX_Marshal 

func (m *DescribeTaskListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTaskListRequest) XXX_Merge 

func (m *DescribeTaskListRequest) XXX_Merge(src proto.Message)

func (*DescribeTaskListRequest) XXX_Size 

func (m *DescribeTaskListRequest) XXX_Size() int

func (*DescribeTaskListRequest) XXX_Unmarshal 

func (m *DescribeTaskListRequest) XXX_Unmarshal(b []byte) error

type DescribeTaskListResponse 

type DescribeTaskListResponse struct {
	Pollers        []*common.PollerInfo   `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskListStatus *common.TaskListStatus `protobuf:"bytes,2,opt,name=taskListStatus,proto3" json:"taskListStatus,omitempty"`
}

func (*DescribeTaskListResponse) Descriptor 

func (*DescribeTaskListResponse) Descriptor() ([]byte, []int)

func (*DescribeTaskListResponse) Equal 

func (this *DescribeTaskListResponse) Equal(that interface{}) bool

func (*DescribeTaskListResponse) GetPollers 

func (m *DescribeTaskListResponse) GetPollers() []*common.PollerInfo

func (*DescribeTaskListResponse) GetTaskListStatus 

func (m *DescribeTaskListResponse) GetTaskListStatus() *common.TaskListStatus

func (*DescribeTaskListResponse) GoString 

func (this *DescribeTaskListResponse) GoString() string

func (*DescribeTaskListResponse) Marshal 

func (m *DescribeTaskListResponse) Marshal() (dAtA []byte, err error)

func (*DescribeTaskListResponse) MarshalTo 

func (m *DescribeTaskListResponse) MarshalTo(dAtA []byte) (int, error)

func (*DescribeTaskListResponse) MarshalToSizedBuffer 

func (m *DescribeTaskListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeTaskListResponse) ProtoMessage 

func (*DescribeTaskListResponse) ProtoMessage()

func (*DescribeTaskListResponse) Reset 

func (m *DescribeTaskListResponse) Reset()

func (*DescribeTaskListResponse) Size 

func (m *DescribeTaskListResponse) Size() (n int)

func (*DescribeTaskListResponse) String 

func (this *DescribeTaskListResponse) String() string

func (*DescribeTaskListResponse) Unmarshal 

func (m *DescribeTaskListResponse) Unmarshal(dAtA []byte) error

func (*DescribeTaskListResponse) XXX_DiscardUnknown 

func (m *DescribeTaskListResponse) XXX_DiscardUnknown()

func (*DescribeTaskListResponse) XXX_Marshal 

func (m *DescribeTaskListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeTaskListResponse) XXX_Merge 

func (m *DescribeTaskListResponse) XXX_Merge(src proto.Message)

func (*DescribeTaskListResponse) XXX_Size 

func (m *DescribeTaskListResponse) XXX_Size() int

func (*DescribeTaskListResponse) XXX_Unmarshal 

func (m *DescribeTaskListResponse) XXX_Unmarshal(b []byte) error

type DescribeWorkflowExecutionRequest 

type DescribeWorkflowExecutionRequest struct {
	Domain    string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Execution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*DescribeWorkflowExecutionRequest) Descriptor 

func (*DescribeWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*DescribeWorkflowExecutionRequest) Equal 

func (this *DescribeWorkflowExecutionRequest) Equal(that interface{}) bool

func (*DescribeWorkflowExecutionRequest) GetDomain 

func (m *DescribeWorkflowExecutionRequest) GetDomain() string

func (*DescribeWorkflowExecutionRequest) GetExecution 

func (m *DescribeWorkflowExecutionRequest) GetExecution() *common.WorkflowExecution

func (*DescribeWorkflowExecutionRequest) GoString 

func (this *DescribeWorkflowExecutionRequest) GoString() string

func (*DescribeWorkflowExecutionRequest) Marshal 

func (m *DescribeWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*DescribeWorkflowExecutionRequest) MarshalTo 

func (m *DescribeWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*DescribeWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *DescribeWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeWorkflowExecutionRequest) ProtoMessage 

func (*DescribeWorkflowExecutionRequest) ProtoMessage()

func (*DescribeWorkflowExecutionRequest) Reset 

func (m *DescribeWorkflowExecutionRequest) Reset()

func (*DescribeWorkflowExecutionRequest) Size 

func (m *DescribeWorkflowExecutionRequest) Size() (n int)

func (*DescribeWorkflowExecutionRequest) String 

func (this *DescribeWorkflowExecutionRequest) String() string

func (*DescribeWorkflowExecutionRequest) Unmarshal 

func (m *DescribeWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*DescribeWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *DescribeWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionRequest) XXX_Marshal 

func (m *DescribeWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeWorkflowExecutionRequest) XXX_Merge 

func (m *DescribeWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*DescribeWorkflowExecutionRequest) XXX_Size 

func (m *DescribeWorkflowExecutionRequest) XXX_Size() int

func (*DescribeWorkflowExecutionRequest) XXX_Unmarshal 

func (m *DescribeWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type DescribeWorkflowExecutionResponse 

type DescribeWorkflowExecutionResponse struct {
	ExecutionConfiguration *common.WorkflowExecutionConfiguration `protobuf:"bytes,1,opt,name=executionConfiguration,proto3" json:"executionConfiguration,omitempty"`
	WorkflowExecutionInfo  *common.WorkflowExecutionInfo          `protobuf:"bytes,2,opt,name=workflowExecutionInfo,proto3" json:"workflowExecutionInfo,omitempty"`
	PendingActivities      []*common.PendingActivityInfo          `protobuf:"bytes,3,rep,name=pendingActivities,proto3" json:"pendingActivities,omitempty"`
	PendingChildren        []*common.PendingChildExecutionInfo    `protobuf:"bytes,4,rep,name=pendingChildren,proto3" json:"pendingChildren,omitempty"`
}

func (*DescribeWorkflowExecutionResponse) Descriptor 

func (*DescribeWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*DescribeWorkflowExecutionResponse) Equal 

func (this *DescribeWorkflowExecutionResponse) Equal(that interface{}) bool

func (*DescribeWorkflowExecutionResponse) GetExecutionConfiguration 

func (m *DescribeWorkflowExecutionResponse) GetExecutionConfiguration() *common.WorkflowExecutionConfiguration

func (*DescribeWorkflowExecutionResponse) GetPendingActivities 

func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*common.PendingActivityInfo

func (*DescribeWorkflowExecutionResponse) GetPendingChildren 

func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*common.PendingChildExecutionInfo

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo 

func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *common.WorkflowExecutionInfo

func (*DescribeWorkflowExecutionResponse) GoString 

func (this *DescribeWorkflowExecutionResponse) GoString() string

func (*DescribeWorkflowExecutionResponse) Marshal 

func (m *DescribeWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*DescribeWorkflowExecutionResponse) MarshalTo 

func (m *DescribeWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*DescribeWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *DescribeWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeWorkflowExecutionResponse) ProtoMessage 

func (*DescribeWorkflowExecutionResponse) ProtoMessage()

func (*DescribeWorkflowExecutionResponse) Reset 

func (m *DescribeWorkflowExecutionResponse) Reset()

func (*DescribeWorkflowExecutionResponse) Size 

func (m *DescribeWorkflowExecutionResponse) Size() (n int)

func (*DescribeWorkflowExecutionResponse) String 

func (this *DescribeWorkflowExecutionResponse) String() string

func (*DescribeWorkflowExecutionResponse) Unmarshal 

func (m *DescribeWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*DescribeWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionResponse) XXX_Marshal 

func (m *DescribeWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeWorkflowExecutionResponse) XXX_Merge 

func (m *DescribeWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*DescribeWorkflowExecutionResponse) XXX_Size 

func (m *DescribeWorkflowExecutionResponse) XXX_Size() int

func (*DescribeWorkflowExecutionResponse) XXX_Unmarshal 

func (m *DescribeWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type FxWorkflowServiceYARPCClientParams 

type FxWorkflowServiceYARPCClientParams struct {
	fx.In

	Provider    yarpc.ClientConfig
	AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"`
}

FxWorkflowServiceYARPCClientParams defines the input for NewFxWorkflowServiceYARPCClient. It provides the paramaters to get a WorkflowServiceYARPCClient in an Fx application.

type FxWorkflowServiceYARPCClientResult 

type FxWorkflowServiceYARPCClientResult struct {
	fx.Out

	Client WorkflowServiceYARPCClient
}

FxWorkflowServiceYARPCClientResult defines the output of NewFxWorkflowServiceYARPCClient. It provides a WorkflowServiceYARPCClient to an Fx application.

type FxWorkflowServiceYARPCProceduresParams 

type FxWorkflowServiceYARPCProceduresParams struct {
	fx.In

	Server      WorkflowServiceYARPCServer
	AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"`
}

FxWorkflowServiceYARPCProceduresParams defines the input for NewFxWorkflowServiceYARPCProcedures. It provides the paramaters to get WorkflowServiceYARPCServer procedures in an Fx application.

type FxWorkflowServiceYARPCProceduresResult 

type FxWorkflowServiceYARPCProceduresResult struct {
	fx.Out

	Procedures     []transport.Procedure `group:"yarpcfx"`
	ReflectionMeta reflection.ServerMeta `group:"yarpcfx"`
}

FxWorkflowServiceYARPCProceduresResult defines the output of NewFxWorkflowServiceYARPCProcedures. It provides WorkflowServiceYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type GetClusterInfoRequest 

type GetClusterInfoRequest struct {
}

func (*GetClusterInfoRequest) Descriptor 

func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)

func (*GetClusterInfoRequest) Equal 

func (this *GetClusterInfoRequest) Equal(that interface{}) bool

func (*GetClusterInfoRequest) GoString 

func (this *GetClusterInfoRequest) GoString() string

func (*GetClusterInfoRequest) Marshal 

func (m *GetClusterInfoRequest) Marshal() (dAtA []byte, err error)

func (*GetClusterInfoRequest) MarshalTo 

func (m *GetClusterInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetClusterInfoRequest) MarshalToSizedBuffer 

func (m *GetClusterInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) Reset 

func (m *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) Size 

func (m *GetClusterInfoRequest) Size() (n int)

func (*GetClusterInfoRequest) String 

func (this *GetClusterInfoRequest) String() string

func (*GetClusterInfoRequest) Unmarshal 

func (m *GetClusterInfoRequest) Unmarshal(dAtA []byte) error

func (*GetClusterInfoRequest) XXX_DiscardUnknown 

func (m *GetClusterInfoRequest) XXX_DiscardUnknown()

func (*GetClusterInfoRequest) XXX_Marshal 

func (m *GetClusterInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterInfoRequest) XXX_Merge 

func (m *GetClusterInfoRequest) XXX_Merge(src proto.Message)

func (*GetClusterInfoRequest) XXX_Size 

func (m *GetClusterInfoRequest) XXX_Size() int

func (*GetClusterInfoRequest) XXX_Unmarshal 

func (m *GetClusterInfoRequest) XXX_Unmarshal(b []byte) error

type GetClusterInfoResponse 

type GetClusterInfoResponse struct {
	SupportedClientVersions *common.SupportedClientVersions `protobuf:"bytes,1,opt,name=supportedClientVersions,proto3" json:"supportedClientVersions,omitempty"`
}

GetClusterInfoResponse contains information about Temporal cluster

func (*GetClusterInfoResponse) Descriptor 

func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)

func (*GetClusterInfoResponse) Equal 

func (this *GetClusterInfoResponse) Equal(that interface{}) bool

func (*GetClusterInfoResponse) GetSupportedClientVersions 

func (m *GetClusterInfoResponse) GetSupportedClientVersions() *common.SupportedClientVersions

func (*GetClusterInfoResponse) GoString 

func (this *GetClusterInfoResponse) GoString() string

func (*GetClusterInfoResponse) Marshal 

func (m *GetClusterInfoResponse) Marshal() (dAtA []byte, err error)

func (*GetClusterInfoResponse) MarshalTo 

func (m *GetClusterInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetClusterInfoResponse) MarshalToSizedBuffer 

func (m *GetClusterInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) Reset 

func (m *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) Size 

func (m *GetClusterInfoResponse) Size() (n int)

func (*GetClusterInfoResponse) String 

func (this *GetClusterInfoResponse) String() string

func (*GetClusterInfoResponse) Unmarshal 

func (m *GetClusterInfoResponse) Unmarshal(dAtA []byte) error

func (*GetClusterInfoResponse) XXX_DiscardUnknown 

func (m *GetClusterInfoResponse) XXX_DiscardUnknown()

func (*GetClusterInfoResponse) XXX_Marshal 

func (m *GetClusterInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterInfoResponse) XXX_Merge 

func (m *GetClusterInfoResponse) XXX_Merge(src proto.Message)

func (*GetClusterInfoResponse) XXX_Size 

func (m *GetClusterInfoResponse) XXX_Size() int

func (*GetClusterInfoResponse) XXX_Unmarshal 

func (m *GetClusterInfoResponse) XXX_Unmarshal(b []byte) error

type GetDomainReplicationMessagesRequest 

type GetDomainReplicationMessagesRequest struct {
	// lastRetrievedMessageId is where the next fetch should begin with.
	LastRetrievedMessageId int64 `protobuf:"varint,1,opt,name=lastRetrievedMessageId,proto3" json:"lastRetrievedMessageId,omitempty"`
	// lastProcessedMessageId is the last messageId that is processed on the passive side.
	// This can be different than lastRetrievedMessageId if passive side supports prefetching messages.
	LastProcessedMessageId int64 `protobuf:"varint,2,opt,name=lastProcessedMessageId,proto3" json:"lastProcessedMessageId,omitempty"`
	// clusterName is the name of the pulling cluster.
	ClusterName string `protobuf:"bytes,3,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
}

func (*GetDomainReplicationMessagesRequest) Descriptor 

func (*GetDomainReplicationMessagesRequest) Descriptor() ([]byte, []int)

func (*GetDomainReplicationMessagesRequest) Equal 

func (this *GetDomainReplicationMessagesRequest) Equal(that interface{}) bool

func (*GetDomainReplicationMessagesRequest) GetClusterName 

func (m *GetDomainReplicationMessagesRequest) GetClusterName() string

func (*GetDomainReplicationMessagesRequest) GetLastProcessedMessageId 

func (m *GetDomainReplicationMessagesRequest) GetLastProcessedMessageId() int64

func (*GetDomainReplicationMessagesRequest) GetLastRetrievedMessageId 

func (m *GetDomainReplicationMessagesRequest) GetLastRetrievedMessageId() int64

func (*GetDomainReplicationMessagesRequest) GoString 

func (this *GetDomainReplicationMessagesRequest) GoString() string

func (*GetDomainReplicationMessagesRequest) Marshal 

func (m *GetDomainReplicationMessagesRequest) Marshal() (dAtA []byte, err error)

func (*GetDomainReplicationMessagesRequest) MarshalTo 

func (m *GetDomainReplicationMessagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDomainReplicationMessagesRequest) MarshalToSizedBuffer 

func (m *GetDomainReplicationMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDomainReplicationMessagesRequest) ProtoMessage 

func (*GetDomainReplicationMessagesRequest) ProtoMessage()

func (*GetDomainReplicationMessagesRequest) Reset 

func (m *GetDomainReplicationMessagesRequest) Reset()

func (*GetDomainReplicationMessagesRequest) Size 

func (m *GetDomainReplicationMessagesRequest) Size() (n int)

func (*GetDomainReplicationMessagesRequest) String 

func (this *GetDomainReplicationMessagesRequest) String() string

func (*GetDomainReplicationMessagesRequest) Unmarshal 

func (m *GetDomainReplicationMessagesRequest) Unmarshal(dAtA []byte) error

func (*GetDomainReplicationMessagesRequest) XXX_DiscardUnknown 

func (m *GetDomainReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetDomainReplicationMessagesRequest) XXX_Marshal 

func (m *GetDomainReplicationMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDomainReplicationMessagesRequest) XXX_Merge 

func (m *GetDomainReplicationMessagesRequest) XXX_Merge(src proto.Message)

func (*GetDomainReplicationMessagesRequest) XXX_Size 

func (m *GetDomainReplicationMessagesRequest) XXX_Size() int

func (*GetDomainReplicationMessagesRequest) XXX_Unmarshal 

func (m *GetDomainReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

type GetDomainReplicationMessagesResponse 

type GetDomainReplicationMessagesResponse struct {
	Messages *common.ReplicationMessages `protobuf:"bytes,1,opt,name=messages,proto3" json:"messages,omitempty"`
}

func (*GetDomainReplicationMessagesResponse) Descriptor 

func (*GetDomainReplicationMessagesResponse) Descriptor() ([]byte, []int)

func (*GetDomainReplicationMessagesResponse) Equal 

func (this *GetDomainReplicationMessagesResponse) Equal(that interface{}) bool

func (*GetDomainReplicationMessagesResponse) GetMessages 

func (m *GetDomainReplicationMessagesResponse) GetMessages() *common.ReplicationMessages

func (*GetDomainReplicationMessagesResponse) GoString 

func (this *GetDomainReplicationMessagesResponse) GoString() string

func (*GetDomainReplicationMessagesResponse) Marshal 

func (m *GetDomainReplicationMessagesResponse) Marshal() (dAtA []byte, err error)

func (*GetDomainReplicationMessagesResponse) MarshalTo 

func (m *GetDomainReplicationMessagesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetDomainReplicationMessagesResponse) MarshalToSizedBuffer 

func (m *GetDomainReplicationMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDomainReplicationMessagesResponse) ProtoMessage 

func (*GetDomainReplicationMessagesResponse) ProtoMessage()

func (*GetDomainReplicationMessagesResponse) Reset 

func (m *GetDomainReplicationMessagesResponse) Reset()

func (*GetDomainReplicationMessagesResponse) Size 

func (m *GetDomainReplicationMessagesResponse) Size() (n int)

func (*GetDomainReplicationMessagesResponse) String 

func (this *GetDomainReplicationMessagesResponse) String() string

func (*GetDomainReplicationMessagesResponse) Unmarshal 

func (m *GetDomainReplicationMessagesResponse) Unmarshal(dAtA []byte) error

func (*GetDomainReplicationMessagesResponse) XXX_DiscardUnknown 

func (m *GetDomainReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetDomainReplicationMessagesResponse) XXX_Marshal 

func (m *GetDomainReplicationMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDomainReplicationMessagesResponse) XXX_Merge 

func (m *GetDomainReplicationMessagesResponse) XXX_Merge(src proto.Message)

func (*GetDomainReplicationMessagesResponse) XXX_Size 

func (m *GetDomainReplicationMessagesResponse) XXX_Size() int

func (*GetDomainReplicationMessagesResponse) XXX_Unmarshal 

func (m *GetDomainReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

type GetReplicationMessagesRequest 

type GetReplicationMessagesRequest struct {
	Tokens      []*common.ReplicationToken `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	ClusterName string                     `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"`
}

func (*GetReplicationMessagesRequest) Descriptor 

func (*GetReplicationMessagesRequest) Descriptor() ([]byte, []int)

func (*GetReplicationMessagesRequest) Equal 

func (this *GetReplicationMessagesRequest) Equal(that interface{}) bool

func (*GetReplicationMessagesRequest) GetClusterName 

func (m *GetReplicationMessagesRequest) GetClusterName() string

func (*GetReplicationMessagesRequest) GetTokens 

func (m *GetReplicationMessagesRequest) GetTokens() []*common.ReplicationToken

func (*GetReplicationMessagesRequest) GoString 

func (this *GetReplicationMessagesRequest) GoString() string

func (*GetReplicationMessagesRequest) Marshal 

func (m *GetReplicationMessagesRequest) Marshal() (dAtA []byte, err error)

func (*GetReplicationMessagesRequest) MarshalTo 

func (m *GetReplicationMessagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetReplicationMessagesRequest) MarshalToSizedBuffer 

func (m *GetReplicationMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetReplicationMessagesRequest) ProtoMessage 

func (*GetReplicationMessagesRequest) ProtoMessage()

func (*GetReplicationMessagesRequest) Reset 

func (m *GetReplicationMessagesRequest) Reset()

func (*GetReplicationMessagesRequest) Size 

func (m *GetReplicationMessagesRequest) Size() (n int)

func (*GetReplicationMessagesRequest) String 

func (this *GetReplicationMessagesRequest) String() string

func (*GetReplicationMessagesRequest) Unmarshal 

func (m *GetReplicationMessagesRequest) Unmarshal(dAtA []byte) error

func (*GetReplicationMessagesRequest) XXX_DiscardUnknown 

func (m *GetReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetReplicationMessagesRequest) XXX_Marshal 

func (m *GetReplicationMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetReplicationMessagesRequest) XXX_Merge 

func (m *GetReplicationMessagesRequest) XXX_Merge(src proto.Message)

func (*GetReplicationMessagesRequest) XXX_Size 

func (m *GetReplicationMessagesRequest) XXX_Size() int

func (*GetReplicationMessagesRequest) XXX_Unmarshal 

func (m *GetReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

type GetReplicationMessagesResponse 

type GetReplicationMessagesResponse struct {
	MessagesByShard map[int32]*common.ReplicationMessages `` /* 172-byte string literal not displayed */
}

func (*GetReplicationMessagesResponse) Descriptor 

func (*GetReplicationMessagesResponse) Descriptor() ([]byte, []int)

func (*GetReplicationMessagesResponse) Equal 

func (this *GetReplicationMessagesResponse) Equal(that interface{}) bool

func (*GetReplicationMessagesResponse) GetMessagesByShard 

func (m *GetReplicationMessagesResponse) GetMessagesByShard() map[int32]*common.ReplicationMessages

func (*GetReplicationMessagesResponse) GoString 

func (this *GetReplicationMessagesResponse) GoString() string

func (*GetReplicationMessagesResponse) Marshal 

func (m *GetReplicationMessagesResponse) Marshal() (dAtA []byte, err error)

func (*GetReplicationMessagesResponse) MarshalTo 

func (m *GetReplicationMessagesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetReplicationMessagesResponse) MarshalToSizedBuffer 

func (m *GetReplicationMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetReplicationMessagesResponse) ProtoMessage 

func (*GetReplicationMessagesResponse) ProtoMessage()

func (*GetReplicationMessagesResponse) Reset 

func (m *GetReplicationMessagesResponse) Reset()

func (*GetReplicationMessagesResponse) Size 

func (m *GetReplicationMessagesResponse) Size() (n int)

func (*GetReplicationMessagesResponse) String 

func (this *GetReplicationMessagesResponse) String() string

func (*GetReplicationMessagesResponse) Unmarshal 

func (m *GetReplicationMessagesResponse) Unmarshal(dAtA []byte) error

func (*GetReplicationMessagesResponse) XXX_DiscardUnknown 

func (m *GetReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetReplicationMessagesResponse) XXX_Marshal 

func (m *GetReplicationMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetReplicationMessagesResponse) XXX_Merge 

func (m *GetReplicationMessagesResponse) XXX_Merge(src proto.Message)

func (*GetReplicationMessagesResponse) XXX_Size 

func (m *GetReplicationMessagesResponse) XXX_Size() int

func (*GetReplicationMessagesResponse) XXX_Unmarshal 

func (m *GetReplicationMessagesResponse) XXX_Unmarshal(b []byte) error

type GetSearchAttributesRequest 

type GetSearchAttributesRequest struct {
}

func (*GetSearchAttributesRequest) Descriptor 

func (*GetSearchAttributesRequest) Descriptor() ([]byte, []int)

func (*GetSearchAttributesRequest) Equal 

func (this *GetSearchAttributesRequest) Equal(that interface{}) bool

func (*GetSearchAttributesRequest) GoString 

func (this *GetSearchAttributesRequest) GoString() string

func (*GetSearchAttributesRequest) Marshal 

func (m *GetSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*GetSearchAttributesRequest) MarshalTo 

func (m *GetSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetSearchAttributesRequest) MarshalToSizedBuffer 

func (m *GetSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSearchAttributesRequest) ProtoMessage 

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) Reset 

func (m *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) Size 

func (m *GetSearchAttributesRequest) Size() (n int)

func (*GetSearchAttributesRequest) String 

func (this *GetSearchAttributesRequest) String() string

func (*GetSearchAttributesRequest) Unmarshal 

func (m *GetSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*GetSearchAttributesRequest) XXX_DiscardUnknown 

func (m *GetSearchAttributesRequest) XXX_DiscardUnknown()

func (*GetSearchAttributesRequest) XXX_Marshal 

func (m *GetSearchAttributesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSearchAttributesRequest) XXX_Merge 

func (m *GetSearchAttributesRequest) XXX_Merge(src proto.Message)

func (*GetSearchAttributesRequest) XXX_Size 

func (m *GetSearchAttributesRequest) XXX_Size() int

func (*GetSearchAttributesRequest) XXX_Unmarshal 

func (m *GetSearchAttributesRequest) XXX_Unmarshal(b []byte) error

type GetSearchAttributesResponse 

type GetSearchAttributesResponse struct {
	Keys map[string]enums.IndexedValueType `` /* 178-byte string literal not displayed */
}

func (*GetSearchAttributesResponse) Descriptor 

func (*GetSearchAttributesResponse) Descriptor() ([]byte, []int)

func (*GetSearchAttributesResponse) Equal 

func (this *GetSearchAttributesResponse) Equal(that interface{}) bool

func (*GetSearchAttributesResponse) GetKeys 

func (m *GetSearchAttributesResponse) GetKeys() map[string]enums.IndexedValueType

func (*GetSearchAttributesResponse) GoString 

func (this *GetSearchAttributesResponse) GoString() string

func (*GetSearchAttributesResponse) Marshal 

func (m *GetSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*GetSearchAttributesResponse) MarshalTo 

func (m *GetSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetSearchAttributesResponse) MarshalToSizedBuffer 

func (m *GetSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSearchAttributesResponse) ProtoMessage 

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) Reset 

func (m *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) Size 

func (m *GetSearchAttributesResponse) Size() (n int)

func (*GetSearchAttributesResponse) String 

func (this *GetSearchAttributesResponse) String() string

func (*GetSearchAttributesResponse) Unmarshal 

func (m *GetSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*GetSearchAttributesResponse) XXX_DiscardUnknown 

func (m *GetSearchAttributesResponse) XXX_DiscardUnknown()

func (*GetSearchAttributesResponse) XXX_Marshal 

func (m *GetSearchAttributesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSearchAttributesResponse) XXX_Merge 

func (m *GetSearchAttributesResponse) XXX_Merge(src proto.Message)

func (*GetSearchAttributesResponse) XXX_Size 

func (m *GetSearchAttributesResponse) XXX_Size() int

func (*GetSearchAttributesResponse) XXX_Unmarshal 

func (m *GetSearchAttributesResponse) XXX_Unmarshal(b []byte) error

type GetWorkflowExecutionHistoryRequest 

type GetWorkflowExecutionHistoryRequest struct {
	Domain                 string                       `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Execution              *common.WorkflowExecution    `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	MaximumPageSize        int32                        `protobuf:"varint,3,opt,name=maximumPageSize,proto3" json:"maximumPageSize,omitempty"`
	NextPageToken          []byte                       `protobuf:"bytes,4,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	WaitForNewEvent        bool                         `protobuf:"varint,5,opt,name=waitForNewEvent,proto3" json:"waitForNewEvent,omitempty"`
	HistoryEventFilterType enums.HistoryEventFilterType `` /* 132-byte string literal not displayed */
}

func (*GetWorkflowExecutionHistoryRequest) Descriptor 

func (*GetWorkflowExecutionHistoryRequest) Descriptor() ([]byte, []int)

func (*GetWorkflowExecutionHistoryRequest) Equal 

func (this *GetWorkflowExecutionHistoryRequest) Equal(that interface{}) bool

func (*GetWorkflowExecutionHistoryRequest) GetDomain 

func (m *GetWorkflowExecutionHistoryRequest) GetDomain() string

func (*GetWorkflowExecutionHistoryRequest) GetExecution 

func (m *GetWorkflowExecutionHistoryRequest) GetExecution() *common.WorkflowExecution

func (*GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType 

func (m *GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType() enums.HistoryEventFilterType

func (*GetWorkflowExecutionHistoryRequest) GetMaximumPageSize 

func (m *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryRequest) GetNextPageToken 

func (m *GetWorkflowExecutionHistoryRequest) GetNextPageToken() []byte

func (*GetWorkflowExecutionHistoryRequest) GetWaitForNewEvent 

func (m *GetWorkflowExecutionHistoryRequest) GetWaitForNewEvent() bool

func (*GetWorkflowExecutionHistoryRequest) GoString 

func (this *GetWorkflowExecutionHistoryRequest) GoString() string

func (*GetWorkflowExecutionHistoryRequest) Marshal 

func (m *GetWorkflowExecutionHistoryRequest) Marshal() (dAtA []byte, err error)

func (*GetWorkflowExecutionHistoryRequest) MarshalTo 

func (m *GetWorkflowExecutionHistoryRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowExecutionHistoryRequest) MarshalToSizedBuffer 

func (m *GetWorkflowExecutionHistoryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage 

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

func (*GetWorkflowExecutionHistoryRequest) Reset 

func (m *GetWorkflowExecutionHistoryRequest) Reset()

func (*GetWorkflowExecutionHistoryRequest) Size 

func (m *GetWorkflowExecutionHistoryRequest) Size() (n int)

func (*GetWorkflowExecutionHistoryRequest) String 

func (this *GetWorkflowExecutionHistoryRequest) String() string

func (*GetWorkflowExecutionHistoryRequest) Unmarshal 

func (m *GetWorkflowExecutionHistoryRequest) Unmarshal(dAtA []byte) error

func (*GetWorkflowExecutionHistoryRequest) XXX_DiscardUnknown 

func (m *GetWorkflowExecutionHistoryRequest) XXX_DiscardUnknown()

func (*GetWorkflowExecutionHistoryRequest) XXX_Marshal 

func (m *GetWorkflowExecutionHistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkflowExecutionHistoryRequest) XXX_Merge 

func (m *GetWorkflowExecutionHistoryRequest) XXX_Merge(src proto.Message)

func (*GetWorkflowExecutionHistoryRequest) XXX_Size 

func (m *GetWorkflowExecutionHistoryRequest) XXX_Size() int

func (*GetWorkflowExecutionHistoryRequest) XXX_Unmarshal 

func (m *GetWorkflowExecutionHistoryRequest) XXX_Unmarshal(b []byte) error

type GetWorkflowExecutionHistoryResponse 

type GetWorkflowExecutionHistoryResponse struct {
	History       *common.History `protobuf:"bytes,1,opt,name=history,proto3" json:"history,omitempty"`
	NextPageToken []byte          `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	Archived      bool            `protobuf:"varint,3,opt,name=archived,proto3" json:"archived,omitempty"`
}

func (*GetWorkflowExecutionHistoryResponse) Descriptor 

func (*GetWorkflowExecutionHistoryResponse) Descriptor() ([]byte, []int)

func (*GetWorkflowExecutionHistoryResponse) Equal 

func (this *GetWorkflowExecutionHistoryResponse) Equal(that interface{}) bool

func (*GetWorkflowExecutionHistoryResponse) GetArchived 

func (m *GetWorkflowExecutionHistoryResponse) GetArchived() bool

func (*GetWorkflowExecutionHistoryResponse) GetHistory 

func (m *GetWorkflowExecutionHistoryResponse) GetHistory() *common.History

func (*GetWorkflowExecutionHistoryResponse) GetNextPageToken 

func (m *GetWorkflowExecutionHistoryResponse) GetNextPageToken() []byte

func (*GetWorkflowExecutionHistoryResponse) GoString 

func (this *GetWorkflowExecutionHistoryResponse) GoString() string

func (*GetWorkflowExecutionHistoryResponse) Marshal 

func (m *GetWorkflowExecutionHistoryResponse) Marshal() (dAtA []byte, err error)

func (*GetWorkflowExecutionHistoryResponse) MarshalTo 

func (m *GetWorkflowExecutionHistoryResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetWorkflowExecutionHistoryResponse) MarshalToSizedBuffer 

func (m *GetWorkflowExecutionHistoryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetWorkflowExecutionHistoryResponse) ProtoMessage 

func (*GetWorkflowExecutionHistoryResponse) ProtoMessage()

func (*GetWorkflowExecutionHistoryResponse) Reset 

func (m *GetWorkflowExecutionHistoryResponse) Reset()

func (*GetWorkflowExecutionHistoryResponse) Size 

func (m *GetWorkflowExecutionHistoryResponse) Size() (n int)

func (*GetWorkflowExecutionHistoryResponse) String 

func (this *GetWorkflowExecutionHistoryResponse) String() string

func (*GetWorkflowExecutionHistoryResponse) Unmarshal 

func (m *GetWorkflowExecutionHistoryResponse) Unmarshal(dAtA []byte) error

func (*GetWorkflowExecutionHistoryResponse) XXX_DiscardUnknown 

func (m *GetWorkflowExecutionHistoryResponse) XXX_DiscardUnknown()

func (*GetWorkflowExecutionHistoryResponse) XXX_Marshal 

func (m *GetWorkflowExecutionHistoryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkflowExecutionHistoryResponse) XXX_Merge 

func (m *GetWorkflowExecutionHistoryResponse) XXX_Merge(src proto.Message)

func (*GetWorkflowExecutionHistoryResponse) XXX_Size 

func (m *GetWorkflowExecutionHistoryResponse) XXX_Size() int

func (*GetWorkflowExecutionHistoryResponse) XXX_Unmarshal 

func (m *GetWorkflowExecutionHistoryResponse) XXX_Unmarshal(b []byte) error

type ListArchivedWorkflowExecutionsRequest 

type ListArchivedWorkflowExecutionsRequest struct {
	Domain        string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	Query         string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
}

func (*ListArchivedWorkflowExecutionsRequest) Descriptor 

func (*ListArchivedWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

func (*ListArchivedWorkflowExecutionsRequest) Equal 

func (this *ListArchivedWorkflowExecutionsRequest) Equal(that interface{}) bool

func (*ListArchivedWorkflowExecutionsRequest) GetDomain 

func (m *ListArchivedWorkflowExecutionsRequest) GetDomain() string

func (*ListArchivedWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListArchivedWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListArchivedWorkflowExecutionsRequest) GetPageSize 

func (m *ListArchivedWorkflowExecutionsRequest) GetPageSize() int32

func (*ListArchivedWorkflowExecutionsRequest) GetQuery 

func (m *ListArchivedWorkflowExecutionsRequest) GetQuery() string

func (*ListArchivedWorkflowExecutionsRequest) GoString 

func (this *ListArchivedWorkflowExecutionsRequest) GoString() string

func (*ListArchivedWorkflowExecutionsRequest) Marshal 

func (m *ListArchivedWorkflowExecutionsRequest) Marshal() (dAtA []byte, err error)

func (*ListArchivedWorkflowExecutionsRequest) MarshalTo 

func (m *ListArchivedWorkflowExecutionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListArchivedWorkflowExecutionsRequest) MarshalToSizedBuffer 

func (m *ListArchivedWorkflowExecutionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage 

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage()

func (*ListArchivedWorkflowExecutionsRequest) Reset 

func (m *ListArchivedWorkflowExecutionsRequest) Reset()

func (*ListArchivedWorkflowExecutionsRequest) Size 

func (m *ListArchivedWorkflowExecutionsRequest) Size() (n int)

func (*ListArchivedWorkflowExecutionsRequest) String 

func (this *ListArchivedWorkflowExecutionsRequest) String() string

func (*ListArchivedWorkflowExecutionsRequest) Unmarshal 

func (m *ListArchivedWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

func (*ListArchivedWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowExecutionsRequest) XXX_Marshal 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListArchivedWorkflowExecutionsRequest) XXX_Merge 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

func (*ListArchivedWorkflowExecutionsRequest) XXX_Size 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_Size() int

func (*ListArchivedWorkflowExecutionsRequest) XXX_Unmarshal 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

type ListArchivedWorkflowExecutionsResponse 

type ListArchivedWorkflowExecutionsResponse struct {
	Executions    []*common.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                          `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ListArchivedWorkflowExecutionsResponse) Descriptor 

func (*ListArchivedWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

func (*ListArchivedWorkflowExecutionsResponse) Equal 

func (this *ListArchivedWorkflowExecutionsResponse) Equal(that interface{}) bool

func (*ListArchivedWorkflowExecutionsResponse) GetExecutions 

func (m *ListArchivedWorkflowExecutionsResponse) GetExecutions() []*common.WorkflowExecutionInfo

func (*ListArchivedWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListArchivedWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListArchivedWorkflowExecutionsResponse) GoString 

func (this *ListArchivedWorkflowExecutionsResponse) GoString() string

func (*ListArchivedWorkflowExecutionsResponse) Marshal 

func (m *ListArchivedWorkflowExecutionsResponse) Marshal() (dAtA []byte, err error)

func (*ListArchivedWorkflowExecutionsResponse) MarshalTo 

func (m *ListArchivedWorkflowExecutionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListArchivedWorkflowExecutionsResponse) MarshalToSizedBuffer 

func (m *ListArchivedWorkflowExecutionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage 

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage()

func (*ListArchivedWorkflowExecutionsResponse) Reset 

func (m *ListArchivedWorkflowExecutionsResponse) Reset()

func (*ListArchivedWorkflowExecutionsResponse) Size 

func (m *ListArchivedWorkflowExecutionsResponse) Size() (n int)

func (*ListArchivedWorkflowExecutionsResponse) String 

func (this *ListArchivedWorkflowExecutionsResponse) String() string

func (*ListArchivedWorkflowExecutionsResponse) Unmarshal 

func (m *ListArchivedWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

func (*ListArchivedWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListArchivedWorkflowExecutionsResponse) XXX_Marshal 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListArchivedWorkflowExecutionsResponse) XXX_Merge 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

func (*ListArchivedWorkflowExecutionsResponse) XXX_Size 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_Size() int

func (*ListArchivedWorkflowExecutionsResponse) XXX_Unmarshal 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

type ListClosedWorkflowExecutionsRequest 

type ListClosedWorkflowExecutionsRequest struct {
	Domain          string                  `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	MaximumPageSize int32                   `protobuf:"varint,2,opt,name=maximumPageSize,proto3" json:"maximumPageSize,omitempty"`
	NextPageToken   []byte                  `protobuf:"bytes,3,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	StartTimeFilter *common.StartTimeFilter `protobuf:"bytes,4,opt,name=StartTimeFilter,proto3" json:"StartTimeFilter,omitempty"`
	// Types that are valid to be assigned to Filters:
	//	*ListClosedWorkflowExecutionsRequest_ExecutionFilter
	//	*ListClosedWorkflowExecutionsRequest_TypeFilter
	//	*ListClosedWorkflowExecutionsRequest_StatusFilter
	Filters isListClosedWorkflowExecutionsRequest_Filters `protobuf_oneof:"Filters"`
}

func (*ListClosedWorkflowExecutionsRequest) Descriptor 

func (*ListClosedWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

func (*ListClosedWorkflowExecutionsRequest) Equal 

func (this *ListClosedWorkflowExecutionsRequest) Equal(that interface{}) bool

func (*ListClosedWorkflowExecutionsRequest) GetDomain 

func (m *ListClosedWorkflowExecutionsRequest) GetDomain() string

func (*ListClosedWorkflowExecutionsRequest) GetExecutionFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetExecutionFilter() *common.WorkflowExecutionFilter

func (*ListClosedWorkflowExecutionsRequest) GetFilters 

func (m *ListClosedWorkflowExecutionsRequest) GetFilters() isListClosedWorkflowExecutionsRequest_Filters

func (*ListClosedWorkflowExecutionsRequest) GetMaximumPageSize 

func (m *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() int32

func (*ListClosedWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListClosedWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListClosedWorkflowExecutionsRequest) GetStartTimeFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetStartTimeFilter() *common.StartTimeFilter

func (*ListClosedWorkflowExecutionsRequest) GetStatusFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetStatusFilter() *common.StatusFilter

func (*ListClosedWorkflowExecutionsRequest) GetTypeFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetTypeFilter() *common.WorkflowTypeFilter

func (*ListClosedWorkflowExecutionsRequest) GoString 

func (this *ListClosedWorkflowExecutionsRequest) GoString() string

func (*ListClosedWorkflowExecutionsRequest) Marshal 

func (m *ListClosedWorkflowExecutionsRequest) Marshal() (dAtA []byte, err error)

func (*ListClosedWorkflowExecutionsRequest) MarshalTo 

func (m *ListClosedWorkflowExecutionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest) MarshalToSizedBuffer 

func (m *ListClosedWorkflowExecutionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage 

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage()

func (*ListClosedWorkflowExecutionsRequest) Reset 

func (m *ListClosedWorkflowExecutionsRequest) Reset()

func (*ListClosedWorkflowExecutionsRequest) Size 

func (m *ListClosedWorkflowExecutionsRequest) Size() (n int)

func (*ListClosedWorkflowExecutionsRequest) String 

func (this *ListClosedWorkflowExecutionsRequest) String() string

func (*ListClosedWorkflowExecutionsRequest) Unmarshal 

func (m *ListClosedWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

func (*ListClosedWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListClosedWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListClosedWorkflowExecutionsRequest) XXX_Marshal 

func (m *ListClosedWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListClosedWorkflowExecutionsRequest) XXX_Merge 

func (m *ListClosedWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

func (*ListClosedWorkflowExecutionsRequest) XXX_OneofWrappers 

func (*ListClosedWorkflowExecutionsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ListClosedWorkflowExecutionsRequest) XXX_Size 

func (m *ListClosedWorkflowExecutionsRequest) XXX_Size() int

func (*ListClosedWorkflowExecutionsRequest) XXX_Unmarshal 

func (m *ListClosedWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

type ListClosedWorkflowExecutionsRequest_ExecutionFilter 

type ListClosedWorkflowExecutionsRequest_ExecutionFilter struct {
	ExecutionFilter *common.WorkflowExecutionFilter `protobuf:"bytes,5,opt,name=executionFilter,proto3,oneof" json:"executionFilter,omitempty"`
}

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) Equal 

func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) Equal(that interface{}) bool

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) GoString 

func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) GoString() string

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalTo 

func (m *ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalTo(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer 

func (m *ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) Size 

func (m *ListClosedWorkflowExecutionsRequest_ExecutionFilter) Size() (n int)

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) String 

func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) String() string

type ListClosedWorkflowExecutionsRequest_StatusFilter 

type ListClosedWorkflowExecutionsRequest_StatusFilter struct {
	StatusFilter *common.StatusFilter `protobuf:"bytes,7,opt,name=statusFilter,proto3,oneof" json:"statusFilter,omitempty"`
}

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) Equal 

func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) Equal(that interface{}) bool

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) GoString 

func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) GoString() string

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalTo 

func (m *ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalTo(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalToSizedBuffer 

func (m *ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) Size 

func (m *ListClosedWorkflowExecutionsRequest_StatusFilter) Size() (n int)

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) String 

func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) String() string

type ListClosedWorkflowExecutionsRequest_TypeFilter 

type ListClosedWorkflowExecutionsRequest_TypeFilter struct {
	TypeFilter *common.WorkflowTypeFilter `protobuf:"bytes,6,opt,name=typeFilter,proto3,oneof" json:"typeFilter,omitempty"`
}

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) Equal 

func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) Equal(that interface{}) bool

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) GoString 

func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) GoString() string

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalTo 

func (m *ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalTo(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer 

func (m *ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) Size 

func (m *ListClosedWorkflowExecutionsRequest_TypeFilter) Size() (n int)

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) String 

func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) String() string

type ListClosedWorkflowExecutionsResponse 

type ListClosedWorkflowExecutionsResponse struct {
	Executions    []*common.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                          `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ListClosedWorkflowExecutionsResponse) Descriptor 

func (*ListClosedWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

func (*ListClosedWorkflowExecutionsResponse) Equal 

func (this *ListClosedWorkflowExecutionsResponse) Equal(that interface{}) bool

func (*ListClosedWorkflowExecutionsResponse) GetExecutions 

func (m *ListClosedWorkflowExecutionsResponse) GetExecutions() []*common.WorkflowExecutionInfo

func (*ListClosedWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListClosedWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListClosedWorkflowExecutionsResponse) GoString 

func (this *ListClosedWorkflowExecutionsResponse) GoString() string

func (*ListClosedWorkflowExecutionsResponse) Marshal 

func (m *ListClosedWorkflowExecutionsResponse) Marshal() (dAtA []byte, err error)

func (*ListClosedWorkflowExecutionsResponse) MarshalTo 

func (m *ListClosedWorkflowExecutionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsResponse) MarshalToSizedBuffer 

func (m *ListClosedWorkflowExecutionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage 

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage()

func (*ListClosedWorkflowExecutionsResponse) Reset 

func (m *ListClosedWorkflowExecutionsResponse) Reset()

func (*ListClosedWorkflowExecutionsResponse) Size 

func (m *ListClosedWorkflowExecutionsResponse) Size() (n int)

func (*ListClosedWorkflowExecutionsResponse) String 

func (this *ListClosedWorkflowExecutionsResponse) String() string

func (*ListClosedWorkflowExecutionsResponse) Unmarshal 

func (m *ListClosedWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

func (*ListClosedWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListClosedWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListClosedWorkflowExecutionsResponse) XXX_Marshal 

func (m *ListClosedWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListClosedWorkflowExecutionsResponse) XXX_Merge 

func (m *ListClosedWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

func (*ListClosedWorkflowExecutionsResponse) XXX_Size 

func (m *ListClosedWorkflowExecutionsResponse) XXX_Size() int

func (*ListClosedWorkflowExecutionsResponse) XXX_Unmarshal 

func (m *ListClosedWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

type ListDomainsRequest 

type ListDomainsRequest struct {
	PageSize      int32  `protobuf:"varint,1,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	NextPageToken []byte `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ListDomainsRequest) Descriptor 

func (*ListDomainsRequest) Descriptor() ([]byte, []int)

func (*ListDomainsRequest) Equal 

func (this *ListDomainsRequest) Equal(that interface{}) bool

func (*ListDomainsRequest) GetNextPageToken 

func (m *ListDomainsRequest) GetNextPageToken() []byte

func (*ListDomainsRequest) GetPageSize 

func (m *ListDomainsRequest) GetPageSize() int32

func (*ListDomainsRequest) GoString 

func (this *ListDomainsRequest) GoString() string

func (*ListDomainsRequest) Marshal 

func (m *ListDomainsRequest) Marshal() (dAtA []byte, err error)

func (*ListDomainsRequest) MarshalTo 

func (m *ListDomainsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListDomainsRequest) MarshalToSizedBuffer 

func (m *ListDomainsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListDomainsRequest) ProtoMessage 

func (*ListDomainsRequest) ProtoMessage()

func (*ListDomainsRequest) Reset 

func (m *ListDomainsRequest) Reset()

func (*ListDomainsRequest) Size 

func (m *ListDomainsRequest) Size() (n int)

func (*ListDomainsRequest) String 

func (this *ListDomainsRequest) String() string

func (*ListDomainsRequest) Unmarshal 

func (m *ListDomainsRequest) Unmarshal(dAtA []byte) error

func (*ListDomainsRequest) XXX_DiscardUnknown 

func (m *ListDomainsRequest) XXX_DiscardUnknown()

func (*ListDomainsRequest) XXX_Marshal 

func (m *ListDomainsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDomainsRequest) XXX_Merge 

func (m *ListDomainsRequest) XXX_Merge(src proto.Message)

func (*ListDomainsRequest) XXX_Size 

func (m *ListDomainsRequest) XXX_Size() int

func (*ListDomainsRequest) XXX_Unmarshal 

func (m *ListDomainsRequest) XXX_Unmarshal(b []byte) error

type ListDomainsResponse 

type ListDomainsResponse struct {
	Domains       []*DescribeDomainResponse `protobuf:"bytes,1,rep,name=domains,proto3" json:"domains,omitempty"`
	NextPageToken []byte                    `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ListDomainsResponse) Descriptor 

func (*ListDomainsResponse) Descriptor() ([]byte, []int)

func (*ListDomainsResponse) Equal 

func (this *ListDomainsResponse) Equal(that interface{}) bool

func (*ListDomainsResponse) GetDomains 

func (m *ListDomainsResponse) GetDomains() []*DescribeDomainResponse

func (*ListDomainsResponse) GetNextPageToken 

func (m *ListDomainsResponse) GetNextPageToken() []byte

func (*ListDomainsResponse) GoString 

func (this *ListDomainsResponse) GoString() string

func (*ListDomainsResponse) Marshal 

func (m *ListDomainsResponse) Marshal() (dAtA []byte, err error)

func (*ListDomainsResponse) MarshalTo 

func (m *ListDomainsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListDomainsResponse) MarshalToSizedBuffer 

func (m *ListDomainsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListDomainsResponse) ProtoMessage 

func (*ListDomainsResponse) ProtoMessage()

func (*ListDomainsResponse) Reset 

func (m *ListDomainsResponse) Reset()

func (*ListDomainsResponse) Size 

func (m *ListDomainsResponse) Size() (n int)

func (*ListDomainsResponse) String 

func (this *ListDomainsResponse) String() string

func (*ListDomainsResponse) Unmarshal 

func (m *ListDomainsResponse) Unmarshal(dAtA []byte) error

func (*ListDomainsResponse) XXX_DiscardUnknown 

func (m *ListDomainsResponse) XXX_DiscardUnknown()

func (*ListDomainsResponse) XXX_Marshal 

func (m *ListDomainsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListDomainsResponse) XXX_Merge 

func (m *ListDomainsResponse) XXX_Merge(src proto.Message)

func (*ListDomainsResponse) XXX_Size 

func (m *ListDomainsResponse) XXX_Size() int

func (*ListDomainsResponse) XXX_Unmarshal 

func (m *ListDomainsResponse) XXX_Unmarshal(b []byte) error

type ListOpenWorkflowExecutionsRequest 

type ListOpenWorkflowExecutionsRequest struct {
	Domain          string                  `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	MaximumPageSize int32                   `protobuf:"varint,2,opt,name=maximumPageSize,proto3" json:"maximumPageSize,omitempty"`
	NextPageToken   []byte                  `protobuf:"bytes,3,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	StartTimeFilter *common.StartTimeFilter `protobuf:"bytes,4,opt,name=StartTimeFilter,proto3" json:"StartTimeFilter,omitempty"`
	// Types that are valid to be assigned to Filters:
	//	*ListOpenWorkflowExecutionsRequest_ExecutionFilter
	//	*ListOpenWorkflowExecutionsRequest_TypeFilter
	Filters isListOpenWorkflowExecutionsRequest_Filters `protobuf_oneof:"Filters"`
}

func (*ListOpenWorkflowExecutionsRequest) Descriptor 

func (*ListOpenWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

func (*ListOpenWorkflowExecutionsRequest) Equal 

func (this *ListOpenWorkflowExecutionsRequest) Equal(that interface{}) bool

func (*ListOpenWorkflowExecutionsRequest) GetDomain 

func (m *ListOpenWorkflowExecutionsRequest) GetDomain() string

func (*ListOpenWorkflowExecutionsRequest) GetExecutionFilter 

func (m *ListOpenWorkflowExecutionsRequest) GetExecutionFilter() *common.WorkflowExecutionFilter

func (*ListOpenWorkflowExecutionsRequest) GetFilters 

func (m *ListOpenWorkflowExecutionsRequest) GetFilters() isListOpenWorkflowExecutionsRequest_Filters

func (*ListOpenWorkflowExecutionsRequest) GetMaximumPageSize 

func (m *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() int32

func (*ListOpenWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListOpenWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListOpenWorkflowExecutionsRequest) GetStartTimeFilter 

func (m *ListOpenWorkflowExecutionsRequest) GetStartTimeFilter() *common.StartTimeFilter

func (*ListOpenWorkflowExecutionsRequest) GetTypeFilter 

func (m *ListOpenWorkflowExecutionsRequest) GetTypeFilter() *common.WorkflowTypeFilter

func (*ListOpenWorkflowExecutionsRequest) GoString 

func (this *ListOpenWorkflowExecutionsRequest) GoString() string

func (*ListOpenWorkflowExecutionsRequest) Marshal 

func (m *ListOpenWorkflowExecutionsRequest) Marshal() (dAtA []byte, err error)

func (*ListOpenWorkflowExecutionsRequest) MarshalTo 

func (m *ListOpenWorkflowExecutionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsRequest) MarshalToSizedBuffer 

func (m *ListOpenWorkflowExecutionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage 

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage()

func (*ListOpenWorkflowExecutionsRequest) Reset 

func (m *ListOpenWorkflowExecutionsRequest) Reset()

func (*ListOpenWorkflowExecutionsRequest) Size 

func (m *ListOpenWorkflowExecutionsRequest) Size() (n int)

func (*ListOpenWorkflowExecutionsRequest) String 

func (this *ListOpenWorkflowExecutionsRequest) String() string

func (*ListOpenWorkflowExecutionsRequest) Unmarshal 

func (m *ListOpenWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

func (*ListOpenWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListOpenWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListOpenWorkflowExecutionsRequest) XXX_Marshal 

func (m *ListOpenWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListOpenWorkflowExecutionsRequest) XXX_Merge 

func (m *ListOpenWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

func (*ListOpenWorkflowExecutionsRequest) XXX_OneofWrappers 

func (*ListOpenWorkflowExecutionsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ListOpenWorkflowExecutionsRequest) XXX_Size 

func (m *ListOpenWorkflowExecutionsRequest) XXX_Size() int

func (*ListOpenWorkflowExecutionsRequest) XXX_Unmarshal 

func (m *ListOpenWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

type ListOpenWorkflowExecutionsRequest_ExecutionFilter 

type ListOpenWorkflowExecutionsRequest_ExecutionFilter struct {
	ExecutionFilter *common.WorkflowExecutionFilter `protobuf:"bytes,5,opt,name=executionFilter,proto3,oneof" json:"executionFilter,omitempty"`
}

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) Equal 

func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) Equal(that interface{}) bool

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) GoString 

func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) GoString() string

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalTo 

func (m *ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalTo(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer 

func (m *ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) Size 

func (m *ListOpenWorkflowExecutionsRequest_ExecutionFilter) Size() (n int)

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) String 

func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) String() string

type ListOpenWorkflowExecutionsRequest_TypeFilter 

type ListOpenWorkflowExecutionsRequest_TypeFilter struct {
	TypeFilter *common.WorkflowTypeFilter `protobuf:"bytes,6,opt,name=typeFilter,proto3,oneof" json:"typeFilter,omitempty"`
}

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) Equal 

func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) Equal(that interface{}) bool

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) GoString 

func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) GoString() string

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalTo 

func (m *ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalTo(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer 

func (m *ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) Size 

func (m *ListOpenWorkflowExecutionsRequest_TypeFilter) Size() (n int)

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) String 

func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) String() string

type ListOpenWorkflowExecutionsResponse 

type ListOpenWorkflowExecutionsResponse struct {
	Executions    []*common.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                          `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ListOpenWorkflowExecutionsResponse) Descriptor 

func (*ListOpenWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

func (*ListOpenWorkflowExecutionsResponse) Equal 

func (this *ListOpenWorkflowExecutionsResponse) Equal(that interface{}) bool

func (*ListOpenWorkflowExecutionsResponse) GetExecutions 

func (m *ListOpenWorkflowExecutionsResponse) GetExecutions() []*common.WorkflowExecutionInfo

func (*ListOpenWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListOpenWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListOpenWorkflowExecutionsResponse) GoString 

func (this *ListOpenWorkflowExecutionsResponse) GoString() string

func (*ListOpenWorkflowExecutionsResponse) Marshal 

func (m *ListOpenWorkflowExecutionsResponse) Marshal() (dAtA []byte, err error)

func (*ListOpenWorkflowExecutionsResponse) MarshalTo 

func (m *ListOpenWorkflowExecutionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsResponse) MarshalToSizedBuffer 

func (m *ListOpenWorkflowExecutionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage 

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage()

func (*ListOpenWorkflowExecutionsResponse) Reset 

func (m *ListOpenWorkflowExecutionsResponse) Reset()

func (*ListOpenWorkflowExecutionsResponse) Size 

func (m *ListOpenWorkflowExecutionsResponse) Size() (n int)

func (*ListOpenWorkflowExecutionsResponse) String 

func (this *ListOpenWorkflowExecutionsResponse) String() string

func (*ListOpenWorkflowExecutionsResponse) Unmarshal 

func (m *ListOpenWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

func (*ListOpenWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListOpenWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListOpenWorkflowExecutionsResponse) XXX_Marshal 

func (m *ListOpenWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListOpenWorkflowExecutionsResponse) XXX_Merge 

func (m *ListOpenWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

func (*ListOpenWorkflowExecutionsResponse) XXX_Size 

func (m *ListOpenWorkflowExecutionsResponse) XXX_Size() int

func (*ListOpenWorkflowExecutionsResponse) XXX_Unmarshal 

func (m *ListOpenWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

type ListTaskListPartitionsRequest 

type ListTaskListPartitionsRequest struct {
	Domain   string           `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	TaskList *common.TaskList `protobuf:"bytes,2,opt,name=taskList,proto3" json:"taskList,omitempty"`
}

func (*ListTaskListPartitionsRequest) Descriptor 

func (*ListTaskListPartitionsRequest) Descriptor() ([]byte, []int)

func (*ListTaskListPartitionsRequest) Equal 

func (this *ListTaskListPartitionsRequest) Equal(that interface{}) bool

func (*ListTaskListPartitionsRequest) GetDomain 

func (m *ListTaskListPartitionsRequest) GetDomain() string

func (*ListTaskListPartitionsRequest) GetTaskList 

func (m *ListTaskListPartitionsRequest) GetTaskList() *common.TaskList

func (*ListTaskListPartitionsRequest) GoString 

func (this *ListTaskListPartitionsRequest) GoString() string

func (*ListTaskListPartitionsRequest) Marshal 

func (m *ListTaskListPartitionsRequest) Marshal() (dAtA []byte, err error)

func (*ListTaskListPartitionsRequest) MarshalTo 

func (m *ListTaskListPartitionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListTaskListPartitionsRequest) MarshalToSizedBuffer 

func (m *ListTaskListPartitionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTaskListPartitionsRequest) ProtoMessage 

func (*ListTaskListPartitionsRequest) ProtoMessage()

func (*ListTaskListPartitionsRequest) Reset 

func (m *ListTaskListPartitionsRequest) Reset()

func (*ListTaskListPartitionsRequest) Size 

func (m *ListTaskListPartitionsRequest) Size() (n int)

func (*ListTaskListPartitionsRequest) String 

func (this *ListTaskListPartitionsRequest) String() string

func (*ListTaskListPartitionsRequest) Unmarshal 

func (m *ListTaskListPartitionsRequest) Unmarshal(dAtA []byte) error

func (*ListTaskListPartitionsRequest) XXX_DiscardUnknown 

func (m *ListTaskListPartitionsRequest) XXX_DiscardUnknown()

func (*ListTaskListPartitionsRequest) XXX_Marshal 

func (m *ListTaskListPartitionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTaskListPartitionsRequest) XXX_Merge 

func (m *ListTaskListPartitionsRequest) XXX_Merge(src proto.Message)

func (*ListTaskListPartitionsRequest) XXX_Size 

func (m *ListTaskListPartitionsRequest) XXX_Size() int

func (*ListTaskListPartitionsRequest) XXX_Unmarshal 

func (m *ListTaskListPartitionsRequest) XXX_Unmarshal(b []byte) error

type ListTaskListPartitionsResponse 

type ListTaskListPartitionsResponse struct {
	ActivityTaskListPartitions []*common.TaskListPartitionMetadata `protobuf:"bytes,1,rep,name=activityTaskListPartitions,proto3" json:"activityTaskListPartitions,omitempty"`
	DecisionTaskListPartitions []*common.TaskListPartitionMetadata `protobuf:"bytes,2,rep,name=decisionTaskListPartitions,proto3" json:"decisionTaskListPartitions,omitempty"`
}

func (*ListTaskListPartitionsResponse) Descriptor 

func (*ListTaskListPartitionsResponse) Descriptor() ([]byte, []int)

func (*ListTaskListPartitionsResponse) Equal 

func (this *ListTaskListPartitionsResponse) Equal(that interface{}) bool

func (*ListTaskListPartitionsResponse) GetActivityTaskListPartitions 

func (m *ListTaskListPartitionsResponse) GetActivityTaskListPartitions() []*common.TaskListPartitionMetadata

func (*ListTaskListPartitionsResponse) GetDecisionTaskListPartitions 

func (m *ListTaskListPartitionsResponse) GetDecisionTaskListPartitions() []*common.TaskListPartitionMetadata

func (*ListTaskListPartitionsResponse) GoString 

func (this *ListTaskListPartitionsResponse) GoString() string

func (*ListTaskListPartitionsResponse) Marshal 

func (m *ListTaskListPartitionsResponse) Marshal() (dAtA []byte, err error)

func (*ListTaskListPartitionsResponse) MarshalTo 

func (m *ListTaskListPartitionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListTaskListPartitionsResponse) MarshalToSizedBuffer 

func (m *ListTaskListPartitionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTaskListPartitionsResponse) ProtoMessage 

func (*ListTaskListPartitionsResponse) ProtoMessage()

func (*ListTaskListPartitionsResponse) Reset 

func (m *ListTaskListPartitionsResponse) Reset()

func (*ListTaskListPartitionsResponse) Size 

func (m *ListTaskListPartitionsResponse) Size() (n int)

func (*ListTaskListPartitionsResponse) String 

func (this *ListTaskListPartitionsResponse) String() string

func (*ListTaskListPartitionsResponse) Unmarshal 

func (m *ListTaskListPartitionsResponse) Unmarshal(dAtA []byte) error

func (*ListTaskListPartitionsResponse) XXX_DiscardUnknown 

func (m *ListTaskListPartitionsResponse) XXX_DiscardUnknown()

func (*ListTaskListPartitionsResponse) XXX_Marshal 

func (m *ListTaskListPartitionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTaskListPartitionsResponse) XXX_Merge 

func (m *ListTaskListPartitionsResponse) XXX_Merge(src proto.Message)

func (*ListTaskListPartitionsResponse) XXX_Size 

func (m *ListTaskListPartitionsResponse) XXX_Size() int

func (*ListTaskListPartitionsResponse) XXX_Unmarshal 

func (m *ListTaskListPartitionsResponse) XXX_Unmarshal(b []byte) error

type ListWorkflowExecutionsRequest 

type ListWorkflowExecutionsRequest struct {
	Domain        string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	Query         string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
}

func (*ListWorkflowExecutionsRequest) Descriptor 

func (*ListWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

func (*ListWorkflowExecutionsRequest) Equal 

func (this *ListWorkflowExecutionsRequest) Equal(that interface{}) bool

func (*ListWorkflowExecutionsRequest) GetDomain 

func (m *ListWorkflowExecutionsRequest) GetDomain() string

func (*ListWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListWorkflowExecutionsRequest) GetPageSize 

func (m *ListWorkflowExecutionsRequest) GetPageSize() int32

func (*ListWorkflowExecutionsRequest) GetQuery 

func (m *ListWorkflowExecutionsRequest) GetQuery() string

func (*ListWorkflowExecutionsRequest) GoString 

func (this *ListWorkflowExecutionsRequest) GoString() string

func (*ListWorkflowExecutionsRequest) Marshal 

func (m *ListWorkflowExecutionsRequest) Marshal() (dAtA []byte, err error)

func (*ListWorkflowExecutionsRequest) MarshalTo 

func (m *ListWorkflowExecutionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowExecutionsRequest) MarshalToSizedBuffer 

func (m *ListWorkflowExecutionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowExecutionsRequest) ProtoMessage 

func (*ListWorkflowExecutionsRequest) ProtoMessage()

func (*ListWorkflowExecutionsRequest) Reset 

func (m *ListWorkflowExecutionsRequest) Reset()

func (*ListWorkflowExecutionsRequest) Size 

func (m *ListWorkflowExecutionsRequest) Size() (n int)

func (*ListWorkflowExecutionsRequest) String 

func (this *ListWorkflowExecutionsRequest) String() string

func (*ListWorkflowExecutionsRequest) Unmarshal 

func (m *ListWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

func (*ListWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListWorkflowExecutionsRequest) XXX_Marshal 

func (m *ListWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkflowExecutionsRequest) XXX_Merge 

func (m *ListWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

func (*ListWorkflowExecutionsRequest) XXX_Size 

func (m *ListWorkflowExecutionsRequest) XXX_Size() int

func (*ListWorkflowExecutionsRequest) XXX_Unmarshal 

func (m *ListWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

type ListWorkflowExecutionsResponse 

type ListWorkflowExecutionsResponse struct {
	Executions    []*common.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                          `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ListWorkflowExecutionsResponse) Descriptor 

func (*ListWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

func (*ListWorkflowExecutionsResponse) Equal 

func (this *ListWorkflowExecutionsResponse) Equal(that interface{}) bool

func (*ListWorkflowExecutionsResponse) GetExecutions 

func (m *ListWorkflowExecutionsResponse) GetExecutions() []*common.WorkflowExecutionInfo

func (*ListWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListWorkflowExecutionsResponse) GoString 

func (this *ListWorkflowExecutionsResponse) GoString() string

func (*ListWorkflowExecutionsResponse) Marshal 

func (m *ListWorkflowExecutionsResponse) Marshal() (dAtA []byte, err error)

func (*ListWorkflowExecutionsResponse) MarshalTo 

func (m *ListWorkflowExecutionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListWorkflowExecutionsResponse) MarshalToSizedBuffer 

func (m *ListWorkflowExecutionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListWorkflowExecutionsResponse) ProtoMessage 

func (*ListWorkflowExecutionsResponse) ProtoMessage()

func (*ListWorkflowExecutionsResponse) Reset 

func (m *ListWorkflowExecutionsResponse) Reset()

func (*ListWorkflowExecutionsResponse) Size 

func (m *ListWorkflowExecutionsResponse) Size() (n int)

func (*ListWorkflowExecutionsResponse) String 

func (this *ListWorkflowExecutionsResponse) String() string

func (*ListWorkflowExecutionsResponse) Unmarshal 

func (m *ListWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

func (*ListWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListWorkflowExecutionsResponse) XXX_Marshal 

func (m *ListWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkflowExecutionsResponse) XXX_Merge 

func (m *ListWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

func (*ListWorkflowExecutionsResponse) XXX_Size 

func (m *ListWorkflowExecutionsResponse) XXX_Size() int

func (*ListWorkflowExecutionsResponse) XXX_Unmarshal 

func (m *ListWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

type PollForActivityTaskRequest 

type PollForActivityTaskRequest struct {
	Domain           string                   `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	TaskList         *common.TaskList         `protobuf:"bytes,2,opt,name=taskList,proto3" json:"taskList,omitempty"`
	Identity         string                   `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	TaskListMetadata *common.TaskListMetadata `protobuf:"bytes,4,opt,name=taskListMetadata,proto3" json:"taskListMetadata,omitempty"`
}

func (*PollForActivityTaskRequest) Descriptor 

func (*PollForActivityTaskRequest) Descriptor() ([]byte, []int)

func (*PollForActivityTaskRequest) Equal 

func (this *PollForActivityTaskRequest) Equal(that interface{}) bool

func (*PollForActivityTaskRequest) GetDomain 

func (m *PollForActivityTaskRequest) GetDomain() string

func (*PollForActivityTaskRequest) GetIdentity 

func (m *PollForActivityTaskRequest) GetIdentity() string

func (*PollForActivityTaskRequest) GetTaskList 

func (m *PollForActivityTaskRequest) GetTaskList() *common.TaskList

func (*PollForActivityTaskRequest) GetTaskListMetadata 

func (m *PollForActivityTaskRequest) GetTaskListMetadata() *common.TaskListMetadata

func (*PollForActivityTaskRequest) GoString 

func (this *PollForActivityTaskRequest) GoString() string

func (*PollForActivityTaskRequest) Marshal 

func (m *PollForActivityTaskRequest) Marshal() (dAtA []byte, err error)

func (*PollForActivityTaskRequest) MarshalTo 

func (m *PollForActivityTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*PollForActivityTaskRequest) MarshalToSizedBuffer 

func (m *PollForActivityTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollForActivityTaskRequest) ProtoMessage 

func (*PollForActivityTaskRequest) ProtoMessage()

func (*PollForActivityTaskRequest) Reset 

func (m *PollForActivityTaskRequest) Reset()

func (*PollForActivityTaskRequest) Size 

func (m *PollForActivityTaskRequest) Size() (n int)

func (*PollForActivityTaskRequest) String 

func (this *PollForActivityTaskRequest) String() string

func (*PollForActivityTaskRequest) Unmarshal 

func (m *PollForActivityTaskRequest) Unmarshal(dAtA []byte) error

func (*PollForActivityTaskRequest) XXX_DiscardUnknown 

func (m *PollForActivityTaskRequest) XXX_DiscardUnknown()

func (*PollForActivityTaskRequest) XXX_Marshal 

func (m *PollForActivityTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PollForActivityTaskRequest) XXX_Merge 

func (m *PollForActivityTaskRequest) XXX_Merge(src proto.Message)

func (*PollForActivityTaskRequest) XXX_Size 

func (m *PollForActivityTaskRequest) XXX_Size() int

func (*PollForActivityTaskRequest) XXX_Unmarshal 

func (m *PollForActivityTaskRequest) XXX_Unmarshal(b []byte) error

type PollForActivityTaskResponse 

type PollForActivityTaskResponse struct {
	TaskToken                       []byte                    `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	WorkflowExecution               *common.WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	ActivityId                      string                    `protobuf:"bytes,3,opt,name=activityId,proto3" json:"activityId,omitempty"`
	ActivityType                    *common.ActivityType      `protobuf:"bytes,4,opt,name=activityType,proto3" json:"activityType,omitempty"`
	Input                           []byte                    `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledTimestamp              int64                     `protobuf:"varint,6,opt,name=scheduledTimestamp,proto3" json:"scheduledTimestamp,omitempty"`
	ScheduleToCloseTimeoutSeconds   int32                     `protobuf:"varint,7,opt,name=scheduleToCloseTimeoutSeconds,proto3" json:"scheduleToCloseTimeoutSeconds,omitempty"`
	StartedTimestamp                int64                     `protobuf:"varint,8,opt,name=startedTimestamp,proto3" json:"startedTimestamp,omitempty"`
	StartToCloseTimeoutSeconds      int32                     `protobuf:"varint,9,opt,name=startToCloseTimeoutSeconds,proto3" json:"startToCloseTimeoutSeconds,omitempty"`
	HeartbeatTimeoutSeconds         int32                     `protobuf:"varint,10,opt,name=heartbeatTimeoutSeconds,proto3" json:"heartbeatTimeoutSeconds,omitempty"`
	Attempt                         int32                     `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
	ScheduledTimestampOfThisAttempt int64                     `protobuf:"varint,12,opt,name=scheduledTimestampOfThisAttempt,proto3" json:"scheduledTimestampOfThisAttempt,omitempty"`
	HeartbeatDetails                []byte                    `protobuf:"bytes,13,opt,name=heartbeatDetails,proto3" json:"heartbeatDetails,omitempty"`
	WorkflowType                    *common.WorkflowType      `protobuf:"bytes,14,opt,name=workflowType,proto3" json:"workflowType,omitempty"`
	WorkflowDomain                  string                    `protobuf:"bytes,15,opt,name=workflowDomain,proto3" json:"workflowDomain,omitempty"`
	Header                          *common.Header            `protobuf:"bytes,16,opt,name=header,proto3" json:"header,omitempty"`
}

func (*PollForActivityTaskResponse) Descriptor 

func (*PollForActivityTaskResponse) Descriptor() ([]byte, []int)

func (*PollForActivityTaskResponse) Equal 

func (this *PollForActivityTaskResponse) Equal(that interface{}) bool

func (*PollForActivityTaskResponse) GetActivityId 

func (m *PollForActivityTaskResponse) GetActivityId() string

func (*PollForActivityTaskResponse) GetActivityType 

func (m *PollForActivityTaskResponse) GetActivityType() *common.ActivityType

func (*PollForActivityTaskResponse) GetAttempt 

func (m *PollForActivityTaskResponse) GetAttempt() int32

func (*PollForActivityTaskResponse) GetHeader 

func (m *PollForActivityTaskResponse) GetHeader() *common.Header

func (*PollForActivityTaskResponse) GetHeartbeatDetails 

func (m *PollForActivityTaskResponse) GetHeartbeatDetails() []byte

func (*PollForActivityTaskResponse) GetHeartbeatTimeoutSeconds 

func (m *PollForActivityTaskResponse) GetHeartbeatTimeoutSeconds() int32

func (*PollForActivityTaskResponse) GetInput 

func (m *PollForActivityTaskResponse) GetInput() []byte

func (*PollForActivityTaskResponse) GetScheduleToCloseTimeoutSeconds 

func (m *PollForActivityTaskResponse) GetScheduleToCloseTimeoutSeconds() int32

func (*PollForActivityTaskResponse) GetScheduledTimestamp 

func (m *PollForActivityTaskResponse) GetScheduledTimestamp() int64

func (*PollForActivityTaskResponse) GetScheduledTimestampOfThisAttempt 

func (m *PollForActivityTaskResponse) GetScheduledTimestampOfThisAttempt() int64

func (*PollForActivityTaskResponse) GetStartToCloseTimeoutSeconds 

func (m *PollForActivityTaskResponse) GetStartToCloseTimeoutSeconds() int32

func (*PollForActivityTaskResponse) GetStartedTimestamp 

func (m *PollForActivityTaskResponse) GetStartedTimestamp() int64

func (*PollForActivityTaskResponse) GetTaskToken 

func (m *PollForActivityTaskResponse) GetTaskToken() []byte

func (*PollForActivityTaskResponse) GetWorkflowDomain 

func (m *PollForActivityTaskResponse) GetWorkflowDomain() string

func (*PollForActivityTaskResponse) GetWorkflowExecution 

func (m *PollForActivityTaskResponse) GetWorkflowExecution() *common.WorkflowExecution

func (*PollForActivityTaskResponse) GetWorkflowType 

func (m *PollForActivityTaskResponse) GetWorkflowType() *common.WorkflowType

func (*PollForActivityTaskResponse) GoString 

func (this *PollForActivityTaskResponse) GoString() string

func (*PollForActivityTaskResponse) Marshal 

func (m *PollForActivityTaskResponse) Marshal() (dAtA []byte, err error)

func (*PollForActivityTaskResponse) MarshalTo 

func (m *PollForActivityTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*PollForActivityTaskResponse) MarshalToSizedBuffer 

func (m *PollForActivityTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollForActivityTaskResponse) ProtoMessage 

func (*PollForActivityTaskResponse) ProtoMessage()

func (*PollForActivityTaskResponse) Reset 

func (m *PollForActivityTaskResponse) Reset()

func (*PollForActivityTaskResponse) Size 

func (m *PollForActivityTaskResponse) Size() (n int)

func (*PollForActivityTaskResponse) String 

func (this *PollForActivityTaskResponse) String() string

func (*PollForActivityTaskResponse) Unmarshal 

func (m *PollForActivityTaskResponse) Unmarshal(dAtA []byte) error

func (*PollForActivityTaskResponse) XXX_DiscardUnknown 

func (m *PollForActivityTaskResponse) XXX_DiscardUnknown()

func (*PollForActivityTaskResponse) XXX_Marshal 

func (m *PollForActivityTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PollForActivityTaskResponse) XXX_Merge 

func (m *PollForActivityTaskResponse) XXX_Merge(src proto.Message)

func (*PollForActivityTaskResponse) XXX_Size 

func (m *PollForActivityTaskResponse) XXX_Size() int

func (*PollForActivityTaskResponse) XXX_Unmarshal 

func (m *PollForActivityTaskResponse) XXX_Unmarshal(b []byte) error

type PollForDecisionTaskRequest 

type PollForDecisionTaskRequest struct {
	Domain         string           `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	TaskList       *common.TaskList `protobuf:"bytes,2,opt,name=taskList,proto3" json:"taskList,omitempty"`
	Identity       string           `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	BinaryChecksum string           `protobuf:"bytes,4,opt,name=binaryChecksum,proto3" json:"binaryChecksum,omitempty"`
}

func (*PollForDecisionTaskRequest) Descriptor 

func (*PollForDecisionTaskRequest) Descriptor() ([]byte, []int)

func (*PollForDecisionTaskRequest) Equal 

func (this *PollForDecisionTaskRequest) Equal(that interface{}) bool

func (*PollForDecisionTaskRequest) GetBinaryChecksum 

func (m *PollForDecisionTaskRequest) GetBinaryChecksum() string

func (*PollForDecisionTaskRequest) GetDomain 

func (m *PollForDecisionTaskRequest) GetDomain() string

func (*PollForDecisionTaskRequest) GetIdentity 

func (m *PollForDecisionTaskRequest) GetIdentity() string

func (*PollForDecisionTaskRequest) GetTaskList 

func (m *PollForDecisionTaskRequest) GetTaskList() *common.TaskList

func (*PollForDecisionTaskRequest) GoString 

func (this *PollForDecisionTaskRequest) GoString() string

func (*PollForDecisionTaskRequest) Marshal 

func (m *PollForDecisionTaskRequest) Marshal() (dAtA []byte, err error)

func (*PollForDecisionTaskRequest) MarshalTo 

func (m *PollForDecisionTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*PollForDecisionTaskRequest) MarshalToSizedBuffer 

func (m *PollForDecisionTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollForDecisionTaskRequest) ProtoMessage 

func (*PollForDecisionTaskRequest) ProtoMessage()

func (*PollForDecisionTaskRequest) Reset 

func (m *PollForDecisionTaskRequest) Reset()

func (*PollForDecisionTaskRequest) Size 

func (m *PollForDecisionTaskRequest) Size() (n int)

func (*PollForDecisionTaskRequest) String 

func (this *PollForDecisionTaskRequest) String() string

func (*PollForDecisionTaskRequest) Unmarshal 

func (m *PollForDecisionTaskRequest) Unmarshal(dAtA []byte) error

func (*PollForDecisionTaskRequest) XXX_DiscardUnknown 

func (m *PollForDecisionTaskRequest) XXX_DiscardUnknown()

func (*PollForDecisionTaskRequest) XXX_Marshal 

func (m *PollForDecisionTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PollForDecisionTaskRequest) XXX_Merge 

func (m *PollForDecisionTaskRequest) XXX_Merge(src proto.Message)

func (*PollForDecisionTaskRequest) XXX_Size 

func (m *PollForDecisionTaskRequest) XXX_Size() int

func (*PollForDecisionTaskRequest) XXX_Unmarshal 

func (m *PollForDecisionTaskRequest) XXX_Unmarshal(b []byte) error

type PollForDecisionTaskResponse 

type PollForDecisionTaskResponse struct {
	TaskToken                 []byte                           `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	WorkflowExecution         *common.WorkflowExecution        `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	WorkflowType              *common.WorkflowType             `protobuf:"bytes,3,opt,name=workflowType,proto3" json:"workflowType,omitempty"`
	PreviousStartedEventId    int64                            `protobuf:"varint,4,opt,name=previousStartedEventId,proto3" json:"previousStartedEventId,omitempty"`
	StartedEventId            int64                            `protobuf:"varint,5,opt,name=startedEventId,proto3" json:"startedEventId,omitempty"`
	Attempt                   int64                            `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	BacklogCountHint          int64                            `protobuf:"varint,7,opt,name=backlogCountHint,proto3" json:"backlogCountHint,omitempty"`
	History                   *common.History                  `protobuf:"bytes,8,opt,name=history,proto3" json:"history,omitempty"`
	NextPageToken             []byte                           `protobuf:"bytes,9,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	Query                     *common.WorkflowQuery            `protobuf:"bytes,10,opt,name=query,proto3" json:"query,omitempty"`
	WorkflowExecutionTaskList *common.TaskList                 `protobuf:"bytes,11,opt,name=WorkflowExecutionTaskList,proto3" json:"WorkflowExecutionTaskList,omitempty"`
	ScheduledTimestamp        int64                            `protobuf:"varint,12,opt,name=scheduledTimestamp,proto3" json:"scheduledTimestamp,omitempty"`
	StartedTimestamp          int64                            `protobuf:"varint,13,opt,name=startedTimestamp,proto3" json:"startedTimestamp,omitempty"`
	Queries                   map[string]*common.WorkflowQuery `` /* 156-byte string literal not displayed */
}

func (*PollForDecisionTaskResponse) Descriptor 

func (*PollForDecisionTaskResponse) Descriptor() ([]byte, []int)

func (*PollForDecisionTaskResponse) Equal 

func (this *PollForDecisionTaskResponse) Equal(that interface{}) bool

func (*PollForDecisionTaskResponse) GetAttempt 

func (m *PollForDecisionTaskResponse) GetAttempt() int64

func (*PollForDecisionTaskResponse) GetBacklogCountHint 

func (m *PollForDecisionTaskResponse) GetBacklogCountHint() int64

func (*PollForDecisionTaskResponse) GetHistory 

func (m *PollForDecisionTaskResponse) GetHistory() *common.History

func (*PollForDecisionTaskResponse) GetNextPageToken 

func (m *PollForDecisionTaskResponse) GetNextPageToken() []byte

func (*PollForDecisionTaskResponse) GetPreviousStartedEventId 

func (m *PollForDecisionTaskResponse) GetPreviousStartedEventId() int64

func (*PollForDecisionTaskResponse) GetQueries 

func (m *PollForDecisionTaskResponse) GetQueries() map[string]*common.WorkflowQuery

func (*PollForDecisionTaskResponse) GetQuery 

func (m *PollForDecisionTaskResponse) GetQuery() *common.WorkflowQuery

func (*PollForDecisionTaskResponse) GetScheduledTimestamp 

func (m *PollForDecisionTaskResponse) GetScheduledTimestamp() int64

func (*PollForDecisionTaskResponse) GetStartedEventId 

func (m *PollForDecisionTaskResponse) GetStartedEventId() int64

func (*PollForDecisionTaskResponse) GetStartedTimestamp 

func (m *PollForDecisionTaskResponse) GetStartedTimestamp() int64

func (*PollForDecisionTaskResponse) GetTaskToken 

func (m *PollForDecisionTaskResponse) GetTaskToken() []byte

func (*PollForDecisionTaskResponse) GetWorkflowExecution 

func (m *PollForDecisionTaskResponse) GetWorkflowExecution() *common.WorkflowExecution

func (*PollForDecisionTaskResponse) GetWorkflowExecutionTaskList 

func (m *PollForDecisionTaskResponse) GetWorkflowExecutionTaskList() *common.TaskList

func (*PollForDecisionTaskResponse) GetWorkflowType 

func (m *PollForDecisionTaskResponse) GetWorkflowType() *common.WorkflowType

func (*PollForDecisionTaskResponse) GoString 

func (this *PollForDecisionTaskResponse) GoString() string

func (*PollForDecisionTaskResponse) Marshal 

func (m *PollForDecisionTaskResponse) Marshal() (dAtA []byte, err error)

func (*PollForDecisionTaskResponse) MarshalTo 

func (m *PollForDecisionTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*PollForDecisionTaskResponse) MarshalToSizedBuffer 

func (m *PollForDecisionTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PollForDecisionTaskResponse) ProtoMessage 

func (*PollForDecisionTaskResponse) ProtoMessage()

func (*PollForDecisionTaskResponse) Reset 

func (m *PollForDecisionTaskResponse) Reset()

func (*PollForDecisionTaskResponse) Size 

func (m *PollForDecisionTaskResponse) Size() (n int)

func (*PollForDecisionTaskResponse) String 

func (this *PollForDecisionTaskResponse) String() string

func (*PollForDecisionTaskResponse) Unmarshal 

func (m *PollForDecisionTaskResponse) Unmarshal(dAtA []byte) error

func (*PollForDecisionTaskResponse) XXX_DiscardUnknown 

func (m *PollForDecisionTaskResponse) XXX_DiscardUnknown()

func (*PollForDecisionTaskResponse) XXX_Marshal 

func (m *PollForDecisionTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PollForDecisionTaskResponse) XXX_Merge 

func (m *PollForDecisionTaskResponse) XXX_Merge(src proto.Message)

func (*PollForDecisionTaskResponse) XXX_Size 

func (m *PollForDecisionTaskResponse) XXX_Size() int

func (*PollForDecisionTaskResponse) XXX_Unmarshal 

func (m *PollForDecisionTaskResponse) XXX_Unmarshal(b []byte) error

type QueryWorkflowRequest 

type QueryWorkflowRequest struct {
	Domain    string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Execution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	Query     *common.WorkflowQuery     `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// QueryRejectCondition can used to reject the query if workflow state does not satisfy condition
	QueryRejectCondition  enums.QueryRejectCondition  `` /* 126-byte string literal not displayed */
	QueryConsistencyLevel enums.QueryConsistencyLevel `` /* 129-byte string literal not displayed */
}

func (*QueryWorkflowRequest) Descriptor 

func (*QueryWorkflowRequest) Descriptor() ([]byte, []int)

func (*QueryWorkflowRequest) Equal 

func (this *QueryWorkflowRequest) Equal(that interface{}) bool

func (*QueryWorkflowRequest) GetDomain 

func (m *QueryWorkflowRequest) GetDomain() string

func (*QueryWorkflowRequest) GetExecution 

func (m *QueryWorkflowRequest) GetExecution() *common.WorkflowExecution

func (*QueryWorkflowRequest) GetQuery 

func (m *QueryWorkflowRequest) GetQuery() *common.WorkflowQuery

func (*QueryWorkflowRequest) GetQueryConsistencyLevel 

func (m *QueryWorkflowRequest) GetQueryConsistencyLevel() enums.QueryConsistencyLevel

func (*QueryWorkflowRequest) GetQueryRejectCondition 

func (m *QueryWorkflowRequest) GetQueryRejectCondition() enums.QueryRejectCondition

func (*QueryWorkflowRequest) GoString 

func (this *QueryWorkflowRequest) GoString() string

func (*QueryWorkflowRequest) Marshal 

func (m *QueryWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*QueryWorkflowRequest) MarshalTo 

func (m *QueryWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryWorkflowRequest) MarshalToSizedBuffer 

func (m *QueryWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWorkflowRequest) ProtoMessage 

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) Reset 

func (m *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size 

func (m *QueryWorkflowRequest) Size() (n int)

func (*QueryWorkflowRequest) String 

func (this *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal 

func (m *QueryWorkflowRequest) Unmarshal(dAtA []byte) error

func (*QueryWorkflowRequest) XXX_DiscardUnknown 

func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

func (*QueryWorkflowRequest) XXX_Marshal 

func (m *QueryWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWorkflowRequest) XXX_Merge 

func (m *QueryWorkflowRequest) XXX_Merge(src proto.Message)

func (*QueryWorkflowRequest) XXX_Size 

func (m *QueryWorkflowRequest) XXX_Size() int

func (*QueryWorkflowRequest) XXX_Unmarshal 

func (m *QueryWorkflowRequest) XXX_Unmarshal(b []byte) error

type QueryWorkflowResponse 

type QueryWorkflowResponse struct {
	QueryResult   []byte                `protobuf:"bytes,1,opt,name=queryResult,proto3" json:"queryResult,omitempty"`
	QueryRejected *common.QueryRejected `protobuf:"bytes,2,opt,name=queryRejected,proto3" json:"queryRejected,omitempty"`
}

func (*QueryWorkflowResponse) Descriptor 

func (*QueryWorkflowResponse) Descriptor() ([]byte, []int)

func (*QueryWorkflowResponse) Equal 

func (this *QueryWorkflowResponse) Equal(that interface{}) bool

func (*QueryWorkflowResponse) GetQueryRejected 

func (m *QueryWorkflowResponse) GetQueryRejected() *common.QueryRejected

func (*QueryWorkflowResponse) GetQueryResult 

func (m *QueryWorkflowResponse) GetQueryResult() []byte

func (*QueryWorkflowResponse) GoString 

func (this *QueryWorkflowResponse) GoString() string

func (*QueryWorkflowResponse) Marshal 

func (m *QueryWorkflowResponse) Marshal() (dAtA []byte, err error)

func (*QueryWorkflowResponse) MarshalTo 

func (m *QueryWorkflowResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryWorkflowResponse) MarshalToSizedBuffer 

func (m *QueryWorkflowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWorkflowResponse) ProtoMessage 

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) Reset 

func (m *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size 

func (m *QueryWorkflowResponse) Size() (n int)

func (*QueryWorkflowResponse) String 

func (this *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal 

func (m *QueryWorkflowResponse) Unmarshal(dAtA []byte) error

func (*QueryWorkflowResponse) XXX_DiscardUnknown 

func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

func (*QueryWorkflowResponse) XXX_Marshal 

func (m *QueryWorkflowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWorkflowResponse) XXX_Merge 

func (m *QueryWorkflowResponse) XXX_Merge(src proto.Message)

func (*QueryWorkflowResponse) XXX_Size 

func (m *QueryWorkflowResponse) XXX_Size() int

func (*QueryWorkflowResponse) XXX_Unmarshal 

func (m *QueryWorkflowResponse) XXX_Unmarshal(b []byte) error

type ReapplyEventsRequest 

type ReapplyEventsRequest struct {
	DomainName        string                    `protobuf:"bytes,1,opt,name=domainName,proto3" json:"domainName,omitempty"`
	WorkflowExecution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	Events            *common.DataBlob          `protobuf:"bytes,3,opt,name=events,proto3" json:"events,omitempty"`
}

ReapplyEventsRequest is the request for reapply events API.

func (*ReapplyEventsRequest) Descriptor 

func (*ReapplyEventsRequest) Descriptor() ([]byte, []int)

func (*ReapplyEventsRequest) Equal 

func (this *ReapplyEventsRequest) Equal(that interface{}) bool

func (*ReapplyEventsRequest) GetDomainName 

func (m *ReapplyEventsRequest) GetDomainName() string

func (*ReapplyEventsRequest) GetEvents 

func (m *ReapplyEventsRequest) GetEvents() *common.DataBlob

func (*ReapplyEventsRequest) GetWorkflowExecution 

func (m *ReapplyEventsRequest) GetWorkflowExecution() *common.WorkflowExecution

func (*ReapplyEventsRequest) GoString 

func (this *ReapplyEventsRequest) GoString() string

func (*ReapplyEventsRequest) Marshal 

func (m *ReapplyEventsRequest) Marshal() (dAtA []byte, err error)

func (*ReapplyEventsRequest) MarshalTo 

func (m *ReapplyEventsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReapplyEventsRequest) MarshalToSizedBuffer 

func (m *ReapplyEventsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReapplyEventsRequest) ProtoMessage 

func (*ReapplyEventsRequest) ProtoMessage()

func (*ReapplyEventsRequest) Reset 

func (m *ReapplyEventsRequest) Reset()

func (*ReapplyEventsRequest) Size 

func (m *ReapplyEventsRequest) Size() (n int)

func (*ReapplyEventsRequest) String 

func (this *ReapplyEventsRequest) String() string

func (*ReapplyEventsRequest) Unmarshal 

func (m *ReapplyEventsRequest) Unmarshal(dAtA []byte) error

func (*ReapplyEventsRequest) XXX_DiscardUnknown 

func (m *ReapplyEventsRequest) XXX_DiscardUnknown()

func (*ReapplyEventsRequest) XXX_Marshal 

func (m *ReapplyEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReapplyEventsRequest) XXX_Merge 

func (m *ReapplyEventsRequest) XXX_Merge(src proto.Message)

func (*ReapplyEventsRequest) XXX_Size 

func (m *ReapplyEventsRequest) XXX_Size() int

func (*ReapplyEventsRequest) XXX_Unmarshal 

func (m *ReapplyEventsRequest) XXX_Unmarshal(b []byte) error

type ReapplyEventsResponse 

type ReapplyEventsResponse struct {
}

func (*ReapplyEventsResponse) Descriptor 

func (*ReapplyEventsResponse) Descriptor() ([]byte, []int)

func (*ReapplyEventsResponse) Equal 

func (this *ReapplyEventsResponse) Equal(that interface{}) bool

func (*ReapplyEventsResponse) GoString 

func (this *ReapplyEventsResponse) GoString() string

func (*ReapplyEventsResponse) Marshal 

func (m *ReapplyEventsResponse) Marshal() (dAtA []byte, err error)

func (*ReapplyEventsResponse) MarshalTo 

func (m *ReapplyEventsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReapplyEventsResponse) MarshalToSizedBuffer 

func (m *ReapplyEventsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReapplyEventsResponse) ProtoMessage 

func (*ReapplyEventsResponse) ProtoMessage()

func (*ReapplyEventsResponse) Reset 

func (m *ReapplyEventsResponse) Reset()

func (*ReapplyEventsResponse) Size 

func (m *ReapplyEventsResponse) Size() (n int)

func (*ReapplyEventsResponse) String 

func (this *ReapplyEventsResponse) String() string

func (*ReapplyEventsResponse) Unmarshal 

func (m *ReapplyEventsResponse) Unmarshal(dAtA []byte) error

func (*ReapplyEventsResponse) XXX_DiscardUnknown 

func (m *ReapplyEventsResponse) XXX_DiscardUnknown()

func (*ReapplyEventsResponse) XXX_Marshal 

func (m *ReapplyEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReapplyEventsResponse) XXX_Merge 

func (m *ReapplyEventsResponse) XXX_Merge(src proto.Message)

func (*ReapplyEventsResponse) XXX_Size 

func (m *ReapplyEventsResponse) XXX_Size() int

func (*ReapplyEventsResponse) XXX_Unmarshal 

func (m *ReapplyEventsResponse) XXX_Unmarshal(b []byte) error

type RecordActivityTaskHeartbeatByIDRequest 

type RecordActivityTaskHeartbeatByIDRequest struct {
	Domain     string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowID string `protobuf:"bytes,2,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	RunID      string `protobuf:"bytes,3,opt,name=runID,proto3" json:"runID,omitempty"`
	ActivityID string `protobuf:"bytes,4,opt,name=activityID,proto3" json:"activityID,omitempty"`
	Details    []byte `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	Identity   string `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RecordActivityTaskHeartbeatByIDRequest) Descriptor 

func (*RecordActivityTaskHeartbeatByIDRequest) Descriptor() ([]byte, []int)

func (*RecordActivityTaskHeartbeatByIDRequest) Equal 

func (this *RecordActivityTaskHeartbeatByIDRequest) Equal(that interface{}) bool

func (*RecordActivityTaskHeartbeatByIDRequest) GetActivityID 

func (m *RecordActivityTaskHeartbeatByIDRequest) GetActivityID() string

func (*RecordActivityTaskHeartbeatByIDRequest) GetDetails 

func (m *RecordActivityTaskHeartbeatByIDRequest) GetDetails() []byte

func (*RecordActivityTaskHeartbeatByIDRequest) GetDomain 

func (m *RecordActivityTaskHeartbeatByIDRequest) GetDomain() string

func (*RecordActivityTaskHeartbeatByIDRequest) GetIdentity 

func (m *RecordActivityTaskHeartbeatByIDRequest) GetIdentity() string

func (*RecordActivityTaskHeartbeatByIDRequest) GetRunID 

func (m *RecordActivityTaskHeartbeatByIDRequest) GetRunID() string

func (*RecordActivityTaskHeartbeatByIDRequest) GetWorkflowID 

func (m *RecordActivityTaskHeartbeatByIDRequest) GetWorkflowID() string

func (*RecordActivityTaskHeartbeatByIDRequest) GoString 

func (this *RecordActivityTaskHeartbeatByIDRequest) GoString() string

func (*RecordActivityTaskHeartbeatByIDRequest) Marshal 

func (m *RecordActivityTaskHeartbeatByIDRequest) Marshal() (dAtA []byte, err error)

func (*RecordActivityTaskHeartbeatByIDRequest) MarshalTo 

func (m *RecordActivityTaskHeartbeatByIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatByIDRequest) MarshalToSizedBuffer 

func (m *RecordActivityTaskHeartbeatByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatByIDRequest) ProtoMessage 

func (*RecordActivityTaskHeartbeatByIDRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatByIDRequest) Reset 

func (m *RecordActivityTaskHeartbeatByIDRequest) Reset()

func (*RecordActivityTaskHeartbeatByIDRequest) Size 

func (m *RecordActivityTaskHeartbeatByIDRequest) Size() (n int)

func (*RecordActivityTaskHeartbeatByIDRequest) String 

func (this *RecordActivityTaskHeartbeatByIDRequest) String() string

func (*RecordActivityTaskHeartbeatByIDRequest) Unmarshal 

func (m *RecordActivityTaskHeartbeatByIDRequest) Unmarshal(dAtA []byte) error

func (*RecordActivityTaskHeartbeatByIDRequest) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatByIDRequest) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatByIDRequest) XXX_Marshal 

func (m *RecordActivityTaskHeartbeatByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordActivityTaskHeartbeatByIDRequest) XXX_Merge 

func (m *RecordActivityTaskHeartbeatByIDRequest) XXX_Merge(src proto.Message)

func (*RecordActivityTaskHeartbeatByIDRequest) XXX_Size 

func (m *RecordActivityTaskHeartbeatByIDRequest) XXX_Size() int

func (*RecordActivityTaskHeartbeatByIDRequest) XXX_Unmarshal 

func (m *RecordActivityTaskHeartbeatByIDRequest) XXX_Unmarshal(b []byte) error

type RecordActivityTaskHeartbeatByIDResponse 

type RecordActivityTaskHeartbeatByIDResponse struct {
	CancelRequested bool `protobuf:"varint,1,opt,name=cancelRequested,proto3" json:"cancelRequested,omitempty"`
}

func (*RecordActivityTaskHeartbeatByIDResponse) Descriptor 

func (*RecordActivityTaskHeartbeatByIDResponse) Descriptor() ([]byte, []int)

func (*RecordActivityTaskHeartbeatByIDResponse) Equal 

func (this *RecordActivityTaskHeartbeatByIDResponse) Equal(that interface{}) bool

func (*RecordActivityTaskHeartbeatByIDResponse) GetCancelRequested 

func (m *RecordActivityTaskHeartbeatByIDResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatByIDResponse) GoString 

func (this *RecordActivityTaskHeartbeatByIDResponse) GoString() string

func (*RecordActivityTaskHeartbeatByIDResponse) Marshal 

func (m *RecordActivityTaskHeartbeatByIDResponse) Marshal() (dAtA []byte, err error)

func (*RecordActivityTaskHeartbeatByIDResponse) MarshalTo 

func (m *RecordActivityTaskHeartbeatByIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatByIDResponse) MarshalToSizedBuffer 

func (m *RecordActivityTaskHeartbeatByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatByIDResponse) ProtoMessage 

func (*RecordActivityTaskHeartbeatByIDResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatByIDResponse) Reset 

func (m *RecordActivityTaskHeartbeatByIDResponse) Reset()

func (*RecordActivityTaskHeartbeatByIDResponse) Size 

func (m *RecordActivityTaskHeartbeatByIDResponse) Size() (n int)

func (*RecordActivityTaskHeartbeatByIDResponse) String 

func (this *RecordActivityTaskHeartbeatByIDResponse) String() string

func (*RecordActivityTaskHeartbeatByIDResponse) Unmarshal 

func (m *RecordActivityTaskHeartbeatByIDResponse) Unmarshal(dAtA []byte) error

func (*RecordActivityTaskHeartbeatByIDResponse) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatByIDResponse) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatByIDResponse) XXX_Marshal 

func (m *RecordActivityTaskHeartbeatByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordActivityTaskHeartbeatByIDResponse) XXX_Merge 

func (m *RecordActivityTaskHeartbeatByIDResponse) XXX_Merge(src proto.Message)

func (*RecordActivityTaskHeartbeatByIDResponse) XXX_Size 

func (m *RecordActivityTaskHeartbeatByIDResponse) XXX_Size() int

func (*RecordActivityTaskHeartbeatByIDResponse) XXX_Unmarshal 

func (m *RecordActivityTaskHeartbeatByIDResponse) XXX_Unmarshal(b []byte) error

type RecordActivityTaskHeartbeatRequest 

type RecordActivityTaskHeartbeatRequest struct {
	TaskToken []byte `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	Details   []byte `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RecordActivityTaskHeartbeatRequest) Descriptor 

func (*RecordActivityTaskHeartbeatRequest) Descriptor() ([]byte, []int)

func (*RecordActivityTaskHeartbeatRequest) Equal 

func (this *RecordActivityTaskHeartbeatRequest) Equal(that interface{}) bool

func (*RecordActivityTaskHeartbeatRequest) GetDetails 

func (m *RecordActivityTaskHeartbeatRequest) GetDetails() []byte

func (*RecordActivityTaskHeartbeatRequest) GetIdentity 

func (m *RecordActivityTaskHeartbeatRequest) GetIdentity() string

func (*RecordActivityTaskHeartbeatRequest) GetTaskToken 

func (m *RecordActivityTaskHeartbeatRequest) GetTaskToken() []byte

func (*RecordActivityTaskHeartbeatRequest) GoString 

func (this *RecordActivityTaskHeartbeatRequest) GoString() string

func (*RecordActivityTaskHeartbeatRequest) Marshal 

func (m *RecordActivityTaskHeartbeatRequest) Marshal() (dAtA []byte, err error)

func (*RecordActivityTaskHeartbeatRequest) MarshalTo 

func (m *RecordActivityTaskHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatRequest) MarshalToSizedBuffer 

func (m *RecordActivityTaskHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage 

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatRequest) Reset 

func (m *RecordActivityTaskHeartbeatRequest) Reset()

func (*RecordActivityTaskHeartbeatRequest) Size 

func (m *RecordActivityTaskHeartbeatRequest) Size() (n int)

func (*RecordActivityTaskHeartbeatRequest) String 

func (this *RecordActivityTaskHeartbeatRequest) String() string

func (*RecordActivityTaskHeartbeatRequest) Unmarshal 

func (m *RecordActivityTaskHeartbeatRequest) Unmarshal(dAtA []byte) error

func (*RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatRequest) XXX_Marshal 

func (m *RecordActivityTaskHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordActivityTaskHeartbeatRequest) XXX_Merge 

func (m *RecordActivityTaskHeartbeatRequest) XXX_Merge(src proto.Message)

func (*RecordActivityTaskHeartbeatRequest) XXX_Size 

func (m *RecordActivityTaskHeartbeatRequest) XXX_Size() int

func (*RecordActivityTaskHeartbeatRequest) XXX_Unmarshal 

func (m *RecordActivityTaskHeartbeatRequest) XXX_Unmarshal(b []byte) error

type RecordActivityTaskHeartbeatResponse 

type RecordActivityTaskHeartbeatResponse struct {
	CancelRequested bool `protobuf:"varint,1,opt,name=cancelRequested,proto3" json:"cancelRequested,omitempty"`
}

func (*RecordActivityTaskHeartbeatResponse) Descriptor 

func (*RecordActivityTaskHeartbeatResponse) Descriptor() ([]byte, []int)

func (*RecordActivityTaskHeartbeatResponse) Equal 

func (this *RecordActivityTaskHeartbeatResponse) Equal(that interface{}) bool

func (*RecordActivityTaskHeartbeatResponse) GetCancelRequested 

func (m *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatResponse) GoString 

func (this *RecordActivityTaskHeartbeatResponse) GoString() string

func (*RecordActivityTaskHeartbeatResponse) Marshal 

func (m *RecordActivityTaskHeartbeatResponse) Marshal() (dAtA []byte, err error)

func (*RecordActivityTaskHeartbeatResponse) MarshalTo 

func (m *RecordActivityTaskHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatResponse) MarshalToSizedBuffer 

func (m *RecordActivityTaskHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage 

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatResponse) Reset 

func (m *RecordActivityTaskHeartbeatResponse) Reset()

func (*RecordActivityTaskHeartbeatResponse) Size 

func (m *RecordActivityTaskHeartbeatResponse) Size() (n int)

func (*RecordActivityTaskHeartbeatResponse) String 

func (this *RecordActivityTaskHeartbeatResponse) String() string

func (*RecordActivityTaskHeartbeatResponse) Unmarshal 

func (m *RecordActivityTaskHeartbeatResponse) Unmarshal(dAtA []byte) error

func (*RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatResponse) XXX_Marshal 

func (m *RecordActivityTaskHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordActivityTaskHeartbeatResponse) XXX_Merge 

func (m *RecordActivityTaskHeartbeatResponse) XXX_Merge(src proto.Message)

func (*RecordActivityTaskHeartbeatResponse) XXX_Size 

func (m *RecordActivityTaskHeartbeatResponse) XXX_Size() int

func (*RecordActivityTaskHeartbeatResponse) XXX_Unmarshal 

func (m *RecordActivityTaskHeartbeatResponse) XXX_Unmarshal(b []byte) error

type RegisterDomainRequest 

type RegisterDomainRequest struct {
	Name                                   string                                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description                            string                                    `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	OwnerEmail                             string                                    `protobuf:"bytes,3,opt,name=ownerEmail,proto3" json:"ownerEmail,omitempty"`
	WorkflowExecutionRetentionPeriodInDays int32                                     `` /* 130-byte string literal not displayed */
	EmitMetric                             bool                                      `protobuf:"varint,5,opt,name=emitMetric,proto3" json:"emitMetric,omitempty"`
	Clusters                               []*common.ClusterReplicationConfiguration `protobuf:"bytes,6,rep,name=clusters,proto3" json:"clusters,omitempty"`
	ActiveClusterName                      string                                    `protobuf:"bytes,7,opt,name=activeClusterName,proto3" json:"activeClusterName,omitempty"`
	// A key-value map for any customized purpose.
	Data                     map[string]string    `` /* 149-byte string literal not displayed */
	SecurityToken            string               `protobuf:"bytes,9,opt,name=securityToken,proto3" json:"securityToken,omitempty"`
	IsGlobalDomain           bool                 `protobuf:"varint,10,opt,name=isGlobalDomain,proto3" json:"isGlobalDomain,omitempty"`
	HistoryArchivalStatus    enums.ArchivalStatus `protobuf:"varint,11,opt,name=historyArchivalStatus,proto3,enum=enums.ArchivalStatus" json:"historyArchivalStatus,omitempty"`
	HistoryArchivalURI       string               `protobuf:"bytes,12,opt,name=historyArchivalURI,proto3" json:"historyArchivalURI,omitempty"`
	VisibilityArchivalStatus enums.ArchivalStatus `` /* 129-byte string literal not displayed */
	VisibilityArchivalURI    string               `protobuf:"bytes,14,opt,name=visibilityArchivalURI,proto3" json:"visibilityArchivalURI,omitempty"`
}

func (*RegisterDomainRequest) Descriptor 

func (*RegisterDomainRequest) Descriptor() ([]byte, []int)

func (*RegisterDomainRequest) Equal 

func (this *RegisterDomainRequest) Equal(that interface{}) bool

func (*RegisterDomainRequest) GetActiveClusterName 

func (m *RegisterDomainRequest) GetActiveClusterName() string

func (*RegisterDomainRequest) GetClusters 

func (m *RegisterDomainRequest) GetClusters() []*common.ClusterReplicationConfiguration

func (*RegisterDomainRequest) GetData 

func (m *RegisterDomainRequest) GetData() map[string]string

func (*RegisterDomainRequest) GetDescription 

func (m *RegisterDomainRequest) GetDescription() string

func (*RegisterDomainRequest) GetEmitMetric 

func (m *RegisterDomainRequest) GetEmitMetric() bool

func (*RegisterDomainRequest) GetHistoryArchivalStatus 

func (m *RegisterDomainRequest) GetHistoryArchivalStatus() enums.ArchivalStatus

func (*RegisterDomainRequest) GetHistoryArchivalURI 

func (m *RegisterDomainRequest) GetHistoryArchivalURI() string

func (*RegisterDomainRequest) GetIsGlobalDomain 

func (m *RegisterDomainRequest) GetIsGlobalDomain() bool

func (*RegisterDomainRequest) GetName 

func (m *RegisterDomainRequest) GetName() string

func (*RegisterDomainRequest) GetOwnerEmail 

func (m *RegisterDomainRequest) GetOwnerEmail() string

func (*RegisterDomainRequest) GetSecurityToken 

func (m *RegisterDomainRequest) GetSecurityToken() string

func (*RegisterDomainRequest) GetVisibilityArchivalStatus 

func (m *RegisterDomainRequest) GetVisibilityArchivalStatus() enums.ArchivalStatus

func (*RegisterDomainRequest) GetVisibilityArchivalURI 

func (m *RegisterDomainRequest) GetVisibilityArchivalURI() string

func (*RegisterDomainRequest) GetWorkflowExecutionRetentionPeriodInDays 

func (m *RegisterDomainRequest) GetWorkflowExecutionRetentionPeriodInDays() int32

func (*RegisterDomainRequest) GoString 

func (this *RegisterDomainRequest) GoString() string

func (*RegisterDomainRequest) Marshal 

func (m *RegisterDomainRequest) Marshal() (dAtA []byte, err error)

func (*RegisterDomainRequest) MarshalTo 

func (m *RegisterDomainRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterDomainRequest) MarshalToSizedBuffer 

func (m *RegisterDomainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterDomainRequest) ProtoMessage 

func (*RegisterDomainRequest) ProtoMessage()

func (*RegisterDomainRequest) Reset 

func (m *RegisterDomainRequest) Reset()

func (*RegisterDomainRequest) Size 

func (m *RegisterDomainRequest) Size() (n int)

func (*RegisterDomainRequest) String 

func (this *RegisterDomainRequest) String() string

func (*RegisterDomainRequest) Unmarshal 

func (m *RegisterDomainRequest) Unmarshal(dAtA []byte) error

func (*RegisterDomainRequest) XXX_DiscardUnknown 

func (m *RegisterDomainRequest) XXX_DiscardUnknown()

func (*RegisterDomainRequest) XXX_Marshal 

func (m *RegisterDomainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterDomainRequest) XXX_Merge 

func (m *RegisterDomainRequest) XXX_Merge(src proto.Message)

func (*RegisterDomainRequest) XXX_Size 

func (m *RegisterDomainRequest) XXX_Size() int

func (*RegisterDomainRequest) XXX_Unmarshal 

func (m *RegisterDomainRequest) XXX_Unmarshal(b []byte) error

type RegisterDomainResponse 

type RegisterDomainResponse struct {
}

func (*RegisterDomainResponse) Descriptor 

func (*RegisterDomainResponse) Descriptor() ([]byte, []int)

func (*RegisterDomainResponse) Equal 

func (this *RegisterDomainResponse) Equal(that interface{}) bool

func (*RegisterDomainResponse) GoString 

func (this *RegisterDomainResponse) GoString() string

func (*RegisterDomainResponse) Marshal 

func (m *RegisterDomainResponse) Marshal() (dAtA []byte, err error)

func (*RegisterDomainResponse) MarshalTo 

func (m *RegisterDomainResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterDomainResponse) MarshalToSizedBuffer 

func (m *RegisterDomainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterDomainResponse) ProtoMessage 

func (*RegisterDomainResponse) ProtoMessage()

func (*RegisterDomainResponse) Reset 

func (m *RegisterDomainResponse) Reset()

func (*RegisterDomainResponse) Size 

func (m *RegisterDomainResponse) Size() (n int)

func (*RegisterDomainResponse) String 

func (this *RegisterDomainResponse) String() string

func (*RegisterDomainResponse) Unmarshal 

func (m *RegisterDomainResponse) Unmarshal(dAtA []byte) error

func (*RegisterDomainResponse) XXX_DiscardUnknown 

func (m *RegisterDomainResponse) XXX_DiscardUnknown()

func (*RegisterDomainResponse) XXX_Marshal 

func (m *RegisterDomainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterDomainResponse) XXX_Merge 

func (m *RegisterDomainResponse) XXX_Merge(src proto.Message)

func (*RegisterDomainResponse) XXX_Size 

func (m *RegisterDomainResponse) XXX_Size() int

func (*RegisterDomainResponse) XXX_Unmarshal 

func (m *RegisterDomainResponse) XXX_Unmarshal(b []byte) error

type RequestCancelWorkflowExecutionRequest 

type RequestCancelWorkflowExecutionRequest struct {
	Domain            string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	Identity          string                    `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId         string                    `protobuf:"bytes,4,opt,name=requestId,proto3" json:"requestId,omitempty"`
}

func (*RequestCancelWorkflowExecutionRequest) Descriptor 

func (*RequestCancelWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*RequestCancelWorkflowExecutionRequest) Equal 

func (this *RequestCancelWorkflowExecutionRequest) Equal(that interface{}) bool

func (*RequestCancelWorkflowExecutionRequest) GetDomain 

func (m *RequestCancelWorkflowExecutionRequest) GetDomain() string

func (*RequestCancelWorkflowExecutionRequest) GetIdentity 

func (m *RequestCancelWorkflowExecutionRequest) GetIdentity() string

func (*RequestCancelWorkflowExecutionRequest) GetRequestId 

func (m *RequestCancelWorkflowExecutionRequest) GetRequestId() string

func (*RequestCancelWorkflowExecutionRequest) GetWorkflowExecution 

func (m *RequestCancelWorkflowExecutionRequest) GetWorkflowExecution() *common.WorkflowExecution

func (*RequestCancelWorkflowExecutionRequest) GoString 

func (this *RequestCancelWorkflowExecutionRequest) GoString() string

func (*RequestCancelWorkflowExecutionRequest) Marshal 

func (m *RequestCancelWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*RequestCancelWorkflowExecutionRequest) MarshalTo 

func (m *RequestCancelWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*RequestCancelWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *RequestCancelWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage 

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

func (*RequestCancelWorkflowExecutionRequest) Reset 

func (m *RequestCancelWorkflowExecutionRequest) Reset()

func (*RequestCancelWorkflowExecutionRequest) Size 

func (m *RequestCancelWorkflowExecutionRequest) Size() (n int)

func (*RequestCancelWorkflowExecutionRequest) String 

func (this *RequestCancelWorkflowExecutionRequest) String() string

func (*RequestCancelWorkflowExecutionRequest) Unmarshal 

func (m *RequestCancelWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*RequestCancelWorkflowExecutionRequest) XXX_Marshal 

func (m *RequestCancelWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestCancelWorkflowExecutionRequest) XXX_Merge 

func (m *RequestCancelWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*RequestCancelWorkflowExecutionRequest) XXX_Size 

func (m *RequestCancelWorkflowExecutionRequest) XXX_Size() int

func (*RequestCancelWorkflowExecutionRequest) XXX_Unmarshal 

func (m *RequestCancelWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type RequestCancelWorkflowExecutionResponse 

type RequestCancelWorkflowExecutionResponse struct {
}

func (*RequestCancelWorkflowExecutionResponse) Descriptor 

func (*RequestCancelWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*RequestCancelWorkflowExecutionResponse) Equal 

func (this *RequestCancelWorkflowExecutionResponse) Equal(that interface{}) bool

func (*RequestCancelWorkflowExecutionResponse) GoString 

func (this *RequestCancelWorkflowExecutionResponse) GoString() string

func (*RequestCancelWorkflowExecutionResponse) Marshal 

func (m *RequestCancelWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*RequestCancelWorkflowExecutionResponse) MarshalTo 

func (m *RequestCancelWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*RequestCancelWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *RequestCancelWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage 

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage()

func (*RequestCancelWorkflowExecutionResponse) Reset 

func (m *RequestCancelWorkflowExecutionResponse) Reset()

func (*RequestCancelWorkflowExecutionResponse) Size 

func (m *RequestCancelWorkflowExecutionResponse) Size() (n int)

func (*RequestCancelWorkflowExecutionResponse) String 

func (this *RequestCancelWorkflowExecutionResponse) String() string

func (*RequestCancelWorkflowExecutionResponse) Unmarshal 

func (m *RequestCancelWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*RequestCancelWorkflowExecutionResponse) XXX_Marshal 

func (m *RequestCancelWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestCancelWorkflowExecutionResponse) XXX_Merge 

func (m *RequestCancelWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*RequestCancelWorkflowExecutionResponse) XXX_Size 

func (m *RequestCancelWorkflowExecutionResponse) XXX_Size() int

func (*RequestCancelWorkflowExecutionResponse) XXX_Unmarshal 

func (m *RequestCancelWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type ResetStickyTaskListRequest 

type ResetStickyTaskListRequest struct {
	Domain    string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Execution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*ResetStickyTaskListRequest) Descriptor 

func (*ResetStickyTaskListRequest) Descriptor() ([]byte, []int)

func (*ResetStickyTaskListRequest) Equal 

func (this *ResetStickyTaskListRequest) Equal(that interface{}) bool

func (*ResetStickyTaskListRequest) GetDomain 

func (m *ResetStickyTaskListRequest) GetDomain() string

func (*ResetStickyTaskListRequest) GetExecution 

func (m *ResetStickyTaskListRequest) GetExecution() *common.WorkflowExecution

func (*ResetStickyTaskListRequest) GoString 

func (this *ResetStickyTaskListRequest) GoString() string

func (*ResetStickyTaskListRequest) Marshal 

func (m *ResetStickyTaskListRequest) Marshal() (dAtA []byte, err error)

func (*ResetStickyTaskListRequest) MarshalTo 

func (m *ResetStickyTaskListRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResetStickyTaskListRequest) MarshalToSizedBuffer 

func (m *ResetStickyTaskListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetStickyTaskListRequest) ProtoMessage 

func (*ResetStickyTaskListRequest) ProtoMessage()

func (*ResetStickyTaskListRequest) Reset 

func (m *ResetStickyTaskListRequest) Reset()

func (*ResetStickyTaskListRequest) Size 

func (m *ResetStickyTaskListRequest) Size() (n int)

func (*ResetStickyTaskListRequest) String 

func (this *ResetStickyTaskListRequest) String() string

func (*ResetStickyTaskListRequest) Unmarshal 

func (m *ResetStickyTaskListRequest) Unmarshal(dAtA []byte) error

func (*ResetStickyTaskListRequest) XXX_DiscardUnknown 

func (m *ResetStickyTaskListRequest) XXX_DiscardUnknown()

func (*ResetStickyTaskListRequest) XXX_Marshal 

func (m *ResetStickyTaskListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetStickyTaskListRequest) XXX_Merge 

func (m *ResetStickyTaskListRequest) XXX_Merge(src proto.Message)

func (*ResetStickyTaskListRequest) XXX_Size 

func (m *ResetStickyTaskListRequest) XXX_Size() int

func (*ResetStickyTaskListRequest) XXX_Unmarshal 

func (m *ResetStickyTaskListRequest) XXX_Unmarshal(b []byte) error

type ResetStickyTaskListResponse 

type ResetStickyTaskListResponse struct {
}

func (*ResetStickyTaskListResponse) Descriptor 

func (*ResetStickyTaskListResponse) Descriptor() ([]byte, []int)

func (*ResetStickyTaskListResponse) Equal 

func (this *ResetStickyTaskListResponse) Equal(that interface{}) bool

func (*ResetStickyTaskListResponse) GoString 

func (this *ResetStickyTaskListResponse) GoString() string

func (*ResetStickyTaskListResponse) Marshal 

func (m *ResetStickyTaskListResponse) Marshal() (dAtA []byte, err error)

func (*ResetStickyTaskListResponse) MarshalTo 

func (m *ResetStickyTaskListResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResetStickyTaskListResponse) MarshalToSizedBuffer 

func (m *ResetStickyTaskListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetStickyTaskListResponse) ProtoMessage 

func (*ResetStickyTaskListResponse) ProtoMessage()

func (*ResetStickyTaskListResponse) Reset 

func (m *ResetStickyTaskListResponse) Reset()

func (*ResetStickyTaskListResponse) Size 

func (m *ResetStickyTaskListResponse) Size() (n int)

func (*ResetStickyTaskListResponse) String 

func (this *ResetStickyTaskListResponse) String() string

func (*ResetStickyTaskListResponse) Unmarshal 

func (m *ResetStickyTaskListResponse) Unmarshal(dAtA []byte) error

func (*ResetStickyTaskListResponse) XXX_DiscardUnknown 

func (m *ResetStickyTaskListResponse) XXX_DiscardUnknown()

func (*ResetStickyTaskListResponse) XXX_Marshal 

func (m *ResetStickyTaskListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetStickyTaskListResponse) XXX_Merge 

func (m *ResetStickyTaskListResponse) XXX_Merge(src proto.Message)

func (*ResetStickyTaskListResponse) XXX_Size 

func (m *ResetStickyTaskListResponse) XXX_Size() int

func (*ResetStickyTaskListResponse) XXX_Unmarshal 

func (m *ResetStickyTaskListResponse) XXX_Unmarshal(b []byte) error

type ResetWorkflowExecutionRequest 

type ResetWorkflowExecutionRequest struct {
	Domain                string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution     *common.WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	Reason                string                    `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	DecisionFinishEventId int64                     `protobuf:"varint,4,opt,name=decisionFinishEventId,proto3" json:"decisionFinishEventId,omitempty"`
	RequestId             string                    `protobuf:"bytes,5,opt,name=requestId,proto3" json:"requestId,omitempty"`
}

func (*ResetWorkflowExecutionRequest) Descriptor 

func (*ResetWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*ResetWorkflowExecutionRequest) Equal 

func (this *ResetWorkflowExecutionRequest) Equal(that interface{}) bool

func (*ResetWorkflowExecutionRequest) GetDecisionFinishEventId 

func (m *ResetWorkflowExecutionRequest) GetDecisionFinishEventId() int64

func (*ResetWorkflowExecutionRequest) GetDomain 

func (m *ResetWorkflowExecutionRequest) GetDomain() string

func (*ResetWorkflowExecutionRequest) GetReason 

func (m *ResetWorkflowExecutionRequest) GetReason() string

func (*ResetWorkflowExecutionRequest) GetRequestId 

func (m *ResetWorkflowExecutionRequest) GetRequestId() string

func (*ResetWorkflowExecutionRequest) GetWorkflowExecution 

func (m *ResetWorkflowExecutionRequest) GetWorkflowExecution() *common.WorkflowExecution

func (*ResetWorkflowExecutionRequest) GoString 

func (this *ResetWorkflowExecutionRequest) GoString() string

func (*ResetWorkflowExecutionRequest) Marshal 

func (m *ResetWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*ResetWorkflowExecutionRequest) MarshalTo 

func (m *ResetWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResetWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *ResetWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetWorkflowExecutionRequest) ProtoMessage 

func (*ResetWorkflowExecutionRequest) ProtoMessage()

func (*ResetWorkflowExecutionRequest) Reset 

func (m *ResetWorkflowExecutionRequest) Reset()

func (*ResetWorkflowExecutionRequest) Size 

func (m *ResetWorkflowExecutionRequest) Size() (n int)

func (*ResetWorkflowExecutionRequest) String 

func (this *ResetWorkflowExecutionRequest) String() string

func (*ResetWorkflowExecutionRequest) Unmarshal 

func (m *ResetWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*ResetWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *ResetWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionRequest) XXX_Marshal 

func (m *ResetWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetWorkflowExecutionRequest) XXX_Merge 

func (m *ResetWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*ResetWorkflowExecutionRequest) XXX_Size 

func (m *ResetWorkflowExecutionRequest) XXX_Size() int

func (*ResetWorkflowExecutionRequest) XXX_Unmarshal 

func (m *ResetWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type ResetWorkflowExecutionResponse 

type ResetWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=runId,proto3" json:"runId,omitempty"`
}

func (*ResetWorkflowExecutionResponse) Descriptor 

func (*ResetWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*ResetWorkflowExecutionResponse) Equal 

func (this *ResetWorkflowExecutionResponse) Equal(that interface{}) bool

func (*ResetWorkflowExecutionResponse) GetRunId 

func (m *ResetWorkflowExecutionResponse) GetRunId() string

func (*ResetWorkflowExecutionResponse) GoString 

func (this *ResetWorkflowExecutionResponse) GoString() string

func (*ResetWorkflowExecutionResponse) Marshal 

func (m *ResetWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*ResetWorkflowExecutionResponse) MarshalTo 

func (m *ResetWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResetWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *ResetWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetWorkflowExecutionResponse) ProtoMessage 

func (*ResetWorkflowExecutionResponse) ProtoMessage()

func (*ResetWorkflowExecutionResponse) Reset 

func (m *ResetWorkflowExecutionResponse) Reset()

func (*ResetWorkflowExecutionResponse) Size 

func (m *ResetWorkflowExecutionResponse) Size() (n int)

func (*ResetWorkflowExecutionResponse) String 

func (this *ResetWorkflowExecutionResponse) String() string

func (*ResetWorkflowExecutionResponse) Unmarshal 

func (m *ResetWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*ResetWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *ResetWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionResponse) XXX_Marshal 

func (m *ResetWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetWorkflowExecutionResponse) XXX_Merge 

func (m *ResetWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*ResetWorkflowExecutionResponse) XXX_Size 

func (m *ResetWorkflowExecutionResponse) XXX_Size() int

func (*ResetWorkflowExecutionResponse) XXX_Unmarshal 

func (m *ResetWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCanceledByIDRequest 

type RespondActivityTaskCanceledByIDRequest struct {
	Domain     string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowID string `protobuf:"bytes,2,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	RunID      string `protobuf:"bytes,3,opt,name=runID,proto3" json:"runID,omitempty"`
	ActivityID string `protobuf:"bytes,4,opt,name=activityID,proto3" json:"activityID,omitempty"`
	Details    []byte `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	Identity   string `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCanceledByIDRequest) Descriptor 

func (*RespondActivityTaskCanceledByIDRequest) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCanceledByIDRequest) Equal 

func (this *RespondActivityTaskCanceledByIDRequest) Equal(that interface{}) bool

func (*RespondActivityTaskCanceledByIDRequest) GetActivityID 

func (m *RespondActivityTaskCanceledByIDRequest) GetActivityID() string

func (*RespondActivityTaskCanceledByIDRequest) GetDetails 

func (m *RespondActivityTaskCanceledByIDRequest) GetDetails() []byte

func (*RespondActivityTaskCanceledByIDRequest) GetDomain 

func (m *RespondActivityTaskCanceledByIDRequest) GetDomain() string

func (*RespondActivityTaskCanceledByIDRequest) GetIdentity 

func (m *RespondActivityTaskCanceledByIDRequest) GetIdentity() string

func (*RespondActivityTaskCanceledByIDRequest) GetRunID 

func (m *RespondActivityTaskCanceledByIDRequest) GetRunID() string

func (*RespondActivityTaskCanceledByIDRequest) GetWorkflowID 

func (m *RespondActivityTaskCanceledByIDRequest) GetWorkflowID() string

func (*RespondActivityTaskCanceledByIDRequest) GoString 

func (this *RespondActivityTaskCanceledByIDRequest) GoString() string

func (*RespondActivityTaskCanceledByIDRequest) Marshal 

func (m *RespondActivityTaskCanceledByIDRequest) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCanceledByIDRequest) MarshalTo 

func (m *RespondActivityTaskCanceledByIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledByIDRequest) MarshalToSizedBuffer 

func (m *RespondActivityTaskCanceledByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledByIDRequest) ProtoMessage 

func (*RespondActivityTaskCanceledByIDRequest) ProtoMessage()

func (*RespondActivityTaskCanceledByIDRequest) Reset 

func (m *RespondActivityTaskCanceledByIDRequest) Reset()

func (*RespondActivityTaskCanceledByIDRequest) Size 

func (m *RespondActivityTaskCanceledByIDRequest) Size() (n int)

func (*RespondActivityTaskCanceledByIDRequest) String 

func (this *RespondActivityTaskCanceledByIDRequest) String() string

func (*RespondActivityTaskCanceledByIDRequest) Unmarshal 

func (m *RespondActivityTaskCanceledByIDRequest) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCanceledByIDRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledByIDRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledByIDRequest) XXX_Marshal 

func (m *RespondActivityTaskCanceledByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCanceledByIDRequest) XXX_Merge 

func (m *RespondActivityTaskCanceledByIDRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCanceledByIDRequest) XXX_Size 

func (m *RespondActivityTaskCanceledByIDRequest) XXX_Size() int

func (*RespondActivityTaskCanceledByIDRequest) XXX_Unmarshal 

func (m *RespondActivityTaskCanceledByIDRequest) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCanceledByIDResponse 

type RespondActivityTaskCanceledByIDResponse struct {
}

func (*RespondActivityTaskCanceledByIDResponse) Descriptor 

func (*RespondActivityTaskCanceledByIDResponse) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCanceledByIDResponse) Equal 

func (this *RespondActivityTaskCanceledByIDResponse) Equal(that interface{}) bool

func (*RespondActivityTaskCanceledByIDResponse) GoString 

func (this *RespondActivityTaskCanceledByIDResponse) GoString() string

func (*RespondActivityTaskCanceledByIDResponse) Marshal 

func (m *RespondActivityTaskCanceledByIDResponse) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCanceledByIDResponse) MarshalTo 

func (m *RespondActivityTaskCanceledByIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledByIDResponse) MarshalToSizedBuffer 

func (m *RespondActivityTaskCanceledByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledByIDResponse) ProtoMessage 

func (*RespondActivityTaskCanceledByIDResponse) ProtoMessage()

func (*RespondActivityTaskCanceledByIDResponse) Reset 

func (m *RespondActivityTaskCanceledByIDResponse) Reset()

func (*RespondActivityTaskCanceledByIDResponse) Size 

func (m *RespondActivityTaskCanceledByIDResponse) Size() (n int)

func (*RespondActivityTaskCanceledByIDResponse) String 

func (this *RespondActivityTaskCanceledByIDResponse) String() string

func (*RespondActivityTaskCanceledByIDResponse) Unmarshal 

func (m *RespondActivityTaskCanceledByIDResponse) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCanceledByIDResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledByIDResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledByIDResponse) XXX_Marshal 

func (m *RespondActivityTaskCanceledByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCanceledByIDResponse) XXX_Merge 

func (m *RespondActivityTaskCanceledByIDResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCanceledByIDResponse) XXX_Size 

func (m *RespondActivityTaskCanceledByIDResponse) XXX_Size() int

func (*RespondActivityTaskCanceledByIDResponse) XXX_Unmarshal 

func (m *RespondActivityTaskCanceledByIDResponse) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCanceledRequest 

type RespondActivityTaskCanceledRequest struct {
	TaskToken []byte `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	Details   []byte `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCanceledRequest) Descriptor 

func (*RespondActivityTaskCanceledRequest) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCanceledRequest) Equal 

func (this *RespondActivityTaskCanceledRequest) Equal(that interface{}) bool

func (*RespondActivityTaskCanceledRequest) GetDetails 

func (m *RespondActivityTaskCanceledRequest) GetDetails() []byte

func (*RespondActivityTaskCanceledRequest) GetIdentity 

func (m *RespondActivityTaskCanceledRequest) GetIdentity() string

func (*RespondActivityTaskCanceledRequest) GetTaskToken 

func (m *RespondActivityTaskCanceledRequest) GetTaskToken() []byte

func (*RespondActivityTaskCanceledRequest) GoString 

func (this *RespondActivityTaskCanceledRequest) GoString() string

func (*RespondActivityTaskCanceledRequest) Marshal 

func (m *RespondActivityTaskCanceledRequest) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCanceledRequest) MarshalTo 

func (m *RespondActivityTaskCanceledRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledRequest) MarshalToSizedBuffer 

func (m *RespondActivityTaskCanceledRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledRequest) ProtoMessage 

func (*RespondActivityTaskCanceledRequest) ProtoMessage()

func (*RespondActivityTaskCanceledRequest) Reset 

func (m *RespondActivityTaskCanceledRequest) Reset()

func (*RespondActivityTaskCanceledRequest) Size 

func (m *RespondActivityTaskCanceledRequest) Size() (n int)

func (*RespondActivityTaskCanceledRequest) String 

func (this *RespondActivityTaskCanceledRequest) String() string

func (*RespondActivityTaskCanceledRequest) Unmarshal 

func (m *RespondActivityTaskCanceledRequest) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCanceledRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledRequest) XXX_Marshal 

func (m *RespondActivityTaskCanceledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCanceledRequest) XXX_Merge 

func (m *RespondActivityTaskCanceledRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCanceledRequest) XXX_Size 

func (m *RespondActivityTaskCanceledRequest) XXX_Size() int

func (*RespondActivityTaskCanceledRequest) XXX_Unmarshal 

func (m *RespondActivityTaskCanceledRequest) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCanceledResponse 

type RespondActivityTaskCanceledResponse struct {
}

func (*RespondActivityTaskCanceledResponse) Descriptor 

func (*RespondActivityTaskCanceledResponse) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCanceledResponse) Equal 

func (this *RespondActivityTaskCanceledResponse) Equal(that interface{}) bool

func (*RespondActivityTaskCanceledResponse) GoString 

func (this *RespondActivityTaskCanceledResponse) GoString() string

func (*RespondActivityTaskCanceledResponse) Marshal 

func (m *RespondActivityTaskCanceledResponse) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCanceledResponse) MarshalTo 

func (m *RespondActivityTaskCanceledResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledResponse) MarshalToSizedBuffer 

func (m *RespondActivityTaskCanceledResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCanceledResponse) ProtoMessage 

func (*RespondActivityTaskCanceledResponse) ProtoMessage()

func (*RespondActivityTaskCanceledResponse) Reset 

func (m *RespondActivityTaskCanceledResponse) Reset()

func (*RespondActivityTaskCanceledResponse) Size 

func (m *RespondActivityTaskCanceledResponse) Size() (n int)

func (*RespondActivityTaskCanceledResponse) String 

func (this *RespondActivityTaskCanceledResponse) String() string

func (*RespondActivityTaskCanceledResponse) Unmarshal 

func (m *RespondActivityTaskCanceledResponse) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCanceledResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledResponse) XXX_Marshal 

func (m *RespondActivityTaskCanceledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCanceledResponse) XXX_Merge 

func (m *RespondActivityTaskCanceledResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCanceledResponse) XXX_Size 

func (m *RespondActivityTaskCanceledResponse) XXX_Size() int

func (*RespondActivityTaskCanceledResponse) XXX_Unmarshal 

func (m *RespondActivityTaskCanceledResponse) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCompletedByIDRequest 

type RespondActivityTaskCompletedByIDRequest struct {
	Domain     string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowID string `protobuf:"bytes,2,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	RunID      string `protobuf:"bytes,3,opt,name=runID,proto3" json:"runID,omitempty"`
	ActivityID string `protobuf:"bytes,4,opt,name=activityID,proto3" json:"activityID,omitempty"`
	Result     []byte `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	Identity   string `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCompletedByIDRequest) Descriptor 

func (*RespondActivityTaskCompletedByIDRequest) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCompletedByIDRequest) Equal 

func (this *RespondActivityTaskCompletedByIDRequest) Equal(that interface{}) bool

func (*RespondActivityTaskCompletedByIDRequest) GetActivityID 

func (m *RespondActivityTaskCompletedByIDRequest) GetActivityID() string

func (*RespondActivityTaskCompletedByIDRequest) GetDomain 

func (m *RespondActivityTaskCompletedByIDRequest) GetDomain() string

func (*RespondActivityTaskCompletedByIDRequest) GetIdentity 

func (m *RespondActivityTaskCompletedByIDRequest) GetIdentity() string

func (*RespondActivityTaskCompletedByIDRequest) GetResult 

func (m *RespondActivityTaskCompletedByIDRequest) GetResult() []byte

func (*RespondActivityTaskCompletedByIDRequest) GetRunID 

func (m *RespondActivityTaskCompletedByIDRequest) GetRunID() string

func (*RespondActivityTaskCompletedByIDRequest) GetWorkflowID 

func (m *RespondActivityTaskCompletedByIDRequest) GetWorkflowID() string

func (*RespondActivityTaskCompletedByIDRequest) GoString 

func (this *RespondActivityTaskCompletedByIDRequest) GoString() string

func (*RespondActivityTaskCompletedByIDRequest) Marshal 

func (m *RespondActivityTaskCompletedByIDRequest) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCompletedByIDRequest) MarshalTo 

func (m *RespondActivityTaskCompletedByIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedByIDRequest) MarshalToSizedBuffer 

func (m *RespondActivityTaskCompletedByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedByIDRequest) ProtoMessage 

func (*RespondActivityTaskCompletedByIDRequest) ProtoMessage()

func (*RespondActivityTaskCompletedByIDRequest) Reset 

func (m *RespondActivityTaskCompletedByIDRequest) Reset()

func (*RespondActivityTaskCompletedByIDRequest) Size 

func (m *RespondActivityTaskCompletedByIDRequest) Size() (n int)

func (*RespondActivityTaskCompletedByIDRequest) String 

func (this *RespondActivityTaskCompletedByIDRequest) String() string

func (*RespondActivityTaskCompletedByIDRequest) Unmarshal 

func (m *RespondActivityTaskCompletedByIDRequest) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCompletedByIDRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedByIDRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedByIDRequest) XXX_Marshal 

func (m *RespondActivityTaskCompletedByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCompletedByIDRequest) XXX_Merge 

func (m *RespondActivityTaskCompletedByIDRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCompletedByIDRequest) XXX_Size 

func (m *RespondActivityTaskCompletedByIDRequest) XXX_Size() int

func (*RespondActivityTaskCompletedByIDRequest) XXX_Unmarshal 

func (m *RespondActivityTaskCompletedByIDRequest) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCompletedByIDResponse 

type RespondActivityTaskCompletedByIDResponse struct {
}

func (*RespondActivityTaskCompletedByIDResponse) Descriptor 

func (*RespondActivityTaskCompletedByIDResponse) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCompletedByIDResponse) Equal 

func (this *RespondActivityTaskCompletedByIDResponse) Equal(that interface{}) bool

func (*RespondActivityTaskCompletedByIDResponse) GoString 

func (this *RespondActivityTaskCompletedByIDResponse) GoString() string

func (*RespondActivityTaskCompletedByIDResponse) Marshal 

func (m *RespondActivityTaskCompletedByIDResponse) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCompletedByIDResponse) MarshalTo 

func (m *RespondActivityTaskCompletedByIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedByIDResponse) MarshalToSizedBuffer 

func (m *RespondActivityTaskCompletedByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedByIDResponse) ProtoMessage 

func (*RespondActivityTaskCompletedByIDResponse) ProtoMessage()

func (*RespondActivityTaskCompletedByIDResponse) Reset 

func (m *RespondActivityTaskCompletedByIDResponse) Reset()

func (*RespondActivityTaskCompletedByIDResponse) Size 

func (m *RespondActivityTaskCompletedByIDResponse) Size() (n int)

func (*RespondActivityTaskCompletedByIDResponse) String 

func (this *RespondActivityTaskCompletedByIDResponse) String() string

func (*RespondActivityTaskCompletedByIDResponse) Unmarshal 

func (m *RespondActivityTaskCompletedByIDResponse) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCompletedByIDResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedByIDResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedByIDResponse) XXX_Marshal 

func (m *RespondActivityTaskCompletedByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCompletedByIDResponse) XXX_Merge 

func (m *RespondActivityTaskCompletedByIDResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCompletedByIDResponse) XXX_Size 

func (m *RespondActivityTaskCompletedByIDResponse) XXX_Size() int

func (*RespondActivityTaskCompletedByIDResponse) XXX_Unmarshal 

func (m *RespondActivityTaskCompletedByIDResponse) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCompletedRequest 

type RespondActivityTaskCompletedRequest struct {
	TaskToken []byte `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	Result    []byte `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCompletedRequest) Descriptor 

func (*RespondActivityTaskCompletedRequest) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCompletedRequest) Equal 

func (this *RespondActivityTaskCompletedRequest) Equal(that interface{}) bool

func (*RespondActivityTaskCompletedRequest) GetIdentity 

func (m *RespondActivityTaskCompletedRequest) GetIdentity() string

func (*RespondActivityTaskCompletedRequest) GetResult 

func (m *RespondActivityTaskCompletedRequest) GetResult() []byte

func (*RespondActivityTaskCompletedRequest) GetTaskToken 

func (m *RespondActivityTaskCompletedRequest) GetTaskToken() []byte

func (*RespondActivityTaskCompletedRequest) GoString 

func (this *RespondActivityTaskCompletedRequest) GoString() string

func (*RespondActivityTaskCompletedRequest) Marshal 

func (m *RespondActivityTaskCompletedRequest) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCompletedRequest) MarshalTo 

func (m *RespondActivityTaskCompletedRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedRequest) MarshalToSizedBuffer 

func (m *RespondActivityTaskCompletedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedRequest) ProtoMessage 

func (*RespondActivityTaskCompletedRequest) ProtoMessage()

func (*RespondActivityTaskCompletedRequest) Reset 

func (m *RespondActivityTaskCompletedRequest) Reset()

func (*RespondActivityTaskCompletedRequest) Size 

func (m *RespondActivityTaskCompletedRequest) Size() (n int)

func (*RespondActivityTaskCompletedRequest) String 

func (this *RespondActivityTaskCompletedRequest) String() string

func (*RespondActivityTaskCompletedRequest) Unmarshal 

func (m *RespondActivityTaskCompletedRequest) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedRequest) XXX_Marshal 

func (m *RespondActivityTaskCompletedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCompletedRequest) XXX_Merge 

func (m *RespondActivityTaskCompletedRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCompletedRequest) XXX_Size 

func (m *RespondActivityTaskCompletedRequest) XXX_Size() int

func (*RespondActivityTaskCompletedRequest) XXX_Unmarshal 

func (m *RespondActivityTaskCompletedRequest) XXX_Unmarshal(b []byte) error

type RespondActivityTaskCompletedResponse 

type RespondActivityTaskCompletedResponse struct {
}

func (*RespondActivityTaskCompletedResponse) Descriptor 

func (*RespondActivityTaskCompletedResponse) Descriptor() ([]byte, []int)

func (*RespondActivityTaskCompletedResponse) Equal 

func (this *RespondActivityTaskCompletedResponse) Equal(that interface{}) bool

func (*RespondActivityTaskCompletedResponse) GoString 

func (this *RespondActivityTaskCompletedResponse) GoString() string

func (*RespondActivityTaskCompletedResponse) Marshal 

func (m *RespondActivityTaskCompletedResponse) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskCompletedResponse) MarshalTo 

func (m *RespondActivityTaskCompletedResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedResponse) MarshalToSizedBuffer 

func (m *RespondActivityTaskCompletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskCompletedResponse) ProtoMessage 

func (*RespondActivityTaskCompletedResponse) ProtoMessage()

func (*RespondActivityTaskCompletedResponse) Reset 

func (m *RespondActivityTaskCompletedResponse) Reset()

func (*RespondActivityTaskCompletedResponse) Size 

func (m *RespondActivityTaskCompletedResponse) Size() (n int)

func (*RespondActivityTaskCompletedResponse) String 

func (this *RespondActivityTaskCompletedResponse) String() string

func (*RespondActivityTaskCompletedResponse) Unmarshal 

func (m *RespondActivityTaskCompletedResponse) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedResponse) XXX_Marshal 

func (m *RespondActivityTaskCompletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskCompletedResponse) XXX_Merge 

func (m *RespondActivityTaskCompletedResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCompletedResponse) XXX_Size 

func (m *RespondActivityTaskCompletedResponse) XXX_Size() int

func (*RespondActivityTaskCompletedResponse) XXX_Unmarshal 

func (m *RespondActivityTaskCompletedResponse) XXX_Unmarshal(b []byte) error

type RespondActivityTaskFailedByIDRequest 

type RespondActivityTaskFailedByIDRequest struct {
	Domain     string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowID string `protobuf:"bytes,2,opt,name=workflowID,proto3" json:"workflowID,omitempty"`
	RunID      string `protobuf:"bytes,3,opt,name=runID,proto3" json:"runID,omitempty"`
	ActivityID string `protobuf:"bytes,4,opt,name=activityID,proto3" json:"activityID,omitempty"`
	Reason     string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	Details    []byte `protobuf:"bytes,6,opt,name=details,proto3" json:"details,omitempty"`
	Identity   string `protobuf:"bytes,7,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskFailedByIDRequest) Descriptor 

func (*RespondActivityTaskFailedByIDRequest) Descriptor() ([]byte, []int)

func (*RespondActivityTaskFailedByIDRequest) Equal 

func (this *RespondActivityTaskFailedByIDRequest) Equal(that interface{}) bool

func (*RespondActivityTaskFailedByIDRequest) GetActivityID 

func (m *RespondActivityTaskFailedByIDRequest) GetActivityID() string

func (*RespondActivityTaskFailedByIDRequest) GetDetails 

func (m *RespondActivityTaskFailedByIDRequest) GetDetails() []byte

func (*RespondActivityTaskFailedByIDRequest) GetDomain 

func (m *RespondActivityTaskFailedByIDRequest) GetDomain() string

func (*RespondActivityTaskFailedByIDRequest) GetIdentity 

func (m *RespondActivityTaskFailedByIDRequest) GetIdentity() string

func (*RespondActivityTaskFailedByIDRequest) GetReason 

func (m *RespondActivityTaskFailedByIDRequest) GetReason() string

func (*RespondActivityTaskFailedByIDRequest) GetRunID 

func (m *RespondActivityTaskFailedByIDRequest) GetRunID() string

func (*RespondActivityTaskFailedByIDRequest) GetWorkflowID 

func (m *RespondActivityTaskFailedByIDRequest) GetWorkflowID() string

func (*RespondActivityTaskFailedByIDRequest) GoString 

func (this *RespondActivityTaskFailedByIDRequest) GoString() string

func (*RespondActivityTaskFailedByIDRequest) Marshal 

func (m *RespondActivityTaskFailedByIDRequest) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskFailedByIDRequest) MarshalTo 

func (m *RespondActivityTaskFailedByIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedByIDRequest) MarshalToSizedBuffer 

func (m *RespondActivityTaskFailedByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedByIDRequest) ProtoMessage 

func (*RespondActivityTaskFailedByIDRequest) ProtoMessage()

func (*RespondActivityTaskFailedByIDRequest) Reset 

func (m *RespondActivityTaskFailedByIDRequest) Reset()

func (*RespondActivityTaskFailedByIDRequest) Size 

func (m *RespondActivityTaskFailedByIDRequest) Size() (n int)

func (*RespondActivityTaskFailedByIDRequest) String 

func (this *RespondActivityTaskFailedByIDRequest) String() string

func (*RespondActivityTaskFailedByIDRequest) Unmarshal 

func (m *RespondActivityTaskFailedByIDRequest) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskFailedByIDRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedByIDRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedByIDRequest) XXX_Marshal 

func (m *RespondActivityTaskFailedByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskFailedByIDRequest) XXX_Merge 

func (m *RespondActivityTaskFailedByIDRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskFailedByIDRequest) XXX_Size 

func (m *RespondActivityTaskFailedByIDRequest) XXX_Size() int

func (*RespondActivityTaskFailedByIDRequest) XXX_Unmarshal 

func (m *RespondActivityTaskFailedByIDRequest) XXX_Unmarshal(b []byte) error

type RespondActivityTaskFailedByIDResponse 

type RespondActivityTaskFailedByIDResponse struct {
}

func (*RespondActivityTaskFailedByIDResponse) Descriptor 

func (*RespondActivityTaskFailedByIDResponse) Descriptor() ([]byte, []int)

func (*RespondActivityTaskFailedByIDResponse) Equal 

func (this *RespondActivityTaskFailedByIDResponse) Equal(that interface{}) bool

func (*RespondActivityTaskFailedByIDResponse) GoString 

func (this *RespondActivityTaskFailedByIDResponse) GoString() string

func (*RespondActivityTaskFailedByIDResponse) Marshal 

func (m *RespondActivityTaskFailedByIDResponse) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskFailedByIDResponse) MarshalTo 

func (m *RespondActivityTaskFailedByIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedByIDResponse) MarshalToSizedBuffer 

func (m *RespondActivityTaskFailedByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedByIDResponse) ProtoMessage 

func (*RespondActivityTaskFailedByIDResponse) ProtoMessage()

func (*RespondActivityTaskFailedByIDResponse) Reset 

func (m *RespondActivityTaskFailedByIDResponse) Reset()

func (*RespondActivityTaskFailedByIDResponse) Size 

func (m *RespondActivityTaskFailedByIDResponse) Size() (n int)

func (*RespondActivityTaskFailedByIDResponse) String 

func (this *RespondActivityTaskFailedByIDResponse) String() string

func (*RespondActivityTaskFailedByIDResponse) Unmarshal 

func (m *RespondActivityTaskFailedByIDResponse) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskFailedByIDResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedByIDResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedByIDResponse) XXX_Marshal 

func (m *RespondActivityTaskFailedByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskFailedByIDResponse) XXX_Merge 

func (m *RespondActivityTaskFailedByIDResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskFailedByIDResponse) XXX_Size 

func (m *RespondActivityTaskFailedByIDResponse) XXX_Size() int

func (*RespondActivityTaskFailedByIDResponse) XXX_Unmarshal 

func (m *RespondActivityTaskFailedByIDResponse) XXX_Unmarshal(b []byte) error

type RespondActivityTaskFailedRequest 

type RespondActivityTaskFailedRequest struct {
	TaskToken []byte `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	Reason    string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Details   []byte `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	Identity  string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskFailedRequest) Descriptor 

func (*RespondActivityTaskFailedRequest) Descriptor() ([]byte, []int)

func (*RespondActivityTaskFailedRequest) Equal 

func (this *RespondActivityTaskFailedRequest) Equal(that interface{}) bool

func (*RespondActivityTaskFailedRequest) GetDetails 

func (m *RespondActivityTaskFailedRequest) GetDetails() []byte

func (*RespondActivityTaskFailedRequest) GetIdentity 

func (m *RespondActivityTaskFailedRequest) GetIdentity() string

func (*RespondActivityTaskFailedRequest) GetReason 

func (m *RespondActivityTaskFailedRequest) GetReason() string

func (*RespondActivityTaskFailedRequest) GetTaskToken 

func (m *RespondActivityTaskFailedRequest) GetTaskToken() []byte

func (*RespondActivityTaskFailedRequest) GoString 

func (this *RespondActivityTaskFailedRequest) GoString() string

func (*RespondActivityTaskFailedRequest) Marshal 

func (m *RespondActivityTaskFailedRequest) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskFailedRequest) MarshalTo 

func (m *RespondActivityTaskFailedRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedRequest) MarshalToSizedBuffer 

func (m *RespondActivityTaskFailedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedRequest) ProtoMessage 

func (*RespondActivityTaskFailedRequest) ProtoMessage()

func (*RespondActivityTaskFailedRequest) Reset 

func (m *RespondActivityTaskFailedRequest) Reset()

func (*RespondActivityTaskFailedRequest) Size 

func (m *RespondActivityTaskFailedRequest) Size() (n int)

func (*RespondActivityTaskFailedRequest) String 

func (this *RespondActivityTaskFailedRequest) String() string

func (*RespondActivityTaskFailedRequest) Unmarshal 

func (m *RespondActivityTaskFailedRequest) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskFailedRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedRequest) XXX_Marshal 

func (m *RespondActivityTaskFailedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskFailedRequest) XXX_Merge 

func (m *RespondActivityTaskFailedRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskFailedRequest) XXX_Size 

func (m *RespondActivityTaskFailedRequest) XXX_Size() int

func (*RespondActivityTaskFailedRequest) XXX_Unmarshal 

func (m *RespondActivityTaskFailedRequest) XXX_Unmarshal(b []byte) error

type RespondActivityTaskFailedResponse 

type RespondActivityTaskFailedResponse struct {
}

func (*RespondActivityTaskFailedResponse) Descriptor 

func (*RespondActivityTaskFailedResponse) Descriptor() ([]byte, []int)

func (*RespondActivityTaskFailedResponse) Equal 

func (this *RespondActivityTaskFailedResponse) Equal(that interface{}) bool

func (*RespondActivityTaskFailedResponse) GoString 

func (this *RespondActivityTaskFailedResponse) GoString() string

func (*RespondActivityTaskFailedResponse) Marshal 

func (m *RespondActivityTaskFailedResponse) Marshal() (dAtA []byte, err error)

func (*RespondActivityTaskFailedResponse) MarshalTo 

func (m *RespondActivityTaskFailedResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedResponse) MarshalToSizedBuffer 

func (m *RespondActivityTaskFailedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondActivityTaskFailedResponse) ProtoMessage 

func (*RespondActivityTaskFailedResponse) ProtoMessage()

func (*RespondActivityTaskFailedResponse) Reset 

func (m *RespondActivityTaskFailedResponse) Reset()

func (*RespondActivityTaskFailedResponse) Size 

func (m *RespondActivityTaskFailedResponse) Size() (n int)

func (*RespondActivityTaskFailedResponse) String 

func (this *RespondActivityTaskFailedResponse) String() string

func (*RespondActivityTaskFailedResponse) Unmarshal 

func (m *RespondActivityTaskFailedResponse) Unmarshal(dAtA []byte) error

func (*RespondActivityTaskFailedResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedResponse) XXX_Marshal 

func (m *RespondActivityTaskFailedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondActivityTaskFailedResponse) XXX_Merge 

func (m *RespondActivityTaskFailedResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskFailedResponse) XXX_Size 

func (m *RespondActivityTaskFailedResponse) XXX_Size() int

func (*RespondActivityTaskFailedResponse) XXX_Unmarshal 

func (m *RespondActivityTaskFailedResponse) XXX_Unmarshal(b []byte) error

type RespondDecisionTaskCompletedRequest 

type RespondDecisionTaskCompletedRequest struct {
	TaskToken                  []byte                                 `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	Decisions                  []*common.Decision                     `protobuf:"bytes,2,rep,name=decisions,proto3" json:"decisions,omitempty"`
	ExecutionContext           []byte                                 `protobuf:"bytes,3,opt,name=executionContext,proto3" json:"executionContext,omitempty"`
	Identity                   string                                 `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	StickyAttributes           *common.StickyExecutionAttributes      `protobuf:"bytes,5,opt,name=stickyAttributes,proto3" json:"stickyAttributes,omitempty"`
	ReturnNewDecisionTask      bool                                   `protobuf:"varint,6,opt,name=returnNewDecisionTask,proto3" json:"returnNewDecisionTask,omitempty"`
	ForceCreateNewDecisionTask bool                                   `protobuf:"varint,7,opt,name=forceCreateNewDecisionTask,proto3" json:"forceCreateNewDecisionTask,omitempty"`
	BinaryChecksum             string                                 `protobuf:"bytes,8,opt,name=binaryChecksum,proto3" json:"binaryChecksum,omitempty"`
	QueryResults               map[string]*common.WorkflowQueryResult `` /* 165-byte string literal not displayed */
}

func (*RespondDecisionTaskCompletedRequest) Descriptor 

func (*RespondDecisionTaskCompletedRequest) Descriptor() ([]byte, []int)

func (*RespondDecisionTaskCompletedRequest) Equal 

func (this *RespondDecisionTaskCompletedRequest) Equal(that interface{}) bool

func (*RespondDecisionTaskCompletedRequest) GetBinaryChecksum 

func (m *RespondDecisionTaskCompletedRequest) GetBinaryChecksum() string

func (*RespondDecisionTaskCompletedRequest) GetDecisions 

func (m *RespondDecisionTaskCompletedRequest) GetDecisions() []*common.Decision

func (*RespondDecisionTaskCompletedRequest) GetExecutionContext 

func (m *RespondDecisionTaskCompletedRequest) GetExecutionContext() []byte

func (*RespondDecisionTaskCompletedRequest) GetForceCreateNewDecisionTask 

func (m *RespondDecisionTaskCompletedRequest) GetForceCreateNewDecisionTask() bool

func (*RespondDecisionTaskCompletedRequest) GetIdentity 

func (m *RespondDecisionTaskCompletedRequest) GetIdentity() string

func (*RespondDecisionTaskCompletedRequest) GetQueryResults 

func (m *RespondDecisionTaskCompletedRequest) GetQueryResults() map[string]*common.WorkflowQueryResult

func (*RespondDecisionTaskCompletedRequest) GetReturnNewDecisionTask 

func (m *RespondDecisionTaskCompletedRequest) GetReturnNewDecisionTask() bool

func (*RespondDecisionTaskCompletedRequest) GetStickyAttributes 

func (m *RespondDecisionTaskCompletedRequest) GetStickyAttributes() *common.StickyExecutionAttributes

func (*RespondDecisionTaskCompletedRequest) GetTaskToken 

func (m *RespondDecisionTaskCompletedRequest) GetTaskToken() []byte

func (*RespondDecisionTaskCompletedRequest) GoString 

func (this *RespondDecisionTaskCompletedRequest) GoString() string

func (*RespondDecisionTaskCompletedRequest) Marshal 

func (m *RespondDecisionTaskCompletedRequest) Marshal() (dAtA []byte, err error)

func (*RespondDecisionTaskCompletedRequest) MarshalTo 

func (m *RespondDecisionTaskCompletedRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondDecisionTaskCompletedRequest) MarshalToSizedBuffer 

func (m *RespondDecisionTaskCompletedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondDecisionTaskCompletedRequest) ProtoMessage 

func (*RespondDecisionTaskCompletedRequest) ProtoMessage()

func (*RespondDecisionTaskCompletedRequest) Reset 

func (m *RespondDecisionTaskCompletedRequest) Reset()

func (*RespondDecisionTaskCompletedRequest) Size 

func (m *RespondDecisionTaskCompletedRequest) Size() (n int)

func (*RespondDecisionTaskCompletedRequest) String 

func (this *RespondDecisionTaskCompletedRequest) String() string

func (*RespondDecisionTaskCompletedRequest) Unmarshal 

func (m *RespondDecisionTaskCompletedRequest) Unmarshal(dAtA []byte) error

func (*RespondDecisionTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondDecisionTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondDecisionTaskCompletedRequest) XXX_Marshal 

func (m *RespondDecisionTaskCompletedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondDecisionTaskCompletedRequest) XXX_Merge 

func (m *RespondDecisionTaskCompletedRequest) XXX_Merge(src proto.Message)

func (*RespondDecisionTaskCompletedRequest) XXX_Size 

func (m *RespondDecisionTaskCompletedRequest) XXX_Size() int

func (*RespondDecisionTaskCompletedRequest) XXX_Unmarshal 

func (m *RespondDecisionTaskCompletedRequest) XXX_Unmarshal(b []byte) error

type RespondDecisionTaskCompletedResponse 

type RespondDecisionTaskCompletedResponse struct {
	DecisionTask *PollForDecisionTaskResponse `protobuf:"bytes,1,opt,name=decisionTask,proto3" json:"decisionTask,omitempty"`
}

func (*RespondDecisionTaskCompletedResponse) Descriptor 

func (*RespondDecisionTaskCompletedResponse) Descriptor() ([]byte, []int)

func (*RespondDecisionTaskCompletedResponse) Equal 

func (this *RespondDecisionTaskCompletedResponse) Equal(that interface{}) bool

func (*RespondDecisionTaskCompletedResponse) GetDecisionTask 

func (m *RespondDecisionTaskCompletedResponse) GetDecisionTask() *PollForDecisionTaskResponse

func (*RespondDecisionTaskCompletedResponse) GoString 

func (this *RespondDecisionTaskCompletedResponse) GoString() string

func (*RespondDecisionTaskCompletedResponse) Marshal 

func (m *RespondDecisionTaskCompletedResponse) Marshal() (dAtA []byte, err error)

func (*RespondDecisionTaskCompletedResponse) MarshalTo 

func (m *RespondDecisionTaskCompletedResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondDecisionTaskCompletedResponse) MarshalToSizedBuffer 

func (m *RespondDecisionTaskCompletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondDecisionTaskCompletedResponse) ProtoMessage 

func (*RespondDecisionTaskCompletedResponse) ProtoMessage()

func (*RespondDecisionTaskCompletedResponse) Reset 

func (m *RespondDecisionTaskCompletedResponse) Reset()

func (*RespondDecisionTaskCompletedResponse) Size 

func (m *RespondDecisionTaskCompletedResponse) Size() (n int)

func (*RespondDecisionTaskCompletedResponse) String 

func (this *RespondDecisionTaskCompletedResponse) String() string

func (*RespondDecisionTaskCompletedResponse) Unmarshal 

func (m *RespondDecisionTaskCompletedResponse) Unmarshal(dAtA []byte) error

func (*RespondDecisionTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondDecisionTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondDecisionTaskCompletedResponse) XXX_Marshal 

func (m *RespondDecisionTaskCompletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondDecisionTaskCompletedResponse) XXX_Merge 

func (m *RespondDecisionTaskCompletedResponse) XXX_Merge(src proto.Message)

func (*RespondDecisionTaskCompletedResponse) XXX_Size 

func (m *RespondDecisionTaskCompletedResponse) XXX_Size() int

func (*RespondDecisionTaskCompletedResponse) XXX_Unmarshal 

func (m *RespondDecisionTaskCompletedResponse) XXX_Unmarshal(b []byte) error

type RespondDecisionTaskFailedRequest 

type RespondDecisionTaskFailedRequest struct {
	TaskToken      []byte                        `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	Cause          enums.DecisionTaskFailedCause `protobuf:"varint,2,opt,name=cause,proto3,enum=enums.DecisionTaskFailedCause" json:"cause,omitempty"`
	Details        []byte                        `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	Identity       string                        `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	BinaryChecksum string                        `protobuf:"bytes,5,opt,name=binaryChecksum,proto3" json:"binaryChecksum,omitempty"`
}

func (*RespondDecisionTaskFailedRequest) Descriptor 

func (*RespondDecisionTaskFailedRequest) Descriptor() ([]byte, []int)

func (*RespondDecisionTaskFailedRequest) Equal 

func (this *RespondDecisionTaskFailedRequest) Equal(that interface{}) bool

func (*RespondDecisionTaskFailedRequest) GetBinaryChecksum 

func (m *RespondDecisionTaskFailedRequest) GetBinaryChecksum() string

func (*RespondDecisionTaskFailedRequest) GetCause 

func (m *RespondDecisionTaskFailedRequest) GetCause() enums.DecisionTaskFailedCause

func (*RespondDecisionTaskFailedRequest) GetDetails 

func (m *RespondDecisionTaskFailedRequest) GetDetails() []byte

func (*RespondDecisionTaskFailedRequest) GetIdentity 

func (m *RespondDecisionTaskFailedRequest) GetIdentity() string

func (*RespondDecisionTaskFailedRequest) GetTaskToken 

func (m *RespondDecisionTaskFailedRequest) GetTaskToken() []byte

func (*RespondDecisionTaskFailedRequest) GoString 

func (this *RespondDecisionTaskFailedRequest) GoString() string

func (*RespondDecisionTaskFailedRequest) Marshal 

func (m *RespondDecisionTaskFailedRequest) Marshal() (dAtA []byte, err error)

func (*RespondDecisionTaskFailedRequest) MarshalTo 

func (m *RespondDecisionTaskFailedRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondDecisionTaskFailedRequest) MarshalToSizedBuffer 

func (m *RespondDecisionTaskFailedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondDecisionTaskFailedRequest) ProtoMessage 

func (*RespondDecisionTaskFailedRequest) ProtoMessage()

func (*RespondDecisionTaskFailedRequest) Reset 

func (m *RespondDecisionTaskFailedRequest) Reset()

func (*RespondDecisionTaskFailedRequest) Size 

func (m *RespondDecisionTaskFailedRequest) Size() (n int)

func (*RespondDecisionTaskFailedRequest) String 

func (this *RespondDecisionTaskFailedRequest) String() string

func (*RespondDecisionTaskFailedRequest) Unmarshal 

func (m *RespondDecisionTaskFailedRequest) Unmarshal(dAtA []byte) error

func (*RespondDecisionTaskFailedRequest) XXX_DiscardUnknown 

func (m *RespondDecisionTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondDecisionTaskFailedRequest) XXX_Marshal 

func (m *RespondDecisionTaskFailedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondDecisionTaskFailedRequest) XXX_Merge 

func (m *RespondDecisionTaskFailedRequest) XXX_Merge(src proto.Message)

func (*RespondDecisionTaskFailedRequest) XXX_Size 

func (m *RespondDecisionTaskFailedRequest) XXX_Size() int

func (*RespondDecisionTaskFailedRequest) XXX_Unmarshal 

func (m *RespondDecisionTaskFailedRequest) XXX_Unmarshal(b []byte) error

type RespondDecisionTaskFailedResponse 

type RespondDecisionTaskFailedResponse struct {
}

func (*RespondDecisionTaskFailedResponse) Descriptor 

func (*RespondDecisionTaskFailedResponse) Descriptor() ([]byte, []int)

func (*RespondDecisionTaskFailedResponse) Equal 

func (this *RespondDecisionTaskFailedResponse) Equal(that interface{}) bool

func (*RespondDecisionTaskFailedResponse) GoString 

func (this *RespondDecisionTaskFailedResponse) GoString() string

func (*RespondDecisionTaskFailedResponse) Marshal 

func (m *RespondDecisionTaskFailedResponse) Marshal() (dAtA []byte, err error)

func (*RespondDecisionTaskFailedResponse) MarshalTo 

func (m *RespondDecisionTaskFailedResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondDecisionTaskFailedResponse) MarshalToSizedBuffer 

func (m *RespondDecisionTaskFailedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondDecisionTaskFailedResponse) ProtoMessage 

func (*RespondDecisionTaskFailedResponse) ProtoMessage()

func (*RespondDecisionTaskFailedResponse) Reset 

func (m *RespondDecisionTaskFailedResponse) Reset()

func (*RespondDecisionTaskFailedResponse) Size 

func (m *RespondDecisionTaskFailedResponse) Size() (n int)

func (*RespondDecisionTaskFailedResponse) String 

func (this *RespondDecisionTaskFailedResponse) String() string

func (*RespondDecisionTaskFailedResponse) Unmarshal 

func (m *RespondDecisionTaskFailedResponse) Unmarshal(dAtA []byte) error

func (*RespondDecisionTaskFailedResponse) XXX_DiscardUnknown 

func (m *RespondDecisionTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondDecisionTaskFailedResponse) XXX_Marshal 

func (m *RespondDecisionTaskFailedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondDecisionTaskFailedResponse) XXX_Merge 

func (m *RespondDecisionTaskFailedResponse) XXX_Merge(src proto.Message)

func (*RespondDecisionTaskFailedResponse) XXX_Size 

func (m *RespondDecisionTaskFailedResponse) XXX_Size() int

func (*RespondDecisionTaskFailedResponse) XXX_Unmarshal 

func (m *RespondDecisionTaskFailedResponse) XXX_Unmarshal(b []byte) error

type RespondQueryTaskCompletedRequest 

type RespondQueryTaskCompletedRequest struct {
	TaskToken         []byte                       `protobuf:"bytes,1,opt,name=taskToken,proto3" json:"taskToken,omitempty"`
	CompletedType     enums.QueryTaskCompletedType `protobuf:"varint,2,opt,name=completedType,proto3,enum=enums.QueryTaskCompletedType" json:"completedType,omitempty"`
	QueryResult       []byte                       `protobuf:"bytes,3,opt,name=queryResult,proto3" json:"queryResult,omitempty"`
	ErrorMessage      string                       `protobuf:"bytes,4,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	WorkerVersionInfo *common.WorkerVersionInfo    `protobuf:"bytes,5,opt,name=workerVersionInfo,proto3" json:"workerVersionInfo,omitempty"`
}

func (*RespondQueryTaskCompletedRequest) Descriptor 

func (*RespondQueryTaskCompletedRequest) Descriptor() ([]byte, []int)

func (*RespondQueryTaskCompletedRequest) Equal 

func (this *RespondQueryTaskCompletedRequest) Equal(that interface{}) bool

func (*RespondQueryTaskCompletedRequest) GetCompletedType 

func (m *RespondQueryTaskCompletedRequest) GetCompletedType() enums.QueryTaskCompletedType

func (*RespondQueryTaskCompletedRequest) GetErrorMessage 

func (m *RespondQueryTaskCompletedRequest) GetErrorMessage() string

func (*RespondQueryTaskCompletedRequest) GetQueryResult 

func (m *RespondQueryTaskCompletedRequest) GetQueryResult() []byte

func (*RespondQueryTaskCompletedRequest) GetTaskToken 

func (m *RespondQueryTaskCompletedRequest) GetTaskToken() []byte

func (*RespondQueryTaskCompletedRequest) GetWorkerVersionInfo 

func (m *RespondQueryTaskCompletedRequest) GetWorkerVersionInfo() *common.WorkerVersionInfo

func (*RespondQueryTaskCompletedRequest) GoString 

func (this *RespondQueryTaskCompletedRequest) GoString() string

func (*RespondQueryTaskCompletedRequest) Marshal 

func (m *RespondQueryTaskCompletedRequest) Marshal() (dAtA []byte, err error)

func (*RespondQueryTaskCompletedRequest) MarshalTo 

func (m *RespondQueryTaskCompletedRequest) MarshalTo(dAtA []byte) (int, error)

func (*RespondQueryTaskCompletedRequest) MarshalToSizedBuffer 

func (m *RespondQueryTaskCompletedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondQueryTaskCompletedRequest) ProtoMessage 

func (*RespondQueryTaskCompletedRequest) ProtoMessage()

func (*RespondQueryTaskCompletedRequest) Reset 

func (m *RespondQueryTaskCompletedRequest) Reset()

func (*RespondQueryTaskCompletedRequest) Size 

func (m *RespondQueryTaskCompletedRequest) Size() (n int)

func (*RespondQueryTaskCompletedRequest) String 

func (this *RespondQueryTaskCompletedRequest) String() string

func (*RespondQueryTaskCompletedRequest) Unmarshal 

func (m *RespondQueryTaskCompletedRequest) Unmarshal(dAtA []byte) error

func (*RespondQueryTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondQueryTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondQueryTaskCompletedRequest) XXX_Marshal 

func (m *RespondQueryTaskCompletedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondQueryTaskCompletedRequest) XXX_Merge 

func (m *RespondQueryTaskCompletedRequest) XXX_Merge(src proto.Message)

func (*RespondQueryTaskCompletedRequest) XXX_Size 

func (m *RespondQueryTaskCompletedRequest) XXX_Size() int

func (*RespondQueryTaskCompletedRequest) XXX_Unmarshal 

func (m *RespondQueryTaskCompletedRequest) XXX_Unmarshal(b []byte) error

type RespondQueryTaskCompletedResponse 

type RespondQueryTaskCompletedResponse struct {
}

func (*RespondQueryTaskCompletedResponse) Descriptor 

func (*RespondQueryTaskCompletedResponse) Descriptor() ([]byte, []int)

func (*RespondQueryTaskCompletedResponse) Equal 

func (this *RespondQueryTaskCompletedResponse) Equal(that interface{}) bool

func (*RespondQueryTaskCompletedResponse) GoString 

func (this *RespondQueryTaskCompletedResponse) GoString() string

func (*RespondQueryTaskCompletedResponse) Marshal 

func (m *RespondQueryTaskCompletedResponse) Marshal() (dAtA []byte, err error)

func (*RespondQueryTaskCompletedResponse) MarshalTo 

func (m *RespondQueryTaskCompletedResponse) MarshalTo(dAtA []byte) (int, error)

func (*RespondQueryTaskCompletedResponse) MarshalToSizedBuffer 

func (m *RespondQueryTaskCompletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RespondQueryTaskCompletedResponse) ProtoMessage 

func (*RespondQueryTaskCompletedResponse) ProtoMessage()

func (*RespondQueryTaskCompletedResponse) Reset 

func (m *RespondQueryTaskCompletedResponse) Reset()

func (*RespondQueryTaskCompletedResponse) Size 

func (m *RespondQueryTaskCompletedResponse) Size() (n int)

func (*RespondQueryTaskCompletedResponse) String 

func (this *RespondQueryTaskCompletedResponse) String() string

func (*RespondQueryTaskCompletedResponse) Unmarshal 

func (m *RespondQueryTaskCompletedResponse) Unmarshal(dAtA []byte) error

func (*RespondQueryTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondQueryTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondQueryTaskCompletedResponse) XXX_Marshal 

func (m *RespondQueryTaskCompletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RespondQueryTaskCompletedResponse) XXX_Merge 

func (m *RespondQueryTaskCompletedResponse) XXX_Merge(src proto.Message)

func (*RespondQueryTaskCompletedResponse) XXX_Size 

func (m *RespondQueryTaskCompletedResponse) XXX_Size() int

func (*RespondQueryTaskCompletedResponse) XXX_Unmarshal 

func (m *RespondQueryTaskCompletedResponse) XXX_Unmarshal(b []byte) error

type ScanWorkflowExecutionsRequest 

type ScanWorkflowExecutionsRequest struct {
	Domain        string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
	Query         string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
}

func (*ScanWorkflowExecutionsRequest) Descriptor 

func (*ScanWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

func (*ScanWorkflowExecutionsRequest) Equal 

func (this *ScanWorkflowExecutionsRequest) Equal(that interface{}) bool

func (*ScanWorkflowExecutionsRequest) GetDomain 

func (m *ScanWorkflowExecutionsRequest) GetDomain() string

func (*ScanWorkflowExecutionsRequest) GetNextPageToken 

func (m *ScanWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ScanWorkflowExecutionsRequest) GetPageSize 

func (m *ScanWorkflowExecutionsRequest) GetPageSize() int32

func (*ScanWorkflowExecutionsRequest) GetQuery 

func (m *ScanWorkflowExecutionsRequest) GetQuery() string

func (*ScanWorkflowExecutionsRequest) GoString 

func (this *ScanWorkflowExecutionsRequest) GoString() string

func (*ScanWorkflowExecutionsRequest) Marshal 

func (m *ScanWorkflowExecutionsRequest) Marshal() (dAtA []byte, err error)

func (*ScanWorkflowExecutionsRequest) MarshalTo 

func (m *ScanWorkflowExecutionsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ScanWorkflowExecutionsRequest) MarshalToSizedBuffer 

func (m *ScanWorkflowExecutionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScanWorkflowExecutionsRequest) ProtoMessage 

func (*ScanWorkflowExecutionsRequest) ProtoMessage()

func (*ScanWorkflowExecutionsRequest) Reset 

func (m *ScanWorkflowExecutionsRequest) Reset()

func (*ScanWorkflowExecutionsRequest) Size 

func (m *ScanWorkflowExecutionsRequest) Size() (n int)

func (*ScanWorkflowExecutionsRequest) String 

func (this *ScanWorkflowExecutionsRequest) String() string

func (*ScanWorkflowExecutionsRequest) Unmarshal 

func (m *ScanWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

func (*ScanWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ScanWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ScanWorkflowExecutionsRequest) XXX_Marshal 

func (m *ScanWorkflowExecutionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanWorkflowExecutionsRequest) XXX_Merge 

func (m *ScanWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

func (*ScanWorkflowExecutionsRequest) XXX_Size 

func (m *ScanWorkflowExecutionsRequest) XXX_Size() int

func (*ScanWorkflowExecutionsRequest) XXX_Unmarshal 

func (m *ScanWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

type ScanWorkflowExecutionsResponse 

type ScanWorkflowExecutionsResponse struct {
	Executions    []*common.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                          `protobuf:"bytes,2,opt,name=nextPageToken,proto3" json:"nextPageToken,omitempty"`
}

func (*ScanWorkflowExecutionsResponse) Descriptor 

func (*ScanWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

func (*ScanWorkflowExecutionsResponse) Equal 

func (this *ScanWorkflowExecutionsResponse) Equal(that interface{}) bool

func (*ScanWorkflowExecutionsResponse) GetExecutions 

func (m *ScanWorkflowExecutionsResponse) GetExecutions() []*common.WorkflowExecutionInfo

func (*ScanWorkflowExecutionsResponse) GetNextPageToken 

func (m *ScanWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ScanWorkflowExecutionsResponse) GoString 

func (this *ScanWorkflowExecutionsResponse) GoString() string

func (*ScanWorkflowExecutionsResponse) Marshal 

func (m *ScanWorkflowExecutionsResponse) Marshal() (dAtA []byte, err error)

func (*ScanWorkflowExecutionsResponse) MarshalTo 

func (m *ScanWorkflowExecutionsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ScanWorkflowExecutionsResponse) MarshalToSizedBuffer 

func (m *ScanWorkflowExecutionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScanWorkflowExecutionsResponse) ProtoMessage 

func (*ScanWorkflowExecutionsResponse) ProtoMessage()

func (*ScanWorkflowExecutionsResponse) Reset 

func (m *ScanWorkflowExecutionsResponse) Reset()

func (*ScanWorkflowExecutionsResponse) Size 

func (m *ScanWorkflowExecutionsResponse) Size() (n int)

func (*ScanWorkflowExecutionsResponse) String 

func (this *ScanWorkflowExecutionsResponse) String() string

func (*ScanWorkflowExecutionsResponse) Unmarshal 

func (m *ScanWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

func (*ScanWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ScanWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ScanWorkflowExecutionsResponse) XXX_Marshal 

func (m *ScanWorkflowExecutionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScanWorkflowExecutionsResponse) XXX_Merge 

func (m *ScanWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

func (*ScanWorkflowExecutionsResponse) XXX_Size 

func (m *ScanWorkflowExecutionsResponse) XXX_Size() int

func (*ScanWorkflowExecutionsResponse) XXX_Unmarshal 

func (m *ScanWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

type SignalWithStartWorkflowExecutionRequest 

type SignalWithStartWorkflowExecutionRequest struct {
	Domain                              string                      `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowId                          string                      `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	WorkflowType                        *common.WorkflowType        `protobuf:"bytes,3,opt,name=workflowType,proto3" json:"workflowType,omitempty"`
	TaskList                            *common.TaskList            `protobuf:"bytes,4,opt,name=taskList,proto3" json:"taskList,omitempty"`
	Input                               []byte                      `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	ExecutionStartToCloseTimeoutSeconds int32                       `protobuf:"varint,6,opt,name=executionStartToCloseTimeoutSeconds,proto3" json:"executionStartToCloseTimeoutSeconds,omitempty"`
	TaskStartToCloseTimeoutSeconds      int32                       `protobuf:"varint,7,opt,name=taskStartToCloseTimeoutSeconds,proto3" json:"taskStartToCloseTimeoutSeconds,omitempty"`
	Identity                            string                      `protobuf:"bytes,8,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId                           string                      `protobuf:"bytes,9,opt,name=requestId,proto3" json:"requestId,omitempty"`
	WorkflowIdReusePolicy               enums.WorkflowIdReusePolicy `` /* 130-byte string literal not displayed */
	SignalName                          string                      `protobuf:"bytes,11,opt,name=signalName,proto3" json:"signalName,omitempty"`
	SignalInput                         []byte                      `protobuf:"bytes,12,opt,name=signalInput,proto3" json:"signalInput,omitempty"`
	Control                             []byte                      `protobuf:"bytes,13,opt,name=control,proto3" json:"control,omitempty"`
	RetryPolicy                         *common.RetryPolicy         `protobuf:"bytes,14,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"`
	CronSchedule                        string                      `protobuf:"bytes,15,opt,name=cronSchedule,proto3" json:"cronSchedule,omitempty"`
	Memo                                *common.Memo                `protobuf:"bytes,16,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes                    *common.SearchAttributes    `protobuf:"bytes,17,opt,name=searchAttributes,proto3" json:"searchAttributes,omitempty"`
	Header                              *common.Header              `protobuf:"bytes,18,opt,name=header,proto3" json:"header,omitempty"`
}

func (*SignalWithStartWorkflowExecutionRequest) Descriptor 

func (*SignalWithStartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*SignalWithStartWorkflowExecutionRequest) Equal 

func (this *SignalWithStartWorkflowExecutionRequest) Equal(that interface{}) bool

func (*SignalWithStartWorkflowExecutionRequest) GetControl 

func (m *SignalWithStartWorkflowExecutionRequest) GetControl() []byte

func (*SignalWithStartWorkflowExecutionRequest) GetCronSchedule 

func (m *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

func (*SignalWithStartWorkflowExecutionRequest) GetDomain 

func (m *SignalWithStartWorkflowExecutionRequest) GetDomain() string

func (*SignalWithStartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds 

func (m *SignalWithStartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds() int32

func (*SignalWithStartWorkflowExecutionRequest) GetHeader 

func (m *SignalWithStartWorkflowExecutionRequest) GetHeader() *common.Header

func (*SignalWithStartWorkflowExecutionRequest) GetIdentity 

func (m *SignalWithStartWorkflowExecutionRequest) GetIdentity() string

func (*SignalWithStartWorkflowExecutionRequest) GetInput 

func (m *SignalWithStartWorkflowExecutionRequest) GetInput() []byte

func (*SignalWithStartWorkflowExecutionRequest) GetMemo 

func (m *SignalWithStartWorkflowExecutionRequest) GetMemo() *common.Memo

func (*SignalWithStartWorkflowExecutionRequest) GetRequestId 

func (m *SignalWithStartWorkflowExecutionRequest) GetRequestId() string

func (*SignalWithStartWorkflowExecutionRequest) GetRetryPolicy 

func (m *SignalWithStartWorkflowExecutionRequest) GetRetryPolicy() *common.RetryPolicy

func (*SignalWithStartWorkflowExecutionRequest) GetSearchAttributes 

func (m *SignalWithStartWorkflowExecutionRequest) GetSearchAttributes() *common.SearchAttributes

func (*SignalWithStartWorkflowExecutionRequest) GetSignalInput 

func (m *SignalWithStartWorkflowExecutionRequest) GetSignalInput() []byte

func (*SignalWithStartWorkflowExecutionRequest) GetSignalName 

func (m *SignalWithStartWorkflowExecutionRequest) GetSignalName() string

func (*SignalWithStartWorkflowExecutionRequest) GetTaskList 

func (m *SignalWithStartWorkflowExecutionRequest) GetTaskList() *common.TaskList

func (*SignalWithStartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds 

func (m *SignalWithStartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds() int32

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowId() string

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() enums.WorkflowIdReusePolicy

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowType 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() *common.WorkflowType

func (*SignalWithStartWorkflowExecutionRequest) GoString 

func (this *SignalWithStartWorkflowExecutionRequest) GoString() string

func (*SignalWithStartWorkflowExecutionRequest) Marshal 

func (m *SignalWithStartWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*SignalWithStartWorkflowExecutionRequest) MarshalTo 

func (m *SignalWithStartWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*SignalWithStartWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *SignalWithStartWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage 

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage()

func (*SignalWithStartWorkflowExecutionRequest) Reset 

func (m *SignalWithStartWorkflowExecutionRequest) Reset()

func (*SignalWithStartWorkflowExecutionRequest) Size 

func (m *SignalWithStartWorkflowExecutionRequest) Size() (n int)

func (*SignalWithStartWorkflowExecutionRequest) String 

func (this *SignalWithStartWorkflowExecutionRequest) String() string

func (*SignalWithStartWorkflowExecutionRequest) Unmarshal 

func (m *SignalWithStartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*SignalWithStartWorkflowExecutionRequest) XXX_Marshal 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignalWithStartWorkflowExecutionRequest) XXX_Merge 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*SignalWithStartWorkflowExecutionRequest) XXX_Size 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_Size() int

func (*SignalWithStartWorkflowExecutionRequest) XXX_Unmarshal 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type SignalWithStartWorkflowExecutionResponse 

type SignalWithStartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=runId,proto3" json:"runId,omitempty"`
}

func (*SignalWithStartWorkflowExecutionResponse) Descriptor 

func (*SignalWithStartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*SignalWithStartWorkflowExecutionResponse) Equal 

func (this *SignalWithStartWorkflowExecutionResponse) Equal(that interface{}) bool

func (*SignalWithStartWorkflowExecutionResponse) GetRunId 

func (m *SignalWithStartWorkflowExecutionResponse) GetRunId() string

func (*SignalWithStartWorkflowExecutionResponse) GoString 

func (this *SignalWithStartWorkflowExecutionResponse) GoString() string

func (*SignalWithStartWorkflowExecutionResponse) Marshal 

func (m *SignalWithStartWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*SignalWithStartWorkflowExecutionResponse) MarshalTo 

func (m *SignalWithStartWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*SignalWithStartWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *SignalWithStartWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage 

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage()

func (*SignalWithStartWorkflowExecutionResponse) Reset 

func (m *SignalWithStartWorkflowExecutionResponse) Reset()

func (*SignalWithStartWorkflowExecutionResponse) Size 

func (m *SignalWithStartWorkflowExecutionResponse) Size() (n int)

func (*SignalWithStartWorkflowExecutionResponse) String 

func (this *SignalWithStartWorkflowExecutionResponse) String() string

func (*SignalWithStartWorkflowExecutionResponse) Unmarshal 

func (m *SignalWithStartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*SignalWithStartWorkflowExecutionResponse) XXX_Marshal 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignalWithStartWorkflowExecutionResponse) XXX_Merge 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*SignalWithStartWorkflowExecutionResponse) XXX_Size 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_Size() int

func (*SignalWithStartWorkflowExecutionResponse) XXX_Unmarshal 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type SignalWorkflowExecutionRequest 

type SignalWorkflowExecutionRequest struct {
	Domain            string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	SignalName        string                    `protobuf:"bytes,3,opt,name=signalName,proto3" json:"signalName,omitempty"`
	Input             []byte                    `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Identity          string                    `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId         string                    `protobuf:"bytes,6,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Control           []byte                    `protobuf:"bytes,7,opt,name=control,proto3" json:"control,omitempty"`
}

func (*SignalWorkflowExecutionRequest) Descriptor 

func (*SignalWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*SignalWorkflowExecutionRequest) Equal 

func (this *SignalWorkflowExecutionRequest) Equal(that interface{}) bool

func (*SignalWorkflowExecutionRequest) GetControl 

func (m *SignalWorkflowExecutionRequest) GetControl() []byte

func (*SignalWorkflowExecutionRequest) GetDomain 

func (m *SignalWorkflowExecutionRequest) GetDomain() string

func (*SignalWorkflowExecutionRequest) GetIdentity 

func (m *SignalWorkflowExecutionRequest) GetIdentity() string

func (*SignalWorkflowExecutionRequest) GetInput 

func (m *SignalWorkflowExecutionRequest) GetInput() []byte

func (*SignalWorkflowExecutionRequest) GetRequestId 

func (m *SignalWorkflowExecutionRequest) GetRequestId() string

func (*SignalWorkflowExecutionRequest) GetSignalName 

func (m *SignalWorkflowExecutionRequest) GetSignalName() string

func (*SignalWorkflowExecutionRequest) GetWorkflowExecution 

func (m *SignalWorkflowExecutionRequest) GetWorkflowExecution() *common.WorkflowExecution

func (*SignalWorkflowExecutionRequest) GoString 

func (this *SignalWorkflowExecutionRequest) GoString() string

func (*SignalWorkflowExecutionRequest) Marshal 

func (m *SignalWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*SignalWorkflowExecutionRequest) MarshalTo 

func (m *SignalWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*SignalWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *SignalWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignalWorkflowExecutionRequest) ProtoMessage 

func (*SignalWorkflowExecutionRequest) ProtoMessage()

func (*SignalWorkflowExecutionRequest) Reset 

func (m *SignalWorkflowExecutionRequest) Reset()

func (*SignalWorkflowExecutionRequest) Size 

func (m *SignalWorkflowExecutionRequest) Size() (n int)

func (*SignalWorkflowExecutionRequest) String 

func (this *SignalWorkflowExecutionRequest) String() string

func (*SignalWorkflowExecutionRequest) Unmarshal 

func (m *SignalWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*SignalWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *SignalWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*SignalWorkflowExecutionRequest) XXX_Marshal 

func (m *SignalWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignalWorkflowExecutionRequest) XXX_Merge 

func (m *SignalWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*SignalWorkflowExecutionRequest) XXX_Size 

func (m *SignalWorkflowExecutionRequest) XXX_Size() int

func (*SignalWorkflowExecutionRequest) XXX_Unmarshal 

func (m *SignalWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type SignalWorkflowExecutionResponse 

type SignalWorkflowExecutionResponse struct {
}

func (*SignalWorkflowExecutionResponse) Descriptor 

func (*SignalWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*SignalWorkflowExecutionResponse) Equal 

func (this *SignalWorkflowExecutionResponse) Equal(that interface{}) bool

func (*SignalWorkflowExecutionResponse) GoString 

func (this *SignalWorkflowExecutionResponse) GoString() string

func (*SignalWorkflowExecutionResponse) Marshal 

func (m *SignalWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*SignalWorkflowExecutionResponse) MarshalTo 

func (m *SignalWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*SignalWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *SignalWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignalWorkflowExecutionResponse) ProtoMessage 

func (*SignalWorkflowExecutionResponse) ProtoMessage()

func (*SignalWorkflowExecutionResponse) Reset 

func (m *SignalWorkflowExecutionResponse) Reset()

func (*SignalWorkflowExecutionResponse) Size 

func (m *SignalWorkflowExecutionResponse) Size() (n int)

func (*SignalWorkflowExecutionResponse) String 

func (this *SignalWorkflowExecutionResponse) String() string

func (*SignalWorkflowExecutionResponse) Unmarshal 

func (m *SignalWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*SignalWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *SignalWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*SignalWorkflowExecutionResponse) XXX_Marshal 

func (m *SignalWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignalWorkflowExecutionResponse) XXX_Merge 

func (m *SignalWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*SignalWorkflowExecutionResponse) XXX_Size 

func (m *SignalWorkflowExecutionResponse) XXX_Size() int

func (*SignalWorkflowExecutionResponse) XXX_Unmarshal 

func (m *SignalWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type StartWorkflowExecutionRequest 

type StartWorkflowExecutionRequest struct {
	Domain                              string                      `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowId                          string                      `protobuf:"bytes,2,opt,name=workflowId,proto3" json:"workflowId,omitempty"`
	WorkflowType                        *common.WorkflowType        `protobuf:"bytes,3,opt,name=workflowType,proto3" json:"workflowType,omitempty"`
	TaskList                            *common.TaskList            `protobuf:"bytes,4,opt,name=taskList,proto3" json:"taskList,omitempty"`
	Input                               []byte                      `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	ExecutionStartToCloseTimeoutSeconds int32                       `protobuf:"varint,6,opt,name=executionStartToCloseTimeoutSeconds,proto3" json:"executionStartToCloseTimeoutSeconds,omitempty"`
	TaskStartToCloseTimeoutSeconds      int32                       `protobuf:"varint,7,opt,name=taskStartToCloseTimeoutSeconds,proto3" json:"taskStartToCloseTimeoutSeconds,omitempty"`
	Identity                            string                      `protobuf:"bytes,8,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId                           string                      `protobuf:"bytes,9,opt,name=requestId,proto3" json:"requestId,omitempty"`
	WorkflowIdReusePolicy               enums.WorkflowIdReusePolicy `` /* 130-byte string literal not displayed */
	RetryPolicy                         *common.RetryPolicy         `protobuf:"bytes,11,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"`
	CronSchedule                        string                      `protobuf:"bytes,12,opt,name=cronSchedule,proto3" json:"cronSchedule,omitempty"`
	Memo                                *common.Memo                `protobuf:"bytes,13,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes                    *common.SearchAttributes    `protobuf:"bytes,14,opt,name=searchAttributes,proto3" json:"searchAttributes,omitempty"`
	Header                              *common.Header              `protobuf:"bytes,15,opt,name=header,proto3" json:"header,omitempty"`
}

func (*StartWorkflowExecutionRequest) Descriptor 

func (*StartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*StartWorkflowExecutionRequest) Equal 

func (this *StartWorkflowExecutionRequest) Equal(that interface{}) bool

func (*StartWorkflowExecutionRequest) GetCronSchedule 

func (m *StartWorkflowExecutionRequest) GetCronSchedule() string

func (*StartWorkflowExecutionRequest) GetDomain 

func (m *StartWorkflowExecutionRequest) GetDomain() string

func (*StartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds 

func (m *StartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds() int32

func (*StartWorkflowExecutionRequest) GetHeader 

func (m *StartWorkflowExecutionRequest) GetHeader() *common.Header

func (*StartWorkflowExecutionRequest) GetIdentity 

func (m *StartWorkflowExecutionRequest) GetIdentity() string

func (*StartWorkflowExecutionRequest) GetInput 

func (m *StartWorkflowExecutionRequest) GetInput() []byte

func (*StartWorkflowExecutionRequest) GetMemo 

func (m *StartWorkflowExecutionRequest) GetMemo() *common.Memo

func (*StartWorkflowExecutionRequest) GetRequestId 

func (m *StartWorkflowExecutionRequest) GetRequestId() string

func (*StartWorkflowExecutionRequest) GetRetryPolicy 

func (m *StartWorkflowExecutionRequest) GetRetryPolicy() *common.RetryPolicy

func (*StartWorkflowExecutionRequest) GetSearchAttributes 

func (m *StartWorkflowExecutionRequest) GetSearchAttributes() *common.SearchAttributes

func (*StartWorkflowExecutionRequest) GetTaskList 

func (m *StartWorkflowExecutionRequest) GetTaskList() *common.TaskList

func (*StartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds 

func (m *StartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds() int32

func (*StartWorkflowExecutionRequest) GetWorkflowId 

func (m *StartWorkflowExecutionRequest) GetWorkflowId() string

func (*StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy 

func (m *StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() enums.WorkflowIdReusePolicy

func (*StartWorkflowExecutionRequest) GetWorkflowType 

func (m *StartWorkflowExecutionRequest) GetWorkflowType() *common.WorkflowType

func (*StartWorkflowExecutionRequest) GoString 

func (this *StartWorkflowExecutionRequest) GoString() string

func (*StartWorkflowExecutionRequest) Marshal 

func (m *StartWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*StartWorkflowExecutionRequest) MarshalTo 

func (m *StartWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *StartWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartWorkflowExecutionRequest) ProtoMessage 

func (*StartWorkflowExecutionRequest) ProtoMessage()

func (*StartWorkflowExecutionRequest) Reset 

func (m *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) Size 

func (m *StartWorkflowExecutionRequest) Size() (n int)

func (*StartWorkflowExecutionRequest) String 

func (this *StartWorkflowExecutionRequest) String() string

func (*StartWorkflowExecutionRequest) Unmarshal 

func (m *StartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*StartWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*StartWorkflowExecutionRequest) XXX_Marshal 

func (m *StartWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartWorkflowExecutionRequest) XXX_Merge 

func (m *StartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*StartWorkflowExecutionRequest) XXX_Size 

func (m *StartWorkflowExecutionRequest) XXX_Size() int

func (*StartWorkflowExecutionRequest) XXX_Unmarshal 

func (m *StartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type StartWorkflowExecutionResponse 

type StartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=runId,proto3" json:"runId,omitempty"`
}

func (*StartWorkflowExecutionResponse) Descriptor 

func (*StartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*StartWorkflowExecutionResponse) Equal 

func (this *StartWorkflowExecutionResponse) Equal(that interface{}) bool

func (*StartWorkflowExecutionResponse) GetRunId 

func (m *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) GoString 

func (this *StartWorkflowExecutionResponse) GoString() string

func (*StartWorkflowExecutionResponse) Marshal 

func (m *StartWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*StartWorkflowExecutionResponse) MarshalTo 

func (m *StartWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *StartWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartWorkflowExecutionResponse) ProtoMessage 

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) Reset 

func (m *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) Size 

func (m *StartWorkflowExecutionResponse) Size() (n int)

func (*StartWorkflowExecutionResponse) String 

func (this *StartWorkflowExecutionResponse) String() string

func (*StartWorkflowExecutionResponse) Unmarshal 

func (m *StartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*StartWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*StartWorkflowExecutionResponse) XXX_Marshal 

func (m *StartWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartWorkflowExecutionResponse) XXX_Merge 

func (m *StartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*StartWorkflowExecutionResponse) XXX_Size 

func (m *StartWorkflowExecutionResponse) XXX_Size() int

func (*StartWorkflowExecutionResponse) XXX_Unmarshal 

func (m *StartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type TerminateWorkflowExecutionRequest 

type TerminateWorkflowExecutionRequest struct {
	Domain            string                    `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	WorkflowExecution *common.WorkflowExecution `protobuf:"bytes,2,opt,name=workflowExecution,proto3" json:"workflowExecution,omitempty"`
	Reason            string                    `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Details           []byte                    `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	Identity          string                    `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*TerminateWorkflowExecutionRequest) Descriptor 

func (*TerminateWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*TerminateWorkflowExecutionRequest) Equal 

func (this *TerminateWorkflowExecutionRequest) Equal(that interface{}) bool

func (*TerminateWorkflowExecutionRequest) GetDetails 

func (m *TerminateWorkflowExecutionRequest) GetDetails() []byte

func (*TerminateWorkflowExecutionRequest) GetDomain 

func (m *TerminateWorkflowExecutionRequest) GetDomain() string

func (*TerminateWorkflowExecutionRequest) GetIdentity 

func (m *TerminateWorkflowExecutionRequest) GetIdentity() string

func (*TerminateWorkflowExecutionRequest) GetReason 

func (m *TerminateWorkflowExecutionRequest) GetReason() string

func (*TerminateWorkflowExecutionRequest) GetWorkflowExecution 

func (m *TerminateWorkflowExecutionRequest) GetWorkflowExecution() *common.WorkflowExecution

func (*TerminateWorkflowExecutionRequest) GoString 

func (this *TerminateWorkflowExecutionRequest) GoString() string

func (*TerminateWorkflowExecutionRequest) Marshal 

func (m *TerminateWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*TerminateWorkflowExecutionRequest) MarshalTo 

func (m *TerminateWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionRequest) MarshalToSizedBuffer 

func (m *TerminateWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionRequest) ProtoMessage 

func (*TerminateWorkflowExecutionRequest) ProtoMessage()

func (*TerminateWorkflowExecutionRequest) Reset 

func (m *TerminateWorkflowExecutionRequest) Reset()

func (*TerminateWorkflowExecutionRequest) Size 

func (m *TerminateWorkflowExecutionRequest) Size() (n int)

func (*TerminateWorkflowExecutionRequest) String 

func (this *TerminateWorkflowExecutionRequest) String() string

func (*TerminateWorkflowExecutionRequest) Unmarshal 

func (m *TerminateWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*TerminateWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *TerminateWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*TerminateWorkflowExecutionRequest) XXX_Marshal 

func (m *TerminateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateWorkflowExecutionRequest) XXX_Merge 

func (m *TerminateWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*TerminateWorkflowExecutionRequest) XXX_Size 

func (m *TerminateWorkflowExecutionRequest) XXX_Size() int

func (*TerminateWorkflowExecutionRequest) XXX_Unmarshal 

func (m *TerminateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type TerminateWorkflowExecutionResponse 

type TerminateWorkflowExecutionResponse struct {
}

func (*TerminateWorkflowExecutionResponse) Descriptor 

func (*TerminateWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*TerminateWorkflowExecutionResponse) Equal 

func (this *TerminateWorkflowExecutionResponse) Equal(that interface{}) bool

func (*TerminateWorkflowExecutionResponse) GoString 

func (this *TerminateWorkflowExecutionResponse) GoString() string

func (*TerminateWorkflowExecutionResponse) Marshal 

func (m *TerminateWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*TerminateWorkflowExecutionResponse) MarshalTo 

func (m *TerminateWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *TerminateWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionResponse) ProtoMessage 

func (*TerminateWorkflowExecutionResponse) ProtoMessage()

func (*TerminateWorkflowExecutionResponse) Reset 

func (m *TerminateWorkflowExecutionResponse) Reset()

func (*TerminateWorkflowExecutionResponse) Size 

func (m *TerminateWorkflowExecutionResponse) Size() (n int)

func (*TerminateWorkflowExecutionResponse) String 

func (this *TerminateWorkflowExecutionResponse) String() string

func (*TerminateWorkflowExecutionResponse) Unmarshal 

func (m *TerminateWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*TerminateWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *TerminateWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*TerminateWorkflowExecutionResponse) XXX_Marshal 

func (m *TerminateWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateWorkflowExecutionResponse) XXX_Merge 

func (m *TerminateWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*TerminateWorkflowExecutionResponse) XXX_Size 

func (m *TerminateWorkflowExecutionResponse) XXX_Size() int

func (*TerminateWorkflowExecutionResponse) XXX_Unmarshal 

func (m *TerminateWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServiceServer) CountWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) CountWorkflowExecutions(ctx context.Context, req *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) DeprecateDomain 

func (*UnimplementedWorkflowServiceServer) DeprecateDomain(ctx context.Context, req *DeprecateDomainRequest) (*DeprecateDomainResponse, error)

func (*UnimplementedWorkflowServiceServer) DescribeDomain 

func (*UnimplementedWorkflowServiceServer) DescribeDomain(ctx context.Context, req *DescribeDomainRequest) (*DescribeDomainResponse, error)

func (*UnimplementedWorkflowServiceServer) DescribeTaskList 

func (*UnimplementedWorkflowServiceServer) DescribeTaskList(ctx context.Context, req *DescribeTaskListRequest) (*DescribeTaskListResponse, error)

func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution(ctx context.Context, req *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) GetClusterInfo 

func (*UnimplementedWorkflowServiceServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

func (*UnimplementedWorkflowServiceServer) GetDomainReplicationMessages 

func (*UnimplementedWorkflowServiceServer) GetDomainReplicationMessages(ctx context.Context, req *GetDomainReplicationMessagesRequest) (*GetDomainReplicationMessagesResponse, error)

func (*UnimplementedWorkflowServiceServer) GetReplicationMessages 

func (*UnimplementedWorkflowServiceServer) GetReplicationMessages(ctx context.Context, req *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)

func (*UnimplementedWorkflowServiceServer) GetSearchAttributes 

func (*UnimplementedWorkflowServiceServer) GetSearchAttributes(ctx context.Context, req *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory 

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory(ctx context.Context, req *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

func (*UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions(ctx context.Context, req *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions(ctx context.Context, req *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListDomains 

func (*UnimplementedWorkflowServiceServer) ListDomains(ctx context.Context, req *ListDomainsRequest) (*ListDomainsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions(ctx context.Context, req *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListTaskListPartitions 

func (*UnimplementedWorkflowServiceServer) ListTaskListPartitions(ctx context.Context, req *ListTaskListPartitionsRequest) (*ListTaskListPartitionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions(ctx context.Context, req *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) PollForActivityTask 

func (*UnimplementedWorkflowServiceServer) PollForActivityTask(ctx context.Context, req *PollForActivityTaskRequest) (*PollForActivityTaskResponse, error)

func (*UnimplementedWorkflowServiceServer) PollForDecisionTask 

func (*UnimplementedWorkflowServiceServer) PollForDecisionTask(ctx context.Context, req *PollForDecisionTaskRequest) (*PollForDecisionTaskResponse, error)

func (*UnimplementedWorkflowServiceServer) QueryWorkflow 

func (*UnimplementedWorkflowServiceServer) QueryWorkflow(ctx context.Context, req *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

func (*UnimplementedWorkflowServiceServer) ReapplyEvents 

func (*UnimplementedWorkflowServiceServer) ReapplyEvents(ctx context.Context, req *ReapplyEventsRequest) (*ReapplyEventsResponse, error)

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat 

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat(ctx context.Context, req *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatByID 

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatByID(ctx context.Context, req *RecordActivityTaskHeartbeatByIDRequest) (*RecordActivityTaskHeartbeatByIDResponse, error)

func (*UnimplementedWorkflowServiceServer) RegisterDomain 

func (*UnimplementedWorkflowServiceServer) RegisterDomain(ctx context.Context, req *RegisterDomainRequest) (*RegisterDomainResponse, error)

func (*UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution(ctx context.Context, req *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) ResetStickyTaskList 

func (*UnimplementedWorkflowServiceServer) ResetStickyTaskList(ctx context.Context, req *ResetStickyTaskListRequest) (*ResetStickyTaskListResponse, error)

func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution(ctx context.Context, req *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled(ctx context.Context, req *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledByID 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledByID(ctx context.Context, req *RespondActivityTaskCanceledByIDRequest) (*RespondActivityTaskCanceledByIDResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted(ctx context.Context, req *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedByID 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedByID(ctx context.Context, req *RespondActivityTaskCompletedByIDRequest) (*RespondActivityTaskCompletedByIDResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed(ctx context.Context, req *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedByID 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedByID(ctx context.Context, req *RespondActivityTaskFailedByIDRequest) (*RespondActivityTaskFailedByIDResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondDecisionTaskCompleted 

func (*UnimplementedWorkflowServiceServer) RespondDecisionTaskCompleted(ctx context.Context, req *RespondDecisionTaskCompletedRequest) (*RespondDecisionTaskCompletedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondDecisionTaskFailed 

func (*UnimplementedWorkflowServiceServer) RespondDecisionTaskFailed(ctx context.Context, req *RespondDecisionTaskFailedRequest) (*RespondDecisionTaskFailedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted 

func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted(ctx context.Context, req *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions(ctx context.Context, req *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution(ctx context.Context, req *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) SignalWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) SignalWorkflowExecution(ctx context.Context, req *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) StartWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) StartWorkflowExecution(ctx context.Context, req *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution(ctx context.Context, req *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) UpdateDomain 

func (*UnimplementedWorkflowServiceServer) UpdateDomain(ctx context.Context, req *UpdateDomainRequest) (*UpdateDomainResponse, error)

type UpdateDomainRequest 

type UpdateDomainRequest struct {
	Name                     string                                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UpdatedInfo              *common.UpdateDomainInfo               `protobuf:"bytes,2,opt,name=updatedInfo,proto3" json:"updatedInfo,omitempty"`
	Configuration            *common.DomainConfiguration            `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration,omitempty"`
	ReplicationConfiguration *common.DomainReplicationConfiguration `protobuf:"bytes,4,opt,name=replicationConfiguration,proto3" json:"replicationConfiguration,omitempty"`
	SecurityToken            string                                 `protobuf:"bytes,5,opt,name=securityToken,proto3" json:"securityToken,omitempty"`
	DeleteBadBinary          string                                 `protobuf:"bytes,6,opt,name=deleteBadBinary,proto3" json:"deleteBadBinary,omitempty"`
}

func (*UpdateDomainRequest) Descriptor 

func (*UpdateDomainRequest) Descriptor() ([]byte, []int)

func (*UpdateDomainRequest) Equal 

func (this *UpdateDomainRequest) Equal(that interface{}) bool

func (*UpdateDomainRequest) GetConfiguration 

func (m *UpdateDomainRequest) GetConfiguration() *common.DomainConfiguration

func (*UpdateDomainRequest) GetDeleteBadBinary 

func (m *UpdateDomainRequest) GetDeleteBadBinary() string

func (*UpdateDomainRequest) GetName 

func (m *UpdateDomainRequest) GetName() string

func (*UpdateDomainRequest) GetReplicationConfiguration 

func (m *UpdateDomainRequest) GetReplicationConfiguration() *common.DomainReplicationConfiguration

func (*UpdateDomainRequest) GetSecurityToken 

func (m *UpdateDomainRequest) GetSecurityToken() string

func (*UpdateDomainRequest) GetUpdatedInfo 

func (m *UpdateDomainRequest) GetUpdatedInfo() *common.UpdateDomainInfo

func (*UpdateDomainRequest) GoString 

func (this *UpdateDomainRequest) GoString() string

func (*UpdateDomainRequest) Marshal 

func (m *UpdateDomainRequest) Marshal() (dAtA []byte, err error)

func (*UpdateDomainRequest) MarshalTo 

func (m *UpdateDomainRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateDomainRequest) MarshalToSizedBuffer 

func (m *UpdateDomainRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateDomainRequest) ProtoMessage 

func (*UpdateDomainRequest) ProtoMessage()

func (*UpdateDomainRequest) Reset 

func (m *UpdateDomainRequest) Reset()

func (*UpdateDomainRequest) Size 

func (m *UpdateDomainRequest) Size() (n int)

func (*UpdateDomainRequest) String 

func (this *UpdateDomainRequest) String() string

func (*UpdateDomainRequest) Unmarshal 

func (m *UpdateDomainRequest) Unmarshal(dAtA []byte) error

func (*UpdateDomainRequest) XXX_DiscardUnknown 

func (m *UpdateDomainRequest) XXX_DiscardUnknown()

func (*UpdateDomainRequest) XXX_Marshal 

func (m *UpdateDomainRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateDomainRequest) XXX_Merge 

func (m *UpdateDomainRequest) XXX_Merge(src proto.Message)

func (*UpdateDomainRequest) XXX_Size 

func (m *UpdateDomainRequest) XXX_Size() int

func (*UpdateDomainRequest) XXX_Unmarshal 

func (m *UpdateDomainRequest) XXX_Unmarshal(b []byte) error

type UpdateDomainResponse 

type UpdateDomainResponse struct {
	DomainInfo               *common.DomainInfo                     `protobuf:"bytes,1,opt,name=domainInfo,proto3" json:"domainInfo,omitempty"`
	Configuration            *common.DomainConfiguration            `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"`
	ReplicationConfiguration *common.DomainReplicationConfiguration `protobuf:"bytes,3,opt,name=replicationConfiguration,proto3" json:"replicationConfiguration,omitempty"`
	FailoverVersion          int64                                  `protobuf:"varint,4,opt,name=failoverVersion,proto3" json:"failoverVersion,omitempty"`
	IsGlobalDomain           bool                                   `protobuf:"varint,5,opt,name=isGlobalDomain,proto3" json:"isGlobalDomain,omitempty"`
}

func (*UpdateDomainResponse) Descriptor 

func (*UpdateDomainResponse) Descriptor() ([]byte, []int)

func (*UpdateDomainResponse) Equal 

func (this *UpdateDomainResponse) Equal(that interface{}) bool

func (*UpdateDomainResponse) GetConfiguration 

func (m *UpdateDomainResponse) GetConfiguration() *common.DomainConfiguration

func (*UpdateDomainResponse) GetDomainInfo 

func (m *UpdateDomainResponse) GetDomainInfo() *common.DomainInfo

func (*UpdateDomainResponse) GetFailoverVersion 

func (m *UpdateDomainResponse) GetFailoverVersion() int64

func (*UpdateDomainResponse) GetIsGlobalDomain 

func (m *UpdateDomainResponse) GetIsGlobalDomain() bool

func (*UpdateDomainResponse) GetReplicationConfiguration 

func (m *UpdateDomainResponse) GetReplicationConfiguration() *common.DomainReplicationConfiguration

func (*UpdateDomainResponse) GoString 

func (this *UpdateDomainResponse) GoString() string

func (*UpdateDomainResponse) Marshal 

func (m *UpdateDomainResponse) Marshal() (dAtA []byte, err error)

func (*UpdateDomainResponse) MarshalTo 

func (m *UpdateDomainResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateDomainResponse) MarshalToSizedBuffer 

func (m *UpdateDomainResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateDomainResponse) ProtoMessage 

func (*UpdateDomainResponse) ProtoMessage()

func (*UpdateDomainResponse) Reset 

func (m *UpdateDomainResponse) Reset()

func (*UpdateDomainResponse) Size 

func (m *UpdateDomainResponse) Size() (n int)

func (*UpdateDomainResponse) String 

func (this *UpdateDomainResponse) String() string

func (*UpdateDomainResponse) Unmarshal 

func (m *UpdateDomainResponse) Unmarshal(dAtA []byte) error

func (*UpdateDomainResponse) XXX_DiscardUnknown 

func (m *UpdateDomainResponse) XXX_DiscardUnknown()

func (*UpdateDomainResponse) XXX_Marshal 

func (m *UpdateDomainResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateDomainResponse) XXX_Merge 

func (m *UpdateDomainResponse) XXX_Merge(src proto.Message)

func (*UpdateDomainResponse) XXX_Size 

func (m *UpdateDomainResponse) XXX_Size() int

func (*UpdateDomainResponse) XXX_Unmarshal 

func (m *UpdateDomainResponse) XXX_Unmarshal(b []byte) error

type WorkflowServiceClient 

type WorkflowServiceClient interface {
	// RegisterDomain creates a new domain which can be used as a container for all resources.  Domain is a top level
	// entity within Cadence, used as a container for all resources like workflow executions, task lists, etc.  Domain
	// acts as a sandbox and provides isolation for all resources within the domain.  All resources belongs to exactly one
	// domain.
	RegisterDomain(ctx context.Context, in *RegisterDomainRequest, opts ...grpc.CallOption) (*RegisterDomainResponse, error)
	// DescribeDomain returns the information and configuration for a registered domain.
	DescribeDomain(ctx context.Context, in *DescribeDomainRequest, opts ...grpc.CallOption) (*DescribeDomainResponse, error)
	// ListDomains returns the information and configuration for all domains.
	ListDomains(ctx context.Context, in *ListDomainsRequest, opts ...grpc.CallOption) (*ListDomainsResponse, error)
	// UpdateDomain is used to update the information and configuration for a registered domain.
	UpdateDomain(ctx context.Context, in *UpdateDomainRequest, opts ...grpc.CallOption) (*UpdateDomainResponse, error)
	// DeprecateDomain us used to update status of a registered domain to DEPRECATED.  Once the domain is deprecated
	// it cannot be used to start new workflow executions.  Existing workflow executions will continue to run on
	// deprecated domains.
	DeprecateDomain(ctx context.Context, in *DeprecateDomainRequest, opts ...grpc.CallOption) (*DeprecateDomainResponse, error)
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first DecisionTask for the worker to make the
	// first decision for this instance.  It will return 'WorkflowExecutionAlreadyStartedError', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(ctx context.Context, in *StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution.  It fails with 'EntityNotExistError' if specified workflow
	// execution in unknown to the service.
	GetWorkflowExecutionHistory(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryResponse, error)
	// PollForDecisionTask is called by application worker to process DecisionTask from a specific task list.  A
	// DecisionTask is dispatched to callers for active workflow executions, with pending decisions.
	// Application is then expected to call 'RespondDecisionTaskCompleted' API when it is done processing the DecisionTask.
	// It will also create a 'DecisionTaskStarted' event in the history for that session before handing off DecisionTask to
	// application worker.
	PollForDecisionTask(ctx context.Context, in *PollForDecisionTaskRequest, opts ...grpc.CallOption) (*PollForDecisionTaskResponse, error)
	// RespondDecisionTaskCompleted is called by application worker to complete a DecisionTask handed as a result of
	// 'PollForDecisionTask' API call.  Completing a DecisionTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding decisions.  It will also create a DecisionTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollForDecisionTask API call
	// for completing the DecisionTask.
	// The response could contain a new decision task if there is one or if the request asking for one.
	RespondDecisionTaskCompleted(ctx context.Context, in *RespondDecisionTaskCompletedRequest, opts ...grpc.CallOption) (*RespondDecisionTaskCompletedResponse, error)
	// RespondDecisionTaskFailed is called by application worker to indicate failure.  This results in
	// DecisionTaskFailedEvent written to the history and a new DecisionTask created.  This API can be used by client to
	// either clear sticky task list or report any panics during DecisionTask processing.  Cadence will only append first
	// DecisionTaskFailed event to the history of workflow execution for consecutive failures.
	RespondDecisionTaskFailed(ctx context.Context, in *RespondDecisionTaskFailedRequest, opts ...grpc.CallOption) (*RespondDecisionTaskFailedResponse, error)
	// PollForActivityTask is called by application worker to process ActivityTask from a specific task list.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask decision is made for a workflow execution.
	// Application is expected to call 'RespondActivityTaskCompleted' or 'RespondActivityTaskFailed' once it is done
	// processing the task.
	// Application also needs to call 'RecordActivityTaskHeartbeat' API within 'heartbeatTimeoutSeconds' interval to
	// prevent the task from getting timed out.  An event 'ActivityTaskStarted' event is also written to workflow execution
	// history before the ActivityTask is dispatched to application worker.
	PollForActivityTask(ctx context.Context, in *PollForActivityTaskRequest, opts ...grpc.CallOption) (*PollForActivityTaskResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'EntityNotExistsError' in such situations.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for heart beating.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// RecordActivityTaskHeartbeatByID is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timed out and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeatByID' will
	// fail with 'EntityNotExistsError' in such situations.  Instead of using 'taskToken' like in RecordActivityTaskHeartbeat,
	// use Domain, WorkflowID and ActivityID
	RecordActivityTaskHeartbeatByID(ctx context.Context, in *RecordActivityTaskHeartbeatByIDRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatByIDResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new DecisionTask
	// created for the workflow so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(ctx context.Context, in *RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	// RespondActivityTaskCompletedByID is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new DecisionTask
	// created for the workflow so new decisions could be made.  Similar to RespondActivityTaskCompleted but use Domain,
	// WorkflowID and ActivityID instead of 'taskToken' for completion. It fails with 'EntityNotExistsError'
	// if the these IDs are not valid anymore due to activity timeout.
	RespondActivityTaskCompletedByID(ctx context.Context, in *RespondActivityTaskCompletedByIDRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedByIDResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(ctx context.Context, in *RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	// RespondActivityTaskFailedByID is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskFailed' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Similar to RespondActivityTaskFailed but use
	// Domain, WorkflowID and ActivityID instead of 'taskToken' for completion. It fails with 'EntityNotExistsError'
	// if the these IDs are not valid anymore due to activity timeout.
	RespondActivityTaskFailedByID(ctx context.Context, in *RespondActivityTaskFailedByIDRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedByIDResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(ctx context.Context, in *RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	// RespondActivityTaskCanceledByID is called by application worker when it is successfully canceled an ActivityTask.
	// It will result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Similar to RespondActivityTaskCanceled but use
	// Domain, WorkflowID and ActivityID instead of 'taskToken' for completion. It fails with 'EntityNotExistsError'
	// if the these IDs are not valid anymore due to activity timeout.
	RespondActivityTaskCanceledByID(ctx context.Context, in *RespondActivityTaskCanceledByIDRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledByIDResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made. It fails with 'EntityNotExistsError' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a decision task being created for the execution.
	SignalWorkflowExecution(ctx context.Context, in *SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	// SignalWithStartWorkflowExecution is used to ensure sending signal to a workflow.
	// If the workflow is running, this results in WorkflowExecutionSignaled event being recorded in the history
	// and a decision task being created for the execution.
	// If the workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled
	// events being recorded in history, and a decision task being created for the execution
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to DecisionTaskCompleted event(exclusive).
	// And it will immediately terminating the current execution instance.
	ResetWorkflowExecution(ctx context.Context, in *ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*TerminateWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific domain.
	ListOpenWorkflowExecutions(ctx context.Context, in *ListOpenWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific domain.
	ListClosedWorkflowExecutions(ctx context.Context, in *ListClosedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific domain.
	ListWorkflowExecutions(ctx context.Context, in *ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific domain.
	ListArchivedWorkflowExecutions(ctx context.Context, in *ListArchivedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific domain without order.
	ScanWorkflowExecutions(ctx context.Context, in *ScanWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific domain.
	CountWorkflowExecutions(ctx context.Context, in *CountWorkflowExecutionsRequest, opts ...grpc.CallOption) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	GetSearchAttributes(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by application worker to complete a QueryTask (which is a DecisionTask for query)
	// as a result of 'PollForDecisionTask' API call. Completing a QueryTask will unblock the client call to 'QueryWorkflow'
	// API and return the query result to client as a response to 'QueryWorkflow' API call.
	RespondQueryTaskCompleted(ctx context.Context, in *RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskList resets the sticky task list related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskList
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskList(ctx context.Context, in *ResetStickyTaskListRequest, opts ...grpc.CallOption) (*ResetStickyTaskListResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution
	QueryWorkflow(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(ctx context.Context, in *DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskList returns information about the target task list, right now this API returns the
	// pollers which polled this task list in last few minutes.
	DescribeTaskList(ctx context.Context, in *DescribeTaskListRequest, opts ...grpc.CallOption) (*DescribeTaskListResponse, error)
	// GetReplicationMessages returns new replication tasks since the read level provided in the token.
	GetReplicationMessages(ctx context.Context, in *GetReplicationMessagesRequest, opts ...grpc.CallOption) (*GetReplicationMessagesResponse, error)
	// GetDomainReplicationMessages returns new domain replication tasks since last retrieved task ID.
	GetDomainReplicationMessages(ctx context.Context, in *GetDomainReplicationMessagesRequest, opts ...grpc.CallOption) (*GetDomainReplicationMessagesResponse, error)
	// ReapplyEvents applies stale events to the current workflow and current run
	ReapplyEvents(ctx context.Context, in *ReapplyEventsRequest, opts ...grpc.CallOption) (*ReapplyEventsResponse, error)
	// GetClusterInfo returns information about cadence cluster
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	ListTaskListPartitions(ctx context.Context, in *ListTaskListPartitionsRequest, opts ...grpc.CallOption) (*ListTaskListPartitionsResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowServiceClient 

func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

type WorkflowServiceServer 

type WorkflowServiceServer interface {
	// RegisterDomain creates a new domain which can be used as a container for all resources.  Domain is a top level
	// entity within Cadence, used as a container for all resources like workflow executions, task lists, etc.  Domain
	// acts as a sandbox and provides isolation for all resources within the domain.  All resources belongs to exactly one
	// domain.
	RegisterDomain(context.Context, *RegisterDomainRequest) (*RegisterDomainResponse, error)
	// DescribeDomain returns the information and configuration for a registered domain.
	DescribeDomain(context.Context, *DescribeDomainRequest) (*DescribeDomainResponse, error)
	// ListDomains returns the information and configuration for all domains.
	ListDomains(context.Context, *ListDomainsRequest) (*ListDomainsResponse, error)
	// UpdateDomain is used to update the information and configuration for a registered domain.
	UpdateDomain(context.Context, *UpdateDomainRequest) (*UpdateDomainResponse, error)
	// DeprecateDomain us used to update status of a registered domain to DEPRECATED.  Once the domain is deprecated
	// it cannot be used to start new workflow executions.  Existing workflow executions will continue to run on
	// deprecated domains.
	DeprecateDomain(context.Context, *DeprecateDomainRequest) (*DeprecateDomainResponse, error)
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first DecisionTask for the worker to make the
	// first decision for this instance.  It will return 'WorkflowExecutionAlreadyStartedError', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution.  It fails with 'EntityNotExistError' if specified workflow
	// execution in unknown to the service.
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)
	// PollForDecisionTask is called by application worker to process DecisionTask from a specific task list.  A
	// DecisionTask is dispatched to callers for active workflow executions, with pending decisions.
	// Application is then expected to call 'RespondDecisionTaskCompleted' API when it is done processing the DecisionTask.
	// It will also create a 'DecisionTaskStarted' event in the history for that session before handing off DecisionTask to
	// application worker.
	PollForDecisionTask(context.Context, *PollForDecisionTaskRequest) (*PollForDecisionTaskResponse, error)
	// RespondDecisionTaskCompleted is called by application worker to complete a DecisionTask handed as a result of
	// 'PollForDecisionTask' API call.  Completing a DecisionTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding decisions.  It will also create a DecisionTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollForDecisionTask API call
	// for completing the DecisionTask.
	// The response could contain a new decision task if there is one or if the request asking for one.
	RespondDecisionTaskCompleted(context.Context, *RespondDecisionTaskCompletedRequest) (*RespondDecisionTaskCompletedResponse, error)
	// RespondDecisionTaskFailed is called by application worker to indicate failure.  This results in
	// DecisionTaskFailedEvent written to the history and a new DecisionTask created.  This API can be used by client to
	// either clear sticky task list or report any panics during DecisionTask processing.  Cadence will only append first
	// DecisionTaskFailed event to the history of workflow execution for consecutive failures.
	RespondDecisionTaskFailed(context.Context, *RespondDecisionTaskFailedRequest) (*RespondDecisionTaskFailedResponse, error)
	// PollForActivityTask is called by application worker to process ActivityTask from a specific task list.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask decision is made for a workflow execution.
	// Application is expected to call 'RespondActivityTaskCompleted' or 'RespondActivityTaskFailed' once it is done
	// processing the task.
	// Application also needs to call 'RecordActivityTaskHeartbeat' API within 'heartbeatTimeoutSeconds' interval to
	// prevent the task from getting timed out.  An event 'ActivityTaskStarted' event is also written to workflow execution
	// history before the ActivityTask is dispatched to application worker.
	PollForActivityTask(context.Context, *PollForActivityTaskRequest) (*PollForActivityTaskResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'EntityNotExistsError' in such situations.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for heart beating.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// RecordActivityTaskHeartbeatByID is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timed out and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeatByID' will
	// fail with 'EntityNotExistsError' in such situations.  Instead of using 'taskToken' like in RecordActivityTaskHeartbeat,
	// use Domain, WorkflowID and ActivityID
	RecordActivityTaskHeartbeatByID(context.Context, *RecordActivityTaskHeartbeatByIDRequest) (*RecordActivityTaskHeartbeatByIDResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new DecisionTask
	// created for the workflow so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	// RespondActivityTaskCompletedByID is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new DecisionTask
	// created for the workflow so new decisions could be made.  Similar to RespondActivityTaskCompleted but use Domain,
	// WorkflowID and ActivityID instead of 'taskToken' for completion. It fails with 'EntityNotExistsError'
	// if the these IDs are not valid anymore due to activity timeout.
	RespondActivityTaskCompletedByID(context.Context, *RespondActivityTaskCompletedByIDRequest) (*RespondActivityTaskCompletedByIDResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	// RespondActivityTaskFailedByID is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskFailed' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Similar to RespondActivityTaskFailed but use
	// Domain, WorkflowID and ActivityID instead of 'taskToken' for completion. It fails with 'EntityNotExistsError'
	// if the these IDs are not valid anymore due to activity timeout.
	RespondActivityTaskFailedByID(context.Context, *RespondActivityTaskFailedByIDRequest) (*RespondActivityTaskFailedByIDResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	// RespondActivityTaskCanceledByID is called by application worker when it is successfully canceled an ActivityTask.
	// It will result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made.  Similar to RespondActivityTaskCanceled but use
	// Domain, WorkflowID and ActivityID instead of 'taskToken' for completion. It fails with 'EntityNotExistsError'
	// if the these IDs are not valid anymore due to activity timeout.
	RespondActivityTaskCanceledByID(context.Context, *RespondActivityTaskCanceledByIDRequest) (*RespondActivityTaskCanceledByIDResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new DecisionTask
	// created for the workflow instance so new decisions could be made. It fails with 'EntityNotExistsError' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a decision task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// SignalWithStartWorkflowExecution is used to ensure sending signal to a workflow.
	// If the workflow is running, this results in WorkflowExecutionSignaled event being recorded in the history
	// and a decision task being created for the execution.
	// If the workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled
	// events being recorded in history, and a decision task being created for the execution
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to DecisionTaskCompleted event(exclusive).
	// And it will immediately terminating the current execution instance.
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific domain.
	ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific domain.
	ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific domain.
	ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific domain.
	ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific domain without order.
	ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific domain.
	CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by application worker to complete a QueryTask (which is a DecisionTask for query)
	// as a result of 'PollForDecisionTask' API call. Completing a QueryTask will unblock the client call to 'QueryWorkflow'
	// API and return the query result to client as a response to 'QueryWorkflow' API call.
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskList resets the sticky task list related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskList
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskList(context.Context, *ResetStickyTaskListRequest) (*ResetStickyTaskListResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskList returns information about the target task list, right now this API returns the
	// pollers which polled this task list in last few minutes.
	DescribeTaskList(context.Context, *DescribeTaskListRequest) (*DescribeTaskListResponse, error)
	// GetReplicationMessages returns new replication tasks since the read level provided in the token.
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)
	// GetDomainReplicationMessages returns new domain replication tasks since last retrieved task ID.
	GetDomainReplicationMessages(context.Context, *GetDomainReplicationMessagesRequest) (*GetDomainReplicationMessagesResponse, error)
	// ReapplyEvents applies stale events to the current workflow and current run
	ReapplyEvents(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)
	// GetClusterInfo returns information about cadence cluster
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	ListTaskListPartitions(context.Context, *ListTaskListPartitionsRequest) (*ListTaskListPartitionsResponse, error)
}

WorkflowServiceServer is the server API for WorkflowService service.

type WorkflowServiceYARPCClient 

type WorkflowServiceYARPCClient interface {
	RegisterDomain(context.Context, *RegisterDomainRequest, ...yarpc.CallOption) (*RegisterDomainResponse, error)
	DescribeDomain(context.Context, *DescribeDomainRequest, ...yarpc.CallOption) (*DescribeDomainResponse, error)
	ListDomains(context.Context, *ListDomainsRequest, ...yarpc.CallOption) (*ListDomainsResponse, error)
	UpdateDomain(context.Context, *UpdateDomainRequest, ...yarpc.CallOption) (*UpdateDomainResponse, error)
	DeprecateDomain(context.Context, *DeprecateDomainRequest, ...yarpc.CallOption) (*DeprecateDomainResponse, error)
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest, ...yarpc.CallOption) (*StartWorkflowExecutionResponse, error)
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest, ...yarpc.CallOption) (*GetWorkflowExecutionHistoryResponse, error)
	PollForDecisionTask(context.Context, *PollForDecisionTaskRequest, ...yarpc.CallOption) (*PollForDecisionTaskResponse, error)
	RespondDecisionTaskCompleted(context.Context, *RespondDecisionTaskCompletedRequest, ...yarpc.CallOption) (*RespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *RespondDecisionTaskFailedRequest, ...yarpc.CallOption) (*RespondDecisionTaskFailedResponse, error)
	PollForActivityTask(context.Context, *PollForActivityTaskRequest, ...yarpc.CallOption) (*PollForActivityTaskResponse, error)
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest, ...yarpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskHeartbeatByID(context.Context, *RecordActivityTaskHeartbeatByIDRequest, ...yarpc.CallOption) (*RecordActivityTaskHeartbeatByIDResponse, error)
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest, ...yarpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	RespondActivityTaskCompletedByID(context.Context, *RespondActivityTaskCompletedByIDRequest, ...yarpc.CallOption) (*RespondActivityTaskCompletedByIDResponse, error)
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest, ...yarpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	RespondActivityTaskFailedByID(context.Context, *RespondActivityTaskFailedByIDRequest, ...yarpc.CallOption) (*RespondActivityTaskFailedByIDResponse, error)
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest, ...yarpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	RespondActivityTaskCanceledByID(context.Context, *RespondActivityTaskCanceledByIDRequest, ...yarpc.CallOption) (*RespondActivityTaskCanceledByIDResponse, error)
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest, ...yarpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest, ...yarpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest, ...yarpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest, ...yarpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest, ...yarpc.CallOption) (*TerminateWorkflowExecutionResponse, error)
	ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest, ...yarpc.CallOption) (*ListOpenWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest, ...yarpc.CallOption) (*ListClosedWorkflowExecutionsResponse, error)
	ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest, ...yarpc.CallOption) (*ListWorkflowExecutionsResponse, error)
	ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest, ...yarpc.CallOption) (*ListArchivedWorkflowExecutionsResponse, error)
	ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest, ...yarpc.CallOption) (*ScanWorkflowExecutionsResponse, error)
	CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest, ...yarpc.CallOption) (*CountWorkflowExecutionsResponse, error)
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest, ...yarpc.CallOption) (*GetSearchAttributesResponse, error)
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest, ...yarpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	ResetStickyTaskList(context.Context, *ResetStickyTaskListRequest, ...yarpc.CallOption) (*ResetStickyTaskListResponse, error)
	QueryWorkflow(context.Context, *QueryWorkflowRequest, ...yarpc.CallOption) (*QueryWorkflowResponse, error)
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest, ...yarpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	DescribeTaskList(context.Context, *DescribeTaskListRequest, ...yarpc.CallOption) (*DescribeTaskListResponse, error)
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest, ...yarpc.CallOption) (*GetReplicationMessagesResponse, error)
	GetDomainReplicationMessages(context.Context, *GetDomainReplicationMessagesRequest, ...yarpc.CallOption) (*GetDomainReplicationMessagesResponse, error)
	ReapplyEvents(context.Context, *ReapplyEventsRequest, ...yarpc.CallOption) (*ReapplyEventsResponse, error)
	GetClusterInfo(context.Context, *GetClusterInfoRequest, ...yarpc.CallOption) (*GetClusterInfoResponse, error)
	ListTaskListPartitions(context.Context, *ListTaskListPartitionsRequest, ...yarpc.CallOption) (*ListTaskListPartitionsResponse, error)
}

WorkflowServiceYARPCClient is the YARPC client-side interface for the WorkflowService service.

func NewWorkflowServiceYARPCClient 

func NewWorkflowServiceYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) WorkflowServiceYARPCClient

NewWorkflowServiceYARPCClient builds a new YARPC client for the WorkflowService service.

type WorkflowServiceYARPCServer 

type WorkflowServiceYARPCServer interface {
	RegisterDomain(context.Context, *RegisterDomainRequest) (*RegisterDomainResponse, error)
	DescribeDomain(context.Context, *DescribeDomainRequest) (*DescribeDomainResponse, error)
	ListDomains(context.Context, *ListDomainsRequest) (*ListDomainsResponse, error)
	UpdateDomain(context.Context, *UpdateDomainRequest) (*UpdateDomainResponse, error)
	DeprecateDomain(context.Context, *DeprecateDomainRequest) (*DeprecateDomainResponse, error)
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)
	PollForDecisionTask(context.Context, *PollForDecisionTaskRequest) (*PollForDecisionTaskResponse, error)
	RespondDecisionTaskCompleted(context.Context, *RespondDecisionTaskCompletedRequest) (*RespondDecisionTaskCompletedResponse, error)
	RespondDecisionTaskFailed(context.Context, *RespondDecisionTaskFailedRequest) (*RespondDecisionTaskFailedResponse, error)
	PollForActivityTask(context.Context, *PollForActivityTaskRequest) (*PollForActivityTaskResponse, error)
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	RecordActivityTaskHeartbeatByID(context.Context, *RecordActivityTaskHeartbeatByIDRequest) (*RecordActivityTaskHeartbeatByIDResponse, error)
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	RespondActivityTaskCompletedByID(context.Context, *RespondActivityTaskCompletedByIDRequest) (*RespondActivityTaskCompletedByIDResponse, error)
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	RespondActivityTaskFailedByID(context.Context, *RespondActivityTaskFailedByIDRequest) (*RespondActivityTaskFailedByIDResponse, error)
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	RespondActivityTaskCanceledByID(context.Context, *RespondActivityTaskCanceledByIDRequest) (*RespondActivityTaskCanceledByIDResponse, error)
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)
	ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)
	ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)
	ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)
	CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	ResetStickyTaskList(context.Context, *ResetStickyTaskListRequest) (*ResetStickyTaskListResponse, error)
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	DescribeTaskList(context.Context, *DescribeTaskListRequest) (*DescribeTaskListResponse, error)
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)
	GetDomainReplicationMessages(context.Context, *GetDomainReplicationMessagesRequest) (*GetDomainReplicationMessagesResponse, error)
	ReapplyEvents(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	ListTaskListPartitions(context.Context, *ListTaskListPartitionsRequest) (*ListTaskListPartitionsResponse, error)
}

WorkflowServiceYARPCServer is the YARPC server-side interface for the WorkflowService service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.