- deleteSnapshots$
- jobs-aggregated$
- jobs-create$
- jobs-debug-getConfig$
- jobs-debug-sendCapture$
- jobs-get$
- jobs-getMetrics$
- jobs-list$
- jobs-messages-list$
- jobs-snapshot$
- jobs-update$
- jobs-workItems-lease$
- jobs-workItems-reportStatus$
- locations-flexTemplates-launch$
- locations-jobs-create$
- locations-jobs-debug-getConfig$
- locations-jobs-debug-sendCapture$
- locations-jobs-get$
- locations-jobs-getExecutionDetails$
- locations-jobs-getMetrics$
- locations-jobs-list$
- locations-jobs-messages-list$
- locations-jobs-snapshot$
- locations-jobs-snapshots-list$
- locations-jobs-stages-getExecutionDetails$
- locations-jobs-update$
- locations-jobs-workItems-lease$
- locations-jobs-workItems-reportStatus$
- locations-snapshots-delete$
- locations-snapshots-get$
- locations-snapshots-list$
- locations-sql-validate$
- locations-templates-create$
- locations-templates-get$
- locations-templates-launch$
- locations-workerMessages$
- snapshots-get$
- snapshots-list$
- templates-create$
- templates-get$
- templates-launch$
- workerMessages$
happygapi.dataflow.projects
Dataflow API: projects. Manages Google Cloud Dataflow projects on Google Cloud Platform. See: https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects
Dataflow API: projects. Manages Google Cloud Dataflow projects on Google Cloud Platform. See: https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects
deleteSnapshots$clj
(deleteSnapshots$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/deleteSnapshots
Required parameters: projectId
Optional parameters: snapshotId, location
Deletes a snapshot.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/deleteSnapshots Required parameters: projectId Optional parameters: snapshotId, location Deletes a snapshot.
jobs-aggregated$clj
(jobs-aggregated$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/aggregated
Required parameters: projectId
Optional parameters: view, location, pageSize, filter, pageToken
List the jobs of a project across all regions.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/aggregated Required parameters: projectId Optional parameters: view, location, pageSize, filter, pageToken List the jobs of a project across all regions.
jobs-create$clj
(jobs-create$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/create
Required parameters: projectId
Optional parameters: view, location, replaceJobId
Body:
{:labels {}, :stepsLocation string, :executionInfo {:stages {}}, :jobMetadata {:fileDetails [FileIODetails], :sdkVersion SdkVersion, :bigTableDetails [BigTableIODetails], :pubsubDetails [PubSubIODetails], :bigqueryDetails [BigQueryIODetails], :datastoreDetails [DatastoreIODetails], :spannerDetails [SpannerIODetails]}, :clientRequestId string, :startTime string, :stageStates [{:currentStateTime string, :executionStageState string, :executionStageName string}], :name string, :steps [{:name string, :properties {}, :kind string}], :createTime string, :currentStateTime string, :type string, :transformNameMapping {}, :replaceJobId string, :pipelineDescription {:originalPipelineTransform [TransformSummary], :displayData [DisplayData], :executionPipelineStage [ExecutionStageSummary]}, :replacedByJobId string, :satisfiesPzs boolean, :currentState string, :tempFiles [string], :id string, :createdFromSnapshotId string, :environment {:flexResourceSchedulingGoal string, :internalExperiments {}, :experiments [string], :workerRegion string, :shuffleMode string, :debugOptions DebugOptions, :sdkPipelineOptions {}, :serviceKmsKeyName string, :tempStoragePrefix string, :serviceAccountEmail string, :clusterManagerApiService string, :userAgent {}, :serviceOptions [string], :workerZone string, :version {}, :workerPools [WorkerPool], :dataset string}, :projectId string, :requestedState string, :location string}
Creates a Cloud Dataflow job. To create a job, we recommend using projects.locations.jobs.create with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.create is not recommended, as your job will always start in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/create
Required parameters: projectId
Optional parameters: view, location, replaceJobId
Body:
{:labels {},
:stepsLocation string,
:executionInfo {:stages {}},
:jobMetadata {:fileDetails [FileIODetails],
:sdkVersion SdkVersion,
:bigTableDetails [BigTableIODetails],
:pubsubDetails [PubSubIODetails],
:bigqueryDetails [BigQueryIODetails],
:datastoreDetails [DatastoreIODetails],
:spannerDetails [SpannerIODetails]},
:clientRequestId string,
:startTime string,
:stageStates [{:currentStateTime string,
:executionStageState string,
:executionStageName string}],
:name string,
:steps [{:name string, :properties {}, :kind string}],
:createTime string,
:currentStateTime string,
:type string,
:transformNameMapping {},
:replaceJobId string,
:pipelineDescription {:originalPipelineTransform [TransformSummary],
:displayData [DisplayData],
:executionPipelineStage [ExecutionStageSummary]},
:replacedByJobId string,
:satisfiesPzs boolean,
:currentState string,
:tempFiles [string],
:id string,
:createdFromSnapshotId string,
:environment {:flexResourceSchedulingGoal string,
:internalExperiments {},
:experiments [string],
:workerRegion string,
:shuffleMode string,
:debugOptions DebugOptions,
:sdkPipelineOptions {},
:serviceKmsKeyName string,
:tempStoragePrefix string,
:serviceAccountEmail string,
:clusterManagerApiService string,
:userAgent {},
:serviceOptions [string],
:workerZone string,
:version {},
:workerPools [WorkerPool],
:dataset string},
:projectId string,
:requestedState string,
:location string}
Creates a Cloud Dataflow job. To create a job, we recommend using `projects.locations.jobs.create` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.create` is not recommended, as your job will always start in `us-central1`.jobs-debug-getConfig$clj
(jobs-debug-getConfig$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/debug/getConfig
Required parameters: jobId, projectId
Optional parameters: none
Body:
{:componentId string, :location string, :workerId string}
Get encoded debug configuration for component. Not cacheable.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/debug/getConfig
Required parameters: jobId, projectId
Optional parameters: none
Body:
{:componentId string, :location string, :workerId string}
Get encoded debug configuration for component. Not cacheable.jobs-debug-sendCapture$clj
(jobs-debug-sendCapture$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/debug/sendCapture
Required parameters: projectId, jobId
Optional parameters: none
Body:
{:workerId string, :data string, :componentId string, :location string}
Send encoded debug capture data for component.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/debug/sendCapture
Required parameters: projectId, jobId
Optional parameters: none
Body:
{:workerId string,
:data string,
:componentId string,
:location string}
Send encoded debug capture data for component.jobs-get$clj
(jobs-get$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/get
Required parameters: projectId, jobId
Optional parameters: view, location
Gets the state of the specified Cloud Dataflow job. To get the state of a job, we recommend using projects.locations.jobs.get with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.get is not recommended, as you can only get the state of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/get Required parameters: projectId, jobId Optional parameters: view, location Gets the state of the specified Cloud Dataflow job. To get the state of a job, we recommend using `projects.locations.jobs.get` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.get` is not recommended, as you can only get the state of jobs that are running in `us-central1`.
jobs-getMetrics$clj
(jobs-getMetrics$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/getMetrics
Required parameters: projectId, jobId
Optional parameters: startTime, location
Request the job status. To request the status of a job, we recommend using projects.locations.jobs.getMetrics with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.getMetrics is not recommended, as you can only request the status of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/getMetrics Required parameters: projectId, jobId Optional parameters: startTime, location Request the job status. To request the status of a job, we recommend using `projects.locations.jobs.getMetrics` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.getMetrics` is not recommended, as you can only request the status of jobs that are running in `us-central1`.
jobs-list$clj
(jobs-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/list
Required parameters: projectId
Optional parameters: filter, location, view, pageSize, pageToken
List the jobs of a project. To list the jobs of a project in a region, we recommend using projects.locations.jobs.list with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To list the all jobs across all regions, use projects.jobs.aggregated. Using projects.jobs.list is not recommended, as you can only get the list of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/list Required parameters: projectId Optional parameters: filter, location, view, pageSize, pageToken List the jobs of a project. To list the jobs of a project in a region, we recommend using `projects.locations.jobs.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To list the all jobs across all regions, use `projects.jobs.aggregated`. Using `projects.jobs.list` is not recommended, as you can only get the list of jobs that are running in `us-central1`.
jobs-messages-list$clj
(jobs-messages-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/messages/list
Required parameters: jobId, projectId
Optional parameters: pageSize, pageToken, startTime, endTime, minimumImportance, location
Request the job status. To request the status of a job, we recommend using projects.locations.jobs.messages.list with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.messages.list is not recommended, as you can only request the status of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/messages/list Required parameters: jobId, projectId Optional parameters: pageSize, pageToken, startTime, endTime, minimumImportance, location Request the job status. To request the status of a job, we recommend using `projects.locations.jobs.messages.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.messages.list` is not recommended, as you can only request the status of jobs that are running in `us-central1`.
jobs-snapshot$clj
(jobs-snapshot$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/snapshot
Required parameters: projectId, jobId
Optional parameters: none
Body:
{:description string, :ttl string, :location string, :snapshotSources boolean}
Snapshot the state of a streaming job.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/snapshot
Required parameters: projectId, jobId
Optional parameters: none
Body:
{:description string,
:ttl string,
:location string,
:snapshotSources boolean}
Snapshot the state of a streaming job.jobs-update$clj
(jobs-update$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/update
Required parameters: jobId, projectId
Optional parameters: location
Body:
{:labels {}, :stepsLocation string, :executionInfo {:stages {}}, :jobMetadata {:fileDetails [FileIODetails], :sdkVersion SdkVersion, :bigTableDetails [BigTableIODetails], :pubsubDetails [PubSubIODetails], :bigqueryDetails [BigQueryIODetails], :datastoreDetails [DatastoreIODetails], :spannerDetails [SpannerIODetails]}, :clientRequestId string, :startTime string, :stageStates [{:currentStateTime string, :executionStageState string, :executionStageName string}], :name string, :steps [{:name string, :properties {}, :kind string}], :createTime string, :currentStateTime string, :type string, :transformNameMapping {}, :replaceJobId string, :pipelineDescription {:originalPipelineTransform [TransformSummary], :displayData [DisplayData], :executionPipelineStage [ExecutionStageSummary]}, :replacedByJobId string, :satisfiesPzs boolean, :currentState string, :tempFiles [string], :id string, :createdFromSnapshotId string, :environment {:flexResourceSchedulingGoal string, :internalExperiments {}, :experiments [string], :workerRegion string, :shuffleMode string, :debugOptions DebugOptions, :sdkPipelineOptions {}, :serviceKmsKeyName string, :tempStoragePrefix string, :serviceAccountEmail string, :clusterManagerApiService string, :userAgent {}, :serviceOptions [string], :workerZone string, :version {}, :workerPools [WorkerPool], :dataset string}, :projectId string, :requestedState string, :location string}
Updates the state of an existing Cloud Dataflow job. To update the state of an existing job, we recommend using projects.locations.jobs.update with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.update is not recommended, as you can only update the state of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/update
Required parameters: jobId, projectId
Optional parameters: location
Body:
{:labels {},
:stepsLocation string,
:executionInfo {:stages {}},
:jobMetadata {:fileDetails [FileIODetails],
:sdkVersion SdkVersion,
:bigTableDetails [BigTableIODetails],
:pubsubDetails [PubSubIODetails],
:bigqueryDetails [BigQueryIODetails],
:datastoreDetails [DatastoreIODetails],
:spannerDetails [SpannerIODetails]},
:clientRequestId string,
:startTime string,
:stageStates [{:currentStateTime string,
:executionStageState string,
:executionStageName string}],
:name string,
:steps [{:name string, :properties {}, :kind string}],
:createTime string,
:currentStateTime string,
:type string,
:transformNameMapping {},
:replaceJobId string,
:pipelineDescription {:originalPipelineTransform [TransformSummary],
:displayData [DisplayData],
:executionPipelineStage [ExecutionStageSummary]},
:replacedByJobId string,
:satisfiesPzs boolean,
:currentState string,
:tempFiles [string],
:id string,
:createdFromSnapshotId string,
:environment {:flexResourceSchedulingGoal string,
:internalExperiments {},
:experiments [string],
:workerRegion string,
:shuffleMode string,
:debugOptions DebugOptions,
:sdkPipelineOptions {},
:serviceKmsKeyName string,
:tempStoragePrefix string,
:serviceAccountEmail string,
:clusterManagerApiService string,
:userAgent {},
:serviceOptions [string],
:workerZone string,
:version {},
:workerPools [WorkerPool],
:dataset string},
:projectId string,
:requestedState string,
:location string}
Updates the state of an existing Cloud Dataflow job. To update the state of an existing job, we recommend using `projects.locations.jobs.update` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.update` is not recommended, as you can only update the state of jobs that are running in `us-central1`.jobs-workItems-lease$clj
(jobs-workItems-lease$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/workItems/lease
Required parameters: jobId, projectId
Optional parameters: none
Body:
{:requestedLeaseDuration string, :workerCapabilities [string], :workItemTypes [string], :workerId string, :unifiedWorkerRequest {}, :location string, :currentWorkerTime string}
Leases a dataflow WorkItem to run.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/workItems/lease
Required parameters: jobId, projectId
Optional parameters: none
Body:
{:requestedLeaseDuration string,
:workerCapabilities [string],
:workItemTypes [string],
:workerId string,
:unifiedWorkerRequest {},
:location string,
:currentWorkerTime string}
Leases a dataflow WorkItem to run.jobs-workItems-reportStatus$clj
(jobs-workItems-reportStatus$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/workItems/reportStatus
Required parameters: projectId, jobId
Optional parameters: none
Body:
{:currentWorkerTime string, :workItemStatuses [{:stopPosition Position, :sourceFork SourceFork, :sourceOperationResponse SourceOperationResponse, :errors [Status], :reportedProgress ApproximateReportedProgress, :completed boolean, :workItemId string, :reportIndex string, :totalThrottlerWaitTimeSeconds number, :metricUpdates [MetricUpdate], :progress ApproximateProgress, :dynamicSourceSplit DynamicSourceSplit, :counterUpdates [CounterUpdate], :requestedLeaseDuration string}], :unifiedWorkerRequest {}, :workerId string, :location string}
Reports the status of dataflow WorkItems leased by a worker.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/jobs/workItems/reportStatus
Required parameters: projectId, jobId
Optional parameters: none
Body:
{:currentWorkerTime string,
:workItemStatuses [{:stopPosition Position,
:sourceFork SourceFork,
:sourceOperationResponse SourceOperationResponse,
:errors [Status],
:reportedProgress ApproximateReportedProgress,
:completed boolean,
:workItemId string,
:reportIndex string,
:totalThrottlerWaitTimeSeconds number,
:metricUpdates [MetricUpdate],
:progress ApproximateProgress,
:dynamicSourceSplit DynamicSourceSplit,
:counterUpdates [CounterUpdate],
:requestedLeaseDuration string}],
:unifiedWorkerRequest {},
:workerId string,
:location string}
Reports the status of dataflow WorkItems leased by a worker.locations-flexTemplates-launch$clj
(locations-flexTemplates-launch$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/flexTemplates/launch
Required parameters: location, projectId
Optional parameters: none
Body:
{:launchParameter {:parameters {}, :launchOptions {}, :transformNameMappings {}, :containerSpec ContainerSpec, :containerSpecGcsPath string, :jobName string, :environment FlexTemplateRuntimeEnvironment, :update boolean}, :validateOnly boolean}
Launch a job with a FlexTemplate.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/flexTemplates/launch
Required parameters: location, projectId
Optional parameters: none
Body:
{:launchParameter {:parameters {},
:launchOptions {},
:transformNameMappings {},
:containerSpec ContainerSpec,
:containerSpecGcsPath string,
:jobName string,
:environment FlexTemplateRuntimeEnvironment,
:update boolean},
:validateOnly boolean}
Launch a job with a FlexTemplate.locations-jobs-create$clj
(locations-jobs-create$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/create
Required parameters: location, projectId
Optional parameters: replaceJobId, view
Body:
{:labels {}, :stepsLocation string, :executionInfo {:stages {}}, :jobMetadata {:fileDetails [FileIODetails], :sdkVersion SdkVersion, :bigTableDetails [BigTableIODetails], :pubsubDetails [PubSubIODetails], :bigqueryDetails [BigQueryIODetails], :datastoreDetails [DatastoreIODetails], :spannerDetails [SpannerIODetails]}, :clientRequestId string, :startTime string, :stageStates [{:currentStateTime string, :executionStageState string, :executionStageName string}], :name string, :steps [{:name string, :properties {}, :kind string}], :createTime string, :currentStateTime string, :type string, :transformNameMapping {}, :replaceJobId string, :pipelineDescription {:originalPipelineTransform [TransformSummary], :displayData [DisplayData], :executionPipelineStage [ExecutionStageSummary]}, :replacedByJobId string, :satisfiesPzs boolean, :currentState string, :tempFiles [string], :id string, :createdFromSnapshotId string, :environment {:flexResourceSchedulingGoal string, :internalExperiments {}, :experiments [string], :workerRegion string, :shuffleMode string, :debugOptions DebugOptions, :sdkPipelineOptions {}, :serviceKmsKeyName string, :tempStoragePrefix string, :serviceAccountEmail string, :clusterManagerApiService string, :userAgent {}, :serviceOptions [string], :workerZone string, :version {}, :workerPools [WorkerPool], :dataset string}, :projectId string, :requestedState string, :location string}
Creates a Cloud Dataflow job. To create a job, we recommend using projects.locations.jobs.create with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.create is not recommended, as your job will always start in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/create
Required parameters: location, projectId
Optional parameters: replaceJobId, view
Body:
{:labels {},
:stepsLocation string,
:executionInfo {:stages {}},
:jobMetadata {:fileDetails [FileIODetails],
:sdkVersion SdkVersion,
:bigTableDetails [BigTableIODetails],
:pubsubDetails [PubSubIODetails],
:bigqueryDetails [BigQueryIODetails],
:datastoreDetails [DatastoreIODetails],
:spannerDetails [SpannerIODetails]},
:clientRequestId string,
:startTime string,
:stageStates [{:currentStateTime string,
:executionStageState string,
:executionStageName string}],
:name string,
:steps [{:name string, :properties {}, :kind string}],
:createTime string,
:currentStateTime string,
:type string,
:transformNameMapping {},
:replaceJobId string,
:pipelineDescription {:originalPipelineTransform [TransformSummary],
:displayData [DisplayData],
:executionPipelineStage [ExecutionStageSummary]},
:replacedByJobId string,
:satisfiesPzs boolean,
:currentState string,
:tempFiles [string],
:id string,
:createdFromSnapshotId string,
:environment {:flexResourceSchedulingGoal string,
:internalExperiments {},
:experiments [string],
:workerRegion string,
:shuffleMode string,
:debugOptions DebugOptions,
:sdkPipelineOptions {},
:serviceKmsKeyName string,
:tempStoragePrefix string,
:serviceAccountEmail string,
:clusterManagerApiService string,
:userAgent {},
:serviceOptions [string],
:workerZone string,
:version {},
:workerPools [WorkerPool],
:dataset string},
:projectId string,
:requestedState string,
:location string}
Creates a Cloud Dataflow job. To create a job, we recommend using `projects.locations.jobs.create` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.create` is not recommended, as your job will always start in `us-central1`.locations-jobs-debug-getConfig$clj
(locations-jobs-debug-getConfig$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/debug/getConfig
Required parameters: jobId, projectId, location
Optional parameters: none
Body:
{:componentId string, :location string, :workerId string}
Get encoded debug configuration for component. Not cacheable.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/debug/getConfig
Required parameters: jobId, projectId, location
Optional parameters: none
Body:
{:componentId string, :location string, :workerId string}
Get encoded debug configuration for component. Not cacheable.locations-jobs-debug-sendCapture$clj
(locations-jobs-debug-sendCapture$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/debug/sendCapture
Required parameters: jobId, location, projectId
Optional parameters: none
Body:
{:workerId string, :data string, :componentId string, :location string}
Send encoded debug capture data for component.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/debug/sendCapture
Required parameters: jobId, location, projectId
Optional parameters: none
Body:
{:workerId string,
:data string,
:componentId string,
:location string}
Send encoded debug capture data for component.locations-jobs-get$clj
(locations-jobs-get$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/get
Required parameters: location, projectId, jobId
Optional parameters: view
Gets the state of the specified Cloud Dataflow job. To get the state of a job, we recommend using projects.locations.jobs.get with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.get is not recommended, as you can only get the state of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/get Required parameters: location, projectId, jobId Optional parameters: view Gets the state of the specified Cloud Dataflow job. To get the state of a job, we recommend using `projects.locations.jobs.get` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.get` is not recommended, as you can only get the state of jobs that are running in `us-central1`.
locations-jobs-getExecutionDetails$clj
(locations-jobs-getExecutionDetails$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/getExecutionDetails
Required parameters: jobId, location, projectId
Optional parameters: pageSize, pageToken
Request detailed information about the execution status of the job. EXPERIMENTAL. This API is subject to change or removal without notice.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/getExecutionDetails Required parameters: jobId, location, projectId Optional parameters: pageSize, pageToken Request detailed information about the execution status of the job. EXPERIMENTAL. This API is subject to change or removal without notice.
locations-jobs-getMetrics$clj
(locations-jobs-getMetrics$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/getMetrics
Required parameters: location, jobId, projectId
Optional parameters: startTime
Request the job status. To request the status of a job, we recommend using projects.locations.jobs.getMetrics with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.getMetrics is not recommended, as you can only request the status of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/getMetrics Required parameters: location, jobId, projectId Optional parameters: startTime Request the job status. To request the status of a job, we recommend using `projects.locations.jobs.getMetrics` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.getMetrics` is not recommended, as you can only request the status of jobs that are running in `us-central1`.
locations-jobs-list$clj
(locations-jobs-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/list
Required parameters: location, projectId
Optional parameters: pageSize, view, filter, pageToken
List the jobs of a project. To list the jobs of a project in a region, we recommend using projects.locations.jobs.list with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To list the all jobs across all regions, use projects.jobs.aggregated. Using projects.jobs.list is not recommended, as you can only get the list of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/list Required parameters: location, projectId Optional parameters: pageSize, view, filter, pageToken List the jobs of a project. To list the jobs of a project in a region, we recommend using `projects.locations.jobs.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To list the all jobs across all regions, use `projects.jobs.aggregated`. Using `projects.jobs.list` is not recommended, as you can only get the list of jobs that are running in `us-central1`.
locations-jobs-messages-list$clj
(locations-jobs-messages-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/messages/list
Required parameters: jobId, projectId, location
Optional parameters: startTime, minimumImportance, endTime, pageSize, pageToken
Request the job status. To request the status of a job, we recommend using projects.locations.jobs.messages.list with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.messages.list is not recommended, as you can only request the status of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/messages/list Required parameters: jobId, projectId, location Optional parameters: startTime, minimumImportance, endTime, pageSize, pageToken Request the job status. To request the status of a job, we recommend using `projects.locations.jobs.messages.list` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.messages.list` is not recommended, as you can only request the status of jobs that are running in `us-central1`.
locations-jobs-snapshot$clj
(locations-jobs-snapshot$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/snapshot
Required parameters: projectId, jobId, location
Optional parameters: none
Body:
{:description string, :ttl string, :location string, :snapshotSources boolean}
Snapshot the state of a streaming job.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/snapshot
Required parameters: projectId, jobId, location
Optional parameters: none
Body:
{:description string,
:ttl string,
:location string,
:snapshotSources boolean}
Snapshot the state of a streaming job.locations-jobs-snapshots-list$clj
(locations-jobs-snapshots-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/snapshots/list
Required parameters: projectId, jobId, location
Optional parameters: none
Lists snapshots.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/snapshots/list Required parameters: projectId, jobId, location Optional parameters: none Lists snapshots.
locations-jobs-stages-getExecutionDetails$clj
(locations-jobs-stages-getExecutionDetails$ auth parameters)Required parameters: stageId, projectId, jobId, location
Optional parameters: endTime, pageToken, pageSize, startTime
Request detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/stages/getExecutionDetails Required parameters: stageId, projectId, jobId, location Optional parameters: endTime, pageToken, pageSize, startTime Request detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice.
locations-jobs-update$clj
(locations-jobs-update$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/update
Required parameters: location, projectId, jobId
Optional parameters: none
Body:
{:labels {}, :stepsLocation string, :executionInfo {:stages {}}, :jobMetadata {:fileDetails [FileIODetails], :sdkVersion SdkVersion, :bigTableDetails [BigTableIODetails], :pubsubDetails [PubSubIODetails], :bigqueryDetails [BigQueryIODetails], :datastoreDetails [DatastoreIODetails], :spannerDetails [SpannerIODetails]}, :clientRequestId string, :startTime string, :stageStates [{:currentStateTime string, :executionStageState string, :executionStageName string}], :name string, :steps [{:name string, :properties {}, :kind string}], :createTime string, :currentStateTime string, :type string, :transformNameMapping {}, :replaceJobId string, :pipelineDescription {:originalPipelineTransform [TransformSummary], :displayData [DisplayData], :executionPipelineStage [ExecutionStageSummary]}, :replacedByJobId string, :satisfiesPzs boolean, :currentState string, :tempFiles [string], :id string, :createdFromSnapshotId string, :environment {:flexResourceSchedulingGoal string, :internalExperiments {}, :experiments [string], :workerRegion string, :shuffleMode string, :debugOptions DebugOptions, :sdkPipelineOptions {}, :serviceKmsKeyName string, :tempStoragePrefix string, :serviceAccountEmail string, :clusterManagerApiService string, :userAgent {}, :serviceOptions [string], :workerZone string, :version {}, :workerPools [WorkerPool], :dataset string}, :projectId string, :requestedState string, :location string}
Updates the state of an existing Cloud Dataflow job. To update the state of an existing job, we recommend using projects.locations.jobs.update with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using projects.jobs.update is not recommended, as you can only update the state of jobs that are running in us-central1.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/update
Required parameters: location, projectId, jobId
Optional parameters: none
Body:
{:labels {},
:stepsLocation string,
:executionInfo {:stages {}},
:jobMetadata {:fileDetails [FileIODetails],
:sdkVersion SdkVersion,
:bigTableDetails [BigTableIODetails],
:pubsubDetails [PubSubIODetails],
:bigqueryDetails [BigQueryIODetails],
:datastoreDetails [DatastoreIODetails],
:spannerDetails [SpannerIODetails]},
:clientRequestId string,
:startTime string,
:stageStates [{:currentStateTime string,
:executionStageState string,
:executionStageName string}],
:name string,
:steps [{:name string, :properties {}, :kind string}],
:createTime string,
:currentStateTime string,
:type string,
:transformNameMapping {},
:replaceJobId string,
:pipelineDescription {:originalPipelineTransform [TransformSummary],
:displayData [DisplayData],
:executionPipelineStage [ExecutionStageSummary]},
:replacedByJobId string,
:satisfiesPzs boolean,
:currentState string,
:tempFiles [string],
:id string,
:createdFromSnapshotId string,
:environment {:flexResourceSchedulingGoal string,
:internalExperiments {},
:experiments [string],
:workerRegion string,
:shuffleMode string,
:debugOptions DebugOptions,
:sdkPipelineOptions {},
:serviceKmsKeyName string,
:tempStoragePrefix string,
:serviceAccountEmail string,
:clusterManagerApiService string,
:userAgent {},
:serviceOptions [string],
:workerZone string,
:version {},
:workerPools [WorkerPool],
:dataset string},
:projectId string,
:requestedState string,
:location string}
Updates the state of an existing Cloud Dataflow job. To update the state of an existing job, we recommend using `projects.locations.jobs.update` with a [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using `projects.jobs.update` is not recommended, as you can only update the state of jobs that are running in `us-central1`.locations-jobs-workItems-lease$clj
(locations-jobs-workItems-lease$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/workItems/lease
Required parameters: projectId, location, jobId
Optional parameters: none
Body:
{:requestedLeaseDuration string, :workerCapabilities [string], :workItemTypes [string], :workerId string, :unifiedWorkerRequest {}, :location string, :currentWorkerTime string}
Leases a dataflow WorkItem to run.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/workItems/lease
Required parameters: projectId, location, jobId
Optional parameters: none
Body:
{:requestedLeaseDuration string,
:workerCapabilities [string],
:workItemTypes [string],
:workerId string,
:unifiedWorkerRequest {},
:location string,
:currentWorkerTime string}
Leases a dataflow WorkItem to run.locations-jobs-workItems-reportStatus$clj
(locations-jobs-workItems-reportStatus$ auth parameters body)Required parameters: location, projectId, jobId
Optional parameters: none
Body:
{:currentWorkerTime string, :workItemStatuses [{:stopPosition Position, :sourceFork SourceFork, :sourceOperationResponse SourceOperationResponse, :errors [Status], :reportedProgress ApproximateReportedProgress, :completed boolean, :workItemId string, :reportIndex string, :totalThrottlerWaitTimeSeconds number, :metricUpdates [MetricUpdate], :progress ApproximateProgress, :dynamicSourceSplit DynamicSourceSplit, :counterUpdates [CounterUpdate], :requestedLeaseDuration string}], :unifiedWorkerRequest {}, :workerId string, :location string}
Reports the status of dataflow WorkItems leased by a worker.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/jobs/workItems/reportStatus
Required parameters: location, projectId, jobId
Optional parameters: none
Body:
{:currentWorkerTime string,
:workItemStatuses [{:stopPosition Position,
:sourceFork SourceFork,
:sourceOperationResponse SourceOperationResponse,
:errors [Status],
:reportedProgress ApproximateReportedProgress,
:completed boolean,
:workItemId string,
:reportIndex string,
:totalThrottlerWaitTimeSeconds number,
:metricUpdates [MetricUpdate],
:progress ApproximateProgress,
:dynamicSourceSplit DynamicSourceSplit,
:counterUpdates [CounterUpdate],
:requestedLeaseDuration string}],
:unifiedWorkerRequest {},
:workerId string,
:location string}
Reports the status of dataflow WorkItems leased by a worker.locations-snapshots-delete$clj
(locations-snapshots-delete$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/snapshots/delete
Required parameters: snapshotId, location, projectId
Optional parameters: none
Deletes a snapshot.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/snapshots/delete Required parameters: snapshotId, location, projectId Optional parameters: none Deletes a snapshot.
locations-snapshots-get$clj
(locations-snapshots-get$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/snapshots/get
Required parameters: location, projectId, snapshotId
Optional parameters: none
Gets information about a snapshot.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/snapshots/get Required parameters: location, projectId, snapshotId Optional parameters: none Gets information about a snapshot.
locations-snapshots-list$clj
(locations-snapshots-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/snapshots/list
Required parameters: location, projectId
Optional parameters: jobId
Lists snapshots.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/snapshots/list Required parameters: location, projectId Optional parameters: jobId Lists snapshots.
locations-sql-validate$clj
(locations-sql-validate$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/sql/validate
Required parameters: location, projectId
Optional parameters: query
Validates a GoogleSQL query for Cloud Dataflow syntax. Will always confirm the given query parses correctly, and if able to look up schema information from DataCatalog, will validate that the query analyzes properly as well.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/sql/validate Required parameters: location, projectId Optional parameters: query Validates a GoogleSQL query for Cloud Dataflow syntax. Will always confirm the given query parses correctly, and if able to look up schema information from DataCatalog, will validate that the query analyzes properly as well.
locations-templates-create$clj
(locations-templates-create$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/templates/create
Required parameters: location, projectId
Optional parameters: none
Body:
{:jobName string, :parameters {}, :gcsPath string, :environment {:maxWorkers integer, :workerRegion string, :additionalExperiments [string], :zone string, :machineType string, :tempLocation string, :numWorkers integer, :serviceAccountEmail string, :bypassTempDirValidation boolean, :ipConfiguration string, :kmsKeyName string, :enableStreamingEngine boolean, :network string, :workerZone string, :additionalUserLabels {}, :subnetwork string}, :location string}
Creates a Cloud Dataflow job from a template.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/templates/create
Required parameters: location, projectId
Optional parameters: none
Body:
{:jobName string,
:parameters {},
:gcsPath string,
:environment {:maxWorkers integer,
:workerRegion string,
:additionalExperiments [string],
:zone string,
:machineType string,
:tempLocation string,
:numWorkers integer,
:serviceAccountEmail string,
:bypassTempDirValidation boolean,
:ipConfiguration string,
:kmsKeyName string,
:enableStreamingEngine boolean,
:network string,
:workerZone string,
:additionalUserLabels {},
:subnetwork string},
:location string}
Creates a Cloud Dataflow job from a template.locations-templates-get$clj
(locations-templates-get$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/templates/get
Required parameters: location, projectId
Optional parameters: view, gcsPath
Get the template associated with a template.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/templates/get Required parameters: location, projectId Optional parameters: view, gcsPath Get the template associated with a template.
locations-templates-launch$clj
(locations-templates-launch$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/templates/launch
Required parameters: projectId, location
Optional parameters: validateOnly, dynamicTemplate.stagingLocation, gcsPath, dynamicTemplate.gcsPath
Body:
{:environment {:maxWorkers integer, :workerRegion string, :additionalExperiments [string], :zone string, :machineType string, :tempLocation string, :numWorkers integer, :serviceAccountEmail string, :bypassTempDirValidation boolean, :ipConfiguration string, :kmsKeyName string, :enableStreamingEngine boolean, :network string, :workerZone string, :additionalUserLabels {}, :subnetwork string}, :update boolean, :parameters {}, :transformNameMapping {}, :jobName string}
Launch a template.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/templates/launch
Required parameters: projectId, location
Optional parameters: validateOnly, dynamicTemplate.stagingLocation, gcsPath, dynamicTemplate.gcsPath
Body:
{:environment {:maxWorkers integer,
:workerRegion string,
:additionalExperiments [string],
:zone string,
:machineType string,
:tempLocation string,
:numWorkers integer,
:serviceAccountEmail string,
:bypassTempDirValidation boolean,
:ipConfiguration string,
:kmsKeyName string,
:enableStreamingEngine boolean,
:network string,
:workerZone string,
:additionalUserLabels {},
:subnetwork string},
:update boolean,
:parameters {},
:transformNameMapping {},
:jobName string}
Launch a template.locations-workerMessages$clj
(locations-workerMessages$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/workerMessages
Required parameters: location, projectId
Optional parameters: none
Body:
{:workerMessages [{:workerMetrics ResourceUtilizationReport, :labels {}, :workerShutdownNotice WorkerShutdownNotice, :workerHealthReport WorkerHealthReport, :workerLifecycleEvent WorkerLifecycleEvent, :time string, :workerMessageCode WorkerMessageCode}], :location string}
Send a worker_message to the service.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/locations/workerMessages
Required parameters: location, projectId
Optional parameters: none
Body:
{:workerMessages [{:workerMetrics ResourceUtilizationReport,
:labels {},
:workerShutdownNotice WorkerShutdownNotice,
:workerHealthReport WorkerHealthReport,
:workerLifecycleEvent WorkerLifecycleEvent,
:time string,
:workerMessageCode WorkerMessageCode}],
:location string}
Send a worker_message to the service.snapshots-get$clj
(snapshots-get$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/snapshots/get
Required parameters: snapshotId, projectId
Optional parameters: location
Gets information about a snapshot.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/snapshots/get Required parameters: snapshotId, projectId Optional parameters: location Gets information about a snapshot.
snapshots-list$clj
(snapshots-list$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/snapshots/list
Required parameters: projectId
Optional parameters: location, jobId
Lists snapshots.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/snapshots/list Required parameters: projectId Optional parameters: location, jobId Lists snapshots.
templates-create$clj
(templates-create$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/templates/create
Required parameters: projectId
Optional parameters: none
Body:
{:jobName string, :parameters {}, :gcsPath string, :environment {:maxWorkers integer, :workerRegion string, :additionalExperiments [string], :zone string, :machineType string, :tempLocation string, :numWorkers integer, :serviceAccountEmail string, :bypassTempDirValidation boolean, :ipConfiguration string, :kmsKeyName string, :enableStreamingEngine boolean, :network string, :workerZone string, :additionalUserLabels {}, :subnetwork string}, :location string}
Creates a Cloud Dataflow job from a template.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/templates/create
Required parameters: projectId
Optional parameters: none
Body:
{:jobName string,
:parameters {},
:gcsPath string,
:environment {:maxWorkers integer,
:workerRegion string,
:additionalExperiments [string],
:zone string,
:machineType string,
:tempLocation string,
:numWorkers integer,
:serviceAccountEmail string,
:bypassTempDirValidation boolean,
:ipConfiguration string,
:kmsKeyName string,
:enableStreamingEngine boolean,
:network string,
:workerZone string,
:additionalUserLabels {},
:subnetwork string},
:location string}
Creates a Cloud Dataflow job from a template.templates-get$clj
(templates-get$ auth parameters)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/templates/get
Required parameters: projectId
Optional parameters: location, view, gcsPath
Get the template associated with a template.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/templates/get Required parameters: projectId Optional parameters: location, view, gcsPath Get the template associated with a template.
templates-launch$clj
(templates-launch$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/templates/launch
Required parameters: projectId
Optional parameters: location, dynamicTemplate.gcsPath, dynamicTemplate.stagingLocation, validateOnly, gcsPath
Body:
{:environment {:maxWorkers integer, :workerRegion string, :additionalExperiments [string], :zone string, :machineType string, :tempLocation string, :numWorkers integer, :serviceAccountEmail string, :bypassTempDirValidation boolean, :ipConfiguration string, :kmsKeyName string, :enableStreamingEngine boolean, :network string, :workerZone string, :additionalUserLabels {}, :subnetwork string}, :update boolean, :parameters {}, :transformNameMapping {}, :jobName string}
Launch a template.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/templates/launch
Required parameters: projectId
Optional parameters: location, dynamicTemplate.gcsPath, dynamicTemplate.stagingLocation, validateOnly, gcsPath
Body:
{:environment {:maxWorkers integer,
:workerRegion string,
:additionalExperiments [string],
:zone string,
:machineType string,
:tempLocation string,
:numWorkers integer,
:serviceAccountEmail string,
:bypassTempDirValidation boolean,
:ipConfiguration string,
:kmsKeyName string,
:enableStreamingEngine boolean,
:network string,
:workerZone string,
:additionalUserLabels {},
:subnetwork string},
:update boolean,
:parameters {},
:transformNameMapping {},
:jobName string}
Launch a template.workerMessages$clj
(workerMessages$ auth parameters body)https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/workerMessages
Required parameters: projectId
Optional parameters: none
Body:
{:workerMessages [{:workerMetrics ResourceUtilizationReport, :labels {}, :workerShutdownNotice WorkerShutdownNotice, :workerHealthReport WorkerHealthReport, :workerLifecycleEvent WorkerLifecycleEvent, :time string, :workerMessageCode WorkerMessageCode}], :location string}
Send a worker_message to the service.
https://cloud.google.com/dataflowapi/reference/rest/v1b3/projects/workerMessages
Required parameters: projectId
Optional parameters: none
Body:
{:workerMessages [{:workerMetrics ResourceUtilizationReport,
:labels {},
:workerShutdownNotice WorkerShutdownNotice,
:workerHealthReport WorkerHealthReport,
:workerLifecycleEvent WorkerLifecycleEvent,
:time string,
:workerMessageCode WorkerMessageCode}],
:location string}
Send a worker_message to the service.cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close