Public Member Functions
def	__init__
def	do
def	start
def	start_excluding_directories
def	do_auditctl_rule
def	remove_auditctl_rules
def	stop
def	reload
def	stop_watching_directory
def	restart
def	fuse_kafka_running_at
def	list_watched_directories
def	get_status
def	status
def	cleanup
Data Fields
	auditctl_bin
	prefix
	proc_mount_path
	configuration

Detailed Description

Utility class to run multiple fuse_kafka processes as one service

Definition at line 172 of file fuse_kafka.py.

Member Function Documentation

def fuse_kafka.FuseKafkaService.cleanup ( self )

if a fuse kafka mountpoint is not accessible, umount it.
Also installs this action in the crontab so it is launched
every minute.

Definition at line 319 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.do	(	self,
		action
	)

Actually run an action 

action - the action name

Definition at line 181 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.get_status ( self )

Displays the status of fuse_kafka processes

Definition at line 306 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.reload	(	self,
		var_run_path = `"/var/run"`
	)

if fuse_kafka is running, reloads the dynamic part of 
the configuration. If it is not running, starts it

Definition at line 250 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.restart ( self )

Stops and starts fuse_kafka processes

Definition at line 274 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.start_excluding_directories	(	self,
		excluded
	)

Starts fuse_kafka processes

Definition at line 193 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.stop ( self )

Stops fuse_kafka processes

Definition at line 241 of file fuse_kafka.py.

def fuse_kafka.FuseKafkaService.stop_watching_directory	(	self,
		to_stop_watching
	)

Stops fuse_kafka process for a specific directory

Definition at line 268 of file fuse_kafka.py.

The documentation for this class was generated from the following file: