› Async::GRPC::XDS › Source › Async › GRPC › XDS › ClusterDiscoveryService

class ClusterDiscoveryService

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

Nested

Definitions

def initialize(control_plane)

Initialize a Cluster Discovery Service.

Signature
parameter　control_plane　ControlPlane

The control plane that provides clusters.

Implementation

 
def initialize(control_plane)
	super(Interface, SERVICE_NAME, control_plane, resource_type: RESOURCE_TYPE)
end

def stream_clusters(input, output, call)

  • asynchronous

Serve a state-of-the-world cluster discovery 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_clusters(input, output, call)
	stream_resources(input, output)
end

def delta_clusters(input, output, call)

Reject a delta cluster discovery stream, which is not supported.

Signature
raises　Protocol::GRPC::Error

Always raised because delta xDS is not implemented.

Implementation

 
def delta_clusters(input, output, call)
	delta_resources
end