ThreadQuery

org.llm4s.agent.graph.ThreadQuery
See theThreadQuery companion object
@Experimental
final case class ThreadQuery

A search of the thread registry (Checkpointer.threads): the root threads of one tenant - None and Some differ, as for claims: None finds only threads of no tenant - narrowed by every filter given, newest first by ThreadSummary.updatedAt, at most limit at a time (1 to ThreadQuery.MaxLimit), starting after after.

  • status: only threads of that ThreadStatus;
  • agent: only threads whose latest checkpoint is of that graph (GraphSnapshot.graphId; an Agent's is its id);
  • metadata: only threads whose metadata holds every one of these entries (ThreadMetadata.matches);
  • updatedSince: only threads the store changed at or after this instant, by its clock.

Attributes

Companion
object
Graph
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

def matches(thread: ThreadSummary): Boolean

Whether thread passes every filter but the page's position and size.

Whether thread passes every filter but the page's position and size.

Attributes

def withAfter(cursor: Option[ThreadCursor]): ThreadQuery
def withAgent(a: String): ThreadQuery
def withAgent(a: Option[String]): ThreadQuery
def withLimit(n: Int): ThreadQuery
def withTenantId(t: Option[TenantId]): ThreadQuery
def withUpdatedSince(at: Instant): ThreadQuery
def withUpdatedSince(at: Option[Instant]): ThreadQuery

Inherited methods

def productElementNames: Iterator[String]

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

Attributes

Inherited from:
Product