kubernetes/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go

const testProviderName

type testSocket

// newEndpoint constructs a unique name for a Linux Abstract Socket to be used in a test.
// This package uses Linux Domain Sockets to remove the need for clean-up of socket files.
func newEndpoint() *testSocket {}

// TestKMSPluginLateStart tests the scenario where kms-plugin pod/container starts after kube-apiserver pod/container.
// Since the Dial to kms-plugin is non-blocking we expect the construction of gRPC service to succeed even when
// kms-plugin is not yet up - dialing happens in the background.
func TestKMSPluginLateStart(t *testing.T) {}

func TestTimeouts(t *testing.T) {}

// TestIntermittentConnectionLoss tests the scenario where the connection with kms-plugin is intermittently lost.
func TestIntermittentConnectionLoss(t *testing.T) {}

// Normal encryption and decryption operation.
func TestGRPCService(t *testing.T) {}

// Normal encryption and decryption operation by multiple go-routines.
func TestGRPCServiceConcurrentAccess(t *testing.T) {}

func destroyService(service kmsservice.Service) {}

// Test all those invalid configuration for KMS provider.
func TestInvalidConfiguration(t *testing.T) {}

func TestKMSOperationsMetric(t *testing.T) {}

func testContext(t *testing.T) context.Context {}