router

type AgentFinder interface {
	AgentLastConnected(ctx context.Context, agentKey api.AgentKey) (time.Time, error)
}

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

type Handler interface {
	// HandleTunnel is called with server-side interface of the reverse tunnel.
	// It registers the tunnel and blocks, waiting for a request to proxy through the tunnel.
	// The method returns the error value to return to gRPC framework.
	// ageCtx can be used to unblock the method if the tunnel is not being used already.
	HandleTunnel(ageCtx context.Context, agentKey api.AgentKey, server grpc.BidiStreamingServer[rpc.ConnectRequest, rpc.ConnectResponse]) error
}

type MultiURL struct {
	Scheme  string   `protobuf:"bytes,1,opt,name=scheme" json:"scheme,omitempty"`
	Ip      [][]byte `protobuf:"bytes,2,rep,name=ip" json:"ip,omitempty"`
	Host    string   `protobuf:"bytes,3,opt,name=host" json:"host,omitempty"`
	TlsHost string   `protobuf:"bytes,4,opt,name=tls_host,json=tlsHost" json:"tls_host,omitempty"`
	Port    uint32   `protobuf:"varint,5,opt,name=port" json:"port,omitempty"`
	// contains filtered or unexported fields
}

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

type Querier interface {
	// KASURLsByAgentKey returns the list of kas URLs for a particular agent key.
	// A partial list may be returned together with an error.
	// Safe for concurrent use.
	KASURLsByAgentKey(ctx context.Context, agentKey api.AgentKey) ([]nettool.MultiURL, error)
}

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

type Registerer interface {
	RegistrationBuilder() RegistrationBuilder
	// GC deletes expired tunnels from the underlying storage.
	GC(ctx context.Context, agentKeys []api.AgentKey) (int, error)
}

type RegistrationBuilder interface {
	// Register registers tunnels for the given agent ids with the tracker.
	Register(ttl time.Duration, agentKeys ...api.AgentKey)
	// Unregister unregisters tunnels for the given agent ids with the tracker.
	Unregister(agentKeys ...api.AgentKey)
	// Refresh refreshes registered tunnels in the underlying storage.
	Refresh(ttl time.Duration, agentKeys ...api.AgentKey)
	// Do executes the enqueued operations.
	Do(context.Context) error
}

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

type Tracker interface {
	Registerer
	Querier
}

type TunnelFinder interface {
	FindTunnel(ctx context.Context, agentKey api.AgentKey, service, method string) (bool, tunserver.FindHandle)
}