subscribe

Documentation

Index

• Constants
• func Register(root *cobra.Command, brokers *[]string)
• type Config

Constants

const (
	// TopicFlag used with cobra to read the topic flag from user.
	TopicFlag = "topic"
	// QoSFlag used with cobra to read the qos flag from user.
	QoSFlag = "qos"

	// Timeout for disconnecting from brokers.
	Timeout = 10
)

Functions

func Register

func Register(root *cobra.Command, brokers *[]string)

Register migrate command.

Types

type Config

type Config struct {
	Brokers []string
	QoS     byte
	Topic   string
}