// Package abstract ...
//
// Description : abstract ...
//
// Author : go_developer@163.com<白茶清欢>
//
// Date : 2025-08-27 08:54
package abstract

import (
	"context"

	"git.zhangdeman.cn/zhangdeman/queue/define"
)

// IConsumerHandler 消费者的一些处理逻辑
type IConsumerHandler interface {
	Lock(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData) error                             // 加锁
	Unlock(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData) error                           // 释放锁
	MessageLogic(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData) error                     // 处理订阅到的消息
	PanicCallback(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData, e any)                   // 出现异常panic的回调
	SubscribeFailureCallback(ctx context.Context, serverInfo *define.EventConsumerServerInfo, err error)                            // 订阅失败的回调
	UnmarshalFailureCallback(ctx context.Context, serverInfo *define.EventConsumerServerInfo, msgData string, err error)            // 数据解析失败的回调
	Async(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData) bool                             // 每一条数据可独立判断是否进行异步处理
	LockFailureCallback(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData, err error)         // 加锁失败的回调
	UnlockFailureCallback(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData, err error)       // 释放锁失败的回调
	MessageLogicFailureCallback(ctx context.Context, serverInfo *define.EventConsumerServerInfo, data *define.EventData, err error) // 消息数据处理失败的回调
}