| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/ |
| H A D | controller.go | 46 type Controller struct { struct
54 establishedOnce bool
55 tunnelPoolSize int
57 nextTunnel int
58 isEstablishing bool
62 establishConnectTunnelCount int
63 concurrentEstablishTunnels int
64 concurrentIntensiveEstablishTunnels int
65 peakConcurrentEstablishTunnels int
66 peakConcurrentIntensiveEstablishTunnels int
[all …]
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/ |
| H A D | controller.go | 47 type Controller struct { struct
55 establishedOnce bool
56 tunnelPoolSize int
58 nextTunnel int
63 establishConnectTunnelCount int
64 concurrentEstablishTunnels int
65 concurrentIntensiveEstablishTunnels int
66 peakConcurrentEstablishTunnels int
67 peakConcurrentIntensiveEstablishTunnels int
76 splitTunnelClassificationMaxEntries int
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pilot/pkg/serviceregistry/consul/ |
| H A D | controller.go | 35 type Controller struct { struct
36 client *api.Client
37 monitor Monitor
39 servicesList []*model.Service
41 cacheMutex sync.Mutex
42 initDone bool
43 clusterID string
69 func (c *Controller) Cluster() string {
218 func (c *Controller) Run(stop <-chan struct{}) {
253 func (c *Controller) initCache() error {
[all …]
|
| /dports/multimedia/navidrome/navidrome-0.40.0/vendor/github.com/astaxie/beego/ |
| H A D | controller.go | 90 Ctx *context.Context
94 controllerName string
95 actionName string
100 TplName string
101 ViewPath string
102 Layout string
104 TplPrefix string
106 EnableRender bool
109 _xsrfToken string
110 XSRFExpire int
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/go.opentelemetry.io/otel/sdk/metric/controller/basic/ |
| H A D | controller.go | 57 type Controller struct { struct
58 lock sync.Mutex
59 accumulator *sdk.Accumulator
61 checkpointer export.Checkpointer
62 exporter export.Exporter
63 wg sync.WaitGroup
64 stopCh chan struct{}
68 collectPeriod time.Duration
69 collectTimeout time.Duration
70 pushTimeout time.Duration
[all …]
|
| /dports/games/automuteus/automuteus-6.15.2/vendor/go.opentelemetry.io/otel/sdk/metric/controller/basic/ |
| H A D | controller.go | 57 type Controller struct { struct
58 lock sync.Mutex
59 accumulator *sdk.Accumulator
61 checkpointer export.Checkpointer
62 exporter export.Exporter
63 wg sync.WaitGroup
64 stopCh chan struct{}
68 collectPeriod time.Duration
69 collectTimeout time.Duration
70 pushTimeout time.Duration
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.opentelemetry.io/otel/sdk/metric/controller/basic/ |
| H A D | controller.go | 57 type Controller struct { struct
58 lock sync.Mutex
59 accumulator *sdk.Accumulator
61 checkpointer export.Checkpointer
62 exporter export.Exporter
63 wg sync.WaitGroup
64 stopCh chan struct{}
68 collectPeriod time.Duration
69 collectTimeout time.Duration
70 pushTimeout time.Duration
[all …]
|
| /dports/net/storj/storj-1.45.3/vendor/go.opentelemetry.io/otel/sdk/metric/controller/basic/ |
| H A D | controller.go | 57 type Controller struct { struct
58 lock sync.Mutex
59 accumulator *sdk.Accumulator
61 checkpointer export.Checkpointer
62 pusher export.Exporter
63 wg sync.WaitGroup
64 stopCh chan struct{}
68 collectPeriod time.Duration
69 collectTimeout time.Duration
70 pushTimeout time.Duration
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/endpointslice/ |
| H A D | endpointslice_controller.go | 180 type Controller struct { struct
181 client clientset.Interface
190 servicesSynced cache.InformerSynced
194 podLister corelisters.PodLister
197 podsSynced cache.InformerSynced
212 nodeLister corelisters.NodeLister
215 nodesSynced cache.InformerSynced
218 reconciler *reconciler
233 maxEndpointsPerSlice int32
237 workerLoopPeriod time.Duration
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/endpointslicemirroring/ |
| H A D | endpointslicemirroring_controller.go | 149 type Controller struct { struct
150 client clientset.Interface
152 eventRecorder record.EventRecorder
160 endpointsSynced cache.InformerSynced
177 serviceLister corelisters.ServiceLister
181 servicesSynced cache.InformerSynced
184 reconciler *reconciler
191 queue workqueue.RateLimitingInterface
195 maxEndpointsPerSubset int32
199 workerLoopPeriod time.Duration
[all …]
|
| /dports/databases/tile38/tile38-1.12.0/controller/ |
| H A D | controller.go | 64 host string
65 port int
66 http bool
67 dir string
68 started time.Time
69 config *Config
84 connsmu sync.RWMutex
87 exlistmu sync.RWMutex
88 exlist []exitem
90 mu sync.RWMutex
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/sdk/metric/controller/basic/ |
| H A D | controller.go | 58 type Controller struct { struct
60 lock sync.Mutex
69 resource *resource.Resource
70 exporter export.Exporter
71 wg sync.WaitGroup
72 stopCh chan struct{}
73 clock controllerTime.Clock
76 collectPeriod time.Duration
77 collectTimeout time.Duration
78 pushTimeout time.Duration
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/controller-runtime/pkg/internal/controller/ |
| H A D | controller.go | 46 type Controller struct { struct
48 Name string
51 MaxConcurrentReconciles int
56 Do reconcile.Reconciler
59 Client client.Client
62 Scheme *runtime.Scheme
65 Cache cache.Cache
69 Config *rest.Config
84 mu sync.Mutex
94 Started bool
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/sigs.k8s.io/service-apis/vendor/sigs.k8s.io/controller-runtime/pkg/internal/controller/ |
| H A D | controller.go | 46 type Controller struct { struct
48 Name string
51 MaxConcurrentReconciles int
56 Do reconcile.Reconciler
59 Client client.Client
62 Scheme *runtime.Scheme
65 Cache cache.Cache
69 Config *rest.Config
84 mu sync.Mutex
94 Started bool
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controlplane/ |
| H A D | controller.go | 51 type Controller struct { struct
55 readyzClient rest.Interface
69 EndpointInterval time.Duration
74 PublicIP net.IP
77 ServiceIP net.IP
78 ServicePort int
81 PublicServicePort int
82 KubernetesServiceNodePort int
84 runner *async.Runner
144 func (c *Controller) Start() {
[all …]
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/cmd/ooniprobe/internal/nettests/ |
| H A D | nettests.go | 20 Run(*Controller) error
36 type Controller struct { struct
37 Probe *ooni.Probe
40 nt Nettest
41 ntCount int
42 ntIndex int
50 InputFiles []string
54 Inputs []string
58 RunType string
61 numInputs int
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/google.golang.org/grpc/xds/internal/xdsclient/controller/ |
| H A D | controller.go | 51 type Controller struct { struct
53 updateHandler pubsub.UpdateHandler
55 logger *grpclog.PrefixLogger
59 stopRunGoroutine context.CancelFunc
61 backoff func(int) time.Duration
62 streamCh chan grpc.ClientStream
63 sendCh *buffer.Unbounded
65 mu sync.Mutex
87 lrsMu sync.Mutex
88 lrsClients map[string]*lrsClient
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/volume/pvcprotection/ |
| H A D | pvc_protection_controller.go | 44 type Controller struct { struct
45 client clientset.Interface
48 pvcListerSynced cache.InformerSynced
50 podLister corelisters.PodLister
51 podListerSynced cache.InformerSynced
52 podIndexer cache.Indexer
54 queue workqueue.RateLimitingInterface
57 storageObjectInUseProtectionEnabled bool
60 genericEphemeralVolumeFeatureEnabled bool
124 func (c *Controller) runWorker() {
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/nodelifecycle/ |
| H A D | node_lifecycle_controller.go | 261 type Controller struct { struct
270 now func() metav1.Time
276 knownNodeSet map[string]*v1.Node
278 nodeHealthMap *nodeHealthMap
282 evictorLock sync.Mutex
283 nodeEvictionMap *nodeEvictionMap
289 nodesToRetry sync.Map
291 zoneStates map[string]ZoneState
303 recorder record.EventRecorder
309 nodeMonitorPeriod time.Duration
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pilot/pkg/serviceregistry/aggregate/ |
| H A D | controller.go | 42 type Controller struct { struct
43 registries []serviceregistry.Instance
44 storeLock sync.RWMutex
55 func (c *Controller) AddRegistry(registry serviceregistry.Instance) {
65 func (c *Controller) DeleteRegistry(clusterID string) {
85 func (c *Controller) GetRegistries() []serviceregistry.Instance {
93 func (c *Controller) GetRegistryIndex(clusterID string) (int, bool) {
103 func (c *Controller) Services() ([]*model.Service, error) {
206 func (c *Controller) ManagementPorts(addr string) model.PortList {
228 func (c *Controller) InstancesByPort(svc *model.Service, port int,
[all …]
|
| /dports/security/vuls/vuls-0.13.7/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/ |
| H A D | push.go | 34 type Controller struct { struct
35 lock sync.Mutex
36 accumulator *sdk.Accumulator
39 exporter export.Exporter
40 wg sync.WaitGroup
41 ch chan struct{}
42 period time.Duration
43 timeout time.Duration
93 func (c *Controller) Start() {
108 func (c *Controller) Stop() {
[all …]
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/ |
| H A D | push.go | 34 type Controller struct { struct
35 lock sync.Mutex
36 accumulator *sdk.Accumulator
39 exporter export.Exporter
40 wg sync.WaitGroup
41 ch chan struct{}
42 period time.Duration
43 timeout time.Duration
93 func (c *Controller) Start() {
108 func (c *Controller) Stop() {
[all …]
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/go.opentelemetry.io/otel/sdk/metric/controller/push/ |
| H A D | push.go | 34 type Controller struct { struct
35 lock sync.Mutex
36 accumulator *sdk.Accumulator
39 exporter export.Exporter
40 wg sync.WaitGroup
41 ch chan struct{}
42 period time.Duration
43 timeout time.Duration
93 func (c *Controller) Start() {
108 func (c *Controller) Stop() {
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/storageversiongc/ |
| H A D | gc_controller.go | 45 type Controller struct { struct
46 kubeclientset kubernetes.Interface
48 leaseLister coordlisters.LeaseLister
49 leasesSynced cache.InformerSynced
51 storageVersionSynced cache.InformerSynced
53 leaseQueue workqueue.RateLimitingInterface
54 storageVersionQueue workqueue.RateLimitingInterface
81 func (c *Controller) Run(stopCh <-chan struct{}) {
105 func (c *Controller) runLeaseWorker() {
110 func (c *Controller) processNextLease() bool {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/apiextensions-apiserver/pkg/controller/openapi/ |
| H A D | controller.go | 44 type Controller struct { struct
45 crdLister listers.CustomResourceDefinitionLister
46 crdsSynced cache.InformerSynced
49 syncFn func(string) error
51 queue workqueue.RateLimitingInterface
53 staticSpec *spec.Swagger
54 openAPIService *handler.OpenAPIService
57 lock sync.Mutex
58 crdSpecs map[string]map[string]*spec.Swagger
125 func (c *Controller) runWorker() {
[all …]
|