reporting

package

v1.0.0 Latest Latest Go to latest Published: Mar 19, 2025 License: MPL-2.0 Imports: 7 Imported by: 0

Details

View Source

const (
	SystemMetadataReportingProcessID = "reporting-process-id"
	ReportingInterval                = 1 * time.Hour
)

This section is empty.

This section is empty.

type EntDeps struct{}

type ReportingManager struct {
	EntDeps
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewReportingManager(logger hclog.Logger, deps EntDeps, server ServerDelegate, stateProvider StateDelegate) *ReportingManager

func (m *ReportingManager) Run(ctx context.Context)

func (rm *ReportingManager) StartReportingAgent() error

func (rm *ReportingManager) StopReportingAgent() error

type ServerDelegate interface {
	GetSystemMetadata(key string) (string, error)
	SetSystemMetadataKey(key, val string) error
	IsLeader() bool
}

type StateDelegate interface {
	NodeUsage() (uint64, state.NodeUsage, error)
	ServiceUsage(ws memdb.WatchSet) (uint64, structs.ServiceUsage, error)
}