plugin

Documentation

Index

• Constants
• func GetMetaData(resource string) string
• type KMSServer
  • func New(pathToUnixSocketFile, keyID string) (*KMSServer, error)
  • func (s *KMSServer) Decrypt(ctx context.Context, request *k8spb.DecryptRequest) (*k8spb.DecryptResponse, error)
  • func (s *KMSServer) Encrypt(ctx context.Context, request *k8spb.EncryptRequest) (*k8spb.EncryptResponse, error)
  • func (s *KMSServer) StartRPCServer() (*grpc.Server, chan error)
  • func (s *KMSServer) Version(ctx context.Context, request *k8spb.VersionRequest) (*k8spb.VersionResponse, error)

Constants

const (

	// Version is the current kms api version
	Version = "v1beta1"

	// HTTPS protocol
	HTTPS = "https"
)

const (
	//MetadataURL is the ECS metadata server addr
	MetadataURL = "http://100.100.100.200/latest/meta-data/"
	RegionID    = "region-id"
)

Functions

func GetMetaData

func GetMetaData(resource string) string

GetMetaData return host regionid, zoneid

Types

type KMSServer

type KMSServer struct {
	net.Listener
	*grpc.Server
	// contains filtered or unexported fields
}

KMSServer is t CloudKMS plugin for K8S.

func New

func New(pathToUnixSocketFile, keyID string) (*KMSServer, error)

New creates an instance of the KMS Service Server.

func (*KMSServer) Decrypt

func (s *KMSServer) Decrypt(ctx context.Context, request *k8spb.DecryptRequest) (*k8spb.DecryptResponse, error)

Decrypt execute decryption operation in KMS providers.

func (*KMSServer) Encrypt

func (s *KMSServer) Encrypt(ctx context.Context, request *k8spb.EncryptRequest) (*k8spb.EncryptResponse, error)

Encrypt execute encryption operation in KMS providers.

func (*KMSServer) StartRPCServer

func (s *KMSServer) StartRPCServer() (*grpc.Server, chan error)

StartRPCServer starts gRPC server or dies.

func (*KMSServer) Version

func (s *KMSServer) Version(ctx context.Context, request *k8spb.VersionRequest) (*k8spb.VersionResponse, error)

Version return the current api version