FM / ndb

/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/

/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb

Name	Size	Mode	Actions
objects/	-	0755	rm
__pycache__/	-	0755	rm
auth_manager.py	2647	0644	edit dl rm
cli.py	2305	0644	edit dl rm
cluster.py	1003	0644	edit dl rm
compat.py	2254	0644	edit dl rm
events.py	2067	0644	edit dl rm
main.py	21460	0644	edit dl rm
messages.py	246	0644	edit dl rm
noipdb.py	5147	0644	edit dl rm
query.py	4867	0644	edit dl rm
report.py	12148	0644	edit dl rm
schema.py	32812	0644	edit dl rm
source.py	16959	0644	edit dl rm
task_manager.py	9808	0644	edit dl rm
transaction.py	11314	0644	edit dl rm
transport.py	6350	0644	edit dl rm
view.py	16900	0644	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/cluster.py (1003B)

import json
import socket

from pyroute2.common import basestring

from .main import NDB
from .transport import Messenger, Transport

def init(config):
    if isinstance(config, basestring):
        config = json.loads(config)
    else:
        config = json.load(config)
    hostname = config['local'].get('hostname', socket.gethostname())
    messenger = Messenger(
        config['local']['id'],
        Transport(config['local']['address'], config['local']['port']),
    )

for target in config['local'].get('targets', []):
        messenger.targets.add(target)

if not messenger.targets:
        messenger.targets.add(hostname)

for peer in config.get('peers', []):
        messenger.add_peer(*peer)

sources = config['local'].get('sources')
    if sources is None:
        sources = [{'target': hostname, 'kind': 'local'}]

return NDB(
        log=config.get('log', 'debug'),
        sources=sources,
        localhost=sources[0]['target'],
        messenger=messenger,
    )

import json import socket from pyroute2.common import basestring from .main import NDB from .transport import Messenger, Transport def init(config): if isinstance(config, basestring): config = json.loads(config) else: config = json.load(config) hostname = config['local'].get('hostname', socket.gethostname()) messenger = Messenger( config['local']['id'], Transport(config['local']['address'], config['local']['port']), ) for target in config['local'].get('targets', []): messenger.targets.add(target) if not messenger.targets: messenger.targets.add(hostname) for peer in config.get('peers', []): messenger.add_peer(*peer) sources = config['local'].get('sources') if sources is None: sources = [{'target': hostname, 'kind': 'local'}] return NDB( log=config.get('log', 'debug'), sources=sources, localhost=sources[0]['target'], messenger=messenger, )