zhangdeman/event
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

feat: 移除chan方法约束

Browse Source
This commit is contained in:
白茶清欢
2026-01-25 22:19:24 +08:00
parent 652fd36634
commit c008bee4a2
2 changed files with 0 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
abstract/IEvent.go
View File

@@ -40,8 +40,6 @@ type IEvent interface {
SendEvent(ctx context.Context, eventData *define.EventData) (*define.SendResult, error)
// SendEventAsync 发送事件(异步)
SendEventAsync(ctx context.Context, eventData *define.EventData, sendSuccessCallback SendSuccessCallback, sendFailCallback SendFailCallback)
// GetConsumeEventChan 或去消息消费的channel, 自行实现消费
GetConsumeEventChan(ctx context.Context) (<-chan *define.EventData, error)
// ConsumeEvent 消费事件
ConsumeEvent(ctx context.Context, handler EventHandler, successCallback ConsumeSuccessCallback, failureCallback ConsumeFailCallbackHandler) error
// Destroy 事件实例销毁时, 执行的方法

5
redis_queue.go
View File

@@ -36,11 +36,6 @@ func (r *RedisEventQueue) SendEventAsync(ctx context.Context, eventData *define.
panic("implement me")
}
func (r *RedisEventQueue) GetConsumeEventChan(ctx context.Context) (<-chan *define.EventData, error) {
//TODO implement me
panic("implement me")
}
func (r *RedisEventQueue) ConsumeEvent(ctx context.Context, handler abstract.EventHandler, successCallback abstract.ConsumeSuccessCallback, failureCallback abstract.ConsumeFailCallbackHandler) error {
//TODO implement me
panic("implement me")