server

type Item struct {
	K string
	V string
}

type MessageChan chan *message.Any

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

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

type Storage interface {
	// AddItem adds Item to storage
	AddItem(item Item)
	// RemoveItem removes Item from storage
	RemoveItem(key string) error
	// GetItem returns Item with given id from storage
	GetItem(key string) (*Item, error)
	// GetAllItems returns items in storage, new slice created every time
	GetAllItems() []Item
	// Iterate allows to iterato over ordered in storage, can be used for processing which does not involve blocking IO
	Iterate(accept func(Item))
}