queue

Documentation

Index

• type ConsumeHandler
• type KQueue
  • func NewKQueue(KafkaOptions *genericoptions.KafkaOptions, handler ConsumeHandler) (*KQueue, error)
  • func (c *KQueue) Start()
  • func (c *KQueue) Stop()

Types

type ConsumeHandler

type ConsumeHandler interface {
	Consume(val any) error
}

type KQueue

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

func NewKQueue

func NewKQueue(KafkaOptions *genericoptions.KafkaOptions, handler ConsumeHandler) (*KQueue, error)

func (*KQueue) Start

func (c *KQueue) Start()

func (*KQueue) Stop

func (c *KQueue) Stop()