proxy

type Config struct {
	Proxy              ProxyConfig
	Targets            []NodeProviderConfig
	HealthChecks       HealthCheckConfig
	HealthcheckManager *HealthCheckManager
}

type HealthCheckConfig struct {
	Interval         time.Duration `yaml:"interval"`
	Timeout          time.Duration `yaml:"timeout"`
	FailureThreshold uint          `yaml:"failureThreshold"`
	SuccessThreshold uint          `yaml:"successThreshold"`
}

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

type HealthCheckManagerConfig struct {
	Targets []NodeProviderConfig
	Config  HealthCheckConfig
	Logger  *slog.Logger
}

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

type HealthCheckerConfig struct {
	URL    string
	Name   string // identifier imported from RPC gateway config
	Logger *slog.Logger

	// How often to check health.
	Interval time.Duration `yaml:"healthcheckInterval"`

	// How long to wait for responses before failing
	Timeout time.Duration `yaml:"healthcheckTimeout"`

	// Try FailureThreshold times before marking as unhealthy
	FailureThreshold uint `yaml:"healthcheckInterval"`

	// Minimum consecutive successes required to mark as healthy
	SuccessThreshold uint `yaml:"healthcheckInterval"`
}

type JSONRPCResponse struct {
	Jsonrpc string `json:"jsonrpc"`
	ID      int    `json:"id"`
	Result  string `json:"result"`
}

type NodeProvider struct {
	Config NodeProviderConfig
	Proxy  *httputil.ReverseProxy
}

type NodeProviderConfig struct {
	Name       string                       `yaml:"name"`
	Connection NodeProviderConnectionConfig `yaml:"connection"`
}

type NodeProviderConnectionConfig struct {
	HTTP NodeProviderConnectionHTTPConfig `yaml:"http"`
}

type NodeProviderConnectionHTTPConfig struct {
	URL         string `yaml:"url"`
	Compression bool   `yaml:"compression"`
}

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

type ProxyConfig struct {
	Port            string        `yaml:"port"`
	UpstreamTimeout time.Duration `yaml:"upstreamTimeout"`
}

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