static

Documentation

Index

• Constants
• type Config
  • func (c *Config) Validate() error
• type Metrics
  • func NewMetrics(namespace string) *Metrics
  • func (m *Metrics) SetPeers(count int, status string)
• type Static
  • func New(name string, config *Config, handlers *handler.Peer, ...) (*Static, error)
  • func (s *Static) Start(ctx context.Context) error
  • func (s *Static) Stop(ctx context.Context) error
  • func (s *Static) Type() string

Constants

const Type = "static"

Types

type Config

type Config struct {
	RetryInterval time.Duration `yaml:"retryInterval" default:"60s"`
	NodeRecords   []string      `yaml:"nodeRecords"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Metrics

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

func NewMetrics

func NewMetrics(namespace string) *Metrics

func (*Metrics) SetPeers

func (m *Metrics) SetPeers(count int, status string)

type Static

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

func New

func New(name string, config *Config, handlers *handler.Peer, captureDelay time.Duration, log logrus.FieldLogger) (*Static, error)

func (*Static) Start

func (s *Static) Start(ctx context.Context) error

func (*Static) Stop

func (s *Static) Stop(ctx context.Context) error

func (*Static) Type

func (s *Static) Type() string