broker

func ConnectToOrigin ¶

func ConnectToOrigin(ctx context.Context, brokerUrl, prefix, originName string) (conn net.Conn, err error)

Given an origin's broker URL, return a connected socket to the origin

func LaunchNamespaceKeyMaintenance ¶

func LaunchNamespaceKeyMaintenance(ctx context.Context, egrp *errgroup.Group)

Launches a background goroutine that periodically expires the namespace key cache

func LaunchRequestMonitor ¶

func LaunchRequestMonitor(ctx context.Context, egrp *errgroup.Group, resultChan chan any) (err error)

Launch a goroutine that polls the broker endpoint for reversal requests The returned channel will produce listeners that are "one shot"; it's a TLS listener where you can invoke "Accept" once before it automatically closes itself. It is the result of a successful connection reversal to a cache.

func RegisterBroker ¶

func RegisterBroker(ctx context.Context, router *gin.RouterGroup)

func RegisterBrokerCallback ¶

func RegisterBrokerCallback(ctx context.Context, router *gin.RouterGroup)

Register the HTTP handlers for the callback to a cache