broker

Documentation

Index

• Constants
• func WithPartitions(p int32) func(*createTopic)
• type AfterConsumedFunc
• type Consumer
  • func NewConsumer(addrs, groupID string, afterConsumedFunc AfterConsumedFunc) Consumer
• type Producer
  • func NewProducer(addrs string) Producer

Constants

const (
	CreateOrderTopic = "order.create"
	UpdateCartTopic  = "cart.update"
)

Functions

func WithPartitions

func WithPartitions(p int32) func(*createTopic)

Types

type AfterConsumedFunc

type AfterConsumedFunc = func([]byte) error

type Consumer

type Consumer interface {
	Consume(topics string)
	Close() error
}

func NewConsumer

func NewConsumer(addrs, groupID string, afterConsumedFunc AfterConsumedFunc) Consumer

type Producer

type Producer interface {
	CreateTopic(topic string, options ...func(*createTopic)) error
	Publish(topic string, msg []byte)
	Close() error
}

func NewProducer

func NewProducer(addrs string) Producer