Copyright	(c) Moritz Clasmeier 2017 2018
License	BSD3
Maintainer	mtesseract@silverratio.net
Stability	experimental
Portability	POSIX
Safe Haskell	None
Language	Haskell2010

Network.Nakadi.Internal.Http

Description

Internal module containing HTTP client relevant code.

Synopsis

setRequestCheckStatus :: Request -> Request
setRequestIgnoreStatus :: Request -> Request
defaultRequest :: Request
parseRequest_ :: String -> Request
parseRequest :: MonadThrow m => String -> m Request
data HttpException
- = HttpExceptionRequest Request HttpExceptionContent
- | InvalidUrlException String String
proxyHost :: Proxy -> ByteString
proxyPort :: Proxy -> Int
data Request
data Response body
getResponseBody :: Response a -> a
getResponseHeaders :: Response a -> [(HeaderName, ByteString)]
getResponseHeader :: HeaderName -> Response a -> [ByteString]
getResponseStatusCode :: Response a -> Int
getResponseStatus :: Response a -> Status
setRequestProxy :: Maybe Proxy -> Request -> Request
setRequestManager :: Manager -> Request -> Request
setRequestBasicAuth :: ByteString -> ByteString -> Request -> Request
setRequestBodyURLEncoded :: [(ByteString, ByteString)] -> Request -> Request
setRequestBodyFile :: FilePath -> Request -> Request
setRequestBodySource :: Int64 -> ConduitM () ByteString IO () -> Request -> Request
setRequestBodyLBS :: ByteString -> Request -> Request
setRequestBodyJSON :: ToJSON a => a -> Request -> Request
setRequestBody :: RequestBody -> Request -> Request
setRequestQueryString :: Query -> Request -> Request
getRequestQueryString :: Request -> Query
setRequestHeaders :: RequestHeaders -> Request -> Request
setRequestHeader :: HeaderName -> [ByteString] -> Request -> Request
getRequestHeader :: HeaderName -> Request -> [ByteString]
addRequestHeader :: HeaderName -> ByteString -> Request -> Request
setRequestPath :: ByteString -> Request -> Request
setRequestPort :: Int -> Request -> Request
setRequestHost :: ByteString -> Request -> Request
setRequestSecure :: Bool -> Request -> Request
setRequestMethod :: ByteString -> Request -> Request
httpLbs :: MonadIO m => Request -> m (Response ByteString)
parseRequestThrow_ :: String -> Request
parseRequestThrow :: MonadThrow m => String -> m Request
withResponse :: (MonadUnliftIO m, MonadIO n) => Request -> (Response (ConduitM i ByteString n ()) -> m a) -> m a
httpSource :: (MonadResource m, MonadIO n) => Request -> (Response (ConduitM i ByteString n ()) -> ConduitM i o m r) -> ConduitM i o m r
httpSink :: MonadUnliftIO m => Request -> (Response () -> ConduitM ByteString Void m a) -> m a
httpJSONEither :: (MonadIO m, FromJSON a) => Request -> m (Response (Either JSONException a))
httpJSON :: (MonadIO m, FromJSON a) => Request -> m (Response a)
httpNoBody :: MonadIO m => Request -> m (Response ())
httpLBS :: MonadIO m => Request -> m (Response ByteString)
httpBS :: MonadIO m => Request -> m (Response ByteString)
data JSONException
- = JSONParseException Request (Response ()) ParseError
- | JSONConversionException Request (Response Value) String
type ResponseHeaders = [Header]
type RequestHeaders = [Header]
type Header = (HeaderName, ByteString)
type Query = [QueryItem]
type QueryItem = (ByteString, Maybe ByteString)
module Network.HTTP.Types.Status
type StreamConnectCallback m = Response () -> m ()
type HttpErrorCallback m = Request -> HttpException -> RetryStatus -> Bool -> m ()
type ConfigIO = Config IO
data Config m = Config {
- _requestTemplate :: Request
- _requestModifier :: Request -> m Request
- _manager :: Maybe Manager
- _deserializationFailureCallback :: Maybe (ByteString -> Text -> m ())
- _streamConnectCallback :: Maybe (StreamConnectCallback m)
- _logFunc :: Maybe (LogFunc m)
- _retryPolicy :: RetryPolicyM IO
- _http :: HttpBackend m
- _httpErrorCallback :: Maybe (HttpErrorCallback m)
- _flowId :: Maybe FlowId
- _commitStrategy :: CommitStrategy
- _commitTimeout :: Maybe CommitTimeout
- _subscriptionStats :: Maybe SubscriptionStatsConf
- _maxUncommittedEvents :: Maybe Int32
- _batchLimit :: Maybe Int32
- _streamLimit :: Maybe Int32
- _batchFlushTimeout :: Maybe Int32
- _streamTimeout :: Maybe Int32
- _streamKeepAliveLimit :: Maybe Int32
- _worker :: WorkerConfig
}
data HttpBackend b = HttpBackend {
- _httpLbs :: Config b -> Request -> Maybe Manager -> b (Response ByteString)
- _httpResponseOpen :: Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))
- _httpResponseClose :: Response () -> b ()
}
data WorkerConfig = WorkerConfig {
- _nThreads :: Int
}
data SubscriptionStatsConf = SubscriptionStatsConf {
- _showTimeLag :: Bool
}
data SubscriptionCursorWithCounter = SubscriptionCursorWithCounter {
- _cursor :: SubscriptionCursor
- _nEvents :: Int
}
type StagedCursorsMap a = HashMap (EventTypeName, PartitionName) a
data NakadiException
- = BatchPartiallySubmitted [BatchItemResponse]
- | BatchNotSubmitted [BatchItemResponse]
- | BatchValidationFailure [BatchItemResponse]
- | ClientNotAuthenticated Problem
- | AccessForbidden Problem
- | UnprocessableEntity Problem
- | Conflict Problem
- | DeserializationFailure ByteString Text
- | UnexpectedResponse (Response ())
- | NotFound Problem
- | TooManyRequests Problem
- | BadRequest Problem
- | SubscriptionNotFound Problem
- | CursorAlreadyCommitted CursorCommitResults
- | CursorResetInProgress Problem
- | EventTypeNotFound Problem
- | SubscriptionExistsAlready Subscription
- | RequestModificationException SomeException
- | CursorDistanceNoResult
- | StreamIdMissing
- | NakadiUrlMissing
- | ConfigurationMissing
type LogFunc m = LogSource -> LogLevel -> LogStr -> m ()
type LogFuncIO = LogFunc IO
data Problem = Problem {
- problemType :: Maybe URI
- problemTitle :: Text
- problemStatus :: Maybe Status
- problemDetail :: Maybe Text
- problemInstance :: Maybe URI
- problemCustom :: HashMap Text Value
}
newtype CursorOffset = CursorOffset {
- unCursorOffset :: Text
}
newtype EventTypeName = EventTypeName {
- unEventTypeName :: Text
}
newtype PartitionName = PartitionName {
- unPartitionName :: Text
}
newtype PartitionCompactionKey = PartitionCompactionKey {
- unPartitionCompactionKey :: Text
}
newtype CursorToken = CursorToken Text
data Cursor = Cursor {
- _partition :: PartitionName
- _offset :: CursorOffset
}
newtype ApplicationName = ApplicationName {
- unApplicationName :: Text
}
data SubscriptionCursor = SubscriptionCursor {
- _partition :: PartitionName
- _offset :: CursorOffset
- _eventType :: EventTypeName
- _cursorToken :: Text
}
data SubscriptionCursorWithoutToken = SubscriptionCursorWithoutToken {
- _partition :: PartitionName
- _offset :: CursorOffset
- _eventType :: EventTypeName
}
newtype SubscriptionCursorCommit = SubscriptionCursorCommit {
- _items :: [SubscriptionCursor]
}
newtype CursorCommit = CursorCommit {
- _items :: [Cursor]
}
newtype SubscriptionId = SubscriptionId {
- unSubscriptionId :: UUID
}
newtype StreamId = StreamId {
- unStreamId :: Text
}
data SubscriptionEventStream = SubscriptionEventStream {
- _streamId :: StreamId
- _subscriptionId :: SubscriptionId
}
newtype Timestamp = Timestamp {
- unTimestamp :: UTCTime
}
newtype FlowId = FlowId {
- unFlowId :: Text
}
newtype EventId = EventId {
- unEventId :: UUID
}
data Partition = Partition {
- _oldestAvailableOffset :: CursorOffset
- _newestAvailableOffset :: CursorOffset
- _partition :: PartitionName
- _unconsumedEvents :: Maybe Int64
}
data ShiftedCursor = ShiftedCursor {
- _partition :: PartitionName
- _offset :: CursorOffset
- _shift :: Int64
}
data CursorDistanceQuery = CursorDistanceQuery {
- _initialCursor :: Cursor
- _finalCursor :: Cursor
}
newtype CursorDistanceResult = CursorDistanceResult {
- _distance :: Int64
}
data SubscriptionReadFrom
- = SubscriptionReadFromBegin
- | SubscriptionReadFromEnd
- | SubscriptionReadFromCursors
data SubscriptionPosition
- = SubscriptionPositionBegin
- | SubscriptionPositionEnd
- | SubscriptionPositionCursors [SubscriptionCursorWithoutToken]
subscriptionPositionToObject :: SubscriptionPosition -> Object
newtype ConsumerGroup = ConsumerGroup {
- unConsumerGroup :: Text
}
data Subscription = Subscription {
- _id :: SubscriptionId
- _owningApplication :: ApplicationName
- _eventTypes :: [EventTypeName]
- _consumerGroup :: ConsumerGroup
- _createdAt :: Timestamp
- _subscriptionPosition :: SubscriptionPosition
}
data SubscriptionRequest = SubscriptionRequest {
- _owningApplication :: ApplicationName
- _eventTypes :: [EventTypeName]
- _consumerGroup :: Maybe ConsumerGroup
- _subscriptionPosition :: Maybe SubscriptionPosition
}
data PublishingStatus
- = PublishingStatusSubmitted
- | PublishingStatusFailed
- | PublishingStatusAborted
data Step
- = StepNone
- | StepValidating
- | StepPartitioning
- | StepEnriching
- | StepPublishing
data BatchItemResponse = BatchItemResponse {
- _eid :: Maybe EventId
- _publishingStatus :: PublishingStatus
- _step :: Maybe Step
- _detail :: Maybe Text
}
newtype StreamKeepAliveLimit = StreamKeepAliveLimit {
- unStreamKeepAliveLimit :: Int32
}
newtype BatchFlushTimeout = BatchFlushTimeout {
- unBatchFlushTimeout :: Int32
}
data CursorCommitResultType
- = CursorCommitResultCommitted
- | CursorCommitResultOutdated
data CursorCommitResult = CursorCommitResult {
- _cursor :: SubscriptionCursor
- _result :: CursorCommitResultType
}
newtype CursorCommitResults = CursorCommitResults {
- _items :: [CursorCommitResult]
}
data SchemaType = SchemaTypeJson
newtype SchemaVersion = SchemaVersion {
- unSchemaVersion :: Text
}
data EventTypeSchema = EventTypeSchema {
- _version :: Maybe SchemaVersion
- _createdAt :: Maybe Timestamp
- _schemaType :: SchemaType
- _schema :: Text
}
newtype PaginationLink = PaginationLink {
- _href :: Text
}
data PaginationLinks = PaginationLinks {
- _prev :: Maybe PaginationLink
- _next :: Maybe PaginationLink
}
data EventTypeSchemasResponse = EventTypeSchemasResponse {
- _links :: PaginationLinks
- _items :: [EventTypeSchema]
}
data SubscriptionsListResponse = SubscriptionsListResponse {
- _links :: PaginationLinks
- _items :: [Subscription]
}
newtype Offset = Offset {
- unOffset :: Int64
}
newtype Limit = Limit {
- unLimit :: Int64
}
data PartitionState
- = PartitionStateUnassigned
- | PartitionStateReassigning
- | PartitionStateAssigned
data PartitionStat = PartitionStat {
- _partition :: PartitionName
- _state :: PartitionState
- _unconsumedEvents :: Maybe Int64
- _streamId :: Maybe StreamId
- _consumerLagSeconds :: Maybe Int64
}
data SubscriptionEventTypeStats = SubscriptionEventTypeStats {
- _eventType :: EventTypeName
- _partitions :: [PartitionStat]
}
newtype SubscriptionStats = SubscriptionStats {
- _items :: [SubscriptionEventTypeStats]
}
data EventTypeCategory
- = EventTypeCategoryUndefined
- | EventTypeCategoryData
- | EventTypeCategoryBusiness
data PartitionStrategy
- = PartitionStrategyRandom
- | PartitionStrategyUser
- | PartitionStrategyHash
- | PartitionStrategyCustom Text
data EnrichmentStrategy = EnrichmentStrategyMetadata
data CompatibilityMode
- = CompatibilityModeCompatible
- | CompatibilityModeForward
- | CompatibilityModeNone
data CleanupPolicy
- = CleanupPolicyDelete
- | CleanupPolicyCompact
newtype PartitionKeyField = PartitionKeyField {
- unPartitionKeyField :: Text
}
data EventTypeStatistics = EventTypeStatistics {
- _messagesPerMinute :: Int64
- _messageSize :: Int64
- _readParallelism :: Int64
- _writeParallelism :: Int64
}
data EventTypeOptions = EventTypeOptions {
- _retentionTime :: Int64
}
data EventType = EventType {
- _name :: EventTypeName
- _owningApplication :: Maybe ApplicationName
- _category :: Maybe EventTypeCategory
- _enrichmentStrategies :: Maybe [EnrichmentStrategy]
- _partitionStrategy :: Maybe PartitionStrategy
- _compatibilityMode :: Maybe CompatibilityMode
- _schema :: EventTypeSchema
- _partitionKeyFields :: Maybe [PartitionKeyField]
- _cleanupPolicy :: Maybe CleanupPolicy
- _defaultStatistic :: Maybe EventTypeStatistics
- _options :: Maybe EventTypeOptions
}
data EventMetadata = EventMetadata {
- _eid :: EventId
- _occurredAt :: Timestamp
- _parentEids :: Maybe [EventId]
- _partition :: Maybe PartitionName
- _partitionCompactionKey :: Maybe PartitionCompactionKey
}
data EventMetadataEnriched = EventMetadataEnriched {
- _eid :: EventId
- _eventType :: EventTypeName
- _occurredAt :: Timestamp
- _receivedAt :: Timestamp
- _version :: SchemaVersion
- _parentEids :: Maybe [EventId]
- _flowId :: Maybe FlowId
- _partition :: Maybe PartitionName
- _partitionCompactionKey :: Maybe PartitionCompactionKey
}
data SubscriptionEventStreamBatch a = SubscriptionEventStreamBatch {
- _cursor :: SubscriptionCursor
- _events :: Maybe (Vector a)
}
data DataOp
- = DataOpCreation
- | DataOpUpdate
- | DataOpDeletion
- | DataOpSnapshot
data DataChangeEvent a = DataChangeEvent {
- _payload :: a
- _metadata :: EventMetadata
- _dataType :: Text
- _dataOp :: DataOp
}
data DataChangeEventEnriched a = DataChangeEventEnriched {
- _payload :: a
- _metadata :: EventMetadataEnriched
- _dataType :: Text
- _dataOp :: DataOp
}
data BusinessEvent a = BusinessEvent {
- _payload :: a
- _metadata :: EventMetadata
}
data BusinessEventEnriched a = BusinessEventEnriched {
- _payload :: a
- _metadata :: EventMetadataEnriched
}
makeFieldRenamer :: [(String, String)] -> String -> String
parseUUID :: String -> (UUID -> a) -> Value -> Parser a
parseInteger :: (Integral i, Bounded i) => String -> (i -> a) -> Value -> Parser a
parseString :: String -> (Text -> a) -> Value -> Parser a
class (Monad b, Monad m) => MonadNakadiBase b m where
- nakadiLiftBase :: b a -> m a
newtype NakadiBaseT m a = NakadiBaseT {
- runNakadiBaseT :: m a
}
data CommitStrategy
- = CommitSync
- | CommitAsync CommitBufferingStrategy
data CommitBufferingStrategy
- = CommitNoBuffer
- | CommitTimeBuffer Int32
- | CommitSmartBuffer
newtype CommitTimeout = CommitTimeout {
- unCommitTimeout :: Int32
}
data Worker a = Worker {
- _queue :: TBQueue (SubscriptionEventStreamBatch a)
- _async :: Async ()
}
data WorkerRegistry a = WorkerRegistry {
- _workers :: NonEmpty (Worker a)
- _partitionIndexMap :: PartitionIndexMap
}
type PartitionIndexMap = HashMap (PartitionName, EventTypeName) Int
class HasNakadiConfig b r | r -> b where
- nakadiConfig :: r -> Config b
class (MonadNakadiBase b m, MonadThrow b, MonadMask b, MonadThrow m, MonadCatch m) => MonadNakadi b m | m -> b where
- nakadiAsk :: m (Config b)
type MonadNakadiIO = MonadNakadi IO
newtype NakadiT b m a = NakadiT {
- _runNakadiT :: Config b -> m a
}
runNakadiT :: Config b -> NakadiT b m a -> m a
httpJsonBody :: (MonadNakadi b m, FromJSON a) => Status -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> m a
httpJsonNoBody :: MonadNakadi b m => Status -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> m ()
httpJsonBodyStream :: forall b m r. (MonadNakadi b m, MonadMask m) => Status -> [(Status, ByteString -> m NakadiException)] -> (Request -> Request) -> (Response (ConduitM () ByteString m ()) -> m r) -> m r
httpBuildRequest :: MonadNakadi b m => (Request -> Request) -> m Request
conduitDecode :: forall a b m. (FromJSON a, MonadNakadi b m) => ConduitM ByteString a m ()
includeFlowId :: Config b -> Request -> Request
errorClientNotAuthenticated :: MonadThrow m => ByteString -> m NakadiException
errorUnprocessableEntity :: MonadThrow m => ByteString -> m NakadiException
errorAccessForbidden :: MonadThrow m => ByteString -> m NakadiException
errorTooManyRequests :: MonadThrow m => ByteString -> m NakadiException
errorBadRequest :: MonadThrow m => ByteString -> m NakadiException
errorSubscriptionNotFound :: MonadThrow m => ByteString -> m NakadiException
errorCursorAlreadyCommitted :: MonadThrow m => ByteString -> m NakadiException
errorCursorResetInProgress :: MonadThrow m => ByteString -> m NakadiException
errorEventTypeNotFound :: MonadThrow m => ByteString -> m NakadiException
errorSubscriptionExistsAlready :: MonadThrow m => ByteString -> m NakadiException
errorBatchPartiallySubmitted :: MonadThrow m => ByteString -> m NakadiException
errorBatchNotSubmitted :: MonadThrow m => ByteString -> m NakadiException
setRequestQueryParameters :: [(ByteString, ByteString)] -> Request -> Request

Documentation

setRequestCheckStatus :: Request -> Request #

Modify the request so that non-2XX status codes generate a runtime StatusCodeException, by using throwErrorStatusCodes

Since: http-client-0.5.13

setRequestIgnoreStatus :: Request -> Request #

Modify the request so that non-2XX status codes do not generate a runtime StatusCodeException.

Since: http-client-0.4.29

defaultRequest :: Request #

A default request value, a GET request of localhost/:80, with an empty request body.

Note that the default checkResponse does nothing.

Since: http-client-0.4.30

parseRequest_ :: String -> Request #

Same as parseRequest, but parse errors cause an impure exception. Mostly useful for static strings which are known to be correctly formatted.

parseRequest :: MonadThrow m => String -> m Request #

Convert a URL into a Request.

This function defaults some of the values in Request, such as setting method to GET and requestHeaders to [].

Since this function uses MonadThrow, the return monad can be anything that is an instance of MonadThrow, such as IO or Maybe.

You can place the request method at the beginning of the URL separated by a space, e.g.:

@@parseRequest "POST http://httpbin.org/post"@@

Note that the request method must be provided as all capital letters.

A Request created by this function won't cause exceptions on non-2XX response status codes.

To create a request which throws on non-2XX status codes, see parseUrlThrow

Since: http-client-0.4.30

data HttpException #

An exception which may be generated by this library

Since: http-client-0.5.0

Constructors

HttpExceptionRequest Request HttpExceptionContent

Most exceptions are specific to a Request. Inspect the HttpExceptionContent value for details on what occurred.

Since: http-client-0.5.0

InvalidUrlException String String

A URL (first field) is invalid for a given reason (second argument).

Since: http-client-0.5.0

Instances

Show HttpException
Instance details Defined in Network.HTTP.Client.Types Methods showsPrec :: Int -> HttpException -> ShowS # show :: HttpException -> String # showList :: [HttpException] -> ShowS #
Exception HttpException
Instance details Defined in Network.HTTP.Client.Types Methods toException :: HttpException -> SomeException # fromException :: SomeException -> Maybe HttpException # displayException :: HttpException -> String #
HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpErrorCallback :: Lens' (Config m) (Maybe (HttpErrorCallback m))

proxyHost :: Proxy -> ByteString #

The host name of the HTTP proxy.

proxyPort :: Proxy -> Int #

The port number of the HTTP proxy.

data Request #

All information on how to connect to a host and what should be sent in the HTTP request.

If you simply wish to download from a URL, see parseRequest.

The constructor for this data type is not exposed. Instead, you should use either the defaultRequest value, or parseRequest to construct from a URL, and then use the records below to make modifications. This approach allows http-client to add configuration options without breaking backwards compatibility.

For example, to construct a POST request, you could do something like:

initReq <- parseRequest "http://www.example.com/path"
let req = initReq
            { method = "POST"
            }

For more information, please see http://www.yesodweb.com/book/settings-types.

Since 0.1.0

Instances

Show Request
Instance details Defined in Network.HTTP.Client.Types Methods showsPrec :: Int -> Request -> ShowS # show :: Request -> String # showList :: [Request] -> ShowS #
HasNakadiRequestTemplate (Config m) Request
Instance details Defined in Network.Nakadi.Internal.Lenses Methods requestTemplate :: Lens' (Config m) Request
HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpErrorCallback :: Lens' (Config m) (Maybe (HttpErrorCallback m))
HasNakadiRequestModifier (Config m) (Request -> m Request)
Instance details Defined in Network.Nakadi.Internal.Lenses Methods requestModifier :: Lens' (Config m) (Request -> m Request)
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpResponseOpen :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpLbs :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))

data Response body #

A simple representation of the HTTP response.

Since 0.1.0

Instances

Functor Response
Instance details Defined in Network.HTTP.Client.Types Methods fmap :: (a -> b) -> Response a -> Response b # (<$) :: a -> Response b -> Response a #
Foldable Response
Instance details Defined in Network.HTTP.Client.Types Methods fold :: Monoid m => Response m -> m # foldMap :: Monoid m => (a -> m) -> Response a -> m # foldr :: (a -> b -> b) -> b -> Response a -> b # foldr' :: (a -> b -> b) -> b -> Response a -> b # foldl :: (b -> a -> b) -> b -> Response a -> b # foldl' :: (b -> a -> b) -> b -> Response a -> b # foldr1 :: (a -> a -> a) -> Response a -> a # foldl1 :: (a -> a -> a) -> Response a -> a # toList :: Response a -> [a] # null :: Response a -> Bool # length :: Response a -> Int # elem :: Eq a => a -> Response a -> Bool # maximum :: Ord a => Response a -> a # minimum :: Ord a => Response a -> a # sum :: Num a => Response a -> a # product :: Num a => Response a -> a #
Traversable Response
Instance details Defined in Network.HTTP.Client.Types Methods traverse :: Applicative f => (a -> f b) -> Response a -> f (Response b) # sequenceA :: Applicative f => Response (f a) -> f (Response a) # mapM :: Monad m => (a -> m b) -> Response a -> m (Response b) # sequence :: Monad m => Response (m a) -> m (Response a) #
Eq body => Eq (Response body)
Instance details Defined in Network.HTTP.Client.Types Methods (==) :: Response body -> Response body -> Bool # (/=) :: Response body -> Response body -> Bool #
Show body => Show (Response body)
Instance details Defined in Network.HTTP.Client.Types Methods showsPrec :: Int -> Response body -> ShowS # show :: Response body -> String # showList :: [Response body] -> ShowS #
HasNakadiStreamConnectCallback (Config m) (Maybe (StreamConnectCallback m))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods streamConnectCallback :: Lens' (Config m) (Maybe (StreamConnectCallback m))
HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpResponseOpen :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ())))
HasNakadiHttpResponseClose (HttpBackend b) (Response () -> b ())
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpResponseClose :: Lens' (HttpBackend b) (Response () -> b ())
HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))
Instance details Defined in Network.Nakadi.Internal.Lenses Methods httpLbs :: Lens' (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString))

getResponseBody :: Response a -> a #

Get the response body

Since: http-conduit-2.1.10

getResponseHeaders :: Response a -> [(HeaderName, ByteString)] #

Get all response headers

Since: http-conduit-2.1.10

getResponseHeader :: HeaderName -> Response a -> [ByteString] #

Get all response header values with the given name

Since: http-conduit-2.1.10

getResponseStatusCode :: Response a -> Int #

Get the integral status code of the response

Since: http-conduit-2.1.10

getResponseStatus :: Response a -> Status #

Get the status of the response

Since: http-conduit-2.1.10

setRequestProxy :: Maybe Proxy -> Request -> Request #

Override the default proxy server settings

Since: http-conduit-2.1.10

setRequestManager :: Manager -> Request -> Request #

Instead of using the default global Manager, use the supplied Manager.

Since: http-conduit-2.1.10

setRequestBasicAuth #

Arguments

:: ByteString	username
-> ByteString	password
-> Request
-> Request

Set basic auth with the given username and password

Since: http-conduit-2.1.10

setRequestBodyURLEncoded :: [(ByteString, ByteString)] -> Request -> Request #

Set the request body as URL encoded data

Note: This will change the request method to POST and set the content-type to application/x-www-form-urlencoded

Since: http-conduit-2.1.10

setRequestBodyFile :: FilePath -> Request -> Request #

Set the request body as a file