Enum value maps for AttachedDisk_DiskMode.
var (
AttachedDisk_DiskMode_name = map[int32]string{
0: "DISK_MODE_UNSPECIFIED",
1: "READ_WRITE",
2: "READ_ONLY",
}
AttachedDisk_DiskMode_value = map[string]int32{
"DISK_MODE_UNSPECIFIED": 0,
"READ_WRITE": 1,
"READ_ONLY": 2,
}
)
Enum value maps for Node_State.
var (
Node_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "READY",
3: "RESTARTING",
4: "REIMAGING",
5: "DELETING",
6: "REPAIRING",
8: "STOPPED",
9: "STOPPING",
10: "STARTING",
11: "PREEMPTED",
12: "TERMINATED",
13: "HIDING",
14: "HIDDEN",
15: "UNHIDING",
}
Node_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"READY": 2,
"RESTARTING": 3,
"REIMAGING": 4,
"DELETING": 5,
"REPAIRING": 6,
"STOPPED": 8,
"STOPPING": 9,
"STARTING": 10,
"PREEMPTED": 11,
"TERMINATED": 12,
"HIDING": 13,
"HIDDEN": 14,
"UNHIDING": 15,
}
)
Enum value maps for Node_Health.
var (
Node_Health_name = map[int32]string{
0: "HEALTH_UNSPECIFIED",
1: "HEALTHY",
3: "TIMEOUT",
4: "UNHEALTHY_TENSORFLOW",
5: "UNHEALTHY_MAINTENANCE",
}
Node_Health_value = map[string]int32{
"HEALTH_UNSPECIFIED": 0,
"HEALTHY": 1,
"TIMEOUT": 3,
"UNHEALTHY_TENSORFLOW": 4,
"UNHEALTHY_MAINTENANCE": 5,
}
)
Enum value maps for Node_ApiVersion.
var (
Node_ApiVersion_name = map[int32]string{
0: "API_VERSION_UNSPECIFIED",
1: "V1_ALPHA1",
2: "V1",
3: "V2_ALPHA1",
}
Node_ApiVersion_value = map[string]int32{
"API_VERSION_UNSPECIFIED": 0,
"V1_ALPHA1": 1,
"V1": 2,
"V2_ALPHA1": 3,
}
)
Enum value maps for QueuedResourceState_State.
var (
QueuedResourceState_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "ACCEPTED",
3: "PROVISIONING",
4: "FAILED",
5: "DELETING",
6: "ACTIVE",
7: "SUSPENDING",
8: "SUSPENDED",
}
QueuedResourceState_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"ACCEPTED": 2,
"PROVISIONING": 3,
"FAILED": 4,
"DELETING": 5,
"ACTIVE": 6,
"SUSPENDING": 7,
"SUSPENDED": 8,
}
)
Enum value maps for Symptom_SymptomType.
var (
Symptom_SymptomType_name = map[int32]string{
0: "SYMPTOM_TYPE_UNSPECIFIED",
1: "LOW_MEMORY",
2: "OUT_OF_MEMORY",
3: "EXECUTE_TIMED_OUT",
4: "MESH_BUILD_FAIL",
5: "HBM_OUT_OF_MEMORY",
6: "PROJECT_ABUSE",
}
Symptom_SymptomType_value = map[string]int32{
"SYMPTOM_TYPE_UNSPECIFIED": 0,
"LOW_MEMORY": 1,
"OUT_OF_MEMORY": 2,
"EXECUTE_TIMED_OUT": 3,
"MESH_BUILD_FAIL": 4,
"HBM_OUT_OF_MEMORY": 5,
"PROJECT_ABUSE": 6,
}
)
var File_google_cloud_tpu_v2alpha1_cloud_tpu_proto protoreflect.FileDescriptor
func RegisterTpuServer(s *grpc.Server, srv TpuServer)
A accelerator type that a Node can be configured with.
type AcceleratorType struct {
// The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The accelerator type.
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*AcceleratorType) Descriptor() ([]byte, []int)
Deprecated: Use AcceleratorType.ProtoReflect.Descriptor instead.
func (x *AcceleratorType) GetName() string
func (x *AcceleratorType) GetType() string
func (*AcceleratorType) ProtoMessage()
func (x *AcceleratorType) ProtoReflect() protoreflect.Message
func (x *AcceleratorType) Reset()
func (x *AcceleratorType) String() string
An access config attached to the TPU worker.
type AccessConfig struct {
// Output only. An external IP address associated with the TPU worker.
ExternalIp string `protobuf:"bytes,1,opt,name=external_ip,json=externalIp,proto3" json:"external_ip,omitempty"`
// contains filtered or unexported fields
}
func (*AccessConfig) Descriptor() ([]byte, []int)
Deprecated: Use AccessConfig.ProtoReflect.Descriptor instead.
func (x *AccessConfig) GetExternalIp() string
func (*AccessConfig) ProtoMessage()
func (x *AccessConfig) ProtoReflect() protoreflect.Message
func (x *AccessConfig) Reset()
func (x *AccessConfig) String() string
A node-attached disk resource. Next ID: 8;
type AttachedDisk struct {
// Specifies the full path to an existing disk.
// For example: "projects/my-project/zones/us-central1-c/disks/my-disk".
SourceDisk string `protobuf:"bytes,3,opt,name=source_disk,json=sourceDisk,proto3" json:"source_disk,omitempty"`
// The mode in which to attach this disk.
// If not specified, the default is READ_WRITE mode.
// Only applicable to data_disks.
Mode AttachedDisk_DiskMode `protobuf:"varint,4,opt,name=mode,proto3,enum=google.cloud.tpu.v2alpha1.AttachedDisk_DiskMode" json:"mode,omitempty"`
// contains filtered or unexported fields
}
func (*AttachedDisk) Descriptor() ([]byte, []int)
Deprecated: Use AttachedDisk.ProtoReflect.Descriptor instead.
func (x *AttachedDisk) GetMode() AttachedDisk_DiskMode
func (x *AttachedDisk) GetSourceDisk() string
func (*AttachedDisk) ProtoMessage()
func (x *AttachedDisk) ProtoReflect() protoreflect.Message
func (x *AttachedDisk) Reset()
func (x *AttachedDisk) String() string
The different mode of the attached disk.
type AttachedDisk_DiskMode int32
const (
// The disk mode is not known/set.
AttachedDisk_DISK_MODE_UNSPECIFIED AttachedDisk_DiskMode = 0
// Attaches the disk in read-write mode. Only one TPU node can attach a disk
// in read-write mode at a time.
AttachedDisk_READ_WRITE AttachedDisk_DiskMode = 1
// Attaches the disk in read-only mode. Multiple TPU nodes can attach
// a disk in read-only mode at a time.
AttachedDisk_READ_ONLY AttachedDisk_DiskMode = 2
)
func (AttachedDisk_DiskMode) Descriptor() protoreflect.EnumDescriptor
func (x AttachedDisk_DiskMode) Enum() *AttachedDisk_DiskMode
func (AttachedDisk_DiskMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use AttachedDisk_DiskMode.Descriptor instead.
func (x AttachedDisk_DiskMode) Number() protoreflect.EnumNumber
func (x AttachedDisk_DiskMode) String() string
func (AttachedDisk_DiskMode) Type() protoreflect.EnumType
Request for [CreateNode][google.cloud.tpu.v2alpha1.Tpu.CreateNode].
type CreateNodeRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The unqualified resource name.
NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// Required. The node.
Node *Node `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
// Idempotent request UUID.
RequestId string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateNodeRequest.ProtoReflect.Descriptor instead.
func (x *CreateNodeRequest) GetNode() *Node
func (x *CreateNodeRequest) GetNodeId() string
func (x *CreateNodeRequest) GetParent() string
func (x *CreateNodeRequest) GetRequestId() string
func (*CreateNodeRequest) ProtoMessage()
func (x *CreateNodeRequest) ProtoReflect() protoreflect.Message
func (x *CreateNodeRequest) Reset()
func (x *CreateNodeRequest) String() string
Request for [CreateQueuedResource][google.cloud.tpu.v2alpha1.Tpu.CreateQueuedResource].
type CreateQueuedResourceRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The unqualified resource name. Should follow the ^[A-Za-z0-9_.~+%-]+$
// regex format.
QueuedResourceId string `protobuf:"bytes,2,opt,name=queued_resource_id,json=queuedResourceId,proto3" json:"queued_resource_id,omitempty"`
// Required. The queued resource.
QueuedResource *QueuedResource `protobuf:"bytes,3,opt,name=queued_resource,json=queuedResource,proto3" json:"queued_resource,omitempty"`
// Idempotent request UUID.
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*CreateQueuedResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateQueuedResourceRequest.ProtoReflect.Descriptor instead.
func (x *CreateQueuedResourceRequest) GetParent() string
func (x *CreateQueuedResourceRequest) GetQueuedResource() *QueuedResource
func (x *CreateQueuedResourceRequest) GetQueuedResourceId() string
func (x *CreateQueuedResourceRequest) GetRequestId() string
func (*CreateQueuedResourceRequest) ProtoMessage()
func (x *CreateQueuedResourceRequest) ProtoReflect() protoreflect.Message
func (x *CreateQueuedResourceRequest) Reset()
func (x *CreateQueuedResourceRequest) String() string
Request for [DeleteNode][google.cloud.tpu.v2alpha1.Tpu.DeleteNode].
type DeleteNodeRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Idempotent request UUID.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNodeRequest.ProtoReflect.Descriptor instead.
func (x *DeleteNodeRequest) GetName() string
func (x *DeleteNodeRequest) GetRequestId() string
func (*DeleteNodeRequest) ProtoMessage()
func (x *DeleteNodeRequest) ProtoReflect() protoreflect.Message
func (x *DeleteNodeRequest) Reset()
func (x *DeleteNodeRequest) String() string
Request for [DeleteQueuedResource][google.cloud.tpu.v2alpha1.Tpu.DeleteQueuedResource].
type DeleteQueuedResourceRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Idempotent request UUID.
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteQueuedResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteQueuedResourceRequest.ProtoReflect.Descriptor instead.
func (x *DeleteQueuedResourceRequest) GetName() string
func (x *DeleteQueuedResourceRequest) GetRequestId() string
func (*DeleteQueuedResourceRequest) ProtoMessage()
func (x *DeleteQueuedResourceRequest) ProtoReflect() protoreflect.Message
func (x *DeleteQueuedResourceRequest) Reset()
func (x *DeleteQueuedResourceRequest) String() string
Request for [GenerateServiceIdentity][google.cloud.tpu.v2alpha1.Tpu.GenerateServiceIdentity].
type GenerateServiceIdentityRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// contains filtered or unexported fields
}
func (*GenerateServiceIdentityRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenerateServiceIdentityRequest.ProtoReflect.Descriptor instead.
func (x *GenerateServiceIdentityRequest) GetParent() string
func (*GenerateServiceIdentityRequest) ProtoMessage()
func (x *GenerateServiceIdentityRequest) ProtoReflect() protoreflect.Message
func (x *GenerateServiceIdentityRequest) Reset()
func (x *GenerateServiceIdentityRequest) String() string
Response for [GenerateServiceIdentity][google.cloud.tpu.v2alpha1.Tpu.GenerateServiceIdentity].
type GenerateServiceIdentityResponse struct {
// ServiceIdentity that was created or retrieved.
Identity *ServiceIdentity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// contains filtered or unexported fields
}
func (*GenerateServiceIdentityResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenerateServiceIdentityResponse.ProtoReflect.Descriptor instead.
func (x *GenerateServiceIdentityResponse) GetIdentity() *ServiceIdentity
func (*GenerateServiceIdentityResponse) ProtoMessage()
func (x *GenerateServiceIdentityResponse) ProtoReflect() protoreflect.Message
func (x *GenerateServiceIdentityResponse) Reset()
func (x *GenerateServiceIdentityResponse) String() string
Request for [GetAcceleratorType][google.cloud.tpu.v2alpha1.Tpu.GetAcceleratorType].
type GetAcceleratorTypeRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetAcceleratorTypeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAcceleratorTypeRequest.ProtoReflect.Descriptor instead.
func (x *GetAcceleratorTypeRequest) GetName() string
func (*GetAcceleratorTypeRequest) ProtoMessage()
func (x *GetAcceleratorTypeRequest) ProtoReflect() protoreflect.Message
func (x *GetAcceleratorTypeRequest) Reset()
func (x *GetAcceleratorTypeRequest) String() string
Request for [GetGuestAttributes][google.cloud.tpu.v2alpha1.Tpu.GetGuestAttributes].
type GetGuestAttributesRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The guest attributes path to be queried.
QueryPath string `protobuf:"bytes,2,opt,name=query_path,json=queryPath,proto3" json:"query_path,omitempty"`
// The 0-based worker ID. If it is empty, all workers' GuestAttributes will be
// returned.
WorkerIds []string `protobuf:"bytes,3,rep,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
// contains filtered or unexported fields
}
func (*GetGuestAttributesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetGuestAttributesRequest.ProtoReflect.Descriptor instead.
func (x *GetGuestAttributesRequest) GetName() string
func (x *GetGuestAttributesRequest) GetQueryPath() string
func (x *GetGuestAttributesRequest) GetWorkerIds() []string
func (*GetGuestAttributesRequest) ProtoMessage()
func (x *GetGuestAttributesRequest) ProtoReflect() protoreflect.Message
func (x *GetGuestAttributesRequest) Reset()
func (x *GetGuestAttributesRequest) String() string
Response for [GetGuestAttributes][google.cloud.tpu.v2alpha1.Tpu.GetGuestAttributes].
type GetGuestAttributesResponse struct {
// The guest attributes for the TPU workers.
GuestAttributes []*GuestAttributes `protobuf:"bytes,1,rep,name=guest_attributes,json=guestAttributes,proto3" json:"guest_attributes,omitempty"`
// contains filtered or unexported fields
}
func (*GetGuestAttributesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetGuestAttributesResponse.ProtoReflect.Descriptor instead.
func (x *GetGuestAttributesResponse) GetGuestAttributes() []*GuestAttributes
func (*GetGuestAttributesResponse) ProtoMessage()
func (x *GetGuestAttributesResponse) ProtoReflect() protoreflect.Message
func (x *GetGuestAttributesResponse) Reset()
func (x *GetGuestAttributesResponse) String() string
Request for [GetNode][google.cloud.tpu.v2alpha1.Tpu.GetNode].
type GetNodeRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.
func (x *GetNodeRequest) GetName() string
func (*GetNodeRequest) ProtoMessage()
func (x *GetNodeRequest) ProtoReflect() protoreflect.Message
func (x *GetNodeRequest) Reset()
func (x *GetNodeRequest) String() string
Request for [GetQueuedResource][google.cloud.tpu.v2alpha1.Tpu.GetQueuedResource]
type GetQueuedResourceRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetQueuedResourceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetQueuedResourceRequest.ProtoReflect.Descriptor instead.
func (x *GetQueuedResourceRequest) GetName() string
func (*GetQueuedResourceRequest) ProtoMessage()
func (x *GetQueuedResourceRequest) ProtoReflect() protoreflect.Message
func (x *GetQueuedResourceRequest) Reset()
func (x *GetQueuedResourceRequest) String() string
Request for [GetRuntimeVersion][google.cloud.tpu.v2alpha1.Tpu.GetRuntimeVersion].
type GetRuntimeVersionRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetRuntimeVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRuntimeVersionRequest.ProtoReflect.Descriptor instead.
func (x *GetRuntimeVersionRequest) GetName() string
func (*GetRuntimeVersionRequest) ProtoMessage()
func (x *GetRuntimeVersionRequest) ProtoReflect() protoreflect.Message
func (x *GetRuntimeVersionRequest) Reset()
func (x *GetRuntimeVersionRequest) String() string
A guest attributes.
type GuestAttributes struct {
// The path to be queried. This can be the default namespace ('/') or a
// nested namespace ('/\<namespace\>/') or a specified key
// ('/\<namespace\>/\<key\>')
QueryPath string `protobuf:"bytes,1,opt,name=query_path,json=queryPath,proto3" json:"query_path,omitempty"`
// The value of the requested queried path.
QueryValue *GuestAttributesValue `protobuf:"bytes,2,opt,name=query_value,json=queryValue,proto3" json:"query_value,omitempty"`
// contains filtered or unexported fields
}
func (*GuestAttributes) Descriptor() ([]byte, []int)
Deprecated: Use GuestAttributes.ProtoReflect.Descriptor instead.
func (x *GuestAttributes) GetQueryPath() string
func (x *GuestAttributes) GetQueryValue() *GuestAttributesValue
func (*GuestAttributes) ProtoMessage()
func (x *GuestAttributes) ProtoReflect() protoreflect.Message
func (x *GuestAttributes) Reset()
func (x *GuestAttributes) String() string
A guest attributes namespace/key/value entry.
type GuestAttributesEntry struct {
// Namespace for the guest attribute entry.
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
// Key for the guest attribute entry.
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// Value for the guest attribute entry.
Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*GuestAttributesEntry) Descriptor() ([]byte, []int)
Deprecated: Use GuestAttributesEntry.ProtoReflect.Descriptor instead.
func (x *GuestAttributesEntry) GetKey() string
func (x *GuestAttributesEntry) GetNamespace() string
func (x *GuestAttributesEntry) GetValue() string
func (*GuestAttributesEntry) ProtoMessage()
func (x *GuestAttributesEntry) ProtoReflect() protoreflect.Message
func (x *GuestAttributesEntry) Reset()
func (x *GuestAttributesEntry) String() string
Array of guest attribute namespace/key/value tuples.
type GuestAttributesValue struct {
// The list of guest attributes entries.
Items []*GuestAttributesEntry `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
// contains filtered or unexported fields
}
func (*GuestAttributesValue) Descriptor() ([]byte, []int)
Deprecated: Use GuestAttributesValue.ProtoReflect.Descriptor instead.
func (x *GuestAttributesValue) GetItems() []*GuestAttributesEntry
func (*GuestAttributesValue) ProtoMessage()
func (x *GuestAttributesValue) ProtoReflect() protoreflect.Message
func (x *GuestAttributesValue) Reset()
func (x *GuestAttributesValue) String() string
Request for [ListAcceleratorTypes][google.cloud.tpu.v2alpha1.Tpu.ListAcceleratorTypes].
type ListAcceleratorTypesRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of items to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The next_page_token value returned from a previous List request, if any.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// List filter.
Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
// Sort results.
OrderBy string `protobuf:"bytes,6,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}
func (*ListAcceleratorTypesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListAcceleratorTypesRequest.ProtoReflect.Descriptor instead.
func (x *ListAcceleratorTypesRequest) GetFilter() string
func (x *ListAcceleratorTypesRequest) GetOrderBy() string
func (x *ListAcceleratorTypesRequest) GetPageSize() int32
func (x *ListAcceleratorTypesRequest) GetPageToken() string
func (x *ListAcceleratorTypesRequest) GetParent() string
func (*ListAcceleratorTypesRequest) ProtoMessage()
func (x *ListAcceleratorTypesRequest) ProtoReflect() protoreflect.Message
func (x *ListAcceleratorTypesRequest) Reset()
func (x *ListAcceleratorTypesRequest) String() string
Response for [ListAcceleratorTypes][google.cloud.tpu.v2alpha1.Tpu.ListAcceleratorTypes].
type ListAcceleratorTypesResponse struct {
// The listed nodes.
AcceleratorTypes []*AcceleratorType `protobuf:"bytes,1,rep,name=accelerator_types,json=acceleratorTypes,proto3" json:"accelerator_types,omitempty"`
// The next page token or empty if none.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
func (*ListAcceleratorTypesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListAcceleratorTypesResponse.ProtoReflect.Descriptor instead.
func (x *ListAcceleratorTypesResponse) GetAcceleratorTypes() []*AcceleratorType
func (x *ListAcceleratorTypesResponse) GetNextPageToken() string
func (x *ListAcceleratorTypesResponse) GetUnreachable() []string
func (*ListAcceleratorTypesResponse) ProtoMessage()
func (x *ListAcceleratorTypesResponse) ProtoReflect() protoreflect.Message
func (x *ListAcceleratorTypesResponse) Reset()
func (x *ListAcceleratorTypesResponse) String() string
Request for [ListNodes][google.cloud.tpu.v2alpha1.Tpu.ListNodes].
type ListNodesRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of items to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The next_page_token value returned from a previous List request, if any.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListNodesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.
func (x *ListNodesRequest) GetPageSize() int32
func (x *ListNodesRequest) GetPageToken() string
func (x *ListNodesRequest) GetParent() string
func (*ListNodesRequest) ProtoMessage()
func (x *ListNodesRequest) ProtoReflect() protoreflect.Message
func (x *ListNodesRequest) Reset()
func (x *ListNodesRequest) String() string
Response for [ListNodes][google.cloud.tpu.v2alpha1.Tpu.ListNodes].
type ListNodesResponse struct {
// The listed nodes.
Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
// The next page token or empty if none.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
func (*ListNodesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.
func (x *ListNodesResponse) GetNextPageToken() string
func (x *ListNodesResponse) GetNodes() []*Node
func (x *ListNodesResponse) GetUnreachable() []string
func (*ListNodesResponse) ProtoMessage()
func (x *ListNodesResponse) ProtoReflect() protoreflect.Message
func (x *ListNodesResponse) Reset()
func (x *ListNodesResponse) String() string
Request for [ListQueuedResources][google.cloud.tpu.v2alpha1.Tpu.ListQueuedResources].
type ListQueuedResourcesRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of items to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The next_page_token value returned from a previous List request, if any.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// contains filtered or unexported fields
}
func (*ListQueuedResourcesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListQueuedResourcesRequest.ProtoReflect.Descriptor instead.
func (x *ListQueuedResourcesRequest) GetPageSize() int32
func (x *ListQueuedResourcesRequest) GetPageToken() string
func (x *ListQueuedResourcesRequest) GetParent() string
func (*ListQueuedResourcesRequest) ProtoMessage()
func (x *ListQueuedResourcesRequest) ProtoReflect() protoreflect.Message
func (x *ListQueuedResourcesRequest) Reset()
func (x *ListQueuedResourcesRequest) String() string
Response for [ListQueuedResources][google.cloud.tpu.v2alpha1.Tpu.ListQueuedResources].
type ListQueuedResourcesResponse struct {
// The listed queued resources.
QueuedResources []*QueuedResource `protobuf:"bytes,1,rep,name=queued_resources,json=queuedResources,proto3" json:"queued_resources,omitempty"`
// The next page token or empty if none.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
func (*ListQueuedResourcesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListQueuedResourcesResponse.ProtoReflect.Descriptor instead.
func (x *ListQueuedResourcesResponse) GetNextPageToken() string
func (x *ListQueuedResourcesResponse) GetQueuedResources() []*QueuedResource
func (x *ListQueuedResourcesResponse) GetUnreachable() []string
func (*ListQueuedResourcesResponse) ProtoMessage()
func (x *ListQueuedResourcesResponse) ProtoReflect() protoreflect.Message
func (x *ListQueuedResourcesResponse) Reset()
func (x *ListQueuedResourcesResponse) String() string
Request for [ListRuntimeVersions][google.cloud.tpu.v2alpha1.Tpu.ListRuntimeVersions].
type ListRuntimeVersionsRequest struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The maximum number of items to return.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// The next_page_token value returned from a previous List request, if any.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// List filter.
Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
// Sort results.
OrderBy string `protobuf:"bytes,6,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}
func (*ListRuntimeVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRuntimeVersionsRequest.ProtoReflect.Descriptor instead.
func (x *ListRuntimeVersionsRequest) GetFilter() string
func (x *ListRuntimeVersionsRequest) GetOrderBy() string
func (x *ListRuntimeVersionsRequest) GetPageSize() int32
func (x *ListRuntimeVersionsRequest) GetPageToken() string
func (x *ListRuntimeVersionsRequest) GetParent() string
func (*ListRuntimeVersionsRequest) ProtoMessage()
func (x *ListRuntimeVersionsRequest) ProtoReflect() protoreflect.Message
func (x *ListRuntimeVersionsRequest) Reset()
func (x *ListRuntimeVersionsRequest) String() string
Response for [ListRuntimeVersions][google.cloud.tpu.v2alpha1.Tpu.ListRuntimeVersions].
type ListRuntimeVersionsResponse struct {
// The listed nodes.
RuntimeVersions []*RuntimeVersion `protobuf:"bytes,1,rep,name=runtime_versions,json=runtimeVersions,proto3" json:"runtime_versions,omitempty"`
// The next page token or empty if none.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}
func (*ListRuntimeVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRuntimeVersionsResponse.ProtoReflect.Descriptor instead.
func (x *ListRuntimeVersionsResponse) GetNextPageToken() string
func (x *ListRuntimeVersionsResponse) GetRuntimeVersions() []*RuntimeVersion
func (x *ListRuntimeVersionsResponse) GetUnreachable() []string
func (*ListRuntimeVersionsResponse) ProtoMessage()
func (x *ListRuntimeVersionsResponse) ProtoReflect() protoreflect.Message
func (x *ListRuntimeVersionsResponse) Reset()
func (x *ListRuntimeVersionsResponse) String() string
Network related configurations.
type NetworkConfig struct {
// The name of the network for the TPU node. It must be a preexisting Google
// Compute Engine network. If none is provided, "default" will be used.
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
// The name of the subnetwork for the TPU node. It must be a preexisting
// Google Compute Engine subnetwork. If none is provided, "default" will be
// used.
Subnetwork string `protobuf:"bytes,2,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`
// Indicates that external IP addresses would be associated with the TPU
// workers. If set to false, the specified subnetwork or network should have
// Private Google Access enabled.
EnableExternalIps bool `protobuf:"varint,3,opt,name=enable_external_ips,json=enableExternalIps,proto3" json:"enable_external_ips,omitempty"`
// Allows the TPU node to send and receive packets with non-matching
// destination or source IPs. This is required if you plan to use the TPU
// workers to forward routes.
CanIpForward bool `protobuf:"varint,4,opt,name=can_ip_forward,json=canIpForward,proto3" json:"can_ip_forward,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkConfig) Descriptor() ([]byte, []int)
Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.
func (x *NetworkConfig) GetCanIpForward() bool
func (x *NetworkConfig) GetEnableExternalIps() bool
func (x *NetworkConfig) GetNetwork() string
func (x *NetworkConfig) GetSubnetwork() string
func (*NetworkConfig) ProtoMessage()
func (x *NetworkConfig) ProtoReflect() protoreflect.Message
func (x *NetworkConfig) Reset()
func (x *NetworkConfig) String() string
A network endpoint over which a TPU worker can be reached.
type NetworkEndpoint struct {
// The internal IP address of this network endpoint.
IpAddress string `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
// The port of this network endpoint.
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// The access config for the TPU worker.
AccessConfig *AccessConfig `protobuf:"bytes,5,opt,name=access_config,json=accessConfig,proto3" json:"access_config,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkEndpoint) Descriptor() ([]byte, []int)
Deprecated: Use NetworkEndpoint.ProtoReflect.Descriptor instead.
func (x *NetworkEndpoint) GetAccessConfig() *AccessConfig
func (x *NetworkEndpoint) GetIpAddress() string
func (x *NetworkEndpoint) GetPort() int32
func (*NetworkEndpoint) ProtoMessage()
func (x *NetworkEndpoint) ProtoReflect() protoreflect.Message
func (x *NetworkEndpoint) Reset()
func (x *NetworkEndpoint) String() string
A TPU instance.
type Node struct {
// Output only. Immutable. The name of the TPU.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The user-supplied description of the TPU. Maximum of 512 characters.
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
// The type of hardware accelerators associated with this node.
AcceleratorType string `protobuf:"bytes,5,opt,name=accelerator_type,json=acceleratorType,proto3" json:"accelerator_type,omitempty"`
// Output only. The current state for the TPU Node.
State Node_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.tpu.v2alpha1.Node_State" json:"state,omitempty"`
// Output only. If this field is populated, it contains a description of why
// the TPU Node is unhealthy.
HealthDescription string `protobuf:"bytes,10,opt,name=health_description,json=healthDescription,proto3" json:"health_description,omitempty"`
// Required. The runtime version running in the Node.
RuntimeVersion string `protobuf:"bytes,11,opt,name=runtime_version,json=runtimeVersion,proto3" json:"runtime_version,omitempty"`
// Network configurations for the TPU node.
NetworkConfig *NetworkConfig `protobuf:"bytes,36,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
// The CIDR block that the TPU node will use when selecting an IP address.
// This CIDR block must be a /29 block; the Compute Engine networks API
// forbids a smaller block, and using a larger block would be wasteful (a
// node can only consume one IP address). Errors will occur if the CIDR block
// has already been used for a currently existing TPU node, the CIDR block
// conflicts with any subnetworks in the user's provided network, or the
// provided network is peered with another network that is using that CIDR
// block.
CidrBlock string `protobuf:"bytes,13,opt,name=cidr_block,json=cidrBlock,proto3" json:"cidr_block,omitempty"`
// The Google Cloud Platform Service Account to be used by the TPU node VMs.
// If None is specified, the default compute service account will be used.
ServiceAccount *ServiceAccount `protobuf:"bytes,37,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
// Output only. The time when the node was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// The scheduling options for this node.
SchedulingConfig *SchedulingConfig `protobuf:"bytes,17,opt,name=scheduling_config,json=schedulingConfig,proto3" json:"scheduling_config,omitempty"`
// Output only. The network endpoints where TPU workers can be accessed and
// sent work. It is recommended that runtime clients of the node reach out
// to the 0th entry in this map first.
NetworkEndpoints []*NetworkEndpoint `protobuf:"bytes,21,rep,name=network_endpoints,json=networkEndpoints,proto3" json:"network_endpoints,omitempty"`
// The health status of the TPU node.
Health Node_Health `protobuf:"varint,22,opt,name=health,proto3,enum=google.cloud.tpu.v2alpha1.Node_Health" json:"health,omitempty"`
// Resource labels to represent user-provided metadata.
Labels map[string]string `protobuf:"bytes,24,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Custom metadata to apply to the TPU Node.
// Can set startup-script and shutdown-script
Metadata map[string]string `protobuf:"bytes,34,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
// Tags to apply to the TPU Node. Tags are used to identify valid sources or
// targets for network firewalls.
Tags []string `protobuf:"bytes,40,rep,name=tags,proto3" json:"tags,omitempty"`
// Output only. The unique identifier for the TPU Node.
Id int64 `protobuf:"varint,33,opt,name=id,proto3" json:"id,omitempty"`
// The additional data disks for the Node.
DataDisks []*AttachedDisk `protobuf:"bytes,41,rep,name=data_disks,json=dataDisks,proto3" json:"data_disks,omitempty"`
// Output only. The API version that created this Node.
ApiVersion Node_ApiVersion `protobuf:"varint,38,opt,name=api_version,json=apiVersion,proto3,enum=google.cloud.tpu.v2alpha1.Node_ApiVersion" json:"api_version,omitempty"`
// Output only. The Symptoms that have occurred to the TPU Node.
Symptoms []*Symptom `protobuf:"bytes,39,rep,name=symptoms,proto3" json:"symptoms,omitempty"`
// Output only. The qualified name of the QueuedResource that requested this
// Node.
QueuedResource string `protobuf:"bytes,43,opt,name=queued_resource,json=queuedResource,proto3" json:"queued_resource,omitempty"`
// Shielded Instance options.
ShieldedInstanceConfig *ShieldedInstanceConfig `protobuf:"bytes,45,opt,name=shielded_instance_config,json=shieldedInstanceConfig,proto3" json:"shielded_instance_config,omitempty"`
// contains filtered or unexported fields
}
func (*Node) Descriptor() ([]byte, []int)
Deprecated: Use Node.ProtoReflect.Descriptor instead.
func (x *Node) GetAcceleratorType() string
func (x *Node) GetApiVersion() Node_ApiVersion
func (x *Node) GetCidrBlock() string
func (x *Node) GetCreateTime() *timestamppb.Timestamp
func (x *Node) GetDataDisks() []*AttachedDisk
func (x *Node) GetDescription() string
func (x *Node) GetHealth() Node_Health
func (x *Node) GetHealthDescription() string
func (x *Node) GetId() int64
func (x *Node) GetLabels() map[string]string
func (x *Node) GetMetadata() map[string]string
func (x *Node) GetName() string
func (x *Node) GetNetworkConfig() *NetworkConfig
func (x *Node) GetNetworkEndpoints() []*NetworkEndpoint
func (x *Node) GetQueuedResource() string
func (x *Node) GetRuntimeVersion() string
func (x *Node) GetSchedulingConfig() *SchedulingConfig
func (x *Node) GetServiceAccount() *ServiceAccount
func (x *Node) GetShieldedInstanceConfig() *ShieldedInstanceConfig
func (x *Node) GetState() Node_State
func (x *Node) GetSymptoms() []*Symptom
func (x *Node) GetTags() []string
func (*Node) ProtoMessage()
func (x *Node) ProtoReflect() protoreflect.Message
func (x *Node) Reset()
func (x *Node) String() string
TPU API Version.
type Node_ApiVersion int32
const (
// API version is unknown.
Node_API_VERSION_UNSPECIFIED Node_ApiVersion = 0
// TPU API V1Alpha1 version.
Node_V1_ALPHA1 Node_ApiVersion = 1
// TPU API V1 version.
Node_V1 Node_ApiVersion = 2
// TPU API V2Alpha1 version.
Node_V2_ALPHA1 Node_ApiVersion = 3
)
func (Node_ApiVersion) Descriptor() protoreflect.EnumDescriptor
func (x Node_ApiVersion) Enum() *Node_ApiVersion
func (Node_ApiVersion) EnumDescriptor() ([]byte, []int)
Deprecated: Use Node_ApiVersion.Descriptor instead.
func (x Node_ApiVersion) Number() protoreflect.EnumNumber
func (x Node_ApiVersion) String() string
func (Node_ApiVersion) Type() protoreflect.EnumType
Health defines the status of a TPU node as reported by Health Monitor.
type Node_Health int32
const (
// Health status is unknown: not initialized or failed to retrieve.
Node_HEALTH_UNSPECIFIED Node_Health = 0
// The resource is healthy.
Node_HEALTHY Node_Health = 1
// The resource is unresponsive.
Node_TIMEOUT Node_Health = 3
// The in-guest ML stack is unhealthy.
Node_UNHEALTHY_TENSORFLOW Node_Health = 4
// The node is under maintenance/priority boost caused rescheduling and
// will resume running once rescheduled.
Node_UNHEALTHY_MAINTENANCE Node_Health = 5
)
func (Node_Health) Descriptor() protoreflect.EnumDescriptor
func (x Node_Health) Enum() *Node_Health
func (Node_Health) EnumDescriptor() ([]byte, []int)
Deprecated: Use Node_Health.Descriptor instead.
func (x Node_Health) Number() protoreflect.EnumNumber
func (x Node_Health) String() string
func (Node_Health) Type() protoreflect.EnumType
Represents the different states of a TPU node during its lifecycle.
type Node_State int32
const (
// TPU node state is not known/set.
Node_STATE_UNSPECIFIED Node_State = 0
// TPU node is being created.
Node_CREATING Node_State = 1
// TPU node has been created.
Node_READY Node_State = 2
// TPU node is restarting.
Node_RESTARTING Node_State = 3
// TPU node is undergoing reimaging.
Node_REIMAGING Node_State = 4
// TPU node is being deleted.
Node_DELETING Node_State = 5
// TPU node is being repaired and may be unusable. Details can be
// found in the 'help_description' field.
Node_REPAIRING Node_State = 6
// TPU node is stopped.
Node_STOPPED Node_State = 8
// TPU node is currently stopping.
Node_STOPPING Node_State = 9
// TPU node is currently starting.
Node_STARTING Node_State = 10
// TPU node has been preempted. Only applies to Preemptible TPU Nodes.
Node_PREEMPTED Node_State = 11
// TPU node has been terminated due to maintenance or has reached the end of
// its life cycle (for preemptible nodes).
Node_TERMINATED Node_State = 12
// TPU node is currently hiding.
Node_HIDING Node_State = 13
// TPU node has been hidden.
Node_HIDDEN Node_State = 14
// TPU node is currently unhiding.
Node_UNHIDING Node_State = 15
)
func (Node_State) Descriptor() protoreflect.EnumDescriptor
func (x Node_State) Enum() *Node_State
func (Node_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Node_State.Descriptor instead.
func (x Node_State) Number() protoreflect.EnumNumber
func (x Node_State) String() string
func (Node_State) Type() protoreflect.EnumType
Metadata describing an [Operation][google.longrunning.Operation]
type OperationMetadata struct {
// The time the operation was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// The time the operation finished running.
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Target of the operation - for example
// projects/project-1/connectivityTests/test-1
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Name of the verb executed by the operation.
Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Human-readable status of the operation, if any.
StatusDetail string `protobuf:"bytes,5,opt,name=status_detail,json=statusDetail,proto3" json:"status_detail,omitempty"`
// Specifies if cancellation was requested for the operation.
CancelRequested bool `protobuf:"varint,6,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
// API version.
ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// contains filtered or unexported fields
}
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (x *OperationMetadata) GetApiVersion() string
func (x *OperationMetadata) GetCancelRequested() bool
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (x *OperationMetadata) GetStatusDetail() string
func (x *OperationMetadata) GetTarget() string
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage()
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (x *OperationMetadata) Reset()
func (x *OperationMetadata) String() string
A QueuedResource represents a request for resources that will be placed in a queue and fulfilled when the necessary resources are available.
type QueuedResource struct {
// Output only. Immutable. The name of the QueuedResource.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Resource specification.
//
// Types that are assignable to Resource:
//
// *QueuedResource_Tpu_
Resource isQueuedResource_Resource `protobuf_oneof:"resource"`
// Tier specifies the required tier.
//
// Types that are assignable to Tier:
//
// *QueuedResource_BestEffort_
// *QueuedResource_Guaranteed_
Tier isQueuedResource_Tier `protobuf_oneof:"tier"`
// The queueing policy of the QueuedRequest.
QueueingPolicy *QueuedResource_QueueingPolicy `protobuf:"bytes,5,opt,name=queueing_policy,json=queueingPolicy,proto3" json:"queueing_policy,omitempty"`
// Output only. State of the QueuedResource request
State *QueuedResourceState `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
// contains filtered or unexported fields
}
func (*QueuedResource) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResource.ProtoReflect.Descriptor instead.
func (x *QueuedResource) GetBestEffort() *QueuedResource_BestEffort
func (x *QueuedResource) GetGuaranteed() *QueuedResource_Guaranteed
func (x *QueuedResource) GetName() string
func (x *QueuedResource) GetQueueingPolicy() *QueuedResource_QueueingPolicy
func (m *QueuedResource) GetResource() isQueuedResource_Resource
func (x *QueuedResource) GetState() *QueuedResourceState
func (m *QueuedResource) GetTier() isQueuedResource_Tier
func (x *QueuedResource) GetTpu() *QueuedResource_Tpu
func (*QueuedResource) ProtoMessage()
func (x *QueuedResource) ProtoReflect() protoreflect.Message
func (x *QueuedResource) Reset()
func (x *QueuedResource) String() string
QueuedResourceState defines the details of the QueuedResource request.
type QueuedResourceState struct {
// State of the QueuedResource request.
State QueuedResourceState_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.cloud.tpu.v2alpha1.QueuedResourceState_State" json:"state,omitempty"`
// Further data for the state.
//
// Types that are assignable to StateData:
//
// *QueuedResourceState_CreatingData_
// *QueuedResourceState_AcceptedData_
// *QueuedResourceState_ProvisioningData_
// *QueuedResourceState_FailedData_
// *QueuedResourceState_DeletingData_
// *QueuedResourceState_ActiveData_
// *QueuedResourceState_SuspendingData_
// *QueuedResourceState_SuspendedData_
StateData isQueuedResourceState_StateData `protobuf_oneof:"state_data"`
// contains filtered or unexported fields
}
func (*QueuedResourceState) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState.ProtoReflect.Descriptor instead.
func (x *QueuedResourceState) GetAcceptedData() *QueuedResourceState_AcceptedData
func (x *QueuedResourceState) GetActiveData() *QueuedResourceState_ActiveData
func (x *QueuedResourceState) GetCreatingData() *QueuedResourceState_CreatingData
func (x *QueuedResourceState) GetDeletingData() *QueuedResourceState_DeletingData
func (x *QueuedResourceState) GetFailedData() *QueuedResourceState_FailedData
func (x *QueuedResourceState) GetProvisioningData() *QueuedResourceState_ProvisioningData
func (x *QueuedResourceState) GetState() QueuedResourceState_State
func (m *QueuedResourceState) GetStateData() isQueuedResourceState_StateData
func (x *QueuedResourceState) GetSuspendedData() *QueuedResourceState_SuspendedData
func (x *QueuedResourceState) GetSuspendingData() *QueuedResourceState_SuspendingData
func (*QueuedResourceState) ProtoMessage()
func (x *QueuedResourceState) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState) Reset()
func (x *QueuedResourceState) String() string
Further data for the accepted state.
type QueuedResourceState_AcceptedData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_AcceptedData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_AcceptedData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_AcceptedData) ProtoMessage()
func (x *QueuedResourceState_AcceptedData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_AcceptedData) Reset()
func (x *QueuedResourceState_AcceptedData) String() string
type QueuedResourceState_AcceptedData_ struct {
// Further data for the accepted state.
AcceptedData *QueuedResourceState_AcceptedData `protobuf:"bytes,3,opt,name=accepted_data,json=acceptedData,proto3,oneof"`
}
Further data for the active state.
type QueuedResourceState_ActiveData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_ActiveData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_ActiveData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_ActiveData) ProtoMessage()
func (x *QueuedResourceState_ActiveData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_ActiveData) Reset()
func (x *QueuedResourceState_ActiveData) String() string
type QueuedResourceState_ActiveData_ struct {
// Further data for the active state.
ActiveData *QueuedResourceState_ActiveData `protobuf:"bytes,7,opt,name=active_data,json=activeData,proto3,oneof"`
}
Further data for the creating state.
type QueuedResourceState_CreatingData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_CreatingData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_CreatingData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_CreatingData) ProtoMessage()
func (x *QueuedResourceState_CreatingData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_CreatingData) Reset()
func (x *QueuedResourceState_CreatingData) String() string
type QueuedResourceState_CreatingData_ struct {
// Further data for the creating state.
CreatingData *QueuedResourceState_CreatingData `protobuf:"bytes,2,opt,name=creating_data,json=creatingData,proto3,oneof"`
}
Further data for the deleting state.
type QueuedResourceState_DeletingData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_DeletingData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_DeletingData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_DeletingData) ProtoMessage()
func (x *QueuedResourceState_DeletingData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_DeletingData) Reset()
func (x *QueuedResourceState_DeletingData) String() string
type QueuedResourceState_DeletingData_ struct {
// Further data for the deleting state.
DeletingData *QueuedResourceState_DeletingData `protobuf:"bytes,6,opt,name=deleting_data,json=deletingData,proto3,oneof"`
}
Further data for the failed state.
type QueuedResourceState_FailedData struct {
// The error that caused the queued resource to enter the FAILED state.
Error *status.Status `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*QueuedResourceState_FailedData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_FailedData.ProtoReflect.Descriptor instead.
func (x *QueuedResourceState_FailedData) GetError() *status.Status
func (*QueuedResourceState_FailedData) ProtoMessage()
func (x *QueuedResourceState_FailedData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_FailedData) Reset()
func (x *QueuedResourceState_FailedData) String() string
type QueuedResourceState_FailedData_ struct {
// Further data for the failed state.
FailedData *QueuedResourceState_FailedData `protobuf:"bytes,5,opt,name=failed_data,json=failedData,proto3,oneof"`
}
Further data for the provisioning state.
type QueuedResourceState_ProvisioningData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_ProvisioningData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_ProvisioningData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_ProvisioningData) ProtoMessage()
func (x *QueuedResourceState_ProvisioningData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_ProvisioningData) Reset()
func (x *QueuedResourceState_ProvisioningData) String() string
type QueuedResourceState_ProvisioningData_ struct {
// Further data for the provisioning state.
ProvisioningData *QueuedResourceState_ProvisioningData `protobuf:"bytes,4,opt,name=provisioning_data,json=provisioningData,proto3,oneof"`
}
Output only state of the request
type QueuedResourceState_State int32
const (
// State of the QueuedResource request is not known/set.
QueuedResourceState_STATE_UNSPECIFIED QueuedResourceState_State = 0
// The QueuedResource request has been received. We're still working on
// determining if we will be able to honor this request.
QueuedResourceState_CREATING QueuedResourceState_State = 1
// The QueuedResource request has passed initial validation/admission
// control and has been persisted in the queue.
QueuedResourceState_ACCEPTED QueuedResourceState_State = 2
// The QueuedResource request has been selected. The
// associated resources are currently being provisioned (or very soon
// will begin provisioning).
QueuedResourceState_PROVISIONING QueuedResourceState_State = 3
// The request could not be completed. This may be due to some
// late-discovered problem with the request itself, or due to
// unavailability of resources within the constraints of the request
// (e.g., the 'valid until' start timing constraint expired).
QueuedResourceState_FAILED QueuedResourceState_State = 4
// The QueuedResource is being deleted.
QueuedResourceState_DELETING QueuedResourceState_State = 5
// The resources specified in the QueuedResource request have been
// provisioned and are ready for use by the end-user/consumer.
QueuedResourceState_ACTIVE QueuedResourceState_State = 6
// The resources specified in the QueuedResource request are being
// deleted. This may have been initiated by the user, or
// the Cloud TPU service. Inspect the state data for more details.
QueuedResourceState_SUSPENDING QueuedResourceState_State = 7
// The resources specified in the QueuedResource request have been
// deleted.
QueuedResourceState_SUSPENDED QueuedResourceState_State = 8
)
func (QueuedResourceState_State) Descriptor() protoreflect.EnumDescriptor
func (x QueuedResourceState_State) Enum() *QueuedResourceState_State
func (QueuedResourceState_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_State.Descriptor instead.
func (x QueuedResourceState_State) Number() protoreflect.EnumNumber
func (x QueuedResourceState_State) String() string
func (QueuedResourceState_State) Type() protoreflect.EnumType
Further data for the suspended state.
type QueuedResourceState_SuspendedData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_SuspendedData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_SuspendedData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_SuspendedData) ProtoMessage()
func (x *QueuedResourceState_SuspendedData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_SuspendedData) Reset()
func (x *QueuedResourceState_SuspendedData) String() string
type QueuedResourceState_SuspendedData_ struct {
// Further data for the suspended state.
SuspendedData *QueuedResourceState_SuspendedData `protobuf:"bytes,9,opt,name=suspended_data,json=suspendedData,proto3,oneof"`
}
Further data for the suspending state.
type QueuedResourceState_SuspendingData struct {
// contains filtered or unexported fields
}
func (*QueuedResourceState_SuspendingData) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResourceState_SuspendingData.ProtoReflect.Descriptor instead.
func (*QueuedResourceState_SuspendingData) ProtoMessage()
func (x *QueuedResourceState_SuspendingData) ProtoReflect() protoreflect.Message
func (x *QueuedResourceState_SuspendingData) Reset()
func (x *QueuedResourceState_SuspendingData) String() string
type QueuedResourceState_SuspendingData_ struct {
// Further data for the suspending state.
SuspendingData *QueuedResourceState_SuspendingData `protobuf:"bytes,8,opt,name=suspending_data,json=suspendingData,proto3,oneof"`
}
BestEffort tier definition.
type QueuedResource_BestEffort struct {
// contains filtered or unexported fields
}
func (*QueuedResource_BestEffort) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResource_BestEffort.ProtoReflect.Descriptor instead.
func (*QueuedResource_BestEffort) ProtoMessage()
func (x *QueuedResource_BestEffort) ProtoReflect() protoreflect.Message
func (x *QueuedResource_BestEffort) Reset()
func (x *QueuedResource_BestEffort) String() string
type QueuedResource_BestEffort_ struct {
// The BestEffort tier.
BestEffort *QueuedResource_BestEffort `protobuf:"bytes,3,opt,name=best_effort,json=bestEffort,proto3,oneof"`
}
Guaranteed tier definition.
type QueuedResource_Guaranteed struct {
// Optional. Defines the minimum duration of the guarantee. If specified,
// the requested resources will only be provisioned if they can be
// allocated for at least the given duration.
MinDuration *durationpb.Duration `protobuf:"bytes,1,opt,name=min_duration,json=minDuration,proto3" json:"min_duration,omitempty"`
// Optional. Specifies the request should be scheduled on reserved capacity.
Reserved bool `protobuf:"varint,2,opt,name=reserved,proto3" json:"reserved,omitempty"`
// contains filtered or unexported fields
}
func (*QueuedResource_Guaranteed) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResource_Guaranteed.ProtoReflect.Descriptor instead.
func (x *QueuedResource_Guaranteed) GetMinDuration() *durationpb.Duration
func (x *QueuedResource_Guaranteed) GetReserved() bool
func (*QueuedResource_Guaranteed) ProtoMessage()
func (x *QueuedResource_Guaranteed) ProtoReflect() protoreflect.Message
func (x *QueuedResource_Guaranteed) Reset()
func (x *QueuedResource_Guaranteed) String() string
type QueuedResource_Guaranteed_ struct {
// The Guaranteed tier
Guaranteed *QueuedResource_Guaranteed `protobuf:"bytes,4,opt,name=guaranteed,proto3,oneof"`
}
Defines the policy of the QueuedRequest.
type QueuedResource_QueueingPolicy struct {
// Time flexibility specification.
//
// Types that are assignable to StartTimingConstraints:
//
// *QueuedResource_QueueingPolicy_ValidUntilDuration
// *QueuedResource_QueueingPolicy_ValidUntilTime
// *QueuedResource_QueueingPolicy_ValidAfterDuration
// *QueuedResource_QueueingPolicy_ValidAfterTime
// *QueuedResource_QueueingPolicy_ValidInterval
StartTimingConstraints isQueuedResource_QueueingPolicy_StartTimingConstraints `protobuf_oneof:"start_timing_constraints"`
// contains filtered or unexported fields
}
func (*QueuedResource_QueueingPolicy) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResource_QueueingPolicy.ProtoReflect.Descriptor instead.
func (m *QueuedResource_QueueingPolicy) GetStartTimingConstraints() isQueuedResource_QueueingPolicy_StartTimingConstraints
func (x *QueuedResource_QueueingPolicy) GetValidAfterDuration() *durationpb.Duration
func (x *QueuedResource_QueueingPolicy) GetValidAfterTime() *timestamppb.Timestamp
func (x *QueuedResource_QueueingPolicy) GetValidInterval() *interval.Interval
func (x *QueuedResource_QueueingPolicy) GetValidUntilDuration() *durationpb.Duration
func (x *QueuedResource_QueueingPolicy) GetValidUntilTime() *timestamppb.Timestamp
func (*QueuedResource_QueueingPolicy) ProtoMessage()
func (x *QueuedResource_QueueingPolicy) ProtoReflect() protoreflect.Message
func (x *QueuedResource_QueueingPolicy) Reset()
func (x *QueuedResource_QueueingPolicy) String() string
type QueuedResource_QueueingPolicy_ValidAfterDuration struct {
// A relative time after which resources may be created.
ValidAfterDuration *durationpb.Duration `protobuf:"bytes,3,opt,name=valid_after_duration,json=validAfterDuration,proto3,oneof"`
}
type QueuedResource_QueueingPolicy_ValidAfterTime struct {
// An absolute time at which resources may be created.
ValidAfterTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=valid_after_time,json=validAfterTime,proto3,oneof"`
}
type QueuedResource_QueueingPolicy_ValidInterval struct {
// An absolute time interval within which resources may be created.
ValidInterval *interval.Interval `protobuf:"bytes,5,opt,name=valid_interval,json=validInterval,proto3,oneof"`
}
type QueuedResource_QueueingPolicy_ValidUntilDuration struct {
// A relative time after which resources should not be created.
// If the request cannot be fulfilled by this time the request will be
// failed.
ValidUntilDuration *durationpb.Duration `protobuf:"bytes,1,opt,name=valid_until_duration,json=validUntilDuration,proto3,oneof"`
}
type QueuedResource_QueueingPolicy_ValidUntilTime struct {
// An absolute time after which resources should not be created.
// If the request cannot be fulfilled by this time the request will be
// failed.
ValidUntilTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=valid_until_time,json=validUntilTime,proto3,oneof"`
}
Details of the TPU resource(s) being requested.
type QueuedResource_Tpu struct {
// The TPU node(s) being requested.
NodeSpec []*QueuedResource_Tpu_NodeSpec `protobuf:"bytes,1,rep,name=node_spec,json=nodeSpec,proto3" json:"node_spec,omitempty"`
// contains filtered or unexported fields
}
func (*QueuedResource_Tpu) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResource_Tpu.ProtoReflect.Descriptor instead.
func (x *QueuedResource_Tpu) GetNodeSpec() []*QueuedResource_Tpu_NodeSpec
func (*QueuedResource_Tpu) ProtoMessage()
func (x *QueuedResource_Tpu) ProtoReflect() protoreflect.Message
func (x *QueuedResource_Tpu) Reset()
func (x *QueuedResource_Tpu) String() string
type QueuedResource_Tpu_ struct {
// Defines a TPU resource.
Tpu *QueuedResource_Tpu `protobuf:"bytes,2,opt,name=tpu,proto3,oneof"`
}
Details of the TPU node(s) being requested. Users can request either a single node or multiple nodes. NodeSpec provides the specification for node(s) to be created.
type QueuedResource_Tpu_NodeSpec struct {
// Required. The parent resource name.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// The unqualified resource name. Should follow the `^[A-Za-z0-9_.~+%-]+$`
// regex format. This is only specified when requesting a single node.
// In case of multi-node requests, multi_node_params must be populated
// instead. It's an error to specify both node_id and multi_node_params.
NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// Required. The node.
Node *Node `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
// contains filtered or unexported fields
}
func (*QueuedResource_Tpu_NodeSpec) Descriptor() ([]byte, []int)
Deprecated: Use QueuedResource_Tpu_NodeSpec.ProtoReflect.Descriptor instead.
func (x *QueuedResource_Tpu_NodeSpec) GetNode() *Node
func (x *QueuedResource_Tpu_NodeSpec) GetNodeId() string
func (x *QueuedResource_Tpu_NodeSpec) GetParent() string
func (*QueuedResource_Tpu_NodeSpec) ProtoMessage()
func (x *QueuedResource_Tpu_NodeSpec) ProtoReflect() protoreflect.Message
func (x *QueuedResource_Tpu_NodeSpec) Reset()
func (x *QueuedResource_Tpu_NodeSpec) String() string
A runtime version that a Node can be configured with.
type RuntimeVersion struct {
// The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The runtime version.
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*RuntimeVersion) Descriptor() ([]byte, []int)
Deprecated: Use RuntimeVersion.ProtoReflect.Descriptor instead.
func (x *RuntimeVersion) GetName() string
func (x *RuntimeVersion) GetVersion() string
func (*RuntimeVersion) ProtoMessage()
func (x *RuntimeVersion) ProtoReflect() protoreflect.Message
func (x *RuntimeVersion) Reset()
func (x *RuntimeVersion) String() string
Sets the scheduling options for this node.
type SchedulingConfig struct {
// Defines whether the node is preemptible.
Preemptible bool `protobuf:"varint,1,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
// Whether the node is created under a reservation.
Reserved bool `protobuf:"varint,2,opt,name=reserved,proto3" json:"reserved,omitempty"`
// contains filtered or unexported fields
}
func (*SchedulingConfig) Descriptor() ([]byte, []int)
Deprecated: Use SchedulingConfig.ProtoReflect.Descriptor instead.
func (x *SchedulingConfig) GetPreemptible() bool
func (x *SchedulingConfig) GetReserved() bool
func (*SchedulingConfig) ProtoMessage()
func (x *SchedulingConfig) ProtoReflect() protoreflect.Message
func (x *SchedulingConfig) Reset()
func (x *SchedulingConfig) String() string
A service account.
type ServiceAccount struct {
// Email address of the service account. If empty, default Compute service
// account will be used.
Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
// The list of scopes to be made available for this service account. If empty,
// access to all Cloud APIs will be allowed.
Scope []string `protobuf:"bytes,2,rep,name=scope,proto3" json:"scope,omitempty"`
// contains filtered or unexported fields
}
func (*ServiceAccount) Descriptor() ([]byte, []int)
Deprecated: Use ServiceAccount.ProtoReflect.Descriptor instead.
func (x *ServiceAccount) GetEmail() string
func (x *ServiceAccount) GetScope() []string
func (*ServiceAccount) ProtoMessage()
func (x *ServiceAccount) ProtoReflect() protoreflect.Message
func (x *ServiceAccount) Reset()
func (x *ServiceAccount) String() string
The per-product per-project service identity for Cloud TPU service.
type ServiceIdentity struct {
// The email address of the service identity.
Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
// contains filtered or unexported fields
}
func (*ServiceIdentity) Descriptor() ([]byte, []int)
Deprecated: Use ServiceIdentity.ProtoReflect.Descriptor instead.
func (x *ServiceIdentity) GetEmail() string
func (*ServiceIdentity) ProtoMessage()
func (x *ServiceIdentity) ProtoReflect() protoreflect.Message
func (x *ServiceIdentity) Reset()
func (x *ServiceIdentity) String() string
A set of Shielded Instance options.
type ShieldedInstanceConfig struct {
// Defines whether the instance has Secure Boot enabled.
EnableSecureBoot bool `protobuf:"varint,1,opt,name=enable_secure_boot,json=enableSecureBoot,proto3" json:"enable_secure_boot,omitempty"`
// contains filtered or unexported fields
}
func (*ShieldedInstanceConfig) Descriptor() ([]byte, []int)
Deprecated: Use ShieldedInstanceConfig.ProtoReflect.Descriptor instead.
func (x *ShieldedInstanceConfig) GetEnableSecureBoot() bool
func (*ShieldedInstanceConfig) ProtoMessage()
func (x *ShieldedInstanceConfig) ProtoReflect() protoreflect.Message
func (x *ShieldedInstanceConfig) Reset()
func (x *ShieldedInstanceConfig) String() string
Request for [SimulateMaintenanceEvent][google.cloud.tpu.v2alpha1.Tpu.SimulateMaintenanceEvent].
type SimulateMaintenanceEventRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The 0-based worker ID. If it is empty, worker ID 0 will be selected for
// maintenance event simulation. A maintenance event will only be fired on the
// first specified worker ID. Future implementations may support firing on
// multiple workers.
WorkerIds []string `protobuf:"bytes,2,rep,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
// contains filtered or unexported fields
}
func (*SimulateMaintenanceEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use SimulateMaintenanceEventRequest.ProtoReflect.Descriptor instead.
func (x *SimulateMaintenanceEventRequest) GetName() string
func (x *SimulateMaintenanceEventRequest) GetWorkerIds() []string
func (*SimulateMaintenanceEventRequest) ProtoMessage()
func (x *SimulateMaintenanceEventRequest) ProtoReflect() protoreflect.Message
func (x *SimulateMaintenanceEventRequest) Reset()
func (x *SimulateMaintenanceEventRequest) String() string
Request for [StartNode][google.cloud.tpu.v2alpha1.Tpu.StartNode].
type StartNodeRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*StartNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartNodeRequest.ProtoReflect.Descriptor instead.
func (x *StartNodeRequest) GetName() string
func (*StartNodeRequest) ProtoMessage()
func (x *StartNodeRequest) ProtoReflect() protoreflect.Message
func (x *StartNodeRequest) Reset()
func (x *StartNodeRequest) String() string
Request for [StopNode][google.cloud.tpu.v2alpha1.Tpu.StopNode].
type StopNodeRequest struct {
// Required. The resource name.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*StopNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopNodeRequest.ProtoReflect.Descriptor instead.
func (x *StopNodeRequest) GetName() string
func (*StopNodeRequest) ProtoMessage()
func (x *StopNodeRequest) ProtoReflect() protoreflect.Message
func (x *StopNodeRequest) Reset()
func (x *StopNodeRequest) String() string
A Symptom instance.
type Symptom struct {
// Timestamp when the Symptom is created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Type of the Symptom.
SymptomType Symptom_SymptomType `protobuf:"varint,2,opt,name=symptom_type,json=symptomType,proto3,enum=google.cloud.tpu.v2alpha1.Symptom_SymptomType" json:"symptom_type,omitempty"`
// Detailed information of the current Symptom.
Details string `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
// A string used to uniquely distinguish a worker within a TPU node.
WorkerId string `protobuf:"bytes,4,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
// contains filtered or unexported fields
}
func (*Symptom) Descriptor() ([]byte, []int)
Deprecated: Use Symptom.ProtoReflect.Descriptor instead.
func (x *Symptom) GetCreateTime() *timestamppb.Timestamp
func (x *Symptom) GetDetails() string
func (x *Symptom) GetSymptomType() Symptom_SymptomType
func (x *Symptom) GetWorkerId() string
func (*Symptom) ProtoMessage()
func (x *Symptom) ProtoReflect() protoreflect.Message
func (x *Symptom) Reset()
func (x *Symptom) String() string
SymptomType represents the different types of Symptoms that a TPU can be at.
type Symptom_SymptomType int32
const (
// Unspecified symptom.
Symptom_SYMPTOM_TYPE_UNSPECIFIED Symptom_SymptomType = 0
// TPU VM memory is low.
Symptom_LOW_MEMORY Symptom_SymptomType = 1
// TPU runtime is out of memory.
Symptom_OUT_OF_MEMORY Symptom_SymptomType = 2
// TPU runtime execution has timed out.
Symptom_EXECUTE_TIMED_OUT Symptom_SymptomType = 3
// TPU runtime fails to construct a mesh that recognizes each TPU device's
// neighbors.
Symptom_MESH_BUILD_FAIL Symptom_SymptomType = 4
// TPU HBM is out of memory.
Symptom_HBM_OUT_OF_MEMORY Symptom_SymptomType = 5
// Abusive behaviors have been identified on the current project.
Symptom_PROJECT_ABUSE Symptom_SymptomType = 6
)
func (Symptom_SymptomType) Descriptor() protoreflect.EnumDescriptor
func (x Symptom_SymptomType) Enum() *Symptom_SymptomType
func (Symptom_SymptomType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Symptom_SymptomType.Descriptor instead.
func (x Symptom_SymptomType) Number() protoreflect.EnumNumber
func (x Symptom_SymptomType) String() string
func (Symptom_SymptomType) Type() protoreflect.EnumType
TpuClient is the client API for Tpu service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type TpuClient interface {
// Lists nodes.
ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
// Gets the details of a node.
GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*Node, error)
// Creates a node.
CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Deletes a node.
DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Stops a node. This operation is only available with single TPU nodes.
StopNode(ctx context.Context, in *StopNodeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Starts a node.
StartNode(ctx context.Context, in *StartNodeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Updates the configurations of a node.
UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Lists queued resources.
ListQueuedResources(ctx context.Context, in *ListQueuedResourcesRequest, opts ...grpc.CallOption) (*ListQueuedResourcesResponse, error)
// Gets details of a queued resource.
GetQueuedResource(ctx context.Context, in *GetQueuedResourceRequest, opts ...grpc.CallOption) (*QueuedResource, error)
// Creates a QueuedResource TPU instance.
CreateQueuedResource(ctx context.Context, in *CreateQueuedResourceRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Deletes a QueuedResource TPU instance.
DeleteQueuedResource(ctx context.Context, in *DeleteQueuedResourceRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
// Generates the Cloud TPU service identity for the project.
GenerateServiceIdentity(ctx context.Context, in *GenerateServiceIdentityRequest, opts ...grpc.CallOption) (*GenerateServiceIdentityResponse, error)
// Lists accelerator types supported by this API.
ListAcceleratorTypes(ctx context.Context, in *ListAcceleratorTypesRequest, opts ...grpc.CallOption) (*ListAcceleratorTypesResponse, error)
// Gets AcceleratorType.
GetAcceleratorType(ctx context.Context, in *GetAcceleratorTypeRequest, opts ...grpc.CallOption) (*AcceleratorType, error)
// Lists runtime versions supported by this API.
ListRuntimeVersions(ctx context.Context, in *ListRuntimeVersionsRequest, opts ...grpc.CallOption) (*ListRuntimeVersionsResponse, error)
// Gets a runtime version.
GetRuntimeVersion(ctx context.Context, in *GetRuntimeVersionRequest, opts ...grpc.CallOption) (*RuntimeVersion, error)
// Retrieves the guest attributes for the node.
GetGuestAttributes(ctx context.Context, in *GetGuestAttributesRequest, opts ...grpc.CallOption) (*GetGuestAttributesResponse, error)
// Simulates a maintenance event.
SimulateMaintenanceEvent(ctx context.Context, in *SimulateMaintenanceEventRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}
func NewTpuClient(cc grpc.ClientConnInterface) TpuClient
TpuServer is the server API for Tpu service.
type TpuServer interface {
// Lists nodes.
ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
// Gets the details of a node.
GetNode(context.Context, *GetNodeRequest) (*Node, error)
// Creates a node.
CreateNode(context.Context, *CreateNodeRequest) (*longrunning.Operation, error)
// Deletes a node.
DeleteNode(context.Context, *DeleteNodeRequest) (*longrunning.Operation, error)
// Stops a node. This operation is only available with single TPU nodes.
StopNode(context.Context, *StopNodeRequest) (*longrunning.Operation, error)
// Starts a node.
StartNode(context.Context, *StartNodeRequest) (*longrunning.Operation, error)
// Updates the configurations of a node.
UpdateNode(context.Context, *UpdateNodeRequest) (*longrunning.Operation, error)
// Lists queued resources.
ListQueuedResources(context.Context, *ListQueuedResourcesRequest) (*ListQueuedResourcesResponse, error)
// Gets details of a queued resource.
GetQueuedResource(context.Context, *GetQueuedResourceRequest) (*QueuedResource, error)
// Creates a QueuedResource TPU instance.
CreateQueuedResource(context.Context, *CreateQueuedResourceRequest) (*longrunning.Operation, error)
// Deletes a QueuedResource TPU instance.
DeleteQueuedResource(context.Context, *DeleteQueuedResourceRequest) (*longrunning.Operation, error)
// Generates the Cloud TPU service identity for the project.
GenerateServiceIdentity(context.Context, *GenerateServiceIdentityRequest) (*GenerateServiceIdentityResponse, error)
// Lists accelerator types supported by this API.
ListAcceleratorTypes(context.Context, *ListAcceleratorTypesRequest) (*ListAcceleratorTypesResponse, error)
// Gets AcceleratorType.
GetAcceleratorType(context.Context, *GetAcceleratorTypeRequest) (*AcceleratorType, error)
// Lists runtime versions supported by this API.
ListRuntimeVersions(context.Context, *ListRuntimeVersionsRequest) (*ListRuntimeVersionsResponse, error)
// Gets a runtime version.
GetRuntimeVersion(context.Context, *GetRuntimeVersionRequest) (*RuntimeVersion, error)
// Retrieves the guest attributes for the node.
GetGuestAttributes(context.Context, *GetGuestAttributesRequest) (*GetGuestAttributesResponse, error)
// Simulates a maintenance event.
SimulateMaintenanceEvent(context.Context, *SimulateMaintenanceEventRequest) (*longrunning.Operation, error)
}
UnimplementedTpuServer can be embedded to have forward compatible implementations.
type UnimplementedTpuServer struct {
}
func (*UnimplementedTpuServer) CreateNode(context.Context, *CreateNodeRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) CreateQueuedResource(context.Context, *CreateQueuedResourceRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) DeleteNode(context.Context, *DeleteNodeRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) DeleteQueuedResource(context.Context, *DeleteQueuedResourceRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) GenerateServiceIdentity(context.Context, *GenerateServiceIdentityRequest) (*GenerateServiceIdentityResponse, error)
func (*UnimplementedTpuServer) GetAcceleratorType(context.Context, *GetAcceleratorTypeRequest) (*AcceleratorType, error)
func (*UnimplementedTpuServer) GetGuestAttributes(context.Context, *GetGuestAttributesRequest) (*GetGuestAttributesResponse, error)
func (*UnimplementedTpuServer) GetNode(context.Context, *GetNodeRequest) (*Node, error)
func (*UnimplementedTpuServer) GetQueuedResource(context.Context, *GetQueuedResourceRequest) (*QueuedResource, error)
func (*UnimplementedTpuServer) GetRuntimeVersion(context.Context, *GetRuntimeVersionRequest) (*RuntimeVersion, error)
func (*UnimplementedTpuServer) ListAcceleratorTypes(context.Context, *ListAcceleratorTypesRequest) (*ListAcceleratorTypesResponse, error)
func (*UnimplementedTpuServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
func (*UnimplementedTpuServer) ListQueuedResources(context.Context, *ListQueuedResourcesRequest) (*ListQueuedResourcesResponse, error)
func (*UnimplementedTpuServer) ListRuntimeVersions(context.Context, *ListRuntimeVersionsRequest) (*ListRuntimeVersionsResponse, error)
func (*UnimplementedTpuServer) SimulateMaintenanceEvent(context.Context, *SimulateMaintenanceEventRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) StartNode(context.Context, *StartNodeRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) StopNode(context.Context, *StopNodeRequest) (*longrunning.Operation, error)
func (*UnimplementedTpuServer) UpdateNode(context.Context, *UpdateNodeRequest) (*longrunning.Operation, error)
Request for [UpdateNode][google.cloud.tpu.v2alpha1.Tpu.UpdateNode].
type UpdateNodeRequest struct {
// Required. Mask of fields from [Node][Tpu.Node] to update.
// Supported fields: [description, tags, labels, metadata,
// network_config.enable_external_ips].
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. The node. Only fields specified in update_mask are updated.
Node *Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.
func (x *UpdateNodeRequest) GetNode() *Node
func (x *UpdateNodeRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateNodeRequest) ProtoMessage()
func (x *UpdateNodeRequest) ProtoReflect() protoreflect.Message
func (x *UpdateNodeRequest) Reset()
func (x *UpdateNodeRequest) String() string