Api / create

[jesperpedersen]

Hi,

I have done a minimal example which looks like

    let pv: PersistentVolume = pv_create(name, namespace);
    let pv_api: Api<PersistentVolume> = Api::namespaced(client, namespace);
    let pp: PostParams = PostParams::default();
    match pv_api.create(&pp, &pv).await {
        Ok(o) => {
            info!("Created PersistentVolume");
            return Ok(o);
        }
        Err(e) => return Err(e.into()),
    }

This gives the following log

2022-07-08T09:49:23.130209009-04:00 TRACE tower::buffer::service - sending request to buffer worker
2022-07-08T09:49:23.130417139-04:00 TRACE tower::buffer::worker - worker polling for next message
2022-07-08T09:49:23.130524346-04:00 TRACE tower::buffer::worker - processing new request
2022-07-08T09:49:23.130593630-04:00 TRACE tower::buffer::worker - resumed=false message=worker received request; waiting for service readiness
2022-07-08T09:49:23.130655091-04:00 DEBUG tower::buffer::worker - service.ready=true message=processing request
2022-07-08T09:49:23.130849322-04:00 DEBUG kube_client::client::builder - HTTP; http.method=POST http.url=https://127.0.0.1:40149/api/v1/namespaces/default/persistentvolumes? otel.name="create" otel.kind="client"
2022-07-08T09:49:23.130946123-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.130994873-04:00 DEBUG kube_client::client::builder - requesting
2022-07-08T09:49:23.131074423-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.131132532-04:00 TRACE tower::buffer::worker - returning response future
2022-07-08T09:49:23.131208800-04:00 TRACE tower::buffer::worker - worker polling for next message
2022-07-08T09:49:23.131258807-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.131389621-04:00 TRACE hyper::client::pool - checkout waiting for idle connection: ("https", 127.0.0.1:40149)
2022-07-08T09:49:23.131594817-04:00 TRACE hyper::client::connect::http - Http::connect; scheme=Some("https"), host=Some("127.0.0.1"), port=Some(Port(40149))
2022-07-08T09:49:23.131712082-04:00 DEBUG hyper::client::connect::http - connecting to 127.0.0.1:40149
2022-07-08T09:49:23.132076658-04:00 TRACE mio::poll - registering event source with poller: token=Token(1), interests=READABLE | WRITABLE
2022-07-08T09:49:23.132209079-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.132265302-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.132323900-04:00 DEBUG hyper::client::connect::http - connected to 127.0.0.1:40149
2022-07-08T09:49:23.132943470-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.138196579-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.142793451-04:00 TRACE hyper::client::conn - client handshake Http1
2022-07-08T09:49:23.142973155-04:00 TRACE hyper::client::client - handshake complete, spawning background dispatcher task
2022-07-08T09:49:23.143070585-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.143402754-04:00 TRACE want - signal: Want
2022-07-08T09:49:23.143519111-04:00 TRACE want - signal found waiting giver, notifying
2022-07-08T09:49:23.143600268-04:00 TRACE hyper::proto::h1::conn - flushed({role=client}): State { reading: Init, writing: Init, keep_alive: Busy }
2022-07-08T09:49:23.143656002-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.143738905-04:00 TRACE want - poll_want: taker wants!
2022-07-08T09:49:23.143797153-04:00 TRACE hyper::client::pool - checkout dropped for ("https", 127.0.0.1:40149)
2022-07-08T09:49:23.144012686-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.144069398-04:00 TRACE tracing::span - encode_headers
2022-07-08T09:49:23.144148180-04:00 TRACE tracing::span::active - -> encode_headers
2022-07-08T09:49:23.144197209-04:00 TRACE hyper::proto::h1::role - Client::encode method=POST, body=Some(Known(285))
2022-07-08T09:49:23.144340036-04:00 TRACE tracing::span::active - <- encode_headers
2022-07-08T09:49:23.144397237-04:00 TRACE tracing::span - -- encode_headers
2022-07-08T09:49:23.144468266-04:00 TRACE hyper::proto::h1::io - buffer.flatten self.len=139 buf.len=285
2022-07-08T09:49:23.144681983-04:00 DEBUG hyper::proto::h1::io - flushed 424 bytes
2022-07-08T09:49:23.144797712-04:00 TRACE hyper::proto::h1::conn - flushed({role=client}): State { reading: Init, writing: KeepAlive, keep_alive: Busy }
2022-07-08T09:49:23.144908901-04:00 TRACE hyper::proto::h1::conn - Conn::read_head
2022-07-08T09:49:23.145012826-04:00 TRACE hyper::proto::h1::conn - flushed({role=client}): State { reading: Init, writing: KeepAlive, keep_alive: Busy }
2022-07-08T09:49:23.147443543-04:00 TRACE hyper::proto::h1::conn - Conn::read_head
2022-07-08T09:49:23.147829980-04:00 TRACE hyper::proto::h1::io - received 515 bytes
2022-07-08T09:49:23.147934883-04:00 TRACE tracing::span - parse_headers
2022-07-08T09:49:23.147987404-04:00 TRACE tracing::span::active - -> parse_headers
2022-07-08T09:49:23.148082669-04:00 TRACE hyper::proto::h1::role - Response.parse bytes=515
2022-07-08T09:49:23.148235763-04:00 TRACE hyper::proto::h1::role - Response.parse Complete(341)
2022-07-08T09:49:23.148579177-04:00 TRACE tracing::span::active - <- parse_headers
2022-07-08T09:49:23.148651324-04:00 TRACE tracing::span - -- parse_headers
2022-07-08T09:49:23.148732760-04:00 DEBUG hyper::proto::h1::io - parsed 7 headers
2022-07-08T09:49:23.148796805-04:00 DEBUG hyper::proto::h1::conn - incoming body is content-length (174 bytes)
2022-07-08T09:49:23.148981398-04:00 TRACE hyper::proto::h1::decode - decode; state=Length(174)
2022-07-08T09:49:23.149043906-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.149126669-04:00 DEBUG hyper::proto::h1::conn - incoming body completed
2022-07-08T09:49:23.149392489-04:00 TRACE hyper::proto::h1::conn - maybe_notify; read_from_io blocked
2022-07-08T09:49:23.149458769-04:00 DEBUG kube_client::client::builder - HTTP; http.status_code=404
2022-07-08T09:49:23.149511639-04:00 DEBUG kube_client::client::builder - HTTP; otel.status_code="ERROR"
2022-07-08T09:49:23.149553684-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.149583018-04:00 TRACE want - signal: Want
2022-07-08T09:49:23.149643362-04:00 TRACE tracing::span - -- HTTP
2022-07-08T09:49:23.149714042-04:00 TRACE want - signal found waiting giver, notifying
2022-07-08T09:49:23.149815523-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.149864761-04:00 TRACE hyper::proto::h1::conn - flushed({role=client}): State { reading: Init, writing: Init, keep_alive: Idle }
2022-07-08T09:49:23.149929645-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.149967849-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.150001652-04:00 TRACE want - signal: Want
2022-07-08T09:49:23.150055012-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.150087488-04:00 TRACE hyper::proto::h1::conn - flushed({role=client}): State { reading: Init, writing: Init, keep_alive: Idle }
2022-07-08T09:49:23.150182683-04:00 TRACE want - poll_want: taker wants!
2022-07-08T09:49:23.150249522-04:00 TRACE hyper::client::pool - put; add idle connection for ("https", 127.0.0.1:40149)
2022-07-08T09:49:23.150364273-04:00 DEBUG hyper::client::pool - pooling idle connection for ("https", 127.0.0.1:40149)
2022-07-08T09:49:23.150474693-04:00 TRACE tracing::span::active - -> HTTP
2022-07-08T09:49:23.150517576-04:00 TRACE tracing::span::active - <- HTTP
2022-07-08T09:49:23.150593355-04:00 TRACE tracing::span - -- HTTP
2022-07-08T09:49:23.150763840-04:00 DEBUG kube_client::client - Unsuccessful: ErrorResponse { status: "Failure", message: "the server could not find the requested resource", reason: "NotFound", code: 404 }
2022-07-08T09:49:23.150814755-04:00 TRACE want - signal: Want
2022-07-08T09:49:23.150915956-04:00 TRACE hyper::proto::h1::conn - flushed({role=client}): State { reading: Init, writing: Init, keep_alive: Idle }
2022-07-08T09:49:23.151009894-04:00 INFO opr: Err(Api(ErrorResponse { status: "Failure", message: "the server could not find the requested resource", reason: "NotFound", code: 404 }))

The namespace default exists, and the pod_api example works - looks to have almost identical code. Am I missing a dependency or some init code to get it working ?

If I output the PersistentVolume to a YAML file and use kubectl apply -f pv.yaml the resource gets installed.

kube-0.73.1 w/ kind/main

Any help would be greatly appreciated.

[clux]

uhm, that is confusing. i don't think there's been any upgrades to PersistentVolme versions in kubernetes (which is usually what that error message "the server could not find the requested resource" means - i.e. apigroup/version mismatches).

you could try to cross-reference with kubectl:

you see your post url is https://127.0.0.1:40149/api/v1/namespaces/default/persistentvolumes from your logs
kubectl will posts its urls via kubectl apply -f .. -v=9. maybe there's something weird that's not lining up there.

[clux]

oh, wait, PersistentVolume is not namespaced. You gotta use Api::all for it.

[jesperpedersen]

Ah, great - works now :)

It would be nice if Api knew from its own context which combinations were allowed, e.g.

let pv_api: Api<PersistentVolume> = Api::namespaced(client, namespace);
...
pv_api.create(&pp, &pv);

would throw an error highlighting that Api::all should be used instead.

Thanks for your help !

[clux]

Ah, yeah - that would indeed be better. We even had some plans on doing this via #194 but it fell to the wayside, I'll try to spend some time on it soon!

[clux]

A fix for this will land in 0.75!

[jesperpedersen]

@clux Thank you !