diff --git a/pkg/rpc/ctrl/BUILD.bazel b/pkg/rpc/ctrl/BUILD.bazel deleted file mode 100644 index 3ea7c2a448..0000000000 --- a/pkg/rpc/ctrl/BUILD.bazel +++ /dev/null @@ -1,21 +0,0 @@ -load("@rules_go//go:def.bzl", "go_library") - -go_library( - name = "ctrl", - srcs = [ - "acme_generated.go", - "cluster_generated.go", - "custom_domain_generated.go", - "deployment_generated.go", - "environment_generated.go", - "openapi_generated.go", - "service_generated.go", - ], - importpath = "github.com/unkeyed/unkey/pkg/rpc/ctrl", - visibility = ["//visibility:public"], - deps = [ - "//gen/proto/ctrl/v1:ctrl", - "//gen/proto/ctrl/v1/ctrlv1connect", - "@com_connectrpc_connect//:connect", - ], -) diff --git a/pkg/rpc/ctrl/acme_generated.go b/pkg/rpc/ctrl/acme_generated.go deleted file mode 100644 index cc1250ad12..0000000000 --- a/pkg/rpc/ctrl/acme_generated.go +++ /dev/null @@ -1,37 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// AcmeServiceClient wraps ctrlv1connect.AcmeServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type AcmeServiceClient interface { - VerifyCertificate(ctx context.Context, req *v1.VerifyCertificateRequest) (*v1.VerifyCertificateResponse, error) -} - -var _ AcmeServiceClient = (*ConnectAcmeServiceClient)(nil) - -// ConnectAcmeServiceClient adapts a ctrlv1connect.AcmeServiceClient to the simplified AcmeServiceClient interface. -type ConnectAcmeServiceClient struct { - inner ctrlv1connect.AcmeServiceClient -} - -// NewConnectAcmeServiceClient creates a new ConnectAcmeServiceClient. -func NewConnectAcmeServiceClient(inner ctrlv1connect.AcmeServiceClient) *ConnectAcmeServiceClient { - return &ConnectAcmeServiceClient{inner: inner} -} - -func (c *ConnectAcmeServiceClient) VerifyCertificate(ctx context.Context, req *v1.VerifyCertificateRequest) (*v1.VerifyCertificateResponse, error) { - resp, err := c.inner.VerifyCertificate(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/ctrl/cluster_generated.go b/pkg/rpc/ctrl/cluster_generated.go deleted file mode 100644 index c0fbbc5293..0000000000 --- a/pkg/rpc/ctrl/cluster_generated.go +++ /dev/null @@ -1,88 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// ClusterServiceClient wraps ctrlv1connect.ClusterServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type ClusterServiceClient interface { - WatchDeployments(ctx context.Context, req *v1.WatchDeploymentsRequest) (*connect.ServerStreamForClient[v1.DeploymentState], error) - WatchSentinels(ctx context.Context, req *v1.WatchSentinelsRequest) (*connect.ServerStreamForClient[v1.SentinelState], error) - GetDesiredSentinelState(ctx context.Context, req *v1.GetDesiredSentinelStateRequest) (*v1.SentinelState, error) - ReportSentinelStatus(ctx context.Context, req *v1.ReportSentinelStatusRequest) (*v1.ReportSentinelStatusResponse, error) - GetDesiredDeploymentState(ctx context.Context, req *v1.GetDesiredDeploymentStateRequest) (*v1.DeploymentState, error) - ReportDeploymentStatus(ctx context.Context, req *v1.ReportDeploymentStatusRequest) (*v1.ReportDeploymentStatusResponse, error) - WatchCiliumNetworkPolicies(ctx context.Context, req *v1.WatchCiliumNetworkPoliciesRequest) (*connect.ServerStreamForClient[v1.CiliumNetworkPolicyState], error) - GetDesiredCiliumNetworkPolicyState(ctx context.Context, req *v1.GetDesiredCiliumNetworkPolicyStateRequest) (*v1.CiliumNetworkPolicyState, error) -} - -var _ ClusterServiceClient = (*ConnectClusterServiceClient)(nil) - -// ConnectClusterServiceClient adapts a ctrlv1connect.ClusterServiceClient to the simplified ClusterServiceClient interface. -type ConnectClusterServiceClient struct { - inner ctrlv1connect.ClusterServiceClient -} - -// NewConnectClusterServiceClient creates a new ConnectClusterServiceClient. -func NewConnectClusterServiceClient(inner ctrlv1connect.ClusterServiceClient) *ConnectClusterServiceClient { - return &ConnectClusterServiceClient{inner: inner} -} - -func (c *ConnectClusterServiceClient) WatchDeployments(ctx context.Context, req *v1.WatchDeploymentsRequest) (*connect.ServerStreamForClient[v1.DeploymentState], error) { - return c.inner.WatchDeployments(ctx, connect.NewRequest(req)) -} - -func (c *ConnectClusterServiceClient) WatchSentinels(ctx context.Context, req *v1.WatchSentinelsRequest) (*connect.ServerStreamForClient[v1.SentinelState], error) { - return c.inner.WatchSentinels(ctx, connect.NewRequest(req)) -} - -func (c *ConnectClusterServiceClient) GetDesiredSentinelState(ctx context.Context, req *v1.GetDesiredSentinelStateRequest) (*v1.SentinelState, error) { - resp, err := c.inner.GetDesiredSentinelState(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectClusterServiceClient) ReportSentinelStatus(ctx context.Context, req *v1.ReportSentinelStatusRequest) (*v1.ReportSentinelStatusResponse, error) { - resp, err := c.inner.ReportSentinelStatus(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectClusterServiceClient) GetDesiredDeploymentState(ctx context.Context, req *v1.GetDesiredDeploymentStateRequest) (*v1.DeploymentState, error) { - resp, err := c.inner.GetDesiredDeploymentState(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectClusterServiceClient) ReportDeploymentStatus(ctx context.Context, req *v1.ReportDeploymentStatusRequest) (*v1.ReportDeploymentStatusResponse, error) { - resp, err := c.inner.ReportDeploymentStatus(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectClusterServiceClient) WatchCiliumNetworkPolicies(ctx context.Context, req *v1.WatchCiliumNetworkPoliciesRequest) (*connect.ServerStreamForClient[v1.CiliumNetworkPolicyState], error) { - return c.inner.WatchCiliumNetworkPolicies(ctx, connect.NewRequest(req)) -} - -func (c *ConnectClusterServiceClient) GetDesiredCiliumNetworkPolicyState(ctx context.Context, req *v1.GetDesiredCiliumNetworkPolicyStateRequest) (*v1.CiliumNetworkPolicyState, error) { - resp, err := c.inner.GetDesiredCiliumNetworkPolicyState(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/ctrl/custom_domain_generated.go b/pkg/rpc/ctrl/custom_domain_generated.go deleted file mode 100644 index 707e13681c..0000000000 --- a/pkg/rpc/ctrl/custom_domain_generated.go +++ /dev/null @@ -1,55 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// CustomDomainServiceClient wraps ctrlv1connect.CustomDomainServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type CustomDomainServiceClient interface { - AddCustomDomain(ctx context.Context, req *v1.AddCustomDomainRequest) (*v1.AddCustomDomainResponse, error) - DeleteCustomDomain(ctx context.Context, req *v1.DeleteCustomDomainRequest) (*v1.DeleteCustomDomainResponse, error) - RetryVerification(ctx context.Context, req *v1.RetryVerificationRequest) (*v1.RetryVerificationResponse, error) -} - -var _ CustomDomainServiceClient = (*ConnectCustomDomainServiceClient)(nil) - -// ConnectCustomDomainServiceClient adapts a ctrlv1connect.CustomDomainServiceClient to the simplified CustomDomainServiceClient interface. -type ConnectCustomDomainServiceClient struct { - inner ctrlv1connect.CustomDomainServiceClient -} - -// NewConnectCustomDomainServiceClient creates a new ConnectCustomDomainServiceClient. -func NewConnectCustomDomainServiceClient(inner ctrlv1connect.CustomDomainServiceClient) *ConnectCustomDomainServiceClient { - return &ConnectCustomDomainServiceClient{inner: inner} -} - -func (c *ConnectCustomDomainServiceClient) AddCustomDomain(ctx context.Context, req *v1.AddCustomDomainRequest) (*v1.AddCustomDomainResponse, error) { - resp, err := c.inner.AddCustomDomain(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectCustomDomainServiceClient) DeleteCustomDomain(ctx context.Context, req *v1.DeleteCustomDomainRequest) (*v1.DeleteCustomDomainResponse, error) { - resp, err := c.inner.DeleteCustomDomain(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectCustomDomainServiceClient) RetryVerification(ctx context.Context, req *v1.RetryVerificationRequest) (*v1.RetryVerificationResponse, error) { - resp, err := c.inner.RetryVerification(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/ctrl/deployment_generated.go b/pkg/rpc/ctrl/deployment_generated.go deleted file mode 100644 index 0a5ef4cc6a..0000000000 --- a/pkg/rpc/ctrl/deployment_generated.go +++ /dev/null @@ -1,64 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// DeployServiceClient wraps ctrlv1connect.DeployServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type DeployServiceClient interface { - CreateDeployment(ctx context.Context, req *v1.CreateDeploymentRequest) (*v1.CreateDeploymentResponse, error) - GetDeployment(ctx context.Context, req *v1.GetDeploymentRequest) (*v1.GetDeploymentResponse, error) - Rollback(ctx context.Context, req *v1.RollbackRequest) (*v1.RollbackResponse, error) - Promote(ctx context.Context, req *v1.PromoteRequest) (*v1.PromoteResponse, error) -} - -var _ DeployServiceClient = (*ConnectDeployServiceClient)(nil) - -// ConnectDeployServiceClient adapts a ctrlv1connect.DeployServiceClient to the simplified DeployServiceClient interface. -type ConnectDeployServiceClient struct { - inner ctrlv1connect.DeployServiceClient -} - -// NewConnectDeployServiceClient creates a new ConnectDeployServiceClient. -func NewConnectDeployServiceClient(inner ctrlv1connect.DeployServiceClient) *ConnectDeployServiceClient { - return &ConnectDeployServiceClient{inner: inner} -} - -func (c *ConnectDeployServiceClient) CreateDeployment(ctx context.Context, req *v1.CreateDeploymentRequest) (*v1.CreateDeploymentResponse, error) { - resp, err := c.inner.CreateDeployment(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectDeployServiceClient) GetDeployment(ctx context.Context, req *v1.GetDeploymentRequest) (*v1.GetDeploymentResponse, error) { - resp, err := c.inner.GetDeployment(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectDeployServiceClient) Rollback(ctx context.Context, req *v1.RollbackRequest) (*v1.RollbackResponse, error) { - resp, err := c.inner.Rollback(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectDeployServiceClient) Promote(ctx context.Context, req *v1.PromoteRequest) (*v1.PromoteResponse, error) { - resp, err := c.inner.Promote(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/ctrl/environment_generated.go b/pkg/rpc/ctrl/environment_generated.go deleted file mode 100644 index 467f73f6c7..0000000000 --- a/pkg/rpc/ctrl/environment_generated.go +++ /dev/null @@ -1,37 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// EnvironmentServiceClient wraps ctrlv1connect.EnvironmentServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type EnvironmentServiceClient interface { - CreateEnvironment(ctx context.Context, req *v1.CreateEnvironmentRequest) (*v1.CreateEnvironmentResponse, error) -} - -var _ EnvironmentServiceClient = (*ConnectEnvironmentServiceClient)(nil) - -// ConnectEnvironmentServiceClient adapts a ctrlv1connect.EnvironmentServiceClient to the simplified EnvironmentServiceClient interface. -type ConnectEnvironmentServiceClient struct { - inner ctrlv1connect.EnvironmentServiceClient -} - -// NewConnectEnvironmentServiceClient creates a new ConnectEnvironmentServiceClient. -func NewConnectEnvironmentServiceClient(inner ctrlv1connect.EnvironmentServiceClient) *ConnectEnvironmentServiceClient { - return &ConnectEnvironmentServiceClient{inner: inner} -} - -func (c *ConnectEnvironmentServiceClient) CreateEnvironment(ctx context.Context, req *v1.CreateEnvironmentRequest) (*v1.CreateEnvironmentResponse, error) { - resp, err := c.inner.CreateEnvironment(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/ctrl/openapi_generated.go b/pkg/rpc/ctrl/openapi_generated.go deleted file mode 100644 index 927200e3df..0000000000 --- a/pkg/rpc/ctrl/openapi_generated.go +++ /dev/null @@ -1,37 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// OpenApiServiceClient wraps ctrlv1connect.OpenApiServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type OpenApiServiceClient interface { - GetOpenApiDiff(ctx context.Context, req *v1.GetOpenApiDiffRequest) (*v1.GetOpenApiDiffResponse, error) -} - -var _ OpenApiServiceClient = (*ConnectOpenApiServiceClient)(nil) - -// ConnectOpenApiServiceClient adapts a ctrlv1connect.OpenApiServiceClient to the simplified OpenApiServiceClient interface. -type ConnectOpenApiServiceClient struct { - inner ctrlv1connect.OpenApiServiceClient -} - -// NewConnectOpenApiServiceClient creates a new ConnectOpenApiServiceClient. -func NewConnectOpenApiServiceClient(inner ctrlv1connect.OpenApiServiceClient) *ConnectOpenApiServiceClient { - return &ConnectOpenApiServiceClient{inner: inner} -} - -func (c *ConnectOpenApiServiceClient) GetOpenApiDiff(ctx context.Context, req *v1.GetOpenApiDiffRequest) (*v1.GetOpenApiDiffResponse, error) { - resp, err := c.inner.GetOpenApiDiff(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/ctrl/service_generated.go b/pkg/rpc/ctrl/service_generated.go deleted file mode 100644 index 46716a5bab..0000000000 --- a/pkg/rpc/ctrl/service_generated.go +++ /dev/null @@ -1,37 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package ctrl - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/ctrl/v1" - "github.com/unkeyed/unkey/gen/proto/ctrl/v1/ctrlv1connect" -) - -// CtrlServiceClient wraps ctrlv1connect.CtrlServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type CtrlServiceClient interface { - Liveness(ctx context.Context, req *v1.LivenessRequest) (*v1.LivenessResponse, error) -} - -var _ CtrlServiceClient = (*ConnectCtrlServiceClient)(nil) - -// ConnectCtrlServiceClient adapts a ctrlv1connect.CtrlServiceClient to the simplified CtrlServiceClient interface. -type ConnectCtrlServiceClient struct { - inner ctrlv1connect.CtrlServiceClient -} - -// NewConnectCtrlServiceClient creates a new ConnectCtrlServiceClient. -func NewConnectCtrlServiceClient(inner ctrlv1connect.CtrlServiceClient) *ConnectCtrlServiceClient { - return &ConnectCtrlServiceClient{inner: inner} -} - -func (c *ConnectCtrlServiceClient) Liveness(ctx context.Context, req *v1.LivenessRequest) (*v1.LivenessResponse, error) { - resp, err := c.inner.Liveness(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/krane/BUILD.bazel b/pkg/rpc/krane/BUILD.bazel deleted file mode 100644 index bb067a2f75..0000000000 --- a/pkg/rpc/krane/BUILD.bazel +++ /dev/null @@ -1,13 +0,0 @@ -load("@rules_go//go:def.bzl", "go_library") - -go_library( - name = "krane", - srcs = ["secrets_generated.go"], - importpath = "github.com/unkeyed/unkey/pkg/rpc/krane", - visibility = ["//visibility:public"], - deps = [ - "//gen/proto/krane/v1:krane", - "//gen/proto/krane/v1/kranev1connect", - "@com_connectrpc_connect//:connect", - ], -) diff --git a/pkg/rpc/krane/secrets_generated.go b/pkg/rpc/krane/secrets_generated.go deleted file mode 100644 index c327f61ff9..0000000000 --- a/pkg/rpc/krane/secrets_generated.go +++ /dev/null @@ -1,37 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package krane - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/krane/v1" - "github.com/unkeyed/unkey/gen/proto/krane/v1/kranev1connect" -) - -// SecretsServiceClient wraps kranev1connect.SecretsServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type SecretsServiceClient interface { - DecryptSecretsBlob(ctx context.Context, req *v1.DecryptSecretsBlobRequest) (*v1.DecryptSecretsBlobResponse, error) -} - -var _ SecretsServiceClient = (*ConnectSecretsServiceClient)(nil) - -// ConnectSecretsServiceClient adapts a kranev1connect.SecretsServiceClient to the simplified SecretsServiceClient interface. -type ConnectSecretsServiceClient struct { - inner kranev1connect.SecretsServiceClient -} - -// NewConnectSecretsServiceClient creates a new ConnectSecretsServiceClient. -func NewConnectSecretsServiceClient(inner kranev1connect.SecretsServiceClient) *ConnectSecretsServiceClient { - return &ConnectSecretsServiceClient{inner: inner} -} - -func (c *ConnectSecretsServiceClient) DecryptSecretsBlob(ctx context.Context, req *v1.DecryptSecretsBlobRequest) (*v1.DecryptSecretsBlobResponse, error) { - resp, err := c.inner.DecryptSecretsBlob(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} diff --git a/pkg/rpc/vault/BUILD.bazel b/pkg/rpc/vault/BUILD.bazel deleted file mode 100644 index 75e377f6f5..0000000000 --- a/pkg/rpc/vault/BUILD.bazel +++ /dev/null @@ -1,13 +0,0 @@ -load("@rules_go//go:def.bzl", "go_library") - -go_library( - name = "vault", - srcs = ["service_generated.go"], - importpath = "github.com/unkeyed/unkey/pkg/rpc/vault", - visibility = ["//visibility:public"], - deps = [ - "//gen/proto/vault/v1:vault", - "//gen/proto/vault/v1/vaultv1connect", - "@com_connectrpc_connect//:connect", - ], -) diff --git a/pkg/rpc/vault/service_generated.go b/pkg/rpc/vault/service_generated.go deleted file mode 100644 index 9c52b6433d..0000000000 --- a/pkg/rpc/vault/service_generated.go +++ /dev/null @@ -1,64 +0,0 @@ -// Code generated by generate-rpc-clients. DO NOT EDIT. - -package vault - -import ( - "context" - - "connectrpc.com/connect" - v1 "github.com/unkeyed/unkey/gen/proto/vault/v1" - "github.com/unkeyed/unkey/gen/proto/vault/v1/vaultv1connect" -) - -// VaultServiceClient wraps vaultv1connect.VaultServiceClient with simplified signatures. -// Request and response types are plain protobuf messages without connect wrappers. -type VaultServiceClient interface { - Liveness(ctx context.Context, req *v1.LivenessRequest) (*v1.LivenessResponse, error) - Encrypt(ctx context.Context, req *v1.EncryptRequest) (*v1.EncryptResponse, error) - Decrypt(ctx context.Context, req *v1.DecryptRequest) (*v1.DecryptResponse, error) - ReEncrypt(ctx context.Context, req *v1.ReEncryptRequest) (*v1.ReEncryptResponse, error) -} - -var _ VaultServiceClient = (*ConnectVaultServiceClient)(nil) - -// ConnectVaultServiceClient adapts a vaultv1connect.VaultServiceClient to the simplified VaultServiceClient interface. -type ConnectVaultServiceClient struct { - inner vaultv1connect.VaultServiceClient -} - -// NewConnectVaultServiceClient creates a new ConnectVaultServiceClient. -func NewConnectVaultServiceClient(inner vaultv1connect.VaultServiceClient) *ConnectVaultServiceClient { - return &ConnectVaultServiceClient{inner: inner} -} - -func (c *ConnectVaultServiceClient) Liveness(ctx context.Context, req *v1.LivenessRequest) (*v1.LivenessResponse, error) { - resp, err := c.inner.Liveness(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectVaultServiceClient) Encrypt(ctx context.Context, req *v1.EncryptRequest) (*v1.EncryptResponse, error) { - resp, err := c.inner.Encrypt(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectVaultServiceClient) Decrypt(ctx context.Context, req *v1.DecryptRequest) (*v1.DecryptResponse, error) { - resp, err := c.inner.Decrypt(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -} - -func (c *ConnectVaultServiceClient) ReEncrypt(ctx context.Context, req *v1.ReEncryptRequest) (*v1.ReEncryptResponse, error) { - resp, err := c.inner.ReEncrypt(ctx, connect.NewRequest(req)) - if err != nil { - return nil, err - } - return resp.Msg, nil -}