httpClient

Documentation

Index

• Variables
• type ProviderClient
  • func NewProviderClient(HttpRequestEndpoint string, MaxTxConnection int, MaxRxConnection int, ...) *ProviderClient
  • func (pc *ProviderClient) AsConn() net.Conn
  • func (pc *ProviderClient) BoostingListener()
  • func (pc *ProviderClient) Close() error
  • func (pc *ProviderClient) DialRxConnection(ctx context.Context)
  • func (pc *ProviderClient) DialRxConnectionD(ctx context.Context)
  • func (pc *ProviderClient) DialRxTestConnection(TestSize int) int
  • func (pc *ProviderClient) DialTxConnection(ctx context.Context)
  • func (pc *ProviderClient) DialTxConnectionD(ctx context.Context)
  • func (pc *ProviderClient) DialTxConnectionTest(TestSize int) int
  • func (pc *ProviderClient) DialWsAlternativeChannelConnection(ctx context.Context) io.ReadWriteCloser
  • func (pc *ProviderClient) DialWsConnection(ctx context.Context)
  • func (pc *ProviderClient) DialWsConnectionD(ctx context.Context)
  • func (pc *ProviderClient) GetConnCtx() context.Context
  • func (pc *ProviderClient) StartConnections()
  • func (pc *ProviderClient) StartConnectionsWS()
• type ProviderClientCreator
  • func NewProviderClientCreator(HttpRequestEndpoint string, MaxTxConnection int, MaxRxConnection int, ...) *ProviderClientCreator
  • func (p ProviderClientCreator) Connect(ctx context.Context) (net.Conn, error, context.Context)
  • func (p ProviderClientCreator) ConnectL(ctx context.Context) *ProviderClient

Variables

var WriteBufferSize = 0

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