wshserver

package
v0.10.0-beta.4 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2024 License: Apache-2.0 Imports: 30 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 added in v0.9.3 

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) 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, connName string) error

func (*WshServer) ConnListCommand 

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

func (*WshServer) ConnReinstallWshCommand 

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

func (*WshServer) ConnStatusCommand 

func (ws *WshServer) ConnStatusCommand(ctx context.Context) ([]wshrpc.ConnStatus, 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) ControllerStopCommand 

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

func (*WshServer) CreateBlockCommand 

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

func (*WshServer) CreateSubBlockCommand added in v0.9.0 

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

func (*WshServer) DeleteBlockCommand 

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

func (*WshServer) DeleteSubBlockCommand added in v0.9.0 

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

func (*WshServer) DismissWshFailCommand added in v0.10.0 

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

*

  • Dismisses the WshFail Command in runtime memory on the backend

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) FileAppendCommand 

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

func (*WshServer) FileAppendIJsonCommand 

func (ws *WshServer) FileAppendIJsonCommand(ctx context.Context, data wshrpc.CommandAppendIJsonData) error

func (*WshServer) FileCreateCommand added in v0.9.3 

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

func (*WshServer) FileDeleteCommand added in v0.9.3 

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

func (*WshServer) FileInfoCommand added in v0.9.3 

func (ws *WshServer) FileInfoCommand(ctx context.Context, data wshrpc.CommandFileData) (*wshrpc.WaveFileInfo, error)

func (*WshServer) FileListCommand added in v0.9.3 

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

func (*WshServer) FileReadCommand 

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

func (*WshServer) FileWriteCommand 

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

func (*WshServer) GetMetaCommand 

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

func (*WshServer) GetVarCommand added in v0.9.3 

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

func (*WshServer) MessageCommand 

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

for testing

func (*WshServer) ResolveIdsCommand 

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

func (*WshServer) SetConfigCommand 

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

func (*WshServer) SetConnectionsConfigCommand added in v0.10.0 

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) SetVarCommand added in v0.9.3 

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

func (*WshServer) SetViewCommand 

func (ws *WshServer) SetViewCommand(ctx context.Context, data wshrpc.CommandBlockSetViewData) 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.OpenAiStreamRequest) chan wshrpc.RespOrErrorUnion[wshrpc.OpenAIPacketType]

func (*WshServer) TestCommand 

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

func (*WshServer) WaitForRouteCommand added in v0.9.0 

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

func (*WshServer) WaveInfoCommand added in v0.9.1 

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

func (*WshServer) WorkspaceListCommand added in v0.10.0 

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

func (*WshServer) WshActivityCommand added in v0.9.3 

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

func (*WshServer) WshServerImpl 

func (*WshServer) WshServerImpl()

func (*WshServer) WslDefaultDistroCommand added in v0.9.0 

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

func (*WshServer) WslListCommand added in v0.9.0 

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

func (*WshServer) WslStatusCommand added in v0.9.0 

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.