mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Shahab TajikandGitHub
37e7c4dd5d
## What changed? - Add compute config summary for latest and all other version so it is exposed in `ListWorkerDeployments` and `DescribeWorkerDeployment` APIs. ## Why? Mainly for UI to show compute provider types. ## How did you test it? - [x] built - [ ] run locally and tested manually - [x] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ## Potential risks None
4577 lines
190 KiB
Go
4577 lines
190 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// plugins:
|
|
// protoc-gen-go
|
|
// protoc
|
|
// source: temporal/server/api/deployment/v1/message.proto
|
|
|
|
package deployment
|
|
|
|
import (
|
|
reflect "reflect"
|
|
sync "sync"
|
|
unsafe "unsafe"
|
|
|
|
v13 "go.temporal.io/api/common/v1"
|
|
v12 "go.temporal.io/api/compute/v1"
|
|
v11 "go.temporal.io/api/deployment/v1"
|
|
v1 "go.temporal.io/api/enums/v1"
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
timestamppb "google.golang.org/protobuf/types/known/timestamppb"
|
|
)
|
|
|
|
const (
|
|
// Verify that this generated code is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
|
|
// Verify that runtime/protoimpl is sufficiently up-to-date.
|
|
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
|
|
)
|
|
|
|
// Identifies a Worker Deployment Version. The combination of `deployment_name` and `build_id`
|
|
// serve as the identifier.
|
|
type WorkerDeploymentVersion struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// 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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersion) Reset() {
|
|
*x = WorkerDeploymentVersion{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[0]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersion) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentVersion) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentVersion) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[0]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentVersion.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentVersion) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{0}
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersion) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersion) GetBuildId() string {
|
|
if x != nil {
|
|
return x.BuildId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// The source of truth for this data is in the WorkerDeployment entity workflows, which is
|
|
// synced to all TQs whenever the source changes.
|
|
// Deprecated.
|
|
type DeploymentVersionData struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// 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"`
|
|
// Status of the Worker Deployment Version.
|
|
Status v1.WorkerDeploymentVersionStatus `protobuf:"varint,6,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkerDeploymentVersionStatus" json:"status,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeploymentVersionData) Reset() {
|
|
*x = DeploymentVersionData{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[1]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeploymentVersionData) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeploymentVersionData) ProtoMessage() {}
|
|
|
|
func (x *DeploymentVersionData) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[1]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DeploymentVersionData.ProtoReflect.Descriptor instead.
|
|
func (*DeploymentVersionData) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{1}
|
|
}
|
|
|
|
func (x *DeploymentVersionData) GetVersion() *WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *DeploymentVersionData) GetRoutingUpdateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RoutingUpdateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *DeploymentVersionData) GetCurrentSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CurrentSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *DeploymentVersionData) GetRampingSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RampingSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *DeploymentVersionData) GetRampPercentage() float32 {
|
|
if x != nil {
|
|
return x.RampPercentage
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *DeploymentVersionData) GetStatus() v1.WorkerDeploymentVersionStatus {
|
|
if x != nil {
|
|
return x.Status
|
|
}
|
|
return v1.WorkerDeploymentVersionStatus(0)
|
|
}
|
|
|
|
// Information that a TQ should know about a particular Deployment Version. This info is not part of
|
|
// RoutingConfig and hence not protected by the routing config revision number.
|
|
// As of Workflow Version `VersionDataRevisionNumber`, version specific data has its own revision
|
|
// number, which makes async propagations safer and allows async registration.
|
|
type WorkerDeploymentVersionData struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Incremented everytime version data changes. Updates with lower revision number than what is
|
|
// already in the TQ will be ignored to avoid stale writes.
|
|
RevisionNumber int64 `protobuf:"varint,1,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
|
|
// Last update time. Used for garbage collecting deleted versions from TQ user data.
|
|
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
|
|
// In order to protect against deletes being overwritten by delayed stale writes, we can't
|
|
// immediately delete the version data from task queues. instead, we mark them as deleted while
|
|
// keeping the revision number.
|
|
// Old enough deleted versions are GCed based on update_time.
|
|
// Deprecated. This mechanism is not safe against reactivation of versions after delete.
|
|
// Use forget_version flag for synchronous deletion of the version data from TQ.
|
|
Deleted bool `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
|
|
Status v1.WorkerDeploymentVersionStatus `protobuf:"varint,6,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkerDeploymentVersionStatus" json:"status,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionData) Reset() {
|
|
*x = WorkerDeploymentVersionData{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[2]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionData) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentVersionData) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentVersionData) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[2]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentVersionData.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentVersionData) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{2}
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionData) GetRevisionNumber() int64 {
|
|
if x != nil {
|
|
return x.RevisionNumber
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionData) GetUpdateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.UpdateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionData) GetDeleted() bool {
|
|
if x != nil {
|
|
return x.Deleted
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionData) GetStatus() v1.WorkerDeploymentVersionStatus {
|
|
if x != nil {
|
|
return x.Status
|
|
}
|
|
return v1.WorkerDeploymentVersionStatus(0)
|
|
}
|
|
|
|
// Local state for Worker Deployment Version
|
|
type VersionLocalState struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
// 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,16,opt,name=last_current_time,json=lastCurrentTime,proto3" json:"last_current_time,omitempty"`
|
|
// Timestamp when this version last stopped being current or ramping.
|
|
LastDeactivationTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=last_deactivation_time,json=lastDeactivationTime,proto3" json:"last_deactivation_time,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 *v11.VersionDrainageInfo `protobuf:"bytes,7,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"`
|
|
// Arbitrary user-provided metadata attached to this version.
|
|
Metadata *v11.VersionMetadata `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
|
// Deployment workflow should always be running before starting the version workflow.
|
|
// We should not start the deployment workflow. If we cannot find the deployment workflow when signaling, it means a bug and we should fix it.
|
|
// Deprecated.
|
|
//
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
StartedDeploymentWorkflow bool `protobuf:"varint,9,opt,name=started_deployment_workflow,json=startedDeploymentWorkflow,proto3" json:"started_deployment_workflow,omitempty"`
|
|
// Key: Task Queue Name
|
|
TaskQueueFamilies map[string]*VersionLocalState_TaskQueueFamilyData `protobuf:"bytes,10,rep,name=task_queue_families,json=taskQueueFamilies,proto3" json:"task_queue_families,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
// Number of task queues which will be synced in a single batch.
|
|
SyncBatchSize int32 `protobuf:"varint,11,opt,name=sync_batch_size,json=syncBatchSize,proto3" json:"sync_batch_size,omitempty"`
|
|
// 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"`
|
|
// Incremented everytime version data synced to TQ changes. Updates with lower revision number
|
|
// than what is already in the TQ will be ignored to avoid stale writes during async operations.
|
|
RevisionNumber int64 `protobuf:"varint,15,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
|
|
// Identity of the last client who modified the configuration of this Version.
|
|
// Covers changes through: CreateWorkerDeploymentVersion, UpdateWorkerDeploymentVersionComputeConfig,
|
|
// UpdateWorkerDeploymentVersionMetadata.
|
|
LastModifierIdentity string `protobuf:"bytes,17,opt,name=last_modifier_identity,json=lastModifierIdentity,proto3" json:"last_modifier_identity,omitempty"`
|
|
// Cached compute config summary, kept in sync with the WCI on each compute config update.
|
|
ComputeConfig *v12.ComputeConfigSummary `protobuf:"bytes,18,opt,name=compute_config,json=computeConfig,proto3" json:"compute_config,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *VersionLocalState) Reset() {
|
|
*x = VersionLocalState{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[3]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *VersionLocalState) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*VersionLocalState) ProtoMessage() {}
|
|
|
|
func (x *VersionLocalState) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[3]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use VersionLocalState.ProtoReflect.Descriptor instead.
|
|
func (*VersionLocalState) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{3}
|
|
}
|
|
|
|
func (x *VersionLocalState) GetVersion() *WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetRoutingUpdateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RoutingUpdateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetCurrentSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CurrentSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetRampingSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RampingSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetRampPercentage() float32 {
|
|
if x != nil {
|
|
return x.RampPercentage
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *VersionLocalState) GetFirstActivationTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.FirstActivationTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetLastCurrentTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastCurrentTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetLastDeactivationTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastDeactivationTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetDrainageInfo() *v11.VersionDrainageInfo {
|
|
if x != nil {
|
|
return x.DrainageInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetMetadata() *v11.VersionMetadata {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *VersionLocalState) GetStartedDeploymentWorkflow() bool {
|
|
if x != nil {
|
|
return x.StartedDeploymentWorkflow
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *VersionLocalState) GetTaskQueueFamilies() map[string]*VersionLocalState_TaskQueueFamilyData {
|
|
if x != nil {
|
|
return x.TaskQueueFamilies
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *VersionLocalState) GetSyncBatchSize() int32 {
|
|
if x != nil {
|
|
return x.SyncBatchSize
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *VersionLocalState) GetStatus() v1.WorkerDeploymentVersionStatus {
|
|
if x != nil {
|
|
return x.Status
|
|
}
|
|
return v1.WorkerDeploymentVersionStatus(0)
|
|
}
|
|
|
|
func (x *VersionLocalState) GetRevisionNumber() int64 {
|
|
if x != nil {
|
|
return x.RevisionNumber
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *VersionLocalState) GetLastModifierIdentity() string {
|
|
if x != nil {
|
|
return x.LastModifierIdentity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *VersionLocalState) GetComputeConfig() *v12.ComputeConfigSummary {
|
|
if x != nil {
|
|
return x.ComputeConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Data specific to a task queue, from the perspective of a worker deployment version.
|
|
type TaskQueueVersionData struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *TaskQueueVersionData) Reset() {
|
|
*x = TaskQueueVersionData{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[4]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *TaskQueueVersionData) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*TaskQueueVersionData) ProtoMessage() {}
|
|
|
|
func (x *TaskQueueVersionData) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[4]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use TaskQueueVersionData.ProtoReflect.Descriptor instead.
|
|
func (*TaskQueueVersionData) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{4}
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow input:
|
|
type WorkerDeploymentVersionWorkflowArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionWorkflowArgs) Reset() {
|
|
*x = WorkerDeploymentVersionWorkflowArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[5]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionWorkflowArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentVersionWorkflowArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[5]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentVersionWorkflowArgs.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentVersionWorkflowArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{5}
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceName() string {
|
|
if x != nil {
|
|
return x.NamespaceName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionWorkflowArgs) GetVersionState() *VersionLocalState {
|
|
if x != nil {
|
|
return x.VersionState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow input:
|
|
type WorkerDeploymentWorkflowArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) Reset() {
|
|
*x = WorkerDeploymentWorkflowArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[6]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentWorkflowArgs) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[6]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentWorkflowArgs.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentWorkflowArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{6}
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) GetNamespaceName() string {
|
|
if x != nil {
|
|
return x.NamespaceName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) GetNamespaceId() string {
|
|
if x != nil {
|
|
return x.NamespaceId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowArgs) GetState() *WorkerDeploymentLocalState {
|
|
if x != nil {
|
|
return x.State
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Local state for Worker Deployment
|
|
type WorkerDeploymentLocalState struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 *v11.RoutingConfig `protobuf:"bytes,2,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
|
|
Versions map[string]*WorkerDeploymentVersionSummary `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
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"`
|
|
// Number of task queues which will be synced in a single batch.
|
|
SyncBatchSize int32 `protobuf:"varint,6,opt,name=sync_batch_size,json=syncBatchSize,proto3" json:"sync_batch_size,omitempty"`
|
|
ManagerIdentity string `protobuf:"bytes,7,opt,name=manager_identity,json=managerIdentity,proto3" json:"manager_identity,omitempty"`
|
|
// Track async propagations in progress per build ID. Map: build_id -> revision numbers.
|
|
// Used to track which propagations are still pending across continue-as-new.
|
|
PropagatingRevisions map[string]*PropagatingRevisions `protobuf:"bytes,8,rep,name=propagating_revisions,json=propagatingRevisions,proto3" json:"propagating_revisions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
// Request ID used to create this worker deployment.
|
|
CreateRequestId string `protobuf:"bytes,9,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) Reset() {
|
|
*x = WorkerDeploymentLocalState{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[7]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentLocalState) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentLocalState) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[7]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentLocalState.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentLocalState) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{7}
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetRoutingConfig() *v11.RoutingConfig {
|
|
if x != nil {
|
|
return x.RoutingConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetVersions() map[string]*WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.Versions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetLastModifierIdentity() string {
|
|
if x != nil {
|
|
return x.LastModifierIdentity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetSyncBatchSize() int32 {
|
|
if x != nil {
|
|
return x.SyncBatchSize
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetManagerIdentity() string {
|
|
if x != nil {
|
|
return x.ManagerIdentity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetPropagatingRevisions() map[string]*PropagatingRevisions {
|
|
if x != nil {
|
|
return x.PropagatingRevisions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentLocalState) GetCreateRequestId() string {
|
|
if x != nil {
|
|
return x.CreateRequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// Tracks revision numbers that are currently propagating for a specific build ID
|
|
type PropagatingRevisions struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
RevisionNumbers []int64 `protobuf:"varint,1,rep,packed,name=revision_numbers,json=revisionNumbers,proto3" json:"revision_numbers,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *PropagatingRevisions) Reset() {
|
|
*x = PropagatingRevisions{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[8]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *PropagatingRevisions) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*PropagatingRevisions) ProtoMessage() {}
|
|
|
|
func (x *PropagatingRevisions) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[8]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use PropagatingRevisions.ProtoReflect.Descriptor instead.
|
|
func (*PropagatingRevisions) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{8}
|
|
}
|
|
|
|
func (x *PropagatingRevisions) GetRevisionNumbers() []int64 {
|
|
if x != nil {
|
|
return x.RevisionNumbers
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type WorkerDeploymentVersionSummary struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
DrainageStatus v1.VersionDrainageStatus `protobuf:"varint,3,opt,name=drainage_status,json=drainageStatus,proto3,enum=temporal.api.enums.v1.VersionDrainageStatus" json:"drainage_status,omitempty"`
|
|
// 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 *v11.VersionDrainageInfo `protobuf:"bytes,4,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"`
|
|
// Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed.
|
|
RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,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,6,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,7,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,8,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,11,opt,name=last_current_time,json=lastCurrentTime,proto3" json:"last_current_time,omitempty"`
|
|
// Timestamp when this version last stopped being current or ramping.
|
|
LastDeactivationTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=last_deactivation_time,json=lastDeactivationTime,proto3" json:"last_deactivation_time,omitempty"`
|
|
// Status of the Worker Deployment Version.
|
|
Status v1.WorkerDeploymentVersionStatus `protobuf:"varint,10,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkerDeploymentVersionStatus" json:"status,omitempty"`
|
|
// Request ID used to create this version. Used for idempotency.
|
|
// Not synced from the version workflow; only set by the deployment workflow.
|
|
CreateRequestId string `protobuf:"bytes,12,opt,name=create_request_id,json=createRequestId,proto3" json:"create_request_id,omitempty"`
|
|
// Compute config summary for this version. Synced from the version workflow on each compute config update.
|
|
// Also set by the deployment workflow at version creation time if a compute config was provided.
|
|
ComputeConfig *v12.ComputeConfigSummary `protobuf:"bytes,13,opt,name=compute_config,json=computeConfig,proto3" json:"compute_config,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) Reset() {
|
|
*x = WorkerDeploymentVersionSummary{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[9]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentVersionSummary) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[9]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentVersionSummary.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentVersionSummary) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{9}
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *WorkerDeploymentVersionSummary) GetDrainageStatus() v1.VersionDrainageStatus {
|
|
if x != nil {
|
|
return x.DrainageStatus
|
|
}
|
|
return v1.VersionDrainageStatus(0)
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetDrainageInfo() *v11.VersionDrainageInfo {
|
|
if x != nil {
|
|
return x.DrainageInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetRoutingUpdateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RoutingUpdateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetCurrentSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CurrentSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetRampingSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RampingSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetFirstActivationTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.FirstActivationTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetLastCurrentTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastCurrentTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetLastDeactivationTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.LastDeactivationTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetStatus() v1.WorkerDeploymentVersionStatus {
|
|
if x != nil {
|
|
return x.Status
|
|
}
|
|
return v1.WorkerDeploymentVersionStatus(0)
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetCreateRequestId() string {
|
|
if x != nil {
|
|
return x.CreateRequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentVersionSummary) GetComputeConfig() *v12.ComputeConfigSummary {
|
|
if x != nil {
|
|
return x.ComputeConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow update input:
|
|
type RegisterWorkerInVersionArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskQueueName string `protobuf:"bytes,1,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"`
|
|
TaskQueueType v1.TaskQueueType `protobuf:"varint,2,opt,name=task_queue_type,json=taskQueueType,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"task_queue_type,omitempty"`
|
|
MaxTaskQueues int32 `protobuf:"varint,3,opt,name=max_task_queues,json=maxTaskQueues,proto3" json:"max_task_queues,omitempty"`
|
|
Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
|
|
RoutingConfig *v11.RoutingConfig `protobuf:"bytes,5,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) Reset() {
|
|
*x = RegisterWorkerInVersionArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[10]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*RegisterWorkerInVersionArgs) ProtoMessage() {}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[10]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use RegisterWorkerInVersionArgs.ProtoReflect.Descriptor instead.
|
|
func (*RegisterWorkerInVersionArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{10}
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) GetTaskQueueName() string {
|
|
if x != nil {
|
|
return x.TaskQueueName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) GetTaskQueueType() v1.TaskQueueType {
|
|
if x != nil {
|
|
return x.TaskQueueType
|
|
}
|
|
return v1.TaskQueueType(0)
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) GetMaxTaskQueues() int32 {
|
|
if x != nil {
|
|
return x.MaxTaskQueues
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *RegisterWorkerInVersionArgs) GetRoutingConfig() *v11.RoutingConfig {
|
|
if x != nil {
|
|
return x.RoutingConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type RegisterWorkerInWorkerDeploymentArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskQueueName string `protobuf:"bytes,1,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"`
|
|
TaskQueueType v1.TaskQueueType `protobuf:"varint,2,opt,name=task_queue_type,json=taskQueueType,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"task_queue_type,omitempty"`
|
|
MaxTaskQueues int32 `protobuf:"varint,3,opt,name=max_task_queues,json=maxTaskQueues,proto3" json:"max_task_queues,omitempty"`
|
|
Version *WorkerDeploymentVersion `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) Reset() {
|
|
*x = RegisterWorkerInWorkerDeploymentArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[11]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*RegisterWorkerInWorkerDeploymentArgs) ProtoMessage() {}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[11]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use RegisterWorkerInWorkerDeploymentArgs.ProtoReflect.Descriptor instead.
|
|
func (*RegisterWorkerInWorkerDeploymentArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{11}
|
|
}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) GetTaskQueueName() string {
|
|
if x != nil {
|
|
return x.TaskQueueName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) GetTaskQueueType() v1.TaskQueueType {
|
|
if x != nil {
|
|
return x.TaskQueueType
|
|
}
|
|
return v1.TaskQueueType(0)
|
|
}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) GetMaxTaskQueues() int32 {
|
|
if x != nil {
|
|
return x.MaxTaskQueues
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *RegisterWorkerInWorkerDeploymentArgs) GetVersion() *WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow activity input:
|
|
type DescribeVersionFromWorkerDeploymentActivityArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityArgs) Reset() {
|
|
*x = DescribeVersionFromWorkerDeploymentActivityArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[12]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DescribeVersionFromWorkerDeploymentActivityArgs) ProtoMessage() {}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[12]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DescribeVersionFromWorkerDeploymentActivityArgs.ProtoReflect.Descriptor instead.
|
|
func (*DescribeVersionFromWorkerDeploymentActivityArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{12}
|
|
}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type DescribeVersionFromWorkerDeploymentActivityResult struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// All the Task Queues that have ever polled from this Deployment version.
|
|
TaskQueueInfos []*v11.WorkerDeploymentVersionInfo_VersionTaskQueueInfo `protobuf:"bytes,1,rep,name=task_queue_infos,json=taskQueueInfos,proto3" json:"task_queue_infos,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityResult) Reset() {
|
|
*x = DescribeVersionFromWorkerDeploymentActivityResult{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[13]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityResult) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DescribeVersionFromWorkerDeploymentActivityResult) ProtoMessage() {}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityResult) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[13]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DescribeVersionFromWorkerDeploymentActivityResult.ProtoReflect.Descriptor instead.
|
|
func (*DescribeVersionFromWorkerDeploymentActivityResult) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{13}
|
|
}
|
|
|
|
func (x *DescribeVersionFromWorkerDeploymentActivityResult) GetTaskQueueInfos() []*v11.WorkerDeploymentVersionInfo_VersionTaskQueueInfo {
|
|
if x != nil {
|
|
return x.TaskQueueInfos
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input (sent from Worker Deployment workflow):
|
|
type SyncVersionStateUpdateArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed.
|
|
//
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
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.
|
|
//
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
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.
|
|
//
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
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.
|
|
//
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
RampPercentage float32 `protobuf:"fixed32,4,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"`
|
|
// Full routing config for async propagation mode. When present, the version workflow
|
|
// will propagate the entire routing config asynchronously. When absent, sync mode is used.
|
|
RoutingConfig *v11.RoutingConfig `protobuf:"bytes,5,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncVersionStateUpdateArgs) Reset() {
|
|
*x = SyncVersionStateUpdateArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[14]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncVersionStateUpdateArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncVersionStateUpdateArgs) ProtoMessage() {}
|
|
|
|
func (x *SyncVersionStateUpdateArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[14]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncVersionStateUpdateArgs.ProtoReflect.Descriptor instead.
|
|
func (*SyncVersionStateUpdateArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{14}
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *SyncVersionStateUpdateArgs) GetRoutingUpdateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RoutingUpdateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *SyncVersionStateUpdateArgs) GetCurrentSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CurrentSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *SyncVersionStateUpdateArgs) GetRampingSinceTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.RampingSinceTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *SyncVersionStateUpdateArgs) GetRampPercentage() float32 {
|
|
if x != nil {
|
|
return x.RampPercentage
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SyncVersionStateUpdateArgs) GetRoutingConfig() *v11.RoutingConfig {
|
|
if x != nil {
|
|
return x.RoutingConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update response (sent from Worker Deployment workflow):
|
|
type SyncVersionStateResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Deprecated. State could be so large, no need to send it to the deployment workflow.
|
|
//
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"`
|
|
Summary *WorkerDeploymentVersionSummary `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncVersionStateResponse) Reset() {
|
|
*x = SyncVersionStateResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[15]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncVersionStateResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncVersionStateResponse) ProtoMessage() {}
|
|
|
|
func (x *SyncVersionStateResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[15]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncVersionStateResponse.ProtoReflect.Descriptor instead.
|
|
func (*SyncVersionStateResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{15}
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *SyncVersionStateResponse) GetVersionState() *VersionLocalState {
|
|
if x != nil {
|
|
return x.VersionState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncVersionStateResponse) GetSummary() *WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.Summary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Sent from Version workflow to Worker Deployment workflow
|
|
type AddVersionUpdateArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *AddVersionUpdateArgs) Reset() {
|
|
*x = AddVersionUpdateArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[16]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *AddVersionUpdateArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*AddVersionUpdateArgs) ProtoMessage() {}
|
|
|
|
func (x *AddVersionUpdateArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[16]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use AddVersionUpdateArgs.ProtoReflect.Descriptor instead.
|
|
func (*AddVersionUpdateArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{16}
|
|
}
|
|
|
|
func (x *AddVersionUpdateArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *AddVersionUpdateArgs) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Sent from Drainage child workflow to Version parent
|
|
type SyncDrainageInfoSignalArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
DrainageInfo *v11.VersionDrainageInfo `protobuf:"bytes,1,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncDrainageInfoSignalArgs) Reset() {
|
|
*x = SyncDrainageInfoSignalArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[17]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncDrainageInfoSignalArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncDrainageInfoSignalArgs) ProtoMessage() {}
|
|
|
|
func (x *SyncDrainageInfoSignalArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[17]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncDrainageInfoSignalArgs.ProtoReflect.Descriptor instead.
|
|
func (*SyncDrainageInfoSignalArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{17}
|
|
}
|
|
|
|
func (x *SyncDrainageInfoSignalArgs) GetDrainageInfo() *v11.VersionDrainageInfo {
|
|
if x != nil {
|
|
return x.DrainageInfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Sent from Version workflow to Worker Deployment workflow
|
|
type SyncDrainageStatusSignalArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
|
|
DrainageStatus v1.VersionDrainageStatus `protobuf:"varint,2,opt,name=drainage_status,json=drainageStatus,proto3,enum=temporal.api.enums.v1.VersionDrainageStatus" json:"drainage_status,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncDrainageStatusSignalArgs) Reset() {
|
|
*x = SyncDrainageStatusSignalArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[18]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncDrainageStatusSignalArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncDrainageStatusSignalArgs) ProtoMessage() {}
|
|
|
|
func (x *SyncDrainageStatusSignalArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[18]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncDrainageStatusSignalArgs.ProtoReflect.Descriptor instead.
|
|
func (*SyncDrainageStatusSignalArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{18}
|
|
}
|
|
|
|
func (x *SyncDrainageStatusSignalArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncDrainageStatusSignalArgs) GetDrainageStatus() v1.VersionDrainageStatus {
|
|
if x != nil {
|
|
return x.DrainageStatus
|
|
}
|
|
return v1.VersionDrainageStatus(0)
|
|
}
|
|
|
|
// Sent from Version workflow to Worker Deployment workflow when async propagation completes
|
|
type PropagationCompletionInfo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
RevisionNumber int64 `protobuf:"varint,1,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
|
|
BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *PropagationCompletionInfo) Reset() {
|
|
*x = PropagationCompletionInfo{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[19]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *PropagationCompletionInfo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*PropagationCompletionInfo) ProtoMessage() {}
|
|
|
|
func (x *PropagationCompletionInfo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[19]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use PropagationCompletionInfo.ProtoReflect.Descriptor instead.
|
|
func (*PropagationCompletionInfo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{19}
|
|
}
|
|
|
|
func (x *PropagationCompletionInfo) GetRevisionNumber() int64 {
|
|
if x != nil {
|
|
return x.RevisionNumber
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *PropagationCompletionInfo) GetBuildId() string {
|
|
if x != nil {
|
|
return x.BuildId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow query response:
|
|
type QueryDescribeVersionResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *QueryDescribeVersionResponse) Reset() {
|
|
*x = QueryDescribeVersionResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[20]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *QueryDescribeVersionResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*QueryDescribeVersionResponse) ProtoMessage() {}
|
|
|
|
func (x *QueryDescribeVersionResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[20]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use QueryDescribeVersionResponse.ProtoReflect.Descriptor instead.
|
|
func (*QueryDescribeVersionResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{20}
|
|
}
|
|
|
|
func (x *QueryDescribeVersionResponse) GetVersionState() *VersionLocalState {
|
|
if x != nil {
|
|
return x.VersionState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow query response:
|
|
type QueryDescribeWorkerDeploymentResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
State *WorkerDeploymentLocalState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *QueryDescribeWorkerDeploymentResponse) Reset() {
|
|
*x = QueryDescribeWorkerDeploymentResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[21]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *QueryDescribeWorkerDeploymentResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage() {}
|
|
|
|
func (x *QueryDescribeWorkerDeploymentResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[21]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use QueryDescribeWorkerDeploymentResponse.ProtoReflect.Descriptor instead.
|
|
func (*QueryDescribeWorkerDeploymentResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{21}
|
|
}
|
|
|
|
func (x *QueryDescribeWorkerDeploymentResponse) GetState() *WorkerDeploymentLocalState {
|
|
if x != nil {
|
|
return x.State
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow query response:
|
|
type CreateRequestIDQueryResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
|
|
ConflictToken []byte `protobuf:"bytes,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateRequestIDQueryResponse) Reset() {
|
|
*x = CreateRequestIDQueryResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[22]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateRequestIDQueryResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateRequestIDQueryResponse) ProtoMessage() {}
|
|
|
|
func (x *CreateRequestIDQueryResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[22]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CreateRequestIDQueryResponse.ProtoReflect.Descriptor instead.
|
|
func (*CreateRequestIDQueryResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{22}
|
|
}
|
|
|
|
func (x *CreateRequestIDQueryResponse) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *CreateRequestIDQueryResponse) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow activity input:
|
|
type StartWorkerDeploymentRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentRequest) Reset() {
|
|
*x = StartWorkerDeploymentRequest{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[23]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StartWorkerDeploymentRequest) ProtoMessage() {}
|
|
|
|
func (x *StartWorkerDeploymentRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[23]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StartWorkerDeploymentRequest.ProtoReflect.Descriptor instead.
|
|
func (*StartWorkerDeploymentRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{23}
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentRequest) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentRequest) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment workflow activity input:
|
|
type StartWorkerDeploymentVersionRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
|
|
BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
|
|
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
|
|
Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
ComputeConfig *v12.ComputeConfigSummary `protobuf:"bytes,5,opt,name=compute_config,json=computeConfig,proto3" json:"compute_config,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) Reset() {
|
|
*x = StartWorkerDeploymentVersionRequest{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[24]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*StartWorkerDeploymentVersionRequest) ProtoMessage() {}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[24]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use StartWorkerDeploymentVersionRequest.ProtoReflect.Descriptor instead.
|
|
func (*StartWorkerDeploymentVersionRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{24}
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) GetBuildId() string {
|
|
if x != nil {
|
|
return x.BuildId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *StartWorkerDeploymentVersionRequest) GetComputeConfig() *v12.ComputeConfigSummary {
|
|
if x != nil {
|
|
return x.ComputeConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow activity input:
|
|
type SyncDeploymentVersionUserDataRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
DeploymentName string `protobuf:"bytes,4,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
|
|
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"`
|
|
// Async mode: full routing config to propagate (includes revision_number)
|
|
UpdateRoutingConfig *v11.RoutingConfig `protobuf:"bytes,5,opt,name=update_routing_config,json=updateRoutingConfig,proto3" json:"update_routing_config,omitempty"`
|
|
// Async mode: version-specific data to upsert
|
|
UpsertVersionData *WorkerDeploymentVersionData `protobuf:"bytes,6,opt,name=upsert_version_data,json=upsertVersionData,proto3" json:"upsert_version_data,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) Reset() {
|
|
*x = SyncDeploymentVersionUserDataRequest{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[25]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncDeploymentVersionUserDataRequest) ProtoMessage() {}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[25]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncDeploymentVersionUserDataRequest.ProtoReflect.Descriptor instead.
|
|
func (*SyncDeploymentVersionUserDataRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{25}
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) GetVersion() *WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) GetSync() []*SyncDeploymentVersionUserDataRequest_SyncUserData {
|
|
if x != nil {
|
|
return x.Sync
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) GetForgetVersion() bool {
|
|
if x != nil {
|
|
return x.ForgetVersion
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) GetUpdateRoutingConfig() *v11.RoutingConfig {
|
|
if x != nil {
|
|
return x.UpdateRoutingConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest) GetUpsertVersionData() *WorkerDeploymentVersionData {
|
|
if x != nil {
|
|
return x.UpsertVersionData
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow activity output:
|
|
type SyncDeploymentVersionUserDataResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskQueueMaxVersions map[string]int64 `protobuf:"bytes,1,rep,name=task_queue_max_versions,json=taskQueueMaxVersions,proto3" json:"task_queue_max_versions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataResponse) Reset() {
|
|
*x = SyncDeploymentVersionUserDataResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[26]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncDeploymentVersionUserDataResponse) ProtoMessage() {}
|
|
|
|
func (x *SyncDeploymentVersionUserDataResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[26]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncDeploymentVersionUserDataResponse.ProtoReflect.Descriptor instead.
|
|
func (*SyncDeploymentVersionUserDataResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{26}
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataResponse) GetTaskQueueMaxVersions() map[string]int64 {
|
|
if x != nil {
|
|
return x.TaskQueueMaxVersions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow activity input:
|
|
type CheckWorkerDeploymentUserDataPropagationRequest struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskQueueMaxVersions map[string]int64 `protobuf:"bytes,1,rep,name=task_queue_max_versions,json=taskQueueMaxVersions,proto3" json:"task_queue_max_versions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CheckWorkerDeploymentUserDataPropagationRequest) Reset() {
|
|
*x = CheckWorkerDeploymentUserDataPropagationRequest{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[27]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CheckWorkerDeploymentUserDataPropagationRequest) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage() {}
|
|
|
|
func (x *CheckWorkerDeploymentUserDataPropagationRequest) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[27]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CheckWorkerDeploymentUserDataPropagationRequest.ProtoReflect.Descriptor instead.
|
|
func (*CheckWorkerDeploymentUserDataPropagationRequest) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{27}
|
|
}
|
|
|
|
func (x *CheckWorkerDeploymentUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64 {
|
|
if x != nil {
|
|
return x.TaskQueueMaxVersions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow activity input:
|
|
type SyncUnversionedRampActivityArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityArgs) Reset() {
|
|
*x = SyncUnversionedRampActivityArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[28]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncUnversionedRampActivityArgs) ProtoMessage() {}
|
|
|
|
func (x *SyncUnversionedRampActivityArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[28]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncUnversionedRampActivityArgs.ProtoReflect.Descriptor instead.
|
|
func (*SyncUnversionedRampActivityArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{28}
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityArgs) GetCurrentVersion() string {
|
|
if x != nil {
|
|
return x.CurrentVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs {
|
|
if x != nil {
|
|
return x.UpdateArgs
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow activity output:
|
|
type SyncUnversionedRampActivityResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
TaskQueueMaxVersions map[string]int64 `protobuf:"bytes,1,rep,name=task_queue_max_versions,json=taskQueueMaxVersions,proto3" json:"task_queue_max_versions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"varint,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityResponse) Reset() {
|
|
*x = SyncUnversionedRampActivityResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[29]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncUnversionedRampActivityResponse) ProtoMessage() {}
|
|
|
|
func (x *SyncUnversionedRampActivityResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[29]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncUnversionedRampActivityResponse.ProtoReflect.Descriptor instead.
|
|
func (*SyncUnversionedRampActivityResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{29}
|
|
}
|
|
|
|
func (x *SyncUnversionedRampActivityResponse) GetTaskQueueMaxVersions() map[string]int64 {
|
|
if x != nil {
|
|
return x.TaskQueueMaxVersions
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow update input:
|
|
type UpdateVersionMetadataArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
UpsertEntries map[string]*v13.Payload `protobuf:"bytes,1,rep,name=upsert_entries,json=upsertEntries,proto3" json:"upsert_entries,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataArgs) Reset() {
|
|
*x = UpdateVersionMetadataArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[30]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateVersionMetadataArgs) ProtoMessage() {}
|
|
|
|
func (x *UpdateVersionMetadataArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[30]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use UpdateVersionMetadataArgs.ProtoReflect.Descriptor instead.
|
|
func (*UpdateVersionMetadataArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{30}
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataArgs) GetUpsertEntries() map[string]*v13.Payload {
|
|
if x != nil {
|
|
return x.UpsertEntries
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataArgs) GetRemoveEntries() []string {
|
|
if x != nil {
|
|
return x.RemoveEntries
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment Version workflow update response:
|
|
type UpdateVersionMetadataResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Metadata *v11.VersionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataResponse) Reset() {
|
|
*x = UpdateVersionMetadataResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[31]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateVersionMetadataResponse) ProtoMessage() {}
|
|
|
|
func (x *UpdateVersionMetadataResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[31]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use UpdateVersionMetadataResponse.ProtoReflect.Descriptor instead.
|
|
func (*UpdateVersionMetadataResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{31}
|
|
}
|
|
|
|
func (x *UpdateVersionMetadataResponse) GetMetadata() *v11.VersionMetadata {
|
|
if x != nil {
|
|
return x.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type SetCurrentVersionArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 `protobuf:"varint,3,opt,name=ignore_missing_task_queues,json=ignoreMissingTaskQueues,proto3" json:"ignore_missing_task_queues,omitempty"`
|
|
ConflictToken []byte `protobuf:"bytes,4,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
|
|
AllowNoPollers bool `protobuf:"varint,5,opt,name=allow_no_pollers,json=allowNoPollers,proto3" json:"allow_no_pollers,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) Reset() {
|
|
*x = SetCurrentVersionArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[32]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SetCurrentVersionArgs) ProtoMessage() {}
|
|
|
|
func (x *SetCurrentVersionArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[32]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SetCurrentVersionArgs.ProtoReflect.Descriptor instead.
|
|
func (*SetCurrentVersionArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{32}
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) GetIgnoreMissingTaskQueues() bool {
|
|
if x != nil {
|
|
return x.IgnoreMissingTaskQueues
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SetCurrentVersionArgs) GetAllowNoPollers() bool {
|
|
if x != nil {
|
|
return x.AllowNoPollers
|
|
}
|
|
return false
|
|
}
|
|
|
|
// used as Worker Deployment update response:
|
|
type SetCurrentVersionResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SetCurrentVersionResponse) Reset() {
|
|
*x = SetCurrentVersionResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[33]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SetCurrentVersionResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SetCurrentVersionResponse) ProtoMessage() {}
|
|
|
|
func (x *SetCurrentVersionResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[33]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SetCurrentVersionResponse.ProtoReflect.Descriptor instead.
|
|
func (*SetCurrentVersionResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{33}
|
|
}
|
|
|
|
func (x *SetCurrentVersionResponse) GetPreviousVersion() string {
|
|
if x != nil {
|
|
return x.PreviousVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetCurrentVersionResponse) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type CreateWorkerDeploymentArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
// Retrying with same request id is a successful no-op.
|
|
// Retrying with different request id is an error.
|
|
// One deployment is deleted, same or different request id will re-create it.
|
|
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentArgs) Reset() {
|
|
*x = CreateWorkerDeploymentArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[34]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateWorkerDeploymentArgs) ProtoMessage() {}
|
|
|
|
func (x *CreateWorkerDeploymentArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[34]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CreateWorkerDeploymentArgs.ProtoReflect.Descriptor instead.
|
|
func (*CreateWorkerDeploymentArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{34}
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentArgs) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment update response:
|
|
type CreateWorkerDeploymentResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
ConflictToken []byte `protobuf:"bytes,1,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentResponse) Reset() {
|
|
*x = CreateWorkerDeploymentResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[35]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateWorkerDeploymentResponse) ProtoMessage() {}
|
|
|
|
func (x *CreateWorkerDeploymentResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[35]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CreateWorkerDeploymentResponse.ProtoReflect.Descriptor instead.
|
|
func (*CreateWorkerDeploymentResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{35}
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentResponse) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type CreateWorkerDeploymentVersionArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
// Retrying with same request id is a successful no-op.
|
|
// Retrying with different request id (including auto-created) is an error.
|
|
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
|
|
// Version string (<deployment_name>.<build_id>)
|
|
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
|
|
ComputeConfig *v12.ComputeConfig `protobuf:"bytes,4,opt,name=compute_config,json=computeConfig,proto3" json:"compute_config,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) Reset() {
|
|
*x = CreateWorkerDeploymentVersionArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[36]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateWorkerDeploymentVersionArgs) ProtoMessage() {}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[36]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CreateWorkerDeploymentVersionArgs.ProtoReflect.Descriptor instead.
|
|
func (*CreateWorkerDeploymentVersionArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{36}
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionArgs) GetComputeConfig() *v12.ComputeConfig {
|
|
if x != nil {
|
|
return x.ComputeConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment update response:
|
|
type CreateWorkerDeploymentVersionResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionResponse) Reset() {
|
|
*x = CreateWorkerDeploymentVersionResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[37]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CreateWorkerDeploymentVersionResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CreateWorkerDeploymentVersionResponse) ProtoMessage() {}
|
|
|
|
func (x *CreateWorkerDeploymentVersionResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[37]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CreateWorkerDeploymentVersionResponse.ProtoReflect.Descriptor instead.
|
|
func (*CreateWorkerDeploymentVersionResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{37}
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type DeleteVersionArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
// If true, it would mean that the delete operation is initiated by the server internally. This is done on the
|
|
// event that the addition of a version exceeds the max number of versions allowed in a worker-deployment (defaultMaxVersions).
|
|
// False elsewhere.
|
|
ServerDelete bool `protobuf:"varint,4,opt,name=server_delete,json=serverDelete,proto3" json:"server_delete,omitempty"`
|
|
// version workflow does not block the update for tq propagation
|
|
AsyncPropagation bool `protobuf:"varint,5,opt,name=async_propagation,json=asyncPropagation,proto3" json:"async_propagation,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) Reset() {
|
|
*x = DeleteVersionArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[38]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeleteVersionArgs) ProtoMessage() {}
|
|
|
|
func (x *DeleteVersionArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[38]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DeleteVersionArgs.ProtoReflect.Descriptor instead.
|
|
func (*DeleteVersionArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{38}
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) GetSkipDrainage() bool {
|
|
if x != nil {
|
|
return x.SkipDrainage
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) GetServerDelete() bool {
|
|
if x != nil {
|
|
return x.ServerDelete
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *DeleteVersionArgs) GetAsyncPropagation() bool {
|
|
if x != nil {
|
|
return x.AsyncPropagation
|
|
}
|
|
return false
|
|
}
|
|
|
|
// used as Worker Deployment Activity input:
|
|
type DeleteVersionActivityArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
AsyncPropagation bool `protobuf:"varint,6,opt,name=async_propagation,json=asyncPropagation,proto3" json:"async_propagation,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) Reset() {
|
|
*x = DeleteVersionActivityArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[39]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeleteVersionActivityArgs) ProtoMessage() {}
|
|
|
|
func (x *DeleteVersionActivityArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[39]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DeleteVersionActivityArgs.ProtoReflect.Descriptor instead.
|
|
func (*DeleteVersionActivityArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{39}
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) GetSkipDrainage() bool {
|
|
if x != nil {
|
|
return x.SkipDrainage
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *DeleteVersionActivityArgs) GetAsyncPropagation() bool {
|
|
if x != nil {
|
|
return x.AsyncPropagation
|
|
}
|
|
return false
|
|
}
|
|
|
|
// used as Worker Deployment Activity input:
|
|
type CheckTaskQueuesHavePollersActivityArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Key: Task Queue Name
|
|
TaskQueuesAndTypes map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes `protobuf:"bytes,1,rep,name=task_queues_and_types,json=taskQueuesAndTypes,proto3" json:"task_queues_and_types,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
WorkerDeploymentVersion *WorkerDeploymentVersion `protobuf:"bytes,2,opt,name=worker_deployment_version,json=workerDeploymentVersion,proto3" json:"worker_deployment_version,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs) Reset() {
|
|
*x = CheckTaskQueuesHavePollersActivityArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[40]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage() {}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[40]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CheckTaskQueuesHavePollersActivityArgs.ProtoReflect.Descriptor instead.
|
|
func (*CheckTaskQueuesHavePollersActivityArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{40}
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs) GetTaskQueuesAndTypes() map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes {
|
|
if x != nil {
|
|
return x.TaskQueuesAndTypes
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion() *WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.WorkerDeploymentVersion
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type DeleteDeploymentArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeleteDeploymentArgs) Reset() {
|
|
*x = DeleteDeploymentArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[41]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeleteDeploymentArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeleteDeploymentArgs) ProtoMessage() {}
|
|
|
|
func (x *DeleteDeploymentArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[41]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DeleteDeploymentArgs.ProtoReflect.Descriptor instead.
|
|
func (*DeleteDeploymentArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{41}
|
|
}
|
|
|
|
func (x *DeleteDeploymentArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment update response:
|
|
type SetRampingVersionResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SetRampingVersionResponse) Reset() {
|
|
*x = SetRampingVersionResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[42]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SetRampingVersionResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SetRampingVersionResponse) ProtoMessage() {}
|
|
|
|
func (x *SetRampingVersionResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[42]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SetRampingVersionResponse.ProtoReflect.Descriptor instead.
|
|
func (*SetRampingVersionResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{42}
|
|
}
|
|
|
|
func (x *SetRampingVersionResponse) GetPreviousVersion() string {
|
|
if x != nil {
|
|
return x.PreviousVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetRampingVersionResponse) GetPreviousPercentage() float32 {
|
|
if x != nil {
|
|
return x.PreviousPercentage
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SetRampingVersionResponse) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type SetRampingVersionArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 `protobuf:"varint,4,opt,name=ignore_missing_task_queues,json=ignoreMissingTaskQueues,proto3" json:"ignore_missing_task_queues,omitempty"`
|
|
ConflictToken []byte `protobuf:"bytes,5,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
|
|
AllowNoPollers bool `protobuf:"varint,6,opt,name=allow_no_pollers,json=allowNoPollers,proto3" json:"allow_no_pollers,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) Reset() {
|
|
*x = SetRampingVersionArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[43]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SetRampingVersionArgs) ProtoMessage() {}
|
|
|
|
func (x *SetRampingVersionArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[43]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SetRampingVersionArgs.ProtoReflect.Descriptor instead.
|
|
func (*SetRampingVersionArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{43}
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) GetPercentage() float32 {
|
|
if x != nil {
|
|
return x.Percentage
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) GetIgnoreMissingTaskQueues() bool {
|
|
if x != nil {
|
|
return x.IgnoreMissingTaskQueues
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SetRampingVersionArgs) GetAllowNoPollers() bool {
|
|
if x != nil {
|
|
return x.AllowNoPollers
|
|
}
|
|
return false
|
|
}
|
|
|
|
// used as Worker Deployment workflow update input:
|
|
type SetManagerIdentityArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// identity is the client's identity, as usual
|
|
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
// manager_identity is the new manager_identity.
|
|
ManagerIdentity string `protobuf:"bytes,2,opt,name=manager_identity,json=managerIdentity,proto3" json:"manager_identity,omitempty"`
|
|
ConflictToken []byte `protobuf:"bytes,5,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SetManagerIdentityArgs) Reset() {
|
|
*x = SetManagerIdentityArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[44]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SetManagerIdentityArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SetManagerIdentityArgs) ProtoMessage() {}
|
|
|
|
func (x *SetManagerIdentityArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[44]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SetManagerIdentityArgs.ProtoReflect.Descriptor instead.
|
|
func (*SetManagerIdentityArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{44}
|
|
}
|
|
|
|
func (x *SetManagerIdentityArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetManagerIdentityArgs) GetManagerIdentity() string {
|
|
if x != nil {
|
|
return x.ManagerIdentity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetManagerIdentityArgs) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment update response:
|
|
type SetManagerIdentityResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
PreviousManagerIdentity string `protobuf:"bytes,1,opt,name=previous_manager_identity,json=previousManagerIdentity,proto3" json:"previous_manager_identity,omitempty"`
|
|
ConflictToken []byte `protobuf:"bytes,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SetManagerIdentityResponse) Reset() {
|
|
*x = SetManagerIdentityResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[45]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SetManagerIdentityResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SetManagerIdentityResponse) ProtoMessage() {}
|
|
|
|
func (x *SetManagerIdentityResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[45]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SetManagerIdentityResponse.ProtoReflect.Descriptor instead.
|
|
func (*SetManagerIdentityResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{45}
|
|
}
|
|
|
|
func (x *SetManagerIdentityResponse) GetPreviousManagerIdentity() string {
|
|
if x != nil {
|
|
return x.PreviousManagerIdentity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SetManagerIdentityResponse) GetConflictToken() []byte {
|
|
if x != nil {
|
|
return x.ConflictToken
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment activity input:
|
|
type SyncVersionStateActivityArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityArgs) Reset() {
|
|
*x = SyncVersionStateActivityArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[46]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncVersionStateActivityArgs) ProtoMessage() {}
|
|
|
|
func (x *SyncVersionStateActivityArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[46]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncVersionStateActivityArgs.ProtoReflect.Descriptor instead.
|
|
func (*SyncVersionStateActivityArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{46}
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityArgs) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityArgs) GetVersion() string {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs {
|
|
if x != nil {
|
|
return x.UpdateArgs
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityArgs) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment activity result:
|
|
type SyncVersionStateActivityResult struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"`
|
|
Summary *WorkerDeploymentVersionSummary `protobuf:"bytes,2,opt,name=summary,proto3" json:"summary,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityResult) Reset() {
|
|
*x = SyncVersionStateActivityResult{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[47]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityResult) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncVersionStateActivityResult) ProtoMessage() {}
|
|
|
|
func (x *SyncVersionStateActivityResult) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[47]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncVersionStateActivityResult.ProtoReflect.Descriptor instead.
|
|
func (*SyncVersionStateActivityResult) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{47}
|
|
}
|
|
|
|
// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
|
|
func (x *SyncVersionStateActivityResult) GetVersionState() *VersionLocalState {
|
|
if x != nil {
|
|
return x.VersionState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncVersionStateActivityResult) GetSummary() *WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.Summary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as Worker Deployment activity input:
|
|
type IsVersionMissingTaskQueuesArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesArgs) Reset() {
|
|
*x = IsVersionMissingTaskQueuesArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[48]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*IsVersionMissingTaskQueuesArgs) ProtoMessage() {}
|
|
|
|
func (x *IsVersionMissingTaskQueuesArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[48]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use IsVersionMissingTaskQueuesArgs.ProtoReflect.Descriptor instead.
|
|
func (*IsVersionMissingTaskQueuesArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{48}
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion() string {
|
|
if x != nil {
|
|
return x.PrevCurrentVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion() string {
|
|
if x != nil {
|
|
return x.NewCurrentVersion
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// used as Worker Deployment activity output:
|
|
type IsVersionMissingTaskQueuesResult struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
IsMissingTaskQueues bool `protobuf:"varint,1,opt,name=is_missing_task_queues,json=isMissingTaskQueues,proto3" json:"is_missing_task_queues,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesResult) Reset() {
|
|
*x = IsVersionMissingTaskQueuesResult{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[49]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesResult) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*IsVersionMissingTaskQueuesResult) ProtoMessage() {}
|
|
|
|
func (x *IsVersionMissingTaskQueuesResult) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[49]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use IsVersionMissingTaskQueuesResult.ProtoReflect.Descriptor instead.
|
|
func (*IsVersionMissingTaskQueuesResult) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{49}
|
|
}
|
|
|
|
func (x *IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues() bool {
|
|
if x != nil {
|
|
return x.IsMissingTaskQueues
|
|
}
|
|
return false
|
|
}
|
|
|
|
// used as Worker Deployment workflow memo:
|
|
type WorkerDeploymentWorkflowMemo struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 *v11.RoutingConfig `protobuf:"bytes,3,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
|
|
LatestVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,4,opt,name=latest_version_summary,json=latestVersionSummary,proto3" json:"latest_version_summary,omitempty"`
|
|
CurrentVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,5,opt,name=current_version_summary,json=currentVersionSummary,proto3" json:"current_version_summary,omitempty"`
|
|
RampingVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,6,opt,name=ramping_version_summary,json=rampingVersionSummary,proto3" json:"ramping_version_summary,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) Reset() {
|
|
*x = WorkerDeploymentWorkflowMemo{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[50]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentWorkflowMemo) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[50]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentWorkflowMemo.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentWorkflowMemo) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{50}
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) GetDeploymentName() string {
|
|
if x != nil {
|
|
return x.DeploymentName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) GetRoutingConfig() *v11.RoutingConfig {
|
|
if x != nil {
|
|
return x.RoutingConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) GetLatestVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.LatestVersionSummary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) GetCurrentVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.CurrentVersionSummary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentWorkflowMemo) GetRampingVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.RampingVersionSummary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Subset of fields of WorkerDeploymentInfo returned in ListWorkerDeploymentsResponse
|
|
type WorkerDeploymentSummary struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
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 *v11.RoutingConfig `protobuf:"bytes,3,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
|
|
LatestVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,4,opt,name=latest_version_summary,json=latestVersionSummary,proto3" json:"latest_version_summary,omitempty"`
|
|
CurrentVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,5,opt,name=current_version_summary,json=currentVersionSummary,proto3" json:"current_version_summary,omitempty"`
|
|
RampingVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `protobuf:"bytes,6,opt,name=ramping_version_summary,json=rampingVersionSummary,proto3" json:"ramping_version_summary,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) Reset() {
|
|
*x = WorkerDeploymentSummary{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[51]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*WorkerDeploymentSummary) ProtoMessage() {}
|
|
|
|
func (x *WorkerDeploymentSummary) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[51]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use WorkerDeploymentSummary.ProtoReflect.Descriptor instead.
|
|
func (*WorkerDeploymentSummary) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{51}
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) GetName() string {
|
|
if x != nil {
|
|
return x.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) GetCreateTime() *timestamppb.Timestamp {
|
|
if x != nil {
|
|
return x.CreateTime
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) GetRoutingConfig() *v11.RoutingConfig {
|
|
if x != nil {
|
|
return x.RoutingConfig
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) GetLatestVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.LatestVersionSummary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) GetCurrentVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.CurrentVersionSummary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *WorkerDeploymentSummary) GetRampingVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary {
|
|
if x != nil {
|
|
return x.RampingVersionSummary
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Input for the activity that validates compute config scaling groups via
|
|
// the Worker Controller Instance client.
|
|
type ValidateWorkerControllerInstanceSpecInput struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
ScalingGroups map[string]*v12.ComputeConfigScalingGroup `protobuf:"bytes,1,rep,name=scaling_groups,json=scalingGroups,proto3" json:"scaling_groups,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ValidateWorkerControllerInstanceSpecInput) Reset() {
|
|
*x = ValidateWorkerControllerInstanceSpecInput{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[52]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ValidateWorkerControllerInstanceSpecInput) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ValidateWorkerControllerInstanceSpecInput) ProtoMessage() {}
|
|
|
|
func (x *ValidateWorkerControllerInstanceSpecInput) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[52]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ValidateWorkerControllerInstanceSpecInput.ProtoReflect.Descriptor instead.
|
|
func (*ValidateWorkerControllerInstanceSpecInput) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{52}
|
|
}
|
|
|
|
func (x *ValidateWorkerControllerInstanceSpecInput) GetScalingGroups() map[string]*v12.ComputeConfigScalingGroup {
|
|
if x != nil {
|
|
return x.ScalingGroups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as activity input for creating or updating a Worker Controller Instance
|
|
// via the WCI client.
|
|
type UpdateWorkerControllerInstanceInput struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Version *v11.WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
|
|
Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
UpsertScalingGroups map[string]*v12.ComputeConfigScalingGroupUpdate `protobuf:"bytes,3,rep,name=upsert_scaling_groups,json=upsertScalingGroups,proto3" json:"upsert_scaling_groups,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
RemoveScalingGroups []string `protobuf:"bytes,4,rep,name=remove_scaling_groups,json=removeScalingGroups,proto3" json:"remove_scaling_groups,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) Reset() {
|
|
*x = UpdateWorkerControllerInstanceInput{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[53]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateWorkerControllerInstanceInput) ProtoMessage() {}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[53]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use UpdateWorkerControllerInstanceInput.ProtoReflect.Descriptor instead.
|
|
func (*UpdateWorkerControllerInstanceInput) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{53}
|
|
}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) GetVersion() *v11.WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) GetUpsertScalingGroups() map[string]*v12.ComputeConfigScalingGroupUpdate {
|
|
if x != nil {
|
|
return x.UpsertScalingGroups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *UpdateWorkerControllerInstanceInput) GetRemoveScalingGroups() []string {
|
|
if x != nil {
|
|
return x.RemoveScalingGroups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// used as activity input for deleting a Worker Controller Instance
|
|
// via the WCI client.
|
|
type DeleteWorkerControllerInstanceInput struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Version *v11.WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
|
|
Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *DeleteWorkerControllerInstanceInput) Reset() {
|
|
*x = DeleteWorkerControllerInstanceInput{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[54]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *DeleteWorkerControllerInstanceInput) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*DeleteWorkerControllerInstanceInput) ProtoMessage() {}
|
|
|
|
func (x *DeleteWorkerControllerInstanceInput) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[54]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use DeleteWorkerControllerInstanceInput.ProtoReflect.Descriptor instead.
|
|
func (*DeleteWorkerControllerInstanceInput) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{54}
|
|
}
|
|
|
|
func (x *DeleteWorkerControllerInstanceInput) GetVersion() *v11.WorkerDeploymentVersion {
|
|
if x != nil {
|
|
return x.Version
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *DeleteWorkerControllerInstanceInput) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// Input for the UpdateComputeConfig workflow update on a version workflow.
|
|
type UpdateComputeConfigArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
|
|
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
|
|
// Scaling groups to add or update.
|
|
UpsertScalingGroups map[string]*v12.ComputeConfigScalingGroupUpdate `protobuf:"bytes,3,rep,name=upsert_scaling_groups,json=upsertScalingGroups,proto3" json:"upsert_scaling_groups,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
// Names of scaling groups to remove. Names that don't match an existing group are ignored.
|
|
RemoveScalingGroups []string `protobuf:"bytes,4,rep,name=remove_scaling_groups,json=removeScalingGroups,proto3" json:"remove_scaling_groups,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateComputeConfigArgs) Reset() {
|
|
*x = UpdateComputeConfigArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[55]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateComputeConfigArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateComputeConfigArgs) ProtoMessage() {}
|
|
|
|
func (x *UpdateComputeConfigArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[55]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use UpdateComputeConfigArgs.ProtoReflect.Descriptor instead.
|
|
func (*UpdateComputeConfigArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{55}
|
|
}
|
|
|
|
func (x *UpdateComputeConfigArgs) GetIdentity() string {
|
|
if x != nil {
|
|
return x.Identity
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *UpdateComputeConfigArgs) GetRequestId() string {
|
|
if x != nil {
|
|
return x.RequestId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *UpdateComputeConfigArgs) GetUpsertScalingGroups() map[string]*v12.ComputeConfigScalingGroupUpdate {
|
|
if x != nil {
|
|
return x.UpsertScalingGroups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *UpdateComputeConfigArgs) GetRemoveScalingGroups() []string {
|
|
if x != nil {
|
|
return x.RemoveScalingGroups
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Response for the UpdateComputeConfig workflow update on a version workflow.
|
|
type UpdateComputeConfigResponse struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *UpdateComputeConfigResponse) Reset() {
|
|
*x = UpdateComputeConfigResponse{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[56]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *UpdateComputeConfigResponse) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*UpdateComputeConfigResponse) ProtoMessage() {}
|
|
|
|
func (x *UpdateComputeConfigResponse) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[56]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use UpdateComputeConfigResponse.ProtoReflect.Descriptor instead.
|
|
func (*UpdateComputeConfigResponse) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{56}
|
|
}
|
|
|
|
// Signal input for force-continue-as-new on Deployment workflow
|
|
type ForceCANDeploymentSignalArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// If provided, this state will be used instead of the current state
|
|
// when performing continue-as-new.
|
|
OverrideState *WorkerDeploymentLocalState `protobuf:"bytes,1,opt,name=override_state,json=overrideState,proto3" json:"override_state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ForceCANDeploymentSignalArgs) Reset() {
|
|
*x = ForceCANDeploymentSignalArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[57]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ForceCANDeploymentSignalArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ForceCANDeploymentSignalArgs) ProtoMessage() {}
|
|
|
|
func (x *ForceCANDeploymentSignalArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[57]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ForceCANDeploymentSignalArgs.ProtoReflect.Descriptor instead.
|
|
func (*ForceCANDeploymentSignalArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{57}
|
|
}
|
|
|
|
func (x *ForceCANDeploymentSignalArgs) GetOverrideState() *WorkerDeploymentLocalState {
|
|
if x != nil {
|
|
return x.OverrideState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Signal input for force-continue-as-new on Version workflow
|
|
type ForceCANVersionSignalArgs struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// If provided, this state will be used instead of the current state
|
|
// when performing continue-as-new.
|
|
OverrideState *VersionLocalState `protobuf:"bytes,1,opt,name=override_state,json=overrideState,proto3" json:"override_state,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *ForceCANVersionSignalArgs) Reset() {
|
|
*x = ForceCANVersionSignalArgs{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[58]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *ForceCANVersionSignalArgs) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*ForceCANVersionSignalArgs) ProtoMessage() {}
|
|
|
|
func (x *ForceCANVersionSignalArgs) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[58]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use ForceCANVersionSignalArgs.ProtoReflect.Descriptor instead.
|
|
func (*ForceCANVersionSignalArgs) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{58}
|
|
}
|
|
|
|
func (x *ForceCANVersionSignalArgs) GetOverrideState() *VersionLocalState {
|
|
if x != nil {
|
|
return x.OverrideState
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type VersionLocalState_TaskQueueFamilyData struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
// Key: Task Queue Type
|
|
TaskQueues map[int32]*TaskQueueVersionData `protobuf:"bytes,1,rep,name=task_queues,json=taskQueues,proto3" json:"task_queues,omitempty" protobuf_key:"varint,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *VersionLocalState_TaskQueueFamilyData) Reset() {
|
|
*x = VersionLocalState_TaskQueueFamilyData{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[60]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *VersionLocalState_TaskQueueFamilyData) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage() {}
|
|
|
|
func (x *VersionLocalState_TaskQueueFamilyData) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[60]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use VersionLocalState_TaskQueueFamilyData.ProtoReflect.Descriptor instead.
|
|
func (*VersionLocalState_TaskQueueFamilyData) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{3, 1}
|
|
}
|
|
|
|
func (x *VersionLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueVersionData {
|
|
if x != nil {
|
|
return x.TaskQueues
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type SyncDeploymentVersionUserDataRequest_SyncUserData struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
|
|
Types []v1.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"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) Reset() {
|
|
*x = SyncDeploymentVersionUserDataRequest_SyncUserData{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[64]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage() {}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[64]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use SyncDeploymentVersionUserDataRequest_SyncUserData.ProtoReflect.Descriptor instead.
|
|
func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{25, 0}
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetName() string {
|
|
if x != nil {
|
|
return x.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes() []v1.TaskQueueType {
|
|
if x != nil {
|
|
return x.Types
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetData() *DeploymentVersionData {
|
|
if x != nil {
|
|
return x.Data
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes struct {
|
|
state protoimpl.MessageState `protogen:"open.v1"`
|
|
Types []v1.TaskQueueType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"types,omitempty"`
|
|
unknownFields protoimpl.UnknownFields
|
|
sizeCache protoimpl.SizeCache
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset() {
|
|
*x = CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes{}
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[70]
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String() string {
|
|
return protoimpl.X.MessageStringOf(x)
|
|
}
|
|
|
|
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage() {}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoReflect() protoreflect.Message {
|
|
mi := &file_temporal_server_api_deployment_v1_message_proto_msgTypes[70]
|
|
if x != nil {
|
|
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
|
|
if ms.LoadMessageInfo() == nil {
|
|
ms.StoreMessageInfo(mi)
|
|
}
|
|
return ms
|
|
}
|
|
return mi.MessageOf(x)
|
|
}
|
|
|
|
// Deprecated: Use CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes.ProtoReflect.Descriptor instead.
|
|
func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Descriptor() ([]byte, []int) {
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP(), []int{40, 1}
|
|
}
|
|
|
|
func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes() []v1.TaskQueueType {
|
|
if x != nil {
|
|
return x.Types
|
|
}
|
|
return nil
|
|
}
|
|
|
|
var File_temporal_server_api_deployment_v1_message_proto protoreflect.FileDescriptor
|
|
|
|
const file_temporal_server_api_deployment_v1_message_proto_rawDesc = "" +
|
|
"\n" +
|
|
"/temporal/server/api/deployment/v1/message.proto\x12!temporal.server.api.deployment.v1\x1a\x1fgoogle/protobuf/timestamp.proto\x1a$temporal/api/common/v1/message.proto\x1a$temporal/api/compute/v1/config.proto\x1a(temporal/api/deployment/v1/message.proto\x1a&temporal/api/enums/v1/deployment.proto\x1a&temporal/api/enums/v1/task_queue.proto\"]\n" +
|
|
"\x17WorkerDeploymentVersion\x12'\n" +
|
|
"\x0fdeployment_name\x18\x01 \x01(\tR\x0edeploymentName\x12\x19\n" +
|
|
"\bbuild_id\x18\x02 \x01(\tR\abuildId\"\xc4\x03\n" +
|
|
"\x15DeploymentVersionData\x12T\n" +
|
|
"\aversion\x18\x01 \x01(\v2:.temporal.server.api.deployment.v1.WorkerDeploymentVersionR\aversion\x12J\n" +
|
|
"\x13routing_update_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\x11routingUpdateTime\x12H\n" +
|
|
"\x12current_since_time\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\x10currentSinceTime\x12H\n" +
|
|
"\x12ramping_since_time\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\x10rampingSinceTime\x12'\n" +
|
|
"\x0framp_percentage\x18\x05 \x01(\x02R\x0erampPercentage\x12L\n" +
|
|
"\x06status\x18\x06 \x01(\x0e24.temporal.api.enums.v1.WorkerDeploymentVersionStatusR\x06status\"\xeb\x01\n" +
|
|
"\x1bWorkerDeploymentVersionData\x12'\n" +
|
|
"\x0frevision_number\x18\x01 \x01(\x03R\x0erevisionNumber\x12;\n" +
|
|
"\vupdate_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"updateTime\x12\x18\n" +
|
|
"\adeleted\x18\x03 \x01(\bR\adeleted\x12L\n" +
|
|
"\x06status\x18\x06 \x01(\x0e24.temporal.api.enums.v1.WorkerDeploymentVersionStatusR\x06status\"\xc0\r\n" +
|
|
"\x11VersionLocalState\x12T\n" +
|
|
"\aversion\x18\x01 \x01(\v2:.temporal.server.api.deployment.v1.WorkerDeploymentVersionR\aversion\x12;\n" +
|
|
"\vcreate_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\x12J\n" +
|
|
"\x13routing_update_time\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\x11routingUpdateTime\x12H\n" +
|
|
"\x12current_since_time\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\x10currentSinceTime\x12H\n" +
|
|
"\x12ramping_since_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\x10rampingSinceTime\x12'\n" +
|
|
"\x0framp_percentage\x18\x06 \x01(\x02R\x0erampPercentage\x12N\n" +
|
|
"\x15first_activation_time\x18\f \x01(\v2\x1a.google.protobuf.TimestampR\x13firstActivationTime\x12F\n" +
|
|
"\x11last_current_time\x18\x10 \x01(\v2\x1a.google.protobuf.TimestampR\x0flastCurrentTime\x12P\n" +
|
|
"\x16last_deactivation_time\x18\r \x01(\v2\x1a.google.protobuf.TimestampR\x14lastDeactivationTime\x12T\n" +
|
|
"\rdrainage_info\x18\a \x01(\v2/.temporal.api.deployment.v1.VersionDrainageInfoR\fdrainageInfo\x12G\n" +
|
|
"\bmetadata\x18\b \x01(\v2+.temporal.api.deployment.v1.VersionMetadataR\bmetadata\x12B\n" +
|
|
"\x1bstarted_deployment_workflow\x18\t \x01(\bB\x02\x18\x01R\x19startedDeploymentWorkflow\x12{\n" +
|
|
"\x13task_queue_families\x18\n" +
|
|
" \x03(\v2K.temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamiliesEntryR\x11taskQueueFamilies\x12&\n" +
|
|
"\x0fsync_batch_size\x18\v \x01(\x05R\rsyncBatchSize\x12L\n" +
|
|
"\x06status\x18\x0e \x01(\x0e24.temporal.api.enums.v1.WorkerDeploymentVersionStatusR\x06status\x12'\n" +
|
|
"\x0frevision_number\x18\x0f \x01(\x03R\x0erevisionNumber\x124\n" +
|
|
"\x16last_modifier_identity\x18\x11 \x01(\tR\x14lastModifierIdentity\x12T\n" +
|
|
"\x0ecompute_config\x18\x12 \x01(\v2-.temporal.api.compute.v1.ComputeConfigSummaryR\rcomputeConfig\x1a\x8e\x01\n" +
|
|
"\x16TaskQueueFamiliesEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12^\n" +
|
|
"\x05value\x18\x02 \x01(\v2H.temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyDataR\x05value:\x028\x01\x1a\x88\x02\n" +
|
|
"\x13TaskQueueFamilyData\x12y\n" +
|
|
"\vtask_queues\x18\x01 \x03(\v2X.temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData.TaskQueuesEntryR\n" +
|
|
"taskQueues\x1av\n" +
|
|
"\x0fTaskQueuesEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\x05R\x03key\x12M\n" +
|
|
"\x05value\x18\x02 \x01(\v27.temporal.server.api.deployment.v1.TaskQueueVersionDataR\x05value:\x028\x01\"\x16\n" +
|
|
"\x14TaskQueueVersionData\"\xca\x01\n" +
|
|
"#WorkerDeploymentVersionWorkflowArgs\x12%\n" +
|
|
"\x0enamespace_name\x18\x01 \x01(\tR\rnamespaceName\x12!\n" +
|
|
"\fnamespace_id\x18\x02 \x01(\tR\vnamespaceId\x12Y\n" +
|
|
"\rversion_state\x18\x03 \x01(\v24.temporal.server.api.deployment.v1.VersionLocalStateR\fversionState\"\xe6\x01\n" +
|
|
"\x1cWorkerDeploymentWorkflowArgs\x12%\n" +
|
|
"\x0enamespace_name\x18\x01 \x01(\tR\rnamespaceName\x12!\n" +
|
|
"\fnamespace_id\x18\x02 \x01(\tR\vnamespaceId\x12'\n" +
|
|
"\x0fdeployment_name\x18\x03 \x01(\tR\x0edeploymentName\x12S\n" +
|
|
"\x05state\x18\x04 \x01(\v2=.temporal.server.api.deployment.v1.WorkerDeploymentLocalStateR\x05state\"\x82\a\n" +
|
|
"\x1aWorkerDeploymentLocalState\x12;\n" +
|
|
"\vcreate_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\x12P\n" +
|
|
"\x0erouting_config\x18\x02 \x01(\v2).temporal.api.deployment.v1.RoutingConfigR\rroutingConfig\x12g\n" +
|
|
"\bversions\x18\x03 \x03(\v2K.temporal.server.api.deployment.v1.WorkerDeploymentLocalState.VersionsEntryR\bversions\x12%\n" +
|
|
"\x0econflict_token\x18\x04 \x01(\fR\rconflictToken\x124\n" +
|
|
"\x16last_modifier_identity\x18\x05 \x01(\tR\x14lastModifierIdentity\x12&\n" +
|
|
"\x0fsync_batch_size\x18\x06 \x01(\x05R\rsyncBatchSize\x12)\n" +
|
|
"\x10manager_identity\x18\a \x01(\tR\x0fmanagerIdentity\x12\x8c\x01\n" +
|
|
"\x15propagating_revisions\x18\b \x03(\v2W.temporal.server.api.deployment.v1.WorkerDeploymentLocalState.PropagatingRevisionsEntryR\x14propagatingRevisions\x12*\n" +
|
|
"\x11create_request_id\x18\t \x01(\tR\x0fcreateRequestId\x1a~\n" +
|
|
"\rVersionsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12W\n" +
|
|
"\x05value\x18\x02 \x01(\v2A.temporal.server.api.deployment.v1.WorkerDeploymentVersionSummaryR\x05value:\x028\x01\x1a\x80\x01\n" +
|
|
"\x19PropagatingRevisionsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12M\n" +
|
|
"\x05value\x18\x02 \x01(\v27.temporal.server.api.deployment.v1.PropagatingRevisionsR\x05value:\x028\x01\"A\n" +
|
|
"\x14PropagatingRevisions\x12)\n" +
|
|
"\x10revision_numbers\x18\x01 \x03(\x03R\x0frevisionNumbers\"\xc2\a\n" +
|
|
"\x1eWorkerDeploymentVersionSummary\x12\x18\n" +
|
|
"\aversion\x18\x01 \x01(\tR\aversion\x12;\n" +
|
|
"\vcreate_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\x12Y\n" +
|
|
"\x0fdrainage_status\x18\x03 \x01(\x0e2,.temporal.api.enums.v1.VersionDrainageStatusB\x02\x18\x01R\x0edrainageStatus\x12T\n" +
|
|
"\rdrainage_info\x18\x04 \x01(\v2/.temporal.api.deployment.v1.VersionDrainageInfoR\fdrainageInfo\x12J\n" +
|
|
"\x13routing_update_time\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\x11routingUpdateTime\x12H\n" +
|
|
"\x12current_since_time\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\x10currentSinceTime\x12H\n" +
|
|
"\x12ramping_since_time\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\x10rampingSinceTime\x12N\n" +
|
|
"\x15first_activation_time\x18\b \x01(\v2\x1a.google.protobuf.TimestampR\x13firstActivationTime\x12F\n" +
|
|
"\x11last_current_time\x18\v \x01(\v2\x1a.google.protobuf.TimestampR\x0flastCurrentTime\x12P\n" +
|
|
"\x16last_deactivation_time\x18\t \x01(\v2\x1a.google.protobuf.TimestampR\x14lastDeactivationTime\x12L\n" +
|
|
"\x06status\x18\n" +
|
|
" \x01(\x0e24.temporal.api.enums.v1.WorkerDeploymentVersionStatusR\x06status\x12*\n" +
|
|
"\x11create_request_id\x18\f \x01(\tR\x0fcreateRequestId\x12T\n" +
|
|
"\x0ecompute_config\x18\r \x01(\v2-.temporal.api.compute.v1.ComputeConfigSummaryR\rcomputeConfig\"\xa7\x02\n" +
|
|
"\x1bRegisterWorkerInVersionArgs\x12&\n" +
|
|
"\x0ftask_queue_name\x18\x01 \x01(\tR\rtaskQueueName\x12L\n" +
|
|
"\x0ftask_queue_type\x18\x02 \x01(\x0e2$.temporal.api.enums.v1.TaskQueueTypeR\rtaskQueueType\x12&\n" +
|
|
"\x0fmax_task_queues\x18\x03 \x01(\x05R\rmaxTaskQueues\x12\x18\n" +
|
|
"\aversion\x18\x04 \x01(\tR\aversion\x12P\n" +
|
|
"\x0erouting_config\x18\x05 \x01(\v2).temporal.api.deployment.v1.RoutingConfigR\rroutingConfig\"\x9a\x02\n" +
|
|
"$RegisterWorkerInWorkerDeploymentArgs\x12&\n" +
|
|
"\x0ftask_queue_name\x18\x01 \x01(\tR\rtaskQueueName\x12L\n" +
|
|
"\x0ftask_queue_type\x18\x02 \x01(\x0e2$.temporal.api.enums.v1.TaskQueueTypeR\rtaskQueueType\x12&\n" +
|
|
"\x0fmax_task_queues\x18\x03 \x01(\x05R\rmaxTaskQueues\x12T\n" +
|
|
"\aversion\x18\x04 \x01(\v2:.temporal.server.api.deployment.v1.WorkerDeploymentVersionR\aversion\"K\n" +
|
|
"/DescribeVersionFromWorkerDeploymentActivityArgs\x12\x18\n" +
|
|
"\aversion\x18\x01 \x01(\tR\aversion\"\xab\x01\n" +
|
|
"1DescribeVersionFromWorkerDeploymentActivityResult\x12v\n" +
|
|
"\x10task_queue_infos\x18\x01 \x03(\v2L.temporal.api.deployment.v1.WorkerDeploymentVersionInfo.VersionTaskQueueInfoR\x0etaskQueueInfos\"\x87\x03\n" +
|
|
"\x1aSyncVersionStateUpdateArgs\x12N\n" +
|
|
"\x13routing_update_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampB\x02\x18\x01R\x11routingUpdateTime\x12L\n" +
|
|
"\x12current_since_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampB\x02\x18\x01R\x10currentSinceTime\x12L\n" +
|
|
"\x12ramping_since_time\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampB\x02\x18\x01R\x10rampingSinceTime\x12+\n" +
|
|
"\x0framp_percentage\x18\x04 \x01(\x02B\x02\x18\x01R\x0erampPercentage\x12P\n" +
|
|
"\x0erouting_config\x18\x05 \x01(\v2).temporal.api.deployment.v1.RoutingConfigR\rroutingConfig\"\xd6\x01\n" +
|
|
"\x18SyncVersionStateResponse\x12]\n" +
|
|
"\rversion_state\x18\x01 \x01(\v24.temporal.server.api.deployment.v1.VersionLocalStateB\x02\x18\x01R\fversionState\x12[\n" +
|
|
"\asummary\x18\x02 \x01(\v2A.temporal.server.api.deployment.v1.WorkerDeploymentVersionSummaryR\asummary\"m\n" +
|
|
"\x14AddVersionUpdateArgs\x12\x18\n" +
|
|
"\aversion\x18\x01 \x01(\tR\aversion\x12;\n" +
|
|
"\vcreate_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\"r\n" +
|
|
"\x1aSyncDrainageInfoSignalArgs\x12T\n" +
|
|
"\rdrainage_info\x18\x01 \x01(\v2/.temporal.api.deployment.v1.VersionDrainageInfoR\fdrainageInfo\"\x8f\x01\n" +
|
|
"\x1cSyncDrainageStatusSignalArgs\x12\x18\n" +
|
|
"\aversion\x18\x01 \x01(\tR\aversion\x12U\n" +
|
|
"\x0fdrainage_status\x18\x02 \x01(\x0e2,.temporal.api.enums.v1.VersionDrainageStatusR\x0edrainageStatus\"_\n" +
|
|
"\x19PropagationCompletionInfo\x12'\n" +
|
|
"\x0frevision_number\x18\x01 \x01(\x03R\x0erevisionNumber\x12\x19\n" +
|
|
"\bbuild_id\x18\x02 \x01(\tR\abuildId\"y\n" +
|
|
"\x1cQueryDescribeVersionResponse\x12Y\n" +
|
|
"\rversion_state\x18\x01 \x01(\v24.temporal.server.api.deployment.v1.VersionLocalStateR\fversionState\"|\n" +
|
|
"%QueryDescribeWorkerDeploymentResponse\x12S\n" +
|
|
"\x05state\x18\x01 \x01(\v2=.temporal.server.api.deployment.v1.WorkerDeploymentLocalStateR\x05state\"d\n" +
|
|
"\x1cCreateRequestIDQueryResponse\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x01 \x01(\tR\trequestId\x12%\n" +
|
|
"\x0econflict_token\x18\x02 \x01(\fR\rconflictToken\"f\n" +
|
|
"\x1cStartWorkerDeploymentRequest\x12'\n" +
|
|
"\x0fdeployment_name\x18\x01 \x01(\tR\x0edeploymentName\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x02 \x01(\tR\trequestId\"\xfa\x01\n" +
|
|
"#StartWorkerDeploymentVersionRequest\x12'\n" +
|
|
"\x0fdeployment_name\x18\x01 \x01(\tR\x0edeploymentName\x12\x19\n" +
|
|
"\bbuild_id\x18\x02 \x01(\tR\abuildId\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x03 \x01(\tR\trequestId\x12\x1a\n" +
|
|
"\bidentity\x18\x04 \x01(\tR\bidentity\x12T\n" +
|
|
"\x0ecompute_config\x18\x05 \x01(\v2-.temporal.api.compute.v1.ComputeConfigSummaryR\rcomputeConfig\"\xb4\x05\n" +
|
|
"$SyncDeploymentVersionUserDataRequest\x12'\n" +
|
|
"\x0fdeployment_name\x18\x04 \x01(\tR\x0edeploymentName\x12T\n" +
|
|
"\aversion\x18\x01 \x01(\v2:.temporal.server.api.deployment.v1.WorkerDeploymentVersionR\aversion\x12h\n" +
|
|
"\x04sync\x18\x02 \x03(\v2T.temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.SyncUserDataR\x04sync\x12%\n" +
|
|
"\x0eforget_version\x18\x03 \x01(\bR\rforgetVersion\x12]\n" +
|
|
"\x15update_routing_config\x18\x05 \x01(\v2).temporal.api.deployment.v1.RoutingConfigR\x13updateRoutingConfig\x12n\n" +
|
|
"\x13upsert_version_data\x18\x06 \x01(\v2>.temporal.server.api.deployment.v1.WorkerDeploymentVersionDataR\x11upsertVersionData\x1a\xac\x01\n" +
|
|
"\fSyncUserData\x12\x12\n" +
|
|
"\x04name\x18\x01 \x01(\tR\x04name\x12:\n" +
|
|
"\x05types\x18\x02 \x03(\x0e2$.temporal.api.enums.v1.TaskQueueTypeR\x05types\x12L\n" +
|
|
"\x04data\x18\x03 \x01(\v28.temporal.server.api.deployment.v1.DeploymentVersionDataR\x04data\"\x8c\x02\n" +
|
|
"%SyncDeploymentVersionUserDataResponse\x12\x99\x01\n" +
|
|
"\x17task_queue_max_versions\x18\x01 \x03(\v2b.temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataResponse.TaskQueueMaxVersionsEntryR\x14taskQueueMaxVersions\x1aG\n" +
|
|
"\x19TaskQueueMaxVersionsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\x03R\x05value:\x028\x01\"\xa0\x02\n" +
|
|
"/CheckWorkerDeploymentUserDataPropagationRequest\x12\xa3\x01\n" +
|
|
"\x17task_queue_max_versions\x18\x01 \x03(\v2l.temporal.server.api.deployment.v1.CheckWorkerDeploymentUserDataPropagationRequest.TaskQueueMaxVersionsEntryR\x14taskQueueMaxVersions\x1aG\n" +
|
|
"\x19TaskQueueMaxVersionsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\x03R\x05value:\x028\x01\"\xaa\x01\n" +
|
|
"\x1fSyncUnversionedRampActivityArgs\x12'\n" +
|
|
"\x0fcurrent_version\x18\x01 \x01(\tR\x0ecurrentVersion\x12^\n" +
|
|
"\vupdate_args\x18\x02 \x01(\v2=.temporal.server.api.deployment.v1.SyncVersionStateUpdateArgsR\n" +
|
|
"updateArgs\"\x88\x02\n" +
|
|
"#SyncUnversionedRampActivityResponse\x12\x97\x01\n" +
|
|
"\x17task_queue_max_versions\x18\x01 \x03(\v2`.temporal.server.api.deployment.v1.SyncUnversionedRampActivityResponse.TaskQueueMaxVersionsEntryR\x14taskQueueMaxVersions\x1aG\n" +
|
|
"\x19TaskQueueMaxVersionsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
|
|
"\x05value\x18\x02 \x01(\x03R\x05value:\x028\x01\"\xb9\x02\n" +
|
|
"\x19UpdateVersionMetadataArgs\x12v\n" +
|
|
"\x0eupsert_entries\x18\x01 \x03(\v2O.temporal.server.api.deployment.v1.UpdateVersionMetadataArgs.UpsertEntriesEntryR\rupsertEntries\x12%\n" +
|
|
"\x0eremove_entries\x18\x02 \x03(\tR\rremoveEntries\x12\x1a\n" +
|
|
"\bidentity\x18\x03 \x01(\tR\bidentity\x1aa\n" +
|
|
"\x12UpsertEntriesEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x125\n" +
|
|
"\x05value\x18\x02 \x01(\v2\x1f.temporal.api.common.v1.PayloadR\x05value:\x028\x01\"h\n" +
|
|
"\x1dUpdateVersionMetadataResponse\x12G\n" +
|
|
"\bmetadata\x18\x01 \x01(\v2+.temporal.api.deployment.v1.VersionMetadataR\bmetadata\"\xdb\x01\n" +
|
|
"\x15SetCurrentVersionArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12\x18\n" +
|
|
"\aversion\x18\x02 \x01(\tR\aversion\x12;\n" +
|
|
"\x1aignore_missing_task_queues\x18\x03 \x01(\bR\x17ignoreMissingTaskQueues\x12%\n" +
|
|
"\x0econflict_token\x18\x04 \x01(\fR\rconflictToken\x12(\n" +
|
|
"\x10allow_no_pollers\x18\x05 \x01(\bR\x0eallowNoPollers\"m\n" +
|
|
"\x19SetCurrentVersionResponse\x12)\n" +
|
|
"\x10previous_version\x18\x01 \x01(\tR\x0fpreviousVersion\x12%\n" +
|
|
"\x0econflict_token\x18\x02 \x01(\fR\rconflictToken\"W\n" +
|
|
"\x1aCreateWorkerDeploymentArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x02 \x01(\tR\trequestId\"G\n" +
|
|
"\x1eCreateWorkerDeploymentResponse\x12%\n" +
|
|
"\x0econflict_token\x18\x01 \x01(\fR\rconflictToken\"\xc7\x01\n" +
|
|
"!CreateWorkerDeploymentVersionArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x02 \x01(\tR\trequestId\x12\x18\n" +
|
|
"\aversion\x18\x03 \x01(\tR\aversion\x12M\n" +
|
|
"\x0ecompute_config\x18\x04 \x01(\v2&.temporal.api.compute.v1.ComputeConfigR\rcomputeConfig\"'\n" +
|
|
"%CreateWorkerDeploymentVersionResponse\"\xc0\x01\n" +
|
|
"\x11DeleteVersionArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12\x18\n" +
|
|
"\aversion\x18\x02 \x01(\tR\aversion\x12#\n" +
|
|
"\rskip_drainage\x18\x03 \x01(\bR\fskipDrainage\x12#\n" +
|
|
"\rserver_delete\x18\x04 \x01(\bR\fserverDelete\x12+\n" +
|
|
"\x11async_propagation\x18\x05 \x01(\bR\x10asyncPropagation\"\xeb\x01\n" +
|
|
"\x19DeleteVersionActivityArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12'\n" +
|
|
"\x0fdeployment_name\x18\x02 \x01(\tR\x0edeploymentName\x12\x18\n" +
|
|
"\aversion\x18\x03 \x01(\tR\aversion\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x04 \x01(\tR\trequestId\x12#\n" +
|
|
"\rskip_drainage\x18\x05 \x01(\bR\fskipDrainage\x12+\n" +
|
|
"\x11async_propagation\x18\x06 \x01(\bR\x10asyncPropagation\"\xa7\x04\n" +
|
|
"&CheckTaskQueuesHavePollersActivityArgs\x12\x94\x01\n" +
|
|
"\x15task_queues_and_types\x18\x01 \x03(\v2a.temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueuesAndTypesEntryR\x12taskQueuesAndTypes\x12v\n" +
|
|
"\x19worker_deployment_version\x18\x02 \x01(\v2:.temporal.server.api.deployment.v1.WorkerDeploymentVersionR\x17workerDeploymentVersion\x1a\x9f\x01\n" +
|
|
"\x17TaskQueuesAndTypesEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12n\n" +
|
|
"\x05value\x18\x02 \x01(\v2X.temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueueTypesR\x05value:\x028\x01\x1aL\n" +
|
|
"\x0eTaskQueueTypes\x12:\n" +
|
|
"\x05types\x18\x01 \x03(\x0e2$.temporal.api.enums.v1.TaskQueueTypeR\x05types\"2\n" +
|
|
"\x14DeleteDeploymentArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\"\x9e\x01\n" +
|
|
"\x19SetRampingVersionResponse\x12)\n" +
|
|
"\x10previous_version\x18\x01 \x01(\tR\x0fpreviousVersion\x12/\n" +
|
|
"\x13previous_percentage\x18\x02 \x01(\x02R\x12previousPercentage\x12%\n" +
|
|
"\x0econflict_token\x18\x03 \x01(\fR\rconflictToken\"\xfb\x01\n" +
|
|
"\x15SetRampingVersionArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12\x18\n" +
|
|
"\aversion\x18\x02 \x01(\tR\aversion\x12\x1e\n" +
|
|
"\n" +
|
|
"percentage\x18\x03 \x01(\x02R\n" +
|
|
"percentage\x12;\n" +
|
|
"\x1aignore_missing_task_queues\x18\x04 \x01(\bR\x17ignoreMissingTaskQueues\x12%\n" +
|
|
"\x0econflict_token\x18\x05 \x01(\fR\rconflictToken\x12(\n" +
|
|
"\x10allow_no_pollers\x18\x06 \x01(\bR\x0eallowNoPollers\"\x86\x01\n" +
|
|
"\x16SetManagerIdentityArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12)\n" +
|
|
"\x10manager_identity\x18\x02 \x01(\tR\x0fmanagerIdentity\x12%\n" +
|
|
"\x0econflict_token\x18\x05 \x01(\fR\rconflictToken\"\x7f\n" +
|
|
"\x1aSetManagerIdentityResponse\x12:\n" +
|
|
"\x19previous_manager_identity\x18\x01 \x01(\tR\x17previousManagerIdentity\x12%\n" +
|
|
"\x0econflict_token\x18\x02 \x01(\fR\rconflictToken\"\xe0\x01\n" +
|
|
"\x1cSyncVersionStateActivityArgs\x12'\n" +
|
|
"\x0fdeployment_name\x18\x01 \x01(\tR\x0edeploymentName\x12\x18\n" +
|
|
"\aversion\x18\x02 \x01(\tR\aversion\x12^\n" +
|
|
"\vupdate_args\x18\x03 \x01(\v2=.temporal.server.api.deployment.v1.SyncVersionStateUpdateArgsR\n" +
|
|
"updateArgs\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x04 \x01(\tR\trequestId\"\xdc\x01\n" +
|
|
"\x1eSyncVersionStateActivityResult\x12]\n" +
|
|
"\rversion_state\x18\x01 \x01(\v24.temporal.server.api.deployment.v1.VersionLocalStateB\x02\x18\x01R\fversionState\x12[\n" +
|
|
"\asummary\x18\x02 \x01(\v2A.temporal.server.api.deployment.v1.WorkerDeploymentVersionSummaryR\asummary\"\x82\x01\n" +
|
|
"\x1eIsVersionMissingTaskQueuesArgs\x120\n" +
|
|
"\x14prev_current_version\x18\x01 \x01(\tR\x12prevCurrentVersion\x12.\n" +
|
|
"\x13new_current_version\x18\x02 \x01(\tR\x11newCurrentVersion\"W\n" +
|
|
" IsVersionMissingTaskQueuesResult\x123\n" +
|
|
"\x16is_missing_task_queues\x18\x01 \x01(\bR\x13isMissingTaskQueues\"\xf2\x04\n" +
|
|
"\x1cWorkerDeploymentWorkflowMemo\x12'\n" +
|
|
"\x0fdeployment_name\x18\x01 \x01(\tR\x0edeploymentName\x12;\n" +
|
|
"\vcreate_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\x12P\n" +
|
|
"\x0erouting_config\x18\x03 \x01(\v2).temporal.api.deployment.v1.RoutingConfigR\rroutingConfig\x12\x85\x01\n" +
|
|
"\x16latest_version_summary\x18\x04 \x01(\v2O.temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummaryR\x14latestVersionSummary\x12\x87\x01\n" +
|
|
"\x17current_version_summary\x18\x05 \x01(\v2O.temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummaryR\x15currentVersionSummary\x12\x87\x01\n" +
|
|
"\x17ramping_version_summary\x18\x06 \x01(\v2O.temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummaryR\x15rampingVersionSummary\"\xd8\x04\n" +
|
|
"\x17WorkerDeploymentSummary\x12\x12\n" +
|
|
"\x04name\x18\x01 \x01(\tR\x04name\x12;\n" +
|
|
"\vcreate_time\x18\x02 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
|
|
"createTime\x12P\n" +
|
|
"\x0erouting_config\x18\x03 \x01(\v2).temporal.api.deployment.v1.RoutingConfigR\rroutingConfig\x12\x85\x01\n" +
|
|
"\x16latest_version_summary\x18\x04 \x01(\v2O.temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummaryR\x14latestVersionSummary\x12\x87\x01\n" +
|
|
"\x17current_version_summary\x18\x05 \x01(\v2O.temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummaryR\x15currentVersionSummary\x12\x87\x01\n" +
|
|
"\x17ramping_version_summary\x18\x06 \x01(\v2O.temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummaryR\x15rampingVersionSummary\"\xaa\x02\n" +
|
|
")ValidateWorkerControllerInstanceSpecInput\x12\x86\x01\n" +
|
|
"\x0escaling_groups\x18\x01 \x03(\v2_.temporal.server.api.deployment.v1.ValidateWorkerControllerInstanceSpecInput.ScalingGroupsEntryR\rscalingGroups\x1at\n" +
|
|
"\x12ScalingGroupsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12H\n" +
|
|
"\x05value\x18\x02 \x01(\v22.temporal.api.compute.v1.ComputeConfigScalingGroupR\x05value:\x028\x01\"\xdd\x03\n" +
|
|
"#UpdateWorkerControllerInstanceInput\x12M\n" +
|
|
"\aversion\x18\x01 \x01(\v23.temporal.api.deployment.v1.WorkerDeploymentVersionR\aversion\x12\x1a\n" +
|
|
"\bidentity\x18\x02 \x01(\tR\bidentity\x12\x93\x01\n" +
|
|
"\x15upsert_scaling_groups\x18\x03 \x03(\v2_.temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput.UpsertScalingGroupsEntryR\x13upsertScalingGroups\x122\n" +
|
|
"\x15remove_scaling_groups\x18\x04 \x03(\tR\x13removeScalingGroups\x1a\x80\x01\n" +
|
|
"\x18UpsertScalingGroupsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12N\n" +
|
|
"\x05value\x18\x02 \x01(\v28.temporal.api.compute.v1.ComputeConfigScalingGroupUpdateR\x05value:\x028\x01\"\x90\x01\n" +
|
|
"#DeleteWorkerControllerInstanceInput\x12M\n" +
|
|
"\aversion\x18\x01 \x01(\v23.temporal.api.deployment.v1.WorkerDeploymentVersionR\aversion\x12\x1a\n" +
|
|
"\bidentity\x18\x02 \x01(\tR\bidentity\"\x95\x03\n" +
|
|
"\x17UpdateComputeConfigArgs\x12\x1a\n" +
|
|
"\bidentity\x18\x01 \x01(\tR\bidentity\x12\x1d\n" +
|
|
"\n" +
|
|
"request_id\x18\x02 \x01(\tR\trequestId\x12\x87\x01\n" +
|
|
"\x15upsert_scaling_groups\x18\x03 \x03(\v2S.temporal.server.api.deployment.v1.UpdateComputeConfigArgs.UpsertScalingGroupsEntryR\x13upsertScalingGroups\x122\n" +
|
|
"\x15remove_scaling_groups\x18\x04 \x03(\tR\x13removeScalingGroups\x1a\x80\x01\n" +
|
|
"\x18UpsertScalingGroupsEntry\x12\x10\n" +
|
|
"\x03key\x18\x01 \x01(\tR\x03key\x12N\n" +
|
|
"\x05value\x18\x02 \x01(\v28.temporal.api.compute.v1.ComputeConfigScalingGroupUpdateR\x05value:\x028\x01\"\x1d\n" +
|
|
"\x1bUpdateComputeConfigResponse\"\x84\x01\n" +
|
|
"\x1cForceCANDeploymentSignalArgs\x12d\n" +
|
|
"\x0eoverride_state\x18\x01 \x01(\v2=.temporal.server.api.deployment.v1.WorkerDeploymentLocalStateR\roverrideState\"x\n" +
|
|
"\x19ForceCANVersionSignalArgs\x12[\n" +
|
|
"\x0eoverride_state\x18\x01 \x01(\v24.temporal.server.api.deployment.v1.VersionLocalStateR\roverrideStateB4Z2go.temporal.io/server/api/deployment/v1;deploymentb\x06proto3"
|
|
|
|
var (
|
|
file_temporal_server_api_deployment_v1_message_proto_rawDescOnce sync.Once
|
|
file_temporal_server_api_deployment_v1_message_proto_rawDescData []byte
|
|
)
|
|
|
|
func file_temporal_server_api_deployment_v1_message_proto_rawDescGZIP() []byte {
|
|
file_temporal_server_api_deployment_v1_message_proto_rawDescOnce.Do(func() {
|
|
file_temporal_server_api_deployment_v1_message_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_temporal_server_api_deployment_v1_message_proto_rawDesc), len(file_temporal_server_api_deployment_v1_message_proto_rawDesc)))
|
|
})
|
|
return file_temporal_server_api_deployment_v1_message_proto_rawDescData
|
|
}
|
|
|
|
var file_temporal_server_api_deployment_v1_message_proto_msgTypes = make([]protoimpl.MessageInfo, 74)
|
|
var file_temporal_server_api_deployment_v1_message_proto_goTypes = []any{
|
|
(*WorkerDeploymentVersion)(nil), // 0: temporal.server.api.deployment.v1.WorkerDeploymentVersion
|
|
(*DeploymentVersionData)(nil), // 1: temporal.server.api.deployment.v1.DeploymentVersionData
|
|
(*WorkerDeploymentVersionData)(nil), // 2: temporal.server.api.deployment.v1.WorkerDeploymentVersionData
|
|
(*VersionLocalState)(nil), // 3: temporal.server.api.deployment.v1.VersionLocalState
|
|
(*TaskQueueVersionData)(nil), // 4: temporal.server.api.deployment.v1.TaskQueueVersionData
|
|
(*WorkerDeploymentVersionWorkflowArgs)(nil), // 5: temporal.server.api.deployment.v1.WorkerDeploymentVersionWorkflowArgs
|
|
(*WorkerDeploymentWorkflowArgs)(nil), // 6: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowArgs
|
|
(*WorkerDeploymentLocalState)(nil), // 7: temporal.server.api.deployment.v1.WorkerDeploymentLocalState
|
|
(*PropagatingRevisions)(nil), // 8: temporal.server.api.deployment.v1.PropagatingRevisions
|
|
(*WorkerDeploymentVersionSummary)(nil), // 9: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary
|
|
(*RegisterWorkerInVersionArgs)(nil), // 10: temporal.server.api.deployment.v1.RegisterWorkerInVersionArgs
|
|
(*RegisterWorkerInWorkerDeploymentArgs)(nil), // 11: temporal.server.api.deployment.v1.RegisterWorkerInWorkerDeploymentArgs
|
|
(*DescribeVersionFromWorkerDeploymentActivityArgs)(nil), // 12: temporal.server.api.deployment.v1.DescribeVersionFromWorkerDeploymentActivityArgs
|
|
(*DescribeVersionFromWorkerDeploymentActivityResult)(nil), // 13: temporal.server.api.deployment.v1.DescribeVersionFromWorkerDeploymentActivityResult
|
|
(*SyncVersionStateUpdateArgs)(nil), // 14: temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs
|
|
(*SyncVersionStateResponse)(nil), // 15: temporal.server.api.deployment.v1.SyncVersionStateResponse
|
|
(*AddVersionUpdateArgs)(nil), // 16: temporal.server.api.deployment.v1.AddVersionUpdateArgs
|
|
(*SyncDrainageInfoSignalArgs)(nil), // 17: temporal.server.api.deployment.v1.SyncDrainageInfoSignalArgs
|
|
(*SyncDrainageStatusSignalArgs)(nil), // 18: temporal.server.api.deployment.v1.SyncDrainageStatusSignalArgs
|
|
(*PropagationCompletionInfo)(nil), // 19: temporal.server.api.deployment.v1.PropagationCompletionInfo
|
|
(*QueryDescribeVersionResponse)(nil), // 20: temporal.server.api.deployment.v1.QueryDescribeVersionResponse
|
|
(*QueryDescribeWorkerDeploymentResponse)(nil), // 21: temporal.server.api.deployment.v1.QueryDescribeWorkerDeploymentResponse
|
|
(*CreateRequestIDQueryResponse)(nil), // 22: temporal.server.api.deployment.v1.CreateRequestIDQueryResponse
|
|
(*StartWorkerDeploymentRequest)(nil), // 23: temporal.server.api.deployment.v1.StartWorkerDeploymentRequest
|
|
(*StartWorkerDeploymentVersionRequest)(nil), // 24: temporal.server.api.deployment.v1.StartWorkerDeploymentVersionRequest
|
|
(*SyncDeploymentVersionUserDataRequest)(nil), // 25: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest
|
|
(*SyncDeploymentVersionUserDataResponse)(nil), // 26: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataResponse
|
|
(*CheckWorkerDeploymentUserDataPropagationRequest)(nil), // 27: temporal.server.api.deployment.v1.CheckWorkerDeploymentUserDataPropagationRequest
|
|
(*SyncUnversionedRampActivityArgs)(nil), // 28: temporal.server.api.deployment.v1.SyncUnversionedRampActivityArgs
|
|
(*SyncUnversionedRampActivityResponse)(nil), // 29: temporal.server.api.deployment.v1.SyncUnversionedRampActivityResponse
|
|
(*UpdateVersionMetadataArgs)(nil), // 30: temporal.server.api.deployment.v1.UpdateVersionMetadataArgs
|
|
(*UpdateVersionMetadataResponse)(nil), // 31: temporal.server.api.deployment.v1.UpdateVersionMetadataResponse
|
|
(*SetCurrentVersionArgs)(nil), // 32: temporal.server.api.deployment.v1.SetCurrentVersionArgs
|
|
(*SetCurrentVersionResponse)(nil), // 33: temporal.server.api.deployment.v1.SetCurrentVersionResponse
|
|
(*CreateWorkerDeploymentArgs)(nil), // 34: temporal.server.api.deployment.v1.CreateWorkerDeploymentArgs
|
|
(*CreateWorkerDeploymentResponse)(nil), // 35: temporal.server.api.deployment.v1.CreateWorkerDeploymentResponse
|
|
(*CreateWorkerDeploymentVersionArgs)(nil), // 36: temporal.server.api.deployment.v1.CreateWorkerDeploymentVersionArgs
|
|
(*CreateWorkerDeploymentVersionResponse)(nil), // 37: temporal.server.api.deployment.v1.CreateWorkerDeploymentVersionResponse
|
|
(*DeleteVersionArgs)(nil), // 38: temporal.server.api.deployment.v1.DeleteVersionArgs
|
|
(*DeleteVersionActivityArgs)(nil), // 39: temporal.server.api.deployment.v1.DeleteVersionActivityArgs
|
|
(*CheckTaskQueuesHavePollersActivityArgs)(nil), // 40: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs
|
|
(*DeleteDeploymentArgs)(nil), // 41: temporal.server.api.deployment.v1.DeleteDeploymentArgs
|
|
(*SetRampingVersionResponse)(nil), // 42: temporal.server.api.deployment.v1.SetRampingVersionResponse
|
|
(*SetRampingVersionArgs)(nil), // 43: temporal.server.api.deployment.v1.SetRampingVersionArgs
|
|
(*SetManagerIdentityArgs)(nil), // 44: temporal.server.api.deployment.v1.SetManagerIdentityArgs
|
|
(*SetManagerIdentityResponse)(nil), // 45: temporal.server.api.deployment.v1.SetManagerIdentityResponse
|
|
(*SyncVersionStateActivityArgs)(nil), // 46: temporal.server.api.deployment.v1.SyncVersionStateActivityArgs
|
|
(*SyncVersionStateActivityResult)(nil), // 47: temporal.server.api.deployment.v1.SyncVersionStateActivityResult
|
|
(*IsVersionMissingTaskQueuesArgs)(nil), // 48: temporal.server.api.deployment.v1.IsVersionMissingTaskQueuesArgs
|
|
(*IsVersionMissingTaskQueuesResult)(nil), // 49: temporal.server.api.deployment.v1.IsVersionMissingTaskQueuesResult
|
|
(*WorkerDeploymentWorkflowMemo)(nil), // 50: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowMemo
|
|
(*WorkerDeploymentSummary)(nil), // 51: temporal.server.api.deployment.v1.WorkerDeploymentSummary
|
|
(*ValidateWorkerControllerInstanceSpecInput)(nil), // 52: temporal.server.api.deployment.v1.ValidateWorkerControllerInstanceSpecInput
|
|
(*UpdateWorkerControllerInstanceInput)(nil), // 53: temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput
|
|
(*DeleteWorkerControllerInstanceInput)(nil), // 54: temporal.server.api.deployment.v1.DeleteWorkerControllerInstanceInput
|
|
(*UpdateComputeConfigArgs)(nil), // 55: temporal.server.api.deployment.v1.UpdateComputeConfigArgs
|
|
(*UpdateComputeConfigResponse)(nil), // 56: temporal.server.api.deployment.v1.UpdateComputeConfigResponse
|
|
(*ForceCANDeploymentSignalArgs)(nil), // 57: temporal.server.api.deployment.v1.ForceCANDeploymentSignalArgs
|
|
(*ForceCANVersionSignalArgs)(nil), // 58: temporal.server.api.deployment.v1.ForceCANVersionSignalArgs
|
|
nil, // 59: temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamiliesEntry
|
|
(*VersionLocalState_TaskQueueFamilyData)(nil), // 60: temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData
|
|
nil, // 61: temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData.TaskQueuesEntry
|
|
nil, // 62: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.VersionsEntry
|
|
nil, // 63: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.PropagatingRevisionsEntry
|
|
(*SyncDeploymentVersionUserDataRequest_SyncUserData)(nil), // 64: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.SyncUserData
|
|
nil, // 65: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataResponse.TaskQueueMaxVersionsEntry
|
|
nil, // 66: temporal.server.api.deployment.v1.CheckWorkerDeploymentUserDataPropagationRequest.TaskQueueMaxVersionsEntry
|
|
nil, // 67: temporal.server.api.deployment.v1.SyncUnversionedRampActivityResponse.TaskQueueMaxVersionsEntry
|
|
nil, // 68: temporal.server.api.deployment.v1.UpdateVersionMetadataArgs.UpsertEntriesEntry
|
|
nil, // 69: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueuesAndTypesEntry
|
|
(*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes)(nil), // 70: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueueTypes
|
|
nil, // 71: temporal.server.api.deployment.v1.ValidateWorkerControllerInstanceSpecInput.ScalingGroupsEntry
|
|
nil, // 72: temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput.UpsertScalingGroupsEntry
|
|
nil, // 73: temporal.server.api.deployment.v1.UpdateComputeConfigArgs.UpsertScalingGroupsEntry
|
|
(*timestamppb.Timestamp)(nil), // 74: google.protobuf.Timestamp
|
|
(v1.WorkerDeploymentVersionStatus)(0), // 75: temporal.api.enums.v1.WorkerDeploymentVersionStatus
|
|
(*v11.VersionDrainageInfo)(nil), // 76: temporal.api.deployment.v1.VersionDrainageInfo
|
|
(*v11.VersionMetadata)(nil), // 77: temporal.api.deployment.v1.VersionMetadata
|
|
(*v12.ComputeConfigSummary)(nil), // 78: temporal.api.compute.v1.ComputeConfigSummary
|
|
(*v11.RoutingConfig)(nil), // 79: temporal.api.deployment.v1.RoutingConfig
|
|
(v1.VersionDrainageStatus)(0), // 80: temporal.api.enums.v1.VersionDrainageStatus
|
|
(v1.TaskQueueType)(0), // 81: temporal.api.enums.v1.TaskQueueType
|
|
(*v11.WorkerDeploymentVersionInfo_VersionTaskQueueInfo)(nil), // 82: temporal.api.deployment.v1.WorkerDeploymentVersionInfo.VersionTaskQueueInfo
|
|
(*v12.ComputeConfig)(nil), // 83: temporal.api.compute.v1.ComputeConfig
|
|
(*v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary)(nil), // 84: temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
(*v11.WorkerDeploymentVersion)(nil), // 85: temporal.api.deployment.v1.WorkerDeploymentVersion
|
|
(*v13.Payload)(nil), // 86: temporal.api.common.v1.Payload
|
|
(*v12.ComputeConfigScalingGroup)(nil), // 87: temporal.api.compute.v1.ComputeConfigScalingGroup
|
|
(*v12.ComputeConfigScalingGroupUpdate)(nil), // 88: temporal.api.compute.v1.ComputeConfigScalingGroupUpdate
|
|
}
|
|
var file_temporal_server_api_deployment_v1_message_proto_depIdxs = []int32{
|
|
0, // 0: temporal.server.api.deployment.v1.DeploymentVersionData.version:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersion
|
|
74, // 1: temporal.server.api.deployment.v1.DeploymentVersionData.routing_update_time:type_name -> google.protobuf.Timestamp
|
|
74, // 2: temporal.server.api.deployment.v1.DeploymentVersionData.current_since_time:type_name -> google.protobuf.Timestamp
|
|
74, // 3: temporal.server.api.deployment.v1.DeploymentVersionData.ramping_since_time:type_name -> google.protobuf.Timestamp
|
|
75, // 4: temporal.server.api.deployment.v1.DeploymentVersionData.status:type_name -> temporal.api.enums.v1.WorkerDeploymentVersionStatus
|
|
74, // 5: temporal.server.api.deployment.v1.WorkerDeploymentVersionData.update_time:type_name -> google.protobuf.Timestamp
|
|
75, // 6: temporal.server.api.deployment.v1.WorkerDeploymentVersionData.status:type_name -> temporal.api.enums.v1.WorkerDeploymentVersionStatus
|
|
0, // 7: temporal.server.api.deployment.v1.VersionLocalState.version:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersion
|
|
74, // 8: temporal.server.api.deployment.v1.VersionLocalState.create_time:type_name -> google.protobuf.Timestamp
|
|
74, // 9: temporal.server.api.deployment.v1.VersionLocalState.routing_update_time:type_name -> google.protobuf.Timestamp
|
|
74, // 10: temporal.server.api.deployment.v1.VersionLocalState.current_since_time:type_name -> google.protobuf.Timestamp
|
|
74, // 11: temporal.server.api.deployment.v1.VersionLocalState.ramping_since_time:type_name -> google.protobuf.Timestamp
|
|
74, // 12: temporal.server.api.deployment.v1.VersionLocalState.first_activation_time:type_name -> google.protobuf.Timestamp
|
|
74, // 13: temporal.server.api.deployment.v1.VersionLocalState.last_current_time:type_name -> google.protobuf.Timestamp
|
|
74, // 14: temporal.server.api.deployment.v1.VersionLocalState.last_deactivation_time:type_name -> google.protobuf.Timestamp
|
|
76, // 15: temporal.server.api.deployment.v1.VersionLocalState.drainage_info:type_name -> temporal.api.deployment.v1.VersionDrainageInfo
|
|
77, // 16: temporal.server.api.deployment.v1.VersionLocalState.metadata:type_name -> temporal.api.deployment.v1.VersionMetadata
|
|
59, // 17: temporal.server.api.deployment.v1.VersionLocalState.task_queue_families:type_name -> temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamiliesEntry
|
|
75, // 18: temporal.server.api.deployment.v1.VersionLocalState.status:type_name -> temporal.api.enums.v1.WorkerDeploymentVersionStatus
|
|
78, // 19: temporal.server.api.deployment.v1.VersionLocalState.compute_config:type_name -> temporal.api.compute.v1.ComputeConfigSummary
|
|
3, // 20: temporal.server.api.deployment.v1.WorkerDeploymentVersionWorkflowArgs.version_state:type_name -> temporal.server.api.deployment.v1.VersionLocalState
|
|
7, // 21: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowArgs.state:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentLocalState
|
|
74, // 22: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.create_time:type_name -> google.protobuf.Timestamp
|
|
79, // 23: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.routing_config:type_name -> temporal.api.deployment.v1.RoutingConfig
|
|
62, // 24: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.versions:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentLocalState.VersionsEntry
|
|
63, // 25: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.propagating_revisions:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentLocalState.PropagatingRevisionsEntry
|
|
74, // 26: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.create_time:type_name -> google.protobuf.Timestamp
|
|
80, // 27: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.drainage_status:type_name -> temporal.api.enums.v1.VersionDrainageStatus
|
|
76, // 28: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.drainage_info:type_name -> temporal.api.deployment.v1.VersionDrainageInfo
|
|
74, // 29: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.routing_update_time:type_name -> google.protobuf.Timestamp
|
|
74, // 30: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.current_since_time:type_name -> google.protobuf.Timestamp
|
|
74, // 31: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.ramping_since_time:type_name -> google.protobuf.Timestamp
|
|
74, // 32: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.first_activation_time:type_name -> google.protobuf.Timestamp
|
|
74, // 33: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.last_current_time:type_name -> google.protobuf.Timestamp
|
|
74, // 34: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.last_deactivation_time:type_name -> google.protobuf.Timestamp
|
|
75, // 35: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.status:type_name -> temporal.api.enums.v1.WorkerDeploymentVersionStatus
|
|
78, // 36: temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary.compute_config:type_name -> temporal.api.compute.v1.ComputeConfigSummary
|
|
81, // 37: temporal.server.api.deployment.v1.RegisterWorkerInVersionArgs.task_queue_type:type_name -> temporal.api.enums.v1.TaskQueueType
|
|
79, // 38: temporal.server.api.deployment.v1.RegisterWorkerInVersionArgs.routing_config:type_name -> temporal.api.deployment.v1.RoutingConfig
|
|
81, // 39: temporal.server.api.deployment.v1.RegisterWorkerInWorkerDeploymentArgs.task_queue_type:type_name -> temporal.api.enums.v1.TaskQueueType
|
|
0, // 40: temporal.server.api.deployment.v1.RegisterWorkerInWorkerDeploymentArgs.version:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersion
|
|
82, // 41: temporal.server.api.deployment.v1.DescribeVersionFromWorkerDeploymentActivityResult.task_queue_infos:type_name -> temporal.api.deployment.v1.WorkerDeploymentVersionInfo.VersionTaskQueueInfo
|
|
74, // 42: temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs.routing_update_time:type_name -> google.protobuf.Timestamp
|
|
74, // 43: temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs.current_since_time:type_name -> google.protobuf.Timestamp
|
|
74, // 44: temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs.ramping_since_time:type_name -> google.protobuf.Timestamp
|
|
79, // 45: temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs.routing_config:type_name -> temporal.api.deployment.v1.RoutingConfig
|
|
3, // 46: temporal.server.api.deployment.v1.SyncVersionStateResponse.version_state:type_name -> temporal.server.api.deployment.v1.VersionLocalState
|
|
9, // 47: temporal.server.api.deployment.v1.SyncVersionStateResponse.summary:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary
|
|
74, // 48: temporal.server.api.deployment.v1.AddVersionUpdateArgs.create_time:type_name -> google.protobuf.Timestamp
|
|
76, // 49: temporal.server.api.deployment.v1.SyncDrainageInfoSignalArgs.drainage_info:type_name -> temporal.api.deployment.v1.VersionDrainageInfo
|
|
80, // 50: temporal.server.api.deployment.v1.SyncDrainageStatusSignalArgs.drainage_status:type_name -> temporal.api.enums.v1.VersionDrainageStatus
|
|
3, // 51: temporal.server.api.deployment.v1.QueryDescribeVersionResponse.version_state:type_name -> temporal.server.api.deployment.v1.VersionLocalState
|
|
7, // 52: temporal.server.api.deployment.v1.QueryDescribeWorkerDeploymentResponse.state:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentLocalState
|
|
78, // 53: temporal.server.api.deployment.v1.StartWorkerDeploymentVersionRequest.compute_config:type_name -> temporal.api.compute.v1.ComputeConfigSummary
|
|
0, // 54: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.version:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersion
|
|
64, // 55: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.sync:type_name -> temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.SyncUserData
|
|
79, // 56: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.update_routing_config:type_name -> temporal.api.deployment.v1.RoutingConfig
|
|
2, // 57: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.upsert_version_data:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersionData
|
|
65, // 58: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataResponse.task_queue_max_versions:type_name -> temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataResponse.TaskQueueMaxVersionsEntry
|
|
66, // 59: temporal.server.api.deployment.v1.CheckWorkerDeploymentUserDataPropagationRequest.task_queue_max_versions:type_name -> temporal.server.api.deployment.v1.CheckWorkerDeploymentUserDataPropagationRequest.TaskQueueMaxVersionsEntry
|
|
14, // 60: temporal.server.api.deployment.v1.SyncUnversionedRampActivityArgs.update_args:type_name -> temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs
|
|
67, // 61: temporal.server.api.deployment.v1.SyncUnversionedRampActivityResponse.task_queue_max_versions:type_name -> temporal.server.api.deployment.v1.SyncUnversionedRampActivityResponse.TaskQueueMaxVersionsEntry
|
|
68, // 62: temporal.server.api.deployment.v1.UpdateVersionMetadataArgs.upsert_entries:type_name -> temporal.server.api.deployment.v1.UpdateVersionMetadataArgs.UpsertEntriesEntry
|
|
77, // 63: temporal.server.api.deployment.v1.UpdateVersionMetadataResponse.metadata:type_name -> temporal.api.deployment.v1.VersionMetadata
|
|
83, // 64: temporal.server.api.deployment.v1.CreateWorkerDeploymentVersionArgs.compute_config:type_name -> temporal.api.compute.v1.ComputeConfig
|
|
69, // 65: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.task_queues_and_types:type_name -> temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueuesAndTypesEntry
|
|
0, // 66: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.worker_deployment_version:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersion
|
|
14, // 67: temporal.server.api.deployment.v1.SyncVersionStateActivityArgs.update_args:type_name -> temporal.server.api.deployment.v1.SyncVersionStateUpdateArgs
|
|
3, // 68: temporal.server.api.deployment.v1.SyncVersionStateActivityResult.version_state:type_name -> temporal.server.api.deployment.v1.VersionLocalState
|
|
9, // 69: temporal.server.api.deployment.v1.SyncVersionStateActivityResult.summary:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary
|
|
74, // 70: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowMemo.create_time:type_name -> google.protobuf.Timestamp
|
|
79, // 71: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowMemo.routing_config:type_name -> temporal.api.deployment.v1.RoutingConfig
|
|
84, // 72: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowMemo.latest_version_summary:type_name -> temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
84, // 73: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowMemo.current_version_summary:type_name -> temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
84, // 74: temporal.server.api.deployment.v1.WorkerDeploymentWorkflowMemo.ramping_version_summary:type_name -> temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
74, // 75: temporal.server.api.deployment.v1.WorkerDeploymentSummary.create_time:type_name -> google.protobuf.Timestamp
|
|
79, // 76: temporal.server.api.deployment.v1.WorkerDeploymentSummary.routing_config:type_name -> temporal.api.deployment.v1.RoutingConfig
|
|
84, // 77: temporal.server.api.deployment.v1.WorkerDeploymentSummary.latest_version_summary:type_name -> temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
84, // 78: temporal.server.api.deployment.v1.WorkerDeploymentSummary.current_version_summary:type_name -> temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
84, // 79: temporal.server.api.deployment.v1.WorkerDeploymentSummary.ramping_version_summary:type_name -> temporal.api.deployment.v1.WorkerDeploymentInfo.WorkerDeploymentVersionSummary
|
|
71, // 80: temporal.server.api.deployment.v1.ValidateWorkerControllerInstanceSpecInput.scaling_groups:type_name -> temporal.server.api.deployment.v1.ValidateWorkerControllerInstanceSpecInput.ScalingGroupsEntry
|
|
85, // 81: temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput.version:type_name -> temporal.api.deployment.v1.WorkerDeploymentVersion
|
|
72, // 82: temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput.upsert_scaling_groups:type_name -> temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput.UpsertScalingGroupsEntry
|
|
85, // 83: temporal.server.api.deployment.v1.DeleteWorkerControllerInstanceInput.version:type_name -> temporal.api.deployment.v1.WorkerDeploymentVersion
|
|
73, // 84: temporal.server.api.deployment.v1.UpdateComputeConfigArgs.upsert_scaling_groups:type_name -> temporal.server.api.deployment.v1.UpdateComputeConfigArgs.UpsertScalingGroupsEntry
|
|
7, // 85: temporal.server.api.deployment.v1.ForceCANDeploymentSignalArgs.override_state:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentLocalState
|
|
3, // 86: temporal.server.api.deployment.v1.ForceCANVersionSignalArgs.override_state:type_name -> temporal.server.api.deployment.v1.VersionLocalState
|
|
60, // 87: temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamiliesEntry.value:type_name -> temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData
|
|
61, // 88: temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData.task_queues:type_name -> temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData.TaskQueuesEntry
|
|
4, // 89: temporal.server.api.deployment.v1.VersionLocalState.TaskQueueFamilyData.TaskQueuesEntry.value:type_name -> temporal.server.api.deployment.v1.TaskQueueVersionData
|
|
9, // 90: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.VersionsEntry.value:type_name -> temporal.server.api.deployment.v1.WorkerDeploymentVersionSummary
|
|
8, // 91: temporal.server.api.deployment.v1.WorkerDeploymentLocalState.PropagatingRevisionsEntry.value:type_name -> temporal.server.api.deployment.v1.PropagatingRevisions
|
|
81, // 92: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.SyncUserData.types:type_name -> temporal.api.enums.v1.TaskQueueType
|
|
1, // 93: temporal.server.api.deployment.v1.SyncDeploymentVersionUserDataRequest.SyncUserData.data:type_name -> temporal.server.api.deployment.v1.DeploymentVersionData
|
|
86, // 94: temporal.server.api.deployment.v1.UpdateVersionMetadataArgs.UpsertEntriesEntry.value:type_name -> temporal.api.common.v1.Payload
|
|
70, // 95: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueuesAndTypesEntry.value:type_name -> temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueueTypes
|
|
81, // 96: temporal.server.api.deployment.v1.CheckTaskQueuesHavePollersActivityArgs.TaskQueueTypes.types:type_name -> temporal.api.enums.v1.TaskQueueType
|
|
87, // 97: temporal.server.api.deployment.v1.ValidateWorkerControllerInstanceSpecInput.ScalingGroupsEntry.value:type_name -> temporal.api.compute.v1.ComputeConfigScalingGroup
|
|
88, // 98: temporal.server.api.deployment.v1.UpdateWorkerControllerInstanceInput.UpsertScalingGroupsEntry.value:type_name -> temporal.api.compute.v1.ComputeConfigScalingGroupUpdate
|
|
88, // 99: temporal.server.api.deployment.v1.UpdateComputeConfigArgs.UpsertScalingGroupsEntry.value:type_name -> temporal.api.compute.v1.ComputeConfigScalingGroupUpdate
|
|
100, // [100:100] is the sub-list for method output_type
|
|
100, // [100:100] is the sub-list for method input_type
|
|
100, // [100:100] is the sub-list for extension type_name
|
|
100, // [100:100] is the sub-list for extension extendee
|
|
0, // [0:100] is the sub-list for field type_name
|
|
}
|
|
|
|
func init() { file_temporal_server_api_deployment_v1_message_proto_init() }
|
|
func file_temporal_server_api_deployment_v1_message_proto_init() {
|
|
if File_temporal_server_api_deployment_v1_message_proto != nil {
|
|
return
|
|
}
|
|
type x struct{}
|
|
out := protoimpl.TypeBuilder{
|
|
File: protoimpl.DescBuilder{
|
|
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
|
|
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_deployment_v1_message_proto_rawDesc), len(file_temporal_server_api_deployment_v1_message_proto_rawDesc)),
|
|
NumEnums: 0,
|
|
NumMessages: 74,
|
|
NumExtensions: 0,
|
|
NumServices: 0,
|
|
},
|
|
GoTypes: file_temporal_server_api_deployment_v1_message_proto_goTypes,
|
|
DependencyIndexes: file_temporal_server_api_deployment_v1_message_proto_depIdxs,
|
|
MessageInfos: file_temporal_server_api_deployment_v1_message_proto_msgTypes,
|
|
}.Build()
|
|
File_temporal_server_api_deployment_v1_message_proto = out.File
|
|
file_temporal_server_api_deployment_v1_message_proto_goTypes = nil
|
|
file_temporal_server_api_deployment_v1_message_proto_depIdxs = nil
|
|
}
|