{-# LANGUAGE DataKinds #-}
{-# LANGUAGE NoImplicitPrelude #-}
{-# LANGUAGE TypeOperators #-}
{-# OPTIONS_GHC -fno-warn-unused-imports #-}
{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}
module Network.Google.Dataflow
(
dataflowService
, userInfoEmailScope
, cloudPlatformScope
, DataflowAPI
, module Network.Google.Resource.Dataflow.Projects.Jobs.Create
, module Network.Google.Resource.Dataflow.Projects.Jobs.Debug.GetConfig
, module Network.Google.Resource.Dataflow.Projects.Jobs.Debug.SendCapture
, module Network.Google.Resource.Dataflow.Projects.Jobs.Get
, module Network.Google.Resource.Dataflow.Projects.Jobs.GetMetrics
, module Network.Google.Resource.Dataflow.Projects.Jobs.List
, module Network.Google.Resource.Dataflow.Projects.Jobs.Messages.List
, module Network.Google.Resource.Dataflow.Projects.Jobs.Update
, module Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.Lease
, module Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.ReportStatus
, module Network.Google.Resource.Dataflow.Projects.Templates.Create
, module Network.Google.Resource.Dataflow.Projects.WorkerMessages
, JobExecutionInfoStages
, jobExecutionInfoStages
, jeisAddtional
, ComputationTopology
, computationTopology
, ctStateFamilies
, ctUserStageName
, ctInputs
, ctKeyRanges
, ctOutputs
, ctComputationId
, ctSystemStageName
, SourceSplitResponse
, sourceSplitResponse
, ssrBundles
, ssrShards
, ssrOutcome
, CreateJobFromTemplateRequest
, createJobFromTemplateRequest
, cjftrGcsPath
, cjftrParameters
, Status
, status
, sDetails
, sCode
, sMessage
, NameAndKind
, nameAndKind
, nakKind
, nakName
, IntegerList
, integerList
, ilElements
, WorkItem
, workItem
, wiJobId
, wiReportStatusInterval
, wiShellTask
, wiStreamingSetupTask
, wiInitialReportIndex
, wiMapTask
, wiPackages
, wiStreamingComputationTask
, wiSourceOperationTask
, wiId
, wiProjectId
, wiLeaseExpireTime
, wiConfiguration
, wiStreamingConfigTask
, wiSeqMapTask
, WorkerHealthReport
, workerHealthReport
, whrVMIsHealthy
, whrReportInterval
, whrPods
, whrVMStartupTime
, SourceSplitOptions
, sourceSplitOptions
, ssoDesiredShardSizeBytes
, ssoDesiredBundleSizeBytes
, WorkerPoolMetadata
, workerPoolMetadata
, wpmAddtional
, AutoscalingSettings
, autoscalingSettings
, asMaxNumWorkers
, asAlgorithm
, JobExecutionStageInfo
, jobExecutionStageInfo
, jesiStepName
, InstructionOutput
, instructionOutput
, ioOnlyCountValueBytes
, ioCodec
, ioName
, ioSystemName
, ioOriginalName
, ioOnlyCountKeyBytes
, ReportWorkItemStatusRequest
, reportWorkItemStatusRequest
, rwisrCurrentWorkerTime
, rwisrWorkItemStatuses
, rwisrWorkerId
, EnvironmentVersion
, environmentVersion
, evAddtional
, Sink
, sink
, sCodec
, sSpec
, StringList
, stringList
, slElements
, WorkerHealthReportResponse
, workerHealthReportResponse
, whrrReportInterval
, SendDebugCaptureResponse
, sendDebugCaptureResponse
, JobLabels
, jobLabels
, jlAddtional
, MetricStructuredName
, metricStructuredName
, msnOrigin
, msnContext
, msnName
, CounterStructuredName
, counterStructuredName
, csnStandardOrigin
, csnComponentStepName
, csnOtherOrigin
, csnPortion
, csnOriginalStepName
, csnName
, csnExecutionStepName
, csnWorkerId
, WriteInstruction
, writeInstruction
, wiSink
, wiInput
, EnvironmentUserAgent
, environmentUserAgent
, euaAddtional
, Disk
, disk
, dSizeGb
, dDiskType
, dMountPoint
, MetricUpdate
, metricUpdate
, muMeanSum
, muInternal
, muSet
, muCumulative
, muKind
, muUpdateTime
, muMeanCount
, muName
, muScalar
, SourceGetMetadataResponse
, sourceGetMetadataResponse
, sgmrMetadata
, Environment
, environment
, eDataSet
, eExperiments
, eWorkerPools
, eClusterManagerAPIService
, eVersion
, eInternalExperiments
, eTempStoragePrefix
, eServiceAccountEmail
, eUserAgent
, eSdkPipelineOptions
, ConcatPosition
, concatPosition
, cpIndex
, cpPosition
, MetricStructuredNameContext
, metricStructuredNameContext
, msncAddtional
, CounterUpdate
, counterUpdate
, cuNameAndKind
, cuIntegerList
, cuFloatingPoint
, cuInternal
, cuStringList
, cuShortId
, cuCumulative
, cuStructuredNameAndMetadata
, cuFloatingPointMean
, cuIntegerMean
, cuBoolean
, cuFloatingPointList
, cuInteger
, StreamingStageLocation
, streamingStageLocation
, sslStreamId
, DerivedSource
, derivedSource
, dsDerivationMode
, dsSource
, JobMetrics
, jobMetrics
, jmMetrics
, jmMetricTime
, SendDebugCaptureRequest
, sendDebugCaptureRequest
, sdcrData
, sdcrComponentId
, sdcrWorkerId
, WorkItemStatus
, workItemStatus
, wisReportedProgress
, wisProgress
, wisSourceOperationResponse
, wisStopPosition
, wisDynamicSourceSplit
, wisCompleted
, wisSourceFork
, wisReportIndex
, wisRequestedLeaseDuration
, wisErrors
, wisCounterUpdates
, wisMetricUpdates
, wisWorkItemId
, WorkerMessageLabels
, workerMessageLabels
, wmlAddtional
, FlattenInstruction
, flattenInstruction
, fiInputs
, WorkerMessageCode
, workerMessageCode
, wmcParameters
, wmcCode
, JobTransformNameMApping
, jobTransformNameMApping
, jtnmaAddtional
, SourceSpec
, sourceSpec
, ssAddtional
, SourceMetadata
, sourceMetadata
, smEstimatedSizeBytes
, smProducesSortedKeys
, smInfinite
, EnvironmentInternalExperiments
, environmentInternalExperiments
, eieAddtional
, TaskRunnerSettings
, taskRunnerSettings
, trsContinueOnException
, trsHarnessCommand
, trsWorkflowFileName
, trsTaskGroup
, trsAlsologtostderr
, trsDataflowAPIVersion
, trsLogDir
, trsCommandlinesFileName
, trsVMId
, trsBaseURL
, trsOAuthScopes
, trsTaskUser
, trsStreamingWorkerMainClass
, trsBaseTaskDir
, trsLogUploadLocation
, trsTempStoragePrefix
, trsLogToSerialconsole
, trsParallelWorkerSettings
, trsLanguageHint
, StreamingComputationConfig
, streamingComputationConfig
, sccInstructions
, sccSystemName
, sccComputationId
, sccStageName
, EnvironmentSdkPipelineOptions
, environmentSdkPipelineOptions
, espoAddtional
, FloatingPointMean
, floatingPointMean
, fpmCount
, fpmSum
, LeaseWorkItemRequest
, leaseWorkItemRequest
, lwirWorkItemTypes
, lwirCurrentWorkerTime
, lwirWorkerCapabilities
, lwirRequestedLeaseDuration
, lwirWorkerId
, SourceOperationResponse
, sourceOperationResponse
, sorSplit
, sorGetMetadata
, TopologyConfigUserStageToComputationNameMap
, topologyConfigUserStageToComputationNameMap
, tcustcnmAddtional
, ShellTask
, shellTask
, stCommand
, stExitCode
, StatusDetailsItem
, statusDetailsItem
, sdiAddtional
, ReportedParallelism
, reportedParallelism
, rpValue
, rpIsInfinite
, StepProperties
, stepProperties
, spAddtional
, TopologyConfig
, topologyConfig
, tcDataDiskAssignments
, tcPersistentStateVersion
, tcForwardingKeyBits
, tcUserStageToComputationNameMap
, tcComputations
, ApproximateSplitRequest
, approximateSplitRequest
, asrFractionConsumed
, asrPosition
, SplitInt64
, splitInt64
, siHighBits
, siLowBits
, WorkerSettings
, workerSettings
, wsServicePath
, wsBaseURL
, wsShuffleServicePath
, wsTempStoragePrefix
, wsReportingEnabled
, wsWorkerId
, GetDebugConfigResponse
, getDebugConfigResponse
, gdcrConfig
, WorkItemServiceStateHarnessData
, workItemServiceStateHarnessData
, wisshdAddtional
, DataDiskAssignment
, dataDiskAssignment
, ddaVMInstance
, ddaDataDisks
, WorkerMessageResponse
, workerMessageResponse
, wmrWorkerHealthReportResponse
, CreateJobFromTemplateRequestParameters
, createJobFromTemplateRequestParameters
, cjftrpAddtional
, WorkItemServiceState
, workItemServiceState
, wissNextReportIndex
, wissReportStatusInterval
, wissHarnessData
, wissSuggestedStopPoint
, wissSuggestedStopPosition
, wissLeaseExpireTime
, wissSplitRequest
, wissMetricShortId
, StreamingSetupTask
, streamingSetupTask
, sstStreamingComputationTopology
, sstReceiveWorkPort
, sstWorkerHarnessPort
, sstDrain
, PartialGroupByKeyInstructionInputElementCodec
, partialGroupByKeyInstructionInputElementCodec
, pgbkiiecAddtional
, MapTask
, mapTask
, mtInstructions
, mtSystemName
, mtStageName
, MountedDataDisk
, mountedDataDisk
, mddDataDisk
, SinkCodec
, sinkCodec
, scAddtional
, IntegerMean
, integerMean
, imCount
, imSum
, WorkerHealthReportPodsItem
, workerHealthReportPodsItem
, whrpiAddtional
, ParDoInstructionUserFn
, parDoInstructionUserFn
, pdiufAddtional
, InstructionOutputCodec
, instructionOutputCodec
, iocAddtional
, StreamLocation
, streamLocation
, slStreamingStageLocation
, slSideInputLocation
, slCustomSourceLocation
, slPubsubLocation
, WorkerPoolPoolArgs
, workerPoolPoolArgs
, wppaAddtional
, CounterMetadata
, counterMetadata
, cmKind
, cmDescription
, cmStandardUnits
, cmOtherUnits
, SendWorkerMessagesResponse
, sendWorkerMessagesResponse
, swmrWorkerMessageResponses
, StreamingSideInputLocation
, streamingSideInputLocation
, ssilTag
, ssilStateFamily
, GetDebugConfigRequest
, getDebugConfigRequest
, gdcrComponentId
, gdcrWorkerId
, CounterStructuredNameAndMetadata
, counterStructuredNameAndMetadata
, csnamName
, csnamMetadata
, StreamingComputationTask
, streamingComputationTask
, sctTaskType
, sctDataDisks
, sctComputationRanges
, JobMessage
, jobMessage
, jmTime
, jmMessageText
, jmMessageImportance
, jmId
, SeqMapTaskOutputInfo
, seqMapTaskOutputInfo
, smtoiSink
, smtoiTag
, SourceGetMetadataRequest
, sourceGetMetadataRequest
, sgmrSource
, SeqMapTaskUserFn
, seqMapTaskUserFn
, smtufAddtional
, PartialGroupByKeyInstructionValueCombiningFn
, partialGroupByKeyInstructionValueCombiningFn
, pgbkivcfAddtional
, Job
, job
, jRequestedState
, jEnvironment
, jClientRequestId
, jCurrentState
, jReplacedByJobId
, jTempFiles
, jSteps
, jExecutionInfo
, jName
, jTransformNameMApping
, jId
, jLabels
, jProjectId
, jType
, jCurrentStateTime
, jReplaceJobId
, jCreateTime
, ReadInstruction
, readInstruction
, riSource
, ApproximateReportedProgress
, approximateReportedProgress
, arpFractionConsumed
, arpConsumedParallelism
, arpRemainingParallelism
, arpPosition
, SinkSpec
, sinkSpec
, sAddtional
, WorkerPool
, workerPool
, wpAutoscalingSettings
, wpNumThreadsPerWorker
, wpDiskSizeGb
, wpKind
, wpTaskrunnerSettings
, wpNumWorkers
, wpNetwork
, wpZone
, wpIPConfiguration
, wpPackages
, wpOnHostMaintenance
, wpDiskSourceImage
, wpSubnetwork
, wpMachineType
, wpMetadata
, wpDiskType
, wpTeardownPolicy
, wpDefaultPackageSet
, wpPoolArgs
, wpWorkerHarnessContainerImage
, wpDataDisks
, Step
, step
, sKind
, sName
, sProperties
, Package
, package
, pLocation
, pName
, WorkerMessageCodeParameters
, workerMessageCodeParameters
, wmcpAddtional
, DynamicSourceSplit
, dynamicSourceSplit
, dssResidual
, dssPrimary
, ReportWorkItemStatusResponse
, reportWorkItemStatusResponse
, rwisrWorkItemServiceStates
, SourceFork
, sourceFork
, sfResidual
, sfPrimarySource
, sfPrimary
, sfResidualSource
, StreamingComputationRanges
, streamingComputationRanges
, scrRangeAssignments
, scrComputationId
, ListJobsResponse
, listJobsResponse
, ljrNextPageToken
, ljrJobs
, Source
, source
, souDoesNotNeedSplitting
, souBaseSpecs
, souCodec
, souSpec
, souMetadata
, ApproximateProgress
, approximateProgress
, apRemainingTime
, apPercentComplete
, apPosition
, WorkerMessage
, workerMessage
, wmWorkerHealthReport
, wmTime
, wmWorkerMessageCode
, wmLabels
, KeyRangeLocation
, keyRangeLocation
, krlPersistentDirectory
, krlDataDisk
, krlStart
, krlDeliveryEndpoint
, krlEnd
, MultiOutputInfo
, multiOutputInfo
, moiTag
, PartialGroupByKeyInstruction
, partialGroupByKeyInstruction
, pgbkiValueCombiningFn
, pgbkiSideInputs
, pgbkiInput
, pgbkiOriginalCombineValuesStepName
, pgbkiInputElementCodec
, pgbkiOriginalCombineValuesInputStoreName
, ParDoInstruction
, parDoInstruction
, pdiNumOutputs
, pdiMultiOutputInfos
, pdiSideInputs
, pdiInput
, pdiUserFn
, CustomSourceLocation
, customSourceLocation
, cslStateful
, SourceBaseSpecsItem
, sourceBaseSpecsItem
, sbsiAddtional
, ParallelInstruction
, parallelInstruction
, piRead
, piWrite
, piParDo
, piPartialGroupByKey
, piOutputs
, piName
, piSystemName
, piFlatten
, piOriginalName
, SideInputInfoKind
, sideInputInfoKind
, siikAddtional
, StreamingConfigTask
, streamingConfigTask
, sctUserStepToStateFamilyNameMap
, sctStreamingComputationConfigs
, MetricShortId
, metricShortId
, msiShortId
, msiMetricIndex
, SendWorkerMessagesRequest
, sendWorkerMessagesRequest
, swmrWorkerMessages
, SourceSplitShard
, sourceSplitShard
, sssDerivationMode
, sssSource
, SideInputInfo
, sideInputInfo
, siiTag
, siiKind
, siiSources
, JobExecutionInfo
, jobExecutionInfo
, jeiStages
, SourceCodec
, sourceCodec
, souAddtional
, StateFamilyConfig
, stateFamilyConfig
, sfcIsRead
, sfcStateFamily
, KeyRangeDataDiskAssignment
, keyRangeDataDiskAssignment
, krddaDataDisk
, krddaStart
, krddaEnd
, SourceSplitRequest
, sourceSplitRequest
, ssrSource
, ssrOptions
, ListJobMessagesResponse
, listJobMessagesResponse
, ljmrJobMessages
, ljmrNextPageToken
, PubsubLocation
, pubsubLocation
, plTrackingSubscription
, plDropLateData
, plTimestampLabel
, plIdLabel
, plTopic
, plSubscription
, FloatingPointList
, floatingPointList
, fplElements
, InstructionInput
, instructionInput
, iiProducerInstructionIndex
, iiOutputNum
, SeqMapTask
, seqMapTask
, smtInputs
, smtName
, smtOutputInfos
, smtSystemName
, smtStageName
, smtUserFn
, StreamingConfigTaskUserStepToStateFamilyNameMap
, streamingConfigTaskUserStepToStateFamilyNameMap
, sctustsfnmAddtional
, SourceOperationRequest
, sourceOperationRequest
, sSplit
, sGetMetadata
, LeaseWorkItemResponse
, leaseWorkItemResponse
, lwirWorkItems
, Position
, position
, pByteOffSet
, pConcatPosition
, pRecordIndex
, pShufflePosition
, pKey
, pEnd
) where
import Network.Google.Dataflow.Types
import Network.Google.Prelude
import Network.Google.Resource.Dataflow.Projects.Jobs.Create
import Network.Google.Resource.Dataflow.Projects.Jobs.Debug.GetConfig
import Network.Google.Resource.Dataflow.Projects.Jobs.Debug.SendCapture
import Network.Google.Resource.Dataflow.Projects.Jobs.Get
import Network.Google.Resource.Dataflow.Projects.Jobs.GetMetrics
import Network.Google.Resource.Dataflow.Projects.Jobs.List
import Network.Google.Resource.Dataflow.Projects.Jobs.Messages.List
import Network.Google.Resource.Dataflow.Projects.Jobs.Update
import Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.Lease
import Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.ReportStatus
import Network.Google.Resource.Dataflow.Projects.Templates.Create
import Network.Google.Resource.Dataflow.Projects.WorkerMessages
type DataflowAPI =
ProjectsTemplatesCreateResource :<|>
ProjectsJobsDebugGetConfigResource
:<|> ProjectsJobsDebugSendCaptureResource
:<|> ProjectsJobsWorkItemsLeaseResource
:<|> ProjectsJobsWorkItemsReportStatusResource
:<|> ProjectsJobsMessagesListResource
:<|> ProjectsJobsListResource
:<|> ProjectsJobsGetResource
:<|> ProjectsJobsCreateResource
:<|> ProjectsJobsUpdateResource
:<|> ProjectsJobsGetMetricsResource
:<|> ProjectsWorkerMessagesResource