router

Jul 17, 2024

Changes in this version

+ type GatewayURLQuerier struct

+ func NewGatewayURLQuerier(kubeClient kubernetes.Interface, ...) *GatewayURLQuerier

+ func (q *GatewayURLQuerier) CachedGatewayURLs(agentID int64) []string

+ func (q *GatewayURLQuerier) PollGatewayURLs(ctx context.Context, agentID int64, cb tunserver.PollGatewayURLsCallback)

+ func (q *GatewayURLQuerier) Run(ctx context.Context) error

+ type Plugin struct

+ API modshared.API

+ AgentkPool grpctool.PoolInterface

+ Creds credentials.PerRPCCredentials

+ GatewayQuerier tunserver.PollingGatewayURLQuerier

+ OwnPrivateAPIURL string

+ PollConfig retry.PollConfigFactory

+ Registry *Registry

+ TryNewGatewayInterval time.Duration

+ TunnelFindTimeout time.Duration

+ func (p *Plugin) FindReadyGateway(ctx context.Context, log *slog.Logger, method string) (tunserver.ReadyGateway, *slog.Logger, int64, error)

+ func (p *Plugin) FindTunnel(stream grpc.ServerStream, rpcAPI modshared.RPCAPI) (bool, *slog.Logger, tunserver.FindHandle, error)

+ func (p *Plugin) PrepareStreamForForwarding(stream grpc.ServerStream) (grpc.ServerStream, error)

+ type Registry struct

+ func NewRegistry(log *slog.Logger) *Registry

+ func (r *Registry) FindTunnel(ctx context.Context, service, method string) (bool, tunserver.FindHandle)

+ func (r *Registry) HandleTunnel(ageCtx context.Context, server rpc.ReverseTunnel_ConnectServer) error