tracker

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2022 License: BSD-3-Clause Imports: 13 Imported by: 1

Documentation

Overview

Package tracker is a generated GoMock package.

Package tracker is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DiskTracker 

type DiskTracker interface {
	Tracker
	AvailableDiskBytes() uint64
}

type MockResourceTracker 

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

MockResourceTracker is a mock of ResourceTracker interface.

func NewMockResourceTracker 

func NewMockResourceTracker(ctrl *gomock.Controller) *MockResourceTracker

NewMockResourceTracker creates a new mock instance.

func (*MockResourceTracker) CPUTracker 

func (m *MockResourceTracker) CPUTracker() Tracker

CPUTracker mocks base method.

func (*MockResourceTracker) DiskTracker 

func (m *MockResourceTracker) DiskTracker() Tracker

DiskTracker mocks base method.

func (*MockResourceTracker) EXPECT 

func (m *MockResourceTracker) EXPECT() *MockResourceTrackerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockResourceTracker) StartProcessing 

func (m *MockResourceTracker) StartProcessing(arg0 ids.NodeID, arg1 time.Time)

StartProcessing mocks base method.

func (*MockResourceTracker) StopProcessing 

func (m *MockResourceTracker) StopProcessing(arg0 ids.NodeID, arg1 time.Time)

StopProcessing mocks base method.

type MockResourceTrackerMockRecorder 

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

MockResourceTrackerMockRecorder is the mock recorder for MockResourceTracker.

func (*MockResourceTrackerMockRecorder) CPUTracker 

func (mr *MockResourceTrackerMockRecorder) CPUTracker() *gomock.Call

CPUTracker indicates an expected call of CPUTracker.

func (*MockResourceTrackerMockRecorder) DiskTracker 

func (mr *MockResourceTrackerMockRecorder) DiskTracker() *gomock.Call

DiskTracker indicates an expected call of DiskTracker.

func (*MockResourceTrackerMockRecorder) StartProcessing 

func (mr *MockResourceTrackerMockRecorder) StartProcessing(arg0, arg1 interface{}) *gomock.Call

StartProcessing indicates an expected call of StartProcessing.

func (*MockResourceTrackerMockRecorder) StopProcessing 

func (mr *MockResourceTrackerMockRecorder) StopProcessing(arg0, arg1 interface{}) *gomock.Call

StopProcessing indicates an expected call of StopProcessing.

type MockTargeter 

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

MockTargeter is a mock of Targeter interface.

func NewMockTargeter 

func NewMockTargeter(ctrl *gomock.Controller) *MockTargeter

NewMockTargeter creates a new mock instance.

func (*MockTargeter) EXPECT 

func (m *MockTargeter) EXPECT() *MockTargeterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTargeter) TargetUsage 

func (m *MockTargeter) TargetUsage(nodeID ids.NodeID) float64

TargetUsage mocks base method.

type MockTargeterMockRecorder 

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

MockTargeterMockRecorder is the mock recorder for MockTargeter.

func (*MockTargeterMockRecorder) TargetUsage 

func (mr *MockTargeterMockRecorder) TargetUsage(nodeID interface{}) *gomock.Call

TargetUsage indicates an expected call of TargetUsage.

type MockTracker 

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

MockTracker is a mock of Tracker interface.

func NewMockTracker 

func NewMockTracker(ctrl *gomock.Controller) *MockTracker

NewMockTracker creates a new mock instance.

func (*MockTracker) EXPECT 

func (m *MockTracker) EXPECT() *MockTrackerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTracker) TimeUntilUsage 

func (m *MockTracker) TimeUntilUsage(nodeID ids.NodeID, now time.Time, value float64) time.Duration

TimeUntilUsage mocks base method.

func (*MockTracker) TotalUsage 

func (m *MockTracker) TotalUsage() float64

TotalUsage mocks base method.

func (*MockTracker) Usage 

func (m *MockTracker) Usage(nodeID ids.NodeID, now time.Time) float64

Usage mocks base method.

type MockTrackerMockRecorder 

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

MockTrackerMockRecorder is the mock recorder for MockTracker.

func (*MockTrackerMockRecorder) TimeUntilUsage 

func (mr *MockTrackerMockRecorder) TimeUntilUsage(nodeID, now, value interface{}) *gomock.Call

TimeUntilUsage indicates an expected call of TimeUntilUsage.

func (*MockTrackerMockRecorder) TotalUsage 

func (mr *MockTrackerMockRecorder) TotalUsage() *gomock.Call

TotalUsage indicates an expected call of TotalUsage.

func (*MockTrackerMockRecorder) Usage 

func (mr *MockTrackerMockRecorder) Usage(nodeID, now interface{}) *gomock.Call

Usage indicates an expected call of Usage.

type ResourceTracker 

type ResourceTracker interface {
	CPUTracker() Tracker
	DiskTracker() DiskTracker
	// Registers that the given node started processing at the given time.
	StartProcessing(ids.NodeID, time.Time)
	// Registers that the given node stopped processing at the given time.
	StopProcessing(ids.NodeID, time.Time)
}

ResourceTracker is an interface for tracking peers' usage of resources

func NewResourceTracker 

func NewResourceTracker(
	reg prometheus.Registerer,
	resources resource.User,
	factory meter.Factory,
	halflife time.Duration,
) (ResourceTracker, error)

type Targeter 

type Targeter interface {
	// Returns the target usage of the given node.
	TargetUsage(nodeID ids.NodeID) float64
}

func NewTargeter 

func NewTargeter(
	config *TargeterConfig,
	vdrs validators.Set,
	tracker Tracker,
) Targeter

type TargeterConfig 

type TargeterConfig struct {
	// VdrAlloc is the amount of the resource to split over validators, weighted
	// by stake.
	VdrAlloc float64 `json:"vdrAlloc"`

	// MaxNonVdrUsage is the amount of the resource which, if utilized, will
	// result in allocations being based only on the stake weighted allocation.
	MaxNonVdrUsage float64 `json:"maxNonVdrUsage"`

	// MaxNonVdrNodeUsage is the amount of the resource to allocate to a node
	// before adding the stake weighted allocation.
	MaxNonVdrNodeUsage float64 `json:"maxNonVdrNodeUsage"`
}

type Tracker 

type Tracker interface {
	// Returns the current usage for the given node.
	Usage(nodeID ids.NodeID, now time.Time) float64
	// Returns the current usage by all nodes.
	TotalUsage() float64
	// Returns the duration between [now] and when the usage of [nodeID] reaches
	// [value], assuming that the node uses no more resources.
	// If the node's usage isn't known, or is already <= [value], returns the
	// zero duration.
	TimeUntilUsage(nodeID ids.NodeID, now time.Time, value float64) time.Duration
}

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.