{-# 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.RunPipelineActivity
(
runPipelineActivity
, RunPipelineActivity
, rpaPipelineActivity
, rpaPayloads
, runPipelineActivityResponse
, RunPipelineActivityResponse
, rparsLogResult
, rparsPayloads
, rparsResponseStatus
) 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 RunPipelineActivity = RunPipelineActivity'
{ _rpaPipelineActivity :: !PipelineActivity
, _rpaPayloads :: !(List1 Base64)
} deriving (Eq, Read, Show, Data, Typeable, Generic)
runPipelineActivity
:: PipelineActivity
-> NonEmpty ByteString
-> RunPipelineActivity
runPipelineActivity pPipelineActivity_ pPayloads_ =
RunPipelineActivity'
{ _rpaPipelineActivity = pPipelineActivity_
, _rpaPayloads = _List1 # pPayloads_
}
rpaPipelineActivity :: Lens' RunPipelineActivity PipelineActivity
rpaPipelineActivity = lens _rpaPipelineActivity (\ s a -> s{_rpaPipelineActivity = a})
rpaPayloads :: Lens' RunPipelineActivity (NonEmpty ByteString)
rpaPayloads = lens _rpaPayloads (\ s a -> s{_rpaPayloads = a}) . _List1
instance AWSRequest RunPipelineActivity where
type Rs RunPipelineActivity =
RunPipelineActivityResponse
request = postJSON ioTAnalytics
response
= receiveJSON
(\ s h x ->
RunPipelineActivityResponse' <$>
(x .?> "logResult") <*> (x .?> "payloads") <*>
(pure (fromEnum s)))
instance Hashable RunPipelineActivity where
instance NFData RunPipelineActivity where
instance ToHeaders RunPipelineActivity where
toHeaders = const mempty
instance ToJSON RunPipelineActivity where
toJSON RunPipelineActivity'{..}
= object
(catMaybes
[Just ("pipelineActivity" .= _rpaPipelineActivity),
Just ("payloads" .= _rpaPayloads)])
instance ToPath RunPipelineActivity where
toPath = const "/pipelineactivities/run"
instance ToQuery RunPipelineActivity where
toQuery = const mempty
data RunPipelineActivityResponse = RunPipelineActivityResponse'
{ _rparsLogResult :: !(Maybe Text)
, _rparsPayloads :: !(Maybe (List1 Base64))
, _rparsResponseStatus :: !Int
} deriving (Eq, Read, Show, Data, Typeable, Generic)
runPipelineActivityResponse
:: Int
-> RunPipelineActivityResponse
runPipelineActivityResponse pResponseStatus_ =
RunPipelineActivityResponse'
{ _rparsLogResult = Nothing
, _rparsPayloads = Nothing
, _rparsResponseStatus = pResponseStatus_
}
rparsLogResult :: Lens' RunPipelineActivityResponse (Maybe Text)
rparsLogResult = lens _rparsLogResult (\ s a -> s{_rparsLogResult = a})
rparsPayloads :: Lens' RunPipelineActivityResponse (Maybe (NonEmpty ByteString))
rparsPayloads = lens _rparsPayloads (\ s a -> s{_rparsPayloads = a}) . mapping _List1
rparsResponseStatus :: Lens' RunPipelineActivityResponse Int
rparsResponseStatus = lens _rparsResponseStatus (\ s a -> s{_rparsResponseStatus = a})
instance NFData RunPipelineActivityResponse where