3i SSKJr SSKJr SSKJrJrJr SSKJ r Jr SSK J r J r SSK Jr "SS\ 5r\"S S 55r\\r"S S \ \ 5rg ))abstractmethod) dataclass)AnyCallableList)EnforceOverrides overrides) ComponentSystem)Segmentcf\rSrSrSr\S\S\S\\ 4Sj5r \S\ \/S4SS4S j5r S r g) SegmentDirectory zA segment directory is a data interface that manages the location of segments. Concretely, this means that for distributed chroma, it provides the grpc endpoint for a segment.segmentnreturncg)zReturn the segment residences for a given segment ID. Will return at most n residences. Should only return less than n residences if there are less than n residences available. N)selfrrs _/home/james-whalen/.local/lib/python3.13/site-packages/chromadb/segment/distributed/__init__.pyget_segment_endpoints&SegmentDirectory.get_segment_endpointsscallbackNcg)zARegister a callback that will be called when a segment is updatedNrrrs r!register_updated_segment_callback2SegmentDirectory.register_updated_segment_callbacks rr)__name__ __module__ __qualname____firstlineno____doc__rr intrstrrrr__static_attributes__rrrrr sdW W  c    'D1   rrc4\rSrSr%\\S'\\S'\\S'Srg)MemberidipnoderN)rr r!r"r%__annotations__r&rrrr(r(s G G Irr(c^\rSrSr%Sr\\\/\4\ S'S\ 4U4Sjjr \ S\4Sj5r \ S\SS 4S j5r\SS j5rS \\/\4SS 4S jrS \\/\4S\4SjrSrU=r$)MemberlistProvider&zReturns the latest memberlist and provdes a callback for when it changes. This callback may be called from a different thread than the one that called. Callers should ensure that they are thread-safe. callbackssystemc2>/Ul[TU] U5 g)N)r1super__init__)rr2 __class__s rr5MemberlistProvider.__init__-s  rrcg)zReturns the latest memberlistNrrs rget_memberlist!MemberlistProvider.get_memberlist1 r memberlistNcg)z1Sets the memberlist that this provider will watchNr)rr=s rset_memberlist_name&MemberlistProvider.set_memberlist_name6r<rc/Ulg)zStops watching the memberlistNr1r9s rstopMemberlistProvider.stop;s rrc:URRU5 g)zRegisters a callback that will be called when the memberlist changes. May be called many times with the same memberlist, so callers should be idempotent. May be called from a different thread. N)r1appendrs r$register_updated_memberlist_callback7MemberlistProvider.register_updated_memberlist_callback@s h'rcZXR;aURRU5 gg)zUnregisters a callback that was previously registered. Returns True if the callback was successfully unregistered, False if it was not ever registered.TF)r1removers r&unregister_updated_memberlist_callback9MemberlistProvider.unregister_updated_memberlist_callbackHs& ~~ % NN ! !( +rrB)rN)rr r!r"r#rr Memberlistrr-r r5rr:r%r?r rCrGboolrKr& __classcell__)r6s@rr/r/&s"Hj\3./00!v!    c d  ( *s!23( ( *s!23 rr/N)abcr dataclassesrtypingrrrr rchromadb.configr r chromadb.typesr rr(rMr/rrrrUsY!&&1-" y $   &\ *$4*r