module Network.Google.Dataflow.Types
(
dataflowService
, userInfoEmailScope
, cloudPlatformScope
, JobExecutionInfoStages
, jobExecutionInfoStages
, jeisAddtional
, ComputationTopology
, computationTopology
, ctStateFamilies
, ctUserStageName
, ctInputs
, ctKeyRanges
, ctOutputs
, ctComputationId
, ctSystemStageName
, SourceSplitResponse
, sourceSplitResponse
, ssrBundles
, ssrShards
, ssrOutcome
, Status
, status
, sDetails
, sCode
, sMessage
, WorkItem
, workItem
, wiJobId
, wiReportStatusInterval
, wiShellTask
, wiStreamingSetupTask
, wiInitialReportIndex
, wiMapTask
, wiPackages
, wiStreamingComputationTask
, wiSourceOperationTask
, wiId
, wiProjectId
, wiLeaseExpireTime
, wiConfiguration
, wiSeqMapTask
, WorkerHealthReport
, workerHealthReport
, whrVMIsHealthy
, whrReportInterval
, whrPods
, whrVMStartupTime
, SourceSplitOptions
, sourceSplitOptions
, ssoDesiredShardSizeBytes
, ssoDesiredBundleSizeBytes
, WorkerPoolMetadata
, workerPoolMetadata
, wpmAddtional
, AutoscalingSettings
, autoscalingSettings
, asMaxNumWorkers
, asAlgorithm
, JobExecutionStageInfo
, jobExecutionStageInfo
, jesiStepName
, InstructionOutput
, instructionOutput
, ioCodec
, ioName
, ioSystemName
, ReportWorkItemStatusRequest
, reportWorkItemStatusRequest
, rwisrCurrentWorkerTime
, rwisrWorkItemStatuses
, rwisrWorkerId
, EnvironmentVersion
, environmentVersion
, evAddtional
, Sink
, sink
, sCodec
, sSpec
, WorkerHealthReportResponse
, workerHealthReportResponse
, whrrReportInterval
, MetricStructuredName
, metricStructuredName
, msnOrigin
, msnContext
, msnName
, 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
, eUserAgent
, eSdkPipelineOptions
, ConcatPosition
, concatPosition
, cpIndex
, cpPosition
, MetricStructuredNameContext
, metricStructuredNameContext
, msncAddtional
, StreamingStageLocation
, streamingStageLocation
, sslStreamId
, DerivedSource
, derivedSource
, dsDerivationMode
, dsSource
, JobMetrics
, jobMetrics
, jmMetrics
, jmMetricTime
, WorkItemStatus
, workItemStatus
, wisReportedProgress
, wisProgress
, wisSourceOperationResponse
, wisStopPosition
, wisDynamicSourceSplit
, wisCompleted
, wisSourceFork
, wisReportIndex
, wisRequestedLeaseDuration
, wisErrors
, 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
, EnvironmentSdkPipelineOptions
, environmentSdkPipelineOptions
, espoAddtional
, 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
, WorkerSettings
, workerSettings
, wsServicePath
, wsBaseURL
, wsShuffleServicePath
, wsTempStoragePrefix
, wsReportingEnabled
, wsWorkerId
, WorkItemServiceStateHarnessData
, workItemServiceStateHarnessData
, wisshdAddtional
, DataDiskAssignment
, dataDiskAssignment
, ddaVMInstance
, ddaDataDisks
, WorkerMessageResponse
, workerMessageResponse
, wmrWorkerHealthReportResponse
, WorkItemServiceState
, workItemServiceState
, wissNextReportIndex
, wissReportStatusInterval
, wissHarnessData
, wissSuggestedStopPoint
, wissSuggestedStopPosition
, wissLeaseExpireTime
, wissSplitRequest
, StreamingSetupTask
, streamingSetupTask
, sstStreamingComputationTopology
, sstReceiveWorkPort
, sstWorkerHarnessPort
, sstDrain
, PartialGroupByKeyInstructionInputElementCodec
, partialGroupByKeyInstructionInputElementCodec
, pgbkiiecAddtional
, MapTask
, mapTask
, mtInstructions
, mtSystemName
, mtStageName
, MountedDataDisk
, mountedDataDisk
, mddDataDisk
, SinkCodec
, sinkCodec
, scAddtional
, WorkerHealthReportPodsItem
, workerHealthReportPodsItem
, whrpiAddtional
, ParDoInstructionUserFn
, parDoInstructionUserFn
, pdiufAddtional
, InstructionOutputCodec
, instructionOutputCodec
, iocAddtional
, StreamLocation
, streamLocation
, slStreamingStageLocation
, slSideInputLocation
, slCustomSourceLocation
, slPubsubLocation
, WorkerPoolPoolArgs
, workerPoolPoolArgs
, wppaAddtional
, SendWorkerMessagesResponse
, sendWorkerMessagesResponse
, swmrWorkerMessageResponses
, StreamingSideInputLocation
, streamingSideInputLocation
, ssilTag
, ssilStateFamily
, 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
, 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
, 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
, pgbkiInputElementCodec
, ParDoInstruction
, parDoInstruction
, pdiNumOutputs
, pdiMultiOutputInfos
, pdiSideInputs
, pdiInput
, pdiUserFn
, CustomSourceLocation
, customSourceLocation
, cslStateful
, SourceBaseSpecsItem
, sourceBaseSpecsItem
, sbsiAddtional
, ParallelInstruction
, parallelInstruction
, piRead
, piWrite
, piParDo
, piPartialGroupByKey
, piOutputs
, piName
, piSystemName
, piFlatten
, SideInputInfoKind
, sideInputInfoKind
, siikAddtional
, 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
, InstructionInput
, instructionInput
, iiProducerInstructionIndex
, iiOutputNum
, SeqMapTask
, seqMapTask
, smtInputs
, smtName
, smtOutputInfos
, smtSystemName
, smtStageName
, smtUserFn
, SourceOperationRequest
, sourceOperationRequest
, sSplit
, sGetMetadata
, LeaseWorkItemResponse
, leaseWorkItemResponse
, lwirWorkItems
, Position
, position
, pByteOffSet
, pConcatPosition
, pRecordIndex
, pShufflePosition
, pKey
, pEnd
) where
import Network.Google.Dataflow.Types.Product
import Network.Google.Dataflow.Types.Sum
import Network.Google.Prelude
dataflowService :: ServiceConfig
dataflowService
= defaultService (ServiceId "dataflow:v1b3")
"dataflow.googleapis.com"
userInfoEmailScope :: Proxy '["https://www.googleapis.com/auth/userinfo.email"]
userInfoEmailScope = Proxy;
cloudPlatformScope :: Proxy '["https://www.googleapis.com/auth/cloud-platform"]
cloudPlatformScope = Proxy;