dataproc

Oct 9, 2024

Changes in this version

+ type AccessSessionSparkApplicationEnvironmentInfoResponse struct

+ ApplicationEnvironmentInfo *ApplicationEnvironmentInfo

+ ForceSendFields []string

+ NullFields []string

+ func (s AccessSessionSparkApplicationEnvironmentInfoResponse) MarshalJSON() ([]byte, error)

+ type AccessSessionSparkApplicationJobResponse struct

+ ForceSendFields []string

+ JobData *JobData

+ NullFields []string

+ func (s AccessSessionSparkApplicationJobResponse) MarshalJSON() ([]byte, error)

+ type AccessSessionSparkApplicationResponse struct

+ Application *ApplicationInfo

+ ForceSendFields []string

+ NullFields []string

+ func (s AccessSessionSparkApplicationResponse) MarshalJSON() ([]byte, error)

+ type AccessSessionSparkApplicationSqlQueryResponse struct

+ ExecutionData *SqlExecutionUiData

+ ForceSendFields []string

+ NullFields []string

+ func (s AccessSessionSparkApplicationSqlQueryResponse) MarshalJSON() ([]byte, error)

+ type AccessSessionSparkApplicationSqlSparkPlanGraphResponse struct

+ ForceSendFields []string

+ NullFields []string

+ SparkPlanGraph *SparkPlanGraph

+ func (s AccessSessionSparkApplicationSqlSparkPlanGraphResponse) MarshalJSON() ([]byte, error)

+ type AccessSessionSparkApplicationStageAttemptResponse struct

+ ForceSendFields []string

+ NullFields []string

+ StageData *StageData

+ func (s AccessSessionSparkApplicationStageAttemptResponse) MarshalJSON() ([]byte, error)

+ type AccessSessionSparkApplicationStageRddOperationGraphResponse struct

+ ForceSendFields []string

+ NullFields []string

+ RddOperationGraph *RddOperationGraph

+ func (s AccessSessionSparkApplicationStageRddOperationGraphResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationEnvironmentInfoResponse struct

+ ApplicationEnvironmentInfo *ApplicationEnvironmentInfo

+ ForceSendFields []string

+ NullFields []string

+ func (s AccessSparkApplicationEnvironmentInfoResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationJobResponse struct

+ ForceSendFields []string

+ JobData *JobData

+ NullFields []string

+ func (s AccessSparkApplicationJobResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationResponse struct

+ Application *ApplicationInfo

+ ForceSendFields []string

+ NullFields []string

+ func (s AccessSparkApplicationResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationSqlQueryResponse struct

+ ExecutionData *SqlExecutionUiData

+ ForceSendFields []string

+ NullFields []string

+ func (s AccessSparkApplicationSqlQueryResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationSqlSparkPlanGraphResponse struct

+ ForceSendFields []string

+ NullFields []string

+ SparkPlanGraph *SparkPlanGraph

+ func (s AccessSparkApplicationSqlSparkPlanGraphResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationStageAttemptResponse struct

+ ForceSendFields []string

+ NullFields []string

+ StageData *StageData

+ func (s AccessSparkApplicationStageAttemptResponse) MarshalJSON() ([]byte, error)

+ type AccessSparkApplicationStageRddOperationGraphResponse struct

+ ForceSendFields []string

+ NullFields []string

+ RddOperationGraph *RddOperationGraph

+ func (s AccessSparkApplicationStageRddOperationGraphResponse) MarshalJSON() ([]byte, error)

+ type AccumulableInfo struct

+ AccumullableInfoId int64

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ Update string

+ Value string

+ func (s AccumulableInfo) MarshalJSON() ([]byte, error)

+ type AppSummary struct

+ ForceSendFields []string

+ NullFields []string

+ NumCompletedJobs int64

+ NumCompletedStages int64

+ func (s AppSummary) MarshalJSON() ([]byte, error)

+ type ApplicationAttemptInfo struct

+ AppSparkVersion string

+ AttemptId string

+ Completed bool

+ DurationMillis int64

+ EndTime string

+ ForceSendFields []string

+ LastUpdated string

+ NullFields []string

+ SparkUser string

+ StartTime string

+ func (s ApplicationAttemptInfo) MarshalJSON() ([]byte, error)

+ type ApplicationEnvironmentInfo struct

+ ClasspathEntries map[string]string

+ ForceSendFields []string

+ HadoopProperties map[string]string

+ MetricsProperties map[string]string

+ NullFields []string

+ ResourceProfiles []*ResourceProfileInfo

+ Runtime *SparkRuntimeInfo

+ SparkProperties map[string]string

+ SystemProperties map[string]string

+ func (s ApplicationEnvironmentInfo) MarshalJSON() ([]byte, error)

+ type ApplicationInfo struct

+ ApplicationContextIngestionStatus string

+ ApplicationId string

+ Attempts []*ApplicationAttemptInfo

+ CoresGranted int64

+ CoresPerExecutor int64

+ ForceSendFields []string

+ MaxCores int64

+ MemoryPerExecutorMb int64

+ Name string

+ NullFields []string

+ QuantileDataStatus string

+ func (s ApplicationInfo) MarshalJSON() ([]byte, error)

+ type ClusterToRepair struct

+ ClusterRepairAction string

+ ForceSendFields []string

+ NullFields []string

+ func (s ClusterToRepair) MarshalJSON() ([]byte, error)

+ type ConsolidatedExecutorSummary struct

+ ActiveTasks int64

+ CompletedTasks int64

+ Count int64

+ DiskUsed int64

+ FailedTasks int64

+ ForceSendFields []string

+ IsExcluded int64

+ MaxMemory int64

+ MemoryMetrics *MemoryMetrics

+ MemoryUsed int64

+ NullFields []string

+ RddBlocks int64

+ TotalCores int64

+ TotalDurationMillis int64

+ TotalGcTimeMillis int64

+ TotalInputBytes int64

+ TotalShuffleRead int64

+ TotalShuffleWrite int64

+ TotalTasks int64

+ func (s ConsolidatedExecutorSummary) MarshalJSON() ([]byte, error)

+ type ExecutorMetrics struct

+ ForceSendFields []string

+ Metrics map[string]string

+ NullFields []string

+ func (s ExecutorMetrics) MarshalJSON() ([]byte, error)

+ type ExecutorMetricsDistributions struct

+ DiskBytesSpilled []float64

+ FailedTasks []float64

+ ForceSendFields []string

+ InputBytes []float64

+ InputRecords []float64

+ KilledTasks []float64

+ MemoryBytesSpilled []float64

+ NullFields []string

+ OutputBytes []float64

+ OutputRecords []float64

+ PeakMemoryMetrics *ExecutorPeakMetricsDistributions

+ Quantiles []float64

+ ShuffleRead []float64

+ ShuffleReadRecords []float64

+ ShuffleWrite []float64

+ ShuffleWriteRecords []float64

+ SucceededTasks []float64

+ TaskTimeMillis []float64

+ func (s *ExecutorMetricsDistributions) UnmarshalJSON(data []byte) error

+ func (s ExecutorMetricsDistributions) MarshalJSON() ([]byte, error)

+ type ExecutorPeakMetricsDistributions struct

+ ExecutorMetrics []*ExecutorMetrics

+ ForceSendFields []string

+ NullFields []string

+ Quantiles []float64

+ func (s *ExecutorPeakMetricsDistributions) UnmarshalJSON(data []byte) error

+ func (s ExecutorPeakMetricsDistributions) MarshalJSON() ([]byte, error)

+ type ExecutorResourceRequest struct

+ Amount int64

+ DiscoveryScript string

+ ForceSendFields []string

+ NullFields []string

+ ResourceName string

+ Vendor string

+ func (s ExecutorResourceRequest) MarshalJSON() ([]byte, error)

+ type ExecutorStageSummary struct

+ DiskBytesSpilled int64

+ ExecutorId string

+ FailedTasks int64

+ ForceSendFields []string

+ InputBytes int64

+ InputRecords int64

+ IsExcludedForStage bool

+ KilledTasks int64

+ MemoryBytesSpilled int64

+ NullFields []string

+ OutputBytes int64

+ OutputRecords int64

+ PeakMemoryMetrics *ExecutorMetrics

+ ShuffleRead int64

+ ShuffleReadRecords int64

+ ShuffleWrite int64

+ ShuffleWriteRecords int64

+ StageAttemptId int64

+ StageId int64

+ SucceededTasks int64

+ TaskTimeMillis int64

+ func (s ExecutorStageSummary) MarshalJSON() ([]byte, error)

+ type ExecutorSummary struct

+ ActiveTasks int64

+ AddTime string

+ Attributes map[string]string

+ CompletedTasks int64

+ DiskUsed int64

+ ExcludedInStages googleapi.Int64s

+ ExecutorId string

+ ExecutorLogs map[string]string

+ FailedTasks int64

+ ForceSendFields []string

+ HostPort string

+ IsActive bool

+ IsExcluded bool

+ MaxMemory int64

+ MaxTasks int64

+ MemoryMetrics *MemoryMetrics

+ MemoryUsed int64

+ NullFields []string

+ PeakMemoryMetrics *ExecutorMetrics

+ RddBlocks int64

+ RemoveReason string

+ RemoveTime string

+ ResourceProfileId int64

+ Resources map[string]ResourceInformation

+ TotalCores int64

+ TotalDurationMillis int64

+ TotalGcTimeMillis int64

+ TotalInputBytes int64

+ TotalShuffleRead int64

+ TotalShuffleWrite int64

+ TotalTasks int64

+ func (s ExecutorSummary) MarshalJSON() ([]byte, error)

+ type InputMetrics struct

+ BytesRead int64

+ ForceSendFields []string

+ NullFields []string

+ RecordsRead int64

+ func (s InputMetrics) MarshalJSON() ([]byte, error)

+ type InputQuantileMetrics struct

+ BytesRead *Quantiles

+ ForceSendFields []string

+ NullFields []string

+ RecordsRead *Quantiles

+ func (s InputQuantileMetrics) MarshalJSON() ([]byte, error)

type InstanceFlexibilityPolicy

+ ProvisioningModelMix *ProvisioningModelMix

+ type JobData struct

+ CompletionTime string

+ Description string

+ ForceSendFields []string

+ JobGroup string

+ JobId int64

+ KillTasksSummary map[string]int64

+ Name string

+ NullFields []string

+ NumActiveStages int64

+ NumActiveTasks int64

+ NumCompletedIndices int64

+ NumCompletedStages int64

+ NumCompletedTasks int64

+ NumFailedStages int64

+ NumFailedTasks int64

+ NumKilledTasks int64

+ NumSkippedStages int64

+ NumSkippedTasks int64

+ NumTasks int64

+ SkippedStages []int64

+ SqlExecutionId int64

+ StageIds googleapi.Int64s

+ Status string

+ SubmissionTime string

+ func (s JobData) MarshalJSON() ([]byte, error)

+ type JobsSummary struct

+ ActiveJobs int64

+ ApplicationId string

+ Attempts []*ApplicationAttemptInfo

+ CompletedJobs int64

+ FailedJobs int64

+ ForceSendFields []string

+ NullFields []string

+ SchedulingMode string

+ func (s JobsSummary) MarshalJSON() ([]byte, error)

+ type MemoryMetrics struct

+ ForceSendFields []string

+ NullFields []string

+ TotalOffHeapStorageMemory int64

+ TotalOnHeapStorageMemory int64

+ UsedOffHeapStorageMemory int64

+ UsedOnHeapStorageMemory int64

+ func (s MemoryMetrics) MarshalJSON() ([]byte, error)

+ type OutputMetrics struct

+ BytesWritten int64

+ ForceSendFields []string

+ NullFields []string

+ RecordsWritten int64

+ func (s OutputMetrics) MarshalJSON() ([]byte, error)

+ type OutputQuantileMetrics struct

+ BytesWritten *Quantiles

+ ForceSendFields []string

+ NullFields []string

+ RecordsWritten *Quantiles

+ func (s OutputQuantileMetrics) MarshalJSON() ([]byte, error)

+ type PoolData struct

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ StageIds googleapi.Int64s

+ func (s PoolData) MarshalJSON() ([]byte, error)

+ type ProcessSummary struct

+ AddTime string

+ ForceSendFields []string

+ HostPort string

+ IsActive bool

+ NullFields []string

+ ProcessId string

+ ProcessLogs map[string]string

+ RemoveTime string

+ TotalCores int64

+ func (s ProcessSummary) MarshalJSON() ([]byte, error)

type ProjectsLocationsBatchesService

+ SparkApplications *ProjectsLocationsBatchesSparkApplicationsService

+ type ProjectsLocationsBatchesSparkApplicationsAccessCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessCall

+ type ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationEnvironmentInfoResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall

+ type ProjectsLocationsBatchesSparkApplicationsAccessJobCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationJobResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) JobId(jobId int64) *ProjectsLocationsBatchesSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessJobCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessJobCall

+ type ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationSqlSparkPlanGraphResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) ExecutionId(executionId int64) *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall

+ type ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) Details(details bool) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationSqlQueryResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) ExecutionId(executionId int64) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall) PlanDescription(planDescription bool) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ type ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationStageAttemptResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) StageId(stageId int64) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall) SummaryMetricsMask(summaryMetricsMask string) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ type ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) Do(opts ...googleapi.CallOption) (*AccessSparkApplicationStageRddOperationGraphResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall) StageId(stageId int64) *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) ApplicationStatus(applicationStatus string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationsResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) MaxEndTime(maxEndTime string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) MaxTime(maxTime string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) MinEndTime(minEndTime string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) MinTime(minTime string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchCall) Pages(ctx context.Context, f func(*SearchSparkApplicationsResponse) error) error

+ type ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationExecutorStageSummaryResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall) StageId(stageId int64) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationExecutorsResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) ExecutorStatus(executorStatus string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) Pages(ctx context.Context, f func(*SearchSparkApplicationExecutorsResponse) error) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchJobsCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationJobsResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) JobStatus(jobStatus string) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) Pages(ctx context.Context, f func(*SearchSparkApplicationJobsResponse) error) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Details(details bool) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationSqlQueriesResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Pages(ctx context.Context, f func(*SearchSparkApplicationSqlQueriesResponse) error) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall) PlanDescription(planDescription bool) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationStageAttemptTasksResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) SortRuntime(sortRuntime bool) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) StageId(stageId int64) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall) TaskStatus(taskStatus string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationStageAttemptsResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) StageId(stageId int64) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall) SummaryMetricsMask(summaryMetricsMask string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ type ProjectsLocationsBatchesSparkApplicationsSearchStagesCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) Do(opts ...googleapi.CallOption) (*SearchSparkApplicationStagesResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) PageSize(pageSize int64) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) PageToken(pageToken string) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) Pages(ctx context.Context, f func(*SearchSparkApplicationStagesResponse) error) error

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) StageStatus(stageStatus string) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall) SummaryMetricsMask(summaryMetricsMask string) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ type ProjectsLocationsBatchesSparkApplicationsService struct

+ func NewProjectsLocationsBatchesSparkApplicationsService(s *Service) *ProjectsLocationsBatchesSparkApplicationsService

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) Access(name string) *ProjectsLocationsBatchesSparkApplicationsAccessCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) AccessEnvironmentInfo(name string) *ProjectsLocationsBatchesSparkApplicationsAccessEnvironmentInfoCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) AccessJob(name string) *ProjectsLocationsBatchesSparkApplicationsAccessJobCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) AccessSqlPlan(name string) *ProjectsLocationsBatchesSparkApplicationsAccessSqlPlanCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) AccessSqlQuery(name string) *ProjectsLocationsBatchesSparkApplicationsAccessSqlQueryCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) AccessStageAttempt(name string) *ProjectsLocationsBatchesSparkApplicationsAccessStageAttemptCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) AccessStageRddGraph(name string) *ProjectsLocationsBatchesSparkApplicationsAccessStageRddGraphCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) Search(parent string) *ProjectsLocationsBatchesSparkApplicationsSearchCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchExecutorStageSummary(name string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorStageSummaryCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchExecutors(name string) *ProjectsLocationsBatchesSparkApplicationsSearchExecutorsCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchJobs(name string) *ProjectsLocationsBatchesSparkApplicationsSearchJobsCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchSqlQueries(name string) *ProjectsLocationsBatchesSparkApplicationsSearchSqlQueriesCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchStageAttemptTasks(name string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptTasksCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchStageAttempts(name string) *ProjectsLocationsBatchesSparkApplicationsSearchStageAttemptsCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SearchStages(name string) *ProjectsLocationsBatchesSparkApplicationsSearchStagesCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SummarizeExecutors(name string) *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SummarizeJobs(name string) *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SummarizeStageAttemptTasks(name string) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) SummarizeStages(name string) *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall

+ func (r *ProjectsLocationsBatchesSparkApplicationsService) Write(name string, ...) *ProjectsLocationsBatchesSparkApplicationsWriteCall

+ type ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall) Do(opts ...googleapi.CallOption) (*SummarizeSparkApplicationExecutorsResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSummarizeExecutorsCall

+ type ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall) Do(opts ...googleapi.CallOption) (*SummarizeSparkApplicationJobsResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSummarizeJobsCall

+ type ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) Do(opts ...googleapi.CallOption) (*SummarizeSparkApplicationStageAttemptTasksResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall) StageId(stageId int64) *ProjectsLocationsBatchesSparkApplicationsSummarizeStageAttemptTasksCall

+ type ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall) Do(opts ...googleapi.CallOption) (*SummarizeSparkApplicationStagesResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall) Parent(parent string) *ProjectsLocationsBatchesSparkApplicationsSummarizeStagesCall

+ type ProjectsLocationsBatchesSparkApplicationsWriteCall struct

+ func (c *ProjectsLocationsBatchesSparkApplicationsWriteCall) Context(ctx context.Context) *ProjectsLocationsBatchesSparkApplicationsWriteCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsWriteCall) Do(opts ...googleapi.CallOption) (*WriteSparkApplicationContextResponse, error)

+ func (c *ProjectsLocationsBatchesSparkApplicationsWriteCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesSparkApplicationsWriteCall

+ func (c *ProjectsLocationsBatchesSparkApplicationsWriteCall) Header() http.Header

type ProjectsLocationsSessionsService

+ SparkApplications *ProjectsLocationsSessionsSparkApplicationsService

+ type ProjectsLocationsSessionsSparkApplicationsAccessCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessCall

+ type ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationEnvironmentInfoResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall

+ type ProjectsLocationsSessionsSparkApplicationsAccessJobCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationJobResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) JobId(jobId int64) *ProjectsLocationsSessionsSparkApplicationsAccessJobCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessJobCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessJobCall

+ type ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationSqlSparkPlanGraphResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) ExecutionId(executionId int64) *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall

+ type ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) Details(details bool) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationSqlQueryResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) ExecutionId(executionId int64) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall) PlanDescription(planDescription bool) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ type ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationStageAttemptResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) StageId(stageId int64) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall) SummaryMetricsMask(summaryMetricsMask string) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ type ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) Do(opts ...googleapi.CallOption) (*AccessSessionSparkApplicationStageRddOperationGraphResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall) StageId(stageId int64) *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) ApplicationStatus(applicationStatus string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationsResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) MaxEndTime(maxEndTime string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) MaxTime(maxTime string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) MinEndTime(minEndTime string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) MinTime(minTime string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchCall) Pages(ctx context.Context, f func(*SearchSessionSparkApplicationsResponse) error) error

+ type ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationExecutorStageSummaryResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall) StageId(stageId int64) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationExecutorsResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) ExecutorStatus(executorStatus string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchJobsCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationJobsResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) JobStatus(jobStatus string) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) Pages(ctx context.Context, f func(*SearchSessionSparkApplicationJobsResponse) error) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Details(details bool) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationSqlQueriesResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall) PlanDescription(planDescription bool) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationStageAttemptTasksResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) SortRuntime(sortRuntime bool) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) StageId(stageId int64) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall) TaskStatus(taskStatus string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationStageAttemptsResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) StageId(stageId int64) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall) SummaryMetricsMask(summaryMetricsMask string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ type ProjectsLocationsSessionsSparkApplicationsSearchStagesCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) Do(opts ...googleapi.CallOption) (*SearchSessionSparkApplicationStagesResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) PageSize(pageSize int64) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) PageToken(pageToken string) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) Pages(ctx context.Context, ...) error

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) StageStatus(stageStatus string) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall) SummaryMetricsMask(summaryMetricsMask string) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ type ProjectsLocationsSessionsSparkApplicationsService struct

+ func NewProjectsLocationsSessionsSparkApplicationsService(s *Service) *ProjectsLocationsSessionsSparkApplicationsService

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) Access(name string) *ProjectsLocationsSessionsSparkApplicationsAccessCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) AccessEnvironmentInfo(name string) *ProjectsLocationsSessionsSparkApplicationsAccessEnvironmentInfoCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) AccessJob(name string) *ProjectsLocationsSessionsSparkApplicationsAccessJobCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) AccessSqlPlan(name string) *ProjectsLocationsSessionsSparkApplicationsAccessSqlPlanCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) AccessSqlQuery(name string) *ProjectsLocationsSessionsSparkApplicationsAccessSqlQueryCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) AccessStageAttempt(name string) *ProjectsLocationsSessionsSparkApplicationsAccessStageAttemptCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) AccessStageRddGraph(name string) *ProjectsLocationsSessionsSparkApplicationsAccessStageRddGraphCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) Search(parent string) *ProjectsLocationsSessionsSparkApplicationsSearchCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchExecutorStageSummary(name string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorStageSummaryCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchExecutors(name string) *ProjectsLocationsSessionsSparkApplicationsSearchExecutorsCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchJobs(name string) *ProjectsLocationsSessionsSparkApplicationsSearchJobsCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchSqlQueries(name string) *ProjectsLocationsSessionsSparkApplicationsSearchSqlQueriesCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchStageAttemptTasks(name string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptTasksCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchStageAttempts(name string) *ProjectsLocationsSessionsSparkApplicationsSearchStageAttemptsCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SearchStages(name string) *ProjectsLocationsSessionsSparkApplicationsSearchStagesCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SummarizeExecutors(name string) *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SummarizeJobs(name string) *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SummarizeStageAttemptTasks(name string) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) SummarizeStages(name string) *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall

+ func (r *ProjectsLocationsSessionsSparkApplicationsService) Write(name string, ...) *ProjectsLocationsSessionsSparkApplicationsWriteCall

+ type ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall) Do(opts ...googleapi.CallOption) (*SummarizeSessionSparkApplicationExecutorsResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSummarizeExecutorsCall

+ type ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall) Do(opts ...googleapi.CallOption) (*SummarizeSessionSparkApplicationJobsResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSummarizeJobsCall

+ type ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) Do(opts ...googleapi.CallOption) (*SummarizeSessionSparkApplicationStageAttemptTasksResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) StageAttemptId(stageAttemptId int64) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall) StageId(stageId int64) *ProjectsLocationsSessionsSparkApplicationsSummarizeStageAttemptTasksCall

+ type ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall) Do(opts ...googleapi.CallOption) (*SummarizeSessionSparkApplicationStagesResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall) Parent(parent string) *ProjectsLocationsSessionsSparkApplicationsSummarizeStagesCall

+ type ProjectsLocationsSessionsSparkApplicationsWriteCall struct

+ func (c *ProjectsLocationsSessionsSparkApplicationsWriteCall) Context(ctx context.Context) *ProjectsLocationsSessionsSparkApplicationsWriteCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsWriteCall) Do(opts ...googleapi.CallOption) (*WriteSessionSparkApplicationContextResponse, error)

+ func (c *ProjectsLocationsSessionsSparkApplicationsWriteCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsSparkApplicationsWriteCall

+ func (c *ProjectsLocationsSessionsSparkApplicationsWriteCall) Header() http.Header

+ type ProvisioningModelMix struct

+ ForceSendFields []string

+ NullFields []string

+ StandardCapacityBase int64

+ StandardCapacityPercentAboveBase int64

+ func (s ProvisioningModelMix) MarshalJSON() ([]byte, error)

+ type Quantiles struct

+ Count int64

+ ForceSendFields []string

+ Maximum int64

+ Minimum int64

+ NullFields []string

+ Percentile25 int64

+ Percentile50 int64

+ Percentile75 int64

+ Sum int64

+ func (s Quantiles) MarshalJSON() ([]byte, error)

+ type RddDataDistribution struct

+ Address string

+ DiskUsed int64

+ ForceSendFields []string

+ MemoryRemaining int64

+ MemoryUsed int64

+ NullFields []string

+ OffHeapMemoryRemaining int64

+ OffHeapMemoryUsed int64

+ OnHeapMemoryRemaining int64

+ OnHeapMemoryUsed int64

+ func (s RddDataDistribution) MarshalJSON() ([]byte, error)

+ type RddOperationCluster struct

+ ChildClusters []*RddOperationCluster

+ ChildNodes []*RddOperationNode

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ RddClusterId string

+ func (s RddOperationCluster) MarshalJSON() ([]byte, error)

+ type RddOperationEdge struct

+ ForceSendFields []string

+ FromId int64

+ NullFields []string

+ ToId int64

+ func (s RddOperationEdge) MarshalJSON() ([]byte, error)

+ type RddOperationGraph struct

+ Edges []*RddOperationEdge

+ ForceSendFields []string

+ IncomingEdges []*RddOperationEdge

+ NullFields []string

+ OutgoingEdges []*RddOperationEdge

+ RootCluster *RddOperationCluster

+ StageId int64

+ func (s RddOperationGraph) MarshalJSON() ([]byte, error)

+ type RddOperationNode struct

+ Barrier bool

+ Cached bool

+ Callsite string

+ ForceSendFields []string

+ Name string

+ NodeId int64

+ NullFields []string

+ OutputDeterministicLevel string

+ func (s RddOperationNode) MarshalJSON() ([]byte, error)

+ type RddPartitionInfo struct

+ BlockName string

+ DiskUsed int64

+ Executors []string

+ ForceSendFields []string

+ MemoryUsed int64

+ NullFields []string

+ StorageLevel string

+ func (s RddPartitionInfo) MarshalJSON() ([]byte, error)

+ type RddStorageInfo struct

+ DataDistribution []*RddDataDistribution

+ DiskUsed int64

+ ForceSendFields []string

+ MemoryUsed int64

+ Name string

+ NullFields []string

+ NumCachedPartitions int64

+ NumPartitions int64

+ Partitions []*RddPartitionInfo

+ RddStorageId int64

+ StorageLevel string

+ func (s RddStorageInfo) MarshalJSON() ([]byte, error)

type RepairClusterRequest

+ Cluster *ClusterToRepair

+ type ResourceInformation struct

+ Addresses []string

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ func (s ResourceInformation) MarshalJSON() ([]byte, error)

+ type ResourceProfileInfo struct

+ ExecutorResources map[string]ExecutorResourceRequest

+ ForceSendFields []string

+ NullFields []string

+ ResourceProfileId int64

+ TaskResources map[string]TaskResourceRequest

+ func (s ResourceProfileInfo) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationExecutorStageSummaryResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStageExecutors []*ExecutorStageSummary

+ func (s SearchSessionSparkApplicationExecutorStageSummaryResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationExecutorsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationExecutors []*ExecutorSummary

+ func (s SearchSessionSparkApplicationExecutorsResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationJobsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationJobs []*JobData

+ func (s SearchSessionSparkApplicationJobsResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationSqlQueriesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationSqlQueries []*SqlExecutionUiData

+ func (s SearchSessionSparkApplicationSqlQueriesResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationStageAttemptTasksResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStageAttemptTasks []*TaskData

+ func (s SearchSessionSparkApplicationStageAttemptTasksResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationStageAttemptsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStageAttempts []*StageData

+ func (s SearchSessionSparkApplicationStageAttemptsResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationStagesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStages []*StageData

+ func (s SearchSessionSparkApplicationStagesResponse) MarshalJSON() ([]byte, error)

+ type SearchSessionSparkApplicationsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplications []*SparkApplication

+ func (s SearchSessionSparkApplicationsResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationExecutorStageSummaryResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStageExecutors []*ExecutorStageSummary

+ func (s SearchSparkApplicationExecutorStageSummaryResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationExecutorsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationExecutors []*ExecutorSummary

+ func (s SearchSparkApplicationExecutorsResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationJobsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationJobs []*JobData

+ func (s SearchSparkApplicationJobsResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationSqlQueriesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationSqlQueries []*SqlExecutionUiData

+ func (s SearchSparkApplicationSqlQueriesResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationStageAttemptTasksResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStageAttemptTasks []*TaskData

+ func (s SearchSparkApplicationStageAttemptTasksResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationStageAttemptsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStageAttempts []*StageData

+ func (s SearchSparkApplicationStageAttemptsResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationStagesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplicationStages []*StageData

+ func (s SearchSparkApplicationStagesResponse) MarshalJSON() ([]byte, error)

+ type SearchSparkApplicationsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SparkApplications []*SparkApplication

+ func (s SearchSparkApplicationsResponse) MarshalJSON() ([]byte, error)

+ type ShufflePushReadMetrics struct

+ CorruptMergedBlockChunks int64

+ ForceSendFields []string

+ LocalMergedBlocksFetched int64

+ LocalMergedBytesRead int64

+ LocalMergedChunksFetched int64

+ MergedFetchFallbackCount int64

+ NullFields []string

+ RemoteMergedBlocksFetched int64

+ RemoteMergedBytesRead int64

+ RemoteMergedChunksFetched int64

+ RemoteMergedReqsDuration int64

+ func (s ShufflePushReadMetrics) MarshalJSON() ([]byte, error)

+ type ShufflePushReadQuantileMetrics struct

+ CorruptMergedBlockChunks *Quantiles

+ ForceSendFields []string

+ LocalMergedBlocksFetched *Quantiles

+ LocalMergedBytesRead *Quantiles

+ LocalMergedChunksFetched *Quantiles

+ MergedFetchFallbackCount *Quantiles

+ NullFields []string

+ RemoteMergedBlocksFetched *Quantiles

+ RemoteMergedBytesRead *Quantiles

+ RemoteMergedChunksFetched *Quantiles

+ RemoteMergedReqsDuration *Quantiles

+ func (s ShufflePushReadQuantileMetrics) MarshalJSON() ([]byte, error)

+ type ShuffleReadMetrics struct

+ FetchWaitTimeMillis int64

+ ForceSendFields []string

+ LocalBlocksFetched int64

+ LocalBytesRead int64

+ NullFields []string

+ RecordsRead int64

+ RemoteBlocksFetched int64

+ RemoteBytesRead int64

+ RemoteBytesReadToDisk int64

+ RemoteReqsDuration int64

+ ShufflePushReadMetrics *ShufflePushReadMetrics

+ func (s ShuffleReadMetrics) MarshalJSON() ([]byte, error)

+ type ShuffleReadQuantileMetrics struct

+ FetchWaitTimeMillis *Quantiles

+ ForceSendFields []string

+ LocalBlocksFetched *Quantiles

+ NullFields []string

+ ReadBytes *Quantiles

+ ReadRecords *Quantiles

+ RemoteBlocksFetched *Quantiles

+ RemoteBytesRead *Quantiles

+ RemoteBytesReadToDisk *Quantiles

+ RemoteReqsDuration *Quantiles

+ ShufflePushReadMetrics *ShufflePushReadQuantileMetrics

+ TotalBlocksFetched *Quantiles

+ func (s ShuffleReadQuantileMetrics) MarshalJSON() ([]byte, error)

+ type ShuffleWriteMetrics struct

+ BytesWritten int64

+ ForceSendFields []string

+ NullFields []string

+ RecordsWritten int64

+ WriteTimeNanos int64

+ func (s ShuffleWriteMetrics) MarshalJSON() ([]byte, error)

+ type ShuffleWriteQuantileMetrics struct

+ ForceSendFields []string

+ NullFields []string

+ WriteBytes *Quantiles

+ WriteRecords *Quantiles

+ WriteTimeNanos *Quantiles

+ func (s ShuffleWriteQuantileMetrics) MarshalJSON() ([]byte, error)

+ type SinkProgress struct

+ Description string

+ ForceSendFields []string

+ Metrics map[string]string

+ NullFields []string

+ NumOutputRows int64

+ func (s SinkProgress) MarshalJSON() ([]byte, error)

+ type SourceProgress struct

+ Description string

+ EndOffset string

+ ForceSendFields []string

+ InputRowsPerSecond float64

+ LatestOffset string

+ Metrics map[string]string

+ NullFields []string

+ NumInputRows int64

+ ProcessedRowsPerSecond float64

+ StartOffset string

+ func (s *SourceProgress) UnmarshalJSON(data []byte) error

+ func (s SourceProgress) MarshalJSON() ([]byte, error)

+ type SparkApplication struct

+ Application *ApplicationInfo

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ func (s SparkApplication) MarshalJSON() ([]byte, error)

+ type SparkPlanGraph struct

+ Edges []*SparkPlanGraphEdge

+ ExecutionId int64

+ ForceSendFields []string

+ Nodes []*SparkPlanGraphNodeWrapper

+ NullFields []string

+ func (s SparkPlanGraph) MarshalJSON() ([]byte, error)

+ type SparkPlanGraphCluster struct

+ Desc string

+ ForceSendFields []string

+ Metrics []*SqlPlanMetric

+ Name string

+ Nodes []*SparkPlanGraphNodeWrapper

+ NullFields []string

+ SparkPlanGraphClusterId int64

+ func (s SparkPlanGraphCluster) MarshalJSON() ([]byte, error)

+ type SparkPlanGraphEdge struct

+ ForceSendFields []string

+ FromId int64

+ NullFields []string

+ ToId int64

+ func (s SparkPlanGraphEdge) MarshalJSON() ([]byte, error)

+ type SparkPlanGraphNode struct

+ Desc string

+ ForceSendFields []string

+ Metrics []*SqlPlanMetric

+ Name string

+ NullFields []string

+ SparkPlanGraphNodeId int64

+ func (s SparkPlanGraphNode) MarshalJSON() ([]byte, error)

+ type SparkPlanGraphNodeWrapper struct

+ Cluster *SparkPlanGraphCluster

+ ForceSendFields []string

+ Node *SparkPlanGraphNode

+ NullFields []string

+ func (s SparkPlanGraphNodeWrapper) MarshalJSON() ([]byte, error)

+ type SparkRuntimeInfo struct

+ ForceSendFields []string

+ JavaHome string

+ JavaVersion string

+ NullFields []string

+ ScalaVersion string

+ func (s SparkRuntimeInfo) MarshalJSON() ([]byte, error)

+ type SparkWrapperObject struct

+ AppSummary *AppSummary

+ ApplicationEnvironmentInfo *ApplicationEnvironmentInfo

+ ApplicationId string

+ ApplicationInfo *ApplicationInfo

+ EventTimestamp string

+ ExecutorStageSummary *ExecutorStageSummary

+ ExecutorSummary *ExecutorSummary

+ ForceSendFields []string

+ JobData *JobData

+ NullFields []string

+ PoolData *PoolData

+ ProcessSummary *ProcessSummary

+ RddOperationGraph *RddOperationGraph

+ RddStorageInfo *RddStorageInfo

+ ResourceProfileInfo *ResourceProfileInfo

+ SparkPlanGraph *SparkPlanGraph

+ SpeculationStageSummary *SpeculationStageSummary

+ SqlExecutionUiData *SqlExecutionUiData

+ StageData *StageData

+ StreamBlockData *StreamBlockData

+ StreamingQueryData *StreamingQueryData

+ StreamingQueryProgress *StreamingQueryProgress

+ TaskData *TaskData

+ func (s SparkWrapperObject) MarshalJSON() ([]byte, error)

+ type SpeculationStageSummary struct

+ ForceSendFields []string

+ NullFields []string

+ NumActiveTasks int64

+ NumCompletedTasks int64

+ NumFailedTasks int64

+ NumKilledTasks int64

+ NumTasks int64

+ StageAttemptId int64

+ StageId int64

+ func (s SpeculationStageSummary) MarshalJSON() ([]byte, error)

+ type SqlExecutionUiData struct

+ CompletionTime string

+ Description string

+ Details string

+ ErrorMessage string

+ ExecutionId int64

+ ForceSendFields []string

+ Jobs map[string]string

+ MetricValues map[string]string

+ MetricValuesIsNull bool

+ Metrics []*SqlPlanMetric

+ ModifiedConfigs map[string]string

+ NullFields []string

+ PhysicalPlanDescription string

+ RootExecutionId int64

+ Stages googleapi.Int64s

+ SubmissionTime string

+ func (s SqlExecutionUiData) MarshalJSON() ([]byte, error)

+ type SqlPlanMetric struct

+ AccumulatorId int64

+ ForceSendFields []string

+ MetricType string

+ Name string

+ NullFields []string

+ func (s SqlPlanMetric) MarshalJSON() ([]byte, error)

+ type StageAttemptTasksSummary struct

+ ApplicationId string

+ ForceSendFields []string

+ NullFields []string

+ NumFailedTasks int64

+ NumKilledTasks int64

+ NumPendingTasks int64

+ NumRunningTasks int64

+ NumSuccessTasks int64

+ NumTasks int64

+ StageAttemptId int64

+ StageId int64

+ func (s StageAttemptTasksSummary) MarshalJSON() ([]byte, error)

+ type StageData struct

+ AccumulatorUpdates []*AccumulableInfo

+ CompletionTime string

+ Description string

+ Details string

+ ExecutorMetricsDistributions *ExecutorMetricsDistributions

+ ExecutorSummary map[string]ExecutorStageSummary

+ FailureReason string

+ FirstTaskLaunchedTime string

+ ForceSendFields []string

+ IsShufflePushEnabled bool

+ JobIds googleapi.Int64s

+ KilledTasksSummary map[string]int64

+ Locality map[string]string

+ Name string

+ NullFields []string

+ NumActiveTasks int64

+ NumCompleteTasks int64

+ NumCompletedIndices int64

+ NumFailedTasks int64

+ NumKilledTasks int64

+ NumTasks int64

+ ParentStageIds googleapi.Int64s

+ PeakExecutorMetrics *ExecutorMetrics

+ RddIds googleapi.Int64s

+ ResourceProfileId int64

+ SchedulingPool string

+ ShuffleMergersCount int64

+ SpeculationSummary *SpeculationStageSummary

+ StageAttemptId int64

+ StageId int64

+ StageMetrics *StageMetrics

+ Status string

+ SubmissionTime string

+ TaskQuantileMetrics *TaskQuantileMetrics

+ Tasks map[string]TaskData

+ func (s StageData) MarshalJSON() ([]byte, error)

+ type StageInputMetrics struct

+ BytesRead int64

+ ForceSendFields []string

+ NullFields []string

+ RecordsRead int64

+ func (s StageInputMetrics) MarshalJSON() ([]byte, error)

+ type StageMetrics struct

+ DiskBytesSpilled int64

+ ExecutorCpuTimeNanos int64

+ ExecutorDeserializeCpuTimeNanos int64

+ ExecutorDeserializeTimeMillis int64

+ ExecutorRunTimeMillis int64

+ ForceSendFields []string

+ JvmGcTimeMillis int64

+ MemoryBytesSpilled int64

+ NullFields []string

+ PeakExecutionMemoryBytes int64

+ ResultSerializationTimeMillis int64

+ ResultSize int64

+ StageInputMetrics *StageInputMetrics

+ StageOutputMetrics *StageOutputMetrics

+ StageShuffleReadMetrics *StageShuffleReadMetrics

+ StageShuffleWriteMetrics *StageShuffleWriteMetrics

+ func (s StageMetrics) MarshalJSON() ([]byte, error)

+ type StageOutputMetrics struct

+ BytesWritten int64

+ ForceSendFields []string

+ NullFields []string

+ RecordsWritten int64

+ func (s StageOutputMetrics) MarshalJSON() ([]byte, error)

+ type StageShufflePushReadMetrics struct

+ CorruptMergedBlockChunks int64

+ ForceSendFields []string

+ LocalMergedBlocksFetched int64

+ LocalMergedBytesRead int64

+ LocalMergedChunksFetched int64

+ MergedFetchFallbackCount int64

+ NullFields []string

+ RemoteMergedBlocksFetched int64

+ RemoteMergedBytesRead int64

+ RemoteMergedChunksFetched int64

+ RemoteMergedReqsDuration int64

+ func (s StageShufflePushReadMetrics) MarshalJSON() ([]byte, error)

+ type StageShuffleReadMetrics struct

+ BytesRead int64

+ FetchWaitTimeMillis int64

+ ForceSendFields []string

+ LocalBlocksFetched int64

+ LocalBytesRead int64

+ NullFields []string

+ RecordsRead int64

+ RemoteBlocksFetched int64

+ RemoteBytesRead int64

+ RemoteBytesReadToDisk int64

+ RemoteReqsDuration int64

+ StageShufflePushReadMetrics *StageShufflePushReadMetrics

+ func (s StageShuffleReadMetrics) MarshalJSON() ([]byte, error)

+ type StageShuffleWriteMetrics struct

+ BytesWritten int64

+ ForceSendFields []string

+ NullFields []string

+ RecordsWritten int64

+ WriteTimeNanos int64

+ func (s StageShuffleWriteMetrics) MarshalJSON() ([]byte, error)

+ type StagesSummary struct

+ ApplicationId string

+ ForceSendFields []string

+ NullFields []string

+ NumActiveStages int64

+ NumCompletedStages int64

+ NumFailedStages int64

+ NumPendingStages int64

+ NumSkippedStages int64

+ func (s StagesSummary) MarshalJSON() ([]byte, error)

+ type StateOperatorProgress struct

+ AllRemovalsTimeMs int64

+ AllUpdatesTimeMs int64

+ CommitTimeMs int64

+ CustomMetrics map[string]string

+ ForceSendFields []string

+ MemoryUsedBytes int64

+ NullFields []string

+ NumRowsDroppedByWatermark int64

+ NumRowsRemoved int64

+ NumRowsTotal int64

+ NumRowsUpdated int64

+ NumShufflePartitions int64

+ NumStateStoreInstances int64

+ OperatorName string

+ func (s StateOperatorProgress) MarshalJSON() ([]byte, error)

+ type StreamBlockData struct

+ Deserialized bool

+ DiskSize int64

+ ExecutorId string

+ ForceSendFields []string

+ HostPort string

+ MemSize int64

+ Name string

+ NullFields []string

+ StorageLevel string

+ UseDisk bool

+ UseMemory bool

+ func (s StreamBlockData) MarshalJSON() ([]byte, error)

+ type StreamingQueryData struct

+ EndTimestamp int64

+ Exception string

+ ForceSendFields []string

+ IsActive bool

+ Name string

+ NullFields []string

+ RunId string

+ StartTimestamp int64

+ StreamingQueryId string

+ func (s StreamingQueryData) MarshalJSON() ([]byte, error)

+ type StreamingQueryProgress struct

+ BatchDuration int64

+ BatchId int64

+ DurationMillis map[string]string

+ EventTime map[string]string

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ ObservedMetrics map[string]string

+ RunId string

+ Sink *SinkProgress

+ Sources []*SourceProgress

+ StateOperators []*StateOperatorProgress

+ StreamingQueryProgressId string

+ Timestamp string

+ func (s StreamingQueryProgress) MarshalJSON() ([]byte, error)

+ type SummarizeSessionSparkApplicationExecutorsResponse struct

+ ActiveExecutorSummary *ConsolidatedExecutorSummary

+ ApplicationId string

+ DeadExecutorSummary *ConsolidatedExecutorSummary

+ ForceSendFields []string

+ NullFields []string

+ TotalExecutorSummary *ConsolidatedExecutorSummary

+ func (s SummarizeSessionSparkApplicationExecutorsResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSessionSparkApplicationJobsResponse struct

+ ForceSendFields []string

+ JobsSummary *JobsSummary

+ NullFields []string

+ func (s SummarizeSessionSparkApplicationJobsResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSessionSparkApplicationStageAttemptTasksResponse struct

+ ForceSendFields []string

+ NullFields []string

+ StageAttemptTasksSummary *StageAttemptTasksSummary

+ func (s SummarizeSessionSparkApplicationStageAttemptTasksResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSessionSparkApplicationStagesResponse struct

+ ForceSendFields []string

+ NullFields []string

+ StagesSummary *StagesSummary

+ func (s SummarizeSessionSparkApplicationStagesResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSparkApplicationExecutorsResponse struct

+ ActiveExecutorSummary *ConsolidatedExecutorSummary

+ ApplicationId string

+ DeadExecutorSummary *ConsolidatedExecutorSummary

+ ForceSendFields []string

+ NullFields []string

+ TotalExecutorSummary *ConsolidatedExecutorSummary

+ func (s SummarizeSparkApplicationExecutorsResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSparkApplicationJobsResponse struct

+ ForceSendFields []string

+ JobsSummary *JobsSummary

+ NullFields []string

+ func (s SummarizeSparkApplicationJobsResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSparkApplicationStageAttemptTasksResponse struct

+ ForceSendFields []string

+ NullFields []string

+ StageAttemptTasksSummary *StageAttemptTasksSummary

+ func (s SummarizeSparkApplicationStageAttemptTasksResponse) MarshalJSON() ([]byte, error)

+ type SummarizeSparkApplicationStagesResponse struct

+ ForceSendFields []string

+ NullFields []string

+ StagesSummary *StagesSummary

+ func (s SummarizeSparkApplicationStagesResponse) MarshalJSON() ([]byte, error)

+ type TaskData struct

+ AccumulatorUpdates []*AccumulableInfo

+ Attempt int64

+ DurationMillis int64

+ ErrorMessage string

+ ExecutorId string

+ ExecutorLogs map[string]string

+ ForceSendFields []string

+ GettingResultTimeMillis int64

+ HasMetrics bool

+ Host string

+ Index int64

+ LaunchTime string

+ NullFields []string

+ PartitionId int64

+ ResultFetchStart string

+ SchedulerDelayMillis int64

+ Speculative bool

+ StageAttemptId int64

+ StageId int64

+ Status string

+ TaskId int64

+ TaskLocality string

+ TaskMetrics *TaskMetrics

+ func (s TaskData) MarshalJSON() ([]byte, error)

+ type TaskMetrics struct

+ DiskBytesSpilled int64

+ ExecutorCpuTimeNanos int64

+ ExecutorDeserializeCpuTimeNanos int64

+ ExecutorDeserializeTimeMillis int64

+ ExecutorRunTimeMillis int64

+ ForceSendFields []string

+ InputMetrics *InputMetrics

+ JvmGcTimeMillis int64

+ MemoryBytesSpilled int64

+ NullFields []string

+ OutputMetrics *OutputMetrics

+ PeakExecutionMemoryBytes int64

+ ResultSerializationTimeMillis int64

+ ResultSize int64

+ ShuffleReadMetrics *ShuffleReadMetrics

+ ShuffleWriteMetrics *ShuffleWriteMetrics

+ func (s TaskMetrics) MarshalJSON() ([]byte, error)

+ type TaskQuantileMetrics struct

+ DiskBytesSpilled *Quantiles

+ DurationMillis *Quantiles

+ ExecutorCpuTimeNanos *Quantiles

+ ExecutorDeserializeCpuTimeNanos *Quantiles

+ ExecutorDeserializeTimeMillis *Quantiles

+ ExecutorRunTimeMillis *Quantiles

+ ForceSendFields []string

+ GettingResultTimeMillis *Quantiles

+ InputMetrics *InputQuantileMetrics

+ JvmGcTimeMillis *Quantiles

+ MemoryBytesSpilled *Quantiles

+ NullFields []string

+ OutputMetrics *OutputQuantileMetrics

+ PeakExecutionMemoryBytes *Quantiles

+ ResultSerializationTimeMillis *Quantiles

+ ResultSize *Quantiles

+ SchedulerDelayMillis *Quantiles

+ ShuffleReadMetrics *ShuffleReadQuantileMetrics

+ ShuffleWriteMetrics *ShuffleWriteQuantileMetrics

+ func (s TaskQuantileMetrics) MarshalJSON() ([]byte, error)

+ type TaskResourceRequest struct

+ Amount float64

+ ForceSendFields []string

+ NullFields []string

+ ResourceName string

+ func (s *TaskResourceRequest) UnmarshalJSON(data []byte) error

+ func (s TaskResourceRequest) MarshalJSON() ([]byte, error)

+ type WriteSessionSparkApplicationContextRequest struct

+ ForceSendFields []string

+ NullFields []string

+ Parent string

+ SparkWrapperObjects []*SparkWrapperObject

+ func (s WriteSessionSparkApplicationContextRequest) MarshalJSON() ([]byte, error)

+ type WriteSessionSparkApplicationContextResponse struct

+ type WriteSparkApplicationContextRequest struct

+ ForceSendFields []string

+ NullFields []string

+ Parent string

+ SparkWrapperObjects []*SparkWrapperObject

+ func (s WriteSparkApplicationContextRequest) MarshalJSON() ([]byte, error)

+ type WriteSparkApplicationContextResponse struct

Sep 3, 2024

Changes in this version

type Session

+ SparkConnectSession *SparkConnectConfig

type SessionTemplate

+ SparkConnectSession *SparkConnectConfig

+ type SparkConnectConfig struct

Jun 25, 2024

Changes in this version

type DiskConfig

+ BootDiskProvisionedIops int64

+ BootDiskProvisionedThroughput int64

Jun 18, 2024

Changes in this version

+ type AutotuningConfig struct

+ ForceSendFields []string

+ NullFields []string

+ Scenarios []string

+ func (s *AutotuningConfig) MarshalJSON() ([]byte, error)

type RuntimeConfig

+ AutotuningConfig *AutotuningConfig

+ Cohort string

Mar 27, 2024

Changes in this version

+ type AnalyzeBatchRequest struct

+ ForceSendFields []string

+ NullFields []string

+ RequestId string

+ func (s *AnalyzeBatchRequest) MarshalJSON() ([]byte, error)

+ type ProjectsLocationsBatchesAnalyzeCall struct

+ func (c *ProjectsLocationsBatchesAnalyzeCall) Context(ctx context.Context) *ProjectsLocationsBatchesAnalyzeCall

+ func (c *ProjectsLocationsBatchesAnalyzeCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsBatchesAnalyzeCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesAnalyzeCall

+ func (c *ProjectsLocationsBatchesAnalyzeCall) Header() http.Header

type ProjectsLocationsBatchesService

+ func (r *ProjectsLocationsBatchesService) Analyze(name string, analyzebatchrequest *AnalyzeBatchRequest) *ProjectsLocationsBatchesAnalyzeCall

Feb 21, 2024

Changes in this version

+ type AnalyzeOperationMetadata struct

+ AnalyzedWorkloadName string

+ AnalyzedWorkloadType string

+ AnalyzedWorkloadUuid string

+ CreateTime string

+ Description string

+ DoneTime string

+ ForceSendFields []string

+ Labels map[string]string

+ NullFields []string

+ Warnings []string

+ func (s *AnalyzeOperationMetadata) MarshalJSON() ([]byte, error)

+ type ProjectsRegionsClustersNodeGroupsRepairCall struct

+ func (c *ProjectsRegionsClustersNodeGroupsRepairCall) Context(ctx context.Context) *ProjectsRegionsClustersNodeGroupsRepairCall

+ func (c *ProjectsRegionsClustersNodeGroupsRepairCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersNodeGroupsRepairCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersNodeGroupsRepairCall

+ func (c *ProjectsRegionsClustersNodeGroupsRepairCall) Header() http.Header

type ProjectsRegionsClustersNodeGroupsService

+ func (r *ProjectsRegionsClustersNodeGroupsService) Repair(name string, repairnodegrouprequest *RepairNodeGroupRequest) *ProjectsRegionsClustersNodeGroupsRepairCall

+ type RepairNodeGroupRequest struct

+ ForceSendFields []string

+ InstanceNames []string

+ NullFields []string

+ RepairAction string

+ RequestId string

+ func (s *RepairNodeGroupRequest) MarshalJSON() ([]byte, error)

Jan 4, 2024

Changes in this version

type ListBatchesResponse

+ Unreachable []string

Nov 16, 2023

Changes in this version

type DiagnoseClusterRequest

+ TarballAccess string

Nov 6, 2023

Changes in this version

type ListJobsResponse

+ Unreachable []string

Oct 31, 2023

Changes in this version

+ type GoogleCloudDataprocV1WorkflowTemplateEncryptionConfig struct

+ ForceSendFields []string

+ KmsKey string

+ NullFields []string

+ func (s *GoogleCloudDataprocV1WorkflowTemplateEncryptionConfig) MarshalJSON() ([]byte, error)

type ListWorkflowTemplatesResponse

+ Unreachable []string

type UsageMetrics

+ AcceleratorType string

+ MilliAcceleratorSeconds int64

type UsageSnapshot

+ AcceleratorType string

+ MilliAccelerator int64

type WorkflowTemplate

+ EncryptionConfig *GoogleCloudDataprocV1WorkflowTemplateEncryptionConfig

Oct 9, 2023

Changes in this version

type ProjectsRegionsClustersNodeGroupsCreateCall

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) ParentOperationId(parentOperationId string) *ProjectsRegionsClustersNodeGroupsCreateCall

type ResizeNodeGroupRequest

+ ParentOperationId string

Oct 4, 2023

Changes in this version

type InstanceGroupConfig

+ StartupConfig *StartupConfig

type OrderedJob

+ FlinkJob *FlinkJob

type SessionTemplate

+ Uuid string

type SparkStandaloneAutoscalingConfig

+ RemoveOnlyIdleWorkers bool

+ type StartupConfig struct

+ ForceSendFields []string

+ NullFields []string

+ RequiredRegistrationFraction float64

+ func (s *StartupConfig) MarshalJSON() ([]byte, error)

+ func (s *StartupConfig) UnmarshalJSON(data []byte) error

Sep 11, 2023

Changes in this version

type DiagnoseClusterRequest

+ TarballGcsDir string

+ type InstanceFlexibilityPolicy struct

+ ForceSendFields []string

+ InstanceSelectionList []*InstanceSelection

+ InstanceSelectionResults []*InstanceSelectionResult

+ NullFields []string

+ func (s *InstanceFlexibilityPolicy) MarshalJSON() ([]byte, error)

type InstanceGroupConfig

+ InstanceFlexibilityPolicy *InstanceFlexibilityPolicy

+ type InstanceSelection struct

+ ForceSendFields []string

+ MachineTypes []string

+ NullFields []string

+ Rank int64

+ func (s *InstanceSelection) MarshalJSON() ([]byte, error)

+ type InstanceSelectionResult struct

+ ForceSendFields []string

+ MachineType string

+ NullFields []string

+ VmCount int64

+ func (s *InstanceSelectionResult) MarshalJSON() ([]byte, error)

type ManagedGroupConfig

+ InstanceGroupManagerUri string

+ type PyPiRepositoryConfig struct

+ ForceSendFields []string

+ NullFields []string

+ PypiRepository string

+ func (s *PyPiRepositoryConfig) MarshalJSON() ([]byte, error)

+ type RepositoryConfig struct

+ ForceSendFields []string

+ NullFields []string

+ PypiRepositoryConfig *PyPiRepositoryConfig

+ func (s *RepositoryConfig) MarshalJSON() ([]byte, error)

type RuntimeConfig

+ RepositoryConfig *RepositoryConfig

Sep 8, 2023

Changes in this version

+ type InjectSessionCredentialsRequest struct

+ CredentialsCiphertext string

+ ForceSendFields []string

+ NullFields []string

+ RequestId string

+ func (s *InjectSessionCredentialsRequest) MarshalJSON() ([]byte, error)

+ type JupyterConfig struct

+ DisplayName string

+ ForceSendFields []string

+ Kernel string

+ NullFields []string

+ func (s *JupyterConfig) MarshalJSON() ([]byte, error)

+ type ListSessionTemplatesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ SessionTemplates []*SessionTemplate

+ func (s *ListSessionTemplatesResponse) MarshalJSON() ([]byte, error)

+ type ListSessionsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Sessions []*Session

+ func (s *ListSessionsResponse) MarshalJSON() ([]byte, error)

type ProjectsLocationsService

+ SessionTemplates *ProjectsLocationsSessionTemplatesService

+ Sessions *ProjectsLocationsSessionsService

+ type ProjectsLocationsSessionTemplatesCreateCall struct

+ func (c *ProjectsLocationsSessionTemplatesCreateCall) Context(ctx context.Context) *ProjectsLocationsSessionTemplatesCreateCall

+ func (c *ProjectsLocationsSessionTemplatesCreateCall) Do(opts ...googleapi.CallOption) (*SessionTemplate, error)

+ func (c *ProjectsLocationsSessionTemplatesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionTemplatesCreateCall

+ func (c *ProjectsLocationsSessionTemplatesCreateCall) Header() http.Header

+ type ProjectsLocationsSessionTemplatesDeleteCall struct

+ func (c *ProjectsLocationsSessionTemplatesDeleteCall) Context(ctx context.Context) *ProjectsLocationsSessionTemplatesDeleteCall

+ func (c *ProjectsLocationsSessionTemplatesDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsLocationsSessionTemplatesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionTemplatesDeleteCall

+ func (c *ProjectsLocationsSessionTemplatesDeleteCall) Header() http.Header

+ type ProjectsLocationsSessionTemplatesGetCall struct

+ func (c *ProjectsLocationsSessionTemplatesGetCall) Context(ctx context.Context) *ProjectsLocationsSessionTemplatesGetCall

+ func (c *ProjectsLocationsSessionTemplatesGetCall) Do(opts ...googleapi.CallOption) (*SessionTemplate, error)

+ func (c *ProjectsLocationsSessionTemplatesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionTemplatesGetCall

+ func (c *ProjectsLocationsSessionTemplatesGetCall) Header() http.Header

+ func (c *ProjectsLocationsSessionTemplatesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionTemplatesGetCall

+ type ProjectsLocationsSessionTemplatesListCall struct

+ func (c *ProjectsLocationsSessionTemplatesListCall) Context(ctx context.Context) *ProjectsLocationsSessionTemplatesListCall

+ func (c *ProjectsLocationsSessionTemplatesListCall) Do(opts ...googleapi.CallOption) (*ListSessionTemplatesResponse, error)

+ func (c *ProjectsLocationsSessionTemplatesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionTemplatesListCall

+ func (c *ProjectsLocationsSessionTemplatesListCall) Filter(filter string) *ProjectsLocationsSessionTemplatesListCall

+ func (c *ProjectsLocationsSessionTemplatesListCall) Header() http.Header

+ func (c *ProjectsLocationsSessionTemplatesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionTemplatesListCall

+ func (c *ProjectsLocationsSessionTemplatesListCall) PageSize(pageSize int64) *ProjectsLocationsSessionTemplatesListCall

+ func (c *ProjectsLocationsSessionTemplatesListCall) PageToken(pageToken string) *ProjectsLocationsSessionTemplatesListCall

+ func (c *ProjectsLocationsSessionTemplatesListCall) Pages(ctx context.Context, f func(*ListSessionTemplatesResponse) error) error

+ type ProjectsLocationsSessionTemplatesPatchCall struct

+ func (c *ProjectsLocationsSessionTemplatesPatchCall) Context(ctx context.Context) *ProjectsLocationsSessionTemplatesPatchCall

+ func (c *ProjectsLocationsSessionTemplatesPatchCall) Do(opts ...googleapi.CallOption) (*SessionTemplate, error)

+ func (c *ProjectsLocationsSessionTemplatesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionTemplatesPatchCall

+ func (c *ProjectsLocationsSessionTemplatesPatchCall) Header() http.Header

+ type ProjectsLocationsSessionTemplatesService struct

+ func NewProjectsLocationsSessionTemplatesService(s *Service) *ProjectsLocationsSessionTemplatesService

+ func (r *ProjectsLocationsSessionTemplatesService) Create(parent string, sessiontemplate *SessionTemplate) *ProjectsLocationsSessionTemplatesCreateCall

+ func (r *ProjectsLocationsSessionTemplatesService) Delete(name string) *ProjectsLocationsSessionTemplatesDeleteCall

+ func (r *ProjectsLocationsSessionTemplatesService) Get(name string) *ProjectsLocationsSessionTemplatesGetCall

+ func (r *ProjectsLocationsSessionTemplatesService) List(parent string) *ProjectsLocationsSessionTemplatesListCall

+ func (r *ProjectsLocationsSessionTemplatesService) Patch(name string, sessiontemplate *SessionTemplate) *ProjectsLocationsSessionTemplatesPatchCall

+ type ProjectsLocationsSessionsCreateCall struct

+ func (c *ProjectsLocationsSessionsCreateCall) Context(ctx context.Context) *ProjectsLocationsSessionsCreateCall

+ func (c *ProjectsLocationsSessionsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsSessionsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsCreateCall

+ func (c *ProjectsLocationsSessionsCreateCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsCreateCall) RequestId(requestId string) *ProjectsLocationsSessionsCreateCall

+ func (c *ProjectsLocationsSessionsCreateCall) SessionId(sessionId string) *ProjectsLocationsSessionsCreateCall

+ type ProjectsLocationsSessionsDeleteCall struct

+ func (c *ProjectsLocationsSessionsDeleteCall) Context(ctx context.Context) *ProjectsLocationsSessionsDeleteCall

+ func (c *ProjectsLocationsSessionsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsSessionsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsDeleteCall

+ func (c *ProjectsLocationsSessionsDeleteCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsDeleteCall) RequestId(requestId string) *ProjectsLocationsSessionsDeleteCall

+ type ProjectsLocationsSessionsGetCall struct

+ func (c *ProjectsLocationsSessionsGetCall) Context(ctx context.Context) *ProjectsLocationsSessionsGetCall

+ func (c *ProjectsLocationsSessionsGetCall) Do(opts ...googleapi.CallOption) (*Session, error)

+ func (c *ProjectsLocationsSessionsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsGetCall

+ func (c *ProjectsLocationsSessionsGetCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsGetCall

+ type ProjectsLocationsSessionsInjectCredentialsCall struct

+ func (c *ProjectsLocationsSessionsInjectCredentialsCall) Context(ctx context.Context) *ProjectsLocationsSessionsInjectCredentialsCall

+ func (c *ProjectsLocationsSessionsInjectCredentialsCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsSessionsInjectCredentialsCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsInjectCredentialsCall

+ func (c *ProjectsLocationsSessionsInjectCredentialsCall) Header() http.Header

+ type ProjectsLocationsSessionsListCall struct

+ func (c *ProjectsLocationsSessionsListCall) Context(ctx context.Context) *ProjectsLocationsSessionsListCall

+ func (c *ProjectsLocationsSessionsListCall) Do(opts ...googleapi.CallOption) (*ListSessionsResponse, error)

+ func (c *ProjectsLocationsSessionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsListCall

+ func (c *ProjectsLocationsSessionsListCall) Filter(filter string) *ProjectsLocationsSessionsListCall

+ func (c *ProjectsLocationsSessionsListCall) Header() http.Header

+ func (c *ProjectsLocationsSessionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsSessionsListCall

+ func (c *ProjectsLocationsSessionsListCall) PageSize(pageSize int64) *ProjectsLocationsSessionsListCall

+ func (c *ProjectsLocationsSessionsListCall) PageToken(pageToken string) *ProjectsLocationsSessionsListCall

+ func (c *ProjectsLocationsSessionsListCall) Pages(ctx context.Context, f func(*ListSessionsResponse) error) error

+ type ProjectsLocationsSessionsService struct

+ func NewProjectsLocationsSessionsService(s *Service) *ProjectsLocationsSessionsService

+ func (r *ProjectsLocationsSessionsService) Create(parent string, session *Session) *ProjectsLocationsSessionsCreateCall

+ func (r *ProjectsLocationsSessionsService) Delete(name string) *ProjectsLocationsSessionsDeleteCall

+ func (r *ProjectsLocationsSessionsService) Get(name string) *ProjectsLocationsSessionsGetCall

+ func (r *ProjectsLocationsSessionsService) InjectCredentials(session string, ...) *ProjectsLocationsSessionsInjectCredentialsCall

+ func (r *ProjectsLocationsSessionsService) List(parent string) *ProjectsLocationsSessionsListCall

+ func (r *ProjectsLocationsSessionsService) Terminate(name string, terminatesessionrequest *TerminateSessionRequest) *ProjectsLocationsSessionsTerminateCall

+ type ProjectsLocationsSessionsTerminateCall struct

+ func (c *ProjectsLocationsSessionsTerminateCall) Context(ctx context.Context) *ProjectsLocationsSessionsTerminateCall

+ func (c *ProjectsLocationsSessionsTerminateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsSessionsTerminateCall) Fields(s ...googleapi.Field) *ProjectsLocationsSessionsTerminateCall

+ func (c *ProjectsLocationsSessionsTerminateCall) Header() http.Header

+ type Session struct

+ CreateTime string

+ Creator string

+ EnvironmentConfig *EnvironmentConfig

+ ForceSendFields []string

+ JupyterSession *JupyterConfig

+ Labels map[string]string

+ Name string

+ NullFields []string

+ RuntimeConfig *RuntimeConfig

+ RuntimeInfo *RuntimeInfo

+ SessionTemplate string

+ State string

+ StateHistory []*SessionStateHistory

+ StateMessage string

+ StateTime string

+ User string

+ Uuid string

+ func (s *Session) MarshalJSON() ([]byte, error)

+ type SessionStateHistory struct

+ ForceSendFields []string

+ NullFields []string

+ State string

+ StateMessage string

+ StateStartTime string

+ func (s *SessionStateHistory) MarshalJSON() ([]byte, error)

+ type SessionTemplate struct

+ CreateTime string

+ Creator string

+ Description string

+ EnvironmentConfig *EnvironmentConfig

+ ForceSendFields []string

+ JupyterSession *JupyterConfig

+ Labels map[string]string

+ Name string

+ NullFields []string

+ RuntimeConfig *RuntimeConfig

+ UpdateTime string

+ func (s *SessionTemplate) MarshalJSON() ([]byte, error)

+ type TerminateSessionRequest struct

+ ForceSendFields []string

+ NullFields []string

+ RequestId string

+ func (s *TerminateSessionRequest) MarshalJSON() ([]byte, error)

Aug 14, 2023

Changes in this version

type InstanceGroupConfig

+ MinNumInstances int64

type ProjectsRegionsClustersDeleteCall

+ func (c *ProjectsRegionsClustersDeleteCall) GracefulTerminationTimeout(gracefulTerminationTimeout string) *ProjectsRegionsClustersDeleteCall

Jul 26, 2023

Changes in this version

+ type FlinkJob struct

+ Args []string

+ ForceSendFields []string

+ JarFileUris []string

+ LoggingConfig *LoggingConfig

+ MainClass string

+ MainJarFileUri string

+ NullFields []string

+ Properties map[string]string

+ SavepointUri string

+ func (s *FlinkJob) MarshalJSON() ([]byte, error)

type Job

+ FlinkJob *FlinkJob

type UsageSnapshot

+ MilliDcuPremium int64

+ ShuffleStorageGbPremium int64

Apr 4, 2023

Changes in this version

type DiagnoseClusterRequest

+ Jobs []string

+ YarnApplicationIds []string

Mar 9, 2023

Changes in this version

type EncryptionConfig

+ KmsKey string

Feb 13, 2023

Changes in this version

type ExecutionConfig

+ StagingBucket string

+ Ttl string

type ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) Filter(filter string) *ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) OrderBy(orderBy string) *ProjectsLocationsBatchesListCall

Jan 31, 2023

Changes in this version

type DiagnoseClusterRequest

+ DiagnosisInterval *Interval

+ ForceSendFields []string

+ Job string

+ NullFields []string

+ YarnApplicationId string

+ func (s *DiagnoseClusterRequest) MarshalJSON() ([]byte, error)

+ type Interval struct

+ EndTime string

+ ForceSendFields []string

+ NullFields []string

+ StartTime string

+ func (s *Interval) MarshalJSON() ([]byte, error)

Jan 4, 2023

Changes in this version

+ type AuxiliaryNodeGroup struct

+ ForceSendFields []string

+ NodeGroup *NodeGroup

+ NodeGroupId string

+ NullFields []string

+ func (s *AuxiliaryNodeGroup) MarshalJSON() ([]byte, error)

type ClusterConfig

+ AuxiliaryNodeGroups []*AuxiliaryNodeGroup

+ type DriverSchedulingConfig struct

+ ForceSendFields []string

+ MemoryMb int64

+ NullFields []string

+ Vcores int64

+ func (s *DriverSchedulingConfig) MarshalJSON() ([]byte, error)

type Job

+ DriverSchedulingConfig *DriverSchedulingConfig

+ type NodeGroup struct

+ ForceSendFields []string

+ Labels map[string]string

+ Name string

+ NodeGroupConfig *InstanceGroupConfig

+ NullFields []string

+ Roles []string

+ func (s *NodeGroup) MarshalJSON() ([]byte, error)

+ type ProjectsRegionsClustersNodeGroupsCreateCall struct

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) Context(ctx context.Context) *ProjectsRegionsClustersNodeGroupsCreateCall

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersNodeGroupsCreateCall

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) Header() http.Header

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) NodeGroupId(nodeGroupId string) *ProjectsRegionsClustersNodeGroupsCreateCall

+ func (c *ProjectsRegionsClustersNodeGroupsCreateCall) RequestId(requestId string) *ProjectsRegionsClustersNodeGroupsCreateCall

+ type ProjectsRegionsClustersNodeGroupsGetCall struct

+ func (c *ProjectsRegionsClustersNodeGroupsGetCall) Context(ctx context.Context) *ProjectsRegionsClustersNodeGroupsGetCall

+ func (c *ProjectsRegionsClustersNodeGroupsGetCall) Do(opts ...googleapi.CallOption) (*NodeGroup, error)

+ func (c *ProjectsRegionsClustersNodeGroupsGetCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersNodeGroupsGetCall

+ func (c *ProjectsRegionsClustersNodeGroupsGetCall) Header() http.Header

+ func (c *ProjectsRegionsClustersNodeGroupsGetCall) IfNoneMatch(entityTag string) *ProjectsRegionsClustersNodeGroupsGetCall

+ type ProjectsRegionsClustersNodeGroupsResizeCall struct

+ func (c *ProjectsRegionsClustersNodeGroupsResizeCall) Context(ctx context.Context) *ProjectsRegionsClustersNodeGroupsResizeCall

+ func (c *ProjectsRegionsClustersNodeGroupsResizeCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersNodeGroupsResizeCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersNodeGroupsResizeCall

+ func (c *ProjectsRegionsClustersNodeGroupsResizeCall) Header() http.Header

+ type ProjectsRegionsClustersNodeGroupsService struct

+ func NewProjectsRegionsClustersNodeGroupsService(s *Service) *ProjectsRegionsClustersNodeGroupsService

+ func (r *ProjectsRegionsClustersNodeGroupsService) Create(parent string, nodegroup *NodeGroup) *ProjectsRegionsClustersNodeGroupsCreateCall

+ func (r *ProjectsRegionsClustersNodeGroupsService) Get(name string) *ProjectsRegionsClustersNodeGroupsGetCall

+ func (r *ProjectsRegionsClustersNodeGroupsService) Resize(name string, resizenodegrouprequest *ResizeNodeGroupRequest) *ProjectsRegionsClustersNodeGroupsResizeCall

type ProjectsRegionsClustersService

+ NodeGroups *ProjectsRegionsClustersNodeGroupsService

+ type ResizeNodeGroupRequest struct

+ ForceSendFields []string

+ GracefulDecommissionTimeout string

+ NullFields []string

+ RequestId string

+ Size int64

+ func (s *ResizeNodeGroupRequest) MarshalJSON() ([]byte, error)

type RuntimeInfo

+ CurrentUsage *UsageSnapshot

+ type UsageSnapshot struct

+ ForceSendFields []string

+ MilliDcu int64

+ NullFields []string

+ ShuffleStorageGb int64

+ SnapshotTime string

+ func (s *UsageSnapshot) MarshalJSON() ([]byte, error)

Nov 2, 2022

Changes in this version

+ type NodeGroupOperationMetadata struct

+ ClusterUuid string

+ Description string

+ ForceSendFields []string

+ Labels map[string]string

+ NodeGroupId string

+ NullFields []string

+ OperationType string

+ Status *ClusterOperationStatus

+ StatusHistory []*ClusterOperationStatus

+ Warnings []string

+ func (s *NodeGroupOperationMetadata) MarshalJSON() ([]byte, error)

type RuntimeInfo

+ ApproximateUsage *UsageMetrics

+ type UsageMetrics struct

+ ForceSendFields []string

+ MilliDcuSeconds int64

+ NullFields []string

+ ShuffleStorageGbSeconds int64

+ func (s *UsageMetrics) MarshalJSON() ([]byte, error)

Oct 18, 2022

Changes in this version

+ type ProjectsLocationsOperationsCancelCall struct

+ func (c *ProjectsLocationsOperationsCancelCall) Context(ctx context.Context) *ProjectsLocationsOperationsCancelCall

+ func (c *ProjectsLocationsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsLocationsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsCancelCall

+ func (c *ProjectsLocationsOperationsCancelCall) Header() http.Header

+ type ProjectsLocationsOperationsDeleteCall struct

+ func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall

+ func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall

+ func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header

+ type ProjectsLocationsOperationsGetCall struct

+ func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall

+ func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall

+ func (c *ProjectsLocationsOperationsGetCall) Header() http.Header

+ func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall

+ type ProjectsLocationsOperationsListCall struct

+ func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error)

+ func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Header() http.Header

+ func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall

+ func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error

+ type ProjectsLocationsOperationsService struct

+ func NewProjectsLocationsOperationsService(s *Service) *ProjectsLocationsOperationsService

+ func (r *ProjectsLocationsOperationsService) Cancel(name string) *ProjectsLocationsOperationsCancelCall

+ func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall

+ func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall

+ func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall

type ProjectsLocationsService

+ Operations *ProjectsLocationsOperationsService

Sep 14, 2022

Changes in this version

+ type GceNodePoolOperationMetadata struct

+ ClusterUuid string

+ Description string

+ ForceSendFields []string

+ GceNodePoolId string

+ Labels map[string]string

+ NullFields []string

+ OperationType string

+ Status *ClusterOperationStatus

+ StatusHistory []*ClusterOperationStatus

+ Warnings []string

+ func (s *GceNodePoolOperationMetadata) MarshalJSON() ([]byte, error)

type Job

+ TrinoJob *TrinoJob

type OrderedJob

+ TrinoJob *TrinoJob

+ type TrinoJob struct

+ ClientTags []string

+ ContinueOnFailure bool

+ ForceSendFields []string

+ LoggingConfig *LoggingConfig

+ NullFields []string

+ OutputFormat string

+ Properties map[string]string

+ QueryFileUri string

+ QueryList *QueryList

+ func (s *TrinoJob) MarshalJSON() ([]byte, error)

Aug 23, 2022

Changes in this version

type ExecutionConfig

+ IdleTtl string

Aug 10, 2022

Changes in this version

type RepairClusterRequest

+ GracefulDecommissionTimeout string

+ ParentOperationId string

Jul 12, 2022

Changes in this version

type ClusterOperationMetadata

+ ChildOperationIds []string

Jun 7, 2022

Changes in this version

type GkeNodeConfig

+ BootDiskKmsKey string

+ type NodePool struct

+ ForceSendFields []string

+ Id string

+ InstanceNames []string

+ NullFields []string

+ RepairAction string

+ func (s *NodePool) MarshalJSON() ([]byte, error)

type RepairClusterRequest

+ NodePools []*NodePool

May 10, 2022

Changes in this version

+ type AuthenticationConfig struct

+ AuthenticationType string

+ ForceSendFields []string

+ InjectableCredentialsConfig *InjectableCredentialsConfig

+ NullFields []string

+ func (s *AuthenticationConfig) MarshalJSON() ([]byte, error)

+ type InjectableCredentialsConfig struct

type RuntimeConfig

+ SessionAuthenticationConfig *AuthenticationConfig

Apr 20, 2022

Changes in this version

+ type AuxiliaryServicesConfig struct

+ ForceSendFields []string

+ MetastoreConfig *MetastoreConfig

+ NullFields []string

+ SparkHistoryServerConfig *SparkHistoryServerConfig

+ func (s *AuxiliaryServicesConfig) MarshalJSON() ([]byte, error)

type Cluster

+ VirtualClusterConfig *VirtualClusterConfig

type GkeClusterConfig

+ GkeClusterTarget string

+ NodePoolTarget []*GkeNodePoolTarget

+ type GkeNodeConfig struct

+ Accelerators []*GkeNodePoolAcceleratorConfig

+ ForceSendFields []string

+ LocalSsdCount int64

+ MachineType string

+ MinCpuPlatform string

+ NullFields []string

+ Preemptible bool

+ Spot bool

+ func (s *GkeNodeConfig) MarshalJSON() ([]byte, error)

+ type GkeNodePoolAcceleratorConfig struct

+ AcceleratorCount int64

+ AcceleratorType string

+ ForceSendFields []string

+ GpuPartitionSize string

+ NullFields []string

+ func (s *GkeNodePoolAcceleratorConfig) MarshalJSON() ([]byte, error)

+ type GkeNodePoolAutoscalingConfig struct

+ ForceSendFields []string

+ MaxNodeCount int64

+ MinNodeCount int64

+ NullFields []string

+ func (s *GkeNodePoolAutoscalingConfig) MarshalJSON() ([]byte, error)

+ type GkeNodePoolConfig struct

+ Autoscaling *GkeNodePoolAutoscalingConfig

+ Config *GkeNodeConfig

+ ForceSendFields []string

+ Locations []string

+ NullFields []string

+ func (s *GkeNodePoolConfig) MarshalJSON() ([]byte, error)

+ type GkeNodePoolTarget struct

+ ForceSendFields []string

+ NodePool string

+ NodePoolConfig *GkeNodePoolConfig

+ NullFields []string

+ Roles []string

+ func (s *GkeNodePoolTarget) MarshalJSON() ([]byte, error)

+ type KubernetesClusterConfig struct

+ ForceSendFields []string

+ GkeClusterConfig *GkeClusterConfig

+ KubernetesNamespace string

+ KubernetesSoftwareConfig *KubernetesSoftwareConfig

+ NullFields []string

+ func (s *KubernetesClusterConfig) MarshalJSON() ([]byte, error)

+ type KubernetesSoftwareConfig struct

+ ComponentVersion map[string]string

+ ForceSendFields []string

+ NullFields []string

+ Properties map[string]string

+ func (s *KubernetesSoftwareConfig) MarshalJSON() ([]byte, error)

+ type VirtualClusterConfig struct

+ AuxiliaryServicesConfig *AuxiliaryServicesConfig

+ ForceSendFields []string

+ KubernetesClusterConfig *KubernetesClusterConfig

+ NullFields []string

+ StagingBucket string

+ func (s *VirtualClusterConfig) MarshalJSON() ([]byte, error)

Feb 8, 2022

Changes in this version

type ClusterConfig

+ DataprocMetricConfig *DataprocMetricConfig

+ type DataprocMetricConfig struct

+ ForceSendFields []string

+ Metrics []*Metric

+ NullFields []string

+ func (s *DataprocMetricConfig) MarshalJSON() ([]byte, error)

+ type Metric struct

+ ForceSendFields []string

+ MetricOverrides []string

+ MetricSource string

+ NullFields []string

+ func (s *Metric) MarshalJSON() ([]byte, error)

Jan 28, 2022

Changes in this version

+ type Batch struct

+ CreateTime string

+ Creator string

+ EnvironmentConfig *EnvironmentConfig

+ ForceSendFields []string

+ Labels map[string]string

+ Name string

+ NullFields []string

+ Operation string

+ PysparkBatch *PySparkBatch

+ RuntimeConfig *RuntimeConfig

+ RuntimeInfo *RuntimeInfo

+ SparkBatch *SparkBatch

+ SparkRBatch *SparkRBatch

+ SparkSqlBatch *SparkSqlBatch

+ State string

+ StateHistory []*StateHistory

+ StateMessage string

+ StateTime string

+ Uuid string

+ func (s *Batch) MarshalJSON() ([]byte, error)

+ type EnvironmentConfig struct

+ ExecutionConfig *ExecutionConfig

+ ForceSendFields []string

+ NullFields []string

+ PeripheralsConfig *PeripheralsConfig

+ func (s *EnvironmentConfig) MarshalJSON() ([]byte, error)

+ type ExecutionConfig struct

+ ForceSendFields []string

+ KmsKey string

+ NetworkTags []string

+ NetworkUri string

+ NullFields []string

+ ServiceAccount string

+ SubnetworkUri string

+ func (s *ExecutionConfig) MarshalJSON() ([]byte, error)

+ type ListBatchesResponse struct

+ Batches []*Batch

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ func (s *ListBatchesResponse) MarshalJSON() ([]byte, error)

+ type PeripheralsConfig struct

+ ForceSendFields []string

+ MetastoreService string

+ NullFields []string

+ SparkHistoryServerConfig *SparkHistoryServerConfig

+ func (s *PeripheralsConfig) MarshalJSON() ([]byte, error)

+ type ProjectsLocationsBatchesCreateCall struct

+ func (c *ProjectsLocationsBatchesCreateCall) BatchId(batchId string) *ProjectsLocationsBatchesCreateCall

+ func (c *ProjectsLocationsBatchesCreateCall) Context(ctx context.Context) *ProjectsLocationsBatchesCreateCall

+ func (c *ProjectsLocationsBatchesCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsBatchesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesCreateCall

+ func (c *ProjectsLocationsBatchesCreateCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesCreateCall) RequestId(requestId string) *ProjectsLocationsBatchesCreateCall

+ type ProjectsLocationsBatchesDeleteCall struct

+ func (c *ProjectsLocationsBatchesDeleteCall) Context(ctx context.Context) *ProjectsLocationsBatchesDeleteCall

+ func (c *ProjectsLocationsBatchesDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsLocationsBatchesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesDeleteCall

+ func (c *ProjectsLocationsBatchesDeleteCall) Header() http.Header

+ type ProjectsLocationsBatchesGetCall struct

+ func (c *ProjectsLocationsBatchesGetCall) Context(ctx context.Context) *ProjectsLocationsBatchesGetCall

+ func (c *ProjectsLocationsBatchesGetCall) Do(opts ...googleapi.CallOption) (*Batch, error)

+ func (c *ProjectsLocationsBatchesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesGetCall

+ func (c *ProjectsLocationsBatchesGetCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesGetCall

+ type ProjectsLocationsBatchesListCall struct

+ func (c *ProjectsLocationsBatchesListCall) Context(ctx context.Context) *ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) Do(opts ...googleapi.CallOption) (*ListBatchesResponse, error)

+ func (c *ProjectsLocationsBatchesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) Header() http.Header

+ func (c *ProjectsLocationsBatchesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) PageSize(pageSize int64) *ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) PageToken(pageToken string) *ProjectsLocationsBatchesListCall

+ func (c *ProjectsLocationsBatchesListCall) Pages(ctx context.Context, f func(*ListBatchesResponse) error) error

+ type ProjectsLocationsBatchesService struct

+ func NewProjectsLocationsBatchesService(s *Service) *ProjectsLocationsBatchesService

+ func (r *ProjectsLocationsBatchesService) Create(parent string, batch *Batch) *ProjectsLocationsBatchesCreateCall

+ func (r *ProjectsLocationsBatchesService) Delete(name string) *ProjectsLocationsBatchesDeleteCall

+ func (r *ProjectsLocationsBatchesService) Get(name string) *ProjectsLocationsBatchesGetCall

+ func (r *ProjectsLocationsBatchesService) List(parent string) *ProjectsLocationsBatchesListCall

type ProjectsLocationsService

+ Batches *ProjectsLocationsBatchesService

+ type PySparkBatch struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ JarFileUris []string

+ MainPythonFileUri string

+ NullFields []string

+ PythonFileUris []string

+ func (s *PySparkBatch) MarshalJSON() ([]byte, error)

+ type RuntimeConfig struct

+ ContainerImage string

+ ForceSendFields []string

+ NullFields []string

+ Properties map[string]string

+ Version string

+ func (s *RuntimeConfig) MarshalJSON() ([]byte, error)

+ type RuntimeInfo struct

+ DiagnosticOutputUri string

+ Endpoints map[string]string

+ ForceSendFields []string

+ NullFields []string

+ OutputUri string

+ func (s *RuntimeInfo) MarshalJSON() ([]byte, error)

+ type SparkBatch struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ JarFileUris []string

+ MainClass string

+ MainJarFileUri string

+ NullFields []string

+ func (s *SparkBatch) MarshalJSON() ([]byte, error)

+ type SparkHistoryServerConfig struct

+ DataprocCluster string

+ ForceSendFields []string

+ NullFields []string

+ func (s *SparkHistoryServerConfig) MarshalJSON() ([]byte, error)

+ type SparkRBatch struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ MainRFileUri string

+ NullFields []string

+ func (s *SparkRBatch) MarshalJSON() ([]byte, error)

+ type SparkSqlBatch struct

+ ForceSendFields []string

+ JarFileUris []string

+ NullFields []string

+ QueryFileUri string

+ QueryVariables map[string]string

+ func (s *SparkSqlBatch) MarshalJSON() ([]byte, error)

+ type StateHistory struct

+ ForceSendFields []string

+ NullFields []string

+ State string

+ StateMessage string

+ StateStartTime string

+ func (s *StateHistory) MarshalJSON() ([]byte, error)

Jan 11, 2022

Changes in this version

type DiskConfig

+ LocalSsdInterface string

Oct 28, 2021

Changes in this version

type AutoscalingPolicy

+ Labels map[string]string

type BasicAutoscalingAlgorithm

+ SparkStandaloneConfig *SparkStandaloneAutoscalingConfig

+ type SparkStandaloneAutoscalingConfig struct

+ ForceSendFields []string

+ GracefulDecommissionTimeout string

+ NullFields []string

+ ScaleDownFactor float64

+ ScaleDownMinWorkerFraction float64

+ ScaleUpFactor float64

+ ScaleUpMinWorkerFraction float64

+ func (s *SparkStandaloneAutoscalingConfig) MarshalJSON() ([]byte, error)

+ func (s *SparkStandaloneAutoscalingConfig) UnmarshalJSON(data []byte) error

Sep 16, 2021

Changes in this version

+ type SessionOperationMetadata struct

+ CreateTime string

+ Description string

+ DoneTime string

+ ForceSendFields []string

+ Labels map[string]string

+ NullFields []string

+ OperationType string

+ Session string

+ SessionUuid string

+ Warnings []string

+ func (s *SessionOperationMetadata) MarshalJSON() ([]byte, error)

Aug 31, 2021

Changes in this version

type ProjectsRegionsClustersCreateCall

+ func (c *ProjectsRegionsClustersCreateCall) ActionOnFailedPrimaryWorkers(actionOnFailedPrimaryWorkers string) *ProjectsRegionsClustersCreateCall

Jul 22, 2021

Changes in this version

+ type ProjectsRegionsClustersRepairCall struct

+ func (c *ProjectsRegionsClustersRepairCall) Context(ctx context.Context) *ProjectsRegionsClustersRepairCall

+ func (c *ProjectsRegionsClustersRepairCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersRepairCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersRepairCall

+ func (c *ProjectsRegionsClustersRepairCall) Header() http.Header

type ProjectsRegionsClustersService

+ func (r *ProjectsRegionsClustersService) Repair(projectId string, region string, clusterName string, ...) *ProjectsRegionsClustersRepairCall

+ type RepairClusterRequest struct

+ ClusterUuid string

+ ForceSendFields []string

+ NullFields []string

+ RequestId string

+ func (s *RepairClusterRequest) MarshalJSON() ([]byte, error)

Jun 7, 2021

Changes in this version

type InstanceReference

+ PublicEciesKey string

May 3, 2021

Changes in this version

+ type BatchOperationMetadata struct

+ Batch string

+ BatchUuid string

+ CreateTime string

+ Description string

+ DoneTime string

+ ForceSendFields []string

+ Labels map[string]string

+ NullFields []string

+ OperationType string

+ Warnings []string

+ func (s *BatchOperationMetadata) MarshalJSON() ([]byte, error)

+ type ConfidentialInstanceConfig struct

+ EnableConfidentialCompute bool

+ ForceSendFields []string

+ NullFields []string

+ func (s *ConfidentialInstanceConfig) MarshalJSON() ([]byte, error)

type GceClusterConfig

+ ConfidentialInstanceConfig *ConfidentialInstanceConfig

Apr 7, 2021

Changes in this version

type ClusterConfig

+ GkeClusterConfig *GkeClusterConfig

+ type GkeClusterConfig struct

+ ForceSendFields []string

+ NamespacedGkeDeploymentTarget *NamespacedGkeDeploymentTarget

+ NullFields []string

+ func (s *GkeClusterConfig) MarshalJSON() ([]byte, error)

+ type IdentityConfig struct

+ ForceSendFields []string

+ NullFields []string

+ UserServiceAccountMapping map[string]string

+ func (s *IdentityConfig) MarshalJSON() ([]byte, error)

+ type NamespacedGkeDeploymentTarget struct

+ ClusterNamespace string

+ ForceSendFields []string

+ NullFields []string

+ TargetGkeCluster string

+ func (s *NamespacedGkeDeploymentTarget) MarshalJSON() ([]byte, error)

type SecurityConfig

+ IdentityConfig *IdentityConfig

Mar 9, 2021

Changes in this version

type JobPlacement

+ ClusterLabels map[string]string

Feb 12, 2021

Changes in this version

type ClusterConfig

+ MetastoreConfig *MetastoreConfig

+ type MetastoreConfig struct

+ DataprocMetastoreService string

+ ForceSendFields []string

+ NullFields []string

+ func (s *MetastoreConfig) MarshalJSON() ([]byte, error)

type ProjectsRegionsClustersService

+ func (r *ProjectsRegionsClustersService) Start(projectId string, region string, clusterName string, ...) *ProjectsRegionsClustersStartCall

+ func (r *ProjectsRegionsClustersService) Stop(projectId string, region string, clusterName string, ...) *ProjectsRegionsClustersStopCall

+ type ProjectsRegionsClustersStartCall struct

+ func (c *ProjectsRegionsClustersStartCall) Context(ctx context.Context) *ProjectsRegionsClustersStartCall

+ func (c *ProjectsRegionsClustersStartCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersStartCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersStartCall

+ func (c *ProjectsRegionsClustersStartCall) Header() http.Header

+ type ProjectsRegionsClustersStopCall struct

+ func (c *ProjectsRegionsClustersStopCall) Context(ctx context.Context) *ProjectsRegionsClustersStopCall

+ func (c *ProjectsRegionsClustersStopCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersStopCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersStopCall

+ func (c *ProjectsRegionsClustersStopCall) Header() http.Header

+ type StartClusterRequest struct

+ ClusterUuid string

+ ForceSendFields []string

+ NullFields []string

+ RequestId string

+ func (s *StartClusterRequest) MarshalJSON() ([]byte, error)

+ type StopClusterRequest struct

+ ClusterUuid string

+ ForceSendFields []string

+ NullFields []string

+ RequestId string

+ func (s *StopClusterRequest) MarshalJSON() ([]byte, error)

Jan 25, 2021

Changes in this version

type GceClusterConfig

+ ShieldedInstanceConfig *ShieldedInstanceConfig

+ type InjectCredentialsRequest struct

+ ClusterUuid string

+ CredentialsCiphertext string

+ ForceSendFields []string

+ NullFields []string

+ func (s *InjectCredentialsRequest) MarshalJSON() ([]byte, error)

type InstanceReference

+ PublicKey string

+ type ProjectsRegionsClustersInjectCredentialsCall struct

+ func (c *ProjectsRegionsClustersInjectCredentialsCall) Context(ctx context.Context) *ProjectsRegionsClustersInjectCredentialsCall

+ func (c *ProjectsRegionsClustersInjectCredentialsCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersInjectCredentialsCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersInjectCredentialsCall

+ func (c *ProjectsRegionsClustersInjectCredentialsCall) Header() http.Header

type ProjectsRegionsClustersService

+ func (r *ProjectsRegionsClustersService) InjectCredentials(project string, region string, cluster string, ...) *ProjectsRegionsClustersInjectCredentialsCall

+ type ShieldedInstanceConfig struct

+ EnableIntegrityMonitoring bool

+ EnableSecureBoot bool

+ EnableVtpm bool

+ ForceSendFields []string

+ NullFields []string

+ func (s *ShieldedInstanceConfig) MarshalJSON() ([]byte, error)

type WorkflowMetadata

+ DagEndTime string

+ DagStartTime string

+ DagTimeout string

type WorkflowTemplate

+ DagTimeout string

Oct 26, 2020

Changes in this version

type JobScheduling

+ MaxFailuresTotal int64

Oct 13, 2020

Changes in this version

type GceClusterConfig

+ NodeGroupAffinity *NodeGroupAffinity

+ type NodeGroupAffinity struct

+ ForceSendFields []string

+ NodeGroupUri string

+ NullFields []string

+ func (s *NodeGroupAffinity) MarshalJSON() ([]byte, error)

Sep 15, 2020

Changes in this version

type Binding

+ BindingId string

type GceClusterConfig

+ PrivateIpv6GoogleAccess string

Sep 1, 2020

Changes in this version

type InstanceGroupConfig

+ InstanceReferences []*InstanceReference

+ type InstanceReference struct

+ ForceSendFields []string

+ InstanceId string

+ InstanceName string

+ NullFields []string

+ func (s *InstanceReference) MarshalJSON() ([]byte, error)

Jul 8, 2020

Changes in this version

type ClusterConfig

+ EndpointConfig *EndpointConfig

+ TempBucket string

+ type EndpointConfig struct

+ EnableHttpPortAccess bool

+ ForceSendFields []string

+ HttpPorts map[string]string

+ NullFields []string

+ func (s *EndpointConfig) MarshalJSON() ([]byte, error)

Apr 21, 2020

Changes in this version

+ type JobMetadata struct

+ ForceSendFields []string

+ JobId string

+ NullFields []string

+ OperationType string

+ StartTime string

+ Status *JobStatus

+ func (s *JobMetadata) MarshalJSON() ([]byte, error)

type OrderedJob

+ PrestoJob *PrestoJob

+ SparkRJob *SparkRJob

type ProjectsRegionsJobsService

+ func (r *ProjectsRegionsJobsService) SubmitAsOperation(projectId string, region string, submitjobrequest *SubmitJobRequest) *ProjectsRegionsJobsSubmitAsOperationCall

+ type ProjectsRegionsJobsSubmitAsOperationCall struct

+ func (c *ProjectsRegionsJobsSubmitAsOperationCall) Context(ctx context.Context) *ProjectsRegionsJobsSubmitAsOperationCall

+ func (c *ProjectsRegionsJobsSubmitAsOperationCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsJobsSubmitAsOperationCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsSubmitAsOperationCall

+ func (c *ProjectsRegionsJobsSubmitAsOperationCall) Header() http.Header

Apr 3, 2020

Changes in this version

type InstanceGroupConfig

+ Preemptibility string

type Job

+ Done bool

Feb 24, 2020

Changes in this version

type Job

+ PrestoJob *PrestoJob

+ type PrestoJob struct

+ ClientTags []string

+ ContinueOnFailure bool

+ ForceSendFields []string

+ LoggingConfig *LoggingConfig

+ NullFields []string

+ OutputFormat string

+ Properties map[string]string

+ QueryFileUri string

+ QueryList *QueryList

+ func (s *PrestoJob) MarshalJSON() ([]byte, error)

Dec 17, 2019

Changes in this version

type GceClusterConfig

+ ReservationAffinity *ReservationAffinity

type InstanceGroupConfig

+ MinCpuPlatform string

type Job

+ SparkRJob *SparkRJob

+ type ReservationAffinity struct

+ ConsumeReservationType string

+ ForceSendFields []string

+ Key string

+ NullFields []string

+ Values []string

+ func (s *ReservationAffinity) MarshalJSON() ([]byte, error)

+ type SparkRJob struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ LoggingConfig *LoggingConfig

+ MainRFileUri string

+ NullFields []string

+ Properties map[string]string

+ func (s *SparkRJob) MarshalJSON() ([]byte, error)

Oct 8, 2019

Changes in this version

+ type AutoscalingConfig struct

+ ForceSendFields []string

+ NullFields []string

+ PolicyUri string

+ func (s *AutoscalingConfig) MarshalJSON() ([]byte, error)

+ type AutoscalingPolicy struct

+ BasicAlgorithm *BasicAutoscalingAlgorithm

+ ForceSendFields []string

+ Id string

+ Name string

+ NullFields []string

+ SecondaryWorkerConfig *InstanceGroupAutoscalingPolicyConfig

+ WorkerConfig *InstanceGroupAutoscalingPolicyConfig

+ func (s *AutoscalingPolicy) MarshalJSON() ([]byte, error)

+ type BasicAutoscalingAlgorithm struct

+ CooldownPeriod string

+ ForceSendFields []string

+ NullFields []string

+ YarnConfig *BasicYarnAutoscalingConfig

+ func (s *BasicAutoscalingAlgorithm) MarshalJSON() ([]byte, error)

+ type BasicYarnAutoscalingConfig struct

+ ForceSendFields []string

+ GracefulDecommissionTimeout string

+ NullFields []string

+ ScaleDownFactor float64

+ ScaleDownMinWorkerFraction float64

+ ScaleUpFactor float64

+ ScaleUpMinWorkerFraction float64

+ func (s *BasicYarnAutoscalingConfig) MarshalJSON() ([]byte, error)

+ func (s *BasicYarnAutoscalingConfig) UnmarshalJSON(data []byte) error

type ClusterConfig

+ AutoscalingConfig *AutoscalingConfig

+ type InstanceGroupAutoscalingPolicyConfig struct

+ ForceSendFields []string

+ MaxInstances int64

+ MinInstances int64

+ NullFields []string

+ Weight int64

+ func (s *InstanceGroupAutoscalingPolicyConfig) MarshalJSON() ([]byte, error)

type KerberosConfig

+ Realm string

+ type ListAutoscalingPoliciesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Policies []*AutoscalingPolicy

+ func (s *ListAutoscalingPoliciesResponse) MarshalJSON() ([]byte, error)

+ type ProjectsLocationsAutoscalingPoliciesCreateCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesCreateCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesCreateCall

+ func (c *ProjectsLocationsAutoscalingPoliciesCreateCall) Do(opts ...googleapi.CallOption) (*AutoscalingPolicy, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesCreateCall

+ func (c *ProjectsLocationsAutoscalingPoliciesCreateCall) Header() http.Header

+ type ProjectsLocationsAutoscalingPoliciesDeleteCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesDeleteCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesDeleteCall

+ func (c *ProjectsLocationsAutoscalingPoliciesDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesDeleteCall

+ func (c *ProjectsLocationsAutoscalingPoliciesDeleteCall) Header() http.Header

+ type ProjectsLocationsAutoscalingPoliciesGetCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesGetCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesGetCall

+ func (c *ProjectsLocationsAutoscalingPoliciesGetCall) Do(opts ...googleapi.CallOption) (*AutoscalingPolicy, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesGetCall

+ func (c *ProjectsLocationsAutoscalingPoliciesGetCall) Header() http.Header

+ func (c *ProjectsLocationsAutoscalingPoliciesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsAutoscalingPoliciesGetCall

+ type ProjectsLocationsAutoscalingPoliciesListCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesListCall

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) Do(opts ...googleapi.CallOption) (*ListAutoscalingPoliciesResponse, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesListCall

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) Header() http.Header

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsAutoscalingPoliciesListCall

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) PageSize(pageSize int64) *ProjectsLocationsAutoscalingPoliciesListCall

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) PageToken(pageToken string) *ProjectsLocationsAutoscalingPoliciesListCall

+ func (c *ProjectsLocationsAutoscalingPoliciesListCall) Pages(ctx context.Context, f func(*ListAutoscalingPoliciesResponse) error) error

type ProjectsLocationsAutoscalingPoliciesService

+ func (r *ProjectsLocationsAutoscalingPoliciesService) Create(parent string, autoscalingpolicy *AutoscalingPolicy) *ProjectsLocationsAutoscalingPoliciesCreateCall

+ func (r *ProjectsLocationsAutoscalingPoliciesService) Delete(name string) *ProjectsLocationsAutoscalingPoliciesDeleteCall

+ func (r *ProjectsLocationsAutoscalingPoliciesService) Get(name string) *ProjectsLocationsAutoscalingPoliciesGetCall

+ func (r *ProjectsLocationsAutoscalingPoliciesService) List(parent string) *ProjectsLocationsAutoscalingPoliciesListCall

+ func (r *ProjectsLocationsAutoscalingPoliciesService) Update(name string, autoscalingpolicy *AutoscalingPolicy) *ProjectsLocationsAutoscalingPoliciesUpdateCall

+ type ProjectsLocationsAutoscalingPoliciesUpdateCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesUpdateCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesUpdateCall

+ func (c *ProjectsLocationsAutoscalingPoliciesUpdateCall) Do(opts ...googleapi.CallOption) (*AutoscalingPolicy, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesUpdateCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesUpdateCall

+ func (c *ProjectsLocationsAutoscalingPoliciesUpdateCall) Header() http.Header

+ type ProjectsRegionsAutoscalingPoliciesCreateCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesCreateCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesCreateCall

+ func (c *ProjectsRegionsAutoscalingPoliciesCreateCall) Do(opts ...googleapi.CallOption) (*AutoscalingPolicy, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesCreateCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesCreateCall

+ func (c *ProjectsRegionsAutoscalingPoliciesCreateCall) Header() http.Header

+ type ProjectsRegionsAutoscalingPoliciesDeleteCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesDeleteCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesDeleteCall

+ func (c *ProjectsRegionsAutoscalingPoliciesDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesDeleteCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesDeleteCall

+ func (c *ProjectsRegionsAutoscalingPoliciesDeleteCall) Header() http.Header

+ type ProjectsRegionsAutoscalingPoliciesGetCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesGetCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesGetCall

+ func (c *ProjectsRegionsAutoscalingPoliciesGetCall) Do(opts ...googleapi.CallOption) (*AutoscalingPolicy, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesGetCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesGetCall

+ func (c *ProjectsRegionsAutoscalingPoliciesGetCall) Header() http.Header

+ func (c *ProjectsRegionsAutoscalingPoliciesGetCall) IfNoneMatch(entityTag string) *ProjectsRegionsAutoscalingPoliciesGetCall

+ type ProjectsRegionsAutoscalingPoliciesListCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesListCall

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) Do(opts ...googleapi.CallOption) (*ListAutoscalingPoliciesResponse, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesListCall

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) Header() http.Header

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) IfNoneMatch(entityTag string) *ProjectsRegionsAutoscalingPoliciesListCall

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) PageSize(pageSize int64) *ProjectsRegionsAutoscalingPoliciesListCall

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) PageToken(pageToken string) *ProjectsRegionsAutoscalingPoliciesListCall

+ func (c *ProjectsRegionsAutoscalingPoliciesListCall) Pages(ctx context.Context, f func(*ListAutoscalingPoliciesResponse) error) error

type ProjectsRegionsAutoscalingPoliciesService

+ func (r *ProjectsRegionsAutoscalingPoliciesService) Create(parent string, autoscalingpolicy *AutoscalingPolicy) *ProjectsRegionsAutoscalingPoliciesCreateCall

+ func (r *ProjectsRegionsAutoscalingPoliciesService) Delete(name string) *ProjectsRegionsAutoscalingPoliciesDeleteCall

+ func (r *ProjectsRegionsAutoscalingPoliciesService) Get(name string) *ProjectsRegionsAutoscalingPoliciesGetCall

+ func (r *ProjectsRegionsAutoscalingPoliciesService) List(parent string) *ProjectsRegionsAutoscalingPoliciesListCall

+ func (r *ProjectsRegionsAutoscalingPoliciesService) Update(name string, autoscalingpolicy *AutoscalingPolicy) *ProjectsRegionsAutoscalingPoliciesUpdateCall

+ type ProjectsRegionsAutoscalingPoliciesUpdateCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesUpdateCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesUpdateCall

+ func (c *ProjectsRegionsAutoscalingPoliciesUpdateCall) Do(opts ...googleapi.CallOption) (*AutoscalingPolicy, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesUpdateCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesUpdateCall

+ func (c *ProjectsRegionsAutoscalingPoliciesUpdateCall) Header() http.Header

Aug 9, 2019

Changes in this version

type ClusterConfig

+ LifecycleConfig *LifecycleConfig

type GetIamPolicyRequest

+ ForceSendFields []string

+ NullFields []string

+ Options *GetPolicyOptions

+ func (s *GetIamPolicyRequest) MarshalJSON() ([]byte, error)

+ type GetPolicyOptions struct

+ ForceSendFields []string

+ NullFields []string

+ RequestedPolicyVersion int64

+ func (s *GetPolicyOptions) MarshalJSON() ([]byte, error)

+ type LifecycleConfig struct

+ AutoDeleteTime string

+ AutoDeleteTtl string

+ ForceSendFields []string

+ IdleDeleteTtl string

+ IdleStartTime string

+ NullFields []string

+ func (s *LifecycleConfig) MarshalJSON() ([]byte, error)

Jun 24, 2019

Changes in this version

type ClusterConfig

+ SecurityConfig *SecurityConfig

+ type KerberosConfig struct

+ CrossRealmTrustAdminServer string

+ CrossRealmTrustKdc string

+ CrossRealmTrustRealm string

+ CrossRealmTrustSharedPasswordUri string

+ EnableKerberos bool

+ ForceSendFields []string

+ KdcDbKeyUri string

+ KeyPasswordUri string

+ KeystorePasswordUri string

+ KeystoreUri string

+ KmsKeyUri string

+ NullFields []string

+ RootPrincipalPasswordUri string

+ TgtLifetimeHours int64

+ TruststorePasswordUri string

+ TruststoreUri string

+ func (s *KerberosConfig) MarshalJSON() ([]byte, error)

+ type SecurityConfig struct

+ ForceSendFields []string

+ KerberosConfig *KerberosConfig

+ NullFields []string

+ func (s *SecurityConfig) MarshalJSON() ([]byte, error)

Jun 6, 2019

Changes in this version

+ type ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall

+ func (c *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall

+ func (c *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall) Header() http.Header

+ type ProjectsLocationsAutoscalingPoliciesService struct

+ func NewProjectsLocationsAutoscalingPoliciesService(s *Service) *ProjectsLocationsAutoscalingPoliciesService

+ func (r *ProjectsLocationsAutoscalingPoliciesService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsLocationsAutoscalingPoliciesGetIamPolicyCall

+ func (r *ProjectsLocationsAutoscalingPoliciesService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall

+ func (r *ProjectsLocationsAutoscalingPoliciesService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall

+ type ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall

+ func (c *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall

+ func (c *ProjectsLocationsAutoscalingPoliciesSetIamPolicyCall) Header() http.Header

+ type ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall struct

+ func (c *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall) Context(ctx context.Context) *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall

+ func (c *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall

+ func (c *ProjectsLocationsAutoscalingPoliciesTestIamPermissionsCall) Header() http.Header

type ProjectsLocationsService

+ AutoscalingPolicies *ProjectsLocationsAutoscalingPoliciesService

+ type ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall

+ func (c *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall

+ func (c *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsAutoscalingPoliciesService struct

+ func NewProjectsRegionsAutoscalingPoliciesService(s *Service) *ProjectsRegionsAutoscalingPoliciesService

+ func (r *ProjectsRegionsAutoscalingPoliciesService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsRegionsAutoscalingPoliciesGetIamPolicyCall

+ func (r *ProjectsRegionsAutoscalingPoliciesService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall

+ func (r *ProjectsRegionsAutoscalingPoliciesService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall

+ type ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall

+ func (c *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall

+ func (c *ProjectsRegionsAutoscalingPoliciesSetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall struct

+ func (c *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall) Context(ctx context.Context) *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall

+ func (c *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall

+ func (c *ProjectsRegionsAutoscalingPoliciesTestIamPermissionsCall) Header() http.Header

type ProjectsRegionsService

+ AutoscalingPolicies *ProjectsRegionsAutoscalingPoliciesService

Mar 26, 2019

Changes in this version

type Service

+ func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error)

Mar 13, 2019

Changes in this version

type SoftwareConfig

+ OptionalComponents []string

Jan 2, 2019

Changes in this version

+ const CloudPlatformScope

+ type AcceleratorConfig struct

+ AcceleratorCount int64

+ AcceleratorTypeUri string

+ ForceSendFields []string

+ NullFields []string

+ func (s *AcceleratorConfig) MarshalJSON() ([]byte, error)

+ type Binding struct

+ Condition *Expr

+ ForceSendFields []string

+ Members []string

+ NullFields []string

+ Role string

+ func (s *Binding) MarshalJSON() ([]byte, error)

+ type CancelJobRequest struct

+ type Cluster struct

+ ClusterName string

+ ClusterUuid string

+ Config *ClusterConfig

+ ForceSendFields []string

+ Labels map[string]string

+ Metrics *ClusterMetrics

+ NullFields []string

+ ProjectId string

+ Status *ClusterStatus

+ StatusHistory []*ClusterStatus

+ func (s *Cluster) MarshalJSON() ([]byte, error)

+ type ClusterConfig struct

+ ConfigBucket string

+ EncryptionConfig *EncryptionConfig

+ ForceSendFields []string

+ GceClusterConfig *GceClusterConfig

+ InitializationActions []*NodeInitializationAction

+ MasterConfig *InstanceGroupConfig

+ NullFields []string

+ SecondaryWorkerConfig *InstanceGroupConfig

+ SoftwareConfig *SoftwareConfig

+ WorkerConfig *InstanceGroupConfig

+ func (s *ClusterConfig) MarshalJSON() ([]byte, error)

+ type ClusterMetrics struct

+ ForceSendFields []string

+ HdfsMetrics map[string]string

+ NullFields []string

+ YarnMetrics map[string]string

+ func (s *ClusterMetrics) MarshalJSON() ([]byte, error)

+ type ClusterOperation struct

+ Done bool

+ Error string

+ ForceSendFields []string

+ NullFields []string

+ OperationId string

+ func (s *ClusterOperation) MarshalJSON() ([]byte, error)

+ type ClusterOperationMetadata struct

+ ClusterName string

+ ClusterUuid string

+ Description string

+ ForceSendFields []string

+ Labels map[string]string

+ NullFields []string

+ OperationType string

+ Status *ClusterOperationStatus

+ StatusHistory []*ClusterOperationStatus

+ Warnings []string

+ func (s *ClusterOperationMetadata) MarshalJSON() ([]byte, error)

+ type ClusterOperationStatus struct

+ Details string

+ ForceSendFields []string

+ InnerState string

+ NullFields []string

+ State string

+ StateStartTime string

+ func (s *ClusterOperationStatus) MarshalJSON() ([]byte, error)

+ type ClusterSelector struct

+ ClusterLabels map[string]string

+ ForceSendFields []string

+ NullFields []string

+ Zone string

+ func (s *ClusterSelector) MarshalJSON() ([]byte, error)

+ type ClusterStatus struct

+ Detail string

+ ForceSendFields []string

+ NullFields []string

+ State string

+ StateStartTime string

+ Substate string

+ func (s *ClusterStatus) MarshalJSON() ([]byte, error)

+ type DiagnoseClusterRequest struct

+ type DiagnoseClusterResults struct

+ ForceSendFields []string

+ NullFields []string

+ OutputUri string

+ func (s *DiagnoseClusterResults) MarshalJSON() ([]byte, error)

+ type DiskConfig struct

+ BootDiskSizeGb int64

+ BootDiskType string

+ ForceSendFields []string

+ NullFields []string

+ NumLocalSsds int64

+ func (s *DiskConfig) MarshalJSON() ([]byte, error)

+ type Empty struct

+ type EncryptionConfig struct

+ ForceSendFields []string

+ GcePdKmsKeyName string

+ NullFields []string

+ func (s *EncryptionConfig) MarshalJSON() ([]byte, error)

+ type Expr struct

+ Description string

+ Expression string

+ ForceSendFields []string

+ Location string

+ NullFields []string

+ Title string

+ func (s *Expr) MarshalJSON() ([]byte, error)

+ type GceClusterConfig struct

+ ForceSendFields []string

+ InternalIpOnly bool

+ Metadata map[string]string

+ NetworkUri string

+ NullFields []string

+ ServiceAccount string

+ ServiceAccountScopes []string

+ SubnetworkUri string

+ Tags []string

+ ZoneUri string

+ func (s *GceClusterConfig) MarshalJSON() ([]byte, error)

+ type GetIamPolicyRequest struct

+ type HadoopJob struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ JarFileUris []string

+ LoggingConfig *LoggingConfig

+ MainClass string

+ MainJarFileUri string

+ NullFields []string

+ Properties map[string]string

+ func (s *HadoopJob) MarshalJSON() ([]byte, error)

+ type HiveJob struct

+ ContinueOnFailure bool

+ ForceSendFields []string

+ JarFileUris []string

+ NullFields []string

+ Properties map[string]string

+ QueryFileUri string

+ QueryList *QueryList

+ ScriptVariables map[string]string

+ func (s *HiveJob) MarshalJSON() ([]byte, error)

+ type InstanceGroupConfig struct

+ Accelerators []*AcceleratorConfig

+ DiskConfig *DiskConfig

+ ForceSendFields []string

+ ImageUri string

+ InstanceNames []string

+ IsPreemptible bool

+ MachineTypeUri string

+ ManagedGroupConfig *ManagedGroupConfig

+ NullFields []string

+ NumInstances int64

+ func (s *InstanceGroupConfig) MarshalJSON() ([]byte, error)

+ type InstantiateWorkflowTemplateRequest struct

+ ForceSendFields []string

+ NullFields []string

+ Parameters map[string]string

+ RequestId string

+ Version int64

+ func (s *InstantiateWorkflowTemplateRequest) MarshalJSON() ([]byte, error)

+ type Job struct

+ DriverControlFilesUri string

+ DriverOutputResourceUri string

+ ForceSendFields []string

+ HadoopJob *HadoopJob

+ HiveJob *HiveJob

+ JobUuid string

+ Labels map[string]string

+ NullFields []string

+ PigJob *PigJob

+ Placement *JobPlacement

+ PysparkJob *PySparkJob

+ Reference *JobReference

+ Scheduling *JobScheduling

+ SparkJob *SparkJob

+ SparkSqlJob *SparkSqlJob

+ Status *JobStatus

+ StatusHistory []*JobStatus

+ YarnApplications []*YarnApplication

+ func (s *Job) MarshalJSON() ([]byte, error)

+ type JobPlacement struct

+ ClusterName string

+ ClusterUuid string

+ ForceSendFields []string

+ NullFields []string

+ func (s *JobPlacement) MarshalJSON() ([]byte, error)

+ type JobReference struct

+ ForceSendFields []string

+ JobId string

+ NullFields []string

+ ProjectId string

+ func (s *JobReference) MarshalJSON() ([]byte, error)

+ type JobScheduling struct

+ ForceSendFields []string

+ MaxFailuresPerHour int64

+ NullFields []string

+ func (s *JobScheduling) MarshalJSON() ([]byte, error)

+ type JobStatus struct

+ Details string

+ ForceSendFields []string

+ NullFields []string

+ State string

+ StateStartTime string

+ Substate string

+ func (s *JobStatus) MarshalJSON() ([]byte, error)

+ type ListClustersResponse struct

+ Clusters []*Cluster

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ func (s *ListClustersResponse) MarshalJSON() ([]byte, error)

+ type ListJobsResponse struct

+ ForceSendFields []string

+ Jobs []*Job

+ NextPageToken string

+ NullFields []string

+ func (s *ListJobsResponse) MarshalJSON() ([]byte, error)

+ type ListOperationsResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Operations []*Operation

+ func (s *ListOperationsResponse) MarshalJSON() ([]byte, error)

+ type ListWorkflowTemplatesResponse struct

+ ForceSendFields []string

+ NextPageToken string

+ NullFields []string

+ Templates []*WorkflowTemplate

+ func (s *ListWorkflowTemplatesResponse) MarshalJSON() ([]byte, error)

+ type LoggingConfig struct

+ DriverLogLevels map[string]string

+ ForceSendFields []string

+ NullFields []string

+ func (s *LoggingConfig) MarshalJSON() ([]byte, error)

+ type ManagedCluster struct

+ ClusterName string

+ Config *ClusterConfig

+ ForceSendFields []string

+ Labels map[string]string

+ NullFields []string

+ func (s *ManagedCluster) MarshalJSON() ([]byte, error)

+ type ManagedGroupConfig struct

+ ForceSendFields []string

+ InstanceGroupManagerName string

+ InstanceTemplateName string

+ NullFields []string

+ func (s *ManagedGroupConfig) MarshalJSON() ([]byte, error)

+ type NodeInitializationAction struct

+ ExecutableFile string

+ ExecutionTimeout string

+ ForceSendFields []string

+ NullFields []string

+ func (s *NodeInitializationAction) MarshalJSON() ([]byte, error)

+ type Operation struct

+ Done bool

+ Error *Status

+ ForceSendFields []string

+ Metadata googleapi.RawMessage

+ Name string

+ NullFields []string

+ Response googleapi.RawMessage

+ func (s *Operation) MarshalJSON() ([]byte, error)

+ type OrderedJob struct

+ ForceSendFields []string

+ HadoopJob *HadoopJob

+ HiveJob *HiveJob

+ Labels map[string]string

+ NullFields []string

+ PigJob *PigJob

+ PrerequisiteStepIds []string

+ PysparkJob *PySparkJob

+ Scheduling *JobScheduling

+ SparkJob *SparkJob

+ SparkSqlJob *SparkSqlJob

+ StepId string

+ func (s *OrderedJob) MarshalJSON() ([]byte, error)

+ type ParameterValidation struct

+ ForceSendFields []string

+ NullFields []string

+ Regex *RegexValidation

+ Values *ValueValidation

+ func (s *ParameterValidation) MarshalJSON() ([]byte, error)

+ type PigJob struct

+ ContinueOnFailure bool

+ ForceSendFields []string

+ JarFileUris []string

+ LoggingConfig *LoggingConfig

+ NullFields []string

+ Properties map[string]string

+ QueryFileUri string

+ QueryList *QueryList

+ ScriptVariables map[string]string

+ func (s *PigJob) MarshalJSON() ([]byte, error)

+ type Policy struct

+ Bindings []*Binding

+ Etag string

+ ForceSendFields []string

+ NullFields []string

+ Version int64

+ func (s *Policy) MarshalJSON() ([]byte, error)

+ type ProjectsLocationsService struct

+ WorkflowTemplates *ProjectsLocationsWorkflowTemplatesService

+ func NewProjectsLocationsService(s *Service) *ProjectsLocationsService

+ type ProjectsLocationsWorkflowTemplatesCreateCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesCreateCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesCreateCall

+ func (c *ProjectsLocationsWorkflowTemplatesCreateCall) Do(opts ...googleapi.CallOption) (*WorkflowTemplate, error)

+ func (c *ProjectsLocationsWorkflowTemplatesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesCreateCall

+ func (c *ProjectsLocationsWorkflowTemplatesCreateCall) Header() http.Header

+ type ProjectsLocationsWorkflowTemplatesDeleteCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesDeleteCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesDeleteCall

+ func (c *ProjectsLocationsWorkflowTemplatesDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsLocationsWorkflowTemplatesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesDeleteCall

+ func (c *ProjectsLocationsWorkflowTemplatesDeleteCall) Header() http.Header

+ func (c *ProjectsLocationsWorkflowTemplatesDeleteCall) Version(version int64) *ProjectsLocationsWorkflowTemplatesDeleteCall

+ type ProjectsLocationsWorkflowTemplatesGetCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesGetCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesGetCall

+ func (c *ProjectsLocationsWorkflowTemplatesGetCall) Do(opts ...googleapi.CallOption) (*WorkflowTemplate, error)

+ func (c *ProjectsLocationsWorkflowTemplatesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesGetCall

+ func (c *ProjectsLocationsWorkflowTemplatesGetCall) Header() http.Header

+ func (c *ProjectsLocationsWorkflowTemplatesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsWorkflowTemplatesGetCall

+ func (c *ProjectsLocationsWorkflowTemplatesGetCall) Version(version int64) *ProjectsLocationsWorkflowTemplatesGetCall

+ type ProjectsLocationsWorkflowTemplatesGetIamPolicyCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall

+ func (c *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall

+ func (c *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall) Header() http.Header

+ type ProjectsLocationsWorkflowTemplatesInstantiateCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesInstantiateCall

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesInstantiateCall

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateCall) Header() http.Header

+ type ProjectsLocationsWorkflowTemplatesInstantiateInlineCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall) Header() http.Header

+ func (c *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall) RequestId(requestId string) *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall

+ type ProjectsLocationsWorkflowTemplatesListCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesListCall

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) Do(opts ...googleapi.CallOption) (*ListWorkflowTemplatesResponse, error)

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesListCall

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) Header() http.Header

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsWorkflowTemplatesListCall

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) PageSize(pageSize int64) *ProjectsLocationsWorkflowTemplatesListCall

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) PageToken(pageToken string) *ProjectsLocationsWorkflowTemplatesListCall

+ func (c *ProjectsLocationsWorkflowTemplatesListCall) Pages(ctx context.Context, f func(*ListWorkflowTemplatesResponse) error) error

+ type ProjectsLocationsWorkflowTemplatesService struct

+ func NewProjectsLocationsWorkflowTemplatesService(s *Service) *ProjectsLocationsWorkflowTemplatesService

+ func (r *ProjectsLocationsWorkflowTemplatesService) Create(parent string, workflowtemplate *WorkflowTemplate) *ProjectsLocationsWorkflowTemplatesCreateCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) Delete(name string) *ProjectsLocationsWorkflowTemplatesDeleteCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) Get(name string) *ProjectsLocationsWorkflowTemplatesGetCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsLocationsWorkflowTemplatesGetIamPolicyCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) Instantiate(name string, ...) *ProjectsLocationsWorkflowTemplatesInstantiateCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) InstantiateInline(parent string, workflowtemplate *WorkflowTemplate) *ProjectsLocationsWorkflowTemplatesInstantiateInlineCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) List(parent string) *ProjectsLocationsWorkflowTemplatesListCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall

+ func (r *ProjectsLocationsWorkflowTemplatesService) Update(name string, workflowtemplate *WorkflowTemplate) *ProjectsLocationsWorkflowTemplatesUpdateCall

+ type ProjectsLocationsWorkflowTemplatesSetIamPolicyCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall

+ func (c *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall

+ func (c *ProjectsLocationsWorkflowTemplatesSetIamPolicyCall) Header() http.Header

+ type ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall

+ func (c *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall

+ func (c *ProjectsLocationsWorkflowTemplatesTestIamPermissionsCall) Header() http.Header

+ type ProjectsLocationsWorkflowTemplatesUpdateCall struct

+ func (c *ProjectsLocationsWorkflowTemplatesUpdateCall) Context(ctx context.Context) *ProjectsLocationsWorkflowTemplatesUpdateCall

+ func (c *ProjectsLocationsWorkflowTemplatesUpdateCall) Do(opts ...googleapi.CallOption) (*WorkflowTemplate, error)

+ func (c *ProjectsLocationsWorkflowTemplatesUpdateCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkflowTemplatesUpdateCall

+ func (c *ProjectsLocationsWorkflowTemplatesUpdateCall) Header() http.Header

+ type ProjectsRegionsClustersCreateCall struct

+ func (c *ProjectsRegionsClustersCreateCall) Context(ctx context.Context) *ProjectsRegionsClustersCreateCall

+ func (c *ProjectsRegionsClustersCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersCreateCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersCreateCall

+ func (c *ProjectsRegionsClustersCreateCall) Header() http.Header

+ func (c *ProjectsRegionsClustersCreateCall) RequestId(requestId string) *ProjectsRegionsClustersCreateCall

+ type ProjectsRegionsClustersDeleteCall struct

+ func (c *ProjectsRegionsClustersDeleteCall) ClusterUuid(clusterUuid string) *ProjectsRegionsClustersDeleteCall

+ func (c *ProjectsRegionsClustersDeleteCall) Context(ctx context.Context) *ProjectsRegionsClustersDeleteCall

+ func (c *ProjectsRegionsClustersDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersDeleteCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersDeleteCall

+ func (c *ProjectsRegionsClustersDeleteCall) Header() http.Header

+ func (c *ProjectsRegionsClustersDeleteCall) RequestId(requestId string) *ProjectsRegionsClustersDeleteCall

+ type ProjectsRegionsClustersDiagnoseCall struct

+ func (c *ProjectsRegionsClustersDiagnoseCall) Context(ctx context.Context) *ProjectsRegionsClustersDiagnoseCall

+ func (c *ProjectsRegionsClustersDiagnoseCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersDiagnoseCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersDiagnoseCall

+ func (c *ProjectsRegionsClustersDiagnoseCall) Header() http.Header

+ type ProjectsRegionsClustersGetCall struct

+ func (c *ProjectsRegionsClustersGetCall) Context(ctx context.Context) *ProjectsRegionsClustersGetCall

+ func (c *ProjectsRegionsClustersGetCall) Do(opts ...googleapi.CallOption) (*Cluster, error)

+ func (c *ProjectsRegionsClustersGetCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersGetCall

+ func (c *ProjectsRegionsClustersGetCall) Header() http.Header

+ func (c *ProjectsRegionsClustersGetCall) IfNoneMatch(entityTag string) *ProjectsRegionsClustersGetCall

+ type ProjectsRegionsClustersGetIamPolicyCall struct

+ func (c *ProjectsRegionsClustersGetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsClustersGetIamPolicyCall

+ func (c *ProjectsRegionsClustersGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsClustersGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersGetIamPolicyCall

+ func (c *ProjectsRegionsClustersGetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsClustersListCall struct

+ func (c *ProjectsRegionsClustersListCall) Context(ctx context.Context) *ProjectsRegionsClustersListCall

+ func (c *ProjectsRegionsClustersListCall) Do(opts ...googleapi.CallOption) (*ListClustersResponse, error)

+ func (c *ProjectsRegionsClustersListCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersListCall

+ func (c *ProjectsRegionsClustersListCall) Filter(filter string) *ProjectsRegionsClustersListCall

+ func (c *ProjectsRegionsClustersListCall) Header() http.Header

+ func (c *ProjectsRegionsClustersListCall) IfNoneMatch(entityTag string) *ProjectsRegionsClustersListCall

+ func (c *ProjectsRegionsClustersListCall) PageSize(pageSize int64) *ProjectsRegionsClustersListCall

+ func (c *ProjectsRegionsClustersListCall) PageToken(pageToken string) *ProjectsRegionsClustersListCall

+ func (c *ProjectsRegionsClustersListCall) Pages(ctx context.Context, f func(*ListClustersResponse) error) error

+ type ProjectsRegionsClustersPatchCall struct

+ func (c *ProjectsRegionsClustersPatchCall) Context(ctx context.Context) *ProjectsRegionsClustersPatchCall

+ func (c *ProjectsRegionsClustersPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsClustersPatchCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersPatchCall

+ func (c *ProjectsRegionsClustersPatchCall) GracefulDecommissionTimeout(gracefulDecommissionTimeout string) *ProjectsRegionsClustersPatchCall

+ func (c *ProjectsRegionsClustersPatchCall) Header() http.Header

+ func (c *ProjectsRegionsClustersPatchCall) RequestId(requestId string) *ProjectsRegionsClustersPatchCall

+ func (c *ProjectsRegionsClustersPatchCall) UpdateMask(updateMask string) *ProjectsRegionsClustersPatchCall

+ type ProjectsRegionsClustersService struct

+ func NewProjectsRegionsClustersService(s *Service) *ProjectsRegionsClustersService

+ func (r *ProjectsRegionsClustersService) Create(projectId string, region string, cluster *Cluster) *ProjectsRegionsClustersCreateCall

+ func (r *ProjectsRegionsClustersService) Delete(projectId string, region string, clusterName string) *ProjectsRegionsClustersDeleteCall

+ func (r *ProjectsRegionsClustersService) Diagnose(projectId string, region string, clusterName string, ...) *ProjectsRegionsClustersDiagnoseCall

+ func (r *ProjectsRegionsClustersService) Get(projectId string, region string, clusterName string) *ProjectsRegionsClustersGetCall

+ func (r *ProjectsRegionsClustersService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsRegionsClustersGetIamPolicyCall

+ func (r *ProjectsRegionsClustersService) List(projectId string, region string) *ProjectsRegionsClustersListCall

+ func (r *ProjectsRegionsClustersService) Patch(projectId string, region string, clusterName string, cluster *Cluster) *ProjectsRegionsClustersPatchCall

+ func (r *ProjectsRegionsClustersService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsRegionsClustersSetIamPolicyCall

+ func (r *ProjectsRegionsClustersService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsRegionsClustersTestIamPermissionsCall

+ type ProjectsRegionsClustersSetIamPolicyCall struct

+ func (c *ProjectsRegionsClustersSetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsClustersSetIamPolicyCall

+ func (c *ProjectsRegionsClustersSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsClustersSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersSetIamPolicyCall

+ func (c *ProjectsRegionsClustersSetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsClustersTestIamPermissionsCall struct

+ func (c *ProjectsRegionsClustersTestIamPermissionsCall) Context(ctx context.Context) *ProjectsRegionsClustersTestIamPermissionsCall

+ func (c *ProjectsRegionsClustersTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsRegionsClustersTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsRegionsClustersTestIamPermissionsCall

+ func (c *ProjectsRegionsClustersTestIamPermissionsCall) Header() http.Header

+ type ProjectsRegionsJobsCancelCall struct

+ func (c *ProjectsRegionsJobsCancelCall) Context(ctx context.Context) *ProjectsRegionsJobsCancelCall

+ func (c *ProjectsRegionsJobsCancelCall) Do(opts ...googleapi.CallOption) (*Job, error)

+ func (c *ProjectsRegionsJobsCancelCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsCancelCall

+ func (c *ProjectsRegionsJobsCancelCall) Header() http.Header

+ type ProjectsRegionsJobsDeleteCall struct

+ func (c *ProjectsRegionsJobsDeleteCall) Context(ctx context.Context) *ProjectsRegionsJobsDeleteCall

+ func (c *ProjectsRegionsJobsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsRegionsJobsDeleteCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsDeleteCall

+ func (c *ProjectsRegionsJobsDeleteCall) Header() http.Header

+ type ProjectsRegionsJobsGetCall struct

+ func (c *ProjectsRegionsJobsGetCall) Context(ctx context.Context) *ProjectsRegionsJobsGetCall

+ func (c *ProjectsRegionsJobsGetCall) Do(opts ...googleapi.CallOption) (*Job, error)

+ func (c *ProjectsRegionsJobsGetCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsGetCall

+ func (c *ProjectsRegionsJobsGetCall) Header() http.Header

+ func (c *ProjectsRegionsJobsGetCall) IfNoneMatch(entityTag string) *ProjectsRegionsJobsGetCall

+ type ProjectsRegionsJobsGetIamPolicyCall struct

+ func (c *ProjectsRegionsJobsGetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsJobsGetIamPolicyCall

+ func (c *ProjectsRegionsJobsGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsJobsGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsGetIamPolicyCall

+ func (c *ProjectsRegionsJobsGetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsJobsListCall struct

+ func (c *ProjectsRegionsJobsListCall) ClusterName(clusterName string) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) Context(ctx context.Context) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) Do(opts ...googleapi.CallOption) (*ListJobsResponse, error)

+ func (c *ProjectsRegionsJobsListCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) Filter(filter string) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) Header() http.Header

+ func (c *ProjectsRegionsJobsListCall) IfNoneMatch(entityTag string) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) JobStateMatcher(jobStateMatcher string) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) PageSize(pageSize int64) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) PageToken(pageToken string) *ProjectsRegionsJobsListCall

+ func (c *ProjectsRegionsJobsListCall) Pages(ctx context.Context, f func(*ListJobsResponse) error) error

+ type ProjectsRegionsJobsPatchCall struct

+ func (c *ProjectsRegionsJobsPatchCall) Context(ctx context.Context) *ProjectsRegionsJobsPatchCall

+ func (c *ProjectsRegionsJobsPatchCall) Do(opts ...googleapi.CallOption) (*Job, error)

+ func (c *ProjectsRegionsJobsPatchCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsPatchCall

+ func (c *ProjectsRegionsJobsPatchCall) Header() http.Header

+ func (c *ProjectsRegionsJobsPatchCall) UpdateMask(updateMask string) *ProjectsRegionsJobsPatchCall

+ type ProjectsRegionsJobsService struct

+ func NewProjectsRegionsJobsService(s *Service) *ProjectsRegionsJobsService

+ func (r *ProjectsRegionsJobsService) Cancel(projectId string, region string, jobId string, ...) *ProjectsRegionsJobsCancelCall

+ func (r *ProjectsRegionsJobsService) Delete(projectId string, region string, jobId string) *ProjectsRegionsJobsDeleteCall

+ func (r *ProjectsRegionsJobsService) Get(projectId string, region string, jobId string) *ProjectsRegionsJobsGetCall

+ func (r *ProjectsRegionsJobsService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsRegionsJobsGetIamPolicyCall

+ func (r *ProjectsRegionsJobsService) List(projectId string, region string) *ProjectsRegionsJobsListCall

+ func (r *ProjectsRegionsJobsService) Patch(projectId string, region string, jobId string, job *Job) *ProjectsRegionsJobsPatchCall

+ func (r *ProjectsRegionsJobsService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsRegionsJobsSetIamPolicyCall

+ func (r *ProjectsRegionsJobsService) Submit(projectId string, region string, submitjobrequest *SubmitJobRequest) *ProjectsRegionsJobsSubmitCall

+ func (r *ProjectsRegionsJobsService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsRegionsJobsTestIamPermissionsCall

+ type ProjectsRegionsJobsSetIamPolicyCall struct

+ func (c *ProjectsRegionsJobsSetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsJobsSetIamPolicyCall

+ func (c *ProjectsRegionsJobsSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsJobsSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsSetIamPolicyCall

+ func (c *ProjectsRegionsJobsSetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsJobsSubmitCall struct

+ func (c *ProjectsRegionsJobsSubmitCall) Context(ctx context.Context) *ProjectsRegionsJobsSubmitCall

+ func (c *ProjectsRegionsJobsSubmitCall) Do(opts ...googleapi.CallOption) (*Job, error)

+ func (c *ProjectsRegionsJobsSubmitCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsSubmitCall

+ func (c *ProjectsRegionsJobsSubmitCall) Header() http.Header

+ type ProjectsRegionsJobsTestIamPermissionsCall struct

+ func (c *ProjectsRegionsJobsTestIamPermissionsCall) Context(ctx context.Context) *ProjectsRegionsJobsTestIamPermissionsCall

+ func (c *ProjectsRegionsJobsTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsRegionsJobsTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsRegionsJobsTestIamPermissionsCall

+ func (c *ProjectsRegionsJobsTestIamPermissionsCall) Header() http.Header

+ type ProjectsRegionsOperationsCancelCall struct

+ func (c *ProjectsRegionsOperationsCancelCall) Context(ctx context.Context) *ProjectsRegionsOperationsCancelCall

+ func (c *ProjectsRegionsOperationsCancelCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsRegionsOperationsCancelCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsCancelCall

+ func (c *ProjectsRegionsOperationsCancelCall) Header() http.Header

+ type ProjectsRegionsOperationsDeleteCall struct

+ func (c *ProjectsRegionsOperationsDeleteCall) Context(ctx context.Context) *ProjectsRegionsOperationsDeleteCall

+ func (c *ProjectsRegionsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsRegionsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsDeleteCall

+ func (c *ProjectsRegionsOperationsDeleteCall) Header() http.Header

+ type ProjectsRegionsOperationsGetCall struct

+ func (c *ProjectsRegionsOperationsGetCall) Context(ctx context.Context) *ProjectsRegionsOperationsGetCall

+ func (c *ProjectsRegionsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsGetCall

+ func (c *ProjectsRegionsOperationsGetCall) Header() http.Header

+ func (c *ProjectsRegionsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsRegionsOperationsGetCall

+ type ProjectsRegionsOperationsGetIamPolicyCall struct

+ func (c *ProjectsRegionsOperationsGetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsOperationsGetIamPolicyCall

+ func (c *ProjectsRegionsOperationsGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsOperationsGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsGetIamPolicyCall

+ func (c *ProjectsRegionsOperationsGetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsOperationsListCall struct

+ func (c *ProjectsRegionsOperationsListCall) Context(ctx context.Context) *ProjectsRegionsOperationsListCall

+ func (c *ProjectsRegionsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error)

+ func (c *ProjectsRegionsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsListCall

+ func (c *ProjectsRegionsOperationsListCall) Filter(filter string) *ProjectsRegionsOperationsListCall

+ func (c *ProjectsRegionsOperationsListCall) Header() http.Header

+ func (c *ProjectsRegionsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsRegionsOperationsListCall

+ func (c *ProjectsRegionsOperationsListCall) PageSize(pageSize int64) *ProjectsRegionsOperationsListCall

+ func (c *ProjectsRegionsOperationsListCall) PageToken(pageToken string) *ProjectsRegionsOperationsListCall

+ func (c *ProjectsRegionsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error

+ type ProjectsRegionsOperationsService struct

+ func NewProjectsRegionsOperationsService(s *Service) *ProjectsRegionsOperationsService

+ func (r *ProjectsRegionsOperationsService) Cancel(name string) *ProjectsRegionsOperationsCancelCall

+ func (r *ProjectsRegionsOperationsService) Delete(name string) *ProjectsRegionsOperationsDeleteCall

+ func (r *ProjectsRegionsOperationsService) Get(name string) *ProjectsRegionsOperationsGetCall

+ func (r *ProjectsRegionsOperationsService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsRegionsOperationsGetIamPolicyCall

+ func (r *ProjectsRegionsOperationsService) List(name string) *ProjectsRegionsOperationsListCall

+ func (r *ProjectsRegionsOperationsService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsRegionsOperationsSetIamPolicyCall

+ func (r *ProjectsRegionsOperationsService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsRegionsOperationsTestIamPermissionsCall

+ type ProjectsRegionsOperationsSetIamPolicyCall struct

+ func (c *ProjectsRegionsOperationsSetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsOperationsSetIamPolicyCall

+ func (c *ProjectsRegionsOperationsSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsOperationsSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsSetIamPolicyCall

+ func (c *ProjectsRegionsOperationsSetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsOperationsTestIamPermissionsCall struct

+ func (c *ProjectsRegionsOperationsTestIamPermissionsCall) Context(ctx context.Context) *ProjectsRegionsOperationsTestIamPermissionsCall

+ func (c *ProjectsRegionsOperationsTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsRegionsOperationsTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsRegionsOperationsTestIamPermissionsCall

+ func (c *ProjectsRegionsOperationsTestIamPermissionsCall) Header() http.Header

+ type ProjectsRegionsService struct

+ Clusters *ProjectsRegionsClustersService

+ Jobs *ProjectsRegionsJobsService

+ Operations *ProjectsRegionsOperationsService

+ WorkflowTemplates *ProjectsRegionsWorkflowTemplatesService

+ func NewProjectsRegionsService(s *Service) *ProjectsRegionsService

+ type ProjectsRegionsWorkflowTemplatesCreateCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesCreateCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesCreateCall

+ func (c *ProjectsRegionsWorkflowTemplatesCreateCall) Do(opts ...googleapi.CallOption) (*WorkflowTemplate, error)

+ func (c *ProjectsRegionsWorkflowTemplatesCreateCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesCreateCall

+ func (c *ProjectsRegionsWorkflowTemplatesCreateCall) Header() http.Header

+ type ProjectsRegionsWorkflowTemplatesDeleteCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesDeleteCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesDeleteCall

+ func (c *ProjectsRegionsWorkflowTemplatesDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error)

+ func (c *ProjectsRegionsWorkflowTemplatesDeleteCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesDeleteCall

+ func (c *ProjectsRegionsWorkflowTemplatesDeleteCall) Header() http.Header

+ func (c *ProjectsRegionsWorkflowTemplatesDeleteCall) Version(version int64) *ProjectsRegionsWorkflowTemplatesDeleteCall

+ type ProjectsRegionsWorkflowTemplatesGetCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesGetCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesGetCall

+ func (c *ProjectsRegionsWorkflowTemplatesGetCall) Do(opts ...googleapi.CallOption) (*WorkflowTemplate, error)

+ func (c *ProjectsRegionsWorkflowTemplatesGetCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesGetCall

+ func (c *ProjectsRegionsWorkflowTemplatesGetCall) Header() http.Header

+ func (c *ProjectsRegionsWorkflowTemplatesGetCall) IfNoneMatch(entityTag string) *ProjectsRegionsWorkflowTemplatesGetCall

+ func (c *ProjectsRegionsWorkflowTemplatesGetCall) Version(version int64) *ProjectsRegionsWorkflowTemplatesGetCall

+ type ProjectsRegionsWorkflowTemplatesGetIamPolicyCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall

+ func (c *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall

+ func (c *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsWorkflowTemplatesInstantiateCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesInstantiateCall

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesInstantiateCall

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateCall) Header() http.Header

+ type ProjectsRegionsWorkflowTemplatesInstantiateInlineCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall) Do(opts ...googleapi.CallOption) (*Operation, error)

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall) Header() http.Header

+ func (c *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall) RequestId(requestId string) *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall

+ type ProjectsRegionsWorkflowTemplatesListCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesListCall

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) Do(opts ...googleapi.CallOption) (*ListWorkflowTemplatesResponse, error)

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesListCall

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) Header() http.Header

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) IfNoneMatch(entityTag string) *ProjectsRegionsWorkflowTemplatesListCall

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) PageSize(pageSize int64) *ProjectsRegionsWorkflowTemplatesListCall

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) PageToken(pageToken string) *ProjectsRegionsWorkflowTemplatesListCall

+ func (c *ProjectsRegionsWorkflowTemplatesListCall) Pages(ctx context.Context, f func(*ListWorkflowTemplatesResponse) error) error

+ type ProjectsRegionsWorkflowTemplatesService struct

+ func NewProjectsRegionsWorkflowTemplatesService(s *Service) *ProjectsRegionsWorkflowTemplatesService

+ func (r *ProjectsRegionsWorkflowTemplatesService) Create(parent string, workflowtemplate *WorkflowTemplate) *ProjectsRegionsWorkflowTemplatesCreateCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) Delete(name string) *ProjectsRegionsWorkflowTemplatesDeleteCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) Get(name string) *ProjectsRegionsWorkflowTemplatesGetCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) GetIamPolicy(resource string, getiampolicyrequest *GetIamPolicyRequest) *ProjectsRegionsWorkflowTemplatesGetIamPolicyCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) Instantiate(name string, ...) *ProjectsRegionsWorkflowTemplatesInstantiateCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) InstantiateInline(parent string, workflowtemplate *WorkflowTemplate) *ProjectsRegionsWorkflowTemplatesInstantiateInlineCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) List(parent string) *ProjectsRegionsWorkflowTemplatesListCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) SetIamPolicy(resource string, setiampolicyrequest *SetIamPolicyRequest) *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) TestIamPermissions(resource string, testiampermissionsrequest *TestIamPermissionsRequest) *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall

+ func (r *ProjectsRegionsWorkflowTemplatesService) Update(name string, workflowtemplate *WorkflowTemplate) *ProjectsRegionsWorkflowTemplatesUpdateCall

+ type ProjectsRegionsWorkflowTemplatesSetIamPolicyCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall

+ func (c *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall) Do(opts ...googleapi.CallOption) (*Policy, error)

+ func (c *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall

+ func (c *ProjectsRegionsWorkflowTemplatesSetIamPolicyCall) Header() http.Header

+ type ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall

+ func (c *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall) Do(opts ...googleapi.CallOption) (*TestIamPermissionsResponse, error)

+ func (c *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall

+ func (c *ProjectsRegionsWorkflowTemplatesTestIamPermissionsCall) Header() http.Header

+ type ProjectsRegionsWorkflowTemplatesUpdateCall struct

+ func (c *ProjectsRegionsWorkflowTemplatesUpdateCall) Context(ctx context.Context) *ProjectsRegionsWorkflowTemplatesUpdateCall

+ func (c *ProjectsRegionsWorkflowTemplatesUpdateCall) Do(opts ...googleapi.CallOption) (*WorkflowTemplate, error)

+ func (c *ProjectsRegionsWorkflowTemplatesUpdateCall) Fields(s ...googleapi.Field) *ProjectsRegionsWorkflowTemplatesUpdateCall

+ func (c *ProjectsRegionsWorkflowTemplatesUpdateCall) Header() http.Header

+ type ProjectsService struct

+ Locations *ProjectsLocationsService

+ Regions *ProjectsRegionsService

+ func NewProjectsService(s *Service) *ProjectsService

+ type PySparkJob struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ JarFileUris []string

+ LoggingConfig *LoggingConfig

+ MainPythonFileUri string

+ NullFields []string

+ Properties map[string]string

+ PythonFileUris []string

+ func (s *PySparkJob) MarshalJSON() ([]byte, error)

+ type QueryList struct

+ ForceSendFields []string

+ NullFields []string

+ Queries []string

+ func (s *QueryList) MarshalJSON() ([]byte, error)

+ type RegexValidation struct

+ ForceSendFields []string

+ NullFields []string

+ Regexes []string

+ func (s *RegexValidation) MarshalJSON() ([]byte, error)

+ type Service struct

+ BasePath string

+ Projects *ProjectsService

+ UserAgent string

+ func New(client *http.Client) (*Service, error)

+ type SetIamPolicyRequest struct

+ ForceSendFields []string

+ NullFields []string

+ Policy *Policy

+ func (s *SetIamPolicyRequest) MarshalJSON() ([]byte, error)

+ type SoftwareConfig struct

+ ForceSendFields []string

+ ImageVersion string

+ NullFields []string

+ Properties map[string]string

+ func (s *SoftwareConfig) MarshalJSON() ([]byte, error)

+ type SparkJob struct

+ ArchiveUris []string

+ Args []string

+ FileUris []string

+ ForceSendFields []string

+ JarFileUris []string

+ LoggingConfig *LoggingConfig

+ MainClass string

+ MainJarFileUri string

+ NullFields []string

+ Properties map[string]string

+ func (s *SparkJob) MarshalJSON() ([]byte, error)

+ type SparkSqlJob struct

+ ForceSendFields []string

+ JarFileUris []string

+ LoggingConfig *LoggingConfig

+ NullFields []string

+ Properties map[string]string

+ QueryFileUri string

+ QueryList *QueryList

+ ScriptVariables map[string]string

+ func (s *SparkSqlJob) MarshalJSON() ([]byte, error)

+ type Status struct

+ Code int64

+ Details []googleapi.RawMessage

+ ForceSendFields []string

+ Message string

+ NullFields []string

+ func (s *Status) MarshalJSON() ([]byte, error)

+ type SubmitJobRequest struct

+ ForceSendFields []string

+ Job *Job

+ NullFields []string

+ RequestId string

+ func (s *SubmitJobRequest) MarshalJSON() ([]byte, error)

+ type TemplateParameter struct

+ Description string

+ Fields []string

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ Validation *ParameterValidation

+ func (s *TemplateParameter) MarshalJSON() ([]byte, error)

+ type TestIamPermissionsRequest struct

+ ForceSendFields []string

+ NullFields []string

+ Permissions []string

+ func (s *TestIamPermissionsRequest) MarshalJSON() ([]byte, error)

+ type TestIamPermissionsResponse struct

+ ForceSendFields []string

+ NullFields []string

+ Permissions []string

+ func (s *TestIamPermissionsResponse) MarshalJSON() ([]byte, error)

+ type ValueValidation struct

+ ForceSendFields []string

+ NullFields []string

+ Values []string

+ func (s *ValueValidation) MarshalJSON() ([]byte, error)

+ type WorkflowGraph struct

+ ForceSendFields []string

+ Nodes []*WorkflowNode

+ NullFields []string

+ func (s *WorkflowGraph) MarshalJSON() ([]byte, error)

+ type WorkflowMetadata struct

+ ClusterName string

+ ClusterUuid string

+ CreateCluster *ClusterOperation

+ DeleteCluster *ClusterOperation

+ EndTime string

+ ForceSendFields []string

+ Graph *WorkflowGraph

+ NullFields []string

+ Parameters map[string]string

+ StartTime string

+ State string

+ Template string

+ Version int64

+ func (s *WorkflowMetadata) MarshalJSON() ([]byte, error)

+ type WorkflowNode struct

+ Error string

+ ForceSendFields []string

+ JobId string

+ NullFields []string

+ PrerequisiteStepIds []string

+ State string

+ StepId string

+ func (s *WorkflowNode) MarshalJSON() ([]byte, error)

+ type WorkflowTemplate struct

+ CreateTime string

+ ForceSendFields []string

+ Id string

+ Jobs []*OrderedJob

+ Labels map[string]string

+ Name string

+ NullFields []string

+ Parameters []*TemplateParameter

+ Placement *WorkflowTemplatePlacement

+ UpdateTime string

+ Version int64

+ func (s *WorkflowTemplate) MarshalJSON() ([]byte, error)

+ type WorkflowTemplatePlacement struct

+ ClusterSelector *ClusterSelector

+ ForceSendFields []string

+ ManagedCluster *ManagedCluster

+ NullFields []string

+ func (s *WorkflowTemplatePlacement) MarshalJSON() ([]byte, error)

+ type YarnApplication struct

+ ForceSendFields []string

+ Name string

+ NullFields []string

+ Progress float64

+ State string

+ TrackingUrl string

+ func (s *YarnApplication) MarshalJSON() ([]byte, error)

+ func (s *YarnApplication) UnmarshalJSON(data []byte) error