connector

Documentation

Index

• func Connect(socketType SocketType, ip string, port int, retryTimes int, ...)
• func NewRoutine(ChanSize int64) (ret *routine)
• type Event
• type IConnectFail
• type IConnectSuccess
• type RoutinePool
  • func NewRoutinePool(PoolSize int64, ChanSize int64) (pool *RoutinePool)
  • func (pool *RoutinePool) FireEvent(e Event)
  • func (pool *RoutinePool) ShutDown()
• type SocketType
• type WSConn
  • func NewWSConn(conn *websocket.Conn) (*WSConn, error)
  • func (c *WSConn) Close() error
  • func (c *WSConn) LocalAddr() net.Addr
  • func (c *WSConn) Read(b []byte) (int, error)
  • func (c *WSConn) RemoteAddr() net.Addr
  • func (c *WSConn) SetDeadline(t time.Time) error
  • func (c *WSConn) SetReadDeadline(t time.Time) error
  • func (c *WSConn) SetWriteDeadline(t time.Time) error
  • func (c *WSConn) Write(b []byte) (int, error)

Functions

func Connect

func Connect(socketType SocketType, ip string, port int, retryTimes int, success IConnectSuccess, fail IConnectFail)

func NewRoutine

func NewRoutine(ChanSize int64) (ret *routine)

Types

type Event

type Event interface {
	/**
	 * 为保证事件序列化执行，需要序列化执行的事件必须提供一致的queueId
	 * */
	QueueId() (queueId int64)
	Exec()
}

type IConnectFail

type IConnectFail interface {
	Handle(err error)
}

type IConnectSuccess

type IConnectSuccess interface {
	Handle(conn net.Conn)
}

type RoutinePool

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

func NewRoutinePool

func NewRoutinePool(PoolSize int64, ChanSize int64) (pool *RoutinePool)

func (*RoutinePool) FireEvent

func (pool *RoutinePool) FireEvent(e Event)

func (*RoutinePool) ShutDown

func (pool *RoutinePool) ShutDown()

type SocketType

type SocketType int

const (
	NormalSocket SocketType = 0
	WebSocket    SocketType = 1
)

type WSConn

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

WSConn is an adapter to t.Conn, which implements all t.Conn interface base on *websocket.Conn

func NewWSConn

func NewWSConn(conn *websocket.Conn) (*WSConn, error)

NewWSConn return an initialized *WSConn

func (*WSConn) Close

func (c *WSConn) Close() error

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

func (*WSConn) LocalAddr

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

LocalAddr returns the local network address.

func (*WSConn) Read

func (c *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 (c *WSConn) RemoteAddr() net.Addr

RemoteAddr returns the remote network address.

func (*WSConn) SetDeadline

func (c *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 (c *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 (c *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 (c *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.