Lines Matching defs:Controller

47 type Controller struct {  struct
48 	config                                  *Config
49 	runCtx                                  context.Context
50 	stopRunning                             context.CancelFunc
51 	runWaitGroup                            *sync.WaitGroup
52 	connectedTunnels                        chan *Tunnel
53 	failedTunnels                           chan *Tunnel
54 	tunnelMutex                             sync.Mutex
55 	establishedOnce                         bool
56 	tunnelPoolSize                          int
57 	tunnels                                 []*Tunnel
58 	nextTunnel                              int
59 	isEstablishing                          bool
60 	establishStartTime                      time.Time
61 	protocolSelectionConstraints            *protocolSelectionConstraints
62 	concurrentEstablishTunnelsMutex         sync.Mutex
63 	establishConnectTunnelCount             int
64 	concurrentEstablishTunnels              int
65 	concurrentIntensiveEstablishTunnels     int
66 	peakConcurrentEstablishTunnels          int
67 	peakConcurrentIntensiveEstablishTunnels int
68 	establishCtx                            context.Context
69 	stopEstablish                           context.CancelFunc
70 	establishWaitGroup                      *sync.WaitGroup
71 	establishedTunnelsCount                 int32
72 	candidateServerEntries                  chan *candidateServerEntry
73 	untunneledDialConfig                    *DialConfig
74 	untunneledSplitTunnelClassifications    *lrucache.Cache
75 	splitTunnelClassificationTTL            time.Duration
76 	splitTunnelClassificationMaxEntries     int
77 	signalFetchCommonRemoteServerList       chan struct{}
78 	signalFetchObfuscatedServerLists        chan struct{}
79 	signalDownloadUpgrade                   chan string
80 	signalReportServerEntries               chan *serverEntriesReportRequest
81 	signalReportConnected                   chan struct{}
82 	signalRestartEstablishing               chan struct{}
83 	serverAffinityDoneBroadcast             chan struct{}
84 	packetTunnelClient                      *tun.Client
85 	packetTunnelTransport                   *PacketTunnelTransport
86 	staggerMutex                            sync.Mutex
189 func (controller *Controller) Run(ctx context.Context) {
305 func (controller *Controller) SignalComponentFailure() {
313 func (controller *Controller) SetDynamicConfig(sponsorID string, authorizations []string) {
319 func (controller *Controller) TerminateNextActiveTunnel() {
330 func (controller *Controller) ExportExchangePayload() string {
347 func (controller *Controller) ImportExchangePayload(payload string) bool {
369 func (controller *Controller) remoteServerListFetcher(
460 func (controller *Controller) upgradeDownloader() {
572 func (controller *Controller) serverEntriesReporter() {
697 func (controller *Controller) signalServerEntriesReporter(request *serverEntriesReportRequest) {
723 func (controller *Controller) connectedReporter() {
784 func (controller *Controller) signalConnectedReporter() {
802 func (controller *Controller) establishTunnelWatcher() {
839 func (controller *Controller) runTunnels() {
1029 func (controller *Controller) SignalSeededNewSLOK() {
1040 func (controller *Controller) SignalTunnelFailure(tunnel *Tunnel) {
1053 func (controller *Controller) discardTunnel(tunnel *Tunnel) {
1065 func (controller *Controller) registerTunnel(tunnel *Tunnel) bool {
1099 func (controller *Controller) hasEstablishedOnce() bool {
1106 func (controller *Controller) isFullyEstablished() bool {
1115 func (controller *Controller) numTunnels() (int, int) {
1126 func (controller *Controller) terminateTunnel(tunnel *Tunnel) {
1148 func (controller *Controller) terminateAllTunnels() {
1171 func (controller *Controller) getNextActiveTunnel() (tunnel *Tunnel) {
1185 func (controller *Controller) isActiveTunnelServerEntry(
1198 func (controller *Controller) setTunnelPoolSize(tunnelPoolSize int) {
1210 func (controller *Controller) getTunnelPoolSize() int {
1227 func (controller *Controller) Dial(
1320 func (controller *Controller) DirectDial(remoteAddr string) (conn net.Conn, err error) {
1329 func (controller *Controller) triggerFetches() {
1461 func (controller *Controller) startEstablishing() {
1519 func (controller *Controller) launchEstablishing() {
1748 func (controller *Controller) stopEstablishing() {
1786 func (controller *Controller) establishCandidateGenerator() {
1984 func (controller *Controller) establishTunnelWorker() {
2285 func (controller *Controller) isStopEstablishing() bool {