metrics

package
v0.42.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlobobvnizcaMetrics added in v0.37.0 

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

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 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) LogMetrics added in v0.38.0 

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

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)
}

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) LogMetrics added in v0.38.0 

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

func (*NodeMetrics) MetabaseMetrics added in v0.37.0 

func (m *NodeMetrics) MetabaseMetrics() MetabaseMetrics

func (*NodeMetrics) MorphCacheMetrics added in v0.38.0 

func (m *NodeMetrics) MorphCacheMetrics() MorphCacheMetrics

func (*NodeMetrics) MorphClientMetrics added in v0.38.0 

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

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) PolicerMetrics added in v0.38.0 

func (m *NodeMetrics) PolicerMetrics() PolicerMetrics

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.ComponentMode)
	Close(shardID string)

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

type PolicerMetrics added in v0.38.0 

type PolicerMetrics interface {
	IncProcessedObjects()
}

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, 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)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.