cephmoncluster

Documentation

Index

• Variables
• func Add(mgr manager.Manager) error
• func EncodeKey(key []byte, t time.Time) (string, error)
• type Keyring
  • func (k Keyring) CreateKeyring() string
  • func (k *Keyring) GenerateKey() error
  • func (k *Keyring) GetSecret(cluster string) *corev1.Secret
  • func (k *Keyring) GetSecretName(cluster string) string
• type MonEventMapper
  • func (m *MonEventMapper) Map(o handler.MapObject) []reconcile.Request
• type ReconcileCephMonCluster
  • func (r *ReconcileCephMonCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)

Variables

var (
	CLIENT_ADMIN_KEYRING = Keyring{
		Entity: "client.admin",
		Caps: map[string]string{
			"mds": "allow",
			"mon": "allow *",
			"osd": "allow *",
		},
	}
	MON_KEYRING = Keyring{
		Entity: "mon.",
		Caps: map[string]string{
			"mon": "allow *",
		},
	}
)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new CephMonCluster Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func EncodeKey

func EncodeKey(key []byte, t time.Time) (string, error)

Types

type Keyring

type Keyring struct {
	Entity string
	Key    string
	Caps   map[string]string
}

func (Keyring) CreateKeyring

func (k Keyring) CreateKeyring() string

func (*Keyring) GenerateKey

func (k *Keyring) GenerateKey() error

func (*Keyring) GetSecret

func (k *Keyring) GetSecret(cluster string) *corev1.Secret

func (*Keyring) GetSecretName

func (k *Keyring) GetSecretName(cluster string) string

type MonEventMapper

type MonEventMapper struct{}

func (*MonEventMapper) Map

func (m *MonEventMapper) Map(o handler.MapObject) []reconcile.Request

type ReconcileCephMonCluster

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

ReconcileCephMonCluster reconciles a CephMonCluster object

func (*ReconcileCephMonCluster) Reconcile

func (r *ReconcileCephMonCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a CephMonCluster object and makes changes based on the state read and what is in the CephMonCluster.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.