consumer

package

v0.0.1 Latest Latest Go to latest Published: Dec 24, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Kafka mq.KafkaConfig
}

Config 消费者配置

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

Consumer 异步任务消费者 TODO: 重新设计用于 Zep 风格的异步处理（如 Community 检测等）

func NewConsumer(memory *action.Memory, cfg Config) (*Consumer, error)

NewConsumer 创建消费者

func (c *Consumer) Start(ctx context.Context) error

Start 启动所有消费者

func (c *Consumer) Stop() error

Stop 停止所有消费者