proxy

Documentation

Index

• type App
  • func (a *App) HandleConnection(ctx context.Context, wg *sync.WaitGroup, gateway chan comfoconnect.Message) error
  • func (a *App) Write(message comfoconnect.Message) error
• type Client
  • func NewClient(ip string, macAddress []byte, toGateway chan comfoconnect.Message, ...) *Client
  • func (c Client) Run(ctx context.Context, wg *sync.WaitGroup) error
• type Listener
  • func NewListener(toGateway chan comfoconnect.Message) *Listener
  • func (l *Listener) Run(ctx context.Context, wg *sync.WaitGroup)
• type Proxy
  • func NewProxy(gatewayIP string, myMacAddress []byte) *Proxy
  • func (p Proxy) Run(ctx context.Context, wg *sync.WaitGroup)

Types

type App

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

func (*App) HandleConnection

func (a *App) HandleConnection(ctx context.Context, wg *sync.WaitGroup, gateway chan comfoconnect.Message) error

func (*App) Write

func (a *App) Write(message comfoconnect.Message) error

type Client

type Client struct {
	IP string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ip string, macAddress []byte, toGateway chan comfoconnect.Message, fromGateway chan comfoconnect.Message) *Client

func (Client) Run

func (c Client) Run(ctx context.Context, wg *sync.WaitGroup) error

type Listener

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

func NewListener

func NewListener(toGateway chan comfoconnect.Message) *Listener

func (*Listener) Run

func (l *Listener) Run(ctx context.Context, wg *sync.WaitGroup)

type Proxy

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

func NewProxy

func NewProxy(gatewayIP string, myMacAddress []byte) *Proxy

func (Proxy) Run

func (p Proxy) Run(ctx context.Context, wg *sync.WaitGroup)