collector

Documentation

Index

• func NewMemoryStorage(storageDriver *string, storageDuration *time.Duration) (*memory.InMemoryCache, error)
• type CollectorManager
  • func (cm *CollectorManager) Start(ch <-chan bool)
  • func (cm *CollectorManager) Store(in *pb.MeteringReqResp) (*pb.MeteringReqResp, error)

Functions

func NewMemoryStorage

func NewMemoryStorage(storageDriver *string, storageDuration *time.Duration) (*memory.InMemoryCache, error)

NewMemoryStorage creates a memory storage with an optional backend storage option.

Types

type CollectorManager

type CollectorManager struct {
	MetricsStorageDriver   string
	MetricsStorageDuration time.Duration
	// contains filtered or unexported fields
}

func (*CollectorManager) Start

func (cm *CollectorManager) Start(ch <-chan bool)

func (*CollectorManager) Store

func (cm *CollectorManager) Store(in *pb.MeteringReqResp) (*pb.MeteringReqResp, error)