grpcserver

package
v1.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 26, 2026 License: BSD-3-Clause Imports: 24 Imported by: 0

Documentation

Overview

Package grpcserver provides ConnectRPC service handlers for the PeeringDB gRPC API. Each handler implements the generated service interface and queries the ent database layer.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CampusService 

type CampusService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

CampusService implements the peeringdb.v1.CampusService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*CampusService) GetCampus 

func (s *CampusService) GetCampus(ctx context.Context, req *pb.GetCampusRequest) (*pb.GetCampusResponse, error)

GetCampus returns a single campus by ID. Returns NOT_FOUND if the campus does not exist.

func (*CampusService) ListCampuses 

func (s *CampusService) ListCampuses(ctx context.Context, req *pb.ListCampusesRequest) (*pb.ListCampusesResponse, error)

ListCampuses returns a paginated list of campuses ordered by ID ascending. Supports page_size, page_token, and optional filter fields (name, country, city, status, org_id). Multiple filters combine with AND logic.

func (*CampusService) StreamCampuses added in v1.7.0 

func (s *CampusService) StreamCampuses(ctx context.Context, req *pb.StreamCampusesRequest, stream *connect.ServerStream[pb.Campus]) error

StreamCampuses streams all matching campuses one message at a time using batched keyset pagination. Filters match the ListCampuses behavior.

type CarrierFacilityService 

type CarrierFacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

CarrierFacilityService implements the peeringdb.v1.CarrierFacilityService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*CarrierFacilityService) GetCarrierFacility 

func (s *CarrierFacilityService) GetCarrierFacility(ctx context.Context, req *pb.GetCarrierFacilityRequest) (*pb.GetCarrierFacilityResponse, error)

GetCarrierFacility returns a single carrier facility by ID. Returns NOT_FOUND if the carrier facility does not exist.

func (*CarrierFacilityService) ListCarrierFacilities 

func (s *CarrierFacilityService) ListCarrierFacilities(ctx context.Context, req *pb.ListCarrierFacilitiesRequest) (*pb.ListCarrierFacilitiesResponse, error)

ListCarrierFacilities returns a paginated list of carrier facilities ordered by ID ascending. Supports page_size, page_token, and optional filter fields (carrier_id, fac_id, status). Multiple filters combine with AND logic.

func (*CarrierFacilityService) StreamCarrierFacilities added in v1.7.0 

func (s *CarrierFacilityService) StreamCarrierFacilities(ctx context.Context, req *pb.StreamCarrierFacilitiesRequest, stream *connect.ServerStream[pb.CarrierFacility]) error

StreamCarrierFacilities streams all matching carrier facilities one message at a time using batched keyset pagination. Filters match the ListCarrierFacilities behavior.

type CarrierService 

type CarrierService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

CarrierService implements the peeringdb.v1.CarrierService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*CarrierService) GetCarrier 

func (s *CarrierService) GetCarrier(ctx context.Context, req *pb.GetCarrierRequest) (*pb.GetCarrierResponse, error)

GetCarrier returns a single carrier by ID. Returns NOT_FOUND if the carrier does not exist.

func (*CarrierService) ListCarriers 

func (s *CarrierService) ListCarriers(ctx context.Context, req *pb.ListCarriersRequest) (*pb.ListCarriersResponse, error)

ListCarriers returns a paginated list of carriers ordered by ID ascending. Supports page_size, page_token, and optional filter fields (name, status, org_id). Multiple filters combine with AND logic.

func (*CarrierService) StreamCarriers added in v1.7.0 

func (s *CarrierService) StreamCarriers(ctx context.Context, req *pb.StreamCarriersRequest, stream *connect.ServerStream[pb.Carrier]) error

StreamCarriers streams all matching carriers one message at a time using batched keyset pagination. Filters match the ListCarriers behavior.

type FacilityService 

type FacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

FacilityService implements the peeringdb.v1.FacilityService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*FacilityService) GetFacility 

func (s *FacilityService) GetFacility(ctx context.Context, req *pb.GetFacilityRequest) (*pb.GetFacilityResponse, error)

GetFacility returns a single facility by ID. Returns NOT_FOUND if the facility does not exist.

func (*FacilityService) ListFacilities 

func (s *FacilityService) ListFacilities(ctx context.Context, req *pb.ListFacilitiesRequest) (*pb.ListFacilitiesResponse, error)

ListFacilities returns a paginated list of facilities ordered by ID ascending. Supports page_size, page_token, and optional filter fields (name, country, city, status, org_id). Multiple filters combine with AND logic.

func (*FacilityService) StreamFacilities added in v1.7.0 

func (s *FacilityService) StreamFacilities(ctx context.Context, req *pb.StreamFacilitiesRequest, stream *connect.ServerStream[pb.Facility]) error

StreamFacilities streams all matching facilities one message at a time using batched keyset pagination. Filters match the ListFacilities behavior.

type InternetExchangeService 

type InternetExchangeService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

InternetExchangeService implements the peeringdb.v1.InternetExchangeService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*InternetExchangeService) GetInternetExchange 

func (s *InternetExchangeService) GetInternetExchange(ctx context.Context, req *pb.GetInternetExchangeRequest) (*pb.GetInternetExchangeResponse, error)

GetInternetExchange returns a single internet exchange by ID. Returns NOT_FOUND if the internet exchange does not exist.

func (*InternetExchangeService) ListInternetExchanges 

func (s *InternetExchangeService) ListInternetExchanges(ctx context.Context, req *pb.ListInternetExchangesRequest) (*pb.ListInternetExchangesResponse, error)

ListInternetExchanges returns a paginated list of internet exchanges ordered by ID ascending. Supports page_size, page_token, and optional filter fields (name, country, city, status, org_id). Multiple filters combine with AND logic.

func (*InternetExchangeService) StreamInternetExchanges added in v1.7.0 

func (s *InternetExchangeService) StreamInternetExchanges(ctx context.Context, req *pb.StreamInternetExchangesRequest, stream *connect.ServerStream[pb.InternetExchange]) error

StreamInternetExchanges streams all matching internet exchanges one message at a time using batched keyset pagination. Filters match the ListInternetExchanges behavior.

type IxFacilityService 

type IxFacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

IxFacilityService implements the peeringdb.v1.IxFacilityService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*IxFacilityService) GetIxFacility 

func (s *IxFacilityService) GetIxFacility(ctx context.Context, req *pb.GetIxFacilityRequest) (*pb.GetIxFacilityResponse, error)

GetIxFacility returns a single IX facility by ID. Returns NOT_FOUND if the IX facility does not exist.

func (*IxFacilityService) ListIxFacilities 

func (s *IxFacilityService) ListIxFacilities(ctx context.Context, req *pb.ListIxFacilitiesRequest) (*pb.ListIxFacilitiesResponse, error)

ListIxFacilities returns a paginated list of IX facilities ordered by ID ascending. Supports page_size, page_token, and optional filter fields (ix_id, fac_id, country, city, status). Multiple filters combine with AND logic.

func (*IxFacilityService) StreamIxFacilities added in v1.7.0 

func (s *IxFacilityService) StreamIxFacilities(ctx context.Context, req *pb.StreamIxFacilitiesRequest, stream *connect.ServerStream[pb.IxFacility]) error

StreamIxFacilities streams all matching IX facilities one message at a time using batched keyset pagination. Filters match the ListIxFacilities behavior.

type IxLanService 

type IxLanService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

IxLanService implements the peeringdb.v1.IxLanService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*IxLanService) GetIxLan 

func (s *IxLanService) GetIxLan(ctx context.Context, req *pb.GetIxLanRequest) (*pb.GetIxLanResponse, error)

GetIxLan returns a single IX LAN by ID. Returns NOT_FOUND if the IX LAN does not exist.

func (*IxLanService) ListIxLans 

func (s *IxLanService) ListIxLans(ctx context.Context, req *pb.ListIxLansRequest) (*pb.ListIxLansResponse, error)

ListIxLans returns a paginated list of IX LANs ordered by ID ascending. Supports page_size, page_token, and optional filter fields (ix_id, name, status). Multiple filters combine with AND logic.

func (*IxLanService) StreamIxLans added in v1.7.0 

func (s *IxLanService) StreamIxLans(ctx context.Context, req *pb.StreamIxLansRequest, stream *connect.ServerStream[pb.IxLan]) error

StreamIxLans streams all matching IX LANs one message at a time using batched keyset pagination. Filters match the ListIxLans behavior.

type IxPrefixService 

type IxPrefixService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

IxPrefixService implements the peeringdb.v1.IxPrefixService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*IxPrefixService) GetIxPrefix 

func (s *IxPrefixService) GetIxPrefix(ctx context.Context, req *pb.GetIxPrefixRequest) (*pb.GetIxPrefixResponse, error)

GetIxPrefix returns a single IX prefix by ID. Returns NOT_FOUND if the IX prefix does not exist.

func (*IxPrefixService) ListIxPrefixes 

func (s *IxPrefixService) ListIxPrefixes(ctx context.Context, req *pb.ListIxPrefixesRequest) (*pb.ListIxPrefixesResponse, error)

ListIxPrefixes returns a paginated list of IX prefixes ordered by ID ascending. Supports page_size, page_token, and optional filter fields (ixlan_id, protocol, status). Multiple filters combine with AND logic.

func (*IxPrefixService) StreamIxPrefixes added in v1.7.0 

func (s *IxPrefixService) StreamIxPrefixes(ctx context.Context, req *pb.StreamIxPrefixesRequest, stream *connect.ServerStream[pb.IxPrefix]) error

StreamIxPrefixes streams all matching IX prefixes one message at a time using batched keyset pagination. Filters match the ListIxPrefixes behavior.

type NetworkFacilityService 

type NetworkFacilityService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

NetworkFacilityService implements the peeringdb.v1.NetworkFacilityService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*NetworkFacilityService) GetNetworkFacility 

func (s *NetworkFacilityService) GetNetworkFacility(ctx context.Context, req *pb.GetNetworkFacilityRequest) (*pb.GetNetworkFacilityResponse, error)

GetNetworkFacility returns a single network facility by ID. Returns NOT_FOUND if the network facility does not exist.

func (*NetworkFacilityService) ListNetworkFacilities 

func (s *NetworkFacilityService) ListNetworkFacilities(ctx context.Context, req *pb.ListNetworkFacilitiesRequest) (*pb.ListNetworkFacilitiesResponse, error)

ListNetworkFacilities returns a paginated list of network facilities ordered by ID ascending. Supports page_size, page_token, and optional filter fields (net_id, fac_id, country, city, status). Multiple filters combine with AND logic.

func (*NetworkFacilityService) StreamNetworkFacilities added in v1.7.0 

func (s *NetworkFacilityService) StreamNetworkFacilities(ctx context.Context, req *pb.StreamNetworkFacilitiesRequest, stream *connect.ServerStream[pb.NetworkFacility]) error

StreamNetworkFacilities streams all matching network facilities one message at a time using batched keyset pagination. Filters match the ListNetworkFacilities behavior.

type NetworkIxLanService 

type NetworkIxLanService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

NetworkIxLanService implements the peeringdb.v1.NetworkIxLanService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*NetworkIxLanService) GetNetworkIxLan 

func (s *NetworkIxLanService) GetNetworkIxLan(ctx context.Context, req *pb.GetNetworkIxLanRequest) (*pb.GetNetworkIxLanResponse, error)

GetNetworkIxLan returns a single network IX LAN by ID. Returns NOT_FOUND if the network IX LAN does not exist.

func (*NetworkIxLanService) ListNetworkIxLans 

func (s *NetworkIxLanService) ListNetworkIxLans(ctx context.Context, req *pb.ListNetworkIxLansRequest) (*pb.ListNetworkIxLansResponse, error)

ListNetworkIxLans returns a paginated list of network IX LANs ordered by ID ascending. Supports page_size, page_token, and optional filter fields (net_id, ixlan_id, asn, name, status). Multiple filters combine with AND logic.

func (*NetworkIxLanService) StreamNetworkIxLans added in v1.7.0 

func (s *NetworkIxLanService) StreamNetworkIxLans(ctx context.Context, req *pb.StreamNetworkIxLansRequest, stream *connect.ServerStream[pb.NetworkIxLan]) error

StreamNetworkIxLans streams all matching network IX LANs one message at a time using batched keyset pagination. Filters match the ListNetworkIxLans behavior.

type NetworkService 

type NetworkService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

NetworkService implements the peeringdb.v1.NetworkService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*NetworkService) GetNetwork 

func (s *NetworkService) GetNetwork(ctx context.Context, req *pb.GetNetworkRequest) (*pb.GetNetworkResponse, error)

GetNetwork returns a single network by ID. Returns NOT_FOUND if the network does not exist.

func (*NetworkService) ListNetworks 

func (s *NetworkService) ListNetworks(ctx context.Context, req *pb.ListNetworksRequest) (*pb.ListNetworksResponse, error)

ListNetworks returns a paginated list of networks ordered by ID ascending. Supports page_size, page_token, and optional filter fields (asn, name, status, org_id). Multiple filters combine with AND logic. Name uses case-insensitive substring matching; other fields use exact match.

func (*NetworkService) StreamNetworks added in v1.7.0 

func (s *NetworkService) StreamNetworks(ctx context.Context, req *pb.StreamNetworksRequest, stream *connect.ServerStream[pb.Network]) error

StreamNetworks streams all matching networks one message at a time using batched keyset pagination. Filters match the ListNetworks behavior.

type OrganizationService 

type OrganizationService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

OrganizationService implements the peeringdb.v1.OrganizationService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*OrganizationService) GetOrganization 

func (s *OrganizationService) GetOrganization(ctx context.Context, req *pb.GetOrganizationRequest) (*pb.GetOrganizationResponse, error)

GetOrganization returns a single organization by ID. Returns NOT_FOUND if the organization does not exist.

func (*OrganizationService) ListOrganizations 

func (s *OrganizationService) ListOrganizations(ctx context.Context, req *pb.ListOrganizationsRequest) (*pb.ListOrganizationsResponse, error)

ListOrganizations returns a paginated list of organizations ordered by ID ascending. Supports page_size, page_token, and optional filter fields (name, country, city, status). Multiple filters combine with AND logic.

func (*OrganizationService) StreamOrganizations added in v1.7.0 

func (s *OrganizationService) StreamOrganizations(ctx context.Context, req *pb.StreamOrganizationsRequest, stream *connect.ServerStream[pb.Organization]) error

StreamOrganizations streams all matching organizations one message at a time using batched keyset pagination. Filters match the ListOrganizations behavior.

type PocService 

type PocService struct {
	Client        *ent.Client
	StreamTimeout time.Duration
}

PocService implements the peeringdb.v1.PocService ConnectRPC handler interface. It queries the ent database layer and converts results to protobuf messages.

func (*PocService) GetPoc 

func (s *PocService) GetPoc(ctx context.Context, req *pb.GetPocRequest) (*pb.GetPocResponse, error)

GetPoc returns a single point of contact by ID. Returns NOT_FOUND if the POC does not exist.

func (*PocService) ListPocs 

func (s *PocService) ListPocs(ctx context.Context, req *pb.ListPocsRequest) (*pb.ListPocsResponse, error)

ListPocs returns a paginated list of points of contact ordered by ID ascending. Supports page_size, page_token, and optional filter fields (net_id, role, name, status). Multiple filters combine with AND logic.

func (*PocService) StreamPocs added in v1.7.0 

func (s *PocService) StreamPocs(ctx context.Context, req *pb.StreamPocsRequest, stream *connect.ServerStream[pb.Poc]) error

StreamPocs streams all matching points of contact one message at a time using batched keyset pagination. Filters match the ListPocs behavior.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.