server

Documentation

Overview

* Package responsible for reciving incomming mount requests from the driver. * * This package acts as the high level orchestrator; unpacking the message and * calling the provider implementation to fetch the secrets. *

Index

• Variables
• type CSIDriverProviderServer
  • func NewServer(secretProviderFact provider.ProviderFactoryFactory, ...) (srv *CSIDriverProviderServer, e error)
  • func (s *CSIDriverProviderServer) Mount(ctx context.Context, req *v1alpha1.MountRequest) (response *v1alpha1.MountResponse, e error)
  • func (s *CSIDriverProviderServer) Version(ctx context.Context, req *v1alpha1.VersionRequest) (*v1alpha1.VersionResponse, error)

Variables

var Version string

Version filled in by Makefile during build.

Types

type CSIDriverProviderServer

type CSIDriverProviderServer struct {
	*grpc.Server
	// contains filtered or unexported fields
}

A Secrets Store CSI Driver provider implementation for AWS Secrets Manager and SSM Parameter Store.

This server receives mount requests and then retreives and stores the secrets from that request. The details of what secrets are required and where to store them are in the request. The secrets will be retrieved using the AWS credentials of the IAM role associated with the pod. If there is a failure during the mount of any one secret no secrets are written to the mount point.

func NewServer

func NewServer(
	secretProviderFact provider.ProviderFactoryFactory,
	k8client k8sv1.CoreV1Interface,
	driverWriteSecrets bool,
) (srv *CSIDriverProviderServer, e error)

Factory function to create the server to handle incoming mount requests.

func (*CSIDriverProviderServer) Mount

func (s *CSIDriverProviderServer) Mount(ctx context.Context, req *v1alpha1.MountRequest) (response *v1alpha1.MountResponse, e error)

Mount handles each incomming mount request.

The provider will fetch the secret value from the secret provider (Parameter Store or Secrets Manager) and write the secrets to the mount point. The version ids of the secrets are then returned to the driver.

func (*CSIDriverProviderServer) Version

func (s *CSIDriverProviderServer) Version(ctx context.Context, req *v1alpha1.VersionRequest) (*v1alpha1.VersionResponse, error)

Return the provider plugin version information to the driver.