GoでGlusterFSのlibgfapiを使う

分散ファイルシステムGlusterFSのlibgfapiをGoから使うには、gogfapiというものがあるのでそれを使う。

gogfapi - Gluster Community Forge

例えば、GlusterFSのボリューム上にあるファイルを読み出すプログラム gfcat.go は以下のようになる。

package main

import (
    "os"

    "forge.gluster.org/gogfapi/gogfapi.git/gfapi"
)

func main() {
    if len(os.Args) < 3 {
        os.Exit(1)
    }
    volname := os.Args[1]
    path := os.Args[2]

    vol := new(gfapi.Volume)
    ret := vol.Init("localhost", volname)
    if ret != 0 {
        panic("failed to init volume")
    }
    ret = vol.Mount()
    if ret != 0 {
        panic("failed to mount volume")
    }

    f, err := vol.Open(path)
    if err != nil {
        panic(err)
    }
    b := make([]byte, 4096)

    for {
        n, err := f.Read(b)
        if n == 0 || err != nil {
            break
        }
        os.Stdout.Write(b)
    }
}

使い方は

go build gfcat.go
sudo gfcat VOLNAME path

のように、root権限で実行し、引数としてボリューム名とパスを指定する。root権限が必要なのはlibgfapiの仕様である。 接続先ホストはlocalhost決めうちになっているので、ボリュームを構成するノード上で実行しなければいけない。

プログラムとしては、ボリュームの初期化と仮想的なマウントが入る以外は、Goのosパッケージのファイル操作に近い。 ただ、上記でも使っているRead関数は、ファイルの終端に達してもEOFを返してくれないようであるので注意。よって上記のプログラムでは、読み込んだバイト数が0かどうかで終わりを判定している。