| /dports/net/storj/storj-1.45.3/vendor/gopkg.in/segmentio/analytics-go.v3/ |
| H A D | analytics.go | 42 type client struct { struct
43 Config
44 key string
49 msgs chan Message
56 quit chan struct{}
57 shutdown chan struct{}
61 http http.Client
211 func (c *client) Close() (err error) {
247 func (c *client) send(msgs []message) {
327 func (c *client) loop() {
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/imap/ |
| H A D | imap-client.h | 151 struct client { struct
152 struct client *prev, *next; argument
158 int fd_in, fd_out;
159 struct io *io;
162 struct timeout *to_idle, *to_idle_output, *to_delayed_input;
186 struct client_command_context *command_queue; argument
210 /* client input/output is locked by this command */ argument
225 bool logged_out:1;
227 bool hibernated:1;
251 struct imap_client_vfuncs super; argument
[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/common/quic/gquic-go/h2quic/ |
| H A D | client.go | 30 type client struct { struct
31 mutex sync.RWMutex
33 tlsConf *tls.Config
34 config *quic.Config
35 opts *roundTripperOpts
37 hostname string
38 handshakeErr error
39 dialOnce sync.Once
46 sessionMutex sync.Mutex
47 closed bool
[all …]
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/quic/gquic-go/h2quic/ |
| H A D | client.go | 30 type client struct { struct
31 mutex sync.RWMutex
33 tlsConf *tls.Config
34 config *quic.Config
35 opts *roundTripperOpts
37 hostname string
38 handshakeErr error
39 dialOnce sync.Once
46 sessionMutex sync.Mutex
47 closed bool
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/imap-urlauth/ |
| H A D | imap-urlauth-client.h | 13 struct client { struct
14 struct client *prev, *next; argument
34 extern struct client *imap_urlauth_clients; argument
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/libcontainerd/ |
| H A D | client_daemon.go | 102 type client struct { struct
103 sync.RWMutex // protects containers map
105 client *containerd.Client member
106 stateDir string
107 logger *logrus.Entry
108 ns string
110 backend Backend
111 eventQ queue
112 containers map[string]*container
620 func (c *client) getContainer(id string) *container {
[all …]
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/libcontainerd/ |
| H A D | client_daemon.go | 102 type client struct { struct
103 sync.RWMutex // protects containers map
105 client *containerd.Client argument
106 stateDir string
107 logger *logrus.Entry
108 ns string
110 backend Backend
111 eventQ queue
112 containers map[string]*container
634 func (c *client) getContainer(id string) *container {
[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/common/quic/gquic-go/ |
| H A D | client.go | 20 type client struct { struct
21 mutex sync.Mutex
23 conn connection
26 createdPacketConn bool
30 token []byte
36 tlsConf *tls.Config
37 mintConf *mint.Config
38 config *Config
46 handshakeChan chan struct{}
49 session quicSession
[all …]
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/common/quic/gquic-go/ |
| H A D | client.go | 20 type client struct { struct
21 mutex sync.Mutex
23 conn connection
26 createdPacketConn bool
30 token []byte
36 tlsConf *tls.Config
37 mintConf *mint.Config
38 config *Config
46 handshakeChan chan struct{}
49 session quicSession
[all …]
|
| /dports/x11-wm/oroborus/oroborus-2.0.20/src/ |
| H A D | client.h | 97 struct client struct
106 int x, /**< top left corner of the client. */ argument
107 y, /**< top left corner of the client. */ argument
108 width, height, /**< dimensions of the client. */ argument
119 CARD32 margins[4]; /**< the space, the client wants to "reserve" at the desktop border, argument
123 char *name; /**< the clients name */ argument
124 XSizeHints *size; /**< client size hints, see man XSizeHints. */ argument
131 …r example the gnome desktop specifies a window layer which is typically below each other client. */ argument
134 focus, /**< the client has the focus. */ argument
136 client_t *next; /**< pointer to the next client. */ argument
[all …]
|
| /dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
| H A D | client.go | 82 type client struct { struct
83 *xdsclient.TransportHelper
85 ctx context.Context
86 cancelCtx context.CancelFunc
87 parent xdsclient.UpdateHandler
88 logger *grpclog.PrefixLogger
91 cc *grpc.ClientConn
92 nodeProto *v2corepb.Node
94 mu sync.Mutex
100 ldsResourceName string
[all …]
|
| /dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/xds/internal/client/v3/ |
| H A D | client.go | 82 type client struct { struct
83 *xdsclient.TransportHelper
85 ctx context.Context
86 cancelCtx context.CancelFunc
87 parent xdsclient.UpdateHandler
88 logger *grpclog.PrefixLogger
91 cc *grpc.ClientConn
92 nodeProto *v3corepb.Node
94 mu sync.Mutex
100 ldsResourceName string
[all …]
|
| /dports/audio/murmur-cli/murmur-cli-8f83169/vendor/google.golang.org/grpc/xds/internal/balancer/ |
| H A D | xds_client.go | 48 type client struct { struct
51 serviceName string
54 channelzParentID int64
57 cleanup func()
60 loadStore lrs.Store
61 loadReportOnce sync.Once
64 mu sync.Mutex
65 cc *grpc.ClientConn
68 func (c *client) run() {
73 func (c *client) close() {
[all …]
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/google.golang.org/grpc/xds/internal/balancer/ |
| H A D | xds_client.go | 48 type client struct { struct
51 serviceName string
54 channelzParentID int64
57 cleanup func()
60 loadStore lrs.Store
61 loadReportOnce sync.Once
64 mu sync.Mutex
65 cc *grpc.ClientConn
68 func (c *client) run() {
73 func (c *client) close() {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/google.golang.org/grpc/xds/internal/client/v2/ |
| H A D | client.go | 86 type client struct { struct
87 *xdsclient.TransportHelper
89 ctx context.Context
90 cancelCtx context.CancelFunc
92 loadStore *load.Store
93 logger *grpclog.PrefixLogger
96 cc *grpc.ClientConn
97 nodeProto *v2corepb.Node
99 mu sync.Mutex
105 ldsResourceName string
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/google.golang.org/grpc/xds/internal/client/v3/ |
| H A D | client.go | 86 type client struct { struct
87 *xdsclient.TransportHelper
89 ctx context.Context
90 cancelCtx context.CancelFunc
92 loadStore *load.Store
93 logger *grpclog.PrefixLogger
96 cc *grpc.ClientConn
97 nodeProto *v3corepb.Node
99 mu sync.Mutex
105 ldsResourceName string
[all …]
|
| /dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/balancer/xds/ |
| H A D | xds_client.go | 58 type client struct { struct
59 ctx context.Context
65 enableCDS bool
68 cleanup func()
71 loadStore lrs.Store
72 loadReportOnce sync.Once
74 mu sync.Mutex
75 cc *grpc.ClientConn
78 func (c *client) run() {
83 func (c *client) close() {
[all …]
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/grpc/grpc-go-1.21.1/balancer/xds/ |
| H A D | xds_client.go | 60 type client struct { struct
61 ctx context.Context
67 enableCDS bool
70 cleanup func()
73 loadStore lrs.Store
74 loadReportOnce sync.Once
76 mu sync.Mutex
77 cc *grpc.ClientConn
80 func (c *client) run() {
85 func (c *client) close() {
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/google.golang.org/grpc/grpc-go-1.23.0/xds/internal/balancer/ |
| H A D | xds_client.go | 58 type client struct { struct
59 ctx context.Context
65 enableCDS bool
68 cleanup func()
71 loadStore lrs.Store
72 loadReportOnce sync.Once
74 mu sync.Mutex
75 cc *grpc.ClientConn
78 func (c *client) run() {
83 func (c *client) close() {
[all …]
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/lucas-clemente/quic-go/h2quic/ |
| H A D | client.go | 30 type client struct { struct
31 mutex sync.RWMutex
33 tlsConf *tls.Config
34 config *quic.Config
35 opts *roundTripperOpts
37 hostname string
38 handshakeErr error
39 dialOnce sync.Once
42 session quic.Session
43 headerStream quic.Stream
[all …]
|
| /dports/net/grpcox/grpcox-1.0.0/vendor/google.golang.org/grpc/balancer/xds/ |
| H A D | xds_client.go | 60 type client struct { struct
61 ctx context.Context
67 enableCDS bool
70 cleanup func()
73 loadStore lrs.Store
74 loadReportOnce sync.Once
76 mu sync.Mutex
77 cc *grpc.ClientConn
80 func (c *client) run() {
85 func (c *client) close() {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/network/ |
| H A D | client.go | 53 type client struct { struct
54 http.Client
55 url *url.URL
56 caFile string
57 certFile string
58 keyFile string
59 caData []byte
60 updateTime time.Time
61 lastUpdate string
65 requester requester
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/go-kivik/pouchdb/ |
| H A D | pouchdb.go | 61 type client struct { struct
62 dsn *url.URL
63 opts map[string]Options
64 pouch *bindings.PouchDB
67 replications []*replication
68 replicationsMU sync.RWMutex
75 func (c *client) AllDBs(ctx context.Context, _ map[string]interface{}) ([]string, error) {
82 func (c *client) Version(_ context.Context) (*driver.Version, error) {
91 func (c *client) dbURL(db string) string {
104 func (c *client) options(options ...Options) (Options, error) {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/google.golang.org/grpc/balancer/xds/ |
| H A D | xds_client.go | 59 type client struct { struct
60 ctx context.Context
61 cancel context.CancelFunc
66 enableCDS bool
69 cleanup func()
70 backoff backoff.Strategy
72 mu sync.Mutex
73 cc *grpc.ClientConn
76 func (c *client) run() {
81 func (c *client) close() {
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetrichttp/ |
| H A D | client.go | 61 type client struct { struct
62 name string
63 cfg otlpconfig.SignalConfig
64 generalCfg otlpconfig.Config
65 client *http.Client member
66 stopCh chan struct{}
122 func (d *client) Start(ctx context.Context) error {
133 func (d *client) Stop(ctx context.Context) error {
155 func (d *client) send(ctx context.Context, rawRequest []byte) error {
189 func (d *client) getScheme() string {
[all …]
|