SDK Go : logs et statut en direct

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

​

Événements

​

La struct Status

​

Fin du flux

• le serveur ferme proprement la connexion (chaque connexion dure jusqu’à 10 minutes) ;
• le serveur a envoyé REALTIME_DISCONNECTED (l’événement est livré d’abord, puis io.EOF) ;
• vous avez appelé Close.

​

Reconnexion

• jusqu’à 3 fois d’affilée ; tout événement logs ou status remet le compteur à zéro ;
• chaque réouverture au moins 5,5 s après l’ouverture précédente, pour rester sous le rythme de l’API d’une ouverture toutes les 5 secondes par application.

​

Limites et erreurs

• 5 connexions simultanées par compte et 30 par application, tous utilisateurs confondus. Les dépasser donne 429 REALTIME_MAX_CONNECTIONS ou REALTIME_MAX_CONNECTIONS_APP.
• Le statut HTTP est vérifié avant la diffusion, de sorte que ces erreurs (et 404 pour une application inconnue) sont renvoyées par Realtime lui-même, avant le premier Next.
• Lorsque ctx n’a pas d’échéance, l’échéance de WithTimeout ne couvre que l’ouverture, jusqu’à l’arrivée des en-têtes de réponse (TIMEOUT s’ils n’arrivent pas). Le flux lui-même n’a pas d’échéance en dehors de ctx.

​

Prochaines étapes