pubsub

type Delegate interface {
	Accept(r *http.Request) (channelName string, err error)
	OnRedisSubscribe(r *http.Request) error
}

type HTTPHandler struct {
	RedisHub      RedisHub
	Delegate      Delegate
	OriginMatcher WebsocketOriginMatcher
}

type Publisher struct {
	RedisPool RedisPool
}

type RedisHub interface {
	Subscribe(channelName string) (chan *redis.Message, func())
}

type RedisPool interface {
	Get() *redis.Client
}

type WebsocketOriginMatcher interface {
	MatchOrigin(origin string) bool
}

type WebsocketOutgoingMessage struct {
	MessageType websocket.MessageType
	Data        []byte
}