util

Documentation

Index

• Constants
• func EncodePrivateKeyToPEM(privateKey *rsa.PrivateKey) []byte
• func GeneratePrivateKey(bitSize int) (*rsa.PrivateKey, error)
• func GeneratePublicKey(publicKey *rsa.PublicKey) ([]byte, error)
• func VirtClientUpdateVmi(ctx context.Context, client rest.Interface, ...) error
• type CountingReader
  • func (r *CountingReader) Close() error
  • func (r *CountingReader) Read(p []byte) (n int, err error)

Constants

const (
	RemovedDataVolumesAnnotationKey = prefix + "/removedDataVolumes"
	AnnotationMigrationTarget       = prefix + "/migrationTargetNodeName"
	AnnotationMigrationUID          = prefix + "/migrationUID"
	AnnotationMigrationState        = prefix + "/migrationState"
	AnnotationTimestamp             = prefix + "/timestamp"
)

Functions

func EncodePrivateKeyToPEM

func EncodePrivateKeyToPEM(privateKey *rsa.PrivateKey) []byte

EncodePrivateKeyToPEM encodes Private Key from RSA to PEM format

func GeneratePrivateKey

func GeneratePrivateKey(bitSize int) (*rsa.PrivateKey, error)

GeneratePrivateKey creates a RSA Private Key of specified byte size

func GeneratePublicKey

func GeneratePublicKey(publicKey *rsa.PublicKey) ([]byte, error)

GeneratePublicKey take a rsa.PublicKey and return bytes suitable for writing to .pub file returns in the format "ssh-rsa ..."

func VirtClientUpdateVmi

func VirtClientUpdateVmi(ctx context.Context, client rest.Interface, managementNamespace, namespace, name string, obj runtime.Object) error

Types

type CountingReader

type CountingReader struct {
	Reader  io.ReadCloser
	Current int64
	// Total can be negative meaning the total size is unknown
	Total int64
	Done  bool
}

CountingReader is a reader that keeps track of how much has been read

func (*CountingReader) Close

func (r *CountingReader) Close() error

Close closes the stream

func (*CountingReader) Read

func (r *CountingReader) Read(p []byte) (n int, err error)

Read reads bytes from the stream and updates the prometheus clone_progress metric according to the progress.