cherryConnector

Documentation

Index

• type Connector
  • func NewConnector(size int) Connector
  • func (p *Connector) GetListener(certFile, keyFile, address string) (net.Listener, error)
  • func (p *Connector) InChan(conn net.Conn)
  • func (p *Connector) OnConnect(fn cfacade.OnConnectFunc)
  • func (p *Connector) Running() bool
  • func (p *Connector) Start()
  • func (p *Connector) Stop()
• type Option
  • func WithCert(certFile, keyFile string) Option
  • func WithChanSize(size int) Option
• type Options
• type TCPConnector
  • func NewTCP(address string, opts ...Option) *TCPConnector
  • func (*TCPConnector) Name() string
  • func (t *TCPConnector) OnAfterInit()
  • func (t *TCPConnector) OnStop()
  • func (t *TCPConnector) Start()
  • func (t *TCPConnector) Stop()
• type WSConn
  • func NewWSConn(conn *websocket.Conn) WSConn
  • func (c *WSConn) Read(b []byte) (int, error)
  • func (c *WSConn) SetDeadline(t time.Time) error
  • func (c *WSConn) Write(b []byte) (int, error)
• type WSConnector
  • func NewWS(address string, opts ...Option) *WSConnector
  • func (*WSConnector) Name() string
  • func (w *WSConnector) OnAfterInit()
  • func (w *WSConnector) OnStop()
  • func (w *WSConnector) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (w *WSConnector) SetUpgrade(upgrade *websocket.Upgrader)
  • func (w *WSConnector) Start()
  • func (w *WSConnector) Stop()

Types

type Connector

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

func NewConnector

func NewConnector(size int) Connector

func (*Connector) GetListener

func (p *Connector) GetListener(certFile, keyFile, address string) (net.Listener, error)

func (*Connector) InChan

func (p *Connector) InChan(conn net.Conn)

func (*Connector) OnConnect

func (p *Connector) OnConnect(fn cfacade.OnConnectFunc)

func (*Connector) Running

func (p *Connector) Running() bool

func (*Connector) Start

func (p *Connector) Start()

func (*Connector) Stop

func (p *Connector) Stop()

type Option

type Option func(*Options)

func WithCert

func WithCert(certFile, keyFile string) Option

func WithChanSize

func WithChanSize(size int) Option

type Options

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

type TCPConnector

type TCPConnector struct {
	cfacade.Component
	Connector
	Options
}

func NewTCP

func NewTCP(address string, opts ...Option) *TCPConnector

func (*TCPConnector) Name

func (*TCPConnector) Name() string

func (*TCPConnector) OnAfterInit

func (t *TCPConnector) OnAfterInit()

func (*TCPConnector) OnStop

func (t *TCPConnector) OnStop()

func (*TCPConnector) Start

func (t *TCPConnector) Start()

func (*TCPConnector) Stop

func (t *TCPConnector) Stop()

type WSConn

type WSConn struct {
	*websocket.Conn
	// contains filtered or unexported fields
}

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

func NewWSConn

func NewWSConn(conn *websocket.Conn) WSConn

NewWSConn return an initialized *WSConn

func (*WSConn) Read

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

func (*WSConn) SetDeadline

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

func (*WSConn) Write

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

type WSConnector

type WSConnector struct {
	cfacade.Component
	Connector
	Options
	// contains filtered or unexported fields
}

func NewWS

func NewWS(address string, opts ...Option) *WSConnector

func (*WSConnector) Name

func (*WSConnector) Name() string

func (*WSConnector) OnAfterInit

func (w *WSConnector) OnAfterInit()

func (*WSConnector) OnStop

func (w *WSConnector) OnStop()

func (*WSConnector) ServeHTTP

func (w *WSConnector) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (*WSConnector) SetUpgrade

func (w *WSConnector) SetUpgrade(upgrade *websocket.Upgrader)

func (*WSConnector) Start

func (w *WSConnector) Start()

func (*WSConnector) Stop

func (w *WSConnector) Stop()