| Copyright | (c) 2011 MailRank Inc. |
|---|---|
| License | Apache |
| Maintainer | Mark Hibberd <mark@hibberd.id.au>, Nathan Hunter <nhunter@janrain.com> |
| Stability | experimental |
| Portability | portable |
| Safe Haskell | None |
| Language | Haskell98 |
Network.Riak.Types.Internal
Contents
Description
Basic types.
Synopsis
- type ClientID = ByteString
- data Client = Client {}
- data Connection = Connection {}
- data RiakException
- netError :: String -> String -> String -> a
- typeError :: String -> String -> String -> a
- unexError :: String -> String -> String -> a
- type Bucket = ByteString
- type BucketType = ByteString
- type Key = ByteString
- type Index = ByteString
- type Schema = ByteString
- data IndexQuery
- data IndexValue
- type Tag = ByteString
- type SearchQuery = ByteString
- data SearchResult = SearchResult {}
- type Score = Double
- type IndexInfo = YzIndex
- newtype VClock = VClock {}
- data Job
- type N = Word32
- type Timeout = Word32
- data Quorum
- type DW = Quorum
- type R = Quorum
- type RW = Quorum
- type W = Quorum
- fromQuorum :: Quorum -> Maybe Word32
- toQuorum :: Word32 -> Maybe Quorum
- class (Tagged msg, ReflectDescriptor msg, Show msg, Wire msg) => Request msg where
- class (Tagged msg, ReflectDescriptor msg, Show msg, Wire msg) => Response msg
- class (Request req, Response resp) => Exchange req resp | req -> resp
- data MessageTag
- = ErrorResponse
- | PingRequest
- | PingResponse
- | GetClientIDRequest
- | GetClientIDResponse
- | SetClientIDRequest
- | SetClientIDResponse
- | GetServerInfoRequest
- | GetServerInfoResponse
- | GetRequest
- | GetResponse
- | PutRequest
- | PutResponse
- | DeleteRequest
- | DeleteResponse
- | ListBucketsRequest
- | ListBucketsResponse
- | ListKeysRequest
- | ListKeysResponse
- | GetBucketRequest
- | GetBucketResponse
- | SetBucketRequest
- | SetBucketResponse
- | GetBucketTypeRequest
- | MapReduceRequest
- | MapReduceResponse
- | IndexRequest
- | IndexResponse
- | DtFetchRequest
- | DtFetchResponse
- | DtUpdateRequest
- | DtUpdateResponse
- | SearchQueryRequest
- | SearchQueryResponse
- | YokozunaIndexGetRequest
- | YokozunaIndexGetResponse
- | YokozunaIndexPutRequest
- | YokozunaIndexDeleteRequest
- class Tagged msg where
Client management
type ClientID = ByteString #
A client identifier. This is used by the Riak cluster when logging vector clock changes, and should be unique for each client.
Constructors
| Client | |
Connection management
data Connection #
A connection to a Riak server.
Constructors
| Connection | |
Fields
| |
Instances
| Eq Connection # | |
Defined in Network.Riak.Types.Internal | |
| Show Connection # | |
Defined in Network.Riak.Types.Internal Methods showsPrec :: Int -> Connection -> ShowS # show :: Connection -> String # showList :: [Connection] -> ShowS # | |
Errors
data RiakException #
The main Riak exception type.
Instances
| Eq RiakException # | |
Defined in Network.Riak.Types.Internal Methods (==) :: RiakException -> RiakException -> Bool # (/=) :: RiakException -> RiakException -> Bool # | |
| Show RiakException # | |
Defined in Network.Riak.Types.Internal Methods showsPrec :: Int -> RiakException -> ShowS # show :: RiakException -> String # showList :: [RiakException] -> ShowS # | |
| Exception RiakException # | |
Defined in Network.Riak.Types.Internal Methods toException :: RiakException -> SomeException # fromException :: SomeException -> Maybe RiakException # displayException :: RiakException -> String # | |
Data types
type Bucket = ByteString #
A Bucket is a container and keyspace for data stored in Riak, with a set of common properties for its contents (the number of replicas, for instance).
type BucketType = ByteString #
Bucket types is a riak >= 2.0 feature allowing groups of buckets to share configuration details
type Key = ByteString #
Keys are unique object identifiers in Riak and are scoped within buckets.
type Index = ByteString #
Name of a secondary index
type Schema = ByteString #
Name of an index schema
data IndexQuery #
Index query. Can be exact or range, int or bin. Index name should not contain the "_bin" or "_int" part, since it's determined from data constructor.
Constructors
| IndexQueryExactInt !Index !Int | |
| IndexQueryExactBin !Index !ByteString | |
| IndexQueryRangeInt !Index !Int !Int | |
| IndexQueryRangeBin !Index !ByteString !ByteString |
Instances
| Eq IndexQuery # | |
Defined in Network.Riak.Types.Internal | |
| Show IndexQuery # | |
Defined in Network.Riak.Types.Internal Methods showsPrec :: Int -> IndexQuery -> ShowS # show :: IndexQuery -> String # showList :: [IndexQuery] -> ShowS # | |
data IndexValue #
Instances
| Eq IndexValue # | |
Defined in Network.Riak.Types.Internal | |
| Show IndexValue # | |
Defined in Network.Riak.Types.Internal Methods showsPrec :: Int -> IndexValue -> ShowS # show :: IndexValue -> String # showList :: [IndexValue] -> ShowS # | |
type Tag = ByteString #
An application-specific identifier for a link. See http://wiki.basho.com/Links.html for details.
type SearchQuery = ByteString #
Search request
data SearchResult #
Solr search result
Constructors
| SearchResult | |
Instances
| Eq SearchResult # | |
Defined in Network.Riak.Types.Internal | |
| Ord SearchResult # | |
Defined in Network.Riak.Types.Internal Methods compare :: SearchResult -> SearchResult -> Ordering # (<) :: SearchResult -> SearchResult -> Bool # (<=) :: SearchResult -> SearchResult -> Bool # (>) :: SearchResult -> SearchResult -> Bool # (>=) :: SearchResult -> SearchResult -> Bool # max :: SearchResult -> SearchResult -> SearchResult # min :: SearchResult -> SearchResult -> SearchResult # | |
| Show SearchResult # | |
Defined in Network.Riak.Types.Internal Methods showsPrec :: Int -> SearchResult -> ShowS # show :: SearchResult -> String # showList :: [SearchResult] -> ShowS # | |
A wrapper that keeps Riak vector clocks opaque.
Constructors
| VClock | |
Fields
| |
A specification of a MapReduce job. http://wiki.basho.com/MapReduce.html.
Constructors
| JSON ByteString | |
| Erlang ByteString |
Quorum management
A read/write quorum. The quantity of replicas that must respond
to a read or write request before it is considered successful. This
is defined as a bucket property or as one of the relevant
parameters to a single request (R,W,DW,RW).
Constructors
| Default | Use the default quorum settings for the bucket. |
| One | Success after one server has responded. |
| Quorum | Success after a quorum of servers has responded. |
| All | Success after all servers have responded. |
Durable write quorum. How many replicas to commit to durable storage before returning a successful response.
Write quorum. How many replicas to write to before returning a successful response.
fromQuorum :: Quorum -> Maybe Word32 #
Message identification
class (Tagged msg, ReflectDescriptor msg, Show msg, Wire msg) => Request msg where #
A message representing a request from client to server.
Minimal complete definition
Methods
expectedResponse :: msg -> MessageTag #
Instances
class (Tagged msg, ReflectDescriptor msg, Show msg, Wire msg) => Response msg #
A message representing a response from server to client.
Instances
| Response YzIndexGetResponse # | |
Defined in Network.Riak.Tag | |
| Response ServerInfo # | |
Defined in Network.Riak.Tag | |
| Response SearchQueryResponse # | |
Defined in Network.Riak.Tag | |
| Response PutResponse # | |
Defined in Network.Riak.Tag | |
| Response GetResponse # | |
Defined in Network.Riak.Tag | |
| Response IndexResponse # | |
Defined in Network.Riak.Tag | |
| Response GetBucketResponse # | |
Defined in Network.Riak.Tag | |
| Response MapReduce # | |
Defined in Network.Riak.Tag | |
| Response DtUpdateResponse # | |
Defined in Network.Riak.Tag | |
| Response DtFetchResponse # | |
Defined in Network.Riak.Tag | |
| Response ListKeysResponse # | |
Defined in Network.Riak.Tag | |
| Response ListBucketsResponse # | |
Defined in Network.Riak.Tag | |
| Response GetClientIDResponse # | |
Defined in Network.Riak.Tag | |
| Response ErrorResponse # | |
Defined in Network.Riak.Tag | |
class (Request req, Response resp) => Exchange req resp | req -> resp #
Instances
| Exchange YzIndexPutRequest PutResponse # | |
Defined in Network.Riak.Tag | |
| Exchange YzIndexGetRequest YzIndexGetResponse # | |
Defined in Network.Riak.Tag | |
| Exchange DtUpdateRequest DtUpdateResponse # | |
Defined in Network.Riak.Tag | |
| Exchange SearchQueryRequest SearchQueryResponse # | |
Defined in Network.Riak.Tag | |
| Exchange PutRequest PutResponse # | |
Defined in Network.Riak.Tag | |
| Exchange MapReduceRequest MapReduce # | |
Defined in Network.Riak.Tag | |
| Exchange ListBucketsRequest ListBucketsResponse # | |
Defined in Network.Riak.Tag | |
| Exchange IndexRequest IndexResponse # | |
Defined in Network.Riak.Tag | |
| Exchange GetServerInfoRequest ServerInfo # | |
Defined in Network.Riak.Tag | |
| Exchange GetRequest GetResponse # | |
Defined in Network.Riak.Tag | |
| Exchange GetClientIDRequest GetClientIDResponse # | |
Defined in Network.Riak.Tag | |
| Exchange GetBucketTypeRequest GetBucketResponse # | |
Defined in Network.Riak.Tag | |
| Exchange GetBucketRequest GetBucketResponse # | |
Defined in Network.Riak.Tag | |
| Exchange DtFetchRequest DtFetchResponse # | |
Defined in Network.Riak.Tag | |
data MessageTag #
List of (known to us) inbound or outbound message identifiers.
Constructors
Instances
| Eq MessageTag # | |
Defined in Network.Riak.Types.Internal | |
| Show MessageTag # | |
Defined in Network.Riak.Types.Internal Methods showsPrec :: Int -> MessageTag -> ShowS # show :: MessageTag -> String # showList :: [MessageTag] -> ShowS # | |
| Generic MessageTag # | |
Defined in Network.Riak.Types.Internal Associated Types type Rep MessageTag :: * -> * # | |
| Hashable MessageTag # | |
Defined in Network.Riak.Types.Internal | |
| Tagged MessageTag # | |
Defined in Network.Riak.Types.Internal Methods messageTag :: MessageTag -> MessageTag # | |
| type Rep MessageTag # | |
Defined in Network.Riak.Types.Internal type Rep MessageTag = D1 (MetaData "MessageTag" "Network.Riak.Types.Internal" "riak-1.1.2.5-KWQXjHso6ubKlDhGH5ul14" False) (((((C1 (MetaCons "ErrorResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "PingRequest" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "PingResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "GetClientIDRequest" PrefixI False) (U1 :: * -> *))) :+: ((C1 (MetaCons "GetClientIDResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "SetClientIDRequest" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "SetClientIDResponse" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "GetServerInfoRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "GetServerInfoResponse" PrefixI False) (U1 :: * -> *))))) :+: (((C1 (MetaCons "GetRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "GetResponse" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "PutRequest" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "PutResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "DeleteRequest" PrefixI False) (U1 :: * -> *)))) :+: ((C1 (MetaCons "DeleteResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "ListBucketsRequest" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "ListBucketsResponse" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "ListKeysRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "ListKeysResponse" PrefixI False) (U1 :: * -> *)))))) :+: ((((C1 (MetaCons "GetBucketRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "GetBucketResponse" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "SetBucketRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "SetBucketResponse" PrefixI False) (U1 :: * -> *))) :+: ((C1 (MetaCons "GetBucketTypeRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "MapReduceRequest" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "MapReduceResponse" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "IndexRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "IndexResponse" PrefixI False) (U1 :: * -> *))))) :+: (((C1 (MetaCons "DtFetchRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "DtFetchResponse" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "DtUpdateRequest" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "DtUpdateResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "SearchQueryRequest" PrefixI False) (U1 :: * -> *)))) :+: ((C1 (MetaCons "SearchQueryResponse" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "YokozunaIndexGetRequest" PrefixI False) (U1 :: * -> *)) :+: (C1 (MetaCons "YokozunaIndexGetResponse" PrefixI False) (U1 :: * -> *) :+: (C1 (MetaCons "YokozunaIndexPutRequest" PrefixI False) (U1 :: * -> *) :+: C1 (MetaCons "YokozunaIndexDeleteRequest" PrefixI False) (U1 :: * -> *))))))) | |
Messages are tagged.
Minimal complete definition