wshserver

package
v0.16.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 28, 2026 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SimpleId_This      = "this"
	SimpleId_Block     = "block"
	SimpleId_Tab       = "tab"
	SimpleId_Ws        = "ws"
	SimpleId_Workspace = "workspace"
	SimpleId_Client    = "client"
	SimpleId_Global    = "global"
	SimpleId_Temp      = "temp"
)
View Source 
const (
	DefaultOutputChSize = 32
	DefaultInputChSize  = 32
)

Variables

View Source 
var InvalidWslDistroNames = []string{"docker-desktop", "docker-desktop-data"}
View Source 
var WshServerImpl = WshServer{}

Functions

func GetMainRpcClient 

func GetMainRpcClient() *wshutil.WshRpc

returns the wavesrv main rpc client singleton

func MakePlotData 

func MakePlotData(ctx context.Context, blockId string) error

func SavePlotData 

func SavePlotData(ctx context.Context, blockId string, history string) error

Types

type WshServer 

type WshServer struct{}

func (*WshServer) ActivityCommand 

func (ws *WshServer) ActivityCommand(ctx context.Context, activity wshrpc.ActivityUpdate) error

func (*WshServer) BlockInfoCommand 

func (ws *WshServer) BlockInfoCommand(ctx context.Context, blockId string) (*wshrpc.BlockInfoData, error)

func (*WshServer) BlockJobStatusCommand 

func (ws *WshServer) BlockJobStatusCommand(ctx context.Context, blockId string) (*wshrpc.BlockJobStatusData, error)

func (*WshServer) BlocksListCommand 

func (ws *WshServer) BlocksListCommand(
	ctx context.Context,
	req wshrpc.BlocksListRequest) ([]wshrpc.BlocksListEntry, error)

BlocksListCommand returns every block visible in the requested scope (current workspace by default).

func (*WshServer) CheckGoVersionCommand 

func (ws *WshServer) CheckGoVersionCommand(ctx context.Context) (*wshrpc.CommandCheckGoVersionRtnData, error)

func (*WshServer) ConnConnectCommand 

func (ws *WshServer) ConnConnectCommand(ctx context.Context, connRequest wshrpc.ConnRequest) error

func (*WshServer) ConnDisconnectCommand 

func (ws *WshServer) ConnDisconnectCommand(ctx context.Context, connName string) error

func (*WshServer) ConnEnsureCommand 

func (ws *WshServer) ConnEnsureCommand(ctx context.Context, data wshrpc.ConnExtData) error

func (*WshServer) ConnListCommand 

func (ws *WshServer) ConnListCommand(ctx context.Context) ([]string, error)

func (*WshServer) ConnReinstallWshCommand 

func (ws *WshServer) ConnReinstallWshCommand(ctx context.Context, data wshrpc.ConnExtData) error

func (*WshServer) ConnStatusCommand 

func (ws *WshServer) ConnStatusCommand(ctx context.Context) ([]wshrpc.ConnStatus, error)

func (*WshServer) ConnUpdateWshCommand 

func (ws *WshServer) ConnUpdateWshCommand(ctx context.Context, remoteInfo wshrpc.RemoteInfo) (bool, error)

func (*WshServer) ControllerAppendOutputCommand 

func (ws *WshServer) ControllerAppendOutputCommand(ctx context.Context, data wshrpc.CommandControllerAppendOutputData) error

func (*WshServer) ControllerDestroyCommand 

func (ws *WshServer) ControllerDestroyCommand(ctx context.Context, blockId string) error

func (*WshServer) ControllerInputCommand 

func (ws *WshServer) ControllerInputCommand(ctx context.Context, data wshrpc.CommandBlockInputData) error

func (*WshServer) ControllerResyncCommand 

func (ws *WshServer) ControllerResyncCommand(ctx context.Context, data wshrpc.CommandControllerResyncData) error

func (*WshServer) CreateBlockCommand 

func (ws *WshServer) CreateBlockCommand(ctx context.Context, data wshrpc.CommandCreateBlockData) (*waveobj.ORef, error)

func (*WshServer) CreateSubBlockCommand 

func (ws *WshServer) CreateSubBlockCommand(ctx context.Context, data wshrpc.CommandCreateSubBlockData) (*waveobj.ORef, error)

func (*WshServer) DeleteAppFileCommand 

func (ws *WshServer) DeleteAppFileCommand(ctx context.Context, data wshrpc.CommandDeleteAppFileData) error

func (*WshServer) DeleteBlockCommand 

func (ws *WshServer) DeleteBlockCommand(ctx context.Context, data wshrpc.CommandDeleteBlockData) error

func (*WshServer) DeleteBuilderCommand 

func (ws *WshServer) DeleteBuilderCommand(ctx context.Context, builderId string) error

func (*WshServer) DeleteSubBlockCommand 

func (ws *WshServer) DeleteSubBlockCommand(ctx context.Context, data wshrpc.CommandDeleteBlockData) error

func (*WshServer) DismissWshFailCommand 

func (ws *WshServer) DismissWshFailCommand(ctx context.Context, connName string) error

*

  • Dismisses the WshFail Command in runtime memory on the backend

func (*WshServer) DisposeSuggestionsCommand 

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

func (*WshServer) EventPublishCommand 

func (ws *WshServer) EventPublishCommand(ctx context.Context, data wps.WaveEvent) error

func (*WshServer) EventReadHistoryCommand 

func (ws *WshServer) EventReadHistoryCommand(ctx context.Context, data wshrpc.CommandEventReadHistoryData) ([]*wps.WaveEvent, error)

func (*WshServer) EventRecvCommand 

func (ws *WshServer) EventRecvCommand(ctx context.Context, data wps.WaveEvent) error

func (*WshServer) EventSubCommand 

func (ws *WshServer) EventSubCommand(ctx context.Context, data wps.SubscriptionRequest) error

func (*WshServer) EventUnsubAllCommand 

func (ws *WshServer) EventUnsubAllCommand(ctx context.Context) error

func (*WshServer) EventUnsubCommand 

func (ws *WshServer) EventUnsubCommand(ctx context.Context, data string) error

func (*WshServer) FetchSuggestionsCommand 

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

func (*WshServer) FileAppendCommand 

func (ws *WshServer) FileAppendCommand(ctx context.Context, data wshrpc.FileData) error

func (*WshServer) FileCopyCommand 

func (ws *WshServer) FileCopyCommand(ctx context.Context, data wshrpc.CommandFileCopyData) error

func (*WshServer) FileCreateCommand 

func (ws *WshServer) FileCreateCommand(ctx context.Context, data wshrpc.FileData) error

func (*WshServer) FileDeleteCommand 

func (ws *WshServer) FileDeleteCommand(ctx context.Context, data wshrpc.CommandDeleteFileData) error

func (*WshServer) FileInfoCommand 

func (ws *WshServer) FileInfoCommand(ctx context.Context, data wshrpc.FileData) (*wshrpc.FileInfo, error)

func (*WshServer) FileJoinCommand 

func (ws *WshServer) FileJoinCommand(ctx context.Context, paths []string) (*wshrpc.FileInfo, error)

func (*WshServer) FileListCommand 

func (ws *WshServer) FileListCommand(ctx context.Context, data wshrpc.FileListData) ([]*wshrpc.FileInfo, error)

func (*WshServer) FileListStreamCommand 

func (ws *WshServer) FileListStreamCommand(ctx context.Context, data wshrpc.FileListData) <-chan wshrpc.RespOrErrorUnion[wshrpc.CommandRemoteListEntriesRtnData]

func (*WshServer) FileMkdirCommand 

func (ws *WshServer) FileMkdirCommand(ctx context.Context, data wshrpc.FileData) error

func (*WshServer) FileMoveCommand 

func (ws *WshServer) FileMoveCommand(ctx context.Context, data wshrpc.CommandFileCopyData) error

func (*WshServer) FileReadCommand 

func (ws *WshServer) FileReadCommand(ctx context.Context, data wshrpc.FileData) (*wshrpc.FileData, error)

func (*WshServer) FileReadStreamCommand 

func (ws *WshServer) FileReadStreamCommand(ctx context.Context, data wshrpc.FileData) <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]

func (*WshServer) FileRestoreBackupCommand 

func (ws *WshServer) FileRestoreBackupCommand(ctx context.Context, data wshrpc.CommandFileRestoreBackupData) error

func (*WshServer) FileWriteCommand 

func (ws *WshServer) FileWriteCommand(ctx context.Context, data wshrpc.FileData) error

func (*WshServer) FindGitBashCommand 

func (ws *WshServer) FindGitBashCommand(ctx context.Context, rescan bool) (string, error)

func (*WshServer) GetAllTabIndicatorsCommand 

func (ws *WshServer) GetAllTabIndicatorsCommand(ctx context.Context) (map[string]*wshrpc.TabIndicator, error)

func (*WshServer) GetAllVarsCommand 

func (ws *WshServer) GetAllVarsCommand(ctx context.Context, data wshrpc.CommandVarData) ([]wshrpc.CommandVarResponseData, error)

func (*WshServer) GetBuilderOutputCommand 

func (ws *WshServer) GetBuilderOutputCommand(ctx context.Context, builderId string) ([]string, error)

func (*WshServer) GetBuilderStatusCommand 

func (ws *WshServer) GetBuilderStatusCommand(ctx context.Context, builderId string) (*wshrpc.BuilderStatusData, error)

func (*WshServer) GetFullConfigCommand 

func (ws *WshServer) GetFullConfigCommand(ctx context.Context) (wconfig.FullConfigType, error)

func (*WshServer) GetJwtPublicKeyCommand 

func (ws *WshServer) GetJwtPublicKeyCommand(ctx context.Context) (string, error)

func (*WshServer) GetMetaCommand 

func (ws *WshServer) GetMetaCommand(ctx context.Context, data wshrpc.CommandGetMetaData) (waveobj.MetaMapType, error)

func (*WshServer) GetRTInfoCommand 

func (ws *WshServer) GetRTInfoCommand(ctx context.Context, data wshrpc.CommandGetRTInfoData) (*waveobj.ObjRTInfo, error)

func (*WshServer) GetSecretsCommand 

func (ws *WshServer) GetSecretsCommand(ctx context.Context, names []string) (map[string]string, error)

func (*WshServer) GetSecretsLinuxStorageBackendCommand 

func (ws *WshServer) GetSecretsLinuxStorageBackendCommand(ctx context.Context) (string, error)

func (*WshServer) GetSecretsNamesCommand 

func (ws *WshServer) GetSecretsNamesCommand(ctx context.Context) ([]string, error)

func (*WshServer) GetTabCommand 

func (ws *WshServer) GetTabCommand(ctx context.Context, tabId string) (*waveobj.Tab, error)

func (*WshServer) GetTempDirCommand 

func (ws *WshServer) GetTempDirCommand(ctx context.Context, data wshrpc.CommandGetTempDirData) (string, error)

func (*WshServer) GetVarCommand 

func (ws *WshServer) GetVarCommand(ctx context.Context, data wshrpc.CommandVarData) (*wshrpc.CommandVarResponseData, error)

func (*WshServer) GetWaveAIChatCommand 

func (ws *WshServer) GetWaveAIChatCommand(ctx context.Context, data wshrpc.CommandGetWaveAIChatData) (any, error)

func (*WshServer) GetWaveAIModeConfigCommand 

func (ws *WshServer) GetWaveAIModeConfigCommand(ctx context.Context) (wconfig.AIModeConfigUpdate, error)

func (*WshServer) GetWaveAIRateLimitCommand 

func (ws *WshServer) GetWaveAIRateLimitCommand(ctx context.Context) (any, error)

func (*WshServer) JobCmdExitedCommand 

func (ws *WshServer) JobCmdExitedCommand(ctx context.Context, data wshrpc.CommandJobCmdExitedData) error

func (*WshServer) JobControllerAttachJobCommand 

func (ws *WshServer) JobControllerAttachJobCommand(ctx context.Context, data wshrpc.CommandJobControllerAttachJobData) error

func (*WshServer) JobControllerConnectedJobsCommand 

func (ws *WshServer) JobControllerConnectedJobsCommand(ctx context.Context) ([]string, error)

func (*WshServer) JobControllerDeleteJobCommand 

func (ws *WshServer) JobControllerDeleteJobCommand(ctx context.Context, jobId string) error

func (*WshServer) JobControllerDetachJobCommand 

func (ws *WshServer) JobControllerDetachJobCommand(ctx context.Context, jobId string) error

func (*WshServer) JobControllerDisconnectJobCommand 

func (ws *WshServer) JobControllerDisconnectJobCommand(ctx context.Context, jobId string) error

func (*WshServer) JobControllerExitJobCommand 

func (ws *WshServer) JobControllerExitJobCommand(ctx context.Context, jobId string) error

func (*WshServer) JobControllerListCommand 

func (ws *WshServer) JobControllerListCommand(ctx context.Context) ([]*waveobj.Job, error)

func (*WshServer) JobControllerReconnectJobCommand 

func (ws *WshServer) JobControllerReconnectJobCommand(ctx context.Context, jobId string) error

func (*WshServer) JobControllerReconnectJobsForConnCommand 

func (ws *WshServer) JobControllerReconnectJobsForConnCommand(ctx context.Context, connName string) error

func (*WshServer) JobControllerStartJobCommand 

func (ws *WshServer) JobControllerStartJobCommand(ctx context.Context, data wshrpc.CommandJobControllerStartJobData) (string, error)

func (*WshServer) ListAllAppFilesCommand 

func (ws *WshServer) ListAllAppFilesCommand(ctx context.Context, data wshrpc.CommandListAllAppFilesData) (*wshrpc.CommandListAllAppFilesRtnData, error)

func (*WshServer) ListAllAppsCommand 

func (ws *WshServer) ListAllAppsCommand(ctx context.Context) ([]wshrpc.AppInfo, error)

func (*WshServer) ListAllEditableAppsCommand 

func (ws *WshServer) ListAllEditableAppsCommand(ctx context.Context) ([]wshrpc.AppInfo, error)

func (*WshServer) MakeDraftFromLocalCommand 

func (ws *WshServer) MakeDraftFromLocalCommand(ctx context.Context, data wshrpc.CommandMakeDraftFromLocalData) (*wshrpc.CommandMakeDraftFromLocalRtnData, error)

func (*WshServer) MessageCommand 

func (ws *WshServer) MessageCommand(ctx context.Context, data wshrpc.CommandMessageData) error

for testing

func (*WshServer) NotifySystemResumeCommand 

func (ws *WshServer) NotifySystemResumeCommand(ctx context.Context) error

func (*WshServer) PathCommand 

func (ws *WshServer) PathCommand(ctx context.Context, data wshrpc.PathCommandData) (string, error)

func (*WshServer) PublishAppCommand 

func (ws *WshServer) PublishAppCommand(ctx context.Context, data wshrpc.CommandPublishAppData) (*wshrpc.CommandPublishAppRtnData, error)

func (*WshServer) ReadAppFileCommand 

func (ws *WshServer) ReadAppFileCommand(ctx context.Context, data wshrpc.CommandReadAppFileData) (*wshrpc.CommandReadAppFileRtnData, error)

func (*WshServer) RecordTEventCommand 

func (ws *WshServer) RecordTEventCommand(ctx context.Context, data telemetrydata.TEvent) error

func (*WshServer) RenameAppFileCommand 

func (ws *WshServer) RenameAppFileCommand(ctx context.Context, data wshrpc.CommandRenameAppFileData) error

func (*WshServer) ResolveIdsCommand 

func (ws *WshServer) ResolveIdsCommand(ctx context.Context, data wshrpc.CommandResolveIdsData) (wshrpc.CommandResolveIdsRtnData, error)

func (*WshServer) RestartBuilderAndWaitCommand 

func (ws *WshServer) RestartBuilderAndWaitCommand(ctx context.Context, data wshrpc.CommandRestartBuilderAndWaitData) (*wshrpc.RestartBuilderAndWaitResult, error)

func (WshServer) SendTelemetryCommand 

func (ws WshServer) SendTelemetryCommand(ctx context.Context) error

func (*WshServer) SetConfigCommand 

func (ws *WshServer) SetConfigCommand(ctx context.Context, data wshrpc.MetaSettingsType) error

func (*WshServer) SetConnectionsConfigCommand 

func (ws *WshServer) SetConnectionsConfigCommand(ctx context.Context, data wshrpc.ConnConfigRequest) error

func (*WshServer) SetMetaCommand 

func (ws *WshServer) SetMetaCommand(ctx context.Context, data wshrpc.CommandSetMetaData) error

func (*WshServer) SetRTInfoCommand 

func (ws *WshServer) SetRTInfoCommand(ctx context.Context, data wshrpc.CommandSetRTInfoData) error

func (*WshServer) SetSecretsCommand 

func (ws *WshServer) SetSecretsCommand(ctx context.Context, secrets map[string]*string) error

func (*WshServer) SetVarCommand 

func (ws *WshServer) SetVarCommand(ctx context.Context, data wshrpc.CommandVarData) error

func (*WshServer) StartBuilderCommand 

func (ws *WshServer) StartBuilderCommand(ctx context.Context, data wshrpc.CommandStartBuilderData) error

func (*WshServer) StopBuilderCommand 

func (ws *WshServer) StopBuilderCommand(ctx context.Context, builderId string) error

func (*WshServer) StreamTestCommand 

func (ws *WshServer) StreamTestCommand(ctx context.Context) chan wshrpc.RespOrErrorUnion[int]

for testing

func (*WshServer) StreamWaveAiCommand 

func (ws *WshServer) StreamWaveAiCommand(ctx context.Context, request wshrpc.WaveAIStreamRequest) chan wshrpc.RespOrErrorUnion[wshrpc.WaveAIPacketType]

func (*WshServer) TestCommand 

func (ws *WshServer) TestCommand(ctx context.Context, data string) error

func (*WshServer) WaitForRouteCommand 

func (ws *WshServer) WaitForRouteCommand(ctx context.Context, data wshrpc.CommandWaitForRouteData) (bool, error)

func (*WshServer) WaveAIEnableTelemetryCommand 

func (ws *WshServer) WaveAIEnableTelemetryCommand(ctx context.Context) error

func (*WshServer) WaveAIGetToolDiffCommand 

func (ws *WshServer) WaveAIGetToolDiffCommand(ctx context.Context, data wshrpc.CommandWaveAIGetToolDiffData) (*wshrpc.CommandWaveAIGetToolDiffRtnData, error)

func (*WshServer) WaveAIToolApproveCommand 

func (ws *WshServer) WaveAIToolApproveCommand(ctx context.Context, data wshrpc.CommandWaveAIToolApproveData) error

func (*WshServer) WaveFileReadStreamCommand 

func (ws *WshServer) WaveFileReadStreamCommand(ctx context.Context, data wshrpc.CommandWaveFileReadStreamData) (*wshrpc.WaveFileInfo, error)

func (*WshServer) WaveInfoCommand 

func (ws *WshServer) WaveInfoCommand(ctx context.Context) (*wshrpc.WaveInfoData, error)

func (*WshServer) WorkspaceListCommand 

func (ws *WshServer) WorkspaceListCommand(ctx context.Context) ([]wshrpc.WorkspaceInfoData, error)

func (*WshServer) WriteAppFileCommand 

func (ws *WshServer) WriteAppFileCommand(ctx context.Context, data wshrpc.CommandWriteAppFileData) error

func (*WshServer) WriteAppGoFileCommand 

func (ws *WshServer) WriteAppGoFileCommand(ctx context.Context, data wshrpc.CommandWriteAppGoFileData) (*wshrpc.CommandWriteAppGoFileRtnData, error)

func (*WshServer) WriteAppSecretBindingsCommand 

func (ws *WshServer) WriteAppSecretBindingsCommand(ctx context.Context, data wshrpc.CommandWriteAppSecretBindingsData) error

func (*WshServer) WriteTempFileCommand 

func (ws *WshServer) WriteTempFileCommand(ctx context.Context, data wshrpc.CommandWriteTempFileData) (string, error)

func (*WshServer) WshActivityCommand 

func (ws *WshServer) WshActivityCommand(ctx context.Context, data map[string]int) error

func (*WshServer) WshServerImpl 

func (*WshServer) WshServerImpl()

func (*WshServer) WslDefaultDistroCommand 

func (ws *WshServer) WslDefaultDistroCommand(ctx context.Context) (string, error)

func (*WshServer) WslListCommand 

func (ws *WshServer) WslListCommand(ctx context.Context) ([]string, error)

func (*WshServer) WslStatusCommand 

func (ws *WshServer) WslStatusCommand(ctx context.Context) ([]wshrpc.ConnStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.