Method LogsSubscribeHandler

engine/server/telemetry.go:237–270

nolint:dupl

(w http.ResponseWriter, r *http.Request, client *daggerClient)

//nolint:dupl
func (ps *PubSub) LogsSubscribeHandler(w http.ResponseWriter, r *http.Request, client *daggerClient) error {
	return ps.sseHandler(w, r, client, func(ctx context.Context, db *clientdb.DB, lastID string) (*sse.Event, bool, error) {
		var since int64
		if lastID != "" {
			_, err := fmt.Sscanf(lastID, "%d", &since)
			if err != nil {
				return nil, false, fmt.Errorf("invalid last ID: %w", err)
			}
		}
		logs, err := db.SelectLogsSince(ctx, clientdb.SelectLogsSinceParams{
			ID:    since,
			Limit: otlpBatchSize,
		})
		if err != nil {
			return nil, false, fmt.Errorf("select logs: %w", err)
		}
		if len(logs) == 0 {
			return nil, false, nil
		}
		since = logs[len(logs)-1].ID
		// Marshal the logs to OTLP.
		payload, err := protojson.Marshal(&collogspb.ExportLogsServiceRequest{
			ResourceLogs: clientdb.LogsToPB(logs),
		})
		if err != nil {
			return nil, false, fmt.Errorf("marshal logs: %w", err)
		}
		return &sse.Event{
			Name: "logs",
			ID:   fmt.Sprintf("%d", since),
			Data: payload,
		}, true, nil
	})
}

//nolint:dupl
func (ps *PubSub) MetricsSubscribeHandler(w http.ResponseWriter, r *http.Request, client *daggerClient) error {