providers

package

v1.2.2 Latest Latest Go to latest Published: Nov 17, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lwolf/konsumerator

Links

Open Source Insights

Documentation ¶

Index ¶

func DumpSyncState(n int32, prov MetricsProvider) map[string]konsumeratorv1.InstanceState
func LoadSyncState(mp MetricsProvider, status konsumeratorv1.ConsumerStatus)
type DummyMP
- func NewDummyMP(numPartitions int32) *DummyMP
type MetricsProvider
type PrometheusMP
- func NewPrometheusMP(log logr.Logger, spec *konsumeratorv1.PrometheusAutoscalerSpec, ...) (*PrometheusMP, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DumpSyncState ¶

func DumpSyncState(n int32, prov MetricsProvider) map[string]konsumeratorv1.InstanceState

func LoadSyncState ¶

func LoadSyncState(mp MetricsProvider, status konsumeratorv1.ConsumerStatus)

Types ¶

type DummyMP ¶

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

func NewDummyMP ¶

func NewDummyMP(numPartitions int32) *DummyMP

func (*DummyMP) GetConsumptionRate ¶

func (l *DummyMP) GetConsumptionRate(partition int32) int64

func (*DummyMP) GetLagByPartition ¶

func (l *DummyMP) GetLagByPartition(partition int32) time.Duration

func (*DummyMP) GetMessagesBehind ¶

func (l *DummyMP) GetMessagesBehind(partition int32) int64

func (*DummyMP) GetProductionRate ¶

func (l *DummyMP) GetProductionRate(partition int32) int64

func (*DummyMP) Load ¶

func (l *DummyMP) Load(production map[int32]int64, consumption map[int32]int64, offset map[int32]int64)

func (*DummyMP) Update ¶

func (l *DummyMP) Update() error

type MetricsProvider ¶

type MetricsProvider interface {
	GetProductionRate(int32) int64
	GetConsumptionRate(int32) int64
	GetMessagesBehind(int32) int64
	GetLagByPartition(int32) time.Duration
	Update() error
	Load(map[int32]int64, map[int32]int64, map[int32]int64)
}

type PrometheusMP ¶

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

func NewPrometheusMP ¶

func NewPrometheusMP(log logr.Logger, spec *konsumeratorv1.PrometheusAutoscalerSpec, consumer string) (*PrometheusMP, error)

func (*PrometheusMP) GetConsumptionRate ¶

func (l *PrometheusMP) GetConsumptionRate(partition int32) int64

GetConsumptionRate returns consumption rate. not thread-safe

func (*PrometheusMP) GetLagByPartition ¶

func (l *PrometheusMP) GetLagByPartition(partition int32) time.Duration

GetLagByPartition calculates lag based on ProductionRate, ConsumptionRate and the number of not processed messages for partition not thread-safe

func (*PrometheusMP) GetMessagesBehind ¶

func (l *PrometheusMP) GetMessagesBehind(partition int32) int64

GetMessagesBehind returns how many messages we're behind. not thread-safe

func (*PrometheusMP) GetProductionRate ¶

func (l *PrometheusMP) GetProductionRate(partition int32) int64

GetProductionRate returns production rate. not thread-safe

func (*PrometheusMP) Load ¶

func (l *PrometheusMP) Load(production, consumption, offset map[int32]int64)

Load loads given metrics into object not thread-safe

func (*PrometheusMP) Update ¶

func (l *PrometheusMP) Update() error

Update updates metrics values by querying Prometheus not thread-safe TODO: may lead to partial update TODO: might be queried in parallel

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL