wshfs

Documentation

Index

• Constants
• Variables
• type WshClient
  • func NewWshClient() *WshClient
  • func (c WshClient) AppendFile(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) error
  • func (c WshClient) Copy(ctx context.Context, srcConn, destConn *connparse.Connection, ...) error
  • func (c WshClient) Delete(ctx context.Context, conn *connparse.Connection) error
  • func (c WshClient) GetConnectionType() string
  • func (c WshClient) Join(ctx context.Context, conn *connparse.Connection, parts ...string) (string, error)
  • func (c WshClient) ListEntries(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileListOpts) ([]*wshrpc.FileInfo, error)
  • func (c WshClient) ListEntriesStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileListOpts) <-chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]
  • func (c WshClient) Mkdir(ctx context.Context, conn *connparse.Connection) error
  • func (c WshClient) Move(ctx context.Context, srcConn, destConn *connparse.Connection, ...) error
  • func (c WshClient) PutFile(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) error
  • func (c WshClient) Read(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) (*wshrpc.FileData, error)
  • func (c WshClient) ReadStream(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]
  • func (c WshClient) ReadTarStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileCopyOpts) <-chan wshrpc.RespOrErrorUnion[[]byte]
  • func (c WshClient) Stat(ctx context.Context, conn *connparse.Connection) (*wshrpc.FileInfo, error)

Constants

const (
	ThirtySeconds = 30 * 1000
)

Variables

var RpcClient *wshutil.WshRpc

This needs to be set by whoever initializes the client, either main-server or wshcmd-connserver

Types

type WshClient

type WshClient struct{}

func NewWshClient

func NewWshClient() *WshClient

func (WshClient) AppendFile

func (c WshClient) AppendFile(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) error

func (WshClient) Copy

func (c WshClient) Copy(ctx context.Context, srcConn, destConn *connparse.Connection, opts *wshrpc.FileCopyOpts) error

func (WshClient) Delete

func (c WshClient) Delete(ctx context.Context, conn *connparse.Connection) error

func (WshClient) GetConnectionType

func (c WshClient) GetConnectionType() string

func (WshClient) Join

func (c WshClient) Join(ctx context.Context, conn *connparse.Connection, parts ...string) (string, error)

func (WshClient) ListEntries

func (c WshClient) ListEntries(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileListOpts) ([]*wshrpc.FileInfo, error)

func (WshClient) ListEntriesStream

func (c WshClient) ListEntriesStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileListOpts) <-chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]

func (WshClient) Mkdir

func (c WshClient) Mkdir(ctx context.Context, conn *connparse.Connection) error

func (WshClient) Move

func (c WshClient) Move(ctx context.Context, srcConn, destConn *connparse.Connection, opts *wshrpc.FileCopyOpts) error

func (WshClient) PutFile

func (c WshClient) PutFile(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) error

func (WshClient) Read

func (c WshClient) Read(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) (*wshrpc.FileData, error)

func (WshClient) ReadStream

func (c WshClient) ReadStream(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]

func (WshClient) ReadTarStream

func (c WshClient) ReadTarStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileCopyOpts) <-chan wshrpc.RespOrErrorUnion[[]byte]

func (WshClient) Stat

func (c WshClient) Stat(ctx context.Context, conn *connparse.Connection) (*wshrpc.FileInfo, error)