Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler handles waiting for pending requests and responses
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 ¶
WaitForPending uses double locking of mutex to wait until mutex is unlocked by loop listening for pending req/resp
Source Files
Click to show internal directories.
Click to hide internal directories.