core.event_service Namespace Reference

Classes
class	EventServiceGrpc
class	PublishResult

Functions
def	add_service_parser (parser)
def	load_service_config (_args)
def	event_service_main_args ()
None	test_send_smoke (EventServiceGrpc event_service)
None	test_send_smoke2 (EventServiceGrpc event_service)
Message	test_req_rep_handler_smoke (RequestReplyRequest request)
None	test_main (args, EventServiceGrpc event_service)

Variables
	frozen
	config_list
	service_config
	parser = argparse.ArgumentParser()
	type
	str
	required
	nargs
	args = parser.parse_args(service_config.args)
	EventServiceGrpc
	loop = asyncio.get_event_loop()

Detailed Description

# Will run an test_service from the config.
python -m farm_ng.core.event_service --service-config config.json --service-name test_service

Function Documentation

add_service_parser()

def core.event_service.add_service_parser

(

parser

)

event_service_main_args()

def core.event_service.event_service_main_args

(

)

load_service_config()

def core.event_service.load_service_config

(

_args

)

test_main()

None core.event_service.test_main	(		args,
		EventServiceGrpc	event_service
	)

test_req_rep_handler_smoke()

Message core.event_service.test_req_rep_handler_smoke

(

RequestReplyRequest

request

)

test_send_smoke()

None core.event_service.test_send_smoke

(

EventServiceGrpc

event_service

)

test_send_smoke2()

None core.event_service.test_send_smoke2

(

EventServiceGrpc

event_service

)

Variable Documentation

args

core.event_service.args = parser.parse_args(service_config.args)

config_list

core.event_service.config_list

EventServiceGrpc

core.event_service.EventServiceGrpc

frozen

core.event_service.frozen

loop

core.event_service.loop = asyncio.get_event_loop()

nargs

core.event_service.nargs

parser

core.event_service.parser = argparse.ArgumentParser()

required

core.event_service.required

service_config

core.event_service.service_config

str

core.event_service.str

type

core.event_service.type