Begin implementation of outbound work queue

1 files changed, 14 insertions, 2 deletions

diff --git a/src/keypair.go b/src/keypair.go
index e7961a8..53e123f 100644
--- a/src/keypair.go
+++ b/src/keypair.go
@@ -16,6 +16,18 @@ type KeyPairs struct {
 	mutex      sync.RWMutex
 	current    *KeyPair
 	previous   *KeyPair
-	next       *KeyPair
-	newKeyPair chan bool
+	next       *KeyPair  // not yet "confirmed by transport"
+	newKeyPair chan bool // signals when "current" has been updated
+}
+
+func (kp *KeyPairs) Init() {
+	kp.mutex.Lock()
+	kp.newKeyPair = make(chan bool, 5)
+	kp.mutex.Unlock()
+}
+
+func (kp *KeyPairs) Current() *KeyPair {
+	kp.mutex.RLock()
+	defer kp.mutex.RUnlock()
+	return kp.current
 }