service

type APIClient struct {
	*c8y.Client
}

type DefaultServiceOptions struct {
	Broker                     string
	ClientID                   string
	CleanSession               bool
	HTTPEndpoint               string
	RouteDirs                  []string
	MaxRouteDepth              int
	PostMessageDelay           time.Duration
	Debug                      bool
	DryRun                     bool
	MetaOptions                []MetaOption
	LibraryPaths               []string
	UseColor                   bool
	EntityFile                 string
	EnableRegistrationListener bool
}

type Entity struct {
	ID          string          `json:"@id"`
	EntityType  string          `json:"@type"`
	ParentID    string          `json:"@parent"`
	Type        string          `json:"type"`
	DisplayName string          `json:"displayName"`
	Contents    []EntityContent `json:"contents,omitempty"`
}

type EntityContent struct {
	ID     string `json:"@id"`
	Type   string `json:"@type"`
	Value  string `json:"value"`
	Schema string `json:"schema"`
}

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

type MessageHandler func(topic string, message_in string) (message_out *streamer.OutputMessage, err error)

type MetaOption func(m map[string]any)

type Service struct {
	Client        mqtt.Client
	APIClient     *APIClient
	Subscriptions map[string]byte
	Routes        []routes.Route
	EntityStore   *EntityStore
}

type SettingOption func() string

type VariablesFactory func() string