plugin

Documentation

Index

• type PluginV1
  • func NewPluginV1(vc *vault.Client) *PluginV1
  • func (p *PluginV1) Decrypt(ctx context.Context, request *pb.DecryptRequest) (*pb.DecryptResponse, error)
  • func (p *PluginV1) Encrypt(ctx context.Context, request *pb.EncryptRequest) (*pb.EncryptResponse, error)
  • func (p *PluginV1) Health() error
  • func (p *PluginV1) Register(s *grpc.Server)
  • func (p *PluginV1) Version(ctx context.Context, request *pb.VersionRequest) (*pb.VersionResponse, error)
• type PluginV2
  • func NewPluginV2(vc *vault.Client) *PluginV2
  • func (p *PluginV2) Decrypt(ctx context.Context, request *pb.DecryptRequest) (*pb.DecryptResponse, error)
  • func (p *PluginV2) Encrypt(ctx context.Context, request *pb.EncryptRequest) (*pb.EncryptResponse, error)
  • func (p *PluginV2) Health() error
  • func (p *PluginV2) Register(s *grpc.Server)
  • func (p *PluginV2) Status(ctx context.Context, _ *pb.StatusRequest) (*pb.StatusResponse, error)

Types

type PluginV1

type PluginV1 struct {
	*vault.Client
}

PluginV1 a kms plugin wrapper.

func NewPluginV1

func NewPluginV1(vc *vault.Client) *PluginV1

NewPluginV1 returns a kms wrapper.

func (*PluginV1) Decrypt

func (p *PluginV1) Decrypt(ctx context.Context, request *pb.DecryptRequest) (*pb.DecryptResponse, error)

nolint: staticcheck

func (*PluginV1) Encrypt

func (p *PluginV1) Encrypt(ctx context.Context, request *pb.EncryptRequest) (*pb.EncryptResponse, error)

nolint: staticcheck

func (*PluginV1) Health

func (p *PluginV1) Health() error

Health sends a simple plaintext for encryption and then compares the decrypted value. nolint: staticcheck

func (*PluginV1) Register

func (p *PluginV1) Register(s *grpc.Server)

nolint: staticcheck

func (*PluginV1) Version

func (p *PluginV1) Version(ctx context.Context, request *pb.VersionRequest) (*pb.VersionResponse, error)

nolint: staticcheck

type PluginV2

type PluginV2 struct {
	*vault.Client
}

PluginV2 a kms plugin wrapper.

func NewPluginV2

func NewPluginV2(vc *vault.Client) *PluginV2

PluginV2 returns a kms wrapper.

func (*PluginV2) Decrypt

func (p *PluginV2) Decrypt(ctx context.Context, request *pb.DecryptRequest) (*pb.DecryptResponse, error)

func (*PluginV2) Encrypt

func (p *PluginV2) Encrypt(ctx context.Context, request *pb.EncryptRequest) (*pb.EncryptResponse, error)

func (*PluginV2) Health

func (p *PluginV2) Health() error

Health sends a simple plaintext for encryption and then compares the decrypted value.

func (*PluginV2) Register

func (p *PluginV2) Register(s *grpc.Server)

func (*PluginV2) Status

func (p *PluginV2) Status(ctx context.Context, _ *pb.StatusRequest) (*pb.StatusResponse, error)

Status performs a simple health check and returns ok if encryption / decryption was successful https://kubernetes.io/docs/tasks/administer-cluster/kms-provider/#developing-a-kms-plugin-gRPC-server-notes-kms-v2