{-# LANGUAGE DeriveDataTypeable #-}
{-# LANGUAGE DeriveGeneric #-}
{-# LANGUAGE OverloadedStrings #-}
{-# LANGUAGE RecordWildCards #-}
{-# LANGUAGE TypeFamilies #-}
{-# OPTIONS_GHC -fno-warn-unused-imports #-}
{-# OPTIONS_GHC -fno-warn-unused-binds #-}
{-# OPTIONS_GHC -fno-warn-unused-matches #-}
module Network.AWS.IoTAnalytics.StartPipelineReprocessing
(
startPipelineReprocessing
, StartPipelineReprocessing
, sprStartTime
, sprEndTime
, sprPipelineName
, startPipelineReprocessingResponse
, StartPipelineReprocessingResponse
, sprrsReprocessingId
, sprrsResponseStatus
) where
import Network.AWS.IoTAnalytics.Types
import Network.AWS.IoTAnalytics.Types.Product
import Network.AWS.Lens
import Network.AWS.Prelude
import Network.AWS.Request
import Network.AWS.Response
data StartPipelineReprocessing = StartPipelineReprocessing'
{ _sprStartTime :: !(Maybe POSIX)
, _sprEndTime :: !(Maybe POSIX)
, _sprPipelineName :: !Text
} deriving (Eq, Read, Show, Data, Typeable, Generic)
startPipelineReprocessing
:: Text
-> StartPipelineReprocessing
startPipelineReprocessing pPipelineName_ =
StartPipelineReprocessing'
{ _sprStartTime = Nothing
, _sprEndTime = Nothing
, _sprPipelineName = pPipelineName_
}
sprStartTime :: Lens' StartPipelineReprocessing (Maybe UTCTime)
sprStartTime = lens _sprStartTime (\ s a -> s{_sprStartTime = a}) . mapping _Time
sprEndTime :: Lens' StartPipelineReprocessing (Maybe UTCTime)
sprEndTime = lens _sprEndTime (\ s a -> s{_sprEndTime = a}) . mapping _Time
sprPipelineName :: Lens' StartPipelineReprocessing Text
sprPipelineName = lens _sprPipelineName (\ s a -> s{_sprPipelineName = a})
instance AWSRequest StartPipelineReprocessing where
type Rs StartPipelineReprocessing =
StartPipelineReprocessingResponse
request = postJSON ioTAnalytics
response
= receiveJSON
(\ s h x ->
StartPipelineReprocessingResponse' <$>
(x .?> "reprocessingId") <*> (pure (fromEnum s)))
instance Hashable StartPipelineReprocessing where
instance NFData StartPipelineReprocessing where
instance ToHeaders StartPipelineReprocessing where
toHeaders = const mempty
instance ToJSON StartPipelineReprocessing where
toJSON StartPipelineReprocessing'{..}
= object
(catMaybes
[("startTime" .=) <$> _sprStartTime,
("endTime" .=) <$> _sprEndTime])
instance ToPath StartPipelineReprocessing where
toPath StartPipelineReprocessing'{..}
= mconcat
["/pipelines/", toBS _sprPipelineName,
"/reprocessing"]
instance ToQuery StartPipelineReprocessing where
toQuery = const mempty
data StartPipelineReprocessingResponse = StartPipelineReprocessingResponse'
{ _sprrsReprocessingId :: !(Maybe Text)
, _sprrsResponseStatus :: !Int
} deriving (Eq, Read, Show, Data, Typeable, Generic)
startPipelineReprocessingResponse
:: Int
-> StartPipelineReprocessingResponse
startPipelineReprocessingResponse pResponseStatus_ =
StartPipelineReprocessingResponse'
{_sprrsReprocessingId = Nothing, _sprrsResponseStatus = pResponseStatus_}
sprrsReprocessingId :: Lens' StartPipelineReprocessingResponse (Maybe Text)
sprrsReprocessingId = lens _sprrsReprocessingId (\ s a -> s{_sprrsReprocessingId = a})
sprrsResponseStatus :: Lens' StartPipelineReprocessingResponse Int
sprrsResponseStatus = lens _sprrsResponseStatus (\ s a -> s{_sprrsResponseStatus = a})
instance NFData StartPipelineReprocessingResponse
where