c3_brokerStatus

Documentation

Index

• Variables
• func BootMain()
• type BootArgs
  • func NewBootArgs() *BootArgs
  • func (bx *BootArgs) ExecFunc() func()
  • func (bx *BootArgs) FlagDefine() func(xflag *flag.FlagSet)
• type ServiceHandler
  • func NewServiceHandler() *ServiceHandler
  • func (s *ServiceHandler) MsgHandler(cli mqtt.Client, msg mqtt.Message)
  • func (s *ServiceHandler) Start() error
• type Status
  • func (s *Status) Disable(target Status)
  • func (s *Status) Enable(target Status)
  • func (s Status) Equal(other Status) bool
  • func (s Status) Get(target Status) bool
  • func (s Status) String() string

Variables

var (
	Xbootargs = NewBootArgs()
)

Functions

func BootMain

func BootMain()

Types

type BootArgs

type BootArgs struct {
	MqttHostAddr string
	MqttHostPort int
}

func NewBootArgs

func NewBootArgs() *BootArgs

func (*BootArgs) ExecFunc

func (bx *BootArgs) ExecFunc() func()

func (*BootArgs) FlagDefine

func (bx *BootArgs) FlagDefine() func(xflag *flag.FlagSet)

type ServiceHandler

type ServiceHandler struct {
	// contains filtered or unexported fields
}

func NewServiceHandler

func NewServiceHandler() *ServiceHandler

func (*ServiceHandler) MsgHandler

func (s *ServiceHandler) MsgHandler(cli mqtt.Client, msg mqtt.Message)

func (*ServiceHandler) Start

func (s *ServiceHandler) Start() error

start for wait

type Status

type Status byte

const (
	// 共计8个状态位
	Status_0 Status = 1 << (iota)
	Status_1
	Status_2
	Status_3
	Status_4
	Status_5
	Status_6
	Status_7
)

func (*Status) Disable

func (s *Status) Disable(target Status)

func (*Status) Enable

func (s *Status) Enable(target Status)

func (Status) Equal

func (s Status) Equal(other Status) bool

func (Status) Get

func (s Status) Get(target Status) bool

func (Status) String

func (s Status) String() string