Class GetModelEvents

java.lang.Object

io.fluxzero.common.api.Request

io.fluxzero.common.api.modeling.GetModelEvents

All Implemented Interfaces:

JsonType

Direct Known Subclasses:

GetModelEventsByIdentity

public class GetModelEvents
extends Request

Batch-loads independent model stream memberships at one namespace-wide state boundary.

A current boundary pins the committed boundary atomically with the model-head read. State, commit and event selectors perform the corresponding as-of load. A stream request with maxSize == 0 requests only its head. Retained historical head metadata can be read even when the corresponding event history is incomplete; requesting event membership still requires that history. Older Runtimes may reject these historical head-only reads; this does not prevent existing current reads or writes. maxBytes bounds the total deduplicated complete event messages selected by the runtime. The oldest single event message is always allowed through to guarantee progress, even when it exceeds that bound.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GetModelEvents.Metric

Constructor Summary

Constructors

Constructor	Description
GetModelEvents(List<ModelEventStreamRequest> requests, ModelReadBoundary boundary, long maxBytes)

Method Summary

Modifier and Type	Method	Description
GetModelEvents.Metric	toMetric()	Converts this object into a compact metric representation for logging or monitoring.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GetModelEvents

@ConstructorProperties({"requests","boundary","maxBytes"})
public GetModelEvents(List<ModelEventStreamRequest> requests,
 ModelReadBoundary boundary,
 long maxBytes)

Method Details

toMetric

public GetModelEvents.Metric toMetric()

Description copied from interface: JsonType

Converts this object into a compact metric representation for logging or monitoring.

Used by the Fluxzero Java SDK to avoid logging large payloads directly while still tracking platform usage.

Returns:

a safe and compact object suitable for serialization to the metrics log