websocket

Documentation

Index

• Variables
• func DialWithTimeout(node eocontext.INode, path string, query string, header http.Header, ...) (*websocket.Conn, *http.Response, error)
• type Complete
  • func NewComplete(retry int, timeOut time.Duration) *Complete
  • func (h *Complete) Complete(org eocontext.EoContext) error
• type Conn
  • func (c *Conn) Read(b []byte) (n int, err error)
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) Write(b []byte) (n int, err error)

Variables

var (
	ErrorTimeoutComplete = errors.New("complete timeout")
)

Functions

func DialWithTimeout

func DialWithTimeout(node eocontext.INode, path string, query string, header http.Header, timeout time.Duration) (*websocket.Conn, *http.Response, error)

Types

type Complete

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

func NewComplete

func NewComplete(retry int, timeOut time.Duration) *Complete

func (*Complete) Complete

func (h *Complete) Complete(org eocontext.EoContext) error

type Conn

type Conn struct {
	*websocket.Conn
}

func (*Conn) Read

func (c *Conn) Read(b []byte) (n int, err error)

func (*Conn) SetDeadline

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

func (*Conn) Write

func (c *Conn) Write(b []byte) (n int, err error)