chore: linting

Author: gregfurman

internal/plugin/components/types.go

@@ -14,8 +14,6 @@ type (
 
 var (
 	errPluginAlreadyRegistered  = errors.New("plugin already registered")
-	errPluginNotRegistered      = errors.New("plugin is not registered")
-	errInvalidPluginType        = errors.New("Invalid or unsupported plugin type")
 	errInvalidInstanceID        = errors.New("instance ID does not correspond to an active plugin")
 	errInvalidInitNotRegistered = errors.New("cannot initialize an unregistered plugin")
 )

public/wasm/examples/flip/main.go

@@ -9,7 +9,9 @@ import (
 )
 
 func init() {
-	plugin.RegisterBatchProcessor(newFlipProcessor)
+	if err := plugin.RegisterBatchProcessor(newFlipProcessor); err != nil {
+		panic(err)
+	}
 }
 
 func newFlipProcessor(conf *service.ParsedConfig, mgr *service.Resources) (service.BatchProcessor, error) {

public/wasm/examples/reverse/main.go

@@ -12,7 +12,9 @@ import (
 )
 
 func init() {
-	plugin.RegisterBatchProcessor(newReverseProcessor)
+	if err := plugin.RegisterBatchProcessor(newReverseProcessor); err != nil {
+		panic(err)
+	}
 }
 
 func newReverseProcessor(_ *service.ParsedConfig, mgr *service.Resources) (service.BatchProcessor, error) {

public/wasm/examples/uppercase_processor/main.go

@@ -15,7 +15,9 @@ type config struct {
 }
 
 func init() {
-	plugin.RegisterBatchProcessor(newUppercaseProcessor)
+	if err := plugin.RegisterBatchProcessor(newUppercaseProcessor); err != nil {
+		panic(err)
+	}
 }
 
 func newUppercaseProcessor(cfg *config, mgr *service.Resources) (service.BatchProcessor, error) {