headwaters-proto 0.0.2

///Shorthand for `OwnedView<ListNamespacesRequestView<'static>>`.
pub type OwnedListNamespacesRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesRequestView<'static>,
>;
///Shorthand for `OwnedView<ListNamespacesResponseView<'static>>`.
pub type OwnedListNamespacesResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesResponseView<
        'static,
    >,
>;
///Shorthand for `OwnedView<ListJobsRequestView<'static>>`.
pub type OwnedListJobsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListJobsRequestView<'static>,
>;
///Shorthand for `OwnedView<ListJobsResponseView<'static>>`.
pub type OwnedListJobsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListJobsResponseView<'static>,
>;
///Shorthand for `OwnedView<GetJobRequestView<'static>>`.
pub type OwnedGetJobRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetJobRequestView<'static>,
>;
///Shorthand for `OwnedView<JobDetailView<'static>>`.
pub type OwnedJobDetailView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::JobDetailView<'static>,
>;
///Shorthand for `OwnedView<GetJobRunsRequestView<'static>>`.
pub type OwnedGetJobRunsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetJobRunsRequestView<'static>,
>;
///Shorthand for `OwnedView<ListRunsResponseView<'static>>`.
pub type OwnedListRunsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListRunsResponseView<'static>,
>;
///Shorthand for `OwnedView<ListDatasetsRequestView<'static>>`.
pub type OwnedListDatasetsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsRequestView<'static>,
>;
///Shorthand for `OwnedView<ListDatasetsResponseView<'static>>`.
pub type OwnedListDatasetsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsResponseView<'static>,
>;
///Shorthand for `OwnedView<GetDatasetRequestView<'static>>`.
pub type OwnedGetDatasetRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetDatasetRequestView<'static>,
>;
///Shorthand for `OwnedView<DatasetView<'static>>`.
pub type OwnedDatasetView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::DatasetView<'static>,
>;
///Shorthand for `OwnedView<ListDatasetVersionsRequestView<'static>>`.
pub type OwnedListDatasetVersionsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsRequestView<
        'static,
    >,
>;
///Shorthand for `OwnedView<ListDatasetVersionsResponseView<'static>>`.
pub type OwnedListDatasetVersionsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsResponseView<
        'static,
    >,
>;
///Shorthand for `OwnedView<SearchRequestView<'static>>`.
pub type OwnedSearchRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::SearchRequestView<'static>,
>;
///Shorthand for `OwnedView<SearchResponseView<'static>>`.
pub type OwnedSearchResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::SearchResponseView<'static>,
>;
///Shorthand for `OwnedView<GetLineageRequestView<'static>>`.
pub type OwnedGetLineageRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetLineageRequestView<'static>,
>;
///Shorthand for `OwnedView<LineageGraphView<'static>>`.
pub type OwnedLineageGraphView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<'static>,
>;
///Shorthand for `OwnedView<GetColumnLineageRequestView<'static>>`.
pub type OwnedGetColumnLineageRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetColumnLineageRequestView<
        'static,
    >,
>;
///Shorthand for `OwnedView<ListEventsRequestView<'static>>`.
pub type OwnedListEventsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListEventsRequestView<'static>,
>;
///Shorthand for `OwnedView<ListEventsResponseView<'static>>`.
pub type OwnedListEventsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListEventsResponseView<'static>,
>;
///Shorthand for `OwnedView<GetRunFacetsRequestView<'static>>`.
pub type OwnedGetRunFacetsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetRunFacetsRequestView<'static>,
>;
///Shorthand for `OwnedView<RunFacetsResponseView<'static>>`.
pub type OwnedRunFacetsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::RunFacetsResponseView<'static>,
>;
///Shorthand for `OwnedView<ListTagsRequestView<'static>>`.
pub type OwnedListTagsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListTagsRequestView<'static>,
>;
///Shorthand for `OwnedView<ListTagsResponseView<'static>>`.
pub type OwnedListTagsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListTagsResponseView<'static>,
>;
///Shorthand for `OwnedView<GetTagDownstreamRequestView<'static>>`.
pub type OwnedGetTagDownstreamRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetTagDownstreamRequestView<
        'static,
    >,
>;
///Shorthand for `OwnedView<TagPropagationView<'static>>`.
pub type OwnedTagPropagationView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::TagPropagationView<'static>,
>;
///Shorthand for `OwnedView<GetLineageEventStatsRequestView<'static>>`.
pub type OwnedGetLineageEventStatsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetLineageEventStatsRequestView<
        'static,
    >,
>;
///Shorthand for `OwnedView<StatsResponseView<'static>>`.
pub type OwnedStatsResponseView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<'static>,
>;
///Shorthand for `OwnedView<GetAssetStatsRequestView<'static>>`.
pub type OwnedGetAssetStatsRequestView = ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::GetAssetStatsRequestView<'static>,
>;
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListNamespacesResponse>
for crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListNamespacesResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesResponseView<
        'static,
    >,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListJobsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::ListJobsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListJobsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListJobsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::JobDetail>
for crate::proto::headwaters::read::v1::__buffa::view::JobDetailView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::JobDetail>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::JobDetailView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListRunsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::ListRunsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListRunsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListRunsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListDatasetsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListDatasetsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::Dataset>
for crate::proto::headwaters::read::v1::__buffa::view::DatasetView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::Dataset>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::DatasetView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<
    crate::proto::headwaters::read::v1::ListDatasetVersionsResponse,
>
for crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsResponseView<
    '_,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<
    crate::proto::headwaters::read::v1::ListDatasetVersionsResponse,
>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsResponseView<
        'static,
    >,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::SearchResponse>
for crate::proto::headwaters::read::v1::__buffa::view::SearchResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::SearchResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::SearchResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::LineageGraph>
for crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::LineageGraph>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListEventsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::ListEventsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListEventsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListEventsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::RunFacetsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::RunFacetsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::RunFacetsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::RunFacetsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListTagsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::ListTagsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::ListTagsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::ListTagsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::TagPropagation>
for crate::proto::headwaters::read::v1::__buffa::view::TagPropagationView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::TagPropagation>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::TagPropagationView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::StatsResponse>
for crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<'_> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self, codec)
    }
}
impl ::connectrpc::Encodable<crate::proto::headwaters::read::v1::StatsResponse>
for ::buffa::view::OwnedView<
    crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<'static>,
> {
    fn encode(
        &self,
        codec: ::connectrpc::CodecFormat,
    ) -> ::std::result::Result<::buffa::bytes::Bytes, ::connectrpc::ConnectError> {
        ::connectrpc::__codegen::encode_view_body(self.reborrow(), codec)
    }
}
/// Full service name for this service.
pub const READ_SERVICE_SERVICE_NAME: &str = "headwaters.read.v1.ReadService";
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListNamespaces` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_LIST_NAMESPACES_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/ListNamespaces",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListJobs` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_LIST_JOBS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/ListJobs",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetJob` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_JOB_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetJob",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetJobRuns` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_JOB_RUNS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetJobRuns",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListDatasets` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_LIST_DATASETS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/ListDatasets",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetDataset` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_DATASET_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetDataset",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListDatasetVersions` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_LIST_DATASET_VERSIONS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/ListDatasetVersions",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `Search` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_SEARCH_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/Search",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetLineage` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_LINEAGE_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetLineage",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetColumnLineage` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_COLUMN_LINEAGE_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetColumnLineage",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListEvents` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_LIST_EVENTS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/ListEvents",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetRunFacets` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_RUN_FACETS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetRunFacets",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `ListTags` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_LIST_TAGS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/ListTags",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetTagDownstream` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_TAG_DOWNSTREAM_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetTagDownstream",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetLineageEventStats` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_LINEAGE_EVENT_STATS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetLineageEventStats",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// Static [`Spec`](::connectrpc::Spec) for the server-side `GetAssetStats` RPC.
///
/// The dispatcher surfaces this on
/// [`RequestContext::spec`](::connectrpc::RequestContext::spec).
pub const READ_SERVICE_GET_ASSET_STATS_SPEC: ::connectrpc::Spec = ::connectrpc::Spec::server(
        "/headwaters.read.v1.ReadService/GetAssetStats",
        ::connectrpc::StreamType::Unary,
    )
    .with_idempotency_level(::connectrpc::IdempotencyLevel::Unknown);
/// --- namespaces ---
///
/// # Implementing handlers
///
/// Implement methods with plain `async fn`; the returned future satisfies
/// the `Send` bound automatically.
///
/// **Unary and server-streaming requests** arrive as
/// [`ServiceRequest<'_, Req>`](::connectrpc::ServiceRequest): a zero-copy
/// view of the request plus its body, valid for the duration of the call.
/// Fields are read directly (`request.name` is a `&str` into the decoded
/// buffer) and the borrow may be held across `.await` points. Anything
/// that must outlive the call — `tokio::spawn`, channels, server state,
/// or data captured by a returned response stream — takes owned data:
/// call `request.to_owned_message()` (or copy the specific fields)
/// first.
///
/// **Client-streaming and bidi requests** arrive as
/// `ServiceStream<`[`StreamMessage<Req>`](::connectrpc::StreamMessage)`>`.
/// Each item owns its decoded buffer and is `Send + 'static`, so items
/// can be buffered or moved into spawned tasks; read fields zero-copy
/// through the generated accessor methods (`item.name()`) or `.view()`,
/// convert with `.to_owned_message()`, or yield an item back unchanged —
/// `StreamMessage<M>` implements `Encodable<M>`.
///
/// Request types resolved through `extern_path` (e.g. well-known types
/// from another crate) use the same wrappers; the crate that owns the
/// type must be generated with buffa ≥ 0.7.0 and views enabled so the
/// backing `HasMessageView` impl exists.
///
/// The `impl Encodable<Out>` return bound accepts the owned `Out`, the
/// generated `OutView<'_>` / `OwnedOutView`,
/// [`MaybeBorrowed`](::connectrpc::MaybeBorrowed), or
/// [`PreEncoded`](::connectrpc::PreEncoded) for handlers that encode a
/// non-`'static` view internally and pass the bytes across the handler
/// boundary. View bodies are not emitted for output types mapped via
/// `extern_path` (the impl would be an orphan); return owned for
/// WKT/extern outputs.
///
/// Server-streaming and bidi-streaming methods return
/// `ServiceStream<impl Encodable<Out> + Send + use<Self>>`. The
/// `use<Self>` precise-capturing clause excludes `&self`'s lifetime and
/// the request's lifetime (unary methods use `use<'a, Self>` and may
/// borrow from `&self`), so stream items must be `'static` and cannot
/// borrow from the request. To stream view-encoded data, encode each
/// item inside the stream body and yield
/// [`PreEncoded`](::connectrpc::PreEncoded) — see its `# Streaming
/// example` doc.
#[allow(clippy::type_complexity)]
pub trait ReadService: Send + Sync + 'static {
    /// Handle the ListNamespaces RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_namespaces<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::ListNamespacesRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListNamespacesResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// List jobs, optionally scoped to one namespace.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_jobs<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::ListJobsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListJobsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the GetJob RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_job<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetJobRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::JobDetail,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the GetJobRuns RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_job_runs<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetJobRunsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListRunsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the ListDatasets RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_datasets<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::ListDatasetsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListDatasetsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the GetDataset RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_dataset<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetDatasetRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::Dataset,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the ListDatasetVersions RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_dataset_versions<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::ListDatasetVersionsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListDatasetVersionsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Substring search over job and dataset names.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn search<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::SearchRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::SearchResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Entity-level lineage: the jobs and datasets within `depth` hops of a seed
    /// node, with the edges between them.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_lineage<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetLineageRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::LineageGraph,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Column-level lineage: how a dataset's fields derive from upstream fields.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_column_lineage<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetColumnLineageRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::LineageGraph,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the ListEvents RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_events<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::ListEventsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListEventsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the GetRunFacets RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_run_facets<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetRunFacetsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::RunFacetsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the ListTags RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn list_tags<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::ListTagsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::ListTagsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Every field a tag reaches downstream through column lineage.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_tag_downstream<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetTagDownstreamRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::TagPropagation,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the GetLineageEventStats RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_lineage_event_stats<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetLineageEventStatsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::StatsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
    /// Handle the GetAssetStats RPC.
    ///
    /// `'a` lets the response body borrow from `&self` (e.g. server-resident state).
    ///
    /// `request` is borrowed from the request body and is valid for the
    /// duration of the call; message fields are read directly on it
    /// (zero-copy). The response cannot borrow from `request` — use
    /// `.to_owned_message()` (or copy the specific fields) for anything
    /// returned, stored, or moved into `tokio::spawn`.
    fn get_asset_stats<'a>(
        &'a self,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::ServiceRequest<
            '_,
            crate::proto::headwaters::read::v1::GetAssetStatsRequest,
        >,
    ) -> impl ::std::future::Future<
        Output = ::connectrpc::ServiceResult<
            impl ::connectrpc::Encodable<
                crate::proto::headwaters::read::v1::StatsResponse,
            > + Send + use<'a, Self>,
        >,
    > + Send;
}
/// Extension trait for registering a service implementation with a Router.
///
/// This trait is automatically implemented for all types that implement the service trait.
///
/// # Example
///
/// ```rust,ignore
/// use std::sync::Arc;
///
/// let service = Arc::new(MyServiceImpl);
/// let router = service.register(Router::new());
/// ```
pub trait ReadServiceExt: ReadService {
    /// Register this service implementation with a Router.
    ///
    /// Takes ownership of the `Arc<Self>` and returns a new Router with
    /// this service's methods registered.
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router;
}
impl<S: ReadService> ReadServiceExt for S {
    fn register(
        self: ::std::sync::Arc<Self>,
        router: ::connectrpc::Router,
    ) -> ::connectrpc::Router {
        router
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "ListNamespaces",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::ListNamespacesRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_namespaces(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListNamespacesResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_LIST_NAMESPACES_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "ListJobs",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::ListJobsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::ListJobsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_jobs(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListJobsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_LIST_JOBS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetJob",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetJobRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetJobRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_job(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::JobDetail,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_JOB_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetJobRuns",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetJobRunsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetJobRunsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_job_runs(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListRunsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_JOB_RUNS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "ListDatasets",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::ListDatasetsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_datasets(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListDatasetsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_LIST_DATASETS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetDataset",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetDatasetRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetDatasetRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_dataset(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::Dataset,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_DATASET_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "ListDatasetVersions",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::ListDatasetVersionsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_dataset_versions(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListDatasetVersionsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_LIST_DATASET_VERSIONS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "Search",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::SearchRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::SearchRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.search(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::SearchResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_SEARCH_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetLineage",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetLineageRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetLineageRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_lineage(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::LineageGraph,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_LINEAGE_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetColumnLineage",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetColumnLineageRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetColumnLineageRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_column_lineage(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::LineageGraph,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_COLUMN_LINEAGE_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "ListEvents",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::ListEventsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::ListEventsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_events(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListEventsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_LIST_EVENTS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetRunFacets",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetRunFacetsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetRunFacetsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_run_facets(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::RunFacetsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_RUN_FACETS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "ListTags",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::ListTagsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::ListTagsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.list_tags(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::ListTagsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_LIST_TAGS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetTagDownstream",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetTagDownstreamRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetTagDownstreamRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_tag_downstream(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::TagPropagation,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_TAG_DOWNSTREAM_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetLineageEventStats",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetLineageEventStatsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetLineageEventStatsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_lineage_event_stats(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::StatsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_LINEAGE_EVENT_STATS_SPEC)
            .route_view(
                READ_SERVICE_SERVICE_NAME,
                "GetAssetStats",
                {
                    let svc = ::std::sync::Arc::clone(&self);
                    ::connectrpc::view_handler_fn(move |
                        ctx,
                        req: ::buffa::view::OwnedView<
                            crate::proto::headwaters::read::v1::__buffa::view::GetAssetStatsRequestView<
                                'static,
                            >,
                        >,
                        format|
                    {
                        let svc = ::std::sync::Arc::clone(&svc);
                        async move {
                            let sreq = ::connectrpc::ServiceRequest::<
                                crate::proto::headwaters::read::v1::GetAssetStatsRequest,
                            >::from_parts(req.reborrow(), req.bytes());
                            svc.get_asset_stats(ctx, sreq)
                                .await?
                                .encode::<
                                    crate::proto::headwaters::read::v1::StatsResponse,
                                >(format)
                        }
                    })
                },
            )
            .with_spec(READ_SERVICE_GET_ASSET_STATS_SPEC)
    }
}
/// Monomorphic dispatcher for `ReadService`.
///
/// Unlike `.register(Router)` which type-erases each method into an `Arc<dyn ErasedHandler>` stored in a `HashMap`, this struct dispatches via a compile-time `match` on method name: no vtable, no hash lookup.
///
/// # Example
///
/// ```rust,ignore
/// use connectrpc::ConnectRpcService;
///
/// let server = ReadServiceServer::new(MyImpl);
/// let service = ConnectRpcService::new(server);
/// // hand `service` to axum/hyper as a fallback_service
/// ```
pub struct ReadServiceServer<T> {
    inner: ::std::sync::Arc<T>,
}
impl<T: ReadService> ReadServiceServer<T> {
    /// Wrap a service implementation in a monomorphic dispatcher.
    pub fn new(service: T) -> Self {
        Self {
            inner: ::std::sync::Arc::new(service),
        }
    }
    /// Wrap an already-`Arc`'d service implementation.
    pub fn from_arc(inner: ::std::sync::Arc<T>) -> Self {
        Self { inner }
    }
}
impl<T> Clone for ReadServiceServer<T> {
    fn clone(&self) -> Self {
        Self {
            inner: ::std::sync::Arc::clone(&self.inner),
        }
    }
}
impl<T: ReadService> ::connectrpc::Dispatcher for ReadServiceServer<T> {
    #[inline]
    fn lookup(
        &self,
        path: &str,
    ) -> Option<::connectrpc::dispatcher::codegen::MethodDescriptor> {
        let method = path.strip_prefix("headwaters.read.v1.ReadService/")?;
        match method {
            "ListNamespaces" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_LIST_NAMESPACES_SPEC),
                )
            }
            "ListJobs" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_LIST_JOBS_SPEC),
                )
            }
            "GetJob" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_JOB_SPEC),
                )
            }
            "GetJobRuns" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_JOB_RUNS_SPEC),
                )
            }
            "ListDatasets" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_LIST_DATASETS_SPEC),
                )
            }
            "GetDataset" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_DATASET_SPEC),
                )
            }
            "ListDatasetVersions" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_LIST_DATASET_VERSIONS_SPEC),
                )
            }
            "Search" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_SEARCH_SPEC),
                )
            }
            "GetLineage" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_LINEAGE_SPEC),
                )
            }
            "GetColumnLineage" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_COLUMN_LINEAGE_SPEC),
                )
            }
            "ListEvents" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_LIST_EVENTS_SPEC),
                )
            }
            "GetRunFacets" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_RUN_FACETS_SPEC),
                )
            }
            "ListTags" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_LIST_TAGS_SPEC),
                )
            }
            "GetTagDownstream" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_TAG_DOWNSTREAM_SPEC),
                )
            }
            "GetLineageEventStats" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_LINEAGE_EVENT_STATS_SPEC),
                )
            }
            "GetAssetStats" => {
                Some(
                    ::connectrpc::dispatcher::codegen::MethodDescriptor::unary(false)
                        .with_spec(READ_SERVICE_GET_ASSET_STATS_SPEC),
                )
            }
            _ => None,
        }
    }
    fn call_unary(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::connectrpc::Payload,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("headwaters.read.v1.ReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            "ListNamespaces" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::ListNamespacesRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::ListNamespacesRequest,
                    >::from_parts(&req, &body);
                    svc.list_namespaces(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListNamespacesResponse,
                        >(format)
                })
            }
            "ListJobs" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::ListJobsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::ListJobsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::ListJobsRequest,
                    >::from_parts(&req, &body);
                    svc.list_jobs(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListJobsResponse,
                        >(format)
                })
            }
            "GetJob" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetJobRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetJobRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetJobRequest,
                    >::from_parts(&req, &body);
                    svc.get_job(ctx, req)
                        .await?
                        .encode::<crate::proto::headwaters::read::v1::JobDetail>(format)
                })
            }
            "GetJobRuns" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetJobRunsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetJobRunsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetJobRunsRequest,
                    >::from_parts(&req, &body);
                    svc.get_job_runs(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListRunsResponse,
                        >(format)
                })
            }
            "ListDatasets" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::ListDatasetsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::ListDatasetsRequest,
                    >::from_parts(&req, &body);
                    svc.list_datasets(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListDatasetsResponse,
                        >(format)
                })
            }
            "GetDataset" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetDatasetRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetDatasetRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetDatasetRequest,
                    >::from_parts(&req, &body);
                    svc.get_dataset(ctx, req)
                        .await?
                        .encode::<crate::proto::headwaters::read::v1::Dataset>(format)
                })
            }
            "ListDatasetVersions" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::ListDatasetVersionsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::ListDatasetVersionsRequest,
                    >::from_parts(&req, &body);
                    svc.list_dataset_versions(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListDatasetVersionsResponse,
                        >(format)
                })
            }
            "Search" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::SearchRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::SearchRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::SearchRequest,
                    >::from_parts(&req, &body);
                    svc.search(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::SearchResponse,
                        >(format)
                })
            }
            "GetLineage" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetLineageRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetLineageRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetLineageRequest,
                    >::from_parts(&req, &body);
                    svc.get_lineage(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::LineageGraph,
                        >(format)
                })
            }
            "GetColumnLineage" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetColumnLineageRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetColumnLineageRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetColumnLineageRequest,
                    >::from_parts(&req, &body);
                    svc.get_column_lineage(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::LineageGraph,
                        >(format)
                })
            }
            "ListEvents" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::ListEventsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::ListEventsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::ListEventsRequest,
                    >::from_parts(&req, &body);
                    svc.list_events(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListEventsResponse,
                        >(format)
                })
            }
            "GetRunFacets" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetRunFacetsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetRunFacetsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetRunFacetsRequest,
                    >::from_parts(&req, &body);
                    svc.get_run_facets(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::RunFacetsResponse,
                        >(format)
                })
            }
            "ListTags" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::ListTagsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::ListTagsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::ListTagsRequest,
                    >::from_parts(&req, &body);
                    svc.list_tags(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::ListTagsResponse,
                        >(format)
                })
            }
            "GetTagDownstream" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetTagDownstreamRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetTagDownstreamRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetTagDownstreamRequest,
                    >::from_parts(&req, &body);
                    svc.get_tag_downstream(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::TagPropagation,
                        >(format)
                })
            }
            "GetLineageEventStats" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetLineageEventStatsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetLineageEventStatsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetLineageEventStatsRequest,
                    >::from_parts(&req, &body);
                    svc.get_lineage_event_stats(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::StatsResponse,
                        >(format)
                })
            }
            "GetAssetStats" => {
                let svc = ::std::sync::Arc::clone(&self.inner);
                Box::pin(async move {
                    let body = ::connectrpc::dispatcher::codegen::request_proto_bytes::<
                        crate::proto::headwaters::read::v1::GetAssetStatsRequest,
                    >(request.encoded()?, format)?;
                    let req: crate::proto::headwaters::read::v1::__buffa::view::GetAssetStatsRequestView<
                        '_,
                    > = ::connectrpc::dispatcher::codegen::decode_borrowed_request_view(
                        &body,
                    )?;
                    let req = ::connectrpc::ServiceRequest::<
                        crate::proto::headwaters::read::v1::GetAssetStatsRequest,
                    >::from_parts(&req, &body);
                    svc.get_asset_stats(ctx, req)
                        .await?
                        .encode::<
                            crate::proto::headwaters::read::v1::StatsResponse,
                        >(format)
                })
            }
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_server_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        request: ::buffa::bytes::Bytes,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("headwaters.read.v1.ReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &request, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
    fn call_client_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::UnaryResult {
        let Some(method) = path.strip_prefix("headwaters.read.v1.ReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_unary(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_unary(path),
        }
    }
    fn call_bidi_streaming(
        &self,
        path: &str,
        ctx: ::connectrpc::RequestContext,
        requests: ::connectrpc::dispatcher::codegen::RequestStream,
        format: ::connectrpc::CodecFormat,
    ) -> ::connectrpc::dispatcher::codegen::StreamingResult {
        let Some(method) = path.strip_prefix("headwaters.read.v1.ReadService/") else {
            return ::connectrpc::dispatcher::codegen::unimplemented_streaming(path);
        };
        let _ = (&ctx, &requests, &format);
        match method {
            _ => ::connectrpc::dispatcher::codegen::unimplemented_streaming(path),
        }
    }
}
/// Client for this service.
///
/// Generic over `T: ClientTransport`. For **gRPC** (HTTP/2), use
/// `Http2Connection` — it has honest `poll_ready` and composes with
/// `tower::balance` for multi-connection load balancing. For **Connect
/// over HTTP/1.1** (or unknown protocol), use `HttpClient`.
///
/// # Example (gRPC / HTTP/2)
///
/// ```rust,ignore
/// use connectrpc::client::{Http2Connection, ClientConfig};
/// use connectrpc::Protocol;
///
/// let uri: http::Uri = "http://localhost:8080".parse()?;
/// let conn = Http2Connection::connect_plaintext(uri.clone()).await?.shared(1024);
/// let config = ClientConfig::new(uri).with_protocol(Protocol::Grpc);
///
/// let client = ReadServiceClient::new(conn, config);
/// let response = client.list_namespaces(request).await?;
/// ```
///
/// # Example (Connect / HTTP/1.1 or ALPN)
///
/// ```rust,ignore
/// use connectrpc::client::{HttpClient, ClientConfig};
///
/// let http = HttpClient::plaintext();  // cleartext http:// only
/// let config = ClientConfig::new("http://localhost:8080".parse()?);
///
/// let client = ReadServiceClient::new(http, config);
/// let response = client.list_namespaces(request).await?;
/// ```
///
/// # Working with the response
///
/// Unary calls return [`UnaryResponse<OwnedView<FooView>>`](::connectrpc::client::UnaryResponse).
/// [`view()`](::connectrpc::client::UnaryResponse::view) borrows the response
/// message, so field access is zero-copy:
///
/// ```rust,ignore
/// let resp = client.list_namespaces(request).await?;
/// let name: &str = resp.view().name;  // borrow into the response buffer
/// ```
///
/// If you need the owned struct (e.g. to store or pass by value), use
/// [`into_owned()`](::connectrpc::client::UnaryResponse::into_owned):
///
/// ```rust,ignore
/// let owned = client.list_namespaces(request).await?.into_owned();
/// ```
///
/// [`into_view()`](::connectrpc::client::UnaryResponse::into_view) keeps the
/// zero-copy decoded body (an `OwnedView`) without copying; field access on it
/// goes through `.reborrow()`. Streaming responses yield one `OwnedView` per
/// received message from `.message().await` — bind `msg.reborrow()` for field
/// access, or convert with `.to_owned_message()`.
#[derive(Clone)]
pub struct ReadServiceClient<T> {
    transport: T,
    config: ::connectrpc::client::ClientConfig,
}
impl<T> ReadServiceClient<T>
where
    T: ::connectrpc::client::ClientTransport,
    <T::ResponseBody as ::http_body::Body>::Error: ::std::fmt::Display,
{
    /// Create a new client with the given transport and configuration.
    pub fn new(transport: T, config: ::connectrpc::client::ClientConfig) -> Self {
        Self { transport, config }
    }
    /// Get the client configuration.
    pub fn config(&self) -> &::connectrpc::client::ClientConfig {
        &self.config
    }
    /// Get a mutable reference to the client configuration.
    pub fn config_mut(&mut self) -> &mut ::connectrpc::client::ClientConfig {
        &mut self.config
    }
    /// Call the ListNamespaces RPC. Sends a request to /headwaters.read.v1.ReadService/ListNamespaces.
    pub async fn list_namespaces(
        &self,
        request: crate::proto::headwaters::read::v1::ListNamespacesRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_namespaces_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListNamespaces RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_namespaces_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::ListNamespacesRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListNamespacesResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "ListNamespaces",
                request,
                options,
            )
            .await
    }
    /// Call the ListJobs RPC. Sends a request to /headwaters.read.v1.ReadService/ListJobs.
    pub async fn list_jobs(
        &self,
        request: crate::proto::headwaters::read::v1::ListJobsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListJobsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_jobs_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListJobs RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_jobs_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::ListJobsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListJobsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "ListJobs",
                request,
                options,
            )
            .await
    }
    /// Call the GetJob RPC. Sends a request to /headwaters.read.v1.ReadService/GetJob.
    pub async fn get_job(
        &self,
        request: crate::proto::headwaters::read::v1::GetJobRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::JobDetailView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_job_with_options(request, ::connectrpc::client::CallOptions::default())
            .await
    }
    /// Call the GetJob RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_job_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetJobRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::JobDetailView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetJob",
                request,
                options,
            )
            .await
    }
    /// Call the GetJobRuns RPC. Sends a request to /headwaters.read.v1.ReadService/GetJobRuns.
    pub async fn get_job_runs(
        &self,
        request: crate::proto::headwaters::read::v1::GetJobRunsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListRunsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_job_runs_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetJobRuns RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_job_runs_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetJobRunsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListRunsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetJobRuns",
                request,
                options,
            )
            .await
    }
    /// Call the ListDatasets RPC. Sends a request to /headwaters.read.v1.ReadService/ListDatasets.
    pub async fn list_datasets(
        &self,
        request: crate::proto::headwaters::read::v1::ListDatasetsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_datasets_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListDatasets RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_datasets_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::ListDatasetsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListDatasetsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "ListDatasets",
                request,
                options,
            )
            .await
    }
    /// Call the GetDataset RPC. Sends a request to /headwaters.read.v1.ReadService/GetDataset.
    pub async fn get_dataset(
        &self,
        request: crate::proto::headwaters::read::v1::GetDatasetRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::DatasetView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_dataset_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetDataset RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_dataset_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetDatasetRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::DatasetView<'static>,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetDataset",
                request,
                options,
            )
            .await
    }
    /// Call the ListDatasetVersions RPC. Sends a request to /headwaters.read.v1.ReadService/ListDatasetVersions.
    pub async fn list_dataset_versions(
        &self,
        request: crate::proto::headwaters::read::v1::ListDatasetVersionsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_dataset_versions_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListDatasetVersions RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_dataset_versions_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::ListDatasetVersionsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListDatasetVersionsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "ListDatasetVersions",
                request,
                options,
            )
            .await
    }
    /// Call the Search RPC. Sends a request to /headwaters.read.v1.ReadService/Search.
    pub async fn search(
        &self,
        request: crate::proto::headwaters::read::v1::SearchRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::SearchResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.search_with_options(request, ::connectrpc::client::CallOptions::default())
            .await
    }
    /// Call the Search RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn search_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::SearchRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::SearchResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "Search",
                request,
                options,
            )
            .await
    }
    /// Call the GetLineage RPC. Sends a request to /headwaters.read.v1.ReadService/GetLineage.
    pub async fn get_lineage(
        &self,
        request: crate::proto::headwaters::read::v1::GetLineageRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_lineage_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetLineage RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_lineage_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetLineageRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetLineage",
                request,
                options,
            )
            .await
    }
    /// Call the GetColumnLineage RPC. Sends a request to /headwaters.read.v1.ReadService/GetColumnLineage.
    pub async fn get_column_lineage(
        &self,
        request: crate::proto::headwaters::read::v1::GetColumnLineageRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_column_lineage_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetColumnLineage RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_column_lineage_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetColumnLineageRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::LineageGraphView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetColumnLineage",
                request,
                options,
            )
            .await
    }
    /// Call the ListEvents RPC. Sends a request to /headwaters.read.v1.ReadService/ListEvents.
    pub async fn list_events(
        &self,
        request: crate::proto::headwaters::read::v1::ListEventsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListEventsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_events_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListEvents RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_events_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::ListEventsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListEventsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "ListEvents",
                request,
                options,
            )
            .await
    }
    /// Call the GetRunFacets RPC. Sends a request to /headwaters.read.v1.ReadService/GetRunFacets.
    pub async fn get_run_facets(
        &self,
        request: crate::proto::headwaters::read::v1::GetRunFacetsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::RunFacetsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_run_facets_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetRunFacets RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_run_facets_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetRunFacetsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::RunFacetsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetRunFacets",
                request,
                options,
            )
            .await
    }
    /// Call the ListTags RPC. Sends a request to /headwaters.read.v1.ReadService/ListTags.
    pub async fn list_tags(
        &self,
        request: crate::proto::headwaters::read::v1::ListTagsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListTagsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.list_tags_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the ListTags RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn list_tags_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::ListTagsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::ListTagsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "ListTags",
                request,
                options,
            )
            .await
    }
    /// Call the GetTagDownstream RPC. Sends a request to /headwaters.read.v1.ReadService/GetTagDownstream.
    pub async fn get_tag_downstream(
        &self,
        request: crate::proto::headwaters::read::v1::GetTagDownstreamRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::TagPropagationView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_tag_downstream_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetTagDownstream RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_tag_downstream_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetTagDownstreamRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::TagPropagationView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetTagDownstream",
                request,
                options,
            )
            .await
    }
    /// Call the GetLineageEventStats RPC. Sends a request to /headwaters.read.v1.ReadService/GetLineageEventStats.
    pub async fn get_lineage_event_stats(
        &self,
        request: crate::proto::headwaters::read::v1::GetLineageEventStatsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_lineage_event_stats_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetLineageEventStats RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_lineage_event_stats_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetLineageEventStatsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetLineageEventStats",
                request,
                options,
            )
            .await
    }
    /// Call the GetAssetStats RPC. Sends a request to /headwaters.read.v1.ReadService/GetAssetStats.
    pub async fn get_asset_stats(
        &self,
        request: crate::proto::headwaters::read::v1::GetAssetStatsRequest,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        self.get_asset_stats_with_options(
                request,
                ::connectrpc::client::CallOptions::default(),
            )
            .await
    }
    /// Call the GetAssetStats RPC with explicit per-call options. Options override [`ClientConfig`](::connectrpc::client::ClientConfig) defaults.
    pub async fn get_asset_stats_with_options(
        &self,
        request: crate::proto::headwaters::read::v1::GetAssetStatsRequest,
        options: ::connectrpc::client::CallOptions,
    ) -> Result<
        ::connectrpc::client::UnaryResponse<
            ::buffa::view::OwnedView<
                crate::proto::headwaters::read::v1::__buffa::view::StatsResponseView<
                    'static,
                >,
            >,
        >,
        ::connectrpc::ConnectError,
    > {
        ::connectrpc::client::call_unary(
                &self.transport,
                &self.config,
                READ_SERVICE_SERVICE_NAME,
                "GetAssetStats",
                request,
                options,
            )
            .await
    }
}