zws

Documentation

Overview

This file is part of fingerpoken Copyright (C) 2015 Jordan Sissel

This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

This file is part of fingerpoken Copyright (C) 2015 Jordan Sissel

This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

This file is part of fingerpoken Copyright (C) 2015 Jordan Sissel

This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

This file is part of fingerpoken Copyright (C) 2015 Jordan Sissel

This program is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Index

• Constants
• func HandleZWS(w http.ResponseWriter, r *http.Request)
• func ProxyDealer(ws *websocket.Conn, zmq *czmq.Sock)
• func ProxyReqRep(ws *websocket.Conn, zmq *czmq.Sock)
• func ProxyReqRep1(ws *websocket.Conn, zmq *czmq.Sock) error
• func ProxyReqRep2(ws *websocket.Conn, zmq *czmq.Sock) error
• func ProxySub(ws *websocket.Conn, zmq *czmq.Sock)
• func WStoZMQ(ws *websocket.Conn, zmq *czmq.Sock)
• func ZMQtoWS(ws *websocket.Conn, zmq *czmq.Sock)
• type InvalidMessageTypeError
  • func (e *InvalidMessageTypeError) Error() string
• type InvalidMoreFlagError
  • func (e *InvalidMoreFlagError) Error() string
• type InvalidSocketTypeError
  • func (e *InvalidSocketTypeError) Error() string
• type SocketType
  • func ParseSocketType(name string) (SocketType, error)
  • func (s *SocketType) Create(endpoint string) (sock *czmq.Sock, err error)
  • func (s *SocketType) EndpointSuffix() (string, error)
  • func (s *SocketType) String() string
• type ZWS
  • func NewZWS(endpoint_prefix string, w http.ResponseWriter, r *http.Request) (*ZWS, error)
• type ZWSRequestInvalidTypeParameterError
  • func (e *ZWSRequestInvalidTypeParameterError) Error() string
• type ZWSRequestMissingTypeParameterError
  • func (e *ZWSRequestMissingTypeParameterError) Error() string
• type ZeroMQSocketCreationError
  • func (e *ZeroMQSocketCreationError) Error() string

Constants

const (
	INVALID = iota
	REQ     = iota
	DEALER  = iota
	SUB     = iota
)

const (
	FINAL_FRAME = '0'
	MORE_FRAME  = '1'
)

Functions

func HandleZWS

func HandleZWS(w http.ResponseWriter, r *http.Request)

func ProxyDealer

func ProxyDealer(ws *websocket.Conn, zmq *czmq.Sock)

func ProxyReqRep

func ProxyReqRep(ws *websocket.Conn, zmq *czmq.Sock)

func ProxyReqRep1

func ProxyReqRep1(ws *websocket.Conn, zmq *czmq.Sock) error

func ProxyReqRep2

func ProxyReqRep2(ws *websocket.Conn, zmq *czmq.Sock) error

func ProxySub

func ProxySub(ws *websocket.Conn, zmq *czmq.Sock)

func WStoZMQ

func WStoZMQ(ws *websocket.Conn, zmq *czmq.Sock)

func ZMQtoWS

func ZMQtoWS(ws *websocket.Conn, zmq *czmq.Sock)

Types

type InvalidMessageTypeError

type InvalidMessageTypeError struct {
	MessageType int
}

func (*InvalidMessageTypeError) Error

func (e *InvalidMessageTypeError) Error() string

type InvalidMoreFlagError

type InvalidMoreFlagError struct {
	Flag byte
}

func (*InvalidMoreFlagError) Error

func (e *InvalidMoreFlagError) Error() string

type InvalidSocketTypeError

type InvalidSocketTypeError struct {
	SocketType SocketType
}

func (*InvalidSocketTypeError) Error

func (e *InvalidSocketTypeError) Error() string

type SocketType

type SocketType int8

func ParseSocketType

func ParseSocketType(name string) (SocketType, error)

func (*SocketType) Create

func (s *SocketType) Create(endpoint string) (sock *czmq.Sock, err error)

func (*SocketType) EndpointSuffix

func (s *SocketType) EndpointSuffix() (string, error)

func (*SocketType) String

func (s *SocketType) String() string

type ZWS

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

func NewZWS

func NewZWS(endpoint_prefix string, w http.ResponseWriter, r *http.Request) (*ZWS, error)

type ZWSRequestInvalidTypeParameterError

type ZWSRequestInvalidTypeParameterError struct {
	SocketTypeName string
	Cause          error
}

func (*ZWSRequestInvalidTypeParameterError) Error

func (e *ZWSRequestInvalidTypeParameterError) Error() string

type ZWSRequestMissingTypeParameterError

type ZWSRequestMissingTypeParameterError struct {
	Url *url.URL
}

func (*ZWSRequestMissingTypeParameterError) Error

func (e *ZWSRequestMissingTypeParameterError) Error() string

type ZeroMQSocketCreationError

type ZeroMQSocketCreationError struct {
	Cause error
}

func (*ZeroMQSocketCreationError) Error

func (e *ZeroMQSocketCreationError) Error() string