Add PKI placeholder code

ci/tools.go

@@ -1,3 +1,4 @@
+//go:build tools
 // +build tools
 
 /*

pkg/api/v1/clients/kube/crd/client/clientset/versioned/versioned_suite_test.go

@@ -9,7 +9,7 @@ import (
 	. "github.com/onsi/gomega"
 )
 
-//TODO: fix tests
+// TODO: fix tests
 func TestVersioned(t *testing.T) {
 
 	log.Printf("Skipping Versioned Suite. Tests are currently failing and need to be fixed.")

pkg/api/v1/clients/vault/pki_resource_client.go

@@ -0,0 +1,91 @@
+package vault
+
+import (
+	"time"
+
+	"github.com/solo-io/solo-kit/pkg/api/shared"
+	"github.com/solo-io/solo-kit/pkg/api/v1/clients"
+	"github.com/solo-io/solo-kit/pkg/api/v1/resources"
+)
+
+var _ clients.ResourceClient = new(PkiResourceClient)
+
+type PkiResourceClient struct {
+	//vault *api.Client
+
+	resourceType resources.VersionedResource
+}
+
+func (p PkiResourceClient) Kind() string {
+	return resources.Kind(p.resourceType)
+}
+
+func (p PkiResourceClient) NewResource() resources.Resource {
+	return resources.Clone(p.resourceType)
+}
+
+func (p PkiResourceClient) Register() error {
+	return nil
+}
+
+func (p PkiResourceClient) Read(namespace, name string, opts clients.ReadOpts) (resources.Resource, error) {
+	//TODO implement me
+	panic("implement me")
+}
+
+func (p PkiResourceClient) Write(resource resources.Resource, opts clients.WriteOpts) (resources.Resource, error) {
+	//TODO implement me
+	panic("implement me")
+}
+
+func (p PkiResourceClient) Delete(namespace, name string, opts clients.DeleteOpts) error {
+	//TODO implement me
+	panic("implement me")
+}
+
+func (p PkiResourceClient) List(namespace string, opts clients.ListOpts) (resources.ResourceList, error) {
+	//TODO implement me
+	panic("implement me")
+}
+
+func (p PkiResourceClient) ApplyStatus(statusClient resources.StatusClient, inputResource resources.InputResource, opts clients.ApplyStatusOpts) (resources.Resource, error) {
+	return shared.ApplyStatus(p, statusClient, inputResource, opts)
+}
+
+func (p PkiResourceClient) Watch(namespace string, opts clients.WatchOpts) (<-chan resources.ResourceList, <-chan error, error) {
+	opts = opts.WithDefaults()
+	resourcesChan := make(chan resources.ResourceList)
+	errs := make(chan error)
+
+	listOpts := clients.ListOpts{
+		Ctx:                opts.Ctx,
+		Selector:           opts.Selector,
+		ExpressionSelector: opts.ExpressionSelector,
+	}
+
+	go func() {
+		// watch should open up with an initial read
+		initialResourceList, initialResourceListErr := p.List(namespace, listOpts)
+		if initialResourceListErr != nil {
+			errs <- initialResourceListErr
+			return
+		}
+		resourcesChan <- initialResourceList
+		for {
+			select {
+			case <-time.After(opts.RefreshRate):
+				resourceList, resourceListErr := p.List(namespace, listOpts)
+				if resourceListErr != nil {
+					errs <- resourceListErr
+				}
+				resourcesChan <- resourceList
+			case <-opts.Ctx.Done():
+				close(resourcesChan)
+				close(errs)
+				return
+			}
+		}
+	}()
+
+	return resourcesChan, errs, nil
+}

pkg/api/v1/control-plane/cache/prioritylist.go

@@ -21,11 +21,12 @@ type PriorityValue interface {
 // If a priority does not exist for an added element, it is added to the lowest priority.
 //
 // The below 1, 2, 4 go first, 10 second, and 17 third. Anything else is processed last
-// {
-//	0: {item1, item2, item4}
-//	1: {item10}
-//	2: {item17}
-// }
+//
+//	{
+//		0: {item1, item2, item4}
+//		1: {item10}
+//		2: {item17}
+//	}
 type PrioritySortedStruct struct {
 	// priorityMap maps the value to the priority.
 	priorityMap map[string]int

pkg/code-generator/collector/extractor.go

@@ -16,11 +16,11 @@ type ImportsExtractor interface {
 // thread-safe
 // The synchronizedImportsExtractor provides synchronized access to imports for a given proto file.
 // It provides 2 useful features for tree traversal:
-//	1. Imports for each file are cached, ensuring that if we attempt to access that file
-//		during traversal again, we do not need to duplicate work.
-//	2. If imports for a file are unknown, and simultaneous go routines attempt to load
-//		the imports, only 1 will execute and the other will block, waiting for the result.
-//		This reduces the number of times we open and parse files.
+//  1. Imports for each file are cached, ensuring that if we attempt to access that file
+//     during traversal again, we do not need to duplicate work.
+//  2. If imports for a file are unknown, and simultaneous go routines attempt to load
+//     the imports, only 1 will execute and the other will block, waiting for the result.
+//     This reduces the number of times we open and parse files.
 type synchronizedImportsExtractor struct {
 	// cachedImports contains a map of fileImports, each indexed by their file name
 	cachedImports sync.Map

pkg/code-generator/docgen/cross_project.go

@@ -104,7 +104,8 @@ func WriteCrossProjectDocsHugo(
 }
 
 // util for populating the Hugo ProtoMap to enable allows lookup by
-//   somepkg.solo.io or somepkg.solo.io.SomeMessage
+//
+//	somepkg.solo.io or somepkg.solo.io.SomeMessage
 func getApiSummaryKV(apiDir, filename, packageName, fieldName string) (string, datafile.ApiSummary) {
 	key := packageName
 	hashPath := ""

pkg/code-generator/metrics/metrics.go

@@ -40,6 +40,7 @@ func Flush(writer io.Writer) error {
 
 // This is a primitive implementation for compiling performance measurements of code-gen
 // If we need it, we could substitute this with something more heavy handed like:
+//
 //	https://github.com/armon/go-metrics
 type metricAggregator struct {
 	metricsMu sync.Mutex

pkg/code-generator/schemagen/cue.go

@@ -21,10 +21,11 @@ import (
 // packages to translate protobuf definitions into OpenAPI schemas with structural constraints
 // It is modeled after the istio tool: https://github.com/istio/tools/tree/master/cmd/cue-gen
 // TODO (sam-heilbron) This tool has a known flaw that makes it unusable with Gloo Edge protos
-// 	 There are open issues to track this and a GitHub discussion with more context:
-//	 https://github.com/cuelang/cue/discussions/944. We would like to move towards this
-//	 implementation and have added it now to compare schemas generated with this implementation
-//	 to schemas generated with other implementations to ensure consistency.
+//
+//	There are open issues to track this and a GitHub discussion with more context:
+//	https://github.com/cuelang/cue/discussions/944. We would like to move towards this
+//	implementation and have added it now to compare schemas generated with this implementation
+//	to schemas generated with other implementations to ensure consistency.
 type cueGenerator struct {
 	// The Collector used to extract imports for proto files
 	importsCollector collector.Collector

pkg/utils/modutils/mod.go

@@ -21,9 +21,9 @@ var (
 )
 
 /*
-	Returns the current go mod package name from the go.mod file.
-	Use the function below to get the filename
-	Ex: github.com/solo-io/solo-kit
+Returns the current go mod package name from the go.mod file.
+Use the function below to get the filename
+Ex: github.com/solo-io/solo-kit
 */
 func GetCurrentModPackageName(module string) (string, error) {
 	f, err := os.Open(module)
@@ -44,10 +44,10 @@ func GetCurrentModPackageName(module string) (string, error) {
 }
 
 /*
-	Returns the current go mod package
-	Ex: /path/to/solo-kit/go.mod
+Returns the current go mod package
+Ex: /path/to/solo-kit/go.mod
 
-	Will return /dev/null on unix if not in a go.mod package
+Will return /dev/null on unix if not in a go.mod package
 */
 func GetCurrentModPackageFile() (string, error) {
 	cmd := exec.Command("go", "env", "GOMOD")

pkg/utils/statusutils/client.go

@@ -31,7 +31,7 @@ func (s *NamespacedStatusesClient) SetStatus(resource resources.InputResource, s
 type NoOpStatusClient struct {
 }
 
-//noinspection GoUnusedExportedFunction
+// noinspection GoUnusedExportedFunction
 func NewNoOpStatusClient() *NoOpStatusClient {
 	return &NoOpStatusClient{}
 }

pkg/utils/statusutils/env.go

@@ -10,7 +10,7 @@ import (
 // to associate a resource status with the appropriate controller statusReporterNamespace
 const PodNamespaceEnvName = "POD_NAMESPACE"
 
-//noinspection GoUnusedExportedFunction
+// noinspection GoUnusedExportedFunction
 func GetStatusReporterNamespaceFromEnv() (string, error) {
 	podNamespace := os.Getenv(PodNamespaceEnvName)
 	if podNamespace == "" {