taskqueue

Oct 16, 2025

Changes in this version

type TaskQueueConfig

+ FairnessWeightOverrides map[string]float32

+ func (x *TaskQueueConfig) GetFairnessWeightOverrides() map[string]float32

Jul 23, 2025

Changes in this version

+ type ConfigMetadata struct

+ Reason string

+ UpdateIdentity string

+ UpdateTime *timestamppb.Timestamp

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

+ func (*ConfigMetadata) ProtoMessage()

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

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

+ func (val *ConfigMetadata) Size() int

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

+ func (x *ConfigMetadata) GetReason() string

+ func (x *ConfigMetadata) GetUpdateIdentity() string

+ func (x *ConfigMetadata) GetUpdateTime() *timestamppb.Timestamp

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

+ func (x *ConfigMetadata) Reset()

+ func (x *ConfigMetadata) String() string

+ type RateLimit struct

+ RequestsPerSecond float32

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

+ func (*RateLimit) ProtoMessage()

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

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

+ func (val *RateLimit) Size() int

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

+ func (x *RateLimit) GetRequestsPerSecond() float32

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

+ func (x *RateLimit) Reset()

+ func (x *RateLimit) String() string

+ type RateLimitConfig struct

+ Metadata *ConfigMetadata

+ RateLimit *RateLimit

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

+ func (*RateLimitConfig) ProtoMessage()

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

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

+ func (val *RateLimitConfig) Size() int

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

+ func (x *RateLimitConfig) GetMetadata() *ConfigMetadata

+ func (x *RateLimitConfig) GetRateLimit() *RateLimit

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

+ func (x *RateLimitConfig) Reset()

+ func (x *RateLimitConfig) String() string

+ type TaskQueueConfig struct

+ FairnessKeysRateLimitDefault *RateLimitConfig

+ QueueRateLimit *RateLimitConfig

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

+ func (*TaskQueueConfig) ProtoMessage()

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

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

+ func (val *TaskQueueConfig) Size() int

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

+ func (x *TaskQueueConfig) GetFairnessKeysRateLimitDefault() *RateLimitConfig

+ func (x *TaskQueueConfig) GetQueueRateLimit() *RateLimitConfig

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

+ func (x *TaskQueueConfig) Reset()

+ func (x *TaskQueueConfig) String() string

May 13, 2025

Changes in this version

type TaskQueueVersioningInfo

+ CurrentDeploymentVersion *v11.WorkerDeploymentVersion

+ RampingDeploymentVersion *v11.WorkerDeploymentVersion

+ func (x *TaskQueueVersioningInfo) GetCurrentDeploymentVersion() *v11.WorkerDeploymentVersion

+ func (x *TaskQueueVersioningInfo) GetRampingDeploymentVersion() *v11.WorkerDeploymentVersion

Feb 24, 2025

Changes in this version

+ type PollerScalingDecision struct

+ PollRequestDeltaSuggestion int32

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

+ func (*PollerScalingDecision) ProtoMessage()

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

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

+ func (val *PollerScalingDecision) Size() int

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

+ func (x *PollerScalingDecision) GetPollRequestDeltaSuggestion() int32

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

+ func (x *PollerScalingDecision) Reset()

+ func (x *PollerScalingDecision) String() string

Feb 7, 2025 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

type PollerInfo

+ DeploymentOptions *v12.WorkerDeploymentOptions

+ func (x *PollerInfo) GetDeploymentOptions() *v12.WorkerDeploymentOptions

+ type TaskQueueVersioningInfo struct

+ CurrentVersion string

+ RampingVersion string

+ RampingVersionPercentage float32

+ UpdateTime *timestamppb.Timestamp

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

+ func (*TaskQueueVersioningInfo) ProtoMessage()

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

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

+ func (val *TaskQueueVersioningInfo) Size() int

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

+ func (x *TaskQueueVersioningInfo) GetCurrentVersion() string

+ func (x *TaskQueueVersioningInfo) GetRampingVersion() string

+ func (x *TaskQueueVersioningInfo) GetRampingVersionPercentage() float32

+ func (x *TaskQueueVersioningInfo) GetUpdateTime() *timestamppb.Timestamp

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

+ func (x *TaskQueueVersioningInfo) Reset()

+ func (x *TaskQueueVersioningInfo) String() string

Jan 17, 2025 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jan 9, 2025 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Nov 27, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Nov 18, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Oct 31, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Oct 24, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Aug 28, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Aug 23, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Aug 8, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jul 12, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jun 26, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ type TaskQueueStats struct

+ ApproximateBacklogAge *durationpb.Duration

+ ApproximateBacklogCount int64

+ TasksAddRate float32

+ TasksDispatchRate float32

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

+ func (*TaskQueueStats) ProtoMessage()

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

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

+ func (val *TaskQueueStats) Size() int

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

+ func (x *TaskQueueStats) GetApproximateBacklogAge() *durationpb.Duration

+ func (x *TaskQueueStats) GetApproximateBacklogCount() int64

+ func (x *TaskQueueStats) GetTasksAddRate() float32

+ func (x *TaskQueueStats) GetTasksDispatchRate() float32

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

+ func (x *TaskQueueStats) Reset()

+ func (x *TaskQueueStats) String() string

type TaskQueueTypeInfo

+ Stats *TaskQueueStats

+ func (x *TaskQueueTypeInfo) GetStats() *TaskQueueStats

May 22, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

May 9, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Apr 25, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jul 5, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jul 5, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Apr 10, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ type BuildIdAssignmentRule struct

+ Ramp isBuildIdAssignmentRule_Ramp

+ TargetBuildId string

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

+ func (*BuildIdAssignmentRule) ProtoMessage()

+ func (m *BuildIdAssignmentRule) GetRamp() isBuildIdAssignmentRule_Ramp

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

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

+ func (val *BuildIdAssignmentRule) Size() int

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

+ func (x *BuildIdAssignmentRule) GetPercentageRamp() *RampByPercentage

+ func (x *BuildIdAssignmentRule) GetTargetBuildId() string

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

+ func (x *BuildIdAssignmentRule) Reset()

+ func (x *BuildIdAssignmentRule) String() string

+ type BuildIdAssignmentRule_PercentageRamp struct

+ PercentageRamp *RampByPercentage

+ type CompatibleBuildIdRedirectRule struct

+ SourceBuildId string

+ TargetBuildId string

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

+ func (*CompatibleBuildIdRedirectRule) ProtoMessage()

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

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

+ func (val *CompatibleBuildIdRedirectRule) Size() int

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

+ func (x *CompatibleBuildIdRedirectRule) GetSourceBuildId() string

+ func (x *CompatibleBuildIdRedirectRule) GetTargetBuildId() string

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

+ func (x *CompatibleBuildIdRedirectRule) Reset()

+ func (x *CompatibleBuildIdRedirectRule) String() string

+ type RampByPercentage struct

+ RampPercentage float32

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

+ func (*RampByPercentage) ProtoMessage()

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

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

+ func (val *RampByPercentage) Size() int

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

+ func (x *RampByPercentage) GetRampPercentage() float32

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

+ func (x *RampByPercentage) Reset()

+ func (x *RampByPercentage) String() string

+ type TaskQueueTypeInfo struct

+ Pollers []*PollerInfo

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

+ func (*TaskQueueTypeInfo) ProtoMessage()

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

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

+ func (val *TaskQueueTypeInfo) Size() int

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

+ func (x *TaskQueueTypeInfo) GetPollers() []*PollerInfo

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

+ func (x *TaskQueueTypeInfo) Reset()

+ func (x *TaskQueueTypeInfo) String() string

+ type TaskQueueVersionInfo struct

+ TaskReachability v1.BuildIdTaskReachability

+ TypesInfo map[int32]*TaskQueueTypeInfo

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

+ func (*TaskQueueVersionInfo) ProtoMessage()

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

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

+ func (val *TaskQueueVersionInfo) Size() int

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

+ func (x *TaskQueueVersionInfo) GetTaskReachability() v1.BuildIdTaskReachability

+ func (x *TaskQueueVersionInfo) GetTypesInfo() map[int32]*TaskQueueTypeInfo

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

+ func (x *TaskQueueVersionInfo) Reset()

+ func (x *TaskQueueVersionInfo) String() string

+ type TaskQueueVersionSelection struct

+ AllActive bool

+ BuildIds []string

+ Unversioned bool

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

+ func (*TaskQueueVersionSelection) ProtoMessage()

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

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

+ func (val *TaskQueueVersionSelection) Size() int

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

+ func (x *TaskQueueVersionSelection) GetAllActive() bool

+ func (x *TaskQueueVersionSelection) GetBuildIds() []string

+ func (x *TaskQueueVersionSelection) GetUnversioned() bool

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

+ func (x *TaskQueueVersionSelection) Reset()

+ func (x *TaskQueueVersionSelection) String() string

+ type TimestampedBuildIdAssignmentRule struct

+ CreateTime *timestamppb.Timestamp

+ Rule *BuildIdAssignmentRule

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

+ func (*TimestampedBuildIdAssignmentRule) ProtoMessage()

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

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

+ func (val *TimestampedBuildIdAssignmentRule) Size() int

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

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

+ func (x *TimestampedBuildIdAssignmentRule) GetRule() *BuildIdAssignmentRule

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

+ func (x *TimestampedBuildIdAssignmentRule) Reset()

+ func (x *TimestampedBuildIdAssignmentRule) String() string

+ type TimestampedCompatibleBuildIdRedirectRule struct

+ CreateTime *timestamppb.Timestamp

+ Rule *CompatibleBuildIdRedirectRule

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

+ func (*TimestampedCompatibleBuildIdRedirectRule) ProtoMessage()

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

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

+ func (val *TimestampedCompatibleBuildIdRedirectRule) Size() int

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

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

+ func (x *TimestampedCompatibleBuildIdRedirectRule) GetRule() *CompatibleBuildIdRedirectRule

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

+ func (x *TimestampedCompatibleBuildIdRedirectRule) Reset()

+ func (x *TimestampedCompatibleBuildIdRedirectRule) String() string

Apr 6, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Mar 19, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Mar 15, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Mar 11, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Mar 11, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Mar 1, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Feb 23, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jan 31, 2024 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Dec 4, 2023

retracted

GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Nov 28, 2023

retracted

GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ var File_temporal_api_taskqueue_v1_message_proto protoreflect.FileDescriptor

type BuildIdReachability

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

type CompatibleVersionSet

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

type PollerInfo

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

type StickyExecutionAttributes

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

type TaskIdBlock

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

type TaskQueue

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

type TaskQueueMetadata

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

type TaskQueuePartitionMetadata

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

type TaskQueueReachability

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

type TaskQueueStatus

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

Nov 13, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Oct 27, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Aug 18, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jun 6, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jun 2, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

May 25, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ type BuildIdReachability struct

+ BuildId string

+ TaskQueueReachability []*TaskQueueReachability

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

+ func (*BuildIdReachability) ProtoMessage()

+ func (m *BuildIdReachability) GetBuildId() string

+ func (m *BuildIdReachability) GetTaskQueueReachability() []*TaskQueueReachability

+ func (m *BuildIdReachability) Marshal() (dAtA []byte, err error)

+ func (m *BuildIdReachability) MarshalTo(dAtA []byte) (int, error)

+ func (m *BuildIdReachability) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BuildIdReachability) Reset()

+ func (m *BuildIdReachability) Size() (n int)

+ func (m *BuildIdReachability) Unmarshal(dAtA []byte) error

+ func (m *BuildIdReachability) XXX_DiscardUnknown()

+ func (m *BuildIdReachability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BuildIdReachability) XXX_Merge(src proto.Message)

+ func (m *BuildIdReachability) XXX_Size() int

+ func (m *BuildIdReachability) XXX_Unmarshal(b []byte) error

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

+ func (this *BuildIdReachability) GoString() string

+ func (this *BuildIdReachability) String() string

type TaskQueue

+ NormalName string

+ func (m *TaskQueue) GetNormalName() string

+ type TaskQueueReachability struct

+ Reachability []v1.TaskReachability

+ TaskQueue string

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

+ func (*TaskQueueReachability) ProtoMessage()

+ func (m *TaskQueueReachability) GetReachability() []v1.TaskReachability

+ func (m *TaskQueueReachability) GetTaskQueue() string

+ func (m *TaskQueueReachability) Marshal() (dAtA []byte, err error)

+ func (m *TaskQueueReachability) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskQueueReachability) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskQueueReachability) Reset()

+ func (m *TaskQueueReachability) Size() (n int)

+ func (m *TaskQueueReachability) Unmarshal(dAtA []byte) error

+ func (m *TaskQueueReachability) XXX_DiscardUnknown()

+ func (m *TaskQueueReachability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskQueueReachability) XXX_Merge(src proto.Message)

+ func (m *TaskQueueReachability) XXX_Size() int

+ func (m *TaskQueueReachability) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskQueueReachability) GoString() string

+ func (this *TaskQueueReachability) String() string

Mar 13, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ type CompatibleVersionSet struct

+ BuildIds []string

+ VersionSetId string

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

+ func (*CompatibleVersionSet) ProtoMessage()

+ func (m *CompatibleVersionSet) GetBuildIds() []string

+ func (m *CompatibleVersionSet) GetVersionSetId() string

+ func (m *CompatibleVersionSet) Marshal() (dAtA []byte, err error)

+ func (m *CompatibleVersionSet) MarshalTo(dAtA []byte) (int, error)

+ func (m *CompatibleVersionSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CompatibleVersionSet) Reset()

+ func (m *CompatibleVersionSet) Size() (n int)

+ func (m *CompatibleVersionSet) Unmarshal(dAtA []byte) error

+ func (m *CompatibleVersionSet) XXX_DiscardUnknown()

+ func (m *CompatibleVersionSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompatibleVersionSet) XXX_Merge(src proto.Message)

+ func (m *CompatibleVersionSet) XXX_Size() int

+ func (m *CompatibleVersionSet) XXX_Unmarshal(b []byte) error

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

+ func (this *CompatibleVersionSet) GoString() string

+ func (this *CompatibleVersionSet) String() string

type PollerInfo

+ WorkerVersionCapabilities *v11.WorkerVersionCapabilities

+ func (m *PollerInfo) GetWorkerVersionCapabilities() *v11.WorkerVersionCapabilities

Feb 16, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Feb 10, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Feb 10, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Feb 2, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jan 24, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jan 6, 2023 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Oct 28, 2022 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Sep 13, 2022 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

type PollerInfo

+ WorkerVersioningId *VersionId

+ func (m *PollerInfo) GetWorkerVersioningId() *VersionId

Jul 28, 2022 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jul 13, 2022 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jun 16, 2022 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ type VersionId struct

+ WorkerBuildId string

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

+ func (*VersionId) ProtoMessage()

+ func (m *VersionId) GetWorkerBuildId() string

+ func (m *VersionId) Marshal() (dAtA []byte, err error)

+ func (m *VersionId) MarshalTo(dAtA []byte) (int, error)

+ func (m *VersionId) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VersionId) Reset()

+ func (m *VersionId) Size() (n int)

+ func (m *VersionId) Unmarshal(dAtA []byte) error

+ func (m *VersionId) XXX_DiscardUnknown()

+ func (m *VersionId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VersionId) XXX_Merge(src proto.Message)

+ func (m *VersionId) XXX_Size() int

+ func (m *VersionId) XXX_Unmarshal(b []byte) error

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

+ func (this *VersionId) GoString() string

+ func (this *VersionId) String() string

+ type VersionIdNode struct

+ PreviousCompatible *VersionIdNode

+ PreviousIncompatible *VersionIdNode

+ Version *VersionId

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

+ func (*VersionIdNode) ProtoMessage()

+ func (m *VersionIdNode) GetPreviousCompatible() *VersionIdNode

+ func (m *VersionIdNode) GetPreviousIncompatible() *VersionIdNode

+ func (m *VersionIdNode) GetVersion() *VersionId

+ func (m *VersionIdNode) Marshal() (dAtA []byte, err error)

+ func (m *VersionIdNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *VersionIdNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VersionIdNode) Reset()

+ func (m *VersionIdNode) Size() (n int)

+ func (m *VersionIdNode) Unmarshal(dAtA []byte) error

+ func (m *VersionIdNode) XXX_DiscardUnknown()

+ func (m *VersionIdNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VersionIdNode) XXX_Merge(src proto.Message)

+ func (m *VersionIdNode) XXX_Size() int

+ func (m *VersionIdNode) XXX_Unmarshal(b []byte) error

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

+ func (this *VersionIdNode) GoString() string

+ func (this *VersionIdNode) String() string

Jun 2, 2022 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Dec 9, 2021 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Nov 1, 2021 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Sep 14, 2021 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Dec 23, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Dec 7, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Nov 4, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Oct 13, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Sep 25, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Sep 25, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Sep 18, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Aug 31, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Aug 19, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Jul 31, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

type StickyExecutionAttributes

+ ScheduleToStartTimeout *time.Duration

+ func (m *StickyExecutionAttributes) GetScheduleToStartTimeout() *time.Duration

Jul 14, 2020 GO-2025-3462

  GO-2025-3462: Unencrypted transmission in Temporal api-go library in go.temporal.io/api

Changes in this version

+ var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")

+ type PollerInfo struct

+ Identity string

+ LastAccessTime int64

+ RatePerSecond float64

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

+ func (*PollerInfo) ProtoMessage()

+ func (m *PollerInfo) GetIdentity() string

+ func (m *PollerInfo) GetLastAccessTime() int64

+ func (m *PollerInfo) GetRatePerSecond() float64

+ func (m *PollerInfo) Marshal() (dAtA []byte, err error)

+ func (m *PollerInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *PollerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PollerInfo) Reset()

+ func (m *PollerInfo) Size() (n int)

+ func (m *PollerInfo) Unmarshal(dAtA []byte) error

+ func (m *PollerInfo) XXX_DiscardUnknown()

+ func (m *PollerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PollerInfo) XXX_Merge(src proto.Message)

+ func (m *PollerInfo) XXX_Size() int

+ func (m *PollerInfo) XXX_Unmarshal(b []byte) error

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

+ func (this *PollerInfo) GoString() string

+ func (this *PollerInfo) String() string

+ type StickyExecutionAttributes struct

+ ScheduleToStartTimeoutSeconds int32

+ WorkerTaskQueue *TaskQueue

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

+ func (*StickyExecutionAttributes) ProtoMessage()

+ func (m *StickyExecutionAttributes) GetScheduleToStartTimeoutSeconds() int32

+ func (m *StickyExecutionAttributes) GetWorkerTaskQueue() *TaskQueue

+ func (m *StickyExecutionAttributes) Marshal() (dAtA []byte, err error)

+ func (m *StickyExecutionAttributes) MarshalTo(dAtA []byte) (int, error)

+ func (m *StickyExecutionAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StickyExecutionAttributes) Reset()

+ func (m *StickyExecutionAttributes) Size() (n int)

+ func (m *StickyExecutionAttributes) Unmarshal(dAtA []byte) error

+ func (m *StickyExecutionAttributes) XXX_DiscardUnknown()

+ func (m *StickyExecutionAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StickyExecutionAttributes) XXX_Merge(src proto.Message)

+ func (m *StickyExecutionAttributes) XXX_Size() int

+ func (m *StickyExecutionAttributes) XXX_Unmarshal(b []byte) error

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

+ func (this *StickyExecutionAttributes) GoString() string

+ func (this *StickyExecutionAttributes) String() string

+ type TaskIdBlock struct

+ EndId int64

+ StartId int64

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

+ func (*TaskIdBlock) ProtoMessage()

+ func (m *TaskIdBlock) GetEndId() int64

+ func (m *TaskIdBlock) GetStartId() int64

+ func (m *TaskIdBlock) Marshal() (dAtA []byte, err error)

+ func (m *TaskIdBlock) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskIdBlock) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskIdBlock) Reset()

+ func (m *TaskIdBlock) Size() (n int)

+ func (m *TaskIdBlock) Unmarshal(dAtA []byte) error

+ func (m *TaskIdBlock) XXX_DiscardUnknown()

+ func (m *TaskIdBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskIdBlock) XXX_Merge(src proto.Message)

+ func (m *TaskIdBlock) XXX_Size() int

+ func (m *TaskIdBlock) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskIdBlock) GoString() string

+ func (this *TaskIdBlock) String() string

+ type TaskQueue struct

+ Kind v1.TaskQueueKind

+ Name string

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

+ func (*TaskQueue) ProtoMessage()

+ func (m *TaskQueue) GetKind() v1.TaskQueueKind

+ func (m *TaskQueue) GetName() string

+ func (m *TaskQueue) Marshal() (dAtA []byte, err error)

+ func (m *TaskQueue) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskQueue) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskQueue) Reset()

+ func (m *TaskQueue) Size() (n int)

+ func (m *TaskQueue) Unmarshal(dAtA []byte) error

+ func (m *TaskQueue) XXX_DiscardUnknown()

+ func (m *TaskQueue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskQueue) XXX_Merge(src proto.Message)

+ func (m *TaskQueue) XXX_Size() int

+ func (m *TaskQueue) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskQueue) GoString() string

+ func (this *TaskQueue) String() string

+ type TaskQueueMetadata struct

+ MaxTasksPerSecond *types.DoubleValue

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

+ func (*TaskQueueMetadata) ProtoMessage()

+ func (m *TaskQueueMetadata) GetMaxTasksPerSecond() *types.DoubleValue

+ func (m *TaskQueueMetadata) Marshal() (dAtA []byte, err error)

+ func (m *TaskQueueMetadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskQueueMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskQueueMetadata) Reset()

+ func (m *TaskQueueMetadata) Size() (n int)

+ func (m *TaskQueueMetadata) Unmarshal(dAtA []byte) error

+ func (m *TaskQueueMetadata) XXX_DiscardUnknown()

+ func (m *TaskQueueMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskQueueMetadata) XXX_Merge(src proto.Message)

+ func (m *TaskQueueMetadata) XXX_Size() int

+ func (m *TaskQueueMetadata) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskQueueMetadata) GoString() string

+ func (this *TaskQueueMetadata) String() string

+ type TaskQueuePartitionMetadata struct

+ Key string

+ OwnerHostName string

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

+ func (*TaskQueuePartitionMetadata) ProtoMessage()

+ func (m *TaskQueuePartitionMetadata) GetKey() string

+ func (m *TaskQueuePartitionMetadata) GetOwnerHostName() string

+ func (m *TaskQueuePartitionMetadata) Marshal() (dAtA []byte, err error)

+ func (m *TaskQueuePartitionMetadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskQueuePartitionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskQueuePartitionMetadata) Reset()

+ func (m *TaskQueuePartitionMetadata) Size() (n int)

+ func (m *TaskQueuePartitionMetadata) Unmarshal(dAtA []byte) error

+ func (m *TaskQueuePartitionMetadata) XXX_DiscardUnknown()

+ func (m *TaskQueuePartitionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskQueuePartitionMetadata) XXX_Merge(src proto.Message)

+ func (m *TaskQueuePartitionMetadata) XXX_Size() int

+ func (m *TaskQueuePartitionMetadata) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskQueuePartitionMetadata) GoString() string

+ func (this *TaskQueuePartitionMetadata) String() string

+ type TaskQueueStatus struct

+ AckLevel int64

+ BacklogCountHint int64

+ RatePerSecond float64

+ ReadLevel int64

+ TaskIdBlock *TaskIdBlock

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

+ func (*TaskQueueStatus) ProtoMessage()

+ func (m *TaskQueueStatus) GetAckLevel() int64

+ func (m *TaskQueueStatus) GetBacklogCountHint() int64

+ func (m *TaskQueueStatus) GetRatePerSecond() float64

+ func (m *TaskQueueStatus) GetReadLevel() int64

+ func (m *TaskQueueStatus) GetTaskIdBlock() *TaskIdBlock

+ func (m *TaskQueueStatus) Marshal() (dAtA []byte, err error)

+ func (m *TaskQueueStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskQueueStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskQueueStatus) Reset()

+ func (m *TaskQueueStatus) Size() (n int)

+ func (m *TaskQueueStatus) Unmarshal(dAtA []byte) error

+ func (m *TaskQueueStatus) XXX_DiscardUnknown()

+ func (m *TaskQueueStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskQueueStatus) XXX_Merge(src proto.Message)

+ func (m *TaskQueueStatus) XXX_Size() int

+ func (m *TaskQueueStatus) XXX_Unmarshal(b []byte) error

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

+ func (this *TaskQueueStatus) GoString() string

+ func (this *TaskQueueStatus) String() string