static

Documentation

Index

• type Config
  • func (x Config) Validate() error
• type Discovery
  • func NewDiscovery(config *Config) *Discovery
  • func (d *Discovery) Close() error
  • func (d *Discovery) Deregister() error
  • func (d *Discovery) DiscoverPeers() ([]string, error)
  • func (d *Discovery) ID() string
  • func (d *Discovery) Initialize() error
  • func (d *Discovery) Register() error

Types

type Config

type Config struct {
	// Hosts defines the list of hosts in the form of ip:port where the port is the  gossip port.
	Hosts []string
}

Config represents the static discovery provider configuration

func (Config) Validate

func (x Config) Validate() error

Validate checks whether the given discovery configuration is valid

type Discovery

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

Discovery represents the static discovery provider

func NewDiscovery

func NewDiscovery(config *Config) *Discovery

NewDiscovery creates an instance of the static discovery provider

func (*Discovery) Close

func (d *Discovery) Close() error

Close closes the provider

func (*Discovery) Deregister

func (d *Discovery) Deregister() error

Deregister removes this node from a service discovery directory.

func (*Discovery) DiscoverPeers

func (d *Discovery) DiscoverPeers() ([]string, error)

DiscoverPeers returns a list of known nodes.

func (*Discovery) ID

func (d *Discovery) ID() string

ID returns the discovery provider identifier

func (*Discovery) Initialize

func (d *Discovery) Initialize() error

Initialize the discovery provider

func (*Discovery) Register

func (d *Discovery) Register() error

Register registers this node to a service discovery directory.