K8S Inventory operator for Akash provider

Monitor K8S resources and report them via REST API

Resources monitored

Resource type	Status
StorageClass	✅
Nodes	TBD

StorageClass

Reported metrics

• Allocatable - total allocatable in bytes for given storage class
• Allocated - total in use in bytes for given storage class

Supported provisioners

Provisioner	Status
Rook+Ceph	✅
rancher local	✅

NOTE: The inventory on rancher local work with single node cluster for now.

Provider talks with service endpoint via K8S API

// discover inventory operator
svcResult, err := c.kc.CoreV1().Services("").List(ctx, metav1.ListOptions{
    LabelSelector: builder.AkashManagedLabelName + "=true" +
        ",app.kubernetes.io/name=akash" +
        ",app.kubernetes.io/instance=inventory" +
        ",app.kubernetes.io/component=operator",
})
if err != nil {
    return nil, err
}

if len(svcResult.Items) == 0 {
    return nil, nil
}

// request inventory snapshot
result := c.kc.CoreV1().RESTClient().Get().
    Namespace(svcResult.Items[0].Namespace).
    Resource("services").
    Name(svcResult.Items[0].Name + ":api").
    SubResource("proxy").
    Suffix("inventory").
    Do(ctx)

if err := result.Error(); err != nil {
    return nil, err
}

inv := &akashv1.Inventory{}

if err := result.Into(inv); err != nil {
    return nil, err
}

Deploy

kubectl apply -f example/inventory-operator.yaml