websocketcapnp

Documentation

Overview

Package websocketcapnp integrates websockets with capnproto.

TODO: this should probably get factored out into its own library/module at some point.

Index

• func NewTransport(conn *websocket.Conn) rpc.Transport
• func PortCodec(p Port) transport.Codec
• type Port
  • func WebSocketPort(conn *websocket.Conn) Port
  • func XZPort(p Port) Port

Functions

func NewTransport

func NewTransport(conn *websocket.Conn) rpc.Transport

Return an rpc.Transport that sends messages over the websocket connection. Sends each capnproto message in its own websocket binary message, xz-compressed.

func PortCodec

func PortCodec(p Port) transport.Codec

Types

type Port

type Port interface {
	NextWriter() (io.WriteCloser, error)
	NextReader() (io.Reader, error)
	Close() error
}

func WebSocketPort

func WebSocketPort(conn *websocket.Conn) Port

func XZPort

func XZPort(p Port) Port