metrics

type Manager ¶

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

Manager shares one upstream metrics stream across all viewers of the same workload. Samples are held in memory only and are discarded when the stream has no viewers.

func NewManager(factory provider.Factory) *Manager

func (m *Manager) InvalidateSnapshot(connectionID string)

func (m *Manager) Snapshot(ctx context.Context, connection model.Connection, maxAge time.Duration) ([]model.WorkloadMetric, error)

func (m *Manager) Subscribe(ctx context.Context, connection model.Connection, request model.MetricRequest) (<-chan model.WorkloadMetric, func(), error)