Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

deployment

package

Go to main page

Versions in this module

v1

v1.28.0-129.0

Mar 7, 2025

v1.27.1

Feb 26, 2025

v1.27.0

Feb 21, 2025

Changes in this version

+ type AddVersionToWorkerDeploymentRequest struct

+ DeploymentName string

+ RequestId string

+ UpdateArgs *AddVersionUpdateArgs

+ func (*AddVersionToWorkerDeploymentRequest) Descriptor() ([]byte, []int)

+ func (*AddVersionToWorkerDeploymentRequest) ProtoMessage()

+ func (this *AddVersionToWorkerDeploymentRequest) Equal(that interface{}) bool

+ func (val *AddVersionToWorkerDeploymentRequest) Marshal() ([]byte, error)

+ func (val *AddVersionToWorkerDeploymentRequest) Size() int

+ func (val *AddVersionToWorkerDeploymentRequest) Unmarshal(buf []byte) error

+ func (x *AddVersionToWorkerDeploymentRequest) GetDeploymentName() string

+ func (x *AddVersionToWorkerDeploymentRequest) GetRequestId() string

+ func (x *AddVersionToWorkerDeploymentRequest) GetUpdateArgs() *AddVersionUpdateArgs

+ func (x *AddVersionToWorkerDeploymentRequest) ProtoReflect() protoreflect.Message

+ func (x *AddVersionToWorkerDeploymentRequest) Reset()

+ func (x *AddVersionToWorkerDeploymentRequest) String() string

+ type AddVersionToWorkerDeploymentResponse struct

+ func (*AddVersionToWorkerDeploymentResponse) Descriptor() ([]byte, []int)

+ func (*AddVersionToWorkerDeploymentResponse) ProtoMessage()

+ func (this *AddVersionToWorkerDeploymentResponse) Equal(that interface{}) bool

+ func (val *AddVersionToWorkerDeploymentResponse) Marshal() ([]byte, error)

+ func (val *AddVersionToWorkerDeploymentResponse) Size() int

+ func (val *AddVersionToWorkerDeploymentResponse) Unmarshal(buf []byte) error

+ func (x *AddVersionToWorkerDeploymentResponse) ProtoReflect() protoreflect.Message

+ func (x *AddVersionToWorkerDeploymentResponse) Reset()

+ func (x *AddVersionToWorkerDeploymentResponse) String() string

+ type AddVersionUpdateArgs struct

+ CreateTime *timestamppb.Timestamp

+ Version string

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

+ func (*AddVersionUpdateArgs) ProtoMessage()

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

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

+ func (val *AddVersionUpdateArgs) Size() int

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

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

+ func (x *AddVersionUpdateArgs) GetVersion() string

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

+ func (x *AddVersionUpdateArgs) Reset()

+ func (x *AddVersionUpdateArgs) String() string

+ type CheckTaskQueuesHavePollersActivityArgs struct

+ TaskQueuesAndTypes map[string]*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes

+ WorkerDeploymentVersion *WorkerDeploymentVersion

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

+ func (*CheckTaskQueuesHavePollersActivityArgs) ProtoMessage()

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

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

+ func (val *CheckTaskQueuesHavePollersActivityArgs) Size() int

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

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

+ func (x *CheckTaskQueuesHavePollersActivityArgs) GetWorkerDeploymentVersion() *WorkerDeploymentVersion

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

+ func (x *CheckTaskQueuesHavePollersActivityArgs) Reset()

+ func (x *CheckTaskQueuesHavePollersActivityArgs) String() string

+ type CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes struct

+ Types []v11.TaskQueueType

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

+ func (*CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) ProtoMessage()

+ func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) GetTypes() []v11.TaskQueueType

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

+ func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) Reset()

+ func (x *CheckTaskQueuesHavePollersActivityArgs_TaskQueueTypes) String() string

+ type CheckUserDataPropagationRequest struct

+ TaskQueueMaxVersions map[string]int64

+ func (*CheckUserDataPropagationRequest) Descriptor() ([]byte, []int)

+ func (*CheckUserDataPropagationRequest) ProtoMessage()

+ func (this *CheckUserDataPropagationRequest) Equal(that interface{}) bool

+ func (val *CheckUserDataPropagationRequest) Marshal() ([]byte, error)

+ func (val *CheckUserDataPropagationRequest) Size() int

+ func (val *CheckUserDataPropagationRequest) Unmarshal(buf []byte) error

+ func (x *CheckUserDataPropagationRequest) GetTaskQueueMaxVersions() map[string]int64

+ func (x *CheckUserDataPropagationRequest) ProtoReflect() protoreflect.Message

+ func (x *CheckUserDataPropagationRequest) Reset()

+ func (x *CheckUserDataPropagationRequest) String() string

+ type CheckWorkerDeploymentUserDataPropagationRequest struct

+ TaskQueueMaxVersions map[string]int64

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

+ func (*CheckWorkerDeploymentUserDataPropagationRequest) ProtoMessage()

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

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

+ func (val *CheckWorkerDeploymentUserDataPropagationRequest) Size() int

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

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

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

+ func (x *CheckWorkerDeploymentUserDataPropagationRequest) Reset()

+ func (x *CheckWorkerDeploymentUserDataPropagationRequest) String() string

+ type DeleteDeploymentArgs struct

+ Identity string

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

+ func (*DeleteDeploymentArgs) ProtoMessage()

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

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

+ func (val *DeleteDeploymentArgs) Size() int

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

+ func (x *DeleteDeploymentArgs) GetIdentity() string

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

+ func (x *DeleteDeploymentArgs) Reset()

+ func (x *DeleteDeploymentArgs) String() string

+ type DeleteVersionActivityArgs struct

+ DeploymentName string

+ Identity string

+ RequestId string

+ SkipDrainage bool

+ Version string

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

+ func (*DeleteVersionActivityArgs) ProtoMessage()

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

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

+ func (val *DeleteVersionActivityArgs) Size() int

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

+ func (x *DeleteVersionActivityArgs) GetDeploymentName() string

+ func (x *DeleteVersionActivityArgs) GetIdentity() string

+ func (x *DeleteVersionActivityArgs) GetRequestId() string

+ func (x *DeleteVersionActivityArgs) GetSkipDrainage() bool

+ func (x *DeleteVersionActivityArgs) GetVersion() string

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

+ func (x *DeleteVersionActivityArgs) Reset()

+ func (x *DeleteVersionActivityArgs) String() string

+ type DeleteVersionArgs struct

+ Identity string

+ SkipDrainage bool

+ Version string

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

+ func (*DeleteVersionArgs) ProtoMessage()

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

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

+ func (val *DeleteVersionArgs) Size() int

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

+ func (x *DeleteVersionArgs) GetIdentity() string

+ func (x *DeleteVersionArgs) GetSkipDrainage() bool

+ func (x *DeleteVersionArgs) GetVersion() string

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

+ func (x *DeleteVersionArgs) Reset()

+ func (x *DeleteVersionArgs) String() string

+ type DeploymentVersionData struct

+ CurrentSinceTime *timestamppb.Timestamp

+ RampPercentage float32

+ RampingSinceTime *timestamppb.Timestamp

+ RoutingUpdateTime *timestamppb.Timestamp

+ Version *WorkerDeploymentVersion

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

+ func (*DeploymentVersionData) ProtoMessage()

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

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

+ func (val *DeploymentVersionData) Size() int

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

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

+ func (x *DeploymentVersionData) GetRampPercentage() float32

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

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

+ func (x *DeploymentVersionData) GetVersion() *WorkerDeploymentVersion

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

+ func (x *DeploymentVersionData) Reset()

+ func (x *DeploymentVersionData) String() string

+ type DrainageWorkflowArgs struct

+ IsCan bool

+ NamespaceName string

+ Version *WorkerDeploymentVersion

+ func (*DrainageWorkflowArgs) Descriptor() ([]byte, []int)

+ func (*DrainageWorkflowArgs) ProtoMessage()

+ func (this *DrainageWorkflowArgs) Equal(that interface{}) bool

+ func (val *DrainageWorkflowArgs) Marshal() ([]byte, error)

+ func (val *DrainageWorkflowArgs) Size() int

+ func (val *DrainageWorkflowArgs) Unmarshal(buf []byte) error

+ func (x *DrainageWorkflowArgs) GetIsCan() bool

+ func (x *DrainageWorkflowArgs) GetNamespaceName() string

+ func (x *DrainageWorkflowArgs) GetVersion() *WorkerDeploymentVersion

+ func (x *DrainageWorkflowArgs) ProtoReflect() protoreflect.Message

+ func (x *DrainageWorkflowArgs) Reset()

+ func (x *DrainageWorkflowArgs) String() string

+ type IsVersionMissingTaskQueuesArgs struct

+ NewCurrentVersion string

+ PrevCurrentVersion string

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

+ func (*IsVersionMissingTaskQueuesArgs) ProtoMessage()

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

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

+ func (val *IsVersionMissingTaskQueuesArgs) Size() int

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

+ func (x *IsVersionMissingTaskQueuesArgs) GetNewCurrentVersion() string

+ func (x *IsVersionMissingTaskQueuesArgs) GetPrevCurrentVersion() string

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

+ func (x *IsVersionMissingTaskQueuesArgs) Reset()

+ func (x *IsVersionMissingTaskQueuesArgs) String() string

+ type IsVersionMissingTaskQueuesResult struct

+ IsMissingTaskQueues bool

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

+ func (*IsVersionMissingTaskQueuesResult) ProtoMessage()

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

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

+ func (val *IsVersionMissingTaskQueuesResult) Size() int

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

+ func (x *IsVersionMissingTaskQueuesResult) GetIsMissingTaskQueues() bool

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

+ func (x *IsVersionMissingTaskQueuesResult) Reset()

+ func (x *IsVersionMissingTaskQueuesResult) String() string

+ type QueryDescribeVersionResponse struct

+ VersionState *VersionLocalState

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

+ func (*QueryDescribeVersionResponse) ProtoMessage()

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

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

+ func (val *QueryDescribeVersionResponse) Size() int

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

+ func (x *QueryDescribeVersionResponse) GetVersionState() *VersionLocalState

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

+ func (x *QueryDescribeVersionResponse) Reset()

+ func (x *QueryDescribeVersionResponse) String() string

+ type QueryDescribeWorkerDeploymentResponse struct

+ State *WorkerDeploymentLocalState

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

+ func (*QueryDescribeWorkerDeploymentResponse) ProtoMessage()

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

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

+ func (val *QueryDescribeWorkerDeploymentResponse) Size() int

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

+ func (x *QueryDescribeWorkerDeploymentResponse) GetState() *WorkerDeploymentLocalState

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

+ func (x *QueryDescribeWorkerDeploymentResponse) Reset()

+ func (x *QueryDescribeWorkerDeploymentResponse) String() string

+ type RegisterWorkerInVersionArgs struct

+ MaxTaskQueues int32

+ TaskQueueName string

+ TaskQueueType v11.TaskQueueType

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

+ func (*RegisterWorkerInVersionArgs) ProtoMessage()

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

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

+ func (val *RegisterWorkerInVersionArgs) Size() int

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

+ func (x *RegisterWorkerInVersionArgs) GetMaxTaskQueues() int32

+ func (x *RegisterWorkerInVersionArgs) GetTaskQueueName() string

+ func (x *RegisterWorkerInVersionArgs) GetTaskQueueType() v11.TaskQueueType

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

+ func (x *RegisterWorkerInVersionArgs) Reset()

+ func (x *RegisterWorkerInVersionArgs) String() string

+ type SetCurrentVersionArgs struct

+ ConflictToken []byte

+ Identity string

+ IgnoreMissingTaskQueues bool

+ Version string

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

+ func (*SetCurrentVersionArgs) ProtoMessage()

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

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

+ func (val *SetCurrentVersionArgs) Size() int

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

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

+ func (x *SetCurrentVersionArgs) GetIdentity() string

+ func (x *SetCurrentVersionArgs) GetIgnoreMissingTaskQueues() bool

+ func (x *SetCurrentVersionArgs) GetVersion() string

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

+ func (x *SetCurrentVersionArgs) Reset()

+ func (x *SetCurrentVersionArgs) String() string

+ type SetCurrentVersionResponse struct

+ ConflictToken []byte

+ PreviousVersion string

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

+ func (*SetCurrentVersionResponse) ProtoMessage()

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

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

+ func (val *SetCurrentVersionResponse) Size() int

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

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

+ func (x *SetCurrentVersionResponse) GetPreviousVersion() string

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

+ func (x *SetCurrentVersionResponse) Reset()

+ func (x *SetCurrentVersionResponse) String() string

+ type SetRampingVersionArgs struct

+ ConflictToken []byte

+ Identity string

+ IgnoreMissingTaskQueues bool

+ Percentage float32

+ Version string

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

+ func (*SetRampingVersionArgs) ProtoMessage()

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

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

+ func (val *SetRampingVersionArgs) Size() int

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

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

+ func (x *SetRampingVersionArgs) GetIdentity() string

+ func (x *SetRampingVersionArgs) GetIgnoreMissingTaskQueues() bool

+ func (x *SetRampingVersionArgs) GetPercentage() float32

+ func (x *SetRampingVersionArgs) GetVersion() string

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

+ func (x *SetRampingVersionArgs) Reset()

+ func (x *SetRampingVersionArgs) String() string

+ type SetRampingVersionResponse struct

+ ConflictToken []byte

+ PreviousPercentage float32

+ PreviousVersion string

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

+ func (*SetRampingVersionResponse) ProtoMessage()

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

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

+ func (val *SetRampingVersionResponse) Size() int

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

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

+ func (x *SetRampingVersionResponse) GetPreviousPercentage() float32

+ func (x *SetRampingVersionResponse) GetPreviousVersion() string

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

+ func (x *SetRampingVersionResponse) Reset()

+ func (x *SetRampingVersionResponse) String() string

+ type StartWorkerDeploymentRequest struct

+ DeploymentName string

+ RequestId string

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

+ func (*StartWorkerDeploymentRequest) ProtoMessage()

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

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

+ func (val *StartWorkerDeploymentRequest) Size() int

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

+ func (x *StartWorkerDeploymentRequest) GetDeploymentName() string

+ func (x *StartWorkerDeploymentRequest) GetRequestId() string

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

+ func (x *StartWorkerDeploymentRequest) Reset()

+ func (x *StartWorkerDeploymentRequest) String() string

+ type SyncDeploymentVersionUserDataRequest struct

+ ForgetVersion bool

+ Sync []*SyncDeploymentVersionUserDataRequest_SyncUserData

+ Version *WorkerDeploymentVersion

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

+ func (*SyncDeploymentVersionUserDataRequest) ProtoMessage()

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

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

+ func (val *SyncDeploymentVersionUserDataRequest) Size() int

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

+ func (x *SyncDeploymentVersionUserDataRequest) GetForgetVersion() bool

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

+ func (x *SyncDeploymentVersionUserDataRequest) GetVersion() *WorkerDeploymentVersion

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

+ func (x *SyncDeploymentVersionUserDataRequest) Reset()

+ func (x *SyncDeploymentVersionUserDataRequest) String() string

+ type SyncDeploymentVersionUserDataRequest_SyncUserData struct

+ Data *DeploymentVersionData

+ Name string

+ Types []v11.TaskQueueType

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

+ func (*SyncDeploymentVersionUserDataRequest_SyncUserData) ProtoMessage()

+ func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetData() *DeploymentVersionData

+ func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetName() string

+ func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) GetTypes() []v11.TaskQueueType

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

+ func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) Reset()

+ func (x *SyncDeploymentVersionUserDataRequest_SyncUserData) String() string

+ type SyncDeploymentVersionUserDataResponse struct

+ TaskQueueMaxVersions map[string]int64

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

+ func (*SyncDeploymentVersionUserDataResponse) ProtoMessage()

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

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

+ func (val *SyncDeploymentVersionUserDataResponse) Size() int

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

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

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

+ func (x *SyncDeploymentVersionUserDataResponse) Reset()

+ func (x *SyncDeploymentVersionUserDataResponse) String() string

+ type SyncDrainageInfoSignalArgs struct

+ DrainageInfo *v1.VersionDrainageInfo

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

+ func (*SyncDrainageInfoSignalArgs) ProtoMessage()

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

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

+ func (val *SyncDrainageInfoSignalArgs) Size() int

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

+ func (x *SyncDrainageInfoSignalArgs) GetDrainageInfo() *v1.VersionDrainageInfo

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

+ func (x *SyncDrainageInfoSignalArgs) Reset()

+ func (x *SyncDrainageInfoSignalArgs) String() string

+ type SyncDrainageStatusSignalArgs struct

+ DrainageStatus v11.VersionDrainageStatus

+ Version string

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

+ func (*SyncDrainageStatusSignalArgs) ProtoMessage()

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

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

+ func (val *SyncDrainageStatusSignalArgs) Size() int

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

+ func (x *SyncDrainageStatusSignalArgs) GetDrainageStatus() v11.VersionDrainageStatus

+ func (x *SyncDrainageStatusSignalArgs) GetVersion() string

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

+ func (x *SyncDrainageStatusSignalArgs) Reset()

+ func (x *SyncDrainageStatusSignalArgs) String() string

+ type SyncUnversionedRampActivityArgs struct

+ CurrentVersion string

+ UpdateArgs *SyncVersionStateUpdateArgs

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

+ func (*SyncUnversionedRampActivityArgs) ProtoMessage()

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

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

+ func (val *SyncUnversionedRampActivityArgs) Size() int

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

+ func (x *SyncUnversionedRampActivityArgs) GetCurrentVersion() string

+ func (x *SyncUnversionedRampActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs

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

+ func (x *SyncUnversionedRampActivityArgs) Reset()

+ func (x *SyncUnversionedRampActivityArgs) String() string

+ type SyncUnversionedRampActivityResponse struct

+ TaskQueueMaxVersions map[string]int64

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

+ func (*SyncUnversionedRampActivityResponse) ProtoMessage()

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

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

+ func (val *SyncUnversionedRampActivityResponse) Size() int

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

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

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

+ func (x *SyncUnversionedRampActivityResponse) Reset()

+ func (x *SyncUnversionedRampActivityResponse) String() string

+ type SyncUserDataResponse struct

+ TaskQueueMaxVersions map[string]int64

+ func (*SyncUserDataResponse) Descriptor() ([]byte, []int)

+ func (*SyncUserDataResponse) ProtoMessage()

+ func (this *SyncUserDataResponse) Equal(that interface{}) bool

+ func (val *SyncUserDataResponse) Marshal() ([]byte, error)

+ func (val *SyncUserDataResponse) Size() int

+ func (val *SyncUserDataResponse) Unmarshal(buf []byte) error

+ func (x *SyncUserDataResponse) GetTaskQueueMaxVersions() map[string]int64

+ func (x *SyncUserDataResponse) ProtoReflect() protoreflect.Message

+ func (x *SyncUserDataResponse) Reset()

+ func (x *SyncUserDataResponse) String() string

+ type SyncVersionStateActivityArgs struct

+ DeploymentName string

+ RequestId string

+ UpdateArgs *SyncVersionStateUpdateArgs

+ Version string

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

+ func (*SyncVersionStateActivityArgs) ProtoMessage()

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

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

+ func (val *SyncVersionStateActivityArgs) Size() int

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

+ func (x *SyncVersionStateActivityArgs) GetDeploymentName() string

+ func (x *SyncVersionStateActivityArgs) GetRequestId() string

+ func (x *SyncVersionStateActivityArgs) GetUpdateArgs() *SyncVersionStateUpdateArgs

+ func (x *SyncVersionStateActivityArgs) GetVersion() string

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

+ func (x *SyncVersionStateActivityArgs) Reset()

+ func (x *SyncVersionStateActivityArgs) String() string

+ type SyncVersionStateActivityResult struct

+ VersionState *VersionLocalState

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

+ func (*SyncVersionStateActivityResult) ProtoMessage()

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

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

+ func (val *SyncVersionStateActivityResult) Size() int

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

+ func (x *SyncVersionStateActivityResult) GetVersionState() *VersionLocalState

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

+ func (x *SyncVersionStateActivityResult) Reset()

+ func (x *SyncVersionStateActivityResult) String() string

+ type SyncVersionStateResponse struct

+ VersionState *VersionLocalState

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

+ func (*SyncVersionStateResponse) ProtoMessage()

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

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

+ func (val *SyncVersionStateResponse) Size() int

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

+ func (x *SyncVersionStateResponse) GetVersionState() *VersionLocalState

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

+ func (x *SyncVersionStateResponse) Reset()

+ func (x *SyncVersionStateResponse) String() string

+ type SyncVersionStateUpdateArgs struct

+ CurrentSinceTime *timestamppb.Timestamp

+ RampPercentage float32

+ RampingSinceTime *timestamppb.Timestamp

+ RoutingUpdateTime *timestamppb.Timestamp

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

+ func (*SyncVersionStateUpdateArgs) ProtoMessage()

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

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

+ func (val *SyncVersionStateUpdateArgs) Size() int

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

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

+ func (x *SyncVersionStateUpdateArgs) GetRampPercentage() float32

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

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

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

+ func (x *SyncVersionStateUpdateArgs) Reset()

+ func (x *SyncVersionStateUpdateArgs) String() string

+ type TaskQueueVersionData struct

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

+ func (*TaskQueueVersionData) ProtoMessage()

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

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

+ func (val *TaskQueueVersionData) Size() int

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

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

+ func (x *TaskQueueVersionData) Reset()

+ func (x *TaskQueueVersionData) String() string

+ type UpdateVersionMetadataArgs struct

+ Identity string

+ RemoveEntries []string

+ UpsertEntries map[string]*v12.Payload

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

+ func (*UpdateVersionMetadataArgs) ProtoMessage()

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

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

+ func (val *UpdateVersionMetadataArgs) Size() int

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

+ func (x *UpdateVersionMetadataArgs) GetIdentity() string

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

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

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

+ func (x *UpdateVersionMetadataArgs) Reset()

+ func (x *UpdateVersionMetadataArgs) String() string

+ type UpdateVersionMetadataResponse struct

+ Metadata *v1.VersionMetadata

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

+ func (*UpdateVersionMetadataResponse) ProtoMessage()

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

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

+ func (val *UpdateVersionMetadataResponse) Size() int

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

+ func (x *UpdateVersionMetadataResponse) GetMetadata() *v1.VersionMetadata

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

+ func (x *UpdateVersionMetadataResponse) Reset()

+ func (x *UpdateVersionMetadataResponse) String() string

+ type VersionLocalState struct

+ CreateTime *timestamppb.Timestamp

+ CurrentSinceTime *timestamppb.Timestamp

+ DrainageInfo *v1.VersionDrainageInfo

+ Metadata *v1.VersionMetadata

+ RampPercentage float32

+ RampingSinceTime *timestamppb.Timestamp

+ RoutingUpdateTime *timestamppb.Timestamp

+ StartedDeploymentWorkflow bool

+ TaskQueueFamilies map[string]*VersionLocalState_TaskQueueFamilyData

+ Version *WorkerDeploymentVersion

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

+ func (*VersionLocalState) ProtoMessage()

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

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

+ func (val *VersionLocalState) Size() int

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

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

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

+ func (x *VersionLocalState) GetDrainageInfo() *v1.VersionDrainageInfo

+ func (x *VersionLocalState) GetMetadata() *v1.VersionMetadata

+ func (x *VersionLocalState) GetRampPercentage() float32

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

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

+ func (x *VersionLocalState) GetStartedDeploymentWorkflow() bool

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

+ func (x *VersionLocalState) GetVersion() *WorkerDeploymentVersion

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

+ func (x *VersionLocalState) Reset()

+ func (x *VersionLocalState) String() string

+ type VersionLocalState_TaskQueueFamilyData struct

+ TaskQueues map[int32]*TaskQueueVersionData

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

+ func (*VersionLocalState_TaskQueueFamilyData) ProtoMessage()

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

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

+ func (x *VersionLocalState_TaskQueueFamilyData) Reset()

+ func (x *VersionLocalState_TaskQueueFamilyData) String() string

+ type WorkerDeploymentLocalState struct

+ ConflictToken []byte

+ CreateTime *timestamppb.Timestamp

+ LastModifierIdentity string

+ RoutingConfig *v1.RoutingConfig

+ Versions map[string]*WorkerDeploymentVersionSummary

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

+ func (*WorkerDeploymentLocalState) ProtoMessage()

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

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

+ func (val *WorkerDeploymentLocalState) Size() int

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

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

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

+ func (x *WorkerDeploymentLocalState) GetLastModifierIdentity() string

+ func (x *WorkerDeploymentLocalState) GetRoutingConfig() *v1.RoutingConfig

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

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

+ func (x *WorkerDeploymentLocalState) Reset()

+ func (x *WorkerDeploymentLocalState) String() string

+ type WorkerDeploymentSummary struct

+ CreateTime *timestamppb.Timestamp

+ Name string

+ RoutingConfig *v1.RoutingConfig

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

+ func (*WorkerDeploymentSummary) ProtoMessage()

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

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

+ func (val *WorkerDeploymentSummary) Size() int

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

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

+ func (x *WorkerDeploymentSummary) GetName() string

+ func (x *WorkerDeploymentSummary) GetRoutingConfig() *v1.RoutingConfig

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

+ func (x *WorkerDeploymentSummary) Reset()

+ func (x *WorkerDeploymentSummary) String() string

+ type WorkerDeploymentVersion struct

+ BuildId string

+ DeploymentName string

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

+ func (*WorkerDeploymentVersion) ProtoMessage()

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

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

+ func (val *WorkerDeploymentVersion) Size() int

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

+ func (x *WorkerDeploymentVersion) GetBuildId() string

+ func (x *WorkerDeploymentVersion) GetDeploymentName() string

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

+ func (x *WorkerDeploymentVersion) Reset()

+ func (x *WorkerDeploymentVersion) String() string

+ type WorkerDeploymentVersionSummary struct

+ CreateTime *timestamppb.Timestamp

+ DrainageStatus v11.VersionDrainageStatus

+ Version string

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

+ func (*WorkerDeploymentVersionSummary) ProtoMessage()

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

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

+ func (val *WorkerDeploymentVersionSummary) Size() int

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

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

+ func (x *WorkerDeploymentVersionSummary) GetDrainageStatus() v11.VersionDrainageStatus

+ func (x *WorkerDeploymentVersionSummary) GetVersion() string

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

+ func (x *WorkerDeploymentVersionSummary) Reset()

+ func (x *WorkerDeploymentVersionSummary) String() string

+ type WorkerDeploymentVersionWorkflowArgs struct

+ NamespaceId string

+ NamespaceName string

+ VersionState *VersionLocalState

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

+ func (*WorkerDeploymentVersionWorkflowArgs) ProtoMessage()

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

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

+ func (val *WorkerDeploymentVersionWorkflowArgs) Size() int

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

+ func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceId() string

+ func (x *WorkerDeploymentVersionWorkflowArgs) GetNamespaceName() string

+ func (x *WorkerDeploymentVersionWorkflowArgs) GetVersionState() *VersionLocalState

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

+ func (x *WorkerDeploymentVersionWorkflowArgs) Reset()

+ func (x *WorkerDeploymentVersionWorkflowArgs) String() string

+ type WorkerDeploymentWorkflowArgs struct

+ DeploymentName string

+ NamespaceId string

+ NamespaceName string

+ State *WorkerDeploymentLocalState

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

+ func (*WorkerDeploymentWorkflowArgs) ProtoMessage()

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

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

+ func (val *WorkerDeploymentWorkflowArgs) Size() int

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

+ func (x *WorkerDeploymentWorkflowArgs) GetDeploymentName() string

+ func (x *WorkerDeploymentWorkflowArgs) GetNamespaceId() string

+ func (x *WorkerDeploymentWorkflowArgs) GetNamespaceName() string

+ func (x *WorkerDeploymentWorkflowArgs) GetState() *WorkerDeploymentLocalState

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

+ func (x *WorkerDeploymentWorkflowArgs) Reset()

+ func (x *WorkerDeploymentWorkflowArgs) String() string

+ type WorkerDeploymentWorkflowMemo struct

+ CreateTime *timestamppb.Timestamp

+ DeploymentName string

+ RoutingConfig *v1.RoutingConfig

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

+ func (*WorkerDeploymentWorkflowMemo) ProtoMessage()

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

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

+ func (val *WorkerDeploymentWorkflowMemo) Size() int

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

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

+ func (x *WorkerDeploymentWorkflowMemo) GetDeploymentName() string

+ func (x *WorkerDeploymentWorkflowMemo) GetRoutingConfig() *v1.RoutingConfig

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

+ func (x *WorkerDeploymentWorkflowMemo) Reset()

+ func (x *WorkerDeploymentWorkflowMemo) String() string

v1.27.0-rc.0

Feb 21, 2025

v1.27.0-128.6

Feb 26, 2025

v1.27.0-128.5

Feb 20, 2025

v1.27.0-128.4

Feb 14, 2025

v1.27.0-128.3

Feb 12, 2025

v1.27.0-128.2

Feb 11, 2025

v1.27.0-128.1

Feb 10, 2025

v1.27.0-128.0

Feb 7, 2025

v1.27.0-127.2

Jan 29, 2025

v1.27.0-127.1

Jan 17, 2025

v1.27.0-127.0

Jan 17, 2025

v1.27.0-126.3

Jan 16, 2025

v1.27.0-126.2

Jan 11, 2025

v1.27.0-126.1

Jan 10, 2025

v1.27.0-126.0

Jan 7, 2025

v1.26.2

Dec 23, 2024

Changes in this version

+ var File_temporal_server_api_deployment_v1_message_proto protoreflect.FileDescriptor

+ type DeploymentLocalState struct

+ CreateTime *timestamppb.Timestamp

+ Deployment *v1.Deployment

+ IsCurrent bool

+ LastBecameCurrentTime *timestamppb.Timestamp

+ Metadata map[string]*v11.Payload

+ StartedSeriesWorkflow bool

+ TaskQueueFamilies map[string]*DeploymentLocalState_TaskQueueFamilyData

+ func (*DeploymentLocalState) Descriptor() ([]byte, []int)

+ func (*DeploymentLocalState) ProtoMessage()

+ func (this *DeploymentLocalState) Equal(that interface{}) bool

+ func (val *DeploymentLocalState) Marshal() ([]byte, error)

+ func (val *DeploymentLocalState) Size() int

+ func (val *DeploymentLocalState) Unmarshal(buf []byte) error

+ func (x *DeploymentLocalState) GetCreateTime() *timestamppb.Timestamp

+ func (x *DeploymentLocalState) GetDeployment() *v1.Deployment

+ func (x *DeploymentLocalState) GetIsCurrent() bool

+ func (x *DeploymentLocalState) GetLastBecameCurrentTime() *timestamppb.Timestamp

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

+ func (x *DeploymentLocalState) GetStartedSeriesWorkflow() bool

+ func (x *DeploymentLocalState) GetTaskQueueFamilies() map[string]*DeploymentLocalState_TaskQueueFamilyData

+ func (x *DeploymentLocalState) ProtoReflect() protoreflect.Message

+ func (x *DeploymentLocalState) Reset()

+ func (x *DeploymentLocalState) String() string

+ type DeploymentLocalState_TaskQueueFamilyData struct

+ TaskQueues map[int32]*TaskQueueData

+ func (*DeploymentLocalState_TaskQueueFamilyData) Descriptor() ([]byte, []int)

+ func (*DeploymentLocalState_TaskQueueFamilyData) ProtoMessage()

+ func (x *DeploymentLocalState_TaskQueueFamilyData) GetTaskQueues() map[int32]*TaskQueueData

+ func (x *DeploymentLocalState_TaskQueueFamilyData) ProtoReflect() protoreflect.Message

+ func (x *DeploymentLocalState_TaskQueueFamilyData) Reset()

+ func (x *DeploymentLocalState_TaskQueueFamilyData) String() string

+ type DeploymentSeriesWorkflowArgs struct

+ NamespaceId string

+ NamespaceName string

+ SeriesName string

+ State *SeriesLocalState

+ func (*DeploymentSeriesWorkflowArgs) Descriptor() ([]byte, []int)

+ func (*DeploymentSeriesWorkflowArgs) ProtoMessage()

+ func (this *DeploymentSeriesWorkflowArgs) Equal(that interface{}) bool

+ func (val *DeploymentSeriesWorkflowArgs) Marshal() ([]byte, error)

+ func (val *DeploymentSeriesWorkflowArgs) Size() int

+ func (val *DeploymentSeriesWorkflowArgs) Unmarshal(buf []byte) error

+ func (x *DeploymentSeriesWorkflowArgs) GetNamespaceId() string

+ func (x *DeploymentSeriesWorkflowArgs) GetNamespaceName() string

+ func (x *DeploymentSeriesWorkflowArgs) GetSeriesName() string

+ func (x *DeploymentSeriesWorkflowArgs) GetState() *SeriesLocalState

+ func (x *DeploymentSeriesWorkflowArgs) ProtoReflect() protoreflect.Message

+ func (x *DeploymentSeriesWorkflowArgs) Reset()

+ func (x *DeploymentSeriesWorkflowArgs) String() string

+ type DeploymentSeriesWorkflowMemo struct

+ CurrentBuildId string

+ CurrentChangedTime *timestamppb.Timestamp

+ SeriesName string

+ func (*DeploymentSeriesWorkflowMemo) Descriptor() ([]byte, []int)

+ func (*DeploymentSeriesWorkflowMemo) ProtoMessage()

+ func (this *DeploymentSeriesWorkflowMemo) Equal(that interface{}) bool

+ func (val *DeploymentSeriesWorkflowMemo) Marshal() ([]byte, error)

+ func (val *DeploymentSeriesWorkflowMemo) Size() int

+ func (val *DeploymentSeriesWorkflowMemo) Unmarshal(buf []byte) error

+ func (x *DeploymentSeriesWorkflowMemo) GetCurrentBuildId() string

+ func (x *DeploymentSeriesWorkflowMemo) GetCurrentChangedTime() *timestamppb.Timestamp

+ func (x *DeploymentSeriesWorkflowMemo) GetSeriesName() string

+ func (x *DeploymentSeriesWorkflowMemo) ProtoReflect() protoreflect.Message

+ func (x *DeploymentSeriesWorkflowMemo) Reset()

+ func (x *DeploymentSeriesWorkflowMemo) String() string

+ type DeploymentWorkflowArgs struct

+ NamespaceId string

+ NamespaceName string

+ State *DeploymentLocalState

+ func (*DeploymentWorkflowArgs) Descriptor() ([]byte, []int)

+ func (*DeploymentWorkflowArgs) ProtoMessage()

+ func (this *DeploymentWorkflowArgs) Equal(that interface{}) bool

+ func (val *DeploymentWorkflowArgs) Marshal() ([]byte, error)

+ func (val *DeploymentWorkflowArgs) Size() int

+ func (val *DeploymentWorkflowArgs) Unmarshal(buf []byte) error

+ func (x *DeploymentWorkflowArgs) GetNamespaceId() string

+ func (x *DeploymentWorkflowArgs) GetNamespaceName() string

+ func (x *DeploymentWorkflowArgs) GetState() *DeploymentLocalState

+ func (x *DeploymentWorkflowArgs) ProtoReflect() protoreflect.Message

+ func (x *DeploymentWorkflowArgs) Reset()

+ func (x *DeploymentWorkflowArgs) String() string

+ type DeploymentWorkflowMemo struct

+ CreateTime *timestamppb.Timestamp

+ Deployment *v1.Deployment

+ IsCurrentDeployment bool

+ func (*DeploymentWorkflowMemo) Descriptor() ([]byte, []int)

+ func (*DeploymentWorkflowMemo) ProtoMessage()

+ func (this *DeploymentWorkflowMemo) Equal(that interface{}) bool

+ func (val *DeploymentWorkflowMemo) Marshal() ([]byte, error)

+ func (val *DeploymentWorkflowMemo) Size() int

+ func (val *DeploymentWorkflowMemo) Unmarshal(buf []byte) error

+ func (x *DeploymentWorkflowMemo) GetCreateTime() *timestamppb.Timestamp

+ func (x *DeploymentWorkflowMemo) GetDeployment() *v1.Deployment

+ func (x *DeploymentWorkflowMemo) GetIsCurrentDeployment() bool

+ func (x *DeploymentWorkflowMemo) ProtoReflect() protoreflect.Message

+ func (x *DeploymentWorkflowMemo) Reset()

+ func (x *DeploymentWorkflowMemo) String() string

+ type QueryDescribeDeploymentResponse struct

+ DeploymentLocalState *DeploymentLocalState

+ func (*QueryDescribeDeploymentResponse) Descriptor() ([]byte, []int)

+ func (*QueryDescribeDeploymentResponse) ProtoMessage()

+ func (this *QueryDescribeDeploymentResponse) Equal(that interface{}) bool

+ func (val *QueryDescribeDeploymentResponse) Marshal() ([]byte, error)

+ func (val *QueryDescribeDeploymentResponse) Size() int

+ func (val *QueryDescribeDeploymentResponse) Unmarshal(buf []byte) error

+ func (x *QueryDescribeDeploymentResponse) GetDeploymentLocalState() *DeploymentLocalState

+ func (x *QueryDescribeDeploymentResponse) ProtoReflect() protoreflect.Message

+ func (x *QueryDescribeDeploymentResponse) Reset()

+ func (x *QueryDescribeDeploymentResponse) String() string

+ type RegisterWorkerInDeploymentArgs struct

+ FirstPollerTime *timestamppb.Timestamp

+ MaxTaskQueues int32

+ TaskQueueName string

+ TaskQueueType v12.TaskQueueType

+ func (*RegisterWorkerInDeploymentArgs) Descriptor() ([]byte, []int)

+ func (*RegisterWorkerInDeploymentArgs) ProtoMessage()

+ func (this *RegisterWorkerInDeploymentArgs) Equal(that interface{}) bool

+ func (val *RegisterWorkerInDeploymentArgs) Marshal() ([]byte, error)

+ func (val *RegisterWorkerInDeploymentArgs) Size() int

+ func (val *RegisterWorkerInDeploymentArgs) Unmarshal(buf []byte) error

+ func (x *RegisterWorkerInDeploymentArgs) GetFirstPollerTime() *timestamppb.Timestamp

+ func (x *RegisterWorkerInDeploymentArgs) GetMaxTaskQueues() int32

+ func (x *RegisterWorkerInDeploymentArgs) GetTaskQueueName() string

+ func (x *RegisterWorkerInDeploymentArgs) GetTaskQueueType() v12.TaskQueueType

+ func (x *RegisterWorkerInDeploymentArgs) ProtoReflect() protoreflect.Message

+ func (x *RegisterWorkerInDeploymentArgs) Reset()

+ func (x *RegisterWorkerInDeploymentArgs) String() string

+ type SeriesLocalState struct

+ CurrentBuildId string

+ CurrentChangedTime *timestamppb.Timestamp

+ func (*SeriesLocalState) Descriptor() ([]byte, []int)

+ func (*SeriesLocalState) ProtoMessage()

+ func (this *SeriesLocalState) Equal(that interface{}) bool

+ func (val *SeriesLocalState) Marshal() ([]byte, error)

+ func (val *SeriesLocalState) Size() int

+ func (val *SeriesLocalState) Unmarshal(buf []byte) error

+ func (x *SeriesLocalState) GetCurrentBuildId() string

+ func (x *SeriesLocalState) GetCurrentChangedTime() *timestamppb.Timestamp

+ func (x *SeriesLocalState) ProtoReflect() protoreflect.Message

+ func (x *SeriesLocalState) Reset()

+ func (x *SeriesLocalState) String() string

+ type SetCurrentDeploymentArgs struct

+ BuildId string

+ Identity string

+ RequestId string

+ UpdateMetadata *v1.UpdateDeploymentMetadata

+ func (*SetCurrentDeploymentArgs) Descriptor() ([]byte, []int)

+ func (*SetCurrentDeploymentArgs) ProtoMessage()

+ func (this *SetCurrentDeploymentArgs) Equal(that interface{}) bool

+ func (val *SetCurrentDeploymentArgs) Marshal() ([]byte, error)

+ func (val *SetCurrentDeploymentArgs) Size() int

+ func (val *SetCurrentDeploymentArgs) Unmarshal(buf []byte) error

+ func (x *SetCurrentDeploymentArgs) GetBuildId() string

+ func (x *SetCurrentDeploymentArgs) GetIdentity() string

+ func (x *SetCurrentDeploymentArgs) GetRequestId() string

+ func (x *SetCurrentDeploymentArgs) GetUpdateMetadata() *v1.UpdateDeploymentMetadata

+ func (x *SetCurrentDeploymentArgs) ProtoReflect() protoreflect.Message

+ func (x *SetCurrentDeploymentArgs) Reset()

+ func (x *SetCurrentDeploymentArgs) String() string

+ type SetCurrentDeploymentResponse struct

+ CurrentDeploymentState *DeploymentLocalState

+ PreviousDeploymentState *DeploymentLocalState

+ func (*SetCurrentDeploymentResponse) Descriptor() ([]byte, []int)

+ func (*SetCurrentDeploymentResponse) ProtoMessage()

+ func (this *SetCurrentDeploymentResponse) Equal(that interface{}) bool

+ func (val *SetCurrentDeploymentResponse) Marshal() ([]byte, error)

+ func (val *SetCurrentDeploymentResponse) Size() int

+ func (val *SetCurrentDeploymentResponse) Unmarshal(buf []byte) error

+ func (x *SetCurrentDeploymentResponse) GetCurrentDeploymentState() *DeploymentLocalState

+ func (x *SetCurrentDeploymentResponse) GetPreviousDeploymentState() *DeploymentLocalState

+ func (x *SetCurrentDeploymentResponse) ProtoReflect() protoreflect.Message

+ func (x *SetCurrentDeploymentResponse) Reset()

+ func (x *SetCurrentDeploymentResponse) String() string

+ type StartDeploymentSeriesRequest struct

+ RequestId string

+ SeriesName string

+ func (*StartDeploymentSeriesRequest) Descriptor() ([]byte, []int)

+ func (*StartDeploymentSeriesRequest) ProtoMessage()

+ func (this *StartDeploymentSeriesRequest) Equal(that interface{}) bool

+ func (val *StartDeploymentSeriesRequest) Marshal() ([]byte, error)

+ func (val *StartDeploymentSeriesRequest) Size() int

+ func (val *StartDeploymentSeriesRequest) Unmarshal(buf []byte) error

+ func (x *StartDeploymentSeriesRequest) GetRequestId() string

+ func (x *StartDeploymentSeriesRequest) GetSeriesName() string

+ func (x *StartDeploymentSeriesRequest) ProtoReflect() protoreflect.Message

+ func (x *StartDeploymentSeriesRequest) Reset()

+ func (x *StartDeploymentSeriesRequest) String() string

+ type SyncDeploymentStateActivityArgs struct

+ Args *SyncDeploymentStateArgs

+ Deployment *v1.Deployment

+ RequestId string

+ func (*SyncDeploymentStateActivityArgs) Descriptor() ([]byte, []int)

+ func (*SyncDeploymentStateActivityArgs) ProtoMessage()

+ func (this *SyncDeploymentStateActivityArgs) Equal(that interface{}) bool

+ func (val *SyncDeploymentStateActivityArgs) Marshal() ([]byte, error)

+ func (val *SyncDeploymentStateActivityArgs) Size() int

+ func (val *SyncDeploymentStateActivityArgs) Unmarshal(buf []byte) error

+ func (x *SyncDeploymentStateActivityArgs) GetArgs() *SyncDeploymentStateArgs

+ func (x *SyncDeploymentStateActivityArgs) GetDeployment() *v1.Deployment

+ func (x *SyncDeploymentStateActivityArgs) GetRequestId() string

+ func (x *SyncDeploymentStateActivityArgs) ProtoReflect() protoreflect.Message

+ func (x *SyncDeploymentStateActivityArgs) Reset()

+ func (x *SyncDeploymentStateActivityArgs) String() string

+ type SyncDeploymentStateActivityResult struct

+ State *DeploymentLocalState

+ func (*SyncDeploymentStateActivityResult) Descriptor() ([]byte, []int)

+ func (*SyncDeploymentStateActivityResult) ProtoMessage()

+ func (this *SyncDeploymentStateActivityResult) Equal(that interface{}) bool

+ func (val *SyncDeploymentStateActivityResult) Marshal() ([]byte, error)

+ func (val *SyncDeploymentStateActivityResult) Size() int

+ func (val *SyncDeploymentStateActivityResult) Unmarshal(buf []byte) error

+ func (x *SyncDeploymentStateActivityResult) GetState() *DeploymentLocalState

+ func (x *SyncDeploymentStateActivityResult) ProtoReflect() protoreflect.Message

+ func (x *SyncDeploymentStateActivityResult) Reset()

+ func (x *SyncDeploymentStateActivityResult) String() string

+ type SyncDeploymentStateArgs struct

+ SetCurrent *SyncDeploymentStateArgs_SetCurrent

+ UpdateMetadata *v1.UpdateDeploymentMetadata

+ func (*SyncDeploymentStateArgs) Descriptor() ([]byte, []int)

+ func (*SyncDeploymentStateArgs) ProtoMessage()

+ func (this *SyncDeploymentStateArgs) Equal(that interface{}) bool

+ func (val *SyncDeploymentStateArgs) Marshal() ([]byte, error)

+ func (val *SyncDeploymentStateArgs) Size() int

+ func (val *SyncDeploymentStateArgs) Unmarshal(buf []byte) error

+ func (x *SyncDeploymentStateArgs) GetSetCurrent() *SyncDeploymentStateArgs_SetCurrent

+ func (x *SyncDeploymentStateArgs) GetUpdateMetadata() *v1.UpdateDeploymentMetadata

+ func (x *SyncDeploymentStateArgs) ProtoReflect() protoreflect.Message

+ func (x *SyncDeploymentStateArgs) Reset()

+ func (x *SyncDeploymentStateArgs) String() string

+ type SyncDeploymentStateArgs_SetCurrent struct

+ LastBecameCurrentTime *timestamppb.Timestamp

+ func (*SyncDeploymentStateArgs_SetCurrent) Descriptor() ([]byte, []int)

+ func (*SyncDeploymentStateArgs_SetCurrent) ProtoMessage()

+ func (x *SyncDeploymentStateArgs_SetCurrent) GetLastBecameCurrentTime() *timestamppb.Timestamp

+ func (x *SyncDeploymentStateArgs_SetCurrent) ProtoReflect() protoreflect.Message

+ func (x *SyncDeploymentStateArgs_SetCurrent) Reset()

+ func (x *SyncDeploymentStateArgs_SetCurrent) String() string

+ type SyncDeploymentStateResponse struct

+ DeploymentLocalState *DeploymentLocalState

+ func (*SyncDeploymentStateResponse) Descriptor() ([]byte, []int)

+ func (*SyncDeploymentStateResponse) ProtoMessage()

+ func (this *SyncDeploymentStateResponse) Equal(that interface{}) bool

+ func (val *SyncDeploymentStateResponse) Marshal() ([]byte, error)

+ func (val *SyncDeploymentStateResponse) Size() int

+ func (val *SyncDeploymentStateResponse) Unmarshal(buf []byte) error

+ func (x *SyncDeploymentStateResponse) GetDeploymentLocalState() *DeploymentLocalState

+ func (x *SyncDeploymentStateResponse) ProtoReflect() protoreflect.Message

+ func (x *SyncDeploymentStateResponse) Reset()

+ func (x *SyncDeploymentStateResponse) String() string

+ type SyncUserDataRequest struct

+ Deployment *v1.Deployment

+ Sync []*SyncUserDataRequest_SyncUserData

+ func (*SyncUserDataRequest) Descriptor() ([]byte, []int)

+ func (*SyncUserDataRequest) ProtoMessage()

+ func (this *SyncUserDataRequest) Equal(that interface{}) bool

+ func (val *SyncUserDataRequest) Marshal() ([]byte, error)

+ func (val *SyncUserDataRequest) Size() int

+ func (val *SyncUserDataRequest) Unmarshal(buf []byte) error

+ func (x *SyncUserDataRequest) GetDeployment() *v1.Deployment

+ func (x *SyncUserDataRequest) GetSync() []*SyncUserDataRequest_SyncUserData

+ func (x *SyncUserDataRequest) ProtoReflect() protoreflect.Message

+ func (x *SyncUserDataRequest) Reset()

+ func (x *SyncUserDataRequest) String() string

+ type SyncUserDataRequest_SyncUserData struct

+ Data *TaskQueueData

+ Name string

+ Type v12.TaskQueueType

+ func (*SyncUserDataRequest_SyncUserData) Descriptor() ([]byte, []int)

+ func (*SyncUserDataRequest_SyncUserData) ProtoMessage()

+ func (x *SyncUserDataRequest_SyncUserData) GetData() *TaskQueueData

+ func (x *SyncUserDataRequest_SyncUserData) GetName() string

+ func (x *SyncUserDataRequest_SyncUserData) GetType() v12.TaskQueueType

+ func (x *SyncUserDataRequest_SyncUserData) ProtoReflect() protoreflect.Message

+ func (x *SyncUserDataRequest_SyncUserData) Reset()

+ func (x *SyncUserDataRequest_SyncUserData) String() string

+ type TaskQueueData struct

+ FirstPollerTime *timestamppb.Timestamp

+ LastBecameCurrentTime *timestamppb.Timestamp

+ func (*TaskQueueData) Descriptor() ([]byte, []int)

+ func (*TaskQueueData) ProtoMessage()

+ func (this *TaskQueueData) Equal(that interface{}) bool

+ func (val *TaskQueueData) Marshal() ([]byte, error)

+ func (val *TaskQueueData) Size() int

+ func (val *TaskQueueData) Unmarshal(buf []byte) error

+ func (x *TaskQueueData) GetFirstPollerTime() *timestamppb.Timestamp

+ func (x *TaskQueueData) GetLastBecameCurrentTime() *timestamppb.Timestamp

+ func (x *TaskQueueData) ProtoReflect() protoreflect.Message

+ func (x *TaskQueueData) Reset()

+ func (x *TaskQueueData) String() string

v1.26.2-rc.2

Dec 20, 2024

v1.26.2-rc.0

Dec 17, 2024

v1.26.2-125.3

Jan 16, 2025

v1.26.2-125.2

Dec 20, 2024

v1.26.2-125.1

Dec 5, 2024

v1.26.2-125.0

Dec 2, 2024