Documentation ¶
Index ¶
- type PubSubWorkersManager
- func (p *PubSubWorkersManager) Ack(workerCtx context.Context, msg pulsar.Message) error
- func (p *PubSubWorkersManager) Done() bool
- func (p *PubSubWorkersManager) Nack(workerCtx context.Context, msg pulsar.Message)
- func (p *PubSubWorkersManager) Receive(workerCtx context.Context) (pulsar.Message, error)
- func (p *PubSubWorkersManager) Send(workerCtx context.Context, msg *pulsar.ProducerMessage) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PubSubWorkersManager ¶
type PubSubWorkersManager struct {
// contains filtered or unexported fields
}
func NewPubSubWorkersManager ¶
func (*PubSubWorkersManager) Done ¶
func (p *PubSubWorkersManager) Done() bool
func (*PubSubWorkersManager) Nack ¶
func (p *PubSubWorkersManager) Nack(workerCtx context.Context, msg pulsar.Message)
func (*PubSubWorkersManager) Send ¶
func (p *PubSubWorkersManager) Send(workerCtx context.Context, msg *pulsar.ProducerMessage) error
Click to show internal directories.
Click to hide internal directories.