protocol

Mar 26, 2026

Changes in this version

type Handler

+ func (h *Handler) SetQueuer(queuer MessageQueuer)

+ type MessageQueuer interface

+ Queue func(msg *Message, watchers []string)

Feb 4, 2026

Changes in this version

+ type BatchWrapper struct

+ Messages []Message

+ UserEvent bool

type CreateMessage

+ ID int64

Jan 22, 2026

Changes in this version

type CreateMessage

+ RequestID int

type CreateResponse

+ RequestID int

type Message

+ func ParseMessages(data []byte) ([]*Message, error)

type MessageType

+ const MsgCreateResponse

Dec 26, 2025

Changes in this version

+ type BackendLookup interface

+ GetBackendForConnection func(connectionID string) backend.Backend

+ type CreateMessage struct

+ NoWatch bool

+ ParentID int64

+ Properties map[string]string

+ Unbound bool

+ Value json.RawMessage

+ type CreateResponse struct

+ ID int64

+ type DestroyMessage struct

+ VarID int64

+ type ErrorMessage struct

+ Code string

+ Description string

+ VarID int64

+ type GetMessage struct

+ VarIDs []int64

+ type GetObjectsMessage struct

+ ObjIDs []int64

+ type GetObjectsResponse struct

+ Objects []ObjectData

+ type GetResponse struct

+ Variables []VariableData

+ type Handler struct

+ func NewHandler(cfg *config.Config, store *variable.Store, sender MessageSender) *Handler

+ func (h *Handler) HandleMessage(connectionID string, msg *Message) (*Response, error)

+ func (h *Handler) Log(level int, format string, args ...interface{})

+ func (h *Handler) SendError(connectionID string, varID int64, description string) error

+ func (h *Handler) SetBackendLookup(lookup BackendLookup)

+ func (h *Handler) SetPathVariableHandler(handler PathVariableHandler)

+ func (h *Handler) SetPendingQueuer(pending PendingQueuer)

+ type Message struct

+ Data json.RawMessage

+ Type MessageType

+ func NewMessage(msgType MessageType, data interface{}) (*Message, error)

+ func ParseMessage(data []byte) (*Message, error)

+ func (m *Message) Encode() ([]byte, error)

+ type MessageBatcher struct

+ func NewMessageBatcher() *MessageBatcher

+ func (b *MessageBatcher) Flush() []*Message

+ func (b *MessageBatcher) FlushJSON() ([]byte, error)

+ func (b *MessageBatcher) IsEmpty() bool

+ func (b *MessageBatcher) QueueProperties(varID int64, properties map[string]string)

+ func (b *MessageBatcher) QueueProperty(varID int64, propertyName, value string)

+ func (b *MessageBatcher) QueueValue(varID int64, value json.RawMessage, priority Priority)

+ type MessageSender interface

+ Broadcast func(sessionID string, msg *Message) error

+ Send func(connectionID string, msg *Message) error

+ type MessageType string

+ const MsgCreate

+ const MsgDestroy

+ const MsgError

+ const MsgGet

+ const MsgGetObjects

+ const MsgPoll

+ const MsgUnwatch

+ const MsgUpdate

+ const MsgWatch

+ type ObjectData struct

+ ID int64

+ Value json.RawMessage

+ type PathVariableHandler interface

+ HandleFrontendCreate func(sessionID string, parentID int64, properties map[string]string) (int64, json.RawMessage, map[string]string, error)

+ HandleFrontendUpdate func(sessionID string, varID int64, value json.RawMessage) error

+ type PendingChange struct

+ HasValue bool

+ PropPriorities map[string]Priority

+ Properties map[string]string

+ Value json.RawMessage

+ ValuePriority Priority

+ VarID int64

+ type PendingQueuer interface

+ Enqueue func(connectionID string, msg *Message)

+ Poll func(connectionID string, wait time.Duration) []*Message

+ type PollMessage struct

+ Wait string

+ type Priority int

+ const PriorityHigh

+ const PriorityLow

+ const PriorityMedium

+ func ParsePrioritySuffix(propertyName string) (string, Priority)

+ type Response struct

+ Error string

+ Pending []Message

+ Result interface{}

+ type UpdateMessage struct

+ Properties map[string]string

+ Value json.RawMessage

+ VarID int64

+ type VariableData struct

+ ID int64

+ Properties map[string]string

+ Value json.RawMessage

+ type WatchMessage struct

+ VarID int64