xatu

Documentation

Index

• Constants
• type Config
  • func (c *Config) Validate() error
• type Coordinator
  • func New(config *Config, ...) (*Coordinator, error)
  • func (c *Coordinator) Start(ctx context.Context) error
  • func (c *Coordinator) Stop(ctx context.Context) error
  • func (c *Coordinator) Type() string

Constants

const Type = "xatu"

Types

type Config

type Config struct {
	Address      string            `yaml:"address"`
	Headers      map[string]string `yaml:"headers"`
	TLS          bool              `yaml:"tls" default:"false"`
	DiscV4       bool              `yaml:"discV4" default:"true"`
	DiscV5       bool              `yaml:"discV5" default:"true"`
	Restart      time.Duration     `yaml:"restart" default:"2m"`
	NetworkIds   []uint64          `yaml:"networkIds"`
	ForkIDHashes []string          `yaml:"forkIdHashes"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Coordinator

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

func New

func New(config *Config, handler func(ctx context.Context, node *enode.Node, source string) error, log logrus.FieldLogger) (*Coordinator, error)

func (*Coordinator) Start

func (c *Coordinator) Start(ctx context.Context) error

func (*Coordinator) Stop

func (c *Coordinator) Stop(ctx context.Context) error

func (*Coordinator) Type

func (c *Coordinator) Type() string