metrics

package
v0.37.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 7, 2023 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMorphClientMetrics added in v0.37.0

func NewMorphClientMetrics() morphmetrics.Register

Types

type BlobobvnizcaMetrics added in v0.37.0

type BlobobvnizcaMetrics interface {
	SetBlobobvnizcaTreeMode(shardID, path string, readOnly bool)
	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)
}

type BlobstoreMetrics added in v0.37.0

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 EngineMetrics added in v0.37.0

type EngineMetrics interface {
	AddMethodDuration(method string, d time.Duration)
	AddToContainerSize(cnrID string, size int64)
	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)

	WriteCache() WriteCacheMetrics
	GC() GCMetrics
}

type FSTreeMetrics added in v0.37.0

type FSTreeMetrics interface {
	SetMode(shardID, path string, readOnly bool)
	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 added in v0.37.0

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 added in v0.37.0

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 added in v0.37.0

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

func (*InnerRingServiceMetrics) MorphCacheMetrics added in v0.37.0

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 added in v0.37.0

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 added in v0.37.0

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

func NewNodeMorphCacheMetrics added in v0.37.0

func NewNodeMorphCacheMetrics() MorphCacheMetrics

type NodeMetrics

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

func NewNodeMetrics

func NewNodeMetrics() *NodeMetrics

func (*NodeMetrics) BlobobvnizcaTreeMetrics added in v0.37.0

func (m *NodeMetrics) BlobobvnizcaTreeMetrics() BlobobvnizcaMetrics

func (*NodeMetrics) Blobstore added in v0.37.0

func (m *NodeMetrics) Blobstore() BlobstoreMetrics

func (*NodeMetrics) Engine added in v0.37.0

func (m *NodeMetrics) Engine() EngineMetrics

func (*NodeMetrics) FSTree added in v0.37.0

func (m *NodeMetrics) FSTree() FSTreeMetrics

func (*NodeMetrics) GrpcServerMetrics added in v0.37.0

func (m *NodeMetrics) GrpcServerMetrics() GrpcServerMetrics

func (*NodeMetrics) MetabaseMetrics added in v0.37.0

func (m *NodeMetrics) MetabaseMetrics() MetabaseMetrics

func (*NodeMetrics) ObjectService added in v0.37.0

func (m *NodeMetrics) ObjectService() ObjectServiceMetrics

func (*NodeMetrics) PiloramaMetrics added in v0.37.0

func (m *NodeMetrics) PiloramaMetrics() PiloramaMetrics

func (*NodeMetrics) Replicator added in v0.37.0

func (m *NodeMetrics) Replicator() ReplicatorMetrics

func (*NodeMetrics) SetEpoch

func (m *NodeMetrics) SetEpoch(epoch uint64)

SetEpoch updates epoch metric.

func (*NodeMetrics) State added in v0.37.0

func (m *NodeMetrics) State() StateMetrics

func (*NodeMetrics) TreeService added in v0.37.0

func (m *NodeMetrics) TreeService() TreeMetricsRegister

type NullBool added in v0.37.0

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

func (NullBool) String added in v0.37.0

func (v NullBool) String() string

type ObjectServiceMetrics added in v0.37.0

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

type PiloramaMetrics added in v0.37.0

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

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

type ReplicatorMetrics added in v0.37.0

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

type StateMetrics added in v0.37.0

type StateMetrics interface {
	SetHealth(s int32)
}

type TreeMetricsRegister added in v0.37.0

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

type WriteCacheMetrics added in v0.37.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL