kubeflow
/
model-registry
mirror of https://github.com/kubeflow/model-registry.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Made pkg code private 

Moved pkg to internal since it's not meant to be exported as reusable pkg outside this project.
This commit is contained in:
Dhiraj Bokde 2023-09-20 09:08:40 -07:00
parent 11f65a9bbd
commit 7782ec4974
35 changed files with 236 additions and 231 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
Makefile
View File

@ -1,16 +1,16 @@
model-registry: build
pkg/ml_metadata/proto/%.pb.go: api/grpc/ml_metadata/proto/%.proto
protoc -I./api/grpc --go_out=./pkg --go_opt=paths=source_relative \
--go-grpc_out=./pkg --go-grpc_opt=paths=source_relative $<
internal/ml_metadata/proto/%.pb.go: api/grpc/ml_metadata/proto/%.proto
protoc -I./api/grpc --go_out=./internal --go_opt=paths=source_relative \
--go-grpc_out=./internal --go-grpc_opt=paths=source_relative $<
.PHONY: gen/grpc
gen/grpc: pkg/ml_metadata/proto/metadata_store.pb.go pkg/ml_metadata/proto/metadata_store_service.pb.go
gen/grpc: internal/ml_metadata/proto/metadata_store.pb.go internal/ml_metadata/proto/metadata_store_service.pb.go
.PHONY: gen/graph
gen/graph: pkg/model/graph/models_gen.go
gen/graph: internal/model/graph/models_gen.go
pkg/model/graph/models_gen.go: api/graphql/*.graphqls gqlgen.yml
internal/model/graph/models_gen.go: api/graphql/*.graphqls gqlgen.yml
go run github.com/99designs/gqlgen generate
.PHONY: vet
@ -19,7 +19,7 @@ vet:
.PHONY: clean
clean:
rm -Rf ./model-registry pkg/ml_metadata/proto/*.go pkg/model/graph/*.go
rm -Rf ./model-registry internal/ml_metadata/proto/*.go internal/model/graph/*.go
.PHONY: vendor
vendor:
@ -31,11 +31,12 @@ build: gen vet lint
.PHONY: gen
gen: gen/grpc gen/graph
go generate ./...
.PHONY: lint
lint: gen
golangci-lint run main.go
golangci-lint run cmd/... pkg/...
golangci-lint run cmd/... internal/...
.PHONY: run/migrate
run/migrate: gen

2
api/grpc/ml_metadata/proto/metadata_source.proto
View File

@ -14,7 +14,7 @@ limitations under the License.
==============================================================================*/
// The returned results from a MetadataSource.
syntax = "proto3";
option go_package = "github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto";
option go_package = "github.com/opendatahub-io/model-registry/internal/ml_metadata/proto";
package ml_metadata;

2
api/grpc/ml_metadata/proto/metadata_store.proto
View File

@ -13,7 +13,7 @@ See the License for the specific language governing permissions and
limitations under the License.
==============================================================================*/
syntax = "proto2";
option go_package = "github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto";
option go_package = "github.com/opendatahub-io/model-registry/internal/ml_metadata/proto";
package ml_metadata;

2
api/grpc/ml_metadata/proto/metadata_store_service.proto
View File

@ -14,7 +14,7 @@ limitations under the License.
==============================================================================*/
syntax = "proto2";
option go_package = "github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto";
option go_package = "github.com/opendatahub-io/model-registry/internal/ml_metadata/proto";
package ml_metadata;

44
cmd/migrate.go
View File

@ -19,12 +19,12 @@ import (
"context"
"fmt"
"github.com/golang/glog"
proto2 "github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto"
db2 "github.com/opendatahub-io/model-registry/pkg/model/db"
"github.com/opendatahub-io/model-registry/pkg/model/library"
"github.com/opendatahub-io/model-registry/pkg/server"
"github.com/opendatahub-io/model-registry/internal/ml_metadata/proto"
"github.com/opendatahub-io/model-registry/internal/model/db"
"github.com/opendatahub-io/model-registry/internal/model/library"
"github.com/opendatahub-io/model-registry/internal/server"
"github.com/spf13/cobra"
yaml "gopkg.in/yaml.v3"
"gopkg.in/yaml.v3"
"gorm.io/gorm"
"io/fs"
"os"
@ -75,19 +75,19 @@ to the latest schema required by this server.`,
func migrateDatabase(dbConn *gorm.DB) error {
// TODO add support for more elaborate Gorm migrations
err := dbConn.AutoMigrate(
db2.Artifact{},
db2.ArtifactProperty{},
db2.Association{},
db2.Attribution{},
db2.Context{},
db2.ContextProperty{},
db2.Event{},
db2.EventPath{},
db2.Execution{},
db2.ExecutionProperty{},
db2.ParentContext{},
db2.Type{},
db2.TypeProperty{},
db.Artifact{},
db.ArtifactProperty{},
db.Association{},
db.Attribution{},
db.Context{},
db.ContextProperty{},
db.Event{},
db.EventPath{},
db.Execution{},
db.ExecutionProperty{},
db.ParentContext{},
db.Type{},
db.TypeProperty{},
)
if err != nil {
return fmt.Errorf("db migration failed: %w", err)
@ -124,9 +124,9 @@ func loadLibraries(dbConn *gorm.DB) error {
return fmt.Errorf("failed to parse library file %s: %w", path, err)
}
grpcServer := server.NewGrpcServer(dbConn)
typesRequest := proto2.PutTypesRequest{}
typesRequest := proto.PutTypesRequest{}
for _, at := range lib.ArtifactTypes {
typesRequest.ArtifactTypes = append(typesRequest.ArtifactTypes, &proto2.ArtifactType{
typesRequest.ArtifactTypes = append(typesRequest.ArtifactTypes, &proto.ArtifactType{
Name: at.Name,
Version: at.Version,
Description: at.Description,
@ -135,7 +135,7 @@ func loadLibraries(dbConn *gorm.DB) error {
})
}
for _, ct := range lib.ContextTypes {
typesRequest.ContextTypes = append(typesRequest.ContextTypes, &proto2.ContextType{
typesRequest.ContextTypes = append(typesRequest.ContextTypes, &proto.ContextType{
Name: ct.Name,
Version: ct.Version,
Description: ct.Description,
@ -144,7 +144,7 @@ func loadLibraries(dbConn *gorm.DB) error {
})
}
for _, et := range lib.ExecutionTypes {
typesRequest.ExecutionTypes = append(typesRequest.ExecutionTypes, &proto2.ExecutionType{
typesRequest.ExecutionTypes = append(typesRequest.ExecutionTypes, &proto.ExecutionType{
Name: et.Name,
Version: et.Version,
Description: et.Description,

3
cmd/root.go
View File

@ -62,6 +62,9 @@ func init() {
// will be global for your application.
rootCmd.PersistentFlags().StringVar(&cfgFile, "config", "", "config file (default is $HOME/.model-registry.yaml)")
// default to logging to stderr
_ = flag.Set("logtostderr", "true")
// also add standard glog flags
rootCmd.PersistentFlags().AddGoFlagSet(flag.CommandLine)

8
cmd/serve.go
View File

@ -22,9 +22,9 @@ import (
"github.com/99designs/gqlgen/graphql/playground"
"github.com/golang/glog"
"github.com/grpc-ecosystem/go-grpc-middleware/v2/interceptors/logging"
"github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto"
"github.com/opendatahub-io/model-registry/pkg/server"
graph2 "github.com/opendatahub-io/model-registry/pkg/server/graph"
"github.com/opendatahub-io/model-registry/internal/ml_metadata/proto"
"github.com/opendatahub-io/model-registry/internal/server"
"github.com/opendatahub-io/model-registry/internal/server/graph"
"github.com/soheilhy/cmux"
"github.com/spf13/cobra"
"golang.org/x/sync/errgroup"
@ -154,7 +154,7 @@ func runServer(cmd *cobra.Command, args []string) error {
func graphQlListenerServer(listener net.Listener, db *gorm.DB) *http.Server {
mux := http.NewServeMux()
srv := handler.NewDefaultServer(graph2.NewExecutableSchema(graph2.Config{Resolvers: &graph2.Resolver{}}))
srv := handler.NewDefaultServer(graph.NewExecutableSchema(graph.Config{Resolvers: &graph.Resolver{}}))
mux.Handle("/", playground.Handler("GraphQL playground", "/query"))
mux.Handle("/query", srv)

6
gqlgen.yml
View File

@ -4,7 +4,7 @@ schema:
# Where should the generated server code go?
exec:
filename: pkg/server/graph/generated.go
filename: internal/server/graph/generated.go
package: graph
# Uncomment to enable federation
@ -14,13 +14,13 @@ exec:
# Where should any generated models go?
model:
filename: pkg/model/graph/models_gen.go
filename: internal/model/graph/models_gen.go
package: graph
# Where should the resolver implementations go?
resolver:
layout: follow-schema
dir: pkg/server/graph
dir: internal/server/graph
package: graph
filename_template: "{name}.resolvers.go"
# Optional: turn on to not generate template comments above resolvers

9
pkg/ml_metadata/proto/metadata_store.pb.go → internal/ml_metadata/proto/metadata_store.pb.go
View File

@ -5662,11 +5662,12 @@ var file_ml_metadata_proto_metadata_store_proto_rawDesc = []byte{
0xb7, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x6d, 0x6c, 0x5f, 0x6d, 0x65, 0x74, 0x61,
0x64, 0x61, 0x74, 0x61, 0x2e, 0x53, 0x79, 0x73, 0x74, 0x65, 0x6d, 0x54, 0x79, 0x70, 0x65, 0x45,
0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x13, 0x73, 0x79, 0x73, 0x74, 0x65, 0x6d,
0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x40, 0x5a,
0x3e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6f, 0x70, 0x65, 0x6e,
0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x42, 0x45, 0x5a,
0x43, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6f, 0x70, 0x65, 0x6e,
0x64, 0x61, 0x74, 0x61, 0x68, 0x75, 0x62, 0x2d, 0x69, 0x6f, 0x2f, 0x6d, 0x6f, 0x64, 0x65, 0x6c,
0x2d, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x72, 0x79, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x6d, 0x6c,
0x5f, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x2d, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x72, 0x79, 0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e,
0x61, 0x6c, 0x2f, 0x6d, 0x6c, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x70,
0x72, 0x6f, 0x74, 0x6f,
}
var (

6
pkg/ml_metadata/proto/metadata_store_service.pb.go → internal/ml_metadata/proto/metadata_store_service.pb.go
View File

@ -8399,11 +8399,11 @@ var file_ml_metadata_proto_metadata_store_service_proto_rawDesc = []byte{
0x70, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x6d, 0x6c, 0x5f, 0x6d,
0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x69, 0x6e, 0x65, 0x61,
0x67, 0x65, 0x53, 0x75, 0x62, 0x67, 0x72, 0x61, 0x70, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
0x73, 0x65, 0x22, 0x00, 0x42, 0x40, 0x5a, 0x3e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
0x73, 0x65, 0x22, 0x00, 0x42, 0x45, 0x5a, 0x43, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63,
0x6f, 0x6d, 0x2f, 0x6f, 0x70, 0x65, 0x6e, 0x64, 0x61, 0x74, 0x61, 0x68, 0x75, 0x62, 0x2d, 0x69,
0x6f, 0x2f, 0x6d, 0x6f, 0x64, 0x65, 0x6c, 0x2d, 0x72, 0x65, 0x67, 0x69, 0x73, 0x74, 0x72, 0x79,
0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x6d, 0x6c, 0x5f, 0x6d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61,
0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x2f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x2f, 0x6d, 0x6c, 0x5f, 0x6d, 0x65, 0x74,
0x61, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
}
var (

0
pkg/ml_metadata/proto/metadata_store_service_grpc.pb.go → internal/ml_metadata/proto/metadata_store_service_grpc.pb.go
View File

0
pkg/model/db/artifact.gen.go → internal/model/db/artifact.gen.go
View File

0
pkg/model/db/artifactproperty.gen.go → internal/model/db/artifactproperty.gen.go
View File

0
pkg/model/db/association.gen.go → internal/model/db/association.gen.go
View File

0
pkg/model/db/attribution.gen.go → internal/model/db/attribution.gen.go
View File

0
pkg/model/db/context.gen.go → internal/model/db/context.gen.go
View File

0
pkg/model/db/contextproperty.gen.go → internal/model/db/contextproperty.gen.go
View File

0
pkg/model/db/event.gen.go → internal/model/db/event.gen.go
View File

0
pkg/model/db/eventpath.gen.go → internal/model/db/eventpath.gen.go
View File

0
pkg/model/db/execution.gen.go → internal/model/db/execution.gen.go
View File

0
pkg/model/db/executionproperty.gen.go → internal/model/db/executionproperty.gen.go
View File

0
pkg/model/db/mlmdenv.gen.go → internal/model/db/mlmdenv.gen.go
View File

0
pkg/model/db/parentcontext.gen.go → internal/model/db/parentcontext.gen.go
View File

0
pkg/model/db/parenttype.gen.go → internal/model/db/parenttype.gen.go
View File

0
pkg/model/db/type.gen.go → internal/model/db/type.gen.go
View File

0
pkg/model/db/typeproperty.gen.go → internal/model/db/typeproperty.gen.go
View File

0
pkg/model/graph/models_gen.go → internal/model/graph/models_gen.go
View File

2
pkg/model/library/metadata_library.go → internal/model/library/metadata_library.go
View File

@ -1,7 +1,7 @@
package library
import (
"github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto"
"github.com/opendatahub-io/model-registry/internal/ml_metadata/proto"
)
//go:generate go-enum -type=PropertyType

0
pkg/model/library/propertytype_enum.go → internal/model/library/propertytype_enum.go
View File

0
pkg/server/db_context.go → internal/server/db_context.go
View File

2
pkg/server/graph/base-schema.resolvers.go → internal/server/graph/base-schema.resolvers.go
View File

@ -7,7 +7,7 @@ package graph
import (
"context"
"github.com/opendatahub-io/model-registry/pkg/model/graph"
"github.com/opendatahub-io/model-registry/internal/model/graph"
)
// Type is the resolver for the type field.

188
pkg/server/graph/generated.go → internal/server/graph/generated.go
View File

@ -13,7 +13,7 @@ import (
"github.com/99designs/gqlgen/graphql"
"github.com/99designs/gqlgen/graphql/introspection"
"github.com/opendatahub-io/model-registry/pkg/model/graph"
"github.com/opendatahub-io/model-registry/internal/model/graph"
gqlparser "github.com/vektah/gqlparser/v2"
"github.com/vektah/gqlparser/v2/ast"
)
@ -1933,7 +1933,7 @@ func (ec *executionContext) field_Artifact_type_args(ctx context.Context, rawArg
var arg0 *graph.InstanceFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -1963,7 +1963,7 @@ func (ec *executionContext) field_Query_artifactTypes_args(ctx context.Context,
var arg0 *graph.TypeFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -1978,7 +1978,7 @@ func (ec *executionContext) field_Query_artifacts_args(ctx context.Context, rawA
var arg0 *graph.InstanceFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -1993,7 +1993,7 @@ func (ec *executionContext) field_Query_contextTypes_args(ctx context.Context, r
var arg0 *graph.TypeFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -2008,7 +2008,7 @@ func (ec *executionContext) field_Query_contexts_args(ctx context.Context, rawAr
var arg0 *graph.InstanceFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -2023,7 +2023,7 @@ func (ec *executionContext) field_Query_executionTypes_args(ctx context.Context,
var arg0 *graph.TypeFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -2038,7 +2038,7 @@ func (ec *executionContext) field_Query_executions_args(ctx context.Context, raw
var arg0 *graph.InstanceFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -2053,7 +2053,7 @@ func (ec *executionContext) field_Query_mlmdDataset_args(ctx context.Context, ra
var arg0 *graph.InstanceFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
arg0, err = ec.unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐInstanceFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -2068,7 +2068,7 @@ func (ec *executionContext) field_Query_types_args(ctx context.Context, rawArgs
var arg0 *graph.TypeFilter
if tmp, ok := rawArgs["filter"]; ok {
ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("filter"))
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
arg0, err = ec.unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeFilter(ctx, tmp)
if err != nil {
return nil, err
}
@ -2489,7 +2489,7 @@ func (ec *executionContext) _Artifact_type(ctx context.Context, field graphql.Co
}
res := resTmp.(*graph.ArtifactType)
fc.Result = res
return ec.marshalNArtifactType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactType(ctx, field.Selections, res)
return ec.marshalNArtifactType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactType(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Artifact_type(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -2557,7 +2557,7 @@ func (ec *executionContext) _Artifact_properties(ctx context.Context, field grap
}
res := resTmp.([]*graph.ArtifactProperty)
fc.Result = res
return ec.marshalOArtifactProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactPropertyᚄ(ctx, field.Selections, res)
return ec.marshalOArtifactProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactPropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Artifact_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -2737,7 +2737,7 @@ func (ec *executionContext) _ArtifactProperty_propertyValue(ctx context.Context,
}
res := resTmp.(graph.Value)
fc.Result = res
return ec.marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐValue(ctx, field.Selections, res)
return ec.marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐValue(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_ArtifactProperty_propertyValue(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3036,7 +3036,7 @@ func (ec *executionContext) _ArtifactType_properties(ctx context.Context, field
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_ArtifactType_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3390,7 +3390,7 @@ func (ec *executionContext) _Context_type(ctx context.Context, field graphql.Col
}
res := resTmp.(*graph.ContextType)
fc.Result = res
return ec.marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextType(ctx, field.Selections, res)
return ec.marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextType(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Context_type(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3447,7 +3447,7 @@ func (ec *executionContext) _Context_parent(ctx context.Context, field graphql.C
}
res := resTmp.(*graph.Context)
fc.Result = res
return ec.marshalOContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx, field.Selections, res)
return ec.marshalOContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Context_parent(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3514,7 +3514,7 @@ func (ec *executionContext) _Context_children(ctx context.Context, field graphql
}
res := resTmp.([]*graph.Context)
fc.Result = res
return ec.marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx, field.Selections, res)
return ec.marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Context_children(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3581,7 +3581,7 @@ func (ec *executionContext) _Context_attributions(ctx context.Context, field gra
}
res := resTmp.([]*graph.Artifact)
fc.Result = res
return ec.marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactᚄ(ctx, field.Selections, res)
return ec.marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Context_attributions(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3644,7 +3644,7 @@ func (ec *executionContext) _Context_associations(ctx context.Context, field gra
}
res := resTmp.([]*graph.Execution)
fc.Result = res
return ec.marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionᚄ(ctx, field.Selections, res)
return ec.marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Context_associations(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3705,7 +3705,7 @@ func (ec *executionContext) _Context_properties(ctx context.Context, field graph
}
res := resTmp.([]*graph.ContextProperty)
fc.Result = res
return ec.marshalOContextProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextPropertyᚄ(ctx, field.Selections, res)
return ec.marshalOContextProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextPropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Context_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -3888,7 +3888,7 @@ func (ec *executionContext) _ContextProperty_propertyValue(ctx context.Context,
}
res := resTmp.(graph.Value)
fc.Result = res
return ec.marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐValue(ctx, field.Selections, res)
return ec.marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐValue(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_ContextProperty_propertyValue(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -4187,7 +4187,7 @@ func (ec *executionContext) _ContextType_properties(ctx context.Context, field g
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_ContextType_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -4453,7 +4453,7 @@ func (ec *executionContext) _Event_artifact(ctx context.Context, field graphql.C
}
res := resTmp.(*graph.Artifact)
fc.Result = res
return ec.marshalOArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifact(ctx, field.Selections, res)
return ec.marshalOArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifact(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Event_artifact(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -4516,7 +4516,7 @@ func (ec *executionContext) _Event_execution(ctx context.Context, field graphql.
}
res := resTmp.(*graph.Execution)
fc.Result = res
return ec.marshalOExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecution(ctx, field.Selections, res)
return ec.marshalOExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecution(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Event_execution(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -5102,7 +5102,7 @@ func (ec *executionContext) _Execution_type(ctx context.Context, field graphql.C
}
res := resTmp.(*graph.ExecutionType)
fc.Result = res
return ec.marshalNExecutionType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionType(ctx, field.Selections, res)
return ec.marshalNExecutionType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionType(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Execution_type(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -5163,7 +5163,7 @@ func (ec *executionContext) _Execution_properties(ctx context.Context, field gra
}
res := resTmp.([]*graph.ExecutionProperty)
fc.Result = res
return ec.marshalOExecutionProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionPropertyᚄ(ctx, field.Selections, res)
return ec.marshalOExecutionProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionPropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Execution_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -5346,7 +5346,7 @@ func (ec *executionContext) _ExecutionProperty_propertyValue(ctx context.Context
}
res := resTmp.(graph.Value)
fc.Result = res
return ec.marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐValue(ctx, field.Selections, res)
return ec.marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐValue(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_ExecutionProperty_propertyValue(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -5733,7 +5733,7 @@ func (ec *executionContext) _ExecutionType_properties(ctx context.Context, field
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_ExecutionType_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -6084,7 +6084,7 @@ func (ec *executionContext) _MlmdDataset_properties(ctx context.Context, field g
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdDataset_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -6479,7 +6479,7 @@ func (ec *executionContext) _MlmdDeploy_properties(ctx context.Context, field gr
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdDeploy_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -6874,7 +6874,7 @@ func (ec *executionContext) _MlmdEvaluate_properties(ctx context.Context, field
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdEvaluate_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -7181,7 +7181,7 @@ func (ec *executionContext) _MlmdMetrics_properties(ctx context.Context, field g
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdMetrics_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -7488,7 +7488,7 @@ func (ec *executionContext) _MlmdModel_properties(ctx context.Context, field gra
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdModel_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -7883,7 +7883,7 @@ func (ec *executionContext) _MlmdProcess_properties(ctx context.Context, field g
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdProcess_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -8190,7 +8190,7 @@ func (ec *executionContext) _MlmdStatistics_properties(ctx context.Context, fiel
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdStatistics_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -8585,7 +8585,7 @@ func (ec *executionContext) _MlmdTrain_properties(ctx context.Context, field gra
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdTrain_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -8980,7 +8980,7 @@ func (ec *executionContext) _MlmdTransform_properties(ctx context.Context, field
}
res := resTmp.([]*graph.TypeProperty)
fc.Result = res
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
return ec.marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_MlmdTransform_properties(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9029,7 +9029,7 @@ func (ec *executionContext) _Query_types(ctx context.Context, field graphql.Coll
}
res := resTmp.([]graph.Type)
fc.Result = res
return ec.marshalOType2ᚕgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeᚄ(ctx, field.Selections, res)
return ec.marshalOType2ᚕgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_types(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9081,7 +9081,7 @@ func (ec *executionContext) _Query_artifactTypes(ctx context.Context, field grap
}
res := resTmp.([]*graph.ArtifactType)
fc.Result = res
return ec.marshalOArtifactType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactTypeᚄ(ctx, field.Selections, res)
return ec.marshalOArtifactType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactTypeᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_artifactTypes(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9149,7 +9149,7 @@ func (ec *executionContext) _Query_contextTypes(ctx context.Context, field graph
}
res := resTmp.([]*graph.ContextType)
fc.Result = res
return ec.marshalOContextType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextTypeᚄ(ctx, field.Selections, res)
return ec.marshalOContextType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextTypeᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_contextTypes(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9217,7 +9217,7 @@ func (ec *executionContext) _Query_executionTypes(ctx context.Context, field gra
}
res := resTmp.([]*graph.ExecutionType)
fc.Result = res
return ec.marshalOExecutionType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionTypeᚄ(ctx, field.Selections, res)
return ec.marshalOExecutionType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionTypeᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_executionTypes(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9289,7 +9289,7 @@ func (ec *executionContext) _Query_artifacts(ctx context.Context, field graphql.
}
res := resTmp.([]*graph.Artifact)
fc.Result = res
return ec.marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactᚄ(ctx, field.Selections, res)
return ec.marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_artifacts(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9363,7 +9363,7 @@ func (ec *executionContext) _Query_contexts(ctx context.Context, field graphql.C
}
res := resTmp.([]*graph.Context)
fc.Result = res
return ec.marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextᚄ(ctx, field.Selections, res)
return ec.marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_contexts(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9441,7 +9441,7 @@ func (ec *executionContext) _Query_executions(ctx context.Context, field graphql
}
res := resTmp.([]*graph.Execution)
fc.Result = res
return ec.marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionᚄ(ctx, field.Selections, res)
return ec.marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_executions(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9513,7 +9513,7 @@ func (ec *executionContext) _Query_events(ctx context.Context, field graphql.Col
}
res := resTmp.([]*graph.Event)
fc.Result = res
return ec.marshalOEvent2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐEventᚄ(ctx, field.Selections, res)
return ec.marshalOEvent2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐEventᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_events(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -9570,7 +9570,7 @@ func (ec *executionContext) _Query_mlmdDataset(ctx context.Context, field graphq
}
res := resTmp.([]*graph.MlmdDataset)
fc.Result = res
return ec.marshalOMlmdDataset2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐMlmdDatasetᚄ(ctx, field.Selections, res)
return ec.marshalOMlmdDataset2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐMlmdDatasetᚄ(ctx, field.Selections, res)
}
func (ec *executionContext) fieldContext_Query_mlmdDataset(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) {
@ -14112,7 +14112,7 @@ func (ec *executionContext) ___Type(ctx context.Context, sel ast.SelectionSet, o
// region ***************************** type.gotpl *****************************
func (ec *executionContext) marshalNArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifact(ctx context.Context, sel ast.SelectionSet, v *graph.Artifact) graphql.Marshaler {
func (ec *executionContext) marshalNArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifact(ctx context.Context, sel ast.SelectionSet, v *graph.Artifact) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14122,7 +14122,7 @@ func (ec *executionContext) marshalNArtifact2ᚖgithubᚗcomᚋopendatahubᚑio
return ec._Artifact(ctx, sel, v)
}
func (ec *executionContext) marshalNArtifactProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactProperty(ctx context.Context, sel ast.SelectionSet, v *graph.ArtifactProperty) graphql.Marshaler {
func (ec *executionContext) marshalNArtifactProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactProperty(ctx context.Context, sel ast.SelectionSet, v *graph.ArtifactProperty) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14132,11 +14132,11 @@ func (ec *executionContext) marshalNArtifactProperty2ᚖgithubᚗcomᚋopendatah
return ec._ArtifactProperty(ctx, sel, v)
}
func (ec *executionContext) marshalNArtifactType2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactType(ctx context.Context, sel ast.SelectionSet, v graph.ArtifactType) graphql.Marshaler {
func (ec *executionContext) marshalNArtifactType2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactType(ctx context.Context, sel ast.SelectionSet, v graph.ArtifactType) graphql.Marshaler {
return ec._ArtifactType(ctx, sel, &v)
}
func (ec *executionContext) marshalNArtifactType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactType(ctx context.Context, sel ast.SelectionSet, v *graph.ArtifactType) graphql.Marshaler {
func (ec *executionContext) marshalNArtifactType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactType(ctx context.Context, sel ast.SelectionSet, v *graph.ArtifactType) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14161,7 +14161,7 @@ func (ec *executionContext) marshalNBoolean2bool(ctx context.Context, sel ast.Se
return res
}
func (ec *executionContext) marshalNContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx context.Context, sel ast.SelectionSet, v *graph.Context) graphql.Marshaler {
func (ec *executionContext) marshalNContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx context.Context, sel ast.SelectionSet, v *graph.Context) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14171,7 +14171,7 @@ func (ec *executionContext) marshalNContext2ᚖgithubᚗcomᚋopendatahubᚑio
return ec._Context(ctx, sel, v)
}
func (ec *executionContext) marshalNContextProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextProperty(ctx context.Context, sel ast.SelectionSet, v *graph.ContextProperty) graphql.Marshaler {
func (ec *executionContext) marshalNContextProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextProperty(ctx context.Context, sel ast.SelectionSet, v *graph.ContextProperty) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14181,7 +14181,7 @@ func (ec *executionContext) marshalNContextProperty2ᚖgithubᚗcomᚋopendatahu
return ec._ContextProperty(ctx, sel, v)
}
func (ec *executionContext) marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextType(ctx context.Context, sel ast.SelectionSet, v *graph.ContextType) graphql.Marshaler {
func (ec *executionContext) marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextType(ctx context.Context, sel ast.SelectionSet, v *graph.ContextType) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14191,7 +14191,7 @@ func (ec *executionContext) marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑ
return ec._ContextType(ctx, sel, v)
}
func (ec *executionContext) marshalNEvent2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐEvent(ctx context.Context, sel ast.SelectionSet, v *graph.Event) graphql.Marshaler {
func (ec *executionContext) marshalNEvent2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐEvent(ctx context.Context, sel ast.SelectionSet, v *graph.Event) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14201,7 +14201,7 @@ func (ec *executionContext) marshalNEvent2ᚖgithubᚗcomᚋopendatahubᚑioᚋm
return ec._Event(ctx, sel, v)
}
func (ec *executionContext) marshalNExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecution(ctx context.Context, sel ast.SelectionSet, v *graph.Execution) graphql.Marshaler {
func (ec *executionContext) marshalNExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecution(ctx context.Context, sel ast.SelectionSet, v *graph.Execution) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14211,7 +14211,7 @@ func (ec *executionContext) marshalNExecution2ᚖgithubᚗcomᚋopendatahubᚑio
return ec._Execution(ctx, sel, v)
}
func (ec *executionContext) marshalNExecutionProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionProperty(ctx context.Context, sel ast.SelectionSet, v *graph.ExecutionProperty) graphql.Marshaler {
func (ec *executionContext) marshalNExecutionProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionProperty(ctx context.Context, sel ast.SelectionSet, v *graph.ExecutionProperty) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14221,7 +14221,7 @@ func (ec *executionContext) marshalNExecutionProperty2ᚖgithubᚗcomᚋopendata
return ec._ExecutionProperty(ctx, sel, v)
}
func (ec *executionContext) marshalNExecutionType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionType(ctx context.Context, sel ast.SelectionSet, v *graph.ExecutionType) graphql.Marshaler {
func (ec *executionContext) marshalNExecutionType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionType(ctx context.Context, sel ast.SelectionSet, v *graph.ExecutionType) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14276,7 +14276,7 @@ func (ec *executionContext) marshalNInt2int(ctx context.Context, sel ast.Selecti
return res
}
func (ec *executionContext) marshalNMlmdDataset2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐMlmdDataset(ctx context.Context, sel ast.SelectionSet, v *graph.MlmdDataset) graphql.Marshaler {
func (ec *executionContext) marshalNMlmdDataset2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐMlmdDataset(ctx context.Context, sel ast.SelectionSet, v *graph.MlmdDataset) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14301,7 +14301,7 @@ func (ec *executionContext) marshalNString2string(ctx context.Context, sel ast.S
return res
}
func (ec *executionContext) marshalNType2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐType(ctx context.Context, sel ast.SelectionSet, v graph.Type) graphql.Marshaler {
func (ec *executionContext) marshalNType2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐType(ctx context.Context, sel ast.SelectionSet, v graph.Type) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14311,7 +14311,7 @@ func (ec *executionContext) marshalNType2githubᚗcomᚋopendatahubᚑioᚋmodel
return ec._Type(ctx, sel, v)
}
func (ec *executionContext) marshalNTypeProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeProperty(ctx context.Context, sel ast.SelectionSet, v *graph.TypeProperty) graphql.Marshaler {
func (ec *executionContext) marshalNTypeProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeProperty(ctx context.Context, sel ast.SelectionSet, v *graph.TypeProperty) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14321,7 +14321,7 @@ func (ec *executionContext) marshalNTypeProperty2ᚖgithubᚗcomᚋopendatahub
return ec._TypeProperty(ctx, sel, v)
}
func (ec *executionContext) marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐValue(ctx context.Context, sel ast.SelectionSet, v graph.Value) graphql.Marshaler {
func (ec *executionContext) marshalNValue2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐValue(ctx context.Context, sel ast.SelectionSet, v graph.Value) graphql.Marshaler {
if v == nil {
if !graphql.HasFieldError(ctx, graphql.GetFieldContext(ctx)) {
ec.Errorf(ctx, "the requested element is null which the schema does not allow")
@ -14584,7 +14584,7 @@ func (ec *executionContext) marshalN__TypeKind2string(ctx context.Context, sel a
return res
}
func (ec *executionContext) marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Artifact) graphql.Marshaler {
func (ec *executionContext) marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Artifact) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14611,7 +14611,7 @@ func (ec *executionContext) marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑ
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifact(ctx, sel, v[i])
ret[i] = ec.marshalNArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifact(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14631,14 +14631,14 @@ func (ec *executionContext) marshalOArtifact2ᚕᚖgithubᚗcomᚋopendatahubᚑ
return ret
}
func (ec *executionContext) marshalOArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifact(ctx context.Context, sel ast.SelectionSet, v *graph.Artifact) graphql.Marshaler {
func (ec *executionContext) marshalOArtifact2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifact(ctx context.Context, sel ast.SelectionSet, v *graph.Artifact) graphql.Marshaler {
if v == nil {
return graphql.Null
}
return ec._Artifact(ctx, sel, v)
}
func (ec *executionContext) marshalOArtifactProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactPropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ArtifactProperty) graphql.Marshaler {
func (ec *executionContext) marshalOArtifactProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactPropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ArtifactProperty) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14665,7 +14665,7 @@ func (ec *executionContext) marshalOArtifactProperty2ᚕᚖgithubᚗcomᚋopenda
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNArtifactProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactProperty(ctx, sel, v[i])
ret[i] = ec.marshalNArtifactProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactProperty(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14685,7 +14685,7 @@ func (ec *executionContext) marshalOArtifactProperty2ᚕᚖgithubᚗcomᚋopenda
return ret
}
func (ec *executionContext) marshalOArtifactType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ArtifactType) graphql.Marshaler {
func (ec *executionContext) marshalOArtifactType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ArtifactType) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14712,7 +14712,7 @@ func (ec *executionContext) marshalOArtifactType2ᚕᚖgithubᚗcomᚋopendatahu
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNArtifactType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐArtifactType(ctx, sel, v[i])
ret[i] = ec.marshalNArtifactType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐArtifactType(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14758,7 +14758,7 @@ func (ec *executionContext) marshalOBoolean2ᚖbool(ctx context.Context, sel ast
return res
}
func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx context.Context, sel ast.SelectionSet, v []*graph.Context) graphql.Marshaler {
func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx context.Context, sel ast.SelectionSet, v []*graph.Context) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14785,7 +14785,7 @@ func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑi
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalOContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx, sel, v[i])
ret[i] = ec.marshalOContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14799,7 +14799,7 @@ func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑi
return ret
}
func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Context) graphql.Marshaler {
func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Context) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14826,7 +14826,7 @@ func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑi
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx, sel, v[i])
ret[i] = ec.marshalNContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14846,14 +14846,14 @@ func (ec *executionContext) marshalOContext2ᚕᚖgithubᚗcomᚋopendatahubᚑi
return ret
}
func (ec *executionContext) marshalOContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContext(ctx context.Context, sel ast.SelectionSet, v *graph.Context) graphql.Marshaler {
func (ec *executionContext) marshalOContext2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContext(ctx context.Context, sel ast.SelectionSet, v *graph.Context) graphql.Marshaler {
if v == nil {
return graphql.Null
}
return ec._Context(ctx, sel, v)
}
func (ec *executionContext) marshalOContextProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextPropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ContextProperty) graphql.Marshaler {
func (ec *executionContext) marshalOContextProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextPropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ContextProperty) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14880,7 +14880,7 @@ func (ec *executionContext) marshalOContextProperty2ᚕᚖgithubᚗcomᚋopendat
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNContextProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextProperty(ctx, sel, v[i])
ret[i] = ec.marshalNContextProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextProperty(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14900,7 +14900,7 @@ func (ec *executionContext) marshalOContextProperty2ᚕᚖgithubᚗcomᚋopendat
return ret
}
func (ec *executionContext) marshalOContextType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ContextType) graphql.Marshaler {
func (ec *executionContext) marshalOContextType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ContextType) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14927,7 +14927,7 @@ func (ec *executionContext) marshalOContextType2ᚕᚖgithubᚗcomᚋopendatahub
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐContextType(ctx, sel, v[i])
ret[i] = ec.marshalNContextType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐContextType(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14947,7 +14947,7 @@ func (ec *executionContext) marshalOContextType2ᚕᚖgithubᚗcomᚋopendatahub
return ret
}
func (ec *executionContext) marshalOEvent2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐEventᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Event) graphql.Marshaler {
func (ec *executionContext) marshalOEvent2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐEventᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Event) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -14974,7 +14974,7 @@ func (ec *executionContext) marshalOEvent2ᚕᚖgithubᚗcomᚋopendatahubᚑio
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNEvent2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐEvent(ctx, sel, v[i])
ret[i] = ec.marshalNEvent2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐEvent(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -14994,7 +14994,7 @@ func (ec *executionContext) marshalOEvent2ᚕᚖgithubᚗcomᚋopendatahubᚑio
return ret
}
func (ec *executionContext) marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Execution) graphql.Marshaler {
func (ec *executionContext) marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.Execution) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -15021,7 +15021,7 @@ func (ec *executionContext) marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahub
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecution(ctx, sel, v[i])
ret[i] = ec.marshalNExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecution(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -15041,14 +15041,14 @@ func (ec *executionContext) marshalOExecution2ᚕᚖgithubᚗcomᚋopendatahub
return ret
}
func (ec *executionContext) marshalOExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecution(ctx context.Context, sel ast.SelectionSet, v *graph.Execution) graphql.Marshaler {
func (ec *executionContext) marshalOExecution2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecution(ctx context.Context, sel ast.SelectionSet, v *graph.Execution) graphql.Marshaler {
if v == nil {
return graphql.Null
}
return ec._Execution(ctx, sel, v)
}
func (ec *executionContext) marshalOExecutionProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionPropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ExecutionProperty) graphql.Marshaler {
func (ec *executionContext) marshalOExecutionProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionPropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ExecutionProperty) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -15075,7 +15075,7 @@ func (ec *executionContext) marshalOExecutionProperty2ᚕᚖgithubᚗcomᚋopend
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNExecutionProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionProperty(ctx, sel, v[i])
ret[i] = ec.marshalNExecutionProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionProperty(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -15095,7 +15095,7 @@ func (ec *executionContext) marshalOExecutionProperty2ᚕᚖgithubᚗcomᚋopend
return ret
}
func (ec *executionContext) marshalOExecutionType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ExecutionType) graphql.Marshaler {
func (ec *executionContext) marshalOExecutionType2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.ExecutionType) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -15122,7 +15122,7 @@ func (ec *executionContext) marshalOExecutionType2ᚕᚖgithubᚗcomᚋopendatah
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNExecutionType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐExecutionType(ctx, sel, v[i])
ret[i] = ec.marshalNExecutionType2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐExecutionType(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -15196,7 +15196,7 @@ func (ec *executionContext) marshalOID2ᚖstring(ctx context.Context, sel ast.Se
return res
}
func (ec *executionContext) unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐInstanceFilter(ctx context.Context, v interface{}) (*graph.InstanceFilter, error) {
func (ec *executionContext) unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐInstanceFilter(ctx context.Context, v interface{}) (*graph.InstanceFilter, error) {
if v == nil {
return nil, nil
}
@ -15204,7 +15204,7 @@ func (ec *executionContext) unmarshalOInstanceFilter2ᚖgithubᚗcomᚋopendatah
return &res, graphql.ErrorOnPath(ctx, err)
}
func (ec *executionContext) marshalOMlmdDataset2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐMlmdDatasetᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.MlmdDataset) graphql.Marshaler {
func (ec *executionContext) marshalOMlmdDataset2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐMlmdDatasetᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.MlmdDataset) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -15231,7 +15231,7 @@ func (ec *executionContext) marshalOMlmdDataset2ᚕᚖgithubᚗcomᚋopendatahub
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNMlmdDataset2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐMlmdDataset(ctx, sel, v[i])
ret[i] = ec.marshalNMlmdDataset2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐMlmdDataset(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -15305,7 +15305,7 @@ func (ec *executionContext) marshalOString2ᚖstring(ctx context.Context, sel as
return res
}
func (ec *executionContext) marshalOType2ᚕgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []graph.Type) graphql.Marshaler {
func (ec *executionContext) marshalOType2ᚕgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeᚄ(ctx context.Context, sel ast.SelectionSet, v []graph.Type) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -15332,7 +15332,7 @@ func (ec *executionContext) marshalOType2ᚕgithubᚗcomᚋopendatahubᚑioᚋmo
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNType2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐType(ctx, sel, v[i])
ret[i] = ec.marshalNType2githubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐType(ctx, sel, v[i])
}
if isLen1 {
f(i)
@ -15352,7 +15352,7 @@ func (ec *executionContext) marshalOType2ᚕgithubᚗcomᚋopendatahubᚑioᚋmo
return ret
}
func (ec *executionContext) unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeFilter(ctx context.Context, v interface{}) (*graph.TypeFilter, error) {
func (ec *executionContext) unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeFilter(ctx context.Context, v interface{}) (*graph.TypeFilter, error) {
if v == nil {
return nil, nil
}
@ -15360,7 +15360,7 @@ func (ec *executionContext) unmarshalOTypeFilter2ᚖgithubᚗcomᚋopendatahub
return &res, graphql.ErrorOnPath(ctx, err)
}
func (ec *executionContext) marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypePropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.TypeProperty) graphql.Marshaler {
func (ec *executionContext) marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypePropertyᚄ(ctx context.Context, sel ast.SelectionSet, v []*graph.TypeProperty) graphql.Marshaler {
if v == nil {
return graphql.Null
}
@ -15387,7 +15387,7 @@ func (ec *executionContext) marshalOTypeProperty2ᚕᚖgithubᚗcomᚋopendatahu
if !isLen1 {
defer wg.Done()
}
ret[i] = ec.marshalNTypeProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋpkgᚋmodelᚋgraphᚐTypeProperty(ctx, sel, v[i])
ret[i] = ec.marshalNTypeProperty2ᚖgithubᚗcomᚋopendatahubᚑioᚋmodelᚑregistryᚋinternalᚋmodelᚋgraphᚐTypeProperty(ctx, sel, v[i])
}
if isLen1 {
f(i)

0
pkg/server/graph/resolver.go → internal/server/graph/resolver.go
View File

2
pkg/server/graph/schema.resolvers.go → internal/server/graph/schema.resolvers.go
View File

@ -8,7 +8,7 @@ import (
"context"
"fmt"
"github.com/opendatahub-io/model-registry/pkg/model/graph"
"github.com/opendatahub-io/model-registry/internal/model/graph"
)
// Types is the resolver for the types field.

174
pkg/server/grpc_server.go → internal/server/grpc_server.go
View File

@ -3,8 +3,8 @@ package server
import (
"context"
"fmt"
proto2 "github.com/opendatahub-io/model-registry/pkg/ml_metadata/proto"
db2 "github.com/opendatahub-io/model-registry/pkg/model/db"
"github.com/opendatahub-io/model-registry/internal/ml_metadata/proto"
"github.com/opendatahub-io/model-registry/internal/model/db"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
"gorm.io/gorm"
@ -32,20 +32,20 @@ func (tk TypeKind) String() string {
}
type grpcServer struct {
proto2.UnimplementedMetadataStoreServiceServer
proto.UnimplementedMetadataStoreServiceServer
dbConnection *gorm.DB
}
var _ proto2.MetadataStoreServiceServer = grpcServer{}
var _ proto2.MetadataStoreServiceServer = (*grpcServer)(nil)
var _ proto.MetadataStoreServiceServer = grpcServer{}
var _ proto.MetadataStoreServiceServer = (*grpcServer)(nil)
func NewGrpcServer(dbConnection *gorm.DB) proto2.MetadataStoreServiceServer {
func NewGrpcServer(dbConnection *gorm.DB) proto.MetadataStoreServiceServer {
return &grpcServer{dbConnection: dbConnection}
}
var REQUIRED_TYPE_FIELDS = []string{"name"}
func (g grpcServer) PutArtifactType(ctx context.Context, request *proto2.PutArtifactTypeRequest) (resp *proto2.PutArtifactTypeResponse, err error) {
func (g grpcServer) PutArtifactType(ctx context.Context, request *proto.PutArtifactTypeRequest) (resp *proto.PutArtifactTypeResponse, err error) {
ctx, _ = Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
@ -55,7 +55,7 @@ func (g grpcServer) PutArtifactType(ctx context.Context, request *proto2.PutArti
if err != nil {
return nil, err
}
value := &db2.Type{
value := &db.Type{
Name: *artifactType.Name,
Version: artifactType.Version,
TypeKind: int32(ARTIFACT_TYPE),
@ -67,13 +67,13 @@ func (g grpcServer) PutArtifactType(ctx context.Context, request *proto2.PutArti
return nil, err
}
var typeId = int64(value.ID)
return &proto2.PutArtifactTypeResponse{
return &proto.PutArtifactTypeResponse{
TypeId: &typeId,
}, nil
}
func (g grpcServer) createOrUpdateType(ctx context.Context, value *db2.Type,
properties map[string]proto2.PropertyType) error {
func (g grpcServer) createOrUpdateType(ctx context.Context, value *db.Type,
properties map[string]proto.PropertyType) error {
// TODO handle CanAdd, CanOmit properties from type request
dbConn, _ := FromContext(ctx)
@ -88,7 +88,7 @@ func (g grpcServer) createOrUpdateType(ctx context.Context, value *db2.Type,
return nil
}
func (g grpcServer) PutExecutionType(ctx context.Context, request *proto2.PutExecutionTypeRequest) (resp *proto2.PutExecutionTypeResponse, err error) {
func (g grpcServer) PutExecutionType(ctx context.Context, request *proto.PutExecutionTypeRequest) (resp *proto.PutExecutionTypeResponse, err error) {
ctx, _ = Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
@ -97,7 +97,7 @@ func (g grpcServer) PutExecutionType(ctx context.Context, request *proto2.PutExe
if err != nil {
return nil, err
}
value := &db2.Type{
value := &db.Type{
Name: *executionType.Name,
Version: executionType.Version,
TypeKind: int32(EXECUTION_TYPE),
@ -109,12 +109,12 @@ func (g grpcServer) PutExecutionType(ctx context.Context, request *proto2.PutExe
return nil, err
}
var typeId = int64(value.ID)
return &proto2.PutExecutionTypeResponse{
return &proto.PutExecutionTypeResponse{
TypeId: &typeId,
}, nil
}
func (g grpcServer) PutContextType(ctx context.Context, request *proto2.PutContextTypeRequest) (resp *proto2.PutContextTypeResponse, err error) {
func (g grpcServer) PutContextType(ctx context.Context, request *proto.PutContextTypeRequest) (resp *proto.PutContextTypeResponse, err error) {
ctx, _ = Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
@ -123,7 +123,7 @@ func (g grpcServer) PutContextType(ctx context.Context, request *proto2.PutConte
if err != nil {
return nil, err
}
value := &db2.Type{
value := &db.Type{
Name: *contextType.Name,
Version: contextType.Version,
TypeKind: int32(CONTEXT_TYPE),
@ -138,20 +138,20 @@ func (g grpcServer) PutContextType(ctx context.Context, request *proto2.PutConte
return nil, err
}
var typeId = int64(value.ID)
return &proto2.PutContextTypeResponse{
return &proto.PutContextTypeResponse{
TypeId: &typeId,
}, nil
}
func (g grpcServer) PutTypes(ctx context.Context, request *proto2.PutTypesRequest) (resp *proto2.PutTypesResponse, err error) {
func (g grpcServer) PutTypes(ctx context.Context, request *proto.PutTypesRequest) (resp *proto.PutTypesResponse, err error) {
ctx, _ = Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
response := &proto2.PutTypesResponse{}
response := &proto.PutTypesResponse{}
for _, ar := range request.ArtifactTypes {
var at *proto2.PutArtifactTypeResponse
at, err = g.PutArtifactType(ctx, &proto2.PutArtifactTypeRequest{
var at *proto.PutArtifactTypeResponse
at, err = g.PutArtifactType(ctx, &proto.PutArtifactTypeRequest{
ArtifactType: ar,
CanAddFields: request.CanAddFields,
CanOmitFields: request.CanOmitFields,
@ -163,8 +163,8 @@ func (g grpcServer) PutTypes(ctx context.Context, request *proto2.PutTypesReques
response.ArtifactTypeIds = append(response.ArtifactTypeIds, *at.TypeId)
}
for _, ex := range request.ExecutionTypes {
var er *proto2.PutExecutionTypeResponse
er, err = g.PutExecutionType(ctx, &proto2.PutExecutionTypeRequest{
var er *proto.PutExecutionTypeResponse
er, err = g.PutExecutionType(ctx, &proto.PutExecutionTypeRequest{
ExecutionType: ex,
CanAddFields: request.CanAddFields,
CanOmitFields: request.CanOmitFields,
@ -176,8 +176,8 @@ func (g grpcServer) PutTypes(ctx context.Context, request *proto2.PutTypesReques
response.ExecutionTypeIds = append(response.ExecutionTypeIds, *er.TypeId)
}
for _, ct := range request.ContextTypes {
var cr *proto2.PutContextTypeResponse
cr, err = g.PutContextType(ctx, &proto2.PutContextTypeRequest{
var cr *proto.PutContextTypeResponse
cr, err = g.PutContextType(ctx, &proto.PutContextTypeRequest{
ContextType: ct,
CanAddFields: request.CanAddFields,
CanOmitFields: request.CanOmitFields,
@ -193,7 +193,7 @@ func (g grpcServer) PutTypes(ctx context.Context, request *proto2.PutTypesReques
var REQUIRED_ARTIFACT_FIELDS = []string{"type_id", "uri"}
func (g grpcServer) PutArtifacts(ctx context.Context, request *proto2.PutArtifactsRequest) (resp *proto2.PutArtifactsResponse, err error) {
func (g grpcServer) PutArtifacts(ctx context.Context, request *proto.PutArtifactsRequest) (resp *proto.PutArtifactsResponse, err error) {
ctx, dbConn := Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
@ -203,7 +203,7 @@ func (g grpcServer) PutArtifacts(ctx context.Context, request *proto2.PutArtifac
if err != nil {
return nil, err
}
value := &db2.Artifact{
value := &db.Artifact{
TypeID: *artifact.TypeId,
URI: artifact.Uri,
Name: artifact.Name,
@ -227,243 +227,243 @@ func (g grpcServer) PutArtifacts(ctx context.Context, request *proto2.PutArtifac
}
artifactIds = append(artifactIds, int64(value.ID))
}
resp = &proto2.PutArtifactsResponse{
resp = &proto.PutArtifactsResponse{
ArtifactIds: artifactIds,
}
return resp, nil
}
func (g grpcServer) PutExecutions(ctx context.Context, request *proto2.PutExecutionsRequest) (*proto2.PutExecutionsResponse, error) {
func (g grpcServer) PutExecutions(ctx context.Context, request *proto.PutExecutionsRequest) (*proto.PutExecutionsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) PutEvents(ctx context.Context, request *proto2.PutEventsRequest) (*proto2.PutEventsResponse, error) {
func (g grpcServer) PutEvents(ctx context.Context, request *proto.PutEventsRequest) (*proto.PutEventsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) PutExecution(ctx context.Context, request *proto2.PutExecutionRequest) (*proto2.PutExecutionResponse, error) {
func (g grpcServer) PutExecution(ctx context.Context, request *proto.PutExecutionRequest) (*proto.PutExecutionResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) PutLineageSubgraph(ctx context.Context, request *proto2.PutLineageSubgraphRequest) (*proto2.PutLineageSubgraphResponse, error) {
func (g grpcServer) PutLineageSubgraph(ctx context.Context, request *proto.PutLineageSubgraphRequest) (*proto.PutLineageSubgraphResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) PutContexts(ctx context.Context, request *proto2.PutContextsRequest) (*proto2.PutContextsResponse, error) {
func (g grpcServer) PutContexts(ctx context.Context, request *proto.PutContextsRequest) (*proto.PutContextsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) PutAttributionsAndAssociations(ctx context.Context, request *proto2.PutAttributionsAndAssociationsRequest) (*proto2.PutAttributionsAndAssociationsResponse, error) {
func (g grpcServer) PutAttributionsAndAssociations(ctx context.Context, request *proto.PutAttributionsAndAssociationsRequest) (*proto.PutAttributionsAndAssociationsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) PutParentContexts(ctx context.Context, request *proto2.PutParentContextsRequest) (*proto2.PutParentContextsResponse, error) {
func (g grpcServer) PutParentContexts(ctx context.Context, request *proto.PutParentContextsRequest) (*proto.PutParentContextsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactType(ctx context.Context, request *proto2.GetArtifactTypeRequest) (*proto2.GetArtifactTypeResponse, error) {
func (g grpcServer) GetArtifactType(ctx context.Context, request *proto.GetArtifactTypeRequest) (*proto.GetArtifactTypeResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactTypesByID(ctx context.Context, request *proto2.GetArtifactTypesByIDRequest) (*proto2.GetArtifactTypesByIDResponse, error) {
func (g grpcServer) GetArtifactTypesByID(ctx context.Context, request *proto.GetArtifactTypesByIDRequest) (*proto.GetArtifactTypesByIDResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactTypes(ctx context.Context, request *proto2.GetArtifactTypesRequest) (*proto2.GetArtifactTypesResponse, error) {
func (g grpcServer) GetArtifactTypes(ctx context.Context, request *proto.GetArtifactTypesRequest) (*proto.GetArtifactTypesResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionType(ctx context.Context, request *proto2.GetExecutionTypeRequest) (*proto2.GetExecutionTypeResponse, error) {
func (g grpcServer) GetExecutionType(ctx context.Context, request *proto.GetExecutionTypeRequest) (*proto.GetExecutionTypeResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionTypesByID(ctx context.Context, request *proto2.GetExecutionTypesByIDRequest) (*proto2.GetExecutionTypesByIDResponse, error) {
func (g grpcServer) GetExecutionTypesByID(ctx context.Context, request *proto.GetExecutionTypesByIDRequest) (*proto.GetExecutionTypesByIDResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionTypes(ctx context.Context, request *proto2.GetExecutionTypesRequest) (*proto2.GetExecutionTypesResponse, error) {
func (g grpcServer) GetExecutionTypes(ctx context.Context, request *proto.GetExecutionTypesRequest) (*proto.GetExecutionTypesResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextType(ctx context.Context, request *proto2.GetContextTypeRequest) (*proto2.GetContextTypeResponse, error) {
func (g grpcServer) GetContextType(ctx context.Context, request *proto.GetContextTypeRequest) (*proto.GetContextTypeResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextTypesByID(ctx context.Context, request *proto2.GetContextTypesByIDRequest) (*proto2.GetContextTypesByIDResponse, error) {
func (g grpcServer) GetContextTypesByID(ctx context.Context, request *proto.GetContextTypesByIDRequest) (*proto.GetContextTypesByIDResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextTypes(ctx context.Context, request *proto2.GetContextTypesRequest) (*proto2.GetContextTypesResponse, error) {
func (g grpcServer) GetContextTypes(ctx context.Context, request *proto.GetContextTypesRequest) (*proto.GetContextTypesResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifacts(ctx context.Context, request *proto2.GetArtifactsRequest) (*proto2.GetArtifactsResponse, error) {
func (g grpcServer) GetArtifacts(ctx context.Context, request *proto.GetArtifactsRequest) (*proto.GetArtifactsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutions(ctx context.Context, request *proto2.GetExecutionsRequest) (*proto2.GetExecutionsResponse, error) {
func (g grpcServer) GetExecutions(ctx context.Context, request *proto.GetExecutionsRequest) (*proto.GetExecutionsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContexts(ctx context.Context, request *proto2.GetContextsRequest) (*proto2.GetContextsResponse, error) {
func (g grpcServer) GetContexts(ctx context.Context, request *proto.GetContextsRequest) (*proto.GetContextsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactsByID(ctx context.Context, request *proto2.GetArtifactsByIDRequest) (*proto2.GetArtifactsByIDResponse, error) {
func (g grpcServer) GetArtifactsByID(ctx context.Context, request *proto.GetArtifactsByIDRequest) (*proto.GetArtifactsByIDResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionsByID(ctx context.Context, request *proto2.GetExecutionsByIDRequest) (*proto2.GetExecutionsByIDResponse, error) {
func (g grpcServer) GetExecutionsByID(ctx context.Context, request *proto.GetExecutionsByIDRequest) (*proto.GetExecutionsByIDResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextsByID(ctx context.Context, request *proto2.GetContextsByIDRequest) (*proto2.GetContextsByIDResponse, error) {
func (g grpcServer) GetContextsByID(ctx context.Context, request *proto.GetContextsByIDRequest) (*proto.GetContextsByIDResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactsByType(ctx context.Context, request *proto2.GetArtifactsByTypeRequest) (*proto2.GetArtifactsByTypeResponse, error) {
func (g grpcServer) GetArtifactsByType(ctx context.Context, request *proto.GetArtifactsByTypeRequest) (*proto.GetArtifactsByTypeResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionsByType(ctx context.Context, request *proto2.GetExecutionsByTypeRequest) (*proto2.GetExecutionsByTypeResponse, error) {
func (g grpcServer) GetExecutionsByType(ctx context.Context, request *proto.GetExecutionsByTypeRequest) (*proto.GetExecutionsByTypeResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextsByType(ctx context.Context, request *proto2.GetContextsByTypeRequest) (*proto2.GetContextsByTypeResponse, error) {
func (g grpcServer) GetContextsByType(ctx context.Context, request *proto.GetContextsByTypeRequest) (*proto.GetContextsByTypeResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactByTypeAndName(ctx context.Context, request *proto2.GetArtifactByTypeAndNameRequest) (*proto2.GetArtifactByTypeAndNameResponse, error) {
func (g grpcServer) GetArtifactByTypeAndName(ctx context.Context, request *proto.GetArtifactByTypeAndNameRequest) (*proto.GetArtifactByTypeAndNameResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionByTypeAndName(ctx context.Context, request *proto2.GetExecutionByTypeAndNameRequest) (*proto2.GetExecutionByTypeAndNameResponse, error) {
func (g grpcServer) GetExecutionByTypeAndName(ctx context.Context, request *proto.GetExecutionByTypeAndNameRequest) (*proto.GetExecutionByTypeAndNameResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextByTypeAndName(ctx context.Context, request *proto2.GetContextByTypeAndNameRequest) (*proto2.GetContextByTypeAndNameResponse, error) {
func (g grpcServer) GetContextByTypeAndName(ctx context.Context, request *proto.GetContextByTypeAndNameRequest) (*proto.GetContextByTypeAndNameResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactsByURI(ctx context.Context, request *proto2.GetArtifactsByURIRequest) (*proto2.GetArtifactsByURIResponse, error) {
func (g grpcServer) GetArtifactsByURI(ctx context.Context, request *proto.GetArtifactsByURIRequest) (*proto.GetArtifactsByURIResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetEventsByExecutionIDs(ctx context.Context, request *proto2.GetEventsByExecutionIDsRequest) (*proto2.GetEventsByExecutionIDsResponse, error) {
func (g grpcServer) GetEventsByExecutionIDs(ctx context.Context, request *proto.GetEventsByExecutionIDsRequest) (*proto.GetEventsByExecutionIDsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetEventsByArtifactIDs(ctx context.Context, request *proto2.GetEventsByArtifactIDsRequest) (*proto2.GetEventsByArtifactIDsResponse, error) {
func (g grpcServer) GetEventsByArtifactIDs(ctx context.Context, request *proto.GetEventsByArtifactIDsRequest) (*proto.GetEventsByArtifactIDsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactsByExternalIds(ctx context.Context, request *proto2.GetArtifactsByExternalIdsRequest) (*proto2.GetArtifactsByExternalIdsResponse, error) {
func (g grpcServer) GetArtifactsByExternalIds(ctx context.Context, request *proto.GetArtifactsByExternalIdsRequest) (*proto.GetArtifactsByExternalIdsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionsByExternalIds(ctx context.Context, request *proto2.GetExecutionsByExternalIdsRequest) (*proto2.GetExecutionsByExternalIdsResponse, error) {
func (g grpcServer) GetExecutionsByExternalIds(ctx context.Context, request *proto.GetExecutionsByExternalIdsRequest) (*proto.GetExecutionsByExternalIdsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextsByExternalIds(ctx context.Context, request *proto2.GetContextsByExternalIdsRequest) (*proto2.GetContextsByExternalIdsResponse, error) {
func (g grpcServer) GetContextsByExternalIds(ctx context.Context, request *proto.GetContextsByExternalIdsRequest) (*proto.GetContextsByExternalIdsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactTypesByExternalIds(ctx context.Context, request *proto2.GetArtifactTypesByExternalIdsRequest) (*proto2.GetArtifactTypesByExternalIdsResponse, error) {
func (g grpcServer) GetArtifactTypesByExternalIds(ctx context.Context, request *proto.GetArtifactTypesByExternalIdsRequest) (*proto.GetArtifactTypesByExternalIdsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionTypesByExternalIds(ctx context.Context, request *proto2.GetExecutionTypesByExternalIdsRequest) (*proto2.GetExecutionTypesByExternalIdsResponse, error) {
func (g grpcServer) GetExecutionTypesByExternalIds(ctx context.Context, request *proto.GetExecutionTypesByExternalIdsRequest) (*proto.GetExecutionTypesByExternalIdsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextTypesByExternalIds(ctx context.Context, request *proto2.GetContextTypesByExternalIdsRequest) (*proto2.GetContextTypesByExternalIdsResponse, error) {
func (g grpcServer) GetContextTypesByExternalIds(ctx context.Context, request *proto.GetContextTypesByExternalIdsRequest) (*proto.GetContextTypesByExternalIdsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextsByArtifact(ctx context.Context, request *proto2.GetContextsByArtifactRequest) (*proto2.GetContextsByArtifactResponse, error) {
func (g grpcServer) GetContextsByArtifact(ctx context.Context, request *proto.GetContextsByArtifactRequest) (*proto.GetContextsByArtifactResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetContextsByExecution(ctx context.Context, request *proto2.GetContextsByExecutionRequest) (*proto2.GetContextsByExecutionResponse, error) {
func (g grpcServer) GetContextsByExecution(ctx context.Context, request *proto.GetContextsByExecutionRequest) (*proto.GetContextsByExecutionResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetParentContextsByContext(ctx context.Context, request *proto2.GetParentContextsByContextRequest) (*proto2.GetParentContextsByContextResponse, error) {
func (g grpcServer) GetParentContextsByContext(ctx context.Context, request *proto.GetParentContextsByContextRequest) (*proto.GetParentContextsByContextResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetChildrenContextsByContext(ctx context.Context, request *proto2.GetChildrenContextsByContextRequest) (*proto2.GetChildrenContextsByContextResponse, error) {
func (g grpcServer) GetChildrenContextsByContext(ctx context.Context, request *proto.GetChildrenContextsByContextRequest) (*proto.GetChildrenContextsByContextResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetParentContextsByContexts(ctx context.Context, request *proto2.GetParentContextsByContextsRequest) (*proto2.GetParentContextsByContextsResponse, error) {
func (g grpcServer) GetParentContextsByContexts(ctx context.Context, request *proto.GetParentContextsByContextsRequest) (*proto.GetParentContextsByContextsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetChildrenContextsByContexts(ctx context.Context, request *proto2.GetChildrenContextsByContextsRequest) (*proto2.GetChildrenContextsByContextsResponse, error) {
func (g grpcServer) GetChildrenContextsByContexts(ctx context.Context, request *proto.GetChildrenContextsByContextsRequest) (*proto.GetChildrenContextsByContextsResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetArtifactsByContext(ctx context.Context, request *proto2.GetArtifactsByContextRequest) (*proto2.GetArtifactsByContextResponse, error) {
func (g grpcServer) GetArtifactsByContext(ctx context.Context, request *proto.GetArtifactsByContextRequest) (*proto.GetArtifactsByContextResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetExecutionsByContext(ctx context.Context, request *proto2.GetExecutionsByContextRequest) (*proto2.GetExecutionsByContextResponse, error) {
func (g grpcServer) GetExecutionsByContext(ctx context.Context, request *proto.GetExecutionsByContextRequest) (*proto.GetExecutionsByContextResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetLineageGraph(ctx context.Context, request *proto2.GetLineageGraphRequest) (*proto2.GetLineageGraphResponse, error) {
func (g grpcServer) GetLineageGraph(ctx context.Context, request *proto.GetLineageGraphRequest) (*proto.GetLineageGraphResponse, error) {
//TODO implement me
panic("implement me")
}
func (g grpcServer) GetLineageSubgraph(ctx context.Context, request *proto2.GetLineageSubgraphRequest) (*proto2.GetLineageSubgraphResponse, error) {
func (g grpcServer) GetLineageSubgraph(ctx context.Context, request *proto.GetLineageSubgraphRequest) (*proto.GetLineageSubgraphResponse, error) {
//TODO implement me
panic("implement me")
}
@ -473,13 +473,13 @@ func (g grpcServer) mustEmbedUnimplementedMetadataStoreServiceServer() {
// implemented to signal that server is extendable
}
func (g grpcServer) createTypeProperties(ctx context.Context, properties map[string]proto2.PropertyType, typeId int64) (err error) {
func (g grpcServer) createTypeProperties(ctx context.Context, properties map[string]proto.PropertyType, typeId int64) (err error) {
ctx, dbConn := Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
for propName, prop := range properties {
number := int32(prop.Number())
property := &db2.TypeProperty{
property := &db.TypeProperty{
TypeID: typeId,
Name: propName,
DataType: number,
@ -493,12 +493,12 @@ func (g grpcServer) createTypeProperties(ctx context.Context, properties map[str
return nil
}
func (g grpcServer) createArtifactProperties(ctx context.Context, artifactId int64, properties map[string]*proto2.Value, isCustomProperty bool) (err error) {
func (g grpcServer) createArtifactProperties(ctx context.Context, artifactId int64, properties map[string]*proto.Value, isCustomProperty bool) (err error) {
ctx, dbConn := Begin(ctx, g.dbConnection)
defer handleTransaction(ctx, &err)
for propName, prop := range properties {
property := &db2.ArtifactProperty{
property := &db.ArtifactProperty{
ArtifactID: artifactId,
Name: propName,
}
@ -506,19 +506,19 @@ func (g grpcServer) createArtifactProperties(ctx context.Context, artifactId int
property.IsCustomProperty = true
}
// TODO handle polymorphic value with null columns
intValue, ok := prop.GetValue().(*proto2.Value_IntValue)
intValue, ok := prop.GetValue().(*proto.Value_IntValue)
if ok {
property.IntValue = &intValue.IntValue
}
doubleValue, ok := prop.GetValue().(*proto2.Value_DoubleValue)
doubleValue, ok := prop.GetValue().(*proto.Value_DoubleValue)
if ok {
property.DoubleValue = &doubleValue.DoubleValue
}
stringValue, ok := prop.GetValue().(*proto2.Value_StringValue)
stringValue, ok := prop.GetValue().(*proto.Value_StringValue)
if ok {
property.StringValue = &stringValue.StringValue
}
structValue, ok := prop.GetValue().(*proto2.Value_StructValue)
structValue, ok := prop.GetValue().(*proto.Value_StructValue)
if ok {
json, err2 := structValue.StructValue.MarshalJSON()
if err2 != nil {
@ -527,11 +527,11 @@ func (g grpcServer) createArtifactProperties(ctx context.Context, artifactId int
}
property.ByteValue = &json
}
protoValue, ok := prop.GetValue().(*proto2.Value_ProtoValue)
protoValue, ok := prop.GetValue().(*proto.Value_ProtoValue)
if ok {
property.ProtoValue = &protoValue.ProtoValue.Value
}
boolValue, ok := prop.GetValue().(*proto2.Value_BoolValue)
boolValue, ok := prop.GetValue().(*proto.Value_BoolValue)
if ok {
property.BoolValue = &boolValue.BoolValue
}
@ -544,7 +544,7 @@ func (g grpcServer) createArtifactProperties(ctx context.Context, artifactId int
}
func identity[T int64 | string](i T) T { return i }
func artifactStateToInt64(i proto2.Artifact_State) *int64 {
func artifactStateToInt64(i proto.Artifact_State) *int64 {
var result = int64(i)
return &result
}
@ -562,7 +562,7 @@ func requiredFields(names []string, args ...interface{}) error {
return nil
}
func nilSafeCopy[D int32 | int64 | *int64 | string, S int64 | proto2.Artifact_State | string](dest *D, src *S, f func(i S) D) {
func nilSafeCopy[D int32 | int64 | *int64 | string, S int64 | proto.Artifact_State | string](dest *D, src *S, f func(i S) D) {
if src != nil {
*dest = f(*src)
}