core.event_service_tool Namespace Reference

Functions
def	config_gen_command (args)
def	list_uri (EventServiceConfig config)
def	uris_command (args)

Variables
	client = EventClient(config)
	uris = await client.list_uris()
	configs
	service_config
def	config = await list_uri(service_config)
	parser = argparse.ArgumentParser()
	sub_parsers = parser.add_subparsers()
	config_gen_parser = sub_parsers.add_parser("config-gen")
	default
	type
	func
	uris_parser = sub_parsers.add_parser("uris")
	args = parser.parse_args()

Detailed Description

Usage:
python -m farm_ng.core.event_service_tool uris config.json

This will print a config file will all the uris currently being published by the config

python -m farm_ng.core.event_service_tool config-gen config2.json

This print a sample config file with a single service called test_service, and an example
recorder service configuration (note with no port numbers so scripts no not to connect)

Runs a single service from the config file

python -m farm_ng.core.event_service_tool launch1 --service-config config.json --service-name test_service

Function Documentation

config_gen_command()

def core.event_service_tool.config_gen_command

(

args

)

list_uri()

def core.event_service_tool.list_uri

(

EventServiceConfig

config

)

uris_command()

def core.event_service_tool.uris_command

(

args

)

Variable Documentation

args

core.event_service_tool.args = parser.parse_args()

client

core.event_service_tool.client = EventClient(config)

config

def core.event_service_tool.config = await list_uri(service_config)

config_gen_parser

core.event_service_tool.config_gen_parser = sub_parsers.add_parser("config-gen")

configs

core.event_service_tool.configs

default

core.event_service_tool.default

func

core.event_service_tool.func

parser

core.event_service_tool.parser = argparse.ArgumentParser()

service_config

core.event_service_tool.service_config

sub_parsers

core.event_service_tool.sub_parsers = parser.add_subparsers()

type

core.event_service_tool.type

uris

core.event_service_tool.uris = await client.list_uris()

uris_parser

core.event_service_tool.uris_parser = sub_parsers.add_parser("uris")