Safe Haskell	None
Language	Haskell98

Asapo.Raw.Consumer

Documentation

newtype AsapoConsumerHandle Source #

Constructors

AsapoConsumerHandle (Ptr ())

Instances

Instances details

Storable AsapoConsumerHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoConsumerHandle -> Int #

alignment :: AsapoConsumerHandle -> Int #

peekElemOff :: Ptr AsapoConsumerHandle -> Int -> IO AsapoConsumerHandle #

pokeElemOff :: Ptr AsapoConsumerHandle -> Int -> AsapoConsumerHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoConsumerHandle #

pokeByteOff :: Ptr b -> Int -> AsapoConsumerHandle -> IO () #

peek :: Ptr AsapoConsumerHandle -> IO AsapoConsumerHandle #

poke :: Ptr AsapoConsumerHandle -> AsapoConsumerHandle -> IO () #

newtype AsapoMessageMetaHandle Source #

Constructors

AsapoMessageMetaHandle (Ptr ())

Instances

Instances details

Storable AsapoMessageMetaHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoMessageMetaHandle -> Int #

alignment :: AsapoMessageMetaHandle -> Int #

peekElemOff :: Ptr AsapoMessageMetaHandle -> Int -> IO AsapoMessageMetaHandle #

pokeElemOff :: Ptr AsapoMessageMetaHandle -> Int -> AsapoMessageMetaHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoMessageMetaHandle #

pokeByteOff :: Ptr b -> Int -> AsapoMessageMetaHandle -> IO () #

peek :: Ptr AsapoMessageMetaHandle -> IO AsapoMessageMetaHandle #

poke :: Ptr AsapoMessageMetaHandle -> AsapoMessageMetaHandle -> IO () #

newtype AsapoMessageMetasHandle Source #

Constructors

AsapoMessageMetasHandle (Ptr ())

Instances

Instances details

Storable AsapoMessageMetasHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoMessageMetasHandle -> Int #

alignment :: AsapoMessageMetasHandle -> Int #

peekElemOff :: Ptr AsapoMessageMetasHandle -> Int -> IO AsapoMessageMetasHandle #

pokeElemOff :: Ptr AsapoMessageMetasHandle -> Int -> AsapoMessageMetasHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoMessageMetasHandle #

pokeByteOff :: Ptr b -> Int -> AsapoMessageMetasHandle -> IO () #

peek :: Ptr AsapoMessageMetasHandle -> IO AsapoMessageMetasHandle #

poke :: Ptr AsapoMessageMetasHandle -> AsapoMessageMetasHandle -> IO () #

newtype AsapoIdListHandle Source #

Constructors

AsapoIdListHandle (Ptr ())

Instances

Instances details

Storable AsapoIdListHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoIdListHandle -> Int #

alignment :: AsapoIdListHandle -> Int #

peekElemOff :: Ptr AsapoIdListHandle -> Int -> IO AsapoIdListHandle #

pokeElemOff :: Ptr AsapoIdListHandle -> Int -> AsapoIdListHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoIdListHandle #

pokeByteOff :: Ptr b -> Int -> AsapoIdListHandle -> IO () #

peek :: Ptr AsapoIdListHandle -> IO AsapoIdListHandle #

poke :: Ptr AsapoIdListHandle -> AsapoIdListHandle -> IO () #

newtype AsapoDataSetHandle Source #

Constructors

AsapoDataSetHandle (Ptr ())

Instances

Instances details

Storable AsapoDataSetHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoDataSetHandle -> Int #

alignment :: AsapoDataSetHandle -> Int #

peekElemOff :: Ptr AsapoDataSetHandle -> Int -> IO AsapoDataSetHandle #

pokeElemOff :: Ptr AsapoDataSetHandle -> Int -> AsapoDataSetHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoDataSetHandle #

pokeByteOff :: Ptr b -> Int -> AsapoDataSetHandle -> IO () #

peek :: Ptr AsapoDataSetHandle -> IO AsapoDataSetHandle #

poke :: Ptr AsapoDataSetHandle -> AsapoDataSetHandle -> IO () #

newtype AsapoPartialErrorDataHandle Source #

Constructors

AsapoPartialErrorDataHandle (Ptr ())

Instances

Instances details

Storable AsapoPartialErrorDataHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoPartialErrorDataHandle -> Int #

alignment :: AsapoPartialErrorDataHandle -> Int #

peekElemOff :: Ptr AsapoPartialErrorDataHandle -> Int -> IO AsapoPartialErrorDataHandle #

pokeElemOff :: Ptr AsapoPartialErrorDataHandle -> Int -> AsapoPartialErrorDataHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoPartialErrorDataHandle #

pokeByteOff :: Ptr b -> Int -> AsapoPartialErrorDataHandle -> IO () #

peek :: Ptr AsapoPartialErrorDataHandle -> IO AsapoPartialErrorDataHandle #

poke :: Ptr AsapoPartialErrorDataHandle -> AsapoPartialErrorDataHandle -> IO () #

newtype AsapoConsumerErrorDataHandle Source #

Constructors

AsapoConsumerErrorDataHandle (Ptr ())

Instances

Instances details

Storable AsapoConsumerErrorDataHandle Source #

Instance details

Defined in Asapo.Raw.Consumer

Methods

sizeOf :: AsapoConsumerErrorDataHandle -> Int #

alignment :: AsapoConsumerErrorDataHandle -> Int #

peekElemOff :: Ptr AsapoConsumerErrorDataHandle -> Int -> IO AsapoConsumerErrorDataHandle #

pokeElemOff :: Ptr AsapoConsumerErrorDataHandle -> Int -> AsapoConsumerErrorDataHandle -> IO () #

peekByteOff :: Ptr b -> Int -> IO AsapoConsumerErrorDataHandle #

pokeByteOff :: Ptr b -> Int -> AsapoConsumerErrorDataHandle -> IO () #

peek :: Ptr AsapoConsumerErrorDataHandle -> IO AsapoConsumerErrorDataHandle #

poke :: Ptr AsapoConsumerErrorDataHandle -> AsapoConsumerErrorDataHandle -> IO () #

type AsapoConsumerErrorType = CInt Source #

asapo_stream_infos_get_size :: AsapoStreamInfosHandle -> IO CSize Source #

asapo_new_message_meta_handle :: IO AsapoMessageMetaHandle Source #

asapo_free_consumer_handle :: AsapoConsumerHandle -> IO () Source #

asapo_free_message_metas_handle :: AsapoMessageMetasHandle -> IO () Source #

asapo_free_id_list_handle :: AsapoIdListHandle -> IO () Source #

kNoData :: AsapoConsumerErrorType Source #

kEndOfStream :: AsapoConsumerErrorType Source #

kStreamFinished :: AsapoConsumerErrorType Source #

kUnavailableService :: AsapoConsumerErrorType Source #

kInterruptedTransaction :: AsapoConsumerErrorType Source #

kLocalIOError :: AsapoConsumerErrorType Source #

kWrongInput :: AsapoConsumerErrorType Source #

kPartialData :: AsapoConsumerErrorType Source #

kUnsupportedClient :: AsapoConsumerErrorType Source #

kDataNotInCache :: AsapoConsumerErrorType Source #

kUnknownError :: AsapoConsumerErrorType Source #

type AsapoStreamFilter = CInt Source #

kAllStreams :: AsapoStreamFilter Source #

kFinishedStreams :: AsapoStreamFilter Source #

kUnfinishedStreams :: AsapoStreamFilter Source #

type AsapoNetworkConnectionType = CInt Source #

kUndefined :: AsapoNetworkConnectionType Source #

kAsapoTcp :: AsapoNetworkConnectionType Source #

kFabric :: AsapoNetworkConnectionType Source #

asapo_error_get_type :: AsapoErrorHandle -> IO AsapoConsumerErrorType Source #

asapo_create_consumer :: ConstCString -> ConstCString -> AsapoBool -> AsapoSourceCredentialsHandle -> Ptr AsapoErrorHandle -> IO AsapoConsumerHandle Source #

asapo_consumer_generate_new_group_id :: AsapoConsumerHandle -> Ptr AsapoErrorHandle -> IO AsapoStringHandle Source #

asapo_consumer_set_timeout :: AsapoConsumerHandle -> Word64 -> IO () Source #

asapo_consumer_reset_last_read_marker :: AsapoConsumerHandle -> AsapoStringHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_set_last_read_marker :: AsapoConsumerHandle -> AsapoStringHandle -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_acknowledge :: AsapoConsumerHandle -> AsapoStringHandle -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_negative_acknowledge :: AsapoConsumerHandle -> AsapoStringHandle -> Word64 -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_get_unacknowledged_messages :: AsapoConsumerHandle -> AsapoStringHandle -> Word64 -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO AsapoIdListHandle Source #

asapo_id_list_get_size :: AsapoIdListHandle -> IO CSize Source #

asapo_id_list_get_item :: AsapoIdListHandle -> CSize -> IO Word64 Source #

asapo_consumer_get_last_acknowledged_message :: AsapoConsumerHandle -> AsapoStringHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CLong Source #

asapo_consumer_current_connection_type :: AsapoConsumerHandle -> IO AsapoNetworkConnectionType Source #

asapo_consumer_get_stream_list :: AsapoConsumerHandle -> ConstCString -> AsapoStreamFilter -> Ptr AsapoErrorHandle -> IO AsapoStreamInfosHandle Source #

asapo_consumer_delete_stream :: AsapoConsumerHandle -> ConstCString -> AsapoBool -> AsapoBool -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_set_stream_persistent :: AsapoConsumerHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_get_current_size :: AsapoConsumerHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO Int64 Source #

asapo_consumer_get_current_dataset_count :: AsapoConsumerHandle -> ConstCString -> AsapoBool -> Ptr AsapoErrorHandle -> IO Int64 Source #

asapo_consumer_get_beamtime_meta :: AsapoConsumerHandle -> Ptr AsapoErrorHandle -> IO AsapoStringHandle Source #

asapo_consumer_retrieve_data :: AsapoConsumerHandle -> AsapoMessageMetaHandle -> Ptr AsapoMessageDataHandle -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_get_next_dataset :: AsapoConsumerHandle -> AsapoStringHandle -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO AsapoDataSetHandle Source #

asapo_consumer_get_last_dataset :: AsapoConsumerHandle -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO AsapoDataSetHandle Source #

asapo_consumer_get_last_dataset_ingroup :: AsapoConsumerHandle -> AsapoStringHandle -> Word64 -> ConstCString -> Ptr AsapoErrorHandle -> IO AsapoDataSetHandle Source #

asapo_consumer_get_by_id :: AsapoConsumerHandle -> Word64 -> Ptr AsapoMessageMetaHandle -> Ptr AsapoMessageDataHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_get_last :: AsapoConsumerHandle -> Ptr AsapoMessageMetaHandle -> Ptr AsapoMessageDataHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_get_last_ingroup :: AsapoConsumerHandle -> AsapoStringHandle -> Ptr AsapoMessageMetaHandle -> Ptr AsapoMessageDataHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_get_next :: AsapoConsumerHandle -> AsapoStringHandle -> Ptr AsapoMessageMetaHandle -> Ptr AsapoMessageDataHandle -> ConstCString -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_consumer_query_messages :: AsapoConsumerHandle -> ConstCString -> ConstCString -> Ptr AsapoErrorHandle -> IO AsapoMessageMetasHandle Source #

asapo_consumer_set_resend_nacs :: AsapoConsumerHandle -> AsapoBool -> Word64 -> Word64 -> IO () Source #

asapo_message_data_get_as_chars :: AsapoMessageDataHandle -> IO ConstCString Source #

asapo_message_meta_get_name :: AsapoMessageMetaHandle -> IO ConstCString Source #

asapo_message_meta_get_timestamp :: AsapoMessageMetaHandle -> Ptr TimeSpec -> IO () Source #

asapo_message_meta_get_size :: AsapoMessageMetaHandle -> IO Word64 Source #

asapo_message_meta_get_id :: AsapoMessageMetaHandle -> IO Word64 Source #

asapo_message_meta_get_source :: AsapoMessageMetaHandle -> IO ConstCString Source #

asapo_message_meta_get_metadata :: AsapoMessageMetaHandle -> IO ConstCString Source #

asapo_message_meta_get_buf_id :: AsapoMessageMetaHandle -> IO Word64 Source #

asapo_message_meta_get_dataset_substream :: AsapoMessageMetaHandle -> IO Word64 Source #

asapo_dataset_get_id :: AsapoDataSetHandle -> IO Word64 Source #

asapo_dataset_get_expected_size :: AsapoDataSetHandle -> IO Word64 Source #

asapo_dataset_get_size :: AsapoDataSetHandle -> IO CSize Source #

asapo_dataset_get_item :: AsapoDataSetHandle -> CSize -> IO AsapoMessageMetaHandle Source #

asapo_message_metas_get_size :: AsapoMessageMetasHandle -> IO CSize Source #

asapo_message_metas_get_item :: AsapoMessageMetasHandle -> CSize -> IO AsapoMessageMetaHandle Source #

asapo_error_get_payload_from_partial_error :: AsapoErrorHandle -> IO AsapoPartialErrorDataHandle Source #

asapo_partial_error_get_id :: AsapoPartialErrorDataHandle -> IO Word64 Source #

asapo_partial_error_get_expected_size :: AsapoPartialErrorDataHandle -> IO Word64 Source #

asapo_error_get_payload_from_consumer_error :: AsapoErrorHandle -> IO AsapoConsumerErrorDataHandle Source #

asapo_consumer_error_get_id :: AsapoConsumerErrorDataHandle -> IO Word64 Source #

asapo_consumer_error_get_next_stream :: AsapoConsumerErrorDataHandle -> IO ConstCString Source #