application

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

type BeaconHealth struct {
	Connected bool   `json:"connected"`
	Healthy   bool   `json:"healthy"`
	Address   string `json:"address"`
}

type BeaconNodeInstance struct {
	Node         ethereum.BeaconNodeAPI
	Cache        *events.DuplicateCache
	Sinks        []sinks.ContributoorSink
	Metrics      *events.Metrics
	Summary      *events.Summary
	Address      string // The beacon node's address
	TopicManager ethereum.TopicManager
	// contains filtered or unexported fields
}

type HealthStatus struct {
	Healthy     bool                    `json:"healthy"`
	BeaconNodes map[string]BeaconHealth `json:"beacon_nodes"` //nolint:tagliatelle // upstream definition.
}

type Options struct {
	// Config is the Contributoor configuration. This field is required.
	Config *config.Config

	// Logger is the logger to use. If nil, a default logger will be created.
	Logger logrus.FieldLogger

	// Debug enables debug mode which uses stdout sink instead of the configured output.
	Debug bool

	// ClockDrift is an optional clock drift service. If nil, one will be created.
	ClockDrift clockdrift.ClockDrift

	// NTPServer is the NTP server to use for clock drift detection.
	// Defaults to "pool.ntp.org" if not specified.
	NTPServer string

	// ClockDriftSyncInterval is the interval for syncing with NTP.
	// Defaults to 5 minutes if not specified.
	ClockDriftSyncInterval time.Duration
}

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

type TestOptions struct {
	// T is the testing context, used for cleanup registration
	T *testing.T

	// Config to use. If nil, a minimal test config will be created
	Config *config.Config

	// Logger to use. If nil, a test logger will be created
	Logger logrus.FieldLogger

	// Debug mode
	Debug bool

	// Custom beacon addresses. If empty, uses localhost:5052
	BeaconAddresses []string
}