csr

Documentation

Index

• Constants
• Variables
• func WatchCastAINodeCSRs(ctx context.Context, log logrus.FieldLogger, client kubernetes.Interface, ...)
• type ApprovalManager
  • func NewApprovalManager(log logrus.FieldLogger, clientset kubernetes.Interface) *ApprovalManager
  • func (h *ApprovalManager) Start(ctx context.Context)
  • func (h *ApprovalManager) Stop()
• type Certificate
  • func GetCertificateByNodeName(ctx context.Context, client kubernetes.Interface, nodeName string) (*Certificate, error)
  • func (c *Certificate) ApproveCertificate(ctx context.Context, client kubernetes.Interface) (*Certificate, error)
  • func (c *Certificate) Approved() bool
  • func (c *Certificate) DeleteCertificate(ctx context.Context, client kubernetes.Interface) error
  • func (c *Certificate) NewCSR(ctx context.Context, client kubernetes.Interface) (*Certificate, error)
  • func (c *Certificate) Validate() error

Constants

const (
	ReasonApproved = "AutoApproved"
)

Variables

var ErrNodeCertificateNotFound = errors.New("node certificate not found")

Functions

func WatchCastAINodeCSRs

func WatchCastAINodeCSRs(ctx context.Context, log logrus.FieldLogger, client kubernetes.Interface, c chan *Certificate)

Types

type ApprovalManager

type ApprovalManager struct {
	// contains filtered or unexported fields
}

func NewApprovalManager

func NewApprovalManager(log logrus.FieldLogger, clientset kubernetes.Interface) *ApprovalManager

func (*ApprovalManager) Start

func (h *ApprovalManager) Start(ctx context.Context)

func (*ApprovalManager) Stop

func (h *ApprovalManager) Stop()

type Certificate

type Certificate struct {
	Name           string
	RequestingUser string
	// contains filtered or unexported fields
}

Certificate wraps v1 and v1beta1 csr.

func GetCertificateByNodeName

func GetCertificateByNodeName(ctx context.Context, client kubernetes.Interface, nodeName string) (*Certificate, error)

GetCertificateByNodeName lists all csr objects and parses request pem encoded cert to find it by node name.

func (*Certificate) ApproveCertificate

func (c *Certificate) ApproveCertificate(ctx context.Context, client kubernetes.Interface) (*Certificate, error)

ApproveCertificate approves csr.

func (*Certificate) Approved

func (c *Certificate) Approved() bool

func (*Certificate) DeleteCertificate

func (c *Certificate) DeleteCertificate(ctx context.Context, client kubernetes.Interface) error

DeleteCertificate deletes csr.

func (*Certificate) NewCSR

func (c *Certificate) NewCSR(ctx context.Context, client kubernetes.Interface) (*Certificate, error)

NewCSR creates new csr.

func (*Certificate) Validate

func (c *Certificate) Validate() error