The highest tagged major version is v4.

internal

package

v3.2.0 Latest Latest Go to latest Published: Aug 13, 2024 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func IsAckEvent(event string) bool

func ToAckEvent(event string) string

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

func NewAck(id uint64) *Ack

func (a *Ack) Id() uint64

func (a *Ack) Notify(data []byte)

func (a *Ack) Wait(ctx context.Context) ([]byte, error)

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

func NewAcks() *Acks

func (a *Acks) DeleteAck(ackId uint64)

func (a *Acks) NextAck() *Ack

func (a *Acks) NotifyAck(ackId uint64, data []byte)

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

func NewIdGenerator() *IdGenerator

func (g *IdGenerator) Next() uint64