deployment

package
v1.63.2 Latest Latest
Warning

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

Go to latest
Published: Jul 8, 2026 License: MIT Imports: 10 Imported by: 24

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source
var File_temporal_api_deployment_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ComputeStatus added in v1.63.0

type ComputeStatus struct {

	// provider_validation encapsulates the health signal for validating the compute provider.
	ProviderValidation *ComputeStatus_ProviderValidationStatus `protobuf:"bytes,1,opt,name=provider_validation,json=providerValidation,proto3" json:"provider_validation,omitempty"`
	// contains filtered or unexported fields
}

ComputeStatus represents compute-related configuration and health for a Worker Deployment Version.

func (*ComputeStatus) Descriptor deprecated added in v1.63.0

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

Deprecated: Use ComputeStatus.ProtoReflect.Descriptor instead.

func (*ComputeStatus) Equal added in v1.63.0

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

Equal returns whether two ComputeStatus 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 (*ComputeStatus) GetProviderValidation added in v1.63.0

func (x *ComputeStatus) GetProviderValidation() *ComputeStatus_ProviderValidationStatus

func (*ComputeStatus) Marshal added in v1.63.0

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

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

func (*ComputeStatus) ProtoMessage added in v1.63.0

func (*ComputeStatus) ProtoMessage()

func (*ComputeStatus) ProtoReflect added in v1.63.0

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

func (*ComputeStatus) Reset added in v1.63.0

func (x *ComputeStatus) Reset()

func (*ComputeStatus) Size added in v1.63.0

func (val *ComputeStatus) Size() int

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

func (*ComputeStatus) String added in v1.63.0

func (x *ComputeStatus) String() string

func (*ComputeStatus) Unmarshal added in v1.63.0

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

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

type ComputeStatus_ProviderValidationStatus added in v1.63.0

type ComputeStatus_ProviderValidationStatus struct {

	// Human-readable error message if connectivity validation failed.
	// An empty string means validation passed.
	ErrorMessage string `protobuf:"bytes,1,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Timestamp of the last validation check.
	LastCheckTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_check_time,json=lastCheckTime,proto3" json:"last_check_time,omitempty"`
	// contains filtered or unexported fields
}

ProviderValidationStatus represents the result of the most recent connectivity check between Temporal and a customer's compute provider.

func (*ComputeStatus_ProviderValidationStatus) Descriptor deprecated added in v1.63.0

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

Deprecated: Use ComputeStatus_ProviderValidationStatus.ProtoReflect.Descriptor instead.

func (*ComputeStatus_ProviderValidationStatus) GetErrorMessage added in v1.63.0

func (x *ComputeStatus_ProviderValidationStatus) GetErrorMessage() string

func (*ComputeStatus_ProviderValidationStatus) GetLastCheckTime added in v1.63.0

func (*ComputeStatus_ProviderValidationStatus) ProtoMessage added in v1.63.0

func (*ComputeStatus_ProviderValidationStatus) ProtoReflect added in v1.63.0

func (*ComputeStatus_ProviderValidationStatus) Reset added in v1.63.0

func (*ComputeStatus_ProviderValidationStatus) String added in v1.63.0

type Deployment

type Deployment struct {

	// Different versions of the same worker service/application are related together by having a
	// shared series name.
	// Out of all deployments of a series, one can be designated as the current deployment, which
	// receives new workflow executions and new tasks of workflows with
	// `VERSIONING_BEHAVIOR_AUTO_UPGRADE` versioning behavior.
	SeriesName string `protobuf:"bytes,1,opt,name=series_name,json=seriesName,proto3" json:"series_name,omitempty"`
	// Build ID changes with each version of the worker when the worker program code and/or config
	// changes.
	BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

`Deployment` identifies a deployment of Temporal workers. The combination of deployment series name + build ID serves as the identifier. User can use `WorkerDeploymentOptions` in their worker programs to specify these values. Deprecated.

func (*Deployment) Descriptor deprecated

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) Equal

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

Equal returns whether two Deployment 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 (*Deployment) GetBuildId

func (x *Deployment) GetBuildId() string

func (*Deployment) GetSeriesName

func (x *Deployment) GetSeriesName() string

func (*Deployment) Marshal

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

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

func (*Deployment) ProtoMessage

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect

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

func (*Deployment) Reset

func (x *Deployment) Reset()

func (*Deployment) Size

func (val *Deployment) Size() int

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

func (*Deployment) String

func (x *Deployment) String() string

func (*Deployment) Unmarshal

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

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

type DeploymentInfo

type DeploymentInfo struct {
	Deployment     *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"`
	TaskQueueInfos []*DeploymentInfo_TaskQueueInfo `protobuf:"bytes,3,rep,name=task_queue_infos,json=taskQueueInfos,proto3" json:"task_queue_infos,omitempty"`
	// A user-defined set of key-values. Can be updated as part of write operations to the
	// deployment, such as `SetCurrentDeployment`.
	Metadata map[string]*v11.Payload `` /* 143-byte string literal not displayed */
	// If this deployment is the current deployment of its deployment series.
	IsCurrent bool `protobuf:"varint,5,opt,name=is_current,json=isCurrent,proto3" json:"is_current,omitempty"`
	// contains filtered or unexported fields
}

`DeploymentInfo` holds information about a deployment. Deployment information is tracked automatically by server as soon as the first poll from that deployment reaches the server. There can be multiple task queue workers in a single deployment which are listed in this message. Deprecated.

func (*DeploymentInfo) Descriptor deprecated

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

Deprecated: Use DeploymentInfo.ProtoReflect.Descriptor instead.

func (*DeploymentInfo) Equal

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

Equal returns whether two DeploymentInfo 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 (*DeploymentInfo) GetCreateTime

func (x *DeploymentInfo) GetCreateTime() *timestamppb.Timestamp

func (*DeploymentInfo) GetDeployment

func (x *DeploymentInfo) GetDeployment() *Deployment

func (*DeploymentInfo) GetIsCurrent

func (x *DeploymentInfo) GetIsCurrent() bool

func (*DeploymentInfo) GetMetadata

func (x *DeploymentInfo) GetMetadata() map[string]*v11.Payload

func (*DeploymentInfo) GetTaskQueueInfos

func (x *DeploymentInfo) GetTaskQueueInfos() []*DeploymentInfo_TaskQueueInfo

func (*DeploymentInfo) Marshal

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

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

func (*DeploymentInfo) ProtoMessage

func (*DeploymentInfo) ProtoMessage()

func (*DeploymentInfo) ProtoReflect

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

func (*DeploymentInfo) Reset

func (x *DeploymentInfo) Reset()

func (*DeploymentInfo) Size

func (val *DeploymentInfo) Size() int

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

func (*DeploymentInfo) String

func (x *DeploymentInfo) String() string

func (*DeploymentInfo) Unmarshal

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

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

type DeploymentInfo_TaskQueueInfo

type DeploymentInfo_TaskQueueInfo struct {
	Name string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type v1.TaskQueueType `protobuf:"varint,2,opt,name=type,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"type,omitempty"`
	// When server saw the first poller for this task queue in this deployment.
	FirstPollerTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=first_poller_time,json=firstPollerTime,proto3" json:"first_poller_time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentInfo_TaskQueueInfo) Descriptor deprecated

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

Deprecated: Use DeploymentInfo_TaskQueueInfo.ProtoReflect.Descriptor instead.

func (*DeploymentInfo_TaskQueueInfo) GetFirstPollerTime

func (x *DeploymentInfo_TaskQueueInfo) GetFirstPollerTime() *timestamppb.Timestamp

func (*DeploymentInfo_TaskQueueInfo) GetName

func (x *DeploymentInfo_TaskQueueInfo) GetName() string

func (*DeploymentInfo_TaskQueueInfo) GetType

func (*DeploymentInfo_TaskQueueInfo) ProtoMessage

func (*DeploymentInfo_TaskQueueInfo) ProtoMessage()

func (*DeploymentInfo_TaskQueueInfo) ProtoReflect

func (*DeploymentInfo_TaskQueueInfo) Reset

func (x *DeploymentInfo_TaskQueueInfo) Reset()

func (*DeploymentInfo_TaskQueueInfo) String

type DeploymentListInfo

type DeploymentListInfo struct {
	Deployment *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"`
	// If this deployment is the current deployment of its deployment series.
	IsCurrent bool `protobuf:"varint,3,opt,name=is_current,json=isCurrent,proto3" json:"is_current,omitempty"`
	// contains filtered or unexported fields
}

DeploymentListInfo is an abbreviated set of fields from DeploymentInfo that's returned in ListDeployments. Deprecated.

func (*DeploymentListInfo) Descriptor deprecated

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

Deprecated: Use DeploymentListInfo.ProtoReflect.Descriptor instead.

func (*DeploymentListInfo) Equal

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

Equal returns whether two DeploymentListInfo 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 (*DeploymentListInfo) GetCreateTime

func (x *DeploymentListInfo) GetCreateTime() *timestamppb.Timestamp

func (*DeploymentListInfo) GetDeployment

func (x *DeploymentListInfo) GetDeployment() *Deployment

func (*DeploymentListInfo) GetIsCurrent

func (x *DeploymentListInfo) GetIsCurrent() bool

func (*DeploymentListInfo) Marshal

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

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

func (*DeploymentListInfo) ProtoMessage

func (*DeploymentListInfo) ProtoMessage()

func (*DeploymentListInfo) ProtoReflect

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

func (*DeploymentListInfo) Reset

func (x *DeploymentListInfo) Reset()

func (*DeploymentListInfo) Size

func (val *DeploymentListInfo) Size() int

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

func (*DeploymentListInfo) String

func (x *DeploymentListInfo) String() string

func (*DeploymentListInfo) Unmarshal

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

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

type InheritedAutoUpgradeInfo added in v1.59.0

type InheritedAutoUpgradeInfo struct {

	// The source deployment version of the parent/previous workflow.
	SourceDeploymentVersion *WorkerDeploymentVersion `` /* 132-byte string literal not displayed */
	// The revision number of the source deployment version of the parent/previous workflow.
	SourceDeploymentRevisionNumber int64 `` /* 156-byte string literal not displayed */
	// Experimental.
	// If this workflow is the result of a continue-as-new, this field is set to the initial_versioning_behavior
	// specified in that command.
	// Only used for the initial task of this run and the initial task of any retries of this run.
	// Not passed to children or to future continue-as-new.
	//
	// Note: In the first release of Upgrade-on-CaN, when the only ContinueAsNewVersioningBehavior was AutoUpgrade,
	// a non-empty InheritedAutoUpgradeInfo meant that the workflow should start as AutoUpgrade. So for compatibility
	// with history events generated during that time, know that an UNSPECIFIED value here is equivalent to AutoUpgrade
	// value if the InheritedAutoUpgradeInfo is non-empty.
	ContinueAsNewInitialVersioningBehavior v1.ContinueAsNewVersioningBehavior `` /* 243-byte string literal not displayed */
	// contains filtered or unexported fields
}

Used as part of WorkflowExecutionStartedEventAttributes to pass down the AutoUpgrade behavior and source deployment version to a workflow execution whose parent/previous workflow has an AutoUpgrade behavior. Also used for Upgrade-on-CaN behaviors AutoUpgrade and UseRampingVersion.

func (*InheritedAutoUpgradeInfo) Descriptor deprecated added in v1.59.0

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

Deprecated: Use InheritedAutoUpgradeInfo.ProtoReflect.Descriptor instead.

func (*InheritedAutoUpgradeInfo) Equal added in v1.59.0

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

Equal returns whether two InheritedAutoUpgradeInfo 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 (*InheritedAutoUpgradeInfo) GetContinueAsNewInitialVersioningBehavior added in v1.62.8

func (x *InheritedAutoUpgradeInfo) GetContinueAsNewInitialVersioningBehavior() v1.ContinueAsNewVersioningBehavior

func (*InheritedAutoUpgradeInfo) GetSourceDeploymentRevisionNumber added in v1.59.0

func (x *InheritedAutoUpgradeInfo) GetSourceDeploymentRevisionNumber() int64

func (*InheritedAutoUpgradeInfo) GetSourceDeploymentVersion added in v1.59.0

func (x *InheritedAutoUpgradeInfo) GetSourceDeploymentVersion() *WorkerDeploymentVersion

func (*InheritedAutoUpgradeInfo) Marshal added in v1.59.0

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

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

func (*InheritedAutoUpgradeInfo) ProtoMessage added in v1.59.0

func (*InheritedAutoUpgradeInfo) ProtoMessage()

func (*InheritedAutoUpgradeInfo) ProtoReflect added in v1.59.0

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

func (*InheritedAutoUpgradeInfo) Reset added in v1.59.0

func (x *InheritedAutoUpgradeInfo) Reset()

func (*InheritedAutoUpgradeInfo) Size added in v1.59.0

func (val *InheritedAutoUpgradeInfo) Size() int

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

func (*InheritedAutoUpgradeInfo) String added in v1.59.0

func (x *InheritedAutoUpgradeInfo) String() string

func (*InheritedAutoUpgradeInfo) Unmarshal added in v1.59.0

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

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

type RoutingConfig added in v1.44.0

type RoutingConfig struct {

	// Specifies which Deployment Version should receive new workflow executions and tasks of
	// existing unversioned or AutoUpgrade workflows.
	// Nil value means no Version in this Deployment (except Ramping Version, if present) receives traffic other than tasks of previously Pinned workflows. In absence of a Current Version, remaining traffic after any ramp (if set)  goes to unversioned workers (those with `UNVERSIONED` (or unspecified) `WorkerVersioningMode`.).
	// Note: Current Version is overridden by the Ramping Version for a portion of traffic when ramp percentage
	// is non-zero (see `ramping_deployment_version` and `ramping_version_percentage`).
	CurrentDeploymentVersion *WorkerDeploymentVersion `` /* 135-byte string literal not displayed */
	// Deprecated. Use `current_deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.
	CurrentVersion string `protobuf:"bytes,1,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	// When ramp percentage is non-zero, that portion of traffic is shifted from the Current Version to the Ramping Version.
	// Must always be different from `current_deployment_version` unless both are nil.
	// Nil value represents all the unversioned workers (those with `UNVERSIONED` (or unspecified) `WorkerVersioningMode`.)
	// Note that it is possible to ramp from one Version to another Version, or from unversioned
	// workers to a particular Version, or from a particular Version to unversioned workers.
	RampingDeploymentVersion *WorkerDeploymentVersion `` /* 135-byte string literal not displayed */
	// Deprecated. Use `ramping_deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.
	RampingVersion string `protobuf:"bytes,2,opt,name=ramping_version,json=rampingVersion,proto3" json:"ramping_version,omitempty"`
	// Percentage of tasks that are routed to the Ramping Version instead of the Current Version.
	// Valid range: [0, 100]. A 100% value means the Ramping Version is receiving full traffic but
	// not yet "promoted" to be the Current Version, likely due to pending validations.
	// A 0% value means the Ramping Version is receiving no traffic.
	RampingVersionPercentage float32 `` /* 137-byte string literal not displayed */
	// Last time current version was changed.
	CurrentVersionChangedTime *timestamppb.Timestamp `` /* 140-byte string literal not displayed */
	// Last time ramping version was changed. Not updated if only the ramp percentage changes.
	RampingVersionChangedTime *timestamppb.Timestamp `` /* 140-byte string literal not displayed */
	// Last time ramping version percentage was changed.
	// If ramping version is changed, this is also updated, even if the percentage stays the same.
	RampingVersionPercentageChangedTime *timestamppb.Timestamp `` /* 172-byte string literal not displayed */
	// Monotonically increasing value which is incremented on every mutation
	// to any field of this message to achieve eventual consistency between task queues and their partitions.
	RevisionNumber int64 `protobuf:"varint,10,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
	// contains filtered or unexported fields
}

func (*RoutingConfig) Descriptor deprecated added in v1.44.0

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

Deprecated: Use RoutingConfig.ProtoReflect.Descriptor instead.

func (*RoutingConfig) Equal added in v1.44.0

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

Equal returns whether two RoutingConfig 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 (*RoutingConfig) GetCurrentDeploymentVersion added in v1.49.1

func (x *RoutingConfig) GetCurrentDeploymentVersion() *WorkerDeploymentVersion

func (*RoutingConfig) GetCurrentVersion deprecated added in v1.44.0

func (x *RoutingConfig) GetCurrentVersion() string

Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.

func (*RoutingConfig) GetCurrentVersionChangedTime added in v1.44.0

func (x *RoutingConfig) GetCurrentVersionChangedTime() *timestamppb.Timestamp

func (*RoutingConfig) GetRampingDeploymentVersion added in v1.49.1

func (x *RoutingConfig) GetRampingDeploymentVersion() *WorkerDeploymentVersion

func (*RoutingConfig) GetRampingVersion deprecated added in v1.44.0

func (x *RoutingConfig) GetRampingVersion() string

Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.

func (*RoutingConfig) GetRampingVersionChangedTime added in v1.44.0

func (x *RoutingConfig) GetRampingVersionChangedTime() *timestamppb.Timestamp

func (*RoutingConfig) GetRampingVersionPercentage added in v1.44.0

func (x *RoutingConfig) GetRampingVersionPercentage() float32

func (*RoutingConfig) GetRampingVersionPercentageChangedTime added in v1.44.0

func (x *RoutingConfig) GetRampingVersionPercentageChangedTime() *timestamppb.Timestamp

func (*RoutingConfig) GetRevisionNumber added in v1.57.0

func (x *RoutingConfig) GetRevisionNumber() int64

func (*RoutingConfig) Marshal added in v1.44.0

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

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

func (*RoutingConfig) ProtoMessage added in v1.44.0

func (*RoutingConfig) ProtoMessage()

func (*RoutingConfig) ProtoReflect added in v1.44.0

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

func (*RoutingConfig) Reset added in v1.44.0

func (x *RoutingConfig) Reset()

func (*RoutingConfig) Size added in v1.44.0

func (val *RoutingConfig) Size() int

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

func (*RoutingConfig) String added in v1.44.0

func (x *RoutingConfig) String() string

func (*RoutingConfig) Unmarshal added in v1.44.0

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

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

type UpdateDeploymentMetadata

type UpdateDeploymentMetadata struct {
	UpsertEntries map[string]*v11.Payload `` /* 174-byte string literal not displayed */
	// List of keys to remove from the metadata.
	RemoveEntries []string `protobuf:"bytes,2,rep,name=remove_entries,json=removeEntries,proto3" json:"remove_entries,omitempty"`
	// contains filtered or unexported fields
}

Used as part of Deployment write APIs to update metadata attached to a deployment. Deprecated.

func (*UpdateDeploymentMetadata) Descriptor deprecated

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

Deprecated: Use UpdateDeploymentMetadata.ProtoReflect.Descriptor instead.

func (*UpdateDeploymentMetadata) Equal

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

Equal returns whether two UpdateDeploymentMetadata 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 (*UpdateDeploymentMetadata) GetRemoveEntries

func (x *UpdateDeploymentMetadata) GetRemoveEntries() []string

func (*UpdateDeploymentMetadata) GetUpsertEntries

func (x *UpdateDeploymentMetadata) GetUpsertEntries() map[string]*v11.Payload

func (*UpdateDeploymentMetadata) Marshal

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

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

func (*UpdateDeploymentMetadata) ProtoMessage

func (*UpdateDeploymentMetadata) ProtoMessage()

func (*UpdateDeploymentMetadata) ProtoReflect

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

func (*UpdateDeploymentMetadata) Reset

func (x *UpdateDeploymentMetadata) Reset()

func (*UpdateDeploymentMetadata) Size

func (val *UpdateDeploymentMetadata) Size() int

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

func (*UpdateDeploymentMetadata) String

func (x *UpdateDeploymentMetadata) String() string

func (*UpdateDeploymentMetadata) Unmarshal

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

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

type VersionDrainageInfo added in v1.44.0

type VersionDrainageInfo struct {

	// Set to DRAINING when the version first stops accepting new executions (is no longer current or ramping).
	// Set to DRAINED when no more open pinned workflows exist on this version.
	Status v1.VersionDrainageStatus `protobuf:"varint,1,opt,name=status,proto3,enum=temporal.api.enums.v1.VersionDrainageStatus" json:"status,omitempty"`
	// Last time the drainage status changed.
	LastChangedTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_changed_time,json=lastChangedTime,proto3" json:"last_changed_time,omitempty"`
	// Last time the system checked for drainage of this version.
	LastCheckedTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_checked_time,json=lastCheckedTime,proto3" json:"last_checked_time,omitempty"`
	// contains filtered or unexported fields
}

Information about workflow drainage to help the user determine when it is safe to decommission a Version. Not present while version is current or ramping.

func (*VersionDrainageInfo) Descriptor deprecated added in v1.44.0

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

Deprecated: Use VersionDrainageInfo.ProtoReflect.Descriptor instead.

func (*VersionDrainageInfo) Equal added in v1.44.0

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

Equal returns whether two VersionDrainageInfo 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 (*VersionDrainageInfo) GetLastChangedTime added in v1.44.0

func (x *VersionDrainageInfo) GetLastChangedTime() *timestamppb.Timestamp

func (*VersionDrainageInfo) GetLastCheckedTime added in v1.44.0

func (x *VersionDrainageInfo) GetLastCheckedTime() *timestamppb.Timestamp

func (*VersionDrainageInfo) GetStatus added in v1.44.0

func (*VersionDrainageInfo) Marshal added in v1.44.0

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

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

func (*VersionDrainageInfo) ProtoMessage added in v1.44.0

func (*VersionDrainageInfo) ProtoMessage()

func (*VersionDrainageInfo) ProtoReflect added in v1.44.0

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

func (*VersionDrainageInfo) Reset added in v1.44.0

func (x *VersionDrainageInfo) Reset()

func (*VersionDrainageInfo) Size added in v1.44.0

func (val *VersionDrainageInfo) Size() int

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

func (*VersionDrainageInfo) String added in v1.44.0

func (x *VersionDrainageInfo) String() string

func (*VersionDrainageInfo) Unmarshal added in v1.44.0

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

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

type VersionMetadata added in v1.44.0

type VersionMetadata struct {

	// Arbitrary key-values.
	Entries map[string]*v11.Payload `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VersionMetadata) Descriptor deprecated added in v1.44.0

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

Deprecated: Use VersionMetadata.ProtoReflect.Descriptor instead.

func (*VersionMetadata) Equal added in v1.44.0

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

Equal returns whether two VersionMetadata 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 (*VersionMetadata) GetEntries added in v1.44.0

func (x *VersionMetadata) GetEntries() map[string]*v11.Payload

func (*VersionMetadata) Marshal added in v1.44.0

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

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

func (*VersionMetadata) ProtoMessage added in v1.44.0

func (*VersionMetadata) ProtoMessage()

func (*VersionMetadata) ProtoReflect added in v1.44.0

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

func (*VersionMetadata) Reset added in v1.44.0

func (x *VersionMetadata) Reset()

func (*VersionMetadata) Size added in v1.44.0

func (val *VersionMetadata) Size() int

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

func (*VersionMetadata) String added in v1.44.0

func (x *VersionMetadata) String() string

func (*VersionMetadata) Unmarshal added in v1.44.0

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

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

type WorkerDeploymentInfo added in v1.44.0

type WorkerDeploymentInfo struct {

	// Identifies a Worker Deployment. Must be unique within the namespace.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Deployment Versions that are currently tracked in this Deployment. A DeploymentVersion will be
	// cleaned up automatically if all the following conditions meet:
	// - It does not receive new executions (is not current or ramping)
	// - It has no active pollers (see WorkerDeploymentVersionInfo.pollers_status)
	// - It is drained (see WorkerDeploymentVersionInfo.drainage_status)
	VersionSummaries []*WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,2,rep,name=version_summaries,json=versionSummaries,proto3" json:"version_summaries,omitempty"`
	CreateTime       *timestamppb.Timestamp                                 `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	RoutingConfig    *RoutingConfig                                         `protobuf:"bytes,4,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
	// Identity of the last client who modified the configuration of this Deployment. Set to the
	// `identity` value sent by APIs such as `SetWorkerDeploymentCurrentVersion` and
	// `SetWorkerDeploymentRampingVersion`.
	LastModifierIdentity string `protobuf:"bytes,5,opt,name=last_modifier_identity,json=lastModifierIdentity,proto3" json:"last_modifier_identity,omitempty"`
	// Identity of the client that has the exclusive right to make changes to this Worker Deployment.
	// Empty by default.
	// If this is set, clients whose identity does not match `manager_identity` will not be able to make changes
	// to this Worker Deployment. They can either set their own identity as the manager or unset the field to proceed.
	ManagerIdentity string `protobuf:"bytes,6,opt,name=manager_identity,json=managerIdentity,proto3" json:"manager_identity,omitempty"`
	// Indicates whether the routing_config has been fully propagated to all
	// relevant task queues and their partitions.
	RoutingConfigUpdateState v1.RoutingConfigUpdateState `` /* 190-byte string literal not displayed */
	// contains filtered or unexported fields
}

A Worker Deployment (Deployment, for short) represents all workers serving a shared set of Task Queues. Typically, a Deployment represents one service or application. A Deployment contains multiple Deployment Versions, each representing a different version of workers. (see documentation of WorkerDeploymentVersionInfo) Deployment records are created in Temporal server automatically when their first poller arrives to the server.

func (*WorkerDeploymentInfo) Descriptor deprecated added in v1.44.0

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

Deprecated: Use WorkerDeploymentInfo.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentInfo) Equal added in v1.44.0

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

Equal returns whether two WorkerDeploymentInfo 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 (*WorkerDeploymentInfo) GetCreateTime added in v1.44.0

func (x *WorkerDeploymentInfo) GetCreateTime() *timestamppb.Timestamp

func (*WorkerDeploymentInfo) GetLastModifierIdentity added in v1.44.0

func (x *WorkerDeploymentInfo) GetLastModifierIdentity() string

func (*WorkerDeploymentInfo) GetManagerIdentity added in v1.53.0

func (x *WorkerDeploymentInfo) GetManagerIdentity() string

func (*WorkerDeploymentInfo) GetName added in v1.44.0

func (x *WorkerDeploymentInfo) GetName() string

func (*WorkerDeploymentInfo) GetRoutingConfig added in v1.44.0

func (x *WorkerDeploymentInfo) GetRoutingConfig() *RoutingConfig

func (*WorkerDeploymentInfo) GetRoutingConfigUpdateState added in v1.57.0

func (x *WorkerDeploymentInfo) GetRoutingConfigUpdateState() v1.RoutingConfigUpdateState

func (*WorkerDeploymentInfo) GetVersionSummaries added in v1.44.0

func (*WorkerDeploymentInfo) Marshal added in v1.44.0

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

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

func (*WorkerDeploymentInfo) ProtoMessage added in v1.44.0

func (*WorkerDeploymentInfo) ProtoMessage()

func (*WorkerDeploymentInfo) ProtoReflect added in v1.44.0

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

func (*WorkerDeploymentInfo) Reset added in v1.44.0

func (x *WorkerDeploymentInfo) Reset()

func (*WorkerDeploymentInfo) Size added in v1.44.0

func (val *WorkerDeploymentInfo) Size() int

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

func (*WorkerDeploymentInfo) String added in v1.44.0

func (x *WorkerDeploymentInfo) String() string

func (*WorkerDeploymentInfo) Unmarshal added in v1.44.0

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

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

type WorkerDeploymentInfo_WorkerDeploymentVersionSummary added in v1.44.0

type WorkerDeploymentInfo_WorkerDeploymentVersionSummary struct {

	// Deprecated. Use `deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// The status of the Worker Deployment Version.
	Status v1.WorkerDeploymentVersionStatus `protobuf:"varint,11,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkerDeploymentVersionStatus" json:"status,omitempty"`
	// Required.
	DeploymentVersion *WorkerDeploymentVersion `protobuf:"bytes,4,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
	CreateTime        *timestamppb.Timestamp   `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Deprecated. Use `drainage_info` instead.
	DrainageStatus v1.VersionDrainageStatus `` /* 153-byte string literal not displayed */
	// Information about workflow drainage to help the user determine when it is safe
	// to decommission a Version. Not present while version is current or ramping
	DrainageInfo *VersionDrainageInfo `protobuf:"bytes,5,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"`
	// Unset if not current.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=current_since_time,json=currentSinceTime,proto3" json:"current_since_time,omitempty"`
	// Unset if not ramping. Updated when the version first starts ramping, not on each ramp change.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"`
	// Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed.
	RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=routing_update_time,json=routingUpdateTime,proto3" json:"routing_update_time,omitempty"`
	// Timestamp when this version first became current or ramping.
	FirstActivationTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=first_activation_time,json=firstActivationTime,proto3" json:"first_activation_time,omitempty"`
	// Timestamp when this version last became current.
	// Can be used to determine whether a version has ever been Current.
	LastCurrentTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=last_current_time,json=lastCurrentTime,proto3" json:"last_current_time,omitempty"`
	// Timestamp when this version last stopped being current or ramping.
	// Cleared if the version becomes current or ramping again.
	LastDeactivationTime *timestamppb.Timestamp    `protobuf:"bytes,10,opt,name=last_deactivation_time,json=lastDeactivationTime,proto3" json:"last_deactivation_time,omitempty"`
	ComputeConfig        *v12.ComputeConfigSummary `protobuf:"bytes,13,opt,name=compute_config,json=computeConfig,proto3" json:"compute_config,omitempty"`
	// ComputeStatus represents compute-related configuration and healthchecks.
	ComputeStatus *ComputeStatus `protobuf:"bytes,14,opt,name=compute_status,json=computeStatus,proto3" json:"compute_status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) Descriptor deprecated added in v1.44.0

Deprecated: Use WorkerDeploymentInfo_WorkerDeploymentVersionSummary.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetComputeConfig added in v1.62.8

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetComputeStatus added in v1.63.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetCreateTime added in v1.44.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetCurrentSinceTime added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetDeploymentVersion added in v1.49.1

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetDrainageInfo added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetDrainageStatus added in v1.44.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetFirstActivationTime added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetLastCurrentTime added in v1.60.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetLastDeactivationTime added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetRampingSinceTime added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetRoutingUpdateTime added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetStatus added in v1.50.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) GetVersion deprecated added in v1.44.0

Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) ProtoMessage added in v1.44.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) ProtoReflect added in v1.44.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) Reset added in v1.44.0

func (*WorkerDeploymentInfo_WorkerDeploymentVersionSummary) String added in v1.44.0

type WorkerDeploymentOptions added in v1.44.0

type WorkerDeploymentOptions struct {

	// Required when `worker_versioning_mode==VERSIONED`.
	DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	// The Build ID of the worker. Required when `worker_versioning_mode==VERSIONED`, in which case,
	// the worker will be part of a Deployment Version.
	BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Required. Versioning Mode for this worker. Must be the same for all workers with the
	// same `deployment_name` and `build_id` combination, across all Task Queues.
	// When `worker_versioning_mode==VERSIONED`, the worker will be part of a Deployment Version.
	WorkerVersioningMode v1.WorkerVersioningMode `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

Worker Deployment options set in SDK that need to be sent to server in every poll.

func (*WorkerDeploymentOptions) Descriptor deprecated added in v1.44.0

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

Deprecated: Use WorkerDeploymentOptions.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentOptions) Equal added in v1.44.0

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

Equal returns whether two WorkerDeploymentOptions 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 (*WorkerDeploymentOptions) GetBuildId added in v1.44.0

func (x *WorkerDeploymentOptions) GetBuildId() string

func (*WorkerDeploymentOptions) GetDeploymentName added in v1.44.0

func (x *WorkerDeploymentOptions) GetDeploymentName() string

func (*WorkerDeploymentOptions) GetWorkerVersioningMode added in v1.44.0

func (x *WorkerDeploymentOptions) GetWorkerVersioningMode() v1.WorkerVersioningMode

func (*WorkerDeploymentOptions) Marshal added in v1.44.0

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

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

func (*WorkerDeploymentOptions) ProtoMessage added in v1.44.0

func (*WorkerDeploymentOptions) ProtoMessage()

func (*WorkerDeploymentOptions) ProtoReflect added in v1.44.0

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

func (*WorkerDeploymentOptions) Reset added in v1.44.0

func (x *WorkerDeploymentOptions) Reset()

func (*WorkerDeploymentOptions) Size added in v1.44.0

func (val *WorkerDeploymentOptions) Size() int

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

func (*WorkerDeploymentOptions) String added in v1.44.0

func (x *WorkerDeploymentOptions) String() string

func (*WorkerDeploymentOptions) Unmarshal added in v1.44.0

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

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

type WorkerDeploymentVersion added in v1.49.1

type WorkerDeploymentVersion struct {

	// A unique identifier for this Version within the Deployment it is a part of.
	// Not necessarily unique within the namespace.
	// The combination of `deployment_name` and `build_id` uniquely identifies this
	// Version within the namespace, because Deployment names are unique within a namespace.
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Identifies the Worker Deployment this Version is part of.
	DeploymentName string `protobuf:"bytes,2,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	// contains filtered or unexported fields
}

A Worker Deployment Version (Version, for short) represents a version of workers within a Worker Deployment. (see documentation of WorkerDeploymentVersionInfo) Version records are created in Temporal server automatically when their first poller arrives to the server. Experimental. Worker Deployment Versions are experimental and might significantly change in the future.

func (*WorkerDeploymentVersion) Descriptor deprecated added in v1.49.1

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

Deprecated: Use WorkerDeploymentVersion.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersion) Equal added in v1.49.1

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.49.1

func (x *WorkerDeploymentVersion) GetBuildId() string

func (*WorkerDeploymentVersion) GetDeploymentName added in v1.49.1

func (x *WorkerDeploymentVersion) GetDeploymentName() string

func (*WorkerDeploymentVersion) Marshal added in v1.49.1

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

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

func (*WorkerDeploymentVersion) ProtoMessage added in v1.49.1

func (*WorkerDeploymentVersion) ProtoMessage()

func (*WorkerDeploymentVersion) ProtoReflect added in v1.49.1

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

func (*WorkerDeploymentVersion) Reset added in v1.49.1

func (x *WorkerDeploymentVersion) Reset()

func (*WorkerDeploymentVersion) Size added in v1.49.1

func (val *WorkerDeploymentVersion) Size() int

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

func (*WorkerDeploymentVersion) String added in v1.49.1

func (x *WorkerDeploymentVersion) String() string

func (*WorkerDeploymentVersion) Unmarshal added in v1.49.1

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

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

type WorkerDeploymentVersionInfo added in v1.44.0

type WorkerDeploymentVersionInfo struct {

	// Deprecated. Use `deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// The status of the Worker Deployment Version.
	Status v1.WorkerDeploymentVersionStatus `protobuf:"varint,14,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkerDeploymentVersionStatus" json:"status,omitempty"`
	// Required.
	DeploymentVersion *WorkerDeploymentVersion `protobuf:"bytes,11,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
	// Deprecated. User deployment_version.deployment_name.
	DeploymentName string                 `protobuf:"bytes,2,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	CreateTime     *timestamppb.Timestamp `protobuf:"bytes,3,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.
	RoutingChangedTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=routing_changed_time,json=routingChangedTime,proto3" json:"routing_changed_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	//
	// Unset if not current.
	CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,5,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. --)
	//
	// Unset if not ramping. Updated when the version first starts ramping, not on each ramp change.
	RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"`
	// Timestamp when this version first became current or ramping.
	FirstActivationTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=first_activation_time,json=firstActivationTime,proto3" json:"first_activation_time,omitempty"`
	// Timestamp when this version last became current.
	// Can be used to determine whether a version has ever been Current.
	LastCurrentTime *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=last_current_time,json=lastCurrentTime,proto3" json:"last_current_time,omitempty"`
	// Timestamp when this version last stopped being current or ramping.
	// Cleared if the version becomes current or ramping again.
	LastDeactivationTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=last_deactivation_time,json=lastDeactivationTime,proto3" json:"last_deactivation_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,7,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"`
	// All the Task Queues that have ever polled from this Deployment version.
	// Deprecated. Use `version_task_queues` in DescribeWorkerDeploymentVersionResponse instead.
	TaskQueueInfos []*WorkerDeploymentVersionInfo_VersionTaskQueueInfo `protobuf:"bytes,8,rep,name=task_queue_infos,json=taskQueueInfos,proto3" json:"task_queue_infos,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 *VersionDrainageInfo `protobuf:"bytes,9,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"`
	// Arbitrary user-provided metadata attached to this version.
	Metadata *VersionMetadata `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Optional. Contains the new worker compute configuration for the Worker
	// Deployment. Used for worker scale management.
	ComputeConfig *v12.ComputeConfig `protobuf:"bytes,16,opt,name=compute_config,json=computeConfig,proto3" json:"compute_config,omitempty"`
	// Identity of the last client who modified the configuration of this Version.
	// As of now, this field only covers changes through the following APIs:
	// - `CreateWorkerDeploymentVersion`
	// - `UpdateWorkerDeploymentVersionComputeConfig`
	// - `UpdateWorkerDeploymentVersionMetadata`
	LastModifierIdentity string `protobuf:"bytes,17,opt,name=last_modifier_identity,json=lastModifierIdentity,proto3" json:"last_modifier_identity,omitempty"`
	// contains filtered or unexported fields
}

A Worker Deployment Version (Version, for short) represents all workers of the same code and config within a Deployment. Workers of the same Version are expected to behave exactly the same so when executions move between them there are no non-determinism issues. Worker Deployment Versions are created in Temporal server automatically when their first poller arrives to the server.

func (*WorkerDeploymentVersionInfo) Descriptor deprecated added in v1.44.0

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

Deprecated: Use WorkerDeploymentVersionInfo.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersionInfo) Equal added in v1.44.0

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

Equal returns whether two WorkerDeploymentVersionInfo 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 (*WorkerDeploymentVersionInfo) GetComputeConfig added in v1.62.8

func (x *WorkerDeploymentVersionInfo) GetComputeConfig() *v12.ComputeConfig

func (*WorkerDeploymentVersionInfo) GetCreateTime added in v1.44.0

func (*WorkerDeploymentVersionInfo) GetCurrentSinceTime added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetCurrentSinceTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionInfo) GetDeploymentName added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetDeploymentName() string

func (*WorkerDeploymentVersionInfo) GetDeploymentVersion added in v1.49.1

func (x *WorkerDeploymentVersionInfo) GetDeploymentVersion() *WorkerDeploymentVersion

func (*WorkerDeploymentVersionInfo) GetDrainageInfo added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetDrainageInfo() *VersionDrainageInfo

func (*WorkerDeploymentVersionInfo) GetFirstActivationTime added in v1.50.0

func (x *WorkerDeploymentVersionInfo) GetFirstActivationTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionInfo) GetLastCurrentTime added in v1.60.0

func (x *WorkerDeploymentVersionInfo) GetLastCurrentTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionInfo) GetLastDeactivationTime added in v1.50.0

func (x *WorkerDeploymentVersionInfo) GetLastDeactivationTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionInfo) GetLastModifierIdentity added in v1.62.8

func (x *WorkerDeploymentVersionInfo) GetLastModifierIdentity() string

func (*WorkerDeploymentVersionInfo) GetMetadata added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetMetadata() *VersionMetadata

func (*WorkerDeploymentVersionInfo) GetRampPercentage added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetRampPercentage() float32

func (*WorkerDeploymentVersionInfo) GetRampingSinceTime added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetRampingSinceTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionInfo) GetRoutingChangedTime added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetRoutingChangedTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionInfo) GetStatus added in v1.50.0

func (*WorkerDeploymentVersionInfo) GetTaskQueueInfos added in v1.44.0

func (*WorkerDeploymentVersionInfo) GetVersion deprecated added in v1.44.0

func (x *WorkerDeploymentVersionInfo) GetVersion() string

Deprecated: Marked as deprecated in temporal/api/deployment/v1/message.proto.

func (*WorkerDeploymentVersionInfo) Marshal added in v1.44.0

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

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

func (*WorkerDeploymentVersionInfo) ProtoMessage added in v1.44.0

func (*WorkerDeploymentVersionInfo) ProtoMessage()

func (*WorkerDeploymentVersionInfo) ProtoReflect added in v1.44.0

func (*WorkerDeploymentVersionInfo) Reset added in v1.44.0

func (x *WorkerDeploymentVersionInfo) Reset()

func (*WorkerDeploymentVersionInfo) Size added in v1.44.0

func (val *WorkerDeploymentVersionInfo) Size() int

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

func (*WorkerDeploymentVersionInfo) String added in v1.44.0

func (x *WorkerDeploymentVersionInfo) String() string

func (*WorkerDeploymentVersionInfo) Unmarshal added in v1.44.0

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

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

type WorkerDeploymentVersionInfo_VersionTaskQueueInfo added in v1.44.0

type WorkerDeploymentVersionInfo_VersionTaskQueueInfo struct {
	Name string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type v1.TaskQueueType `protobuf:"varint,2,opt,name=type,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) Descriptor deprecated added in v1.44.0

Deprecated: Use WorkerDeploymentVersionInfo_VersionTaskQueueInfo.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) GetName added in v1.44.0

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) GetType added in v1.44.0

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) ProtoMessage added in v1.44.0

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) ProtoReflect added in v1.44.0

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) Reset added in v1.44.0

func (*WorkerDeploymentVersionInfo_VersionTaskQueueInfo) String added in v1.44.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL