shiva

README

Shiva

Shiva is a modul

Documentation

Index

• type AcknowledgementStrategy
• type Consumer
  • func NewConsumer(brokers []string, groupID string, topic string) (*Consumer, error)
  • func (c *Consumer) Close() error
  • func (c *Consumer) Consume() error
• type Logger
• type Message
• type MessageHandler
• type MessageHandlerFunc
  • func (m MessageHandlerFunc) ProcessMessage(msg Message) error

Types

type AcknowledgementStrategy

type AcknowledgementStrategy uint

const (
	// AtMostOnce configures the Consumer to acknowledge the message after the
	// Consumer receives the Message but before it is passed to the MessageHandler
	// to process the message.
	AtMostOnce  AcknowledgementStrategy = 1
	AtLeastOnce AcknowledgementStrategy = 2
)

type Consumer

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

func NewConsumer

func NewConsumer(brokers []string, groupID string, topic string) (*Consumer, error)

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Consume

func (c *Consumer) Consume() error

type Logger

type Logger interface {
	Debug(msg string, keysAndValues ...any)
	Info(msg string, keysAndValues ...any)
	Warn(msg string, keysAndValues ...any)
	Error(msg string, keysAndValues ...any)
}

type Message

type Message = kafka.Message

type MessageHandler

type MessageHandler interface {
	ProcessMessage(msg Message) error
}

MessageHandler is a type that processes message read from Kafka

type MessageHandlerFunc

type MessageHandlerFunc func(msg Message) error

func (MessageHandlerFunc) ProcessMessage

func (m MessageHandlerFunc) ProcessMessage(msg Message) error