SDK Go: log e stato in tempo reale

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"
		}
	}
}

​

Eventi

​

La struct Status

​

Terminare il flusso

• il server chiude la connessione in modo pulito (ogni connessione dura fino a 10 minuti);
• il server ha inviato REALTIME_DISCONNECTED (prima viene consegnato l’evento, poi io.EOF);
• hai chiamato Close.

​

Riconnessione

• fino a 3 volte di fila; qualsiasi evento logs o status azzera il conteggio;
• ogni riapertura avviene almeno 5,5 s dopo l’apertura precedente, per restare sotto il ritmo dell’API di un’apertura ogni 5 secondi per app.

​

Limiti ed errori

• 5 connessioni simultanee per account e 30 per app, considerando tutti gli utenti. Superarle produce 429 REALTIME_MAX_CONNECTIONS o REALTIME_MAX_CONNECTIONS_APP.
• Lo status HTTP viene controllato prima dello streaming, quindi questi errori (e il 404 per un’app sconosciuta) vengono restituiti da Realtime stesso, prima del primo Next.
• Quando ctx non ha una scadenza, la scadenza di WithTimeout copre solo l’apertura, fino all’arrivo degli header della risposta (TIMEOUT se non arrivano). Il flusso in sé non ha altra scadenza oltre a ctx.

​

Prossimi passi