Documentation
¶
Index ¶
- type StorageClient
- func (c *StorageClient) Close() error
- func (c *StorageClient) Clusters(ctx context.Context) ([]string, error)
- func (c *StorageClient) Databases(ctx context.Context, cluster string) ([]string, error)
- func (c *StorageClient) DeleteFiles(ctx context.Context, paths []store.StoragePath) error
- func (c *StorageClient) Iterator(ctx context.Context, cluster, database string, level int) (store.StoragePathIterator, error)
- func (c *StorageClient) Levels(ctx context.Context, cluster, database string) ([]int, error)
- func (c *StorageClient) Metadata(ctx context.Context, path store.StoragePath) (store.StorageMetadata, error)
- func (c *StorageClient) OpenFile(ctx context.Context, path store.StoragePath) (io.ReadCloser, error)
- func (c *StorageClient) OrgIDs(ctx context.Context) ([]int, error)
- func (c *StorageClient) WriteFile(ctx context.Context, path store.StoragePath, r io.Reader) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StorageClient ¶
type StorageClient struct {
CloseFunc func() error
OrgIDsFunc func(ctx context.Context) ([]int, error)
ClustersFunc func(ctx context.Context) ([]string, error)
DatabasesFunc func(ctx context.Context, cluster string) ([]string, error)
LevelsFunc func(ctx context.Context, cluster, database string) ([]int, error)
MetadataFunc func(ctx context.Context, path store.StoragePath) (store.StorageMetadata, error)
OpenFileFunc func(ctx context.Context, path store.StoragePath) (io.ReadCloser, error)
WriteFileFunc func(ctx context.Context, path store.StoragePath, r io.Reader) error
DeleteFilesFunc func(ctx context.Context, paths []store.StoragePath) error
IteratorFunc func(ctx context.Context, cluster, database string, level int) (store.StoragePathIterator, error)
}
func (*StorageClient) Close ¶
func (c *StorageClient) Close() error
func (*StorageClient) Clusters ¶
func (c *StorageClient) Clusters(ctx context.Context) ([]string, error)
func (*StorageClient) DeleteFiles ¶
func (c *StorageClient) DeleteFiles(ctx context.Context, paths []store.StoragePath) error
func (*StorageClient) Iterator ¶
func (c *StorageClient) Iterator(ctx context.Context, cluster, database string, level int) (store.StoragePathIterator, error)
func (*StorageClient) Metadata ¶
func (c *StorageClient) Metadata(ctx context.Context, path store.StoragePath) (store.StorageMetadata, error)
func (*StorageClient) OpenFile ¶
func (c *StorageClient) OpenFile(ctx context.Context, path store.StoragePath) (io.ReadCloser, error)
func (*StorageClient) WriteFile ¶
func (c *StorageClient) WriteFile(ctx context.Context, path store.StoragePath, r io.Reader) error
Click to show internal directories.
Click to hide internal directories.