wsync

type Agent struct {
	Sub map[string]Topic
}

type AuthMethod int

type Client struct {
	URL       string
	Token     string // for auth
	Dialer    *websocket.Dialer
	OnTopic   func(topic string, metas ...string)
	AfterOpen func(conn *websocket.Conn)
	OnError   func(error)

	ReadWait  time.Duration
	WriteWait time.Duration

	S chan string     // subscribe
	U chan string     // unsubscrbe
	B chan TopicEvent // boardcast
}

type Server struct {
	C chan ServerFunc // never closed

	Agents map[*websocket.Conn]*Agent

	InitMetas map[string][]string // map[topic]metas

	// status
	MessageSent int

	// readonly
	Upgrader     websocket.Upgrader
	MessageCache int
	Auth         func(token string, m AuthMethod, topic string) bool
}

type ServerFunc func(*Server)

type Topic struct {
	Updated bool
	Meta    []string
}

type TopicEvent struct {
	Topic string
	Meta  []string
}