workflowservice

package

Go to main page

Versions in this module

v0

v0.15.1

Jun 1, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.15.0

May 25, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.14.1

May 16, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.14.0

May 16, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.13.2

May 12, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

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 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.13.0

May 5, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.12.2

May 4, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.12.1

Apr 29, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.12.0

Apr 28, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.11.0

Apr 26, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.6

Apr 22, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.5

Apr 22, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.4

Apr 21, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.3

Apr 20, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.2

Apr 14, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.1

Apr 13, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.10.0

Apr 13, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.9.0

Apr 7, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.8.0

Mar 29, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

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 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.6.0

Mar 21, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.5.0

Mar 16, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.4.0

Mar 11, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.3.0

Feb 28, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.2.0

Jan 29, 2022 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

v0.1.0

Oct 27, 2021 GO-2024-2675

GO-2024-2675: Temporal UI Server cross-site scripting vulnerability in github.com/temporalio/ui-server

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