Go-SDK: Live-Logs und Status

package main

import (
	"context"
	"errors"
	"fmt"
	"io"
	"log"
	"os"

	"github.com/squarecloudofc/sdk-api-go/v3"
)

func main() {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	c := squarecloud.New(os.Getenv("SQUARECLOUD_API_KEY"))
	appID := "abc123def456abc123def456"

	r, err := c.Apps.Realtime(ctx, appID)
	if err != nil {
		log.Fatal(err)
	}
	defer r.Close()

	for {
		ev, err := r.Next()
		if err != nil {
			if errors.Is(err, io.EOF) || ctx.Err() != nil {
				break // the stream ended, or ctx was canceled
			}
			log.Fatal(err)
		}

		switch ev.Event {
		case "logs":
			fmt.Println(ev.Stream, ev.Line) // "stdout" | "stderr"
		case "status":
			fmt.Println(ev.Status.CPU, ev.Status.RAM) // never nil: always the full, merged state
		default:
			fmt.Println(ev.Event, ev.Data) // "system", "error" or "message"
		}
	}
}

​

Ereignisse

​

Das Struct Status

​

Den Stream beenden

• der Server die Verbindung sauber schließt (jede Verbindung dauert bis zu 10 Minuten);
• der Server REALTIME_DISCONNECTED gesendet hat (zuerst wird das Ereignis zugestellt, dann io.EOF);
• du Close aufgerufen hast.

​

Neuverbindung

• bis zu 3 Mal hintereinander; jedes logs- oder status-Ereignis setzt den Zähler zurück;
• jedes erneute Öffnen mindestens 5,5 s nach dem vorherigen, um unter dem Takt der API von einem Öffnen pro 5 Sekunden pro App zu bleiben.

​

Limits und Fehler

• 5 gleichzeitige Verbindungen pro Konto und 30 pro App, über alle Benutzer hinweg. Eine Überschreitung ergibt 429 REALTIME_MAX_CONNECTIONS oder REALTIME_MAX_CONNECTIONS_APP.
• Der HTTP-Status wird vor dem Streaming geprüft, daher werden diese Fehler (und 404 für eine unbekannte App) von Realtime selbst zurückgegeben, noch vor dem ersten Next.
• Hat ctx keine Deadline, deckt die Deadline von WithTimeout nur das Öffnen ab, bis die Antwort-Header eintreffen (TIMEOUT, wenn sie nicht eintreffen). Der Stream selbst hat außer ctx keine Deadline.

​

Nächste Schritte