weaviate.cluster

Module for interacting with Weaviate cluster information.

class weaviate.cluster._ClusterAsync(connection)[source]

Bases: _ClusterExecutor[ConnectionAsync]

Parameters:: connection (ConnectionAsync)

class weaviate.cluster._Cluster(connection)[source]

Bases: _ClusterExecutor[ConnectionSync]

Parameters:: connection (ConnectionSync)

weaviate.cluster.types

class weaviate.cluster.types.BatchStats[source]

Bases: TypedDict

queueLength: int

ratePerSecond: int

class weaviate.cluster.types.Shard

Bases: TypedDict

name: str

class: str

objectCount: int

vectorIndexingStatus: Literal['READONLY', 'INDEXING', 'READY']

vectorQueueLength: int

compressed: bool

loaded: bool | None

class weaviate.cluster.types.Stats[source]

Bases: TypedDict

objectCount: int

shardCount: int

class weaviate.cluster.types.Node[source]

Bases: TypedDict

batchStats: BatchStats

gitHash: str

name: str

shards: List[Shard] | None

stats: Stats

status: str

version: str