kafka

Documentation

Index

• type MessageBroker
  • func New[T [][]byte](conn []string, config any, Logger *log.Logger) (mb *MessageBroker[T], err error)
  • func (mb *MessageBroker[T]) Error() error
  • func (mb *MessageBroker[T]) Publish(ctx context.Context, message *common.Message[T]) spec.IMessage[T]
  • func (mb *MessageBroker[T]) Subscribe(ctx context.Context, message *common.Message[T], f func(data T)) spec.IMessage[T]
  • func (mb *MessageBroker[T]) SubscribeSync(ctx context.Context, message *common.Message[T], f func(data T)) spec.IMessage[T]

Types

type MessageBroker

type MessageBroker[T [][]byte] struct {
	Conn   []string // This is an array for kafka
	Config any
	Err    error
	Logger *log.Logger
}

func New

func New[T [][]byte](conn []string, config any, Logger *log.Logger) (mb *MessageBroker[T], err error)

func (*MessageBroker[T]) Error

func (mb *MessageBroker[T]) Error() error

func (*MessageBroker[T]) Publish

func (mb *MessageBroker[T]) Publish(ctx context.Context, message *common.Message[T]) spec.IMessage[T]

func (*MessageBroker[T]) Subscribe

func (mb *MessageBroker[T]) Subscribe(ctx context.Context, message *common.Message[T], f func(data T)) spec.IMessage[T]

func (*MessageBroker[T]) SubscribeSync

func (mb *MessageBroker[T]) SubscribeSync(ctx context.Context, message *common.Message[T], f func(data T)) spec.IMessage[T]