From f2a8e95248ca42cf29885a44bc1362cf78d364fe Mon Sep 17 00:00:00 2001 From: Jae Kwon Date: Mon, 25 Dec 2017 11:40:05 -0800 Subject: [PATCH] Add KI64Pair(s) --- common/kvpair.go | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/common/kvpair.go b/common/kvpair.go index b9e45733..5faa534d 100644 --- a/common/kvpair.go +++ b/common/kvpair.go @@ -5,6 +5,9 @@ import ( "sort" ) +//---------------------------------------- +// KVPair + type KVPair struct { Key Bytes Value Bytes @@ -28,3 +31,30 @@ func (kvs KVPairs) Less(i, j int) bool { } func (kvs KVPairs) Swap(i, j int) { kvs[i], kvs[j] = kvs[j], kvs[i] } func (kvs KVPairs) Sort() { sort.Sort(kvs) } + +//---------------------------------------- +// KI64Pair + +type KI64Pair struct { + Key Bytes + Value int64 +} + +type KI64Pairs []KI64Pair + +// Sorting +func (kvs KI64Pairs) Len() int { return len(kvs) } +func (kvs KI64Pairs) Less(i, j int) bool { + switch bytes.Compare(kvs[i].Key, kvs[j].Key) { + case -1: + return true + case 0: + return kvs[i].Value < kvs[j].Value + case 1: + return false + default: + panic("invalid comparison result") + } +} +func (kvs KI64Pairs) Swap(i, j int) { kvs[i], kvs[j] = kvs[j], kvs[i] } +func (kvs KI64Pairs) Sort() { sort.Sort(kvs) }