position_cache

type PositionCacheInterface interface {
	Start() error
	Close()
	Put(position position_repos.Position) error

	// Get will get a value from cache, if there is no value inside the cache
	// it will try to get it from position repo
	Get() (position position_repos.Position, exist bool, err error)

	GetEncodedPersistentPosition() (position position_repos.PositionMeta, v string, exist bool, err error)
	Flush() error
	Clear() error
}