› Async::GRPC::XDS › Source › Async › GRPC › XDS › Service

`class Service`

Serves Envoy Aggregated Discovery Service requests from a class Async::GRPC::XDS::ControlPlane.

Definitions

`def initialize(control_plane)`

Initialize an Aggregated Discovery Service.

Signature

parameter　control_plane　ControlPlane: The control plane that provides resources.

Implementation

def initialize(control_plane)
	super(Envoy::Service::Discovery::V3::AggregatedDiscoveryService, SERVICE_NAME, control_plane)
end

`def stream_aggregated_resources(input, output, call)`

asynchronous

Serve a state-of-the-world Aggregated Discovery Service stream.

Signature

parameter　input　Enumerable: The stream of discovery requests.
parameter　output　Interface(:write): The discovery response stream.
parameter　call　Object: The gRPC call context.
asynchronous

Implementation

def stream_aggregated_resources(input, output, call)
	stream_resources(input, output)
end

`def delta_aggregated_resources(input, output, call)`

Reject a delta Aggregated Discovery Service stream, which is not supported.

Signature

parameter　input　Enumerable: The stream of delta discovery requests.
parameter　output　Interface(:write): The delta discovery response stream.
parameter　call　Object: The gRPC call context.
raises　Protocol::GRPC::Error: Always raised because delta xDS is not implemented.

Implementation

def delta_aggregated_resources(input, output, call)
	delta_resources
end