mqtt

type Emitter ¶

type Emitter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Emitter is an implementation of transport.Emitter that uses MQTT as the transport.

Messages are published on a topic that is composed of a number of elements: <prefix>/out/<ocpp-version>/<cs-id>. The prefix is configured, the ocpp-version and cs-id are provided to the Emit function. If not configured the default prefix is `cs`.

The Emitter defaults to connecting to a broker on 127.0.0.1:1883.

func (e *Emitter) Emit(ctx context.Context, ocppVersion transport.OcppVersion, chargeStationId string, message *transport.Message) error

type Listener ¶

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

func NewListener(opts ...Opt[Listener]) *Listener

func (l *Listener) Connect(ctx context.Context, ocppVersion transport.OcppVersion, chargeStationId *string, handler transport.MessageHandler) (transport.Connection, error)

type Opt ¶

type Opt[T any] func(h *T)

func WithMqttBrokerUrl[T Emitter | Listener](brokerUrl *url.URL) Opt[T]

func WithMqttBrokerUrls[T Emitter | Listener](brokerUrls []*url.URL) Opt[T]

func WithMqttConnectSettings[T Emitter | Listener](mqttConnectTimeout, mqttConnectRetryDelay, mqttKeepAliveInterval time.Duration) Opt[T]

func WithMqttGroup[T Listener](mqttGroup string) Opt[T]

func WithMqttPrefix[T Emitter | Listener](mqttPrefix string) Opt[T]

func WithOtelTracer[T Emitter | Listener](tracer trace.Tracer) Opt[T]