internal

package

v1.6.3 Latest Latest Go to latest Published: May 2, 2025 License: MIT Imports: 6 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 {
}

func NewIdGenerator() *IdGenerator

func (g *IdGenerator) Next() string

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

func NewSequenceGenerator() *SequenceGenerator

func (g *SequenceGenerator) Next() uint64