kafka

package

v0.1.1 Latest Latest Go to latest Published: Mar 4, 2026 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-bamboo/pkg

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func MustNewProducer(c *queue.Conf) queue.Pusher
func MustNewQueue(c *queue.Conf) (queue.MessageQueue, error)
func NewConsumer(c *queue.Conf) (queue.MessageQueue, error)
func NewProducer(c *queue.Conf) (queue.Pusher, error)
func WrapError(err error) error
type Consumer
type KafkaMessageTextMapCarrier
type Producer
type Subscriber

Constants ¶

View Source

const Name = "kafka"

Name is the name registered for kafka

Variables ¶

This section is empty.

Functions ¶

func MustNewProducer ¶

func MustNewProducer(c *queue.Conf) queue.Pusher

func MustNewQueue ¶

func MustNewQueue(c *queue.Conf) (queue.MessageQueue, error)

func NewConsumer ¶

func NewConsumer(c *queue.Conf) (queue.MessageQueue, error)

func NewProducer ¶

func NewProducer(c *queue.Conf) (queue.Pusher, error)

func WrapError ¶

func WrapError(err error) error

Types ¶

type Consumer ¶

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

func (*Consumer) Close ¶ added in v0.1.1

func (c *Consumer) Close() error

func (*Consumer) Name ¶ added in v0.1.1

func (c *Consumer) Name() string

func (c *Consumer) Subscribe(topic string, handler queue.ConsumeHandle, opts ...queue.SubscribeOption) (queue.Subscriber, error)

type KafkaMessageTextMapCarrier ¶

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

func (*KafkaMessageTextMapCarrier) Get ¶

func (carrier *KafkaMessageTextMapCarrier) Get(key string) string

Get returns the value associated with the passed key.

func (*KafkaMessageTextMapCarrier) Keys ¶

func (carrier *KafkaMessageTextMapCarrier) Keys() []string

Keys lists the keys stored in this carrier.

func (*KafkaMessageTextMapCarrier) Set ¶

func (carrier *KafkaMessageTextMapCarrier) Set(key string, value string)

Set stores the key-value pair.

type Producer ¶

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

Producer 生产者

func (*Producer) Close ¶

func (p *Producer) Close() error

func (*Producer) Name ¶

func (p *Producer) Name() string

func (*Producer) Push ¶

func (p *Producer) Push(ctx context.Context, topic string, key, value []byte) error

func (*Producer) PushWithPartition ¶ added in v0.1.1

func (p *Producer) PushWithPartition(ctx context.Context, topic string, key, value []byte, partition int32) error

type Subscriber ¶ added in v0.1.1

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

func (*Subscriber) Options ¶ added in v0.1.1

func (s *Subscriber) Options() queue.SubscribeOptions

Options .

func (*Subscriber) Topic ¶ added in v0.1.1

func (s *Subscriber) Topic() string

Topic .

func (*Subscriber) Unsubscribe ¶ added in v0.1.1

func (s *Subscriber) Unsubscribe(removeFromManager bool) error

Unsubscribe .

Source Files ¶

View all Source files

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