Documentation ¶ Rendered for linux/amd64 windows/amd64 darwin/amd64 js/wasm Index ¶ type Conn type Synchronizer type Websocket func NewWebsocket() *Websocket func (ws *Websocket) Publish(addr string, fn func(Conn)) error func (ws *Websocket) Subscribe(addr string, fn func(*pb.Op)) error type WsConn func (w *WsConn) Send(op *pb.Op) error func (w *WsConn) Wait() error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Conn ¶ type Conn interface { Send(*pb.Op) error Wait() error } type Synchronizer ¶ type Synchronizer interface { Publish(addr string, fn func(c Conn)) error Subscribe(addr string, fn func(*pb.Op)) error } type Websocket ¶ type Websocket struct { // contains filtered or unexported fields } func NewWebsocket ¶ func NewWebsocket() *Websocket func (*Websocket) Publish ¶ func (ws *Websocket) Publish(addr string, fn func(Conn)) error func (*Websocket) Subscribe ¶ func (ws *Websocket) Subscribe(addr string, fn func(*pb.Op)) error type WsConn ¶ type WsConn struct { // contains filtered or unexported fields } func (*WsConn) Send ¶ func (w *WsConn) Send(op *pb.Op) error func (*WsConn) Wait ¶ func (w *WsConn) Wait() error Source Files ¶ View all Source files sync.go websocket.go Click to show internal directories. Click to hide internal directories.