article

Documentation

Index

• type Article
• type ArticleProccessor
• type Config
• type Consumer
  • func NewConsumer(log *slog.Logger, processor ArticleProccessor) *Consumer
  • func (c *Consumer) Close() error
  • func (c *Consumer) Connect(addr string) error
  • func (c *Consumer) Consume() error

Types

type Article

type Article struct {
	URL         string `json:"url,omitempty"`
	Header      string `json:"header,omitempty"`
	Content     string `json:"content,omitempty"`
	Author      string `json:"author,omitempty"`
	IsSponsored bool   `json:"isSponsored,omitempty"`
}

type ArticleProccessor

type ArticleProccessor interface {
	Process(msg Article) error
}

type Config

type Config struct {
	Addr string
}

type Consumer

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

func NewConsumer

func NewConsumer(log *slog.Logger, processor ArticleProccessor) *Consumer

func (*Consumer) Close

func (c *Consumer) Close() error

func (*Consumer) Connect

func (c *Consumer) Connect(addr string) error

func (*Consumer) Consume

func (c *Consumer) Consume() error