ghm

Documentation

Index

• type ConsoleConsumer
  • func (cc *ConsoleConsumer[R]) Close() error
  • func (cc *ConsoleConsumer[R]) Consume(v R) error
  • func (cc *ConsoleConsumer[R]) Init(d bool) error
  • func (cc *ConsoleConsumer[R]) Setup(cmd *cobra.Command, name string)
• type Consumer
• type Entry
• type Executor
  • func NewExecutor[R any](name string, p Producer[R], c ...Consumer[R]) Executor
• type HassioConsumer
  • func (hc *HassioConsumer[R]) Close() error
  • func (hc *HassioConsumer[R]) Consume(v R) error
  • func (hc *HassioConsumer[R]) Init(debug bool) error
  • func (hc *HassioConsumer[R]) Setup(cmd *cobra.Command, name string)
• type HttpServer
  • func (ht *HttpServer[R]) Close() error
  • func (ht *HttpServer[R]) Consume(v R) error
  • func (ht *HttpServer[R]) Init(d bool) error
  • func (ht *HttpServer[R]) Setup(cmd *cobra.Command, name string)
• type IndexModel
• type MemoryConsumer
  • func (mc *MemoryConsumer[R]) Close() error
  • func (mc *MemoryConsumer[R]) Consume(v R) error
  • func (mc MemoryConsumer[R]) Data(c ...func(R) Entry) []Entry
  • func (mc *MemoryConsumer[R]) Init(d bool) error
  • func (mc MemoryConsumer[R]) Last() R
  • func (mc *MemoryConsumer[R]) Setup(cmd *cobra.Command, name string)
• type Producer

Types

type ConsoleConsumer

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

func (*ConsoleConsumer[R]) Close

func (cc *ConsoleConsumer[R]) Close() error

func (*ConsoleConsumer[R]) Consume

func (cc *ConsoleConsumer[R]) Consume(v R) error

func (*ConsoleConsumer[R]) Init

func (cc *ConsoleConsumer[R]) Init(d bool) error

func (*ConsoleConsumer[R]) Setup

func (cc *ConsoleConsumer[R]) Setup(cmd *cobra.Command, name string)

type Consumer

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

Consumer is generic consumer

type Entry

type Entry map[string]any

type Executor

type Executor interface {
	Main()
}

Executor to be obtained via NewExecutor

func NewExecutor

func NewExecutor[R any](name string, p Producer[R], c ...Consumer[R]) Executor

type HassioConsumer

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

func (*HassioConsumer[R]) Close

func (hc *HassioConsumer[R]) Close() error

func (*HassioConsumer[R]) Consume

func (hc *HassioConsumer[R]) Consume(v R) error

func (*HassioConsumer[R]) Init

func (hc *HassioConsumer[R]) Init(debug bool) error

func (*HassioConsumer[R]) Setup

func (hc *HassioConsumer[R]) Setup(cmd *cobra.Command, name string)

type HttpServer

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

func (*HttpServer[R]) Close

func (ht *HttpServer[R]) Close() error

func (*HttpServer[R]) Consume

func (ht *HttpServer[R]) Consume(v R) error

func (*HttpServer[R]) Init

func (ht *HttpServer[R]) Init(d bool) error

func (*HttpServer[R]) Setup

func (ht *HttpServer[R]) Setup(cmd *cobra.Command, name string)

type IndexModel

type IndexModel struct {
	Yaxis string
	Marks []string
}

type MemoryConsumer

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

func (*MemoryConsumer[R]) Close

func (mc *MemoryConsumer[R]) Close() error

func (*MemoryConsumer[R]) Consume

func (mc *MemoryConsumer[R]) Consume(v R) error

func (MemoryConsumer[R]) Data

func (mc MemoryConsumer[R]) Data(c ...func(R) Entry) []Entry

func (*MemoryConsumer[R]) Init

func (mc *MemoryConsumer[R]) Init(d bool) error

func (MemoryConsumer[R]) Last

func (mc MemoryConsumer[R]) Last() R

func (*MemoryConsumer[R]) Setup

func (mc *MemoryConsumer[R]) Setup(cmd *cobra.Command, name string)

type Producer

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

Producer is a generic producer