Documentation ¶
Index ¶
- type IOContext
- func (t *IOContext) AcquireFetchToken() (err error)
- func (t *IOContext) ConcludeExtend()
- func (t *IOContext) Context() context.Context
- func (t *IOContext) ExtendContext()
- func (t *IOContext) GetHeadersProxy() *shared.HeadersProxy
- func (t *IOContext) RegisterCleanup(c func())
- func (t *IOContext) ReleaseFetchToken()
- type IOContextPool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IOContext ¶
type IOContext struct {
// contains filtered or unexported fields
}
func (*IOContext) AcquireFetchToken ¶
func (*IOContext) ConcludeExtend ¶
func (t *IOContext) ConcludeExtend()
func (*IOContext) ExtendContext ¶
func (t *IOContext) ExtendContext()
func (*IOContext) GetHeadersProxy ¶
func (t *IOContext) GetHeadersProxy() *shared.HeadersProxy
func (*IOContext) RegisterCleanup ¶
func (t *IOContext) RegisterCleanup(c func())
func (*IOContext) ReleaseFetchToken ¶
func (t *IOContext) ReleaseFetchToken()
type IOContextPool ¶
type IOContextPool struct {
// contains filtered or unexported fields
}
func NewIOContextPool ¶
func NewIOContextPool(logger *zap.Logger, hp *shared.HeadersProxyPool, concurrent int64) *IOContextPool
func (*IOContextPool) Put ¶
func (p *IOContextPool) Put(t *IOContext)
Click to show internal directories.
Click to hide internal directories.