messaging

type Connector interface {
	Connect(uri string, opts Options)
	Close()
}

type Consumer interface {
	Consume(opts interface{}) ([][]byte, error)
}

type Options map[string]interface{}

type Publisher interface {
	Publish(msg []byte, opts interface{}) error
}

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

type RabbitMQConsumeSettings struct {
	QueueName    string
	MessageCount uint
}

type RabbitMQPublishSettings struct {
	QueueName string
}

type RabbitMQStream struct {
	RabbitMQConnector
}

type Stream interface {
	Connector
	Publisher
	Consumer
}