blob

func (*GCS) Create ¶

func (g *GCS) Create(name string) (io.WriteCloser, chan struct{}, error)

func (*GCS) List ¶

func (g *GCS) List() ([]string, error)

func (*GCS) Open ¶

func (g *GCS) Open(name string) (io.ReadCloser, error)

func (*GCS) Remove ¶

func (g *GCS) Remove(name string) error

func (*MasterStoreClient) Create ¶

func (c *MasterStoreClient) Create(name string) (io.WriteCloser, chan struct{}, error)

func (*MasterStoreClient) List ¶

func (c *MasterStoreClient) List() ([]string, error)

func (*MasterStoreClient) Open ¶

func (c *MasterStoreClient) Open(name string) (io.ReadCloser, error)

func (*MasterStoreClient) Remove ¶

func (c *MasterStoreClient) Remove(name string) error

func (*MasterStoreServer) DownloadBlob ¶

func (s *MasterStoreServer) DownloadBlob(request *protocol.DownloadBlobRequest, stream grpc.ServerStreamingServer[protocol.DownloadBlobResponse]) error

func (*MasterStoreServer) ListBlobs ¶

func (s *MasterStoreServer) ListBlobs(ctx context.Context, request *protocol.ListBlobsRequest) (*protocol.ListBlobsResponse, error)

func (*MasterStoreServer) RemoveBlob ¶

func (s *MasterStoreServer) RemoveBlob(ctx context.Context, request *protocol.RemoveBlobRequest) (*protocol.RemoveBlobResponse, error)

func (*MasterStoreServer) UploadBlob ¶

func (s *MasterStoreServer) UploadBlob(stream grpc.ClientStreamingServer[protocol.UploadBlobRequest, protocol.UploadBlobResponse]) error

func (*POSIX) Create ¶

func (p *POSIX) Create(name string) (io.WriteCloser, chan struct{}, error)

Create a new file for writing. It returns an io.WriteCloser that can be used to write data to the file. It also returns a done channel that is closed when the writing is complete.

func (*POSIX) List ¶

func (p *POSIX) List() ([]string, error)

List files in the directory. It returns a slice of file names.

func (*POSIX) Open ¶

func (p *POSIX) Open(name string) (io.ReadCloser, error)

Open a file for reading. It returns an io.Reader that can be used to read the file's content.

func (*POSIX) Remove ¶

func (p *POSIX) Remove(name string) error

Remove a file by its name. It deletes the file from the filesystem.

func (*S3) Create ¶

func (s *S3) Create(name string) (io.WriteCloser, chan struct{}, error)

Create a new file in S3 for writing. This function returns an io.WriteCloser that can be used to write data to the file. It also returns a done channel that is closed when the writing is complete.

func (*S3) List ¶

func (s *S3) List() ([]string, error)

List files in the S3 bucket with the specified prefix. This function returns a slice of file names.

func (*S3) Open ¶

func (s *S3) Open(name string) (io.ReadCloser, error)

Open a file in S3 for reading. This function returns an io.Reader that can be used to read the file's content.

func (*S3) Remove ¶

func (s *S3) Remove(name string) error

Remove a file from the S3 bucket by its name. This function deletes the file from S3.