storage_service

Documentation

Index

• type StorageService
  • func NewStorageService(cfg *config.Config, repo repositories.RepositoriesInterface, ...) *StorageService
  • func (self *StorageService) CreatePVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) (*models.PVCInfo, error)
  • func (self *StorageService) CreateS3StorageBackend(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) (*models.S3Response, error)
  • func (self *StorageService) DeletePVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) error
  • func (self *StorageService) DeleteS3StorageByID(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) error
  • func (self *StorageService) GetPVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) (*models.PVCInfo, error)
  • func (self *StorageService) GetS3StorageByID(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) (*models.S3Response, error)
  • func (self *StorageService) ListPVCs(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) ([]*models.PVCInfo, error)
  • func (self *StorageService) ListS3StorageBackends(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) ([]*models.S3Response, error)
  • func (self *StorageService) UpdatePVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) (*models.PVCInfo, error)
  • func (self *StorageService) UpdateS3Storage(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, ...) (*models.S3Response, error)

Types

type StorageService

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

Integrate storage management with internal permissions and kubernetes RBAC

func NewStorageService

func NewStorageService(cfg *config.Config, repo repositories.RepositoriesInterface, k8sClient *k8s.KubeClient, promClient *prometheus.PrometheusClient, svcService *service_service.ServiceService) *StorageService

func (*StorageService) CreatePVC

func (self *StorageService) CreatePVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, input *models.CreatePVCInput) (*models.PVCInfo, error)

func (*StorageService) CreateS3StorageBackend

func (self *StorageService) CreateS3StorageBackend(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, input *models.S3BackendCreateInput) (*models.S3Response, error)

func (*StorageService) DeletePVC

func (self *StorageService) DeletePVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, input *models.DeletePVCInput) error

func (*StorageService) DeleteS3StorageByID

func (self *StorageService) DeleteS3StorageByID(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, teamID, id uuid.UUID) error

Delete a specific storage backend by ID

func (*StorageService) GetPVC

func (self *StorageService) GetPVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, input *models.GetPVCInput) (*models.PVCInfo, error)

func (*StorageService) GetS3StorageByID

func (self *StorageService) GetS3StorageByID(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, teamID, id uuid.UUID, withBuckets bool) (*models.S3Response, error)

Get a specific storage backend by ID

func (*StorageService) ListPVCs

func (self *StorageService) ListPVCs(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, input *models.ListPVCInput) ([]*models.PVCInfo, error)

func (*StorageService) ListS3StorageBackends

func (self *StorageService) ListS3StorageBackends(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, teamID uuid.UUID, withBuckets bool) ([]*models.S3Response, error)

ListS3StorageBackends lists all S3 storage backends for a given team.

func (*StorageService) UpdatePVC

func (self *StorageService) UpdatePVC(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, input *models.UpdatePVCInput) (*models.PVCInfo, error)

func (*StorageService) UpdateS3Storage

func (self *StorageService) UpdateS3Storage(ctx context.Context, requesterUserID uuid.UUID, bearerToken string, teamID, id uuid.UUID, name, accessKeyID, secretKey *string) (*models.S3Response, error)

Delete a specific storage backend by ID