wshserver

package
v0.8.12 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultOutputChSize = 32
	DefaultInputChSize  = 32
)
View Source 
const SimpleId_Tab = "tab"
View Source 
const SimpleId_This = "this"

Variables

View Source 
var SimpleId_BlockNum_Regex = regexp.MustCompile(`^\d+$`)
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) BlockInfoCommand 

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

func (*WshServer) ConnConnectCommand 

func (ws *WshServer) ConnConnectCommand(ctx context.Context, connName string) 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) DeleteBlockCommand 

func (ws *WshServer) DeleteBlockCommand(ctx context.Context, data wshrpc.CommandDeleteBlockData) 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) 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) 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) 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 wconfig.MetaSettingsType) error

func (*WshServer) SetMetaCommand 

func (ws *WshServer) SetMetaCommand(ctx context.Context, data wshrpc.CommandSetMetaData) 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) WshServerImpl 

func (*WshServer) WshServerImpl()

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.