metrics

Documentation

Index

• type ApplicationInfo
  • func NewApplicationInfo(version string) *ApplicationInfo
• type BlobobvnizcaMetrics
• type BlobstoreMetrics
• type CacheMetrics
  • func NewCacheMetrics(cache string) *CacheMetrics
  • func (m *CacheMetrics) AddMethodDuration(method string, d time.Duration, hit bool)
• type EngineMetrics
• type FSTreeMetrics
• type GCMetrics
• type GrpcServerMetrics
• type InnerRingServiceMetrics
  • func NewInnerRingMetrics() *InnerRingServiceMetrics
  • func (m *InnerRingServiceMetrics) AddEvent(d time.Duration, typ string, success bool)
  • func (m *InnerRingServiceMetrics) LogMetrics() logger.LogMetrics
  • func (m *InnerRingServiceMetrics) MorphCacheMetrics() MorphCacheMetrics
  • func (m *InnerRingServiceMetrics) SetEpoch(epoch uint64)
  • func (m *InnerRingServiceMetrics) SetHealth(s int32)
• type MetabaseMetrics
• type MorphCacheMetrics
• type NodeMetrics
  • func NewNodeMetrics() *NodeMetrics
  • func (m *NodeMetrics) BlobobvnizcaTreeMetrics() BlobobvnizcaMetrics
  • func (m *NodeMetrics) Blobstore() BlobstoreMetrics
  • func (m *NodeMetrics) Engine() EngineMetrics
  • func (m *NodeMetrics) FSTree() FSTreeMetrics
  • func (m *NodeMetrics) GrpcServerMetrics() GrpcServerMetrics
  • func (m *NodeMetrics) LogMetrics() logger.LogMetrics
  • func (m *NodeMetrics) MetabaseMetrics() MetabaseMetrics
  • func (m *NodeMetrics) MorphCacheMetrics() MorphCacheMetrics
  • func (m *NodeMetrics) MorphClientMetrics() morphmetrics.Register
  • func (m *NodeMetrics) ObjectService() ObjectServiceMetrics
  • func (m *NodeMetrics) PiloramaMetrics() PiloramaMetrics
  • func (m *NodeMetrics) PolicerMetrics() PolicerMetrics
  • func (m *NodeMetrics) Replicator() ReplicatorMetrics
  • func (m *NodeMetrics) SetEpoch(epoch uint64)
  • func (m *NodeMetrics) State() StateMetrics
  • func (m *NodeMetrics) TreeService() TreeMetricsRegister
• type NullBool
  • func (v NullBool) String() string
• type ObjectServiceMetrics
• type PiloramaMetrics
• type PolicerMetrics
• type ReplicatorMetrics
• type StateMetrics
• type TreeMetricsRegister
• type WriteCacheMetrics

Types

type ApplicationInfo

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

func NewApplicationInfo

func NewApplicationInfo(version string) *ApplicationInfo

type BlobobvnizcaMetrics

type BlobobvnizcaMetrics interface {
	SetBlobobvnizcaTreeMode(shardID, path string, mode mode.ComponentMode)
	CloseBlobobvnizcaTree(shardID, path string)
	BlobobvnizcaTreeMethodDuration(shardID, path string, method string, d time.Duration, success bool, withStorageID NullBool)
	AddBlobobvnizcaTreePut(shardID, path string, size int)
	AddBlobobvnizcaTreeGet(shardID, path string, size int)

	AddOpenBlobovniczaSize(shardID, path string, size uint64)
	SubOpenBlobovniczaSize(shardID, path string, size uint64)

	AddOpenBlobovniczaItems(shardID, path string, items uint64)
	SubOpenBlobovniczaItems(shardID, path string, items uint64)

	IncOpenBlobovniczaCount(shardID, path string)
	DecOpenBlobovniczaCount(shardID, path string)

	BlobovniczaTreeRebuildStatus(shardID, path, status string)
	BlobovniczaTreeRebuildPercent(shardID, path string, value uint32)
	BlobovniczaTreeObjectMoved(shardID, path string, d time.Duration)
}

type BlobstoreMetrics

type BlobstoreMetrics interface {
	SetMode(shardID string, readOnly bool)
	Close(shardID string)

	MethodDuration(shardID string, method string, d time.Duration, success bool, withStorageID NullBool)
	AddPut(shardID string, size int)
	AddGet(shardID string, size int)
}

type CacheMetrics

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

func NewCacheMetrics

func NewCacheMetrics(cache string) *CacheMetrics

NewCacheMetrics returns new CacheMetrics instance for cache specified.

func (*CacheMetrics) AddMethodDuration

func (m *CacheMetrics) AddMethodDuration(method string, d time.Duration, hit bool)

type EngineMetrics

type EngineMetrics interface {
	AddMethodDuration(method string, d time.Duration)
	AddToContainerSize(cnrID string, size int64)
	DeleteContainerSize(cnrID string)
	DeleteContainerCount(cnrID string)
	IncErrorCounter(shardID string)
	ClearErrorCounter(shardID string)
	DeleteShardMetrics(shardID string)
	AddToObjectCounter(shardID, objectType string, delta int)
	SetObjectCounter(shardID, objectType string, v uint64)
	AddToPayloadCounter(shardID string, size int64)
	SetMode(shardID string, mode mode.Mode)
	SetContainerObjectCounter(shardID, contID, objectType string, v uint64)
	IncContainerObjectCounter(shardID, contID, objectType string)
	SubContainerObjectCounter(shardID, contID, objectType string, v uint64)
	IncRefillObjectsCount(shardID, path string, size int, success bool)
	SetRefillPercent(shardID, path string, percent uint32)
	SetRefillStatus(shardID, path, status string)

	WriteCache() WriteCacheMetrics
	GC() GCMetrics
}

type FSTreeMetrics

type FSTreeMetrics interface {
	SetMode(shardID, path string, mode mode.ComponentMode)
	Close(shardID, path string)

	MethodDuration(shardID, path string, method string, d time.Duration, success bool)
	AddGet(shardID, path string, size int)
	AddPut(shardID, path string, size int)
}

type GCMetrics

type GCMetrics interface {
	AddRunDuration(shardID string, d time.Duration, success bool)
	AddDeletedCount(shardID string, deleted, failed uint64)
	AddExpiredObjectCollectionDuration(shardID string, d time.Duration, success bool, objectType string)
	AddInhumedObjectCount(shardID string, count uint64, objectType string)
}

type GrpcServerMetrics

type GrpcServerMetrics interface {
	MarkHealthy(endpoint string)
	MarkUnhealthy(endpoint string)
}

type InnerRingServiceMetrics

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

InnerRingServiceMetrics contains metrics collected by inner ring.

func NewInnerRingMetrics

func NewInnerRingMetrics() *InnerRingServiceMetrics

NewInnerRingMetrics returns new instance of metrics collectors for inner ring.

func (*InnerRingServiceMetrics) AddEvent

func (m *InnerRingServiceMetrics) AddEvent(d time.Duration, typ string, success bool)

func (*InnerRingServiceMetrics) LogMetrics

func (m *InnerRingServiceMetrics) LogMetrics() logger.LogMetrics

func (*InnerRingServiceMetrics) MorphCacheMetrics

func (m *InnerRingServiceMetrics) MorphCacheMetrics() MorphCacheMetrics

func (*InnerRingServiceMetrics) SetEpoch

func (m *InnerRingServiceMetrics) SetEpoch(epoch uint64)

SetEpoch updates epoch metrics.

func (*InnerRingServiceMetrics) SetHealth

func (m *InnerRingServiceMetrics) SetHealth(s int32)

SetHealth updates health metrics.

type MetabaseMetrics

type MetabaseMetrics interface {
	SetMode(shardID, path string, mode string)
	Close(shardID, path string)

	MethodDuration(shardID, path string, method string, d time.Duration, success bool)
}

type MorphCacheMetrics

type MorphCacheMetrics interface {
	AddMethodDuration(method string, success bool, d time.Duration)
}

type NodeMetrics

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

func NewNodeMetrics

func NewNodeMetrics() *NodeMetrics

func (*NodeMetrics) BlobobvnizcaTreeMetrics

func (m *NodeMetrics) BlobobvnizcaTreeMetrics() BlobobvnizcaMetrics

func (*NodeMetrics) Blobstore

func (m *NodeMetrics) Blobstore() BlobstoreMetrics

func (*NodeMetrics) Engine

func (m *NodeMetrics) Engine() EngineMetrics

func (*NodeMetrics) FSTree

func (m *NodeMetrics) FSTree() FSTreeMetrics

func (*NodeMetrics) GrpcServerMetrics

func (m *NodeMetrics) GrpcServerMetrics() GrpcServerMetrics

func (*NodeMetrics) LogMetrics

func (m *NodeMetrics) LogMetrics() logger.LogMetrics

func (*NodeMetrics) MetabaseMetrics

func (m *NodeMetrics) MetabaseMetrics() MetabaseMetrics

func (*NodeMetrics) MorphCacheMetrics

func (m *NodeMetrics) MorphCacheMetrics() MorphCacheMetrics

func (*NodeMetrics) MorphClientMetrics

func (m *NodeMetrics) MorphClientMetrics() morphmetrics.Register

func (*NodeMetrics) ObjectService

func (m *NodeMetrics) ObjectService() ObjectServiceMetrics

func (*NodeMetrics) PiloramaMetrics

func (m *NodeMetrics) PiloramaMetrics() PiloramaMetrics

func (*NodeMetrics) PolicerMetrics

func (m *NodeMetrics) PolicerMetrics() PolicerMetrics

func (*NodeMetrics) Replicator

func (m *NodeMetrics) Replicator() ReplicatorMetrics

func (*NodeMetrics) SetEpoch

func (m *NodeMetrics) SetEpoch(epoch uint64)

SetEpoch updates epoch metric.

func (*NodeMetrics) State

func (m *NodeMetrics) State() StateMetrics

func (*NodeMetrics) TreeService

func (m *NodeMetrics) TreeService() TreeMetricsRegister

type NullBool

type NullBool struct {
	Bool  bool
	Valid bool // Valid is true if Bool is not NULL
}

func (NullBool) String

func (v NullBool) String() string

type ObjectServiceMetrics

type ObjectServiceMetrics interface {
	AddRequestDuration(method string, d time.Duration, success bool)
	AddPayloadSize(method string, size int)
}

type PiloramaMetrics

type PiloramaMetrics interface {
	SetMode(shardID string, m mode.ComponentMode)
	Close(shardID string)

	AddMethodDuration(shardID string, method string, d time.Duration, success bool)
}

type PolicerMetrics

type PolicerMetrics interface {
	IncProcessedObjects()
}

type ReplicatorMetrics

type ReplicatorMetrics interface {
	IncInFlightRequest()
	DecInFlightRequest()
	IncProcessedObjects()
	AddPayloadSize(size int64)
}

type StateMetrics

type StateMetrics interface {
	SetHealth(s int32)
}

type TreeMetricsRegister

type TreeMetricsRegister interface {
	AddReplicateTaskDuration(time.Duration, bool)
	AddReplicateWaitDuration(time.Duration, bool)
	AddSyncDuration(time.Duration, bool)
}

type WriteCacheMetrics

type WriteCacheMetrics interface {
	AddMethodDuration(shardID, path, storageType, method string, success bool, d time.Duration)
	SetActualCount(shardID, path, storageType string, count uint64)
	SetEstimateSize(shardID, path, storageType string, size uint64)
	SetMode(shardID, mode string)
	IncOperationCounter(shardID, path, storageType, operation string, success NullBool)
	Close(shardID, path string)
}