manager

Oct 21, 2022

Changes in this version

type Manager

+ func (m *Manager) ManageVolumeImmediate(ctx context.Context, volumeID string) (managed bool, err error)

type Options

+ RenewalBackoffConfig *wait.Backoff

Mar 29, 2022

Changes in this version

+ func AlwaysReadyToRequest(_ metadata.Metadata) (bool, string)

type Manager

+ func (m *Manager) IsVolumeReadyToRequest(volumeID string) (bool, string)

type Options

+ ReadyToRequest ReadyToRequestFunc

+ type ReadyToRequestFunc func(meta metadata.Metadata) (bool, string)

Aug 16, 2021

Changes in this version

+ type CertificateRequestBundle struct

+ Annotations map[string]string

+ Duration time.Duration

+ IsCA bool

+ IssuerRef cmmeta.ObjectReference

+ Namespace string

+ Request *x509.CertificateRequest

+ Usages []cmapi.KeyUsage

+ type ClientForMetadataFunc func(meta metadata.Metadata) (cmclient.Interface, error)

+ type GeneratePrivateKeyFunc func(meta metadata.Metadata) (crypto.PrivateKey, error)

+ type GenerateRequestFunc func(meta metadata.Metadata) (*CertificateRequestBundle, error)

+ type Manager struct

+ func NewManager(opts Options) (*Manager, error)

+ func NewManagerOrDie(opts Options) *Manager

+ func (m *Manager) IsVolumeReady(volumeID string) bool

+ func (m *Manager) ManageVolume(volumeID string) error

+ func (m *Manager) Stop()

+ func (m *Manager) UnmanageVolume(volumeID string)

+ type Options struct

+ Client cmclient.Interface

+ ClientForMetadata ClientForMetadataFunc

+ Clock clock.Clock

+ GeneratePrivateKey GeneratePrivateKeyFunc

+ GenerateRequest GenerateRequestFunc

+ Log logr.Logger

+ MaxRequestsPerVolume int

+ MetadataReader storage.MetadataReader

+ NodeID string

+ SignRequest SignRequestFunc

+ WriteKeypair WriteKeypairFunc

+ type SignRequestFunc func(meta metadata.Metadata, key crypto.PrivateKey, ...) (pem []byte, err error)

+ type WriteKeypairFunc func(meta metadata.Metadata, key crypto.PrivateKey, chain []byte, ca []byte) error