web

Documentation

Index

• func Init(ctx context.Context, c *hardware.TrackService) error
• func RouteWithMessageRouter(router *MessageRouter) echo.HandlerFunc
• type LayoutHTTPAdapter
  • func NewLayoutHTTP(c *hardware.TrackService, h io.Writer) *LayoutHTTPAdapter
  • func (l *LayoutHTTPAdapter) Handle(ctx context.Context)
  • func (l *LayoutHTTPAdapter) SetSwitch(c echo.Context) error
• type LayoutJSONAdapter
  • func NewLayoutJSONAdapter(c *hardware.TrackService, h io.Writer) *LayoutJSONAdapter
  • func (l *LayoutJSONAdapter) Handle(ctx context.Context)
  • func (l *LayoutJSONAdapter) SetSwitch(c echo.Context) error
• type MessageRouter
  • func NewRouter() *MessageRouter
  • func (r *MessageRouter) Subscribe() *chan []byte
  • func (r *MessageRouter) Unsubscribe(c *chan []byte)
  • func (r *MessageRouter) Write(in []byte) (int, error)

Functions

func Init

func Init(ctx context.Context, c *hardware.TrackService) error

func RouteWithMessageRouter

func RouteWithMessageRouter(router *MessageRouter) echo.HandlerFunc

Types

type LayoutHTTPAdapter

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

func NewLayoutHTTP

func NewLayoutHTTP(c *hardware.TrackService, h io.Writer) *LayoutHTTPAdapter

func (*LayoutHTTPAdapter) Handle

func (l *LayoutHTTPAdapter) Handle(ctx context.Context)

func (*LayoutHTTPAdapter) SetSwitch

func (l *LayoutHTTPAdapter) SetSwitch(c echo.Context) error

type LayoutJSONAdapter

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

func NewLayoutJSONAdapter

func NewLayoutJSONAdapter(c *hardware.TrackService, h io.Writer) *LayoutJSONAdapter

func (*LayoutJSONAdapter) Handle

func (l *LayoutJSONAdapter) Handle(ctx context.Context)

func (*LayoutJSONAdapter) SetSwitch

func (l *LayoutJSONAdapter) SetSwitch(c echo.Context) error

type MessageRouter

type MessageRouter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter() *MessageRouter

func (*MessageRouter) Subscribe

func (r *MessageRouter) Subscribe() *chan []byte

func (*MessageRouter) Unsubscribe

func (r *MessageRouter) Unsubscribe(c *chan []byte)

func (*MessageRouter) Write

func (r *MessageRouter) Write(in []byte) (int, error)