SDK Go: logs e status ao 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

​

A struct Status

​

Encerrando o stream

• o servidor fecha a conexão de forma limpa (cada conexão dura até 10 minutos);
• o servidor envia REALTIME_DISCONNECTED (o evento é entregue primeiro, depois io.EOF);
• você chamou Close.

​

Reconexão

• até 3 vezes seguidas; qualquer evento logs ou status zera a contagem;
• cada reabertura ocorre pelo menos 5,5 s após a abertura anterior, para respeitar o ritmo da API de uma abertura a cada 5 segundos por aplicação.

​

Limites e erros

• 5 conexões simultâneas por conta e 30 por aplicação, somando todos os usuários. Ultrapassar resulta em 429 REALTIME_MAX_CONNECTIONS ou REALTIME_MAX_CONNECTIONS_APP.
• O status HTTP é verificado antes do streaming, então esses erros (e o 404 para uma aplicação desconhecida) são retornados pelo próprio Realtime, antes do primeiro Next.
• Quando o ctx não tem prazo, o prazo de WithTimeout cobre apenas a abertura, até os headers da resposta chegarem (TIMEOUT se não chegarem). O stream em si não tem prazo além do ctx.

​

Próximos passos