httpClient

package
v0.0.0-...-632c06c Latest Latest
Warning

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

Go to latest
Published: Oct 16, 2022 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var WriteBufferSize = 0

Functions

This section is empty.

Types

type ProviderClient

type ProviderClient struct {
	HttpRequestEndpoint string
	MaxTxConnection     int
	MaxRxConnection     int

	MaxBoostTxConnection int
	MaxBoostRxConnection int

	TxChan chan []byte
	RxChan chan []byte

	ID []byte
	// contains filtered or unexported fields
}

func NewProviderClient

func NewProviderClient(HttpRequestEndpoint string,
	MaxTxConnection int,
	MaxRxConnection int,
	password string, ctx context.Context) *ProviderClient

func (*ProviderClient) AsConn

func (pc *ProviderClient) AsConn() net.Conn

func (*ProviderClient) BoostingListener

func (pc *ProviderClient) BoostingListener()

func (*ProviderClient) Close

func (pc *ProviderClient) Close() error

func (*ProviderClient) DialRxConnection

func (pc *ProviderClient) DialRxConnection(ctx context.Context)

func (*ProviderClient) DialRxConnectionD

func (pc *ProviderClient) DialRxConnectionD(ctx context.Context)

func (*ProviderClient) DialRxTestConnection

func (pc *ProviderClient) DialRxTestConnection(TestSize int) int

func (*ProviderClient) DialTxConnection

func (pc *ProviderClient) DialTxConnection(ctx context.Context)

func (*ProviderClient) DialTxConnectionD

func (pc *ProviderClient) DialTxConnectionD(ctx context.Context)

func (*ProviderClient) DialTxConnectionTest

func (pc *ProviderClient) DialTxConnectionTest(TestSize int) int

func (*ProviderClient) DialWsAlternativeChannelConnection

func (pc *ProviderClient) DialWsAlternativeChannelConnection(ctx context.Context) io.ReadWriteCloser

func (*ProviderClient) DialWsConnection

func (pc *ProviderClient) DialWsConnection(ctx context.Context)

func (*ProviderClient) DialWsConnectionD

func (pc *ProviderClient) DialWsConnectionD(ctx context.Context)

func (*ProviderClient) GetConnCtx

func (pc *ProviderClient) GetConnCtx() context.Context

func (*ProviderClient) StartConnections

func (pc *ProviderClient) StartConnections()

func (*ProviderClient) StartConnectionsWS

func (pc *ProviderClient) StartConnectionsWS()

type ProviderClientCreator

type ProviderClientCreator struct {
	HttpRequestEndpoint string
	MaxTxConnection     int
	MaxRxConnection     int
	// contains filtered or unexported fields
}

func NewProviderClientCreator

func NewProviderClientCreator(HttpRequestEndpoint string,
	MaxTxConnection int,
	MaxRxConnection int,
	password string, ctx context.Context) *ProviderClientCreator

func (ProviderClientCreator) Connect

func (ProviderClientCreator) ConnectL

Jump to

Keyboard shortcuts

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