Versions in this module Expand all Collapse all v0 v0.1.0 Jul 1, 2026 Changes in this version + const EnvTestDSN + const TimescaleImage + func DeflateControlList(entries []string) []byte + func DeviceCSR(t testing.TB) (*ecdsa.PrivateKey, string) + func DeviceTLSConfig(t testing.TB, clientCertPEM string, key *ecdsa.PrivateKey, ...) *tls.Config + func Golden(t testing.TB, name string, got []byte) + func InflateControlList(t testing.TB, frame []byte) []string + func Introspection(entries map[string][2]int) string + func MQTTConnect(t testing.TB, brokerURL, clientID string, cleanSession bool, ...) (paho.Client, bool) + func MQTTTryConnect(t testing.TB, brokerURL, clientID string, cleanSession bool, ...) (paho.Client, bool, error) + func ServerTLSCert(t testing.TB) (tls.Certificate, *x509.CertPool) + func StartTimescale(t testing.TB) *pgxpool.Pool + func WaitToken(t testing.TB, token paho.Token, timeout time.Duration) + type AstarteDevice struct + Client paho.Client + ID deviceid.ID + Realm string + func ConnectAstarteDevice(t testing.TB, brokerURL, realm string, id deviceid.ID, tlsCfg *tls.Config, ...) *AstarteDevice + func (d *AstarteDevice) Base() string + func (d *AstarteDevice) DataTopic(iface, path string) string + func (d *AstarteDevice) Disconnect() + func (d *AstarteDevice) EmptyCache(t testing.TB) + func (d *AstarteDevice) Messages() []ServerMessage + func (d *AstarteDevice) PublishIntrospection(t testing.TB, introspection string) + func (d *AstarteDevice) PublishRaw(t testing.TB, iface, path string, body []byte, qos byte) + func (d *AstarteDevice) PublishValue(t testing.TB, iface, path string, v payload.Value, ts *time.Time, ...) + func (d *AstarteDevice) SendProducerProperties(t testing.TB, entries []string) + func (d *AstarteDevice) WaitForMessage(t testing.TB, timeout time.Duration, what string, ...) ServerMessage + func (d *AstarteDevice) WaitForTopic(t testing.TB, timeout time.Duration, topic string) ServerMessage + type ServerMessage struct + Payload []byte + Topic string
Go to main page