store

type Config struct {
	Storage   Storage
	Transport transport.Transport
	Log       log.Logger
}

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

type Storage interface {
	// Add adds a message to the store. If the message already exists, no error
	// will be returned. Method is thread safe.
	Add(msg *messages.Event) error
	// Get returns a message form the store. If the message does not exist,
	// nil will be returned. Method is thread safe.
	Get(typ string, idx []byte) ([]*messages.Event, error)
}