tpupb

package
v0.0.0-...-8436a1e Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package tpupb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
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 AttachedDisk_DiskMode.

View Source 
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",
		16: "UNKNOWN",
	}
	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,
		"UNKNOWN":           16,
	}
)

Enum value maps for Node_State.

View Source 
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_Health.

View Source 
var (
	Node_ApiVersion_name = map[int32]string{
		0: "API_VERSION_UNSPECIFIED",
		1: "V1_ALPHA1",
		2: "V1",
		3: "V2_ALPHA1",
		4: "V2",
	}
	Node_ApiVersion_value = map[string]int32{
		"API_VERSION_UNSPECIFIED": 0,
		"V1_ALPHA1":               1,
		"V1":                      2,
		"V2_ALPHA1":               3,
		"V2":                      4,
	}
)

Enum value maps for Node_ApiVersion.

View Source 
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",
		9: "WAITING_FOR_RESOURCES",
	}
	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,
		"WAITING_FOR_RESOURCES": 9,
	}
)

Enum value maps for QueuedResourceState_State.

View Source 
var (
	QueuedResourceState_StateInitiator_name = map[int32]string{
		0: "STATE_INITIATOR_UNSPECIFIED",
		1: "USER",
		2: "SERVICE",
	}
	QueuedResourceState_StateInitiator_value = map[string]int32{
		"STATE_INITIATOR_UNSPECIFIED": 0,
		"USER":                        1,
		"SERVICE":                     2,
	}
)

Enum value maps for QueuedResourceState_StateInitiator.

View Source 
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,
	}
)

Enum value maps for Symptom_SymptomType.

View Source 
var (
	AcceleratorConfig_Type_name = map[int32]string{
		0:  "TYPE_UNSPECIFIED",
		2:  "V2",
		4:  "V3",
		7:  "V4",
		9:  "V5LITE_POD",
		10: "V5P",
		11: "V6E",
	}
	AcceleratorConfig_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"V2":               2,
		"V3":               4,
		"V4":               7,
		"V5LITE_POD":       9,
		"V5P":              10,
		"V6E":              11,
	}
)

Enum value maps for AcceleratorConfig_Type.

View Source 
var File_mockgcp_cloud_tpu_v2_cloud_tpu_proto protoreflect.FileDescriptor
View Source 
var Tpu_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mockgcp.cloud.tpu.v2.Tpu",
	HandlerType: (*TpuServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListNodes",
			Handler:    _Tpu_ListNodes_Handler,
		},
		{
			MethodName: "GetNode",
			Handler:    _Tpu_GetNode_Handler,
		},
		{
			MethodName: "CreateNode",
			Handler:    _Tpu_CreateNode_Handler,
		},
		{
			MethodName: "DeleteNode",
			Handler:    _Tpu_DeleteNode_Handler,
		},
		{
			MethodName: "StopNode",
			Handler:    _Tpu_StopNode_Handler,
		},
		{
			MethodName: "StartNode",
			Handler:    _Tpu_StartNode_Handler,
		},
		{
			MethodName: "UpdateNode",
			Handler:    _Tpu_UpdateNode_Handler,
		},
		{
			MethodName: "ListQueuedResources",
			Handler:    _Tpu_ListQueuedResources_Handler,
		},
		{
			MethodName: "GetQueuedResource",
			Handler:    _Tpu_GetQueuedResource_Handler,
		},
		{
			MethodName: "CreateQueuedResource",
			Handler:    _Tpu_CreateQueuedResource_Handler,
		},
		{
			MethodName: "DeleteQueuedResource",
			Handler:    _Tpu_DeleteQueuedResource_Handler,
		},
		{
			MethodName: "ResetQueuedResource",
			Handler:    _Tpu_ResetQueuedResource_Handler,
		},
		{
			MethodName: "GenerateServiceIdentity",
			Handler:    _Tpu_GenerateServiceIdentity_Handler,
		},
		{
			MethodName: "ListAcceleratorTypes",
			Handler:    _Tpu_ListAcceleratorTypes_Handler,
		},
		{
			MethodName: "GetAcceleratorType",
			Handler:    _Tpu_GetAcceleratorType_Handler,
		},
		{
			MethodName: "ListRuntimeVersions",
			Handler:    _Tpu_ListRuntimeVersions_Handler,
		},
		{
			MethodName: "GetRuntimeVersion",
			Handler:    _Tpu_GetRuntimeVersion_Handler,
		},
		{
			MethodName: "GetGuestAttributes",
			Handler:    _Tpu_GetGuestAttributes_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "mockgcp/cloud/tpu/v2/cloud_tpu.proto",
}

Tpu_ServiceDesc is the grpc.ServiceDesc for Tpu service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTpuHandler 

func RegisterTpuHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterTpuHandler registers the http handlers for service Tpu to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterTpuHandlerClient 

func RegisterTpuHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TpuClient) error

RegisterTpuHandlerClient registers the http handlers for service Tpu to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TpuClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TpuClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "TpuClient" to call the correct interceptors.

func RegisterTpuHandlerFromEndpoint 

func RegisterTpuHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterTpuHandlerFromEndpoint is same as RegisterTpuHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterTpuHandlerServer 

func RegisterTpuHandlerServer(ctx context.Context, mux *runtime.ServeMux, server TpuServer) error

RegisterTpuHandlerServer registers the http handlers for service Tpu to "mux". UnaryRPC :call TpuServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterTpuHandlerFromEndpoint instead.

func RegisterTpuServer 

func RegisterTpuServer(s grpc.ServiceRegistrar, srv TpuServer)

Types

type AcceleratorConfig 

type AcceleratorConfig struct {

	// Required. Type of TPU.
	Type AcceleratorConfig_Type `protobuf:"varint,1,opt,name=type,proto3,enum=mockgcp.cloud.tpu.v2.AcceleratorConfig_Type" json:"type,omitempty"`
	// Required. Topology of TPU in chips.
	Topology string `protobuf:"bytes,2,opt,name=topology,proto3" json:"topology,omitempty"`
	// contains filtered or unexported fields
}

A TPU accelerator configuration.

func (*AcceleratorConfig) Descriptor deprecated 

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

Deprecated: Use AcceleratorConfig.ProtoReflect.Descriptor instead.

func (*AcceleratorConfig) GetTopology 

func (x *AcceleratorConfig) GetTopology() string

func (*AcceleratorConfig) GetType 

func (x *AcceleratorConfig) GetType() AcceleratorConfig_Type

func (*AcceleratorConfig) ProtoMessage 

func (*AcceleratorConfig) ProtoMessage()

func (*AcceleratorConfig) ProtoReflect 

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

func (*AcceleratorConfig) Reset 

func (x *AcceleratorConfig) Reset()

func (*AcceleratorConfig) String 

func (x *AcceleratorConfig) String() string

type AcceleratorConfig_Type 

type AcceleratorConfig_Type int32

TPU type. 

const (
	// Unspecified version.
	AcceleratorConfig_TYPE_UNSPECIFIED AcceleratorConfig_Type = 0
	// TPU v2.
	AcceleratorConfig_V2 AcceleratorConfig_Type = 2
	// TPU v3.
	AcceleratorConfig_V3 AcceleratorConfig_Type = 4
	// TPU v4.
	AcceleratorConfig_V4 AcceleratorConfig_Type = 7
	// TPU v5lite pod.
	AcceleratorConfig_V5LITE_POD AcceleratorConfig_Type = 9
	// TPU v5p.
	AcceleratorConfig_V5P AcceleratorConfig_Type = 10
	// TPU v6e.
	AcceleratorConfig_V6E AcceleratorConfig_Type = 11
)

func (AcceleratorConfig_Type) Descriptor 

func (AcceleratorConfig_Type) Descriptor() protoreflect.EnumDescriptor

func (AcceleratorConfig_Type) Enum 

func (x AcceleratorConfig_Type) Enum() *AcceleratorConfig_Type

func (AcceleratorConfig_Type) EnumDescriptor deprecated 

func (AcceleratorConfig_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use AcceleratorConfig_Type.Descriptor instead.

func (AcceleratorConfig_Type) Number 

func (x AcceleratorConfig_Type) Number() protoreflect.EnumNumber

func (AcceleratorConfig_Type) String 

func (x AcceleratorConfig_Type) String() string

func (AcceleratorConfig_Type) Type 

func (AcceleratorConfig_Type) Type() protoreflect.EnumType

type AcceleratorType 

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"`
	// The accelerator config.
	AcceleratorConfigs []*AcceleratorConfig `protobuf:"bytes,3,rep,name=accelerator_configs,json=acceleratorConfigs,proto3" json:"accelerator_configs,omitempty"`
	// contains filtered or unexported fields
}

A accelerator type that a Node can be configured with.

func (*AcceleratorType) Descriptor deprecated 

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

Deprecated: Use AcceleratorType.ProtoReflect.Descriptor instead.

func (*AcceleratorType) GetAcceleratorConfigs 

func (x *AcceleratorType) GetAcceleratorConfigs() []*AcceleratorConfig

func (*AcceleratorType) GetName 

func (x *AcceleratorType) GetName() string

func (*AcceleratorType) GetType 

func (x *AcceleratorType) GetType() string

func (*AcceleratorType) ProtoMessage 

func (*AcceleratorType) ProtoMessage()

func (*AcceleratorType) ProtoReflect 

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

func (*AcceleratorType) Reset 

func (x *AcceleratorType) Reset()

func (*AcceleratorType) String 

func (x *AcceleratorType) String() string

type AccessConfig 

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
}

An access config attached to the TPU worker.

func (*AccessConfig) Descriptor deprecated 

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

Deprecated: Use AccessConfig.ProtoReflect.Descriptor instead.

func (*AccessConfig) GetExternalIp 

func (x *AccessConfig) GetExternalIp() string

func (*AccessConfig) ProtoMessage 

func (*AccessConfig) ProtoMessage()

func (*AccessConfig) ProtoReflect 

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

func (*AccessConfig) Reset 

func (x *AccessConfig) Reset()

func (*AccessConfig) String 

func (x *AccessConfig) String() string

type AttachedDisk 

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=mockgcp.cloud.tpu.v2.AttachedDisk_DiskMode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

A node-attached disk resource. Next ID: 8;

func (*AttachedDisk) Descriptor deprecated 

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

Deprecated: Use AttachedDisk.ProtoReflect.Descriptor instead.

func (*AttachedDisk) GetMode 

func (x *AttachedDisk) GetMode() AttachedDisk_DiskMode

func (*AttachedDisk) GetSourceDisk 

func (x *AttachedDisk) GetSourceDisk() string

func (*AttachedDisk) ProtoMessage 

func (*AttachedDisk) ProtoMessage()

func (*AttachedDisk) ProtoReflect 

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

func (*AttachedDisk) Reset 

func (x *AttachedDisk) Reset()

func (*AttachedDisk) String 

func (x *AttachedDisk) String() string

type AttachedDisk_DiskMode 

type AttachedDisk_DiskMode int32

The different mode of the attached disk. 

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 

func (AttachedDisk_DiskMode) Descriptor() protoreflect.EnumDescriptor

func (AttachedDisk_DiskMode) Enum 

func (x AttachedDisk_DiskMode) Enum() *AttachedDisk_DiskMode

func (AttachedDisk_DiskMode) EnumDescriptor deprecated 

func (AttachedDisk_DiskMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use AttachedDisk_DiskMode.Descriptor instead.

func (AttachedDisk_DiskMode) Number 

func (x AttachedDisk_DiskMode) Number() protoreflect.EnumNumber

func (AttachedDisk_DiskMode) String 

func (x AttachedDisk_DiskMode) String() string

func (AttachedDisk_DiskMode) Type 

func (AttachedDisk_DiskMode) Type() protoreflect.EnumType

type CreateNodeRequest 

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

Request for [CreateNode][mockgcp.cloud.tpu.v2.Tpu.CreateNode].

func (*CreateNodeRequest) Descriptor deprecated 

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

Deprecated: Use CreateNodeRequest.ProtoReflect.Descriptor instead.

func (*CreateNodeRequest) GetNode 

func (x *CreateNodeRequest) GetNode() *Node

func (*CreateNodeRequest) GetNodeId 

func (x *CreateNodeRequest) GetNodeId() string

func (*CreateNodeRequest) GetParent 

func (x *CreateNodeRequest) GetParent() string

func (*CreateNodeRequest) ProtoMessage 

func (*CreateNodeRequest) ProtoMessage()

func (*CreateNodeRequest) ProtoReflect 

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

func (*CreateNodeRequest) Reset 

func (x *CreateNodeRequest) Reset()

func (*CreateNodeRequest) String 

func (x *CreateNodeRequest) String() string

type CreateQueuedResourceRequest 

type CreateQueuedResourceRequest struct {

	// Required. The parent resource name.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. 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"`
	// Optional. Idempotent request UUID.
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for [CreateQueuedResource][mockgcp.cloud.tpu.v2.Tpu.CreateQueuedResource].

func (*CreateQueuedResourceRequest) Descriptor deprecated 

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

Deprecated: Use CreateQueuedResourceRequest.ProtoReflect.Descriptor instead.

func (*CreateQueuedResourceRequest) GetParent 

func (x *CreateQueuedResourceRequest) GetParent() string

func (*CreateQueuedResourceRequest) GetQueuedResource 

func (x *CreateQueuedResourceRequest) GetQueuedResource() *QueuedResource

func (*CreateQueuedResourceRequest) GetQueuedResourceId 

func (x *CreateQueuedResourceRequest) GetQueuedResourceId() string

func (*CreateQueuedResourceRequest) GetRequestId 

func (x *CreateQueuedResourceRequest) GetRequestId() string

func (*CreateQueuedResourceRequest) ProtoMessage 

func (*CreateQueuedResourceRequest) ProtoMessage()

func (*CreateQueuedResourceRequest) ProtoReflect 

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

func (*CreateQueuedResourceRequest) Reset 

func (x *CreateQueuedResourceRequest) Reset()

func (*CreateQueuedResourceRequest) String 

func (x *CreateQueuedResourceRequest) String() string

type DeleteNodeRequest 

type DeleteNodeRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [DeleteNode][mockgcp.cloud.tpu.v2.Tpu.DeleteNode].

func (*DeleteNodeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNodeRequest.ProtoReflect.Descriptor instead.

func (*DeleteNodeRequest) GetName 

func (x *DeleteNodeRequest) GetName() string

func (*DeleteNodeRequest) ProtoMessage 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) ProtoReflect 

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

func (*DeleteNodeRequest) Reset 

func (x *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String 

func (x *DeleteNodeRequest) String() string

type DeleteQueuedResourceRequest 

type DeleteQueuedResourceRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. Idempotent request UUID.
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. If set to true, all running nodes belonging to this queued
	// resource will be deleted first and then the queued resource will be
	// deleted. Otherwise (i.e. force=false), the queued resource will only be
	// deleted if its nodes have already been deleted or the queued resource is in
	// the ACCEPTED, FAILED, or SUSPENDED state.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Request for [DeleteQueuedResource][mockgcp.cloud.tpu.v2.Tpu.DeleteQueuedResource].

func (*DeleteQueuedResourceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteQueuedResourceRequest.ProtoReflect.Descriptor instead.

func (*DeleteQueuedResourceRequest) GetForce 

func (x *DeleteQueuedResourceRequest) GetForce() bool

func (*DeleteQueuedResourceRequest) GetName 

func (x *DeleteQueuedResourceRequest) GetName() string

func (*DeleteQueuedResourceRequest) GetRequestId 

func (x *DeleteQueuedResourceRequest) GetRequestId() string

func (*DeleteQueuedResourceRequest) ProtoMessage 

func (*DeleteQueuedResourceRequest) ProtoMessage()

func (*DeleteQueuedResourceRequest) ProtoReflect 

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

func (*DeleteQueuedResourceRequest) Reset 

func (x *DeleteQueuedResourceRequest) Reset()

func (*DeleteQueuedResourceRequest) String 

func (x *DeleteQueuedResourceRequest) String() string

type GenerateServiceIdentityRequest 

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
}

Request for [GenerateServiceIdentity][mockgcp.cloud.tpu.v2.Tpu.GenerateServiceIdentity].

func (*GenerateServiceIdentityRequest) Descriptor deprecated 

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

Deprecated: Use GenerateServiceIdentityRequest.ProtoReflect.Descriptor instead.

func (*GenerateServiceIdentityRequest) GetParent 

func (x *GenerateServiceIdentityRequest) GetParent() string

func (*GenerateServiceIdentityRequest) ProtoMessage 

func (*GenerateServiceIdentityRequest) ProtoMessage()

func (*GenerateServiceIdentityRequest) ProtoReflect 

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

func (*GenerateServiceIdentityRequest) Reset 

func (x *GenerateServiceIdentityRequest) Reset()

func (*GenerateServiceIdentityRequest) String 

func (x *GenerateServiceIdentityRequest) String() string

type GenerateServiceIdentityResponse 

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
}

Response for [GenerateServiceIdentity][mockgcp.cloud.tpu.v2.Tpu.GenerateServiceIdentity].

func (*GenerateServiceIdentityResponse) Descriptor deprecated 

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

Deprecated: Use GenerateServiceIdentityResponse.ProtoReflect.Descriptor instead.

func (*GenerateServiceIdentityResponse) GetIdentity 

func (x *GenerateServiceIdentityResponse) GetIdentity() *ServiceIdentity

func (*GenerateServiceIdentityResponse) ProtoMessage 

func (*GenerateServiceIdentityResponse) ProtoMessage()

func (*GenerateServiceIdentityResponse) ProtoReflect 

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

func (*GenerateServiceIdentityResponse) Reset 

func (x *GenerateServiceIdentityResponse) Reset()

func (*GenerateServiceIdentityResponse) String 

func (x *GenerateServiceIdentityResponse) String() string

type GetAcceleratorTypeRequest 

type GetAcceleratorTypeRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [GetAcceleratorType][mockgcp.cloud.tpu.v2.Tpu.GetAcceleratorType].

func (*GetAcceleratorTypeRequest) Descriptor deprecated 

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

Deprecated: Use GetAcceleratorTypeRequest.ProtoReflect.Descriptor instead.

func (*GetAcceleratorTypeRequest) GetName 

func (x *GetAcceleratorTypeRequest) GetName() string

func (*GetAcceleratorTypeRequest) ProtoMessage 

func (*GetAcceleratorTypeRequest) ProtoMessage()

func (*GetAcceleratorTypeRequest) ProtoReflect 

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

func (*GetAcceleratorTypeRequest) Reset 

func (x *GetAcceleratorTypeRequest) Reset()

func (*GetAcceleratorTypeRequest) String 

func (x *GetAcceleratorTypeRequest) String() string

type GetGuestAttributesRequest 

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
}

Request for [GetGuestAttributes][mockgcp.cloud.tpu.v2.Tpu.GetGuestAttributes].

func (*GetGuestAttributesRequest) Descriptor deprecated 

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

Deprecated: Use GetGuestAttributesRequest.ProtoReflect.Descriptor instead.

func (*GetGuestAttributesRequest) GetName 

func (x *GetGuestAttributesRequest) GetName() string

func (*GetGuestAttributesRequest) GetQueryPath 

func (x *GetGuestAttributesRequest) GetQueryPath() string

func (*GetGuestAttributesRequest) GetWorkerIds 

func (x *GetGuestAttributesRequest) GetWorkerIds() []string

func (*GetGuestAttributesRequest) ProtoMessage 

func (*GetGuestAttributesRequest) ProtoMessage()

func (*GetGuestAttributesRequest) ProtoReflect 

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

func (*GetGuestAttributesRequest) Reset 

func (x *GetGuestAttributesRequest) Reset()

func (*GetGuestAttributesRequest) String 

func (x *GetGuestAttributesRequest) String() string

type GetGuestAttributesResponse 

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
}

Response for [GetGuestAttributes][mockgcp.cloud.tpu.v2.Tpu.GetGuestAttributes].

func (*GetGuestAttributesResponse) Descriptor deprecated 

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

Deprecated: Use GetGuestAttributesResponse.ProtoReflect.Descriptor instead.

func (*GetGuestAttributesResponse) GetGuestAttributes 

func (x *GetGuestAttributesResponse) GetGuestAttributes() []*GuestAttributes

func (*GetGuestAttributesResponse) ProtoMessage 

func (*GetGuestAttributesResponse) ProtoMessage()

func (*GetGuestAttributesResponse) ProtoReflect 

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

func (*GetGuestAttributesResponse) Reset 

func (x *GetGuestAttributesResponse) Reset()

func (*GetGuestAttributesResponse) String 

func (x *GetGuestAttributesResponse) String() string

type GetNodeRequest 

type GetNodeRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [GetNode][mockgcp.cloud.tpu.v2.Tpu.GetNode].

func (*GetNodeRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) GetName 

func (x *GetNodeRequest) GetName() string

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect 

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

func (*GetNodeRequest) Reset 

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (x *GetNodeRequest) String() string

type GetQueuedResourceRequest 

type GetQueuedResourceRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [GetQueuedResource][mockgcp.cloud.tpu.v2.Tpu.GetQueuedResource]

func (*GetQueuedResourceRequest) Descriptor deprecated 

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

Deprecated: Use GetQueuedResourceRequest.ProtoReflect.Descriptor instead.

func (*GetQueuedResourceRequest) GetName 

func (x *GetQueuedResourceRequest) GetName() string

func (*GetQueuedResourceRequest) ProtoMessage 

func (*GetQueuedResourceRequest) ProtoMessage()

func (*GetQueuedResourceRequest) ProtoReflect 

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

func (*GetQueuedResourceRequest) Reset 

func (x *GetQueuedResourceRequest) Reset()

func (*GetQueuedResourceRequest) String 

func (x *GetQueuedResourceRequest) String() string

type GetRuntimeVersionRequest 

type GetRuntimeVersionRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [GetRuntimeVersion][mockgcp.cloud.tpu.v2.Tpu.GetRuntimeVersion].

func (*GetRuntimeVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetRuntimeVersionRequest.ProtoReflect.Descriptor instead.

func (*GetRuntimeVersionRequest) GetName 

func (x *GetRuntimeVersionRequest) GetName() string

func (*GetRuntimeVersionRequest) ProtoMessage 

func (*GetRuntimeVersionRequest) ProtoMessage()

func (*GetRuntimeVersionRequest) ProtoReflect 

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

func (*GetRuntimeVersionRequest) Reset 

func (x *GetRuntimeVersionRequest) Reset()

func (*GetRuntimeVersionRequest) String 

func (x *GetRuntimeVersionRequest) String() string

type GuestAttributes 

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
}

A guest attributes.

func (*GuestAttributes) Descriptor deprecated 

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

Deprecated: Use GuestAttributes.ProtoReflect.Descriptor instead.

func (*GuestAttributes) GetQueryPath 

func (x *GuestAttributes) GetQueryPath() string

func (*GuestAttributes) GetQueryValue 

func (x *GuestAttributes) GetQueryValue() *GuestAttributesValue

func (*GuestAttributes) ProtoMessage 

func (*GuestAttributes) ProtoMessage()

func (*GuestAttributes) ProtoReflect 

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

func (*GuestAttributes) Reset 

func (x *GuestAttributes) Reset()

func (*GuestAttributes) String 

func (x *GuestAttributes) String() string

type GuestAttributesEntry 

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
}

A guest attributes namespace/key/value entry.

func (*GuestAttributesEntry) Descriptor deprecated 

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

Deprecated: Use GuestAttributesEntry.ProtoReflect.Descriptor instead.

func (*GuestAttributesEntry) GetKey 

func (x *GuestAttributesEntry) GetKey() string

func (*GuestAttributesEntry) GetNamespace 

func (x *GuestAttributesEntry) GetNamespace() string

func (*GuestAttributesEntry) GetValue 

func (x *GuestAttributesEntry) GetValue() string

func (*GuestAttributesEntry) ProtoMessage 

func (*GuestAttributesEntry) ProtoMessage()

func (*GuestAttributesEntry) ProtoReflect 

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

func (*GuestAttributesEntry) Reset 

func (x *GuestAttributesEntry) Reset()

func (*GuestAttributesEntry) String 

func (x *GuestAttributesEntry) String() string

type GuestAttributesValue 

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
}

Array of guest attribute namespace/key/value tuples.

func (*GuestAttributesValue) Descriptor deprecated 

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

Deprecated: Use GuestAttributesValue.ProtoReflect.Descriptor instead.

func (*GuestAttributesValue) GetItems 

func (x *GuestAttributesValue) GetItems() []*GuestAttributesEntry

func (*GuestAttributesValue) ProtoMessage 

func (*GuestAttributesValue) ProtoMessage()

func (*GuestAttributesValue) ProtoReflect 

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

func (*GuestAttributesValue) Reset 

func (x *GuestAttributesValue) Reset()

func (*GuestAttributesValue) String 

func (x *GuestAttributesValue) String() string

type ListAcceleratorTypesRequest 

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
}

Request for [ListAcceleratorTypes][mockgcp.cloud.tpu.v2.Tpu.ListAcceleratorTypes].

func (*ListAcceleratorTypesRequest) Descriptor deprecated 

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

Deprecated: Use ListAcceleratorTypesRequest.ProtoReflect.Descriptor instead.

func (*ListAcceleratorTypesRequest) GetFilter 

func (x *ListAcceleratorTypesRequest) GetFilter() string

func (*ListAcceleratorTypesRequest) GetOrderBy 

func (x *ListAcceleratorTypesRequest) GetOrderBy() string

func (*ListAcceleratorTypesRequest) GetPageSize 

func (x *ListAcceleratorTypesRequest) GetPageSize() int32

func (*ListAcceleratorTypesRequest) GetPageToken 

func (x *ListAcceleratorTypesRequest) GetPageToken() string

func (*ListAcceleratorTypesRequest) GetParent 

func (x *ListAcceleratorTypesRequest) GetParent() string

func (*ListAcceleratorTypesRequest) ProtoMessage 

func (*ListAcceleratorTypesRequest) ProtoMessage()

func (*ListAcceleratorTypesRequest) ProtoReflect 

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

func (*ListAcceleratorTypesRequest) Reset 

func (x *ListAcceleratorTypesRequest) Reset()

func (*ListAcceleratorTypesRequest) String 

func (x *ListAcceleratorTypesRequest) String() string

type ListAcceleratorTypesResponse 

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
}

Response for [ListAcceleratorTypes][mockgcp.cloud.tpu.v2.Tpu.ListAcceleratorTypes].

func (*ListAcceleratorTypesResponse) Descriptor deprecated 

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

Deprecated: Use ListAcceleratorTypesResponse.ProtoReflect.Descriptor instead.

func (*ListAcceleratorTypesResponse) GetAcceleratorTypes 

func (x *ListAcceleratorTypesResponse) GetAcceleratorTypes() []*AcceleratorType

func (*ListAcceleratorTypesResponse) GetNextPageToken 

func (x *ListAcceleratorTypesResponse) GetNextPageToken() string

func (*ListAcceleratorTypesResponse) GetUnreachable 

func (x *ListAcceleratorTypesResponse) GetUnreachable() []string

func (*ListAcceleratorTypesResponse) ProtoMessage 

func (*ListAcceleratorTypesResponse) ProtoMessage()

func (*ListAcceleratorTypesResponse) ProtoReflect 

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

func (*ListAcceleratorTypesResponse) Reset 

func (x *ListAcceleratorTypesResponse) Reset()

func (*ListAcceleratorTypesResponse) String 

func (x *ListAcceleratorTypesResponse) String() string

type ListNodesRequest 

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
}

Request for [ListNodes][mockgcp.cloud.tpu.v2.Tpu.ListNodes].

func (*ListNodesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetPageSize 

func (x *ListNodesRequest) GetPageSize() int32

func (*ListNodesRequest) GetPageToken 

func (x *ListNodesRequest) GetPageToken() string

func (*ListNodesRequest) GetParent 

func (x *ListNodesRequest) GetParent() string

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

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

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

type ListNodesResponse 

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
}

Response for [ListNodes][mockgcp.cloud.tpu.v2.Tpu.ListNodes].

func (*ListNodesResponse) Descriptor deprecated 

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetNextPageToken 

func (x *ListNodesResponse) GetNextPageToken() string

func (*ListNodesResponse) GetNodes 

func (x *ListNodesResponse) GetNodes() []*Node

func (*ListNodesResponse) GetUnreachable 

func (x *ListNodesResponse) GetUnreachable() []string

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

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

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

type ListQueuedResourcesRequest 

type ListQueuedResourcesRequest struct {

	// Required. The parent resource name.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of items to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. 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
}

Request for [ListQueuedResources][mockgcp.cloud.tpu.v2.Tpu.ListQueuedResources].

func (*ListQueuedResourcesRequest) Descriptor deprecated 

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

Deprecated: Use ListQueuedResourcesRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedResourcesRequest) GetPageSize 

func (x *ListQueuedResourcesRequest) GetPageSize() int32

func (*ListQueuedResourcesRequest) GetPageToken 

func (x *ListQueuedResourcesRequest) GetPageToken() string

func (*ListQueuedResourcesRequest) GetParent 

func (x *ListQueuedResourcesRequest) GetParent() string

func (*ListQueuedResourcesRequest) ProtoMessage 

func (*ListQueuedResourcesRequest) ProtoMessage()

func (*ListQueuedResourcesRequest) ProtoReflect 

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

func (*ListQueuedResourcesRequest) Reset 

func (x *ListQueuedResourcesRequest) Reset()

func (*ListQueuedResourcesRequest) String 

func (x *ListQueuedResourcesRequest) String() string

type ListQueuedResourcesResponse 

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
}

Response for [ListQueuedResources][mockgcp.cloud.tpu.v2.Tpu.ListQueuedResources].

func (*ListQueuedResourcesResponse) Descriptor deprecated 

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

Deprecated: Use ListQueuedResourcesResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedResourcesResponse) GetNextPageToken 

func (x *ListQueuedResourcesResponse) GetNextPageToken() string

func (*ListQueuedResourcesResponse) GetQueuedResources 

func (x *ListQueuedResourcesResponse) GetQueuedResources() []*QueuedResource

func (*ListQueuedResourcesResponse) GetUnreachable 

func (x *ListQueuedResourcesResponse) GetUnreachable() []string

func (*ListQueuedResourcesResponse) ProtoMessage 

func (*ListQueuedResourcesResponse) ProtoMessage()

func (*ListQueuedResourcesResponse) ProtoReflect 

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

func (*ListQueuedResourcesResponse) Reset 

func (x *ListQueuedResourcesResponse) Reset()

func (*ListQueuedResourcesResponse) String 

func (x *ListQueuedResourcesResponse) String() string

type ListRuntimeVersionsRequest 

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
}

Request for [ListRuntimeVersions][mockgcp.cloud.tpu.v2.Tpu.ListRuntimeVersions].

func (*ListRuntimeVersionsRequest) Descriptor deprecated 

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

Deprecated: Use ListRuntimeVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListRuntimeVersionsRequest) GetFilter 

func (x *ListRuntimeVersionsRequest) GetFilter() string

func (*ListRuntimeVersionsRequest) GetOrderBy 

func (x *ListRuntimeVersionsRequest) GetOrderBy() string

func (*ListRuntimeVersionsRequest) GetPageSize 

func (x *ListRuntimeVersionsRequest) GetPageSize() int32

func (*ListRuntimeVersionsRequest) GetPageToken 

func (x *ListRuntimeVersionsRequest) GetPageToken() string

func (*ListRuntimeVersionsRequest) GetParent 

func (x *ListRuntimeVersionsRequest) GetParent() string

func (*ListRuntimeVersionsRequest) ProtoMessage 

func (*ListRuntimeVersionsRequest) ProtoMessage()

func (*ListRuntimeVersionsRequest) ProtoReflect 

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

func (*ListRuntimeVersionsRequest) Reset 

func (x *ListRuntimeVersionsRequest) Reset()

func (*ListRuntimeVersionsRequest) String 

func (x *ListRuntimeVersionsRequest) String() string

type ListRuntimeVersionsResponse 

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
}

Response for [ListRuntimeVersions][mockgcp.cloud.tpu.v2.Tpu.ListRuntimeVersions].

func (*ListRuntimeVersionsResponse) Descriptor deprecated 

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

Deprecated: Use ListRuntimeVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListRuntimeVersionsResponse) GetNextPageToken 

func (x *ListRuntimeVersionsResponse) GetNextPageToken() string

func (*ListRuntimeVersionsResponse) GetRuntimeVersions 

func (x *ListRuntimeVersionsResponse) GetRuntimeVersions() []*RuntimeVersion

func (*ListRuntimeVersionsResponse) GetUnreachable 

func (x *ListRuntimeVersionsResponse) GetUnreachable() []string

func (*ListRuntimeVersionsResponse) ProtoMessage 

func (*ListRuntimeVersionsResponse) ProtoMessage()

func (*ListRuntimeVersionsResponse) ProtoReflect 

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

func (*ListRuntimeVersionsResponse) Reset 

func (x *ListRuntimeVersionsResponse) Reset()

func (*ListRuntimeVersionsResponse) String 

func (x *ListRuntimeVersionsResponse) String() string

type NetworkConfig 

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"`
	// Optional. Specifies networking queue count for TPU VM instance's network
	// interface.
	QueueCount int32 `protobuf:"varint,6,opt,name=queue_count,json=queueCount,proto3" json:"queue_count,omitempty"`
	// contains filtered or unexported fields
}

Network related configurations.

func (*NetworkConfig) Descriptor deprecated 

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

Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.

func (*NetworkConfig) GetCanIpForward 

func (x *NetworkConfig) GetCanIpForward() bool

func (*NetworkConfig) GetEnableExternalIps 

func (x *NetworkConfig) GetEnableExternalIps() bool

func (*NetworkConfig) GetNetwork 

func (x *NetworkConfig) GetNetwork() string

func (*NetworkConfig) GetQueueCount 

func (x *NetworkConfig) GetQueueCount() int32

func (*NetworkConfig) GetSubnetwork 

func (x *NetworkConfig) GetSubnetwork() string

func (*NetworkConfig) ProtoMessage 

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect 

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

func (*NetworkConfig) Reset 

func (x *NetworkConfig) Reset()

func (*NetworkConfig) String 

func (x *NetworkConfig) String() string

type NetworkEndpoint 

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
}

A network endpoint over which a TPU worker can be reached.

func (*NetworkEndpoint) Descriptor deprecated 

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

Deprecated: Use NetworkEndpoint.ProtoReflect.Descriptor instead.

func (*NetworkEndpoint) GetAccessConfig 

func (x *NetworkEndpoint) GetAccessConfig() *AccessConfig

func (*NetworkEndpoint) GetIpAddress 

func (x *NetworkEndpoint) GetIpAddress() string

func (*NetworkEndpoint) GetPort 

func (x *NetworkEndpoint) GetPort() int32

func (*NetworkEndpoint) ProtoMessage 

func (*NetworkEndpoint) ProtoMessage()

func (*NetworkEndpoint) ProtoReflect 

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

func (*NetworkEndpoint) Reset 

func (x *NetworkEndpoint) Reset()

func (*NetworkEndpoint) String 

func (x *NetworkEndpoint) String() string

type Node 

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"`
	// Optional. 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=mockgcp.cloud.tpu.v2.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. network_config and network_configs
	// are mutually exclusive, you can only specify one of them. If both are
	// specified, an error will be returned.
	NetworkConfig *NetworkConfig `protobuf:"bytes,36,opt,name=network_config,json=networkConfig,proto3" json:"network_config,omitempty"`
	// Optional. Repeated network configurations for the TPU node. This field is
	// used to specify multiple networks configs for the TPU node. network_config
	// and network_configs are mutually exclusive, you can only specify one of
	// them. If both are specified, an error will be returned.
	NetworkConfigs []*NetworkConfig `protobuf:"bytes,49,rep,name=network_configs,json=networkConfigs,proto3" json:"network_configs,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 *timestamp.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=mockgcp.cloud.tpu.v2.Node_Health" json:"health,omitempty"`
	// Resource labels to represent user-provided metadata.
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// Custom metadata to apply to the TPU Node.
	// Can set startup-script and shutdown-script
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// 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 `` /* 135-byte string literal not displayed */
	// Output only. The Symptoms that have occurred to the TPU Node.
	Symptoms []*Symptom `protobuf:"bytes,39,rep,name=symptoms,proto3" json:"symptoms,omitempty"`
	// Shielded Instance options.
	ShieldedInstanceConfig *ShieldedInstanceConfig `` /* 130-byte string literal not displayed */
	// The AccleratorConfig for the TPU Node.
	AcceleratorConfig *AcceleratorConfig `protobuf:"bytes,46,opt,name=accelerator_config,json=acceleratorConfig,proto3" json:"accelerator_config,omitempty"`
	// Output only. The qualified name of the QueuedResource that requested this
	// Node.
	QueuedResource string `protobuf:"bytes,47,opt,name=queued_resource,json=queuedResource,proto3" json:"queued_resource,omitempty"`
	// Output only. Whether the Node belongs to a Multislice group.
	MultisliceNode bool `protobuf:"varint,48,opt,name=multislice_node,json=multisliceNode,proto3" json:"multislice_node,omitempty"`
	// contains filtered or unexported fields
}

A TPU instance.

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAcceleratorConfig 

func (x *Node) GetAcceleratorConfig() *AcceleratorConfig

func (*Node) GetAcceleratorType 

func (x *Node) GetAcceleratorType() string

func (*Node) GetApiVersion 

func (x *Node) GetApiVersion() Node_ApiVersion

func (*Node) GetCidrBlock 

func (x *Node) GetCidrBlock() string

func (*Node) GetCreateTime 

func (x *Node) GetCreateTime() *timestamp.Timestamp

func (*Node) GetDataDisks 

func (x *Node) GetDataDisks() []*AttachedDisk

func (*Node) GetDescription 

func (x *Node) GetDescription() string

func (*Node) GetHealth 

func (x *Node) GetHealth() Node_Health

func (*Node) GetHealthDescription 

func (x *Node) GetHealthDescription() string

func (*Node) GetId 

func (x *Node) GetId() int64

func (*Node) GetLabels 

func (x *Node) GetLabels() map[string]string

func (*Node) GetMetadata 

func (x *Node) GetMetadata() map[string]string

func (*Node) GetMultisliceNode 

func (x *Node) GetMultisliceNode() bool

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetNetworkConfig 

func (x *Node) GetNetworkConfig() *NetworkConfig

func (*Node) GetNetworkConfigs 

func (x *Node) GetNetworkConfigs() []*NetworkConfig

func (*Node) GetNetworkEndpoints 

func (x *Node) GetNetworkEndpoints() []*NetworkEndpoint

func (*Node) GetQueuedResource 

func (x *Node) GetQueuedResource() string

func (*Node) GetRuntimeVersion 

func (x *Node) GetRuntimeVersion() string

func (*Node) GetSchedulingConfig 

func (x *Node) GetSchedulingConfig() *SchedulingConfig

func (*Node) GetServiceAccount 

func (x *Node) GetServiceAccount() *ServiceAccount

func (*Node) GetShieldedInstanceConfig 

func (x *Node) GetShieldedInstanceConfig() *ShieldedInstanceConfig

func (*Node) GetState 

func (x *Node) GetState() Node_State

func (*Node) GetSymptoms 

func (x *Node) GetSymptoms() []*Symptom

func (*Node) GetTags 

func (x *Node) GetTags() []string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type Node_ApiVersion 

type Node_ApiVersion int32

TPU API Version. 

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
	// TPU API V2 version.
	Node_V2 Node_ApiVersion = 4
)

func (Node_ApiVersion) Descriptor 

func (Node_ApiVersion) Descriptor() protoreflect.EnumDescriptor

func (Node_ApiVersion) Enum 

func (x Node_ApiVersion) Enum() *Node_ApiVersion

func (Node_ApiVersion) EnumDescriptor deprecated 

func (Node_ApiVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use Node_ApiVersion.Descriptor instead.

func (Node_ApiVersion) Number 

func (x Node_ApiVersion) Number() protoreflect.EnumNumber

func (Node_ApiVersion) String 

func (x Node_ApiVersion) String() string

func (Node_ApiVersion) Type 

func (Node_ApiVersion) Type() protoreflect.EnumType

type Node_Health 

type Node_Health int32

Health defines the status of a TPU node as reported by Health Monitor. 

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 

func (Node_Health) Descriptor() protoreflect.EnumDescriptor

func (Node_Health) Enum 

func (x Node_Health) Enum() *Node_Health

func (Node_Health) EnumDescriptor deprecated 

func (Node_Health) EnumDescriptor() ([]byte, []int)

Deprecated: Use Node_Health.Descriptor instead.

func (Node_Health) Number 

func (x Node_Health) Number() protoreflect.EnumNumber

func (Node_Health) String 

func (x Node_Health) String() string

func (Node_Health) Type 

func (Node_Health) Type() protoreflect.EnumType

type Node_State 

type Node_State int32

Represents the different states of a TPU node during its lifecycle. 

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
	// TPU node has unknown state after a failed repair.
	Node_UNKNOWN Node_State = 16
)

func (Node_State) Descriptor 

func (Node_State) Descriptor() protoreflect.EnumDescriptor

func (Node_State) Enum 

func (x Node_State) Enum() *Node_State

func (Node_State) EnumDescriptor deprecated 

func (Node_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Node_State.Descriptor instead.

func (Node_State) Number 

func (x Node_State) Number() protoreflect.EnumNumber

func (Node_State) String 

func (x Node_State) String() string

func (Node_State) Type 

func (Node_State) Type() protoreflect.EnumType

type OperationMetadata 

type OperationMetadata struct {

	// The time the operation was created.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The time the operation finished running.
	EndTime *timestamp.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
}

Metadata describing an [Operation][google.longrunning.Operation]

func (*OperationMetadata) Descriptor deprecated 

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion 

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCancelRequested 

func (x *OperationMetadata) GetCancelRequested() bool

func (*OperationMetadata) GetCreateTime 

func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp

func (*OperationMetadata) GetStatusDetail 

func (x *OperationMetadata) GetStatusDetail() string

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb 

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

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

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type QueuedResource 

type QueuedResource struct {

	// Output only. Immutable. The name of the QueuedResource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The time when the QueuedResource was created.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,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_Spot_
	//	*QueuedResource_Guaranteed_
	Tier isQueuedResource_Tier `protobuf_oneof:"tier"`
	// Optional. 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"`
	// Optional. Name of the reservation in which the resource should be
	// provisioned. Format:
	// projects/{project}/locations/{zone}/reservations/{reservation}
	ReservationName string `protobuf:"bytes,7,opt,name=reservation_name,json=reservationName,proto3" json:"reservation_name,omitempty"`
	// contains filtered or unexported fields
}

A QueuedResource represents a request for resources that will be placed in a queue and fulfilled when the necessary resources are available.

func (*QueuedResource) Descriptor deprecated 

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

Deprecated: Use QueuedResource.ProtoReflect.Descriptor instead.

func (*QueuedResource) GetCreateTime 

func (x *QueuedResource) GetCreateTime() *timestamp.Timestamp

func (*QueuedResource) GetGuaranteed 

func (x *QueuedResource) GetGuaranteed() *QueuedResource_Guaranteed

func (*QueuedResource) GetName 

func (x *QueuedResource) GetName() string

func (*QueuedResource) GetQueueingPolicy 

func (x *QueuedResource) GetQueueingPolicy() *QueuedResource_QueueingPolicy

func (*QueuedResource) GetReservationName 

func (x *QueuedResource) GetReservationName() string

func (*QueuedResource) GetResource 

func (m *QueuedResource) GetResource() isQueuedResource_Resource

func (*QueuedResource) GetSpot 

func (x *QueuedResource) GetSpot() *QueuedResource_Spot

func (*QueuedResource) GetState 

func (x *QueuedResource) GetState() *QueuedResourceState

func (*QueuedResource) GetTier 

func (m *QueuedResource) GetTier() isQueuedResource_Tier

func (*QueuedResource) GetTpu 

func (x *QueuedResource) GetTpu() *QueuedResource_Tpu

func (*QueuedResource) ProtoMessage 

func (*QueuedResource) ProtoMessage()

func (*QueuedResource) ProtoReflect 

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

func (*QueuedResource) Reset 

func (x *QueuedResource) Reset()

func (*QueuedResource) String 

func (x *QueuedResource) String() string

type QueuedResourceState 

type QueuedResourceState struct {

	// Output only. State of the QueuedResource request.
	State QueuedResourceState_State `protobuf:"varint,1,opt,name=state,proto3,enum=mockgcp.cloud.tpu.v2.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"`
	// Output only. The initiator of the QueuedResources's current state. Used to
	// indicate whether the SUSPENDING/SUSPENDED state was initiated by the user
	// or the service.
	StateInitiator QueuedResourceState_StateInitiator `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueuedResourceState defines the details of the QueuedResource request.

func (*QueuedResourceState) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState.ProtoReflect.Descriptor instead.

func (*QueuedResourceState) GetAcceptedData 

func (x *QueuedResourceState) GetAcceptedData() *QueuedResourceState_AcceptedData

func (*QueuedResourceState) GetActiveData 

func (x *QueuedResourceState) GetActiveData() *QueuedResourceState_ActiveData

func (*QueuedResourceState) GetCreatingData 

func (x *QueuedResourceState) GetCreatingData() *QueuedResourceState_CreatingData

func (*QueuedResourceState) GetDeletingData 

func (x *QueuedResourceState) GetDeletingData() *QueuedResourceState_DeletingData

func (*QueuedResourceState) GetFailedData 

func (x *QueuedResourceState) GetFailedData() *QueuedResourceState_FailedData

func (*QueuedResourceState) GetProvisioningData 

func (x *QueuedResourceState) GetProvisioningData() *QueuedResourceState_ProvisioningData

func (*QueuedResourceState) GetState 

func (x *QueuedResourceState) GetState() QueuedResourceState_State

func (*QueuedResourceState) GetStateData 

func (m *QueuedResourceState) GetStateData() isQueuedResourceState_StateData

func (*QueuedResourceState) GetStateInitiator 

func (x *QueuedResourceState) GetStateInitiator() QueuedResourceState_StateInitiator

func (*QueuedResourceState) GetSuspendedData 

func (x *QueuedResourceState) GetSuspendedData() *QueuedResourceState_SuspendedData

func (*QueuedResourceState) GetSuspendingData 

func (x *QueuedResourceState) GetSuspendingData() *QueuedResourceState_SuspendingData

func (*QueuedResourceState) ProtoMessage 

func (*QueuedResourceState) ProtoMessage()

func (*QueuedResourceState) ProtoReflect 

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

func (*QueuedResourceState) Reset 

func (x *QueuedResourceState) Reset()

func (*QueuedResourceState) String 

func (x *QueuedResourceState) String() string

type QueuedResourceState_AcceptedData 

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

Further data for the accepted state.

func (*QueuedResourceState_AcceptedData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_AcceptedData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_AcceptedData) ProtoMessage 

func (*QueuedResourceState_AcceptedData) ProtoMessage()

func (*QueuedResourceState_AcceptedData) ProtoReflect 

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

func (*QueuedResourceState_AcceptedData) Reset 

func (x *QueuedResourceState_AcceptedData) Reset()

func (*QueuedResourceState_AcceptedData) String 

func (x *QueuedResourceState_AcceptedData) String() string

type QueuedResourceState_AcceptedData_ 

type QueuedResourceState_AcceptedData_ struct {
	// Output only. Further data for the accepted state.
	AcceptedData *QueuedResourceState_AcceptedData `protobuf:"bytes,3,opt,name=accepted_data,json=acceptedData,proto3,oneof"`
}

type QueuedResourceState_ActiveData 

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

Further data for the active state.

func (*QueuedResourceState_ActiveData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_ActiveData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_ActiveData) ProtoMessage 

func (*QueuedResourceState_ActiveData) ProtoMessage()

func (*QueuedResourceState_ActiveData) ProtoReflect 

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

func (*QueuedResourceState_ActiveData) Reset 

func (x *QueuedResourceState_ActiveData) Reset()

func (*QueuedResourceState_ActiveData) String 

func (x *QueuedResourceState_ActiveData) String() string

type QueuedResourceState_ActiveData_ 

type QueuedResourceState_ActiveData_ struct {
	// Output only. Further data for the active state.
	ActiveData *QueuedResourceState_ActiveData `protobuf:"bytes,7,opt,name=active_data,json=activeData,proto3,oneof"`
}

type QueuedResourceState_CreatingData 

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

Further data for the creating state.

func (*QueuedResourceState_CreatingData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_CreatingData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_CreatingData) ProtoMessage 

func (*QueuedResourceState_CreatingData) ProtoMessage()

func (*QueuedResourceState_CreatingData) ProtoReflect 

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

func (*QueuedResourceState_CreatingData) Reset 

func (x *QueuedResourceState_CreatingData) Reset()

func (*QueuedResourceState_CreatingData) String 

func (x *QueuedResourceState_CreatingData) String() string

type QueuedResourceState_CreatingData_ 

type QueuedResourceState_CreatingData_ struct {
	// Output only. Further data for the creating state.
	CreatingData *QueuedResourceState_CreatingData `protobuf:"bytes,2,opt,name=creating_data,json=creatingData,proto3,oneof"`
}

type QueuedResourceState_DeletingData 

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

Further data for the deleting state.

func (*QueuedResourceState_DeletingData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_DeletingData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_DeletingData) ProtoMessage 

func (*QueuedResourceState_DeletingData) ProtoMessage()

func (*QueuedResourceState_DeletingData) ProtoReflect 

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

func (*QueuedResourceState_DeletingData) Reset 

func (x *QueuedResourceState_DeletingData) Reset()

func (*QueuedResourceState_DeletingData) String 

func (x *QueuedResourceState_DeletingData) String() string

type QueuedResourceState_DeletingData_ 

type QueuedResourceState_DeletingData_ struct {
	// Output only. Further data for the deleting state.
	DeletingData *QueuedResourceState_DeletingData `protobuf:"bytes,6,opt,name=deleting_data,json=deletingData,proto3,oneof"`
}

type QueuedResourceState_FailedData 

type QueuedResourceState_FailedData struct {

	// Output only. 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
}

Further data for the failed state.

func (*QueuedResourceState_FailedData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_FailedData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_FailedData) GetError 

func (x *QueuedResourceState_FailedData) GetError() *status.Status

func (*QueuedResourceState_FailedData) ProtoMessage 

func (*QueuedResourceState_FailedData) ProtoMessage()

func (*QueuedResourceState_FailedData) ProtoReflect 

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

func (*QueuedResourceState_FailedData) Reset 

func (x *QueuedResourceState_FailedData) Reset()

func (*QueuedResourceState_FailedData) String 

func (x *QueuedResourceState_FailedData) String() string

type QueuedResourceState_FailedData_ 

type QueuedResourceState_FailedData_ struct {
	// Output only. Further data for the failed state.
	FailedData *QueuedResourceState_FailedData `protobuf:"bytes,5,opt,name=failed_data,json=failedData,proto3,oneof"`
}

type QueuedResourceState_ProvisioningData 

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

Further data for the provisioning state.

func (*QueuedResourceState_ProvisioningData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_ProvisioningData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_ProvisioningData) ProtoMessage 

func (*QueuedResourceState_ProvisioningData) ProtoMessage()

func (*QueuedResourceState_ProvisioningData) ProtoReflect 

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

func (*QueuedResourceState_ProvisioningData) Reset 

func (x *QueuedResourceState_ProvisioningData) Reset()

func (*QueuedResourceState_ProvisioningData) String 

func (x *QueuedResourceState_ProvisioningData) String() string

type QueuedResourceState_ProvisioningData_ 

type QueuedResourceState_ProvisioningData_ struct {
	// Output only. Further data for the provisioning state.
	ProvisioningData *QueuedResourceState_ProvisioningData `protobuf:"bytes,4,opt,name=provisioning_data,json=provisioningData,proto3,oneof"`
}

type QueuedResourceState_State 

type QueuedResourceState_State int32

Output only state of the request 

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
	// The QueuedResource request has passed initial validation and has been
	// persisted in the queue. It will remain in this state until there are
	// sufficient free resources to begin provisioning your request. Wait times
	// will vary significantly depending on demand levels. When demand is high,
	// not all requests can be immediately provisioned. If you
	// need more reliable obtainability of TPUs consider purchasing a
	// reservation. To put a limit on how long you are willing to wait, use
	// [timing
	// constraints](https://cloud.google.com/tpu/docs/queued-resources#request_a_queued_resource_before_a_specified_time).
	QueuedResourceState_WAITING_FOR_RESOURCES QueuedResourceState_State = 9
)

func (QueuedResourceState_State) Descriptor 

func (QueuedResourceState_State) Descriptor() protoreflect.EnumDescriptor

func (QueuedResourceState_State) Enum 

func (x QueuedResourceState_State) Enum() *QueuedResourceState_State

func (QueuedResourceState_State) EnumDescriptor deprecated 

func (QueuedResourceState_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueuedResourceState_State.Descriptor instead.

func (QueuedResourceState_State) Number 

func (x QueuedResourceState_State) Number() protoreflect.EnumNumber

func (QueuedResourceState_State) String 

func (x QueuedResourceState_State) String() string

func (QueuedResourceState_State) Type 

func (QueuedResourceState_State) Type() protoreflect.EnumType

type QueuedResourceState_StateInitiator 

type QueuedResourceState_StateInitiator int32

The initiator of the QueuedResource's SUSPENDING/SUSPENDED state. 

const (
	// The state initiator is unspecified.
	QueuedResourceState_STATE_INITIATOR_UNSPECIFIED QueuedResourceState_StateInitiator = 0
	// The current QueuedResource state was initiated by the user.
	QueuedResourceState_USER QueuedResourceState_StateInitiator = 1
	// The current QueuedResource state was initiated by the service.
	QueuedResourceState_SERVICE QueuedResourceState_StateInitiator = 2
)

func (QueuedResourceState_StateInitiator) Descriptor 

func (QueuedResourceState_StateInitiator) Descriptor() protoreflect.EnumDescriptor

func (QueuedResourceState_StateInitiator) Enum 

func (x QueuedResourceState_StateInitiator) Enum() *QueuedResourceState_StateInitiator

func (QueuedResourceState_StateInitiator) EnumDescriptor deprecated 

func (QueuedResourceState_StateInitiator) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueuedResourceState_StateInitiator.Descriptor instead.

func (QueuedResourceState_StateInitiator) Number 

func (x QueuedResourceState_StateInitiator) Number() protoreflect.EnumNumber

func (QueuedResourceState_StateInitiator) String 

func (x QueuedResourceState_StateInitiator) String() string

func (QueuedResourceState_StateInitiator) Type 

func (QueuedResourceState_StateInitiator) Type() protoreflect.EnumType

type QueuedResourceState_SuspendedData 

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

Further data for the suspended state.

func (*QueuedResourceState_SuspendedData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_SuspendedData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_SuspendedData) ProtoMessage 

func (*QueuedResourceState_SuspendedData) ProtoMessage()

func (*QueuedResourceState_SuspendedData) ProtoReflect 

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

func (*QueuedResourceState_SuspendedData) Reset 

func (x *QueuedResourceState_SuspendedData) Reset()

func (*QueuedResourceState_SuspendedData) String 

func (x *QueuedResourceState_SuspendedData) String() string

type QueuedResourceState_SuspendedData_ 

type QueuedResourceState_SuspendedData_ struct {
	// Output only. Further data for the suspended state.
	SuspendedData *QueuedResourceState_SuspendedData `protobuf:"bytes,9,opt,name=suspended_data,json=suspendedData,proto3,oneof"`
}

type QueuedResourceState_SuspendingData 

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

Further data for the suspending state.

func (*QueuedResourceState_SuspendingData) Descriptor deprecated 

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

Deprecated: Use QueuedResourceState_SuspendingData.ProtoReflect.Descriptor instead.

func (*QueuedResourceState_SuspendingData) ProtoMessage 

func (*QueuedResourceState_SuspendingData) ProtoMessage()

func (*QueuedResourceState_SuspendingData) ProtoReflect 

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

func (*QueuedResourceState_SuspendingData) Reset 

func (x *QueuedResourceState_SuspendingData) Reset()

func (*QueuedResourceState_SuspendingData) String 

func (x *QueuedResourceState_SuspendingData) String() string

type QueuedResourceState_SuspendingData_ 

type QueuedResourceState_SuspendingData_ struct {
	// Output only. Further data for the suspending state.
	SuspendingData *QueuedResourceState_SuspendingData `protobuf:"bytes,8,opt,name=suspending_data,json=suspendingData,proto3,oneof"`
}

type QueuedResource_Guaranteed 

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 *duration.Duration `protobuf:"bytes,1,opt,name=min_duration,json=minDuration,proto3" json:"min_duration,omitempty"`
	// contains filtered or unexported fields
}

Guaranteed tier definition.

func (*QueuedResource_Guaranteed) Descriptor deprecated 

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

Deprecated: Use QueuedResource_Guaranteed.ProtoReflect.Descriptor instead.

func (*QueuedResource_Guaranteed) GetMinDuration 

func (x *QueuedResource_Guaranteed) GetMinDuration() *duration.Duration

func (*QueuedResource_Guaranteed) ProtoMessage 

func (*QueuedResource_Guaranteed) ProtoMessage()

func (*QueuedResource_Guaranteed) ProtoReflect 

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

func (*QueuedResource_Guaranteed) Reset 

func (x *QueuedResource_Guaranteed) Reset()

func (*QueuedResource_Guaranteed) String 

func (x *QueuedResource_Guaranteed) String() string

type QueuedResource_Guaranteed_ 

type QueuedResource_Guaranteed_ struct {
	// Optional. The Guaranteed tier
	Guaranteed *QueuedResource_Guaranteed `protobuf:"bytes,4,opt,name=guaranteed,proto3,oneof"`
}

type QueuedResource_QueueingPolicy 

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
}

Defines the policy of the QueuedRequest.

func (*QueuedResource_QueueingPolicy) Descriptor deprecated 

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

Deprecated: Use QueuedResource_QueueingPolicy.ProtoReflect.Descriptor instead.

func (*QueuedResource_QueueingPolicy) GetStartTimingConstraints 

func (m *QueuedResource_QueueingPolicy) GetStartTimingConstraints() isQueuedResource_QueueingPolicy_StartTimingConstraints

func (*QueuedResource_QueueingPolicy) GetValidAfterDuration 

func (x *QueuedResource_QueueingPolicy) GetValidAfterDuration() *duration.Duration

func (*QueuedResource_QueueingPolicy) GetValidAfterTime 

func (x *QueuedResource_QueueingPolicy) GetValidAfterTime() *timestamp.Timestamp

func (*QueuedResource_QueueingPolicy) GetValidInterval 

func (x *QueuedResource_QueueingPolicy) GetValidInterval() *interval.Interval

func (*QueuedResource_QueueingPolicy) GetValidUntilDuration 

func (x *QueuedResource_QueueingPolicy) GetValidUntilDuration() *duration.Duration

func (*QueuedResource_QueueingPolicy) GetValidUntilTime 

func (x *QueuedResource_QueueingPolicy) GetValidUntilTime() *timestamp.Timestamp

func (*QueuedResource_QueueingPolicy) ProtoMessage 

func (*QueuedResource_QueueingPolicy) ProtoMessage()

func (*QueuedResource_QueueingPolicy) ProtoReflect 

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

func (*QueuedResource_QueueingPolicy) Reset 

func (x *QueuedResource_QueueingPolicy) Reset()

func (*QueuedResource_QueueingPolicy) String 

func (x *QueuedResource_QueueingPolicy) String() string

type QueuedResource_QueueingPolicy_ValidAfterDuration 

type QueuedResource_QueueingPolicy_ValidAfterDuration struct {
	// Optional. A relative time after which resources may be created.
	ValidAfterDuration *duration.Duration `protobuf:"bytes,3,opt,name=valid_after_duration,json=validAfterDuration,proto3,oneof"`
}

type QueuedResource_QueueingPolicy_ValidAfterTime 

type QueuedResource_QueueingPolicy_ValidAfterTime struct {
	// Optional. An absolute time after which resources may be created.
	ValidAfterTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=valid_after_time,json=validAfterTime,proto3,oneof"`
}

type QueuedResource_QueueingPolicy_ValidInterval 

type QueuedResource_QueueingPolicy_ValidInterval struct {
	// Optional. 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 

type QueuedResource_QueueingPolicy_ValidUntilDuration struct {
	// Optional. 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 *duration.Duration `protobuf:"bytes,1,opt,name=valid_until_duration,json=validUntilDuration,proto3,oneof"`
}

type QueuedResource_QueueingPolicy_ValidUntilTime 

type QueuedResource_QueueingPolicy_ValidUntilTime struct {
	// Optional. 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 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=valid_until_time,json=validUntilTime,proto3,oneof"`
}

type QueuedResource_Spot 

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

Spot tier definition.

func (*QueuedResource_Spot) Descriptor deprecated 

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

Deprecated: Use QueuedResource_Spot.ProtoReflect.Descriptor instead.

func (*QueuedResource_Spot) ProtoMessage 

func (*QueuedResource_Spot) ProtoMessage()

func (*QueuedResource_Spot) ProtoReflect 

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

func (*QueuedResource_Spot) Reset 

func (x *QueuedResource_Spot) Reset()

func (*QueuedResource_Spot) String 

func (x *QueuedResource_Spot) String() string

type QueuedResource_Spot_ 

type QueuedResource_Spot_ struct {
	// Optional. The Spot tier.
	Spot *QueuedResource_Spot `protobuf:"bytes,3,opt,name=spot,proto3,oneof"`
}

type QueuedResource_Tpu 

type QueuedResource_Tpu struct {

	// Optional. 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
}

Details of the TPU resource(s) being requested.

func (*QueuedResource_Tpu) Descriptor deprecated 

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

Deprecated: Use QueuedResource_Tpu.ProtoReflect.Descriptor instead.

func (*QueuedResource_Tpu) GetNodeSpec 

func (x *QueuedResource_Tpu) GetNodeSpec() []*QueuedResource_Tpu_NodeSpec

func (*QueuedResource_Tpu) ProtoMessage 

func (*QueuedResource_Tpu) ProtoMessage()

func (*QueuedResource_Tpu) ProtoReflect 

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

func (*QueuedResource_Tpu) Reset 

func (x *QueuedResource_Tpu) Reset()

func (*QueuedResource_Tpu) String 

func (x *QueuedResource_Tpu) String() string

type QueuedResource_Tpu_ 

type QueuedResource_Tpu_ struct {
	// Optional. Defines a TPU resource.
	Tpu *QueuedResource_Tpu `protobuf:"bytes,2,opt,name=tpu,proto3,oneof"`
}

type QueuedResource_Tpu_NodeSpec 

type QueuedResource_Tpu_NodeSpec struct {

	// Required. The parent resource name.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Either a node_id or multislice_params.
	//
	// Types that are assignable to NameStrategy:
	//
	//	*QueuedResource_Tpu_NodeSpec_NodeId
	//	*QueuedResource_Tpu_NodeSpec_MultisliceParams_
	NameStrategy isQueuedResource_Tpu_NodeSpec_NameStrategy `protobuf_oneof:"name_strategy"`
	// Required. The node.
	Node *Node `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

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.

func (*QueuedResource_Tpu_NodeSpec) Descriptor deprecated 

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

Deprecated: Use QueuedResource_Tpu_NodeSpec.ProtoReflect.Descriptor instead.

func (*QueuedResource_Tpu_NodeSpec) GetMultisliceParams 

func (x *QueuedResource_Tpu_NodeSpec) GetMultisliceParams() *QueuedResource_Tpu_NodeSpec_MultisliceParams

func (*QueuedResource_Tpu_NodeSpec) GetNameStrategy 

func (m *QueuedResource_Tpu_NodeSpec) GetNameStrategy() isQueuedResource_Tpu_NodeSpec_NameStrategy

func (*QueuedResource_Tpu_NodeSpec) GetNode 

func (x *QueuedResource_Tpu_NodeSpec) GetNode() *Node

func (*QueuedResource_Tpu_NodeSpec) GetNodeId 

func (x *QueuedResource_Tpu_NodeSpec) GetNodeId() string

func (*QueuedResource_Tpu_NodeSpec) GetParent 

func (x *QueuedResource_Tpu_NodeSpec) GetParent() string

func (*QueuedResource_Tpu_NodeSpec) ProtoMessage 

func (*QueuedResource_Tpu_NodeSpec) ProtoMessage()

func (*QueuedResource_Tpu_NodeSpec) ProtoReflect 

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

func (*QueuedResource_Tpu_NodeSpec) Reset 

func (x *QueuedResource_Tpu_NodeSpec) Reset()

func (*QueuedResource_Tpu_NodeSpec) String 

func (x *QueuedResource_Tpu_NodeSpec) String() string

type QueuedResource_Tpu_NodeSpec_MultisliceParams 

type QueuedResource_Tpu_NodeSpec_MultisliceParams struct {

	// Required. Number of nodes with this spec. The system will attempt
	// to provision "node_count" nodes as part of the request.
	// This needs to be > 1.
	NodeCount int32 `protobuf:"varint,1,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// Optional. Prefix of node_ids in case of multislice request.
	// Should follow the `^[A-Za-z0-9_.~+%-]+$` regex format.
	// If node_count = 3 and node_id_prefix = "np", node ids of nodes
	// created will be "np-0", "np-1", "np-2". If this field is not
	// provided we use queued_resource_id as the node_id_prefix.
	NodeIdPrefix string `protobuf:"bytes,2,opt,name=node_id_prefix,json=nodeIdPrefix,proto3" json:"node_id_prefix,omitempty"`
	// contains filtered or unexported fields
}

Parameters to specify for multislice QueuedResource requests. This message must be populated in case of multislice requests instead of node_id.

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) Descriptor deprecated 

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

Deprecated: Use QueuedResource_Tpu_NodeSpec_MultisliceParams.ProtoReflect.Descriptor instead.

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) GetNodeCount 

func (x *QueuedResource_Tpu_NodeSpec_MultisliceParams) GetNodeCount() int32

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) GetNodeIdPrefix 

func (x *QueuedResource_Tpu_NodeSpec_MultisliceParams) GetNodeIdPrefix() string

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) ProtoMessage 

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) ProtoMessage()

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) ProtoReflect 

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

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) Reset 

func (x *QueuedResource_Tpu_NodeSpec_MultisliceParams) Reset()

func (*QueuedResource_Tpu_NodeSpec_MultisliceParams) String 

func (x *QueuedResource_Tpu_NodeSpec_MultisliceParams) String() string

type QueuedResource_Tpu_NodeSpec_MultisliceParams_ 

type QueuedResource_Tpu_NodeSpec_MultisliceParams_ struct {
	// Optional. Fields to specify in case of multislice request.
	MultisliceParams *QueuedResource_Tpu_NodeSpec_MultisliceParams `protobuf:"bytes,3,opt,name=multislice_params,json=multisliceParams,proto3,oneof"`
}

type QueuedResource_Tpu_NodeSpec_NodeId 

type QueuedResource_Tpu_NodeSpec_NodeId struct {
	// Optional. 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 multislice requests,
	// multislice_params must be populated instead.
	NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3,oneof"`
}

type ResetQueuedResourceRequest 

type ResetQueuedResourceRequest struct {

	// Required. The name of the queued resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [ResetQueuedResource][mockgcp.cloud.tpu.v2.Tpu.ResetQueuedResource].

func (*ResetQueuedResourceRequest) Descriptor deprecated 

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

Deprecated: Use ResetQueuedResourceRequest.ProtoReflect.Descriptor instead.

func (*ResetQueuedResourceRequest) GetName 

func (x *ResetQueuedResourceRequest) GetName() string

func (*ResetQueuedResourceRequest) ProtoMessage 

func (*ResetQueuedResourceRequest) ProtoMessage()

func (*ResetQueuedResourceRequest) ProtoReflect 

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

func (*ResetQueuedResourceRequest) Reset 

func (x *ResetQueuedResourceRequest) Reset()

func (*ResetQueuedResourceRequest) String 

func (x *ResetQueuedResourceRequest) String() string

type RuntimeVersion 

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
}

A runtime version that a Node can be configured with.

func (*RuntimeVersion) Descriptor deprecated 

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

Deprecated: Use RuntimeVersion.ProtoReflect.Descriptor instead.

func (*RuntimeVersion) GetName 

func (x *RuntimeVersion) GetName() string

func (*RuntimeVersion) GetVersion 

func (x *RuntimeVersion) GetVersion() string

func (*RuntimeVersion) ProtoMessage 

func (*RuntimeVersion) ProtoMessage()

func (*RuntimeVersion) ProtoReflect 

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

func (*RuntimeVersion) Reset 

func (x *RuntimeVersion) Reset()

func (*RuntimeVersion) String 

func (x *RuntimeVersion) String() string

type SchedulingConfig 

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"`
	// Optional. Defines whether the node is Spot VM.
	Spot bool `protobuf:"varint,3,opt,name=spot,proto3" json:"spot,omitempty"`
	// contains filtered or unexported fields
}

Sets the scheduling options for this node.

func (*SchedulingConfig) Descriptor deprecated 

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

Deprecated: Use SchedulingConfig.ProtoReflect.Descriptor instead.

func (*SchedulingConfig) GetPreemptible 

func (x *SchedulingConfig) GetPreemptible() bool

func (*SchedulingConfig) GetReserved 

func (x *SchedulingConfig) GetReserved() bool

func (*SchedulingConfig) GetSpot 

func (x *SchedulingConfig) GetSpot() bool

func (*SchedulingConfig) ProtoMessage 

func (*SchedulingConfig) ProtoMessage()

func (*SchedulingConfig) ProtoReflect 

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

func (*SchedulingConfig) Reset 

func (x *SchedulingConfig) Reset()

func (*SchedulingConfig) String 

func (x *SchedulingConfig) String() string

type ServiceAccount 

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
}

A service account.

func (*ServiceAccount) Descriptor deprecated 

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

Deprecated: Use ServiceAccount.ProtoReflect.Descriptor instead.

func (*ServiceAccount) GetEmail 

func (x *ServiceAccount) GetEmail() string

func (*ServiceAccount) GetScope 

func (x *ServiceAccount) GetScope() []string

func (*ServiceAccount) ProtoMessage 

func (*ServiceAccount) ProtoMessage()

func (*ServiceAccount) ProtoReflect 

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

func (*ServiceAccount) Reset 

func (x *ServiceAccount) Reset()

func (*ServiceAccount) String 

func (x *ServiceAccount) String() string

type ServiceIdentity 

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
}

The per-product per-project service identity for Cloud TPU service.

func (*ServiceIdentity) Descriptor deprecated 

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

Deprecated: Use ServiceIdentity.ProtoReflect.Descriptor instead.

func (*ServiceIdentity) GetEmail 

func (x *ServiceIdentity) GetEmail() string

func (*ServiceIdentity) ProtoMessage 

func (*ServiceIdentity) ProtoMessage()

func (*ServiceIdentity) ProtoReflect 

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

func (*ServiceIdentity) Reset 

func (x *ServiceIdentity) Reset()

func (*ServiceIdentity) String 

func (x *ServiceIdentity) String() string

type ShieldedInstanceConfig 

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
}

A set of Shielded Instance options.

func (*ShieldedInstanceConfig) Descriptor deprecated 

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

Deprecated: Use ShieldedInstanceConfig.ProtoReflect.Descriptor instead.

func (*ShieldedInstanceConfig) GetEnableSecureBoot 

func (x *ShieldedInstanceConfig) GetEnableSecureBoot() bool

func (*ShieldedInstanceConfig) ProtoMessage 

func (*ShieldedInstanceConfig) ProtoMessage()

func (*ShieldedInstanceConfig) ProtoReflect 

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

func (*ShieldedInstanceConfig) Reset 

func (x *ShieldedInstanceConfig) Reset()

func (*ShieldedInstanceConfig) String 

func (x *ShieldedInstanceConfig) String() string

type StartNodeRequest 

type StartNodeRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [StartNode][mockgcp.cloud.tpu.v2.Tpu.StartNode].

func (*StartNodeRequest) Descriptor deprecated 

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

Deprecated: Use StartNodeRequest.ProtoReflect.Descriptor instead.

func (*StartNodeRequest) GetName 

func (x *StartNodeRequest) GetName() string

func (*StartNodeRequest) ProtoMessage 

func (*StartNodeRequest) ProtoMessage()

func (*StartNodeRequest) ProtoReflect 

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

func (*StartNodeRequest) Reset 

func (x *StartNodeRequest) Reset()

func (*StartNodeRequest) String 

func (x *StartNodeRequest) String() string

type StopNodeRequest 

type StopNodeRequest struct {

	// Required. The resource name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for [StopNode][mockgcp.cloud.tpu.v2.Tpu.StopNode].

func (*StopNodeRequest) Descriptor deprecated 

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

Deprecated: Use StopNodeRequest.ProtoReflect.Descriptor instead.

func (*StopNodeRequest) GetName 

func (x *StopNodeRequest) GetName() string

func (*StopNodeRequest) ProtoMessage 

func (*StopNodeRequest) ProtoMessage()

func (*StopNodeRequest) ProtoReflect 

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

func (*StopNodeRequest) Reset 

func (x *StopNodeRequest) Reset()

func (*StopNodeRequest) String 

func (x *StopNodeRequest) String() string

type Symptom 

type Symptom struct {

	// Timestamp when the Symptom is created.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Type of the Symptom.
	SymptomType Symptom_SymptomType `` /* 141-byte string literal not displayed */
	// 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
}

A Symptom instance.

func (*Symptom) Descriptor deprecated 

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

Deprecated: Use Symptom.ProtoReflect.Descriptor instead.

func (*Symptom) GetCreateTime 

func (x *Symptom) GetCreateTime() *timestamp.Timestamp

func (*Symptom) GetDetails 

func (x *Symptom) GetDetails() string

func (*Symptom) GetSymptomType 

func (x *Symptom) GetSymptomType() Symptom_SymptomType

func (*Symptom) GetWorkerId 

func (x *Symptom) GetWorkerId() string

func (*Symptom) ProtoMessage 

func (*Symptom) ProtoMessage()

func (*Symptom) ProtoReflect 

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

func (*Symptom) Reset 

func (x *Symptom) Reset()

func (*Symptom) String 

func (x *Symptom) String() string

type Symptom_SymptomType 

type Symptom_SymptomType int32

SymptomType represents the different types of Symptoms that a TPU can be at. 

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 

func (Symptom_SymptomType) Descriptor() protoreflect.EnumDescriptor

func (Symptom_SymptomType) Enum 

func (x Symptom_SymptomType) Enum() *Symptom_SymptomType

func (Symptom_SymptomType) EnumDescriptor deprecated 

func (Symptom_SymptomType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Symptom_SymptomType.Descriptor instead.

func (Symptom_SymptomType) Number 

func (x Symptom_SymptomType) Number() protoreflect.EnumNumber

func (Symptom_SymptomType) String 

func (x Symptom_SymptomType) String() string

func (Symptom_SymptomType) Type 

func (Symptom_SymptomType) Type() protoreflect.EnumType

type TpuClient 

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) (*longrunningpb.Operation, error)
	// Deletes a node.
	DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Stops a node. This operation is only available with single TPU nodes.
	StopNode(ctx context.Context, in *StopNodeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Starts a node.
	StartNode(ctx context.Context, in *StartNodeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates the configurations of a node.
	UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*longrunningpb.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) (*longrunningpb.Operation, error)
	// Deletes a QueuedResource TPU instance.
	DeleteQueuedResource(ctx context.Context, in *DeleteQueuedResourceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Resets a QueuedResource TPU instance
	ResetQueuedResource(ctx context.Context, in *ResetQueuedResourceRequest, opts ...grpc.CallOption) (*longrunningpb.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)
}

TpuClient is the client API for Tpu service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTpuClient 

func NewTpuClient(cc grpc.ClientConnInterface) TpuClient

type TpuServer 

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) (*longrunningpb.Operation, error)
	// Deletes a node.
	DeleteNode(context.Context, *DeleteNodeRequest) (*longrunningpb.Operation, error)
	// Stops a node. This operation is only available with single TPU nodes.
	StopNode(context.Context, *StopNodeRequest) (*longrunningpb.Operation, error)
	// Starts a node.
	StartNode(context.Context, *StartNodeRequest) (*longrunningpb.Operation, error)
	// Updates the configurations of a node.
	UpdateNode(context.Context, *UpdateNodeRequest) (*longrunningpb.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) (*longrunningpb.Operation, error)
	// Deletes a QueuedResource TPU instance.
	DeleteQueuedResource(context.Context, *DeleteQueuedResourceRequest) (*longrunningpb.Operation, error)
	// Resets a QueuedResource TPU instance
	ResetQueuedResource(context.Context, *ResetQueuedResourceRequest) (*longrunningpb.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)
	// contains filtered or unexported methods
}

TpuServer is the server API for Tpu service. All implementations must embed UnimplementedTpuServer for forward compatibility

type UnimplementedTpuServer 

type UnimplementedTpuServer struct {
}

UnimplementedTpuServer must be embedded to have forward compatible implementations.

func (UnimplementedTpuServer) CreateNode 

func (UnimplementedTpuServer) CreateNode(context.Context, *CreateNodeRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) CreateQueuedResource 

func (UnimplementedTpuServer) CreateQueuedResource(context.Context, *CreateQueuedResourceRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) DeleteNode 

func (UnimplementedTpuServer) DeleteNode(context.Context, *DeleteNodeRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) DeleteQueuedResource 

func (UnimplementedTpuServer) DeleteQueuedResource(context.Context, *DeleteQueuedResourceRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) GenerateServiceIdentity 

func (UnimplementedTpuServer) GenerateServiceIdentity(context.Context, *GenerateServiceIdentityRequest) (*GenerateServiceIdentityResponse, error)

func (UnimplementedTpuServer) GetAcceleratorType 

func (UnimplementedTpuServer) GetAcceleratorType(context.Context, *GetAcceleratorTypeRequest) (*AcceleratorType, error)

func (UnimplementedTpuServer) GetGuestAttributes 

func (UnimplementedTpuServer) GetGuestAttributes(context.Context, *GetGuestAttributesRequest) (*GetGuestAttributesResponse, error)

func (UnimplementedTpuServer) GetNode 

func (UnimplementedTpuServer) GetNode(context.Context, *GetNodeRequest) (*Node, error)

func (UnimplementedTpuServer) GetQueuedResource 

func (UnimplementedTpuServer) GetQueuedResource(context.Context, *GetQueuedResourceRequest) (*QueuedResource, error)

func (UnimplementedTpuServer) GetRuntimeVersion 

func (UnimplementedTpuServer) GetRuntimeVersion(context.Context, *GetRuntimeVersionRequest) (*RuntimeVersion, error)

func (UnimplementedTpuServer) ListAcceleratorTypes 

func (UnimplementedTpuServer) ListAcceleratorTypes(context.Context, *ListAcceleratorTypesRequest) (*ListAcceleratorTypesResponse, error)

func (UnimplementedTpuServer) ListNodes 

func (UnimplementedTpuServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)

func (UnimplementedTpuServer) ListQueuedResources 

func (UnimplementedTpuServer) ListQueuedResources(context.Context, *ListQueuedResourcesRequest) (*ListQueuedResourcesResponse, error)

func (UnimplementedTpuServer) ListRuntimeVersions 

func (UnimplementedTpuServer) ListRuntimeVersions(context.Context, *ListRuntimeVersionsRequest) (*ListRuntimeVersionsResponse, error)

func (UnimplementedTpuServer) ResetQueuedResource 

func (UnimplementedTpuServer) ResetQueuedResource(context.Context, *ResetQueuedResourceRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) StartNode 

func (UnimplementedTpuServer) StartNode(context.Context, *StartNodeRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) StopNode 

func (UnimplementedTpuServer) StopNode(context.Context, *StopNodeRequest) (*longrunningpb.Operation, error)

func (UnimplementedTpuServer) UpdateNode 

func (UnimplementedTpuServer) UpdateNode(context.Context, *UpdateNodeRequest) (*longrunningpb.Operation, error)

type UnsafeTpuServer 

type UnsafeTpuServer interface {
	// contains filtered or unexported methods
}

UnsafeTpuServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TpuServer will result in compilation errors.

type UpdateNodeRequest 

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 *field_mask.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
}

Request for [UpdateNode][mockgcp.cloud.tpu.v2.Tpu.UpdateNode].

func (*UpdateNodeRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeRequest) GetNode 

func (x *UpdateNodeRequest) GetNode() *Node

func (*UpdateNodeRequest) GetUpdateMask 

func (x *UpdateNodeRequest) GetUpdateMask() *field_mask.FieldMask

func (*UpdateNodeRequest) ProtoMessage 

func (*UpdateNodeRequest) ProtoMessage()

func (*UpdateNodeRequest) ProtoReflect 

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

func (*UpdateNodeRequest) Reset 

func (x *UpdateNodeRequest) Reset()

func (*UpdateNodeRequest) String 

func (x *UpdateNodeRequest) String() string

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.