wavefs

Documentation

Index

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

Types

type WaveClient

type WaveClient struct{}

func NewWaveClient

func NewWaveClient() *WaveClient

func (WaveClient) AppendFile

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

func (WaveClient) Copy

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

func (WaveClient) Delete

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

func (WaveClient) GetConnectionType

func (c WaveClient) GetConnectionType() string

func (WaveClient) Join

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

func (WaveClient) ListEntries

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

func (WaveClient) ListEntriesStream

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

func (WaveClient) Mkdir

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

WaveFile does not support directories, only prefix-based listing

func (WaveClient) Move

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

func (WaveClient) PutFile

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

func (WaveClient) Read

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

func (WaveClient) ReadStream

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

func (WaveClient) ReadTarStream

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

func (WaveClient) Stat

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