rpcclient

func EventPublishCommand ¶

func EventPublishCommand(w *rpc.RpcClient, data rpctypes.EventType, opts *rpc.RpcOpts) error

command "eventpublish", rpctypes.EventPublishCommand

func EventReadHistoryCommand ¶

func EventReadHistoryCommand(w *rpc.RpcClient, data rpctypes.EventReadHistoryData, opts *rpc.RpcOpts) ([]*rpctypes.EventType, error)

command "eventreadhistory", rpctypes.EventReadHistoryCommand

func EventSubCommand ¶

func EventSubCommand(w *rpc.RpcClient, data rpctypes.SubscriptionRequest, opts *rpc.RpcOpts) error

command "eventsub", rpctypes.EventSubCommand

func EventUnsubAllCommand ¶

func EventUnsubAllCommand(w *rpc.RpcClient, opts *rpc.RpcOpts) error

command "eventunsuball", rpctypes.EventUnsubAllCommand

func EventUnsubCommand ¶

func EventUnsubCommand(w *rpc.RpcClient, data string, opts *rpc.RpcOpts) error

command "eventunsub", rpctypes.EventUnsubCommand

func GetAppRunGoRoutinesByIdsCommand ¶

func GetAppRunGoRoutinesByIdsCommand(w *rpc.RpcClient, data rpctypes.AppRunGoRoutinesByIdsRequest, opts *rpc.RpcOpts) (rpctypes.AppRunGoRoutinesData, error)

command "getapprungoroutinesbyids", rpctypes.GetAppRunGoRoutinesByIdsCommand

func GetAppRunGoRoutinesCommand ¶

func GetAppRunGoRoutinesCommand(w *rpc.RpcClient, data rpctypes.AppRunRequest, opts *rpc.RpcOpts) (rpctypes.AppRunGoRoutinesData, error)

command "getapprungoroutines", rpctypes.GetAppRunGoRoutinesCommand

func GetAppRunRuntimeStatsCommand ¶

func GetAppRunRuntimeStatsCommand(w *rpc.RpcClient, data rpctypes.AppRunRequest, opts *rpc.RpcOpts) (rpctypes.AppRunRuntimeStatsData, error)

command "getapprunruntimestats", rpctypes.GetAppRunRuntimeStatsCommand

func GetAppRunWatchesByIdsCommand ¶

func GetAppRunWatchesByIdsCommand(w *rpc.RpcClient, data rpctypes.AppRunWatchesByIdsRequest, opts *rpc.RpcOpts) (rpctypes.AppRunWatchesData, error)

command "getapprunwatchesbyids", rpctypes.GetAppRunWatchesByIdsCommand

func GetAppRunWatchesCommand ¶

func GetAppRunWatchesCommand(w *rpc.RpcClient, data rpctypes.AppRunRequest, opts *rpc.RpcOpts) (rpctypes.AppRunWatchesData, error)

command "getapprunwatches", rpctypes.GetAppRunWatchesCommand

func GetAppRunsCommand ¶

func GetAppRunsCommand(w *rpc.RpcClient, data rpctypes.AppRunUpdatesRequest, opts *rpc.RpcOpts) (rpctypes.AppRunsData, error)

command "getappruns", rpctypes.GetAppRunsCommand

func GetBareClient ¶ added in v0.1.1

func GetBareClient() *rpc.RpcClient

GetBareClient returns the BareClient, initializing it if needed

func GetWatchHistoryCommand ¶

func GetWatchHistoryCommand(w *rpc.RpcClient, data rpctypes.WatchHistoryRequest, opts *rpc.RpcOpts) (rpctypes.WatchHistoryData, error)

command "getwatchhistory", rpctypes.GetWatchHistoryCommand

func GetWatchNumericCommand ¶

func GetWatchNumericCommand(w *rpc.RpcClient, data rpctypes.WatchNumericRequest, opts *rpc.RpcOpts) (rpctypes.WatchNumericData, error)

command "getwatchnumeric", rpctypes.GetWatchNumericCommand

func GoRoutineSearchRequestCommand ¶

func GoRoutineSearchRequestCommand(w *rpc.RpcClient, data rpctypes.GoRoutineSearchRequestData, opts *rpc.RpcOpts) (rpctypes.GoRoutineSearchResultData, error)

command "goroutinesearchrequest", rpctypes.GoRoutineSearchRequestCommand

func LogGetMarkedLinesCommand ¶

func LogGetMarkedLinesCommand(w *rpc.RpcClient, data rpctypes.MarkedLinesRequestData, opts *rpc.RpcOpts) (rpctypes.MarkedLinesResultData, error)

command "loggetmarkedlines", rpctypes.LogGetMarkedLinesCommand

func LogSearchRequestCommand ¶

func LogSearchRequestCommand(w *rpc.RpcClient, data rpctypes.SearchRequestData, opts *rpc.RpcOpts) (rpctypes.SearchResultData, error)

command "logsearchrequest", rpctypes.LogSearchRequestCommand

func LogStreamUpdateCommand ¶

func LogStreamUpdateCommand(w *rpc.RpcClient, data rpctypes.StreamUpdateData, opts *rpc.RpcOpts) error

command "logstreamupdate", rpctypes.LogStreamUpdateCommand

func LogUpdateMarkedLinesCommand ¶

func LogUpdateMarkedLinesCommand(w *rpc.RpcClient, data rpctypes.MarkedLinesData, opts *rpc.RpcOpts) error

command "logupdatemarkedlines", rpctypes.LogUpdateMarkedLinesCommand

func LogWidgetAdminCommand ¶

func LogWidgetAdminCommand(w *rpc.RpcClient, data rpctypes.LogWidgetAdminData, opts *rpc.RpcOpts) error

command "logwidgetadmin", rpctypes.LogWidgetAdminCommand

func MessageCommand ¶

func MessageCommand(w *rpc.RpcClient, data rpctypes.CommandMessageData, opts *rpc.RpcOpts) error

command "message", rpctypes.MessageCommand

func RtnStreamErr ¶

func RtnStreamErr[T any](ch chan rpctypes.RespUnion[T], err error)

func SendRpcRequestCallHelper ¶

func SendRpcRequestCallHelper[T any](w *rpc.RpcClient, command string, data interface{}, opts *rpc.RpcOpts) (T, error)

func SendRpcRequestResponseStreamHelper ¶

func SendRpcRequestResponseStreamHelper[T any](w *rpc.RpcClient, command string, data interface{}, opts *rpc.RpcOpts) chan rpctypes.RespUnion[T]

func UpdateBrowserTabUrlCommand ¶

func UpdateBrowserTabUrlCommand(w *rpc.RpcClient, data rpctypes.BrowserTabUrlData, opts *rpc.RpcOpts) error

command "updatebrowsertaburl", rpctypes.UpdateBrowserTabUrlCommand

func UpdateStatusCommand ¶

func UpdateStatusCommand(w *rpc.RpcClient, data rpctypes.StatusUpdateData, opts *rpc.RpcOpts) error

command "updatestatus", rpctypes.UpdateStatusCommand

func WatchSearchRequestCommand ¶

func WatchSearchRequestCommand(w *rpc.RpcClient, data rpctypes.WatchSearchRequestData, opts *rpc.RpcOpts) (rpctypes.WatchSearchResultData, error)

command "watchsearchrequest", rpctypes.WatchSearchRequestCommand