store

Documentation

Index

• type Store
  • func NewStore(client *mqtt.Client, topic string) (*Store, error)
  • func (s *Store) Flatten(sep string) map[string]interface{}
  • func (s *Store) Notify(sup *pb.StateUpdatePoint)
  • func (s *Store) Subscribe() (chan *pb.StateUpdatePoint, error)
  • func (s *Store) Unsubscribe(ch chan *pb.StateUpdatePoint)
  • func (s *Store) Update(sup *pb.StateUpdatePoint) error

Types

type Store

type Store struct {
	State pb.StateUpdatePoint
	// contains filtered or unexported fields
}

func NewStore

func NewStore(client *mqtt.Client, topic string) (*Store, error)

func (*Store) Flatten

func (s *Store) Flatten(sep string) map[string]interface{}

func (*Store) Notify

func (s *Store) Notify(sup *pb.StateUpdatePoint)

func (*Store) Subscribe

func (s *Store) Subscribe() (chan *pb.StateUpdatePoint, error)

func (*Store) Unsubscribe

func (s *Store) Unsubscribe(ch chan *pb.StateUpdatePoint)

func (*Store) Update

func (s *Store) Update(sup *pb.StateUpdatePoint) error