pubsub

type DataMessage struct {
	Type string
	Data interface{}
}

type PubSub struct {
	Host       host.Host
	Topic      *libpubsub.Topic
	Type       string
	SubHandler SubHandler
	// contains filtered or unexported fields
}

type PubSubInterface interface {
	InitPubSub()
	GetType() string
	SetType(Type string)
	Pub(message DataMessage)
	Sub() (*libpubsub.Subscription, *libpubsub.Topic, error)
	// contains filtered or unexported methods
}

type SubHandler interface {
	SubHandler(DataMessage)
}