{-# 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])
, _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
, _ctInputs = Nothing
, _ctKeyRanges = Nothing
, _ctOutputs = Nothing
, _ctComputationId = Nothing
, _ctSystemStageName = Nothing
}
ctStateFamilies :: Lens' ComputationTopology [StateFamilyConfig]
ctStateFamilies
= lens _ctStateFamilies
(\ s a -> s{_ctStateFamilies = a})
. _Default
. _Coerce
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 .:? "inputs" .!= mempty)
<*> (o .:? "keyRanges" .!= mempty)
<*> (o .:? "outputs" .!= mempty)
<*> (o .:? "computationId")
<*> (o .:? "systemStageName"))
instance ToJSON ComputationTopology where
toJSON ComputationTopology'{..}
= object
(catMaybes
[("stateFamilies" .=) <$> _ctStateFamilies,
("inputs" .=) <$> _ctInputs,
("keyRanges" .=) <$> _ctKeyRanges,
("outputs" .=) <$> _ctOutputs,
("computationId" .=) <$> _ctComputationId,
("systemStageName" .=) <$> _ctSystemStageName])
data SourceSplitResponse = SourceSplitResponse'
{ _ssrBundles :: !(Maybe [DerivedSource])
, _ssrShards :: !(Maybe [SourceSplitShard])
, _ssrOutcome :: !(Maybe SourceSplitResponseOutcome)
} 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 SourceSplitResponseOutcome)
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 ParameterMetadata = ParameterMetadata'
{ _pmHelpText :: !(Maybe Text)
, _pmIsOptional :: !(Maybe Bool)
, _pmName :: !(Maybe Text)
, _pmRegexes :: !(Maybe [Text])
, _pmLabel :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
parameterMetadata
:: ParameterMetadata
parameterMetadata =
ParameterMetadata'
{ _pmHelpText = Nothing
, _pmIsOptional = Nothing
, _pmName = Nothing
, _pmRegexes = Nothing
, _pmLabel = Nothing
}
pmHelpText :: Lens' ParameterMetadata (Maybe Text)
pmHelpText
= lens _pmHelpText (\ s a -> s{_pmHelpText = a})
pmIsOptional :: Lens' ParameterMetadata (Maybe Bool)
pmIsOptional
= lens _pmIsOptional (\ s a -> s{_pmIsOptional = a})
pmName :: Lens' ParameterMetadata (Maybe Text)
pmName = lens _pmName (\ s a -> s{_pmName = a})
pmRegexes :: Lens' ParameterMetadata [Text]
pmRegexes
= lens _pmRegexes (\ s a -> s{_pmRegexes = a}) .
_Default
. _Coerce
pmLabel :: Lens' ParameterMetadata (Maybe Text)
pmLabel = lens _pmLabel (\ s a -> s{_pmLabel = a})
instance FromJSON ParameterMetadata where
parseJSON
= withObject "ParameterMetadata"
(\ o ->
ParameterMetadata' <$>
(o .:? "helpText") <*> (o .:? "isOptional") <*>
(o .:? "name")
<*> (o .:? "regexes" .!= mempty)
<*> (o .:? "label"))
instance ToJSON ParameterMetadata where
toJSON ParameterMetadata'{..}
= object
(catMaybes
[("helpText" .=) <$> _pmHelpText,
("isOptional" .=) <$> _pmIsOptional,
("name" .=) <$> _pmName,
("regexes" .=) <$> _pmRegexes,
("label" .=) <$> _pmLabel])
data CreateJobFromTemplateRequest = CreateJobFromTemplateRequest'
{ _cjftrLocation :: !(Maybe Text)
, _cjftrEnvironment :: !(Maybe RuntimeEnvironment)
, _cjftrJobName :: !(Maybe Text)
, _cjftrGcsPath :: !(Maybe Text)
, _cjftrParameters :: !(Maybe CreateJobFromTemplateRequestParameters)
} deriving (Eq,Show,Data,Typeable,Generic)
createJobFromTemplateRequest
:: CreateJobFromTemplateRequest
createJobFromTemplateRequest =
CreateJobFromTemplateRequest'
{ _cjftrLocation = Nothing
, _cjftrEnvironment = Nothing
, _cjftrJobName = Nothing
, _cjftrGcsPath = Nothing
, _cjftrParameters = Nothing
}
cjftrLocation :: Lens' CreateJobFromTemplateRequest (Maybe Text)
cjftrLocation
= lens _cjftrLocation
(\ s a -> s{_cjftrLocation = a})
cjftrEnvironment :: Lens' CreateJobFromTemplateRequest (Maybe RuntimeEnvironment)
cjftrEnvironment
= lens _cjftrEnvironment
(\ s a -> s{_cjftrEnvironment = a})
cjftrJobName :: Lens' CreateJobFromTemplateRequest (Maybe Text)
cjftrJobName
= lens _cjftrJobName (\ s a -> s{_cjftrJobName = a})
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 .:? "location") <*> (o .:? "environment") <*>
(o .:? "jobName")
<*> (o .:? "gcsPath")
<*> (o .:? "parameters"))
instance ToJSON CreateJobFromTemplateRequest where
toJSON CreateJobFromTemplateRequest'{..}
= object
(catMaybes
[("location" .=) <$> _cjftrLocation,
("environment" .=) <$> _cjftrEnvironment,
("jobName" .=) <$> _cjftrJobName,
("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 NameAndKindKind)
, _nakName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
nameAndKind
:: NameAndKind
nameAndKind =
NameAndKind'
{ _nakKind = Nothing
, _nakName = Nothing
}
nakKind :: Lens' NameAndKind (Maybe NameAndKindKind)
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 GDuration)
, _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 DateTime')
, _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 Scientific)
wiReportStatusInterval
= lens _wiReportStatusInterval
(\ s a -> s{_wiReportStatusInterval = a})
. mapping _GDuration
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 UTCTime)
wiLeaseExpireTime
= lens _wiLeaseExpireTime
(\ s a -> s{_wiLeaseExpireTime = a})
. mapping _DateTime
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 GDuration)
, _whrPods :: !(Maybe [WorkerHealthReportPodsItem])
, _whrVMStartupTime :: !(Maybe DateTime')
} 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 Scientific)
whrReportInterval
= lens _whrReportInterval
(\ s a -> s{_whrReportInterval = a})
. mapping _GDuration
whrPods :: Lens' WorkerHealthReport [WorkerHealthReportPodsItem]
whrPods
= lens _whrPods (\ s a -> s{_whrPods = a}) . _Default
. _Coerce
whrVMStartupTime :: Lens' WorkerHealthReport (Maybe UTCTime)
whrVMStartupTime
= lens _whrVMStartupTime
(\ s a -> s{_whrVMStartupTime = a})
. mapping _DateTime
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 Snapshot = Snapshot'
{ _sCreationTime :: !(Maybe DateTime')
, _sTtl :: !(Maybe GDuration)
, _sSourceJobId :: !(Maybe Text)
, _sId :: !(Maybe Text)
, _sProjectId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
snapshot
:: Snapshot
snapshot =
Snapshot'
{ _sCreationTime = Nothing
, _sTtl = Nothing
, _sSourceJobId = Nothing
, _sId = Nothing
, _sProjectId = Nothing
}
sCreationTime :: Lens' Snapshot (Maybe UTCTime)
sCreationTime
= lens _sCreationTime
(\ s a -> s{_sCreationTime = a})
. mapping _DateTime
sTtl :: Lens' Snapshot (Maybe Scientific)
sTtl
= lens _sTtl (\ s a -> s{_sTtl = a}) .
mapping _GDuration
sSourceJobId :: Lens' Snapshot (Maybe Text)
sSourceJobId
= lens _sSourceJobId (\ s a -> s{_sSourceJobId = a})
sId :: Lens' Snapshot (Maybe Text)
sId = lens _sId (\ s a -> s{_sId = a})
sProjectId :: Lens' Snapshot (Maybe Text)
sProjectId
= lens _sProjectId (\ s a -> s{_sProjectId = a})
instance FromJSON Snapshot where
parseJSON
= withObject "Snapshot"
(\ o ->
Snapshot' <$>
(o .:? "creationTime") <*> (o .:? "ttl") <*>
(o .:? "sourceJobId")
<*> (o .:? "id")
<*> (o .:? "projectId"))
instance ToJSON Snapshot where
toJSON Snapshot'{..}
= object
(catMaybes
[("creationTime" .=) <$> _sCreationTime,
("ttl" .=) <$> _sTtl,
("sourceJobId" .=) <$> _sSourceJobId,
("id" .=) <$> _sId,
("projectId" .=) <$> _sProjectId])
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 AutoscalingSettingsAlgorithm)
} 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 AutoscalingSettingsAlgorithm)
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 IntegerGauge = IntegerGauge'
{ _igValue :: !(Maybe SplitInt64)
, _igTimestamp :: !(Maybe DateTime')
} deriving (Eq,Show,Data,Typeable,Generic)
integerGauge
:: IntegerGauge
integerGauge =
IntegerGauge'
{ _igValue = Nothing
, _igTimestamp = Nothing
}
igValue :: Lens' IntegerGauge (Maybe SplitInt64)
igValue = lens _igValue (\ s a -> s{_igValue = a})
igTimestamp :: Lens' IntegerGauge (Maybe UTCTime)
igTimestamp
= lens _igTimestamp (\ s a -> s{_igTimestamp = a}) .
mapping _DateTime
instance FromJSON IntegerGauge where
parseJSON
= withObject "IntegerGauge"
(\ o ->
IntegerGauge' <$>
(o .:? "value") <*> (o .:? "timestamp"))
instance ToJSON IntegerGauge where
toJSON IntegerGauge'{..}
= object
(catMaybes
[("value" .=) <$> _igValue,
("timestamp" .=) <$> _igTimestamp])
data LaunchTemplateParameters = LaunchTemplateParameters'
{ _ltpEnvironment :: !(Maybe RuntimeEnvironment)
, _ltpJobName :: !(Maybe Text)
, _ltpParameters :: !(Maybe LaunchTemplateParametersParameters)
} deriving (Eq,Show,Data,Typeable,Generic)
launchTemplateParameters
:: LaunchTemplateParameters
launchTemplateParameters =
LaunchTemplateParameters'
{ _ltpEnvironment = Nothing
, _ltpJobName = Nothing
, _ltpParameters = Nothing
}
ltpEnvironment :: Lens' LaunchTemplateParameters (Maybe RuntimeEnvironment)
ltpEnvironment
= lens _ltpEnvironment
(\ s a -> s{_ltpEnvironment = a})
ltpJobName :: Lens' LaunchTemplateParameters (Maybe Text)
ltpJobName
= lens _ltpJobName (\ s a -> s{_ltpJobName = a})
ltpParameters :: Lens' LaunchTemplateParameters (Maybe LaunchTemplateParametersParameters)
ltpParameters
= lens _ltpParameters
(\ s a -> s{_ltpParameters = a})
instance FromJSON LaunchTemplateParameters where
parseJSON
= withObject "LaunchTemplateParameters"
(\ o ->
LaunchTemplateParameters' <$>
(o .:? "environment") <*> (o .:? "jobName") <*>
(o .:? "parameters"))
instance ToJSON LaunchTemplateParameters where
toJSON LaunchTemplateParameters'{..}
= object
(catMaybes
[("environment" .=) <$> _ltpEnvironment,
("jobName" .=) <$> _ltpJobName,
("parameters" .=) <$> _ltpParameters])
data ReportWorkItemStatusRequest = ReportWorkItemStatusRequest'
{ _rwisrCurrentWorkerTime :: !(Maybe DateTime')
, _rwisrLocation :: !(Maybe Text)
, _rwisrWorkItemStatuses :: !(Maybe [WorkItemStatus])
, _rwisrWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
reportWorkItemStatusRequest
:: ReportWorkItemStatusRequest
reportWorkItemStatusRequest =
ReportWorkItemStatusRequest'
{ _rwisrCurrentWorkerTime = Nothing
, _rwisrLocation = Nothing
, _rwisrWorkItemStatuses = Nothing
, _rwisrWorkerId = Nothing
}
rwisrCurrentWorkerTime :: Lens' ReportWorkItemStatusRequest (Maybe UTCTime)
rwisrCurrentWorkerTime
= lens _rwisrCurrentWorkerTime
(\ s a -> s{_rwisrCurrentWorkerTime = a})
. mapping _DateTime
rwisrLocation :: Lens' ReportWorkItemStatusRequest (Maybe Text)
rwisrLocation
= lens _rwisrLocation
(\ s a -> s{_rwisrLocation = 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 .:? "location")
<*> (o .:? "workItemStatuses" .!= mempty)
<*> (o .:? "workerId"))
instance ToJSON ReportWorkItemStatusRequest where
toJSON ReportWorkItemStatusRequest'{..}
= object
(catMaybes
[("currentWorkerTime" .=) <$>
_rwisrCurrentWorkerTime,
("location" .=) <$> _rwisrLocation,
("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 StreamingApplianceSnapshotConfig = StreamingApplianceSnapshotConfig'
{ _sascImportStateEndpoint :: !(Maybe Text)
, _sascSnapshotId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
streamingApplianceSnapshotConfig
:: StreamingApplianceSnapshotConfig
streamingApplianceSnapshotConfig =
StreamingApplianceSnapshotConfig'
{ _sascImportStateEndpoint = Nothing
, _sascSnapshotId = Nothing
}
sascImportStateEndpoint :: Lens' StreamingApplianceSnapshotConfig (Maybe Text)
sascImportStateEndpoint
= lens _sascImportStateEndpoint
(\ s a -> s{_sascImportStateEndpoint = a})
sascSnapshotId :: Lens' StreamingApplianceSnapshotConfig (Maybe Text)
sascSnapshotId
= lens _sascSnapshotId
(\ s a -> s{_sascSnapshotId = a})
instance FromJSON StreamingApplianceSnapshotConfig
where
parseJSON
= withObject "StreamingApplianceSnapshotConfig"
(\ o ->
StreamingApplianceSnapshotConfig' <$>
(o .:? "importStateEndpoint") <*>
(o .:? "snapshotId"))
instance ToJSON StreamingApplianceSnapshotConfig
where
toJSON StreamingApplianceSnapshotConfig'{..}
= object
(catMaybes
[("importStateEndpoint" .=) <$>
_sascImportStateEndpoint,
("snapshotId" .=) <$> _sascSnapshotId])
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 GDuration
} deriving (Eq,Show,Data,Typeable,Generic)
workerHealthReportResponse
:: WorkerHealthReportResponse
workerHealthReportResponse =
WorkerHealthReportResponse'
{ _whrrReportInterval = Nothing
}
whrrReportInterval :: Lens' WorkerHealthReportResponse (Maybe Scientific)
whrrReportInterval
= lens _whrrReportInterval
(\ s a -> s{_whrrReportInterval = a})
. mapping _GDuration
instance FromJSON WorkerHealthReportResponse where
parseJSON
= withObject "WorkerHealthReportResponse"
(\ o ->
WorkerHealthReportResponse' <$>
(o .:? "reportInterval"))
instance ToJSON WorkerHealthReportResponse where
toJSON WorkerHealthReportResponse'{..}
= object
(catMaybes
[("reportInterval" .=) <$> _whrrReportInterval])
data DisplayData = DisplayData'
{ _ddDurationValue :: !(Maybe GDuration)
, _ddBoolValue :: !(Maybe Bool)
, _ddTimestampValue :: !(Maybe DateTime')
, _ddURL :: !(Maybe Text)
, _ddNamespace :: !(Maybe Text)
, _ddJavaClassValue :: !(Maybe Text)
, _ddShortStrValue :: !(Maybe Text)
, _ddKey :: !(Maybe Text)
, _ddInt64Value :: !(Maybe (Textual Int64))
, _ddFloatValue :: !(Maybe (Textual Double))
, _ddStrValue :: !(Maybe Text)
, _ddLabel :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
displayData
:: DisplayData
displayData =
DisplayData'
{ _ddDurationValue = Nothing
, _ddBoolValue = Nothing
, _ddTimestampValue = Nothing
, _ddURL = Nothing
, _ddNamespace = Nothing
, _ddJavaClassValue = Nothing
, _ddShortStrValue = Nothing
, _ddKey = Nothing
, _ddInt64Value = Nothing
, _ddFloatValue = Nothing
, _ddStrValue = Nothing
, _ddLabel = Nothing
}
ddDurationValue :: Lens' DisplayData (Maybe Scientific)
ddDurationValue
= lens _ddDurationValue
(\ s a -> s{_ddDurationValue = a})
. mapping _GDuration
ddBoolValue :: Lens' DisplayData (Maybe Bool)
ddBoolValue
= lens _ddBoolValue (\ s a -> s{_ddBoolValue = a})
ddTimestampValue :: Lens' DisplayData (Maybe UTCTime)
ddTimestampValue
= lens _ddTimestampValue
(\ s a -> s{_ddTimestampValue = a})
. mapping _DateTime
ddURL :: Lens' DisplayData (Maybe Text)
ddURL = lens _ddURL (\ s a -> s{_ddURL = a})
ddNamespace :: Lens' DisplayData (Maybe Text)
ddNamespace
= lens _ddNamespace (\ s a -> s{_ddNamespace = a})
ddJavaClassValue :: Lens' DisplayData (Maybe Text)
ddJavaClassValue
= lens _ddJavaClassValue
(\ s a -> s{_ddJavaClassValue = a})
ddShortStrValue :: Lens' DisplayData (Maybe Text)
ddShortStrValue
= lens _ddShortStrValue
(\ s a -> s{_ddShortStrValue = a})
ddKey :: Lens' DisplayData (Maybe Text)
ddKey = lens _ddKey (\ s a -> s{_ddKey = a})
ddInt64Value :: Lens' DisplayData (Maybe Int64)
ddInt64Value
= lens _ddInt64Value (\ s a -> s{_ddInt64Value = a})
. mapping _Coerce
ddFloatValue :: Lens' DisplayData (Maybe Double)
ddFloatValue
= lens _ddFloatValue (\ s a -> s{_ddFloatValue = a})
. mapping _Coerce
ddStrValue :: Lens' DisplayData (Maybe Text)
ddStrValue
= lens _ddStrValue (\ s a -> s{_ddStrValue = a})
ddLabel :: Lens' DisplayData (Maybe Text)
ddLabel = lens _ddLabel (\ s a -> s{_ddLabel = a})
instance FromJSON DisplayData where
parseJSON
= withObject "DisplayData"
(\ o ->
DisplayData' <$>
(o .:? "durationValue") <*> (o .:? "boolValue") <*>
(o .:? "timestampValue")
<*> (o .:? "url")
<*> (o .:? "namespace")
<*> (o .:? "javaClassValue")
<*> (o .:? "shortStrValue")
<*> (o .:? "key")
<*> (o .:? "int64Value")
<*> (o .:? "floatValue")
<*> (o .:? "strValue")
<*> (o .:? "label"))
instance ToJSON DisplayData where
toJSON DisplayData'{..}
= object
(catMaybes
[("durationValue" .=) <$> _ddDurationValue,
("boolValue" .=) <$> _ddBoolValue,
("timestampValue" .=) <$> _ddTimestampValue,
("url" .=) <$> _ddURL,
("namespace" .=) <$> _ddNamespace,
("javaClassValue" .=) <$> _ddJavaClassValue,
("shortStrValue" .=) <$> _ddShortStrValue,
("key" .=) <$> _ddKey,
("int64Value" .=) <$> _ddInt64Value,
("floatValue" .=) <$> _ddFloatValue,
("strValue" .=) <$> _ddStrValue,
("label" .=) <$> _ddLabel])
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
data StructuredMessage = StructuredMessage'
{ _smMessageText :: !(Maybe Text)
, _smMessageKey :: !(Maybe Text)
, _smParameters :: !(Maybe [Parameter])
} deriving (Eq,Show,Data,Typeable,Generic)
structuredMessage
:: StructuredMessage
structuredMessage =
StructuredMessage'
{ _smMessageText = Nothing
, _smMessageKey = Nothing
, _smParameters = Nothing
}
smMessageText :: Lens' StructuredMessage (Maybe Text)
smMessageText
= lens _smMessageText
(\ s a -> s{_smMessageText = a})
smMessageKey :: Lens' StructuredMessage (Maybe Text)
smMessageKey
= lens _smMessageKey (\ s a -> s{_smMessageKey = a})
smParameters :: Lens' StructuredMessage [Parameter]
smParameters
= lens _smParameters (\ s a -> s{_smParameters = a})
. _Default
. _Coerce
instance FromJSON StructuredMessage where
parseJSON
= withObject "StructuredMessage"
(\ o ->
StructuredMessage' <$>
(o .:? "messageText") <*> (o .:? "messageKey") <*>
(o .:? "parameters" .!= mempty))
instance ToJSON StructuredMessage where
toJSON StructuredMessage'{..}
= object
(catMaybes
[("messageText" .=) <$> _smMessageText,
("messageKey" .=) <$> _smMessageKey,
("parameters" .=) <$> _smParameters])
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 BigQueryIODetails = BigQueryIODetails'
{ _bqiodDataSet :: !(Maybe Text)
, _bqiodQuery :: !(Maybe Text)
, _bqiodProjectId :: !(Maybe Text)
, _bqiodTable :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
bigQueryIODetails
:: BigQueryIODetails
bigQueryIODetails =
BigQueryIODetails'
{ _bqiodDataSet = Nothing
, _bqiodQuery = Nothing
, _bqiodProjectId = Nothing
, _bqiodTable = Nothing
}
bqiodDataSet :: Lens' BigQueryIODetails (Maybe Text)
bqiodDataSet
= lens _bqiodDataSet (\ s a -> s{_bqiodDataSet = a})
bqiodQuery :: Lens' BigQueryIODetails (Maybe Text)
bqiodQuery
= lens _bqiodQuery (\ s a -> s{_bqiodQuery = a})
bqiodProjectId :: Lens' BigQueryIODetails (Maybe Text)
bqiodProjectId
= lens _bqiodProjectId
(\ s a -> s{_bqiodProjectId = a})
bqiodTable :: Lens' BigQueryIODetails (Maybe Text)
bqiodTable
= lens _bqiodTable (\ s a -> s{_bqiodTable = a})
instance FromJSON BigQueryIODetails where
parseJSON
= withObject "BigQueryIODetails"
(\ o ->
BigQueryIODetails' <$>
(o .:? "dataset") <*> (o .:? "query") <*>
(o .:? "projectId")
<*> (o .:? "table"))
instance ToJSON BigQueryIODetails where
toJSON BigQueryIODetails'{..}
= object
(catMaybes
[("dataset" .=) <$> _bqiodDataSet,
("query" .=) <$> _bqiodQuery,
("projectId" .=) <$> _bqiodProjectId,
("table" .=) <$> _bqiodTable])
newtype FileIODetails = FileIODetails'
{ _fiodFilePattern :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
fileIODetails
:: FileIODetails
fileIODetails =
FileIODetails'
{ _fiodFilePattern = Nothing
}
fiodFilePattern :: Lens' FileIODetails (Maybe Text)
fiodFilePattern
= lens _fiodFilePattern
(\ s a -> s{_fiodFilePattern = a})
instance FromJSON FileIODetails where
parseJSON
= withObject "FileIODetails"
(\ o -> FileIODetails' <$> (o .:? "filePattern"))
instance ToJSON FileIODetails where
toJSON FileIODetails'{..}
= object
(catMaybes [("filePattern" .=) <$> _fiodFilePattern])
data CounterStructuredName = CounterStructuredName'
{ _csnOrigin :: !(Maybe CounterStructuredNameOrigin)
, _csnOriginNamespace :: !(Maybe Text)
, _csnComponentStepName :: !(Maybe Text)
, _csnPortion :: !(Maybe CounterStructuredNamePortion)
, _csnOriginalStepName :: !(Maybe Text)
, _csnName :: !(Maybe Text)
, _csnExecutionStepName :: !(Maybe Text)
, _csnOriginalRequestingStepName :: !(Maybe Text)
, _csnInputIndex :: !(Maybe (Textual Int32))
, _csnWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
counterStructuredName
:: CounterStructuredName
counterStructuredName =
CounterStructuredName'
{ _csnOrigin = Nothing
, _csnOriginNamespace = Nothing
, _csnComponentStepName = Nothing
, _csnPortion = Nothing
, _csnOriginalStepName = Nothing
, _csnName = Nothing
, _csnExecutionStepName = Nothing
, _csnOriginalRequestingStepName = Nothing
, _csnInputIndex = Nothing
, _csnWorkerId = Nothing
}
csnOrigin :: Lens' CounterStructuredName (Maybe CounterStructuredNameOrigin)
csnOrigin
= lens _csnOrigin (\ s a -> s{_csnOrigin = a})
csnOriginNamespace :: Lens' CounterStructuredName (Maybe Text)
csnOriginNamespace
= lens _csnOriginNamespace
(\ s a -> s{_csnOriginNamespace = a})
csnComponentStepName :: Lens' CounterStructuredName (Maybe Text)
csnComponentStepName
= lens _csnComponentStepName
(\ s a -> s{_csnComponentStepName = a})
csnPortion :: Lens' CounterStructuredName (Maybe CounterStructuredNamePortion)
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})
csnOriginalRequestingStepName :: Lens' CounterStructuredName (Maybe Text)
csnOriginalRequestingStepName
= lens _csnOriginalRequestingStepName
(\ s a -> s{_csnOriginalRequestingStepName = a})
csnInputIndex :: Lens' CounterStructuredName (Maybe Int32)
csnInputIndex
= lens _csnInputIndex
(\ s a -> s{_csnInputIndex = a})
. mapping _Coerce
csnWorkerId :: Lens' CounterStructuredName (Maybe Text)
csnWorkerId
= lens _csnWorkerId (\ s a -> s{_csnWorkerId = a})
instance FromJSON CounterStructuredName where
parseJSON
= withObject "CounterStructuredName"
(\ o ->
CounterStructuredName' <$>
(o .:? "origin") <*> (o .:? "originNamespace") <*>
(o .:? "componentStepName")
<*> (o .:? "portion")
<*> (o .:? "originalStepName")
<*> (o .:? "name")
<*> (o .:? "executionStepName")
<*> (o .:? "originalRequestingStepName")
<*> (o .:? "inputIndex")
<*> (o .:? "workerId"))
instance ToJSON CounterStructuredName where
toJSON CounterStructuredName'{..}
= object
(catMaybes
[("origin" .=) <$> _csnOrigin,
("originNamespace" .=) <$> _csnOriginNamespace,
("componentStepName" .=) <$> _csnComponentStepName,
("portion" .=) <$> _csnPortion,
("originalStepName" .=) <$> _csnOriginalStepName,
("name" .=) <$> _csnName,
("executionStepName" .=) <$> _csnExecutionStepName,
("originalRequestingStepName" .=) <$>
_csnOriginalRequestingStepName,
("inputIndex" .=) <$> _csnInputIndex,
("workerId" .=) <$> _csnWorkerId])
data JobMetadata = JobMetadata'
{ _jmSpannerDetails :: !(Maybe [SpannerIODetails])
, _jmBigTableDetails :: !(Maybe [BigTableIODetails])
, _jmSdkVersion :: !(Maybe SdkVersion)
, _jmPubsubDetails :: !(Maybe [PubSubIODetails])
, _jmFileDetails :: !(Maybe [FileIODetails])
, _jmBigQueryDetails :: !(Maybe [BigQueryIODetails])
, _jmDatastoreDetails :: !(Maybe [DatastoreIODetails])
} deriving (Eq,Show,Data,Typeable,Generic)
jobMetadata
:: JobMetadata
jobMetadata =
JobMetadata'
{ _jmSpannerDetails = Nothing
, _jmBigTableDetails = Nothing
, _jmSdkVersion = Nothing
, _jmPubsubDetails = Nothing
, _jmFileDetails = Nothing
, _jmBigQueryDetails = Nothing
, _jmDatastoreDetails = Nothing
}
jmSpannerDetails :: Lens' JobMetadata [SpannerIODetails]
jmSpannerDetails
= lens _jmSpannerDetails
(\ s a -> s{_jmSpannerDetails = a})
. _Default
. _Coerce
jmBigTableDetails :: Lens' JobMetadata [BigTableIODetails]
jmBigTableDetails
= lens _jmBigTableDetails
(\ s a -> s{_jmBigTableDetails = a})
. _Default
. _Coerce
jmSdkVersion :: Lens' JobMetadata (Maybe SdkVersion)
jmSdkVersion
= lens _jmSdkVersion (\ s a -> s{_jmSdkVersion = a})
jmPubsubDetails :: Lens' JobMetadata [PubSubIODetails]
jmPubsubDetails
= lens _jmPubsubDetails
(\ s a -> s{_jmPubsubDetails = a})
. _Default
. _Coerce
jmFileDetails :: Lens' JobMetadata [FileIODetails]
jmFileDetails
= lens _jmFileDetails
(\ s a -> s{_jmFileDetails = a})
. _Default
. _Coerce
jmBigQueryDetails :: Lens' JobMetadata [BigQueryIODetails]
jmBigQueryDetails
= lens _jmBigQueryDetails
(\ s a -> s{_jmBigQueryDetails = a})
. _Default
. _Coerce
jmDatastoreDetails :: Lens' JobMetadata [DatastoreIODetails]
jmDatastoreDetails
= lens _jmDatastoreDetails
(\ s a -> s{_jmDatastoreDetails = a})
. _Default
. _Coerce
instance FromJSON JobMetadata where
parseJSON
= withObject "JobMetadata"
(\ o ->
JobMetadata' <$>
(o .:? "spannerDetails" .!= mempty) <*>
(o .:? "bigTableDetails" .!= mempty)
<*> (o .:? "sdkVersion")
<*> (o .:? "pubsubDetails" .!= mempty)
<*> (o .:? "fileDetails" .!= mempty)
<*> (o .:? "bigqueryDetails" .!= mempty)
<*> (o .:? "datastoreDetails" .!= mempty))
instance ToJSON JobMetadata where
toJSON JobMetadata'{..}
= object
(catMaybes
[("spannerDetails" .=) <$> _jmSpannerDetails,
("bigTableDetails" .=) <$> _jmBigTableDetails,
("sdkVersion" .=) <$> _jmSdkVersion,
("pubsubDetails" .=) <$> _jmPubsubDetails,
("fileDetails" .=) <$> _jmFileDetails,
("bigqueryDetails" .=) <$> _jmBigQueryDetails,
("datastoreDetails" .=) <$> _jmDatastoreDetails])
data GetTemplateResponse = GetTemplateResponse'
{ _gtrStatus :: !(Maybe Status)
, _gtrMetadata :: !(Maybe TemplateMetadata)
} deriving (Eq,Show,Data,Typeable,Generic)
getTemplateResponse
:: GetTemplateResponse
getTemplateResponse =
GetTemplateResponse'
{ _gtrStatus = Nothing
, _gtrMetadata = Nothing
}
gtrStatus :: Lens' GetTemplateResponse (Maybe Status)
gtrStatus
= lens _gtrStatus (\ s a -> s{_gtrStatus = a})
gtrMetadata :: Lens' GetTemplateResponse (Maybe TemplateMetadata)
gtrMetadata
= lens _gtrMetadata (\ s a -> s{_gtrMetadata = a})
instance FromJSON GetTemplateResponse where
parseJSON
= withObject "GetTemplateResponse"
(\ o ->
GetTemplateResponse' <$>
(o .:? "status") <*> (o .:? "metadata"))
instance ToJSON GetTemplateResponse where
toJSON GetTemplateResponse'{..}
= object
(catMaybes
[("status" .=) <$> _gtrStatus,
("metadata" .=) <$> _gtrMetadata])
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)
, _muDistribution :: !(Maybe JSONValue)
, _muCumulative :: !(Maybe Bool)
, _muKind :: !(Maybe Text)
, _muGauge :: !(Maybe JSONValue)
, _muUpdateTime :: !(Maybe DateTime')
, _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
, _muDistribution = Nothing
, _muCumulative = Nothing
, _muKind = Nothing
, _muGauge = 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})
muDistribution :: Lens' MetricUpdate (Maybe JSONValue)
muDistribution
= lens _muDistribution
(\ s a -> s{_muDistribution = 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})
muGauge :: Lens' MetricUpdate (Maybe JSONValue)
muGauge = lens _muGauge (\ s a -> s{_muGauge = a})
muUpdateTime :: Lens' MetricUpdate (Maybe UTCTime)
muUpdateTime
= lens _muUpdateTime (\ s a -> s{_muUpdateTime = a})
. mapping _DateTime
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 .:? "distribution")
<*> (o .:? "cumulative")
<*> (o .:? "kind")
<*> (o .:? "gauge")
<*> (o .:? "updateTime")
<*> (o .:? "meanCount")
<*> (o .:? "name")
<*> (o .:? "scalar"))
instance ToJSON MetricUpdate where
toJSON MetricUpdate'{..}
= object
(catMaybes
[("meanSum" .=) <$> _muMeanSum,
("internal" .=) <$> _muInternal,
("set" .=) <$> _muSet,
("distribution" .=) <$> _muDistribution,
("cumulative" .=) <$> _muCumulative,
("kind" .=) <$> _muKind, ("gauge" .=) <$> _muGauge,
("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 TemplateMetadata = TemplateMetadata'
{ _tmName :: !(Maybe Text)
, _tmParameters :: !(Maybe [ParameterMetadata])
, _tmDescription :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
templateMetadata
:: TemplateMetadata
templateMetadata =
TemplateMetadata'
{ _tmName = Nothing
, _tmParameters = Nothing
, _tmDescription = Nothing
}
tmName :: Lens' TemplateMetadata (Maybe Text)
tmName = lens _tmName (\ s a -> s{_tmName = a})
tmParameters :: Lens' TemplateMetadata [ParameterMetadata]
tmParameters
= lens _tmParameters (\ s a -> s{_tmParameters = a})
. _Default
. _Coerce
tmDescription :: Lens' TemplateMetadata (Maybe Text)
tmDescription
= lens _tmDescription
(\ s a -> s{_tmDescription = a})
instance FromJSON TemplateMetadata where
parseJSON
= withObject "TemplateMetadata"
(\ o ->
TemplateMetadata' <$>
(o .:? "name") <*> (o .:? "parameters" .!= mempty)
<*> (o .:? "description"))
instance ToJSON TemplateMetadata where
toJSON TemplateMetadata'{..}
= object
(catMaybes
[("name" .=) <$> _tmName,
("parameters" .=) <$> _tmParameters,
("description" .=) <$> _tmDescription])
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))
, _cuIntegerGauge :: !(Maybe IntegerGauge)
, _cuDistribution :: !(Maybe DistributionUpdate)
, _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
, _cuIntegerGauge = Nothing
, _cuDistribution = 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
cuIntegerGauge :: Lens' CounterUpdate (Maybe IntegerGauge)
cuIntegerGauge
= lens _cuIntegerGauge
(\ s a -> s{_cuIntegerGauge = a})
cuDistribution :: Lens' CounterUpdate (Maybe DistributionUpdate)
cuDistribution
= lens _cuDistribution
(\ s a -> s{_cuDistribution = a})
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 .:? "integerGauge")
<*> (o .:? "distribution")
<*> (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,
("integerGauge" .=) <$> _cuIntegerGauge,
("distribution" .=) <$> _cuDistribution,
("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 DerivedSourceDerivationMode)
, _dsSource :: !(Maybe Source)
} deriving (Eq,Show,Data,Typeable,Generic)
derivedSource
:: DerivedSource
derivedSource =
DerivedSource'
{ _dsDerivationMode = Nothing
, _dsSource = Nothing
}
dsDerivationMode :: Lens' DerivedSource (Maybe DerivedSourceDerivationMode)
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 DateTime')
} 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 UTCTime)
jmMetricTime
= lens _jmMetricTime (\ s a -> s{_jmMetricTime = a})
. mapping _DateTime
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'
{ _sdcrLocation :: !(Maybe Text)
, _sdcrData :: !(Maybe Text)
, _sdcrComponentId :: !(Maybe Text)
, _sdcrWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
sendDebugCaptureRequest
:: SendDebugCaptureRequest
sendDebugCaptureRequest =
SendDebugCaptureRequest'
{ _sdcrLocation = Nothing
, _sdcrData = Nothing
, _sdcrComponentId = Nothing
, _sdcrWorkerId = Nothing
}
sdcrLocation :: Lens' SendDebugCaptureRequest (Maybe Text)
sdcrLocation
= lens _sdcrLocation (\ s a -> s{_sdcrLocation = a})
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 .:? "location") <*> (o .:? "data") <*>
(o .:? "componentId")
<*> (o .:? "workerId"))
instance ToJSON SendDebugCaptureRequest where
toJSON SendDebugCaptureRequest'{..}
= object
(catMaybes
[("location" .=) <$> _sdcrLocation,
("data" .=) <$> _sdcrData,
("componentId" .=) <$> _sdcrComponentId,
("workerId" .=) <$> _sdcrWorkerId])
data WorkItemStatus = WorkItemStatus'
{ _wisReportedProgress :: !(Maybe ApproximateReportedProgress)
, _wisProgress :: !(Maybe ApproximateProgress)
, _wisTotalThrottlerWaitTimeSeconds :: !(Maybe (Textual Double))
, _wisSourceOperationResponse :: !(Maybe SourceOperationResponse)
, _wisStopPosition :: !(Maybe Position)
, _wisDynamicSourceSplit :: !(Maybe DynamicSourceSplit)
, _wisCompleted :: !(Maybe Bool)
, _wisSourceFork :: !(Maybe SourceFork)
, _wisReportIndex :: !(Maybe (Textual Int64))
, _wisRequestedLeaseDuration :: !(Maybe GDuration)
, _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
, _wisTotalThrottlerWaitTimeSeconds = 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})
wisTotalThrottlerWaitTimeSeconds :: Lens' WorkItemStatus (Maybe Double)
wisTotalThrottlerWaitTimeSeconds
= lens _wisTotalThrottlerWaitTimeSeconds
(\ s a -> s{_wisTotalThrottlerWaitTimeSeconds = a})
. mapping _Coerce
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 Scientific)
wisRequestedLeaseDuration
= lens _wisRequestedLeaseDuration
(\ s a -> s{_wisRequestedLeaseDuration = a})
. mapping _GDuration
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 .:? "totalThrottlerWaitTimeSeconds")
<*> (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,
("totalThrottlerWaitTimeSeconds" .=) <$>
_wisTotalThrottlerWaitTimeSeconds,
("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])
data TransformSummary = TransformSummary'
{ _tsDisplayData :: !(Maybe [DisplayData])
, _tsKind :: !(Maybe TransformSummaryKind)
, _tsOutputCollectionName :: !(Maybe [Text])
, _tsInputCollectionName :: !(Maybe [Text])
, _tsName :: !(Maybe Text)
, _tsId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
transformSummary
:: TransformSummary
transformSummary =
TransformSummary'
{ _tsDisplayData = Nothing
, _tsKind = Nothing
, _tsOutputCollectionName = Nothing
, _tsInputCollectionName = Nothing
, _tsName = Nothing
, _tsId = Nothing
}
tsDisplayData :: Lens' TransformSummary [DisplayData]
tsDisplayData
= lens _tsDisplayData
(\ s a -> s{_tsDisplayData = a})
. _Default
. _Coerce
tsKind :: Lens' TransformSummary (Maybe TransformSummaryKind)
tsKind = lens _tsKind (\ s a -> s{_tsKind = a})
tsOutputCollectionName :: Lens' TransformSummary [Text]
tsOutputCollectionName
= lens _tsOutputCollectionName
(\ s a -> s{_tsOutputCollectionName = a})
. _Default
. _Coerce
tsInputCollectionName :: Lens' TransformSummary [Text]
tsInputCollectionName
= lens _tsInputCollectionName
(\ s a -> s{_tsInputCollectionName = a})
. _Default
. _Coerce
tsName :: Lens' TransformSummary (Maybe Text)
tsName = lens _tsName (\ s a -> s{_tsName = a})
tsId :: Lens' TransformSummary (Maybe Text)
tsId = lens _tsId (\ s a -> s{_tsId = a})
instance FromJSON TransformSummary where
parseJSON
= withObject "TransformSummary"
(\ o ->
TransformSummary' <$>
(o .:? "displayData" .!= mempty) <*> (o .:? "kind")
<*> (o .:? "outputCollectionName" .!= mempty)
<*> (o .:? "inputCollectionName" .!= mempty)
<*> (o .:? "name")
<*> (o .:? "id"))
instance ToJSON TransformSummary where
toJSON TransformSummary'{..}
= object
(catMaybes
[("displayData" .=) <$> _tsDisplayData,
("kind" .=) <$> _tsKind,
("outputCollectionName" .=) <$>
_tsOutputCollectionName,
("inputCollectionName" .=) <$>
_tsInputCollectionName,
("name" .=) <$> _tsName, ("id" .=) <$> _tsId])
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 CPUTime = CPUTime'
{ _ctTotalMs :: !(Maybe (Textual Word64))
, _ctRate :: !(Maybe (Textual Double))
, _ctTimestamp :: !(Maybe DateTime')
} deriving (Eq,Show,Data,Typeable,Generic)
cpuTime
:: CPUTime
cpuTime =
CPUTime'
{ _ctTotalMs = Nothing
, _ctRate = Nothing
, _ctTimestamp = Nothing
}
ctTotalMs :: Lens' CPUTime (Maybe Word64)
ctTotalMs
= lens _ctTotalMs (\ s a -> s{_ctTotalMs = a}) .
mapping _Coerce
ctRate :: Lens' CPUTime (Maybe Double)
ctRate
= lens _ctRate (\ s a -> s{_ctRate = a}) .
mapping _Coerce
ctTimestamp :: Lens' CPUTime (Maybe UTCTime)
ctTimestamp
= lens _ctTimestamp (\ s a -> s{_ctTimestamp = a}) .
mapping _DateTime
instance FromJSON CPUTime where
parseJSON
= withObject "CPUTime"
(\ o ->
CPUTime' <$>
(o .:? "totalMs") <*> (o .:? "rate") <*>
(o .:? "timestamp"))
instance ToJSON CPUTime where
toJSON CPUTime'{..}
= object
(catMaybes
[("totalMs" .=) <$> _ctTotalMs,
("rate" .=) <$> _ctRate,
("timestamp" .=) <$> _ctTimestamp])
data LeaseWorkItemRequest = LeaseWorkItemRequest'
{ _lwirWorkItemTypes :: !(Maybe [Text])
, _lwirCurrentWorkerTime :: !(Maybe DateTime')
, _lwirLocation :: !(Maybe Text)
, _lwirWorkerCapabilities :: !(Maybe [Text])
, _lwirRequestedLeaseDuration :: !(Maybe GDuration)
, _lwirWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
leaseWorkItemRequest
:: LeaseWorkItemRequest
leaseWorkItemRequest =
LeaseWorkItemRequest'
{ _lwirWorkItemTypes = Nothing
, _lwirCurrentWorkerTime = Nothing
, _lwirLocation = 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 UTCTime)
lwirCurrentWorkerTime
= lens _lwirCurrentWorkerTime
(\ s a -> s{_lwirCurrentWorkerTime = a})
. mapping _DateTime
lwirLocation :: Lens' LeaseWorkItemRequest (Maybe Text)
lwirLocation
= lens _lwirLocation (\ s a -> s{_lwirLocation = a})
lwirWorkerCapabilities :: Lens' LeaseWorkItemRequest [Text]
lwirWorkerCapabilities
= lens _lwirWorkerCapabilities
(\ s a -> s{_lwirWorkerCapabilities = a})
. _Default
. _Coerce
lwirRequestedLeaseDuration :: Lens' LeaseWorkItemRequest (Maybe Scientific)
lwirRequestedLeaseDuration
= lens _lwirRequestedLeaseDuration
(\ s a -> s{_lwirRequestedLeaseDuration = a})
. mapping _GDuration
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 .:? "location")
<*> (o .:? "workerCapabilities" .!= mempty)
<*> (o .:? "requestedLeaseDuration")
<*> (o .:? "workerId"))
instance ToJSON LeaseWorkItemRequest where
toJSON LeaseWorkItemRequest'{..}
= object
(catMaybes
[("workItemTypes" .=) <$> _lwirWorkItemTypes,
("currentWorkerTime" .=) <$> _lwirCurrentWorkerTime,
("location" .=) <$> _lwirLocation,
("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])
data DatastoreIODetails = DatastoreIODetails'
{ _diodNamespace :: !(Maybe Text)
, _diodProjectId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
datastoreIODetails
:: DatastoreIODetails
datastoreIODetails =
DatastoreIODetails'
{ _diodNamespace = Nothing
, _diodProjectId = Nothing
}
diodNamespace :: Lens' DatastoreIODetails (Maybe Text)
diodNamespace
= lens _diodNamespace
(\ s a -> s{_diodNamespace = a})
diodProjectId :: Lens' DatastoreIODetails (Maybe Text)
diodProjectId
= lens _diodProjectId
(\ s a -> s{_diodProjectId = a})
instance FromJSON DatastoreIODetails where
parseJSON
= withObject "DatastoreIODetails"
(\ o ->
DatastoreIODetails' <$>
(o .:? "namespace") <*> (o .:? "projectId"))
instance ToJSON DatastoreIODetails where
toJSON DatastoreIODetails'{..}
= object
(catMaybes
[("namespace" .=) <$> _diodNamespace,
("projectId" .=) <$> _diodProjectId])
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))
, _asrFractionOfRemainder :: !(Maybe (Textual Double))
, _asrPosition :: !(Maybe Position)
} deriving (Eq,Show,Data,Typeable,Generic)
approximateSplitRequest
:: ApproximateSplitRequest
approximateSplitRequest =
ApproximateSplitRequest'
{ _asrFractionConsumed = Nothing
, _asrFractionOfRemainder = Nothing
, _asrPosition = Nothing
}
asrFractionConsumed :: Lens' ApproximateSplitRequest (Maybe Double)
asrFractionConsumed
= lens _asrFractionConsumed
(\ s a -> s{_asrFractionConsumed = a})
. mapping _Coerce
asrFractionOfRemainder :: Lens' ApproximateSplitRequest (Maybe Double)
asrFractionOfRemainder
= lens _asrFractionOfRemainder
(\ s a -> s{_asrFractionOfRemainder = 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 .:? "fractionOfRemainder")
<*> (o .:? "position"))
instance ToJSON ApproximateSplitRequest where
toJSON ApproximateSplitRequest'{..}
= object
(catMaybes
[("fractionConsumed" .=) <$> _asrFractionConsumed,
("fractionOfRemainder" .=) <$>
_asrFractionOfRemainder,
("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])
data SdkVersion = SdkVersion'
{ _svSdkSupportStatus :: !(Maybe SdkVersionSdkSupportStatus)
, _svVersionDisplayName :: !(Maybe Text)
, _svVersion :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
sdkVersion
:: SdkVersion
sdkVersion =
SdkVersion'
{ _svSdkSupportStatus = Nothing
, _svVersionDisplayName = Nothing
, _svVersion = Nothing
}
svSdkSupportStatus :: Lens' SdkVersion (Maybe SdkVersionSdkSupportStatus)
svSdkSupportStatus
= lens _svSdkSupportStatus
(\ s a -> s{_svSdkSupportStatus = a})
svVersionDisplayName :: Lens' SdkVersion (Maybe Text)
svVersionDisplayName
= lens _svVersionDisplayName
(\ s a -> s{_svVersionDisplayName = a})
svVersion :: Lens' SdkVersion (Maybe Text)
svVersion
= lens _svVersion (\ s a -> s{_svVersion = a})
instance FromJSON SdkVersion where
parseJSON
= withObject "SdkVersion"
(\ o ->
SdkVersion' <$>
(o .:? "sdkSupportStatus") <*>
(o .:? "versionDisplayName")
<*> (o .:? "version"))
instance ToJSON SdkVersion where
toJSON SdkVersion'{..}
= object
(catMaybes
[("sdkSupportStatus" .=) <$> _svSdkSupportStatus,
("versionDisplayName" .=) <$> _svVersionDisplayName,
("version" .=) <$> _svVersion])
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 ResourceUtilizationReport = ResourceUtilizationReport'
{ _rurCPUTime :: Maybe [CPUTime]
} deriving (Eq,Show,Data,Typeable,Generic)
resourceUtilizationReport
:: ResourceUtilizationReport
resourceUtilizationReport =
ResourceUtilizationReport'
{ _rurCPUTime = Nothing
}
rurCPUTime :: Lens' ResourceUtilizationReport [CPUTime]
rurCPUTime
= lens _rurCPUTime (\ s a -> s{_rurCPUTime = a}) .
_Default
. _Coerce
instance FromJSON ResourceUtilizationReport where
parseJSON
= withObject "ResourceUtilizationReport"
(\ o ->
ResourceUtilizationReport' <$>
(o .:? "cpuTime" .!= mempty))
instance ToJSON ResourceUtilizationReport where
toJSON ResourceUtilizationReport'{..}
= object (catMaybes [("cpuTime" .=) <$> _rurCPUTime])
newtype FailedLocation = FailedLocation'
{ _flName :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
failedLocation
:: FailedLocation
failedLocation =
FailedLocation'
{ _flName = Nothing
}
flName :: Lens' FailedLocation (Maybe Text)
flName = lens _flName (\ s a -> s{_flName = a})
instance FromJSON FailedLocation where
parseJSON
= withObject "FailedLocation"
(\ o -> FailedLocation' <$> (o .:? "name"))
instance ToJSON FailedLocation where
toJSON FailedLocation'{..}
= object (catMaybes [("name" .=) <$> _flName])
data WorkerMessageResponse = WorkerMessageResponse'
{ _wmrWorkerHealthReportResponse :: !(Maybe WorkerHealthReportResponse)
, _wmrWorkerMetricsResponse :: !(Maybe ResourceUtilizationReportResponse)
, _wmrWorkerShutdownNoticeResponse :: !(Maybe WorkerShutdownNoticeResponse)
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessageResponse
:: WorkerMessageResponse
workerMessageResponse =
WorkerMessageResponse'
{ _wmrWorkerHealthReportResponse = Nothing
, _wmrWorkerMetricsResponse = Nothing
, _wmrWorkerShutdownNoticeResponse = Nothing
}
wmrWorkerHealthReportResponse :: Lens' WorkerMessageResponse (Maybe WorkerHealthReportResponse)
wmrWorkerHealthReportResponse
= lens _wmrWorkerHealthReportResponse
(\ s a -> s{_wmrWorkerHealthReportResponse = a})
wmrWorkerMetricsResponse :: Lens' WorkerMessageResponse (Maybe ResourceUtilizationReportResponse)
wmrWorkerMetricsResponse
= lens _wmrWorkerMetricsResponse
(\ s a -> s{_wmrWorkerMetricsResponse = a})
wmrWorkerShutdownNoticeResponse :: Lens' WorkerMessageResponse (Maybe WorkerShutdownNoticeResponse)
wmrWorkerShutdownNoticeResponse
= lens _wmrWorkerShutdownNoticeResponse
(\ s a -> s{_wmrWorkerShutdownNoticeResponse = a})
instance FromJSON WorkerMessageResponse where
parseJSON
= withObject "WorkerMessageResponse"
(\ o ->
WorkerMessageResponse' <$>
(o .:? "workerHealthReportResponse") <*>
(o .:? "workerMetricsResponse")
<*> (o .:? "workerShutdownNoticeResponse"))
instance ToJSON WorkerMessageResponse where
toJSON WorkerMessageResponse'{..}
= object
(catMaybes
[("workerHealthReportResponse" .=) <$>
_wmrWorkerHealthReportResponse,
("workerMetricsResponse" .=) <$>
_wmrWorkerMetricsResponse,
("workerShutdownNoticeResponse" .=) <$>
_wmrWorkerShutdownNoticeResponse])
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 BigTableIODetails = BigTableIODetails'
{ _btiodInstanceId :: !(Maybe Text)
, _btiodProjectId :: !(Maybe Text)
, _btiodTableId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
bigTableIODetails
:: BigTableIODetails
bigTableIODetails =
BigTableIODetails'
{ _btiodInstanceId = Nothing
, _btiodProjectId = Nothing
, _btiodTableId = Nothing
}
btiodInstanceId :: Lens' BigTableIODetails (Maybe Text)
btiodInstanceId
= lens _btiodInstanceId
(\ s a -> s{_btiodInstanceId = a})
btiodProjectId :: Lens' BigTableIODetails (Maybe Text)
btiodProjectId
= lens _btiodProjectId
(\ s a -> s{_btiodProjectId = a})
btiodTableId :: Lens' BigTableIODetails (Maybe Text)
btiodTableId
= lens _btiodTableId (\ s a -> s{_btiodTableId = a})
instance FromJSON BigTableIODetails where
parseJSON
= withObject "BigTableIODetails"
(\ o ->
BigTableIODetails' <$>
(o .:? "instanceId") <*> (o .:? "projectId") <*>
(o .:? "tableId"))
instance ToJSON BigTableIODetails where
toJSON BigTableIODetails'{..}
= object
(catMaybes
[("instanceId" .=) <$> _btiodInstanceId,
("projectId" .=) <$> _btiodProjectId,
("tableId" .=) <$> _btiodTableId])
data WorkItemServiceState = WorkItemServiceState'
{ _wissNextReportIndex :: !(Maybe (Textual Int64))
, _wissReportStatusInterval :: !(Maybe GDuration)
, _wissHarnessData :: !(Maybe WorkItemServiceStateHarnessData)
, _wissSuggestedStopPoint :: !(Maybe ApproximateProgress)
, _wissSuggestedStopPosition :: !(Maybe Position)
, _wissLeaseExpireTime :: !(Maybe DateTime')
, _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 Scientific)
wissReportStatusInterval
= lens _wissReportStatusInterval
(\ s a -> s{_wissReportStatusInterval = a})
. mapping _GDuration
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 UTCTime)
wissLeaseExpireTime
= lens _wissLeaseExpireTime
(\ s a -> s{_wissLeaseExpireTime = a})
. mapping _DateTime
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])
newtype LaunchTemplateResponse = LaunchTemplateResponse'
{ _ltrJob :: Maybe Job
} deriving (Eq,Show,Data,Typeable,Generic)
launchTemplateResponse
:: LaunchTemplateResponse
launchTemplateResponse =
LaunchTemplateResponse'
{ _ltrJob = Nothing
}
ltrJob :: Lens' LaunchTemplateResponse (Maybe Job)
ltrJob = lens _ltrJob (\ s a -> s{_ltrJob = a})
instance FromJSON LaunchTemplateResponse where
parseJSON
= withObject "LaunchTemplateResponse"
(\ o -> LaunchTemplateResponse' <$> (o .:? "job"))
instance ToJSON LaunchTemplateResponse where
toJSON LaunchTemplateResponse'{..}
= object (catMaybes [("job" .=) <$> _ltrJob])
data StreamingSetupTask = StreamingSetupTask'
{ _sstStreamingComputationTopology :: !(Maybe TopologyConfig)
, _sstReceiveWorkPort :: !(Maybe (Textual Int32))
, _sstWorkerHarnessPort :: !(Maybe (Textual Int32))
, _sstDrain :: !(Maybe Bool)
, _sstSnapshotConfig :: !(Maybe StreamingApplianceSnapshotConfig)
} deriving (Eq,Show,Data,Typeable,Generic)
streamingSetupTask
:: StreamingSetupTask
streamingSetupTask =
StreamingSetupTask'
{ _sstStreamingComputationTopology = Nothing
, _sstReceiveWorkPort = Nothing
, _sstWorkerHarnessPort = Nothing
, _sstDrain = Nothing
, _sstSnapshotConfig = 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})
sstSnapshotConfig :: Lens' StreamingSetupTask (Maybe StreamingApplianceSnapshotConfig)
sstSnapshotConfig
= lens _sstSnapshotConfig
(\ s a -> s{_sstSnapshotConfig = a})
instance FromJSON StreamingSetupTask where
parseJSON
= withObject "StreamingSetupTask"
(\ o ->
StreamingSetupTask' <$>
(o .:? "streamingComputationTopology") <*>
(o .:? "receiveWorkPort")
<*> (o .:? "workerHarnessPort")
<*> (o .:? "drain")
<*> (o .:? "snapshotConfig"))
instance ToJSON StreamingSetupTask where
toJSON StreamingSetupTask'{..}
= object
(catMaybes
[("streamingComputationTopology" .=) <$>
_sstStreamingComputationTopology,
("receiveWorkPort" .=) <$> _sstReceiveWorkPort,
("workerHarnessPort" .=) <$> _sstWorkerHarnessPort,
("drain" .=) <$> _sstDrain,
("snapshotConfig" .=) <$> _sstSnapshotConfig])
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])
, _mtCounterPrefix :: !(Maybe Text)
, _mtSystemName :: !(Maybe Text)
, _mtStageName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
mapTask
:: MapTask
mapTask =
MapTask'
{ _mtInstructions = Nothing
, _mtCounterPrefix = Nothing
, _mtSystemName = Nothing
, _mtStageName = Nothing
}
mtInstructions :: Lens' MapTask [ParallelInstruction]
mtInstructions
= lens _mtInstructions
(\ s a -> s{_mtInstructions = a})
. _Default
. _Coerce
mtCounterPrefix :: Lens' MapTask (Maybe Text)
mtCounterPrefix
= lens _mtCounterPrefix
(\ s a -> s{_mtCounterPrefix = a})
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 .:? "counterPrefix")
<*> (o .:? "systemName")
<*> (o .:? "stageName"))
instance ToJSON MapTask where
toJSON MapTask'{..}
= object
(catMaybes
[("instructions" .=) <$> _mtInstructions,
("counterPrefix" .=) <$> _mtCounterPrefix,
("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 WorkerLifecycleEventMetadata = WorkerLifecycleEventMetadata'
{ _wlemAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
workerLifecycleEventMetadata
:: HashMap Text Text
-> WorkerLifecycleEventMetadata
workerLifecycleEventMetadata pWlemAddtional_ =
WorkerLifecycleEventMetadata'
{ _wlemAddtional = _Coerce # pWlemAddtional_
}
wlemAddtional :: Lens' WorkerLifecycleEventMetadata (HashMap Text Text)
wlemAddtional
= lens _wlemAddtional
(\ s a -> s{_wlemAddtional = a})
. _Coerce
instance FromJSON WorkerLifecycleEventMetadata where
parseJSON
= withObject "WorkerLifecycleEventMetadata"
(\ o ->
WorkerLifecycleEventMetadata' <$>
(parseJSONObject o))
instance ToJSON WorkerLifecycleEventMetadata where
toJSON = toJSON . _wlemAddtional
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 RuntimeEnvironment = RuntimeEnvironment'
{ _reNumWorkers :: !(Maybe (Textual Int32))
, _reNetwork :: !(Maybe Text)
, _reZone :: !(Maybe Text)
, _reBypassTempDirValidation :: !(Maybe Bool)
, _reSubnetwork :: !(Maybe Text)
, _reMachineType :: !(Maybe Text)
, _reAdditionalUserLabels :: !(Maybe RuntimeEnvironmentAdditionalUserLabels)
, _reServiceAccountEmail :: !(Maybe Text)
, _reAdditionalExperiments :: !(Maybe [Text])
, _reMaxWorkers :: !(Maybe (Textual Int32))
, _reTempLocation :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
runtimeEnvironment
:: RuntimeEnvironment
runtimeEnvironment =
RuntimeEnvironment'
{ _reNumWorkers = Nothing
, _reNetwork = Nothing
, _reZone = Nothing
, _reBypassTempDirValidation = Nothing
, _reSubnetwork = Nothing
, _reMachineType = Nothing
, _reAdditionalUserLabels = Nothing
, _reServiceAccountEmail = Nothing
, _reAdditionalExperiments = Nothing
, _reMaxWorkers = Nothing
, _reTempLocation = Nothing
}
reNumWorkers :: Lens' RuntimeEnvironment (Maybe Int32)
reNumWorkers
= lens _reNumWorkers (\ s a -> s{_reNumWorkers = a})
. mapping _Coerce
reNetwork :: Lens' RuntimeEnvironment (Maybe Text)
reNetwork
= lens _reNetwork (\ s a -> s{_reNetwork = a})
reZone :: Lens' RuntimeEnvironment (Maybe Text)
reZone = lens _reZone (\ s a -> s{_reZone = a})
reBypassTempDirValidation :: Lens' RuntimeEnvironment (Maybe Bool)
reBypassTempDirValidation
= lens _reBypassTempDirValidation
(\ s a -> s{_reBypassTempDirValidation = a})
reSubnetwork :: Lens' RuntimeEnvironment (Maybe Text)
reSubnetwork
= lens _reSubnetwork (\ s a -> s{_reSubnetwork = a})
reMachineType :: Lens' RuntimeEnvironment (Maybe Text)
reMachineType
= lens _reMachineType
(\ s a -> s{_reMachineType = a})
reAdditionalUserLabels :: Lens' RuntimeEnvironment (Maybe RuntimeEnvironmentAdditionalUserLabels)
reAdditionalUserLabels
= lens _reAdditionalUserLabels
(\ s a -> s{_reAdditionalUserLabels = a})
reServiceAccountEmail :: Lens' RuntimeEnvironment (Maybe Text)
reServiceAccountEmail
= lens _reServiceAccountEmail
(\ s a -> s{_reServiceAccountEmail = a})
reAdditionalExperiments :: Lens' RuntimeEnvironment [Text]
reAdditionalExperiments
= lens _reAdditionalExperiments
(\ s a -> s{_reAdditionalExperiments = a})
. _Default
. _Coerce
reMaxWorkers :: Lens' RuntimeEnvironment (Maybe Int32)
reMaxWorkers
= lens _reMaxWorkers (\ s a -> s{_reMaxWorkers = a})
. mapping _Coerce
reTempLocation :: Lens' RuntimeEnvironment (Maybe Text)
reTempLocation
= lens _reTempLocation
(\ s a -> s{_reTempLocation = a})
instance FromJSON RuntimeEnvironment where
parseJSON
= withObject "RuntimeEnvironment"
(\ o ->
RuntimeEnvironment' <$>
(o .:? "numWorkers") <*> (o .:? "network") <*>
(o .:? "zone")
<*> (o .:? "bypassTempDirValidation")
<*> (o .:? "subnetwork")
<*> (o .:? "machineType")
<*> (o .:? "additionalUserLabels")
<*> (o .:? "serviceAccountEmail")
<*> (o .:? "additionalExperiments" .!= mempty)
<*> (o .:? "maxWorkers")
<*> (o .:? "tempLocation"))
instance ToJSON RuntimeEnvironment where
toJSON RuntimeEnvironment'{..}
= object
(catMaybes
[("numWorkers" .=) <$> _reNumWorkers,
("network" .=) <$> _reNetwork,
("zone" .=) <$> _reZone,
("bypassTempDirValidation" .=) <$>
_reBypassTempDirValidation,
("subnetwork" .=) <$> _reSubnetwork,
("machineType" .=) <$> _reMachineType,
("additionalUserLabels" .=) <$>
_reAdditionalUserLabels,
("serviceAccountEmail" .=) <$>
_reServiceAccountEmail,
("additionalExperiments" .=) <$>
_reAdditionalExperiments,
("maxWorkers" .=) <$> _reMaxWorkers,
("tempLocation" .=) <$> _reTempLocation])
data CounterMetadata = CounterMetadata'
{ _cmKind :: !(Maybe CounterMetadataKind)
, _cmDescription :: !(Maybe Text)
, _cmStandardUnits :: !(Maybe CounterMetadataStandardUnits)
, _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 CounterMetadataKind)
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 CounterMetadataStandardUnits)
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'
{ _gdcrLocation :: !(Maybe Text)
, _gdcrComponentId :: !(Maybe Text)
, _gdcrWorkerId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
getDebugConfigRequest
:: GetDebugConfigRequest
getDebugConfigRequest =
GetDebugConfigRequest'
{ _gdcrLocation = Nothing
, _gdcrComponentId = Nothing
, _gdcrWorkerId = Nothing
}
gdcrLocation :: Lens' GetDebugConfigRequest (Maybe Text)
gdcrLocation
= lens _gdcrLocation (\ s a -> s{_gdcrLocation = a})
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 .:? "location") <*> (o .:? "componentId") <*>
(o .:? "workerId"))
instance ToJSON GetDebugConfigRequest where
toJSON GetDebugConfigRequest'{..}
= object
(catMaybes
[("location" .=) <$> _gdcrLocation,
("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])
newtype WorkerShutdownNotice = WorkerShutdownNotice'
{ _wsnReason :: Maybe Text
} deriving (Eq,Show,Data,Typeable,Generic)
workerShutdownNotice
:: WorkerShutdownNotice
workerShutdownNotice =
WorkerShutdownNotice'
{ _wsnReason = Nothing
}
wsnReason :: Lens' WorkerShutdownNotice (Maybe Text)
wsnReason
= lens _wsnReason (\ s a -> s{_wsnReason = a})
instance FromJSON WorkerShutdownNotice where
parseJSON
= withObject "WorkerShutdownNotice"
(\ o -> WorkerShutdownNotice' <$> (o .:? "reason"))
instance ToJSON WorkerShutdownNotice where
toJSON WorkerShutdownNotice'{..}
= object (catMaybes [("reason" .=) <$> _wsnReason])
data StreamingComputationTask = StreamingComputationTask'
{ _sctTaskType :: !(Maybe StreamingComputationTaskTaskType)
, _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 StreamingComputationTaskTaskType)
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 PipelineDescription = PipelineDescription'
{ _pdExecutionPipelineStage :: !(Maybe [ExecutionStageSummary])
, _pdDisplayData :: !(Maybe [DisplayData])
, _pdOriginalPipelineTransform :: !(Maybe [TransformSummary])
} deriving (Eq,Show,Data,Typeable,Generic)
pipelineDescription
:: PipelineDescription
pipelineDescription =
PipelineDescription'
{ _pdExecutionPipelineStage = Nothing
, _pdDisplayData = Nothing
, _pdOriginalPipelineTransform = Nothing
}
pdExecutionPipelineStage :: Lens' PipelineDescription [ExecutionStageSummary]
pdExecutionPipelineStage
= lens _pdExecutionPipelineStage
(\ s a -> s{_pdExecutionPipelineStage = a})
. _Default
. _Coerce
pdDisplayData :: Lens' PipelineDescription [DisplayData]
pdDisplayData
= lens _pdDisplayData
(\ s a -> s{_pdDisplayData = a})
. _Default
. _Coerce
pdOriginalPipelineTransform :: Lens' PipelineDescription [TransformSummary]
pdOriginalPipelineTransform
= lens _pdOriginalPipelineTransform
(\ s a -> s{_pdOriginalPipelineTransform = a})
. _Default
. _Coerce
instance FromJSON PipelineDescription where
parseJSON
= withObject "PipelineDescription"
(\ o ->
PipelineDescription' <$>
(o .:? "executionPipelineStage" .!= mempty) <*>
(o .:? "displayData" .!= mempty)
<*> (o .:? "originalPipelineTransform" .!= mempty))
instance ToJSON PipelineDescription where
toJSON PipelineDescription'{..}
= object
(catMaybes
[("executionPipelineStage" .=) <$>
_pdExecutionPipelineStage,
("displayData" .=) <$> _pdDisplayData,
("originalPipelineTransform" .=) <$>
_pdOriginalPipelineTransform])
data JobMessage = JobMessage'
{ _jmTime :: !(Maybe DateTime')
, _jmMessageText :: !(Maybe Text)
, _jmMessageImportance :: !(Maybe JobMessageMessageImportance)
, _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 UTCTime)
jmTime
= lens _jmTime (\ s a -> s{_jmTime = a}) .
mapping _DateTime
jmMessageText :: Lens' JobMessage (Maybe Text)
jmMessageText
= lens _jmMessageText
(\ s a -> s{_jmMessageText = a})
jmMessageImportance :: Lens' JobMessage (Maybe JobMessageMessageImportance)
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 WorkerLifecycleEvent = WorkerLifecycleEvent'
{ _wleEvent :: !(Maybe WorkerLifecycleEventEvent)
, _wleContainerStartTime :: !(Maybe DateTime')
, _wleMetadata :: !(Maybe WorkerLifecycleEventMetadata)
} deriving (Eq,Show,Data,Typeable,Generic)
workerLifecycleEvent
:: WorkerLifecycleEvent
workerLifecycleEvent =
WorkerLifecycleEvent'
{ _wleEvent = Nothing
, _wleContainerStartTime = Nothing
, _wleMetadata = Nothing
}
wleEvent :: Lens' WorkerLifecycleEvent (Maybe WorkerLifecycleEventEvent)
wleEvent = lens _wleEvent (\ s a -> s{_wleEvent = a})
wleContainerStartTime :: Lens' WorkerLifecycleEvent (Maybe UTCTime)
wleContainerStartTime
= lens _wleContainerStartTime
(\ s a -> s{_wleContainerStartTime = a})
. mapping _DateTime
wleMetadata :: Lens' WorkerLifecycleEvent (Maybe WorkerLifecycleEventMetadata)
wleMetadata
= lens _wleMetadata (\ s a -> s{_wleMetadata = a})
instance FromJSON WorkerLifecycleEvent where
parseJSON
= withObject "WorkerLifecycleEvent"
(\ o ->
WorkerLifecycleEvent' <$>
(o .:? "event") <*> (o .:? "containerStartTime") <*>
(o .:? "metadata"))
instance ToJSON WorkerLifecycleEvent where
toJSON WorkerLifecycleEvent'{..}
= object
(catMaybes
[("event" .=) <$> _wleEvent,
("containerStartTime" .=) <$> _wleContainerStartTime,
("metadata" .=) <$> _wleMetadata])
newtype RuntimeEnvironmentAdditionalUserLabels = RuntimeEnvironmentAdditionalUserLabels'
{ _reaulAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
runtimeEnvironmentAdditionalUserLabels
:: HashMap Text Text
-> RuntimeEnvironmentAdditionalUserLabels
runtimeEnvironmentAdditionalUserLabels pReaulAddtional_ =
RuntimeEnvironmentAdditionalUserLabels'
{ _reaulAddtional = _Coerce # pReaulAddtional_
}
reaulAddtional :: Lens' RuntimeEnvironmentAdditionalUserLabels (HashMap Text Text)
reaulAddtional
= lens _reaulAddtional
(\ s a -> s{_reaulAddtional = a})
. _Coerce
instance FromJSON
RuntimeEnvironmentAdditionalUserLabels where
parseJSON
= withObject "RuntimeEnvironmentAdditionalUserLabels"
(\ o ->
RuntimeEnvironmentAdditionalUserLabels' <$>
(parseJSONObject o))
instance ToJSON
RuntimeEnvironmentAdditionalUserLabels where
toJSON = toJSON . _reaulAddtional
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])
data PubSubIODetails = PubSubIODetails'
{ _psiodTopic :: !(Maybe Text)
, _psiodSubscription :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
pubSubIODetails
:: PubSubIODetails
pubSubIODetails =
PubSubIODetails'
{ _psiodTopic = Nothing
, _psiodSubscription = Nothing
}
psiodTopic :: Lens' PubSubIODetails (Maybe Text)
psiodTopic
= lens _psiodTopic (\ s a -> s{_psiodTopic = a})
psiodSubscription :: Lens' PubSubIODetails (Maybe Text)
psiodSubscription
= lens _psiodSubscription
(\ s a -> s{_psiodSubscription = a})
instance FromJSON PubSubIODetails where
parseJSON
= withObject "PubSubIODetails"
(\ o ->
PubSubIODetails' <$>
(o .:? "topic") <*> (o .:? "subscription"))
instance ToJSON PubSubIODetails where
toJSON PubSubIODetails'{..}
= object
(catMaybes
[("topic" .=) <$> _psiodTopic,
("subscription" .=) <$> _psiodSubscription])
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])
data WorkerShutdownNoticeResponse =
WorkerShutdownNoticeResponse'
deriving (Eq,Show,Data,Typeable,Generic)
workerShutdownNoticeResponse
:: WorkerShutdownNoticeResponse
workerShutdownNoticeResponse = WorkerShutdownNoticeResponse'
instance FromJSON WorkerShutdownNoticeResponse where
parseJSON
= withObject "WorkerShutdownNoticeResponse"
(\ o -> pure WorkerShutdownNoticeResponse')
instance ToJSON WorkerShutdownNoticeResponse where
toJSON = const emptyObject
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'
{ _jStepsLocation :: !(Maybe Text)
, _jCreatedFromSnapshotId :: !(Maybe Text)
, _jRequestedState :: !(Maybe JobRequestedState)
, _jJobMetadata :: !(Maybe JobMetadata)
, _jLocation :: !(Maybe Text)
, _jStartTime :: !(Maybe DateTime')
, _jEnvironment :: !(Maybe Environment)
, _jClientRequestId :: !(Maybe Text)
, _jStageStates :: !(Maybe [ExecutionStageState])
, _jCurrentState :: !(Maybe JobCurrentState)
, _jReplacedByJobId :: !(Maybe Text)
, _jTempFiles :: !(Maybe [Text])
, _jSteps :: !(Maybe [Step])
, _jPipelineDescription :: !(Maybe PipelineDescription)
, _jExecutionInfo :: !(Maybe JobExecutionInfo)
, _jName :: !(Maybe Text)
, _jTransformNameMApping :: !(Maybe JobTransformNameMApping)
, _jId :: !(Maybe Text)
, _jLabels :: !(Maybe JobLabels)
, _jProjectId :: !(Maybe Text)
, _jType :: !(Maybe JobType)
, _jCurrentStateTime :: !(Maybe DateTime')
, _jReplaceJobId :: !(Maybe Text)
, _jCreateTime :: !(Maybe DateTime')
} deriving (Eq,Show,Data,Typeable,Generic)
job
:: Job
job =
Job'
{ _jStepsLocation = Nothing
, _jCreatedFromSnapshotId = Nothing
, _jRequestedState = Nothing
, _jJobMetadata = Nothing
, _jLocation = Nothing
, _jStartTime = Nothing
, _jEnvironment = Nothing
, _jClientRequestId = Nothing
, _jStageStates = Nothing
, _jCurrentState = Nothing
, _jReplacedByJobId = Nothing
, _jTempFiles = Nothing
, _jSteps = Nothing
, _jPipelineDescription = Nothing
, _jExecutionInfo = Nothing
, _jName = Nothing
, _jTransformNameMApping = Nothing
, _jId = Nothing
, _jLabels = Nothing
, _jProjectId = Nothing
, _jType = Nothing
, _jCurrentStateTime = Nothing
, _jReplaceJobId = Nothing
, _jCreateTime = Nothing
}
jStepsLocation :: Lens' Job (Maybe Text)
jStepsLocation
= lens _jStepsLocation
(\ s a -> s{_jStepsLocation = a})
jCreatedFromSnapshotId :: Lens' Job (Maybe Text)
jCreatedFromSnapshotId
= lens _jCreatedFromSnapshotId
(\ s a -> s{_jCreatedFromSnapshotId = a})
jRequestedState :: Lens' Job (Maybe JobRequestedState)
jRequestedState
= lens _jRequestedState
(\ s a -> s{_jRequestedState = a})
jJobMetadata :: Lens' Job (Maybe JobMetadata)
jJobMetadata
= lens _jJobMetadata (\ s a -> s{_jJobMetadata = a})
jLocation :: Lens' Job (Maybe Text)
jLocation
= lens _jLocation (\ s a -> s{_jLocation = a})
jStartTime :: Lens' Job (Maybe UTCTime)
jStartTime
= lens _jStartTime (\ s a -> s{_jStartTime = a}) .
mapping _DateTime
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})
jStageStates :: Lens' Job [ExecutionStageState]
jStageStates
= lens _jStageStates (\ s a -> s{_jStageStates = a})
. _Default
. _Coerce
jCurrentState :: Lens' Job (Maybe JobCurrentState)
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
jPipelineDescription :: Lens' Job (Maybe PipelineDescription)
jPipelineDescription
= lens _jPipelineDescription
(\ s a -> s{_jPipelineDescription = a})
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 JobType)
jType = lens _jType (\ s a -> s{_jType = a})
jCurrentStateTime :: Lens' Job (Maybe UTCTime)
jCurrentStateTime
= lens _jCurrentStateTime
(\ s a -> s{_jCurrentStateTime = a})
. mapping _DateTime
jReplaceJobId :: Lens' Job (Maybe Text)
jReplaceJobId
= lens _jReplaceJobId
(\ s a -> s{_jReplaceJobId = a})
jCreateTime :: Lens' Job (Maybe UTCTime)
jCreateTime
= lens _jCreateTime (\ s a -> s{_jCreateTime = a}) .
mapping _DateTime
instance FromJSON Job where
parseJSON
= withObject "Job"
(\ o ->
Job' <$>
(o .:? "stepsLocation") <*>
(o .:? "createdFromSnapshotId")
<*> (o .:? "requestedState")
<*> (o .:? "jobMetadata")
<*> (o .:? "location")
<*> (o .:? "startTime")
<*> (o .:? "environment")
<*> (o .:? "clientRequestId")
<*> (o .:? "stageStates" .!= mempty)
<*> (o .:? "currentState")
<*> (o .:? "replacedByJobId")
<*> (o .:? "tempFiles" .!= mempty)
<*> (o .:? "steps" .!= mempty)
<*> (o .:? "pipelineDescription")
<*> (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
[("stepsLocation" .=) <$> _jStepsLocation,
("createdFromSnapshotId" .=) <$>
_jCreatedFromSnapshotId,
("requestedState" .=) <$> _jRequestedState,
("jobMetadata" .=) <$> _jJobMetadata,
("location" .=) <$> _jLocation,
("startTime" .=) <$> _jStartTime,
("environment" .=) <$> _jEnvironment,
("clientRequestId" .=) <$> _jClientRequestId,
("stageStates" .=) <$> _jStageStates,
("currentState" .=) <$> _jCurrentState,
("replacedByJobId" .=) <$> _jReplacedByJobId,
("tempFiles" .=) <$> _jTempFiles,
("steps" .=) <$> _jSteps,
("pipelineDescription" .=) <$> _jPipelineDescription,
("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 WorkerPoolIPConfiguration)
, _wpPackages :: !(Maybe [Package])
, _wpOnHostMaintenance :: !(Maybe Text)
, _wpDiskSourceImage :: !(Maybe Text)
, _wpSubnetwork :: !(Maybe Text)
, _wpMachineType :: !(Maybe Text)
, _wpMetadata :: !(Maybe WorkerPoolMetadata)
, _wpDiskType :: !(Maybe Text)
, _wpTeardownPolicy :: !(Maybe WorkerPoolTeardownPolicy)
, _wpDefaultPackageSet :: !(Maybe WorkerPoolDefaultPackageSet)
, _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 WorkerPoolIPConfiguration)
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 WorkerPoolTeardownPolicy)
wpTeardownPolicy
= lens _wpTeardownPolicy
(\ s a -> s{_wpTeardownPolicy = a})
wpDefaultPackageSet :: Lens' WorkerPool (Maybe WorkerPoolDefaultPackageSet)
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 ComponentSource = ComponentSource'
{ _csUserName :: !(Maybe Text)
, _csName :: !(Maybe Text)
, _csOriginalTransformOrCollection :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
componentSource
:: ComponentSource
componentSource =
ComponentSource'
{ _csUserName = Nothing
, _csName = Nothing
, _csOriginalTransformOrCollection = Nothing
}
csUserName :: Lens' ComponentSource (Maybe Text)
csUserName
= lens _csUserName (\ s a -> s{_csUserName = a})
csName :: Lens' ComponentSource (Maybe Text)
csName = lens _csName (\ s a -> s{_csName = a})
csOriginalTransformOrCollection :: Lens' ComponentSource (Maybe Text)
csOriginalTransformOrCollection
= lens _csOriginalTransformOrCollection
(\ s a -> s{_csOriginalTransformOrCollection = a})
instance FromJSON ComponentSource where
parseJSON
= withObject "ComponentSource"
(\ o ->
ComponentSource' <$>
(o .:? "userName") <*> (o .:? "name") <*>
(o .:? "originalTransformOrCollection"))
instance ToJSON ComponentSource where
toJSON ComponentSource'{..}
= object
(catMaybes
[("userName" .=) <$> _csUserName,
("name" .=) <$> _csName,
("originalTransformOrCollection" .=) <$>
_csOriginalTransformOrCollection])
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])
data ExecutionStageSummary = ExecutionStageSummary'
{ _essOutputSource :: !(Maybe [StageSource])
, _essKind :: !(Maybe ExecutionStageSummaryKind)
, _essInputSource :: !(Maybe [StageSource])
, _essName :: !(Maybe Text)
, _essComponentSource :: !(Maybe [ComponentSource])
, _essId :: !(Maybe Text)
, _essComponentTransform :: !(Maybe [ComponentTransform])
} deriving (Eq,Show,Data,Typeable,Generic)
executionStageSummary
:: ExecutionStageSummary
executionStageSummary =
ExecutionStageSummary'
{ _essOutputSource = Nothing
, _essKind = Nothing
, _essInputSource = Nothing
, _essName = Nothing
, _essComponentSource = Nothing
, _essId = Nothing
, _essComponentTransform = Nothing
}
essOutputSource :: Lens' ExecutionStageSummary [StageSource]
essOutputSource
= lens _essOutputSource
(\ s a -> s{_essOutputSource = a})
. _Default
. _Coerce
essKind :: Lens' ExecutionStageSummary (Maybe ExecutionStageSummaryKind)
essKind = lens _essKind (\ s a -> s{_essKind = a})
essInputSource :: Lens' ExecutionStageSummary [StageSource]
essInputSource
= lens _essInputSource
(\ s a -> s{_essInputSource = a})
. _Default
. _Coerce
essName :: Lens' ExecutionStageSummary (Maybe Text)
essName = lens _essName (\ s a -> s{_essName = a})
essComponentSource :: Lens' ExecutionStageSummary [ComponentSource]
essComponentSource
= lens _essComponentSource
(\ s a -> s{_essComponentSource = a})
. _Default
. _Coerce
essId :: Lens' ExecutionStageSummary (Maybe Text)
essId = lens _essId (\ s a -> s{_essId = a})
essComponentTransform :: Lens' ExecutionStageSummary [ComponentTransform]
essComponentTransform
= lens _essComponentTransform
(\ s a -> s{_essComponentTransform = a})
. _Default
. _Coerce
instance FromJSON ExecutionStageSummary where
parseJSON
= withObject "ExecutionStageSummary"
(\ o ->
ExecutionStageSummary' <$>
(o .:? "outputSource" .!= mempty) <*> (o .:? "kind")
<*> (o .:? "inputSource" .!= mempty)
<*> (o .:? "name")
<*> (o .:? "componentSource" .!= mempty)
<*> (o .:? "id")
<*> (o .:? "componentTransform" .!= mempty))
instance ToJSON ExecutionStageSummary where
toJSON ExecutionStageSummary'{..}
= object
(catMaybes
[("outputSource" .=) <$> _essOutputSource,
("kind" .=) <$> _essKind,
("inputSource" .=) <$> _essInputSource,
("name" .=) <$> _essName,
("componentSource" .=) <$> _essComponentSource,
("id" .=) <$> _essId,
("componentTransform" .=) <$>
_essComponentTransform])
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])
data SnapshotJobRequest = SnapshotJobRequest'
{ _sjrTtl :: !(Maybe GDuration)
, _sjrLocation :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
snapshotJobRequest
:: SnapshotJobRequest
snapshotJobRequest =
SnapshotJobRequest'
{ _sjrTtl = Nothing
, _sjrLocation = Nothing
}
sjrTtl :: Lens' SnapshotJobRequest (Maybe Scientific)
sjrTtl
= lens _sjrTtl (\ s a -> s{_sjrTtl = a}) .
mapping _GDuration
sjrLocation :: Lens' SnapshotJobRequest (Maybe Text)
sjrLocation
= lens _sjrLocation (\ s a -> s{_sjrLocation = a})
instance FromJSON SnapshotJobRequest where
parseJSON
= withObject "SnapshotJobRequest"
(\ o ->
SnapshotJobRequest' <$>
(o .:? "ttl") <*> (o .:? "location"))
instance ToJSON SnapshotJobRequest where
toJSON SnapshotJobRequest'{..}
= object
(catMaybes
[("ttl" .=) <$> _sjrTtl,
("location" .=) <$> _sjrLocation])
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 ResourceUtilizationReportResponse =
ResourceUtilizationReportResponse'
deriving (Eq,Show,Data,Typeable,Generic)
resourceUtilizationReportResponse
:: ResourceUtilizationReportResponse
resourceUtilizationReportResponse = ResourceUtilizationReportResponse'
instance FromJSON ResourceUtilizationReportResponse
where
parseJSON
= withObject "ResourceUtilizationReportResponse"
(\ o -> pure ResourceUtilizationReportResponse')
instance ToJSON ResourceUtilizationReportResponse
where
toJSON = const emptyObject
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)
, _ljrFailedLocation :: !(Maybe [FailedLocation])
, _ljrJobs :: !(Maybe [Job])
} deriving (Eq,Show,Data,Typeable,Generic)
listJobsResponse
:: ListJobsResponse
listJobsResponse =
ListJobsResponse'
{ _ljrNextPageToken = Nothing
, _ljrFailedLocation = Nothing
, _ljrJobs = Nothing
}
ljrNextPageToken :: Lens' ListJobsResponse (Maybe Text)
ljrNextPageToken
= lens _ljrNextPageToken
(\ s a -> s{_ljrNextPageToken = a})
ljrFailedLocation :: Lens' ListJobsResponse [FailedLocation]
ljrFailedLocation
= lens _ljrFailedLocation
(\ s a -> s{_ljrFailedLocation = a})
. _Default
. _Coerce
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 .:? "failedLocation" .!= mempty)
<*> (o .:? "jobs" .!= mempty))
instance ToJSON ListJobsResponse where
toJSON ListJobsResponse'{..}
= object
(catMaybes
[("nextPageToken" .=) <$> _ljrNextPageToken,
("failedLocation" .=) <$> _ljrFailedLocation,
("jobs" .=) <$> _ljrJobs])
newtype LaunchTemplateParametersParameters = LaunchTemplateParametersParameters'
{ _ltppAddtional :: HashMap Text Text
} deriving (Eq,Show,Data,Typeable,Generic)
launchTemplateParametersParameters
:: HashMap Text Text
-> LaunchTemplateParametersParameters
launchTemplateParametersParameters pLtppAddtional_ =
LaunchTemplateParametersParameters'
{ _ltppAddtional = _Coerce # pLtppAddtional_
}
ltppAddtional :: Lens' LaunchTemplateParametersParameters (HashMap Text Text)
ltppAddtional
= lens _ltppAddtional
(\ s a -> s{_ltppAddtional = a})
. _Coerce
instance FromJSON LaunchTemplateParametersParameters
where
parseJSON
= withObject "LaunchTemplateParametersParameters"
(\ o ->
LaunchTemplateParametersParameters' <$>
(parseJSONObject o))
instance ToJSON LaunchTemplateParametersParameters
where
toJSON = toJSON . _ltppAddtional
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 GDuration)
, _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 Scientific)
apRemainingTime
= lens _apRemainingTime
(\ s a -> s{_apRemainingTime = a})
. mapping _GDuration
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 DateTime')
, _wmWorkerMessageCode :: !(Maybe WorkerMessageCode)
, _wmWorkerMetrics :: !(Maybe ResourceUtilizationReport)
, _wmWorkerLifecycleEvent :: !(Maybe WorkerLifecycleEvent)
, _wmWorkerShutdownNotice :: !(Maybe WorkerShutdownNotice)
, _wmLabels :: !(Maybe WorkerMessageLabels)
} deriving (Eq,Show,Data,Typeable,Generic)
workerMessage
:: WorkerMessage
workerMessage =
WorkerMessage'
{ _wmWorkerHealthReport = Nothing
, _wmTime = Nothing
, _wmWorkerMessageCode = Nothing
, _wmWorkerMetrics = Nothing
, _wmWorkerLifecycleEvent = Nothing
, _wmWorkerShutdownNotice = Nothing
, _wmLabels = Nothing
}
wmWorkerHealthReport :: Lens' WorkerMessage (Maybe WorkerHealthReport)
wmWorkerHealthReport
= lens _wmWorkerHealthReport
(\ s a -> s{_wmWorkerHealthReport = a})
wmTime :: Lens' WorkerMessage (Maybe UTCTime)
wmTime
= lens _wmTime (\ s a -> s{_wmTime = a}) .
mapping _DateTime
wmWorkerMessageCode :: Lens' WorkerMessage (Maybe WorkerMessageCode)
wmWorkerMessageCode
= lens _wmWorkerMessageCode
(\ s a -> s{_wmWorkerMessageCode = a})
wmWorkerMetrics :: Lens' WorkerMessage (Maybe ResourceUtilizationReport)
wmWorkerMetrics
= lens _wmWorkerMetrics
(\ s a -> s{_wmWorkerMetrics = a})
wmWorkerLifecycleEvent :: Lens' WorkerMessage (Maybe WorkerLifecycleEvent)
wmWorkerLifecycleEvent
= lens _wmWorkerLifecycleEvent
(\ s a -> s{_wmWorkerLifecycleEvent = a})
wmWorkerShutdownNotice :: Lens' WorkerMessage (Maybe WorkerShutdownNotice)
wmWorkerShutdownNotice
= lens _wmWorkerShutdownNotice
(\ s a -> s{_wmWorkerShutdownNotice = 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 .:? "workerMetrics")
<*> (o .:? "workerLifecycleEvent")
<*> (o .:? "workerShutdownNotice")
<*> (o .:? "labels"))
instance ToJSON WorkerMessage where
toJSON WorkerMessage'{..}
= object
(catMaybes
[("workerHealthReport" .=) <$> _wmWorkerHealthReport,
("time" .=) <$> _wmTime,
("workerMessageCode" .=) <$> _wmWorkerMessageCode,
("workerMetrics" .=) <$> _wmWorkerMetrics,
("workerLifecycleEvent" .=) <$>
_wmWorkerLifecycleEvent,
("workerShutdownNotice" .=) <$>
_wmWorkerShutdownNotice,
("labels" .=) <$> _wmLabels])
data KeyRangeLocation = KeyRangeLocation'
{ _krlDataDisk :: !(Maybe Text)
, _krlDeprecatedPersistentDirectory :: !(Maybe Text)
, _krlStart :: !(Maybe Text)
, _krlDeliveryEndpoint :: !(Maybe Text)
, _krlEnd :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
keyRangeLocation
:: KeyRangeLocation
keyRangeLocation =
KeyRangeLocation'
{ _krlDataDisk = Nothing
, _krlDeprecatedPersistentDirectory = Nothing
, _krlStart = Nothing
, _krlDeliveryEndpoint = Nothing
, _krlEnd = Nothing
}
krlDataDisk :: Lens' KeyRangeLocation (Maybe Text)
krlDataDisk
= lens _krlDataDisk (\ s a -> s{_krlDataDisk = a})
krlDeprecatedPersistentDirectory :: Lens' KeyRangeLocation (Maybe Text)
krlDeprecatedPersistentDirectory
= lens _krlDeprecatedPersistentDirectory
(\ s a -> s{_krlDeprecatedPersistentDirectory = 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 .:? "dataDisk") <*>
(o .:? "deprecatedPersistentDirectory")
<*> (o .:? "start")
<*> (o .:? "deliveryEndpoint")
<*> (o .:? "end"))
instance ToJSON KeyRangeLocation where
toJSON KeyRangeLocation'{..}
= object
(catMaybes
[("dataDisk" .=) <$> _krlDataDisk,
("deprecatedPersistentDirectory" .=) <$>
_krlDeprecatedPersistentDirectory,
("start" .=) <$> _krlStart,
("deliveryEndpoint" .=) <$> _krlDeliveryEndpoint,
("end" .=) <$> _krlEnd])
data Histogram = Histogram'
{ _hBucketCounts :: !(Maybe [Textual Int64])
, _hFirstBucketOffSet :: !(Maybe (Textual Int32))
} deriving (Eq,Show,Data,Typeable,Generic)
histogram
:: Histogram
histogram =
Histogram'
{ _hBucketCounts = Nothing
, _hFirstBucketOffSet = Nothing
}
hBucketCounts :: Lens' Histogram [Int64]
hBucketCounts
= lens _hBucketCounts
(\ s a -> s{_hBucketCounts = a})
. _Default
. _Coerce
hFirstBucketOffSet :: Lens' Histogram (Maybe Int32)
hFirstBucketOffSet
= lens _hFirstBucketOffSet
(\ s a -> s{_hFirstBucketOffSet = a})
. mapping _Coerce
instance FromJSON Histogram where
parseJSON
= withObject "Histogram"
(\ o ->
Histogram' <$>
(o .:? "bucketCounts" .!= mempty) <*>
(o .:? "firstBucketOffset"))
instance ToJSON Histogram where
toJSON Histogram'{..}
= object
(catMaybes
[("bucketCounts" .=) <$> _hBucketCounts,
("firstBucketOffset" .=) <$> _hFirstBucketOffSet])
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])
data DistributionUpdate = DistributionUpdate'
{ _duMax :: !(Maybe SplitInt64)
, _duCount :: !(Maybe SplitInt64)
, _duMin :: !(Maybe SplitInt64)
, _duHistogram :: !(Maybe Histogram)
, _duSumOfSquares :: !(Maybe (Textual Double))
, _duSum :: !(Maybe SplitInt64)
} deriving (Eq,Show,Data,Typeable,Generic)
distributionUpdate
:: DistributionUpdate
distributionUpdate =
DistributionUpdate'
{ _duMax = Nothing
, _duCount = Nothing
, _duMin = Nothing
, _duHistogram = Nothing
, _duSumOfSquares = Nothing
, _duSum = Nothing
}
duMax :: Lens' DistributionUpdate (Maybe SplitInt64)
duMax = lens _duMax (\ s a -> s{_duMax = a})
duCount :: Lens' DistributionUpdate (Maybe SplitInt64)
duCount = lens _duCount (\ s a -> s{_duCount = a})
duMin :: Lens' DistributionUpdate (Maybe SplitInt64)
duMin = lens _duMin (\ s a -> s{_duMin = a})
duHistogram :: Lens' DistributionUpdate (Maybe Histogram)
duHistogram
= lens _duHistogram (\ s a -> s{_duHistogram = a})
duSumOfSquares :: Lens' DistributionUpdate (Maybe Double)
duSumOfSquares
= lens _duSumOfSquares
(\ s a -> s{_duSumOfSquares = a})
. mapping _Coerce
duSum :: Lens' DistributionUpdate (Maybe SplitInt64)
duSum = lens _duSum (\ s a -> s{_duSum = a})
instance FromJSON DistributionUpdate where
parseJSON
= withObject "DistributionUpdate"
(\ o ->
DistributionUpdate' <$>
(o .:? "max") <*> (o .:? "count") <*> (o .:? "min")
<*> (o .:? "histogram")
<*> (o .:? "sumOfSquares")
<*> (o .:? "sum"))
instance ToJSON DistributionUpdate where
toJSON DistributionUpdate'{..}
= object
(catMaybes
[("max" .=) <$> _duMax, ("count" .=) <$> _duCount,
("min" .=) <$> _duMin,
("histogram" .=) <$> _duHistogram,
("sumOfSquares" .=) <$> _duSumOfSquares,
("sum" .=) <$> _duSum])
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])
, _sctWindmillServiceEndpoint :: !(Maybe Text)
, _sctWindmillServicePort :: !(Maybe (Textual Int64))
} deriving (Eq,Show,Data,Typeable,Generic)
streamingConfigTask
:: StreamingConfigTask
streamingConfigTask =
StreamingConfigTask'
{ _sctUserStepToStateFamilyNameMap = Nothing
, _sctStreamingComputationConfigs = Nothing
, _sctWindmillServiceEndpoint = Nothing
, _sctWindmillServicePort = 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
sctWindmillServiceEndpoint :: Lens' StreamingConfigTask (Maybe Text)
sctWindmillServiceEndpoint
= lens _sctWindmillServiceEndpoint
(\ s a -> s{_sctWindmillServiceEndpoint = a})
sctWindmillServicePort :: Lens' StreamingConfigTask (Maybe Int64)
sctWindmillServicePort
= lens _sctWindmillServicePort
(\ s a -> s{_sctWindmillServicePort = a})
. mapping _Coerce
instance FromJSON StreamingConfigTask where
parseJSON
= withObject "StreamingConfigTask"
(\ o ->
StreamingConfigTask' <$>
(o .:? "userStepToStateFamilyNameMap") <*>
(o .:? "streamingComputationConfigs" .!= mempty)
<*> (o .:? "windmillServiceEndpoint")
<*> (o .:? "windmillServicePort"))
instance ToJSON StreamingConfigTask where
toJSON StreamingConfigTask'{..}
= object
(catMaybes
[("userStepToStateFamilyNameMap" .=) <$>
_sctUserStepToStateFamilyNameMap,
("streamingComputationConfigs" .=) <$>
_sctStreamingComputationConfigs,
("windmillServiceEndpoint" .=) <$>
_sctWindmillServiceEndpoint,
("windmillServicePort" .=) <$>
_sctWindmillServicePort])
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])
data SendWorkerMessagesRequest = SendWorkerMessagesRequest'
{ _swmrLocation :: !(Maybe Text)
, _swmrWorkerMessages :: !(Maybe [WorkerMessage])
} deriving (Eq,Show,Data,Typeable,Generic)
sendWorkerMessagesRequest
:: SendWorkerMessagesRequest
sendWorkerMessagesRequest =
SendWorkerMessagesRequest'
{ _swmrLocation = Nothing
, _swmrWorkerMessages = Nothing
}
swmrLocation :: Lens' SendWorkerMessagesRequest (Maybe Text)
swmrLocation
= lens _swmrLocation (\ s a -> s{_swmrLocation = a})
swmrWorkerMessages :: Lens' SendWorkerMessagesRequest [WorkerMessage]
swmrWorkerMessages
= lens _swmrWorkerMessages
(\ s a -> s{_swmrWorkerMessages = a})
. _Default
. _Coerce
instance FromJSON SendWorkerMessagesRequest where
parseJSON
= withObject "SendWorkerMessagesRequest"
(\ o ->
SendWorkerMessagesRequest' <$>
(o .:? "location") <*>
(o .:? "workerMessages" .!= mempty))
instance ToJSON SendWorkerMessagesRequest where
toJSON SendWorkerMessagesRequest'{..}
= object
(catMaybes
[("location" .=) <$> _swmrLocation,
("workerMessages" .=) <$> _swmrWorkerMessages])
data SourceSplitShard = SourceSplitShard'
{ _sssDerivationMode :: !(Maybe SourceSplitShardDerivationMode)
, _sssSource :: !(Maybe Source)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceSplitShard
:: SourceSplitShard
sourceSplitShard =
SourceSplitShard'
{ _sssDerivationMode = Nothing
, _sssSource = Nothing
}
sssDerivationMode :: Lens' SourceSplitShard (Maybe SourceSplitShardDerivationMode)
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])
data ComponentTransform = ComponentTransform'
{ _ctOriginalTransform :: !(Maybe Text)
, _ctUserName :: !(Maybe Text)
, _ctName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
componentTransform
:: ComponentTransform
componentTransform =
ComponentTransform'
{ _ctOriginalTransform = Nothing
, _ctUserName = Nothing
, _ctName = Nothing
}
ctOriginalTransform :: Lens' ComponentTransform (Maybe Text)
ctOriginalTransform
= lens _ctOriginalTransform
(\ s a -> s{_ctOriginalTransform = a})
ctUserName :: Lens' ComponentTransform (Maybe Text)
ctUserName
= lens _ctUserName (\ s a -> s{_ctUserName = a})
ctName :: Lens' ComponentTransform (Maybe Text)
ctName = lens _ctName (\ s a -> s{_ctName = a})
instance FromJSON ComponentTransform where
parseJSON
= withObject "ComponentTransform"
(\ o ->
ComponentTransform' <$>
(o .:? "originalTransform") <*> (o .:? "userName")
<*> (o .:? "name"))
instance ToJSON ComponentTransform where
toJSON ComponentTransform'{..}
= object
(catMaybes
[("originalTransform" .=) <$> _ctOriginalTransform,
("userName" .=) <$> _ctUserName,
("name" .=) <$> _ctName])
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 AutoscalingEvent = AutoscalingEvent'
{ _aeCurrentNumWorkers :: !(Maybe (Textual Int64))
, _aeTime :: !(Maybe DateTime')
, _aeEventType :: !(Maybe AutoscalingEventEventType)
, _aeTargetNumWorkers :: !(Maybe (Textual Int64))
, _aeWorkerPool :: !(Maybe Text)
, _aeDescription :: !(Maybe StructuredMessage)
} deriving (Eq,Show,Data,Typeable,Generic)
autoscalingEvent
:: AutoscalingEvent
autoscalingEvent =
AutoscalingEvent'
{ _aeCurrentNumWorkers = Nothing
, _aeTime = Nothing
, _aeEventType = Nothing
, _aeTargetNumWorkers = Nothing
, _aeWorkerPool = Nothing
, _aeDescription = Nothing
}
aeCurrentNumWorkers :: Lens' AutoscalingEvent (Maybe Int64)
aeCurrentNumWorkers
= lens _aeCurrentNumWorkers
(\ s a -> s{_aeCurrentNumWorkers = a})
. mapping _Coerce
aeTime :: Lens' AutoscalingEvent (Maybe UTCTime)
aeTime
= lens _aeTime (\ s a -> s{_aeTime = a}) .
mapping _DateTime
aeEventType :: Lens' AutoscalingEvent (Maybe AutoscalingEventEventType)
aeEventType
= lens _aeEventType (\ s a -> s{_aeEventType = a})
aeTargetNumWorkers :: Lens' AutoscalingEvent (Maybe Int64)
aeTargetNumWorkers
= lens _aeTargetNumWorkers
(\ s a -> s{_aeTargetNumWorkers = a})
. mapping _Coerce
aeWorkerPool :: Lens' AutoscalingEvent (Maybe Text)
aeWorkerPool
= lens _aeWorkerPool (\ s a -> s{_aeWorkerPool = a})
aeDescription :: Lens' AutoscalingEvent (Maybe StructuredMessage)
aeDescription
= lens _aeDescription
(\ s a -> s{_aeDescription = a})
instance FromJSON AutoscalingEvent where
parseJSON
= withObject "AutoscalingEvent"
(\ o ->
AutoscalingEvent' <$>
(o .:? "currentNumWorkers") <*> (o .:? "time") <*>
(o .:? "eventType")
<*> (o .:? "targetNumWorkers")
<*> (o .:? "workerPool")
<*> (o .:? "description"))
instance ToJSON AutoscalingEvent where
toJSON AutoscalingEvent'{..}
= object
(catMaybes
[("currentNumWorkers" .=) <$> _aeCurrentNumWorkers,
("time" .=) <$> _aeTime,
("eventType" .=) <$> _aeEventType,
("targetNumWorkers" .=) <$> _aeTargetNumWorkers,
("workerPool" .=) <$> _aeWorkerPool,
("description" .=) <$> _aeDescription])
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)
, _ljmrAutoscalingEvents :: !(Maybe [AutoscalingEvent])
} deriving (Eq,Show,Data,Typeable,Generic)
listJobMessagesResponse
:: ListJobMessagesResponse
listJobMessagesResponse =
ListJobMessagesResponse'
{ _ljmrJobMessages = Nothing
, _ljmrNextPageToken = Nothing
, _ljmrAutoscalingEvents = 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})
ljmrAutoscalingEvents :: Lens' ListJobMessagesResponse [AutoscalingEvent]
ljmrAutoscalingEvents
= lens _ljmrAutoscalingEvents
(\ s a -> s{_ljmrAutoscalingEvents = a})
. _Default
. _Coerce
instance FromJSON ListJobMessagesResponse where
parseJSON
= withObject "ListJobMessagesResponse"
(\ o ->
ListJobMessagesResponse' <$>
(o .:? "jobMessages" .!= mempty) <*>
(o .:? "nextPageToken")
<*> (o .:? "autoscalingEvents" .!= mempty))
instance ToJSON ListJobMessagesResponse where
toJSON ListJobMessagesResponse'{..}
= object
(catMaybes
[("jobMessages" .=) <$> _ljmrJobMessages,
("nextPageToken" .=) <$> _ljmrNextPageToken,
("autoscalingEvents" .=) <$> _ljmrAutoscalingEvents])
data PubsubLocation = PubsubLocation'
{ _plTrackingSubscription :: !(Maybe Text)
, _plDropLateData :: !(Maybe Bool)
, _plTimestampLabel :: !(Maybe Text)
, _plIdLabel :: !(Maybe Text)
, _plTopic :: !(Maybe Text)
, _plWithAttributes :: !(Maybe Bool)
, _plSubscription :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
pubsubLocation
:: PubsubLocation
pubsubLocation =
PubsubLocation'
{ _plTrackingSubscription = Nothing
, _plDropLateData = Nothing
, _plTimestampLabel = Nothing
, _plIdLabel = Nothing
, _plTopic = Nothing
, _plWithAttributes = 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})
plWithAttributes :: Lens' PubsubLocation (Maybe Bool)
plWithAttributes
= lens _plWithAttributes
(\ s a -> s{_plWithAttributes = 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 .:? "withAttributes")
<*> (o .:? "subscription"))
instance ToJSON PubsubLocation where
toJSON PubsubLocation'{..}
= object
(catMaybes
[("trackingSubscription" .=) <$>
_plTrackingSubscription,
("dropLateData" .=) <$> _plDropLateData,
("timestampLabel" .=) <$> _plTimestampLabel,
("idLabel" .=) <$> _plIdLabel,
("topic" .=) <$> _plTopic,
("withAttributes" .=) <$> _plWithAttributes,
("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 ExecutionStageState = ExecutionStageState'
{ _essExecutionStageName :: !(Maybe Text)
, _essCurrentStateTime :: !(Maybe DateTime')
, _essExecutionStageState :: !(Maybe ExecutionStageStateExecutionStageState)
} deriving (Eq,Show,Data,Typeable,Generic)
executionStageState
:: ExecutionStageState
executionStageState =
ExecutionStageState'
{ _essExecutionStageName = Nothing
, _essCurrentStateTime = Nothing
, _essExecutionStageState = Nothing
}
essExecutionStageName :: Lens' ExecutionStageState (Maybe Text)
essExecutionStageName
= lens _essExecutionStageName
(\ s a -> s{_essExecutionStageName = a})
essCurrentStateTime :: Lens' ExecutionStageState (Maybe UTCTime)
essCurrentStateTime
= lens _essCurrentStateTime
(\ s a -> s{_essCurrentStateTime = a})
. mapping _DateTime
essExecutionStageState :: Lens' ExecutionStageState (Maybe ExecutionStageStateExecutionStageState)
essExecutionStageState
= lens _essExecutionStageState
(\ s a -> s{_essExecutionStageState = a})
instance FromJSON ExecutionStageState where
parseJSON
= withObject "ExecutionStageState"
(\ o ->
ExecutionStageState' <$>
(o .:? "executionStageName") <*>
(o .:? "currentStateTime")
<*> (o .:? "executionStageState"))
instance ToJSON ExecutionStageState where
toJSON ExecutionStageState'{..}
= object
(catMaybes
[("executionStageName" .=) <$>
_essExecutionStageName,
("currentStateTime" .=) <$> _essCurrentStateTime,
("executionStageState" .=) <$>
_essExecutionStageState])
data StageSource = StageSource'
{ _ssSizeBytes :: !(Maybe (Textual Int64))
, _ssUserName :: !(Maybe Text)
, _ssName :: !(Maybe Text)
, _ssOriginalTransformOrCollection :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
stageSource
:: StageSource
stageSource =
StageSource'
{ _ssSizeBytes = Nothing
, _ssUserName = Nothing
, _ssName = Nothing
, _ssOriginalTransformOrCollection = Nothing
}
ssSizeBytes :: Lens' StageSource (Maybe Int64)
ssSizeBytes
= lens _ssSizeBytes (\ s a -> s{_ssSizeBytes = a}) .
mapping _Coerce
ssUserName :: Lens' StageSource (Maybe Text)
ssUserName
= lens _ssUserName (\ s a -> s{_ssUserName = a})
ssName :: Lens' StageSource (Maybe Text)
ssName = lens _ssName (\ s a -> s{_ssName = a})
ssOriginalTransformOrCollection :: Lens' StageSource (Maybe Text)
ssOriginalTransformOrCollection
= lens _ssOriginalTransformOrCollection
(\ s a -> s{_ssOriginalTransformOrCollection = a})
instance FromJSON StageSource where
parseJSON
= withObject "StageSource"
(\ o ->
StageSource' <$>
(o .:? "sizeBytes") <*> (o .:? "userName") <*>
(o .:? "name")
<*> (o .:? "originalTransformOrCollection"))
instance ToJSON StageSource where
toJSON StageSource'{..}
= object
(catMaybes
[("sizeBytes" .=) <$> _ssSizeBytes,
("userName" .=) <$> _ssUserName,
("name" .=) <$> _ssName,
("originalTransformOrCollection" .=) <$>
_ssOriginalTransformOrCollection])
data SourceOperationRequest = SourceOperationRequest'
{ _souSplit :: !(Maybe SourceSplitRequest)
, _souGetMetadata :: !(Maybe SourceGetMetadataRequest)
, _souName :: !(Maybe Text)
, _souSystemName :: !(Maybe Text)
, _souStageName :: !(Maybe Text)
, _souOriginalName :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
sourceOperationRequest
:: SourceOperationRequest
sourceOperationRequest =
SourceOperationRequest'
{ _souSplit = Nothing
, _souGetMetadata = Nothing
, _souName = Nothing
, _souSystemName = Nothing
, _souStageName = Nothing
, _souOriginalName = Nothing
}
souSplit :: Lens' SourceOperationRequest (Maybe SourceSplitRequest)
souSplit = lens _souSplit (\ s a -> s{_souSplit = a})
souGetMetadata :: Lens' SourceOperationRequest (Maybe SourceGetMetadataRequest)
souGetMetadata
= lens _souGetMetadata
(\ s a -> s{_souGetMetadata = a})
souName :: Lens' SourceOperationRequest (Maybe Text)
souName = lens _souName (\ s a -> s{_souName = a})
souSystemName :: Lens' SourceOperationRequest (Maybe Text)
souSystemName
= lens _souSystemName
(\ s a -> s{_souSystemName = a})
souStageName :: Lens' SourceOperationRequest (Maybe Text)
souStageName
= lens _souStageName (\ s a -> s{_souStageName = a})
souOriginalName :: Lens' SourceOperationRequest (Maybe Text)
souOriginalName
= lens _souOriginalName
(\ s a -> s{_souOriginalName = a})
instance FromJSON SourceOperationRequest where
parseJSON
= withObject "SourceOperationRequest"
(\ o ->
SourceOperationRequest' <$>
(o .:? "split") <*> (o .:? "getMetadata") <*>
(o .:? "name")
<*> (o .:? "systemName")
<*> (o .:? "stageName")
<*> (o .:? "originalName"))
instance ToJSON SourceOperationRequest where
toJSON SourceOperationRequest'{..}
= object
(catMaybes
[("split" .=) <$> _souSplit,
("getMetadata" .=) <$> _souGetMetadata,
("name" .=) <$> _souName,
("systemName" .=) <$> _souSystemName,
("stageName" .=) <$> _souStageName,
("originalName" .=) <$> _souOriginalName])
data SpannerIODetails = SpannerIODetails'
{ _siodInstanceId :: !(Maybe Text)
, _siodDatabaseId :: !(Maybe Text)
, _siodProjectId :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
spannerIODetails
:: SpannerIODetails
spannerIODetails =
SpannerIODetails'
{ _siodInstanceId = Nothing
, _siodDatabaseId = Nothing
, _siodProjectId = Nothing
}
siodInstanceId :: Lens' SpannerIODetails (Maybe Text)
siodInstanceId
= lens _siodInstanceId
(\ s a -> s{_siodInstanceId = a})
siodDatabaseId :: Lens' SpannerIODetails (Maybe Text)
siodDatabaseId
= lens _siodDatabaseId
(\ s a -> s{_siodDatabaseId = a})
siodProjectId :: Lens' SpannerIODetails (Maybe Text)
siodProjectId
= lens _siodProjectId
(\ s a -> s{_siodProjectId = a})
instance FromJSON SpannerIODetails where
parseJSON
= withObject "SpannerIODetails"
(\ o ->
SpannerIODetails' <$>
(o .:? "instanceId") <*> (o .:? "databaseId") <*>
(o .:? "projectId"))
instance ToJSON SpannerIODetails where
toJSON SpannerIODetails'{..}
= object
(catMaybes
[("instanceId" .=) <$> _siodInstanceId,
("databaseId" .=) <$> _siodDatabaseId,
("projectId" .=) <$> _siodProjectId])
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])
data Parameter = Parameter'
{ _parValue :: !(Maybe JSONValue)
, _parKey :: !(Maybe Text)
} deriving (Eq,Show,Data,Typeable,Generic)
parameter
:: Parameter
parameter =
Parameter'
{ _parValue = Nothing
, _parKey = Nothing
}
parValue :: Lens' Parameter (Maybe JSONValue)
parValue = lens _parValue (\ s a -> s{_parValue = a})
parKey :: Lens' Parameter (Maybe Text)
parKey = lens _parKey (\ s a -> s{_parKey = a})
instance FromJSON Parameter where
parseJSON
= withObject "Parameter"
(\ o ->
Parameter' <$> (o .:? "value") <*> (o .:? "key"))
instance ToJSON Parameter where
toJSON Parameter'{..}
= object
(catMaybes
[("value" .=) <$> _parValue, ("key" .=) <$> _parKey])