stop exporting registerUpstreamMessageTypeSpecifier

internal/daemon/cluster/handlers/upstream_message_service_controller.go

@@ -49,7 +49,7 @@ func RegisterUpstreamMessageHandler(ctx context.Context, msgType pbs.MsgType, h
 		return errors.New(ctx, errors.InvalidParameter, op, "missing handler")
 	}
 	upstreamMessageHandler.Store(msgType, h)
-	if err := RegisterUpstreamMessageTypeSpecifier(ctx, msgType, h); err != nil {
+	if err := registerUpstreamMessageTypeSpecifier(ctx, msgType, h); err != nil {
 		return errors.Wrap(ctx, err, op)
 	}
 	return nil

internal/daemon/cluster/handlers/upstream_message_service_test.go

@@ -473,7 +473,7 @@ func Test_RegisterUpstreamMessageTypeSpecifier(t *testing.T) {
 				cp.Store(k, v)
 				return true
 			})
-			err := RegisterUpstreamMessageTypeSpecifier(testCtx, tc.msgType, tc.s)
+			err := registerUpstreamMessageTypeSpecifier(testCtx, tc.msgType, tc.s)
 			t.Cleanup(func() {
 				upstreamMessageHandler = cp
 			})

internal/daemon/cluster/handlers/upstream_message_service_worker.go

@@ -84,13 +84,13 @@ type UpstreamMessageTypeSpecifier interface {
 
 var upstreamMessageTypeSpecifier sync.Map
 
-// RegisterUpstreamMessageTypeSpecifier will register an
+// registerUpstreamMessageTypeSpecifier will register an
 // UpstreamMessageTypeSpecifier for the specified msg name.
 //
 // See handlers.SendUpstreamMessage for how this is
 // used to send UpstreamMessage requests
-func RegisterUpstreamMessageTypeSpecifier(ctx context.Context, msgType pbs.MsgType, t UpstreamMessageTypeSpecifier) error {
-	const op = "handlers.RegisterUpstreamMessageTypeSpecifier"
+func registerUpstreamMessageTypeSpecifier(ctx context.Context, msgType pbs.MsgType, t UpstreamMessageTypeSpecifier) error {
+	const op = "handlers.registerUpstreamMessageTypeSpecifier"
 	switch {
 	case msgType == pbs.MsgType_MSG_TYPE_UNSPECIFIED:
 		return errors.New(ctx, errors.InvalidParameter, op, "missing msg type")