plugin

type BackendConfig struct {
	DriverName string
	ReportSvc  Report
	Log        log.Logger
}

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Driver interface {
	// GetDriverInfo 获取驱动信息
	GetDriverInfo(req *Request) (*Response, error)
	// SetConfig 配置驱动，目前只配置了驱动的配置文件路径
	SetConfig(req *Request) (*Response, error)
	// Setup 宿主进程上报接口传递，必须调用下述逻辑，其余可用户自定义
	Setup(config *BackendConfig) (*Response, error)
	// Start 驱动采集启动，用户自定义实现
	Start(req *Request) (*Response, error)
	// Restart 驱动重启，用户自定义实现
	Restart(req *Request) (*Response, error)
	// Stop 驱动停止，用户自定义实现
	Stop(req *Request) (*Response, error)

	// Get 召测，用户自定义实现
	Get(req *Request) (*Response, error)
	// Set 置数，用户自定义实现
	Set(req *Request) (*Response, error)
}

type DriverConfig struct {
	Name       string `yaml:"name" json:"name"`
	BinPath    string `yaml:"binPath" json:"binPath"`
	ConfigPath string `yaml:"configPath" json:"configPath"`
}

type DriverGRPCPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	Factory Factory
	Log     log.Logger
}

type Entry struct {
	Entry string `yaml:"entry" json:"entry" validate:"nonzero"`
}

type Factory func(context.Context, *BackendConfig) (Driver, error)

type Report interface {
	Post(req *Request) (*Response, error)
	State(req *Request) (*Response, error)
}

type Request struct {
	BrokerID  uint32 `json:"brokerID"`
	Req       string `json:"req"`
	RequestID string `json:"requestID"`
}

type Response struct {
	Data      string `json:"data"`
	RequestID string `json:"requestID"`
}

type ServeOpts struct {
	FactoryFunc     Factory
	TLSProviderFunc TLSProviderFunc
	Logger          log.Logger
}

type TLSProviderFunc func() (*tls.Config, error)