Coverage for integrations / channels / queue / __init__.py: 100.0%

1""" 

2Message Queue Package 

3 

4Provides message queue infrastructure for channel messaging. 

5 

6Components: 

7- Message Queue: Queue policies (DROP, LATEST, BACKLOG, PRIORITY, COLLECT) 

8- Debounce: Collect rapid-fire messages into batches 

9- Dedupe: Prevent duplicate message processing 

10- Concurrency: Control concurrent processing limits 

11- Rate Limit: Prevent abuse and comply with API limits 

12- Retry: Handle transient failures with backoff 

13""" 

14 

15from .message_queue import ( 

16 QueuePolicy, 

17 DropPolicy, 

18 DedupeMode as QueueDedupeMode, 

19 QueuedMessage, 

20 QueueConfig, 

21 QueueStats, 

22 MessageQueue, 

23 QueueManager, 

24 get_queue_manager, 

25) 

26 

27from .debounce import ( 

28 DebounceConfig, 

29 DebounceStats, 

30 DebounceBuffer, 

31 InboundDebouncer, 

32 SyncDebouncer, 

33) 

34 

35from .dedupe import ( 

36 DedupeMode, 

37 DedupeConfig, 

38 DedupeStats, 

39 DedupeEntry, 

40 MessageDeduplicator, 

41 SimpleDeduplicator, 

42) 

43 

44from .concurrency import ( 

45 ConcurrencyLimits, 

46 ConcurrencyStats, 

47 ConcurrencySlot, 

48 ConcurrencyController, 

49) 

50 

51from .rate_limit import ( 

52 RateLimitResult, 

53 RateLimitConfig, 

54 RateLimitInfo, 

55 RateLimitStats, 

56 SlidingWindowCounter, 

57 TokenBucket, 

58 RateLimiter, 

59) 

60 

61from .retry import ( 

62 RetryResult, 

63 RetryConfig, 

64 RetryStats, 

65 RetryAttempt, 

66 RetryHandler, 

67 retry_async, 

68 retry_sync, 

69) 

70 

71__all__ = [ 

72 # Message Queue 

73 "QueuePolicy", 

74 "DropPolicy", 

75 "QueueDedupeMode", 

76 "QueuedMessage", 

77 "QueueConfig", 

78 "QueueStats", 

79 "MessageQueue", 

80 "QueueManager", 

81 "get_queue_manager", 

82 # Debounce 

83 "DebounceConfig", 

84 "DebounceStats", 

85 "DebounceBuffer", 

86 "InboundDebouncer", 

87 "SyncDebouncer", 

88 # Dedupe 

89 "DedupeMode", 

90 "DedupeConfig", 

91 "DedupeStats", 

92 "DedupeEntry", 

93 "MessageDeduplicator", 

94 "SimpleDeduplicator", 

95 # Concurrency 

96 "ConcurrencyLimits", 

97 "ConcurrencyStats", 

98 "ConcurrencySlot", 

99 "ConcurrencyController", 

100 # Rate Limit 

101 "RateLimitResult", 

102 "RateLimitConfig", 

103 "RateLimitInfo", 

104 "RateLimitStats", 

105 "SlidingWindowCounter", 

106 "TokenBucket", 

107 "RateLimiter", 

108 # Retry 

109 "RetryResult", 

110 "RetryConfig", 

111 "RetryStats", 

112 "RetryAttempt", 

113 "RetryHandler", 

114 "retry_async", 

115 "retry_sync", 

116]