Object Storage (LEP 20230430)

.gitignore

@@ -22,6 +22,7 @@ _testmain.go
 *.exe
 *.test
 *.prof
+coverage.out
 
 # Rancher
 .dapper

api/model.go

@@ -539,6 +539,62 @@ type SnapshotCRListOutput struct {
 	Type string       `json:"type"`
 }
 
+type ObjectStore struct {
+	client.Resource
+	Name       string                    `json:"name"`
+	State      longhorn.ObjectStoreState `json:"state"`
+	Endpoints  []string                  `json:"endpoints"`
+	Size       int64                     `json:"size"`       // number of bytes allocated
+	ActualSize int64                     `json:"actualSize"` // number of bytes occupied
+	Image      string                    `json:"image"`
+	UIImage    string                    `json:"uiImage"`
+}
+
+type ObjectStoreInput struct {
+	Name string `json:"name"`
+	Size string `json:"size"`
+
+	AccessKey string `json:"accesskey"`
+	SecretKey string `json:"secretkey"`
+
+	Endpoints []ObjectEndpointInput `json:"endpoints"`
+
+	NumberOfReplicas            int                                  `json:"numberOfReplicas"`
+	ReplicaSoftAntiAffinity     longhorn.ReplicaSoftAntiAffinity     `json:"replicaSoftAntiAffinity"`
+	ReplicaZoneSoftAntiAffinity longhorn.ReplicaZoneSoftAntiAffinity `json:"replicaZoneSoftAntiAffinity"`
+	ReplicaDiskSoftAntiAffinity longhorn.ReplicaDiskSoftAntiAffinity `json:"replicaDiskSoftAntiAffinity"`
+	DiskSelector                []string                             `json:"diskSelector"`
+	NodeSelector                []string                             `json:"nodeSelector"`
+	DataLocality                longhorn.DataLocality                `json:"dataLocality"`
+	FromBackup                  string                               `json:"fromBackup"`
+	StaleReplicaTimeout         int                                  `json:"staleReplicaTimeout"`
+	RecurringJobSelector        []longhorn.VolumeRecurringJob        `json:"recurringJobSelector"`
+	ReplicaAutoBalance          longhorn.ReplicaAutoBalance          `json:"replicaAutoBalance"`
+	RevisionCounterDisabled     bool                                 `json:"revisionCounterDisabled"`
+	UnmapMarkSnapChainRemoved   longhorn.UnmapMarkSnapChainRemoved   `json:"unmapMarkSnapChainRemoved"`
+	BackendStoreDriver          longhorn.BackendStoreDriverType      `json:"backendStoreDriver"`
+	TargetState                 longhorn.ObjectStoreState            `json:"targetState"`
+	Image                       string                               `json:"image"`
+	UIImage                     string                               `json:"uiImage"`
+}
+
+type ObjectEndpointInput struct {
+	DomainName      string `json:"domainName"`
+	SecretName      string `json:"secretName"`
+	SecretNamespace string `json:"secretNamespace"`
+}
+
+type ObjectStoreListOutput struct {
+	Data []ObjectStore `json:"data"`
+	Type string        `json:"type"`
+}
+
+type SecretRef struct {
+	client.Resource
+	Name      string `json:"name"`
+	Namespace string `json:"namespace"`
+}
+
 func NewSchema() *client.Schemas {
 	schemas := &client.Schemas{}
 
@@ -625,6 +681,9 @@ func NewSchema() *client.Schemas {
 	systemRestoreSchema(schemas.AddType("systemRestore", SystemRestore{}))
 	snapshotCRListOutputSchema(schemas.AddType("snapshotCRListOutput", SnapshotCRListOutput{}))
 
+	objectStoreSchema(schemas.AddType("objectStore", ObjectStore{}))
+	secretRefSchema(schemas.AddType("secretRef", SecretRef{}))
+
 	return schemas
 }
 
@@ -1190,6 +1249,37 @@ func volumeAttachmentSchema(volumeAttachment *client.Schema) {
 	volumeAttachment.ResourceFields["attachments"] = attachments
 }
 
+func objectStoreSchema(objectStore *client.Schema) {
+	objectStore.CollectionMethods = []string{"GET", "POST"}
+	objectStore.ResourceMethods = []string{"GET", "PUT", "DELETE"}
+
+	name := objectStore.ResourceFields["name"]
+	name.Required = true
+	name.Unique = true
+	name.Create = true
+	objectStore.ResourceFields["name"] = name
+}
+
+func secretRefSchema(secretRef *client.Schema) {
+	secretRef.CollectionMethods = []string{"GET"}
+
+	name := secretRef.ResourceFields["name"]
+	name.Required = true
+	name.Unique = true
+	name.Create = true
+	secretRef.ResourceFields["name"] = name
+}
+
+func storageClassSchema(storageClass *client.Schema) {
+	storageClass.CollectionMethods = []string{"GET"}
+
+	name := storageClass.ResourceFields["name"]
+	name.Required = true
+	name.Unique = true
+	name.Create = true
+	storageClass.ResourceFields["name"] = name
+}
+
 func toEmptyResource() *Empty {
 	return &Empty{
 		Resource: client.Resource{
@@ -2124,3 +2214,45 @@ func sliceToMap(conditions []longhorn.Condition) map[string]longhorn.Condition {
 	}
 	return converted
 }
+
+func toObjectStoreResource(store *longhorn.ObjectStore, size, actualSize int64, image, uiImage string) *ObjectStore {
+	return &ObjectStore{
+		Resource: client.Resource{
+			Id:   store.Name,
+			Type: "objectStore",
+		},
+		Name:       store.Name,
+		State:      store.Status.State,
+		Endpoints:  store.Status.Endpoints,
+		Size:       size,
+		ActualSize: actualSize,
+		Image:      image,
+		UIImage:    uiImage,
+	}
+}
+
+func toSecretRefResource(secret *corev1.Secret) *SecretRef {
+	return &SecretRef{
+		Resource: client.Resource{
+			Id:   secret.Name,
+			Type: "secretRef",
+		},
+		Name:      secret.Name,
+		Namespace: secret.Namespace,
+	}
+}
+
+func toSecretRefCollection(secrets []*corev1.Secret, apiContext *api.ApiContext) *client.GenericCollection {
+	data := []interface{}{}
+
+	for _, secret := range secrets {
+		data = append(data, toSecretRefResource(secret))
+	}
+
+	return &client.GenericCollection{
+		Data: data,
+		Collection: client.Collection{
+			ResourceType: "secretRef",
+		},
+	}
+}