shiva

package module

v0.0.0-...-6c77b72 Latest Latest Go to latest Published: Aug 1, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jkratz55/shiva

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

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