kafka

package

v0.2.12 Latest Latest Go to latest Published: Apr 11, 2022 License: BSD-3-Clause Imports: 7 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/WiFeng/go-sky

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Init(ctx context.Context, serviceName string, cfs []config.Kafka)
func NewAsyncProducer(ctx context.Context, name string) (kafka.AsyncProducer, error)
func NewConsumer(ctx context.Context, name string) (kafka.Consumer, error)
func NewConsumerGroup(ctx context.Context, name string) (kafka.ConsumerGroup, error)
type SyncProducer
- func NewSyncProducer(ctx context.Context, name string) (SyncProducer, error)
type SyncProducerSendMessage
- func SyncProducerSendMessageCoreFunc(s kafka.SyncProducer) SyncProducerSendMessage
- func SyncProducerSendMessageTracingMiddleware(next SyncProducerSendMessage) SyncProducerSendMessage
type SyncProducerSendMessageFunc
- func (s SyncProducerSendMessageFunc) Do(ctx context.Context, msg *kafka.ProducerMessage) (partition int32, offset int64, err error)
type SyncProducerSendMessageMiddleware
type SyncProducerSendMessageMiddlewareFunc
- func (mw SyncProducerSendMessageMiddlewareFunc) Middleware(sp SyncProducerSendMessage) SyncProducerSendMessage

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrConfigNotFound ...
	ErrConfigNotFound = errors.New("kafka config is not found")
)

View Source

var (
	// ErrDeprecatedMethod ...
	ErrDeprecatedMethod = errors.New("kafka deprecated method")
)

Functions ¶

func Init ¶

func Init(ctx context.Context, serviceName string, cfs []config.Kafka)

Init ...

func NewAsyncProducer ¶

func NewAsyncProducer(ctx context.Context, name string) (kafka.AsyncProducer, error)

NewAsyncProducer ...

func NewConsumer ¶

func NewConsumer(ctx context.Context, name string) (kafka.Consumer, error)

NewConsumer ...

func NewConsumerGroup ¶

func NewConsumerGroup(ctx context.Context, name string) (kafka.ConsumerGroup, error)

NewConsumerGroup ...

Types ¶

type SyncProducer ¶

type SyncProducer interface {
	kafka.SyncProducer
	Use(ctx context.Context, mwf ...interface{})
	SendMessageContext(ctx context.Context, msg *kafka.ProducerMessage) (partition int32, offset int64, err error)
}

SyncProducer ...

func NewSyncProducer ¶

func NewSyncProducer(ctx context.Context, name string) (SyncProducer, error)

NewSyncProducer ...

type SyncProducerSendMessage ¶

type SyncProducerSendMessage interface {
	Do(ctx context.Context, msg *kafka.ProducerMessage) (partition int32, offset int64, err error)
}

SyncProducerSendMessage ...

func SyncProducerSendMessageCoreFunc ¶

func SyncProducerSendMessageCoreFunc(s kafka.SyncProducer) SyncProducerSendMessage

SyncProducerSendMessageCoreFunc ...

func SyncProducerSendMessageTracingMiddleware ¶

func SyncProducerSendMessageTracingMiddleware(next SyncProducerSendMessage) SyncProducerSendMessage

SyncProducerSendMessageTracingMiddleware ...

type SyncProducerSendMessageFunc ¶

type SyncProducerSendMessageFunc func(ctx context.Context, msg *kafka.ProducerMessage) (partition int32, offset int64, err error)

SyncProducerSendMessageFunc ...

func (SyncProducerSendMessageFunc) Do ¶

func (s SyncProducerSendMessageFunc) Do(ctx context.Context, msg *kafka.ProducerMessage) (partition int32, offset int64, err error)

Do ...

type SyncProducerSendMessageMiddleware ¶

type SyncProducerSendMessageMiddleware interface {
	Middleware(SyncProducerSendMessage) SyncProducerSendMessage
}

SyncProducerSendMessageMiddleware ...

type SyncProducerSendMessageMiddlewareFunc ¶

type SyncProducerSendMessageMiddlewareFunc func(SyncProducerSendMessage) SyncProducerSendMessage

SyncProducerSendMessageMiddlewareFunc ...

func (SyncProducerSendMessageMiddlewareFunc) Middleware ¶

func (mw SyncProducerSendMessageMiddlewareFunc) Middleware(sp SyncProducerSendMessage) SyncProducerSendMessage

Middleware allows MiddlewareFunc to implement the middleware interface.

Source Files ¶

View all Source files

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