| /dports/devel/py-azure-core/azure-core-1.20.1/tests/ |
| H A D | test_rest_stream_responses.py | 25 def test_iter_raw(client): argument
39 def test_iter_raw_on_iterable(client): argument
48 def test_iter_with_error(client): argument
67 def test_iter_bytes(client): argument
83 def test_iter_text(client): argument
92 def test_iter_lines(client): argument
101 def test_sync_streaming_response(client): argument
152 def test_compress_plain_no_header(client): argument
183 def test_iter_read(client): argument
220 def test_error_reading(client): argument
[all …]
|
| /dports/www/beehive/beehive-0.4.0/vendor/github.com/flashmob/go-guerrilla/ |
| H A D | client.go | 35 type client struct { struct
36 *mail.Envelope
37 ID uint64
38 ConnectedAt time.Time
39 KilledAt time.Time
41 errors int
43 messagesSent int
46 bufErr error
47 conn net.Conn
53 connGuard sync.Mutex
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/siddontang/ledisdb/server/ |
| H A D | cmd_zset.go | 19 func zaddCommand(c *client) error {
52 func zcardCommand(c *client) error {
67 func zscoreCommand(c *client) error {
86 func zremCommand(c *client) error {
101 func zincrbyCommand(c *client) error {
193 func zcountCommand(c *client) error {
218 func zrankCommand(c *client) error {
235 func zrevrankCommand(c *client) error {
342 func zrangeCommand(c *client) error {
428 func zclearCommand(c *client) error {
[all …]
|
| H A D | cmd_set.go | 7 func saddCommand(c *client) error {
77 func scardCommand(c *client) error {
92 func sdiffCommand(c *client) error {
100 func sinterCommand(c *client) error {
124 func smembersCommand(c *client) error {
140 func sremCommand(c *client) error {
156 func sunionCommand(c *client) error {
164 func sclearCommand(c *client) error {
179 func smclearCommand(c *client) error {
194 func sexpireCommand(c *client) error {
[all …]
|
| H A D | cmd_hash.go | 7 func hsetCommand(c *client) error {
22 func hgetCommand(c *client) error {
37 func hexistsCommand(c *client) error {
56 func hdelCommand(c *client) error {
71 func hlenCommand(c *client) error {
86 func hincrbyCommand(c *client) error {
106 func hmsetCommand(c *client) error {
135 func hmgetCommand(c *client) error {
165 func hkeysCommand(c *client) error {
180 func hvalsCommand(c *client) error {
[all …]
|
| /dports/net/trickle/trickle-1.07/ |
| H A D | client.h | 17 struct client { struct
19 int s;
43 TAILQ_ENTRY(client) nextq; argument
|
| /dports/comms/conserver-com/conserver-8.2.4/conserver/ |
| H A D | client.h | 60 short fwr; /* (client) write enable flag */ argument
61 short fwantwr; /* (client) wants to write */ argument
64 short fiwait; /* client wanting for console init */ argument
65 STRING *acid; /* login and location of client */ argument
72 *pCEto; /* host a client gets output from */ argument
75 *pCLscan, /* next client fd to scan after select */ argument
79 /* next lists link clients on a console */ argument
80 char ic[2]; /* two character escape sequence */
84 char caccess; /* did we trust the remote machine */
86 time_t stateTimer; /* timer for various ioState states */
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/ |
| H A D | client.go | 93 type client struct { struct
94 conf *Config
95 closer, closed chan none // for shutting down background metadata updater
100 seedBrokers []*Broker
101 deadSeeds []*Broker
172 func (client *client) Config() *Config {
176 func (client *client) Brokers() []*Broker {
186 func (client *client) Close() error {
217 func (client *client) Closed() bool {
504 func (client *client) resurrectDeadBrokers() {
[all …]
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/Shopify/sarama/sarama-1.19.0/ |
| H A D | client.go | 93 type client struct { struct
94 conf *Config
95 closer, closed chan none // for shutting down background metadata updater
100 seedBrokers []*Broker
101 deadSeeds []*Broker
172 func (client *client) Config() *Config {
176 func (client *client) Brokers() []*Broker {
186 func (client *client) Close() error {
217 func (client *client) Closed() bool {
504 func (client *client) resurrectDeadBrokers() {
[all …]
|
| /dports/www/py-google-cloud-dlp/google-cloud-dlp-3.3.1/tests/system/gapic/v2/ |
| H A D | test_system_dlp_service_v2_vpcsc.py | 30 def client(): function
35 def name_inside(client): argument
40 def name_outside(client): argument
120 def inspect_template_path_inside(client): argument
128 def inspect_template_path_outside(client): argument
212 def deidentify_template_path_inside(client): argument
400 def job_trigger_path_inside(client): argument
406 def job_trigger_path_outside(client): argument
483 def stored_info_type_path_inside(client): argument
491 def stored_info_type_path_outside(client): argument
[all …]
|
| /dports/devel/py-azure-core/azure-core-1.20.1/tests/async_tests/ |
| H A D | test_rest_stream_responses_async.py | 12 async def test_iter_raw(client): argument
21 async def test_iter_raw_on_iterable(client): argument
31 async def test_iter_with_error(client): argument
56 async def test_iter_bytes(client): argument
71 async def test_iter_text(client): argument
82 async def test_iter_lines(client): argument
93 async def test_streaming_response(client): argument
144 async def test_compress_plain_no_header(client): argument
158 async def test_iter_read_back_and_forth(client): argument
192 async def test_error_reading(client): argument
[all …]
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/eclipse/paho.mqtt.golang/ |
| H A D | client.go | 66 type client struct { struct
67 sync.RWMutex
68 messageIds
69 conn net.Conn
73 msgRouter *router
74 stopRouter chan bool
76 errors chan error
78 persist Store
80 pingResp *sync.Cond
81 packetResp *sync.Cond
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/Godeps/_workspace/src/github.com/Shopify/sarama/ |
| H A D | client.go | 81 type client struct { struct
82 conf *Config
83 closer, closed chan none // for shutting down background metadata updater
88 seedBrokers []*Broker
89 deadSeeds []*Broker
155 func (client *client) Config() *Config {
159 func (client *client) Close() error {
189 func (client *client) Closed() bool {
193 func (client *client) Topics() ([]string, error) {
410 func (client *client) resurrectDeadBrokers() {
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/login-common/ |
| H A D | client-common.h | 154 struct client { struct
155 struct client *prev, *next; argument
162 struct client_vfuncs v; argument
180 const char *client_cert_common_name; argument
198 const struct dsasl_client_mech *proxy_mech; argument
203 struct auth_client_request *auth_request; argument
217 enum client_auth_fail_code last_auth_fail; argument
223 char *virtual_user, *virtual_user_orig, *virtual_auth_user;
238 bool starttls:1;
262 union login_client_module_context { argument
[all …]
|
| /dports/mail/dovecot/dovecot-2.3.17/src/old-stats/ |
| H A D | client.h | 4 struct client { struct
5 struct client *prev, *next; argument
14 struct client_export_cmd *cmd_export; argument
15 int (*cmd_more)(struct client *client); argument
27 struct client *client_create(int fd); argument
|
| /dports/databases/tile38/tile38-1.12.0/vendor/github.com/Shopify/sarama/ |
| H A D | client.go | 90 type client struct { struct
91 conf *Config
92 closer, closed chan none // for shutting down background metadata updater
97 seedBrokers []*Broker
98 deadSeeds []*Broker
166 func (client *client) Config() *Config {
170 func (client *client) Brokers() []*Broker {
180 func (client *client) Close() error {
210 func (client *client) Closed() bool {
456 func (client *client) resurrectDeadBrokers() {
[all …]
|
| /dports/games/automuteus/automuteus-6.15.2/vendor/github.com/googollee/go-socket.io/engineio/ |
| H A D | client.go | 80 type client struct { struct
81 conn base.Conn
82 params base.ConnParameters
83 transport string
84 context interface{}
85 close chan struct{}
86 closeOnce sync.Once
97 func (c *client) ID() string {
105 func (c *client) Close() error {
135 func (c *client) URL() url.URL {
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/libcontainerd/ |
| H A D | client_daemon.go | 102 type client struct { struct
103 sync.RWMutex // protects containers map
105 remote *containerd.Client
106 stateDir string
107 logger *logrus.Entry
109 namespace string
110 backend Backend
111 eventQ queue
112 containers map[string]*container
115 func (c *client) reconnect() error {
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/rudderlabs/analytics-go/ |
| H A D | analytics.go | 47 type client struct { struct
48 Config
49 key string
54 msgs chan Message
61 quit chan struct{}
62 shutdown chan struct{}
63 totalNodes int
66 http http.Client
276 func (c *client) Close() (err error) {
341 func (c *client) setNodeCount() {
[all …]
|
| /dports/net/tightvnc/vnc_unixsrc/Xvnc/programs/Xserver/dix/ |
| H A D | swapreq.c | 134 SProcSimpleReq(client) in SProcSimpleReq() argument
327 SProcSendEvent(client) in SProcSendEvent() argument
422 SProcGrabKey(client) in SProcGrabKey() argument
509 SProcOpenFont(client) in SProcOpenFont() argument
576 SProcCreateGC(client) in SProcCreateGC() argument
591 SProcChangeGC(client) in SProcChangeGC() argument
605 SProcCopyGC(client) in SProcCopyGC() argument
665 SProcCopyArea(client) in SProcCopyArea() argument
708 SProcPoly(client) in SProcPoly() argument
726 SProcFillPoly(client) in SProcFillPoly() argument
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/docker/libcontainerd/ |
| H A D | client_windows.go | 21 type client struct { struct
22 clientCommon
374 func (clnt *client) Signal(containerID string, sig int) error {
430 func (clnt *client) Resize(containerID, processFriendlyName string, width, height int) error {
458 func (clnt *client) Pause(containerID string) error {
497 func (clnt *client) Resume(containerID string) error {
537 func (clnt *client) Stats(containerID string) (*Stats, error) {
566 func (clnt *client) GetPidsForContainer(containerID string) ([]int, error) {
590 func (clnt *client) Summary(containerID string) ([]Summary, error) {
611 func (clnt *client) UpdateResources(containerID string, resources Resources) error {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/libcontainerd/ |
| H A D | client_daemon.go | 103 type client struct { struct
104 sync.RWMutex // protects containers map
106 remote *containerd.Client
107 stateDir string
108 logger *logrus.Entry
110 namespace string
111 backend Backend
112 eventQ queue
113 containers map[string]*container
576 func (c *client) getContainer(id string) *container {
[all …]
|
| /dports/sysutils/hared/hared-hare-1.0-45-g8341d8a/vendor/github.com/eclipse/paho.mqtt.golang/ |
| H A D | client.go | 67 type client struct { struct
68 sync.RWMutex
69 messageIds
70 conn net.Conn
74 msgRouter *router
75 stopRouter chan bool
77 errors chan error
78 stop chan struct{}
79 persist Store
80 options ClientOptions
[all …]
|
| /dports/net/concourse-fly/concourse-6.7.1/vendor/github.com/concourse/baggageclaim/client/ |
| H A D | client.go | 1 package client package
28 type client struct { struct
29 requestGenerator *rata.RequestGenerator
31 retryBackOffFactory retryhttp.BackOffFactory
32 nestedRoundTripper http.RoundTripper
34 givenHttpClient *http.Client
54 func (c *client) httpClient(logger lager.Logger) *http.Client {
178 func (c *client) DestroyVolumes(logger lager.Logger, handles []string) error {
206 func (c *client) DestroyVolume(logger lager.Logger, handle string) error {
345 func (c *client) destroy(logger lager.Logger, handle string) error {
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/baggageclaim/client/ |
| H A D | client.go | 1 package client package
28 type client struct { struct
29 requestGenerator *rata.RequestGenerator
31 retryBackOffFactory retryhttp.BackOffFactory
32 nestedRoundTripper http.RoundTripper
34 givenHttpClient *http.Client
54 func (c *client) httpClient(logger lager.Logger) *http.Client {
178 func (c *client) DestroyVolumes(logger lager.Logger, handles []string) error {
206 func (c *client) DestroyVolume(logger lager.Logger, handle string) error {
345 func (c *client) destroy(logger lager.Logger, handle string) error {
[all …]
|