fileshare

Documentation

Index

• Constants
• func Append(ctx context.Context, data wshrpc.FileData) error
• func Copy(ctx context.Context, data wshrpc.CommandFileCopyData) error
• func CreateFileShareClient(ctx context.Context, connection string) (fstype.FileShareClient, *connparse.Connection)
• func Delete(ctx context.Context, path string) error
• func Join(ctx context.Context, path string, parts ...string) (string, error)
• func ListEntries(ctx context.Context, path string, opts *wshrpc.FileListOpts) ([]*wshrpc.FileInfo, error)
• func ListEntriesStream(ctx context.Context, path string, opts *wshrpc.FileListOpts) <-chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]
• func Mkdir(ctx context.Context, path string) error
• func Move(ctx context.Context, data wshrpc.CommandFileCopyData) error
• func PutFile(ctx context.Context, data wshrpc.FileData) error
• func Read(ctx context.Context, data wshrpc.FileData) (*wshrpc.FileData, error)
• func ReadStream(ctx context.Context, data wshrpc.FileData) <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]
• func ReadTarStream(ctx context.Context, data wshrpc.CommandRemoteStreamTarData) <-chan wshrpc.RespOrErrorUnion[[]byte]
• func Stat(ctx context.Context, path string) (*wshrpc.FileInfo, error)

Constants

const (
	ErrorParsingConnection = "error creating fileshare client, could not parse connection %s"
)

Functions

func Append

func Append(ctx context.Context, data wshrpc.FileData) error

func Copy

func Copy(ctx context.Context, data wshrpc.CommandFileCopyData) error

func CreateFileShareClient

func CreateFileShareClient(ctx context.Context, connection string) (fstype.FileShareClient, *connparse.Connection)

CreateFileShareClient creates a fileshare client based on the connection string Returns the client and the parsed connection

func Delete

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

func Join

func Join(ctx context.Context, path string, parts ...string) (string, error)

func ListEntries

func ListEntries(ctx context.Context, path string, opts *wshrpc.FileListOpts) ([]*wshrpc.FileInfo, error)

func ListEntriesStream

func ListEntriesStream(ctx context.Context, path string, opts *wshrpc.FileListOpts) <-chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]

func Mkdir

func Mkdir(ctx context.Context, path string) error

func Move

func Move(ctx context.Context, data wshrpc.CommandFileCopyData) error

func PutFile

func PutFile(ctx context.Context, data wshrpc.FileData) error

func Read

func Read(ctx context.Context, data wshrpc.FileData) (*wshrpc.FileData, error)

func ReadStream

func ReadStream(ctx context.Context, data wshrpc.FileData) <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]

func ReadTarStream

func ReadTarStream(ctx context.Context, data wshrpc.CommandRemoteStreamTarData) <-chan wshrpc.RespOrErrorUnion[[]byte]

func Stat

func Stat(ctx context.Context, path string) (*wshrpc.FileInfo, error)