peripheral

Index ¶

• type Conn
• • func NewConnectivity(id uint64, ec *server.ExtensionContext) *Conn
• • func (c *Conn) Close() error
  • func (c *Conn) CollectMetrics(ctx context.Context, params map[string]string) ([]*arhatgopb.PeripheralMetricsMsg_Value, error)
  • func (c *Conn) Operate(ctx context.Context, params map[string]string, data []byte) ([][]byte, error)
• type Manager
• • func NewManager(ctx context.Context, config *conf.PeripheralExtensionConfig) *Manager
• • func (m *Manager) CacheMetrics(metrics []*dto.MetricFamily)
  • func (m *Manager) Cleanup()
  • func (m *Manager) CollectMetrics(peripheralIDs ...string) (metricsForNode []*dto.MetricFamily, paramsForAgent []map[string]string, ...)
  • func (m *Manager) CreateExtensionHandleFunc(extensionName string) (server.ExtensionHandleFunc, server.OutOfBandMsgHandleFunc)
  • func (m *Manager) Delete(ids ...string) (result []*aranyagopb.PeripheralStatusMsg)
  • func (m *Manager) Ensure(cmd *aranyagopb.PeripheralEnsureCmd) (err error)
  • func (m *Manager) GetAllStatuses() []*aranyagopb.PeripheralStatusMsg
  • func (m *Manager) GetStatus(peripheralID string) *aranyagopb.PeripheralStatusMsg
  • func (m *Manager) Operate(ctx context.Context, peripheralID, operationID string, data []byte) ([][]byte, error)
  • func (m *Manager) RetrieveCachedMetrics() interface{}
• type Metric
• type MetricReportKey
• type MetricReportSpec
• type MetricSpec
• type MetricsCache
• • func NewMetricsCache(maxCacheTime time.Duration) *MetricsCache
• • func (m *MetricsCache) CacheMetrics(metrics []*dto.MetricFamily)
  • func (m *MetricsCache) RetrieveCachedMetrics() []*dto.MetricFamily
• type MetricsReporter
• • func NewMetricsReporter(ctx context.Context, connectorHashHex string, conn *Conn) *MetricsReporter
• • func (r *MetricsReporter) Close() error
  • func (r *MetricsReporter) ReportMetrics(params map[string]string, metrics []*dto.MetricFamily) error
  • func (d MetricsReporter) Status() *aranyagopb.PeripheralStatusMsg
• type Peripheral
• • func NewPeripheral(ctx context.Context, name string, connector *Conn, ...) *Peripheral
• • func (d *Peripheral) Close() error
  • func (d *Peripheral) CollectMetrics(resultCh chan<- *Metric)
  • func (d *Peripheral) Operate(ctx context.Context, id string, data []byte) ([][]byte, error)
  • func (d Peripheral) Status() *aranyagopb.PeripheralStatusMsg