kafka

Documentation

Index

• type Producer
  • func NewProducer(cfg *config.Config) (*Producer, error)
  • func (p *Producer) Close() error
  • func (p *Producer) PublishBlock(block *models.Block) error
  • func (p *Producer) PublishBlocks(blocks []*models.Block) error

Types

type Producer

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

func NewProducer

func NewProducer(cfg *config.Config) (*Producer, error)

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) PublishBlock

func (p *Producer) PublishBlock(block *models.Block) error

func (*Producer) PublishBlocks

func (p *Producer) PublishBlocks(blocks []*models.Block) error