common

package
v0.0.0-...-5ee457c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

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 (t *IOContext) AcquireFetchToken() (err error)

func (*IOContext) ConcludeExtend

func (t *IOContext) ConcludeExtend()

func (*IOContext) Context

func (t *IOContext) Context() context.Context

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) Get

func (p *IOContextPool) Get(ctx context.Context) *IOContext

func (*IOContextPool) Put

func (p *IOContextPool) Put(t *IOContext)

Directories

Path Synopsis
x

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL