service

Documentation

Index

• type Message
• type Service
  • func NewService(repo *repository.Repository, kafkaProducer sarama.AsyncProducer, ...) *Service
  • func (s *Service) GetStatistics(ctx context.Context) (*Statistics, error)
  • func (s *Service) ProcessMessage(ctx context.Context, msg *Message) error
• type Statistics

Types

type Message

type Message struct {
	ID      int    `json:"id"`
	Content string `json:"content"`
	Status  string `json:"status"`
}

type Service

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

func NewService

func NewService(repo *repository.Repository, kafkaProducer sarama.AsyncProducer, logger *zap.Logger) *Service

func (*Service) GetStatistics

func (s *Service) GetStatistics(ctx context.Context) (*Statistics, error)

func (*Service) ProcessMessage

func (s *Service) ProcessMessage(ctx context.Context, msg *Message) error

type Statistics

type Statistics struct {
	ProcessedMessages int `json:"processed_messages"`
}