propagator

package

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

Details

View Source

const PATH_PREFIX = "cedana://"

This section is empty.

func CheckConfig() types.Check

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

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

Cedana managed file

func NewDownloadableFile(ctx context.Context, downloadUrl string) *File

func NewUploadableFile(ctx context.Context, uploadUrl string) *File

func (c *File) Close() error

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

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

type Storage struct {
	*v1.V1RequestBuilder
}

Cedana managed storage

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(_ context.Context, path string) error

func (s *Storage) IsDir(_ 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)