feat: Add missing method

keboola · Jun 6, 2024 · 5a591f0 · 5a591f0
1 parent d703cea
commit 5a591f0
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/internal/pkg/service/stream/api/service/aggregation.go b/internal/pkg/service/stream/api/service/aggregation.go
@@ -0,0 +1,13 @@
+package service
+
+import (
+	"context"
+
+	"github.com/keboola/keboola-as-code/internal/pkg/service/common/errors"
+	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/api/gen/stream"
+	"github.com/keboola/keboola-as-code/internal/pkg/service/stream/dependencies"
+)
+
+func (s *service) AggregateSources(ctx context.Context, d dependencies.BranchRequestScope, payload *stream.AggregateSourcesPayload) (res *stream.AggregationSourcesResult, err error) {
+	return nil, errors.NewNotImplementedError()
+}