pool

Documentation

Index

• Constants
• Variables
• type ConnPool
  • func New(strategy Strategy) *ConnPool
  • func (p *ConnPool) BestArchiveClient(ctx context.Context) (*liteclient.Client, ton.BlockIDExt, error)
  • func (p *ConnPool) BestClientByAccountID(ctx context.Context, accountID ton.AccountID, archiveRequired bool) (*liteclient.Client, ton.BlockIDExt, error)
  • func (p *ConnPool) BestClientByBlockID(ctx context.Context, blockID ton.BlockID) (*liteclient.Client, error)
  • func (p *ConnPool) BestMasterchainClient(ctx context.Context) (*liteclient.Client, ton.BlockIDExt, error)
  • func (p *ConnPool) BestMasterchainInfoClient() *MasterchainInfoClient
  • func (p *ConnPool) ConnectionsNumber() int
  • func (p *ConnPool) InitializeConnections(ctx context.Context, timeout time.Duration, maxConnections int, ...) chan error
  • func (p *ConnPool) Run(ctx context.Context)
  • func (p *ConnPool) WaitMasterchainSeqno(ctx context.Context, seqno uint32, timeout time.Duration) error
• type MasterchainInfoClient
  • func (s *MasterchainInfoClient) LiteServerGetMasterchainInfo(ctx context.Context) (liteclient.LiteServerMasterchainInfoC, error)
  • func (s *MasterchainInfoClient) LiteServerGetMasterchainInfoExt(ctx context.Context, request liteclient.LiteServerGetMasterchainInfoExtRequest) (res liteclient.LiteServerMasterchainInfoExtC, err error)
• type Strategy

Constants

const (
	BestPingStrategy       = "best-ping"
	FirstWorkingConnection = "first-working"
)

Variables

var (
	ErrNoConnections = fmt.Errorf("no connections available")
)

Types

type ConnPool

type ConnPool struct {
	// contains filtered or unexported fields
}

ConnPool is a pool of connections to lite servers that implements two different strategy:

1. BestPingStrategy - it'll switch to a connection with the best ping.
2. FirstWorkingConnection - it'll switch to the first working connection.

For both strategies, a connection has to be not more than 1 block behind the head of masterchain to be considered as working.

func New

func New(strategy Strategy) *ConnPool

New returns a new instance of a connections pool.

func (*ConnPool) BestArchiveClient

func (p *ConnPool) BestArchiveClient(ctx context.Context) (*liteclient.Client, ton.BlockIDExt, error)

func (*ConnPool) BestClientByAccountID

func (p *ConnPool) BestClientByAccountID(ctx context.Context, accountID ton.AccountID, archiveRequired bool) (*liteclient.Client, ton.BlockIDExt, error)

BestClientByAccountID returns a liteclient and its known masterchain head.

func (*ConnPool) BestClientByBlockID

func (p *ConnPool) BestClientByBlockID(ctx context.Context, blockID ton.BlockID) (*liteclient.Client, error)

BestClientByBlockID returns a liteclient and its known masterchain head.

func (*ConnPool) BestMasterchainClient

func (p *ConnPool) BestMasterchainClient(ctx context.Context) (*liteclient.Client, ton.BlockIDExt, error)

BestMasterchainClient returns a liteclient and its known masterchain head.

func (*ConnPool) BestMasterchainInfoClient

func (p *ConnPool) BestMasterchainInfoClient() *MasterchainInfoClient

func (*ConnPool) ConnectionsNumber

func (p *ConnPool) ConnectionsNumber() int

ConnectionsNumber returns a number of connections in this pool.

func (*ConnPool) InitializeConnections

func (p *ConnPool) InitializeConnections(ctx context.Context, timeout time.Duration, maxConnections int, detectArchiveNodes bool, servers []config.LiteServer) chan error

func (*ConnPool) Run

func (p *ConnPool) Run(ctx context.Context)

func (*ConnPool) WaitMasterchainSeqno

func (p *ConnPool) WaitMasterchainSeqno(ctx context.Context, seqno uint32, timeout time.Duration) error

type MasterchainInfoClient

type MasterchainInfoClient struct {
	// contains filtered or unexported fields
}

func (*MasterchainInfoClient) LiteServerGetMasterchainInfo

func (s *MasterchainInfoClient) LiteServerGetMasterchainInfo(ctx context.Context) (liteclient.LiteServerMasterchainInfoC, error)

func (*MasterchainInfoClient) LiteServerGetMasterchainInfoExt

func (s *MasterchainInfoClient) LiteServerGetMasterchainInfoExt(ctx context.Context, request liteclient.LiteServerGetMasterchainInfoExtRequest) (res liteclient.LiteServerMasterchainInfoExtC, err error)

type Strategy

type Strategy string