api

Documentation

Index

• type MqttTransport
  • func NewMqttTransport() *MqttTransport
  • func (t *MqttTransport) Connect() error
  • func (t *MqttTransport) Disconnect() error
  • func (t *MqttTransport) Publish(topic string, data []byte) error
  • func (t *MqttTransport) Subscribe(topic string) (chan []byte, error)
  • func (t *MqttTransport) Unsubscribe(topic string) error
• type NatsTransport
  • func GetCurrentTransport() *NatsTransport
  • func NewNatsTransport() *NatsTransport
  • func (transport *NatsTransport) Connect() error
  • func (transport *NatsTransport) Disconnect() error
  • func (transport *NatsTransport) GetSubscriptions() []string
  • func (transport *NatsTransport) Publish(subj string, data []byte) error
  • func (transport *NatsTransport) Subscribe(subj string) (chan []byte, error)
  • func (transport *NatsTransport) Unsubscribe(subj string) error
• type RedirectServer
  • func NewRedirectServer(nats *NatsTransport) *RedirectServer
  • func (redirect *RedirectServer) Send(ctx context.Context, in *models.PingMessage) (*models.Empty, error)

Types

type MqttTransport

type MqttTransport struct {
	Client paho.Client
}

func NewMqttTransport

func NewMqttTransport() *MqttTransport

func (*MqttTransport) Connect

func (t *MqttTransport) Connect() error

func (*MqttTransport) Disconnect

func (t *MqttTransport) Disconnect() error

func (*MqttTransport) Publish

func (t *MqttTransport) Publish(topic string, data []byte) error

func (*MqttTransport) Subscribe

func (t *MqttTransport) Subscribe(topic string) (chan []byte, error)

func (*MqttTransport) Unsubscribe

func (t *MqttTransport) Unsubscribe(topic string) error

type NatsTransport

type NatsTransport struct {
	URL  string
	Conn *nats.Conn
}

func GetCurrentTransport

func GetCurrentTransport() *NatsTransport

func NewNatsTransport

func NewNatsTransport() *NatsTransport

func (*NatsTransport) Connect

func (transport *NatsTransport) Connect() error

func (*NatsTransport) Disconnect

func (transport *NatsTransport) Disconnect() error

func (*NatsTransport) GetSubscriptions

func (transport *NatsTransport) GetSubscriptions() []string

func (*NatsTransport) Publish

func (transport *NatsTransport) Publish(subj string, data []byte) error

func (*NatsTransport) Subscribe

func (transport *NatsTransport) Subscribe(subj string) (chan []byte, error)

func (*NatsTransport) Unsubscribe

func (transport *NatsTransport) Unsubscribe(subj string) error

type RedirectServer

type RedirectServer struct {
	NatsHandler *NatsTransport
}

func NewRedirectServer

func NewRedirectServer(nats *NatsTransport) *RedirectServer

func (*RedirectServer) Send

func (redirect *RedirectServer) Send(ctx context.Context, in *models.PingMessage) (*models.Empty, error)