storageadapter

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

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

type StorageAdapter interface {
	Inject(data *parser.Data) error
	Retrieve(key string) (*parser.Data, error)
	ReadStream(key string) (<-chan *parser.Data, <-chan error)
}