metrics

package
v0.42.18 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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.