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 |