make fmt
This commit is contained in:
parent
5f92cbacd7
commit
c758a074ad
2 changed files with 6 additions and 6 deletions
|
|
@ -215,7 +215,7 @@ func (m *Manager) initChannels() error {
|
||||||
logger.InfoC("channels", "WebSocket channel enabled successfully")
|
logger.InfoC("channels", "WebSocket channel enabled successfully")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
logger.InfoCF("channels", "Channel initialization completed", map[string]interface{}{
|
logger.InfoCF("channels", "Channel initialization completed", map[string]interface{}{
|
||||||
"enabled_channels": len(m.channels),
|
"enabled_channels": len(m.channels),
|
||||||
})
|
})
|
||||||
|
|
|
||||||
|
|
@ -27,11 +27,11 @@ var logoImage []byte
|
||||||
|
|
||||||
// Channel implements the Channel interface for WebSocket connections
|
// Channel implements the Channel interface for WebSocket connections
|
||||||
type Channel struct {
|
type Channel struct {
|
||||||
config config.WebSocketConfig
|
config config.WebSocketConfig
|
||||||
bus *bus.MessageBus
|
bus *bus.MessageBus
|
||||||
running bool
|
running bool
|
||||||
allowList []string
|
allowList []string
|
||||||
server *http.Server
|
server *http.Server
|
||||||
upgrader websocket.Upgrader
|
upgrader websocket.Upgrader
|
||||||
clients sync.Map // map[string]*websocket.Conn
|
clients sync.Map // map[string]*websocket.Conn
|
||||||
clientsMu sync.RWMutex
|
clientsMu sync.RWMutex
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue