Copyright	(c) 2013-2023 Brendan Hay
License	Mozilla Public License, v. 2.0.
Maintainer	Brendan Hay
Stability	auto-generated
Portability	non-portable (GHC extensions)
Safe Haskell	Safe-Inferred
Language	Haskell2010

Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters

Description

Documentation

data UpdatePipeSourceManagedStreamingKafkaParameters Source #

The parameters for using an MSK stream as a source.

See: newUpdatePipeSourceManagedStreamingKafkaParameters smart constructor.

Constructors

UpdatePipeSourceManagedStreamingKafkaParameters'
Fields batchSize :: Maybe Natural The maximum number of records to include in each batch. credentials :: Maybe MSKAccessCredentials The credentials needed to access the resource. maximumBatchingWindowInSeconds :: Maybe Natural The maximum length of a time to wait for events.

Instances

Instances details

ToJSON UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Methods toJSON :: UpdatePipeSourceManagedStreamingKafkaParameters -> Value # toEncoding :: UpdatePipeSourceManagedStreamingKafkaParameters -> Encoding # toJSONList :: [UpdatePipeSourceManagedStreamingKafkaParameters] -> Value # toEncodingList :: [UpdatePipeSourceManagedStreamingKafkaParameters] -> Encoding #
Generic UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Associated Types type Rep UpdatePipeSourceManagedStreamingKafkaParameters :: Type -> Type # Methods from :: UpdatePipeSourceManagedStreamingKafkaParameters -> Rep UpdatePipeSourceManagedStreamingKafkaParameters x # to :: Rep UpdatePipeSourceManagedStreamingKafkaParameters x -> UpdatePipeSourceManagedStreamingKafkaParameters #
Read UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Methods readsPrec :: Int -> ReadS UpdatePipeSourceManagedStreamingKafkaParameters # readList :: ReadS [UpdatePipeSourceManagedStreamingKafkaParameters] # readPrec :: ReadPrec UpdatePipeSourceManagedStreamingKafkaParameters # readListPrec :: ReadPrec [UpdatePipeSourceManagedStreamingKafkaParameters] #
Show UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Methods showsPrec :: Int -> UpdatePipeSourceManagedStreamingKafkaParameters -> ShowS # show :: UpdatePipeSourceManagedStreamingKafkaParameters -> String # showList :: [UpdatePipeSourceManagedStreamingKafkaParameters] -> ShowS #
NFData UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Methods rnf :: UpdatePipeSourceManagedStreamingKafkaParameters -> () #
Eq UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Methods (==) :: UpdatePipeSourceManagedStreamingKafkaParameters -> UpdatePipeSourceManagedStreamingKafkaParameters -> Bool # (/=) :: UpdatePipeSourceManagedStreamingKafkaParameters -> UpdatePipeSourceManagedStreamingKafkaParameters -> Bool #
Hashable UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters Methods hashWithSalt :: Int -> UpdatePipeSourceManagedStreamingKafkaParameters -> Int # hash :: UpdatePipeSourceManagedStreamingKafkaParameters -> Int #
type Rep UpdatePipeSourceManagedStreamingKafkaParameters Source #
Instance details Defined in Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters type Rep UpdatePipeSourceManagedStreamingKafkaParameters = D1 ('MetaData "UpdatePipeSourceManagedStreamingKafkaParameters" "Amazonka.Pipes.Types.UpdatePipeSourceManagedStreamingKafkaParameters" "amazonka-pipes-2.0-DDuNjbjVfgsJFLlibzr06i" 'False) (C1 ('MetaCons "UpdatePipeSourceManagedStreamingKafkaParameters'" 'PrefixI 'True) (S1 ('MetaSel ('Just "batchSize") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Natural)) :: (S1 ('MetaSel ('Just "credentials") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe MSKAccessCredentials)) :: S1 ('MetaSel ('Just "maximumBatchingWindowInSeconds") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedStrict) (Rec0 (Maybe Natural)))))

newUpdatePipeSourceManagedStreamingKafkaParameters :: UpdatePipeSourceManagedStreamingKafkaParameters Source #

Create a value of UpdatePipeSourceManagedStreamingKafkaParameters with all optional fields omitted.

Use generic-lens or optics to modify other optional fields.

The following record fields are available, with the corresponding lenses provided for backwards compatibility:

$sel:batchSize:UpdatePipeSourceManagedStreamingKafkaParameters', updatePipeSourceManagedStreamingKafkaParameters_batchSize - The maximum number of records to include in each batch.

$sel:credentials:UpdatePipeSourceManagedStreamingKafkaParameters', updatePipeSourceManagedStreamingKafkaParameters_credentials - The credentials needed to access the resource.

$sel:maximumBatchingWindowInSeconds:UpdatePipeSourceManagedStreamingKafkaParameters', updatePipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds - The maximum length of a time to wait for events.

updatePipeSourceManagedStreamingKafkaParameters_batchSize :: Lens' UpdatePipeSourceManagedStreamingKafkaParameters (Maybe Natural) Source #

The maximum number of records to include in each batch.

updatePipeSourceManagedStreamingKafkaParameters_credentials :: Lens' UpdatePipeSourceManagedStreamingKafkaParameters (Maybe MSKAccessCredentials) Source #

The credentials needed to access the resource.

updatePipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds :: Lens' UpdatePipeSourceManagedStreamingKafkaParameters (Maybe Natural) Source #

The maximum length of a time to wait for events.