relay

type ClientKey struct {
	Endpoint model.Endpoint `json:"endpoint"`
	Role     model.Role     `json:"role"`
	Key      model.Key      `json:"key"`
}

type ClientValue struct {
	Cert *x509.Certificate `json:"cert"`
}

type Config struct {
	Metadata string

	ControlAddr  *net.UDPAddr
	ControlHost  string
	ControlToken string
	ControlCAs   *x509.CertPool

	HandshakeIdleTimeout time.Duration

	Ingress []Ingress

	Stores Stores

	Logger *slog.Logger
}

type ConfigKey string

type ConfigValue struct {
	Int64  int64  `json:"int64,omitempty"`
	String string `json:"string,omitempty"`
	Bytes  []byte `json:"bytes,omitempty"`
}

type EndpointPeerStatus struct {
	Key      model.Key `json:"key"`
	Metadata string    `json:"metadata"`
}

type EndpointStatus struct {
	Endpoint     model.Endpoint                   `json:"endpoint"`
	Destinations map[model.Key]EndpointPeerStatus `json:"destinations"`
	Sources      map[model.Key]EndpointPeerStatus `json:"sources"`
}

type Ingress struct {
	Addr      *net.UDPAddr
	Hostports []model.HostPort
	Restr     restr.IP
}

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

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

type ServerKey struct {
	Endpoint model.Endpoint `json:"endpoint"`
}

type ServerValue struct {
	Name    string                          `json:"name"`
	Cert    *certc.Cert                     `json:"cert"`
	Clients map[serverClientKey]ClientValue `json:"clients"`
}

type Status struct {
	Status       statusc.Status            `json:"status"`
	BuildVersion string                    `json:"build-version"`
	Hostports    []string                  `json:"hostports"`
	ServerAddr   string                    `json:"server-addrress"`
	ServerID     string                    `json:"server-id"`
	Endpoints    map[string]EndpointStatus `json:"endpoints"`
}

type Stores interface {
	Config() (logc.KV[ConfigKey, ConfigValue], error)
	Clients() (logc.KV[ClientKey, ClientValue], error)
	Servers() (logc.KV[ServerKey, ServerValue], error)
}

type TransportsFn func(ctx context.Context) ([]*quic.Transport, error)