internal

Documentation

Index

• Variables
• type Entry
• type MonoChecker
  • 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)

Variables

var (
	ErrMonoChecker  = errors.New("monochecker error")
	ErrDuplicateRun = fmt.Errorf("[%w]:run仅允许调用一次", ErrMonoChecker)
	ErrTouchBlock   = fmt.Errorf("[%w]:touch管道阻塞了", ErrMonoChecker)
)

Types

type Entry

type Entry struct {
	K string
	T time.Time
}

type MonoChecker

type MonoChecker struct {
	// contains filtered or unexported fields
}

func NewMonoChecker

func NewMonoChecker(bufferCount int, timeout time.Duration, batchSize int) *MonoChecker

func (*MonoChecker) DownChan

func (checker *MonoChecker) DownChan() (downChan <-chan Entry)

func (*MonoChecker) Run

func (checker *MonoChecker) Run() (err error)

func (*MonoChecker) Touch

func (checker *MonoChecker) Touch(identity string) (err error)

func (*MonoChecker) UpChan

func (checker *MonoChecker) UpChan() (upChan <-chan Entry)