pool

Documentation

Index

• Constants
• type Pool
• type Service
  • func New() Service

Constants

const (
	CName = "common.net.pool"
)

Types

type Pool

type Pool interface {
	// Get lookups to peer in existing connections or creates and outgoing new one
	Get(ctx context.Context, id string) (peer.Peer, error)
	// GetOneOf searches at least one existing connection in outgoing or creates a new one from a randomly selected id from given list
	GetOneOf(ctx context.Context, peerIds []string) (peer.Peer, error)
	// AddPeer adds incoming peer to the pool
	AddPeer(ctx context.Context, p peer.Peer) (err error)
	// Pick check if connection with peer exist without dial
	Pick(ctx context.Context, id string) (pr peer.Peer, err error)
}

Pool creates and caches outgoing connection

type Service

type Service interface {
	Pool
	app.ComponentRunnable
}

func New

func New() Service