Embed the Unimplemented implementation

Author: aledbf

components/content-service/pkg/service/blob-service.go

@@ -22,6 +22,8 @@ import (
 type BlobService struct {
 	cfg storage.Config
 	s   storage.PresignedAccess
+
+	api.UnimplementedBlobServiceServer
 }
 
 // NewBlobService create a new content service
@@ -30,7 +32,7 @@ func NewBlobService(cfg storage.Config) (res *BlobService, err error) {
 	if err != nil {
 		return nil, err
 	}
-	return &BlobService{cfg, s}, nil
+	return &BlobService{cfg: cfg, s: s}, nil
 }
 
 // UploadUrl provides a upload URL

components/content-service/pkg/service/content-service.go

@@ -7,19 +7,22 @@ package service
 import (
 	"context"
 
+	"github.com/opentracing/opentracing-go"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+
 	"github.com/gitpod-io/gitpod/common-go/log"
 	"github.com/gitpod-io/gitpod/common-go/tracing"
 	"github.com/gitpod-io/gitpod/content-service/api"
 	"github.com/gitpod-io/gitpod/content-service/pkg/storage"
-	"github.com/opentracing/opentracing-go"
-	"google.golang.org/grpc/codes"
-	"google.golang.org/grpc/status"
 )
 
 // ContentService implements ContentServiceServer
 type ContentService struct {
 	cfg storage.Config
 	s   storage.PresignedAccess
+
+	api.UnimplementedContentServiceServer
 }
 
 // NewContentService create a new content service
@@ -28,7 +31,7 @@ func NewContentService(cfg storage.Config) (res *ContentService, err error) {
 	if err != nil {
 		return nil, err
 	}
-	return &ContentService{cfg, s}, nil
+	return &ContentService{cfg: cfg, s: s}, nil
 }
 
 // DeleteUserContent deletes all content associated with a user.

components/content-service/pkg/service/ideplugin-service.go

@@ -7,19 +7,22 @@ package service
 import (
 	"context"
 
+	"github.com/opentracing/opentracing-go"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+
 	"github.com/gitpod-io/gitpod/common-go/log"
 	"github.com/gitpod-io/gitpod/common-go/tracing"
 	"github.com/gitpod-io/gitpod/content-service/api"
 	"github.com/gitpod-io/gitpod/content-service/pkg/storage"
-	"github.com/opentracing/opentracing-go"
-	"google.golang.org/grpc/codes"
-	"google.golang.org/grpc/status"
 )
 
 // IDEPluginService implements IDEPluginServiceServer
 type IDEPluginService struct {
 	cfg storage.Config
 	s   storage.PresignedAccess
+
+	api.UnimplementedIDEPluginServiceServer
 }
 
 // NewIDEPluginService create a new IDE plugin service
@@ -28,7 +31,7 @@ func NewIDEPluginService(cfg storage.Config) (res *IDEPluginService, err error)
 	if err != nil {
 		return nil, err
 	}
-	return &IDEPluginService{cfg, s}, nil
+	return &IDEPluginService{cfg: cfg, s: s}, nil
 }
 
 // UploadURL provides a URL to which clients can upload the content via HTTP PUT.

components/content-service/pkg/service/workspace-service.go

@@ -8,19 +8,22 @@ import (
 	"context"
 	"strings"
 
+	"github.com/opentracing/opentracing-go"
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
+
 	"github.com/gitpod-io/gitpod/common-go/log"
 	"github.com/gitpod-io/gitpod/common-go/tracing"
 	"github.com/gitpod-io/gitpod/content-service/api"
 	"github.com/gitpod-io/gitpod/content-service/pkg/storage"
-	"github.com/opentracing/opentracing-go"
-	"google.golang.org/grpc/codes"
-	"google.golang.org/grpc/status"
 )
 
 // WorkspaceService implements WorkspaceServiceServer
 type WorkspaceService struct {
 	cfg storage.Config
 	s   storage.PresignedAccess
+
+	api.UnimplementedWorkspaceServiceServer
 }
 
 // NewWorkspaceService create a new content service
@@ -29,7 +32,7 @@ func NewWorkspaceService(cfg storage.Config) (res *WorkspaceService, err error)
 	if err != nil {
 		return nil, err
 	}
-	return &WorkspaceService{cfg, s}, nil
+	return &WorkspaceService{cfg: cfg, s: s}, nil
 }
 
 // WorkspaceDownloadURL provides a URL from where the content of a workspace can be downloaded from

components/image-builder-api/go/mock/mock.go

@@ -80,6 +80,8 @@ type DockerBuilder struct {
 	imgExistsCache map[string]struct{}
 
 	gc *GarbageCollector
+
+	api.UnimplementedImageBuilderServer
 }
 
 // Start iniitializes the docker builder and starts its maintainance functions. This function must be called prior to calling

components/image-builder/pkg/builder/builder.go

@@ -8,12 +8,13 @@ import (
 	"context"
 	"sync"
 
-	"github.com/gitpod-io/gitpod/common-go/log"
-	"github.com/gitpod-io/gitpod/supervisor/api"
 	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
+
+	"github.com/gitpod-io/gitpod/common-go/log"
+	"github.com/gitpod-io/gitpod/supervisor/api"
 )
 
 const (
@@ -36,6 +37,8 @@ type NotificationService struct {
 	subscriptions        map[uint64]*subscription
 	nextNotificationID   uint64
 	pendingNotifications map[uint64]*pendingNotification
+
+	api.UnimplementedNotificationServiceServer
 }
 
 type pendingNotification struct {

components/supervisor/pkg/supervisor/notification.go

@@ -81,6 +81,8 @@ type statusService struct {
 	Ports        *ports.Manager
 	Tasks        *tasksManager
 	ideReady     *ideReadyState
+
+	api.UnimplementedStatusServiceServer
 }
 
 func (s *statusService) RegisterGRPC(srv *grpc.Server) {
@@ -220,6 +222,8 @@ func (s *statusService) TasksStatus(req *api.TasksStatusRequest, srv api.StatusS
 // RegistrableTokenService can register the token service
 type RegistrableTokenService struct {
 	Service api.TokenServiceServer
+
+	api.UnimplementedTokenServiceServer
 }
 
 // RegisterGRPC registers a gRPC service
@@ -297,6 +301,8 @@ type InMemoryTokenService struct {
 	token    map[string][]*Token
 	provider map[string][]tokenProvider
 	mu       sync.RWMutex
+
+	api.UnimplementedTokenServiceServer
 }
 
 // GetToken returns a token for a host
@@ -560,6 +566,8 @@ func (rt *remoteTokenProvider) GetToken(ctx context.Context, req *api.GetTokenRe
 type InfoService struct {
 	cfg          *Config
 	ContentState ContentState
+
+	api.UnimplementedInfoServiceServer
 }
 
 // RegisterGRPC registers the gRPC info service
@@ -625,6 +633,8 @@ func (is *InfoService) WorkspaceInfo(context.Context, *api.WorkspaceInfoRequest)
 // ControlService implements the supervisor control service
 type ControlService struct {
 	portsManager *ports.Manager
+
+	api.UnimplementedControlServiceServer
 }
 
 // RegisterGRPC registers the gRPC info service

components/supervisor/pkg/supervisor/services.go

@@ -162,7 +162,7 @@ func Run(options ...RunOption) {
 			ideReady:     ideReady,
 		},
 		termMuxSrv,
-		RegistrableTokenService{tokenService},
+		RegistrableTokenService{Service: tokenService},
 		notificationService,
 		&InfoService{cfg: cfg, ContentState: cstate},
 		&ControlService{portsManager: portMgmt},

components/supervisor/pkg/supervisor/supervisor.go

@@ -50,6 +50,8 @@ type MuxTerminalService struct {
 	DefaultWorkdir string
 	DefaultShell   string
 	Env            []string
+
+	api.UnimplementedTerminalServiceServer
 }
 
 // RegisterGRPC registers a gRPC service