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

const unixProtocol …

const kmsapiVersion …

type Base64Plugin …

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

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

// waitForBase64PluginToBeUpdated waits until the plugin updates keyID.
func WaitForBase64PluginToBeUpdated(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() { … }

// Update keyID for the plugin.
func (s *Base64Plugin) UpdateKeyID() { … }

// Status returns the status of the kms-plugin.
func (s *Base64Plugin) Status(ctx context.Context, request *kmsapi.StatusRequest) (*kmsapi.StatusResponse, 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) { … }