{-# LANGUAGE DeriveDataTypeable #-}
{-# LANGUAGE DeriveGeneric #-}
{-# LANGUAGE NoImplicitPrelude #-}
{-# LANGUAGE OverloadedStrings #-}
{-# LANGUAGE RecordWildCards #-}
{-# OPTIONS_GHC -fno-warn-unused-binds #-}
{-# OPTIONS_GHC -fno-warn-unused-imports #-}
module Network.Google.Dataflow.Types.Product where
import Network.Google.Dataflow.Types.Sum
import Network.Google.Prelude
newtype JobExecutionInfoStages = JobExecutionInfoStages'
{ _jeisAddtional :: HashMap Text JobExecutionStageInfo
} deriving (Eq,Show,Data,Typeable,Generic)
jobExecutionInfoStages
:: HashMap Text JobExecutionStageInfo
-> JobExecutionInfoStages
jobExecutionInfoStages pJeisAddtional_ =
JobExecutionInfoStages'
{ _jeisAddtional = _Coerce # pJeisAddtional_
}
jeisAddtional :: Lens' JobExecutionInfoStages (HashMap Text JobExecutionStageInfo)
jeisAddtional
= lens _jeisAddtional
(\ s a -> s{_jeisAddtional = a})
. _Coerce
instance FromJSON JobExecutionInfoStages where
parseJSON
= withObject "JobExecutionInfoStages"
(\ o ->
JobExecutionInfoStages' <$> (parseJSONObject o))
instance ToJSON JobExecutionInfoStages where
toJSON = toJSON . _jeisAddtional
data ComputationTopology = ComputationTopology'
{ _ctStateFamilies :: !(Maybe [StateFamilyConfig])
, _ctUserStageName :: !(Maybe Text)
, _ctInputs :: !(Maybe [StreamLocation])
, _ctKeyRanges :: !(Maybe [KeyRangeLocation])
, _ctOutputs :: !(Maybe [StreamLocation])
, _ctComputationId :: !(Maybe Text)
, _ctSystemStageName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
computationTopology
:: ComputationTopology
computationTopology =
ComputationTopology'
{ _ctStateFamilies = Nothing
, _ctUserStageName = Nothing
, _ctInputs = Nothing
, _ctKeyRanges = Nothing
, _ctOutputs = Nothing
, _ctComputationId = Nothing
, _ctSystemStageName = Nothing
}
ctStateFamilies :: Lens' ComputationTopology [StateFamilyConfig]
ctStateFamilies
= lens _ctStateFamilies
(\ s a -> s{_ctStateFamilies = a})
. _Default
. _Coerce
ctUserStageName :: Lens' ComputationTopology (Maybe Text)
ctUserStageName
= lens _ctUserStageName
(\ s a -> s{_ctUserStageName = a})
ctInputs :: Lens' ComputationTopology [StreamLocation]
ctInputs
= lens _ctInputs (\ s a -> s{_ctInputs = a}) .
_Default
. _Coerce
ctKeyRanges :: Lens' ComputationTopology [KeyRangeLocation]
ctKeyRanges
= lens _ctKeyRanges (\ s a -> s{_ctKeyRanges = a}) .
_Default
. _Coerce
ctOutputs :: Lens' ComputationTopology [StreamLocation]
ctOutputs
= lens _ctOutputs (\ s a -> s{_ctOutputs = a}) .
_Default
. _Coerce
ctComputationId :: Lens' ComputationTopology (Maybe Text)
ctComputationId
= lens _ctComputationId
(\ s a -> s{_ctComputationId = a})
ctSystemStageName :: Lens' ComputationTopology (Maybe Text)
ctSystemStageName
= lens _ctSystemStageName
(\ s a -> s{_ctSystemStageName = a})
instance FromJSON ComputationTopology where
parseJSON
= withObject "ComputationTopology"
(\ o ->
ComputationTopology' <$>
(o .:? "stateFamilies" .!= mempty) <*>
(o .:? "userStageName")
<*> (o .:? "inputs" .!= mempty)
<*> (o .:? "keyRanges" .!= mempty)
<*> (o .:? "outputs" .!= mempty)
<*> (o .:? "computationId")
<*> (o .:? "systemStageName"))
instance ToJSON ComputationTopology where
toJSON ComputationTopology'{..}
= object
(catMaybes
[("stateFamilies" .=) <$> _ctStateFamilies,
("userStageName" .=) <$> _ctUserStageName,
("inputs" .=) <$> _ctInputs,
("keyRanges" .=) <$> _ctKeyRanges,
("outputs" .=) <$> _ctOutputs,
("computationId" .=) <$> _ctComputationId,
("systemStageName" .=) <$> _ctSystemStageName])
data SourceSplitResponse = SourceSplitResponse'
{ _ssrBundles :: !(Maybe [DerivedSource])
, _ssrShards :: !(Maybe [SourceSplitShard])
, _ssrOutcome :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceSplitResponse
:: SourceSplitResponse
sourceSplitResponse =
SourceSplitResponse'
{ _ssrBundles = Nothing
, _ssrShards = Nothing
, _ssrOutcome = Nothing
}
ssrBundles :: Lens' SourceSplitResponse [DerivedSource]
ssrBundles
= lens _ssrBundles (\ s a -> s{_ssrBundles = a}) .
_Default
. _Coerce
ssrShards :: Lens' SourceSplitResponse [SourceSplitShard]
ssrShards
= lens _ssrShards (\ s a -> s{_ssrShards = a}) .
_Default
. _Coerce
ssrOutcome :: Lens' SourceSplitResponse (Maybe Text)
ssrOutcome
= lens _ssrOutcome (\ s a -> s{_ssrOutcome = a})
instance FromJSON SourceSplitResponse where
parseJSON
= withObject "SourceSplitResponse"
(\ o ->
SourceSplitResponse' <$>
(o .:? "bundles" .!= mempty) <*>
(o .:? "shards" .!= mempty)
<*> (o .:? "outcome"))
instance ToJSON SourceSplitResponse where
toJSON SourceSplitResponse'{..}
= object
(catMaybes
[("bundles" .=) <$> _ssrBundles,
("shards" .=) <$> _ssrShards,
("outcome" .=) <$> _ssrOutcome])
data CreateJobFromTemplateRequest = CreateJobFromTemplateRequest'
{ _cjftrGcsPath :: !(Maybe Text)
, _cjftrParameters :: !(Maybe CreateJobFromTemplateRequestParameters)
} deriving (Eq,Show,Data,Typeable,Generic)
createJobFromTemplateRequest
:: CreateJobFromTemplateRequest
createJobFromTemplateRequest =
CreateJobFromTemplateRequest'
{ _cjftrGcsPath = Nothing
, _cjftrParameters = Nothing
}
cjftrGcsPath :: Lens' CreateJobFromTemplateRequest (Maybe Text)
cjftrGcsPath
= lens _cjftrGcsPath (\ s a -> s{_cjftrGcsPath = a})
cjftrParameters :: Lens' CreateJobFromTemplateRequest (Maybe CreateJobFromTemplateRequestParameters)
cjftrParameters
= lens _cjftrParameters
(\ s a -> s{_cjftrParameters = a})
instance FromJSON CreateJobFromTemplateRequest where
parseJSON
= withObject "CreateJobFromTemplateRequest"
(\ o ->
CreateJobFromTemplateRequest' <$>
(o .:? "gcsPath") <*> (o .:? "parameters"))
instance ToJSON CreateJobFromTemplateRequest where
toJSON CreateJobFromTemplateRequest'{..}
= object
(catMaybes
[("gcsPath" .=) <$> _cjftrGcsPath,
("parameters" .=) <$> _cjftrParameters])
data Status = Status'
{ _sDetails :: !(Maybe [StatusDetailsItem])
, _sCode :: !(Maybe (Textual Int32))
, _sMessage :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
status
:: Status
status =
Status'
{ _sDetails = Nothing
, _sCode = Nothing
, _sMessage = Nothing
}
sDetails :: Lens' Status [StatusDetailsItem]
sDetails
= lens _sDetails (\ s a -> s{_sDetails = a}) .
_Default
. _Coerce
sCode :: Lens' Status (Maybe Int32)
sCode
= lens _sCode (\ s a -> s{_sCode = a}) .
mapping _Coerce
sMessage :: Lens' Status (Maybe Text)
sMessage = lens _sMessage (\ s a -> s{_sMessage = a})
instance FromJSON Status where
parseJSON
= withObject "Status"
(\ o ->
Status' <$>
(o .:? "details" .!= mempty) <*> (o .:? "code") <*>
(o .:? "message"))
instance ToJSON Status where
toJSON Status'{..}
= object
(catMaybes
[("details" .=) <$> _sDetails,
("code" .=) <$> _sCode,
("message" .=) <$> _sMessage])
data NameAndKind = NameAndKind'
{ _nakKind :: !(Maybe Text)
, _nakName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
nameAndKind
:: NameAndKind
nameAndKind =
NameAndKind'
{ _nakKind = Nothing
, _nakName = Nothing
}
nakKind :: Lens' NameAndKind (Maybe Text)
nakKind = lens _nakKind (\ s a -> s{_nakKind = a})
nakName :: Lens' NameAndKind (Maybe Text)
nakName = lens _nakName (\ s a -> s{_nakName = a})
instance FromJSON NameAndKind where
parseJSON
= withObject "NameAndKind"
(\ o ->
NameAndKind' <$> (o .:? "kind") <*> (o .:? "name"))
instance ToJSON NameAndKind where
toJSON NameAndKind'{..}
= object
(catMaybes
[("kind" .=) <$> _nakKind, ("name" .=) <$> _nakName])
newtype IntegerList = IntegerList'
{ _ilElements :: Maybe [SplitInt64]
} deriving (Eq,Show,Data,Typeable,Generic)
integerList
:: IntegerList
integerList =
IntegerList'
{ _ilElements = Nothing
}
ilElements :: Lens' IntegerList [SplitInt64]
ilElements
= lens _ilElements (\ s a -> s{_ilElements = a}) .
_Default
. _Coerce
instance FromJSON IntegerList where
parseJSON
= withObject "IntegerList"
(\ o ->
IntegerList' <$> (o .:? "elements" .!= mempty))
instance ToJSON IntegerList where
toJSON IntegerList'{..}
= object
(catMaybes [("elements" .=) <$> _ilElements])
data WorkItem = WorkItem'
{ _wiJobId :: !(Maybe Text)
, _wiReportStatusInterval :: !(Maybe Text)
, _wiShellTask :: !(Maybe ShellTask)
, _wiStreamingSetupTask :: !(Maybe StreamingSetupTask)
, _wiInitialReportIndex :: !(Maybe (Textual Int64))
, _wiMapTask :: !(Maybe MapTask)
, _wiPackages :: !(Maybe [Package])
, _wiStreamingComputationTask :: !(Maybe StreamingComputationTask)
, _wiSourceOperationTask :: !(Maybe SourceOperationRequest)
, _wiId :: !(Maybe (Textual Int64))
, _wiProjectId :: !(Maybe Text)
, _wiLeaseExpireTime :: !(Maybe Text)
, _wiConfiguration :: !(Maybe Text)
, _wiStreamingConfigTask :: !(Maybe StreamingConfigTask)
, _wiSeqMapTask :: !(Maybe SeqMapTask)
} deriving (Eq,Show,Data,Typeable,Generic)
workItem
:: WorkItem
workItem =
WorkItem'
{ _wiJobId = Nothing
, _wiReportStatusInterval = Nothing
, _wiShellTask = Nothing
, _wiStreamingSetupTask = Nothing
, _wiInitialReportIndex = Nothing
, _wiMapTask = Nothing
, _wiPackages = Nothing
, _wiStreamingComputationTask = Nothing
, _wiSourceOperationTask = Nothing
, _wiId = Nothing
, _wiProjectId = Nothing
, _wiLeaseExpireTime = Nothing
, _wiConfiguration = Nothing
, _wiStreamingConfigTask = Nothing
, _wiSeqMapTask = Nothing
}
wiJobId :: Lens' WorkItem (Maybe Text)
wiJobId = lens _wiJobId (\ s a -> s{_wiJobId = a})
wiReportStatusInterval :: Lens' WorkItem (Maybe Text)
wiReportStatusInterval
= lens _wiReportStatusInterval
(\ s a -> s{_wiReportStatusInterval = a})
wiShellTask :: Lens' WorkItem (Maybe ShellTask)
wiShellTask
= lens _wiShellTask (\ s a -> s{_wiShellTask = a})
wiStreamingSetupTask :: Lens' WorkItem (Maybe StreamingSetupTask)
wiStreamingSetupTask
= lens _wiStreamingSetupTask
(\ s a -> s{_wiStreamingSetupTask = a})
wiInitialReportIndex :: Lens' WorkItem (Maybe Int64)
wiInitialReportIndex
= lens _wiInitialReportIndex
(\ s a -> s{_wiInitialReportIndex = a})
. mapping _Coerce
wiMapTask :: Lens' WorkItem (Maybe MapTask)
wiMapTask
= lens _wiMapTask (\ s a -> s{_wiMapTask = a})
wiPackages :: Lens' WorkItem [Package]
wiPackages
= lens _wiPackages (\ s a -> s{_wiPackages = a}) .
_Default
. _Coerce
wiStreamingComputationTask :: Lens' WorkItem (Maybe StreamingComputationTask)
wiStreamingComputationTask
= lens _wiStreamingComputationTask
(\ s a -> s{_wiStreamingComputationTask = a})
wiSourceOperationTask :: Lens' WorkItem (Maybe SourceOperationRequest)
wiSourceOperationTask
= lens _wiSourceOperationTask
(\ s a -> s{_wiSourceOperationTask = a})
wiId :: Lens' WorkItem (Maybe Int64)
wiId
= lens _wiId (\ s a -> s{_wiId = a}) .
mapping _Coerce
wiProjectId :: Lens' WorkItem (Maybe Text)
wiProjectId
= lens _wiProjectId (\ s a -> s{_wiProjectId = a})
wiLeaseExpireTime :: Lens' WorkItem (Maybe Text)
wiLeaseExpireTime
= lens _wiLeaseExpireTime
(\ s a -> s{_wiLeaseExpireTime = a})
wiConfiguration :: Lens' WorkItem (Maybe Text)
wiConfiguration
= lens _wiConfiguration
(\ s a -> s{_wiConfiguration = a})
wiStreamingConfigTask :: Lens' WorkItem (Maybe StreamingConfigTask)
wiStreamingConfigTask
= lens _wiStreamingConfigTask
(\ s a -> s{_wiStreamingConfigTask = a})
wiSeqMapTask :: Lens' WorkItem (Maybe SeqMapTask)
wiSeqMapTask
= lens _wiSeqMapTask (\ s a -> s{_wiSeqMapTask = a})
instance FromJSON WorkItem where
parseJSON
= withObject "WorkItem"
(\ o ->
WorkItem' <$>
(o .:? "jobId") <*> (o .:? "reportStatusInterval")
<*> (o .:? "shellTask")
<*> (o .:? "streamingSetupTask")
<*> (o .:? "initialReportIndex")
<*> (o .:? "mapTask")
<*> (o .:? "packages" .!= mempty)
<*> (o .:? "streamingComputationTask")
<*> (o .:? "sourceOperationTask")
<*> (o .:? "id")
<*> (o .:? "projectId")
<*> (o .:? "leaseExpireTime")
<*> (o .:? "configuration")
<*> (o .:? "streamingConfigTask")
<*> (o .:? "seqMapTask"))
instance ToJSON WorkItem where
toJSON WorkItem'{..}
= object
(catMaybes
[("jobId" .=) <$> _wiJobId,
("reportStatusInterval" .=) <$>
_wiReportStatusInterval,
("shellTask" .=) <$> _wiShellTask,
("streamingSetupTask" .=) <$> _wiStreamingSetupTask,
("initialReportIndex" .=) <$> _wiInitialReportIndex,
("mapTask" .=) <$> _wiMapTask,
("packages" .=) <$> _wiPackages,
("streamingComputationTask" .=) <$>
_wiStreamingComputationTask,
("sourceOperationTask" .=) <$>
_wiSourceOperationTask,
("id" .=) <$> _wiId,
("projectId" .=) <$> _wiProjectId,
("leaseExpireTime" .=) <$> _wiLeaseExpireTime,
("configuration" .=) <$> _wiConfiguration,
("streamingConfigTask" .=) <$>
_wiStreamingConfigTask,
("seqMapTask" .=) <$> _wiSeqMapTask])
data WorkerHealthReport = WorkerHealthReport'
{ _whrVMIsHealthy :: !(Maybe Bool)
, _whrReportInterval :: !(Maybe Text)
, _whrPods :: !(Maybe [WorkerHealthReportPodsItem])
, _whrVMStartupTime :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
workerHealthReport
:: WorkerHealthReport
workerHealthReport =
WorkerHealthReport'
{ _whrVMIsHealthy = Nothing
, _whrReportInterval = Nothing
, _whrPods = Nothing
, _whrVMStartupTime = Nothing
}
whrVMIsHealthy :: Lens' WorkerHealthReport (Maybe Bool)
whrVMIsHealthy
= lens _whrVMIsHealthy
(\ s a -> s{_whrVMIsHealthy = a})
whrReportInterval :: Lens' WorkerHealthReport (Maybe Text)
whrReportInterval
= lens _whrReportInterval
(\ s a -> s{_whrReportInterval = a})
whrPods :: Lens' WorkerHealthReport [WorkerHealthReportPodsItem]
whrPods
= lens _whrPods (\ s a -> s{_whrPods = a}) . _Default
. _Coerce
whrVMStartupTime :: Lens' WorkerHealthReport (Maybe Text)
whrVMStartupTime
= lens _whrVMStartupTime
(\ s a -> s{_whrVMStartupTime = a})
instance FromJSON WorkerHealthReport where
parseJSON
= withObject "WorkerHealthReport"
(\ o ->
WorkerHealthReport' <$>
(o .:? "vmIsHealthy") <*> (o .:? "reportInterval")
<*> (o .:? "pods" .!= mempty)
<*> (o .:? "vmStartupTime"))
instance ToJSON WorkerHealthReport where
toJSON WorkerHealthReport'{..}
= object
(catMaybes
[("vmIsHealthy" .=) <$> _whrVMIsHealthy,
("reportInterval" .=) <$> _whrReportInterval,
("pods" .=) <$> _whrPods,
("vmStartupTime" .=) <$> _whrVMStartupTime])
data SourceSplitOptions = SourceSplitOptions'
{ _ssoDesiredShardSizeBytes :: !(Maybe (Textual Int64))
, _ssoDesiredBundleSizeBytes :: !(Maybe (Textual Int64))
} deriving (Eq,Show,Data,Typeable,Generic)
sourceSplitOptions
:: SourceSplitOptions
sourceSplitOptions =
SourceSplitOptions'
{ _ssoDesiredShardSizeBytes = Nothing
, _ssoDesiredBundleSizeBytes = Nothing
}
ssoDesiredShardSizeBytes :: Lens' SourceSplitOptions (Maybe Int64)
ssoDesiredShardSizeBytes
= lens _ssoDesiredShardSizeBytes
(\ s a -> s{_ssoDesiredShardSizeBytes = a})
. mapping _Coerce
ssoDesiredBundleSizeBytes :: Lens' SourceSplitOptions (Maybe Int64)
ssoDesiredBundleSizeBytes
= lens _ssoDesiredBundleSizeBytes
(\ s a -> s{_ssoDesiredBundleSizeBytes = a})
. mapping _Coerce
instance FromJSON SourceSplitOptions where
parseJSON
= withObject "SourceSplitOptions"
(\ o ->
SourceSplitOptions' <$>
(o .:? "desiredShardSizeBytes") <*>
(o .:? "desiredBundleSizeBytes"))
instance ToJSON SourceSplitOptions where
toJSON SourceSplitOptions'{..}
= object
(catMaybes
[("desiredShardSizeBytes" .=) <$>
_ssoDesiredShardSizeBytes,
("desiredBundleSizeBytes" .=) <$>
_ssoDesiredBundleSizeBytes])
newtype WorkerPoolMetadata = WorkerPoolMetadata'
{ _wpmAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
workerPoolMetadata
:: HashMap Text Text
-> WorkerPoolMetadata
workerPoolMetadata pWpmAddtional_ =
WorkerPoolMetadata'
{ _wpmAddtional = _Coerce # pWpmAddtional_
}
wpmAddtional :: Lens' WorkerPoolMetadata (HashMap Text Text)
wpmAddtional
= lens _wpmAddtional (\ s a -> s{_wpmAddtional = a})
. _Coerce
instance FromJSON WorkerPoolMetadata where
parseJSON
= withObject "WorkerPoolMetadata"
(\ o -> WorkerPoolMetadata' <$> (parseJSONObject o))
instance ToJSON WorkerPoolMetadata where
toJSON = toJSON . _wpmAddtional
data AutoscalingSettings = AutoscalingSettings'
{ _asMaxNumWorkers :: !(Maybe (Textual Int32))
, _asAlgorithm :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
autoscalingSettings
:: AutoscalingSettings
autoscalingSettings =
AutoscalingSettings'
{ _asMaxNumWorkers = Nothing
, _asAlgorithm = Nothing
}
asMaxNumWorkers :: Lens' AutoscalingSettings (Maybe Int32)
asMaxNumWorkers
= lens _asMaxNumWorkers
(\ s a -> s{_asMaxNumWorkers = a})
. mapping _Coerce
asAlgorithm :: Lens' AutoscalingSettings (Maybe Text)
asAlgorithm
= lens _asAlgorithm (\ s a -> s{_asAlgorithm = a})
instance FromJSON AutoscalingSettings where
parseJSON
= withObject "AutoscalingSettings"
(\ o ->
AutoscalingSettings' <$>
(o .:? "maxNumWorkers") <*> (o .:? "algorithm"))
instance ToJSON AutoscalingSettings where
toJSON AutoscalingSettings'{..}
= object
(catMaybes
[("maxNumWorkers" .=) <$> _asMaxNumWorkers,
("algorithm" .=) <$> _asAlgorithm])
newtype JobExecutionStageInfo = JobExecutionStageInfo'
{ _jesiStepName :: Maybe [Text]
} deriving (Eq,Show,Data,Typeable,Generic)
jobExecutionStageInfo
:: JobExecutionStageInfo
jobExecutionStageInfo =
JobExecutionStageInfo'
{ _jesiStepName = Nothing
}
jesiStepName :: Lens' JobExecutionStageInfo [Text]
jesiStepName
= lens _jesiStepName (\ s a -> s{_jesiStepName = a})
. _Default
. _Coerce
instance FromJSON JobExecutionStageInfo where
parseJSON
= withObject "JobExecutionStageInfo"
(\ o ->
JobExecutionStageInfo' <$>
(o .:? "stepName" .!= mempty))
instance ToJSON JobExecutionStageInfo where
toJSON JobExecutionStageInfo'{..}
= object
(catMaybes [("stepName" .=) <$> _jesiStepName])
data InstructionOutput = InstructionOutput'
{ _ioOnlyCountValueBytes :: !(Maybe Bool)
, _ioCodec :: !(Maybe InstructionOutputCodec)
, _ioName :: !(Maybe Text)
, _ioSystemName :: !(Maybe Text)
, _ioOriginalName :: !(Maybe Text)
, _ioOnlyCountKeyBytes :: !(Maybe Bool)
} deriving (Eq,Show,Data,Typeable,Generic)
instructionOutput
:: InstructionOutput
instructionOutput =
InstructionOutput'
{ _ioOnlyCountValueBytes = Nothing
, _ioCodec = Nothing
, _ioName = Nothing
, _ioSystemName = Nothing
, _ioOriginalName = Nothing
, _ioOnlyCountKeyBytes = Nothing
}
ioOnlyCountValueBytes :: Lens' InstructionOutput (Maybe Bool)
ioOnlyCountValueBytes
= lens _ioOnlyCountValueBytes
(\ s a -> s{_ioOnlyCountValueBytes = a})
ioCodec :: Lens' InstructionOutput (Maybe InstructionOutputCodec)
ioCodec = lens _ioCodec (\ s a -> s{_ioCodec = a})
ioName :: Lens' InstructionOutput (Maybe Text)
ioName = lens _ioName (\ s a -> s{_ioName = a})
ioSystemName :: Lens' InstructionOutput (Maybe Text)
ioSystemName
= lens _ioSystemName (\ s a -> s{_ioSystemName = a})
ioOriginalName :: Lens' InstructionOutput (Maybe Text)
ioOriginalName
= lens _ioOriginalName
(\ s a -> s{_ioOriginalName = a})
ioOnlyCountKeyBytes :: Lens' InstructionOutput (Maybe Bool)
ioOnlyCountKeyBytes
= lens _ioOnlyCountKeyBytes
(\ s a -> s{_ioOnlyCountKeyBytes = a})
instance FromJSON InstructionOutput where
parseJSON
= withObject "InstructionOutput"
(\ o ->
InstructionOutput' <$>
(o .:? "onlyCountValueBytes") <*> (o .:? "codec") <*>
(o .:? "name")
<*> (o .:? "systemName")
<*> (o .:? "originalName")
<*> (o .:? "onlyCountKeyBytes"))
instance ToJSON InstructionOutput where
toJSON InstructionOutput'{..}
= object
(catMaybes
[("onlyCountValueBytes" .=) <$>
_ioOnlyCountValueBytes,
("codec" .=) <$> _ioCodec, ("name" .=) <$> _ioName,
("systemName" .=) <$> _ioSystemName,
("originalName" .=) <$> _ioOriginalName,
("onlyCountKeyBytes" .=) <$> _ioOnlyCountKeyBytes])
data ReportWorkItemStatusRequest = ReportWorkItemStatusRequest'
{ _rwisrCurrentWorkerTime :: !(Maybe Text)
, _rwisrWorkItemStatuses :: !(Maybe [WorkItemStatus])
, _rwisrWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
reportWorkItemStatusRequest
:: ReportWorkItemStatusRequest
reportWorkItemStatusRequest =
ReportWorkItemStatusRequest'
{ _rwisrCurrentWorkerTime = Nothing
, _rwisrWorkItemStatuses = Nothing
, _rwisrWorkerId = Nothing
}
rwisrCurrentWorkerTime :: Lens' ReportWorkItemStatusRequest (Maybe Text)
rwisrCurrentWorkerTime
= lens _rwisrCurrentWorkerTime
(\ s a -> s{_rwisrCurrentWorkerTime = a})
rwisrWorkItemStatuses :: Lens' ReportWorkItemStatusRequest [WorkItemStatus]
rwisrWorkItemStatuses
= lens _rwisrWorkItemStatuses
(\ s a -> s{_rwisrWorkItemStatuses = a})
. _Default
. _Coerce
rwisrWorkerId :: Lens' ReportWorkItemStatusRequest (Maybe Text)
rwisrWorkerId
= lens _rwisrWorkerId
(\ s a -> s{_rwisrWorkerId = a})
instance FromJSON ReportWorkItemStatusRequest where
parseJSON
= withObject "ReportWorkItemStatusRequest"
(\ o ->
ReportWorkItemStatusRequest' <$>
(o .:? "currentWorkerTime") <*>
(o .:? "workItemStatuses" .!= mempty)
<*> (o .:? "workerId"))
instance ToJSON ReportWorkItemStatusRequest where
toJSON ReportWorkItemStatusRequest'{..}
= object
(catMaybes
[("currentWorkerTime" .=) <$>
_rwisrCurrentWorkerTime,
("workItemStatuses" .=) <$> _rwisrWorkItemStatuses,
("workerId" .=) <$> _rwisrWorkerId])
newtype EnvironmentVersion = EnvironmentVersion'
{ _evAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
environmentVersion
:: HashMap Text JSONValue
-> EnvironmentVersion
environmentVersion pEvAddtional_ =
EnvironmentVersion'
{ _evAddtional = _Coerce # pEvAddtional_
}
evAddtional :: Lens' EnvironmentVersion (HashMap Text JSONValue)
evAddtional
= lens _evAddtional (\ s a -> s{_evAddtional = a}) .
_Coerce
instance FromJSON EnvironmentVersion where
parseJSON
= withObject "EnvironmentVersion"
(\ o -> EnvironmentVersion' <$> (parseJSONObject o))
instance ToJSON EnvironmentVersion where
toJSON = toJSON . _evAddtional
data Sink = Sink'
{ _sCodec :: !(Maybe SinkCodec)
, _sSpec :: !(Maybe SinkSpec)
} deriving (Eq,Show,Data,Typeable,Generic)
sink
:: Sink
sink =
Sink'
{ _sCodec = Nothing
, _sSpec = Nothing
}
sCodec :: Lens' Sink (Maybe SinkCodec)
sCodec = lens _sCodec (\ s a -> s{_sCodec = a})
sSpec :: Lens' Sink (Maybe SinkSpec)
sSpec = lens _sSpec (\ s a -> s{_sSpec = a})
instance FromJSON Sink where
parseJSON
= withObject "Sink"
(\ o -> Sink' <$> (o .:? "codec") <*> (o .:? "spec"))
instance ToJSON Sink where
toJSON Sink'{..}
= object
(catMaybes
[("codec" .=) <$> _sCodec, ("spec" .=) <$> _sSpec])
newtype StringList = StringList'
{ _slElements :: Maybe [Text]
} deriving (Eq,Show,Data,Typeable,Generic)
stringList
:: StringList
stringList =
StringList'
{ _slElements = Nothing
}
slElements :: Lens' StringList [Text]
slElements
= lens _slElements (\ s a -> s{_slElements = a}) .
_Default
. _Coerce
instance FromJSON StringList where
parseJSON
= withObject "StringList"
(\ o ->
StringList' <$> (o .:? "elements" .!= mempty))
instance ToJSON StringList where
toJSON StringList'{..}
= object
(catMaybes [("elements" .=) <$> _slElements])
newtype WorkerHealthReportResponse = WorkerHealthReportResponse'
{ _whrrReportInterval :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
workerHealthReportResponse
:: WorkerHealthReportResponse
workerHealthReportResponse =
WorkerHealthReportResponse'
{ _whrrReportInterval = Nothing
}
whrrReportInterval :: Lens' WorkerHealthReportResponse (Maybe Text)
whrrReportInterval
= lens _whrrReportInterval
(\ s a -> s{_whrrReportInterval = a})
instance FromJSON WorkerHealthReportResponse where
parseJSON
= withObject "WorkerHealthReportResponse"
(\ o ->
WorkerHealthReportResponse' <$>
(o .:? "reportInterval"))
instance ToJSON WorkerHealthReportResponse where
toJSON WorkerHealthReportResponse'{..}
= object
(catMaybes
[("reportInterval" .=) <$> _whrrReportInterval])
data SendDebugCaptureResponse =
SendDebugCaptureResponse'
deriving (Eq,Show,Data,Typeable,Generic)
sendDebugCaptureResponse
:: SendDebugCaptureResponse
sendDebugCaptureResponse = SendDebugCaptureResponse'
instance FromJSON SendDebugCaptureResponse where
parseJSON
= withObject "SendDebugCaptureResponse"
(\ o -> pure SendDebugCaptureResponse')
instance ToJSON SendDebugCaptureResponse where
toJSON = const emptyObject
newtype JobLabels = JobLabels'
{ _jlAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
jobLabels
:: HashMap Text Text
-> JobLabels
jobLabels pJlAddtional_ =
JobLabels'
{ _jlAddtional = _Coerce # pJlAddtional_
}
jlAddtional :: Lens' JobLabels (HashMap Text Text)
jlAddtional
= lens _jlAddtional (\ s a -> s{_jlAddtional = a}) .
_Coerce
instance FromJSON JobLabels where
parseJSON
= withObject "JobLabels"
(\ o -> JobLabels' <$> (parseJSONObject o))
instance ToJSON JobLabels where
toJSON = toJSON . _jlAddtional
data MetricStructuredName = MetricStructuredName'
{ _msnOrigin :: !(Maybe Text)
, _msnContext :: !(Maybe MetricStructuredNameContext)
, _msnName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
metricStructuredName
:: MetricStructuredName
metricStructuredName =
MetricStructuredName'
{ _msnOrigin = Nothing
, _msnContext = Nothing
, _msnName = Nothing
}
msnOrigin :: Lens' MetricStructuredName (Maybe Text)
msnOrigin
= lens _msnOrigin (\ s a -> s{_msnOrigin = a})
msnContext :: Lens' MetricStructuredName (Maybe MetricStructuredNameContext)
msnContext
= lens _msnContext (\ s a -> s{_msnContext = a})
msnName :: Lens' MetricStructuredName (Maybe Text)
msnName = lens _msnName (\ s a -> s{_msnName = a})
instance FromJSON MetricStructuredName where
parseJSON
= withObject "MetricStructuredName"
(\ o ->
MetricStructuredName' <$>
(o .:? "origin") <*> (o .:? "context") <*>
(o .:? "name"))
instance ToJSON MetricStructuredName where
toJSON MetricStructuredName'{..}
= object
(catMaybes
[("origin" .=) <$> _msnOrigin,
("context" .=) <$> _msnContext,
("name" .=) <$> _msnName])
data CounterStructuredName = CounterStructuredName'
{ _csnStandardOrigin :: !(Maybe Text)
, _csnComponentStepName :: !(Maybe Text)
, _csnOtherOrigin :: !(Maybe Text)
, _csnPortion :: !(Maybe Text)
, _csnOriginalStepName :: !(Maybe Text)
, _csnName :: !(Maybe Text)
, _csnExecutionStepName :: !(Maybe Text)
, _csnWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
counterStructuredName
:: CounterStructuredName
counterStructuredName =
CounterStructuredName'
{ _csnStandardOrigin = Nothing
, _csnComponentStepName = Nothing
, _csnOtherOrigin = Nothing
, _csnPortion = Nothing
, _csnOriginalStepName = Nothing
, _csnName = Nothing
, _csnExecutionStepName = Nothing
, _csnWorkerId = Nothing
}
csnStandardOrigin :: Lens' CounterStructuredName (Maybe Text)
csnStandardOrigin
= lens _csnStandardOrigin
(\ s a -> s{_csnStandardOrigin = a})
csnComponentStepName :: Lens' CounterStructuredName (Maybe Text)
csnComponentStepName
= lens _csnComponentStepName
(\ s a -> s{_csnComponentStepName = a})
csnOtherOrigin :: Lens' CounterStructuredName (Maybe Text)
csnOtherOrigin
= lens _csnOtherOrigin
(\ s a -> s{_csnOtherOrigin = a})
csnPortion :: Lens' CounterStructuredName (Maybe Text)
csnPortion
= lens _csnPortion (\ s a -> s{_csnPortion = a})
csnOriginalStepName :: Lens' CounterStructuredName (Maybe Text)
csnOriginalStepName
= lens _csnOriginalStepName
(\ s a -> s{_csnOriginalStepName = a})
csnName :: Lens' CounterStructuredName (Maybe Text)
csnName = lens _csnName (\ s a -> s{_csnName = a})
csnExecutionStepName :: Lens' CounterStructuredName (Maybe Text)
csnExecutionStepName
= lens _csnExecutionStepName
(\ s a -> s{_csnExecutionStepName = a})
csnWorkerId :: Lens' CounterStructuredName (Maybe Text)
csnWorkerId
= lens _csnWorkerId (\ s a -> s{_csnWorkerId = a})
instance FromJSON CounterStructuredName where
parseJSON
= withObject "CounterStructuredName"
(\ o ->
CounterStructuredName' <$>
(o .:? "standardOrigin") <*>
(o .:? "componentStepName")
<*> (o .:? "otherOrigin")
<*> (o .:? "portion")
<*> (o .:? "originalStepName")
<*> (o .:? "name")
<*> (o .:? "executionStepName")
<*> (o .:? "workerId"))
instance ToJSON CounterStructuredName where
toJSON CounterStructuredName'{..}
= object
(catMaybes
[("standardOrigin" .=) <$> _csnStandardOrigin,
("componentStepName" .=) <$> _csnComponentStepName,
("otherOrigin" .=) <$> _csnOtherOrigin,
("portion" .=) <$> _csnPortion,
("originalStepName" .=) <$> _csnOriginalStepName,
("name" .=) <$> _csnName,
("executionStepName" .=) <$> _csnExecutionStepName,
("workerId" .=) <$> _csnWorkerId])
data WriteInstruction = WriteInstruction'
{ _wiSink :: !(Maybe Sink)
, _wiInput :: !(Maybe InstructionInput)
} deriving (Eq,Show,Data,Typeable,Generic)
writeInstruction
:: WriteInstruction
writeInstruction =
WriteInstruction'
{ _wiSink = Nothing
, _wiInput = Nothing
}
wiSink :: Lens' WriteInstruction (Maybe Sink)
wiSink = lens _wiSink (\ s a -> s{_wiSink = a})
wiInput :: Lens' WriteInstruction (Maybe InstructionInput)
wiInput = lens _wiInput (\ s a -> s{_wiInput = a})
instance FromJSON WriteInstruction where
parseJSON
= withObject "WriteInstruction"
(\ o ->
WriteInstruction' <$>
(o .:? "sink") <*> (o .:? "input"))
instance ToJSON WriteInstruction where
toJSON WriteInstruction'{..}
= object
(catMaybes
[("sink" .=) <$> _wiSink, ("input" .=) <$> _wiInput])
newtype EnvironmentUserAgent = EnvironmentUserAgent'
{ _euaAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
environmentUserAgent
:: HashMap Text JSONValue
-> EnvironmentUserAgent
environmentUserAgent pEuaAddtional_ =
EnvironmentUserAgent'
{ _euaAddtional = _Coerce # pEuaAddtional_
}
euaAddtional :: Lens' EnvironmentUserAgent (HashMap Text JSONValue)
euaAddtional
= lens _euaAddtional (\ s a -> s{_euaAddtional = a})
. _Coerce
instance FromJSON EnvironmentUserAgent where
parseJSON
= withObject "EnvironmentUserAgent"
(\ o ->
EnvironmentUserAgent' <$> (parseJSONObject o))
instance ToJSON EnvironmentUserAgent where
toJSON = toJSON . _euaAddtional
data Disk = Disk'
{ _dSizeGb :: !(Maybe (Textual Int32))
, _dDiskType :: !(Maybe Text)
, _dMountPoint :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
disk
:: Disk
disk =
Disk'
{ _dSizeGb = Nothing
, _dDiskType = Nothing
, _dMountPoint = Nothing
}
dSizeGb :: Lens' Disk (Maybe Int32)
dSizeGb
= lens _dSizeGb (\ s a -> s{_dSizeGb = a}) .
mapping _Coerce
dDiskType :: Lens' Disk (Maybe Text)
dDiskType
= lens _dDiskType (\ s a -> s{_dDiskType = a})
dMountPoint :: Lens' Disk (Maybe Text)
dMountPoint
= lens _dMountPoint (\ s a -> s{_dMountPoint = a})
instance FromJSON Disk where
parseJSON
= withObject "Disk"
(\ o ->
Disk' <$>
(o .:? "sizeGb") <*> (o .:? "diskType") <*>
(o .:? "mountPoint"))
instance ToJSON Disk where
toJSON Disk'{..}
= object
(catMaybes
[("sizeGb" .=) <$> _dSizeGb,
("diskType" .=) <$> _dDiskType,
("mountPoint" .=) <$> _dMountPoint])
data MetricUpdate = MetricUpdate'
{ _muMeanSum :: !(Maybe JSONValue)
, _muInternal :: !(Maybe JSONValue)
, _muSet :: !(Maybe JSONValue)
, _muCumulative :: !(Maybe Bool)
, _muKind :: !(Maybe Text)
, _muUpdateTime :: !(Maybe Text)
, _muMeanCount :: !(Maybe JSONValue)
, _muName :: !(Maybe MetricStructuredName)
, _muScalar :: !(Maybe JSONValue)
} deriving (Eq,Show,Data,Typeable,Generic)
metricUpdate
:: MetricUpdate
metricUpdate =
MetricUpdate'
{ _muMeanSum = Nothing
, _muInternal = Nothing
, _muSet = Nothing
, _muCumulative = Nothing
, _muKind = Nothing
, _muUpdateTime = Nothing
, _muMeanCount = Nothing
, _muName = Nothing
, _muScalar = Nothing
}
muMeanSum :: Lens' MetricUpdate (Maybe JSONValue)
muMeanSum
= lens _muMeanSum (\ s a -> s{_muMeanSum = a})
muInternal :: Lens' MetricUpdate (Maybe JSONValue)
muInternal
= lens _muInternal (\ s a -> s{_muInternal = a})
muSet :: Lens' MetricUpdate (Maybe JSONValue)
muSet = lens _muSet (\ s a -> s{_muSet = a})
muCumulative :: Lens' MetricUpdate (Maybe Bool)
muCumulative
= lens _muCumulative (\ s a -> s{_muCumulative = a})
muKind :: Lens' MetricUpdate (Maybe Text)
muKind = lens _muKind (\ s a -> s{_muKind = a})
muUpdateTime :: Lens' MetricUpdate (Maybe Text)
muUpdateTime
= lens _muUpdateTime (\ s a -> s{_muUpdateTime = a})
muMeanCount :: Lens' MetricUpdate (Maybe JSONValue)
muMeanCount
= lens _muMeanCount (\ s a -> s{_muMeanCount = a})
muName :: Lens' MetricUpdate (Maybe MetricStructuredName)
muName = lens _muName (\ s a -> s{_muName = a})
muScalar :: Lens' MetricUpdate (Maybe JSONValue)
muScalar = lens _muScalar (\ s a -> s{_muScalar = a})
instance FromJSON MetricUpdate where
parseJSON
= withObject "MetricUpdate"
(\ o ->
MetricUpdate' <$>
(o .:? "meanSum") <*> (o .:? "internal") <*>
(o .:? "set")
<*> (o .:? "cumulative")
<*> (o .:? "kind")
<*> (o .:? "updateTime")
<*> (o .:? "meanCount")
<*> (o .:? "name")
<*> (o .:? "scalar"))
instance ToJSON MetricUpdate where
toJSON MetricUpdate'{..}
= object
(catMaybes
[("meanSum" .=) <$> _muMeanSum,
("internal" .=) <$> _muInternal,
("set" .=) <$> _muSet,
("cumulative" .=) <$> _muCumulative,
("kind" .=) <$> _muKind,
("updateTime" .=) <$> _muUpdateTime,
("meanCount" .=) <$> _muMeanCount,
("name" .=) <$> _muName,
("scalar" .=) <$> _muScalar])
newtype SourceGetMetadataResponse = SourceGetMetadataResponse'
{ _sgmrMetadata :: Maybe SourceMetadata
} deriving (Eq,Show,Data,Typeable,Generic)
sourceGetMetadataResponse
:: SourceGetMetadataResponse
sourceGetMetadataResponse =
SourceGetMetadataResponse'
{ _sgmrMetadata = Nothing
}
sgmrMetadata :: Lens' SourceGetMetadataResponse (Maybe SourceMetadata)
sgmrMetadata
= lens _sgmrMetadata (\ s a -> s{_sgmrMetadata = a})
instance FromJSON SourceGetMetadataResponse where
parseJSON
= withObject "SourceGetMetadataResponse"
(\ o ->
SourceGetMetadataResponse' <$> (o .:? "metadata"))
instance ToJSON SourceGetMetadataResponse where
toJSON SourceGetMetadataResponse'{..}
= object
(catMaybes [("metadata" .=) <$> _sgmrMetadata])
data Environment = Environment'
{ _eDataSet :: !(Maybe Text)
, _eExperiments :: !(Maybe [Text])
, _eWorkerPools :: !(Maybe [WorkerPool])
, _eClusterManagerAPIService :: !(Maybe Text)
, _eVersion :: !(Maybe EnvironmentVersion)
, _eInternalExperiments :: !(Maybe EnvironmentInternalExperiments)
, _eTempStoragePrefix :: !(Maybe Text)
, _eServiceAccountEmail :: !(Maybe Text)
, _eUserAgent :: !(Maybe EnvironmentUserAgent)
, _eSdkPipelineOptions :: !(Maybe EnvironmentSdkPipelineOptions)
} deriving (Eq,Show,Data,Typeable,Generic)
environment
:: Environment
environment =
Environment'
{ _eDataSet = Nothing
, _eExperiments = Nothing
, _eWorkerPools = Nothing
, _eClusterManagerAPIService = Nothing
, _eVersion = Nothing
, _eInternalExperiments = Nothing
, _eTempStoragePrefix = Nothing
, _eServiceAccountEmail = Nothing
, _eUserAgent = Nothing
, _eSdkPipelineOptions = Nothing
}
eDataSet :: Lens' Environment (Maybe Text)
eDataSet = lens _eDataSet (\ s a -> s{_eDataSet = a})
eExperiments :: Lens' Environment [Text]
eExperiments
= lens _eExperiments (\ s a -> s{_eExperiments = a})
. _Default
. _Coerce
eWorkerPools :: Lens' Environment [WorkerPool]
eWorkerPools
= lens _eWorkerPools (\ s a -> s{_eWorkerPools = a})
. _Default
. _Coerce
eClusterManagerAPIService :: Lens' Environment (Maybe Text)
eClusterManagerAPIService
= lens _eClusterManagerAPIService
(\ s a -> s{_eClusterManagerAPIService = a})
eVersion :: Lens' Environment (Maybe EnvironmentVersion)
eVersion = lens _eVersion (\ s a -> s{_eVersion = a})
eInternalExperiments :: Lens' Environment (Maybe EnvironmentInternalExperiments)
eInternalExperiments
= lens _eInternalExperiments
(\ s a -> s{_eInternalExperiments = a})
eTempStoragePrefix :: Lens' Environment (Maybe Text)
eTempStoragePrefix
= lens _eTempStoragePrefix
(\ s a -> s{_eTempStoragePrefix = a})
eServiceAccountEmail :: Lens' Environment (Maybe Text)
eServiceAccountEmail
= lens _eServiceAccountEmail
(\ s a -> s{_eServiceAccountEmail = a})
eUserAgent :: Lens' Environment (Maybe EnvironmentUserAgent)
eUserAgent
= lens _eUserAgent (\ s a -> s{_eUserAgent = a})
eSdkPipelineOptions :: Lens' Environment (Maybe EnvironmentSdkPipelineOptions)
eSdkPipelineOptions
= lens _eSdkPipelineOptions
(\ s a -> s{_eSdkPipelineOptions = a})
instance FromJSON Environment where
parseJSON
= withObject "Environment"
(\ o ->
Environment' <$>
(o .:? "dataset") <*>
(o .:? "experiments" .!= mempty)
<*> (o .:? "workerPools" .!= mempty)
<*> (o .:? "clusterManagerApiService")
<*> (o .:? "version")
<*> (o .:? "internalExperiments")
<*> (o .:? "tempStoragePrefix")
<*> (o .:? "serviceAccountEmail")
<*> (o .:? "userAgent")
<*> (o .:? "sdkPipelineOptions"))
instance ToJSON Environment where
toJSON Environment'{..}
= object
(catMaybes
[("dataset" .=) <$> _eDataSet,
("experiments" .=) <$> _eExperiments,
("workerPools" .=) <$> _eWorkerPools,
("clusterManagerApiService" .=) <$>
_eClusterManagerAPIService,
("version" .=) <$> _eVersion,
("internalExperiments" .=) <$> _eInternalExperiments,
("tempStoragePrefix" .=) <$> _eTempStoragePrefix,
("serviceAccountEmail" .=) <$> _eServiceAccountEmail,
("userAgent" .=) <$> _eUserAgent,
("sdkPipelineOptions" .=) <$> _eSdkPipelineOptions])
data ConcatPosition = ConcatPosition'
{ _cpIndex :: !(Maybe (Textual Int32))
, _cpPosition :: !(Maybe Position)
} deriving (Eq,Show,Data,Typeable,Generic)
concatPosition
:: ConcatPosition
concatPosition =
ConcatPosition'
{ _cpIndex = Nothing
, _cpPosition = Nothing
}
cpIndex :: Lens' ConcatPosition (Maybe Int32)
cpIndex
= lens _cpIndex (\ s a -> s{_cpIndex = a}) .
mapping _Coerce
cpPosition :: Lens' ConcatPosition (Maybe Position)
cpPosition
= lens _cpPosition (\ s a -> s{_cpPosition = a})
instance FromJSON ConcatPosition where
parseJSON
= withObject "ConcatPosition"
(\ o ->
ConcatPosition' <$>
(o .:? "index") <*> (o .:? "position"))
instance ToJSON ConcatPosition where
toJSON ConcatPosition'{..}
= object
(catMaybes
[("index" .=) <$> _cpIndex,
("position" .=) <$> _cpPosition])
newtype MetricStructuredNameContext = MetricStructuredNameContext'
{ _msncAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
metricStructuredNameContext
:: HashMap Text Text
-> MetricStructuredNameContext
metricStructuredNameContext pMsncAddtional_ =
MetricStructuredNameContext'
{ _msncAddtional = _Coerce # pMsncAddtional_
}
msncAddtional :: Lens' MetricStructuredNameContext (HashMap Text Text)
msncAddtional
= lens _msncAddtional
(\ s a -> s{_msncAddtional = a})
. _Coerce
instance FromJSON MetricStructuredNameContext where
parseJSON
= withObject "MetricStructuredNameContext"
(\ o ->
MetricStructuredNameContext' <$> (parseJSONObject o))
instance ToJSON MetricStructuredNameContext where
toJSON = toJSON . _msncAddtional
data CounterUpdate = CounterUpdate'
{ _cuNameAndKind :: !(Maybe NameAndKind)
, _cuIntegerList :: !(Maybe IntegerList)
, _cuFloatingPoint :: !(Maybe (Textual Double))
, _cuInternal :: !(Maybe JSONValue)
, _cuStringList :: !(Maybe StringList)
, _cuShortId :: !(Maybe (Textual Int64))
, _cuCumulative :: !(Maybe Bool)
, _cuStructuredNameAndMetadata :: !(Maybe CounterStructuredNameAndMetadata)
, _cuFloatingPointMean :: !(Maybe FloatingPointMean)
, _cuIntegerMean :: !(Maybe IntegerMean)
, _cuBoolean :: !(Maybe Bool)
, _cuFloatingPointList :: !(Maybe FloatingPointList)
, _cuInteger :: !(Maybe SplitInt64)
} deriving (Eq,Show,Data,Typeable,Generic)
counterUpdate
:: CounterUpdate
counterUpdate =
CounterUpdate'
{ _cuNameAndKind = Nothing
, _cuIntegerList = Nothing
, _cuFloatingPoint = Nothing
, _cuInternal = Nothing
, _cuStringList = Nothing
, _cuShortId = Nothing
, _cuCumulative = Nothing
, _cuStructuredNameAndMetadata = Nothing
, _cuFloatingPointMean = Nothing
, _cuIntegerMean = Nothing
, _cuBoolean = Nothing
, _cuFloatingPointList = Nothing
, _cuInteger = Nothing
}
cuNameAndKind :: Lens' CounterUpdate (Maybe NameAndKind)
cuNameAndKind
= lens _cuNameAndKind
(\ s a -> s{_cuNameAndKind = a})
cuIntegerList :: Lens' CounterUpdate (Maybe IntegerList)
cuIntegerList
= lens _cuIntegerList
(\ s a -> s{_cuIntegerList = a})
cuFloatingPoint :: Lens' CounterUpdate (Maybe Double)
cuFloatingPoint
= lens _cuFloatingPoint
(\ s a -> s{_cuFloatingPoint = a})
. mapping _Coerce
cuInternal :: Lens' CounterUpdate (Maybe JSONValue)
cuInternal
= lens _cuInternal (\ s a -> s{_cuInternal = a})
cuStringList :: Lens' CounterUpdate (Maybe StringList)
cuStringList
= lens _cuStringList (\ s a -> s{_cuStringList = a})
cuShortId :: Lens' CounterUpdate (Maybe Int64)
cuShortId
= lens _cuShortId (\ s a -> s{_cuShortId = a}) .
mapping _Coerce
cuCumulative :: Lens' CounterUpdate (Maybe Bool)
cuCumulative
= lens _cuCumulative (\ s a -> s{_cuCumulative = a})
cuStructuredNameAndMetadata :: Lens' CounterUpdate (Maybe CounterStructuredNameAndMetadata)
cuStructuredNameAndMetadata
= lens _cuStructuredNameAndMetadata
(\ s a -> s{_cuStructuredNameAndMetadata = a})
cuFloatingPointMean :: Lens' CounterUpdate (Maybe FloatingPointMean)
cuFloatingPointMean
= lens _cuFloatingPointMean
(\ s a -> s{_cuFloatingPointMean = a})
cuIntegerMean :: Lens' CounterUpdate (Maybe IntegerMean)
cuIntegerMean
= lens _cuIntegerMean
(\ s a -> s{_cuIntegerMean = a})
cuBoolean :: Lens' CounterUpdate (Maybe Bool)
cuBoolean
= lens _cuBoolean (\ s a -> s{_cuBoolean = a})
cuFloatingPointList :: Lens' CounterUpdate (Maybe FloatingPointList)
cuFloatingPointList
= lens _cuFloatingPointList
(\ s a -> s{_cuFloatingPointList = a})
cuInteger :: Lens' CounterUpdate (Maybe SplitInt64)
cuInteger
= lens _cuInteger (\ s a -> s{_cuInteger = a})
instance FromJSON CounterUpdate where
parseJSON
= withObject "CounterUpdate"
(\ o ->
CounterUpdate' <$>
(o .:? "nameAndKind") <*> (o .:? "integerList") <*>
(o .:? "floatingPoint")
<*> (o .:? "internal")
<*> (o .:? "stringList")
<*> (o .:? "shortId")
<*> (o .:? "cumulative")
<*> (o .:? "structuredNameAndMetadata")
<*> (o .:? "floatingPointMean")
<*> (o .:? "integerMean")
<*> (o .:? "boolean")
<*> (o .:? "floatingPointList")
<*> (o .:? "integer"))
instance ToJSON CounterUpdate where
toJSON CounterUpdate'{..}
= object
(catMaybes
[("nameAndKind" .=) <$> _cuNameAndKind,
("integerList" .=) <$> _cuIntegerList,
("floatingPoint" .=) <$> _cuFloatingPoint,
("internal" .=) <$> _cuInternal,
("stringList" .=) <$> _cuStringList,
("shortId" .=) <$> _cuShortId,
("cumulative" .=) <$> _cuCumulative,
("structuredNameAndMetadata" .=) <$>
_cuStructuredNameAndMetadata,
("floatingPointMean" .=) <$> _cuFloatingPointMean,
("integerMean" .=) <$> _cuIntegerMean,
("boolean" .=) <$> _cuBoolean,
("floatingPointList" .=) <$> _cuFloatingPointList,
("integer" .=) <$> _cuInteger])
newtype StreamingStageLocation = StreamingStageLocation'
{ _sslStreamId :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
streamingStageLocation
:: StreamingStageLocation
streamingStageLocation =
StreamingStageLocation'
{ _sslStreamId = Nothing
}
sslStreamId :: Lens' StreamingStageLocation (Maybe Text)
sslStreamId
= lens _sslStreamId (\ s a -> s{_sslStreamId = a})
instance FromJSON StreamingStageLocation where
parseJSON
= withObject "StreamingStageLocation"
(\ o ->
StreamingStageLocation' <$> (o .:? "streamId"))
instance ToJSON StreamingStageLocation where
toJSON StreamingStageLocation'{..}
= object
(catMaybes [("streamId" .=) <$> _sslStreamId])
data DerivedSource = DerivedSource'
{ _dsDerivationMode :: !(Maybe Text)
, _dsSource :: !(Maybe Source)
} deriving (Eq,Show,Data,Typeable,Generic)
derivedSource
:: DerivedSource
derivedSource =
DerivedSource'
{ _dsDerivationMode = Nothing
, _dsSource = Nothing
}
dsDerivationMode :: Lens' DerivedSource (Maybe Text)
dsDerivationMode
= lens _dsDerivationMode
(\ s a -> s{_dsDerivationMode = a})
dsSource :: Lens' DerivedSource (Maybe Source)
dsSource = lens _dsSource (\ s a -> s{_dsSource = a})
instance FromJSON DerivedSource where
parseJSON
= withObject "DerivedSource"
(\ o ->
DerivedSource' <$>
(o .:? "derivationMode") <*> (o .:? "source"))
instance ToJSON DerivedSource where
toJSON DerivedSource'{..}
= object
(catMaybes
[("derivationMode" .=) <$> _dsDerivationMode,
("source" .=) <$> _dsSource])
data JobMetrics = JobMetrics'
{ _jmMetrics :: !(Maybe [MetricUpdate])
, _jmMetricTime :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
jobMetrics
:: JobMetrics
jobMetrics =
JobMetrics'
{ _jmMetrics = Nothing
, _jmMetricTime = Nothing
}
jmMetrics :: Lens' JobMetrics [MetricUpdate]
jmMetrics
= lens _jmMetrics (\ s a -> s{_jmMetrics = a}) .
_Default
. _Coerce
jmMetricTime :: Lens' JobMetrics (Maybe Text)
jmMetricTime
= lens _jmMetricTime (\ s a -> s{_jmMetricTime = a})
instance FromJSON JobMetrics where
parseJSON
= withObject "JobMetrics"
(\ o ->
JobMetrics' <$>
(o .:? "metrics" .!= mempty) <*>
(o .:? "metricTime"))
instance ToJSON JobMetrics where
toJSON JobMetrics'{..}
= object
(catMaybes
[("metrics" .=) <$> _jmMetrics,
("metricTime" .=) <$> _jmMetricTime])
data SendDebugCaptureRequest = SendDebugCaptureRequest'
{ _sdcrData :: !(Maybe Text)
, _sdcrComponentId :: !(Maybe Text)
, _sdcrWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
sendDebugCaptureRequest
:: SendDebugCaptureRequest
sendDebugCaptureRequest =
SendDebugCaptureRequest'
{ _sdcrData = Nothing
, _sdcrComponentId = Nothing
, _sdcrWorkerId = Nothing
}
sdcrData :: Lens' SendDebugCaptureRequest (Maybe Text)
sdcrData = lens _sdcrData (\ s a -> s{_sdcrData = a})
sdcrComponentId :: Lens' SendDebugCaptureRequest (Maybe Text)
sdcrComponentId
= lens _sdcrComponentId
(\ s a -> s{_sdcrComponentId = a})
sdcrWorkerId :: Lens' SendDebugCaptureRequest (Maybe Text)
sdcrWorkerId
= lens _sdcrWorkerId (\ s a -> s{_sdcrWorkerId = a})
instance FromJSON SendDebugCaptureRequest where
parseJSON
= withObject "SendDebugCaptureRequest"
(\ o ->
SendDebugCaptureRequest' <$>
(o .:? "data") <*> (o .:? "componentId") <*>
(o .:? "workerId"))
instance ToJSON SendDebugCaptureRequest where
toJSON SendDebugCaptureRequest'{..}
= object
(catMaybes
[("data" .=) <$> _sdcrData,
("componentId" .=) <$> _sdcrComponentId,
("workerId" .=) <$> _sdcrWorkerId])
data WorkItemStatus = WorkItemStatus'
{ _wisReportedProgress :: !(Maybe ApproximateReportedProgress)
, _wisProgress :: !(Maybe ApproximateProgress)
, _wisSourceOperationResponse :: !(Maybe SourceOperationResponse)
, _wisStopPosition :: !(Maybe Position)
, _wisDynamicSourceSplit :: !(Maybe DynamicSourceSplit)
, _wisCompleted :: !(Maybe Bool)
, _wisSourceFork :: !(Maybe SourceFork)
, _wisReportIndex :: !(Maybe (Textual Int64))
, _wisRequestedLeaseDuration :: !(Maybe Text)
, _wisErrors :: !(Maybe [Status])
, _wisCounterUpdates :: !(Maybe [CounterUpdate])
, _wisMetricUpdates :: !(Maybe [MetricUpdate])
, _wisWorkItemId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
workItemStatus
:: WorkItemStatus
workItemStatus =
WorkItemStatus'
{ _wisReportedProgress = Nothing
, _wisProgress = Nothing
, _wisSourceOperationResponse = Nothing
, _wisStopPosition = Nothing
, _wisDynamicSourceSplit = Nothing
, _wisCompleted = Nothing
, _wisSourceFork = Nothing
, _wisReportIndex = Nothing
, _wisRequestedLeaseDuration = Nothing
, _wisErrors = Nothing
, _wisCounterUpdates = Nothing
, _wisMetricUpdates = Nothing
, _wisWorkItemId = Nothing
}
wisReportedProgress :: Lens' WorkItemStatus (Maybe ApproximateReportedProgress)
wisReportedProgress
= lens _wisReportedProgress
(\ s a -> s{_wisReportedProgress = a})
wisProgress :: Lens' WorkItemStatus (Maybe ApproximateProgress)
wisProgress
= lens _wisProgress (\ s a -> s{_wisProgress = a})
wisSourceOperationResponse :: Lens' WorkItemStatus (Maybe SourceOperationResponse)
wisSourceOperationResponse
= lens _wisSourceOperationResponse
(\ s a -> s{_wisSourceOperationResponse = a})
wisStopPosition :: Lens' WorkItemStatus (Maybe Position)
wisStopPosition
= lens _wisStopPosition
(\ s a -> s{_wisStopPosition = a})
wisDynamicSourceSplit :: Lens' WorkItemStatus (Maybe DynamicSourceSplit)
wisDynamicSourceSplit
= lens _wisDynamicSourceSplit
(\ s a -> s{_wisDynamicSourceSplit = a})
wisCompleted :: Lens' WorkItemStatus (Maybe Bool)
wisCompleted
= lens _wisCompleted (\ s a -> s{_wisCompleted = a})
wisSourceFork :: Lens' WorkItemStatus (Maybe SourceFork)
wisSourceFork
= lens _wisSourceFork
(\ s a -> s{_wisSourceFork = a})
wisReportIndex :: Lens' WorkItemStatus (Maybe Int64)
wisReportIndex
= lens _wisReportIndex
(\ s a -> s{_wisReportIndex = a})
. mapping _Coerce
wisRequestedLeaseDuration :: Lens' WorkItemStatus (Maybe Text)
wisRequestedLeaseDuration
= lens _wisRequestedLeaseDuration
(\ s a -> s{_wisRequestedLeaseDuration = a})
wisErrors :: Lens' WorkItemStatus [Status]
wisErrors
= lens _wisErrors (\ s a -> s{_wisErrors = a}) .
_Default
. _Coerce
wisCounterUpdates :: Lens' WorkItemStatus [CounterUpdate]
wisCounterUpdates
= lens _wisCounterUpdates
(\ s a -> s{_wisCounterUpdates = a})
. _Default
. _Coerce
wisMetricUpdates :: Lens' WorkItemStatus [MetricUpdate]
wisMetricUpdates
= lens _wisMetricUpdates
(\ s a -> s{_wisMetricUpdates = a})
. _Default
. _Coerce
wisWorkItemId :: Lens' WorkItemStatus (Maybe Text)
wisWorkItemId
= lens _wisWorkItemId
(\ s a -> s{_wisWorkItemId = a})
instance FromJSON WorkItemStatus where
parseJSON
= withObject "WorkItemStatus"
(\ o ->
WorkItemStatus' <$>
(o .:? "reportedProgress") <*> (o .:? "progress") <*>
(o .:? "sourceOperationResponse")
<*> (o .:? "stopPosition")
<*> (o .:? "dynamicSourceSplit")
<*> (o .:? "completed")
<*> (o .:? "sourceFork")
<*> (o .:? "reportIndex")
<*> (o .:? "requestedLeaseDuration")
<*> (o .:? "errors" .!= mempty)
<*> (o .:? "counterUpdates" .!= mempty)
<*> (o .:? "metricUpdates" .!= mempty)
<*> (o .:? "workItemId"))
instance ToJSON WorkItemStatus where
toJSON WorkItemStatus'{..}
= object
(catMaybes
[("reportedProgress" .=) <$> _wisReportedProgress,
("progress" .=) <$> _wisProgress,
("sourceOperationResponse" .=) <$>
_wisSourceOperationResponse,
("stopPosition" .=) <$> _wisStopPosition,
("dynamicSourceSplit" .=) <$> _wisDynamicSourceSplit,
("completed" .=) <$> _wisCompleted,
("sourceFork" .=) <$> _wisSourceFork,
("reportIndex" .=) <$> _wisReportIndex,
("requestedLeaseDuration" .=) <$>
_wisRequestedLeaseDuration,
("errors" .=) <$> _wisErrors,
("counterUpdates" .=) <$> _wisCounterUpdates,
("metricUpdates" .=) <$> _wisMetricUpdates,
("workItemId" .=) <$> _wisWorkItemId])
newtype WorkerMessageLabels = WorkerMessageLabels'
{ _wmlAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessageLabels
:: HashMap Text Text
-> WorkerMessageLabels
workerMessageLabels pWmlAddtional_ =
WorkerMessageLabels'
{ _wmlAddtional = _Coerce # pWmlAddtional_
}
wmlAddtional :: Lens' WorkerMessageLabels (HashMap Text Text)
wmlAddtional
= lens _wmlAddtional (\ s a -> s{_wmlAddtional = a})
. _Coerce
instance FromJSON WorkerMessageLabels where
parseJSON
= withObject "WorkerMessageLabels"
(\ o -> WorkerMessageLabels' <$> (parseJSONObject o))
instance ToJSON WorkerMessageLabels where
toJSON = toJSON . _wmlAddtional
newtype FlattenInstruction = FlattenInstruction'
{ _fiInputs :: Maybe [InstructionInput]
} deriving (Eq,Show,Data,Typeable,Generic)
flattenInstruction
:: FlattenInstruction
flattenInstruction =
FlattenInstruction'
{ _fiInputs = Nothing
}
fiInputs :: Lens' FlattenInstruction [InstructionInput]
fiInputs
= lens _fiInputs (\ s a -> s{_fiInputs = a}) .
_Default
. _Coerce
instance FromJSON FlattenInstruction where
parseJSON
= withObject "FlattenInstruction"
(\ o ->
FlattenInstruction' <$> (o .:? "inputs" .!= mempty))
instance ToJSON FlattenInstruction where
toJSON FlattenInstruction'{..}
= object (catMaybes [("inputs" .=) <$> _fiInputs])
data WorkerMessageCode = WorkerMessageCode'
{ _wmcParameters :: !(Maybe WorkerMessageCodeParameters)
, _wmcCode :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessageCode
:: WorkerMessageCode
workerMessageCode =
WorkerMessageCode'
{ _wmcParameters = Nothing
, _wmcCode = Nothing
}
wmcParameters :: Lens' WorkerMessageCode (Maybe WorkerMessageCodeParameters)
wmcParameters
= lens _wmcParameters
(\ s a -> s{_wmcParameters = a})
wmcCode :: Lens' WorkerMessageCode (Maybe Text)
wmcCode = lens _wmcCode (\ s a -> s{_wmcCode = a})
instance FromJSON WorkerMessageCode where
parseJSON
= withObject "WorkerMessageCode"
(\ o ->
WorkerMessageCode' <$>
(o .:? "parameters") <*> (o .:? "code"))
instance ToJSON WorkerMessageCode where
toJSON WorkerMessageCode'{..}
= object
(catMaybes
[("parameters" .=) <$> _wmcParameters,
("code" .=) <$> _wmcCode])
newtype JobTransformNameMApping = JobTransformNameMApping'
{ _jtnmaAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
jobTransformNameMApping
:: HashMap Text Text
-> JobTransformNameMApping
jobTransformNameMApping pJtnmaAddtional_ =
JobTransformNameMApping'
{ _jtnmaAddtional = _Coerce # pJtnmaAddtional_
}
jtnmaAddtional :: Lens' JobTransformNameMApping (HashMap Text Text)
jtnmaAddtional
= lens _jtnmaAddtional
(\ s a -> s{_jtnmaAddtional = a})
. _Coerce
instance FromJSON JobTransformNameMApping where
parseJSON
= withObject "JobTransformNameMApping"
(\ o ->
JobTransformNameMApping' <$> (parseJSONObject o))
instance ToJSON JobTransformNameMApping where
toJSON = toJSON . _jtnmaAddtional
newtype SourceSpec = SourceSpec'
{ _ssAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
sourceSpec
:: HashMap Text JSONValue
-> SourceSpec
sourceSpec pSsAddtional_ =
SourceSpec'
{ _ssAddtional = _Coerce # pSsAddtional_
}
ssAddtional :: Lens' SourceSpec (HashMap Text JSONValue)
ssAddtional
= lens _ssAddtional (\ s a -> s{_ssAddtional = a}) .
_Coerce
instance FromJSON SourceSpec where
parseJSON
= withObject "SourceSpec"
(\ o -> SourceSpec' <$> (parseJSONObject o))
instance ToJSON SourceSpec where
toJSON = toJSON . _ssAddtional
data SourceMetadata = SourceMetadata'
{ _smEstimatedSizeBytes :: !(Maybe (Textual Int64))
, _smProducesSortedKeys :: !(Maybe Bool)
, _smInfinite :: !(Maybe Bool)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceMetadata
:: SourceMetadata
sourceMetadata =
SourceMetadata'
{ _smEstimatedSizeBytes = Nothing
, _smProducesSortedKeys = Nothing
, _smInfinite = Nothing
}
smEstimatedSizeBytes :: Lens' SourceMetadata (Maybe Int64)
smEstimatedSizeBytes
= lens _smEstimatedSizeBytes
(\ s a -> s{_smEstimatedSizeBytes = a})
. mapping _Coerce
smProducesSortedKeys :: Lens' SourceMetadata (Maybe Bool)
smProducesSortedKeys
= lens _smProducesSortedKeys
(\ s a -> s{_smProducesSortedKeys = a})
smInfinite :: Lens' SourceMetadata (Maybe Bool)
smInfinite
= lens _smInfinite (\ s a -> s{_smInfinite = a})
instance FromJSON SourceMetadata where
parseJSON
= withObject "SourceMetadata"
(\ o ->
SourceMetadata' <$>
(o .:? "estimatedSizeBytes") <*>
(o .:? "producesSortedKeys")
<*> (o .:? "infinite"))
instance ToJSON SourceMetadata where
toJSON SourceMetadata'{..}
= object
(catMaybes
[("estimatedSizeBytes" .=) <$> _smEstimatedSizeBytes,
("producesSortedKeys" .=) <$> _smProducesSortedKeys,
("infinite" .=) <$> _smInfinite])
newtype EnvironmentInternalExperiments = EnvironmentInternalExperiments'
{ _eieAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
environmentInternalExperiments
:: HashMap Text JSONValue
-> EnvironmentInternalExperiments
environmentInternalExperiments pEieAddtional_ =
EnvironmentInternalExperiments'
{ _eieAddtional = _Coerce # pEieAddtional_
}
eieAddtional :: Lens' EnvironmentInternalExperiments (HashMap Text JSONValue)
eieAddtional
= lens _eieAddtional (\ s a -> s{_eieAddtional = a})
. _Coerce
instance FromJSON EnvironmentInternalExperiments
where
parseJSON
= withObject "EnvironmentInternalExperiments"
(\ o ->
EnvironmentInternalExperiments' <$>
(parseJSONObject o))
instance ToJSON EnvironmentInternalExperiments where
toJSON = toJSON . _eieAddtional
data TaskRunnerSettings = TaskRunnerSettings'
{ _trsContinueOnException :: !(Maybe Bool)
, _trsHarnessCommand :: !(Maybe Text)
, _trsWorkflowFileName :: !(Maybe Text)
, _trsTaskGroup :: !(Maybe Text)
, _trsAlsologtostderr :: !(Maybe Bool)
, _trsDataflowAPIVersion :: !(Maybe Text)
, _trsLogDir :: !(Maybe Text)
, _trsCommandlinesFileName :: !(Maybe Text)
, _trsVMId :: !(Maybe Text)
, _trsBaseURL :: !(Maybe Text)
, _trsOAuthScopes :: !(Maybe [Text])
, _trsTaskUser :: !(Maybe Text)
, _trsStreamingWorkerMainClass :: !(Maybe Text)
, _trsBaseTaskDir :: !(Maybe Text)
, _trsLogUploadLocation :: !(Maybe Text)
, _trsTempStoragePrefix :: !(Maybe Text)
, _trsLogToSerialconsole :: !(Maybe Bool)
, _trsParallelWorkerSettings :: !(Maybe WorkerSettings)
, _trsLanguageHint :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
taskRunnerSettings
:: TaskRunnerSettings
taskRunnerSettings =
TaskRunnerSettings'
{ _trsContinueOnException = Nothing
, _trsHarnessCommand = Nothing
, _trsWorkflowFileName = Nothing
, _trsTaskGroup = Nothing
, _trsAlsologtostderr = Nothing
, _trsDataflowAPIVersion = Nothing
, _trsLogDir = Nothing
, _trsCommandlinesFileName = Nothing
, _trsVMId = Nothing
, _trsBaseURL = Nothing
, _trsOAuthScopes = Nothing
, _trsTaskUser = Nothing
, _trsStreamingWorkerMainClass = Nothing
, _trsBaseTaskDir = Nothing
, _trsLogUploadLocation = Nothing
, _trsTempStoragePrefix = Nothing
, _trsLogToSerialconsole = Nothing
, _trsParallelWorkerSettings = Nothing
, _trsLanguageHint = Nothing
}
trsContinueOnException :: Lens' TaskRunnerSettings (Maybe Bool)
trsContinueOnException
= lens _trsContinueOnException
(\ s a -> s{_trsContinueOnException = a})
trsHarnessCommand :: Lens' TaskRunnerSettings (Maybe Text)
trsHarnessCommand
= lens _trsHarnessCommand
(\ s a -> s{_trsHarnessCommand = a})
trsWorkflowFileName :: Lens' TaskRunnerSettings (Maybe Text)
trsWorkflowFileName
= lens _trsWorkflowFileName
(\ s a -> s{_trsWorkflowFileName = a})
trsTaskGroup :: Lens' TaskRunnerSettings (Maybe Text)
trsTaskGroup
= lens _trsTaskGroup (\ s a -> s{_trsTaskGroup = a})
trsAlsologtostderr :: Lens' TaskRunnerSettings (Maybe Bool)
trsAlsologtostderr
= lens _trsAlsologtostderr
(\ s a -> s{_trsAlsologtostderr = a})
trsDataflowAPIVersion :: Lens' TaskRunnerSettings (Maybe Text)
trsDataflowAPIVersion
= lens _trsDataflowAPIVersion
(\ s a -> s{_trsDataflowAPIVersion = a})
trsLogDir :: Lens' TaskRunnerSettings (Maybe Text)
trsLogDir
= lens _trsLogDir (\ s a -> s{_trsLogDir = a})
trsCommandlinesFileName :: Lens' TaskRunnerSettings (Maybe Text)
trsCommandlinesFileName
= lens _trsCommandlinesFileName
(\ s a -> s{_trsCommandlinesFileName = a})
trsVMId :: Lens' TaskRunnerSettings (Maybe Text)
trsVMId = lens _trsVMId (\ s a -> s{_trsVMId = a})
trsBaseURL :: Lens' TaskRunnerSettings (Maybe Text)
trsBaseURL
= lens _trsBaseURL (\ s a -> s{_trsBaseURL = a})
trsOAuthScopes :: Lens' TaskRunnerSettings [Text]
trsOAuthScopes
= lens _trsOAuthScopes
(\ s a -> s{_trsOAuthScopes = a})
. _Default
. _Coerce
trsTaskUser :: Lens' TaskRunnerSettings (Maybe Text)
trsTaskUser
= lens _trsTaskUser (\ s a -> s{_trsTaskUser = a})
trsStreamingWorkerMainClass :: Lens' TaskRunnerSettings (Maybe Text)
trsStreamingWorkerMainClass
= lens _trsStreamingWorkerMainClass
(\ s a -> s{_trsStreamingWorkerMainClass = a})
trsBaseTaskDir :: Lens' TaskRunnerSettings (Maybe Text)
trsBaseTaskDir
= lens _trsBaseTaskDir
(\ s a -> s{_trsBaseTaskDir = a})
trsLogUploadLocation :: Lens' TaskRunnerSettings (Maybe Text)
trsLogUploadLocation
= lens _trsLogUploadLocation
(\ s a -> s{_trsLogUploadLocation = a})
trsTempStoragePrefix :: Lens' TaskRunnerSettings (Maybe Text)
trsTempStoragePrefix
= lens _trsTempStoragePrefix
(\ s a -> s{_trsTempStoragePrefix = a})
trsLogToSerialconsole :: Lens' TaskRunnerSettings (Maybe Bool)
trsLogToSerialconsole
= lens _trsLogToSerialconsole
(\ s a -> s{_trsLogToSerialconsole = a})
trsParallelWorkerSettings :: Lens' TaskRunnerSettings (Maybe WorkerSettings)
trsParallelWorkerSettings
= lens _trsParallelWorkerSettings
(\ s a -> s{_trsParallelWorkerSettings = a})
trsLanguageHint :: Lens' TaskRunnerSettings (Maybe Text)
trsLanguageHint
= lens _trsLanguageHint
(\ s a -> s{_trsLanguageHint = a})
instance FromJSON TaskRunnerSettings where
parseJSON
= withObject "TaskRunnerSettings"
(\ o ->
TaskRunnerSettings' <$>
(o .:? "continueOnException") <*>
(o .:? "harnessCommand")
<*> (o .:? "workflowFileName")
<*> (o .:? "taskGroup")
<*> (o .:? "alsologtostderr")
<*> (o .:? "dataflowApiVersion")
<*> (o .:? "logDir")
<*> (o .:? "commandlinesFileName")
<*> (o .:? "vmId")
<*> (o .:? "baseUrl")
<*> (o .:? "oauthScopes" .!= mempty)
<*> (o .:? "taskUser")
<*> (o .:? "streamingWorkerMainClass")
<*> (o .:? "baseTaskDir")
<*> (o .:? "logUploadLocation")
<*> (o .:? "tempStoragePrefix")
<*> (o .:? "logToSerialconsole")
<*> (o .:? "parallelWorkerSettings")
<*> (o .:? "languageHint"))
instance ToJSON TaskRunnerSettings where
toJSON TaskRunnerSettings'{..}
= object
(catMaybes
[("continueOnException" .=) <$>
_trsContinueOnException,
("harnessCommand" .=) <$> _trsHarnessCommand,
("workflowFileName" .=) <$> _trsWorkflowFileName,
("taskGroup" .=) <$> _trsTaskGroup,
("alsologtostderr" .=) <$> _trsAlsologtostderr,
("dataflowApiVersion" .=) <$> _trsDataflowAPIVersion,
("logDir" .=) <$> _trsLogDir,
("commandlinesFileName" .=) <$>
_trsCommandlinesFileName,
("vmId" .=) <$> _trsVMId,
("baseUrl" .=) <$> _trsBaseURL,
("oauthScopes" .=) <$> _trsOAuthScopes,
("taskUser" .=) <$> _trsTaskUser,
("streamingWorkerMainClass" .=) <$>
_trsStreamingWorkerMainClass,
("baseTaskDir" .=) <$> _trsBaseTaskDir,
("logUploadLocation" .=) <$> _trsLogUploadLocation,
("tempStoragePrefix" .=) <$> _trsTempStoragePrefix,
("logToSerialconsole" .=) <$> _trsLogToSerialconsole,
("parallelWorkerSettings" .=) <$>
_trsParallelWorkerSettings,
("languageHint" .=) <$> _trsLanguageHint])
data StreamingComputationConfig = StreamingComputationConfig'
{ _sccInstructions :: !(Maybe [ParallelInstruction])
, _sccSystemName :: !(Maybe Text)
, _sccComputationId :: !(Maybe Text)
, _sccStageName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
streamingComputationConfig
:: StreamingComputationConfig
streamingComputationConfig =
StreamingComputationConfig'
{ _sccInstructions = Nothing
, _sccSystemName = Nothing
, _sccComputationId = Nothing
, _sccStageName = Nothing
}
sccInstructions :: Lens' StreamingComputationConfig [ParallelInstruction]
sccInstructions
= lens _sccInstructions
(\ s a -> s{_sccInstructions = a})
. _Default
. _Coerce
sccSystemName :: Lens' StreamingComputationConfig (Maybe Text)
sccSystemName
= lens _sccSystemName
(\ s a -> s{_sccSystemName = a})
sccComputationId :: Lens' StreamingComputationConfig (Maybe Text)
sccComputationId
= lens _sccComputationId
(\ s a -> s{_sccComputationId = a})
sccStageName :: Lens' StreamingComputationConfig (Maybe Text)
sccStageName
= lens _sccStageName (\ s a -> s{_sccStageName = a})
instance FromJSON StreamingComputationConfig where
parseJSON
= withObject "StreamingComputationConfig"
(\ o ->
StreamingComputationConfig' <$>
(o .:? "instructions" .!= mempty) <*>
(o .:? "systemName")
<*> (o .:? "computationId")
<*> (o .:? "stageName"))
instance ToJSON StreamingComputationConfig where
toJSON StreamingComputationConfig'{..}
= object
(catMaybes
[("instructions" .=) <$> _sccInstructions,
("systemName" .=) <$> _sccSystemName,
("computationId" .=) <$> _sccComputationId,
("stageName" .=) <$> _sccStageName])
newtype EnvironmentSdkPipelineOptions = EnvironmentSdkPipelineOptions'
{ _espoAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
environmentSdkPipelineOptions
:: HashMap Text JSONValue
-> EnvironmentSdkPipelineOptions
environmentSdkPipelineOptions pEspoAddtional_ =
EnvironmentSdkPipelineOptions'
{ _espoAddtional = _Coerce # pEspoAddtional_
}
espoAddtional :: Lens' EnvironmentSdkPipelineOptions (HashMap Text JSONValue)
espoAddtional
= lens _espoAddtional
(\ s a -> s{_espoAddtional = a})
. _Coerce
instance FromJSON EnvironmentSdkPipelineOptions where
parseJSON
= withObject "EnvironmentSdkPipelineOptions"
(\ o ->
EnvironmentSdkPipelineOptions' <$>
(parseJSONObject o))
instance ToJSON EnvironmentSdkPipelineOptions where
toJSON = toJSON . _espoAddtional
data FloatingPointMean = FloatingPointMean'
{ _fpmCount :: !(Maybe SplitInt64)
, _fpmSum :: !(Maybe (Textual Double))
} deriving (Eq,Show,Data,Typeable,Generic)
floatingPointMean
:: FloatingPointMean
floatingPointMean =
FloatingPointMean'
{ _fpmCount = Nothing
, _fpmSum = Nothing
}
fpmCount :: Lens' FloatingPointMean (Maybe SplitInt64)
fpmCount = lens _fpmCount (\ s a -> s{_fpmCount = a})
fpmSum :: Lens' FloatingPointMean (Maybe Double)
fpmSum
= lens _fpmSum (\ s a -> s{_fpmSum = a}) .
mapping _Coerce
instance FromJSON FloatingPointMean where
parseJSON
= withObject "FloatingPointMean"
(\ o ->
FloatingPointMean' <$>
(o .:? "count") <*> (o .:? "sum"))
instance ToJSON FloatingPointMean where
toJSON FloatingPointMean'{..}
= object
(catMaybes
[("count" .=) <$> _fpmCount, ("sum" .=) <$> _fpmSum])
data LeaseWorkItemRequest = LeaseWorkItemRequest'
{ _lwirWorkItemTypes :: !(Maybe [Text])
, _lwirCurrentWorkerTime :: !(Maybe Text)
, _lwirWorkerCapabilities :: !(Maybe [Text])
, _lwirRequestedLeaseDuration :: !(Maybe Text)
, _lwirWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
leaseWorkItemRequest
:: LeaseWorkItemRequest
leaseWorkItemRequest =
LeaseWorkItemRequest'
{ _lwirWorkItemTypes = Nothing
, _lwirCurrentWorkerTime = Nothing
, _lwirWorkerCapabilities = Nothing
, _lwirRequestedLeaseDuration = Nothing
, _lwirWorkerId = Nothing
}
lwirWorkItemTypes :: Lens' LeaseWorkItemRequest [Text]
lwirWorkItemTypes
= lens _lwirWorkItemTypes
(\ s a -> s{_lwirWorkItemTypes = a})
. _Default
. _Coerce
lwirCurrentWorkerTime :: Lens' LeaseWorkItemRequest (Maybe Text)
lwirCurrentWorkerTime
= lens _lwirCurrentWorkerTime
(\ s a -> s{_lwirCurrentWorkerTime = a})
lwirWorkerCapabilities :: Lens' LeaseWorkItemRequest [Text]
lwirWorkerCapabilities
= lens _lwirWorkerCapabilities
(\ s a -> s{_lwirWorkerCapabilities = a})
. _Default
. _Coerce
lwirRequestedLeaseDuration :: Lens' LeaseWorkItemRequest (Maybe Text)
lwirRequestedLeaseDuration
= lens _lwirRequestedLeaseDuration
(\ s a -> s{_lwirRequestedLeaseDuration = a})
lwirWorkerId :: Lens' LeaseWorkItemRequest (Maybe Text)
lwirWorkerId
= lens _lwirWorkerId (\ s a -> s{_lwirWorkerId = a})
instance FromJSON LeaseWorkItemRequest where
parseJSON
= withObject "LeaseWorkItemRequest"
(\ o ->
LeaseWorkItemRequest' <$>
(o .:? "workItemTypes" .!= mempty) <*>
(o .:? "currentWorkerTime")
<*> (o .:? "workerCapabilities" .!= mempty)
<*> (o .:? "requestedLeaseDuration")
<*> (o .:? "workerId"))
instance ToJSON LeaseWorkItemRequest where
toJSON LeaseWorkItemRequest'{..}
= object
(catMaybes
[("workItemTypes" .=) <$> _lwirWorkItemTypes,
("currentWorkerTime" .=) <$> _lwirCurrentWorkerTime,
("workerCapabilities" .=) <$>
_lwirWorkerCapabilities,
("requestedLeaseDuration" .=) <$>
_lwirRequestedLeaseDuration,
("workerId" .=) <$> _lwirWorkerId])
data SourceOperationResponse = SourceOperationResponse'
{ _sorSplit :: !(Maybe SourceSplitResponse)
, _sorGetMetadata :: !(Maybe SourceGetMetadataResponse)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceOperationResponse
:: SourceOperationResponse
sourceOperationResponse =
SourceOperationResponse'
{ _sorSplit = Nothing
, _sorGetMetadata = Nothing
}
sorSplit :: Lens' SourceOperationResponse (Maybe SourceSplitResponse)
sorSplit = lens _sorSplit (\ s a -> s{_sorSplit = a})
sorGetMetadata :: Lens' SourceOperationResponse (Maybe SourceGetMetadataResponse)
sorGetMetadata
= lens _sorGetMetadata
(\ s a -> s{_sorGetMetadata = a})
instance FromJSON SourceOperationResponse where
parseJSON
= withObject "SourceOperationResponse"
(\ o ->
SourceOperationResponse' <$>
(o .:? "split") <*> (o .:? "getMetadata"))
instance ToJSON SourceOperationResponse where
toJSON SourceOperationResponse'{..}
= object
(catMaybes
[("split" .=) <$> _sorSplit,
("getMetadata" .=) <$> _sorGetMetadata])
newtype TopologyConfigUserStageToComputationNameMap = TopologyConfigUserStageToComputationNameMap'
{ _tcustcnmAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
topologyConfigUserStageToComputationNameMap
:: HashMap Text Text
-> TopologyConfigUserStageToComputationNameMap
topologyConfigUserStageToComputationNameMap pTcustcnmAddtional_ =
TopologyConfigUserStageToComputationNameMap'
{ _tcustcnmAddtional = _Coerce # pTcustcnmAddtional_
}
tcustcnmAddtional :: Lens' TopologyConfigUserStageToComputationNameMap (HashMap Text Text)
tcustcnmAddtional
= lens _tcustcnmAddtional
(\ s a -> s{_tcustcnmAddtional = a})
. _Coerce
instance FromJSON
TopologyConfigUserStageToComputationNameMap where
parseJSON
= withObject
"TopologyConfigUserStageToComputationNameMap"
(\ o ->
TopologyConfigUserStageToComputationNameMap' <$>
(parseJSONObject o))
instance ToJSON
TopologyConfigUserStageToComputationNameMap where
toJSON = toJSON . _tcustcnmAddtional
data ShellTask = ShellTask'
{ _stCommand :: !(Maybe Text)
, _stExitCode :: !(Maybe (Textual Int32))
} deriving (Eq,Show,Data,Typeable,Generic)
shellTask
:: ShellTask
shellTask =
ShellTask'
{ _stCommand = Nothing
, _stExitCode = Nothing
}
stCommand :: Lens' ShellTask (Maybe Text)
stCommand
= lens _stCommand (\ s a -> s{_stCommand = a})
stExitCode :: Lens' ShellTask (Maybe Int32)
stExitCode
= lens _stExitCode (\ s a -> s{_stExitCode = a}) .
mapping _Coerce
instance FromJSON ShellTask where
parseJSON
= withObject "ShellTask"
(\ o ->
ShellTask' <$>
(o .:? "command") <*> (o .:? "exitCode"))
instance ToJSON ShellTask where
toJSON ShellTask'{..}
= object
(catMaybes
[("command" .=) <$> _stCommand,
("exitCode" .=) <$> _stExitCode])
newtype StatusDetailsItem = StatusDetailsItem'
{ _sdiAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
statusDetailsItem
:: HashMap Text JSONValue
-> StatusDetailsItem
statusDetailsItem pSdiAddtional_ =
StatusDetailsItem'
{ _sdiAddtional = _Coerce # pSdiAddtional_
}
sdiAddtional :: Lens' StatusDetailsItem (HashMap Text JSONValue)
sdiAddtional
= lens _sdiAddtional (\ s a -> s{_sdiAddtional = a})
. _Coerce
instance FromJSON StatusDetailsItem where
parseJSON
= withObject "StatusDetailsItem"
(\ o -> StatusDetailsItem' <$> (parseJSONObject o))
instance ToJSON StatusDetailsItem where
toJSON = toJSON . _sdiAddtional
data ReportedParallelism = ReportedParallelism'
{ _rpValue :: !(Maybe (Textual Double))
, _rpIsInfinite :: !(Maybe Bool)
} deriving (Eq,Show,Data,Typeable,Generic)
reportedParallelism
:: ReportedParallelism
reportedParallelism =
ReportedParallelism'
{ _rpValue = Nothing
, _rpIsInfinite = Nothing
}
rpValue :: Lens' ReportedParallelism (Maybe Double)
rpValue
= lens _rpValue (\ s a -> s{_rpValue = a}) .
mapping _Coerce
rpIsInfinite :: Lens' ReportedParallelism (Maybe Bool)
rpIsInfinite
= lens _rpIsInfinite (\ s a -> s{_rpIsInfinite = a})
instance FromJSON ReportedParallelism where
parseJSON
= withObject "ReportedParallelism"
(\ o ->
ReportedParallelism' <$>
(o .:? "value") <*> (o .:? "isInfinite"))
instance ToJSON ReportedParallelism where
toJSON ReportedParallelism'{..}
= object
(catMaybes
[("value" .=) <$> _rpValue,
("isInfinite" .=) <$> _rpIsInfinite])
newtype StepProperties = StepProperties'
{ _spAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
stepProperties
:: HashMap Text JSONValue
-> StepProperties
stepProperties pSpAddtional_ =
StepProperties'
{ _spAddtional = _Coerce # pSpAddtional_
}
spAddtional :: Lens' StepProperties (HashMap Text JSONValue)
spAddtional
= lens _spAddtional (\ s a -> s{_spAddtional = a}) .
_Coerce
instance FromJSON StepProperties where
parseJSON
= withObject "StepProperties"
(\ o -> StepProperties' <$> (parseJSONObject o))
instance ToJSON StepProperties where
toJSON = toJSON . _spAddtional
data TopologyConfig = TopologyConfig'
{ _tcDataDiskAssignments :: !(Maybe [DataDiskAssignment])
, _tcPersistentStateVersion :: !(Maybe (Textual Int32))
, _tcForwardingKeyBits :: !(Maybe (Textual Int32))
, _tcUserStageToComputationNameMap :: !(Maybe TopologyConfigUserStageToComputationNameMap)
, _tcComputations :: !(Maybe [ComputationTopology])
} deriving (Eq,Show,Data,Typeable,Generic)
topologyConfig
:: TopologyConfig
topologyConfig =
TopologyConfig'
{ _tcDataDiskAssignments = Nothing
, _tcPersistentStateVersion = Nothing
, _tcForwardingKeyBits = Nothing
, _tcUserStageToComputationNameMap = Nothing
, _tcComputations = Nothing
}
tcDataDiskAssignments :: Lens' TopologyConfig [DataDiskAssignment]
tcDataDiskAssignments
= lens _tcDataDiskAssignments
(\ s a -> s{_tcDataDiskAssignments = a})
. _Default
. _Coerce
tcPersistentStateVersion :: Lens' TopologyConfig (Maybe Int32)
tcPersistentStateVersion
= lens _tcPersistentStateVersion
(\ s a -> s{_tcPersistentStateVersion = a})
. mapping _Coerce
tcForwardingKeyBits :: Lens' TopologyConfig (Maybe Int32)
tcForwardingKeyBits
= lens _tcForwardingKeyBits
(\ s a -> s{_tcForwardingKeyBits = a})
. mapping _Coerce
tcUserStageToComputationNameMap :: Lens' TopologyConfig (Maybe TopologyConfigUserStageToComputationNameMap)
tcUserStageToComputationNameMap
= lens _tcUserStageToComputationNameMap
(\ s a -> s{_tcUserStageToComputationNameMap = a})
tcComputations :: Lens' TopologyConfig [ComputationTopology]
tcComputations
= lens _tcComputations
(\ s a -> s{_tcComputations = a})
. _Default
. _Coerce
instance FromJSON TopologyConfig where
parseJSON
= withObject "TopologyConfig"
(\ o ->
TopologyConfig' <$>
(o .:? "dataDiskAssignments" .!= mempty) <*>
(o .:? "persistentStateVersion")
<*> (o .:? "forwardingKeyBits")
<*> (o .:? "userStageToComputationNameMap")
<*> (o .:? "computations" .!= mempty))
instance ToJSON TopologyConfig where
toJSON TopologyConfig'{..}
= object
(catMaybes
[("dataDiskAssignments" .=) <$>
_tcDataDiskAssignments,
("persistentStateVersion" .=) <$>
_tcPersistentStateVersion,
("forwardingKeyBits" .=) <$> _tcForwardingKeyBits,
("userStageToComputationNameMap" .=) <$>
_tcUserStageToComputationNameMap,
("computations" .=) <$> _tcComputations])
data ApproximateSplitRequest = ApproximateSplitRequest'
{ _asrFractionConsumed :: !(Maybe (Textual Double))
, _asrPosition :: !(Maybe Position)
} deriving (Eq,Show,Data,Typeable,Generic)
approximateSplitRequest
:: ApproximateSplitRequest
approximateSplitRequest =
ApproximateSplitRequest'
{ _asrFractionConsumed = Nothing
, _asrPosition = Nothing
}
asrFractionConsumed :: Lens' ApproximateSplitRequest (Maybe Double)
asrFractionConsumed
= lens _asrFractionConsumed
(\ s a -> s{_asrFractionConsumed = a})
. mapping _Coerce
asrPosition :: Lens' ApproximateSplitRequest (Maybe Position)
asrPosition
= lens _asrPosition (\ s a -> s{_asrPosition = a})
instance FromJSON ApproximateSplitRequest where
parseJSON
= withObject "ApproximateSplitRequest"
(\ o ->
ApproximateSplitRequest' <$>
(o .:? "fractionConsumed") <*> (o .:? "position"))
instance ToJSON ApproximateSplitRequest where
toJSON ApproximateSplitRequest'{..}
= object
(catMaybes
[("fractionConsumed" .=) <$> _asrFractionConsumed,
("position" .=) <$> _asrPosition])
data SplitInt64 = SplitInt64'
{ _siHighBits :: !(Maybe (Textual Int32))
, _siLowBits :: !(Maybe (Textual Word32))
} deriving (Eq,Show,Data,Typeable,Generic)
splitInt64
:: SplitInt64
splitInt64 =
SplitInt64'
{ _siHighBits = Nothing
, _siLowBits = Nothing
}
siHighBits :: Lens' SplitInt64 (Maybe Int32)
siHighBits
= lens _siHighBits (\ s a -> s{_siHighBits = a}) .
mapping _Coerce
siLowBits :: Lens' SplitInt64 (Maybe Word32)
siLowBits
= lens _siLowBits (\ s a -> s{_siLowBits = a}) .
mapping _Coerce
instance FromJSON SplitInt64 where
parseJSON
= withObject "SplitInt64"
(\ o ->
SplitInt64' <$>
(o .:? "highBits") <*> (o .:? "lowBits"))
instance ToJSON SplitInt64 where
toJSON SplitInt64'{..}
= object
(catMaybes
[("highBits" .=) <$> _siHighBits,
("lowBits" .=) <$> _siLowBits])
data WorkerSettings = WorkerSettings'
{ _wsServicePath :: !(Maybe Text)
, _wsBaseURL :: !(Maybe Text)
, _wsShuffleServicePath :: !(Maybe Text)
, _wsTempStoragePrefix :: !(Maybe Text)
, _wsReportingEnabled :: !(Maybe Bool)
, _wsWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
workerSettings
:: WorkerSettings
workerSettings =
WorkerSettings'
{ _wsServicePath = Nothing
, _wsBaseURL = Nothing
, _wsShuffleServicePath = Nothing
, _wsTempStoragePrefix = Nothing
, _wsReportingEnabled = Nothing
, _wsWorkerId = Nothing
}
wsServicePath :: Lens' WorkerSettings (Maybe Text)
wsServicePath
= lens _wsServicePath
(\ s a -> s{_wsServicePath = a})
wsBaseURL :: Lens' WorkerSettings (Maybe Text)
wsBaseURL
= lens _wsBaseURL (\ s a -> s{_wsBaseURL = a})
wsShuffleServicePath :: Lens' WorkerSettings (Maybe Text)
wsShuffleServicePath
= lens _wsShuffleServicePath
(\ s a -> s{_wsShuffleServicePath = a})
wsTempStoragePrefix :: Lens' WorkerSettings (Maybe Text)
wsTempStoragePrefix
= lens _wsTempStoragePrefix
(\ s a -> s{_wsTempStoragePrefix = a})
wsReportingEnabled :: Lens' WorkerSettings (Maybe Bool)
wsReportingEnabled
= lens _wsReportingEnabled
(\ s a -> s{_wsReportingEnabled = a})
wsWorkerId :: Lens' WorkerSettings (Maybe Text)
wsWorkerId
= lens _wsWorkerId (\ s a -> s{_wsWorkerId = a})
instance FromJSON WorkerSettings where
parseJSON
= withObject "WorkerSettings"
(\ o ->
WorkerSettings' <$>
(o .:? "servicePath") <*> (o .:? "baseUrl") <*>
(o .:? "shuffleServicePath")
<*> (o .:? "tempStoragePrefix")
<*> (o .:? "reportingEnabled")
<*> (o .:? "workerId"))
instance ToJSON WorkerSettings where
toJSON WorkerSettings'{..}
= object
(catMaybes
[("servicePath" .=) <$> _wsServicePath,
("baseUrl" .=) <$> _wsBaseURL,
("shuffleServicePath" .=) <$> _wsShuffleServicePath,
("tempStoragePrefix" .=) <$> _wsTempStoragePrefix,
("reportingEnabled" .=) <$> _wsReportingEnabled,
("workerId" .=) <$> _wsWorkerId])
newtype GetDebugConfigResponse = GetDebugConfigResponse'
{ _gdcrConfig :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
getDebugConfigResponse
:: GetDebugConfigResponse
getDebugConfigResponse =
GetDebugConfigResponse'
{ _gdcrConfig = Nothing
}
gdcrConfig :: Lens' GetDebugConfigResponse (Maybe Text)
gdcrConfig
= lens _gdcrConfig (\ s a -> s{_gdcrConfig = a})
instance FromJSON GetDebugConfigResponse where
parseJSON
= withObject "GetDebugConfigResponse"
(\ o -> GetDebugConfigResponse' <$> (o .:? "config"))
instance ToJSON GetDebugConfigResponse where
toJSON GetDebugConfigResponse'{..}
= object (catMaybes [("config" .=) <$> _gdcrConfig])
newtype WorkItemServiceStateHarnessData = WorkItemServiceStateHarnessData'
{ _wisshdAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
workItemServiceStateHarnessData
:: HashMap Text JSONValue
-> WorkItemServiceStateHarnessData
workItemServiceStateHarnessData pWisshdAddtional_ =
WorkItemServiceStateHarnessData'
{ _wisshdAddtional = _Coerce # pWisshdAddtional_
}
wisshdAddtional :: Lens' WorkItemServiceStateHarnessData (HashMap Text JSONValue)
wisshdAddtional
= lens _wisshdAddtional
(\ s a -> s{_wisshdAddtional = a})
. _Coerce
instance FromJSON WorkItemServiceStateHarnessData
where
parseJSON
= withObject "WorkItemServiceStateHarnessData"
(\ o ->
WorkItemServiceStateHarnessData' <$>
(parseJSONObject o))
instance ToJSON WorkItemServiceStateHarnessData where
toJSON = toJSON . _wisshdAddtional
data DataDiskAssignment = DataDiskAssignment'
{ _ddaVMInstance :: !(Maybe Text)
, _ddaDataDisks :: !(Maybe [Text])
} deriving (Eq,Show,Data,Typeable,Generic)
dataDiskAssignment
:: DataDiskAssignment
dataDiskAssignment =
DataDiskAssignment'
{ _ddaVMInstance = Nothing
, _ddaDataDisks = Nothing
}
ddaVMInstance :: Lens' DataDiskAssignment (Maybe Text)
ddaVMInstance
= lens _ddaVMInstance
(\ s a -> s{_ddaVMInstance = a})
ddaDataDisks :: Lens' DataDiskAssignment [Text]
ddaDataDisks
= lens _ddaDataDisks (\ s a -> s{_ddaDataDisks = a})
. _Default
. _Coerce
instance FromJSON DataDiskAssignment where
parseJSON
= withObject "DataDiskAssignment"
(\ o ->
DataDiskAssignment' <$>
(o .:? "vmInstance") <*>
(o .:? "dataDisks" .!= mempty))
instance ToJSON DataDiskAssignment where
toJSON DataDiskAssignment'{..}
= object
(catMaybes
[("vmInstance" .=) <$> _ddaVMInstance,
("dataDisks" .=) <$> _ddaDataDisks])
newtype WorkerMessageResponse = WorkerMessageResponse'
{ _wmrWorkerHealthReportResponse :: Maybe WorkerHealthReportResponse
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessageResponse
:: WorkerMessageResponse
workerMessageResponse =
WorkerMessageResponse'
{ _wmrWorkerHealthReportResponse = Nothing
}
wmrWorkerHealthReportResponse :: Lens' WorkerMessageResponse (Maybe WorkerHealthReportResponse)
wmrWorkerHealthReportResponse
= lens _wmrWorkerHealthReportResponse
(\ s a -> s{_wmrWorkerHealthReportResponse = a})
instance FromJSON WorkerMessageResponse where
parseJSON
= withObject "WorkerMessageResponse"
(\ o ->
WorkerMessageResponse' <$>
(o .:? "workerHealthReportResponse"))
instance ToJSON WorkerMessageResponse where
toJSON WorkerMessageResponse'{..}
= object
(catMaybes
[("workerHealthReportResponse" .=) <$>
_wmrWorkerHealthReportResponse])
newtype CreateJobFromTemplateRequestParameters = CreateJobFromTemplateRequestParameters'
{ _cjftrpAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
createJobFromTemplateRequestParameters
:: HashMap Text Text
-> CreateJobFromTemplateRequestParameters
createJobFromTemplateRequestParameters pCjftrpAddtional_ =
CreateJobFromTemplateRequestParameters'
{ _cjftrpAddtional = _Coerce # pCjftrpAddtional_
}
cjftrpAddtional :: Lens' CreateJobFromTemplateRequestParameters (HashMap Text Text)
cjftrpAddtional
= lens _cjftrpAddtional
(\ s a -> s{_cjftrpAddtional = a})
. _Coerce
instance FromJSON
CreateJobFromTemplateRequestParameters where
parseJSON
= withObject "CreateJobFromTemplateRequestParameters"
(\ o ->
CreateJobFromTemplateRequestParameters' <$>
(parseJSONObject o))
instance ToJSON
CreateJobFromTemplateRequestParameters where
toJSON = toJSON . _cjftrpAddtional
data WorkItemServiceState = WorkItemServiceState'
{ _wissNextReportIndex :: !(Maybe (Textual Int64))
, _wissReportStatusInterval :: !(Maybe Text)
, _wissHarnessData :: !(Maybe WorkItemServiceStateHarnessData)
, _wissSuggestedStopPoint :: !(Maybe ApproximateProgress)
, _wissSuggestedStopPosition :: !(Maybe Position)
, _wissLeaseExpireTime :: !(Maybe Text)
, _wissSplitRequest :: !(Maybe ApproximateSplitRequest)
, _wissMetricShortId :: !(Maybe [MetricShortId])
} deriving (Eq,Show,Data,Typeable,Generic)
workItemServiceState
:: WorkItemServiceState
workItemServiceState =
WorkItemServiceState'
{ _wissNextReportIndex = Nothing
, _wissReportStatusInterval = Nothing
, _wissHarnessData = Nothing
, _wissSuggestedStopPoint = Nothing
, _wissSuggestedStopPosition = Nothing
, _wissLeaseExpireTime = Nothing
, _wissSplitRequest = Nothing
, _wissMetricShortId = Nothing
}
wissNextReportIndex :: Lens' WorkItemServiceState (Maybe Int64)
wissNextReportIndex
= lens _wissNextReportIndex
(\ s a -> s{_wissNextReportIndex = a})
. mapping _Coerce
wissReportStatusInterval :: Lens' WorkItemServiceState (Maybe Text)
wissReportStatusInterval
= lens _wissReportStatusInterval
(\ s a -> s{_wissReportStatusInterval = a})
wissHarnessData :: Lens' WorkItemServiceState (Maybe WorkItemServiceStateHarnessData)
wissHarnessData
= lens _wissHarnessData
(\ s a -> s{_wissHarnessData = a})
wissSuggestedStopPoint :: Lens' WorkItemServiceState (Maybe ApproximateProgress)
wissSuggestedStopPoint
= lens _wissSuggestedStopPoint
(\ s a -> s{_wissSuggestedStopPoint = a})
wissSuggestedStopPosition :: Lens' WorkItemServiceState (Maybe Position)
wissSuggestedStopPosition
= lens _wissSuggestedStopPosition
(\ s a -> s{_wissSuggestedStopPosition = a})
wissLeaseExpireTime :: Lens' WorkItemServiceState (Maybe Text)
wissLeaseExpireTime
= lens _wissLeaseExpireTime
(\ s a -> s{_wissLeaseExpireTime = a})
wissSplitRequest :: Lens' WorkItemServiceState (Maybe ApproximateSplitRequest)
wissSplitRequest
= lens _wissSplitRequest
(\ s a -> s{_wissSplitRequest = a})
wissMetricShortId :: Lens' WorkItemServiceState [MetricShortId]
wissMetricShortId
= lens _wissMetricShortId
(\ s a -> s{_wissMetricShortId = a})
. _Default
. _Coerce
instance FromJSON WorkItemServiceState where
parseJSON
= withObject "WorkItemServiceState"
(\ o ->
WorkItemServiceState' <$>
(o .:? "nextReportIndex") <*>
(o .:? "reportStatusInterval")
<*> (o .:? "harnessData")
<*> (o .:? "suggestedStopPoint")
<*> (o .:? "suggestedStopPosition")
<*> (o .:? "leaseExpireTime")
<*> (o .:? "splitRequest")
<*> (o .:? "metricShortId" .!= mempty))
instance ToJSON WorkItemServiceState where
toJSON WorkItemServiceState'{..}
= object
(catMaybes
[("nextReportIndex" .=) <$> _wissNextReportIndex,
("reportStatusInterval" .=) <$>
_wissReportStatusInterval,
("harnessData" .=) <$> _wissHarnessData,
("suggestedStopPoint" .=) <$>
_wissSuggestedStopPoint,
("suggestedStopPosition" .=) <$>
_wissSuggestedStopPosition,
("leaseExpireTime" .=) <$> _wissLeaseExpireTime,
("splitRequest" .=) <$> _wissSplitRequest,
("metricShortId" .=) <$> _wissMetricShortId])
data StreamingSetupTask = StreamingSetupTask'
{ _sstStreamingComputationTopology :: !(Maybe TopologyConfig)
, _sstReceiveWorkPort :: !(Maybe (Textual Int32))
, _sstWorkerHarnessPort :: !(Maybe (Textual Int32))
, _sstDrain :: !(Maybe Bool)
} deriving (Eq,Show,Data,Typeable,Generic)
streamingSetupTask
:: StreamingSetupTask
streamingSetupTask =
StreamingSetupTask'
{ _sstStreamingComputationTopology = Nothing
, _sstReceiveWorkPort = Nothing
, _sstWorkerHarnessPort = Nothing
, _sstDrain = Nothing
}
sstStreamingComputationTopology :: Lens' StreamingSetupTask (Maybe TopologyConfig)
sstStreamingComputationTopology
= lens _sstStreamingComputationTopology
(\ s a -> s{_sstStreamingComputationTopology = a})
sstReceiveWorkPort :: Lens' StreamingSetupTask (Maybe Int32)
sstReceiveWorkPort
= lens _sstReceiveWorkPort
(\ s a -> s{_sstReceiveWorkPort = a})
. mapping _Coerce
sstWorkerHarnessPort :: Lens' StreamingSetupTask (Maybe Int32)
sstWorkerHarnessPort
= lens _sstWorkerHarnessPort
(\ s a -> s{_sstWorkerHarnessPort = a})
. mapping _Coerce
sstDrain :: Lens' StreamingSetupTask (Maybe Bool)
sstDrain = lens _sstDrain (\ s a -> s{_sstDrain = a})
instance FromJSON StreamingSetupTask where
parseJSON
= withObject "StreamingSetupTask"
(\ o ->
StreamingSetupTask' <$>
(o .:? "streamingComputationTopology") <*>
(o .:? "receiveWorkPort")
<*> (o .:? "workerHarnessPort")
<*> (o .:? "drain"))
instance ToJSON StreamingSetupTask where
toJSON StreamingSetupTask'{..}
= object
(catMaybes
[("streamingComputationTopology" .=) <$>
_sstStreamingComputationTopology,
("receiveWorkPort" .=) <$> _sstReceiveWorkPort,
("workerHarnessPort" .=) <$> _sstWorkerHarnessPort,
("drain" .=) <$> _sstDrain])
newtype PartialGroupByKeyInstructionInputElementCodec = PartialGroupByKeyInstructionInputElementCodec'
{ _pgbkiiecAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
partialGroupByKeyInstructionInputElementCodec
:: HashMap Text JSONValue
-> PartialGroupByKeyInstructionInputElementCodec
partialGroupByKeyInstructionInputElementCodec pPgbkiiecAddtional_ =
PartialGroupByKeyInstructionInputElementCodec'
{ _pgbkiiecAddtional = _Coerce # pPgbkiiecAddtional_
}
pgbkiiecAddtional :: Lens' PartialGroupByKeyInstructionInputElementCodec (HashMap Text JSONValue)
pgbkiiecAddtional
= lens _pgbkiiecAddtional
(\ s a -> s{_pgbkiiecAddtional = a})
. _Coerce
instance FromJSON
PartialGroupByKeyInstructionInputElementCodec where
parseJSON
= withObject
"PartialGroupByKeyInstructionInputElementCodec"
(\ o ->
PartialGroupByKeyInstructionInputElementCodec' <$>
(parseJSONObject o))
instance ToJSON
PartialGroupByKeyInstructionInputElementCodec where
toJSON = toJSON . _pgbkiiecAddtional
data MapTask = MapTask'
{ _mtInstructions :: !(Maybe [ParallelInstruction])
, _mtSystemName :: !(Maybe Text)
, _mtStageName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
mapTask
:: MapTask
mapTask =
MapTask'
{ _mtInstructions = Nothing
, _mtSystemName = Nothing
, _mtStageName = Nothing
}
mtInstructions :: Lens' MapTask [ParallelInstruction]
mtInstructions
= lens _mtInstructions
(\ s a -> s{_mtInstructions = a})
. _Default
. _Coerce
mtSystemName :: Lens' MapTask (Maybe Text)
mtSystemName
= lens _mtSystemName (\ s a -> s{_mtSystemName = a})
mtStageName :: Lens' MapTask (Maybe Text)
mtStageName
= lens _mtStageName (\ s a -> s{_mtStageName = a})
instance FromJSON MapTask where
parseJSON
= withObject "MapTask"
(\ o ->
MapTask' <$>
(o .:? "instructions" .!= mempty) <*>
(o .:? "systemName")
<*> (o .:? "stageName"))
instance ToJSON MapTask where
toJSON MapTask'{..}
= object
(catMaybes
[("instructions" .=) <$> _mtInstructions,
("systemName" .=) <$> _mtSystemName,
("stageName" .=) <$> _mtStageName])
newtype MountedDataDisk = MountedDataDisk'
{ _mddDataDisk :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
mountedDataDisk
:: MountedDataDisk
mountedDataDisk =
MountedDataDisk'
{ _mddDataDisk = Nothing
}
mddDataDisk :: Lens' MountedDataDisk (Maybe Text)
mddDataDisk
= lens _mddDataDisk (\ s a -> s{_mddDataDisk = a})
instance FromJSON MountedDataDisk where
parseJSON
= withObject "MountedDataDisk"
(\ o -> MountedDataDisk' <$> (o .:? "dataDisk"))
instance ToJSON MountedDataDisk where
toJSON MountedDataDisk'{..}
= object
(catMaybes [("dataDisk" .=) <$> _mddDataDisk])
newtype SinkCodec = SinkCodec'
{ _scAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
sinkCodec
:: HashMap Text JSONValue
-> SinkCodec
sinkCodec pScAddtional_ =
SinkCodec'
{ _scAddtional = _Coerce # pScAddtional_
}
scAddtional :: Lens' SinkCodec (HashMap Text JSONValue)
scAddtional
= lens _scAddtional (\ s a -> s{_scAddtional = a}) .
_Coerce
instance FromJSON SinkCodec where
parseJSON
= withObject "SinkCodec"
(\ o -> SinkCodec' <$> (parseJSONObject o))
instance ToJSON SinkCodec where
toJSON = toJSON . _scAddtional
data IntegerMean = IntegerMean'
{ _imCount :: !(Maybe SplitInt64)
, _imSum :: !(Maybe SplitInt64)
} deriving (Eq,Show,Data,Typeable,Generic)
integerMean
:: IntegerMean
integerMean =
IntegerMean'
{ _imCount = Nothing
, _imSum = Nothing
}
imCount :: Lens' IntegerMean (Maybe SplitInt64)
imCount = lens _imCount (\ s a -> s{_imCount = a})
imSum :: Lens' IntegerMean (Maybe SplitInt64)
imSum = lens _imSum (\ s a -> s{_imSum = a})
instance FromJSON IntegerMean where
parseJSON
= withObject "IntegerMean"
(\ o ->
IntegerMean' <$> (o .:? "count") <*> (o .:? "sum"))
instance ToJSON IntegerMean where
toJSON IntegerMean'{..}
= object
(catMaybes
[("count" .=) <$> _imCount, ("sum" .=) <$> _imSum])
newtype WorkerHealthReportPodsItem = WorkerHealthReportPodsItem'
{ _whrpiAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
workerHealthReportPodsItem
:: HashMap Text JSONValue
-> WorkerHealthReportPodsItem
workerHealthReportPodsItem pWhrpiAddtional_ =
WorkerHealthReportPodsItem'
{ _whrpiAddtional = _Coerce # pWhrpiAddtional_
}
whrpiAddtional :: Lens' WorkerHealthReportPodsItem (HashMap Text JSONValue)
whrpiAddtional
= lens _whrpiAddtional
(\ s a -> s{_whrpiAddtional = a})
. _Coerce
instance FromJSON WorkerHealthReportPodsItem where
parseJSON
= withObject "WorkerHealthReportPodsItem"
(\ o ->
WorkerHealthReportPodsItem' <$> (parseJSONObject o))
instance ToJSON WorkerHealthReportPodsItem where
toJSON = toJSON . _whrpiAddtional
newtype ParDoInstructionUserFn = ParDoInstructionUserFn'
{ _pdiufAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
parDoInstructionUserFn
:: HashMap Text JSONValue
-> ParDoInstructionUserFn
parDoInstructionUserFn pPdiufAddtional_ =
ParDoInstructionUserFn'
{ _pdiufAddtional = _Coerce # pPdiufAddtional_
}
pdiufAddtional :: Lens' ParDoInstructionUserFn (HashMap Text JSONValue)
pdiufAddtional
= lens _pdiufAddtional
(\ s a -> s{_pdiufAddtional = a})
. _Coerce
instance FromJSON ParDoInstructionUserFn where
parseJSON
= withObject "ParDoInstructionUserFn"
(\ o ->
ParDoInstructionUserFn' <$> (parseJSONObject o))
instance ToJSON ParDoInstructionUserFn where
toJSON = toJSON . _pdiufAddtional
newtype InstructionOutputCodec = InstructionOutputCodec'
{ _iocAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
instructionOutputCodec
:: HashMap Text JSONValue
-> InstructionOutputCodec
instructionOutputCodec pIocAddtional_ =
InstructionOutputCodec'
{ _iocAddtional = _Coerce # pIocAddtional_
}
iocAddtional :: Lens' InstructionOutputCodec (HashMap Text JSONValue)
iocAddtional
= lens _iocAddtional (\ s a -> s{_iocAddtional = a})
. _Coerce
instance FromJSON InstructionOutputCodec where
parseJSON
= withObject "InstructionOutputCodec"
(\ o ->
InstructionOutputCodec' <$> (parseJSONObject o))
instance ToJSON InstructionOutputCodec where
toJSON = toJSON . _iocAddtional
data StreamLocation = StreamLocation'
{ _slStreamingStageLocation :: !(Maybe StreamingStageLocation)
, _slSideInputLocation :: !(Maybe StreamingSideInputLocation)
, _slCustomSourceLocation :: !(Maybe CustomSourceLocation)
, _slPubsubLocation :: !(Maybe PubsubLocation)
} deriving (Eq,Show,Data,Typeable,Generic)
streamLocation
:: StreamLocation
streamLocation =
StreamLocation'
{ _slStreamingStageLocation = Nothing
, _slSideInputLocation = Nothing
, _slCustomSourceLocation = Nothing
, _slPubsubLocation = Nothing
}
slStreamingStageLocation :: Lens' StreamLocation (Maybe StreamingStageLocation)
slStreamingStageLocation
= lens _slStreamingStageLocation
(\ s a -> s{_slStreamingStageLocation = a})
slSideInputLocation :: Lens' StreamLocation (Maybe StreamingSideInputLocation)
slSideInputLocation
= lens _slSideInputLocation
(\ s a -> s{_slSideInputLocation = a})
slCustomSourceLocation :: Lens' StreamLocation (Maybe CustomSourceLocation)
slCustomSourceLocation
= lens _slCustomSourceLocation
(\ s a -> s{_slCustomSourceLocation = a})
slPubsubLocation :: Lens' StreamLocation (Maybe PubsubLocation)
slPubsubLocation
= lens _slPubsubLocation
(\ s a -> s{_slPubsubLocation = a})
instance FromJSON StreamLocation where
parseJSON
= withObject "StreamLocation"
(\ o ->
StreamLocation' <$>
(o .:? "streamingStageLocation") <*>
(o .:? "sideInputLocation")
<*> (o .:? "customSourceLocation")
<*> (o .:? "pubsubLocation"))
instance ToJSON StreamLocation where
toJSON StreamLocation'{..}
= object
(catMaybes
[("streamingStageLocation" .=) <$>
_slStreamingStageLocation,
("sideInputLocation" .=) <$> _slSideInputLocation,
("customSourceLocation" .=) <$>
_slCustomSourceLocation,
("pubsubLocation" .=) <$> _slPubsubLocation])
newtype WorkerPoolPoolArgs = WorkerPoolPoolArgs'
{ _wppaAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
workerPoolPoolArgs
:: HashMap Text JSONValue
-> WorkerPoolPoolArgs
workerPoolPoolArgs pWppaAddtional_ =
WorkerPoolPoolArgs'
{ _wppaAddtional = _Coerce # pWppaAddtional_
}
wppaAddtional :: Lens' WorkerPoolPoolArgs (HashMap Text JSONValue)
wppaAddtional
= lens _wppaAddtional
(\ s a -> s{_wppaAddtional = a})
. _Coerce
instance FromJSON WorkerPoolPoolArgs where
parseJSON
= withObject "WorkerPoolPoolArgs"
(\ o -> WorkerPoolPoolArgs' <$> (parseJSONObject o))
instance ToJSON WorkerPoolPoolArgs where
toJSON = toJSON . _wppaAddtional
data CounterMetadata = CounterMetadata'
{ _cmKind :: !(Maybe Text)
, _cmDescription :: !(Maybe Text)
, _cmStandardUnits :: !(Maybe Text)
, _cmOtherUnits :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
counterMetadata
:: CounterMetadata
counterMetadata =
CounterMetadata'
{ _cmKind = Nothing
, _cmDescription = Nothing
, _cmStandardUnits = Nothing
, _cmOtherUnits = Nothing
}
cmKind :: Lens' CounterMetadata (Maybe Text)
cmKind = lens _cmKind (\ s a -> s{_cmKind = a})
cmDescription :: Lens' CounterMetadata (Maybe Text)
cmDescription
= lens _cmDescription
(\ s a -> s{_cmDescription = a})
cmStandardUnits :: Lens' CounterMetadata (Maybe Text)
cmStandardUnits
= lens _cmStandardUnits
(\ s a -> s{_cmStandardUnits = a})
cmOtherUnits :: Lens' CounterMetadata (Maybe Text)
cmOtherUnits
= lens _cmOtherUnits (\ s a -> s{_cmOtherUnits = a})
instance FromJSON CounterMetadata where
parseJSON
= withObject "CounterMetadata"
(\ o ->
CounterMetadata' <$>
(o .:? "kind") <*> (o .:? "description") <*>
(o .:? "standardUnits")
<*> (o .:? "otherUnits"))
instance ToJSON CounterMetadata where
toJSON CounterMetadata'{..}
= object
(catMaybes
[("kind" .=) <$> _cmKind,
("description" .=) <$> _cmDescription,
("standardUnits" .=) <$> _cmStandardUnits,
("otherUnits" .=) <$> _cmOtherUnits])
newtype SendWorkerMessagesResponse = SendWorkerMessagesResponse'
{ _swmrWorkerMessageResponses :: Maybe [WorkerMessageResponse]
} deriving (Eq,Show,Data,Typeable,Generic)
sendWorkerMessagesResponse
:: SendWorkerMessagesResponse
sendWorkerMessagesResponse =
SendWorkerMessagesResponse'
{ _swmrWorkerMessageResponses = Nothing
}
swmrWorkerMessageResponses :: Lens' SendWorkerMessagesResponse [WorkerMessageResponse]
swmrWorkerMessageResponses
= lens _swmrWorkerMessageResponses
(\ s a -> s{_swmrWorkerMessageResponses = a})
. _Default
. _Coerce
instance FromJSON SendWorkerMessagesResponse where
parseJSON
= withObject "SendWorkerMessagesResponse"
(\ o ->
SendWorkerMessagesResponse' <$>
(o .:? "workerMessageResponses" .!= mempty))
instance ToJSON SendWorkerMessagesResponse where
toJSON SendWorkerMessagesResponse'{..}
= object
(catMaybes
[("workerMessageResponses" .=) <$>
_swmrWorkerMessageResponses])
data StreamingSideInputLocation = StreamingSideInputLocation'
{ _ssilTag :: !(Maybe Text)
, _ssilStateFamily :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
streamingSideInputLocation
:: StreamingSideInputLocation
streamingSideInputLocation =
StreamingSideInputLocation'
{ _ssilTag = Nothing
, _ssilStateFamily = Nothing
}
ssilTag :: Lens' StreamingSideInputLocation (Maybe Text)
ssilTag = lens _ssilTag (\ s a -> s{_ssilTag = a})
ssilStateFamily :: Lens' StreamingSideInputLocation (Maybe Text)
ssilStateFamily
= lens _ssilStateFamily
(\ s a -> s{_ssilStateFamily = a})
instance FromJSON StreamingSideInputLocation where
parseJSON
= withObject "StreamingSideInputLocation"
(\ o ->
StreamingSideInputLocation' <$>
(o .:? "tag") <*> (o .:? "stateFamily"))
instance ToJSON StreamingSideInputLocation where
toJSON StreamingSideInputLocation'{..}
= object
(catMaybes
[("tag" .=) <$> _ssilTag,
("stateFamily" .=) <$> _ssilStateFamily])
data GetDebugConfigRequest = GetDebugConfigRequest'
{ _gdcrComponentId :: !(Maybe Text)
, _gdcrWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
getDebugConfigRequest
:: GetDebugConfigRequest
getDebugConfigRequest =
GetDebugConfigRequest'
{ _gdcrComponentId = Nothing
, _gdcrWorkerId = Nothing
}
gdcrComponentId :: Lens' GetDebugConfigRequest (Maybe Text)
gdcrComponentId
= lens _gdcrComponentId
(\ s a -> s{_gdcrComponentId = a})
gdcrWorkerId :: Lens' GetDebugConfigRequest (Maybe Text)
gdcrWorkerId
= lens _gdcrWorkerId (\ s a -> s{_gdcrWorkerId = a})
instance FromJSON GetDebugConfigRequest where
parseJSON
= withObject "GetDebugConfigRequest"
(\ o ->
GetDebugConfigRequest' <$>
(o .:? "componentId") <*> (o .:? "workerId"))
instance ToJSON GetDebugConfigRequest where
toJSON GetDebugConfigRequest'{..}
= object
(catMaybes
[("componentId" .=) <$> _gdcrComponentId,
("workerId" .=) <$> _gdcrWorkerId])
data CounterStructuredNameAndMetadata = CounterStructuredNameAndMetadata'
{ _csnamName :: !(Maybe CounterStructuredName)
, _csnamMetadata :: !(Maybe CounterMetadata)
} deriving (Eq,Show,Data,Typeable,Generic)
counterStructuredNameAndMetadata
:: CounterStructuredNameAndMetadata
counterStructuredNameAndMetadata =
CounterStructuredNameAndMetadata'
{ _csnamName = Nothing
, _csnamMetadata = Nothing
}
csnamName :: Lens' CounterStructuredNameAndMetadata (Maybe CounterStructuredName)
csnamName
= lens _csnamName (\ s a -> s{_csnamName = a})
csnamMetadata :: Lens' CounterStructuredNameAndMetadata (Maybe CounterMetadata)
csnamMetadata
= lens _csnamMetadata
(\ s a -> s{_csnamMetadata = a})
instance FromJSON CounterStructuredNameAndMetadata
where
parseJSON
= withObject "CounterStructuredNameAndMetadata"
(\ o ->
CounterStructuredNameAndMetadata' <$>
(o .:? "name") <*> (o .:? "metadata"))
instance ToJSON CounterStructuredNameAndMetadata
where
toJSON CounterStructuredNameAndMetadata'{..}
= object
(catMaybes
[("name" .=) <$> _csnamName,
("metadata" .=) <$> _csnamMetadata])
data StreamingComputationTask = StreamingComputationTask'
{ _sctTaskType :: !(Maybe Text)
, _sctDataDisks :: !(Maybe [MountedDataDisk])
, _sctComputationRanges :: !(Maybe [StreamingComputationRanges])
} deriving (Eq,Show,Data,Typeable,Generic)
streamingComputationTask
:: StreamingComputationTask
streamingComputationTask =
StreamingComputationTask'
{ _sctTaskType = Nothing
, _sctDataDisks = Nothing
, _sctComputationRanges = Nothing
}
sctTaskType :: Lens' StreamingComputationTask (Maybe Text)
sctTaskType
= lens _sctTaskType (\ s a -> s{_sctTaskType = a})
sctDataDisks :: Lens' StreamingComputationTask [MountedDataDisk]
sctDataDisks
= lens _sctDataDisks (\ s a -> s{_sctDataDisks = a})
. _Default
. _Coerce
sctComputationRanges :: Lens' StreamingComputationTask [StreamingComputationRanges]
sctComputationRanges
= lens _sctComputationRanges
(\ s a -> s{_sctComputationRanges = a})
. _Default
. _Coerce
instance FromJSON StreamingComputationTask where
parseJSON
= withObject "StreamingComputationTask"
(\ o ->
StreamingComputationTask' <$>
(o .:? "taskType") <*> (o .:? "dataDisks" .!= mempty)
<*> (o .:? "computationRanges" .!= mempty))
instance ToJSON StreamingComputationTask where
toJSON StreamingComputationTask'{..}
= object
(catMaybes
[("taskType" .=) <$> _sctTaskType,
("dataDisks" .=) <$> _sctDataDisks,
("computationRanges" .=) <$> _sctComputationRanges])
data JobMessage = JobMessage'
{ _jmTime :: !(Maybe Text)
, _jmMessageText :: !(Maybe Text)
, _jmMessageImportance :: !(Maybe Text)
, _jmId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
jobMessage
:: JobMessage
jobMessage =
JobMessage'
{ _jmTime = Nothing
, _jmMessageText = Nothing
, _jmMessageImportance = Nothing
, _jmId = Nothing
}
jmTime :: Lens' JobMessage (Maybe Text)
jmTime = lens _jmTime (\ s a -> s{_jmTime = a})
jmMessageText :: Lens' JobMessage (Maybe Text)
jmMessageText
= lens _jmMessageText
(\ s a -> s{_jmMessageText = a})
jmMessageImportance :: Lens' JobMessage (Maybe Text)
jmMessageImportance
= lens _jmMessageImportance
(\ s a -> s{_jmMessageImportance = a})
jmId :: Lens' JobMessage (Maybe Text)
jmId = lens _jmId (\ s a -> s{_jmId = a})
instance FromJSON JobMessage where
parseJSON
= withObject "JobMessage"
(\ o ->
JobMessage' <$>
(o .:? "time") <*> (o .:? "messageText") <*>
(o .:? "messageImportance")
<*> (o .:? "id"))
instance ToJSON JobMessage where
toJSON JobMessage'{..}
= object
(catMaybes
[("time" .=) <$> _jmTime,
("messageText" .=) <$> _jmMessageText,
("messageImportance" .=) <$> _jmMessageImportance,
("id" .=) <$> _jmId])
data SeqMapTaskOutputInfo = SeqMapTaskOutputInfo'
{ _smtoiSink :: !(Maybe Sink)
, _smtoiTag :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
seqMapTaskOutputInfo
:: SeqMapTaskOutputInfo
seqMapTaskOutputInfo =
SeqMapTaskOutputInfo'
{ _smtoiSink = Nothing
, _smtoiTag = Nothing
}
smtoiSink :: Lens' SeqMapTaskOutputInfo (Maybe Sink)
smtoiSink
= lens _smtoiSink (\ s a -> s{_smtoiSink = a})
smtoiTag :: Lens' SeqMapTaskOutputInfo (Maybe Text)
smtoiTag = lens _smtoiTag (\ s a -> s{_smtoiTag = a})
instance FromJSON SeqMapTaskOutputInfo where
parseJSON
= withObject "SeqMapTaskOutputInfo"
(\ o ->
SeqMapTaskOutputInfo' <$>
(o .:? "sink") <*> (o .:? "tag"))
instance ToJSON SeqMapTaskOutputInfo where
toJSON SeqMapTaskOutputInfo'{..}
= object
(catMaybes
[("sink" .=) <$> _smtoiSink,
("tag" .=) <$> _smtoiTag])
newtype SourceGetMetadataRequest = SourceGetMetadataRequest'
{ _sgmrSource :: Maybe Source
} deriving (Eq,Show,Data,Typeable,Generic)
sourceGetMetadataRequest
:: SourceGetMetadataRequest
sourceGetMetadataRequest =
SourceGetMetadataRequest'
{ _sgmrSource = Nothing
}
sgmrSource :: Lens' SourceGetMetadataRequest (Maybe Source)
sgmrSource
= lens _sgmrSource (\ s a -> s{_sgmrSource = a})
instance FromJSON SourceGetMetadataRequest where
parseJSON
= withObject "SourceGetMetadataRequest"
(\ o ->
SourceGetMetadataRequest' <$> (o .:? "source"))
instance ToJSON SourceGetMetadataRequest where
toJSON SourceGetMetadataRequest'{..}
= object (catMaybes [("source" .=) <$> _sgmrSource])
newtype SeqMapTaskUserFn = SeqMapTaskUserFn'
{ _smtufAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
seqMapTaskUserFn
:: HashMap Text JSONValue
-> SeqMapTaskUserFn
seqMapTaskUserFn pSmtufAddtional_ =
SeqMapTaskUserFn'
{ _smtufAddtional = _Coerce # pSmtufAddtional_
}
smtufAddtional :: Lens' SeqMapTaskUserFn (HashMap Text JSONValue)
smtufAddtional
= lens _smtufAddtional
(\ s a -> s{_smtufAddtional = a})
. _Coerce
instance FromJSON SeqMapTaskUserFn where
parseJSON
= withObject "SeqMapTaskUserFn"
(\ o -> SeqMapTaskUserFn' <$> (parseJSONObject o))
instance ToJSON SeqMapTaskUserFn where
toJSON = toJSON . _smtufAddtional
newtype PartialGroupByKeyInstructionValueCombiningFn = PartialGroupByKeyInstructionValueCombiningFn'
{ _pgbkivcfAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
partialGroupByKeyInstructionValueCombiningFn
:: HashMap Text JSONValue
-> PartialGroupByKeyInstructionValueCombiningFn
partialGroupByKeyInstructionValueCombiningFn pPgbkivcfAddtional_ =
PartialGroupByKeyInstructionValueCombiningFn'
{ _pgbkivcfAddtional = _Coerce # pPgbkivcfAddtional_
}
pgbkivcfAddtional :: Lens' PartialGroupByKeyInstructionValueCombiningFn (HashMap Text JSONValue)
pgbkivcfAddtional
= lens _pgbkivcfAddtional
(\ s a -> s{_pgbkivcfAddtional = a})
. _Coerce
instance FromJSON
PartialGroupByKeyInstructionValueCombiningFn where
parseJSON
= withObject
"PartialGroupByKeyInstructionValueCombiningFn"
(\ o ->
PartialGroupByKeyInstructionValueCombiningFn' <$>
(parseJSONObject o))
instance ToJSON
PartialGroupByKeyInstructionValueCombiningFn where
toJSON = toJSON . _pgbkivcfAddtional
data Job = Job'
{ _jRequestedState :: !(Maybe Text)
, _jEnvironment :: !(Maybe Environment)
, _jClientRequestId :: !(Maybe Text)
, _jCurrentState :: !(Maybe Text)
, _jReplacedByJobId :: !(Maybe Text)
, _jTempFiles :: !(Maybe [Text])
, _jSteps :: !(Maybe [Step])
, _jExecutionInfo :: !(Maybe JobExecutionInfo)
, _jName :: !(Maybe Text)
, _jTransformNameMApping :: !(Maybe JobTransformNameMApping)
, _jId :: !(Maybe Text)
, _jLabels :: !(Maybe JobLabels)
, _jProjectId :: !(Maybe Text)
, _jType :: !(Maybe Text)
, _jCurrentStateTime :: !(Maybe Text)
, _jReplaceJobId :: !(Maybe Text)
, _jCreateTime :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
job
:: Job
job =
Job'
{ _jRequestedState = Nothing
, _jEnvironment = Nothing
, _jClientRequestId = Nothing
, _jCurrentState = Nothing
, _jReplacedByJobId = Nothing
, _jTempFiles = Nothing
, _jSteps = Nothing
, _jExecutionInfo = Nothing
, _jName = Nothing
, _jTransformNameMApping = Nothing
, _jId = Nothing
, _jLabels = Nothing
, _jProjectId = Nothing
, _jType = Nothing
, _jCurrentStateTime = Nothing
, _jReplaceJobId = Nothing
, _jCreateTime = Nothing
}
jRequestedState :: Lens' Job (Maybe Text)
jRequestedState
= lens _jRequestedState
(\ s a -> s{_jRequestedState = a})
jEnvironment :: Lens' Job (Maybe Environment)
jEnvironment
= lens _jEnvironment (\ s a -> s{_jEnvironment = a})
jClientRequestId :: Lens' Job (Maybe Text)
jClientRequestId
= lens _jClientRequestId
(\ s a -> s{_jClientRequestId = a})
jCurrentState :: Lens' Job (Maybe Text)
jCurrentState
= lens _jCurrentState
(\ s a -> s{_jCurrentState = a})
jReplacedByJobId :: Lens' Job (Maybe Text)
jReplacedByJobId
= lens _jReplacedByJobId
(\ s a -> s{_jReplacedByJobId = a})
jTempFiles :: Lens' Job [Text]
jTempFiles
= lens _jTempFiles (\ s a -> s{_jTempFiles = a}) .
_Default
. _Coerce
jSteps :: Lens' Job [Step]
jSteps
= lens _jSteps (\ s a -> s{_jSteps = a}) . _Default .
_Coerce
jExecutionInfo :: Lens' Job (Maybe JobExecutionInfo)
jExecutionInfo
= lens _jExecutionInfo
(\ s a -> s{_jExecutionInfo = a})
jName :: Lens' Job (Maybe Text)
jName = lens _jName (\ s a -> s{_jName = a})
jTransformNameMApping :: Lens' Job (Maybe JobTransformNameMApping)
jTransformNameMApping
= lens _jTransformNameMApping
(\ s a -> s{_jTransformNameMApping = a})
jId :: Lens' Job (Maybe Text)
jId = lens _jId (\ s a -> s{_jId = a})
jLabels :: Lens' Job (Maybe JobLabels)
jLabels = lens _jLabels (\ s a -> s{_jLabels = a})
jProjectId :: Lens' Job (Maybe Text)
jProjectId
= lens _jProjectId (\ s a -> s{_jProjectId = a})
jType :: Lens' Job (Maybe Text)
jType = lens _jType (\ s a -> s{_jType = a})
jCurrentStateTime :: Lens' Job (Maybe Text)
jCurrentStateTime
= lens _jCurrentStateTime
(\ s a -> s{_jCurrentStateTime = a})
jReplaceJobId :: Lens' Job (Maybe Text)
jReplaceJobId
= lens _jReplaceJobId
(\ s a -> s{_jReplaceJobId = a})
jCreateTime :: Lens' Job (Maybe Text)
jCreateTime
= lens _jCreateTime (\ s a -> s{_jCreateTime = a})
instance FromJSON Job where
parseJSON
= withObject "Job"
(\ o ->
Job' <$>
(o .:? "requestedState") <*> (o .:? "environment")
<*> (o .:? "clientRequestId")
<*> (o .:? "currentState")
<*> (o .:? "replacedByJobId")
<*> (o .:? "tempFiles" .!= mempty)
<*> (o .:? "steps" .!= mempty)
<*> (o .:? "executionInfo")
<*> (o .:? "name")
<*> (o .:? "transformNameMapping")
<*> (o .:? "id")
<*> (o .:? "labels")
<*> (o .:? "projectId")
<*> (o .:? "type")
<*> (o .:? "currentStateTime")
<*> (o .:? "replaceJobId")
<*> (o .:? "createTime"))
instance ToJSON Job where
toJSON Job'{..}
= object
(catMaybes
[("requestedState" .=) <$> _jRequestedState,
("environment" .=) <$> _jEnvironment,
("clientRequestId" .=) <$> _jClientRequestId,
("currentState" .=) <$> _jCurrentState,
("replacedByJobId" .=) <$> _jReplacedByJobId,
("tempFiles" .=) <$> _jTempFiles,
("steps" .=) <$> _jSteps,
("executionInfo" .=) <$> _jExecutionInfo,
("name" .=) <$> _jName,
("transformNameMapping" .=) <$>
_jTransformNameMApping,
("id" .=) <$> _jId, ("labels" .=) <$> _jLabels,
("projectId" .=) <$> _jProjectId,
("type" .=) <$> _jType,
("currentStateTime" .=) <$> _jCurrentStateTime,
("replaceJobId" .=) <$> _jReplaceJobId,
("createTime" .=) <$> _jCreateTime])
newtype ReadInstruction = ReadInstruction'
{ _riSource :: Maybe Source
} deriving (Eq,Show,Data,Typeable,Generic)
readInstruction
:: ReadInstruction
readInstruction =
ReadInstruction'
{ _riSource = Nothing
}
riSource :: Lens' ReadInstruction (Maybe Source)
riSource = lens _riSource (\ s a -> s{_riSource = a})
instance FromJSON ReadInstruction where
parseJSON
= withObject "ReadInstruction"
(\ o -> ReadInstruction' <$> (o .:? "source"))
instance ToJSON ReadInstruction where
toJSON ReadInstruction'{..}
= object (catMaybes [("source" .=) <$> _riSource])
data ApproximateReportedProgress = ApproximateReportedProgress'
{ _arpFractionConsumed :: !(Maybe (Textual Double))
, _arpConsumedParallelism :: !(Maybe ReportedParallelism)
, _arpRemainingParallelism :: !(Maybe ReportedParallelism)
, _arpPosition :: !(Maybe Position)
} deriving (Eq,Show,Data,Typeable,Generic)
approximateReportedProgress
:: ApproximateReportedProgress
approximateReportedProgress =
ApproximateReportedProgress'
{ _arpFractionConsumed = Nothing
, _arpConsumedParallelism = Nothing
, _arpRemainingParallelism = Nothing
, _arpPosition = Nothing
}
arpFractionConsumed :: Lens' ApproximateReportedProgress (Maybe Double)
arpFractionConsumed
= lens _arpFractionConsumed
(\ s a -> s{_arpFractionConsumed = a})
. mapping _Coerce
arpConsumedParallelism :: Lens' ApproximateReportedProgress (Maybe ReportedParallelism)
arpConsumedParallelism
= lens _arpConsumedParallelism
(\ s a -> s{_arpConsumedParallelism = a})
arpRemainingParallelism :: Lens' ApproximateReportedProgress (Maybe ReportedParallelism)
arpRemainingParallelism
= lens _arpRemainingParallelism
(\ s a -> s{_arpRemainingParallelism = a})
arpPosition :: Lens' ApproximateReportedProgress (Maybe Position)
arpPosition
= lens _arpPosition (\ s a -> s{_arpPosition = a})
instance FromJSON ApproximateReportedProgress where
parseJSON
= withObject "ApproximateReportedProgress"
(\ o ->
ApproximateReportedProgress' <$>
(o .:? "fractionConsumed") <*>
(o .:? "consumedParallelism")
<*> (o .:? "remainingParallelism")
<*> (o .:? "position"))
instance ToJSON ApproximateReportedProgress where
toJSON ApproximateReportedProgress'{..}
= object
(catMaybes
[("fractionConsumed" .=) <$> _arpFractionConsumed,
("consumedParallelism" .=) <$>
_arpConsumedParallelism,
("remainingParallelism" .=) <$>
_arpRemainingParallelism,
("position" .=) <$> _arpPosition])
newtype SinkSpec = SinkSpec'
{ _sAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
sinkSpec
:: HashMap Text JSONValue
-> SinkSpec
sinkSpec pSAddtional_ =
SinkSpec'
{ _sAddtional = _Coerce # pSAddtional_
}
sAddtional :: Lens' SinkSpec (HashMap Text JSONValue)
sAddtional
= lens _sAddtional (\ s a -> s{_sAddtional = a}) .
_Coerce
instance FromJSON SinkSpec where
parseJSON
= withObject "SinkSpec"
(\ o -> SinkSpec' <$> (parseJSONObject o))
instance ToJSON SinkSpec where
toJSON = toJSON . _sAddtional
data WorkerPool = WorkerPool'
{ _wpAutoscalingSettings :: !(Maybe AutoscalingSettings)
, _wpNumThreadsPerWorker :: !(Maybe (Textual Int32))
, _wpDiskSizeGb :: !(Maybe (Textual Int32))
, _wpKind :: !(Maybe Text)
, _wpTaskrunnerSettings :: !(Maybe TaskRunnerSettings)
, _wpNumWorkers :: !(Maybe (Textual Int32))
, _wpNetwork :: !(Maybe Text)
, _wpZone :: !(Maybe Text)
, _wpIPConfiguration :: !(Maybe Text)
, _wpPackages :: !(Maybe [Package])
, _wpOnHostMaintenance :: !(Maybe Text)
, _wpDiskSourceImage :: !(Maybe Text)
, _wpSubnetwork :: !(Maybe Text)
, _wpMachineType :: !(Maybe Text)
, _wpMetadata :: !(Maybe WorkerPoolMetadata)
, _wpDiskType :: !(Maybe Text)
, _wpTeardownPolicy :: !(Maybe Text)
, _wpDefaultPackageSet :: !(Maybe Text)
, _wpPoolArgs :: !(Maybe WorkerPoolPoolArgs)
, _wpWorkerHarnessContainerImage :: !(Maybe Text)
, _wpDataDisks :: !(Maybe [Disk])
} deriving (Eq,Show,Data,Typeable,Generic)
workerPool
:: WorkerPool
workerPool =
WorkerPool'
{ _wpAutoscalingSettings = Nothing
, _wpNumThreadsPerWorker = Nothing
, _wpDiskSizeGb = Nothing
, _wpKind = Nothing
, _wpTaskrunnerSettings = Nothing
, _wpNumWorkers = Nothing
, _wpNetwork = Nothing
, _wpZone = Nothing
, _wpIPConfiguration = Nothing
, _wpPackages = Nothing
, _wpOnHostMaintenance = Nothing
, _wpDiskSourceImage = Nothing
, _wpSubnetwork = Nothing
, _wpMachineType = Nothing
, _wpMetadata = Nothing
, _wpDiskType = Nothing
, _wpTeardownPolicy = Nothing
, _wpDefaultPackageSet = Nothing
, _wpPoolArgs = Nothing
, _wpWorkerHarnessContainerImage = Nothing
, _wpDataDisks = Nothing
}
wpAutoscalingSettings :: Lens' WorkerPool (Maybe AutoscalingSettings)
wpAutoscalingSettings
= lens _wpAutoscalingSettings
(\ s a -> s{_wpAutoscalingSettings = a})
wpNumThreadsPerWorker :: Lens' WorkerPool (Maybe Int32)
wpNumThreadsPerWorker
= lens _wpNumThreadsPerWorker
(\ s a -> s{_wpNumThreadsPerWorker = a})
. mapping _Coerce
wpDiskSizeGb :: Lens' WorkerPool (Maybe Int32)
wpDiskSizeGb
= lens _wpDiskSizeGb (\ s a -> s{_wpDiskSizeGb = a})
. mapping _Coerce
wpKind :: Lens' WorkerPool (Maybe Text)
wpKind = lens _wpKind (\ s a -> s{_wpKind = a})
wpTaskrunnerSettings :: Lens' WorkerPool (Maybe TaskRunnerSettings)
wpTaskrunnerSettings
= lens _wpTaskrunnerSettings
(\ s a -> s{_wpTaskrunnerSettings = a})
wpNumWorkers :: Lens' WorkerPool (Maybe Int32)
wpNumWorkers
= lens _wpNumWorkers (\ s a -> s{_wpNumWorkers = a})
. mapping _Coerce
wpNetwork :: Lens' WorkerPool (Maybe Text)
wpNetwork
= lens _wpNetwork (\ s a -> s{_wpNetwork = a})
wpZone :: Lens' WorkerPool (Maybe Text)
wpZone = lens _wpZone (\ s a -> s{_wpZone = a})
wpIPConfiguration :: Lens' WorkerPool (Maybe Text)
wpIPConfiguration
= lens _wpIPConfiguration
(\ s a -> s{_wpIPConfiguration = a})
wpPackages :: Lens' WorkerPool [Package]
wpPackages
= lens _wpPackages (\ s a -> s{_wpPackages = a}) .
_Default
. _Coerce
wpOnHostMaintenance :: Lens' WorkerPool (Maybe Text)
wpOnHostMaintenance
= lens _wpOnHostMaintenance
(\ s a -> s{_wpOnHostMaintenance = a})
wpDiskSourceImage :: Lens' WorkerPool (Maybe Text)
wpDiskSourceImage
= lens _wpDiskSourceImage
(\ s a -> s{_wpDiskSourceImage = a})
wpSubnetwork :: Lens' WorkerPool (Maybe Text)
wpSubnetwork
= lens _wpSubnetwork (\ s a -> s{_wpSubnetwork = a})
wpMachineType :: Lens' WorkerPool (Maybe Text)
wpMachineType
= lens _wpMachineType
(\ s a -> s{_wpMachineType = a})
wpMetadata :: Lens' WorkerPool (Maybe WorkerPoolMetadata)
wpMetadata
= lens _wpMetadata (\ s a -> s{_wpMetadata = a})
wpDiskType :: Lens' WorkerPool (Maybe Text)
wpDiskType
= lens _wpDiskType (\ s a -> s{_wpDiskType = a})
wpTeardownPolicy :: Lens' WorkerPool (Maybe Text)
wpTeardownPolicy
= lens _wpTeardownPolicy
(\ s a -> s{_wpTeardownPolicy = a})
wpDefaultPackageSet :: Lens' WorkerPool (Maybe Text)
wpDefaultPackageSet
= lens _wpDefaultPackageSet
(\ s a -> s{_wpDefaultPackageSet = a})
wpPoolArgs :: Lens' WorkerPool (Maybe WorkerPoolPoolArgs)
wpPoolArgs
= lens _wpPoolArgs (\ s a -> s{_wpPoolArgs = a})
wpWorkerHarnessContainerImage :: Lens' WorkerPool (Maybe Text)
wpWorkerHarnessContainerImage
= lens _wpWorkerHarnessContainerImage
(\ s a -> s{_wpWorkerHarnessContainerImage = a})
wpDataDisks :: Lens' WorkerPool [Disk]
wpDataDisks
= lens _wpDataDisks (\ s a -> s{_wpDataDisks = a}) .
_Default
. _Coerce
instance FromJSON WorkerPool where
parseJSON
= withObject "WorkerPool"
(\ o ->
WorkerPool' <$>
(o .:? "autoscalingSettings") <*>
(o .:? "numThreadsPerWorker")
<*> (o .:? "diskSizeGb")
<*> (o .:? "kind")
<*> (o .:? "taskrunnerSettings")
<*> (o .:? "numWorkers")
<*> (o .:? "network")
<*> (o .:? "zone")
<*> (o .:? "ipConfiguration")
<*> (o .:? "packages" .!= mempty)
<*> (o .:? "onHostMaintenance")
<*> (o .:? "diskSourceImage")
<*> (o .:? "subnetwork")
<*> (o .:? "machineType")
<*> (o .:? "metadata")
<*> (o .:? "diskType")
<*> (o .:? "teardownPolicy")
<*> (o .:? "defaultPackageSet")
<*> (o .:? "poolArgs")
<*> (o .:? "workerHarnessContainerImage")
<*> (o .:? "dataDisks" .!= mempty))
instance ToJSON WorkerPool where
toJSON WorkerPool'{..}
= object
(catMaybes
[("autoscalingSettings" .=) <$>
_wpAutoscalingSettings,
("numThreadsPerWorker" .=) <$>
_wpNumThreadsPerWorker,
("diskSizeGb" .=) <$> _wpDiskSizeGb,
("kind" .=) <$> _wpKind,
("taskrunnerSettings" .=) <$> _wpTaskrunnerSettings,
("numWorkers" .=) <$> _wpNumWorkers,
("network" .=) <$> _wpNetwork,
("zone" .=) <$> _wpZone,
("ipConfiguration" .=) <$> _wpIPConfiguration,
("packages" .=) <$> _wpPackages,
("onHostMaintenance" .=) <$> _wpOnHostMaintenance,
("diskSourceImage" .=) <$> _wpDiskSourceImage,
("subnetwork" .=) <$> _wpSubnetwork,
("machineType" .=) <$> _wpMachineType,
("metadata" .=) <$> _wpMetadata,
("diskType" .=) <$> _wpDiskType,
("teardownPolicy" .=) <$> _wpTeardownPolicy,
("defaultPackageSet" .=) <$> _wpDefaultPackageSet,
("poolArgs" .=) <$> _wpPoolArgs,
("workerHarnessContainerImage" .=) <$>
_wpWorkerHarnessContainerImage,
("dataDisks" .=) <$> _wpDataDisks])
data Step = Step'
{ _sKind :: !(Maybe Text)
, _sName :: !(Maybe Text)
, _sProperties :: !(Maybe StepProperties)
} deriving (Eq,Show,Data,Typeable,Generic)
step
:: Step
step =
Step'
{ _sKind = Nothing
, _sName = Nothing
, _sProperties = Nothing
}
sKind :: Lens' Step (Maybe Text)
sKind = lens _sKind (\ s a -> s{_sKind = a})
sName :: Lens' Step (Maybe Text)
sName = lens _sName (\ s a -> s{_sName = a})
sProperties :: Lens' Step (Maybe StepProperties)
sProperties
= lens _sProperties (\ s a -> s{_sProperties = a})
instance FromJSON Step where
parseJSON
= withObject "Step"
(\ o ->
Step' <$>
(o .:? "kind") <*> (o .:? "name") <*>
(o .:? "properties"))
instance ToJSON Step where
toJSON Step'{..}
= object
(catMaybes
[("kind" .=) <$> _sKind, ("name" .=) <$> _sName,
("properties" .=) <$> _sProperties])
data Package = Package'
{ _pLocation :: !(Maybe Text)
, _pName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
package
:: Package
package =
Package'
{ _pLocation = Nothing
, _pName = Nothing
}
pLocation :: Lens' Package (Maybe Text)
pLocation
= lens _pLocation (\ s a -> s{_pLocation = a})
pName :: Lens' Package (Maybe Text)
pName = lens _pName (\ s a -> s{_pName = a})
instance FromJSON Package where
parseJSON
= withObject "Package"
(\ o ->
Package' <$> (o .:? "location") <*> (o .:? "name"))
instance ToJSON Package where
toJSON Package'{..}
= object
(catMaybes
[("location" .=) <$> _pLocation,
("name" .=) <$> _pName])
newtype WorkerMessageCodeParameters = WorkerMessageCodeParameters'
{ _wmcpAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessageCodeParameters
:: HashMap Text JSONValue
-> WorkerMessageCodeParameters
workerMessageCodeParameters pWmcpAddtional_ =
WorkerMessageCodeParameters'
{ _wmcpAddtional = _Coerce # pWmcpAddtional_
}
wmcpAddtional :: Lens' WorkerMessageCodeParameters (HashMap Text JSONValue)
wmcpAddtional
= lens _wmcpAddtional
(\ s a -> s{_wmcpAddtional = a})
. _Coerce
instance FromJSON WorkerMessageCodeParameters where
parseJSON
= withObject "WorkerMessageCodeParameters"
(\ o ->
WorkerMessageCodeParameters' <$> (parseJSONObject o))
instance ToJSON WorkerMessageCodeParameters where
toJSON = toJSON . _wmcpAddtional
data DynamicSourceSplit = DynamicSourceSplit'
{ _dssResidual :: !(Maybe DerivedSource)
, _dssPrimary :: !(Maybe DerivedSource)
} deriving (Eq,Show,Data,Typeable,Generic)
dynamicSourceSplit
:: DynamicSourceSplit
dynamicSourceSplit =
DynamicSourceSplit'
{ _dssResidual = Nothing
, _dssPrimary = Nothing
}
dssResidual :: Lens' DynamicSourceSplit (Maybe DerivedSource)
dssResidual
= lens _dssResidual (\ s a -> s{_dssResidual = a})
dssPrimary :: Lens' DynamicSourceSplit (Maybe DerivedSource)
dssPrimary
= lens _dssPrimary (\ s a -> s{_dssPrimary = a})
instance FromJSON DynamicSourceSplit where
parseJSON
= withObject "DynamicSourceSplit"
(\ o ->
DynamicSourceSplit' <$>
(o .:? "residual") <*> (o .:? "primary"))
instance ToJSON DynamicSourceSplit where
toJSON DynamicSourceSplit'{..}
= object
(catMaybes
[("residual" .=) <$> _dssResidual,
("primary" .=) <$> _dssPrimary])
newtype ReportWorkItemStatusResponse = ReportWorkItemStatusResponse'
{ _rwisrWorkItemServiceStates :: Maybe [WorkItemServiceState]
} deriving (Eq,Show,Data,Typeable,Generic)
reportWorkItemStatusResponse
:: ReportWorkItemStatusResponse
reportWorkItemStatusResponse =
ReportWorkItemStatusResponse'
{ _rwisrWorkItemServiceStates = Nothing
}
rwisrWorkItemServiceStates :: Lens' ReportWorkItemStatusResponse [WorkItemServiceState]
rwisrWorkItemServiceStates
= lens _rwisrWorkItemServiceStates
(\ s a -> s{_rwisrWorkItemServiceStates = a})
. _Default
. _Coerce
instance FromJSON ReportWorkItemStatusResponse where
parseJSON
= withObject "ReportWorkItemStatusResponse"
(\ o ->
ReportWorkItemStatusResponse' <$>
(o .:? "workItemServiceStates" .!= mempty))
instance ToJSON ReportWorkItemStatusResponse where
toJSON ReportWorkItemStatusResponse'{..}
= object
(catMaybes
[("workItemServiceStates" .=) <$>
_rwisrWorkItemServiceStates])
data SourceFork = SourceFork'
{ _sfResidual :: !(Maybe SourceSplitShard)
, _sfPrimarySource :: !(Maybe DerivedSource)
, _sfPrimary :: !(Maybe SourceSplitShard)
, _sfResidualSource :: !(Maybe DerivedSource)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceFork
:: SourceFork
sourceFork =
SourceFork'
{ _sfResidual = Nothing
, _sfPrimarySource = Nothing
, _sfPrimary = Nothing
, _sfResidualSource = Nothing
}
sfResidual :: Lens' SourceFork (Maybe SourceSplitShard)
sfResidual
= lens _sfResidual (\ s a -> s{_sfResidual = a})
sfPrimarySource :: Lens' SourceFork (Maybe DerivedSource)
sfPrimarySource
= lens _sfPrimarySource
(\ s a -> s{_sfPrimarySource = a})
sfPrimary :: Lens' SourceFork (Maybe SourceSplitShard)
sfPrimary
= lens _sfPrimary (\ s a -> s{_sfPrimary = a})
sfResidualSource :: Lens' SourceFork (Maybe DerivedSource)
sfResidualSource
= lens _sfResidualSource
(\ s a -> s{_sfResidualSource = a})
instance FromJSON SourceFork where
parseJSON
= withObject "SourceFork"
(\ o ->
SourceFork' <$>
(o .:? "residual") <*> (o .:? "primarySource") <*>
(o .:? "primary")
<*> (o .:? "residualSource"))
instance ToJSON SourceFork where
toJSON SourceFork'{..}
= object
(catMaybes
[("residual" .=) <$> _sfResidual,
("primarySource" .=) <$> _sfPrimarySource,
("primary" .=) <$> _sfPrimary,
("residualSource" .=) <$> _sfResidualSource])
data StreamingComputationRanges = StreamingComputationRanges'
{ _scrRangeAssignments :: !(Maybe [KeyRangeDataDiskAssignment])
, _scrComputationId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
streamingComputationRanges
:: StreamingComputationRanges
streamingComputationRanges =
StreamingComputationRanges'
{ _scrRangeAssignments = Nothing
, _scrComputationId = Nothing
}
scrRangeAssignments :: Lens' StreamingComputationRanges [KeyRangeDataDiskAssignment]
scrRangeAssignments
= lens _scrRangeAssignments
(\ s a -> s{_scrRangeAssignments = a})
. _Default
. _Coerce
scrComputationId :: Lens' StreamingComputationRanges (Maybe Text)
scrComputationId
= lens _scrComputationId
(\ s a -> s{_scrComputationId = a})
instance FromJSON StreamingComputationRanges where
parseJSON
= withObject "StreamingComputationRanges"
(\ o ->
StreamingComputationRanges' <$>
(o .:? "rangeAssignments" .!= mempty) <*>
(o .:? "computationId"))
instance ToJSON StreamingComputationRanges where
toJSON StreamingComputationRanges'{..}
= object
(catMaybes
[("rangeAssignments" .=) <$> _scrRangeAssignments,
("computationId" .=) <$> _scrComputationId])
data ListJobsResponse = ListJobsResponse'
{ _ljrNextPageToken :: !(Maybe Text)
, _ljrJobs :: !(Maybe [Job])
} deriving (Eq,Show,Data,Typeable,Generic)
listJobsResponse
:: ListJobsResponse
listJobsResponse =
ListJobsResponse'
{ _ljrNextPageToken = Nothing
, _ljrJobs = Nothing
}
ljrNextPageToken :: Lens' ListJobsResponse (Maybe Text)
ljrNextPageToken
= lens _ljrNextPageToken
(\ s a -> s{_ljrNextPageToken = a})
ljrJobs :: Lens' ListJobsResponse [Job]
ljrJobs
= lens _ljrJobs (\ s a -> s{_ljrJobs = a}) . _Default
. _Coerce
instance FromJSON ListJobsResponse where
parseJSON
= withObject "ListJobsResponse"
(\ o ->
ListJobsResponse' <$>
(o .:? "nextPageToken") <*>
(o .:? "jobs" .!= mempty))
instance ToJSON ListJobsResponse where
toJSON ListJobsResponse'{..}
= object
(catMaybes
[("nextPageToken" .=) <$> _ljrNextPageToken,
("jobs" .=) <$> _ljrJobs])
data Source = Source'
{ _souDoesNotNeedSplitting :: !(Maybe Bool)
, _souBaseSpecs :: !(Maybe [SourceBaseSpecsItem])
, _souCodec :: !(Maybe SourceCodec)
, _souSpec :: !(Maybe SourceSpec)
, _souMetadata :: !(Maybe SourceMetadata)
} deriving (Eq,Show,Data,Typeable,Generic)
source
:: Source
source =
Source'
{ _souDoesNotNeedSplitting = Nothing
, _souBaseSpecs = Nothing
, _souCodec = Nothing
, _souSpec = Nothing
, _souMetadata = Nothing
}
souDoesNotNeedSplitting :: Lens' Source (Maybe Bool)
souDoesNotNeedSplitting
= lens _souDoesNotNeedSplitting
(\ s a -> s{_souDoesNotNeedSplitting = a})
souBaseSpecs :: Lens' Source [SourceBaseSpecsItem]
souBaseSpecs
= lens _souBaseSpecs (\ s a -> s{_souBaseSpecs = a})
. _Default
. _Coerce
souCodec :: Lens' Source (Maybe SourceCodec)
souCodec = lens _souCodec (\ s a -> s{_souCodec = a})
souSpec :: Lens' Source (Maybe SourceSpec)
souSpec = lens _souSpec (\ s a -> s{_souSpec = a})
souMetadata :: Lens' Source (Maybe SourceMetadata)
souMetadata
= lens _souMetadata (\ s a -> s{_souMetadata = a})
instance FromJSON Source where
parseJSON
= withObject "Source"
(\ o ->
Source' <$>
(o .:? "doesNotNeedSplitting") <*>
(o .:? "baseSpecs" .!= mempty)
<*> (o .:? "codec")
<*> (o .:? "spec")
<*> (o .:? "metadata"))
instance ToJSON Source where
toJSON Source'{..}
= object
(catMaybes
[("doesNotNeedSplitting" .=) <$>
_souDoesNotNeedSplitting,
("baseSpecs" .=) <$> _souBaseSpecs,
("codec" .=) <$> _souCodec, ("spec" .=) <$> _souSpec,
("metadata" .=) <$> _souMetadata])
data ApproximateProgress = ApproximateProgress'
{ _apRemainingTime :: !(Maybe Text)
, _apPercentComplete :: !(Maybe (Textual Double))
, _apPosition :: !(Maybe Position)
} deriving (Eq,Show,Data,Typeable,Generic)
approximateProgress
:: ApproximateProgress
approximateProgress =
ApproximateProgress'
{ _apRemainingTime = Nothing
, _apPercentComplete = Nothing
, _apPosition = Nothing
}
apRemainingTime :: Lens' ApproximateProgress (Maybe Text)
apRemainingTime
= lens _apRemainingTime
(\ s a -> s{_apRemainingTime = a})
apPercentComplete :: Lens' ApproximateProgress (Maybe Double)
apPercentComplete
= lens _apPercentComplete
(\ s a -> s{_apPercentComplete = a})
. mapping _Coerce
apPosition :: Lens' ApproximateProgress (Maybe Position)
apPosition
= lens _apPosition (\ s a -> s{_apPosition = a})
instance FromJSON ApproximateProgress where
parseJSON
= withObject "ApproximateProgress"
(\ o ->
ApproximateProgress' <$>
(o .:? "remainingTime") <*> (o .:? "percentComplete")
<*> (o .:? "position"))
instance ToJSON ApproximateProgress where
toJSON ApproximateProgress'{..}
= object
(catMaybes
[("remainingTime" .=) <$> _apRemainingTime,
("percentComplete" .=) <$> _apPercentComplete,
("position" .=) <$> _apPosition])
data WorkerMessage = WorkerMessage'
{ _wmWorkerHealthReport :: !(Maybe WorkerHealthReport)
, _wmTime :: !(Maybe Text)
, _wmWorkerMessageCode :: !(Maybe WorkerMessageCode)
, _wmLabels :: !(Maybe WorkerMessageLabels)
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessage
:: WorkerMessage
workerMessage =
WorkerMessage'
{ _wmWorkerHealthReport = Nothing
, _wmTime = Nothing
, _wmWorkerMessageCode = Nothing
, _wmLabels = Nothing
}
wmWorkerHealthReport :: Lens' WorkerMessage (Maybe WorkerHealthReport)
wmWorkerHealthReport
= lens _wmWorkerHealthReport
(\ s a -> s{_wmWorkerHealthReport = a})
wmTime :: Lens' WorkerMessage (Maybe Text)
wmTime = lens _wmTime (\ s a -> s{_wmTime = a})
wmWorkerMessageCode :: Lens' WorkerMessage (Maybe WorkerMessageCode)
wmWorkerMessageCode
= lens _wmWorkerMessageCode
(\ s a -> s{_wmWorkerMessageCode = a})
wmLabels :: Lens' WorkerMessage (Maybe WorkerMessageLabels)
wmLabels = lens _wmLabels (\ s a -> s{_wmLabels = a})
instance FromJSON WorkerMessage where
parseJSON
= withObject "WorkerMessage"
(\ o ->
WorkerMessage' <$>
(o .:? "workerHealthReport") <*> (o .:? "time") <*>
(o .:? "workerMessageCode")
<*> (o .:? "labels"))
instance ToJSON WorkerMessage where
toJSON WorkerMessage'{..}
= object
(catMaybes
[("workerHealthReport" .=) <$> _wmWorkerHealthReport,
("time" .=) <$> _wmTime,
("workerMessageCode" .=) <$> _wmWorkerMessageCode,
("labels" .=) <$> _wmLabels])
data KeyRangeLocation = KeyRangeLocation'
{ _krlPersistentDirectory :: !(Maybe Text)
, _krlDataDisk :: !(Maybe Text)
, _krlStart :: !(Maybe Text)
, _krlDeliveryEndpoint :: !(Maybe Text)
, _krlEnd :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
keyRangeLocation
:: KeyRangeLocation
keyRangeLocation =
KeyRangeLocation'
{ _krlPersistentDirectory = Nothing
, _krlDataDisk = Nothing
, _krlStart = Nothing
, _krlDeliveryEndpoint = Nothing
, _krlEnd = Nothing
}
krlPersistentDirectory :: Lens' KeyRangeLocation (Maybe Text)
krlPersistentDirectory
= lens _krlPersistentDirectory
(\ s a -> s{_krlPersistentDirectory = a})
krlDataDisk :: Lens' KeyRangeLocation (Maybe Text)
krlDataDisk
= lens _krlDataDisk (\ s a -> s{_krlDataDisk = a})
krlStart :: Lens' KeyRangeLocation (Maybe Text)
krlStart = lens _krlStart (\ s a -> s{_krlStart = a})
krlDeliveryEndpoint :: Lens' KeyRangeLocation (Maybe Text)
krlDeliveryEndpoint
= lens _krlDeliveryEndpoint
(\ s a -> s{_krlDeliveryEndpoint = a})
krlEnd :: Lens' KeyRangeLocation (Maybe Text)
krlEnd = lens _krlEnd (\ s a -> s{_krlEnd = a})
instance FromJSON KeyRangeLocation where
parseJSON
= withObject "KeyRangeLocation"
(\ o ->
KeyRangeLocation' <$>
(o .:? "persistentDirectory") <*> (o .:? "dataDisk")
<*> (o .:? "start")
<*> (o .:? "deliveryEndpoint")
<*> (o .:? "end"))
instance ToJSON KeyRangeLocation where
toJSON KeyRangeLocation'{..}
= object
(catMaybes
[("persistentDirectory" .=) <$>
_krlPersistentDirectory,
("dataDisk" .=) <$> _krlDataDisk,
("start" .=) <$> _krlStart,
("deliveryEndpoint" .=) <$> _krlDeliveryEndpoint,
("end" .=) <$> _krlEnd])
newtype MultiOutputInfo = MultiOutputInfo'
{ _moiTag :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
multiOutputInfo
:: MultiOutputInfo
multiOutputInfo =
MultiOutputInfo'
{ _moiTag = Nothing
}
moiTag :: Lens' MultiOutputInfo (Maybe Text)
moiTag = lens _moiTag (\ s a -> s{_moiTag = a})
instance FromJSON MultiOutputInfo where
parseJSON
= withObject "MultiOutputInfo"
(\ o -> MultiOutputInfo' <$> (o .:? "tag"))
instance ToJSON MultiOutputInfo where
toJSON MultiOutputInfo'{..}
= object (catMaybes [("tag" .=) <$> _moiTag])
data PartialGroupByKeyInstruction = PartialGroupByKeyInstruction'
{ _pgbkiValueCombiningFn :: !(Maybe PartialGroupByKeyInstructionValueCombiningFn)
, _pgbkiSideInputs :: !(Maybe [SideInputInfo])
, _pgbkiInput :: !(Maybe InstructionInput)
, _pgbkiOriginalCombineValuesStepName :: !(Maybe Text)
, _pgbkiInputElementCodec :: !(Maybe PartialGroupByKeyInstructionInputElementCodec)
, _pgbkiOriginalCombineValuesInputStoreName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
partialGroupByKeyInstruction
:: PartialGroupByKeyInstruction
partialGroupByKeyInstruction =
PartialGroupByKeyInstruction'
{ _pgbkiValueCombiningFn = Nothing
, _pgbkiSideInputs = Nothing
, _pgbkiInput = Nothing
, _pgbkiOriginalCombineValuesStepName = Nothing
, _pgbkiInputElementCodec = Nothing
, _pgbkiOriginalCombineValuesInputStoreName = Nothing
}
pgbkiValueCombiningFn :: Lens' PartialGroupByKeyInstruction (Maybe PartialGroupByKeyInstructionValueCombiningFn)
pgbkiValueCombiningFn
= lens _pgbkiValueCombiningFn
(\ s a -> s{_pgbkiValueCombiningFn = a})
pgbkiSideInputs :: Lens' PartialGroupByKeyInstruction [SideInputInfo]
pgbkiSideInputs
= lens _pgbkiSideInputs
(\ s a -> s{_pgbkiSideInputs = a})
. _Default
. _Coerce
pgbkiInput :: Lens' PartialGroupByKeyInstruction (Maybe InstructionInput)
pgbkiInput
= lens _pgbkiInput (\ s a -> s{_pgbkiInput = a})
pgbkiOriginalCombineValuesStepName :: Lens' PartialGroupByKeyInstruction (Maybe Text)
pgbkiOriginalCombineValuesStepName
= lens _pgbkiOriginalCombineValuesStepName
(\ s a -> s{_pgbkiOriginalCombineValuesStepName = a})
pgbkiInputElementCodec :: Lens' PartialGroupByKeyInstruction (Maybe PartialGroupByKeyInstructionInputElementCodec)
pgbkiInputElementCodec
= lens _pgbkiInputElementCodec
(\ s a -> s{_pgbkiInputElementCodec = a})
pgbkiOriginalCombineValuesInputStoreName :: Lens' PartialGroupByKeyInstruction (Maybe Text)
pgbkiOriginalCombineValuesInputStoreName
= lens _pgbkiOriginalCombineValuesInputStoreName
(\ s a ->
s{_pgbkiOriginalCombineValuesInputStoreName = a})
instance FromJSON PartialGroupByKeyInstruction where
parseJSON
= withObject "PartialGroupByKeyInstruction"
(\ o ->
PartialGroupByKeyInstruction' <$>
(o .:? "valueCombiningFn") <*>
(o .:? "sideInputs" .!= mempty)
<*> (o .:? "input")
<*> (o .:? "originalCombineValuesStepName")
<*> (o .:? "inputElementCodec")
<*> (o .:? "originalCombineValuesInputStoreName"))
instance ToJSON PartialGroupByKeyInstruction where
toJSON PartialGroupByKeyInstruction'{..}
= object
(catMaybes
[("valueCombiningFn" .=) <$> _pgbkiValueCombiningFn,
("sideInputs" .=) <$> _pgbkiSideInputs,
("input" .=) <$> _pgbkiInput,
("originalCombineValuesStepName" .=) <$>
_pgbkiOriginalCombineValuesStepName,
("inputElementCodec" .=) <$> _pgbkiInputElementCodec,
("originalCombineValuesInputStoreName" .=) <$>
_pgbkiOriginalCombineValuesInputStoreName])
data ParDoInstruction = ParDoInstruction'
{ _pdiNumOutputs :: !(Maybe (Textual Int32))
, _pdiMultiOutputInfos :: !(Maybe [MultiOutputInfo])
, _pdiSideInputs :: !(Maybe [SideInputInfo])
, _pdiInput :: !(Maybe InstructionInput)
, _pdiUserFn :: !(Maybe ParDoInstructionUserFn)
} deriving (Eq,Show,Data,Typeable,Generic)
parDoInstruction
:: ParDoInstruction
parDoInstruction =
ParDoInstruction'
{ _pdiNumOutputs = Nothing
, _pdiMultiOutputInfos = Nothing
, _pdiSideInputs = Nothing
, _pdiInput = Nothing
, _pdiUserFn = Nothing
}
pdiNumOutputs :: Lens' ParDoInstruction (Maybe Int32)
pdiNumOutputs
= lens _pdiNumOutputs
(\ s a -> s{_pdiNumOutputs = a})
. mapping _Coerce
pdiMultiOutputInfos :: Lens' ParDoInstruction [MultiOutputInfo]
pdiMultiOutputInfos
= lens _pdiMultiOutputInfos
(\ s a -> s{_pdiMultiOutputInfos = a})
. _Default
. _Coerce
pdiSideInputs :: Lens' ParDoInstruction [SideInputInfo]
pdiSideInputs
= lens _pdiSideInputs
(\ s a -> s{_pdiSideInputs = a})
. _Default
. _Coerce
pdiInput :: Lens' ParDoInstruction (Maybe InstructionInput)
pdiInput = lens _pdiInput (\ s a -> s{_pdiInput = a})
pdiUserFn :: Lens' ParDoInstruction (Maybe ParDoInstructionUserFn)
pdiUserFn
= lens _pdiUserFn (\ s a -> s{_pdiUserFn = a})
instance FromJSON ParDoInstruction where
parseJSON
= withObject "ParDoInstruction"
(\ o ->
ParDoInstruction' <$>
(o .:? "numOutputs") <*>
(o .:? "multiOutputInfos" .!= mempty)
<*> (o .:? "sideInputs" .!= mempty)
<*> (o .:? "input")
<*> (o .:? "userFn"))
instance ToJSON ParDoInstruction where
toJSON ParDoInstruction'{..}
= object
(catMaybes
[("numOutputs" .=) <$> _pdiNumOutputs,
("multiOutputInfos" .=) <$> _pdiMultiOutputInfos,
("sideInputs" .=) <$> _pdiSideInputs,
("input" .=) <$> _pdiInput,
("userFn" .=) <$> _pdiUserFn])
newtype CustomSourceLocation = CustomSourceLocation'
{ _cslStateful :: Maybe Bool
} deriving (Eq,Show,Data,Typeable,Generic)
customSourceLocation
:: CustomSourceLocation
customSourceLocation =
CustomSourceLocation'
{ _cslStateful = Nothing
}
cslStateful :: Lens' CustomSourceLocation (Maybe Bool)
cslStateful
= lens _cslStateful (\ s a -> s{_cslStateful = a})
instance FromJSON CustomSourceLocation where
parseJSON
= withObject "CustomSourceLocation"
(\ o -> CustomSourceLocation' <$> (o .:? "stateful"))
instance ToJSON CustomSourceLocation where
toJSON CustomSourceLocation'{..}
= object
(catMaybes [("stateful" .=) <$> _cslStateful])
newtype SourceBaseSpecsItem = SourceBaseSpecsItem'
{ _sbsiAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
sourceBaseSpecsItem
:: HashMap Text JSONValue
-> SourceBaseSpecsItem
sourceBaseSpecsItem pSbsiAddtional_ =
SourceBaseSpecsItem'
{ _sbsiAddtional = _Coerce # pSbsiAddtional_
}
sbsiAddtional :: Lens' SourceBaseSpecsItem (HashMap Text JSONValue)
sbsiAddtional
= lens _sbsiAddtional
(\ s a -> s{_sbsiAddtional = a})
. _Coerce
instance FromJSON SourceBaseSpecsItem where
parseJSON
= withObject "SourceBaseSpecsItem"
(\ o -> SourceBaseSpecsItem' <$> (parseJSONObject o))
instance ToJSON SourceBaseSpecsItem where
toJSON = toJSON . _sbsiAddtional
data ParallelInstruction = ParallelInstruction'
{ _piRead :: !(Maybe ReadInstruction)
, _piWrite :: !(Maybe WriteInstruction)
, _piParDo :: !(Maybe ParDoInstruction)
, _piPartialGroupByKey :: !(Maybe PartialGroupByKeyInstruction)
, _piOutputs :: !(Maybe [InstructionOutput])
, _piName :: !(Maybe Text)
, _piSystemName :: !(Maybe Text)
, _piFlatten :: !(Maybe FlattenInstruction)
, _piOriginalName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
parallelInstruction
:: ParallelInstruction
parallelInstruction =
ParallelInstruction'
{ _piRead = Nothing
, _piWrite = Nothing
, _piParDo = Nothing
, _piPartialGroupByKey = Nothing
, _piOutputs = Nothing
, _piName = Nothing
, _piSystemName = Nothing
, _piFlatten = Nothing
, _piOriginalName = Nothing
}
piRead :: Lens' ParallelInstruction (Maybe ReadInstruction)
piRead = lens _piRead (\ s a -> s{_piRead = a})
piWrite :: Lens' ParallelInstruction (Maybe WriteInstruction)
piWrite = lens _piWrite (\ s a -> s{_piWrite = a})
piParDo :: Lens' ParallelInstruction (Maybe ParDoInstruction)
piParDo = lens _piParDo (\ s a -> s{_piParDo = a})
piPartialGroupByKey :: Lens' ParallelInstruction (Maybe PartialGroupByKeyInstruction)
piPartialGroupByKey
= lens _piPartialGroupByKey
(\ s a -> s{_piPartialGroupByKey = a})
piOutputs :: Lens' ParallelInstruction [InstructionOutput]
piOutputs
= lens _piOutputs (\ s a -> s{_piOutputs = a}) .
_Default
. _Coerce
piName :: Lens' ParallelInstruction (Maybe Text)
piName = lens _piName (\ s a -> s{_piName = a})
piSystemName :: Lens' ParallelInstruction (Maybe Text)
piSystemName
= lens _piSystemName (\ s a -> s{_piSystemName = a})
piFlatten :: Lens' ParallelInstruction (Maybe FlattenInstruction)
piFlatten
= lens _piFlatten (\ s a -> s{_piFlatten = a})
piOriginalName :: Lens' ParallelInstruction (Maybe Text)
piOriginalName
= lens _piOriginalName
(\ s a -> s{_piOriginalName = a})
instance FromJSON ParallelInstruction where
parseJSON
= withObject "ParallelInstruction"
(\ o ->
ParallelInstruction' <$>
(o .:? "read") <*> (o .:? "write") <*>
(o .:? "parDo")
<*> (o .:? "partialGroupByKey")
<*> (o .:? "outputs" .!= mempty)
<*> (o .:? "name")
<*> (o .:? "systemName")
<*> (o .:? "flatten")
<*> (o .:? "originalName"))
instance ToJSON ParallelInstruction where
toJSON ParallelInstruction'{..}
= object
(catMaybes
[("read" .=) <$> _piRead, ("write" .=) <$> _piWrite,
("parDo" .=) <$> _piParDo,
("partialGroupByKey" .=) <$> _piPartialGroupByKey,
("outputs" .=) <$> _piOutputs,
("name" .=) <$> _piName,
("systemName" .=) <$> _piSystemName,
("flatten" .=) <$> _piFlatten,
("originalName" .=) <$> _piOriginalName])
newtype SideInputInfoKind = SideInputInfoKind'
{ _siikAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
sideInputInfoKind
:: HashMap Text JSONValue
-> SideInputInfoKind
sideInputInfoKind pSiikAddtional_ =
SideInputInfoKind'
{ _siikAddtional = _Coerce # pSiikAddtional_
}
siikAddtional :: Lens' SideInputInfoKind (HashMap Text JSONValue)
siikAddtional
= lens _siikAddtional
(\ s a -> s{_siikAddtional = a})
. _Coerce
instance FromJSON SideInputInfoKind where
parseJSON
= withObject "SideInputInfoKind"
(\ o -> SideInputInfoKind' <$> (parseJSONObject o))
instance ToJSON SideInputInfoKind where
toJSON = toJSON . _siikAddtional
data StreamingConfigTask = StreamingConfigTask'
{ _sctUserStepToStateFamilyNameMap :: !(Maybe StreamingConfigTaskUserStepToStateFamilyNameMap)
, _sctStreamingComputationConfigs :: !(Maybe [StreamingComputationConfig])
} deriving (Eq,Show,Data,Typeable,Generic)
streamingConfigTask
:: StreamingConfigTask
streamingConfigTask =
StreamingConfigTask'
{ _sctUserStepToStateFamilyNameMap = Nothing
, _sctStreamingComputationConfigs = Nothing
}
sctUserStepToStateFamilyNameMap :: Lens' StreamingConfigTask (Maybe StreamingConfigTaskUserStepToStateFamilyNameMap)
sctUserStepToStateFamilyNameMap
= lens _sctUserStepToStateFamilyNameMap
(\ s a -> s{_sctUserStepToStateFamilyNameMap = a})
sctStreamingComputationConfigs :: Lens' StreamingConfigTask [StreamingComputationConfig]
sctStreamingComputationConfigs
= lens _sctStreamingComputationConfigs
(\ s a -> s{_sctStreamingComputationConfigs = a})
. _Default
. _Coerce
instance FromJSON StreamingConfigTask where
parseJSON
= withObject "StreamingConfigTask"
(\ o ->
StreamingConfigTask' <$>
(o .:? "userStepToStateFamilyNameMap") <*>
(o .:? "streamingComputationConfigs" .!= mempty))
instance ToJSON StreamingConfigTask where
toJSON StreamingConfigTask'{..}
= object
(catMaybes
[("userStepToStateFamilyNameMap" .=) <$>
_sctUserStepToStateFamilyNameMap,
("streamingComputationConfigs" .=) <$>
_sctStreamingComputationConfigs])
data MetricShortId = MetricShortId'
{ _msiShortId :: !(Maybe (Textual Int64))
, _msiMetricIndex :: !(Maybe (Textual Int32))
} deriving (Eq,Show,Data,Typeable,Generic)
metricShortId
:: MetricShortId
metricShortId =
MetricShortId'
{ _msiShortId = Nothing
, _msiMetricIndex = Nothing
}
msiShortId :: Lens' MetricShortId (Maybe Int64)
msiShortId
= lens _msiShortId (\ s a -> s{_msiShortId = a}) .
mapping _Coerce
msiMetricIndex :: Lens' MetricShortId (Maybe Int32)
msiMetricIndex
= lens _msiMetricIndex
(\ s a -> s{_msiMetricIndex = a})
. mapping _Coerce
instance FromJSON MetricShortId where
parseJSON
= withObject "MetricShortId"
(\ o ->
MetricShortId' <$>
(o .:? "shortId") <*> (o .:? "metricIndex"))
instance ToJSON MetricShortId where
toJSON MetricShortId'{..}
= object
(catMaybes
[("shortId" .=) <$> _msiShortId,
("metricIndex" .=) <$> _msiMetricIndex])
newtype SendWorkerMessagesRequest = SendWorkerMessagesRequest'
{ _swmrWorkerMessages :: Maybe [WorkerMessage]
} deriving (Eq,Show,Data,Typeable,Generic)
sendWorkerMessagesRequest
:: SendWorkerMessagesRequest
sendWorkerMessagesRequest =
SendWorkerMessagesRequest'
{ _swmrWorkerMessages = Nothing
}
swmrWorkerMessages :: Lens' SendWorkerMessagesRequest [WorkerMessage]
swmrWorkerMessages
= lens _swmrWorkerMessages
(\ s a -> s{_swmrWorkerMessages = a})
. _Default
. _Coerce
instance FromJSON SendWorkerMessagesRequest where
parseJSON
= withObject "SendWorkerMessagesRequest"
(\ o ->
SendWorkerMessagesRequest' <$>
(o .:? "workerMessages" .!= mempty))
instance ToJSON SendWorkerMessagesRequest where
toJSON SendWorkerMessagesRequest'{..}
= object
(catMaybes
[("workerMessages" .=) <$> _swmrWorkerMessages])
data SourceSplitShard = SourceSplitShard'
{ _sssDerivationMode :: !(Maybe Text)
, _sssSource :: !(Maybe Source)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceSplitShard
:: SourceSplitShard
sourceSplitShard =
SourceSplitShard'
{ _sssDerivationMode = Nothing
, _sssSource = Nothing
}
sssDerivationMode :: Lens' SourceSplitShard (Maybe Text)
sssDerivationMode
= lens _sssDerivationMode
(\ s a -> s{_sssDerivationMode = a})
sssSource :: Lens' SourceSplitShard (Maybe Source)
sssSource
= lens _sssSource (\ s a -> s{_sssSource = a})
instance FromJSON SourceSplitShard where
parseJSON
= withObject "SourceSplitShard"
(\ o ->
SourceSplitShard' <$>
(o .:? "derivationMode") <*> (o .:? "source"))
instance ToJSON SourceSplitShard where
toJSON SourceSplitShard'{..}
= object
(catMaybes
[("derivationMode" .=) <$> _sssDerivationMode,
("source" .=) <$> _sssSource])
data SideInputInfo = SideInputInfo'
{ _siiTag :: !(Maybe Text)
, _siiKind :: !(Maybe SideInputInfoKind)
, _siiSources :: !(Maybe [Source])
} deriving (Eq,Show,Data,Typeable,Generic)
sideInputInfo
:: SideInputInfo
sideInputInfo =
SideInputInfo'
{ _siiTag = Nothing
, _siiKind = Nothing
, _siiSources = Nothing
}
siiTag :: Lens' SideInputInfo (Maybe Text)
siiTag = lens _siiTag (\ s a -> s{_siiTag = a})
siiKind :: Lens' SideInputInfo (Maybe SideInputInfoKind)
siiKind = lens _siiKind (\ s a -> s{_siiKind = a})
siiSources :: Lens' SideInputInfo [Source]
siiSources
= lens _siiSources (\ s a -> s{_siiSources = a}) .
_Default
. _Coerce
instance FromJSON SideInputInfo where
parseJSON
= withObject "SideInputInfo"
(\ o ->
SideInputInfo' <$>
(o .:? "tag") <*> (o .:? "kind") <*>
(o .:? "sources" .!= mempty))
instance ToJSON SideInputInfo where
toJSON SideInputInfo'{..}
= object
(catMaybes
[("tag" .=) <$> _siiTag, ("kind" .=) <$> _siiKind,
("sources" .=) <$> _siiSources])
newtype JobExecutionInfo = JobExecutionInfo'
{ _jeiStages :: Maybe JobExecutionInfoStages
} deriving (Eq,Show,Data,Typeable,Generic)
jobExecutionInfo
:: JobExecutionInfo
jobExecutionInfo =
JobExecutionInfo'
{ _jeiStages = Nothing
}
jeiStages :: Lens' JobExecutionInfo (Maybe JobExecutionInfoStages)
jeiStages
= lens _jeiStages (\ s a -> s{_jeiStages = a})
instance FromJSON JobExecutionInfo where
parseJSON
= withObject "JobExecutionInfo"
(\ o -> JobExecutionInfo' <$> (o .:? "stages"))
instance ToJSON JobExecutionInfo where
toJSON JobExecutionInfo'{..}
= object (catMaybes [("stages" .=) <$> _jeiStages])
newtype SourceCodec = SourceCodec'
{ _souAddtional :: HashMap Text JSONValue
} deriving (Eq,Show,Data,Typeable,Generic)
sourceCodec
:: HashMap Text JSONValue
-> SourceCodec
sourceCodec pSouAddtional_ =
SourceCodec'
{ _souAddtional = _Coerce # pSouAddtional_
}
souAddtional :: Lens' SourceCodec (HashMap Text JSONValue)
souAddtional
= lens _souAddtional (\ s a -> s{_souAddtional = a})
. _Coerce
instance FromJSON SourceCodec where
parseJSON
= withObject "SourceCodec"
(\ o -> SourceCodec' <$> (parseJSONObject o))
instance ToJSON SourceCodec where
toJSON = toJSON . _souAddtional
data StateFamilyConfig = StateFamilyConfig'
{ _sfcIsRead :: !(Maybe Bool)
, _sfcStateFamily :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
stateFamilyConfig
:: StateFamilyConfig
stateFamilyConfig =
StateFamilyConfig'
{ _sfcIsRead = Nothing
, _sfcStateFamily = Nothing
}
sfcIsRead :: Lens' StateFamilyConfig (Maybe Bool)
sfcIsRead
= lens _sfcIsRead (\ s a -> s{_sfcIsRead = a})
sfcStateFamily :: Lens' StateFamilyConfig (Maybe Text)
sfcStateFamily
= lens _sfcStateFamily
(\ s a -> s{_sfcStateFamily = a})
instance FromJSON StateFamilyConfig where
parseJSON
= withObject "StateFamilyConfig"
(\ o ->
StateFamilyConfig' <$>
(o .:? "isRead") <*> (o .:? "stateFamily"))
instance ToJSON StateFamilyConfig where
toJSON StateFamilyConfig'{..}
= object
(catMaybes
[("isRead" .=) <$> _sfcIsRead,
("stateFamily" .=) <$> _sfcStateFamily])
data KeyRangeDataDiskAssignment = KeyRangeDataDiskAssignment'
{ _krddaDataDisk :: !(Maybe Text)
, _krddaStart :: !(Maybe Text)
, _krddaEnd :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
keyRangeDataDiskAssignment
:: KeyRangeDataDiskAssignment
keyRangeDataDiskAssignment =
KeyRangeDataDiskAssignment'
{ _krddaDataDisk = Nothing
, _krddaStart = Nothing
, _krddaEnd = Nothing
}
krddaDataDisk :: Lens' KeyRangeDataDiskAssignment (Maybe Text)
krddaDataDisk
= lens _krddaDataDisk
(\ s a -> s{_krddaDataDisk = a})
krddaStart :: Lens' KeyRangeDataDiskAssignment (Maybe Text)
krddaStart
= lens _krddaStart (\ s a -> s{_krddaStart = a})
krddaEnd :: Lens' KeyRangeDataDiskAssignment (Maybe Text)
krddaEnd = lens _krddaEnd (\ s a -> s{_krddaEnd = a})
instance FromJSON KeyRangeDataDiskAssignment where
parseJSON
= withObject "KeyRangeDataDiskAssignment"
(\ o ->
KeyRangeDataDiskAssignment' <$>
(o .:? "dataDisk") <*> (o .:? "start") <*>
(o .:? "end"))
instance ToJSON KeyRangeDataDiskAssignment where
toJSON KeyRangeDataDiskAssignment'{..}
= object
(catMaybes
[("dataDisk" .=) <$> _krddaDataDisk,
("start" .=) <$> _krddaStart,
("end" .=) <$> _krddaEnd])
data SourceSplitRequest = SourceSplitRequest'
{ _ssrSource :: !(Maybe Source)
, _ssrOptions :: !(Maybe SourceSplitOptions)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceSplitRequest
:: SourceSplitRequest
sourceSplitRequest =
SourceSplitRequest'
{ _ssrSource = Nothing
, _ssrOptions = Nothing
}
ssrSource :: Lens' SourceSplitRequest (Maybe Source)
ssrSource
= lens _ssrSource (\ s a -> s{_ssrSource = a})
ssrOptions :: Lens' SourceSplitRequest (Maybe SourceSplitOptions)
ssrOptions
= lens _ssrOptions (\ s a -> s{_ssrOptions = a})
instance FromJSON SourceSplitRequest where
parseJSON
= withObject "SourceSplitRequest"
(\ o ->
SourceSplitRequest' <$>
(o .:? "source") <*> (o .:? "options"))
instance ToJSON SourceSplitRequest where
toJSON SourceSplitRequest'{..}
= object
(catMaybes
[("source" .=) <$> _ssrSource,
("options" .=) <$> _ssrOptions])
data ListJobMessagesResponse = ListJobMessagesResponse'
{ _ljmrJobMessages :: !(Maybe [JobMessage])
, _ljmrNextPageToken :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
listJobMessagesResponse
:: ListJobMessagesResponse
listJobMessagesResponse =
ListJobMessagesResponse'
{ _ljmrJobMessages = Nothing
, _ljmrNextPageToken = Nothing
}
ljmrJobMessages :: Lens' ListJobMessagesResponse [JobMessage]
ljmrJobMessages
= lens _ljmrJobMessages
(\ s a -> s{_ljmrJobMessages = a})
. _Default
. _Coerce
ljmrNextPageToken :: Lens' ListJobMessagesResponse (Maybe Text)
ljmrNextPageToken
= lens _ljmrNextPageToken
(\ s a -> s{_ljmrNextPageToken = a})
instance FromJSON ListJobMessagesResponse where
parseJSON
= withObject "ListJobMessagesResponse"
(\ o ->
ListJobMessagesResponse' <$>
(o .:? "jobMessages" .!= mempty) <*>
(o .:? "nextPageToken"))
instance ToJSON ListJobMessagesResponse where
toJSON ListJobMessagesResponse'{..}
= object
(catMaybes
[("jobMessages" .=) <$> _ljmrJobMessages,
("nextPageToken" .=) <$> _ljmrNextPageToken])
data PubsubLocation = PubsubLocation'
{ _plTrackingSubscription :: !(Maybe Text)
, _plDropLateData :: !(Maybe Bool)
, _plTimestampLabel :: !(Maybe Text)
, _plIdLabel :: !(Maybe Text)
, _plTopic :: !(Maybe Text)
, _plSubscription :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
pubsubLocation
:: PubsubLocation
pubsubLocation =
PubsubLocation'
{ _plTrackingSubscription = Nothing
, _plDropLateData = Nothing
, _plTimestampLabel = Nothing
, _plIdLabel = Nothing
, _plTopic = Nothing
, _plSubscription = Nothing
}
plTrackingSubscription :: Lens' PubsubLocation (Maybe Text)
plTrackingSubscription
= lens _plTrackingSubscription
(\ s a -> s{_plTrackingSubscription = a})
plDropLateData :: Lens' PubsubLocation (Maybe Bool)
plDropLateData
= lens _plDropLateData
(\ s a -> s{_plDropLateData = a})
plTimestampLabel :: Lens' PubsubLocation (Maybe Text)
plTimestampLabel
= lens _plTimestampLabel
(\ s a -> s{_plTimestampLabel = a})
plIdLabel :: Lens' PubsubLocation (Maybe Text)
plIdLabel
= lens _plIdLabel (\ s a -> s{_plIdLabel = a})
plTopic :: Lens' PubsubLocation (Maybe Text)
plTopic = lens _plTopic (\ s a -> s{_plTopic = a})
plSubscription :: Lens' PubsubLocation (Maybe Text)
plSubscription
= lens _plSubscription
(\ s a -> s{_plSubscription = a})
instance FromJSON PubsubLocation where
parseJSON
= withObject "PubsubLocation"
(\ o ->
PubsubLocation' <$>
(o .:? "trackingSubscription") <*>
(o .:? "dropLateData")
<*> (o .:? "timestampLabel")
<*> (o .:? "idLabel")
<*> (o .:? "topic")
<*> (o .:? "subscription"))
instance ToJSON PubsubLocation where
toJSON PubsubLocation'{..}
= object
(catMaybes
[("trackingSubscription" .=) <$>
_plTrackingSubscription,
("dropLateData" .=) <$> _plDropLateData,
("timestampLabel" .=) <$> _plTimestampLabel,
("idLabel" .=) <$> _plIdLabel,
("topic" .=) <$> _plTopic,
("subscription" .=) <$> _plSubscription])
newtype FloatingPointList = FloatingPointList'
{ _fplElements :: Maybe [Textual Double]
} deriving (Eq,Show,Data,Typeable,Generic)
floatingPointList
:: FloatingPointList
floatingPointList =
FloatingPointList'
{ _fplElements = Nothing
}
fplElements :: Lens' FloatingPointList [Double]
fplElements
= lens _fplElements (\ s a -> s{_fplElements = a}) .
_Default
. _Coerce
instance FromJSON FloatingPointList where
parseJSON
= withObject "FloatingPointList"
(\ o ->
FloatingPointList' <$> (o .:? "elements" .!= mempty))
instance ToJSON FloatingPointList where
toJSON FloatingPointList'{..}
= object
(catMaybes [("elements" .=) <$> _fplElements])
data InstructionInput = InstructionInput'
{ _iiProducerInstructionIndex :: !(Maybe (Textual Int32))
, _iiOutputNum :: !(Maybe (Textual Int32))
} deriving (Eq,Show,Data,Typeable,Generic)
instructionInput
:: InstructionInput
instructionInput =
InstructionInput'
{ _iiProducerInstructionIndex = Nothing
, _iiOutputNum = Nothing
}
iiProducerInstructionIndex :: Lens' InstructionInput (Maybe Int32)
iiProducerInstructionIndex
= lens _iiProducerInstructionIndex
(\ s a -> s{_iiProducerInstructionIndex = a})
. mapping _Coerce
iiOutputNum :: Lens' InstructionInput (Maybe Int32)
iiOutputNum
= lens _iiOutputNum (\ s a -> s{_iiOutputNum = a}) .
mapping _Coerce
instance FromJSON InstructionInput where
parseJSON
= withObject "InstructionInput"
(\ o ->
InstructionInput' <$>
(o .:? "producerInstructionIndex") <*>
(o .:? "outputNum"))
instance ToJSON InstructionInput where
toJSON InstructionInput'{..}
= object
(catMaybes
[("producerInstructionIndex" .=) <$>
_iiProducerInstructionIndex,
("outputNum" .=) <$> _iiOutputNum])
data SeqMapTask = SeqMapTask'
{ _smtInputs :: !(Maybe [SideInputInfo])
, _smtName :: !(Maybe Text)
, _smtOutputInfos :: !(Maybe [SeqMapTaskOutputInfo])
, _smtSystemName :: !(Maybe Text)
, _smtStageName :: !(Maybe Text)
, _smtUserFn :: !(Maybe SeqMapTaskUserFn)
} deriving (Eq,Show,Data,Typeable,Generic)
seqMapTask
:: SeqMapTask
seqMapTask =
SeqMapTask'
{ _smtInputs = Nothing
, _smtName = Nothing
, _smtOutputInfos = Nothing
, _smtSystemName = Nothing
, _smtStageName = Nothing
, _smtUserFn = Nothing
}
smtInputs :: Lens' SeqMapTask [SideInputInfo]
smtInputs
= lens _smtInputs (\ s a -> s{_smtInputs = a}) .
_Default
. _Coerce
smtName :: Lens' SeqMapTask (Maybe Text)
smtName = lens _smtName (\ s a -> s{_smtName = a})
smtOutputInfos :: Lens' SeqMapTask [SeqMapTaskOutputInfo]
smtOutputInfos
= lens _smtOutputInfos
(\ s a -> s{_smtOutputInfos = a})
. _Default
. _Coerce
smtSystemName :: Lens' SeqMapTask (Maybe Text)
smtSystemName
= lens _smtSystemName
(\ s a -> s{_smtSystemName = a})
smtStageName :: Lens' SeqMapTask (Maybe Text)
smtStageName
= lens _smtStageName (\ s a -> s{_smtStageName = a})
smtUserFn :: Lens' SeqMapTask (Maybe SeqMapTaskUserFn)
smtUserFn
= lens _smtUserFn (\ s a -> s{_smtUserFn = a})
instance FromJSON SeqMapTask where
parseJSON
= withObject "SeqMapTask"
(\ o ->
SeqMapTask' <$>
(o .:? "inputs" .!= mempty) <*> (o .:? "name") <*>
(o .:? "outputInfos" .!= mempty)
<*> (o .:? "systemName")
<*> (o .:? "stageName")
<*> (o .:? "userFn"))
instance ToJSON SeqMapTask where
toJSON SeqMapTask'{..}
= object
(catMaybes
[("inputs" .=) <$> _smtInputs,
("name" .=) <$> _smtName,
("outputInfos" .=) <$> _smtOutputInfos,
("systemName" .=) <$> _smtSystemName,
("stageName" .=) <$> _smtStageName,
("userFn" .=) <$> _smtUserFn])
newtype StreamingConfigTaskUserStepToStateFamilyNameMap = StreamingConfigTaskUserStepToStateFamilyNameMap'
{ _sctustsfnmAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
streamingConfigTaskUserStepToStateFamilyNameMap
:: HashMap Text Text
-> StreamingConfigTaskUserStepToStateFamilyNameMap
streamingConfigTaskUserStepToStateFamilyNameMap pSctustsfnmAddtional_ =
StreamingConfigTaskUserStepToStateFamilyNameMap'
{ _sctustsfnmAddtional = _Coerce # pSctustsfnmAddtional_
}
sctustsfnmAddtional :: Lens' StreamingConfigTaskUserStepToStateFamilyNameMap (HashMap Text Text)
sctustsfnmAddtional
= lens _sctustsfnmAddtional
(\ s a -> s{_sctustsfnmAddtional = a})
. _Coerce
instance FromJSON
StreamingConfigTaskUserStepToStateFamilyNameMap where
parseJSON
= withObject
"StreamingConfigTaskUserStepToStateFamilyNameMap"
(\ o ->
StreamingConfigTaskUserStepToStateFamilyNameMap' <$>
(parseJSONObject o))
instance ToJSON
StreamingConfigTaskUserStepToStateFamilyNameMap where
toJSON = toJSON . _sctustsfnmAddtional
data SourceOperationRequest = SourceOperationRequest'
{ _sSplit :: !(Maybe SourceSplitRequest)
, _sGetMetadata :: !(Maybe SourceGetMetadataRequest)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceOperationRequest
:: SourceOperationRequest
sourceOperationRequest =
SourceOperationRequest'
{ _sSplit = Nothing
, _sGetMetadata = Nothing
}
sSplit :: Lens' SourceOperationRequest (Maybe SourceSplitRequest)
sSplit = lens _sSplit (\ s a -> s{_sSplit = a})
sGetMetadata :: Lens' SourceOperationRequest (Maybe SourceGetMetadataRequest)
sGetMetadata
= lens _sGetMetadata (\ s a -> s{_sGetMetadata = a})
instance FromJSON SourceOperationRequest where
parseJSON
= withObject "SourceOperationRequest"
(\ o ->
SourceOperationRequest' <$>
(o .:? "split") <*> (o .:? "getMetadata"))
instance ToJSON SourceOperationRequest where
toJSON SourceOperationRequest'{..}
= object
(catMaybes
[("split" .=) <$> _sSplit,
("getMetadata" .=) <$> _sGetMetadata])
newtype LeaseWorkItemResponse = LeaseWorkItemResponse'
{ _lwirWorkItems :: Maybe [WorkItem]
} deriving (Eq,Show,Data,Typeable,Generic)
leaseWorkItemResponse
:: LeaseWorkItemResponse
leaseWorkItemResponse =
LeaseWorkItemResponse'
{ _lwirWorkItems = Nothing
}
lwirWorkItems :: Lens' LeaseWorkItemResponse [WorkItem]
lwirWorkItems
= lens _lwirWorkItems
(\ s a -> s{_lwirWorkItems = a})
. _Default
. _Coerce
instance FromJSON LeaseWorkItemResponse where
parseJSON
= withObject "LeaseWorkItemResponse"
(\ o ->
LeaseWorkItemResponse' <$>
(o .:? "workItems" .!= mempty))
instance ToJSON LeaseWorkItemResponse where
toJSON LeaseWorkItemResponse'{..}
= object
(catMaybes [("workItems" .=) <$> _lwirWorkItems])
data Position = Position'
{ _pByteOffSet :: !(Maybe (Textual Int64))
, _pConcatPosition :: !(Maybe ConcatPosition)
, _pRecordIndex :: !(Maybe (Textual Int64))
, _pShufflePosition :: !(Maybe Text)
, _pKey :: !(Maybe Text)
, _pEnd :: !(Maybe Bool)
} deriving (Eq,Show,Data,Typeable,Generic)
position
:: Position
position =
Position'
{ _pByteOffSet = Nothing
, _pConcatPosition = Nothing
, _pRecordIndex = Nothing
, _pShufflePosition = Nothing
, _pKey = Nothing
, _pEnd = Nothing
}
pByteOffSet :: Lens' Position (Maybe Int64)
pByteOffSet
= lens _pByteOffSet (\ s a -> s{_pByteOffSet = a}) .
mapping _Coerce
pConcatPosition :: Lens' Position (Maybe ConcatPosition)
pConcatPosition
= lens _pConcatPosition
(\ s a -> s{_pConcatPosition = a})
pRecordIndex :: Lens' Position (Maybe Int64)
pRecordIndex
= lens _pRecordIndex (\ s a -> s{_pRecordIndex = a})
. mapping _Coerce
pShufflePosition :: Lens' Position (Maybe Text)
pShufflePosition
= lens _pShufflePosition
(\ s a -> s{_pShufflePosition = a})
pKey :: Lens' Position (Maybe Text)
pKey = lens _pKey (\ s a -> s{_pKey = a})
pEnd :: Lens' Position (Maybe Bool)
pEnd = lens _pEnd (\ s a -> s{_pEnd = a})
instance FromJSON Position where
parseJSON
= withObject "Position"
(\ o ->
Position' <$>
(o .:? "byteOffset") <*> (o .:? "concatPosition") <*>
(o .:? "recordIndex")
<*> (o .:? "shufflePosition")
<*> (o .:? "key")
<*> (o .:? "end"))
instance ToJSON Position where
toJSON Position'{..}
= object
(catMaybes
[("byteOffset" .=) <$> _pByteOffSet,
("concatPosition" .=) <$> _pConcatPosition,
("recordIndex" .=) <$> _pRecordIndex,
("shufflePosition" .=) <$> _pShufflePosition,
("key" .=) <$> _pKey, ("end" .=) <$> _pEnd])