coap

Documentation

Index

• func NewCoAPClient(ctx context.Context, handleCmd types.AgentCmdHandleFunc, cfg interface{}) (_ client.Interface, err error)
• type Client
  • func (c *Client) Close() error
  • func (c *Client) Connect(dialCtx context.Context) error
  • func (c *Client) PostMsg(msg *aranyagopb.Msg) error
  • func (c *Client) Start(ctx context.Context) error
• type Config

Functions

func NewCoAPClient

func NewCoAPClient(
	ctx context.Context,
	handleCmd types.AgentCmdHandleFunc,
	cfg interface{},
) (_ client.Interface, err error)

nolint:gocyclo

Types

type Client

type Client struct {
	*clientutil.BaseClient
	// contains filtered or unexported fields
}

func (*Client) Close

func (c *Client) Close() error

func (*Client) Connect

func (c *Client) Connect(dialCtx context.Context) error

func (*Client) PostMsg

func (c *Client) PostMsg(msg *aranyagopb.Msg) error

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

type Config

type Config struct {
	clientutil.CommonConfig `json:",inline" yaml:",inline"`

	PathNamespaceFrom conf.ValueFromSpec `json:"pathNamespaceFrom" yaml:"pathNamespaceFrom"`
	Transport         string             `json:"transport" yaml:"transport"`
	URIQueries        map[string]string  `json:"uriQueries" yaml:"uriQueries"`
	KeepaliveInterval time.Duration      `json:"keepaliveInterval" yaml:"keepaliveInterval"`
}