DONOTMERGE: Initial new api

pkg/ipcache/ipcache.go

@@ -4,14 +4,17 @@
 package ipcache
 
 import (
+	"errors"
 	"net"
 
 	"github.com/sirupsen/logrus"
 
 	"github.com/cilium/cilium/pkg/controller"
 	"github.com/cilium/cilium/pkg/identity"
 	"github.com/cilium/cilium/pkg/identity/cache"
+	"github.com/cilium/cilium/pkg/ipcache/types"
 	ipcacheTypes "github.com/cilium/cilium/pkg/ipcache/types"
+	"github.com/cilium/cilium/pkg/labels"
 	"github.com/cilium/cilium/pkg/lock"
 	"github.com/cilium/cilium/pkg/logging/logfields"
 	"github.com/cilium/cilium/pkg/option"
@@ -411,6 +414,45 @@ func (ipc *IPCache) DumpToListener(listener IPIdentityMappingListener) {
 	ipc.RUnlock()
 }
 
+func (ipc *IPCache) UpsertIdentity(cidr string, id identity.Identity) error {
+	return errors.New("not implemented")
+}
+func (ipc *IPCache) UpsertEncryptKey(cidr string, key uint8) error {
+	return errors.New("not implemented")
+}
+func (ipc *IPCache) UpsertK8sMetadata(cidr string, k8sMeta *K8sMetadata) error {
+	return errors.New("not implemented")
+}
+
+// TODO: Figure out what kind of mechanism we need to report that this operation was completed
+func (ipc *IPCache) UpsertLabels(cidr string, lbls labels.Labels, src source.Source, name types.ResourceID) error {
+	ipc.UpsertMetadata(cidr, lbls, src, name)
+	ipc.TriggerLabelInjection()
+
+	return errors.New("not implemented")
+}
+
+// TODO: Figure out what kind of mechanism we need to report that this operation was completed
+func (ipc *IPCache) RemoveLabels(cidr string, lbls labels.Labels, name types.ResourceID) error {
+	ipc.metadata.Lock()
+	ipc.removeLabels(cidr, lbls, name)
+	ipc.metadata.Unlock()
+
+	ipc.TriggerLabelInjection()
+
+	return errors.New("not implemented")
+}
+
+//func (ipc *IPcache) UpsertCIDRs(cidrs []string) error {
+//	ipc.Lock()
+//	defer ipc.Unlock()
+//
+//	for c := cidrs {
+//		// insert into the tree
+//	}
+//	ipc.TriggerLabelInjection()
+//}
+
 // DumpToListenerLocked dumps the entire contents of the IPCache by triggering
 // the listener's "OnIPIdentityCacheChange" method for each entry in the cache.
 // The caller *MUST* grab the IPCache.Lock for reading before calling this