Public Member Functions | |
def | __init__ |
def | set_ingestion_and_expiration_managers |
def | is_active |
def | add_termination_callback |
def | time_remaining |
def | fail |
![]() | |
def | is_active |
def | add_termination_callback |
def | time_remaining |
def | fail |
Public Attributes | |
operation_id | |
An implementation of interfaces.OperationContext.
def grpc.framework.base._context.OperationContext.__init__ | ( | self, | |
lock, | |||
operation_id, | |||
local_failure, | |||
termination_manager, | |||
transmission_manager | |||
) |
Constructor. Args: lock: The operation-wide lock. operation_id: An object identifying the operation. local_failure: 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.
def grpc.framework.base._context.OperationContext.add_termination_callback | ( | self, | |
callback | |||
) |
See interfaces.OperationContext.add_termination_callback.
def grpc.framework.base._context.OperationContext.fail | ( | self, | |
exception | |||
) |
See interfaces.OperationContext.fail for specification.
def grpc.framework.base._context.OperationContext.is_active | ( | self | ) |
See interfaces.OperationContext.is_active for specification.
def grpc.framework.base._context.OperationContext.set_ingestion_and_expiration_managers | ( | self, | |
ingestion_manager, | |||
expiration_manager | |||
) |
Sets managers with which this OperationContext cooperates. Args: ingestion_manager: The _interfaces.IngestionManager for the operation. expiration_manager: The _interfaces.ExpirationManager for the operation.
def grpc.framework.base._context.OperationContext.time_remaining | ( | self | ) |
See interfaces.OperationContext.time_remaining for specification.