kubernetes/staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/kms_plugin_mock.go

const unixProtocol …

const kmsapiVersion …

type Base64Plugin …

// NewBase64Plugin is a constructor for Base64Plugin.
func NewBase64Plugin(t *testing.T, socketPath string) *Base64Plugin { … }

// waitForBase64PluginToBeUp waits until the plugin is ready to serve requests.
func waitForBase64PluginToBeUp(plugin *Base64Plugin) error { … }

// LastEncryptRequest returns the last EncryptRequest.Plain sent to the plugin.
func (s *Base64Plugin) LastEncryptRequest() []byte { … }

// SetVersion sets the version of kms-plugin.
func (s *Base64Plugin) SetVersion(ver string) { … }

// start starts plugin's gRPC service.
func (s *Base64Plugin) start() error { … }

// CleanUp stops gRPC server and the underlying listener.
func (s *Base64Plugin) CleanUp() { … }

// EnterFailedState places the plugin into failed state.
func (s *Base64Plugin) EnterFailedState() { … }

// ExitFailedState removes the plugin from the failed state.
func (s *Base64Plugin) ExitFailedState() { … }

// Version returns the version of the kms-plugin.
func (s *Base64Plugin) Version(ctx context.Context, request *kmsapi.VersionRequest) (*kmsapi.VersionResponse, error) { … }

// Decrypt performs base64 decoding of the payload of kms.DecryptRequest.
func (s *Base64Plugin) Decrypt(ctx context.Context, request *kmsapi.DecryptRequest) (*kmsapi.DecryptResponse, error) { … }

// Encrypt performs base64 encoding of the payload of kms.EncryptRequest.
func (s *Base64Plugin) Encrypt(ctx context.Context, request *kmsapi.EncryptRequest) (*kmsapi.EncryptResponse, error) { … }