httpClient

package
v0.0.0-...-75fa4b0 Latest Latest
Warning

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

 Go to latest Published: Dec 25, 2023 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 (p ProviderClientCreator) Connect(ctx context.Context) (net.Conn, error, context.Context)

func (ProviderClientCreator) ConnectL 

func (p ProviderClientCreator) ConnectL(ctx context.Context) *ProviderClient

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.