position_cache

Documentation

Index

• Variables
• type PositionCacheInterface
  • func NewPositionCache(pipelineName string, repo position_repos.PositionRepo, ...) (PositionCacheInterface, error)

Variables

var DefaultFlushPeriod = 5 * time.Second

Types

type PositionCacheInterface

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
}

func NewPositionCache

func NewPositionCache(pipelineName string, repo position_repos.PositionRepo, encoder position_repos.PositionValueEncoder, decoder position_repos.PositionValueDecoder, flushDuration time.Duration) (PositionCacheInterface, error)