api

type Cfg struct {
	Log                log.Logger
	Ctrl               svc.Ctrl
	Metric             *metric.Metric
	PubChan            chan<- *model.Cfg
	PortRPC            uint32
	PortREST           uint32
	CfgProvider        CfgProvider
	DataProvider       DataProvider
	Retry              time.Duration
	PublicKey          string
	PrivateKey         string
	TerminationTimeout time.Duration
}

type CfgProvider interface {
	GetInitCfg(m *model.Meta) (*model.Cfg, error)
	GetCfg(devID string, t model.Type) (*model.Cfg, error)
	SetCfg(devID string, t model.Type, c *model.Cfg) error
}

type DataProvider interface {
	GetDevsData() ([]model.Data, error)
	GetDevData(devID string) (*model.Data, error)
	SaveData(*model.Data) error
}

type Publisher interface {
	Publish(msg interface{}, channel string) (int64, error)
}