broker

type Broker struct {
	// contains filtered or unexported fields
}

type Channel struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type Memberlist interface {
	NumMembers() int
	LocalNode() *memberlist.Node
	Members() []*memberlist.Node
}

type Message struct {
	// The event ID to set the EventSource object's last event ID value.
	ID string `json:"id"`

	// A string identifying the type of event described. If this is specified, an event will
	// be dispatched on the browser to the listener for the specified event name;
	// the website source code should use addEventListener() to listen for named events.
	// The onmessage handler is called if no event name is specified for a message.
	Event string `json:"event"`

	// The data field for the message. When the EventSource receives multiple consecutive lines that begin with data:,
	// it will concatenate them, inserting a newline character between each one.
	// Trailing newlines are removed.
	Data json.RawMessage `json:"data"`

	// The reconnection time to use when attempting to send the event. This must be an integer,
	// specifying the reconnection time in milliseconds.
	// If a non-integer value is specified, the field is ignored.
	Retry int `json:"retry"`

	// Contains identifiers of previous nodes this event has been through
	BeenTo []string `json:"been_to"`
}

type Status struct {
	Goroutines int `json:"num_goroutines"`
	Gossip     struct {
		MemberCount int            `json:"member_count"`
		Members     map[string]int `json:"members"`
	} `json:"gossip"`
	Channels map[string][]string `json:"channels"`
}