temporal-api-protos-2025.10.1.0: src/Proto/Temporal/Api/Taskqueue/V1/Message.hs
{- This file was auto-generated from temporal/api/taskqueue/v1/message.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.Temporal.Api.Taskqueue.V1.Message (
BuildIdAssignmentRule(), BuildIdAssignmentRule'Ramp(..),
_BuildIdAssignmentRule'PercentageRamp, BuildIdReachability(),
CompatibleBuildIdRedirectRule(), CompatibleVersionSet(),
PollerInfo(), PollerScalingDecision(), RampByPercentage(),
StickyExecutionAttributes(), TaskIdBlock(), TaskQueue(),
TaskQueueMetadata(), TaskQueuePartitionMetadata(),
TaskQueueReachability(), TaskQueueStats(), TaskQueueStatus(),
TaskQueueTypeInfo(), TaskQueueVersionInfo(),
TaskQueueVersionInfo'TypesInfoEntry(), TaskQueueVersionSelection(),
TaskQueueVersioningInfo(), TimestampedBuildIdAssignmentRule(),
TimestampedCompatibleBuildIdRedirectRule()
) 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
import qualified Proto.Google.Protobuf.Duration
import qualified Proto.Google.Protobuf.Timestamp
import qualified Proto.Google.Protobuf.Wrappers
import qualified Proto.Temporal.Api.Common.V1.Message
import qualified Proto.Temporal.Api.Deployment.V1.Message
import qualified Proto.Temporal.Api.Enums.V1.TaskQueue
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.targetBuildId' @:: Lens' BuildIdAssignmentRule Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'ramp' @:: Lens' BuildIdAssignmentRule (Prelude.Maybe BuildIdAssignmentRule'Ramp)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'percentageRamp' @:: Lens' BuildIdAssignmentRule (Prelude.Maybe RampByPercentage)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.percentageRamp' @:: Lens' BuildIdAssignmentRule RampByPercentage@ -}
data BuildIdAssignmentRule
= BuildIdAssignmentRule'_constructor {_BuildIdAssignmentRule'targetBuildId :: !Data.Text.Text,
_BuildIdAssignmentRule'ramp :: !(Prelude.Maybe BuildIdAssignmentRule'Ramp),
_BuildIdAssignmentRule'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show BuildIdAssignmentRule where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
data BuildIdAssignmentRule'Ramp
= BuildIdAssignmentRule'PercentageRamp !RampByPercentage
deriving stock (Prelude.Show, Prelude.Eq, Prelude.Ord)
instance Data.ProtoLens.Field.HasField BuildIdAssignmentRule "targetBuildId" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdAssignmentRule'targetBuildId
(\ x__ y__ -> x__ {_BuildIdAssignmentRule'targetBuildId = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField BuildIdAssignmentRule "maybe'ramp" (Prelude.Maybe BuildIdAssignmentRule'Ramp) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdAssignmentRule'ramp
(\ x__ y__ -> x__ {_BuildIdAssignmentRule'ramp = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField BuildIdAssignmentRule "maybe'percentageRamp" (Prelude.Maybe RampByPercentage) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdAssignmentRule'ramp
(\ x__ y__ -> x__ {_BuildIdAssignmentRule'ramp = y__}))
(Lens.Family2.Unchecked.lens
(\ x__
-> case x__ of
(Prelude.Just (BuildIdAssignmentRule'PercentageRamp x__val))
-> Prelude.Just x__val
_otherwise -> Prelude.Nothing)
(\ _ y__ -> Prelude.fmap BuildIdAssignmentRule'PercentageRamp y__))
instance Data.ProtoLens.Field.HasField BuildIdAssignmentRule "percentageRamp" RampByPercentage where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdAssignmentRule'ramp
(\ x__ y__ -> x__ {_BuildIdAssignmentRule'ramp = y__}))
((Prelude..)
(Lens.Family2.Unchecked.lens
(\ x__
-> case x__ of
(Prelude.Just (BuildIdAssignmentRule'PercentageRamp x__val))
-> Prelude.Just x__val
_otherwise -> Prelude.Nothing)
(\ _ y__ -> Prelude.fmap BuildIdAssignmentRule'PercentageRamp y__))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage))
instance Data.ProtoLens.Message BuildIdAssignmentRule where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.BuildIdAssignmentRule"
packedMessageDescriptor _
= "\n\
\\NAKBuildIdAssignmentRule\DC2&\n\
\\SItarget_build_id\CAN\SOH \SOH(\tR\rtargetBuildId\DC2V\n\
\\SIpercentage_ramp\CAN\ETX \SOH(\v2+.temporal.api.taskqueue.v1.RampByPercentageH\NULR\SOpercentageRampB\ACK\n\
\\EOTramp"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
targetBuildId__field_descriptor
= Data.ProtoLens.FieldDescriptor
"target_build_id"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"targetBuildId")) ::
Data.ProtoLens.FieldDescriptor BuildIdAssignmentRule
percentageRamp__field_descriptor
= Data.ProtoLens.FieldDescriptor
"percentage_ramp"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor RampByPercentage)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'percentageRamp")) ::
Data.ProtoLens.FieldDescriptor BuildIdAssignmentRule
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, targetBuildId__field_descriptor),
(Data.ProtoLens.Tag 3, percentageRamp__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_BuildIdAssignmentRule'_unknownFields
(\ x__ y__ -> x__ {_BuildIdAssignmentRule'_unknownFields = y__})
defMessage
= BuildIdAssignmentRule'_constructor
{_BuildIdAssignmentRule'targetBuildId = Data.ProtoLens.fieldDefault,
_BuildIdAssignmentRule'ramp = Prelude.Nothing,
_BuildIdAssignmentRule'_unknownFields = []}
parseMessage
= let
loop ::
BuildIdAssignmentRule
-> Data.ProtoLens.Encoding.Bytes.Parser BuildIdAssignmentRule
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"target_build_id"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"targetBuildId") y x)
26
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"percentage_ramp"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"percentageRamp") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "BuildIdAssignmentRule"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"targetBuildId") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(case
Lens.Family2.view (Data.ProtoLens.Field.field @"maybe'ramp") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just (BuildIdAssignmentRule'PercentageRamp v))
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 26)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData BuildIdAssignmentRule where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_BuildIdAssignmentRule'_unknownFields x__)
(Control.DeepSeq.deepseq
(_BuildIdAssignmentRule'targetBuildId x__)
(Control.DeepSeq.deepseq (_BuildIdAssignmentRule'ramp x__) ()))
instance Control.DeepSeq.NFData BuildIdAssignmentRule'Ramp where
rnf (BuildIdAssignmentRule'PercentageRamp x__)
= Control.DeepSeq.rnf x__
_BuildIdAssignmentRule'PercentageRamp ::
Data.ProtoLens.Prism.Prism' BuildIdAssignmentRule'Ramp RampByPercentage
_BuildIdAssignmentRule'PercentageRamp
= Data.ProtoLens.Prism.prism'
BuildIdAssignmentRule'PercentageRamp
(\ p__
-> case p__ of
(BuildIdAssignmentRule'PercentageRamp p__val)
-> Prelude.Just p__val)
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.buildId' @:: Lens' BuildIdReachability Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.taskQueueReachability' @:: Lens' BuildIdReachability [TaskQueueReachability]@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.vec'taskQueueReachability' @:: Lens' BuildIdReachability (Data.Vector.Vector TaskQueueReachability)@ -}
data BuildIdReachability
= BuildIdReachability'_constructor {_BuildIdReachability'buildId :: !Data.Text.Text,
_BuildIdReachability'taskQueueReachability :: !(Data.Vector.Vector TaskQueueReachability),
_BuildIdReachability'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show BuildIdReachability where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField BuildIdReachability "buildId" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdReachability'buildId
(\ x__ y__ -> x__ {_BuildIdReachability'buildId = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField BuildIdReachability "taskQueueReachability" [TaskQueueReachability] where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdReachability'taskQueueReachability
(\ x__ y__
-> x__ {_BuildIdReachability'taskQueueReachability = y__}))
(Lens.Family2.Unchecked.lens
Data.Vector.Generic.toList
(\ _ y__ -> Data.Vector.Generic.fromList y__))
instance Data.ProtoLens.Field.HasField BuildIdReachability "vec'taskQueueReachability" (Data.Vector.Vector TaskQueueReachability) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_BuildIdReachability'taskQueueReachability
(\ x__ y__
-> x__ {_BuildIdReachability'taskQueueReachability = y__}))
Prelude.id
instance Data.ProtoLens.Message BuildIdReachability where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.BuildIdReachability"
packedMessageDescriptor _
= "\n\
\\DC3BuildIdReachability\DC2\EM\n\
\\bbuild_id\CAN\SOH \SOH(\tR\abuildId\DC2h\n\
\\ETBtask_queue_reachability\CAN\STX \ETX(\v20.temporal.api.taskqueue.v1.TaskQueueReachabilityR\NAKtaskQueueReachability"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
buildId__field_descriptor
= Data.ProtoLens.FieldDescriptor
"build_id"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"buildId")) ::
Data.ProtoLens.FieldDescriptor BuildIdReachability
taskQueueReachability__field_descriptor
= Data.ProtoLens.FieldDescriptor
"task_queue_reachability"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor TaskQueueReachability)
(Data.ProtoLens.RepeatedField
Data.ProtoLens.Unpacked
(Data.ProtoLens.Field.field @"taskQueueReachability")) ::
Data.ProtoLens.FieldDescriptor BuildIdReachability
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, buildId__field_descriptor),
(Data.ProtoLens.Tag 2, taskQueueReachability__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_BuildIdReachability'_unknownFields
(\ x__ y__ -> x__ {_BuildIdReachability'_unknownFields = y__})
defMessage
= BuildIdReachability'_constructor
{_BuildIdReachability'buildId = Data.ProtoLens.fieldDefault,
_BuildIdReachability'taskQueueReachability = Data.Vector.Generic.empty,
_BuildIdReachability'_unknownFields = []}
parseMessage
= let
loop ::
BuildIdReachability
-> Data.ProtoLens.Encoding.Growing.Growing Data.Vector.Vector Data.ProtoLens.Encoding.Growing.RealWorld TaskQueueReachability
-> Data.ProtoLens.Encoding.Bytes.Parser BuildIdReachability
loop x mutable'taskQueueReachability
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do frozen'taskQueueReachability <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.unsafeFreeze
mutable'taskQueueReachability)
(let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t)
(Lens.Family2.set
(Data.ProtoLens.Field.field @"vec'taskQueueReachability")
frozen'taskQueueReachability x))
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"build_id"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"buildId") y x)
mutable'taskQueueReachability
18
-> do !y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len)
Data.ProtoLens.parseMessage)
"task_queue_reachability"
v <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.append
mutable'taskQueueReachability y)
loop x v
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
mutable'taskQueueReachability
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do mutable'taskQueueReachability <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
Data.ProtoLens.Encoding.Growing.new
loop Data.ProtoLens.defMessage mutable'taskQueueReachability)
"BuildIdReachability"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"buildId") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.foldMapBuilder
(\ _v
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Lens.Family2.view
(Data.ProtoLens.Field.field @"vec'taskQueueReachability") _x))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData BuildIdReachability where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_BuildIdReachability'_unknownFields x__)
(Control.DeepSeq.deepseq
(_BuildIdReachability'buildId x__)
(Control.DeepSeq.deepseq
(_BuildIdReachability'taskQueueReachability x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.sourceBuildId' @:: Lens' CompatibleBuildIdRedirectRule Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.targetBuildId' @:: Lens' CompatibleBuildIdRedirectRule Data.Text.Text@ -}
data CompatibleBuildIdRedirectRule
= CompatibleBuildIdRedirectRule'_constructor {_CompatibleBuildIdRedirectRule'sourceBuildId :: !Data.Text.Text,
_CompatibleBuildIdRedirectRule'targetBuildId :: !Data.Text.Text,
_CompatibleBuildIdRedirectRule'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show CompatibleBuildIdRedirectRule where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField CompatibleBuildIdRedirectRule "sourceBuildId" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_CompatibleBuildIdRedirectRule'sourceBuildId
(\ x__ y__
-> x__ {_CompatibleBuildIdRedirectRule'sourceBuildId = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField CompatibleBuildIdRedirectRule "targetBuildId" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_CompatibleBuildIdRedirectRule'targetBuildId
(\ x__ y__
-> x__ {_CompatibleBuildIdRedirectRule'targetBuildId = y__}))
Prelude.id
instance Data.ProtoLens.Message CompatibleBuildIdRedirectRule where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.CompatibleBuildIdRedirectRule"
packedMessageDescriptor _
= "\n\
\\GSCompatibleBuildIdRedirectRule\DC2&\n\
\\SIsource_build_id\CAN\SOH \SOH(\tR\rsourceBuildId\DC2&\n\
\\SItarget_build_id\CAN\STX \SOH(\tR\rtargetBuildId"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
sourceBuildId__field_descriptor
= Data.ProtoLens.FieldDescriptor
"source_build_id"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"sourceBuildId")) ::
Data.ProtoLens.FieldDescriptor CompatibleBuildIdRedirectRule
targetBuildId__field_descriptor
= Data.ProtoLens.FieldDescriptor
"target_build_id"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"targetBuildId")) ::
Data.ProtoLens.FieldDescriptor CompatibleBuildIdRedirectRule
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, sourceBuildId__field_descriptor),
(Data.ProtoLens.Tag 2, targetBuildId__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_CompatibleBuildIdRedirectRule'_unknownFields
(\ x__ y__
-> x__ {_CompatibleBuildIdRedirectRule'_unknownFields = y__})
defMessage
= CompatibleBuildIdRedirectRule'_constructor
{_CompatibleBuildIdRedirectRule'sourceBuildId = Data.ProtoLens.fieldDefault,
_CompatibleBuildIdRedirectRule'targetBuildId = Data.ProtoLens.fieldDefault,
_CompatibleBuildIdRedirectRule'_unknownFields = []}
parseMessage
= let
loop ::
CompatibleBuildIdRedirectRule
-> Data.ProtoLens.Encoding.Bytes.Parser CompatibleBuildIdRedirectRule
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"source_build_id"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"sourceBuildId") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"target_build_id"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"targetBuildId") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "CompatibleBuildIdRedirectRule"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"sourceBuildId") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"targetBuildId") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData CompatibleBuildIdRedirectRule where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_CompatibleBuildIdRedirectRule'_unknownFields x__)
(Control.DeepSeq.deepseq
(_CompatibleBuildIdRedirectRule'sourceBuildId x__)
(Control.DeepSeq.deepseq
(_CompatibleBuildIdRedirectRule'targetBuildId x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.buildIds' @:: Lens' CompatibleVersionSet [Data.Text.Text]@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.vec'buildIds' @:: Lens' CompatibleVersionSet (Data.Vector.Vector Data.Text.Text)@ -}
data CompatibleVersionSet
= CompatibleVersionSet'_constructor {_CompatibleVersionSet'buildIds :: !(Data.Vector.Vector Data.Text.Text),
_CompatibleVersionSet'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show CompatibleVersionSet where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField CompatibleVersionSet "buildIds" [Data.Text.Text] where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_CompatibleVersionSet'buildIds
(\ x__ y__ -> x__ {_CompatibleVersionSet'buildIds = y__}))
(Lens.Family2.Unchecked.lens
Data.Vector.Generic.toList
(\ _ y__ -> Data.Vector.Generic.fromList y__))
instance Data.ProtoLens.Field.HasField CompatibleVersionSet "vec'buildIds" (Data.Vector.Vector Data.Text.Text) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_CompatibleVersionSet'buildIds
(\ x__ y__ -> x__ {_CompatibleVersionSet'buildIds = y__}))
Prelude.id
instance Data.ProtoLens.Message CompatibleVersionSet where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.CompatibleVersionSet"
packedMessageDescriptor _
= "\n\
\\DC4CompatibleVersionSet\DC2\ESC\n\
\\tbuild_ids\CAN\SOH \ETX(\tR\bbuildIds"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
buildIds__field_descriptor
= Data.ProtoLens.FieldDescriptor
"build_ids"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.RepeatedField
Data.ProtoLens.Unpacked
(Data.ProtoLens.Field.field @"buildIds")) ::
Data.ProtoLens.FieldDescriptor CompatibleVersionSet
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, buildIds__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_CompatibleVersionSet'_unknownFields
(\ x__ y__ -> x__ {_CompatibleVersionSet'_unknownFields = y__})
defMessage
= CompatibleVersionSet'_constructor
{_CompatibleVersionSet'buildIds = Data.Vector.Generic.empty,
_CompatibleVersionSet'_unknownFields = []}
parseMessage
= let
loop ::
CompatibleVersionSet
-> Data.ProtoLens.Encoding.Growing.Growing Data.Vector.Vector Data.ProtoLens.Encoding.Growing.RealWorld Data.Text.Text
-> Data.ProtoLens.Encoding.Bytes.Parser CompatibleVersionSet
loop x mutable'buildIds
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do frozen'buildIds <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.unsafeFreeze
mutable'buildIds)
(let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t)
(Lens.Family2.set
(Data.ProtoLens.Field.field @"vec'buildIds") frozen'buildIds x))
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do !y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"build_ids"
v <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.append mutable'buildIds y)
loop x v
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
mutable'buildIds
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do mutable'buildIds <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
Data.ProtoLens.Encoding.Growing.new
loop Data.ProtoLens.defMessage mutable'buildIds)
"CompatibleVersionSet"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.foldMapBuilder
(\ _v
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
(Lens.Family2.view
(Data.ProtoLens.Field.field @"vec'buildIds") _x))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))
instance Control.DeepSeq.NFData CompatibleVersionSet where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_CompatibleVersionSet'_unknownFields x__)
(Control.DeepSeq.deepseq (_CompatibleVersionSet'buildIds x__) ())
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.lastAccessTime' @:: Lens' PollerInfo Proto.Google.Protobuf.Timestamp.Timestamp@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'lastAccessTime' @:: Lens' PollerInfo (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.identity' @:: Lens' PollerInfo Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.ratePerSecond' @:: Lens' PollerInfo Prelude.Double@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.workerVersionCapabilities' @:: Lens' PollerInfo Proto.Temporal.Api.Common.V1.Message.WorkerVersionCapabilities@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'workerVersionCapabilities' @:: Lens' PollerInfo (Prelude.Maybe Proto.Temporal.Api.Common.V1.Message.WorkerVersionCapabilities)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.deploymentOptions' @:: Lens' PollerInfo Proto.Temporal.Api.Deployment.V1.Message.WorkerDeploymentOptions@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'deploymentOptions' @:: Lens' PollerInfo (Prelude.Maybe Proto.Temporal.Api.Deployment.V1.Message.WorkerDeploymentOptions)@ -}
data PollerInfo
= PollerInfo'_constructor {_PollerInfo'lastAccessTime :: !(Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp),
_PollerInfo'identity :: !Data.Text.Text,
_PollerInfo'ratePerSecond :: !Prelude.Double,
_PollerInfo'workerVersionCapabilities :: !(Prelude.Maybe Proto.Temporal.Api.Common.V1.Message.WorkerVersionCapabilities),
_PollerInfo'deploymentOptions :: !(Prelude.Maybe Proto.Temporal.Api.Deployment.V1.Message.WorkerDeploymentOptions),
_PollerInfo'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show PollerInfo where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField PollerInfo "lastAccessTime" Proto.Google.Protobuf.Timestamp.Timestamp where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'lastAccessTime
(\ x__ y__ -> x__ {_PollerInfo'lastAccessTime = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField PollerInfo "maybe'lastAccessTime" (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'lastAccessTime
(\ x__ y__ -> x__ {_PollerInfo'lastAccessTime = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField PollerInfo "identity" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'identity
(\ x__ y__ -> x__ {_PollerInfo'identity = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField PollerInfo "ratePerSecond" Prelude.Double where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'ratePerSecond
(\ x__ y__ -> x__ {_PollerInfo'ratePerSecond = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField PollerInfo "workerVersionCapabilities" Proto.Temporal.Api.Common.V1.Message.WorkerVersionCapabilities where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'workerVersionCapabilities
(\ x__ y__ -> x__ {_PollerInfo'workerVersionCapabilities = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField PollerInfo "maybe'workerVersionCapabilities" (Prelude.Maybe Proto.Temporal.Api.Common.V1.Message.WorkerVersionCapabilities) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'workerVersionCapabilities
(\ x__ y__ -> x__ {_PollerInfo'workerVersionCapabilities = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField PollerInfo "deploymentOptions" Proto.Temporal.Api.Deployment.V1.Message.WorkerDeploymentOptions where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'deploymentOptions
(\ x__ y__ -> x__ {_PollerInfo'deploymentOptions = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField PollerInfo "maybe'deploymentOptions" (Prelude.Maybe Proto.Temporal.Api.Deployment.V1.Message.WorkerDeploymentOptions) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerInfo'deploymentOptions
(\ x__ y__ -> x__ {_PollerInfo'deploymentOptions = y__}))
Prelude.id
instance Data.ProtoLens.Message PollerInfo where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.PollerInfo"
packedMessageDescriptor _
= "\n\
\\n\
\PollerInfo\DC2D\n\
\\DLElast_access_time\CAN\SOH \SOH(\v2\SUB.google.protobuf.TimestampR\SOlastAccessTime\DC2\SUB\n\
\\bidentity\CAN\STX \SOH(\tR\bidentity\DC2&\n\
\\SIrate_per_second\CAN\ETX \SOH(\SOHR\rratePerSecond\DC2u\n\
\\ESCworker_version_capabilities\CAN\EOT \SOH(\v21.temporal.api.common.v1.WorkerVersionCapabilitiesR\EMworkerVersionCapabilitiesB\STX\CAN\SOH\DC2b\n\
\\DC2deployment_options\CAN\ENQ \SOH(\v23.temporal.api.deployment.v1.WorkerDeploymentOptionsR\DC1deploymentOptions"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
lastAccessTime__field_descriptor
= Data.ProtoLens.FieldDescriptor
"last_access_time"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Timestamp.Timestamp)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'lastAccessTime")) ::
Data.ProtoLens.FieldDescriptor PollerInfo
identity__field_descriptor
= Data.ProtoLens.FieldDescriptor
"identity"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"identity")) ::
Data.ProtoLens.FieldDescriptor PollerInfo
ratePerSecond__field_descriptor
= Data.ProtoLens.FieldDescriptor
"rate_per_second"
(Data.ProtoLens.ScalarField Data.ProtoLens.DoubleField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Double)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"ratePerSecond")) ::
Data.ProtoLens.FieldDescriptor PollerInfo
workerVersionCapabilities__field_descriptor
= Data.ProtoLens.FieldDescriptor
"worker_version_capabilities"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Temporal.Api.Common.V1.Message.WorkerVersionCapabilities)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'workerVersionCapabilities")) ::
Data.ProtoLens.FieldDescriptor PollerInfo
deploymentOptions__field_descriptor
= Data.ProtoLens.FieldDescriptor
"deployment_options"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Temporal.Api.Deployment.V1.Message.WorkerDeploymentOptions)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'deploymentOptions")) ::
Data.ProtoLens.FieldDescriptor PollerInfo
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, lastAccessTime__field_descriptor),
(Data.ProtoLens.Tag 2, identity__field_descriptor),
(Data.ProtoLens.Tag 3, ratePerSecond__field_descriptor),
(Data.ProtoLens.Tag 4,
workerVersionCapabilities__field_descriptor),
(Data.ProtoLens.Tag 5, deploymentOptions__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_PollerInfo'_unknownFields
(\ x__ y__ -> x__ {_PollerInfo'_unknownFields = y__})
defMessage
= PollerInfo'_constructor
{_PollerInfo'lastAccessTime = Prelude.Nothing,
_PollerInfo'identity = Data.ProtoLens.fieldDefault,
_PollerInfo'ratePerSecond = Data.ProtoLens.fieldDefault,
_PollerInfo'workerVersionCapabilities = Prelude.Nothing,
_PollerInfo'deploymentOptions = Prelude.Nothing,
_PollerInfo'_unknownFields = []}
parseMessage
= let
loop ::
PollerInfo -> Data.ProtoLens.Encoding.Bytes.Parser PollerInfo
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"last_access_time"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"lastAccessTime") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"identity"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"identity") y x)
25
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Data.ProtoLens.Encoding.Bytes.wordToDouble
Data.ProtoLens.Encoding.Bytes.getFixed64)
"rate_per_second"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"ratePerSecond") y x)
34
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"worker_version_capabilities"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"workerVersionCapabilities") y x)
42
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"deployment_options"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"deploymentOptions") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "PollerInfo"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'lastAccessTime") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
((Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"identity") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"ratePerSecond") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 25)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putFixed64
Data.ProtoLens.Encoding.Bytes.doubleToWord _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'workerVersionCapabilities") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 34)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'deploymentOptions") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 42)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))))))
instance Control.DeepSeq.NFData PollerInfo where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_PollerInfo'_unknownFields x__)
(Control.DeepSeq.deepseq
(_PollerInfo'lastAccessTime x__)
(Control.DeepSeq.deepseq
(_PollerInfo'identity x__)
(Control.DeepSeq.deepseq
(_PollerInfo'ratePerSecond x__)
(Control.DeepSeq.deepseq
(_PollerInfo'workerVersionCapabilities x__)
(Control.DeepSeq.deepseq
(_PollerInfo'deploymentOptions x__) ())))))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.pollRequestDeltaSuggestion' @:: Lens' PollerScalingDecision Data.Int.Int32@ -}
data PollerScalingDecision
= PollerScalingDecision'_constructor {_PollerScalingDecision'pollRequestDeltaSuggestion :: !Data.Int.Int32,
_PollerScalingDecision'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show PollerScalingDecision where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField PollerScalingDecision "pollRequestDeltaSuggestion" Data.Int.Int32 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_PollerScalingDecision'pollRequestDeltaSuggestion
(\ x__ y__
-> x__ {_PollerScalingDecision'pollRequestDeltaSuggestion = y__}))
Prelude.id
instance Data.ProtoLens.Message PollerScalingDecision where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.PollerScalingDecision"
packedMessageDescriptor _
= "\n\
\\NAKPollerScalingDecision\DC2A\n\
\\GSpoll_request_delta_suggestion\CAN\SOH \SOH(\ENQR\SUBpollRequestDeltaSuggestion"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
pollRequestDeltaSuggestion__field_descriptor
= Data.ProtoLens.FieldDescriptor
"poll_request_delta_suggestion"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int32Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int32)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"pollRequestDeltaSuggestion")) ::
Data.ProtoLens.FieldDescriptor PollerScalingDecision
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1,
pollRequestDeltaSuggestion__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_PollerScalingDecision'_unknownFields
(\ x__ y__ -> x__ {_PollerScalingDecision'_unknownFields = y__})
defMessage
= PollerScalingDecision'_constructor
{_PollerScalingDecision'pollRequestDeltaSuggestion = Data.ProtoLens.fieldDefault,
_PollerScalingDecision'_unknownFields = []}
parseMessage
= let
loop ::
PollerScalingDecision
-> Data.ProtoLens.Encoding.Bytes.Parser PollerScalingDecision
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
8 -> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"poll_request_delta_suggestion"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"pollRequestDeltaSuggestion") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "PollerScalingDecision"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"pollRequestDeltaSuggestion") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 8)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))
instance Control.DeepSeq.NFData PollerScalingDecision where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_PollerScalingDecision'_unknownFields x__)
(Control.DeepSeq.deepseq
(_PollerScalingDecision'pollRequestDeltaSuggestion x__) ())
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.rampPercentage' @:: Lens' RampByPercentage Prelude.Float@ -}
data RampByPercentage
= RampByPercentage'_constructor {_RampByPercentage'rampPercentage :: !Prelude.Float,
_RampByPercentage'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show RampByPercentage where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField RampByPercentage "rampPercentage" Prelude.Float where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_RampByPercentage'rampPercentage
(\ x__ y__ -> x__ {_RampByPercentage'rampPercentage = y__}))
Prelude.id
instance Data.ProtoLens.Message RampByPercentage where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.RampByPercentage"
packedMessageDescriptor _
= "\n\
\\DLERampByPercentage\DC2'\n\
\\SIramp_percentage\CAN\SOH \SOH(\STXR\SOrampPercentage"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
rampPercentage__field_descriptor
= Data.ProtoLens.FieldDescriptor
"ramp_percentage"
(Data.ProtoLens.ScalarField Data.ProtoLens.FloatField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Float)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"rampPercentage")) ::
Data.ProtoLens.FieldDescriptor RampByPercentage
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, rampPercentage__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_RampByPercentage'_unknownFields
(\ x__ y__ -> x__ {_RampByPercentage'_unknownFields = y__})
defMessage
= RampByPercentage'_constructor
{_RampByPercentage'rampPercentage = Data.ProtoLens.fieldDefault,
_RampByPercentage'_unknownFields = []}
parseMessage
= let
loop ::
RampByPercentage
-> Data.ProtoLens.Encoding.Bytes.Parser RampByPercentage
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
13
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Data.ProtoLens.Encoding.Bytes.wordToFloat
Data.ProtoLens.Encoding.Bytes.getFixed32)
"ramp_percentage"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"rampPercentage") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "RampByPercentage"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"rampPercentage") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 13)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putFixed32
Data.ProtoLens.Encoding.Bytes.floatToWord _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))
instance Control.DeepSeq.NFData RampByPercentage where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_RampByPercentage'_unknownFields x__)
(Control.DeepSeq.deepseq (_RampByPercentage'rampPercentage x__) ())
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.workerTaskQueue' @:: Lens' StickyExecutionAttributes TaskQueue@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'workerTaskQueue' @:: Lens' StickyExecutionAttributes (Prelude.Maybe TaskQueue)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.scheduleToStartTimeout' @:: Lens' StickyExecutionAttributes Proto.Google.Protobuf.Duration.Duration@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'scheduleToStartTimeout' @:: Lens' StickyExecutionAttributes (Prelude.Maybe Proto.Google.Protobuf.Duration.Duration)@ -}
data StickyExecutionAttributes
= StickyExecutionAttributes'_constructor {_StickyExecutionAttributes'workerTaskQueue :: !(Prelude.Maybe TaskQueue),
_StickyExecutionAttributes'scheduleToStartTimeout :: !(Prelude.Maybe Proto.Google.Protobuf.Duration.Duration),
_StickyExecutionAttributes'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show StickyExecutionAttributes where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField StickyExecutionAttributes "workerTaskQueue" TaskQueue where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_StickyExecutionAttributes'workerTaskQueue
(\ x__ y__
-> x__ {_StickyExecutionAttributes'workerTaskQueue = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField StickyExecutionAttributes "maybe'workerTaskQueue" (Prelude.Maybe TaskQueue) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_StickyExecutionAttributes'workerTaskQueue
(\ x__ y__
-> x__ {_StickyExecutionAttributes'workerTaskQueue = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField StickyExecutionAttributes "scheduleToStartTimeout" Proto.Google.Protobuf.Duration.Duration where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_StickyExecutionAttributes'scheduleToStartTimeout
(\ x__ y__
-> x__ {_StickyExecutionAttributes'scheduleToStartTimeout = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField StickyExecutionAttributes "maybe'scheduleToStartTimeout" (Prelude.Maybe Proto.Google.Protobuf.Duration.Duration) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_StickyExecutionAttributes'scheduleToStartTimeout
(\ x__ y__
-> x__ {_StickyExecutionAttributes'scheduleToStartTimeout = y__}))
Prelude.id
instance Data.ProtoLens.Message StickyExecutionAttributes where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.StickyExecutionAttributes"
packedMessageDescriptor _
= "\n\
\\EMStickyExecutionAttributes\DC2P\n\
\\DC1worker_task_queue\CAN\SOH \SOH(\v2$.temporal.api.taskqueue.v1.TaskQueueR\SIworkerTaskQueue\DC2T\n\
\\EMschedule_to_start_timeout\CAN\STX \SOH(\v2\EM.google.protobuf.DurationR\SYNscheduleToStartTimeout"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
workerTaskQueue__field_descriptor
= Data.ProtoLens.FieldDescriptor
"worker_task_queue"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor TaskQueue)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'workerTaskQueue")) ::
Data.ProtoLens.FieldDescriptor StickyExecutionAttributes
scheduleToStartTimeout__field_descriptor
= Data.ProtoLens.FieldDescriptor
"schedule_to_start_timeout"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Duration.Duration)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'scheduleToStartTimeout")) ::
Data.ProtoLens.FieldDescriptor StickyExecutionAttributes
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, workerTaskQueue__field_descriptor),
(Data.ProtoLens.Tag 2, scheduleToStartTimeout__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_StickyExecutionAttributes'_unknownFields
(\ x__ y__
-> x__ {_StickyExecutionAttributes'_unknownFields = y__})
defMessage
= StickyExecutionAttributes'_constructor
{_StickyExecutionAttributes'workerTaskQueue = Prelude.Nothing,
_StickyExecutionAttributes'scheduleToStartTimeout = Prelude.Nothing,
_StickyExecutionAttributes'_unknownFields = []}
parseMessage
= let
loop ::
StickyExecutionAttributes
-> Data.ProtoLens.Encoding.Bytes.Parser StickyExecutionAttributes
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"worker_task_queue"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"workerTaskQueue") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"schedule_to_start_timeout"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"scheduleToStartTimeout") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "StickyExecutionAttributes"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'workerTaskQueue") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'scheduleToStartTimeout") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData StickyExecutionAttributes where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_StickyExecutionAttributes'_unknownFields x__)
(Control.DeepSeq.deepseq
(_StickyExecutionAttributes'workerTaskQueue x__)
(Control.DeepSeq.deepseq
(_StickyExecutionAttributes'scheduleToStartTimeout x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.startId' @:: Lens' TaskIdBlock Data.Int.Int64@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.endId' @:: Lens' TaskIdBlock Data.Int.Int64@ -}
data TaskIdBlock
= TaskIdBlock'_constructor {_TaskIdBlock'startId :: !Data.Int.Int64,
_TaskIdBlock'endId :: !Data.Int.Int64,
_TaskIdBlock'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskIdBlock where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskIdBlock "startId" Data.Int.Int64 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskIdBlock'startId
(\ x__ y__ -> x__ {_TaskIdBlock'startId = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskIdBlock "endId" Data.Int.Int64 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskIdBlock'endId (\ x__ y__ -> x__ {_TaskIdBlock'endId = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskIdBlock where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskIdBlock"
packedMessageDescriptor _
= "\n\
\\vTaskIdBlock\DC2\EM\n\
\\bstart_id\CAN\SOH \SOH(\ETXR\astartId\DC2\NAK\n\
\\ACKend_id\CAN\STX \SOH(\ETXR\ENQendId"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
startId__field_descriptor
= Data.ProtoLens.FieldDescriptor
"start_id"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int64Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int64)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"startId")) ::
Data.ProtoLens.FieldDescriptor TaskIdBlock
endId__field_descriptor
= Data.ProtoLens.FieldDescriptor
"end_id"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int64Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int64)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"endId")) ::
Data.ProtoLens.FieldDescriptor TaskIdBlock
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, startId__field_descriptor),
(Data.ProtoLens.Tag 2, endId__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskIdBlock'_unknownFields
(\ x__ y__ -> x__ {_TaskIdBlock'_unknownFields = y__})
defMessage
= TaskIdBlock'_constructor
{_TaskIdBlock'startId = Data.ProtoLens.fieldDefault,
_TaskIdBlock'endId = Data.ProtoLens.fieldDefault,
_TaskIdBlock'_unknownFields = []}
parseMessage
= let
loop ::
TaskIdBlock -> Data.ProtoLens.Encoding.Bytes.Parser TaskIdBlock
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
8 -> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"start_id"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"startId") y x)
16
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"end_id"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"endId") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskIdBlock"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"startId") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 8)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
((Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"endId") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 16)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TaskIdBlock where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskIdBlock'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskIdBlock'startId x__)
(Control.DeepSeq.deepseq (_TaskIdBlock'endId x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.name' @:: Lens' TaskQueue Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.kind' @:: Lens' TaskQueue Proto.Temporal.Api.Enums.V1.TaskQueue.TaskQueueKind@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.normalName' @:: Lens' TaskQueue Data.Text.Text@ -}
data TaskQueue
= TaskQueue'_constructor {_TaskQueue'name :: !Data.Text.Text,
_TaskQueue'kind :: !Proto.Temporal.Api.Enums.V1.TaskQueue.TaskQueueKind,
_TaskQueue'normalName :: !Data.Text.Text,
_TaskQueue'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueue where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueue "name" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueue'name (\ x__ y__ -> x__ {_TaskQueue'name = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueue "kind" Proto.Temporal.Api.Enums.V1.TaskQueue.TaskQueueKind where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueue'kind (\ x__ y__ -> x__ {_TaskQueue'kind = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueue "normalName" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueue'normalName
(\ x__ y__ -> x__ {_TaskQueue'normalName = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueue where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueue"
packedMessageDescriptor _
= "\n\
\\tTaskQueue\DC2\DC2\n\
\\EOTname\CAN\SOH \SOH(\tR\EOTname\DC28\n\
\\EOTkind\CAN\STX \SOH(\SO2$.temporal.api.enums.v1.TaskQueueKindR\EOTkind\DC2\US\n\
\\vnormal_name\CAN\ETX \SOH(\tR\n\
\normalName"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
name__field_descriptor
= Data.ProtoLens.FieldDescriptor
"name"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"name")) ::
Data.ProtoLens.FieldDescriptor TaskQueue
kind__field_descriptor
= Data.ProtoLens.FieldDescriptor
"kind"
(Data.ProtoLens.ScalarField Data.ProtoLens.EnumField ::
Data.ProtoLens.FieldTypeDescriptor Proto.Temporal.Api.Enums.V1.TaskQueue.TaskQueueKind)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"kind")) ::
Data.ProtoLens.FieldDescriptor TaskQueue
normalName__field_descriptor
= Data.ProtoLens.FieldDescriptor
"normal_name"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"normalName")) ::
Data.ProtoLens.FieldDescriptor TaskQueue
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, name__field_descriptor),
(Data.ProtoLens.Tag 2, kind__field_descriptor),
(Data.ProtoLens.Tag 3, normalName__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueue'_unknownFields
(\ x__ y__ -> x__ {_TaskQueue'_unknownFields = y__})
defMessage
= TaskQueue'_constructor
{_TaskQueue'name = Data.ProtoLens.fieldDefault,
_TaskQueue'kind = Data.ProtoLens.fieldDefault,
_TaskQueue'normalName = Data.ProtoLens.fieldDefault,
_TaskQueue'_unknownFields = []}
parseMessage
= let
loop :: TaskQueue -> Data.ProtoLens.Encoding.Bytes.Parser TaskQueue
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"name"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"name") y x)
16
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.toEnum
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt))
"kind"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"kind") y x)
26
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"normal_name"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"normalName") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueue"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let _v = Lens.Family2.view (Data.ProtoLens.Field.field @"name") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let _v = Lens.Family2.view (Data.ProtoLens.Field.field @"kind") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 16)
((Prelude..)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral)
Prelude.fromEnum _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view (Data.ProtoLens.Field.field @"normalName") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 26)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))))
instance Control.DeepSeq.NFData TaskQueue where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueue'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueue'name x__)
(Control.DeepSeq.deepseq
(_TaskQueue'kind x__)
(Control.DeepSeq.deepseq (_TaskQueue'normalName x__) ())))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maxTasksPerSecond' @:: Lens' TaskQueueMetadata Proto.Google.Protobuf.Wrappers.DoubleValue@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'maxTasksPerSecond' @:: Lens' TaskQueueMetadata (Prelude.Maybe Proto.Google.Protobuf.Wrappers.DoubleValue)@ -}
data TaskQueueMetadata
= TaskQueueMetadata'_constructor {_TaskQueueMetadata'maxTasksPerSecond :: !(Prelude.Maybe Proto.Google.Protobuf.Wrappers.DoubleValue),
_TaskQueueMetadata'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueMetadata where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueMetadata "maxTasksPerSecond" Proto.Google.Protobuf.Wrappers.DoubleValue where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueMetadata'maxTasksPerSecond
(\ x__ y__ -> x__ {_TaskQueueMetadata'maxTasksPerSecond = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TaskQueueMetadata "maybe'maxTasksPerSecond" (Prelude.Maybe Proto.Google.Protobuf.Wrappers.DoubleValue) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueMetadata'maxTasksPerSecond
(\ x__ y__ -> x__ {_TaskQueueMetadata'maxTasksPerSecond = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueMetadata where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueueMetadata"
packedMessageDescriptor _
= "\n\
\\DC1TaskQueueMetadata\DC2M\n\
\\DC4max_tasks_per_second\CAN\SOH \SOH(\v2\FS.google.protobuf.DoubleValueR\DC1maxTasksPerSecond"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
maxTasksPerSecond__field_descriptor
= Data.ProtoLens.FieldDescriptor
"max_tasks_per_second"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Wrappers.DoubleValue)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'maxTasksPerSecond")) ::
Data.ProtoLens.FieldDescriptor TaskQueueMetadata
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, maxTasksPerSecond__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueMetadata'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueMetadata'_unknownFields = y__})
defMessage
= TaskQueueMetadata'_constructor
{_TaskQueueMetadata'maxTasksPerSecond = Prelude.Nothing,
_TaskQueueMetadata'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueMetadata
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueMetadata
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"max_tasks_per_second"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"maxTasksPerSecond") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueueMetadata"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'maxTasksPerSecond") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))
instance Control.DeepSeq.NFData TaskQueueMetadata where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueMetadata'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueMetadata'maxTasksPerSecond x__) ())
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.key' @:: Lens' TaskQueuePartitionMetadata Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.ownerHostName' @:: Lens' TaskQueuePartitionMetadata Data.Text.Text@ -}
data TaskQueuePartitionMetadata
= TaskQueuePartitionMetadata'_constructor {_TaskQueuePartitionMetadata'key :: !Data.Text.Text,
_TaskQueuePartitionMetadata'ownerHostName :: !Data.Text.Text,
_TaskQueuePartitionMetadata'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueuePartitionMetadata where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueuePartitionMetadata "key" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueuePartitionMetadata'key
(\ x__ y__ -> x__ {_TaskQueuePartitionMetadata'key = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueuePartitionMetadata "ownerHostName" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueuePartitionMetadata'ownerHostName
(\ x__ y__
-> x__ {_TaskQueuePartitionMetadata'ownerHostName = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueuePartitionMetadata where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.TaskQueuePartitionMetadata"
packedMessageDescriptor _
= "\n\
\\SUBTaskQueuePartitionMetadata\DC2\DLE\n\
\\ETXkey\CAN\SOH \SOH(\tR\ETXkey\DC2&\n\
\\SIowner_host_name\CAN\STX \SOH(\tR\rownerHostName"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
key__field_descriptor
= Data.ProtoLens.FieldDescriptor
"key"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"key")) ::
Data.ProtoLens.FieldDescriptor TaskQueuePartitionMetadata
ownerHostName__field_descriptor
= Data.ProtoLens.FieldDescriptor
"owner_host_name"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"ownerHostName")) ::
Data.ProtoLens.FieldDescriptor TaskQueuePartitionMetadata
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, key__field_descriptor),
(Data.ProtoLens.Tag 2, ownerHostName__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueuePartitionMetadata'_unknownFields
(\ x__ y__
-> x__ {_TaskQueuePartitionMetadata'_unknownFields = y__})
defMessage
= TaskQueuePartitionMetadata'_constructor
{_TaskQueuePartitionMetadata'key = Data.ProtoLens.fieldDefault,
_TaskQueuePartitionMetadata'ownerHostName = Data.ProtoLens.fieldDefault,
_TaskQueuePartitionMetadata'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueuePartitionMetadata
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueuePartitionMetadata
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"key"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"key") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"owner_host_name"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"ownerHostName") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueuePartitionMetadata"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let _v = Lens.Family2.view (Data.ProtoLens.Field.field @"key") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"ownerHostName") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TaskQueuePartitionMetadata where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueuePartitionMetadata'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueuePartitionMetadata'key x__)
(Control.DeepSeq.deepseq
(_TaskQueuePartitionMetadata'ownerHostName x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.taskQueue' @:: Lens' TaskQueueReachability Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.reachability' @:: Lens' TaskQueueReachability [Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability]@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.vec'reachability' @:: Lens' TaskQueueReachability (Data.Vector.Vector Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability)@ -}
data TaskQueueReachability
= TaskQueueReachability'_constructor {_TaskQueueReachability'taskQueue :: !Data.Text.Text,
_TaskQueueReachability'reachability :: !(Data.Vector.Vector Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability),
_TaskQueueReachability'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueReachability where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueReachability "taskQueue" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueReachability'taskQueue
(\ x__ y__ -> x__ {_TaskQueueReachability'taskQueue = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueReachability "reachability" [Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability] where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueReachability'reachability
(\ x__ y__ -> x__ {_TaskQueueReachability'reachability = y__}))
(Lens.Family2.Unchecked.lens
Data.Vector.Generic.toList
(\ _ y__ -> Data.Vector.Generic.fromList y__))
instance Data.ProtoLens.Field.HasField TaskQueueReachability "vec'reachability" (Data.Vector.Vector Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueReachability'reachability
(\ x__ y__ -> x__ {_TaskQueueReachability'reachability = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueReachability where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueueReachability"
packedMessageDescriptor _
= "\n\
\\NAKTaskQueueReachability\DC2\GS\n\
\\n\
\task_queue\CAN\SOH \SOH(\tR\ttaskQueue\DC2K\n\
\\freachability\CAN\STX \ETX(\SO2'.temporal.api.enums.v1.TaskReachabilityR\freachability"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
taskQueue__field_descriptor
= Data.ProtoLens.FieldDescriptor
"task_queue"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"taskQueue")) ::
Data.ProtoLens.FieldDescriptor TaskQueueReachability
reachability__field_descriptor
= Data.ProtoLens.FieldDescriptor
"reachability"
(Data.ProtoLens.ScalarField Data.ProtoLens.EnumField ::
Data.ProtoLens.FieldTypeDescriptor Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability)
(Data.ProtoLens.RepeatedField
Data.ProtoLens.Packed
(Data.ProtoLens.Field.field @"reachability")) ::
Data.ProtoLens.FieldDescriptor TaskQueueReachability
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, taskQueue__field_descriptor),
(Data.ProtoLens.Tag 2, reachability__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueReachability'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueReachability'_unknownFields = y__})
defMessage
= TaskQueueReachability'_constructor
{_TaskQueueReachability'taskQueue = Data.ProtoLens.fieldDefault,
_TaskQueueReachability'reachability = Data.Vector.Generic.empty,
_TaskQueueReachability'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueReachability
-> Data.ProtoLens.Encoding.Growing.Growing Data.Vector.Vector Data.ProtoLens.Encoding.Growing.RealWorld Proto.Temporal.Api.Enums.V1.TaskQueue.TaskReachability
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueReachability
loop x mutable'reachability
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do frozen'reachability <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.unsafeFreeze
mutable'reachability)
(let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t)
(Lens.Family2.set
(Data.ProtoLens.Field.field @"vec'reachability")
frozen'reachability x))
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"task_queue"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"taskQueue") y x)
mutable'reachability
16
-> do !y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.toEnum
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt))
"reachability"
v <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.append
mutable'reachability y)
loop x v
18
-> do y <- do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len)
((let
ploop qs
= do packedEnd <- Data.ProtoLens.Encoding.Bytes.atEnd
if packedEnd then
Prelude.return qs
else
do !q <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.toEnum
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt))
"reachability"
qs' <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.append
qs q)
ploop qs'
in ploop)
mutable'reachability)
loop x y
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
mutable'reachability
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do mutable'reachability <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
Data.ProtoLens.Encoding.Growing.new
loop Data.ProtoLens.defMessage mutable'reachability)
"TaskQueueReachability"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"taskQueue") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let
p = Lens.Family2.view
(Data.ProtoLens.Field.field @"vec'reachability") _x
in
if Data.Vector.Generic.null p then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
(Data.ProtoLens.Encoding.Bytes.runBuilder
(Data.ProtoLens.Encoding.Bytes.foldMapBuilder
((Prelude..)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt
Prelude.fromIntegral)
Prelude.fromEnum)
p))))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TaskQueueReachability where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueReachability'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueReachability'taskQueue x__)
(Control.DeepSeq.deepseq
(_TaskQueueReachability'reachability x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.approximateBacklogCount' @:: Lens' TaskQueueStats Data.Int.Int64@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.approximateBacklogAge' @:: Lens' TaskQueueStats Proto.Google.Protobuf.Duration.Duration@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'approximateBacklogAge' @:: Lens' TaskQueueStats (Prelude.Maybe Proto.Google.Protobuf.Duration.Duration)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.tasksAddRate' @:: Lens' TaskQueueStats Prelude.Float@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.tasksDispatchRate' @:: Lens' TaskQueueStats Prelude.Float@ -}
data TaskQueueStats
= TaskQueueStats'_constructor {_TaskQueueStats'approximateBacklogCount :: !Data.Int.Int64,
_TaskQueueStats'approximateBacklogAge :: !(Prelude.Maybe Proto.Google.Protobuf.Duration.Duration),
_TaskQueueStats'tasksAddRate :: !Prelude.Float,
_TaskQueueStats'tasksDispatchRate :: !Prelude.Float,
_TaskQueueStats'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueStats where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueStats "approximateBacklogCount" Data.Int.Int64 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStats'approximateBacklogCount
(\ x__ y__ -> x__ {_TaskQueueStats'approximateBacklogCount = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStats "approximateBacklogAge" Proto.Google.Protobuf.Duration.Duration where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStats'approximateBacklogAge
(\ x__ y__ -> x__ {_TaskQueueStats'approximateBacklogAge = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TaskQueueStats "maybe'approximateBacklogAge" (Prelude.Maybe Proto.Google.Protobuf.Duration.Duration) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStats'approximateBacklogAge
(\ x__ y__ -> x__ {_TaskQueueStats'approximateBacklogAge = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStats "tasksAddRate" Prelude.Float where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStats'tasksAddRate
(\ x__ y__ -> x__ {_TaskQueueStats'tasksAddRate = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStats "tasksDispatchRate" Prelude.Float where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStats'tasksDispatchRate
(\ x__ y__ -> x__ {_TaskQueueStats'tasksDispatchRate = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueStats where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueueStats"
packedMessageDescriptor _
= "\n\
\\SOTaskQueueStats\DC2:\n\
\\EMapproximate_backlog_count\CAN\SOH \SOH(\ETXR\ETBapproximateBacklogCount\DC2Q\n\
\\ETBapproximate_backlog_age\CAN\STX \SOH(\v2\EM.google.protobuf.DurationR\NAKapproximateBacklogAge\DC2$\n\
\\SOtasks_add_rate\CAN\ETX \SOH(\STXR\ftasksAddRate\DC2.\n\
\\DC3tasks_dispatch_rate\CAN\EOT \SOH(\STXR\DC1tasksDispatchRate"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
approximateBacklogCount__field_descriptor
= Data.ProtoLens.FieldDescriptor
"approximate_backlog_count"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int64Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int64)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"approximateBacklogCount")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStats
approximateBacklogAge__field_descriptor
= Data.ProtoLens.FieldDescriptor
"approximate_backlog_age"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Duration.Duration)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'approximateBacklogAge")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStats
tasksAddRate__field_descriptor
= Data.ProtoLens.FieldDescriptor
"tasks_add_rate"
(Data.ProtoLens.ScalarField Data.ProtoLens.FloatField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Float)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"tasksAddRate")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStats
tasksDispatchRate__field_descriptor
= Data.ProtoLens.FieldDescriptor
"tasks_dispatch_rate"
(Data.ProtoLens.ScalarField Data.ProtoLens.FloatField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Float)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"tasksDispatchRate")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStats
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, approximateBacklogCount__field_descriptor),
(Data.ProtoLens.Tag 2, approximateBacklogAge__field_descriptor),
(Data.ProtoLens.Tag 3, tasksAddRate__field_descriptor),
(Data.ProtoLens.Tag 4, tasksDispatchRate__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueStats'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueStats'_unknownFields = y__})
defMessage
= TaskQueueStats'_constructor
{_TaskQueueStats'approximateBacklogCount = Data.ProtoLens.fieldDefault,
_TaskQueueStats'approximateBacklogAge = Prelude.Nothing,
_TaskQueueStats'tasksAddRate = Data.ProtoLens.fieldDefault,
_TaskQueueStats'tasksDispatchRate = Data.ProtoLens.fieldDefault,
_TaskQueueStats'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueStats
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueStats
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
8 -> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"approximate_backlog_count"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"approximateBacklogCount") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"approximate_backlog_age"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"approximateBacklogAge") y x)
29
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Data.ProtoLens.Encoding.Bytes.wordToFloat
Data.ProtoLens.Encoding.Bytes.getFixed32)
"tasks_add_rate"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"tasksAddRate") y x)
37
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Data.ProtoLens.Encoding.Bytes.wordToFloat
Data.ProtoLens.Encoding.Bytes.getFixed32)
"tasks_dispatch_rate"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"tasksDispatchRate") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueueStats"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"approximateBacklogCount") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 8)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'approximateBacklogAge") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view (Data.ProtoLens.Field.field @"tasksAddRate") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 29)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putFixed32
Data.ProtoLens.Encoding.Bytes.floatToWord _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"tasksDispatchRate") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 37)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putFixed32
Data.ProtoLens.Encoding.Bytes.floatToWord _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))))
instance Control.DeepSeq.NFData TaskQueueStats where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueStats'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueStats'approximateBacklogCount x__)
(Control.DeepSeq.deepseq
(_TaskQueueStats'approximateBacklogAge x__)
(Control.DeepSeq.deepseq
(_TaskQueueStats'tasksAddRate x__)
(Control.DeepSeq.deepseq
(_TaskQueueStats'tasksDispatchRate x__) ()))))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.backlogCountHint' @:: Lens' TaskQueueStatus Data.Int.Int64@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.readLevel' @:: Lens' TaskQueueStatus Data.Int.Int64@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.ackLevel' @:: Lens' TaskQueueStatus Data.Int.Int64@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.ratePerSecond' @:: Lens' TaskQueueStatus Prelude.Double@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.taskIdBlock' @:: Lens' TaskQueueStatus TaskIdBlock@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'taskIdBlock' @:: Lens' TaskQueueStatus (Prelude.Maybe TaskIdBlock)@ -}
data TaskQueueStatus
= TaskQueueStatus'_constructor {_TaskQueueStatus'backlogCountHint :: !Data.Int.Int64,
_TaskQueueStatus'readLevel :: !Data.Int.Int64,
_TaskQueueStatus'ackLevel :: !Data.Int.Int64,
_TaskQueueStatus'ratePerSecond :: !Prelude.Double,
_TaskQueueStatus'taskIdBlock :: !(Prelude.Maybe TaskIdBlock),
_TaskQueueStatus'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueStatus where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueStatus "backlogCountHint" Data.Int.Int64 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStatus'backlogCountHint
(\ x__ y__ -> x__ {_TaskQueueStatus'backlogCountHint = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStatus "readLevel" Data.Int.Int64 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStatus'readLevel
(\ x__ y__ -> x__ {_TaskQueueStatus'readLevel = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStatus "ackLevel" Data.Int.Int64 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStatus'ackLevel
(\ x__ y__ -> x__ {_TaskQueueStatus'ackLevel = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStatus "ratePerSecond" Prelude.Double where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStatus'ratePerSecond
(\ x__ y__ -> x__ {_TaskQueueStatus'ratePerSecond = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueStatus "taskIdBlock" TaskIdBlock where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStatus'taskIdBlock
(\ x__ y__ -> x__ {_TaskQueueStatus'taskIdBlock = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TaskQueueStatus "maybe'taskIdBlock" (Prelude.Maybe TaskIdBlock) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueStatus'taskIdBlock
(\ x__ y__ -> x__ {_TaskQueueStatus'taskIdBlock = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueStatus where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueueStatus"
packedMessageDescriptor _
= "\n\
\\SITaskQueueStatus\DC2,\n\
\\DC2backlog_count_hint\CAN\SOH \SOH(\ETXR\DLEbacklogCountHint\DC2\GS\n\
\\n\
\read_level\CAN\STX \SOH(\ETXR\treadLevel\DC2\ESC\n\
\\tack_level\CAN\ETX \SOH(\ETXR\backLevel\DC2&\n\
\\SIrate_per_second\CAN\EOT \SOH(\SOHR\rratePerSecond\DC2J\n\
\\rtask_id_block\CAN\ENQ \SOH(\v2&.temporal.api.taskqueue.v1.TaskIdBlockR\vtaskIdBlock"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
backlogCountHint__field_descriptor
= Data.ProtoLens.FieldDescriptor
"backlog_count_hint"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int64Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int64)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"backlogCountHint")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStatus
readLevel__field_descriptor
= Data.ProtoLens.FieldDescriptor
"read_level"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int64Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int64)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"readLevel")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStatus
ackLevel__field_descriptor
= Data.ProtoLens.FieldDescriptor
"ack_level"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int64Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int64)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"ackLevel")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStatus
ratePerSecond__field_descriptor
= Data.ProtoLens.FieldDescriptor
"rate_per_second"
(Data.ProtoLens.ScalarField Data.ProtoLens.DoubleField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Double)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"ratePerSecond")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStatus
taskIdBlock__field_descriptor
= Data.ProtoLens.FieldDescriptor
"task_id_block"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor TaskIdBlock)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'taskIdBlock")) ::
Data.ProtoLens.FieldDescriptor TaskQueueStatus
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, backlogCountHint__field_descriptor),
(Data.ProtoLens.Tag 2, readLevel__field_descriptor),
(Data.ProtoLens.Tag 3, ackLevel__field_descriptor),
(Data.ProtoLens.Tag 4, ratePerSecond__field_descriptor),
(Data.ProtoLens.Tag 5, taskIdBlock__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueStatus'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueStatus'_unknownFields = y__})
defMessage
= TaskQueueStatus'_constructor
{_TaskQueueStatus'backlogCountHint = Data.ProtoLens.fieldDefault,
_TaskQueueStatus'readLevel = Data.ProtoLens.fieldDefault,
_TaskQueueStatus'ackLevel = Data.ProtoLens.fieldDefault,
_TaskQueueStatus'ratePerSecond = Data.ProtoLens.fieldDefault,
_TaskQueueStatus'taskIdBlock = Prelude.Nothing,
_TaskQueueStatus'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueStatus
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueStatus
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
8 -> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"backlog_count_hint"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"backlogCountHint") y x)
16
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"read_level"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"readLevel") y x)
24
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"ack_level"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"ackLevel") y x)
33
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Data.ProtoLens.Encoding.Bytes.wordToDouble
Data.ProtoLens.Encoding.Bytes.getFixed64)
"rate_per_second"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"ratePerSecond") y x)
42
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"task_id_block"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"taskIdBlock") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueueStatus"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"backlogCountHint") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 8)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
((Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"readLevel") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 16)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
((Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"ackLevel") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 24)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"ratePerSecond") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 33)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putFixed64
Data.ProtoLens.Encoding.Bytes.doubleToWord _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'taskIdBlock") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 42)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))))))
instance Control.DeepSeq.NFData TaskQueueStatus where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueStatus'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueStatus'backlogCountHint x__)
(Control.DeepSeq.deepseq
(_TaskQueueStatus'readLevel x__)
(Control.DeepSeq.deepseq
(_TaskQueueStatus'ackLevel x__)
(Control.DeepSeq.deepseq
(_TaskQueueStatus'ratePerSecond x__)
(Control.DeepSeq.deepseq (_TaskQueueStatus'taskIdBlock x__) ())))))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.pollers' @:: Lens' TaskQueueTypeInfo [PollerInfo]@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.vec'pollers' @:: Lens' TaskQueueTypeInfo (Data.Vector.Vector PollerInfo)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.stats' @:: Lens' TaskQueueTypeInfo TaskQueueStats@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'stats' @:: Lens' TaskQueueTypeInfo (Prelude.Maybe TaskQueueStats)@ -}
data TaskQueueTypeInfo
= TaskQueueTypeInfo'_constructor {_TaskQueueTypeInfo'pollers :: !(Data.Vector.Vector PollerInfo),
_TaskQueueTypeInfo'stats :: !(Prelude.Maybe TaskQueueStats),
_TaskQueueTypeInfo'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueTypeInfo where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueTypeInfo "pollers" [PollerInfo] where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueTypeInfo'pollers
(\ x__ y__ -> x__ {_TaskQueueTypeInfo'pollers = y__}))
(Lens.Family2.Unchecked.lens
Data.Vector.Generic.toList
(\ _ y__ -> Data.Vector.Generic.fromList y__))
instance Data.ProtoLens.Field.HasField TaskQueueTypeInfo "vec'pollers" (Data.Vector.Vector PollerInfo) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueTypeInfo'pollers
(\ x__ y__ -> x__ {_TaskQueueTypeInfo'pollers = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueTypeInfo "stats" TaskQueueStats where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueTypeInfo'stats
(\ x__ y__ -> x__ {_TaskQueueTypeInfo'stats = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TaskQueueTypeInfo "maybe'stats" (Prelude.Maybe TaskQueueStats) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueTypeInfo'stats
(\ x__ y__ -> x__ {_TaskQueueTypeInfo'stats = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueTypeInfo where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueueTypeInfo"
packedMessageDescriptor _
= "\n\
\\DC1TaskQueueTypeInfo\DC2?\n\
\\apollers\CAN\SOH \ETX(\v2%.temporal.api.taskqueue.v1.PollerInfoR\apollers\DC2?\n\
\\ENQstats\CAN\STX \SOH(\v2).temporal.api.taskqueue.v1.TaskQueueStatsR\ENQstats"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
pollers__field_descriptor
= Data.ProtoLens.FieldDescriptor
"pollers"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor PollerInfo)
(Data.ProtoLens.RepeatedField
Data.ProtoLens.Unpacked (Data.ProtoLens.Field.field @"pollers")) ::
Data.ProtoLens.FieldDescriptor TaskQueueTypeInfo
stats__field_descriptor
= Data.ProtoLens.FieldDescriptor
"stats"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor TaskQueueStats)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'stats")) ::
Data.ProtoLens.FieldDescriptor TaskQueueTypeInfo
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, pollers__field_descriptor),
(Data.ProtoLens.Tag 2, stats__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueTypeInfo'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueTypeInfo'_unknownFields = y__})
defMessage
= TaskQueueTypeInfo'_constructor
{_TaskQueueTypeInfo'pollers = Data.Vector.Generic.empty,
_TaskQueueTypeInfo'stats = Prelude.Nothing,
_TaskQueueTypeInfo'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueTypeInfo
-> Data.ProtoLens.Encoding.Growing.Growing Data.Vector.Vector Data.ProtoLens.Encoding.Growing.RealWorld PollerInfo
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueTypeInfo
loop x mutable'pollers
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do frozen'pollers <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.unsafeFreeze
mutable'pollers)
(let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t)
(Lens.Family2.set
(Data.ProtoLens.Field.field @"vec'pollers") frozen'pollers x))
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do !y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len)
Data.ProtoLens.parseMessage)
"pollers"
v <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.append mutable'pollers y)
loop x v
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"stats"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"stats") y x)
mutable'pollers
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
mutable'pollers
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do mutable'pollers <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
Data.ProtoLens.Encoding.Growing.new
loop Data.ProtoLens.defMessage mutable'pollers)
"TaskQueueTypeInfo"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.foldMapBuilder
(\ _v
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Lens.Family2.view (Data.ProtoLens.Field.field @"vec'pollers") _x))
((Data.Monoid.<>)
(case
Lens.Family2.view (Data.ProtoLens.Field.field @"maybe'stats") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TaskQueueTypeInfo where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueTypeInfo'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueTypeInfo'pollers x__)
(Control.DeepSeq.deepseq (_TaskQueueTypeInfo'stats x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.typesInfo' @:: Lens' TaskQueueVersionInfo (Data.Map.Map Data.Int.Int32 TaskQueueTypeInfo)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.taskReachability' @:: Lens' TaskQueueVersionInfo Proto.Temporal.Api.Enums.V1.TaskQueue.BuildIdTaskReachability@ -}
data TaskQueueVersionInfo
= TaskQueueVersionInfo'_constructor {_TaskQueueVersionInfo'typesInfo :: !(Data.Map.Map Data.Int.Int32 TaskQueueTypeInfo),
_TaskQueueVersionInfo'taskReachability :: !Proto.Temporal.Api.Enums.V1.TaskQueue.BuildIdTaskReachability,
_TaskQueueVersionInfo'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueVersionInfo where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueVersionInfo "typesInfo" (Data.Map.Map Data.Int.Int32 TaskQueueTypeInfo) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'typesInfo
(\ x__ y__ -> x__ {_TaskQueueVersionInfo'typesInfo = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersionInfo "taskReachability" Proto.Temporal.Api.Enums.V1.TaskQueue.BuildIdTaskReachability where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'taskReachability
(\ x__ y__ -> x__ {_TaskQueueVersionInfo'taskReachability = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueVersionInfo where
messageName _
= Data.Text.pack "temporal.api.taskqueue.v1.TaskQueueVersionInfo"
packedMessageDescriptor _
= "\n\
\\DC4TaskQueueVersionInfo\DC2]\n\
\\n\
\types_info\CAN\SOH \ETX(\v2>.temporal.api.taskqueue.v1.TaskQueueVersionInfo.TypesInfoEntryR\ttypesInfo\DC2[\n\
\\DC1task_reachability\CAN\STX \SOH(\SO2..temporal.api.enums.v1.BuildIdTaskReachabilityR\DLEtaskReachability\SUBj\n\
\\SOTypesInfoEntry\DC2\DLE\n\
\\ETXkey\CAN\SOH \SOH(\ENQR\ETXkey\DC2B\n\
\\ENQvalue\CAN\STX \SOH(\v2,.temporal.api.taskqueue.v1.TaskQueueTypeInfoR\ENQvalue:\STX8\SOH"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
typesInfo__field_descriptor
= Data.ProtoLens.FieldDescriptor
"types_info"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor TaskQueueVersionInfo'TypesInfoEntry)
(Data.ProtoLens.MapField
(Data.ProtoLens.Field.field @"key")
(Data.ProtoLens.Field.field @"value")
(Data.ProtoLens.Field.field @"typesInfo")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionInfo
taskReachability__field_descriptor
= Data.ProtoLens.FieldDescriptor
"task_reachability"
(Data.ProtoLens.ScalarField Data.ProtoLens.EnumField ::
Data.ProtoLens.FieldTypeDescriptor Proto.Temporal.Api.Enums.V1.TaskQueue.BuildIdTaskReachability)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"taskReachability")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionInfo
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, typesInfo__field_descriptor),
(Data.ProtoLens.Tag 2, taskReachability__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueVersionInfo'_unknownFields = y__})
defMessage
= TaskQueueVersionInfo'_constructor
{_TaskQueueVersionInfo'typesInfo = Data.Map.empty,
_TaskQueueVersionInfo'taskReachability = Data.ProtoLens.fieldDefault,
_TaskQueueVersionInfo'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueVersionInfo
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueVersionInfo
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do !(entry :: TaskQueueVersionInfo'TypesInfoEntry) <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral
len)
Data.ProtoLens.parseMessage)
"types_info"
(let
key = Lens.Family2.view (Data.ProtoLens.Field.field @"key") entry
value
= Lens.Family2.view (Data.ProtoLens.Field.field @"value") entry
in
loop
(Lens.Family2.over
(Data.ProtoLens.Field.field @"typesInfo")
(\ !t -> Data.Map.insert key value t) x))
16
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.toEnum
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt))
"task_reachability"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"taskReachability") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueueVersionInfo"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(Data.Monoid.mconcat
(Prelude.map
(\ _v
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage
(Lens.Family2.set
(Data.ProtoLens.Field.field @"key") (Prelude.fst _v)
(Lens.Family2.set
(Data.ProtoLens.Field.field @"value") (Prelude.snd _v)
(Data.ProtoLens.defMessage ::
TaskQueueVersionInfo'TypesInfoEntry)))))
(Data.Map.toList
(Lens.Family2.view (Data.ProtoLens.Field.field @"typesInfo") _x))))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"taskReachability") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 16)
((Prelude..)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral)
Prelude.fromEnum _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TaskQueueVersionInfo where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueVersionInfo'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionInfo'typesInfo x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionInfo'taskReachability x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.key' @:: Lens' TaskQueueVersionInfo'TypesInfoEntry Data.Int.Int32@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.value' @:: Lens' TaskQueueVersionInfo'TypesInfoEntry TaskQueueTypeInfo@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'value' @:: Lens' TaskQueueVersionInfo'TypesInfoEntry (Prelude.Maybe TaskQueueTypeInfo)@ -}
data TaskQueueVersionInfo'TypesInfoEntry
= TaskQueueVersionInfo'TypesInfoEntry'_constructor {_TaskQueueVersionInfo'TypesInfoEntry'key :: !Data.Int.Int32,
_TaskQueueVersionInfo'TypesInfoEntry'value :: !(Prelude.Maybe TaskQueueTypeInfo),
_TaskQueueVersionInfo'TypesInfoEntry'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueVersionInfo'TypesInfoEntry where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueVersionInfo'TypesInfoEntry "key" Data.Int.Int32 where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'TypesInfoEntry'key
(\ x__ y__
-> x__ {_TaskQueueVersionInfo'TypesInfoEntry'key = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersionInfo'TypesInfoEntry "value" TaskQueueTypeInfo where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'TypesInfoEntry'value
(\ x__ y__
-> x__ {_TaskQueueVersionInfo'TypesInfoEntry'value = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TaskQueueVersionInfo'TypesInfoEntry "maybe'value" (Prelude.Maybe TaskQueueTypeInfo) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'TypesInfoEntry'value
(\ x__ y__
-> x__ {_TaskQueueVersionInfo'TypesInfoEntry'value = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueVersionInfo'TypesInfoEntry where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.TaskQueueVersionInfo.TypesInfoEntry"
packedMessageDescriptor _
= "\n\
\\SOTypesInfoEntry\DC2\DLE\n\
\\ETXkey\CAN\SOH \SOH(\ENQR\ETXkey\DC2B\n\
\\ENQvalue\CAN\STX \SOH(\v2,.temporal.api.taskqueue.v1.TaskQueueTypeInfoR\ENQvalue:\STX8\SOH"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
key__field_descriptor
= Data.ProtoLens.FieldDescriptor
"key"
(Data.ProtoLens.ScalarField Data.ProtoLens.Int32Field ::
Data.ProtoLens.FieldTypeDescriptor Data.Int.Int32)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional (Data.ProtoLens.Field.field @"key")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionInfo'TypesInfoEntry
value__field_descriptor
= Data.ProtoLens.FieldDescriptor
"value"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor TaskQueueTypeInfo)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'value")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionInfo'TypesInfoEntry
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, key__field_descriptor),
(Data.ProtoLens.Tag 2, value__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueVersionInfo'TypesInfoEntry'_unknownFields
(\ x__ y__
-> x__ {_TaskQueueVersionInfo'TypesInfoEntry'_unknownFields = y__})
defMessage
= TaskQueueVersionInfo'TypesInfoEntry'_constructor
{_TaskQueueVersionInfo'TypesInfoEntry'key = Data.ProtoLens.fieldDefault,
_TaskQueueVersionInfo'TypesInfoEntry'value = Prelude.Nothing,
_TaskQueueVersionInfo'TypesInfoEntry'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueVersionInfo'TypesInfoEntry
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueVersionInfo'TypesInfoEntry
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
8 -> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Prelude.fromIntegral
Data.ProtoLens.Encoding.Bytes.getVarInt)
"key"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"key") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"value"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"value") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TypesInfoEntry"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let _v = Lens.Family2.view (Data.ProtoLens.Field.field @"key") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 8)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt Prelude.fromIntegral _v))
((Data.Monoid.<>)
(case
Lens.Family2.view (Data.ProtoLens.Field.field @"maybe'value") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TaskQueueVersionInfo'TypesInfoEntry where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueVersionInfo'TypesInfoEntry'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionInfo'TypesInfoEntry'key x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionInfo'TypesInfoEntry'value x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.buildIds' @:: Lens' TaskQueueVersionSelection [Data.Text.Text]@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.vec'buildIds' @:: Lens' TaskQueueVersionSelection (Data.Vector.Vector Data.Text.Text)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.unversioned' @:: Lens' TaskQueueVersionSelection Prelude.Bool@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.allActive' @:: Lens' TaskQueueVersionSelection Prelude.Bool@ -}
data TaskQueueVersionSelection
= TaskQueueVersionSelection'_constructor {_TaskQueueVersionSelection'buildIds :: !(Data.Vector.Vector Data.Text.Text),
_TaskQueueVersionSelection'unversioned :: !Prelude.Bool,
_TaskQueueVersionSelection'allActive :: !Prelude.Bool,
_TaskQueueVersionSelection'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueVersionSelection where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueVersionSelection "buildIds" [Data.Text.Text] where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionSelection'buildIds
(\ x__ y__ -> x__ {_TaskQueueVersionSelection'buildIds = y__}))
(Lens.Family2.Unchecked.lens
Data.Vector.Generic.toList
(\ _ y__ -> Data.Vector.Generic.fromList y__))
instance Data.ProtoLens.Field.HasField TaskQueueVersionSelection "vec'buildIds" (Data.Vector.Vector Data.Text.Text) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionSelection'buildIds
(\ x__ y__ -> x__ {_TaskQueueVersionSelection'buildIds = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersionSelection "unversioned" Prelude.Bool where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionSelection'unversioned
(\ x__ y__ -> x__ {_TaskQueueVersionSelection'unversioned = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersionSelection "allActive" Prelude.Bool where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersionSelection'allActive
(\ x__ y__ -> x__ {_TaskQueueVersionSelection'allActive = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueVersionSelection where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.TaskQueueVersionSelection"
packedMessageDescriptor _
= "\n\
\\EMTaskQueueVersionSelection\DC2\ESC\n\
\\tbuild_ids\CAN\SOH \ETX(\tR\bbuildIds\DC2 \n\
\\vunversioned\CAN\STX \SOH(\bR\vunversioned\DC2\GS\n\
\\n\
\all_active\CAN\ETX \SOH(\bR\tallActive"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
buildIds__field_descriptor
= Data.ProtoLens.FieldDescriptor
"build_ids"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.RepeatedField
Data.ProtoLens.Unpacked
(Data.ProtoLens.Field.field @"buildIds")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionSelection
unversioned__field_descriptor
= Data.ProtoLens.FieldDescriptor
"unversioned"
(Data.ProtoLens.ScalarField Data.ProtoLens.BoolField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Bool)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"unversioned")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionSelection
allActive__field_descriptor
= Data.ProtoLens.FieldDescriptor
"all_active"
(Data.ProtoLens.ScalarField Data.ProtoLens.BoolField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Bool)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"allActive")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersionSelection
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, buildIds__field_descriptor),
(Data.ProtoLens.Tag 2, unversioned__field_descriptor),
(Data.ProtoLens.Tag 3, allActive__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueVersionSelection'_unknownFields
(\ x__ y__
-> x__ {_TaskQueueVersionSelection'_unknownFields = y__})
defMessage
= TaskQueueVersionSelection'_constructor
{_TaskQueueVersionSelection'buildIds = Data.Vector.Generic.empty,
_TaskQueueVersionSelection'unversioned = Data.ProtoLens.fieldDefault,
_TaskQueueVersionSelection'allActive = Data.ProtoLens.fieldDefault,
_TaskQueueVersionSelection'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueVersionSelection
-> Data.ProtoLens.Encoding.Growing.Growing Data.Vector.Vector Data.ProtoLens.Encoding.Growing.RealWorld Data.Text.Text
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueVersionSelection
loop x mutable'buildIds
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do frozen'buildIds <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.unsafeFreeze
mutable'buildIds)
(let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t)
(Lens.Family2.set
(Data.ProtoLens.Field.field @"vec'buildIds") frozen'buildIds x))
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do !y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"build_ids"
v <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
(Data.ProtoLens.Encoding.Growing.append mutable'buildIds y)
loop x v
16
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
((Prelude./=) 0) Data.ProtoLens.Encoding.Bytes.getVarInt)
"unversioned"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"unversioned") y x)
mutable'buildIds
24
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
((Prelude./=) 0) Data.ProtoLens.Encoding.Bytes.getVarInt)
"all_active"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"allActive") y x)
mutable'buildIds
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
mutable'buildIds
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do mutable'buildIds <- Data.ProtoLens.Encoding.Parser.Unsafe.unsafeLiftIO
Data.ProtoLens.Encoding.Growing.new
loop Data.ProtoLens.defMessage mutable'buildIds)
"TaskQueueVersionSelection"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.foldMapBuilder
(\ _v
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
(Lens.Family2.view
(Data.ProtoLens.Field.field @"vec'buildIds") _x))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view (Data.ProtoLens.Field.field @"unversioned") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 16)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt (\ b -> if b then 1 else 0)
_v))
((Data.Monoid.<>)
(let
_v = Lens.Family2.view (Data.ProtoLens.Field.field @"allActive") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 24)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putVarInt (\ b -> if b then 1 else 0)
_v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x))))
instance Control.DeepSeq.NFData TaskQueueVersionSelection where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueVersionSelection'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionSelection'buildIds x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionSelection'unversioned x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersionSelection'allActive x__) ())))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.currentVersion' @:: Lens' TaskQueueVersioningInfo Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.rampingVersion' @:: Lens' TaskQueueVersioningInfo Data.Text.Text@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.rampingVersionPercentage' @:: Lens' TaskQueueVersioningInfo Prelude.Float@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.updateTime' @:: Lens' TaskQueueVersioningInfo Proto.Google.Protobuf.Timestamp.Timestamp@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'updateTime' @:: Lens' TaskQueueVersioningInfo (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp)@ -}
data TaskQueueVersioningInfo
= TaskQueueVersioningInfo'_constructor {_TaskQueueVersioningInfo'currentVersion :: !Data.Text.Text,
_TaskQueueVersioningInfo'rampingVersion :: !Data.Text.Text,
_TaskQueueVersioningInfo'rampingVersionPercentage :: !Prelude.Float,
_TaskQueueVersioningInfo'updateTime :: !(Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp),
_TaskQueueVersioningInfo'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TaskQueueVersioningInfo where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TaskQueueVersioningInfo "currentVersion" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersioningInfo'currentVersion
(\ x__ y__ -> x__ {_TaskQueueVersioningInfo'currentVersion = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersioningInfo "rampingVersion" Data.Text.Text where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersioningInfo'rampingVersion
(\ x__ y__ -> x__ {_TaskQueueVersioningInfo'rampingVersion = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersioningInfo "rampingVersionPercentage" Prelude.Float where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersioningInfo'rampingVersionPercentage
(\ x__ y__
-> x__ {_TaskQueueVersioningInfo'rampingVersionPercentage = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TaskQueueVersioningInfo "updateTime" Proto.Google.Protobuf.Timestamp.Timestamp where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersioningInfo'updateTime
(\ x__ y__ -> x__ {_TaskQueueVersioningInfo'updateTime = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TaskQueueVersioningInfo "maybe'updateTime" (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TaskQueueVersioningInfo'updateTime
(\ x__ y__ -> x__ {_TaskQueueVersioningInfo'updateTime = y__}))
Prelude.id
instance Data.ProtoLens.Message TaskQueueVersioningInfo where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.TaskQueueVersioningInfo"
packedMessageDescriptor _
= "\n\
\\ETBTaskQueueVersioningInfo\DC2'\n\
\\SIcurrent_version\CAN\SOH \SOH(\tR\SOcurrentVersion\DC2'\n\
\\SIramping_version\CAN\STX \SOH(\tR\SOrampingVersion\DC2<\n\
\\SUBramping_version_percentage\CAN\ETX \SOH(\STXR\CANrampingVersionPercentage\DC2;\n\
\\vupdate_time\CAN\EOT \SOH(\v2\SUB.google.protobuf.TimestampR\n\
\updateTime"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
currentVersion__field_descriptor
= Data.ProtoLens.FieldDescriptor
"current_version"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"currentVersion")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersioningInfo
rampingVersion__field_descriptor
= Data.ProtoLens.FieldDescriptor
"ramping_version"
(Data.ProtoLens.ScalarField Data.ProtoLens.StringField ::
Data.ProtoLens.FieldTypeDescriptor Data.Text.Text)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"rampingVersion")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersioningInfo
rampingVersionPercentage__field_descriptor
= Data.ProtoLens.FieldDescriptor
"ramping_version_percentage"
(Data.ProtoLens.ScalarField Data.ProtoLens.FloatField ::
Data.ProtoLens.FieldTypeDescriptor Prelude.Float)
(Data.ProtoLens.PlainField
Data.ProtoLens.Optional
(Data.ProtoLens.Field.field @"rampingVersionPercentage")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersioningInfo
updateTime__field_descriptor
= Data.ProtoLens.FieldDescriptor
"update_time"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Timestamp.Timestamp)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'updateTime")) ::
Data.ProtoLens.FieldDescriptor TaskQueueVersioningInfo
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, currentVersion__field_descriptor),
(Data.ProtoLens.Tag 2, rampingVersion__field_descriptor),
(Data.ProtoLens.Tag 3, rampingVersionPercentage__field_descriptor),
(Data.ProtoLens.Tag 4, updateTime__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TaskQueueVersioningInfo'_unknownFields
(\ x__ y__ -> x__ {_TaskQueueVersioningInfo'_unknownFields = y__})
defMessage
= TaskQueueVersioningInfo'_constructor
{_TaskQueueVersioningInfo'currentVersion = Data.ProtoLens.fieldDefault,
_TaskQueueVersioningInfo'rampingVersion = Data.ProtoLens.fieldDefault,
_TaskQueueVersioningInfo'rampingVersionPercentage = Data.ProtoLens.fieldDefault,
_TaskQueueVersioningInfo'updateTime = Prelude.Nothing,
_TaskQueueVersioningInfo'_unknownFields = []}
parseMessage
= let
loop ::
TaskQueueVersioningInfo
-> Data.ProtoLens.Encoding.Bytes.Parser TaskQueueVersioningInfo
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"current_version"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"currentVersion") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.getText
(Prelude.fromIntegral len))
"ramping_version"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"rampingVersion") y x)
29
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(Prelude.fmap
Data.ProtoLens.Encoding.Bytes.wordToFloat
Data.ProtoLens.Encoding.Bytes.getFixed32)
"ramping_version_percentage"
loop
(Lens.Family2.set
(Data.ProtoLens.Field.field @"rampingVersionPercentage") y x)
34
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"update_time"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"updateTime") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage) "TaskQueueVersioningInfo"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"currentVersion") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"rampingVersion") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.Text.Encoding.encodeUtf8 _v))
((Data.Monoid.<>)
(let
_v
= Lens.Family2.view
(Data.ProtoLens.Field.field @"rampingVersionPercentage") _x
in
if (Prelude.==) _v Data.ProtoLens.fieldDefault then
Data.Monoid.mempty
else
(Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 29)
((Prelude..)
Data.ProtoLens.Encoding.Bytes.putFixed32
Data.ProtoLens.Encoding.Bytes.floatToWord _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'updateTime") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 34)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))))
instance Control.DeepSeq.NFData TaskQueueVersioningInfo where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TaskQueueVersioningInfo'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersioningInfo'currentVersion x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersioningInfo'rampingVersion x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersioningInfo'rampingVersionPercentage x__)
(Control.DeepSeq.deepseq
(_TaskQueueVersioningInfo'updateTime x__) ()))))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.rule' @:: Lens' TimestampedBuildIdAssignmentRule BuildIdAssignmentRule@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'rule' @:: Lens' TimestampedBuildIdAssignmentRule (Prelude.Maybe BuildIdAssignmentRule)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.createTime' @:: Lens' TimestampedBuildIdAssignmentRule Proto.Google.Protobuf.Timestamp.Timestamp@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'createTime' @:: Lens' TimestampedBuildIdAssignmentRule (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp)@ -}
data TimestampedBuildIdAssignmentRule
= TimestampedBuildIdAssignmentRule'_constructor {_TimestampedBuildIdAssignmentRule'rule :: !(Prelude.Maybe BuildIdAssignmentRule),
_TimestampedBuildIdAssignmentRule'createTime :: !(Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp),
_TimestampedBuildIdAssignmentRule'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TimestampedBuildIdAssignmentRule where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TimestampedBuildIdAssignmentRule "rule" BuildIdAssignmentRule where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedBuildIdAssignmentRule'rule
(\ x__ y__ -> x__ {_TimestampedBuildIdAssignmentRule'rule = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TimestampedBuildIdAssignmentRule "maybe'rule" (Prelude.Maybe BuildIdAssignmentRule) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedBuildIdAssignmentRule'rule
(\ x__ y__ -> x__ {_TimestampedBuildIdAssignmentRule'rule = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TimestampedBuildIdAssignmentRule "createTime" Proto.Google.Protobuf.Timestamp.Timestamp where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedBuildIdAssignmentRule'createTime
(\ x__ y__
-> x__ {_TimestampedBuildIdAssignmentRule'createTime = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TimestampedBuildIdAssignmentRule "maybe'createTime" (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedBuildIdAssignmentRule'createTime
(\ x__ y__
-> x__ {_TimestampedBuildIdAssignmentRule'createTime = y__}))
Prelude.id
instance Data.ProtoLens.Message TimestampedBuildIdAssignmentRule where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.TimestampedBuildIdAssignmentRule"
packedMessageDescriptor _
= "\n\
\ TimestampedBuildIdAssignmentRule\DC2D\n\
\\EOTrule\CAN\SOH \SOH(\v20.temporal.api.taskqueue.v1.BuildIdAssignmentRuleR\EOTrule\DC2;\n\
\\vcreate_time\CAN\STX \SOH(\v2\SUB.google.protobuf.TimestampR\n\
\createTime"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
rule__field_descriptor
= Data.ProtoLens.FieldDescriptor
"rule"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor BuildIdAssignmentRule)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'rule")) ::
Data.ProtoLens.FieldDescriptor TimestampedBuildIdAssignmentRule
createTime__field_descriptor
= Data.ProtoLens.FieldDescriptor
"create_time"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Timestamp.Timestamp)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'createTime")) ::
Data.ProtoLens.FieldDescriptor TimestampedBuildIdAssignmentRule
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, rule__field_descriptor),
(Data.ProtoLens.Tag 2, createTime__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TimestampedBuildIdAssignmentRule'_unknownFields
(\ x__ y__
-> x__ {_TimestampedBuildIdAssignmentRule'_unknownFields = y__})
defMessage
= TimestampedBuildIdAssignmentRule'_constructor
{_TimestampedBuildIdAssignmentRule'rule = Prelude.Nothing,
_TimestampedBuildIdAssignmentRule'createTime = Prelude.Nothing,
_TimestampedBuildIdAssignmentRule'_unknownFields = []}
parseMessage
= let
loop ::
TimestampedBuildIdAssignmentRule
-> Data.ProtoLens.Encoding.Bytes.Parser TimestampedBuildIdAssignmentRule
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"rule"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"rule") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"create_time"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"createTime") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage)
"TimestampedBuildIdAssignmentRule"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(case
Lens.Family2.view (Data.ProtoLens.Field.field @"maybe'rule") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'createTime") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TimestampedBuildIdAssignmentRule where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TimestampedBuildIdAssignmentRule'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TimestampedBuildIdAssignmentRule'rule x__)
(Control.DeepSeq.deepseq
(_TimestampedBuildIdAssignmentRule'createTime x__) ()))
{- | Fields :
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.rule' @:: Lens' TimestampedCompatibleBuildIdRedirectRule CompatibleBuildIdRedirectRule@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'rule' @:: Lens' TimestampedCompatibleBuildIdRedirectRule (Prelude.Maybe CompatibleBuildIdRedirectRule)@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.createTime' @:: Lens' TimestampedCompatibleBuildIdRedirectRule Proto.Google.Protobuf.Timestamp.Timestamp@
* 'Proto.Temporal.Api.Taskqueue.V1.Message_Fields.maybe'createTime' @:: Lens' TimestampedCompatibleBuildIdRedirectRule (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp)@ -}
data TimestampedCompatibleBuildIdRedirectRule
= TimestampedCompatibleBuildIdRedirectRule'_constructor {_TimestampedCompatibleBuildIdRedirectRule'rule :: !(Prelude.Maybe CompatibleBuildIdRedirectRule),
_TimestampedCompatibleBuildIdRedirectRule'createTime :: !(Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp),
_TimestampedCompatibleBuildIdRedirectRule'_unknownFields :: !Data.ProtoLens.FieldSet}
deriving stock (Prelude.Eq, Prelude.Ord)
instance Prelude.Show TimestampedCompatibleBuildIdRedirectRule where
showsPrec _ __x __s
= Prelude.showChar
'{'
(Prelude.showString
(Data.ProtoLens.showMessageShort __x) (Prelude.showChar '}' __s))
instance Data.ProtoLens.Field.HasField TimestampedCompatibleBuildIdRedirectRule "rule" CompatibleBuildIdRedirectRule where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedCompatibleBuildIdRedirectRule'rule
(\ x__ y__
-> x__ {_TimestampedCompatibleBuildIdRedirectRule'rule = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TimestampedCompatibleBuildIdRedirectRule "maybe'rule" (Prelude.Maybe CompatibleBuildIdRedirectRule) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedCompatibleBuildIdRedirectRule'rule
(\ x__ y__
-> x__ {_TimestampedCompatibleBuildIdRedirectRule'rule = y__}))
Prelude.id
instance Data.ProtoLens.Field.HasField TimestampedCompatibleBuildIdRedirectRule "createTime" Proto.Google.Protobuf.Timestamp.Timestamp where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedCompatibleBuildIdRedirectRule'createTime
(\ x__ y__
-> x__
{_TimestampedCompatibleBuildIdRedirectRule'createTime = y__}))
(Data.ProtoLens.maybeLens Data.ProtoLens.defMessage)
instance Data.ProtoLens.Field.HasField TimestampedCompatibleBuildIdRedirectRule "maybe'createTime" (Prelude.Maybe Proto.Google.Protobuf.Timestamp.Timestamp) where
fieldOf _
= (Prelude..)
(Lens.Family2.Unchecked.lens
_TimestampedCompatibleBuildIdRedirectRule'createTime
(\ x__ y__
-> x__
{_TimestampedCompatibleBuildIdRedirectRule'createTime = y__}))
Prelude.id
instance Data.ProtoLens.Message TimestampedCompatibleBuildIdRedirectRule where
messageName _
= Data.Text.pack
"temporal.api.taskqueue.v1.TimestampedCompatibleBuildIdRedirectRule"
packedMessageDescriptor _
= "\n\
\(TimestampedCompatibleBuildIdRedirectRule\DC2L\n\
\\EOTrule\CAN\SOH \SOH(\v28.temporal.api.taskqueue.v1.CompatibleBuildIdRedirectRuleR\EOTrule\DC2;\n\
\\vcreate_time\CAN\STX \SOH(\v2\SUB.google.protobuf.TimestampR\n\
\createTime"
packedFileDescriptor _ = packedFileDescriptor
fieldsByTag
= let
rule__field_descriptor
= Data.ProtoLens.FieldDescriptor
"rule"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor CompatibleBuildIdRedirectRule)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'rule")) ::
Data.ProtoLens.FieldDescriptor TimestampedCompatibleBuildIdRedirectRule
createTime__field_descriptor
= Data.ProtoLens.FieldDescriptor
"create_time"
(Data.ProtoLens.MessageField Data.ProtoLens.MessageType ::
Data.ProtoLens.FieldTypeDescriptor Proto.Google.Protobuf.Timestamp.Timestamp)
(Data.ProtoLens.OptionalField
(Data.ProtoLens.Field.field @"maybe'createTime")) ::
Data.ProtoLens.FieldDescriptor TimestampedCompatibleBuildIdRedirectRule
in
Data.Map.fromList
[(Data.ProtoLens.Tag 1, rule__field_descriptor),
(Data.ProtoLens.Tag 2, createTime__field_descriptor)]
unknownFields
= Lens.Family2.Unchecked.lens
_TimestampedCompatibleBuildIdRedirectRule'_unknownFields
(\ x__ y__
-> x__
{_TimestampedCompatibleBuildIdRedirectRule'_unknownFields = y__})
defMessage
= TimestampedCompatibleBuildIdRedirectRule'_constructor
{_TimestampedCompatibleBuildIdRedirectRule'rule = Prelude.Nothing,
_TimestampedCompatibleBuildIdRedirectRule'createTime = Prelude.Nothing,
_TimestampedCompatibleBuildIdRedirectRule'_unknownFields = []}
parseMessage
= let
loop ::
TimestampedCompatibleBuildIdRedirectRule
-> Data.ProtoLens.Encoding.Bytes.Parser TimestampedCompatibleBuildIdRedirectRule
loop x
= do end <- Data.ProtoLens.Encoding.Bytes.atEnd
if end then
do (let missing = []
in
if Prelude.null missing then
Prelude.return ()
else
Prelude.fail
((Prelude.++)
"Missing required fields: "
(Prelude.show (missing :: [Prelude.String]))))
Prelude.return
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> Prelude.reverse t) x)
else
do tag <- Data.ProtoLens.Encoding.Bytes.getVarInt
case tag of
10
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"rule"
loop (Lens.Family2.set (Data.ProtoLens.Field.field @"rule") y x)
18
-> do y <- (Data.ProtoLens.Encoding.Bytes.<?>)
(do len <- Data.ProtoLens.Encoding.Bytes.getVarInt
Data.ProtoLens.Encoding.Bytes.isolate
(Prelude.fromIntegral len) Data.ProtoLens.parseMessage)
"create_time"
loop
(Lens.Family2.set (Data.ProtoLens.Field.field @"createTime") y x)
wire
-> do !y <- Data.ProtoLens.Encoding.Wire.parseTaggedValueFromWire
wire
loop
(Lens.Family2.over
Data.ProtoLens.unknownFields (\ !t -> (:) y t) x)
in
(Data.ProtoLens.Encoding.Bytes.<?>)
(do loop Data.ProtoLens.defMessage)
"TimestampedCompatibleBuildIdRedirectRule"
buildMessage
= \ _x
-> (Data.Monoid.<>)
(case
Lens.Family2.view (Data.ProtoLens.Field.field @"maybe'rule") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 10)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
((Data.Monoid.<>)
(case
Lens.Family2.view
(Data.ProtoLens.Field.field @"maybe'createTime") _x
of
Prelude.Nothing -> Data.Monoid.mempty
(Prelude.Just _v)
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt 18)
((Prelude..)
(\ bs
-> (Data.Monoid.<>)
(Data.ProtoLens.Encoding.Bytes.putVarInt
(Prelude.fromIntegral (Data.ByteString.length bs)))
(Data.ProtoLens.Encoding.Bytes.putBytes bs))
Data.ProtoLens.encodeMessage _v))
(Data.ProtoLens.Encoding.Wire.buildFieldSet
(Lens.Family2.view Data.ProtoLens.unknownFields _x)))
instance Control.DeepSeq.NFData TimestampedCompatibleBuildIdRedirectRule where
rnf
= \ x__
-> Control.DeepSeq.deepseq
(_TimestampedCompatibleBuildIdRedirectRule'_unknownFields x__)
(Control.DeepSeq.deepseq
(_TimestampedCompatibleBuildIdRedirectRule'rule x__)
(Control.DeepSeq.deepseq
(_TimestampedCompatibleBuildIdRedirectRule'createTime x__) ()))
packedFileDescriptor :: Data.ByteString.ByteString
packedFileDescriptor
= "\n\
\'temporal/api/taskqueue/v1/message.proto\DC2\EMtemporal.api.taskqueue.v1\SUB\RSgoogle/protobuf/duration.proto\SUB\USgoogle/protobuf/timestamp.proto\SUB\RSgoogle/protobuf/wrappers.proto\SUB&temporal/api/enums/v1/task_queue.proto\SUB$temporal/api/common/v1/message.proto\SUB(temporal/api/deployment/v1/message.proto\"z\n\
\\tTaskQueue\DC2\DC2\n\
\\EOTname\CAN\SOH \SOH(\tR\EOTname\DC28\n\
\\EOTkind\CAN\STX \SOH(\SO2$.temporal.api.enums.v1.TaskQueueKindR\EOTkind\DC2\US\n\
\\vnormal_name\CAN\ETX \SOH(\tR\n\
\normalName\"b\n\
\\DC1TaskQueueMetadata\DC2M\n\
\\DC4max_tasks_per_second\CAN\SOH \SOH(\v2\FS.google.protobuf.DoubleValueR\DC1maxTasksPerSecond\"\230\SOH\n\
\\ETBTaskQueueVersioningInfo\DC2'\n\
\\SIcurrent_version\CAN\SOH \SOH(\tR\SOcurrentVersion\DC2'\n\
\\SIramping_version\CAN\STX \SOH(\tR\SOrampingVersion\DC2<\n\
\\SUBramping_version_percentage\CAN\ETX \SOH(\STXR\CANrampingVersionPercentage\DC2;\n\
\\vupdate_time\CAN\EOT \SOH(\v2\SUB.google.protobuf.TimestampR\n\
\updateTime\"y\n\
\\EMTaskQueueVersionSelection\DC2\ESC\n\
\\tbuild_ids\CAN\SOH \ETX(\tR\bbuildIds\DC2 \n\
\\vunversioned\CAN\STX \SOH(\bR\vunversioned\DC2\GS\n\
\\n\
\all_active\CAN\ETX \SOH(\bR\tallActive\"\190\STX\n\
\\DC4TaskQueueVersionInfo\DC2]\n\
\\n\
\types_info\CAN\SOH \ETX(\v2>.temporal.api.taskqueue.v1.TaskQueueVersionInfo.TypesInfoEntryR\ttypesInfo\DC2[\n\
\\DC1task_reachability\CAN\STX \SOH(\SO2..temporal.api.enums.v1.BuildIdTaskReachabilityR\DLEtaskReachability\SUBj\n\
\\SOTypesInfoEntry\DC2\DLE\n\
\\ETXkey\CAN\SOH \SOH(\ENQR\ETXkey\DC2B\n\
\\ENQvalue\CAN\STX \SOH(\v2,.temporal.api.taskqueue.v1.TaskQueueTypeInfoR\ENQvalue:\STX8\SOH\"\149\SOH\n\
\\DC1TaskQueueTypeInfo\DC2?\n\
\\apollers\CAN\SOH \ETX(\v2%.temporal.api.taskqueue.v1.PollerInfoR\apollers\DC2?\n\
\\ENQstats\CAN\STX \SOH(\v2).temporal.api.taskqueue.v1.TaskQueueStatsR\ENQstats\"\245\SOH\n\
\\SOTaskQueueStats\DC2:\n\
\\EMapproximate_backlog_count\CAN\SOH \SOH(\ETXR\ETBapproximateBacklogCount\DC2Q\n\
\\ETBapproximate_backlog_age\CAN\STX \SOH(\v2\EM.google.protobuf.DurationR\NAKapproximateBacklogAge\DC2$\n\
\\SOtasks_add_rate\CAN\ETX \SOH(\STXR\ftasksAddRate\DC2.\n\
\\DC3tasks_dispatch_rate\CAN\EOT \SOH(\STXR\DC1tasksDispatchRate\"\239\SOH\n\
\\SITaskQueueStatus\DC2,\n\
\\DC2backlog_count_hint\CAN\SOH \SOH(\ETXR\DLEbacklogCountHint\DC2\GS\n\
\\n\
\read_level\CAN\STX \SOH(\ETXR\treadLevel\DC2\ESC\n\
\\tack_level\CAN\ETX \SOH(\ETXR\backLevel\DC2&\n\
\\SIrate_per_second\CAN\EOT \SOH(\SOHR\rratePerSecond\DC2J\n\
\\rtask_id_block\CAN\ENQ \SOH(\v2&.temporal.api.taskqueue.v1.TaskIdBlockR\vtaskIdBlock\"?\n\
\\vTaskIdBlock\DC2\EM\n\
\\bstart_id\CAN\SOH \SOH(\ETXR\astartId\DC2\NAK\n\
\\ACKend_id\CAN\STX \SOH(\ETXR\ENQendId\"V\n\
\\SUBTaskQueuePartitionMetadata\DC2\DLE\n\
\\ETXkey\CAN\SOH \SOH(\tR\ETXkey\DC2&\n\
\\SIowner_host_name\CAN\STX \SOH(\tR\rownerHostName\"\241\STX\n\
\\n\
\PollerInfo\DC2D\n\
\\DLElast_access_time\CAN\SOH \SOH(\v2\SUB.google.protobuf.TimestampR\SOlastAccessTime\DC2\SUB\n\
\\bidentity\CAN\STX \SOH(\tR\bidentity\DC2&\n\
\\SIrate_per_second\CAN\ETX \SOH(\SOHR\rratePerSecond\DC2u\n\
\\ESCworker_version_capabilities\CAN\EOT \SOH(\v21.temporal.api.common.v1.WorkerVersionCapabilitiesR\EMworkerVersionCapabilitiesB\STX\CAN\SOH\DC2b\n\
\\DC2deployment_options\CAN\ENQ \SOH(\v23.temporal.api.deployment.v1.WorkerDeploymentOptionsR\DC1deploymentOptions\"\195\SOH\n\
\\EMStickyExecutionAttributes\DC2P\n\
\\DC1worker_task_queue\CAN\SOH \SOH(\v2$.temporal.api.taskqueue.v1.TaskQueueR\SIworkerTaskQueue\DC2T\n\
\\EMschedule_to_start_timeout\CAN\STX \SOH(\v2\EM.google.protobuf.DurationR\SYNscheduleToStartTimeout\"3\n\
\\DC4CompatibleVersionSet\DC2\ESC\n\
\\tbuild_ids\CAN\SOH \ETX(\tR\bbuildIds\"\131\SOH\n\
\\NAKTaskQueueReachability\DC2\GS\n\
\\n\
\task_queue\CAN\SOH \SOH(\tR\ttaskQueue\DC2K\n\
\\freachability\CAN\STX \ETX(\SO2'.temporal.api.enums.v1.TaskReachabilityR\freachability\"\154\SOH\n\
\\DC3BuildIdReachability\DC2\EM\n\
\\bbuild_id\CAN\SOH \SOH(\tR\abuildId\DC2h\n\
\\ETBtask_queue_reachability\CAN\STX \ETX(\v20.temporal.api.taskqueue.v1.TaskQueueReachabilityR\NAKtaskQueueReachability\";\n\
\\DLERampByPercentage\DC2'\n\
\\SIramp_percentage\CAN\SOH \SOH(\STXR\SOrampPercentage\"\159\SOH\n\
\\NAKBuildIdAssignmentRule\DC2&\n\
\\SItarget_build_id\CAN\SOH \SOH(\tR\rtargetBuildId\DC2V\n\
\\SIpercentage_ramp\CAN\ETX \SOH(\v2+.temporal.api.taskqueue.v1.RampByPercentageH\NULR\SOpercentageRampB\ACK\n\
\\EOTramp\"o\n\
\\GSCompatibleBuildIdRedirectRule\DC2&\n\
\\SIsource_build_id\CAN\SOH \SOH(\tR\rsourceBuildId\DC2&\n\
\\SItarget_build_id\CAN\STX \SOH(\tR\rtargetBuildId\"\165\SOH\n\
\ TimestampedBuildIdAssignmentRule\DC2D\n\
\\EOTrule\CAN\SOH \SOH(\v20.temporal.api.taskqueue.v1.BuildIdAssignmentRuleR\EOTrule\DC2;\n\
\\vcreate_time\CAN\STX \SOH(\v2\SUB.google.protobuf.TimestampR\n\
\createTime\"\181\SOH\n\
\(TimestampedCompatibleBuildIdRedirectRule\DC2L\n\
\\EOTrule\CAN\SOH \SOH(\v28.temporal.api.taskqueue.v1.CompatibleBuildIdRedirectRuleR\EOTrule\DC2;\n\
\\vcreate_time\CAN\STX \SOH(\v2\SUB.google.protobuf.TimestampR\n\
\createTime\"Z\n\
\\NAKPollerScalingDecision\DC2A\n\
\\GSpoll_request_delta_suggestion\CAN\SOH \SOH(\ENQR\SUBpollRequestDeltaSuggestionB\152\SOH\n\
\\FSio.temporal.api.taskqueue.v1B\fMessageProtoP\SOHZ)go.temporal.io/api/taskqueue/v1;taskqueue\170\STX\ESCTemporalio.Api.TaskQueue.V1\234\STX\RSTemporalio::Api::TaskQueue::V1J\132\DEL\n\
\\a\DC2\ENQ\SYN\NUL\209\STX\SOH\n\
\\241\b\n\
\\SOH\f\DC2\ETX\SYN\NUL\DC22\230\b The MIT License\n\
\\n\
\ Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.\n\
\\n\
\ Permission is hereby granted, free of charge, to any person obtaining a copy\n\
\ of this software and associated documentation files (the \"Software\"), to deal\n\
\ in the Software without restriction, including without limitation the rights\n\
\ to use, copy, modify, merge, publish, distribute, sublicense, and/or sell\n\
\ copies of the Software, and to permit persons to whom the Software is\n\
\ furnished to do so, subject to the following conditions:\n\
\\n\
\ The above copyright notice and this permission notice shall be included in\n\
\ all copies or substantial portions of the Software.\n\
\\n\
\ THE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR\n\
\ IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,\n\
\ FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE\n\
\ AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER\n\
\ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,\n\
\ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN\n\
\ THE SOFTWARE.\n\
\\n\
\\b\n\
\\SOH\STX\DC2\ETX\CAN\NUL\"\n\
\\b\n\
\\SOH\b\DC2\ETX\SUB\NUL@\n\
\\t\n\
\\STX\b\v\DC2\ETX\SUB\NUL@\n\
\\b\n\
\\SOH\b\DC2\ETX\ESC\NUL5\n\
\\t\n\
\\STX\b\SOH\DC2\ETX\ESC\NUL5\n\
\\b\n\
\\SOH\b\DC2\ETX\FS\NUL\"\n\
\\t\n\
\\STX\b\n\
\\DC2\ETX\FS\NUL\"\n\
\\b\n\
\\SOH\b\DC2\ETX\GS\NUL-\n\
\\t\n\
\\STX\b\b\DC2\ETX\GS\NUL-\n\
\\b\n\
\\SOH\b\DC2\ETX\RS\NUL7\n\
\\t\n\
\\STX\b-\DC2\ETX\RS\NUL7\n\
\\b\n\
\\SOH\b\DC2\ETX\US\NUL8\n\
\\t\n\
\\STX\b%\DC2\ETX\US\NUL8\n\
\\t\n\
\\STX\ETX\NUL\DC2\ETX!\NUL(\n\
\\t\n\
\\STX\ETX\SOH\DC2\ETX\"\NUL)\n\
\\t\n\
\\STX\ETX\STX\DC2\ETX#\NUL(\n\
\\t\n\
\\STX\ETX\ETX\DC2\ETX%\NUL0\n\
\\t\n\
\\STX\ETX\EOT\DC2\ETX&\NUL.\n\
\\t\n\
\\STX\ETX\ENQ\DC2\ETX'\NUL2\n\
\E\n\
\\STX\EOT\NUL\DC2\EOT*\NUL1\SOH\SUB9 See https://docs.temporal.io/docs/concepts/task-queues/\n\
\\n\
\\n\
\\n\
\\ETX\EOT\NUL\SOH\DC2\ETX*\b\DC1\n\
\\v\n\
\\EOT\EOT\NUL\STX\NUL\DC2\ETX+\EOT\DC4\n\
\\f\n\
\\ENQ\EOT\NUL\STX\NUL\ENQ\DC2\ETX+\EOT\n\
\\n\
\\f\n\
\\ENQ\EOT\NUL\STX\NUL\SOH\DC2\ETX+\v\SI\n\
\\f\n\
\\ENQ\EOT\NUL\STX\NUL\ETX\DC2\ETX+\DC2\DC3\n\
\/\n\
\\EOT\EOT\NUL\STX\SOH\DC2\ETX-\EOT1\SUB\" Default: TASK_QUEUE_KIND_NORMAL.\n\
\\n\
\\f\n\
\\ENQ\EOT\NUL\STX\SOH\ACK\DC2\ETX-\EOT'\n\
\\f\n\
\\ENQ\EOT\NUL\STX\SOH\SOH\DC2\ETX-(,\n\
\\f\n\
\\ENQ\EOT\NUL\STX\SOH\ETX\DC2\ETX-/0\n\
\\149\SOH\n\
\\EOT\EOT\NUL\STX\STX\DC2\ETX0\EOT\ESC\SUB\135\SOH Iff kind == TASK_QUEUE_KIND_STICKY, then this field contains the name of\n\
\ the normal task queue that the sticky worker is running on.\n\
\\n\
\\f\n\
\\ENQ\EOT\NUL\STX\STX\ENQ\DC2\ETX0\EOT\n\
\\n\
\\f\n\
\\ENQ\EOT\NUL\STX\STX\SOH\DC2\ETX0\v\SYN\n\
\\f\n\
\\ENQ\EOT\NUL\STX\STX\ETX\DC2\ETX0\EM\SUB\n\
\2\n\
\\STX\EOT\SOH\DC2\EOT4\NUL7\SOH\SUB& Only applies to activity task queues\n\
\\n\
\\n\
\\n\
\\ETX\EOT\SOH\SOH\DC2\ETX4\b\EM\n\
\B\n\
\\EOT\EOT\SOH\STX\NUL\DC2\ETX6\EOT9\SUB5 Allows throttling dispatch of tasks from this queue\n\
\\n\
\\f\n\
\\ENQ\EOT\SOH\STX\NUL\ACK\DC2\ETX6\EOT\US\n\
\\f\n\
\\ENQ\EOT\SOH\STX\NUL\SOH\DC2\ETX6 4\n\
\\f\n\
\\ENQ\EOT\SOH\STX\NUL\ETX\DC2\ETX678\n\
\m\n\
\\STX\EOT\STX\DC2\EOT:\NULS\SOH\SUBa Experimental. Worker Deployments are experimental and might significantly change in the future.\n\
\\n\
\\n\
\\n\
\\ETX\EOT\STX\SOH\DC2\ETX:\b\US\n\
\\177\EOT\n\
\\EOT\EOT\STX\STX\NUL\DC2\ETXC\EOT\US\SUB\163\EOT Always present. Specifies which Deployment Version should receive new workflow\n\
\ executions and tasks of existing unversioned or AutoUpgrade workflows.\n\
\ Can be one of the following:\n\
\ - A Deployment Version identifier in the form \"<deployment_name>.<build_id>\".\n\
\ - Or, the \"__unversioned__\" special value, to represent all the unversioned workers (those\n\
\ with `UNVERSIONED` (or unspecified) `WorkerVersioningMode`.)\n\
\ Note: Current Version is overridden by the Ramping Version for a portion of traffic when a ramp\n\
\ is set (see `ramping_version`.)\n\
\\n\
\\f\n\
\\ENQ\EOT\STX\STX\NUL\ENQ\DC2\ETXC\EOT\n\
\\n\
\\f\n\
\\ENQ\EOT\STX\STX\NUL\SOH\DC2\ETXC\v\SUB\n\
\\f\n\
\\ENQ\EOT\STX\STX\NUL\ETX\DC2\ETXC\GS\RS\n\
\\225\EOT\n\
\\EOT\EOT\STX\STX\SOH\DC2\ETXL\EOT\US\SUB\211\EOT When present, it means the traffic is being shifted from the Current Version to the Ramping\n\
\ Version.\n\
\ Must always be different from `current_version`. Can be one of the following:\n\
\ - A Deployment Version identifier in the form \"<deployment_name>.<build_id>\".\n\
\ - Or, the \"__unversioned__\" special value, to represent all the unversioned workers (those\n\
\ with `UNVERSIONED` (or unspecified) `WorkerVersioningMode`.)\n\
\ Note that it is possible to ramp from one Version to another Version, or from unversioned\n\
\ workers to a particular Version, or from a particular Version to unversioned workers.\n\
\\n\
\\f\n\
\\ENQ\EOT\STX\STX\SOH\ENQ\DC2\ETXL\EOT\n\
\\n\
\\f\n\
\\ENQ\EOT\STX\STX\SOH\SOH\DC2\ETXL\v\SUB\n\
\\f\n\
\\ENQ\EOT\STX\STX\SOH\ETX\DC2\ETXL\GS\RS\n\
\\153\STX\n\
\\EOT\EOT\STX\STX\STX\DC2\ETXP\EOT)\SUB\139\STX Percentage of tasks that are routed to the Ramping Version instead of the Current Version.\n\
\ Valid range: [0, 100]. A 100% value means the Ramping Version is receiving full traffic but\n\
\ not yet \"promoted\" to be the Current Version, likely due to pending validations.\n\
\\n\
\\f\n\
\\ENQ\EOT\STX\STX\STX\ENQ\DC2\ETXP\EOT\t\n\
\\f\n\
\\ENQ\EOT\STX\STX\STX\SOH\DC2\ETXP\n\
\$\n\
\\f\n\
\\ENQ\EOT\STX\STX\STX\ETX\DC2\ETXP'(\n\
\K\n\
\\EOT\EOT\STX\STX\ETX\DC2\ETXR\EOT.\SUB> Last time versioning information of this Task Queue changed.\n\
\\n\
\\f\n\
\\ENQ\EOT\STX\STX\ETX\ACK\DC2\ETXR\EOT\GS\n\
\\f\n\
\\ENQ\EOT\STX\STX\ETX\SOH\DC2\ETXR\RS)\n\
\\f\n\
\\ENQ\EOT\STX\STX\ETX\ETX\DC2\ETXR,-\n\
\G\n\
\\STX\EOT\ETX\DC2\EOTV\NUL^\SOH\SUB; Used for specifying versions the caller is interested in.\n\
\\n\
\\n\
\\n\
\\ETX\EOT\ETX\SOH\DC2\ETXV\b!\n\
\*\n\
\\EOT\EOT\ETX\STX\NUL\DC2\ETXX\EOT\"\SUB\GS Include specific Build IDs.\n\
\\n\
\\f\n\
\\ENQ\EOT\ETX\STX\NUL\EOT\DC2\ETXX\EOT\f\n\
\\f\n\
\\ENQ\EOT\ETX\STX\NUL\ENQ\DC2\ETXX\r\DC3\n\
\\f\n\
\\ENQ\EOT\ETX\STX\NUL\SOH\DC2\ETXX\DC4\GS\n\
\\f\n\
\\ENQ\EOT\ETX\STX\NUL\ETX\DC2\ETXX !\n\
\-\n\
\\EOT\EOT\ETX\STX\SOH\DC2\ETXZ\EOT\EM\SUB Include the unversioned queue.\n\
\\n\
\\f\n\
\\ENQ\EOT\ETX\STX\SOH\ENQ\DC2\ETXZ\EOT\b\n\
\\f\n\
\\ENQ\EOT\ETX\STX\SOH\SOH\DC2\ETXZ\t\DC4\n\
\\f\n\
\\ENQ\EOT\ETX\STX\SOH\ETX\DC2\ETXZ\ETB\CAN\n\
\\196\SOH\n\
\\EOT\EOT\ETX\STX\STX\DC2\ETX]\EOT\CAN\SUB\182\SOH Include all active versions. A version is considered active if, in the last few minutes,\n\
\ it has had new tasks or polls, or it has been the subject of certain task queue API calls.\n\
\\n\
\\f\n\
\\ENQ\EOT\ETX\STX\STX\ENQ\DC2\ETX]\EOT\b\n\
\\f\n\
\\ENQ\EOT\ETX\STX\STX\SOH\DC2\ETX]\t\DC3\n\
\\f\n\
\\ENQ\EOT\ETX\STX\STX\ETX\DC2\ETX]\SYN\ETB\n\
\\n\
\\n\
\\STX\EOT\EOT\DC2\EOT`\NULn\SOH\n\
\\n\
\\n\
\\ETX\EOT\EOT\SOH\DC2\ETX`\b\FS\n\
\y\n\
\\EOT\EOT\EOT\STX\NUL\DC2\ETXb\EOT1\SUBl Task Queue info per Task Type. Key is the numerical value of the temporal.api.enums.v1.TaskQueueType enum.\n\
\\n\
\\f\n\
\\ENQ\EOT\EOT\STX\NUL\ACK\DC2\ETXb\EOT!\n\
\\f\n\
\\ENQ\EOT\EOT\STX\NUL\SOH\DC2\ETXb\",\n\
\\f\n\
\\ENQ\EOT\EOT\STX\NUL\ETX\DC2\ETXb/0\n\
\\235\ENQ\n\
\\EOT\EOT\EOT\STX\SOH\DC2\ETXm\EOTH\SUB\221\ENQ Task Reachability is eventually consistent; there may be a delay until it converges to the most\n\
\ accurate value but it is designed in a way to take the more conservative side until it converges.\n\
\ For example REACHABLE is more conservative than CLOSED_WORKFLOWS_ONLY.\n\
\\n\
\ Note: future activities who inherit their workflow's Build ID but not its Task Queue will not be\n\
\ accounted for reachability as server cannot know if they'll happen as they do not use\n\
\ assignment rules of their Task Queue. Same goes for Child Workflows or Continue-As-New Workflows\n\
\ who inherit the parent/previous workflow's Build ID but not its Task Queue. In those cases, make\n\
\ sure to query reachability for the parent/previous workflow's Task Queue as well.\n\
\\n\
\\f\n\
\\ENQ\EOT\EOT\STX\SOH\ACK\DC2\ETXm\EOT1\n\
\\f\n\
\\ENQ\EOT\EOT\STX\SOH\SOH\DC2\ETXm2C\n\
\\f\n\
\\ENQ\EOT\EOT\STX\SOH\ETX\DC2\ETXmFG\n\
\\n\
\\n\
\\STX\EOT\ENQ\DC2\EOTp\NULt\SOH\n\
\\n\
\\n\
\\ETX\EOT\ENQ\SOH\DC2\ETXp\b\EM\n\
\\DEL\n\
\\EOT\EOT\ENQ\STX\NUL\DC2\ETXr\EOT$\SUBr Unversioned workers (with `useVersioning=false`) are reported in unversioned result even if they set a Build ID.\n\
\\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\NUL\EOT\DC2\ETXr\EOT\f\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\NUL\ACK\DC2\ETXr\r\ETB\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\NUL\SOH\DC2\ETXr\CAN\US\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\NUL\ETX\DC2\ETXr\"#\n\
\\v\n\
\\EOT\EOT\ENQ\STX\SOH\DC2\ETXs\EOT\GS\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\SOH\ACK\DC2\ETXs\EOT\DC2\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\SOH\SOH\DC2\ETXs\DC3\CAN\n\
\\f\n\
\\ENQ\EOT\ENQ\STX\SOH\ETX\DC2\ETXs\ESC\FS\n\
\\179\STX\n\
\\STX\EOT\ACK\DC2\ENQz\NUL\167\SOH\SOH\SUB\165\STX TaskQueueStats contains statistics about task queue backlog and activity.\n\
\\n\
\ For workflow task queue type, this result is partial because tasks sent to sticky queues are not included. Read\n\
\ comments above each metric to understand the impact of sticky queue exclusion on that metric accuracy.\n\
\\n\
\\n\
\\n\
\\ETX\EOT\ACK\SOH\DC2\ETXz\b\SYN\n\
\\162\ETX\n\
\\EOT\EOT\ACK\STX\NUL\DC2\EOT\129\SOH\EOT(\SUB\147\ETX The approximate number of tasks backlogged in this task queue. May count expired tasks but eventually\n\
\ converges to the right value. Can be relied upon for scaling decisions.\n\
\\n\
\ Special note for workflow task queue type: this metric does not count sticky queue tasks. However, because\n\
\ those tasks only remain valid for a few seconds, the inaccuracy becomes less significant as the backlog size\n\
\ grows.\n\
\\n\
\\r\n\
\\ENQ\EOT\ACK\STX\NUL\ENQ\DC2\EOT\129\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\ACK\STX\NUL\SOH\DC2\EOT\129\SOH\n\
\#\n\
\\r\n\
\\ENQ\EOT\ACK\STX\NUL\ETX\DC2\EOT\129\SOH&'\n\
\\152\ETX\n\
\\EOT\EOT\ACK\STX\SOH\DC2\EOT\136\SOH\EOT9\SUB\137\ETX Approximate age of the oldest task in the backlog based on the creation time of the task at the head of\n\
\ the queue. Can be relied upon for scaling decisions.\n\
\\n\
\ Special note for workflow task queue type: this metric does not count sticky queue tasks. However, because\n\
\ those tasks only remain valid for a few seconds, they should not affect the result when backlog is older than\n\
\ few seconds.\n\
\\n\
\\r\n\
\\ENQ\EOT\ACK\STX\SOH\ACK\DC2\EOT\136\SOH\EOT\FS\n\
\\r\n\
\\ENQ\EOT\ACK\STX\SOH\SOH\DC2\EOT\136\SOH\GS4\n\
\\r\n\
\\ENQ\EOT\ACK\STX\SOH\ETX\DC2\EOT\136\SOH78\n\
\\188\a\n\
\\EOT\EOT\ACK\STX\STX\DC2\EOT\151\SOH\EOT\GS\SUB\173\a The approximate tasks per second added to the task queue, averaging the last 30 seconds. These includes tasks\n\
\ whether or not they were added to/dispatched from the backlog or they were dispatched immediately without going\n\
\ to the backlog (sync-matched).\n\
\\n\
\ The difference between `tasks_add_rate` and `tasks_dispatch_rate` is a reliable metric for the rate at which\n\
\ backlog grows/shrinks.\n\
\\n\
\ Note: the actual tasks delivered to the workers may significantly be higher than the numbers reported by\n\
\ tasks_add_rate, because:\n\
\ - Tasks can be sent to workers without going to the task queue. This is called Eager dispatch. Eager dispatch is\n\
\ enable for activities by default in the latest SDKs.\n\
\ - Tasks going to Sticky queue are not accounted for. Note that, typically, only the first workflow task of each\n\
\ workflow goes to a normal queue, and the rest workflow tasks go to the Sticky queue associated with a specific\n\
\ worker instance.\n\
\\n\
\\r\n\
\\ENQ\EOT\ACK\STX\STX\ENQ\DC2\EOT\151\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\ACK\STX\STX\SOH\DC2\EOT\151\SOH\n\
\\CAN\n\
\\r\n\
\\ENQ\EOT\ACK\STX\STX\ETX\DC2\EOT\151\SOH\ESC\FS\n\
\\200\a\n\
\\EOT\EOT\ACK\STX\ETX\DC2\EOT\166\SOH\EOT\"\SUB\185\a The approximate tasks per second dispatched from the task queue, averaging the last 30 seconds. These includes\n\
\ tasks whether or not they were added to/dispatched from the backlog or they were dispatched immediately without\n\
\ going to the backlog (sync-matched).\n\
\\n\
\ The difference between `tasks_add_rate` and `tasks_dispatch_rate` is a reliable metric for the rate at which\n\
\ backlog grows/shrinks.\n\
\\n\
\ Note: the actual tasks delivered to the workers may significantly be higher than the numbers reported by\n\
\ tasks_dispatch_rate, because:\n\
\ - Tasks can be sent to workers without going to the task queue. This is called Eager dispatch. Eager dispatch is\n\
\ enable for activities by default in the latest SDKs.\n\
\ - Tasks going to Sticky queue are not accounted for. Note that, typically, only the first workflow task of each\n\
\ workflow goes to a normal queue, and the rest workflow tasks go to the Sticky queue associated with a specific\n\
\ worker instance.\n\
\\n\
\\r\n\
\\ENQ\EOT\ACK\STX\ETX\ENQ\DC2\EOT\166\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\ACK\STX\ETX\SOH\DC2\EOT\166\SOH\n\
\\GS\n\
\\r\n\
\\ENQ\EOT\ACK\STX\ETX\ETX\DC2\EOT\166\SOH !\n\
\{\n\
\\STX\EOT\a\DC2\ACK\170\SOH\NUL\176\SOH\SOH\SUBm Deprecated. Use `InternalTaskQueueStatus`. This is kept until `DescribeTaskQueue` supports legacy behavior.\n\
\\n\
\\v\n\
\\ETX\EOT\a\SOH\DC2\EOT\170\SOH\b\ETB\n\
\\f\n\
\\EOT\EOT\a\STX\NUL\DC2\EOT\171\SOH\EOT!\n\
\\r\n\
\\ENQ\EOT\a\STX\NUL\ENQ\DC2\EOT\171\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\a\STX\NUL\SOH\DC2\EOT\171\SOH\n\
\\FS\n\
\\r\n\
\\ENQ\EOT\a\STX\NUL\ETX\DC2\EOT\171\SOH\US \n\
\\f\n\
\\EOT\EOT\a\STX\SOH\DC2\EOT\172\SOH\EOT\EM\n\
\\r\n\
\\ENQ\EOT\a\STX\SOH\ENQ\DC2\EOT\172\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\a\STX\SOH\SOH\DC2\EOT\172\SOH\n\
\\DC4\n\
\\r\n\
\\ENQ\EOT\a\STX\SOH\ETX\DC2\EOT\172\SOH\ETB\CAN\n\
\\f\n\
\\EOT\EOT\a\STX\STX\DC2\EOT\173\SOH\EOT\CAN\n\
\\r\n\
\\ENQ\EOT\a\STX\STX\ENQ\DC2\EOT\173\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\a\STX\STX\SOH\DC2\EOT\173\SOH\n\
\\DC3\n\
\\r\n\
\\ENQ\EOT\a\STX\STX\ETX\DC2\EOT\173\SOH\SYN\ETB\n\
\\f\n\
\\EOT\EOT\a\STX\ETX\DC2\EOT\174\SOH\EOT\US\n\
\\r\n\
\\ENQ\EOT\a\STX\ETX\ENQ\DC2\EOT\174\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\a\STX\ETX\SOH\DC2\EOT\174\SOH\v\SUB\n\
\\r\n\
\\ENQ\EOT\a\STX\ETX\ETX\DC2\EOT\174\SOH\GS\RS\n\
\\f\n\
\\EOT\EOT\a\STX\EOT\DC2\EOT\175\SOH\EOT\"\n\
\\r\n\
\\ENQ\EOT\a\STX\EOT\ACK\DC2\EOT\175\SOH\EOT\SI\n\
\\r\n\
\\ENQ\EOT\a\STX\EOT\SOH\DC2\EOT\175\SOH\DLE\GS\n\
\\r\n\
\\ENQ\EOT\a\STX\EOT\ETX\DC2\EOT\175\SOH !\n\
\\f\n\
\\STX\EOT\b\DC2\ACK\178\SOH\NUL\181\SOH\SOH\n\
\\v\n\
\\ETX\EOT\b\SOH\DC2\EOT\178\SOH\b\DC3\n\
\\f\n\
\\EOT\EOT\b\STX\NUL\DC2\EOT\179\SOH\EOT\ETB\n\
\\r\n\
\\ENQ\EOT\b\STX\NUL\ENQ\DC2\EOT\179\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\b\STX\NUL\SOH\DC2\EOT\179\SOH\n\
\\DC2\n\
\\r\n\
\\ENQ\EOT\b\STX\NUL\ETX\DC2\EOT\179\SOH\NAK\SYN\n\
\\f\n\
\\EOT\EOT\b\STX\SOH\DC2\EOT\180\SOH\EOT\NAK\n\
\\r\n\
\\ENQ\EOT\b\STX\SOH\ENQ\DC2\EOT\180\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\b\STX\SOH\SOH\DC2\EOT\180\SOH\n\
\\DLE\n\
\\r\n\
\\ENQ\EOT\b\STX\SOH\ETX\DC2\EOT\180\SOH\DC3\DC4\n\
\\f\n\
\\STX\EOT\t\DC2\ACK\183\SOH\NUL\186\SOH\SOH\n\
\\v\n\
\\ETX\EOT\t\SOH\DC2\EOT\183\SOH\b\"\n\
\\f\n\
\\EOT\EOT\t\STX\NUL\DC2\EOT\184\SOH\EOT\DC3\n\
\\r\n\
\\ENQ\EOT\t\STX\NUL\ENQ\DC2\EOT\184\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\t\STX\NUL\SOH\DC2\EOT\184\SOH\v\SO\n\
\\r\n\
\\ENQ\EOT\t\STX\NUL\ETX\DC2\EOT\184\SOH\DC1\DC2\n\
\\f\n\
\\EOT\EOT\t\STX\SOH\DC2\EOT\185\SOH\EOT\US\n\
\\r\n\
\\ENQ\EOT\t\STX\SOH\ENQ\DC2\EOT\185\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\t\STX\SOH\SOH\DC2\EOT\185\SOH\v\SUB\n\
\\r\n\
\\ENQ\EOT\t\STX\SOH\ETX\DC2\EOT\185\SOH\GS\RS\n\
\\f\n\
\\STX\EOT\n\
\\DC2\ACK\188\SOH\NUL\198\SOH\SOH\n\
\\v\n\
\\ETX\EOT\n\
\\SOH\DC2\EOT\188\SOH\b\DC2\n\
\\f\n\
\\EOT\EOT\n\
\\STX\NUL\DC2\EOT\189\SOH\EOT3\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\NUL\ACK\DC2\EOT\189\SOH\EOT\GS\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\NUL\SOH\DC2\EOT\189\SOH\RS.\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\NUL\ETX\DC2\EOT\189\SOH12\n\
\\f\n\
\\EOT\EOT\n\
\\STX\SOH\DC2\EOT\190\SOH\EOT\CAN\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\SOH\ENQ\DC2\EOT\190\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\SOH\SOH\DC2\EOT\190\SOH\v\DC3\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\SOH\ETX\DC2\EOT\190\SOH\SYN\ETB\n\
\\f\n\
\\EOT\EOT\n\
\\STX\STX\DC2\EOT\191\SOH\EOT\US\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\STX\ENQ\DC2\EOT\191\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\STX\SOH\DC2\EOT\191\SOH\v\SUB\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\STX\ETX\DC2\EOT\191\SOH\GS\RS\n\
\\169\SOH\n\
\\EOT\EOT\n\
\\STX\ETX\DC2\EOT\195\SOH\EOTi\SUB\154\SOH If a worker has opted into the worker versioning feature while polling, its capabilities will\n\
\ appear here.\n\
\ Deprecated. Replaced by deployment_options.\n\
\\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\ETX\ACK\DC2\EOT\195\SOH\EOT4\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\ETX\SOH\DC2\EOT\195\SOH5P\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\ETX\ETX\DC2\EOT\195\SOHST\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\ETX\b\DC2\EOT\195\SOHUh\n\
\\SO\n\
\\ACK\EOT\n\
\\STX\ETX\b\ETX\DC2\EOT\195\SOHVg\n\
\B\n\
\\EOT\EOT\n\
\\STX\EOT\DC2\EOT\197\SOH\EOTN\SUB4 Worker deployment options that SDK sent to server.\n\
\\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\EOT\ACK\DC2\EOT\197\SOH\EOT6\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\EOT\SOH\DC2\EOT\197\SOH7I\n\
\\r\n\
\\ENQ\EOT\n\
\\STX\EOT\ETX\DC2\EOT\197\SOHLM\n\
\\f\n\
\\STX\EOT\v\DC2\ACK\200\SOH\NUL\205\SOH\SOH\n\
\\v\n\
\\ETX\EOT\v\SOH\DC2\EOT\200\SOH\b!\n\
\\f\n\
\\EOT\EOT\v\STX\NUL\DC2\EOT\201\SOH\EOT$\n\
\\r\n\
\\ENQ\EOT\v\STX\NUL\ACK\DC2\EOT\201\SOH\EOT\r\n\
\\r\n\
\\ENQ\EOT\v\STX\NUL\SOH\DC2\EOT\201\SOH\SO\US\n\
\\r\n\
\\ENQ\EOT\v\STX\NUL\ETX\DC2\EOT\201\SOH\"#\n\
\\132\SOH\n\
\\EOT\EOT\v\STX\SOH\DC2\EOT\204\SOH\EOT;\SUBv (-- api-linter: core::0140::prepositions=disabled\n\
\ aip.dev/not-precedent: \"to\" is used to indicate interval. --)\n\
\\n\
\\r\n\
\\ENQ\EOT\v\STX\SOH\ACK\DC2\EOT\204\SOH\EOT\FS\n\
\\r\n\
\\ENQ\EOT\v\STX\SOH\SOH\DC2\EOT\204\SOH\GS6\n\
\\r\n\
\\ENQ\EOT\v\STX\SOH\ETX\DC2\EOT\204\SOH9:\n\
\\212\SOH\n\
\\STX\EOT\f\DC2\ACK\209\SOH\NUL\212\SOH\SOH\SUB\197\SOH Used by the worker versioning APIs, represents an unordered set of one or more versions which are\n\
\ considered to be compatible with each other. Currently the versions are always worker build IDs.\n\
\\n\
\\v\n\
\\ETX\EOT\f\SOH\DC2\EOT\209\SOH\b\FS\n\
\{\n\
\\EOT\EOT\f\STX\NUL\DC2\EOT\211\SOH\EOT\"\SUBm All the compatible versions, unordered, except for the last element, which is considered the set \"default\".\n\
\\n\
\\r\n\
\\ENQ\EOT\f\STX\NUL\EOT\DC2\EOT\211\SOH\EOT\f\n\
\\r\n\
\\ENQ\EOT\f\STX\NUL\ENQ\DC2\EOT\211\SOH\r\DC3\n\
\\r\n\
\\ENQ\EOT\f\STX\NUL\SOH\DC2\EOT\211\SOH\DC4\GS\n\
\\r\n\
\\ENQ\EOT\f\STX\NUL\ETX\DC2\EOT\211\SOH !\n\
\J\n\
\\STX\EOT\r\DC2\ACK\215\SOH\NUL\221\SOH\SOH\SUB< Reachability of tasks for a worker on a single task queue.\n\
\\n\
\\v\n\
\\ETX\EOT\r\SOH\DC2\EOT\215\SOH\b\GS\n\
\\f\n\
\\EOT\EOT\r\STX\NUL\DC2\EOT\216\SOH\EOT\SUB\n\
\\r\n\
\\ENQ\EOT\r\STX\NUL\ENQ\DC2\EOT\216\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\r\STX\NUL\SOH\DC2\EOT\216\SOH\v\NAK\n\
\\r\n\
\\ENQ\EOT\r\STX\NUL\ETX\DC2\EOT\216\SOH\CAN\EM\n\
\\233\SOH\n\
\\EOT\EOT\r\STX\SOH\DC2\EOT\220\SOH\EOTE\SUB\218\SOH Task reachability for a worker in a single task queue.\n\
\ See the TaskReachability docstring for information about each enum variant.\n\
\ If reachability is empty, this worker is considered unreachable in this task queue.\n\
\\n\
\\r\n\
\\ENQ\EOT\r\STX\SOH\EOT\DC2\EOT\220\SOH\EOT\f\n\
\\r\n\
\\ENQ\EOT\r\STX\SOH\ACK\DC2\EOT\220\SOH\r3\n\
\\r\n\
\\ENQ\EOT\r\STX\SOH\SOH\DC2\EOT\220\SOH4@\n\
\\r\n\
\\ENQ\EOT\r\STX\SOH\ETX\DC2\EOT\220\SOHCD\n\
\[\n\
\\STX\EOT\SO\DC2\ACK\224\SOH\NUL\229\SOH\SOH\SUBM Reachability of tasks for a worker by build id, in one or more task queues.\n\
\\n\
\\v\n\
\\ETX\EOT\SO\SOH\DC2\EOT\224\SOH\b\ESC\n\
\3\n\
\\EOT\EOT\SO\STX\NUL\DC2\EOT\226\SOH\EOT\CAN\SUB% A build id or empty if unversioned.\n\
\\n\
\\r\n\
\\ENQ\EOT\SO\STX\NUL\ENQ\DC2\EOT\226\SOH\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\SO\STX\NUL\SOH\DC2\EOT\226\SOH\v\DC3\n\
\\r\n\
\\ENQ\EOT\SO\STX\NUL\ETX\DC2\EOT\226\SOH\SYN\ETB\n\
\,\n\
\\EOT\EOT\SO\STX\SOH\DC2\EOT\228\SOH\EOT?\SUB\RS Reachability per task queue.\n\
\\n\
\\r\n\
\\ENQ\EOT\SO\STX\SOH\EOT\DC2\EOT\228\SOH\EOT\f\n\
\\r\n\
\\ENQ\EOT\SO\STX\SOH\ACK\DC2\EOT\228\SOH\r\"\n\
\\r\n\
\\ENQ\EOT\SO\STX\SOH\SOH\DC2\EOT\228\SOH#:\n\
\\r\n\
\\ENQ\EOT\SO\STX\SOH\ETX\DC2\EOT\228\SOH=>\n\
\\f\n\
\\STX\EOT\SI\DC2\ACK\231\SOH\NUL\234\SOH\SOH\n\
\\v\n\
\\ETX\EOT\SI\SOH\DC2\EOT\231\SOH\b\CAN\n\
\,\n\
\\EOT\EOT\SI\STX\NUL\DC2\EOT\233\SOH\EOT\RS\SUB\RS Acceptable range is [0,100).\n\
\\n\
\\r\n\
\\ENQ\EOT\SI\STX\NUL\ENQ\DC2\EOT\233\SOH\EOT\t\n\
\\r\n\
\\ENQ\EOT\SI\STX\NUL\SOH\DC2\EOT\233\SOH\n\
\\EM\n\
\\r\n\
\\ENQ\EOT\SI\STX\NUL\ETX\DC2\EOT\233\SOH\FS\GS\n\
\\190\SI\n\
\\STX\EOT\DLE\DC2\ACK\145\STX\NUL\158\STX\SOH\SUB\175\SI Assignment rules are applied to *new* Workflow and Activity executions at\n\
\ schedule time to assign them to a Build ID.\n\
\\n\
\ Assignment rules will not be used in the following cases:\n\
\ - Child Workflows or Continue-As-New Executions who inherit their\n\
\ parent/previous Workflow's assigned Build ID (by setting the\n\
\ `inherit_build_id` flag - default behavior in SDKs when the same Task Queue\n\
\ is used.)\n\
\ - An Activity that inherits the assigned Build ID of its Workflow (by\n\
\ setting the `use_workflow_build_id` flag - default behavior in SDKs\n\
\ when the same Task Queue is used.)\n\
\\n\
\ In absence of (applicable) redirect rules (`CompatibleBuildIdRedirectRule`s)\n\
\ the task will be dispatched to Workers of the Build ID determined by the\n\
\ assignment rules (or inherited). Otherwise, the final Build ID will be\n\
\ determined by the redirect rules.\n\
\\n\
\ Once a Workflow completes its first Workflow Task in a particular Build ID it\n\
\ stays in that Build ID regardless of changes to assignment rules. Redirect\n\
\ rules can be used to move the workflow to another compatible Build ID.\n\
\\n\
\ When using Worker Versioning on a Task Queue, in the steady state,\n\
\ there should typically be a single assignment rule to send all new executions\n\
\ to the latest Build ID. Existence of at least one such \"unconditional\"\n\
\ rule at all times is enforces by the system, unless the `force` flag is used\n\
\ by the user when replacing/deleting these rules (for exceptional cases).\n\
\\n\
\ During a deployment, one or more additional rules can be added to assign a\n\
\ subset of the tasks to a new Build ID based on a \"ramp percentage\".\n\
\\n\
\ When there are multiple assignment rules for a Task Queue, the rules are\n\
\ evaluated in order, starting from index 0. The first applicable rule will be\n\
\ applied and the rest will be ignored.\n\
\\n\
\ In the event that no assignment rule is applicable on a task (or the Task\n\
\ Queue is simply not versioned), the tasks will be dispatched to an\n\
\ unversioned Worker.\n\
\\n\
\\v\n\
\\ETX\EOT\DLE\SOH\DC2\EOT\145\STX\b\GS\n\
\\f\n\
\\EOT\EOT\DLE\STX\NUL\DC2\EOT\146\STX\EOT\US\n\
\\r\n\
\\ENQ\EOT\DLE\STX\NUL\ENQ\DC2\EOT\146\STX\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\DLE\STX\NUL\SOH\DC2\EOT\146\STX\v\SUB\n\
\\r\n\
\\ENQ\EOT\DLE\STX\NUL\ETX\DC2\EOT\146\STX\GS\RS\n\
\\240\SOH\n\
\\EOT\EOT\DLE\b\NUL\DC2\ACK\152\STX\EOT\157\STX\ENQ\SUB\223\SOH If a ramp is provided, this rule will be applied only to a sample of\n\
\ tasks according to the provided percentage.\n\
\ This option can be used only on \"terminal\" Build IDs (the ones not used\n\
\ as source in any redirect rules).\n\
\\n\
\\r\n\
\\ENQ\EOT\DLE\b\NUL\SOH\DC2\EOT\152\STX\n\
\\SO\n\
\\167\SOH\n\
\\EOT\EOT\DLE\STX\SOH\DC2\EOT\156\STX\b-\SUB\152\SOH This ramp is useful for gradual Blue/Green deployments (and similar)\n\
\ where you want to send a certain portion of the traffic to the target\n\
\ Build ID.\n\
\\n\
\\r\n\
\\ENQ\EOT\DLE\STX\SOH\ACK\DC2\EOT\156\STX\b\CAN\n\
\\r\n\
\\ENQ\EOT\DLE\STX\SOH\SOH\DC2\EOT\156\STX\EM(\n\
\\r\n\
\\ENQ\EOT\DLE\STX\SOH\ETX\DC2\EOT\156\STX+,\n\
\\144\a\n\
\\STX\EOT\DC1\DC2\ACK\180\STX\NUL\187\STX\SOH\SUB\129\a These rules apply to tasks assigned to a particular Build ID\n\
\ (`source_build_id`) to redirect them to another *compatible* Build ID\n\
\ (`target_build_id`).\n\
\\n\
\ It is user's responsibility to ensure that the target Build ID is compatible\n\
\ with the source Build ID (e.g. by using the Patching API).\n\
\\n\
\ Most deployments are not expected to need these rules, however following\n\
\ situations can greatly benefit from redirects:\n\
\ - Need to move long-running Workflow Executions from an old Build ID to a\n\
\ newer one.\n\
\ - Need to hotfix some broken or stuck Workflow Executions.\n\
\\n\
\ In steady state, redirect rules are beneficial when dealing with old\n\
\ Executions ran on now-decommissioned Build IDs:\n\
\ - To redirecting the Workflow Queries to the current (compatible) Build ID.\n\
\ - To be able to Reset an old Execution so it can run on the current\n\
\ (compatible) Build ID.\n\
\\n\
\ Redirect rules can be chained.\n\
\\n\
\\v\n\
\\ETX\EOT\DC1\SOH\DC2\EOT\180\STX\b%\n\
\\f\n\
\\EOT\EOT\DC1\STX\NUL\DC2\EOT\181\STX\EOT\US\n\
\\r\n\
\\ENQ\EOT\DC1\STX\NUL\ENQ\DC2\EOT\181\STX\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\DC1\STX\NUL\SOH\DC2\EOT\181\STX\v\SUB\n\
\\r\n\
\\ENQ\EOT\DC1\STX\NUL\ETX\DC2\EOT\181\STX\GS\RS\n\
\\240\SOH\n\
\\EOT\EOT\DC1\STX\SOH\DC2\EOT\186\STX\EOT\US\SUB\225\SOH Target Build ID must be compatible with the Source Build ID; that is it\n\
\ must be able to process event histories made by the Source Build ID by\n\
\ using [Patching](https://docs.temporal.io/workflows#patching) or other\n\
\ means.\n\
\\n\
\\r\n\
\\ENQ\EOT\DC1\STX\SOH\ENQ\DC2\EOT\186\STX\EOT\n\
\\n\
\\r\n\
\\ENQ\EOT\DC1\STX\SOH\SOH\DC2\EOT\186\STX\v\SUB\n\
\\r\n\
\\ENQ\EOT\DC1\STX\SOH\ETX\DC2\EOT\186\STX\GS\RS\n\
\\f\n\
\\STX\EOT\DC2\DC2\ACK\189\STX\NUL\192\STX\SOH\n\
\\v\n\
\\ETX\EOT\DC2\SOH\DC2\EOT\189\STX\b(\n\
\\f\n\
\\EOT\EOT\DC2\STX\NUL\DC2\EOT\190\STX\EOT#\n\
\\r\n\
\\ENQ\EOT\DC2\STX\NUL\ACK\DC2\EOT\190\STX\EOT\EM\n\
\\r\n\
\\ENQ\EOT\DC2\STX\NUL\SOH\DC2\EOT\190\STX\SUB\RS\n\
\\r\n\
\\ENQ\EOT\DC2\STX\NUL\ETX\DC2\EOT\190\STX!\"\n\
\\f\n\
\\EOT\EOT\DC2\STX\SOH\DC2\EOT\191\STX\EOT.\n\
\\r\n\
\\ENQ\EOT\DC2\STX\SOH\ACK\DC2\EOT\191\STX\EOT\GS\n\
\\r\n\
\\ENQ\EOT\DC2\STX\SOH\SOH\DC2\EOT\191\STX\RS)\n\
\\r\n\
\\ENQ\EOT\DC2\STX\SOH\ETX\DC2\EOT\191\STX,-\n\
\\f\n\
\\STX\EOT\DC3\DC2\ACK\194\STX\NUL\197\STX\SOH\n\
\\v\n\
\\ETX\EOT\DC3\SOH\DC2\EOT\194\STX\b0\n\
\\f\n\
\\EOT\EOT\DC3\STX\NUL\DC2\EOT\195\STX\EOT+\n\
\\r\n\
\\ENQ\EOT\DC3\STX\NUL\ACK\DC2\EOT\195\STX\EOT!\n\
\\r\n\
\\ENQ\EOT\DC3\STX\NUL\SOH\DC2\EOT\195\STX\"&\n\
\\r\n\
\\ENQ\EOT\DC3\STX\NUL\ETX\DC2\EOT\195\STX)*\n\
\\f\n\
\\EOT\EOT\DC3\STX\SOH\DC2\EOT\196\STX\EOT.\n\
\\r\n\
\\ENQ\EOT\DC3\STX\SOH\ACK\DC2\EOT\196\STX\EOT\GS\n\
\\r\n\
\\ENQ\EOT\DC3\STX\SOH\SOH\DC2\EOT\196\STX\RS)\n\
\\r\n\
\\ENQ\EOT\DC3\STX\SOH\ETX\DC2\EOT\196\STX,-\n\
\s\n\
\\STX\EOT\DC4\DC2\ACK\201\STX\NUL\209\STX\SOH\SUBe Attached to task responses to give hints to the SDK about how it may adjust its number of\n\
\ pollers.\n\
\\n\
\\v\n\
\\ETX\EOT\DC4\SOH\DC2\EOT\201\STX\b\GS\n\
\\220\STX\n\
\\EOT\EOT\DC4\STX\NUL\DC2\EOT\208\STX\STX*\SUB\205\STX How many poll requests to suggest should be added or removed, if any. As of now, server only\n\
\ scales up or down by 1. However, SDKs should allow for other values (while staying within\n\
\ defined min/max).\n\
\\n\
\ The SDK is free to ignore this suggestion, EX: making more polls would not make sense because\n\
\ all slots are already occupied.\n\
\\n\
\\r\n\
\\ENQ\EOT\DC4\STX\NUL\ENQ\DC2\EOT\208\STX\STX\a\n\
\\r\n\
\\ENQ\EOT\DC4\STX\NUL\SOH\DC2\EOT\208\STX\b%\n\
\\r\n\
\\ENQ\EOT\DC4\STX\NUL\ETX\DC2\EOT\208\STX()b\ACKproto3"