1 files changed, 759 insertions, 0 deletions
diff --git a/gen/Network/Google/Dataflow.hs b/gen/Network/Google/Dataflow.hs
new file mode 100644
index 0000000..b1d49df
--- /dev/null
+++ b/gen/Network/Google/Dataflow.hs
@@ -0,0 +1,759 @@
+{-# LANGUAGE DataKinds         #-}
+{-# LANGUAGE NoImplicitPrelude #-}
+{-# LANGUAGE TypeOperators     #-}
+
+{-# OPTIONS_GHC -fno-warn-unused-imports    #-}
+{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}
+
+-- |
+-- Module      : Network.Google.Dataflow
+-- Copyright   : (c) 2015 Brendan Hay
+-- License     : Mozilla Public License, v. 2.0.
+-- Maintainer  : Brendan Hay <brendan.g.hay@gmail.com>
+-- Stability   : auto-generated
+-- Portability : non-portable (GHC extensions)
+--
+-- Google Dataflow API.
+--
+-- /See:/ <https://cloud.google.com/dataflow Google Dataflow API Reference>
+module Network.Google.Dataflow
+    (
+    -- * Service Configuration
+      dataflowService
+
+    -- * API Declaration
+    , DataflowAPI
+
+    -- * Resources
+
+    -- ** dataflow.projects.jobs.create
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.Create
+
+    -- ** dataflow.projects.jobs.get
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.Get
+
+    -- ** dataflow.projects.jobs.getMetrics
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.GetMetrics
+
+    -- ** dataflow.projects.jobs.list
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.List
+
+    -- ** dataflow.projects.jobs.messages.list
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.Messages.List
+
+    -- ** dataflow.projects.jobs.update
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.Update
+
+    -- ** dataflow.projects.jobs.workItems.lease
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.Lease
+
+    -- ** dataflow.projects.jobs.workItems.reportStatus
+    , module Network.Google.Resource.Dataflow.Projects.Jobs.WorkItems.ReportStatus
+
+    -- * Types
+
+    -- ** JobExecutionInfoStages
+    , JobExecutionInfoStages
+    , jobExecutionInfoStages
+    , jeisAddtional
+
+    -- ** ComputationTopology
+    , ComputationTopology
+    , computationTopology
+    , ctStateFamilies
+    , ctUserStageName
+    , ctInputs
+    , ctKeyRanges
+    , ctOutputs
+    , ctComputationId
+    , ctSystemStageName
+
+    -- ** SourceSplitResponse
+    , SourceSplitResponse
+    , sourceSplitResponse
+    , ssrBundles
+    , ssrShards
+    , ssrOutcome
+
+    -- ** Status
+    , Status
+    , status
+    , sDetails
+    , sCode
+    , sMessage
+
+    -- ** WorkItem
+    , WorkItem
+    , workItem
+    , wiJobId
+    , wiReportStatusInterval
+    , wiShellTask
+    , wiStreamingSetupTask
+    , wiInitialReportIndex
+    , wiMapTask
+    , wiPackages
+    , wiStreamingComputationTask
+    , wiSourceOperationTask
+    , wiId
+    , wiProjectId
+    , wiLeaseExpireTime
+    , wiConfiguration
+    , wiSeqMapTask
+
+    -- ** SourceSplitOptions
+    , SourceSplitOptions
+    , sourceSplitOptions
+    , ssoDesiredShardSizeBytes
+    , ssoDesiredBundleSizeBytes
+
+    -- ** WorkerPoolMetadata
+    , WorkerPoolMetadata
+    , workerPoolMetadata
+    , wpmAddtional
+
+    -- ** AutoscalingSettings
+    , AutoscalingSettings
+    , autoscalingSettings
+    , asMaxNumWorkers
+    , asAlgorithm
+
+    -- ** JobExecutionStageInfo
+    , JobExecutionStageInfo
+    , jobExecutionStageInfo
+    , jesiStepName
+
+    -- ** InstructionOutput
+    , InstructionOutput
+    , instructionOutput
+    , ioCodec
+    , ioName
+    , ioSystemName
+
+    -- ** ReportWorkItemStatusRequest
+    , ReportWorkItemStatusRequest
+    , reportWorkItemStatusRequest
+    , rwisrCurrentWorkerTime
+    , rwisrWorkItemStatuses
+    , rwisrWorkerId
+
+    -- ** EnvironmentVersion
+    , EnvironmentVersion
+    , environmentVersion
+    , evAddtional
+
+    -- ** Sink
+    , Sink
+    , sink
+    , sCodec
+    , sSpec
+
+    -- ** MetricStructuredName
+    , MetricStructuredName
+    , metricStructuredName
+    , msnOrigin
+    , msnContext
+    , msnName
+
+    -- ** WriteInstruction
+    , WriteInstruction
+    , writeInstruction
+    , wiSink
+    , wiInput
+
+    -- ** EnvironmentUserAgent
+    , EnvironmentUserAgent
+    , environmentUserAgent
+    , euaAddtional
+
+    -- ** Disk
+    , Disk
+    , disk
+    , dSizeGb
+    , dDiskType
+    , dMountPoint
+
+    -- ** MetricUpdate
+    , MetricUpdate
+    , metricUpdate
+    , muMeanSum
+    , muInternal
+    , muSet
+    , muCumulative
+    , muKind
+    , muUpdateTime
+    , muMeanCount
+    , muName
+    , muScalar
+
+    -- ** SourceGetMetadataResponse
+    , SourceGetMetadataResponse
+    , sourceGetMetadataResponse
+    , sgmrMetadata
+
+    -- ** Environment
+    , Environment
+    , environment
+    , eDataSet
+    , eExperiments
+    , eWorkerPools
+    , eClusterManagerAPIService
+    , eVersion
+    , eInternalExperiments
+    , eTempStoragePrefix
+    , eUserAgent
+    , eSdkPipelineOptions
+
+    -- ** ConcatPosition
+    , ConcatPosition
+    , concatPosition
+    , cpIndex
+    , cpPosition
+
+    -- ** MetricStructuredNameContext
+    , MetricStructuredNameContext
+    , metricStructuredNameContext
+    , msncAddtional
+
+    -- ** StreamingStageLocation
+    , StreamingStageLocation
+    , streamingStageLocation
+    , sslStreamId
+
+    -- ** DerivedSource
+    , DerivedSource
+    , derivedSource
+    , dsDerivationMode
+    , dsSource
+
+    -- ** JobMetrics
+    , JobMetrics
+    , jobMetrics
+    , jmMetrics
+    , jmMetricTime
+
+    -- ** WorkItemStatus
+    , WorkItemStatus
+    , workItemStatus
+    , wisProgress
+    , wisSourceOperationResponse
+    , wisStopPosition
+    , wisDynamicSourceSplit
+    , wisCompleted
+    , wisSourceFork
+    , wisReportIndex
+    , wisRequestedLeaseDuration
+    , wisErrors
+    , wisMetricUpdates
+    , wisWorkItemId
+
+    -- ** FlattenInstruction
+    , FlattenInstruction
+    , flattenInstruction
+    , fiInputs
+
+    -- ** JobTransformNameMApping
+    , JobTransformNameMApping
+    , jobTransformNameMApping
+    , jtnmaAddtional
+
+    -- ** SourceSpec
+    , SourceSpec
+    , sourceSpec
+    , ssAddtional
+
+    -- ** SourceMetadata
+    , SourceMetadata
+    , sourceMetadata
+    , smEstimatedSizeBytes
+    , smProducesSortedKeys
+    , smInfinite
+
+    -- ** EnvironmentInternalExperiments
+    , EnvironmentInternalExperiments
+    , environmentInternalExperiments
+    , eieAddtional
+
+    -- ** TaskRunnerSettings
+    , TaskRunnerSettings
+    , taskRunnerSettings
+    , trsContinueOnException
+    , trsHarnessCommand
+    , trsWorkflowFileName
+    , trsTaskGroup
+    , trsAlsologtostderr
+    , trsDataflowAPIVersion
+    , trsLogDir
+    , trsCommandlinesFileName
+    , trsVMId
+    , trsBaseURL
+    , trsOAuthScopes
+    , trsTaskUser
+    , trsStreamingWorkerMainClass
+    , trsBaseTaskDir
+    , trsLogUploadLocation
+    , trsTempStoragePrefix
+    , trsLogToSerialconsole
+    , trsParallelWorkerSettings
+    , trsLanguageHint
+
+    -- ** EnvironmentSdkPipelineOptions
+    , EnvironmentSdkPipelineOptions
+    , environmentSdkPipelineOptions
+    , espoAddtional
+
+    -- ** LeaseWorkItemRequest
+    , LeaseWorkItemRequest
+    , leaseWorkItemRequest
+    , lwirWorkItemTypes
+    , lwirCurrentWorkerTime
+    , lwirWorkerCapabilities
+    , lwirRequestedLeaseDuration
+    , lwirWorkerId
+
+    -- ** SourceOperationResponse
+    , SourceOperationResponse
+    , sourceOperationResponse
+    , sorSplit
+    , sorGetMetadata
+
+    -- ** TopologyConfigUserStageToComputationNameMap
+    , TopologyConfigUserStageToComputationNameMap
+    , topologyConfigUserStageToComputationNameMap
+    , tcustcnmAddtional
+
+    -- ** ShellTask
+    , ShellTask
+    , shellTask
+    , stCommand
+    , stExitCode
+
+    -- ** StatusDetailsItem
+    , StatusDetailsItem
+    , statusDetailsItem
+    , sdiAddtional
+
+    -- ** StepProperties
+    , StepProperties
+    , stepProperties
+    , spAddtional
+
+    -- ** TopologyConfig
+    , TopologyConfig
+    , topologyConfig
+    , tcDataDiskAssignments
+    , tcUserStageToComputationNameMap
+    , tcComputations
+
+    -- ** WorkerSettings
+    , WorkerSettings
+    , workerSettings
+    , wsServicePath
+    , wsBaseURL
+    , wsShuffleServicePath
+    , wsTempStoragePrefix
+    , wsReportingEnabled
+    , wsWorkerId
+
+    -- ** WorkItemServiceStateHarnessData
+    , WorkItemServiceStateHarnessData
+    , workItemServiceStateHarnessData
+    , wisshdAddtional
+
+    -- ** DataDiskAssignment
+    , DataDiskAssignment
+    , dataDiskAssignment
+    , ddaVMInstance
+    , ddaDataDisks
+
+    -- ** WorkItemServiceState
+    , WorkItemServiceState
+    , workItemServiceState
+    , wissNextReportIndex
+    , wissReportStatusInterval
+    , wissHarnessData
+    , wissSuggestedStopPoint
+    , wissSuggestedStopPosition
+    , wissLeaseExpireTime
+
+    -- ** StreamingSetupTask
+    , StreamingSetupTask
+    , streamingSetupTask
+    , sstStreamingComputationTopology
+    , sstReceiveWorkPort
+    , sstWorkerHarnessPort
+
+    -- ** PartialGroupByKeyInstructionInputElementCodec
+    , PartialGroupByKeyInstructionInputElementCodec
+    , partialGroupByKeyInstructionInputElementCodec
+    , pgbkiiecAddtional
+
+    -- ** MapTask
+    , MapTask
+    , mapTask
+    , mtInstructions
+    , mtSystemName
+    , mtStageName
+
+    -- ** MountedDataDisk
+    , MountedDataDisk
+    , mountedDataDisk
+    , mddDataDisk
+
+    -- ** SinkCodec
+    , SinkCodec
+    , sinkCodec
+    , scAddtional
+
+    -- ** ParDoInstructionUserFn
+    , ParDoInstructionUserFn
+    , parDoInstructionUserFn
+    , pdiufAddtional
+
+    -- ** InstructionOutputCodec
+    , InstructionOutputCodec
+    , instructionOutputCodec
+    , iocAddtional
+
+    -- ** StreamLocation
+    , StreamLocation
+    , streamLocation
+    , slStreamingStageLocation
+    , slSideInputLocation
+    , slCustomSourceLocation
+    , slPubsubLocation
+
+    -- ** WorkerPoolPoolArgs
+    , WorkerPoolPoolArgs
+    , workerPoolPoolArgs
+    , wppaAddtional
+
+    -- ** StreamingSideInputLocation
+    , StreamingSideInputLocation
+    , streamingSideInputLocation
+    , ssilTag
+    , ssilStateFamily
+
+    -- ** StreamingComputationTask
+    , StreamingComputationTask
+    , streamingComputationTask
+    , sctTaskType
+    , sctDataDisks
+    , sctComputationRanges
+
+    -- ** JobMessage
+    , JobMessage
+    , jobMessage
+    , jmTime
+    , jmMessageText
+    , jmMessageImportance
+    , jmId
+
+    -- ** SeqMapTaskOutputInfo
+    , SeqMapTaskOutputInfo
+    , seqMapTaskOutputInfo
+    , smtoiSink
+    , smtoiTag
+
+    -- ** SourceGetMetadataRequest
+    , SourceGetMetadataRequest
+    , sourceGetMetadataRequest
+    , sgmrSource
+
+    -- ** SeqMapTaskUserFn
+    , SeqMapTaskUserFn
+    , seqMapTaskUserFn
+    , smtufAddtional
+
+    -- ** PartialGroupByKeyInstructionValueCombiningFn
+    , PartialGroupByKeyInstructionValueCombiningFn
+    , partialGroupByKeyInstructionValueCombiningFn
+    , pgbkivcfAddtional
+
+    -- ** Job
+    , Job
+    , job
+    , jRequestedState
+    , jEnvironment
+    , jClientRequestId
+    , jCurrentState
+    , jReplacedByJobId
+    , jSteps
+    , jExecutionInfo
+    , jName
+    , jTransformNameMApping
+    , jId
+    , jProjectId
+    , jType
+    , jCurrentStateTime
+    , jReplaceJobId
+    , jCreateTime
+
+    -- ** ReadInstruction
+    , ReadInstruction
+    , readInstruction
+    , riSource
+
+    -- ** SinkSpec
+    , SinkSpec
+    , sinkSpec
+    , sAddtional
+
+    -- ** WorkerPool
+    , WorkerPool
+    , workerPool
+    , wpAutoscalingSettings
+    , wpDiskSizeGb
+    , wpKind
+    , wpTaskrunnerSettings
+    , wpNumWorkers
+    , wpNetwork
+    , wpZone
+    , wpPackages
+    , wpOnHostMaintenance
+    , wpDiskSourceImage
+    , wpMachineType
+    , wpMetadata
+    , wpDiskType
+    , wpTeardownPolicy
+    , wpDefaultPackageSet
+    , wpPoolArgs
+    , wpDataDisks
+
+    -- ** Step
+    , Step
+    , step
+    , sKind
+    , sName
+    , sProperties
+
+    -- ** Package
+    , Package
+    , package
+    , pLocation
+    , pName
+
+    -- ** DynamicSourceSplit
+    , DynamicSourceSplit
+    , dynamicSourceSplit
+    , dssResidual
+    , dssPrimary
+
+    -- ** ReportWorkItemStatusResponse
+    , ReportWorkItemStatusResponse
+    , reportWorkItemStatusResponse
+    , rwisrWorkItemServiceStates
+
+    -- ** SourceFork
+    , SourceFork
+    , sourceFork
+    , sfResidual
+    , sfPrimarySource
+    , sfPrimary
+    , sfResidualSource
+
+    -- ** StreamingComputationRanges
+    , StreamingComputationRanges
+    , streamingComputationRanges
+    , scrRangeAssignments
+    , scrComputationId
+
+    -- ** ListJobsResponse
+    , ListJobsResponse
+    , listJobsResponse
+    , ljrNextPageToken
+    , ljrJobs
+
+    -- ** Source
+    , Source
+    , source
+    , souDoesNotNeedSplitting
+    , souBaseSpecs
+    , souCodec
+    , souSpec
+    , souMetadata
+
+    -- ** ApproximateProgress
+    , ApproximateProgress
+    , approximateProgress
+    , apRemainingTime
+    , apPercentComplete
+    , apPosition
+
+    -- ** KeyRangeLocation
+    , KeyRangeLocation
+    , keyRangeLocation
+    , krlPersistentDirectory
+    , krlDataDisk
+    , krlStart
+    , krlDeliveryEndpoint
+    , krlEnd
+
+    -- ** MultiOutputInfo
+    , MultiOutputInfo
+    , multiOutputInfo
+    , moiTag
+
+    -- ** PartialGroupByKeyInstruction
+    , PartialGroupByKeyInstruction
+    , partialGroupByKeyInstruction
+    , pgbkiValueCombiningFn
+    , pgbkiInput
+    , pgbkiInputElementCodec
+
+    -- ** ParDoInstruction
+    , ParDoInstruction
+    , parDoInstruction
+    , pdiNumOutputs
+    , pdiMultiOutputInfos
+    , pdiSideInputs
+    , pdiInput
+    , pdiUserFn
+
+    -- ** CustomSourceLocation
+    , CustomSourceLocation
+    , customSourceLocation
+    , cslStateful
+
+    -- ** SourceBaseSpecsItem
+    , SourceBaseSpecsItem
+    , sourceBaseSpecsItem
+    , sbsiAddtional
+
+    -- ** ParallelInstruction
+    , ParallelInstruction
+    , parallelInstruction
+    , piRead
+    , piWrite
+    , piParDo
+    , piPartialGroupByKey
+    , piOutputs
+    , piName
+    , piSystemName
+    , piFlatten
+
+    -- ** SideInputInfoKind
+    , SideInputInfoKind
+    , sideInputInfoKind
+    , siikAddtional
+
+    -- ** SourceSplitShard
+    , SourceSplitShard
+    , sourceSplitShard
+    , sssDerivationMode
+    , sssSource
+
+    -- ** SideInputInfo
+    , SideInputInfo
+    , sideInputInfo
+    , siiTag
+    , siiKind
+    , siiSources
+
+    -- ** JobExecutionInfo
+    , JobExecutionInfo
+    , jobExecutionInfo
+    , jeiStages
+
+    -- ** SourceCodec
+    , SourceCodec
+    , sourceCodec
+    , souAddtional
+
+    -- ** StateFamilyConfig
+    , StateFamilyConfig
+    , stateFamilyConfig
+    , sfcIsRead
+    , sfcStateFamily
+
+    -- ** KeyRangeDataDiskAssignment
+    , KeyRangeDataDiskAssignment
+    , keyRangeDataDiskAssignment
+    , krddaDataDisk
+    , krddaStart
+    , krddaEnd
+
+    -- ** SourceSplitRequest
+    , SourceSplitRequest
+    , sourceSplitRequest
+    , ssrSource
+    , ssrOptions
+
+    -- ** ListJobMessagesResponse
+    , ListJobMessagesResponse
+    , listJobMessagesResponse
+    , ljmrJobMessages
+    , ljmrNextPageToken
+
+    -- ** PubsubLocation
+    , PubsubLocation
+    , pubsubLocation
+    , plTrackingSubscription
+    , plDropLateData
+    , plTimestampLabel
+    , plIdLabel
+    , plTopic
+    , plSubscription
+
+    -- ** InstructionInput
+    , InstructionInput
+    , instructionInput
+    , iiProducerInstructionIndex
+    , iiOutputNum
+
+    -- ** SeqMapTask
+    , SeqMapTask
+    , seqMapTask
+    , smtInputs
+    , smtName
+    , smtOutputInfos
+    , smtSystemName
+    , smtStageName
+    , smtUserFn
+
+    -- ** SourceOperationRequest
+    , SourceOperationRequest
+    , sourceOperationRequest
+    , sSplit
+    , sGetMetadata
+
+    -- ** LeaseWorkItemResponse
+    , LeaseWorkItemResponse
+    , leaseWorkItemResponse
+    , lwirWorkItems
+
+    -- ** Position
+    , 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.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
+
+{- $resources
+TODO
+-}
+
+-- | Represents the entirety of the methods and resources available for the Google Dataflow API service.
+type DataflowAPI =
+     ProjectsJobsWorkItemsLeaseResource :<|>
+       ProjectsJobsWorkItemsReportStatusResource
+       :<|> ProjectsJobsMessagesListResource
+       :<|> ProjectsJobsListResource
+       :<|> ProjectsJobsGetResource
+       :<|> ProjectsJobsCreateResource
+       :<|> ProjectsJobsUpdateResource
+       :<|> ProjectsJobsGetMetricsResource