websocket

Documentation

Index

• Variables
• func AckHandler(ch <-chan AckInfo)
• func Pinger(c chan connection.Conn, size int, PingInterval time.Duration, ...)
• type AckInfo
• type Handler
  • func NewHandler(pingC chan connection.Conn, collector collection.Collector) *Handler
  • func (h *Handler) Ack(conn connection.Conn, resChannel chan AckInfo, s serialization.SerializeFunc, ...) collection.AckFunc
  • func (h *Handler) HandlerWSEvents(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) Table() *connection.Table

Variables

var AckChan = make(chan AckInfo)

Functions

func AckHandler

func AckHandler(ch <-chan AckInfo)

func Pinger

func Pinger(c chan connection.Conn, size int, PingInterval time.Duration, WriteWaitInterval time.Duration)

Pinger is worker that pings the connected peers based on ping interval.

Types

type AckInfo

type AckInfo struct {
	MessageType int
	RequestGuid string
	Err         error
	Conn        connection.Conn

	TimeConsumed    time.Time
	AckTimeConsumed time.Time
	// contains filtered or unexported fields
}

type Handler

type Handler struct {
	PingChannel chan connection.Conn
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(pingC chan connection.Conn, collector collection.Collector) *Handler

func (*Handler) Ack

func (h *Handler) Ack(conn connection.Conn, resChannel chan AckInfo, s serialization.SerializeFunc, messageType int, reqGuid string, timeConsumed time.Time) collection.AckFunc

func (*Handler) HandlerWSEvents

func (h *Handler) HandlerWSEvents(w http.ResponseWriter, r *http.Request)

HandlerWSEvents handles the upgrade and the events sent by the peers

func (*Handler) Table

func (h *Handler) Table() *connection.Table