#p:>      !"#$%&'()*+,-./0123456789:;<=Safep>?@ABCDENone.;=>?@AFHMVXgk!c@F supernovaFields : $:: Lens' Subscription Data.Text.Text $:: Lens' Subscription Data.Text.Text G supernovaFields : ):: Lens' SingleMessageMetadata [KeyValue] <:: Lens' SingleMessageMetadata (Data.Vector.Vector KeyValue)  -:: Lens' SingleMessageMetadata Data.Text.Text  =:: Lens' SingleMessageMetadata (Prelude.Maybe Data.Text.Text)  -:: Lens' SingleMessageMetadata Data.Int.Int32  +:: Lens' SingleMessageMetadata Prelude.Bool  ;:: Lens' SingleMessageMetadata (Prelude.Maybe Prelude.Bool) /:: Lens' SingleMessageMetadata Data.Word.Word64 ?:: Lens' SingleMessageMetadata (Prelude.Maybe Data.Word.Word64) +:: Lens' SingleMessageMetadata Prelude.Bool ;:: Lens' SingleMessageMetadata (Prelude.Maybe Prelude.Bool) 9:: Lens' SingleMessageMetadata Data.ByteString.ByteString I:: Lens' SingleMessageMetadata (Prelude.Maybe Data.ByteString.ByteString) /:: Lens' SingleMessageMetadata Data.Word.Word64 ?:: Lens' SingleMessageMetadata (Prelude.Maybe Data.Word.Word64) +:: Lens' SingleMessageMetadata Prelude.Bool ;:: Lens' SingleMessageMetadata (Prelude.Maybe Prelude.Bool) +:: Lens' SingleMessageMetadata Prelude.Bool ;:: Lens' SingleMessageMetadata (Prelude.Maybe Prelude.Bool) H supernovaFields : :: Lens' Schema Data.Text.Text *:: Lens' Schema Data.ByteString.ByteString :: Lens' Schema Schema'Type :: Lens' Schema [KeyValue] -:: Lens' Schema (Data.Vector.Vector KeyValue) I supernovaFields :5 ':: Lens' MessageMetadata Data.Text.Text ):: Lens' MessageMetadata Data.Word.Word64 ):: Lens' MessageMetadata Data.Word.Word64 #:: Lens' MessageMetadata [KeyValue] 6:: Lens' MessageMetadata (Data.Vector.Vector KeyValue) ':: Lens' MessageMetadata Data.Text.Text  7:: Lens' MessageMetadata (Prelude.Maybe Data.Text.Text)  ':: Lens' MessageMetadata Data.Text.Text  7:: Lens' MessageMetadata (Prelude.Maybe Data.Text.Text)! ):: Lens' MessageMetadata [Data.Text.Text]" <:: Lens' MessageMetadata (Data.Vector.Vector Data.Text.Text)# (:: Lens' MessageMetadata CompressionType$ 8:: Lens' MessageMetadata (Prelude.Maybe CompressionType)% ):: Lens' MessageMetadata Data.Word.Word32& 9:: Lens' MessageMetadata (Prelude.Maybe Data.Word.Word32)' ':: Lens' MessageMetadata Data.Int.Int32( 7:: Lens' MessageMetadata (Prelude.Maybe Data.Int.Int32) ):: Lens' MessageMetadata Data.Word.Word64 9:: Lens' MessageMetadata (Prelude.Maybe Data.Word.Word64)) ):: Lens' MessageMetadata [EncryptionKeys]* <:: Lens' MessageMetadata (Data.Vector.Vector EncryptionKeys)+ ':: Lens' MessageMetadata Data.Text.Text, 7:: Lens' MessageMetadata (Prelude.Maybe Data.Text.Text)- 3:: Lens' MessageMetadata Data.ByteString.ByteString. C:: Lens' MessageMetadata (Prelude.Maybe Data.ByteString.ByteString)/ 3:: Lens' MessageMetadata Data.ByteString.ByteString0 C:: Lens' MessageMetadata (Prelude.Maybe Data.ByteString.ByteString) %:: Lens' MessageMetadata Prelude.Bool 5:: Lens' MessageMetadata (Prelude.Maybe Prelude.Bool) 3:: Lens' MessageMetadata Data.ByteString.ByteString C:: Lens' MessageMetadata (Prelude.Maybe Data.ByteString.ByteString)1 ':: Lens' MessageMetadata Data.Int.Int642 7:: Lens' MessageMetadata (Prelude.Maybe Data.Int.Int64)3 ':: Lens' MessageMetadata Data.Int.Int324 7:: Lens' MessageMetadata (Prelude.Maybe Data.Int.Int32)5 ):: Lens' MessageMetadata Data.Word.Word646 9:: Lens' MessageMetadata (Prelude.Maybe Data.Word.Word64)7 ):: Lens' MessageMetadata Data.Word.Word648 9:: Lens' MessageMetadata (Prelude.Maybe Data.Word.Word64)9 ):: Lens' MessageMetadata Data.Word.Word64: 9:: Lens' MessageMetadata (Prelude.Maybe Data.Word.Word64) %:: Lens' MessageMetadata Prelude.Bool 5:: Lens' MessageMetadata (Prelude.Maybe Prelude.Bool); ':: Lens' MessageMetadata Data.Text.Text< 7:: Lens' MessageMetadata (Prelude.Maybe Data.Text.Text)= ':: Lens' MessageMetadata Data.Int.Int32> 7:: Lens' MessageMetadata (Prelude.Maybe Data.Int.Int32)? ':: Lens' MessageMetadata Data.Int.Int32@ 7:: Lens' MessageMetadata (Prelude.Maybe Data.Int.Int32)A ':: Lens' MessageMetadata Data.Int.Int32B 7:: Lens' MessageMetadata (Prelude.Maybe Data.Int.Int32) %:: Lens' MessageMetadata Prelude.Bool 5:: Lens' MessageMetadata (Prelude.Maybe Prelude.Bool) J supernovaFields :C ':: Lens' MessageIdData Data.Word.Word64D ':: Lens' MessageIdData Data.Word.Word64E %:: Lens' MessageIdData Data.Int.Int32F 5:: Lens' MessageIdData (Prelude.Maybe Data.Int.Int32)G %:: Lens' MessageIdData Data.Int.Int32H 5:: Lens' MessageIdData (Prelude.Maybe Data.Int.Int32)I ':: Lens' MessageIdData [Data.Int.Int64]J B:: Lens' MessageIdData (Data.Vector.Unboxed.Vector Data.Int.Int64) K supernovaFields :K  :: Lens' KeyValue Data.Text.TextL  :: Lens' KeyValue Data.Text.Text L supernovaFields :M $:: Lens' KeySharedMeta KeySharedModeN !:: Lens' KeySharedMeta [IntRange]O 4:: Lens' KeySharedMeta (Data.Vector.Vector IntRange)P #:: Lens' KeySharedMeta Prelude.BoolQ 3:: Lens' KeySharedMeta (Prelude.Maybe Prelude.Bool) M supernovaFields :K $:: Lens' KeyLongValue Data.Text.TextL &:: Lens' KeyLongValue Data.Word.Word64 N supernovaFields :R  :: Lens' IntRange Data.Int.Int32S  :: Lens' IntRange Data.Int.Int32 O supernovaFields :T ":: Lens' FeatureFlags Prelude.BoolU 2:: Lens' FeatureFlags (Prelude.Maybe Prelude.Bool) P supernovaFields :K &:: Lens' EncryptionKeys Data.Text.TextL 2:: Lens' EncryptionKeys Data.ByteString.ByteStringV ":: Lens' EncryptionKeys [KeyValue]W 5:: Lens' EncryptionKeys (Data.Vector.Vector KeyValue) Q supernovaFields :X ,:: Lens' CommandUnsubscribe Data.Word.Word64Y ,:: Lens' CommandUnsubscribe Data.Word.Word64 R supernovaFields :Y (:: Lens' CommandSuccess Data.Word.Word64Z :: Lens' CommandSuccess Schema[ .:: Lens' CommandSuccess (Prelude.Maybe Schema) S supernovaFields : (:: Lens' CommandSubscribe Data.Text.Text (:: Lens' CommandSubscribe Data.Text.Text\ 2:: Lens' CommandSubscribe CommandSubscribe'SubTypeX *:: Lens' CommandSubscribe Data.Word.Word64Y *:: Lens' CommandSubscribe Data.Word.Word64] (:: Lens' CommandSubscribe Data.Text.Text^ 8:: Lens' CommandSubscribe (Prelude.Maybe Data.Text.Text)_ (:: Lens' CommandSubscribe Data.Int.Int32` 8:: Lens' CommandSubscribe (Prelude.Maybe Data.Int.Int32)a &:: Lens' CommandSubscribe Prelude.Boolb 6:: Lens' CommandSubscribe (Prelude.Maybe Prelude.Bool)c ':: Lens' CommandSubscribe MessageIdDatad 7:: Lens' CommandSubscribe (Prelude.Maybe MessageIdData)V $:: Lens' CommandSubscribe [KeyValue]W 7:: Lens' CommandSubscribe (Data.Vector.Vector KeyValue)e &:: Lens' CommandSubscribe Prelude.Boolf 6:: Lens' CommandSubscribe (Prelude.Maybe Prelude.Bool)Z  :: Lens' CommandSubscribe Schema[ 0:: Lens' CommandSubscribe (Prelude.Maybe Schema)g ::: Lens' CommandSubscribe CommandSubscribe'InitialPositionh J:: Lens' CommandSubscribe (Prelude.Maybe CommandSubscribe'InitialPosition)i &:: Lens' CommandSubscribe Prelude.Boolj 6:: Lens' CommandSubscribe (Prelude.Maybe Prelude.Bool)k &:: Lens' CommandSubscribe Prelude.Booll 6:: Lens' CommandSubscribe (Prelude.Maybe Prelude.Bool)m *:: Lens' CommandSubscribe Data.Word.Word64n ::: Lens' CommandSubscribe (Prelude.Maybe Data.Word.Word64)o ':: Lens' CommandSubscribe KeySharedMetap 7:: Lens' CommandSubscribe (Prelude.Maybe KeySharedMeta) T supernovaFields :q ,:: Lens' CommandSendReceipt Data.Word.Word64 ,:: Lens' CommandSendReceipt Data.Word.Word64r ):: Lens' CommandSendReceipt MessageIdDatas 9:: Lens' CommandSendReceipt (Prelude.Maybe MessageIdData)9 ,:: Lens' CommandSendReceipt Data.Word.Word64: <:: Lens' CommandSendReceipt (Prelude.Maybe Data.Word.Word64) U supernovaFields :q *:: Lens' CommandSendError Data.Word.Word64 *:: Lens' CommandSendError Data.Word.Word64t %:: Lens' CommandSendError ServerErroru (:: Lens' CommandSendError Data.Text.Text V supernovaFields : q %:: Lens' CommandSend Data.Word.Word64 %:: Lens' CommandSend Data.Word.Word64v #:: Lens' CommandSend Data.Int.Int32w 3:: Lens' CommandSend (Prelude.Maybe Data.Int.Int32)5 %:: Lens' CommandSend Data.Word.Word646 5:: Lens' CommandSend (Prelude.Maybe Data.Word.Word64)7 %:: Lens' CommandSend Data.Word.Word648 5:: Lens' CommandSend (Prelude.Maybe Data.Word.Word64)9 %:: Lens' CommandSend Data.Word.Word64: 5:: Lens' CommandSend (Prelude.Maybe Data.Word.Word64)x !:: Lens' CommandSend Prelude.Booly 1:: Lens' CommandSend (Prelude.Maybe Prelude.Bool) W supernovaFields :X %:: Lens' CommandSeek Data.Word.Word64Y %:: Lens' CommandSeek Data.Word.Word64r ":: Lens' CommandSeek MessageIdDatas 2:: Lens' CommandSeek (Prelude.Maybe MessageIdData)z %:: Lens' CommandSeek Data.Word.Word64{ 5:: Lens' CommandSeek (Prelude.Maybe Data.Word.Word64) X supernovaFields :X @:: Lens' CommandRedeliverUnacknowledgedMessages Data.Word.Word64| ?:: Lens' CommandRedeliverUnacknowledgedMessages [MessageIdData]} R:: Lens' CommandRedeliverUnacknowledgedMessages (Data.Vector.Vector MessageIdData) Y supernovaFields :X 2:: Lens' CommandReachedEndOfTopic Data.Word.Word64 Z supernovaFields :Y 0:: Lens' CommandProducerSuccess Data.Word.Word64 .:: Lens' CommandProducerSuccess Data.Text.Text~ .:: Lens' CommandProducerSuccess Data.Int.Int64 >:: Lens' CommandProducerSuccess (Prelude.Maybe Data.Int.Int64)/ ::: Lens' CommandProducerSuccess Data.ByteString.ByteString0 J:: Lens' CommandProducerSuccess (Prelude.Maybe Data.ByteString.ByteString) [ supernovaFields : ':: Lens' CommandProducer Data.Text.Textq ):: Lens' CommandProducer Data.Word.Word64Y ):: Lens' CommandProducer Data.Word.Word64 ':: Lens' CommandProducer Data.Text.Text 7:: Lens' CommandProducer (Prelude.Maybe Data.Text.Text) %:: Lens' CommandProducer Prelude.Bool 5:: Lens' CommandProducer (Prelude.Maybe Prelude.Bool)V #:: Lens' CommandProducer [KeyValue]W 6:: Lens' CommandProducer (Data.Vector.Vector KeyValue)Z :: Lens' CommandProducer Schema[ /:: Lens' CommandProducer (Prelude.Maybe Schema) ):: Lens' CommandProducer Data.Word.Word64 9:: Lens' CommandProducer (Prelude.Maybe Data.Word.Word64) %:: Lens' CommandProducer Prelude.Bool 5:: Lens' CommandProducer (Prelude.Maybe Prelude.Bool) \ supernovaFields :] supernovaFields :^ supernovaFields :  A:: Lens' CommandPartitionedTopicMetadataResponse Data.Word.Word32 Q:: Lens' CommandPartitionedTopicMetadataResponse (Prelude.Maybe Data.Word.Word32)Y A:: Lens' CommandPartitionedTopicMetadataResponse Data.Word.Word64 c:: Lens' CommandPartitionedTopicMetadataResponse CommandPartitionedTopicMetadataResponse'LookupType s:: Lens' CommandPartitionedTopicMetadataResponse (Prelude.Maybe CommandPartitionedTopicMetadataResponse'LookupType)t <:: Lens' CommandPartitionedTopicMetadataResponse ServerError L:: Lens' CommandPartitionedTopicMetadataResponse (Prelude.Maybe ServerError)u ?:: Lens' CommandPartitionedTopicMetadataResponse Data.Text.Text O:: Lens' CommandPartitionedTopicMetadataResponse (Prelude.Maybe Data.Text.Text) _ supernovaFields : 7:: Lens' CommandPartitionedTopicMetadata Data.Text.TextY 9:: Lens' CommandPartitionedTopicMetadata Data.Word.Word64 7:: Lens' CommandPartitionedTopicMetadata Data.Text.Text G:: Lens' CommandPartitionedTopicMetadata (Prelude.Maybe Data.Text.Text) 7:: Lens' CommandPartitionedTopicMetadata Data.Text.Text G:: Lens' CommandPartitionedTopicMetadata (Prelude.Maybe Data.Text.Text) 7:: Lens' CommandPartitionedTopicMetadata Data.Text.Text G:: Lens' CommandPartitionedTopicMetadata (Prelude.Maybe Data.Text.Text) ` supernovaFields : Y /:: Lens' CommandNewTxnResponse Data.Word.Word645 /:: Lens' CommandNewTxnResponse Data.Word.Word646 ?:: Lens' CommandNewTxnResponse (Prelude.Maybe Data.Word.Word64)7 /:: Lens' CommandNewTxnResponse Data.Word.Word648 ?:: Lens' CommandNewTxnResponse (Prelude.Maybe Data.Word.Word64)t *:: Lens' CommandNewTxnResponse ServerError ::: Lens' CommandNewTxnResponse (Prelude.Maybe ServerError)u -:: Lens' CommandNewTxnResponse Data.Text.Text =:: Lens' CommandNewTxnResponse (Prelude.Maybe Data.Text.Text) a supernovaFields :Y ':: Lens' CommandNewTxn Data.Word.Word64 ':: Lens' CommandNewTxn Data.Word.Word64 7:: Lens' CommandNewTxn (Prelude.Maybe Data.Word.Word64) ':: Lens' CommandNewTxn Data.Word.Word64 7:: Lens' CommandNewTxn (Prelude.Maybe Data.Word.Word64) b supernovaFields :X (:: Lens' CommandMessage Data.Word.Word64r %:: Lens' CommandMessage MessageIdData (:: Lens' CommandMessage Data.Word.Word32 8:: Lens' CommandMessage (Prelude.Maybe Data.Word.Word32)I (:: Lens' CommandMessage [Data.Int.Int64]J C:: Lens' CommandMessage (Data.Vector.Unboxed.Vector Data.Int.Int64) c supernovaFields : 2:: Lens' CommandLookupTopicResponse Data.Text.Text B:: Lens' CommandLookupTopicResponse (Prelude.Maybe Data.Text.Text) 2:: Lens' CommandLookupTopicResponse Data.Text.Text B:: Lens' CommandLookupTopicResponse (Prelude.Maybe Data.Text.Text) I:: Lens' CommandLookupTopicResponse CommandLookupTopicResponse'LookupType Y:: Lens' CommandLookupTopicResponse (Prelude.Maybe CommandLookupTopicResponse'LookupType)Y 4:: Lens' CommandLookupTopicResponse Data.Word.Word64 0:: Lens' CommandLookupTopicResponse Prelude.Bool @:: Lens' CommandLookupTopicResponse (Prelude.Maybe Prelude.Bool)t /:: Lens' CommandLookupTopicResponse ServerError ?:: Lens' CommandLookupTopicResponse (Prelude.Maybe ServerError)u 2:: Lens' CommandLookupTopicResponse Data.Text.Text B:: Lens' CommandLookupTopicResponse (Prelude.Maybe Data.Text.Text) 0:: Lens' CommandLookupTopicResponse Prelude.Bool @:: Lens' CommandLookupTopicResponse (Prelude.Maybe Prelude.Bool) d supernovaFields :  *:: Lens' CommandLookupTopic Data.Text.TextY ,:: Lens' CommandLookupTopic Data.Word.Word64 (:: Lens' CommandLookupTopic Prelude.Bool 8:: Lens' CommandLookupTopic (Prelude.Maybe Prelude.Bool) *:: Lens' CommandLookupTopic Data.Text.Text ::: Lens' CommandLookupTopic (Prelude.Maybe Data.Text.Text) *:: Lens' CommandLookupTopic Data.Text.Text ::: Lens' CommandLookupTopic (Prelude.Maybe Data.Text.Text) *:: Lens' CommandLookupTopic Data.Text.Text ::: Lens' CommandLookupTopic (Prelude.Maybe Data.Text.Text) *:: Lens' CommandLookupTopic Data.Text.Text ::: Lens' CommandLookupTopic (Prelude.Maybe Data.Text.Text) e supernovaFields :Y =:: Lens' CommandGetTopicsOfNamespaceResponse Data.Word.Word64 =:: Lens' CommandGetTopicsOfNamespaceResponse [Data.Text.Text] P:: Lens' CommandGetTopicsOfNamespaceResponse (Data.Vector.Vector Data.Text.Text) f supernovaFields :Y 5:: Lens' CommandGetTopicsOfNamespace Data.Word.Word64 3:: Lens' CommandGetTopicsOfNamespace Data.Text.Text E:: Lens' CommandGetTopicsOfNamespace CommandGetTopicsOfNamespace'Mode U:: Lens' CommandGetTopicsOfNamespace (Prelude.Maybe CommandGetTopicsOfNamespace'Mode) g supernovaFields : Y 2:: Lens' CommandGetSchemaResponse Data.Word.Word64 -:: Lens' CommandGetSchemaResponse ServerError =:: Lens' CommandGetSchemaResponse (Prelude.Maybe ServerError) 0:: Lens' CommandGetSchemaResponse Data.Text.Text @:: Lens' CommandGetSchemaResponse (Prelude.Maybe Data.Text.Text)Z (:: Lens' CommandGetSchemaResponse Schema[ 8:: Lens' CommandGetSchemaResponse (Prelude.Maybe Schema)/ <:: Lens' CommandGetSchemaResponse Data.ByteString.ByteString0 L:: Lens' CommandGetSchemaResponse (Prelude.Maybe Data.ByteString.ByteString) h supernovaFields :Y *:: Lens' CommandGetSchema Data.Word.Word64 (:: Lens' CommandGetSchema Data.Text.Text/ 4:: Lens' CommandGetSchema Data.ByteString.ByteString0 D:: Lens' CommandGetSchema (Prelude.Maybe Data.ByteString.ByteString) i supernovaFields :Y ::: Lens' CommandGetOrCreateSchemaResponse Data.Word.Word64 5:: Lens' CommandGetOrCreateSchemaResponse ServerError E:: Lens' CommandGetOrCreateSchemaResponse (Prelude.Maybe ServerError) 8:: Lens' CommandGetOrCreateSchemaResponse Data.Text.Text H:: Lens' CommandGetOrCreateSchemaResponse (Prelude.Maybe Data.Text.Text)/ D:: Lens' CommandGetOrCreateSchemaResponse Data.ByteString.ByteString0 T:: Lens' CommandGetOrCreateSchemaResponse (Prelude.Maybe Data.ByteString.ByteString) j supernovaFields :Y 2:: Lens' CommandGetOrCreateSchema Data.Word.Word64 0:: Lens' CommandGetOrCreateSchema Data.Text.TextZ (:: Lens' CommandGetOrCreateSchema Schema k supernovaFields : 6:: Lens' CommandGetLastMessageIdResponse MessageIdDataY 9:: Lens' CommandGetLastMessageIdResponse Data.Word.Word64 l supernovaFields :X 1:: Lens' CommandGetLastMessageId Data.Word.Word64Y 1:: Lens' CommandGetLastMessageId Data.Word.Word64 m supernovaFields :X %:: Lens' CommandFlow Data.Word.Word64 %:: Lens' CommandFlow Data.Word.Word32 n supernovaFields :Y &:: Lens' CommandError Data.Word.Word64t !:: Lens' CommandError ServerErroru $:: Lens' CommandError Data.Text.Text o supernovaFields : Y /:: Lens' CommandEndTxnResponse Data.Word.Word645 /:: Lens' CommandEndTxnResponse Data.Word.Word646 ?:: Lens' CommandEndTxnResponse (Prelude.Maybe Data.Word.Word64)7 /:: Lens' CommandEndTxnResponse Data.Word.Word648 ?:: Lens' CommandEndTxnResponse (Prelude.Maybe Data.Word.Word64)t *:: Lens' CommandEndTxnResponse ServerError ::: Lens' CommandEndTxnResponse (Prelude.Maybe ServerError)u -:: Lens' CommandEndTxnResponse Data.Text.Text =:: Lens' CommandEndTxnResponse (Prelude.Maybe Data.Text.Text) p supernovaFields : Y =:: Lens' CommandEndTxnOnSubscriptionResponse Data.Word.Word645 =:: Lens' CommandEndTxnOnSubscriptionResponse Data.Word.Word646 M:: Lens' CommandEndTxnOnSubscriptionResponse (Prelude.Maybe Data.Word.Word64)7 =:: Lens' CommandEndTxnOnSubscriptionResponse Data.Word.Word648 M:: Lens' CommandEndTxnOnSubscriptionResponse (Prelude.Maybe Data.Word.Word64)t 8:: Lens' CommandEndTxnOnSubscriptionResponse ServerError H:: Lens' CommandEndTxnOnSubscriptionResponse (Prelude.Maybe ServerError)u ;:: Lens' CommandEndTxnOnSubscriptionResponse Data.Text.Text K:: Lens' CommandEndTxnOnSubscriptionResponse (Prelude.Maybe Data.Text.Text) q supernovaFields : Y 5:: Lens' CommandEndTxnOnSubscription Data.Word.Word645 5:: Lens' CommandEndTxnOnSubscription Data.Word.Word646 E:: Lens' CommandEndTxnOnSubscription (Prelude.Maybe Data.Word.Word64)7 5:: Lens' CommandEndTxnOnSubscription Data.Word.Word648 E:: Lens' CommandEndTxnOnSubscription (Prelude.Maybe Data.Word.Word64) 1:: Lens' CommandEndTxnOnSubscription Subscription A:: Lens' CommandEndTxnOnSubscription (Prelude.Maybe Subscription) .:: Lens' CommandEndTxnOnSubscription TxnAction >:: Lens' CommandEndTxnOnSubscription (Prelude.Maybe TxnAction) r supernovaFields : Y ::: Lens' CommandEndTxnOnPartitionResponse Data.Word.Word645 ::: Lens' CommandEndTxnOnPartitionResponse Data.Word.Word646 J:: Lens' CommandEndTxnOnPartitionResponse (Prelude.Maybe Data.Word.Word64)7 ::: Lens' CommandEndTxnOnPartitionResponse Data.Word.Word648 J:: Lens' CommandEndTxnOnPartitionResponse (Prelude.Maybe Data.Word.Word64)t 5:: Lens' CommandEndTxnOnPartitionResponse ServerError E:: Lens' CommandEndTxnOnPartitionResponse (Prelude.Maybe ServerError)u 8:: Lens' CommandEndTxnOnPartitionResponse Data.Text.Text H:: Lens' CommandEndTxnOnPartitionResponse (Prelude.Maybe Data.Text.Text) s supernovaFields : Y 2:: Lens' CommandEndTxnOnPartition Data.Word.Word645 2:: Lens' CommandEndTxnOnPartition Data.Word.Word646 B:: Lens' CommandEndTxnOnPartition (Prelude.Maybe Data.Word.Word64)7 2:: Lens' CommandEndTxnOnPartition Data.Word.Word648 B:: Lens' CommandEndTxnOnPartition (Prelude.Maybe Data.Word.Word64) 0:: Lens' CommandEndTxnOnPartition Data.Text.Text @:: Lens' CommandEndTxnOnPartition (Prelude.Maybe Data.Text.Text) +:: Lens' CommandEndTxnOnPartition TxnAction ;:: Lens' CommandEndTxnOnPartition (Prelude.Maybe TxnAction) t supernovaFields :Y ':: Lens' CommandEndTxn Data.Word.Word645 ':: Lens' CommandEndTxn Data.Word.Word646 7:: Lens' CommandEndTxn (Prelude.Maybe Data.Word.Word64)7 ':: Lens' CommandEndTxn Data.Word.Word648 7:: Lens' CommandEndTxn (Prelude.Maybe Data.Word.Word64)  :: Lens' CommandEndTxn TxnAction 0:: Lens' CommandEndTxn (Prelude.Maybe TxnAction) u supernovaFields :Y 6:: Lens' CommandConsumerStatsResponse Data.Word.Word64 1:: Lens' CommandConsumerStatsResponse ServerError A:: Lens' CommandConsumerStatsResponse (Prelude.Maybe ServerError) 4:: Lens' CommandConsumerStatsResponse Data.Text.Text D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Text.Text) 4:: Lens' CommandConsumerStatsResponse Prelude.Double D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Prelude.Double) 4:: Lens' CommandConsumerStatsResponse Prelude.Double D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Prelude.Double) 4:: Lens' CommandConsumerStatsResponse Prelude.Double D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Prelude.Double)] 4:: Lens' CommandConsumerStatsResponse Data.Text.Text^ D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Text.Text) 6:: Lens' CommandConsumerStatsResponse Data.Word.Word64 F:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Word.Word64) 6:: Lens' CommandConsumerStatsResponse Data.Word.Word64 F:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Word.Word64) 2:: Lens' CommandConsumerStatsResponse Prelude.Bool B:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Prelude.Bool) 4:: Lens' CommandConsumerStatsResponse Data.Text.Text D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Text.Text) 4:: Lens' CommandConsumerStatsResponse Data.Text.Text D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Text.Text) 4:: Lens' CommandConsumerStatsResponse Data.Text.Text D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Text.Text) 4:: Lens' CommandConsumerStatsResponse Prelude.Double D:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Prelude.Double) 6:: Lens' CommandConsumerStatsResponse Data.Word.Word64 F:: Lens' CommandConsumerStatsResponse (Prelude.Maybe Data.Word.Word64) v supernovaFields :Y .:: Lens' CommandConsumerStats Data.Word.Word64X .:: Lens' CommandConsumerStats Data.Word.Word64 w supernovaFields : (:: Lens' CommandConnected Data.Text.Text (:: Lens' CommandConnected Data.Int.Int32 8:: Lens' CommandConnected (Prelude.Maybe Data.Int.Int32) (:: Lens' CommandConnected Data.Int.Int32 8:: Lens' CommandConnected (Prelude.Maybe Data.Int.Int32) x supernovaFields : &:: Lens' CommandConnect Data.Text.Text ":: Lens' CommandConnect AuthMethod 2:: Lens' CommandConnect (Prelude.Maybe AuthMethod) &:: Lens' CommandConnect Data.Text.Text 6:: Lens' CommandConnect (Prelude.Maybe Data.Text.Text) 2:: Lens' CommandConnect Data.ByteString.ByteString B:: Lens' CommandConnect (Prelude.Maybe Data.ByteString.ByteString) &:: Lens' CommandConnect Data.Int.Int32 6:: Lens' CommandConnect (Prelude.Maybe Data.Int.Int32) &:: Lens' CommandConnect Data.Text.Text 6:: Lens' CommandConnect (Prelude.Maybe Data.Text.Text) &:: Lens' CommandConnect Data.Text.Text 6:: Lens' CommandConnect (Prelude.Maybe Data.Text.Text) &:: Lens' CommandConnect Data.Text.Text 6:: Lens' CommandConnect (Prelude.Maybe Data.Text.Text) &:: Lens' CommandConnect Data.Text.Text 6:: Lens' CommandConnect (Prelude.Maybe Data.Text.Text) $:: Lens' CommandConnect FeatureFlags 4:: Lens' CommandConnect (Prelude.Maybe FeatureFlags) y supernovaFields :q .:: Lens' CommandCloseProducer Data.Word.Word64Y .:: Lens' CommandCloseProducer Data.Word.Word64 z supernovaFields :X .:: Lens' CommandCloseConsumer Data.Word.Word64Y .:: Lens' CommandCloseConsumer Data.Word.Word64 { supernovaFields : +:: Lens' CommandAuthResponse Data.Text.Text ;:: Lens' CommandAuthResponse (Prelude.Maybe Data.Text.Text) %:: Lens' CommandAuthResponse AuthData 5:: Lens' CommandAuthResponse (Prelude.Maybe AuthData) +:: Lens' CommandAuthResponse Data.Int.Int32 ;:: Lens' CommandAuthResponse (Prelude.Maybe Data.Int.Int32) | supernovaFields : ,:: Lens' CommandAuthChallenge Data.Text.Text <:: Lens' CommandAuthChallenge (Prelude.Maybe Data.Text.Text) &:: Lens' CommandAuthChallenge AuthData 6:: Lens' CommandAuthChallenge (Prelude.Maybe AuthData) ,:: Lens' CommandAuthChallenge Data.Int.Int32 <:: Lens' CommandAuthChallenge (Prelude.Maybe Data.Int.Int32) } supernovaFields : Y =:: Lens' CommandAddSubscriptionToTxnResponse Data.Word.Word645 =:: Lens' CommandAddSubscriptionToTxnResponse Data.Word.Word646 M:: Lens' CommandAddSubscriptionToTxnResponse (Prelude.Maybe Data.Word.Word64)7 =:: Lens' CommandAddSubscriptionToTxnResponse Data.Word.Word648 M:: Lens' CommandAddSubscriptionToTxnResponse (Prelude.Maybe Data.Word.Word64)t 8:: Lens' CommandAddSubscriptionToTxnResponse ServerError H:: Lens' CommandAddSubscriptionToTxnResponse (Prelude.Maybe ServerError)u ;:: Lens' CommandAddSubscriptionToTxnResponse Data.Text.Text K:: Lens' CommandAddSubscriptionToTxnResponse (Prelude.Maybe Data.Text.Text) ~ supernovaFields :Y 5:: Lens' CommandAddSubscriptionToTxn Data.Word.Word645 5:: Lens' CommandAddSubscriptionToTxn Data.Word.Word646 E:: Lens' CommandAddSubscriptionToTxn (Prelude.Maybe Data.Word.Word64)7 5:: Lens' CommandAddSubscriptionToTxn Data.Word.Word648 E:: Lens' CommandAddSubscriptionToTxn (Prelude.Maybe Data.Word.Word64) 3:: Lens' CommandAddSubscriptionToTxn [Subscription] F:: Lens' CommandAddSubscriptionToTxn (Data.Vector.Vector Subscription)  supernovaFields : Y ::: Lens' CommandAddPartitionToTxnResponse Data.Word.Word645 ::: Lens' CommandAddPartitionToTxnResponse Data.Word.Word646 J:: Lens' CommandAddPartitionToTxnResponse (Prelude.Maybe Data.Word.Word64)7 ::: Lens' CommandAddPartitionToTxnResponse Data.Word.Word648 J:: Lens' CommandAddPartitionToTxnResponse (Prelude.Maybe Data.Word.Word64)t 5:: Lens' CommandAddPartitionToTxnResponse ServerError E:: Lens' CommandAddPartitionToTxnResponse (Prelude.Maybe ServerError)u 8:: Lens' CommandAddPartitionToTxnResponse Data.Text.Text H:: Lens' CommandAddPartitionToTxnResponse (Prelude.Maybe Data.Text.Text)  supernovaFields :Y 2:: Lens' CommandAddPartitionToTxn Data.Word.Word645 2:: Lens' CommandAddPartitionToTxn Data.Word.Word646 B:: Lens' CommandAddPartitionToTxn (Prelude.Maybe Data.Word.Word64)7 2:: Lens' CommandAddPartitionToTxn Data.Word.Word648 B:: Lens' CommandAddPartitionToTxn (Prelude.Maybe Data.Word.Word64) 2:: Lens' CommandAddPartitionToTxn [Data.Text.Text] E:: Lens' CommandAddPartitionToTxn (Data.Vector.Vector Data.Text.Text)  supernovaFields :X 5:: Lens' CommandActiveConsumerChange Data.Word.Word64 1:: Lens' CommandActiveConsumerChange Prelude.Bool A:: Lens' CommandActiveConsumerChange (Prelude.Maybe Prelude.Bool)  supernovaFields : X ,:: Lens' CommandAckResponse Data.Word.Word645 ,:: Lens' CommandAckResponse Data.Word.Word646 <:: Lens' CommandAckResponse (Prelude.Maybe Data.Word.Word64)7 ,:: Lens' CommandAckResponse Data.Word.Word648 <:: Lens' CommandAckResponse (Prelude.Maybe Data.Word.Word64)t ':: Lens' CommandAckResponse ServerError 7:: Lens' CommandAckResponse (Prelude.Maybe ServerError)u *:: Lens' CommandAckResponse Data.Text.Text ::: Lens' CommandAckResponse (Prelude.Maybe Data.Text.Text)  supernovaFields : X $:: Lens' CommandAck Data.Word.Word64 &:: Lens' CommandAck CommandAck'AckTyper #:: Lens' CommandAck [MessageIdData] 6:: Lens' CommandAck (Data.Vector.Vector MessageIdData) .:: Lens' CommandAck CommandAck'ValidationError >:: Lens' CommandAck (Prelude.Maybe CommandAck'ValidationError) ":: Lens' CommandAck [KeyLongValue] 5:: Lens' CommandAck (Data.Vector.Vector KeyLongValue)5 $:: Lens' CommandAck Data.Word.Word646 4:: Lens' CommandAck (Prelude.Maybe Data.Word.Word64)7 $:: Lens' CommandAck Data.Word.Word648 4:: Lens' CommandAck (Prelude.Maybe Data.Word.Word64)  supernovaFields :g %:: Lens' BaseCommand BaseCommand'Type #:: Lens' BaseCommand CommandConnect 3:: Lens' BaseCommand (Prelude.Maybe CommandConnect) %:: Lens' BaseCommand CommandConnected 5:: Lens' BaseCommand (Prelude.Maybe CommandConnected) %:: Lens' BaseCommand CommandSubscribe 5:: Lens' BaseCommand (Prelude.Maybe CommandSubscribe) $:: Lens' BaseCommand CommandProducer 4:: Lens' BaseCommand (Prelude.Maybe CommandProducer)  :: Lens' BaseCommand CommandSend 0:: Lens' BaseCommand (Prelude.Maybe CommandSend) ':: Lens' BaseCommand CommandSendReceipt 7:: Lens' BaseCommand (Prelude.Maybe CommandSendReceipt) %:: Lens' BaseCommand CommandSendError 5:: Lens' BaseCommand (Prelude.Maybe CommandSendError)u #:: Lens' BaseCommand CommandMessage 3:: Lens' BaseCommand (Prelude.Maybe CommandMessage) :: Lens' BaseCommand CommandAck /:: Lens' BaseCommand (Prelude.Maybe CommandAck)  :: Lens' BaseCommand CommandFlow 0:: Lens' BaseCommand (Prelude.Maybe CommandFlow) ':: Lens' BaseCommand CommandUnsubscribe 7:: Lens' BaseCommand (Prelude.Maybe CommandUnsubscribe) #:: Lens' BaseCommand CommandSuccess 3:: Lens' BaseCommand (Prelude.Maybe CommandSuccess)t !:: Lens' BaseCommand CommandError 1:: Lens' BaseCommand (Prelude.Maybe CommandError) ):: Lens' BaseCommand CommandCloseProducer 9:: Lens' BaseCommand (Prelude.Maybe CommandCloseProducer) ):: Lens' BaseCommand CommandCloseConsumer 9:: Lens' BaseCommand (Prelude.Maybe CommandCloseConsumer) +:: Lens' BaseCommand CommandProducerSuccess ;:: Lens' BaseCommand (Prelude.Maybe CommandProducerSuccess)  :: Lens' BaseCommand CommandPing 0:: Lens' BaseCommand (Prelude.Maybe CommandPing)  :: Lens' BaseCommand CommandPong 0:: Lens' BaseCommand (Prelude.Maybe CommandPong) ;:: Lens' BaseCommand CommandRedeliverUnacknowledgedMessages K:: Lens' BaseCommand (Prelude.Maybe CommandRedeliverUnacknowledgedMessages) 4:: Lens' BaseCommand CommandPartitionedTopicMetadata D:: Lens' BaseCommand (Prelude.Maybe CommandPartitionedTopicMetadata) <:: Lens' BaseCommand CommandPartitionedTopicMetadataResponse L:: Lens' BaseCommand (Prelude.Maybe CommandPartitionedTopicMetadataResponse)  ':: Lens' BaseCommand CommandLookupTopic  7:: Lens' BaseCommand (Prelude.Maybe CommandLookupTopic)  /:: Lens' BaseCommand CommandLookupTopicResponse  ?:: Lens' BaseCommand (Prelude.Maybe CommandLookupTopicResponse)  ):: Lens' BaseCommand CommandConsumerStats 9:: Lens' BaseCommand (Prelude.Maybe CommandConsumerStats) 1:: Lens' BaseCommand CommandConsumerStatsResponse A:: Lens' BaseCommand (Prelude.Maybe CommandConsumerStatsResponse) -:: Lens' BaseCommand CommandReachedEndOfTopic =:: Lens' BaseCommand (Prelude.Maybe CommandReachedEndOfTopic)  :: Lens' BaseCommand CommandSeek 0:: Lens' BaseCommand (Prelude.Maybe CommandSeek) ,:: Lens' BaseCommand CommandGetLastMessageId <:: Lens' BaseCommand (Prelude.Maybe CommandGetLastMessageId) 4:: Lens' BaseCommand CommandGetLastMessageIdResponse D:: Lens' BaseCommand (Prelude.Maybe CommandGetLastMessageIdResponse) 0:: Lens' BaseCommand CommandActiveConsumerChange @:: Lens' BaseCommand (Prelude.Maybe CommandActiveConsumerChange) 0:: Lens' BaseCommand CommandGetTopicsOfNamespace @:: Lens' BaseCommand (Prelude.Maybe CommandGetTopicsOfNamespace) 8:: Lens' BaseCommand CommandGetTopicsOfNamespaceResponse H:: Lens' BaseCommand (Prelude.Maybe CommandGetTopicsOfNamespaceResponse) %:: Lens' BaseCommand CommandGetSchema  5:: Lens' BaseCommand (Prelude.Maybe CommandGetSchema)! -:: Lens' BaseCommand CommandGetSchemaResponse" =:: Lens' BaseCommand (Prelude.Maybe CommandGetSchemaResponse)# ):: Lens' BaseCommand CommandAuthChallenge$ 9:: Lens' BaseCommand (Prelude.Maybe CommandAuthChallenge)% (:: Lens' BaseCommand CommandAuthResponse& 8:: Lens' BaseCommand (Prelude.Maybe CommandAuthResponse)' ':: Lens' BaseCommand CommandAckResponse( 7:: Lens' BaseCommand (Prelude.Maybe CommandAckResponse)) -:: Lens' BaseCommand CommandGetOrCreateSchema* =:: Lens' BaseCommand (Prelude.Maybe CommandGetOrCreateSchema)+ 5:: Lens' BaseCommand CommandGetOrCreateSchemaResponse, E:: Lens' BaseCommand (Prelude.Maybe CommandGetOrCreateSchemaResponse)- ":: Lens' BaseCommand CommandNewTxn. 2:: Lens' BaseCommand (Prelude.Maybe CommandNewTxn)/ *:: Lens' BaseCommand CommandNewTxnResponse0 ::: Lens' BaseCommand (Prelude.Maybe CommandNewTxnResponse)1 -:: Lens' BaseCommand CommandAddPartitionToTxn2 =:: Lens' BaseCommand (Prelude.Maybe CommandAddPartitionToTxn)3 5:: Lens' BaseCommand CommandAddPartitionToTxnResponse4 E:: Lens' BaseCommand (Prelude.Maybe CommandAddPartitionToTxnResponse)5 0:: Lens' BaseCommand CommandAddSubscriptionToTxn6 @:: Lens' BaseCommand (Prelude.Maybe CommandAddSubscriptionToTxn)7 8:: Lens' BaseCommand CommandAddSubscriptionToTxnResponse8 H:: Lens' BaseCommand (Prelude.Maybe CommandAddSubscriptionToTxnResponse)9 ":: Lens' BaseCommand CommandEndTxn: 2:: Lens' BaseCommand (Prelude.Maybe CommandEndTxn); *:: Lens' BaseCommand CommandEndTxnResponse< ::: Lens' BaseCommand (Prelude.Maybe CommandEndTxnResponse)= -:: Lens' BaseCommand CommandEndTxnOnPartition> =:: Lens' BaseCommand (Prelude.Maybe CommandEndTxnOnPartition)? 5:: Lens' BaseCommand CommandEndTxnOnPartitionResponse@ E:: Lens' BaseCommand (Prelude.Maybe CommandEndTxnOnPartitionResponse)A 0:: Lens' BaseCommand CommandEndTxnOnSubscriptionB @:: Lens' BaseCommand (Prelude.Maybe CommandEndTxnOnSubscription)C 8:: Lens' BaseCommand CommandEndTxnOnSubscriptionResponseD H:: Lens' BaseCommand (Prelude.Maybe CommandEndTxnOnSubscriptionResponse)  supernovaFields :  :: Lens' AuthData Data.Text.Text 0:: Lens' AuthData (Prelude.Maybe Data.Text.Text) ,:: Lens' AuthData Data.ByteString.ByteString <:: Lens' AuthData (Prelude.Maybe Data.ByteString.ByteString) FGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~     None.;=>?@AFHMVXgk%@ !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_ENone*`aFNoneSX_+DbGNone+cdefghiHNone+jklmnopqrstuvwxyz{|}~INone,aJNone=?_3r supernovasParse total size, command size and message. If done, return simple frame. Otherwise, try to parse a payload frame.  supernovabThe 2-bytes "magic number" is optional. If present, it indicates that a 4-bytes checksum follows.  supernovaEIf a checksum is given, validate it. Otherwise, return simple frame.  supernova=Take in a simple command and try to parse a payload command.  supernovaDecode either a | or a {. KNoneM8 supernova@It represents a list of registered sequence ids for a producer.  supernovaLIt represents a running worker in the background along with a synchronizer.  supernova:Register a response for a request and unregister request.  supernovaCRegister a response for a message sent and unregister sequence id. %LEnd-user Pulsar API types. Apache-2.0gabriel.volpe@chatroulette.com experimentalNoneHQ  supernova'A subscription with a type and a name.  supernovaA subscription type. See  Chttps://pulsar.apache.org/docs/en/concepts-messaging/#subscriptions to learn more.  supernova-A subscription name can be any string value.  supernova=A produced message, containing just a payload as bytestring.  supernova$A consumed message, containing both   and payload as bytestring.  supernova5A message id, needed for acknowledging messages. See M.  supernova&A topic name can be any string value.  supernovaAA namespace can be any string value. Default value is "default".  supernova=A tenant can be any string value. Default value is "public".  supernovaA topic can be either  or .  supernovaOA Topic is in the form "type://tenant/namespace/topic-name", which is what the  instance does.  supernova A default .: "non-persistent://public/default/my-topic".  NNoneI ONone_P supernovayInternal Pulsar context. You will never need to access its content (not exported) but might need to take it as argument.  supernova#Connection details: host and port. # supernova*Default connection data: "127.0.0.1:6650" $ supernova-Starts a Pulsar connection with the supplied   supernovaIt listens to incoming messages directly from the network socket and it writes them to all the - consumers and producers' communication channels.  "!#$PNoneMY% supernova!Internal logging output, part of -. Can be used together with 3`. ( supernova Internal logging level, part of -. Can be used together with 3`. - supernova4Internal logging options. Can be used together with 3`. 1 supernova.The main Pulsar monad, which abstracts over a  monad. 2 supernova Alias for Connection PulsarCtx.  supernova0Pulsar connection monad, which abstracts over a  monad. 3 supernovaBRuns a Pulsar computation with default logging to standard output 4 supernova<Runs a Pulsar computation with the supplied logging options %&'(*+),-.0/1234QNoneZ RApache Pulsar client Apache-2.0gabriel.volpe@chatroulette.com experimentalNone>^5 supernova An abstract 5 able to 7 messages of type  . 7 supernovaProduces a single message.8 supernova Create a new 5 by supplying a  (returned by ) and a . 5678MApache Pulsar client Apache-2.0gabriel.volpe@chatroulette.com experimentalNone>_l9 supernova An abstract 9 able to ; messages and <nowledge them. ; supernova>Fetches a single message. Blocks if no messages are available.< supernovaAcknowledges a single message. supernovafThe protocol expects the implementation to use some kind of queue to store events sent by the broker.  supernova<It keeps track of the size of our internal messages queue . = supernova Create a new 9 by supplying a  (returned by ), a  and a SubscriptionName.  supernova[It reads responses from the main communication channel and whenever it corresponds to a - k, it creates a  B and it writes it to the fetcher channel, which - is the one the ; function is listening on. - - It also keeps count of the internal fetcher channel size and issues new permits (FLOW) - whenever necessary.9:<;=Apache Pulsar client Apache-2.0gabriel.volpe@chatroulette.com experimentalNonenF>  !"#$%'&(,)+*-./0123456789:<;=>$#=8349:<;56712 !"(,)+*-./0%'&  LSLSLTLULVLWLXLYLYLZLZL[L[L\L\L]L]L^L^L_L_L`LaLbLcLcLLdLLLeOfOgOhOiOjOPkPlPmPnPoPpPqPrPsPsPtPuPPvPwPxRyRyRRzM{M{M|MM}~S      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^'I1357P#%GA #X] 1a+)-S9=?AC;Dtk)+!N9gxKoM~C  3(2468Q$&HB $^2b,.:>@BD<l*, ":hyp  4s{.0>w(F `fj [0dnU@68&<ur|zV-/=v'E  _qei!YZ/Rcm\T?57%;LJ*O}W"E_E`FaGbGbGcGdGeGfGgHhHiHjHkHkHlHmHnHoHpHqHrHsHtHuHvHwHxHyHzH{H|I}J~JJJJJKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKKNN\NNNNNNNNNNNOOOOOOOOOOOOOOOOOOPPPPQQzQQQQQQQQRRRRRMMMsupernova-0.0.3-inplacePulsarPaths_supernovaProto.PulsarApiProto.PulsarApi_Fieldstopic subscription propertiesvec'properties partitionKeymaybe'partitionKey payloadSize compactedOutmaybe'compactedOut eventTimemaybe'eventTimepartitionKeyB64Encodedmaybe'partitionKeyB64Encoded orderingKeymaybe'orderingKey sequenceIdmaybe'sequenceId nullValuemaybe'nullValuenullPartitionKeymaybe'nullPartitionKeyname schemaDatatype' producerName publishTimereplicatedFrommaybe'replicatedFrom replicateTovec'replicateTo compressionmaybe'compressionuncompressedSizemaybe'uncompressedSizenumMessagesInBatchmaybe'numMessagesInBatchencryptionKeysvec'encryptionKeysencryptionAlgomaybe'encryptionAlgoencryptionParammaybe'encryptionParam schemaVersionmaybe'schemaVersion deliverAtTimemaybe'deliverAtTime markerTypemaybe'markerTypetxnidLeastBitsmaybe'txnidLeastBits txnidMostBitsmaybe'txnidMostBitshighestSequenceIdmaybe'highestSequenceIduuid maybe'uuidnumChunksFromMsgmaybe'numChunksFromMsgtotalChunkMsgSizemaybe'totalChunkMsgSizechunkId maybe'chunkIdledgerIdentryId partitionmaybe'partition batchIndexmaybe'batchIndexackSet vec'ackSetkeyvalue keySharedMode hashRangesvec'hashRangesallowOutOfOrderDeliverymaybe'allowOutOfOrderDeliverystartendsupportsAuthRefreshmaybe'supportsAuthRefreshmetadata vec'metadata consumerId requestIdschema maybe'schemasubType consumerNamemaybe'consumerName priorityLevelmaybe'priorityLeveldurable maybe'durablestartMessageIdmaybe'startMessageId readCompactedmaybe'readCompactedinitialPositionmaybe'initialPositionreplicateSubscriptionState maybe'replicateSubscriptionStateforceTopicCreationmaybe'forceTopicCreationstartMessageRollbackDurationSec%maybe'startMessageRollbackDurationSec keySharedMetamaybe'keySharedMeta producerId messageIdmaybe'messageIderrormessage numMessagesmaybe'numMessagesisChunk maybe'isChunkmessagePublishTimemaybe'messagePublishTime messageIdsvec'messageIdslastSequenceIdmaybe'lastSequenceIdmaybe'producerName encryptedmaybe'encryptedepoch maybe'epochuserProvidedProducerNamemaybe'userProvidedProducerName partitionsmaybe'partitionsresponsemaybe'response maybe'error maybe'messageoriginalPrincipalmaybe'originalPrincipaloriginalAuthDatamaybe'originalAuthDataoriginalAuthMethodmaybe'originalAuthMethod txnTtlSecondsmaybe'txnTtlSecondstcId maybe'tcIdredeliveryCountmaybe'redeliveryCountbrokerServiceUrlmaybe'brokerServiceUrlbrokerServiceUrlTlsmaybe'brokerServiceUrlTls authoritativemaybe'authoritativeproxyThroughServiceUrlmaybe'proxyThroughServiceUrladvertisedListenerNamemaybe'advertisedListenerNametopics vec'topics namespacemode maybe'mode errorCodemaybe'errorCode errorMessagemaybe'errorMessage lastMessageIdmessagePermitsmaybe'subscription txnActionmaybe'txnAction maybe'topic msgRateOutmaybe'msgRateOutmsgThroughputOutmaybe'msgThroughputOutmsgRateRedelivermaybe'msgRateRedeliveravailablePermitsmaybe'availablePermitsunackedMessagesmaybe'unackedMessagesblockedConsumerOnUnackedMsgs"maybe'blockedConsumerOnUnackedMsgsaddress maybe'addressconnectedSincemaybe'connectedSince maybe'type'msgRateExpiredmaybe'msgRateExpired msgBacklogmaybe'msgBacklog serverVersionprotocolVersionmaybe'protocolVersionmaxMessageSizemaybe'maxMessageSize clientVersion authMethodmaybe'authMethodauthMethodNamemaybe'authMethodNameauthDatamaybe'authDataproxyToBrokerUrlmaybe'proxyToBrokerUrl featureFlagsmaybe'featureFlagsmaybe'clientVersionmaybe'serverVersion challengemaybe'challengevec'subscriptionvec'partitionsisActivemaybe'isActiveackType vec'messageIdvalidationErrormaybe'validationErrorconnect maybe'connect connectedmaybe'connected subscribemaybe'subscribeproducermaybe'producersend maybe'send sendReceiptmaybe'sendReceipt sendErrormaybe'sendErrorack maybe'ackflow maybe'flow unsubscribemaybe'unsubscribesuccess maybe'success closeProducermaybe'closeProducer closeConsumermaybe'closeConsumerproducerSuccessmaybe'producerSuccessping maybe'pingpong maybe'pongredeliverUnacknowledgedMessages%maybe'redeliverUnacknowledgedMessagespartitionMetadatamaybe'partitionMetadatapartitionMetadataResponsemaybe'partitionMetadataResponse lookupTopicmaybe'lookupTopiclookupTopicResponsemaybe'lookupTopicResponse consumerStatsmaybe'consumerStatsconsumerStatsResponsemaybe'consumerStatsResponsereachedEndOfTopicmaybe'reachedEndOfTopicseek maybe'seekgetLastMessageIdmaybe'getLastMessageIdgetLastMessageIdResponsemaybe'getLastMessageIdResponseactiveConsumerChangemaybe'activeConsumerChangegetTopicsOfNamespacemaybe'getTopicsOfNamespacegetTopicsOfNamespaceResponse"maybe'getTopicsOfNamespaceResponse getSchemamaybe'getSchemagetSchemaResponsemaybe'getSchemaResponse authChallengemaybe'authChallenge authResponsemaybe'authResponse ackResponsemaybe'ackResponsegetOrCreateSchemamaybe'getOrCreateSchemagetOrCreateSchemaResponsemaybe'getOrCreateSchemaResponsenewTxn maybe'newTxnnewTxnResponsemaybe'newTxnResponseaddPartitionToTxnmaybe'addPartitionToTxnaddPartitionToTxnResponsemaybe'addPartitionToTxnResponseaddSubscriptionToTxnmaybe'addSubscriptionToTxnaddSubscriptionToTxnResponse"maybe'addSubscriptionToTxnResponseendTxn maybe'endTxnendTxnResponsemaybe'endTxnResponseendTxnOnPartitionmaybe'endTxnOnPartitionendTxnOnPartitionResponsemaybe'endTxnOnPartitionResponseendTxnOnSubscriptionmaybe'endTxnOnSubscriptionendTxnOnSubscriptionResponse"maybe'endTxnOnSubscriptionResponsePulsar.Internal.LoggerPulsar.Internal.TCPClientPulsar.Protocol.CheckSumPulsar.Protocol.FramePulsar.Protocol.EncoderPulsar.Protocol.DecoderPulsar.AppState Pulsar.TypesPulsar.ConsumerPulsar.Protocol.CommandsPulsar.ConnectionPulsar.Internal.Core Pulsar.CorePulsar.Producer SubscriptionSubType ExclusiveFailoverShared KeySharedSubName PulsarMessageMessageMsgId TopicName NameSpaceTenant TopicType Persistent NonPersistentTopictenant defaultTopic ConnectDataConnDataconnHostconnPortdefaultConnectData LogOutputStdOutFileLogLevelErrorWarnInfoDebug LogOptionslogLevel logOutputPulsarConnection runPulsar runPulsar'Producer newProducerConsumerfetch newConsumerversion getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileNameSingleMessageMetadataSchemaMessageMetadata MessageIdDataKeyValue KeySharedMeta KeyLongValueIntRange FeatureFlagsEncryptionKeysCommandUnsubscribeCommandSuccessCommandSubscribeCommandSendReceiptCommandSendError CommandSend CommandSeek&CommandRedeliverUnacknowledgedMessagesCommandReachedEndOfTopicCommandProducerSuccessCommandProducer CommandPong CommandPing'CommandPartitionedTopicMetadataResponseCommandPartitionedTopicMetadataCommandNewTxnResponse CommandNewTxnCommandMessageCommandLookupTopicResponseCommandLookupTopic#CommandGetTopicsOfNamespaceResponseCommandGetTopicsOfNamespaceCommandGetSchemaResponseCommandGetSchema CommandGetOrCreateSchemaResponseCommandGetOrCreateSchemaCommandGetLastMessageIdResponseCommandGetLastMessageId CommandFlow CommandErrorCommandEndTxnResponse#CommandEndTxnOnSubscriptionResponseCommandEndTxnOnSubscription CommandEndTxnOnPartitionResponseCommandEndTxnOnPartition CommandEndTxnCommandConsumerStatsResponseCommandConsumerStatsCommandConnectedCommandConnectCommandCloseProducerCommandCloseConsumerCommandAuthResponseCommandAuthChallenge#CommandAddSubscriptionToTxnResponseCommandAddSubscriptionToTxn CommandAddPartitionToTxnResponseCommandAddPartitionToTxnCommandActiveConsumerChangeCommandAckResponse CommandAck BaseCommandAuthData TxnActionCOMMITABORT ServerError UnknownError MetadataErrorPersistenceErrorAuthenticationErrorAuthorizationError ConsumerBusyServiceNotReady!ProducerBlockedQuotaExceededError%ProducerBlockedQuotaExceededException ChecksumErrorUnsupportedVersionError TopicNotFoundSubscriptionNotFoundConsumerNotFoundTooManyRequestsTopicTerminatedError ProducerBusyInvalidTopicNameIncompatibleSchemaConsumerAssignErrorTransactionCoordinatorNotFoundInvalidTxnStatusNotAllowedError Schema'Type Schema'None Schema'String Schema'JsonSchema'Protobuf Schema'Avro Schema'Bool Schema'Int8 Schema'Int16 Schema'Int32 Schema'Int64 Schema'Float Schema'Double Schema'Date Schema'TimeSchema'TimestampSchema'KeyValueProtocolVersionV1V4V0V2V3V5V6V7V8V9V10V11V12V13V14V15 KeySharedMode AUTO_SPLITSTICKYCompressionTypeNONELZ4ZLIBZSTDSNAPPYCommandSubscribe'SubTypeCommandSubscribe'ExclusiveCommandSubscribe'SharedCommandSubscribe'FailoverCommandSubscribe'Key_Shared CommandSubscribe'InitialPositionCommandSubscribe'LatestCommandSubscribe'Earliest2CommandPartitionedTopicMetadataResponse'LookupType/CommandPartitionedTopicMetadataResponse'Success.CommandPartitionedTopicMetadataResponse'Failed%CommandLookupTopicResponse'LookupType#CommandLookupTopicResponse'Redirect"CommandLookupTopicResponse'Connect!CommandLookupTopicResponse'Failed CommandGetTopicsOfNamespace'Mode&CommandGetTopicsOfNamespace'PERSISTENT*CommandGetTopicsOfNamespace'NON_PERSISTENTCommandGetTopicsOfNamespace'ALLCommandAck'ValidationError%CommandAck'UncompressedSizeCorruptionCommandAck'DecompressionErrorCommandAck'ChecksumMismatch CommandAck'BatchDeSerializeErrorCommandAck'DecryptionErrorCommandAck'AckTypeCommandAck'IndividualCommandAck'CumulativeBaseCommand'TypeBaseCommand'CONNECTBaseCommand'CONNECTEDBaseCommand'SUBSCRIBEBaseCommand'PRODUCERBaseCommand'SENDBaseCommand'SEND_RECEIPTBaseCommand'SEND_ERRORBaseCommand'MESSAGEBaseCommand'ACKBaseCommand'FLOWBaseCommand'UNSUBSCRIBEBaseCommand'SUCCESSBaseCommand'ERRORBaseCommand'CLOSE_PRODUCERBaseCommand'CLOSE_CONSUMERBaseCommand'PRODUCER_SUCCESSBaseCommand'PINGBaseCommand'PONG-BaseCommand'REDELIVER_UNACKNOWLEDGED_MESSAGES BaseCommand'PARTITIONED_METADATA)BaseCommand'PARTITIONED_METADATA_RESPONSEBaseCommand'LOOKUPBaseCommand'LOOKUP_RESPONSEBaseCommand'CONSUMER_STATS#BaseCommand'CONSUMER_STATS_RESPONSE BaseCommand'REACHED_END_OF_TOPICBaseCommand'SEEKBaseCommand'GET_LAST_MESSAGE_ID(BaseCommand'GET_LAST_MESSAGE_ID_RESPONSE"BaseCommand'ACTIVE_CONSUMER_CHANGE#BaseCommand'GET_TOPICS_OF_NAMESPACE,BaseCommand'GET_TOPICS_OF_NAMESPACE_RESPONSEBaseCommand'GET_SCHEMABaseCommand'GET_SCHEMA_RESPONSEBaseCommand'AUTH_CHALLENGEBaseCommand'AUTH_RESPONSEBaseCommand'ACK_RESPONSE BaseCommand'GET_OR_CREATE_SCHEMA)BaseCommand'GET_OR_CREATE_SCHEMA_RESPONSEBaseCommand'NEW_TXNBaseCommand'NEW_TXN_RESPONSE BaseCommand'ADD_PARTITION_TO_TXN)BaseCommand'ADD_PARTITION_TO_TXN_RESPONSE#BaseCommand'ADD_SUBSCRIPTION_TO_TXN,BaseCommand'ADD_SUBSCRIPTION_TO_TXN_RESPONSEBaseCommand'END_TXNBaseCommand'END_TXN_RESPONSE BaseCommand'END_TXN_ON_PARTITION)BaseCommand'END_TXN_ON_PARTITION_RESPONSE#BaseCommand'END_TXN_ON_SUBSCRIPTION,BaseCommand'END_TXN_ON_SUBSCRIPTION_RESPONSE AuthMethodAuthMethodNoneAuthMethodYcaV1AuthMethodAthens logRequest logResponse acquireSocketCheckSumCheckSumValidationInvalidValid runCheckSumcomputeCheckSumResponsePayloadResponseSimpleResponsePayload PayloadCmdPayloadCommand framePayload frameMetadataframeMetadataSize frameCheckSum SimpleCmd SimpleCommand frameMessageframeCommandSizeframeTotalSizeFrame PayloadFrame SimpleFrame frameMaxSizeframeMagicNumber getCommandencodeBaseCommand parseFramevalidateMagicNumbervalidateCheckSum parsePayloaddecodeBaseCommanddropPayloadGarbage ProducerSeqsWorkerregisterReqResponseregisterSendReceiptAppState_appSendReceipts _appResponse _appWorkers _appRequestId_appProducerId_appConsumerId _appConsumersPermits ConsumerIdCId ProducerIdPIdSeqIdReqId appConsumers appConsumerId appProducerId appRequestId appWorkers appResponseappSendReceipts mkConsumerId mkProducerId mkRequestId addWorkergetProducerSeqsupdateProducerSeqs registerSeqIdbaseGHC.ShowShowlookupmessageMetadata PulsarCtx recvDispatchCtx ctxConnWorkerctxStatectxConn ConnectionConncheckConnection initAppStateresponseForRequestresponseForSendReceipt pongResponsemessageResponse keepAlive sendSimpleCmdsendPayloadCmdreceivetransformers-0.5.6.2Control.Monad.Trans.ReaderReaderT$managed-1.0.7-2wFCwv0rolgGQlt0c4eY4pControl.Monad.ManagedManaged fromLogLevel newSubscriber ProducerStatestNamestSeqIdmkSeqIddefaultQueueSizeupdateQueueSizefetcher