acceptor

Documentation

Index

• func NewTCPAcceptor(addr string, certs ...string) actor.Actor
• type TCPAcceptor
  • func (ta *TCPAcceptor) ListenAndServe()
  • func (ta *TCPAcceptor) Receive(ctx actor.Context)
• type TCPConn
  • func (tc *TCPConn) GetNextMessage() (b []byte, err error)
  • func (tc *TCPConn) RemoteAddr() net.Addr
• type WSAcceptor
  • func NewWSAcceptor(addr string, certs ...string) *WSAcceptor
  • func (wa *WSAcceptor) GetAddr() string
  • func (wa *WSAcceptor) ListenAndServe()
  • func (wa *WSAcceptor) Receive(ctx actor.Context)
  • func (wa *WSAcceptor) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (wa *WSAcceptor) Stop()
• type WSConn
  • func NewWSConn(conn *websocket.Conn) *WSConn
  • func (w *WSConn) Close() error
  • func (w *WSConn) GetNextMessage() (b []byte, err error)
  • func (w *WSConn) LocalAddr() net.Addr
  • func (w *WSConn) Read(b []byte) (int, error)
  • func (w *WSConn) RemoteAddr() net.Addr
  • func (w *WSConn) SetDeadline(t time.Time) error
  • func (w *WSConn) SetReadDeadline(t time.Time) error
  • func (w *WSConn) SetWriteDeadline(t time.Time) error
  • func (w *WSConn) Write(b []byte) (int, error)

Functions

func NewTCPAcceptor

func NewTCPAcceptor(addr string, certs ...string) actor.Actor

Types

type TCPAcceptor

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

func (*TCPAcceptor) ListenAndServe

func (ta *TCPAcceptor) ListenAndServe()

func (*TCPAcceptor) Receive

func (ta *TCPAcceptor) Receive(ctx actor.Context)

type TCPConn

type TCPConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*TCPConn) GetNextMessage

func (tc *TCPConn) GetNextMessage() (b []byte, err error)

GetNextMessage reads the next message available in the stream

func (*TCPConn) RemoteAddr

func (tc *TCPConn) RemoteAddr() net.Addr

type WSAcceptor

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

func NewWSAcceptor

func NewWSAcceptor(addr string, certs ...string) *WSAcceptor

func (*WSAcceptor) GetAddr

func (wa *WSAcceptor) GetAddr() string

func (*WSAcceptor) ListenAndServe

func (wa *WSAcceptor) ListenAndServe()

func (*WSAcceptor) Receive

func (wa *WSAcceptor) Receive(ctx actor.Context)

func (*WSAcceptor) ServeHTTP

func (wa *WSAcceptor) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*WSAcceptor) Stop

func (wa *WSAcceptor) Stop()

type WSConn

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

func NewWSConn

func NewWSConn(conn *websocket.Conn) *WSConn

NewWSConn return an initialized *WSConn

func (*WSConn) Close

func (w *WSConn) Close() error

Close closes the connection. Any blocked Read or Write operations will be unblocked and return errors.

func (*WSConn) GetNextMessage

func (w *WSConn) GetNextMessage() (b []byte, err error)

GetNextMessage reads the next message available in the stream

func (*WSConn) LocalAddr

func (w *WSConn) LocalAddr() net.Addr

LocalAddr returns the local network address.

func (*WSConn) Read

func (w *WSConn) Read(b []byte) (int, error)

Read reads data from the connection. Read can be made to time out and return an Error with Timeout() == true after a fixed time limit; see SetDeadline and SetReadDeadline.

func (*WSConn) RemoteAddr

func (w *WSConn) RemoteAddr() net.Addr

RemoteAddr returns the remote network address.

func (*WSConn) SetDeadline

func (w *WSConn) SetDeadline(t time.Time) error

SetDeadline sets the read and write deadlines associated with the connection. It is equivalent to calling both SetReadDeadline and SetWriteDeadline.

A deadline is an absolute time after which I/O operations fail with a timeout (see type Error) instead of blocking. The deadline applies to all future and pending I/O, not just the immediately following call to Read or Write. After a deadline has been exceeded, the connection can be refreshed by setting a deadline in the future.

An idle timeout can be implemented by repeatedly extending the deadline after successful Read or Write calls.

A zero value for t means I/O operations will not time out.

func (*WSConn) SetReadDeadline

func (w *WSConn) SetReadDeadline(t time.Time) error

SetReadDeadline sets the deadline for future Read calls and any currently-blocked Read call. A zero value for t means Read will not time out.

func (*WSConn) SetWriteDeadline

func (w *WSConn) SetWriteDeadline(t time.Time) error

SetWriteDeadline sets the deadline for future Write calls and any currently-blocked Write call. Even if write times out, it may return n > 0, indicating that some of the data was successfully written. A zero value for t means Write will not time out.

func (*WSConn) Write

func (w *WSConn) Write(b []byte) (int, error)

Write writes data to the connection. Write can be made to time out and return an Error with Timeout() == true after a fixed time limit; see SetDeadline and SetWriteDeadline.