nakadi-client-0.6.1.0: Client library for the Nakadi Event Broker

Copyright(c) Moritz Clasmeier 2017 2018
LicenseBSD3
Maintainermtesseract@silverratio.net
Stabilityexperimental
PortabilityPOSIX
Safe HaskellNone
LanguageHaskell2010

Network.Nakadi.Internal.Http

Description

Internal module containing HTTP client relevant code.

Synopsis

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

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

HasNakadiRequestTemplate (Config m) Request 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiRequestModifier (Config m) (Request -> m Request) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

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

HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

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

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

Note: This will not modify the request method. For that, please use requestMethod. You likely don't want the default of GET.

Since: http-conduit-2.1.10

setRequestBodySource #

Arguments

:: Int64

length of source

-> ConduitM () ByteString IO () 
-> Request 
-> Request 

Set the request body as a Source

Note: This will not modify the request method. For that, please use requestMethod. You likely don't want the default of GET.

Since: http-conduit-2.1.10

setRequestBodyLBS :: ByteString -> Request -> Request #

Set the request body as a lazy ByteString

Note: This will not modify the request method. For that, please use requestMethod. You likely don't want the default of GET.

Since: http-conduit-2.1.10

setRequestBodyJSON :: ToJSON a => a -> Request -> Request #

Set the request body as a JSON value

Note: This will not modify the request method. For that, please use requestMethod. You likely don't want the default of GET.

This also sets the Content-Type to application/json; charset=utf-8

Since: http-conduit-2.1.10

setRequestBody :: RequestBody -> Request -> Request #

Set the request body to the given RequestBody. You may want to consider using one of the convenience functions in the modules, e.g. requestBodyJSON.

Note: This will not modify the request method. For that, please use requestMethod. You likely don't want the default of GET.

Since: http-conduit-2.1.10

setRequestQueryString :: Query -> Request -> Request #

Set the query string parameters

Since: http-conduit-2.1.10

getRequestQueryString :: Request -> Query #

Get the query string parameters

Since: http-conduit-2.1.10

setRequestHeaders :: [(HeaderName, ByteString)] -> Request -> Request #

Set the request headers, wiping out all previously set headers. This means if you use setRequestHeaders to set some headers and also use one of the other setters that modifies the content-type header (such as setRequestBodyJSON), be sure that setRequestHeaders is evaluated first.

Since: http-conduit-2.1.10

setRequestHeader :: HeaderName -> [ByteString] -> Request -> Request #

Set the given request header to the given list of values. Removes any previously set header values with the same name.

Since: http-conduit-2.1.10

getRequestHeader :: HeaderName -> Request -> [ByteString] #

Get all request header values for the given name

Since: http-conduit-2.1.10

addRequestHeader :: HeaderName -> ByteString -> Request -> Request #

Add a request header name/value combination

Since: http-conduit-2.1.10

setRequestPath :: ByteString -> Request -> Request #

Lens for the requested path info of the request

Since: http-conduit-2.1.10

setRequestPort :: Int -> Request -> Request #

Set the destination port of the request

Since: http-conduit-2.1.10

setRequestHost :: ByteString -> Request -> Request #

Set the destination host of the request

Since: http-conduit-2.1.10

setRequestSecure :: Bool -> Request -> Request #

Set whether this is a secureHTTPS (True) or insecureHTTP (False) request

Since: http-conduit-2.1.10

setRequestMethod :: ByteString -> Request -> Request #

Set the request method

Since: http-conduit-2.1.10

httpLbs :: MonadIO m => Request -> m (Response ByteString) #

Alternate spelling of httpLBS

Since: http-conduit-2.1.10

parseRequestThrow_ :: String -> Request #

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

Since: http-conduit-2.3.2

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

Same as parseRequest, except will throw an HttpException in the event of a non-2XX response. This uses throwErrorStatusCodes to implement checkResponse.

Exactly the same as parseUrlThrow, but has a name that is more consistent with the other parseRequest functions.

Since: http-conduit-2.3.2

withResponse :: (MonadUnliftIO m, MonadIO n) => Request -> (Response (ConduitM i ByteString n ()) -> m a) -> m a #

Perform an action with the given request. This employes the bracket pattern.

This is similar to httpSource, but does not require MonadResource and allows the result to not contain a ConduitM value.

Since: http-conduit-2.2.3

httpSource :: (MonadResource m, MonadIO n) => Request -> (Response (ConduitM i ByteString n ()) -> ConduitM i o m r) -> ConduitM i o m r #

Perform an HTTP request, and get the response body as a Source.

The second argument to this function tells us how to make the Source from the Response itself. This allows you to perform actions with the status or headers, for example, in addition to the raw bytes themselves. If you just care about the response body, you can use getResponseBody as the second argument here.

{-# LANGUAGE OverloadedStrings #-}
import           Control.Monad.IO.Class       (liftIO)
import           Control.Monad.Trans.Resource (runResourceT)
import           Data.Conduit                 (($$))
import qualified Data.Conduit.Binary          as CB
import qualified Data.Conduit.List            as CL
import           Network.HTTP.Simple
import           System.IO                    (stdout)

main :: IO ()
main =
    runResourceT
        $ httpSource "http://httpbin.org/robots.txt" getSrc
       $$ CB.sinkHandle stdout
  where
    getSrc res = do
        liftIO $ print (getResponseStatus res, getResponseHeaders res)
        getResponseBody res

Since: http-conduit-2.2.1

httpSink :: MonadUnliftIO m => Request -> (Response () -> ConduitM ByteString Void m a) -> m a #

Perform an HTTP request and consume the body with the given Sink

Since: http-conduit-2.1.10

httpJSONEither :: (MonadIO m, FromJSON a) => Request -> m (Response (Either JSONException a)) #

Perform an HTTP request and parse the body as JSON. In the event of an JSON parse errors, a Left value will be returned.

Since: http-conduit-2.1.10

httpJSON :: (MonadIO m, FromJSON a) => Request -> m (Response a) #

Perform an HTTP request and parse the body as JSON. In the event of an JSON parse errors, a JSONException runtime exception will be thrown.

Since: http-conduit-2.1.10

httpNoBody :: MonadIO m => Request -> m (Response ()) #

Perform an HTTP request and ignore the response body.

Since: http-conduit-2.2.2

httpLBS :: MonadIO m => Request -> m (Response ByteString) #

Perform an HTTP request and return the body as a lazy ByteString. Note that the entire value will be read into memory at once (no lazy I/O will be performed). The advantage of a lazy ByteString here (versus using httpBS) is--if needed--a better in-memory representation.

Since: http-conduit-2.1.10

httpBS :: MonadIO m => Request -> m (Response ByteString) #

Perform an HTTP request and return the body as a ByteString.

Since: http-conduit-2.2.4

type Query = [QueryItem] #

Query.

General form: a=b&c=d, but if the value is Nothing, it becomes a&c=d.

type StreamConnectCallback m = Response () -> m () Source #

Config

type HttpErrorCallback m = Request -> HttpException -> RetryStatus -> Bool -> m () Source #

Type synonym for user-provided callbacks which are used for HTTP Errror propagation.

data Config m Source #

Instances
HasNakadiWorker (Config m) WorkerConfig 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiRequestTemplate (Config m) Request 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCommitStrategy (Config m) CommitStrategy 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionStats (Config m) (Maybe SubscriptionStatsConf) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiStreamTimeout (Config m) (Maybe Int32) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiStreamLimit (Config m) (Maybe Int32) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiStreamKeepAliveLimit (Config m) (Maybe Int32) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiStreamConnectCallback (Config m) (Maybe (StreamConnectCallback m)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiRetryPolicy (Config m) (RetryPolicyM IO) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiMaxUncommittedEvents (Config m) (Maybe Int32) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiManager (Config m) (Maybe Manager) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

manager :: Lens' (Config m) (Maybe Manager)

HasNakadiLogFunc (Config m) (Maybe (LogFunc m)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

logFunc :: Lens' (Config m) (Maybe (LogFunc m))

HasNakadiHttpErrorCallback (Config m) (Maybe (HttpErrorCallback m)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiHttp (Config m) (HttpBackend m) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

http :: Lens' (Config m) (HttpBackend m)

HasNakadiFlowId (Config m) (Maybe FlowId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

flowId :: Lens' (Config m) (Maybe FlowId)

HasNakadiDeserializationFailureCallback (Config m) (Maybe (ByteString -> Text -> m ())) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiBatchLimit (Config m) (Maybe Int32) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiBatchFlushTimeout (Config m) (Maybe Int32) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiRequestModifier (Config m) (Request -> m Request) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiHttpLbs (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response ByteString)) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

data HttpBackend b Source #

Instances
HasNakadiHttp (Config m) (HttpBackend m) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

http :: Lens' (Config m) (HttpBackend m)

HasNakadiHttpResponseOpen (HttpBackend b) (Config b -> Request -> Maybe Manager -> b (Response (ConduitM () ByteString b ()))) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

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

data WorkerConfig Source #

Constructors

WorkerConfig 

Fields

Instances
HasNakadiNThreads WorkerConfig Int 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiWorker (Config m) WorkerConfig 
Instance details

Defined in Network.Nakadi.Internal.Lenses

data SubscriptionStatsConf Source #

Constructors

SubscriptionStatsConf 

Fields

Instances
HasNakadiShowTimeLag SubscriptionStatsConf Bool 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionStats (Config m) (Maybe SubscriptionStatsConf) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type LogFunc m = LogSource -> LogLevel -> LogStr -> m () Source #

Type of a logger callback provided to nakadi-client for logging purposes.

type LogFuncIO = LogFunc IO Source #

LogFunc specialized to IO.

data Problem Source #

Type for RFC7807 Problem objects.

Instances
Eq Problem Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Problem

Methods

(==) :: Problem -> Problem -> Bool #

(/=) :: Problem -> Problem -> Bool #

Show Problem Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Problem

Generic Problem Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Problem

Associated Types

type Rep Problem :: * -> * #

Methods

from :: Problem -> Rep Problem x #

to :: Rep Problem x -> Problem #

ToJSON Problem Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Problem

FromJSON Problem Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Problem

type Rep Problem Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Problem

newtype CursorOffset Source #

Type for cursor offsets.

Constructors

CursorOffset 

Fields

Instances
Eq CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorOffset :: * -> * #

Hashable CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOffset Cursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOffset SubscriptionCursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOldestAvailableOffset Partition CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiNewestAvailableOffset Partition CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorOffset Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorOffset = D1 (MetaData "CursorOffset" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "CursorOffset" PrefixI True) (S1 (MetaSel (Just "unCursorOffset") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype EventTypeName Source #

Type for event type names.

Constructors

EventTypeName 

Fields

Instances
Eq EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventTypeName :: * -> * #

Hashable EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiEventType SubscriptionCursor EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventType EventMetadataEnriched EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiName EventType EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes SubscriptionRequest [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes Subscription [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartitionIndexMap (WorkerRegistry a) PartitionIndexMap 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventTypeName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventTypeName = D1 (MetaData "EventTypeName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "EventTypeName" PrefixI True) (S1 (MetaSel (Just "unEventTypeName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionName Source #

Type for partition names.

Constructors

PartitionName 

Fields

Instances
Eq PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PartitionName :: * -> * #

Hashable PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartition Cursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition SubscriptionCursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition Partition PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition PartitionStat PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition EventMetadata (Maybe PartitionName) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition EventMetadataEnriched (Maybe PartitionName) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartitionIndexMap (WorkerRegistry a) PartitionIndexMap 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep PartitionName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PartitionName = D1 (MetaData "PartitionName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "PartitionName" PrefixI True) (S1 (MetaSel (Just "unPartitionName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype PartitionCompactionKey Source #

Type for partition compaction keys.

Constructors

PartitionCompactionKey 

Fields

Instances
Eq PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PartitionCompactionKey :: * -> * #

Hashable PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartitionCompactionKey EventMetadata (Maybe PartitionCompactionKey) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartitionCompactionKey EventMetadataEnriched (Maybe PartitionCompactionKey) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep PartitionCompactionKey Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PartitionCompactionKey = D1 (MetaData "PartitionCompactionKey" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "PartitionCompactionKey" PrefixI True) (S1 (MetaSel (Just "unPartitionCompactionKey") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data Cursor Source #

Type for cursors.

Constructors

Cursor 
Instances
Eq Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

(==) :: Cursor -> Cursor -> Bool #

(/=) :: Cursor -> Cursor -> Bool #

Ord Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Cursor :: * -> * #

Methods

from :: Cursor -> Rep Cursor x #

to :: Rep Cursor x -> Cursor #

Hashable Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> Cursor -> Int #

hash :: Cursor -> Int #

ToJSON Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiPartition Cursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOffset Cursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiInitialCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiFinalCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems CursorCommit [Cursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep Cursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Cursor = D1 (MetaData "Cursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "Cursor" PrefixI True) (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset)))

newtype ApplicationName Source #

Type for application names.

Constructors

ApplicationName 
Instances
Eq ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep ApplicationName :: * -> * #

Hashable ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOwningApplication SubscriptionRequest ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOwningApplication Subscription ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOwningApplication EventType (Maybe ApplicationName) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep ApplicationName Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep ApplicationName = D1 (MetaData "ApplicationName" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "ApplicationName" PrefixI True) (S1 (MetaSel (Just "unApplicationName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data SubscriptionCursor Source #

Type fo rsubscription cursors.

Constructors

SubscriptionCursor 

Fields

Instances
Eq SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionCursor :: * -> * #

ToJSON SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionCursor SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiPartition SubscriptionCursor PartitionName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOffset SubscriptionCursor CursorOffset 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursor SubscriptionCursorWithCounter SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventType SubscriptionCursor EventTypeName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursorToken SubscriptionCursor Text 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCursor (SubscriptionEventStreamBatch a) SubscriptionCursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionCursor Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursor = D1 (MetaData "SubscriptionCursor" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionCursor" PrefixI True) ((S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset)) :*: (S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName) :*: S1 (MetaSel (Just "_cursorToken") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text))))

data SubscriptionCursorWithoutToken Source #

Type for subscription cursors without token.

Constructors

SubscriptionCursorWithoutToken 

Fields

Instances
Eq SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionCursorWithoutToken :: * -> * #

Hashable SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursorWithoutToken Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursorWithoutToken = D1 (MetaData "SubscriptionCursorWithoutToken" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionCursorWithoutToken" PrefixI True) (S1 (MetaSel (Just "_partition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PartitionName) :*: (S1 (MetaSel (Just "_offset") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 CursorOffset) :*: S1 (MetaSel (Just "_eventType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 EventTypeName))))

newtype SubscriptionCursorCommit Source #

Type for commit object for subscription cursor committing.

Constructors

SubscriptionCursorCommit 

Fields

Instances
Show SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionCursorCommit :: * -> * #

ToJSON SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiItems SubscriptionCursorCommit [SubscriptionCursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionCursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionCursorCommit = D1 (MetaData "SubscriptionCursorCommit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SubscriptionCursorCommit" PrefixI True) (S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [SubscriptionCursor])))

newtype CursorCommit Source #

Type for commit objects for cursor committing.

Constructors

CursorCommit 

Fields

Instances
Show CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorCommit :: * -> * #

ToJSON CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiItems CursorCommit [Cursor] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorCommit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorCommit = D1 (MetaData "CursorCommit" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "CursorCommit" PrefixI True) (S1 (MetaSel (Just "_items") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 [Cursor])))

newtype SubscriptionId Source #

Type for subscription IDs.

Constructors

SubscriptionId 

Fields

Instances
Eq SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionId :: * -> * #

Hashable SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionId SubscriptionEventStream SubscriptionId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId SubscriptionId UUID 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId Subscription SubscriptionId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionId = D1 (MetaData "SubscriptionId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SubscriptionId" PrefixI True) (S1 (MetaSel (Just "unSubscriptionId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

newtype StreamId Source #

Type for stream IDs.

Constructors

StreamId 

Fields

Instances
Eq StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep StreamId :: * -> * #

Methods

from :: StreamId -> Rep StreamId x #

to :: Rep StreamId x -> StreamId #

ToJSON StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiStreamId SubscriptionEventStream StreamId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId StreamId Text 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

id :: Lens' StreamId Text

HasNakadiStreamId PartitionStat (Maybe StreamId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep StreamId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep StreamId = D1 (MetaData "StreamId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "StreamId" PrefixI True) (S1 (MetaSel (Just "unStreamId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype Timestamp Source #

Type for timestamps.

Constructors

Timestamp 

Fields

Instances
Eq Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Timestamp :: * -> * #

Hashable Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOccurredAt EventMetadata Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOccurredAt EventMetadataEnriched Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiReceivedAt EventMetadataEnriched Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCreatedAt Subscription Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiUTCTime Timestamp UTCTime 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep Timestamp Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Timestamp = D1 (MetaData "Timestamp" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "Timestamp" PrefixI True) (S1 (MetaSel (Just "unTimestamp") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UTCTime)))

newtype FlowId Source #

A Flow ID.

Constructors

FlowId 

Fields

Instances
Eq FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

(==) :: FlowId -> FlowId -> Bool #

(/=) :: FlowId -> FlowId -> Bool #

Ord FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

fromString :: String -> FlowId #

Generic FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep FlowId :: * -> * #

Methods

from :: FlowId -> Rep FlowId x #

to :: Rep FlowId x -> FlowId #

ToJSON FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiFlowId EventMetadataEnriched (Maybe FlowId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiFlowId (Config m) (Maybe FlowId) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

flowId :: Lens' (Config m) (Maybe FlowId)

type Rep FlowId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep FlowId = D1 (MetaData "FlowId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "FlowId" PrefixI True) (S1 (MetaSel (Just "unFlowId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

newtype EventId Source #

ID of an Event

Constructors

EventId 

Fields

Instances
Eq EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

(==) :: EventId -> EventId -> Bool #

(/=) :: EventId -> EventId -> Bool #

Ord EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventId :: * -> * #

Methods

from :: EventId -> Rep EventId x #

to :: Rep EventId x -> EventId #

Hashable EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> EventId -> Int #

hash :: EventId -> Int #

ToJSON EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiEid EventMetadata EventId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEid EventMetadataEnriched EventId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId EventId UUID 
Instance details

Defined in Network.Nakadi.Internal.Lenses

Methods

id :: Lens' EventId UUID

HasNakadiParentEids EventMetadata (Maybe [EventId]) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiParentEids EventMetadataEnriched (Maybe [EventId]) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventId Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventId = D1 (MetaData "EventId" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "EventId" PrefixI True) (S1 (MetaSel (Just "unEventId") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 UUID)))

data Partition Source #

Partition Data

Constructors

Partition 

Fields

data ShiftedCursor Source #

Type for shift-cursor queries.

Constructors

ShiftedCursor 

Fields

data CursorDistanceQuery Source #

Type for cursor-distance queries. Represents the request to compute the distance between initial cursor and final cursor.

Constructors

CursorDistanceQuery 

Fields

Instances
Eq CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorDistanceQuery :: * -> * #

Hashable CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiInitialCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiFinalCursor CursorDistanceQuery Cursor 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorDistanceQuery Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorDistanceQuery = D1 (MetaData "CursorDistanceQuery" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "CursorDistanceQuery" PrefixI True) (S1 (MetaSel (Just "_initialCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Cursor) :*: S1 (MetaSel (Just "_finalCursor") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Cursor)))

newtype CursorDistanceResult Source #

Type for results of cursor-distance-queries.

Constructors

CursorDistanceResult 

Fields

Instances
Eq CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep CursorDistanceResult :: * -> * #

Hashable CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiDistance CursorDistanceResult Int64 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep CursorDistanceResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep CursorDistanceResult = D1 (MetaData "CursorDistanceResult" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "CursorDistanceResult" PrefixI True) (S1 (MetaSel (Just "_distance") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int64)))

data SubscriptionReadFrom Source #

This type models the "read_from" field contained in subscription objects.

Instances
Eq SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionReadFrom :: * -> * #

Hashable SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionReadFrom Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionReadFrom = D1 (MetaData "SubscriptionReadFrom" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionReadFromBegin" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "SubscriptionReadFromEnd" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "SubscriptionReadFromCursors" PrefixI False) (U1 :: * -> *)))

data SubscriptionPosition Source #

Type modelling a subscription position.

Instances
Eq SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionPosition :: * -> * #

Hashable SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSubscriptionPosition Subscription SubscriptionPosition 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionPosition SubscriptionRequest (Maybe SubscriptionPosition) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionPosition Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionPosition = D1 (MetaData "SubscriptionPosition" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionPositionBegin" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "SubscriptionPositionEnd" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "SubscriptionPositionCursors" PrefixI False) (S1 (MetaSel (Nothing :: Maybe Symbol) NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [SubscriptionCursorWithoutToken]))))

subscriptionPositionToObject :: SubscriptionPosition -> Object Source #

Internal helper function for converting a SubscriptionPosition into a JSON Object (not a JSON Value). Removes the need for partial pattern matching later.

newtype ConsumerGroup Source #

This type models the value describing the use case of a subscription. In general this is an additional identifier used to differ subscriptions having the same owning application and event types.

Constructors

ConsumerGroup 
Instances
Eq ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep ConsumerGroup :: * -> * #

Hashable ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiConsumerGroup Subscription ConsumerGroup 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerGroup SubscriptionRequest (Maybe ConsumerGroup) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep ConsumerGroup Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep ConsumerGroup = D1 (MetaData "ConsumerGroup" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "ConsumerGroup" PrefixI True) (S1 (MetaSel (Just "unConsumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data Subscription Source #

Type for a Subscription which has already been created.

When a subscription object is retrieved from Nakadi the following fields are regarded as mandatory:

  • id
  • owning_application
  • event_types
  • consumer_group
  • created_at
  • read_from
  • depending on read_from also cursors.
Instances
Eq Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Subscription :: * -> * #

Hashable Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiCreatedAt Subscription Timestamp 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiOwningApplication Subscription ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionPosition Subscription SubscriptionPosition 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiId Subscription SubscriptionId 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerGroup Subscription ConsumerGroup 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems SubscriptionsListResponse [Subscription] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes Subscription [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep Subscription Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data SubscriptionRequest Source #

Type for a Subscription which is to be created.

When a subscription is to be created the following fields are regarded as mandatory in the subscription object:

  • owning_application
  • event_types

The remaining fields are regarded as optional:

  • consumer_group
  • read_from
  • depending on read_from the field cursors might have to be present as well.
Instances
Eq SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SubscriptionRequest :: * -> * #

Hashable SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiOwningApplication SubscriptionRequest ApplicationName 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSubscriptionPosition SubscriptionRequest (Maybe SubscriptionPosition) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiEventTypes SubscriptionRequest [EventTypeName] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiConsumerGroup SubscriptionRequest (Maybe ConsumerGroup) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SubscriptionRequest Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SubscriptionRequest = D1 (MetaData "SubscriptionRequest" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SubscriptionRequest" PrefixI True) ((S1 (MetaSel (Just "_owningApplication") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 ApplicationName) :*: S1 (MetaSel (Just "_eventTypes") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 [EventTypeName])) :*: (S1 (MetaSel (Just "_consumerGroup") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe ConsumerGroup)) :*: S1 (MetaSel (Just "_subscriptionPosition") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe SubscriptionPosition)))))

data PublishingStatus Source #

Type for publishing status.

Instances
Eq PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep PublishingStatus :: * -> * #

Hashable PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PublishingStatus Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep PublishingStatus = D1 (MetaData "PublishingStatus" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "PublishingStatusSubmitted" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "PublishingStatusFailed" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "PublishingStatusAborted" PrefixI False) (U1 :: * -> *)))

data Step Source #

Step

Instances
Eq Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

(==) :: Step -> Step -> Bool #

(/=) :: Step -> Step -> Bool #

Ord Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

compare :: Step -> Step -> Ordering #

(<) :: Step -> Step -> Bool #

(<=) :: Step -> Step -> Bool #

(>) :: Step -> Step -> Bool #

(>=) :: Step -> Step -> Bool #

max :: Step -> Step -> Step #

min :: Step -> Step -> Step #

Show Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

showsPrec :: Int -> Step -> ShowS #

show :: Step -> String #

showList :: [Step] -> ShowS #

Generic Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep Step :: * -> * #

Methods

from :: Step -> Rep Step x #

to :: Rep Step x -> Step #

Hashable Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Methods

hashWithSalt :: Int -> Step -> Int #

hash :: Step -> Int #

ToJSON Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Step Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep Step = D1 (MetaData "Step" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) ((C1 (MetaCons "StepNone" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "StepValidating" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "StepPartitioning" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "StepEnriching" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "StepPublishing" PrefixI False) (U1 :: * -> *))))

data BatchItemResponse Source #

In case of failures during batch publishing, Nakadi returns detailed information about which events failed to be published. This per-event information is a batch item response.

Instances
Eq BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep BatchItemResponse :: * -> * #

Hashable BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep BatchItemResponse Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep BatchItemResponse = D1 (MetaData "BatchItemResponse" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "BatchItemResponse" PrefixI True) ((S1 (MetaSel (Just "_eid") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe EventId)) :*: S1 (MetaSel (Just "_publishingStatus") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 PublishingStatus)) :*: (S1 (MetaSel (Just "_step") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Step)) :*: S1 (MetaSel (Just "_detail") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Text)))))

newtype StreamKeepAliveLimit Source #

StreamKeepAliveLimit

Instances
Eq StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON StreamKeepAliveLimit Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

newtype BatchFlushTimeout Source #

BatchFlushTimeout

data CursorCommitResultType Source #

CursorCommitResultType

Instances
Eq CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommitResultType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data CursorCommitResult Source #

CursorCommitResult

Instances
Eq CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommitResult Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

newtype CursorCommitResults Source #

Instances
Eq CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON CursorCommitResults Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

data SchemaType Source #

SchemaType

Constructors

SchemaTypeJson 
Instances
Eq SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SchemaType :: * -> * #

Hashable SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSchemaType EventTypeSchema SchemaType 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SchemaType Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SchemaType = D1 (MetaData "SchemaType" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "SchemaTypeJson" PrefixI False) (U1 :: * -> *))

newtype SchemaVersion Source #

Type for the version of a schema.

Constructors

SchemaVersion 
Instances
Eq SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

IsString SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep SchemaVersion :: * -> * #

Hashable SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiVersion EventMetadataEnriched SchemaVersion 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiVersion EventTypeSchema (Maybe SchemaVersion) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep SchemaVersion Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep SchemaVersion = D1 (MetaData "SchemaVersion" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" True) (C1 (MetaCons "SchemaVersion" PrefixI True) (S1 (MetaSel (Just "unSchemaVersion") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Text)))

data EventTypeSchema Source #

Type for the schema of an event type.

Instances
Eq EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Ord EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Show EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Generic EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

Associated Types

type Rep EventTypeSchema :: * -> * #

Hashable EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

ToJSON EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

FromJSON EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

HasNakadiSchemaType EventTypeSchema SchemaType 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSchema EventTypeSchema Text 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiSchema EventType EventTypeSchema 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiVersion EventTypeSchema (Maybe SchemaVersion) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiCreatedAt EventTypeSchema (Maybe Timestamp) 
Instance details

Defined in Network.Nakadi.Internal.Lenses

HasNakadiItems EventTypeSchemasResponse [EventTypeSchema] 
Instance details

Defined in Network.Nakadi.Internal.Lenses

type Rep EventTypeSchema Source # 
Instance details

Defined in Network.Nakadi.Internal.Types.Service

type Rep EventTypeSchema = D1 (MetaData "EventTypeSchema" "Network.Nakadi.Internal.Types.Service" "nakadi-client-0.6.1.0-BI9eY53buIQ2t4mz78rAfF" False) (C1 (MetaCons "EventTypeSchema" PrefixI True) ((S1 (MetaSel (Just "_version") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe SchemaVersion)) :*: S1 (MetaSel (Just "_createdAt") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 (Maybe Timestamp))) :*: (S1 (MetaSel (Just "_schemaType") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 SchemaType) :*: S1 (MetaSel (Just "_schema") NoSourceUnpackedness NoSourceStrictness DecidedStrict) (Rec0 Text))))

newtype PaginationLink Source #

PaginationLink

Constructors

PaginationLink 

Fields