realtime

type Broker interface {
	Publish(topic string, channel string, message []byte) error
	Close()
}

type Channel struct {
	Name  string
	Topic string
}

type Client struct {
	// contains filtered or unexported fields
}

type KafkaConfig struct {
	Addres            []string
	PartitionsOnTopic int
	MaxNumTopic       int
}

type Node struct {
	// contains filtered or unexported fields
}

type Server struct {
	rt.UnimplementedRealTimeServer
	// contains filtered or unexported fields
}

type SubscriberHub map[Channel]map[string]*Client