ws

type Connection ¶

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func Dial(ctx context.Context, url string) (*Connection, error)

func NewConnection(ctx context.Context, socket *websocket.Conn) *Connection

func (c *Connection) Close() error

func (c *Connection) EmitClosing()

func (c *Connection) Id() string

func (c *Connection) OnClosing(onClosing func())

func (c *Connection) ReadPump()

func (c *Connection) SetOutput(out io.WriteCloser)

func (c *Connection) Url() string

func (c *Connection) Use(m Middleware)

func (c *Connection) Write(bytes []byte) (int, error)

func (c *Connection) WritePump()

type Hub ¶

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

Hub maintains the set of active peers and broadcasts messages to the peers.

func NewHub(ctx context.Context, registry *remote.Registry) *Hub

func (h *Hub) Close()

func (h *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)

type LockWriter ¶

type LockWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

LockWriter is a writer that locks the underlying writer using a mutex.

func NewLockWriter(writer io.Writer) *LockWriter

func (l *LockWriter) Write(p []byte) (n int, err error)

type LogMiddleware ¶ added in v0.5.0

type LogMiddleware struct{}

func (l LogMiddleware) Process(msg []byte) ([]byte, error)

type Middleware ¶ added in v0.5.0

type Middleware interface {
	Process(msg []byte) ([]byte, error)
}

type MiddlewareFunc ¶ added in v0.5.0

type MiddlewareFunc func(msg []byte) ([]byte, error)

func (f MiddlewareFunc) Process(msg []byte) ([]byte, error)