schedule

package
v1.36.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_server_api_schedule_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BufferedStart 

type BufferedStart struct {

	// Nominal (pre-jitter) and Actual (post-jitter) time of action
	NominalTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=nominal_time,json=nominalTime,proto3" json:"nominal_time,omitempty"`
	ActualTime  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=actual_time,json=actualTime,proto3" json:"actual_time,omitempty"`
	// Desired time is usually nil, which should be interpreted as == actual time, but for starts
	// that are blocked behind another action, it is set to the close time of the previous action
	// for more meaningful metrics.
	DesiredTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=desired_time,json=desiredTime,proto3" json:"desired_time,omitempty"`
	// Overridden overlap policy
	OverlapPolicy v1.ScheduleOverlapPolicy `` /* 150-byte string literal not displayed */
	// Trigger-immediately or backfill
	Manual bool `protobuf:"varint,4,opt,name=manual,proto3" json:"manual,omitempty"`
	// An ID generated when the action is buffered for deduplication during
	// execution. Only used by the CHASM scheduler (otherwise left empty).
	RequestId string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Initially 0. Once a BufferedStart is ready to execute (overlap policies
	// are resolved), its attempt count is set to 1. If a BufferedStart fails
	// execution, its attempt count here is incremented. Only used by the CHASM
	// scheduler (otherwise left empty).
	Attempt int64 `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// If a BufferedStart is rate limited or needs to backoff while retrying,
	// this time will be set, and the start will be held in the buffer until
	// the backoff time has passed. Only used by the CHASM scheduler (otherwise
	// ignored).
	BackoffTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=backoff_time,json=backoffTime,proto3" json:"backoff_time,omitempty"`
	// The precomputed workflow ID that should be used (as-is) when executing
	// this start. Only used by the CHASM scheduler (otherwise ignored).
	WorkflowId string `protobuf:"bytes,9,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// The run ID of the started workflow. Populated when the workflow is
	// successfully started. Only used by the CHASM scheduler.
	RunId string `protobuf:"bytes,10,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// The actual time the workflow was started. Populated when the workflow is
	// successfully started. Only used by the CHASM scheduler.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Populated when the workflow execution completes. Presence indicates the
	// action is complete and retained for history. Only used by the CHASM scheduler.
	Completed *CompletedResult `protobuf:"bytes,12,opt,name=completed,proto3" json:"completed,omitempty"`
	// contains filtered or unexported fields
}

func (*BufferedStart) Descriptor deprecated 

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

Deprecated: Use BufferedStart.ProtoReflect.Descriptor instead.

func (*BufferedStart) Equal 

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

Equal returns whether two BufferedStart values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*BufferedStart) GetActualTime 

func (x *BufferedStart) GetActualTime() *timestamppb.Timestamp

func (*BufferedStart) GetAttempt 

func (x *BufferedStart) GetAttempt() int64

func (*BufferedStart) GetBackoffTime 

func (x *BufferedStart) GetBackoffTime() *timestamppb.Timestamp

func (*BufferedStart) GetCompleted 

func (x *BufferedStart) GetCompleted() *CompletedResult

func (*BufferedStart) GetDesiredTime 

func (x *BufferedStart) GetDesiredTime() *timestamppb.Timestamp

func (*BufferedStart) GetManual 

func (x *BufferedStart) GetManual() bool

func (*BufferedStart) GetNominalTime 

func (x *BufferedStart) GetNominalTime() *timestamppb.Timestamp

func (*BufferedStart) GetOverlapPolicy 

func (x *BufferedStart) GetOverlapPolicy() v1.ScheduleOverlapPolicy

func (*BufferedStart) GetRequestId 

func (x *BufferedStart) GetRequestId() string

func (*BufferedStart) GetRunId 

func (x *BufferedStart) GetRunId() string

func (*BufferedStart) GetStartTime 

func (x *BufferedStart) GetStartTime() *timestamppb.Timestamp

func (*BufferedStart) GetWorkflowId 

func (x *BufferedStart) GetWorkflowId() string

func (*BufferedStart) Marshal 

func (val *BufferedStart) Marshal() ([]byte, error)

Marshal an object of type BufferedStart to the protobuf v3 wire format

func (*BufferedStart) ProtoMessage 

func (*BufferedStart) ProtoMessage()

func (*BufferedStart) ProtoReflect 

func (x *BufferedStart) ProtoReflect() protoreflect.Message

func (*BufferedStart) Reset 

func (x *BufferedStart) Reset()

func (*BufferedStart) Size 

func (val *BufferedStart) Size() int

Size returns the size of the object, in bytes, once serialized

func (*BufferedStart) String 

func (x *BufferedStart) String() string

func (*BufferedStart) Unmarshal 

func (val *BufferedStart) Unmarshal(buf []byte) error

Unmarshal an object of type BufferedStart from the protobuf v3 wire format

type CancelWorkflowRequest 

type CancelWorkflowRequest struct {
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Identity  string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// Note: run id in execution is first execution run id
	Execution *v12.WorkflowExecution `protobuf:"bytes,5,opt,name=execution,proto3" json:"execution,omitempty"`
	Reason    string                 `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use CancelWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CancelWorkflowRequest) Equal 

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

Equal returns whether two CancelWorkflowRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelWorkflowRequest) GetExecution 

func (x *CancelWorkflowRequest) GetExecution() *v12.WorkflowExecution

func (*CancelWorkflowRequest) GetIdentity 

func (x *CancelWorkflowRequest) GetIdentity() string

func (*CancelWorkflowRequest) GetReason 

func (x *CancelWorkflowRequest) GetReason() string

func (*CancelWorkflowRequest) GetRequestId 

func (x *CancelWorkflowRequest) GetRequestId() string

func (*CancelWorkflowRequest) Marshal 

func (val *CancelWorkflowRequest) Marshal() ([]byte, error)

Marshal an object of type CancelWorkflowRequest to the protobuf v3 wire format

func (*CancelWorkflowRequest) ProtoMessage 

func (*CancelWorkflowRequest) ProtoMessage()

func (*CancelWorkflowRequest) ProtoReflect 

func (x *CancelWorkflowRequest) ProtoReflect() protoreflect.Message

func (*CancelWorkflowRequest) Reset 

func (x *CancelWorkflowRequest) Reset()

func (*CancelWorkflowRequest) Size 

func (val *CancelWorkflowRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelWorkflowRequest) String 

func (x *CancelWorkflowRequest) String() string

func (*CancelWorkflowRequest) Unmarshal 

func (val *CancelWorkflowRequest) Unmarshal(buf []byte) error

Unmarshal an object of type CancelWorkflowRequest from the protobuf v3 wire format

type CompletedResult 

type CompletedResult struct {

	// The final status of the workflow execution.
	Status v1.WorkflowExecutionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	// The time the workflow closed.
	CloseTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	// contains filtered or unexported fields
}

Result when a workflow execution has completed. Only used by the CHASM scheduler.

func (*CompletedResult) Descriptor deprecated 

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

Deprecated: Use CompletedResult.ProtoReflect.Descriptor instead.

func (*CompletedResult) Equal 

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

Equal returns whether two CompletedResult values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CompletedResult) GetCloseTime 

func (x *CompletedResult) GetCloseTime() *timestamppb.Timestamp

func (*CompletedResult) GetStatus 

func (x *CompletedResult) GetStatus() v1.WorkflowExecutionStatus

func (*CompletedResult) Marshal 

func (val *CompletedResult) Marshal() ([]byte, error)

Marshal an object of type CompletedResult to the protobuf v3 wire format

func (*CompletedResult) ProtoMessage 

func (*CompletedResult) ProtoMessage()

func (*CompletedResult) ProtoReflect 

func (x *CompletedResult) ProtoReflect() protoreflect.Message

func (*CompletedResult) Reset 

func (x *CompletedResult) Reset()

func (*CompletedResult) Size 

func (val *CompletedResult) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CompletedResult) String 

func (x *CompletedResult) String() string

func (*CompletedResult) Unmarshal 

func (val *CompletedResult) Unmarshal(buf []byte) error

Unmarshal an object of type CompletedResult from the protobuf v3 wire format

type DescribeResponse 

type DescribeResponse struct {
	Schedule      *v11.Schedule     `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Info          *v11.ScheduleInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	ConflictToken int64             `protobuf:"varint,3,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeResponse) Descriptor deprecated 

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

Deprecated: Use DescribeResponse.ProtoReflect.Descriptor instead.

func (*DescribeResponse) Equal 

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

Equal returns whether two DescribeResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeResponse) GetConflictToken 

func (x *DescribeResponse) GetConflictToken() int64

func (*DescribeResponse) GetInfo 

func (x *DescribeResponse) GetInfo() *v11.ScheduleInfo

func (*DescribeResponse) GetSchedule 

func (x *DescribeResponse) GetSchedule() *v11.Schedule

func (*DescribeResponse) Marshal 

func (val *DescribeResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeResponse to the protobuf v3 wire format

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) ProtoReflect 

func (x *DescribeResponse) ProtoReflect() protoreflect.Message

func (*DescribeResponse) Reset 

func (x *DescribeResponse) Reset()

func (*DescribeResponse) Size 

func (val *DescribeResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeResponse) String 

func (x *DescribeResponse) String() string

func (*DescribeResponse) Unmarshal 

func (val *DescribeResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeResponse from the protobuf v3 wire format

type FullUpdateRequest 

type FullUpdateRequest struct {
	Schedule         *v11.Schedule         `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	ConflictToken    int64                 `protobuf:"varint,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	SearchAttributes *v12.SearchAttributes `protobuf:"bytes,3,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*FullUpdateRequest) Descriptor deprecated 

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

Deprecated: Use FullUpdateRequest.ProtoReflect.Descriptor instead.

func (*FullUpdateRequest) Equal 

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

Equal returns whether two FullUpdateRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*FullUpdateRequest) GetConflictToken 

func (x *FullUpdateRequest) GetConflictToken() int64

func (*FullUpdateRequest) GetSchedule 

func (x *FullUpdateRequest) GetSchedule() *v11.Schedule

func (*FullUpdateRequest) GetSearchAttributes 

func (x *FullUpdateRequest) GetSearchAttributes() *v12.SearchAttributes

func (*FullUpdateRequest) Marshal 

func (val *FullUpdateRequest) Marshal() ([]byte, error)

Marshal an object of type FullUpdateRequest to the protobuf v3 wire format

func (*FullUpdateRequest) ProtoMessage 

func (*FullUpdateRequest) ProtoMessage()

func (*FullUpdateRequest) ProtoReflect 

func (x *FullUpdateRequest) ProtoReflect() protoreflect.Message

func (*FullUpdateRequest) Reset 

func (x *FullUpdateRequest) Reset()

func (*FullUpdateRequest) Size 

func (val *FullUpdateRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*FullUpdateRequest) String 

func (x *FullUpdateRequest) String() string

func (*FullUpdateRequest) Unmarshal 

func (val *FullUpdateRequest) Unmarshal(buf []byte) error

Unmarshal an object of type FullUpdateRequest from the protobuf v3 wire format

type InternalState 

type InternalState struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NamespaceId       string                 `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ScheduleId        string                 `protobuf:"bytes,8,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	LastProcessedTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_processed_time,json=lastProcessedTime,proto3" json:"last_processed_time,omitempty"`
	BufferedStarts    []*BufferedStart       `protobuf:"bytes,4,rep,name=buffered_starts,json=bufferedStarts,proto3" json:"buffered_starts,omitempty"`
	OngoingBackfills  []*v11.BackfillRequest `protobuf:"bytes,10,rep,name=ongoing_backfills,json=ongoingBackfills,proto3" json:"ongoing_backfills,omitempty"`
	// last completion/failure
	LastCompletionResult *v12.Payloads `protobuf:"bytes,5,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"`
	ContinuedFailure     *v13.Failure  `protobuf:"bytes,6,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"`
	// conflict token is implemented as simple sequence number
	ConflictToken    int64 `protobuf:"varint,7,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	NeedRefresh      bool  `protobuf:"varint,9,opt,name=need_refresh,json=needRefresh,proto3" json:"need_refresh,omitempty"`
	PendingMigration bool  `protobuf:"varint,11,opt,name=pending_migration,json=pendingMigration,proto3" json:"pending_migration,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalState) Descriptor deprecated 

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

Deprecated: Use InternalState.ProtoReflect.Descriptor instead.

func (*InternalState) Equal 

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

Equal returns whether two InternalState values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*InternalState) GetBufferedStarts 

func (x *InternalState) GetBufferedStarts() []*BufferedStart

func (*InternalState) GetConflictToken 

func (x *InternalState) GetConflictToken() int64

func (*InternalState) GetContinuedFailure 

func (x *InternalState) GetContinuedFailure() *v13.Failure

func (*InternalState) GetLastCompletionResult 

func (x *InternalState) GetLastCompletionResult() *v12.Payloads

func (*InternalState) GetLastProcessedTime 

func (x *InternalState) GetLastProcessedTime() *timestamppb.Timestamp

func (*InternalState) GetNamespace 

func (x *InternalState) GetNamespace() string

func (*InternalState) GetNamespaceId 

func (x *InternalState) GetNamespaceId() string

func (*InternalState) GetNeedRefresh 

func (x *InternalState) GetNeedRefresh() bool

func (*InternalState) GetOngoingBackfills 

func (x *InternalState) GetOngoingBackfills() []*v11.BackfillRequest

func (*InternalState) GetPendingMigration 

func (x *InternalState) GetPendingMigration() bool

func (*InternalState) GetScheduleId 

func (x *InternalState) GetScheduleId() string

func (*InternalState) Marshal 

func (val *InternalState) Marshal() ([]byte, error)

Marshal an object of type InternalState to the protobuf v3 wire format

func (*InternalState) ProtoMessage 

func (*InternalState) ProtoMessage()

func (*InternalState) ProtoReflect 

func (x *InternalState) ProtoReflect() protoreflect.Message

func (*InternalState) Reset 

func (x *InternalState) Reset()

func (*InternalState) Size 

func (val *InternalState) Size() int

Size returns the size of the object, in bytes, once serialized

func (*InternalState) String 

func (x *InternalState) String() string

func (*InternalState) Unmarshal 

func (val *InternalState) Unmarshal(buf []byte) error

Unmarshal an object of type InternalState from the protobuf v3 wire format

type NextTimeCache 

type NextTimeCache struct {

	// workflow logic version (invalidate when changed)
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// start time that the results were calculated from
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// next_times and nominal_times are a series of timestamp pairs, encoded as a nanosecond
	// offset from start_time. next_times has one value for each time in the cache.
	// nominal_times may have up to the same number of values, but it may also be shorter (or
	// empty), if the corresponding nominal time is equal to the next time.
	NextTimes    []int64 `protobuf:"varint,3,rep,packed,name=next_times,json=nextTimes,proto3" json:"next_times,omitempty"`
	NominalTimes []int64 `protobuf:"varint,4,rep,packed,name=nominal_times,json=nominalTimes,proto3" json:"nominal_times,omitempty"`
	Completed    bool    `protobuf:"varint,5,opt,name=completed,proto3" json:"completed,omitempty"`
	// contains filtered or unexported fields
}

func (*NextTimeCache) Descriptor deprecated 

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

Deprecated: Use NextTimeCache.ProtoReflect.Descriptor instead.

func (*NextTimeCache) Equal 

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

Equal returns whether two NextTimeCache values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NextTimeCache) GetCompleted 

func (x *NextTimeCache) GetCompleted() bool

func (*NextTimeCache) GetNextTimes 

func (x *NextTimeCache) GetNextTimes() []int64

func (*NextTimeCache) GetNominalTimes 

func (x *NextTimeCache) GetNominalTimes() []int64

func (*NextTimeCache) GetStartTime 

func (x *NextTimeCache) GetStartTime() *timestamppb.Timestamp

func (*NextTimeCache) GetVersion 

func (x *NextTimeCache) GetVersion() int64

func (*NextTimeCache) Marshal 

func (val *NextTimeCache) Marshal() ([]byte, error)

Marshal an object of type NextTimeCache to the protobuf v3 wire format

func (*NextTimeCache) ProtoMessage 

func (*NextTimeCache) ProtoMessage()

func (*NextTimeCache) ProtoReflect 

func (x *NextTimeCache) ProtoReflect() protoreflect.Message

func (*NextTimeCache) Reset 

func (x *NextTimeCache) Reset()

func (*NextTimeCache) Size 

func (val *NextTimeCache) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NextTimeCache) String 

func (x *NextTimeCache) String() string

func (*NextTimeCache) Unmarshal 

func (val *NextTimeCache) Unmarshal(buf []byte) error

Unmarshal an object of type NextTimeCache from the protobuf v3 wire format

type StartScheduleArgs 

type StartScheduleArgs struct {
	Schedule     *v11.Schedule      `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Info         *v11.ScheduleInfo  `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	InitialPatch *v11.SchedulePatch `protobuf:"bytes,3,opt,name=initial_patch,json=initialPatch,proto3" json:"initial_patch,omitempty"`
	State        *InternalState     `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*StartScheduleArgs) Descriptor deprecated 

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

Deprecated: Use StartScheduleArgs.ProtoReflect.Descriptor instead.

func (*StartScheduleArgs) Equal 

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

Equal returns whether two StartScheduleArgs values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartScheduleArgs) GetInfo 

func (x *StartScheduleArgs) GetInfo() *v11.ScheduleInfo

func (*StartScheduleArgs) GetInitialPatch 

func (x *StartScheduleArgs) GetInitialPatch() *v11.SchedulePatch

func (*StartScheduleArgs) GetSchedule 

func (x *StartScheduleArgs) GetSchedule() *v11.Schedule

func (*StartScheduleArgs) GetState 

func (x *StartScheduleArgs) GetState() *InternalState

func (*StartScheduleArgs) Marshal 

func (val *StartScheduleArgs) Marshal() ([]byte, error)

Marshal an object of type StartScheduleArgs to the protobuf v3 wire format

func (*StartScheduleArgs) ProtoMessage 

func (*StartScheduleArgs) ProtoMessage()

func (*StartScheduleArgs) ProtoReflect 

func (x *StartScheduleArgs) ProtoReflect() protoreflect.Message

func (*StartScheduleArgs) Reset 

func (x *StartScheduleArgs) Reset()

func (*StartScheduleArgs) Size 

func (val *StartScheduleArgs) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartScheduleArgs) String 

func (x *StartScheduleArgs) String() string

func (*StartScheduleArgs) Unmarshal 

func (val *StartScheduleArgs) Unmarshal(buf []byte) error

Unmarshal an object of type StartScheduleArgs from the protobuf v3 wire format

type StartWorkflowRequest 

type StartWorkflowRequest struct {
	Request                 *v14.StartWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	CompletedRateLimitSleep bool                               `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowRequest) Equal 

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

Equal returns whether two StartWorkflowRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartWorkflowRequest) GetCompletedRateLimitSleep 

func (x *StartWorkflowRequest) GetCompletedRateLimitSleep() bool

func (*StartWorkflowRequest) GetRequest 

func (x *StartWorkflowRequest) GetRequest() *v14.StartWorkflowExecutionRequest

func (*StartWorkflowRequest) Marshal 

func (val *StartWorkflowRequest) Marshal() ([]byte, error)

Marshal an object of type StartWorkflowRequest to the protobuf v3 wire format

func (*StartWorkflowRequest) ProtoMessage 

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) ProtoReflect 

func (x *StartWorkflowRequest) ProtoReflect() protoreflect.Message

func (*StartWorkflowRequest) Reset 

func (x *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) Size 

func (val *StartWorkflowRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartWorkflowRequest) String 

func (x *StartWorkflowRequest) String() string

func (*StartWorkflowRequest) Unmarshal 

func (val *StartWorkflowRequest) Unmarshal(buf []byte) error

Unmarshal an object of type StartWorkflowRequest from the protobuf v3 wire format

type StartWorkflowResponse 

type StartWorkflowResponse struct {
	RunId         string                 `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	RealStartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=real_start_time,json=realStartTime,proto3" json:"real_start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use StartWorkflowResponse.ProtoReflect.Descriptor instead.

func (*StartWorkflowResponse) Equal 

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

Equal returns whether two StartWorkflowResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartWorkflowResponse) GetRealStartTime 

func (x *StartWorkflowResponse) GetRealStartTime() *timestamppb.Timestamp

func (*StartWorkflowResponse) GetRunId 

func (x *StartWorkflowResponse) GetRunId() string

func (*StartWorkflowResponse) Marshal 

func (val *StartWorkflowResponse) Marshal() ([]byte, error)

Marshal an object of type StartWorkflowResponse to the protobuf v3 wire format

func (*StartWorkflowResponse) ProtoMessage 

func (*StartWorkflowResponse) ProtoMessage()

func (*StartWorkflowResponse) ProtoReflect 

func (x *StartWorkflowResponse) ProtoReflect() protoreflect.Message

func (*StartWorkflowResponse) Reset 

func (x *StartWorkflowResponse) Reset()

func (*StartWorkflowResponse) Size 

func (val *StartWorkflowResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartWorkflowResponse) String 

func (x *StartWorkflowResponse) String() string

func (*StartWorkflowResponse) Unmarshal 

func (val *StartWorkflowResponse) Unmarshal(buf []byte) error

Unmarshal an object of type StartWorkflowResponse from the protobuf v3 wire format

type TerminateWorkflowRequest 

type TerminateWorkflowRequest struct {
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Identity  string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// Note: run id in execution is first execution run id
	Execution *v12.WorkflowExecution `protobuf:"bytes,5,opt,name=execution,proto3" json:"execution,omitempty"`
	Reason    string                 `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use TerminateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowRequest) Equal 

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

Equal returns whether two TerminateWorkflowRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TerminateWorkflowRequest) GetExecution 

func (x *TerminateWorkflowRequest) GetExecution() *v12.WorkflowExecution

func (*TerminateWorkflowRequest) GetIdentity 

func (x *TerminateWorkflowRequest) GetIdentity() string

func (*TerminateWorkflowRequest) GetReason 

func (x *TerminateWorkflowRequest) GetReason() string

func (*TerminateWorkflowRequest) GetRequestId 

func (x *TerminateWorkflowRequest) GetRequestId() string

func (*TerminateWorkflowRequest) Marshal 

func (val *TerminateWorkflowRequest) Marshal() ([]byte, error)

Marshal an object of type TerminateWorkflowRequest to the protobuf v3 wire format

func (*TerminateWorkflowRequest) ProtoMessage 

func (*TerminateWorkflowRequest) ProtoMessage()

func (*TerminateWorkflowRequest) ProtoReflect 

func (x *TerminateWorkflowRequest) ProtoReflect() protoreflect.Message

func (*TerminateWorkflowRequest) Reset 

func (x *TerminateWorkflowRequest) Reset()

func (*TerminateWorkflowRequest) Size 

func (val *TerminateWorkflowRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TerminateWorkflowRequest) String 

func (x *TerminateWorkflowRequest) String() string

func (*TerminateWorkflowRequest) Unmarshal 

func (val *TerminateWorkflowRequest) Unmarshal(buf []byte) error

Unmarshal an object of type TerminateWorkflowRequest from the protobuf v3 wire format

type WatchWorkflowRequest 

type WatchWorkflowRequest struct {

	// Note: this will be sent to the activity with empty execution.run_id, and
	// the run id that we started in first_execution_run_id.
	Execution           *v12.WorkflowExecution `protobuf:"bytes,3,opt,name=execution,proto3" json:"execution,omitempty"`
	FirstExecutionRunId string                 `protobuf:"bytes,4,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	LongPoll            bool                   `protobuf:"varint,5,opt,name=long_poll,json=longPoll,proto3" json:"long_poll,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use WatchWorkflowRequest.ProtoReflect.Descriptor instead.

func (*WatchWorkflowRequest) Equal 

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

Equal returns whether two WatchWorkflowRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WatchWorkflowRequest) GetExecution 

func (x *WatchWorkflowRequest) GetExecution() *v12.WorkflowExecution

func (*WatchWorkflowRequest) GetFirstExecutionRunId 

func (x *WatchWorkflowRequest) GetFirstExecutionRunId() string

func (*WatchWorkflowRequest) GetLongPoll 

func (x *WatchWorkflowRequest) GetLongPoll() bool

func (*WatchWorkflowRequest) Marshal 

func (val *WatchWorkflowRequest) Marshal() ([]byte, error)

Marshal an object of type WatchWorkflowRequest to the protobuf v3 wire format

func (*WatchWorkflowRequest) ProtoMessage 

func (*WatchWorkflowRequest) ProtoMessage()

func (*WatchWorkflowRequest) ProtoReflect 

func (x *WatchWorkflowRequest) ProtoReflect() protoreflect.Message

func (*WatchWorkflowRequest) Reset 

func (x *WatchWorkflowRequest) Reset()

func (*WatchWorkflowRequest) Size 

func (val *WatchWorkflowRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WatchWorkflowRequest) String 

func (x *WatchWorkflowRequest) String() string

func (*WatchWorkflowRequest) Unmarshal 

func (val *WatchWorkflowRequest) Unmarshal(buf []byte) error

Unmarshal an object of type WatchWorkflowRequest from the protobuf v3 wire format

type WatchWorkflowResponse 

type WatchWorkflowResponse struct {
	Status v1.WorkflowExecutionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	// Types that are valid to be assigned to ResultFailure:
	//
	//	*WatchWorkflowResponse_Result
	//	*WatchWorkflowResponse_Failure
	ResultFailure isWatchWorkflowResponse_ResultFailure `protobuf_oneof:"result_failure"`
	// Timestamp of close event
	CloseTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use WatchWorkflowResponse.ProtoReflect.Descriptor instead.

func (*WatchWorkflowResponse) Equal 

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

Equal returns whether two WatchWorkflowResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WatchWorkflowResponse) GetCloseTime 

func (x *WatchWorkflowResponse) GetCloseTime() *timestamppb.Timestamp

func (*WatchWorkflowResponse) GetFailure 

func (x *WatchWorkflowResponse) GetFailure() *v13.Failure

func (*WatchWorkflowResponse) GetResult 

func (x *WatchWorkflowResponse) GetResult() *v12.Payloads

func (*WatchWorkflowResponse) GetResultFailure 

func (x *WatchWorkflowResponse) GetResultFailure() isWatchWorkflowResponse_ResultFailure

func (*WatchWorkflowResponse) GetStatus 

func (x *WatchWorkflowResponse) GetStatus() v1.WorkflowExecutionStatus

func (*WatchWorkflowResponse) Marshal 

func (val *WatchWorkflowResponse) Marshal() ([]byte, error)

Marshal an object of type WatchWorkflowResponse to the protobuf v3 wire format

func (*WatchWorkflowResponse) ProtoMessage 

func (*WatchWorkflowResponse) ProtoMessage()

func (*WatchWorkflowResponse) ProtoReflect 

func (x *WatchWorkflowResponse) ProtoReflect() protoreflect.Message

func (*WatchWorkflowResponse) Reset 

func (x *WatchWorkflowResponse) Reset()

func (*WatchWorkflowResponse) Size 

func (val *WatchWorkflowResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WatchWorkflowResponse) String 

func (x *WatchWorkflowResponse) String() string

func (*WatchWorkflowResponse) Unmarshal 

func (val *WatchWorkflowResponse) Unmarshal(buf []byte) error

Unmarshal an object of type WatchWorkflowResponse from the protobuf v3 wire format

type WatchWorkflowResponse_Failure 

type WatchWorkflowResponse_Failure struct {
	Failure *v13.Failure `protobuf:"bytes,3,opt,name=failure,proto3,oneof"`
}

type WatchWorkflowResponse_Result 

type WatchWorkflowResponse_Result struct {
	Result *v12.Payloads `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.