Documentation
¶
Overview ¶
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Index ¶
- Variables
- type AddVersionToWorkerDeploymentRequest
- func (*AddVersionToWorkerDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (this *AddVersionToWorkerDeploymentRequest) Equal(that interface{}) bool
- func (x *AddVersionToWorkerDeploymentRequest) GetDeploymentName() string
- func (x *AddVersionToWorkerDeploymentRequest) GetRequestId() string
- func (x *AddVersionToWorkerDeploymentRequest) GetUpdateArgs() *AddVersionUpdateArgs
- func (val *AddVersionToWorkerDeploymentRequest) Marshal() ([]byte, error)
- func (*AddVersionToWorkerDeploymentRequest) ProtoMessage()
- func (x *AddVersionToWorkerDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *AddVersionToWorkerDeploymentRequest) Reset()
- func (val *AddVersionToWorkerDeploymentRequest) Size() int
- func (x *AddVersionToWorkerDeploymentRequest) String() string
- func (val *AddVersionToWorkerDeploymentRequest) Unmarshal(buf []byte) error
- type AddVersionToWorkerDeploymentResponse
- func (*AddVersionToWorkerDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (this *AddVersionToWorkerDeploymentResponse) Equal(that interface{}) bool
- func (val *AddVersionToWorkerDeploymentResponse) Marshal() ([]byte, error)
- func (*AddVersionToWorkerDeploymentResponse) ProtoMessage()
- func (x *AddVersionToWorkerDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *AddVersionToWorkerDeploymentResponse) Reset()
- func (val *AddVersionToWorkerDeploymentResponse) Size() int
- func (x *AddVersionToWorkerDeploymentResponse) String() string
- func (val *AddVersionToWorkerDeploymentResponse) Unmarshal(buf []byte) error
- type AddVersionUpdateArgs
- func (*AddVersionUpdateArgs) Descriptor() ([]byte, []int)deprecated
- func (this *AddVersionUpdateArgs) Equal(that interface{}) bool
- func (x *AddVersionUpdateArgs) GetCreateTime() *timestamppb.Timestamp
- func (x *AddVersionUpdateArgs) GetVersion() string
- func (val *AddVersionUpdateArgs) Marshal() ([]byte, error)
- func (*AddVersionUpdateArgs) ProtoMessage()
- func (x *AddVersionUpdateArgs) ProtoReflect() protoreflect.Message
- func (x *AddVersionUpdateArgs) Reset()
- func (val *AddVersionUpdateArgs) Size() int
- func (x *AddVersionUpdateArgs) String() string
- func (val *AddVersionUpdateArgs) Unmarshal(buf []byte) error
- type CheckTaskQueuesHavePollersActivityArgs
- func (*CheckTaskQueuesHavePollersActivityArgs) Descriptor() ([]byte, []int)deprecated
- func (this *CheckTaskQueuesHavePollersActivityArgs) Equal(that interface{}) bool
- func (x *CheckTaskQueuesHavePollersActivityArgs) GetTaskQueuesAndTypes() map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes
- func (x *CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion() *WorkerDeploymentVersion
- func (val *CheckTaskQueuesHavePollersActivityArgs) Marshal() ([]byte, error)
- func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage()
- func (x *CheckTaskQueuesHavePollersActivityArgs) ProtoReflect() protoreflect.Message
- func (x *CheckTaskQueuesHavePollersActivityArgs) Reset()
- func (val *CheckTaskQueuesHavePollersActivityArgs) Size() int
- func (x *CheckTaskQueuesHavePollersActivityArgs) String() string
- func (val *CheckTaskQueuesHavePollersActivityArgs) Unmarshal(buf []byte) error
- type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes
- func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Descriptor() ([]byte, []int)deprecated
- func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes() []v11.TaskQueueType
- func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage()
- func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoReflect() protoreflect.Message
- func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset()
- func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String() string
- type CheckUserDataPropagationRequest
- func (*CheckUserDataPropagationRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CheckUserDataPropagationRequest) Equal(that interface{}) bool
- func (x *CheckUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64
- func (val *CheckUserDataPropagationRequest) Marshal() ([]byte, error)
- func (*CheckUserDataPropagationRequest) ProtoMessage()
- func (x *CheckUserDataPropagationRequest) ProtoReflect() protoreflect.Message
- func (x *CheckUserDataPropagationRequest) Reset()
- func (val *CheckUserDataPropagationRequest) Size() int
- func (x *CheckUserDataPropagationRequest) String() string
- func (val *CheckUserDataPropagationRequest) Unmarshal(buf []byte) error
- type CheckWorkerDeploymentUserDataPropagationRequest
- func (*CheckWorkerDeploymentUserDataPropagationRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CheckWorkerDeploymentUserDataPropagationRequest) Equal(that interface{}) bool
- func (x *CheckWorkerDeploymentUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64
- func (val *CheckWorkerDeploymentUserDataPropagationRequest) Marshal() ([]byte, error)
- func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage()
- func (x *CheckWorkerDeploymentUserDataPropagationRequest) ProtoReflect() protoreflect.Message
- func (x *CheckWorkerDeploymentUserDataPropagationRequest) Reset()
- func (val *CheckWorkerDeploymentUserDataPropagationRequest) Size() int
- func (x *CheckWorkerDeploymentUserDataPropagationRequest) String() string
- func (val *CheckWorkerDeploymentUserDataPropagationRequest) Unmarshal(buf []byte) error
- type DeleteDeploymentArgs
- func (*DeleteDeploymentArgs) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteDeploymentArgs) Equal(that interface{}) bool
- func (x *DeleteDeploymentArgs) GetIdentity() string
- func (val *DeleteDeploymentArgs) Marshal() ([]byte, error)
- func (*DeleteDeploymentArgs) ProtoMessage()
- func (x *DeleteDeploymentArgs) ProtoReflect() protoreflect.Message
- func (x *DeleteDeploymentArgs) Reset()
- func (val *DeleteDeploymentArgs) Size() int
- func (x *DeleteDeploymentArgs) String() string
- func (val *DeleteDeploymentArgs) Unmarshal(buf []byte) error
- type DeleteVersionActivityArgs
- func (*DeleteVersionActivityArgs) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteVersionActivityArgs) Equal(that interface{}) bool
- func (x *DeleteVersionActivityArgs) GetDeploymentName() string
- func (x *DeleteVersionActivityArgs) GetIdentity() string
- func (x *DeleteVersionActivityArgs) GetRequestId() string
- func (x *DeleteVersionActivityArgs) GetSkipDrainage() bool
- func (x *DeleteVersionActivityArgs) GetVersion() string
- func (val *DeleteVersionActivityArgs) Marshal() ([]byte, error)
- func (*DeleteVersionActivityArgs) ProtoMessage()
- func (x *DeleteVersionActivityArgs) ProtoReflect() protoreflect.Message
- func (x *DeleteVersionActivityArgs) Reset()
- func (val *DeleteVersionActivityArgs) Size() int
- func (x *DeleteVersionActivityArgs) String() string
- func (val *DeleteVersionActivityArgs) Unmarshal(buf []byte) error
- type DeleteVersionArgs
- func (*DeleteVersionArgs) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteVersionArgs) Equal(that interface{}) bool
- func (x *DeleteVersionArgs) GetIdentity() string
- func (x *DeleteVersionArgs) GetSkipDrainage() bool
- func (x *DeleteVersionArgs) GetVersion() string
- func (val *DeleteVersionArgs) Marshal() ([]byte, error)
- func (*DeleteVersionArgs) ProtoMessage()
- func (x *DeleteVersionArgs) ProtoReflect() protoreflect.Message
- func (x *DeleteVersionArgs) Reset()
- func (val *DeleteVersionArgs) Size() int
- func (x *DeleteVersionArgs) String() string
- func (val *DeleteVersionArgs) Unmarshal(buf []byte) error
- type DeploymentLocalState
- func (*DeploymentLocalState) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentLocalState) Equal(that interface{}) bool
- func (x *DeploymentLocalState) GetCreateTime() *timestamppb.Timestamp
- func (x *DeploymentLocalState) GetDeployment() *v1.Deployment
- func (x *DeploymentLocalState) GetIsCurrent() bool
- func (x *DeploymentLocalState) GetLastBecameCurrentTime() *timestamppb.Timestamp
- func (x *DeploymentLocalState) GetMetadata() map[string]*v12.Payload
- func (x *DeploymentLocalState) GetStartedSeriesWorkflow() bool
- func (x *DeploymentLocalState) GetTaskQueueFamilies() map[string]*DeploymentLocalState_TaskQueueFamilyData
- func (val *DeploymentLocalState) Marshal() ([]byte, error)
- func (*DeploymentLocalState) ProtoMessage()
- func (x *DeploymentLocalState) ProtoReflect() protoreflect.Message
- func (x *DeploymentLocalState) Reset()
- func (val *DeploymentLocalState) Size() int
- func (x *DeploymentLocalState) String() string
- func (val *DeploymentLocalState) Unmarshal(buf []byte) error
- type DeploymentLocalState_TaskQueueFamilyData
- func (*DeploymentLocalState_TaskQueueFamilyData) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueData
- func (*DeploymentLocalState_TaskQueueFamilyData) ProtoMessage()
- func (x *DeploymentLocalState_TaskQueueFamilyData) ProtoReflect() protoreflect.Message
- func (x *DeploymentLocalState_TaskQueueFamilyData) Reset()
- func (x *DeploymentLocalState_TaskQueueFamilyData) String() string
- type DeploymentSeriesWorkflowArgs
- func (*DeploymentSeriesWorkflowArgs) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentSeriesWorkflowArgs) Equal(that interface{}) bool
- func (x *DeploymentSeriesWorkflowArgs) GetNamespaceId() string
- func (x *DeploymentSeriesWorkflowArgs) GetNamespaceName() string
- func (x *DeploymentSeriesWorkflowArgs) GetSeriesName() string
- func (x *DeploymentSeriesWorkflowArgs) GetState() *SeriesLocalState
- func (val *DeploymentSeriesWorkflowArgs) Marshal() ([]byte, error)
- func (*DeploymentSeriesWorkflowArgs) ProtoMessage()
- func (x *DeploymentSeriesWorkflowArgs) ProtoReflect() protoreflect.Message
- func (x *DeploymentSeriesWorkflowArgs) Reset()
- func (val *DeploymentSeriesWorkflowArgs) Size() int
- func (x *DeploymentSeriesWorkflowArgs) String() string
- func (val *DeploymentSeriesWorkflowArgs) Unmarshal(buf []byte) error
- type DeploymentSeriesWorkflowMemo
- func (*DeploymentSeriesWorkflowMemo) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentSeriesWorkflowMemo) Equal(that interface{}) bool
- func (x *DeploymentSeriesWorkflowMemo) GetCurrentBuildId() string
- func (x *DeploymentSeriesWorkflowMemo) GetCurrentChangedTime() *timestamppb.Timestamp
- func (x *DeploymentSeriesWorkflowMemo) GetSeriesName() string
- func (val *DeploymentSeriesWorkflowMemo) Marshal() ([]byte, error)
- func (*DeploymentSeriesWorkflowMemo) ProtoMessage()
- func (x *DeploymentSeriesWorkflowMemo) ProtoReflect() protoreflect.Message
- func (x *DeploymentSeriesWorkflowMemo) Reset()
- func (val *DeploymentSeriesWorkflowMemo) Size() int
- func (x *DeploymentSeriesWorkflowMemo) String() string
- func (val *DeploymentSeriesWorkflowMemo) Unmarshal(buf []byte) error
- type DeploymentVersionData
- func (*DeploymentVersionData) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentVersionData) Equal(that interface{}) bool
- func (x *DeploymentVersionData) GetCurrentSinceTime() *timestamppb.Timestamp
- func (x *DeploymentVersionData) GetRampPercentage() float32
- func (x *DeploymentVersionData) GetRampingSinceTime() *timestamppb.Timestamp
- func (x *DeploymentVersionData) GetRoutingUpdateTime() *timestamppb.Timestamp
- func (x *DeploymentVersionData) GetVersion() *WorkerDeploymentVersion
- func (val *DeploymentVersionData) Marshal() ([]byte, error)
- func (*DeploymentVersionData) ProtoMessage()
- func (x *DeploymentVersionData) ProtoReflect() protoreflect.Message
- func (x *DeploymentVersionData) Reset()
- func (val *DeploymentVersionData) Size() int
- func (x *DeploymentVersionData) String() string
- func (val *DeploymentVersionData) Unmarshal(buf []byte) error
- type DeploymentWorkflowArgs
- func (*DeploymentWorkflowArgs) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentWorkflowArgs) Equal(that interface{}) bool
- func (x *DeploymentWorkflowArgs) GetNamespaceId() string
- func (x *DeploymentWorkflowArgs) GetNamespaceName() string
- func (x *DeploymentWorkflowArgs) GetState() *DeploymentLocalState
- func (val *DeploymentWorkflowArgs) Marshal() ([]byte, error)
- func (*DeploymentWorkflowArgs) ProtoMessage()
- func (x *DeploymentWorkflowArgs) ProtoReflect() protoreflect.Message
- func (x *DeploymentWorkflowArgs) Reset()
- func (val *DeploymentWorkflowArgs) Size() int
- func (x *DeploymentWorkflowArgs) String() string
- func (val *DeploymentWorkflowArgs) Unmarshal(buf []byte) error
- type DeploymentWorkflowMemo
- func (*DeploymentWorkflowMemo) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentWorkflowMemo) Equal(that interface{}) bool
- func (x *DeploymentWorkflowMemo) GetCreateTime() *timestamppb.Timestamp
- func (x *DeploymentWorkflowMemo) GetDeployment() *v1.Deployment
- func (x *DeploymentWorkflowMemo) GetIsCurrentDeployment() bool
- func (val *DeploymentWorkflowMemo) Marshal() ([]byte, error)
- func (*DeploymentWorkflowMemo) ProtoMessage()
- func (x *DeploymentWorkflowMemo) ProtoReflect() protoreflect.Message
- func (x *DeploymentWorkflowMemo) Reset()
- func (val *DeploymentWorkflowMemo) Size() int
- func (x *DeploymentWorkflowMemo) String() string
- func (val *DeploymentWorkflowMemo) Unmarshal(buf []byte) error
- type DrainageWorkflowArgs
- func (*DrainageWorkflowArgs) Descriptor() ([]byte, []int)deprecated
- func (this *DrainageWorkflowArgs) Equal(that interface{}) bool
- func (x *DrainageWorkflowArgs) GetIsCan() bool
- func (x *DrainageWorkflowArgs) GetNamespaceName() string
- func (x *DrainageWorkflowArgs) GetVersion() *WorkerDeploymentVersion
- func (val *DrainageWorkflowArgs) Marshal() ([]byte, error)
- func (*DrainageWorkflowArgs) ProtoMessage()
- func (x *DrainageWorkflowArgs) ProtoReflect() protoreflect.Message
- func (x *DrainageWorkflowArgs) Reset()
- func (val *DrainageWorkflowArgs) Size() int
- func (x *DrainageWorkflowArgs) String() string
- func (val *DrainageWorkflowArgs) Unmarshal(buf []byte) error
- type IsVersionMissingTaskQueuesArgs
- func (*IsVersionMissingTaskQueuesArgs) Descriptor() ([]byte, []int)deprecated
- func (this *IsVersionMissingTaskQueuesArgs) Equal(that interface{}) bool
- func (x *IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion() string
- func (x *IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion() string
- func (val *IsVersionMissingTaskQueuesArgs) Marshal() ([]byte, error)
- func (*IsVersionMissingTaskQueuesArgs) ProtoMessage()
- func (x *IsVersionMissingTaskQueuesArgs) ProtoReflect() protoreflect.Message
- func (x *IsVersionMissingTaskQueuesArgs) Reset()
- func (val *IsVersionMissingTaskQueuesArgs) Size() int
- func (x *IsVersionMissingTaskQueuesArgs) String() string
- func (val *IsVersionMissingTaskQueuesArgs) Unmarshal(buf []byte) error
- type IsVersionMissingTaskQueuesResult
- func (*IsVersionMissingTaskQueuesResult) Descriptor() ([]byte, []int)deprecated
- func (this *IsVersionMissingTaskQueuesResult) Equal(that interface{}) bool
- func (x *IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues() bool
- func (val *IsVersionMissingTaskQueuesResult) Marshal() ([]byte, error)
- func (*IsVersionMissingTaskQueuesResult) ProtoMessage()
- func (x *IsVersionMissingTaskQueuesResult) ProtoReflect() protoreflect.Message
- func (x *IsVersionMissingTaskQueuesResult) Reset()
- func (val *IsVersionMissingTaskQueuesResult) Size() int
- func (x *IsVersionMissingTaskQueuesResult) String() string
- func (val *IsVersionMissingTaskQueuesResult) Unmarshal(buf []byte) error
- type QueryDescribeDeploymentResponse
- func (*QueryDescribeDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (this *QueryDescribeDeploymentResponse) Equal(that interface{}) bool
- func (x *QueryDescribeDeploymentResponse) GetDeploymentLocalState() *DeploymentLocalState
- func (val *QueryDescribeDeploymentResponse) Marshal() ([]byte, error)
- func (*QueryDescribeDeploymentResponse) ProtoMessage()
- func (x *QueryDescribeDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *QueryDescribeDeploymentResponse) Reset()
- func (val *QueryDescribeDeploymentResponse) Size() int
- func (x *QueryDescribeDeploymentResponse) String() string
- func (val *QueryDescribeDeploymentResponse) Unmarshal(buf []byte) error
- type QueryDescribeVersionResponse
- func (*QueryDescribeVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (this *QueryDescribeVersionResponse) Equal(that interface{}) bool
- func (x *QueryDescribeVersionResponse) GetVersionState() *VersionLocalState
- func (val *QueryDescribeVersionResponse) Marshal() ([]byte, error)
- func (*QueryDescribeVersionResponse) ProtoMessage()
- func (x *QueryDescribeVersionResponse) ProtoReflect() protoreflect.Message
- func (x *QueryDescribeVersionResponse) Reset()
- func (val *QueryDescribeVersionResponse) Size() int
- func (x *QueryDescribeVersionResponse) String() string
- func (val *QueryDescribeVersionResponse) Unmarshal(buf []byte) error
- type QueryDescribeWorkerDeploymentResponse
- func (*QueryDescribeWorkerDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (this *QueryDescribeWorkerDeploymentResponse) Equal(that interface{}) bool
- func (x *QueryDescribeWorkerDeploymentResponse) GetState() *WorkerDeploymentLocalState
- func (val *QueryDescribeWorkerDeploymentResponse) Marshal() ([]byte, error)
- func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage()
- func (x *QueryDescribeWorkerDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *QueryDescribeWorkerDeploymentResponse) Reset()
- func (val *QueryDescribeWorkerDeploymentResponse) Size() int
- func (x *QueryDescribeWorkerDeploymentResponse) String() string
- func (val *QueryDescribeWorkerDeploymentResponse) Unmarshal(buf []byte) error
- type RegisterWorkerInDeploymentArgs
- func (*RegisterWorkerInDeploymentArgs) Descriptor() ([]byte, []int)deprecated
- func (this *RegisterWorkerInDeploymentArgs) Equal(that interface{}) bool
- func (x *RegisterWorkerInDeploymentArgs) GetFirstPollerTime() *timestamppb.Timestamp
- func (x *RegisterWorkerInDeploymentArgs) GetMaxTaskQueues() int32
- func (x *RegisterWorkerInDeploymentArgs) GetTaskQueueName() string
- func (x *RegisterWorkerInDeploymentArgs) GetTaskQueueType() v11.TaskQueueType
- func (val *RegisterWorkerInDeploymentArgs) Marshal() ([]byte, error)
- func (*RegisterWorkerInDeploymentArgs) ProtoMessage()
- func (x *RegisterWorkerInDeploymentArgs) ProtoReflect() protoreflect.Message
- func (x *RegisterWorkerInDeploymentArgs) Reset()
- func (val *RegisterWorkerInDeploymentArgs) Size() int
- func (x *RegisterWorkerInDeploymentArgs) String() string
- func (val *RegisterWorkerInDeploymentArgs) Unmarshal(buf []byte) error
- type RegisterWorkerInVersionArgs
- func (*RegisterWorkerInVersionArgs) Descriptor() ([]byte, []int)deprecated
- func (this *RegisterWorkerInVersionArgs) Equal(that interface{}) bool
- func (x *RegisterWorkerInVersionArgs) GetMaxTaskQueues() int32
- func (x *RegisterWorkerInVersionArgs) GetTaskQueueName() string
- func (x *RegisterWorkerInVersionArgs) GetTaskQueueType() v11.TaskQueueType
- func (val *RegisterWorkerInVersionArgs) Marshal() ([]byte, error)
- func (*RegisterWorkerInVersionArgs) ProtoMessage()
- func (x *RegisterWorkerInVersionArgs) ProtoReflect() protoreflect.Message
- func (x *RegisterWorkerInVersionArgs) Reset()
- func (val *RegisterWorkerInVersionArgs) Size() int
- func (x *RegisterWorkerInVersionArgs) String() string
- func (val *RegisterWorkerInVersionArgs) Unmarshal(buf []byte) error
- type SeriesLocalState
- func (*SeriesLocalState) Descriptor() ([]byte, []int)deprecated
- func (this *SeriesLocalState) Equal(that interface{}) bool
- func (x *SeriesLocalState) GetCurrentBuildId() string
- func (x *SeriesLocalState) GetCurrentChangedTime() *timestamppb.Timestamp
- func (val *SeriesLocalState) Marshal() ([]byte, error)
- func (*SeriesLocalState) ProtoMessage()
- func (x *SeriesLocalState) ProtoReflect() protoreflect.Message
- func (x *SeriesLocalState) Reset()
- func (val *SeriesLocalState) Size() int
- func (x *SeriesLocalState) String() string
- func (val *SeriesLocalState) Unmarshal(buf []byte) error
- type SetCurrentDeploymentArgs
- func (*SetCurrentDeploymentArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SetCurrentDeploymentArgs) Equal(that interface{}) bool
- func (x *SetCurrentDeploymentArgs) GetBuildId() string
- func (x *SetCurrentDeploymentArgs) GetIdentity() string
- func (x *SetCurrentDeploymentArgs) GetRequestId() string
- func (x *SetCurrentDeploymentArgs) GetUpdateMetadata() *v1.UpdateDeploymentMetadata
- func (val *SetCurrentDeploymentArgs) Marshal() ([]byte, error)
- func (*SetCurrentDeploymentArgs) ProtoMessage()
- func (x *SetCurrentDeploymentArgs) ProtoReflect() protoreflect.Message
- func (x *SetCurrentDeploymentArgs) Reset()
- func (val *SetCurrentDeploymentArgs) Size() int
- func (x *SetCurrentDeploymentArgs) String() string
- func (val *SetCurrentDeploymentArgs) Unmarshal(buf []byte) error
- type SetCurrentDeploymentResponse
- func (*SetCurrentDeploymentResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SetCurrentDeploymentResponse) Equal(that interface{}) bool
- func (x *SetCurrentDeploymentResponse) GetCurrentDeploymentState() *DeploymentLocalState
- func (x *SetCurrentDeploymentResponse) GetPreviousDeploymentState() *DeploymentLocalState
- func (val *SetCurrentDeploymentResponse) Marshal() ([]byte, error)
- func (*SetCurrentDeploymentResponse) ProtoMessage()
- func (x *SetCurrentDeploymentResponse) ProtoReflect() protoreflect.Message
- func (x *SetCurrentDeploymentResponse) Reset()
- func (val *SetCurrentDeploymentResponse) Size() int
- func (x *SetCurrentDeploymentResponse) String() string
- func (val *SetCurrentDeploymentResponse) Unmarshal(buf []byte) error
- type SetCurrentVersionArgs
- func (*SetCurrentVersionArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SetCurrentVersionArgs) Equal(that interface{}) bool
- func (x *SetCurrentVersionArgs) GetConflictToken() []byte
- func (x *SetCurrentVersionArgs) GetIdentity() string
- func (x *SetCurrentVersionArgs) GetIgnoreMissingTaskQueues() bool
- func (x *SetCurrentVersionArgs) GetVersion() string
- func (val *SetCurrentVersionArgs) Marshal() ([]byte, error)
- func (*SetCurrentVersionArgs) ProtoMessage()
- func (x *SetCurrentVersionArgs) ProtoReflect() protoreflect.Message
- func (x *SetCurrentVersionArgs) Reset()
- func (val *SetCurrentVersionArgs) Size() int
- func (x *SetCurrentVersionArgs) String() string
- func (val *SetCurrentVersionArgs) Unmarshal(buf []byte) error
- type SetCurrentVersionResponse
- func (*SetCurrentVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SetCurrentVersionResponse) Equal(that interface{}) bool
- func (x *SetCurrentVersionResponse) GetConflictToken() []byte
- func (x *SetCurrentVersionResponse) GetPreviousVersion() string
- func (val *SetCurrentVersionResponse) Marshal() ([]byte, error)
- func (*SetCurrentVersionResponse) ProtoMessage()
- func (x *SetCurrentVersionResponse) ProtoReflect() protoreflect.Message
- func (x *SetCurrentVersionResponse) Reset()
- func (val *SetCurrentVersionResponse) Size() int
- func (x *SetCurrentVersionResponse) String() string
- func (val *SetCurrentVersionResponse) Unmarshal(buf []byte) error
- type SetRampingVersionArgs
- func (*SetRampingVersionArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SetRampingVersionArgs) Equal(that interface{}) bool
- func (x *SetRampingVersionArgs) GetConflictToken() []byte
- func (x *SetRampingVersionArgs) GetIdentity() string
- func (x *SetRampingVersionArgs) GetIgnoreMissingTaskQueues() bool
- func (x *SetRampingVersionArgs) GetPercentage() float32
- func (x *SetRampingVersionArgs) GetVersion() string
- func (val *SetRampingVersionArgs) Marshal() ([]byte, error)
- func (*SetRampingVersionArgs) ProtoMessage()
- func (x *SetRampingVersionArgs) ProtoReflect() protoreflect.Message
- func (x *SetRampingVersionArgs) Reset()
- func (val *SetRampingVersionArgs) Size() int
- func (x *SetRampingVersionArgs) String() string
- func (val *SetRampingVersionArgs) Unmarshal(buf []byte) error
- type SetRampingVersionResponse
- func (*SetRampingVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SetRampingVersionResponse) Equal(that interface{}) bool
- func (x *SetRampingVersionResponse) GetConflictToken() []byte
- func (x *SetRampingVersionResponse) GetPreviousPercentage() float32
- func (x *SetRampingVersionResponse) GetPreviousVersion() string
- func (val *SetRampingVersionResponse) Marshal() ([]byte, error)
- func (*SetRampingVersionResponse) ProtoMessage()
- func (x *SetRampingVersionResponse) ProtoReflect() protoreflect.Message
- func (x *SetRampingVersionResponse) Reset()
- func (val *SetRampingVersionResponse) Size() int
- func (x *SetRampingVersionResponse) String() string
- func (val *SetRampingVersionResponse) Unmarshal(buf []byte) error
- type StartDeploymentSeriesRequest
- func (*StartDeploymentSeriesRequest) Descriptor() ([]byte, []int)deprecated
- func (this *StartDeploymentSeriesRequest) Equal(that interface{}) bool
- func (x *StartDeploymentSeriesRequest) GetRequestId() string
- func (x *StartDeploymentSeriesRequest) GetSeriesName() string
- func (val *StartDeploymentSeriesRequest) Marshal() ([]byte, error)
- func (*StartDeploymentSeriesRequest) ProtoMessage()
- func (x *StartDeploymentSeriesRequest) ProtoReflect() protoreflect.Message
- func (x *StartDeploymentSeriesRequest) Reset()
- func (val *StartDeploymentSeriesRequest) Size() int
- func (x *StartDeploymentSeriesRequest) String() string
- func (val *StartDeploymentSeriesRequest) Unmarshal(buf []byte) error
- type StartWorkerDeploymentRequest
- func (*StartWorkerDeploymentRequest) Descriptor() ([]byte, []int)deprecated
- func (this *StartWorkerDeploymentRequest) Equal(that interface{}) bool
- func (x *StartWorkerDeploymentRequest) GetDeploymentName() string
- func (x *StartWorkerDeploymentRequest) GetRequestId() string
- func (val *StartWorkerDeploymentRequest) Marshal() ([]byte, error)
- func (*StartWorkerDeploymentRequest) ProtoMessage()
- func (x *StartWorkerDeploymentRequest) ProtoReflect() protoreflect.Message
- func (x *StartWorkerDeploymentRequest) Reset()
- func (val *StartWorkerDeploymentRequest) Size() int
- func (x *StartWorkerDeploymentRequest) String() string
- func (val *StartWorkerDeploymentRequest) Unmarshal(buf []byte) error
- type SyncDeploymentStateActivityArgs
- func (*SyncDeploymentStateActivityArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDeploymentStateActivityArgs) Equal(that interface{}) bool
- func (x *SyncDeploymentStateActivityArgs) GetArgs() *SyncDeploymentStateArgs
- func (x *SyncDeploymentStateActivityArgs) GetDeployment() *v1.Deployment
- func (x *SyncDeploymentStateActivityArgs) GetRequestId() string
- func (val *SyncDeploymentStateActivityArgs) Marshal() ([]byte, error)
- func (*SyncDeploymentStateActivityArgs) ProtoMessage()
- func (x *SyncDeploymentStateActivityArgs) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentStateActivityArgs) Reset()
- func (val *SyncDeploymentStateActivityArgs) Size() int
- func (x *SyncDeploymentStateActivityArgs) String() string
- func (val *SyncDeploymentStateActivityArgs) Unmarshal(buf []byte) error
- type SyncDeploymentStateActivityResult
- func (*SyncDeploymentStateActivityResult) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDeploymentStateActivityResult) Equal(that interface{}) bool
- func (x *SyncDeploymentStateActivityResult) GetState() *DeploymentLocalState
- func (val *SyncDeploymentStateActivityResult) Marshal() ([]byte, error)
- func (*SyncDeploymentStateActivityResult) ProtoMessage()
- func (x *SyncDeploymentStateActivityResult) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentStateActivityResult) Reset()
- func (val *SyncDeploymentStateActivityResult) Size() int
- func (x *SyncDeploymentStateActivityResult) String() string
- func (val *SyncDeploymentStateActivityResult) Unmarshal(buf []byte) error
- type SyncDeploymentStateArgs
- func (*SyncDeploymentStateArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDeploymentStateArgs) Equal(that interface{}) bool
- func (x *SyncDeploymentStateArgs) GetSetCurrent() *SyncDeploymentStateArgs_SetCurrent
- func (x *SyncDeploymentStateArgs) GetUpdateMetadata() *v1.UpdateDeploymentMetadata
- func (val *SyncDeploymentStateArgs) Marshal() ([]byte, error)
- func (*SyncDeploymentStateArgs) ProtoMessage()
- func (x *SyncDeploymentStateArgs) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentStateArgs) Reset()
- func (val *SyncDeploymentStateArgs) Size() int
- func (x *SyncDeploymentStateArgs) String() string
- func (val *SyncDeploymentStateArgs) Unmarshal(buf []byte) error
- type SyncDeploymentStateArgs_SetCurrent
- func (*SyncDeploymentStateArgs_SetCurrent) Descriptor() ([]byte, []int)deprecated
- func (x *SyncDeploymentStateArgs_SetCurrent) GetLastBecameCurrentTime() *timestamppb.Timestamp
- func (*SyncDeploymentStateArgs_SetCurrent) ProtoMessage()
- func (x *SyncDeploymentStateArgs_SetCurrent) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentStateArgs_SetCurrent) Reset()
- func (x *SyncDeploymentStateArgs_SetCurrent) String() string
- type SyncDeploymentStateResponse
- func (*SyncDeploymentStateResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDeploymentStateResponse) Equal(that interface{}) bool
- func (x *SyncDeploymentStateResponse) GetDeploymentLocalState() *DeploymentLocalState
- func (val *SyncDeploymentStateResponse) Marshal() ([]byte, error)
- func (*SyncDeploymentStateResponse) ProtoMessage()
- func (x *SyncDeploymentStateResponse) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentStateResponse) Reset()
- func (val *SyncDeploymentStateResponse) Size() int
- func (x *SyncDeploymentStateResponse) String() string
- func (val *SyncDeploymentStateResponse) Unmarshal(buf []byte) error
- type SyncDeploymentVersionUserDataRequest
- func (*SyncDeploymentVersionUserDataRequest) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDeploymentVersionUserDataRequest) Equal(that interface{}) bool
- func (x *SyncDeploymentVersionUserDataRequest) GetForgetVersion() bool
- func (x *SyncDeploymentVersionUserDataRequest) GetSync() []*SyncDeploymentVersionUserDataRequest_SyncUserData
- func (x *SyncDeploymentVersionUserDataRequest) GetVersion() *WorkerDeploymentVersion
- func (val *SyncDeploymentVersionUserDataRequest) Marshal() ([]byte, error)
- func (*SyncDeploymentVersionUserDataRequest) ProtoMessage()
- func (x *SyncDeploymentVersionUserDataRequest) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentVersionUserDataRequest) Reset()
- func (val *SyncDeploymentVersionUserDataRequest) Size() int
- func (x *SyncDeploymentVersionUserDataRequest) String() string
- func (val *SyncDeploymentVersionUserDataRequest) Unmarshal(buf []byte) error
- type SyncDeploymentVersionUserDataRequest_SyncUserData
- func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Descriptor() ([]byte, []int)deprecated
- func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetData() *DeploymentVersionData
- func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetName() string
- func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes() []v11.TaskQueueType
- func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage()
- func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) Reset()
- func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) String() string
- type SyncDeploymentVersionUserDataResponse
- func (*SyncDeploymentVersionUserDataResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDeploymentVersionUserDataResponse) Equal(that interface{}) bool
- func (x *SyncDeploymentVersionUserDataResponse) GetTaskQueueMaxVersions() map[string]int64
- func (val *SyncDeploymentVersionUserDataResponse) Marshal() ([]byte, error)
- func (*SyncDeploymentVersionUserDataResponse) ProtoMessage()
- func (x *SyncDeploymentVersionUserDataResponse) ProtoReflect() protoreflect.Message
- func (x *SyncDeploymentVersionUserDataResponse) Reset()
- func (val *SyncDeploymentVersionUserDataResponse) Size() int
- func (x *SyncDeploymentVersionUserDataResponse) String() string
- func (val *SyncDeploymentVersionUserDataResponse) Unmarshal(buf []byte) error
- type SyncDrainageInfoSignalArgs
- func (*SyncDrainageInfoSignalArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDrainageInfoSignalArgs) Equal(that interface{}) bool
- func (x *SyncDrainageInfoSignalArgs) GetDrainageInfo() *v1.VersionDrainageInfo
- func (val *SyncDrainageInfoSignalArgs) Marshal() ([]byte, error)
- func (*SyncDrainageInfoSignalArgs) ProtoMessage()
- func (x *SyncDrainageInfoSignalArgs) ProtoReflect() protoreflect.Message
- func (x *SyncDrainageInfoSignalArgs) Reset()
- func (val *SyncDrainageInfoSignalArgs) Size() int
- func (x *SyncDrainageInfoSignalArgs) String() string
- func (val *SyncDrainageInfoSignalArgs) Unmarshal(buf []byte) error
- type SyncDrainageStatusSignalArgs
- func (*SyncDrainageStatusSignalArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncDrainageStatusSignalArgs) Equal(that interface{}) bool
- func (x *SyncDrainageStatusSignalArgs) GetDrainageStatus() v11.VersionDrainageStatus
- func (x *SyncDrainageStatusSignalArgs) GetVersion() string
- func (val *SyncDrainageStatusSignalArgs) Marshal() ([]byte, error)
- func (*SyncDrainageStatusSignalArgs) ProtoMessage()
- func (x *SyncDrainageStatusSignalArgs) ProtoReflect() protoreflect.Message
- func (x *SyncDrainageStatusSignalArgs) Reset()
- func (val *SyncDrainageStatusSignalArgs) Size() int
- func (x *SyncDrainageStatusSignalArgs) String() string
- func (val *SyncDrainageStatusSignalArgs) Unmarshal(buf []byte) error
- type SyncUnversionedRampActivityArgs
- func (*SyncUnversionedRampActivityArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncUnversionedRampActivityArgs) Equal(that interface{}) bool
- func (x *SyncUnversionedRampActivityArgs) GetCurrentVersion() string
- func (x *SyncUnversionedRampActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs
- func (val *SyncUnversionedRampActivityArgs) Marshal() ([]byte, error)
- func (*SyncUnversionedRampActivityArgs) ProtoMessage()
- func (x *SyncUnversionedRampActivityArgs) ProtoReflect() protoreflect.Message
- func (x *SyncUnversionedRampActivityArgs) Reset()
- func (val *SyncUnversionedRampActivityArgs) Size() int
- func (x *SyncUnversionedRampActivityArgs) String() string
- func (val *SyncUnversionedRampActivityArgs) Unmarshal(buf []byte) error
- type SyncUnversionedRampActivityResponse
- func (*SyncUnversionedRampActivityResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncUnversionedRampActivityResponse) Equal(that interface{}) bool
- func (x *SyncUnversionedRampActivityResponse) GetTaskQueueMaxVersions() map[string]int64
- func (val *SyncUnversionedRampActivityResponse) Marshal() ([]byte, error)
- func (*SyncUnversionedRampActivityResponse) ProtoMessage()
- func (x *SyncUnversionedRampActivityResponse) ProtoReflect() protoreflect.Message
- func (x *SyncUnversionedRampActivityResponse) Reset()
- func (val *SyncUnversionedRampActivityResponse) Size() int
- func (x *SyncUnversionedRampActivityResponse) String() string
- func (val *SyncUnversionedRampActivityResponse) Unmarshal(buf []byte) error
- type SyncUserDataRequest
- func (*SyncUserDataRequest) Descriptor() ([]byte, []int)deprecated
- func (this *SyncUserDataRequest) Equal(that interface{}) bool
- func (x *SyncUserDataRequest) GetDeployment() *v1.Deployment
- func (x *SyncUserDataRequest) GetSync() []*SyncUserDataRequest_SyncUserData
- func (val *SyncUserDataRequest) Marshal() ([]byte, error)
- func (*SyncUserDataRequest) ProtoMessage()
- func (x *SyncUserDataRequest) ProtoReflect() protoreflect.Message
- func (x *SyncUserDataRequest) Reset()
- func (val *SyncUserDataRequest) Size() int
- func (x *SyncUserDataRequest) String() string
- func (val *SyncUserDataRequest) Unmarshal(buf []byte) error
- type SyncUserDataRequest_SyncUserData
- func (*SyncUserDataRequest_SyncUserData) Descriptor() ([]byte, []int)deprecated
- func (x *SyncUserDataRequest_SyncUserData) GetData() *TaskQueueData
- func (x *SyncUserDataRequest_SyncUserData) GetName() string
- func (x *SyncUserDataRequest_SyncUserData) GetType() v11.TaskQueueType
- func (*SyncUserDataRequest_SyncUserData) ProtoMessage()
- func (x *SyncUserDataRequest_SyncUserData) ProtoReflect() protoreflect.Message
- func (x *SyncUserDataRequest_SyncUserData) Reset()
- func (x *SyncUserDataRequest_SyncUserData) String() string
- type SyncUserDataResponse
- func (*SyncUserDataResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncUserDataResponse) Equal(that interface{}) bool
- func (x *SyncUserDataResponse) GetTaskQueueMaxVersions() map[string]int64
- func (val *SyncUserDataResponse) Marshal() ([]byte, error)
- func (*SyncUserDataResponse) ProtoMessage()
- func (x *SyncUserDataResponse) ProtoReflect() protoreflect.Message
- func (x *SyncUserDataResponse) Reset()
- func (val *SyncUserDataResponse) Size() int
- func (x *SyncUserDataResponse) String() string
- func (val *SyncUserDataResponse) Unmarshal(buf []byte) error
- type SyncVersionStateActivityArgs
- func (*SyncVersionStateActivityArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncVersionStateActivityArgs) Equal(that interface{}) bool
- func (x *SyncVersionStateActivityArgs) GetDeploymentName() string
- func (x *SyncVersionStateActivityArgs) GetRequestId() string
- func (x *SyncVersionStateActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs
- func (x *SyncVersionStateActivityArgs) GetVersion() string
- func (val *SyncVersionStateActivityArgs) Marshal() ([]byte, error)
- func (*SyncVersionStateActivityArgs) ProtoMessage()
- func (x *SyncVersionStateActivityArgs) ProtoReflect() protoreflect.Message
- func (x *SyncVersionStateActivityArgs) Reset()
- func (val *SyncVersionStateActivityArgs) Size() int
- func (x *SyncVersionStateActivityArgs) String() string
- func (val *SyncVersionStateActivityArgs) Unmarshal(buf []byte) error
- type SyncVersionStateActivityResult
- func (*SyncVersionStateActivityResult) Descriptor() ([]byte, []int)deprecated
- func (this *SyncVersionStateActivityResult) Equal(that interface{}) bool
- func (x *SyncVersionStateActivityResult) GetVersionState() *VersionLocalState
- func (val *SyncVersionStateActivityResult) Marshal() ([]byte, error)
- func (*SyncVersionStateActivityResult) ProtoMessage()
- func (x *SyncVersionStateActivityResult) ProtoReflect() protoreflect.Message
- func (x *SyncVersionStateActivityResult) Reset()
- func (val *SyncVersionStateActivityResult) Size() int
- func (x *SyncVersionStateActivityResult) String() string
- func (val *SyncVersionStateActivityResult) Unmarshal(buf []byte) error
- type SyncVersionStateResponse
- func (*SyncVersionStateResponse) Descriptor() ([]byte, []int)deprecated
- func (this *SyncVersionStateResponse) Equal(that interface{}) bool
- func (x *SyncVersionStateResponse) GetVersionState() *VersionLocalState
- func (val *SyncVersionStateResponse) Marshal() ([]byte, error)
- func (*SyncVersionStateResponse) ProtoMessage()
- func (x *SyncVersionStateResponse) ProtoReflect() protoreflect.Message
- func (x *SyncVersionStateResponse) Reset()
- func (val *SyncVersionStateResponse) Size() int
- func (x *SyncVersionStateResponse) String() string
- func (val *SyncVersionStateResponse) Unmarshal(buf []byte) error
- type SyncVersionStateUpdateArgs
- func (*SyncVersionStateUpdateArgs) Descriptor() ([]byte, []int)deprecated
- func (this *SyncVersionStateUpdateArgs) Equal(that interface{}) bool
- func (x *SyncVersionStateUpdateArgs) GetCurrentSinceTime() *timestamppb.Timestamp
- func (x *SyncVersionStateUpdateArgs) GetRampPercentage() float32
- func (x *SyncVersionStateUpdateArgs) GetRampingSinceTime() *timestamppb.Timestamp
- func (x *SyncVersionStateUpdateArgs) GetRoutingUpdateTime() *timestamppb.Timestamp
- func (val *SyncVersionStateUpdateArgs) Marshal() ([]byte, error)
- func (*SyncVersionStateUpdateArgs) ProtoMessage()
- func (x *SyncVersionStateUpdateArgs) ProtoReflect() protoreflect.Message
- func (x *SyncVersionStateUpdateArgs) Reset()
- func (val *SyncVersionStateUpdateArgs) Size() int
- func (x *SyncVersionStateUpdateArgs) String() string
- func (val *SyncVersionStateUpdateArgs) Unmarshal(buf []byte) error
- type TaskQueueData
- func (*TaskQueueData) Descriptor() ([]byte, []int)deprecated
- func (this *TaskQueueData) Equal(that interface{}) bool
- func (x *TaskQueueData) GetFirstPollerTime() *timestamppb.Timestamp
- func (x *TaskQueueData) GetLastBecameCurrentTime() *timestamppb.Timestamp
- func (val *TaskQueueData) Marshal() ([]byte, error)
- func (*TaskQueueData) ProtoMessage()
- func (x *TaskQueueData) ProtoReflect() protoreflect.Message
- func (x *TaskQueueData) Reset()
- func (val *TaskQueueData) Size() int
- func (x *TaskQueueData) String() string
- func (val *TaskQueueData) Unmarshal(buf []byte) error
- type TaskQueueVersionData
- func (*TaskQueueVersionData) Descriptor() ([]byte, []int)deprecated
- func (this *TaskQueueVersionData) Equal(that interface{}) bool
- func (val *TaskQueueVersionData) Marshal() ([]byte, error)
- func (*TaskQueueVersionData) ProtoMessage()
- func (x *TaskQueueVersionData) ProtoReflect() protoreflect.Message
- func (x *TaskQueueVersionData) Reset()
- func (val *TaskQueueVersionData) Size() int
- func (x *TaskQueueVersionData) String() string
- func (val *TaskQueueVersionData) Unmarshal(buf []byte) error
- type UpdateVersionMetadataArgs
- func (*UpdateVersionMetadataArgs) Descriptor() ([]byte, []int)deprecated
- func (this *UpdateVersionMetadataArgs) Equal(that interface{}) bool
- func (x *UpdateVersionMetadataArgs) GetIdentity() string
- func (x *UpdateVersionMetadataArgs) GetRemoveEntries() []string
- func (x *UpdateVersionMetadataArgs) GetUpsertEntries() map[string]*v12.Payload
- func (val *UpdateVersionMetadataArgs) Marshal() ([]byte, error)
- func (*UpdateVersionMetadataArgs) ProtoMessage()
- func (x *UpdateVersionMetadataArgs) ProtoReflect() protoreflect.Message
- func (x *UpdateVersionMetadataArgs) Reset()
- func (val *UpdateVersionMetadataArgs) Size() int
- func (x *UpdateVersionMetadataArgs) String() string
- func (val *UpdateVersionMetadataArgs) Unmarshal(buf []byte) error
- type UpdateVersionMetadataResponse
- func (*UpdateVersionMetadataResponse) Descriptor() ([]byte, []int)deprecated
- func (this *UpdateVersionMetadataResponse) Equal(that interface{}) bool
- func (x *UpdateVersionMetadataResponse) GetMetadata() *v1.VersionMetadata
- func (val *UpdateVersionMetadataResponse) Marshal() ([]byte, error)
- func (*UpdateVersionMetadataResponse) ProtoMessage()
- func (x *UpdateVersionMetadataResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateVersionMetadataResponse) Reset()
- func (val *UpdateVersionMetadataResponse) Size() int
- func (x *UpdateVersionMetadataResponse) String() string
- func (val *UpdateVersionMetadataResponse) Unmarshal(buf []byte) error
- type VersionLocalState
- func (*VersionLocalState) Descriptor() ([]byte, []int)deprecated
- func (this *VersionLocalState) Equal(that interface{}) bool
- func (x *VersionLocalState) GetCreateTime() *timestamppb.Timestamp
- func (x *VersionLocalState) GetCurrentSinceTime() *timestamppb.Timestamp
- func (x *VersionLocalState) GetDrainageInfo() *v1.VersionDrainageInfo
- func (x *VersionLocalState) GetMetadata() *v1.VersionMetadata
- func (x *VersionLocalState) GetRampPercentage() float32
- func (x *VersionLocalState) GetRampingSinceTime() *timestamppb.Timestamp
- func (x *VersionLocalState) GetRoutingUpdateTime() *timestamppb.Timestamp
- func (x *VersionLocalState) GetStartedDeploymentWorkflow() bool
- func (x *VersionLocalState) GetTaskQueueFamilies() map[string]*VersionLocalState_TaskQueueFamilyData
- func (x *VersionLocalState) GetVersion() *WorkerDeploymentVersion
- func (val *VersionLocalState) Marshal() ([]byte, error)
- func (*VersionLocalState) ProtoMessage()
- func (x *VersionLocalState) ProtoReflect() protoreflect.Message
- func (x *VersionLocalState) Reset()
- func (val *VersionLocalState) Size() int
- func (x *VersionLocalState) String() string
- func (val *VersionLocalState) Unmarshal(buf []byte) error
- type VersionLocalState_TaskQueueFamilyData
- func (*VersionLocalState_TaskQueueFamilyData) Descriptor() ([]byte, []int)deprecated
- func (x *VersionLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueVersionData
- func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage()
- func (x *VersionLocalState_TaskQueueFamilyData) ProtoReflect() protoreflect.Message
- func (x *VersionLocalState_TaskQueueFamilyData) Reset()
- func (x *VersionLocalState_TaskQueueFamilyData) String() string
- type WorkerDeploymentLocalState
- func (*WorkerDeploymentLocalState) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentLocalState) Equal(that interface{}) bool
- func (x *WorkerDeploymentLocalState) GetConflictToken() []byte
- func (x *WorkerDeploymentLocalState) GetCreateTime() *timestamppb.Timestamp
- func (x *WorkerDeploymentLocalState) GetLastModifierIdentity() string
- func (x *WorkerDeploymentLocalState) GetRoutingConfig() *v1.RoutingConfig
- func (x *WorkerDeploymentLocalState) GetVersions() map[string]*WorkerDeploymentVersionSummary
- func (val *WorkerDeploymentLocalState) Marshal() ([]byte, error)
- func (*WorkerDeploymentLocalState) ProtoMessage()
- func (x *WorkerDeploymentLocalState) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentLocalState) Reset()
- func (val *WorkerDeploymentLocalState) Size() int
- func (x *WorkerDeploymentLocalState) String() string
- func (val *WorkerDeploymentLocalState) Unmarshal(buf []byte) error
- type WorkerDeploymentSummary
- func (*WorkerDeploymentSummary) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentSummary) Equal(that interface{}) bool
- func (x *WorkerDeploymentSummary) GetCreateTime() *timestamppb.Timestamp
- func (x *WorkerDeploymentSummary) GetName() string
- func (x *WorkerDeploymentSummary) GetRoutingConfig() *v1.RoutingConfig
- func (val *WorkerDeploymentSummary) Marshal() ([]byte, error)
- func (*WorkerDeploymentSummary) ProtoMessage()
- func (x *WorkerDeploymentSummary) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentSummary) Reset()
- func (val *WorkerDeploymentSummary) Size() int
- func (x *WorkerDeploymentSummary) String() string
- func (val *WorkerDeploymentSummary) Unmarshal(buf []byte) error
- type WorkerDeploymentVersion
- func (*WorkerDeploymentVersion) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentVersion) Equal(that interface{}) bool
- func (x *WorkerDeploymentVersion) GetBuildId() string
- func (x *WorkerDeploymentVersion) GetDeploymentName() string
- func (val *WorkerDeploymentVersion) Marshal() ([]byte, error)
- func (*WorkerDeploymentVersion) ProtoMessage()
- func (x *WorkerDeploymentVersion) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentVersion) Reset()
- func (val *WorkerDeploymentVersion) Size() int
- func (x *WorkerDeploymentVersion) String() string
- func (val *WorkerDeploymentVersion) Unmarshal(buf []byte) error
- type WorkerDeploymentVersionSummary
- func (*WorkerDeploymentVersionSummary) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentVersionSummary) Equal(that interface{}) bool
- func (x *WorkerDeploymentVersionSummary) GetCreateTime() *timestamppb.Timestamp
- func (x *WorkerDeploymentVersionSummary) GetDrainageStatus() v11.VersionDrainageStatus
- func (x *WorkerDeploymentVersionSummary) GetVersion() string
- func (val *WorkerDeploymentVersionSummary) Marshal() ([]byte, error)
- func (*WorkerDeploymentVersionSummary) ProtoMessage()
- func (x *WorkerDeploymentVersionSummary) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentVersionSummary) Reset()
- func (val *WorkerDeploymentVersionSummary) Size() int
- func (x *WorkerDeploymentVersionSummary) String() string
- func (val *WorkerDeploymentVersionSummary) Unmarshal(buf []byte) error
- type WorkerDeploymentVersionWorkflowArgs
- func (*WorkerDeploymentVersionWorkflowArgs) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentVersionWorkflowArgs) Equal(that interface{}) bool
- func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceId() string
- func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceName() string
- func (x *WorkerDeploymentVersionWorkflowArgs) GetVersionState() *VersionLocalState
- func (val *WorkerDeploymentVersionWorkflowArgs) Marshal() ([]byte, error)
- func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage()
- func (x *WorkerDeploymentVersionWorkflowArgs) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentVersionWorkflowArgs) Reset()
- func (val *WorkerDeploymentVersionWorkflowArgs) Size() int
- func (x *WorkerDeploymentVersionWorkflowArgs) String() string
- func (val *WorkerDeploymentVersionWorkflowArgs) Unmarshal(buf []byte) error
- type WorkerDeploymentWorkflowArgs
- func (*WorkerDeploymentWorkflowArgs) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentWorkflowArgs) Equal(that interface{}) bool
- func (x *WorkerDeploymentWorkflowArgs) GetDeploymentName() string
- func (x *WorkerDeploymentWorkflowArgs) GetNamespaceId() string
- func (x *WorkerDeploymentWorkflowArgs) GetNamespaceName() string
- func (x *WorkerDeploymentWorkflowArgs) GetState() *WorkerDeploymentLocalState
- func (val *WorkerDeploymentWorkflowArgs) Marshal() ([]byte, error)
- func (*WorkerDeploymentWorkflowArgs) ProtoMessage()
- func (x *WorkerDeploymentWorkflowArgs) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentWorkflowArgs) Reset()
- func (val *WorkerDeploymentWorkflowArgs) Size() int
- func (x *WorkerDeploymentWorkflowArgs) String() string
- func (val *WorkerDeploymentWorkflowArgs) Unmarshal(buf []byte) error
- type WorkerDeploymentWorkflowMemo
- func (*WorkerDeploymentWorkflowMemo) Descriptor() ([]byte, []int)deprecated
- func (this *WorkerDeploymentWorkflowMemo) Equal(that interface{}) bool
- func (x *WorkerDeploymentWorkflowMemo) GetCreateTime() *timestamppb.Timestamp
- func (x *WorkerDeploymentWorkflowMemo) GetDeploymentName() string
- func (x *WorkerDeploymentWorkflowMemo) GetRoutingConfig() *v1.RoutingConfig
- func (val *WorkerDeploymentWorkflowMemo) Marshal() ([]byte, error)
- func (*WorkerDeploymentWorkflowMemo) ProtoMessage()
- func (x *WorkerDeploymentWorkflowMemo) ProtoReflect() protoreflect.Message
- func (x *WorkerDeploymentWorkflowMemo) Reset()
- func (val *WorkerDeploymentWorkflowMemo) Size() int
- func (x *WorkerDeploymentWorkflowMemo) String() string
- func (val *WorkerDeploymentWorkflowMemo) Unmarshal(buf []byte) error
Constants ¶
This section is empty.
Variables ¶
var File_temporal_server_api_deployment_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AddVersionToWorkerDeploymentRequest ¶ added in v1.27.0
type AddVersionToWorkerDeploymentRequest struct { DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` UpdateArgs *AddVersionUpdateArgs `protobuf:"bytes,2,opt,name=update_args,json=updateArgs,proto3" json:"update_args,omitempty"` RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
Used as Worker Deployment Version workflow activity input:
func (*AddVersionToWorkerDeploymentRequest) Descriptor
deprecated
added in
v1.27.0
func (*AddVersionToWorkerDeploymentRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddVersionToWorkerDeploymentRequest.ProtoReflect.Descriptor instead.
func (*AddVersionToWorkerDeploymentRequest) Equal ¶ added in v1.27.0
func (this *AddVersionToWorkerDeploymentRequest) Equal(that interface{}) bool
Equal returns whether two AddVersionToWorkerDeploymentRequest 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 (*AddVersionToWorkerDeploymentRequest) GetDeploymentName ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentRequest) GetDeploymentName() string
func (*AddVersionToWorkerDeploymentRequest) GetRequestId ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentRequest) GetRequestId() string
func (*AddVersionToWorkerDeploymentRequest) GetUpdateArgs ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentRequest) GetUpdateArgs() *AddVersionUpdateArgs
func (*AddVersionToWorkerDeploymentRequest) Marshal ¶ added in v1.27.0
func (val *AddVersionToWorkerDeploymentRequest) Marshal() ([]byte, error)
Marshal an object of type AddVersionToWorkerDeploymentRequest to the protobuf v3 wire format
func (*AddVersionToWorkerDeploymentRequest) ProtoMessage ¶ added in v1.27.0
func (*AddVersionToWorkerDeploymentRequest) ProtoMessage()
func (*AddVersionToWorkerDeploymentRequest) ProtoReflect ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentRequest) ProtoReflect() protoreflect.Message
func (*AddVersionToWorkerDeploymentRequest) Reset ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentRequest) Reset()
func (*AddVersionToWorkerDeploymentRequest) Size ¶ added in v1.27.0
func (val *AddVersionToWorkerDeploymentRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*AddVersionToWorkerDeploymentRequest) String ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentRequest) String() string
func (*AddVersionToWorkerDeploymentRequest) Unmarshal ¶ added in v1.27.0
func (val *AddVersionToWorkerDeploymentRequest) Unmarshal(buf []byte) error
Unmarshal an object of type AddVersionToWorkerDeploymentRequest from the protobuf v3 wire format
type AddVersionToWorkerDeploymentResponse ¶ added in v1.27.0
type AddVersionToWorkerDeploymentResponse struct {
// contains filtered or unexported fields
}
Used as Worker Deployment Version workflow activity output:
func (*AddVersionToWorkerDeploymentResponse) Descriptor
deprecated
added in
v1.27.0
func (*AddVersionToWorkerDeploymentResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddVersionToWorkerDeploymentResponse.ProtoReflect.Descriptor instead.
func (*AddVersionToWorkerDeploymentResponse) Equal ¶ added in v1.27.0
func (this *AddVersionToWorkerDeploymentResponse) Equal(that interface{}) bool
Equal returns whether two AddVersionToWorkerDeploymentResponse 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 (*AddVersionToWorkerDeploymentResponse) Marshal ¶ added in v1.27.0
func (val *AddVersionToWorkerDeploymentResponse) Marshal() ([]byte, error)
Marshal an object of type AddVersionToWorkerDeploymentResponse to the protobuf v3 wire format
func (*AddVersionToWorkerDeploymentResponse) ProtoMessage ¶ added in v1.27.0
func (*AddVersionToWorkerDeploymentResponse) ProtoMessage()
func (*AddVersionToWorkerDeploymentResponse) ProtoReflect ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentResponse) ProtoReflect() protoreflect.Message
func (*AddVersionToWorkerDeploymentResponse) Reset ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentResponse) Reset()
func (*AddVersionToWorkerDeploymentResponse) Size ¶ added in v1.27.0
func (val *AddVersionToWorkerDeploymentResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*AddVersionToWorkerDeploymentResponse) String ¶ added in v1.27.0
func (x *AddVersionToWorkerDeploymentResponse) String() string
func (*AddVersionToWorkerDeploymentResponse) Unmarshal ¶ added in v1.27.0
func (val *AddVersionToWorkerDeploymentResponse) Unmarshal(buf []byte) error
Unmarshal an object of type AddVersionToWorkerDeploymentResponse from the protobuf v3 wire format
type AddVersionUpdateArgs ¶ added in v1.27.0
type AddVersionUpdateArgs struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // contains filtered or unexported fields }
Sent from Version workflow to Worker Deployment workflow
func (*AddVersionUpdateArgs) Descriptor
deprecated
added in
v1.27.0
func (*AddVersionUpdateArgs) Descriptor() ([]byte, []int)
Deprecated: Use AddVersionUpdateArgs.ProtoReflect.Descriptor instead.
func (*AddVersionUpdateArgs) Equal ¶ added in v1.27.0
func (this *AddVersionUpdateArgs) Equal(that interface{}) bool
Equal returns whether two AddVersionUpdateArgs 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 (*AddVersionUpdateArgs) GetCreateTime ¶ added in v1.27.0
func (x *AddVersionUpdateArgs) GetCreateTime() *timestamppb.Timestamp
func (*AddVersionUpdateArgs) GetVersion ¶ added in v1.27.0
func (x *AddVersionUpdateArgs) GetVersion() string
func (*AddVersionUpdateArgs) Marshal ¶ added in v1.27.0
func (val *AddVersionUpdateArgs) Marshal() ([]byte, error)
Marshal an object of type AddVersionUpdateArgs to the protobuf v3 wire format
func (*AddVersionUpdateArgs) ProtoMessage ¶ added in v1.27.0
func (*AddVersionUpdateArgs) ProtoMessage()
func (*AddVersionUpdateArgs) ProtoReflect ¶ added in v1.27.0
func (x *AddVersionUpdateArgs) ProtoReflect() protoreflect.Message
func (*AddVersionUpdateArgs) Reset ¶ added in v1.27.0
func (x *AddVersionUpdateArgs) Reset()
func (*AddVersionUpdateArgs) Size ¶ added in v1.27.0
func (val *AddVersionUpdateArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*AddVersionUpdateArgs) String ¶ added in v1.27.0
func (x *AddVersionUpdateArgs) String() string
func (*AddVersionUpdateArgs) Unmarshal ¶ added in v1.27.0
func (val *AddVersionUpdateArgs) Unmarshal(buf []byte) error
Unmarshal an object of type AddVersionUpdateArgs from the protobuf v3 wire format
type CheckTaskQueuesHavePollersActivityArgs ¶ added in v1.27.0
type CheckTaskQueuesHavePollersActivityArgs struct { // Key: Task Queue Name TaskQueuesAndTypes map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes `` /* 207-byte string literal not displayed */ WorkerDeploymentVersion *WorkerDeploymentVersion `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
used as Worker Deployment Activity input:
func (*CheckTaskQueuesHavePollersActivityArgs) Descriptor
deprecated
added in
v1.27.0
func (*CheckTaskQueuesHavePollersActivityArgs) Descriptor() ([]byte, []int)
Deprecated: Use CheckTaskQueuesHavePollersActivityArgs.ProtoReflect.Descriptor instead.
func (*CheckTaskQueuesHavePollersActivityArgs) Equal ¶ added in v1.27.0
func (this *CheckTaskQueuesHavePollersActivityArgs) Equal(that interface{}) bool
Equal returns whether two CheckTaskQueuesHavePollersActivityArgs 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 (*CheckTaskQueuesHavePollersActivityArgs) GetTaskQueuesAndTypes ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs) GetTaskQueuesAndTypes() map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes
func (*CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion() *WorkerDeploymentVersion
func (*CheckTaskQueuesHavePollersActivityArgs) Marshal ¶ added in v1.27.0
func (val *CheckTaskQueuesHavePollersActivityArgs) Marshal() ([]byte, error)
Marshal an object of type CheckTaskQueuesHavePollersActivityArgs to the protobuf v3 wire format
func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage ¶ added in v1.27.0
func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage()
func (*CheckTaskQueuesHavePollersActivityArgs) ProtoReflect ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs) ProtoReflect() protoreflect.Message
func (*CheckTaskQueuesHavePollersActivityArgs) Reset ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs) Reset()
func (*CheckTaskQueuesHavePollersActivityArgs) Size ¶ added in v1.27.0
func (val *CheckTaskQueuesHavePollersActivityArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*CheckTaskQueuesHavePollersActivityArgs) String ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs) String() string
func (*CheckTaskQueuesHavePollersActivityArgs) Unmarshal ¶ added in v1.27.0
func (val *CheckTaskQueuesHavePollersActivityArgs) Unmarshal(buf []byte) error
Unmarshal an object of type CheckTaskQueuesHavePollersActivityArgs from the protobuf v3 wire format
type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes ¶ added in v1.27.0
type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes struct { Types []v11.TaskQueueType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"types,omitempty"` // contains filtered or unexported fields }
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Descriptor
deprecated
added in
v1.27.0
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Descriptor() ([]byte, []int)
Deprecated: Use CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes.ProtoReflect.Descriptor instead.
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes() []v11.TaskQueueType
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage ¶ added in v1.27.0
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage()
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoReflect ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoReflect() protoreflect.Message
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset()
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String ¶ added in v1.27.0
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String() string
type CheckUserDataPropagationRequest ¶ added in v1.27.0
type CheckUserDataPropagationRequest struct { TaskQueueMaxVersions map[string]int64 `` /* 214-byte string literal not displayed */ // contains filtered or unexported fields }
used as deployment workflow activity input:
func (*CheckUserDataPropagationRequest) Descriptor
deprecated
added in
v1.27.0
func (*CheckUserDataPropagationRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckUserDataPropagationRequest.ProtoReflect.Descriptor instead.
func (*CheckUserDataPropagationRequest) Equal ¶ added in v1.27.0
func (this *CheckUserDataPropagationRequest) Equal(that interface{}) bool
Equal returns whether two CheckUserDataPropagationRequest 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 (*CheckUserDataPropagationRequest) GetTaskQueueMaxVersions ¶ added in v1.27.0
func (x *CheckUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64
func (*CheckUserDataPropagationRequest) Marshal ¶ added in v1.27.0
func (val *CheckUserDataPropagationRequest) Marshal() ([]byte, error)
Marshal an object of type CheckUserDataPropagationRequest to the protobuf v3 wire format
func (*CheckUserDataPropagationRequest) ProtoMessage ¶ added in v1.27.0
func (*CheckUserDataPropagationRequest) ProtoMessage()
func (*CheckUserDataPropagationRequest) ProtoReflect ¶ added in v1.27.0
func (x *CheckUserDataPropagationRequest) ProtoReflect() protoreflect.Message
func (*CheckUserDataPropagationRequest) Reset ¶ added in v1.27.0
func (x *CheckUserDataPropagationRequest) Reset()
func (*CheckUserDataPropagationRequest) Size ¶ added in v1.27.0
func (val *CheckUserDataPropagationRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*CheckUserDataPropagationRequest) String ¶ added in v1.27.0
func (x *CheckUserDataPropagationRequest) String() string
func (*CheckUserDataPropagationRequest) Unmarshal ¶ added in v1.27.0
func (val *CheckUserDataPropagationRequest) Unmarshal(buf []byte) error
Unmarshal an object of type CheckUserDataPropagationRequest from the protobuf v3 wire format
type CheckWorkerDeploymentUserDataPropagationRequest ¶ added in v1.27.0
type CheckWorkerDeploymentUserDataPropagationRequest struct { TaskQueueMaxVersions map[string]int64 `` /* 214-byte string literal not displayed */ // contains filtered or unexported fields }
used as Worker Deployment Version workflow activity input:
func (*CheckWorkerDeploymentUserDataPropagationRequest) Descriptor
deprecated
added in
v1.27.0
func (*CheckWorkerDeploymentUserDataPropagationRequest) Descriptor() ([]byte, []int)
Deprecated: Use CheckWorkerDeploymentUserDataPropagationRequest.ProtoReflect.Descriptor instead.
func (*CheckWorkerDeploymentUserDataPropagationRequest) Equal ¶ added in v1.27.0
func (this *CheckWorkerDeploymentUserDataPropagationRequest) Equal(that interface{}) bool
Equal returns whether two CheckWorkerDeploymentUserDataPropagationRequest 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 (*CheckWorkerDeploymentUserDataPropagationRequest) GetTaskQueueMaxVersions ¶ added in v1.27.0
func (x *CheckWorkerDeploymentUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64
func (*CheckWorkerDeploymentUserDataPropagationRequest) Marshal ¶ added in v1.27.0
func (val *CheckWorkerDeploymentUserDataPropagationRequest) Marshal() ([]byte, error)
Marshal an object of type CheckWorkerDeploymentUserDataPropagationRequest to the protobuf v3 wire format
func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage ¶ added in v1.27.0
func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage()
func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoReflect ¶ added in v1.27.0
func (x *CheckWorkerDeploymentUserDataPropagationRequest) ProtoReflect() protoreflect.Message
func (*CheckWorkerDeploymentUserDataPropagationRequest) Reset ¶ added in v1.27.0
func (x *CheckWorkerDeploymentUserDataPropagationRequest) Reset()
func (*CheckWorkerDeploymentUserDataPropagationRequest) Size ¶ added in v1.27.0
func (val *CheckWorkerDeploymentUserDataPropagationRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*CheckWorkerDeploymentUserDataPropagationRequest) String ¶ added in v1.27.0
func (x *CheckWorkerDeploymentUserDataPropagationRequest) String() string
func (*CheckWorkerDeploymentUserDataPropagationRequest) Unmarshal ¶ added in v1.27.0
func (val *CheckWorkerDeploymentUserDataPropagationRequest) Unmarshal(buf []byte) error
Unmarshal an object of type CheckWorkerDeploymentUserDataPropagationRequest from the protobuf v3 wire format
type DeleteDeploymentArgs ¶ added in v1.27.0
type DeleteDeploymentArgs struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow update input:
func (*DeleteDeploymentArgs) Descriptor
deprecated
added in
v1.27.0
func (*DeleteDeploymentArgs) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDeploymentArgs.ProtoReflect.Descriptor instead.
func (*DeleteDeploymentArgs) Equal ¶ added in v1.27.0
func (this *DeleteDeploymentArgs) Equal(that interface{}) bool
Equal returns whether two DeleteDeploymentArgs 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 (*DeleteDeploymentArgs) GetIdentity ¶ added in v1.27.0
func (x *DeleteDeploymentArgs) GetIdentity() string
func (*DeleteDeploymentArgs) Marshal ¶ added in v1.27.0
func (val *DeleteDeploymentArgs) Marshal() ([]byte, error)
Marshal an object of type DeleteDeploymentArgs to the protobuf v3 wire format
func (*DeleteDeploymentArgs) ProtoMessage ¶ added in v1.27.0
func (*DeleteDeploymentArgs) ProtoMessage()
func (*DeleteDeploymentArgs) ProtoReflect ¶ added in v1.27.0
func (x *DeleteDeploymentArgs) ProtoReflect() protoreflect.Message
func (*DeleteDeploymentArgs) Reset ¶ added in v1.27.0
func (x *DeleteDeploymentArgs) Reset()
func (*DeleteDeploymentArgs) Size ¶ added in v1.27.0
func (val *DeleteDeploymentArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeleteDeploymentArgs) String ¶ added in v1.27.0
func (x *DeleteDeploymentArgs) String() string
func (*DeleteDeploymentArgs) Unmarshal ¶ added in v1.27.0
func (val *DeleteDeploymentArgs) Unmarshal(buf []byte) error
Unmarshal an object of type DeleteDeploymentArgs from the protobuf v3 wire format
type DeleteVersionActivityArgs ¶ added in v1.27.0
type DeleteVersionActivityArgs struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` DeploymentName string `protobuf:"bytes,2,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` SkipDrainage bool `protobuf:"varint,5,opt,name=skip_drainage,json=skipDrainage,proto3" json:"skip_drainage,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Activity input:
func (*DeleteVersionActivityArgs) Descriptor
deprecated
added in
v1.27.0
func (*DeleteVersionActivityArgs) Descriptor() ([]byte, []int)
Deprecated: Use DeleteVersionActivityArgs.ProtoReflect.Descriptor instead.
func (*DeleteVersionActivityArgs) Equal ¶ added in v1.27.0
func (this *DeleteVersionActivityArgs) Equal(that interface{}) bool
Equal returns whether two DeleteVersionActivityArgs 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 (*DeleteVersionActivityArgs) GetDeploymentName ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) GetDeploymentName() string
func (*DeleteVersionActivityArgs) GetIdentity ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) GetIdentity() string
func (*DeleteVersionActivityArgs) GetRequestId ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) GetRequestId() string
func (*DeleteVersionActivityArgs) GetSkipDrainage ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) GetSkipDrainage() bool
func (*DeleteVersionActivityArgs) GetVersion ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) GetVersion() string
func (*DeleteVersionActivityArgs) Marshal ¶ added in v1.27.0
func (val *DeleteVersionActivityArgs) Marshal() ([]byte, error)
Marshal an object of type DeleteVersionActivityArgs to the protobuf v3 wire format
func (*DeleteVersionActivityArgs) ProtoMessage ¶ added in v1.27.0
func (*DeleteVersionActivityArgs) ProtoMessage()
func (*DeleteVersionActivityArgs) ProtoReflect ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) ProtoReflect() protoreflect.Message
func (*DeleteVersionActivityArgs) Reset ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) Reset()
func (*DeleteVersionActivityArgs) Size ¶ added in v1.27.0
func (val *DeleteVersionActivityArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeleteVersionActivityArgs) String ¶ added in v1.27.0
func (x *DeleteVersionActivityArgs) String() string
func (*DeleteVersionActivityArgs) Unmarshal ¶ added in v1.27.0
func (val *DeleteVersionActivityArgs) Unmarshal(buf []byte) error
Unmarshal an object of type DeleteVersionActivityArgs from the protobuf v3 wire format
type DeleteVersionArgs ¶ added in v1.27.0
type DeleteVersionArgs struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` SkipDrainage bool `protobuf:"varint,3,opt,name=skip_drainage,json=skipDrainage,proto3" json:"skip_drainage,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow update input:
func (*DeleteVersionArgs) Descriptor
deprecated
added in
v1.27.0
func (*DeleteVersionArgs) Descriptor() ([]byte, []int)
Deprecated: Use DeleteVersionArgs.ProtoReflect.Descriptor instead.
func (*DeleteVersionArgs) Equal ¶ added in v1.27.0
func (this *DeleteVersionArgs) Equal(that interface{}) bool
Equal returns whether two DeleteVersionArgs 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 (*DeleteVersionArgs) GetIdentity ¶ added in v1.27.0
func (x *DeleteVersionArgs) GetIdentity() string
func (*DeleteVersionArgs) GetSkipDrainage ¶ added in v1.27.0
func (x *DeleteVersionArgs) GetSkipDrainage() bool
func (*DeleteVersionArgs) GetVersion ¶ added in v1.27.0
func (x *DeleteVersionArgs) GetVersion() string
func (*DeleteVersionArgs) Marshal ¶ added in v1.27.0
func (val *DeleteVersionArgs) Marshal() ([]byte, error)
Marshal an object of type DeleteVersionArgs to the protobuf v3 wire format
func (*DeleteVersionArgs) ProtoMessage ¶ added in v1.27.0
func (*DeleteVersionArgs) ProtoMessage()
func (*DeleteVersionArgs) ProtoReflect ¶ added in v1.27.0
func (x *DeleteVersionArgs) ProtoReflect() protoreflect.Message
func (*DeleteVersionArgs) Reset ¶ added in v1.27.0
func (x *DeleteVersionArgs) Reset()
func (*DeleteVersionArgs) Size ¶ added in v1.27.0
func (val *DeleteVersionArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeleteVersionArgs) String ¶ added in v1.27.0
func (x *DeleteVersionArgs) String() string
func (*DeleteVersionArgs) Unmarshal ¶ added in v1.27.0
func (val *DeleteVersionArgs) Unmarshal(buf []byte) error
Unmarshal an object of type DeleteVersionArgs from the protobuf v3 wire format
type DeploymentLocalState ¶
type DeploymentLocalState struct { Deployment *v1.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"` TaskQueueFamilies map[string]*DeploymentLocalState_TaskQueueFamilyData `` /* 202-byte string literal not displayed */ IsCurrent bool `protobuf:"varint,3,opt,name=is_current,json=isCurrent,proto3" json:"is_current,omitempty"` LastBecameCurrentTime *timestamppb.Timestamp `` /* 128-byte string literal not displayed */ CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` Metadata map[string]*v12.Payload `` /* 157-byte string literal not displayed */ StartedSeriesWorkflow bool `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeploymentLocalState) Descriptor
deprecated
func (*DeploymentLocalState) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentLocalState.ProtoReflect.Descriptor instead.
func (*DeploymentLocalState) Equal ¶
func (this *DeploymentLocalState) Equal(that interface{}) bool
Equal returns whether two DeploymentLocalState 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 (*DeploymentLocalState) GetCreateTime ¶
func (x *DeploymentLocalState) GetCreateTime() *timestamppb.Timestamp
func (*DeploymentLocalState) GetDeployment ¶
func (x *DeploymentLocalState) GetDeployment() *v1.Deployment
func (*DeploymentLocalState) GetIsCurrent ¶
func (x *DeploymentLocalState) GetIsCurrent() bool
func (*DeploymentLocalState) GetLastBecameCurrentTime ¶
func (x *DeploymentLocalState) GetLastBecameCurrentTime() *timestamppb.Timestamp
func (*DeploymentLocalState) GetMetadata ¶
func (x *DeploymentLocalState) GetMetadata() map[string]*v12.Payload
func (*DeploymentLocalState) GetStartedSeriesWorkflow ¶
func (x *DeploymentLocalState) GetStartedSeriesWorkflow() bool
func (*DeploymentLocalState) GetTaskQueueFamilies ¶
func (x *DeploymentLocalState) GetTaskQueueFamilies() map[string]*DeploymentLocalState_TaskQueueFamilyData
func (*DeploymentLocalState) Marshal ¶
func (val *DeploymentLocalState) Marshal() ([]byte, error)
Marshal an object of type DeploymentLocalState to the protobuf v3 wire format
func (*DeploymentLocalState) ProtoMessage ¶
func (*DeploymentLocalState) ProtoMessage()
func (*DeploymentLocalState) ProtoReflect ¶
func (x *DeploymentLocalState) ProtoReflect() protoreflect.Message
func (*DeploymentLocalState) Reset ¶
func (x *DeploymentLocalState) Reset()
func (*DeploymentLocalState) Size ¶
func (val *DeploymentLocalState) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentLocalState) String ¶
func (x *DeploymentLocalState) String() string
func (*DeploymentLocalState) Unmarshal ¶
func (val *DeploymentLocalState) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentLocalState from the protobuf v3 wire format
type DeploymentLocalState_TaskQueueFamilyData ¶
type DeploymentLocalState_TaskQueueFamilyData struct { // Key: enums.TaskQueueType, Value: TaskQueueData // All fields in TaskQueueData are valid except last_became_current_time, the source of // truth for that is the value at the root of DeploymentLocalState. TaskQueues map[int32]*TaskQueueData `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeploymentLocalState_TaskQueueFamilyData) Descriptor
deprecated
func (*DeploymentLocalState_TaskQueueFamilyData) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentLocalState_TaskQueueFamilyData.ProtoReflect.Descriptor instead.
func (*DeploymentLocalState_TaskQueueFamilyData) GetTaskQueues ¶
func (x *DeploymentLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueData
func (*DeploymentLocalState_TaskQueueFamilyData) ProtoMessage ¶
func (*DeploymentLocalState_TaskQueueFamilyData) ProtoMessage()
func (*DeploymentLocalState_TaskQueueFamilyData) ProtoReflect ¶
func (x *DeploymentLocalState_TaskQueueFamilyData) ProtoReflect() protoreflect.Message
func (*DeploymentLocalState_TaskQueueFamilyData) Reset ¶
func (x *DeploymentLocalState_TaskQueueFamilyData) Reset()
func (*DeploymentLocalState_TaskQueueFamilyData) String ¶
func (x *DeploymentLocalState_TaskQueueFamilyData) String() string
type DeploymentSeriesWorkflowArgs ¶
type DeploymentSeriesWorkflowArgs struct { NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` SeriesName string `protobuf:"bytes,3,opt,name=series_name,json=seriesName,proto3" json:"series_name,omitempty"` State *SeriesLocalState `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
used as deployment series workflow input:
func (*DeploymentSeriesWorkflowArgs) Descriptor
deprecated
func (*DeploymentSeriesWorkflowArgs) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentSeriesWorkflowArgs.ProtoReflect.Descriptor instead.
func (*DeploymentSeriesWorkflowArgs) Equal ¶
func (this *DeploymentSeriesWorkflowArgs) Equal(that interface{}) bool
Equal returns whether two DeploymentSeriesWorkflowArgs 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 (*DeploymentSeriesWorkflowArgs) GetNamespaceId ¶
func (x *DeploymentSeriesWorkflowArgs) GetNamespaceId() string
func (*DeploymentSeriesWorkflowArgs) GetNamespaceName ¶
func (x *DeploymentSeriesWorkflowArgs) GetNamespaceName() string
func (*DeploymentSeriesWorkflowArgs) GetSeriesName ¶
func (x *DeploymentSeriesWorkflowArgs) GetSeriesName() string
func (*DeploymentSeriesWorkflowArgs) GetState ¶
func (x *DeploymentSeriesWorkflowArgs) GetState() *SeriesLocalState
func (*DeploymentSeriesWorkflowArgs) Marshal ¶
func (val *DeploymentSeriesWorkflowArgs) Marshal() ([]byte, error)
Marshal an object of type DeploymentSeriesWorkflowArgs to the protobuf v3 wire format
func (*DeploymentSeriesWorkflowArgs) ProtoMessage ¶
func (*DeploymentSeriesWorkflowArgs) ProtoMessage()
func (*DeploymentSeriesWorkflowArgs) ProtoReflect ¶
func (x *DeploymentSeriesWorkflowArgs) ProtoReflect() protoreflect.Message
func (*DeploymentSeriesWorkflowArgs) Reset ¶
func (x *DeploymentSeriesWorkflowArgs) Reset()
func (*DeploymentSeriesWorkflowArgs) Size ¶
func (val *DeploymentSeriesWorkflowArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentSeriesWorkflowArgs) String ¶
func (x *DeploymentSeriesWorkflowArgs) String() string
func (*DeploymentSeriesWorkflowArgs) Unmarshal ¶
func (val *DeploymentSeriesWorkflowArgs) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentSeriesWorkflowArgs from the protobuf v3 wire format
type DeploymentSeriesWorkflowMemo ¶
type DeploymentSeriesWorkflowMemo struct { SeriesName string `protobuf:"bytes,1,opt,name=series_name,json=seriesName,proto3" json:"series_name,omitempty"` CurrentBuildId string `protobuf:"bytes,2,opt,name=current_build_id,json=currentBuildId,proto3" json:"current_build_id,omitempty"` CurrentChangedTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=current_changed_time,json=currentChangedTime,proto3" json:"current_changed_time,omitempty"` // contains filtered or unexported fields }
used as deployment series workflow memo:
func (*DeploymentSeriesWorkflowMemo) Descriptor
deprecated
func (*DeploymentSeriesWorkflowMemo) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentSeriesWorkflowMemo.ProtoReflect.Descriptor instead.
func (*DeploymentSeriesWorkflowMemo) Equal ¶
func (this *DeploymentSeriesWorkflowMemo) Equal(that interface{}) bool
Equal returns whether two DeploymentSeriesWorkflowMemo 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 (*DeploymentSeriesWorkflowMemo) GetCurrentBuildId ¶
func (x *DeploymentSeriesWorkflowMemo) GetCurrentBuildId() string
func (*DeploymentSeriesWorkflowMemo) GetCurrentChangedTime ¶
func (x *DeploymentSeriesWorkflowMemo) GetCurrentChangedTime() *timestamppb.Timestamp
func (*DeploymentSeriesWorkflowMemo) GetSeriesName ¶
func (x *DeploymentSeriesWorkflowMemo) GetSeriesName() string
func (*DeploymentSeriesWorkflowMemo) Marshal ¶
func (val *DeploymentSeriesWorkflowMemo) Marshal() ([]byte, error)
Marshal an object of type DeploymentSeriesWorkflowMemo to the protobuf v3 wire format
func (*DeploymentSeriesWorkflowMemo) ProtoMessage ¶
func (*DeploymentSeriesWorkflowMemo) ProtoMessage()
func (*DeploymentSeriesWorkflowMemo) ProtoReflect ¶
func (x *DeploymentSeriesWorkflowMemo) ProtoReflect() protoreflect.Message
func (*DeploymentSeriesWorkflowMemo) Reset ¶
func (x *DeploymentSeriesWorkflowMemo) Reset()
func (*DeploymentSeriesWorkflowMemo) Size ¶
func (val *DeploymentSeriesWorkflowMemo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentSeriesWorkflowMemo) String ¶
func (x *DeploymentSeriesWorkflowMemo) String() string
func (*DeploymentSeriesWorkflowMemo) Unmarshal ¶
func (val *DeploymentSeriesWorkflowMemo) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentSeriesWorkflowMemo from the protobuf v3 wire format
type DeploymentVersionData ¶ added in v1.27.0
type DeploymentVersionData struct { // Nil means unversioned. Version *WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed. RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=routing_update_time,json=routingUpdateTime,proto3" json:"routing_update_time,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --) // // Nil if not current. CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=current_since_time,json=currentSinceTime,proto3" json:"current_since_time,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --) // // Nil if not ramping. Updated when the version first starts ramping, not on each ramp change. RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"` // Range: [0, 100]. Must be zero if the version is not ramping (i.e. `ramping_since_time` is nil). // Can be in the range [0, 100] if the version is ramping. RampPercentage float32 `protobuf:"fixed32,5,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"` // contains filtered or unexported fields }
The source of truth for this data is in the WorkerDeployment entity workflows, which is synced to all TQs whenever the source changes.
func (*DeploymentVersionData) Descriptor
deprecated
added in
v1.27.0
func (*DeploymentVersionData) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentVersionData.ProtoReflect.Descriptor instead.
func (*DeploymentVersionData) Equal ¶ added in v1.27.0
func (this *DeploymentVersionData) Equal(that interface{}) bool
Equal returns whether two DeploymentVersionData 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 (*DeploymentVersionData) GetCurrentSinceTime ¶ added in v1.27.0
func (x *DeploymentVersionData) GetCurrentSinceTime() *timestamppb.Timestamp
func (*DeploymentVersionData) GetRampPercentage ¶ added in v1.27.0
func (x *DeploymentVersionData) GetRampPercentage() float32
func (*DeploymentVersionData) GetRampingSinceTime ¶ added in v1.27.0
func (x *DeploymentVersionData) GetRampingSinceTime() *timestamppb.Timestamp
func (*DeploymentVersionData) GetRoutingUpdateTime ¶ added in v1.27.0
func (x *DeploymentVersionData) GetRoutingUpdateTime() *timestamppb.Timestamp
func (*DeploymentVersionData) GetVersion ¶ added in v1.27.0
func (x *DeploymentVersionData) GetVersion() *WorkerDeploymentVersion
func (*DeploymentVersionData) Marshal ¶ added in v1.27.0
func (val *DeploymentVersionData) Marshal() ([]byte, error)
Marshal an object of type DeploymentVersionData to the protobuf v3 wire format
func (*DeploymentVersionData) ProtoMessage ¶ added in v1.27.0
func (*DeploymentVersionData) ProtoMessage()
func (*DeploymentVersionData) ProtoReflect ¶ added in v1.27.0
func (x *DeploymentVersionData) ProtoReflect() protoreflect.Message
func (*DeploymentVersionData) Reset ¶ added in v1.27.0
func (x *DeploymentVersionData) Reset()
func (*DeploymentVersionData) Size ¶ added in v1.27.0
func (val *DeploymentVersionData) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentVersionData) String ¶ added in v1.27.0
func (x *DeploymentVersionData) String() string
func (*DeploymentVersionData) Unmarshal ¶ added in v1.27.0
func (val *DeploymentVersionData) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentVersionData from the protobuf v3 wire format
type DeploymentWorkflowArgs ¶
type DeploymentWorkflowArgs struct { NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` State *DeploymentLocalState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
used as deployment workflow input:
func (*DeploymentWorkflowArgs) Descriptor
deprecated
func (*DeploymentWorkflowArgs) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentWorkflowArgs.ProtoReflect.Descriptor instead.
func (*DeploymentWorkflowArgs) Equal ¶
func (this *DeploymentWorkflowArgs) Equal(that interface{}) bool
Equal returns whether two DeploymentWorkflowArgs 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 (*DeploymentWorkflowArgs) GetNamespaceId ¶
func (x *DeploymentWorkflowArgs) GetNamespaceId() string
func (*DeploymentWorkflowArgs) GetNamespaceName ¶
func (x *DeploymentWorkflowArgs) GetNamespaceName() string
func (*DeploymentWorkflowArgs) GetState ¶
func (x *DeploymentWorkflowArgs) GetState() *DeploymentLocalState
func (*DeploymentWorkflowArgs) Marshal ¶
func (val *DeploymentWorkflowArgs) Marshal() ([]byte, error)
Marshal an object of type DeploymentWorkflowArgs to the protobuf v3 wire format
func (*DeploymentWorkflowArgs) ProtoMessage ¶
func (*DeploymentWorkflowArgs) ProtoMessage()
func (*DeploymentWorkflowArgs) ProtoReflect ¶
func (x *DeploymentWorkflowArgs) ProtoReflect() protoreflect.Message
func (*DeploymentWorkflowArgs) Reset ¶
func (x *DeploymentWorkflowArgs) Reset()
func (*DeploymentWorkflowArgs) Size ¶
func (val *DeploymentWorkflowArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentWorkflowArgs) String ¶
func (x *DeploymentWorkflowArgs) String() string
func (*DeploymentWorkflowArgs) Unmarshal ¶
func (val *DeploymentWorkflowArgs) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentWorkflowArgs from the protobuf v3 wire format
type DeploymentWorkflowMemo ¶
type DeploymentWorkflowMemo struct { Deployment *v1.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` IsCurrentDeployment bool `protobuf:"varint,3,opt,name=is_current_deployment,json=isCurrentDeployment,proto3" json:"is_current_deployment,omitempty"` // contains filtered or unexported fields }
used as deployment workflow memo:
func (*DeploymentWorkflowMemo) Descriptor
deprecated
func (*DeploymentWorkflowMemo) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentWorkflowMemo.ProtoReflect.Descriptor instead.
func (*DeploymentWorkflowMemo) Equal ¶
func (this *DeploymentWorkflowMemo) Equal(that interface{}) bool
Equal returns whether two DeploymentWorkflowMemo 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 (*DeploymentWorkflowMemo) GetCreateTime ¶
func (x *DeploymentWorkflowMemo) GetCreateTime() *timestamppb.Timestamp
func (*DeploymentWorkflowMemo) GetDeployment ¶
func (x *DeploymentWorkflowMemo) GetDeployment() *v1.Deployment
func (*DeploymentWorkflowMemo) GetIsCurrentDeployment ¶
func (x *DeploymentWorkflowMemo) GetIsCurrentDeployment() bool
func (*DeploymentWorkflowMemo) Marshal ¶
func (val *DeploymentWorkflowMemo) Marshal() ([]byte, error)
Marshal an object of type DeploymentWorkflowMemo to the protobuf v3 wire format
func (*DeploymentWorkflowMemo) ProtoMessage ¶
func (*DeploymentWorkflowMemo) ProtoMessage()
func (*DeploymentWorkflowMemo) ProtoReflect ¶
func (x *DeploymentWorkflowMemo) ProtoReflect() protoreflect.Message
func (*DeploymentWorkflowMemo) Reset ¶
func (x *DeploymentWorkflowMemo) Reset()
func (*DeploymentWorkflowMemo) Size ¶
func (val *DeploymentWorkflowMemo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentWorkflowMemo) String ¶
func (x *DeploymentWorkflowMemo) String() string
func (*DeploymentWorkflowMemo) Unmarshal ¶
func (val *DeploymentWorkflowMemo) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentWorkflowMemo from the protobuf v3 wire format
type DrainageWorkflowArgs ¶ added in v1.27.0
type DrainageWorkflowArgs struct { NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` Version *WorkerDeploymentVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` IsCan bool `protobuf:"varint,3,opt,name=is_can,json=isCan,proto3" json:"is_can,omitempty"` // contains filtered or unexported fields }
used as drainage workflow input:
func (*DrainageWorkflowArgs) Descriptor
deprecated
added in
v1.27.0
func (*DrainageWorkflowArgs) Descriptor() ([]byte, []int)
Deprecated: Use DrainageWorkflowArgs.ProtoReflect.Descriptor instead.
func (*DrainageWorkflowArgs) Equal ¶ added in v1.27.0
func (this *DrainageWorkflowArgs) Equal(that interface{}) bool
Equal returns whether two DrainageWorkflowArgs 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 (*DrainageWorkflowArgs) GetIsCan ¶ added in v1.27.0
func (x *DrainageWorkflowArgs) GetIsCan() bool
func (*DrainageWorkflowArgs) GetNamespaceName ¶ added in v1.27.0
func (x *DrainageWorkflowArgs) GetNamespaceName() string
func (*DrainageWorkflowArgs) GetVersion ¶ added in v1.27.0
func (x *DrainageWorkflowArgs) GetVersion() *WorkerDeploymentVersion
func (*DrainageWorkflowArgs) Marshal ¶ added in v1.27.0
func (val *DrainageWorkflowArgs) Marshal() ([]byte, error)
Marshal an object of type DrainageWorkflowArgs to the protobuf v3 wire format
func (*DrainageWorkflowArgs) ProtoMessage ¶ added in v1.27.0
func (*DrainageWorkflowArgs) ProtoMessage()
func (*DrainageWorkflowArgs) ProtoReflect ¶ added in v1.27.0
func (x *DrainageWorkflowArgs) ProtoReflect() protoreflect.Message
func (*DrainageWorkflowArgs) Reset ¶ added in v1.27.0
func (x *DrainageWorkflowArgs) Reset()
func (*DrainageWorkflowArgs) Size ¶ added in v1.27.0
func (val *DrainageWorkflowArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DrainageWorkflowArgs) String ¶ added in v1.27.0
func (x *DrainageWorkflowArgs) String() string
func (*DrainageWorkflowArgs) Unmarshal ¶ added in v1.27.0
func (val *DrainageWorkflowArgs) Unmarshal(buf []byte) error
Unmarshal an object of type DrainageWorkflowArgs from the protobuf v3 wire format
type IsVersionMissingTaskQueuesArgs ¶ added in v1.27.0
type IsVersionMissingTaskQueuesArgs struct { PrevCurrentVersion string `protobuf:"bytes,1,opt,name=prev_current_version,json=prevCurrentVersion,proto3" json:"prev_current_version,omitempty"` NewCurrentVersion string `protobuf:"bytes,2,opt,name=new_current_version,json=newCurrentVersion,proto3" json:"new_current_version,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment activity input:
func (*IsVersionMissingTaskQueuesArgs) Descriptor
deprecated
added in
v1.27.0
func (*IsVersionMissingTaskQueuesArgs) Descriptor() ([]byte, []int)
Deprecated: Use IsVersionMissingTaskQueuesArgs.ProtoReflect.Descriptor instead.
func (*IsVersionMissingTaskQueuesArgs) Equal ¶ added in v1.27.0
func (this *IsVersionMissingTaskQueuesArgs) Equal(that interface{}) bool
Equal returns whether two IsVersionMissingTaskQueuesArgs 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 (*IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion() string
func (*IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion() string
func (*IsVersionMissingTaskQueuesArgs) Marshal ¶ added in v1.27.0
func (val *IsVersionMissingTaskQueuesArgs) Marshal() ([]byte, error)
Marshal an object of type IsVersionMissingTaskQueuesArgs to the protobuf v3 wire format
func (*IsVersionMissingTaskQueuesArgs) ProtoMessage ¶ added in v1.27.0
func (*IsVersionMissingTaskQueuesArgs) ProtoMessage()
func (*IsVersionMissingTaskQueuesArgs) ProtoReflect ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesArgs) ProtoReflect() protoreflect.Message
func (*IsVersionMissingTaskQueuesArgs) Reset ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesArgs) Reset()
func (*IsVersionMissingTaskQueuesArgs) Size ¶ added in v1.27.0
func (val *IsVersionMissingTaskQueuesArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*IsVersionMissingTaskQueuesArgs) String ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesArgs) String() string
func (*IsVersionMissingTaskQueuesArgs) Unmarshal ¶ added in v1.27.0
func (val *IsVersionMissingTaskQueuesArgs) Unmarshal(buf []byte) error
Unmarshal an object of type IsVersionMissingTaskQueuesArgs from the protobuf v3 wire format
type IsVersionMissingTaskQueuesResult ¶ added in v1.27.0
type IsVersionMissingTaskQueuesResult struct { IsMissingTaskQueues bool `protobuf:"varint,1,opt,name=is_missing_task_queues,json=isMissingTaskQueues,proto3" json:"is_missing_task_queues,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment activity output:
func (*IsVersionMissingTaskQueuesResult) Descriptor
deprecated
added in
v1.27.0
func (*IsVersionMissingTaskQueuesResult) Descriptor() ([]byte, []int)
Deprecated: Use IsVersionMissingTaskQueuesResult.ProtoReflect.Descriptor instead.
func (*IsVersionMissingTaskQueuesResult) Equal ¶ added in v1.27.0
func (this *IsVersionMissingTaskQueuesResult) Equal(that interface{}) bool
Equal returns whether two IsVersionMissingTaskQueuesResult 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 (*IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues() bool
func (*IsVersionMissingTaskQueuesResult) Marshal ¶ added in v1.27.0
func (val *IsVersionMissingTaskQueuesResult) Marshal() ([]byte, error)
Marshal an object of type IsVersionMissingTaskQueuesResult to the protobuf v3 wire format
func (*IsVersionMissingTaskQueuesResult) ProtoMessage ¶ added in v1.27.0
func (*IsVersionMissingTaskQueuesResult) ProtoMessage()
func (*IsVersionMissingTaskQueuesResult) ProtoReflect ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesResult) ProtoReflect() protoreflect.Message
func (*IsVersionMissingTaskQueuesResult) Reset ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesResult) Reset()
func (*IsVersionMissingTaskQueuesResult) Size ¶ added in v1.27.0
func (val *IsVersionMissingTaskQueuesResult) Size() int
Size returns the size of the object, in bytes, once serialized
func (*IsVersionMissingTaskQueuesResult) String ¶ added in v1.27.0
func (x *IsVersionMissingTaskQueuesResult) String() string
func (*IsVersionMissingTaskQueuesResult) Unmarshal ¶ added in v1.27.0
func (val *IsVersionMissingTaskQueuesResult) Unmarshal(buf []byte) error
Unmarshal an object of type IsVersionMissingTaskQueuesResult from the protobuf v3 wire format
type QueryDescribeDeploymentResponse ¶
type QueryDescribeDeploymentResponse struct { DeploymentLocalState *DeploymentLocalState `protobuf:"bytes,1,opt,name=deployment_local_state,json=deploymentLocalState,proto3" json:"deployment_local_state,omitempty"` // contains filtered or unexported fields }
used as deployment workflow query response:
func (*QueryDescribeDeploymentResponse) Descriptor
deprecated
func (*QueryDescribeDeploymentResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryDescribeDeploymentResponse.ProtoReflect.Descriptor instead.
func (*QueryDescribeDeploymentResponse) Equal ¶
func (this *QueryDescribeDeploymentResponse) Equal(that interface{}) bool
Equal returns whether two QueryDescribeDeploymentResponse 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 (*QueryDescribeDeploymentResponse) GetDeploymentLocalState ¶
func (x *QueryDescribeDeploymentResponse) GetDeploymentLocalState() *DeploymentLocalState
func (*QueryDescribeDeploymentResponse) Marshal ¶
func (val *QueryDescribeDeploymentResponse) Marshal() ([]byte, error)
Marshal an object of type QueryDescribeDeploymentResponse to the protobuf v3 wire format
func (*QueryDescribeDeploymentResponse) ProtoMessage ¶
func (*QueryDescribeDeploymentResponse) ProtoMessage()
func (*QueryDescribeDeploymentResponse) ProtoReflect ¶
func (x *QueryDescribeDeploymentResponse) ProtoReflect() protoreflect.Message
func (*QueryDescribeDeploymentResponse) Reset ¶
func (x *QueryDescribeDeploymentResponse) Reset()
func (*QueryDescribeDeploymentResponse) Size ¶
func (val *QueryDescribeDeploymentResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*QueryDescribeDeploymentResponse) String ¶
func (x *QueryDescribeDeploymentResponse) String() string
func (*QueryDescribeDeploymentResponse) Unmarshal ¶
func (val *QueryDescribeDeploymentResponse) Unmarshal(buf []byte) error
Unmarshal an object of type QueryDescribeDeploymentResponse from the protobuf v3 wire format
type QueryDescribeVersionResponse ¶ added in v1.27.0
type QueryDescribeVersionResponse struct { VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow query response:
func (*QueryDescribeVersionResponse) Descriptor
deprecated
added in
v1.27.0
func (*QueryDescribeVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryDescribeVersionResponse.ProtoReflect.Descriptor instead.
func (*QueryDescribeVersionResponse) Equal ¶ added in v1.27.0
func (this *QueryDescribeVersionResponse) Equal(that interface{}) bool
Equal returns whether two QueryDescribeVersionResponse 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 (*QueryDescribeVersionResponse) GetVersionState ¶ added in v1.27.0
func (x *QueryDescribeVersionResponse) GetVersionState() *VersionLocalState
func (*QueryDescribeVersionResponse) Marshal ¶ added in v1.27.0
func (val *QueryDescribeVersionResponse) Marshal() ([]byte, error)
Marshal an object of type QueryDescribeVersionResponse to the protobuf v3 wire format
func (*QueryDescribeVersionResponse) ProtoMessage ¶ added in v1.27.0
func (*QueryDescribeVersionResponse) ProtoMessage()
func (*QueryDescribeVersionResponse) ProtoReflect ¶ added in v1.27.0
func (x *QueryDescribeVersionResponse) ProtoReflect() protoreflect.Message
func (*QueryDescribeVersionResponse) Reset ¶ added in v1.27.0
func (x *QueryDescribeVersionResponse) Reset()
func (*QueryDescribeVersionResponse) Size ¶ added in v1.27.0
func (val *QueryDescribeVersionResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*QueryDescribeVersionResponse) String ¶ added in v1.27.0
func (x *QueryDescribeVersionResponse) String() string
func (*QueryDescribeVersionResponse) Unmarshal ¶ added in v1.27.0
func (val *QueryDescribeVersionResponse) Unmarshal(buf []byte) error
Unmarshal an object of type QueryDescribeVersionResponse from the protobuf v3 wire format
type QueryDescribeWorkerDeploymentResponse ¶ added in v1.27.0
type QueryDescribeWorkerDeploymentResponse struct { State *WorkerDeploymentLocalState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow query response:
func (*QueryDescribeWorkerDeploymentResponse) Descriptor
deprecated
added in
v1.27.0
func (*QueryDescribeWorkerDeploymentResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryDescribeWorkerDeploymentResponse.ProtoReflect.Descriptor instead.
func (*QueryDescribeWorkerDeploymentResponse) Equal ¶ added in v1.27.0
func (this *QueryDescribeWorkerDeploymentResponse) Equal(that interface{}) bool
Equal returns whether two QueryDescribeWorkerDeploymentResponse 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 (*QueryDescribeWorkerDeploymentResponse) GetState ¶ added in v1.27.0
func (x *QueryDescribeWorkerDeploymentResponse) GetState() *WorkerDeploymentLocalState
func (*QueryDescribeWorkerDeploymentResponse) Marshal ¶ added in v1.27.0
func (val *QueryDescribeWorkerDeploymentResponse) Marshal() ([]byte, error)
Marshal an object of type QueryDescribeWorkerDeploymentResponse to the protobuf v3 wire format
func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage ¶ added in v1.27.0
func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage()
func (*QueryDescribeWorkerDeploymentResponse) ProtoReflect ¶ added in v1.27.0
func (x *QueryDescribeWorkerDeploymentResponse) ProtoReflect() protoreflect.Message
func (*QueryDescribeWorkerDeploymentResponse) Reset ¶ added in v1.27.0
func (x *QueryDescribeWorkerDeploymentResponse) Reset()
func (*QueryDescribeWorkerDeploymentResponse) Size ¶ added in v1.27.0
func (val *QueryDescribeWorkerDeploymentResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*QueryDescribeWorkerDeploymentResponse) String ¶ added in v1.27.0
func (x *QueryDescribeWorkerDeploymentResponse) String() string
func (*QueryDescribeWorkerDeploymentResponse) Unmarshal ¶ added in v1.27.0
func (val *QueryDescribeWorkerDeploymentResponse) Unmarshal(buf []byte) error
Unmarshal an object of type QueryDescribeWorkerDeploymentResponse from the protobuf v3 wire format
type RegisterWorkerInDeploymentArgs ¶
type RegisterWorkerInDeploymentArgs struct { TaskQueueName string `protobuf:"bytes,1,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"` TaskQueueType v11.TaskQueueType `` /* 144-byte string literal not displayed */ FirstPollerTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=first_poller_time,json=firstPollerTime,proto3" json:"first_poller_time,omitempty"` MaxTaskQueues int32 `protobuf:"varint,4,opt,name=max_task_queues,json=maxTaskQueues,proto3" json:"max_task_queues,omitempty"` // contains filtered or unexported fields }
used as deployment workflow update input:
func (*RegisterWorkerInDeploymentArgs) Descriptor
deprecated
func (*RegisterWorkerInDeploymentArgs) Descriptor() ([]byte, []int)
Deprecated: Use RegisterWorkerInDeploymentArgs.ProtoReflect.Descriptor instead.
func (*RegisterWorkerInDeploymentArgs) Equal ¶
func (this *RegisterWorkerInDeploymentArgs) Equal(that interface{}) bool
Equal returns whether two RegisterWorkerInDeploymentArgs 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 (*RegisterWorkerInDeploymentArgs) GetFirstPollerTime ¶
func (x *RegisterWorkerInDeploymentArgs) GetFirstPollerTime() *timestamppb.Timestamp
func (*RegisterWorkerInDeploymentArgs) GetMaxTaskQueues ¶
func (x *RegisterWorkerInDeploymentArgs) GetMaxTaskQueues() int32
func (*RegisterWorkerInDeploymentArgs) GetTaskQueueName ¶
func (x *RegisterWorkerInDeploymentArgs) GetTaskQueueName() string
func (*RegisterWorkerInDeploymentArgs) GetTaskQueueType ¶
func (x *RegisterWorkerInDeploymentArgs) GetTaskQueueType() v11.TaskQueueType
func (*RegisterWorkerInDeploymentArgs) Marshal ¶
func (val *RegisterWorkerInDeploymentArgs) Marshal() ([]byte, error)
Marshal an object of type RegisterWorkerInDeploymentArgs to the protobuf v3 wire format
func (*RegisterWorkerInDeploymentArgs) ProtoMessage ¶
func (*RegisterWorkerInDeploymentArgs) ProtoMessage()
func (*RegisterWorkerInDeploymentArgs) ProtoReflect ¶
func (x *RegisterWorkerInDeploymentArgs) ProtoReflect() protoreflect.Message
func (*RegisterWorkerInDeploymentArgs) Reset ¶
func (x *RegisterWorkerInDeploymentArgs) Reset()
func (*RegisterWorkerInDeploymentArgs) Size ¶
func (val *RegisterWorkerInDeploymentArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*RegisterWorkerInDeploymentArgs) String ¶
func (x *RegisterWorkerInDeploymentArgs) String() string
func (*RegisterWorkerInDeploymentArgs) Unmarshal ¶
func (val *RegisterWorkerInDeploymentArgs) Unmarshal(buf []byte) error
Unmarshal an object of type RegisterWorkerInDeploymentArgs from the protobuf v3 wire format
type RegisterWorkerInVersionArgs ¶ added in v1.27.0
type RegisterWorkerInVersionArgs struct { TaskQueueName string `protobuf:"bytes,1,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"` TaskQueueType v11.TaskQueueType `` /* 144-byte string literal not displayed */ MaxTaskQueues int32 `protobuf:"varint,3,opt,name=max_task_queues,json=maxTaskQueues,proto3" json:"max_task_queues,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow update input:
func (*RegisterWorkerInVersionArgs) Descriptor
deprecated
added in
v1.27.0
func (*RegisterWorkerInVersionArgs) Descriptor() ([]byte, []int)
Deprecated: Use RegisterWorkerInVersionArgs.ProtoReflect.Descriptor instead.
func (*RegisterWorkerInVersionArgs) Equal ¶ added in v1.27.0
func (this *RegisterWorkerInVersionArgs) Equal(that interface{}) bool
Equal returns whether two RegisterWorkerInVersionArgs 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 (*RegisterWorkerInVersionArgs) GetMaxTaskQueues ¶ added in v1.27.0
func (x *RegisterWorkerInVersionArgs) GetMaxTaskQueues() int32
func (*RegisterWorkerInVersionArgs) GetTaskQueueName ¶ added in v1.27.0
func (x *RegisterWorkerInVersionArgs) GetTaskQueueName() string
func (*RegisterWorkerInVersionArgs) GetTaskQueueType ¶ added in v1.27.0
func (x *RegisterWorkerInVersionArgs) GetTaskQueueType() v11.TaskQueueType
func (*RegisterWorkerInVersionArgs) Marshal ¶ added in v1.27.0
func (val *RegisterWorkerInVersionArgs) Marshal() ([]byte, error)
Marshal an object of type RegisterWorkerInVersionArgs to the protobuf v3 wire format
func (*RegisterWorkerInVersionArgs) ProtoMessage ¶ added in v1.27.0
func (*RegisterWorkerInVersionArgs) ProtoMessage()
func (*RegisterWorkerInVersionArgs) ProtoReflect ¶ added in v1.27.0
func (x *RegisterWorkerInVersionArgs) ProtoReflect() protoreflect.Message
func (*RegisterWorkerInVersionArgs) Reset ¶ added in v1.27.0
func (x *RegisterWorkerInVersionArgs) Reset()
func (*RegisterWorkerInVersionArgs) Size ¶ added in v1.27.0
func (val *RegisterWorkerInVersionArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*RegisterWorkerInVersionArgs) String ¶ added in v1.27.0
func (x *RegisterWorkerInVersionArgs) String() string
func (*RegisterWorkerInVersionArgs) Unmarshal ¶ added in v1.27.0
func (val *RegisterWorkerInVersionArgs) Unmarshal(buf []byte) error
Unmarshal an object of type RegisterWorkerInVersionArgs from the protobuf v3 wire format
type SeriesLocalState ¶
type SeriesLocalState struct { CurrentBuildId string `protobuf:"bytes,1,opt,name=current_build_id,json=currentBuildId,proto3" json:"current_build_id,omitempty"` CurrentChangedTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=current_changed_time,json=currentChangedTime,proto3" json:"current_changed_time,omitempty"` // contains filtered or unexported fields }
func (*SeriesLocalState) Descriptor
deprecated
func (*SeriesLocalState) Descriptor() ([]byte, []int)
Deprecated: Use SeriesLocalState.ProtoReflect.Descriptor instead.
func (*SeriesLocalState) Equal ¶
func (this *SeriesLocalState) Equal(that interface{}) bool
Equal returns whether two SeriesLocalState 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 (*SeriesLocalState) GetCurrentBuildId ¶
func (x *SeriesLocalState) GetCurrentBuildId() string
func (*SeriesLocalState) GetCurrentChangedTime ¶
func (x *SeriesLocalState) GetCurrentChangedTime() *timestamppb.Timestamp
func (*SeriesLocalState) Marshal ¶
func (val *SeriesLocalState) Marshal() ([]byte, error)
Marshal an object of type SeriesLocalState to the protobuf v3 wire format
func (*SeriesLocalState) ProtoMessage ¶
func (*SeriesLocalState) ProtoMessage()
func (*SeriesLocalState) ProtoReflect ¶
func (x *SeriesLocalState) ProtoReflect() protoreflect.Message
func (*SeriesLocalState) Reset ¶
func (x *SeriesLocalState) Reset()
func (*SeriesLocalState) Size ¶
func (val *SeriesLocalState) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SeriesLocalState) String ¶
func (x *SeriesLocalState) String() string
func (*SeriesLocalState) Unmarshal ¶
func (val *SeriesLocalState) Unmarshal(buf []byte) error
Unmarshal an object of type SeriesLocalState from the protobuf v3 wire format
type SetCurrentDeploymentArgs ¶
type SetCurrentDeploymentArgs struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"` UpdateMetadata *v1.UpdateDeploymentMetadata `protobuf:"bytes,3,opt,name=update_metadata,json=updateMetadata,proto3" json:"update_metadata,omitempty"` RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
used as deployment series workflow update input:
func (*SetCurrentDeploymentArgs) Descriptor
deprecated
func (*SetCurrentDeploymentArgs) Descriptor() ([]byte, []int)
Deprecated: Use SetCurrentDeploymentArgs.ProtoReflect.Descriptor instead.
func (*SetCurrentDeploymentArgs) Equal ¶
func (this *SetCurrentDeploymentArgs) Equal(that interface{}) bool
Equal returns whether two SetCurrentDeploymentArgs 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 (*SetCurrentDeploymentArgs) GetBuildId ¶
func (x *SetCurrentDeploymentArgs) GetBuildId() string
func (*SetCurrentDeploymentArgs) GetIdentity ¶
func (x *SetCurrentDeploymentArgs) GetIdentity() string
func (*SetCurrentDeploymentArgs) GetRequestId ¶
func (x *SetCurrentDeploymentArgs) GetRequestId() string
func (*SetCurrentDeploymentArgs) GetUpdateMetadata ¶
func (x *SetCurrentDeploymentArgs) GetUpdateMetadata() *v1.UpdateDeploymentMetadata
func (*SetCurrentDeploymentArgs) Marshal ¶
func (val *SetCurrentDeploymentArgs) Marshal() ([]byte, error)
Marshal an object of type SetCurrentDeploymentArgs to the protobuf v3 wire format
func (*SetCurrentDeploymentArgs) ProtoMessage ¶
func (*SetCurrentDeploymentArgs) ProtoMessage()
func (*SetCurrentDeploymentArgs) ProtoReflect ¶
func (x *SetCurrentDeploymentArgs) ProtoReflect() protoreflect.Message
func (*SetCurrentDeploymentArgs) Reset ¶
func (x *SetCurrentDeploymentArgs) Reset()
func (*SetCurrentDeploymentArgs) Size ¶
func (val *SetCurrentDeploymentArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SetCurrentDeploymentArgs) String ¶
func (x *SetCurrentDeploymentArgs) String() string
func (*SetCurrentDeploymentArgs) Unmarshal ¶
func (val *SetCurrentDeploymentArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SetCurrentDeploymentArgs from the protobuf v3 wire format
type SetCurrentDeploymentResponse ¶
type SetCurrentDeploymentResponse struct { CurrentDeploymentState *DeploymentLocalState `` /* 129-byte string literal not displayed */ PreviousDeploymentState *DeploymentLocalState `` /* 132-byte string literal not displayed */ // contains filtered or unexported fields }
used as deployment series update response:
func (*SetCurrentDeploymentResponse) Descriptor
deprecated
func (*SetCurrentDeploymentResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetCurrentDeploymentResponse.ProtoReflect.Descriptor instead.
func (*SetCurrentDeploymentResponse) Equal ¶
func (this *SetCurrentDeploymentResponse) Equal(that interface{}) bool
Equal returns whether two SetCurrentDeploymentResponse 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 (*SetCurrentDeploymentResponse) GetCurrentDeploymentState ¶
func (x *SetCurrentDeploymentResponse) GetCurrentDeploymentState() *DeploymentLocalState
func (*SetCurrentDeploymentResponse) GetPreviousDeploymentState ¶
func (x *SetCurrentDeploymentResponse) GetPreviousDeploymentState() *DeploymentLocalState
func (*SetCurrentDeploymentResponse) Marshal ¶
func (val *SetCurrentDeploymentResponse) Marshal() ([]byte, error)
Marshal an object of type SetCurrentDeploymentResponse to the protobuf v3 wire format
func (*SetCurrentDeploymentResponse) ProtoMessage ¶
func (*SetCurrentDeploymentResponse) ProtoMessage()
func (*SetCurrentDeploymentResponse) ProtoReflect ¶
func (x *SetCurrentDeploymentResponse) ProtoReflect() protoreflect.Message
func (*SetCurrentDeploymentResponse) Reset ¶
func (x *SetCurrentDeploymentResponse) Reset()
func (*SetCurrentDeploymentResponse) Size ¶
func (val *SetCurrentDeploymentResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SetCurrentDeploymentResponse) String ¶
func (x *SetCurrentDeploymentResponse) String() string
func (*SetCurrentDeploymentResponse) Unmarshal ¶
func (val *SetCurrentDeploymentResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SetCurrentDeploymentResponse from the protobuf v3 wire format
type SetCurrentVersionArgs ¶ added in v1.27.0
type SetCurrentVersionArgs struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` IgnoreMissingTaskQueues bool `` /* 135-byte string literal not displayed */ ConflictToken []byte `protobuf:"bytes,4,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow update input:
func (*SetCurrentVersionArgs) Descriptor
deprecated
added in
v1.27.0
func (*SetCurrentVersionArgs) Descriptor() ([]byte, []int)
Deprecated: Use SetCurrentVersionArgs.ProtoReflect.Descriptor instead.
func (*SetCurrentVersionArgs) Equal ¶ added in v1.27.0
func (this *SetCurrentVersionArgs) Equal(that interface{}) bool
Equal returns whether two SetCurrentVersionArgs 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 (*SetCurrentVersionArgs) GetConflictToken ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) GetConflictToken() []byte
func (*SetCurrentVersionArgs) GetIdentity ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) GetIdentity() string
func (*SetCurrentVersionArgs) GetIgnoreMissingTaskQueues ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) GetIgnoreMissingTaskQueues() bool
func (*SetCurrentVersionArgs) GetVersion ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) GetVersion() string
func (*SetCurrentVersionArgs) Marshal ¶ added in v1.27.0
func (val *SetCurrentVersionArgs) Marshal() ([]byte, error)
Marshal an object of type SetCurrentVersionArgs to the protobuf v3 wire format
func (*SetCurrentVersionArgs) ProtoMessage ¶ added in v1.27.0
func (*SetCurrentVersionArgs) ProtoMessage()
func (*SetCurrentVersionArgs) ProtoReflect ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) ProtoReflect() protoreflect.Message
func (*SetCurrentVersionArgs) Reset ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) Reset()
func (*SetCurrentVersionArgs) Size ¶ added in v1.27.0
func (val *SetCurrentVersionArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SetCurrentVersionArgs) String ¶ added in v1.27.0
func (x *SetCurrentVersionArgs) String() string
func (*SetCurrentVersionArgs) Unmarshal ¶ added in v1.27.0
func (val *SetCurrentVersionArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SetCurrentVersionArgs from the protobuf v3 wire format
type SetCurrentVersionResponse ¶ added in v1.27.0
type SetCurrentVersionResponse struct { PreviousVersion string `protobuf:"bytes,1,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` ConflictToken []byte `protobuf:"bytes,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment update response:
func (*SetCurrentVersionResponse) Descriptor
deprecated
added in
v1.27.0
func (*SetCurrentVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetCurrentVersionResponse.ProtoReflect.Descriptor instead.
func (*SetCurrentVersionResponse) Equal ¶ added in v1.27.0
func (this *SetCurrentVersionResponse) Equal(that interface{}) bool
Equal returns whether two SetCurrentVersionResponse 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 (*SetCurrentVersionResponse) GetConflictToken ¶ added in v1.27.0
func (x *SetCurrentVersionResponse) GetConflictToken() []byte
func (*SetCurrentVersionResponse) GetPreviousVersion ¶ added in v1.27.0
func (x *SetCurrentVersionResponse) GetPreviousVersion() string
func (*SetCurrentVersionResponse) Marshal ¶ added in v1.27.0
func (val *SetCurrentVersionResponse) Marshal() ([]byte, error)
Marshal an object of type SetCurrentVersionResponse to the protobuf v3 wire format
func (*SetCurrentVersionResponse) ProtoMessage ¶ added in v1.27.0
func (*SetCurrentVersionResponse) ProtoMessage()
func (*SetCurrentVersionResponse) ProtoReflect ¶ added in v1.27.0
func (x *SetCurrentVersionResponse) ProtoReflect() protoreflect.Message
func (*SetCurrentVersionResponse) Reset ¶ added in v1.27.0
func (x *SetCurrentVersionResponse) Reset()
func (*SetCurrentVersionResponse) Size ¶ added in v1.27.0
func (val *SetCurrentVersionResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SetCurrentVersionResponse) String ¶ added in v1.27.0
func (x *SetCurrentVersionResponse) String() string
func (*SetCurrentVersionResponse) Unmarshal ¶ added in v1.27.0
func (val *SetCurrentVersionResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SetCurrentVersionResponse from the protobuf v3 wire format
type SetRampingVersionArgs ¶ added in v1.27.0
type SetRampingVersionArgs struct { Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Percentage float32 `protobuf:"fixed32,3,opt,name=percentage,proto3" json:"percentage,omitempty"` IgnoreMissingTaskQueues bool `` /* 135-byte string literal not displayed */ ConflictToken []byte `protobuf:"bytes,5,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow update input:
func (*SetRampingVersionArgs) Descriptor
deprecated
added in
v1.27.0
func (*SetRampingVersionArgs) Descriptor() ([]byte, []int)
Deprecated: Use SetRampingVersionArgs.ProtoReflect.Descriptor instead.
func (*SetRampingVersionArgs) Equal ¶ added in v1.27.0
func (this *SetRampingVersionArgs) Equal(that interface{}) bool
Equal returns whether two SetRampingVersionArgs 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 (*SetRampingVersionArgs) GetConflictToken ¶ added in v1.27.0
func (x *SetRampingVersionArgs) GetConflictToken() []byte
func (*SetRampingVersionArgs) GetIdentity ¶ added in v1.27.0
func (x *SetRampingVersionArgs) GetIdentity() string
func (*SetRampingVersionArgs) GetIgnoreMissingTaskQueues ¶ added in v1.27.0
func (x *SetRampingVersionArgs) GetIgnoreMissingTaskQueues() bool
func (*SetRampingVersionArgs) GetPercentage ¶ added in v1.27.0
func (x *SetRampingVersionArgs) GetPercentage() float32
func (*SetRampingVersionArgs) GetVersion ¶ added in v1.27.0
func (x *SetRampingVersionArgs) GetVersion() string
func (*SetRampingVersionArgs) Marshal ¶ added in v1.27.0
func (val *SetRampingVersionArgs) Marshal() ([]byte, error)
Marshal an object of type SetRampingVersionArgs to the protobuf v3 wire format
func (*SetRampingVersionArgs) ProtoMessage ¶ added in v1.27.0
func (*SetRampingVersionArgs) ProtoMessage()
func (*SetRampingVersionArgs) ProtoReflect ¶ added in v1.27.0
func (x *SetRampingVersionArgs) ProtoReflect() protoreflect.Message
func (*SetRampingVersionArgs) Reset ¶ added in v1.27.0
func (x *SetRampingVersionArgs) Reset()
func (*SetRampingVersionArgs) Size ¶ added in v1.27.0
func (val *SetRampingVersionArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SetRampingVersionArgs) String ¶ added in v1.27.0
func (x *SetRampingVersionArgs) String() string
func (*SetRampingVersionArgs) Unmarshal ¶ added in v1.27.0
func (val *SetRampingVersionArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SetRampingVersionArgs from the protobuf v3 wire format
type SetRampingVersionResponse ¶ added in v1.27.0
type SetRampingVersionResponse struct { PreviousVersion string `protobuf:"bytes,1,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"` PreviousPercentage float32 `protobuf:"fixed32,2,opt,name=previous_percentage,json=previousPercentage,proto3" json:"previous_percentage,omitempty"` ConflictToken []byte `protobuf:"bytes,3,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment update response:
func (*SetRampingVersionResponse) Descriptor
deprecated
added in
v1.27.0
func (*SetRampingVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetRampingVersionResponse.ProtoReflect.Descriptor instead.
func (*SetRampingVersionResponse) Equal ¶ added in v1.27.0
func (this *SetRampingVersionResponse) Equal(that interface{}) bool
Equal returns whether two SetRampingVersionResponse 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 (*SetRampingVersionResponse) GetConflictToken ¶ added in v1.27.0
func (x *SetRampingVersionResponse) GetConflictToken() []byte
func (*SetRampingVersionResponse) GetPreviousPercentage ¶ added in v1.27.0
func (x *SetRampingVersionResponse) GetPreviousPercentage() float32
func (*SetRampingVersionResponse) GetPreviousVersion ¶ added in v1.27.0
func (x *SetRampingVersionResponse) GetPreviousVersion() string
func (*SetRampingVersionResponse) Marshal ¶ added in v1.27.0
func (val *SetRampingVersionResponse) Marshal() ([]byte, error)
Marshal an object of type SetRampingVersionResponse to the protobuf v3 wire format
func (*SetRampingVersionResponse) ProtoMessage ¶ added in v1.27.0
func (*SetRampingVersionResponse) ProtoMessage()
func (*SetRampingVersionResponse) ProtoReflect ¶ added in v1.27.0
func (x *SetRampingVersionResponse) ProtoReflect() protoreflect.Message
func (*SetRampingVersionResponse) Reset ¶ added in v1.27.0
func (x *SetRampingVersionResponse) Reset()
func (*SetRampingVersionResponse) Size ¶ added in v1.27.0
func (val *SetRampingVersionResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SetRampingVersionResponse) String ¶ added in v1.27.0
func (x *SetRampingVersionResponse) String() string
func (*SetRampingVersionResponse) Unmarshal ¶ added in v1.27.0
func (val *SetRampingVersionResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SetRampingVersionResponse from the protobuf v3 wire format
type StartDeploymentSeriesRequest ¶
type StartDeploymentSeriesRequest struct { SeriesName string `protobuf:"bytes,1,opt,name=series_name,json=seriesName,proto3" json:"series_name,omitempty"` RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
used as deployment workflow activity input:
func (*StartDeploymentSeriesRequest) Descriptor
deprecated
func (*StartDeploymentSeriesRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartDeploymentSeriesRequest.ProtoReflect.Descriptor instead.
func (*StartDeploymentSeriesRequest) Equal ¶
func (this *StartDeploymentSeriesRequest) Equal(that interface{}) bool
Equal returns whether two StartDeploymentSeriesRequest 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 (*StartDeploymentSeriesRequest) GetRequestId ¶
func (x *StartDeploymentSeriesRequest) GetRequestId() string
func (*StartDeploymentSeriesRequest) GetSeriesName ¶
func (x *StartDeploymentSeriesRequest) GetSeriesName() string
func (*StartDeploymentSeriesRequest) Marshal ¶
func (val *StartDeploymentSeriesRequest) Marshal() ([]byte, error)
Marshal an object of type StartDeploymentSeriesRequest to the protobuf v3 wire format
func (*StartDeploymentSeriesRequest) ProtoMessage ¶
func (*StartDeploymentSeriesRequest) ProtoMessage()
func (*StartDeploymentSeriesRequest) ProtoReflect ¶
func (x *StartDeploymentSeriesRequest) ProtoReflect() protoreflect.Message
func (*StartDeploymentSeriesRequest) Reset ¶
func (x *StartDeploymentSeriesRequest) Reset()
func (*StartDeploymentSeriesRequest) Size ¶
func (val *StartDeploymentSeriesRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*StartDeploymentSeriesRequest) String ¶
func (x *StartDeploymentSeriesRequest) String() string
func (*StartDeploymentSeriesRequest) Unmarshal ¶
func (val *StartDeploymentSeriesRequest) Unmarshal(buf []byte) error
Unmarshal an object of type StartDeploymentSeriesRequest from the protobuf v3 wire format
type StartWorkerDeploymentRequest ¶ added in v1.27.0
type StartWorkerDeploymentRequest struct { DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow activity input:
func (*StartWorkerDeploymentRequest) Descriptor
deprecated
added in
v1.27.0
func (*StartWorkerDeploymentRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartWorkerDeploymentRequest.ProtoReflect.Descriptor instead.
func (*StartWorkerDeploymentRequest) Equal ¶ added in v1.27.0
func (this *StartWorkerDeploymentRequest) Equal(that interface{}) bool
Equal returns whether two StartWorkerDeploymentRequest 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 (*StartWorkerDeploymentRequest) GetDeploymentName ¶ added in v1.27.0
func (x *StartWorkerDeploymentRequest) GetDeploymentName() string
func (*StartWorkerDeploymentRequest) GetRequestId ¶ added in v1.27.0
func (x *StartWorkerDeploymentRequest) GetRequestId() string
func (*StartWorkerDeploymentRequest) Marshal ¶ added in v1.27.0
func (val *StartWorkerDeploymentRequest) Marshal() ([]byte, error)
Marshal an object of type StartWorkerDeploymentRequest to the protobuf v3 wire format
func (*StartWorkerDeploymentRequest) ProtoMessage ¶ added in v1.27.0
func (*StartWorkerDeploymentRequest) ProtoMessage()
func (*StartWorkerDeploymentRequest) ProtoReflect ¶ added in v1.27.0
func (x *StartWorkerDeploymentRequest) ProtoReflect() protoreflect.Message
func (*StartWorkerDeploymentRequest) Reset ¶ added in v1.27.0
func (x *StartWorkerDeploymentRequest) Reset()
func (*StartWorkerDeploymentRequest) Size ¶ added in v1.27.0
func (val *StartWorkerDeploymentRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*StartWorkerDeploymentRequest) String ¶ added in v1.27.0
func (x *StartWorkerDeploymentRequest) String() string
func (*StartWorkerDeploymentRequest) Unmarshal ¶ added in v1.27.0
func (val *StartWorkerDeploymentRequest) Unmarshal(buf []byte) error
Unmarshal an object of type StartWorkerDeploymentRequest from the protobuf v3 wire format
type SyncDeploymentStateActivityArgs ¶
type SyncDeploymentStateActivityArgs struct { Deployment *v1.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"` Args *SyncDeploymentStateArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"` RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
used as deployment series activity input:
func (*SyncDeploymentStateActivityArgs) Descriptor
deprecated
func (*SyncDeploymentStateActivityArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentStateActivityArgs.ProtoReflect.Descriptor instead.
func (*SyncDeploymentStateActivityArgs) Equal ¶
func (this *SyncDeploymentStateActivityArgs) Equal(that interface{}) bool
Equal returns whether two SyncDeploymentStateActivityArgs 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 (*SyncDeploymentStateActivityArgs) GetArgs ¶
func (x *SyncDeploymentStateActivityArgs) GetArgs() *SyncDeploymentStateArgs
func (*SyncDeploymentStateActivityArgs) GetDeployment ¶
func (x *SyncDeploymentStateActivityArgs) GetDeployment() *v1.Deployment
func (*SyncDeploymentStateActivityArgs) GetRequestId ¶
func (x *SyncDeploymentStateActivityArgs) GetRequestId() string
func (*SyncDeploymentStateActivityArgs) Marshal ¶
func (val *SyncDeploymentStateActivityArgs) Marshal() ([]byte, error)
Marshal an object of type SyncDeploymentStateActivityArgs to the protobuf v3 wire format
func (*SyncDeploymentStateActivityArgs) ProtoMessage ¶
func (*SyncDeploymentStateActivityArgs) ProtoMessage()
func (*SyncDeploymentStateActivityArgs) ProtoReflect ¶
func (x *SyncDeploymentStateActivityArgs) ProtoReflect() protoreflect.Message
func (*SyncDeploymentStateActivityArgs) Reset ¶
func (x *SyncDeploymentStateActivityArgs) Reset()
func (*SyncDeploymentStateActivityArgs) Size ¶
func (val *SyncDeploymentStateActivityArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDeploymentStateActivityArgs) String ¶
func (x *SyncDeploymentStateActivityArgs) String() string
func (*SyncDeploymentStateActivityArgs) Unmarshal ¶
func (val *SyncDeploymentStateActivityArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDeploymentStateActivityArgs from the protobuf v3 wire format
type SyncDeploymentStateActivityResult ¶
type SyncDeploymentStateActivityResult struct { State *DeploymentLocalState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
used as deployment series activity result:
func (*SyncDeploymentStateActivityResult) Descriptor
deprecated
func (*SyncDeploymentStateActivityResult) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentStateActivityResult.ProtoReflect.Descriptor instead.
func (*SyncDeploymentStateActivityResult) Equal ¶
func (this *SyncDeploymentStateActivityResult) Equal(that interface{}) bool
Equal returns whether two SyncDeploymentStateActivityResult 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 (*SyncDeploymentStateActivityResult) GetState ¶
func (x *SyncDeploymentStateActivityResult) GetState() *DeploymentLocalState
func (*SyncDeploymentStateActivityResult) Marshal ¶
func (val *SyncDeploymentStateActivityResult) Marshal() ([]byte, error)
Marshal an object of type SyncDeploymentStateActivityResult to the protobuf v3 wire format
func (*SyncDeploymentStateActivityResult) ProtoMessage ¶
func (*SyncDeploymentStateActivityResult) ProtoMessage()
func (*SyncDeploymentStateActivityResult) ProtoReflect ¶
func (x *SyncDeploymentStateActivityResult) ProtoReflect() protoreflect.Message
func (*SyncDeploymentStateActivityResult) Reset ¶
func (x *SyncDeploymentStateActivityResult) Reset()
func (*SyncDeploymentStateActivityResult) Size ¶
func (val *SyncDeploymentStateActivityResult) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDeploymentStateActivityResult) String ¶
func (x *SyncDeploymentStateActivityResult) String() string
func (*SyncDeploymentStateActivityResult) Unmarshal ¶
func (val *SyncDeploymentStateActivityResult) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDeploymentStateActivityResult from the protobuf v3 wire format
type SyncDeploymentStateArgs ¶
type SyncDeploymentStateArgs struct { SetCurrent *SyncDeploymentStateArgs_SetCurrent `protobuf:"bytes,1,opt,name=set_current,json=setCurrent,proto3" json:"set_current,omitempty"` // currently, update_metadata will only be set if set_current.last_became_current_time is // present. this could change in the future. UpdateMetadata *v1.UpdateDeploymentMetadata `protobuf:"bytes,2,opt,name=update_metadata,json=updateMetadata,proto3" json:"update_metadata,omitempty"` // contains filtered or unexported fields }
used as deployment series workflow update input (sent from series workflow):
func (*SyncDeploymentStateArgs) Descriptor
deprecated
func (*SyncDeploymentStateArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentStateArgs.ProtoReflect.Descriptor instead.
func (*SyncDeploymentStateArgs) Equal ¶
func (this *SyncDeploymentStateArgs) Equal(that interface{}) bool
Equal returns whether two SyncDeploymentStateArgs 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 (*SyncDeploymentStateArgs) GetSetCurrent ¶
func (x *SyncDeploymentStateArgs) GetSetCurrent() *SyncDeploymentStateArgs_SetCurrent
func (*SyncDeploymentStateArgs) GetUpdateMetadata ¶
func (x *SyncDeploymentStateArgs) GetUpdateMetadata() *v1.UpdateDeploymentMetadata
func (*SyncDeploymentStateArgs) Marshal ¶
func (val *SyncDeploymentStateArgs) Marshal() ([]byte, error)
Marshal an object of type SyncDeploymentStateArgs to the protobuf v3 wire format
func (*SyncDeploymentStateArgs) ProtoMessage ¶
func (*SyncDeploymentStateArgs) ProtoMessage()
func (*SyncDeploymentStateArgs) ProtoReflect ¶
func (x *SyncDeploymentStateArgs) ProtoReflect() protoreflect.Message
func (*SyncDeploymentStateArgs) Reset ¶
func (x *SyncDeploymentStateArgs) Reset()
func (*SyncDeploymentStateArgs) Size ¶
func (val *SyncDeploymentStateArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDeploymentStateArgs) String ¶
func (x *SyncDeploymentStateArgs) String() string
func (*SyncDeploymentStateArgs) Unmarshal ¶
func (val *SyncDeploymentStateArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDeploymentStateArgs from the protobuf v3 wire format
type SyncDeploymentStateArgs_SetCurrent ¶
type SyncDeploymentStateArgs_SetCurrent struct { // If last_became_current_time is present, then set the deployment's // last_became_current_time to it and set is_current true. If it's missing, // set is_current false. LastBecameCurrentTime *timestamppb.Timestamp `` /* 128-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SyncDeploymentStateArgs_SetCurrent) Descriptor
deprecated
func (*SyncDeploymentStateArgs_SetCurrent) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentStateArgs_SetCurrent.ProtoReflect.Descriptor instead.
func (*SyncDeploymentStateArgs_SetCurrent) GetLastBecameCurrentTime ¶
func (x *SyncDeploymentStateArgs_SetCurrent) GetLastBecameCurrentTime() *timestamppb.Timestamp
func (*SyncDeploymentStateArgs_SetCurrent) ProtoMessage ¶
func (*SyncDeploymentStateArgs_SetCurrent) ProtoMessage()
func (*SyncDeploymentStateArgs_SetCurrent) ProtoReflect ¶
func (x *SyncDeploymentStateArgs_SetCurrent) ProtoReflect() protoreflect.Message
func (*SyncDeploymentStateArgs_SetCurrent) Reset ¶
func (x *SyncDeploymentStateArgs_SetCurrent) Reset()
func (*SyncDeploymentStateArgs_SetCurrent) String ¶
func (x *SyncDeploymentStateArgs_SetCurrent) String() string
type SyncDeploymentStateResponse ¶
type SyncDeploymentStateResponse struct { DeploymentLocalState *DeploymentLocalState `protobuf:"bytes,1,opt,name=deployment_local_state,json=deploymentLocalState,proto3" json:"deployment_local_state,omitempty"` // contains filtered or unexported fields }
used as deployment series workflow update response (sent from series workflow):
func (*SyncDeploymentStateResponse) Descriptor
deprecated
func (*SyncDeploymentStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentStateResponse.ProtoReflect.Descriptor instead.
func (*SyncDeploymentStateResponse) Equal ¶
func (this *SyncDeploymentStateResponse) Equal(that interface{}) bool
Equal returns whether two SyncDeploymentStateResponse 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 (*SyncDeploymentStateResponse) GetDeploymentLocalState ¶
func (x *SyncDeploymentStateResponse) GetDeploymentLocalState() *DeploymentLocalState
func (*SyncDeploymentStateResponse) Marshal ¶
func (val *SyncDeploymentStateResponse) Marshal() ([]byte, error)
Marshal an object of type SyncDeploymentStateResponse to the protobuf v3 wire format
func (*SyncDeploymentStateResponse) ProtoMessage ¶
func (*SyncDeploymentStateResponse) ProtoMessage()
func (*SyncDeploymentStateResponse) ProtoReflect ¶
func (x *SyncDeploymentStateResponse) ProtoReflect() protoreflect.Message
func (*SyncDeploymentStateResponse) Reset ¶
func (x *SyncDeploymentStateResponse) Reset()
func (*SyncDeploymentStateResponse) Size ¶
func (val *SyncDeploymentStateResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDeploymentStateResponse) String ¶
func (x *SyncDeploymentStateResponse) String() string
func (*SyncDeploymentStateResponse) Unmarshal ¶
func (val *SyncDeploymentStateResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDeploymentStateResponse from the protobuf v3 wire format
type SyncDeploymentVersionUserDataRequest ¶ added in v1.27.0
type SyncDeploymentVersionUserDataRequest struct { Version *WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` Sync []*SyncDeploymentVersionUserDataRequest_SyncUserData `protobuf:"bytes,2,rep,name=sync,proto3" json:"sync,omitempty"` // if true, the version will be forgotten from the task queue user data. ForgetVersion bool `protobuf:"varint,3,opt,name=forget_version,json=forgetVersion,proto3" json:"forget_version,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow activity input:
func (*SyncDeploymentVersionUserDataRequest) Descriptor
deprecated
added in
v1.27.0
func (*SyncDeploymentVersionUserDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentVersionUserDataRequest.ProtoReflect.Descriptor instead.
func (*SyncDeploymentVersionUserDataRequest) Equal ¶ added in v1.27.0
func (this *SyncDeploymentVersionUserDataRequest) Equal(that interface{}) bool
Equal returns whether two SyncDeploymentVersionUserDataRequest 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 (*SyncDeploymentVersionUserDataRequest) GetForgetVersion ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest) GetForgetVersion() bool
func (*SyncDeploymentVersionUserDataRequest) GetSync ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest) GetSync() []*SyncDeploymentVersionUserDataRequest_SyncUserData
func (*SyncDeploymentVersionUserDataRequest) GetVersion ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest) GetVersion() *WorkerDeploymentVersion
func (*SyncDeploymentVersionUserDataRequest) Marshal ¶ added in v1.27.0
func (val *SyncDeploymentVersionUserDataRequest) Marshal() ([]byte, error)
Marshal an object of type SyncDeploymentVersionUserDataRequest to the protobuf v3 wire format
func (*SyncDeploymentVersionUserDataRequest) ProtoMessage ¶ added in v1.27.0
func (*SyncDeploymentVersionUserDataRequest) ProtoMessage()
func (*SyncDeploymentVersionUserDataRequest) ProtoReflect ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest) ProtoReflect() protoreflect.Message
func (*SyncDeploymentVersionUserDataRequest) Reset ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest) Reset()
func (*SyncDeploymentVersionUserDataRequest) Size ¶ added in v1.27.0
func (val *SyncDeploymentVersionUserDataRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDeploymentVersionUserDataRequest) String ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest) String() string
func (*SyncDeploymentVersionUserDataRequest) Unmarshal ¶ added in v1.27.0
func (val *SyncDeploymentVersionUserDataRequest) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDeploymentVersionUserDataRequest from the protobuf v3 wire format
type SyncDeploymentVersionUserDataRequest_SyncUserData ¶ added in v1.27.0
type SyncDeploymentVersionUserDataRequest_SyncUserData struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Types []v11.TaskQueueType `protobuf:"varint,2,rep,packed,name=types,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"types,omitempty"` Data *DeploymentVersionData `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Descriptor
deprecated
added in
v1.27.0
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentVersionUserDataRequest_SyncUserData.ProtoReflect.Descriptor instead.
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) GetData ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetData() *DeploymentVersionData
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) GetName ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetName() string
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes() []v11.TaskQueueType
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage ¶ added in v1.27.0
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage()
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoReflect ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoReflect() protoreflect.Message
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Reset ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) Reset()
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) String ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) String() string
type SyncDeploymentVersionUserDataResponse ¶ added in v1.27.0
type SyncDeploymentVersionUserDataResponse struct { TaskQueueMaxVersions map[string]int64 `` /* 214-byte string literal not displayed */ // contains filtered or unexported fields }
used as Worker Deployment Version workflow activity output:
func (*SyncDeploymentVersionUserDataResponse) Descriptor
deprecated
added in
v1.27.0
func (*SyncDeploymentVersionUserDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncDeploymentVersionUserDataResponse.ProtoReflect.Descriptor instead.
func (*SyncDeploymentVersionUserDataResponse) Equal ¶ added in v1.27.0
func (this *SyncDeploymentVersionUserDataResponse) Equal(that interface{}) bool
Equal returns whether two SyncDeploymentVersionUserDataResponse 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 (*SyncDeploymentVersionUserDataResponse) GetTaskQueueMaxVersions ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataResponse) GetTaskQueueMaxVersions() map[string]int64
func (*SyncDeploymentVersionUserDataResponse) Marshal ¶ added in v1.27.0
func (val *SyncDeploymentVersionUserDataResponse) Marshal() ([]byte, error)
Marshal an object of type SyncDeploymentVersionUserDataResponse to the protobuf v3 wire format
func (*SyncDeploymentVersionUserDataResponse) ProtoMessage ¶ added in v1.27.0
func (*SyncDeploymentVersionUserDataResponse) ProtoMessage()
func (*SyncDeploymentVersionUserDataResponse) ProtoReflect ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataResponse) ProtoReflect() protoreflect.Message
func (*SyncDeploymentVersionUserDataResponse) Reset ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataResponse) Reset()
func (*SyncDeploymentVersionUserDataResponse) Size ¶ added in v1.27.0
func (val *SyncDeploymentVersionUserDataResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDeploymentVersionUserDataResponse) String ¶ added in v1.27.0
func (x *SyncDeploymentVersionUserDataResponse) String() string
func (*SyncDeploymentVersionUserDataResponse) Unmarshal ¶ added in v1.27.0
func (val *SyncDeploymentVersionUserDataResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDeploymentVersionUserDataResponse from the protobuf v3 wire format
type SyncDrainageInfoSignalArgs ¶ added in v1.27.0
type SyncDrainageInfoSignalArgs struct { DrainageInfo *v1.VersionDrainageInfo `protobuf:"bytes,1,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"` // contains filtered or unexported fields }
Sent from Drainage child workflow to Version parent
func (*SyncDrainageInfoSignalArgs) Descriptor
deprecated
added in
v1.27.0
func (*SyncDrainageInfoSignalArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncDrainageInfoSignalArgs.ProtoReflect.Descriptor instead.
func (*SyncDrainageInfoSignalArgs) Equal ¶ added in v1.27.0
func (this *SyncDrainageInfoSignalArgs) Equal(that interface{}) bool
Equal returns whether two SyncDrainageInfoSignalArgs 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 (*SyncDrainageInfoSignalArgs) GetDrainageInfo ¶ added in v1.27.0
func (x *SyncDrainageInfoSignalArgs) GetDrainageInfo() *v1.VersionDrainageInfo
func (*SyncDrainageInfoSignalArgs) Marshal ¶ added in v1.27.0
func (val *SyncDrainageInfoSignalArgs) Marshal() ([]byte, error)
Marshal an object of type SyncDrainageInfoSignalArgs to the protobuf v3 wire format
func (*SyncDrainageInfoSignalArgs) ProtoMessage ¶ added in v1.27.0
func (*SyncDrainageInfoSignalArgs) ProtoMessage()
func (*SyncDrainageInfoSignalArgs) ProtoReflect ¶ added in v1.27.0
func (x *SyncDrainageInfoSignalArgs) ProtoReflect() protoreflect.Message
func (*SyncDrainageInfoSignalArgs) Reset ¶ added in v1.27.0
func (x *SyncDrainageInfoSignalArgs) Reset()
func (*SyncDrainageInfoSignalArgs) Size ¶ added in v1.27.0
func (val *SyncDrainageInfoSignalArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDrainageInfoSignalArgs) String ¶ added in v1.27.0
func (x *SyncDrainageInfoSignalArgs) String() string
func (*SyncDrainageInfoSignalArgs) Unmarshal ¶ added in v1.27.0
func (val *SyncDrainageInfoSignalArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDrainageInfoSignalArgs from the protobuf v3 wire format
type SyncDrainageStatusSignalArgs ¶ added in v1.27.0
type SyncDrainageStatusSignalArgs struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` DrainageStatus v11.VersionDrainageStatus `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Sent from Version workflow to Worker Deployment workflow
func (*SyncDrainageStatusSignalArgs) Descriptor
deprecated
added in
v1.27.0
func (*SyncDrainageStatusSignalArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncDrainageStatusSignalArgs.ProtoReflect.Descriptor instead.
func (*SyncDrainageStatusSignalArgs) Equal ¶ added in v1.27.0
func (this *SyncDrainageStatusSignalArgs) Equal(that interface{}) bool
Equal returns whether two SyncDrainageStatusSignalArgs 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 (*SyncDrainageStatusSignalArgs) GetDrainageStatus ¶ added in v1.27.0
func (x *SyncDrainageStatusSignalArgs) GetDrainageStatus() v11.VersionDrainageStatus
func (*SyncDrainageStatusSignalArgs) GetVersion ¶ added in v1.27.0
func (x *SyncDrainageStatusSignalArgs) GetVersion() string
func (*SyncDrainageStatusSignalArgs) Marshal ¶ added in v1.27.0
func (val *SyncDrainageStatusSignalArgs) Marshal() ([]byte, error)
Marshal an object of type SyncDrainageStatusSignalArgs to the protobuf v3 wire format
func (*SyncDrainageStatusSignalArgs) ProtoMessage ¶ added in v1.27.0
func (*SyncDrainageStatusSignalArgs) ProtoMessage()
func (*SyncDrainageStatusSignalArgs) ProtoReflect ¶ added in v1.27.0
func (x *SyncDrainageStatusSignalArgs) ProtoReflect() protoreflect.Message
func (*SyncDrainageStatusSignalArgs) Reset ¶ added in v1.27.0
func (x *SyncDrainageStatusSignalArgs) Reset()
func (*SyncDrainageStatusSignalArgs) Size ¶ added in v1.27.0
func (val *SyncDrainageStatusSignalArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncDrainageStatusSignalArgs) String ¶ added in v1.27.0
func (x *SyncDrainageStatusSignalArgs) String() string
func (*SyncDrainageStatusSignalArgs) Unmarshal ¶ added in v1.27.0
func (val *SyncDrainageStatusSignalArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncDrainageStatusSignalArgs from the protobuf v3 wire format
type SyncUnversionedRampActivityArgs ¶ added in v1.27.0
type SyncUnversionedRampActivityArgs struct { CurrentVersion string `protobuf:"bytes,1,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"` UpdateArgs *SyncVersionStateUpdateArgs `protobuf:"bytes,2,opt,name=update_args,json=updateArgs,proto3" json:"update_args,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow activity input:
func (*SyncUnversionedRampActivityArgs) Descriptor
deprecated
added in
v1.27.0
func (*SyncUnversionedRampActivityArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncUnversionedRampActivityArgs.ProtoReflect.Descriptor instead.
func (*SyncUnversionedRampActivityArgs) Equal ¶ added in v1.27.0
func (this *SyncUnversionedRampActivityArgs) Equal(that interface{}) bool
Equal returns whether two SyncUnversionedRampActivityArgs 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 (*SyncUnversionedRampActivityArgs) GetCurrentVersion ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityArgs) GetCurrentVersion() string
func (*SyncUnversionedRampActivityArgs) GetUpdateArgs ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs
func (*SyncUnversionedRampActivityArgs) Marshal ¶ added in v1.27.0
func (val *SyncUnversionedRampActivityArgs) Marshal() ([]byte, error)
Marshal an object of type SyncUnversionedRampActivityArgs to the protobuf v3 wire format
func (*SyncUnversionedRampActivityArgs) ProtoMessage ¶ added in v1.27.0
func (*SyncUnversionedRampActivityArgs) ProtoMessage()
func (*SyncUnversionedRampActivityArgs) ProtoReflect ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityArgs) ProtoReflect() protoreflect.Message
func (*SyncUnversionedRampActivityArgs) Reset ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityArgs) Reset()
func (*SyncUnversionedRampActivityArgs) Size ¶ added in v1.27.0
func (val *SyncUnversionedRampActivityArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncUnversionedRampActivityArgs) String ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityArgs) String() string
func (*SyncUnversionedRampActivityArgs) Unmarshal ¶ added in v1.27.0
func (val *SyncUnversionedRampActivityArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncUnversionedRampActivityArgs from the protobuf v3 wire format
type SyncUnversionedRampActivityResponse ¶ added in v1.27.0
type SyncUnversionedRampActivityResponse struct { TaskQueueMaxVersions map[string]int64 `` /* 214-byte string literal not displayed */ // contains filtered or unexported fields }
used as Worker Deployment workflow activity output:
func (*SyncUnversionedRampActivityResponse) Descriptor
deprecated
added in
v1.27.0
func (*SyncUnversionedRampActivityResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncUnversionedRampActivityResponse.ProtoReflect.Descriptor instead.
func (*SyncUnversionedRampActivityResponse) Equal ¶ added in v1.27.0
func (this *SyncUnversionedRampActivityResponse) Equal(that interface{}) bool
Equal returns whether two SyncUnversionedRampActivityResponse 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 (*SyncUnversionedRampActivityResponse) GetTaskQueueMaxVersions ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityResponse) GetTaskQueueMaxVersions() map[string]int64
func (*SyncUnversionedRampActivityResponse) Marshal ¶ added in v1.27.0
func (val *SyncUnversionedRampActivityResponse) Marshal() ([]byte, error)
Marshal an object of type SyncUnversionedRampActivityResponse to the protobuf v3 wire format
func (*SyncUnversionedRampActivityResponse) ProtoMessage ¶ added in v1.27.0
func (*SyncUnversionedRampActivityResponse) ProtoMessage()
func (*SyncUnversionedRampActivityResponse) ProtoReflect ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityResponse) ProtoReflect() protoreflect.Message
func (*SyncUnversionedRampActivityResponse) Reset ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityResponse) Reset()
func (*SyncUnversionedRampActivityResponse) Size ¶ added in v1.27.0
func (val *SyncUnversionedRampActivityResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncUnversionedRampActivityResponse) String ¶ added in v1.27.0
func (x *SyncUnversionedRampActivityResponse) String() string
func (*SyncUnversionedRampActivityResponse) Unmarshal ¶ added in v1.27.0
func (val *SyncUnversionedRampActivityResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SyncUnversionedRampActivityResponse from the protobuf v3 wire format
type SyncUserDataRequest ¶
type SyncUserDataRequest struct { Deployment *v1.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"` Sync []*SyncUserDataRequest_SyncUserData `protobuf:"bytes,2,rep,name=sync,proto3" json:"sync,omitempty"` // contains filtered or unexported fields }
used as deployment workflow activity input:
func (*SyncUserDataRequest) Descriptor
deprecated
func (*SyncUserDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncUserDataRequest.ProtoReflect.Descriptor instead.
func (*SyncUserDataRequest) Equal ¶
func (this *SyncUserDataRequest) Equal(that interface{}) bool
Equal returns whether two SyncUserDataRequest 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 (*SyncUserDataRequest) GetDeployment ¶
func (x *SyncUserDataRequest) GetDeployment() *v1.Deployment
func (*SyncUserDataRequest) GetSync ¶
func (x *SyncUserDataRequest) GetSync() []*SyncUserDataRequest_SyncUserData
func (*SyncUserDataRequest) Marshal ¶
func (val *SyncUserDataRequest) Marshal() ([]byte, error)
Marshal an object of type SyncUserDataRequest to the protobuf v3 wire format
func (*SyncUserDataRequest) ProtoMessage ¶
func (*SyncUserDataRequest) ProtoMessage()
func (*SyncUserDataRequest) ProtoReflect ¶
func (x *SyncUserDataRequest) ProtoReflect() protoreflect.Message
func (*SyncUserDataRequest) Reset ¶
func (x *SyncUserDataRequest) Reset()
func (*SyncUserDataRequest) Size ¶
func (val *SyncUserDataRequest) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncUserDataRequest) String ¶
func (x *SyncUserDataRequest) String() string
func (*SyncUserDataRequest) Unmarshal ¶
func (val *SyncUserDataRequest) Unmarshal(buf []byte) error
Unmarshal an object of type SyncUserDataRequest from the protobuf v3 wire format
type SyncUserDataRequest_SyncUserData ¶
type SyncUserDataRequest_SyncUserData struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type v11.TaskQueueType `protobuf:"varint,2,opt,name=type,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"type,omitempty"` Data *TaskQueueData `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*SyncUserDataRequest_SyncUserData) Descriptor
deprecated
func (*SyncUserDataRequest_SyncUserData) Descriptor() ([]byte, []int)
Deprecated: Use SyncUserDataRequest_SyncUserData.ProtoReflect.Descriptor instead.
func (*SyncUserDataRequest_SyncUserData) GetData ¶
func (x *SyncUserDataRequest_SyncUserData) GetData() *TaskQueueData
func (*SyncUserDataRequest_SyncUserData) GetName ¶
func (x *SyncUserDataRequest_SyncUserData) GetName() string
func (*SyncUserDataRequest_SyncUserData) GetType ¶
func (x *SyncUserDataRequest_SyncUserData) GetType() v11.TaskQueueType
func (*SyncUserDataRequest_SyncUserData) ProtoMessage ¶
func (*SyncUserDataRequest_SyncUserData) ProtoMessage()
func (*SyncUserDataRequest_SyncUserData) ProtoReflect ¶
func (x *SyncUserDataRequest_SyncUserData) ProtoReflect() protoreflect.Message
func (*SyncUserDataRequest_SyncUserData) Reset ¶
func (x *SyncUserDataRequest_SyncUserData) Reset()
func (*SyncUserDataRequest_SyncUserData) String ¶
func (x *SyncUserDataRequest_SyncUserData) String() string
type SyncUserDataResponse ¶ added in v1.27.0
type SyncUserDataResponse struct { TaskQueueMaxVersions map[string]int64 `` /* 214-byte string literal not displayed */ // contains filtered or unexported fields }
used as deployment workflow activity output:
func (*SyncUserDataResponse) Descriptor
deprecated
added in
v1.27.0
func (*SyncUserDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncUserDataResponse.ProtoReflect.Descriptor instead.
func (*SyncUserDataResponse) Equal ¶ added in v1.27.0
func (this *SyncUserDataResponse) Equal(that interface{}) bool
Equal returns whether two SyncUserDataResponse 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 (*SyncUserDataResponse) GetTaskQueueMaxVersions ¶ added in v1.27.0
func (x *SyncUserDataResponse) GetTaskQueueMaxVersions() map[string]int64
func (*SyncUserDataResponse) Marshal ¶ added in v1.27.0
func (val *SyncUserDataResponse) Marshal() ([]byte, error)
Marshal an object of type SyncUserDataResponse to the protobuf v3 wire format
func (*SyncUserDataResponse) ProtoMessage ¶ added in v1.27.0
func (*SyncUserDataResponse) ProtoMessage()
func (*SyncUserDataResponse) ProtoReflect ¶ added in v1.27.0
func (x *SyncUserDataResponse) ProtoReflect() protoreflect.Message
func (*SyncUserDataResponse) Reset ¶ added in v1.27.0
func (x *SyncUserDataResponse) Reset()
func (*SyncUserDataResponse) Size ¶ added in v1.27.0
func (val *SyncUserDataResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncUserDataResponse) String ¶ added in v1.27.0
func (x *SyncUserDataResponse) String() string
func (*SyncUserDataResponse) Unmarshal ¶ added in v1.27.0
func (val *SyncUserDataResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SyncUserDataResponse from the protobuf v3 wire format
type SyncVersionStateActivityArgs ¶ added in v1.27.0
type SyncVersionStateActivityArgs struct { DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` // <deployment_name>.<build_id> or possibly just <version_id> in the future Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` UpdateArgs *SyncVersionStateUpdateArgs `protobuf:"bytes,3,opt,name=update_args,json=updateArgs,proto3" json:"update_args,omitempty"` RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment activity input:
func (*SyncVersionStateActivityArgs) Descriptor
deprecated
added in
v1.27.0
func (*SyncVersionStateActivityArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncVersionStateActivityArgs.ProtoReflect.Descriptor instead.
func (*SyncVersionStateActivityArgs) Equal ¶ added in v1.27.0
func (this *SyncVersionStateActivityArgs) Equal(that interface{}) bool
Equal returns whether two SyncVersionStateActivityArgs 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 (*SyncVersionStateActivityArgs) GetDeploymentName ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) GetDeploymentName() string
func (*SyncVersionStateActivityArgs) GetRequestId ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) GetRequestId() string
func (*SyncVersionStateActivityArgs) GetUpdateArgs ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs
func (*SyncVersionStateActivityArgs) GetVersion ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) GetVersion() string
func (*SyncVersionStateActivityArgs) Marshal ¶ added in v1.27.0
func (val *SyncVersionStateActivityArgs) Marshal() ([]byte, error)
Marshal an object of type SyncVersionStateActivityArgs to the protobuf v3 wire format
func (*SyncVersionStateActivityArgs) ProtoMessage ¶ added in v1.27.0
func (*SyncVersionStateActivityArgs) ProtoMessage()
func (*SyncVersionStateActivityArgs) ProtoReflect ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) ProtoReflect() protoreflect.Message
func (*SyncVersionStateActivityArgs) Reset ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) Reset()
func (*SyncVersionStateActivityArgs) Size ¶ added in v1.27.0
func (val *SyncVersionStateActivityArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncVersionStateActivityArgs) String ¶ added in v1.27.0
func (x *SyncVersionStateActivityArgs) String() string
func (*SyncVersionStateActivityArgs) Unmarshal ¶ added in v1.27.0
func (val *SyncVersionStateActivityArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncVersionStateActivityArgs from the protobuf v3 wire format
type SyncVersionStateActivityResult ¶ added in v1.27.0
type SyncVersionStateActivityResult struct { VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment activity result:
func (*SyncVersionStateActivityResult) Descriptor
deprecated
added in
v1.27.0
func (*SyncVersionStateActivityResult) Descriptor() ([]byte, []int)
Deprecated: Use SyncVersionStateActivityResult.ProtoReflect.Descriptor instead.
func (*SyncVersionStateActivityResult) Equal ¶ added in v1.27.0
func (this *SyncVersionStateActivityResult) Equal(that interface{}) bool
Equal returns whether two SyncVersionStateActivityResult 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 (*SyncVersionStateActivityResult) GetVersionState ¶ added in v1.27.0
func (x *SyncVersionStateActivityResult) GetVersionState() *VersionLocalState
func (*SyncVersionStateActivityResult) Marshal ¶ added in v1.27.0
func (val *SyncVersionStateActivityResult) Marshal() ([]byte, error)
Marshal an object of type SyncVersionStateActivityResult to the protobuf v3 wire format
func (*SyncVersionStateActivityResult) ProtoMessage ¶ added in v1.27.0
func (*SyncVersionStateActivityResult) ProtoMessage()
func (*SyncVersionStateActivityResult) ProtoReflect ¶ added in v1.27.0
func (x *SyncVersionStateActivityResult) ProtoReflect() protoreflect.Message
func (*SyncVersionStateActivityResult) Reset ¶ added in v1.27.0
func (x *SyncVersionStateActivityResult) Reset()
func (*SyncVersionStateActivityResult) Size ¶ added in v1.27.0
func (val *SyncVersionStateActivityResult) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncVersionStateActivityResult) String ¶ added in v1.27.0
func (x *SyncVersionStateActivityResult) String() string
func (*SyncVersionStateActivityResult) Unmarshal ¶ added in v1.27.0
func (val *SyncVersionStateActivityResult) Unmarshal(buf []byte) error
Unmarshal an object of type SyncVersionStateActivityResult from the protobuf v3 wire format
type SyncVersionStateResponse ¶ added in v1.27.0
type SyncVersionStateResponse struct { VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow update response (sent from Worker Deployment workflow):
func (*SyncVersionStateResponse) Descriptor
deprecated
added in
v1.27.0
func (*SyncVersionStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncVersionStateResponse.ProtoReflect.Descriptor instead.
func (*SyncVersionStateResponse) Equal ¶ added in v1.27.0
func (this *SyncVersionStateResponse) Equal(that interface{}) bool
Equal returns whether two SyncVersionStateResponse 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 (*SyncVersionStateResponse) GetVersionState ¶ added in v1.27.0
func (x *SyncVersionStateResponse) GetVersionState() *VersionLocalState
func (*SyncVersionStateResponse) Marshal ¶ added in v1.27.0
func (val *SyncVersionStateResponse) Marshal() ([]byte, error)
Marshal an object of type SyncVersionStateResponse to the protobuf v3 wire format
func (*SyncVersionStateResponse) ProtoMessage ¶ added in v1.27.0
func (*SyncVersionStateResponse) ProtoMessage()
func (*SyncVersionStateResponse) ProtoReflect ¶ added in v1.27.0
func (x *SyncVersionStateResponse) ProtoReflect() protoreflect.Message
func (*SyncVersionStateResponse) Reset ¶ added in v1.27.0
func (x *SyncVersionStateResponse) Reset()
func (*SyncVersionStateResponse) Size ¶ added in v1.27.0
func (val *SyncVersionStateResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncVersionStateResponse) String ¶ added in v1.27.0
func (x *SyncVersionStateResponse) String() string
func (*SyncVersionStateResponse) Unmarshal ¶ added in v1.27.0
func (val *SyncVersionStateResponse) Unmarshal(buf []byte) error
Unmarshal an object of type SyncVersionStateResponse from the protobuf v3 wire format
type SyncVersionStateUpdateArgs ¶ added in v1.27.0
type SyncVersionStateUpdateArgs struct { // Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed. RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=routing_update_time,json=routingUpdateTime,proto3" json:"routing_update_time,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --) // // Nil if not current. CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=current_since_time,json=currentSinceTime,proto3" json:"current_since_time,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --) // // Nil if not ramping. Updated when the version first starts ramping, not on each ramp change. RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"` // Range: [0, 100]. Must be zero if the version is not ramping (i.e. `ramping_since_time` is nil). // Can be in the range [0, 100] if the version is ramping. RampPercentage float32 `protobuf:"fixed32,4,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow update input (sent from Worker Deployment workflow):
func (*SyncVersionStateUpdateArgs) Descriptor
deprecated
added in
v1.27.0
func (*SyncVersionStateUpdateArgs) Descriptor() ([]byte, []int)
Deprecated: Use SyncVersionStateUpdateArgs.ProtoReflect.Descriptor instead.
func (*SyncVersionStateUpdateArgs) Equal ¶ added in v1.27.0
func (this *SyncVersionStateUpdateArgs) Equal(that interface{}) bool
Equal returns whether two SyncVersionStateUpdateArgs 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 (*SyncVersionStateUpdateArgs) GetCurrentSinceTime ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) GetCurrentSinceTime() *timestamppb.Timestamp
func (*SyncVersionStateUpdateArgs) GetRampPercentage ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) GetRampPercentage() float32
func (*SyncVersionStateUpdateArgs) GetRampingSinceTime ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) GetRampingSinceTime() *timestamppb.Timestamp
func (*SyncVersionStateUpdateArgs) GetRoutingUpdateTime ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) GetRoutingUpdateTime() *timestamppb.Timestamp
func (*SyncVersionStateUpdateArgs) Marshal ¶ added in v1.27.0
func (val *SyncVersionStateUpdateArgs) Marshal() ([]byte, error)
Marshal an object of type SyncVersionStateUpdateArgs to the protobuf v3 wire format
func (*SyncVersionStateUpdateArgs) ProtoMessage ¶ added in v1.27.0
func (*SyncVersionStateUpdateArgs) ProtoMessage()
func (*SyncVersionStateUpdateArgs) ProtoReflect ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) ProtoReflect() protoreflect.Message
func (*SyncVersionStateUpdateArgs) Reset ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) Reset()
func (*SyncVersionStateUpdateArgs) Size ¶ added in v1.27.0
func (val *SyncVersionStateUpdateArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*SyncVersionStateUpdateArgs) String ¶ added in v1.27.0
func (x *SyncVersionStateUpdateArgs) String() string
func (*SyncVersionStateUpdateArgs) Unmarshal ¶ added in v1.27.0
func (val *SyncVersionStateUpdateArgs) Unmarshal(buf []byte) error
Unmarshal an object of type SyncVersionStateUpdateArgs from the protobuf v3 wire format
type TaskQueueData ¶
type TaskQueueData struct { FirstPollerTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=first_poller_time,json=firstPollerTime,proto3" json:"first_poller_time,omitempty"` LastBecameCurrentTime *timestamppb.Timestamp `` /* 128-byte string literal not displayed */ // contains filtered or unexported fields }
//////////////////////////////////////////////////////////////////////// Below this line are the messages for the pre-release Deployment APIs // //////////////////////////////////////////////////////////////////////// Data for each deployment+task queue pair. This is stored in each deployment (for each task queue), and synced to task queue user data (for each deployment).
func (*TaskQueueData) Descriptor
deprecated
func (*TaskQueueData) Descriptor() ([]byte, []int)
Deprecated: Use TaskQueueData.ProtoReflect.Descriptor instead.
func (*TaskQueueData) Equal ¶
func (this *TaskQueueData) Equal(that interface{}) bool
Equal returns whether two TaskQueueData 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 (*TaskQueueData) GetFirstPollerTime ¶
func (x *TaskQueueData) GetFirstPollerTime() *timestamppb.Timestamp
func (*TaskQueueData) GetLastBecameCurrentTime ¶
func (x *TaskQueueData) GetLastBecameCurrentTime() *timestamppb.Timestamp
func (*TaskQueueData) Marshal ¶
func (val *TaskQueueData) Marshal() ([]byte, error)
Marshal an object of type TaskQueueData to the protobuf v3 wire format
func (*TaskQueueData) ProtoMessage ¶
func (*TaskQueueData) ProtoMessage()
func (*TaskQueueData) ProtoReflect ¶
func (x *TaskQueueData) ProtoReflect() protoreflect.Message
func (*TaskQueueData) Reset ¶
func (x *TaskQueueData) Reset()
func (*TaskQueueData) Size ¶
func (val *TaskQueueData) Size() int
Size returns the size of the object, in bytes, once serialized
func (*TaskQueueData) String ¶
func (x *TaskQueueData) String() string
func (*TaskQueueData) Unmarshal ¶
func (val *TaskQueueData) Unmarshal(buf []byte) error
Unmarshal an object of type TaskQueueData from the protobuf v3 wire format
type TaskQueueVersionData ¶ added in v1.27.0
type TaskQueueVersionData struct {
// contains filtered or unexported fields
}
Data specific to a task queue, from the perspective of a worker deployment version.
func (*TaskQueueVersionData) Descriptor
deprecated
added in
v1.27.0
func (*TaskQueueVersionData) Descriptor() ([]byte, []int)
Deprecated: Use TaskQueueVersionData.ProtoReflect.Descriptor instead.
func (*TaskQueueVersionData) Equal ¶ added in v1.27.0
func (this *TaskQueueVersionData) Equal(that interface{}) bool
Equal returns whether two TaskQueueVersionData 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 (*TaskQueueVersionData) Marshal ¶ added in v1.27.0
func (val *TaskQueueVersionData) Marshal() ([]byte, error)
Marshal an object of type TaskQueueVersionData to the protobuf v3 wire format
func (*TaskQueueVersionData) ProtoMessage ¶ added in v1.27.0
func (*TaskQueueVersionData) ProtoMessage()
func (*TaskQueueVersionData) ProtoReflect ¶ added in v1.27.0
func (x *TaskQueueVersionData) ProtoReflect() protoreflect.Message
func (*TaskQueueVersionData) Reset ¶ added in v1.27.0
func (x *TaskQueueVersionData) Reset()
func (*TaskQueueVersionData) Size ¶ added in v1.27.0
func (val *TaskQueueVersionData) Size() int
Size returns the size of the object, in bytes, once serialized
func (*TaskQueueVersionData) String ¶ added in v1.27.0
func (x *TaskQueueVersionData) String() string
func (*TaskQueueVersionData) Unmarshal ¶ added in v1.27.0
func (val *TaskQueueVersionData) Unmarshal(buf []byte) error
Unmarshal an object of type TaskQueueVersionData from the protobuf v3 wire format
type UpdateVersionMetadataArgs ¶ added in v1.27.0
type UpdateVersionMetadataArgs struct { UpsertEntries map[string]*v12.Payload `` /* 188-byte string literal not displayed */ RemoveEntries []string `protobuf:"bytes,2,rep,name=remove_entries,json=removeEntries,proto3" json:"remove_entries,omitempty"` Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow update input:
func (*UpdateVersionMetadataArgs) Descriptor
deprecated
added in
v1.27.0
func (*UpdateVersionMetadataArgs) Descriptor() ([]byte, []int)
Deprecated: Use UpdateVersionMetadataArgs.ProtoReflect.Descriptor instead.
func (*UpdateVersionMetadataArgs) Equal ¶ added in v1.27.0
func (this *UpdateVersionMetadataArgs) Equal(that interface{}) bool
Equal returns whether two UpdateVersionMetadataArgs 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 (*UpdateVersionMetadataArgs) GetIdentity ¶ added in v1.27.0
func (x *UpdateVersionMetadataArgs) GetIdentity() string
func (*UpdateVersionMetadataArgs) GetRemoveEntries ¶ added in v1.27.0
func (x *UpdateVersionMetadataArgs) GetRemoveEntries() []string
func (*UpdateVersionMetadataArgs) GetUpsertEntries ¶ added in v1.27.0
func (x *UpdateVersionMetadataArgs) GetUpsertEntries() map[string]*v12.Payload
func (*UpdateVersionMetadataArgs) Marshal ¶ added in v1.27.0
func (val *UpdateVersionMetadataArgs) Marshal() ([]byte, error)
Marshal an object of type UpdateVersionMetadataArgs to the protobuf v3 wire format
func (*UpdateVersionMetadataArgs) ProtoMessage ¶ added in v1.27.0
func (*UpdateVersionMetadataArgs) ProtoMessage()
func (*UpdateVersionMetadataArgs) ProtoReflect ¶ added in v1.27.0
func (x *UpdateVersionMetadataArgs) ProtoReflect() protoreflect.Message
func (*UpdateVersionMetadataArgs) Reset ¶ added in v1.27.0
func (x *UpdateVersionMetadataArgs) Reset()
func (*UpdateVersionMetadataArgs) Size ¶ added in v1.27.0
func (val *UpdateVersionMetadataArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*UpdateVersionMetadataArgs) String ¶ added in v1.27.0
func (x *UpdateVersionMetadataArgs) String() string
func (*UpdateVersionMetadataArgs) Unmarshal ¶ added in v1.27.0
func (val *UpdateVersionMetadataArgs) Unmarshal(buf []byte) error
Unmarshal an object of type UpdateVersionMetadataArgs from the protobuf v3 wire format
type UpdateVersionMetadataResponse ¶ added in v1.27.0
type UpdateVersionMetadataResponse struct { Metadata *v1.VersionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow update response:
func (*UpdateVersionMetadataResponse) Descriptor
deprecated
added in
v1.27.0
func (*UpdateVersionMetadataResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateVersionMetadataResponse.ProtoReflect.Descriptor instead.
func (*UpdateVersionMetadataResponse) Equal ¶ added in v1.27.0
func (this *UpdateVersionMetadataResponse) Equal(that interface{}) bool
Equal returns whether two UpdateVersionMetadataResponse 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 (*UpdateVersionMetadataResponse) GetMetadata ¶ added in v1.27.0
func (x *UpdateVersionMetadataResponse) GetMetadata() *v1.VersionMetadata
func (*UpdateVersionMetadataResponse) Marshal ¶ added in v1.27.0
func (val *UpdateVersionMetadataResponse) Marshal() ([]byte, error)
Marshal an object of type UpdateVersionMetadataResponse to the protobuf v3 wire format
func (*UpdateVersionMetadataResponse) ProtoMessage ¶ added in v1.27.0
func (*UpdateVersionMetadataResponse) ProtoMessage()
func (*UpdateVersionMetadataResponse) ProtoReflect ¶ added in v1.27.0
func (x *UpdateVersionMetadataResponse) ProtoReflect() protoreflect.Message
func (*UpdateVersionMetadataResponse) Reset ¶ added in v1.27.0
func (x *UpdateVersionMetadataResponse) Reset()
func (*UpdateVersionMetadataResponse) Size ¶ added in v1.27.0
func (val *UpdateVersionMetadataResponse) Size() int
Size returns the size of the object, in bytes, once serialized
func (*UpdateVersionMetadataResponse) String ¶ added in v1.27.0
func (x *UpdateVersionMetadataResponse) String() string
func (*UpdateVersionMetadataResponse) Unmarshal ¶ added in v1.27.0
func (val *UpdateVersionMetadataResponse) Unmarshal(buf []byte) error
Unmarshal an object of type UpdateVersionMetadataResponse from the protobuf v3 wire format
type VersionLocalState ¶ added in v1.27.0
type VersionLocalState struct { Version *WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed. RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=routing_update_time,json=routingUpdateTime,proto3" json:"routing_update_time,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --) // // Nil if not current. CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=current_since_time,json=currentSinceTime,proto3" json:"current_since_time,omitempty"` // (-- api-linter: core::0140::prepositions=disabled // // aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --) // // Nil if not ramping. Updated when the version first starts ramping, not on each ramp change. RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"` // Range: [0, 100]. Must be zero if the version is not ramping (i.e. `ramping_since_time` is nil). // Can be in the range [0, 100] if the version is ramping. RampPercentage float32 `protobuf:"fixed32,6,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"` // Helps user determine when it is safe to decommission the workers of this // Version. Not present when version is current or ramping. // Current limitations: // - Not supported for Unversioned mode. // - Periodically refreshed, may have delays up to few minutes (consult the // last_checked_time value). // - Refreshed only when version is not current or ramping AND the status is not // "drained" yet. // - Once the status is changed to "drained", it is not changed until the Version // becomes Current or Ramping again, at which time the drainage info is cleared. // This means if the Version is "drained" but new workflows are sent to it via // Pinned Versioning Override, the status does not account for those Pinned-override // executions and remains "drained". DrainageInfo *v1.VersionDrainageInfo `protobuf:"bytes,7,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"` // Arbitrary user-provided metadata attached to this version. Metadata *v1.VersionMetadata `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"` StartedDeploymentWorkflow bool `` /* 139-byte string literal not displayed */ // Key: Task Queue Name TaskQueueFamilies map[string]*VersionLocalState_TaskQueueFamilyData `` /* 203-byte string literal not displayed */ // contains filtered or unexported fields }
Local state for Worker Deployment Version
func (*VersionLocalState) Descriptor
deprecated
added in
v1.27.0
func (*VersionLocalState) Descriptor() ([]byte, []int)
Deprecated: Use VersionLocalState.ProtoReflect.Descriptor instead.
func (*VersionLocalState) Equal ¶ added in v1.27.0
func (this *VersionLocalState) Equal(that interface{}) bool
Equal returns whether two VersionLocalState 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 (*VersionLocalState) GetCreateTime ¶ added in v1.27.0
func (x *VersionLocalState) GetCreateTime() *timestamppb.Timestamp
func (*VersionLocalState) GetCurrentSinceTime ¶ added in v1.27.0
func (x *VersionLocalState) GetCurrentSinceTime() *timestamppb.Timestamp
func (*VersionLocalState) GetDrainageInfo ¶ added in v1.27.0
func (x *VersionLocalState) GetDrainageInfo() *v1.VersionDrainageInfo
func (*VersionLocalState) GetMetadata ¶ added in v1.27.0
func (x *VersionLocalState) GetMetadata() *v1.VersionMetadata
func (*VersionLocalState) GetRampPercentage ¶ added in v1.27.0
func (x *VersionLocalState) GetRampPercentage() float32
func (*VersionLocalState) GetRampingSinceTime ¶ added in v1.27.0
func (x *VersionLocalState) GetRampingSinceTime() *timestamppb.Timestamp
func (*VersionLocalState) GetRoutingUpdateTime ¶ added in v1.27.0
func (x *VersionLocalState) GetRoutingUpdateTime() *timestamppb.Timestamp
func (*VersionLocalState) GetStartedDeploymentWorkflow ¶ added in v1.27.0
func (x *VersionLocalState) GetStartedDeploymentWorkflow() bool
func (*VersionLocalState) GetTaskQueueFamilies ¶ added in v1.27.0
func (x *VersionLocalState) GetTaskQueueFamilies() map[string]*VersionLocalState_TaskQueueFamilyData
func (*VersionLocalState) GetVersion ¶ added in v1.27.0
func (x *VersionLocalState) GetVersion() *WorkerDeploymentVersion
func (*VersionLocalState) Marshal ¶ added in v1.27.0
func (val *VersionLocalState) Marshal() ([]byte, error)
Marshal an object of type VersionLocalState to the protobuf v3 wire format
func (*VersionLocalState) ProtoMessage ¶ added in v1.27.0
func (*VersionLocalState) ProtoMessage()
func (*VersionLocalState) ProtoReflect ¶ added in v1.27.0
func (x *VersionLocalState) ProtoReflect() protoreflect.Message
func (*VersionLocalState) Reset ¶ added in v1.27.0
func (x *VersionLocalState) Reset()
func (*VersionLocalState) Size ¶ added in v1.27.0
func (val *VersionLocalState) Size() int
Size returns the size of the object, in bytes, once serialized
func (*VersionLocalState) String ¶ added in v1.27.0
func (x *VersionLocalState) String() string
func (*VersionLocalState) Unmarshal ¶ added in v1.27.0
func (val *VersionLocalState) Unmarshal(buf []byte) error
Unmarshal an object of type VersionLocalState from the protobuf v3 wire format
type VersionLocalState_TaskQueueFamilyData ¶ added in v1.27.0
type VersionLocalState_TaskQueueFamilyData struct { // Key: Task Queue Type TaskQueues map[int32]*TaskQueueVersionData `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
func (*VersionLocalState_TaskQueueFamilyData) Descriptor
deprecated
added in
v1.27.0
func (*VersionLocalState_TaskQueueFamilyData) Descriptor() ([]byte, []int)
Deprecated: Use VersionLocalState_TaskQueueFamilyData.ProtoReflect.Descriptor instead.
func (*VersionLocalState_TaskQueueFamilyData) GetTaskQueues ¶ added in v1.27.0
func (x *VersionLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueVersionData
func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage ¶ added in v1.27.0
func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage()
func (*VersionLocalState_TaskQueueFamilyData) ProtoReflect ¶ added in v1.27.0
func (x *VersionLocalState_TaskQueueFamilyData) ProtoReflect() protoreflect.Message
func (*VersionLocalState_TaskQueueFamilyData) Reset ¶ added in v1.27.0
func (x *VersionLocalState_TaskQueueFamilyData) Reset()
func (*VersionLocalState_TaskQueueFamilyData) String ¶ added in v1.27.0
func (x *VersionLocalState_TaskQueueFamilyData) String() string
type WorkerDeploymentLocalState ¶ added in v1.27.0
type WorkerDeploymentLocalState struct { CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Encapsulates task routing information for this deployment. RoutingConfig *v1.RoutingConfig `protobuf:"bytes,2,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"` Versions map[string]*WorkerDeploymentVersionSummary `` /* 157-byte string literal not displayed */ ConflictToken []byte `protobuf:"bytes,4,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"` LastModifierIdentity string `protobuf:"bytes,5,opt,name=last_modifier_identity,json=lastModifierIdentity,proto3" json:"last_modifier_identity,omitempty"` // contains filtered or unexported fields }
Local state for Worker Deployment
func (*WorkerDeploymentLocalState) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentLocalState) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentLocalState.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentLocalState) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentLocalState) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentLocalState 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 (*WorkerDeploymentLocalState) GetConflictToken ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) GetConflictToken() []byte
func (*WorkerDeploymentLocalState) GetCreateTime ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) GetCreateTime() *timestamppb.Timestamp
func (*WorkerDeploymentLocalState) GetLastModifierIdentity ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) GetLastModifierIdentity() string
func (*WorkerDeploymentLocalState) GetRoutingConfig ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) GetRoutingConfig() *v1.RoutingConfig
func (*WorkerDeploymentLocalState) GetVersions ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) GetVersions() map[string]*WorkerDeploymentVersionSummary
func (*WorkerDeploymentLocalState) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentLocalState) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentLocalState to the protobuf v3 wire format
func (*WorkerDeploymentLocalState) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentLocalState) ProtoMessage()
func (*WorkerDeploymentLocalState) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentLocalState) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) Reset()
func (*WorkerDeploymentLocalState) Size ¶ added in v1.27.0
func (val *WorkerDeploymentLocalState) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentLocalState) String ¶ added in v1.27.0
func (x *WorkerDeploymentLocalState) String() string
func (*WorkerDeploymentLocalState) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentLocalState) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentLocalState from the protobuf v3 wire format
type WorkerDeploymentSummary ¶ added in v1.27.0
type WorkerDeploymentSummary struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` RoutingConfig *v1.RoutingConfig `protobuf:"bytes,3,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"` // contains filtered or unexported fields }
Subset of fields of WorkerDeploymentInfo returned in ListWorkerDeploymentsResponse
func (*WorkerDeploymentSummary) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentSummary) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentSummary.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentSummary) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentSummary) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentSummary 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 (*WorkerDeploymentSummary) GetCreateTime ¶ added in v1.27.0
func (x *WorkerDeploymentSummary) GetCreateTime() *timestamppb.Timestamp
func (*WorkerDeploymentSummary) GetName ¶ added in v1.27.0
func (x *WorkerDeploymentSummary) GetName() string
func (*WorkerDeploymentSummary) GetRoutingConfig ¶ added in v1.27.0
func (x *WorkerDeploymentSummary) GetRoutingConfig() *v1.RoutingConfig
func (*WorkerDeploymentSummary) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentSummary) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentSummary to the protobuf v3 wire format
func (*WorkerDeploymentSummary) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentSummary) ProtoMessage()
func (*WorkerDeploymentSummary) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentSummary) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentSummary) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentSummary) Reset()
func (*WorkerDeploymentSummary) Size ¶ added in v1.27.0
func (val *WorkerDeploymentSummary) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentSummary) String ¶ added in v1.27.0
func (x *WorkerDeploymentSummary) String() string
func (*WorkerDeploymentSummary) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentSummary) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentSummary from the protobuf v3 wire format
type WorkerDeploymentVersion ¶ added in v1.27.0
type WorkerDeploymentVersion struct { // The name of the Deployment this version belongs too. DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` // Build ID uniquely identifies the Deployment Version within a Deployment, but the same Build // ID can be used in multiple Deployments. BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"` // contains filtered or unexported fields }
Identifies a Worker Deployment Version. The combination of `deployment_name` and `build_id` serve as the identifier.
func (*WorkerDeploymentVersion) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentVersion) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentVersion.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentVersion) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentVersion) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentVersion 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 (*WorkerDeploymentVersion) GetBuildId ¶ added in v1.27.0
func (x *WorkerDeploymentVersion) GetBuildId() string
func (*WorkerDeploymentVersion) GetDeploymentName ¶ added in v1.27.0
func (x *WorkerDeploymentVersion) GetDeploymentName() string
func (*WorkerDeploymentVersion) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentVersion) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentVersion to the protobuf v3 wire format
func (*WorkerDeploymentVersion) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentVersion) ProtoMessage()
func (*WorkerDeploymentVersion) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentVersion) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentVersion) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentVersion) Reset()
func (*WorkerDeploymentVersion) Size ¶ added in v1.27.0
func (val *WorkerDeploymentVersion) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentVersion) String ¶ added in v1.27.0
func (x *WorkerDeploymentVersion) String() string
func (*WorkerDeploymentVersion) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentVersion) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentVersion from the protobuf v3 wire format
type WorkerDeploymentVersionSummary ¶ added in v1.27.0
type WorkerDeploymentVersionSummary struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` DrainageStatus v11.VersionDrainageStatus `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WorkerDeploymentVersionSummary) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentVersionSummary) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentVersionSummary.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentVersionSummary) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentVersionSummary) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentVersionSummary 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 (*WorkerDeploymentVersionSummary) GetCreateTime ¶ added in v1.27.0
func (x *WorkerDeploymentVersionSummary) GetCreateTime() *timestamppb.Timestamp
func (*WorkerDeploymentVersionSummary) GetDrainageStatus ¶ added in v1.27.0
func (x *WorkerDeploymentVersionSummary) GetDrainageStatus() v11.VersionDrainageStatus
func (*WorkerDeploymentVersionSummary) GetVersion ¶ added in v1.27.0
func (x *WorkerDeploymentVersionSummary) GetVersion() string
func (*WorkerDeploymentVersionSummary) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentVersionSummary) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentVersionSummary to the protobuf v3 wire format
func (*WorkerDeploymentVersionSummary) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentVersionSummary) ProtoMessage()
func (*WorkerDeploymentVersionSummary) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentVersionSummary) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentVersionSummary) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentVersionSummary) Reset()
func (*WorkerDeploymentVersionSummary) Size ¶ added in v1.27.0
func (val *WorkerDeploymentVersionSummary) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentVersionSummary) String ¶ added in v1.27.0
func (x *WorkerDeploymentVersionSummary) String() string
func (*WorkerDeploymentVersionSummary) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentVersionSummary) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentVersionSummary from the protobuf v3 wire format
type WorkerDeploymentVersionWorkflowArgs ¶ added in v1.27.0
type WorkerDeploymentVersionWorkflowArgs struct { NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` VersionState *VersionLocalState `protobuf:"bytes,3,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment Version workflow input:
func (*WorkerDeploymentVersionWorkflowArgs) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentVersionWorkflowArgs) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentVersionWorkflowArgs.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentVersionWorkflowArgs) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentVersionWorkflowArgs) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentVersionWorkflowArgs 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 (*WorkerDeploymentVersionWorkflowArgs) GetNamespaceId ¶ added in v1.27.0
func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceId() string
func (*WorkerDeploymentVersionWorkflowArgs) GetNamespaceName ¶ added in v1.27.0
func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceName() string
func (*WorkerDeploymentVersionWorkflowArgs) GetVersionState ¶ added in v1.27.0
func (x *WorkerDeploymentVersionWorkflowArgs) GetVersionState() *VersionLocalState
func (*WorkerDeploymentVersionWorkflowArgs) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentVersionWorkflowArgs) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentVersionWorkflowArgs to the protobuf v3 wire format
func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage()
func (*WorkerDeploymentVersionWorkflowArgs) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentVersionWorkflowArgs) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentVersionWorkflowArgs) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentVersionWorkflowArgs) Reset()
func (*WorkerDeploymentVersionWorkflowArgs) Size ¶ added in v1.27.0
func (val *WorkerDeploymentVersionWorkflowArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentVersionWorkflowArgs) String ¶ added in v1.27.0
func (x *WorkerDeploymentVersionWorkflowArgs) String() string
func (*WorkerDeploymentVersionWorkflowArgs) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentVersionWorkflowArgs) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentVersionWorkflowArgs from the protobuf v3 wire format
type WorkerDeploymentWorkflowArgs ¶ added in v1.27.0
type WorkerDeploymentWorkflowArgs struct { NamespaceName string `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"` NamespaceId string `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` DeploymentName string `protobuf:"bytes,3,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` State *WorkerDeploymentLocalState `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow input:
func (*WorkerDeploymentWorkflowArgs) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentWorkflowArgs) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentWorkflowArgs.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentWorkflowArgs) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentWorkflowArgs) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentWorkflowArgs 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 (*WorkerDeploymentWorkflowArgs) GetDeploymentName ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) GetDeploymentName() string
func (*WorkerDeploymentWorkflowArgs) GetNamespaceId ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) GetNamespaceId() string
func (*WorkerDeploymentWorkflowArgs) GetNamespaceName ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) GetNamespaceName() string
func (*WorkerDeploymentWorkflowArgs) GetState ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) GetState() *WorkerDeploymentLocalState
func (*WorkerDeploymentWorkflowArgs) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentWorkflowArgs) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentWorkflowArgs to the protobuf v3 wire format
func (*WorkerDeploymentWorkflowArgs) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentWorkflowArgs) ProtoMessage()
func (*WorkerDeploymentWorkflowArgs) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentWorkflowArgs) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) Reset()
func (*WorkerDeploymentWorkflowArgs) Size ¶ added in v1.27.0
func (val *WorkerDeploymentWorkflowArgs) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentWorkflowArgs) String ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowArgs) String() string
func (*WorkerDeploymentWorkflowArgs) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentWorkflowArgs) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentWorkflowArgs from the protobuf v3 wire format
type WorkerDeploymentWorkflowMemo ¶ added in v1.27.0
type WorkerDeploymentWorkflowMemo struct { DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` RoutingConfig *v1.RoutingConfig `protobuf:"bytes,3,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"` // contains filtered or unexported fields }
used as Worker Deployment workflow memo:
func (*WorkerDeploymentWorkflowMemo) Descriptor
deprecated
added in
v1.27.0
func (*WorkerDeploymentWorkflowMemo) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeploymentWorkflowMemo.ProtoReflect.Descriptor instead.
func (*WorkerDeploymentWorkflowMemo) Equal ¶ added in v1.27.0
func (this *WorkerDeploymentWorkflowMemo) Equal(that interface{}) bool
Equal returns whether two WorkerDeploymentWorkflowMemo 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 (*WorkerDeploymentWorkflowMemo) GetCreateTime ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowMemo) GetCreateTime() *timestamppb.Timestamp
func (*WorkerDeploymentWorkflowMemo) GetDeploymentName ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowMemo) GetDeploymentName() string
func (*WorkerDeploymentWorkflowMemo) GetRoutingConfig ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowMemo) GetRoutingConfig() *v1.RoutingConfig
func (*WorkerDeploymentWorkflowMemo) Marshal ¶ added in v1.27.0
func (val *WorkerDeploymentWorkflowMemo) Marshal() ([]byte, error)
Marshal an object of type WorkerDeploymentWorkflowMemo to the protobuf v3 wire format
func (*WorkerDeploymentWorkflowMemo) ProtoMessage ¶ added in v1.27.0
func (*WorkerDeploymentWorkflowMemo) ProtoMessage()
func (*WorkerDeploymentWorkflowMemo) ProtoReflect ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowMemo) ProtoReflect() protoreflect.Message
func (*WorkerDeploymentWorkflowMemo) Reset ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowMemo) Reset()
func (*WorkerDeploymentWorkflowMemo) Size ¶ added in v1.27.0
func (val *WorkerDeploymentWorkflowMemo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkerDeploymentWorkflowMemo) String ¶ added in v1.27.0
func (x *WorkerDeploymentWorkflowMemo) String() string
func (*WorkerDeploymentWorkflowMemo) Unmarshal ¶ added in v1.27.0
func (val *WorkerDeploymentWorkflowMemo) Unmarshal(buf []byte) error
Unmarshal an object of type WorkerDeploymentWorkflowMemo from the protobuf v3 wire format