Versions in this module Expand all Collapse all v0 v0.25.2 May 21, 2020 Changes in this version + const CloudPlatformScope + const ComputeReadonlyScope + const ComputeScope + const UserinfoEmailScope + type ApproximateProgress struct + ForceSendFields []string + NullFields []string + PercentComplete float64 + Position *Position + RemainingTime string + func (s *ApproximateProgress) MarshalJSON() ([]byte, error) + func (s *ApproximateProgress) UnmarshalJSON(data []byte) error + type ApproximateReportedProgress struct + ConsumedParallelism *ReportedParallelism + ForceSendFields []string + FractionConsumed float64 + NullFields []string + Position *Position + RemainingParallelism *ReportedParallelism + func (s *ApproximateReportedProgress) MarshalJSON() ([]byte, error) + func (s *ApproximateReportedProgress) UnmarshalJSON(data []byte) error + type ApproximateSplitRequest struct + ForceSendFields []string + FractionConsumed float64 + FractionOfRemainder float64 + NullFields []string + Position *Position + func (s *ApproximateSplitRequest) MarshalJSON() ([]byte, error) + func (s *ApproximateSplitRequest) UnmarshalJSON(data []byte) error + type AutoscalingEvent struct + CurrentNumWorkers int64 + Description *StructuredMessage + EventType string + ForceSendFields []string + NullFields []string + TargetNumWorkers int64 + Time string + WorkerPool string + func (s *AutoscalingEvent) MarshalJSON() ([]byte, error) + type AutoscalingSettings struct + Algorithm string + ForceSendFields []string + MaxNumWorkers int64 + NullFields []string + func (s *AutoscalingSettings) MarshalJSON() ([]byte, error) + type BigQueryIODetails struct + Dataset string + ForceSendFields []string + NullFields []string + ProjectId string + Query string + Table string + func (s *BigQueryIODetails) MarshalJSON() ([]byte, error) + type BigTableIODetails struct + ForceSendFields []string + InstanceId string + NullFields []string + ProjectId string + TableId string + func (s *BigTableIODetails) MarshalJSON() ([]byte, error) + type CPUTime struct + ForceSendFields []string + NullFields []string + Rate float64 + Timestamp string + TotalMs uint64 + func (s *CPUTime) MarshalJSON() ([]byte, error) + func (s *CPUTime) UnmarshalJSON(data []byte) error + type ComponentSource struct + ForceSendFields []string + Name string + NullFields []string + OriginalTransformOrCollection string + UserName string + func (s *ComponentSource) MarshalJSON() ([]byte, error) + type ComponentTransform struct + ForceSendFields []string + Name string + NullFields []string + OriginalTransform string + UserName string + func (s *ComponentTransform) MarshalJSON() ([]byte, error) + type ComputationTopology struct + ComputationId string + ForceSendFields []string + Inputs []*StreamLocation + KeyRanges []*KeyRangeLocation + NullFields []string + Outputs []*StreamLocation + StateFamilies []*StateFamilyConfig + SystemStageName string + func (s *ComputationTopology) MarshalJSON() ([]byte, error) + type ConcatPosition struct + ForceSendFields []string + Index int64 + NullFields []string + Position *Position + func (s *ConcatPosition) MarshalJSON() ([]byte, error) + type ContainerSpec struct + ForceSendFields []string + Image string + Metadata *TemplateMetadata + NullFields []string + SdkInfo *SDKInfo + func (s *ContainerSpec) MarshalJSON() ([]byte, error) + type CounterMetadata struct + Description string + ForceSendFields []string + Kind string + NullFields []string + OtherUnits string + StandardUnits string + func (s *CounterMetadata) MarshalJSON() ([]byte, error) + type CounterStructuredName struct + ComponentStepName string + ExecutionStepName string + ForceSendFields []string + InputIndex int64 + Name string + NullFields []string + Origin string + OriginNamespace string + OriginalRequestingStepName string + OriginalStepName string + Portion string + WorkerId string + func (s *CounterStructuredName) MarshalJSON() ([]byte, error) + type CounterStructuredNameAndMetadata struct + ForceSendFields []string + Metadata *CounterMetadata + Name *CounterStructuredName + NullFields []string + func (s *CounterStructuredNameAndMetadata) MarshalJSON() ([]byte, error) + type CounterUpdate struct + Boolean bool + Cumulative bool + Distribution *DistributionUpdate + FloatingPoint float64 + FloatingPointList *FloatingPointList + FloatingPointMean *FloatingPointMean + ForceSendFields []string + Integer *SplitInt64 + IntegerGauge *IntegerGauge + IntegerList *IntegerList + IntegerMean *IntegerMean + Internal interface{} + NameAndKind *NameAndKind + NullFields []string + ShortId int64 + StringList *StringList + StructuredNameAndMetadata *CounterStructuredNameAndMetadata + func (s *CounterUpdate) MarshalJSON() ([]byte, error) + func (s *CounterUpdate) UnmarshalJSON(data []byte) error + type CreateJobFromTemplateRequest struct + Environment *RuntimeEnvironment + ForceSendFields []string + GcsPath string + JobName string + Location string + NullFields []string + Parameters map[string]string + func (s *CreateJobFromTemplateRequest) MarshalJSON() ([]byte, error) + type CustomSourceLocation struct + ForceSendFields []string + NullFields []string + Stateful bool + func (s *CustomSourceLocation) MarshalJSON() ([]byte, error) + type DataDiskAssignment struct + DataDisks []string + ForceSendFields []string + NullFields []string + VmInstance string + func (s *DataDiskAssignment) MarshalJSON() ([]byte, error) + type DatastoreIODetails struct + ForceSendFields []string + Namespace string + NullFields []string + ProjectId string + func (s *DatastoreIODetails) MarshalJSON() ([]byte, error) + type DeleteSnapshotResponse struct + type DerivedSource struct + DerivationMode string + ForceSendFields []string + NullFields []string + Source *Source + func (s *DerivedSource) MarshalJSON() ([]byte, error) + type Disk struct + DiskType string + ForceSendFields []string + MountPoint string + NullFields []string + SizeGb int64 + func (s *Disk) MarshalJSON() ([]byte, error) + type DisplayData struct + BoolValue bool + DurationValue string + FloatValue float64 + ForceSendFields []string + Int64Value int64 + JavaClassValue string + Key string + Label string + Namespace string + NullFields []string + ShortStrValue string + StrValue string + TimestampValue string + Url string + func (s *DisplayData) MarshalJSON() ([]byte, error) + func (s *DisplayData) UnmarshalJSON(data []byte) error + type DistributionUpdate struct + Count *SplitInt64 + ForceSendFields []string + Histogram *Histogram + Max *SplitInt64 + Min *SplitInt64 + NullFields []string + Sum *SplitInt64 + SumOfSquares float64 + func (s *DistributionUpdate) MarshalJSON() ([]byte, error) + func (s *DistributionUpdate) UnmarshalJSON(data []byte) error + type DynamicSourceSplit struct + ForceSendFields []string + NullFields []string + Primary *DerivedSource + Residual *DerivedSource + func (s *DynamicSourceSplit) MarshalJSON() ([]byte, error) + type Environment struct + ClusterManagerApiService string + Dataset string + Experiments []string + FlexResourceSchedulingGoal string + ForceSendFields []string + InternalExperiments googleapi.RawMessage + NullFields []string + SdkPipelineOptions googleapi.RawMessage + ServiceAccountEmail string + ServiceKmsKeyName string + TempStoragePrefix string + UserAgent googleapi.RawMessage + Version googleapi.RawMessage + WorkerPools []*WorkerPool + WorkerRegion string + WorkerZone string + func (s *Environment) MarshalJSON() ([]byte, error) + type ExecutionStageState struct + CurrentStateTime string + ExecutionStageName string + ExecutionStageState string + ForceSendFields []string + NullFields []string + func (s *ExecutionStageState) MarshalJSON() ([]byte, error) + type ExecutionStageSummary struct + ComponentSource []*ComponentSource + ComponentTransform []*ComponentTransform + ForceSendFields []string + Id string + InputSource []*StageSource + Kind string + Name string + NullFields []string + OutputSource []*StageSource + func (s *ExecutionStageSummary) MarshalJSON() ([]byte, error) + type FailedLocation struct + ForceSendFields []string + Name string + NullFields []string + func (s *FailedLocation) MarshalJSON() ([]byte, error) + type FileIODetails struct + FilePattern string + ForceSendFields []string + NullFields []string + func (s *FileIODetails) MarshalJSON() ([]byte, error) + type FlattenInstruction struct + ForceSendFields []string + Inputs []*InstructionInput + NullFields []string + func (s *FlattenInstruction) MarshalJSON() ([]byte, error) + type FloatingPointList struct + Elements []float64 + ForceSendFields []string + NullFields []string + func (s *FloatingPointList) MarshalJSON() ([]byte, error) + type FloatingPointMean struct + Count *SplitInt64 + ForceSendFields []string + NullFields []string + Sum float64 + func (s *FloatingPointMean) MarshalJSON() ([]byte, error) + func (s *FloatingPointMean) UnmarshalJSON(data []byte) error + type GetDebugConfigRequest struct + ComponentId string + ForceSendFields []string + Location string + NullFields []string + WorkerId string + func (s *GetDebugConfigRequest) MarshalJSON() ([]byte, error) + type GetDebugConfigResponse struct + Config string + ForceSendFields []string + NullFields []string + func (s *GetDebugConfigResponse) MarshalJSON() ([]byte, error) + type GetTemplateResponse struct + ForceSendFields []string + Metadata *TemplateMetadata + NullFields []string + RuntimeMetadata *RuntimeMetadata + Status *Status + TemplateType string + func (s *GetTemplateResponse) MarshalJSON() ([]byte, error) + type Histogram struct + BucketCounts googleapi.Int64s + FirstBucketOffset int64 + ForceSendFields []string + NullFields []string + func (s *Histogram) MarshalJSON() ([]byte, error) + type HotKeyDetection struct + ForceSendFields []string + HotKeyAge string + NullFields []string + SystemName string + UserStepName string + func (s *HotKeyDetection) MarshalJSON() ([]byte, error) + type InstructionInput struct + ForceSendFields []string + NullFields []string + OutputNum int64 + ProducerInstructionIndex int64 + func (s *InstructionInput) MarshalJSON() ([]byte, error) + type InstructionOutput struct + Codec googleapi.RawMessage + ForceSendFields []string + Name string + NullFields []string + OnlyCountKeyBytes bool + OnlyCountValueBytes bool + OriginalName string + SystemName string + func (s *InstructionOutput) MarshalJSON() ([]byte, error) + type IntegerGauge struct + ForceSendFields []string + NullFields []string + Timestamp string + Value *SplitInt64 + func (s *IntegerGauge) MarshalJSON() ([]byte, error) + type IntegerList struct + Elements []*SplitInt64 + ForceSendFields []string + NullFields []string + func (s *IntegerList) MarshalJSON() ([]byte, error) + type IntegerMean struct + Count *SplitInt64 + ForceSendFields []string + NullFields []string + Sum *SplitInt64 + func (s *IntegerMean) MarshalJSON() ([]byte, error) + type Job struct + ClientRequestId string + CreateTime string + CreatedFromSnapshotId string + CurrentState string + CurrentStateTime string + Environment *Environment + ExecutionInfo *JobExecutionInfo + ForceSendFields []string + Id string + JobMetadata *JobMetadata + Labels map[string]string + Location string + Name string + NullFields []string + PipelineDescription *PipelineDescription + ProjectId string + ReplaceJobId string + ReplacedByJobId string + RequestedState string + StageStates []*ExecutionStageState + StartTime string + Steps []*Step + StepsLocation string + TempFiles []string + TransformNameMapping map[string]string + Type string + func (s *Job) MarshalJSON() ([]byte, error) + type JobExecutionInfo struct + ForceSendFields []string + NullFields []string + Stages map[string]JobExecutionStageInfo + func (s *JobExecutionInfo) MarshalJSON() ([]byte, error) + type JobExecutionStageInfo struct + ForceSendFields []string + NullFields []string + StepName []string + func (s *JobExecutionStageInfo) MarshalJSON() ([]byte, error) + type JobMessage struct + ForceSendFields []string + Id string + MessageImportance string + MessageText string + NullFields []string + Time string + func (s *JobMessage) MarshalJSON() ([]byte, error) + type JobMetadata struct + BigTableDetails []*BigTableIODetails + BigqueryDetails []*BigQueryIODetails + DatastoreDetails []*DatastoreIODetails + FileDetails []*FileIODetails + ForceSendFields []string + NullFields []string + PubsubDetails []*PubSubIODetails + SdkVersion *SdkVersion + SpannerDetails []*SpannerIODetails + func (s *JobMetadata) MarshalJSON() ([]byte, error) + type JobMetrics struct + ForceSendFields []string + MetricTime string + Metrics []*MetricUpdate + NullFields []string + func (s *JobMetrics) MarshalJSON() ([]byte, error) + type KeyRangeDataDiskAssignment struct + DataDisk string + End string + ForceSendFields []string + NullFields []string + Start string + func (s *KeyRangeDataDiskAssignment) MarshalJSON() ([]byte, error) + type KeyRangeLocation struct + DataDisk string + DeliveryEndpoint string + DeprecatedPersistentDirectory string + End string + ForceSendFields []string + NullFields []string + Start string + func (s *KeyRangeLocation) MarshalJSON() ([]byte, error) + type LaunchFlexTemplateParameter struct + ContainerSpec *ContainerSpec + ContainerSpecGcsPath string + ForceSendFields []string + JobName string + NullFields []string + Parameters map[string]string + func (s *LaunchFlexTemplateParameter) MarshalJSON() ([]byte, error) + type LaunchFlexTemplateRequest struct + ForceSendFields []string + LaunchParameter *LaunchFlexTemplateParameter + NullFields []string + ValidateOnly bool + func (s *LaunchFlexTemplateRequest) MarshalJSON() ([]byte, error) + type LaunchFlexTemplateResponse struct + ForceSendFields []string + Job *Job + NullFields []string + func (s *LaunchFlexTemplateResponse) MarshalJSON() ([]byte, error) + type LaunchTemplateParameters struct + Environment *RuntimeEnvironment + ForceSendFields []string + JobName string + NullFields []string + Parameters map[string]string + TransformNameMapping map[string]string + Update bool + func (s *LaunchTemplateParameters) MarshalJSON() ([]byte, error) + type LaunchTemplateResponse struct + ForceSendFields []string + Job *Job + NullFields []string + func (s *LaunchTemplateResponse) MarshalJSON() ([]byte, error) + type LeaseWorkItemRequest struct + CurrentWorkerTime string + ForceSendFields []string + Location string + NullFields []string + RequestedLeaseDuration string + UnifiedWorkerRequest googleapi.RawMessage + WorkItemTypes []string + WorkerCapabilities []string + WorkerId string + func (s *LeaseWorkItemRequest) MarshalJSON() ([]byte, error) + type LeaseWorkItemResponse struct + ForceSendFields []string + NullFields []string + UnifiedWorkerResponse googleapi.RawMessage + WorkItems []*WorkItem + func (s *LeaseWorkItemResponse) MarshalJSON() ([]byte, error) + type ListJobMessagesResponse struct + AutoscalingEvents []*AutoscalingEvent + ForceSendFields []string + JobMessages []*JobMessage + NextPageToken string + NullFields []string + func (s *ListJobMessagesResponse) MarshalJSON() ([]byte, error) + type ListJobsResponse struct + FailedLocation []*FailedLocation + ForceSendFields []string + Jobs []*Job + NextPageToken string + NullFields []string + func (s *ListJobsResponse) MarshalJSON() ([]byte, error) + type ListSnapshotsResponse struct + ForceSendFields []string + NullFields []string + Snapshots []*Snapshot + func (s *ListSnapshotsResponse) MarshalJSON() ([]byte, error) + type MapTask struct + CounterPrefix string + ForceSendFields []string + Instructions []*ParallelInstruction + NullFields []string + StageName string + SystemName string + func (s *MapTask) MarshalJSON() ([]byte, error) + type MemInfo struct + CurrentLimitBytes uint64 + CurrentRssBytes uint64 + ForceSendFields []string + NullFields []string + Timestamp string + TotalGbMs uint64 + func (s *MemInfo) MarshalJSON() ([]byte, error) + type MetricShortId struct + ForceSendFields []string + MetricIndex int64 + NullFields []string + ShortId int64 + func (s *MetricShortId) MarshalJSON() ([]byte, error) + type MetricStructuredName struct + Context map[string]string + ForceSendFields []string + Name string + NullFields []string + Origin string + func (s *MetricStructuredName) MarshalJSON() ([]byte, error) + type MetricUpdate struct + Cumulative bool + Distribution interface{} + ForceSendFields []string + Gauge interface{} + Internal interface{} + Kind string + MeanCount interface{} + MeanSum interface{} + Name *MetricStructuredName + NullFields []string + Scalar interface{} + Set interface{} + UpdateTime string + func (s *MetricUpdate) MarshalJSON() ([]byte, error) + type MountedDataDisk struct + DataDisk string + ForceSendFields []string + NullFields []string + func (s *MountedDataDisk) MarshalJSON() ([]byte, error) + type MultiOutputInfo struct + ForceSendFields []string + NullFields []string + Tag string + func (s *MultiOutputInfo) MarshalJSON() ([]byte, error) + type NameAndKind struct + ForceSendFields []string + Kind string + Name string + NullFields []string + func (s *NameAndKind) MarshalJSON() ([]byte, error) + type Package struct + ForceSendFields []string + Location string + Name string + NullFields []string + func (s *Package) MarshalJSON() ([]byte, error) + type ParDoInstruction struct + ForceSendFields []string + Input *InstructionInput + MultiOutputInfos []*MultiOutputInfo + NullFields []string + NumOutputs int64 + SideInputs []*SideInputInfo + UserFn googleapi.RawMessage + func (s *ParDoInstruction) MarshalJSON() ([]byte, error) + type ParallelInstruction struct + Flatten *FlattenInstruction + ForceSendFields []string + Name string + NullFields []string + OriginalName string + Outputs []*InstructionOutput + ParDo *ParDoInstruction + PartialGroupByKey *PartialGroupByKeyInstruction + Read *ReadInstruction + SystemName string + Write *WriteInstruction + func (s *ParallelInstruction) MarshalJSON() ([]byte, error) + type Parameter struct + ForceSendFields []string + Key string + NullFields []string + Value interface{} + func (s *Parameter) MarshalJSON() ([]byte, error) + type ParameterMetadata struct + ForceSendFields []string + HelpText string + IsOptional bool + Label string + Name string + NullFields []string + ParamType string + Regexes []string + func (s *ParameterMetadata) MarshalJSON() ([]byte, error) + type PartialGroupByKeyInstruction struct + ForceSendFields []string + Input *InstructionInput + InputElementCodec googleapi.RawMessage + NullFields []string + OriginalCombineValuesInputStoreName string + OriginalCombineValuesStepName string + SideInputs []*SideInputInfo + ValueCombiningFn googleapi.RawMessage + func (s *PartialGroupByKeyInstruction) MarshalJSON() ([]byte, error) + type PipelineDescription struct + DisplayData []*DisplayData + ExecutionPipelineStage []*ExecutionStageSummary + ForceSendFields []string + NullFields []string + OriginalPipelineTransform []*TransformSummary + func (s *PipelineDescription) MarshalJSON() ([]byte, error) + type Position struct + ByteOffset int64 + ConcatPosition *ConcatPosition + End bool + ForceSendFields []string + Key string + NullFields []string + RecordIndex int64 + ShufflePosition string + func (s *Position) MarshalJSON() ([]byte, error) + type ProjectsDeleteSnapshotsCall struct + func (c *ProjectsDeleteSnapshotsCall) Context(ctx context.Context) *ProjectsDeleteSnapshotsCall + func (c *ProjectsDeleteSnapshotsCall) Do(opts ...googleapi.CallOption) (*DeleteSnapshotResponse, error) + func (c *ProjectsDeleteSnapshotsCall) Fields(s ...googleapi.Field) *ProjectsDeleteSnapshotsCall + func (c *ProjectsDeleteSnapshotsCall) Header() http.Header + func (c *ProjectsDeleteSnapshotsCall) Location(location string) *ProjectsDeleteSnapshotsCall + func (c *ProjectsDeleteSnapshotsCall) SnapshotId(snapshotId string) *ProjectsDeleteSnapshotsCall + type ProjectsJobsAggregatedCall struct + func (c *ProjectsJobsAggregatedCall) Context(ctx context.Context) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) Do(opts ...googleapi.CallOption) (*ListJobsResponse, error) + func (c *ProjectsJobsAggregatedCall) Fields(s ...googleapi.Field) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) Filter(filter string) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) Header() http.Header + func (c *ProjectsJobsAggregatedCall) IfNoneMatch(entityTag string) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) Location(location string) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) PageSize(pageSize int64) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) PageToken(pageToken string) *ProjectsJobsAggregatedCall + func (c *ProjectsJobsAggregatedCall) Pages(ctx context.Context, f func(*ListJobsResponse) error) error + func (c *ProjectsJobsAggregatedCall) View(view string) *ProjectsJobsAggregatedCall + type ProjectsJobsCreateCall struct + func (c *ProjectsJobsCreateCall) Context(ctx context.Context) *ProjectsJobsCreateCall + func (c *ProjectsJobsCreateCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsJobsCreateCall) Fields(s ...googleapi.Field) *ProjectsJobsCreateCall + func (c *ProjectsJobsCreateCall) Header() http.Header + func (c *ProjectsJobsCreateCall) Location(location string) *ProjectsJobsCreateCall + func (c *ProjectsJobsCreateCall) ReplaceJobId(replaceJobId string) *ProjectsJobsCreateCall + func (c *ProjectsJobsCreateCall) View(view string) *ProjectsJobsCreateCall + type ProjectsJobsDebugGetConfigCall struct + func (c *ProjectsJobsDebugGetConfigCall) Context(ctx context.Context) *ProjectsJobsDebugGetConfigCall + func (c *ProjectsJobsDebugGetConfigCall) Do(opts ...googleapi.CallOption) (*GetDebugConfigResponse, error) + func (c *ProjectsJobsDebugGetConfigCall) Fields(s ...googleapi.Field) *ProjectsJobsDebugGetConfigCall + func (c *ProjectsJobsDebugGetConfigCall) Header() http.Header + type ProjectsJobsDebugSendCaptureCall struct + func (c *ProjectsJobsDebugSendCaptureCall) Context(ctx context.Context) *ProjectsJobsDebugSendCaptureCall + func (c *ProjectsJobsDebugSendCaptureCall) Do(opts ...googleapi.CallOption) (*SendDebugCaptureResponse, error) + func (c *ProjectsJobsDebugSendCaptureCall) Fields(s ...googleapi.Field) *ProjectsJobsDebugSendCaptureCall + func (c *ProjectsJobsDebugSendCaptureCall) Header() http.Header + type ProjectsJobsDebugService struct + func NewProjectsJobsDebugService(s *Service) *ProjectsJobsDebugService + func (r *ProjectsJobsDebugService) GetConfig(projectId string, jobId string, getdebugconfigrequest *GetDebugConfigRequest) *ProjectsJobsDebugGetConfigCall + func (r *ProjectsJobsDebugService) SendCapture(projectId string, jobId string, ...) *ProjectsJobsDebugSendCaptureCall + type ProjectsJobsGetCall struct + func (c *ProjectsJobsGetCall) Context(ctx context.Context) *ProjectsJobsGetCall + func (c *ProjectsJobsGetCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsJobsGetCall) Fields(s ...googleapi.Field) *ProjectsJobsGetCall + func (c *ProjectsJobsGetCall) Header() http.Header + func (c *ProjectsJobsGetCall) IfNoneMatch(entityTag string) *ProjectsJobsGetCall + func (c *ProjectsJobsGetCall) Location(location string) *ProjectsJobsGetCall + func (c *ProjectsJobsGetCall) View(view string) *ProjectsJobsGetCall + type ProjectsJobsGetMetricsCall struct + func (c *ProjectsJobsGetMetricsCall) Context(ctx context.Context) *ProjectsJobsGetMetricsCall + func (c *ProjectsJobsGetMetricsCall) Do(opts ...googleapi.CallOption) (*JobMetrics, error) + func (c *ProjectsJobsGetMetricsCall) Fields(s ...googleapi.Field) *ProjectsJobsGetMetricsCall + func (c *ProjectsJobsGetMetricsCall) Header() http.Header + func (c *ProjectsJobsGetMetricsCall) IfNoneMatch(entityTag string) *ProjectsJobsGetMetricsCall + func (c *ProjectsJobsGetMetricsCall) Location(location string) *ProjectsJobsGetMetricsCall + func (c *ProjectsJobsGetMetricsCall) StartTime(startTime string) *ProjectsJobsGetMetricsCall + type ProjectsJobsListCall struct + func (c *ProjectsJobsListCall) Context(ctx context.Context) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) Do(opts ...googleapi.CallOption) (*ListJobsResponse, error) + func (c *ProjectsJobsListCall) Fields(s ...googleapi.Field) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) Filter(filter string) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) Header() http.Header + func (c *ProjectsJobsListCall) IfNoneMatch(entityTag string) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) Location(location string) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) PageSize(pageSize int64) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) PageToken(pageToken string) *ProjectsJobsListCall + func (c *ProjectsJobsListCall) Pages(ctx context.Context, f func(*ListJobsResponse) error) error + func (c *ProjectsJobsListCall) View(view string) *ProjectsJobsListCall + type ProjectsJobsMessagesListCall struct + func (c *ProjectsJobsMessagesListCall) Context(ctx context.Context) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) Do(opts ...googleapi.CallOption) (*ListJobMessagesResponse, error) + func (c *ProjectsJobsMessagesListCall) EndTime(endTime string) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) Fields(s ...googleapi.Field) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) Header() http.Header + func (c *ProjectsJobsMessagesListCall) IfNoneMatch(entityTag string) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) Location(location string) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) MinimumImportance(minimumImportance string) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) PageSize(pageSize int64) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) PageToken(pageToken string) *ProjectsJobsMessagesListCall + func (c *ProjectsJobsMessagesListCall) Pages(ctx context.Context, f func(*ListJobMessagesResponse) error) error + func (c *ProjectsJobsMessagesListCall) StartTime(startTime string) *ProjectsJobsMessagesListCall + type ProjectsJobsMessagesService struct + func NewProjectsJobsMessagesService(s *Service) *ProjectsJobsMessagesService + func (r *ProjectsJobsMessagesService) List(projectId string, jobId string) *ProjectsJobsMessagesListCall + type ProjectsJobsService struct + Debug *ProjectsJobsDebugService + Messages *ProjectsJobsMessagesService + WorkItems *ProjectsJobsWorkItemsService + func NewProjectsJobsService(s *Service) *ProjectsJobsService + func (r *ProjectsJobsService) Aggregated(projectId string) *ProjectsJobsAggregatedCall + func (r *ProjectsJobsService) Create(projectId string, job *Job) *ProjectsJobsCreateCall + func (r *ProjectsJobsService) Get(projectId string, jobId string) *ProjectsJobsGetCall + func (r *ProjectsJobsService) GetMetrics(projectId string, jobId string) *ProjectsJobsGetMetricsCall + func (r *ProjectsJobsService) List(projectId string) *ProjectsJobsListCall + func (r *ProjectsJobsService) Snapshot(projectId string, jobId string, snapshotjobrequest *SnapshotJobRequest) *ProjectsJobsSnapshotCall + func (r *ProjectsJobsService) Update(projectId string, jobId string, job *Job) *ProjectsJobsUpdateCall + type ProjectsJobsSnapshotCall struct + func (c *ProjectsJobsSnapshotCall) Context(ctx context.Context) *ProjectsJobsSnapshotCall + func (c *ProjectsJobsSnapshotCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsJobsSnapshotCall) Fields(s ...googleapi.Field) *ProjectsJobsSnapshotCall + func (c *ProjectsJobsSnapshotCall) Header() http.Header + type ProjectsJobsUpdateCall struct + func (c *ProjectsJobsUpdateCall) Context(ctx context.Context) *ProjectsJobsUpdateCall + func (c *ProjectsJobsUpdateCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsJobsUpdateCall) Fields(s ...googleapi.Field) *ProjectsJobsUpdateCall + func (c *ProjectsJobsUpdateCall) Header() http.Header + func (c *ProjectsJobsUpdateCall) Location(location string) *ProjectsJobsUpdateCall + type ProjectsJobsWorkItemsLeaseCall struct + func (c *ProjectsJobsWorkItemsLeaseCall) Context(ctx context.Context) *ProjectsJobsWorkItemsLeaseCall + func (c *ProjectsJobsWorkItemsLeaseCall) Do(opts ...googleapi.CallOption) (*LeaseWorkItemResponse, error) + func (c *ProjectsJobsWorkItemsLeaseCall) Fields(s ...googleapi.Field) *ProjectsJobsWorkItemsLeaseCall + func (c *ProjectsJobsWorkItemsLeaseCall) Header() http.Header + type ProjectsJobsWorkItemsReportStatusCall struct + func (c *ProjectsJobsWorkItemsReportStatusCall) Context(ctx context.Context) *ProjectsJobsWorkItemsReportStatusCall + func (c *ProjectsJobsWorkItemsReportStatusCall) Do(opts ...googleapi.CallOption) (*ReportWorkItemStatusResponse, error) + func (c *ProjectsJobsWorkItemsReportStatusCall) Fields(s ...googleapi.Field) *ProjectsJobsWorkItemsReportStatusCall + func (c *ProjectsJobsWorkItemsReportStatusCall) Header() http.Header + type ProjectsJobsWorkItemsService struct + func NewProjectsJobsWorkItemsService(s *Service) *ProjectsJobsWorkItemsService + func (r *ProjectsJobsWorkItemsService) Lease(projectId string, jobId string, leaseworkitemrequest *LeaseWorkItemRequest) *ProjectsJobsWorkItemsLeaseCall + func (r *ProjectsJobsWorkItemsService) ReportStatus(projectId string, jobId string, ...) *ProjectsJobsWorkItemsReportStatusCall + type ProjectsLocationsFlexTemplatesLaunchCall struct + func (c *ProjectsLocationsFlexTemplatesLaunchCall) Context(ctx context.Context) *ProjectsLocationsFlexTemplatesLaunchCall + func (c *ProjectsLocationsFlexTemplatesLaunchCall) Do(opts ...googleapi.CallOption) (*LaunchFlexTemplateResponse, error) + func (c *ProjectsLocationsFlexTemplatesLaunchCall) Fields(s ...googleapi.Field) *ProjectsLocationsFlexTemplatesLaunchCall + func (c *ProjectsLocationsFlexTemplatesLaunchCall) Header() http.Header + type ProjectsLocationsFlexTemplatesService struct + func NewProjectsLocationsFlexTemplatesService(s *Service) *ProjectsLocationsFlexTemplatesService + func (r *ProjectsLocationsFlexTemplatesService) Launch(projectId string, location string, ...) *ProjectsLocationsFlexTemplatesLaunchCall + type ProjectsLocationsJobsCreateCall struct + func (c *ProjectsLocationsJobsCreateCall) Context(ctx context.Context) *ProjectsLocationsJobsCreateCall + func (c *ProjectsLocationsJobsCreateCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsLocationsJobsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsCreateCall + func (c *ProjectsLocationsJobsCreateCall) Header() http.Header + func (c *ProjectsLocationsJobsCreateCall) ReplaceJobId(replaceJobId string) *ProjectsLocationsJobsCreateCall + func (c *ProjectsLocationsJobsCreateCall) View(view string) *ProjectsLocationsJobsCreateCall + type ProjectsLocationsJobsDebugGetConfigCall struct + func (c *ProjectsLocationsJobsDebugGetConfigCall) Context(ctx context.Context) *ProjectsLocationsJobsDebugGetConfigCall + func (c *ProjectsLocationsJobsDebugGetConfigCall) Do(opts ...googleapi.CallOption) (*GetDebugConfigResponse, error) + func (c *ProjectsLocationsJobsDebugGetConfigCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsDebugGetConfigCall + func (c *ProjectsLocationsJobsDebugGetConfigCall) Header() http.Header + type ProjectsLocationsJobsDebugSendCaptureCall struct + func (c *ProjectsLocationsJobsDebugSendCaptureCall) Context(ctx context.Context) *ProjectsLocationsJobsDebugSendCaptureCall + func (c *ProjectsLocationsJobsDebugSendCaptureCall) Do(opts ...googleapi.CallOption) (*SendDebugCaptureResponse, error) + func (c *ProjectsLocationsJobsDebugSendCaptureCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsDebugSendCaptureCall + func (c *ProjectsLocationsJobsDebugSendCaptureCall) Header() http.Header + type ProjectsLocationsJobsDebugService struct + func NewProjectsLocationsJobsDebugService(s *Service) *ProjectsLocationsJobsDebugService + func (r *ProjectsLocationsJobsDebugService) GetConfig(projectId string, location string, jobId string, ...) *ProjectsLocationsJobsDebugGetConfigCall + func (r *ProjectsLocationsJobsDebugService) SendCapture(projectId string, location string, jobId string, ...) *ProjectsLocationsJobsDebugSendCaptureCall + type ProjectsLocationsJobsGetCall struct + func (c *ProjectsLocationsJobsGetCall) Context(ctx context.Context) *ProjectsLocationsJobsGetCall + func (c *ProjectsLocationsJobsGetCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsLocationsJobsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsGetCall + func (c *ProjectsLocationsJobsGetCall) Header() http.Header + func (c *ProjectsLocationsJobsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsJobsGetCall + func (c *ProjectsLocationsJobsGetCall) View(view string) *ProjectsLocationsJobsGetCall + type ProjectsLocationsJobsGetMetricsCall struct + func (c *ProjectsLocationsJobsGetMetricsCall) Context(ctx context.Context) *ProjectsLocationsJobsGetMetricsCall + func (c *ProjectsLocationsJobsGetMetricsCall) Do(opts ...googleapi.CallOption) (*JobMetrics, error) + func (c *ProjectsLocationsJobsGetMetricsCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsGetMetricsCall + func (c *ProjectsLocationsJobsGetMetricsCall) Header() http.Header + func (c *ProjectsLocationsJobsGetMetricsCall) IfNoneMatch(entityTag string) *ProjectsLocationsJobsGetMetricsCall + func (c *ProjectsLocationsJobsGetMetricsCall) StartTime(startTime string) *ProjectsLocationsJobsGetMetricsCall + type ProjectsLocationsJobsListCall struct + func (c *ProjectsLocationsJobsListCall) Context(ctx context.Context) *ProjectsLocationsJobsListCall + func (c *ProjectsLocationsJobsListCall) Do(opts ...googleapi.CallOption) (*ListJobsResponse, error) + func (c *ProjectsLocationsJobsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsListCall + func (c *ProjectsLocationsJobsListCall) Filter(filter string) *ProjectsLocationsJobsListCall + func (c *ProjectsLocationsJobsListCall) Header() http.Header + func (c *ProjectsLocationsJobsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsJobsListCall + func (c *ProjectsLocationsJobsListCall) PageSize(pageSize int64) *ProjectsLocationsJobsListCall + func (c *ProjectsLocationsJobsListCall) PageToken(pageToken string) *ProjectsLocationsJobsListCall + func (c *ProjectsLocationsJobsListCall) Pages(ctx context.Context, f func(*ListJobsResponse) error) error + func (c *ProjectsLocationsJobsListCall) View(view string) *ProjectsLocationsJobsListCall + type ProjectsLocationsJobsMessagesListCall struct + func (c *ProjectsLocationsJobsMessagesListCall) Context(ctx context.Context) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) Do(opts ...googleapi.CallOption) (*ListJobMessagesResponse, error) + func (c *ProjectsLocationsJobsMessagesListCall) EndTime(endTime string) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) Header() http.Header + func (c *ProjectsLocationsJobsMessagesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) MinimumImportance(minimumImportance string) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) PageSize(pageSize int64) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) PageToken(pageToken string) *ProjectsLocationsJobsMessagesListCall + func (c *ProjectsLocationsJobsMessagesListCall) Pages(ctx context.Context, f func(*ListJobMessagesResponse) error) error + func (c *ProjectsLocationsJobsMessagesListCall) StartTime(startTime string) *ProjectsLocationsJobsMessagesListCall + type ProjectsLocationsJobsMessagesService struct + func NewProjectsLocationsJobsMessagesService(s *Service) *ProjectsLocationsJobsMessagesService + func (r *ProjectsLocationsJobsMessagesService) List(projectId string, location string, jobId string) *ProjectsLocationsJobsMessagesListCall + type ProjectsLocationsJobsService struct + Debug *ProjectsLocationsJobsDebugService + Messages *ProjectsLocationsJobsMessagesService + Snapshots *ProjectsLocationsJobsSnapshotsService + WorkItems *ProjectsLocationsJobsWorkItemsService + func NewProjectsLocationsJobsService(s *Service) *ProjectsLocationsJobsService + func (r *ProjectsLocationsJobsService) Create(projectId string, location string, job *Job) *ProjectsLocationsJobsCreateCall + func (r *ProjectsLocationsJobsService) Get(projectId string, location string, jobId string) *ProjectsLocationsJobsGetCall + func (r *ProjectsLocationsJobsService) GetMetrics(projectId string, location string, jobId string) *ProjectsLocationsJobsGetMetricsCall + func (r *ProjectsLocationsJobsService) List(projectId string, location string) *ProjectsLocationsJobsListCall + func (r *ProjectsLocationsJobsService) Snapshot(projectId string, location string, jobId string, ...) *ProjectsLocationsJobsSnapshotCall + func (r *ProjectsLocationsJobsService) Update(projectId string, location string, jobId string, job *Job) *ProjectsLocationsJobsUpdateCall + type ProjectsLocationsJobsSnapshotCall struct + func (c *ProjectsLocationsJobsSnapshotCall) Context(ctx context.Context) *ProjectsLocationsJobsSnapshotCall + func (c *ProjectsLocationsJobsSnapshotCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsLocationsJobsSnapshotCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsSnapshotCall + func (c *ProjectsLocationsJobsSnapshotCall) Header() http.Header + type ProjectsLocationsJobsSnapshotsListCall struct + func (c *ProjectsLocationsJobsSnapshotsListCall) Context(ctx context.Context) *ProjectsLocationsJobsSnapshotsListCall + func (c *ProjectsLocationsJobsSnapshotsListCall) Do(opts ...googleapi.CallOption) (*ListSnapshotsResponse, error) + func (c *ProjectsLocationsJobsSnapshotsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsSnapshotsListCall + func (c *ProjectsLocationsJobsSnapshotsListCall) Header() http.Header + func (c *ProjectsLocationsJobsSnapshotsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsJobsSnapshotsListCall + type ProjectsLocationsJobsSnapshotsService struct + func NewProjectsLocationsJobsSnapshotsService(s *Service) *ProjectsLocationsJobsSnapshotsService + func (r *ProjectsLocationsJobsSnapshotsService) List(projectId string, location string, jobId string) *ProjectsLocationsJobsSnapshotsListCall + type ProjectsLocationsJobsUpdateCall struct + func (c *ProjectsLocationsJobsUpdateCall) Context(ctx context.Context) *ProjectsLocationsJobsUpdateCall + func (c *ProjectsLocationsJobsUpdateCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsLocationsJobsUpdateCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsUpdateCall + func (c *ProjectsLocationsJobsUpdateCall) Header() http.Header + type ProjectsLocationsJobsWorkItemsLeaseCall struct + func (c *ProjectsLocationsJobsWorkItemsLeaseCall) Context(ctx context.Context) *ProjectsLocationsJobsWorkItemsLeaseCall + func (c *ProjectsLocationsJobsWorkItemsLeaseCall) Do(opts ...googleapi.CallOption) (*LeaseWorkItemResponse, error) + func (c *ProjectsLocationsJobsWorkItemsLeaseCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsWorkItemsLeaseCall + func (c *ProjectsLocationsJobsWorkItemsLeaseCall) Header() http.Header + type ProjectsLocationsJobsWorkItemsReportStatusCall struct + func (c *ProjectsLocationsJobsWorkItemsReportStatusCall) Context(ctx context.Context) *ProjectsLocationsJobsWorkItemsReportStatusCall + func (c *ProjectsLocationsJobsWorkItemsReportStatusCall) Do(opts ...googleapi.CallOption) (*ReportWorkItemStatusResponse, error) + func (c *ProjectsLocationsJobsWorkItemsReportStatusCall) Fields(s ...googleapi.Field) *ProjectsLocationsJobsWorkItemsReportStatusCall + func (c *ProjectsLocationsJobsWorkItemsReportStatusCall) Header() http.Header + type ProjectsLocationsJobsWorkItemsService struct + func NewProjectsLocationsJobsWorkItemsService(s *Service) *ProjectsLocationsJobsWorkItemsService + func (r *ProjectsLocationsJobsWorkItemsService) Lease(projectId string, location string, jobId string, ...) *ProjectsLocationsJobsWorkItemsLeaseCall + func (r *ProjectsLocationsJobsWorkItemsService) ReportStatus(projectId string, location string, jobId string, ...) *ProjectsLocationsJobsWorkItemsReportStatusCall + type ProjectsLocationsService struct + FlexTemplates *ProjectsLocationsFlexTemplatesService + Jobs *ProjectsLocationsJobsService + Snapshots *ProjectsLocationsSnapshotsService + Sql *ProjectsLocationsSqlService + Templates *ProjectsLocationsTemplatesService + func NewProjectsLocationsService(s *Service) *ProjectsLocationsService + func (r *ProjectsLocationsService) WorkerMessages(projectId string, location string, ...) *ProjectsLocationsWorkerMessagesCall + type ProjectsLocationsSnapshotsDeleteCall struct + func (c *ProjectsLocationsSnapshotsDeleteCall) Context(ctx context.Context) *ProjectsLocationsSnapshotsDeleteCall + func (c *ProjectsLocationsSnapshotsDeleteCall) Do(opts ...googleapi.CallOption) (*DeleteSnapshotResponse, error) + func (c *ProjectsLocationsSnapshotsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsSnapshotsDeleteCall + func (c *ProjectsLocationsSnapshotsDeleteCall) Header() http.Header + type ProjectsLocationsSnapshotsGetCall struct + func (c *ProjectsLocationsSnapshotsGetCall) Context(ctx context.Context) *ProjectsLocationsSnapshotsGetCall + func (c *ProjectsLocationsSnapshotsGetCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsLocationsSnapshotsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsSnapshotsGetCall + func (c *ProjectsLocationsSnapshotsGetCall) Header() http.Header + func (c *ProjectsLocationsSnapshotsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsSnapshotsGetCall + type ProjectsLocationsSnapshotsListCall struct + func (c *ProjectsLocationsSnapshotsListCall) Context(ctx context.Context) *ProjectsLocationsSnapshotsListCall + func (c *ProjectsLocationsSnapshotsListCall) Do(opts ...googleapi.CallOption) (*ListSnapshotsResponse, error) + func (c *ProjectsLocationsSnapshotsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsSnapshotsListCall + func (c *ProjectsLocationsSnapshotsListCall) Header() http.Header + func (c *ProjectsLocationsSnapshotsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsSnapshotsListCall + func (c *ProjectsLocationsSnapshotsListCall) JobId(jobId string) *ProjectsLocationsSnapshotsListCall + type ProjectsLocationsSnapshotsService struct + func NewProjectsLocationsSnapshotsService(s *Service) *ProjectsLocationsSnapshotsService + func (r *ProjectsLocationsSnapshotsService) Delete(projectId string, location string, snapshotId string) *ProjectsLocationsSnapshotsDeleteCall + func (r *ProjectsLocationsSnapshotsService) Get(projectId string, location string, snapshotId string) *ProjectsLocationsSnapshotsGetCall + func (r *ProjectsLocationsSnapshotsService) List(projectId string, location string) *ProjectsLocationsSnapshotsListCall + type ProjectsLocationsSqlService struct + func NewProjectsLocationsSqlService(s *Service) *ProjectsLocationsSqlService + func (r *ProjectsLocationsSqlService) Validate(projectId string, location string) *ProjectsLocationsSqlValidateCall + type ProjectsLocationsSqlValidateCall struct + func (c *ProjectsLocationsSqlValidateCall) Context(ctx context.Context) *ProjectsLocationsSqlValidateCall + func (c *ProjectsLocationsSqlValidateCall) Do(opts ...googleapi.CallOption) (*ValidateResponse, error) + func (c *ProjectsLocationsSqlValidateCall) Fields(s ...googleapi.Field) *ProjectsLocationsSqlValidateCall + func (c *ProjectsLocationsSqlValidateCall) Header() http.Header + func (c *ProjectsLocationsSqlValidateCall) IfNoneMatch(entityTag string) *ProjectsLocationsSqlValidateCall + func (c *ProjectsLocationsSqlValidateCall) Query(query string) *ProjectsLocationsSqlValidateCall + type ProjectsLocationsTemplatesCreateCall struct + func (c *ProjectsLocationsTemplatesCreateCall) Context(ctx context.Context) *ProjectsLocationsTemplatesCreateCall + func (c *ProjectsLocationsTemplatesCreateCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsLocationsTemplatesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsTemplatesCreateCall + func (c *ProjectsLocationsTemplatesCreateCall) Header() http.Header + type ProjectsLocationsTemplatesGetCall struct + func (c *ProjectsLocationsTemplatesGetCall) Context(ctx context.Context) *ProjectsLocationsTemplatesGetCall + func (c *ProjectsLocationsTemplatesGetCall) Do(opts ...googleapi.CallOption) (*GetTemplateResponse, error) + func (c *ProjectsLocationsTemplatesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsTemplatesGetCall + func (c *ProjectsLocationsTemplatesGetCall) GcsPath(gcsPath string) *ProjectsLocationsTemplatesGetCall + func (c *ProjectsLocationsTemplatesGetCall) Header() http.Header + func (c *ProjectsLocationsTemplatesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsTemplatesGetCall + func (c *ProjectsLocationsTemplatesGetCall) View(view string) *ProjectsLocationsTemplatesGetCall + type ProjectsLocationsTemplatesLaunchCall struct + func (c *ProjectsLocationsTemplatesLaunchCall) Context(ctx context.Context) *ProjectsLocationsTemplatesLaunchCall + func (c *ProjectsLocationsTemplatesLaunchCall) Do(opts ...googleapi.CallOption) (*LaunchTemplateResponse, error) + func (c *ProjectsLocationsTemplatesLaunchCall) DynamicTemplateGcsPath(dynamicTemplateGcsPath string) *ProjectsLocationsTemplatesLaunchCall + func (c *ProjectsLocationsTemplatesLaunchCall) DynamicTemplateStagingLocation(dynamicTemplateStagingLocation string) *ProjectsLocationsTemplatesLaunchCall + func (c *ProjectsLocationsTemplatesLaunchCall) Fields(s ...googleapi.Field) *ProjectsLocationsTemplatesLaunchCall + func (c *ProjectsLocationsTemplatesLaunchCall) GcsPath(gcsPath string) *ProjectsLocationsTemplatesLaunchCall + func (c *ProjectsLocationsTemplatesLaunchCall) Header() http.Header + func (c *ProjectsLocationsTemplatesLaunchCall) ValidateOnly(validateOnly bool) *ProjectsLocationsTemplatesLaunchCall + type ProjectsLocationsTemplatesService struct + func NewProjectsLocationsTemplatesService(s *Service) *ProjectsLocationsTemplatesService + func (r *ProjectsLocationsTemplatesService) Create(projectId string, location string, ...) *ProjectsLocationsTemplatesCreateCall + func (r *ProjectsLocationsTemplatesService) Get(projectId string, location string) *ProjectsLocationsTemplatesGetCall + func (r *ProjectsLocationsTemplatesService) Launch(projectId string, location string, ...) *ProjectsLocationsTemplatesLaunchCall + type ProjectsLocationsWorkerMessagesCall struct + func (c *ProjectsLocationsWorkerMessagesCall) Context(ctx context.Context) *ProjectsLocationsWorkerMessagesCall + func (c *ProjectsLocationsWorkerMessagesCall) Do(opts ...googleapi.CallOption) (*SendWorkerMessagesResponse, error) + func (c *ProjectsLocationsWorkerMessagesCall) Fields(s ...googleapi.Field) *ProjectsLocationsWorkerMessagesCall + func (c *ProjectsLocationsWorkerMessagesCall) Header() http.Header + type ProjectsService struct + Jobs *ProjectsJobsService + Locations *ProjectsLocationsService + Snapshots *ProjectsSnapshotsService + Templates *ProjectsTemplatesService + func NewProjectsService(s *Service) *ProjectsService + func (r *ProjectsService) DeleteSnapshots(projectId string) *ProjectsDeleteSnapshotsCall + func (r *ProjectsService) WorkerMessages(projectId string, sendworkermessagesrequest *SendWorkerMessagesRequest) *ProjectsWorkerMessagesCall + type ProjectsSnapshotsGetCall struct + func (c *ProjectsSnapshotsGetCall) Context(ctx context.Context) *ProjectsSnapshotsGetCall + func (c *ProjectsSnapshotsGetCall) Do(opts ...googleapi.CallOption) (*Snapshot, error) + func (c *ProjectsSnapshotsGetCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsGetCall + func (c *ProjectsSnapshotsGetCall) Header() http.Header + func (c *ProjectsSnapshotsGetCall) IfNoneMatch(entityTag string) *ProjectsSnapshotsGetCall + func (c *ProjectsSnapshotsGetCall) Location(location string) *ProjectsSnapshotsGetCall + type ProjectsSnapshotsListCall struct + func (c *ProjectsSnapshotsListCall) Context(ctx context.Context) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) Do(opts ...googleapi.CallOption) (*ListSnapshotsResponse, error) + func (c *ProjectsSnapshotsListCall) Fields(s ...googleapi.Field) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) Header() http.Header + func (c *ProjectsSnapshotsListCall) IfNoneMatch(entityTag string) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) JobId(jobId string) *ProjectsSnapshotsListCall + func (c *ProjectsSnapshotsListCall) Location(location string) *ProjectsSnapshotsListCall + type ProjectsSnapshotsService struct + func NewProjectsSnapshotsService(s *Service) *ProjectsSnapshotsService + func (r *ProjectsSnapshotsService) Get(projectId string, snapshotId string) *ProjectsSnapshotsGetCall + func (r *ProjectsSnapshotsService) List(projectId string) *ProjectsSnapshotsListCall + type ProjectsTemplatesCreateCall struct + func (c *ProjectsTemplatesCreateCall) Context(ctx context.Context) *ProjectsTemplatesCreateCall + func (c *ProjectsTemplatesCreateCall) Do(opts ...googleapi.CallOption) (*Job, error) + func (c *ProjectsTemplatesCreateCall) Fields(s ...googleapi.Field) *ProjectsTemplatesCreateCall + func (c *ProjectsTemplatesCreateCall) Header() http.Header + type ProjectsTemplatesGetCall struct + func (c *ProjectsTemplatesGetCall) Context(ctx context.Context) *ProjectsTemplatesGetCall + func (c *ProjectsTemplatesGetCall) Do(opts ...googleapi.CallOption) (*GetTemplateResponse, error) + func (c *ProjectsTemplatesGetCall) Fields(s ...googleapi.Field) *ProjectsTemplatesGetCall + func (c *ProjectsTemplatesGetCall) GcsPath(gcsPath string) *ProjectsTemplatesGetCall + func (c *ProjectsTemplatesGetCall) Header() http.Header + func (c *ProjectsTemplatesGetCall) IfNoneMatch(entityTag string) *ProjectsTemplatesGetCall + func (c *ProjectsTemplatesGetCall) Location(location string) *ProjectsTemplatesGetCall + func (c *ProjectsTemplatesGetCall) View(view string) *ProjectsTemplatesGetCall + type ProjectsTemplatesLaunchCall struct + func (c *ProjectsTemplatesLaunchCall) Context(ctx context.Context) *ProjectsTemplatesLaunchCall + func (c *ProjectsTemplatesLaunchCall) Do(opts ...googleapi.CallOption) (*LaunchTemplateResponse, error) + func (c *ProjectsTemplatesLaunchCall) DynamicTemplateGcsPath(dynamicTemplateGcsPath string) *ProjectsTemplatesLaunchCall + func (c *ProjectsTemplatesLaunchCall) DynamicTemplateStagingLocation(dynamicTemplateStagingLocation string) *ProjectsTemplatesLaunchCall + func (c *ProjectsTemplatesLaunchCall) Fields(s ...googleapi.Field) *ProjectsTemplatesLaunchCall + func (c *ProjectsTemplatesLaunchCall) GcsPath(gcsPath string) *ProjectsTemplatesLaunchCall + func (c *ProjectsTemplatesLaunchCall) Header() http.Header + func (c *ProjectsTemplatesLaunchCall) Location(location string) *ProjectsTemplatesLaunchCall + func (c *ProjectsTemplatesLaunchCall) ValidateOnly(validateOnly bool) *ProjectsTemplatesLaunchCall + type ProjectsTemplatesService struct + func NewProjectsTemplatesService(s *Service) *ProjectsTemplatesService + func (r *ProjectsTemplatesService) Create(projectId string, createjobfromtemplaterequest *CreateJobFromTemplateRequest) *ProjectsTemplatesCreateCall + func (r *ProjectsTemplatesService) Get(projectId string) *ProjectsTemplatesGetCall + func (r *ProjectsTemplatesService) Launch(projectId string, launchtemplateparameters *LaunchTemplateParameters) *ProjectsTemplatesLaunchCall + type ProjectsWorkerMessagesCall struct + func (c *ProjectsWorkerMessagesCall) Context(ctx context.Context) *ProjectsWorkerMessagesCall + func (c *ProjectsWorkerMessagesCall) Do(opts ...googleapi.CallOption) (*SendWorkerMessagesResponse, error) + func (c *ProjectsWorkerMessagesCall) Fields(s ...googleapi.Field) *ProjectsWorkerMessagesCall + func (c *ProjectsWorkerMessagesCall) Header() http.Header + type PubSubIODetails struct + ForceSendFields []string + NullFields []string + Subscription string + Topic string + func (s *PubSubIODetails) MarshalJSON() ([]byte, error) + type PubsubLocation struct + DropLateData bool + ForceSendFields []string + IdLabel string + NullFields []string + Subscription string + TimestampLabel string + Topic string + TrackingSubscription string + WithAttributes bool + func (s *PubsubLocation) MarshalJSON() ([]byte, error) + type PubsubSnapshotMetadata struct + ExpireTime string + ForceSendFields []string + NullFields []string + SnapshotName string + TopicName string + func (s *PubsubSnapshotMetadata) MarshalJSON() ([]byte, error) + type ReadInstruction struct + ForceSendFields []string + NullFields []string + Source *Source + func (s *ReadInstruction) MarshalJSON() ([]byte, error) + type ReportWorkItemStatusRequest struct + CurrentWorkerTime string + ForceSendFields []string + Location string + NullFields []string + UnifiedWorkerRequest googleapi.RawMessage + WorkItemStatuses []*WorkItemStatus + WorkerId string + func (s *ReportWorkItemStatusRequest) MarshalJSON() ([]byte, error) + type ReportWorkItemStatusResponse struct + ForceSendFields []string + NullFields []string + UnifiedWorkerResponse googleapi.RawMessage + WorkItemServiceStates []*WorkItemServiceState + func (s *ReportWorkItemStatusResponse) MarshalJSON() ([]byte, error) + type ReportedParallelism struct + ForceSendFields []string + IsInfinite bool + NullFields []string + Value float64 + func (s *ReportedParallelism) MarshalJSON() ([]byte, error) + func (s *ReportedParallelism) UnmarshalJSON(data []byte) error + type ResourceUtilizationReport struct + Containers map[string]ResourceUtilizationReport + CpuTime []*CPUTime + ForceSendFields []string + MemoryInfo []*MemInfo + NullFields []string + func (s *ResourceUtilizationReport) MarshalJSON() ([]byte, error) + type ResourceUtilizationReportResponse struct + type RuntimeEnvironment struct + AdditionalExperiments []string + AdditionalUserLabels map[string]string + BypassTempDirValidation bool + ForceSendFields []string + IpConfiguration string + KmsKeyName string + MachineType string + MaxWorkers int64 + Network string + NullFields []string + NumWorkers int64 + ServiceAccountEmail string + Subnetwork string + TempLocation string + WorkerRegion string + WorkerZone string + Zone string + func (s *RuntimeEnvironment) MarshalJSON() ([]byte, error) + type RuntimeMetadata struct + ForceSendFields []string + NullFields []string + Parameters []*ParameterMetadata + SdkInfo *SDKInfo + func (s *RuntimeMetadata) MarshalJSON() ([]byte, error) + type SDKInfo struct + ForceSendFields []string + Language string + NullFields []string + Version string + func (s *SDKInfo) MarshalJSON() ([]byte, error) + type SdkHarnessContainerImage struct + ContainerImage string + ForceSendFields []string + NullFields []string + UseSingleCorePerContainer bool + func (s *SdkHarnessContainerImage) MarshalJSON() ([]byte, error) + type SdkVersion struct + ForceSendFields []string + NullFields []string + SdkSupportStatus string + Version string + VersionDisplayName string + func (s *SdkVersion) MarshalJSON() ([]byte, error) + type SendDebugCaptureRequest struct + ComponentId string + Data string + ForceSendFields []string + Location string + NullFields []string + WorkerId string + func (s *SendDebugCaptureRequest) MarshalJSON() ([]byte, error) + type SendDebugCaptureResponse struct + type SendWorkerMessagesRequest struct + ForceSendFields []string + Location string + NullFields []string + WorkerMessages []*WorkerMessage + func (s *SendWorkerMessagesRequest) MarshalJSON() ([]byte, error) + type SendWorkerMessagesResponse struct + ForceSendFields []string + NullFields []string + WorkerMessageResponses []*WorkerMessageResponse + func (s *SendWorkerMessagesResponse) MarshalJSON() ([]byte, error) + type SeqMapTask struct + ForceSendFields []string + Inputs []*SideInputInfo + Name string + NullFields []string + OutputInfos []*SeqMapTaskOutputInfo + StageName string + SystemName string + UserFn googleapi.RawMessage + func (s *SeqMapTask) MarshalJSON() ([]byte, error) + type SeqMapTaskOutputInfo struct + ForceSendFields []string + NullFields []string + Sink *Sink + Tag string + func (s *SeqMapTaskOutputInfo) MarshalJSON() ([]byte, error) + type Service struct + BasePath string + Projects *ProjectsService + UserAgent string + func New(client *http.Client) (*Service, error) + func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) + type ShellTask struct + Command string + ExitCode int64 + ForceSendFields []string + NullFields []string + func (s *ShellTask) MarshalJSON() ([]byte, error) + type SideInputInfo struct + ForceSendFields []string + Kind googleapi.RawMessage + NullFields []string + Sources []*Source + Tag string + func (s *SideInputInfo) MarshalJSON() ([]byte, error) + type Sink struct + Codec googleapi.RawMessage + ForceSendFields []string + NullFields []string + Spec googleapi.RawMessage + func (s *Sink) MarshalJSON() ([]byte, error) + type Snapshot struct + CreationTime string + Description string + DiskSizeBytes int64 + ForceSendFields []string + Id string + NullFields []string + ProjectId string + PubsubMetadata []*PubsubSnapshotMetadata + SourceJobId string + State string + Ttl string + func (s *Snapshot) MarshalJSON() ([]byte, error) + type SnapshotJobRequest struct + Description string + ForceSendFields []string + Location string + NullFields []string + SnapshotSources bool + Ttl string + func (s *SnapshotJobRequest) MarshalJSON() ([]byte, error) + type Source struct + BaseSpecs []googleapi.RawMessage + Codec googleapi.RawMessage + DoesNotNeedSplitting bool + ForceSendFields []string + Metadata *SourceMetadata + NullFields []string + Spec googleapi.RawMessage + func (s *Source) MarshalJSON() ([]byte, error) + type SourceFork struct + ForceSendFields []string + NullFields []string + Primary *SourceSplitShard + PrimarySource *DerivedSource + Residual *SourceSplitShard + ResidualSource *DerivedSource + func (s *SourceFork) MarshalJSON() ([]byte, error) + type SourceGetMetadataRequest struct + ForceSendFields []string + NullFields []string + Source *Source + func (s *SourceGetMetadataRequest) MarshalJSON() ([]byte, error) + type SourceGetMetadataResponse struct + ForceSendFields []string + Metadata *SourceMetadata + NullFields []string + func (s *SourceGetMetadataResponse) MarshalJSON() ([]byte, error) + type SourceMetadata struct + EstimatedSizeBytes int64 + ForceSendFields []string + Infinite bool + NullFields []string + ProducesSortedKeys bool + func (s *SourceMetadata) MarshalJSON() ([]byte, error) + type SourceOperationRequest struct + ForceSendFields []string + GetMetadata *SourceGetMetadataRequest + Name string + NullFields []string + OriginalName string + Split *SourceSplitRequest + StageName string + SystemName string + func (s *SourceOperationRequest) MarshalJSON() ([]byte, error) + type SourceOperationResponse struct + ForceSendFields []string + GetMetadata *SourceGetMetadataResponse + NullFields []string + Split *SourceSplitResponse + func (s *SourceOperationResponse) MarshalJSON() ([]byte, error) + type SourceSplitOptions struct + DesiredBundleSizeBytes int64 + DesiredShardSizeBytes int64 + ForceSendFields []string + NullFields []string + func (s *SourceSplitOptions) MarshalJSON() ([]byte, error) + type SourceSplitRequest struct + ForceSendFields []string + NullFields []string + Options *SourceSplitOptions + Source *Source + func (s *SourceSplitRequest) MarshalJSON() ([]byte, error) + type SourceSplitResponse struct + Bundles []*DerivedSource + ForceSendFields []string + NullFields []string + Outcome string + Shards []*SourceSplitShard + func (s *SourceSplitResponse) MarshalJSON() ([]byte, error) + type SourceSplitShard struct + DerivationMode string + ForceSendFields []string + NullFields []string + Source *Source + func (s *SourceSplitShard) MarshalJSON() ([]byte, error) + type SpannerIODetails struct + DatabaseId string + ForceSendFields []string + InstanceId string + NullFields []string + ProjectId string + func (s *SpannerIODetails) MarshalJSON() ([]byte, error) + type SplitInt64 struct + ForceSendFields []string + HighBits int64 + LowBits int64 + NullFields []string + func (s *SplitInt64) MarshalJSON() ([]byte, error) + type StageSource struct + ForceSendFields []string + Name string + NullFields []string + OriginalTransformOrCollection string + SizeBytes int64 + UserName string + func (s *StageSource) MarshalJSON() ([]byte, error) + type StateFamilyConfig struct + ForceSendFields []string + IsRead bool + NullFields []string + StateFamily string + func (s *StateFamilyConfig) MarshalJSON() ([]byte, error) + type Status struct + Code int64 + Details []googleapi.RawMessage + ForceSendFields []string + Message string + NullFields []string + func (s *Status) MarshalJSON() ([]byte, error) + type Step struct + ForceSendFields []string + Kind string + Name string + NullFields []string + Properties googleapi.RawMessage + func (s *Step) MarshalJSON() ([]byte, error) + type StreamLocation struct + CustomSourceLocation *CustomSourceLocation + ForceSendFields []string + NullFields []string + PubsubLocation *PubsubLocation + SideInputLocation *StreamingSideInputLocation + StreamingStageLocation *StreamingStageLocation + func (s *StreamLocation) MarshalJSON() ([]byte, error) + type StreamingApplianceSnapshotConfig struct + ForceSendFields []string + ImportStateEndpoint string + NullFields []string + SnapshotId string + func (s *StreamingApplianceSnapshotConfig) MarshalJSON() ([]byte, error) + type StreamingComputationConfig struct + ComputationId string + ForceSendFields []string + Instructions []*ParallelInstruction + NullFields []string + StageName string + SystemName string + TransformUserNameToStateFamily map[string]string + func (s *StreamingComputationConfig) MarshalJSON() ([]byte, error) + type StreamingComputationRanges struct + ComputationId string + ForceSendFields []string + NullFields []string + RangeAssignments []*KeyRangeDataDiskAssignment + func (s *StreamingComputationRanges) MarshalJSON() ([]byte, error) + type StreamingComputationTask struct + ComputationRanges []*StreamingComputationRanges + DataDisks []*MountedDataDisk + ForceSendFields []string + NullFields []string + TaskType string + func (s *StreamingComputationTask) MarshalJSON() ([]byte, error) + type StreamingConfigTask struct + CommitStreamChunkSizeBytes int64 + ForceSendFields []string + GetDataStreamChunkSizeBytes int64 + MaxWorkItemCommitBytes int64 + NullFields []string + StreamingComputationConfigs []*StreamingComputationConfig + UserStepToStateFamilyNameMap map[string]string + WindmillServiceEndpoint string + WindmillServicePort int64 + func (s *StreamingConfigTask) MarshalJSON() ([]byte, error) + type StreamingSetupTask struct + Drain bool + ForceSendFields []string + NullFields []string + ReceiveWorkPort int64 + SnapshotConfig *StreamingApplianceSnapshotConfig + StreamingComputationTopology *TopologyConfig + WorkerHarnessPort int64 + func (s *StreamingSetupTask) MarshalJSON() ([]byte, error) + type StreamingSideInputLocation struct + ForceSendFields []string + NullFields []string + StateFamily string + Tag string + func (s *StreamingSideInputLocation) MarshalJSON() ([]byte, error) + type StreamingStageLocation struct + ForceSendFields []string + NullFields []string + StreamId string + func (s *StreamingStageLocation) MarshalJSON() ([]byte, error) + type StringList struct + Elements []string + ForceSendFields []string + NullFields []string + func (s *StringList) MarshalJSON() ([]byte, error) + type StructuredMessage struct + ForceSendFields []string + MessageKey string + MessageText string + NullFields []string + Parameters []*Parameter + func (s *StructuredMessage) MarshalJSON() ([]byte, error) + type TaskRunnerSettings struct + Alsologtostderr bool + BaseTaskDir string + BaseUrl string + CommandlinesFileName string + ContinueOnException bool + DataflowApiVersion string + ForceSendFields []string + HarnessCommand string + LanguageHint string + LogDir string + LogToSerialconsole bool + LogUploadLocation string + NullFields []string + OauthScopes []string + ParallelWorkerSettings *WorkerSettings + StreamingWorkerMainClass string + TaskGroup string + TaskUser string + TempStoragePrefix string + VmId string + WorkflowFileName string + func (s *TaskRunnerSettings) MarshalJSON() ([]byte, error) + type TemplateMetadata struct + Description string + ForceSendFields []string + Name string + NullFields []string + Parameters []*ParameterMetadata + func (s *TemplateMetadata) MarshalJSON() ([]byte, error) + type TopologyConfig struct + Computations []*ComputationTopology + DataDiskAssignments []*DataDiskAssignment + ForceSendFields []string + ForwardingKeyBits int64 + NullFields []string + PersistentStateVersion int64 + UserStageToComputationNameMap map[string]string + func (s *TopologyConfig) MarshalJSON() ([]byte, error) + type TransformSummary struct + DisplayData []*DisplayData + ForceSendFields []string + Id string + InputCollectionName []string + Kind string + Name string + NullFields []string + OutputCollectionName []string + func (s *TransformSummary) MarshalJSON() ([]byte, error) + type ValidateResponse struct + ErrorMessage string + ForceSendFields []string + NullFields []string + func (s *ValidateResponse) MarshalJSON() ([]byte, error) + type WorkItem struct + Configuration string + ForceSendFields []string + Id int64 + InitialReportIndex int64 + JobId string + LeaseExpireTime string + MapTask *MapTask + NullFields []string + Packages []*Package + ProjectId string + ReportStatusInterval string + SeqMapTask *SeqMapTask + ShellTask *ShellTask + SourceOperationTask *SourceOperationRequest + StreamingComputationTask *StreamingComputationTask + StreamingConfigTask *StreamingConfigTask + StreamingSetupTask *StreamingSetupTask + func (s *WorkItem) MarshalJSON() ([]byte, error) + type WorkItemServiceState struct + ForceSendFields []string + HarnessData googleapi.RawMessage + HotKeyDetection *HotKeyDetection + LeaseExpireTime string + MetricShortId []*MetricShortId + NextReportIndex int64 + NullFields []string + ReportStatusInterval string + SplitRequest *ApproximateSplitRequest + SuggestedStopPoint *ApproximateProgress + SuggestedStopPosition *Position + func (s *WorkItemServiceState) MarshalJSON() ([]byte, error) + type WorkItemStatus struct + Completed bool + CounterUpdates []*CounterUpdate + DynamicSourceSplit *DynamicSourceSplit + Errors []*Status + ForceSendFields []string + MetricUpdates []*MetricUpdate + NullFields []string + Progress *ApproximateProgress + ReportIndex int64 + ReportedProgress *ApproximateReportedProgress + RequestedLeaseDuration string + SourceFork *SourceFork + SourceOperationResponse *SourceOperationResponse + StopPosition *Position + TotalThrottlerWaitTimeSeconds float64 + WorkItemId string + func (s *WorkItemStatus) MarshalJSON() ([]byte, error) + func (s *WorkItemStatus) UnmarshalJSON(data []byte) error + type WorkerHealthReport struct + ForceSendFields []string + Msg string + NullFields []string + Pods []googleapi.RawMessage + ReportInterval string + VmIsBroken bool + VmIsHealthy bool + VmStartupTime string + func (s *WorkerHealthReport) MarshalJSON() ([]byte, error) + type WorkerHealthReportResponse struct + ForceSendFields []string + NullFields []string + ReportInterval string + func (s *WorkerHealthReportResponse) MarshalJSON() ([]byte, error) + type WorkerLifecycleEvent struct + ContainerStartTime string + Event string + ForceSendFields []string + Metadata map[string]string + NullFields []string + func (s *WorkerLifecycleEvent) MarshalJSON() ([]byte, error) + type WorkerMessage struct + ForceSendFields []string + Labels map[string]string + NullFields []string + Time string + WorkerHealthReport *WorkerHealthReport + WorkerLifecycleEvent *WorkerLifecycleEvent + WorkerMessageCode *WorkerMessageCode + WorkerMetrics *ResourceUtilizationReport + WorkerShutdownNotice *WorkerShutdownNotice + func (s *WorkerMessage) MarshalJSON() ([]byte, error) + type WorkerMessageCode struct + Code string + ForceSendFields []string + NullFields []string + Parameters googleapi.RawMessage + func (s *WorkerMessageCode) MarshalJSON() ([]byte, error) + type WorkerMessageResponse struct + ForceSendFields []string + NullFields []string + WorkerHealthReportResponse *WorkerHealthReportResponse + WorkerMetricsResponse *ResourceUtilizationReportResponse + WorkerShutdownNoticeResponse *WorkerShutdownNoticeResponse + func (s *WorkerMessageResponse) MarshalJSON() ([]byte, error) + type WorkerPool struct + AutoscalingSettings *AutoscalingSettings + DataDisks []*Disk + DefaultPackageSet string + DiskSizeGb int64 + DiskSourceImage string + DiskType string + ForceSendFields []string + IpConfiguration string + Kind string + MachineType string + Metadata map[string]string + Network string + NullFields []string + NumThreadsPerWorker int64 + NumWorkers int64 + OnHostMaintenance string + Packages []*Package + PoolArgs googleapi.RawMessage + SdkHarnessContainerImages []*SdkHarnessContainerImage + Subnetwork string + TaskrunnerSettings *TaskRunnerSettings + TeardownPolicy string + WorkerHarnessContainerImage string + Zone string + func (s *WorkerPool) MarshalJSON() ([]byte, error) + type WorkerSettings struct + BaseUrl string + ForceSendFields []string + NullFields []string + ReportingEnabled bool + ServicePath string + ShuffleServicePath string + TempStoragePrefix string + WorkerId string + func (s *WorkerSettings) MarshalJSON() ([]byte, error) + type WorkerShutdownNotice struct + ForceSendFields []string + NullFields []string + Reason string + func (s *WorkerShutdownNotice) MarshalJSON() ([]byte, error) + type WorkerShutdownNoticeResponse struct + type WriteInstruction struct + ForceSendFields []string + Input *InstructionInput + NullFields []string + Sink *Sink + func (s *WriteInstruction) MarshalJSON() ([]byte, error)