deployment

package
v1.30.1 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_server_api_deployment_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddVersionUpdateArgs added in v1.27.0 

type AddVersionUpdateArgs struct {
	Version    string                 `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

Sent from Version workflow to Worker Deployment workflow

func (*AddVersionUpdateArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use AddVersionUpdateArgs.ProtoReflect.Descriptor instead.

func (*AddVersionUpdateArgs) Equal added in v1.27.0 

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

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

func (*AddVersionUpdateArgs) GetCreateTime added in v1.27.0 

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

func (*AddVersionUpdateArgs) GetVersion added in v1.27.0 

func (x *AddVersionUpdateArgs) GetVersion() string

func (*AddVersionUpdateArgs) Marshal added in v1.27.0 

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

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

func (*AddVersionUpdateArgs) ProtoMessage added in v1.27.0 

func (*AddVersionUpdateArgs) ProtoMessage()

func (*AddVersionUpdateArgs) ProtoReflect added in v1.27.0 

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

func (*AddVersionUpdateArgs) Reset added in v1.27.0 

func (x *AddVersionUpdateArgs) Reset()

func (*AddVersionUpdateArgs) Size added in v1.27.0 

func (val *AddVersionUpdateArgs) Size() int

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

func (*AddVersionUpdateArgs) String added in v1.27.0 

func (x *AddVersionUpdateArgs) String() string

func (*AddVersionUpdateArgs) Unmarshal added in v1.27.0 

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

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

type CheckTaskQueuesHavePollersActivityArgs added in v1.27.0 

type CheckTaskQueuesHavePollersActivityArgs struct {

	// Key: Task Queue Name
	TaskQueuesAndTypes      map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes `` /* 193-byte string literal not displayed */
	WorkerDeploymentVersion *WorkerDeploymentVersion                                          `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

used as Worker Deployment Activity input:

func (*CheckTaskQueuesHavePollersActivityArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use CheckTaskQueuesHavePollersActivityArgs.ProtoReflect.Descriptor instead.

func (*CheckTaskQueuesHavePollersActivityArgs) Equal added in v1.27.0 

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

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

func (*CheckTaskQueuesHavePollersActivityArgs) GetTaskQueuesAndTypes added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs) GetTaskQueuesAndTypes() map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes

func (*CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion() *WorkerDeploymentVersion

func (*CheckTaskQueuesHavePollersActivityArgs) Marshal added in v1.27.0 

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

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

func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage added in v1.27.0 

func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage()

func (*CheckTaskQueuesHavePollersActivityArgs) ProtoReflect added in v1.27.0 

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

func (*CheckTaskQueuesHavePollersActivityArgs) Reset added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs) Reset()

func (*CheckTaskQueuesHavePollersActivityArgs) Size added in v1.27.0 

func (val *CheckTaskQueuesHavePollersActivityArgs) Size() int

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

func (*CheckTaskQueuesHavePollersActivityArgs) String added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs) String() string

func (*CheckTaskQueuesHavePollersActivityArgs) Unmarshal added in v1.27.0 

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

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

type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes added in v1.27.0 

type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes struct {
	Types []v1.TaskQueueType `protobuf:"varint,1,rep,packed,name=types,proto3,enum=temporal.api.enums.v1.TaskQueueType" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes.ProtoReflect.Descriptor instead.

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes() []v1.TaskQueueType

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage added in v1.27.0 

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage()

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoReflect added in v1.27.0 

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

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset()

func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String added in v1.27.0 

func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String() string

type CheckWorkerDeploymentUserDataPropagationRequest added in v1.27.0 

type CheckWorkerDeploymentUserDataPropagationRequest struct {
	TaskQueueMaxVersions map[string]int64 `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow activity input:

func (*CheckWorkerDeploymentUserDataPropagationRequest) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use CheckWorkerDeploymentUserDataPropagationRequest.ProtoReflect.Descriptor instead.

func (*CheckWorkerDeploymentUserDataPropagationRequest) Equal added in v1.27.0 

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

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

func (*CheckWorkerDeploymentUserDataPropagationRequest) GetTaskQueueMaxVersions added in v1.27.0 

func (x *CheckWorkerDeploymentUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64

func (*CheckWorkerDeploymentUserDataPropagationRequest) Marshal added in v1.27.0 

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

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

func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage added in v1.27.0 

func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage()

func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoReflect added in v1.27.0 

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

func (*CheckWorkerDeploymentUserDataPropagationRequest) Reset added in v1.27.0 

func (x *CheckWorkerDeploymentUserDataPropagationRequest) Reset()

func (*CheckWorkerDeploymentUserDataPropagationRequest) Size added in v1.27.0 

func (val *CheckWorkerDeploymentUserDataPropagationRequest) Size() int

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

func (*CheckWorkerDeploymentUserDataPropagationRequest) String added in v1.27.0 

func (x *CheckWorkerDeploymentUserDataPropagationRequest) String() string

func (*CheckWorkerDeploymentUserDataPropagationRequest) Unmarshal added in v1.27.0 

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

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

type DeleteDeploymentArgs added in v1.27.0 

type DeleteDeploymentArgs struct {
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input:

func (*DeleteDeploymentArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use DeleteDeploymentArgs.ProtoReflect.Descriptor instead.

func (*DeleteDeploymentArgs) Equal added in v1.27.0 

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

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

func (*DeleteDeploymentArgs) GetIdentity added in v1.27.0 

func (x *DeleteDeploymentArgs) GetIdentity() string

func (*DeleteDeploymentArgs) Marshal added in v1.27.0 

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

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

func (*DeleteDeploymentArgs) ProtoMessage added in v1.27.0 

func (*DeleteDeploymentArgs) ProtoMessage()

func (*DeleteDeploymentArgs) ProtoReflect added in v1.27.0 

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

func (*DeleteDeploymentArgs) Reset added in v1.27.0 

func (x *DeleteDeploymentArgs) Reset()

func (*DeleteDeploymentArgs) Size added in v1.27.0 

func (val *DeleteDeploymentArgs) Size() int

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

func (*DeleteDeploymentArgs) String added in v1.27.0 

func (x *DeleteDeploymentArgs) String() string

func (*DeleteDeploymentArgs) Unmarshal added in v1.27.0 

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

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

type DeleteVersionActivityArgs added in v1.27.0 

type DeleteVersionActivityArgs struct {
	Identity         string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	DeploymentName   string `protobuf:"bytes,2,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	Version          string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	RequestId        string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	SkipDrainage     bool   `protobuf:"varint,5,opt,name=skip_drainage,json=skipDrainage,proto3" json:"skip_drainage,omitempty"`
	AsyncPropagation bool   `protobuf:"varint,6,opt,name=async_propagation,json=asyncPropagation,proto3" json:"async_propagation,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Activity input:

func (*DeleteVersionActivityArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use DeleteVersionActivityArgs.ProtoReflect.Descriptor instead.

func (*DeleteVersionActivityArgs) Equal added in v1.27.0 

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

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

func (*DeleteVersionActivityArgs) GetAsyncPropagation added in v1.30.0 

func (x *DeleteVersionActivityArgs) GetAsyncPropagation() bool

func (*DeleteVersionActivityArgs) GetDeploymentName added in v1.27.0 

func (x *DeleteVersionActivityArgs) GetDeploymentName() string

func (*DeleteVersionActivityArgs) GetIdentity added in v1.27.0 

func (x *DeleteVersionActivityArgs) GetIdentity() string

func (*DeleteVersionActivityArgs) GetRequestId added in v1.27.0 

func (x *DeleteVersionActivityArgs) GetRequestId() string

func (*DeleteVersionActivityArgs) GetSkipDrainage added in v1.27.0 

func (x *DeleteVersionActivityArgs) GetSkipDrainage() bool

func (*DeleteVersionActivityArgs) GetVersion added in v1.27.0 

func (x *DeleteVersionActivityArgs) GetVersion() string

func (*DeleteVersionActivityArgs) Marshal added in v1.27.0 

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

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

func (*DeleteVersionActivityArgs) ProtoMessage added in v1.27.0 

func (*DeleteVersionActivityArgs) ProtoMessage()

func (*DeleteVersionActivityArgs) ProtoReflect added in v1.27.0 

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

func (*DeleteVersionActivityArgs) Reset added in v1.27.0 

func (x *DeleteVersionActivityArgs) Reset()

func (*DeleteVersionActivityArgs) Size added in v1.27.0 

func (val *DeleteVersionActivityArgs) Size() int

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

func (*DeleteVersionActivityArgs) String added in v1.27.0 

func (x *DeleteVersionActivityArgs) String() string

func (*DeleteVersionActivityArgs) Unmarshal added in v1.27.0 

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

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

type DeleteVersionArgs added in v1.27.0 

type DeleteVersionArgs struct {
	Identity     string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Version      string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	SkipDrainage bool   `protobuf:"varint,3,opt,name=skip_drainage,json=skipDrainage,proto3" json:"skip_drainage,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input:

func (*DeleteVersionArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use DeleteVersionArgs.ProtoReflect.Descriptor instead.

func (*DeleteVersionArgs) Equal added in v1.27.0 

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

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

func (*DeleteVersionArgs) GetAsyncPropagation added in v1.30.0 

func (x *DeleteVersionArgs) GetAsyncPropagation() bool

func (*DeleteVersionArgs) GetIdentity added in v1.27.0 

func (x *DeleteVersionArgs) GetIdentity() string

func (*DeleteVersionArgs) GetServerDelete added in v1.30.0 

func (x *DeleteVersionArgs) GetServerDelete() bool

func (*DeleteVersionArgs) GetSkipDrainage added in v1.27.0 

func (x *DeleteVersionArgs) GetSkipDrainage() bool

func (*DeleteVersionArgs) GetVersion added in v1.27.0 

func (x *DeleteVersionArgs) GetVersion() string

func (*DeleteVersionArgs) Marshal added in v1.27.0 

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

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

func (*DeleteVersionArgs) ProtoMessage added in v1.27.0 

func (*DeleteVersionArgs) ProtoMessage()

func (*DeleteVersionArgs) ProtoReflect added in v1.27.0 

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

func (*DeleteVersionArgs) Reset added in v1.27.0 

func (x *DeleteVersionArgs) Reset()

func (*DeleteVersionArgs) Size added in v1.27.0 

func (val *DeleteVersionArgs) Size() int

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

func (*DeleteVersionArgs) String added in v1.27.0 

func (x *DeleteVersionArgs) String() string

func (*DeleteVersionArgs) Unmarshal added in v1.27.0 

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

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

type DeploymentVersionData added in v1.27.0 

type DeploymentVersionData struct {

	// Nil means unversioned.
	Version *WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed.
	RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=routing_update_time,json=routingUpdateTime,proto3" json:"routing_update_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	//
	// Nil if not current.
	CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=current_since_time,json=currentSinceTime,proto3" json:"current_since_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	//
	// Nil if not ramping. Updated when the version first starts ramping, not on each ramp change.
	RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"`
	// Range: [0, 100]. Must be zero if the version is not ramping (i.e. `ramping_since_time` is nil).
	// Can be in the range [0, 100] if the version is ramping.
	RampPercentage float32 `protobuf:"fixed32,5,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

The source of truth for this data is in the WorkerDeployment entity workflows, which is synced to all TQs whenever the source changes. Deprecated.

func (*DeploymentVersionData) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use DeploymentVersionData.ProtoReflect.Descriptor instead.

func (*DeploymentVersionData) Equal added in v1.27.0 

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

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

func (*DeploymentVersionData) GetCurrentSinceTime added in v1.27.0 

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

func (*DeploymentVersionData) GetRampPercentage added in v1.27.0 

func (x *DeploymentVersionData) GetRampPercentage() float32

func (*DeploymentVersionData) GetRampingSinceTime added in v1.27.0 

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

func (*DeploymentVersionData) GetRoutingUpdateTime added in v1.27.0 

func (x *DeploymentVersionData) GetRoutingUpdateTime() *timestamppb.Timestamp

func (*DeploymentVersionData) GetStatus added in v1.28.1 

func (x *DeploymentVersionData) GetStatus() v1.WorkerDeploymentVersionStatus

func (*DeploymentVersionData) GetVersion added in v1.27.0 

func (x *DeploymentVersionData) GetVersion() *WorkerDeploymentVersion

func (*DeploymentVersionData) Marshal added in v1.27.0 

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

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

func (*DeploymentVersionData) ProtoMessage added in v1.27.0 

func (*DeploymentVersionData) ProtoMessage()

func (*DeploymentVersionData) ProtoReflect added in v1.27.0 

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

func (*DeploymentVersionData) Reset added in v1.27.0 

func (x *DeploymentVersionData) Reset()

func (*DeploymentVersionData) Size added in v1.27.0 

func (val *DeploymentVersionData) Size() int

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

func (*DeploymentVersionData) String added in v1.27.0 

func (x *DeploymentVersionData) String() string

func (*DeploymentVersionData) Unmarshal added in v1.27.0 

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

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

type DescribeVersionFromWorkerDeploymentActivityArgs added in v1.28.0 

type DescribeVersionFromWorkerDeploymentActivityArgs struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow activity input:

func (*DescribeVersionFromWorkerDeploymentActivityArgs) Descriptor deprecated added in v1.28.0 

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

Deprecated: Use DescribeVersionFromWorkerDeploymentActivityArgs.ProtoReflect.Descriptor instead.

func (*DescribeVersionFromWorkerDeploymentActivityArgs) Equal added in v1.28.0 

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

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

func (*DescribeVersionFromWorkerDeploymentActivityArgs) GetVersion added in v1.28.0 

func (x *DescribeVersionFromWorkerDeploymentActivityArgs) GetVersion() string

func (*DescribeVersionFromWorkerDeploymentActivityArgs) Marshal added in v1.28.0 

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

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

func (*DescribeVersionFromWorkerDeploymentActivityArgs) ProtoMessage added in v1.28.0 

func (*DescribeVersionFromWorkerDeploymentActivityArgs) ProtoMessage()

func (*DescribeVersionFromWorkerDeploymentActivityArgs) ProtoReflect added in v1.28.0 

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

func (*DescribeVersionFromWorkerDeploymentActivityArgs) Reset added in v1.28.0 

func (x *DescribeVersionFromWorkerDeploymentActivityArgs) Reset()

func (*DescribeVersionFromWorkerDeploymentActivityArgs) Size added in v1.28.0 

func (val *DescribeVersionFromWorkerDeploymentActivityArgs) Size() int

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

func (*DescribeVersionFromWorkerDeploymentActivityArgs) String added in v1.28.0 

func (x *DescribeVersionFromWorkerDeploymentActivityArgs) String() string

func (*DescribeVersionFromWorkerDeploymentActivityArgs) Unmarshal added in v1.28.0 

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

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

type DescribeVersionFromWorkerDeploymentActivityResult added in v1.28.0 

type DescribeVersionFromWorkerDeploymentActivityResult struct {

	// 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"`
	// contains filtered or unexported fields
}

func (*DescribeVersionFromWorkerDeploymentActivityResult) Descriptor deprecated added in v1.28.0 

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

Deprecated: Use DescribeVersionFromWorkerDeploymentActivityResult.ProtoReflect.Descriptor instead.

func (*DescribeVersionFromWorkerDeploymentActivityResult) Equal added in v1.28.0 

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

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

func (*DescribeVersionFromWorkerDeploymentActivityResult) GetTaskQueueInfos added in v1.28.0 

func (x *DescribeVersionFromWorkerDeploymentActivityResult) GetTaskQueueInfos() []*v11.WorkerDeploymentVersionInfo_VersionTaskQueueInfo

func (*DescribeVersionFromWorkerDeploymentActivityResult) Marshal added in v1.28.0 

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

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

func (*DescribeVersionFromWorkerDeploymentActivityResult) ProtoMessage added in v1.28.0 

func (*DescribeVersionFromWorkerDeploymentActivityResult) ProtoMessage()

func (*DescribeVersionFromWorkerDeploymentActivityResult) ProtoReflect added in v1.28.0 

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

func (*DescribeVersionFromWorkerDeploymentActivityResult) Reset added in v1.28.0 

func (x *DescribeVersionFromWorkerDeploymentActivityResult) Reset()

func (*DescribeVersionFromWorkerDeploymentActivityResult) Size added in v1.28.0 

func (val *DescribeVersionFromWorkerDeploymentActivityResult) Size() int

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

func (*DescribeVersionFromWorkerDeploymentActivityResult) String added in v1.28.0 

func (x *DescribeVersionFromWorkerDeploymentActivityResult) String() string

func (*DescribeVersionFromWorkerDeploymentActivityResult) Unmarshal added in v1.28.0 

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

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

type IsVersionMissingTaskQueuesArgs added in v1.27.0 

type IsVersionMissingTaskQueuesArgs struct {
	PrevCurrentVersion string `protobuf:"bytes,1,opt,name=prev_current_version,json=prevCurrentVersion,proto3" json:"prev_current_version,omitempty"`
	NewCurrentVersion  string `protobuf:"bytes,2,opt,name=new_current_version,json=newCurrentVersion,proto3" json:"new_current_version,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment activity input:

func (*IsVersionMissingTaskQueuesArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use IsVersionMissingTaskQueuesArgs.ProtoReflect.Descriptor instead.

func (*IsVersionMissingTaskQueuesArgs) Equal added in v1.27.0 

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

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

func (*IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion added in v1.27.0 

func (x *IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion() string

func (*IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion added in v1.27.0 

func (x *IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion() string

func (*IsVersionMissingTaskQueuesArgs) Marshal added in v1.27.0 

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

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

func (*IsVersionMissingTaskQueuesArgs) ProtoMessage added in v1.27.0 

func (*IsVersionMissingTaskQueuesArgs) ProtoMessage()

func (*IsVersionMissingTaskQueuesArgs) ProtoReflect added in v1.27.0 

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

func (*IsVersionMissingTaskQueuesArgs) Reset added in v1.27.0 

func (x *IsVersionMissingTaskQueuesArgs) Reset()

func (*IsVersionMissingTaskQueuesArgs) Size added in v1.27.0 

func (val *IsVersionMissingTaskQueuesArgs) Size() int

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

func (*IsVersionMissingTaskQueuesArgs) String added in v1.27.0 

func (x *IsVersionMissingTaskQueuesArgs) String() string

func (*IsVersionMissingTaskQueuesArgs) Unmarshal added in v1.27.0 

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

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

type IsVersionMissingTaskQueuesResult added in v1.27.0 

type IsVersionMissingTaskQueuesResult struct {
	IsMissingTaskQueues bool `protobuf:"varint,1,opt,name=is_missing_task_queues,json=isMissingTaskQueues,proto3" json:"is_missing_task_queues,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment activity output:

func (*IsVersionMissingTaskQueuesResult) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use IsVersionMissingTaskQueuesResult.ProtoReflect.Descriptor instead.

func (*IsVersionMissingTaskQueuesResult) Equal added in v1.27.0 

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

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

func (*IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues added in v1.27.0 

func (x *IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues() bool

func (*IsVersionMissingTaskQueuesResult) Marshal added in v1.27.0 

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

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

func (*IsVersionMissingTaskQueuesResult) ProtoMessage added in v1.27.0 

func (*IsVersionMissingTaskQueuesResult) ProtoMessage()

func (*IsVersionMissingTaskQueuesResult) ProtoReflect added in v1.27.0 

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

func (*IsVersionMissingTaskQueuesResult) Reset added in v1.27.0 

func (x *IsVersionMissingTaskQueuesResult) Reset()

func (*IsVersionMissingTaskQueuesResult) Size added in v1.27.0 

func (val *IsVersionMissingTaskQueuesResult) Size() int

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

func (*IsVersionMissingTaskQueuesResult) String added in v1.27.0 

func (x *IsVersionMissingTaskQueuesResult) String() string

func (*IsVersionMissingTaskQueuesResult) Unmarshal added in v1.27.0 

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

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

type PropagatingRevisions added in v1.30.0 

type PropagatingRevisions struct {
	RevisionNumbers []int64 `protobuf:"varint,1,rep,packed,name=revision_numbers,json=revisionNumbers,proto3" json:"revision_numbers,omitempty"`
	// contains filtered or unexported fields
}

Tracks revision numbers that are currently propagating for a specific build ID

func (*PropagatingRevisions) Descriptor deprecated added in v1.30.0 

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

Deprecated: Use PropagatingRevisions.ProtoReflect.Descriptor instead.

func (*PropagatingRevisions) Equal added in v1.30.0 

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

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

func (*PropagatingRevisions) GetRevisionNumbers added in v1.30.0 

func (x *PropagatingRevisions) GetRevisionNumbers() []int64

func (*PropagatingRevisions) Marshal added in v1.30.0 

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

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

func (*PropagatingRevisions) ProtoMessage added in v1.30.0 

func (*PropagatingRevisions) ProtoMessage()

func (*PropagatingRevisions) ProtoReflect added in v1.30.0 

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

func (*PropagatingRevisions) Reset added in v1.30.0 

func (x *PropagatingRevisions) Reset()

func (*PropagatingRevisions) Size added in v1.30.0 

func (val *PropagatingRevisions) Size() int

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

func (*PropagatingRevisions) String added in v1.30.0 

func (x *PropagatingRevisions) String() string

func (*PropagatingRevisions) Unmarshal added in v1.30.0 

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

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

type PropagationCompletionInfo added in v1.30.0 

type PropagationCompletionInfo struct {
	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"`
	// contains filtered or unexported fields
}

Sent from Version workflow to Worker Deployment workflow when async propagation completes

func (*PropagationCompletionInfo) Descriptor deprecated added in v1.30.0 

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

Deprecated: Use PropagationCompletionInfo.ProtoReflect.Descriptor instead.

func (*PropagationCompletionInfo) Equal added in v1.30.0 

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

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

func (*PropagationCompletionInfo) GetBuildId added in v1.30.0 

func (x *PropagationCompletionInfo) GetBuildId() string

func (*PropagationCompletionInfo) GetRevisionNumber added in v1.30.0 

func (x *PropagationCompletionInfo) GetRevisionNumber() int64

func (*PropagationCompletionInfo) Marshal added in v1.30.0 

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

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

func (*PropagationCompletionInfo) ProtoMessage added in v1.30.0 

func (*PropagationCompletionInfo) ProtoMessage()

func (*PropagationCompletionInfo) ProtoReflect added in v1.30.0 

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

func (*PropagationCompletionInfo) Reset added in v1.30.0 

func (x *PropagationCompletionInfo) Reset()

func (*PropagationCompletionInfo) Size added in v1.30.0 

func (val *PropagationCompletionInfo) Size() int

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

func (*PropagationCompletionInfo) String added in v1.30.0 

func (x *PropagationCompletionInfo) String() string

func (*PropagationCompletionInfo) Unmarshal added in v1.30.0 

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

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

type QueryDescribeVersionResponse added in v1.27.0 

type QueryDescribeVersionResponse struct {
	VersionState *VersionLocalState `protobuf:"bytes,1,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow query response:

func (*QueryDescribeVersionResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use QueryDescribeVersionResponse.ProtoReflect.Descriptor instead.

func (*QueryDescribeVersionResponse) Equal added in v1.27.0 

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

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

func (*QueryDescribeVersionResponse) GetVersionState added in v1.27.0 

func (x *QueryDescribeVersionResponse) GetVersionState() *VersionLocalState

func (*QueryDescribeVersionResponse) Marshal added in v1.27.0 

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

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

func (*QueryDescribeVersionResponse) ProtoMessage added in v1.27.0 

func (*QueryDescribeVersionResponse) ProtoMessage()

func (*QueryDescribeVersionResponse) ProtoReflect added in v1.27.0 

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

func (*QueryDescribeVersionResponse) Reset added in v1.27.0 

func (x *QueryDescribeVersionResponse) Reset()

func (*QueryDescribeVersionResponse) Size added in v1.27.0 

func (val *QueryDescribeVersionResponse) Size() int

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

func (*QueryDescribeVersionResponse) String added in v1.27.0 

func (x *QueryDescribeVersionResponse) String() string

func (*QueryDescribeVersionResponse) Unmarshal added in v1.27.0 

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

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

type QueryDescribeWorkerDeploymentResponse added in v1.27.0 

type QueryDescribeWorkerDeploymentResponse struct {
	State *WorkerDeploymentLocalState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow query response:

func (*QueryDescribeWorkerDeploymentResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use QueryDescribeWorkerDeploymentResponse.ProtoReflect.Descriptor instead.

func (*QueryDescribeWorkerDeploymentResponse) Equal added in v1.27.0 

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

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

func (*QueryDescribeWorkerDeploymentResponse) GetState added in v1.27.0 

func (x *QueryDescribeWorkerDeploymentResponse) GetState() *WorkerDeploymentLocalState

func (*QueryDescribeWorkerDeploymentResponse) Marshal added in v1.27.0 

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

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

func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage added in v1.27.0 

func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage()

func (*QueryDescribeWorkerDeploymentResponse) ProtoReflect added in v1.27.0 

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

func (*QueryDescribeWorkerDeploymentResponse) Reset added in v1.27.0 

func (x *QueryDescribeWorkerDeploymentResponse) Reset()

func (*QueryDescribeWorkerDeploymentResponse) Size added in v1.27.0 

func (val *QueryDescribeWorkerDeploymentResponse) Size() int

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

func (*QueryDescribeWorkerDeploymentResponse) String added in v1.27.0 

func (x *QueryDescribeWorkerDeploymentResponse) String() string

func (*QueryDescribeWorkerDeploymentResponse) Unmarshal added in v1.27.0 

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

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

type RegisterWorkerInVersionArgs added in v1.27.0 

type RegisterWorkerInVersionArgs struct {
	TaskQueueName string             `protobuf:"bytes,1,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"`
	TaskQueueType v1.TaskQueueType   `` /* 144-byte string literal not displayed */
	MaxTaskQueues int32              `protobuf:"varint,3,opt,name=max_task_queues,json=maxTaskQueues,proto3" json:"max_task_queues,omitempty"`
	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"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow update input:

func (*RegisterWorkerInVersionArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use RegisterWorkerInVersionArgs.ProtoReflect.Descriptor instead.

func (*RegisterWorkerInVersionArgs) Equal added in v1.27.0 

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

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

func (*RegisterWorkerInVersionArgs) GetMaxTaskQueues added in v1.27.0 

func (x *RegisterWorkerInVersionArgs) GetMaxTaskQueues() int32

func (*RegisterWorkerInVersionArgs) GetRoutingConfig added in v1.30.0 

func (x *RegisterWorkerInVersionArgs) GetRoutingConfig() *v11.RoutingConfig

func (*RegisterWorkerInVersionArgs) GetTaskQueueName added in v1.27.0 

func (x *RegisterWorkerInVersionArgs) GetTaskQueueName() string

func (*RegisterWorkerInVersionArgs) GetTaskQueueType added in v1.27.0 

func (x *RegisterWorkerInVersionArgs) GetTaskQueueType() v1.TaskQueueType

func (*RegisterWorkerInVersionArgs) GetVersion added in v1.28.0 

func (x *RegisterWorkerInVersionArgs) GetVersion() string

func (*RegisterWorkerInVersionArgs) Marshal added in v1.27.0 

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

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

func (*RegisterWorkerInVersionArgs) ProtoMessage added in v1.27.0 

func (*RegisterWorkerInVersionArgs) ProtoMessage()

func (*RegisterWorkerInVersionArgs) ProtoReflect added in v1.27.0 

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

func (*RegisterWorkerInVersionArgs) Reset added in v1.27.0 

func (x *RegisterWorkerInVersionArgs) Reset()

func (*RegisterWorkerInVersionArgs) Size added in v1.27.0 

func (val *RegisterWorkerInVersionArgs) Size() int

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

func (*RegisterWorkerInVersionArgs) String added in v1.27.0 

func (x *RegisterWorkerInVersionArgs) String() string

func (*RegisterWorkerInVersionArgs) Unmarshal added in v1.27.0 

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

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

type RegisterWorkerInWorkerDeploymentArgs added in v1.28.0 

type RegisterWorkerInWorkerDeploymentArgs struct {
	TaskQueueName string                   `protobuf:"bytes,1,opt,name=task_queue_name,json=taskQueueName,proto3" json:"task_queue_name,omitempty"`
	TaskQueueType v1.TaskQueueType         `` /* 144-byte string literal not displayed */
	MaxTaskQueues int32                    `protobuf:"varint,3,opt,name=max_task_queues,json=maxTaskQueues,proto3" json:"max_task_queues,omitempty"`
	Version       *WorkerDeploymentVersion `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input:

func (*RegisterWorkerInWorkerDeploymentArgs) Descriptor deprecated added in v1.28.0 

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

Deprecated: Use RegisterWorkerInWorkerDeploymentArgs.ProtoReflect.Descriptor instead.

func (*RegisterWorkerInWorkerDeploymentArgs) Equal added in v1.28.0 

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

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

func (*RegisterWorkerInWorkerDeploymentArgs) GetMaxTaskQueues added in v1.28.0 

func (x *RegisterWorkerInWorkerDeploymentArgs) GetMaxTaskQueues() int32

func (*RegisterWorkerInWorkerDeploymentArgs) GetTaskQueueName added in v1.28.0 

func (x *RegisterWorkerInWorkerDeploymentArgs) GetTaskQueueName() string

func (*RegisterWorkerInWorkerDeploymentArgs) GetTaskQueueType added in v1.28.0 

func (x *RegisterWorkerInWorkerDeploymentArgs) GetTaskQueueType() v1.TaskQueueType

func (*RegisterWorkerInWorkerDeploymentArgs) GetVersion added in v1.28.0 

func (x *RegisterWorkerInWorkerDeploymentArgs) GetVersion() *WorkerDeploymentVersion

func (*RegisterWorkerInWorkerDeploymentArgs) Marshal added in v1.28.0 

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

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

func (*RegisterWorkerInWorkerDeploymentArgs) ProtoMessage added in v1.28.0 

func (*RegisterWorkerInWorkerDeploymentArgs) ProtoMessage()

func (*RegisterWorkerInWorkerDeploymentArgs) ProtoReflect added in v1.28.0 

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

func (*RegisterWorkerInWorkerDeploymentArgs) Reset added in v1.28.0 

func (x *RegisterWorkerInWorkerDeploymentArgs) Reset()

func (*RegisterWorkerInWorkerDeploymentArgs) Size added in v1.28.0 

func (val *RegisterWorkerInWorkerDeploymentArgs) Size() int

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

func (*RegisterWorkerInWorkerDeploymentArgs) String added in v1.28.0 

func (x *RegisterWorkerInWorkerDeploymentArgs) String() string

func (*RegisterWorkerInWorkerDeploymentArgs) Unmarshal added in v1.28.0 

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

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

type SetCurrentVersionArgs added in v1.27.0 

type SetCurrentVersionArgs struct {
	Identity                string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Version                 string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	IgnoreMissingTaskQueues bool   `` /* 135-byte string literal not displayed */
	ConflictToken           []byte `protobuf:"bytes,4,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	AllowNoPollers          bool   `protobuf:"varint,5,opt,name=allow_no_pollers,json=allowNoPollers,proto3" json:"allow_no_pollers,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input:

func (*SetCurrentVersionArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SetCurrentVersionArgs.ProtoReflect.Descriptor instead.

func (*SetCurrentVersionArgs) Equal added in v1.27.0 

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

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

func (*SetCurrentVersionArgs) GetAllowNoPollers added in v1.29.0 

func (x *SetCurrentVersionArgs) GetAllowNoPollers() bool

func (*SetCurrentVersionArgs) GetConflictToken added in v1.27.0 

func (x *SetCurrentVersionArgs) GetConflictToken() []byte

func (*SetCurrentVersionArgs) GetIdentity added in v1.27.0 

func (x *SetCurrentVersionArgs) GetIdentity() string

func (*SetCurrentVersionArgs) GetIgnoreMissingTaskQueues added in v1.27.0 

func (x *SetCurrentVersionArgs) GetIgnoreMissingTaskQueues() bool

func (*SetCurrentVersionArgs) GetVersion added in v1.27.0 

func (x *SetCurrentVersionArgs) GetVersion() string

func (*SetCurrentVersionArgs) Marshal added in v1.27.0 

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

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

func (*SetCurrentVersionArgs) ProtoMessage added in v1.27.0 

func (*SetCurrentVersionArgs) ProtoMessage()

func (*SetCurrentVersionArgs) ProtoReflect added in v1.27.0 

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

func (*SetCurrentVersionArgs) Reset added in v1.27.0 

func (x *SetCurrentVersionArgs) Reset()

func (*SetCurrentVersionArgs) Size added in v1.27.0 

func (val *SetCurrentVersionArgs) Size() int

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

func (*SetCurrentVersionArgs) String added in v1.27.0 

func (x *SetCurrentVersionArgs) String() string

func (*SetCurrentVersionArgs) Unmarshal added in v1.27.0 

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

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

type SetCurrentVersionResponse added in v1.27.0 

type SetCurrentVersionResponse struct {
	PreviousVersion string `protobuf:"bytes,1,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	ConflictToken   []byte `protobuf:"bytes,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment update response:

func (*SetCurrentVersionResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SetCurrentVersionResponse.ProtoReflect.Descriptor instead.

func (*SetCurrentVersionResponse) Equal added in v1.27.0 

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

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

func (*SetCurrentVersionResponse) GetConflictToken added in v1.27.0 

func (x *SetCurrentVersionResponse) GetConflictToken() []byte

func (*SetCurrentVersionResponse) GetPreviousVersion added in v1.27.0 

func (x *SetCurrentVersionResponse) GetPreviousVersion() string

func (*SetCurrentVersionResponse) Marshal added in v1.27.0 

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

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

func (*SetCurrentVersionResponse) ProtoMessage added in v1.27.0 

func (*SetCurrentVersionResponse) ProtoMessage()

func (*SetCurrentVersionResponse) ProtoReflect added in v1.27.0 

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

func (*SetCurrentVersionResponse) Reset added in v1.27.0 

func (x *SetCurrentVersionResponse) Reset()

func (*SetCurrentVersionResponse) Size added in v1.27.0 

func (val *SetCurrentVersionResponse) Size() int

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

func (*SetCurrentVersionResponse) String added in v1.27.0 

func (x *SetCurrentVersionResponse) String() string

func (*SetCurrentVersionResponse) Unmarshal added in v1.27.0 

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

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

type SetManagerIdentityArgs added in v1.29.0 

type SetManagerIdentityArgs struct {

	// 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"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input:

func (*SetManagerIdentityArgs) Descriptor deprecated added in v1.29.0 

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

Deprecated: Use SetManagerIdentityArgs.ProtoReflect.Descriptor instead.

func (*SetManagerIdentityArgs) Equal added in v1.29.0 

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

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

func (*SetManagerIdentityArgs) GetConflictToken added in v1.29.0 

func (x *SetManagerIdentityArgs) GetConflictToken() []byte

func (*SetManagerIdentityArgs) GetIdentity added in v1.29.0 

func (x *SetManagerIdentityArgs) GetIdentity() string

func (*SetManagerIdentityArgs) GetManagerIdentity added in v1.29.0 

func (x *SetManagerIdentityArgs) GetManagerIdentity() string

func (*SetManagerIdentityArgs) Marshal added in v1.29.0 

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

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

func (*SetManagerIdentityArgs) ProtoMessage added in v1.29.0 

func (*SetManagerIdentityArgs) ProtoMessage()

func (*SetManagerIdentityArgs) ProtoReflect added in v1.29.0 

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

func (*SetManagerIdentityArgs) Reset added in v1.29.0 

func (x *SetManagerIdentityArgs) Reset()

func (*SetManagerIdentityArgs) Size added in v1.29.0 

func (val *SetManagerIdentityArgs) Size() int

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

func (*SetManagerIdentityArgs) String added in v1.29.0 

func (x *SetManagerIdentityArgs) String() string

func (*SetManagerIdentityArgs) Unmarshal added in v1.29.0 

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

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

type SetManagerIdentityResponse added in v1.29.0 

type SetManagerIdentityResponse struct {
	PreviousManagerIdentity string `` /* 132-byte string literal not displayed */
	ConflictToken           []byte `protobuf:"bytes,2,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment update response:

func (*SetManagerIdentityResponse) Descriptor deprecated added in v1.29.0 

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

Deprecated: Use SetManagerIdentityResponse.ProtoReflect.Descriptor instead.

func (*SetManagerIdentityResponse) Equal added in v1.29.0 

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

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

func (*SetManagerIdentityResponse) GetConflictToken added in v1.29.0 

func (x *SetManagerIdentityResponse) GetConflictToken() []byte

func (*SetManagerIdentityResponse) GetPreviousManagerIdentity added in v1.29.0 

func (x *SetManagerIdentityResponse) GetPreviousManagerIdentity() string

func (*SetManagerIdentityResponse) Marshal added in v1.29.0 

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

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

func (*SetManagerIdentityResponse) ProtoMessage added in v1.29.0 

func (*SetManagerIdentityResponse) ProtoMessage()

func (*SetManagerIdentityResponse) ProtoReflect added in v1.29.0 

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

func (*SetManagerIdentityResponse) Reset added in v1.29.0 

func (x *SetManagerIdentityResponse) Reset()

func (*SetManagerIdentityResponse) Size added in v1.29.0 

func (val *SetManagerIdentityResponse) Size() int

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

func (*SetManagerIdentityResponse) String added in v1.29.0 

func (x *SetManagerIdentityResponse) String() string

func (*SetManagerIdentityResponse) Unmarshal added in v1.29.0 

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

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

type SetRampingVersionArgs added in v1.27.0 

type SetRampingVersionArgs struct {
	Identity                string  `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Version                 string  `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Percentage              float32 `protobuf:"fixed32,3,opt,name=percentage,proto3" json:"percentage,omitempty"`
	IgnoreMissingTaskQueues bool    `` /* 135-byte string literal not displayed */
	ConflictToken           []byte  `protobuf:"bytes,5,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	AllowNoPollers          bool    `protobuf:"varint,6,opt,name=allow_no_pollers,json=allowNoPollers,proto3" json:"allow_no_pollers,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input:

func (*SetRampingVersionArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SetRampingVersionArgs.ProtoReflect.Descriptor instead.

func (*SetRampingVersionArgs) Equal added in v1.27.0 

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

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

func (*SetRampingVersionArgs) GetAllowNoPollers added in v1.29.0 

func (x *SetRampingVersionArgs) GetAllowNoPollers() bool

func (*SetRampingVersionArgs) GetConflictToken added in v1.27.0 

func (x *SetRampingVersionArgs) GetConflictToken() []byte

func (*SetRampingVersionArgs) GetIdentity added in v1.27.0 

func (x *SetRampingVersionArgs) GetIdentity() string

func (*SetRampingVersionArgs) GetIgnoreMissingTaskQueues added in v1.27.0 

func (x *SetRampingVersionArgs) GetIgnoreMissingTaskQueues() bool

func (*SetRampingVersionArgs) GetPercentage added in v1.27.0 

func (x *SetRampingVersionArgs) GetPercentage() float32

func (*SetRampingVersionArgs) GetVersion added in v1.27.0 

func (x *SetRampingVersionArgs) GetVersion() string

func (*SetRampingVersionArgs) Marshal added in v1.27.0 

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

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

func (*SetRampingVersionArgs) ProtoMessage added in v1.27.0 

func (*SetRampingVersionArgs) ProtoMessage()

func (*SetRampingVersionArgs) ProtoReflect added in v1.27.0 

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

func (*SetRampingVersionArgs) Reset added in v1.27.0 

func (x *SetRampingVersionArgs) Reset()

func (*SetRampingVersionArgs) Size added in v1.27.0 

func (val *SetRampingVersionArgs) Size() int

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

func (*SetRampingVersionArgs) String added in v1.27.0 

func (x *SetRampingVersionArgs) String() string

func (*SetRampingVersionArgs) Unmarshal added in v1.27.0 

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

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

type SetRampingVersionResponse added in v1.27.0 

type SetRampingVersionResponse struct {
	PreviousVersion    string  `protobuf:"bytes,1,opt,name=previous_version,json=previousVersion,proto3" json:"previous_version,omitempty"`
	PreviousPercentage float32 `protobuf:"fixed32,2,opt,name=previous_percentage,json=previousPercentage,proto3" json:"previous_percentage,omitempty"`
	ConflictToken      []byte  `protobuf:"bytes,3,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment update response:

func (*SetRampingVersionResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SetRampingVersionResponse.ProtoReflect.Descriptor instead.

func (*SetRampingVersionResponse) Equal added in v1.27.0 

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

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

func (*SetRampingVersionResponse) GetConflictToken added in v1.27.0 

func (x *SetRampingVersionResponse) GetConflictToken() []byte

func (*SetRampingVersionResponse) GetPreviousPercentage added in v1.27.0 

func (x *SetRampingVersionResponse) GetPreviousPercentage() float32

func (*SetRampingVersionResponse) GetPreviousVersion added in v1.27.0 

func (x *SetRampingVersionResponse) GetPreviousVersion() string

func (*SetRampingVersionResponse) Marshal added in v1.27.0 

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

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

func (*SetRampingVersionResponse) ProtoMessage added in v1.27.0 

func (*SetRampingVersionResponse) ProtoMessage()

func (*SetRampingVersionResponse) ProtoReflect added in v1.27.0 

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

func (*SetRampingVersionResponse) Reset added in v1.27.0 

func (x *SetRampingVersionResponse) Reset()

func (*SetRampingVersionResponse) Size added in v1.27.0 

func (val *SetRampingVersionResponse) Size() int

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

func (*SetRampingVersionResponse) String added in v1.27.0 

func (x *SetRampingVersionResponse) String() string

func (*SetRampingVersionResponse) Unmarshal added in v1.27.0 

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

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

type StartWorkerDeploymentRequest added in v1.27.0 

type StartWorkerDeploymentRequest struct {
	DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	RequestId      string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow activity input:

func (*StartWorkerDeploymentRequest) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use StartWorkerDeploymentRequest.ProtoReflect.Descriptor instead.

func (*StartWorkerDeploymentRequest) Equal added in v1.27.0 

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

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

func (*StartWorkerDeploymentRequest) GetDeploymentName added in v1.27.0 

func (x *StartWorkerDeploymentRequest) GetDeploymentName() string

func (*StartWorkerDeploymentRequest) GetRequestId added in v1.27.0 

func (x *StartWorkerDeploymentRequest) GetRequestId() string

func (*StartWorkerDeploymentRequest) Marshal added in v1.27.0 

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

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

func (*StartWorkerDeploymentRequest) ProtoMessage added in v1.27.0 

func (*StartWorkerDeploymentRequest) ProtoMessage()

func (*StartWorkerDeploymentRequest) ProtoReflect added in v1.27.0 

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

func (*StartWorkerDeploymentRequest) Reset added in v1.27.0 

func (x *StartWorkerDeploymentRequest) Reset()

func (*StartWorkerDeploymentRequest) Size added in v1.27.0 

func (val *StartWorkerDeploymentRequest) Size() int

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

func (*StartWorkerDeploymentRequest) String added in v1.27.0 

func (x *StartWorkerDeploymentRequest) String() string

func (*StartWorkerDeploymentRequest) Unmarshal added in v1.27.0 

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

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

type StartWorkerDeploymentVersionRequest added in v1.29.0 

type StartWorkerDeploymentVersionRequest struct {
	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"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow activity input:

func (*StartWorkerDeploymentVersionRequest) Descriptor deprecated added in v1.29.0 

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

Deprecated: Use StartWorkerDeploymentVersionRequest.ProtoReflect.Descriptor instead.

func (*StartWorkerDeploymentVersionRequest) Equal added in v1.29.0 

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

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

func (*StartWorkerDeploymentVersionRequest) GetBuildId added in v1.29.0 

func (x *StartWorkerDeploymentVersionRequest) GetBuildId() string

func (*StartWorkerDeploymentVersionRequest) GetDeploymentName added in v1.29.0 

func (x *StartWorkerDeploymentVersionRequest) GetDeploymentName() string

func (*StartWorkerDeploymentVersionRequest) GetRequestId added in v1.29.0 

func (x *StartWorkerDeploymentVersionRequest) GetRequestId() string

func (*StartWorkerDeploymentVersionRequest) Marshal added in v1.29.0 

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

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

func (*StartWorkerDeploymentVersionRequest) ProtoMessage added in v1.29.0 

func (*StartWorkerDeploymentVersionRequest) ProtoMessage()

func (*StartWorkerDeploymentVersionRequest) ProtoReflect added in v1.29.0 

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

func (*StartWorkerDeploymentVersionRequest) Reset added in v1.29.0 

func (x *StartWorkerDeploymentVersionRequest) Reset()

func (*StartWorkerDeploymentVersionRequest) Size added in v1.29.0 

func (val *StartWorkerDeploymentVersionRequest) Size() int

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

func (*StartWorkerDeploymentVersionRequest) String added in v1.29.0 

func (x *StartWorkerDeploymentVersionRequest) String() string

func (*StartWorkerDeploymentVersionRequest) Unmarshal added in v1.29.0 

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

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

type SyncDeploymentVersionUserDataRequest added in v1.27.0 

type SyncDeploymentVersionUserDataRequest struct {
	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"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow activity input:

func (*SyncDeploymentVersionUserDataRequest) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncDeploymentVersionUserDataRequest.ProtoReflect.Descriptor instead.

func (*SyncDeploymentVersionUserDataRequest) Equal added in v1.27.0 

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

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

func (*SyncDeploymentVersionUserDataRequest) GetDeploymentName added in v1.30.0 

func (x *SyncDeploymentVersionUserDataRequest) GetDeploymentName() string

func (*SyncDeploymentVersionUserDataRequest) GetForgetVersion added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest) GetForgetVersion() bool

func (*SyncDeploymentVersionUserDataRequest) GetSync added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest) GetSync() []*SyncDeploymentVersionUserDataRequest_SyncUserData

func (*SyncDeploymentVersionUserDataRequest) GetUpdateRoutingConfig added in v1.30.0 

func (x *SyncDeploymentVersionUserDataRequest) GetUpdateRoutingConfig() *v11.RoutingConfig

func (*SyncDeploymentVersionUserDataRequest) GetUpsertVersionData added in v1.30.0 

func (x *SyncDeploymentVersionUserDataRequest) GetUpsertVersionData() *WorkerDeploymentVersionData

func (*SyncDeploymentVersionUserDataRequest) GetVersion added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest) GetVersion() *WorkerDeploymentVersion

func (*SyncDeploymentVersionUserDataRequest) Marshal added in v1.27.0 

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

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

func (*SyncDeploymentVersionUserDataRequest) ProtoMessage added in v1.27.0 

func (*SyncDeploymentVersionUserDataRequest) ProtoMessage()

func (*SyncDeploymentVersionUserDataRequest) ProtoReflect added in v1.27.0 

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

func (*SyncDeploymentVersionUserDataRequest) Reset added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest) Reset()

func (*SyncDeploymentVersionUserDataRequest) Size added in v1.27.0 

func (val *SyncDeploymentVersionUserDataRequest) Size() int

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

func (*SyncDeploymentVersionUserDataRequest) String added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest) String() string

func (*SyncDeploymentVersionUserDataRequest) Unmarshal added in v1.27.0 

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

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

type SyncDeploymentVersionUserDataRequest_SyncUserData added in v1.27.0 

type SyncDeploymentVersionUserDataRequest_SyncUserData struct {
	Name  string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Types []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"`
	// contains filtered or unexported fields
}

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncDeploymentVersionUserDataRequest_SyncUserData.ProtoReflect.Descriptor instead.

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) GetData added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetData() *DeploymentVersionData

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) GetName added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetName() string

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes() []v1.TaskQueueType

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage added in v1.27.0 

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage()

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoReflect added in v1.27.0 

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

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) Reset added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) Reset()

func (*SyncDeploymentVersionUserDataRequest_SyncUserData) String added in v1.27.0 

func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) String() string

type SyncDeploymentVersionUserDataResponse added in v1.27.0 

type SyncDeploymentVersionUserDataResponse struct {
	TaskQueueMaxVersions map[string]int64 `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow activity output:

func (*SyncDeploymentVersionUserDataResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncDeploymentVersionUserDataResponse.ProtoReflect.Descriptor instead.

func (*SyncDeploymentVersionUserDataResponse) Equal added in v1.27.0 

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

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

func (*SyncDeploymentVersionUserDataResponse) GetTaskQueueMaxVersions added in v1.27.0 

func (x *SyncDeploymentVersionUserDataResponse) GetTaskQueueMaxVersions() map[string]int64

func (*SyncDeploymentVersionUserDataResponse) Marshal added in v1.27.0 

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

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

func (*SyncDeploymentVersionUserDataResponse) ProtoMessage added in v1.27.0 

func (*SyncDeploymentVersionUserDataResponse) ProtoMessage()

func (*SyncDeploymentVersionUserDataResponse) ProtoReflect added in v1.27.0 

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

func (*SyncDeploymentVersionUserDataResponse) Reset added in v1.27.0 

func (x *SyncDeploymentVersionUserDataResponse) Reset()

func (*SyncDeploymentVersionUserDataResponse) Size added in v1.27.0 

func (val *SyncDeploymentVersionUserDataResponse) Size() int

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

func (*SyncDeploymentVersionUserDataResponse) String added in v1.27.0 

func (x *SyncDeploymentVersionUserDataResponse) String() string

func (*SyncDeploymentVersionUserDataResponse) Unmarshal added in v1.27.0 

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

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

type SyncDrainageInfoSignalArgs added in v1.27.0 

type SyncDrainageInfoSignalArgs struct {
	DrainageInfo *v11.VersionDrainageInfo `protobuf:"bytes,1,opt,name=drainage_info,json=drainageInfo,proto3" json:"drainage_info,omitempty"`
	// contains filtered or unexported fields
}

Sent from Drainage child workflow to Version parent

func (*SyncDrainageInfoSignalArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncDrainageInfoSignalArgs.ProtoReflect.Descriptor instead.

func (*SyncDrainageInfoSignalArgs) Equal added in v1.27.0 

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

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

func (*SyncDrainageInfoSignalArgs) GetDrainageInfo added in v1.27.0 

func (x *SyncDrainageInfoSignalArgs) GetDrainageInfo() *v11.VersionDrainageInfo

func (*SyncDrainageInfoSignalArgs) Marshal added in v1.27.0 

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

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

func (*SyncDrainageInfoSignalArgs) ProtoMessage added in v1.27.0 

func (*SyncDrainageInfoSignalArgs) ProtoMessage()

func (*SyncDrainageInfoSignalArgs) ProtoReflect added in v1.27.0 

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

func (*SyncDrainageInfoSignalArgs) Reset added in v1.27.0 

func (x *SyncDrainageInfoSignalArgs) Reset()

func (*SyncDrainageInfoSignalArgs) Size added in v1.27.0 

func (val *SyncDrainageInfoSignalArgs) Size() int

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

func (*SyncDrainageInfoSignalArgs) String added in v1.27.0 

func (x *SyncDrainageInfoSignalArgs) String() string

func (*SyncDrainageInfoSignalArgs) Unmarshal added in v1.27.0 

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

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

type SyncDrainageStatusSignalArgs added in v1.27.0 

type SyncDrainageStatusSignalArgs struct {
	Version        string                   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	DrainageStatus v1.VersionDrainageStatus `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Sent from Version workflow to Worker Deployment workflow

func (*SyncDrainageStatusSignalArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncDrainageStatusSignalArgs.ProtoReflect.Descriptor instead.

func (*SyncDrainageStatusSignalArgs) Equal added in v1.27.0 

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

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

func (*SyncDrainageStatusSignalArgs) GetDrainageStatus added in v1.27.0 

func (x *SyncDrainageStatusSignalArgs) GetDrainageStatus() v1.VersionDrainageStatus

func (*SyncDrainageStatusSignalArgs) GetVersion added in v1.27.0 

func (x *SyncDrainageStatusSignalArgs) GetVersion() string

func (*SyncDrainageStatusSignalArgs) Marshal added in v1.27.0 

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

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

func (*SyncDrainageStatusSignalArgs) ProtoMessage added in v1.27.0 

func (*SyncDrainageStatusSignalArgs) ProtoMessage()

func (*SyncDrainageStatusSignalArgs) ProtoReflect added in v1.27.0 

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

func (*SyncDrainageStatusSignalArgs) Reset added in v1.27.0 

func (x *SyncDrainageStatusSignalArgs) Reset()

func (*SyncDrainageStatusSignalArgs) Size added in v1.27.0 

func (val *SyncDrainageStatusSignalArgs) Size() int

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

func (*SyncDrainageStatusSignalArgs) String added in v1.27.0 

func (x *SyncDrainageStatusSignalArgs) String() string

func (*SyncDrainageStatusSignalArgs) Unmarshal added in v1.27.0 

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

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

type SyncUnversionedRampActivityArgs added in v1.27.0 

type SyncUnversionedRampActivityArgs struct {
	CurrentVersion string                      `protobuf:"bytes,1,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
	UpdateArgs     *SyncVersionStateUpdateArgs `protobuf:"bytes,2,opt,name=update_args,json=updateArgs,proto3" json:"update_args,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow activity input:

func (*SyncUnversionedRampActivityArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncUnversionedRampActivityArgs.ProtoReflect.Descriptor instead.

func (*SyncUnversionedRampActivityArgs) Equal added in v1.27.0 

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

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

func (*SyncUnversionedRampActivityArgs) GetCurrentVersion added in v1.27.0 

func (x *SyncUnversionedRampActivityArgs) GetCurrentVersion() string

func (*SyncUnversionedRampActivityArgs) GetUpdateArgs added in v1.27.0 

func (x *SyncUnversionedRampActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs

func (*SyncUnversionedRampActivityArgs) Marshal added in v1.27.0 

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

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

func (*SyncUnversionedRampActivityArgs) ProtoMessage added in v1.27.0 

func (*SyncUnversionedRampActivityArgs) ProtoMessage()

func (*SyncUnversionedRampActivityArgs) ProtoReflect added in v1.27.0 

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

func (*SyncUnversionedRampActivityArgs) Reset added in v1.27.0 

func (x *SyncUnversionedRampActivityArgs) Reset()

func (*SyncUnversionedRampActivityArgs) Size added in v1.27.0 

func (val *SyncUnversionedRampActivityArgs) Size() int

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

func (*SyncUnversionedRampActivityArgs) String added in v1.27.0 

func (x *SyncUnversionedRampActivityArgs) String() string

func (*SyncUnversionedRampActivityArgs) Unmarshal added in v1.27.0 

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

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

type SyncUnversionedRampActivityResponse added in v1.27.0 

type SyncUnversionedRampActivityResponse struct {
	TaskQueueMaxVersions map[string]int64 `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

used as Worker Deployment workflow activity output:

func (*SyncUnversionedRampActivityResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncUnversionedRampActivityResponse.ProtoReflect.Descriptor instead.

func (*SyncUnversionedRampActivityResponse) Equal added in v1.27.0 

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

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

func (*SyncUnversionedRampActivityResponse) GetTaskQueueMaxVersions added in v1.27.0 

func (x *SyncUnversionedRampActivityResponse) GetTaskQueueMaxVersions() map[string]int64

func (*SyncUnversionedRampActivityResponse) Marshal added in v1.27.0 

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

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

func (*SyncUnversionedRampActivityResponse) ProtoMessage added in v1.27.0 

func (*SyncUnversionedRampActivityResponse) ProtoMessage()

func (*SyncUnversionedRampActivityResponse) ProtoReflect added in v1.27.0 

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

func (*SyncUnversionedRampActivityResponse) Reset added in v1.27.0 

func (x *SyncUnversionedRampActivityResponse) Reset()

func (*SyncUnversionedRampActivityResponse) Size added in v1.27.0 

func (val *SyncUnversionedRampActivityResponse) Size() int

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

func (*SyncUnversionedRampActivityResponse) String added in v1.27.0 

func (x *SyncUnversionedRampActivityResponse) String() string

func (*SyncUnversionedRampActivityResponse) Unmarshal added in v1.27.0 

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

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

type SyncVersionStateActivityArgs added in v1.27.0 

type SyncVersionStateActivityArgs struct {
	DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	// <deployment_name>.<build_id> or possibly just <version_id> in the future
	Version    string                      `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	UpdateArgs *SyncVersionStateUpdateArgs `protobuf:"bytes,3,opt,name=update_args,json=updateArgs,proto3" json:"update_args,omitempty"`
	RequestId  string                      `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment activity input:

func (*SyncVersionStateActivityArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncVersionStateActivityArgs.ProtoReflect.Descriptor instead.

func (*SyncVersionStateActivityArgs) Equal added in v1.27.0 

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

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

func (*SyncVersionStateActivityArgs) GetDeploymentName added in v1.27.0 

func (x *SyncVersionStateActivityArgs) GetDeploymentName() string

func (*SyncVersionStateActivityArgs) GetRequestId added in v1.27.0 

func (x *SyncVersionStateActivityArgs) GetRequestId() string

func (*SyncVersionStateActivityArgs) GetUpdateArgs added in v1.27.0 

func (x *SyncVersionStateActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs

func (*SyncVersionStateActivityArgs) GetVersion added in v1.27.0 

func (x *SyncVersionStateActivityArgs) GetVersion() string

func (*SyncVersionStateActivityArgs) Marshal added in v1.27.0 

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

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

func (*SyncVersionStateActivityArgs) ProtoMessage added in v1.27.0 

func (*SyncVersionStateActivityArgs) ProtoMessage()

func (*SyncVersionStateActivityArgs) ProtoReflect added in v1.27.0 

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

func (*SyncVersionStateActivityArgs) Reset added in v1.27.0 

func (x *SyncVersionStateActivityArgs) Reset()

func (*SyncVersionStateActivityArgs) Size added in v1.27.0 

func (val *SyncVersionStateActivityArgs) Size() int

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

func (*SyncVersionStateActivityArgs) String added in v1.27.0 

func (x *SyncVersionStateActivityArgs) String() string

func (*SyncVersionStateActivityArgs) Unmarshal added in v1.27.0 

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

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

type SyncVersionStateActivityResult added in v1.27.0 

type SyncVersionStateActivityResult struct {

	// 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"`
	// contains filtered or unexported fields
}

used as Worker Deployment activity result:

func (*SyncVersionStateActivityResult) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncVersionStateActivityResult.ProtoReflect.Descriptor instead.

func (*SyncVersionStateActivityResult) Equal added in v1.27.0 

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

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

func (*SyncVersionStateActivityResult) GetSummary added in v1.30.0 

func (x *SyncVersionStateActivityResult) GetSummary() *WorkerDeploymentVersionSummary

func (*SyncVersionStateActivityResult) GetVersionState deprecated added in v1.27.0 

func (x *SyncVersionStateActivityResult) GetVersionState() *VersionLocalState

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

func (*SyncVersionStateActivityResult) Marshal added in v1.27.0 

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

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

func (*SyncVersionStateActivityResult) ProtoMessage added in v1.27.0 

func (*SyncVersionStateActivityResult) ProtoMessage()

func (*SyncVersionStateActivityResult) ProtoReflect added in v1.27.0 

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

func (*SyncVersionStateActivityResult) Reset added in v1.27.0 

func (x *SyncVersionStateActivityResult) Reset()

func (*SyncVersionStateActivityResult) Size added in v1.27.0 

func (val *SyncVersionStateActivityResult) Size() int

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

func (*SyncVersionStateActivityResult) String added in v1.27.0 

func (x *SyncVersionStateActivityResult) String() string

func (*SyncVersionStateActivityResult) Unmarshal added in v1.27.0 

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

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

type SyncVersionStateResponse added in v1.27.0 

type SyncVersionStateResponse struct {

	// 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"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update response (sent from Worker Deployment workflow):

func (*SyncVersionStateResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncVersionStateResponse.ProtoReflect.Descriptor instead.

func (*SyncVersionStateResponse) Equal added in v1.27.0 

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

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

func (*SyncVersionStateResponse) GetSummary added in v1.30.0 

func (x *SyncVersionStateResponse) GetSummary() *WorkerDeploymentVersionSummary

func (*SyncVersionStateResponse) GetVersionState deprecated added in v1.27.0 

func (x *SyncVersionStateResponse) GetVersionState() *VersionLocalState

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

func (*SyncVersionStateResponse) Marshal added in v1.27.0 

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

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

func (*SyncVersionStateResponse) ProtoMessage added in v1.27.0 

func (*SyncVersionStateResponse) ProtoMessage()

func (*SyncVersionStateResponse) ProtoReflect added in v1.27.0 

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

func (*SyncVersionStateResponse) Reset added in v1.27.0 

func (x *SyncVersionStateResponse) Reset()

func (*SyncVersionStateResponse) Size added in v1.27.0 

func (val *SyncVersionStateResponse) Size() int

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

func (*SyncVersionStateResponse) String added in v1.27.0 

func (x *SyncVersionStateResponse) String() string

func (*SyncVersionStateResponse) Unmarshal added in v1.27.0 

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

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

type SyncVersionStateUpdateArgs added in v1.27.0 

type SyncVersionStateUpdateArgs struct {

	// Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed.
	//
	// 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"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow update input (sent from Worker Deployment workflow):

func (*SyncVersionStateUpdateArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use SyncVersionStateUpdateArgs.ProtoReflect.Descriptor instead.

func (*SyncVersionStateUpdateArgs) Equal added in v1.27.0 

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

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

func (*SyncVersionStateUpdateArgs) GetCurrentSinceTime deprecated added in v1.27.0 

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

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

func (*SyncVersionStateUpdateArgs) GetRampPercentage deprecated added in v1.27.0 

func (x *SyncVersionStateUpdateArgs) GetRampPercentage() float32

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

func (*SyncVersionStateUpdateArgs) GetRampingSinceTime deprecated added in v1.27.0 

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

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

func (*SyncVersionStateUpdateArgs) GetRoutingConfig added in v1.30.0 

func (x *SyncVersionStateUpdateArgs) GetRoutingConfig() *v11.RoutingConfig

func (*SyncVersionStateUpdateArgs) GetRoutingUpdateTime deprecated added in v1.27.0 

func (x *SyncVersionStateUpdateArgs) GetRoutingUpdateTime() *timestamppb.Timestamp

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

func (*SyncVersionStateUpdateArgs) Marshal added in v1.27.0 

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

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

func (*SyncVersionStateUpdateArgs) ProtoMessage added in v1.27.0 

func (*SyncVersionStateUpdateArgs) ProtoMessage()

func (*SyncVersionStateUpdateArgs) ProtoReflect added in v1.27.0 

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

func (*SyncVersionStateUpdateArgs) Reset added in v1.27.0 

func (x *SyncVersionStateUpdateArgs) Reset()

func (*SyncVersionStateUpdateArgs) Size added in v1.27.0 

func (val *SyncVersionStateUpdateArgs) Size() int

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

func (*SyncVersionStateUpdateArgs) String added in v1.27.0 

func (x *SyncVersionStateUpdateArgs) String() string

func (*SyncVersionStateUpdateArgs) Unmarshal added in v1.27.0 

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

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

type TaskQueueVersionData added in v1.27.0 

type TaskQueueVersionData struct {
	// contains filtered or unexported fields
}

Data specific to a task queue, from the perspective of a worker deployment version.

func (*TaskQueueVersionData) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use TaskQueueVersionData.ProtoReflect.Descriptor instead.

func (*TaskQueueVersionData) Equal added in v1.27.0 

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

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

func (*TaskQueueVersionData) Marshal added in v1.27.0 

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

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

func (*TaskQueueVersionData) ProtoMessage added in v1.27.0 

func (*TaskQueueVersionData) ProtoMessage()

func (*TaskQueueVersionData) ProtoReflect added in v1.27.0 

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

func (*TaskQueueVersionData) Reset added in v1.27.0 

func (x *TaskQueueVersionData) Reset()

func (*TaskQueueVersionData) Size added in v1.27.0 

func (val *TaskQueueVersionData) Size() int

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

func (*TaskQueueVersionData) String added in v1.27.0 

func (x *TaskQueueVersionData) String() string

func (*TaskQueueVersionData) Unmarshal added in v1.27.0 

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

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

type UpdateVersionMetadataArgs added in v1.27.0 

type UpdateVersionMetadataArgs struct {
	UpsertEntries map[string]*v12.Payload `` /* 174-byte string literal not displayed */
	RemoveEntries []string                `protobuf:"bytes,2,rep,name=remove_entries,json=removeEntries,proto3" json:"remove_entries,omitempty"`
	Identity      string                  `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow update input:

func (*UpdateVersionMetadataArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use UpdateVersionMetadataArgs.ProtoReflect.Descriptor instead.

func (*UpdateVersionMetadataArgs) Equal added in v1.27.0 

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

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

func (*UpdateVersionMetadataArgs) GetIdentity added in v1.27.0 

func (x *UpdateVersionMetadataArgs) GetIdentity() string

func (*UpdateVersionMetadataArgs) GetRemoveEntries added in v1.27.0 

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

func (*UpdateVersionMetadataArgs) GetUpsertEntries added in v1.27.0 

func (x *UpdateVersionMetadataArgs) GetUpsertEntries() map[string]*v12.Payload

func (*UpdateVersionMetadataArgs) Marshal added in v1.27.0 

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

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

func (*UpdateVersionMetadataArgs) ProtoMessage added in v1.27.0 

func (*UpdateVersionMetadataArgs) ProtoMessage()

func (*UpdateVersionMetadataArgs) ProtoReflect added in v1.27.0 

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

func (*UpdateVersionMetadataArgs) Reset added in v1.27.0 

func (x *UpdateVersionMetadataArgs) Reset()

func (*UpdateVersionMetadataArgs) Size added in v1.27.0 

func (val *UpdateVersionMetadataArgs) Size() int

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

func (*UpdateVersionMetadataArgs) String added in v1.27.0 

func (x *UpdateVersionMetadataArgs) String() string

func (*UpdateVersionMetadataArgs) Unmarshal added in v1.27.0 

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

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

type UpdateVersionMetadataResponse added in v1.27.0 

type UpdateVersionMetadataResponse struct {
	Metadata *v11.VersionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow update response:

func (*UpdateVersionMetadataResponse) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use UpdateVersionMetadataResponse.ProtoReflect.Descriptor instead.

func (*UpdateVersionMetadataResponse) Equal added in v1.27.0 

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

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

func (*UpdateVersionMetadataResponse) GetMetadata added in v1.27.0 

func (x *UpdateVersionMetadataResponse) GetMetadata() *v11.VersionMetadata

func (*UpdateVersionMetadataResponse) Marshal added in v1.27.0 

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

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

func (*UpdateVersionMetadataResponse) ProtoMessage added in v1.27.0 

func (*UpdateVersionMetadataResponse) ProtoMessage()

func (*UpdateVersionMetadataResponse) ProtoReflect added in v1.27.0 

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

func (*UpdateVersionMetadataResponse) Reset added in v1.27.0 

func (x *UpdateVersionMetadataResponse) Reset()

func (*UpdateVersionMetadataResponse) Size added in v1.27.0 

func (val *UpdateVersionMetadataResponse) Size() int

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

func (*UpdateVersionMetadataResponse) String added in v1.27.0 

func (x *UpdateVersionMetadataResponse) String() string

func (*UpdateVersionMetadataResponse) Unmarshal added in v1.27.0 

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

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

type VersionLocalState added in v1.27.0 

type VersionLocalState struct {
	Version    *WorkerDeploymentVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	CreateTime *timestamppb.Timestamp   `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Last time `current_since_time`, `ramping_since_time, or `ramp_percentage` of this version changed.
	RoutingUpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=routing_update_time,json=routingUpdateTime,proto3" json:"routing_update_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	//
	// Nil if not current.
	CurrentSinceTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=current_since_time,json=currentSinceTime,proto3" json:"current_since_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: 'Since' captures the field semantics despite being a preposition. --)
	//
	// Nil if not ramping. Updated when the version first starts ramping, not on each ramp change.
	RampingSinceTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=ramping_since_time,json=rampingSinceTime,proto3" json:"ramping_since_time,omitempty"`
	// Range: [0, 100]. Must be zero if the version is not ramping (i.e. `ramping_since_time` is nil).
	// Can be in the range [0, 100] if the version is ramping.
	RampPercentage float32 `protobuf:"fixed32,6,opt,name=ramp_percentage,json=rampPercentage,proto3" json:"ramp_percentage,omitempty"`
	// 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 `` /* 139-byte string literal not displayed */
	// Key: Task Queue Name
	TaskQueueFamilies map[string]*VersionLocalState_TaskQueueFamilyData `` /* 189-byte string literal not displayed */
	// 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"`
	// contains filtered or unexported fields
}

Local state for Worker Deployment Version

func (*VersionLocalState) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use VersionLocalState.ProtoReflect.Descriptor instead.

func (*VersionLocalState) Equal added in v1.27.0 

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

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

func (*VersionLocalState) GetCreateTime added in v1.27.0 

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

func (*VersionLocalState) GetCurrentSinceTime added in v1.27.0 

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

func (*VersionLocalState) GetDrainageInfo added in v1.27.0 

func (x *VersionLocalState) GetDrainageInfo() *v11.VersionDrainageInfo

func (*VersionLocalState) GetFirstActivationTime added in v1.28.0 

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

func (*VersionLocalState) GetLastCurrentTime added in v1.30.0 

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

func (*VersionLocalState) GetLastDeactivationTime added in v1.28.0 

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

func (*VersionLocalState) GetMetadata added in v1.27.0 

func (x *VersionLocalState) GetMetadata() *v11.VersionMetadata

func (*VersionLocalState) GetRampPercentage added in v1.27.0 

func (x *VersionLocalState) GetRampPercentage() float32

func (*VersionLocalState) GetRampingSinceTime added in v1.27.0 

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

func (*VersionLocalState) GetRevisionNumber added in v1.30.0 

func (x *VersionLocalState) GetRevisionNumber() int64

func (*VersionLocalState) GetRoutingUpdateTime added in v1.27.0 

func (x *VersionLocalState) GetRoutingUpdateTime() *timestamppb.Timestamp

func (*VersionLocalState) GetStartedDeploymentWorkflow deprecated added in v1.27.0 

func (x *VersionLocalState) GetStartedDeploymentWorkflow() bool

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

func (*VersionLocalState) GetStatus added in v1.28.0 

func (x *VersionLocalState) GetStatus() v1.WorkerDeploymentVersionStatus

func (*VersionLocalState) GetSyncBatchSize added in v1.28.0 

func (x *VersionLocalState) GetSyncBatchSize() int32

func (*VersionLocalState) GetTaskQueueFamilies added in v1.27.0 

func (x *VersionLocalState) GetTaskQueueFamilies() map[string]*VersionLocalState_TaskQueueFamilyData

func (*VersionLocalState) GetVersion added in v1.27.0 

func (x *VersionLocalState) GetVersion() *WorkerDeploymentVersion

func (*VersionLocalState) Marshal added in v1.27.0 

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

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

func (*VersionLocalState) ProtoMessage added in v1.27.0 

func (*VersionLocalState) ProtoMessage()

func (*VersionLocalState) ProtoReflect added in v1.27.0 

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

func (*VersionLocalState) Reset added in v1.27.0 

func (x *VersionLocalState) Reset()

func (*VersionLocalState) Size added in v1.27.0 

func (val *VersionLocalState) Size() int

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

func (*VersionLocalState) String added in v1.27.0 

func (x *VersionLocalState) String() string

func (*VersionLocalState) Unmarshal added in v1.27.0 

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

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

type VersionLocalState_TaskQueueFamilyData added in v1.27.0 

type VersionLocalState_TaskQueueFamilyData struct {

	// Key: Task Queue Type
	TaskQueues map[int32]*TaskQueueVersionData `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VersionLocalState_TaskQueueFamilyData) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use VersionLocalState_TaskQueueFamilyData.ProtoReflect.Descriptor instead.

func (*VersionLocalState_TaskQueueFamilyData) GetTaskQueues added in v1.27.0 

func (x *VersionLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueVersionData

func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage added in v1.27.0 

func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage()

func (*VersionLocalState_TaskQueueFamilyData) ProtoReflect added in v1.27.0 

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

func (*VersionLocalState_TaskQueueFamilyData) Reset added in v1.27.0 

func (x *VersionLocalState_TaskQueueFamilyData) Reset()

func (*VersionLocalState_TaskQueueFamilyData) String added in v1.27.0 

func (x *VersionLocalState_TaskQueueFamilyData) String() string

type WorkerDeploymentLocalState added in v1.27.0 

type WorkerDeploymentLocalState struct {
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Encapsulates task routing information for this deployment.
	RoutingConfig        *v11.RoutingConfig                         `protobuf:"bytes,2,opt,name=routing_config,json=routingConfig,proto3" json:"routing_config,omitempty"`
	Versions             map[string]*WorkerDeploymentVersionSummary `` /* 143-byte string literal not displayed */
	ConflictToken        []byte                                     `protobuf:"bytes,4,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	LastModifierIdentity string                                     `protobuf:"bytes,5,opt,name=last_modifier_identity,json=lastModifierIdentity,proto3" json:"last_modifier_identity,omitempty"`
	// 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 `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

Local state for Worker Deployment

func (*WorkerDeploymentLocalState) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use WorkerDeploymentLocalState.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentLocalState) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentLocalState) GetConflictToken added in v1.27.0 

func (x *WorkerDeploymentLocalState) GetConflictToken() []byte

func (*WorkerDeploymentLocalState) GetCreateTime added in v1.27.0 

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

func (*WorkerDeploymentLocalState) GetLastModifierIdentity added in v1.27.0 

func (x *WorkerDeploymentLocalState) GetLastModifierIdentity() string

func (*WorkerDeploymentLocalState) GetManagerIdentity added in v1.29.0 

func (x *WorkerDeploymentLocalState) GetManagerIdentity() string

func (*WorkerDeploymentLocalState) GetPropagatingRevisions added in v1.30.0 

func (x *WorkerDeploymentLocalState) GetPropagatingRevisions() map[string]*PropagatingRevisions

func (*WorkerDeploymentLocalState) GetRoutingConfig added in v1.27.0 

func (x *WorkerDeploymentLocalState) GetRoutingConfig() *v11.RoutingConfig

func (*WorkerDeploymentLocalState) GetSyncBatchSize added in v1.28.0 

func (x *WorkerDeploymentLocalState) GetSyncBatchSize() int32

func (*WorkerDeploymentLocalState) GetVersions added in v1.27.0 

func (x *WorkerDeploymentLocalState) GetVersions() map[string]*WorkerDeploymentVersionSummary

func (*WorkerDeploymentLocalState) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentLocalState) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentLocalState) ProtoMessage()

func (*WorkerDeploymentLocalState) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentLocalState) Reset added in v1.27.0 

func (x *WorkerDeploymentLocalState) Reset()

func (*WorkerDeploymentLocalState) Size added in v1.27.0 

func (val *WorkerDeploymentLocalState) Size() int

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

func (*WorkerDeploymentLocalState) String added in v1.27.0 

func (x *WorkerDeploymentLocalState) String() string

func (*WorkerDeploymentLocalState) Unmarshal added in v1.27.0 

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

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

type WorkerDeploymentSummary added in v1.27.0 

type WorkerDeploymentSummary struct {
	Name                  string                                                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreateTime            *timestamppb.Timestamp                                   `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	RoutingConfig         *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 `` /* 126-byte string literal not displayed */
	RampingVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Subset of fields of WorkerDeploymentInfo returned in ListWorkerDeploymentsResponse

func (*WorkerDeploymentSummary) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use WorkerDeploymentSummary.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentSummary) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentSummary) GetCreateTime added in v1.27.0 

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

func (*WorkerDeploymentSummary) GetCurrentVersionSummary added in v1.28.0 

func (x *WorkerDeploymentSummary) GetCurrentVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary

func (*WorkerDeploymentSummary) GetLatestVersionSummary added in v1.28.0 

func (x *WorkerDeploymentSummary) GetLatestVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary

func (*WorkerDeploymentSummary) GetName added in v1.27.0 

func (x *WorkerDeploymentSummary) GetName() string

func (*WorkerDeploymentSummary) GetRampingVersionSummary added in v1.28.0 

func (x *WorkerDeploymentSummary) GetRampingVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary

func (*WorkerDeploymentSummary) GetRoutingConfig added in v1.27.0 

func (x *WorkerDeploymentSummary) GetRoutingConfig() *v11.RoutingConfig

func (*WorkerDeploymentSummary) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentSummary) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentSummary) ProtoMessage()

func (*WorkerDeploymentSummary) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentSummary) Reset added in v1.27.0 

func (x *WorkerDeploymentSummary) Reset()

func (*WorkerDeploymentSummary) Size added in v1.27.0 

func (val *WorkerDeploymentSummary) Size() int

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

func (*WorkerDeploymentSummary) String added in v1.27.0 

func (x *WorkerDeploymentSummary) String() string

func (*WorkerDeploymentSummary) Unmarshal added in v1.27.0 

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

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

type WorkerDeploymentVersion added in v1.27.0 

type WorkerDeploymentVersion struct {

	// The name of the Deployment this version belongs too.
	DeploymentName string `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	// Build ID uniquely identifies the Deployment Version within a Deployment, but the same Build
	// ID can be used in multiple Deployments.
	BuildId string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

Identifies a Worker Deployment Version. The combination of `deployment_name` and `build_id` serve as the identifier.

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

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

Deprecated: Use WorkerDeploymentVersion.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersion) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentVersion) GetBuildId added in v1.27.0 

func (x *WorkerDeploymentVersion) GetBuildId() string

func (*WorkerDeploymentVersion) GetDeploymentName added in v1.27.0 

func (x *WorkerDeploymentVersion) GetDeploymentName() string

func (*WorkerDeploymentVersion) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentVersion) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentVersion) ProtoMessage()

func (*WorkerDeploymentVersion) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentVersion) Reset added in v1.27.0 

func (x *WorkerDeploymentVersion) Reset()

func (*WorkerDeploymentVersion) Size added in v1.27.0 

func (val *WorkerDeploymentVersion) Size() int

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

func (*WorkerDeploymentVersion) String added in v1.27.0 

func (x *WorkerDeploymentVersion) String() string

func (*WorkerDeploymentVersion) Unmarshal added in v1.27.0 

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

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

type WorkerDeploymentVersionData added in v1.30.0 

type WorkerDeploymentVersionData struct {

	// 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.
	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"`
	// contains filtered or unexported fields
}

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.

func (*WorkerDeploymentVersionData) Descriptor deprecated added in v1.30.0 

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

Deprecated: Use WorkerDeploymentVersionData.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersionData) Equal added in v1.30.0 

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

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

func (*WorkerDeploymentVersionData) GetDeleted added in v1.30.0 

func (x *WorkerDeploymentVersionData) GetDeleted() bool

func (*WorkerDeploymentVersionData) GetRevisionNumber added in v1.30.0 

func (x *WorkerDeploymentVersionData) GetRevisionNumber() int64

func (*WorkerDeploymentVersionData) GetStatus added in v1.30.0 

func (x *WorkerDeploymentVersionData) GetStatus() v1.WorkerDeploymentVersionStatus

func (*WorkerDeploymentVersionData) GetUpdateTime added in v1.30.0 

func (x *WorkerDeploymentVersionData) GetUpdateTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionData) Marshal added in v1.30.0 

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

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

func (*WorkerDeploymentVersionData) ProtoMessage added in v1.30.0 

func (*WorkerDeploymentVersionData) ProtoMessage()

func (*WorkerDeploymentVersionData) ProtoReflect added in v1.30.0 

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

func (*WorkerDeploymentVersionData) Reset added in v1.30.0 

func (x *WorkerDeploymentVersionData) Reset()

func (*WorkerDeploymentVersionData) Size added in v1.30.0 

func (val *WorkerDeploymentVersionData) Size() int

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

func (*WorkerDeploymentVersionData) String added in v1.30.0 

func (x *WorkerDeploymentVersionData) String() string

func (*WorkerDeploymentVersionData) Unmarshal added in v1.30.0 

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

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

type WorkerDeploymentVersionSummary added in v1.27.0 

type WorkerDeploymentVersionSummary struct {
	Version    string                 `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Deprecated: Marked as deprecated in temporal/server/api/deployment/v1/message.proto.
	DrainageStatus v1.VersionDrainageStatus `` /* 153-byte string literal not displayed */
	// Information about workflow drainage to help the user determine when it is safe
	// to decommission a Version. Not present while version is current or ramping.
	DrainageInfo *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"`
	// contains filtered or unexported fields
}

func (*WorkerDeploymentVersionSummary) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use WorkerDeploymentVersionSummary.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersionSummary) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentVersionSummary) GetCreateTime added in v1.27.0 

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

func (*WorkerDeploymentVersionSummary) GetCurrentSinceTime added in v1.28.0 

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

func (*WorkerDeploymentVersionSummary) GetDrainageInfo added in v1.28.0 

func (x *WorkerDeploymentVersionSummary) GetDrainageInfo() *v11.VersionDrainageInfo

func (*WorkerDeploymentVersionSummary) GetDrainageStatus deprecated added in v1.27.0 

func (x *WorkerDeploymentVersionSummary) GetDrainageStatus() v1.VersionDrainageStatus

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

func (*WorkerDeploymentVersionSummary) GetFirstActivationTime added in v1.28.0 

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

func (*WorkerDeploymentVersionSummary) GetLastCurrentTime added in v1.30.0 

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

func (*WorkerDeploymentVersionSummary) GetLastDeactivationTime added in v1.28.0 

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

func (*WorkerDeploymentVersionSummary) GetRampingSinceTime added in v1.28.0 

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

func (*WorkerDeploymentVersionSummary) GetRoutingUpdateTime added in v1.28.0 

func (x *WorkerDeploymentVersionSummary) GetRoutingUpdateTime() *timestamppb.Timestamp

func (*WorkerDeploymentVersionSummary) GetStatus added in v1.28.0 

func (x *WorkerDeploymentVersionSummary) GetStatus() v1.WorkerDeploymentVersionStatus

func (*WorkerDeploymentVersionSummary) GetVersion added in v1.27.0 

func (x *WorkerDeploymentVersionSummary) GetVersion() string

func (*WorkerDeploymentVersionSummary) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentVersionSummary) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentVersionSummary) ProtoMessage()

func (*WorkerDeploymentVersionSummary) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentVersionSummary) Reset added in v1.27.0 

func (x *WorkerDeploymentVersionSummary) Reset()

func (*WorkerDeploymentVersionSummary) Size added in v1.27.0 

func (val *WorkerDeploymentVersionSummary) Size() int

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

func (*WorkerDeploymentVersionSummary) String added in v1.27.0 

func (x *WorkerDeploymentVersionSummary) String() string

func (*WorkerDeploymentVersionSummary) Unmarshal added in v1.27.0 

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

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

type WorkerDeploymentVersionWorkflowArgs added in v1.27.0 

type WorkerDeploymentVersionWorkflowArgs struct {
	NamespaceName string             `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	NamespaceId   string             `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	VersionState  *VersionLocalState `protobuf:"bytes,3,opt,name=version_state,json=versionState,proto3" json:"version_state,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment Version workflow input:

func (*WorkerDeploymentVersionWorkflowArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use WorkerDeploymentVersionWorkflowArgs.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentVersionWorkflowArgs) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentVersionWorkflowArgs) GetNamespaceId added in v1.27.0 

func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceId() string

func (*WorkerDeploymentVersionWorkflowArgs) GetNamespaceName added in v1.27.0 

func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceName() string

func (*WorkerDeploymentVersionWorkflowArgs) GetVersionState added in v1.27.0 

func (x *WorkerDeploymentVersionWorkflowArgs) GetVersionState() *VersionLocalState

func (*WorkerDeploymentVersionWorkflowArgs) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage()

func (*WorkerDeploymentVersionWorkflowArgs) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentVersionWorkflowArgs) Reset added in v1.27.0 

func (x *WorkerDeploymentVersionWorkflowArgs) Reset()

func (*WorkerDeploymentVersionWorkflowArgs) Size added in v1.27.0 

func (val *WorkerDeploymentVersionWorkflowArgs) Size() int

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

func (*WorkerDeploymentVersionWorkflowArgs) String added in v1.27.0 

func (x *WorkerDeploymentVersionWorkflowArgs) String() string

func (*WorkerDeploymentVersionWorkflowArgs) Unmarshal added in v1.27.0 

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

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

type WorkerDeploymentWorkflowArgs added in v1.27.0 

type WorkerDeploymentWorkflowArgs struct {
	NamespaceName  string                      `protobuf:"bytes,1,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	NamespaceId    string                      `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	DeploymentName string                      `protobuf:"bytes,3,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	State          *WorkerDeploymentLocalState `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

used as Worker Deployment workflow input:

func (*WorkerDeploymentWorkflowArgs) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use WorkerDeploymentWorkflowArgs.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentWorkflowArgs) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentWorkflowArgs) GetDeploymentName added in v1.27.0 

func (x *WorkerDeploymentWorkflowArgs) GetDeploymentName() string

func (*WorkerDeploymentWorkflowArgs) GetNamespaceId added in v1.27.0 

func (x *WorkerDeploymentWorkflowArgs) GetNamespaceId() string

func (*WorkerDeploymentWorkflowArgs) GetNamespaceName added in v1.27.0 

func (x *WorkerDeploymentWorkflowArgs) GetNamespaceName() string

func (*WorkerDeploymentWorkflowArgs) GetState added in v1.27.0 

func (x *WorkerDeploymentWorkflowArgs) GetState() *WorkerDeploymentLocalState

func (*WorkerDeploymentWorkflowArgs) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentWorkflowArgs) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentWorkflowArgs) ProtoMessage()

func (*WorkerDeploymentWorkflowArgs) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentWorkflowArgs) Reset added in v1.27.0 

func (x *WorkerDeploymentWorkflowArgs) Reset()

func (*WorkerDeploymentWorkflowArgs) Size added in v1.27.0 

func (val *WorkerDeploymentWorkflowArgs) Size() int

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

func (*WorkerDeploymentWorkflowArgs) String added in v1.27.0 

func (x *WorkerDeploymentWorkflowArgs) String() string

func (*WorkerDeploymentWorkflowArgs) Unmarshal added in v1.27.0 

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

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

type WorkerDeploymentWorkflowMemo added in v1.27.0 

type WorkerDeploymentWorkflowMemo struct {
	DeploymentName        string                                                   `protobuf:"bytes,1,opt,name=deployment_name,json=deploymentName,proto3" json:"deployment_name,omitempty"`
	CreateTime            *timestamppb.Timestamp                                   `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	RoutingConfig         *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 `` /* 126-byte string literal not displayed */
	RampingVersionSummary *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

used as Worker Deployment workflow memo:

func (*WorkerDeploymentWorkflowMemo) Descriptor deprecated added in v1.27.0 

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

Deprecated: Use WorkerDeploymentWorkflowMemo.ProtoReflect.Descriptor instead.

func (*WorkerDeploymentWorkflowMemo) Equal added in v1.27.0 

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

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

func (*WorkerDeploymentWorkflowMemo) GetCreateTime added in v1.27.0 

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

func (*WorkerDeploymentWorkflowMemo) GetCurrentVersionSummary added in v1.28.0 

func (x *WorkerDeploymentWorkflowMemo) GetCurrentVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary

func (*WorkerDeploymentWorkflowMemo) GetDeploymentName added in v1.27.0 

func (x *WorkerDeploymentWorkflowMemo) GetDeploymentName() string

func (*WorkerDeploymentWorkflowMemo) GetLatestVersionSummary added in v1.28.0 

func (x *WorkerDeploymentWorkflowMemo) GetLatestVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary

func (*WorkerDeploymentWorkflowMemo) GetRampingVersionSummary added in v1.28.0 

func (x *WorkerDeploymentWorkflowMemo) GetRampingVersionSummary() *v11.WorkerDeploymentInfo_WorkerDeploymentVersionSummary

func (*WorkerDeploymentWorkflowMemo) GetRoutingConfig added in v1.27.0 

func (x *WorkerDeploymentWorkflowMemo) GetRoutingConfig() *v11.RoutingConfig

func (*WorkerDeploymentWorkflowMemo) Marshal added in v1.27.0 

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

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

func (*WorkerDeploymentWorkflowMemo) ProtoMessage added in v1.27.0 

func (*WorkerDeploymentWorkflowMemo) ProtoMessage()

func (*WorkerDeploymentWorkflowMemo) ProtoReflect added in v1.27.0 

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

func (*WorkerDeploymentWorkflowMemo) Reset added in v1.27.0 

func (x *WorkerDeploymentWorkflowMemo) Reset()

func (*WorkerDeploymentWorkflowMemo) Size added in v1.27.0 

func (val *WorkerDeploymentWorkflowMemo) Size() int

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

func (*WorkerDeploymentWorkflowMemo) String added in v1.27.0 

func (x *WorkerDeploymentWorkflowMemo) String() string

func (*WorkerDeploymentWorkflowMemo) Unmarshal added in v1.27.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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