apis

type PublishCallbackFunc func(*PublishRequest, *PublishResponse)

type PublishID interface{}

type PublishRequest struct {
	Dup       bool
	Qos       byte
	Retain    bool
	TopicName string
	MessageID uint16
	Message   []byte
}

type PublishResponse struct {
	ID    PublishID
	Error error
}

type Publisher interface {
	Name() string
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	PublishAsync(context.Context, *PublishRequest, PublishCallbackFunc) error
	Serve() error
	Shutdown(err error)
	Close() error
}

type PublisherFactory interface {
	New(params []string) (Publisher, error)
}

type UserPasswordAuthRequest struct {
	Username string
	Password string
}

type UserPasswordAuthResponse struct {
	ReturnCode byte
}

type UserPasswordAuthenticator interface {
	Name() string
	Login(context.Context, *UserPasswordAuthRequest) (*UserPasswordAuthResponse, error)
	Close() error
}

type UserPasswordAuthenticatorFactory interface {
	New(params []string) (UserPasswordAuthenticator, error)
}