client

Documentation

Index

• func GetConnection(_ api.StreamContext) modules.Connection
• type Client
  • func (es *Client) CfgValidate(props map[string]interface{}) error
  • func (es *Client) Close(ctx api.StreamContext) error
  • func (es *Client) DetachSub(ctx api.StreamContext, props map[string]any)
  • func (es *Client) Dial(ctx api.StreamContext) error
  • func (es *Client) Disconnect() error
  • func (es *Client) GetId(ctx api.StreamContext) string
  • func (es *Client) Ping(_ api.StreamContext) error
  • func (es *Client) Provision(ctx api.StreamContext, conId string, props map[string]any) error
  • func (es *Client) Publish(env types.MessageEnvelope, topic string) error
  • func (es *Client) Subscribe(msg chan types.MessageEnvelope, topic string, err chan error) error
• type EdgexConf

Functions

func GetConnection

func GetConnection(_ api.StreamContext) modules.Connection

Types

type Client

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

func (*Client) CfgValidate

func (es *Client) CfgValidate(props map[string]interface{}) error

func (*Client) Close

func (es *Client) Close(ctx api.StreamContext) error

func (*Client) DetachSub

func (es *Client) DetachSub(ctx api.StreamContext, props map[string]any)

func (*Client) Dial

func (es *Client) Dial(ctx api.StreamContext) error

func (*Client) Disconnect

func (es *Client) Disconnect() error

func (*Client) GetId

func (es *Client) GetId(ctx api.StreamContext) string

func (*Client) Ping

func (es *Client) Ping(_ api.StreamContext) error

func (*Client) Provision

func (es *Client) Provision(ctx api.StreamContext, conId string, props map[string]any) error

func (*Client) Publish

func (es *Client) Publish(env types.MessageEnvelope, topic string) error

func (*Client) Subscribe

func (es *Client) Subscribe(msg chan types.MessageEnvelope, topic string, err chan error) error

type EdgexConf

type EdgexConf struct {
	Protocol string            `json:"protocol"`
	Server   string            `json:"server"`
	Host     string            `json:"host"`
	Port     int               `json:"port"`
	Type     string            `json:"type"`
	Optional map[string]string `json:"optional"`
}