pending

Documentation

Index

• type Handler
  • func NewHandler(size int) Handler
  • func (pending *Handler) DecPending()
  • func (pending *Handler) IncPending()
  • func (pending *Handler) QueueRequest(baseCtx context.Context, timeout time.Duration, ...)
  • func (pending *Handler) WaitForPending(ctx context.Context)

Types

type Handler

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

Handler handles waiting for pending requests and responses

func NewHandler

func NewHandler(size int) Handler

NewHandler new instance of PendingHandler

func (*Handler) DecPending

func (pending *Handler) DecPending()

DecPending increase finished requests

func (*Handler) IncPending

func (pending *Handler) IncPending()

IncPending increase pending requests

func (*Handler) QueueRequest

func (pending *Handler) QueueRequest(baseCtx context.Context, timeout time.Duration,
	f func(ctx context.Context) error, logEntry *logger.LogEntry, onFinished func(err error))

QueueRequest Async request,

func (*Handler) WaitForPending

func (pending *Handler) WaitForPending(ctx context.Context)

WaitForPending uses double locking of mutex to wait until mutex is unlocked by loop listening for pending req/resp