csx

package

v0.9.310 Latest Latest Go to latest Published: Oct 9, 2026 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

View Source

const PATH_PREFIX = "csx://"

This section is empty.

func NewStorage(ctx context.Context) (cedana_io.Storage, error)

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

func NewFile(ctx context.Context, objectID, actionID, path string, conn *grpc.ClientConn, csxClient csxgrpc.CSXClient) *File

func (f *File) Close() error

func (f *File) Read(p []byte) (int, error)

func (f *File) Write(p []byte) (int, error)

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

func (s *Storage) Create(ctx context.Context, path string) (io.WriteCloser, error)

func (s *Storage) CreatePath(ctx context.Context, dir, name string) (path string, cleanup func(cancel bool) error, err error)

func (s *Storage) Delete(ctx context.Context, path string) error

func (s *Storage) IsDir(ctx context.Context, path string) (bool, error)

func (s *Storage) IsRemote() bool

func (s *Storage) Open(ctx context.Context, path string) (io.ReadCloser, error)

func (s *Storage) ReadDir(ctx context.Context, path string) ([]string, error)

func (s *Storage) ReadPath(ctx context.Context, path string) (string, func() error, error)