Function executeOperation

concurrent_test.go:424–435

(op OperationType, tx *bolt.Tx, bucket []byte, key []byte, conf concurrentConfig)

}

func executeOperation(op OperationType, tx *bolt.Tx, bucket []byte, key []byte, conf concurrentConfig) (historyRecord, error) {
	switch op {
	case Read:
		return executeRead(tx, bucket, key, conf.readInterval)
	case Write:
		return executeWrite(tx, bucket, key, conf.writeBytes, conf.noopWriteRatio)
	case Delete:
		return executeDelete(tx, bucket, key)
	default:
		panic(fmt.Sprintf("unexpected operation type: %s", op))
	}
}

func executeRead(tx *bolt.Tx, bucket []byte, key []byte, readInterval duration) (historyRecord, error) {
	var rec historyRecord