agent

Documentation

Index

• Constants
• Variables
• type Service
  • func New(mc paho.Client, cfg *config.Config, ec edgex.Client, nc *nats.Conn, ...) (Service, error)
• type ServiceInfo

Constants

const (
	Path     = "./config.toml"
	Hearbeat = "heartbeat.>"
	Commands = "commands"
	Config   = "config"
)

Variables

var (

	// ErrMalformedEntity indicates malformed entity specification
	ErrMalformedEntity = errors.New("malformed entity specification")

	// ErrInvalidQueryParams indicates malformed URL
	ErrInvalidQueryParams = errors.New("invalid query params")
)

Types

type Service

type Service interface {
	// Execute command
	Execute(string, string) (string, error)

	// Control command
	Control(string, string) error

	// Update configuration file
	AddConfig(config.Config) error

	// Config returns Config struct created from config file
	Config() config.Config

	// Saves config file
	ServiceConfig(uuid, cmdStr string) error

	// Services returns service list
	Services() []ServiceInfo

	// Terminal used for terminal control of gateway
	Terminal(string, string) error

	// Publish message
	Publish(string, string) error
}

Service specifies API for publishing messages and subscribing to topics.

func New

func New(mc paho.Client, cfg *config.Config, ec edgex.Client, nc *nats.Conn, logger log.Logger) (Service, error)

New returns agent service implementation.

type ServiceInfo

type ServiceInfo struct {
	Name     string
	LastSeen time.Time
	Status   string
	Type     string
	Terminal int
}