clients

package

Go to main page

Versions in this module

v0

v0.8.1

Aug 1, 2018

v0.8.0

Jul 18, 2018

Changes in this version

+ type BlockImage struct

+ Device string

+ MountPoint string

+ Name string

+ PoolName string

+ Size uint64

type BlockOperation

+ func (b *BlockOperation) Create(manifest string, size int) (string, error)

+ func (b *BlockOperation) DeleteBlock(manifest string) (string, error)

+ func (b *BlockOperation) DeleteBlockImage(image BlockImage, namespace string) error

+ func (b *BlockOperation) List(namespace string) ([]BlockImage, error)

+ func (b *BlockOperation) Read(name string, mountpath string, filename string, namespace string) (string, error)

+ func (b *BlockOperation) Write(name string, mountpath string, data string, filename string, namespace string) (string, error)

type FilesystemOperation

+ func (f *FilesystemOperation) Create(name, namespace string) error

+ func (f *FilesystemOperation) Delete(name, namespace string) error

+ func (f *FilesystemOperation) List(namespace string) ([]client.CephFilesystem, error)

+ func (f *FilesystemOperation) Mount(name string, path string) (string, error)

+ func (f *FilesystemOperation) Read(name string, mountpath string, filename string, namespace string) (string, error)

+ func (f *FilesystemOperation) Unmount(name string) (string, error)

+ func (f *FilesystemOperation) Write(name string, mountpath string, data string, filename string, namespace string) (string, error)

type ObjectOperation

+ func (ro *ObjectOperation) Create(namespace, storeName string, replicaCount int32) error

+ func (ro *ObjectOperation) Delete(namespace, storeName string) error

+ type PoolOperation struct

+ func CreatePoolOperation(k8sh *utils.K8sHelper) *PoolOperation

+ func (p *PoolOperation) CephPoolExists(namespace, name string) (bool, error)

+ func (p *PoolOperation) Create(pool model.Pool, namespace string) (string, error)

+ func (p *PoolOperation) GetCephPoolDetails(namespace, name string) (client.CephStoragePoolDetails, error)

+ func (p *PoolOperation) ListCephPools(namespace string) ([]client.CephStoragePoolSummary, error)

+ func (p *PoolOperation) ListPoolCRDs(namespace string) ([]cephv1beta1.Pool, error)

+ func (p *PoolOperation) PoolCRDExists(namespace, name string) (bool, error)

+ func (p *PoolOperation) Update(pool model.Pool, namespace string) (string, error)

type TestClient

+ BlockClient *BlockOperation

+ FSClient *FilesystemOperation

+ ObjectClient *ObjectOperation

+ PoolClient *PoolOperation

v0.7.1

Mar 9, 2018

v0.7.0

Feb 21, 2018

Changes in this version

type ObjectOperation

+ func (ro *ObjectOperation) ObjectDelete(namespace, storeName string, replicaCount int32, callAPI bool, ...) error

v0.6.2

Dec 12, 2017

v0.6.1

Dec 4, 2017

v0.6.0

Nov 8, 2017

Changes in this version

+ func IsClusterHealthy(testClient *TestClient) (model.StatusDetails, error)

+ type FilesystemOperation struct

+ func CreateK8sFilesystemOperation(k8shelp *utils.K8sHelper, rookRestClient contracts.RestAPIOperator) *FilesystemOperation

+ func (rfs *FilesystemOperation) FSCreate(name, namespace string, callAPI bool, k8sh *utils.K8sHelper) error

+ func (rfs *FilesystemOperation) FSDelete(name string) (string, error)

+ func (rfs *FilesystemOperation) FSList() ([]model.Filesystem, error)

+ func (rfs *FilesystemOperation) FSMount(name string, path string) (string, error)

+ func (rfs *FilesystemOperation) FSRead(name string, mountpath string, filename string, namespace string) (string, error)

+ func (rfs *FilesystemOperation) FSUnmount(name string) (string, error)

+ func (rfs *FilesystemOperation) FSWrite(name string, mountpath string, data string, filename string, namespace string) (string, error)

type RestAPIClient

+ func (a *RestAPIClient) DeleteObjectStore(storeName string) error

v0.5.1

Aug 15, 2017

v0.5.0

Aug 8, 2017

Changes in this version

+ type BlockOperation struct

+ func CreateK8BlockOperation(k8shelp *utils.K8sHelper, rookRestClient contracts.RestAPIOperator) *BlockOperation

+ func (rb *BlockOperation) BlockCreate(name string, size int) (string, error)

+ func (rb *BlockOperation) BlockDelete(name string) (string, error)

+ func (rb *BlockOperation) BlockList() ([]model.BlockImage, error)

+ func (rb *BlockOperation) BlockMap(name string, mountpath string) (string, error)

+ func (rb *BlockOperation) BlockRead(name string, mountpath string, filename string, namespace string) (string, error)

+ func (rb *BlockOperation) BlockUnmap(name string, mountpath string) (string, error)

+ func (rb *BlockOperation) BlockWrite(name string, mountpath string, data string, filename string, namespace string) (string, error)

+ type FileSystemOperation struct

+ func CreateK8sFileSystemOperation(k8shelp *utils.K8sHelper, rookRestClient contracts.RestAPIOperator) *FileSystemOperation

+ func (rfs *FileSystemOperation) FSCreate(name string) (string, error)

+ func (rfs *FileSystemOperation) FSDelete(name string) (string, error)

+ func (rfs *FileSystemOperation) FSList() ([]model.Filesystem, error)

+ func (rfs *FileSystemOperation) FSMount(name string, path string) (string, error)

+ func (rfs *FileSystemOperation) FSRead(name string, mountpath string, filename string, namespace string) (string, error)

+ func (rfs *FileSystemOperation) FSUnmount(name string) (string, error)

+ func (rfs *FileSystemOperation) FSWrite(name string, mountpath string, data string, filename string, namespace string) (string, error)

+ type ObjectOperation struct

+ func CreateObjectOperation(rookRestClient contracts.RestAPIOperator) *ObjectOperation

+ func (ro *ObjectOperation) ObjectBucketList() ([]model.ObjectBucket, error)

+ func (ro *ObjectOperation) ObjectConnection() (*model.ObjectStoreConnectInfo, error)

+ func (ro *ObjectOperation) ObjectCreate() (string, error)

+ func (ro *ObjectOperation) ObjectCreateUser(userid string, displayname string) (*model.ObjectUser, error)

+ func (ro *ObjectOperation) ObjectDeleteUser(userid string) error

+ func (ro *ObjectOperation) ObjectGetUser(userid string) (*model.ObjectUser, error)

+ func (ro *ObjectOperation) ObjectListUser() ([]model.ObjectUser, error)

+ func (ro *ObjectOperation) ObjectUpdateUser(userid string, displayname string, emailid string) (*model.ObjectUser, error)

+ type PoolClient struct

+ func CreatePoolClient(rookRestClient contracts.RestAPIOperator) *PoolClient

+ func (rp *PoolClient) PoolCreate(pool model.Pool) (string, error)

+ func (rp *PoolClient) PoolList() ([]model.Pool, error)

+ type RestAPIClient struct

+ func CreateRestAPIClient(platform enums.RookPlatformType, k8sHelper *utils.K8sHelper) *RestAPIClient

+ func (a *RestAPIClient) CreateBlockImage(image model.BlockImage) (string, error)

+ func (a *RestAPIClient) CreateFilesystem(fsmodel model.FilesystemRequest) (string, error)

+ func (a *RestAPIClient) CreateObjectStore() (string, error)

+ func (a *RestAPIClient) CreateObjectUser(user model.ObjectUser) (*model.ObjectUser, error)

+ func (a *RestAPIClient) CreatePool(pool model.Pool) (string, error)

+ func (a *RestAPIClient) DeleteBlockImage(image model.BlockImage) (string, error)

+ func (a *RestAPIClient) DeleteFilesystem(fsmodel model.FilesystemRequest) (string, error)

+ func (a *RestAPIClient) DeleteObjectUser(id string) error

+ func (a *RestAPIClient) GetBlockImages() ([]model.BlockImage, error)

+ func (a *RestAPIClient) GetClientAccessInfo() (model.ClientAccessInfo, error)

+ func (a *RestAPIClient) GetFilesystems() ([]model.Filesystem, error)

+ func (a *RestAPIClient) GetNodes() ([]model.Node, error)

+ func (a *RestAPIClient) GetObjectStoreConnectionInfo() (*model.ObjectStoreConnectInfo, error)

+ func (a *RestAPIClient) GetObjectUser(id string) (*model.ObjectUser, error)

+ func (a *RestAPIClient) GetPools() ([]model.Pool, error)

+ func (a *RestAPIClient) GetStatusDetails() (model.StatusDetails, error)

+ func (a *RestAPIClient) ListBuckets() ([]model.ObjectBucket, error)

+ func (a *RestAPIClient) ListObjectUsers() ([]model.ObjectUser, error)

+ func (a *RestAPIClient) URL() string

+ func (a *RestAPIClient) UpdateObjectUser(user model.ObjectUser) (*model.ObjectUser, error)

+ type TestClient struct

+ func CreateTestClient(platform enums.RookPlatformType, k8sHelper *utils.K8sHelper) (*TestClient, error)

+ func (c TestClient) GetBlockClient() contracts.BlockOperator

+ func (c TestClient) GetFileSystemClient() contracts.FileSystemOperator

+ func (c TestClient) GetObjectClient() contracts.ObjectOperator

+ func (c TestClient) GetPoolClient() contracts.PoolOperator

+ func (c TestClient) GetRestAPIClient() contracts.RestAPIOperator

+ func (c TestClient) Node() ([]model.Node, error)

+ func (c TestClient) Status() (model.StatusDetails, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL