rgw

Documentation

Overview

Package rgw to manage a rook object store.

Package rgw to manage a rook rgw.

Package rgw for the Ceph object store.

Package rgw to manage a rook object store.

Index

• Variables
• func InstanceName(name string) string
• func Kind(kind string) schema.GroupKind
• func Resource(resource string) schema.GroupResource
• type GatewaySpec
• type ObjectStore
  • func ModelToSpec(store model.ObjectStore, namespace string) *ObjectStore
  • func (s *ObjectStore) Create(context *clusterd.Context, version string, hostNetwork bool) error
  • func (s *ObjectStore) Delete(context *clusterd.Context) error
  • func (s *ObjectStore) Update(context *clusterd.Context, version string, hostNetwork bool) error
• type ObjectStoreController
  • func NewObjectStoreController(context *clusterd.Context, versionTag string, hostNetwork bool) *ObjectStoreController
  • func (c *ObjectStoreController) StartWatch(namespace string, stopCh chan struct{}) error
• type ObjectStoreList
• type ObjectStoreSpec
• type ObjectstoreList

Variables

var ObjectStoreResource = opkit.CustomResource{
	Name:    "objectstore",
	Plural:  "objectstores",
	Group:   k8sutil.CustomResourceGroup,
	Version: k8sutil.V1Alpha1,
	Scope:   apiextensionsv1beta1.NamespaceScoped,
	Kind:    reflect.TypeOf(ObjectStore{}).Name(),
}

ObjectStoreResource represents the object store custom resource

Functions

func InstanceName

func InstanceName(name string) string

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns back a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns back a Group qualified GroupResource

Types

type GatewaySpec

type GatewaySpec struct {
	// The port the rgw service will be listening on (http)
	Port int32 `json:"port"`

	// The port the rgw service will be listening on (https)
	SecurePort int32 `json:"securePort"`

	// The number of pods in the rgw replicaset. If "allNodes" is specified, a daemonset is created.
	Instances int32 `json:"instances"`

	// Whether the rgw pods should be started as a daemonset on all nodes
	AllNodes bool `json:"allNodes"`

	// The name of the secret that stores the ssl certificate for secure rgw connections
	SSLCertificateRef string `json:"sslCertificateRef"`

	// The affinity to place the rgw pods (default is to place on any available node)
	Placement k8sutil.Placement `json:"placement"`
}

type ObjectStore

type ObjectStore struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata"`
	Spec              ObjectStoreSpec `json:"spec"`
}

ObjectStore is the definition of the object store custom resource

func ModelToSpec

func ModelToSpec(store model.ObjectStore, namespace string) *ObjectStore

func (*ObjectStore) Create

func (s *ObjectStore) Create(context *clusterd.Context, version string, hostNetwork bool) error

Start the rgw manager

func (*ObjectStore) Delete

func (s *ObjectStore) Delete(context *clusterd.Context) error

Delete the object store. WARNING: This is a very destructive action that deletes all metadata and data pools.

func (*ObjectStore) Update

func (s *ObjectStore) Update(context *clusterd.Context, version string, hostNetwork bool) error

type ObjectStoreController

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

ObjectStoreController represents a controller object for object store custom resources

func NewObjectStoreController

func NewObjectStoreController(context *clusterd.Context, versionTag string, hostNetwork bool) *ObjectStoreController

NewObjectStoreController create controller for watching object store custom resources created

func (*ObjectStoreController) StartWatch

func (c *ObjectStoreController) StartWatch(namespace string, stopCh chan struct{}) error

StartWatch watches for instances of ObjectStore custom resources and acts on them

type ObjectStoreList

type ObjectStoreList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []ObjectStore `json:"items"`
}

ObjectstoreList is the definition of a list of object stores for CRDs (1.7+)

type ObjectStoreSpec

type ObjectStoreSpec struct {
	// The metadata pool settings
	MetadataPool pool.PoolSpec `json:"metadataPool"`

	// The data pool settings
	DataPool pool.PoolSpec `json:"dataPool"`

	// The rgw pod info
	Gateway GatewaySpec `json:"gateway"`
}

ObjectStoreSpec represent the spec of a pool

type ObjectstoreList

type ObjectstoreList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []ObjectStore `json:"items"`
}

ObjectstoreList is the definition of a list of object stores for TPRs (pre-1.7)