compute

package
v1.63.2 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

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

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

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

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_api_compute_v1_config_proto protoreflect.FileDescriptor
View Source 
var File_temporal_api_compute_v1_provider_proto protoreflect.FileDescriptor
View Source 
var File_temporal_api_compute_v1_scaler_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ComputeConfig 

type ComputeConfig struct {

	// Each scaling group describes a compute config for a specific subset of the worker
	// deployment version: covering a specific set of task types and/or regions.
	// Having different configurations for different task types, allows independent
	// tuning of activity and workflow task processing (for example).
	//
	// The key of the map is the ID of the scaling group used to reference it in subsequent
	// update calls.
	ScalingGroups map[string]*ComputeConfigScalingGroup `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

ComputeConfig stores configuration that helps a worker control plane controller understand *when* and *how* to respond to worker lifecycle events.

func (*ComputeConfig) Descriptor deprecated 

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

Deprecated: Use ComputeConfig.ProtoReflect.Descriptor instead.

func (*ComputeConfig) Equal 

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

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

func (*ComputeConfig) GetScalingGroups 

func (x *ComputeConfig) GetScalingGroups() map[string]*ComputeConfigScalingGroup

func (*ComputeConfig) Marshal 

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

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

func (*ComputeConfig) ProtoMessage 

func (*ComputeConfig) ProtoMessage()

func (*ComputeConfig) ProtoReflect 

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

func (*ComputeConfig) Reset 

func (x *ComputeConfig) Reset()

func (*ComputeConfig) Size 

func (val *ComputeConfig) Size() int

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

func (*ComputeConfig) String 

func (x *ComputeConfig) String() string

func (*ComputeConfig) Unmarshal 

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

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

type ComputeConfigScalingGroup 

type ComputeConfigScalingGroup struct {

	// Optional. The set of task queue types this scaling group serves.
	// If not provided, this scaling group serves all not otherwise defined
	// task types.
	TaskQueueTypes []v1.TaskQueueType `` /* 154-byte string literal not displayed */
	// Stores instructions for a worker control plane controller how to respond
	// to worker lifeycle events.
	Provider *ComputeProvider `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	// Informs a worker lifecycle controller *when* and *how often* to perform
	// certain worker lifecycle actions like starting a serverless worker.
	Scaler *ComputeScaler `protobuf:"bytes,4,opt,name=scaler,proto3" json:"scaler,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeConfigScalingGroup) Descriptor deprecated 

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

Deprecated: Use ComputeConfigScalingGroup.ProtoReflect.Descriptor instead.

func (*ComputeConfigScalingGroup) Equal 

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

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

func (*ComputeConfigScalingGroup) GetProvider 

func (x *ComputeConfigScalingGroup) GetProvider() *ComputeProvider

func (*ComputeConfigScalingGroup) GetScaler 

func (x *ComputeConfigScalingGroup) GetScaler() *ComputeScaler

func (*ComputeConfigScalingGroup) GetTaskQueueTypes 

func (x *ComputeConfigScalingGroup) GetTaskQueueTypes() []v1.TaskQueueType

func (*ComputeConfigScalingGroup) Marshal 

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

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

func (*ComputeConfigScalingGroup) ProtoMessage 

func (*ComputeConfigScalingGroup) ProtoMessage()

func (*ComputeConfigScalingGroup) ProtoReflect 

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

func (*ComputeConfigScalingGroup) Reset 

func (x *ComputeConfigScalingGroup) Reset()

func (*ComputeConfigScalingGroup) Size 

func (val *ComputeConfigScalingGroup) Size() int

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

func (*ComputeConfigScalingGroup) String 

func (x *ComputeConfigScalingGroup) String() string

func (*ComputeConfigScalingGroup) Unmarshal 

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

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

type ComputeConfigScalingGroupSummary 

type ComputeConfigScalingGroupSummary struct {
	TaskQueueTypes []v1.TaskQueueType `` /* 154-byte string literal not displayed */
	ProviderType   string             `protobuf:"bytes,2,opt,name=provider_type,json=providerType,proto3" json:"provider_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeConfigScalingGroupSummary) Descriptor deprecated 

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

Deprecated: Use ComputeConfigScalingGroupSummary.ProtoReflect.Descriptor instead.

func (*ComputeConfigScalingGroupSummary) Equal 

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

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

func (*ComputeConfigScalingGroupSummary) GetProviderType 

func (x *ComputeConfigScalingGroupSummary) GetProviderType() string

func (*ComputeConfigScalingGroupSummary) GetTaskQueueTypes 

func (x *ComputeConfigScalingGroupSummary) GetTaskQueueTypes() []v1.TaskQueueType

func (*ComputeConfigScalingGroupSummary) Marshal 

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

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

func (*ComputeConfigScalingGroupSummary) ProtoMessage 

func (*ComputeConfigScalingGroupSummary) ProtoMessage()

func (*ComputeConfigScalingGroupSummary) ProtoReflect 

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

func (*ComputeConfigScalingGroupSummary) Reset 

func (x *ComputeConfigScalingGroupSummary) Reset()

func (*ComputeConfigScalingGroupSummary) Size 

func (val *ComputeConfigScalingGroupSummary) Size() int

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

func (*ComputeConfigScalingGroupSummary) String 

func (x *ComputeConfigScalingGroupSummary) String() string

func (*ComputeConfigScalingGroupSummary) Unmarshal 

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

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

type ComputeConfigScalingGroupUpdate 

type ComputeConfigScalingGroupUpdate struct {
	ScalingGroup *ComputeConfigScalingGroup `protobuf:"bytes,1,opt,name=scaling_group,json=scalingGroup,proto3" json:"scaling_group,omitempty"`
	// Controls which fields from `scaling_group` will be applied. Semantics:
	//   - Mask is ignored for new scaling groups (only applicable when scaling group already exists).
	//   - Empty mask for an existing scaling group is no-op: no change.
	//   - Non-empty mask for an existing scaling group will update/unset only to the fields
	//     mentioned in the mask.
	//   - Accepted paths: "task_queue_types", "provider", "provider.type", "provider.details",
	//     "provider.nexus_endpoint", "scaler", "scaler.type", "scaler.details"
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeConfigScalingGroupUpdate) Descriptor deprecated 

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

Deprecated: Use ComputeConfigScalingGroupUpdate.ProtoReflect.Descriptor instead.

func (*ComputeConfigScalingGroupUpdate) Equal 

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

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

func (*ComputeConfigScalingGroupUpdate) GetScalingGroup 

func (x *ComputeConfigScalingGroupUpdate) GetScalingGroup() *ComputeConfigScalingGroup

func (*ComputeConfigScalingGroupUpdate) GetUpdateMask 

func (x *ComputeConfigScalingGroupUpdate) GetUpdateMask() *fieldmaskpb.FieldMask

func (*ComputeConfigScalingGroupUpdate) Marshal 

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

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

func (*ComputeConfigScalingGroupUpdate) ProtoMessage 

func (*ComputeConfigScalingGroupUpdate) ProtoMessage()

func (*ComputeConfigScalingGroupUpdate) ProtoReflect 

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

func (*ComputeConfigScalingGroupUpdate) Reset 

func (x *ComputeConfigScalingGroupUpdate) Reset()

func (*ComputeConfigScalingGroupUpdate) Size 

func (val *ComputeConfigScalingGroupUpdate) Size() int

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

func (*ComputeConfigScalingGroupUpdate) String 

func (x *ComputeConfigScalingGroupUpdate) String() string

func (*ComputeConfigScalingGroupUpdate) Unmarshal 

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

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

type ComputeConfigSummary 

type ComputeConfigSummary struct {
	ScalingGroups map[string]*ComputeConfigScalingGroupSummary `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

A subset of information in ComputeConfig optimized for list views.

func (*ComputeConfigSummary) Descriptor deprecated 

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

Deprecated: Use ComputeConfigSummary.ProtoReflect.Descriptor instead.

func (*ComputeConfigSummary) Equal 

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

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

func (*ComputeConfigSummary) GetScalingGroups 

func (x *ComputeConfigSummary) GetScalingGroups() map[string]*ComputeConfigScalingGroupSummary

func (*ComputeConfigSummary) Marshal 

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

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

func (*ComputeConfigSummary) ProtoMessage 

func (*ComputeConfigSummary) ProtoMessage()

func (*ComputeConfigSummary) ProtoReflect 

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

func (*ComputeConfigSummary) Reset 

func (x *ComputeConfigSummary) Reset()

func (*ComputeConfigSummary) Size 

func (val *ComputeConfigSummary) Size() int

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

func (*ComputeConfigSummary) String 

func (x *ComputeConfigSummary) String() string

func (*ComputeConfigSummary) Unmarshal 

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

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

type ComputeProvider 

type ComputeProvider struct {

	// Type of the compute provider. This string is implementation-specific and
	// can be used by implementations to understand how to interpret the
	// contents of the provider_details field.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Contains provider-specific instructions and configuration.
	// For server-implemented providers, use the SDK's default content
	// converter to ensure the server can understand it.
	// For remote-implemented providers, you might use your own content
	// converters according to what the remote endpoints understand.
	Details *v1.Payload `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// Optional. If the compute provider is a Nexus service, this should point
	// there.
	NexusEndpoint string `protobuf:"bytes,10,opt,name=nexus_endpoint,json=nexusEndpoint,proto3" json:"nexus_endpoint,omitempty"`
	// contains filtered or unexported fields
}

ComputeProvider stores information used by a worker control plane controller to respond to worker lifecycle events. For example, when a Task is received on a TaskQueue that has no active pollers, a serverless worker lifecycle controller might need to invoke an AWS Lambda Function that itself ends up calling the SDK's worker.New() function.

func (*ComputeProvider) Descriptor deprecated 

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

Deprecated: Use ComputeProvider.ProtoReflect.Descriptor instead.

func (*ComputeProvider) Equal 

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

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

func (*ComputeProvider) GetDetails 

func (x *ComputeProvider) GetDetails() *v1.Payload

func (*ComputeProvider) GetNexusEndpoint 

func (x *ComputeProvider) GetNexusEndpoint() string

func (*ComputeProvider) GetType 

func (x *ComputeProvider) GetType() string

func (*ComputeProvider) Marshal 

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

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

func (*ComputeProvider) ProtoMessage 

func (*ComputeProvider) ProtoMessage()

func (*ComputeProvider) ProtoReflect 

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

func (*ComputeProvider) Reset 

func (x *ComputeProvider) Reset()

func (*ComputeProvider) Size 

func (val *ComputeProvider) Size() int

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

func (*ComputeProvider) String 

func (x *ComputeProvider) String() string

func (*ComputeProvider) Unmarshal 

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

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

type ComputeScaler 

type ComputeScaler struct {

	// Type of the compute scaler. this string is implementation-specific and
	// can be used by implementations to understand how to interpret the
	// contents of the scaler_details field.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Contains scaler-specific instructions and configuration.
	// For server-implemented scalers, use the SDK's default data
	// converter to ensure the server can understand it.
	// For remote-implemented scalers, you might use your own data
	// converters according to what the remote endpoints understand.
	Details *v1.Payload `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

ComputeScaler instructs the Temporal Service when to scale up or down the number of Workers that comprise a WorkerDeployment.

func (*ComputeScaler) Descriptor deprecated 

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

Deprecated: Use ComputeScaler.ProtoReflect.Descriptor instead.

func (*ComputeScaler) Equal 

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

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

func (*ComputeScaler) GetDetails 

func (x *ComputeScaler) GetDetails() *v1.Payload

func (*ComputeScaler) GetType 

func (x *ComputeScaler) GetType() string

func (*ComputeScaler) Marshal 

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

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

func (*ComputeScaler) ProtoMessage 

func (*ComputeScaler) ProtoMessage()

func (*ComputeScaler) ProtoReflect 

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

func (*ComputeScaler) Reset 

func (x *ComputeScaler) Reset()

func (*ComputeScaler) Size 

func (val *ComputeScaler) Size() int

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

func (*ComputeScaler) String 

func (x *ComputeScaler) String() string

func (*ComputeScaler) Unmarshal 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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