| // Licensed to the Apache Software Foundation (ASF) under one or more |
| // contributor license agreements. See the NOTICE file distributed with |
| // this work for additional information regarding copyright ownership. |
| // The ASF licenses this file to You under the Apache License, Version 2.0 |
| // (the "License"); you may not use this file except in compliance with |
| // the License. You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| // Code generated by protoc-gen-connect-go. DO NOT EDIT. |
| // |
| // Source: registry/v1alpha1/repository.proto |
| |
| package registryv1alpha1v1alpha1connect |
| |
| import ( |
| context "context" |
| errors "errors" |
| v1alpha1 "github.com/apache/dubbo-kubernetes/pkg/bufman/gen/proto/go/registry/v1alpha1" |
| connect_go "github.com/bufbuild/connect-go" |
| http "net/http" |
| strings "strings" |
| ) |
| |
| // This is a compile-time assertion to ensure that this generated file and the connect package are |
| // compatible. If you get a compiler error that this constant is not defined, this code was |
| // generated with a version of connect newer than the one compiled into your binary. You can fix the |
| // problem by either regenerating this code with an older version of connect or updating the connect |
| // version compiled into your binary. |
| const _ = connect_go.IsAtLeastVersion1_7_0 |
| |
| const ( |
| // RepositoryServiceName is the fully-qualified name of the RepositoryService service. |
| RepositoryServiceName = "bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService" |
| ) |
| |
| // These constants are the fully-qualified names of the RPCs defined in this package. They're |
| // exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route. |
| // |
| // Note that these are different from the fully-qualified method names used by |
| // google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to |
| // reflection-formatted method names, remove the leading slash and convert the remaining slash to a |
| // period. |
| const ( |
| // RepositoryServiceGetRepositoryProcedure is the fully-qualified name of the RepositoryService's |
| // GetRepository RPC. |
| RepositoryServiceGetRepositoryProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/GetRepository" |
| // RepositoryServiceGetRepositoryByFullNameProcedure is the fully-qualified name of the |
| // RepositoryService's GetRepositoryByFullName RPC. |
| RepositoryServiceGetRepositoryByFullNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/GetRepositoryByFullName" |
| // RepositoryServiceListRepositoriesProcedure is the fully-qualified name of the RepositoryService's |
| // ListRepositories RPC. |
| RepositoryServiceListRepositoriesProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/ListRepositories" |
| // RepositoryServiceListUserRepositoriesProcedure is the fully-qualified name of the |
| // RepositoryService's ListUserRepositories RPC. |
| RepositoryServiceListUserRepositoriesProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/ListUserRepositories" |
| // RepositoryServiceListRepositoriesUserCanAccessProcedure is the fully-qualified name of the |
| // RepositoryService's ListRepositoriesUserCanAccess RPC. |
| RepositoryServiceListRepositoriesUserCanAccessProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/ListRepositoriesUserCanAccess" |
| // RepositoryServiceListOrganizationRepositoriesProcedure is the fully-qualified name of the |
| // RepositoryService's ListOrganizationRepositories RPC. |
| RepositoryServiceListOrganizationRepositoriesProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/ListOrganizationRepositories" |
| // RepositoryServiceCreateRepositoryByFullNameProcedure is the fully-qualified name of the |
| // RepositoryService's CreateRepositoryByFullName RPC. |
| RepositoryServiceCreateRepositoryByFullNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/CreateRepositoryByFullName" |
| // RepositoryServiceDeleteRepositoryProcedure is the fully-qualified name of the RepositoryService's |
| // DeleteRepository RPC. |
| RepositoryServiceDeleteRepositoryProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/DeleteRepository" |
| // RepositoryServiceDeleteRepositoryByFullNameProcedure is the fully-qualified name of the |
| // RepositoryService's DeleteRepositoryByFullName RPC. |
| RepositoryServiceDeleteRepositoryByFullNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/DeleteRepositoryByFullName" |
| // RepositoryServiceDeprecateRepositoryByNameProcedure is the fully-qualified name of the |
| // RepositoryService's DeprecateRepositoryByName RPC. |
| RepositoryServiceDeprecateRepositoryByNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/DeprecateRepositoryByName" |
| // RepositoryServiceUndeprecateRepositoryByNameProcedure is the fully-qualified name of the |
| // RepositoryService's UndeprecateRepositoryByName RPC. |
| RepositoryServiceUndeprecateRepositoryByNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/UndeprecateRepositoryByName" |
| // RepositoryServiceGetRepositoriesByFullNameProcedure is the fully-qualified name of the |
| // RepositoryService's GetRepositoriesByFullName RPC. |
| RepositoryServiceGetRepositoriesByFullNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/GetRepositoriesByFullName" |
| // RepositoryServiceSetRepositoryContributorProcedure is the fully-qualified name of the |
| // RepositoryService's SetRepositoryContributor RPC. |
| RepositoryServiceSetRepositoryContributorProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/SetRepositoryContributor" |
| // RepositoryServiceListRepositoryContributorsProcedure is the fully-qualified name of the |
| // RepositoryService's ListRepositoryContributors RPC. |
| RepositoryServiceListRepositoryContributorsProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/ListRepositoryContributors" |
| // RepositoryServiceGetRepositoryContributorProcedure is the fully-qualified name of the |
| // RepositoryService's GetRepositoryContributor RPC. |
| RepositoryServiceGetRepositoryContributorProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/GetRepositoryContributor" |
| // RepositoryServiceGetRepositorySettingsProcedure is the fully-qualified name of the |
| // RepositoryService's GetRepositorySettings RPC. |
| RepositoryServiceGetRepositorySettingsProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/GetRepositorySettings" |
| // RepositoryServiceUpdateRepositorySettingsByNameProcedure is the fully-qualified name of the |
| // RepositoryService's UpdateRepositorySettingsByName RPC. |
| RepositoryServiceUpdateRepositorySettingsByNameProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/UpdateRepositorySettingsByName" |
| // RepositoryServiceGetRepositoriesMetadataProcedure is the fully-qualified name of the |
| // RepositoryService's GetRepositoriesMetadata RPC. |
| RepositoryServiceGetRepositoriesMetadataProcedure = "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/GetRepositoriesMetadata" |
| ) |
| |
| // RepositoryServiceClient is a client for the |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService service. |
| type RepositoryServiceClient interface { |
| // GetRepository gets a repository by ID. |
| GetRepository(context.Context, *connect_go.Request[v1alpha1.GetRepositoryRequest]) (*connect_go.Response[v1alpha1.GetRepositoryResponse], error) |
| // GetRepositoryByFullName gets a repository by full name. |
| GetRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.GetRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoryByFullNameResponse], error) |
| // ListRepositories lists all repositories. |
| ListRepositories(context.Context, *connect_go.Request[v1alpha1.ListRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesResponse], error) |
| // ListUserRepositories lists all repositories belonging to a user. |
| ListUserRepositories(context.Context, *connect_go.Request[v1alpha1.ListUserRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListUserRepositoriesResponse], error) |
| // ListRepositoriesUserCanAccess lists all repositories a user can access. |
| ListRepositoriesUserCanAccess(context.Context, *connect_go.Request[v1alpha1.ListRepositoriesUserCanAccessRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesUserCanAccessResponse], error) |
| // ListOrganizationRepositories lists all repositories for an organization. |
| ListOrganizationRepositories(context.Context, *connect_go.Request[v1alpha1.ListOrganizationRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListOrganizationRepositoriesResponse], error) |
| // CreateRepositoryByFullName creates a new repository by full name. |
| CreateRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.CreateRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.CreateRepositoryByFullNameResponse], error) |
| // DeleteRepository deletes a repository. |
| DeleteRepository(context.Context, *connect_go.Request[v1alpha1.DeleteRepositoryRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryResponse], error) |
| // DeleteRepositoryByFullName deletes a repository by full name. |
| DeleteRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.DeleteRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryByFullNameResponse], error) |
| // DeprecateRepositoryByName deprecates the repository. |
| DeprecateRepositoryByName(context.Context, *connect_go.Request[v1alpha1.DeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.DeprecateRepositoryByNameResponse], error) |
| // UndeprecateRepositoryByName makes the repository not deprecated and removes any deprecation_message. |
| UndeprecateRepositoryByName(context.Context, *connect_go.Request[v1alpha1.UndeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.UndeprecateRepositoryByNameResponse], error) |
| // GetRepositoriesByFullName gets repositories by full name. Response order is unspecified. |
| // Errors if any of the repositories don't exist or the caller does not have access to any of the repositories. |
| GetRepositoriesByFullName(context.Context, *connect_go.Request[v1alpha1.GetRepositoriesByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesByFullNameResponse], error) |
| // SetRepositoryContributor sets the role of a user in the repository. |
| SetRepositoryContributor(context.Context, *connect_go.Request[v1alpha1.SetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.SetRepositoryContributorResponse], error) |
| // ListRepositoryContributors returns the list of contributors that has an explicit role against the repository. |
| // This does not include users who have implicit roles against the repository, unless they have also been |
| // assigned a role explicitly. |
| ListRepositoryContributors(context.Context, *connect_go.Request[v1alpha1.ListRepositoryContributorsRequest]) (*connect_go.Response[v1alpha1.ListRepositoryContributorsResponse], error) |
| // GetRepositoryContributor returns the contributor information of a user in a repository. |
| GetRepositoryContributor(context.Context, *connect_go.Request[v1alpha1.GetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.GetRepositoryContributorResponse], error) |
| // GetRepositorySettings gets the settings of a repository. |
| GetRepositorySettings(context.Context, *connect_go.Request[v1alpha1.GetRepositorySettingsRequest]) (*connect_go.Response[v1alpha1.GetRepositorySettingsResponse], error) |
| // UpdateRepositorySettingsByName updates the settings of a repository. |
| UpdateRepositorySettingsByName(context.Context, *connect_go.Request[v1alpha1.UpdateRepositorySettingsByNameRequest]) (*connect_go.Response[v1alpha1.UpdateRepositorySettingsByNameResponse], error) |
| // GetRepositoriesMetadata gets the metadata of the repositories in the request, the length of repositories in the |
| // request should match the length of the metadata in the response, and the order of repositories in the response |
| // should match the order of the metadata in the request. |
| GetRepositoriesMetadata(context.Context, *connect_go.Request[v1alpha1.GetRepositoriesMetadataRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesMetadataResponse], error) |
| } |
| |
| // NewRepositoryServiceClient constructs a client for the |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService service. By default, it uses |
| // the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends |
| // uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or |
| // connect.WithGRPCWeb() options. |
| // |
| // The URL supplied here should be the base URL for the Connect or gRPC server (for example, |
| // http://api.acme.com or https://acme.com/grpc). |
| func NewRepositoryServiceClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) RepositoryServiceClient { |
| baseURL = strings.TrimRight(baseURL, "/") |
| return &repositoryServiceClient{ |
| getRepository: connect_go.NewClient[v1alpha1.GetRepositoryRequest, v1alpha1.GetRepositoryResponse]( |
| httpClient, |
| baseURL+RepositoryServiceGetRepositoryProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| getRepositoryByFullName: connect_go.NewClient[v1alpha1.GetRepositoryByFullNameRequest, v1alpha1.GetRepositoryByFullNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceGetRepositoryByFullNameProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| listRepositories: connect_go.NewClient[v1alpha1.ListRepositoriesRequest, v1alpha1.ListRepositoriesResponse]( |
| httpClient, |
| baseURL+RepositoryServiceListRepositoriesProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| listUserRepositories: connect_go.NewClient[v1alpha1.ListUserRepositoriesRequest, v1alpha1.ListUserRepositoriesResponse]( |
| httpClient, |
| baseURL+RepositoryServiceListUserRepositoriesProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| listRepositoriesUserCanAccess: connect_go.NewClient[v1alpha1.ListRepositoriesUserCanAccessRequest, v1alpha1.ListRepositoriesUserCanAccessResponse]( |
| httpClient, |
| baseURL+RepositoryServiceListRepositoriesUserCanAccessProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| listOrganizationRepositories: connect_go.NewClient[v1alpha1.ListOrganizationRepositoriesRequest, v1alpha1.ListOrganizationRepositoriesResponse]( |
| httpClient, |
| baseURL+RepositoryServiceListOrganizationRepositoriesProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| createRepositoryByFullName: connect_go.NewClient[v1alpha1.CreateRepositoryByFullNameRequest, v1alpha1.CreateRepositoryByFullNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceCreateRepositoryByFullNameProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyIdempotent), |
| connect_go.WithClientOptions(opts...), |
| ), |
| deleteRepository: connect_go.NewClient[v1alpha1.DeleteRepositoryRequest, v1alpha1.DeleteRepositoryResponse]( |
| httpClient, |
| baseURL+RepositoryServiceDeleteRepositoryProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyIdempotent), |
| connect_go.WithClientOptions(opts...), |
| ), |
| deleteRepositoryByFullName: connect_go.NewClient[v1alpha1.DeleteRepositoryByFullNameRequest, v1alpha1.DeleteRepositoryByFullNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceDeleteRepositoryByFullNameProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyIdempotent), |
| connect_go.WithClientOptions(opts...), |
| ), |
| deprecateRepositoryByName: connect_go.NewClient[v1alpha1.DeprecateRepositoryByNameRequest, v1alpha1.DeprecateRepositoryByNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceDeprecateRepositoryByNameProcedure, |
| opts..., |
| ), |
| undeprecateRepositoryByName: connect_go.NewClient[v1alpha1.UndeprecateRepositoryByNameRequest, v1alpha1.UndeprecateRepositoryByNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceUndeprecateRepositoryByNameProcedure, |
| opts..., |
| ), |
| getRepositoriesByFullName: connect_go.NewClient[v1alpha1.GetRepositoriesByFullNameRequest, v1alpha1.GetRepositoriesByFullNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceGetRepositoriesByFullNameProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| setRepositoryContributor: connect_go.NewClient[v1alpha1.SetRepositoryContributorRequest, v1alpha1.SetRepositoryContributorResponse]( |
| httpClient, |
| baseURL+RepositoryServiceSetRepositoryContributorProcedure, |
| opts..., |
| ), |
| listRepositoryContributors: connect_go.NewClient[v1alpha1.ListRepositoryContributorsRequest, v1alpha1.ListRepositoryContributorsResponse]( |
| httpClient, |
| baseURL+RepositoryServiceListRepositoryContributorsProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| getRepositoryContributor: connect_go.NewClient[v1alpha1.GetRepositoryContributorRequest, v1alpha1.GetRepositoryContributorResponse]( |
| httpClient, |
| baseURL+RepositoryServiceGetRepositoryContributorProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| getRepositorySettings: connect_go.NewClient[v1alpha1.GetRepositorySettingsRequest, v1alpha1.GetRepositorySettingsResponse]( |
| httpClient, |
| baseURL+RepositoryServiceGetRepositorySettingsProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| updateRepositorySettingsByName: connect_go.NewClient[v1alpha1.UpdateRepositorySettingsByNameRequest, v1alpha1.UpdateRepositorySettingsByNameResponse]( |
| httpClient, |
| baseURL+RepositoryServiceUpdateRepositorySettingsByNameProcedure, |
| opts..., |
| ), |
| getRepositoriesMetadata: connect_go.NewClient[v1alpha1.GetRepositoriesMetadataRequest, v1alpha1.GetRepositoriesMetadataResponse]( |
| httpClient, |
| baseURL+RepositoryServiceGetRepositoriesMetadataProcedure, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithClientOptions(opts...), |
| ), |
| } |
| } |
| |
| // repositoryServiceClient implements RepositoryServiceClient. |
| type repositoryServiceClient struct { |
| getRepository *connect_go.Client[v1alpha1.GetRepositoryRequest, v1alpha1.GetRepositoryResponse] |
| getRepositoryByFullName *connect_go.Client[v1alpha1.GetRepositoryByFullNameRequest, v1alpha1.GetRepositoryByFullNameResponse] |
| listRepositories *connect_go.Client[v1alpha1.ListRepositoriesRequest, v1alpha1.ListRepositoriesResponse] |
| listUserRepositories *connect_go.Client[v1alpha1.ListUserRepositoriesRequest, v1alpha1.ListUserRepositoriesResponse] |
| listRepositoriesUserCanAccess *connect_go.Client[v1alpha1.ListRepositoriesUserCanAccessRequest, v1alpha1.ListRepositoriesUserCanAccessResponse] |
| listOrganizationRepositories *connect_go.Client[v1alpha1.ListOrganizationRepositoriesRequest, v1alpha1.ListOrganizationRepositoriesResponse] |
| createRepositoryByFullName *connect_go.Client[v1alpha1.CreateRepositoryByFullNameRequest, v1alpha1.CreateRepositoryByFullNameResponse] |
| deleteRepository *connect_go.Client[v1alpha1.DeleteRepositoryRequest, v1alpha1.DeleteRepositoryResponse] |
| deleteRepositoryByFullName *connect_go.Client[v1alpha1.DeleteRepositoryByFullNameRequest, v1alpha1.DeleteRepositoryByFullNameResponse] |
| deprecateRepositoryByName *connect_go.Client[v1alpha1.DeprecateRepositoryByNameRequest, v1alpha1.DeprecateRepositoryByNameResponse] |
| undeprecateRepositoryByName *connect_go.Client[v1alpha1.UndeprecateRepositoryByNameRequest, v1alpha1.UndeprecateRepositoryByNameResponse] |
| getRepositoriesByFullName *connect_go.Client[v1alpha1.GetRepositoriesByFullNameRequest, v1alpha1.GetRepositoriesByFullNameResponse] |
| setRepositoryContributor *connect_go.Client[v1alpha1.SetRepositoryContributorRequest, v1alpha1.SetRepositoryContributorResponse] |
| listRepositoryContributors *connect_go.Client[v1alpha1.ListRepositoryContributorsRequest, v1alpha1.ListRepositoryContributorsResponse] |
| getRepositoryContributor *connect_go.Client[v1alpha1.GetRepositoryContributorRequest, v1alpha1.GetRepositoryContributorResponse] |
| getRepositorySettings *connect_go.Client[v1alpha1.GetRepositorySettingsRequest, v1alpha1.GetRepositorySettingsResponse] |
| updateRepositorySettingsByName *connect_go.Client[v1alpha1.UpdateRepositorySettingsByNameRequest, v1alpha1.UpdateRepositorySettingsByNameResponse] |
| getRepositoriesMetadata *connect_go.Client[v1alpha1.GetRepositoriesMetadataRequest, v1alpha1.GetRepositoriesMetadataResponse] |
| } |
| |
| // GetRepository calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepository. |
| func (c *repositoryServiceClient) GetRepository(ctx context.Context, req *connect_go.Request[v1alpha1.GetRepositoryRequest]) (*connect_go.Response[v1alpha1.GetRepositoryResponse], error) { |
| return c.getRepository.CallUnary(ctx, req) |
| } |
| |
| // GetRepositoryByFullName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoryByFullName. |
| func (c *repositoryServiceClient) GetRepositoryByFullName(ctx context.Context, req *connect_go.Request[v1alpha1.GetRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoryByFullNameResponse], error) { |
| return c.getRepositoryByFullName.CallUnary(ctx, req) |
| } |
| |
| // ListRepositories calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListRepositories. |
| func (c *repositoryServiceClient) ListRepositories(ctx context.Context, req *connect_go.Request[v1alpha1.ListRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesResponse], error) { |
| return c.listRepositories.CallUnary(ctx, req) |
| } |
| |
| // ListUserRepositories calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListUserRepositories. |
| func (c *repositoryServiceClient) ListUserRepositories(ctx context.Context, req *connect_go.Request[v1alpha1.ListUserRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListUserRepositoriesResponse], error) { |
| return c.listUserRepositories.CallUnary(ctx, req) |
| } |
| |
| // ListRepositoriesUserCanAccess calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListRepositoriesUserCanAccess. |
| func (c *repositoryServiceClient) ListRepositoriesUserCanAccess(ctx context.Context, req *connect_go.Request[v1alpha1.ListRepositoriesUserCanAccessRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesUserCanAccessResponse], error) { |
| return c.listRepositoriesUserCanAccess.CallUnary(ctx, req) |
| } |
| |
| // ListOrganizationRepositories calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListOrganizationRepositories. |
| func (c *repositoryServiceClient) ListOrganizationRepositories(ctx context.Context, req *connect_go.Request[v1alpha1.ListOrganizationRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListOrganizationRepositoriesResponse], error) { |
| return c.listOrganizationRepositories.CallUnary(ctx, req) |
| } |
| |
| // CreateRepositoryByFullName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.CreateRepositoryByFullName. |
| func (c *repositoryServiceClient) CreateRepositoryByFullName(ctx context.Context, req *connect_go.Request[v1alpha1.CreateRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.CreateRepositoryByFullNameResponse], error) { |
| return c.createRepositoryByFullName.CallUnary(ctx, req) |
| } |
| |
| // DeleteRepository calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.DeleteRepository. |
| func (c *repositoryServiceClient) DeleteRepository(ctx context.Context, req *connect_go.Request[v1alpha1.DeleteRepositoryRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryResponse], error) { |
| return c.deleteRepository.CallUnary(ctx, req) |
| } |
| |
| // DeleteRepositoryByFullName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.DeleteRepositoryByFullName. |
| func (c *repositoryServiceClient) DeleteRepositoryByFullName(ctx context.Context, req *connect_go.Request[v1alpha1.DeleteRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryByFullNameResponse], error) { |
| return c.deleteRepositoryByFullName.CallUnary(ctx, req) |
| } |
| |
| // DeprecateRepositoryByName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.DeprecateRepositoryByName. |
| func (c *repositoryServiceClient) DeprecateRepositoryByName(ctx context.Context, req *connect_go.Request[v1alpha1.DeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.DeprecateRepositoryByNameResponse], error) { |
| return c.deprecateRepositoryByName.CallUnary(ctx, req) |
| } |
| |
| // UndeprecateRepositoryByName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.UndeprecateRepositoryByName. |
| func (c *repositoryServiceClient) UndeprecateRepositoryByName(ctx context.Context, req *connect_go.Request[v1alpha1.UndeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.UndeprecateRepositoryByNameResponse], error) { |
| return c.undeprecateRepositoryByName.CallUnary(ctx, req) |
| } |
| |
| // GetRepositoriesByFullName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoriesByFullName. |
| func (c *repositoryServiceClient) GetRepositoriesByFullName(ctx context.Context, req *connect_go.Request[v1alpha1.GetRepositoriesByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesByFullNameResponse], error) { |
| return c.getRepositoriesByFullName.CallUnary(ctx, req) |
| } |
| |
| // SetRepositoryContributor calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.SetRepositoryContributor. |
| func (c *repositoryServiceClient) SetRepositoryContributor(ctx context.Context, req *connect_go.Request[v1alpha1.SetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.SetRepositoryContributorResponse], error) { |
| return c.setRepositoryContributor.CallUnary(ctx, req) |
| } |
| |
| // ListRepositoryContributors calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListRepositoryContributors. |
| func (c *repositoryServiceClient) ListRepositoryContributors(ctx context.Context, req *connect_go.Request[v1alpha1.ListRepositoryContributorsRequest]) (*connect_go.Response[v1alpha1.ListRepositoryContributorsResponse], error) { |
| return c.listRepositoryContributors.CallUnary(ctx, req) |
| } |
| |
| // GetRepositoryContributor calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoryContributor. |
| func (c *repositoryServiceClient) GetRepositoryContributor(ctx context.Context, req *connect_go.Request[v1alpha1.GetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.GetRepositoryContributorResponse], error) { |
| return c.getRepositoryContributor.CallUnary(ctx, req) |
| } |
| |
| // GetRepositorySettings calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositorySettings. |
| func (c *repositoryServiceClient) GetRepositorySettings(ctx context.Context, req *connect_go.Request[v1alpha1.GetRepositorySettingsRequest]) (*connect_go.Response[v1alpha1.GetRepositorySettingsResponse], error) { |
| return c.getRepositorySettings.CallUnary(ctx, req) |
| } |
| |
| // UpdateRepositorySettingsByName calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.UpdateRepositorySettingsByName. |
| func (c *repositoryServiceClient) UpdateRepositorySettingsByName(ctx context.Context, req *connect_go.Request[v1alpha1.UpdateRepositorySettingsByNameRequest]) (*connect_go.Response[v1alpha1.UpdateRepositorySettingsByNameResponse], error) { |
| return c.updateRepositorySettingsByName.CallUnary(ctx, req) |
| } |
| |
| // GetRepositoriesMetadata calls |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoriesMetadata. |
| func (c *repositoryServiceClient) GetRepositoriesMetadata(ctx context.Context, req *connect_go.Request[v1alpha1.GetRepositoriesMetadataRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesMetadataResponse], error) { |
| return c.getRepositoriesMetadata.CallUnary(ctx, req) |
| } |
| |
| // RepositoryServiceHandler is an implementation of the |
| // bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService service. |
| type RepositoryServiceHandler interface { |
| // GetRepository gets a repository by ID. |
| GetRepository(context.Context, *connect_go.Request[v1alpha1.GetRepositoryRequest]) (*connect_go.Response[v1alpha1.GetRepositoryResponse], error) |
| // GetRepositoryByFullName gets a repository by full name. |
| GetRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.GetRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoryByFullNameResponse], error) |
| // ListRepositories lists all repositories. |
| ListRepositories(context.Context, *connect_go.Request[v1alpha1.ListRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesResponse], error) |
| // ListUserRepositories lists all repositories belonging to a user. |
| ListUserRepositories(context.Context, *connect_go.Request[v1alpha1.ListUserRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListUserRepositoriesResponse], error) |
| // ListRepositoriesUserCanAccess lists all repositories a user can access. |
| ListRepositoriesUserCanAccess(context.Context, *connect_go.Request[v1alpha1.ListRepositoriesUserCanAccessRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesUserCanAccessResponse], error) |
| // ListOrganizationRepositories lists all repositories for an organization. |
| ListOrganizationRepositories(context.Context, *connect_go.Request[v1alpha1.ListOrganizationRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListOrganizationRepositoriesResponse], error) |
| // CreateRepositoryByFullName creates a new repository by full name. |
| CreateRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.CreateRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.CreateRepositoryByFullNameResponse], error) |
| // DeleteRepository deletes a repository. |
| DeleteRepository(context.Context, *connect_go.Request[v1alpha1.DeleteRepositoryRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryResponse], error) |
| // DeleteRepositoryByFullName deletes a repository by full name. |
| DeleteRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.DeleteRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryByFullNameResponse], error) |
| // DeprecateRepositoryByName deprecates the repository. |
| DeprecateRepositoryByName(context.Context, *connect_go.Request[v1alpha1.DeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.DeprecateRepositoryByNameResponse], error) |
| // UndeprecateRepositoryByName makes the repository not deprecated and removes any deprecation_message. |
| UndeprecateRepositoryByName(context.Context, *connect_go.Request[v1alpha1.UndeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.UndeprecateRepositoryByNameResponse], error) |
| // GetRepositoriesByFullName gets repositories by full name. Response order is unspecified. |
| // Errors if any of the repositories don't exist or the caller does not have access to any of the repositories. |
| GetRepositoriesByFullName(context.Context, *connect_go.Request[v1alpha1.GetRepositoriesByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesByFullNameResponse], error) |
| // SetRepositoryContributor sets the role of a user in the repository. |
| SetRepositoryContributor(context.Context, *connect_go.Request[v1alpha1.SetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.SetRepositoryContributorResponse], error) |
| // ListRepositoryContributors returns the list of contributors that has an explicit role against the repository. |
| // This does not include users who have implicit roles against the repository, unless they have also been |
| // assigned a role explicitly. |
| ListRepositoryContributors(context.Context, *connect_go.Request[v1alpha1.ListRepositoryContributorsRequest]) (*connect_go.Response[v1alpha1.ListRepositoryContributorsResponse], error) |
| // GetRepositoryContributor returns the contributor information of a user in a repository. |
| GetRepositoryContributor(context.Context, *connect_go.Request[v1alpha1.GetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.GetRepositoryContributorResponse], error) |
| // GetRepositorySettings gets the settings of a repository. |
| GetRepositorySettings(context.Context, *connect_go.Request[v1alpha1.GetRepositorySettingsRequest]) (*connect_go.Response[v1alpha1.GetRepositorySettingsResponse], error) |
| // UpdateRepositorySettingsByName updates the settings of a repository. |
| UpdateRepositorySettingsByName(context.Context, *connect_go.Request[v1alpha1.UpdateRepositorySettingsByNameRequest]) (*connect_go.Response[v1alpha1.UpdateRepositorySettingsByNameResponse], error) |
| // GetRepositoriesMetadata gets the metadata of the repositories in the request, the length of repositories in the |
| // request should match the length of the metadata in the response, and the order of repositories in the response |
| // should match the order of the metadata in the request. |
| GetRepositoriesMetadata(context.Context, *connect_go.Request[v1alpha1.GetRepositoriesMetadataRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesMetadataResponse], error) |
| } |
| |
| // NewRepositoryServiceHandler builds an HTTP handler from the service implementation. It returns |
| // the path on which to mount the handler and the handler itself. |
| // |
| // By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf |
| // and JSON codecs. They also support gzip compression. |
| func NewRepositoryServiceHandler(svc RepositoryServiceHandler, opts ...connect_go.HandlerOption) (string, http.Handler) { |
| repositoryServiceGetRepositoryHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceGetRepositoryProcedure, |
| svc.GetRepository, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceGetRepositoryByFullNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceGetRepositoryByFullNameProcedure, |
| svc.GetRepositoryByFullName, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceListRepositoriesHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceListRepositoriesProcedure, |
| svc.ListRepositories, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceListUserRepositoriesHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceListUserRepositoriesProcedure, |
| svc.ListUserRepositories, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceListRepositoriesUserCanAccessHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceListRepositoriesUserCanAccessProcedure, |
| svc.ListRepositoriesUserCanAccess, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceListOrganizationRepositoriesHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceListOrganizationRepositoriesProcedure, |
| svc.ListOrganizationRepositories, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceCreateRepositoryByFullNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceCreateRepositoryByFullNameProcedure, |
| svc.CreateRepositoryByFullName, |
| connect_go.WithIdempotency(connect_go.IdempotencyIdempotent), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceDeleteRepositoryHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceDeleteRepositoryProcedure, |
| svc.DeleteRepository, |
| connect_go.WithIdempotency(connect_go.IdempotencyIdempotent), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceDeleteRepositoryByFullNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceDeleteRepositoryByFullNameProcedure, |
| svc.DeleteRepositoryByFullName, |
| connect_go.WithIdempotency(connect_go.IdempotencyIdempotent), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceDeprecateRepositoryByNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceDeprecateRepositoryByNameProcedure, |
| svc.DeprecateRepositoryByName, |
| opts..., |
| ) |
| repositoryServiceUndeprecateRepositoryByNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceUndeprecateRepositoryByNameProcedure, |
| svc.UndeprecateRepositoryByName, |
| opts..., |
| ) |
| repositoryServiceGetRepositoriesByFullNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceGetRepositoriesByFullNameProcedure, |
| svc.GetRepositoriesByFullName, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceSetRepositoryContributorHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceSetRepositoryContributorProcedure, |
| svc.SetRepositoryContributor, |
| opts..., |
| ) |
| repositoryServiceListRepositoryContributorsHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceListRepositoryContributorsProcedure, |
| svc.ListRepositoryContributors, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceGetRepositoryContributorHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceGetRepositoryContributorProcedure, |
| svc.GetRepositoryContributor, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceGetRepositorySettingsHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceGetRepositorySettingsProcedure, |
| svc.GetRepositorySettings, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| repositoryServiceUpdateRepositorySettingsByNameHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceUpdateRepositorySettingsByNameProcedure, |
| svc.UpdateRepositorySettingsByName, |
| opts..., |
| ) |
| repositoryServiceGetRepositoriesMetadataHandler := connect_go.NewUnaryHandler( |
| RepositoryServiceGetRepositoriesMetadataProcedure, |
| svc.GetRepositoriesMetadata, |
| connect_go.WithIdempotency(connect_go.IdempotencyNoSideEffects), |
| connect_go.WithHandlerOptions(opts...), |
| ) |
| return "/bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { |
| switch r.URL.Path { |
| case RepositoryServiceGetRepositoryProcedure: |
| repositoryServiceGetRepositoryHandler.ServeHTTP(w, r) |
| case RepositoryServiceGetRepositoryByFullNameProcedure: |
| repositoryServiceGetRepositoryByFullNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceListRepositoriesProcedure: |
| repositoryServiceListRepositoriesHandler.ServeHTTP(w, r) |
| case RepositoryServiceListUserRepositoriesProcedure: |
| repositoryServiceListUserRepositoriesHandler.ServeHTTP(w, r) |
| case RepositoryServiceListRepositoriesUserCanAccessProcedure: |
| repositoryServiceListRepositoriesUserCanAccessHandler.ServeHTTP(w, r) |
| case RepositoryServiceListOrganizationRepositoriesProcedure: |
| repositoryServiceListOrganizationRepositoriesHandler.ServeHTTP(w, r) |
| case RepositoryServiceCreateRepositoryByFullNameProcedure: |
| repositoryServiceCreateRepositoryByFullNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceDeleteRepositoryProcedure: |
| repositoryServiceDeleteRepositoryHandler.ServeHTTP(w, r) |
| case RepositoryServiceDeleteRepositoryByFullNameProcedure: |
| repositoryServiceDeleteRepositoryByFullNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceDeprecateRepositoryByNameProcedure: |
| repositoryServiceDeprecateRepositoryByNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceUndeprecateRepositoryByNameProcedure: |
| repositoryServiceUndeprecateRepositoryByNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceGetRepositoriesByFullNameProcedure: |
| repositoryServiceGetRepositoriesByFullNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceSetRepositoryContributorProcedure: |
| repositoryServiceSetRepositoryContributorHandler.ServeHTTP(w, r) |
| case RepositoryServiceListRepositoryContributorsProcedure: |
| repositoryServiceListRepositoryContributorsHandler.ServeHTTP(w, r) |
| case RepositoryServiceGetRepositoryContributorProcedure: |
| repositoryServiceGetRepositoryContributorHandler.ServeHTTP(w, r) |
| case RepositoryServiceGetRepositorySettingsProcedure: |
| repositoryServiceGetRepositorySettingsHandler.ServeHTTP(w, r) |
| case RepositoryServiceUpdateRepositorySettingsByNameProcedure: |
| repositoryServiceUpdateRepositorySettingsByNameHandler.ServeHTTP(w, r) |
| case RepositoryServiceGetRepositoriesMetadataProcedure: |
| repositoryServiceGetRepositoriesMetadataHandler.ServeHTTP(w, r) |
| default: |
| http.NotFound(w, r) |
| } |
| }) |
| } |
| |
| // UnimplementedRepositoryServiceHandler returns CodeUnimplemented from all methods. |
| type UnimplementedRepositoryServiceHandler struct{} |
| |
| func (UnimplementedRepositoryServiceHandler) GetRepository(context.Context, *connect_go.Request[v1alpha1.GetRepositoryRequest]) (*connect_go.Response[v1alpha1.GetRepositoryResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepository is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) GetRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.GetRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoryByFullNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoryByFullName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) ListRepositories(context.Context, *connect_go.Request[v1alpha1.ListRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListRepositories is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) ListUserRepositories(context.Context, *connect_go.Request[v1alpha1.ListUserRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListUserRepositoriesResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListUserRepositories is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) ListRepositoriesUserCanAccess(context.Context, *connect_go.Request[v1alpha1.ListRepositoriesUserCanAccessRequest]) (*connect_go.Response[v1alpha1.ListRepositoriesUserCanAccessResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListRepositoriesUserCanAccess is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) ListOrganizationRepositories(context.Context, *connect_go.Request[v1alpha1.ListOrganizationRepositoriesRequest]) (*connect_go.Response[v1alpha1.ListOrganizationRepositoriesResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListOrganizationRepositories is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) CreateRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.CreateRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.CreateRepositoryByFullNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.CreateRepositoryByFullName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) DeleteRepository(context.Context, *connect_go.Request[v1alpha1.DeleteRepositoryRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.DeleteRepository is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) DeleteRepositoryByFullName(context.Context, *connect_go.Request[v1alpha1.DeleteRepositoryByFullNameRequest]) (*connect_go.Response[v1alpha1.DeleteRepositoryByFullNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.DeleteRepositoryByFullName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) DeprecateRepositoryByName(context.Context, *connect_go.Request[v1alpha1.DeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.DeprecateRepositoryByNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.DeprecateRepositoryByName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) UndeprecateRepositoryByName(context.Context, *connect_go.Request[v1alpha1.UndeprecateRepositoryByNameRequest]) (*connect_go.Response[v1alpha1.UndeprecateRepositoryByNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.UndeprecateRepositoryByName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) GetRepositoriesByFullName(context.Context, *connect_go.Request[v1alpha1.GetRepositoriesByFullNameRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesByFullNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoriesByFullName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) SetRepositoryContributor(context.Context, *connect_go.Request[v1alpha1.SetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.SetRepositoryContributorResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.SetRepositoryContributor is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) ListRepositoryContributors(context.Context, *connect_go.Request[v1alpha1.ListRepositoryContributorsRequest]) (*connect_go.Response[v1alpha1.ListRepositoryContributorsResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.ListRepositoryContributors is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) GetRepositoryContributor(context.Context, *connect_go.Request[v1alpha1.GetRepositoryContributorRequest]) (*connect_go.Response[v1alpha1.GetRepositoryContributorResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoryContributor is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) GetRepositorySettings(context.Context, *connect_go.Request[v1alpha1.GetRepositorySettingsRequest]) (*connect_go.Response[v1alpha1.GetRepositorySettingsResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositorySettings is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) UpdateRepositorySettingsByName(context.Context, *connect_go.Request[v1alpha1.UpdateRepositorySettingsByNameRequest]) (*connect_go.Response[v1alpha1.UpdateRepositorySettingsByNameResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.UpdateRepositorySettingsByName is not implemented")) |
| } |
| |
| func (UnimplementedRepositoryServiceHandler) GetRepositoriesMetadata(context.Context, *connect_go.Request[v1alpha1.GetRepositoriesMetadataRequest]) (*connect_go.Response[v1alpha1.GetRepositoriesMetadataResponse], error) { |
| return nil, connect_go.NewError(connect_go.CodeUnimplemented, errors.New("bufman.dubbo.apache.org.registry.v1alpha1.RepositoryService.GetRepositoriesMetadata is not implemented")) |
| } |
