providers

package

v0.3.0 Latest Latest Go to latest Published: Aug 15, 2019 License: Apache-2.0 Imports: 9 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]konsumeratorv1alpha1.InstanceState
func LoadSyncState(mp MetricsProvider, status konsumeratorv1alpha1.ConsumerStatus)
type DummyMP
- func NewDummyMP(numPartitions int32) *DummyMP
type MetricsMap
type MetricsProvider
type PrometheusMP
- func NewPrometheusMP(log logr.Logger, spec *konsumeratorv1alpha1.PrometheusAutoscalerSpec) (*PrometheusMP, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DumpSyncState ¶

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

func LoadSyncState ¶

func LoadSyncState(mp MetricsProvider, status konsumeratorv1alpha1.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 MetricsMap ¶

type MetricsMap map[int32]int64

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 *konsumeratorv1alpha1.PrometheusAutoscalerSpec) (*PrometheusMP, error)

func (*PrometheusMP) GetConsumptionRate ¶

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

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

func (*PrometheusMP) GetMessagesBehind ¶

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

func (*PrometheusMP) GetProductionRate ¶

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

func (*PrometheusMP) Load ¶

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

func (*PrometheusMP) Update ¶

func (l *PrometheusMP) Update() error

Source Files ¶

View all Source files

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