Coverage for src / tracekit / analyzers / packet / __init__.py: 100%

1"""Packet and DAQ analysis package. 

2 

3This module provides packet parsing, streaming analysis, and error-tolerant 

4DAQ features. 

5 

6- RE-PAY-001: Payload Extraction Framework 

7- RE-PAY-002: Payload Pattern Search 

8- RE-PAY-003: Payload Delimiter Detection 

9- RE-PAY-004: Payload Field Inference 

10- RE-PAY-005: Payload Comparison and Differential Analysis 

11""" 

12 

13from tracekit.analyzers.packet.daq import ( 

14 BitErrorAnalysis, 

15 DAQGap, 

16 DAQGapAnalysis, 

17 ErrorPattern, 

18 FuzzyMatch, 

19 JitterCompensationResult, 

20 PacketRecoveryResult, 

21 analyze_bit_errors, 

22 compensate_timestamp_jitter, 

23 detect_gaps, 

24 detect_gaps_by_samples, 

25 detect_gaps_by_timestamps, 

26 error_tolerant_decode, 

27 fuzzy_pattern_search, 

28 robust_packet_parse, 

29) 

30from tracekit.analyzers.packet.metrics import ( 

31 JitterResult, 

32 LatencyResult, 

33 LossResult, 

34 PacketInfo, 

35 ThroughputResult, 

36 jitter, 

37 latency, 

38 loss_rate, 

39 throughput, 

40 windowed_throughput, 

41) 

42from tracekit.analyzers.packet.parser import ( 

43 BinaryParser, 

44 parse_tlv, 

45) 

46 

47# RE-PAY-001 through RE-PAY-005: Payload analysis 

48from tracekit.analyzers.packet.payload import ( 

49 DelimiterResult, 

50 FieldInferrer, 

51 # RE-PAY-004: Field inference 

52 InferredField, 

53 LengthPrefixResult, 

54 MessageBoundary, 

55 MessageSchema, 

56 PatternMatch, 

57 PayloadCluster, 

58 PayloadDiff, 

59 # Classes 

60 PayloadExtractor, 

61 # Data classes 

62 PayloadInfo, 

63 VariablePositions, 

64 cluster_payloads, 

65 compute_similarity, 

66 correlate_request_response, 

67 # RE-PAY-003: Delimiter detection 

68 detect_delimiter, 

69 detect_field_types, 

70 detect_length_prefix, 

71 # RE-PAY-005: Comparison 

72 diff_payloads, 

73 filter_by_pattern, 

74 find_checksum_fields, 

75 find_common_bytes, 

76 find_message_boundaries, 

77 find_sequence_fields, 

78 find_variable_positions, 

79 infer_fields, 

80 # RE-PAY-002: Pattern search 

81 search_pattern, 

82 search_patterns, 

83 segment_messages, 

84) 

85from tracekit.analyzers.packet.stream import ( 

86 StreamPacket, 

87 batch, 

88 pipeline, 

89 skip, 

90 stream_delimited, 

91 stream_file, 

92 stream_packets, 

93 stream_records, 

94 take, 

95) 

96 

97__all__ = [ 

98 # Parser (PKT-001, PKT-002) 

99 "BinaryParser", 

100 "BitErrorAnalysis", 

101 # DAQ Gap Detection (PKT-008) 

102 "DAQGap", 

103 "DAQGapAnalysis", 

104 "DelimiterResult", 

105 "ErrorPattern", 

106 "FieldInferrer", 

107 # DAQ (DAQ-001 through DAQ-005) 

108 "FuzzyMatch", 

109 # RE-PAY-004: Field inference 

110 "InferredField", 

111 "JitterCompensationResult", 

112 "JitterResult", 

113 "LatencyResult", 

114 "LengthPrefixResult", 

115 "LossResult", 

116 "MessageBoundary", 

117 "MessageSchema", 

118 # Metrics (PKT-005, PKT-006, PKT-007, PKT-009) 

119 "PacketInfo", 

120 "PacketRecoveryResult", 

121 "PatternMatch", 

122 "PayloadCluster", 

123 "PayloadDiff", 

124 # Other payload exports 

125 "PayloadExtractor", 

126 # RE-PAY-001 through RE-PAY-005: Payload analysis 

127 "PayloadInfo", 

128 # Stream (PKT-003) 

129 "StreamPacket", 

130 "ThroughputResult", 

131 "VariablePositions", 

132 "analyze_bit_errors", 

133 "batch", 

134 "cluster_payloads", 

135 "compensate_timestamp_jitter", 

136 "compute_similarity", 

137 "correlate_request_response", 

138 "detect_delimiter", 

139 "detect_field_types", 

140 "detect_gaps", 

141 "detect_gaps_by_samples", 

142 "detect_gaps_by_timestamps", 

143 "detect_length_prefix", 

144 "diff_payloads", 

145 "error_tolerant_decode", 

146 "filter_by_pattern", 

147 "find_checksum_fields", 

148 "find_common_bytes", 

149 "find_message_boundaries", 

150 "find_sequence_fields", 

151 "find_variable_positions", 

152 "fuzzy_pattern_search", 

153 "infer_fields", 

154 "jitter", 

155 "latency", 

156 "loss_rate", 

157 "parse_tlv", 

158 "pipeline", 

159 "robust_packet_parse", 

160 "search_pattern", 

161 "search_patterns", 

162 "segment_messages", 

163 "skip", 

164 "stream_delimited", 

165 "stream_file", 

166 "stream_packets", 

167 "stream_records", 

168 "take", 

169 "throughput", 

170 "windowed_throughput", 

171]