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かどうかで終わりを判定している。