tunclient

Documentation

Index

• func APIDescriptor(server *grpc.Server) *info.APIDescriptor
• type Connection
  • func (c *Connection) Run(attemptCtx, pollCtx context.Context)
• type ConnectionFactory
• type ConnectionInterface
• type ConnectionManager
  • func NewConnectionManager(minIdleConnections, maxConnections, scaleUpStep int32, ...) *ConnectionManager
  • func (m *ConnectionManager) Run(ctx context.Context)

Functions

func APIDescriptor

func APIDescriptor(server *grpc.Server) *info.APIDescriptor

Types

type Connection

type Connection struct {
	Log                *zap.Logger
	Descriptor         *info.APIDescriptor
	Client             rpc.ReverseTunnelClient
	InternalServerConn grpc.ClientConnInterface
	PollConfig         retry.PollConfigFactory
	OnActive           func(ConnectionInterface)
	OnIdle             func(ConnectionInterface)
}

func (*Connection) Run

func (c *Connection) Run(attemptCtx, pollCtx context.Context)

type ConnectionFactory

type ConnectionFactory func(descriptor *info.APIDescriptor, onActive, onIdle func(ConnectionInterface)) ConnectionInterface

ConnectionFactory helps to inject fake connections for testing.

type ConnectionInterface

type ConnectionInterface interface {
	Run(attemptCtx, pollCtx context.Context)
}

type ConnectionManager

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

ConnectionManager manages a pool of connections and their lifecycles.

func NewConnectionManager

func NewConnectionManager(minIdleConnections, maxConnections, scaleUpStep int32, maxIdleTime time.Duration,
	descriptor *info.APIDescriptor, connectionFactory ConnectionFactory) *ConnectionManager

func (*ConnectionManager) Run

func (m *ConnectionManager) Run(ctx context.Context)