Public Member Functions | |
def | __init__ |
def | set_expiration_manager |
def | is_active |
def | add_callback |
def | emission_complete |
def | transmission_complete |
def | ingestion_complete |
def | abort |
![]() | |
def | set_expiration_manager |
def | is_active |
def | add_callback |
def | emission_complete |
def | transmission_complete |
def | ingestion_complete |
def | abort |
An implementation of _interfaces.TerminationManager.
def grpc.framework.base._termination._TerminationManager.__init__ | ( | self, | |
work_pool, | |||
utility_pool, | |||
action, | |||
requirements, | |||
local_failure | |||
) |
Constructor. Args: work_pool: A thread pool in which customer work will be done. utility_pool: A thread pool in which work utility work will be done. action: An action to call on operation termination. requirements: A combination of _Requirement values identifying what must finish for the operation to be considered completed. local_failure: An interfaces.Outcome specifying what constitutes local failure of customer work.
def grpc.framework.base._termination._TerminationManager.abort | ( | self, | |
outcome | |||
) |
See _interfaces.TerminationManager.abort for specification.
def grpc.framework.base._termination._TerminationManager.add_callback | ( | self, | |
callback | |||
) |
See _interfaces.TerminationManager.add_callback for specification.
def grpc.framework.base._termination._TerminationManager.emission_complete | ( | self | ) |
See superclass method for specification.
def grpc.framework.base._termination._TerminationManager.ingestion_complete | ( | self | ) |
See superclass method for specification.
def grpc.framework.base._termination._TerminationManager.is_active | ( | self | ) |
See _interfaces.TerminationManager.is_active for specification.
def grpc.framework.base._termination._TerminationManager.transmission_complete | ( | self | ) |
See superclass method for specification.