command

package
v0.0.0-...-1c24e16 Latest Latest
Warning

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

Go to latest
Published: Sep 20, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PING       = "PING"
	SUB        = "SUB"
	PUB        = "PUB"
	NOP        = "NOP"
	REQ        = "REQ"
	IDENTIFY   = "IDENTIFY"
	REGISTER   = "REGISTER"
	UNREGISTER = "UNREGISTER"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Command

type Command struct {
	Name   []byte
	Params [][]byte
	Body   []byte
}

func IDENTIFYCmd

func IDENTIFYCmd(data map[string]interface{}) (*Command, error)

func NopCmd

func NopCmd() *Command

func PingCmd

func PingCmd() *Command

func PublishCmd

func PublishCmd(topic string, body []byte) *Command

func RegisterCmd

func RegisterCmd(topic, channel string) *Command

func RequeueCmd

func RequeueCmd(id []byte) *Command

func SubscribeCmd

func SubscribeCmd(topic string, channel string) *Command

func UnRegisterCmd

func UnRegisterCmd(topic, channel string) *Command

func (*Command) Write

func (cmd *Command) Write(w io.Writer) error

emqcli to emqd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL