ack

Documentation

Index

• Variables
• func Event(event string) string
• func IsAckEvent(event string) bool
• type Acker
  • func NewAcker(reqCtx context.Context, closeCh chan struct{}) *Acker
  • func (a *Acker) Await() ([]byte, error)
  • func (a *Acker) Notify(data []byte)
• type Ackers
  • func NewAckers() *Ackers
  • func (a *Ackers) RegisterAck(reqId uint64, reqCtx context.Context, closeCh chan struct{}) *Acker
  • func (a *Ackers) TryAck(reqId uint64, data []byte) bool
  • func (a *Ackers) UnregisterAck(reqId uint64)

Variables

var (
	ErrRequestTimeout = errors.New("ack: timeout")
	ErrConnClose      = errors.New("ack: connection closed")
)

Functions

func Event

func Event(event string) string

func IsAckEvent

func IsAckEvent(event string) bool

Types

type Acker

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

func NewAcker

func NewAcker(reqCtx context.Context, closeCh chan struct{}) *Acker

func (*Acker) Await

func (a *Acker) Await() ([]byte, error)

func (*Acker) Notify

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

type Ackers

type Ackers struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewAckers

func NewAckers() *Ackers

func (*Ackers) RegisterAck

func (a *Ackers) RegisterAck(reqId uint64, reqCtx context.Context, closeCh chan struct{}) *Acker

func (*Ackers) TryAck

func (a *Ackers) TryAck(reqId uint64, data []byte) bool

func (*Ackers) UnregisterAck

func (a *Ackers) UnregisterAck(reqId uint64)