Add a public ServerDefaults to give access to FSServerDefaults

Fixes #219

client.go

@@ -307,23 +307,6 @@ func (c *Client) CopyToRemote(src string, dst string) error {
 	return remote.Close()
 }
 
-func (c *Client) fetchDefaults() (*hdfs.FsServerDefaultsProto, error) {
-	if c.defaults != nil {
-		return c.defaults, nil
-	}
-
-	req := &hdfs.GetServerDefaultsRequestProto{}
-	resp := &hdfs.GetServerDefaultsResponseProto{}
-
-	err := c.namenode.Execute("getServerDefaults", req, resp)
-	if err != nil {
-		return nil, err
-	}
-
-	c.defaults = resp.GetServerDefaults()
-	return c.defaults, nil
-}
-
 func (c *Client) fetchDataEncryptionKey() (*hdfs.DataEncryptionKeyProto, error) {
 	if c.encryptionKey != nil {
 		return c.encryptionKey, nil

defaults.go

@@ -0,0 +1,57 @@
+package hdfs
+
+import (
+	hdfs "github.com/colinmarc/hdfs/v2/internal/protocol/hadoop_hdfs"
+)
+
+// ServerDefaults represents the filesystem configuration stored on the
+// Namenode.
+type ServerDefaults struct {
+	BlockSize           int64
+	BytesPerChecksum    int
+	WritePacketSize     int
+	Replication         int
+	FileBufferSize      int
+	EncryptDataTransfer bool
+	TrashInterval       int64
+	KeyProviderURI      string
+	PolicyId            int
+}
+
+// ServerDefaults fetches the stored defaults from the Namenode and returns
+// them and any error encountered.
+func (c *Client) ServerDefaults() (ServerDefaults, error) {
+	resp, err := c.fetchDefaults()
+	if err != nil {
+		return ServerDefaults{}, err
+	}
+
+	return ServerDefaults{
+		BlockSize:           int64(resp.GetBlockSize()),
+		BytesPerChecksum:    int(resp.GetBytesPerChecksum()),
+		WritePacketSize:     int(resp.GetWritePacketSize()),
+		Replication:         int(resp.GetReplication()),
+		FileBufferSize:      int(resp.GetFileBufferSize()),
+		EncryptDataTransfer: resp.GetEncryptDataTransfer(),
+		TrashInterval:       int64(resp.GetTrashInterval()),
+		KeyProviderURI:      resp.GetKeyProviderUri(),
+		PolicyId:            int(resp.GetPolicyId()),
+	}, nil
+}
+
+func (c *Client) fetchDefaults() (*hdfs.FsServerDefaultsProto, error) {
+	if c.defaults != nil {
+		return c.defaults, nil
+	}
+
+	req := &hdfs.GetServerDefaultsRequestProto{}
+	resp := &hdfs.GetServerDefaultsResponseProto{}
+
+	err := c.namenode.Execute("getServerDefaults", req, resp)
+	if err != nil {
+		return nil, err
+	}
+
+	c.defaults = resp.GetServerDefaults()
+	return c.defaults, nil
+}

defaults_test.go

@@ -0,0 +1,16 @@
+package hdfs
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+func TestServerDefaults(t *testing.T) {
+	client := getClient(t)
+
+	sd, err := client.ServerDefaults()
+	require.NoError(t, err)
+	assert.NotZero(t, sd.BlockSize)
+}