mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Using replica read only to get subscription events

pull/622/head
kompotkot 2022-05-26 18:09:55 +00:00
rodzic 65166b7c8c
commit f3134d6e08
1 zmienionych plików z 4 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

8
backend/moonstreamapi/routes/streams.py
Wyświetl plik

@ -81,7 +81,7 @@ async def stream_handler(
end_time: Optional[int] = Query(None),
include_start: bool = Query(False),
include_end: bool = Query(False),
db_session: Session = Depends(db.yield_db_session),
db_session: Session = Depends(db.yield_db_read_only_session),
) -> data.GetEventsResponse:
"""
Gets all events in the client's stream subject to the constraints defined by the following query
@ -132,7 +132,7 @@ async def stream_handler(
@router.get("/latest", tags=["streams"])
async def latest_events_handler(
request: Request, q=Query(""), db_session: Session = Depends(db.yield_db_session)
request: Request, q=Query(""), db_session: Session = Depends(db.yield_db_read_only_session)
) -> List[data.Event]:
"""
Gets the latest events in the client's stream subject to the constraints defined by the following query
@ -180,7 +180,7 @@ async def next_event_handler(
end_time: Optional[int] = Query(None),
include_start: bool = Query(False),
include_end: bool = Query(False),
db_session: Session = Depends(db.yield_db_session),
db_session: Session = Depends(db.yield_db_read_only_session),
) -> Optional[data.Event]:
"""
Gets the next event in the client's stream subject to the constraints defined by the following query
@ -235,7 +235,7 @@ async def previous_event_handler(
end_time: Optional[int] = Query(None),
include_start: bool = Query(False),
include_end: bool = Query(False),
db_session: Session = Depends(db.yield_db_session),
db_session: Session = Depends(db.yield_db_read_only_session),
) -> Optional[data.Event]:
"""
Gets the previous event in the client's stream subject to the constraints defined by the following query