websockets

Jan 31, 2025

Changes in this version

+ type UnregisterFunc func()

Jan 31, 2025

Changes in this version

type Client

+ AgentVersion string

type Config

+ TLSConfig *tls.Config

type Server

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerOption func(*Server)

+ func WithWorkerPoolSize(size int) ServerOption

+ type WorkerPool struct

+ func NewWorkerPool(size int) *WorkerPool

+ func (p *WorkerPool) Submit(ctx context.Context, task func()) error

+ func (p *WorkerPool) Wait()

Jan 28, 2025

Changes in this version

type Server — linux/amd64

+ func (server *Server) AgentVersion(agentTarget *types.Target) string

Jan 28, 2025

Changes in this version

type Server

+ func (s *Server) GetClientVersion(clientID string) string

Jan 24, 2025

Changes in this version

+ type Config struct

+ ClientID string

+ Headers http.Header

+ ServerURL string

+ func GetWindowsConfig() (Config, error)

+ type MessageHandler func(msg *Message)

type Server — linux/amd64

+ func (s *Server) Register(client *Client)

+ func (s *Server) RegisterHandler() (<-chan Message, func())

+ func (s *Server) Unregister(client *Client)

+ func (server *Server) AgentPing(agentTarget *types.Target) bool

+ type WSClient struct — darwin/amd64, js/wasm, linux/amd64

+ ClientID string

+ IsConnected bool

+ TLSConfig *tls.Config

+ func NewWSClient(ctx context.Context, config Config, tlsConfig *tls.Config) (*WSClient, error)

+ func (c *WSClient) Close() error

+ func (c *WSClient) Connect() error

+ func (c *WSClient) GetConnectionStatus() bool

+ func (c *WSClient) RegisterHandler(msgType string, handler MessageHandler)

+ func (c *WSClient) Send(msg Message) error

+ func (c *WSClient) Start()

Jan 12, 2025

Changes in this version

type Message

+ Time time.Time

type Server

+ func (s *Server) IsClientConnected(clientID string) bool

+ func (s *Server) Run()

+ func (s *Server) SendToClient(clientID string, msg Message) error

+ func (s *Server) ServeWS(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Subscribe() (<-chan Message, func())

Jan 11, 2025

Changes in this version

type BroadcastServer

+ Broadcast func(msg Message) error

type Client

+ func NewClient(id string, conn *websocket.Conn, broadcast BroadcastServer) *Client

type Server

+ Broadcast BroadcastServer

type WSClient — windows/amd64

+ func (c *WSClient) SendMessage(msg Message) error

Jan 8, 2025

Changes in this version

+ type BroadcastServer interface

+ CancelSubscription func(<-chan Message)

+ Close func()

+ Subscribe func() <-chan Message

+ func NewBroadcastServer(ctx context.Context, source <-chan Message) BroadcastServer

+ type Client struct

+ Broadcast BroadcastServer

+ Conn *websocket.Conn

+ ID string

+ type Message struct

+ ClientID string

+ Content string

+ Type string

+ type Server struct

+ Clients map[string]*Client

+ ClientsMux sync.Mutex

+ func NewServer() *Server

+ func (s *Server) HandleClientConnection(w http.ResponseWriter, r *http.Request)

+ func (s *Server) RemoveClient(clientID string)

+ func (s *Server) SendCommand(clientID string, msg Message) error

+ func (s *Server) SendCommandWithBroadcast(clientID string, msg Message) (BroadcastServer, error)

+ type WSClient struct — windows/amd64

+ ClientID string

+ CommandListener func(*websocket.Conn, Message)

+ Conn *websocket.Conn

+ Headers http.Header

+ ServerURL string

+ func NewWSClient(commandListener func(*websocket.Conn, Message)) (*WSClient, error)

+ func (client *WSClient) Close()

+ func (client *WSClient) WaitInterrupt()