Versions in this module Expand all Collapse all v0 v0.196.2 Sep 10, 2024 Changes in this version + const CloudPlatformScope + type GoogleCloudDatapipelinesV1DataflowJobDetails struct + CurrentWorkers int64 + ForceSendFields []string + NullFields []string + ResourceInfo map[string]float64 + SdkVersion *GoogleCloudDatapipelinesV1SdkVersion + func (s GoogleCloudDatapipelinesV1DataflowJobDetails) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment struct + AdditionalExperiments []string + AdditionalUserLabels map[string]string + EnableStreamingEngine bool + FlexrsGoal string + 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 GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1Job struct + CreateTime string + DataflowJobDetails *GoogleCloudDatapipelinesV1DataflowJobDetails + EndTime string + ForceSendFields []string + Id string + Name string + NullFields []string + State string + Status *GoogleRpcStatus + func (s GoogleCloudDatapipelinesV1Job) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter struct + ContainerSpecGcsPath string + Environment *GoogleCloudDatapipelinesV1FlexTemplateRuntimeEnvironment + ForceSendFields []string + JobName string + LaunchOptions map[string]string + NullFields []string + Parameters map[string]string + TransformNameMappings map[string]string + Update bool + func (s GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1LaunchFlexTemplateRequest struct + ForceSendFields []string + LaunchParameter *GoogleCloudDatapipelinesV1LaunchFlexTemplateParameter + Location string + NullFields []string + ProjectId string + ValidateOnly bool + func (s GoogleCloudDatapipelinesV1LaunchFlexTemplateRequest) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1LaunchTemplateParameters struct + Environment *GoogleCloudDatapipelinesV1RuntimeEnvironment + ForceSendFields []string + JobName string + NullFields []string + Parameters map[string]string + TransformNameMapping map[string]string + Update bool + func (s GoogleCloudDatapipelinesV1LaunchTemplateParameters) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1LaunchTemplateRequest struct + ForceSendFields []string + GcsPath string + LaunchParameters *GoogleCloudDatapipelinesV1LaunchTemplateParameters + Location string + NullFields []string + ProjectId string + ValidateOnly bool + func (s GoogleCloudDatapipelinesV1LaunchTemplateRequest) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1ListJobsResponse struct + ForceSendFields []string + Jobs []*GoogleCloudDatapipelinesV1Job + NextPageToken string + NullFields []string + func (s GoogleCloudDatapipelinesV1ListJobsResponse) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1ListPipelinesResponse struct + ForceSendFields []string + NextPageToken string + NullFields []string + Pipelines []*GoogleCloudDatapipelinesV1Pipeline + func (s GoogleCloudDatapipelinesV1ListPipelinesResponse) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1Pipeline struct + CreateTime string + DisplayName string + ForceSendFields []string + JobCount int64 + LastUpdateTime string + Name string + NullFields []string + PipelineSources map[string]string + ScheduleInfo *GoogleCloudDatapipelinesV1ScheduleSpec + SchedulerServiceAccountEmail string + State string + Type string + Workload *GoogleCloudDatapipelinesV1Workload + func (s GoogleCloudDatapipelinesV1Pipeline) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1RunPipelineRequest struct + type GoogleCloudDatapipelinesV1RunPipelineResponse struct + ForceSendFields []string + Job *GoogleCloudDatapipelinesV1Job + NullFields []string + func (s GoogleCloudDatapipelinesV1RunPipelineResponse) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1RuntimeEnvironment struct + AdditionalExperiments []string + AdditionalUserLabels map[string]string + BypassTempDirValidation bool + EnableStreamingEngine 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 GoogleCloudDatapipelinesV1RuntimeEnvironment) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1ScheduleSpec struct + ForceSendFields []string + NextJobTime string + NullFields []string + Schedule string + TimeZone string + func (s GoogleCloudDatapipelinesV1ScheduleSpec) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1SdkVersion struct + ForceSendFields []string + NullFields []string + SdkSupportStatus string + Version string + VersionDisplayName string + func (s GoogleCloudDatapipelinesV1SdkVersion) MarshalJSON() ([]byte, error) + type GoogleCloudDatapipelinesV1StopPipelineRequest struct + type GoogleCloudDatapipelinesV1Workload struct + DataflowFlexTemplateRequest *GoogleCloudDatapipelinesV1LaunchFlexTemplateRequest + DataflowLaunchTemplateRequest *GoogleCloudDatapipelinesV1LaunchTemplateRequest + ForceSendFields []string + NullFields []string + func (s GoogleCloudDatapipelinesV1Workload) MarshalJSON() ([]byte, error) + type GoogleProtobufEmpty struct + type GoogleRpcStatus struct + Code int64 + Details []googleapi.RawMessage + ForceSendFields []string + Message string + NullFields []string + func (s GoogleRpcStatus) MarshalJSON() ([]byte, error) + type ProjectsLocationsPipelinesCreateCall struct + func (c *ProjectsLocationsPipelinesCreateCall) Context(ctx context.Context) *ProjectsLocationsPipelinesCreateCall + func (c *ProjectsLocationsPipelinesCreateCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1Pipeline, error) + func (c *ProjectsLocationsPipelinesCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesCreateCall + func (c *ProjectsLocationsPipelinesCreateCall) Header() http.Header + type ProjectsLocationsPipelinesDeleteCall struct + func (c *ProjectsLocationsPipelinesDeleteCall) Context(ctx context.Context) *ProjectsLocationsPipelinesDeleteCall + func (c *ProjectsLocationsPipelinesDeleteCall) Do(opts ...googleapi.CallOption) (*GoogleProtobufEmpty, error) + func (c *ProjectsLocationsPipelinesDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesDeleteCall + func (c *ProjectsLocationsPipelinesDeleteCall) Header() http.Header + type ProjectsLocationsPipelinesGetCall struct + func (c *ProjectsLocationsPipelinesGetCall) Context(ctx context.Context) *ProjectsLocationsPipelinesGetCall + func (c *ProjectsLocationsPipelinesGetCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1Pipeline, error) + func (c *ProjectsLocationsPipelinesGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesGetCall + func (c *ProjectsLocationsPipelinesGetCall) Header() http.Header + func (c *ProjectsLocationsPipelinesGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsPipelinesGetCall + type ProjectsLocationsPipelinesJobsListCall struct + func (c *ProjectsLocationsPipelinesJobsListCall) Context(ctx context.Context) *ProjectsLocationsPipelinesJobsListCall + func (c *ProjectsLocationsPipelinesJobsListCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1ListJobsResponse, error) + func (c *ProjectsLocationsPipelinesJobsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesJobsListCall + func (c *ProjectsLocationsPipelinesJobsListCall) Header() http.Header + func (c *ProjectsLocationsPipelinesJobsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPipelinesJobsListCall + func (c *ProjectsLocationsPipelinesJobsListCall) PageSize(pageSize int64) *ProjectsLocationsPipelinesJobsListCall + func (c *ProjectsLocationsPipelinesJobsListCall) PageToken(pageToken string) *ProjectsLocationsPipelinesJobsListCall + func (c *ProjectsLocationsPipelinesJobsListCall) Pages(ctx context.Context, f func(*GoogleCloudDatapipelinesV1ListJobsResponse) error) error + type ProjectsLocationsPipelinesJobsService struct + func NewProjectsLocationsPipelinesJobsService(s *Service) *ProjectsLocationsPipelinesJobsService + func (r *ProjectsLocationsPipelinesJobsService) List(parent string) *ProjectsLocationsPipelinesJobsListCall + type ProjectsLocationsPipelinesListCall struct + func (c *ProjectsLocationsPipelinesListCall) Context(ctx context.Context) *ProjectsLocationsPipelinesListCall + func (c *ProjectsLocationsPipelinesListCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1ListPipelinesResponse, error) + func (c *ProjectsLocationsPipelinesListCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesListCall + func (c *ProjectsLocationsPipelinesListCall) Filter(filter string) *ProjectsLocationsPipelinesListCall + func (c *ProjectsLocationsPipelinesListCall) Header() http.Header + func (c *ProjectsLocationsPipelinesListCall) IfNoneMatch(entityTag string) *ProjectsLocationsPipelinesListCall + func (c *ProjectsLocationsPipelinesListCall) PageSize(pageSize int64) *ProjectsLocationsPipelinesListCall + func (c *ProjectsLocationsPipelinesListCall) PageToken(pageToken string) *ProjectsLocationsPipelinesListCall + func (c *ProjectsLocationsPipelinesListCall) Pages(ctx context.Context, ...) error + type ProjectsLocationsPipelinesPatchCall struct + func (c *ProjectsLocationsPipelinesPatchCall) Context(ctx context.Context) *ProjectsLocationsPipelinesPatchCall + func (c *ProjectsLocationsPipelinesPatchCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1Pipeline, error) + func (c *ProjectsLocationsPipelinesPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesPatchCall + func (c *ProjectsLocationsPipelinesPatchCall) Header() http.Header + func (c *ProjectsLocationsPipelinesPatchCall) UpdateMask(updateMask string) *ProjectsLocationsPipelinesPatchCall + type ProjectsLocationsPipelinesRunCall struct + func (c *ProjectsLocationsPipelinesRunCall) Context(ctx context.Context) *ProjectsLocationsPipelinesRunCall + func (c *ProjectsLocationsPipelinesRunCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1RunPipelineResponse, error) + func (c *ProjectsLocationsPipelinesRunCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesRunCall + func (c *ProjectsLocationsPipelinesRunCall) Header() http.Header + type ProjectsLocationsPipelinesService struct + Jobs *ProjectsLocationsPipelinesJobsService + func NewProjectsLocationsPipelinesService(s *Service) *ProjectsLocationsPipelinesService + func (r *ProjectsLocationsPipelinesService) Create(parent string, ...) *ProjectsLocationsPipelinesCreateCall + func (r *ProjectsLocationsPipelinesService) Delete(name string) *ProjectsLocationsPipelinesDeleteCall + func (r *ProjectsLocationsPipelinesService) Get(name string) *ProjectsLocationsPipelinesGetCall + func (r *ProjectsLocationsPipelinesService) List(parent string) *ProjectsLocationsPipelinesListCall + func (r *ProjectsLocationsPipelinesService) Patch(name string, ...) *ProjectsLocationsPipelinesPatchCall + func (r *ProjectsLocationsPipelinesService) Run(name string, ...) *ProjectsLocationsPipelinesRunCall + func (r *ProjectsLocationsPipelinesService) Stop(name string, ...) *ProjectsLocationsPipelinesStopCall + type ProjectsLocationsPipelinesStopCall struct + func (c *ProjectsLocationsPipelinesStopCall) Context(ctx context.Context) *ProjectsLocationsPipelinesStopCall + func (c *ProjectsLocationsPipelinesStopCall) Do(opts ...googleapi.CallOption) (*GoogleCloudDatapipelinesV1Pipeline, error) + func (c *ProjectsLocationsPipelinesStopCall) Fields(s ...googleapi.Field) *ProjectsLocationsPipelinesStopCall + func (c *ProjectsLocationsPipelinesStopCall) Header() http.Header + type ProjectsLocationsService struct + Pipelines *ProjectsLocationsPipelinesService + func NewProjectsLocationsService(s *Service) *ProjectsLocationsService + type ProjectsService struct + Locations *ProjectsLocationsService + func NewProjectsService(s *Service) *ProjectsService + 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)
Go to main page