kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-02 00:15:43 +03:00
Code Issues Packages Projects Releases Wiki Activity
Files
cd8f3c616f6e886a71d0e4e8181bbd3575656222
nomad/command/agent
History
Mahmood Ali ab4b42f4f4 exec: http: close websocket connection gracefully 
In this loop, we ought to close the websocket connection gracefully when
the StreamErrWrapper reaches EOF.

Previously, it's possible that that we drop the last few events or skip sending
the websocket closure. If `handler(handlerPipe)` returns and `cancel` is called,
before the loop here completes processing streaming events, the loop exits
prematurely without propagating the last few events.

Instead here, the loop continues until we hit `httpPipe` EOF (through
`decoder.Decode`), to ensure we process the events to completion.
2021-05-24 13:37:23 -04:00
..
consul
Support disabling TCP checks for connect sidecar services
2021-05-07 12:10:26 -04:00
event
make auditor interface more explicit
2020-03-23 19:32:58 -04:00
host
api: nomad debug new /agent/host (#8325)
2020-07-02 09:51:25 -04:00
monitor
unlock before returning, no need for label
2019-11-05 11:44:29 -05:00
pprof
Apply some suggested fixes from staticcheck (#9598)
2020-12-10 07:29:18 -08:00
test-resources
chore: Format hcl configurations
2019-07-20 16:55:07 +02:00
testdata
configuration and oss components for licensing (#10216)
2021-03-23 09:08:14 -04:00
acl_endpoint_test.go
command/agent: fix dropped test errors
2021-04-13 01:51:24 -07:00
acl_endpoint.go
HTTP API support for 'nomad ui -login'
2021-03-10 08:17:56 -05:00
agent_endpoint_test.go
tests: deflake some SetServer related tests
2020-04-07 09:27:48 -04:00
agent_endpoint.go
fix AgentHostRequest panic found in GH-9546 (#9554)
2020-12-07 17:34:40 -05:00
agent_oss.go
Oss license support for ent builds (#8054)
2020-05-27 13:46:52 -04:00
agent_test.go
agent: add test for reserved core config mapping
2021-04-13 13:28:15 -04:00
agent.go
licensing: remove raft storage and sync
2021-04-28 10:28:23 -04:00
alloc_endpoint_test.go
documenting test for #9367
2020-11-15 17:47:50 +00:00
alloc_endpoint.go
exec: http: close websocket connection gracefully
2021-05-24 13:37:23 -04:00
bindata_assetfs.go
Generate files for 1.1.0-rc1 release
2021-05-12 22:43:48 +00:00
command_test.go
Merge pull request #9027 from hashicorp/f-gh-9026
2020-10-06 08:28:18 +02:00
command.go
configuration and oss components for licensing (#10216)
2021-03-23 09:08:14 -04:00
config_oss.go
removes pro tags (#8014)
2020-05-28 15:40:17 -04:00
config_parse_test.go
configuration and oss components for licensing (#10216)
2021-03-23 09:08:14 -04:00
config_parse.go
multi-interface network support
2020-06-19 09:42:10 -04:00
config_test.go
Enable go-sockaddr templating for network-interface (#10404)
2021-04-20 13:55:10 -04:00
config.go
licensing: remove raft storage and sync
2021-04-28 10:28:23 -04:00
csi_endpoint_test.go
CSI: capability block is required for volume registration
2021-04-08 13:02:24 -04:00
csi_endpoint.go
CSI: fix wrong output struct for snapshot list endpoint
2021-04-07 12:00:33 -04:00
deployment_endpoint_test.go
Events/msgtype cleanup (#9117)
2020-10-19 09:30:15 -04:00
deployment_endpoint.go
use constants from http package
2020-06-17 11:04:02 -04:00
eval_endpoint_test.go
Events/msgtype cleanup (#9117)
2020-10-19 09:30:15 -04:00
eval_endpoint.go
…
event_endpoint_test.go
Remove Managed Sinks from Nomad (#9470)
2020-11-30 14:00:31 -05:00
event_endpoint.go
return 405 on non-GET requests to /v1/event/stream (fixes #9526) (#9564)
2020-12-08 13:09:20 -05:00
fs_endpoint_test.go
Events/msgtype cleanup (#9117)
2020-10-19 09:30:15 -04:00
fs_endpoint.go
fixup! vendor: explicit use of hashicorp/go-msgpack
2020-03-31 09:48:07 -04:00
helpers_test.go
test: fix missing agent shutdowns
2020-02-07 15:50:53 -08:00
helpers.go
client: expose task state to client
2018-10-16 16:56:55 -07:00
http_oss.go
Add handling for license requests in OSS (#9963)
2021-02-08 12:53:06 -06:00
http_stdlog_test.go
agent: route http logs through hclog
2020-04-20 10:33:40 -04:00
http_stdlog.go
agent: route http logs through hclog
2020-04-20 10:33:40 -04:00
http_test.go
added missing import from command/agent
2021-04-02 13:53:28 +00:00
http.go
api: implement fuzzy search API
2021-04-16 16:36:07 -06:00
job_endpoint_test.go
Support disabling TCP checks for connect sidecar services
2021-05-07 12:10:26 -04:00
job_endpoint.go
Support disabling TCP checks for connect sidecar services
2021-05-07 12:10:26 -04:00
keyring_test.go
Fix other usages of initKeyring func to use logger as third argument
2020-10-01 11:13:06 -04:00
keyring.go
Log AES-128 and AES-192 key sizes during keyring initialization
2020-10-01 11:12:14 -04:00
log_file_test.go
logging: Sort files when pruning old logs
2019-10-10 13:51:16 +02:00
log_file.go
logging: Correctly track number of written bytes
2019-10-10 14:02:14 +02:00
log_levels_test.go
…
log_levels.go
Support for hot reloading log levels
2019-07-24 13:37:08 +02:00
metrics_endpoint_test.go
agent: return req error if prometheus metrics are disabled.
2021-03-09 15:28:58 +01:00
metrics_endpoint.go
agent: return req error if prometheus metrics are disabled.
2021-03-09 15:28:58 +01:00
namespace_endpoint_test.go
core: open source namespaces
2020-10-22 15:26:32 -07:00
namespace_endpoint.go
core: open source namespaces
2020-10-22 15:26:32 -07:00
node_endpoint_test.go
Node Drain Metadata (#10250)
2021-05-07 13:58:40 -04:00
node_endpoint.go
Node Drain Metadata (#10250)
2021-05-07 13:58:40 -04:00
operator_endpoint_oss.go
Add handling for license requests in OSS (#9963)
2021-02-08 12:53:06 -06:00
operator_endpoint_test.go
api: actually set MemoryOversubscriptionEnabled (#10493)
2021-05-02 22:53:53 -04:00
operator_endpoint.go
api: actually set MemoryOversubscriptionEnabled (#10493)
2021-05-02 22:53:53 -04:00
plugins.go
move pluginutils -> helper/pluginutils
2019-01-22 15:50:08 -08:00
region_endpoint_test.go
…
region_endpoint.go
…
retry_join_test.go
agent + consul
2018-09-13 10:43:40 -07:00
retry_join.go
agent + consul
2018-09-13 10:43:40 -07:00
scaling_endpoint_test.go
added new policy capabilities for recommendations API
2020-10-28 14:32:16 +00:00
scaling_endpoint.go
Add gocritic to golangci-lint config (#9556)
2020-12-08 12:47:04 -08:00
search_endpoint_test.go
api: implement fuzzy search API
2021-04-16 16:36:07 -06:00
search_endpoint.go
api: implement fuzzy search API
2021-04-16 16:36:07 -06:00
stats_endpoint_test.go
Fix failing test TestClientStatusRequest
2018-05-30 15:11:54 -05:00
stats_endpoint.go
Server side impl + touch ups
2018-02-15 13:59:02 -08:00
status_endpoint_test.go
…
status_endpoint.go
…
stub_asset.go
…
syslog_test.go
goimports
2019-01-22 15:44:31 -08:00
syslog.go
goimports
2019-01-22 15:44:31 -08:00
system_endpoint_test.go
…
system_endpoint.go
…
testagent_oss.go
licensing: remove raft storage and sync
2021-04-28 10:28:23 -04:00
testagent.go
licensing: remove raft storage and sync
2021-04-28 10:28:23 -04:00
testingutils_test.go
mock: add default host network
2020-11-23 10:11:00 -06:00