websockets

Documentation

Index

• type Client
• type Config
• type Message
• type MessageHandler
• type Server
  • func NewServer(ctx context.Context) *Server
  • func (server *Server) AgentPing(agentTarget *types.Target) bool
  • func (server *Server) AgentVersion(agentTarget *types.Target) string
  • func (s *Server) GetClientVersion(clientID string) string
  • func (s *Server) IsClientConnected(clientID string) bool
  • func (s *Server) Register(client *Client)
  • func (s *Server) RegisterHandler() (<-chan Message, func())
  • 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) Unregister(client *Client)
• type WSClient
  • 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()

Types

type Client

type Client struct {
	ID string
	// contains filtered or unexported fields
}

type Config

type Config struct {
	ServerURL string
	ClientID  string
	Headers   http.Header
}

type Message

type Message struct {
	ClientID string    `json:"client_id"`
	Type     string    `json:"type"`
	Content  string    `json:"content"`
	Time     time.Time `json:"time"`
}

type MessageHandler

type MessageHandler func(msg *Message)

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context) *Server

func (*Server) AgentPing

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

func (*Server) AgentVersion

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

func (*Server) GetClientVersion

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

func (*Server) IsClientConnected

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

func (*Server) Register

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

func (*Server) RegisterHandler

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

func (*Server) Run

func (s *Server) Run()

func (*Server) SendToClient

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

func (*Server) ServeWS

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

func (*Server) Unregister

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

type WSClient

type WSClient struct {
	ClientID string

	TLSConfig *tls.Config

	IsConnected bool
	// contains filtered or unexported fields
}

func NewWSClient

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

func (*WSClient) Close

func (c *WSClient) Close() error

func (*WSClient) Connect

func (c *WSClient) Connect() error

func (*WSClient) GetConnectionStatus

func (c *WSClient) GetConnectionStatus() bool

func (*WSClient) RegisterHandler

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

func (*WSClient) Send

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

func (*WSClient) Start

func (c *WSClient) Start()