worker

Documentation

Index

• Variables
• type Queue
  • func (q *Queue[T]) Dequeue() (T, error)
  • func (q *Queue[T]) Enqueue(item T)
• type Server
  • func New(device device.Device) (*suture.Supervisor, *Server)
  • func (s *Server) Serve(ctx context.Context) error
  • func (s *Server) SubscribeToActions(mqttClient MQTT.Client) error

Variables

var ErrNoItemsInQueue = errors.New("no items in queue")

Types

type Queue

type Queue[T any] struct {
	Item chan struct{}
	// contains filtered or unexported fields
}

func (*Queue[T]) Dequeue

func (q *Queue[T]) Dequeue() (T, error)

func (*Queue[T]) Enqueue

func (q *Queue[T]) Enqueue(item T)

type Server

type Server struct {
	Supervisor *suture.Supervisor
	// contains filtered or unexported fields
}

func New

func New(device device.Device) (*suture.Supervisor, *Server)

func (*Server) Serve

func (s *Server) Serve(ctx context.Context) error

func (*Server) SubscribeToActions

func (s *Server) SubscribeToActions(mqttClient MQTT.Client) error