SDK de Go: logs y estado en vivo

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

​

Eventos

​

El struct Status

​

Finalizar el stream

• el servidor cierra la conexión limpiamente (cada conexión dura hasta 10 minutos);
• el servidor envió REALTIME_DISCONNECTED (primero se entrega el evento y después io.EOF);
• llamaste a Close.

​

Reconexión

• hasta 3 veces seguidas; cualquier evento logs o status reinicia el contador;
• cada reapertura al menos 5,5 s después de la apertura anterior, para respetar el ritmo de la API de una apertura cada 5 segundos por aplicación.

​

Límites y errores

• 5 conexiones simultáneas por cuenta y 30 por aplicación, sumando todos los usuarios. Superarlas da 429 REALTIME_MAX_CONNECTIONS o REALTIME_MAX_CONNECTIONS_APP.
• El estado HTTP se comprueba antes del streaming, así que estos errores (y el 404 de una aplicación desconocida) los devuelve el propio Realtime, antes del primer Next.
• Cuando ctx no tiene deadline, el deadline de WithTimeout solo cubre la apertura, hasta que llegan los encabezados de la respuesta (TIMEOUT si no llegan). El stream en sí no tiene más deadline que el de ctx.

​

Próximos pasos