outbox_processor

Documentation

Index

• func NewStorage(tableName string, pool *pgxpool.Pool) *storage
• type KafkaProducer
• type Message
• type Service
  • func New(tableName string, topicName string, pool *pgxpool.Pool, producer KafkaProducer) *Service
  • func (s *Service) Publish(ctx context.Context)
• type Storage

Functions

func NewStorage

func NewStorage(tableName string, pool *pgxpool.Pool) *storage

Types

type KafkaProducer

type KafkaProducer interface {
	ProduceMessage(topic string, messageBytes []byte)
}

type Message

type Message struct {
	ID      int64  `db:"id"`
	Message string `db:"message"`
}

type Service

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

func New

func New(
	tableName string,
	topicName string,
	pool *pgxpool.Pool,
	producer KafkaProducer,
) *Service

func (*Service) Publish

func (s *Service) Publish(ctx context.Context)

type Storage

type Storage interface {
	ListOutboxMessages(ctx context.Context, limit uint64) ([]*Message, error)
	DeleteOutboxMessages(ctx context.Context, ids []int64) error
}