ghm

type ConsoleConsumer[R any] struct {
	Converter func(R) any
}

type Consumer[R any] interface {
	Setup(*cobra.Command, string)
	Init(bool) error
	Consume(v R) error
	Close() error
}

type Entry map[string]any

type Executor interface {
	Main()
}

type HassioConsumer[R any] struct {
	Converter func(R) any
	OnConnect func(client MQTT.Client, topic, topicc, topica string)
	// contains filtered or unexported fields
}

type HttpServer[R any] struct {
	ToJsonConverter func(R) any
	ToRawConverter  func(R) Entry
	YAxis           []string
	// contains filtered or unexported fields
}

type IndexModel struct {
	Yaxis string
	Marks []string
}

type MemoryConsumer[R any] struct {
	// contains filtered or unexported fields
}

type Producer[R any] interface {
	Setup(*cobra.Command, string)
	Init(bool) error
	Produce() (R, error)
	Close() error
}