class Monitor

parameter　bind　String | Nil

The optional address for the xDS control plane server.

parameter　delegate　Delegate

The delegate used to map supervisor state into Envoy endpoints.

parameter　control_plane　Async::GRPC::XDS::ControlPlane

The xDS control plane to update.

def initialize(
	bind: nil,
	delegate: Delegate.new,
	control_plane: Async::GRPC::XDS::ControlPlane.new,
	**options
)
	super(**options)
	
	@bind = bind
	@delegate = delegate
	@control_plane = control_plane
	@controllers = {}
	@published_clusters = {}
	@server_task = nil
	@mutex = Mutex.new
end

attribute　Async::GRPC::XDS::ControlPlane

The xDS control plane receiving cluster and endpoint updates.

attribute　Delegate

The delegate used to map supervisor state into Envoy endpoints.

parameter　supervisor_controller　Object

The supervisor controller describing the worker.

returns　void

def register(supervisor_controller)
	@mutex.synchronize do
		@controllers[supervisor_controller.id] = supervisor_controller
		reconcile
	end
end

parameter　supervisor_controller　Object

The supervisor controller describing the worker.

returns　void

def remove(supervisor_controller)
	@mutex.synchronize do
		@controllers.delete(supervisor_controller.id)
		reconcile
	end
end

parameter　parent　Async::Task

The parent task used for the xDS server.

returns　Async::Task

The monitor task.

def run(parent: Async::Task.current)
	task = super(parent: parent)
	
	if @bind
		@server_task = parent.async do
			endpoint = Async::HTTP::Endpoint.parse(@bind, protocol: Async::HTTP::Protocol::HTTP2)
			Async::GRPC::XDS::Server.new(@control_plane).run(endpoint)
		end
	end
	
	task
end

returns　Hash

The clusters and endpoint hashes.

def as_json
	@mutex.synchronize do
		{
			clusters: build_clusters
		}
	end
end

returns　void

def run_once
	@mutex.synchronize do
		reconcile
	end
end