acknowledge | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
AsapoBool | Asapo.Raw.Common |
AsapoConsumerErrorDataHandle | |
1 (Type/Class) | Asapo.Raw.Consumer |
2 (Data Constructor) | Asapo.Raw.Consumer |
AsapoConsumerErrorType | Asapo.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 |
asapoGenericRequestHeaderApiVersion | Asapo.Raw.Producer |
asapoGenericRequestHeaderCustomData | Asapo.Raw.Producer |
asapoGenericRequestHeaderDataId | Asapo.Raw.Producer |
asapoGenericRequestHeaderDataSize | Asapo.Raw.Producer |
asapoGenericRequestHeaderMessage | Asapo.Raw.Producer |
asapoGenericRequestHeaderMetaSize | Asapo.Raw.Producer |
asapoGenericRequestHeaderOpCode | Asapo.Raw.Producer |
asapoGenericRequestHeaderStream | Asapo.Raw.Producer |
AsapoIdListHandle | |
1 (Type/Class) | Asapo.Raw.Consumer |
2 (Data Constructor) | Asapo.Raw.Consumer |
AsapoIngestModeFlags | Asapo.Raw.Producer |
AsapoLogLevel | Asapo.Raw.Producer |
asapoLogLevelDebug | Asapo.Raw.Producer |
asapoLogLevelError | Asapo.Raw.Producer |
asapoLogLevelInfo | Asapo.Raw.Producer |
asapoLogLevelNone | Asapo.Raw.Producer |
asapoLogLevelWarning | Asapo.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 |
AsapoMetaIngestOp | Asapo.Raw.Producer |
AsapoNetworkConnectionType | Asapo.Raw.Consumer |
AsapoOpcode | Asapo.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 |
AsapoRequestCallback | Asapo.Raw.Producer |
AsapoRequestCallbackPayloadHandle | |
1 (Type/Class) | Asapo.Raw.Producer |
2 (Data Constructor) | Asapo.Raw.Producer |
AsapoRequestHandlerType | Asapo.Raw.Producer |
AsapoSourceCredentialsHandle | |
1 (Type/Class) | Asapo.Raw.Common |
2 (Data Constructor) | Asapo.Raw.Common |
AsapoSourceType | Asapo.Raw.Common |
AsapoStreamFilter | Asapo.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_acknowledge | Asapo.Raw.Consumer |
asapo_consumer_current_connection_type | Asapo.Raw.Consumer |
asapo_consumer_delete_stream | Asapo.Raw.Consumer |
asapo_consumer_error_get_id | Asapo.Raw.Consumer |
asapo_consumer_error_get_next_stream | Asapo.Raw.Consumer |
asapo_consumer_generate_new_group_id | Asapo.Raw.Consumer |
asapo_consumer_get_beamtime_meta | Asapo.Raw.Consumer |
asapo_consumer_get_by_id | Asapo.Raw.Consumer |
asapo_consumer_get_current_dataset_count | Asapo.Raw.Consumer |
asapo_consumer_get_current_size | Asapo.Raw.Consumer |
asapo_consumer_get_last | Asapo.Raw.Consumer |
asapo_consumer_get_last_acknowledged_message | Asapo.Raw.Consumer |
asapo_consumer_get_last_dataset | Asapo.Raw.Consumer |
asapo_consumer_get_last_dataset_ingroup | Asapo.Raw.Consumer |
asapo_consumer_get_last_ingroup | Asapo.Raw.Consumer |
asapo_consumer_get_next | Asapo.Raw.Consumer |
asapo_consumer_get_next_dataset | Asapo.Raw.Consumer |
asapo_consumer_get_stream_list | Asapo.Raw.Consumer |
asapo_consumer_get_unacknowledged_messages | Asapo.Raw.Consumer |
asapo_consumer_negative_acknowledge | Asapo.Raw.Consumer |
asapo_consumer_query_messages | Asapo.Raw.Consumer |
asapo_consumer_reset_last_read_marker | Asapo.Raw.Consumer |
asapo_consumer_retrieve_data | Asapo.Raw.Consumer |
asapo_consumer_set_last_read_marker | Asapo.Raw.Consumer |
asapo_consumer_set_resend_nacs | Asapo.Raw.Consumer |
asapo_consumer_set_stream_persistent | Asapo.Raw.Consumer |
asapo_consumer_set_timeout | Asapo.Raw.Consumer |
asapo_create_consumer | Asapo.Raw.Consumer |
asapo_create_message_header | Asapo.Raw.Producer |
asapo_create_producer | Asapo.Raw.Producer |
asapo_create_source_credentials | Asapo.Raw.Common |
asapo_dataset_get_expected_size | Asapo.Raw.Consumer |
asapo_dataset_get_id | Asapo.Raw.Consumer |
asapo_dataset_get_item | Asapo.Raw.Consumer |
asapo_dataset_get_size | Asapo.Raw.Consumer |
asapo_error_explain | Asapo.Raw.Common |
asapo_error_get_payload_from_consumer_error | Asapo.Raw.Consumer |
asapo_error_get_payload_from_partial_error | Asapo.Raw.Consumer |
asapo_error_get_type | Asapo.Raw.Consumer |
asapo_free_consumer_handle | Asapo.Raw.Consumer |
asapo_free_error_handle | Asapo.Raw.Common |
asapo_free_handle | Asapo.Raw.Common |
asapo_free_id_list_handle | Asapo.Raw.Consumer |
asapo_free_message_data_handle | Asapo.Raw.Common |
asapo_free_message_header_handle | Asapo.Raw.Producer |
asapo_free_message_metas_handle | Asapo.Raw.Consumer |
asapo_free_producer_handle | Asapo.Raw.Producer |
asapo_free_source_credentials | Asapo.Raw.Common |
asapo_free_stream_infos_handle | Asapo.Raw.Common |
asapo_free_stream_info_handle | Asapo.Raw.Common |
asapo_free_string_handle | Asapo.Raw.Common |
asapo_id_list_get_item | Asapo.Raw.Consumer |
asapo_id_list_get_size | Asapo.Raw.Consumer |
asapo_is_error | Asapo.Raw.Common |
asapo_message_data_get_as_chars | |
1 (Function) | Asapo.Raw.Common |
2 (Function) | Asapo.Raw.Consumer |
asapo_message_metas_get_item | Asapo.Raw.Consumer |
asapo_message_metas_get_size | Asapo.Raw.Consumer |
asapo_message_meta_get_buf_id | Asapo.Raw.Consumer |
asapo_message_meta_get_dataset_substream | Asapo.Raw.Consumer |
asapo_message_meta_get_id | Asapo.Raw.Consumer |
asapo_message_meta_get_metadata | Asapo.Raw.Consumer |
asapo_message_meta_get_name | Asapo.Raw.Consumer |
asapo_message_meta_get_size | Asapo.Raw.Consumer |
asapo_message_meta_get_source | Asapo.Raw.Consumer |
asapo_message_meta_get_timestamp | Asapo.Raw.Consumer |
asapo_new_error_handle | Asapo.Raw.Common |
asapo_new_handle | Asapo.Raw.Common |
asapo_new_message_data_handle | Asapo.Raw.Common |
asapo_new_message_meta_handle | Asapo.Raw.Consumer |
asapo_new_string_handle | Asapo.Raw.Common |
asapo_partial_error_get_expected_size | Asapo.Raw.Consumer |
asapo_partial_error_get_id | Asapo.Raw.Consumer |
asapo_producer_delete_stream | Asapo.Raw.Producer |
asapo_producer_enable_local_log | Asapo.Raw.Producer |
asapo_producer_enable_remote_log | Asapo.Raw.Producer |
asapo_producer_get_beamtime_meta | Asapo.Raw.Producer |
asapo_producer_get_last_stream | Asapo.Raw.Producer |
asapo_producer_get_requests_queue_size | Asapo.Raw.Producer |
asapo_producer_get_requests_queue_volume_mb | Asapo.Raw.Producer |
asapo_producer_get_stream_info | Asapo.Raw.Producer |
asapo_producer_get_stream_meta | Asapo.Raw.Producer |
asapo_producer_get_version_info | Asapo.Raw.Producer |
asapo_producer_send | Asapo.Raw.Producer |
asapo_producer_send_beamtime_metadata | Asapo.Raw.Producer |
asapo_producer_send_file | Asapo.Raw.Producer |
asapo_producer_send_stream_finished_flag | Asapo.Raw.Producer |
asapo_producer_send_stream_metadata | Asapo.Raw.Producer |
asapo_producer_set_credentials | Asapo.Raw.Producer |
asapo_producer_set_log_level | Asapo.Raw.Producer |
asapo_producer_set_requests_queue_limits | Asapo.Raw.Producer |
asapo_producer_wait_requests_finished | Asapo.Raw.Producer |
asapo_request_callback_payload_get_original_header | Asapo.Raw.Producer |
asapo_request_callback_payload_get_response | Asapo.Raw.Producer |
asapo_stream_infos_get_item | Asapo.Raw.Common |
asapo_stream_infos_get_size | Asapo.Raw.Consumer |
asapo_stream_info_get_finished | Asapo.Raw.Common |
asapo_stream_info_get_last_id | Asapo.Raw.Common |
asapo_stream_info_get_name | Asapo.Raw.Common |
asapo_stream_info_get_next_stream | Asapo.Raw.Common |
asapo_stream_info_get_timestamp_created | Asapo.Raw.Common |
asapo_stream_info_get_timestamp_last_entry | Asapo.Raw.Common |
asapo_string_c_str | Asapo.Raw.Common |
asapo_string_from_c_str | Asapo.Raw.Common |
asapo_string_size | Asapo.Raw.Common |
AutoIdFlag | Asapo.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 |
beamline | Asapo.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 |
beamtime | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
checkError | Asapo.Either.Producer |
checkErrorWithGivenHandle | Asapo.Either.Producer |
ConnectionFabric | Asapo.Either.Consumer, Asapo.Consumer |
ConnectionTcp | Asapo.Either.Consumer, Asapo.Consumer |
ConnectionUndefined | Asapo.Either.Consumer, Asapo.Consumer |
ConstCString | Asapo.Raw.Common |
Consumer | Asapo.Either.Consumer, Asapo.Consumer |
createRequestCallback | Asapo.Raw.Producer |
DataAndMetadata | Asapo.Either.Producer, Asapo.Producer |
Database | Asapo.Either.Producer, Asapo.Producer |
DataNotInCache | Asapo.Consumer |
Dataset | |
1 (Type/Class) | Asapo.Either.Consumer, Asapo.Consumer |
2 (Data Constructor) | Asapo.Either.Consumer, Asapo.Consumer |
datasetExpectedSize | Asapo.Either.Consumer, Asapo.Consumer |
datasetId | Asapo.Either.Consumer, Asapo.Consumer |
datasetItems | Asapo.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 |
dataSource | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
DeleteErrorOnNotExist | Asapo.Either.Producer, Asapo.Producer |
DeleteFlag | Asapo.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 |
DeletionFlags | Asapo.Either.Producer, Asapo.Producer |
DontDeleteMeta | Asapo.Either.Consumer, Asapo.Consumer |
enableLocalLog | Asapo.Either.Producer, Asapo.Producer |
enableRemoteLog | Asapo.Either.Producer, Asapo.Producer |
EndOfStream | Asapo.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 |
ErrorDataNotInCache | Asapo.Either.Consumer |
ErrorEndOfStream | Asapo.Either.Consumer |
ErrorInterruptedTransaction | Asapo.Either.Consumer |
ErrorLocalIOError | Asapo.Either.Consumer |
errorMessage | Asapo.Either.Consumer |
ErrorNoData | Asapo.Either.Consumer, Asapo.Consumer |
ErrorOnNotExist | Asapo.Either.Consumer, Asapo.Consumer |
ErrorOnNotExistFlag | Asapo.Either.Consumer, Asapo.Consumer |
ErrorPartialData | Asapo.Either.Consumer |
ErrorStreamFinished | Asapo.Either.Consumer |
ErrorType | Asapo.Either.Consumer, Asapo.Consumer |
errorType | Asapo.Either.Consumer |
ErrorUnavailableService | Asapo.Either.Consumer |
ErrorUnknownError | Asapo.Either.Consumer |
ErrorUnsupportedClient | Asapo.Either.Consumer |
ErrorWrongInput | Asapo.Either.Consumer |
ExcludeIncomplete | Asapo.Either.Consumer, Asapo.Consumer |
FileName | |
1 (Type/Class) | Asapo.Either.Producer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Producer, Asapo.Producer |
Filesystem | Asapo.Either.Producer, Asapo.Producer |
FilesystemAndDatabase | Asapo.Either.Producer, Asapo.Producer |
FilesystemFlag | Asapo.Either.Consumer, Asapo.Consumer |
FilesystemHandler | Asapo.Either.Producer, Asapo.Producer |
FilterAllStreams | Asapo.Either.Consumer, Asapo.Consumer |
FilterFinishedStreams | Asapo.Either.Consumer, Asapo.Consumer |
FilterUnfinishedStreams | Asapo.Either.Consumer, Asapo.Consumer |
GenericRequestHeader | |
1 (Type/Class) | Asapo.Either.Producer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderApiVersion | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderCustomData | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderDataId | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderDataSize | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderMessage | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderMetaSize | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderOpCode | Asapo.Either.Producer, Asapo.Producer |
genericRequestHeaderStream | Asapo.Either.Producer, Asapo.Producer |
getBeamtimeMeta | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
3 (Function) | Asapo.Either.Producer |
4 (Function) | Asapo.Producer |
getCurrentConnectionType | Asapo.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 |
getRequestsQueueSize | Asapo.Either.Producer, Asapo.Producer |
getRequestsQueueVolumeMb | Asapo.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 |
GroupId | Asapo.Either.Consumer, Asapo.Consumer |
IncludeIncomplete | Asapo.Either.Consumer, Asapo.Consumer |
IncludeIncompleteFlag | Asapo.Either.Consumer, Asapo.Consumer |
Insert | Asapo.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 |
instanceId | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
InterruptedTransaction | Asapo.Consumer |
kAllStreams | Asapo.Raw.Consumer |
kAsapoTcp | Asapo.Raw.Consumer |
kDataNotInCache | Asapo.Raw.Consumer |
kDefaultIngestMode | Asapo.Raw.Producer |
kEndOfStream | Asapo.Raw.Consumer |
kFabric | Asapo.Raw.Consumer |
kFilesystem | Asapo.Raw.Producer |
kFinishedStreams | Asapo.Raw.Consumer |
kInsert | Asapo.Raw.Producer |
kInterruptedTransaction | Asapo.Raw.Consumer |
kLocalIOError | Asapo.Raw.Consumer |
kMaxMessageSize | Asapo.Raw.Producer |
kMaxVersionSize | Asapo.Raw.Producer |
kNCustomParams | Asapo.Raw.Producer |
kNoData | Asapo.Raw.Consumer |
kOpcodeAuthorize | Asapo.Raw.Producer |
kOpcodeCount | Asapo.Raw.Producer |
kOpcodeDeleteStream | Asapo.Raw.Producer |
kOpcodeGetBufferData | Asapo.Raw.Producer |
kOpcodeGetMeta | Asapo.Raw.Producer |
kOpcodeLastStream | Asapo.Raw.Producer |
kOpcodePersistStream | Asapo.Raw.Producer |
kOpcodeStreamInfo | Asapo.Raw.Producer |
kOpcodeTransferData | Asapo.Raw.Producer |
kOpcodeTransferDatasetData | Asapo.Raw.Producer |
kOpcodeTransferMetaData | Asapo.Raw.Producer |
kOpcodeUnknownOp | Asapo.Raw.Producer |
kPartialData | Asapo.Raw.Consumer |
kProcessed | Asapo.Raw.Common |
kRaw | Asapo.Raw.Common |
kReplace | Asapo.Raw.Producer |
kStoreInDatabase | Asapo.Raw.Producer |
kStoreInFilesystem | Asapo.Raw.Producer |
kStreamFinished | Asapo.Raw.Consumer |
kTcp | Asapo.Raw.Producer |
kTransferData | Asapo.Raw.Producer |
kTransferMetaDataOnly | Asapo.Raw.Producer |
kUnavailableService | Asapo.Raw.Consumer |
kUndefined | Asapo.Raw.Consumer |
kUnfinishedStreams | Asapo.Raw.Consumer |
kUnknownError | Asapo.Raw.Consumer |
kUnsupportedClient | Asapo.Raw.Consumer |
kUpdate | Asapo.Raw.Producer |
kWrongInput | Asapo.Raw.Consumer |
LocalIOError | Asapo.Consumer |
LogDebug | Asapo.Either.Producer, Asapo.Producer |
LogError | Asapo.Either.Producer, Asapo.Producer |
LogInfo | Asapo.Either.Producer, Asapo.Producer |
LogLevel | Asapo.Either.Producer, Asapo.Producer |
LogNone | Asapo.Either.Producer, Asapo.Producer |
LogWarning | Asapo.Either.Producer, Asapo.Producer |
MessageId | |
1 (Type/Class) | Asapo.Either.Common, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Common, Asapo.Producer |
messageIdFromInt | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
MessageMeta | |
1 (Type/Class) | Asapo.Either.Consumer, Asapo.Consumer |
2 (Data Constructor) | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaBufId | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaDatasetSubstream | Asapo.Either.Consumer, Asapo.Consumer |
MessageMetaHandle | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaHandle | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaId | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaMetadata | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaName | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaSize | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaSource | Asapo.Either.Consumer, Asapo.Consumer |
messageMetaTimestamp | Asapo.Either.Consumer, Asapo.Consumer |
Metadata | |
1 (Type/Class) | Asapo.Either.Producer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Producer, Asapo.Producer |
MetadataIngestMode | Asapo.Either.Producer, Asapo.Producer |
MetadataOnly | Asapo.Either.Producer, Asapo.Producer |
mkAsapoFreeWrapper | Asapo.Raw.Common |
negativeAcknowledge | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
NetworkConnectionType | Asapo.Either.Consumer, Asapo.Consumer |
NoAutoId | Asapo.Either.Producer, Asapo.Producer |
NoData | Asapo.Consumer |
NoErrorOnNotExist | Asapo.Either.Consumer, Asapo.Consumer |
nominalDiffToMillis | Asapo.Either.Common |
NoUpsert | Asapo.Either.Producer, Asapo.Producer |
Opcode | Asapo.Either.Producer, Asapo.Producer |
OpcodeAuthorize | Asapo.Either.Producer, Asapo.Producer |
OpcodeCount | Asapo.Either.Producer, Asapo.Producer |
OpcodeDeleteStream | Asapo.Either.Producer, Asapo.Producer |
OpcodeGetBufferData | Asapo.Either.Producer, Asapo.Producer |
OpcodeGetMeta | Asapo.Either.Producer, Asapo.Producer |
OpcodeLastStream | Asapo.Either.Producer, Asapo.Producer |
OpcodePersistStream | Asapo.Either.Producer, Asapo.Producer |
OpcodeStreamInfo | Asapo.Either.Producer, Asapo.Producer |
OpcodeTransferData | Asapo.Either.Producer, Asapo.Producer |
OpcodeTransferDatasetData | Asapo.Either.Producer, Asapo.Producer |
OpcodeTransferMetaData | Asapo.Either.Producer, Asapo.Producer |
OpcodeUnknownOp | Asapo.Either.Producer, Asapo.Producer |
PartialData | Asapo.Consumer |
peekConstCStringText | Asapo.Either.Common |
peekCStringText | Asapo.Either.Common |
PipelineStep | |
1 (Type/Class) | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
pipelineStep | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
ProcessedSource | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
ProcessingThreads | |
1 (Type/Class) | Asapo.Either.Producer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Producer, Asapo.Producer |
Producer | Asapo.Either.Producer, Asapo.Producer |
ProducerException | |
1 (Type/Class) | Asapo.Producer |
2 (Data Constructor) | Asapo.Producer |
p_asapo_free_handle | Asapo.Raw.FreeHandleHack |
queryMessages | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
queryMessagesHandles | Asapo.Either.Consumer |
RawSource | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
Replace | Asapo.Either.Producer, Asapo.Producer |
RequestHandlerType | Asapo.Either.Producer, Asapo.Producer |
RequestResponse | |
1 (Type/Class) | Asapo.Either.Producer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Producer, Asapo.Producer |
resendNacs | Asapo.Either.Consumer, Asapo.Consumer |
resetLastReadMarker | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
resolveMetadata | Asapo.Either.Consumer |
responseError | Asapo.Either.Producer, Asapo.Producer |
responseOriginalRequestHeader | Asapo.Either.Producer, Asapo.Producer |
responsePayload | Asapo.Either.Producer, Asapo.Producer |
retrieveDataForMessageMeta | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
retrieveDataFromMeta | Asapo.Either.Consumer |
retrieveStreamInfoFromC | Asapo.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 |
setLogLevel | Asapo.Either.Producer, Asapo.Producer |
setRequestsQueueLimits | Asapo.Either.Producer, Asapo.Producer |
setStreamPersistent | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
setTimeout | Asapo.Either.Consumer, Asapo.Consumer |
SomeConsumerException | Asapo.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 |
SourceType | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
sourceType | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
StorageFlag | Asapo.Either.Producer, Asapo.Producer |
StreamFilter | Asapo.Either.Consumer, Asapo.Consumer |
StreamFinished | Asapo.Consumer |
StreamInfo | |
1 (Type/Class) | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
streamInfoCreated | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
streamInfoFinished | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
streamInfoLastEntry | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
streamInfoLastId | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
streamInfoName | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
streamInfoNextStream | Asapo.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 |
stringHandleToText | Asapo.Either.Common |
stringHandleToTextUnsafe | Asapo.Either.Common |
TcpHandler | Asapo.Either.Producer, Asapo.Producer |
timespecToUTC | Asapo.Either.Common |
Token | |
1 (Type/Class) | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
token | Asapo.Either.Common, Asapo.Consumer, Asapo.Producer |
TransferFlag | Asapo.Either.Producer, Asapo.Producer |
UnavailableService | Asapo.Consumer |
UnknownError | Asapo.Consumer |
UnsupportedClient | Asapo.Consumer |
Update | Asapo.Either.Producer, Asapo.Producer |
UpsertMode | Asapo.Either.Producer, Asapo.Producer |
UseAutoId | Asapo.Either.Producer, Asapo.Producer |
UseUpsert | Asapo.Either.Producer, Asapo.Producer |
versionClient | Asapo.Either.Producer, Asapo.Producer |
VersionInfo | |
1 (Type/Class) | Asapo.Either.Producer, Asapo.Producer |
2 (Data Constructor) | Asapo.Either.Producer, Asapo.Producer |
versionServer | Asapo.Either.Producer, Asapo.Producer |
versionSupported | Asapo.Either.Producer, Asapo.Producer |
waitRequestsFinished | |
1 (Function) | Asapo.Either.Producer |
2 (Function) | Asapo.Producer |
withConstCString | Asapo.Either.Common |
withConstText | Asapo.Either.Common |
withConsumer | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
withCredentials | Asapo.Either.Common |
withCStringN | Asapo.Either.Common |
withCStringNToText | Asapo.Either.Common |
WithFilesystem | Asapo.Either.Consumer, Asapo.Consumer |
withGroupId | |
1 (Function) | Asapo.Either.Consumer |
2 (Function) | Asapo.Consumer |
WithoutFilesystem | Asapo.Either.Consumer, Asapo.Consumer |
withProducer | |
1 (Function) | Asapo.Either.Producer |
2 (Function) | Asapo.Producer |
withPtr | Asapo.Either.Common |
withText | Asapo.Either.Common |
WrongInput | Asapo.Consumer |