Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageQuery ¶
MessageQuery represents a query consult the information stored in mongo
type MessageStore ¶
type MessageStore interface { Close() error Save(amqp.Delivery) error Retrieve(MessageQuery) ([]amqp.Delivery, error) }
MessageStore are the actions that must be realized by any persistence mechanism
func CreateMongoStore ¶
func CreateMongoStore(mongoURL, database string) (MessageStore, error)
CreateMongoStore creates a store providing a mongo url and a mongo database name
Click to show internal directories.
Click to hide internal directories.