Help us shape the future of Go! Take the 2026 Go Developer Survey

zookeeper

package
v0.313.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 21, 2026 License: Apache-2.0 Imports: 17 Imported by: 309

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// DefaultServersetSDConfig is the default Serverset SD configuration.
	DefaultServersetSDConfig = ServersetSDConfig{
		Timeout: model.Duration(10 * time.Second),
	}
	// DefaultNerveSDConfig is the default Nerve SD configuration.
	DefaultNerveSDConfig = NerveSDConfig{
		Timeout: model.Duration(10 * time.Second),
	}
)

Functions

This section is empty.

Types

type Discovery

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

Discovery implements the Discoverer interface for discovering targets from Zookeeper.

func NewDiscovery

func NewDiscovery(
	srvs []string,
	timeout time.Duration,
	paths []string,
	logger *slog.Logger,
	pf func(data []byte, path string) (model.LabelSet, error),
) (*Discovery, error)

NewDiscovery returns a new discovery along Zookeeper parses with the given parse function.

func NewNerveDiscovery

func NewNerveDiscovery(conf *NerveSDConfig, logger *slog.Logger) (*Discovery, error)

NewNerveDiscovery returns a new Discovery for the given Nerve config.

func NewServersetDiscovery

func NewServersetDiscovery(conf *ServersetSDConfig, logger *slog.Logger) (*Discovery, error)

NewServersetDiscovery returns a new Discovery for the given serverset config.

func (*Discovery) Run

func (d *Discovery) Run(ctx context.Context, ch chan<- []*targetgroup.Group)

Run implements the Discoverer interface.

type NerveSDConfig

type NerveSDConfig struct {
	Servers []string       `yaml:"servers"`
	Paths   []string       `yaml:"paths"`
	Timeout model.Duration `yaml:"timeout,omitempty"`
}

NerveSDConfig is the configuration for AirBnB's Nerve in Zookeeper based discovery.

func (*NerveSDConfig) Name

func (*NerveSDConfig) Name() string

Name returns the name of the Config.

func (*NerveSDConfig) NewDiscoverer

NewDiscoverer returns a Discoverer for the Config.

func (*NerveSDConfig) NewDiscovererMetrics added in v0.50.0

NewDiscovererMetrics implements discovery.Config.

func (*NerveSDConfig) UnmarshalYAML

func (c *NerveSDConfig) UnmarshalYAML(unmarshal func(any) error) error

UnmarshalYAML implements the yaml.Unmarshaler interface.

type ServersetSDConfig

type ServersetSDConfig struct {
	Servers []string       `yaml:"servers"`
	Paths   []string       `yaml:"paths"`
	Timeout model.Duration `yaml:"timeout,omitempty"`
}

ServersetSDConfig is the configuration for Twitter serversets in Zookeeper based discovery.

func (*ServersetSDConfig) Name

func (*ServersetSDConfig) Name() string

Name returns the name of the Config.

func (*ServersetSDConfig) NewDiscoverer

NewDiscoverer returns a Discoverer for the Config.

func (*ServersetSDConfig) NewDiscovererMetrics added in v0.50.0

NewDiscovererMetrics implements discovery.Config.

func (*ServersetSDConfig) UnmarshalYAML

func (c *ServersetSDConfig) UnmarshalYAML(unmarshal func(any) error) error

UnmarshalYAML implements the yaml.Unmarshaler interface.

Jump to

Keyboard shortcuts

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