io

type ConnStatus int

type MessageClient interface {
	Subscribe(c api.StreamContext, subChan []TopicChannel, messageErrors chan error, params map[string]interface{}) error
	Publish(c api.StreamContext, topic string, message []byte, params map[string]interface{}) error
	Ping() error
}

type TopicChannel struct {
	// Topic for subscriber to filter on if any
	Topic string
	// Messages is the returned message channel for the subscriber
	Messages chan<- interface{}
}