emqx

Documentation

Index

• Variables
• type AclDto
• type AuthDto
• type BridgeDto
• type Controller
  • func (x *Controller) Acl(ctx context.Context, c *app.RequestContext)
  • func (x *Controller) Auth(ctx context.Context, c *app.RequestContext)
  • func (x *Controller) Bridge(ctx context.Context, c *app.RequestContext)
• type M
• type Service
  • func (x *Service) Acl(ctx context.Context, dto AclDto) (err error)
  • func (x *Service) Auth(ctx context.Context, dto AuthDto) (err error)
  • func (x *Service) Bridge(ctx context.Context, dto BridgeDto) (err error)

Variables

var Provides = wire.NewSet(
	wire.Struct(new(Controller), "*"),
	wire.Struct(new(Service), "*"),
)

Types

type AclDto

type AclDto struct {
	Identity primitive.ObjectID `json:"identity" vd:"mongodb"`
	Topic    string             `json:"topic" vd:"required"`
}

type AuthDto

type AuthDto struct {
	Identity primitive.ObjectID `json:"identity" vd:"mongodb"`
	Token    string             `json:"token" vd:"required"`
}

type BridgeDto

type BridgeDto struct {
	Client  string `json:"client" vd:"required"`
	Topic   string `json:"topic" vd:"required"`
	Payload string `json:"payload" vd:"required"`
}

type Controller

type Controller struct {
	EmqxService *Service
}

func (*Controller) Acl

func (x *Controller) Acl(ctx context.Context, c *app.RequestContext)

func (*Controller) Auth

func (x *Controller) Auth(ctx context.Context, c *app.RequestContext)

func (*Controller) Bridge

func (x *Controller) Bridge(ctx context.Context, c *app.RequestContext)

type M

type M = map[string]interface{}

type Service

type Service struct {
	*common.Inject
}

func (*Service) Acl

func (x *Service) Acl(ctx context.Context, dto AclDto) (err error)

func (*Service) Auth

func (x *Service) Auth(ctx context.Context, dto AuthDto) (err error)

func (*Service) Bridge

func (x *Service) Bridge(ctx context.Context, dto BridgeDto) (err error)