reporting

Documentation

Index

• Constants
• type EntDeps
• type ReportingManager
  • func NewReportingManager(logger hclog.Logger, deps EntDeps, server ServerDelegate, ...) *ReportingManager
  • func (m *ReportingManager) Run(ctx context.Context)
  • func (rm *ReportingManager) StartReportingAgent() error
  • func (rm *ReportingManager) StopReportingAgent() error
• type ServerDelegate
• type StateDelegate

Constants

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

Types

type EntDeps

type EntDeps struct{}

type ReportingManager

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

func NewReportingManager

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

func (*ReportingManager) Run

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

func (*ReportingManager) StartReportingAgent

func (rm *ReportingManager) StartReportingAgent() error

func (*ReportingManager) StopReportingAgent

func (rm *ReportingManager) StopReportingAgent() error

type ServerDelegate

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

type StateDelegate

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