hs-asapo-0.9.0: Haskell bindings for ASAP:O

Index

acknowledge 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
AsapoBoolAsapo.Raw.Common
AsapoConsumerErrorDataHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoConsumerErrorTypeAsapo.Raw.Consumer
AsapoConsumerHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoDataSetHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoErrorHandle 
1 (Type/Class)Asapo.Raw.Common
2 (Data Constructor)Asapo.Raw.Common
AsapoGenericRequestHeader 
1 (Type/Class)Asapo.Raw.Producer
2 (Data Constructor)Asapo.Raw.Producer
asapoGenericRequestHeaderApiVersionAsapo.Raw.Producer
asapoGenericRequestHeaderCustomDataAsapo.Raw.Producer
asapoGenericRequestHeaderDataIdAsapo.Raw.Producer
asapoGenericRequestHeaderDataSizeAsapo.Raw.Producer
asapoGenericRequestHeaderMessageAsapo.Raw.Producer
asapoGenericRequestHeaderMetaSizeAsapo.Raw.Producer
asapoGenericRequestHeaderOpCodeAsapo.Raw.Producer
asapoGenericRequestHeaderStreamAsapo.Raw.Producer
AsapoIdListHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoIngestModeFlagsAsapo.Raw.Producer
AsapoLogLevelAsapo.Raw.Producer
asapoLogLevelDebugAsapo.Raw.Producer
asapoLogLevelErrorAsapo.Raw.Producer
asapoLogLevelInfoAsapo.Raw.Producer
asapoLogLevelNoneAsapo.Raw.Producer
asapoLogLevelWarningAsapo.Raw.Producer
AsapoMessageDataHandle 
1 (Type/Class)Asapo.Raw.Common
2 (Data Constructor)Asapo.Raw.Common
AsapoMessageHeaderHandle 
1 (Type/Class)Asapo.Raw.Producer
2 (Data Constructor)Asapo.Raw.Producer
AsapoMessageMetaHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoMessageMetasHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoMetaIngestOpAsapo.Raw.Producer
AsapoNetworkConnectionTypeAsapo.Raw.Consumer
AsapoOpcodeAsapo.Raw.Producer
AsapoPartialErrorDataHandle 
1 (Type/Class)Asapo.Raw.Consumer
2 (Data Constructor)Asapo.Raw.Consumer
AsapoProducerHandle 
1 (Type/Class)Asapo.Raw.Producer
2 (Data Constructor)Asapo.Raw.Producer
AsapoRequestCallbackAsapo.Raw.Producer
AsapoRequestCallbackPayloadHandle 
1 (Type/Class)Asapo.Raw.Producer
2 (Data Constructor)Asapo.Raw.Producer
AsapoRequestHandlerTypeAsapo.Raw.Producer
AsapoSourceCredentialsHandle 
1 (Type/Class)Asapo.Raw.Common
2 (Data Constructor)Asapo.Raw.Common
AsapoSourceTypeAsapo.Raw.Common
AsapoStreamFilterAsapo.Raw.Consumer
AsapoStreamInfoHandle 
1 (Type/Class)Asapo.Raw.Common
2 (Data Constructor)Asapo.Raw.Common
AsapoStreamInfosHandle 
1 (Type/Class)Asapo.Raw.Common
2 (Data Constructor)Asapo.Raw.Common
AsapoStringHandle 
1 (Type/Class)Asapo.Raw.Common
2 (Data Constructor)Asapo.Raw.Common
asapo_consumer_acknowledgeAsapo.Raw.Consumer
asapo_consumer_current_connection_typeAsapo.Raw.Consumer
asapo_consumer_delete_streamAsapo.Raw.Consumer
asapo_consumer_error_get_idAsapo.Raw.Consumer
asapo_consumer_error_get_next_streamAsapo.Raw.Consumer
asapo_consumer_generate_new_group_idAsapo.Raw.Consumer
asapo_consumer_get_beamtime_metaAsapo.Raw.Consumer
asapo_consumer_get_by_idAsapo.Raw.Consumer
asapo_consumer_get_current_dataset_countAsapo.Raw.Consumer
asapo_consumer_get_current_sizeAsapo.Raw.Consumer
asapo_consumer_get_lastAsapo.Raw.Consumer
asapo_consumer_get_last_acknowledged_messageAsapo.Raw.Consumer
asapo_consumer_get_last_datasetAsapo.Raw.Consumer
asapo_consumer_get_last_dataset_ingroupAsapo.Raw.Consumer
asapo_consumer_get_last_ingroupAsapo.Raw.Consumer
asapo_consumer_get_nextAsapo.Raw.Consumer
asapo_consumer_get_next_datasetAsapo.Raw.Consumer
asapo_consumer_get_stream_listAsapo.Raw.Consumer
asapo_consumer_get_unacknowledged_messagesAsapo.Raw.Consumer
asapo_consumer_negative_acknowledgeAsapo.Raw.Consumer
asapo_consumer_query_messagesAsapo.Raw.Consumer
asapo_consumer_reset_last_read_markerAsapo.Raw.Consumer
asapo_consumer_retrieve_dataAsapo.Raw.Consumer
asapo_consumer_set_last_read_markerAsapo.Raw.Consumer
asapo_consumer_set_resend_nacsAsapo.Raw.Consumer
asapo_consumer_set_stream_persistentAsapo.Raw.Consumer
asapo_consumer_set_timeoutAsapo.Raw.Consumer
asapo_create_consumerAsapo.Raw.Consumer
asapo_create_message_headerAsapo.Raw.Producer
asapo_create_producerAsapo.Raw.Producer
asapo_create_source_credentialsAsapo.Raw.Common
asapo_dataset_get_expected_sizeAsapo.Raw.Consumer
asapo_dataset_get_idAsapo.Raw.Consumer
asapo_dataset_get_itemAsapo.Raw.Consumer
asapo_dataset_get_sizeAsapo.Raw.Consumer
asapo_error_explainAsapo.Raw.Common
asapo_error_get_payload_from_consumer_errorAsapo.Raw.Consumer
asapo_error_get_payload_from_partial_errorAsapo.Raw.Consumer
asapo_error_get_typeAsapo.Raw.Consumer
asapo_free_consumer_handleAsapo.Raw.Consumer
asapo_free_error_handleAsapo.Raw.Common
asapo_free_handleAsapo.Raw.Common
asapo_free_id_list_handleAsapo.Raw.Consumer
asapo_free_message_data_handleAsapo.Raw.Common
asapo_free_message_header_handleAsapo.Raw.Producer
asapo_free_message_metas_handleAsapo.Raw.Consumer
asapo_free_producer_handleAsapo.Raw.Producer
asapo_free_source_credentialsAsapo.Raw.Common
asapo_free_stream_infos_handleAsapo.Raw.Common
asapo_free_stream_info_handleAsapo.Raw.Common
asapo_free_string_handleAsapo.Raw.Common
asapo_id_list_get_itemAsapo.Raw.Consumer
asapo_id_list_get_sizeAsapo.Raw.Consumer
asapo_is_errorAsapo.Raw.Common
asapo_message_data_get_as_chars 
1 (Function)Asapo.Raw.Common
2 (Function)Asapo.Raw.Consumer
asapo_message_metas_get_itemAsapo.Raw.Consumer
asapo_message_metas_get_sizeAsapo.Raw.Consumer
asapo_message_meta_get_buf_idAsapo.Raw.Consumer
asapo_message_meta_get_dataset_substreamAsapo.Raw.Consumer
asapo_message_meta_get_idAsapo.Raw.Consumer
asapo_message_meta_get_metadataAsapo.Raw.Consumer
asapo_message_meta_get_nameAsapo.Raw.Consumer
asapo_message_meta_get_sizeAsapo.Raw.Consumer
asapo_message_meta_get_sourceAsapo.Raw.Consumer
asapo_message_meta_get_timestampAsapo.Raw.Consumer
asapo_new_error_handleAsapo.Raw.Common
asapo_new_handleAsapo.Raw.Common
asapo_new_message_data_handleAsapo.Raw.Common
asapo_new_message_meta_handleAsapo.Raw.Consumer
asapo_new_string_handleAsapo.Raw.Common
asapo_partial_error_get_expected_sizeAsapo.Raw.Consumer
asapo_partial_error_get_idAsapo.Raw.Consumer
asapo_producer_delete_streamAsapo.Raw.Producer
asapo_producer_enable_local_logAsapo.Raw.Producer
asapo_producer_enable_remote_logAsapo.Raw.Producer
asapo_producer_get_beamtime_metaAsapo.Raw.Producer
asapo_producer_get_last_streamAsapo.Raw.Producer
asapo_producer_get_requests_queue_sizeAsapo.Raw.Producer
asapo_producer_get_requests_queue_volume_mbAsapo.Raw.Producer
asapo_producer_get_stream_infoAsapo.Raw.Producer
asapo_producer_get_stream_metaAsapo.Raw.Producer
asapo_producer_get_version_infoAsapo.Raw.Producer
asapo_producer_sendAsapo.Raw.Producer
asapo_producer_send_beamtime_metadataAsapo.Raw.Producer
asapo_producer_send_fileAsapo.Raw.Producer
asapo_producer_send_stream_finished_flagAsapo.Raw.Producer
asapo_producer_send_stream_metadataAsapo.Raw.Producer
asapo_producer_set_credentialsAsapo.Raw.Producer
asapo_producer_set_log_levelAsapo.Raw.Producer
asapo_producer_set_requests_queue_limitsAsapo.Raw.Producer
asapo_producer_wait_requests_finishedAsapo.Raw.Producer
asapo_request_callback_payload_get_original_headerAsapo.Raw.Producer
asapo_request_callback_payload_get_responseAsapo.Raw.Producer
asapo_stream_infos_get_itemAsapo.Raw.Common
asapo_stream_infos_get_sizeAsapo.Raw.Consumer
asapo_stream_info_get_finishedAsapo.Raw.Common
asapo_stream_info_get_last_idAsapo.Raw.Common
asapo_stream_info_get_nameAsapo.Raw.Common
asapo_stream_info_get_next_streamAsapo.Raw.Common
asapo_stream_info_get_timestamp_createdAsapo.Raw.Common
asapo_stream_info_get_timestamp_last_entryAsapo.Raw.Common
asapo_string_c_strAsapo.Raw.Common
asapo_string_from_c_strAsapo.Raw.Common
asapo_string_sizeAsapo.Raw.Common
AutoIdFlagAsapo.Either.Producer, Asapo.Producer
Beamline 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
beamlineAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
Beamtime 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
beamtimeAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
checkErrorAsapo.Either.Producer
checkErrorWithGivenHandleAsapo.Either.Producer
ConnectionFabricAsapo.Either.Consumer, Asapo.Consumer
ConnectionTcpAsapo.Either.Consumer, Asapo.Consumer
ConnectionUndefinedAsapo.Either.Consumer, Asapo.Consumer
ConstCStringAsapo.Raw.Common
ConsumerAsapo.Either.Consumer, Asapo.Consumer
createRequestCallbackAsapo.Raw.Producer
DataAndMetadataAsapo.Either.Producer, Asapo.Producer
DatabaseAsapo.Either.Producer, Asapo.Producer
DataNotInCacheAsapo.Consumer
Dataset 
1 (Type/Class)Asapo.Either.Consumer, Asapo.Consumer
2 (Data Constructor)Asapo.Either.Consumer, Asapo.Consumer
datasetExpectedSizeAsapo.Either.Consumer, Asapo.Consumer
datasetIdAsapo.Either.Consumer, Asapo.Consumer
datasetItemsAsapo.Either.Consumer, Asapo.Consumer
DatasetSize 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
DatasetSubstream 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
DataSource 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
dataSourceAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
DeleteErrorOnNotExistAsapo.Either.Producer, Asapo.Producer
DeleteFlagAsapo.Either.Consumer, Asapo.Consumer
DeleteMeta 
1 (Data Constructor)Asapo.Either.Consumer, Asapo.Consumer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
deleteStream 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
3 (Function)Asapo.Either.Producer
4 (Function)Asapo.Producer
DeletionFlagsAsapo.Either.Producer, Asapo.Producer
DontDeleteMetaAsapo.Either.Consumer, Asapo.Consumer
enableLocalLogAsapo.Either.Producer, Asapo.Producer
enableRemoteLogAsapo.Either.Producer, Asapo.Producer
EndOfStreamAsapo.Consumer
Endpoint 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
Error 
1 (Type/Class)Asapo.Either.Consumer
2 (Data Constructor)Asapo.Either.Consumer
3 (Type/Class)Asapo.Either.Producer, Asapo.Producer
4 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
ErrorDataNotInCacheAsapo.Either.Consumer
ErrorEndOfStreamAsapo.Either.Consumer
ErrorInterruptedTransactionAsapo.Either.Consumer
ErrorLocalIOErrorAsapo.Either.Consumer
errorMessageAsapo.Either.Consumer
ErrorNoDataAsapo.Either.Consumer, Asapo.Consumer
ErrorOnNotExistAsapo.Either.Consumer, Asapo.Consumer
ErrorOnNotExistFlagAsapo.Either.Consumer, Asapo.Consumer
ErrorPartialDataAsapo.Either.Consumer
ErrorStreamFinishedAsapo.Either.Consumer
ErrorTypeAsapo.Either.Consumer, Asapo.Consumer
errorTypeAsapo.Either.Consumer
ErrorUnavailableServiceAsapo.Either.Consumer
ErrorUnknownErrorAsapo.Either.Consumer
ErrorUnsupportedClientAsapo.Either.Consumer
ErrorWrongInputAsapo.Either.Consumer
ExcludeIncompleteAsapo.Either.Consumer, Asapo.Consumer
FileName 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
FilesystemAsapo.Either.Producer, Asapo.Producer
FilesystemAndDatabaseAsapo.Either.Producer, Asapo.Producer
FilesystemFlagAsapo.Either.Consumer, Asapo.Consumer
FilesystemHandlerAsapo.Either.Producer, Asapo.Producer
FilterAllStreamsAsapo.Either.Consumer, Asapo.Consumer
FilterFinishedStreamsAsapo.Either.Consumer, Asapo.Consumer
FilterUnfinishedStreamsAsapo.Either.Consumer, Asapo.Consumer
GenericRequestHeader 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
genericRequestHeaderApiVersionAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderCustomDataAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderDataIdAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderDataSizeAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderMessageAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderMetaSizeAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderOpCodeAsapo.Either.Producer, Asapo.Producer
genericRequestHeaderStreamAsapo.Either.Producer, Asapo.Producer
getBeamtimeMeta 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
3 (Function)Asapo.Either.Producer
4 (Function)Asapo.Producer
getCurrentConnectionTypeAsapo.Either.Consumer, Asapo.Consumer
getCurrentDatasetCount 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getCurrentSize 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastDataset 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastDatasetInGroup 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastInGroupMessageData 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastInGroupMessageMeta 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastInGroupMessageMetaAndData 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastMessageData 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastMessageMeta 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastMessageMetaAndData 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getLastStream 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
getMessageDataById 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getMessageMetaAndDataById 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getMessageMetaById 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getNextDataset 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getNextMessageData 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getNextMessageMeta 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getNextMessageMetaAndData 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getRequestsQueueSizeAsapo.Either.Producer, Asapo.Producer
getRequestsQueueVolumeMbAsapo.Either.Producer, Asapo.Producer
getStreamInfo 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
getStreamList 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getStreamMeta 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
getUnacknowledgedMessages 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
getVersionInfo 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
GroupIdAsapo.Either.Consumer, Asapo.Consumer
IncludeIncompleteAsapo.Either.Consumer, Asapo.Consumer
IncludeIncompleteFlagAsapo.Either.Consumer, Asapo.Consumer
InsertAsapo.Either.Producer, Asapo.Producer
InstanceId 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
instanceIdAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
InterruptedTransactionAsapo.Consumer
kAllStreamsAsapo.Raw.Consumer
kAsapoTcpAsapo.Raw.Consumer
kDataNotInCacheAsapo.Raw.Consumer
kDefaultIngestModeAsapo.Raw.Producer
kEndOfStreamAsapo.Raw.Consumer
kFabricAsapo.Raw.Consumer
kFilesystemAsapo.Raw.Producer
kFinishedStreamsAsapo.Raw.Consumer
kInsertAsapo.Raw.Producer
kInterruptedTransactionAsapo.Raw.Consumer
kLocalIOErrorAsapo.Raw.Consumer
kMaxMessageSizeAsapo.Raw.Producer
kMaxVersionSizeAsapo.Raw.Producer
kNCustomParamsAsapo.Raw.Producer
kNoDataAsapo.Raw.Consumer
kOpcodeAuthorizeAsapo.Raw.Producer
kOpcodeCountAsapo.Raw.Producer
kOpcodeDeleteStreamAsapo.Raw.Producer
kOpcodeGetBufferDataAsapo.Raw.Producer
kOpcodeGetMetaAsapo.Raw.Producer
kOpcodeLastStreamAsapo.Raw.Producer
kOpcodePersistStreamAsapo.Raw.Producer
kOpcodeStreamInfoAsapo.Raw.Producer
kOpcodeTransferDataAsapo.Raw.Producer
kOpcodeTransferDatasetDataAsapo.Raw.Producer
kOpcodeTransferMetaDataAsapo.Raw.Producer
kOpcodeUnknownOpAsapo.Raw.Producer
kPartialDataAsapo.Raw.Consumer
kProcessedAsapo.Raw.Common
kRawAsapo.Raw.Common
kReplaceAsapo.Raw.Producer
kStoreInDatabaseAsapo.Raw.Producer
kStoreInFilesystemAsapo.Raw.Producer
kStreamFinishedAsapo.Raw.Consumer
kTcpAsapo.Raw.Producer
kTransferDataAsapo.Raw.Producer
kTransferMetaDataOnlyAsapo.Raw.Producer
kUnavailableServiceAsapo.Raw.Consumer
kUndefinedAsapo.Raw.Consumer
kUnfinishedStreamsAsapo.Raw.Consumer
kUnknownErrorAsapo.Raw.Consumer
kUnsupportedClientAsapo.Raw.Consumer
kUpdateAsapo.Raw.Producer
kWrongInputAsapo.Raw.Consumer
LocalIOErrorAsapo.Consumer
LogDebugAsapo.Either.Producer, Asapo.Producer
LogErrorAsapo.Either.Producer, Asapo.Producer
LogInfoAsapo.Either.Producer, Asapo.Producer
LogLevelAsapo.Either.Producer, Asapo.Producer
LogNoneAsapo.Either.Producer, Asapo.Producer
LogWarningAsapo.Either.Producer, Asapo.Producer
MessageId 
1 (Type/Class)Asapo.Either.Common, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Producer
messageIdFromIntAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
MessageMeta 
1 (Type/Class)Asapo.Either.Consumer, Asapo.Consumer
2 (Data Constructor)Asapo.Either.Consumer, Asapo.Consumer
messageMetaBufIdAsapo.Either.Consumer, Asapo.Consumer
messageMetaDatasetSubstreamAsapo.Either.Consumer, Asapo.Consumer
MessageMetaHandleAsapo.Either.Consumer, Asapo.Consumer
messageMetaHandleAsapo.Either.Consumer, Asapo.Consumer
messageMetaIdAsapo.Either.Consumer, Asapo.Consumer
messageMetaMetadataAsapo.Either.Consumer, Asapo.Consumer
messageMetaNameAsapo.Either.Consumer, Asapo.Consumer
messageMetaSizeAsapo.Either.Consumer, Asapo.Consumer
messageMetaSourceAsapo.Either.Consumer, Asapo.Consumer
messageMetaTimestampAsapo.Either.Consumer, Asapo.Consumer
Metadata 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
MetadataIngestModeAsapo.Either.Producer, Asapo.Producer
MetadataOnlyAsapo.Either.Producer, Asapo.Producer
mkAsapoFreeWrapperAsapo.Raw.Common
negativeAcknowledge 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
NetworkConnectionTypeAsapo.Either.Consumer, Asapo.Consumer
NoAutoIdAsapo.Either.Producer, Asapo.Producer
NoDataAsapo.Consumer
NoErrorOnNotExistAsapo.Either.Consumer, Asapo.Consumer
nominalDiffToMillisAsapo.Either.Common
NoUpsertAsapo.Either.Producer, Asapo.Producer
OpcodeAsapo.Either.Producer, Asapo.Producer
OpcodeAuthorizeAsapo.Either.Producer, Asapo.Producer
OpcodeCountAsapo.Either.Producer, Asapo.Producer
OpcodeDeleteStreamAsapo.Either.Producer, Asapo.Producer
OpcodeGetBufferDataAsapo.Either.Producer, Asapo.Producer
OpcodeGetMetaAsapo.Either.Producer, Asapo.Producer
OpcodeLastStreamAsapo.Either.Producer, Asapo.Producer
OpcodePersistStreamAsapo.Either.Producer, Asapo.Producer
OpcodeStreamInfoAsapo.Either.Producer, Asapo.Producer
OpcodeTransferDataAsapo.Either.Producer, Asapo.Producer
OpcodeTransferDatasetDataAsapo.Either.Producer, Asapo.Producer
OpcodeTransferMetaDataAsapo.Either.Producer, Asapo.Producer
OpcodeUnknownOpAsapo.Either.Producer, Asapo.Producer
PartialDataAsapo.Consumer
peekConstCStringTextAsapo.Either.Common
peekCStringTextAsapo.Either.Common
PipelineStep 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
pipelineStepAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
ProcessedSourceAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
ProcessingThreads 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
ProducerAsapo.Either.Producer, Asapo.Producer
ProducerException 
1 (Type/Class)Asapo.Producer
2 (Data Constructor)Asapo.Producer
p_asapo_free_handleAsapo.Raw.FreeHandleHack
queryMessages 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
queryMessagesHandlesAsapo.Either.Consumer
RawSourceAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
ReplaceAsapo.Either.Producer, Asapo.Producer
RequestHandlerTypeAsapo.Either.Producer, Asapo.Producer
RequestResponse 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
resendNacsAsapo.Either.Consumer, Asapo.Consumer
resetLastReadMarker 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
resolveMetadataAsapo.Either.Consumer
responseErrorAsapo.Either.Producer, Asapo.Producer
responseOriginalRequestHeaderAsapo.Either.Producer, Asapo.Producer
responsePayloadAsapo.Either.Producer, Asapo.Producer
retrieveDataForMessageMeta 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
retrieveDataFromMetaAsapo.Either.Consumer
retrieveStreamInfoFromCAsapo.Either.Common
send 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
sendBeamtimeMetadata 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
sendFile 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
sendStreamFinishedFlag 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
sendStreamMetadata 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
ServerName 
1 (Type/Class)Asapo.Either.Consumer, Asapo.Consumer
2 (Data Constructor)Asapo.Either.Consumer, Asapo.Consumer
setCredentials 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
setLastReadMarker 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
setLogLevelAsapo.Either.Producer, Asapo.Producer
setRequestsQueueLimitsAsapo.Either.Producer, Asapo.Producer
setStreamPersistent 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
setTimeoutAsapo.Either.Consumer, Asapo.Consumer
SomeConsumerExceptionAsapo.Consumer
SourceCredentials 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
SourcePath 
1 (Type/Class)Asapo.Either.Consumer, Asapo.Consumer
2 (Data Constructor)Asapo.Either.Consumer, Asapo.Consumer
SourceTypeAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
sourceTypeAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
StorageFlagAsapo.Either.Producer, Asapo.Producer
StreamFilterAsapo.Either.Consumer, Asapo.Consumer
StreamFinishedAsapo.Consumer
StreamInfo 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
streamInfoCreatedAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
streamInfoFinishedAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
streamInfoLastEntryAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
streamInfoLastIdAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
streamInfoNameAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
streamInfoNextStreamAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
StreamName 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
stringHandleToTextAsapo.Either.Common
stringHandleToTextUnsafeAsapo.Either.Common
TcpHandlerAsapo.Either.Producer, Asapo.Producer
timespecToUTCAsapo.Either.Common
Token 
1 (Type/Class)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Common, Asapo.Consumer, Asapo.Producer
tokenAsapo.Either.Common, Asapo.Consumer, Asapo.Producer
TransferFlagAsapo.Either.Producer, Asapo.Producer
UnavailableServiceAsapo.Consumer
UnknownErrorAsapo.Consumer
UnsupportedClientAsapo.Consumer
UpdateAsapo.Either.Producer, Asapo.Producer
UpsertModeAsapo.Either.Producer, Asapo.Producer
UseAutoIdAsapo.Either.Producer, Asapo.Producer
UseUpsertAsapo.Either.Producer, Asapo.Producer
versionClientAsapo.Either.Producer, Asapo.Producer
VersionInfo 
1 (Type/Class)Asapo.Either.Producer, Asapo.Producer
2 (Data Constructor)Asapo.Either.Producer, Asapo.Producer
versionServerAsapo.Either.Producer, Asapo.Producer
versionSupportedAsapo.Either.Producer, Asapo.Producer
waitRequestsFinished 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
withConstCStringAsapo.Either.Common
withConstTextAsapo.Either.Common
withConsumer 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
withCredentialsAsapo.Either.Common
withCStringNAsapo.Either.Common
withCStringNToTextAsapo.Either.Common
WithFilesystemAsapo.Either.Consumer, Asapo.Consumer
withGroupId 
1 (Function)Asapo.Either.Consumer
2 (Function)Asapo.Consumer
WithoutFilesystemAsapo.Either.Consumer, Asapo.Consumer
withProducer 
1 (Function)Asapo.Either.Producer
2 (Function)Asapo.Producer
withPtrAsapo.Either.Common
withTextAsapo.Either.Common
WrongInputAsapo.Consumer