/// Process custom spu, converts spu spec to K8 and sends to KV store
Process custom spu, converts spu spec to K8 and sends to KV store
Process custom spu converts spu spec to K8 and sends to KV store
async fn process_custom_spu_request<C>(
    ctx: &PublicContext<C>,
    custom_spu_req: FlvCreateCustomSpuRequest,
) -> FlvResponseMessage
where
    C: MetadataClient,
{
    let name = custom_spu_req.name.clone();
    if let Err(err) = create_custom_spu(ctx, custom_spu_req).await {
        let error = Some(err.to_string());
        FlvResponseMessage::new(name, FlvErrorCode::SpuError, error)
    } else {
        FlvResponseMessage::new_ok(name)
    }
}
async fn process_custom_spu_request < C > ( ctx : & PublicContext < C > , custom_spu_req : FlvCreateCustomSpuRequest , ) -> FlvResponseMessage where C : MetadataClient , { let name = custom_spu_req . name . clone ( ) ; if let Err ( err ) = create_custom_spu ( ctx , custom_spu_req ) . await { let error = Some ( err . to_string ( ) ) ; FlvResponseMessage :: new ( name , FlvErrorCode :: SpuError , error ) } else { FlvResponseMessage :: new_ok ( name ) } }
Process custom spu, converts spu spec to K8 and sends to KV store
Process custom spu converts spu spec to K8 and sends to KV store
ctx
&PublicContext<C>
custom_spu_req
FlvCreateCustomSpuRequest