meta

type Data string

type ErrNotFound struct {
	Key string
}

type Response struct {
	// Key of metadata response
	Key string
	// Value of metadata
	Value Data
	// Error on failure
	Error error
}

type Storage interface {
	// Get returns a channel with single response item,
	// channel is closed on context cancellation. Context
	// shold be cancelled with defer.
	Get(ctx context.Context, key string) <-chan *Response
	// Set updates metadata storage, channel with a
	// value is returned on success, a value could differ from
	// provided value, if storage received new value after this request
	// but before response. Channel is closed on context
	// cancellation. Context should be cancelled with defer.
	Set(ctx context.Context, key string, val Data) <-chan *Response
}