Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broadcaster ¶
type Broadcaster struct {
// contains filtered or unexported fields
}
Broadcaster fans out weight readings to all connected clients
func NewBroadcaster ¶
func NewBroadcaster(broadcast <-chan string) *Broadcaster
NewBroadcaster creates a broadcaster for the given channel
func (*Broadcaster) AddClient ¶
func (b *Broadcaster) AddClient(conn *websocket.Conn)
AddClient registers a new WebSocket connection
func (*Broadcaster) ClientCount ¶
func (b *Broadcaster) ClientCount() int
ClientCount returns the number of connected clients
func (*Broadcaster) RemoveClient ¶
func (b *Broadcaster) RemoveClient(conn *websocket.Conn)
RemoveClient unregisters a WebSocket connection
func (*Broadcaster) Start ¶
func (b *Broadcaster) Start(ctx context.Context)
Start begins broadcasting weights to clients (blocking)
type BuildInfo ¶
type BuildInfo struct {
Env string `json:"env"`
Date string `json:"date"`
Time string `json:"time"`
}
BuildInfo contains build metadata
type ConfigForClient ¶
type ConfigForClient struct {
Tipo string `json:"tipo,omitempty"`
Puerto string `json:"puerto"`
Marca string `json:"marca"`
ModoPrueba bool `json:"modoPrueba"`
Dir string `json:"dir"`
Ambiente string `json:"ambiente"`
}
ConfigForClient is the config subset sent to clients
type ConfigMessage ¶
type ConfigMessage struct {
Tipo string `json:"tipo"`
Puerto string `json:"puerto"`
Marca string `json:"marca"`
ModoPrueba bool `json:"modoPrueba"`
Dir string `json:"dir,omitempty"`
}
ConfigMessage matches the exact JSON structure from clients CONSTRAINT: All fields must match legacy format exactly
type EnvironmentInfo ¶
type EnvironmentInfo struct {
Tipo string `json:"tipo"`
Ambiente string `json:"ambiente"`
Version string `json:"version"`
Config ConfigForClient `json:"config"`
}
EnvironmentInfo sent to clients on connection
type HealthResponse ¶
type HealthResponse struct {
Status string `json:"status"`
Scale ScaleStatus `json:"scale"`
Build BuildInfo `json:"build"`
Uptime int `json:"uptime_seconds"`
}
HealthResponse represents service health (excludes weight data per protocol)
type LogConfigMessage ¶
LogConfigMessage for verbose toggle
type LogFlushResult ¶
type LogFlushResult struct {
Tipo string `json:"tipo"`
OK bool `json:"ok"`
Error string `json:"error,omitempty"`
}
LogFlushResult returned after flush operation
type LogLinesResponse ¶
LogLinesResponse returns log lines
type LogTailMessage ¶
LogTailMessage requests last N lines
type ScaleStatus ¶
type ScaleStatus struct {
Connected bool `json:"connected"`
Port string `json:"port"`
Brand string `json:"brand"`
TestMode bool `json:"test_mode"`
}
ScaleStatus represents scale configuration state (no payload data)
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server handles HTTP and WebSocket connections
func NewServer ¶
func NewServer( cfg *config.Config, env config.Environment, broadcaster *Broadcaster, logMgr *logging.Manager, buildInfo string, onConfigChange func(), buildDate string, buildTime string, startTime time.Time, ) *Server
NewServer creates a new server instance
func (*Server) HandleHealth ¶
func (s *Server) HandleHealth(w http.ResponseWriter, r *http.Request)
HandleHealth returns service health metrics
func (*Server) HandlePing ¶
func (s *Server) HandlePing(w http.ResponseWriter, r *http.Request)
HandlePing is a lightweight liveness check
func (*Server) ListenAndServe ¶
ListenAndServe inicia el servidor HTTP
Source Files