Coverage for src / lexigram / contracts / data / __init__.py: 0%

1"""Data access protocols.""" 

2 

3from __future__ import annotations 

4 

5from lexigram.contracts.data.aggregatable import AggregatableProtocol 

6from lexigram.contracts.data.bulk_operations import BulkOperationsProtocol 

7from lexigram.contracts.data.data_source import DataSourceProtocol 

8from lexigram.contracts.data.exceptions import UnitOfWorkError 

9from lexigram.contracts.data.graph.protocols import GraphProtocol, GraphStoreProtocol 

10from lexigram.contracts.data.graph.types import ( 

11 GraphEdge, 

12 GraphInfo, 

13 GraphNode, 

14 GraphPath, 

15) 

16from lexigram.contracts.data.identifiers import ( 

17 DEFAULT_MAX_IDENTIFIER_LENGTH, 

18 MAX_IDENTIFIER_LENGTHS, 

19 Column, 

20 Identifier, 

21 QualifiedTable, 

22 Schema, 

23 Table, 

24 column, 

25 schema, 

26 table, 

27) 

28from lexigram.contracts.data.nosql.nosql import ( 

29 BulkWriteResult, 

30 CollectionProtocol, 

31 DocumentResult, 

32 DocumentStoreProtocol, 

33) 

34from lexigram.contracts.data.nosql.nosql_repository import DocumentRepositoryProtocol 

35from lexigram.contracts.data.outbox import OutboxStoreProtocol 

36from lexigram.contracts.data.protocols import ( 

37 AndExpr, 

38 CursorCodecProtocol, 

39 CursorPaginationSpec, 

40 FieldContains, 

41 FieldEq, 

42 FieldGt, 

43 FieldGte, 

44 FieldIn, 

45 FieldLt, 

46 FieldLte, 

47 FieldNeq, 

48 FilterCompilerProtocol, 

49 FilterExpression, 

50 NotExpr, 

51 OrExpr, 

52 PaginationSpec, 

53 PaginatorProtocol, 

54 ProjectionSpec, 

55 QueryFilterProtocol, 

56 SortSpecification, 

57) 

58from lexigram.contracts.data.relation_loader import RelationLoaderProtocol 

59from lexigram.contracts.data.repository import ( 

60 ReadOnlyRepositoryProtocol, 

61 RepositoryProtocol, 

62) 

63from lexigram.contracts.data.searchable import SearchableProtocol 

64from lexigram.contracts.data.sql.append_log import ( 

65 AppendLogProtocol, 

66 AppendLogSnapshotStore, 

67) 

68from lexigram.contracts.data.sql.context_protocol import DatabaseContextProtocol 

69from lexigram.contracts.data.sql.database import ( 

70 ConnectionPoolProtocol, 

71 ConnectionProtocol, 

72 CrudOperationsProtocol, 

73 DatabaseMetricsProtocol, 

74 DatabaseProviderProtocol, 

75 DeleteResult, 

76 HealthMonitorProtocol, 

77 InsertResult, 

78 IsolationLevel, 

79 MigrationManagerProtocol, 

80 MigrationRecord, 

81 QueryResult, 

82 SchemaManagerProtocol, 

83 TransactionManagerProtocol, 

84 UpdateResult, 

85) 

86from lexigram.contracts.data.sql.mapper import ( 

87 DataMapperProtocol, 

88 ReadOnlyMapperProtocol, 

89) 

90from lexigram.contracts.data.sql.migrations import MigrationRunnerProtocol 

91from lexigram.contracts.data.sql.query_log import QueryLogEntry, QueryLoggerProtocol 

92from lexigram.contracts.data.sql.sql import InvalidIdentifierError, RawSQL 

93from lexigram.contracts.data.sql.sql_dialect import SQLDialect 

94from lexigram.contracts.data.sql.unit_of_work import UnitOfWorkProtocol 

95from lexigram.contracts.data.timeseries import TimeSeriesStoreProtocol 

96from lexigram.contracts.data.vector.protocols import ( 

97 VectorCollectionProtocol, 

98 VectorStoreProtocol, 

99) 

100from lexigram.contracts.data.vector.types import ( 

101 CollectionConfig, 

102 CollectionInfo, 

103 SearchQuery, 

104 SearchResult, 

105 VectorRecord, 

106) 

107 

108__all__ = [ 

109 "DEFAULT_MAX_IDENTIFIER_LENGTH", 

110 "MAX_IDENTIFIER_LENGTHS", 

111 "AggregatableProtocol", 

112 "AndExpr", 

113 "AppendLogProtocol", 

114 "AppendLogSnapshotStore", 

115 "BulkOperationsProtocol", 

116 "BulkWriteResult", 

117 "CollectionConfig", 

118 "CollectionInfo", 

119 "CollectionProtocol", 

120 "Column", 

121 "ConnectionPoolProtocol", 

122 "ConnectionProtocol", 

123 "CrudOperationsProtocol", 

124 "CursorCodecProtocol", 

125 "CursorPaginationSpec", 

126 "DataMapperProtocol", 

127 "DataSourceProtocol", 

128 "DatabaseMetricsProtocol", 

129 "DatabaseProviderProtocol", 

130 "DeleteResult", 

131 "DocumentRepositoryProtocol", 

132 "DocumentResult", 

133 "DocumentStoreProtocol", 

134 "FieldContains", 

135 "FieldEq", 

136 "FieldGt", 

137 "FieldGte", 

138 "FieldIn", 

139 "FieldLt", 

140 "FieldLte", 

141 "FieldNeq", 

142 "FilterCompilerProtocol", 

143 "FilterExpression", 

144 "GraphEdge", 

145 "GraphInfo", 

146 "GraphNode", 

147 "GraphPath", 

148 "GraphProtocol", 

149 "GraphStoreProtocol", 

150 "HealthMonitorProtocol", 

151 "Identifier", 

152 "InsertResult", 

153 "InvalidIdentifierError", 

154 "IsolationLevel", 

155 "MigrationManagerProtocol", 

156 "MigrationRecord", 

157 "NotExpr", 

158 "OrExpr", 

159 "OutboxStoreProtocol", 

160 "PaginationSpec", 

161 "PaginatorProtocol", 

162 "ProjectionSpec", 

163 "QualifiedTable", 

164 "QueryFilterProtocol", 

165 "QueryLogEntry", 

166 "QueryLoggerProtocol", 

167 "QueryResult", 

168 "RawSQL", 

169 "ReadOnlyMapperProtocol", 

170 "ReadOnlyRepositoryProtocol", 

171 "RelationLoaderProtocol", 

172 "RepositoryProtocol", 

173 "SQLDialect", 

174 "Schema", 

175 "SchemaManagerProtocol", 

176 "SearchQuery", 

177 "SearchResult", 

178 "SearchableProtocol", 

179 "SortSpecification", 

180 "Table", 

181 "TimeSeriesStoreProtocol", 

182 "TransactionManagerProtocol", 

183 "UnitOfWorkError", 

184 "UnitOfWorkProtocol", 

185 "UpdateResult", 

186 "VectorCollectionProtocol", 

187 "VectorRecord", 

188 "VectorStoreProtocol", 

189 "column", 

190 "schema", 

191 "table", 

192]