servers

Documentation

Index

• Variables
• type DaemonServer
  • func (s *DaemonServer) AS(ctx context.Context, req *sdpb.ASRequest) (*sdpb.ASResponse, error)
  • func (s *DaemonServer) DRKeyASHost(ctx context.Context, req *pb_daemon.DRKeyASHostRequest) (*pb_daemon.DRKeyASHostResponse, error)
  • func (s *DaemonServer) DRKeyHostAS(ctx context.Context, req *pb_daemon.DRKeyHostASRequest) (*pb_daemon.DRKeyHostASResponse, error)
  • func (s *DaemonServer) DRKeyHostHost(ctx context.Context, req *pb_daemon.DRKeyHostHostRequest) (*pb_daemon.DRKeyHostHostResponse, error)
  • func (s *DaemonServer) Interfaces(ctx context.Context, req *sdpb.InterfacesRequest) (*sdpb.InterfacesResponse, error)
  • func (s *DaemonServer) NotifyInterfaceDown(ctx context.Context, req *sdpb.NotifyInterfaceDownRequest) (*sdpb.NotifyInterfaceDownResponse, error)
  • func (s *DaemonServer) Paths(ctx context.Context, req *sdpb.PathsRequest) (*sdpb.PathsResponse, error)
  • func (s *DaemonServer) Services(ctx context.Context, req *sdpb.ServicesRequest) (*sdpb.ServicesResponse, error)
• type Metrics
• type RequestMetrics
• type Topology

Variables

var (
	PathsRequestsLabels              = []string{prom.LabelResult, prom.LabelDst}
	ASRequestsLabels                 = []string{prom.LabelResult}
	InterfacesRequestsLabels         = []string{prom.LabelResult}
	ServicesRequestsLabels           = []string{prom.LabelResult}
	InterfaceDownNotificationsLabels = []string{prom.LabelResult, prom.LabelSrc}
	LatencyLabels                    = []string{prom.LabelResult}
)

Labels used for metrics in the Metrics struct, those labels should be used for initialization.

Types

type DaemonServer

type DaemonServer struct {
	IA          addr.IA
	MTU         uint16
	Topology    Topology
	Fetcher     fetcher.Fetcher
	RevCache    revcache.RevCache
	ASInspector trust.Inspector
	DRKeyClient *drkey_daemon.ClientEngine

	Metrics Metrics
	// contains filtered or unexported fields
}

DaemonServer handles gRPC requests to the SCION daemon.

func (*DaemonServer) AS

func (s *DaemonServer) AS(ctx context.Context, req *sdpb.ASRequest) (*sdpb.ASResponse, error)

AS serves the AS request.

func (*DaemonServer) DRKeyASHost

func (s *DaemonServer) DRKeyASHost(
	ctx context.Context,
	req *pb_daemon.DRKeyASHostRequest,
) (*pb_daemon.DRKeyASHostResponse, error)

func (*DaemonServer) DRKeyHostAS

func (s *DaemonServer) DRKeyHostAS(
	ctx context.Context,
	req *pb_daemon.DRKeyHostASRequest,
) (*pb_daemon.DRKeyHostASResponse, error)

func (*DaemonServer) DRKeyHostHost

func (s *DaemonServer) DRKeyHostHost(
	ctx context.Context,
	req *pb_daemon.DRKeyHostHostRequest,
) (*pb_daemon.DRKeyHostHostResponse, error)

func (*DaemonServer) Interfaces

func (s *DaemonServer) Interfaces(ctx context.Context,
	req *sdpb.InterfacesRequest) (*sdpb.InterfacesResponse, error)

Interfaces serves the interfaces request.

func (*DaemonServer) NotifyInterfaceDown

func (s *DaemonServer) NotifyInterfaceDown(ctx context.Context,
	req *sdpb.NotifyInterfaceDownRequest) (*sdpb.NotifyInterfaceDownResponse, error)

NotifyInterfaceDown notifies the server about an interface that is down.

func (*DaemonServer) Paths

func (s *DaemonServer) Paths(ctx context.Context,
	req *sdpb.PathsRequest) (*sdpb.PathsResponse, error)

Paths serves the paths request.

func (*DaemonServer) Services

func (s *DaemonServer) Services(ctx context.Context,
	req *sdpb.ServicesRequest) (*sdpb.ServicesResponse, error)

Services serves the services request.

type Metrics

type Metrics struct {
	PathsRequests              RequestMetrics
	ASRequests                 RequestMetrics
	InterfacesRequests         RequestMetrics
	ServicesRequests           RequestMetrics
	InterfaceDownNotifications RequestMetrics
}

Metrics can be used to inject metrics into the SCION daemon server. Each field may be set individually.

type RequestMetrics

type RequestMetrics struct {
	Requests metrics.Counter
	Latency  metrics.Histogram
}

RequestMetrics contains the metrics for a given request.

type Topology

type Topology interface {
	InterfaceIDs() []uint16
	UnderlayNextHop(uint16) *net.UDPAddr
	ControlServiceAddresses() []*net.UDPAddr
}