lakemanage

package

v1.14.0 Latest Latest Go to latest Published: Feb 15, 2024 License: BSD-3-Clause Imports: 20 Imported by: 0

Details

View Source

const DefaultInterval = time.Minute

This section is empty.

func Monitor(ctx context.Context, conn *client.Connection, conf Config, logger *zap.Logger) error

func Update(ctx context.Context, lk lakeapi.Interface, conf Config, logger *zap.Logger) error

type Config struct {
	Interval *time.Duration `yaml:"interval"`
	Vectors  bool           `yaml:"vectors"`
	Pools    []PoolConfig   `yaml:"pools"`
}

type PoolConfig struct {
	Pool    string `yaml:"pool"`
	Branch  string `yaml:"branch"`
	Vectors bool   `yaml:"vectors"`
}