Safe Haskell | None |
---|---|
Language | Haskell2010 |
Framing in HTTP/2( https://tools.ietf.org/html/rfc7540 ).
Synopsis
- data Frame = Frame { }
-
data
FrameHeader
=
FrameHeader
{
- payloadLength :: Int
- flags :: FrameFlags
- streamId :: StreamId
-
data
FramePayload
- = DataFrame ByteString
- | HeadersFrame ( Maybe Priority ) HeaderBlockFragment
- | PriorityFrame Priority
- | RSTStreamFrame ErrorCodeId
- | SettingsFrame SettingsList
- | PushPromiseFrame StreamId HeaderBlockFragment
- | PingFrame ByteString
- | GoAwayFrame StreamId ErrorCodeId ByteString
- | WindowUpdateFrame WindowSize
- | ContinuationFrame HeaderBlockFragment
- | UnknownFrame FrameType ByteString
- type HeaderBlockFragment = ByteString
- type Padding = ByteString
- isPaddingDefined :: FramePayload -> Bool
- encodeFrame :: EncodeInfo -> FramePayload -> ByteString
- encodeFrameChunks :: EncodeInfo -> FramePayload -> [ ByteString ]
- encodeFrameHeader :: FrameTypeId -> FrameHeader -> ByteString
- encodeFrameHeaderBuf :: FrameTypeId -> FrameHeader -> Ptr Word8 -> IO ()
- encodeFramePayload :: EncodeInfo -> FramePayload -> ( FrameHeader , [ ByteString ])
- data EncodeInfo = EncodeInfo { }
- encodeInfo :: ( FrameFlags -> FrameFlags ) -> Int -> EncodeInfo
- decodeFrame :: Settings -> ByteString -> Either HTTP2Error Frame
- decodeFrameHeader :: ByteString -> ( FrameTypeId , FrameHeader )
- checkFrameHeader :: Settings -> ( FrameTypeId , FrameHeader ) -> Either HTTP2Error ( FrameTypeId , FrameHeader )
- decodeFramePayload :: FrameTypeId -> FramePayloadDecoder
- type FramePayloadDecoder = FrameHeader -> ByteString -> Either HTTP2Error FramePayload
- decodeDataFrame :: FramePayloadDecoder
- decodeHeadersFrame :: FramePayloadDecoder
- decodePriorityFrame :: FramePayloadDecoder
- decoderstStreamFrame :: FramePayloadDecoder
- decodeSettingsFrame :: FramePayloadDecoder
- decodePushPromiseFrame :: FramePayloadDecoder
- decodePingFrame :: FramePayloadDecoder
- decodeGoAwayFrame :: FramePayloadDecoder
- decodeWindowUpdateFrame :: FramePayloadDecoder
- decodeContinuationFrame :: FramePayloadDecoder
- data FrameTypeId
- framePayloadToFrameTypeId :: FramePayload -> FrameTypeId
- type FrameType = Word8
- fromFrameTypeId :: FrameTypeId -> FrameType
- toFrameTypeId :: FrameType -> FrameTypeId
- data Priority = Priority { }
- type Weight = Int
- defaultPriority :: Priority
- highestPriority :: Priority
- defaultWeight :: Weight
- type StreamId = Int
- isControl :: StreamId -> Bool
- isClientInitiated :: StreamId -> Bool
- isServerInitiated :: StreamId -> Bool
- isRequest :: StreamId -> Bool
- isResponse :: StreamId -> Bool
- testExclusive :: StreamId -> Bool
- setExclusive :: StreamId -> StreamId
- clearExclusive :: StreamId -> StreamId
- type FrameFlags = Word8
- defaultFlags :: FrameFlags
- testEndStream :: FrameFlags -> Bool
- testAck :: FrameFlags -> Bool
- testEndHeader :: FrameFlags -> Bool
- testPadded :: FrameFlags -> Bool
- testPriority :: FrameFlags -> Bool
- setEndStream :: FrameFlags -> FrameFlags
- setAck :: FrameFlags -> FrameFlags
- setEndHeader :: FrameFlags -> FrameFlags
- setPadded :: FrameFlags -> FrameFlags
- setPriority :: FrameFlags -> FrameFlags
- type SettingsList = [( SettingsKeyId , SettingsValue )]
- data SettingsKeyId
- type SettingsValue = Int
- fromSettingsKeyId :: SettingsKeyId -> Word16
- toSettingsKeyId :: Word16 -> Maybe SettingsKeyId
- checkSettingsList :: SettingsList -> Maybe HTTP2Error
- data Settings = Settings { }
- defaultSettings :: Settings
- updateSettings :: Settings -> SettingsList -> Settings
- type WindowSize = Int
- defaultInitialWindowSize :: WindowSize
- maxWindowSize :: WindowSize
- isWindowOverflow :: WindowSize -> Bool
- type ErrorCode = Word32
- data ErrorCodeId
- fromErrorCodeId :: ErrorCodeId -> ErrorCode
- toErrorCodeId :: ErrorCode -> ErrorCodeId
- data HTTP2Error
- errorCodeId :: HTTP2Error -> ErrorCodeId
- connectionPreface :: ByteString
- connectionPrefaceLength :: Int
- frameHeaderLength :: Int
- maxPayloadLength :: Int
- recommendedConcurrency :: Int
Frame
The data type for HTTP/2 frames.
data FrameHeader Source #
The data type for HTTP/2 frame headers.
FrameHeader | |
|
Instances
Eq FrameHeader Source # | |
Defined in Network.HTTP2.Frame.Types (==) :: FrameHeader -> FrameHeader -> Bool Source # (/=) :: FrameHeader -> FrameHeader -> Bool Source # |
|
Read FrameHeader Source # | |
Defined in Network.HTTP2.Frame.Types readsPrec :: Int -> ReadS FrameHeader Source # readList :: ReadS [ FrameHeader ] Source # readPrec :: ReadPrec FrameHeader Source # readListPrec :: ReadPrec [ FrameHeader ] Source # |
|
Show FrameHeader Source # | |
Defined in Network.HTTP2.Frame.Types |
data FramePayload Source #
The data type for HTTP/2 frame payloads.
Instances
Eq FramePayload Source # | |
Defined in Network.HTTP2.Frame.Types (==) :: FramePayload -> FramePayload -> Bool Source # (/=) :: FramePayload -> FramePayload -> Bool Source # |
|
Read FramePayload Source # | |
Defined in Network.HTTP2.Frame.Types readsPrec :: Int -> ReadS FramePayload Source # readList :: ReadS [ FramePayload ] Source # readPrec :: ReadPrec FramePayload Source # readListPrec :: ReadPrec [ FramePayload ] Source # |
|
Show FramePayload Source # | |
Defined in Network.HTTP2.Frame.Types |
type HeaderBlockFragment = ByteString Source #
The type for fragments of a header encoded with HPACK.
type Padding = ByteString Source #
The type for padding in payloads.
isPaddingDefined :: FramePayload -> Bool Source #
Checking if padding is defined in this frame type.
>>>
isPaddingDefined $ DataFrame ""
True>>>
isPaddingDefined $ PingFrame ""
False
Encoding
encodeFrame :: EncodeInfo -> FramePayload -> ByteString Source #
Encoding an HTTP/2 frame to
ByteString
.
This function is not efficient enough for high performace
program because of the concatenation of
ByteString
.
>>>
encodeFrame (encodeInfo id 1) (DataFrame "body")
"\NUL\NUL\EOT\NUL\NUL\NUL\NUL\NUL\SOHbody"
encodeFrameChunks :: EncodeInfo -> FramePayload -> [ ByteString ] Source #
Encoding an HTTP/2 frame to [
ByteString
].
This is suitable for sendMany.
encodeFrameHeader :: FrameTypeId -> FrameHeader -> ByteString Source #
Encoding an HTTP/2 frame header. The frame header must be completed.
encodeFrameHeaderBuf :: FrameTypeId -> FrameHeader -> Ptr Word8 -> IO () Source #
Writing an encoded HTTP/2 frame header to the buffer. The length of the buffer must be larger than or equal to 9 bytes.
encodeFramePayload :: EncodeInfo -> FramePayload -> ( FrameHeader , [ ByteString ]) Source #
Encoding an HTTP/2 frame payload. This returns a complete frame header and chunks of payload.
data EncodeInfo Source #
Auxiliary information for frame encoding.
EncodeInfo | |
|
Instances
Read EncodeInfo Source # | |
Defined in Network.HTTP2.Frame.Encode readsPrec :: Int -> ReadS EncodeInfo Source # readList :: ReadS [ EncodeInfo ] Source # readPrec :: ReadPrec EncodeInfo Source # readListPrec :: ReadPrec [ EncodeInfo ] Source # |
|
Show EncodeInfo Source # | |
Defined in Network.HTTP2.Frame.Encode |
:: ( FrameFlags -> FrameFlags ) | |
-> Int |
stream identifier |
-> EncodeInfo |
A smart builder of
EncodeInfo
.
>>>
encodeInfo setAck 0
EncodeInfo {encodeFlags = 1, encodeStreamId = 0, encodePadding = Nothing}
Decoding
:: Settings |
HTTP/2 settings |
-> ByteString |
Input byte-stream |
-> Either HTTP2Error Frame |
Decoded frame |
Decoding an HTTP/2 frame to
ByteString
.
The second argument must be include the entire of frame.
So, this function is not useful for real applications
but useful for testing.
decodeFrameHeader :: ByteString -> ( FrameTypeId , FrameHeader ) Source #
Decoding an HTTP/2 frame header. Must supply 9 bytes.
checkFrameHeader :: Settings -> ( FrameTypeId , FrameHeader ) -> Either HTTP2Error ( FrameTypeId , FrameHeader ) Source #
Checking a frame header and reporting an error if any.
>>>
checkFrameHeader defaultSettings (FrameData,(FrameHeader 100 0 0))
Left (ConnectionError ProtocolError "cannot used in control stream")
Decoding payload
decodeFramePayload :: FrameTypeId -> FramePayloadDecoder Source #
Decoding an HTTP/2 frame payload. This function is considered to return a frame payload decoder according to a frame type.
type FramePayloadDecoder = FrameHeader -> ByteString -> Either HTTP2Error FramePayload Source #
The type for frame payload decoder.
decodeDataFrame :: FramePayloadDecoder Source #
Frame payload decoder for DATA frame.
decodeHeadersFrame :: FramePayloadDecoder Source #
Frame payload decoder for HEADERS frame.
decodePriorityFrame :: FramePayloadDecoder Source #
Frame payload decoder for PRIORITY frame.
decoderstStreamFrame :: FramePayloadDecoder Source #
Frame payload decoder for RST_STREAM frame.
decodeSettingsFrame :: FramePayloadDecoder Source #
Frame payload decoder for SETTINGS frame.
decodePushPromiseFrame :: FramePayloadDecoder Source #
Frame payload decoder for PUSH_PROMISE frame.
decodePingFrame :: FramePayloadDecoder Source #
Frame payload decoder for PING frame.
decodeGoAwayFrame :: FramePayloadDecoder Source #
Frame payload decoder for GOAWAY frame.
decodeWindowUpdateFrame :: FramePayloadDecoder Source #
Frame payload decoder for WINDOW_UPDATE frame.
decodeContinuationFrame :: FramePayloadDecoder Source #
Frame payload decoder for CONTINUATION frame.
Frame type ID
data FrameTypeId Source #
The type for frame type.
FrameData | |
FrameHeaders | |
FramePriority | |
FrameRSTStream | |
FrameSettings | |
FramePushPromise | |
FramePing | |
FrameGoAway | |
FrameWindowUpdate | |
FrameContinuation | |
FrameUnknown FrameType |
Instances
Eq FrameTypeId Source # | |
Defined in Network.HTTP2.Frame.Types (==) :: FrameTypeId -> FrameTypeId -> Bool Source # (/=) :: FrameTypeId -> FrameTypeId -> Bool Source # |
|
Ord FrameTypeId Source # | |
Defined in Network.HTTP2.Frame.Types compare :: FrameTypeId -> FrameTypeId -> Ordering Source # (<) :: FrameTypeId -> FrameTypeId -> Bool Source # (<=) :: FrameTypeId -> FrameTypeId -> Bool Source # (>) :: FrameTypeId -> FrameTypeId -> Bool Source # (>=) :: FrameTypeId -> FrameTypeId -> Bool Source # max :: FrameTypeId -> FrameTypeId -> FrameTypeId Source # min :: FrameTypeId -> FrameTypeId -> FrameTypeId Source # |
|
Show FrameTypeId Source # | |
Defined in Network.HTTP2.Frame.Types |
framePayloadToFrameTypeId :: FramePayload -> FrameTypeId Source #
Getting
FrameType
from
FramePayload
.
>>>
framePayloadToFrameTypeId (DataFrame "body")
FrameData
Frame type
fromFrameTypeId :: FrameTypeId -> FrameType Source #
Converting
FrameTypeId
to
FrameType
.
>>>
fromFrameTypeId FrameData
0>>>
fromFrameTypeId FrameContinuation
9>>>
fromFrameTypeId (FrameUnknown 10)
10
toFrameTypeId :: FrameType -> FrameTypeId Source #
Converting
FrameType
to
FrameTypeId
.
>>>
toFrameTypeId 0
FrameData>>>
toFrameTypeId 9
FrameContinuation>>>
toFrameTypeId 10
FrameUnknown 10
Priority
Type for stream priority
defaultPriority :: Priority Source #
Default priority which depends on stream 0.
>>>
defaultPriority
Priority {exclusive = False, streamDependency = 0, weight = 16}
highestPriority :: Priority Source #
Highest priority which depends on stream 0.
>>>
highestPriority
Priority {exclusive = False, streamDependency = 0, weight = 256}
defaultWeight :: Weight Source #
Deprecated: Don't use this
Default weight.
>>>
defaultWeight
16
Stream identifier
isControl :: StreamId -> Bool Source #
Checking if the stream identifier for control.
>>>
isControl 0
True>>>
isControl 1
False
isClientInitiated :: StreamId -> Bool Source #
Checking if the stream identifier is from a client.
>>>
isClientInitiated 0
False>>>
isClientInitiated 1
True
isServerInitiated :: StreamId -> Bool Source #
Checking if the stream identifier is from a server.
>>>
isServerInitiated 0
False>>>
isServerInitiated 2
True
isRequest :: StreamId -> Bool Source #
Deprecated: Use isClientInitiated instead
Checking if the stream identifier for request.
>>>
isRequest 0
False>>>
isRequest 1
True
isResponse :: StreamId -> Bool Source #
Deprecated: Use isServerInitiated instead
Checking if the stream identifier for response.
>>>
isResponse 0
False>>>
isResponse 2
True
Stream identifier related
testExclusive :: StreamId -> Bool Source #
Checking if the exclusive flag is set.
setExclusive :: StreamId -> StreamId Source #
Setting the exclusive flag.
clearExclusive :: StreamId -> StreamId Source #
Clearing the exclusive flag.
Flags
type FrameFlags = Word8 Source #
The type for flags.
defaultFlags :: FrameFlags Source #
The initial value of flags. No flags are set.
>>>
defaultFlags
0
testEndStream :: FrameFlags -> Bool Source #
Checking if the END_STREAM flag is set. >>> testEndStream 0x1 True
testAck :: FrameFlags -> Bool Source #
Checking if the ACK flag is set. >>> testAck 0x1 True
testEndHeader :: FrameFlags -> Bool Source #
Checking if the END_HEADERS flag is set.
>>>
testEndHeader 0x4
True
testPadded :: FrameFlags -> Bool Source #
Checking if the PADDED flag is set.
>>>
testPadded 0x8
True
testPriority :: FrameFlags -> Bool Source #
Checking if the PRIORITY flag is set.
>>>
testPriority 0x20
True
setEndStream :: FrameFlags -> FrameFlags Source #
Setting the END_STREAM flag.
>>>
setEndStream 0
1
setAck :: FrameFlags -> FrameFlags Source #
Setting the ACK flag.
>>>
setAck 0
1
setEndHeader :: FrameFlags -> FrameFlags Source #
Setting the END_HEADERS flag.
>>>
setEndHeader 0
4
setPadded :: FrameFlags -> FrameFlags Source #
Setting the PADDED flag.
>>>
setPadded 0
8
setPriority :: FrameFlags -> FrameFlags Source #
Setting the PRIORITY flag.
>>>
setPriority 0
32
SettingsList
type SettingsList = [( SettingsKeyId , SettingsValue )] Source #
Association list of SETTINGS.
data SettingsKeyId Source #
The type for SETTINGS key.
SettingsHeaderTableSize | |
SettingsEnablePush | |
SettingsMaxConcurrentStreams | |
SettingsInitialWindowSize | |
SettingsMaxFrameSize | |
SettingsMaxHeaderBlockSize |
Instances
type SettingsValue = Int Source #
The type for raw SETTINGS value.
fromSettingsKeyId :: SettingsKeyId -> Word16 Source #
Converting
SettingsKeyId
to raw value.
>>>
fromSettingsKeyId SettingsHeaderTableSize
1>>>
fromSettingsKeyId SettingsMaxHeaderBlockSize
6
toSettingsKeyId :: Word16 -> Maybe SettingsKeyId Source #
Converting raw value to
SettingsKeyId
.
>>>
toSettingsKeyId 0
Nothing>>>
toSettingsKeyId 1
Just SettingsHeaderTableSize>>>
toSettingsKeyId 6
Just SettingsMaxHeaderBlockSize>>>
toSettingsKeyId 7
Nothing
checkSettingsList :: SettingsList -> Maybe HTTP2Error Source #
Checking
SettingsList
and reporting an error if any.
>>>
checkSettingsList [(SettingsEnablePush,2)]
Just (ConnectionError ProtocolError "enable push must be 0 or 1")
Settings
Cooked version of settings. This is suitable to be stored in a HTTP/2 context.
defaultSettings :: Settings Source #
The default settings.
>>>
defaultSettings
Settings {headerTableSize = 4096, enablePush = True, maxConcurrentStreams = Nothing, initialWindowSize = 65535, maxFrameSize = 16384, maxHeaderBlockSize = Nothing}
updateSettings :: Settings -> SettingsList -> Settings Source #
Updating settings.
>>>
updateSettings defaultSettings [(SettingsEnablePush,0),(SettingsMaxHeaderBlockSize,200)]
Settings {headerTableSize = 4096, enablePush = False, maxConcurrentStreams = Nothing, initialWindowSize = 65535, maxFrameSize = 16384, maxHeaderBlockSize = Just 200}
Window
type WindowSize = Int Source #
The type for window size.
defaultInitialWindowSize :: WindowSize Source #
The default initial window size.
>>>
defaultInitialWindowSize
65535
maxWindowSize :: WindowSize Source #
The maximum window size.
>>>
maxWindowSize
2147483647
isWindowOverflow :: WindowSize -> Bool Source #
Checking if a window size exceeds the maximum window size.
>>>
isWindowOverflow 10
False>>>
isWindowOverflow maxWindowSize
False>>>
isWindowOverflow (maxWindowSize + 1)
True
Error code
data ErrorCodeId Source #
The type for error code. See https://tools.ietf.org/html/rfc7540#section-7 .
Instances
Eq ErrorCodeId Source # | |
Defined in Network.HTTP2.Frame.Types (==) :: ErrorCodeId -> ErrorCodeId -> Bool Source # (/=) :: ErrorCodeId -> ErrorCodeId -> Bool Source # |
|
Ord ErrorCodeId Source # | |
Defined in Network.HTTP2.Frame.Types compare :: ErrorCodeId -> ErrorCodeId -> Ordering Source # (<) :: ErrorCodeId -> ErrorCodeId -> Bool Source # (<=) :: ErrorCodeId -> ErrorCodeId -> Bool Source # (>) :: ErrorCodeId -> ErrorCodeId -> Bool Source # (>=) :: ErrorCodeId -> ErrorCodeId -> Bool Source # max :: ErrorCodeId -> ErrorCodeId -> ErrorCodeId Source # min :: ErrorCodeId -> ErrorCodeId -> ErrorCodeId Source # |
|
Read ErrorCodeId Source # | |
Defined in Network.HTTP2.Frame.Types readsPrec :: Int -> ReadS ErrorCodeId Source # readList :: ReadS [ ErrorCodeId ] Source # readPrec :: ReadPrec ErrorCodeId Source # readListPrec :: ReadPrec [ ErrorCodeId ] Source # |
|
Show ErrorCodeId Source # | |
Defined in Network.HTTP2.Frame.Types |
fromErrorCodeId :: ErrorCodeId -> ErrorCode Source #
Converting
ErrorCodeId
to
ErrorCode
.
>>>
fromErrorCodeId NoError
0>>>
fromErrorCodeId InadequateSecurity
12
toErrorCodeId :: ErrorCode -> ErrorCodeId Source #
Converting
ErrorCode
to
ErrorCodeId
.
>>>
toErrorCodeId 0
NoError>>>
toErrorCodeId 0xc
InadequateSecurity>>>
toErrorCodeId 0xe
UnknownErrorCode 14
Error
data HTTP2Error Source #
The connection error or the stream error.
Instances
Eq HTTP2Error Source # | |
Defined in Network.HTTP2.Frame.Types (==) :: HTTP2Error -> HTTP2Error -> Bool Source # (/=) :: HTTP2Error -> HTTP2Error -> Bool Source # |
|
Read HTTP2Error Source # | |
Defined in Network.HTTP2.Frame.Types readsPrec :: Int -> ReadS HTTP2Error Source # readList :: ReadS [ HTTP2Error ] Source # readPrec :: ReadPrec HTTP2Error Source # readListPrec :: ReadPrec [ HTTP2Error ] Source # |
|
Show HTTP2Error Source # | |
Defined in Network.HTTP2.Frame.Types |
|
Exception HTTP2Error Source # | |
Defined in Network.HTTP2.Frame.Types toException :: HTTP2Error -> SomeException Source # fromException :: SomeException -> Maybe HTTP2Error Source # displayException :: HTTP2Error -> String Source # |
errorCodeId :: HTTP2Error -> ErrorCodeId Source #
Obtaining
ErrorCodeId
from
HTTP2Error
.
Predefined values
connectionPreface :: ByteString Source #
The preface of HTTP/2.
>>>
connectionPreface
"PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n"
connectionPrefaceLength :: Int Source #
Length of the preface.
>>>
connectionPrefaceLength
24
frameHeaderLength :: Int Source #
The length of HTTP/2 frame header.
>>>
frameHeaderLength
9
maxPayloadLength :: Int Source #
The maximum length of HTTP/2 payload.
>>>
maxPayloadLength
16384
recommendedConcurrency :: Int Source #
Default concurrency.
>>>
recommendedConcurrency
100