volatilitymonitor

README

Volatility monitor

You can use a volatility monitor to monitor writes, and to return blocks in order from least volatile to most.

Usage

VolatilityMonitor implements both storage.StorageProvider and also storage.BlockOrder. So you can put it in a chain of storage providers, and then use it as an orderer for a migrator.

Documentation

Index

• type VolatilityMonitor
  • func NewVolatilityMonitor(prov storage.Provider, blockSize int, expiry time.Duration) *VolatilityMonitor
  • func (i *VolatilityMonitor) Add(block int)
  • func (i *VolatilityMonitor) AddAll()
  • func (i *VolatilityMonitor) CancelWrites(offset int64, length int64)
  • func (i *VolatilityMonitor) Close() error
  • func (i *VolatilityMonitor) Flush() error
  • func (i *VolatilityMonitor) GetNext() *storage.BlockInfo
  • func (i *VolatilityMonitor) GetTotalVolatility() int
  • func (i *VolatilityMonitor) GetVolatility(block int) int
  • func (i *VolatilityMonitor) ReadAt(buffer []byte, offset int64) (int, error)
  • func (i *VolatilityMonitor) Remove(block int)
  • func (i *VolatilityMonitor) SendSiloEvent(eventType storage.EventType, eventData storage.EventData) []storage.EventReturnData
  • func (i *VolatilityMonitor) Size() uint64
  • func (i *VolatilityMonitor) WriteAt(buffer []byte, offset int64) (int, error)

Types

type VolatilityMonitor

type VolatilityMonitor struct {
	storage.ProviderWithEvents
	// contains filtered or unexported fields
}

func NewVolatilityMonitor

func NewVolatilityMonitor(prov storage.Provider, blockSize int, expiry time.Duration) *VolatilityMonitor

func (*VolatilityMonitor) Add

func (i *VolatilityMonitor) Add(block int)

func (*VolatilityMonitor) AddAll

func (i *VolatilityMonitor) AddAll()

func (*VolatilityMonitor) CancelWrites

func (i *VolatilityMonitor) CancelWrites(offset int64, length int64)

func (*VolatilityMonitor) Close

func (i *VolatilityMonitor) Close() error

func (*VolatilityMonitor) Flush

func (i *VolatilityMonitor) Flush() error

func (*VolatilityMonitor) GetNext

func (i *VolatilityMonitor) GetNext() *storage.BlockInfo

func (*VolatilityMonitor) GetTotalVolatility

func (i *VolatilityMonitor) GetTotalVolatility() int

func (*VolatilityMonitor) GetVolatility

func (i *VolatilityMonitor) GetVolatility(block int) int

func (*VolatilityMonitor) ReadAt

func (i *VolatilityMonitor) ReadAt(buffer []byte, offset int64) (int, error)

func (*VolatilityMonitor) Remove

func (i *VolatilityMonitor) Remove(block int)

func (*VolatilityMonitor) SendSiloEvent

func (i *VolatilityMonitor) SendSiloEvent(eventType storage.EventType, eventData storage.EventData) []storage.EventReturnData

Relay events to embedded StorageProvider

func (*VolatilityMonitor) Size

func (i *VolatilityMonitor) Size() uint64

func (*VolatilityMonitor) WriteAt

func (i *VolatilityMonitor) WriteAt(buffer []byte, offset int64) (int, error)