From 514df37efae24a2e211726164f4eba47a47ccbbb Mon Sep 17 00:00:00 2001 From: nxtcoder17 Date: Wed, 14 Feb 2024 23:45:38 +0530 Subject: [PATCH 1/2] feat: adds graphql API to upgrade kloudite agent helm on tenant cluster --- .../nvim/__http__/infra/clusters.graphql.yml | 8 + .../internal/app/graph/generated/generated.go | 125 ++++++++++++- apps/infra/internal/app/graph/schema.graphqls | 2 + .../internal/app/graph/schema.resolvers.go | 23 ++- apps/infra/internal/domain/api.go | 5 +- apps/infra/internal/domain/clusters.go | 31 +++- apps/message-office/internal/app/app.go | 4 +- .../internal/app/grpc-server.go | 4 +- .../internal/app/internal-grpc-server.go | 13 +- apps/tenant-agent/main.go | 2 +- flake.lock | 6 +- .../rpc/accounts/accounts_grpc.pb.go | 10 +- .../rpc/agent/kubeagent_grpc.pb.go | 10 +- .../kloudlite.io/rpc/auth/auth_grpc.pb.go | 20 ++- .../kloudlite.io/rpc/ci/ci_grpc.pb.go | 15 +- .../kloudlite.io/rpc/comms/comms_grpc.pb.go | 30 ++-- .../rpc/console/console_grpc.pb.go | 25 ++- .../container-registry_grpc.pb.go | 15 +- .../kloudlite.io/rpc/dns/dns_grpc.pb.go | 10 +- .../rpc/finance/finance-infra_grpc.pb.go | 55 +++--- .../rpc/finance/finance_grpc.pb.go | 20 ++- .../kloudlite.io/rpc/iam/iam_grpc.pb.go | 50 ++++-- .../kloudlite.io/rpc/infra/infra_grpc.pb.go | 20 ++- .../kloudlite.io/rpc/jseval/jseval_grpc.pb.go | 10 +- .../message-office-internal.pb.go | 167 ++++++++++++++++-- .../message-office-internal_grpc.pb.go | 47 ++++- grpc-interfaces/message-office-internal.proto | 10 ++ 27 files changed, 596 insertions(+), 141 deletions(-) diff --git a/.tools/nvim/__http__/infra/clusters.graphql.yml b/.tools/nvim/__http__/infra/clusters.graphql.yml index 889a4ebf0..44f0607eb 100644 --- a/.tools/nvim/__http__/infra/clusters.graphql.yml +++ b/.tools/nvim/__http__/infra/clusters.graphql.yml @@ -140,6 +140,14 @@ variables: iamInstanceProfileRole: "EC2StorageAccess" --- +label: Upgrade Helm Kloudlite Agent +query: |+ + mutation Infra_upgradeHelmKloudliteAgent($clusterName: String!) { + infra_upgradeHelmKloudliteAgent(clusterName: $clusterName) + } +variables: + clusterName: "ab-cluster-3" +--- label: Delete Cluster query: |+ diff --git a/apps/infra/internal/app/graph/generated/generated.go b/apps/infra/internal/app/graph/generated/generated.go index ad27988a4..c97f54ba4 100644 --- a/apps/infra/internal/app/graph/generated/generated.go +++ b/apps/infra/internal/app/graph/generated/generated.go @@ -976,6 +976,7 @@ type ComplexityRoot struct { InfraUpdateHelmRelease func(childComplexity int, clusterName string, release entities.HelmRelease) int InfraUpdateNodePool func(childComplexity int, clusterName string, pool entities.NodePool) int InfraUpdateProviderSecret func(childComplexity int, secret entities.CloudProviderSecret) int + InfraUpgradeHelmKloudliteAgent func(childComplexity int, clusterName string) int } Namespace struct { @@ -1272,6 +1273,7 @@ type MutationResolver interface { InfraCreateCluster(ctx context.Context, cluster entities.Cluster) (*entities.Cluster, error) InfraUpdateCluster(ctx context.Context, cluster entities.Cluster) (*entities.Cluster, error) InfraDeleteCluster(ctx context.Context, name string) (bool, error) + InfraUpgradeHelmKloudliteAgent(ctx context.Context, clusterName string) (bool, error) InfraCreateProviderSecret(ctx context.Context, secret entities.CloudProviderSecret) (*entities.CloudProviderSecret, error) InfraUpdateProviderSecret(ctx context.Context, secret entities.CloudProviderSecret) (*entities.CloudProviderSecret, error) InfraDeleteProviderSecret(ctx context.Context, secretName string) (bool, error) @@ -5417,6 +5419,18 @@ func (e *executableSchema) Complexity(typeName, field string, childComplexity in return e.complexity.Mutation.InfraUpdateProviderSecret(childComplexity, args["secret"].(entities.CloudProviderSecret)), true + case "Mutation.infra_upgradeHelmKloudliteAgent": + if e.complexity.Mutation.InfraUpgradeHelmKloudliteAgent == nil { + break + } + + args, err := ec.field_Mutation_infra_upgradeHelmKloudliteAgent_args(context.TODO(), rawArgs) + if err != nil { + return 0, false + } + + return e.complexity.Mutation.InfraUpgradeHelmKloudliteAgent(childComplexity, args["clusterName"].(string)), true + case "Namespace.apiVersion": if e.complexity.Namespace.APIVersion == nil { break @@ -6889,6 +6903,8 @@ type Mutation { infra_deleteCluster(name: String!): Boolean! @isLoggedInAndVerified @hasAccount # infra_resyncCluster(name: String!): Boolean! @isLoggedInAndVerified @hasAccount + infra_upgradeHelmKloudliteAgent(clusterName: String!): Boolean! @isLoggedInAndVerified @hasAccount + infra_createProviderSecret(secret: CloudProviderSecretIn!): CloudProviderSecret @isLoggedInAndVerified @hasAccount infra_updateProviderSecret(secret: CloudProviderSecretIn!): CloudProviderSecret @isLoggedInAndVerified @hasAccount infra_deleteProviderSecret(secretName: String!): Boolean! @isLoggedInAndVerified @hasAccount @@ -9140,6 +9156,21 @@ func (ec *executionContext) field_Mutation_infra_updateProviderSecret_args(ctx c return args, nil } +func (ec *executionContext) field_Mutation_infra_upgradeHelmKloudliteAgent_args(ctx context.Context, rawArgs map[string]interface{}) (map[string]interface{}, error) { + var err error + args := map[string]interface{}{} + var arg0 string + if tmp, ok := rawArgs["clusterName"]; ok { + ctx := graphql.WithPathContext(ctx, graphql.NewPathWithField("clusterName")) + arg0, err = ec.unmarshalNString2string(ctx, tmp) + if err != nil { + return nil, err + } + } + args["clusterName"] = arg0 + return args, nil +} + func (ec *executionContext) field_Query___type_args(ctx context.Context, rawArgs map[string]interface{}) (map[string]interface{}, error) { var err error args := map[string]interface{}{} @@ -34353,6 +34384,87 @@ func (ec *executionContext) fieldContext_Mutation_infra_deleteCluster(ctx contex return fc, nil } +func (ec *executionContext) _Mutation_infra_upgradeHelmKloudliteAgent(ctx context.Context, field graphql.CollectedField) (ret graphql.Marshaler) { + fc, err := ec.fieldContext_Mutation_infra_upgradeHelmKloudliteAgent(ctx, field) + if err != nil { + return graphql.Null + } + ctx = graphql.WithFieldContext(ctx, fc) + defer func() { + if r := recover(); r != nil { + ec.Error(ctx, ec.Recover(ctx, r)) + ret = graphql.Null + } + }() + resTmp, err := ec.ResolverMiddleware(ctx, func(rctx context.Context) (interface{}, error) { + directive0 := func(rctx context.Context) (interface{}, error) { + ctx = rctx // use context from middleware stack in children + return ec.resolvers.Mutation().InfraUpgradeHelmKloudliteAgent(rctx, fc.Args["clusterName"].(string)) + } + directive1 := func(ctx context.Context) (interface{}, error) { + if ec.directives.IsLoggedInAndVerified == nil { + return nil, errors.New("directive isLoggedInAndVerified is not implemented") + } + return ec.directives.IsLoggedInAndVerified(ctx, nil, directive0) + } + directive2 := func(ctx context.Context) (interface{}, error) { + if ec.directives.HasAccount == nil { + return nil, errors.New("directive hasAccount is not implemented") + } + return ec.directives.HasAccount(ctx, nil, directive1) + } + + tmp, err := directive2(rctx) + if err != nil { + return nil, graphql.ErrorOnPath(ctx, err) + } + if tmp == nil { + return nil, nil + } + if data, ok := tmp.(bool); ok { + return data, nil + } + return nil, fmt.Errorf(`unexpected type %T from directive, should be bool`, tmp) + }) + if err != nil { + ec.Error(ctx, err) + return graphql.Null + } + if resTmp == nil { + if !graphql.HasFieldError(ctx, fc) { + ec.Errorf(ctx, "must not be null") + } + return graphql.Null + } + res := resTmp.(bool) + fc.Result = res + return ec.marshalNBoolean2bool(ctx, field.Selections, res) +} + +func (ec *executionContext) fieldContext_Mutation_infra_upgradeHelmKloudliteAgent(ctx context.Context, field graphql.CollectedField) (fc *graphql.FieldContext, err error) { + fc = &graphql.FieldContext{ + Object: "Mutation", + Field: field, + IsMethod: true, + IsResolver: true, + Child: func(ctx context.Context, field graphql.CollectedField) (*graphql.FieldContext, error) { + return nil, errors.New("field of type Boolean does not have child fields") + }, + } + defer func() { + if r := recover(); r != nil { + err = ec.Recover(ctx, r) + ec.Error(ctx, err) + } + }() + ctx = graphql.WithFieldContext(ctx, fc) + if fc.Args, err = ec.field_Mutation_infra_upgradeHelmKloudliteAgent_args(ctx, field.ArgumentMap(ec.Variables)); err != nil { + ec.Error(ctx, err) + return + } + return fc, nil +} + func (ec *executionContext) _Mutation_infra_createProviderSecret(ctx context.Context, field graphql.CollectedField) (ret graphql.Marshaler) { fc, err := ec.fieldContext_Mutation_infra_createProviderSecret(ctx, field) if err != nil { @@ -57170,6 +57282,15 @@ func (ec *executionContext) _Mutation(ctx context.Context, sel ast.SelectionSet) return ec._Mutation_infra_deleteCluster(ctx, field) }) + if out.Values[i] == graphql.Null { + invalids++ + } + case "infra_upgradeHelmKloudliteAgent": + + out.Values[i] = ec.OperationContext.RootResolverMiddleware(innerCtx, func(ctx context.Context) (res graphql.Marshaler) { + return ec._Mutation_infra_upgradeHelmKloudliteAgent(ctx, field) + }) + if out.Values[i] == graphql.Null { invalids++ } @@ -61758,7 +61879,7 @@ func (ec *executionContext) marshalN__TypeKind2string(ctx context.Context, sel a return res } -func (ec *executionContext) unmarshalOAny2interface(ctx context.Context, v interface{}) (any, error) { +func (ec *executionContext) unmarshalOAny2interface(ctx context.Context, v interface{}) (interface{}, error) { if v == nil { return nil, nil } @@ -61766,7 +61887,7 @@ func (ec *executionContext) unmarshalOAny2interface(ctx context.Context, v inter return res, graphql.ErrorOnPath(ctx, err) } -func (ec *executionContext) marshalOAny2interface(ctx context.Context, sel ast.SelectionSet, v any) graphql.Marshaler { +func (ec *executionContext) marshalOAny2interface(ctx context.Context, sel ast.SelectionSet, v interface{}) graphql.Marshaler { if v == nil { return graphql.Null } diff --git a/apps/infra/internal/app/graph/schema.graphqls b/apps/infra/internal/app/graph/schema.graphqls index ac2ab170d..cf325fd7d 100644 --- a/apps/infra/internal/app/graph/schema.graphqls +++ b/apps/infra/internal/app/graph/schema.graphqls @@ -118,6 +118,8 @@ type Mutation { infra_deleteCluster(name: String!): Boolean! @isLoggedInAndVerified @hasAccount # infra_resyncCluster(name: String!): Boolean! @isLoggedInAndVerified @hasAccount + infra_upgradeHelmKloudliteAgent(clusterName: String!): Boolean! @isLoggedInAndVerified @hasAccount + infra_createProviderSecret(secret: CloudProviderSecretIn!): CloudProviderSecret @isLoggedInAndVerified @hasAccount infra_updateProviderSecret(secret: CloudProviderSecretIn!): CloudProviderSecret @isLoggedInAndVerified @hasAccount infra_deleteProviderSecret(secretName: String!): Boolean! @isLoggedInAndVerified @hasAccount diff --git a/apps/infra/internal/app/graph/schema.resolvers.go b/apps/infra/internal/app/graph/schema.resolvers.go index 94db030e6..4b205249f 100644 --- a/apps/infra/internal/app/graph/schema.resolvers.go +++ b/apps/infra/internal/app/graph/schema.resolvers.go @@ -7,11 +7,13 @@ package graph import ( "context" "encoding/base64" + + "github.com/kloudlite/api/pkg/errors" + "github.com/kloudlite/api/apps/infra/internal/app/graph/generated" "github.com/kloudlite/api/apps/infra/internal/app/graph/model" "github.com/kloudlite/api/apps/infra/internal/domain" "github.com/kloudlite/api/apps/infra/internal/entities" - "github.com/kloudlite/api/pkg/errors" fn "github.com/kloudlite/api/pkg/functions" "github.com/kloudlite/api/pkg/repos" ) @@ -68,6 +70,19 @@ func (r *mutationResolver) InfraDeleteCluster(ctx context.Context, name string) return true, nil } +// InfraUpgradeHelmKloudliteAgent is the resolver for the infra_upgradeHelmKloudliteAgent field. +func (r *mutationResolver) InfraUpgradeHelmKloudliteAgent(ctx context.Context, clusterName string) (bool, error) { + ictx, err := toInfraContext(ctx) + if err != nil { + return false, errors.NewE(err) + } + if err := r.Domain.UpgradeHelmKloudliteAgent(ictx, clusterName); err != nil { + return false, errors.NewE(err) + } + + return true, nil +} + // InfraCreateProviderSecret is the resolver for the infra_createProviderSecret field. func (r *mutationResolver) InfraCreateProviderSecret(ctx context.Context, secret entities.CloudProviderSecret) (*entities.CloudProviderSecret, error) { ictx, err := toInfraContext(ctx) @@ -843,5 +858,7 @@ func (r *Resolver) Mutation() generated.MutationResolver { return &mutationResol // Query returns generated.QueryResolver implementation. func (r *Resolver) Query() generated.QueryResolver { return &queryResolver{r} } -type mutationResolver struct{ *Resolver } -type queryResolver struct{ *Resolver } +type ( + mutationResolver struct{ *Resolver } + queryResolver struct{ *Resolver } +) diff --git a/apps/infra/internal/domain/api.go b/apps/infra/internal/domain/api.go index 71b513a7d..193d6d5fc 100644 --- a/apps/infra/internal/domain/api.go +++ b/apps/infra/internal/domain/api.go @@ -2,9 +2,10 @@ package domain import ( "context" - networkingv1 "k8s.io/api/networking/v1" "time" + networkingv1 "k8s.io/api/networking/v1" + "github.com/kloudlite/api/apps/infra/internal/entities" "github.com/kloudlite/api/pkg/repos" "github.com/kloudlite/operator/operators/resource-watcher/types" @@ -54,6 +55,8 @@ type Domain interface { UpdateCluster(ctx InfraContext, cluster entities.Cluster) (*entities.Cluster, error) DeleteCluster(ctx InfraContext, name string) error + UpgradeHelmKloudliteAgent(ctx InfraContext, clusterName string) error + ListClusters(ctx InfraContext, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.Cluster], error) GetCluster(ctx InfraContext, name string) (*entities.Cluster, error) diff --git a/apps/infra/internal/domain/clusters.go b/apps/infra/internal/domain/clusters.go index 5b9d1801b..568d5259a 100644 --- a/apps/infra/internal/domain/clusters.go +++ b/apps/infra/internal/domain/clusters.go @@ -261,22 +261,23 @@ func (d *domain) CreateCluster(ctx InfraContext, cluster entities.Cluster) (*ent d.resourceEventPublisher.PublishInfraEvent(ctx, ResourceTypeCluster, nCluster.Name, PublishAdd) - if err := d.applyHelmKloudliteAgent(ctx, nCluster, string(tokenScrt.Data[keyClusterToken])); err != nil { + if err := d.applyHelmKloudliteAgent(ctx, nCluster.Name, string(tokenScrt.Data[keyClusterToken])); err != nil { return nil, errors.NewE(err) } return nCluster, nil } -func (d *domain) applyHelmKloudliteAgent(ctx InfraContext, cluster *entities.Cluster, clusterToken string) error { +func (d *domain) applyHelmKloudliteAgent(ctx InfraContext, clusterName string, clusterToken string) error { b, err := templates.Read(templates.HelmKloudliteAgent) if err != nil { return errors.NewE(err) } b2, err := templates.ParseBytes(b, map[string]any{ - "account-name": ctx.AccountName, - "cluster-name": cluster.Name, + "account-name": ctx.AccountName, + + "cluster-name": clusterName, "cluster-token": clusterToken, "kloudlite-release": d.env.KloudliteRelease, @@ -312,18 +313,34 @@ func (d *domain) applyHelmKloudliteAgent(ctx InfraContext, cluster *entities.Clu }, }, AccountName: ctx.AccountName, - ClusterName: cluster.Name, + ClusterName: clusterName, SyncStatus: t.GenSyncStatus(t.SyncActionApply, 0), } hr.IncrementRecordVersion() - uhr, err := d.upsertHelmRelease(ctx, cluster.Name, &hr) + uhr, err := d.upsertHelmRelease(ctx, clusterName, &hr) + if err != nil { + return errors.NewE(err) + } + + if err := d.resDispatcher.ApplyToTargetCluster(ctx, clusterName, &uhr.HelmChart, uhr.RecordVersion); err != nil { + return errors.NewE(err) + } + + return nil +} + +func (d *domain) UpgradeHelmKloudliteAgent(ctx InfraContext, clusterName string) error { + out, err := d.messageOfficeInternalClient.GetClusterToken(ctx, &message_office_internal.GetClusterTokenIn{ + AccountName: ctx.AccountName, + ClusterName: clusterName, + }) if err != nil { return errors.NewE(err) } - if err := d.resDispatcher.ApplyToTargetCluster(ctx, cluster.Name, &uhr.HelmChart, uhr.RecordVersion); err != nil { + if err := d.applyHelmKloudliteAgent(ctx, clusterName, out.ClusterToken); err != nil { return errors.NewE(err) } diff --git a/apps/message-office/internal/app/app.go b/apps/message-office/internal/app/app.go index 95dedbe3f..79a5a376c 100644 --- a/apps/message-office/internal/app/app.go +++ b/apps/message-office/internal/app/app.go @@ -65,9 +65,7 @@ var Module = fx.Module("app", } }), - fx.Provide(func(d domain.Domain) message_office_internal.MessageOfficeInternalServer { - return newInternalMsgServer(d) - }), + fx.Provide(newInternalMsgServer), fx.Invoke(func(server InternalGrpcServer, internalMsgServer message_office_internal.MessageOfficeInternalServer) { message_office_internal.RegisterMessageOfficeInternalServer(server, internalMsgServer) diff --git a/apps/message-office/internal/app/grpc-server.go b/apps/message-office/internal/app/grpc-server.go index b83c0d47e..daa9b1bf5 100644 --- a/apps/message-office/internal/app/grpc-server.go +++ b/apps/message-office/internal/app/grpc-server.go @@ -283,7 +283,7 @@ func (g *grpcServer) processError(ctx context.Context, accountName string, clust } // GetAccessToken implements messages.MessageDispatchServiceServer -func (g *grpcServer) GetAccessToken(ctx context.Context, msg *messages.GetClusterTokenIn) (*messages.GetClusterTokenOut, error) { +func (g *grpcServer) GetAccessToken(ctx context.Context, msg *messages.GetAccessTokenIn) (*messages.GetAccessTokenOut, error) { g.logger.Infof("request received for cluster-token (%q) exchange", msg.ClusterToken) ct, err := g.domain.GetClusterToken(ctx, msg.AccountName, msg.ClusterName) @@ -297,7 +297,7 @@ func (g *grpcServer) GetAccessToken(ctx context.Context, msg *messages.GetCluste s := encodeAccessToken(msg.AccountName, msg.ClusterName, msg.ClusterToken, g.ev.TokenHashingSecret) g.logger.Infof("SUCCESSFUL cluster-token exchange for account=%q, cluster=%q", msg.ClusterToken, msg.AccountName, msg.ClusterName) - return &messages.GetClusterTokenOut{ + return &messages.GetAccessTokenOut{ AccessToken: s, }, nil } diff --git a/apps/message-office/internal/app/internal-grpc-server.go b/apps/message-office/internal/app/internal-grpc-server.go index 75e0e1936..66b9d7d5c 100644 --- a/apps/message-office/internal/app/internal-grpc-server.go +++ b/apps/message-office/internal/app/internal-grpc-server.go @@ -2,6 +2,7 @@ package app import ( "context" + "github.com/kloudlite/api/apps/message-office/internal/domain" "github.com/kloudlite/api/grpc-interfaces/kloudlite.io/rpc/message-office-internal" "github.com/kloudlite/api/pkg/errors" @@ -22,6 +23,16 @@ func (s *internalMsgServer) GenerateClusterToken(ctx context.Context, in *messag }, nil } -func newInternalMsgServer(d domain.Domain) *internalMsgServer { +func (s *internalMsgServer) GetClusterToken(ctx context.Context, in *message_office_internal.GetClusterTokenIn) (*message_office_internal.GetClusterTokenOut, error) { + token, err := s.d.GetClusterToken(ctx, in.AccountName, in.ClusterName) + if err != nil { + return nil, errors.NewE(err) + } + return &message_office_internal.GetClusterTokenOut{ + ClusterToken: token, + }, nil +} + +func newInternalMsgServer(d domain.Domain) message_office_internal.MessageOfficeInternalServer { return &internalMsgServer{d: d} } diff --git a/apps/tenant-agent/main.go b/apps/tenant-agent/main.go index 810a8f226..6becc00e6 100644 --- a/apps/tenant-agent/main.go +++ b/apps/tenant-agent/main.go @@ -172,7 +172,7 @@ func (g *grpcHandler) ensureAccessToken() error { return nil } - out, err := g.msgDispatchCli.GetAccessToken(ctx, &messages.GetClusterTokenIn{ + out, err := g.msgDispatchCli.GetAccessToken(ctx, &messages.GetAccessTokenIn{ AccountName: g.ev.AccountName, ClusterName: g.ev.ClusterName, ClusterToken: g.ev.ClusterToken, diff --git a/flake.lock b/flake.lock index db7c35cdb..106858f19 100644 --- a/flake.lock +++ b/flake.lock @@ -19,11 +19,11 @@ }, "nixpkgs": { "locked": { - "lastModified": 1705856552, - "narHash": "sha256-JXfnuEf5Yd6bhMs/uvM67/joxYKoysyE3M2k6T3eWbg=", + "lastModified": 1707689078, + "narHash": "sha256-UUGmRa84ZJHpGZ1WZEBEUOzaPOWG8LZ0yPg1pdDF/yM=", "owner": "nixos", "repo": "nixpkgs", - "rev": "612f97239e2cc474c13c9dafa0df378058c5ad8d", + "rev": "f9d39fb9aff0efee4a3d5f4a6d7c17701d38a1d8", "type": "github" }, "original": { diff --git a/grpc-interfaces/kloudlite.io/rpc/accounts/accounts_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/accounts/accounts_grpc.pb.go index beca1a899..91b0b817c 100644 --- a/grpc-interfaces/kloudlite.io/rpc/accounts/accounts_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/accounts/accounts_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: accounts.proto @@ -18,6 +18,10 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Accounts_GetAccount_FullMethodName = "/Accounts/GetAccount" +) + // AccountsClient is the client API for Accounts service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -35,7 +39,7 @@ func NewAccountsClient(cc grpc.ClientConnInterface) AccountsClient { func (c *accountsClient) GetAccount(ctx context.Context, in *GetAccountIn, opts ...grpc.CallOption) (*GetAccountOut, error) { out := new(GetAccountOut) - err := c.cc.Invoke(ctx, "/Accounts/GetAccount", in, out, opts...) + err := c.cc.Invoke(ctx, Accounts_GetAccount_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -80,7 +84,7 @@ func _Accounts_GetAccount_Handler(srv interface{}, ctx context.Context, dec func } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Accounts/GetAccount", + FullMethod: Accounts_GetAccount_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AccountsServer).GetAccount(ctx, req.(*GetAccountIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/agent/kubeagent_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/agent/kubeagent_grpc.pb.go index 28fa37624..0d761c0bd 100644 --- a/grpc-interfaces/kloudlite.io/rpc/agent/kubeagent_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/agent/kubeagent_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: kubeagent.proto @@ -18,6 +18,10 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + KubeAgent_KubeApply_FullMethodName = "/KubeAgent/KubeApply" +) + // KubeAgentClient is the client API for KubeAgent service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -35,7 +39,7 @@ func NewKubeAgentClient(cc grpc.ClientConnInterface) KubeAgentClient { func (c *kubeAgentClient) KubeApply(ctx context.Context, in *PayloadIn, opts ...grpc.CallOption) (*PayloadOut, error) { out := new(PayloadOut) - err := c.cc.Invoke(ctx, "/KubeAgent/KubeApply", in, out, opts...) + err := c.cc.Invoke(ctx, KubeAgent_KubeApply_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -80,7 +84,7 @@ func _KubeAgent_KubeApply_Handler(srv interface{}, ctx context.Context, dec func } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/KubeAgent/KubeApply", + FullMethod: KubeAgent_KubeApply_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KubeAgentServer).KubeApply(ctx, req.(*PayloadIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/auth/auth_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/auth/auth_grpc.pb.go index 0a3d22c95..d7b047468 100644 --- a/grpc-interfaces/kloudlite.io/rpc/auth/auth_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/auth/auth_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: auth.proto @@ -18,6 +18,12 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Auth_GetAccessToken_FullMethodName = "/Auth/GetAccessToken" + Auth_EnsureUserByEmail_FullMethodName = "/Auth/EnsureUserByEmail" + Auth_GetUser_FullMethodName = "/Auth/GetUser" +) + // AuthClient is the client API for Auth service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -37,7 +43,7 @@ func NewAuthClient(cc grpc.ClientConnInterface) AuthClient { func (c *authClient) GetAccessToken(ctx context.Context, in *GetAccessTokenRequest, opts ...grpc.CallOption) (*AccessTokenOut, error) { out := new(AccessTokenOut) - err := c.cc.Invoke(ctx, "/Auth/GetAccessToken", in, out, opts...) + err := c.cc.Invoke(ctx, Auth_GetAccessToken_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -46,7 +52,7 @@ func (c *authClient) GetAccessToken(ctx context.Context, in *GetAccessTokenReque func (c *authClient) EnsureUserByEmail(ctx context.Context, in *GetUserByEmailRequest, opts ...grpc.CallOption) (*GetUserByEmailOut, error) { out := new(GetUserByEmailOut) - err := c.cc.Invoke(ctx, "/Auth/EnsureUserByEmail", in, out, opts...) + err := c.cc.Invoke(ctx, Auth_EnsureUserByEmail_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -55,7 +61,7 @@ func (c *authClient) EnsureUserByEmail(ctx context.Context, in *GetUserByEmailRe func (c *authClient) GetUser(ctx context.Context, in *GetUserIn, opts ...grpc.CallOption) (*GetUserOut, error) { out := new(GetUserOut) - err := c.cc.Invoke(ctx, "/Auth/GetUser", in, out, opts...) + err := c.cc.Invoke(ctx, Auth_GetUser_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -108,7 +114,7 @@ func _Auth_GetAccessToken_Handler(srv interface{}, ctx context.Context, dec func } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Auth/GetAccessToken", + FullMethod: Auth_GetAccessToken_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AuthServer).GetAccessToken(ctx, req.(*GetAccessTokenRequest)) @@ -126,7 +132,7 @@ func _Auth_EnsureUserByEmail_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Auth/EnsureUserByEmail", + FullMethod: Auth_EnsureUserByEmail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AuthServer).EnsureUserByEmail(ctx, req.(*GetUserByEmailRequest)) @@ -144,7 +150,7 @@ func _Auth_GetUser_Handler(srv interface{}, ctx context.Context, dec func(interf } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Auth/GetUser", + FullMethod: Auth_GetUser_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AuthServer).GetUser(ctx, req.(*GetUserIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/ci/ci_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/ci/ci_grpc.pb.go index 5792f1ea0..aa4fbd339 100644 --- a/grpc-interfaces/kloudlite.io/rpc/ci/ci_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/ci/ci_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: ci.proto @@ -18,6 +18,11 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + CI_CreateHarborProject_FullMethodName = "/CI/CreateHarborProject" + CI_DeleteHarborProject_FullMethodName = "/CI/DeleteHarborProject" +) + // CIClient is the client API for CI service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -36,7 +41,7 @@ func NewCIClient(cc grpc.ClientConnInterface) CIClient { func (c *cIClient) CreateHarborProject(ctx context.Context, in *HarborProjectIn, opts ...grpc.CallOption) (*HarborProjectOut, error) { out := new(HarborProjectOut) - err := c.cc.Invoke(ctx, "/CI/CreateHarborProject", in, out, opts...) + err := c.cc.Invoke(ctx, CI_CreateHarborProject_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -45,7 +50,7 @@ func (c *cIClient) CreateHarborProject(ctx context.Context, in *HarborProjectIn, func (c *cIClient) DeleteHarborProject(ctx context.Context, in *HarborProjectIn, opts ...grpc.CallOption) (*HarborProjectOut, error) { out := new(HarborProjectOut) - err := c.cc.Invoke(ctx, "/CI/DeleteHarborProject", in, out, opts...) + err := c.cc.Invoke(ctx, CI_DeleteHarborProject_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -94,7 +99,7 @@ func _CI_CreateHarborProject_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/CI/CreateHarborProject", + FullMethod: CI_CreateHarborProject_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CIServer).CreateHarborProject(ctx, req.(*HarborProjectIn)) @@ -112,7 +117,7 @@ func _CI_DeleteHarborProject_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/CI/DeleteHarborProject", + FullMethod: CI_DeleteHarborProject_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CIServer).DeleteHarborProject(ctx, req.(*HarborProjectIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/comms/comms_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/comms/comms_grpc.pb.go index 922658e32..68f1c675e 100644 --- a/grpc-interfaces/kloudlite.io/rpc/comms/comms_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/comms/comms_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: comms.proto @@ -18,6 +18,14 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Comms_SendVerificationEmail_FullMethodName = "/Comms/SendVerificationEmail" + Comms_SendPasswordResetEmail_FullMethodName = "/Comms/SendPasswordResetEmail" + Comms_SendAccountMemberInviteEmail_FullMethodName = "/Comms/SendAccountMemberInviteEmail" + Comms_SendProjectMemberInviteEmail_FullMethodName = "/Comms/SendProjectMemberInviteEmail" + Comms_SendWelcomeEmail_FullMethodName = "/Comms/SendWelcomeEmail" +) + // CommsClient is the client API for Comms service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -39,7 +47,7 @@ func NewCommsClient(cc grpc.ClientConnInterface) CommsClient { func (c *commsClient) SendVerificationEmail(ctx context.Context, in *VerificationEmailInput, opts ...grpc.CallOption) (*Void, error) { out := new(Void) - err := c.cc.Invoke(ctx, "/Comms/SendVerificationEmail", in, out, opts...) + err := c.cc.Invoke(ctx, Comms_SendVerificationEmail_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -48,7 +56,7 @@ func (c *commsClient) SendVerificationEmail(ctx context.Context, in *Verificatio func (c *commsClient) SendPasswordResetEmail(ctx context.Context, in *PasswordResetEmailInput, opts ...grpc.CallOption) (*Void, error) { out := new(Void) - err := c.cc.Invoke(ctx, "/Comms/SendPasswordResetEmail", in, out, opts...) + err := c.cc.Invoke(ctx, Comms_SendPasswordResetEmail_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -57,7 +65,7 @@ func (c *commsClient) SendPasswordResetEmail(ctx context.Context, in *PasswordRe func (c *commsClient) SendAccountMemberInviteEmail(ctx context.Context, in *AccountMemberInviteEmailInput, opts ...grpc.CallOption) (*Void, error) { out := new(Void) - err := c.cc.Invoke(ctx, "/Comms/SendAccountMemberInviteEmail", in, out, opts...) + err := c.cc.Invoke(ctx, Comms_SendAccountMemberInviteEmail_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -66,7 +74,7 @@ func (c *commsClient) SendAccountMemberInviteEmail(ctx context.Context, in *Acco func (c *commsClient) SendProjectMemberInviteEmail(ctx context.Context, in *ProjectMemberInviteEmailInput, opts ...grpc.CallOption) (*Void, error) { out := new(Void) - err := c.cc.Invoke(ctx, "/Comms/SendProjectMemberInviteEmail", in, out, opts...) + err := c.cc.Invoke(ctx, Comms_SendProjectMemberInviteEmail_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -75,7 +83,7 @@ func (c *commsClient) SendProjectMemberInviteEmail(ctx context.Context, in *Proj func (c *commsClient) SendWelcomeEmail(ctx context.Context, in *WelcomeEmailInput, opts ...grpc.CallOption) (*Void, error) { out := new(Void) - err := c.cc.Invoke(ctx, "/Comms/SendWelcomeEmail", in, out, opts...) + err := c.cc.Invoke(ctx, Comms_SendWelcomeEmail_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -136,7 +144,7 @@ func _Comms_SendVerificationEmail_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Comms/SendVerificationEmail", + FullMethod: Comms_SendVerificationEmail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CommsServer).SendVerificationEmail(ctx, req.(*VerificationEmailInput)) @@ -154,7 +162,7 @@ func _Comms_SendPasswordResetEmail_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Comms/SendPasswordResetEmail", + FullMethod: Comms_SendPasswordResetEmail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CommsServer).SendPasswordResetEmail(ctx, req.(*PasswordResetEmailInput)) @@ -172,7 +180,7 @@ func _Comms_SendAccountMemberInviteEmail_Handler(srv interface{}, ctx context.Co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Comms/SendAccountMemberInviteEmail", + FullMethod: Comms_SendAccountMemberInviteEmail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CommsServer).SendAccountMemberInviteEmail(ctx, req.(*AccountMemberInviteEmailInput)) @@ -190,7 +198,7 @@ func _Comms_SendProjectMemberInviteEmail_Handler(srv interface{}, ctx context.Co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Comms/SendProjectMemberInviteEmail", + FullMethod: Comms_SendProjectMemberInviteEmail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CommsServer).SendProjectMemberInviteEmail(ctx, req.(*ProjectMemberInviteEmailInput)) @@ -208,7 +216,7 @@ func _Comms_SendWelcomeEmail_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Comms/SendWelcomeEmail", + FullMethod: Comms_SendWelcomeEmail_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(CommsServer).SendWelcomeEmail(ctx, req.(*WelcomeEmailInput)) diff --git a/grpc-interfaces/kloudlite.io/rpc/console/console_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/console/console_grpc.pb.go index 21a48dd8c..d1ae92d93 100644 --- a/grpc-interfaces/kloudlite.io/rpc/console/console_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/console/console_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: console.proto @@ -18,6 +18,13 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Console_GetProjectName_FullMethodName = "/Console/GetProjectName" + Console_GetApp_FullMethodName = "/Console/GetApp" + Console_GetManagedSvc_FullMethodName = "/Console/GetManagedSvc" + Console_SetupAccount_FullMethodName = "/Console/SetupAccount" +) + // ConsoleClient is the client API for Console service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -38,7 +45,7 @@ func NewConsoleClient(cc grpc.ClientConnInterface) ConsoleClient { func (c *consoleClient) GetProjectName(ctx context.Context, in *ProjectIn, opts ...grpc.CallOption) (*ProjectOut, error) { out := new(ProjectOut) - err := c.cc.Invoke(ctx, "/Console/GetProjectName", in, out, opts...) + err := c.cc.Invoke(ctx, Console_GetProjectName_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -47,7 +54,7 @@ func (c *consoleClient) GetProjectName(ctx context.Context, in *ProjectIn, opts func (c *consoleClient) GetApp(ctx context.Context, in *AppIn, opts ...grpc.CallOption) (*AppOut, error) { out := new(AppOut) - err := c.cc.Invoke(ctx, "/Console/GetApp", in, out, opts...) + err := c.cc.Invoke(ctx, Console_GetApp_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -56,7 +63,7 @@ func (c *consoleClient) GetApp(ctx context.Context, in *AppIn, opts ...grpc.Call func (c *consoleClient) GetManagedSvc(ctx context.Context, in *MSvcIn, opts ...grpc.CallOption) (*MSvcOut, error) { out := new(MSvcOut) - err := c.cc.Invoke(ctx, "/Console/GetManagedSvc", in, out, opts...) + err := c.cc.Invoke(ctx, Console_GetManagedSvc_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -65,7 +72,7 @@ func (c *consoleClient) GetManagedSvc(ctx context.Context, in *MSvcIn, opts ...g func (c *consoleClient) SetupAccount(ctx context.Context, in *AccountSetupIn, opts ...grpc.CallOption) (*AccountSetupVoid, error) { out := new(AccountSetupVoid) - err := c.cc.Invoke(ctx, "/Console/SetupAccount", in, out, opts...) + err := c.cc.Invoke(ctx, Console_SetupAccount_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -122,7 +129,7 @@ func _Console_GetProjectName_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Console/GetProjectName", + FullMethod: Console_GetProjectName_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ConsoleServer).GetProjectName(ctx, req.(*ProjectIn)) @@ -140,7 +147,7 @@ func _Console_GetApp_Handler(srv interface{}, ctx context.Context, dec func(inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Console/GetApp", + FullMethod: Console_GetApp_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ConsoleServer).GetApp(ctx, req.(*AppIn)) @@ -158,7 +165,7 @@ func _Console_GetManagedSvc_Handler(srv interface{}, ctx context.Context, dec fu } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Console/GetManagedSvc", + FullMethod: Console_GetManagedSvc_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ConsoleServer).GetManagedSvc(ctx, req.(*MSvcIn)) @@ -176,7 +183,7 @@ func _Console_SetupAccount_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Console/SetupAccount", + FullMethod: Console_SetupAccount_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ConsoleServer).SetupAccount(ctx, req.(*AccountSetupIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/container_registry/container-registry_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/container_registry/container-registry_grpc.pb.go index 5a88a6ba2..d43d00396 100644 --- a/grpc-interfaces/kloudlite.io/rpc/container_registry/container-registry_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/container_registry/container-registry_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: container-registry.proto @@ -18,6 +18,11 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + ContainerRegistry_CreateProjectForAccount_FullMethodName = "/ContainerRegistry/CreateProjectForAccount" + ContainerRegistry_GetSvcCredentials_FullMethodName = "/ContainerRegistry/GetSvcCredentials" +) + // ContainerRegistryClient is the client API for ContainerRegistry service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -36,7 +41,7 @@ func NewContainerRegistryClient(cc grpc.ClientConnInterface) ContainerRegistryCl func (c *containerRegistryClient) CreateProjectForAccount(ctx context.Context, in *CreateProjectIn, opts ...grpc.CallOption) (*CreateProjectOut, error) { out := new(CreateProjectOut) - err := c.cc.Invoke(ctx, "/ContainerRegistry/CreateProjectForAccount", in, out, opts...) + err := c.cc.Invoke(ctx, ContainerRegistry_CreateProjectForAccount_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -45,7 +50,7 @@ func (c *containerRegistryClient) CreateProjectForAccount(ctx context.Context, i func (c *containerRegistryClient) GetSvcCredentials(ctx context.Context, in *GetSvcCredentialsIn, opts ...grpc.CallOption) (*GetSvcCredentialsOut, error) { out := new(GetSvcCredentialsOut) - err := c.cc.Invoke(ctx, "/ContainerRegistry/GetSvcCredentials", in, out, opts...) + err := c.cc.Invoke(ctx, ContainerRegistry_GetSvcCredentials_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -94,7 +99,7 @@ func _ContainerRegistry_CreateProjectForAccount_Handler(srv interface{}, ctx con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/ContainerRegistry/CreateProjectForAccount", + FullMethod: ContainerRegistry_CreateProjectForAccount_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContainerRegistryServer).CreateProjectForAccount(ctx, req.(*CreateProjectIn)) @@ -112,7 +117,7 @@ func _ContainerRegistry_GetSvcCredentials_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/ContainerRegistry/GetSvcCredentials", + FullMethod: ContainerRegistry_GetSvcCredentials_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContainerRegistryServer).GetSvcCredentials(ctx, req.(*GetSvcCredentialsIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/dns/dns_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/dns/dns_grpc.pb.go index 1ca73d5a7..079d66d82 100644 --- a/grpc-interfaces/kloudlite.io/rpc/dns/dns_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/dns/dns_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: dns.proto @@ -18,6 +18,10 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + DNS_GetAccountDomains_FullMethodName = "/DNS/GetAccountDomains" +) + // DNSClient is the client API for DNS service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -35,7 +39,7 @@ func NewDNSClient(cc grpc.ClientConnInterface) DNSClient { func (c *dNSClient) GetAccountDomains(ctx context.Context, in *GetAccountDomainsIn, opts ...grpc.CallOption) (*GetAccountDomainsOut, error) { out := new(GetAccountDomainsOut) - err := c.cc.Invoke(ctx, "/DNS/GetAccountDomains", in, out, opts...) + err := c.cc.Invoke(ctx, DNS_GetAccountDomains_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -80,7 +84,7 @@ func _DNS_GetAccountDomains_Handler(srv interface{}, ctx context.Context, dec fu } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/DNS/GetAccountDomains", + FullMethod: DNS_GetAccountDomains_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(DNSServer).GetAccountDomains(ctx, req.(*GetAccountDomainsIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/finance/finance-infra_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/finance/finance-infra_grpc.pb.go index e5471555c..417b15177 100644 --- a/grpc-interfaces/kloudlite.io/rpc/finance/finance-infra_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/finance/finance-infra_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: finance-infra.proto @@ -18,6 +18,19 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + FinanceInfra_ComputeStart_FullMethodName = "/FinanceInfra/ComputeStart" + FinanceInfra_ComputeEnd_FullMethodName = "/FinanceInfra/ComputeEnd" + FinanceInfra_LambdaStart_FullMethodName = "/FinanceInfra/LambdaStart" + FinanceInfra_LambdaEnd_FullMethodName = "/FinanceInfra/LambdaEnd" + FinanceInfra_BlockStorageStart_FullMethodName = "/FinanceInfra/BlockStorageStart" + FinanceInfra_BlockStorageEnd_FullMethodName = "/FinanceInfra/BlockStorageEnd" + FinanceInfra_ObjectStorageStart_FullMethodName = "/FinanceInfra/ObjectStorageStart" + FinanceInfra_ObjectStorageEnd_FullMethodName = "/FinanceInfra/ObjectStorageEnd" + FinanceInfra_CIStart_FullMethodName = "/FinanceInfra/CIStart" + FinanceInfra_CIEnd_FullMethodName = "/FinanceInfra/CIEnd" +) + // FinanceInfraClient is the client API for FinanceInfra service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -44,7 +57,7 @@ func NewFinanceInfraClient(cc grpc.ClientConnInterface) FinanceInfraClient { func (c *financeInfraClient) ComputeStart(ctx context.Context, in *ComputeStartIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/ComputeStart", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_ComputeStart_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -53,7 +66,7 @@ func (c *financeInfraClient) ComputeStart(ctx context.Context, in *ComputeStartI func (c *financeInfraClient) ComputeEnd(ctx context.Context, in *ComputeEndIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/ComputeEnd", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_ComputeEnd_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -62,7 +75,7 @@ func (c *financeInfraClient) ComputeEnd(ctx context.Context, in *ComputeEndIn, o func (c *financeInfraClient) LambdaStart(ctx context.Context, in *LambdaStartIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/LambdaStart", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_LambdaStart_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -71,7 +84,7 @@ func (c *financeInfraClient) LambdaStart(ctx context.Context, in *LambdaStartIn, func (c *financeInfraClient) LambdaEnd(ctx context.Context, in *LambdaEndIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/LambdaEnd", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_LambdaEnd_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -80,7 +93,7 @@ func (c *financeInfraClient) LambdaEnd(ctx context.Context, in *LambdaEndIn, opt func (c *financeInfraClient) BlockStorageStart(ctx context.Context, in *BlockStorageStartIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/BlockStorageStart", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_BlockStorageStart_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -89,7 +102,7 @@ func (c *financeInfraClient) BlockStorageStart(ctx context.Context, in *BlockSto func (c *financeInfraClient) BlockStorageEnd(ctx context.Context, in *BlockStorageEndIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/BlockStorageEnd", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_BlockStorageEnd_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -98,7 +111,7 @@ func (c *financeInfraClient) BlockStorageEnd(ctx context.Context, in *BlockStora func (c *financeInfraClient) ObjectStorageStart(ctx context.Context, in *ObjectStorageStartIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/ObjectStorageStart", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_ObjectStorageStart_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -107,7 +120,7 @@ func (c *financeInfraClient) ObjectStorageStart(ctx context.Context, in *ObjectS func (c *financeInfraClient) ObjectStorageEnd(ctx context.Context, in *ObjectStorageEndIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/ObjectStorageEnd", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_ObjectStorageEnd_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -116,7 +129,7 @@ func (c *financeInfraClient) ObjectStorageEnd(ctx context.Context, in *ObjectSto func (c *financeInfraClient) CIStart(ctx context.Context, in *CIStartIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/CIStart", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_CIStart_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -125,7 +138,7 @@ func (c *financeInfraClient) CIStart(ctx context.Context, in *CIStartIn, opts .. func (c *financeInfraClient) CIEnd(ctx context.Context, in *CIEndIn, opts ...grpc.CallOption) (*FinanceInfraVoid, error) { out := new(FinanceInfraVoid) - err := c.cc.Invoke(ctx, "/FinanceInfra/CIEnd", in, out, opts...) + err := c.cc.Invoke(ctx, FinanceInfra_CIEnd_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -206,7 +219,7 @@ func _FinanceInfra_ComputeStart_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/ComputeStart", + FullMethod: FinanceInfra_ComputeStart_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).ComputeStart(ctx, req.(*ComputeStartIn)) @@ -224,7 +237,7 @@ func _FinanceInfra_ComputeEnd_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/ComputeEnd", + FullMethod: FinanceInfra_ComputeEnd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).ComputeEnd(ctx, req.(*ComputeEndIn)) @@ -242,7 +255,7 @@ func _FinanceInfra_LambdaStart_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/LambdaStart", + FullMethod: FinanceInfra_LambdaStart_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).LambdaStart(ctx, req.(*LambdaStartIn)) @@ -260,7 +273,7 @@ func _FinanceInfra_LambdaEnd_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/LambdaEnd", + FullMethod: FinanceInfra_LambdaEnd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).LambdaEnd(ctx, req.(*LambdaEndIn)) @@ -278,7 +291,7 @@ func _FinanceInfra_BlockStorageStart_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/BlockStorageStart", + FullMethod: FinanceInfra_BlockStorageStart_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).BlockStorageStart(ctx, req.(*BlockStorageStartIn)) @@ -296,7 +309,7 @@ func _FinanceInfra_BlockStorageEnd_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/BlockStorageEnd", + FullMethod: FinanceInfra_BlockStorageEnd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).BlockStorageEnd(ctx, req.(*BlockStorageEndIn)) @@ -314,7 +327,7 @@ func _FinanceInfra_ObjectStorageStart_Handler(srv interface{}, ctx context.Conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/ObjectStorageStart", + FullMethod: FinanceInfra_ObjectStorageStart_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).ObjectStorageStart(ctx, req.(*ObjectStorageStartIn)) @@ -332,7 +345,7 @@ func _FinanceInfra_ObjectStorageEnd_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/ObjectStorageEnd", + FullMethod: FinanceInfra_ObjectStorageEnd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).ObjectStorageEnd(ctx, req.(*ObjectStorageEndIn)) @@ -350,7 +363,7 @@ func _FinanceInfra_CIStart_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/CIStart", + FullMethod: FinanceInfra_CIStart_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).CIStart(ctx, req.(*CIStartIn)) @@ -368,7 +381,7 @@ func _FinanceInfra_CIEnd_Handler(srv interface{}, ctx context.Context, dec func( } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/FinanceInfra/CIEnd", + FullMethod: FinanceInfra_CIEnd_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceInfraServer).CIEnd(ctx, req.(*CIEndIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/finance/finance_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/finance/finance_grpc.pb.go index a99d8e8b8..61e0d9dd7 100644 --- a/grpc-interfaces/kloudlite.io/rpc/finance/finance_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/finance/finance_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: finance.proto @@ -18,6 +18,12 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Finance_StartBillable_FullMethodName = "/Finance/startBillable" + Finance_StopBillable_FullMethodName = "/Finance/stopBillable" + Finance_GetAttachedCluster_FullMethodName = "/Finance/getAttachedCluster" +) + // FinanceClient is the client API for Finance service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -37,7 +43,7 @@ func NewFinanceClient(cc grpc.ClientConnInterface) FinanceClient { func (c *financeClient) StartBillable(ctx context.Context, in *StartBillableIn, opts ...grpc.CallOption) (*StartBillableOut, error) { out := new(StartBillableOut) - err := c.cc.Invoke(ctx, "/Finance/startBillable", in, out, opts...) + err := c.cc.Invoke(ctx, Finance_StartBillable_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -46,7 +52,7 @@ func (c *financeClient) StartBillable(ctx context.Context, in *StartBillableIn, func (c *financeClient) StopBillable(ctx context.Context, in *StopBillableIn, opts ...grpc.CallOption) (*StopBillableOut, error) { out := new(StopBillableOut) - err := c.cc.Invoke(ctx, "/Finance/stopBillable", in, out, opts...) + err := c.cc.Invoke(ctx, Finance_StopBillable_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -55,7 +61,7 @@ func (c *financeClient) StopBillable(ctx context.Context, in *StopBillableIn, op func (c *financeClient) GetAttachedCluster(ctx context.Context, in *GetAttachedClusterIn, opts ...grpc.CallOption) (*GetAttachedClusterOut, error) { out := new(GetAttachedClusterOut) - err := c.cc.Invoke(ctx, "/Finance/getAttachedCluster", in, out, opts...) + err := c.cc.Invoke(ctx, Finance_GetAttachedCluster_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -108,7 +114,7 @@ func _Finance_StartBillable_Handler(srv interface{}, ctx context.Context, dec fu } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Finance/startBillable", + FullMethod: Finance_StartBillable_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceServer).StartBillable(ctx, req.(*StartBillableIn)) @@ -126,7 +132,7 @@ func _Finance_StopBillable_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Finance/stopBillable", + FullMethod: Finance_StopBillable_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceServer).StopBillable(ctx, req.(*StopBillableIn)) @@ -144,7 +150,7 @@ func _Finance_GetAttachedCluster_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Finance/getAttachedCluster", + FullMethod: Finance_GetAttachedCluster_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(FinanceServer).GetAttachedCluster(ctx, req.(*GetAttachedClusterIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/iam/iam_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/iam/iam_grpc.pb.go index 45fd8cee4..1810941e2 100644 --- a/grpc-interfaces/kloudlite.io/rpc/iam/iam_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/iam/iam_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: iam.proto @@ -18,6 +18,18 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + IAM_Ping_FullMethodName = "/IAM/Ping" + IAM_Can_FullMethodName = "/IAM/Can" + IAM_ListMembershipsForResource_FullMethodName = "/IAM/ListMembershipsForResource" + IAM_ListMembershipsForUser_FullMethodName = "/IAM/ListMembershipsForUser" + IAM_GetMembership_FullMethodName = "/IAM/GetMembership" + IAM_AddMembership_FullMethodName = "/IAM/AddMembership" + IAM_UpdateMembership_FullMethodName = "/IAM/UpdateMembership" + IAM_RemoveMembership_FullMethodName = "/IAM/RemoveMembership" + IAM_RemoveResource_FullMethodName = "/IAM/RemoveResource" +) + // IAMClient is the client API for IAM service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -45,7 +57,7 @@ func NewIAMClient(cc grpc.ClientConnInterface) IAMClient { func (c *iAMClient) Ping(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error) { out := new(Message) - err := c.cc.Invoke(ctx, "/IAM/Ping", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_Ping_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -54,7 +66,7 @@ func (c *iAMClient) Ping(ctx context.Context, in *Message, opts ...grpc.CallOpti func (c *iAMClient) Can(ctx context.Context, in *CanIn, opts ...grpc.CallOption) (*CanOut, error) { out := new(CanOut) - err := c.cc.Invoke(ctx, "/IAM/Can", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_Can_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -63,7 +75,7 @@ func (c *iAMClient) Can(ctx context.Context, in *CanIn, opts ...grpc.CallOption) func (c *iAMClient) ListMembershipsForResource(ctx context.Context, in *MembershipsForResourceIn, opts ...grpc.CallOption) (*ListMembershipsOut, error) { out := new(ListMembershipsOut) - err := c.cc.Invoke(ctx, "/IAM/ListMembershipsForResource", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_ListMembershipsForResource_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -72,7 +84,7 @@ func (c *iAMClient) ListMembershipsForResource(ctx context.Context, in *Membersh func (c *iAMClient) ListMembershipsForUser(ctx context.Context, in *MembershipsForUserIn, opts ...grpc.CallOption) (*ListMembershipsOut, error) { out := new(ListMembershipsOut) - err := c.cc.Invoke(ctx, "/IAM/ListMembershipsForUser", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_ListMembershipsForUser_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -81,7 +93,7 @@ func (c *iAMClient) ListMembershipsForUser(ctx context.Context, in *MembershipsF func (c *iAMClient) GetMembership(ctx context.Context, in *GetMembershipIn, opts ...grpc.CallOption) (*GetMembershipOut, error) { out := new(GetMembershipOut) - err := c.cc.Invoke(ctx, "/IAM/GetMembership", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_GetMembership_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -90,7 +102,7 @@ func (c *iAMClient) GetMembership(ctx context.Context, in *GetMembershipIn, opts func (c *iAMClient) AddMembership(ctx context.Context, in *AddMembershipIn, opts ...grpc.CallOption) (*AddMembershipOut, error) { out := new(AddMembershipOut) - err := c.cc.Invoke(ctx, "/IAM/AddMembership", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_AddMembership_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -99,7 +111,7 @@ func (c *iAMClient) AddMembership(ctx context.Context, in *AddMembershipIn, opts func (c *iAMClient) UpdateMembership(ctx context.Context, in *UpdateMembershipIn, opts ...grpc.CallOption) (*UpdateMembershipOut, error) { out := new(UpdateMembershipOut) - err := c.cc.Invoke(ctx, "/IAM/UpdateMembership", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_UpdateMembership_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -108,7 +120,7 @@ func (c *iAMClient) UpdateMembership(ctx context.Context, in *UpdateMembershipIn func (c *iAMClient) RemoveMembership(ctx context.Context, in *RemoveMembershipIn, opts ...grpc.CallOption) (*RemoveMembershipOut, error) { out := new(RemoveMembershipOut) - err := c.cc.Invoke(ctx, "/IAM/RemoveMembership", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_RemoveMembership_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -117,7 +129,7 @@ func (c *iAMClient) RemoveMembership(ctx context.Context, in *RemoveMembershipIn func (c *iAMClient) RemoveResource(ctx context.Context, in *RemoveResourceIn, opts ...grpc.CallOption) (*RemoveResourceOut, error) { out := new(RemoveResourceOut) - err := c.cc.Invoke(ctx, "/IAM/RemoveResource", in, out, opts...) + err := c.cc.Invoke(ctx, IAM_RemoveResource_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -196,7 +208,7 @@ func _IAM_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{ } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/Ping", + FullMethod: IAM_Ping_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).Ping(ctx, req.(*Message)) @@ -214,7 +226,7 @@ func _IAM_Can_Handler(srv interface{}, ctx context.Context, dec func(interface{} } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/Can", + FullMethod: IAM_Can_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).Can(ctx, req.(*CanIn)) @@ -232,7 +244,7 @@ func _IAM_ListMembershipsForResource_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/ListMembershipsForResource", + FullMethod: IAM_ListMembershipsForResource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).ListMembershipsForResource(ctx, req.(*MembershipsForResourceIn)) @@ -250,7 +262,7 @@ func _IAM_ListMembershipsForUser_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/ListMembershipsForUser", + FullMethod: IAM_ListMembershipsForUser_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).ListMembershipsForUser(ctx, req.(*MembershipsForUserIn)) @@ -268,7 +280,7 @@ func _IAM_GetMembership_Handler(srv interface{}, ctx context.Context, dec func(i } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/GetMembership", + FullMethod: IAM_GetMembership_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).GetMembership(ctx, req.(*GetMembershipIn)) @@ -286,7 +298,7 @@ func _IAM_AddMembership_Handler(srv interface{}, ctx context.Context, dec func(i } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/AddMembership", + FullMethod: IAM_AddMembership_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).AddMembership(ctx, req.(*AddMembershipIn)) @@ -304,7 +316,7 @@ func _IAM_UpdateMembership_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/UpdateMembership", + FullMethod: IAM_UpdateMembership_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).UpdateMembership(ctx, req.(*UpdateMembershipIn)) @@ -322,7 +334,7 @@ func _IAM_RemoveMembership_Handler(srv interface{}, ctx context.Context, dec fun } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/RemoveMembership", + FullMethod: IAM_RemoveMembership_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).RemoveMembership(ctx, req.(*RemoveMembershipIn)) @@ -340,7 +352,7 @@ func _IAM_RemoveResource_Handler(srv interface{}, ctx context.Context, dec func( } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/IAM/RemoveResource", + FullMethod: IAM_RemoveResource_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(IAMServer).RemoveResource(ctx, req.(*RemoveResourceIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/infra/infra_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/infra/infra_grpc.pb.go index 82934340f..db8dcaf50 100644 --- a/grpc-interfaces/kloudlite.io/rpc/infra/infra_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/infra/infra_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: infra.proto @@ -18,6 +18,12 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + Infra_GetCluster_FullMethodName = "/Infra/GetCluster" + Infra_GetNodepool_FullMethodName = "/Infra/GetNodepool" + Infra_ClusterExists_FullMethodName = "/Infra/ClusterExists" +) + // InfraClient is the client API for Infra service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -37,7 +43,7 @@ func NewInfraClient(cc grpc.ClientConnInterface) InfraClient { func (c *infraClient) GetCluster(ctx context.Context, in *GetClusterIn, opts ...grpc.CallOption) (*GetClusterOut, error) { out := new(GetClusterOut) - err := c.cc.Invoke(ctx, "/Infra/GetCluster", in, out, opts...) + err := c.cc.Invoke(ctx, Infra_GetCluster_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -46,7 +52,7 @@ func (c *infraClient) GetCluster(ctx context.Context, in *GetClusterIn, opts ... func (c *infraClient) GetNodepool(ctx context.Context, in *GetNodepoolIn, opts ...grpc.CallOption) (*GetNodepoolOut, error) { out := new(GetNodepoolOut) - err := c.cc.Invoke(ctx, "/Infra/GetNodepool", in, out, opts...) + err := c.cc.Invoke(ctx, Infra_GetNodepool_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -55,7 +61,7 @@ func (c *infraClient) GetNodepool(ctx context.Context, in *GetNodepoolIn, opts . func (c *infraClient) ClusterExists(ctx context.Context, in *ClusterExistsIn, opts ...grpc.CallOption) (*ClusterExistsOut, error) { out := new(ClusterExistsOut) - err := c.cc.Invoke(ctx, "/Infra/ClusterExists", in, out, opts...) + err := c.cc.Invoke(ctx, Infra_ClusterExists_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -108,7 +114,7 @@ func _Infra_GetCluster_Handler(srv interface{}, ctx context.Context, dec func(in } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Infra/GetCluster", + FullMethod: Infra_GetCluster_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(InfraServer).GetCluster(ctx, req.(*GetClusterIn)) @@ -126,7 +132,7 @@ func _Infra_GetNodepool_Handler(srv interface{}, ctx context.Context, dec func(i } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Infra/GetNodepool", + FullMethod: Infra_GetNodepool_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(InfraServer).GetNodepool(ctx, req.(*GetNodepoolIn)) @@ -144,7 +150,7 @@ func _Infra_ClusterExists_Handler(srv interface{}, ctx context.Context, dec func } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/Infra/ClusterExists", + FullMethod: Infra_ClusterExists_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(InfraServer).ClusterExists(ctx, req.(*ClusterExistsIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/jseval/jseval_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/jseval/jseval_grpc.pb.go index f818f1903..8c2cb8221 100644 --- a/grpc-interfaces/kloudlite.io/rpc/jseval/jseval_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/jseval/jseval_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: jseval.proto @@ -18,6 +18,10 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + JSEval_Eval_FullMethodName = "/JSEval/Eval" +) + // JSEvalClient is the client API for JSEval service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -35,7 +39,7 @@ func NewJSEvalClient(cc grpc.ClientConnInterface) JSEvalClient { func (c *jSEvalClient) Eval(ctx context.Context, in *EvalIn, opts ...grpc.CallOption) (*EvalOut, error) { out := new(EvalOut) - err := c.cc.Invoke(ctx, "/JSEval/Eval", in, out, opts...) + err := c.cc.Invoke(ctx, JSEval_Eval_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -80,7 +84,7 @@ func _JSEval_Eval_Handler(srv interface{}, ctx context.Context, dec func(interfa } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/JSEval/Eval", + FullMethod: JSEval_Eval_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(JSEvalServer).Eval(ctx, req.(*EvalIn)) diff --git a/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal.pb.go b/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal.pb.go index c383b612e..d6ce73674 100644 --- a/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal.pb.go @@ -122,6 +122,108 @@ func (x *GenerateClusterTokenOut) GetClusterToken() string { return "" } +type GetClusterTokenIn struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + AccountName string `protobuf:"bytes,1,opt,name=accountName,proto3" json:"accountName,omitempty"` + ClusterName string `protobuf:"bytes,2,opt,name=clusterName,proto3" json:"clusterName,omitempty"` +} + +func (x *GetClusterTokenIn) Reset() { + *x = GetClusterTokenIn{} + if protoimpl.UnsafeEnabled { + mi := &file_message_office_internal_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetClusterTokenIn) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetClusterTokenIn) ProtoMessage() {} + +func (x *GetClusterTokenIn) ProtoReflect() protoreflect.Message { + mi := &file_message_office_internal_proto_msgTypes[2] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetClusterTokenIn.ProtoReflect.Descriptor instead. +func (*GetClusterTokenIn) Descriptor() ([]byte, []int) { + return file_message_office_internal_proto_rawDescGZIP(), []int{2} +} + +func (x *GetClusterTokenIn) GetAccountName() string { + if x != nil { + return x.AccountName + } + return "" +} + +func (x *GetClusterTokenIn) GetClusterName() string { + if x != nil { + return x.ClusterName + } + return "" +} + +type GetClusterTokenOut struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ClusterToken string `protobuf:"bytes,1,opt,name=clusterToken,proto3" json:"clusterToken,omitempty"` +} + +func (x *GetClusterTokenOut) Reset() { + *x = GetClusterTokenOut{} + if protoimpl.UnsafeEnabled { + mi := &file_message_office_internal_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *GetClusterTokenOut) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetClusterTokenOut) ProtoMessage() {} + +func (x *GetClusterTokenOut) ProtoReflect() protoreflect.Message { + mi := &file_message_office_internal_proto_msgTypes[3] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetClusterTokenOut.ProtoReflect.Descriptor instead. +func (*GetClusterTokenOut) Descriptor() ([]byte, []int) { + return file_message_office_internal_proto_rawDescGZIP(), []int{3} +} + +func (x *GetClusterTokenOut) GetClusterToken() string { + if x != nil { + return x.ClusterToken + } + return "" +} + var File_message_office_internal_proto protoreflect.FileDescriptor var file_message_office_internal_proto_rawDesc = []byte{ @@ -136,13 +238,26 @@ var file_message_office_internal_proto_rawDesc = []byte{ 0x17, 0x47, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x4f, 0x75, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, - 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x32, 0x62, 0x0a, 0x15, - 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x4f, 0x66, 0x66, 0x69, 0x63, 0x65, 0x49, 0x6e, 0x74, - 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x12, 0x49, 0x0a, 0x14, 0x47, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, - 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x17, 0x2e, - 0x47, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, - 0x6f, 0x6b, 0x65, 0x6e, 0x49, 0x6e, 0x1a, 0x18, 0x2e, 0x47, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, - 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x4f, 0x75, 0x74, + 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x57, 0x0a, 0x11, + 0x47, 0x65, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x49, + 0x6e, 0x12, 0x20, 0x0a, 0x0b, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x4e, 0x61, 0x6d, 0x65, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x4e, + 0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4e, 0x61, + 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, + 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x38, 0x0a, 0x12, 0x47, 0x65, 0x74, 0x43, 0x6c, 0x75, 0x73, + 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x4f, 0x75, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x63, + 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x0c, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x32, + 0x9e, 0x01, 0x0a, 0x15, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x4f, 0x66, 0x66, 0x69, 0x63, + 0x65, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x12, 0x49, 0x0a, 0x14, 0x47, 0x65, 0x6e, + 0x65, 0x72, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, + 0x6e, 0x12, 0x17, 0x2e, 0x47, 0x65, 0x6e, 0x65, 0x72, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, + 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x49, 0x6e, 0x1a, 0x18, 0x2e, 0x47, 0x65, 0x6e, + 0x65, 0x72, 0x61, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, + 0x6e, 0x4f, 0x75, 0x74, 0x12, 0x3a, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, + 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x12, 0x2e, 0x47, 0x65, 0x74, 0x43, 0x6c, 0x75, + 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x49, 0x6e, 0x1a, 0x13, 0x2e, 0x47, 0x65, + 0x74, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x4f, 0x75, 0x74, 0x42, 0x2a, 0x5a, 0x28, 0x6b, 0x6c, 0x6f, 0x75, 0x64, 0x6c, 0x69, 0x74, 0x65, 0x2e, 0x69, 0x6f, 0x2f, 0x72, 0x70, 0x63, 0x2f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2d, 0x6f, 0x66, 0x66, 0x69, 0x63, 0x65, 0x2d, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x62, 0x06, 0x70, 0x72, @@ -161,16 +276,20 @@ func file_message_office_internal_proto_rawDescGZIP() []byte { return file_message_office_internal_proto_rawDescData } -var file_message_office_internal_proto_msgTypes = make([]protoimpl.MessageInfo, 2) +var file_message_office_internal_proto_msgTypes = make([]protoimpl.MessageInfo, 4) var file_message_office_internal_proto_goTypes = []interface{}{ (*GenerateClusterTokenIn)(nil), // 0: GenerateClusterTokenIn (*GenerateClusterTokenOut)(nil), // 1: GenerateClusterTokenOut + (*GetClusterTokenIn)(nil), // 2: GetClusterTokenIn + (*GetClusterTokenOut)(nil), // 3: GetClusterTokenOut } var file_message_office_internal_proto_depIdxs = []int32{ 0, // 0: MessageOfficeInternal.GenerateClusterToken:input_type -> GenerateClusterTokenIn - 1, // 1: MessageOfficeInternal.GenerateClusterToken:output_type -> GenerateClusterTokenOut - 1, // [1:2] is the sub-list for method output_type - 0, // [0:1] is the sub-list for method input_type + 2, // 1: MessageOfficeInternal.GetClusterToken:input_type -> GetClusterTokenIn + 1, // 2: MessageOfficeInternal.GenerateClusterToken:output_type -> GenerateClusterTokenOut + 3, // 3: MessageOfficeInternal.GetClusterToken:output_type -> GetClusterTokenOut + 2, // [2:4] is the sub-list for method output_type + 0, // [0:2] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name 0, // [0:0] is the sub-list for extension extendee 0, // [0:0] is the sub-list for field type_name @@ -206,6 +325,30 @@ func file_message_office_internal_proto_init() { return nil } } + file_message_office_internal_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetClusterTokenIn); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_message_office_internal_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*GetClusterTokenOut); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } type x struct{} out := protoimpl.TypeBuilder{ @@ -213,7 +356,7 @@ func file_message_office_internal_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_message_office_internal_proto_rawDesc, NumEnums: 0, - NumMessages: 2, + NumMessages: 4, NumExtensions: 0, NumServices: 1, }, diff --git a/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal_grpc.pb.go b/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal_grpc.pb.go index 852eff2a4..bc6c76b18 100644 --- a/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal_grpc.pb.go +++ b/grpc-interfaces/kloudlite.io/rpc/message-office-internal/message-office-internal_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.2.0 +// - protoc-gen-go-grpc v1.3.0 // - protoc v4.24.4 // source: message-office-internal.proto @@ -18,11 +18,17 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + MessageOfficeInternal_GenerateClusterToken_FullMethodName = "/MessageOfficeInternal/GenerateClusterToken" + MessageOfficeInternal_GetClusterToken_FullMethodName = "/MessageOfficeInternal/GetClusterToken" +) + // MessageOfficeInternalClient is the client API for MessageOfficeInternal service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type MessageOfficeInternalClient interface { GenerateClusterToken(ctx context.Context, in *GenerateClusterTokenIn, opts ...grpc.CallOption) (*GenerateClusterTokenOut, error) + GetClusterToken(ctx context.Context, in *GetClusterTokenIn, opts ...grpc.CallOption) (*GetClusterTokenOut, error) } type messageOfficeInternalClient struct { @@ -35,7 +41,16 @@ func NewMessageOfficeInternalClient(cc grpc.ClientConnInterface) MessageOfficeIn func (c *messageOfficeInternalClient) GenerateClusterToken(ctx context.Context, in *GenerateClusterTokenIn, opts ...grpc.CallOption) (*GenerateClusterTokenOut, error) { out := new(GenerateClusterTokenOut) - err := c.cc.Invoke(ctx, "/MessageOfficeInternal/GenerateClusterToken", in, out, opts...) + err := c.cc.Invoke(ctx, MessageOfficeInternal_GenerateClusterToken_FullMethodName, in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *messageOfficeInternalClient) GetClusterToken(ctx context.Context, in *GetClusterTokenIn, opts ...grpc.CallOption) (*GetClusterTokenOut, error) { + out := new(GetClusterTokenOut) + err := c.cc.Invoke(ctx, MessageOfficeInternal_GetClusterToken_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -47,6 +62,7 @@ func (c *messageOfficeInternalClient) GenerateClusterToken(ctx context.Context, // for forward compatibility type MessageOfficeInternalServer interface { GenerateClusterToken(context.Context, *GenerateClusterTokenIn) (*GenerateClusterTokenOut, error) + GetClusterToken(context.Context, *GetClusterTokenIn) (*GetClusterTokenOut, error) mustEmbedUnimplementedMessageOfficeInternalServer() } @@ -57,6 +73,9 @@ type UnimplementedMessageOfficeInternalServer struct { func (UnimplementedMessageOfficeInternalServer) GenerateClusterToken(context.Context, *GenerateClusterTokenIn) (*GenerateClusterTokenOut, error) { return nil, status.Errorf(codes.Unimplemented, "method GenerateClusterToken not implemented") } +func (UnimplementedMessageOfficeInternalServer) GetClusterToken(context.Context, *GetClusterTokenIn) (*GetClusterTokenOut, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetClusterToken not implemented") +} func (UnimplementedMessageOfficeInternalServer) mustEmbedUnimplementedMessageOfficeInternalServer() {} // UnsafeMessageOfficeInternalServer may be embedded to opt out of forward compatibility for this service. @@ -80,7 +99,7 @@ func _MessageOfficeInternal_GenerateClusterToken_Handler(srv interface{}, ctx co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/MessageOfficeInternal/GenerateClusterToken", + FullMethod: MessageOfficeInternal_GenerateClusterToken_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageOfficeInternalServer).GenerateClusterToken(ctx, req.(*GenerateClusterTokenIn)) @@ -88,6 +107,24 @@ func _MessageOfficeInternal_GenerateClusterToken_Handler(srv interface{}, ctx co return interceptor(ctx, in, info, handler) } +func _MessageOfficeInternal_GetClusterToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetClusterTokenIn) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(MessageOfficeInternalServer).GetClusterToken(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: MessageOfficeInternal_GetClusterToken_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(MessageOfficeInternalServer).GetClusterToken(ctx, req.(*GetClusterTokenIn)) + } + return interceptor(ctx, in, info, handler) +} + // MessageOfficeInternal_ServiceDesc is the grpc.ServiceDesc for MessageOfficeInternal service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -99,6 +136,10 @@ var MessageOfficeInternal_ServiceDesc = grpc.ServiceDesc{ MethodName: "GenerateClusterToken", Handler: _MessageOfficeInternal_GenerateClusterToken_Handler, }, + { + MethodName: "GetClusterToken", + Handler: _MessageOfficeInternal_GetClusterToken_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "message-office-internal.proto", diff --git a/grpc-interfaces/message-office-internal.proto b/grpc-interfaces/message-office-internal.proto index 30b10411e..bd9dcb938 100644 --- a/grpc-interfaces/message-office-internal.proto +++ b/grpc-interfaces/message-office-internal.proto @@ -4,6 +4,7 @@ option go_package = "kloudlite.io/rpc/message-office-internal"; service MessageOfficeInternal { rpc GenerateClusterToken(GenerateClusterTokenIn) returns (GenerateClusterTokenOut); + rpc GetClusterToken(GetClusterTokenIn) returns (GetClusterTokenOut); } message GenerateClusterTokenIn { @@ -14,3 +15,12 @@ message GenerateClusterTokenIn { message GenerateClusterTokenOut { string clusterToken = 1; } + +message GetClusterTokenIn { + string accountName = 1; + string clusterName = 2; +} + +message GetClusterTokenOut { + string clusterToken = 1; +} From c737c03fc34eb5016849135a265910720443f24e Mon Sep 17 00:00:00 2001 From: nxtcoder17 Date: Wed, 14 Feb 2024 23:59:13 +0530 Subject: [PATCH 2/2] chore: updates `github.com/kloudlite/operator` to version `release-v1.0.3` --- go.mod | 2 +- go.sum | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/go.mod b/go.mod index a8106c511..e044c68f9 100644 --- a/go.mod +++ b/go.mod @@ -42,7 +42,7 @@ require ( require ( github.com/kloudlite/container-registry-authorizer v0.0.0-20231021122509-161dc30fde55 - github.com/kloudlite/operator v0.0.0-20240125192852-5c63464fe989 + github.com/kloudlite/operator v1.0.3-0.20240214140630-cabaf59fe3d4 github.com/nats-io/nats.go v1.31.0 github.com/onsi/ginkgo/v2 v2.12.0 github.com/onsi/gomega v1.27.10 diff --git a/go.sum b/go.sum index f917dba56..525be9ff5 100644 --- a/go.sum +++ b/go.sum @@ -168,6 +168,8 @@ github.com/kloudlite/operator v0.0.0-20240124071634-f1e66969c02c h1:oo6k+eLZ8EUL github.com/kloudlite/operator v0.0.0-20240124071634-f1e66969c02c/go.mod h1:eD8xKzwOVtajAglELcEHn2XL4H22ERBLT2uaisA6SzQ= github.com/kloudlite/operator v0.0.0-20240125192852-5c63464fe989 h1:mHshQnMCWiqpHwYn87ARpYRVyN57q0ksOKCM4wXmeHc= github.com/kloudlite/operator v0.0.0-20240125192852-5c63464fe989/go.mod h1:eD8xKzwOVtajAglELcEHn2XL4H22ERBLT2uaisA6SzQ= +github.com/kloudlite/operator v1.0.3-0.20240214140630-cabaf59fe3d4 h1:bpYACb4+ayPc9FQ4kjBLJP6O6uxIW3kLF2tJQXHAnG8= +github.com/kloudlite/operator v1.0.3-0.20240214140630-cabaf59fe3d4/go.mod h1:eD8xKzwOVtajAglELcEHn2XL4H22ERBLT2uaisA6SzQ= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=