memory

Documentation

Index

• type CollectionMetricStorage
  • func NewCollectionMetricStorage() *CollectionMetricStorage
  • func (collection *CollectionMetricStorage) Update()
  • func (collection *CollectionMetricStorage) UpdateGopsutil()
  • func (collection *CollectionMetricStorage) UpdateRuntime()
• type MemStorage
  • func NewMemStorage() *MemStorage
  • func (db *MemStorage) Add(ctx context.Context, m metrics.Metrics) error
  • func (db *MemStorage) BulkAdd(ctx context.Context, metricList []metrics.Metrics) error
  • func (db *MemStorage) Get(ctx context.Context, metric *metrics.Metrics) error
  • func (db *MemStorage) List(ctx context.Context) ([]metrics.Metrics, error)
  • func (db *MemStorage) Ping(ctx context.Context) bool

Types

type CollectionMetricStorage

type CollectionMetricStorage struct {
	MemStorage
}

func NewCollectionMetricStorage

func NewCollectionMetricStorage() *CollectionMetricStorage

func (*CollectionMetricStorage) Update

func (collection *CollectionMetricStorage) Update()

func (*CollectionMetricStorage) UpdateGopsutil

func (collection *CollectionMetricStorage) UpdateGopsutil()

func (*CollectionMetricStorage) UpdateRuntime

func (collection *CollectionMetricStorage) UpdateRuntime()

type MemStorage

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

func NewMemStorage

func NewMemStorage() *MemStorage

func (*MemStorage) Add

func (db *MemStorage) Add(ctx context.Context, m metrics.Metrics) error

func (*MemStorage) BulkAdd

func (db *MemStorage) BulkAdd(ctx context.Context, metricList []metrics.Metrics) error

func (*MemStorage) Get

func (db *MemStorage) Get(ctx context.Context, metric *metrics.Metrics) error

func (*MemStorage) List

func (db *MemStorage) List(ctx context.Context) ([]metrics.Metrics, error)

func (*MemStorage) Ping

func (db *MemStorage) Ping(ctx context.Context) bool