aerospikeでincrement処理

aero.go

package main

import (
	"github.com/aerospike/aerospike-client-go"
	"github.com/k0kubun/pp"
)

const NeverExpire = 0xFFFFFFFF

func main() {
	client, err := aerospike.NewClientWithPolicyAndHost(nil, aerospike.NewHost("localhost", 3000))
	if err != nil {
		panic(err)
	}

	writePolicy := aerospike.NewWritePolicy(0, NeverExpire)
	writePolicy.SendKey = true
	client.DefaultWritePolicy = writePolicy
	defer client.Close()

	key, err := aerospike.NewKey("test", "TEST_INDEX", "test_float")
	if err != nil {
		panic(err)
	}
	value := 1.1

	client.AddBins(writePolicy, key, aerospike.NewBin("payload", value))

	record, err := client.Get(nil, key, "payload")
	if err != nil {
		panic(err)
	}
	pp.Println("record: ", record.Bins)
}