summaryrefslogtreecommitdiff
path: root/gen/Network/Google/Dataflow/Types.hs
diff options
context:
space:
mode:
Diffstat (limited to 'gen/Network/Google/Dataflow/Types.hs')
-rw-r--r--gen/Network/Google/Dataflow/Types.hs721
1 files changed, 721 insertions, 0 deletions
diff --git a/gen/Network/Google/Dataflow/Types.hs b/gen/Network/Google/Dataflow/Types.hs
new file mode 100644
index 0000000..852ee89
--- /dev/null
+++ b/gen/Network/Google/Dataflow/Types.hs
@@ -0,0 +1,721 @@
+{-# LANGUAGE DeriveDataTypeable #-}
+{-# LANGUAGE DeriveGeneric #-}
+{-# LANGUAGE NoImplicitPrelude #-}
+{-# LANGUAGE OverloadedStrings #-}
+
+{-# OPTIONS_GHC -fno-warn-unused-imports #-}
+
+-- |
+-- Module : Network.Google.Dataflow.Types
+-- 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)
+--
+module Network.Google.Dataflow.Types
+ (
+ -- * Service Configuration
+ dataflowService
+
+ -- * OAuth Scopes
+ , userinfoEmailScope
+ , cloudPlatformScope
+
+ -- * 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.Product
+import Network.Google.Dataflow.Types.Sum
+import Network.Google.Prelude
+
+-- | Default request referring to version 'v1b3' of the Google Dataflow API. This contains the host and root path used as a starting point for constructing service requests.
+dataflowService :: Service
+dataflowService
+ = defaultService (ServiceId "dataflow:v1b3")
+ "dataflow.googleapis.com"
+
+-- | View your email address
+userinfoEmailScope :: OAuthScope
+userinfoEmailScope = "https://www.googleapis.com/auth/userinfo.email";
+
+-- | View and manage your data across Google Cloud Platform services
+cloudPlatformScope :: OAuthScope
+cloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";