grpc.framework.base._ingestion._IngestionManager Class Reference

Inheritance diagram for grpc.framework.base._ingestion._IngestionManager:

Public Member Functions
def	__init__
def	set_expiration_manager
def	start
def	consume
def	terminate
def	consume_and_terminate
def	abort
Public Member Functions inherited from grpc.framework.base._interfaces.IngestionManager
def	set_expiration_manager
def	start
def	consume
def	terminate
def	consume_and_terminate
def	abort

Detailed Description

An implementation of _interfaces.IngestionManager.

Constructor & Destructor Documentation

def grpc.framework.base._ingestion._IngestionManager.__init__	(		self,
			lock,
			pool,
			consumer_creator,
			failure_outcome,
			termination_manager,
			transmission_manager
	)

Constructor.

Args:
  lock: The operation-wide lock.
  pool: A thread pool in which to execute customer code.
  consumer_creator: A _ConsumerCreator wrapping the portion of customer code
that when called returns the stream.Consumer with which the customer
code will ingest payload values.
  failure_outcome: Whichever one of
interfaces.Outcome.SERVICED_FAILURE or
interfaces.Outcome.SERVICER_FAILURE describes local failure of
customer code.
  termination_manager: The _interfaces.TerminationManager for the operation.
  transmission_manager: The _interfaces.TransmissionManager for the
operation.

Member Function Documentation

def grpc.framework.base._ingestion._IngestionManager.abort

(

self

)

See _interfaces.IngestionManager.abort for specification.

---

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

• src/python/src/grpc/framework/base/_ingestion.py