ws

Documentation

Index

• func HandleFunc(msgType string, handler WSHandler)
• func Init()
• type Message
  • func (m *Message) GetString(key string) string
  • func (m *Message) String() string
• type Transport
  • func (t *Transport) Close()
  • func (t *Transport) OnChange(f func())
  • func (t *Transport) OnClose(f func())
  • func (t *Transport) OnWrite(f func(msg any) error)
  • func (t *Transport) WithContext(f func(ctx map[any]any))
  • func (t *Transport) Write(msg any)
  • func (t *Transport) Writer() io.Writer
• type WSHandler

Functions

func HandleFunc

func HandleFunc(msgType string, handler WSHandler)

func Init

func Init()

Types

type Message

type Message struct {
	Type  string `json:"type"`
	Value any    `json:"value,omitempty"`
}

Message - struct for data exchange in Web API

func (*Message) GetString

func (m *Message) GetString(key string) string

func (*Message) String

func (m *Message) String() string

type Transport

type Transport struct {
	Request *http.Request
	// contains filtered or unexported fields
}

func (*Transport) Close

func (t *Transport) Close()

func (*Transport) OnChange

func (t *Transport) OnChange(f func())

func (*Transport) OnClose

func (t *Transport) OnClose(f func())

func (*Transport) OnWrite

func (t *Transport) OnWrite(f func(msg any) error)

func (*Transport) WithContext

func (t *Transport) WithContext(f func(ctx map[any]any))

WithContext - run function with Context variable

func (*Transport) Write

func (t *Transport) Write(msg any)

func (*Transport) Writer

func (t *Transport) Writer() io.Writer

type WSHandler

type WSHandler func(tr *Transport, msg *Message) error