grpc

Documentation

Index

• type BeaconHandler
• type BeaconSender
  • func (r BeaconSender) SendBeacon(ctx context.Context, b *seg.PathSegment, remote net.Addr) error
• type Registrar
  • func (r Registrar) RegisterSegment(ctx context.Context, meta seg.Meta, remote net.Addr) error
• type SegmentCreationServer
  • func (s SegmentCreationServer) Beacon(ctx context.Context, req *cppb.BeaconRequest) (*cppb.BeaconResponse, error)

Types

type BeaconHandler

type BeaconHandler interface {
	HandleBeacon(ctx context.Context, b beacon.Beacon, peer *snet.UDPAddr) error
}

BeaconHandler handles the received beacons.

type BeaconSender

type BeaconSender struct {
	// Dialer dials a new gRPC connection.
	Dialer grpc.Dialer
}

BeaconSender propagates beacons.

func (BeaconSender) SendBeacon

func (r BeaconSender) SendBeacon(ctx context.Context, b *seg.PathSegment, remote net.Addr) error

SendBeacon sends a beacon to the remote.

type Registrar

type Registrar struct {
	// Dialer dials a new gRPC connection.
	Dialer grpc.Dialer
}

Registrar registers segments.

func (Registrar) RegisterSegment

func (r Registrar) RegisterSegment(ctx context.Context, meta seg.Meta, remote net.Addr) error

RegisterSegment registers a segment with the remote.

type SegmentCreationServer

type SegmentCreationServer struct {
	Handler BeaconHandler
}

SegmentCreationServer handles beaconing requests.

func (SegmentCreationServer) Beacon

func (s SegmentCreationServer) Beacon(ctx context.Context,
	req *cppb.BeaconRequest) (*cppb.BeaconResponse, error)