Versions in this module Expand all Collapse all v0 v0.2.0 Oct 7, 2026 v0.1.0 Oct 7, 2026 Changes in this version + const CodeDecode + const CodeUnknownRoute + const CodeValidation + const KindHTML + const KindText + const StatusReauth + func Decode[T any](raw json.RawMessage) (T, error) + func ParseValue[T any](s string) (T, error) + type AckMsg struct + RouteKey string + T string + Var string + type Binding struct + Kind string + Value string + func HTMLBinding(markup string) Binding + func TextBinding(text string) Binding + type Broadcast struct + func NewBroadcast[V any]() *Broadcast[V] + func (b *Broadcast[V]) Publish(v V) + func (b *Broadcast[V]) Subscribe() *BroadcastSub[V] + func (b *Broadcast[V]) TotalSubs() int + type BroadcastSub struct + func (s *BroadcastSub[V]) Close() + func (s *BroadcastSub[V]) Updates() <-chan V + type CallMsg struct + Args json.RawMessage + ID uint32 + Name string + RouteKey string + T string + type Conn struct + func Accept(w http.ResponseWriter, r *http.Request) (*Conn, error) + func (c *Conn) Ack(ctx context.Context, msg WriteMsg) + func (c *Conn) Close(code websocket.StatusCode, reason string) + func (c *Conn) Enqueue(key string, b Binding) + func (c *Conn) ReadFrames(ctx context.Context, onWrite func(WriteMsg), onCall func(CallMsg)) error + func (c *Conn) Reject(ctx context.Context, msg WriteMsg, text, code string) + func (c *Conn) Send(ctx context.Context, v any) error + func (c *Conn) SendLoop(ctx context.Context) error + type ErrMsg struct + Code string + Msg string + RouteKey string + T string + Var string + func NewErr(routeKey, varName, text, code string) ErrMsg + type FailMsg struct + ID uint32 + Msg string + Status int + T string + func NewFail(id uint32, status int, text string) FailMsg + type InitMsg struct + Bindings map[string]Binding + T string + func NewInit(bindings map[string]Binding) InitMsg + type PatchMsg struct + Key string + T string + type ResultMsg struct + ID uint32 + T string + Value json.RawMessage + func NewResult(id uint32, value json.RawMessage) ResultMsg + type Topic struct + func NewTopic[K comparable, V any]() *Topic[K, V] + func (t *Topic[K, V]) Len() int + func (t *Topic[K, V]) Publish(key K, v V) + func (t *Topic[K, V]) Subscribe(key K) *TopicSub[V] + func (t *Topic[K, V]) TotalSubs() int + type TopicSub struct + func (s *TopicSub[V]) Close() + func (s *TopicSub[V]) Updates() <-chan V + type WriteMsg struct + RouteKey string + T string + Value json.RawMessage + Var string
Go to main page