001d7f866c
Don’t use the global variable ‘skip’ to decode into, as this causes a data race, when decoding keys from inside multiple different goroutines. Instead we now create a new string variable for every decode function, which will be created on the heap and ignored when the function returns.
74 lines
1.6 KiB
Go
74 lines
1.6 KiB
Go
// Copyright © 2016 Abcum Ltd
|
||
//
|
||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||
// you may not use this file except in compliance with the License.
|
||
// You may obtain a copy of the License at
|
||
//
|
||
// http://www.apache.org/licenses/LICENSE-2.0
|
||
//
|
||
// Unless required by applicable law or agreed to in writing, software
|
||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||
// See the License for the specific language governing permissions and
|
||
// limitations under the License.
|
||
|
||
package keys
|
||
|
||
// Edge ...
|
||
type Edge struct {
|
||
KV string
|
||
NS string
|
||
DB string
|
||
TB string
|
||
ID interface{}
|
||
TK string
|
||
TP string
|
||
FT string
|
||
FK interface{}
|
||
}
|
||
|
||
// init initialises the key
|
||
func (k *Edge) init() *Edge {
|
||
switch k.TK {
|
||
case "«»":
|
||
case "‹", "›":
|
||
case "«", "»":
|
||
default:
|
||
k.TK = "«»"
|
||
}
|
||
return k
|
||
}
|
||
|
||
// Copy creates a copy of the key
|
||
func (k *Edge) Copy() *Edge {
|
||
return &Edge{
|
||
KV: k.KV,
|
||
NS: k.NS,
|
||
DB: k.DB,
|
||
TB: k.TB,
|
||
ID: k.ID,
|
||
TK: k.TK,
|
||
TP: k.TP,
|
||
FT: k.FT,
|
||
FK: k.FK,
|
||
}
|
||
}
|
||
|
||
// Encode encodes the key into binary
|
||
func (k *Edge) Encode() []byte {
|
||
k.init()
|
||
return encode(k.KV, k.NS, "*", k.DB, "*", k.TB, "*", k.ID, k.TK, k.TP, k.FT, k.FK)
|
||
}
|
||
|
||
// Decode decodes the key from binary
|
||
func (k *Edge) Decode(data []byte) {
|
||
k.init()
|
||
var __ string
|
||
decode(data, &k.KV, &k.NS, &__, &k.DB, &__, &k.TB, &__, &k.ID, &k.TK, &k.TP, &k.FT, &k.FK)
|
||
}
|
||
|
||
// String returns a string representation of the key
|
||
func (k *Edge) String() string {
|
||
k.init()
|
||
return output(k.KV, k.NS, "*", k.DB, "*", k.TB, "*", k.ID, k.TK, k.TP, k.FT, k.FK)
|
||
}
|