Add service-config and expose metrics

Author: patilsuraj767

api/v1alpha1/ipfscluster_types.go

@@ -91,6 +91,9 @@ type IpfsClusterSpec struct {
 	// should use when reproviding content.
 	// +optional
 	Reprovider ReprovideSettings `json:"reprovider,omitempty"`
+	// stats determines whether metrics should be enabled.
+	// +optional
+	Stats bool `json:"stats"`
 }
 
 type IpfsClusterStatus struct {

config/crd/bases/cluster.ipfs.io_ipfsclusters.yaml

@@ -129,6 +129,9 @@ spec:
                     - roots
                     type: string
                 type: object
+              stats:
+                description: stats determines whether metrics should be enabled.
+                type: boolean
               url:
                 description: url defines the URL to be using as an ingress controller.
                 type: string

controllers/circuitrelay_controller.go

@@ -36,9 +36,9 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 	"sigs.k8s.io/controller-runtime/pkg/log"
 
-	"github.com/libp2p/go-libp2p-core/crypto"
-	peer "github.com/libp2p/go-libp2p-core/peer"
 	relaydaemon "github.com/libp2p/go-libp2p-relay-daemon"
+	"github.com/libp2p/go-libp2p/core/crypto"
+	peer "github.com/libp2p/go-libp2p/core/peer"
 	relayv2 "github.com/libp2p/go-libp2p/p2p/protocol/circuitv2/relay"
 	clusterv1alpha1 "github.com/redhat-et/ipfs-operator/api/v1alpha1"
 	"github.com/redhat-et/ipfs-operator/controllers/utils"

controllers/ipfs_cluster_service.go

@@ -0,0 +1,17 @@
+package controllers
+
+import (
+	"github.com/ipfs-cluster/ipfs-cluster/cmdutils"
+	ma "github.com/multiformats/go-multiaddr"
+)
+
+func GetDefaultServiceConfig() *cmdutils.ConfigHelper {
+	cfgHelper := cmdutils.NewConfigHelper("", "", "crdt", "badger")
+	cfgHelper.Manager().Default()
+	return cfgHelper
+}
+
+func EnableMetrics(serviceConfig *cmdutils.Configs) {
+	serviceConfig.Metrics.EnableStats = true
+	serviceConfig.Metrics.PrometheusEndpoint, _ = ma.NewMultiaddr("/ip4/0.0.0.0/tcp/8888")
+}

controllers/ipfs_util.go

@@ -6,8 +6,8 @@ import (
 	"encoding/hex"
 	"fmt"
 
-	ci "github.com/libp2p/go-libp2p-core/crypto"
-	peer "github.com/libp2p/go-libp2p-core/peer"
+	ci "github.com/libp2p/go-libp2p/core/crypto"
+	peer "github.com/libp2p/go-libp2p/core/peer"
 )
 
 func newClusterSecret() (string, error) {

controllers/ipfscluster_controller.go

@@ -32,7 +32,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 	ctrllog "sigs.k8s.io/controller-runtime/pkg/log"
 
-	"github.com/libp2p/go-libp2p-core/peer"
+	"github.com/libp2p/go-libp2p/core/peer"
 	clusterv1alpha1 "github.com/redhat-et/ipfs-operator/api/v1alpha1"
 	"github.com/redhat-et/ipfs-operator/controllers/utils"
 )

controllers/scripts.go

@@ -10,7 +10,7 @@ import (
 
 	"github.com/alecthomas/units"
 	"github.com/ipfs/kubo/config"
-	"github.com/libp2p/go-libp2p-core/peer"
+	"github.com/libp2p/go-libp2p/core/peer"
 	ma "github.com/multiformats/go-multiaddr"
 	clusterv1alpha1 "github.com/redhat-et/ipfs-operator/api/v1alpha1"
 	"github.com/redhat-et/ipfs-operator/controllers/scripts"
@@ -101,6 +101,17 @@ func (r *IpfsClusterReconciler) ConfigMapScripts(
 		string(reproviderStrategy),
 	)
 
+	serviceConfig := GetDefaultServiceConfig()
+	if m.Spec.Stats {
+		EnableMetrics(serviceConfig.Configs())
+	}
+
+	serviceConfigFile, err := serviceConfig.Manager().ToJSON()
+	if err != nil {
+		log.Error(err, "could not marshal service config file")
+		return utils.ErrFunc(fmt.Errorf("error converting serviceConfig to JSON: %w", err)), ""
+	}
+
 	expected := &corev1.ConfigMap{
 		ObjectMeta: metav1.ObjectMeta{
 			Name:      cmName,
@@ -109,6 +120,7 @@ func (r *IpfsClusterReconciler) ConfigMapScripts(
 		Data: map[string]string{
 			"entrypoint.sh":     scripts.IPFSClusterEntrypoint,
 			"configure-ipfs.sh": configScript,
+			"service.json":      string(serviceConfigFile),
 		},
 	}
 	expected.DeepCopyInto(cm)

controllers/scripts/config.go

@@ -10,7 +10,7 @@ import (
 
 	"github.com/alecthomas/units"
 	"github.com/ipfs/kubo/config"
-	"github.com/libp2p/go-libp2p-core/peer"
+	"github.com/libp2p/go-libp2p/core/peer"
 )
 
 type configureIpfsOpts struct {
@@ -92,6 +92,8 @@ run_ipfs_cluster() {
 	log "🔍 reading hostname"
 	PEER_HOSTNAME=$(cat /proc/sys/kernel/hostname)
 	log "starting ipfs-cluster on ${PEER_HOSTNAME}"
+	cp /custom/service.json /data/ipfs-cluster/
+	sed -i '/peername/c\   \"peername\" : \"'$PEER_HOSTNAME'\",' /data/ipfs-cluster/service.json
 
 	grep -q ".*-0$" /proc/sys/kernel/hostname
 	if [ $? -eq 0 ]; then
@@ -236,7 +238,9 @@ func applyIPFSClusterK8sDefaults(conf *config.Config, storageMax string, peers [
 	conf.Bootstrap = config.DefaultBootstrapAddresses
 	conf.Addresses.API = config.Strings{"/ip4/0.0.0.0/tcp/5001"}
 	conf.Addresses.Gateway = config.Strings{"/ip4/0.0.0.0/tcp/8080"}
-	conf.Swarm.ConnMgr.HighWater = 2000
+	highWater := &config.OptionalInteger{}
+	highWater.UnmarshalJSON([]byte("2000"))
+	conf.Swarm.ConnMgr.HighWater = highWater
 	conf.Datastore.BloomFilterSize = 1048576
 	conf.Datastore.StorageMax = storageMax
 	conf.Addresses.Swarm = []string{"/ip4/0.0.0.0/tcp/4001", "/ip6/::/tcp/4001"}

controllers/statefulset.go

@@ -54,7 +54,7 @@ const (
 	// ipfsMountPath Defines where the IPFS volume is mounted.
 	ipfsMountPath = "/data/ipfs"
 	// ipfsImage Defines which image we should pull when running IPFS containers.
-	ipfsImage = "docker.io/ipfs/kubo:v0.14.0"
+	ipfsImage = "docker.io/ipfs/kubo:v0.17.0"
 )
 
 // StatefulSet Returns a mutate function that creates a StatefulSet for the