Documentation
      ¶
    
    
  
    
  
    Index ¶
- type 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)
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type S3Client ¶
type S3Client struct {
	// contains filtered or unexported fields
}
    func NewS3Client ¶
func (S3Client) AppendFile ¶
func (S3Client) CopyInternal ¶ added in v0.11.1
func (c S3Client) CopyInternal(ctx context.Context, srcConn, destConn *connparse.Connection, opts *wshrpc.FileCopyOpts) (bool, error)
func (S3Client) CopyRemote ¶ added in v0.11.1
func (c S3Client) CopyRemote(ctx context.Context, srcConn, destConn *connparse.Connection, srcClient fstype.FileShareClient, opts *wshrpc.FileCopyOpts) (bool, error)
func (S3Client) GetCapability ¶ added in v0.11.1
func (c S3Client) GetCapability() wshrpc.FileShareCapability
func (S3Client) GetConnectionType ¶
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) MoveInternal ¶ added in v0.11.1
func (c S3Client) MoveInternal(ctx context.Context, srcConn, destConn *connparse.Connection, opts *wshrpc.FileCopyOpts) error
func (S3Client) ReadStream ¶
func (S3Client) ReadTarStream ¶
func (c S3Client) ReadTarStream(ctx context.Context, conn *connparse.Connection, opts *wshrpc.FileCopyOpts) <-chan wshrpc.RespOrErrorUnion[iochantypes.Packet]
 Click to show internal directories. 
   Click to hide internal directories.