wshremote

Documentation

Index

• Constants
• func RunSysInfoLoop(client *wshutil.WshRpc, connName string)
• type ByteRangeType
• type ServerImpl
  • func (impl *ServerImpl) Log(format string, args ...interface{})
  • func (impl *ServerImpl) MessageCommand(ctx context.Context, data wshrpc.CommandMessageData) error
  • func (*ServerImpl) RemoteFileDeleteCommand(ctx context.Context, path string) error
  • func (impl *ServerImpl) RemoteFileInfoCommand(ctx context.Context, path string) (*wshrpc.FileInfo, error)
  • func (impl *ServerImpl) RemoteFileJoinCommand(ctx context.Context, paths []string) (*wshrpc.FileInfo, error)
  • func (impl *ServerImpl) RemoteStreamFileCommand(ctx context.Context, data wshrpc.CommandRemoteStreamFileData) chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteStreamFileRtnData]
  • func (*ServerImpl) RemoteWriteFileCommand(ctx context.Context, data wshrpc.CommandRemoteWriteFileData) error
  • func (*ServerImpl) WshServerImpl()

Constants

const BYTES_PER_GB = 1073741824

const DirChunkSize = 128

const FileChunkSize = 16 * 1024

const MaxDirSize = 1024

const MaxFileSize = 50 * 1024 * 1024 // 10M

Functions

func RunSysInfoLoop

func RunSysInfoLoop(client *wshutil.WshRpc, connName string)

Types

type ByteRangeType

type ByteRangeType struct {
	All   bool
	Start int64
	End   int64
}

type ServerImpl

type ServerImpl struct {
	LogWriter io.Writer
}

func (*ServerImpl) Log

func (impl *ServerImpl) Log(format string, args ...interface{})

func (*ServerImpl) MessageCommand

func (impl *ServerImpl) MessageCommand(ctx context.Context, data wshrpc.CommandMessageData) error

func (*ServerImpl) RemoteFileDeleteCommand

func (*ServerImpl) RemoteFileDeleteCommand(ctx context.Context, path string) error

func (*ServerImpl) RemoteFileInfoCommand

func (impl *ServerImpl) RemoteFileInfoCommand(ctx context.Context, path string) (*wshrpc.FileInfo, error)

func (*ServerImpl) RemoteFileJoinCommand

func (impl *ServerImpl) RemoteFileJoinCommand(ctx context.Context, paths []string) (*wshrpc.FileInfo, error)

func (*ServerImpl) RemoteStreamFileCommand

func (impl *ServerImpl) RemoteStreamFileCommand(ctx context.Context, data wshrpc.CommandRemoteStreamFileData) chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteStreamFileRtnData]

func (*ServerImpl) RemoteWriteFileCommand

func (*ServerImpl) RemoteWriteFileCommand(ctx context.Context, data wshrpc.CommandRemoteWriteFileData) error

func (*ServerImpl) WshServerImpl

func (*ServerImpl) WshServerImpl()