stream

type StreamConsumer struct {
	Id            int
	Environment   *stream.Environment
	Consumer      *ha.ReliableConsumer
	SuperConsumer *ha.ReliableSuperStreamConsumer
	Topic         string
	Config        config.Config
	// contains filtered or unexported fields
}

type StreamPublisher struct {
	Id            int
	Environment   *stream.Environment
	Producer      *ha.ReliableProducer
	SuperProducer *ha.ReliableSuperStreamProducer
	Topic         string
	Config        config.Config
	// contains filtered or unexported fields
}