datasphere

package
v0.0.0-...-5fa7aab Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ProjectJobService_Create_FullMethodName           = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/Create"
	ProjectJobService_Clone_FullMethodName            = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/Clone"
	ProjectJobService_Execute_FullMethodName          = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/Execute"
	ProjectJobService_Cancel_FullMethodName           = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/Cancel"
	ProjectJobService_ReadStdLogs_FullMethodName      = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/ReadStdLogs"
	ProjectJobService_ReadLogs_FullMethodName         = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/ReadLogs"
	ProjectJobService_DownloadJobFiles_FullMethodName = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/DownloadJobFiles"
	ProjectJobService_List_FullMethodName             = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/List"
	ProjectJobService_Get_FullMethodName              = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/Get"
	ProjectJobService_Delete_FullMethodName           = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/Delete"
	ProjectJobService_DeleteData_FullMethodName       = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/DeleteData"
	ProjectJobService_DeleteAllData_FullMethodName    = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/DeleteAllData"
	ProjectJobService_SetDataTtl_FullMethodName       = "/yandex.cloud.datasphere.v2.jobs.ProjectJobService/SetDataTtl"
)

Variables

View Source
var (
	FileCompressionType_name = map[int32]string{
		0: "FILE_COMPRESSION_TYPE_UNSPECIFIED",
		1: "NONE",
		2: "ZIP",
	}
	FileCompressionType_value = map[string]int32{
		"FILE_COMPRESSION_TYPE_UNSPECIFIED": 0,
		"NONE":                              1,
		"ZIP":                               2,
	}
)

Enum value maps for FileCompressionType.

View Source
var (
	JobStatus_name = map[int32]string{
		0: "JOB_STATUS_UNSPECIFIED",
		1: "CREATING",
		2: "EXECUTING",
		3: "UPLOADING_OUTPUT",
		4: "SUCCESS",
		5: "ERROR",
		6: "CANCELLED",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_UNSPECIFIED": 0,
		"CREATING":               1,
		"EXECUTING":              2,
		"UPLOADING_OUTPUT":       3,
		"SUCCESS":                4,
		"ERROR":                  5,
		"CANCELLED":              6,
	}
)

Enum value maps for JobStatus.

View Source
var (
	ExtendedWorkingStorage_StorageType_name = map[int32]string{
		0: "STORAGE_TYPE_UNSPECIFIED",
		1: "SSD",
	}
	ExtendedWorkingStorage_StorageType_value = map[string]int32{
		"STORAGE_TYPE_UNSPECIFIED": 0,
		"SSD":                      1,
	}
)

Enum value maps for ExtendedWorkingStorage_StorageType.

View Source
var (
	StandardStream_name = map[int32]string{
		0: "STANDARD_STREAM_UNSPECIFIED",
		1: "OUT",
		2: "ERR",
	}
	StandardStream_value = map[string]int32{
		"STANDARD_STREAM_UNSPECIFIED": 0,
		"OUT":                         1,
		"ERR":                         2,
	}
)

Enum value maps for StandardStream.

View Source
var (
	StdLog_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "OUT",
		2: "ERR",
	}
	StdLog_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"OUT":              1,
		"ERR":              2,
	}
)

Enum value maps for StdLog_Type.

View Source
var File_yandex_cloud_datasphere_v2_jobs_jobs_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_datasphere_v2_jobs_project_job_service_proto protoreflect.FileDescriptor
View Source
var ProjectJobService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.datasphere.v2.jobs.ProjectJobService",
	HandlerType: (*ProjectJobServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _ProjectJobService_Create_Handler,
		},
		{
			MethodName: "Clone",
			Handler:    _ProjectJobService_Clone_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _ProjectJobService_Execute_Handler,
		},
		{
			MethodName: "Cancel",
			Handler:    _ProjectJobService_Cancel_Handler,
		},
		{
			MethodName: "DownloadJobFiles",
			Handler:    _ProjectJobService_DownloadJobFiles_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ProjectJobService_List_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ProjectJobService_Get_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ProjectJobService_Delete_Handler,
		},
		{
			MethodName: "DeleteData",
			Handler:    _ProjectJobService_DeleteData_Handler,
		},
		{
			MethodName: "DeleteAllData",
			Handler:    _ProjectJobService_DeleteAllData_Handler,
		},
		{
			MethodName: "SetDataTtl",
			Handler:    _ProjectJobService_SetDataTtl_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReadStdLogs",
			Handler:       _ProjectJobService_ReadStdLogs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReadLogs",
			Handler:       _ProjectJobService_ReadLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "yandex/cloud/datasphere/v2/jobs/project_job_service.proto",
}

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

Functions

func RegisterProjectJobServiceServer

func RegisterProjectJobServiceServer(s grpc.ServiceRegistrar, srv ProjectJobServiceServer)

Types

type Argument

type Argument struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Argument) Descriptor deprecated

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

Deprecated: Use Argument.ProtoReflect.Descriptor instead.

func (*Argument) GetName

func (x *Argument) GetName() string

func (*Argument) GetValue

func (x *Argument) GetValue() string

func (*Argument) ProtoMessage

func (*Argument) ProtoMessage()

func (*Argument) ProtoReflect

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

func (*Argument) Reset

func (x *Argument) Reset()

func (*Argument) SetName

func (m *Argument) SetName(v string)

func (*Argument) SetValue

func (m *Argument) SetValue(v string)

func (*Argument) String

func (x *Argument) String() string

type CancelProjectJobRequest

type CancelProjectJobRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Optional cancellation reason.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelProjectJobRequest) Descriptor deprecated

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

Deprecated: Use CancelProjectJobRequest.ProtoReflect.Descriptor instead.

func (*CancelProjectJobRequest) GetJobId

func (x *CancelProjectJobRequest) GetJobId() string

func (*CancelProjectJobRequest) GetReason

func (x *CancelProjectJobRequest) GetReason() string

func (*CancelProjectJobRequest) ProtoMessage

func (*CancelProjectJobRequest) ProtoMessage()

func (*CancelProjectJobRequest) ProtoReflect

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

func (*CancelProjectJobRequest) Reset

func (x *CancelProjectJobRequest) Reset()

func (*CancelProjectJobRequest) SetJobId

func (m *CancelProjectJobRequest) SetJobId(v string)

func (*CancelProjectJobRequest) SetReason

func (m *CancelProjectJobRequest) SetReason(v string)

func (*CancelProjectJobRequest) String

func (x *CancelProjectJobRequest) String() string

type CloneProjectJobMetadata

type CloneProjectJobMetadata struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	JobId     string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloneProjectJobMetadata) Descriptor deprecated

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

Deprecated: Use CloneProjectJobMetadata.ProtoReflect.Descriptor instead.

func (*CloneProjectJobMetadata) GetJobId

func (x *CloneProjectJobMetadata) GetJobId() string

func (*CloneProjectJobMetadata) GetProjectId

func (x *CloneProjectJobMetadata) GetProjectId() string

func (*CloneProjectJobMetadata) ProtoMessage

func (*CloneProjectJobMetadata) ProtoMessage()

func (*CloneProjectJobMetadata) ProtoReflect

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

func (*CloneProjectJobMetadata) Reset

func (x *CloneProjectJobMetadata) Reset()

func (*CloneProjectJobMetadata) SetJobId

func (m *CloneProjectJobMetadata) SetJobId(v string)

func (*CloneProjectJobMetadata) SetProjectId

func (m *CloneProjectJobMetadata) SetProjectId(v string)

func (*CloneProjectJobMetadata) String

func (x *CloneProjectJobMetadata) String() string

type CloneProjectJobRequest

type CloneProjectJobRequest struct {

	// ID of job to be cloned.
	SourceJobId string `protobuf:"bytes,1,opt,name=source_job_id,json=sourceJobId,proto3" json:"source_job_id,omitempty"`
	// Parameters overrides.
	JobParametersOverrides *JobParameters `` /* 129-byte string literal not displayed */
	// New job name.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New job description
	Desc string `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`
	// Data ttl.
	DataTtl *durationpb.Duration `protobuf:"bytes,5,opt,name=data_ttl,json=dataTtl,proto3" json:"data_ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*CloneProjectJobRequest) Descriptor deprecated

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

Deprecated: Use CloneProjectJobRequest.ProtoReflect.Descriptor instead.

func (*CloneProjectJobRequest) GetDataTtl

func (x *CloneProjectJobRequest) GetDataTtl() *durationpb.Duration

func (*CloneProjectJobRequest) GetDesc

func (x *CloneProjectJobRequest) GetDesc() string

func (*CloneProjectJobRequest) GetJobParametersOverrides

func (x *CloneProjectJobRequest) GetJobParametersOverrides() *JobParameters

func (*CloneProjectJobRequest) GetName

func (x *CloneProjectJobRequest) GetName() string

func (*CloneProjectJobRequest) GetSourceJobId

func (x *CloneProjectJobRequest) GetSourceJobId() string

func (*CloneProjectJobRequest) ProtoMessage

func (*CloneProjectJobRequest) ProtoMessage()

func (*CloneProjectJobRequest) ProtoReflect

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

func (*CloneProjectJobRequest) Reset

func (x *CloneProjectJobRequest) Reset()

func (*CloneProjectJobRequest) SetDataTtl

func (m *CloneProjectJobRequest) SetDataTtl(v *durationpb.Duration)

func (*CloneProjectJobRequest) SetDesc

func (m *CloneProjectJobRequest) SetDesc(v string)

func (*CloneProjectJobRequest) SetJobParametersOverrides

func (m *CloneProjectJobRequest) SetJobParametersOverrides(v *JobParameters)

func (*CloneProjectJobRequest) SetName

func (m *CloneProjectJobRequest) SetName(v string)

func (*CloneProjectJobRequest) SetSourceJobId

func (m *CloneProjectJobRequest) SetSourceJobId(v string)

func (*CloneProjectJobRequest) String

func (x *CloneProjectJobRequest) String() string

type CloneProjectJobResponse

type CloneProjectJobResponse struct {

	// Job ID.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Files with presigned URLs generated by server to upload them to storage. Order is arbitrary.
	//
	// Upload files include input files, executable file (python main script or binary executable) and local modules
	// in case of python.
	//
	// If file was already uploaded, there will be no element for it.
	UploadFiles []*StorageFile `protobuf:"bytes,2,rep,name=upload_files,json=uploadFiles,proto3" json:"upload_files,omitempty"`
	// contains filtered or unexported fields
}

func (*CloneProjectJobResponse) Descriptor deprecated

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

Deprecated: Use CloneProjectJobResponse.ProtoReflect.Descriptor instead.

func (*CloneProjectJobResponse) GetJobId

func (x *CloneProjectJobResponse) GetJobId() string

func (*CloneProjectJobResponse) GetUploadFiles

func (x *CloneProjectJobResponse) GetUploadFiles() []*StorageFile

func (*CloneProjectJobResponse) ProtoMessage

func (*CloneProjectJobResponse) ProtoMessage()

func (*CloneProjectJobResponse) ProtoReflect

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

func (*CloneProjectJobResponse) Reset

func (x *CloneProjectJobResponse) Reset()

func (*CloneProjectJobResponse) SetJobId

func (m *CloneProjectJobResponse) SetJobId(v string)

func (*CloneProjectJobResponse) SetUploadFiles

func (m *CloneProjectJobResponse) SetUploadFiles(v []*StorageFile)

func (*CloneProjectJobResponse) String

func (x *CloneProjectJobResponse) String() string

type CloudInstanceType

type CloudInstanceType struct {

	// Name of DataSphere VM configuration.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudInstanceType) Descriptor deprecated

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

Deprecated: Use CloudInstanceType.ProtoReflect.Descriptor instead.

func (*CloudInstanceType) GetName

func (x *CloudInstanceType) GetName() string

func (*CloudInstanceType) ProtoMessage

func (*CloudInstanceType) ProtoMessage()

func (*CloudInstanceType) ProtoReflect

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

func (*CloudInstanceType) Reset

func (x *CloudInstanceType) Reset()

func (*CloudInstanceType) SetName

func (m *CloudInstanceType) SetName(v string)

func (*CloudInstanceType) String

func (x *CloudInstanceType) String() string

type CreateProjectJobMetadata

type CreateProjectJobMetadata struct {

	// ID of the project.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Job ID.
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateProjectJobMetadata) Descriptor deprecated

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

Deprecated: Use CreateProjectJobMetadata.ProtoReflect.Descriptor instead.

func (*CreateProjectJobMetadata) GetJobId

func (x *CreateProjectJobMetadata) GetJobId() string

func (*CreateProjectJobMetadata) GetProjectId

func (x *CreateProjectJobMetadata) GetProjectId() string

func (*CreateProjectJobMetadata) ProtoMessage

func (*CreateProjectJobMetadata) ProtoMessage()

func (*CreateProjectJobMetadata) ProtoReflect

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

func (*CreateProjectJobMetadata) Reset

func (x *CreateProjectJobMetadata) Reset()

func (*CreateProjectJobMetadata) SetJobId

func (m *CreateProjectJobMetadata) SetJobId(v string)

func (*CreateProjectJobMetadata) SetProjectId

func (m *CreateProjectJobMetadata) SetProjectId(v string)

func (*CreateProjectJobMetadata) String

func (x *CreateProjectJobMetadata) String() string

type CreateProjectJobRequest

type CreateProjectJobRequest struct {

	// ID of the project.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Parameters of the job.
	JobParameters *JobParameters `protobuf:"bytes,2,opt,name=job_parameters,json=jobParameters,proto3" json:"job_parameters,omitempty"`
	// Config of the job.
	Config string `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// Name of the job.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the job.
	Desc string `protobuf:"bytes,5,opt,name=desc,proto3" json:"desc,omitempty"`
	// Job data TTL.
	DataTtl *durationpb.Duration `protobuf:"bytes,6,opt,name=data_ttl,json=dataTtl,proto3" json:"data_ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateProjectJobRequest) Descriptor deprecated

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

Deprecated: Use CreateProjectJobRequest.ProtoReflect.Descriptor instead.

func (*CreateProjectJobRequest) GetConfig

func (x *CreateProjectJobRequest) GetConfig() string

func (*CreateProjectJobRequest) GetDataTtl

func (x *CreateProjectJobRequest) GetDataTtl() *durationpb.Duration

func (*CreateProjectJobRequest) GetDesc

func (x *CreateProjectJobRequest) GetDesc() string

func (*CreateProjectJobRequest) GetJobParameters

func (x *CreateProjectJobRequest) GetJobParameters() *JobParameters

func (*CreateProjectJobRequest) GetName

func (x *CreateProjectJobRequest) GetName() string

func (*CreateProjectJobRequest) GetProjectId

func (x *CreateProjectJobRequest) GetProjectId() string

func (*CreateProjectJobRequest) ProtoMessage

func (*CreateProjectJobRequest) ProtoMessage()

func (*CreateProjectJobRequest) ProtoReflect

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

func (*CreateProjectJobRequest) Reset

func (x *CreateProjectJobRequest) Reset()

func (*CreateProjectJobRequest) SetConfig

func (m *CreateProjectJobRequest) SetConfig(v string)

func (*CreateProjectJobRequest) SetDataTtl

func (m *CreateProjectJobRequest) SetDataTtl(v *durationpb.Duration)

func (*CreateProjectJobRequest) SetDesc

func (m *CreateProjectJobRequest) SetDesc(v string)

func (*CreateProjectJobRequest) SetJobParameters

func (m *CreateProjectJobRequest) SetJobParameters(v *JobParameters)

func (*CreateProjectJobRequest) SetName

func (m *CreateProjectJobRequest) SetName(v string)

func (*CreateProjectJobRequest) SetProjectId

func (m *CreateProjectJobRequest) SetProjectId(v string)

func (*CreateProjectJobRequest) String

func (x *CreateProjectJobRequest) String() string

type CreateProjectJobResponse

type CreateProjectJobResponse struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Files to upload with their presigned URLs for upload.
	UploadFiles []*StorageFile `protobuf:"bytes,2,rep,name=upload_files,json=uploadFiles,proto3" json:"upload_files,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateProjectJobResponse) Descriptor deprecated

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

Deprecated: Use CreateProjectJobResponse.ProtoReflect.Descriptor instead.

func (*CreateProjectJobResponse) GetJobId

func (x *CreateProjectJobResponse) GetJobId() string

func (*CreateProjectJobResponse) GetUploadFiles

func (x *CreateProjectJobResponse) GetUploadFiles() []*StorageFile

func (*CreateProjectJobResponse) ProtoMessage

func (*CreateProjectJobResponse) ProtoMessage()

func (*CreateProjectJobResponse) ProtoReflect

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

func (*CreateProjectJobResponse) Reset

func (x *CreateProjectJobResponse) Reset()

func (*CreateProjectJobResponse) SetJobId

func (m *CreateProjectJobResponse) SetJobId(v string)

func (*CreateProjectJobResponse) SetUploadFiles

func (m *CreateProjectJobResponse) SetUploadFiles(v []*StorageFile)

func (*CreateProjectJobResponse) String

func (x *CreateProjectJobResponse) String() string

type DeleteAllProjectJobDataMetadata

type DeleteAllProjectJobDataMetadata struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAllProjectJobDataMetadata) Descriptor deprecated

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

Deprecated: Use DeleteAllProjectJobDataMetadata.ProtoReflect.Descriptor instead.

func (*DeleteAllProjectJobDataMetadata) GetProjectId

func (x *DeleteAllProjectJobDataMetadata) GetProjectId() string

func (*DeleteAllProjectJobDataMetadata) ProtoMessage

func (*DeleteAllProjectJobDataMetadata) ProtoMessage()

func (*DeleteAllProjectJobDataMetadata) ProtoReflect

func (*DeleteAllProjectJobDataMetadata) Reset

func (*DeleteAllProjectJobDataMetadata) SetProjectId

func (m *DeleteAllProjectJobDataMetadata) SetProjectId(v string)

func (*DeleteAllProjectJobDataMetadata) String

type DeleteAllProjectJobDataRequest

type DeleteAllProjectJobDataRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAllProjectJobDataRequest) Descriptor deprecated

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

Deprecated: Use DeleteAllProjectJobDataRequest.ProtoReflect.Descriptor instead.

func (*DeleteAllProjectJobDataRequest) GetProjectId

func (x *DeleteAllProjectJobDataRequest) GetProjectId() string

func (*DeleteAllProjectJobDataRequest) ProtoMessage

func (*DeleteAllProjectJobDataRequest) ProtoMessage()

func (*DeleteAllProjectJobDataRequest) ProtoReflect

func (*DeleteAllProjectJobDataRequest) Reset

func (x *DeleteAllProjectJobDataRequest) Reset()

func (*DeleteAllProjectJobDataRequest) SetProjectId

func (m *DeleteAllProjectJobDataRequest) SetProjectId(v string)

func (*DeleteAllProjectJobDataRequest) String

type DeleteAllProjectJobDataResponse

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

func (*DeleteAllProjectJobDataResponse) Descriptor deprecated

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

Deprecated: Use DeleteAllProjectJobDataResponse.ProtoReflect.Descriptor instead.

func (*DeleteAllProjectJobDataResponse) ProtoMessage

func (*DeleteAllProjectJobDataResponse) ProtoMessage()

func (*DeleteAllProjectJobDataResponse) ProtoReflect

func (*DeleteAllProjectJobDataResponse) Reset

func (*DeleteAllProjectJobDataResponse) String

type DeleteProjectJobDataMetadata

type DeleteProjectJobDataMetadata struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteProjectJobDataMetadata) Descriptor deprecated

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

Deprecated: Use DeleteProjectJobDataMetadata.ProtoReflect.Descriptor instead.

func (*DeleteProjectJobDataMetadata) GetJobId

func (x *DeleteProjectJobDataMetadata) GetJobId() string

func (*DeleteProjectJobDataMetadata) ProtoMessage

func (*DeleteProjectJobDataMetadata) ProtoMessage()

func (*DeleteProjectJobDataMetadata) ProtoReflect

func (*DeleteProjectJobDataMetadata) Reset

func (x *DeleteProjectJobDataMetadata) Reset()

func (*DeleteProjectJobDataMetadata) SetJobId

func (m *DeleteProjectJobDataMetadata) SetJobId(v string)

func (*DeleteProjectJobDataMetadata) String

type DeleteProjectJobDataRequest

type DeleteProjectJobDataRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteProjectJobDataRequest) Descriptor deprecated

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

Deprecated: Use DeleteProjectJobDataRequest.ProtoReflect.Descriptor instead.

func (*DeleteProjectJobDataRequest) GetJobId

func (x *DeleteProjectJobDataRequest) GetJobId() string

func (*DeleteProjectJobDataRequest) ProtoMessage

func (*DeleteProjectJobDataRequest) ProtoMessage()

func (*DeleteProjectJobDataRequest) ProtoReflect

func (*DeleteProjectJobDataRequest) Reset

func (x *DeleteProjectJobDataRequest) Reset()

func (*DeleteProjectJobDataRequest) SetJobId

func (m *DeleteProjectJobDataRequest) SetJobId(v string)

func (*DeleteProjectJobDataRequest) String

func (x *DeleteProjectJobDataRequest) String() string

type DeleteProjectJobDataResponse

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

func (*DeleteProjectJobDataResponse) Descriptor deprecated

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

Deprecated: Use DeleteProjectJobDataResponse.ProtoReflect.Descriptor instead.

func (*DeleteProjectJobDataResponse) ProtoMessage

func (*DeleteProjectJobDataResponse) ProtoMessage()

func (*DeleteProjectJobDataResponse) ProtoReflect

func (*DeleteProjectJobDataResponse) Reset

func (x *DeleteProjectJobDataResponse) Reset()

func (*DeleteProjectJobDataResponse) String

type DeleteProjectJobMetadata

type DeleteProjectJobMetadata struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteProjectJobMetadata) Descriptor deprecated

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

Deprecated: Use DeleteProjectJobMetadata.ProtoReflect.Descriptor instead.

func (*DeleteProjectJobMetadata) GetJobId

func (x *DeleteProjectJobMetadata) GetJobId() string

func (*DeleteProjectJobMetadata) ProtoMessage

func (*DeleteProjectJobMetadata) ProtoMessage()

func (*DeleteProjectJobMetadata) ProtoReflect

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

func (*DeleteProjectJobMetadata) Reset

func (x *DeleteProjectJobMetadata) Reset()

func (*DeleteProjectJobMetadata) SetJobId

func (m *DeleteProjectJobMetadata) SetJobId(v string)

func (*DeleteProjectJobMetadata) String

func (x *DeleteProjectJobMetadata) String() string

type DeleteProjectJobRequest

type DeleteProjectJobRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteProjectJobRequest) Descriptor deprecated

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

Deprecated: Use DeleteProjectJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteProjectJobRequest) GetJobId

func (x *DeleteProjectJobRequest) GetJobId() string

func (*DeleteProjectJobRequest) ProtoMessage

func (*DeleteProjectJobRequest) ProtoMessage()

func (*DeleteProjectJobRequest) ProtoReflect

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

func (*DeleteProjectJobRequest) Reset

func (x *DeleteProjectJobRequest) Reset()

func (*DeleteProjectJobRequest) SetJobId

func (m *DeleteProjectJobRequest) SetJobId(v string)

func (*DeleteProjectJobRequest) String

func (x *DeleteProjectJobRequest) String() string

type DockerImageSpec

type DockerImageSpec struct {

	// Docker image URL.
	ImageUrl string `protobuf:"bytes,1,opt,name=image_url,json=imageUrl,proto3" json:"image_url,omitempty"`
	// Username for container registry.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Password for container registry.
	//
	// Types that are assignable to Password:
	//
	//	*DockerImageSpec_PasswordPlainText
	//	*DockerImageSpec_PasswordDsSecretName
	Password isDockerImageSpec_Password `protobuf_oneof:"password"`
	// contains filtered or unexported fields
}

func (*DockerImageSpec) Descriptor deprecated

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

Deprecated: Use DockerImageSpec.ProtoReflect.Descriptor instead.

func (*DockerImageSpec) GetImageUrl

func (x *DockerImageSpec) GetImageUrl() string

func (*DockerImageSpec) GetPassword

func (m *DockerImageSpec) GetPassword() isDockerImageSpec_Password

func (*DockerImageSpec) GetPasswordDsSecretName

func (x *DockerImageSpec) GetPasswordDsSecretName() string

func (*DockerImageSpec) GetPasswordPlainText

func (x *DockerImageSpec) GetPasswordPlainText() string

func (*DockerImageSpec) GetUsername

func (x *DockerImageSpec) GetUsername() string

func (*DockerImageSpec) ProtoMessage

func (*DockerImageSpec) ProtoMessage()

func (*DockerImageSpec) ProtoReflect

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

func (*DockerImageSpec) Reset

func (x *DockerImageSpec) Reset()

func (*DockerImageSpec) SetImageUrl

func (m *DockerImageSpec) SetImageUrl(v string)

func (*DockerImageSpec) SetPassword

func (m *DockerImageSpec) SetPassword(v DockerImageSpec_Password)

func (*DockerImageSpec) SetPasswordDsSecretName

func (m *DockerImageSpec) SetPasswordDsSecretName(v string)

func (*DockerImageSpec) SetPasswordPlainText

func (m *DockerImageSpec) SetPasswordPlainText(v string)

func (*DockerImageSpec) SetUsername

func (m *DockerImageSpec) SetUsername(v string)

func (*DockerImageSpec) String

func (x *DockerImageSpec) String() string

type DockerImageSpec_Password

type DockerImageSpec_Password = isDockerImageSpec_Password

type DockerImageSpec_PasswordDsSecretName

type DockerImageSpec_PasswordDsSecretName struct {
	// ID of DataSphere secret containing password.
	PasswordDsSecretName string `protobuf:"bytes,4,opt,name=password_ds_secret_name,json=passwordDsSecretName,proto3,oneof"`
}

type DockerImageSpec_PasswordPlainText

type DockerImageSpec_PasswordPlainText struct {
	// Plaintext password.
	PasswordPlainText string `protobuf:"bytes,3,opt,name=password_plain_text,json=passwordPlainText,proto3,oneof"`
}

type DownloadProjectJobFilesRequest

type DownloadProjectJobFilesRequest struct {
	JobId string  `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Files []*File `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadProjectJobFilesRequest) Descriptor deprecated

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

Deprecated: Use DownloadProjectJobFilesRequest.ProtoReflect.Descriptor instead.

func (*DownloadProjectJobFilesRequest) GetFiles

func (x *DownloadProjectJobFilesRequest) GetFiles() []*File

func (*DownloadProjectJobFilesRequest) GetJobId

func (x *DownloadProjectJobFilesRequest) GetJobId() string

func (*DownloadProjectJobFilesRequest) ProtoMessage

func (*DownloadProjectJobFilesRequest) ProtoMessage()

func (*DownloadProjectJobFilesRequest) ProtoReflect

func (*DownloadProjectJobFilesRequest) Reset

func (x *DownloadProjectJobFilesRequest) Reset()

func (*DownloadProjectJobFilesRequest) SetFiles

func (m *DownloadProjectJobFilesRequest) SetFiles(v []*File)

func (*DownloadProjectJobFilesRequest) SetJobId

func (m *DownloadProjectJobFilesRequest) SetJobId(v string)

func (*DownloadProjectJobFilesRequest) String

type DownloadProjectJobFilesResponse

type DownloadProjectJobFilesResponse struct {
	DownloadFiles []*StorageFile `protobuf:"bytes,1,rep,name=download_files,json=downloadFiles,proto3" json:"download_files,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadProjectJobFilesResponse) Descriptor deprecated

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

Deprecated: Use DownloadProjectJobFilesResponse.ProtoReflect.Descriptor instead.

func (*DownloadProjectJobFilesResponse) GetDownloadFiles

func (x *DownloadProjectJobFilesResponse) GetDownloadFiles() []*StorageFile

func (*DownloadProjectJobFilesResponse) ProtoMessage

func (*DownloadProjectJobFilesResponse) ProtoMessage()

func (*DownloadProjectJobFilesResponse) ProtoReflect

func (*DownloadProjectJobFilesResponse) Reset

func (*DownloadProjectJobFilesResponse) SetDownloadFiles

func (m *DownloadProjectJobFilesResponse) SetDownloadFiles(v []*StorageFile)

func (*DownloadProjectJobFilesResponse) String

type Environment

type Environment struct {

	// Environment variables.
	Vars map[string]string `` /* 149-byte string literal not displayed */
	// Types that are assignable to DockerImage:
	//
	//	*Environment_DockerImageResourceId
	//	*Environment_DockerImageSpec
	DockerImage isEnvironment_DockerImage `protobuf_oneof:"docker_image"`
	PythonEnv   *PythonEnv                `protobuf:"bytes,4,opt,name=python_env,json=pythonEnv,proto3" json:"python_env,omitempty"`
	// contains filtered or unexported fields
}

func (*Environment) Descriptor deprecated

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetDockerImage

func (m *Environment) GetDockerImage() isEnvironment_DockerImage

func (*Environment) GetDockerImageResourceId

func (x *Environment) GetDockerImageResourceId() string

func (*Environment) GetDockerImageSpec

func (x *Environment) GetDockerImageSpec() *DockerImageSpec

func (*Environment) GetPythonEnv

func (x *Environment) GetPythonEnv() *PythonEnv

func (*Environment) GetVars

func (x *Environment) GetVars() map[string]string

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect

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

func (*Environment) Reset

func (x *Environment) Reset()

func (*Environment) SetDockerImage

func (m *Environment) SetDockerImage(v Environment_DockerImage)

func (*Environment) SetDockerImageResourceId

func (m *Environment) SetDockerImageResourceId(v string)

func (*Environment) SetDockerImageSpec

func (m *Environment) SetDockerImageSpec(v *DockerImageSpec)

func (*Environment) SetPythonEnv

func (m *Environment) SetPythonEnv(v *PythonEnv)

func (*Environment) SetVars

func (m *Environment) SetVars(v map[string]string)

func (*Environment) String

func (x *Environment) String() string

type Environment_DockerImage

type Environment_DockerImage = isEnvironment_DockerImage

type Environment_DockerImageResourceId

type Environment_DockerImageResourceId struct {
	// DS docker image id.
	DockerImageResourceId string `protobuf:"bytes,2,opt,name=docker_image_resource_id,json=dockerImageResourceId,proto3,oneof"`
}

type Environment_DockerImageSpec

type Environment_DockerImageSpec struct {
	DockerImageSpec *DockerImageSpec `protobuf:"bytes,3,opt,name=docker_image_spec,json=dockerImageSpec,proto3,oneof"`
}

type ExecuteProjectJobMetadata

type ExecuteProjectJobMetadata struct {

	// Instance of the job.
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteProjectJobMetadata) Descriptor deprecated

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

Deprecated: Use ExecuteProjectJobMetadata.ProtoReflect.Descriptor instead.

func (*ExecuteProjectJobMetadata) GetJob

func (x *ExecuteProjectJobMetadata) GetJob() *Job

func (*ExecuteProjectJobMetadata) ProtoMessage

func (*ExecuteProjectJobMetadata) ProtoMessage()

func (*ExecuteProjectJobMetadata) ProtoReflect

func (*ExecuteProjectJobMetadata) Reset

func (x *ExecuteProjectJobMetadata) Reset()

func (*ExecuteProjectJobMetadata) SetJob

func (m *ExecuteProjectJobMetadata) SetJob(v *Job)

func (*ExecuteProjectJobMetadata) String

func (x *ExecuteProjectJobMetadata) String() string

type ExecuteProjectJobRequest

type ExecuteProjectJobRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteProjectJobRequest) Descriptor deprecated

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

Deprecated: Use ExecuteProjectJobRequest.ProtoReflect.Descriptor instead.

func (*ExecuteProjectJobRequest) GetJobId

func (x *ExecuteProjectJobRequest) GetJobId() string

func (*ExecuteProjectJobRequest) ProtoMessage

func (*ExecuteProjectJobRequest) ProtoMessage()

func (*ExecuteProjectJobRequest) ProtoReflect

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

func (*ExecuteProjectJobRequest) Reset

func (x *ExecuteProjectJobRequest) Reset()

func (*ExecuteProjectJobRequest) SetJobId

func (m *ExecuteProjectJobRequest) SetJobId(v string)

func (*ExecuteProjectJobRequest) String

func (x *ExecuteProjectJobRequest) String() string

type ExecuteProjectJobResponse

type ExecuteProjectJobResponse struct {

	// Uploaded output files with URLs.
	OutputFiles []*StorageFile `protobuf:"bytes,1,rep,name=output_files,json=outputFiles,proto3" json:"output_files,omitempty"`
	// Result of the job.
	Result *JobResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteProjectJobResponse) Descriptor deprecated

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

Deprecated: Use ExecuteProjectJobResponse.ProtoReflect.Descriptor instead.

func (*ExecuteProjectJobResponse) GetOutputFiles

func (x *ExecuteProjectJobResponse) GetOutputFiles() []*StorageFile

func (*ExecuteProjectJobResponse) GetResult

func (x *ExecuteProjectJobResponse) GetResult() *JobResult

func (*ExecuteProjectJobResponse) ProtoMessage

func (*ExecuteProjectJobResponse) ProtoMessage()

func (*ExecuteProjectJobResponse) ProtoReflect

func (*ExecuteProjectJobResponse) Reset

func (x *ExecuteProjectJobResponse) Reset()

func (*ExecuteProjectJobResponse) SetOutputFiles

func (m *ExecuteProjectJobResponse) SetOutputFiles(v []*StorageFile)

func (*ExecuteProjectJobResponse) SetResult

func (m *ExecuteProjectJobResponse) SetResult(v *JobResult)

func (*ExecuteProjectJobResponse) String

func (x *ExecuteProjectJobResponse) String() string

type ExtendedWorkingStorage

type ExtendedWorkingStorage struct {
	Type   ExtendedWorkingStorage_StorageType `` /* 134-byte string literal not displayed */
	SizeGb int64                              `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	// contains filtered or unexported fields
}

Extended working storage configuration.

func (*ExtendedWorkingStorage) Descriptor deprecated

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

Deprecated: Use ExtendedWorkingStorage.ProtoReflect.Descriptor instead.

func (*ExtendedWorkingStorage) GetSizeGb

func (x *ExtendedWorkingStorage) GetSizeGb() int64

func (*ExtendedWorkingStorage) GetType

func (*ExtendedWorkingStorage) ProtoMessage

func (*ExtendedWorkingStorage) ProtoMessage()

func (*ExtendedWorkingStorage) ProtoReflect

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

func (*ExtendedWorkingStorage) Reset

func (x *ExtendedWorkingStorage) Reset()

func (*ExtendedWorkingStorage) SetSizeGb

func (m *ExtendedWorkingStorage) SetSizeGb(v int64)

func (*ExtendedWorkingStorage) SetType

func (*ExtendedWorkingStorage) String

func (x *ExtendedWorkingStorage) String() string

type ExtendedWorkingStorage_StorageType

type ExtendedWorkingStorage_StorageType int32
const (
	ExtendedWorkingStorage_STORAGE_TYPE_UNSPECIFIED ExtendedWorkingStorage_StorageType = 0
	ExtendedWorkingStorage_SSD                      ExtendedWorkingStorage_StorageType = 1
)

func (ExtendedWorkingStorage_StorageType) Descriptor

func (ExtendedWorkingStorage_StorageType) Enum

func (ExtendedWorkingStorage_StorageType) EnumDescriptor deprecated

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

Deprecated: Use ExtendedWorkingStorage_StorageType.Descriptor instead.

func (ExtendedWorkingStorage_StorageType) Number

func (ExtendedWorkingStorage_StorageType) String

func (ExtendedWorkingStorage_StorageType) Type

type File

type File struct {
	Desc *FileDesc `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
	// SHA256 of the file.
	Sha256 string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// File size in bytes.
	SizeBytes int64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// File compression info
	CompressionType FileCompressionType `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetCompressionType

func (x *File) GetCompressionType() FileCompressionType

func (*File) GetDesc

func (x *File) GetDesc() *FileDesc

func (*File) GetSha256

func (x *File) GetSha256() string

func (*File) GetSizeBytes

func (x *File) GetSizeBytes() int64

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) ProtoReflect

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

func (*File) Reset

func (x *File) Reset()

func (*File) SetCompressionType

func (m *File) SetCompressionType(v FileCompressionType)

func (*File) SetDesc

func (m *File) SetDesc(v *FileDesc)

func (*File) SetSha256

func (m *File) SetSha256(v string)

func (*File) SetSizeBytes

func (m *File) SetSizeBytes(v int64)

func (*File) String

func (x *File) String() string

type FileCompressionType

type FileCompressionType int32
const (
	FileCompressionType_FILE_COMPRESSION_TYPE_UNSPECIFIED FileCompressionType = 0
	FileCompressionType_NONE                              FileCompressionType = 1
	FileCompressionType_ZIP                               FileCompressionType = 2
)

func (FileCompressionType) Descriptor

func (FileCompressionType) Enum

func (FileCompressionType) EnumDescriptor deprecated

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

Deprecated: Use FileCompressionType.Descriptor instead.

func (FileCompressionType) Number

func (FileCompressionType) String

func (x FileCompressionType) String() string

func (FileCompressionType) Type

type FileDesc

type FileDesc struct {

	// Path of the file on filesystem.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Variable to use in cmd substitution.
	Var string `protobuf:"bytes,2,opt,name=var,proto3" json:"var,omitempty"`
	// contains filtered or unexported fields
}

func (*FileDesc) Descriptor deprecated

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

Deprecated: Use FileDesc.ProtoReflect.Descriptor instead.

func (*FileDesc) GetPath

func (x *FileDesc) GetPath() string

func (*FileDesc) GetVar

func (x *FileDesc) GetVar() string

func (*FileDesc) ProtoMessage

func (*FileDesc) ProtoMessage()

func (*FileDesc) ProtoReflect

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

func (*FileDesc) Reset

func (x *FileDesc) Reset()

func (*FileDesc) SetPath

func (m *FileDesc) SetPath(v string)

func (*FileDesc) SetVar

func (m *FileDesc) SetVar(v string)

func (*FileDesc) String

func (x *FileDesc) String() string

type GetProjectJobRequest

type GetProjectJobRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProjectJobRequest) Descriptor deprecated

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

Deprecated: Use GetProjectJobRequest.ProtoReflect.Descriptor instead.

func (*GetProjectJobRequest) GetJobId

func (x *GetProjectJobRequest) GetJobId() string

func (*GetProjectJobRequest) ProtoMessage

func (*GetProjectJobRequest) ProtoMessage()

func (*GetProjectJobRequest) ProtoReflect

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

func (*GetProjectJobRequest) Reset

func (x *GetProjectJobRequest) Reset()

func (*GetProjectJobRequest) SetJobId

func (m *GetProjectJobRequest) SetJobId(v string)

func (*GetProjectJobRequest) String

func (x *GetProjectJobRequest) String() string

type Job

type Job struct {

	// ID of the job.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the job.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the job.
	Desc string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// Create job timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Start job timestamp.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Finish job timestamp.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Status of the job.
	Status JobStatus `protobuf:"varint,6,opt,name=status,proto3,enum=yandex.cloud.datasphere.v2.jobs.JobStatus" json:"status,omitempty"`
	// Config of the job, copied from configuration file.
	Config string `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	// ID of the user who created the job.
	CreatedById string `protobuf:"bytes,8,opt,name=created_by_id,json=createdById,proto3" json:"created_by_id,omitempty"`
	// ID of the project.
	ProjectId     string         `protobuf:"bytes,9,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	JobParameters *JobParameters `protobuf:"bytes,10,opt,name=job_parameters,json=jobParameters,proto3" json:"job_parameters,omitempty"`
	// Job data expiration timestamp.
	DataExpiresAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=data_expires_at,json=dataExpiresAt,proto3" json:"data_expires_at,omitempty"`
	// Marks if the job data has been cleared.
	DataCleared bool `protobuf:"varint,12,opt,name=data_cleared,json=dataCleared,proto3" json:"data_cleared,omitempty"`
	// Output files of the job.
	OutputFiles []*File `protobuf:"bytes,13,rep,name=output_files,json=outputFiles,proto3" json:"output_files,omitempty"`
	// Job log files.
	LogFiles []*File `protobuf:"bytes,14,rep,name=log_files,json=logFiles,proto3" json:"log_files,omitempty"`
	// Job diagnostics files.
	DiagnosticFiles []*File `protobuf:"bytes,15,rep,name=diagnostic_files,json=diagnosticFiles,proto3" json:"diagnostic_files,omitempty"`
	// Job total data size.
	DataSizeBytes int64 `protobuf:"varint,16,opt,name=data_size_bytes,json=dataSizeBytes,proto3" json:"data_size_bytes,omitempty"`
	// contains filtered or unexported fields
}

Instance of the job.

func (*Job) Descriptor deprecated

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetConfig

func (x *Job) GetConfig() string

func (*Job) GetCreatedAt

func (x *Job) GetCreatedAt() *timestamppb.Timestamp

func (*Job) GetCreatedById

func (x *Job) GetCreatedById() string

func (*Job) GetDataCleared

func (x *Job) GetDataCleared() bool

func (*Job) GetDataExpiresAt

func (x *Job) GetDataExpiresAt() *timestamppb.Timestamp

func (*Job) GetDataSizeBytes

func (x *Job) GetDataSizeBytes() int64

func (*Job) GetDesc

func (x *Job) GetDesc() string

func (*Job) GetDiagnosticFiles

func (x *Job) GetDiagnosticFiles() []*File

func (*Job) GetFinishedAt

func (x *Job) GetFinishedAt() *timestamppb.Timestamp

func (*Job) GetId

func (x *Job) GetId() string

func (*Job) GetJobParameters

func (x *Job) GetJobParameters() *JobParameters

func (*Job) GetLogFiles

func (x *Job) GetLogFiles() []*File

func (*Job) GetName

func (x *Job) GetName() string

func (*Job) GetOutputFiles

func (x *Job) GetOutputFiles() []*File

func (*Job) GetProjectId

func (x *Job) GetProjectId() string

func (*Job) GetStartedAt

func (x *Job) GetStartedAt() *timestamppb.Timestamp

func (*Job) GetStatus

func (x *Job) GetStatus() JobStatus

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

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

func (*Job) Reset

func (x *Job) Reset()

func (*Job) SetConfig

func (m *Job) SetConfig(v string)

func (*Job) SetCreatedAt

func (m *Job) SetCreatedAt(v *timestamppb.Timestamp)

func (*Job) SetCreatedById

func (m *Job) SetCreatedById(v string)

func (*Job) SetDataCleared

func (m *Job) SetDataCleared(v bool)

func (*Job) SetDataExpiresAt

func (m *Job) SetDataExpiresAt(v *timestamppb.Timestamp)

func (*Job) SetDataSizeBytes

func (m *Job) SetDataSizeBytes(v int64)

func (*Job) SetDesc

func (m *Job) SetDesc(v string)

func (*Job) SetDiagnosticFiles

func (m *Job) SetDiagnosticFiles(v []*File)

func (*Job) SetFinishedAt

func (m *Job) SetFinishedAt(v *timestamppb.Timestamp)

func (*Job) SetId

func (m *Job) SetId(v string)

func (*Job) SetJobParameters

func (m *Job) SetJobParameters(v *JobParameters)

func (*Job) SetLogFiles

func (m *Job) SetLogFiles(v []*File)

func (*Job) SetName

func (m *Job) SetName(v string)

func (*Job) SetOutputFiles

func (m *Job) SetOutputFiles(v []*File)

func (*Job) SetProjectId

func (m *Job) SetProjectId(v string)

func (*Job) SetStartedAt

func (m *Job) SetStartedAt(v *timestamppb.Timestamp)

func (*Job) SetStatus

func (m *Job) SetStatus(v JobStatus)

func (*Job) String

func (x *Job) String() string

type JobParameters

type JobParameters struct {

	// List of input files.
	InputFiles []*File `protobuf:"bytes,1,rep,name=input_files,json=inputFiles,proto3" json:"input_files,omitempty"`
	// List of output files descriptions.
	OutputFiles []*FileDesc `protobuf:"bytes,2,rep,name=output_files,json=outputFiles,proto3" json:"output_files,omitempty"`
	// List of DataSphere S3 mount ids.
	S3MountIds []string `protobuf:"bytes,3,rep,name=s3_mount_ids,json=s3MountIds,proto3" json:"s3_mount_ids,omitempty"`
	// List of DataSphere dataset ids.
	DatasetIds []string `protobuf:"bytes,4,rep,name=dataset_ids,json=datasetIds,proto3" json:"dataset_ids,omitempty"`
	// Job run command.
	Cmd string `protobuf:"bytes,5,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// Job environment description.
	Env *Environment `protobuf:"bytes,6,opt,name=env,proto3" json:"env,omitempty"`
	// Should project disk be attached to VM.
	AttachProjectDisk bool `protobuf:"varint,7,opt,name=attach_project_disk,json=attachProjectDisk,proto3" json:"attach_project_disk,omitempty"`
	// VM specification.
	CloudInstanceType *CloudInstanceType `protobuf:"bytes,8,opt,name=cloud_instance_type,json=cloudInstanceType,proto3" json:"cloud_instance_type,omitempty"`
	// Extended working storage configuration.
	ExtendedWorkingStorage *ExtendedWorkingStorage `` /* 129-byte string literal not displayed */
	// List of literal arguments.
	Arguments []*Argument `protobuf:"bytes,10,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// contains filtered or unexported fields
}

Job parameters.

func (*JobParameters) Descriptor deprecated

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

Deprecated: Use JobParameters.ProtoReflect.Descriptor instead.

func (*JobParameters) GetArguments

func (x *JobParameters) GetArguments() []*Argument

func (*JobParameters) GetAttachProjectDisk

func (x *JobParameters) GetAttachProjectDisk() bool

func (*JobParameters) GetCloudInstanceType

func (x *JobParameters) GetCloudInstanceType() *CloudInstanceType

func (*JobParameters) GetCmd

func (x *JobParameters) GetCmd() string

func (*JobParameters) GetDatasetIds

func (x *JobParameters) GetDatasetIds() []string

func (*JobParameters) GetEnv

func (x *JobParameters) GetEnv() *Environment

func (*JobParameters) GetExtendedWorkingStorage

func (x *JobParameters) GetExtendedWorkingStorage() *ExtendedWorkingStorage

func (*JobParameters) GetInputFiles

func (x *JobParameters) GetInputFiles() []*File

func (*JobParameters) GetOutputFiles

func (x *JobParameters) GetOutputFiles() []*FileDesc

func (*JobParameters) GetS3MountIds

func (x *JobParameters) GetS3MountIds() []string

func (*JobParameters) ProtoMessage

func (*JobParameters) ProtoMessage()

func (*JobParameters) ProtoReflect

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

func (*JobParameters) Reset

func (x *JobParameters) Reset()

func (*JobParameters) SetArguments

func (m *JobParameters) SetArguments(v []*Argument)

func (*JobParameters) SetAttachProjectDisk

func (m *JobParameters) SetAttachProjectDisk(v bool)

func (*JobParameters) SetCloudInstanceType

func (m *JobParameters) SetCloudInstanceType(v *CloudInstanceType)

func (*JobParameters) SetCmd

func (m *JobParameters) SetCmd(v string)

func (*JobParameters) SetDatasetIds

func (m *JobParameters) SetDatasetIds(v []string)

func (*JobParameters) SetEnv

func (m *JobParameters) SetEnv(v *Environment)

func (*JobParameters) SetExtendedWorkingStorage

func (m *JobParameters) SetExtendedWorkingStorage(v *ExtendedWorkingStorage)

func (*JobParameters) SetInputFiles

func (m *JobParameters) SetInputFiles(v []*File)

func (*JobParameters) SetOutputFiles

func (m *JobParameters) SetOutputFiles(v []*FileDesc)

func (*JobParameters) SetS3MountIds

func (m *JobParameters) SetS3MountIds(v []string)

func (*JobParameters) String

func (x *JobParameters) String() string

type JobResult

type JobResult struct {

	// Execution return code.
	ReturnCode int64 `protobuf:"varint,1,opt,name=return_code,json=returnCode,proto3" json:"return_code,omitempty"`
	// contains filtered or unexported fields
}

func (*JobResult) Descriptor deprecated

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

Deprecated: Use JobResult.ProtoReflect.Descriptor instead.

func (*JobResult) GetReturnCode

func (x *JobResult) GetReturnCode() int64

func (*JobResult) ProtoMessage

func (*JobResult) ProtoMessage()

func (*JobResult) ProtoReflect

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

func (*JobResult) Reset

func (x *JobResult) Reset()

func (*JobResult) SetReturnCode

func (m *JobResult) SetReturnCode(v int64)

func (*JobResult) String

func (x *JobResult) String() string

type JobStatus

type JobStatus int32
const (
	JobStatus_JOB_STATUS_UNSPECIFIED JobStatus = 0
	JobStatus_CREATING               JobStatus = 1
	JobStatus_EXECUTING              JobStatus = 2
	JobStatus_UPLOADING_OUTPUT       JobStatus = 3
	JobStatus_SUCCESS                JobStatus = 4
	JobStatus_ERROR                  JobStatus = 5
	JobStatus_CANCELLED              JobStatus = 6
)

func (JobStatus) Descriptor

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String

func (x JobStatus) String() string

func (JobStatus) Type

type ListProjectJobRequest

type ListProjectJobRequest struct {

	// ID of the project.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than [page_size],
	// the service returns a [ListProjectJobResponse.page_token]
	// that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set [page_token] to the
	// [ListProjectJobResponse.page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProjectJobRequest) Descriptor deprecated

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

Deprecated: Use ListProjectJobRequest.ProtoReflect.Descriptor instead.

func (*ListProjectJobRequest) GetPageSize

func (x *ListProjectJobRequest) GetPageSize() int64

func (*ListProjectJobRequest) GetPageToken

func (x *ListProjectJobRequest) GetPageToken() string

func (*ListProjectJobRequest) GetProjectId

func (x *ListProjectJobRequest) GetProjectId() string

func (*ListProjectJobRequest) ProtoMessage

func (*ListProjectJobRequest) ProtoMessage()

func (*ListProjectJobRequest) ProtoReflect

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

func (*ListProjectJobRequest) Reset

func (x *ListProjectJobRequest) Reset()

func (*ListProjectJobRequest) SetPageSize

func (m *ListProjectJobRequest) SetPageSize(v int64)

func (*ListProjectJobRequest) SetPageToken

func (m *ListProjectJobRequest) SetPageToken(v string)

func (*ListProjectJobRequest) SetProjectId

func (m *ListProjectJobRequest) SetProjectId(v string)

func (*ListProjectJobRequest) String

func (x *ListProjectJobRequest) String() string

type ListProjectJobResponse

type ListProjectJobResponse struct {

	// Instances of the jobs.
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// This token allows you to get the next page of results for list requests. If the number of results
	// is larger than [ListProjectJobRequest.page_size], use
	// the [next_page_token] as the value
	// for the [ListProjectJobRequest.page_token] query parameter
	// in the next list request. Each subsequent list request will have its own
	// [page_token] to continue paging through the results.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProjectJobResponse) Descriptor deprecated

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

Deprecated: Use ListProjectJobResponse.ProtoReflect.Descriptor instead.

func (*ListProjectJobResponse) GetJobs

func (x *ListProjectJobResponse) GetJobs() []*Job

func (*ListProjectJobResponse) GetPageToken

func (x *ListProjectJobResponse) GetPageToken() string

func (*ListProjectJobResponse) ProtoMessage

func (*ListProjectJobResponse) ProtoMessage()

func (*ListProjectJobResponse) ProtoReflect

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

func (*ListProjectJobResponse) Reset

func (x *ListProjectJobResponse) Reset()

func (*ListProjectJobResponse) SetJobs

func (m *ListProjectJobResponse) SetJobs(v []*Job)

func (*ListProjectJobResponse) SetPageToken

func (m *ListProjectJobResponse) SetPageToken(v string)

func (*ListProjectJobResponse) String

func (x *ListProjectJobResponse) String() string

type LogMessage

type LogMessage struct {

	// Log message contents.
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// Log message creation timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Types that are assignable to Source:
	//
	//	*LogMessage_StandardStream
	//	*LogMessage_FilePath
	Source isLogMessage_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetContent

func (x *LogMessage) GetContent() []byte

func (*LogMessage) GetCreatedAt

func (x *LogMessage) GetCreatedAt() *timestamppb.Timestamp

func (*LogMessage) GetFilePath

func (x *LogMessage) GetFilePath() string

func (*LogMessage) GetSource

func (m *LogMessage) GetSource() isLogMessage_Source

func (*LogMessage) GetStandardStream

func (x *LogMessage) GetStandardStream() StandardStream

func (*LogMessage) ProtoMessage

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect

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

func (*LogMessage) Reset

func (x *LogMessage) Reset()

func (*LogMessage) SetContent

func (m *LogMessage) SetContent(v []byte)

func (*LogMessage) SetCreatedAt

func (m *LogMessage) SetCreatedAt(v *timestamppb.Timestamp)

func (*LogMessage) SetFilePath

func (m *LogMessage) SetFilePath(v string)

func (*LogMessage) SetSource

func (m *LogMessage) SetSource(v LogMessage_Source)

func (*LogMessage) SetStandardStream

func (m *LogMessage) SetStandardStream(v StandardStream)

func (*LogMessage) String

func (x *LogMessage) String() string

type LogMessage_FilePath

type LogMessage_FilePath struct {
	// System debug log files.
	FilePath string `protobuf:"bytes,4,opt,name=file_path,json=filePath,proto3,oneof"`
}

type LogMessage_Source

type LogMessage_Source = isLogMessage_Source

type LogMessage_StandardStream

type LogMessage_StandardStream struct {
	// Program standard streams.
	StandardStream StandardStream `` /* 129-byte string literal not displayed */
}

type ProjectJobServiceClient

type ProjectJobServiceClient interface {
	// Creates job.
	Create(ctx context.Context, in *CreateProjectJobRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Clone job.
	Clone(ctx context.Context, in *CloneProjectJobRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Runs job execution.
	Execute(ctx context.Context, in *ExecuteProjectJobRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Cancels running job.
	Cancel(ctx context.Context, in *CancelProjectJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	// Returns stream of job logs.
	ReadStdLogs(ctx context.Context, in *ReadProjectJobStdLogsRequest, opts ...grpc.CallOption) (ProjectJobService_ReadStdLogsClient, error)
	// Returns stream of job logs.
	ReadLogs(ctx context.Context, in *ReadProjectJobLogsRequest, opts ...grpc.CallOption) (ProjectJobService_ReadLogsClient, error)
	// Returns download urls for job files.
	DownloadJobFiles(ctx context.Context, in *DownloadProjectJobFilesRequest, opts ...grpc.CallOption) (*DownloadProjectJobFilesResponse, error)
	// Lists jobs.
	List(ctx context.Context, in *ListProjectJobRequest, opts ...grpc.CallOption) (*ListProjectJobResponse, error)
	// Returns job by id.
	Get(ctx context.Context, in *GetProjectJobRequest, opts ...grpc.CallOption) (*Job, error)
	// Deletes specified job.
	Delete(ctx context.Context, in *DeleteProjectJobRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Delete job data.
	DeleteData(ctx context.Context, in *DeleteProjectJobDataRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Delete all jobs data.
	DeleteAllData(ctx context.Context, in *DeleteAllProjectJobDataRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Update job data ttl.
	SetDataTtl(ctx context.Context, in *SetProjectJobDataTtlRequest, opts ...grpc.CallOption) (*SetProjectJobDataTtlResponse, error)
}

ProjectJobServiceClient is the client API for ProjectJobService 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.

type ProjectJobServiceServer

type ProjectJobServiceServer interface {
	// Creates job.
	Create(context.Context, *CreateProjectJobRequest) (*operation.Operation, error)
	// Clone job.
	Clone(context.Context, *CloneProjectJobRequest) (*operation.Operation, error)
	// Runs job execution.
	Execute(context.Context, *ExecuteProjectJobRequest) (*operation.Operation, error)
	// Cancels running job.
	Cancel(context.Context, *CancelProjectJobRequest) (*emptypb.Empty, error)
	// Deprecated: Do not use.
	// Returns stream of job logs.
	ReadStdLogs(*ReadProjectJobStdLogsRequest, ProjectJobService_ReadStdLogsServer) error
	// Returns stream of job logs.
	ReadLogs(*ReadProjectJobLogsRequest, ProjectJobService_ReadLogsServer) error
	// Returns download urls for job files.
	DownloadJobFiles(context.Context, *DownloadProjectJobFilesRequest) (*DownloadProjectJobFilesResponse, error)
	// Lists jobs.
	List(context.Context, *ListProjectJobRequest) (*ListProjectJobResponse, error)
	// Returns job by id.
	Get(context.Context, *GetProjectJobRequest) (*Job, error)
	// Deletes specified job.
	Delete(context.Context, *DeleteProjectJobRequest) (*operation.Operation, error)
	// Delete job data.
	DeleteData(context.Context, *DeleteProjectJobDataRequest) (*operation.Operation, error)
	// Delete all jobs data.
	DeleteAllData(context.Context, *DeleteAllProjectJobDataRequest) (*operation.Operation, error)
	// Update job data ttl.
	SetDataTtl(context.Context, *SetProjectJobDataTtlRequest) (*SetProjectJobDataTtlResponse, error)
}

ProjectJobServiceServer is the server API for ProjectJobService service. All implementations should embed UnimplementedProjectJobServiceServer for forward compatibility

type ProjectJobService_ReadLogsClient

type ProjectJobService_ReadLogsClient interface {
	Recv() (*ReadProjectJobLogsResponse, error)
	grpc.ClientStream
}

type ProjectJobService_ReadLogsServer

type ProjectJobService_ReadLogsServer interface {
	Send(*ReadProjectJobLogsResponse) error
	grpc.ServerStream
}

type ProjectJobService_ReadStdLogsClient

type ProjectJobService_ReadStdLogsClient interface {
	Recv() (*ReadProjectJobStdLogsResponse, error)
	grpc.ClientStream
}

type ProjectJobService_ReadStdLogsServer

type ProjectJobService_ReadStdLogsServer interface {
	Send(*ReadProjectJobStdLogsResponse) error
	grpc.ServerStream
}

type PythonEnv

type PythonEnv struct {

	// Conda YAML.
	CondaYaml string `protobuf:"bytes,1,opt,name=conda_yaml,json=condaYaml,proto3" json:"conda_yaml,omitempty"`
	// List of local modules descriptions.
	LocalModules []*File `protobuf:"bytes,2,rep,name=local_modules,json=localModules,proto3" json:"local_modules,omitempty"`
	// contains filtered or unexported fields
}

func (*PythonEnv) Descriptor deprecated

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

Deprecated: Use PythonEnv.ProtoReflect.Descriptor instead.

func (*PythonEnv) GetCondaYaml

func (x *PythonEnv) GetCondaYaml() string

func (*PythonEnv) GetLocalModules

func (x *PythonEnv) GetLocalModules() []*File

func (*PythonEnv) ProtoMessage

func (*PythonEnv) ProtoMessage()

func (*PythonEnv) ProtoReflect

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

func (*PythonEnv) Reset

func (x *PythonEnv) Reset()

func (*PythonEnv) SetCondaYaml

func (m *PythonEnv) SetCondaYaml(v string)

func (*PythonEnv) SetLocalModules

func (m *PythonEnv) SetLocalModules(v []*File)

func (*PythonEnv) String

func (x *PythonEnv) String() string

type ReadProjectJobLogsRequest

type ReadProjectJobLogsRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Log offset.
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadProjectJobLogsRequest) Descriptor deprecated

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

Deprecated: Use ReadProjectJobLogsRequest.ProtoReflect.Descriptor instead.

func (*ReadProjectJobLogsRequest) GetJobId

func (x *ReadProjectJobLogsRequest) GetJobId() string

func (*ReadProjectJobLogsRequest) GetOffset

func (x *ReadProjectJobLogsRequest) GetOffset() int64

func (*ReadProjectJobLogsRequest) ProtoMessage

func (*ReadProjectJobLogsRequest) ProtoMessage()

func (*ReadProjectJobLogsRequest) ProtoReflect

func (*ReadProjectJobLogsRequest) Reset

func (x *ReadProjectJobLogsRequest) Reset()

func (*ReadProjectJobLogsRequest) SetJobId

func (m *ReadProjectJobLogsRequest) SetJobId(v string)

func (*ReadProjectJobLogsRequest) SetOffset

func (m *ReadProjectJobLogsRequest) SetOffset(v int64)

func (*ReadProjectJobLogsRequest) String

func (x *ReadProjectJobLogsRequest) String() string

type ReadProjectJobLogsResponse

type ReadProjectJobLogsResponse struct {
	Logs []*LogMessage `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// Log offset.
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadProjectJobLogsResponse) Descriptor deprecated

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

Deprecated: Use ReadProjectJobLogsResponse.ProtoReflect.Descriptor instead.

func (*ReadProjectJobLogsResponse) GetLogs

func (x *ReadProjectJobLogsResponse) GetLogs() []*LogMessage

func (*ReadProjectJobLogsResponse) GetOffset

func (x *ReadProjectJobLogsResponse) GetOffset() int64

func (*ReadProjectJobLogsResponse) ProtoMessage

func (*ReadProjectJobLogsResponse) ProtoMessage()

func (*ReadProjectJobLogsResponse) ProtoReflect

func (*ReadProjectJobLogsResponse) Reset

func (x *ReadProjectJobLogsResponse) Reset()

func (*ReadProjectJobLogsResponse) SetLogs

func (m *ReadProjectJobLogsResponse) SetLogs(v []*LogMessage)

func (*ReadProjectJobLogsResponse) SetOffset

func (m *ReadProjectJobLogsResponse) SetOffset(v int64)

func (*ReadProjectJobLogsResponse) String

func (x *ReadProjectJobLogsResponse) String() string

type ReadProjectJobStdLogsRequest

type ReadProjectJobStdLogsRequest struct {

	// ID of the job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Log offset.
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadProjectJobStdLogsRequest) Descriptor deprecated

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

Deprecated: Use ReadProjectJobStdLogsRequest.ProtoReflect.Descriptor instead.

func (*ReadProjectJobStdLogsRequest) GetJobId

func (x *ReadProjectJobStdLogsRequest) GetJobId() string

func (*ReadProjectJobStdLogsRequest) GetOffset

func (x *ReadProjectJobStdLogsRequest) GetOffset() int64

func (*ReadProjectJobStdLogsRequest) ProtoMessage

func (*ReadProjectJobStdLogsRequest) ProtoMessage()

func (*ReadProjectJobStdLogsRequest) ProtoReflect

func (*ReadProjectJobStdLogsRequest) Reset

func (x *ReadProjectJobStdLogsRequest) Reset()

func (*ReadProjectJobStdLogsRequest) SetJobId

func (m *ReadProjectJobStdLogsRequest) SetJobId(v string)

func (*ReadProjectJobStdLogsRequest) SetOffset

func (m *ReadProjectJobStdLogsRequest) SetOffset(v int64)

func (*ReadProjectJobStdLogsRequest) String

type ReadProjectJobStdLogsResponse

type ReadProjectJobStdLogsResponse struct {
	Logs []*StdLog `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// Log offset.
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadProjectJobStdLogsResponse) Descriptor deprecated

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

Deprecated: Use ReadProjectJobStdLogsResponse.ProtoReflect.Descriptor instead.

func (*ReadProjectJobStdLogsResponse) GetLogs

func (x *ReadProjectJobStdLogsResponse) GetLogs() []*StdLog

func (*ReadProjectJobStdLogsResponse) GetOffset

func (x *ReadProjectJobStdLogsResponse) GetOffset() int64

func (*ReadProjectJobStdLogsResponse) ProtoMessage

func (*ReadProjectJobStdLogsResponse) ProtoMessage()

func (*ReadProjectJobStdLogsResponse) ProtoReflect

func (*ReadProjectJobStdLogsResponse) Reset

func (x *ReadProjectJobStdLogsResponse) Reset()

func (*ReadProjectJobStdLogsResponse) SetLogs

func (m *ReadProjectJobStdLogsResponse) SetLogs(v []*StdLog)

func (*ReadProjectJobStdLogsResponse) SetOffset

func (m *ReadProjectJobStdLogsResponse) SetOffset(v int64)

func (*ReadProjectJobStdLogsResponse) String

type SetProjectJobDataTtlRequest

type SetProjectJobDataTtlRequest struct {
	JobId string               `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Ttl   *durationpb.Duration `protobuf:"bytes,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*SetProjectJobDataTtlRequest) Descriptor deprecated

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

Deprecated: Use SetProjectJobDataTtlRequest.ProtoReflect.Descriptor instead.

func (*SetProjectJobDataTtlRequest) GetJobId

func (x *SetProjectJobDataTtlRequest) GetJobId() string

func (*SetProjectJobDataTtlRequest) GetTtl

func (*SetProjectJobDataTtlRequest) ProtoMessage

func (*SetProjectJobDataTtlRequest) ProtoMessage()

func (*SetProjectJobDataTtlRequest) ProtoReflect

func (*SetProjectJobDataTtlRequest) Reset

func (x *SetProjectJobDataTtlRequest) Reset()

func (*SetProjectJobDataTtlRequest) SetJobId

func (m *SetProjectJobDataTtlRequest) SetJobId(v string)

func (*SetProjectJobDataTtlRequest) SetTtl

func (*SetProjectJobDataTtlRequest) String

func (x *SetProjectJobDataTtlRequest) String() string

type SetProjectJobDataTtlResponse

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

func (*SetProjectJobDataTtlResponse) Descriptor deprecated

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

Deprecated: Use SetProjectJobDataTtlResponse.ProtoReflect.Descriptor instead.

func (*SetProjectJobDataTtlResponse) ProtoMessage

func (*SetProjectJobDataTtlResponse) ProtoMessage()

func (*SetProjectJobDataTtlResponse) ProtoReflect

func (*SetProjectJobDataTtlResponse) Reset

func (x *SetProjectJobDataTtlResponse) Reset()

func (*SetProjectJobDataTtlResponse) String

type StandardStream

type StandardStream int32
const (
	StandardStream_STANDARD_STREAM_UNSPECIFIED StandardStream = 0
	// Stdout.
	StandardStream_OUT StandardStream = 1
	// Stderr.
	StandardStream_ERR StandardStream = 2
)

func (StandardStream) Descriptor

func (StandardStream) Enum

func (x StandardStream) Enum() *StandardStream

func (StandardStream) EnumDescriptor deprecated

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

Deprecated: Use StandardStream.Descriptor instead.

func (StandardStream) Number

func (StandardStream) String

func (x StandardStream) String() string

func (StandardStream) Type

type StdLog

type StdLog struct {

	// Log contents.
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// Log type.
	Type StdLog_Type `protobuf:"varint,2,opt,name=type,proto3,enum=yandex.cloud.datasphere.v2.jobs.StdLog_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*StdLog) Descriptor deprecated

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

Deprecated: Use StdLog.ProtoReflect.Descriptor instead.

func (*StdLog) GetContent

func (x *StdLog) GetContent() []byte

func (*StdLog) GetType

func (x *StdLog) GetType() StdLog_Type

func (*StdLog) ProtoMessage

func (*StdLog) ProtoMessage()

func (*StdLog) ProtoReflect

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

func (*StdLog) Reset

func (x *StdLog) Reset()

func (*StdLog) SetContent

func (m *StdLog) SetContent(v []byte)

func (*StdLog) SetType

func (m *StdLog) SetType(v StdLog_Type)

func (*StdLog) String

func (x *StdLog) String() string

type StdLog_Type

type StdLog_Type int32
const (
	StdLog_TYPE_UNSPECIFIED StdLog_Type = 0
	// stdout.
	StdLog_OUT StdLog_Type = 1
	// stderr.
	StdLog_ERR StdLog_Type = 2
)

func (StdLog_Type) Descriptor

func (StdLog_Type) Enum

func (x StdLog_Type) Enum() *StdLog_Type

func (StdLog_Type) EnumDescriptor deprecated

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

Deprecated: Use StdLog_Type.Descriptor instead.

func (StdLog_Type) Number

func (x StdLog_Type) Number() protoreflect.EnumNumber

func (StdLog_Type) String

func (x StdLog_Type) String() string

func (StdLog_Type) Type

type StorageFile

type StorageFile struct {
	File *File `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// File URL.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageFile) Descriptor deprecated

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

Deprecated: Use StorageFile.ProtoReflect.Descriptor instead.

func (*StorageFile) GetFile

func (x *StorageFile) GetFile() *File

func (*StorageFile) GetUrl

func (x *StorageFile) GetUrl() string

func (*StorageFile) ProtoMessage

func (*StorageFile) ProtoMessage()

func (*StorageFile) ProtoReflect

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

func (*StorageFile) Reset

func (x *StorageFile) Reset()

func (*StorageFile) SetFile

func (m *StorageFile) SetFile(v *File)

func (*StorageFile) SetUrl

func (m *StorageFile) SetUrl(v string)

func (*StorageFile) String

func (x *StorageFile) String() string

type UnimplementedProjectJobServiceServer

type UnimplementedProjectJobServiceServer struct {
}

UnimplementedProjectJobServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedProjectJobServiceServer) Cancel

func (UnimplementedProjectJobServiceServer) Clone

func (UnimplementedProjectJobServiceServer) Create

func (UnimplementedProjectJobServiceServer) Delete

func (UnimplementedProjectJobServiceServer) DeleteAllData

func (UnimplementedProjectJobServiceServer) DeleteData

func (UnimplementedProjectJobServiceServer) Execute

func (UnimplementedProjectJobServiceServer) Get

func (UnimplementedProjectJobServiceServer) List

type UnsafeProjectJobServiceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL