Documentation
¶
Index ¶
- func CRLFChannel(ch chan types.WebSocketMessage) chan types.WebSocketMessage
- func CmdWebhook(filestore filesystem.Store, sessionStore *types.SessionStore, ...) gin.HandlerFunc
- func InitCommands(filestore filesystem.Store, fsctx filesystem.FSContext, ...) []sh.Command
- func NormCRLF(s string) string
- func ParseCommand(input string) ([]string, error)
- func RunClient(info types.ClientInfo, commands []sh.Command, filestore filesystem.Store, ...)
- type ChannelReader
- type ChannelWriter
- type CmdActivate
- type CmdB64
- type CmdCat
- type CmdChangePassword
- type CmdChmod
- type CmdClients
- type CmdCopy
- type CmdCryptoRand
- type CmdEcho
- type CmdEdgeNodes
- type CmdEmail
- type CmdEmbed
- type CmdError
- type CmdFinishFlight
- type CmdFluxStream
- type CmdHeartbeat
- type CmdHelp
- type CmdHex
- type CmdLogout
- type CmdLs
- type CmdMLRPC
- type CmdMQTT
- type CmdMkdir
- type CmdMv
- type CmdPilots
- type CmdRm
- type CmdSendText
- type CmdSockets
- type CmdTee
- type CmdWhoami
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CRLFChannel ¶
func CRLFChannel(ch chan types.WebSocketMessage) chan types.WebSocketMessage
func CmdWebhook ¶
func CmdWebhook( filestore filesystem.Store, sessionStore *types.SessionStore, apiKey chatbot.APIKey, jsonConn *jsonrpc2.Conn, mqttEvents *util.EventHandler[types.MQTTMessage], flux_cfg *influx.InfluxDBConfig, uazapi_cfg uazapi.UazapiConfig, email_cfg email.EmailConfig, ) gin.HandlerFunc
func InitCommands ¶
func InitCommands( filestore filesystem.Store, fsctx filesystem.FSContext, socketSession *types.SocketSession, sessionStore *types.SessionStore, apiKey chatbot.APIKey, jsonConn *jsonrpc2.Conn, mqttEvents *util.EventHandler[types.MQTTMessage], flux_cfg *influx.InfluxDBConfig, uazapi_cfg uazapi.UazapiConfig, email_cfg email.EmailConfig, ) []sh.Command
func ParseCommand ¶
ParseCommand splits a string into args with shell-like escaping rules
func RunClient ¶
func RunClient(info types.ClientInfo, commands []sh.Command, filestore filesystem.Store, wg *sync.WaitGroup)
Types ¶
type ChannelReader ¶
type ChannelWriter ¶
type ChannelWriter chan string
type CmdActivate ¶
func (*CmdActivate) Identifier ¶
func (c *CmdActivate) Identifier() string
func (*CmdActivate) Run ¶
func (c *CmdActivate) Run(ctx sh.CommandContext) int
type CmdChangePassword ¶
type CmdChangePassword struct {
FileStore filesystem.Store
}
func (*CmdChangePassword) Identifier ¶
func (c *CmdChangePassword) Identifier() string
func (*CmdChangePassword) Run ¶
func (c *CmdChangePassword) Run(ctx sh.CommandContext) int
type CmdClients ¶
type CmdClients struct {
Socket *types.SocketSession
}
func (*CmdClients) Identifier ¶
func (c *CmdClients) Identifier() string
func (*CmdClients) Run ¶
func (c *CmdClients) Run(ctx sh.CommandContext) int
type CmdCryptoRand ¶
type CmdCryptoRand struct{}
func (CmdCryptoRand) Identifier ¶
func (CmdCryptoRand) Identifier() string
func (CmdCryptoRand) Run ¶
func (CmdCryptoRand) Run(ctx sh.CommandContext) int
type CmdEdgeNodes ¶
type CmdEdgeNodes struct {
FileStore filesystem.Store
}
func (*CmdEdgeNodes) Identifier ¶
func (c *CmdEdgeNodes) Identifier() string
func (*CmdEdgeNodes) Run ¶
func (c *CmdEdgeNodes) Run(ctx sh.CommandContext) int
type CmdEmbed ¶
type CmdEmbed struct {
Conn *jsonrpc2.Conn
FileStore filesystem.Store
}
func (*CmdEmbed) Identifier ¶
type CmdFinishFlight ¶
type CmdFinishFlight struct {
FileStore filesystem.Store
}
func (*CmdFinishFlight) Identifier ¶
func (c *CmdFinishFlight) Identifier() string
func (*CmdFinishFlight) Run ¶
func (c *CmdFinishFlight) Run(ctx sh.CommandContext) int
type CmdFluxStream ¶
type CmdFluxStream struct {
FluxCfg *influx.InfluxDBConfig
}
func (CmdFluxStream) Identifier ¶
func (c CmdFluxStream) Identifier() string
func (CmdFluxStream) Run ¶
func (c CmdFluxStream) Run(ctx sh.CommandContext) int
type CmdHeartbeat ¶
type CmdHeartbeat struct{}
func (CmdHeartbeat) Identifier ¶
func (CmdHeartbeat) Identifier() string
func (CmdHeartbeat) Run ¶
func (CmdHeartbeat) Run(ctx sh.CommandContext) int
type CmdLogout ¶
type CmdLogout struct {
FileStore filesystem.Store
}
func (*CmdLogout) Identifier ¶
type CmdMLRPC ¶
func (CmdMLRPC) Identifier ¶
type CmdMQTT ¶
type CmdMQTT struct {
Events *util.EventHandler[types.MQTTMessage]
}
func (*CmdMQTT) Identifier ¶
type CmdPilots ¶
type CmdPilots struct {
FileStore filesystem.Store
}
func (*CmdPilots) Identifier ¶
type CmdSendText ¶
type CmdSendText struct {
UazapiConfig uazapi.UazapiConfig
}
func (*CmdSendText) Identifier ¶
func (c *CmdSendText) Identifier() string
func (*CmdSendText) Run ¶
func (c *CmdSendText) Run(ctx sh.CommandContext) int
type CmdSockets ¶
type CmdSockets struct {
SessionStore *types.SessionStore
}
func (*CmdSockets) Identifier ¶
func (c *CmdSockets) Identifier() string
func (*CmdSockets) Run ¶
func (c *CmdSockets) Run(ctx sh.CommandContext) int
type CmdWhoami ¶
type CmdWhoami struct {
FileStore filesystem.Store
Session *types.SocketSession
}
func (*CmdWhoami) Identifier ¶
Source Files
¶
- channel_reader.go
- channel_writer.go
- client.go
- cmd_activate.go
- cmd_b64.go
- cmd_cat.go
- cmd_change-password.go
- cmd_chmod.go
- cmd_clients.go
- cmd_copy.go
- cmd_crypto-rand.go
- cmd_echo.go
- cmd_edgenodes.go
- cmd_email.go
- cmd_embed.go
- cmd_error.go
- cmd_finish_flight.go
- cmd_flux.go
- cmd_heartbeat.go
- cmd_help.go
- cmd_hex.go
- cmd_logout.go
- cmd_ls.go
- cmd_mkdir.go
- cmd_ml-rpc.go
- cmd_mqtt.go
- cmd_mv.go
- cmd_pilots.go
- cmd_rm.go
- cmd_send-text.go
- cmd_sockets.go
- cmd_tee.go
- cmd_whoami.go
- crlf_middleware.go
- endpoint.go
- init_commands.go
- tokenize.go
Click to show internal directories.
Click to hide internal directories.