position_cache

Apr 17, 2019

Changes in this version

+ var DefaultFlushPeriod = 5 * time.Second

+ type PositionCacheInterface interface

+ Clear func() error

+ Close func()

+ Flush func() error

+ Get func() (position position_repos.Position, exist bool, err error)

+ GetEncodedPersistentPosition func() (position position_repos.PositionMeta, v string, exist bool, err error)

+ Put func(position position_repos.Position) error

+ Start func() error

+ func NewPositionCache(pipelineName string, repo position_repos.PositionRepo, ...) (PositionCacheInterface, error)