subscribers

type Broadcast func(string, *types.Data)

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

type HttpSubscriberData struct {
	Channels []string `json:"channels"`
	Channel  string   `json:"channel"`
	Name     string   `json:"name"`
	Data     string   `json:"data"`
	SocketId string   `json:"socket_id"`
}

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

type Subscriber interface {
	// Subscribe to incoming events.
	Subscribe(Broadcast)

	// Unsubscribe from events to broadcast.
	UnSubscribe()
}