{- This file was auto-generated from Kafka.proto by the proto-lens-protoc program. -}
{-# LANGUAGE ScopedTypeVariables, DataKinds, TypeFamilies, UndecidableInstances, GeneralizedNewtypeDeriving, MultiParamTypeClasses, FlexibleContexts, FlexibleInstances, PatternSynonyms, MagicHash, NoImplicitPrelude, DataKinds, BangPatterns, TypeApplications, OverloadedStrings, DerivingStrategies#-}
{-# OPTIONS_GHC -Wno-unused-imports#-}
{-# OPTIONS_GHC -Wno-duplicate-exports#-}
{-# OPTIONS_GHC -Wno-dodgy-exports#-}
module Proto.Kafka (
        KafkaProducerRecord()
    ) where
import qualified Data.ProtoLens.Runtime.Control.DeepSeq as Control.DeepSeq
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Prism as Data.ProtoLens.Prism
import qualified Data.ProtoLens.Runtime.Prelude as Prelude
import qualified Data.ProtoLens.Runtime.Data.Int as Data.Int
import qualified Data.ProtoLens.Runtime.Data.Monoid as Data.Monoid
import qualified Data.ProtoLens.Runtime.Data.Word as Data.Word
import qualified Data.ProtoLens.Runtime.Data.ProtoLens as Data.ProtoLens
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Encoding.Bytes as Data.ProtoLens.Encoding.Bytes
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Encoding.Growing as Data.ProtoLens.Encoding.Growing
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Encoding.Parser.Unsafe as Data.ProtoLens.Encoding.Parser.Unsafe
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Encoding.Wire as Data.ProtoLens.Encoding.Wire
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Field as Data.ProtoLens.Field
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Message.Enum as Data.ProtoLens.Message.Enum
import qualified Data.ProtoLens.Runtime.Data.ProtoLens.Service.Types as Data.ProtoLens.Service.Types
import qualified Data.ProtoLens.Runtime.Lens.Family2 as Lens.Family2
import qualified Data.ProtoLens.Runtime.Lens.Family2.Unchecked as Lens.Family2.Unchecked
import qualified Data.ProtoLens.Runtime.Data.Text as Data.Text
import qualified Data.ProtoLens.Runtime.Data.Map as Data.Map
import qualified Data.ProtoLens.Runtime.Data.ByteString as Data.ByteString
import qualified Data.ProtoLens.Runtime.Data.ByteString.Char8 as Data.ByteString.Char8
import qualified Data.ProtoLens.Runtime.Data.Text.Encoding as Data.Text.Encoding
import qualified Data.ProtoLens.Runtime.Data.Vector as Data.Vector
import qualified Data.ProtoLens.Runtime.Data.Vector.Generic as Data.Vector.Generic
import qualified Data.ProtoLens.Runtime.Data.Vector.Unboxed as Data.Vector.Unboxed
import qualified Data.ProtoLens.Runtime.Text.Read as Text.Read
{- | Fields :
     
         * 'Proto.Kafka_Fields.key' @:: Lens' KafkaProducerRecord Data.Text.Text@
         * 'Proto.Kafka_Fields.valueBytes' @:: Lens' KafkaProducerRecord Data.ByteString.ByteString@
         * 'Proto.Kafka_Fields.topic' @:: Lens' KafkaProducerRecord Data.Text.Text@ -}
data KafkaProducerRecord
  = KafkaProducerRecord'_constructor {KafkaProducerRecord -> Text
_KafkaProducerRecord'key :: !Data.Text.Text,
                                      KafkaProducerRecord -> ByteString
_KafkaProducerRecord'valueBytes :: !Data.ByteString.ByteString,
                                      KafkaProducerRecord -> Text
_KafkaProducerRecord'topic :: !Data.Text.Text,
                                      KafkaProducerRecord -> FieldSet
_KafkaProducerRecord'_unknownFields :: !Data.ProtoLens.FieldSet}
  deriving stock (KafkaProducerRecord -> KafkaProducerRecord -> Bool
(KafkaProducerRecord -> KafkaProducerRecord -> Bool)
-> (KafkaProducerRecord -> KafkaProducerRecord -> Bool)
-> Eq KafkaProducerRecord
forall a. (a -> a -> Bool) -> (a -> a -> Bool) -> Eq a
/= :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
$c/= :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
== :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
$c== :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
Prelude.Eq, Eq KafkaProducerRecord
Eq KafkaProducerRecord =>
(KafkaProducerRecord -> KafkaProducerRecord -> Ordering)
-> (KafkaProducerRecord -> KafkaProducerRecord -> Bool)
-> (KafkaProducerRecord -> KafkaProducerRecord -> Bool)
-> (KafkaProducerRecord -> KafkaProducerRecord -> Bool)
-> (KafkaProducerRecord -> KafkaProducerRecord -> Bool)
-> (KafkaProducerRecord
    -> KafkaProducerRecord -> KafkaProducerRecord)
-> (KafkaProducerRecord
    -> KafkaProducerRecord -> KafkaProducerRecord)
-> Ord KafkaProducerRecord
KafkaProducerRecord -> KafkaProducerRecord -> Bool
KafkaProducerRecord -> KafkaProducerRecord -> Ordering
KafkaProducerRecord -> KafkaProducerRecord -> KafkaProducerRecord
forall a.
Eq a =>
(a -> a -> Ordering)
-> (a -> a -> Bool)
-> (a -> a -> Bool)
-> (a -> a -> Bool)
-> (a -> a -> Bool)
-> (a -> a -> a)
-> (a -> a -> a)
-> Ord a
min :: KafkaProducerRecord -> KafkaProducerRecord -> KafkaProducerRecord
$cmin :: KafkaProducerRecord -> KafkaProducerRecord -> KafkaProducerRecord
max :: KafkaProducerRecord -> KafkaProducerRecord -> KafkaProducerRecord
$cmax :: KafkaProducerRecord -> KafkaProducerRecord -> KafkaProducerRecord
>= :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
$c>= :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
> :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
$c> :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
<= :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
$c<= :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
< :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
$c< :: KafkaProducerRecord -> KafkaProducerRecord -> Bool
compare :: KafkaProducerRecord -> KafkaProducerRecord -> Ordering
$ccompare :: KafkaProducerRecord -> KafkaProducerRecord -> Ordering
$cp1Ord :: Eq KafkaProducerRecord
Prelude.Ord)
instance Prelude.Show KafkaProducerRecord where
  showsPrec :: Int -> KafkaProducerRecord -> ShowS
showsPrec _ __x :: KafkaProducerRecord
__x __s :: String
__s
    = Char -> ShowS
Prelude.showChar
        '{'
        (String -> ShowS
Prelude.showString
           (KafkaProducerRecord -> String
forall msg. Message msg => msg -> String
Data.ProtoLens.showMessageShort KafkaProducerRecord
__x) (Char -> ShowS
Prelude.showChar '}' String
__s))
instance Data.ProtoLens.Field.HasField KafkaProducerRecord "key" Data.Text.Text where
  fieldOf :: Proxy# "key"
-> (Text -> f Text) -> KafkaProducerRecord -> f KafkaProducerRecord
fieldOf _
    = ((Text -> f Text) -> KafkaProducerRecord -> f KafkaProducerRecord)
-> ((Text -> f Text) -> Text -> f Text)
-> (Text -> f Text)
-> KafkaProducerRecord
-> f KafkaProducerRecord
forall b c a. (b -> c) -> (a -> b) -> a -> c
(Prelude..)
        ((KafkaProducerRecord -> Text)
-> (KafkaProducerRecord -> Text -> KafkaProducerRecord)
-> Lens KafkaProducerRecord KafkaProducerRecord Text Text
forall s a b t. (s -> a) -> (s -> b -> t) -> Lens s t a b
Lens.Family2.Unchecked.lens
           KafkaProducerRecord -> Text
_KafkaProducerRecord'key
           (\ x__ :: KafkaProducerRecord
x__ y__ :: Text
y__ -> KafkaProducerRecord
x__ {_KafkaProducerRecord'key :: Text
_KafkaProducerRecord'key = Text
y__}))
        (Text -> f Text) -> Text -> f Text
forall a. a -> a
Prelude.id
instance Data.ProtoLens.Field.HasField KafkaProducerRecord "valueBytes" Data.ByteString.ByteString where
  fieldOf :: Proxy# "valueBytes"
-> (ByteString -> f ByteString)
-> KafkaProducerRecord
-> f KafkaProducerRecord
fieldOf _
    = ((ByteString -> f ByteString)
 -> KafkaProducerRecord -> f KafkaProducerRecord)
-> ((ByteString -> f ByteString) -> ByteString -> f ByteString)
-> (ByteString -> f ByteString)
-> KafkaProducerRecord
-> f KafkaProducerRecord
forall b c a. (b -> c) -> (a -> b) -> a -> c
(Prelude..)
        ((KafkaProducerRecord -> ByteString)
-> (KafkaProducerRecord -> ByteString -> KafkaProducerRecord)
-> Lens
     KafkaProducerRecord KafkaProducerRecord ByteString ByteString
forall s a b t. (s -> a) -> (s -> b -> t) -> Lens s t a b
Lens.Family2.Unchecked.lens
           KafkaProducerRecord -> ByteString
_KafkaProducerRecord'valueBytes
           (\ x__ :: KafkaProducerRecord
x__ y__ :: ByteString
y__ -> KafkaProducerRecord
x__ {_KafkaProducerRecord'valueBytes :: ByteString
_KafkaProducerRecord'valueBytes = ByteString
y__}))
        (ByteString -> f ByteString) -> ByteString -> f ByteString
forall a. a -> a
Prelude.id
instance Data.ProtoLens.Field.HasField KafkaProducerRecord "topic" Data.Text.Text where
  fieldOf :: Proxy# "topic"
-> (Text -> f Text) -> KafkaProducerRecord -> f KafkaProducerRecord
fieldOf _
    = ((Text -> f Text) -> KafkaProducerRecord -> f KafkaProducerRecord)
-> ((Text -> f Text) -> Text -> f Text)
-> (Text -> f Text)
-> KafkaProducerRecord
-> f KafkaProducerRecord
forall b c a. (b -> c) -> (a -> b) -> a -> c
(Prelude..)
        ((KafkaProducerRecord -> Text)
-> (KafkaProducerRecord -> Text -> KafkaProducerRecord)
-> Lens KafkaProducerRecord KafkaProducerRecord Text Text
forall s a b t. (s -> a) -> (s -> b -> t) -> Lens s t a b
Lens.Family2.Unchecked.lens
           KafkaProducerRecord -> Text
_KafkaProducerRecord'topic
           (\ x__ :: KafkaProducerRecord
x__ y__ :: Text
y__ -> KafkaProducerRecord
x__ {_KafkaProducerRecord'topic :: Text
_KafkaProducerRecord'topic = Text
y__}))
        (Text -> f Text) -> Text -> f Text
forall a. a -> a
Prelude.id
instance Data.ProtoLens.Message KafkaProducerRecord where
  messageName :: Proxy KafkaProducerRecord -> Text
messageName _
    = String -> Text
Data.Text.pack
        "org.apache.flink.statefun.flink.io.KafkaProducerRecord"
  packedMessageDescriptor :: Proxy KafkaProducerRecord -> ByteString
packedMessageDescriptor _
    = "\n\
      \\DC3KafkaProducerRecord\DC2\DLE\n\
      \\ETXkey\CAN\SOH \SOH(\tR\ETXkey\DC2\US\n\
      \\vvalue_bytes\CAN\STX \SOH(\fR\n\
      \valueBytes\DC2\DC4\n\
      \\ENQtopic\CAN\ETX \SOH(\tR\ENQtopic"
  packedFileDescriptor :: Proxy KafkaProducerRecord -> ByteString
packedFileDescriptor _ = ByteString
packedFileDescriptor
  fieldsByTag :: Map Tag (FieldDescriptor KafkaProducerRecord)
fieldsByTag
    = let
        key__field_descriptor :: FieldDescriptor KafkaProducerRecord
key__field_descriptor
          = String
-> FieldTypeDescriptor Text
-> FieldAccessor KafkaProducerRecord Text
-> FieldDescriptor KafkaProducerRecord
forall value msg.
String
-> FieldTypeDescriptor value
-> FieldAccessor msg value
-> FieldDescriptor msg
Data.ProtoLens.FieldDescriptor
              "key"
              (ScalarField Text -> FieldTypeDescriptor Text
forall value. ScalarField value -> FieldTypeDescriptor value
Data.ProtoLens.ScalarField ScalarField Text
Data.ProtoLens.StringField ::
                 Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
              (WireDefault Text
-> Lens KafkaProducerRecord KafkaProducerRecord Text Text
-> FieldAccessor KafkaProducerRecord Text
forall value msg.
WireDefault value -> Lens' msg value -> FieldAccessor msg value
Data.ProtoLens.PlainField
                 WireDefault Text
forall value. (FieldDefault value, Eq value) => WireDefault value
Data.ProtoLens.Optional (forall s a (f :: * -> *).
(HasField s "key" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"key")) ::
              Data.ProtoLens.FieldDescriptor KafkaProducerRecord
        valueBytes__field_descriptor :: FieldDescriptor KafkaProducerRecord
valueBytes__field_descriptor
          = String
-> FieldTypeDescriptor ByteString
-> FieldAccessor KafkaProducerRecord ByteString
-> FieldDescriptor KafkaProducerRecord
forall value msg.
String
-> FieldTypeDescriptor value
-> FieldAccessor msg value
-> FieldDescriptor msg
Data.ProtoLens.FieldDescriptor
              "value_bytes"
              (ScalarField ByteString -> FieldTypeDescriptor ByteString
forall value. ScalarField value -> FieldTypeDescriptor value
Data.ProtoLens.ScalarField ScalarField ByteString
Data.ProtoLens.BytesField ::
                 Data.ProtoLens.FieldTypeDescriptor Data.ByteString.ByteString)
              (WireDefault ByteString
-> Lens
     KafkaProducerRecord KafkaProducerRecord ByteString ByteString
-> FieldAccessor KafkaProducerRecord ByteString
forall value msg.
WireDefault value -> Lens' msg value -> FieldAccessor msg value
Data.ProtoLens.PlainField
                 WireDefault ByteString
forall value. (FieldDefault value, Eq value) => WireDefault value
Data.ProtoLens.Optional
                 (forall s a (f :: * -> *).
(HasField s "valueBytes" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"valueBytes")) ::
              Data.ProtoLens.FieldDescriptor KafkaProducerRecord
        topic__field_descriptor :: FieldDescriptor KafkaProducerRecord
topic__field_descriptor
          = String
-> FieldTypeDescriptor Text
-> FieldAccessor KafkaProducerRecord Text
-> FieldDescriptor KafkaProducerRecord
forall value msg.
String
-> FieldTypeDescriptor value
-> FieldAccessor msg value
-> FieldDescriptor msg
Data.ProtoLens.FieldDescriptor
              "topic"
              (ScalarField Text -> FieldTypeDescriptor Text
forall value. ScalarField value -> FieldTypeDescriptor value
Data.ProtoLens.ScalarField ScalarField Text
Data.ProtoLens.StringField ::
                 Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
              (WireDefault Text
-> Lens KafkaProducerRecord KafkaProducerRecord Text Text
-> FieldAccessor KafkaProducerRecord Text
forall value msg.
WireDefault value -> Lens' msg value -> FieldAccessor msg value
Data.ProtoLens.PlainField
                 WireDefault Text
forall value. (FieldDefault value, Eq value) => WireDefault value
Data.ProtoLens.Optional (forall s a (f :: * -> *).
(HasField s "topic" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"topic")) ::
              Data.ProtoLens.FieldDescriptor KafkaProducerRecord
      in
        [(Tag, FieldDescriptor KafkaProducerRecord)]
-> Map Tag (FieldDescriptor KafkaProducerRecord)
forall k a. Ord k => [(k, a)] -> Map k a
Data.Map.fromList
          [(Int -> Tag
Data.ProtoLens.Tag 1, FieldDescriptor KafkaProducerRecord
key__field_descriptor),
           (Int -> Tag
Data.ProtoLens.Tag 2, FieldDescriptor KafkaProducerRecord
valueBytes__field_descriptor),
           (Int -> Tag
Data.ProtoLens.Tag 3, FieldDescriptor KafkaProducerRecord
topic__field_descriptor)]
  unknownFields :: LensLike' f KafkaProducerRecord FieldSet
unknownFields
    = (KafkaProducerRecord -> FieldSet)
-> (KafkaProducerRecord -> FieldSet -> KafkaProducerRecord)
-> Lens' KafkaProducerRecord FieldSet
forall s a b t. (s -> a) -> (s -> b -> t) -> Lens s t a b
Lens.Family2.Unchecked.lens
        KafkaProducerRecord -> FieldSet
_KafkaProducerRecord'_unknownFields
        (\ x__ :: KafkaProducerRecord
x__ y__ :: FieldSet
y__ -> KafkaProducerRecord
x__ {_KafkaProducerRecord'_unknownFields :: FieldSet
_KafkaProducerRecord'_unknownFields = FieldSet
y__})
  defMessage :: KafkaProducerRecord
defMessage
    = $WKafkaProducerRecord'_constructor :: Text -> ByteString -> Text -> FieldSet -> KafkaProducerRecord
KafkaProducerRecord'_constructor
        {_KafkaProducerRecord'key :: Text
_KafkaProducerRecord'key = Text
forall value. FieldDefault value => value
Data.ProtoLens.fieldDefault,
         _KafkaProducerRecord'valueBytes :: ByteString
_KafkaProducerRecord'valueBytes = ByteString
forall value. FieldDefault value => value
Data.ProtoLens.fieldDefault,
         _KafkaProducerRecord'topic :: Text
_KafkaProducerRecord'topic = Text
forall value. FieldDefault value => value
Data.ProtoLens.fieldDefault,
         _KafkaProducerRecord'_unknownFields :: FieldSet
_KafkaProducerRecord'_unknownFields = []}
  parseMessage :: Parser KafkaProducerRecord
parseMessage
    = let
        loop ::
          KafkaProducerRecord
          -> Data.ProtoLens.Encoding.Bytes.Parser KafkaProducerRecord
        loop :: KafkaProducerRecord -> Parser KafkaProducerRecord
loop x :: KafkaProducerRecord
x
          = do Bool
end <- Parser Bool
Data.ProtoLens.Encoding.Bytes.atEnd
               if Bool
end then
                   do (let missing :: [a]
missing = []
                       in
                         if [Any] -> Bool
forall (t :: * -> *) a. Foldable t => t a -> Bool
Prelude.null [Any]
forall a. [a]
missing then
                             () -> Parser ()
forall (m :: * -> *) a. Monad m => a -> m a
Prelude.return ()
                         else
                             String -> Parser ()
forall (m :: * -> *) a. MonadFail m => String -> m a
Prelude.fail
                               (String -> ShowS
forall a. [a] -> [a] -> [a]
(Prelude.++)
                                  "Missing required fields: "
                                  ([String] -> String
forall a. Show a => a -> String
Prelude.show ([String]
forall a. [a]
missing :: [Prelude.String]))))
                      KafkaProducerRecord -> Parser KafkaProducerRecord
forall (m :: * -> *) a. Monad m => a -> m a
Prelude.return
                        (Setter KafkaProducerRecord KafkaProducerRecord FieldSet FieldSet
-> (FieldSet -> FieldSet)
-> KafkaProducerRecord
-> KafkaProducerRecord
forall s t a b. Setter s t a b -> (a -> b) -> s -> t
Lens.Family2.over
                           forall msg. Message msg => Lens' msg FieldSet
Setter KafkaProducerRecord KafkaProducerRecord FieldSet FieldSet
Data.ProtoLens.unknownFields (\ !FieldSet
t -> FieldSet -> FieldSet
forall a. [a] -> [a]
Prelude.reverse FieldSet
t) KafkaProducerRecord
x)
               else
                   do Word64
tag <- Parser Word64
Data.ProtoLens.Encoding.Bytes.getVarInt
                      case Word64
tag of
                        10
                          -> do Text
y <- Parser Text -> String -> Parser Text
forall a. Parser a -> String -> Parser a
(Data.ProtoLens.Encoding.Bytes.<?>)
                                       (do ByteString
value <- do Word64
len <- Parser Word64
Data.ProtoLens.Encoding.Bytes.getVarInt
                                                       Int -> Parser ByteString
Data.ProtoLens.Encoding.Bytes.getBytes
                                                         (Word64 -> Int
forall a b. (Integral a, Num b) => a -> b
Prelude.fromIntegral Word64
len)
                                           Either String Text -> Parser Text
forall a. Either String a -> Parser a
Data.ProtoLens.Encoding.Bytes.runEither
                                             (case ByteString -> Either UnicodeException Text
Data.Text.Encoding.decodeUtf8' ByteString
value of
                                                (Prelude.Left err :: UnicodeException
err)
                                                  -> String -> Either String Text
forall a b. a -> Either a b
Prelude.Left (UnicodeException -> String
forall a. Show a => a -> String
Prelude.show UnicodeException
err)
                                                (Prelude.Right r :: Text
r) -> Text -> Either String Text
forall a b. b -> Either a b
Prelude.Right Text
r))
                                       "key"
                                KafkaProducerRecord -> Parser KafkaProducerRecord
loop (Setter KafkaProducerRecord KafkaProducerRecord Text Text
-> Text -> KafkaProducerRecord -> KafkaProducerRecord
forall s t a b. Setter s t a b -> b -> s -> t
Lens.Family2.set (forall s a (f :: * -> *).
(HasField s "key" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"key") Text
y KafkaProducerRecord
x)
                        18
                          -> do ByteString
y <- Parser ByteString -> String -> Parser ByteString
forall a. Parser a -> String -> Parser a
(Data.ProtoLens.Encoding.Bytes.<?>)
                                       (do Word64
len <- Parser Word64
Data.ProtoLens.Encoding.Bytes.getVarInt
                                           Int -> Parser ByteString
Data.ProtoLens.Encoding.Bytes.getBytes
                                             (Word64 -> Int
forall a b. (Integral a, Num b) => a -> b
Prelude.fromIntegral Word64
len))
                                       "value_bytes"
                                KafkaProducerRecord -> Parser KafkaProducerRecord
loop
                                  (Setter
  KafkaProducerRecord KafkaProducerRecord ByteString ByteString
-> ByteString -> KafkaProducerRecord -> KafkaProducerRecord
forall s t a b. Setter s t a b -> b -> s -> t
Lens.Family2.set (forall s a (f :: * -> *).
(HasField s "valueBytes" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"valueBytes") ByteString
y KafkaProducerRecord
x)
                        26
                          -> do Text
y <- Parser Text -> String -> Parser Text
forall a. Parser a -> String -> Parser a
(Data.ProtoLens.Encoding.Bytes.<?>)
                                       (do ByteString
value <- do Word64
len <- Parser Word64
Data.ProtoLens.Encoding.Bytes.getVarInt
                                                       Int -> Parser ByteString
Data.ProtoLens.Encoding.Bytes.getBytes
                                                         (Word64 -> Int
forall a b. (Integral a, Num b) => a -> b
Prelude.fromIntegral Word64
len)
                                           Either String Text -> Parser Text
forall a. Either String a -> Parser a
Data.ProtoLens.Encoding.Bytes.runEither
                                             (case ByteString -> Either UnicodeException Text
Data.Text.Encoding.decodeUtf8' ByteString
value of
                                                (Prelude.Left err :: UnicodeException
err)
                                                  -> String -> Either String Text
forall a b. a -> Either a b
Prelude.Left (UnicodeException -> String
forall a. Show a => a -> String
Prelude.show UnicodeException
err)
                                                (Prelude.Right r :: Text
r) -> Text -> Either String Text
forall a b. b -> Either a b
Prelude.Right Text
r))
                                       "topic"
                                KafkaProducerRecord -> Parser KafkaProducerRecord
loop (Setter KafkaProducerRecord KafkaProducerRecord Text Text
-> Text -> KafkaProducerRecord -> KafkaProducerRecord
forall s t a b. Setter s t a b -> b -> s -> t
Lens.Family2.set (forall s a (f :: * -> *).
(HasField s "topic" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"topic") Text
y KafkaProducerRecord
x)
                        wire :: Word64
wire
                          -> do !TaggedValue
y <- Word64 -> Parser TaggedValue
Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
                                        Word64
wire
                                KafkaProducerRecord -> Parser KafkaProducerRecord
loop
                                  (Setter KafkaProducerRecord KafkaProducerRecord FieldSet FieldSet
-> (FieldSet -> FieldSet)
-> KafkaProducerRecord
-> KafkaProducerRecord
forall s t a b. Setter s t a b -> (a -> b) -> s -> t
Lens.Family2.over
                                     forall msg. Message msg => Lens' msg FieldSet
Setter KafkaProducerRecord KafkaProducerRecord FieldSet FieldSet
Data.ProtoLens.unknownFields (\ !FieldSet
t -> (:) TaggedValue
y FieldSet
t) KafkaProducerRecord
x)
      in
        Parser KafkaProducerRecord -> String -> Parser KafkaProducerRecord
forall a. Parser a -> String -> Parser a
(Data.ProtoLens.Encoding.Bytes.<?>)
          (do KafkaProducerRecord -> Parser KafkaProducerRecord
loop KafkaProducerRecord
forall msg. Message msg => msg
Data.ProtoLens.defMessage) "KafkaProducerRecord"
  buildMessage :: KafkaProducerRecord -> Builder
buildMessage
    = \ _x :: KafkaProducerRecord
_x
        -> Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
             (let _v :: Text
_v = FoldLike Text KafkaProducerRecord KafkaProducerRecord Text Text
-> KafkaProducerRecord -> Text
forall a s t b. FoldLike a s t a b -> s -> a
Lens.Family2.view (forall s a (f :: * -> *).
(HasField s "key" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"key") KafkaProducerRecord
_x
              in
                if Text -> Text -> Bool
forall a. Eq a => a -> a -> Bool
(Prelude.==) Text
_v Text
forall value. FieldDefault value => value
Data.ProtoLens.fieldDefault then
                    Builder
forall a. Monoid a => a
Data.Monoid.mempty
                else
                    Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                      (Word64 -> Builder
Data.ProtoLens.Encoding.Bytes.putVarInt 10)
                      ((ByteString -> Builder) -> (Text -> ByteString) -> Text -> Builder
forall b c a. (b -> c) -> (a -> b) -> a -> c
(Prelude..)
                         (\ bs :: ByteString
bs
                            -> Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                                 (Word64 -> Builder
Data.ProtoLens.Encoding.Bytes.putVarInt
                                    (Int -> Word64
forall a b. (Integral a, Num b) => a -> b
Prelude.fromIntegral (ByteString -> Int
Data.ByteString.length ByteString
bs)))
                                 (ByteString -> Builder
Data.ProtoLens.Encoding.Bytes.putBytes ByteString
bs))
                         Text -> ByteString
Data.Text.Encoding.encodeUtf8
                         Text
_v))
             (Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                (let
                   _v :: ByteString
_v
                     = FoldLike
  ByteString
  KafkaProducerRecord
  KafkaProducerRecord
  ByteString
  ByteString
-> KafkaProducerRecord -> ByteString
forall a s t b. FoldLike a s t a b -> s -> a
Lens.Family2.view (forall s a (f :: * -> *).
(HasField s "valueBytes" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"valueBytes") KafkaProducerRecord
_x
                 in
                   if ByteString -> ByteString -> Bool
forall a. Eq a => a -> a -> Bool
(Prelude.==) ByteString
_v ByteString
forall value. FieldDefault value => value
Data.ProtoLens.fieldDefault then
                       Builder
forall a. Monoid a => a
Data.Monoid.mempty
                   else
                       Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                         (Word64 -> Builder
Data.ProtoLens.Encoding.Bytes.putVarInt 18)
                         ((\ bs :: ByteString
bs
                             -> Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                                  (Word64 -> Builder
Data.ProtoLens.Encoding.Bytes.putVarInt
                                     (Int -> Word64
forall a b. (Integral a, Num b) => a -> b
Prelude.fromIntegral (ByteString -> Int
Data.ByteString.length ByteString
bs)))
                                  (ByteString -> Builder
Data.ProtoLens.Encoding.Bytes.putBytes ByteString
bs))
                            ByteString
_v))
                (Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                   (let
                      _v :: Text
_v = FoldLike Text KafkaProducerRecord KafkaProducerRecord Text Text
-> KafkaProducerRecord -> Text
forall a s t b. FoldLike a s t a b -> s -> a
Lens.Family2.view (forall s a (f :: * -> *).
(HasField s "topic" a, Functor f) =>
(a -> f a) -> s -> f s
forall (x :: Symbol) s a (f :: * -> *).
(HasField s x a, Functor f) =>
(a -> f a) -> s -> f s
Data.ProtoLens.Field.field @"topic") KafkaProducerRecord
_x
                    in
                      if Text -> Text -> Bool
forall a. Eq a => a -> a -> Bool
(Prelude.==) Text
_v Text
forall value. FieldDefault value => value
Data.ProtoLens.fieldDefault then
                          Builder
forall a. Monoid a => a
Data.Monoid.mempty
                      else
                          Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                            (Word64 -> Builder
Data.ProtoLens.Encoding.Bytes.putVarInt 26)
                            ((ByteString -> Builder) -> (Text -> ByteString) -> Text -> Builder
forall b c a. (b -> c) -> (a -> b) -> a -> c
(Prelude..)
                               (\ bs :: ByteString
bs
                                  -> Builder -> Builder -> Builder
forall a. Semigroup a => a -> a -> a
(Data.Monoid.<>)
                                       (Word64 -> Builder
Data.ProtoLens.Encoding.Bytes.putVarInt
                                          (Int -> Word64
forall a b. (Integral a, Num b) => a -> b
Prelude.fromIntegral (ByteString -> Int
Data.ByteString.length ByteString
bs)))
                                       (ByteString -> Builder
Data.ProtoLens.Encoding.Bytes.putBytes ByteString
bs))
                               Text -> ByteString
Data.Text.Encoding.encodeUtf8
                               Text
_v))
                   (FieldSet -> Builder
Data.ProtoLens.Encoding.Wire.buildFieldSet
                      (FoldLike
  FieldSet KafkaProducerRecord KafkaProducerRecord FieldSet FieldSet
-> KafkaProducerRecord -> FieldSet
forall a s t b. FoldLike a s t a b -> s -> a
Lens.Family2.view FoldLike
  FieldSet KafkaProducerRecord KafkaProducerRecord FieldSet FieldSet
forall msg. Message msg => Lens' msg FieldSet
Data.ProtoLens.unknownFields KafkaProducerRecord
_x))))
instance Control.DeepSeq.NFData KafkaProducerRecord where
  rnf :: KafkaProducerRecord -> ()
rnf
    = \ x__ :: KafkaProducerRecord
x__
        -> FieldSet -> () -> ()
forall a b. NFData a => a -> b -> b
Control.DeepSeq.deepseq
             (KafkaProducerRecord -> FieldSet
_KafkaProducerRecord'_unknownFields KafkaProducerRecord
x__)
             (Text -> () -> ()
forall a b. NFData a => a -> b -> b
Control.DeepSeq.deepseq
                (KafkaProducerRecord -> Text
_KafkaProducerRecord'key KafkaProducerRecord
x__)
                (ByteString -> () -> ()
forall a b. NFData a => a -> b -> b
Control.DeepSeq.deepseq
                   (KafkaProducerRecord -> ByteString
_KafkaProducerRecord'valueBytes KafkaProducerRecord
x__)
                   (Text -> () -> ()
forall a b. NFData a => a -> b -> b
Control.DeepSeq.deepseq (KafkaProducerRecord -> Text
_KafkaProducerRecord'topic KafkaProducerRecord
x__) ())))
packedFileDescriptor :: Data.ByteString.ByteString
packedFileDescriptor :: ByteString
packedFileDescriptor
  = "\n\
    \\vKafka.proto\DC2\"org.apache.flink.statefun.flink.io\"^\n\
    \\DC3KafkaProducerRecord\DC2\DLE\n\
    \\ETXkey\CAN\SOH \SOH(\tR\ETXkey\DC2\US\n\
    \\vvalue_bytes\CAN\STX \SOH(\fR\n\
    \valueBytes\DC2\DC4\n\
    \\ENQtopic\CAN\ETX \SOH(\tR\ENQtopicB0\n\
    \,org.apache.flink.statefun.flink.io.generatedP\SOHJ\182\b\n\
    \\ACK\DC2\EOT\DC2\NUL\FS\SOH\n\
    \\141\ACK\n\
    \\SOH\f\DC2\ETX\DC2\NUL\DC22\130\ACK\n\
    \ Licensed to the Apache Software Foundation (ASF) under one\n\
    \ or more contributor license agreements.  See the NOTICE file\n\
    \ distributed with this work for additional information\n\
    \ regarding copyright ownership.  The ASF licenses this file\n\
    \ to you under the Apache License, Version 2.0 (the\n\
    \ \"License\"); you may not use this file except in compliance\n\
    \ with the License.  You may obtain a copy of the License at\n\
    \\n\
    \     http://www.apache.org/licenses/LICENSE-2.0\n\
    \\n\
    \ Unless required by applicable law or agreed to in writing, software\n\
    \ distributed under the License is distributed on an \"AS IS\" BASIS,\n\
    \ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n\
    \ See the License for the specific language governing permissions and\n\
    \ limitations under the License.\n\
    \\n\
    \\b\n\
    \\SOH\STX\DC2\ETX\DC4\NUL+\n\
    \\b\n\
    \\SOH\b\DC2\ETX\NAK\NULE\n\
    \\t\n\
    \\STX\b\SOH\DC2\ETX\NAK\NULE\n\
    \\b\n\
    \\SOH\b\DC2\ETX\SYN\NUL\"\n\
    \\t\n\
    \\STX\b\n\
    \\DC2\ETX\SYN\NUL\"\n\
    \\n\
    \\n\
    \\STX\EOT\NUL\DC2\EOT\CAN\NUL\FS\SOH\n\
    \\n\
    \\n\
    \\ETX\EOT\NUL\SOH\DC2\ETX\CAN\b\ESC\n\
    \\v\n\
    \\EOT\EOT\NUL\STX\NUL\DC2\ETX\EM\EOT\DC3\n\
    \\r\n\
    \\ENQ\EOT\NUL\STX\NUL\EOT\DC2\EOT\EM\EOT\CAN\GS\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\NUL\ENQ\DC2\ETX\EM\EOT\n\
    \\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\NUL\SOH\DC2\ETX\EM\v\SO\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\NUL\ETX\DC2\ETX\EM\DC1\DC2\n\
    \\v\n\
    \\EOT\EOT\NUL\STX\SOH\DC2\ETX\SUB\EOT\SUB\n\
    \\r\n\
    \\ENQ\EOT\NUL\STX\SOH\EOT\DC2\EOT\SUB\EOT\EM\DC3\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\SOH\ENQ\DC2\ETX\SUB\EOT\t\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\SOH\SOH\DC2\ETX\SUB\n\
    \\NAK\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\SOH\ETX\DC2\ETX\SUB\CAN\EM\n\
    \\v\n\
    \\EOT\EOT\NUL\STX\STX\DC2\ETX\ESC\EOT\NAK\n\
    \\r\n\
    \\ENQ\EOT\NUL\STX\STX\EOT\DC2\EOT\ESC\EOT\SUB\SUB\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\STX\ENQ\DC2\ETX\ESC\EOT\n\
    \\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\STX\SOH\DC2\ETX\ESC\v\DLE\n\
    \\f\n\
    \\ENQ\EOT\NUL\STX\STX\ETX\DC2\ETX\ESC\DC3\DC4b\ACKproto3"