test_utils

Documentation

Index

• func CreateDevices(bus *nats.Conn, devices []*mir_apiv1.CreateDeviceRequest) ([]*mir_apiv1.CreateDeviceResponse, error)
• func DeleteDevicesWithLabelsPanic(b *nats.Conn, lbl map[string]string)
• func ExecuteTestQueryForType[T any](t *testing.T, db *surrealdb.DB, query string, vars map[string]any) T
• func GetJsonBytes(m proto.Message) ([]byte, string, error)
• func GetProtoBytes(m proto.Message) ([]byte, string, error)
• func IsIntegratedServices() bool
• func ProtoToMap(p proto.Message) (map[string]any, error)
• func ProtoToPropertyMap(p proto.Message) (map[string]any, error)
• func ProtoToStructPb(p proto.Message) (*structpb.Struct, error)
• func SetupAllExternalsPanic(ctx context.Context, conns ConnsInfo) (*nats.Conn, *surrealdb.DB, influxdb2.Client, api.WriteAPI, api.QueryAPI)
• func SetupInfluxConnsPanic(ctx context.Context, url, token, org, bucket string) (influxdb2.Client, api.WriteAPI, api.QueryAPI)
• func SetupNatsConPanic(url string) *nats.Conn
• func SetupSurrealDbConnsPanic(url, user, pass, ns, db string) *surrealdb.DB
• func TestLogger(component string) zerolog.Logger
• type ConnsInfo
• type InfluxInfo
• type SurrealInfo

Functions

func CreateDevices

func CreateDevices(bus *nats.Conn, devices []*mir_apiv1.CreateDeviceRequest) ([]*mir_apiv1.CreateDeviceResponse, error)

func DeleteDevicesWithLabelsPanic

func DeleteDevicesWithLabelsPanic(b *nats.Conn, lbl map[string]string)

func ExecuteTestQueryForType

func ExecuteTestQueryForType[T any](t *testing.T, db *surrealdb.DB, query string, vars map[string]any) T

func GetJsonBytes

func GetJsonBytes(m proto.Message) ([]byte, string, error)

func GetProtoBytes

func GetProtoBytes(m proto.Message) ([]byte, string, error)

func IsIntegratedServices

func IsIntegratedServices() bool

func ProtoToMap

func ProtoToMap(p proto.Message) (map[string]any, error)

func ProtoToPropertyMap

func ProtoToPropertyMap(p proto.Message) (map[string]any, error)

func ProtoToStructPb

func ProtoToStructPb(p proto.Message) (*structpb.Struct, error)

func SetupAllExternalsPanic

func SetupAllExternalsPanic(ctx context.Context, conns ConnsInfo) (*nats.Conn, *surrealdb.DB, influxdb2.Client, api.WriteAPI, api.QueryAPI)

func SetupInfluxConnsPanic

func SetupInfluxConnsPanic(ctx context.Context, url, token, org, bucket string) (influxdb2.Client, api.WriteAPI, api.QueryAPI)

func SetupNatsConPanic

func SetupNatsConPanic(url string) *nats.Conn

func SetupSurrealDbConnsPanic

func SetupSurrealDbConnsPanic(url, user, pass, ns, db string) *surrealdb.DB

func TestLogger

func TestLogger(component string) zerolog.Logger

Types

type ConnsInfo

type ConnsInfo struct {
	Name    string
	BusUrl  string
	Surreal SurrealInfo
	Influx  InfluxInfo
}

type InfluxInfo

type InfluxInfo struct {
	Url    string
	Token  string
	Org    string
	Bucket string
}

type SurrealInfo

type SurrealInfo struct {
	Url  string
	User string
	Pass string
	Ns   string
	Db   string
}