statesync

Documentation

Overview

Package statesync is a watcher implement.

Index

• type Watcher
  • func (w *Watcher) Run()
  • func (w *Watcher) SetMaxWorkers(maxWorkers int64)
  • func (w *Watcher) SetStore(store store.IStore)
  • func (w *Watcher) Spec() string

Types

type Watcher

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

watcher implement.

func (*Watcher) Run

func (w *Watcher) Run()

Run runs the watcher.

func (*Watcher) SetMaxWorkers

func (w *Watcher) SetMaxWorkers(maxWorkers int64)

func (*Watcher) SetStore

func (w *Watcher) SetStore(store store.IStore)

SetStore sets the persistence store for the Watcher.

func (*Watcher) Spec

func (w *Watcher) Spec() string

Spec is parsed using the time zone of task Cron instance as the default.