#vQ*4      !"#$%&'()*+,-./0123Safe456789:;None.;=>?@AFHMVXgk @< supernovaFields : $:: Lens' Subscription Data.Text.Text $:: Lens' Subscription Data.Text.Text = 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) > supernovaFields : :: Lens' Schema Data.Text.Text *:: Lens' Schema Data.ByteString.ByteString :: Lens' Schema Schema'Type :: Lens' Schema [KeyValue] -:: Lens' Schema (Data.Vector.Vector KeyValue) ? 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) @ 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) A supernovaFields :K  :: Lens' KeyValue Data.Text.TextL  :: Lens' KeyValue Data.Text.Text B 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) C supernovaFields :K $:: Lens' KeyLongValue Data.Text.TextL &:: Lens' KeyLongValue Data.Word.Word64 D supernovaFields :R  :: Lens' IntRange Data.Int.Int32S  :: Lens' IntRange Data.Int.Int32 E supernovaFields :T ":: Lens' FeatureFlags Prelude.BoolU 2:: Lens' FeatureFlags (Prelude.Maybe Prelude.Bool) F supernovaFields :K &:: Lens' EncryptionKeys Data.Text.TextL 2:: Lens' EncryptionKeys Data.ByteString.ByteStringV ":: Lens' EncryptionKeys [KeyValue]W 5:: Lens' EncryptionKeys (Data.Vector.Vector KeyValue) G supernovaFields :X ,:: Lens' CommandUnsubscribe Data.Word.Word64Y ,:: Lens' CommandUnsubscribe Data.Word.Word64 H supernovaFields :Y (:: Lens' CommandSuccess Data.Word.Word64Z :: Lens' CommandSuccess Schema[ .:: Lens' CommandSuccess (Prelude.Maybe Schema) I 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) J 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) K supernovaFields :q *:: Lens' CommandSendError Data.Word.Word64 *:: Lens' CommandSendError Data.Word.Word64t %:: Lens' CommandSendError ServerErroru (:: Lens' CommandSendError Data.Text.Text L 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) M 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) N supernovaFields :X @:: Lens' CommandRedeliverUnacknowledgedMessages Data.Word.Word64| ?:: Lens' CommandRedeliverUnacknowledgedMessages [MessageIdData]} R:: Lens' CommandRedeliverUnacknowledgedMessages (Data.Vector.Vector MessageIdData) O supernovaFields :X 2:: Lens' CommandReachedEndOfTopic Data.Word.Word64 P 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) Q 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) R supernovaFields :S supernovaFields :T 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) U 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) V 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) W 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) X 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) Y 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) Z 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) [ supernovaFields :Y =:: Lens' CommandGetTopicsOfNamespaceResponse Data.Word.Word64 =:: Lens' CommandGetTopicsOfNamespaceResponse [Data.Text.Text] P:: Lens' CommandGetTopicsOfNamespaceResponse (Data.Vector.Vector Data.Text.Text) \ 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) ] 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) ^ 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) _ 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) ` supernovaFields :Y 2:: Lens' CommandGetOrCreateSchema Data.Word.Word64 0:: Lens' CommandGetOrCreateSchema Data.Text.TextZ (:: Lens' CommandGetOrCreateSchema Schema a supernovaFields : 6:: Lens' CommandGetLastMessageIdResponse MessageIdDataY 9:: Lens' CommandGetLastMessageIdResponse Data.Word.Word64 b supernovaFields :X 1:: Lens' CommandGetLastMessageId Data.Word.Word64Y 1:: Lens' CommandGetLastMessageId Data.Word.Word64 c supernovaFields :X %:: Lens' CommandFlow Data.Word.Word64 %:: Lens' CommandFlow Data.Word.Word32 d supernovaFields :Y &:: Lens' CommandError Data.Word.Word64t !:: Lens' CommandError ServerErroru $:: Lens' CommandError Data.Text.Text e 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) f 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) g 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) h 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) i 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) j 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) k 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) l supernovaFields :Y .:: Lens' CommandConsumerStats Data.Word.Word64X .:: Lens' CommandConsumerStats Data.Word.Word64 m 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) n 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) o supernovaFields :q .:: Lens' CommandCloseProducer Data.Word.Word64Y .:: Lens' CommandCloseProducer Data.Word.Word64 p supernovaFields :X .:: Lens' CommandCloseConsumer Data.Word.Word64Y .:: Lens' CommandCloseConsumer Data.Word.Word64 q 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) r 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) s 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) t 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) u 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) v 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) w supernovaFields :X 5:: Lens' CommandActiveConsumerChange Data.Word.Word64 1:: Lens' CommandActiveConsumerChange Prelude.Bool A:: Lens' CommandActiveConsumerChange (Prelude.Maybe Prelude.Bool) x 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) y 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) z 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) |}~<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxy     z{None.;=>?@AFHMVXgk% @ !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUENoneMSX1k supernova!Internal logging output, part of . Can be used together with  `.  supernova Internal logging level, part of . Can be used together with  `.  supernova4Internal logging options. Can be used together with  `.  supernova.The main Pulsar monad, which abstracts over a V monad.  supernovaBRuns a Pulsar computation with default logging to standard output  supernova<Runs a Pulsar computation with the supplied logging options  W XFNone1YZGNone_2=[HNone2x\]^_`abcdefghijklmnopqINone3rJNone=?_3jstKEnd-user Pulsar API types. Apache-2.0gabriel.volpe@chatroulette.com experimentalNone?  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 L.  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 u instance does. & supernova A default  .: "non-persistent://public/default/my-topic".  !#"$%&MNone@r vwxyz{|}~NNoneM_E' 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 ( $'()*ONone.>_Fj PNoneI+ supernova An abstract + able to - messages of type . - supernovaProduces a single message.. supernova Create a new + by supplying a ' (returned by ) and a  . +,-.LNone_N/ supernova An abstract / able to 1 messages and 2nowledge them. 1 supernova>Fetches a single message. Blocks if no messages are available.2 supernovaAcknowledges a single message.3 supernova Create a new / by supplying a ' (returned by ), a   and a . /0123Apache Pulsar client Apache-2.0gabriel.volpe@chatroulette.com experimentalNoneO4  !%$"#&'()*+,-./02134*)3. /021+,- '(  !#"$%&EQERESETEUEVEWEXEYEYEZE[EE\E]K^K^K_K_K`K`KaKaKbKbKcKcKdKdKeKfKgKhKhKKiKKKjNkNlNmNPnPnPoPpLqLqLrLLstuvwxyz{|}~      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTU'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"VWXEEYFZF[G\H]H^H_H`H`HaHbHcHdHeHfHgHhHiHjHkHlHmHnHoHpHqIrJsJtuvwMMMMMMMMMxMMMyNzN{N|N}N~NNNNNNNNNNNNNNNNNNNNNNNNNNNOOxOpOOOOOOOOPPPPPsupernova-0.0.2-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.CorePulsar.Internal.LoggerPulsar.Internal.TCPClientPulsar.Protocol.FramePulsar.Protocol.EncoderPulsar.Protocol.Decoder Pulsar.TypesPulsar.ConsumerPulsar.Protocol.CommandsPulsar.Connection Pulsar.CorePulsar.Producer LogOutputStdOutFileLogLevelErrorWarnInfoDebug LogOptionslogLevel logOutput runPulsar runPulsar'SubscriptionName PulsarMessageMessageMsgId TopicName NameSpaceTenant TopicType Persistent NonPersistentTopictenant defaultTopic PulsarCtx ConnectDatadefaultConnectDataProducerproduce newProducerConsumerfetch newConsumerversion getBinDir getLibDir getDynLibDir getDataDir getLibexecDir getSysconfDirgetDataFileName SubscriptionSingleMessageMetadataSchemaMessageMetadata 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$managed-1.0.7-2wFCwv0rolgGQlt0c4eY4pControl.Monad.ManagedManagedconvertLogLevel logRequest logResponse acquireSocketResponsePayloadResponseSimpleResponsePayload PayloadCmdPayloadCommand framePayload frameMetadataframeMetadataSize frameCheckSum SimpleCmd SimpleCommand frameMessageframeCommandSizeframeTotalSizeFrame PayloadFrame SimpleFrame frameMaxSizeframeMagicNumber getCommandencodeBaseCommanddropPayloadGarbagedecodeBaseCommandbaseGHC.ShowShowlookupmessageMetadataCtxctxStatectxConnConnDataconnPortconnHostAppState appRequestId appProducerId appProducers appConsumerId appConsumers ConsumerIdCId ProducerIdPIdSeqIdReqId ConnectionConn mkConsumerId mkProducerId mkRequestId initAppState recvDispatch keepAlive sendSimpleCmdsendPayloadCmdreceiveverifyResponse newSubscriber ProducerStatestNamestSeqIdmkSeqId