ringbuffer

Documentation

Index

• Constants
• type Option
  • func WithRetryConfig(baseDelay, maxDelay time.Duration) Option
• type QueuedHealthEvents
  • func NewQueuedHealthEvents(events *protos.HealthEvents) *QueuedHealthEvents
• type RingBuffer
  • func NewRingBuffer(ringBufferName string, ctx context.Context, opts ...Option) *RingBuffer
  • func (rb *RingBuffer) AddRateLimited(data *QueuedHealthEvents)
  • func (rb *RingBuffer) CurrentLength() int
  • func (rb *RingBuffer) Dequeue() (*QueuedHealthEvents, bool)
  • func (rb *RingBuffer) Enqueue(item *QueuedHealthEvents)
  • func (rb *RingBuffer) HealthMetricEleProcessingCompleted(data *QueuedHealthEvents)
  • func (rb *RingBuffer) HealthMetricEleProcessingFailed(data *QueuedHealthEvents)
  • func (rb *RingBuffer) NumRequeues(data *QueuedHealthEvents) int
  • func (rb *RingBuffer) ShutDownHealthMetricQueue()

Constants

const (
	// Default retry configuration for production use
	// Retry 1: 500ms, Retry 2: 1.5s, Retry 3: 3s (total ~5s to 4th attempt)
	DefaultBaseDelay = 500 * time.Millisecond
	DefaultMaxDelay  = 3 * time.Second
)

Types

type Option

type Option func(*config)

func WithRetryConfig

func WithRetryConfig(baseDelay, maxDelay time.Duration) Option

type QueuedHealthEvents

type QueuedHealthEvents struct {
	Events            *protos.HealthEvents
	ParentSpanContext trace.SpanContext
}

QueuedHealthEvents carries health events and the trace context from the gRPC handler so store and K8s connectors can continue the same trace.

func NewQueuedHealthEvents

func NewQueuedHealthEvents(events *protos.HealthEvents) *QueuedHealthEvents

type RingBuffer

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

func NewRingBuffer

func NewRingBuffer(ringBufferName string, ctx context.Context, opts ...Option) *RingBuffer

func (*RingBuffer) AddRateLimited

func (rb *RingBuffer) AddRateLimited(data *QueuedHealthEvents)

func (*RingBuffer) CurrentLength

func (rb *RingBuffer) CurrentLength() int

func (*RingBuffer) Dequeue

func (rb *RingBuffer) Dequeue() (*QueuedHealthEvents, bool)

func (*RingBuffer) Enqueue

func (rb *RingBuffer) Enqueue(item *QueuedHealthEvents)

func (*RingBuffer) HealthMetricEleProcessingCompleted

func (rb *RingBuffer) HealthMetricEleProcessingCompleted(data *QueuedHealthEvents)

func (*RingBuffer) HealthMetricEleProcessingFailed

func (rb *RingBuffer) HealthMetricEleProcessingFailed(data *QueuedHealthEvents)

func (*RingBuffer) NumRequeues

func (rb *RingBuffer) NumRequeues(data *QueuedHealthEvents) int

func (*RingBuffer) ShutDownHealthMetricQueue

func (rb *RingBuffer) ShutDownHealthMetricQueue()