libext

Oct 30, 2020

Changes in this version

+ type Client struct

+ func NewClient(ctx context.Context, endpointURL string, tlsConfig *tls.Config, ...) (*Client, error)

+ func (c *Client) ProcessNewStream(cmdCh chan<- *arhatgopb.Cmd, msgCh <-chan *arhatgopb.Msg) error

+ type Codec interface

+ ContentType func() string

+ NewDecoder func(r io.Reader) Decoder

+ NewEncoder func(w io.Writer) Encoder

+ type Controller struct

+ func NewController(ctx context.Context, name string, logger log.Interface, h Handler) (*Controller, error)

+ func (c *Controller) Close()

+ func (c *Controller) RefreshChannels() (cmdCh chan<- *arhatgopb.Cmd, msgCh <-chan *arhatgopb.Msg)

+ func (c *Controller) Start() error

+ type Decoder interface

+ Decode func(out interface{}) error

+ type Encoder interface

+ Encode func(any interface{}) error

+ type ExtensionType string

+ const ExtensionPeripheral

+ type Handler interface

+ HandleCmd func(id uint64, kind arhatgopb.CmdType, payload []byte) (proto.Marshaler, error)