logmq

type BatchAdder ¶ added in v0.13.0

type BatchAdder interface {
	Add(ctx context.Context, msg *mqs.Message) error
}

BatchAdder is the interface for adding messages to a batch processor.

type BatchProcessor ¶ added in v0.13.0

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

BatchProcessor batches log entries and writes them to the log store.

func NewBatchProcessor(ctx context.Context, logger *logging.Logger, logStore LogStore, cfg BatchProcessorConfig) (*BatchProcessor, error)

func (bp *BatchProcessor) Add(ctx context.Context, msg *mqs.Message) error

func (bp *BatchProcessor) Shutdown()

type BatchProcessorConfig ¶ added in v0.13.0

type BatchProcessorConfig struct {
	ItemCountThreshold int
	DelayThreshold     time.Duration
}

BatchProcessorConfig configures the batch processor.

type LogInfra ¶

type LogInfra interface {
	DeclareInfrastructure(ctx context.Context) error
}

type LogMQ ¶

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

func New(opts ...func(opts *LogMQOption)) *LogMQ

func (q *LogMQ) Init(ctx context.Context) (func(), error)

func (q *LogMQ) Publish(ctx context.Context, entry models.LogEntry) error

func (q *LogMQ) Subscribe(ctx context.Context) (mqs.Subscription, error)

type LogMQOption ¶

type LogMQOption struct {
	QueueConfig *mqs.QueueConfig
}

type LogStore ¶ added in v0.13.0

type LogStore interface {
	InsertMany(ctx context.Context, entries []*models.LogEntry) error
}

LogStore defines the interface for persisting log entries. This is a consumer-defined interface containing only what logmq needs.