grpc.framework.base._interfaces.IngestionManager Class Reference

Inheritance diagram for grpc.framework.base._interfaces.IngestionManager:

Public Member Functions
def	set_expiration_manager
def	start
def	consume
def	terminate
def	consume_and_terminate
def	abort

Detailed Description

A manager responsible for executing customer code.

Member Function Documentation

def grpc.framework.base._interfaces.IngestionManager.abort

(

self

)

Indicates to this manager that the operation has aborted.

def grpc.framework.base._interfaces.IngestionManager.consume	(		self,
			payload
	)

Accepts a customer-significant value to be supplied to customer code.

Args:
  payload: Some customer-significant value.

def grpc.framework.base._interfaces.IngestionManager.consume_and_terminate	(		self,
			payload
	)

Accepts the last value to be supplied to customer code.

Args:
  payload: Some customer-significant value (and the last such value).

def grpc.framework.base._interfaces.IngestionManager.set_expiration_manager	(		self,
			expiration_manager
	)

Sets the ExpirationManager with which this object will cooperate.

def grpc.framework.base._interfaces.IngestionManager.start	(		self,
			requirement
	)

Commences execution of customer code.

Args:
  requirement: Some value unavailable at the time of this object's
construction that is required to begin executing customer code.

def grpc.framework.base._interfaces.IngestionManager.terminate

(

self

)

Indicates the end of values to be supplied to customer code.

---

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

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