workflowservice

package

Go to main page

Versions in this module

v0

v0.15.1

Jun 1, 2022

v0.15.0

May 25, 2022

v0.14.1

May 16, 2022

v0.14.0

May 16, 2022

v0.13.2

May 12, 2022

Changes in this version

+ type CreateScheduleRequest struct

+ Identity string

+ InitialPatch *v112.SchedulePatch

+ Memo *v13.Memo

+ Namespace string

+ RequestId string

+ Schedule *v112.Schedule

+ ScheduleId string

+ SearchAttributes *v13.SearchAttributes

+ func (*CreateScheduleRequest) Descriptor() ([]byte, []int)

+ func (*CreateScheduleRequest) ProtoMessage()

+ func (m *CreateScheduleRequest) GetIdentity() string

+ func (m *CreateScheduleRequest) GetInitialPatch() *v112.SchedulePatch

+ func (m *CreateScheduleRequest) GetMemo() *v13.Memo

+ func (m *CreateScheduleRequest) GetNamespace() string

+ func (m *CreateScheduleRequest) GetRequestId() string

+ func (m *CreateScheduleRequest) GetSchedule() *v112.Schedule

+ func (m *CreateScheduleRequest) GetScheduleId() string

+ func (m *CreateScheduleRequest) GetSearchAttributes() *v13.SearchAttributes

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

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

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

+ func (m *CreateScheduleRequest) Reset()

+ func (m *CreateScheduleRequest) Size() (n int)

+ func (m *CreateScheduleRequest) Unmarshal(dAtA []byte) error

+ func (m *CreateScheduleRequest) XXX_DiscardUnknown()

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

+ func (m *CreateScheduleRequest) XXX_Merge(src proto.Message)

+ func (m *CreateScheduleRequest) XXX_Size() int

+ func (m *CreateScheduleRequest) XXX_Unmarshal(b []byte) error

+ func (this *CreateScheduleRequest) Equal(that interface{}) bool

+ func (this *CreateScheduleRequest) GoString() string

+ func (this *CreateScheduleRequest) String() string

+ type CreateScheduleResponse struct

+ ConflictToken []byte

+ func (*CreateScheduleResponse) Descriptor() ([]byte, []int)

+ func (*CreateScheduleResponse) ProtoMessage()

+ func (m *CreateScheduleResponse) GetConflictToken() []byte

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

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

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

+ func (m *CreateScheduleResponse) Reset()

+ func (m *CreateScheduleResponse) Size() (n int)

+ func (m *CreateScheduleResponse) Unmarshal(dAtA []byte) error

+ func (m *CreateScheduleResponse) XXX_DiscardUnknown()

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

+ func (m *CreateScheduleResponse) XXX_Merge(src proto.Message)

+ func (m *CreateScheduleResponse) XXX_Size() int

+ func (m *CreateScheduleResponse) XXX_Unmarshal(b []byte) error

+ func (this *CreateScheduleResponse) Equal(that interface{}) bool

+ func (this *CreateScheduleResponse) GoString() string

+ func (this *CreateScheduleResponse) String() string

+ type DeleteScheduleRequest struct

+ Identity string

+ Namespace string

+ ScheduleId string

+ func (*DeleteScheduleRequest) Descriptor() ([]byte, []int)

+ func (*DeleteScheduleRequest) ProtoMessage()

+ func (m *DeleteScheduleRequest) GetIdentity() string

+ func (m *DeleteScheduleRequest) GetNamespace() string

+ func (m *DeleteScheduleRequest) GetScheduleId() string

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

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

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

+ func (m *DeleteScheduleRequest) Reset()

+ func (m *DeleteScheduleRequest) Size() (n int)

+ func (m *DeleteScheduleRequest) Unmarshal(dAtA []byte) error

+ func (m *DeleteScheduleRequest) XXX_DiscardUnknown()

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

+ func (m *DeleteScheduleRequest) XXX_Merge(src proto.Message)

+ func (m *DeleteScheduleRequest) XXX_Size() int

+ func (m *DeleteScheduleRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeleteScheduleRequest) Equal(that interface{}) bool

+ func (this *DeleteScheduleRequest) GoString() string

+ func (this *DeleteScheduleRequest) String() string

+ type DeleteScheduleResponse struct

+ func (*DeleteScheduleResponse) Descriptor() ([]byte, []int)

+ func (*DeleteScheduleResponse) ProtoMessage()

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

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

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

+ func (m *DeleteScheduleResponse) Reset()

+ func (m *DeleteScheduleResponse) Size() (n int)

+ func (m *DeleteScheduleResponse) Unmarshal(dAtA []byte) error

+ func (m *DeleteScheduleResponse) XXX_DiscardUnknown()

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

+ func (m *DeleteScheduleResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteScheduleResponse) XXX_Size() int

+ func (m *DeleteScheduleResponse) XXX_Unmarshal(b []byte) error

+ func (this *DeleteScheduleResponse) Equal(that interface{}) bool

+ func (this *DeleteScheduleResponse) GoString() string

+ func (this *DeleteScheduleResponse) String() string

+ type DescribeScheduleRequest struct

+ Namespace string

+ ScheduleId string

+ func (*DescribeScheduleRequest) Descriptor() ([]byte, []int)

+ func (*DescribeScheduleRequest) ProtoMessage()

+ func (m *DescribeScheduleRequest) GetNamespace() string

+ func (m *DescribeScheduleRequest) GetScheduleId() string

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

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

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

+ func (m *DescribeScheduleRequest) Reset()

+ func (m *DescribeScheduleRequest) Size() (n int)

+ func (m *DescribeScheduleRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeScheduleRequest) XXX_DiscardUnknown()

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

+ func (m *DescribeScheduleRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeScheduleRequest) XXX_Size() int

+ func (m *DescribeScheduleRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeScheduleRequest) Equal(that interface{}) bool

+ func (this *DescribeScheduleRequest) GoString() string

+ func (this *DescribeScheduleRequest) String() string

+ type DescribeScheduleResponse struct

+ ConflictToken []byte

+ Info *v112.ScheduleInfo

+ Memo *v13.Memo

+ Schedule *v112.Schedule

+ SearchAttributes *v13.SearchAttributes

+ func (*DescribeScheduleResponse) Descriptor() ([]byte, []int)

+ func (*DescribeScheduleResponse) ProtoMessage()

+ func (m *DescribeScheduleResponse) GetConflictToken() []byte

+ func (m *DescribeScheduleResponse) GetInfo() *v112.ScheduleInfo

+ func (m *DescribeScheduleResponse) GetMemo() *v13.Memo

+ func (m *DescribeScheduleResponse) GetSchedule() *v112.Schedule

+ func (m *DescribeScheduleResponse) GetSearchAttributes() *v13.SearchAttributes

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

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

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

+ func (m *DescribeScheduleResponse) Reset()

+ func (m *DescribeScheduleResponse) Size() (n int)

+ func (m *DescribeScheduleResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeScheduleResponse) XXX_DiscardUnknown()

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

+ func (m *DescribeScheduleResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeScheduleResponse) XXX_Size() int

+ func (m *DescribeScheduleResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeScheduleResponse) Equal(that interface{}) bool

+ func (this *DescribeScheduleResponse) GoString() string

+ func (this *DescribeScheduleResponse) String() string

+ type ListScheduleMatchingTimesRequest struct

+ EndTime *time.Time

+ Namespace string

+ ScheduleId string

+ StartTime *time.Time

+ func (*ListScheduleMatchingTimesRequest) Descriptor() ([]byte, []int)

+ func (*ListScheduleMatchingTimesRequest) ProtoMessage()

+ func (m *ListScheduleMatchingTimesRequest) GetEndTime() *time.Time

+ func (m *ListScheduleMatchingTimesRequest) GetNamespace() string

+ func (m *ListScheduleMatchingTimesRequest) GetScheduleId() string

+ func (m *ListScheduleMatchingTimesRequest) GetStartTime() *time.Time

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

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

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

+ func (m *ListScheduleMatchingTimesRequest) Reset()

+ func (m *ListScheduleMatchingTimesRequest) Size() (n int)

+ func (m *ListScheduleMatchingTimesRequest) Unmarshal(dAtA []byte) error

+ func (m *ListScheduleMatchingTimesRequest) XXX_DiscardUnknown()

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

+ func (m *ListScheduleMatchingTimesRequest) XXX_Merge(src proto.Message)

+ func (m *ListScheduleMatchingTimesRequest) XXX_Size() int

+ func (m *ListScheduleMatchingTimesRequest) XXX_Unmarshal(b []byte) error

+ func (this *ListScheduleMatchingTimesRequest) Equal(that interface{}) bool

+ func (this *ListScheduleMatchingTimesRequest) GoString() string

+ func (this *ListScheduleMatchingTimesRequest) String() string

+ type ListScheduleMatchingTimesResponse struct

+ StartTime []*time.Time

+ func (*ListScheduleMatchingTimesResponse) Descriptor() ([]byte, []int)

+ func (*ListScheduleMatchingTimesResponse) ProtoMessage()

+ func (m *ListScheduleMatchingTimesResponse) GetStartTime() []*time.Time

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

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

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

+ func (m *ListScheduleMatchingTimesResponse) Reset()

+ func (m *ListScheduleMatchingTimesResponse) Size() (n int)

+ func (m *ListScheduleMatchingTimesResponse) Unmarshal(dAtA []byte) error

+ func (m *ListScheduleMatchingTimesResponse) XXX_DiscardUnknown()

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

+ func (m *ListScheduleMatchingTimesResponse) XXX_Merge(src proto.Message)

+ func (m *ListScheduleMatchingTimesResponse) XXX_Size() int

+ func (m *ListScheduleMatchingTimesResponse) XXX_Unmarshal(b []byte) error

+ func (this *ListScheduleMatchingTimesResponse) Equal(that interface{}) bool

+ func (this *ListScheduleMatchingTimesResponse) GoString() string

+ func (this *ListScheduleMatchingTimesResponse) String() string

+ type ListSchedulesRequest struct

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ func (*ListSchedulesRequest) Descriptor() ([]byte, []int)

+ func (*ListSchedulesRequest) ProtoMessage()

+ func (m *ListSchedulesRequest) GetMaximumPageSize() int32

+ func (m *ListSchedulesRequest) GetNamespace() string

+ func (m *ListSchedulesRequest) GetNextPageToken() []byte

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

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

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

+ func (m *ListSchedulesRequest) Reset()

+ func (m *ListSchedulesRequest) Size() (n int)

+ func (m *ListSchedulesRequest) Unmarshal(dAtA []byte) error

+ func (m *ListSchedulesRequest) XXX_DiscardUnknown()

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

+ func (m *ListSchedulesRequest) XXX_Merge(src proto.Message)

+ func (m *ListSchedulesRequest) XXX_Size() int

+ func (m *ListSchedulesRequest) XXX_Unmarshal(b []byte) error

+ func (this *ListSchedulesRequest) Equal(that interface{}) bool

+ func (this *ListSchedulesRequest) GoString() string

+ func (this *ListSchedulesRequest) String() string

+ type ListSchedulesResponse struct

+ NextPageToken []byte

+ Schedules []*v112.ScheduleListEntry

+ func (*ListSchedulesResponse) Descriptor() ([]byte, []int)

+ func (*ListSchedulesResponse) ProtoMessage()

+ func (m *ListSchedulesResponse) GetNextPageToken() []byte

+ func (m *ListSchedulesResponse) GetSchedules() []*v112.ScheduleListEntry

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

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

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

+ func (m *ListSchedulesResponse) Reset()

+ func (m *ListSchedulesResponse) Size() (n int)

+ func (m *ListSchedulesResponse) Unmarshal(dAtA []byte) error

+ func (m *ListSchedulesResponse) XXX_DiscardUnknown()

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

+ func (m *ListSchedulesResponse) XXX_Merge(src proto.Message)

+ func (m *ListSchedulesResponse) XXX_Size() int

+ func (m *ListSchedulesResponse) XXX_Unmarshal(b []byte) error

+ func (this *ListSchedulesResponse) Equal(that interface{}) bool

+ func (this *ListSchedulesResponse) GoString() string

+ func (this *ListSchedulesResponse) String() string

+ type PatchScheduleRequest struct

+ Identity string

+ Namespace string

+ Patch *v112.SchedulePatch

+ RequestId string

+ ScheduleId string

+ func (*PatchScheduleRequest) Descriptor() ([]byte, []int)

+ func (*PatchScheduleRequest) ProtoMessage()

+ func (m *PatchScheduleRequest) GetIdentity() string

+ func (m *PatchScheduleRequest) GetNamespace() string

+ func (m *PatchScheduleRequest) GetPatch() *v112.SchedulePatch

+ func (m *PatchScheduleRequest) GetRequestId() string

+ func (m *PatchScheduleRequest) GetScheduleId() string

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

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

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

+ func (m *PatchScheduleRequest) Reset()

+ func (m *PatchScheduleRequest) Size() (n int)

+ func (m *PatchScheduleRequest) Unmarshal(dAtA []byte) error

+ func (m *PatchScheduleRequest) XXX_DiscardUnknown()

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

+ func (m *PatchScheduleRequest) XXX_Merge(src proto.Message)

+ func (m *PatchScheduleRequest) XXX_Size() int

+ func (m *PatchScheduleRequest) XXX_Unmarshal(b []byte) error

+ func (this *PatchScheduleRequest) Equal(that interface{}) bool

+ func (this *PatchScheduleRequest) GoString() string

+ func (this *PatchScheduleRequest) String() string

+ type PatchScheduleResponse struct

+ func (*PatchScheduleResponse) Descriptor() ([]byte, []int)

+ func (*PatchScheduleResponse) ProtoMessage()

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

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

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

+ func (m *PatchScheduleResponse) Reset()

+ func (m *PatchScheduleResponse) Size() (n int)

+ func (m *PatchScheduleResponse) Unmarshal(dAtA []byte) error

+ func (m *PatchScheduleResponse) XXX_DiscardUnknown()

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

+ func (m *PatchScheduleResponse) XXX_Merge(src proto.Message)

+ func (m *PatchScheduleResponse) XXX_Size() int

+ func (m *PatchScheduleResponse) XXX_Unmarshal(b []byte) error

+ func (this *PatchScheduleResponse) Equal(that interface{}) bool

+ func (this *PatchScheduleResponse) GoString() string

+ func (this *PatchScheduleResponse) String() string

type UnimplementedWorkflowServiceServer

+ func (*UnimplementedWorkflowServiceServer) CreateSchedule(ctx context.Context, req *CreateScheduleRequest) (*CreateScheduleResponse, error)

+ func (*UnimplementedWorkflowServiceServer) DeleteSchedule(ctx context.Context, req *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

+ func (*UnimplementedWorkflowServiceServer) DescribeSchedule(ctx context.Context, req *DescribeScheduleRequest) (*DescribeScheduleResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListScheduleMatchingTimes(ctx context.Context, req *ListScheduleMatchingTimesRequest) (*ListScheduleMatchingTimesResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListSchedules(ctx context.Context, req *ListSchedulesRequest) (*ListSchedulesResponse, error)

+ func (*UnimplementedWorkflowServiceServer) PatchSchedule(ctx context.Context, req *PatchScheduleRequest) (*PatchScheduleResponse, error)

+ func (*UnimplementedWorkflowServiceServer) UpdateSchedule(ctx context.Context, req *UpdateScheduleRequest) (*UpdateScheduleResponse, error)

+ type UpdateScheduleRequest struct

+ ConflictToken []byte

+ Identity string

+ Namespace string

+ RequestId string

+ Schedule *v112.Schedule

+ ScheduleId string

+ func (*UpdateScheduleRequest) Descriptor() ([]byte, []int)

+ func (*UpdateScheduleRequest) ProtoMessage()

+ func (m *UpdateScheduleRequest) GetConflictToken() []byte

+ func (m *UpdateScheduleRequest) GetIdentity() string

+ func (m *UpdateScheduleRequest) GetNamespace() string

+ func (m *UpdateScheduleRequest) GetRequestId() string

+ func (m *UpdateScheduleRequest) GetSchedule() *v112.Schedule

+ func (m *UpdateScheduleRequest) GetScheduleId() string

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

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

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

+ func (m *UpdateScheduleRequest) Reset()

+ func (m *UpdateScheduleRequest) Size() (n int)

+ func (m *UpdateScheduleRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateScheduleRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateScheduleRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateScheduleRequest) XXX_Size() int

+ func (m *UpdateScheduleRequest) XXX_Unmarshal(b []byte) error

+ func (this *UpdateScheduleRequest) Equal(that interface{}) bool

+ func (this *UpdateScheduleRequest) GoString() string

+ func (this *UpdateScheduleRequest) String() string

+ type UpdateScheduleResponse struct

+ func (*UpdateScheduleResponse) Descriptor() ([]byte, []int)

+ func (*UpdateScheduleResponse) ProtoMessage()

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

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

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

+ func (m *UpdateScheduleResponse) Reset()

+ func (m *UpdateScheduleResponse) Size() (n int)

+ func (m *UpdateScheduleResponse) Unmarshal(dAtA []byte) error

+ func (m *UpdateScheduleResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateScheduleResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateScheduleResponse) XXX_Size() int

+ func (m *UpdateScheduleResponse) XXX_Unmarshal(b []byte) error

+ func (this *UpdateScheduleResponse) Equal(that interface{}) bool

+ func (this *UpdateScheduleResponse) GoString() string

+ func (this *UpdateScheduleResponse) String() string

type WorkflowServiceClient

+ CreateSchedule func(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreateScheduleResponse, error)

+ DeleteSchedule func(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error)

+ DescribeSchedule func(ctx context.Context, in *DescribeScheduleRequest, opts ...grpc.CallOption) (*DescribeScheduleResponse, error)

+ ListScheduleMatchingTimes func(ctx context.Context, in *ListScheduleMatchingTimesRequest, ...) (*ListScheduleMatchingTimesResponse, error)

+ ListSchedules func(ctx context.Context, in *ListSchedulesRequest, opts ...grpc.CallOption) (*ListSchedulesResponse, error)

+ PatchSchedule func(ctx context.Context, in *PatchScheduleRequest, opts ...grpc.CallOption) (*PatchScheduleResponse, error)

+ UpdateSchedule func(ctx context.Context, in *UpdateScheduleRequest, opts ...grpc.CallOption) (*UpdateScheduleResponse, error)

type WorkflowServiceServer

+ CreateSchedule func(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)

+ DeleteSchedule func(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)

+ DescribeSchedule func(context.Context, *DescribeScheduleRequest) (*DescribeScheduleResponse, error)

+ ListScheduleMatchingTimes func(context.Context, *ListScheduleMatchingTimesRequest) (*ListScheduleMatchingTimesResponse, error)

+ ListSchedules func(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)

+ PatchSchedule func(context.Context, *PatchScheduleRequest) (*PatchScheduleResponse, error)

+ UpdateSchedule func(context.Context, *UpdateScheduleRequest) (*UpdateScheduleResponse, error)

v0.13.1

May 10, 2022

v0.13.0

May 5, 2022

v0.12.2

May 4, 2022

v0.12.1

Apr 29, 2022

v0.12.0

Apr 28, 2022

v0.11.0

Apr 26, 2022

v0.10.6

Apr 22, 2022

v0.10.5

Apr 22, 2022

v0.10.4

Apr 21, 2022

v0.10.3

Apr 20, 2022

v0.10.2

Apr 14, 2022

v0.10.1

Apr 13, 2022

v0.10.0

Apr 13, 2022

v0.9.0

Apr 7, 2022

v0.8.0

Mar 29, 2022

Changes in this version

type DescribeWorkflowExecutionResponse

+ PendingWorkflowTask *v110.PendingWorkflowTaskInfo

+ func (m *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v110.PendingWorkflowTaskInfo

type GetClusterInfoResponse

+ PersistenceStore string

+ VisibilityStore string

+ func (m *GetClusterInfoResponse) GetPersistenceStore() string

+ func (m *GetClusterInfoResponse) GetVisibilityStore() string

+ type GetSystemInfoRequest struct

+ func (*GetSystemInfoRequest) Descriptor() ([]byte, []int)

+ func (*GetSystemInfoRequest) ProtoMessage()

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

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

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

+ func (m *GetSystemInfoRequest) Reset()

+ func (m *GetSystemInfoRequest) Size() (n int)

+ func (m *GetSystemInfoRequest) Unmarshal(dAtA []byte) error

+ func (m *GetSystemInfoRequest) XXX_DiscardUnknown()

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

+ func (m *GetSystemInfoRequest) XXX_Merge(src proto.Message)

+ func (m *GetSystemInfoRequest) XXX_Size() int

+ func (m *GetSystemInfoRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetSystemInfoRequest) Equal(that interface{}) bool

+ func (this *GetSystemInfoRequest) GoString() string

+ func (this *GetSystemInfoRequest) String() string

+ type GetSystemInfoResponse struct

+ Capabilities *GetSystemInfoResponse_Capabilities

+ ServerVersion string

+ func (*GetSystemInfoResponse) Descriptor() ([]byte, []int)

+ func (*GetSystemInfoResponse) ProtoMessage()

+ func (m *GetSystemInfoResponse) GetCapabilities() *GetSystemInfoResponse_Capabilities

+ func (m *GetSystemInfoResponse) GetServerVersion() string

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

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

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

+ func (m *GetSystemInfoResponse) Reset()

+ func (m *GetSystemInfoResponse) Size() (n int)

+ func (m *GetSystemInfoResponse) Unmarshal(dAtA []byte) error

+ func (m *GetSystemInfoResponse) XXX_DiscardUnknown()

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

+ func (m *GetSystemInfoResponse) XXX_Merge(src proto.Message)

+ func (m *GetSystemInfoResponse) XXX_Size() int

+ func (m *GetSystemInfoResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetSystemInfoResponse) Equal(that interface{}) bool

+ func (this *GetSystemInfoResponse) GoString() string

+ func (this *GetSystemInfoResponse) String() string

+ type GetSystemInfoResponse_Capabilities struct

+ ActivityFailureIncludeHeartbeat bool

+ InternalErrorDifferentiation bool

+ SignalAndQueryHeader bool

+ func (*GetSystemInfoResponse_Capabilities) Descriptor() ([]byte, []int)

+ func (*GetSystemInfoResponse_Capabilities) ProtoMessage()

+ func (m *GetSystemInfoResponse_Capabilities) GetActivityFailureIncludeHeartbeat() bool

+ func (m *GetSystemInfoResponse_Capabilities) GetInternalErrorDifferentiation() bool

+ func (m *GetSystemInfoResponse_Capabilities) GetSignalAndQueryHeader() bool

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

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

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

+ func (m *GetSystemInfoResponse_Capabilities) Reset()

+ func (m *GetSystemInfoResponse_Capabilities) Size() (n int)

+ func (m *GetSystemInfoResponse_Capabilities) Unmarshal(dAtA []byte) error

+ func (m *GetSystemInfoResponse_Capabilities) XXX_DiscardUnknown()

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

+ func (m *GetSystemInfoResponse_Capabilities) XXX_Merge(src proto.Message)

+ func (m *GetSystemInfoResponse_Capabilities) XXX_Size() int

+ func (m *GetSystemInfoResponse_Capabilities) XXX_Unmarshal(b []byte) error

+ func (this *GetSystemInfoResponse_Capabilities) Equal(that interface{}) bool

+ func (this *GetSystemInfoResponse_Capabilities) GoString() string

+ func (this *GetSystemInfoResponse_Capabilities) String() string

+ type GetWorkflowExecutionHistoryReverseRequest struct

+ Execution *v13.WorkflowExecution

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ func (*GetWorkflowExecutionHistoryReverseRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage()

+ func (m *GetWorkflowExecutionHistoryReverseRequest) GetExecution() *v13.WorkflowExecution

+ func (m *GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize() int32

+ func (m *GetWorkflowExecutionHistoryReverseRequest) GetNamespace() string

+ func (m *GetWorkflowExecutionHistoryReverseRequest) GetNextPageToken() []byte

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

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

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

+ func (m *GetWorkflowExecutionHistoryReverseRequest) Reset()

+ func (m *GetWorkflowExecutionHistoryReverseRequest) Size() (n int)

+ func (m *GetWorkflowExecutionHistoryReverseRequest) Unmarshal(dAtA []byte) error

+ func (m *GetWorkflowExecutionHistoryReverseRequest) XXX_DiscardUnknown()

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

+ func (m *GetWorkflowExecutionHistoryReverseRequest) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowExecutionHistoryReverseRequest) XXX_Size() int

+ func (m *GetWorkflowExecutionHistoryReverseRequest) XXX_Unmarshal(b []byte) error

+ func (this *GetWorkflowExecutionHistoryReverseRequest) Equal(that interface{}) bool

+ func (this *GetWorkflowExecutionHistoryReverseRequest) GoString() string

+ func (this *GetWorkflowExecutionHistoryReverseRequest) String() string

+ type GetWorkflowExecutionHistoryReverseResponse struct

+ History *v15.History

+ NextPageToken []byte

+ func (*GetWorkflowExecutionHistoryReverseResponse) Descriptor() ([]byte, []int)

+ func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage()

+ func (m *GetWorkflowExecutionHistoryReverseResponse) GetHistory() *v15.History

+ func (m *GetWorkflowExecutionHistoryReverseResponse) GetNextPageToken() []byte

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

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

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

+ func (m *GetWorkflowExecutionHistoryReverseResponse) Reset()

+ func (m *GetWorkflowExecutionHistoryReverseResponse) Size() (n int)

+ func (m *GetWorkflowExecutionHistoryReverseResponse) Unmarshal(dAtA []byte) error

+ func (m *GetWorkflowExecutionHistoryReverseResponse) XXX_DiscardUnknown()

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

+ func (m *GetWorkflowExecutionHistoryReverseResponse) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowExecutionHistoryReverseResponse) XXX_Size() int

+ func (m *GetWorkflowExecutionHistoryReverseResponse) XXX_Unmarshal(b []byte) error

+ func (this *GetWorkflowExecutionHistoryReverseResponse) Equal(that interface{}) bool

+ func (this *GetWorkflowExecutionHistoryReverseResponse) GoString() string

+ func (this *GetWorkflowExecutionHistoryReverseResponse) String() string

type ResetWorkflowExecutionRequest

+ ResetReapplyType v11.ResetReapplyType

+ func (m *ResetWorkflowExecutionRequest) GetResetReapplyType() v11.ResetReapplyType

type RespondActivityTaskFailedByIdRequest

+ LastHeartbeatDetails *v13.Payloads

+ func (m *RespondActivityTaskFailedByIdRequest) GetLastHeartbeatDetails() *v13.Payloads

type RespondActivityTaskFailedByIdResponse

+ Failures []*v18.Failure

+ func (m *RespondActivityTaskFailedByIdResponse) GetFailures() []*v18.Failure

type RespondActivityTaskFailedRequest

+ LastHeartbeatDetails *v13.Payloads

+ func (m *RespondActivityTaskFailedRequest) GetLastHeartbeatDetails() *v13.Payloads

type RespondActivityTaskFailedResponse

+ Failures []*v18.Failure

+ func (m *RespondActivityTaskFailedResponse) GetFailures() []*v18.Failure

type SignalWorkflowExecutionRequest

+ Header *v13.Header

+ func (m *SignalWorkflowExecutionRequest) GetHeader() *v13.Header

type UnimplementedWorkflowServiceServer

+ func (*UnimplementedWorkflowServiceServer) GetSystemInfo(ctx context.Context, req *GetSystemInfoRequest) (*GetSystemInfoResponse, error)

+ func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistoryReverse(ctx context.Context, req *GetWorkflowExecutionHistoryReverseRequest) (*GetWorkflowExecutionHistoryReverseResponse, error)

type UpdateNamespaceRequest

+ PromoteNamespace bool

+ func (m *UpdateNamespaceRequest) GetPromoteNamespace() bool

type WorkflowServiceClient

+ GetSystemInfo func(ctx context.Context, in *GetSystemInfoRequest, opts ...grpc.CallOption) (*GetSystemInfoResponse, error)

+ GetWorkflowExecutionHistoryReverse func(ctx context.Context, in *GetWorkflowExecutionHistoryReverseRequest, ...) (*GetWorkflowExecutionHistoryReverseResponse, error)

type WorkflowServiceServer

+ GetSystemInfo func(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, error)

+ GetWorkflowExecutionHistoryReverse func(context.Context, *GetWorkflowExecutionHistoryReverseRequest) (*GetWorkflowExecutionHistoryReverseResponse, error)

v0.7.0

Mar 22, 2022

v0.6.0

Mar 21, 2022

v0.5.0

Mar 16, 2022

v0.4.0

Mar 11, 2022

v0.3.0

Feb 28, 2022

v0.2.0

Jan 29, 2022

v0.1.0

Oct 27, 2021

Changes in this version

+ var ErrIntOverflowRequestResponse = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRequestResponse = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")

+ func RegisterWorkflowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowServiceClient) error

+ func RegisterWorkflowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowServiceServer) error

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

+ type CountWorkflowExecutionsRequest struct

+ Namespace string

+ Query string

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

+ func (*CountWorkflowExecutionsRequest) ProtoMessage()

+ func (m *CountWorkflowExecutionsRequest) GetNamespace() string

+ func (m *CountWorkflowExecutionsRequest) GetQuery() string

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

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

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

+ func (m *CountWorkflowExecutionsRequest) Reset()

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

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

+ func (m *CountWorkflowExecutionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *CountWorkflowExecutionsRequest) XXX_Size() int

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

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

+ func (this *CountWorkflowExecutionsRequest) GoString() string

+ func (this *CountWorkflowExecutionsRequest) String() string

+ type CountWorkflowExecutionsResponse struct

+ Count int64

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

+ func (*CountWorkflowExecutionsResponse) ProtoMessage()

+ func (m *CountWorkflowExecutionsResponse) GetCount() int64

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

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

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

+ func (m *CountWorkflowExecutionsResponse) Reset()

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

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

+ func (m *CountWorkflowExecutionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *CountWorkflowExecutionsResponse) XXX_Size() int

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

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

+ func (this *CountWorkflowExecutionsResponse) GoString() string

+ func (this *CountWorkflowExecutionsResponse) String() string

+ type DeprecateNamespaceRequest struct

+ Namespace string

+ SecurityToken string

+ func (*DeprecateNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*DeprecateNamespaceRequest) ProtoMessage()

+ func (m *DeprecateNamespaceRequest) GetNamespace() string

+ func (m *DeprecateNamespaceRequest) GetSecurityToken() string

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

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

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

+ func (m *DeprecateNamespaceRequest) Reset()

+ func (m *DeprecateNamespaceRequest) Size() (n int)

+ func (m *DeprecateNamespaceRequest) Unmarshal(dAtA []byte) error

+ func (m *DeprecateNamespaceRequest) XXX_DiscardUnknown()

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

+ func (m *DeprecateNamespaceRequest) XXX_Merge(src proto.Message)

+ func (m *DeprecateNamespaceRequest) XXX_Size() int

+ func (m *DeprecateNamespaceRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeprecateNamespaceRequest) Equal(that interface{}) bool

+ func (this *DeprecateNamespaceRequest) GoString() string

+ func (this *DeprecateNamespaceRequest) String() string

+ type DeprecateNamespaceResponse struct

+ func (*DeprecateNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*DeprecateNamespaceResponse) ProtoMessage()

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

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

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

+ func (m *DeprecateNamespaceResponse) Reset()

+ func (m *DeprecateNamespaceResponse) Size() (n int)

+ func (m *DeprecateNamespaceResponse) Unmarshal(dAtA []byte) error

+ func (m *DeprecateNamespaceResponse) XXX_DiscardUnknown()

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

+ func (m *DeprecateNamespaceResponse) XXX_Merge(src proto.Message)

+ func (m *DeprecateNamespaceResponse) XXX_Size() int

+ func (m *DeprecateNamespaceResponse) XXX_Unmarshal(b []byte) error

+ func (this *DeprecateNamespaceResponse) Equal(that interface{}) bool

+ func (this *DeprecateNamespaceResponse) GoString() string

+ func (this *DeprecateNamespaceResponse) String() string

+ type DescribeNamespaceRequest struct

+ Id string

+ Namespace string

+ func (*DescribeNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*DescribeNamespaceRequest) ProtoMessage()

+ func (m *DescribeNamespaceRequest) GetId() string

+ func (m *DescribeNamespaceRequest) GetNamespace() string

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

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

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

+ func (m *DescribeNamespaceRequest) Reset()

+ func (m *DescribeNamespaceRequest) Size() (n int)

+ func (m *DescribeNamespaceRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeNamespaceRequest) XXX_DiscardUnknown()

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

+ func (m *DescribeNamespaceRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeNamespaceRequest) XXX_Size() int

+ func (m *DescribeNamespaceRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeNamespaceRequest) Equal(that interface{}) bool

+ func (this *DescribeNamespaceRequest) GoString() string

+ func (this *DescribeNamespaceRequest) String() string

+ type DescribeNamespaceResponse struct

+ Config *v12.NamespaceConfig

+ FailoverVersion int64

+ IsGlobalNamespace bool

+ NamespaceInfo *v12.NamespaceInfo

+ ReplicationConfig *v1.NamespaceReplicationConfig

+ func (*DescribeNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*DescribeNamespaceResponse) ProtoMessage()

+ func (m *DescribeNamespaceResponse) GetConfig() *v12.NamespaceConfig

+ func (m *DescribeNamespaceResponse) GetFailoverVersion() int64

+ func (m *DescribeNamespaceResponse) GetIsGlobalNamespace() bool

+ func (m *DescribeNamespaceResponse) GetNamespaceInfo() *v12.NamespaceInfo

+ func (m *DescribeNamespaceResponse) GetReplicationConfig() *v1.NamespaceReplicationConfig

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

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

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

+ func (m *DescribeNamespaceResponse) Reset()

+ func (m *DescribeNamespaceResponse) Size() (n int)

+ func (m *DescribeNamespaceResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeNamespaceResponse) XXX_DiscardUnknown()

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

+ func (m *DescribeNamespaceResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeNamespaceResponse) XXX_Size() int

+ func (m *DescribeNamespaceResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeNamespaceResponse) Equal(that interface{}) bool

+ func (this *DescribeNamespaceResponse) GoString() string

+ func (this *DescribeNamespaceResponse) String() string

+ type DescribeTaskQueueRequest struct

+ IncludeTaskQueueStatus bool

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ TaskQueueType v11.TaskQueueType

+ func (*DescribeTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*DescribeTaskQueueRequest) ProtoMessage()

+ func (m *DescribeTaskQueueRequest) GetIncludeTaskQueueStatus() bool

+ func (m *DescribeTaskQueueRequest) GetNamespace() string

+ func (m *DescribeTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

+ func (m *DescribeTaskQueueRequest) GetTaskQueueType() v11.TaskQueueType

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

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

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

+ func (m *DescribeTaskQueueRequest) Reset()

+ func (m *DescribeTaskQueueRequest) Size() (n int)

+ func (m *DescribeTaskQueueRequest) Unmarshal(dAtA []byte) error

+ func (m *DescribeTaskQueueRequest) XXX_DiscardUnknown()

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

+ func (m *DescribeTaskQueueRequest) XXX_Merge(src proto.Message)

+ func (m *DescribeTaskQueueRequest) XXX_Size() int

+ func (m *DescribeTaskQueueRequest) XXX_Unmarshal(b []byte) error

+ func (this *DescribeTaskQueueRequest) Equal(that interface{}) bool

+ func (this *DescribeTaskQueueRequest) GoString() string

+ func (this *DescribeTaskQueueRequest) String() string

+ type DescribeTaskQueueResponse struct

+ Pollers []*v14.PollerInfo

+ TaskQueueStatus *v14.TaskQueueStatus

+ func (*DescribeTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*DescribeTaskQueueResponse) ProtoMessage()

+ func (m *DescribeTaskQueueResponse) GetPollers() []*v14.PollerInfo

+ func (m *DescribeTaskQueueResponse) GetTaskQueueStatus() *v14.TaskQueueStatus

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

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

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

+ func (m *DescribeTaskQueueResponse) Reset()

+ func (m *DescribeTaskQueueResponse) Size() (n int)

+ func (m *DescribeTaskQueueResponse) Unmarshal(dAtA []byte) error

+ func (m *DescribeTaskQueueResponse) XXX_DiscardUnknown()

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

+ func (m *DescribeTaskQueueResponse) XXX_Merge(src proto.Message)

+ func (m *DescribeTaskQueueResponse) XXX_Size() int

+ func (m *DescribeTaskQueueResponse) XXX_Unmarshal(b []byte) error

+ func (this *DescribeTaskQueueResponse) Equal(that interface{}) bool

+ func (this *DescribeTaskQueueResponse) GoString() string

+ func (this *DescribeTaskQueueResponse) String() string

+ type DescribeWorkflowExecutionRequest struct

+ Execution *v13.WorkflowExecution

+ Namespace string

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

+ func (*DescribeWorkflowExecutionRequest) ProtoMessage()

+ func (m *DescribeWorkflowExecutionRequest) GetExecution() *v13.WorkflowExecution

+ func (m *DescribeWorkflowExecutionRequest) GetNamespace() string

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

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

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

+ func (m *DescribeWorkflowExecutionRequest) Reset()

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

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

+ func (m *DescribeWorkflowExecutionRequest) XXX_DiscardUnknown()

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

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

+ func (m *DescribeWorkflowExecutionRequest) XXX_Size() int

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

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

+ func (this *DescribeWorkflowExecutionRequest) GoString() string

+ func (this *DescribeWorkflowExecutionRequest) String() string

+ type DescribeWorkflowExecutionResponse struct

+ ExecutionConfig *v110.WorkflowExecutionConfig

+ PendingActivities []*v110.PendingActivityInfo

+ PendingChildren []*v110.PendingChildExecutionInfo

+ WorkflowExecutionInfo *v110.WorkflowExecutionInfo

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

+ func (*DescribeWorkflowExecutionResponse) ProtoMessage()

+ func (m *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v110.WorkflowExecutionConfig

+ func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*v110.PendingActivityInfo

+ func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v110.PendingChildExecutionInfo

+ func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v110.WorkflowExecutionInfo

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

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

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

+ func (m *DescribeWorkflowExecutionResponse) Reset()

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

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

+ func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()

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

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

+ func (m *DescribeWorkflowExecutionResponse) XXX_Size() int

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

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

+ func (this *DescribeWorkflowExecutionResponse) GoString() string

+ func (this *DescribeWorkflowExecutionResponse) String() string

+ type GetClusterInfoRequest struct

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

+ func (*GetClusterInfoRequest) ProtoMessage()

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

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

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

+ func (m *GetClusterInfoRequest) Reset()

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

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

+ func (m *GetClusterInfoRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetClusterInfoRequest) XXX_Size() int

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

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

+ func (this *GetClusterInfoRequest) GoString() string

+ func (this *GetClusterInfoRequest) String() string

+ type GetClusterInfoResponse struct

+ ClusterId string

+ ClusterName string

+ HistoryShardCount int32

+ ServerVersion string

+ SupportedClients map[string]string

+ VersionInfo *v111.VersionInfo

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

+ func (*GetClusterInfoResponse) ProtoMessage()

+ func (m *GetClusterInfoResponse) GetClusterId() string

+ func (m *GetClusterInfoResponse) GetClusterName() string

+ func (m *GetClusterInfoResponse) GetHistoryShardCount() int32

+ func (m *GetClusterInfoResponse) GetServerVersion() string

+ func (m *GetClusterInfoResponse) GetSupportedClients() map[string]string

+ func (m *GetClusterInfoResponse) GetVersionInfo() *v111.VersionInfo

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

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

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

+ func (m *GetClusterInfoResponse) Reset()

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

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

+ func (m *GetClusterInfoResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetClusterInfoResponse) XXX_Size() int

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

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

+ func (this *GetClusterInfoResponse) GoString() string

+ func (this *GetClusterInfoResponse) String() string

+ type GetSearchAttributesRequest struct

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

+ func (*GetSearchAttributesRequest) ProtoMessage()

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

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

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

+ func (m *GetSearchAttributesRequest) Reset()

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

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

+ func (m *GetSearchAttributesRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetSearchAttributesRequest) XXX_Size() int

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

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

+ func (this *GetSearchAttributesRequest) GoString() string

+ func (this *GetSearchAttributesRequest) String() string

+ type GetSearchAttributesResponse struct

+ Keys map[string]v11.IndexedValueType

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

+ func (*GetSearchAttributesResponse) ProtoMessage()

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

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

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

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

+ func (m *GetSearchAttributesResponse) Reset()

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

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

+ func (m *GetSearchAttributesResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetSearchAttributesResponse) XXX_Size() int

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

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

+ func (this *GetSearchAttributesResponse) GoString() string

+ func (this *GetSearchAttributesResponse) String() string

+ type GetWorkflowExecutionHistoryRequest struct

+ Execution *v13.WorkflowExecution

+ HistoryEventFilterType v11.HistoryEventFilterType

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ SkipArchival bool

+ WaitNewEvent bool

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

+ func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

+ func (m *GetWorkflowExecutionHistoryRequest) GetExecution() *v13.WorkflowExecution

+ func (m *GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType() v11.HistoryEventFilterType

+ func (m *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32

+ func (m *GetWorkflowExecutionHistoryRequest) GetNamespace() string

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

+ func (m *GetWorkflowExecutionHistoryRequest) GetSkipArchival() bool

+ func (m *GetWorkflowExecutionHistoryRequest) GetWaitNewEvent() bool

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

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

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

+ func (m *GetWorkflowExecutionHistoryRequest) Reset()

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

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

+ func (m *GetWorkflowExecutionHistoryRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetWorkflowExecutionHistoryRequest) XXX_Size() int

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

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

+ func (this *GetWorkflowExecutionHistoryRequest) GoString() string

+ func (this *GetWorkflowExecutionHistoryRequest) String() string

+ type GetWorkflowExecutionHistoryResponse struct

+ Archived bool

+ History *v15.History

+ NextPageToken []byte

+ RawHistory []*v13.DataBlob

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

+ func (*GetWorkflowExecutionHistoryResponse) ProtoMessage()

+ func (m *GetWorkflowExecutionHistoryResponse) GetArchived() bool

+ func (m *GetWorkflowExecutionHistoryResponse) GetHistory() *v15.History

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

+ func (m *GetWorkflowExecutionHistoryResponse) GetRawHistory() []*v13.DataBlob

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

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

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

+ func (m *GetWorkflowExecutionHistoryResponse) Reset()

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

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

+ func (m *GetWorkflowExecutionHistoryResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetWorkflowExecutionHistoryResponse) XXX_Size() int

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

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

+ func (this *GetWorkflowExecutionHistoryResponse) GoString() string

+ func (this *GetWorkflowExecutionHistoryResponse) String() string

+ type ListArchivedWorkflowExecutionsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ Query string

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

+ func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage()

+ func (m *ListArchivedWorkflowExecutionsRequest) GetNamespace() string

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

+ func (m *ListArchivedWorkflowExecutionsRequest) GetPageSize() int32

+ func (m *ListArchivedWorkflowExecutionsRequest) GetQuery() string

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

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

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

+ func (m *ListArchivedWorkflowExecutionsRequest) Reset()

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

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

+ func (m *ListArchivedWorkflowExecutionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListArchivedWorkflowExecutionsRequest) XXX_Size() int

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

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

+ func (this *ListArchivedWorkflowExecutionsRequest) GoString() string

+ func (this *ListArchivedWorkflowExecutionsRequest) String() string

+ type ListArchivedWorkflowExecutionsResponse struct

+ Executions []*v110.WorkflowExecutionInfo

+ NextPageToken []byte

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

+ func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage()

+ func (m *ListArchivedWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

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

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

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

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

+ func (m *ListArchivedWorkflowExecutionsResponse) Reset()

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

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

+ func (m *ListArchivedWorkflowExecutionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListArchivedWorkflowExecutionsResponse) XXX_Size() int

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

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

+ func (this *ListArchivedWorkflowExecutionsResponse) GoString() string

+ func (this *ListArchivedWorkflowExecutionsResponse) String() string

+ type ListClosedWorkflowExecutionsRequest struct

+ Filters isListClosedWorkflowExecutionsRequest_Filters

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ StartTimeFilter *v19.StartTimeFilter

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

+ func (*ListClosedWorkflowExecutionsRequest) ProtoMessage()

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

+ func (m *ListClosedWorkflowExecutionsRequest) GetExecutionFilter() *v19.WorkflowExecutionFilter

+ func (m *ListClosedWorkflowExecutionsRequest) GetFilters() isListClosedWorkflowExecutionsRequest_Filters

+ func (m *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() int32

+ func (m *ListClosedWorkflowExecutionsRequest) GetNamespace() string

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

+ func (m *ListClosedWorkflowExecutionsRequest) GetStartTimeFilter() *v19.StartTimeFilter

+ func (m *ListClosedWorkflowExecutionsRequest) GetStatusFilter() *v19.StatusFilter

+ func (m *ListClosedWorkflowExecutionsRequest) GetTypeFilter() *v19.WorkflowTypeFilter

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

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

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

+ func (m *ListClosedWorkflowExecutionsRequest) Reset()

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

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

+ func (m *ListClosedWorkflowExecutionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListClosedWorkflowExecutionsRequest) XXX_Size() int

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

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

+ func (this *ListClosedWorkflowExecutionsRequest) GoString() string

+ func (this *ListClosedWorkflowExecutionsRequest) String() string

+ type ListClosedWorkflowExecutionsRequest_ExecutionFilter struct

+ ExecutionFilter *v19.WorkflowExecutionFilter

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

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

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

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

+ func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) GoString() string

+ func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) String() string

+ type ListClosedWorkflowExecutionsRequest_StatusFilter struct

+ StatusFilter *v19.StatusFilter

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

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

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

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

+ func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) GoString() string

+ func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) String() string

+ type ListClosedWorkflowExecutionsRequest_TypeFilter struct

+ TypeFilter *v19.WorkflowTypeFilter

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

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

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

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

+ func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) GoString() string

+ func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) String() string

+ type ListClosedWorkflowExecutionsResponse struct

+ Executions []*v110.WorkflowExecutionInfo

+ NextPageToken []byte

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

+ func (*ListClosedWorkflowExecutionsResponse) ProtoMessage()

+ func (m *ListClosedWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

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

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

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

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

+ func (m *ListClosedWorkflowExecutionsResponse) Reset()

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

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

+ func (m *ListClosedWorkflowExecutionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListClosedWorkflowExecutionsResponse) XXX_Size() int

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

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

+ func (this *ListClosedWorkflowExecutionsResponse) GoString() string

+ func (this *ListClosedWorkflowExecutionsResponse) String() string

+ type ListNamespacesRequest struct

+ NextPageToken []byte

+ PageSize int32

+ func (*ListNamespacesRequest) Descriptor() ([]byte, []int)

+ func (*ListNamespacesRequest) ProtoMessage()

+ func (m *ListNamespacesRequest) GetNextPageToken() []byte

+ func (m *ListNamespacesRequest) GetPageSize() int32

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

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

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

+ func (m *ListNamespacesRequest) Reset()

+ func (m *ListNamespacesRequest) Size() (n int)

+ func (m *ListNamespacesRequest) Unmarshal(dAtA []byte) error

+ func (m *ListNamespacesRequest) XXX_DiscardUnknown()

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

+ func (m *ListNamespacesRequest) XXX_Merge(src proto.Message)

+ func (m *ListNamespacesRequest) XXX_Size() int

+ func (m *ListNamespacesRequest) XXX_Unmarshal(b []byte) error

+ func (this *ListNamespacesRequest) Equal(that interface{}) bool

+ func (this *ListNamespacesRequest) GoString() string

+ func (this *ListNamespacesRequest) String() string

+ type ListNamespacesResponse struct

+ Namespaces []*DescribeNamespaceResponse

+ NextPageToken []byte

+ func (*ListNamespacesResponse) Descriptor() ([]byte, []int)

+ func (*ListNamespacesResponse) ProtoMessage()

+ func (m *ListNamespacesResponse) GetNamespaces() []*DescribeNamespaceResponse

+ func (m *ListNamespacesResponse) GetNextPageToken() []byte

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

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

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

+ func (m *ListNamespacesResponse) Reset()

+ func (m *ListNamespacesResponse) Size() (n int)

+ func (m *ListNamespacesResponse) Unmarshal(dAtA []byte) error

+ func (m *ListNamespacesResponse) XXX_DiscardUnknown()

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

+ func (m *ListNamespacesResponse) XXX_Merge(src proto.Message)

+ func (m *ListNamespacesResponse) XXX_Size() int

+ func (m *ListNamespacesResponse) XXX_Unmarshal(b []byte) error

+ func (this *ListNamespacesResponse) Equal(that interface{}) bool

+ func (this *ListNamespacesResponse) GoString() string

+ func (this *ListNamespacesResponse) String() string

+ type ListOpenWorkflowExecutionsRequest struct

+ Filters isListOpenWorkflowExecutionsRequest_Filters

+ MaximumPageSize int32

+ Namespace string

+ NextPageToken []byte

+ StartTimeFilter *v19.StartTimeFilter

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

+ func (*ListOpenWorkflowExecutionsRequest) ProtoMessage()

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

+ func (m *ListOpenWorkflowExecutionsRequest) GetExecutionFilter() *v19.WorkflowExecutionFilter

+ func (m *ListOpenWorkflowExecutionsRequest) GetFilters() isListOpenWorkflowExecutionsRequest_Filters

+ func (m *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() int32

+ func (m *ListOpenWorkflowExecutionsRequest) GetNamespace() string

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

+ func (m *ListOpenWorkflowExecutionsRequest) GetStartTimeFilter() *v19.StartTimeFilter

+ func (m *ListOpenWorkflowExecutionsRequest) GetTypeFilter() *v19.WorkflowTypeFilter

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

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

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

+ func (m *ListOpenWorkflowExecutionsRequest) Reset()

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

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

+ func (m *ListOpenWorkflowExecutionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListOpenWorkflowExecutionsRequest) XXX_Size() int

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

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

+ func (this *ListOpenWorkflowExecutionsRequest) GoString() string

+ func (this *ListOpenWorkflowExecutionsRequest) String() string

+ type ListOpenWorkflowExecutionsRequest_ExecutionFilter struct

+ ExecutionFilter *v19.WorkflowExecutionFilter

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

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

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

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

+ func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) GoString() string

+ func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) String() string

+ type ListOpenWorkflowExecutionsRequest_TypeFilter struct

+ TypeFilter *v19.WorkflowTypeFilter

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

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

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

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

+ func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) GoString() string

+ func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) String() string

+ type ListOpenWorkflowExecutionsResponse struct

+ Executions []*v110.WorkflowExecutionInfo

+ NextPageToken []byte

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

+ func (*ListOpenWorkflowExecutionsResponse) ProtoMessage()

+ func (m *ListOpenWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

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

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

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

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

+ func (m *ListOpenWorkflowExecutionsResponse) Reset()

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

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

+ func (m *ListOpenWorkflowExecutionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListOpenWorkflowExecutionsResponse) XXX_Size() int

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

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

+ func (this *ListOpenWorkflowExecutionsResponse) GoString() string

+ func (this *ListOpenWorkflowExecutionsResponse) String() string

+ type ListTaskQueuePartitionsRequest struct

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ func (*ListTaskQueuePartitionsRequest) Descriptor() ([]byte, []int)

+ func (*ListTaskQueuePartitionsRequest) ProtoMessage()

+ func (m *ListTaskQueuePartitionsRequest) GetNamespace() string

+ func (m *ListTaskQueuePartitionsRequest) GetTaskQueue() *v14.TaskQueue

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

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

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

+ func (m *ListTaskQueuePartitionsRequest) Reset()

+ func (m *ListTaskQueuePartitionsRequest) Size() (n int)

+ func (m *ListTaskQueuePartitionsRequest) Unmarshal(dAtA []byte) error

+ func (m *ListTaskQueuePartitionsRequest) XXX_DiscardUnknown()

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

+ func (m *ListTaskQueuePartitionsRequest) XXX_Merge(src proto.Message)

+ func (m *ListTaskQueuePartitionsRequest) XXX_Size() int

+ func (m *ListTaskQueuePartitionsRequest) XXX_Unmarshal(b []byte) error

+ func (this *ListTaskQueuePartitionsRequest) Equal(that interface{}) bool

+ func (this *ListTaskQueuePartitionsRequest) GoString() string

+ func (this *ListTaskQueuePartitionsRequest) String() string

+ type ListTaskQueuePartitionsResponse struct

+ ActivityTaskQueuePartitions []*v14.TaskQueuePartitionMetadata

+ WorkflowTaskQueuePartitions []*v14.TaskQueuePartitionMetadata

+ func (*ListTaskQueuePartitionsResponse) Descriptor() ([]byte, []int)

+ func (*ListTaskQueuePartitionsResponse) ProtoMessage()

+ func (m *ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions() []*v14.TaskQueuePartitionMetadata

+ func (m *ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions() []*v14.TaskQueuePartitionMetadata

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

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

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

+ func (m *ListTaskQueuePartitionsResponse) Reset()

+ func (m *ListTaskQueuePartitionsResponse) Size() (n int)

+ func (m *ListTaskQueuePartitionsResponse) Unmarshal(dAtA []byte) error

+ func (m *ListTaskQueuePartitionsResponse) XXX_DiscardUnknown()

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

+ func (m *ListTaskQueuePartitionsResponse) XXX_Merge(src proto.Message)

+ func (m *ListTaskQueuePartitionsResponse) XXX_Size() int

+ func (m *ListTaskQueuePartitionsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ListTaskQueuePartitionsResponse) Equal(that interface{}) bool

+ func (this *ListTaskQueuePartitionsResponse) GoString() string

+ func (this *ListTaskQueuePartitionsResponse) String() string

+ type ListWorkflowExecutionsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ Query string

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

+ func (*ListWorkflowExecutionsRequest) ProtoMessage()

+ func (m *ListWorkflowExecutionsRequest) GetNamespace() string

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

+ func (m *ListWorkflowExecutionsRequest) GetPageSize() int32

+ func (m *ListWorkflowExecutionsRequest) GetQuery() string

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

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

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

+ func (m *ListWorkflowExecutionsRequest) Reset()

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

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

+ func (m *ListWorkflowExecutionsRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListWorkflowExecutionsRequest) XXX_Size() int

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

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

+ func (this *ListWorkflowExecutionsRequest) GoString() string

+ func (this *ListWorkflowExecutionsRequest) String() string

+ type ListWorkflowExecutionsResponse struct

+ Executions []*v110.WorkflowExecutionInfo

+ NextPageToken []byte

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

+ func (*ListWorkflowExecutionsResponse) ProtoMessage()

+ func (m *ListWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

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

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

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

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

+ func (m *ListWorkflowExecutionsResponse) Reset()

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

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

+ func (m *ListWorkflowExecutionsResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListWorkflowExecutionsResponse) XXX_Size() int

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

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

+ func (this *ListWorkflowExecutionsResponse) GoString() string

+ func (this *ListWorkflowExecutionsResponse) String() string

+ type PollActivityTaskQueueRequest struct

+ Identity string

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ TaskQueueMetadata *v14.TaskQueueMetadata

+ func (*PollActivityTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*PollActivityTaskQueueRequest) ProtoMessage()

+ func (m *PollActivityTaskQueueRequest) GetIdentity() string

+ func (m *PollActivityTaskQueueRequest) GetNamespace() string

+ func (m *PollActivityTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

+ func (m *PollActivityTaskQueueRequest) GetTaskQueueMetadata() *v14.TaskQueueMetadata

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

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

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

+ func (m *PollActivityTaskQueueRequest) Reset()

+ func (m *PollActivityTaskQueueRequest) Size() (n int)

+ func (m *PollActivityTaskQueueRequest) Unmarshal(dAtA []byte) error

+ func (m *PollActivityTaskQueueRequest) XXX_DiscardUnknown()

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

+ func (m *PollActivityTaskQueueRequest) XXX_Merge(src proto.Message)

+ func (m *PollActivityTaskQueueRequest) XXX_Size() int

+ func (m *PollActivityTaskQueueRequest) XXX_Unmarshal(b []byte) error

+ func (this *PollActivityTaskQueueRequest) Equal(that interface{}) bool

+ func (this *PollActivityTaskQueueRequest) GoString() string

+ func (this *PollActivityTaskQueueRequest) String() string

+ type PollActivityTaskQueueResponse struct

+ ActivityId string

+ ActivityType *v13.ActivityType

+ Attempt int32

+ CurrentAttemptScheduledTime *time.Time

+ Header *v13.Header

+ HeartbeatDetails *v13.Payloads

+ HeartbeatTimeout *time.Duration

+ Input *v13.Payloads

+ RetryPolicy *v13.RetryPolicy

+ ScheduleToCloseTimeout *time.Duration

+ ScheduledTime *time.Time

+ StartToCloseTimeout *time.Duration

+ StartedTime *time.Time

+ TaskToken []byte

+ WorkflowExecution *v13.WorkflowExecution

+ WorkflowNamespace string

+ WorkflowType *v13.WorkflowType

+ func (*PollActivityTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*PollActivityTaskQueueResponse) ProtoMessage()

+ func (m *PollActivityTaskQueueResponse) GetActivityId() string

+ func (m *PollActivityTaskQueueResponse) GetActivityType() *v13.ActivityType

+ func (m *PollActivityTaskQueueResponse) GetAttempt() int32

+ func (m *PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime() *time.Time

+ func (m *PollActivityTaskQueueResponse) GetHeader() *v13.Header

+ func (m *PollActivityTaskQueueResponse) GetHeartbeatDetails() *v13.Payloads

+ func (m *PollActivityTaskQueueResponse) GetHeartbeatTimeout() *time.Duration

+ func (m *PollActivityTaskQueueResponse) GetInput() *v13.Payloads

+ func (m *PollActivityTaskQueueResponse) GetRetryPolicy() *v13.RetryPolicy

+ func (m *PollActivityTaskQueueResponse) GetScheduleToCloseTimeout() *time.Duration

+ func (m *PollActivityTaskQueueResponse) GetScheduledTime() *time.Time

+ func (m *PollActivityTaskQueueResponse) GetStartToCloseTimeout() *time.Duration

+ func (m *PollActivityTaskQueueResponse) GetStartedTime() *time.Time

+ func (m *PollActivityTaskQueueResponse) GetTaskToken() []byte

+ func (m *PollActivityTaskQueueResponse) GetWorkflowExecution() *v13.WorkflowExecution

+ func (m *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

+ func (m *PollActivityTaskQueueResponse) GetWorkflowType() *v13.WorkflowType

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

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

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

+ func (m *PollActivityTaskQueueResponse) Reset()

+ func (m *PollActivityTaskQueueResponse) Size() (n int)

+ func (m *PollActivityTaskQueueResponse) Unmarshal(dAtA []byte) error

+ func (m *PollActivityTaskQueueResponse) XXX_DiscardUnknown()

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

+ func (m *PollActivityTaskQueueResponse) XXX_Merge(src proto.Message)

+ func (m *PollActivityTaskQueueResponse) XXX_Size() int

+ func (m *PollActivityTaskQueueResponse) XXX_Unmarshal(b []byte) error

+ func (this *PollActivityTaskQueueResponse) Equal(that interface{}) bool

+ func (this *PollActivityTaskQueueResponse) GoString() string

+ func (this *PollActivityTaskQueueResponse) String() string

+ type PollWorkflowTaskQueueRequest struct

+ BinaryChecksum string

+ Identity string

+ Namespace string

+ TaskQueue *v14.TaskQueue

+ func (*PollWorkflowTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*PollWorkflowTaskQueueRequest) ProtoMessage()

+ func (m *PollWorkflowTaskQueueRequest) GetBinaryChecksum() string

+ func (m *PollWorkflowTaskQueueRequest) GetIdentity() string

+ func (m *PollWorkflowTaskQueueRequest) GetNamespace() string

+ func (m *PollWorkflowTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

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

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

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

+ func (m *PollWorkflowTaskQueueRequest) Reset()

+ func (m *PollWorkflowTaskQueueRequest) Size() (n int)

+ func (m *PollWorkflowTaskQueueRequest) Unmarshal(dAtA []byte) error

+ func (m *PollWorkflowTaskQueueRequest) XXX_DiscardUnknown()

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

+ func (m *PollWorkflowTaskQueueRequest) XXX_Merge(src proto.Message)

+ func (m *PollWorkflowTaskQueueRequest) XXX_Size() int

+ func (m *PollWorkflowTaskQueueRequest) XXX_Unmarshal(b []byte) error

+ func (this *PollWorkflowTaskQueueRequest) Equal(that interface{}) bool

+ func (this *PollWorkflowTaskQueueRequest) GoString() string

+ func (this *PollWorkflowTaskQueueRequest) String() string

+ type PollWorkflowTaskQueueResponse struct

+ Attempt int32

+ BacklogCountHint int64

+ History *v15.History

+ NextPageToken []byte

+ PreviousStartedEventId int64

+ Queries map[string]*v16.WorkflowQuery

+ Query *v16.WorkflowQuery

+ ScheduledTime *time.Time

+ StartedEventId int64

+ StartedTime *time.Time

+ TaskToken []byte

+ WorkflowExecution *v13.WorkflowExecution

+ WorkflowExecutionTaskQueue *v14.TaskQueue

+ WorkflowType *v13.WorkflowType

+ func (*PollWorkflowTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*PollWorkflowTaskQueueResponse) ProtoMessage()

+ func (m *PollWorkflowTaskQueueResponse) GetAttempt() int32

+ func (m *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

+ func (m *PollWorkflowTaskQueueResponse) GetHistory() *v15.History

+ func (m *PollWorkflowTaskQueueResponse) GetNextPageToken() []byte

+ func (m *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

+ func (m *PollWorkflowTaskQueueResponse) GetQueries() map[string]*v16.WorkflowQuery

+ func (m *PollWorkflowTaskQueueResponse) GetQuery() *v16.WorkflowQuery

+ func (m *PollWorkflowTaskQueueResponse) GetScheduledTime() *time.Time

+ func (m *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

+ func (m *PollWorkflowTaskQueueResponse) GetStartedTime() *time.Time

+ func (m *PollWorkflowTaskQueueResponse) GetTaskToken() []byte

+ func (m *PollWorkflowTaskQueueResponse) GetWorkflowExecution() *v13.WorkflowExecution

+ func (m *PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue() *v14.TaskQueue

+ func (m *PollWorkflowTaskQueueResponse) GetWorkflowType() *v13.WorkflowType

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

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

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

+ func (m *PollWorkflowTaskQueueResponse) Reset()

+ func (m *PollWorkflowTaskQueueResponse) Size() (n int)

+ func (m *PollWorkflowTaskQueueResponse) Unmarshal(dAtA []byte) error

+ func (m *PollWorkflowTaskQueueResponse) XXX_DiscardUnknown()

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

+ func (m *PollWorkflowTaskQueueResponse) XXX_Merge(src proto.Message)

+ func (m *PollWorkflowTaskQueueResponse) XXX_Size() int

+ func (m *PollWorkflowTaskQueueResponse) XXX_Unmarshal(b []byte) error

+ func (this *PollWorkflowTaskQueueResponse) Equal(that interface{}) bool

+ func (this *PollWorkflowTaskQueueResponse) GoString() string

+ func (this *PollWorkflowTaskQueueResponse) String() string

+ type QueryWorkflowRequest struct

+ Execution *v13.WorkflowExecution

+ Namespace string

+ Query *v16.WorkflowQuery

+ QueryRejectCondition v11.QueryRejectCondition

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

+ func (*QueryWorkflowRequest) ProtoMessage()

+ func (m *QueryWorkflowRequest) GetExecution() *v13.WorkflowExecution

+ func (m *QueryWorkflowRequest) GetNamespace() string

+ func (m *QueryWorkflowRequest) GetQuery() *v16.WorkflowQuery

+ func (m *QueryWorkflowRequest) GetQueryRejectCondition() v11.QueryRejectCondition

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

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

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

+ func (m *QueryWorkflowRequest) Reset()

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

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

+ func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueryWorkflowRequest) XXX_Size() int

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

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

+ func (this *QueryWorkflowRequest) GoString() string

+ func (this *QueryWorkflowRequest) String() string

+ type QueryWorkflowResponse struct

+ QueryRejected *v16.QueryRejected

+ QueryResult *v13.Payloads

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

+ func (*QueryWorkflowResponse) ProtoMessage()

+ func (m *QueryWorkflowResponse) GetQueryRejected() *v16.QueryRejected

+ func (m *QueryWorkflowResponse) GetQueryResult() *v13.Payloads

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

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

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

+ func (m *QueryWorkflowResponse) Reset()

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

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

+ func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryWorkflowResponse) XXX_Size() int

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

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

+ func (this *QueryWorkflowResponse) GoString() string

+ func (this *QueryWorkflowResponse) String() string

+ type RecordActivityTaskHeartbeatByIdRequest struct

+ ActivityId string

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ RunId string

+ WorkflowId string

+ func (*RecordActivityTaskHeartbeatByIdRequest) Descriptor() ([]byte, []int)

+ func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage()

+ func (m *RecordActivityTaskHeartbeatByIdRequest) GetActivityId() string

+ func (m *RecordActivityTaskHeartbeatByIdRequest) GetDetails() *v13.Payloads

+ func (m *RecordActivityTaskHeartbeatByIdRequest) GetIdentity() string

+ func (m *RecordActivityTaskHeartbeatByIdRequest) GetNamespace() string

+ func (m *RecordActivityTaskHeartbeatByIdRequest) GetRunId() string

+ func (m *RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId() string

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

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

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

+ func (m *RecordActivityTaskHeartbeatByIdRequest) Reset()

+ func (m *RecordActivityTaskHeartbeatByIdRequest) Size() (n int)

+ func (m *RecordActivityTaskHeartbeatByIdRequest) Unmarshal(dAtA []byte) error

+ func (m *RecordActivityTaskHeartbeatByIdRequest) XXX_DiscardUnknown()

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

+ func (m *RecordActivityTaskHeartbeatByIdRequest) XXX_Merge(src proto.Message)

+ func (m *RecordActivityTaskHeartbeatByIdRequest) XXX_Size() int

+ func (m *RecordActivityTaskHeartbeatByIdRequest) XXX_Unmarshal(b []byte) error

+ func (this *RecordActivityTaskHeartbeatByIdRequest) Equal(that interface{}) bool

+ func (this *RecordActivityTaskHeartbeatByIdRequest) GoString() string

+ func (this *RecordActivityTaskHeartbeatByIdRequest) String() string

+ type RecordActivityTaskHeartbeatByIdResponse struct

+ CancelRequested bool

+ func (*RecordActivityTaskHeartbeatByIdResponse) Descriptor() ([]byte, []int)

+ func (*RecordActivityTaskHeartbeatByIdResponse) ProtoMessage()

+ func (m *RecordActivityTaskHeartbeatByIdResponse) GetCancelRequested() bool

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

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

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

+ func (m *RecordActivityTaskHeartbeatByIdResponse) Reset()

+ func (m *RecordActivityTaskHeartbeatByIdResponse) Size() (n int)

+ func (m *RecordActivityTaskHeartbeatByIdResponse) Unmarshal(dAtA []byte) error

+ func (m *RecordActivityTaskHeartbeatByIdResponse) XXX_DiscardUnknown()

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

+ func (m *RecordActivityTaskHeartbeatByIdResponse) XXX_Merge(src proto.Message)

+ func (m *RecordActivityTaskHeartbeatByIdResponse) XXX_Size() int

+ func (m *RecordActivityTaskHeartbeatByIdResponse) XXX_Unmarshal(b []byte) error

+ func (this *RecordActivityTaskHeartbeatByIdResponse) Equal(that interface{}) bool

+ func (this *RecordActivityTaskHeartbeatByIdResponse) GoString() string

+ func (this *RecordActivityTaskHeartbeatByIdResponse) String() string

+ type RecordActivityTaskHeartbeatRequest struct

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ TaskToken []byte

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

+ func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

+ func (m *RecordActivityTaskHeartbeatRequest) GetDetails() *v13.Payloads

+ func (m *RecordActivityTaskHeartbeatRequest) GetIdentity() string

+ func (m *RecordActivityTaskHeartbeatRequest) GetNamespace() string

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

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

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

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

+ func (m *RecordActivityTaskHeartbeatRequest) Reset()

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

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

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown()

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

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

+ func (m *RecordActivityTaskHeartbeatRequest) XXX_Size() int

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

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

+ func (this *RecordActivityTaskHeartbeatRequest) GoString() string

+ func (this *RecordActivityTaskHeartbeatRequest) String() string

+ type RecordActivityTaskHeartbeatResponse struct

+ CancelRequested bool

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

+ func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

+ func (m *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

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

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

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

+ func (m *RecordActivityTaskHeartbeatResponse) Reset()

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

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

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown()

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

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

+ func (m *RecordActivityTaskHeartbeatResponse) XXX_Size() int

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

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

+ func (this *RecordActivityTaskHeartbeatResponse) GoString() string

+ func (this *RecordActivityTaskHeartbeatResponse) String() string

+ type RegisterNamespaceRequest struct

+ ActiveClusterName string

+ Clusters []*v1.ClusterReplicationConfig

+ Data map[string]string

+ Description string

+ HistoryArchivalState v11.ArchivalState

+ HistoryArchivalUri string

+ IsGlobalNamespace bool

+ Namespace string

+ OwnerEmail string

+ SecurityToken string

+ VisibilityArchivalState v11.ArchivalState

+ VisibilityArchivalUri string

+ WorkflowExecutionRetentionPeriod *time.Duration

+ func (*RegisterNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*RegisterNamespaceRequest) ProtoMessage()

+ func (m *RegisterNamespaceRequest) GetActiveClusterName() string

+ func (m *RegisterNamespaceRequest) GetClusters() []*v1.ClusterReplicationConfig

+ func (m *RegisterNamespaceRequest) GetData() map[string]string

+ func (m *RegisterNamespaceRequest) GetDescription() string

+ func (m *RegisterNamespaceRequest) GetHistoryArchivalState() v11.ArchivalState

+ func (m *RegisterNamespaceRequest) GetHistoryArchivalUri() string

+ func (m *RegisterNamespaceRequest) GetIsGlobalNamespace() bool

+ func (m *RegisterNamespaceRequest) GetNamespace() string

+ func (m *RegisterNamespaceRequest) GetOwnerEmail() string

+ func (m *RegisterNamespaceRequest) GetSecurityToken() string

+ func (m *RegisterNamespaceRequest) GetVisibilityArchivalState() v11.ArchivalState

+ func (m *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

+ func (m *RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod() *time.Duration

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

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

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

+ func (m *RegisterNamespaceRequest) Reset()

+ func (m *RegisterNamespaceRequest) Size() (n int)

+ func (m *RegisterNamespaceRequest) Unmarshal(dAtA []byte) error

+ func (m *RegisterNamespaceRequest) XXX_DiscardUnknown()

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

+ func (m *RegisterNamespaceRequest) XXX_Merge(src proto.Message)

+ func (m *RegisterNamespaceRequest) XXX_Size() int

+ func (m *RegisterNamespaceRequest) XXX_Unmarshal(b []byte) error

+ func (this *RegisterNamespaceRequest) Equal(that interface{}) bool

+ func (this *RegisterNamespaceRequest) GoString() string

+ func (this *RegisterNamespaceRequest) String() string

+ type RegisterNamespaceResponse struct

+ func (*RegisterNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*RegisterNamespaceResponse) ProtoMessage()

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

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

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

+ func (m *RegisterNamespaceResponse) Reset()

+ func (m *RegisterNamespaceResponse) Size() (n int)

+ func (m *RegisterNamespaceResponse) Unmarshal(dAtA []byte) error

+ func (m *RegisterNamespaceResponse) XXX_DiscardUnknown()

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

+ func (m *RegisterNamespaceResponse) XXX_Merge(src proto.Message)

+ func (m *RegisterNamespaceResponse) XXX_Size() int

+ func (m *RegisterNamespaceResponse) XXX_Unmarshal(b []byte) error

+ func (this *RegisterNamespaceResponse) Equal(that interface{}) bool

+ func (this *RegisterNamespaceResponse) GoString() string

+ func (this *RegisterNamespaceResponse) String() string

+ type RequestCancelWorkflowExecutionRequest struct

+ FirstExecutionRunId string

+ Identity string

+ Namespace string

+ RequestId string

+ WorkflowExecution *v13.WorkflowExecution

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

+ func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

+ func (m *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId() string

+ func (m *RequestCancelWorkflowExecutionRequest) GetIdentity() string

+ func (m *RequestCancelWorkflowExecutionRequest) GetNamespace() string

+ func (m *RequestCancelWorkflowExecutionRequest) GetRequestId() string

+ func (m *RequestCancelWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

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

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

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

+ func (m *RequestCancelWorkflowExecutionRequest) Reset()

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

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

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown()

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

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

+ func (m *RequestCancelWorkflowExecutionRequest) XXX_Size() int

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

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

+ func (this *RequestCancelWorkflowExecutionRequest) GoString() string

+ func (this *RequestCancelWorkflowExecutionRequest) String() string

+ type RequestCancelWorkflowExecutionResponse struct

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

+ func (*RequestCancelWorkflowExecutionResponse) ProtoMessage()

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

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

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

+ func (m *RequestCancelWorkflowExecutionResponse) Reset()

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

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

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown()

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

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

+ func (m *RequestCancelWorkflowExecutionResponse) XXX_Size() int

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

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

+ func (this *RequestCancelWorkflowExecutionResponse) GoString() string

+ func (this *RequestCancelWorkflowExecutionResponse) String() string

+ type ResetStickyTaskQueueRequest struct

+ Execution *v13.WorkflowExecution

+ Namespace string

+ func (*ResetStickyTaskQueueRequest) Descriptor() ([]byte, []int)

+ func (*ResetStickyTaskQueueRequest) ProtoMessage()

+ func (m *ResetStickyTaskQueueRequest) GetExecution() *v13.WorkflowExecution

+ func (m *ResetStickyTaskQueueRequest) GetNamespace() string

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

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

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

+ func (m *ResetStickyTaskQueueRequest) Reset()

+ func (m *ResetStickyTaskQueueRequest) Size() (n int)

+ func (m *ResetStickyTaskQueueRequest) Unmarshal(dAtA []byte) error

+ func (m *ResetStickyTaskQueueRequest) XXX_DiscardUnknown()

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

+ func (m *ResetStickyTaskQueueRequest) XXX_Merge(src proto.Message)

+ func (m *ResetStickyTaskQueueRequest) XXX_Size() int

+ func (m *ResetStickyTaskQueueRequest) XXX_Unmarshal(b []byte) error

+ func (this *ResetStickyTaskQueueRequest) Equal(that interface{}) bool

+ func (this *ResetStickyTaskQueueRequest) GoString() string

+ func (this *ResetStickyTaskQueueRequest) String() string

+ type ResetStickyTaskQueueResponse struct

+ func (*ResetStickyTaskQueueResponse) Descriptor() ([]byte, []int)

+ func (*ResetStickyTaskQueueResponse) ProtoMessage()

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

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

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

+ func (m *ResetStickyTaskQueueResponse) Reset()

+ func (m *ResetStickyTaskQueueResponse) Size() (n int)

+ func (m *ResetStickyTaskQueueResponse) Unmarshal(dAtA []byte) error

+ func (m *ResetStickyTaskQueueResponse) XXX_DiscardUnknown()

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

+ func (m *ResetStickyTaskQueueResponse) XXX_Merge(src proto.Message)

+ func (m *ResetStickyTaskQueueResponse) XXX_Size() int

+ func (m *ResetStickyTaskQueueResponse) XXX_Unmarshal(b []byte) error

+ func (this *ResetStickyTaskQueueResponse) Equal(that interface{}) bool

+ func (this *ResetStickyTaskQueueResponse) GoString() string

+ func (this *ResetStickyTaskQueueResponse) String() string

+ type ResetWorkflowExecutionRequest struct

+ Namespace string

+ Reason string

+ RequestId string

+ WorkflowExecution *v13.WorkflowExecution

+ WorkflowTaskFinishEventId int64

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

+ func (*ResetWorkflowExecutionRequest) ProtoMessage()

+ func (m *ResetWorkflowExecutionRequest) GetNamespace() string

+ func (m *ResetWorkflowExecutionRequest) GetReason() string

+ func (m *ResetWorkflowExecutionRequest) GetRequestId() string

+ func (m *ResetWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

+ func (m *ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId() int64

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

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

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

+ func (m *ResetWorkflowExecutionRequest) Reset()

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

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

+ func (m *ResetWorkflowExecutionRequest) XXX_DiscardUnknown()

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

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

+ func (m *ResetWorkflowExecutionRequest) XXX_Size() int

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

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

+ func (this *ResetWorkflowExecutionRequest) GoString() string

+ func (this *ResetWorkflowExecutionRequest) String() string

+ type ResetWorkflowExecutionResponse struct

+ RunId string

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

+ func (*ResetWorkflowExecutionResponse) ProtoMessage()

+ func (m *ResetWorkflowExecutionResponse) GetRunId() string

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

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

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

+ func (m *ResetWorkflowExecutionResponse) Reset()

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

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

+ func (m *ResetWorkflowExecutionResponse) XXX_DiscardUnknown()

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

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

+ func (m *ResetWorkflowExecutionResponse) XXX_Size() int

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

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

+ func (this *ResetWorkflowExecutionResponse) GoString() string

+ func (this *ResetWorkflowExecutionResponse) String() string

+ type RespondActivityTaskCanceledByIdRequest struct

+ ActivityId string

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ RunId string

+ WorkflowId string

+ func (*RespondActivityTaskCanceledByIdRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage()

+ func (m *RespondActivityTaskCanceledByIdRequest) GetActivityId() string

+ func (m *RespondActivityTaskCanceledByIdRequest) GetDetails() *v13.Payloads

+ func (m *RespondActivityTaskCanceledByIdRequest) GetIdentity() string

+ func (m *RespondActivityTaskCanceledByIdRequest) GetNamespace() string

+ func (m *RespondActivityTaskCanceledByIdRequest) GetRunId() string

+ func (m *RespondActivityTaskCanceledByIdRequest) GetWorkflowId() string

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

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

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

+ func (m *RespondActivityTaskCanceledByIdRequest) Reset()

+ func (m *RespondActivityTaskCanceledByIdRequest) Size() (n int)

+ func (m *RespondActivityTaskCanceledByIdRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCanceledByIdRequest) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskCanceledByIdRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCanceledByIdRequest) XXX_Size() int

+ func (m *RespondActivityTaskCanceledByIdRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCanceledByIdRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCanceledByIdRequest) GoString() string

+ func (this *RespondActivityTaskCanceledByIdRequest) String() string

+ type RespondActivityTaskCanceledByIdResponse struct

+ func (*RespondActivityTaskCanceledByIdResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCanceledByIdResponse) ProtoMessage()

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

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

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

+ func (m *RespondActivityTaskCanceledByIdResponse) Reset()

+ func (m *RespondActivityTaskCanceledByIdResponse) Size() (n int)

+ func (m *RespondActivityTaskCanceledByIdResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCanceledByIdResponse) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskCanceledByIdResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCanceledByIdResponse) XXX_Size() int

+ func (m *RespondActivityTaskCanceledByIdResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCanceledByIdResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCanceledByIdResponse) GoString() string

+ func (this *RespondActivityTaskCanceledByIdResponse) String() string

+ type RespondActivityTaskCanceledRequest struct

+ Details *v13.Payloads

+ Identity string

+ Namespace string

+ TaskToken []byte

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

+ func (*RespondActivityTaskCanceledRequest) ProtoMessage()

+ func (m *RespondActivityTaskCanceledRequest) GetDetails() *v13.Payloads

+ func (m *RespondActivityTaskCanceledRequest) GetIdentity() string

+ func (m *RespondActivityTaskCanceledRequest) GetNamespace() string

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

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

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

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

+ func (m *RespondActivityTaskCanceledRequest) Reset()

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

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

+ func (m *RespondActivityTaskCanceledRequest) XXX_DiscardUnknown()

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

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

+ func (m *RespondActivityTaskCanceledRequest) XXX_Size() int

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

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

+ func (this *RespondActivityTaskCanceledRequest) GoString() string

+ func (this *RespondActivityTaskCanceledRequest) String() string

+ type RespondActivityTaskCanceledResponse struct

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

+ func (*RespondActivityTaskCanceledResponse) ProtoMessage()

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

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

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

+ func (m *RespondActivityTaskCanceledResponse) Reset()

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

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

+ func (m *RespondActivityTaskCanceledResponse) XXX_DiscardUnknown()

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

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

+ func (m *RespondActivityTaskCanceledResponse) XXX_Size() int

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

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

+ func (this *RespondActivityTaskCanceledResponse) GoString() string

+ func (this *RespondActivityTaskCanceledResponse) String() string

+ type RespondActivityTaskCompletedByIdRequest struct

+ ActivityId string

+ Identity string

+ Namespace string

+ Result *v13.Payloads

+ RunId string

+ WorkflowId string

+ func (*RespondActivityTaskCompletedByIdRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage()

+ func (m *RespondActivityTaskCompletedByIdRequest) GetActivityId() string

+ func (m *RespondActivityTaskCompletedByIdRequest) GetIdentity() string

+ func (m *RespondActivityTaskCompletedByIdRequest) GetNamespace() string

+ func (m *RespondActivityTaskCompletedByIdRequest) GetResult() *v13.Payloads

+ func (m *RespondActivityTaskCompletedByIdRequest) GetRunId() string

+ func (m *RespondActivityTaskCompletedByIdRequest) GetWorkflowId() string

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

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

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

+ func (m *RespondActivityTaskCompletedByIdRequest) Reset()

+ func (m *RespondActivityTaskCompletedByIdRequest) Size() (n int)

+ func (m *RespondActivityTaskCompletedByIdRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCompletedByIdRequest) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskCompletedByIdRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCompletedByIdRequest) XXX_Size() int

+ func (m *RespondActivityTaskCompletedByIdRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCompletedByIdRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCompletedByIdRequest) GoString() string

+ func (this *RespondActivityTaskCompletedByIdRequest) String() string

+ type RespondActivityTaskCompletedByIdResponse struct

+ func (*RespondActivityTaskCompletedByIdResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskCompletedByIdResponse) ProtoMessage()

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

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

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

+ func (m *RespondActivityTaskCompletedByIdResponse) Reset()

+ func (m *RespondActivityTaskCompletedByIdResponse) Size() (n int)

+ func (m *RespondActivityTaskCompletedByIdResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskCompletedByIdResponse) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskCompletedByIdResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskCompletedByIdResponse) XXX_Size() int

+ func (m *RespondActivityTaskCompletedByIdResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskCompletedByIdResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskCompletedByIdResponse) GoString() string

+ func (this *RespondActivityTaskCompletedByIdResponse) String() string

+ type RespondActivityTaskCompletedRequest struct

+ Identity string

+ Namespace string

+ Result *v13.Payloads

+ TaskToken []byte

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

+ func (*RespondActivityTaskCompletedRequest) ProtoMessage()

+ func (m *RespondActivityTaskCompletedRequest) GetIdentity() string

+ func (m *RespondActivityTaskCompletedRequest) GetNamespace() string

+ func (m *RespondActivityTaskCompletedRequest) GetResult() *v13.Payloads

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

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

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

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

+ func (m *RespondActivityTaskCompletedRequest) Reset()

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

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

+ func (m *RespondActivityTaskCompletedRequest) XXX_DiscardUnknown()

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

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

+ func (m *RespondActivityTaskCompletedRequest) XXX_Size() int

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

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

+ func (this *RespondActivityTaskCompletedRequest) GoString() string

+ func (this *RespondActivityTaskCompletedRequest) String() string

+ type RespondActivityTaskCompletedResponse struct

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

+ func (*RespondActivityTaskCompletedResponse) ProtoMessage()

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

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

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

+ func (m *RespondActivityTaskCompletedResponse) Reset()

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

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

+ func (m *RespondActivityTaskCompletedResponse) XXX_DiscardUnknown()

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

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

+ func (m *RespondActivityTaskCompletedResponse) XXX_Size() int

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

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

+ func (this *RespondActivityTaskCompletedResponse) GoString() string

+ func (this *RespondActivityTaskCompletedResponse) String() string

+ type RespondActivityTaskFailedByIdRequest struct

+ ActivityId string

+ Failure *v18.Failure

+ Identity string

+ Namespace string

+ RunId string

+ WorkflowId string

+ func (*RespondActivityTaskFailedByIdRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedByIdRequest) ProtoMessage()

+ func (m *RespondActivityTaskFailedByIdRequest) GetActivityId() string

+ func (m *RespondActivityTaskFailedByIdRequest) GetFailure() *v18.Failure

+ func (m *RespondActivityTaskFailedByIdRequest) GetIdentity() string

+ func (m *RespondActivityTaskFailedByIdRequest) GetNamespace() string

+ func (m *RespondActivityTaskFailedByIdRequest) GetRunId() string

+ func (m *RespondActivityTaskFailedByIdRequest) GetWorkflowId() string

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

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

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

+ func (m *RespondActivityTaskFailedByIdRequest) Reset()

+ func (m *RespondActivityTaskFailedByIdRequest) Size() (n int)

+ func (m *RespondActivityTaskFailedByIdRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskFailedByIdRequest) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskFailedByIdRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskFailedByIdRequest) XXX_Size() int

+ func (m *RespondActivityTaskFailedByIdRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskFailedByIdRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskFailedByIdRequest) GoString() string

+ func (this *RespondActivityTaskFailedByIdRequest) String() string

+ type RespondActivityTaskFailedByIdResponse struct

+ func (*RespondActivityTaskFailedByIdResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedByIdResponse) ProtoMessage()

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

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

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

+ func (m *RespondActivityTaskFailedByIdResponse) Reset()

+ func (m *RespondActivityTaskFailedByIdResponse) Size() (n int)

+ func (m *RespondActivityTaskFailedByIdResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskFailedByIdResponse) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskFailedByIdResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskFailedByIdResponse) XXX_Size() int

+ func (m *RespondActivityTaskFailedByIdResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskFailedByIdResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskFailedByIdResponse) GoString() string

+ func (this *RespondActivityTaskFailedByIdResponse) String() string

+ type RespondActivityTaskFailedRequest struct

+ Failure *v18.Failure

+ Identity string

+ Namespace string

+ TaskToken []byte

+ func (*RespondActivityTaskFailedRequest) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedRequest) ProtoMessage()

+ func (m *RespondActivityTaskFailedRequest) GetFailure() *v18.Failure

+ func (m *RespondActivityTaskFailedRequest) GetIdentity() string

+ func (m *RespondActivityTaskFailedRequest) GetNamespace() string

+ func (m *RespondActivityTaskFailedRequest) GetTaskToken() []byte

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

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

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

+ func (m *RespondActivityTaskFailedRequest) Reset()

+ func (m *RespondActivityTaskFailedRequest) Size() (n int)

+ func (m *RespondActivityTaskFailedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskFailedRequest) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskFailedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskFailedRequest) XXX_Size() int

+ func (m *RespondActivityTaskFailedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskFailedRequest) Equal(that interface{}) bool

+ func (this *RespondActivityTaskFailedRequest) GoString() string

+ func (this *RespondActivityTaskFailedRequest) String() string

+ type RespondActivityTaskFailedResponse struct

+ func (*RespondActivityTaskFailedResponse) Descriptor() ([]byte, []int)

+ func (*RespondActivityTaskFailedResponse) ProtoMessage()

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

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

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

+ func (m *RespondActivityTaskFailedResponse) Reset()

+ func (m *RespondActivityTaskFailedResponse) Size() (n int)

+ func (m *RespondActivityTaskFailedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondActivityTaskFailedResponse) XXX_DiscardUnknown()

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

+ func (m *RespondActivityTaskFailedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondActivityTaskFailedResponse) XXX_Size() int

+ func (m *RespondActivityTaskFailedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondActivityTaskFailedResponse) Equal(that interface{}) bool

+ func (this *RespondActivityTaskFailedResponse) GoString() string

+ func (this *RespondActivityTaskFailedResponse) String() string

+ type RespondQueryTaskCompletedRequest struct

+ CompletedType v11.QueryResultType

+ ErrorMessage string

+ Namespace string

+ QueryResult *v13.Payloads

+ TaskToken []byte

+ func (*RespondQueryTaskCompletedRequest) Descriptor() ([]byte, []int)

+ func (*RespondQueryTaskCompletedRequest) ProtoMessage()

+ func (m *RespondQueryTaskCompletedRequest) GetCompletedType() v11.QueryResultType

+ func (m *RespondQueryTaskCompletedRequest) GetErrorMessage() string

+ func (m *RespondQueryTaskCompletedRequest) GetNamespace() string

+ func (m *RespondQueryTaskCompletedRequest) GetQueryResult() *v13.Payloads

+ func (m *RespondQueryTaskCompletedRequest) GetTaskToken() []byte

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

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

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

+ func (m *RespondQueryTaskCompletedRequest) Reset()

+ func (m *RespondQueryTaskCompletedRequest) Size() (n int)

+ func (m *RespondQueryTaskCompletedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondQueryTaskCompletedRequest) XXX_DiscardUnknown()

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

+ func (m *RespondQueryTaskCompletedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondQueryTaskCompletedRequest) XXX_Size() int

+ func (m *RespondQueryTaskCompletedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondQueryTaskCompletedRequest) Equal(that interface{}) bool

+ func (this *RespondQueryTaskCompletedRequest) GoString() string

+ func (this *RespondQueryTaskCompletedRequest) String() string

+ type RespondQueryTaskCompletedResponse struct

+ func (*RespondQueryTaskCompletedResponse) Descriptor() ([]byte, []int)

+ func (*RespondQueryTaskCompletedResponse) ProtoMessage()

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

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

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

+ func (m *RespondQueryTaskCompletedResponse) Reset()

+ func (m *RespondQueryTaskCompletedResponse) Size() (n int)

+ func (m *RespondQueryTaskCompletedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondQueryTaskCompletedResponse) XXX_DiscardUnknown()

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

+ func (m *RespondQueryTaskCompletedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondQueryTaskCompletedResponse) XXX_Size() int

+ func (m *RespondQueryTaskCompletedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondQueryTaskCompletedResponse) Equal(that interface{}) bool

+ func (this *RespondQueryTaskCompletedResponse) GoString() string

+ func (this *RespondQueryTaskCompletedResponse) String() string

+ type RespondWorkflowTaskCompletedRequest struct

+ BinaryChecksum string

+ Commands []*v17.Command

+ ForceCreateNewWorkflowTask bool

+ Identity string

+ Namespace string

+ QueryResults map[string]*v16.WorkflowQueryResult

+ ReturnNewWorkflowTask bool

+ StickyAttributes *v14.StickyExecutionAttributes

+ TaskToken []byte

+ func (*RespondWorkflowTaskCompletedRequest) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

+ func (m *RespondWorkflowTaskCompletedRequest) GetBinaryChecksum() string

+ func (m *RespondWorkflowTaskCompletedRequest) GetCommands() []*v17.Command

+ func (m *RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask() bool

+ func (m *RespondWorkflowTaskCompletedRequest) GetIdentity() string

+ func (m *RespondWorkflowTaskCompletedRequest) GetNamespace() string

+ func (m *RespondWorkflowTaskCompletedRequest) GetQueryResults() map[string]*v16.WorkflowQueryResult

+ func (m *RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask() bool

+ func (m *RespondWorkflowTaskCompletedRequest) GetStickyAttributes() *v14.StickyExecutionAttributes

+ func (m *RespondWorkflowTaskCompletedRequest) GetTaskToken() []byte

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

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

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

+ func (m *RespondWorkflowTaskCompletedRequest) Reset()

+ func (m *RespondWorkflowTaskCompletedRequest) Size() (n int)

+ func (m *RespondWorkflowTaskCompletedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown()

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

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Size() int

+ func (m *RespondWorkflowTaskCompletedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskCompletedRequest) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskCompletedRequest) GoString() string

+ func (this *RespondWorkflowTaskCompletedRequest) String() string

+ type RespondWorkflowTaskCompletedResponse struct

+ WorkflowTask *PollWorkflowTaskQueueResponse

+ func (*RespondWorkflowTaskCompletedResponse) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

+ func (m *RespondWorkflowTaskCompletedResponse) GetWorkflowTask() *PollWorkflowTaskQueueResponse

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

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

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

+ func (m *RespondWorkflowTaskCompletedResponse) Reset()

+ func (m *RespondWorkflowTaskCompletedResponse) Size() (n int)

+ func (m *RespondWorkflowTaskCompletedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown()

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

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Size() int

+ func (m *RespondWorkflowTaskCompletedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskCompletedResponse) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskCompletedResponse) GoString() string

+ func (this *RespondWorkflowTaskCompletedResponse) String() string

+ type RespondWorkflowTaskFailedRequest struct

+ BinaryChecksum string

+ Cause v11.WorkflowTaskFailedCause

+ Failure *v18.Failure

+ Identity string

+ Namespace string

+ TaskToken []byte

+ func (*RespondWorkflowTaskFailedRequest) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

+ func (m *RespondWorkflowTaskFailedRequest) GetBinaryChecksum() string

+ func (m *RespondWorkflowTaskFailedRequest) GetCause() v11.WorkflowTaskFailedCause

+ func (m *RespondWorkflowTaskFailedRequest) GetFailure() *v18.Failure

+ func (m *RespondWorkflowTaskFailedRequest) GetIdentity() string

+ func (m *RespondWorkflowTaskFailedRequest) GetNamespace() string

+ func (m *RespondWorkflowTaskFailedRequest) GetTaskToken() []byte

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

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

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

+ func (m *RespondWorkflowTaskFailedRequest) Reset()

+ func (m *RespondWorkflowTaskFailedRequest) Size() (n int)

+ func (m *RespondWorkflowTaskFailedRequest) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown()

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

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Size() int

+ func (m *RespondWorkflowTaskFailedRequest) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskFailedRequest) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskFailedRequest) GoString() string

+ func (this *RespondWorkflowTaskFailedRequest) String() string

+ type RespondWorkflowTaskFailedResponse struct

+ func (*RespondWorkflowTaskFailedResponse) Descriptor() ([]byte, []int)

+ func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

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

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

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

+ func (m *RespondWorkflowTaskFailedResponse) Reset()

+ func (m *RespondWorkflowTaskFailedResponse) Size() (n int)

+ func (m *RespondWorkflowTaskFailedResponse) Unmarshal(dAtA []byte) error

+ func (m *RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown()

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

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Merge(src proto.Message)

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Size() int

+ func (m *RespondWorkflowTaskFailedResponse) XXX_Unmarshal(b []byte) error

+ func (this *RespondWorkflowTaskFailedResponse) Equal(that interface{}) bool

+ func (this *RespondWorkflowTaskFailedResponse) GoString() string

+ func (this *RespondWorkflowTaskFailedResponse) String() string

+ type ScanWorkflowExecutionsRequest struct

+ Namespace string

+ NextPageToken []byte

+ PageSize int32

+ Query string

+ func (*ScanWorkflowExecutionsRequest) Descriptor() ([]byte, []int)

+ func (*ScanWorkflowExecutionsRequest) ProtoMessage()

+ func (m *ScanWorkflowExecutionsRequest) GetNamespace() string

+ func (m *ScanWorkflowExecutionsRequest) GetNextPageToken() []byte

+ func (m *ScanWorkflowExecutionsRequest) GetPageSize() int32

+ func (m *ScanWorkflowExecutionsRequest) GetQuery() string

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

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

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

+ func (m *ScanWorkflowExecutionsRequest) Reset()

+ func (m *ScanWorkflowExecutionsRequest) Size() (n int)

+ func (m *ScanWorkflowExecutionsRequest) Unmarshal(dAtA []byte) error

+ func (m *ScanWorkflowExecutionsRequest) XXX_DiscardUnknown()

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

+ func (m *ScanWorkflowExecutionsRequest) XXX_Merge(src proto.Message)

+ func (m *ScanWorkflowExecutionsRequest) XXX_Size() int

+ func (m *ScanWorkflowExecutionsRequest) XXX_Unmarshal(b []byte) error

+ func (this *ScanWorkflowExecutionsRequest) Equal(that interface{}) bool

+ func (this *ScanWorkflowExecutionsRequest) GoString() string

+ func (this *ScanWorkflowExecutionsRequest) String() string

+ type ScanWorkflowExecutionsResponse struct

+ Executions []*v110.WorkflowExecutionInfo

+ NextPageToken []byte

+ func (*ScanWorkflowExecutionsResponse) Descriptor() ([]byte, []int)

+ func (*ScanWorkflowExecutionsResponse) ProtoMessage()

+ func (m *ScanWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

+ func (m *ScanWorkflowExecutionsResponse) GetNextPageToken() []byte

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

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

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

+ func (m *ScanWorkflowExecutionsResponse) Reset()

+ func (m *ScanWorkflowExecutionsResponse) Size() (n int)

+ func (m *ScanWorkflowExecutionsResponse) Unmarshal(dAtA []byte) error

+ func (m *ScanWorkflowExecutionsResponse) XXX_DiscardUnknown()

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

+ func (m *ScanWorkflowExecutionsResponse) XXX_Merge(src proto.Message)

+ func (m *ScanWorkflowExecutionsResponse) XXX_Size() int

+ func (m *ScanWorkflowExecutionsResponse) XXX_Unmarshal(b []byte) error

+ func (this *ScanWorkflowExecutionsResponse) Equal(that interface{}) bool

+ func (this *ScanWorkflowExecutionsResponse) GoString() string

+ func (this *ScanWorkflowExecutionsResponse) String() string

+ type SignalWithStartWorkflowExecutionRequest struct

+ Control string

+ CronSchedule string

+ Header *v13.Header

+ Identity string

+ Input *v13.Payloads

+ Memo *v13.Memo

+ Namespace string

+ RequestId string

+ RetryPolicy *v13.RetryPolicy

+ SearchAttributes *v13.SearchAttributes

+ SignalInput *v13.Payloads

+ SignalName string

+ TaskQueue *v14.TaskQueue

+ WorkflowExecutionTimeout *time.Duration

+ WorkflowId string

+ WorkflowIdReusePolicy v11.WorkflowIdReusePolicy

+ WorkflowRunTimeout *time.Duration

+ WorkflowTaskTimeout *time.Duration

+ WorkflowType *v13.WorkflowType

+ func (*SignalWithStartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage()

+ func (m *SignalWithStartWorkflowExecutionRequest) GetControl() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetHeader() *v13.Header

+ func (m *SignalWithStartWorkflowExecutionRequest) GetIdentity() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetInput() *v13.Payloads

+ func (m *SignalWithStartWorkflowExecutionRequest) GetMemo() *v13.Memo

+ func (m *SignalWithStartWorkflowExecutionRequest) GetNamespace() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetRequestId() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

+ func (m *SignalWithStartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

+ func (m *SignalWithStartWorkflowExecutionRequest) GetSignalInput() *v13.Payloads

+ func (m *SignalWithStartWorkflowExecutionRequest) GetSignalName() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

+ func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *time.Duration

+ func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowId() string

+ func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

+ func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout() *time.Duration

+ func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *time.Duration

+ func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

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

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

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

+ func (m *SignalWithStartWorkflowExecutionRequest) Reset()

+ func (m *SignalWithStartWorkflowExecutionRequest) Size() (n int)

+ func (m *SignalWithStartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown()

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

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Size() int

+ func (m *SignalWithStartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *SignalWithStartWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *SignalWithStartWorkflowExecutionRequest) GoString() string

+ func (this *SignalWithStartWorkflowExecutionRequest) String() string

+ type SignalWithStartWorkflowExecutionResponse struct

+ RunId string

+ func (*SignalWithStartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage()

+ func (m *SignalWithStartWorkflowExecutionResponse) GetRunId() string

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

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

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

+ func (m *SignalWithStartWorkflowExecutionResponse) Reset()

+ func (m *SignalWithStartWorkflowExecutionResponse) Size() (n int)

+ func (m *SignalWithStartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown()

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

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Size() int

+ func (m *SignalWithStartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *SignalWithStartWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *SignalWithStartWorkflowExecutionResponse) GoString() string

+ func (this *SignalWithStartWorkflowExecutionResponse) String() string

+ type SignalWorkflowExecutionRequest struct

+ Control string

+ Identity string

+ Input *v13.Payloads

+ Namespace string

+ RequestId string

+ SignalName string

+ WorkflowExecution *v13.WorkflowExecution

+ func (*SignalWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*SignalWorkflowExecutionRequest) ProtoMessage()

+ func (m *SignalWorkflowExecutionRequest) GetControl() string

+ func (m *SignalWorkflowExecutionRequest) GetIdentity() string

+ func (m *SignalWorkflowExecutionRequest) GetInput() *v13.Payloads

+ func (m *SignalWorkflowExecutionRequest) GetNamespace() string

+ func (m *SignalWorkflowExecutionRequest) GetRequestId() string

+ func (m *SignalWorkflowExecutionRequest) GetSignalName() string

+ func (m *SignalWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

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

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

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

+ func (m *SignalWorkflowExecutionRequest) Reset()

+ func (m *SignalWorkflowExecutionRequest) Size() (n int)

+ func (m *SignalWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *SignalWorkflowExecutionRequest) XXX_DiscardUnknown()

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

+ func (m *SignalWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *SignalWorkflowExecutionRequest) XXX_Size() int

+ func (m *SignalWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *SignalWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *SignalWorkflowExecutionRequest) GoString() string

+ func (this *SignalWorkflowExecutionRequest) String() string

+ type SignalWorkflowExecutionResponse struct

+ func (*SignalWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*SignalWorkflowExecutionResponse) ProtoMessage()

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

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

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

+ func (m *SignalWorkflowExecutionResponse) Reset()

+ func (m *SignalWorkflowExecutionResponse) Size() (n int)

+ func (m *SignalWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *SignalWorkflowExecutionResponse) XXX_DiscardUnknown()

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

+ func (m *SignalWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *SignalWorkflowExecutionResponse) XXX_Size() int

+ func (m *SignalWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *SignalWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *SignalWorkflowExecutionResponse) GoString() string

+ func (this *SignalWorkflowExecutionResponse) String() string

+ type StartWorkflowExecutionRequest struct

+ CronSchedule string

+ Header *v13.Header

+ Identity string

+ Input *v13.Payloads

+ Memo *v13.Memo

+ Namespace string

+ RequestId string

+ RetryPolicy *v13.RetryPolicy

+ SearchAttributes *v13.SearchAttributes

+ TaskQueue *v14.TaskQueue

+ WorkflowExecutionTimeout *time.Duration

+ WorkflowId string

+ WorkflowIdReusePolicy v11.WorkflowIdReusePolicy

+ WorkflowRunTimeout *time.Duration

+ WorkflowTaskTimeout *time.Duration

+ WorkflowType *v13.WorkflowType

+ func (*StartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*StartWorkflowExecutionRequest) ProtoMessage()

+ func (m *StartWorkflowExecutionRequest) GetCronSchedule() string

+ func (m *StartWorkflowExecutionRequest) GetHeader() *v13.Header

+ func (m *StartWorkflowExecutionRequest) GetIdentity() string

+ func (m *StartWorkflowExecutionRequest) GetInput() *v13.Payloads

+ func (m *StartWorkflowExecutionRequest) GetMemo() *v13.Memo

+ func (m *StartWorkflowExecutionRequest) GetNamespace() string

+ func (m *StartWorkflowExecutionRequest) GetRequestId() string

+ func (m *StartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

+ func (m *StartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

+ func (m *StartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

+ func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *time.Duration

+ func (m *StartWorkflowExecutionRequest) GetWorkflowId() string

+ func (m *StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

+ func (m *StartWorkflowExecutionRequest) GetWorkflowRunTimeout() *time.Duration

+ func (m *StartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *time.Duration

+ func (m *StartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

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

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

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

+ func (m *StartWorkflowExecutionRequest) Reset()

+ func (m *StartWorkflowExecutionRequest) Size() (n int)

+ func (m *StartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

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

+ func (m *StartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *StartWorkflowExecutionRequest) XXX_Size() int

+ func (m *StartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *StartWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *StartWorkflowExecutionRequest) GoString() string

+ func (this *StartWorkflowExecutionRequest) String() string

+ type StartWorkflowExecutionResponse struct

+ RunId string

+ func (*StartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*StartWorkflowExecutionResponse) ProtoMessage()

+ func (m *StartWorkflowExecutionResponse) GetRunId() string

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

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

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

+ func (m *StartWorkflowExecutionResponse) Reset()

+ func (m *StartWorkflowExecutionResponse) Size() (n int)

+ func (m *StartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

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

+ func (m *StartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *StartWorkflowExecutionResponse) XXX_Size() int

+ func (m *StartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *StartWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *StartWorkflowExecutionResponse) GoString() string

+ func (this *StartWorkflowExecutionResponse) String() string

+ type TerminateWorkflowExecutionRequest struct

+ Details *v13.Payloads

+ FirstExecutionRunId string

+ Identity string

+ Namespace string

+ Reason string

+ WorkflowExecution *v13.WorkflowExecution

+ func (*TerminateWorkflowExecutionRequest) Descriptor() ([]byte, []int)

+ func (*TerminateWorkflowExecutionRequest) ProtoMessage()

+ func (m *TerminateWorkflowExecutionRequest) GetDetails() *v13.Payloads

+ func (m *TerminateWorkflowExecutionRequest) GetFirstExecutionRunId() string

+ func (m *TerminateWorkflowExecutionRequest) GetIdentity() string

+ func (m *TerminateWorkflowExecutionRequest) GetNamespace() string

+ func (m *TerminateWorkflowExecutionRequest) GetReason() string

+ func (m *TerminateWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

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

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

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

+ func (m *TerminateWorkflowExecutionRequest) Reset()

+ func (m *TerminateWorkflowExecutionRequest) Size() (n int)

+ func (m *TerminateWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

+ func (m *TerminateWorkflowExecutionRequest) XXX_DiscardUnknown()

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

+ func (m *TerminateWorkflowExecutionRequest) XXX_Merge(src proto.Message)

+ func (m *TerminateWorkflowExecutionRequest) XXX_Size() int

+ func (m *TerminateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

+ func (this *TerminateWorkflowExecutionRequest) Equal(that interface{}) bool

+ func (this *TerminateWorkflowExecutionRequest) GoString() string

+ func (this *TerminateWorkflowExecutionRequest) String() string

+ type TerminateWorkflowExecutionResponse struct

+ func (*TerminateWorkflowExecutionResponse) Descriptor() ([]byte, []int)

+ func (*TerminateWorkflowExecutionResponse) ProtoMessage()

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

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

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

+ func (m *TerminateWorkflowExecutionResponse) Reset()

+ func (m *TerminateWorkflowExecutionResponse) Size() (n int)

+ func (m *TerminateWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

+ func (m *TerminateWorkflowExecutionResponse) XXX_DiscardUnknown()

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

+ func (m *TerminateWorkflowExecutionResponse) XXX_Merge(src proto.Message)

+ func (m *TerminateWorkflowExecutionResponse) XXX_Size() int

+ func (m *TerminateWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

+ func (this *TerminateWorkflowExecutionResponse) Equal(that interface{}) bool

+ func (this *TerminateWorkflowExecutionResponse) GoString() string

+ func (this *TerminateWorkflowExecutionResponse) String() string

+ type UnimplementedWorkflowServiceServer struct

+ func (*UnimplementedWorkflowServiceServer) CountWorkflowExecutions(ctx context.Context, req *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) DeprecateNamespace(ctx context.Context, req *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)

+ func (*UnimplementedWorkflowServiceServer) DescribeNamespace(ctx context.Context, req *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)

+ func (*UnimplementedWorkflowServiceServer) DescribeTaskQueue(ctx context.Context, req *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)

+ func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution(ctx context.Context, req *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

+ func (*UnimplementedWorkflowServiceServer) GetSearchAttributes(ctx context.Context, req *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

+ func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory(ctx context.Context, req *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions(ctx context.Context, req *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions(ctx context.Context, req *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListNamespaces(ctx context.Context, req *ListNamespacesRequest) (*ListNamespacesResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions(ctx context.Context, req *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListTaskQueuePartitions(ctx context.Context, req *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions(ctx context.Context, req *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) PollActivityTaskQueue(ctx context.Context, req *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)

+ func (*UnimplementedWorkflowServiceServer) PollWorkflowTaskQueue(ctx context.Context, req *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)

+ func (*UnimplementedWorkflowServiceServer) QueryWorkflow(ctx context.Context, req *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat(ctx context.Context, req *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatById(ctx context.Context, req *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RegisterNamespace(ctx context.Context, req *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution(ctx context.Context, req *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ResetStickyTaskQueue(ctx context.Context, req *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution(ctx context.Context, req *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled(ctx context.Context, req *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledById(ctx context.Context, req *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted(ctx context.Context, req *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedById(ctx context.Context, req *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed(ctx context.Context, req *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedById(ctx context.Context, req *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted(ctx context.Context, req *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskCompleted(ctx context.Context, req *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)

+ func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskFailed(ctx context.Context, req *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)

+ func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions(ctx context.Context, req *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)

+ func (*UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution(ctx context.Context, req *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) SignalWorkflowExecution(ctx context.Context, req *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) StartWorkflowExecution(ctx context.Context, req *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution(ctx context.Context, req *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

+ func (*UnimplementedWorkflowServiceServer) UpdateNamespace(ctx context.Context, req *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

+ type UpdateNamespaceRequest struct

+ Config *v12.NamespaceConfig

+ DeleteBadBinary string

+ Namespace string

+ ReplicationConfig *v1.NamespaceReplicationConfig

+ SecurityToken string

+ UpdateInfo *v12.UpdateNamespaceInfo

+ func (*UpdateNamespaceRequest) Descriptor() ([]byte, []int)

+ func (*UpdateNamespaceRequest) ProtoMessage()

+ func (m *UpdateNamespaceRequest) GetConfig() *v12.NamespaceConfig

+ func (m *UpdateNamespaceRequest) GetDeleteBadBinary() string

+ func (m *UpdateNamespaceRequest) GetNamespace() string

+ func (m *UpdateNamespaceRequest) GetReplicationConfig() *v1.NamespaceReplicationConfig

+ func (m *UpdateNamespaceRequest) GetSecurityToken() string

+ func (m *UpdateNamespaceRequest) GetUpdateInfo() *v12.UpdateNamespaceInfo

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

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

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

+ func (m *UpdateNamespaceRequest) Reset()

+ func (m *UpdateNamespaceRequest) Size() (n int)

+ func (m *UpdateNamespaceRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateNamespaceRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateNamespaceRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateNamespaceRequest) XXX_Size() int

+ func (m *UpdateNamespaceRequest) XXX_Unmarshal(b []byte) error

+ func (this *UpdateNamespaceRequest) Equal(that interface{}) bool

+ func (this *UpdateNamespaceRequest) GoString() string

+ func (this *UpdateNamespaceRequest) String() string

+ type UpdateNamespaceResponse struct

+ Config *v12.NamespaceConfig

+ FailoverVersion int64

+ IsGlobalNamespace bool

+ NamespaceInfo *v12.NamespaceInfo

+ ReplicationConfig *v1.NamespaceReplicationConfig

+ func (*UpdateNamespaceResponse) Descriptor() ([]byte, []int)

+ func (*UpdateNamespaceResponse) ProtoMessage()

+ func (m *UpdateNamespaceResponse) GetConfig() *v12.NamespaceConfig

+ func (m *UpdateNamespaceResponse) GetFailoverVersion() int64

+ func (m *UpdateNamespaceResponse) GetIsGlobalNamespace() bool

+ func (m *UpdateNamespaceResponse) GetNamespaceInfo() *v12.NamespaceInfo

+ func (m *UpdateNamespaceResponse) GetReplicationConfig() *v1.NamespaceReplicationConfig

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

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

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

+ func (m *UpdateNamespaceResponse) Reset()

+ func (m *UpdateNamespaceResponse) Size() (n int)

+ func (m *UpdateNamespaceResponse) Unmarshal(dAtA []byte) error

+ func (m *UpdateNamespaceResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateNamespaceResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateNamespaceResponse) XXX_Size() int

+ func (m *UpdateNamespaceResponse) XXX_Unmarshal(b []byte) error

+ func (this *UpdateNamespaceResponse) Equal(that interface{}) bool

+ func (this *UpdateNamespaceResponse) GoString() string

+ func (this *UpdateNamespaceResponse) String() string

+ type WorkflowServiceClient interface

+ CountWorkflowExecutions func(ctx context.Context, in *CountWorkflowExecutionsRequest, ...) (*CountWorkflowExecutionsResponse, error)

+ DeprecateNamespace func(ctx context.Context, in *DeprecateNamespaceRequest, opts ...grpc.CallOption) (*DeprecateNamespaceResponse, error)

+ DescribeNamespace func(ctx context.Context, in *DescribeNamespaceRequest, opts ...grpc.CallOption) (*DescribeNamespaceResponse, error)

+ DescribeTaskQueue func(ctx context.Context, in *DescribeTaskQueueRequest, opts ...grpc.CallOption) (*DescribeTaskQueueResponse, error)

+ DescribeWorkflowExecution func(ctx context.Context, in *DescribeWorkflowExecutionRequest, ...) (*DescribeWorkflowExecutionResponse, error)

+ GetClusterInfo func(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)

+ GetSearchAttributes func(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)

+ GetWorkflowExecutionHistory func(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, ...) (*GetWorkflowExecutionHistoryResponse, error)

+ ListArchivedWorkflowExecutions func(ctx context.Context, in *ListArchivedWorkflowExecutionsRequest, ...) (*ListArchivedWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutions func(ctx context.Context, in *ListClosedWorkflowExecutionsRequest, ...) (*ListClosedWorkflowExecutionsResponse, error)

+ ListNamespaces func(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)

+ ListOpenWorkflowExecutions func(ctx context.Context, in *ListOpenWorkflowExecutionsRequest, ...) (*ListOpenWorkflowExecutionsResponse, error)

+ ListTaskQueuePartitions func(ctx context.Context, in *ListTaskQueuePartitionsRequest, ...) (*ListTaskQueuePartitionsResponse, error)

+ ListWorkflowExecutions func(ctx context.Context, in *ListWorkflowExecutionsRequest, ...) (*ListWorkflowExecutionsResponse, error)

+ PollActivityTaskQueue func(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)

+ PollWorkflowTaskQueue func(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)

+ QueryWorkflow func(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)

+ RecordActivityTaskHeartbeat func(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, ...) (*RecordActivityTaskHeartbeatResponse, error)

+ RecordActivityTaskHeartbeatById func(ctx context.Context, in *RecordActivityTaskHeartbeatByIdRequest, ...) (*RecordActivityTaskHeartbeatByIdResponse, error)

+ RegisterNamespace func(ctx context.Context, in *RegisterNamespaceRequest, opts ...grpc.CallOption) (*RegisterNamespaceResponse, error)

+ RequestCancelWorkflowExecution func(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, ...) (*RequestCancelWorkflowExecutionResponse, error)

+ ResetStickyTaskQueue func(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)

+ ResetWorkflowExecution func(ctx context.Context, in *ResetWorkflowExecutionRequest, ...) (*ResetWorkflowExecutionResponse, error)

+ RespondActivityTaskCanceled func(ctx context.Context, in *RespondActivityTaskCanceledRequest, ...) (*RespondActivityTaskCanceledResponse, error)

+ RespondActivityTaskCanceledById func(ctx context.Context, in *RespondActivityTaskCanceledByIdRequest, ...) (*RespondActivityTaskCanceledByIdResponse, error)

+ RespondActivityTaskCompleted func(ctx context.Context, in *RespondActivityTaskCompletedRequest, ...) (*RespondActivityTaskCompletedResponse, error)

+ RespondActivityTaskCompletedById func(ctx context.Context, in *RespondActivityTaskCompletedByIdRequest, ...) (*RespondActivityTaskCompletedByIdResponse, error)

+ RespondActivityTaskFailed func(ctx context.Context, in *RespondActivityTaskFailedRequest, ...) (*RespondActivityTaskFailedResponse, error)

+ RespondActivityTaskFailedById func(ctx context.Context, in *RespondActivityTaskFailedByIdRequest, ...) (*RespondActivityTaskFailedByIdResponse, error)

+ RespondQueryTaskCompleted func(ctx context.Context, in *RespondQueryTaskCompletedRequest, ...) (*RespondQueryTaskCompletedResponse, error)

+ RespondWorkflowTaskCompleted func(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, ...) (*RespondWorkflowTaskCompletedResponse, error)

+ RespondWorkflowTaskFailed func(ctx context.Context, in *RespondWorkflowTaskFailedRequest, ...) (*RespondWorkflowTaskFailedResponse, error)

+ ScanWorkflowExecutions func(ctx context.Context, in *ScanWorkflowExecutionsRequest, ...) (*ScanWorkflowExecutionsResponse, error)

+ SignalWithStartWorkflowExecution func(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, ...) (*SignalWithStartWorkflowExecutionResponse, error)

+ SignalWorkflowExecution func(ctx context.Context, in *SignalWorkflowExecutionRequest, ...) (*SignalWorkflowExecutionResponse, error)

+ StartWorkflowExecution func(ctx context.Context, in *StartWorkflowExecutionRequest, ...) (*StartWorkflowExecutionResponse, error)

+ TerminateWorkflowExecution func(ctx context.Context, in *TerminateWorkflowExecutionRequest, ...) (*TerminateWorkflowExecutionResponse, error)

+ UpdateNamespace func(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)

+ func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

+ type WorkflowServiceServer interface

+ CountWorkflowExecutions func(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

+ DeprecateNamespace func(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)

+ DescribeNamespace func(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)

+ DescribeTaskQueue func(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)

+ DescribeWorkflowExecution func(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

+ GetClusterInfo func(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

+ GetSearchAttributes func(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

+ GetWorkflowExecutionHistory func(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

+ ListArchivedWorkflowExecutions func(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)

+ ListClosedWorkflowExecutions func(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)

+ ListNamespaces func(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)

+ ListOpenWorkflowExecutions func(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)

+ ListTaskQueuePartitions func(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)

+ ListWorkflowExecutions func(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

+ PollActivityTaskQueue func(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)

+ PollWorkflowTaskQueue func(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)

+ QueryWorkflow func(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

+ RecordActivityTaskHeartbeat func(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

+ RecordActivityTaskHeartbeatById func(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)

+ RegisterNamespace func(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)

+ RequestCancelWorkflowExecution func(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

+ ResetStickyTaskQueue func(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)

+ ResetWorkflowExecution func(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

+ RespondActivityTaskCanceled func(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

+ RespondActivityTaskCanceledById func(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)

+ RespondActivityTaskCompleted func(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

+ RespondActivityTaskCompletedById func(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)

+ RespondActivityTaskFailed func(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

+ RespondActivityTaskFailedById func(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)

+ RespondQueryTaskCompleted func(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

+ RespondWorkflowTaskCompleted func(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)

+ RespondWorkflowTaskFailed func(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)

+ ScanWorkflowExecutions func(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)

+ SignalWithStartWorkflowExecution func(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

+ SignalWorkflowExecution func(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

+ StartWorkflowExecution func(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

+ TerminateWorkflowExecution func(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

+ UpdateNamespace func(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

Other modules containing this package

github.com/temporalio/ui-server/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL