43 lines
539 B
Go
43 lines
539 B
Go
|
package kgo
|
||
|
|
|
||
|
|
import (
|
||
|
|
"sync"
|
||
|
|
|
||
|
|
"go.unistack.org/micro/v3/broker"
|
||
|
|
)
|
||
|
|
|
||
|
|
type event struct {
|
||
|
|
topic string
|
||
|
|
err error
|
||
|
|
sync.RWMutex
|
||
|
|
msg *broker.Message
|
||
|
|
ack bool
|
||
|
|
}
|
||
|
|
|
||
|
|
func (p *event) Topic() string {
|
||
|
|
return p.topic
|
||
|
|
}
|
||
|
|
|
||
|
|
func (p *event) Message() *broker.Message {
|
||
|
|
return p.msg
|
||
|
|
}
|
||
|
|
|
||
|
|
func (p *event) Ack() error {
|
||
|
|
p.ack = true
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (p *event) Error() error {
|
||
|
|
return p.err
|
||
|
|
}
|
||
|
|
|
||
|
|
func (p *event) SetError(err error) {
|
||
|
|
p.err = err
|
||
|
|
}
|
||
|
|
|
||
|
|
var eventPool = sync.Pool{
|
||
|
|
New: func() interface{} {
|
||
|
|
return &event{msg: &broker.Message{}}
|
||
|
|
},
|
||
|
|
}
|