app

Documentation

Index

• func Dump(cfg *config.Config) error
• func Monitor(cfg *config.Config) error
• type MessageProcessor
  • func NewMessageProcessor(cfg *config.Config) (*MessageProcessor, error)
  • func (mp *MessageProcessor) Dump() error
  • func (mp *MessageProcessor) Monitor() error

Functions

func Dump

func Dump(cfg *config.Config) error

Dump is a package-level function for convenience

func Monitor

func Monitor(cfg *config.Config) error

Monitor is a package-level function for convenience

Types

type MessageProcessor

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

MessageProcessor handles the core logic of processing messages

func NewMessageProcessor

func NewMessageProcessor(cfg *config.Config) (*MessageProcessor, error)

NewMessageProcessor creates a new MessageProcessor

func (*MessageProcessor) Dump

func (mp *MessageProcessor) Dump() error

Dump processes messages from the main queue

func (*MessageProcessor) Monitor

func (mp *MessageProcessor) Monitor() error

Monitor creates a temporary queue and processes messages