connect

Documentation

Index

• type Connect
  • func New(listener net.Listener, poller netpoll.Poller, pool *pond.WorkerPool, ...) (*Connect, error)
  • func (conn *Connect) Close()
  • func (conn *Connect) Event(callback func(ev netpoll.Event))
  • func (conn *Connect) Read() (*Decoding, error)
  • func (conn *Connect) Send(id int, event string, data interface{}) error
• type Decoding
  • func (r *Decoding) UnmarshalJSON(p []byte) error
• type Encoding

Types

type Connect

type Connect struct {
	ID string

	Host    string
	Uri     string
	Headers map[string]string
	// contains filtered or unexported fields
}

func New

func New(

	listener net.Listener,
	poller netpoll.Poller,
	pool *pond.WorkerPool,

	readBufferSize int,
	writeBufferSize int,
	protocol func([]byte) bool,
	protocolCustom func([]byte) (string, bool),
	extension func(httphead.Option) bool,
	extensionCustom func([]byte, []httphead.Option) ([]httphead.Option, bool),
	negotiate func(httphead.Option) (httphead.Option, error),
	header ws.HandshakeHeader,

	eventsCors *[]func(origin string) (err error),
	eventsConnect *[]func(cn *Connect) (err error),

) (*Connect, error)

func (*Connect) Close

func (conn *Connect) Close()

func (*Connect) Event

func (conn *Connect) Event(callback func(ev netpoll.Event))

func (*Connect) Read

func (conn *Connect) Read() (*Decoding, error)

func (*Connect) Send

func (conn *Connect) Send(id int, event string, data interface{}) error

type Decoding

type Decoding struct {
	ID    int             `json:"id"`
	Type  string          `json:"type"`
	Value json.RawMessage `json:"value"`
}

func (*Decoding) UnmarshalJSON

func (r *Decoding) UnmarshalJSON(p []byte) error

type Encoding

type Encoding struct {
	ID    int         `json:"id"`
	Type  string      `json:"type"`
	Value interface{} `json:"value"`
}