s3fs

Documentation

Index

• type S3Client
  • func NewS3Client(config *aws.Config) *S3Client
  • func (c S3Client) AppendFile(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) error
  • func (c S3Client) CopyInternal(ctx context.Context, srcConn, destConn *connparse.Connection, ...) (bool, error)
  • func (c S3Client) CopyRemote(ctx context.Context, srcConn, destConn *connparse.Connection, ...) (bool, error)
  • func (c S3Client) Delete(ctx context.Context, conn *connparse.Connection, recursive bool) error
  • func (c S3Client) GetCapability() wshrpc.FileShareCapability
  • func (c S3Client) GetConnectionType() string
  • func (c S3Client) Join(ctx context.Context, conn *connparse.Connection, parts ...string) (*wshrpc.FileInfo, error)
  • func (c S3Client) ListEntries(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileListOpts) ([]*wshrpc.FileInfo, error)
  • func (c S3Client) ListEntriesStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileListOpts) <-chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]
  • func (c S3Client) Mkdir(ctx context.Context, conn *connparse.Connection) error
  • func (c S3Client) MoveInternal(ctx context.Context, srcConn, destConn *connparse.Connection, ...) error
  • func (c S3Client) PutFile(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) error
  • func (c S3Client) Read(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) (*wshrpc.FileData, error)
  • func (c S3Client) ReadStream(ctx context.Context, conn *connparse.Connection, data wshrpc.FileData) <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]
  • func (c S3Client) ReadTarStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileCopyOpts) <-chan wshrpc.RespOrErrorUnion[iochantypes.Packet]
  • func (c S3Client) Stat(ctx context.Context, conn *connparse.Connection) (*wshrpc.FileInfo, error)

Types

type S3Client

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

func NewS3Client

func NewS3Client(config *aws.Config) *S3Client

func (S3Client) AppendFile

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

func (S3Client) CopyInternal

func (c S3Client) CopyInternal(ctx context.Context, srcConn, destConn *connparse.Connection, opts *wshrpc.FileCopyOpts) (bool, error)

func (S3Client) CopyRemote

func (c S3Client) CopyRemote(ctx context.Context, srcConn, destConn *connparse.Connection, srcClient fstype.FileShareClient, opts *wshrpc.FileCopyOpts) (bool, error)

func (S3Client) Delete

func (c S3Client) Delete(ctx context.Context, conn *connparse.Connection, recursive bool) error

func (S3Client) GetCapability

func (c S3Client) GetCapability() wshrpc.FileShareCapability

func (S3Client) GetConnectionType

func (c S3Client) GetConnectionType() string

func (S3Client) Join

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

func (S3Client) ListEntries

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

func (S3Client) ListEntriesStream

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

func (S3Client) Mkdir

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

func (S3Client) MoveInternal

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

func (S3Client) PutFile

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

func (S3Client) Read

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

func (S3Client) ReadStream

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

func (S3Client) ReadTarStream

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

func (S3Client) Stat

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