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

zookeeper

package
v0.45.4 Latest Latest
Warning

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

Go to latest
Published: Mar 18, 2024 License: Apache-2.0 Imports: 15 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 log.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 log.Logger) (*Discovery, error)

NewNerveDiscovery returns a new Discovery for the given Nerve config.

func NewServersetDiscovery

func NewServersetDiscovery(conf *ServersetSDConfig, logger log.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) UnmarshalYAML

func (c *NerveSDConfig) UnmarshalYAML(unmarshal func(interface{}) 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) UnmarshalYAML

func (c *ServersetSDConfig) UnmarshalYAML(unmarshal func(interface{}) 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