services

type Adapter struct {
	Peers func() map[string]GatewayRemote
	// contains filtered or unexported fields
}

type AdapterMetadata struct {
	Latencies   map[string]time.Duration
	Throughputs map[string]ThroughputResult
	UserEmail   string
}

type AdapterRemote struct {
	RequestCall      func(ctx context.Context, srcID, srcEmail, routeID, channelID string) (bool, error)
	TestLatency      func(ctx context.Context, timeout time.Duration, addrs []string, benchmarkClientCert CertPair) ([]time.Duration, error)
	TestThroughput   func(ctx context.Context, timeout time.Duration, addrs []string, benchmarkClientCert CertPair, benchmarkLimit int64) ([]ThroughputResult, error)
	UnprovisionRoute func(ctx context.Context, routeID string) error
	ProvisionRoute   func(
		ctx context.Context,
		routeID,
		channelID,
		raddr string,
		cert CertPair,
	) error
}

type CertPair struct {
	CertPEM        []byte
	CertPrivKeyPEM []byte
}

type Gateway struct {
	Router *Router

	Peers func() map[string]AdapterRemote
	// contains filtered or unexported fields
}

type GatewayRemote struct {
	RegisterAdapter  func(ctx context.Context, token string) ([]byte, error)
	RequestCall      func(ctx context.Context, token string, dstID, channelID string) (RequestCallResult, error)
	HangupCall       func(ctx context.Context, token string, routeID string) error
	ResolveEmailToID func(ctx context.Context, token string, email string) (string, error)
}

type Metrics struct {
	Peers func() map[string]VisualizerRemote
	// contains filtered or unexported fields
}

type MetricsRemote struct{}

type RequestCallResult struct {
	Accept  bool
	RouteID string
}

type Router struct {
	Metrics *Metrics
	Gateway *Gateway

	Peers func() map[string]SwitchRemote
	// contains filtered or unexported fields
}

type RouterRemote struct {
	RegisterSwitch func(ctx context.Context, token string, addr string) (SwitchConfiguration, error)
}

type Switch struct {
	Peers func() map[string]RouterRemote
	// contains filtered or unexported fields
}

type SwitchConfiguration struct {
	CAPEM               []byte
	BenchmarkListenCert CertPair
	BenchmarkLimit      int64
}

type SwitchMetadata struct {
	Addr        string
	Latencies   map[string]time.Duration
	Throughputs map[string]ThroughputResult
}

type SwitchRemote struct {
	TestLatency      func(ctx context.Context, timeout time.Duration, addrs []string, benchmarkClientCert CertPair) ([]time.Duration, error)
	TestThroughput   func(ctx context.Context, timeout time.Duration, addrs []string, benchmarkClientCert CertPair, benchmarkLimit int64) ([]ThroughputResult, error)
	UnprovisionRoute func(ctx context.Context, routeID string) error
	GetPublicIP      func(ctx context.Context) (string, error)
	ProvisionRoute   func(
		ctx context.Context,
		routeID string,
		raddr string,
		switchListenCert,
		switchClientCert,
		adapterListenCert CertPair,
	) ([]string, error)
}

type ThroughputResult struct {
	Read  time.Duration
	Write time.Duration
}

type Visualizer struct {
	Peers func() map[string]MetricsRemote
	// contains filtered or unexported fields
}

type VisualizerRemote struct {
	Attest func(
		ctx context.Context,
	) (string, error)
	RenderNetworkVisualization func(
		ctx context.Context,
		switches map[string]SwitchMetadata,
		adapters map[string]AdapterMetadata,
	) error
	RenderRoutesVisualization func(
		ctx context.Context,
		routes map[string][]string,
	) error
}