package pubsub

type PubSub interface {

	Publish(Message)

	Surveyor() []string

	Recv() chan Message
}

type Message struct {
	Id string
	Topic string
	Msg []byte
}

const (
	Topic_Camera = "camera"  //摄像机消息
	Topic_Task = "task" //任务消息
	Topic_Sdk = "sdk" //算法消息
	Topic_Event = "event" //事件消息
)

func NewPublisher(url string,heartBeatUrl string,mode int) (PubSub,error) {
	return newPub(url,heartBeatUrl)
}

//processId is process Identifier,unique
func NewSubscriber(url string,heartBeatUrl string,mode int,topics []string,processId string) (PubSub,error) {
	return newSub(url,heartBeatUrl, topics, processId)
}