storage

Jan 22, 2021

Changes in this version

+ const BcsStorageDynamicAllResourceURI

+ const BcsStorageDynamicWatchResourceURI

+ type Interface interface

+ ListResources func(clusterType, clusterID, resourceType string) (*common.ListStorageResourceResult, error)

+ WatchClusterResources func(clusterID, resourceType string) (chan *common.StorageEvent, error)

+ type StorageClient struct

+ func NewStorageClient(zkAddr string) (*StorageClient, error)

+ func (sc *StorageClient) ListResources(clusterType, clusterID, resourceType string) (*common.ListStorageResourceResult, error)

+ func (sc *StorageClient) SetTLSConfig(conf *tls.Config)

+ func (sc *StorageClient) Start(ctx context.Context)

+ func (sc *StorageClient) WatchClusterResources(clusterID, resourceType string) (chan *common.StorageEvent, error)