hs-asapo-0.9.0: Haskell bindings for ASAP:O
Safe HaskellNone
LanguageHaskell98

Asapo.Raw.Producer

Documentation

newtype AsapoProducerHandle Source #

Constructors

AsapoProducerHandle (Ptr ()) 

Instances

Instances details
Storable AsapoProducerHandle Source # 
Instance details

Defined in Asapo.Raw.Producer

Methods

sizeOf :: AsapoProducerHandle -> Int #

alignment :: AsapoProducerHandle -> Int #

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

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

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

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

peek :: Ptr AsapoProducerHandle -> IO AsapoProducerHandle #

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

newtype AsapoRequestCallbackPayloadHandle Source #

Constructors

AsapoRequestCallbackPayloadHandle (Ptr ()) 

Instances

Instances details
Storable AsapoRequestCallbackPayloadHandle Source # 
Instance details

Defined in Asapo.Raw.Producer

Methods

sizeOf :: AsapoRequestCallbackPayloadHandle -> Int #

alignment :: AsapoRequestCallbackPayloadHandle -> Int #

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

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

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

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

peek :: Ptr AsapoRequestCallbackPayloadHandle -> IO AsapoRequestCallbackPayloadHandle #

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

newtype AsapoMessageHeaderHandle Source #

Constructors

AsapoMessageHeaderHandle (Ptr ()) 

Instances

Instances details
Storable AsapoMessageHeaderHandle Source # 
Instance details

Defined in Asapo.Raw.Producer

Methods

sizeOf :: AsapoMessageHeaderHandle -> Int #

alignment :: AsapoMessageHeaderHandle -> Int #

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

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

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

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

peek :: Ptr AsapoMessageHeaderHandle -> IO AsapoMessageHeaderHandle #

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

type AsapoRequestCallback = Ptr () -> AsapoRequestCallbackPayloadHandle -> AsapoErrorHandle -> IO () Source #

createRequestCallback :: AsapoRequestCallback -> IO (FunPtr AsapoRequestCallback) Source #

kMaxMessageSize :: CSize Source #

asapo_free_producer_handle :: AsapoProducerHandle -> IO () Source #

kNCustomParams :: CSize Source #

kDefaultIngestMode :: AsapoIngestModeFlags Source #

kMaxVersionSize :: CSize Source #

asapo_free_message_header_handle :: AsapoMessageHeaderHandle -> IO () Source #

type AsapoRequestHandlerType = CInt Source #

kTcp :: AsapoRequestHandlerType Source #

kFilesystem :: AsapoRequestHandlerType Source #

type AsapoIngestModeFlags = CInt Source #

kTransferData :: AsapoIngestModeFlags Source #

type AsapoOpcode = CInt Source #

kOpcodeUnknownOp :: AsapoOpcode Source #

kOpcodeTransferData :: AsapoOpcode Source #

kOpcodeTransferDatasetData :: AsapoOpcode Source #

kOpcodeStreamInfo :: AsapoOpcode Source #

kOpcodeLastStream :: AsapoOpcode Source #

kOpcodeGetBufferData :: AsapoOpcode Source #

kOpcodeAuthorize :: AsapoOpcode Source #

kOpcodeTransferMetaData :: AsapoOpcode Source #

kOpcodeDeleteStream :: AsapoOpcode Source #

kOpcodeGetMeta :: AsapoOpcode Source #

kOpcodeCount :: AsapoOpcode Source #

kOpcodePersistStream :: AsapoOpcode Source #

kTransferMetaDataOnly :: AsapoIngestModeFlags Source #

kStoreInFilesystem :: AsapoIngestModeFlags Source #

kStoreInDatabase :: AsapoIngestModeFlags Source #

type AsapoMetaIngestOp = CInt Source #

kInsert :: AsapoMetaIngestOp Source #

kReplace :: AsapoMetaIngestOp Source #

kUpdate :: AsapoMetaIngestOp Source #

type AsapoLogLevel = CInt Source #

asapoLogLevelNone :: AsapoLogLevel Source #

asapoLogLevelError :: AsapoLogLevel Source #

asapoLogLevelInfo :: AsapoLogLevel Source #

asapoLogLevelDebug :: AsapoLogLevel Source #

asapoLogLevelWarning :: AsapoLogLevel Source #

asapo_create_producer :: CString -> CUChar -> AsapoRequestHandlerType -> AsapoSourceCredentialsHandle -> Word64 -> Ptr AsapoErrorHandle -> IO AsapoProducerHandle Source #

asapo_producer_get_version_info :: AsapoProducerHandle -> AsapoStringHandle -> AsapoStringHandle -> Ptr AsapoBool -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_get_stream_info :: AsapoProducerHandle -> ConstCString -> Word64 -> Ptr AsapoErrorHandle -> IO AsapoStreamInfoHandle Source #

asapo_producer_get_stream_meta :: AsapoProducerHandle -> ConstCString -> Word64 -> Ptr AsapoErrorHandle -> IO AsapoStringHandle Source #

asapo_producer_get_beamtime_meta :: AsapoProducerHandle -> Word64 -> Ptr AsapoErrorHandle -> IO AsapoStringHandle Source #

asapo_producer_delete_stream :: AsapoProducerHandle -> ConstCString -> Word64 -> AsapoBool -> AsapoBool -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_get_last_stream :: AsapoProducerHandle -> Word64 -> Ptr AsapoErrorHandle -> IO AsapoStreamInfoHandle Source #

asapo_create_message_header :: Word64 -> Word64 -> ConstCString -> ConstCString -> Word64 -> Word64 -> AsapoBool -> IO AsapoMessageHeaderHandle Source #

asapo_producer_send :: AsapoProducerHandle -> AsapoMessageHeaderHandle -> Ptr () -> Word64 -> ConstCString -> FunPtr AsapoRequestCallback -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_send_file :: AsapoProducerHandle -> AsapoMessageHeaderHandle -> ConstCString -> Word64 -> ConstCString -> FunPtr AsapoRequestCallback -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_send_stream_finished_flag :: AsapoProducerHandle -> ConstCString -> Word64 -> ConstCString -> FunPtr AsapoRequestCallback -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_send_beamtime_metadata :: AsapoProducerHandle -> ConstCString -> AsapoMetaIngestOp -> AsapoBool -> FunPtr AsapoRequestCallback -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_send_stream_metadata :: AsapoProducerHandle -> ConstCString -> AsapoMetaIngestOp -> AsapoBool -> ConstCString -> FunPtr AsapoRequestCallback -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_request_callback_payload_get_response :: AsapoRequestCallbackPayloadHandle -> IO AsapoStringHandle Source #

asapo_request_callback_payload_get_original_header :: AsapoRequestCallbackPayloadHandle -> IO (ConstPtr AsapoGenericRequestHeader) Source #

asapo_producer_set_log_level :: AsapoProducerHandle -> AsapoLogLevel -> IO () Source #

asapo_producer_enable_local_log :: AsapoProducerHandle -> AsapoBool -> IO () Source #

asapo_producer_enable_remote_log :: AsapoProducerHandle -> AsapoBool -> IO () Source #

asapo_producer_set_credentials :: AsapoProducerHandle -> AsapoSourceCredentialsHandle -> Ptr AsapoErrorHandle -> IO CInt Source #

asapo_producer_get_requests_queue_size :: AsapoProducerHandle -> IO Word64 Source #

asapo_producer_get_requests_queue_volume_mb :: AsapoProducerHandle -> IO Word64 Source #

asapo_producer_set_requests_queue_limits :: AsapoProducerHandle -> Word64 -> Word64 -> IO () Source #

asapo_producer_wait_requests_finished :: AsapoProducerHandle -> Word64 -> Ptr AsapoErrorHandle -> IO CInt Source #

data AsapoGenericRequestHeader Source #

Constructors

AsapoGenericRequestHeader 

Fields

Instances

Instances details
Storable AsapoGenericRequestHeader Source # 
Instance details

Defined in Asapo.Raw.Producer

Methods

sizeOf :: AsapoGenericRequestHeader -> Int #

alignment :: AsapoGenericRequestHeader -> Int #

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

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

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

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

peek :: Ptr AsapoGenericRequestHeader -> IO AsapoGenericRequestHeader #

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