proxystore.stream.events¶
Event metadata type.
Warning
Event types are not considered as part of the public API and may change
at any time without warning. Events
are created and consumed internally by the
StreamProducer and
StreamConsumer and
never exposed to client code.
EndOfStreamEvent
dataclass
¶
End of stream event.
from_dict()
classmethod
¶
from_dict(data: dict[str, Any]) -> EndOfStreamEvent
NewObjectEvent
dataclass
¶
EventBatch
dataclass
¶
EventBatch(
events: list[Event],
topic: str,
store_config: StoreConfig,
)
Batch of stream events.
from_dict()
classmethod
¶
from_dict(data: dict[str, Any]) -> EventBatch
Create a new event instance from its dictionary representation.
Source code in proxystore/stream/events.py
event_to_dict() ¶
event_to_dict(event: Event | EventBatch) -> dict[str, Any]
Convert event to dict.
Source code in proxystore/stream/events.py
event_to_bytes() ¶
event_to_bytes(event: Event | EventBatch) -> bytes