pubsub.go @@ -2,12 +2,15 @@ type PubSub interface { Publish([]byte) Publish(Message) Surveyor() []string Recv() chan Message } type Message struct { Id string Topic string Msg []byte }