discover

package

v0.0.0-...-63b02d4 Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 30 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

Repository

github.com/opensvc/om3

Documentation ¶

Overview ¶

Package discover implements object discovery for daemon

It watches config filesystem to create initial instance config worker when config file is created. Instance config worker is then responsible for watching instance config updates

When is discovers that another remote config is available and no instance config worker is running, it fetches remote instance config to local config directory.

It is responsible for initial object status worker creation.

Index ¶

Variables
type Manager
- func NewManager(drainDuration time.Duration) *Manager
- func (t *Manager) Start(ctx context.Context) (err error)
- func (t *Manager) Stop() error

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// SubscriptionQueueSizeCfg is size of "discover.cfg" subscription
	SubscriptionQueueSizeCfg = 30000
)

View Source

var (
	// SubscriptionQueueSizeOmon is size of "discover.omon" subscription
	SubscriptionQueueSizeOmon = 16000
)

Functions ¶

This section is empty.

Types ¶

type Manager ¶

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

func NewManager ¶

func NewManager(drainDuration time.Duration) *Manager

NewManager prepares Discover with drainDuration.

func (*Manager) Start ¶

func (t *Manager) Start(ctx context.Context) (err error)

Start function starts file system watcher on config directory then listen for config file creation to create.

func (*Manager) Stop ¶

func (t *Manager) Stop() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL