get_sink_policy ¶

def get_sink_policy(
    self,
    sink_identifier: "capo_oam.types.resource_identifier.ResourceIdentifier",
    *,
    config_overrides: Optional[OAMClientConfig] = None,
) -> "capo_oam.types.get_sink_policy_output.GetSinkPolicyOutput":
    """<p>Returns the current sink policy attached to this sink. The sink policy specifies what accounts can attach to this sink as source accounts, and what types of data they can share.</p>

    Args:
        sink_identifier: <p>The ARN of the sink to retrieve the policy of.</p>

    Raises:
        capo_oam.errors.internal_service_fault.InternalServiceFault: <p>Unexpected error while processing the request. Retry the request.</p>
        capo_oam.errors.invalid_parameter_exception.InvalidParameterException: <p>A parameter is specified incorrectly.</p>
        capo_oam.errors.missing_required_parameter_exception.MissingRequiredParameterException: <p>A required parameter is missing from the request.</p>
        capo_oam.errors.resource_not_found_exception.ResourceNotFoundException: <p>The request references a resource that does not exist.</p>
        capo_oam.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    def _handler(
        req: "OperationRequest[capo_oam.types.get_sink_policy_input.GetSinkPolicyInput]",
    ) -> OperationResponse[
        "capo_oam.types.get_sink_policy_output.GetSinkPolicyOutput"
    ]:
        import capo_oam._operations.oamservice.get_sink_policy

        output, http_response = (
            capo_oam._operations.oamservice.get_sink_policy.get_sink_policy(
                req.options, req.input
            )
        )
        return OperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("GetSinkPolicy")
    )
    input_: capo_oam.types.get_sink_policy_input.GetSinkPolicyInput = {
        "sink_identifier": sink_identifier
    }

    response = execute_pipeline(
        OperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    response.response.close()
    return response.output