internal

Documentation

Index

• func Publish(data []byte) error
• func PublishToServer(data []byte) error
• func RunPseudoTerminal() error
• func StartServer()
• func Subscribe(w io.Writer) error
• type SocketWriter
  • func NewSocketWriter(ws *websocket.Conn) SocketWriter
  • func (sw SocketWriter) Write(data []byte) (int, error)

Functions

func Publish

func Publish(data []byte) error

Publish publishes the message to all the listening writers not using io.Multiwriter because it stops if one if them fails and it is sequential preferably pool the goroutines instead of creating one per writer

func PublishToServer

func PublishToServer(data []byte) error

func RunPseudoTerminal

func RunPseudoTerminal() error

func StartServer

func StartServer()

func Subscribe

func Subscribe(w io.Writer) error

Types

type SocketWriter

type SocketWriter struct {
	Lock *sync.Mutex
	Conn *websocket.Conn
}

func NewSocketWriter

func NewSocketWriter(ws *websocket.Conn) SocketWriter

func (SocketWriter) Write

func (sw SocketWriter) Write(data []byte) (int, error)