// SPDX-License-Identifier: MIT // Code generated by protoc-gen-connect-go. DO NOT EDIT. // // Source: ermite/mirror.proto package ermiteconnect import ( ermite "bnema.dev/ermite-api/gen/ermite" connect "connectrpc.com/connect" context "context" errors "errors" 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.IsAtLeastVersion1_13_0 const ( // MirrorServiceName is the fully-qualified name of the MirrorService service. MirrorServiceName = "ermite.MirrorService" ) // 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 ( // MirrorServiceGetMirrorKeyProcedure is the fully-qualified name of the MirrorService's // GetMirrorKey RPC. MirrorServiceGetMirrorKeyProcedure = "/ermite.MirrorService/GetMirrorKey" // MirrorServiceRotateMirrorKeyProcedure is the fully-qualified name of the MirrorService's // RotateMirrorKey RPC. MirrorServiceRotateMirrorKeyProcedure = "/ermite.MirrorService/RotateMirrorKey" // MirrorServiceGetMirrorConfigProcedure is the fully-qualified name of the MirrorService's // GetMirrorConfig RPC. MirrorServiceGetMirrorConfigProcedure = "/ermite.MirrorService/GetMirrorConfig" // MirrorServiceSetMirrorConfigProcedure is the fully-qualified name of the MirrorService's // SetMirrorConfig RPC. MirrorServiceSetMirrorConfigProcedure = "/ermite.MirrorService/SetMirrorConfig" // MirrorServiceSetRepoMirrorProcedure is the fully-qualified name of the MirrorService's // SetRepoMirror RPC. MirrorServiceSetRepoMirrorProcedure = "/ermite.MirrorService/SetRepoMirror" // MirrorServiceRemoveRepoMirrorProcedure is the fully-qualified name of the MirrorService's // RemoveRepoMirror RPC. MirrorServiceRemoveRepoMirrorProcedure = "/ermite.MirrorService/RemoveRepoMirror" // MirrorServiceSetRepoMirrorExcludedProcedure is the fully-qualified name of the MirrorService's // SetRepoMirrorExcluded RPC. MirrorServiceSetRepoMirrorExcludedProcedure = "/ermite.MirrorService/SetRepoMirrorExcluded" // MirrorServiceGetMirrorStatusProcedure is the fully-qualified name of the MirrorService's // GetMirrorStatus RPC. MirrorServiceGetMirrorStatusProcedure = "/ermite.MirrorService/GetMirrorStatus" // MirrorServiceListMirrorStatusProcedure is the fully-qualified name of the MirrorService's // ListMirrorStatus RPC. MirrorServiceListMirrorStatusProcedure = "/ermite.MirrorService/ListMirrorStatus" // MirrorServiceSyncMirrorProcedure is the fully-qualified name of the MirrorService's SyncMirror // RPC. MirrorServiceSyncMirrorProcedure = "/ermite.MirrorService/SyncMirror" ) // MirrorServiceClient is a client for the ermite.MirrorService service. type MirrorServiceClient interface { // GetMirrorKey returns the public mirror key, generating it on first use. // Needs a non-anonymous caller. Fails with failed_precondition without // ERMITE_SECRETS_KEY. GetMirrorKey(context.Context, *connect.Request[ermite.GetMirrorKeyRequest]) (*connect.Response[ermite.GetMirrorKeyResponse], error) // RotateMirrorKey replaces the key immediately. Add the new key to remotes // and sync with force to recover from authentication failures. RotateMirrorKey(context.Context, *connect.Request[ermite.RotateMirrorKeyRequest]) (*connect.Response[ermite.RotateMirrorKeyResponse], error) // GetMirrorConfig returns the global mirror policy. GetMirrorConfig(context.Context, *connect.Request[ermite.GetMirrorConfigRequest]) (*connect.Response[ermite.GetMirrorConfigResponse], error) // SetMirrorConfig patches the global policy. Unset fields are unchanged. // Invalid fields give invalid_argument with field violations. SetMirrorConfig(context.Context, *connect.Request[ermite.SetMirrorConfigRequest]) (*connect.Response[ermite.SetMirrorConfigResponse], error) // SetRepoMirror sets an override, even when global mirroring is disabled. SetRepoMirror(context.Context, *connect.Request[ermite.SetRepoMirrorRequest]) (*connect.Response[ermite.SetRepoMirrorResponse], error) // RemoveRepoMirror removes the override so the global policy applies again. RemoveRepoMirror(context.Context, *connect.Request[ermite.RemoveRepoMirrorRequest]) (*connect.Response[ermite.RemoveRepoMirrorResponse], error) // SetRepoMirrorExcluded excludes or includes a repository in the global // policy. An explicit URL override takes precedence. SetRepoMirrorExcluded(context.Context, *connect.Request[ermite.SetRepoMirrorExcludedRequest]) (*connect.Response[ermite.SetRepoMirrorExcludedResponse], error) // GetMirrorStatus returns the resolved target and status of one repository. GetMirrorStatus(context.Context, *connect.Request[ermite.GetMirrorStatusRequest]) (*connect.Response[ermite.GetMirrorStatusResponse], error) // ListMirrorStatus lists mirror statuses and needs owner rights. ListMirrorStatus(context.Context, *connect.Request[ermite.ListMirrorStatusRequest]) (*connect.Response[ermite.ListMirrorStatusResponse], error) // SyncMirror syncs Repo or, with All, every repository. Paused mirrors need // Force. Manual requests without Force are at least 60 seconds apart. SyncMirror(context.Context, *connect.Request[ermite.SyncMirrorRequest]) (*connect.Response[ermite.SyncMirrorResponse], error) } // NewMirrorServiceClient constructs a client for the ermite.MirrorService 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 NewMirrorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MirrorServiceClient { baseURL = strings.TrimRight(baseURL, "/") mirrorServiceMethods := ermite.File_ermite_mirror_proto.Services().ByName("MirrorService").Methods() return &mirrorServiceClient{ getMirrorKey: connect.NewClient[ermite.GetMirrorKeyRequest, ermite.GetMirrorKeyResponse]( httpClient, baseURL+MirrorServiceGetMirrorKeyProcedure, connect.WithSchema(mirrorServiceMethods.ByName("GetMirrorKey")), connect.WithClientOptions(opts...), ), rotateMirrorKey: connect.NewClient[ermite.RotateMirrorKeyRequest, ermite.RotateMirrorKeyResponse]( httpClient, baseURL+MirrorServiceRotateMirrorKeyProcedure, connect.WithSchema(mirrorServiceMethods.ByName("RotateMirrorKey")), connect.WithClientOptions(opts...), ), getMirrorConfig: connect.NewClient[ermite.GetMirrorConfigRequest, ermite.GetMirrorConfigResponse]( httpClient, baseURL+MirrorServiceGetMirrorConfigProcedure, connect.WithSchema(mirrorServiceMethods.ByName("GetMirrorConfig")), connect.WithClientOptions(opts...), ), setMirrorConfig: connect.NewClient[ermite.SetMirrorConfigRequest, ermite.SetMirrorConfigResponse]( httpClient, baseURL+MirrorServiceSetMirrorConfigProcedure, connect.WithSchema(mirrorServiceMethods.ByName("SetMirrorConfig")), connect.WithClientOptions(opts...), ), setRepoMirror: connect.NewClient[ermite.SetRepoMirrorRequest, ermite.SetRepoMirrorResponse]( httpClient, baseURL+MirrorServiceSetRepoMirrorProcedure, connect.WithSchema(mirrorServiceMethods.ByName("SetRepoMirror")), connect.WithClientOptions(opts...), ), removeRepoMirror: connect.NewClient[ermite.RemoveRepoMirrorRequest, ermite.RemoveRepoMirrorResponse]( httpClient, baseURL+MirrorServiceRemoveRepoMirrorProcedure, connect.WithSchema(mirrorServiceMethods.ByName("RemoveRepoMirror")), connect.WithClientOptions(opts...), ), setRepoMirrorExcluded: connect.NewClient[ermite.SetRepoMirrorExcludedRequest, ermite.SetRepoMirrorExcludedResponse]( httpClient, baseURL+MirrorServiceSetRepoMirrorExcludedProcedure, connect.WithSchema(mirrorServiceMethods.ByName("SetRepoMirrorExcluded")), connect.WithClientOptions(opts...), ), getMirrorStatus: connect.NewClient[ermite.GetMirrorStatusRequest, ermite.GetMirrorStatusResponse]( httpClient, baseURL+MirrorServiceGetMirrorStatusProcedure, connect.WithSchema(mirrorServiceMethods.ByName("GetMirrorStatus")), connect.WithClientOptions(opts...), ), listMirrorStatus: connect.NewClient[ermite.ListMirrorStatusRequest, ermite.ListMirrorStatusResponse]( httpClient, baseURL+MirrorServiceListMirrorStatusProcedure, connect.WithSchema(mirrorServiceMethods.ByName("ListMirrorStatus")), connect.WithClientOptions(opts...), ), syncMirror: connect.NewClient[ermite.SyncMirrorRequest, ermite.SyncMirrorResponse]( httpClient, baseURL+MirrorServiceSyncMirrorProcedure, connect.WithSchema(mirrorServiceMethods.ByName("SyncMirror")), connect.WithClientOptions(opts...), ), } } // mirrorServiceClient implements MirrorServiceClient. type mirrorServiceClient struct { getMirrorKey *connect.Client[ermite.GetMirrorKeyRequest, ermite.GetMirrorKeyResponse] rotateMirrorKey *connect.Client[ermite.RotateMirrorKeyRequest, ermite.RotateMirrorKeyResponse] getMirrorConfig *connect.Client[ermite.GetMirrorConfigRequest, ermite.GetMirrorConfigResponse] setMirrorConfig *connect.Client[ermite.SetMirrorConfigRequest, ermite.SetMirrorConfigResponse] setRepoMirror *connect.Client[ermite.SetRepoMirrorRequest, ermite.SetRepoMirrorResponse] removeRepoMirror *connect.Client[ermite.RemoveRepoMirrorRequest, ermite.RemoveRepoMirrorResponse] setRepoMirrorExcluded *connect.Client[ermite.SetRepoMirrorExcludedRequest, ermite.SetRepoMirrorExcludedResponse] getMirrorStatus *connect.Client[ermite.GetMirrorStatusRequest, ermite.GetMirrorStatusResponse] listMirrorStatus *connect.Client[ermite.ListMirrorStatusRequest, ermite.ListMirrorStatusResponse] syncMirror *connect.Client[ermite.SyncMirrorRequest, ermite.SyncMirrorResponse] } // GetMirrorKey calls ermite.MirrorService.GetMirrorKey. func (c *mirrorServiceClient) GetMirrorKey(ctx context.Context, req *connect.Request[ermite.GetMirrorKeyRequest]) (*connect.Response[ermite.GetMirrorKeyResponse], error) { return c.getMirrorKey.CallUnary(ctx, req) } // RotateMirrorKey calls ermite.MirrorService.RotateMirrorKey. func (c *mirrorServiceClient) RotateMirrorKey(ctx context.Context, req *connect.Request[ermite.RotateMirrorKeyRequest]) (*connect.Response[ermite.RotateMirrorKeyResponse], error) { return c.rotateMirrorKey.CallUnary(ctx, req) } // GetMirrorConfig calls ermite.MirrorService.GetMirrorConfig. func (c *mirrorServiceClient) GetMirrorConfig(ctx context.Context, req *connect.Request[ermite.GetMirrorConfigRequest]) (*connect.Response[ermite.GetMirrorConfigResponse], error) { return c.getMirrorConfig.CallUnary(ctx, req) } // SetMirrorConfig calls ermite.MirrorService.SetMirrorConfig. func (c *mirrorServiceClient) SetMirrorConfig(ctx context.Context, req *connect.Request[ermite.SetMirrorConfigRequest]) (*connect.Response[ermite.SetMirrorConfigResponse], error) { return c.setMirrorConfig.CallUnary(ctx, req) } // SetRepoMirror calls ermite.MirrorService.SetRepoMirror. func (c *mirrorServiceClient) SetRepoMirror(ctx context.Context, req *connect.Request[ermite.SetRepoMirrorRequest]) (*connect.Response[ermite.SetRepoMirrorResponse], error) { return c.setRepoMirror.CallUnary(ctx, req) } // RemoveRepoMirror calls ermite.MirrorService.RemoveRepoMirror. func (c *mirrorServiceClient) RemoveRepoMirror(ctx context.Context, req *connect.Request[ermite.RemoveRepoMirrorRequest]) (*connect.Response[ermite.RemoveRepoMirrorResponse], error) { return c.removeRepoMirror.CallUnary(ctx, req) } // SetRepoMirrorExcluded calls ermite.MirrorService.SetRepoMirrorExcluded. func (c *mirrorServiceClient) SetRepoMirrorExcluded(ctx context.Context, req *connect.Request[ermite.SetRepoMirrorExcludedRequest]) (*connect.Response[ermite.SetRepoMirrorExcludedResponse], error) { return c.setRepoMirrorExcluded.CallUnary(ctx, req) } // GetMirrorStatus calls ermite.MirrorService.GetMirrorStatus. func (c *mirrorServiceClient) GetMirrorStatus(ctx context.Context, req *connect.Request[ermite.GetMirrorStatusRequest]) (*connect.Response[ermite.GetMirrorStatusResponse], error) { return c.getMirrorStatus.CallUnary(ctx, req) } // ListMirrorStatus calls ermite.MirrorService.ListMirrorStatus. func (c *mirrorServiceClient) ListMirrorStatus(ctx context.Context, req *connect.Request[ermite.ListMirrorStatusRequest]) (*connect.Response[ermite.ListMirrorStatusResponse], error) { return c.listMirrorStatus.CallUnary(ctx, req) } // SyncMirror calls ermite.MirrorService.SyncMirror. func (c *mirrorServiceClient) SyncMirror(ctx context.Context, req *connect.Request[ermite.SyncMirrorRequest]) (*connect.Response[ermite.SyncMirrorResponse], error) { return c.syncMirror.CallUnary(ctx, req) } // MirrorServiceHandler is an implementation of the ermite.MirrorService service. type MirrorServiceHandler interface { // GetMirrorKey returns the public mirror key, generating it on first use. // Needs a non-anonymous caller. Fails with failed_precondition without // ERMITE_SECRETS_KEY. GetMirrorKey(context.Context, *connect.Request[ermite.GetMirrorKeyRequest]) (*connect.Response[ermite.GetMirrorKeyResponse], error) // RotateMirrorKey replaces the key immediately. Add the new key to remotes // and sync with force to recover from authentication failures. RotateMirrorKey(context.Context, *connect.Request[ermite.RotateMirrorKeyRequest]) (*connect.Response[ermite.RotateMirrorKeyResponse], error) // GetMirrorConfig returns the global mirror policy. GetMirrorConfig(context.Context, *connect.Request[ermite.GetMirrorConfigRequest]) (*connect.Response[ermite.GetMirrorConfigResponse], error) // SetMirrorConfig patches the global policy. Unset fields are unchanged. // Invalid fields give invalid_argument with field violations. SetMirrorConfig(context.Context, *connect.Request[ermite.SetMirrorConfigRequest]) (*connect.Response[ermite.SetMirrorConfigResponse], error) // SetRepoMirror sets an override, even when global mirroring is disabled. SetRepoMirror(context.Context, *connect.Request[ermite.SetRepoMirrorRequest]) (*connect.Response[ermite.SetRepoMirrorResponse], error) // RemoveRepoMirror removes the override so the global policy applies again. RemoveRepoMirror(context.Context, *connect.Request[ermite.RemoveRepoMirrorRequest]) (*connect.Response[ermite.RemoveRepoMirrorResponse], error) // SetRepoMirrorExcluded excludes or includes a repository in the global // policy. An explicit URL override takes precedence. SetRepoMirrorExcluded(context.Context, *connect.Request[ermite.SetRepoMirrorExcludedRequest]) (*connect.Response[ermite.SetRepoMirrorExcludedResponse], error) // GetMirrorStatus returns the resolved target and status of one repository. GetMirrorStatus(context.Context, *connect.Request[ermite.GetMirrorStatusRequest]) (*connect.Response[ermite.GetMirrorStatusResponse], error) // ListMirrorStatus lists mirror statuses and needs owner rights. ListMirrorStatus(context.Context, *connect.Request[ermite.ListMirrorStatusRequest]) (*connect.Response[ermite.ListMirrorStatusResponse], error) // SyncMirror syncs Repo or, with All, every repository. Paused mirrors need // Force. Manual requests without Force are at least 60 seconds apart. SyncMirror(context.Context, *connect.Request[ermite.SyncMirrorRequest]) (*connect.Response[ermite.SyncMirrorResponse], error) } // NewMirrorServiceHandler 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 NewMirrorServiceHandler(svc MirrorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler) { mirrorServiceMethods := ermite.File_ermite_mirror_proto.Services().ByName("MirrorService").Methods() mirrorServiceGetMirrorKeyHandler := connect.NewUnaryHandler( MirrorServiceGetMirrorKeyProcedure, svc.GetMirrorKey, connect.WithSchema(mirrorServiceMethods.ByName("GetMirrorKey")), connect.WithHandlerOptions(opts...), ) mirrorServiceRotateMirrorKeyHandler := connect.NewUnaryHandler( MirrorServiceRotateMirrorKeyProcedure, svc.RotateMirrorKey, connect.WithSchema(mirrorServiceMethods.ByName("RotateMirrorKey")), connect.WithHandlerOptions(opts...), ) mirrorServiceGetMirrorConfigHandler := connect.NewUnaryHandler( MirrorServiceGetMirrorConfigProcedure, svc.GetMirrorConfig, connect.WithSchema(mirrorServiceMethods.ByName("GetMirrorConfig")), connect.WithHandlerOptions(opts...), ) mirrorServiceSetMirrorConfigHandler := connect.NewUnaryHandler( MirrorServiceSetMirrorConfigProcedure, svc.SetMirrorConfig, connect.WithSchema(mirrorServiceMethods.ByName("SetMirrorConfig")), connect.WithHandlerOptions(opts...), ) mirrorServiceSetRepoMirrorHandler := connect.NewUnaryHandler( MirrorServiceSetRepoMirrorProcedure, svc.SetRepoMirror, connect.WithSchema(mirrorServiceMethods.ByName("SetRepoMirror")), connect.WithHandlerOptions(opts...), ) mirrorServiceRemoveRepoMirrorHandler := connect.NewUnaryHandler( MirrorServiceRemoveRepoMirrorProcedure, svc.RemoveRepoMirror, connect.WithSchema(mirrorServiceMethods.ByName("RemoveRepoMirror")), connect.WithHandlerOptions(opts...), ) mirrorServiceSetRepoMirrorExcludedHandler := connect.NewUnaryHandler( MirrorServiceSetRepoMirrorExcludedProcedure, svc.SetRepoMirrorExcluded, connect.WithSchema(mirrorServiceMethods.ByName("SetRepoMirrorExcluded")), connect.WithHandlerOptions(opts...), ) mirrorServiceGetMirrorStatusHandler := connect.NewUnaryHandler( MirrorServiceGetMirrorStatusProcedure, svc.GetMirrorStatus, connect.WithSchema(mirrorServiceMethods.ByName("GetMirrorStatus")), connect.WithHandlerOptions(opts...), ) mirrorServiceListMirrorStatusHandler := connect.NewUnaryHandler( MirrorServiceListMirrorStatusProcedure, svc.ListMirrorStatus, connect.WithSchema(mirrorServiceMethods.ByName("ListMirrorStatus")), connect.WithHandlerOptions(opts...), ) mirrorServiceSyncMirrorHandler := connect.NewUnaryHandler( MirrorServiceSyncMirrorProcedure, svc.SyncMirror, connect.WithSchema(mirrorServiceMethods.ByName("SyncMirror")), connect.WithHandlerOptions(opts...), ) return "/ermite.MirrorService/", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { switch r.URL.Path { case MirrorServiceGetMirrorKeyProcedure: mirrorServiceGetMirrorKeyHandler.ServeHTTP(w, r) case MirrorServiceRotateMirrorKeyProcedure: mirrorServiceRotateMirrorKeyHandler.ServeHTTP(w, r) case MirrorServiceGetMirrorConfigProcedure: mirrorServiceGetMirrorConfigHandler.ServeHTTP(w, r) case MirrorServiceSetMirrorConfigProcedure: mirrorServiceSetMirrorConfigHandler.ServeHTTP(w, r) case MirrorServiceSetRepoMirrorProcedure: mirrorServiceSetRepoMirrorHandler.ServeHTTP(w, r) case MirrorServiceRemoveRepoMirrorProcedure: mirrorServiceRemoveRepoMirrorHandler.ServeHTTP(w, r) case MirrorServiceSetRepoMirrorExcludedProcedure: mirrorServiceSetRepoMirrorExcludedHandler.ServeHTTP(w, r) case MirrorServiceGetMirrorStatusProcedure: mirrorServiceGetMirrorStatusHandler.ServeHTTP(w, r) case MirrorServiceListMirrorStatusProcedure: mirrorServiceListMirrorStatusHandler.ServeHTTP(w, r) case MirrorServiceSyncMirrorProcedure: mirrorServiceSyncMirrorHandler.ServeHTTP(w, r) default: http.NotFound(w, r) } }) } // UnimplementedMirrorServiceHandler returns CodeUnimplemented from all methods. type UnimplementedMirrorServiceHandler struct{} func (UnimplementedMirrorServiceHandler) GetMirrorKey(context.Context, *connect.Request[ermite.GetMirrorKeyRequest]) (*connect.Response[ermite.GetMirrorKeyResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.GetMirrorKey is not implemented")) } func (UnimplementedMirrorServiceHandler) RotateMirrorKey(context.Context, *connect.Request[ermite.RotateMirrorKeyRequest]) (*connect.Response[ermite.RotateMirrorKeyResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.RotateMirrorKey is not implemented")) } func (UnimplementedMirrorServiceHandler) GetMirrorConfig(context.Context, *connect.Request[ermite.GetMirrorConfigRequest]) (*connect.Response[ermite.GetMirrorConfigResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.GetMirrorConfig is not implemented")) } func (UnimplementedMirrorServiceHandler) SetMirrorConfig(context.Context, *connect.Request[ermite.SetMirrorConfigRequest]) (*connect.Response[ermite.SetMirrorConfigResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.SetMirrorConfig is not implemented")) } func (UnimplementedMirrorServiceHandler) SetRepoMirror(context.Context, *connect.Request[ermite.SetRepoMirrorRequest]) (*connect.Response[ermite.SetRepoMirrorResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.SetRepoMirror is not implemented")) } func (UnimplementedMirrorServiceHandler) RemoveRepoMirror(context.Context, *connect.Request[ermite.RemoveRepoMirrorRequest]) (*connect.Response[ermite.RemoveRepoMirrorResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.RemoveRepoMirror is not implemented")) } func (UnimplementedMirrorServiceHandler) SetRepoMirrorExcluded(context.Context, *connect.Request[ermite.SetRepoMirrorExcludedRequest]) (*connect.Response[ermite.SetRepoMirrorExcludedResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.SetRepoMirrorExcluded is not implemented")) } func (UnimplementedMirrorServiceHandler) GetMirrorStatus(context.Context, *connect.Request[ermite.GetMirrorStatusRequest]) (*connect.Response[ermite.GetMirrorStatusResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.GetMirrorStatus is not implemented")) } func (UnimplementedMirrorServiceHandler) ListMirrorStatus(context.Context, *connect.Request[ermite.ListMirrorStatusRequest]) (*connect.Response[ermite.ListMirrorStatusResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.ListMirrorStatus is not implemented")) } func (UnimplementedMirrorServiceHandler) SyncMirror(context.Context, *connect.Request[ermite.SyncMirrorRequest]) (*connect.Response[ermite.SyncMirrorResponse], error) { return nil, connect.NewError(connect.CodeUnimplemented, errors.New("ermite.MirrorService.SyncMirror is not implemented")) }