Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + var ErrDuplicateRun = fmt.Errorf("[%w]:run仅允许调用一次", ErrMonoChecker) + var ErrMonoChecker = errors.New("monochecker error") + var ErrTouchBlock = fmt.Errorf("[%w]:touch管道阻塞了", ErrMonoChecker) + type Entry struct + K string + T time.Time + type MonoChecker struct + func NewMonoChecker(bufferCount int, timeout time.Duration, batchSize int) *MonoChecker + func (checker *MonoChecker) DownChan() (downChan <-chan Entry) + func (checker *MonoChecker) Run() (err error) + func (checker *MonoChecker) Touch(identity string) (err error) + func (checker *MonoChecker) UpChan() (upChan <-chan Entry)
Go to main page