ReaderProcessor
No overview available.
Methods
Process()
@classmethod
def Process(
ctx: context.Context,
workItem: workqueue.WorkItem
) - > (workqueue.WorkStatus, error)
Processes a work item using the provided context. This method is used to execute the core logic for a given work item, potentially involving interactions with a catalog client.
Parameters
| Name | Type | Description |
|---|---|---|
| ctx | context.Context | The context for the operation, used for cancellation signals and deadlines. |
| workItem | workqueue.WorkItem | The specific work item to be processed. |
Returns
| Type | Description |
|---|---|
(workqueue.WorkStatus, error) | A tuple containing the status of the work item processing and an error if one occurred. |