registrar

package

v0.0.0-...-8a44fb0 Latest Latest Go to latest Published: Jul 24, 2022 License: MIT, MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func ResetStates(states []file.State) []file.State

resetStates sets all states to finished and disable TTL on restart For all states covered by an input, TTL will be overwritten with the input value

type Registrar struct {
	Channel chan []file.State
	// contains filtered or unexported fields
}

Registrar: 采集进度管理

func New(config cfg.Registry) (*Registrar, error)

New creates a new Registrar instance, updating the registry file on `file.State` updates. New fails if the file can not be opened or created.

func (r *Registrar) GetStates() []file.State

GetStates return the registrar states

func (r *Registrar) Init() error

Init: 采集器启动时调用，同时对原采集器采集进度迁移

func (r *Registrar) Start() error

Start start the registry.

func (r *Registrar) Stop()

Stop stops the registry. It waits until Run function finished.