websocket

package

v0.3.0 Latest Latest Go to latest Published: Sep 23, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/raystack/raccoon

Links

Open Source Insights

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 collector.Collector) *Handler

Constants ¶

This section is empty.

Variables ¶

View Source

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 collector.Collector) *Handler

func (*Handler) Ack ¶

func (h *Handler) Ack(conn connection.Conn, resChannel chan AckInfo, s serde.SerializeFunc, messageType int, reqGuid string, timeConsumed time.Time) collector.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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
connection

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL