definition

Documentation

Index

• type Consumer
• type ProducerOption
• type WorkQueueProducer

Types

type Consumer

type Consumer struct {
	Handler     func(ctx context.Context, payload []byte) error
	Concurrency int
	MaxRetry    int
	Timeout     time.Duration
}

Consumer ...

type ProducerOption

type ProducerOption struct {
	Tx *query.Query
}

ProducerOption ...

type WorkQueueProducer

type WorkQueueProducer interface {
	// Produce ...
	Produce(ctx context.Context, topic enums.Daemon, payload any, option ProducerOption) error
}

WorkQueueProducer ...