Visitar URL original
Keiro.Router.Selection
keiro
Safe HaskellNone
LanguageGHC2024

Keiro.Router.Selection

Description

Closed runtime semantics for bounded declarative router selection.

Synopsis

Documentation

data RecipientLimit Source #

A positive post-deduplication recipient bound.

Instances

Instances details
Generic RecipientLimit Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep RecipientLimit 
Instance details

Defined in Keiro.Router.Selection

type Rep RecipientLimit = D1 ('MetaData "RecipientLimit" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "RecipientLimit" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Natural)))

Methods

from :: RecipientLimit -> Rep RecipientLimit x #

to :: Rep RecipientLimit x -> RecipientLimit #

Show RecipientLimit Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> RecipientLimit -> ShowS #

show :: RecipientLimit -> String #

showList :: [RecipientLimit] -> ShowS #

Eq RecipientLimit Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: RecipientLimit -> RecipientLimit -> Bool #

(/=) :: RecipientLimit -> RecipientLimit -> Bool #

Ord RecipientLimit Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: RecipientLimit -> RecipientLimit -> Ordering #

(<) :: RecipientLimit -> RecipientLimit -> Bool #

(<=) :: RecipientLimit -> RecipientLimit -> Bool #

(>) :: RecipientLimit -> RecipientLimit -> Bool #

(>=) :: RecipientLimit -> RecipientLimit -> Bool #

max :: RecipientLimit -> RecipientLimit -> RecipientLimit #

min :: RecipientLimit -> RecipientLimit -> RecipientLimit #

type Rep RecipientLimit Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep RecipientLimit = D1 ('MetaData "RecipientLimit" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "RecipientLimit" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Natural)))

mkRecipientLimit :: Natural -> Either RouterSelectionFailure RecipientLimit Source #

recipientLimitValue :: RecipientLimit -> Natural Source #

newtype SelectionIdentity Source #

Stable operator-facing identity for one declarative selection contract.

Constructors

SelectionIdentity Text 

Instances

Instances details
Generic SelectionIdentity Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep SelectionIdentity 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionIdentity = D1 ('MetaData "SelectionIdentity" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "SelectionIdentity" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

Methods

from :: SelectionIdentity -> Rep SelectionIdentity x #

to :: Rep SelectionIdentity x -> SelectionIdentity #

Show SelectionIdentity Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> SelectionIdentity -> ShowS #

show :: SelectionIdentity -> String #

showList :: [SelectionIdentity] -> ShowS #

Eq SelectionIdentity Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: SelectionIdentity -> SelectionIdentity -> Bool #

(/=) :: SelectionIdentity -> SelectionIdentity -> Bool #

Ord SelectionIdentity Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: SelectionIdentity -> SelectionIdentity -> Ordering #

(<) :: SelectionIdentity -> SelectionIdentity -> Bool #

(<=) :: SelectionIdentity -> SelectionIdentity -> Bool #

(>) :: SelectionIdentity -> SelectionIdentity -> Bool #

(>=) :: SelectionIdentity -> SelectionIdentity -> Bool #

max :: SelectionIdentity -> SelectionIdentity -> SelectionIdentity #

min :: SelectionIdentity -> SelectionIdentity -> SelectionIdentity #

type Rep SelectionIdentity Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionIdentity = D1 ('MetaData "SelectionIdentity" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "SelectionIdentity" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

data SelectionVersion Source #

Positive author-controlled semantic edition.

Instances

Instances details
Generic SelectionVersion Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep SelectionVersion 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionVersion = D1 ('MetaData "SelectionVersion" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "SelectionVersion" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Natural)))

Methods

from :: SelectionVersion -> Rep SelectionVersion x #

to :: Rep SelectionVersion x -> SelectionVersion #

Show SelectionVersion Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> SelectionVersion -> ShowS #

show :: SelectionVersion -> String #

showList :: [SelectionVersion] -> ShowS #

Eq SelectionVersion Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: SelectionVersion -> SelectionVersion -> Bool #

(/=) :: SelectionVersion -> SelectionVersion -> Bool #

Ord SelectionVersion Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: SelectionVersion -> SelectionVersion -> Ordering #

(<) :: SelectionVersion -> SelectionVersion -> Bool #

(<=) :: SelectionVersion -> SelectionVersion -> Bool #

(>) :: SelectionVersion -> SelectionVersion -> Bool #

(>=) :: SelectionVersion -> SelectionVersion -> Bool #

max :: SelectionVersion -> SelectionVersion -> SelectionVersion #

min :: SelectionVersion -> SelectionVersion -> SelectionVersion #

type Rep SelectionVersion Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionVersion = D1 ('MetaData "SelectionVersion" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "SelectionVersion" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Natural)))

mkSelectionVersion :: Natural -> Either RouterSelectionFailure SelectionVersion Source #

selectionVersionValue :: SelectionVersion -> Natural Source #

newtype SelectionFingerprint Source #

Lowercase hexadecimal digest of checked selection semantics.

Constructors

SelectionFingerprint Text 

Instances

Instances details
Generic SelectionFingerprint Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep SelectionFingerprint 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionFingerprint = D1 ('MetaData "SelectionFingerprint" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "SelectionFingerprint" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

Methods

from :: SelectionFingerprint -> Rep SelectionFingerprint x #

to :: Rep SelectionFingerprint x -> SelectionFingerprint #

Show SelectionFingerprint Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> SelectionFingerprint -> ShowS #

show :: SelectionFingerprint -> String #

showList :: [SelectionFingerprint] -> ShowS #

Eq SelectionFingerprint Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: SelectionFingerprint -> SelectionFingerprint -> Bool #

(/=) :: SelectionFingerprint -> SelectionFingerprint -> Bool #

Ord SelectionFingerprint Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: SelectionFingerprint -> SelectionFingerprint -> Ordering #

(<) :: SelectionFingerprint -> SelectionFingerprint -> Bool #

(<=) :: SelectionFingerprint -> SelectionFingerprint -> Bool #

(>) :: SelectionFingerprint -> SelectionFingerprint -> Bool #

(>=) :: SelectionFingerprint -> SelectionFingerprint -> Bool #

max :: SelectionFingerprint -> SelectionFingerprint -> SelectionFingerprint #

min :: SelectionFingerprint -> SelectionFingerprint -> SelectionFingerprint #

type Rep SelectionFingerprint Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionFingerprint = D1 ('MetaData "SelectionFingerprint" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'True) (C1 ('MetaCons "SelectionFingerprint" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

data SelectionOrder Source #

Constructors

OrderByTargetStream 

Instances

Instances details
Generic SelectionOrder Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep SelectionOrder 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionOrder = D1 ('MetaData "SelectionOrder" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "OrderByTargetStream" 'PrefixI 'False) (U1 :: Type -> Type))

Methods

from :: SelectionOrder -> Rep SelectionOrder x #

to :: Rep SelectionOrder x -> SelectionOrder #

Show SelectionOrder Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> SelectionOrder -> ShowS #

show :: SelectionOrder -> String #

showList :: [SelectionOrder] -> ShowS #

Eq SelectionOrder Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: SelectionOrder -> SelectionOrder -> Bool #

(/=) :: SelectionOrder -> SelectionOrder -> Bool #

Ord SelectionOrder Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: SelectionOrder -> SelectionOrder -> Ordering #

(<) :: SelectionOrder -> SelectionOrder -> Bool #

(<=) :: SelectionOrder -> SelectionOrder -> Bool #

(>) :: SelectionOrder -> SelectionOrder -> Bool #

(>=) :: SelectionOrder -> SelectionOrder -> Bool #

max :: SelectionOrder -> SelectionOrder -> SelectionOrder #

min :: SelectionOrder -> SelectionOrder -> SelectionOrder #

type Rep SelectionOrder Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionOrder = D1 ('MetaData "SelectionOrder" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "OrderByTargetStream" 'PrefixI 'False) (U1 :: Type -> Type))

data SelectionDedupe Source #

Constructors

DedupeByTargetStream 

Instances

Instances details
Generic SelectionDedupe Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep SelectionDedupe 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionDedupe = D1 ('MetaData "SelectionDedupe" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "DedupeByTargetStream" 'PrefixI 'False) (U1 :: Type -> Type))

Methods

from :: SelectionDedupe -> Rep SelectionDedupe x #

to :: Rep SelectionDedupe x -> SelectionDedupe #

Show SelectionDedupe Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> SelectionDedupe -> ShowS #

show :: SelectionDedupe -> String #

showList :: [SelectionDedupe] -> ShowS #

Eq SelectionDedupe Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: SelectionDedupe -> SelectionDedupe -> Bool #

(/=) :: SelectionDedupe -> SelectionDedupe -> Bool #

Ord SelectionDedupe Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: SelectionDedupe -> SelectionDedupe -> Ordering #

(<) :: SelectionDedupe -> SelectionDedupe -> Bool #

(<=) :: SelectionDedupe -> SelectionDedupe -> Bool #

(>) :: SelectionDedupe -> SelectionDedupe -> Bool #

(>=) :: SelectionDedupe -> SelectionDedupe -> Bool #

max :: SelectionDedupe -> SelectionDedupe -> SelectionDedupe #

min :: SelectionDedupe -> SelectionDedupe -> SelectionDedupe #

type Rep SelectionDedupe Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionDedupe = D1 ('MetaData "SelectionDedupe" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "DedupeByTargetStream" 'PrefixI 'False) (U1 :: Type -> Type))

data RedeliveryPolicy Source #

Constructors

StableUnion 

Instances

Instances details
Generic RedeliveryPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep RedeliveryPolicy 
Instance details

Defined in Keiro.Router.Selection

type Rep RedeliveryPolicy = D1 ('MetaData "RedeliveryPolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "StableUnion" 'PrefixI 'False) (U1 :: Type -> Type))

Methods

from :: RedeliveryPolicy -> Rep RedeliveryPolicy x #

to :: Rep RedeliveryPolicy x -> RedeliveryPolicy #

Show RedeliveryPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> RedeliveryPolicy -> ShowS #

show :: RedeliveryPolicy -> String #

showList :: [RedeliveryPolicy] -> ShowS #

Eq RedeliveryPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: RedeliveryPolicy -> RedeliveryPolicy -> Bool #

(/=) :: RedeliveryPolicy -> RedeliveryPolicy -> Bool #

Ord RedeliveryPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: RedeliveryPolicy -> RedeliveryPolicy -> Ordering #

(<) :: RedeliveryPolicy -> RedeliveryPolicy -> Bool #

(<=) :: RedeliveryPolicy -> RedeliveryPolicy -> Bool #

(>) :: RedeliveryPolicy -> RedeliveryPolicy -> Bool #

(>=) :: RedeliveryPolicy -> RedeliveryPolicy -> Bool #

max :: RedeliveryPolicy -> RedeliveryPolicy -> RedeliveryPolicy #

min :: RedeliveryPolicy -> RedeliveryPolicy -> RedeliveryPolicy #

type Rep RedeliveryPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep RedeliveryPolicy = D1 ('MetaData "RedeliveryPolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "StableUnion" 'PrefixI 'False) (U1 :: Type -> Type))

data PartialDispatchPolicy Source #

Constructors

RetainSuccesses 

Instances

Instances details
Generic PartialDispatchPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep PartialDispatchPolicy 
Instance details

Defined in Keiro.Router.Selection

type Rep PartialDispatchPolicy = D1 ('MetaData "PartialDispatchPolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "RetainSuccesses" 'PrefixI 'False) (U1 :: Type -> Type))

Methods

from :: PartialDispatchPolicy -> Rep PartialDispatchPolicy x #

to :: Rep PartialDispatchPolicy x -> PartialDispatchPolicy #

Show PartialDispatchPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> PartialDispatchPolicy -> ShowS #

show :: PartialDispatchPolicy -> String #

showList :: [PartialDispatchPolicy] -> ShowS #

Eq PartialDispatchPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: PartialDispatchPolicy -> PartialDispatchPolicy -> Bool #

(/=) :: PartialDispatchPolicy -> PartialDispatchPolicy -> Bool #

Ord PartialDispatchPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: PartialDispatchPolicy -> PartialDispatchPolicy -> Ordering #

(<) :: PartialDispatchPolicy -> PartialDispatchPolicy -> Bool #

(<=) :: PartialDispatchPolicy -> PartialDispatchPolicy -> Bool #

(>) :: PartialDispatchPolicy -> PartialDispatchPolicy -> Bool #

(>=) :: PartialDispatchPolicy -> PartialDispatchPolicy -> Bool #

max :: PartialDispatchPolicy -> PartialDispatchPolicy -> PartialDispatchPolicy #

min :: PartialDispatchPolicy -> PartialDispatchPolicy -> PartialDispatchPolicy #

type Rep PartialDispatchPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep PartialDispatchPolicy = D1 ('MetaData "PartialDispatchPolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "RetainSuccesses" 'PrefixI 'False) (U1 :: Type -> Type))

data EmptySelectionPolicy Source #

Constructors

EmptyAck 
EmptyRetry 
EmptyDeadLetter 
EmptyHalt 

Instances

Instances details
Generic EmptySelectionPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep EmptySelectionPolicy 
Instance details

Defined in Keiro.Router.Selection

type Rep EmptySelectionPolicy = D1 ('MetaData "EmptySelectionPolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) ((C1 ('MetaCons "EmptyAck" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "EmptyRetry" 'PrefixI 'False) (U1 :: Type -> Type)) :+: (C1 ('MetaCons "EmptyDeadLetter" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "EmptyHalt" 'PrefixI 'False) (U1 :: Type -> Type)))

Methods

from :: EmptySelectionPolicy -> Rep EmptySelectionPolicy x #

to :: Rep EmptySelectionPolicy x -> EmptySelectionPolicy #

Show EmptySelectionPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> EmptySelectionPolicy -> ShowS #

show :: EmptySelectionPolicy -> String #

showList :: [EmptySelectionPolicy] -> ShowS #

Eq EmptySelectionPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: EmptySelectionPolicy -> EmptySelectionPolicy -> Bool #

(/=) :: EmptySelectionPolicy -> EmptySelectionPolicy -> Bool #

Ord EmptySelectionPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: EmptySelectionPolicy -> EmptySelectionPolicy -> Ordering #

(<) :: EmptySelectionPolicy -> EmptySelectionPolicy -> Bool #

(<=) :: EmptySelectionPolicy -> EmptySelectionPolicy -> Bool #

(>) :: EmptySelectionPolicy -> EmptySelectionPolicy -> Bool #

(>=) :: EmptySelectionPolicy -> EmptySelectionPolicy -> Bool #

max :: EmptySelectionPolicy -> EmptySelectionPolicy -> EmptySelectionPolicy #

min :: EmptySelectionPolicy -> EmptySelectionPolicy -> EmptySelectionPolicy #

type Rep EmptySelectionPolicy Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep EmptySelectionPolicy = D1 ('MetaData "EmptySelectionPolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) ((C1 ('MetaCons "EmptyAck" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "EmptyRetry" 'PrefixI 'False) (U1 :: Type -> Type)) :+: (C1 ('MetaCons "EmptyDeadLetter" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "EmptyHalt" 'PrefixI 'False) (U1 :: Type -> Type)))

data SelectionFailurePolicy Source #

Constructors

FailureRetry 
FailureDeadLetter 
FailureHalt 

Instances

Instances details
Generic SelectionFailurePolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep SelectionFailurePolicy 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionFailurePolicy = D1 ('MetaData "SelectionFailurePolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "FailureRetry" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "FailureDeadLetter" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "FailureHalt" 'PrefixI 'False) (U1 :: Type -> Type)))

Methods

from :: SelectionFailurePolicy -> Rep SelectionFailurePolicy x #

to :: Rep SelectionFailurePolicy x -> SelectionFailurePolicy #

Show SelectionFailurePolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> SelectionFailurePolicy -> ShowS #

show :: SelectionFailurePolicy -> String #

showList :: [SelectionFailurePolicy] -> ShowS #

Eq SelectionFailurePolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: SelectionFailurePolicy -> SelectionFailurePolicy -> Bool #

(/=) :: SelectionFailurePolicy -> SelectionFailurePolicy -> Bool #

Ord SelectionFailurePolicy Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

compare :: SelectionFailurePolicy -> SelectionFailurePolicy -> Ordering #

(<) :: SelectionFailurePolicy -> SelectionFailurePolicy -> Bool #

(<=) :: SelectionFailurePolicy -> SelectionFailurePolicy -> Bool #

(>) :: SelectionFailurePolicy -> SelectionFailurePolicy -> Bool #

(>=) :: SelectionFailurePolicy -> SelectionFailurePolicy -> Bool #

max :: SelectionFailurePolicy -> SelectionFailurePolicy -> SelectionFailurePolicy #

min :: SelectionFailurePolicy -> SelectionFailurePolicy -> SelectionFailurePolicy #

type Rep SelectionFailurePolicy Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep SelectionFailurePolicy = D1 ('MetaData "SelectionFailurePolicy" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "FailureRetry" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "FailureDeadLetter" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "FailureHalt" 'PrefixI 'False) (U1 :: Type -> Type)))

data RouterSelectionContract Source #

Constructors

RouterSelectionContract 

Fields

Instances

Instances details
Generic RouterSelectionContract Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep RouterSelectionContract 
Instance details

Defined in Keiro.Router.Selection

type Rep RouterSelectionContract = D1 ('MetaData "RouterSelectionContract" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "RouterSelectionContract" 'PrefixI 'True) (((S1 ('MetaSel ('Just "identity") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionIdentity) :*: S1 ('MetaSel ('Just "version") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionVersion)) :*: (S1 ('MetaSel ('Just "fingerprint") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionFingerprint) :*: (S1 ('MetaSel ('Just "limit") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RecipientLimit) :*: S1 ('MetaSel ('Just "order") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionOrder)))) :*: ((S1 ('MetaSel ('Just "dedupe") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionDedupe) :*: S1 ('MetaSel ('Just "emptyPolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 EmptySelectionPolicy)) :*: (S1 ('MetaSel ('Just "failurePolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionFailurePolicy) :*: (S1 ('MetaSel ('Just "redeliveryPolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RedeliveryPolicy) :*: S1 ('MetaSel ('Just "partialPolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 PartialDispatchPolicy))))))

Methods

from :: RouterSelectionContract -> Rep RouterSelectionContract x #

to :: Rep RouterSelectionContract x -> RouterSelectionContract #

Show RouterSelectionContract Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> RouterSelectionContract -> ShowS #

show :: RouterSelectionContract -> String #

showList :: [RouterSelectionContract] -> ShowS #

Eq RouterSelectionContract Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: RouterSelectionContract -> RouterSelectionContract -> Bool #

(/=) :: RouterSelectionContract -> RouterSelectionContract -> Bool #

type Rep RouterSelectionContract Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep RouterSelectionContract = D1 ('MetaData "RouterSelectionContract" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) (C1 ('MetaCons "RouterSelectionContract" 'PrefixI 'True) (((S1 ('MetaSel ('Just "identity") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionIdentity) :*: S1 ('MetaSel ('Just "version") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionVersion)) :*: (S1 ('MetaSel ('Just "fingerprint") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionFingerprint) :*: (S1 ('MetaSel ('Just "limit") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RecipientLimit) :*: S1 ('MetaSel ('Just "order") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionOrder)))) :*: ((S1 ('MetaSel ('Just "dedupe") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionDedupe) :*: S1 ('MetaSel ('Just "emptyPolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 EmptySelectionPolicy)) :*: (S1 ('MetaSel ('Just "failurePolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 SelectionFailurePolicy) :*: (S1 ('MetaSel ('Just "redeliveryPolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RedeliveryPolicy) :*: S1 ('MetaSel ('Just "partialPolicy") 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 PartialDispatchPolicy))))))

data RouterSelectionFailure Source #

Constructors

SelectionQueryFailed !Text 
SelectionEvaluationFailed !Text 
SelectionConflictingCommands !StreamName 
SelectionRecipientOverflow !RecipientLimit !Natural 

Instances

Instances details
Generic RouterSelectionFailure Source # 
Instance details

Defined in Keiro.Router.Selection

Associated Types

type Rep RouterSelectionFailure 
Instance details

Defined in Keiro.Router.Selection

type Rep RouterSelectionFailure = D1 ('MetaData "RouterSelectionFailure" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) ((C1 ('MetaCons "SelectionQueryFailed" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Text)) :+: C1 ('MetaCons "SelectionEvaluationFailed" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Text))) :+: (C1 ('MetaCons "SelectionConflictingCommands" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 StreamName)) :+: C1 ('MetaCons "SelectionRecipientOverflow" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RecipientLimit) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Natural))))

Methods

from :: RouterSelectionFailure -> Rep RouterSelectionFailure x #

to :: Rep RouterSelectionFailure x -> RouterSelectionFailure #

Show RouterSelectionFailure Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

showsPrec :: Int -> RouterSelectionFailure -> ShowS #

show :: RouterSelectionFailure -> String #

showList :: [RouterSelectionFailure] -> ShowS #

Eq RouterSelectionFailure Source # 
Instance details

Defined in Keiro.Router.Selection

Methods

(==) :: RouterSelectionFailure -> RouterSelectionFailure -> Bool #

(/=) :: RouterSelectionFailure -> RouterSelectionFailure -> Bool #

type Rep RouterSelectionFailure Source # 
Instance details

Defined in Keiro.Router.Selection

type Rep RouterSelectionFailure = D1 ('MetaData "RouterSelectionFailure" "Keiro.Router.Selection" "keiro-0.24.0.0-inplace" 'False) ((C1 ('MetaCons "SelectionQueryFailed" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Text)) :+: C1 ('MetaCons "SelectionEvaluationFailed" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Text))) :+: (C1 ('MetaCons "SelectionConflictingCommands" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 StreamName)) :+: C1 ('MetaCons "SelectionRecipientOverflow" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 RecipientLimit) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Natural))))

normalizeRecipients :: Eq targetCi => RecipientLimit -> [PMCommand targetCi] -> Either RouterSelectionFailure [PMCommand targetCi] Source #

Sort by physical target stream, collapse exact duplicates, reject unequal commands for one target, and apply the positive cap after deduplication.

emptySelectionDeadLetterReason :: RouterSelectionContract -> DeadLetterReason Source #

selectionFailureDeadLetterReason :: RouterSelectionContract -> RouterSelectionFailure -> DeadLetterReason Source #