monitoring_service

type IntegralMetric struct {
	MetricInterface
	// contains filtered or unexported fields
}

type MetricInterface interface {
	Set(measure int64)
	Get() int64
}

type Monitoring struct {
	EventCap int
	// contains filtered or unexported fields
}

type MonitoringMock struct {
	contracts.MonitoringInterface

	/*
		You need to substitute *Mock methods to do substitute original functions
	*/
	InitMock    func(topic contracts.Topic, metricType contracts.MetricType) error
	PublishMock func(topic contracts.Topic, measurement int64) error
	ListenMock  func(topic contracts.Topic, callback func() int64) error
	RunMock     func()
}

type Options struct {
	PeriodMeasure time.Duration
	EventCap      int

	/*
		Subscribing to measurement events
	*/
	Subscriptions map[contracts.Topic]func(event contracts.MeasurementEvent)
}

type ValueMetric struct {
	MetricInterface
	// contains filtered or unexported fields
}

type VelocityMetric struct {
	MetricInterface
	// contains filtered or unexported fields
}