backend: wip on serialize api

redpanda-data · Aug 30, 2023 · e4c1836 · e4c1836
1 parent dde5877
commit e4c1836
Show file tree

Hide file tree

Showing 15 changed files with 1,449 additions and 664 deletions.
diff --git a/backend/pkg/api/handle_topic_publish_records.go b/backend/pkg/api/handle_topic_publish_records.go
@@ -10,11 +10,16 @@
 package api
 
 import (
+	"context"
+	"errors"
 	"fmt"
 	"net/http"
 
+	"connectrpc.com/connect"
 	"github.com/cloudhut/common/rest"
 	"github.com/twmb/franz-go/pkg/kgo"
+
+	v1alpha "github.com/redpanda-data/console/backend/pkg/protogen/redpanda/api/console/v1alpha"
 )
 
 type recordsRequest struct {
@@ -139,3 +144,7 @@ func (api *API) handlePublishTopicsRecords() http.HandlerFunc {
 		rest.SendResponse(w, r, api.Logger, http.StatusOK, publishRes)
 	}
 }
+
+func (api *API) PublishMessage(context.Context, *connect.Request[v1alpha.PublishMessageRequest]) (*connect.Response[v1alpha.PublishMessageResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("redpanda.api.console.v1alpha.ConsoleService.PublishMessage is not implemented"))
+}
diff --git a/backend/pkg/protogen/redpanda/api/console/v1alpha/common.pb.go b/backend/pkg/protogen/redpanda/api/console/v1alpha/common.pb.go
diff --git a/backend/pkg/protogen/redpanda/api/console/v1alpha/console_service.pb.go b/backend/pkg/protogen/redpanda/api/console/v1alpha/console_service.pb.go
diff --git a/...lev1alphaconnect/list_messages.connect.go → ...v1alphaconnect/console_service.connect.go b/...lev1alphaconnect/list_messages.connect.go → ...v1alphaconnect/console_service.connect.go