Method
StreamLogs
(
ctx context.Context,
query LogsListQuery,
lastEventID string,
handler SSEHandler,
)
Source from the content-addressed store, hash-verified
| 3756 | } |
| 3757 | |
| 3758 | func (c *unixSocketClient) StreamLogs( |
| 3759 | ctx context.Context, |
| 3760 | query LogsListQuery, |
| 3761 | lastEventID string, |
| 3762 | handler SSEHandler, |
| 3763 | ) error { |
| 3764 | return c.doSSE( |
| 3765 | ctx, |
| 3766 | http.MethodGet, |
| 3767 | "/api/logs/stream", |
| 3768 | logsListValues(query), |
| 3769 | nil, |
| 3770 | lastEventID, |
| 3771 | handler, |
| 3772 | ) |
| 3773 | } |
| 3774 | |
| 3775 | func (c *unixSocketClient) MemoryHealth(ctx context.Context, workspace string) (MemoryHealthRecord, error) { |
| 3776 | var response MemoryHealthRecord |