wshremote

package

v0.14.0-beta.1 Latest Latest Go to latest Published: Feb 11, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/wavetermdev/waveterm

Links

Documentation ¶

Index ¶

Constants
Variables
func RunSysInfoLoop(client *wshutil.WshRpc, connName string)
type ByteRangeType
type JobManagerConnection
type ServerImpl
- func MakeRemoteRpcServerImpl(logWriter io.Writer, router *wshutil.WshRouter, rpcClient *wshutil.WshRpc, ...) *ServerImpl

Constants ¶

View Source

const BYTES_PER_GB = 1073741824

View Source

const RemoteFileTransferSizeLimit = 32 * 1024 * 1024

Variables ¶

View Source

var DisableRecursiveFileOpts = true

Functions ¶

func RunSysInfoLoop ¶

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

Types ¶

type ByteRangeType ¶

type ByteRangeType struct {
	All   bool
	Start int64
	End   int64
}

type JobManagerConnection ¶ added in v0.14.0

type JobManagerConnection struct {
	JobId     string
	Conn      net.Conn
	WshRpc    *wshutil.WshRpc
	CleanupFn func()
}

type ServerImpl ¶

type ServerImpl struct {
	LogWriter     io.Writer
	Router        *wshutil.WshRouter
	RpcClient     *wshutil.WshRpc
	IsLocal       bool
	InitialEnv    map[string]string
	JobManagerMap map[string]*JobManagerConnection
	SockName      string
	Lock          sync.Mutex
}

func MakeRemoteRpcServerImpl ¶ added in v0.14.0

func MakeRemoteRpcServerImpl(logWriter io.Writer, router *wshutil.WshRouter, rpcClient *wshutil.WshRpc, isLocal bool, initialEnv map[string]string, sockName string) *ServerImpl

func (*ServerImpl) ConnServerInitCommand ¶ added in v0.14.0

func (impl *ServerImpl) ConnServerInitCommand(ctx context.Context, data wshrpc.CommandConnServerInitData) error

func (*ServerImpl) DisposeSuggestionsCommand ¶ added in v0.11.1

func (*ServerImpl) DisposeSuggestionsCommand(ctx context.Context, widgetId string) error

func (*ServerImpl) FetchSuggestionsCommand ¶ added in v0.11.1

func (*ServerImpl) FetchSuggestionsCommand(ctx context.Context, data wshrpc.FetchSuggestionsData) (*wshrpc.FetchSuggestionsResponse, error)

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) RemoteDisconnectFromJobManagerCommand ¶ added in v0.14.0

func (impl *ServerImpl) RemoteDisconnectFromJobManagerCommand(ctx context.Context, data wshrpc.CommandRemoteDisconnectFromJobManagerData) error

func (*ServerImpl) RemoteFileCopyCommand ¶ added in v0.11.0

func (impl *ServerImpl) RemoteFileCopyCommand(ctx context.Context, data wshrpc.CommandFileCopyData) (bool, error)

RemoteFileCopyCommand copies a file FROM somewhere TO here

func (*ServerImpl) RemoteFileDeleteCommand ¶

func (*ServerImpl) RemoteFileDeleteCommand(ctx context.Context, data wshrpc.CommandDeleteFileData) 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) RemoteFileMoveCommand ¶ added in v0.11.0

func (impl *ServerImpl) RemoteFileMoveCommand(ctx context.Context, data wshrpc.CommandFileCopyData) error

func (*ServerImpl) RemoteFileTouchCommand ¶ added in v0.10.0

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

func (*ServerImpl) RemoteGetInfoCommand ¶ added in v0.11.0

func (*ServerImpl) RemoteGetInfoCommand(ctx context.Context) (wshrpc.RemoteInfo, error)

func (*ServerImpl) RemoteInstallRcFilesCommand ¶ added in v0.11.0

func (*ServerImpl) RemoteInstallRcFilesCommand(ctx context.Context) error

func (*ServerImpl) RemoteListEntriesCommand ¶ added in v0.11.0

func (impl *ServerImpl) RemoteListEntriesCommand(ctx context.Context, data wshrpc.CommandRemoteListEntriesData) chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]

func (*ServerImpl) RemoteMkdirCommand ¶ added in v0.10.0

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

func (*ServerImpl) RemoteReconnectToJobManagerCommand ¶ added in v0.14.0

func (impl *ServerImpl) RemoteReconnectToJobManagerCommand(ctx context.Context, data wshrpc.CommandRemoteReconnectToJobManagerData) (*wshrpc.CommandRemoteReconnectToJobManagerRtnData, error)

func (*ServerImpl) RemoteStartJobCommand ¶ added in v0.14.0

func (impl *ServerImpl) RemoteStartJobCommand(ctx context.Context, data wshrpc.CommandRemoteStartJobData) (*wshrpc.CommandStartJobRtnData, error)

func (*ServerImpl) RemoteStreamFileCommand ¶

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

func (*ServerImpl) RemoteTerminateJobManagerCommand ¶ added in v0.14.0

func (impl *ServerImpl) RemoteTerminateJobManagerCommand(ctx context.Context, data wshrpc.CommandRemoteTerminateJobManagerData) error

func (*ServerImpl) RemoteWriteFileCommand ¶

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

func (*ServerImpl) StreamTestCommand ¶ added in v0.11.1

func (impl *ServerImpl) StreamTestCommand(ctx context.Context) chan wshrpc.RespOrErrorUnion[int]

func (*ServerImpl) WshServerImpl ¶

func (*ServerImpl) WshServerImpl()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL