Service API Reference

honeycomb.servicemanager.base_service module

Custom Service implementation from MazeRunner.

class honeycomb.servicemanager.base_service.DockerService(*args, **kwargs)

Bases: honeycomb.servicemanager.base_service.ServerCustomService

Provides an ability to run a Docker container that will be monitored for events.

docker_image_name

Return docker image name.

docker_params

Return a dictionary of docker run parameters.

See also

Docker run: https://docs.docker.com/engine/reference/run/

Returns:Dictionary, e.g., dict(ports={80: 80})

get_lines()

Fetch log lines from the docker service.

Returns:A blocking logs generator

on_server_shutdown()

Stop the container before shutting down.

on_server_start()

Service run loop function.

Run the desired docker container with parameters and start parsing the monitored file for alerts.

parse_line(line)

Parse line and return dictionary if its an alert, else None / {}.

read_lines(file_path, empty_lines=False, signal_ready=True)

Fetch lines from file.

In case the file handler changes (logrotate), reopen the file.

Parameters:

• file_path – Path to file
• empty_lines – Return empty lines
• signal_ready – Report signal ready on start

class honeycomb.servicemanager.base_service.ServerCustomService(alert_types: list, service_args: dict = {})

Bases: multiprocessing.context.Process

Custom Service Class.

This class provides a basic wrapper for honeycomb (and mazerunner) services.

add_alert_to_queue(alert_dict)

Log alert and send to integrations.

alert_types = None

List of alert types, parsed from config.json

alerts_queue = None

emit(**kwargs)

Send alerts to logfile.

Parameters:kwargs – Fields to pass to honeycomb.decoymanager.models.Alert

logger = <Logger honeycomb.servicemanager.base_service (DEBUG)>

Logger to be used by plugins and collected by main logger.

on_server_shutdown()

Shutdown function of the server.

Override this and take care to gracefully shut down your service (e.g., close files)

on_server_start()

Service run loop function.

The service manager will call this function in a new thread.

Note

Must call signal_ready() after finishing configuration

run()

Daemon entry point.

run_service()

Run the service and start an alert processing queue.

See also

Use on_server_start() and on_server_shutdown() for starting and shutting down your service

service_args = None

Validated dictionary of service arguments (see: honeycomb.utils.plugin_utils.parse_plugin_args())

signal_ready()

Signal the service manager this service is ready for incoming connections.

thread_server = None